|
@@ -173,10 +173,10 @@ class DBManager():
|
|
|
def _convert_to_dataframe_system(data, mode=0):
|
|
|
if mode == 0:
|
|
|
|
|
|
- data_block = np.array([data['info']['obdTime'],data['ffSystemInfo']['heatTargetTemp'], data['ffSystemInfo']['heatTimeout'],
|
|
|
- time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(int(data['ffSystemInfo']['rentalStartTime'])/1000)),
|
|
|
- data['ffSystemInfo']['rentalPeriodDays'],data['ffSystemInfo']['bmsInterval'],
|
|
|
- data['ffSystemInfo']['gpsInterval']]).reshape(1,7)
|
|
|
+ data_block = np.array([data['info'].get('obdTime', None),data['ffSystemInfo'].get('heatTargetTemp', None), data['ffSystemInfo'].get('heatTimeout',None),
|
|
|
+ time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(int(data['ffSystemInfo'].get('rentalStartTime'))/1000)),
|
|
|
+ data['ffSystemInfo'].get('rentalPeriodDays',None),data['ffSystemInfo'].get('bmsInterval',None),
|
|
|
+ data['ffSystemInfo'].get('gpsInterval', None)]).reshape(1,7)
|
|
|
df = pd.DataFrame(
|
|
|
columns=['时间戳','加热目标温度', '加热超时','租赁开始时间','租赁天数','bms上传周期','gps上传周期'],data=data_block)
|
|
|
if mode == 1:
|
|
@@ -188,18 +188,18 @@ class DBManager():
|
|
|
def _convert_to_dataframe_accum(data, mode=0):
|
|
|
if mode == 0:
|
|
|
|
|
|
- data_block = np.array([data['info']['obdTime'],data['ffBatteryAccum']['SOH_AlgUnexTime'], data['ffBatteryAccum']['CHG_AHaccum'],
|
|
|
- data['ffBatteryAccum']['CHG_PHaccum'], data['ffBatteryAccum']['DSG_AHaccum'],
|
|
|
- data['ffBatteryAccum']['DSG_PHaccum'],data['ffBatteryAccum']['OverTemp_CHG_AHaccum'],
|
|
|
- data['ffBatteryAccum']['OverTemp_CHG_PHaccum']]).reshape(1,8)
|
|
|
+ data_block = np.array([data['info'].get('obdTime',None),data['ffBatteryAccum'].get('SOH_AlgUnexTime',None), data['ffBatteryAccum'].get('CHG_AHaccum',None),
|
|
|
+ data['ffBatteryAccum'].get('CHG_PHaccum',None), data['ffBatteryAccum'].get('DSG_AHaccum',None),
|
|
|
+ data['ffBatteryAccum'].get('DSG_PHaccum',None),data['ffBatteryAccum'].get('OverTemp_CHG_AHaccum',None),
|
|
|
+ data['ffBatteryAccum'].get('OverTemp_CHG_PHaccum',None)]).reshape(1,8)
|
|
|
df = pd.DataFrame(
|
|
|
columns=['时间戳','SOH未标定时间', '累计充电电量','累计充电能量','累计放电电量','累计放电能量',
|
|
|
'累计高温充电电量', '累计高温充电能量'],data=data_block)
|
|
|
|
|
|
if mode == 1:
|
|
|
- data_block = np.array([data['info']['obdTime'], data['ffBatteryAccum']['CHG_AHaccum'],
|
|
|
- data['ffBatteryAccum']['CHG_PHaccum'], data['ffBatteryAccum']['DSG_AHaccum'],
|
|
|
- data['ffBatteryAccum']['DSG_PHaccum'],data['ffBatteryAccum']['totalMileage']]).reshape(1,6)
|
|
|
+ data_block = np.array([data['info'].get('obdTime',None), data['ffBatteryAccum'].get('CHG_AHaccum',None),
|
|
|
+ data['ffBatteryAccum'].get('CHG_PHaccum',None), data['ffBatteryAccum'].get('DSG_AHaccum',None),
|
|
|
+ data['ffBatteryAccum'].get('DSG_PHaccum',None),data['ffBatteryAccum'].get('totalMileage',None)]).reshape(1,6)
|
|
|
df = pd.DataFrame(
|
|
|
columns=['时间戳','累计充电电量','累计充电能量','累计放电电量','累计放电能量', '累积里程'],data=data_block)
|
|
|
return df
|