seg_yinzy
/
myems
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Added 'excelexporters.spaceoutput.export()' method

pull/4/head
YangZhang-GitHub 2021-03-04 20:34:03 +08:00
parent 7796eeed5f
commit 22ba6615f4
1 changed files with 15 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
myems-api/reports/spaceoutput.py
View File

@ -5,6 +5,7 @@ import config
from datetime import datetime, timedelta, timezone from datetime import datetime, timedelta, timezone
from core import utilities from core import utilities
from decimal import Decimal from decimal import Decimal
import excelexporters.spaceoutput
class Reporting: class Reporting:
@ -68,7 +69,7 @@ class Reporting:
try: try:
base_start_datetime_utc = datetime.strptime(base_start_datetime_local, base_start_datetime_utc = datetime.strptime(base_start_datetime_local,
'%Y-%m-%dT%H:%M:%S').replace(tzinfo=timezone.utc) - \ '%Y-%m-%dT%H:%M:%S').replace(tzinfo=timezone.utc) - \
timedelta(minutes=timezone_offset) timedelta(minutes=timezone_offset)
except ValueError: except ValueError:
raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST', raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST',
description="API.INVALID_BASE_PERIOD_START_DATETIME") description="API.INVALID_BASE_PERIOD_START_DATETIME")
@ -79,7 +80,7 @@ class Reporting:
try: try:
base_end_datetime_utc = datetime.strptime(base_end_datetime_local, base_end_datetime_utc = datetime.strptime(base_end_datetime_local,
'%Y-%m-%dT%H:%M:%S').replace(tzinfo=timezone.utc) - \ '%Y-%m-%dT%H:%M:%S').replace(tzinfo=timezone.utc) - \
timedelta(minutes=timezone_offset) timedelta(minutes=timezone_offset)
except ValueError: except ValueError:
raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST', raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST',
description="API.INVALID_BASE_PERIOD_END_DATETIME") description="API.INVALID_BASE_PERIOD_END_DATETIME")
@ -97,7 +98,7 @@ class Reporting:
try: try:
reporting_start_datetime_utc = datetime.strptime(reporting_start_datetime_local, reporting_start_datetime_utc = datetime.strptime(reporting_start_datetime_local,
'%Y-%m-%dT%H:%M:%S').replace(tzinfo=timezone.utc) - \ '%Y-%m-%dT%H:%M:%S').replace(tzinfo=timezone.utc) - \
timedelta(minutes=timezone_offset) timedelta(minutes=timezone_offset)
except ValueError: except ValueError:
raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST', raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST',
description="API.INVALID_REPORTING_PERIOD_START_DATETIME") description="API.INVALID_REPORTING_PERIOD_START_DATETIME")
@ -110,7 +111,7 @@ class Reporting:
try: try:
reporting_end_datetime_utc = datetime.strptime(reporting_end_datetime_local, reporting_end_datetime_utc = datetime.strptime(reporting_end_datetime_local,
'%Y-%m-%dT%H:%M:%S').replace(tzinfo=timezone.utc) - \ '%Y-%m-%dT%H:%M:%S').replace(tzinfo=timezone.utc) - \
timedelta(minutes=timezone_offset) timedelta(minutes=timezone_offset)
except ValueError: except ValueError:
raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST', raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST',
description="API.INVALID_REPORTING_PERIOD_END_DATETIME") description="API.INVALID_REPORTING_PERIOD_END_DATETIME")
@ -226,7 +227,7 @@ class Reporting:
" tbl_points po, tbl_sensors_points sepo " " tbl_points po, tbl_sensors_points sepo "
" WHERE sp.id = %s AND sp.id = spse.space_id AND spse.sensor_id = se.id " " WHERE sp.id = %s AND sp.id = spse.space_id AND spse.sensor_id = se.id "
" AND se.id = sepo.sensor_id AND sepo.point_id = po.id " " AND se.id = sepo.sensor_id AND sepo.point_id = po.id "
" ORDER BY po.id ", (space['id'], )) " ORDER BY po.id ", (space['id'],))
rows_points = cursor_system.fetchall() rows_points = cursor_system.fetchall()
if rows_points is not None and len(rows_points) > 0: if rows_points is not None and len(rows_points) > 0:
for row in rows_points: for row in rows_points:
@ -238,7 +239,7 @@ class Reporting:
cursor_system.execute(" SELECT po.id, po.name, po.units, po.object_type " cursor_system.execute(" SELECT po.id, po.name, po.units, po.object_type "
" FROM tbl_spaces sp, tbl_spaces_points sppo, tbl_points po " " FROM tbl_spaces sp, tbl_spaces_points sppo, tbl_points po "
" WHERE sp.id = %s AND sp.id = sppo.space_id AND sppo.point_id = po.id " " WHERE sp.id = %s AND sp.id = sppo.space_id AND sppo.point_id = po.id "
" ORDER BY po.id ", (space['id'], )) " ORDER BY po.id ", (space['id'],))
rows_points = cursor_system.fetchall() rows_points = cursor_system.fetchall()
if rows_points is not None and len(rows_points) > 0: if rows_points is not None and len(rows_points) > 0:
for row in rows_points: for row in rows_points:
@ -251,7 +252,7 @@ class Reporting:
cursor_system.execute(" SELECT id, name " cursor_system.execute(" SELECT id, name "
" FROM tbl_spaces " " FROM tbl_spaces "
" WHERE parent_space_id = %s " " WHERE parent_space_id = %s "
" ORDER BY id ", (space['id'], )) " ORDER BY id ", (space['id'],))
rows_child_spaces = cursor_system.fetchall() rows_child_spaces = cursor_system.fetchall()
if rows_child_spaces is not None and len(rows_child_spaces) > 0: if rows_child_spaces is not None and len(rows_child_spaces) > 0:
for row in rows_child_spaces: for row in rows_child_spaces:
@ -545,4 +546,11 @@ class Reporting:
result['child_space']['subtotals_array'].append( result['child_space']['subtotals_array'].append(
child_space_data[energy_category_id]['subtotals']) child_space_data[energy_category_id]['subtotals'])
# export result to Excel file and then encode the file to base64 string
result['excel_bytes_base64'] = excelexporters.spaceoutput.export(result,
space['name'],
reporting_start_datetime_local,
reporting_end_datetime_local,
period_type)
resp.body = json.dumps(result) resp.body = json.dumps(result)