reports.microgridevcharger.Reporting.__init__() - Code Metrics - Inspection of "Merge branch 'develop'" - MyEMS/myems - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( d99a30...2e4a80 )

unknown

created 2025-11-25 14:09 UTC

reports.microgridevcharger.Reporting.init() A

↳ Parent: reports.microgridevcharger

Complexity

Conditions

Size

Total Lines	3
Code Lines	2

Duplication

Lines	3
Ratio	100 %

Importance

Changes

Metric	Value
eloc	2
dl	3
loc	3
rs	10
c	0
b	0
f	0
cc	1
nop	1

from datetime import datetime, timedelta, timezone
from decimal import Decimal
import falcon
import mysql.connector
import simplejson as json
from core import utilities
import config
from core.useractivity import access_control, api_key_control


class Reporting:

    def __init__(self):
        """Initializes Class"""
        pass

    @staticmethod
    def on_options(req, resp):
        _ = req
        resp.status = falcon.HTTP_200

    ####################################################################################################################
    # PROCEDURES
    # Step 1: valid parameters
    # Step 2: query the microgrid list
    # Step 3: query evcharger energy data in 7 days
    # Step 4: query evcharger energy data in this month
    # Step 5: query evcharger energy data in this year
    # Step 6: construct the report
    ####################################################################################################################
    @staticmethod
    def on_get(req, resp):
        if 'API-KEY' not in req.headers or \
                not isinstance(req.headers['API-KEY'], str) or \
                len(str.strip(req.headers['API-KEY'])) == 0:
            access_control(req)
        else:
            api_key_control(req)
        user_uuid = req.params.get('useruuid')

        ################################################################################################################
        # Step 1: valid parameters
        ################################################################################################################
        if user_uuid is None:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST', description='API.INVALID_USER_UUID')
        else:
            user_uuid = str.strip(user_uuid)
            if len(user_uuid) != 36:
                raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                       description='API.INVALID_USER_UUID')

        ################################################################################################################
        # Step 2: query the microgrid list
        ################################################################################################################
        cnx_user = mysql.connector.connect(**config.myems_user_db)
        cursor_user = cnx_user.cursor()
        cursor_user.execute(" SELECT id, is_admin, privilege_id "
                            " FROM tbl_users "
                            " WHERE uuid = %s ", (user_uuid,))
        row_user = cursor_user.fetchone()
        if row_user is None:
            if cursor_user:
                cursor_user.close()
            if cnx_user:
                cnx_user.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.USER_NOT_FOUND')

        user = {'id': row_user[0], 'is_admin': row_user[1], 'privilege_id': row_user[2]}

        # Get microgrids
        cnx_system_db = mysql.connector.connect(**config.myems_system_db)
        cursor_system_db = cnx_system_db.cursor()
        query = (" SELECT m.id, m.name, m.uuid, "
                 "        m.address, m.postal_code, m.latitude, m.longitude, "
                 "        m.rated_capacity, m.rated_power, m.serial_number, m.description "
                 " FROM tbl_microgrids m, tbl_microgrids_users mu "
                 " WHERE m.id = mu.microgrid_id AND mu.user_id = %s "
                 " ORDER BY id ")
        cursor_system_db.execute(query, (user['id'],))
        rows_microgrids = cursor_system_db.fetchall()

        microgrid_list = list()
        microgrid_names = list()
        if rows_microgrids is not None and len(rows_microgrids) > 0:
            for row in rows_microgrids:
                meta_result = {"id": row[0],
                               "name": row[1],
                               "uuid": row[2],
                               "address": row[3],
                               "postal_code": row[4],
                               "latitude": row[5],
                               "longitude": row[6],
                               "rated_capacity": row[7],
                               "rated_power": row[8],
                               "serial_number": row[9],
                               "description": row[10]}
                microgrid_list.append(meta_result)
                microgrid_names.append(row[1])

        ################################################################################################################
        # Step 3: query evcharger energy data in 7 days
        ################################################################################################################
        timezone_offset = int(config.utc_offset[1:3]) * 60 + int(config.utc_offset[4:6])
        if config.utc_offset[0] == '-':
            timezone_offset = -timezone_offset
        reporting = dict()
        reporting['evcharger_7_days'] = dict()
        reporting['evcharger_this_month'] = dict()
        reporting['evcharger_this_year'] = dict()

        end_datetime_utc = datetime.utcnow()
        end_datetime_local = datetime.utcnow() + timedelta(minutes=timezone_offset)
        period_type = 'daily'
        start_datetime_local = end_datetime_local.replace(hour=0, minute=0, second=0, microsecond=0) - timedelta(days=6)
        start_datetime_utc = start_datetime_local - timedelta(minutes=timezone_offset)
        print('start_datetime_local:' + start_datetime_local.isoformat())
        print('end_datetime_local:' + end_datetime_local.isoformat())
        print('start_datetime_utc:' + start_datetime_utc.isoformat())
        print('end_datetime_utc:' + end_datetime_utc.isoformat())

        cnx_energy_db = mysql.connector.connect(**config.myems_energy_db)
        cursor_energy_db = cnx_energy_db.cursor()

        reporting['evcharger_7_days'] = dict()
        reporting['evcharger_7_days']['timestamps_array'] = list()
        reporting['evcharger_7_days']['values_array'] = list()

        for microgrid in microgrid_list:
            timestamps = list()
            values = list()
            query = (" SELECT start_datetime_utc, actual_value "
                     " FROM tbl_microgrid_evcharger_hourly "
                     " WHERE microgrid_id = %s "
                     " AND start_datetime_utc >= %s "
                     " AND start_datetime_utc < %s "
                     " ORDER BY start_datetime_utc ")
            cursor_energy_db.execute(query, (microgrid['id'], start_datetime_utc, end_datetime_utc))
            rows_evcharger_hourly = cursor_energy_db.fetchall()

            rows_evcharger_periodically = utilities.aggregate_hourly_data_by_period(rows_evcharger_hourly,
                                                                                    start_datetime_utc,
                                                                                    end_datetime_utc,
                                                                                    period_type)
            for row_evcharger_periodically in rows_evcharger_periodically:
                current_datetime_local = row_evcharger_periodically[0].replace(tzinfo=timezone.utc) + \
                                         timedelta(minutes=timezone_offset)
                if period_type == 'hourly':
                    current_datetime = current_datetime_local.isoformat()[0:19]
                elif period_type == 'daily':
                    current_datetime = current_datetime_local.isoformat()[0:10]
                elif period_type == 'weekly':
                    current_datetime = current_datetime_local.isoformat()[0:10]
                elif period_type == 'monthly':
                    current_datetime = current_datetime_local.isoformat()[0:7]
                elif period_type == 'yearly':
                    current_datetime = current_datetime_local.isoformat()[0:4]

                actual_value = Decimal(0.0) if row_evcharger_periodically[1] is None else row_evcharger_periodically[1]
                timestamps.append(current_datetime)

                values.append(actual_value)
            reporting['evcharger_7_days']['timestamps_array'].append(timestamps)
            reporting['evcharger_7_days']['values_array'].append(values)

        ################################################################################################################
        # Step 4: query evcharger energy data in this month
        ################################################################################################################
        end_datetime_utc = datetime.utcnow()
        end_datetime_local = datetime.utcnow() + timedelta(minutes=timezone_offset)
        period_type = 'daily'
        start_datetime_local = end_datetime_local.replace(day=1, hour=0, minute=0, second=0, microsecond=0)
        start_datetime_utc = start_datetime_local - timedelta(minutes=timezone_offset)
        print('start_datetime_local:' + start_datetime_local.isoformat())
        print('end_datetime_local:' + end_datetime_local.isoformat())
        print('start_datetime_utc:' + start_datetime_utc.isoformat())
        print('end_datetime_utc:' + end_datetime_utc.isoformat())

        reporting['evcharger_this_month'] = dict()
        reporting['evcharger_this_month']['timestamps_array'] = list()
        reporting['evcharger_this_month']['values_array'] = list()

        for microgrid in microgrid_list:
            timestamps = list()
            values = list()
            query = (" SELECT start_datetime_utc, actual_value "
                     " FROM tbl_microgrid_evcharger_hourly "
                     " WHERE microgrid_id = %s "
                     " AND start_datetime_utc >= %s "
                     " AND start_datetime_utc < %s "
                     " ORDER BY start_datetime_utc ")
            cursor_energy_db.execute(query, (microgrid['id'], start_datetime_utc, end_datetime_utc))
            rows_evcharger_hourly = cursor_energy_db.fetchall()

            rows_evcharger_periodically = utilities.aggregate_hourly_data_by_period(rows_evcharger_hourly,
                                                                                    start_datetime_utc,
                                                                                    end_datetime_utc,
                                                                                    period_type)

            for row_evcharger_periodically in rows_evcharger_periodically:
                current_datetime_local = row_evcharger_periodically[0].replace(tzinfo=timezone.utc) + \
                                         timedelta(minutes=timezone_offset)
                if period_type == 'hourly':
                    current_datetime = current_datetime_local.isoformat()[0:19]
                elif period_type == 'daily':
                    current_datetime = current_datetime_local.isoformat()[0:10]
                elif period_type == 'weekly':
                    current_datetime = current_datetime_local.isoformat()[0:10]
                elif period_type == 'monthly':
                    current_datetime = current_datetime_local.isoformat()[0:7]
                elif period_type == 'yearly':
                    current_datetime = current_datetime_local.isoformat()[0:4]

                actual_value = Decimal(0.0) if row_evcharger_periodically[1] is None else row_evcharger_periodically[1]
                timestamps.append(current_datetime)
                values.append(actual_value)
            reporting['evcharger_this_month']['timestamps_array'].append(timestamps)
            reporting['evcharger_this_month']['values_array'].append(values)

        ################################################################################################################
        # Step 5: query evcharger energy data in this year
        ################################################################################################################
        end_datetime_utc = datetime.utcnow()
        end_datetime_local = datetime.utcnow() + timedelta(minutes=timezone_offset)
        period_type = 'monthly'
        start_datetime_local = end_datetime_local.replace(month=1, day=1, hour=0, minute=0, second=0, microsecond=0)
        start_datetime_utc = start_datetime_local - timedelta(minutes=timezone_offset)
        print('start_datetime_local:' + start_datetime_local.isoformat())
        print('end_datetime_local:' + end_datetime_local.isoformat())
        print('start_datetime_utc:' + start_datetime_utc.isoformat())
        print('end_datetime_utc:' + end_datetime_utc.isoformat())

        reporting['evcharger_this_year'] = dict()
        reporting['evcharger_this_year']['timestamps_array'] = list()
        reporting['evcharger_this_year']['values_array'] = list()

        for microgrid in microgrid_list:
            timestamps = list()
            values = list()
            query = (" SELECT start_datetime_utc, actual_value "
                     " FROM tbl_microgrid_evcharger_hourly "
                     " WHERE microgrid_id = %s "
                     " AND start_datetime_utc >= %s "
                     " AND start_datetime_utc < %s "
                     " ORDER BY start_datetime_utc ")
            cursor_energy_db.execute(query, (microgrid['id'], start_datetime_utc, end_datetime_utc))
            rows_evcharger_hourly = cursor_energy_db.fetchall()

            rows_evcharger_periodically = utilities.aggregate_hourly_data_by_period(rows_evcharger_hourly,
                                                                                    start_datetime_utc,
                                                                                    end_datetime_utc,
                                                                                    period_type)
            for row_evcharger_periodically in rows_evcharger_periodically:
                current_datetime_local = row_evcharger_periodically[0].replace(tzinfo=timezone.utc) + \
                                         timedelta(minutes=timezone_offset)
                if period_type == 'hourly':
                    current_datetime = current_datetime_local.isoformat()[0:19]
                elif period_type == 'daily':
                    current_datetime = current_datetime_local.isoformat()[0:10]
                elif period_type == 'weekly':
                    current_datetime = current_datetime_local.isoformat()[0:10]
                elif period_type == 'monthly':
                    current_datetime = current_datetime_local.isoformat()[0:7]
                elif period_type == 'yearly':
                    current_datetime = current_datetime_local.isoformat()[0:4]

                actual_value = Decimal(0.0) if row_evcharger_periodically[1] is None else row_evcharger_periodically[1]
                timestamps.append(current_datetime)
                values.append(actual_value)
            reporting['evcharger_this_year']['timestamps_array'].append(timestamps)
            reporting['evcharger_this_year']['values_array'].append(values)

        ################################################################################################################
        # Step 6: construct the report
        ################################################################################################################
        if cursor_user:
            cursor_user.close()
        if cnx_user:
            cnx_user.close()

        if cursor_system_db:
            cursor_system_db.close()
        if cnx_system_db:
            cnx_system_db.close()

        if cursor_energy_db:
            cursor_energy_db.close()
        if cnx_energy_db:
            cnx_energy_db.close()

        result = dict()
        result['microgrid_names'] = microgrid_names
        result['reporting'] = reporting
        resp.text = json.dumps(result)



1		from datetime import datetime, timedelta, timezone
2		from decimal import Decimal
3		import falcon
4		import mysql.connector
5		import simplejson as json
6		from core import utilities
7		import config
8		from core.useractivity import access_control, api_key_control
9
10
11	View Code Duplication	class Reporting:
		0 ignored issues – show Duplication introduced 2025-11-25 14:21 UTC by Report Bug Copy Issue Report This code seems to be duplicated in your project. Loading history...
12		def __init__(self):
13		"""Initializes Class"""
14		pass
15
16		@staticmethod
17		def on_options(req, resp):
18		_ = req
19		resp.status = falcon.HTTP_200
20
21		####################################################################################################################
22		# PROCEDURES
23		# Step 1: valid parameters
24		# Step 2: query the microgrid list
25		# Step 3: query evcharger energy data in 7 days
26		# Step 4: query evcharger energy data in this month
27		# Step 5: query evcharger energy data in this year
28		# Step 6: construct the report
29		####################################################################################################################
30		@staticmethod
31		def on_get(req, resp):
32		if 'API-KEY' not in req.headers or \
33		not isinstance(req.headers['API-KEY'], str) or \
34		len(str.strip(req.headers['API-KEY'])) == 0:
35		access_control(req)
36		else:
37		api_key_control(req)
38		user_uuid = req.params.get('useruuid')
39
40		################################################################################################################
41		# Step 1: valid parameters
42		################################################################################################################
43		if user_uuid is None:
44		raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST', description='API.INVALID_USER_UUID')
45		else:
46		user_uuid = str.strip(user_uuid)
47		if len(user_uuid) != 36:
48		raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
49		description='API.INVALID_USER_UUID')
50
51		################################################################################################################
52		# Step 2: query the microgrid list
53		################################################################################################################
54		cnx_user = mysql.connector.connect(**config.myems_user_db)
55		cursor_user = cnx_user.cursor()
56		cursor_user.execute(" SELECT id, is_admin, privilege_id "
57		" FROM tbl_users "
58		" WHERE uuid = %s ", (user_uuid,))
59		row_user = cursor_user.fetchone()
60		if row_user is None:
61		if cursor_user:
62		cursor_user.close()
63		if cnx_user:
64		cnx_user.close()
65		raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
66		description='API.USER_NOT_FOUND')
67
68		user = {'id': row_user[0], 'is_admin': row_user[1], 'privilege_id': row_user[2]}
69
70		# Get microgrids
71		cnx_system_db = mysql.connector.connect(**config.myems_system_db)
72		cursor_system_db = cnx_system_db.cursor()
73		query = (" SELECT m.id, m.name, m.uuid, "
74		" m.address, m.postal_code, m.latitude, m.longitude, "
75		" m.rated_capacity, m.rated_power, m.serial_number, m.description "
76		" FROM tbl_microgrids m, tbl_microgrids_users mu "
77		" WHERE m.id = mu.microgrid_id AND mu.user_id = %s "
78		" ORDER BY id ")
79		cursor_system_db.execute(query, (user['id'],))
80		rows_microgrids = cursor_system_db.fetchall()
81
82		microgrid_list = list()
83		microgrid_names = list()
84		if rows_microgrids is not None and len(rows_microgrids) > 0:
85		for row in rows_microgrids:
86		meta_result = {"id": row[0],
87		"name": row[1],
88		"uuid": row[2],
89		"address": row[3],
90		"postal_code": row[4],
91		"latitude": row[5],
92		"longitude": row[6],
93		"rated_capacity": row[7],
94		"rated_power": row[8],
95		"serial_number": row[9],
96		"description": row[10]}
97		microgrid_list.append(meta_result)
98		microgrid_names.append(row[1])
99
100		################################################################################################################
101		# Step 3: query evcharger energy data in 7 days
102		################################################################################################################
103		timezone_offset = int(config.utc_offset[1:3]) * 60 + int(config.utc_offset[4:6])
104		if config.utc_offset[0] == '-':
105		timezone_offset = -timezone_offset
106		reporting = dict()
107		reporting['evcharger_7_days'] = dict()
108		reporting['evcharger_this_month'] = dict()
109		reporting['evcharger_this_year'] = dict()
110
111		end_datetime_utc = datetime.utcnow()
112		end_datetime_local = datetime.utcnow() + timedelta(minutes=timezone_offset)
113		period_type = 'daily'
114		start_datetime_local = end_datetime_local.replace(hour=0, minute=0, second=0, microsecond=0) - timedelta(days=6)
115		start_datetime_utc = start_datetime_local - timedelta(minutes=timezone_offset)
116		print('start_datetime_local:' + start_datetime_local.isoformat())
117		print('end_datetime_local:' + end_datetime_local.isoformat())
118		print('start_datetime_utc:' + start_datetime_utc.isoformat())
119		print('end_datetime_utc:' + end_datetime_utc.isoformat())
120
121		cnx_energy_db = mysql.connector.connect(**config.myems_energy_db)
122		cursor_energy_db = cnx_energy_db.cursor()
123
124		reporting['evcharger_7_days'] = dict()
125		reporting['evcharger_7_days']['timestamps_array'] = list()
126		reporting['evcharger_7_days']['values_array'] = list()
127
128		for microgrid in microgrid_list:
129		timestamps = list()
130		values = list()
131		query = (" SELECT start_datetime_utc, actual_value "
132		" FROM tbl_microgrid_evcharger_hourly "
133		" WHERE microgrid_id = %s "
134		" AND start_datetime_utc >= %s "
135		" AND start_datetime_utc < %s "
136		" ORDER BY start_datetime_utc ")
137		cursor_energy_db.execute(query, (microgrid['id'], start_datetime_utc, end_datetime_utc))
138		rows_evcharger_hourly = cursor_energy_db.fetchall()
139
140		rows_evcharger_periodically = utilities.aggregate_hourly_data_by_period(rows_evcharger_hourly,
141		start_datetime_utc,
142		end_datetime_utc,
143		period_type)
144		for row_evcharger_periodically in rows_evcharger_periodically:
145		current_datetime_local = row_evcharger_periodically[0].replace(tzinfo=timezone.utc) + \
146		timedelta(minutes=timezone_offset)
147		if period_type == 'hourly':
148		current_datetime = current_datetime_local.isoformat()[0:19]
149		elif period_type == 'daily':
150		current_datetime = current_datetime_local.isoformat()[0:10]
151		elif period_type == 'weekly':
152		current_datetime = current_datetime_local.isoformat()[0:10]
153		elif period_type == 'monthly':
154		current_datetime = current_datetime_local.isoformat()[0:7]
155		elif period_type == 'yearly':
156		current_datetime = current_datetime_local.isoformat()[0:4]
157
158		actual_value = Decimal(0.0) if row_evcharger_periodically[1] is None else row_evcharger_periodically[1]
159		timestamps.append(current_datetime)
		0 ignored issues – show introduced 2025-02-22 13:57 UTC by Report Bug Copy Issue Report The variable `current_datetime` does not seem to be defined for all execution paths. Loading history...
160		values.append(actual_value)
161		reporting['evcharger_7_days']['timestamps_array'].append(timestamps)
162		reporting['evcharger_7_days']['values_array'].append(values)
163
164		################################################################################################################
165		# Step 4: query evcharger energy data in this month
166		################################################################################################################
167		end_datetime_utc = datetime.utcnow()
168		end_datetime_local = datetime.utcnow() + timedelta(minutes=timezone_offset)
169		period_type = 'daily'
170		start_datetime_local = end_datetime_local.replace(day=1, hour=0, minute=0, second=0, microsecond=0)
171		start_datetime_utc = start_datetime_local - timedelta(minutes=timezone_offset)
172		print('start_datetime_local:' + start_datetime_local.isoformat())
173		print('end_datetime_local:' + end_datetime_local.isoformat())
174		print('start_datetime_utc:' + start_datetime_utc.isoformat())
175		print('end_datetime_utc:' + end_datetime_utc.isoformat())
176
177		reporting['evcharger_this_month'] = dict()
178		reporting['evcharger_this_month']['timestamps_array'] = list()
179		reporting['evcharger_this_month']['values_array'] = list()
180
181		for microgrid in microgrid_list:
182		timestamps = list()
183		values = list()
184		query = (" SELECT start_datetime_utc, actual_value "
185		" FROM tbl_microgrid_evcharger_hourly "
186		" WHERE microgrid_id = %s "
187		" AND start_datetime_utc >= %s "
188		" AND start_datetime_utc < %s "
189		" ORDER BY start_datetime_utc ")
190		cursor_energy_db.execute(query, (microgrid['id'], start_datetime_utc, end_datetime_utc))
191		rows_evcharger_hourly = cursor_energy_db.fetchall()
192
193		rows_evcharger_periodically = utilities.aggregate_hourly_data_by_period(rows_evcharger_hourly,
194		start_datetime_utc,
195		end_datetime_utc,
196		period_type)
197
198		for row_evcharger_periodically in rows_evcharger_periodically:
199		current_datetime_local = row_evcharger_periodically[0].replace(tzinfo=timezone.utc) + \
200		timedelta(minutes=timezone_offset)
201		if period_type == 'hourly':
202		current_datetime = current_datetime_local.isoformat()[0:19]
203		elif period_type == 'daily':
204		current_datetime = current_datetime_local.isoformat()[0:10]
205		elif period_type == 'weekly':
206		current_datetime = current_datetime_local.isoformat()[0:10]
207		elif period_type == 'monthly':
208		current_datetime = current_datetime_local.isoformat()[0:7]
209		elif period_type == 'yearly':
210		current_datetime = current_datetime_local.isoformat()[0:4]
211
212		actual_value = Decimal(0.0) if row_evcharger_periodically[1] is None else row_evcharger_periodically[1]
213		timestamps.append(current_datetime)
214		values.append(actual_value)
215		reporting['evcharger_this_month']['timestamps_array'].append(timestamps)
216		reporting['evcharger_this_month']['values_array'].append(values)
217
218		################################################################################################################
219		# Step 5: query evcharger energy data in this year
220		################################################################################################################
221		end_datetime_utc = datetime.utcnow()
222		end_datetime_local = datetime.utcnow() + timedelta(minutes=timezone_offset)
223		period_type = 'monthly'
224		start_datetime_local = end_datetime_local.replace(month=1, day=1, hour=0, minute=0, second=0, microsecond=0)
225		start_datetime_utc = start_datetime_local - timedelta(minutes=timezone_offset)
226		print('start_datetime_local:' + start_datetime_local.isoformat())
227		print('end_datetime_local:' + end_datetime_local.isoformat())
228		print('start_datetime_utc:' + start_datetime_utc.isoformat())
229		print('end_datetime_utc:' + end_datetime_utc.isoformat())
230
231		reporting['evcharger_this_year'] = dict()
232		reporting['evcharger_this_year']['timestamps_array'] = list()
233		reporting['evcharger_this_year']['values_array'] = list()
234
235		for microgrid in microgrid_list:
236		timestamps = list()
237		values = list()
238		query = (" SELECT start_datetime_utc, actual_value "
239		" FROM tbl_microgrid_evcharger_hourly "
240		" WHERE microgrid_id = %s "
241		" AND start_datetime_utc >= %s "
242		" AND start_datetime_utc < %s "
243		" ORDER BY start_datetime_utc ")
244		cursor_energy_db.execute(query, (microgrid['id'], start_datetime_utc, end_datetime_utc))
245		rows_evcharger_hourly = cursor_energy_db.fetchall()
246
247		rows_evcharger_periodically = utilities.aggregate_hourly_data_by_period(rows_evcharger_hourly,
248		start_datetime_utc,
249		end_datetime_utc,
250		period_type)
251		for row_evcharger_periodically in rows_evcharger_periodically:
252		current_datetime_local = row_evcharger_periodically[0].replace(tzinfo=timezone.utc) + \
253		timedelta(minutes=timezone_offset)
254		if period_type == 'hourly':
255		current_datetime = current_datetime_local.isoformat()[0:19]
256		elif period_type == 'daily':
257		current_datetime = current_datetime_local.isoformat()[0:10]
258		elif period_type == 'weekly':
259		current_datetime = current_datetime_local.isoformat()[0:10]
260		elif period_type == 'monthly':
261		current_datetime = current_datetime_local.isoformat()[0:7]
262		elif period_type == 'yearly':
263		current_datetime = current_datetime_local.isoformat()[0:4]
264
265		actual_value = Decimal(0.0) if row_evcharger_periodically[1] is None else row_evcharger_periodically[1]
266		timestamps.append(current_datetime)
267		values.append(actual_value)
268		reporting['evcharger_this_year']['timestamps_array'].append(timestamps)
269		reporting['evcharger_this_year']['values_array'].append(values)
270
271		################################################################################################################
272		# Step 6: construct the report
273		################################################################################################################
274		if cursor_user:
275		cursor_user.close()
276		if cnx_user:
277		cnx_user.close()
278
279		if cursor_system_db:
280		cursor_system_db.close()
281		if cnx_system_db:
282		cnx_system_db.close()
283
284		if cursor_energy_db:
285		cursor_energy_db.close()
286		if cnx_energy_db:
287		cnx_energy_db.close()
288
289		result = dict()
290		result['microgrid_names'] = microgrid_names
291		result['reporting'] = reporting
292		resp.text = json.dumps(result)
293
294

MyEMS / myems

Push — master ( d99a30...2e4a80 )

reports.microgridevcharger.Reporting.__init__() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

reports.microgridevcharger.Reporting.init() A