修复行程异常BUG

realtime_dispatch.py

@@ -1316,46 +1316,46 @@ class Group(WalkManage):
 # 下面三个函数保证程序定期执行，不用管他
 def process(dispatcher):
 
-    # try:
-    # 更新周期参数
-    logger.info("#####################################周期更新开始#####################################")
-
-    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
-    # para_process(dispatcher)
-    #
-    # state_process(dispatcher)
-
-    # 清空数据库缓存
-    session_mysql.commit()
-    session_mysql.flush()
-
-    # 清空数据库缓存
-    session_postgre.commit()
-    session_postgre.flush()
-    #
-    # # 周期更新
-    # dispatcher.para_period_update()
-
-    # 周期更新
-    dispatcher.dispatcher_period_update()
-
-    # 参数重置
-    dispatcher.sim_para_reset()
-
-    # try:
-
-    # 调度计算
-    dispatcher.schedule_construct()
+    try:
+        # 更新周期参数
+        logger.info("#####################################周期更新开始#####################################")
+
+        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
+        # para_process(dispatcher)
+        #
+        # state_process(dispatcher)
+
+        # 清空数据库缓存
+        session_mysql.commit()
+        session_mysql.flush()
+
+        # 清空数据库缓存
+        session_postgre.commit()
+        session_postgre.flush()
+        #
+        # # 周期更新
+        # dispatcher.para_period_update()
+
+        # 周期更新
+        dispatcher.dispatcher_period_update()
+
+        # 参数重置
+        dispatcher.sim_para_reset()
 
-    # except Exception as es:
-    #     logger.error("更新不及时")
-    #     logger.error(es)
+        # try:
+
+        # 调度计算
+        dispatcher.schedule_construct()
+
+    except Exception as es:
+        logger.error("更新不及时")
+        logger.error(es)
 
     logger.info("#####################################周期更新结束#####################################")