Преглед на файлове

增加漏数据及修复数据;附件处理时如果历史已经处理过,则跳过

luojiehua преди 2 години
родител
ревизия
01063f6632
променени са 1 файла, в които са добавени 4 реда и са изтрити 4 реда
  1. 4 4
      BaseDataMaintenance/maintenance/dataflow.py

+ 4 - 4
BaseDataMaintenance/maintenance/dataflow.py

@@ -1790,17 +1790,17 @@ class Dataflow_attachment(Dataflow):
             _flag = False
             try:
                 item = self.queue_attachment_ocr.get(True,timeout=0.2)
-                log("attachment get doc:%s"%(str(item.get("docid"))))
+                log("attachment get doc:%s"%(str(item.get("item",{}).get("docid"))))
                 self.attachment_recognize(item,None)
-                log("attachment get doc:%s succeed"%(str(item.get("docid"))))
+                log("attachment get doc:%s succeed"%(str(item.get("item",{}).get("docid"))))
             except Exception as e:
                 _flag = True
                 pass
             try:
                 item = self.queue_attachment_not_ocr.get(True,timeout=0.2)
-                log("attachment get doc:%s"%(str(item.get("docid"))))
+                log("attachment get doc:%s"%(str(item.get("item",{}).get("docid"))))
                 self.attachment_recognize(item,None)
-                log("attachment get doc:%s succeed"%(str(item.get("docid"))))
+                log("attachment get doc:%s succeed"%(str(item.get("item",{}).get("docid"))))
             except Exception as e:
                 _flag = True and _flag
                 pass