main.py 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. import CloudBMSSoh
  2. import log
  3. #coding=utf-8
  4. import os
  5. import datetime
  6. import pandas as pd
  7. from LIB.BACKEND import DBManager, Log
  8. # from LIB.MIDDLE import SignalMonitor
  9. from sqlalchemy import create_engine
  10. from sqlalchemy.orm import sessionmaker
  11. import time, datetime
  12. from LIB.MIDDLE.soh import NCMSoh_20210716 as NCMSoh
  13. from LIB.MIDDLE.soh import LFPSoh_20210711 as LFPSoh
  14. from urllib import parse
  15. dbManager = DBManager.DBManager()
  16. if __name__ == "__main__":
  17. SNdata_6040 = pd.read_excel('骑享资产梳理-20210621.xlsx', sheet_name='6040骑享')
  18. SNdata_6060 = pd.read_excel('骑享资产梳理-20210621.xlsx', sheet_name='6060')
  19. SNdata_4840 = pd.read_excel('骑享资产梳理-20210621.xlsx', sheet_name='4840骑享')
  20. SNdata_7250 = pd.read_excel('骑享资产梳理-20210621.xlsx', sheet_name='7250')
  21. SNnums_6060=SNdata_6060['SN号']
  22. SNnums_6040=SNdata_6040['SN号']
  23. SNnums_4840=SNdata_4840['SN号']
  24. SNnums_7250=SNdata_7250['SN号']
  25. SNnums=SNnums_6060.tolist()+SNnums_6040.tolist()+SNnums_4840.tolist()
  26. now_time=datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
  27. now_time=datetime.datetime.strptime(now_time,'%Y-%m-%d %H:%M:%S')
  28. start_time=now_time-datetime.timedelta(days=30*36)
  29. end_time=str(now_time)
  30. start_time=str(start_time)
  31. #log信息配置
  32. mylog=log.Mylog('log.txt','error')
  33. mylog.logcfg()
  34. for sn in SNnums:
  35. try:
  36. dbManager = DBManager.DBManager()
  37. df_data = dbManager.get_data(sn=sn, start_time=start_time, end_time=end_time, data_groups=['bms','accum'])
  38. df_bms = df_data['bms']
  39. df_accum=df_data['accum']
  40. # df_bms.to_csv('BMS_'+sn+'.csv')
  41. # df_accum.to_csv('BMS_accum_'+sn+'.csv')
  42. Soh_cal=CloudBMSSoh.Soh(sn,df_bms,df_accum)
  43. df_res=Soh_cal.soh()
  44. df_res.to_csv('BMS_SOH_'+sn+'.csv',encoding='GB18030')
  45. except IndexError as e:
  46. print(repr(e))
  47. mylog.logopt(sn,e)
  48. pass