core.energystoragecontainer

Complexity

Total Complexity

1562

Size/Duplication

Total Lines	6244
Duplicated Lines	34.22 %

Importance

Changes

0

88 Methods

Rating	Name	Duplication	Size	Complexity
A	EnergyStorageContainerCollection.on_options()	0	3	1
A	EnergyStorageContainerCollection.__init__()	0	3	1
A	EnergyStorageContainerItem.__init__()	0	3	1
B	EnergyStorageContainerBatteryItem.on_delete()	0	40	7
F	EnergyStorageContainerItem.on_put()	0	122	28
B	EnergyStorageContainerItem.on_delete()	0	55	4
A	EnergyStorageContainerBatteryCollection.__init__()	0	3	1
F	EnergyStorageContainerCollection.on_post()	0	109	25
A	EnergyStorageContainerCommandCollection.__init__()	3	3	1
A	EnergyStorageContainerBatteryItem.on_options()	0	3	1
A	EnergyStorageContainerCommandCollection.on_options()	3	3	1
F	EnergyStorageContainerBatteryItem.on_get()	0	133	16
C	EnergyStorageContainerItem.on_get()	58	58	10
F	EnergyStorageContainerBatteryItem.on_put()	0	375	112
C	EnergyStorageContainerCollection.on_get()	0	54	10
A	EnergyStorageContainerBatteryItem.__init__()	0	3	1
A	EnergyStorageContainerItem.on_options()	0	3	1
F	EnergyStorageContainerBatteryCollection.on_post()	0	369	109
A	EnergyStorageContainerBatteryCollection.on_options()	0	3	1
F	EnergyStorageContainerBatteryCollection.on_get()	0	116	13
A	EnergyStorageContainerCommandItem.on_options()	3	3	1
A	EnergyStorageContainerCommandItem.__init__()	3	3	1
B	EnergyStorageContainerCommandItem.on_delete()	50	50	8
A	EnergyStorageContainerFirecontrolCollection.__init__()	0	3	1
A	EnergyStorageContainerFirecontrolCollection.on_options()	0	3	1
C	EnergyStorageContainerCommandCollection.on_post()	65	65	10
C	EnergyStorageContainerCommandCollection.on_get()	38	38	10
D	EnergyStorageContainerGridCollection.on_get()	97	97	13
A	EnergyStorageContainerLoadCollection.on_options()	3	3	1
A	EnergyStorageContainerClone.on_options()	0	3	1
A	EnergyStorageContainerImport.on_options()	0	3	1
A	EnergyStorageContainerClone.__init__()	0	3	1
C	EnergyStorageContainerHVACCollection.on_get()	0	48	10
F	EnergyStorageContainerScheduleItem.on_put()	83	83	20
D	EnergyStorageContainerFirecontrolItem.on_get()	0	82	13
D	EnergyStorageContainerHVACItem.on_get()	0	64	13
B	EnergyStorageContainerPowerconversionsystemItem.on_delete()	0	40	7
F	EnergyStorageContainerLoadCollection.on_post()	248	248	69
A	EnergyStorageContainerGridItem.on_options()	3	3	1
A	EnergyStorageContainerPowerconversionsystemCollection.on_options()	0	3	1
F	EnergyStorageContainerGridCollection.on_post()	267	267	73
C	EnergyStorageContainerExport.on_get()	57	57	10
B	EnergyStorageContainerScheduleCollection.on_post()	56	56	6
A	EnergyStorageContainerGridCollection.__init__()	3	3	1
A	EnergyStorageContainerHVACItem.on_options()	0	3	1
B	EnergyStorageContainerScheduleCollection.on_get()	38	38	7
A	EnergyStorageContainerExport.__init__()	0	3	1
B	EnergyStorageContainerClone.on_post()	0	54	5
B	EnergyStorageContainerFirecontrolItem.on_delete()	0	40	7
A	EnergyStorageContainerScheduleItem.on_options()	3	3	1
A	EnergyStorageContainerPowerconversionsystemItem.__init__()	0	3	1
F	EnergyStorageContainerFirecontrolCollection.on_post()	0	182	64
A	EnergyStorageContainerExport.on_options()	0	3	1
A	EnergyStorageContainerPowerconversionsystemCollection.__init__()	0	3	1
A	EnergyStorageContainerPowerconversionsystemItem.on_options()	0	3	1
C	EnergyStorageContainerScheduleItem.on_get()	53	53	10
A	EnergyStorageContainerGridCollection.on_options()	3	3	1
A	EnergyStorageContainerImport.__init__()	0	3	1
B	EnergyStorageContainerHVACItem.on_delete()	0	40	7
A	EnergyStorageContainerScheduleItem.__init__()	3	3	1
F	EnergyStorageContainerLoadItem.on_put()	244	244	71
B	EnergyStorageContainerGridItem.on_delete()	40	40	7
A	EnergyStorageContainerHVACCollection.__init__()	0	3	1
C	EnergyStorageContainerFirecontrolCollection.on_get()	0	66	10
A	EnergyStorageContainerFirecontrolItem.__init__()	0	3	1
F	EnergyStorageContainerImport.on_post()	0	115	28
A	EnergyStorageContainerScheduleCollection.on_options()	3	3	1
F	EnergyStorageContainerGridItem.on_put()	262	262	75
A	EnergyStorageContainerHVACItem.__init__()	0	3	1
A	EnergyStorageContainerHVACCollection.on_options()	0	3	1
F	EnergyStorageContainerLoadItem.on_get()	111	111	16
F	EnergyStorageContainerHVACCollection.on_post()	0	195	82
A	EnergyStorageContainerLoadItem.on_options()	3	3	1
F	EnergyStorageContainerHVACItem.on_put()	0	191	84
D	EnergyStorageContainerLoadCollection.on_get()	95	95	13
F	EnergyStorageContainerPowerconversionsystemItem.on_put()	0	456	156
F	EnergyStorageContainerFirecontrolItem.on_put()	0	181	66
A	EnergyStorageContainerLoadItem.__init__()	3	3	1
A	EnergyStorageContainerLoadCollection.__init__()	3	3	1
B	EnergyStorageContainerLoadItem.on_delete()	40	40	7
F	EnergyStorageContainerPowerconversionsystemCollection.on_post()	0	463	154
B	EnergyStorageContainerScheduleItem.on_delete()	40	40	7
F	EnergyStorageContainerGridItem.on_get()	113	113	16
F	EnergyStorageContainerPowerconversionsystemCollection.on_get()	0	153	13
A	EnergyStorageContainerGridItem.__init__()	3	3	1
A	EnergyStorageContainerScheduleCollection.__init__()	3	3	1
F	EnergyStorageContainerPowerconversionsystemItem.on_get()	0	181	19
A	EnergyStorageContainerFirecontrolItem.on_options()	0	3	1

import uuid
import falcon
import mysql.connector
import simplejson as json
from core.useractivity import user_logger, admin_control, access_control, api_key_control
import config
from datetime import datetime, timedelta
from decimal import Decimal


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

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

    @staticmethod
    def on_get(req, resp):
        access_control(req)
        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        query = (" SELECT id, name, uuid "
                 " FROM tbl_contacts ")
        cursor.execute(query)
        rows_contacts = cursor.fetchall()

        contact_dict = dict()
        if rows_contacts is not None and len(rows_contacts) > 0:
            for row in rows_contacts:
                contact_dict[row[0]] = {"id": row[0],
                                        "name": row[1],
                                        "uuid": row[2]}

        query = (" SELECT id, name, uuid "
                 " FROM tbl_cost_centers ")
        cursor.execute(query)
        rows_cost_centers = cursor.fetchall()

        cost_center_dict = dict()
        if rows_cost_centers is not None and len(rows_cost_centers) > 0:
            for row in rows_cost_centers:
                cost_center_dict[row[0]] = {"id": row[0],
                                            "name": row[1],
                                            "uuid": row[2]}

        query = (" SELECT id, name, uuid, "
                 "        rated_capacity, rated_power, contact_id, cost_center_id, description "
                 " FROM tbl_energy_storage_containers "
                 " ORDER BY id ")
        cursor.execute(query)
        rows_spaces = cursor.fetchall()

        result = list()
        if rows_spaces is not None and len(rows_spaces) > 0:
            for row in rows_spaces:
                meta_result = {"id": row[0],
                               "name": row[1],
                               "uuid": row[2],
                               "rated_capacity": row[3],
                               "rated_power": row[4],
                               "contact": contact_dict.get(row[5], None),
                               "cost_center": cost_center_dict.get(row[6], None),
                               "description": row[7],
                               "qrcode": 'energystoragecontainer:' + row[2]}
                result.append(meta_result)

        cursor.close()
        cnx.close()
        resp.text = json.dumps(result)

    @staticmethod
    @user_logger
    def on_post(req, resp):
        """Handles POST requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')

        new_values = json.loads(raw_json)

        if 'name' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['name'], str) or \
                len(str.strip(new_values['data']['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_NAME')
        name = str.strip(new_values['data']['name'])

        if 'rated_capacity' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['rated_capacity'], float) or
                     isinstance(new_values['data']['rated_capacity'], int)) or \
                new_values['data']['rated_capacity'] < 0.0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RATED_CAPACITY')
        rated_capacity = new_values['data']['rated_capacity']

        if 'rated_power' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['rated_power'], float) or
                     isinstance(new_values['data']['rated_power'], int)) or \
                new_values['data']['rated_power'] < 0.0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RATED_POWER')
        rated_power = new_values['data']['rated_power']

        if 'contact_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['contact_id'], int) or \
                new_values['data']['contact_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_CONTACT_ID')
        contact_id = new_values['data']['contact_id']

        if 'cost_center_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['cost_center_id'], int) or \
                new_values['data']['cost_center_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_COST_CENTER_ID')
        cost_center_id = new_values['data']['cost_center_id']

        if 'description' in new_values['data'].keys() and \
                new_values['data']['description'] is not None and \
                len(str(new_values['data']['description'])) > 0:
            description = str.strip(new_values['data']['description'])
        else:
            description = None

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE name = %s ", (name,))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_NAME_IS_ALREADY_IN_USE')

        cursor.execute(" SELECT name "
                       " FROM tbl_contacts "
                       " WHERE id = %s ",
                       (new_values['data']['contact_id'],))
        row = cursor.fetchone()
        if row is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.CONTACT_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_cost_centers "
                       " WHERE id = %s ",
                       (new_values['data']['cost_center_id'],))
        row = cursor.fetchone()
        if row is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.COST_CENTER_NOT_FOUND')

        add_values = (" INSERT INTO tbl_energy_storage_containers "
                      "    (name, uuid, rated_capacity, rated_power, contact_id, cost_center_id, description) "
                      " VALUES (%s, %s, %s, %s, %s, %s, %s) ")
        cursor.execute(add_values, (name,
                                    str(uuid.uuid4()),
                                    rated_capacity,
                                    rated_power,
                                    contact_id,
                                    cost_center_id,
                                    description))
        new_id = cursor.lastrowid
        cnx.commit()
        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_201
        resp.location = '/energystoragecontainers/' + str(new_id)


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

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

    @staticmethod

This code seems to be duplicated in your project.

    def on_get(req, resp, id_):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        query = (" SELECT id, name, uuid "
                 " FROM tbl_contacts ")
        cursor.execute(query)
        rows_contacts = cursor.fetchall()

        contact_dict = dict()
        if rows_contacts is not None and len(rows_contacts) > 0:
            for row in rows_contacts:
                contact_dict[row[0]] = {"id": row[0],
                                        "name": row[1],
                                        "uuid": row[2]}

        query = (" SELECT id, name, uuid "
                 " FROM tbl_cost_centers ")
        cursor.execute(query)
        rows_cost_centers = cursor.fetchall()

        cost_center_dict = dict()
        if rows_cost_centers is not None and len(rows_cost_centers) > 0:
            for row in rows_cost_centers:
                cost_center_dict[row[0]] = {"id": row[0],
                                            "name": row[1],
                                            "uuid": row[2]}

        query = (" SELECT id, name, uuid, "
                 "        rated_capacity, rated_power, contact_id, cost_center_id, description "
                 " FROM tbl_energy_storage_containers "
                 " WHERE id = %s ")
        cursor.execute(query, (id_,))
        row = cursor.fetchone()
        cursor.close()
        cnx.close()

        if row is None:
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')
        else:
            meta_result = {"id": row[0],
                           "name": row[1],
                           "uuid": row[2],
                           "rated_capacity": row[3],
                           "rated_power": row[4],
                           "contact": contact_dict.get(row[5], None),
                           "cost_center": cost_center_dict.get(row[6], None),
                           "description": row[7],
                           "qrcode": 'energystoragecontainer:' + row[2]}

        resp.text = json.dumps(meta_result)

    @staticmethod
    @user_logger
    def on_delete(req, resp, id_):
        admin_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_batteries "
                       " WHERE energy_storage_container_id = %s ", (id_, ))

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_commands "
                       " WHERE energy_storage_container_id = %s ", (id_,))

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_firecontrols "
                       " WHERE energy_storage_container_id = %s ", (id_,))

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_grids "
                       " WHERE energy_storage_container_id = %s ", (id_, ))

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_hvacs "
                       " WHERE energy_storage_container_id = %s ", (id_, ))

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_loads "
                       " WHERE energy_storage_container_id = %s ", (id_, ))

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_power_conversion_systems "
                       " WHERE energy_storage_container_id = %s ", (id_, ))

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_schedules "
                       " WHERE energy_storage_container_id = %s ", (id_, ))

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_users "
                       " WHERE energy_storage_container_id = %s ", (id_, ))

        cursor.execute(" DELETE FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_204

    @staticmethod
    @user_logger
    def on_put(req, resp, id_):
        """Handles PUT requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')

        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        new_values = json.loads(raw_json)

        if 'name' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['name'], str) or \
                len(str.strip(new_values['data']['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_NAME')
        name = str.strip(new_values['data']['name'])

        if 'rated_capacity' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['rated_capacity'], float) or
                     isinstance(new_values['data']['rated_capacity'], int)) or \
                new_values['data']['rated_capacity'] < 0.0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RATED_CAPACITY')
        rated_capacity = new_values['data']['rated_capacity']

        if 'rated_power' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['rated_power'], float) or
                     isinstance(new_values['data']['rated_power'], int)) or \
                new_values['data']['rated_power'] < 0.0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RATED_POWER')
        rated_power = new_values['data']['rated_power']

        if 'contact_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['contact_id'], int) or \
                new_values['data']['contact_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_CONTACT_ID')
        contact_id = new_values['data']['contact_id']

        if 'cost_center_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['cost_center_id'], int) or \
                new_values['data']['cost_center_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_COST_CENTER_ID')
        cost_center_id = new_values['data']['cost_center_id']

        if 'description' in new_values['data'].keys() and \
                new_values['data']['description'] is not None and \
                len(str(new_values['data']['description'])) > 0:
            description = str.strip(new_values['data']['description'])
        else:
            description = None

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE name = %s AND id != %s ", (name, id_))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_NAME_IS_ALREADY_IN_USE')

        cursor.execute(" SELECT name "
                       " FROM tbl_contacts "
                       " WHERE id = %s ",
                       (new_values['data']['contact_id'],))
        row = cursor.fetchone()
        if row is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.CONTACT_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_cost_centers "
                       " WHERE id = %s ",
                       (new_values['data']['cost_center_id'],))
        row = cursor.fetchone()
        if row is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.COST_CENTER_NOT_FOUND')

        update_row = (" UPDATE tbl_energy_storage_containers "
                      " SET name = %s, rated_capacity = %s, rated_power = %s, contact_id = %s, cost_center_id = %s, "
                      "     description = %s "
                      " WHERE id = %s ")
        cursor.execute(update_row, (name,
                                    rated_capacity,
                                    rated_power,
                                    contact_id,
                                    cost_center_id,
                                    description,
                                    id_))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_200


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

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

    @staticmethod
    def on_get(req, resp, id_):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        # query meter dict
        query = (" SELECT id, name, uuid "
                 " FROM tbl_meters ")
        cursor.execute(query)
        rows_meters = cursor.fetchall()

        meter_dict = dict()
        if rows_meters is not None and len(rows_meters) > 0:
            for row in rows_meters:
                meter_dict[row[0]] = {"id": row[0],
                                      "name": row[1],
                                      "uuid": row[2]}
        # query point dict
        query = (" SELECT id, name "
                 " FROM tbl_points ")
        cursor.execute(query)
        rows_points = cursor.fetchall()

        point_dict = dict()
        if rows_points is not None and len(rows_points) > 0:
            for row in rows_points:
                point_dict[row[0]] = {"id": row[0],
                                      "name": row[1]}

        query = (" SELECT id, name, uuid, "
                 "        battery_state_point_id, soc_point_id, power_point_id, "
                 "        charge_meter_id, discharge_meter_id, rated_capacity, rated_power, nominal_voltage, "
                 "        communication_status_with_pcs_point_id, "
                 "        communication_status_with_ems_point_id, "
                 "        grid_status_point_id, "
                 "        total_voltage_point_id, "
                 "        total_current_point_id, "
                 "        soh_point_id, "
                 "        charging_power_limit_point_id, "
                 "        discharge_limit_power_point_id, "
                 "        rechargeable_capacity_point_id, "
                 "        dischargeable_capacity_point_id, "
                 "        average_temperature_point_id, "
                 "        average_voltage_point_id, "
                 "        insulation_value_point_id, "
                 "        positive_insulation_value_point_id, "
                 "        negative_insulation_value_point_id, "
                 "        maximum_temperature_point_id, "
                 "        maximum_temperature_battery_cell_point_id, "
                 "        minimum_temperature_point_id, "
                 "        minimum_temperature_battery_cell_point_id, "
                 "        maximum_voltage_point_id, "
                 "        maximum_voltage_battery_cell_point_id, "
                 "        minimum_voltage_point_id, "
                 "        minimum_voltage_battery_cell_point_id "
                 " FROM tbl_energy_storage_containers_batteries "
                 " WHERE energy_storage_container_id = %s "
                 " ORDER BY name ")
        cursor.execute(query, (id_,))
        rows = cursor.fetchall()

        result = list()
        if rows is not None and len(rows) > 0:
            for row in rows:
                meta_result = {"id": row[0],
                               "name": row[1],
                               "uuid": row[2],
                               "battery_state_point": point_dict.get(row[3]),
                               "soc_point": point_dict.get(row[4]),
                               "power_point": point_dict.get(row[5]),
                               "charge_meter": meter_dict.get(row[6]),
                               "discharge_meter": meter_dict.get(row[7]),
                               "rated_capacity": row[8],
                               "rated_power": row[9],
                               "nominal_voltage": row[10],
                               "communication_status_with_pcs_point": point_dict.get(row[11]),
                               "communication_status_with_ems_point": point_dict.get(row[12]),
                               "grid_status_point": point_dict.get(row[13]),
                               "total_voltage_point": point_dict.get(row[14]),
                               "total_current_point": point_dict.get(row[15]),
                               "soh_point": point_dict.get(row[16]),
                               "charging_power_limit_point": point_dict.get(row[17]),
                               "discharge_limit_power_point": point_dict.get(row[18]),
                               "rechargeable_capacity_point": point_dict.get(row[19]),
                               "dischargeable_capacity_point": point_dict.get(row[20]),
                               "average_temperature_point": point_dict.get(row[21]),
                               "average_voltage_point": point_dict.get(row[22]),
                               "insulation_value_point": point_dict.get(row[23]),
                               "positive_insulation_value_point": point_dict.get(row[24]),
                               "negative_insulation_value_point": point_dict.get(row[25]),
                               "maximum_temperature_point": point_dict.get(row[26]),
                               "maximum_temperature_battery_cell_point": point_dict.get(row[27]),
                               "minimum_temperature_point": point_dict.get(row[28]),
                               "minimum_temperature_battery_cell_point": point_dict.get(row[29]),
                               "maximum_voltage_point": point_dict.get(row[30]),
                               "maximum_voltage_battery_cell_point": point_dict.get(row[31]),
                               "minimum_voltage_point": point_dict.get(row[32]),
                               "minimum_voltage_battery_cell_point": point_dict.get(row[33])
                               }
                result.append(meta_result)

        resp.text = json.dumps(result)

    @staticmethod
    @user_logger
    def on_post(req, resp, id_):
        """Handles POST requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')

        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        new_values = json.loads(raw_json)

        if 'name' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['name'], str) or \
                len(str.strip(new_values['data']['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_BATTERY_NAME')
        name = str.strip(new_values['data']['name'])

        if 'battery_state_point_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['battery_state_point_id'], int) or \
                new_values['data']['battery_state_point_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_BATTERY_STATE_POINT_ID')
        battery_state_point_id = new_values['data']['battery_state_point_id']

        if 'soc_point_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['soc_point_id'], int) or \
                new_values['data']['soc_point_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_SOC_POINT_ID')
        soc_point_id = new_values['data']['soc_point_id']

        if 'power_point_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['power_point_id'], int) or \
                new_values['data']['power_point_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_POWER_POINT_ID')
        power_point_id = new_values['data']['power_point_id']

        if 'charge_meter_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['charge_meter_id'], int) or \
                new_values['data']['charge_meter_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_CHARGE_METER_ID')
        charge_meter_id = new_values['data']['charge_meter_id']

        if 'discharge_meter_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['discharge_meter_id'], int) or \
                new_values['data']['discharge_meter_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_DISCHARGE_METER_ID')
        discharge_meter_id = new_values['data']['discharge_meter_id']

        if 'rated_capacity' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['rated_capacity'], float) or
                     isinstance(new_values['data']['rated_capacity'], int)) or \
                new_values['data']['rated_capacity'] < 0.0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RATED_CAPACITY')
        rated_capacity = Decimal(new_values['data']['rated_capacity'])

        if 'rated_power' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['rated_power'], float) or
                     isinstance(new_values['data']['rated_power'], int)) or \
                new_values['data']['rated_power'] < 0.0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RATED_POWER')
        rated_power = Decimal(new_values['data']['rated_power'])

        if 'nominal_voltage' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['nominal_voltage'], float) or
                     isinstance(new_values['data']['nominal_voltage'], int)):
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_NOMINAL_VOLTAGE')
        nominal_voltage = Decimal(new_values['data']['nominal_voltage'])

        communication_status_with_pcs_point_id = None
        communication_status_with_ems_point_id = None
        grid_status_point_id = None
        total_voltage_point_id = None
        total_current_point_id = None
        soh_point_id = None
        charging_power_limit_point_id = None
        discharge_limit_power_point_id = None
        rechargeable_capacity_point_id = None
        dischargeable_capacity_point_id = None
        average_temperature_point_id = None
        average_voltage_point_id = None
        insulation_value_point_id = None
        positive_insulation_value_point_id = None
        negative_insulation_value_point_id = None
        maximum_temperature_point_id = None
        maximum_temperature_battery_cell_point_id = None
        minimum_temperature_point_id = None
        minimum_temperature_battery_cell_point_id = None
        maximum_voltage_point_id = None
        maximum_voltage_battery_cell_point_id = None
        minimum_voltage_point_id = None
        minimum_voltage_battery_cell_point_id = None
        if 'communication_status_with_pcs_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['communication_status_with_pcs_point_id'], int) and \
                new_values['data']['communication_status_with_pcs_point_id'] > 0:
            communication_status_with_pcs_point_id = new_values['data']['communication_status_with_pcs_point_id']

        if 'communication_status_with_ems_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['communication_status_with_ems_point_id'], int) and \
                new_values['data']['communication_status_with_ems_point_id'] > 0:
            communication_status_with_ems_point_id = new_values['data']['communication_status_with_ems_point_id']

        if 'grid_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['grid_status_point_id'], int) and \
                new_values['data']['grid_status_point_id'] > 0:
            grid_status_point_id = new_values['data']['grid_status_point_id']

        if 'total_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_voltage_point_id'], int) and \
                new_values['data']['total_voltage_point_id'] > 0:
            total_voltage_point_id = new_values['data']['total_voltage_point_id']

        if 'total_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_current_point_id'], int) and \
                new_values['data']['total_current_point_id'] > 0:
            total_current_point_id = new_values['data']['total_current_point_id']

        if 'soh_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['soh_point_id'], int) and \
                new_values['data']['soh_point_id'] > 0:
            soh_point_id = new_values['data']['soh_point_id']

        if 'charging_power_limit_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['charging_power_limit_point_id'], int) and \
                new_values['data']['charging_power_limit_point_id'] > 0:
            charging_power_limit_point_id = new_values['data']['charging_power_limit_point_id']

        if 'discharge_limit_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['discharge_limit_power_point_id'], int) and \
                new_values['data']['discharge_limit_power_point_id'] > 0:
            discharge_limit_power_point_id = new_values['data']['discharge_limit_power_point_id']

        if 'rechargeable_capacity_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['rechargeable_capacity_point_id'], int) and \
                new_values['data']['rechargeable_capacity_point_id'] > 0:
            rechargeable_capacity_point_id = new_values['data']['rechargeable_capacity_point_id']

        if 'dischargeable_capacity_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['dischargeable_capacity_point_id'], int) and \
                new_values['data']['dischargeable_capacity_point_id'] > 0:
            dischargeable_capacity_point_id = new_values['data']['dischargeable_capacity_point_id']

        if 'average_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['average_temperature_point_id'], int) and \
                new_values['data']['average_temperature_point_id'] > 0:
            average_temperature_point_id = new_values['data']['average_temperature_point_id']

        if 'average_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['average_voltage_point_id'], int) and \
                new_values['data']['average_voltage_point_id'] > 0:
            average_voltage_point_id = new_values['data']['average_voltage_point_id']

        if 'insulation_value_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['insulation_value_point_id'], int) and \
                new_values['data']['insulation_value_point_id'] > 0:
            insulation_value_point_id = new_values['data']['insulation_value_point_id']

        if 'positive_insulation_value_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['positive_insulation_value_point_id'], int) and \
                new_values['data']['positive_insulation_value_point_id'] > 0:
            positive_insulation_value_point_id = new_values['data']['positive_insulation_value_point_id']

        if 'negative_insulation_value_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['negative_insulation_value_point_id'], int) and \
                new_values['data']['negative_insulation_value_point_id'] > 0:
            negative_insulation_value_point_id = new_values['data']['negative_insulation_value_point_id']

        if 'maximum_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['maximum_temperature_point_id'], int) and \
                new_values['data']['maximum_temperature_point_id'] > 0:
            maximum_temperature_point_id = new_values['data']['maximum_temperature_point_id']

        if 'maximum_temperature_battery_cell_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['maximum_temperature_battery_cell_point_id'], int) and \
                new_values['data']['maximum_temperature_battery_cell_point_id'] > 0:
            maximum_temperature_battery_cell_point_id = new_values['data']['maximum_temperature_battery_cell_point_id']

        if 'minimum_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['minimum_temperature_point_id'], int) and \
                new_values['data']['minimum_temperature_point_id'] > 0:
            minimum_temperature_point_id = new_values['data']['minimum_temperature_point_id']

        if 'minimum_temperature_battery_cell_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['minimum_temperature_battery_cell_point_id'], int) and \
                new_values['data']['minimum_temperature_battery_cell_point_id'] > 0:
            minimum_temperature_battery_cell_point_id = new_values['data']['minimum_temperature_battery_cell_point_id']

        if 'maximum_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['maximum_voltage_point_id'], int) and \
                new_values['data']['maximum_voltage_point_id'] > 0:
            maximum_voltage_point_id = new_values['data']['maximum_voltage_point_id']

        if 'maximum_voltage_battery_cell_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['maximum_voltage_battery_cell_point_id'], int) and \
                new_values['data']['maximum_voltage_battery_cell_point_id'] > 0:
            maximum_voltage_battery_cell_point_id = new_values['data']['maximum_voltage_battery_cell_point_id']

        if 'minimum_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['minimum_voltage_point_id'], int) and \
                new_values['data']['minimum_voltage_point_id'] > 0:
            minimum_voltage_point_id = new_values['data']['minimum_voltage_point_id']

        if 'minimum_voltage_battery_cell_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['minimum_voltage_battery_cell_point_id'], int) and \
                new_values['data']['minimum_voltage_battery_cell_point_id'] > 0:
            minimum_voltage_battery_cell_point_id = new_values['data']['minimum_voltage_battery_cell_point_id']

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_batteries "
                       " WHERE energy_storage_container_id = %s AND name = %s ",
                       (id_, name,))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_BATTERY_NAME_IS_ALREADY_IN_USE')

        cursor.execute(" SELECT name "
                       " FROM tbl_points "
                       " WHERE id = %s ",
                       (battery_state_point_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.BATTERY_STATE_POINT_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_points "
                       " WHERE id = %s ",
                       (soc_point_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.SOC_POINT_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_points "
                       " WHERE id = %s ",
                       (power_point_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.POWER_POINT_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_meters "
                       " WHERE id = %s ",
                       (charge_meter_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.CHARGE_METER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_meters "
                       " WHERE id = %s ",
                       (discharge_meter_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.DISCHARGE_METER_NOT_FOUND')

        add_values = (" INSERT INTO tbl_energy_storage_containers_batteries "
                      "    (name, uuid, energy_storage_container_id, "
                      "     battery_state_point_id, soc_point_id, power_point_id, "
                      "     charge_meter_id, discharge_meter_id, rated_capacity, rated_power, nominal_voltage, "
                      "     communication_status_with_pcs_point_id, "
                      "     communication_status_with_ems_point_id, "
                      "     grid_status_point_id, "
                      "     total_voltage_point_id, "
                      "     total_current_point_id, "
                      "     soh_point_id, "
                      "     charging_power_limit_point_id, "
                      "     discharge_limit_power_point_id, "
                      "     rechargeable_capacity_point_id, "
                      "     dischargeable_capacity_point_id, "
                      "     average_temperature_point_id, "
                      "     average_voltage_point_id, "
                      "     insulation_value_point_id, "
                      "     positive_insulation_value_point_id, "
                      "     negative_insulation_value_point_id, "
                      "     maximum_temperature_point_id, "
                      "     maximum_temperature_battery_cell_point_id, "
                      "     minimum_temperature_point_id, "
                      "     minimum_temperature_battery_cell_point_id, "
                      "     maximum_voltage_point_id, "
                      "     maximum_voltage_battery_cell_point_id, "
                      "     minimum_voltage_point_id, "
                      "     minimum_voltage_battery_cell_point_id) "
                      " VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, "
                      "         %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,"
                      "         %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,"
                      "         %s, %s, %s) ")
        cursor.execute(add_values, (name,
                                    str(uuid.uuid4()),
                                    id_,
                                    battery_state_point_id,
                                    soc_point_id,
                                    power_point_id,
                                    charge_meter_id,
                                    discharge_meter_id,
                                    rated_capacity,
                                    rated_power,
                                    nominal_voltage,
                                    communication_status_with_pcs_point_id,
                                    communication_status_with_ems_point_id,
                                    grid_status_point_id,
                                    total_voltage_point_id,
                                    total_current_point_id,
                                    soh_point_id,
                                    charging_power_limit_point_id,
                                    discharge_limit_power_point_id,
                                    rechargeable_capacity_point_id,
                                    dischargeable_capacity_point_id,
                                    average_temperature_point_id,
                                    average_voltage_point_id,
                                    insulation_value_point_id,
                                    positive_insulation_value_point_id,
                                    negative_insulation_value_point_id,
                                    maximum_temperature_point_id,
                                    maximum_temperature_battery_cell_point_id,
                                    minimum_temperature_point_id,
                                    minimum_temperature_battery_cell_point_id,
                                    maximum_voltage_point_id,
                                    maximum_voltage_battery_cell_point_id,
                                    minimum_voltage_point_id,
                                    minimum_voltage_battery_cell_point_id
                                    ))
        new_id = cursor.lastrowid
        cnx.commit()
        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_201
        resp.location = '/energystoragecontainers/' + str(id_) + '/batteries/' + str(new_id)


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

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

    @staticmethod
    def on_get(req, resp, id_, bid):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not bid.isdigit() or int(bid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_BATTERY_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        # query energy storage power station dict
        query = (" SELECT id, name, uuid "
                 " FROM tbl_energy_storage_containers ")
        cursor.execute(query)
        rows_energystoragecontainers = cursor.fetchall()

        energy_storage_container_dict = dict()
        if rows_energystoragecontainers is not None and len(rows_energystoragecontainers) > 0:
            for row in rows_energystoragecontainers:
                energy_storage_container_dict[row[0]] = {"id": row[0],
                                                         "name": row[1],
                                                         "uuid": row[2]}
        # query meter dict
        query = (" SELECT id, name, uuid "
                 " FROM tbl_meters ")
        cursor.execute(query)
        rows_meters = cursor.fetchall()

        meter_dict = dict()
        if rows_meters is not None and len(rows_meters) > 0:
            for row in rows_meters:
                meter_dict[row[0]] = {"id": row[0],
                                      "name": row[1],
                                      "uuid": row[2]}
        # query point dict
        query = (" SELECT id, name "
                 " FROM tbl_points ")
        cursor.execute(query)
        rows_points = cursor.fetchall()

        point_dict = dict()
        if rows_points is not None and len(rows_points) > 0:
            for row in rows_points:
                point_dict[row[0]] = {"id": row[0],
                                      "name": row[1]}

        query = (" SELECT id, name, uuid, energy_storage_container_id, "
                 "       battery_state_point_id, soc_point_id, power_point_id, "
                 "       charge_meter_id, discharge_meter_id, rated_capacity, rated_power, nominal_voltage, "
                 "       communication_status_with_pcs_point_id, "
                 "       communication_status_with_ems_point_id, "
                 "       grid_status_point_id, "
                 "       total_voltage_point_id, "
                 "       total_current_point_id, "
                 "       soh_point_id, "
                 "       charging_power_limit_point_id, "
                 "       discharge_limit_power_point_id, "
                 "       rechargeable_capacity_point_id, "
                 "       dischargeable_capacity_point_id, "
                 "       average_temperature_point_id, "
                 "       average_voltage_point_id, "
                 "       insulation_value_point_id, "
                 "       positive_insulation_value_point_id, "
                 "       negative_insulation_value_point_id, "
                 "       maximum_temperature_point_id, "
                 "       maximum_temperature_battery_cell_point_id, "
                 "       minimum_temperature_point_id, "
                 "       minimum_temperature_battery_cell_point_id, "
                 "       maximum_voltage_point_id, "
                 "       maximum_voltage_battery_cell_point_id, "
                 "       minimum_voltage_point_id, "
                 "       minimum_voltage_battery_cell_point_id "
                 " FROM tbl_energy_storage_containers_batteries "
                 " WHERE id = %s ")
        cursor.execute(query, (bid,))
        row = cursor.fetchone()
        cursor.close()
        cnx.close()

        if row is None:
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_BATTERY_NOT_FOUND')
        else:
            meta_result = {"id": row[0],
                           "name": row[1],
                           "uuid": row[2],
                           "energy_storage_container": energy_storage_container_dict.get(row[3]),
                           "battery_state_point": point_dict.get(row[4]),
                           "soc_point": point_dict.get(row[5]),
                           "power_point": point_dict.get(row[6]),
                           "charge_meter": meter_dict.get(row[7]),
                           "discharge_meter": meter_dict.get(row[8]),
                           "rated_capacity": row[9],
                           "rated_power": row[10],
                           "nominal_voltage": row[11],
                           "communication_status_with_pcs_point": point_dict.get(row[12]),
                           "communication_status_with_ems_point": point_dict.get(row[13]),
                           "grid_status_point": point_dict.get(row[14]),
                           "total_voltage_point": point_dict.get(row[15]),
                           "total_current_point": point_dict.get(row[16]),
                           "soh_point": point_dict.get(row[17]),
                           "charging_power_limit_point": point_dict.get(row[18]),
                           "discharge_limit_power_point": point_dict.get(row[19]),
                           "rechargeable_capacity_point": point_dict.get(row[20]),
                           "dischargeable_capacity_point": point_dict.get(row[21]),
                           "average_temperature_point": point_dict.get(row[22]),
                           "average_voltage_point": point_dict.get(row[23]),
                           "insulation_value_point": point_dict.get(row[24]),
                           "positive_insulation_value_point": point_dict.get(row[25]),
                           "negative_insulation_value_point": point_dict.get(row[26]),
                           "maximum_temperature_point": point_dict.get(row[27]),
                           "maximum_temperature_battery_cell_point": point_dict.get(row[28]),
                           "minimum_temperature_point": point_dict.get(row[29]),
                           "minimum_temperature_battery_cell_point": point_dict.get(row[30]),
                           "maximum_voltage_point": point_dict.get(row[31]),
                           "maximum_voltage_battery_cell_point": point_dict.get(row[32]),
                           "minimum_voltage_point": point_dict.get(row[33]),
                           "minimum_voltage_battery_cell_point": point_dict.get(row[34])
                           }

        resp.text = json.dumps(meta_result)

    @staticmethod
    @user_logger
    def on_delete(req, resp, id_, bid):
        admin_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not bid.isdigit() or int(bid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_BATTERY_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_batteries "
                       " WHERE id = %s ", (bid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_BATTERY_NOT_FOUND')

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_batteries "
                       " WHERE id = %s ", (bid,))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_204

    @staticmethod
    @user_logger
    def on_put(req, resp, id_, bid):
        """Handles PUT requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not bid.isdigit() or int(bid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_BATTERY_ID')

        new_values = json.loads(raw_json)

        if 'name' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['name'], str) or \
                len(str.strip(new_values['data']['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_BATTERY_NAME')
        name = str.strip(new_values['data']['name'])

        if 'battery_state_point_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['battery_state_point_id'], int) or \
                new_values['data']['battery_state_point_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_BATTERY_STATE_POINT_ID')
        battery_state_point_id = new_values['data']['battery_state_point_id']

        if 'soc_point_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['soc_point_id'], int) or \
                new_values['data']['soc_point_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_SOC_POINT_ID')
        soc_point_id = new_values['data']['soc_point_id']

        if 'power_point_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['power_point_id'], int) or \
                new_values['data']['power_point_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_POWER_POINT_ID')
        power_point_id = new_values['data']['power_point_id']

        if 'charge_meter_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['charge_meter_id'], int) or \
                new_values['data']['charge_meter_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_CHARGE_METER_ID')
        charge_meter_id = new_values['data']['charge_meter_id']

        if 'discharge_meter_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['discharge_meter_id'], int) or \
                new_values['data']['discharge_meter_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_DISCHARGE_METER_ID')
        discharge_meter_id = new_values['data']['discharge_meter_id']

        if 'rated_capacity' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['rated_capacity'], float) or
                     isinstance(new_values['data']['rated_capacity'], int)) or \
                new_values['data']['rated_capacity'] < 0.0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RATED_CAPACITY')
        rated_capacity = Decimal(new_values['data']['rated_capacity'])

        if 'rated_power' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['rated_power'], float) or
                     isinstance(new_values['data']['rated_power'], int)) or \
                new_values['data']['rated_power'] < 0.0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RATED_POWER')
        rated_power = Decimal(new_values['data']['rated_power'])

        if 'nominal_voltage' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['nominal_voltage'], float) or
                     isinstance(new_values['data']['nominal_voltage'], int)):
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_NOMINAL_VOLTAGE')
        nominal_voltage = Decimal(new_values['data']['nominal_voltage'])

        communication_status_with_pcs_point_id = None
        communication_status_with_ems_point_id = None
        grid_status_point_id = None
        total_voltage_point_id = None
        total_current_point_id = None
        soh_point_id = None
        charging_power_limit_point_id = None
        discharge_limit_power_point_id = None
        rechargeable_capacity_point_id = None
        dischargeable_capacity_point_id = None
        average_temperature_point_id = None
        average_voltage_point_id = None
        insulation_value_point_id = None
        positive_insulation_value_point_id = None
        negative_insulation_value_point_id = None
        maximum_temperature_point_id = None
        maximum_temperature_battery_cell_point_id = None
        minimum_temperature_point_id = None
        minimum_temperature_battery_cell_point_id = None
        maximum_voltage_point_id = None
        maximum_voltage_battery_cell_point_id = None
        minimum_voltage_point_id = None
        minimum_voltage_battery_cell_point_id = None

        if 'communication_status_with_pcs_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['communication_status_with_pcs_point_id'], int) and \
                new_values['data']['communication_status_with_pcs_point_id'] > 0:
            communication_status_with_pcs_point_id = new_values['data']['communication_status_with_pcs_point_id']

        if 'communication_status_with_ems_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['communication_status_with_ems_point_id'], int) and \
                new_values['data']['communication_status_with_ems_point_id'] > 0:
            communication_status_with_ems_point_id = new_values['data']['communication_status_with_ems_point_id']

        if 'grid_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['grid_status_point_id'], int) and \
                new_values['data']['grid_status_point_id'] > 0:
            grid_status_point_id = new_values['data']['grid_status_point_id']

        if 'total_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_voltage_point_id'], int) and \
                new_values['data']['total_voltage_point_id'] > 0:
            total_voltage_point_id = new_values['data']['total_voltage_point_id']

        if 'total_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_current_point_id'], int) and \
                new_values['data']['total_current_point_id'] > 0:
            total_current_point_id = new_values['data']['total_current_point_id']

        if 'soh_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['soh_point_id'], int) and \
                new_values['data']['soh_point_id'] > 0:
            soh_point_id = new_values['data']['soh_point_id']

        if 'charging_power_limit_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['charging_power_limit_point_id'], int) and \
                new_values['data']['charging_power_limit_point_id'] > 0:
            charging_power_limit_point_id = new_values['data']['charging_power_limit_point_id']

        if 'discharge_limit_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['discharge_limit_power_point_id'], int) and \
                new_values['data']['discharge_limit_power_point_id'] > 0:
            discharge_limit_power_point_id = new_values['data']['discharge_limit_power_point_id']

        if 'rechargeable_capacity_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['rechargeable_capacity_point_id'], int) and \
                new_values['data']['rechargeable_capacity_point_id'] > 0:
            rechargeable_capacity_point_id = new_values['data']['rechargeable_capacity_point_id']

        if 'dischargeable_capacity_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['dischargeable_capacity_point_id'], int) and \
                new_values['data']['dischargeable_capacity_point_id'] > 0:
            dischargeable_capacity_point_id = new_values['data']['dischargeable_capacity_point_id']

        if 'average_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['average_temperature_point_id'], int) and \
                new_values['data']['average_temperature_point_id'] > 0:
            average_temperature_point_id = new_values['data']['average_temperature_point_id']

        if 'average_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['average_voltage_point_id'], int) and \
                new_values['data']['average_voltage_point_id'] > 0:
            average_voltage_point_id = new_values['data']['average_voltage_point_id']

        if 'insulation_value_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['insulation_value_point_id'], int) and \
                new_values['data']['insulation_value_point_id'] > 0:
            insulation_value_point_id = new_values['data']['insulation_value_point_id']

        if 'positive_insulation_value_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['positive_insulation_value_point_id'], int) and \
                new_values['data']['positive_insulation_value_point_id'] > 0:
            positive_insulation_value_point_id = new_values['data']['positive_insulation_value_point_id']

        if 'negative_insulation_value_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['negative_insulation_value_point_id'], int) and \
                new_values['data']['negative_insulation_value_point_id'] > 0:
            negative_insulation_value_point_id = new_values['data']['negative_insulation_value_point_id']

        if 'maximum_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['maximum_temperature_point_id'], int) and \
                new_values['data']['maximum_temperature_point_id'] > 0:
            maximum_temperature_point_id = new_values['data']['maximum_temperature_point_id']

        if 'maximum_temperature_battery_cell_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['maximum_temperature_battery_cell_point_id'], int) and \
                new_values['data']['maximum_temperature_battery_cell_point_id'] > 0:
            maximum_temperature_battery_cell_point_id = new_values['data']['maximum_temperature_battery_cell_point_id']

        if 'minimum_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['minimum_temperature_point_id'], int) and \
                new_values['data']['minimum_temperature_point_id'] > 0:
            minimum_temperature_point_id = new_values['data']['minimum_temperature_point_id']

        if 'minimum_temperature_battery_cell_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['minimum_temperature_battery_cell_point_id'], int) and \
                new_values['data']['minimum_temperature_battery_cell_point_id'] > 0:
            minimum_temperature_battery_cell_point_id = new_values['data']['minimum_temperature_battery_cell_point_id']

        if 'maximum_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['maximum_voltage_point_id'], int) and \
                new_values['data']['maximum_voltage_point_id'] > 0:
            maximum_voltage_point_id = new_values['data']['maximum_voltage_point_id']

        if 'maximum_voltage_battery_cell_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['maximum_voltage_battery_cell_point_id'], int) and \
                new_values['data']['maximum_voltage_battery_cell_point_id'] > 0:
            maximum_voltage_battery_cell_point_id = new_values['data']['maximum_voltage_battery_cell_point_id']

        if 'minimum_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['minimum_voltage_point_id'], int) and \
                new_values['data']['minimum_voltage_point_id'] > 0:
            minimum_voltage_point_id = new_values['data']['minimum_voltage_point_id']

        if 'minimum_voltage_battery_cell_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['minimum_voltage_battery_cell_point_id'], int) and \
                new_values['data']['minimum_voltage_battery_cell_point_id'] > 0:
            minimum_voltage_battery_cell_point_id = new_values['data']['minimum_voltage_battery_cell_point_id']
        print(new_values)
        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ",
                       (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_batteries "
                       " WHERE id = %s ", (bid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_BATTERY_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_batteries "
                       " WHERE energy_storage_container_id = %s AND name = %s AND id != %s ",
                       (id_, name, bid))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_BATTERY_NAME_IS_ALREADY_IN_USE')

        cursor.execute(" SELECT name "
                       " FROM tbl_points "
                       " WHERE id = %s ",
                       (battery_state_point_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.BATTERY_STATE_POINT_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_points "
                       " WHERE id = %s ",
                       (soc_point_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.SOC_POINT_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_points "
                       " WHERE id = %s ",
                       (power_point_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.POWER_POINT_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_meters "
                       " WHERE id = %s ",
                       (charge_meter_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.CHARGE_METER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_meters "
                       " WHERE id = %s ",
                       (discharge_meter_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.DISCHARGE_METER_NOT_FOUND')

        update_row = (" UPDATE tbl_energy_storage_containers_batteries "
                      " SET name = %s, energy_storage_container_id = %s, "
                      "     battery_state_point_id = %s, soc_point_id = %s, power_point_id = %s, "
                      "     charge_meter_id = %s, discharge_meter_id = %s, "
                      "     rated_capacity = %s,  rated_power = %s, nominal_voltage = %s, "
                      "     communication_status_with_pcs_point_id = %s, "
                      "     communication_status_with_ems_point_id = %s, "
                      "     grid_status_point_id = %s, "
                      "     total_voltage_point_id = %s, "
                      "     total_current_point_id = %s, "
                      "     soh_point_id = %s, "
                      "     charging_power_limit_point_id = %s, "
                      "     discharge_limit_power_point_id = %s, "
                      "     rechargeable_capacity_point_id = %s, "
                      "     dischargeable_capacity_point_id = %s, "
                      "     average_temperature_point_id = %s, "
                      "     average_voltage_point_id = %s, "
                      "     insulation_value_point_id = %s, "
                      "     positive_insulation_value_point_id = %s, "
                      "     negative_insulation_value_point_id = %s, "
                      "     maximum_temperature_point_id = %s, "
                      "     maximum_temperature_battery_cell_point_id = %s, "
                      "     minimum_temperature_point_id = %s, "
                      "     minimum_temperature_battery_cell_point_id = %s, "
                      "     maximum_voltage_point_id = %s, "
                      "     maximum_voltage_battery_cell_point_id = %s, "
                      "     minimum_voltage_point_id = %s, "
                      "     minimum_voltage_battery_cell_point_id = %s "
                      " WHERE id = %s ")
        cursor.execute(update_row, (name,
                                    id_,
                                    battery_state_point_id,
                                    soc_point_id,
                                    power_point_id,
                                    charge_meter_id,
                                    discharge_meter_id,
                                    rated_capacity,
                                    rated_power,
                                    nominal_voltage,
                                    communication_status_with_pcs_point_id,
                                    communication_status_with_ems_point_id,
                                    grid_status_point_id,
                                    total_voltage_point_id,
                                    total_current_point_id,
                                    soh_point_id,
                                    charging_power_limit_point_id,
                                    discharge_limit_power_point_id,
                                    rechargeable_capacity_point_id,
                                    dischargeable_capacity_point_id,
                                    average_temperature_point_id,
                                    average_voltage_point_id,
                                    insulation_value_point_id,
                                    positive_insulation_value_point_id,
                                    negative_insulation_value_point_id,
                                    maximum_temperature_point_id,
                                    maximum_temperature_battery_cell_point_id,
                                    minimum_temperature_point_id,
                                    minimum_temperature_battery_cell_point_id,
                                    maximum_voltage_point_id,
                                    maximum_voltage_battery_cell_point_id,
                                    minimum_voltage_point_id,
                                    minimum_voltage_battery_cell_point_id,
                                    bid))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_200


class EnergyStorageContainerCommandCollection:

This code seems to be duplicated in your project.

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

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

    @staticmethod
    def on_get(req, resp, id_):
        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)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        query = (" SELECT c.id, c.name, c.uuid "
                 " FROM tbl_energy_storage_containers ce, tbl_energy_storage_containers_commands cec, tbl_commands c "
                 " WHERE cec.energy_storage_container_id = ce.id AND c.id = cec.command_id AND ce.id = %s "
                 " ORDER BY c.id ")
        cursor.execute(query, (id_,))
        rows = cursor.fetchall()

        result = list()
        if rows is not None and len(rows) > 0:
            for row in rows:
                meta_result = {"id": row[0], "name": row[1], "uuid": row[2]}
                result.append(meta_result)

        resp.text = json.dumps(result)

    @staticmethod
    @user_logger
    def on_post(req, resp, id_):
        """Handles POST requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')

        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        new_values = json.loads(raw_json)

        if 'command_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['command_id'], int) or \
                new_values['data']['command_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_COMMAND_ID')
        command_id = new_values['data']['command_id']

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " from tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_commands "
                       " WHERE id = %s ", (command_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.COMMAND_NOT_FOUND')

        query = (" SELECT id " 
                 " FROM tbl_energy_storage_containers_commands "
                 " WHERE energy_storage_container_id = %s AND command_id = %s")
        cursor.execute(query, (id_, command_id,))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.ERROR',
                                   description='API.ENERGY_STORAGE_CONTAINER_COMMAND_RELATION_EXISTS')

        add_row = (" INSERT INTO tbl_energy_storage_containers_commands (energy_storage_container_id, command_id) "
                   " VALUES (%s, %s) ")
        cursor.execute(add_row, (id_, command_id,))
        cnx.commit()
        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_201
        resp.location = '/combinedequipments/' + str(id_) + '/commands/' + str(command_id)


class EnergyStorageContainerCommandItem:

This code seems to be duplicated in your project.

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

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

    @staticmethod
    @user_logger
    def on_delete(req, resp, id_, cid):
        admin_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        if not cid.isdigit() or int(cid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_COMMAND_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_commands "
                       " WHERE id = %s ", (cid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.COMMAND_NOT_FOUND')

        cursor.execute(" SELECT id "
                       " FROM tbl_energy_storage_containers_commands "
                       " WHERE energy_storage_container_id = %s AND command_id = %s ", (id_, cid))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_COMMAND_RELATION_NOT_FOUND')

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_commands "
                       " WHERE energy_storage_container_id = %s AND command_id = %s ", (id_, cid))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_204


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

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

    @staticmethod
    def on_get(req, resp, id_):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        # query point dict
        query = (" SELECT id, name "
                 " FROM tbl_points ")
        cursor.execute(query)
        rows_points = cursor.fetchall()

        point_dict = dict()
        if rows_points is not None and len(rows_points) > 0:
            for row in rows_points:
                point_dict[row[0]] = {"id": row[0],
                                      "name": row[1]}

        query = (" SELECT id, name, uuid "
                 " FROM tbl_energy_storage_containers_firecontrols "
                 " WHERE energy_storage_container_id = %s "
                 " ORDER BY name ")
        cursor.execute(query, (id_,))
        rows = cursor.fetchall()

        result = list()
        if rows is not None and len(rows) > 0:
            for row in rows:
                meta_result = {"id": row[0],
                               "name": row[1],
                               "uuid": row[2],
                               "water_immersion_point": point_dict.get(row[3]),
                               "emergency_stop_point": point_dict.get(row[4]),
                               "electrical_compartment_smoke_detector_point": point_dict.get(row[5]),
                               "battery_compartment_door_open_point": point_dict.get(row[6]),
                               "electrical_compartment_door_open_point": point_dict.get(row[7]),
                               "first_level_fire_alarm_point": point_dict.get(row[8]),
                               "second_level_fire_alarm_point": point_dict.get(row[9]),
                               "running_light_point": point_dict.get(row[10]),
                               "fault_light_point": point_dict.get(row[11]),
                               "ac_relay_tripping_point": point_dict.get(row[12]),
                               "inside_temperature_point": point_dict.get(row[13]),
                               "outside_temperature_point": point_dict.get(row[14]),
                               "temperature_alarm_point": point_dict.get(row[15]),
                               "smoke_sensor_value_point": point_dict.get(row[16]),
                               "smoke_sensor_alarm_point": point_dict.get(row[17]),
                               "battery_safety_detection_sensor_value_point": point_dict.get(row[18]),
                               "battery_safety_detection_sensor_alarm_point": point_dict.get(row[19]),
                               "fire_extinguishing_device_status_point": point_dict.get(row[20])
                               }
                result.append(meta_result)

        resp.text = json.dumps(result)

    @staticmethod
    @user_logger
    def on_post(req, resp, id_):
        """Handles POST requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        new_values = json.loads(raw_json)

        if 'name' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['name'], str) or \
                len(str.strip(new_values['data']['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_FIRECONTROL_NAME')
        name = str.strip(new_values['data']['name'])
        water_immersion_point_id = None
        emergency_stop_point_id = None
        electrical_compartment_smoke_detector_point_id = None
        battery_compartment_door_open_point_id = None
        electrical_compartment_door_open_point_id = None
        first_level_fire_alarm_point_id = None
        second_level_fire_alarm_point_id = None
        running_light_point_id = None
        fault_light_point_id = None
        ac_relay_tripping_point_id = None
        inside_temperature_point_id = None
        outside_temperature_point_id = None
        temperature_alarm_point_id = None
        smoke_sensor_value_point_id = None
        smoke_sensor_alarm_point_id = None
        battery_safety_detection_sensor_value_point_id = None
        battery_safety_detection_sensor_alarm_point_id = None
        fire_extinguishing_device_status_point_id = None
        if 'water_immersion_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['water_immersion_point_id'], int) and \
                new_values['data']['water_immersion_point_id'] > 0:
            water_immersion_point_id = new_values['data']['water_immersion_point_id']

        if 'emergency_stop_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['emergency_stop_point_id'], int) and \
                new_values['data']['emergency_stop_point_id'] > 0:
            emergency_stop_point_id = new_values['data']['emergency_stop_point_id']

        if 'electrical_compartment_smoke_detector_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['electrical_compartment_smoke_detector_point_id'], int) and \
                new_values['data']['electrical_compartment_smoke_detector_point_id'] > 0:
            electrical_compartment_smoke_detector_point_id = new_values['data']['electrical_compartment_smoke_detector_point_id']

        if 'battery_compartment_door_open_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['battery_compartment_door_open_point_id'], int) and \
                new_values['data']['battery_compartment_door_open_point_id'] > 0:
            battery_compartment_door_open_point_id = new_values['data']['battery_compartment_door_open_point_id']

        if 'electrical_compartment_door_open_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['electrical_compartment_door_open_point_id'], int) and \
                new_values['data']['electrical_compartment_door_open_point_id'] > 0:
            electrical_compartment_door_open_point_id = new_values['data']['electrical_compartment_door_open_point_id']

        if 'first_level_fire_alarm_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['first_level_fire_alarm_point_id'], int) and \
                new_values['data']['first_level_fire_alarm_point_id'] > 0:
            first_level_fire_alarm_point_id = new_values['data']['first_level_fire_alarm_point_id']

        if 'second_level_fire_alarm_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['second_level_fire_alarm_point_id'], int) and \
                new_values['data']['second_level_fire_alarm_point_id'] > 0:
            second_level_fire_alarm_point_id = new_values['data']['second_level_fire_alarm_point_id']

        if 'running_light_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['running_light_point_id'], int) and \
                new_values['data']['running_light_point_id'] > 0:
            running_light_point_id = new_values['data']['running_light_point_id']

        if 'fault_light_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['fault_light_point_id'], int) and \
                new_values['data']['fault_light_point_id'] > 0:
            fault_light_point_id = new_values['data']['fault_light_point_id']

        if 'ac_relay_tripping_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['ac_relay_tripping_point_id'], int) and \
                new_values['data']['ac_relay_tripping_point_id'] > 0:
            ac_relay_tripping_point_id = new_values['data']['ac_relay_tripping_point_id']

        if 'inside_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['inside_temperature_point_id'], int) and \
                new_values['data']['inside_temperature_point_id'] > 0:
            inside_temperature_point_id = new_values['data']['inside_temperature_point_id']

        if 'outside_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['outside_temperature_point_id'], int) and \
                new_values['data']['outside_temperature_point_id'] > 0:
            outside_temperature_point_id = new_values['data']['outside_temperature_point_id']

        if 'temperature_alarm_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['temperature_alarm_point_id'], int) and \
                new_values['data']['temperature_alarm_point_id'] > 0:
            temperature_alarm_point_id = new_values['data']['temperature_alarm_point_id']

        if 'smoke_sensor_value_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['smoke_sensor_value_point_id'], int) and \
                new_values['data']['smoke_sensor_value_point_id'] > 0:
            smoke_sensor_value_point_id = new_values['data']['smoke_sensor_value_point_id']

        if 'smoke_sensor_alarm_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['smoke_sensor_alarm_point_id'], int) and \
                new_values['data']['smoke_sensor_alarm_point_id'] > 0:
            smoke_sensor_alarm_point_id = new_values['data']['smoke_sensor_alarm_point_id']

        if 'battery_safety_detection_sensor_value_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['battery_safety_detection_sensor_value_point_id'], int) and \
                new_values['data']['battery_safety_detection_sensor_value_point_id'] > 0:
            battery_safety_detection_sensor_value_point_id = \
                new_values['data']['battery_safety_detection_sensor_value_point_id']

        if 'battery_safety_detection_sensor_alarm_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['battery_safety_detection_sensor_alarm_point_id'], int) and \
                new_values['data']['battery_safety_detection_sensor_alarm_point_id'] > 0:
            battery_safety_detection_sensor_alarm_point_id = \
                new_values['data']['battery_safety_detection_sensor_alarm_point_id']

        if 'fire_extinguishing_device_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['fire_extinguishing_device_status_point_id'], int) and \
                new_values['data']['fire_extinguishing_device_status_point_id'] > 0:
            fire_extinguishing_device_status_point_id = new_values['data']['fire_extinguishing_device_status_point_id']

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ",
                       (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_firecontrols "
                       " WHERE energy_storage_container_id = %s AND name = %s ",
                       (id_, name,))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_FIRECONTROL_NAME_IS_ALREADY_IN_USE')

        add_values = (" INSERT INTO tbl_energy_storage_containers_firecontrols "
                      "    (name, uuid, energy_storage_container_id) "
                      " VALUES (%s, %s, %s) ")
        cursor.execute(add_values, (name,
                                    str(uuid.uuid4()),
                                    id_
                                    ))
        new_id = cursor.lastrowid
        cnx.commit()
        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_201
        resp.location = '/energystoragecontainers/' + str(id_) + '/firecontrols/' + str(new_id)


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

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

    @staticmethod
    def on_get(req, resp, id_, fid):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not fid.isdigit() or int(fid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_FIRECONTROL_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        query = (" SELECT id, name, uuid "
                 " FROM tbl_energy_storage_containers ")
        cursor.execute(query)
        rows_energystoragecontainers = cursor.fetchall()

        energy_storage_container_dict = dict()
        if rows_energystoragecontainers is not None and len(rows_energystoragecontainers) > 0:
            for row in rows_energystoragecontainers:
                energy_storage_container_dict[row[0]] = {"id": row[0],
                                                         "name": row[1],
                                                         "uuid": row[2]}

        # query point dict
        query = (" SELECT id, name "
                 " FROM tbl_points ")
        cursor.execute(query)
        rows_points = cursor.fetchall()

        point_dict = dict()
        if rows_points is not None and len(rows_points) > 0:
            for row in rows_points:
                point_dict[row[0]] = {"id": row[0],
                                      "name": row[1]}

        query = (" SELECT id, name, uuid "
                 " FROM tbl_energy_storage_containers_firecontrols "
                 " WHERE id = %s ")
        cursor.execute(query, (fid,))
        row = cursor.fetchone()
        cursor.close()
        cnx.close()

        if row is None:
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_FIRECONTROL_NOT_FOUND')
        else:
            meta_result = {"id": row[0],
                           "name": row[1],
                           "uuid": row[2],
                           "water_immersion_point": row[3],
                           "emergency_stop_point": row[4],
                           "electrical_compartment_smoke_detector_point": row[5],
                           "battery_compartment_door_open_point": row[6],
                           "electrical_compartment_door_open_point": row[7],
                           "first_level_fire_alarm_point": row[8],
                           "second_level_fire_alarm_point": row[9],
                           "running_light_point": row[10],
                           "fault_light_point": row[11],
                           "ac_relay_tripping_point": row[12],
                           "inside_temperature_point": point_dict.get(row[13]),
                           "outside_temperature_point": point_dict.get(row[14]),
                           "temperature_alarm_point": point_dict.get(row[15]),
                           "smoke_sensor_value_point": point_dict.get(row[16]),
                           "smoke_sensor_alarm_point": point_dict.get(row[17]),
                           "battery_safety_detection_sensor_value_point": point_dict.get(row[18]),
                           "battery_safety_detection_sensor_alarm_point": point_dict.get(row[19]),
                           "fire_extinguishing_device_status_point": point_dict.get(row[20])
                           }

        resp.text = json.dumps(meta_result)

    @staticmethod
    @user_logger
    def on_delete(req, resp, id_, fid):
        admin_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not fid.isdigit() or int(fid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_FIRECONTROL_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_firecontrols "
                       " WHERE id = %s ", (fid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_FIRECONTROL_NOT_FOUND')

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_firecontrols "
                       " WHERE id = %s ", (fid,))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_204

    @staticmethod
    @user_logger
    def on_put(req, resp, id_, fid):
        """Handles PUT requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        if not fid.isdigit() or int(fid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_FIRECONTROL_ID')

        new_values = json.loads(raw_json)

        if 'name' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['name'], str) or \
                len(str.strip(new_values['data']['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_FIRECONTROL_NAME')
        name = str.strip(new_values['data']['name'])
        water_immersion_point_id = None
        emergency_stop_point_id = None
        electrical_compartment_smoke_detector_point_id = None
        battery_compartment_door_open_point_id = None
        electrical_compartment_door_open_point_id = None
        first_level_fire_alarm_point_id = None
        second_level_fire_alarm_point_id = None
        running_light_point_id = None
        fault_light_point_id = None
        ac_relay_tripping_point_id = None
        inside_temperature_point_id = None
        outside_temperature_point_id = None
        temperature_alarm_point_id = None
        smoke_sensor_value_point_id = None
        smoke_sensor_alarm_point_id = None
        battery_safety_detection_sensor_value_point_id = None
        battery_safety_detection_sensor_alarm_point_id = None
        fire_extinguishing_device_status_point_id = None
        if 'water_immersion_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['water_immersion_point_id'], int) and \
                new_values['data']['water_immersion_point_id'] > 0:
            water_immersion_point_id = new_values['data']['water_immersion_point_id']

        if 'emergency_stop_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['emergency_stop_point_id'], int) and \
                new_values['data']['emergency_stop_point_id'] > 0:
            emergency_stop_point_id = new_values['data']['emergency_stop_point_id']

        if 'electrical_compartment_smoke_detector_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['electrical_compartment_smoke_detector_point_id'], int) and \
                new_values['data']['electrical_compartment_smoke_detector_point_id'] > 0:
            electrical_compartment_smoke_detector_point_id = \
                new_values['data']['electrical_compartment_smoke_detector_point_id']

        if 'battery_compartment_door_open_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['battery_compartment_door_open_point_id'], int) and \
                new_values['data']['battery_compartment_door_open_point_id'] > 0:
            battery_compartment_door_open_point_id = new_values['data']['battery_compartment_door_open_point_id']

        if 'electrical_compartment_door_open_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['electrical_compartment_door_open_point_id'], int) and \
                new_values['data']['electrical_compartment_door_open_point_id'] > 0:
            electrical_compartment_door_open_point_id = new_values['data']['electrical_compartment_door_open_point_id']

        if 'first_level_fire_alarm_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['first_level_fire_alarm_point_id'], int) and \
                new_values['data']['first_level_fire_alarm_point_id'] > 0:
            first_level_fire_alarm_point_id = new_values['data']['first_level_fire_alarm_point_id']

        if 'second_level_fire_alarm_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['second_level_fire_alarm_point_id'], int) and \
                new_values['data']['second_level_fire_alarm_point_id'] > 0:
            second_level_fire_alarm_point_id = new_values['data']['second_level_fire_alarm_point_id']

        if 'running_light_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['running_light_point_id'], int) and \
                new_values['data']['running_light_point_id'] > 0:
            running_light_point_id = new_values['data']['running_light_point_id']

        if 'fault_light_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['fault_light_point_id'], int) and \
                new_values['data']['fault_light_point_id'] > 0:
            fault_light_point_id = new_values['data']['fault_light_point_id']

        if 'ac_relay_tripping_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['ac_relay_tripping_point_id'], int) and \
                new_values['data']['ac_relay_tripping_point_id'] > 0:
            ac_relay_tripping_point_id = new_values['data']['ac_relay_tripping_point_id']

        if 'inside_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['inside_temperature_point_id'], int) and \
                new_values['data']['inside_temperature_point_id'] > 0:
            inside_temperature_point_id = new_values['data']['inside_temperature_point_id']

        if 'outside_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['outside_temperature_point_id'], int) and \
                new_values['data']['outside_temperature_point_id'] > 0:
            outside_temperature_point_id = new_values['data']['outside_temperature_point_id']

        if 'temperature_alarm_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['temperature_alarm_point_id'], int) and \
                new_values['data']['temperature_alarm_point_id'] > 0:
            temperature_alarm_point_id = new_values['data']['temperature_alarm_point_id']

        if 'smoke_sensor_value_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['smoke_sensor_value_point_id'], int) and \
                new_values['data']['smoke_sensor_value_point_id'] > 0:
            smoke_sensor_value_point_id = new_values['data']['smoke_sensor_value_point_id']

        if 'smoke_sensor_alarm_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['smoke_sensor_alarm_point_id'], int) and \
                new_values['data']['smoke_sensor_alarm_point_id'] > 0:
            smoke_sensor_alarm_point_id = new_values['data']['smoke_sensor_alarm_point_id']

        if 'battery_safety_detection_sensor_value_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['battery_safety_detection_sensor_value_point_id'], int) and \
                new_values['data']['battery_safety_detection_sensor_value_point_id'] > 0:
            battery_safety_detection_sensor_value_point_id = \
                new_values['data']['battery_safety_detection_sensor_value_point_id']

        if 'battery_safety_detection_sensor_alarm_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['battery_safety_detection_sensor_alarm_point_id'], int) and \
                new_values['data']['battery_safety_detection_sensor_alarm_point_id'] > 0:
            battery_safety_detection_sensor_alarm_point_id = \
                new_values['data']['battery_safety_detection_sensor_alarm_point_id']

        if 'fire_extinguishing_device_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['fire_extinguishing_device_status_point_id'], int) and \
                new_values['data']['fire_extinguishing_device_status_point_id'] > 0:
            fire_extinguishing_device_status_point_id = \
                new_values['data']['fire_extinguishing_device_status_point_id']

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_firecontrols "
                       " WHERE id = %s ", (fid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_FIRECONTROL_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_firecontrols "
                       " WHERE energy_storage_container_id = %s AND name = %s AND id != %s ",
                       (id_, name, fid))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_FIRECONTROL_NAME_IS_ALREADY_IN_USE')

        update_row = (" UPDATE tbl_energy_storage_containers_firecontrols "
                      " SET name = %s "
                      "     WHERE id = %s ")
        cursor.execute(update_row, (name,
                                    fid))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_200


class EnergyStorageContainerGridCollection:

This code seems to be duplicated in your project.

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

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

    @staticmethod
    def on_get(req, resp, id_):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        # query meter dict
        query = (" SELECT id, name, uuid "
                 " FROM tbl_meters ")
        cursor.execute(query)
        rows_meters = cursor.fetchall()

        meter_dict = dict()
        if rows_meters is not None and len(rows_meters) > 0:
            for row in rows_meters:
                meter_dict[row[0]] = {"id": row[0],
                                      "name": row[1],
                                      "uuid": row[2]}
        # query point dict
        query = (" SELECT id, name "
                 " FROM tbl_points ")
        cursor.execute(query)
        rows_points = cursor.fetchall()

        point_dict = dict()
        if rows_points is not None and len(rows_points) > 0:
            for row in rows_points:
                point_dict[row[0]] = {"id": row[0],
                                      "name": row[1]}

        query = (" SELECT id, name, uuid, "
                 "        power_point_id, buy_meter_id, sell_meter_id, capacity, "
                 "        total_active_power_point_id, "
                 "        active_power_a_point_id, "
                 "        active_power_b_point_id, "
                 "        active_power_c_point_id, "
                 "        total_reactive_power_point_id, "
                 "        reactive_power_a_point_id, "
                 "        reactive_power_b_point_id, "
                 "        reactive_power_c_point_id, "
                 "        total_apparent_power_point_id, "
                 "        apparent_power_a_point_id, "
                 "        apparent_power_b_point_id, "
                 "        apparent_power_c_point_id, "
                 "        total_power_factor_point_id, "
                 "        active_energy_import_point_id, "
                 "        active_energy_export_point_id, "
                 "        active_energy_net_point_id "
                 " FROM tbl_energy_storage_containers_grids "
                 " WHERE energy_storage_container_id = %s "
                 " ORDER BY name ")
        cursor.execute(query, (id_,))
        rows = cursor.fetchall()

        result = list()
        if rows is not None and len(rows) > 0:
            for row in rows:
                meta_result = {"id": row[0],
                               "name": row[1],
                               "uuid": row[2],
                               "power_point": point_dict.get(row[3]),
                               "buy_meter": meter_dict.get(row[4]),
                               "sell_meter": meter_dict.get(row[5]),
                               "capacity": row[6],
                               "total_active_power_point": point_dict.get(row[7]),
                               "active_power_a_point": point_dict.get(row[8]),
                               "active_power_b_point": point_dict.get(row[9]),
                               "active_power_c_point": point_dict.get(row[10]),
                               "total_reactive_power_point": point_dict.get(row[11]),
                               "reactive_power_a_point": point_dict.get(row[12]),
                               "reactive_power_b_point": point_dict.get(row[13]),
                               "reactive_power_c_point": point_dict.get(row[14]),
                               "total_apparent_power_point": point_dict.get(row[15]),
                               "apparent_power_a_point": point_dict.get(row[16]),
                               "apparent_power_b_point": point_dict.get(row[17]),
                               "apparent_power_c_point": point_dict.get(row[19]),
                               "total_power_factor_point": point_dict.get(row[19]),
                               "active_energy_import_point": point_dict.get(row[20]),
                               "active_energy_export_point": point_dict.get(row[21]),
                               "active_energy_net_point_id": point_dict.get(row[22]),
                               }
                result.append(meta_result)

        resp.text = json.dumps(result)

    @staticmethod
    @user_logger
    def on_post(req, resp, id_):
        """Handles POST requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        new_values = json.loads(raw_json)

        if 'name' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['name'], str) or \
                len(str.strip(new_values['data']['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_GRID_NAME')
        name = str.strip(new_values['data']['name'])

        if 'power_point_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['power_point_id'], int) or \
                new_values['data']['power_point_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_POWER_POINT_ID')
        power_point_id = new_values['data']['power_point_id']

        if 'buy_meter_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['buy_meter_id'], int) or \
                new_values['data']['buy_meter_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_BUY_METER_ID')
        buy_meter_id = new_values['data']['buy_meter_id']

        if 'sell_meter_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['sell_meter_id'], int) or \
                new_values['data']['sell_meter_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_SELL_METER_ID')
        sell_meter_id = new_values['data']['sell_meter_id']

        if 'capacity' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['capacity'], float) or
                     isinstance(new_values['data']['capacity'], int)):
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_CAPACITY')
        capacity = Decimal(new_values['data']['capacity'])

        total_active_power_point_id = None
        active_power_a_point_id = None
        active_power_b_point_id = None
        active_power_c_point_id = None
        total_reactive_power_point_id = None
        reactive_power_a_point_id = None
        reactive_power_b_point_id = None
        reactive_power_c_point_id = None
        total_apparent_power_point_id = None
        apparent_power_a_point_id = None
        apparent_power_b_point_id = None
        apparent_power_c_point_id = None
        total_power_factor_point_id = None
        active_energy_import_point_id = None
        active_energy_export_point_id = None
        active_energy_net_point_id = None

        if 'total_active_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_active_power_point_id'], int) and \
                new_values['data']['total_active_power_point_id'] > 0:
            total_active_power_point_id = new_values['data']['total_active_power_point_id']

        if 'active_power_a_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_power_a_point_id'], int) and \
                new_values['data']['active_power_a_point_id'] > 0:
            active_power_a_point_id = new_values['data']['active_power_a_point_id']

        if 'active_power_b_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_power_b_point_id'], int) and \
                new_values['data']['active_power_b_point_id'] > 0:
            active_power_b_point_id = new_values['data']['active_power_b_point_id']

        if 'active_power_c_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_power_c_point_id'], int) and \
                new_values['data']['active_power_c_point_id'] > 0:
            active_power_c_point_id = new_values['data']['active_power_c_point_id']

        if 'total_reactive_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_reactive_power_point_id'], int) and \
                new_values['data']['total_reactive_power_point_id'] > 0:
            total_reactive_power_point_id = new_values['data']['total_reactive_power_point_id']

        if 'reactive_power_a_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['reactive_power_a_point_id'], int) and \
                new_values['data']['reactive_power_a_point_id'] > 0:
            reactive_power_a_point_id = new_values['data']['reactive_power_a_point_id']

        if 'reactive_power_b_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['reactive_power_b_point_id'], int) and \
                new_values['data']['reactive_power_b_point_id'] > 0:
            reactive_power_b_point_id = new_values['data']['reactive_power_b_point_id']

        if 'reactive_power_c_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['reactive_power_c_point_id'], int) and \
                new_values['data']['reactive_power_c_point_id'] > 0:
            reactive_power_c_point_id = new_values['data']['reactive_power_c_point_id']

        if 'total_apparent_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_apparent_power_point_id'], int) and \
                new_values['data']['total_apparent_power_point_id'] > 0:
            total_apparent_power_point_id = new_values['data']['total_apparent_power_point_id']

        if 'apparent_power_a_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['apparent_power_a_point_id'], int) and \
                new_values['data']['apparent_power_a_point_id'] > 0:
            apparent_power_a_point_id = new_values['data']['apparent_power_a_point_id']

        if 'apparent_power_b_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['apparent_power_b_point_id'], int) and \
                new_values['data']['apparent_power_b_point_id'] > 0:
            apparent_power_b_point_id = new_values['data']['apparent_power_b_point_id']

        if 'apparent_power_c_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['apparent_power_c_point_id'], int) and \
                new_values['data']['apparent_power_c_point_id'] > 0:
            apparent_power_c_point_id = new_values['data']['apparent_power_c_point_id']

        if 'total_power_factor_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_power_factor_point_id'], int) and \
                new_values['data']['total_power_factor_point_id'] > 0:
            total_power_factor_point_id = new_values['data']['total_power_factor_point_id']

        if 'active_energy_import_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_energy_import_point_id'], int) and \
                new_values['data']['active_energy_import_point_id'] > 0:
            active_energy_import_point_id = new_values['data']['active_energy_import_point_id']

        if 'active_energy_export_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_energy_export_point_id'], int) and \
                new_values['data']['active_energy_export_point_id'] > 0:
            active_energy_export_point_id = new_values['data']['active_energy_export_point_id']

        if 'active_energy_net_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_energy_net_point_id'], int) and \
                new_values['data']['active_energy_net_point_id'] > 0:
            active_energy_net_point_id = new_values['data']['active_energy_net_point_id']

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ",
                       (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_grids "
                       " WHERE energy_storage_container_id = %s AND name = %s ",
                       (id_, name,))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_GRID_NAME_IS_ALREADY_IN_USE')

        cursor.execute(" SELECT name "
                       " FROM tbl_points "
                       " WHERE id = %s ",
                       (power_point_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.POWER_POINT_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_meters "
                       " WHERE id = %s ",
                       (buy_meter_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.BUY_METER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_meters "
                       " WHERE id = %s ",
                       (sell_meter_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.SELL_METER_NOT_FOUND')

        add_values = (" INSERT INTO tbl_energy_storage_containers_grids "
                      "    (name, uuid, energy_storage_container_id, power_point_id, "
                      "     buy_meter_id, sell_meter_id, capacity, "
                      "     total_active_power_point_id, "
                      "     active_power_a_point_id, "
                      "     active_power_b_point_id, "
                      "     active_power_c_point_id, "
                      "     total_reactive_power_point_id, "
                      "     reactive_power_a_point_id, "
                      "     reactive_power_b_point_id, "
                      "     reactive_power_c_point_id, "
                      "     total_apparent_power_point_id, "
                      "     apparent_power_a_point_id, "
                      "     apparent_power_b_point_id, "
                      "     apparent_power_c_point_id, "
                      "     total_power_factor_point_id, "
                      "     active_energy_import_point_id, "
                      "     active_energy_export_point_id, "
                      "     active_energy_net_point_id) "
                      " VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, "
                      "         %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, "
                      "         %s, %s, %s) ")
        cursor.execute(add_values, (name,
                                    str(uuid.uuid4()),
                                    id_,
                                    power_point_id,
                                    buy_meter_id,
                                    sell_meter_id,
                                    capacity,
                                    total_active_power_point_id,
                                    active_power_a_point_id,
                                    active_power_b_point_id,
                                    active_power_c_point_id,
                                    total_reactive_power_point_id,
                                    reactive_power_a_point_id,
                                    reactive_power_b_point_id,
                                    reactive_power_c_point_id,
                                    total_apparent_power_point_id,
                                    apparent_power_a_point_id,
                                    apparent_power_b_point_id,
                                    apparent_power_c_point_id,
                                    total_power_factor_point_id,
                                    active_energy_import_point_id,
                                    active_energy_export_point_id,
                                    active_energy_net_point_id
                                    ))
        new_id = cursor.lastrowid
        cnx.commit()
        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_201
        resp.location = '/energystoragecontainers/' + str(id_) + '/grids/' + str(new_id)


class EnergyStorageContainerGridItem:

This code seems to be duplicated in your project.

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

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

    @staticmethod
    def on_get(req, resp, id_, gid):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not gid.isdigit() or int(gid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_GRID_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        query = (" SELECT id, name, uuid "
                 " FROM tbl_energy_storage_containers ")
        cursor.execute(query)
        rows_energystoragecontainers = cursor.fetchall()

        energy_storage_container_dict = dict()
        if rows_energystoragecontainers is not None and len(rows_energystoragecontainers) > 0:
            for row in rows_energystoragecontainers:
                energy_storage_container_dict[row[0]] = {"id": row[0],
                                                         "name": row[1],
                                                         "uuid": row[2]}
        # query meter dict
        query = (" SELECT id, name, uuid "
                 " FROM tbl_meters ")
        cursor.execute(query)
        rows_meters = cursor.fetchall()

        meter_dict = dict()
        if rows_meters is not None and len(rows_meters) > 0:
            for row in rows_meters:
                meter_dict[row[0]] = {"id": row[0],
                                      "name": row[1],
                                      "uuid": row[2]}
        # query point dict
        query = (" SELECT id, name "
                 " FROM tbl_points ")
        cursor.execute(query)
        rows_points = cursor.fetchall()

        point_dict = dict()
        if rows_points is not None and len(rows_points) > 0:
            for row in rows_points:
                point_dict[row[0]] = {"id": row[0],
                                      "name": row[1]}

        query = (" SELECT id, name, uuid, energy_storage_container_id, power_point_id, "
                 "        buy_meter_id, sell_meter_id, capacity, "
                 "        total_active_power_point_id, "
                 "        active_power_a_point_id, "
                 "        active_power_b_point_id, "
                 "        active_power_c_point_id, "
                 "        total_reactive_power_point_id, "
                 "        reactive_power_a_point_id, "
                 "        reactive_power_b_point_id, "
                 "        reactive_power_c_point_id, "
                 "        total_apparent_power_point_id, "
                 "        apparent_power_a_point_id, "
                 "        apparent_power_b_point_id, "
                 "        apparent_power_c_point_id, "
                 "        total_power_factor_point_id, "
                 "        active_energy_import_point_id, "
                 "        active_energy_export_point_id, "
                 "        active_energy_net_point_id "
                 " FROM tbl_energy_storage_containers_grids "
                 " WHERE id = %s ")
        cursor.execute(query, (gid,))
        row = cursor.fetchone()
        cursor.close()
        cnx.close()

        if row is None:
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_GRID_NOT_FOUND')
        else:
            meta_result = {"id": row[0],
                           "name": row[1],
                           "uuid": row[2],
                           "energy_storage_container": energy_storage_container_dict.get(row[3]),
                           "power_point": point_dict.get(row[4]),
                           "buy_meter": meter_dict.get(row[5]),
                           "sell_meter": meter_dict.get(row[6]),
                           "capacity": row[7],
                           "total_active_power_point": point_dict.get(row[8]),
                           "active_power_a_point": point_dict.get(row[9]),
                           "active_power_b_point": point_dict.get(row[10]),
                           "active_power_c_point": point_dict.get(row[11]),
                           "total_reactive_power_point": point_dict.get(row[12]),
                           "reactive_power_a_point": point_dict.get(row[13]),
                           "reactive_power_b_point": point_dict.get(row[14]),
                           "reactive_power_c_point": point_dict.get(row[15]),
                           "total_apparent_power_point": point_dict.get(row[16]),
                           "apparent_power_a_point": point_dict.get(row[17]),
                           "apparent_power_b_point": point_dict.get(row[18]),
                           "apparent_power_c_point": point_dict.get(row[19]),
                           "total_power_factor_point": point_dict.get(row[20]),
                           "active_energy_import_point": point_dict.get(row[21]),
                           "active_energy_export_point": point_dict.get(row[22]),
                           "active_energy_net_point_id": point_dict.get(row[23]),
                           }

        resp.text = json.dumps(meta_result)

    @staticmethod
    @user_logger
    def on_delete(req, resp, id_, gid):
        admin_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not gid.isdigit() or int(gid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_GRID_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_grids "
                       " WHERE id = %s ", (gid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_GRID_NOT_FOUND')

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_grids "
                       " WHERE id = %s ", (gid,))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_204

    @staticmethod
    @user_logger
    def on_put(req, resp, id_, gid):
        """Handles PUT requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        if not gid.isdigit() or int(gid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_GRID_ID')

        new_values = json.loads(raw_json)

        if 'name' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['name'], str) or \
                len(str.strip(new_values['data']['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_GRID_NAME')
        name = str.strip(new_values['data']['name'])

        if 'power_point_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['power_point_id'], int) or \
                new_values['data']['power_point_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_POWER_POINT_ID')
        power_point_id = new_values['data']['power_point_id']

        if 'buy_meter_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['buy_meter_id'], int) or \
                new_values['data']['buy_meter_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_BUY_METER_ID')
        buy_meter_id = new_values['data']['buy_meter_id']

        if 'sell_meter_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['sell_meter_id'], int) or \
                new_values['data']['sell_meter_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_METER_ID')
        sell_meter_id = new_values['data']['sell_meter_id']

        if 'capacity' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['capacity'], float) or
                     isinstance(new_values['data']['capacity'], int)):
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_CAPACITY')
        capacity = Decimal(new_values['data']['capacity'])
        total_active_power_point_id = None
        active_power_a_point_id = None
        active_power_b_point_id = None
        active_power_c_point_id = None
        total_reactive_power_point_id = None
        reactive_power_a_point_id = None
        reactive_power_b_point_id = None
        reactive_power_c_point_id = None
        total_apparent_power_point_id = None
        apparent_power_a_point_id = None
        apparent_power_b_point_id = None
        apparent_power_c_point_id = None
        total_power_factor_point_id = None
        active_energy_import_point_id = None
        active_energy_export_point_id = None
        active_energy_net_point_id = None

        if 'total_active_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_active_power_point_id'], int) and \
                new_values['data']['total_active_power_point_id'] > 0:
            total_active_power_point_id = new_values['data']['total_active_power_point_id']

        if 'active_power_a_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_power_a_point_id'], int) and \
                new_values['data']['active_power_a_point_id'] > 0:
            active_power_a_point_id = new_values['data']['active_power_a_point_id']

        if 'active_power_b_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_power_b_point_id'], int) and \
                new_values['data']['active_power_b_point_id'] > 0:
            active_power_b_point_id = new_values['data']['active_power_b_point_id']

        if 'active_power_c_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_power_c_point_id'], int) and \
                new_values['data']['active_power_c_point_id'] > 0:
            active_power_c_point_id = new_values['data']['active_power_c_point_id']

        if 'total_reactive_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_reactive_power_point_id'], int) and \
                new_values['data']['total_reactive_power_point_id'] > 0:
            total_reactive_power_point_id = new_values['data']['total_reactive_power_point_id']

        if 'reactive_power_a_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['reactive_power_a_point_id'], int) and \
                new_values['data']['reactive_power_a_point_id'] > 0:
            reactive_power_a_point_id = new_values['data']['reactive_power_a_point_id']

        if 'reactive_power_b_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['reactive_power_b_point_id'], int) and \
                new_values['data']['reactive_power_b_point_id'] > 0:
            reactive_power_b_point_id = new_values['data']['reactive_power_b_point_id']

        if 'reactive_power_c_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['reactive_power_c_point_id'], int) and \
                new_values['data']['reactive_power_c_point_id'] > 0:
            reactive_power_c_point_id = new_values['data']['reactive_power_c_point_id']

        if 'total_apparent_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_apparent_power_point_id'], int) and \
                new_values['data']['total_apparent_power_point_id'] > 0:
            total_apparent_power_point_id = new_values['data']['total_apparent_power_point_id']

        if 'apparent_power_a_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['apparent_power_a_point_id'], int) and \
                new_values['data']['apparent_power_a_point_id'] > 0:
            apparent_power_a_point_id = new_values['data']['apparent_power_a_point_id']

        if 'apparent_power_b_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['apparent_power_b_point_id'], int) and \
                new_values['data']['apparent_power_b_point_id'] > 0:
            apparent_power_b_point_id = new_values['data']['apparent_power_b_point_id']

        if 'apparent_power_c_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['apparent_power_c_point_id'], int) and \
                new_values['data']['apparent_power_c_point_id'] > 0:
            apparent_power_c_point_id = new_values['data']['apparent_power_c_point_id']

        if 'total_power_factor_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_power_factor_point_id'], int) and \
                new_values['data']['total_power_factor_point_id'] > 0:
            total_power_factor_point_id = new_values['data']['total_power_factor_point_id']

        if 'active_energy_import_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_energy_import_point_id'], int) and \
                new_values['data']['active_energy_import_point_id'] > 0:
            active_energy_import_point_id = new_values['data']['active_energy_import_point_id']

        if 'active_energy_export_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_energy_export_point_id'], int) and \
                new_values['data']['active_energy_export_point_id'] > 0:
            active_energy_export_point_id = new_values['data']['active_energy_export_point_id']

        if 'active_energy_net_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_energy_net_point_id'], int) and \
                new_values['data']['active_energy_net_point_id'] > 0:
            active_energy_net_point_id = new_values['data']['active_energy_net_point_id']

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_grids "
                       " WHERE id = %s ", (gid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_GRID_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_grids "
                       " WHERE energy_storage_container_id = %s AND name = %s AND id != %s ",
                       (id_, name, gid))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_GRID_NAME_IS_ALREADY_IN_USE')

        cursor.execute(" SELECT name "
                       " FROM tbl_points "
                       " WHERE id = %s ",
                       (power_point_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.POWER_POINT_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_meters "
                       " WHERE id = %s ",
                       (buy_meter_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.BUY_METER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_meters "
                       " WHERE id = %s ",
                       (sell_meter_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.SELL_METER_NOT_FOUND')

        update_row = (" UPDATE tbl_energy_storage_containers_grids "
                      " SET name = %s, energy_storage_container_id = %s, "
                      "     power_point_id = %s, buy_meter_id = %s, sell_meter_id = %s, capacity = %s, "
                      "     total_active_power_point_id = %s, "
                      "     active_power_a_point_id = %s, "
                      "     active_power_b_point_id = %s, "
                      "     active_power_c_point_id = %s, "
                      "     total_reactive_power_point_id = %s, "
                      "     reactive_power_a_point_id = %s, "
                      "     reactive_power_b_point_id = %s, "
                      "     reactive_power_c_point_id = %s, "
                      "     total_apparent_power_point_id = %s, "
                      "     apparent_power_a_point_id = %s, "
                      "     apparent_power_b_point_id = %s, "
                      "     apparent_power_c_point_id = %s, "
                      "     total_power_factor_point_id = %s, "
                      "     active_energy_import_point_id = %s, "
                      "     active_energy_export_point_id = %s, "
                      "     active_energy_net_point_id = %s "
                      "     WHERE id = %s ")
        cursor.execute(update_row, (name,
                                    id_,
                                    power_point_id,
                                    buy_meter_id,
                                    sell_meter_id,
                                    capacity,
                                    total_active_power_point_id,
                                    active_power_a_point_id,
                                    active_power_b_point_id,
                                    active_power_c_point_id,
                                    total_reactive_power_point_id,
                                    reactive_power_a_point_id,
                                    reactive_power_b_point_id,
                                    reactive_power_c_point_id,
                                    total_apparent_power_point_id,
                                    apparent_power_a_point_id,
                                    apparent_power_b_point_id,
                                    apparent_power_c_point_id,
                                    total_power_factor_point_id,
                                    active_energy_import_point_id,
                                    active_energy_export_point_id,
                                    active_energy_net_point_id,
                                    gid))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_200


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

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

    @staticmethod
    def on_get(req, resp, id_):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        # query point dict
        query = (" SELECT id, name "
                 " FROM tbl_points ")
        cursor.execute(query)
        rows_points = cursor.fetchall()

        point_dict = dict()
        if rows_points is not None and len(rows_points) > 0:
            for row in rows_points:
                point_dict[row[0]] = {"id": row[0],
                                      "name": row[1]}

        query = (" SELECT id, name, uuid "
                 " FROM tbl_energy_storage_containers_hvacs "
                 " WHERE energy_storage_container_id = %s "
                 " ORDER BY name ")
        cursor.execute(query, (id_,))
        rows = cursor.fetchall()

        result = list()
        if rows is not None and len(rows) > 0:
            for row in rows:
                meta_result = {"id": row[0],
                               "name": row[1],
                               "uuid": row[2]
                               }
                result.append(meta_result)

        resp.text = json.dumps(result)

    @staticmethod
    @user_logger
    def on_post(req, resp, id_):
        """Handles POST requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        new_values = json.loads(raw_json)

        if 'name' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['name'], str) or \
                len(str.strip(new_values['data']['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_HVAC_NAME')
        name = str.strip(new_values['data']['name'])

        working_status_point_id = None
        indoor_fan_status_point_id = None
        outdoor_fan_status_point_id = None
        emergency_fan_status_point_id = None
        compressor_status_point_id = None
        electric_heating_status_point_id = None
        coil_temperature_point_id = None
        temperature_outside_point_id = None
        temperature_inside_point_id = None
        humidity_inside_point_id = None
        condensation_temperature_point_id = None
        defrosting_temperature_point_id = None
        outlet_air_temperature_point_id = None
        return_air_temperature_point_id = None
        exhaust_temperature_point_id = None
        heating_on_temperature_point_id = None
        heating_off_temperature_point_id = None
        heating_control_hysteresis_point_id = None
        cooling_on_temperature_point_id = None
        cooling_off_temperature_point_id = None
        cooling_control_hysteresis_point_id = None
        high_temperature_alarm_set_point_id = None
        low_temperature_alarm_set_point_id = None
        high_humidity_alarm_set_point_id = None

        if 'working_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['working_status_point_id'], int) and \
                new_values['data']['working_status_point_id'] > 0:
            working_status_point_id = new_values['data']['working_status_point_id']
        if 'indoor_fan_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['indoor_fan_status_point_id'], int) and \
                new_values['data']['indoor_fan_status_point_id'] > 0:
            indoor_fan_status_point_id = new_values['data']['indoor_fan_status_point_id']
        if 'outdoor_fan_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['outdoor_fan_status_point_id'], int) and \
                new_values['data']['outdoor_fan_status_point_id'] > 0:
            outdoor_fan_status_point_id = new_values['data']['outdoor_fan_status_point_id']
        if 'emergency_fan_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['emergency_fan_status_point_id'], int) and \
                new_values['data']['emergency_fan_status_point_id'] > 0:
            emergency_fan_status_point_id = new_values['data']['emergency_fan_status_point_id']
        if 'compressor_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['compressor_status_point_id'], int) and \
                new_values['data']['compressor_status_point_id'] > 0:
            compressor_status_point_id = new_values['data']['compressor_status_point_id']
        if 'electric_heating_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['electric_heating_status_point_id'], int) and \
                new_values['data']['electric_heating_status_point_id'] > 0:
            electric_heating_status_point_id = new_values['data']['electric_heating_status_point_id']
        if 'coil_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['coil_temperature_point_id'], int) and \
                new_values['data']['coil_temperature_point_id'] > 0:
            coil_temperature_point_id = new_values['data']['coil_temperature_point_id']
        if 'temperature_outside_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['temperature_outside_point_id'], int) and \
                new_values['data']['temperature_outside_point_id'] > 0:
            temperature_outside_point_id = new_values['data']['temperature_outside_point_id']
        if 'temperature_inside_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['temperature_inside_point_id'], int) and \
                new_values['data']['temperature_inside_point_id'] > 0:
            temperature_inside_point_id = new_values['data']['temperature_inside_point_id']
        if 'humidity_inside_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['humidity_inside_point_id'], int) and \
                new_values['data']['humidity_inside_point_id'] > 0:
            humidity_inside_point_id = new_values['data']['humidity_inside_point_id']
        if 'condensation_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['condensation_temperature_point_id'], int) and \
                new_values['data']['condensation_temperature_point_id'] > 0:
            condensation_temperature_point_id = new_values['data']['condensation_temperature_point_id']
        if 'defrosting_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['defrosting_temperature_point_id'], int) and \
                new_values['data']['defrosting_temperature_point_id'] > 0:
            defrosting_temperature_point_id = new_values['data']['defrosting_temperature_point_id']
        if 'outlet_air_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['outlet_air_temperature_point_id'], int) and \
                new_values['data']['outlet_air_temperature_point_id'] > 0:
            outlet_air_temperature_point_id = new_values['data']['outlet_air_temperature_point_id']
        if 'return_air_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['return_air_temperature_point_id'], int) and \
                new_values['data']['return_air_temperature_point_id'] > 0:
            return_air_temperature_point_id = new_values['data']['return_air_temperature_point_id']
        if 'exhaust_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['exhaust_temperature_point_id'], int) and \
                new_values['data']['exhaust_temperature_point_id'] > 0:
            exhaust_temperature_point_id = new_values['data']['exhaust_temperature_point_id']
        if 'heating_on_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['heating_on_temperature_point_id'], int) and \
                new_values['data']['heating_on_temperature_point_id'] > 0:
            heating_on_temperature_point_id = new_values['data']['heating_on_temperature_point_id']
        if 'heating_off_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['heating_off_temperature_point_id'], int) and \
                new_values['data']['heating_off_temperature_point_id'] > 0:
            heating_off_temperature_point_id = new_values['data']['heating_off_temperature_point_id']
        if 'heating_control_hysteresis_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['heating_control_hysteresis_point_id'], int) and \
                new_values['data']['heating_control_hysteresis_point_id'] > 0:
            heating_control_hysteresis_point_id = new_values['data']['heating_control_hysteresis_point_id']
        if 'cooling_on_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['cooling_on_temperature_point_id'], int) and \
                new_values['data']['cooling_on_temperature_point_id'] > 0:
            cooling_on_temperature_point_id = new_values['data']['cooling_on_temperature_point_id']
        if 'cooling_off_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['cooling_off_temperature_point_id'], int) and \
                new_values['data']['cooling_off_temperature_point_id'] > 0:
            cooling_off_temperature_point_id = new_values['data']['cooling_off_temperature_point_id']
        if 'cooling_control_hysteresis_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['cooling_control_hysteresis_point_id'], int) and \
                new_values['data']['cooling_control_hysteresis_point_id'] > 0:
            cooling_control_hysteresis_point_id = new_values['data']['cooling_control_hysteresis_point_id']
        if 'high_temperature_alarm_set_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['high_temperature_alarm_set_point_id'], int) and \
                new_values['data']['high_temperature_alarm_set_point_id'] > 0:
            high_temperature_alarm_set_point_id = new_values['data']['high_temperature_alarm_set_point_id']
        if 'low_temperature_alarm_set_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['low_temperature_alarm_set_point_id'], int) and \
                new_values['data']['low_temperature_alarm_set_point_id'] > 0:
            low_temperature_alarm_set_point_id = new_values['data']['low_temperature_alarm_set_point_id']
        if 'high_humidity_alarm_set_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['high_humidity_alarm_set_point_id'], int) and \
                new_values['data']['high_humidity_alarm_set_point_id'] > 0:
            high_humidity_alarm_set_point_id = new_values['data']['high_humidity_alarm_set_point_id']

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ",
                       (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_hvacs "
                       " WHERE energy_storage_container_id = %s AND name = %s ",
                       (id_, name,))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_HVAC_NAME_IS_ALREADY_IN_USE')

        add_values = (" INSERT INTO tbl_energy_storage_containers_hvacs "
                      "    (name, uuid, energy_storage_container_id) "
                      " VALUES (%s, %s, %s) ")
        cursor.execute(add_values, (name,
                                    str(uuid.uuid4()),
                                    id_
                                    ))
        new_id = cursor.lastrowid
        cnx.commit()
        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_201
        resp.location = '/energystoragecontainers/' + str(id_) + '/hvacs/' + str(new_id)


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

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

    @staticmethod
    def on_get(req, resp, id_, hid):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not hid.isdigit() or int(hid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_HVAC_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        query = (" SELECT id, name, uuid "
                 " FROM tbl_energy_storage_containers ")
        cursor.execute(query)
        rows_energystoragecontainers = cursor.fetchall()

        energy_storage_container_dict = dict()
        if rows_energystoragecontainers is not None and len(rows_energystoragecontainers) > 0:
            for row in rows_energystoragecontainers:
                energy_storage_container_dict[row[0]] = {"id": row[0],
                                                         "name": row[1],
                                                         "uuid": row[2]}

        # query point dict
        query = (" SELECT id, name "
                 " FROM tbl_points ")
        cursor.execute(query)
        rows_points = cursor.fetchall()

        point_dict = dict()
        if rows_points is not None and len(rows_points) > 0:
            for row in rows_points:
                point_dict[row[0]] = {"id": row[0],
                                      "name": row[1]}

        query = (" SELECT id, name, uuid "
                 " FROM tbl_energy_storage_containers_hvacs "
                 " WHERE id = %s ")
        cursor.execute(query, (hid,))
        row = cursor.fetchone()
        cursor.close()
        cnx.close()

        if row is None:
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_HVAC_NOT_FOUND')
        else:
            meta_result = {"id": row[0],
                           "name": row[1],
                           "uuid": row[2]
                           }

        resp.text = json.dumps(meta_result)

    @staticmethod
    @user_logger
    def on_delete(req, resp, id_, hid):
        admin_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not hid.isdigit() or int(hid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_HVAC_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_hvacs "
                       " WHERE id = %s ", (hid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_HVAC_NOT_FOUND')

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_hvacs "
                       " WHERE id = %s ", (hid,))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_204

    @staticmethod
    @user_logger
    def on_put(req, resp, id_, hid):
        """Handles PUT requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        if not hid.isdigit() or int(hid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_HVAC_ID')

        new_values = json.loads(raw_json)

        if 'name' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['name'], str) or \
                len(str.strip(new_values['data']['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_HVAC_NAME')
        name = str.strip(new_values['data']['name'])
        working_status_point_id = None
        indoor_fan_status_point_id = None
        outdoor_fan_status_point_id = None
        emergency_fan_status_point_id = None
        compressor_status_point_id = None
        electric_heating_status_point_id = None
        coil_temperature_point_id = None
        temperature_outside_point_id = None
        temperature_inside_point_id = None
        humidity_inside_point_id = None
        condensation_temperature_point_id = None
        defrosting_temperature_point_id = None
        outlet_air_temperature_point_id = None
        return_air_temperature_point_id = None
        exhaust_temperature_point_id = None
        heating_on_temperature_point_id = None
        heating_off_temperature_point_id = None
        heating_control_hysteresis_point_id = None
        cooling_on_temperature_point_id = None
        cooling_off_temperature_point_id = None
        cooling_control_hysteresis_point_id = None
        high_temperature_alarm_set_point_id = None
        low_temperature_alarm_set_point_id = None
        high_humidity_alarm_set_point_id = None

        if 'working_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['working_status_point_id'], int) and \
                new_values['data']['working_status_point_id'] > 0:
            working_status_point_id = new_values['data']['working_status_point_id']
        if 'indoor_fan_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['indoor_fan_status_point_id'], int) and \
                new_values['data']['indoor_fan_status_point_id'] > 0:
            indoor_fan_status_point_id = new_values['data']['indoor_fan_status_point_id']
        if 'outdoor_fan_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['outdoor_fan_status_point_id'], int) and \
                new_values['data']['outdoor_fan_status_point_id'] > 0:
            outdoor_fan_status_point_id = new_values['data']['outdoor_fan_status_point_id']
        if 'emergency_fan_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['emergency_fan_status_point_id'], int) and \
                new_values['data']['emergency_fan_status_point_id'] > 0:
            emergency_fan_status_point_id = new_values['data']['emergency_fan_status_point_id']
        if 'compressor_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['compressor_status_point_id'], int) and \
                new_values['data']['compressor_status_point_id'] > 0:
            compressor_status_point_id = new_values['data']['compressor_status_point_id']
        if 'electric_heating_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['electric_heating_status_point_id'], int) and \
                new_values['data']['electric_heating_status_point_id'] > 0:
            electric_heating_status_point_id = new_values['data']['electric_heating_status_point_id']
        if 'coil_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['coil_temperature_point_id'], int) and \
                new_values['data']['coil_temperature_point_id'] > 0:
            coil_temperature_point_id = new_values['data']['coil_temperature_point_id']
        if 'temperature_outside_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['temperature_outside_point_id'], int) and \
                new_values['data']['temperature_outside_point_id'] > 0:
            temperature_outside_point_id = new_values['data']['temperature_outside_point_id']
        if 'temperature_inside_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['temperature_inside_point_id'], int) and \
                new_values['data']['temperature_inside_point_id'] > 0:
            temperature_inside_point_id = new_values['data']['temperature_inside_point_id']
        if 'humidity_inside_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['humidity_inside_point_id'], int) and \
                new_values['data']['humidity_inside_point_id'] > 0:
            humidity_inside_point_id = new_values['data']['humidity_inside_point_id']
        if 'condensation_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['condensation_temperature_point_id'], int) and \
                new_values['data']['condensation_temperature_point_id'] > 0:
            condensation_temperature_point_id = new_values['data']['condensation_temperature_point_id']
        if 'defrosting_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['defrosting_temperature_point_id'], int) and \
                new_values['data']['defrosting_temperature_point_id'] > 0:
            defrosting_temperature_point_id = new_values['data']['defrosting_temperature_point_id']
        if 'outlet_air_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['outlet_air_temperature_point_id'], int) and \
                new_values['data']['outlet_air_temperature_point_id'] > 0:
            outlet_air_temperature_point_id = new_values['data']['outlet_air_temperature_point_id']
        if 'return_air_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['return_air_temperature_point_id'], int) and \
                new_values['data']['return_air_temperature_point_id'] > 0:
            return_air_temperature_point_id = new_values['data']['return_air_temperature_point_id']
        if 'exhaust_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['exhaust_temperature_point_id'], int) and \
                new_values['data']['exhaust_temperature_point_id'] > 0:
            exhaust_temperature_point_id = new_values['data']['exhaust_temperature_point_id']
        if 'heating_on_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['heating_on_temperature_point_id'], int) and \
                new_values['data']['heating_on_temperature_point_id'] > 0:
            heating_on_temperature_point_id = new_values['data']['heating_on_temperature_point_id']
        if 'heating_off_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['heating_off_temperature_point_id'], int) and \
                new_values['data']['heating_off_temperature_point_id'] > 0:
            heating_off_temperature_point_id = new_values['data']['heating_off_temperature_point_id']
        if 'heating_control_hysteresis_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['heating_control_hysteresis_point_id'], int) and \
                new_values['data']['heating_control_hysteresis_point_id'] > 0:
            heating_control_hysteresis_point_id = new_values['data']['heating_control_hysteresis_point_id']
        if 'cooling_on_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['cooling_on_temperature_point_id'], int) and \
                new_values['data']['cooling_on_temperature_point_id'] > 0:
            cooling_on_temperature_point_id = new_values['data']['cooling_on_temperature_point_id']
        if 'cooling_off_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['cooling_off_temperature_point_id'], int) and \
                new_values['data']['cooling_off_temperature_point_id'] > 0:
            cooling_off_temperature_point_id = new_values['data']['cooling_off_temperature_point_id']
        if 'cooling_control_hysteresis_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['cooling_control_hysteresis_point_id'], int) and \
                new_values['data']['cooling_control_hysteresis_point_id'] > 0:
            cooling_control_hysteresis_point_id = new_values['data']['cooling_control_hysteresis_point_id']
        if 'high_temperature_alarm_set_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['high_temperature_alarm_set_point_id'], int) and \
                new_values['data']['high_temperature_alarm_set_point_id'] > 0:
            high_temperature_alarm_set_point_id = new_values['data']['high_temperature_alarm_set_point_id']
        if 'low_temperature_alarm_set_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['low_temperature_alarm_set_point_id'], int) and \
                new_values['data']['low_temperature_alarm_set_point_id'] > 0:
            low_temperature_alarm_set_point_id = new_values['data']['low_temperature_alarm_set_point_id']
        if 'high_humidity_alarm_set_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['high_humidity_alarm_set_point_id'], int) and \
                new_values['data']['high_humidity_alarm_set_point_id'] > 0:
            high_humidity_alarm_set_point_id = new_values['data']['high_humidity_alarm_set_point_id']

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_hvacs "
                       " WHERE id = %s ", (hid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_HVAC_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_hvacs "
                       " WHERE energy_storage_container_id = %s AND name = %s AND id != %s ",
                       (id_, name, hid))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_HVAC_NAME_IS_ALREADY_IN_USE')

        update_row = (" UPDATE tbl_energy_storage_containers_hvacs "
                      " SET name = %s "
                      "     WHERE id = %s ")
        cursor.execute(update_row, (name,
                                    hid))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_200


class EnergyStorageContainerLoadCollection:

This code seems to be duplicated in your project.

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

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

    @staticmethod
    def on_get(req, resp, id_):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        # query meter dict
        query = (" SELECT id, name, uuid "
                 " FROM tbl_meters ")
        cursor.execute(query)
        rows_meters = cursor.fetchall()

        meter_dict = dict()
        if rows_meters is not None and len(rows_meters) > 0:
            for row in rows_meters:
                meter_dict[row[0]] = {"id": row[0],
                                      "name": row[1],
                                      "uuid": row[2]}
        # query point dict
        query = (" SELECT id, name "
                 " FROM tbl_points ")
        cursor.execute(query)
        rows_points = cursor.fetchall()

        point_dict = dict()
        if rows_points is not None and len(rows_points) > 0:
            for row in rows_points:
                point_dict[row[0]] = {"id": row[0],
                                      "name": row[1]}

        query = (" SELECT id, name, uuid, "
                 "        power_point_id, meter_id, rated_input_power, "
                 "        total_active_power_point_id, "
                 "        active_power_a_point_id, "
                 "        active_power_b_point_id, "
                 "        active_power_c_point_id, "
                 "        total_reactive_power_point_id, "
                 "        reactive_power_a_point_id, "
                 "        reactive_power_b_point_id, "
                 "        reactive_power_c_point_id, "
                 "        total_apparent_power_point_id, "
                 "        apparent_power_a_point_id, "
                 "        apparent_power_b_point_id, "
                 "        apparent_power_c_point_id, "
                 "        total_power_factor_point_id, "
                 "        active_energy_import_point_id, "
                 "        active_energy_export_point_id, "
                 "        active_energy_net_point_id "
                 " FROM tbl_energy_storage_containers_loads "
                 " WHERE energy_storage_container_id = %s "
                 " ORDER BY name ")
        cursor.execute(query, (id_,))
        rows = cursor.fetchall()

        result = list()
        if rows is not None and len(rows) > 0:
            for row in rows:
                meta_result = {"id": row[0],
                               "name": row[1],
                               "uuid": row[2],
                               "power_point": point_dict.get(row[3]),
                               "meter": meter_dict.get(row[4]),
                               "rated_input_power": row[5],
                               "total_active_power_point": point_dict.get(row[6]),
                               "active_power_a_point": point_dict.get(row[7]),
                               "active_power_b_point": point_dict.get(row[8]),
                               "active_power_c_point": point_dict.get(row[9]),
                               "total_reactive_power_point": point_dict.get(row[10]),
                               "reactive_power_a_point": point_dict.get(row[11]),
                               "reactive_power_b_point": point_dict.get(row[12]),
                               "reactive_power_c_point": point_dict.get(row[13]),
                               "total_apparent_power_point": point_dict.get(row[14]),
                               "apparent_power_a_point": point_dict.get(row[15]),
                               "apparent_power_b_point": point_dict.get(row[16]),
                               "apparent_power_c_point": point_dict.get(row[17]),
                               "total_power_factor_point": point_dict.get(row[18]),
                               "active_energy_import_point": point_dict.get(row[19]),
                               "active_energy_export_point": point_dict.get(row[20]),
                               "active_energy_net_point": point_dict.get(row[21])}
                result.append(meta_result)

        resp.text = json.dumps(result)

    @staticmethod
    @user_logger
    def on_post(req, resp, id_):
        """Handles POST requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        new_values = json.loads(raw_json)

        if 'name' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['name'], str) or \
                len(str.strip(new_values['data']['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_LOAD_NAME')
        name = str.strip(new_values['data']['name'])

        if 'power_point_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['power_point_id'], int) or \
                new_values['data']['power_point_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_POWER_POINT_ID')
        power_point_id = new_values['data']['power_point_id']

        if 'meter_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['meter_id'], int) or \
                new_values['data']['meter_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_METER_ID')
        meter_id = new_values['data']['meter_id']

        if 'rated_input_power' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['rated_input_power'], float) or
                     isinstance(new_values['data']['rated_input_power'], int)):
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RATED_INPUT_POWER')
        rated_input_power = Decimal(new_values['data']['rated_input_power'])

        total_active_power_point_id = None
        active_power_a_point_id = None
        active_power_b_point_id = None
        active_power_c_point_id = None
        total_reactive_power_point_id = None
        reactive_power_a_point_id = None
        reactive_power_b_point_id = None
        reactive_power_c_point_id = None
        total_apparent_power_point_id = None
        apparent_power_a_point_id = None
        apparent_power_b_point_id = None
        apparent_power_c_point_id = None
        total_power_factor_point_id = None
        active_energy_import_point_id = None
        active_energy_export_point_id = None
        active_energy_net_point_id = None

        if 'total_active_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_active_power_point_id'], int) and \
                new_values['data']['total_active_power_point_id'] > 0:
            total_active_power_point_id = new_values['data']['total_active_power_point_id']

        if 'active_power_a_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_power_a_point_id'], int) and \
                new_values['data']['active_power_a_point_id'] > 0:
            active_power_a_point_id = new_values['data']['active_power_a_point_id']

        if 'active_power_b_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_power_b_point_id'], int) and \
                new_values['data']['active_power_b_point_id'] > 0:
            active_power_b_point_id = new_values['data']['active_power_b_point_id']

        if 'active_power_c_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_power_c_point_id'], int) and \
                new_values['data']['active_power_c_point_id'] > 0:
            active_power_c_point_id = new_values['data']['active_power_c_point_id']

        if 'total_reactive_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_reactive_power_point_id'], int) and \
                new_values['data']['total_reactive_power_point_id'] > 0:
            total_reactive_power_point_id = new_values['data']['total_reactive_power_point_id']

        if 'reactive_power_a_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['reactive_power_a_point_id'], int) and \
                new_values['data']['reactive_power_a_point_id'] > 0:
            reactive_power_a_point_id = new_values['data']['reactive_power_a_point_id']

        if 'reactive_power_b_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['reactive_power_b_point_id'], int) and \
                new_values['data']['reactive_power_b_point_id'] > 0:
            reactive_power_b_point_id = new_values['data']['reactive_power_b_point_id']

        if 'reactive_power_c_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['reactive_power_c_point_id'], int) and \
                new_values['data']['reactive_power_c_point_id'] > 0:
            reactive_power_c_point_id = new_values['data']['reactive_power_c_point_id']

        if 'total_apparent_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_apparent_power_point_id'], int) and \
                new_values['data']['total_apparent_power_point_id'] > 0:
            total_apparent_power_point_id = new_values['data']['total_apparent_power_point_id']

        if 'apparent_power_a_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['apparent_power_a_point_id'], int) and \
                new_values['data']['apparent_power_a_point_id'] > 0:
            apparent_power_a_point_id = new_values['data']['apparent_power_a_point_id']

        if 'apparent_power_b_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['apparent_power_b_point_id'], int) and \
                new_values['data']['apparent_power_b_point_id'] > 0:
            apparent_power_b_point_id = new_values['data']['apparent_power_b_point_id']

        if 'apparent_power_c_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['apparent_power_c_point_id'], int) and \
                new_values['data']['apparent_power_c_point_id'] > 0:
            apparent_power_c_point_id = new_values['data']['apparent_power_c_point_id']

        if 'total_power_factor_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_power_factor_point_id'], int) and \
                new_values['data']['total_power_factor_point_id'] > 0:
            total_power_factor_point_id = new_values['data']['total_power_factor_point_id']

        if 'active_energy_import_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_energy_import_point_id'], int) and \
                new_values['data']['active_energy_import_point_id'] > 0:
            active_energy_import_point_id = new_values['data']['active_energy_import_point_id']

        if 'active_energy_export_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_energy_export_point_id'], int) and \
                new_values['data']['active_energy_export_point_id'] > 0:
            active_energy_export_point_id = new_values['data']['active_energy_export_point_id']

        if 'active_energy_net_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_energy_net_point_id'], int) and \
                new_values['data']['active_energy_net_point_id'] > 0:
            active_energy_net_point_id = new_values['data']['active_energy_net_point_id']

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ",
                       (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_loads "
                       " WHERE energy_storage_container_id = %s AND name = %s ",
                       (id_, name,))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_LOAD_NAME_IS_ALREADY_IN_USE')

        cursor.execute(" SELECT name "
                       " FROM tbl_points "
                       " WHERE id = %s ",
                       (power_point_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.POWER_POINT_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_meters "
                       " WHERE id = %s ",
                       (meter_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.METER_NOT_FOUND')

        add_values = (" INSERT INTO tbl_energy_storage_containers_loads "
                      "    (name, uuid, energy_storage_container_id, power_point_id, meter_id, rated_input_power,"
                      "     total_active_power_point_id,"
                      "     active_power_a_point_id,"
                      "     active_power_b_point_id,"
                      "     active_power_c_point_id,"
                      "     total_reactive_power_point_id,"
                      "     reactive_power_a_point_id,"
                      "     reactive_power_b_point_id,"
                      "     reactive_power_c_point_id,"
                      "     total_apparent_power_point_id,"
                      "     apparent_power_a_point_id,"
                      "     apparent_power_b_point_id,"
                      "     apparent_power_c_point_id,"
                      "     total_power_factor_point_id,"
                      "     active_energy_import_point_id,"
                      "     active_energy_export_point_id,"
                      "     active_energy_net_point_id) "
                      " VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s,"
                      "         %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,"
                      "         %s, %s) ")
        cursor.execute(add_values, (name,
                                    str(uuid.uuid4()),
                                    id_,
                                    power_point_id,
                                    meter_id,
                                    rated_input_power,
                                    total_active_power_point_id,
                                    active_power_a_point_id,
                                    active_power_b_point_id,
                                    active_power_c_point_id,
                                    total_reactive_power_point_id,
                                    reactive_power_a_point_id,
                                    reactive_power_b_point_id,
                                    reactive_power_c_point_id,
                                    total_apparent_power_point_id,
                                    apparent_power_a_point_id,
                                    apparent_power_b_point_id,
                                    apparent_power_c_point_id,
                                    total_power_factor_point_id,
                                    active_energy_import_point_id,
                                    active_energy_export_point_id,
                                    active_energy_net_point_id
                                    ))
        new_id = cursor.lastrowid
        cnx.commit()
        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_201
        resp.location = '/energystoragecontainers/' + str(id_) + '/loads/' + str(new_id)


class EnergyStorageContainerLoadItem:

This code seems to be duplicated in your project.

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

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

    @staticmethod
    def on_get(req, resp, id_, lid):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not lid.isdigit() or int(lid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_LOAD_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        query = (" SELECT id, name, uuid "
                 " FROM tbl_energy_storage_containers ")
        cursor.execute(query)
        rows_energystoragecontainers = cursor.fetchall()

        energy_storage_container_dict = dict()
        if rows_energystoragecontainers is not None and len(rows_energystoragecontainers) > 0:
            for row in rows_energystoragecontainers:
                energy_storage_container_dict[row[0]] = {"id": row[0],
                                                         "name": row[1],
                                                         "uuid": row[2]}
        # query meter dict
        query = (" SELECT id, name, uuid "
                 " FROM tbl_meters ")
        cursor.execute(query)
        rows_meters = cursor.fetchall()

        meter_dict = dict()
        if rows_meters is not None and len(rows_meters) > 0:
            for row in rows_meters:
                meter_dict[row[0]] = {"id": row[0],
                                      "name": row[1],
                                      "uuid": row[2]}
        # query point dict
        query = (" SELECT id, name "
                 " FROM tbl_points ")
        cursor.execute(query)
        rows_points = cursor.fetchall()

        point_dict = dict()
        if rows_points is not None and len(rows_points) > 0:
            for row in rows_points:
                point_dict[row[0]] = {"id": row[0],
                                      "name": row[1]}

        query = (" SELECT id, name, uuid, "
                 "        energy_storage_container_id, power_point_id, meter_id, rated_input_power, "
                 "        total_active_power_point_id, "
                 "        active_power_a_point_id, "
                 "        active_power_b_point_id, "
                 "        active_power_c_point_id, "
                 "        total_reactive_power_point_id, "
                 "        reactive_power_a_point_id, "
                 "        reactive_power_b_point_id, "
                 "        reactive_power_c_point_id, "
                 "        total_apparent_power_point_id, "
                 "        apparent_power_a_point_id, "
                 "        apparent_power_b_point_id, "
                 "        apparent_power_c_point_id, "
                 "        total_power_factor_point_id, "
                 "        active_energy_import_point_id, "
                 "        active_energy_export_point_id, "
                 "        active_energy_net_point_id "
                 " FROM tbl_energy_storage_containers_loads "
                 " WHERE id = %s ")
        cursor.execute(query, (lid,))
        row = cursor.fetchone()
        cursor.close()
        cnx.close()

        if row is None:
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_LOAD_NOT_FOUND')
        else:
            meta_result = {"id": row[0],
                           "name": row[1],
                           "uuid": row[2],
                           "energy_storage_container": energy_storage_container_dict.get(row[3]),
                           "power_point": point_dict.get(row[4]),
                           "meter": meter_dict.get(row[5]),
                           "rated_input_power": row[6],
                           "total_active_power_point": point_dict.get(row[7]),
                           "active_power_a_point": point_dict.get(row[8]),
                           "active_power_b_point": point_dict.get(row[9]),
                           "active_power_c_point": point_dict.get(row[10]),
                           "total_reactive_power_point": point_dict.get(row[11]),
                           "reactive_power_a_point": point_dict.get(row[12]),
                           "reactive_power_b_point": point_dict.get(row[13]),
                           "reactive_power_c_point": point_dict.get(row[14]),
                           "total_apparent_power_point": point_dict.get(row[15]),
                           "apparent_power_a_point": point_dict.get(row[16]),
                           "apparent_power_b_point": point_dict.get(row[17]),
                           "apparent_power_c_point": point_dict.get(row[18]),
                           "total_power_factor_point": point_dict.get(row[19]),
                           "active_energy_import_point": point_dict.get(row[20]),
                           "active_energy_export_point": point_dict.get(row[21]),
                           "active_energy_net_point": point_dict.get(row[22])}

        resp.text = json.dumps(meta_result)

    @staticmethod
    @user_logger
    def on_delete(req, resp, id_, lid):
        admin_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not lid.isdigit() or int(lid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_LOAD_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_loads "
                       " WHERE id = %s ", (lid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_LOAD_NOT_FOUND')

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_loads "
                       " WHERE id = %s ", (lid,))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_204

    @staticmethod
    @user_logger
    def on_put(req, resp, id_, lid):
        """Handles PUT requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not lid.isdigit() or int(lid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_LOAD_ID')

        new_values = json.loads(raw_json)

        if 'name' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['name'], str) or \
                len(str.strip(new_values['data']['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_LOAD_NAME')
        name = str.strip(new_values['data']['name'])

        if 'power_point_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['power_point_id'], int) or \
                new_values['data']['power_point_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_POWER_POINT_ID')
        power_point_id = new_values['data']['power_point_id']

        if 'meter_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['meter_id'], int) or \
                new_values['data']['meter_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_METER_ID')
        meter_id = new_values['data']['meter_id']

        if 'rated_input_power' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['rated_input_power'], float) or
                     isinstance(new_values['data']['rated_input_power'], int)):
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RATED_INPUT_POWER')
        rated_input_power = Decimal(new_values['data']['rated_input_power'])

        total_active_power_point_id = None
        active_power_a_point_id = None
        active_power_b_point_id = None
        active_power_c_point_id = None
        total_reactive_power_point_id = None
        reactive_power_a_point_id = None
        reactive_power_b_point_id = None
        reactive_power_c_point_id = None
        total_apparent_power_point_id = None
        apparent_power_a_point_id = None
        apparent_power_b_point_id = None
        apparent_power_c_point_id = None
        total_power_factor_point_id = None
        active_energy_import_point_id = None
        active_energy_export_point_id = None
        active_energy_net_point_id = None

        if 'total_active_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_active_power_point_id'], int) and \
                new_values['data']['total_active_power_point_id'] > 0:
            total_active_power_point_id = new_values['data']['total_active_power_point_id']

        if 'active_power_a_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_power_a_point_id'], int) and \
                new_values['data']['active_power_a_point_id'] > 0:
            active_power_a_point_id = new_values['data']['active_power_a_point_id']

        if 'active_power_b_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_power_b_point_id'], int) and \
                new_values['data']['active_power_b_point_id'] > 0:
            active_power_b_point_id = new_values['data']['active_power_b_point_id']

        if 'active_power_c_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_power_c_point_id'], int) and \
                new_values['data']['active_power_c_point_id'] > 0:
            active_power_c_point_id = new_values['data']['active_power_c_point_id']

        if 'total_reactive_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_reactive_power_point_id'], int) and \
                new_values['data']['total_reactive_power_point_id'] > 0:
            total_reactive_power_point_id = new_values['data']['total_reactive_power_point_id']

        if 'reactive_power_a_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['reactive_power_a_point_id'], int) and \
                new_values['data']['reactive_power_a_point_id'] > 0:
            reactive_power_a_point_id = new_values['data']['reactive_power_a_point_id']

        if 'reactive_power_b_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['reactive_power_b_point_id'], int) and \
                new_values['data']['reactive_power_b_point_id'] > 0:
            reactive_power_b_point_id = new_values['data']['reactive_power_b_point_id']

        if 'reactive_power_c_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['reactive_power_c_point_id'], int) and \
                new_values['data']['reactive_power_c_point_id'] > 0:
            reactive_power_c_point_id = new_values['data']['reactive_power_c_point_id']

        if 'total_apparent_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_apparent_power_point_id'], int) and \
                new_values['data']['total_apparent_power_point_id'] > 0:
            total_apparent_power_point_id = new_values['data']['total_apparent_power_point_id']

        if 'apparent_power_a_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['apparent_power_a_point_id'], int) and \
                new_values['data']['apparent_power_a_point_id'] > 0:
            apparent_power_a_point_id = new_values['data']['apparent_power_a_point_id']

        if 'apparent_power_b_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['apparent_power_b_point_id'], int) and \
                new_values['data']['apparent_power_b_point_id'] > 0:
            apparent_power_b_point_id = new_values['data']['apparent_power_b_point_id']

        if 'apparent_power_c_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['apparent_power_c_point_id'], int) and \
                new_values['data']['apparent_power_c_point_id'] > 0:
            apparent_power_c_point_id = new_values['data']['apparent_power_c_point_id']

        if 'total_power_factor_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_power_factor_point_id'], int) and \
                new_values['data']['total_power_factor_point_id'] > 0:
            total_power_factor_point_id = new_values['data']['total_power_factor_point_id']

        if 'active_energy_import_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_energy_import_point_id'], int) and \
                new_values['data']['active_energy_import_point_id'] > 0:
            active_energy_import_point_id = new_values['data']['active_energy_import_point_id']

        if 'active_energy_export_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_energy_export_point_id'], int) and \
                new_values['data']['active_energy_export_point_id'] > 0:
            active_energy_export_point_id = new_values['data']['active_energy_export_point_id']

        if 'active_energy_net_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['active_energy_net_point_id'], int) and \
                new_values['data']['active_energy_net_point_id'] > 0:
            active_energy_net_point_id = new_values['data']['active_energy_net_point_id']

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_loads "
                       " WHERE id = %s ", (lid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_LOAD_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_loads "
                       " WHERE energy_storage_container_id = %s AND name = %s AND id != %s ",
                       (id_, name, lid))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_LOAD_NAME_IS_ALREADY_IN_USE')

        cursor.execute(" SELECT name "
                       " FROM tbl_points "
                       " WHERE id = %s ",
                       (power_point_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.POWER_POINT_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_meters "
                       " WHERE id = %s ",
                       (meter_id,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.METER_NOT_FOUND')

        update_row = (" UPDATE tbl_energy_storage_containers_loads "
                      " SET name = %s, energy_storage_container_id = %s, power_point_id = %s, "
                      "     meter_id = %s, rated_input_power = %s, "
                      "     total_active_power_point_id = %s, "
                      "     active_power_a_point_id = %s, "
                      "     active_power_b_point_id = %s, "
                      "     active_power_c_point_id = %s, "
                      "     total_reactive_power_point_id = %s, "
                      "     reactive_power_a_point_id = %s, "
                      "     reactive_power_b_point_id = %s, "
                      "     reactive_power_c_point_id = %s, "
                      "     total_apparent_power_point_id = %s, "
                      "     apparent_power_a_point_id = %s, "
                      "     apparent_power_b_point_id = %s, "
                      "     apparent_power_c_point_id = %s, "
                      "     total_power_factor_point_id = %s, "
                      "     active_energy_import_point_id = %s, "
                      "     active_energy_export_point_id = %s, "
                      "     active_energy_net_point_id = %s "
                      " WHERE id = %s ")
        cursor.execute(update_row, (name,
                                    id_,
                                    power_point_id,
                                    meter_id,
                                    rated_input_power,
                                    total_active_power_point_id,
                                    active_power_a_point_id,
                                    active_power_b_point_id,
                                    active_power_c_point_id,
                                    total_reactive_power_point_id,
                                    reactive_power_a_point_id,
                                    reactive_power_b_point_id,
                                    reactive_power_c_point_id,
                                    total_apparent_power_point_id,
                                    apparent_power_a_point_id,
                                    apparent_power_b_point_id,
                                    apparent_power_c_point_id,
                                    total_power_factor_point_id,
                                    active_energy_import_point_id,
                                    active_energy_export_point_id,
                                    active_energy_net_point_id,
                                    lid))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_200


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

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

    @staticmethod
    def on_get(req, resp, id_):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        # query point dict
        query = (" SELECT id, name "
                 " FROM tbl_points ")
        cursor.execute(query)
        rows_points = cursor.fetchall()

        point_dict = dict()
        if rows_points is not None and len(rows_points) > 0:
            for row in rows_points:
                point_dict[row[0]] = {"id": row[0],
                                      "name": row[1]}
        # query command dict
        query = (" SELECT id, name "
                 " FROM tbl_commands ")
        cursor.execute(query)
        rows_commands = cursor.fetchall()

        command_dict = dict()
        if rows_commands is not None and len(rows_commands) > 0:
            for row in rows_commands:
                command_dict[row[0]] = {"id": row[0],
                                        "name": row[1]}

        query = (" SELECT id, name, uuid, run_state_point_id, rated_output_power, "
                 "        today_charge_energy_point_id, "
                 "        today_discharge_energy_point_id, "
                 "        total_charge_energy_point_id, "
                 "        total_discharge_energy_point_id, "
                 "        grid_connection_status_point_id, "
                 "        device_status_point_id, "
                 "        control_mode_point_id, "
                 "        total_ac_active_power_point_id, "
                 "        total_ac_reactive_power_point_id, "
                 "        total_ac_apparent_power_point_id, "
                 "        total_ac_power_factor_point_id, "
                 "        ac_frequency_point_id, "
                 "        phase_a_active_power_point_id, "
                 "        phase_b_active_power_point_id, "
                 "        phase_c_active_power_point_id, "
                 "        phase_a_reactive_power_point_id, "
                 "        phase_b_reactive_power_point_id, "
                 "        phase_c_reactive_power_point_id, "
                 "        phase_a_apparent_power_point_id, "
                 "        phase_b_apparent_power_point_id, "
                 "        phase_c_apparent_power_point_id, "
                 "        ab_voltage_point_id, "
                 "        bc_voltage_point_id, "
                 "        ca_voltage_point_id, "
                 "        ab_current_point_id, "
                 "        bc_current_point_id, "
                 "        ca_current_point_id, "
                 "        phase_a_voltage_point_id, "
                 "        phase_b_voltage_point_id, "
                 "        phase_c_voltage_point_id, "
                 "        phase_a_current_point_id, "
                 "        phase_b_current_point_id, "
                 "        phase_c_current_point_id, "
                 "        pcs_module_temperature_point_id, "
                 "        pcs_ambient_temperature_point_id, "
                 "        a1_module_temperature_point_id, "
                 "        b1_module_temperature_point_id, "
                 "        c1_module_temperature_point_id, "
                 "        a2_module_temperature_point_id, "
                 "        b2_module_temperature_point_id, "
                 "        c2_module_temperature_point_id, "
                 "        air_inlet_temperature_point_id, "
                 "        air_outlet_temperature_point_id, "
                 "        dc_power_point_id, "
                 "        dc_voltage_point_id, "
                 "        dc_current_point_id  "
                 "        FROM tbl_energy_storage_containers_power_conversion_systems "
                 " WHERE energy_storage_container_id = %s "
                 " ORDER BY name ")
        cursor.execute(query, (id_,))
        rows = cursor.fetchall()

        result = list()
        if rows is not None and len(rows) > 0:
            for row in rows:
                meta_result = {"id": row[0],
                               "name": row[1],
                               "uuid": row[2],
                               "run_state_point": point_dict.get(row[3]),
                               "rated_output_power": row[4],
                               "today_charge_energy_point": point_dict.get(row[5]),
                               "today_discharge_energy_point": point_dict.get(row[6]),
                               "total_charge_energy_point": point_dict.get(row[7]),
                               "total_discharge_energy_point": point_dict.get(row[8]),
                               "grid_connection_status_point": point_dict.get(row[9]),
                               "device_status_point": point_dict.get(row[10]),
                               "control_mode_point": point_dict.get(row[11]),
                               "total_ac_active_power_point": point_dict.get(row[12]),
                               "total_ac_reactive_power_point": point_dict.get(row[13]),
                               "total_ac_apparent_power_point": point_dict.get(row[14]),
                               "total_ac_power_factor_point": point_dict.get(row[15]),
                               "ac_frequency_point": point_dict.get(row[16]),
                               "phase_a_active_power_point": point_dict.get(row[17]),
                               "phase_b_active_power_point": point_dict.get(row[18]),
                               "phase_c_active_power_point": point_dict.get(row[19]),
                               "phase_a_reactive_power_point": point_dict.get(row[20]),
                               "phase_b_reactive_power_point": point_dict.get(row[21]),
                               "phase_c_reactive_power_point": point_dict.get(row[22]),
                               "phase_a_apparent_power_point": point_dict.get(row[23]),
                               "phase_b_apparent_power_point": point_dict.get(row[24]),
                               "phase_c_apparent_power_point": point_dict.get(row[25]),
                               "ab_voltage_point": point_dict.get(row[26]),
                               "bc_voltage_point": point_dict.get(row[27]),
                               "ca_voltage_point": point_dict.get(row[28]),
                               "ab_current_point": point_dict.get(row[29]),
                               "bc_current_point": point_dict.get(row[30]),
                               "ca_current_point": point_dict.get(row[31]),
                               "phase_a_voltage_point": point_dict.get(row[32]),
                               "phase_b_voltage_point": point_dict.get(row[33]),
                               "phase_c_voltage_point": point_dict.get(row[34]),
                               "phase_a_current_point": point_dict.get(row[35]),
                               "phase_b_current_point": point_dict.get(row[36]),
                               "phase_c_current_point": point_dict.get(row[37]),
                               "pcs_module_temperature_point": point_dict.get(row[38]),
                               "pcs_ambient_temperature_point": point_dict.get(row[39]),
                               "a1_module_temperature_point": point_dict.get(row[40]),
                               "b1_module_temperature_point": point_dict.get(row[41]),
                               "c1_module_temperature_point": point_dict.get(row[42]),
                               "a2_module_temperature_point": point_dict.get(row[43]),
                               "b2_module_temperature_point": point_dict.get(row[44]),
                               "c2_module_temperature_point": point_dict.get(row[45]),
                               "air_inlet_temperature_point": point_dict.get(row[46]),
                               "air_outlet_temperature_point": point_dict.get(row[47]),
                               "dc_power_point": point_dict.get(row[48]),
                               "dc_voltage_point": point_dict.get(row[49]),
                               "dc_current_point": point_dict.get(row[50])
                               }
                result.append(meta_result)

        resp.text = json.dumps(result)

    @staticmethod
    @user_logger
    def on_post(req, resp, id_):
        """Handles POST requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        new_values = json.loads(raw_json)

        if 'name' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['name'], str) or \
                len(str.strip(new_values['data']['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_POWER_CONVERSION_SYSTEM_NAME')
        name = str.strip(new_values['data']['name'])

        if 'run_state_point_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['run_state_point_id'], int) or \
                new_values['data']['run_state_point_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RUN_STATE_POINT_ID')
        run_state_point_id = new_values['data']['run_state_point_id']

        if 'rated_output_power' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['rated_output_power'], float) or
                     isinstance(new_values['data']['rated_output_power'], int)):
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RATED_OUTPUT_POWER')
        rated_output_power = Decimal(new_values['data']['rated_output_power'])

        today_charge_energy_point_id = None
        today_discharge_energy_point_id = None
        total_charge_energy_point_id = None
        total_discharge_energy_point_id = None
        grid_connection_status_point_id = None
        device_status_point_id = None
        control_mode_point_id = None
        total_ac_active_power_point_id = None
        total_ac_reactive_power_point_id = None
        total_ac_apparent_power_point_id = None
        total_ac_power_factor_point_id = None
        ac_frequency_point_id = None
        phase_a_active_power_point_id = None
        phase_b_active_power_point_id = None
        phase_c_active_power_point_id = None
        phase_a_reactive_power_point_id = None
        phase_b_reactive_power_point_id = None
        phase_c_reactive_power_point_id = None
        phase_a_apparent_power_point_id = None
        phase_b_apparent_power_point_id = None
        phase_c_apparent_power_point_id = None
        ab_voltage_point_id = None
        bc_voltage_point_id = None
        ca_voltage_point_id = None
        ab_current_point_id = None
        bc_current_point_id = None
        ca_current_point_id = None
        phase_a_voltage_point_id = None
        phase_b_voltage_point_id = None
        phase_c_voltage_point_id = None
        phase_a_current_point_id = None
        phase_b_current_point_id = None
        phase_c_current_point_id = None
        pcs_module_temperature_point_id = None
        pcs_ambient_temperature_point_id = None
        a1_module_temperature_point_id = None
        b1_module_temperature_point_id = None
        c1_module_temperature_point_id = None
        a2_module_temperature_point_id = None
        b2_module_temperature_point_id = None
        c2_module_temperature_point_id = None
        air_inlet_temperature_point_id = None
        air_outlet_temperature_point_id = None
        dc_power_point_id = None
        dc_voltage_point_id = None
        dc_current_point_id = None

        if 'today_charge_energy_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['today_charge_energy_point_id'], int) and \
                new_values['data']['today_charge_energy_point_id'] > 0:
            today_charge_energy_point_id = new_values['data']['today_charge_energy_point_id']

        if 'today_discharge_energy_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['today_discharge_energy_point_id'], int) and \
                new_values['data']['today_discharge_energy_point_id'] > 0:
            today_discharge_energy_point_id = new_values['data']['today_discharge_energy_point_id']

        if 'total_charge_energy_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_charge_energy_point_id'], int) and \
                new_values['data']['total_charge_energy_point_id'] > 0:
            total_charge_energy_point_id = new_values['data']['total_charge_energy_point_id']

        if 'total_discharge_energy_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_discharge_energy_point_id'], int) and \
                new_values['data']['total_discharge_energy_point_id'] > 0:
            total_discharge_energy_point_id = new_values['data']['total_discharge_energy_point_id']

        if 'grid_connection_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['grid_connection_status_point_id'], int) and \
                new_values['data']['grid_connection_status_point_id'] > 0:
            grid_connection_status_point_id = new_values['data']['grid_connection_status_point_id']

        if 'device_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['device_status_point_id'], int) and \
                new_values['data']['device_status_point_id'] > 0:
            device_status_point_id = new_values['data']['device_status_point_id']

        if 'control_mode_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['control_mode_point_id'], int) and \
                new_values['data']['control_mode_point_id'] > 0:
            control_mode_point_id = new_values['data']['control_mode_point_id']

        if 'total_ac_active_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_ac_active_power_point_id'], int) and \
                new_values['data']['total_ac_active_power_point_id'] > 0:
            total_ac_active_power_point_id = new_values['data']['total_ac_active_power_point_id']

        if 'total_ac_reactive_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_ac_reactive_power_point_id'], int) and \
                new_values['data']['total_ac_reactive_power_point_id'] > 0:
            total_ac_reactive_power_point_id = new_values['data']['total_ac_reactive_power_point_id']

        if 'total_ac_apparent_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_ac_apparent_power_point_id'], int) and \
                new_values['data']['total_ac_apparent_power_point_id'] > 0:
            total_ac_apparent_power_point_id = new_values['data']['total_ac_apparent_power_point_id']

        if 'total_ac_power_factor_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_ac_power_factor_point_id'], int) and \
                new_values['data']['total_ac_power_factor_point_id'] > 0:
            total_ac_power_factor_point_id = new_values['data']['total_ac_power_factor_point_id']

        if 'ac_frequency_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['ac_frequency_point_id'], int) and \
                new_values['data']['ac_frequency_point_id'] > 0:
            ac_frequency_point_id = new_values['data']['ac_frequency_point_id']

        if 'phase_a_active_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_a_active_power_point_id'], int) and \
                new_values['data']['phase_a_active_power_point_id'] > 0:
            phase_a_active_power_point_id = new_values['data']['phase_a_active_power_point_id']

        if 'phase_b_active_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_b_active_power_point_id'], int) and \
                new_values['data']['phase_b_active_power_point_id'] > 0:
            phase_b_active_power_point_id = new_values['data']['phase_b_active_power_point_id']

        if 'phase_c_active_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_c_active_power_point_id'], int) and \
                new_values['data']['phase_c_active_power_point_id'] > 0:
            phase_c_active_power_point_id = new_values['data']['phase_c_active_power_point_id']

        if 'phase_a_reactive_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_a_reactive_power_point_id'], int) and \
                new_values['data']['phase_a_reactive_power_point_id'] > 0:
            phase_a_reactive_power_point_id = new_values['data']['phase_a_reactive_power_point_id']

        if 'phase_b_reactive_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_b_reactive_power_point_id'], int) and \
                new_values['data']['phase_b_reactive_power_point_id'] > 0:
            phase_b_reactive_power_point_id = new_values['data']['phase_b_reactive_power_point_id']

        if 'phase_c_reactive_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_c_reactive_power_point_id'], int) and \
                new_values['data']['phase_c_reactive_power_point_id'] > 0:
            phase_c_reactive_power_point_id = new_values['data']['phase_c_reactive_power_point_id']

        if 'phase_a_apparent_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_a_apparent_power_point_id'], int) and \
                new_values['data']['phase_a_apparent_power_point_id'] > 0:
            phase_a_apparent_power_point_id = new_values['data']['phase_a_apparent_power_point_id']

        if 'phase_b_apparent_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_b_apparent_power_point_id'], int) and \
                new_values['data']['phase_b_apparent_power_point_id'] > 0:
            phase_b_apparent_power_point_id = new_values['data']['phase_b_apparent_power_point_id']

        if 'phase_c_apparent_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_c_apparent_power_point_id'], int) and \
                new_values['data']['phase_c_apparent_power_point_id'] > 0:
            phase_c_apparent_power_point_id = new_values['data']['phase_c_apparent_power_point_id']

        if 'ab_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['ab_voltage_point_id'], int) and \
                new_values['data']['ab_voltage_point_id'] > 0:
            ab_voltage_point_id = new_values['data']['ab_voltage_point_id']

        if 'bc_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['bc_voltage_point_id'], int) and \
                new_values['data']['bc_voltage_point_id'] > 0:
            bc_voltage_point_id = new_values['data']['bc_voltage_point_id']

        if 'ca_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['ca_voltage_point_id'], int) and \
                new_values['data']['ca_voltage_point_id'] > 0:
            ca_voltage_point_id = new_values['data']['ca_voltage_point_id']

        if 'ab_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['ab_current_point_id'], int) and \
                new_values['data']['ab_current_point_id'] > 0:
            ab_current_point_id = new_values['data']['ab_current_point_id']

        if 'bc_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['bc_current_point_id'], int) and \
                new_values['data']['bc_current_point_id'] > 0:
            bc_current_point_id = new_values['data']['bc_current_point_id']

        if 'ca_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['ca_current_point_id'], int) and \
                new_values['data']['ca_current_point_id'] > 0:
            ca_current_point_id = new_values['data']['ca_current_point_id']

        if 'phase_a_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_a_voltage_point_id'], int) and \
                new_values['data']['phase_a_voltage_point_id'] > 0:
            phase_a_voltage_point_id = new_values['data']['phase_a_voltage_point_id']

        if 'phase_b_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_b_voltage_point_id'], int) and \
                new_values['data']['phase_b_voltage_point_id'] > 0:
            phase_b_voltage_point_id = new_values['data']['phase_b_voltage_point_id']

        if 'phase_c_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_c_voltage_point_id'], int) and \
                new_values['data']['phase_c_voltage_point_id'] > 0:
            phase_c_voltage_point_id = new_values['data']['phase_c_voltage_point_id']

        if 'phase_a_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_a_current_point_id'], int) and \
                new_values['data']['phase_a_current_point_id'] > 0:
            phase_a_current_point_id = new_values['data']['phase_a_current_point_id']

        if 'phase_b_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_b_current_point_id'], int) and \
                new_values['data']['phase_b_current_point_id'] > 0:
            phase_b_current_point_id = new_values['data']['phase_b_current_point_id']

        if 'phase_c_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_c_current_point_id'], int) and \
                new_values['data']['phase_c_current_point_id'] > 0:
            phase_c_current_point_id = new_values['data']['phase_c_current_point_id']

        if 'pcs_module_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['pcs_module_temperature_point_id'], int) and \
                new_values['data']['pcs_module_temperature_point_id'] > 0:
            pcs_module_temperature_point_id = new_values['data']['pcs_module_temperature_point_id']

        if 'pcs_ambient_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['pcs_ambient_temperature_point_id'], int) and \
                new_values['data']['pcs_ambient_temperature_point_id'] > 0:
            pcs_ambient_temperature_point_id = new_values['data']['pcs_ambient_temperature_point_id']

        if 'a1_module_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['a1_module_temperature_point_id'], int) and \
                new_values['data']['a1_module_temperature_point_id'] > 0:
            a1_module_temperature_point_id = new_values['data']['a1_module_temperature_point_id']

        if 'b1_module_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['b1_module_temperature_point_id'], int) and \
                new_values['data']['b1_module_temperature_point_id'] > 0:
            b1_module_temperature_point_id = new_values['data']['b1_module_temperature_point_id']

        if 'c1_module_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['c1_module_temperature_point_id'], int) and \
                new_values['data']['c1_module_temperature_point_id'] > 0:
            c1_module_temperature_point_id = new_values['data']['c1_module_temperature_point_id']

        if 'a2_module_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['a2_module_temperature_point_id'], int) and \
                new_values['data']['a2_module_temperature_point_id'] > 0:
            a2_module_temperature_point_id = new_values['data']['a2_module_temperature_point_id']

        if 'b2_module_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['b2_module_temperature_point_id'], int) and \
                new_values['data']['b2_module_temperature_point_id'] > 0:
            b2_module_temperature_point_id = new_values['data']['b2_module_temperature_point_id']

        if 'c2_module_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['c2_module_temperature_point_id'], int) and \
                new_values['data']['c2_module_temperature_point_id'] > 0:
            c2_module_temperature_point_id = new_values['data']['c2_module_temperature_point_id']

        if 'air_inlet_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['air_inlet_temperature_point_id'], int) and \
                new_values['data']['air_inlet_temperature_point_id'] > 0:
            air_inlet_temperature_point_id = new_values['data']['air_inlet_temperature_point_id']

        if 'air_outlet_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['air_outlet_temperature_point_id'], int) and \
                new_values['data']['air_outlet_temperature_point_id'] > 0:
            air_outlet_temperature_point_id = new_values['data']['air_outlet_temperature_point_id']

        if 'dc_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['dc_power_point_id'], int) and \
                new_values['data']['dc_power_point_id'] > 0:
            dc_power_point_id = new_values['data']['dc_power_point_id']

        if 'dc_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['dc_voltage_point_id'], int) and \
                new_values['data']['dc_voltage_point_id'] > 0:
            dc_voltage_point_id = new_values['data']['dc_voltage_point_id']

        if 'dc_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['dc_current_point_id'], int) and \
                new_values['data']['dc_current_point_id'] > 0:
            dc_current_point_id = new_values['data']['dc_current_point_id']

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ",
                       (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_power_conversion_systems "
                       " WHERE energy_storage_container_id = %s AND name = %s ",
                       (id_, name,))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_PCS_NAME_IS_ALREADY_IN_USE')

        add_values = (" INSERT INTO tbl_energy_storage_containers_power_conversion_systems "
                      "     (name, uuid, energy_storage_container_id, run_state_point_id, rated_output_power, "
                      "      today_charge_energy_point_id, "
                      "      today_discharge_energy_point_id,"
                      "      total_charge_energy_point_id, "
                      "      total_discharge_energy_point_id, "
                      "      grid_connection_status_point_id, "
                      "      device_status_point_id, "
                      "      control_mode_point_id, "
                      "      total_ac_active_power_point_id, "
                      "      total_ac_reactive_power_point_id, "
                      "      total_ac_apparent_power_point_id, "
                      "      total_ac_power_factor_point_id, "
                      "      ac_frequency_point_id, "
                      "      phase_a_active_power_point_id, "
                      "      phase_b_active_power_point_id, "
                      "      phase_c_active_power_point_id, "
                      "      phase_a_reactive_power_point_id, "
                      "      phase_b_reactive_power_point_id, "
                      "      phase_c_reactive_power_point_id, "
                      "      phase_a_apparent_power_point_id, "
                      "      phase_b_apparent_power_point_id, "
                      "      phase_c_apparent_power_point_id, "
                      "      ab_voltage_point_id, "
                      "      bc_voltage_point_id, "
                      "      ca_voltage_point_id, "
                      "      ab_current_point_id, "
                      "      bc_current_point_id, "
                      "      ca_current_point_id, "
                      "      phase_a_voltage_point_id, "
                      "      phase_b_voltage_point_id, "
                      "      phase_c_voltage_point_id, "
                      "      phase_a_current_point_id, "
                      "      phase_b_current_point_id, "
                      "      phase_c_current_point_id, "
                      "      pcs_module_temperature_point_id, "
                      "      pcs_ambient_temperature_point_id, "
                      "      a1_module_temperature_point_id, "
                      "      b1_module_temperature_point_id, "
                      "      c1_module_temperature_point_id, "
                      "      a2_module_temperature_point_id, "
                      "      b2_module_temperature_point_id, "
                      "      c2_module_temperature_point_id, "
                      "      air_inlet_temperature_point_id, "
                      "      air_outlet_temperature_point_id, "
                      "      dc_power_point_id, "
                      "      dc_voltage_point_id, "
                      "      dc_current_point_id) "
                      " VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, "
                      "         %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, "
                      "         %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, "
                      "         %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, "
                      "         %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, "
                      "         %s) ")
        cursor.execute(add_values, (name,
                                    str(uuid.uuid4()),
                                    id_,
                                    run_state_point_id,
                                    rated_output_power,
                                    today_charge_energy_point_id,
                                    today_discharge_energy_point_id,
                                    total_charge_energy_point_id,
                                    total_discharge_energy_point_id,
                                    grid_connection_status_point_id,
                                    device_status_point_id,
                                    control_mode_point_id,
                                    total_ac_active_power_point_id,
                                    total_ac_reactive_power_point_id,
                                    total_ac_apparent_power_point_id,
                                    total_ac_power_factor_point_id,
                                    ac_frequency_point_id,
                                    phase_a_active_power_point_id,
                                    phase_b_active_power_point_id,
                                    phase_c_active_power_point_id,
                                    phase_a_reactive_power_point_id,
                                    phase_b_reactive_power_point_id,
                                    phase_c_reactive_power_point_id,
                                    phase_a_apparent_power_point_id,
                                    phase_b_apparent_power_point_id,
                                    phase_c_apparent_power_point_id,
                                    ab_voltage_point_id,
                                    bc_voltage_point_id,
                                    ca_voltage_point_id,
                                    ab_current_point_id,
                                    bc_current_point_id,
                                    ca_current_point_id,
                                    phase_a_voltage_point_id,
                                    phase_b_voltage_point_id,
                                    phase_c_voltage_point_id,
                                    phase_a_current_point_id,
                                    phase_b_current_point_id,
                                    phase_c_current_point_id,
                                    pcs_module_temperature_point_id,
                                    pcs_ambient_temperature_point_id,
                                    a1_module_temperature_point_id,
                                    b1_module_temperature_point_id,
                                    c1_module_temperature_point_id,
                                    a2_module_temperature_point_id,
                                    b2_module_temperature_point_id,
                                    c2_module_temperature_point_id,
                                    air_inlet_temperature_point_id,
                                    air_outlet_temperature_point_id,
                                    dc_power_point_id,
                                    dc_voltage_point_id,
                                    dc_current_point_id
                                    ))
        new_id = cursor.lastrowid
        cnx.commit()
        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_201
        resp.location = '/energystoragecontainerpowerconversionsystems/' + str(new_id)


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

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

    @staticmethod
    def on_get(req, resp, id_, pid):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not pid.isdigit() or int(pid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_POWER_CONVERSION_SYSTEM_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        query = (" SELECT id, name, uuid "
                 " FROM tbl_energy_storage_containers ")
        cursor.execute(query)
        rows_energystoragecontainers = cursor.fetchall()

        energy_storage_container_dict = dict()
        if rows_energystoragecontainers is not None and len(rows_energystoragecontainers) > 0:
            for row in rows_energystoragecontainers:
                energy_storage_container_dict[row[0]] = {"id": row[0],
                                                         "name": row[1],
                                                         "uuid": row[2]}
        query = (" SELECT id, name, uuid "
                 " FROM tbl_meters ")
        cursor.execute(query)
        rows_meters = cursor.fetchall()

        meter_dict = dict()
        if rows_meters is not None and len(rows_meters) > 0:
            for row in rows_meters:
                meter_dict[row[0]] = {"id": row[0],
                                      "name": row[1],
                                      "uuid": row[2]}
        # query point dict
        query = (" SELECT id, name "
                 " FROM tbl_points ")
        cursor.execute(query)
        rows_points = cursor.fetchall()

        point_dict = dict()
        if rows_points is not None and len(rows_points) > 0:
            for row in rows_points:
                point_dict[row[0]] = {"id": row[0],
                                      "name": row[1]}

        # query command dict
        query = (" SELECT id, name "
                 " FROM tbl_commands ")
        cursor.execute(query)
        rows_commands = cursor.fetchall()

        command_dict = dict()
        if rows_commands is not None and len(rows_commands) > 0:
            for row in rows_commands:
                command_dict[row[0]] = {"id": row[0],
                                        "name": row[1]}

        query = (" SELECT id, name, uuid, energy_storage_container_id, run_state_point_id, rated_output_power, "
                 "        today_charge_energy_point_id, "
                 "        today_discharge_energy_point_id, "
                 "        total_charge_energy_point_id, "
                 "        total_discharge_energy_point_id, "
                 "        grid_connection_status_point_id, "
                 "        device_status_point_id, "
                 "        control_mode_point_id, "
                 "        total_ac_active_power_point_id, "
                 "        total_ac_reactive_power_point_id, "
                 "        total_ac_apparent_power_point_id, "
                 "        total_ac_power_factor_point_id, "
                 "        ac_frequency_point_id, "
                 "        phase_a_active_power_point_id, "
                 "        phase_b_active_power_point_id, "
                 "        phase_c_active_power_point_id, "
                 "        phase_a_reactive_power_point_id, "
                 "        phase_b_reactive_power_point_id, "
                 "        phase_c_reactive_power_point_id, "
                 "        phase_a_apparent_power_point_id, "
                 "        phase_b_apparent_power_point_id, "
                 "        phase_c_apparent_power_point_id, "
                 "        ab_voltage_point_id, "
                 "        bc_voltage_point_id, "
                 "        ca_voltage_point_id, "
                 "        ab_current_point_id, "
                 "        bc_current_point_id, "
                 "        ca_current_point_id, "
                 "        phase_a_voltage_point_id, "
                 "        phase_b_voltage_point_id, "
                 "        phase_c_voltage_point_id, "
                 "        phase_a_current_point_id, "
                 "        phase_b_current_point_id, "
                 "        phase_c_current_point_id, "
                 "        pcs_module_temperature_point_id, "
                 "        pcs_ambient_temperature_point_id, "
                 "        a1_module_temperature_point_id, "
                 "        b1_module_temperature_point_id, "
                 "        c1_module_temperature_point_id, "
                 "        a2_module_temperature_point_id, "
                 "        b2_module_temperature_point_id, "
                 "        c2_module_temperature_point_id, "
                 "        air_inlet_temperature_point_id, "
                 "        air_outlet_temperature_point_id, "
                 "        dc_power_point_id, "
                 "        dc_voltage_point_id, "
                 "        dc_current_point_id  "
                 " FROM tbl_energy_storage_containers_power_conversion_systems "
                 " WHERE id = %s ")
        cursor.execute(query, (pid,))
        row = cursor.fetchone()
        cursor.close()
        cnx.close()

        if row is None:
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_POWER_CONVERSION_SYSTEM_NOT_FOUND')
        else:
            meta_result = {"id": row[0],
                           "name": row[1],
                           "uuid": row[2],
                           "energy_storage_container": energy_storage_container_dict.get(row[3]),
                           "run_state_point": point_dict.get(row[4]),
                           "rated_output_power": row[5],
                           "today_charge_energy_point": point_dict.get(row[6]),
                           "today_discharge_energy_point": point_dict.get(row[7]),
                           "total_charge_energy_point": point_dict.get(row[8]),
                           "total_discharge_energy_point": point_dict.get(row[9]),
                           "grid_connection_status_point": point_dict.get(row[10]),
                           "device_status_point": point_dict.get(row[11]),
                           "control_mode_point": point_dict.get(row[12]),
                           "total_ac_active_power_point": point_dict.get(row[13]),
                           "total_ac_reactive_power_point": point_dict.get(row[14]),
                           "total_ac_apparent_power_point": point_dict.get(row[15]),
                           "total_ac_power_factor_point": point_dict.get(row[16]),
                           "ac_frequency_point": point_dict.get(row[17]),
                           "phase_a_active_power_point": point_dict.get(row[18]),
                           "phase_b_active_power_point": point_dict.get(row[19]),
                           "phase_c_active_power_point": point_dict.get(row[20]),
                           "phase_a_reactive_power_point": point_dict.get(row[21]),
                           "phase_b_reactive_power_point": point_dict.get(row[22]),
                           "phase_c_reactive_power_point": point_dict.get(row[23]),
                           "phase_a_apparent_power_point": point_dict.get(row[24]),
                           "phase_b_apparent_power_point": point_dict.get(row[25]),
                           "phase_c_apparent_power_point": point_dict.get(row[26]),
                           "ab_voltage_point": point_dict.get(row[27]),
                           "bc_voltage_point": point_dict.get(row[28]),
                           "ca_voltage_point": point_dict.get(row[29]),
                           "ab_current_point": point_dict.get(row[30]),
                           "bc_current_point": point_dict.get(row[31]),
                           "ca_current_point": point_dict.get(row[32]),
                           "phase_a_voltage_point": point_dict.get(row[33]),
                           "phase_b_voltage_point": point_dict.get(row[34]),
                           "phase_c_voltage_point": point_dict.get(row[35]),
                           "phase_a_current_point": point_dict.get(row[36]),
                           "phase_b_current_point": point_dict.get(row[37]),
                           "phase_c_current_point": point_dict.get(row[38]),
                           "pcs_module_temperature_point": point_dict.get(row[39]),
                           "pcs_ambient_temperature_point": point_dict.get(row[40]),
                           "a1_module_temperature_point": point_dict.get(row[41]),
                           "b1_module_temperature_point": point_dict.get(row[42]),
                           "c1_module_temperature_point": point_dict.get(row[43]),
                           "a2_module_temperature_point": point_dict.get(row[44]),
                           "b2_module_temperature_point": point_dict.get(row[45]),
                           "c2_module_temperature_point": point_dict.get(row[46]),
                           "air_inlet_temperature_point": point_dict.get(row[47]),
                           "air_outlet_temperature_point": point_dict.get(row[48]),
                           "dc_power_point": point_dict.get(row[49]),
                           "dc_voltage_point": point_dict.get(row[50]),
                           "dc_current_point": point_dict.get(row[51])
                           }

        resp.text = json.dumps(meta_result)

    @staticmethod
    @user_logger
    def on_delete(req, resp, id_, pid):
        admin_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not pid.isdigit() or int(pid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_POWER_CONVERSION_SYSTEM_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_power_conversion_systems "
                       " WHERE id = %s ", (pid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_POWER_CONVERSION_SYSTEM_NOT_FOUND')

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_power_conversion_systems "
                       " WHERE id = %s ", (pid,))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_204

    @staticmethod
    @user_logger
    def on_put(req, resp, id_, pid):
        """Handles PUT requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not pid.isdigit() or int(pid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_POWER_CONVERSION_SYSTEM_ID')

        new_values = json.loads(raw_json)

        if 'name' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['name'], str) or \
                len(str.strip(new_values['data']['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_POWER_CONVERSION_SYSTEM_NAME')
        name = str.strip(new_values['data']['name'])

        if 'run_state_point_id' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['run_state_point_id'], int) or \
                new_values['data']['run_state_point_id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RUN_STATE_POINT_ID')
        run_state_point_id = new_values['data']['run_state_point_id']

        if 'rated_output_power' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['rated_output_power'], float) or
                     isinstance(new_values['data']['rated_output_power'], int)):
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RATED_OUTPUT_POWER')
        rated_output_power = Decimal(new_values['data']['rated_output_power'])

        today_charge_energy_point_id = None
        today_discharge_energy_point_id = None
        total_charge_energy_point_id = None
        total_discharge_energy_point_id = None
        grid_connection_status_point_id = None
        device_status_point_id = None
        control_mode_point_id = None
        total_ac_active_power_point_id = None
        total_ac_reactive_power_point_id = None
        total_ac_apparent_power_point_id = None
        total_ac_power_factor_point_id = None
        ac_frequency_point_id = None
        phase_a_active_power_point_id = None
        phase_b_active_power_point_id = None
        phase_c_active_power_point_id = None
        phase_a_reactive_power_point_id = None
        phase_b_reactive_power_point_id = None
        phase_c_reactive_power_point_id = None
        phase_a_apparent_power_point_id = None
        phase_b_apparent_power_point_id = None
        phase_c_apparent_power_point_id = None
        ab_voltage_point_id = None
        bc_voltage_point_id = None
        ca_voltage_point_id = None
        ab_current_point_id = None
        bc_current_point_id = None
        ca_current_point_id = None
        phase_a_voltage_point_id = None
        phase_b_voltage_point_id = None
        phase_c_voltage_point_id = None
        phase_a_current_point_id = None
        phase_b_current_point_id = None
        phase_c_current_point_id = None
        pcs_module_temperature_point_id = None
        pcs_ambient_temperature_point_id = None
        a1_module_temperature_point_id = None
        b1_module_temperature_point_id = None
        c1_module_temperature_point_id = None
        a2_module_temperature_point_id = None
        b2_module_temperature_point_id = None
        c2_module_temperature_point_id = None
        air_inlet_temperature_point_id = None
        air_outlet_temperature_point_id = None
        dc_power_point_id = None
        dc_voltage_point_id = None
        dc_current_point_id = None

        if 'today_charge_energy_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['today_charge_energy_point_id'], int) and \
                new_values['data']['today_charge_energy_point_id'] > 0:
            today_charge_energy_point_id = new_values['data']['today_charge_energy_point_id']

        if 'today_discharge_energy_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['today_discharge_energy_point_id'], int) and \
                new_values['data']['today_discharge_energy_point_id'] > 0:
            today_discharge_energy_point_id = new_values['data']['today_discharge_energy_point_id']

        if 'total_charge_energy_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_charge_energy_point_id'], int) and \
                new_values['data']['total_charge_energy_point_id'] > 0:
            total_charge_energy_point_id = new_values['data']['total_charge_energy_point_id']

        if 'total_discharge_energy_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_discharge_energy_point_id'], int) and \
                new_values['data']['total_discharge_energy_point_id'] > 0:
            total_discharge_energy_point_id = new_values['data']['total_discharge_energy_point_id']

        if 'grid_connection_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['grid_connection_status_point_id'], int) and \
                new_values['data']['grid_connection_status_point_id'] > 0:
            grid_connection_status_point_id = new_values['data']['grid_connection_status_point_id']

        if 'device_status_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['device_status_point_id'], int) and \
                new_values['data']['device_status_point_id'] > 0:
            device_status_point_id = new_values['data']['device_status_point_id']

        if 'control_mode_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['control_mode_point_id'], int) and \
                new_values['data']['control_mode_point_id'] > 0:
            control_mode_point_id = new_values['data']['control_mode_point_id']

        if 'total_ac_active_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_ac_active_power_point_id'], int) and \
                new_values['data']['total_ac_active_power_point_id'] > 0:
            total_ac_active_power_point_id = new_values['data']['total_ac_active_power_point_id']

        if 'total_ac_reactive_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_ac_reactive_power_point_id'], int) and \
                new_values['data']['total_ac_reactive_power_point_id'] > 0:
            total_ac_reactive_power_point_id = new_values['data']['total_ac_reactive_power_point_id']

        if 'total_ac_apparent_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_ac_apparent_power_point_id'], int) and \
                new_values['data']['total_ac_apparent_power_point_id'] > 0:
            total_ac_apparent_power_point_id = new_values['data']['total_ac_apparent_power_point_id']

        if 'total_ac_power_factor_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['total_ac_power_factor_point_id'], int) and \
                new_values['data']['total_ac_power_factor_point_id'] > 0:
            total_ac_power_factor_point_id = new_values['data']['total_ac_power_factor_point_id']

        if 'ac_frequency_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['ac_frequency_point_id'], int) and \
                new_values['data']['ac_frequency_point_id'] > 0:
            ac_frequency_point_id = new_values['data']['ac_frequency_point_id']

        if 'phase_a_active_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_a_active_power_point_id'], int) and \
                new_values['data']['phase_a_active_power_point_id'] > 0:
            phase_a_active_power_point_id = new_values['data']['phase_a_active_power_point_id']

        if 'phase_b_active_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_b_active_power_point_id'], int) and \
                new_values['data']['phase_b_active_power_point_id'] > 0:
            phase_b_active_power_point_id = new_values['data']['phase_b_active_power_point_id']

        if 'phase_c_active_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_c_active_power_point_id'], int) and \
                new_values['data']['phase_c_active_power_point_id'] > 0:
            phase_c_active_power_point_id = new_values['data']['phase_c_active_power_point_id']

        if 'phase_a_reactive_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_a_reactive_power_point_id'], int) and \
                new_values['data']['phase_a_reactive_power_point_id'] > 0:
            phase_a_reactive_power_point_id = new_values['data']['phase_a_reactive_power_point_id']

        if 'phase_b_reactive_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_b_reactive_power_point_id'], int) and \
                new_values['data']['phase_b_reactive_power_point_id'] > 0:
            phase_b_reactive_power_point_id = new_values['data']['phase_b_reactive_power_point_id']

        if 'phase_c_reactive_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_c_reactive_power_point_id'], int) and \
                new_values['data']['phase_c_reactive_power_point_id'] > 0:
            phase_c_reactive_power_point_id = new_values['data']['phase_c_reactive_power_point_id']

        if 'phase_a_apparent_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_a_apparent_power_point_id'], int) and \
                new_values['data']['phase_a_apparent_power_point_id'] > 0:
            phase_a_apparent_power_point_id = new_values['data']['phase_a_apparent_power_point_id']

        if 'phase_b_apparent_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_b_apparent_power_point_id'], int) and \
                new_values['data']['phase_b_apparent_power_point_id'] > 0:
            phase_b_apparent_power_point_id = new_values['data']['phase_b_apparent_power_point_id']

        if 'phase_c_apparent_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_c_apparent_power_point_id'], int) and \
                new_values['data']['phase_c_apparent_power_point_id'] > 0:
            phase_c_apparent_power_point_id = new_values['data']['phase_c_apparent_power_point_id']

        if 'ab_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['ab_voltage_point_id'], int) and \
                new_values['data']['ab_voltage_point_id'] > 0:
            ab_voltage_point_id = new_values['data']['ab_voltage_point_id']

        if 'bc_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['bc_voltage_point_id'], int) and \
                new_values['data']['bc_voltage_point_id'] > 0:
            bc_voltage_point_id = new_values['data']['bc_voltage_point_id']

        if 'ca_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['ca_voltage_point_id'], int) and \
                new_values['data']['ca_voltage_point_id'] > 0:
            ca_voltage_point_id = new_values['data']['ca_voltage_point_id']

        if 'ab_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['ab_current_point_id'], int) and \
                new_values['data']['ab_current_point_id'] > 0:
            ab_current_point_id = new_values['data']['ab_current_point_id']

        if 'bc_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['bc_current_point_id'], int) and \
                new_values['data']['bc_current_point_id'] > 0:
            bc_current_point_id = new_values['data']['bc_current_point_id']

        if 'ca_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['ca_current_point_id'], int) and \
                new_values['data']['ca_current_point_id'] > 0:
            ca_current_point_id = new_values['data']['ca_current_point_id']

        if 'phase_a_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_a_voltage_point_id'], int) and \
                new_values['data']['phase_a_voltage_point_id'] > 0:
            phase_a_voltage_point_id = new_values['data']['phase_a_voltage_point_id']

        if 'phase_b_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_b_voltage_point_id'], int) and \
                new_values['data']['phase_b_voltage_point_id'] > 0:
            phase_b_voltage_point_id = new_values['data']['phase_b_voltage_point_id']

        if 'phase_c_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_c_voltage_point_id'], int) and \
                new_values['data']['phase_c_voltage_point_id'] > 0:
            phase_c_voltage_point_id = new_values['data']['phase_c_voltage_point_id']

        if 'phase_a_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_a_current_point_id'], int) and \
                new_values['data']['phase_a_current_point_id'] > 0:
            phase_a_current_point_id = new_values['data']['phase_a_current_point_id']

        if 'phase_b_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_b_current_point_id'], int) and \
                new_values['data']['phase_b_current_point_id'] > 0:
            phase_b_current_point_id = new_values['data']['phase_b_current_point_id']

        if 'phase_c_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['phase_c_current_point_id'], int) and \
                new_values['data']['phase_c_current_point_id'] > 0:
            phase_c_current_point_id = new_values['data']['phase_c_current_point_id']

        if 'pcs_module_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['pcs_module_temperature_point_id'], int) and \
                new_values['data']['pcs_module_temperature_point_id'] > 0:
            pcs_module_temperature_point_id = new_values['data']['pcs_module_temperature_point_id']

        if 'pcs_ambient_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['pcs_ambient_temperature_point_id'], int) and \
                new_values['data']['pcs_ambient_temperature_point_id'] > 0:
            pcs_ambient_temperature_point_id = new_values['data']['pcs_ambient_temperature_point_id']

        if 'a1_module_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['a1_module_temperature_point_id'], int) and \
                new_values['data']['a1_module_temperature_point_id'] > 0:
            a1_module_temperature_point_id = new_values['data']['a1_module_temperature_point_id']

        if 'b1_module_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['b1_module_temperature_point_id'], int) and \
                new_values['data']['b1_module_temperature_point_id'] > 0:
            b1_module_temperature_point_id = new_values['data']['b1_module_temperature_point_id']

        if 'c1_module_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['c1_module_temperature_point_id'], int) and \
                new_values['data']['c1_module_temperature_point_id'] > 0:
            c1_module_temperature_point_id = new_values['data']['c1_module_temperature_point_id']

        if 'a2_module_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['a2_module_temperature_point_id'], int) and \
                new_values['data']['a2_module_temperature_point_id'] > 0:
            a2_module_temperature_point_id = new_values['data']['a2_module_temperature_point_id']

        if 'b2_module_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['b2_module_temperature_point_id'], int) and \
                new_values['data']['b2_module_temperature_point_id'] > 0:
            b2_module_temperature_point_id = new_values['data']['b2_module_temperature_point_id']

        if 'c2_module_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['c2_module_temperature_point_id'], int) and \
                new_values['data']['c2_module_temperature_point_id'] > 0:
            c2_module_temperature_point_id = new_values['data']['c2_module_temperature_point_id']

        if 'air_inlet_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['air_inlet_temperature_point_id'], int) and \
                new_values['data']['air_inlet_temperature_point_id'] > 0:
            air_inlet_temperature_point_id = new_values['data']['air_inlet_temperature_point_id']

        if 'air_outlet_temperature_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['air_outlet_temperature_point_id'], int) and \
                new_values['data']['air_outlet_temperature_point_id'] > 0:
            air_outlet_temperature_point_id = new_values['data']['air_outlet_temperature_point_id']

        if 'dc_power_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['dc_power_point_id'], int) and \
                new_values['data']['dc_power_point_id'] > 0:
            dc_power_point_id = new_values['data']['dc_power_point_id']

        if 'dc_voltage_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['dc_voltage_point_id'], int) and \
                new_values['data']['dc_voltage_point_id'] > 0:
            dc_voltage_point_id = new_values['data']['dc_voltage_point_id']

        if 'dc_current_point_id' in new_values['data'].keys() and \
                isinstance(new_values['data']['dc_current_point_id'], int) and \
                new_values['data']['dc_current_point_id'] > 0:
            dc_current_point_id = new_values['data']['dc_current_point_id']

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_power_conversion_systems "
                       " WHERE id = %s ", (pid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_POWER_CONVERSION_SYSTEM_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers_power_conversion_systems "
                       " WHERE energy_storage_container_id = %s AND name = %s AND id != %s ",
                       (id_, name, pid))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_PCS_NAME_IS_ALREADY_IN_USE')

        update_row = (" UPDATE tbl_energy_storage_containers_power_conversion_systems "
                      " SET name = %s, energy_storage_container_id = %s, run_state_point_id = %s, "
                      "     rated_output_power = %s, "
                      "     today_charge_energy_point_id = %s, "
                      "     today_discharge_energy_point_id = %s, "
                      "     total_charge_energy_point_id = %s, "
                      "     total_discharge_energy_point_id = %s, "
                      "     grid_connection_status_point_id = %s, "
                      "     device_status_point_id = %s, "
                      "     control_mode_point_id = %s, "
                      "     total_ac_active_power_point_id = %s, "
                      "     total_ac_reactive_power_point_id = %s, "
                      "     total_ac_apparent_power_point_id = %s, "
                      "     total_ac_power_factor_point_id = %s, "
                      "     ac_frequency_point_id = %s, "
                      "     phase_a_active_power_point_id = %s, "
                      "     phase_b_active_power_point_id = %s, "
                      "     phase_c_active_power_point_id = %s, "
                      "     phase_a_reactive_power_point_id = %s, "
                      "     phase_b_reactive_power_point_id = %s, "
                      "     phase_c_reactive_power_point_id = %s, "
                      "     phase_a_apparent_power_point_id = %s, "
                      "     phase_b_apparent_power_point_id = %s, "
                      "     phase_c_apparent_power_point_id = %s, "
                      "     ab_voltage_point_id = %s, "
                      "     bc_voltage_point_id = %s, "
                      "     ca_voltage_point_id = %s, "
                      "     ab_current_point_id = %s, "
                      "     bc_current_point_id = %s, "
                      "     ca_current_point_id = %s, "
                      "     phase_a_voltage_point_id = %s, "
                      "     phase_b_voltage_point_id = %s, "
                      "     phase_c_voltage_point_id = %s, "
                      "     phase_a_current_point_id = %s, "
                      "     phase_b_current_point_id = %s, "
                      "     phase_c_current_point_id = %s, "
                      "     pcs_module_temperature_point_id = %s, "
                      "     pcs_ambient_temperature_point_id = %s, "
                      "     a1_module_temperature_point_id = %s, "
                      "     b1_module_temperature_point_id = %s, "
                      "     c1_module_temperature_point_id = %s, "
                      "     a2_module_temperature_point_id = %s, "
                      "     b2_module_temperature_point_id = %s, "
                      "     c2_module_temperature_point_id = %s, "
                      "     air_inlet_temperature_point_id = %s, "
                      "     air_outlet_temperature_point_id = %s, "
                      "     dc_power_point_id = %s, "
                      "     dc_voltage_point_id = %s, "
                      "     dc_current_point_id = %s "
                      "     WHERE id = %s ")
        cursor.execute(update_row, (name,
                                    id_,
                                    run_state_point_id,
                                    rated_output_power,
                                    today_charge_energy_point_id,
                                    today_discharge_energy_point_id,
                                    total_charge_energy_point_id,
                                    total_discharge_energy_point_id,
                                    grid_connection_status_point_id,
                                    device_status_point_id,
                                    control_mode_point_id,
                                    total_ac_active_power_point_id,
                                    total_ac_reactive_power_point_id,
                                    total_ac_apparent_power_point_id,
                                    total_ac_power_factor_point_id,
                                    ac_frequency_point_id,
                                    phase_a_active_power_point_id,
                                    phase_b_active_power_point_id,
                                    phase_c_active_power_point_id,
                                    phase_a_reactive_power_point_id,
                                    phase_b_reactive_power_point_id,
                                    phase_c_reactive_power_point_id,
                                    phase_a_apparent_power_point_id,
                                    phase_b_apparent_power_point_id,
                                    phase_c_apparent_power_point_id,
                                    ab_voltage_point_id,
                                    bc_voltage_point_id,
                                    ca_voltage_point_id,
                                    ab_current_point_id,
                                    bc_current_point_id,
                                    ca_current_point_id,
                                    phase_a_voltage_point_id,
                                    phase_b_voltage_point_id,
                                    phase_c_voltage_point_id,
                                    phase_a_current_point_id,
                                    phase_b_current_point_id,
                                    phase_c_current_point_id,
                                    pcs_module_temperature_point_id,
                                    pcs_ambient_temperature_point_id,
                                    a1_module_temperature_point_id,
                                    b1_module_temperature_point_id,
                                    c1_module_temperature_point_id,
                                    a2_module_temperature_point_id,
                                    b2_module_temperature_point_id,
                                    c2_module_temperature_point_id,
                                    air_inlet_temperature_point_id,
                                    air_outlet_temperature_point_id,
                                    dc_power_point_id,
                                    dc_voltage_point_id,
                                    dc_current_point_id,
                                    pid))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_200


class EnergyStorageContainerScheduleCollection:

This code seems to be duplicated in your project.

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

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

    @staticmethod
    def on_get(req, resp, id_):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        query = (" SELECT id, start_time_of_day, end_time_of_day, peak_type, power "
                 " FROM tbl_energy_storage_containers_schedules "
                 " WHERE energy_storage_container_id = %s "
                 " ORDER BY start_time_of_day ")
        cursor.execute(query, (id_,))
        rows = cursor.fetchall()

        result = list()
        if rows is not None and len(rows) > 0:
            for row in rows:
                meta_result = {"id": row[0],
                               "start_time_of_day": str(row[1]),
                               "end_time_of_day": str(row[2]),
                               "peak_type": row[3],
                               "power": row[4],
                               }
                result.append(meta_result)

        resp.text = json.dumps(result)

    @staticmethod
    @user_logger
    def on_post(req, resp, id_):
        """Handles POST requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        new_values = json.loads(raw_json)

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ",
                       (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        add_schedule = (" INSERT INTO tbl_energy_storage_containers_schedules "
                        "     (energy_storage_container_id, start_time_of_day, end_time_of_day, peak_type, power) "
                        " VALUES (%s, %s, %s, %s, %s) ")
        cursor.execute(add_schedule, (id_,
                                      new_values['data']['start_time_of_day'],
                                      new_values['data']['end_time_of_day'],
                                      new_values['data']['peak_type'],
                                      new_values['data']['power']))
        new_id = cursor.lastrowid
        cnx.commit()
        cursor.close()
        cnx.close()
        resp.status = falcon.HTTP_201
        resp.location = '/energystoragecontainerschedules/' + str(new_id)


class EnergyStorageContainerScheduleItem:

This code seems to be duplicated in your project.

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

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

    @staticmethod
    def on_get(req, resp, id_, sid):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not sid.isdigit() or int(sid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_SCHEDULE_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        query = (" SELECT id, name, uuid "
                 " FROM tbl_energy_storage_containers ")
        cursor.execute(query)
        rows_energystoragecontainers = cursor.fetchall()

        energy_storage_container_dict = dict()
        if rows_energystoragecontainers is not None and len(rows_energystoragecontainers) > 0:
            for row in rows_energystoragecontainers:
                energy_storage_container_dict[row[0]] = {"id": row[0],
                                                         "name": row[1],
                                                         "uuid": row[2]}

        query = (" SELECT id, start_time_of_day, end_time_of_day, peak_type, power "
                 " FROM tbl_energy_storage_containers_schedules "
                 " WHERE id = %s ")
        cursor.execute(query, (sid,))
        row = cursor.fetchone()
        cursor.close()
        cnx.close()

        if row is None:
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_SCHEDULE_NOT_FOUND')
        else:
            meta_result = {"id": row[0],
                           "start_time_of_day": str(row[1]),
                           "end_time_of_day": str(row[2]),
                           "peak_type": row[3],
                           "power": row[4]}

        resp.text = json.dumps(meta_result)

    @staticmethod
    @user_logger
    def on_delete(req, resp, id_, sid):
        admin_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not sid.isdigit() or int(sid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_SCHEDULE_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT id "
                       " FROM tbl_energy_storage_containers_schedules "
                       " WHERE id = %s ", (sid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_SCHEDULE_NOT_FOUND')

        cursor.execute(" DELETE FROM tbl_energy_storage_containers_schedules "
                       " WHERE id = %s ", (sid,))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_204

    @staticmethod
    @user_logger
    def on_put(req, resp, id_, sid):
        """Handles PUT requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')
        if not sid.isdigit() or int(sid) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_SCHEDULE_ID')

        new_values = json.loads(raw_json)

        if 'start_time_of_day' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['start_time_of_day'], str) or \
                len(str.strip(new_values['data']['start_time_of_day'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_START_TIME_OF_DAY')
        start_time_of_day = str.strip(new_values['data']['start_time_of_day'])

        if 'end_time_of_day' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['end_time_of_day'], str) or \
                len(str.strip(new_values['data']['end_time_of_day'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_END_TIME_OF_DAY')
        end_time_of_day = str.strip(new_values['data']['end_time_of_day'])

        if 'peak_type' not in new_values['data'].keys() or \
                not isinstance(new_values['data']['peak_type'], str) or \
                len(str.strip(new_values['data']['peak_type'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_PEAK_TYPE')
        peak_type = str.strip(new_values['data']['peak_type'])

        if 'power' not in new_values['data'].keys() or \
                not (isinstance(new_values['data']['power'], float) or
                     isinstance(new_values['data']['power'], int)):
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_POWER')
        power = Decimal(new_values['data']['power'])

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE id = %s ", (id_,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')

        cursor.execute(" SELECT id "
                       " FROM tbl_energy_storage_containers_schedules "
                       " WHERE id = %s ", (sid,))
        if cursor.fetchone() is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_SCHEDULE_NOT_FOUND')

        update_row = (" UPDATE tbl_energy_storage_containers_schedules "
                      " SET start_time_of_day = %s, end_time_of_day = %s, peak_type = %s, power = %s "
                      " WHERE id = %s ")
        cursor.execute(update_row, (start_time_of_day,
                                    end_time_of_day,
                                    peak_type,
                                    power,
                                    sid))
        cnx.commit()

        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_200


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

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

    @staticmethod
    @user_logger
    def on_post(req, resp, id_):
        """Handles POST requests"""
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        query = (" SELECT id, name, uuid, "
                 "        rated_capacity, rated_power, contact_id, cost_center_id, description "
                 " FROM tbl_energy_storage_containers "
                 " WHERE id = %s ")
        cursor.execute(query, (id_,))
        row = cursor.fetchone()

        if row is None:
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')
        else:
            meta_result = {"id": row[0],
                           "name": row[1],
                           "uuid": row[2],
                           "rated_capacity": row[3],
                           "rated_power": row[4],
                           "contact_id": row[5],
                           "cost_center_id": row[6],
                           "description": row[7]}
            timezone_offset = int(config.utc_offset[1:3]) * 60 + int(config.utc_offset[4:6])
            if config.utc_offset[0] == '-':
                timezone_offset = -timezone_offset
            new_name = str.strip(meta_result['name']) + \
                (datetime.utcnow() + timedelta(minutes=timezone_offset)).isoformat(sep='-', timespec='seconds')
            add_values = (" INSERT INTO tbl_energy_storage_containers "
                          "    (name, uuid, rated_capacity, rated_power, contact_id, "
                          "     cost_center_id, description) "
                          " VALUES (%s, %s, %s, %s, %s, %s, %s) ")
            cursor.execute(add_values, (new_name,
                                        str(uuid.uuid4()),
                                        meta_result['rated_capacity'],
                                        meta_result['rated_power'],
                                        meta_result['contact_id'],
                                        meta_result['cost_center_id'],
                                        meta_result['description']))
            new_id = cursor.lastrowid
            cnx.commit()
            cursor.close()
            cnx.close()

            resp.status = falcon.HTTP_201
            resp.location = '/energystoragecontainers/' + str(new_id)


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

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

    @staticmethod

This code seems to be duplicated in your project.

    def on_get(req, resp, id_):
        access_control(req)
        if not id_.isdigit() or int(id_) <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_ID')

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        query = (" SELECT id, name, uuid "
                 " FROM tbl_contacts ")
        cursor.execute(query)
        rows_contacts = cursor.fetchall()

        contact_dict = dict()
        if rows_contacts is not None and len(rows_contacts) > 0:
            for row in rows_contacts:
                contact_dict[row[0]] = {"id": row[0],
                                        "name": row[1],
                                        "uuid": row[2]}

        query = (" SELECT id, name, uuid "
                 " FROM tbl_cost_centers ")
        cursor.execute(query)
        rows_cost_centers = cursor.fetchall()

        cost_center_dict = dict()
        if rows_cost_centers is not None and len(rows_cost_centers) > 0:
            for row in rows_cost_centers:
                cost_center_dict[row[0]] = {"id": row[0],
                                            "name": row[1],
                                            "uuid": row[2]}

        query = (" SELECT id, name, uuid, "
                 "        rated_capacity, rated_power, contact_id, cost_center_id, description "
                 " FROM tbl_energy_storage_containers "
                 " WHERE id = %s ")
        cursor.execute(query, (id_,))
        row = cursor.fetchone()
        cursor.close()
        cnx.close()

        if row is None:
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.ENERGY_STORAGE_CONTAINER_NOT_FOUND')
        else:
            meta_result = {"id": row[0],
                           "name": row[1],
                           "uuid": row[2],
                           "rated_capacity": row[3],
                           "rated_power": row[4],
                           "contact": contact_dict.get(row[5], None),
                           "cost_center": cost_center_dict.get(row[6], None),
                           "description": row[7]}

        resp.text = json.dumps(meta_result)


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

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

    @staticmethod
    @user_logger
    def on_post(req, resp):
        """Handles POST requests"""
        admin_control(req)
        try:
            raw_json = req.stream.read().decode('utf-8')
        except Exception as ex:
            raise falcon.HTTPError(status=falcon.HTTP_400,
                                   title='API.BAD_REQUEST',
                                   description='API.FAILED_TO_READ_REQUEST_STREAM')

        new_values = json.loads(raw_json)

        if 'name' not in new_values.keys() or \
                not isinstance(new_values['name'], str) or \
                len(str.strip(new_values['name'])) == 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_ENERGY_STORAGE_CONTAINER_NAME')
        timezone_offset = int(config.utc_offset[1:3]) * 60 + int(config.utc_offset[4:6])
        if config.utc_offset[0] == '-':
            timezone_offset = -timezone_offset
        name = str.strip(new_values['name']) + \
            (datetime.utcnow() + timedelta(minutes=timezone_offset)).isoformat(sep='-', timespec='seconds')

        if 'rated_capacity' not in new_values.keys() or \
                not (isinstance(new_values['rated_capacity'], float) or
                     isinstance(new_values['rated_capacity'], int)) or \
                new_values['rated_capacity'] < 0.0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RATED_CAPACITY')
        rated_capacity = new_values['rated_capacity']

        if 'rated_power' not in new_values.keys() or \
                not (isinstance(new_values['rated_power'], float) or
                     isinstance(new_values['rated_power'], int)) or \
                new_values['rated_power'] < 0.0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_RATED_POWER')
        rated_power = new_values['rated_power']

        if 'contact' not in new_values.keys() or \
                'id' not in new_values['contact'].keys() or \
                not isinstance(new_values['contact']['id'], int) or \
                new_values['contact']['id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_CONTACT_ID')
        contact_id = new_values['contact']['id']

        if 'cost_center' not in new_values.keys() or \
                'id' not in new_values['cost_center'].keys() or \
                not isinstance(new_values['cost_center']['id'], int) or \
                new_values['cost_center']['id'] <= 0:
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.INVALID_COST_CENTER_ID')
        cost_center_id = new_values['cost_center']['id']

        if 'description' in new_values.keys() and \
                new_values['description'] is not None and \
                len(str(new_values['description'])) > 0:
            description = str.strip(new_values['description'])
        else:
            description = None

        cnx = mysql.connector.connect(**config.myems_system_db)
        cursor = cnx.cursor()

        cursor.execute(" SELECT name "
                       " FROM tbl_energy_storage_containers "
                       " WHERE name = %s ", (name,))
        if cursor.fetchone() is not None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_400, title='API.BAD_REQUEST',
                                   description='API.ENERGY_STORAGE_CONTAINER_NAME_IS_ALREADY_IN_USE')

        cursor.execute(" SELECT name "
                       " FROM tbl_contacts "
                       " WHERE id = %s ",
                       (new_values['contact']['id'],))
        row = cursor.fetchone()
        if row is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.CONTACT_NOT_FOUND')

        cursor.execute(" SELECT name "
                       " FROM tbl_cost_centers "
                       " WHERE id = %s ",
                       (new_values['cost_center']['id'],))
        row = cursor.fetchone()
        if row is None:
            cursor.close()
            cnx.close()
            raise falcon.HTTPError(status=falcon.HTTP_404, title='API.NOT_FOUND',
                                   description='API.COST_CENTER_NOT_FOUND')

        add_values = (" INSERT INTO tbl_energy_storage_containers "
                      "    (name, uuid, rated_capacity, rated_power, contact_id, cost_center_id, description) "
                      " VALUES (%s, %s, %s, %s, %s, %s, %s) ")
        cursor.execute(add_values, (name,
                                    str(uuid.uuid4()),
                                    rated_capacity,
                                    rated_power,
                                    contact_id,
                                    cost_center_id,
                                    description))
        new_id = cursor.lastrowid
        cnx.commit()
        cursor.close()
        cnx.close()

        resp.status = falcon.HTTP_201
        resp.location = '/energystoragecontainers/' + str(new_id)