myems / myems-api

        resp.status = falcon.HTTP_200

class DataSourcePointCollection:

    @staticmethod

    def __init__():

        pass

    @staticmethod

    def on_options(req, resp):

        resp.status = falcon.HTTP_200

    @staticmethod

    def on_get(req, resp, id_):

        if not id_.isdigit() or int(id_) <= 0:

            raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST',

                                   description='API.INVALID_DATA_SOURCE_ID')

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

        cursor = cnx.cursor()

        cursor.execute(" SELECT name "

                       " FROM tbl_data_sources "

                       " WHERE id = %s ", (id_,))

        if cursor.fetchone() is None:

            cursor.close()

            cnx.disconnect()

            raise falcon.HTTPError(falcon.HTTP_404, title='API.NOT_FOUND',

                                   description='API.DATA_SOURCE_NOT_FOUND')

        result = list()

        # Get points of the data source

        # NOTE: there is no uuid in tbl_points

        query_point = (" SELECT id, name, object_type, "

                       "        units, high_limit, low_limit, ratio, is_trend, address, description "

                       " FROM tbl_points "

                       " WHERE data_source_id = %s "

                       " ORDER BY name ")

        cursor.execute(query_point, (id_,))

        rows_point = cursor.fetchall()

        if rows_point is not None and len(rows_point) > 0:

            for row in rows_point:

                meta_result = {"id": row[0],

                               "name": row[1],

                               "object_type": row[2],

                               "units": row[3],

                               "high_limit": row[4],

                               "low_limit": row[5],

                               "ratio": float(row[6]),

                               "is_trend": True if row[7] else False,

                               "address": row[8],

                               "description": row[9]}

                result.append(meta_result)

        cursor.close()

        cnx.disconnect()

        resp.body = json.dumps(result)

        resp.status = falcon.HTTP_200

class DistributionSystemDistributionCircuitCollection:

    @staticmethod

    def __init__():

        pass

    @staticmethod

    def on_options(req, resp, id_):

        resp.status = falcon.HTTP_200

    @staticmethod

    def on_get(req, resp, id_):

        if not id_.isdigit() or int(id_) <= 0:

            raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST',

                                   description='API.INVALID_DISTRIBUTION_SYSTEM_ID')

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

        cursor = cnx.cursor(dictionary=True)

        cursor.execute(" SELECT name "

                       " FROM tbl_distribution_systems "

                       " WHERE id = %s ", (id_,))

        if cursor.fetchone() is None:

            cursor.close()

            cnx.disconnect()

            raise falcon.HTTPError(falcon.HTTP_404, title='API.NOT_FOUND',

                                   description='API.DISTRIBUTION_SYSTEM_NOT_FOUND')

        query = (" SELECT id, name, uuid, "

                 "        distribution_room, switchgear, peak_load, peak_current, customers, meters "

                 " FROM tbl_distribution_circuits "

                 " WHERE distribution_system_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['id'], "name": row['name'], "uuid": row['uuid'],

                               "distribution_room": row['distribution_room'], "switchgear": row['switchgear'],

                               "peak_load": row['peak_load'], "peak_current": row['peak_current'],

                               "customers": row['customers'], "meters": row['meters']}

                result.append(meta_result)

        resp.body = json.dumps(result)