deltasoc部署

LIB/FRONTEND/deltsoc/create_table.py

@@ -0,0 +1,43 @@
+'''
+定义表的结构，并在数据库中创建对应的数据表
+'''
+__author__ = 'lmstack'
+
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy import Column, String, create_engine, Integer, DateTime, BigInteger, FLOAT, TIMESTAMP, func
+from urllib import parse
+Base = declarative_base()
+
+
+class ConsistencyDeltaSoc(Base):
+    __tablename__ = "consistency_delta_soc"
+    __table_args__ = ({'comment': '电池一致性：soc差'})  # 添加索引和表注释
+
+    id = Column(Integer, primary_key=True, autoincrement=True, comment="主键")
+    add_time = Column(TIMESTAMP(True), server_default=func.now()) # 创建时间
+    update_time = Column(TIMESTAMP(True), nullable=False, server_default=func.now(), onupdate=func.now()) # 更新时间
+    sn = Column(String(64), comment="sn")
+    time = Column(DateTime, comment="时间")
+    delta_soc = Column(FLOAT, comment="soc差")
+
+
+    # def __init__(self, sn, current, time_stamp, pack_state, line_state):
+    #     self.sn = sn
+    #     self.current = current
+    #     self.time_stamp = time_stamp
+    #     self.pack_state = pack_state
+    #     self.line_state = line_state
+
+# 执行该文件，创建表格到对应的数据库中
+if __name__ == "__main__":
+    host = 'rm-bp10j10qy42bzy0q77o.mysql.rds.aliyuncs.com'
+    port = 3306
+    user = 'qx_cas'
+    password = parse.quote_plus('Qx@123456')
+    database = 'qx_cas'
+    
+    db_engine = create_engine(
+        "mysql+pymysql://{}:{}@{}:{}/{}?charset=utf8".format(
+            user, password, host, port, database
+        ))
+    Base.metadata.create_all(db_engine)

LIB/FRONTEND/deltsoc/deploy.py

@@ -0,0 +1,63 @@
+#coding=utf-8
+import os
+import datetime
+import pandas as pd
+from LIB.BACKEND import DBManager, Log
+from LIB.MIDDLE import SignalMonitor
+from sqlalchemy import create_engine
+from sqlalchemy.orm import sessionmaker
+import time, datetime
+import traceback
+from LIB.MIDDLE.DeltSoc import LFPDeltSoc20210804 as LFPDeltSoc
+from urllib import parse
+
+dbManager = DBManager.DBManager()
+if __name__ == "__main__":
+    # 数据库配置
+    host = 'rm-bp10j10qy42bzy0q77o.mysql.rds.aliyuncs.com'
+    port = 3306
+    user = 'qx_cas'
+    password = parse.quote_plus('Qx@123456')
+    database = 'qx_cas'
+
+    db_engine = create_engine(
+        "mysql+pymysql://{}:{}@{}:{}/{}?charset=utf8".format(
+            user, password, host, port, database
+        ))
+    DbSession = sessionmaker(bind=db_engine)
+    
+    
+    # 日志配置
+    now_str = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())[0:10]
+    if not os.path.exists('log/' + now_str):
+        os.makedirs('log/' + now_str)
+    log = Log.Mylog(log_name='delta_soc', log_level = 'info')
+    log.set_file_hl(file_name='log/{}/info.log'.format(now_str), log_level='info', size=1024* 1024 * 100)
+    log.set_file_hl(file_name='log/{}/error.log'.format(now_str), log_level='error', size=1024* 1024 * 100)
+    logger = log.get_logger()
+
+    logger.info("pid is {}".format(os.getpid()))
+    logger.error("pid is {}".format(os.getpid()))
+    
+    SNdata_6060 = pd.read_excel('骑享资产梳理-20210621.xlsx', sheet_name='6060')
+    SNnums_6060=SNdata_6060['SN号']
+    now_time=datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
+    now_time = "2021-08-01 00:00:00" # 定时任务开启时，需要删除改行！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！
+
+    now_time=datetime.datetime.strptime(now_time,'%Y-%m-%d %H:%M:%S')
+    start_time=now_time-datetime.timedelta(days=1000)
+    end_time=str(now_time)
+    start_time=str(start_time)
+
+    for sn in SNnums_6060.tolist():
+        try:
+            res = LFPDeltSoc.cal_deltsoc(sn, end_time, start_time)
+            if not res.empty:
+                res.columns = ['time', 'sn', 'delta_soc']
+                res.to_sql("consistency_delta_soc",con=db_engine, if_exists="append",index=False)
+            logger.info("6040 SN: {} DONE!".format(sn))
+        except:
+            logger.error(traceback.format_exc)
+            logger.error(u"{} ：{},{} 任务运行错误\n".format(sn,start_time,end_time), exc_info=True)
+
+

LIB/FRONTEND/deltsoc/run.bat

@@ -0,0 +1,2 @@
+cd /d D:\deploy\python_platform\data_analyze_platform\LIB\FRONTEND\deltsoc
+D:\env\py_pro\python.exe D:\deploy\python_platform\data_analyze_platform\LIB\FRONTEND\deltsoc\deploy.py

LIB/FRONTEND/soh/deploy.py

@@ -30,12 +30,15 @@ if __name__ == "__main__":
     
     # 日志配置
     now_str = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())[0:10]
+    if not os.path.exists('log/' + now_str):
+        os.makedirs('log/' + now_str)
     log = Log.Mylog(log_name='soh', log_level = 'info')
-    log.set_file_hl(file_name='log/{}_info.log'.format(now_str), log_level='info', size=1024* 1024 * 100)
-    log.set_file_hl(file_name='log/{}_error.log'.format(now_str), log_level='error', size=1024* 1024 * 100)
+    log.set_file_hl(file_name='log/{}/info.log'.format(now_str), log_level='info', size=1024* 1024 * 100)
+    log.set_file_hl(file_name='log/{}/error.log'.format(now_str), log_level='error', size=1024* 1024 * 100)
     logger = log.get_logger()
 
     logger.info("pid is {}".format(os.getpid()))
+    logger.error("pid is {}".format(os.getpid()))
     
 
     SNdata_6040 = pd.read_excel('骑享资产梳理-20210621.xlsx', sheet_name='6040骑享')
@@ -43,8 +46,9 @@ if __name__ == "__main__":
     SNnums_6060=SNdata_6060['SN号']
     SNnums_6040=SNdata_6040['SN号']
     now_time=datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
+    now_time = "2021-08-01 00:00:00" # 定时任务开启时，需要删除改行！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！
     now_time=datetime.datetime.strptime(now_time,'%Y-%m-%d %H:%M:%S')
-    start_time=now_time-datetime.timedelta(days=30)
+    start_time=now_time-datetime.timedelta(days=1000)
     end_time=str(now_time)
     start_time=str(start_time)
 
@@ -58,7 +62,7 @@ if __name__ == "__main__":
             logger.info("6040 SN: {} DONE!".format(sn))
         except:
             logger.error(traceback.format_exc)
-            logger.error(u"{} ：{},{} 任务运行错误".format(sn,start_time,end_time), exc_info=True)
+            logger.error(u"{} ：{},{} 任务运行错误\n".format(sn,start_time,end_time), exc_info=True)
 
     for sn in SNnums_6060.tolist():
         try:
@@ -70,5 +74,5 @@ if __name__ == "__main__":
             logger.info("6060 SN: {} DONE!".format(sn))
         except:
             logger.error(traceback.format_exc)
-            logger.error(u"{} ：{},{} 任务运行错误".format(sn,start_time,end_time), exc_info=True)
+            logger.error(u"{} ：{},{} 任务运行错误\n".format(sn,start_time,end_time), exc_info=True)
 

LIB/FRONTEND/soh/run.bat

@@ -1,2 +1,2 @@
-cd /d D:\Platform\Users\WLM\work\data_analyze_platform\LIB\FRONTEND\soh
-D:\Platform\Users\WLM\work\py_pro_env\pro_env\python.exe D:\Platform\Users\WLM\work\data_analyze_platform\LIB\FRONTEND\soh\deploy.py
+cd /d D:\deploy\python_platform\data_analyze_platform\LIB\FRONTEND\soh
+D:\env\py_pro\python.exe D:\deploy\python_platform\data_analyze_platform\LIB\FRONTEND\soh\deploy.py