Skip to content

I
integrated-scheduling-v3
Commit 8c155ed9 authored by 张晓彤's avatar 张晓彤
Browse files
Options

添加捕获最外层异常

parent b7f001dc
Hide whitespace changes
Inline Side-by-side
Showing with 95 additions and 95 deletions
realtime_dispatch.py
View file @ 8c155ed9
...@@ -62,101 +62,101 @@ def process(dispatcher): ...@@ -62,101 +62,101 @@ def process(dispatcher):
# # 直接读取数据库写入redis # # 直接读取数据库写入redis
# direct2redis() # direct2redis()
# try: try:
# 更新周期参数 # 更新周期参数
logger.info("#####################################周期更新开始#####################################") logger.info("#####################################周期更新开始#####################################")
global_period_para_update() global_period_para_update()
if get_value("dynamic_dump_num") * get_value("dynamic_excavator_num") == 0: if get_value("dynamic_dump_num") * get_value("dynamic_excavator_num") == 0:
raise Exception("无动态派车计划可用") raise Exception("无动态派车计划可用")
return return
if get_value("dynamic_truck_num") == 0: if get_value("dynamic_truck_num") == 0:
raise Exception("无动态派车可用矿卡") raise Exception("无动态派车可用矿卡")
return return
# 清空数据库缓存 # 清空数据库缓存
session_mysql.commit() session_mysql.commit()
session_mysql.flush() session_mysql.flush()
# 清空数据库缓存 # 清空数据库缓存
session_postgre.commit() session_postgre.commit()
session_postgre.flush() session_postgre.flush()
global_period_para_update() global_period_para_update()
# 更新调度信息 # 更新调度信息
DispatchInfo.reset() DispatchInfo.reset()
DispatchInfo.update_device_group_structure() DispatchInfo.update_device_group_structure()
DispatchInfo.update_route_distance() DispatchInfo.update_route_distance()
DispatchInfo.update_group_mode() DispatchInfo.update_group_mode()
DispatchInfo.update_group_name() DispatchInfo.update_group_name()
# logger.info # logger.info
# group_set = set() # group_set = set()
# #
# # device group structure # # device group structure
# load_excavator_dict = {} # 装载区id-->>电铲编号的映射 # load_excavator_dict = {} # 装载区id-->>电铲编号的映射
# excavator_load_dict = {} # 电铲编号->>装载区id的映射 # excavator_load_dict = {} # 电铲编号->>装载区id的映射
# #
# group_excavator_dict = {} # team_id -> dict {[excavator_id, excavator_id], ...} # group_excavator_dict = {} # team_id -> dict {[excavator_id, excavator_id], ...}
# excavator_group_dict = {} # excavator_id -> team_id 问题：多个key值对应一个value值 # excavator_group_dict = {} # excavator_id -> team_id 问题：多个key值对应一个value值
# #
# group_dump_dict = {} # team_id -> dict {unload_area_id, unload_area_id, ...} # group_dump_dict = {} # team_id -> dict {unload_area_id, unload_area_id, ...}
# dump_group_dict = {} # unload_area_id -> team_id # dump_group_dict = {} # unload_area_id -> team_id
# #
# group_truck_dict = {} # team_id -> dict # {group_id:[truck_id,truck_id],...} # group_truck_dict = {} # team_id -> dict # {group_id:[truck_id,truck_id],...}
# truck_group_dict = {} # truck_id -> team_id # truck_group_dict = {} # truck_id -> team_id
# #
# # group feature # # group feature
# group_mode = {} # 数据格式： {team_id:mode_code} # group_mode = {} # 数据格式： {team_id:mode_code}
# #
# # route_distance（路网距离） # # route_distance（路网距离）
# load_distance = {} # load_distance = {}
# unload_distance = {} # unload_distance = {}
logger.info("Dispatchinfo，更新后信息") logger.info("Dispatchinfo，更新后信息")
logger.info("group_set") logger.info("group_set")
logger.info(DispatchInfo.group_set) logger.info(DispatchInfo.group_set)
logger.info("group_excavator_dict") logger.info("group_excavator_dict")
logger.info(DispatchInfo.group_excavator_dict) logger.info(DispatchInfo.group_excavator_dict)
logger.info("group_unload_area_dict") logger.info("group_unload_area_dict")
logger.info(DispatchInfo.group_unload_area_dict) logger.info(DispatchInfo.group_unload_area_dict)
logger.info("group_truck_dict") logger.info("group_truck_dict")
logger.info(DispatchInfo.group_truck_dict) logger.info(DispatchInfo.group_truck_dict)
logger.info("group_mode") logger.info("group_mode")
logger.info(DispatchInfo.group_mode) logger.info(DispatchInfo.group_mode)
logger.info("load_distance") logger.info("load_distance")
logger.info(DispatchInfo.load_distance) logger.info(DispatchInfo.load_distance)
logger.info("unload_distance") logger.info("unload_distance")
logger.info(DispatchInfo.unload_distance) logger.info(DispatchInfo.unload_distance)
# logger.info("load_excavator_dict") # logger.info("load_excavator_dict")
# logger.info(DispatchInfo.load_excavator_dict) # logger.info(DispatchInfo.load_excavator_dict)
# logger.info("excavator_load_dict") # logger.info("excavator_load_dict")
# logger.info(DispatchInfo.excavator_load_dict) # logger.info(DispatchInfo.excavator_load_dict)
# logger.info(DispatchInfo.excavator_group_dict) # logger.info(DispatchInfo.excavator_group_dict)
# logger.info(DispatchInfo.dump_group_dict) # logger.info(DispatchInfo.dump_group_dict)
# logger.info(DispatchInfo.truck_group_dict) # logger.info(DispatchInfo.truck_group_dict)
# 调度生成 # 调度生成
dispatcher.period_update() dispatcher.period_update()
dispatcher.group_generate() dispatcher.group_generate()
dispatcher.group_info_update() dispatcher.group_info_update()
dispatcher.group_dispatch() dispatcher.group_dispatch()
logger.info("#####################################周期更新结束#####################################") logger.info("#####################################周期更新结束#####################################")
# except Exception as es: except Exception as es:
# logger.error("最外层异常捕获") logger.error("最外层异常捕获")
# logger.error(es) logger.error(es)
def perform(inc, dispatcher): def perform(inc, dispatcher):
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment