|
|
@@ -63,8 +63,6 @@ def SOC_cal():
|
|
|
logger.info("pid-{} celltype-{} SN: {} SKIP!".format(os.getpid(), "未知", sn))
|
|
|
continue
|
|
|
|
|
|
- logger.info("pid-{} celltype-{} SN: {} START!".format(os.getpid(), celltype, sn))
|
|
|
-
|
|
|
#读取原始数据库数据........................................................................................................................................................
|
|
|
dbManager = DBManager.DBManager()
|
|
|
df_data = dbManager.get_data(sn=sn, start_time=start_time, end_time=end_time, data_groups=['bms'])
|
|
|
@@ -73,6 +71,7 @@ def SOC_cal():
|
|
|
|
|
|
#电池诊断................................................................................................................................................................
|
|
|
if not df_bms.empty:
|
|
|
+ logger.info("pid-{} celltype-{} SN: {} START!".format(os.getpid(), celltype, sn))
|
|
|
SOC_result=soc.soc_test(sn,df_bms)
|
|
|
SOC_result.columns=['sn','soc','time']
|
|
|
SOC_result.reset_index(inplace=True,drop=True)
|
|
|
@@ -82,6 +81,8 @@ def SOC_cal():
|
|
|
logger.info("算法运行完成，结果入库")
|
|
|
else:
|
|
|
logger.info("算法运行完成，无结果入库")
|
|
|
+ else:
|
|
|
+ logger.info("pid-{} celltype-{} SN: {} 无数据无需运算".format(os.getpid(), celltype, sn))
|
|
|
|
|
|
except Exception as e:
|
|
|
logger.error(traceback.format_exc)
|
