Просмотр исходного кода

修改附件重跑的逻辑,如果是失败或者初始状态,即使有处理时间也会重新处理

luojiehua 1 год назад
Родитель
Сommit
10f2d5fb2c
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 and _attach.getProperties().get(attachment_status)!=ATTACHMENT_INIT:
+                    if len(str(_attach.getProperties().get(attachment_process_time,"")))>10 and _attach.getProperties().get(attachment_status)!=ATTACHMENT_INIT and not (_attach.getProperties().get(attachment_status)>=ATTACHMENT_MC_FAILED_FROM and _attach.getProperties().get(attachment_status)<=ATTACHMENT_MC_FAILED_TO):
                         log("%s has process_time jump"%(_filemd5))
                         _html = _attach.getProperties().get(attachment_attachmenthtml,"")
                         if _html is None: