소스 검색

修改附件重跑的逻辑

luojiehua 2 년 전
부모
커밋
929558ff9c
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      BaseDataMaintenance/maintenance/dataflow_mq.py

+ 1 - 1
BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -109,7 +109,7 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
                                       "html":_html})
                 else:
                     #has process_time then jump
-                    if len(str(_attach.getProperties().get(attachment_process_time,"")))>10:
+                    if len(str(_attach.getProperties().get(attachment_process_time,"")))>10 and _attach.getProperties().get(attachment_status)!=ATTACHMENT_INIT:
                         log("%s has process_time jump"%(_filemd5))
                         _html = _attach.getProperties().get(attachment_attachmenthtml,"")
                         if _html is None: