123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100 |
- import datetime
- import pandas as pd
- from LIB.BACKEND import DBManager, Log
- import time, datetime
- from apscheduler.schedulers.blocking import BlockingScheduler
- from pandas.core.frame import DataFrame
- import Li_plated
- def cell_platd_test():
- global SNnums
- global df_Diag_lipltd
- start=time.time()
- now_time=datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
- now_time=datetime.datetime.strptime(now_time,'%Y-%m-%d %H:%M:%S')
- start_time=now_time-datetime.timedelta(days=3)
- end_time=str(now_time)
- start_time=str(start_time)
- k = 1
- for sn in SNnums:
- if 'PK500' in sn:
- celltype=1
- elif 'PK502' in sn:
- celltype=2
- elif 'K504B' in sn:
- celltype=99
- elif 'MGMLXN750' in sn:
- celltype=3
- elif ('MGMCLN750' or 'UD') in sn:
- celltype=4
- elif 'TJMCL' in sn:
- celltype=100
- else:
- print('SN:{},未找到对应电池类型!!!'.format(sn))
- continue
-
- print('计算的第' + str(k) + '个:' + sn)
- k = k + 1
-
- start_time = '2021-12-01 00:00:00'
- end_time = '2021-12-08 12:00:00'
- dbManager = DBManager.DBManager()
- df_data = dbManager.get_data(sn=sn, start_time=start_time, end_time=end_time, data_groups=['bms'])
- df_bms = df_data['bms']
- df_Diag_lipltd_add = pd.DataFrame(columns = ['sn','time','liplated', 'liplated_amount'])
-
- if not df_bms.empty:
- Diag_lipltd_temp = Li_plated.Liplated_test(sn,celltype,df_bms)
- df_Diag_lipltd_add = Diag_lipltd_temp.liplated_detect()
- if not df_Diag_lipltd_add.empty:
- df_Diag_lipltd_temp = df_Diag_lipltd.append(df_Diag_lipltd_add)
- df_Diag_lipltd = df_Diag_lipltd_temp.drop_duplicates(subset = ['sn','time'], keep = 'first', inplace = False)
- df_Diag_lipltd.sort_values(by = ['sn'], axis = 0, ascending=True,inplace=True)
- df_Diag_lipltd.to_csv(r'D:\Work\Code_write\data_analyze_platform\USER\lzx\01算法开发\02析锂检测\liplated\析锂.csv',index=False,encoding='GB18030')
- end=time.time()
- print(end-start)
- if __name__ == "__main__":
- global SNnums
- global df_Diag_lipltd
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- SNnums = ['PK50201A000002053']
-
-
-
-
-
-
- print('----------------输入--------')
- print('-------计算中-----------')
- cell_platd_test()
-
- scheduler = BlockingScheduler()
-
- try:
- scheduler.start()
- except Exception as e:
- scheduler.shutdown()
- print(repr(e))
-
|