redis日志

app.py

@@ -35,6 +35,8 @@ def dispatch_request():
     # 获取日志器
     logger = get_logger("zxt.request")
 
+    logger.info("请求调度模式")
+
     try:
 
         # 清空数据库缓存

dispatcher.py

@@ -725,8 +725,8 @@ class DispatchSubmission:
                     if item is None:
                         raise Exception("调度计划表与实时监控不匹配")
 
-                    self.logger.info("dispatch-to-redis")
-                    self.logger.info(item.id + "  " + item.truck_id + "  " + item.exactor_id + "  " + item.dump_id)
+                    # self.logger.info("dispatch-to-redis")
+                    # self.logger.info(item.id + "  " + item.truck_id + "  " + item.exactor_id + "  " + item.dump_id)
                 except Exception as es:
                     self.logger.error(es)
                     item = (
@@ -735,6 +735,9 @@ class DispatchSubmission:
                                        # group_id=group_id,
                                        isauto=1, isdeleted=0, ).first())
 
+                self.logger.info("dispatch-to-redis")
+                self.logger.info(item.id + "  " + item.truck_id + "  " + item.exactor_id + "  " + item.dump_id)
+
                 try:
                     record["exactorId"] = item.exactor_id
                     record["dumpId"] = item.dump_id
@@ -761,8 +764,8 @@ class DispatchSubmission:
                     if item is None:
                         raise Exception("调度计划表与实时监控不匹配")
 
-                    self.logger.info("dispatch-to-redis")
-                    self.logger.info(item.id + "  " + item.truck_id + "  " + item.exactor_id + "  " + item.dump_id)
+                    # self.logger.info("dispatch-to-redis")
+                    # self.logger.info(item.id + "  " + item.truck_id + "  " + item.exactor_id + "  " + item.dump_id)
                 except Exception as es:
                     self.logger.error(es)
                     item = (
@@ -770,6 +773,10 @@ class DispatchSubmission:
                             .filter_by(truck_id=truck_id,
                                        # group_id=group_id,
                                        isauto=1, isdeleted=0, ).first())
+
+                self.logger.info("dispatch-to-redis")
+                self.logger.info(item.id + "  " + item.truck_id + "  " + item.exactor_id + "  " + item.dump_id)
+
                 try:
                     record["exactorId"] = self.excavator.excavator_index_to_uuid_dict[dispatch_seq[1]]
                     record["dumpId"] = item.dump_id
@@ -801,8 +808,8 @@ class DispatchSubmission:
                         # self.logger.info(dispatch_seq[1])
                         # self.logger.info(DeviceMap.excavator_index_to_uuid_dict[dispatch_seq[1]])
 
-                        self.logger.info("item")
-                        self.logger.info(item.id + "  " + item.truck_id + "  " + item.exactor_id + "  " + item.dump_id)
+                        # self.logger.info("item")
+                        # self.logger.info(item.id + "  " + item.truck_id + "  " + item.exactor_id + "  " + item.dump_id)
                     except Exception as es:
                         self.logger.error(es)
                         item = (
@@ -811,6 +818,9 @@ class DispatchSubmission:
                                            # group_id=group_id,
                                            isauto=1, isdeleted=0).first())
 
+                    self.logger.info("dispatch-to-redis")
+                    self.logger.info(item.id + "  " + item.truck_id + "  " + item.exactor_id + "  " + item.dump_id)
+
                     try:
                         record["exactorId"] = item.exactor_id
                         record["dumpId"] = item.dump_id