Jelajahi Sumber

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

luojiehua 2 tahun lalu
induk
melakukan
638041098e
1 mengubah file dengan 3 tambahan dan 1 penghapusan
  1. 3 1
      BaseDataMaintenance/maintenance/dataflow_mq.py

+ 3 - 1
BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -96,6 +96,7 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
 
                 _filemd5 = _attach.getProperties().get(attachment_filemd5)
                 if _attach.getProperties().get(attachment_status) in (ATTACHMENT_PROCESSED,ATTACHMENT_TOOLARGE):
+                    log("%s has processed or toolarge"%(_filemd5))
                     _html = _attach.getProperties().get(attachment_attachmenthtml,"")
                     if _html is None:
                         _html = ""
@@ -105,7 +106,7 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
                 else:
                     #has process_time then jump
                     if len(str(_attach.getProperties().get(attachment_process_time,"")))>10:
-                        log("has process_time jump")
+                        log("%s has process_time jump"%(_filemd5))
                         _html = _attach.getProperties().get(attachment_attachmenthtml,"")
                         if _html is None:
                             _html = ""
@@ -113,6 +114,7 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
                         list_html.append({attachment_filemd5:_filemd5,
                                           "html":_html})
                     else:
+                        log("%s requesting interface"%(_filemd5))
                         _succeed = self.request_attachment_interface(_attach,_dochtmlcon)
                         if not _succeed:
                             _not_failed = False