|
@@ -4,6 +4,7 @@ import os
|
|
|
import time
|
|
|
from MyUtils.ZillionUtil import ZillionUtil
|
|
|
from MyUtils.MysqlUtils import MysqlUtils
|
|
|
+import pytz
|
|
|
|
|
|
INSERT_SQL = "replace into %s.%s(project_id,date,energy_cooling,energy_heating,energy_ac_terminal,energy_light,energy_others,create_time,update_time) values "
|
|
|
DELETE_SQL = "DELETE FROM `energy_week_day` WHERE `project_id` = '%s' AND `date` >= '%s' AND `date` < '%s' "
|
|
@@ -64,10 +65,16 @@ mysql = {
|
|
|
my_database = os.getenv("database")
|
|
|
|
|
|
|
|
|
-print("同步%s项目数据"%building)
|
|
|
+
|
|
|
+
|
|
|
+print("同步%s项目数据"%(building))
|
|
|
while True:
|
|
|
- time_now = time.strftime("%H:%M:%S", time.localtime()) # 刷新
|
|
|
- set_time = "10:05:00"
|
|
|
+ # 容器里获取时间
|
|
|
+ tz = pytz.timezone('Asia/Shanghai') # 东八区
|
|
|
+ time_now = datetime.datetime.fromtimestamp(int(time.time()),
|
|
|
+ pytz.timezone('Asia/Shanghai')).strftime('%H:%M:%S')
|
|
|
+ # time_now = time.strftime("%H:%M:%S", time.localtime()) # 刷新
|
|
|
+ set_time = "10:40:00"
|
|
|
if time_now == set_time:#此处设置每天定时的时间
|
|
|
today = datetime.date.today().strftime("%Y%m%d")
|
|
|
yesterday = (datetime.date.today()-datetime.timedelta(days=1)).strftime("%Y%m%d")
|