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

fixed warnings in myems-aggregation service

pull/75/head
13621160019@163.com 2021-10-24 17:47:22 +08:00
parent 545d16660d
commit 04df9ac030
31 changed files with 33 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
myems-aggregation/combined_equipment_billing_input_category.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
combined_equipment_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_combined_equipments "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
combined_equipment_list = list()
for row in rows_combined_equipments:
combined_equipment_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})

2
myems-aggregation/combined_equipment_billing_input_item.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
combined_equipment_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_combined_equipments "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
combined_equipment_list = list()
for row in rows_combined_equipments:
combined_equipment_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})

2
myems-aggregation/combined_equipment_billing_output_category.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
combined_equipment_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_combined_equipments "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
combined_equipment_list = list()
for row in rows_combined_equipments:
combined_equipment_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})

2
myems-aggregation/combined_equipment_energy_input_category.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
combined_equipment_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_combined_equipments "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
combined_equipment_list = list()
for row in rows_combined_equipments:
combined_equipment_list.append({"id": row[0], "name": row[1]})

2
myems-aggregation/combined_equipment_energy_input_item.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
combined_equipment_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_combined_equipments "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
combined_equipment_list = list()
for row in rows_combined_equipments:
combined_equipment_list.append({"id": row[0], "name": row[1]})

2
myems-aggregation/combined_equipment_energy_output_category.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
combined_equipment_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_combined_equipments "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
combined_equipment_list = list()
for row in rows_combined_equipments:
combined_equipment_list.append({"id": row[0], "name": row[1]})

2
myems-aggregation/equipment_billing_input_category.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
equipment_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_equipments "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
equipment_list = list()
for row in rows_equipments:
equipment_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})

2
myems-aggregation/equipment_billing_input_item.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
equipment_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_equipments "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
equipment_list = list()
for row in rows_equipments:
equipment_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})

2
myems-aggregation/equipment_billing_output_category.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
equipment_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_equipments "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
equipment_list = list()
for row in rows_equipments:
equipment_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})

2
myems-aggregation/equipment_energy_input_category.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
equipment_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_equipments "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
equipment_list = list()
for row in rows_equipments:
equipment_list.append({"id": row[0], "name": row[1]})

2
myems-aggregation/equipment_energy_input_item.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
equipment_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_equipments "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
equipment_list = list()
for row in rows_equipments:
equipment_list.append({"id": row[0], "name": row[1]})

2
myems-aggregation/equipment_energy_output_category.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
equipment_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_equipments "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
equipment_list = list()
for row in rows_equipments:
equipment_list.append({"id": row[0], "name": row[1]})

2
myems-aggregation/meter_billing.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
meter_list = list()
try:
cursor_system_db.execute(" SELECT id, name, energy_category_id, cost_center_id "
" FROM tbl_meters "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
meter_list = list()
for row in rows_meters:
meter_list.append({"id": row[0],
"name": row[1],

2
myems-aggregation/shopfloor_billing_input_category.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
shopfloor_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_shopfloors "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
shopfloor_list = list()
for row in rows_shopfloors:
shopfloor_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})

2
myems-aggregation/shopfloor_billing_input_item.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
shopfloor_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_shopfloors "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
shopfloor_list = list()
for row in rows_shopfloors:
shopfloor_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})

2
myems-aggregation/shopfloor_energy_input_category.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
shopfloor_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_shopfloors "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
shopfloor_list = list()
for row in rows_shopfloors:
shopfloor_list.append({"id": row[0], "name": row[1]})

2
myems-aggregation/shopfloor_energy_input_item.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
shopfloor_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_shopfloors "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
shopfloor_list = list()
for row in rows_shopfloors:
shopfloor_list.append({"id": row[0], "name": row[1]})

2
myems-aggregation/space_billing_input_category.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
space_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_spaces "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
space_list = list()
for row in rows_spaces:
space_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})

2
myems-aggregation/space_billing_input_item.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
space_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_spaces "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
space_list = list()
for row in rows_spaces:
space_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})

2
myems-aggregation/space_billing_output_category.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
space_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_spaces "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
space_list = list()
for row in rows_spaces:
space_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})

2
myems-aggregation/space_energy_input_category.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
space_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_spaces "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
space_list = list()
for row in rows_spaces:
space_list.append({"id": row[0], "name": row[1]})

2
myems-aggregation/space_energy_input_item.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
space_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_spaces "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
space_list = list()
for row in rows_spaces:
space_list.append({"id": row[0], "name": row[1]})

2
myems-aggregation/space_energy_output_category.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
space_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_spaces "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
space_list = list()
for row in rows_spaces:
space_list.append({"id": row[0], "name": row[1]})

2
myems-aggregation/store_billing_input_category.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
store_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_stores "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
store_list = list()
for row in rows_stores:
store_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})

2
myems-aggregation/store_billing_input_item.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
store_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_stores "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
store_list = list()
for row in rows_stores:
store_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})

2
myems-aggregation/store_energy_input_category.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
store_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_stores "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
store_list = list()
for row in rows_stores:
store_list.append({"id": row[0], "name": row[1]})

2
myems-aggregation/store_energy_input_item.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
store_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_stores "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
store_list = list()
for row in rows_stores:
store_list.append({"id": row[0], "name": row[1]})

3
myems-aggregation/tenant_billing_input_category.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
tenant_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_tenants "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
tenant_list = list()
for row in rows_tenants:
tenant_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})
@ -124,7 +124,6 @@ def main(logger):
print("Connected to MyEMS Billing Database")
for tenant in tenant_list:
############################################################################################################
# Step 2: get the latest start_datetime_utc
############################################################################################################

3
myems-aggregation/tenant_billing_input_item.py
View File

@ -42,6 +42,7 @@ def main(logger):
print("Connected to MyEMS System Database")
tenant_list = list()
try:
cursor_system_db.execute(" SELECT id, name, cost_center_id "
" FROM tbl_tenants "
@ -58,7 +59,6 @@ def main(logger):
time.sleep(60)
continue
tenant_list = list()
for row in rows_tenants:
tenant_list.append({"id": row[0], "name": row[1], "cost_center_id": row[2]})
@ -124,7 +124,6 @@ def main(logger):
print("Connected to MyEMS Billing Database")
for tenant in tenant_list:
############################################################################################################
# Step 2: get the latest start_datetime_utc
############################################################################################################

4
myems-aggregation/tenant_energy_input_category.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
tenant_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_tenants "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
tenant_list = list()
for row in rows_tenants:
tenant_list.append({"id": row[0], "name": row[1]})
@ -66,7 +66,7 @@ def main(logger):
print("Got all tenants in MyEMS System Database")
# shuffle the tenant list for randomly calculating the meter hourly value
# shuffle the tenant list for randomly calculating the hourly values
random.shuffle(tenant_list)
################################################################################################################

4
myems-aggregation/tenant_energy_input_item.py
View File

@ -37,6 +37,7 @@ def main(logger):
continue
print("Connected to MyEMS System Database")
tenant_list = list()
try:
cursor_system_db.execute(" SELECT id, name "
" FROM tbl_tenants "
@ -49,7 +50,6 @@ def main(logger):
time.sleep(60)
continue
tenant_list = list()
for row in rows_tenants:
tenant_list.append({"id": row[0], "name": row[1]})
@ -66,7 +66,7 @@ def main(logger):
print("Got all tenants in MyEMS System Database")
# shuffle the tenant list for randomly calculating the meter hourly value
# shuffle the tenant list for randomly calculating the hourly values
random.shuffle(tenant_list)
################################################################################################################