update 续驶里程

LIB/FRONTEND/DrivingRange/deploy_driving_range.py

@@ -21,6 +21,7 @@ if __name__ == "__main__":
     pre_time = now_time + dateutil.relativedelta.relativedelta(minutes=-30)
     end_time=datetime.datetime.strftime(now_time,"%Y-%m-%d %H:%M:%S")
     start_time=datetime.datetime.strftime(pre_time,"%Y-%m-%d %H:%M:%S")
+    print(pre_time)
 
 
     # # 更新sn列表
@@ -83,7 +84,7 @@ if __name__ == "__main__":
         #调度周期：每天运行一次。
         #更新所有sn，连读多日的factor，如果start_date和end_date相隔一天，代表更新start_date的factor。
         logger.info(u"{},{} 任务运行开始\n".format(start_time,end_time), exc_info=True)
-        UpdtFct.updtVehElecRng(db_qx, db_qx, db_engine, range_table_name='driving_range_result', sn_newest_table_name='driving_range_sn_factor_newest', input_time=pre_time)
+        UpdtFct.updtVehElecRng(db_qx, db_qx, db_engine, range_table_name='driving_range_result', sn_newest_table_name='driving_range_sn_factor_newest', input_time=start_time)
         logger.info(u"{},{} 续驶里程计算完成\n".format(start_time,end_time), exc_info=True)
     except:
         logger.error(traceback.format_exc)

LIB/MIDDLE/DrivingRange/UpdtFct.py

@@ -413,7 +413,6 @@ def updtVehElecRng(db_qx, db_local, db_engine, range_table_name='tb_sn_factor_so
         sn_soc_factor_range_df=sn_soc_factor_range_df.append(sn_soc_factor_range_row)#拼接
 
     ##任务5，将sn_soc_factor_range_df写入到tb_sn_factor_soc_range中,使用替换关系。
-    pdb.set_trace()
     sn_soc_factor_range_df.to_sql(range_table_name,con=db_engine,chunksize=10000,\
         if_exists='replace',index=False)