兜底策略改进

core/submit.py

@@ -17,6 +17,7 @@ from equipment import DumpInfo, ExcavatorInfo, TruckInfo
 from graph.topo_graph import Topo
 from settings import get_logger, redis5
 from tables import session_mysql, DispatchSetting
+from realtime_dispatch import truck_direct2redis
 
 
 class DispatchSubmission:
@@ -251,6 +252,8 @@ class DispatchSubmission:
             except Exception as es:
                 self.logger.error("group_dispatch_to_redis_error")
                 self.logger.error(es)
+                truck_direct2redis(truck_id)
+
 
 
 def redis_format(truck_id, group_id, dispatch_id, item):

realtime_dispatch.py

@@ -73,17 +73,7 @@ def group_direct2redis(group: Group):
 
     try:
         for truck_id in group.group_trucks:
-            item = session_mysql.query(DispatchSetting).filter_by(truck_id=truck_id, isdeleted=0, ).first()
-            if item is None:
-                raise CoreException(101, "无可用派车计划")
-            record = {"truckId": item.truck_id, "dispatchId": item.id, "exactorId": item.exactor_id,
-                      "dumpId": item.dump_id, "loadAreaId": item.load_area_id, "unloadAreaId": item.unload_area_id,
-                      "groupId": item.group_id, "isdeleted": False, "isTemp": False, "haulFlag": -1,
-                      "groupName": DispatchInfo.group_name[item.group_id]}
-
-            logger.info(f'写入redis调度结果: {record}')
-            # 写入redis
-            redis5.set(item.truck_id, str(json.dumps(record)))
+            truck_direct2redis(truck_id)
 
     except CoreException as ce:
         logger.error(ce)
@@ -91,6 +81,23 @@ def group_direct2redis(group: Group):
         session_mysql.rollback()
 
 
+def truck_direct2redis(truck_id):
+    """
+    根据车辆直接读取数据库写入redis
+    :return: None
+    """
+    item = session_mysql.query(DispatchSetting).filter_by(truck_id=truck_id, isdeleted=0, ).first()
+    if item is None:
+        raise CoreException(101, "无可用派车计划")
+    record = {"truckId": item.truck_id, "dispatchId": item.id, "exactorId": item.exactor_id,
+              "dumpId": item.dump_id, "loadAreaId": item.load_area_id, "unloadAreaId": item.unload_area_id,
+              "groupId": item.group_id, "isdeleted": False, "isTemp": False, "haulFlag": -1,
+              "groupName": DispatchInfo.group_name[item.group_id]}
+    logger.info(f'写入redis调度结果: {record}')
+    # 写入redis
+    redis5.set(item.truck_id, str(json.dumps(record)))
+
+
 def process(dispatcher):
     """
     周期调度进程