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

add the svg aapi

pull/142/head
hyh123a 2022-04-21 15:01:56 +08:00
parent 6c70ad48a1
commit 946c386ff2
3 changed files with 165 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
myems-api/app.py
View File

@ -5,7 +5,7 @@ from core import energyflowdiagram, privilege, textmessage, distributioncircuit,
costcenter, point, knowledgefile, meter, tariff, user, storetype, timezone, \
costfile, offlinemeterfile, version, contact, emailserver, combinedequipment, datasource, equipment, tenant, \
shopfloor, webmessage, distributionsystem, store, emailmessage, tenanttype, wechatmessage, space, gateway, \
offlinemeter, rule, energycategory, sensor, energyitem, notification, menu
offlinemeter, rule, energycategory, sensor, energyitem, notification, menu, svg
from reports import advancedreport
from reports import distributionsystem as distributionsystemreport
from reports import energyflowdiagram as energyflowdiagramreport
@ -414,6 +414,11 @@ api.add_route('/tariffs',
api.add_route('/tariffs/{id_}',
tariff.TariffItem())
api.add_route('/svgs',
svg.Collection())
api.add_route('/svgs/{id_}',
svg.Item())
api.add_route('/tenants',
tenant.TenantCollection())
api.add_route('/tenants/{id_}',

20
myems-api/config.py
View File

@ -6,7 +6,7 @@ myems_system_db = {
'port': config('MYEMS_SYSTEM_DB_PORT', default=3306, cast=int),
'database': config('MYEMS_SYSTEM_DB_DATABASE', default='myems_system_db'),
'user': config('MYEMS_SYSTEM_DB_USER', default='root'),
'password': config('MYEMS_SYSTEM_DB_PASSWORD', default='!MyEMS1'),
'password': config('MYEMS_SYSTEM_DB_PASSWORD', default=''),
}
myems_energy_db = {
@ -14,7 +14,7 @@ myems_energy_db = {
'port': config('MYEMS_ENERGY_DB_PORT', default=3306, cast=int),
'database': config('MYEMS_ENERGY_DB_DATABASE', default='myems_energy_db'),
'user': config('MYEMS_ENERGY_DB_USER', default='root'),
'password': config('MYEMS_ENERGY_DB_PASSWORD', default='!MyEMS1'),
'password': config('MYEMS_ENERGY_DB_PASSWORD', default=''),
}
myems_energy_baseline_db = {
@ -22,7 +22,7 @@ myems_energy_baseline_db = {
'port': config('MYEMS_ENERGY_BASELINE_DB_PORT', default=3306, cast=int),
'database': config('MYEMS_ENERGY_BASELINE_DB_DATABASE', default='myems_energy_baseline_db'),
'user': config('MYEMS_ENERGY_BASELINE_DB_USER', default='root'),
'password': config('MYEMS_ENERGY_BASELINE_DB_PASSWORD', default='!MyEMS1'),
'password': config('MYEMS_ENERGY_BASELINE_DB_PASSWORD', default=''),
}
myems_billing_db = {
@ -30,7 +30,7 @@ myems_billing_db = {
'port': config('MYEMS_BILLING_DB_PORT', default=3306, cast=int),
'database': config('MYEMS_BILLING_DB_DATABASE', default='myems_billing_db'),
'user': config('MYEMS_BILLING_DB_USER', default='root'),
'password': config('MYEMS_BILLING_DB_PASSWORD', default='!MyEMS1'),
'password': config('MYEMS_BILLING_DB_PASSWORD', default=''),
}
myems_billing_baseline_db = {
@ -38,7 +38,7 @@ myems_billing_baseline_db = {
'port': config('MYEMS_BILLING_BASELINE_DB_PORT', default=3306, cast=int),
'database': config('MYEMS_BILLING_BASELINE_DB_DATABASE', default='myems_billing_baseline_db'),
'user': config('MYEMS_BILLING_BASELINE_DB_USER', default='root'),
'password': config('MYEMS_BILLING_BASELINE_DB_PASSWORD', default='!MyEMS1'),
'password': config('MYEMS_BILLING_BASELINE_DB_PASSWORD', default=''),
}
myems_historical_db = {
@ -46,7 +46,7 @@ myems_historical_db = {
'port': config('MYEMS_HISTORICAL_DB_PORT', default=3306, cast=int),
'database': config('MYEMS_HISTORICAL_DB_DATABASE', default='myems_historical_db'),
'user': config('MYEMS_HISTORICAL_DB_USER', default='root'),
'password': config('MYEMS_HISTORICAL_DB_PASSWORD', default='!MyEMS1'),
'password': config('MYEMS_HISTORICAL_DB_PASSWORD', default=''),
}
myems_user_db = {
@ -54,7 +54,7 @@ myems_user_db = {
'port': config('MYEMS_USER_DB_PORT', default=3306, cast=int),
'database': config('MYEMS_USER_DB_DATABASE', default='myems_user_db'),
'user': config('MYEMS_USER_DB_USER', default='root'),
'password': config('MYEMS_USER_DB_PASSWORD', default='!MyEMS1'),
'password': config('MYEMS_USER_DB_PASSWORD', default=''),
}
myems_fdd_db = {
@ -62,7 +62,7 @@ myems_fdd_db = {
'port': config('MYEMS_FDD_DB_PORT', default=3306, cast=int),
'database': config('MYEMS_FDD_DB_DATABASE', default='myems_fdd_db'),
'user': config('MYEMS_FDD_DB_USER', default='root'),
'password': config('MYEMS_FDD_DB_PASSWORD', default='!MyEMS1'),
'password': config('MYEMS_FDD_DB_PASSWORD', default=''),
}
myems_reporting_db = {
@ -70,7 +70,7 @@ myems_reporting_db = {
'port': config('MYEMS_REPORTING_DB_PORT', default=3306, cast=int),
'database': config('MYEMS_REPORTING_DB_DATABASE', default='myems_reporting_db'),
'user': config('MYEMS_REPORTING_DB_USER', default='root'),
'password': config('MYEMS_REPORTING_DB_PASSWORD', default='!MyEMS1'),
'password': config('MYEMS_REPORTING_DB_PASSWORD', default=''),
}
myems_carbon_db = {
@ -78,7 +78,7 @@ myems_carbon_db = {
'port': config('MYEMS_CARBON_DB_PORT', default=3306, cast=int),
'database': config('MYEMS_CARBON_DB_DATABASE', default='myems_carbon_db'),
'user': config('MYEMS_CARBON_DB_USER', default='root'),
'password': config('MYEMS_CARBON_DB_PASSWORD', default='!MyEMS1'),
'password': config('MYEMS_CARBON_DB_PASSWORD', default=''),
}
# indicated in how many minutes to calculate meter energy consumption

149
myems-api/core/svg.py Normal file
View File

@ -0,0 +1,149 @@
import falcon
import simplejson as json
import mysql.connector
import config
from core.useractivity import user_logger, access_control
class Collection:
@staticmethod
def __init__():
""""Initializes svgCollection"""
pass
@staticmethod
def on_options(req, resp):
resp.status = falcon.HTTP_200
@staticmethod
def on_get(req, resp):
cnx = mysql.connector.connect(**config.myems_system_db)
cursor = cnx.cursor(dictionary=True)
query = (" SELECT id, name, content "
" FROM tbl_svgs "
" ORDER BY id ")
cursor.execute(query)
rows_svgs = cursor.fetchall()
result = list()
if rows_svgs is not None and len(rows_svgs) > 0:
for row in rows_svgs:
temp = {"id": row['id'],
"name": row['name'],
"content": row['content']}
result.append(temp)
cursor.close()
cnx.disconnect()
resp.text = json.dumps(result)
class Item:
@staticmethod
def __init__():
""""Initializes svgItem"""
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_svg_ID')
cnx = mysql.connector.connect(**config.myems_system_db)
cursor = cnx.cursor(dictionary=True)
query = (" SELECT id, name, content "
" FROM tbl_svgs "
" WHERE id=%s ")
cursor.execute(query, (id_,))
rows_svg = cursor.fetchone()
result = None
if rows_svg is not None and len(rows_svg) > 0:
result = {"id": rows_svg['id'],
"name": rows_svg['name'],
"content": rows_svg['content']}
else:
cursor.close()
cnx.disconnect()
resp.text = json.dumps(result)
query = (" SELECT id, svg_id, point_id, point_icon, point_x, point_y, meter_type, meter_id, meter_name, func"
" FROM tbl_svg_points "
" WHERE svg_id=%s ")
cursor.execute(query, (id_,))
rows_point = cursor.fetchall()
add_svg = ""
if rows_point is not None and len(rows_point) > 0:
for row in rows_point:
print("row", row)
add_svg = add_svg + \
'<image id="{point_id}" onclick="{func}(\'{meter_type}\',{meter_id},\'{meter_name}\')" overflow="visible" width="80" height="80" xlink:href="{point_icon}" transform="translate({point_x},{point_y})"> </image>\n'. \
format(point_id=row['point_id'],
point_icon=row['point_icon'],
point_x=row['point_x'],
point_y=row['point_y'],
func=row['func'],
meter_type=row['meter_type'],
meter_id=row['meter_id'],
meter_name=row['meter_name'],
)
result['content'] = result['content'].replace("Template", add_svg)
else:
result['content'] = result['content'].replace("TEMPLATE", "")
cursor.close()
cnx.disconnect()
resp.text = json.dumps(result)
@staticmethod
@user_logger
def on_put(req, resp, id_):
"""Handles PUT requests"""
access_control(req)
try:
raw_json = req.stream.read().decode('utf-8')
except Exception as ex:
raise falcon.HTTPError(falcon.HTTP_400, title='API.EXCEPTION', description=ex)
if not id_.isdigit() or int(id_) <= 0:
raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST',
description='API.INVALID_svg_ID')
new_values = json.loads(raw_json)
if 'name' not in new_values['data'].keys() or \
not isinstance(new_values['data']['name'], str):
raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST',
description='API.INVALID_NAME')
if 'content' not in new_values['data'].keys() or \
not isinstance(new_values['data']['content'], str):
raise falcon.HTTPError(falcon.HTTP_400, title='API.BAD_REQUEST',
description='API.INVALID_CONTENT')
name = new_values['data']['name']
content = new_values['data']['content']
cnx = mysql.connector.connect(**config.myems_system_db)
cursor = cnx.cursor()
update_row = (" UPDATE tbl_svgs "
" SET name = %s, content = %s "
" WHERE id = %s ")
cursor.execute(update_row, (name,
content,
id_))
cnx.commit()
cursor.close()
cnx.disconnect()
resp.status = falcon.HTTP_200