Commit 3bd77b30 authored by 张晓彤's avatar 张晓彤

redis写入异常捕获

parent bc302193
...@@ -716,6 +716,9 @@ class DispatchSubmission: ...@@ -716,6 +716,9 @@ class DispatchSubmission:
isauto=1, isdeleted=0, ).first()) isauto=1, isdeleted=0, ).first())
if item is None: if item is None:
raise Exception("调度计划表与实时监控不匹配") raise Exception("调度计划表与实时监控不匹配")
self.logger.info("dispatch-to-redis")
self.logger.into(item.id, item.truck_id, item.exactor_id, item.dump_id)
except Exception as es: except Exception as es:
self.logger.error(es) self.logger.error(es)
item = ( item = (
...@@ -749,6 +752,9 @@ class DispatchSubmission: ...@@ -749,6 +752,9 @@ class DispatchSubmission:
isauto=1, isdeleted=0, ).first()) isauto=1, isdeleted=0, ).first())
if item is None: if item is None:
raise Exception("调度计划表与实时监控不匹配") raise Exception("调度计划表与实时监控不匹配")
self.logger.info("dispatch-to-redis")
self.logger.into(item.id, item.truck_id, item.exactor_id, item.dump_id)
except Exception as es: except Exception as es:
self.logger.error(es) self.logger.error(es)
item = ( item = (
...@@ -783,12 +789,12 @@ class DispatchSubmission: ...@@ -783,12 +789,12 @@ class DispatchSubmission:
if item is None: if item is None:
raise Exception("调度计划表与实时监控不匹配") raise Exception("调度计划表与实时监控不匹配")
self.logger.info(dispatch_seq) # self.logger.info(dispatch_seq)
self.logger.info(dispatch_seq[1]) # self.logger.info(dispatch_seq[1])
self.logger.info(DeviceMap.excavator_index_to_uuid_dict[dispatch_seq[1]]) # self.logger.info(DeviceMap.excavator_index_to_uuid_dict[dispatch_seq[1]])
self.logger.info("item") self.logger.info("item")
print(item.id, item.truck_id, item.exactor_id, item.dump_id) self.logger.into(item.id, item.truck_id, item.exactor_id, item.dump_id)
except Exception as es: except Exception as es:
self.logger.error(es) self.logger.error(es)
item = ( item = (
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment