添加调度debug模式

realtime_dispatch_test.py

+#!E:\Pycharm Projects\Waytous
+# -*- coding: utf-8 -*-
+# @Time : 2021/7/21 16:45
+# @Author : Opfer
+# @Site :
+# @File : realtime_dispatch.py
+# @Software: PyCharm
+
+
+# 实时调度模块
+from para_config import *
+from equipment.truck import TruckInfo
+from equipment.excavator import ExcavatorInfo
+from equipment.dump import DumpInfo
+import sched
+import time
+from core.dispatcher import Dispatcher
+from core.schedule import PreSchedule
+from data.dispatchInfo import DispatchInfo
+
+
+def direct2redis():
+    """
+    直接读取数据库写入redis
+    :return: None
+    """
+    # 清空数据库缓存
+    session_mysql.commit()
+    session_mysql.flush()
+
+    # 清空数据库缓存
+    session_postgre.commit()
+    session_postgre.flush()
+
+    truck_disp = {}
+    for item in session_mysql.query(DispatchSetting).all():
+        if item.truck_id not in truck_disp:
+            record = {"truckId": item.truck_id}
+            record["id"] = item.id
+            record["exactorId"] = item.exactor_id
+            record["dumpId"] = item.dump_id
+            record["loadAreaId"] = item.load_area_id
+            record["unloadAreaId"] = item.unload_area_id
+            record["groupId"] = item.group_id
+            record["isdeleted"] = False
+            record["isTemp"] = False
+            record["haulFlag"] = -1
+            record["groupName"] = item.group_id
+
+            logger.info("调度结果")
+            logger.info(record)
+            redis5.set(item.truck_id, str(json.dumps(record)))
+
+
+def process(dispatcher):
+    """
+    周期调度进程
+    :param dispatcher:  (Dispatch Class) 矿卡调度类对象
+    :return: None
+    """
+
+    # # 直接读取数据库写入redis
+    # direct2redis()
+
+    # try:
+    # 更新周期参数
+    logger.info("#####################################周期更新开始#####################################")
+
+    global_period_para_update()
+
+    # if get_value("dynamic_dump_num") * get_value("dynamic_excavator_num") == 0:
+    #     raise Exception("无动态派车计划可用")
+    #     return
+    # if get_value("dynamic_truck_num") == 0:
+    #     raise Exception("无动态派车可用矿卡")
+    #     return
+
+    # 清空数据库缓存
+    session_mysql.commit()
+    session_mysql.flush()
+
+    # 清空数据库缓存
+    session_postgre.commit()
+    session_postgre.flush()
+
+    global_period_para_update()
+
+    # 更新调度信息
+    DispatchInfo.reset()
+
+    DispatchInfo.update_device_group_structure()
+
+    DispatchInfo.update_route_distance()
+
+    DispatchInfo.update_group_mode()
+
+    DispatchInfo.update_group_name()
+
+    # logger.info
+    #     group_set = set()
+    #
+    #     # device group structure
+    #     load_excavator_dict = {}  # 装载区id-->>电铲编号的映射
+    #     excavator_load_dict = {}  # 电铲编号->>装载区id的映射
+    #
+    #     group_excavator_dict = {}  # team_id -> dict {[excavator_id, excavator_id], ...}
+    #     excavator_group_dict = {}  # excavator_id -> team_id   问题：多个key值对应一个value值
+    #
+    #     group_dump_dict = {}  # team_id -> dict {unload_area_id, unload_area_id, ...}
+    #     dump_group_dict = {}  # unload_area_id -> team_id
+    #
+    #     group_truck_dict = {}  # team_id -> dict # {group_id:[truck_id,truck_id],...}
+    #     truck_group_dict = {}  # truck_id -> team_id
+    #
+    #     # group feature
+    #     group_mode = {}  # 数据格式： {team_id:mode_code}
+    #
+    #     # route_distance（路网距离）
+    #     load_distance = {}
+    #     unload_distance = {}
+    logger.info("Dispatchinfo，更新后信息")
+    logger.info("group_set")
+    logger.info(DispatchInfo.group_set)
+    logger.info("group_excavator_dict")
+    logger.info(DispatchInfo.group_excavator_dict)
+    logger.info("group_unload_area_dict")
+    logger.info(DispatchInfo.group_unload_area_dict)
+    logger.info("group_truck_dict")
+    logger.info(DispatchInfo.group_truck_dict)
+    logger.info("group_mode")
+    logger.info(DispatchInfo.group_mode)
+    logger.info("load_distance")
+    logger.info(DispatchInfo.load_distance)
+    logger.info("unload_distance")
+    logger.info(DispatchInfo.unload_distance)
+
+    # logger.info("load_excavator_dict")
+    # logger.info(DispatchInfo.load_excavator_dict)
+    # logger.info("excavator_load_dict")
+    # logger.info(DispatchInfo.excavator_load_dict)
+    # logger.info(DispatchInfo.excavator_group_dict)
+    # logger.info(DispatchInfo.dump_group_dict)
+    # logger.info(DispatchInfo.truck_group_dict)
+
+
+    # 调度生成
+    dispatcher.period_update()
+
+    dispatcher.group_generate()
+
+    dispatcher.group_info_update()
+
+    dispatcher.group_dispatch()
+
+    logger.info("#####################################周期更新结束#####################################")
+
+    # except Exception as es:
+    #     logger.error("最外层异常捕获")
+    #     logger.error(es)
+
+
+def perform(inc, dispatcher):
+    """
+    控制程序循环执行
+    :param inc: (int) 循环周期, 单位, 秒
+    :param dispatcher:  (Dispatch Class) 矿卡调度类对象
+    :return: None
+    """
+    scheduler.enter(inc, 0, perform, (inc, dispatcher))
+    process(dispatcher)
+
+
+def main(inc, dispatcher):
+    """
+    程序循环入口函数
+    :param inc:  (int) 循环周期, 单位, 秒
+    :param dispatcher:  (Dispatch Class) 矿卡调度类对象
+    :return: None
+    """
+    scheduler.enter(0, 0, perform, (inc, dispatcher))
+    scheduler.run()
+
+
+if __name__ == "__main__":
+
+    # 初始化日志
+    set_log()
+    # 获取日志器
+    logger = get_logger("zxt.main")
+
+    # 全局参数更新
+    global_period_para_update()
+
+    # 实例化设备对象
+    dump = DumpInfo()
+    excavator = ExcavatorInfo()
+    truck = TruckInfo(dump, excavator)
+
+    # 实例化程序调度器
+    scheduler = sched.scheduler(time.time, time.sleep)
+
+    # 实例化调度预测器
+    pre_sch = PreSchedule(truck, excavator, dump)
+
+    # 实例化矿卡调度器
+    dispatcher = Dispatcher(truck, dump, excavator, pre_sch, False)
+
+    logger.info(" ")
+    logger.info("调度系统启动")
+
+    main(30, dispatcher)