监控与计划不一致-解决异常

dispatcher.py

@@ -613,19 +613,19 @@ class Dispatcher(WalkManage):
                     self.logger.error('error03')
                     self.logger.error(es)
 
-                # try:
-                # 调用调度函数，得到最优目的地序号
-                target_eq_index = self.truck_schedule(self.truck.truck_index_to_uuid_dict[truck_index])
+                try:
+                    # 调用调度函数，得到最优目的地序号
+                    target_eq_index = self.truck_schedule(self.truck.truck_index_to_uuid_dict[truck_index])
 
-                # except Exception as es:
-                #     self.logger.error('error04')
-                #     self.logger.error(es)
-                #     self.logger.error("truck_index,uuid")
-                #     self.logger.error(truck_index)
-                #     self.logger.error(self.truck.truck_index_to_uuid_dict[truck_index])
+                except Exception as es:
+                    self.logger.error('调度算法计算异常')
+                    self.logger.error(es)
+                    self.logger.error("truck_index,uuid")
+                    self.logger.error(truck_index)
+                    self.logger.error(self.truck.truck_index_to_uuid_dict[truck_index])
 
-                # self.logger.("target_eq_index")
-                # self.logger.error(target_eq_index)
+                self.logger.info("target_eq_index")
+                self.logger.info(target_eq_index)
                 try:
                     # 写入Seq序列
                     Seq[truck_index][1] = target_eq_index
@@ -666,7 +666,17 @@ class Dispatcher(WalkManage):
                                            truck_id=truck_id,
                                            group_id=group_id,
                                            isauto=1, isdeleted=0, ).first())
+                        if item is None:
+                            raise Exception("调度计划表与实时监控不匹配")
+                    except Exception as es:
+                        self.logger.error(es)
+                        item = (
+                            session_mysql.query(Dispatch)
+                                .filter_by(truck_id=truck_id,
+                                           # group_id=group_id,
+                                           isauto=1, isdeleted=0, ).first())
 
+                    try:
                         record["exactorId"] = item.exactor_id
                         record["dumpId"] = item.dump_id
                         record["loadAreaId"] = item.load_area_id
@@ -689,6 +699,16 @@ class Dispatcher(WalkManage):
                                            truck_id=truck_id,
                                            group_id=group_id,
                                            isauto=1, isdeleted=0, ).first())
+                        if item is None:
+                            raise Exception("调度计划表与实时监控不匹配")
+                    except Exception as es:
+                        self.logger.error(es)
+                        item = (
+                            session_mysql.query(Dispatch)
+                                .filter_by(truck_id=truck_id,
+                                           # group_id=group_id,
+                                           isauto=1, isdeleted=0, ).first())
+                    try:
                         record["exactorId"] = self.excavator.excavator_index_to_uuid_dict[Seq[i][1]]
                         record["dumpId"] = item.dump_id
                         record["loadAreaId"] = item.load_area_id
@@ -712,6 +732,9 @@ class Dispatcher(WalkManage):
                                                group_id=group_id,
                                                isauto=1, isdeleted=0).first())
 
+                            if item is None:
+                                raise Exception("调度计划表与实时监控不匹配")
+
                             self.logger.info(Seq)
                             self.logger.info(Seq[i][1])
                             self.logger.info(DeviceMap.excavator_index_to_uuid_dict[Seq[i][1]])
@@ -719,7 +742,12 @@ class Dispatcher(WalkManage):
                             self.logger.info("item")
                             print(item.id, item.truck_id, item.exactor_id, item.dump_id)
                         except Exception as es:
-                            self.logger.error("调度结果写入异常-矿卡故障或备停区-调度计划读取异常")
+                            self.logger.error(es)
+                            item = (
+                                session_mysql.query(Dispatch)
+                                    .filter_by(truck_id=truck_id,
+                                               # group_id=group_id,
+                                               isauto=1, isdeleted=0).first())
 
                         try:
                             record["exactorId"] = item.exactor_id