|
|
@@ -20,7 +20,7 @@ def low_soc_alarm_sta(df_sns, db_qxcas_engine, conn, db_sp_engine):
|
|
|
df_offlinealarm_lastday = pd.read_sql(sql, db_qxcas_engine)
|
|
|
sn_offline = df_offlinealarm_lastday['sn'].tolist()
|
|
|
|
|
|
- sql = "select * from all_fault_info where end_time='{}' and code={}".format('0000-00-00 00:00:00', 58)
|
|
|
+ sql = "select * from all_fault_info where end_time='{}' and code='{}'".format('0000-00-00 00:00:00', 'C307')
|
|
|
df_all_alarm_info = pd.read_sql(sql, db_sp_engine)
|
|
|
sn_allalarm = df_all_alarm_info['product_id'].tolist()
|
|
|
|
|
|
@@ -36,7 +36,7 @@ def low_soc_alarm_sta(df_sns, db_qxcas_engine, conn, db_sp_engine):
|
|
|
for sn in sn_new:
|
|
|
df = df_lowsocalarm_lastday[df_lowsocalarm_lastday['sn']==sn]
|
|
|
factory = df_sns[df_sns['sn']==sn]['factory'].values[0]
|
|
|
- df_new = df_new.append({'add_time':now, 'product_id':sn, 'factory':factory, 'start_time':df['time'].values[0], 'end_time':'0000-00-00 00:00:00', 'info':"低电量报警", 'code':58, 'level':1}, ignore_index=True)
|
|
|
+ df_new = df_new.append({'add_time':now, 'product_id':sn, 'factory':factory, 'start_time':df['time'].values[0], 'end_time':'0000-00-00 00:00:00', 'info':"低电量报警", 'code':'C307', 'level':3}, ignore_index=True)
|
|
|
if not df_new.empty:
|
|
|
df_new.to_sql('all_fault_info', db_sp_engine, if_exists='append', index=False)
|
|
|
|
