fix

src/main/java/cn/com/poc/message/service/impl/AirportConsumerServiceImpl.java

@@ -200,6 +200,8 @@ public class AirportConsumerServiceImpl implements AirportConsumerService {
         } catch (Exception e) {
             redisService.set("ERROR_MSG_AI_DATA_AUDIT_TASK:" + message.getTaskId(), e.getMessage(), 60 * 60 * 24 * 7);
             if (bizAiDataAuditTaskEntity != null) {
+                bizAiDataAuditTaskEntity = new BizAiDataAuditTaskEntity();
+                bizAiDataAuditTaskEntity.setDataAuditTaskId(message.getTaskId());
                 bizAiDataAuditTaskEntity.setStatus("fail");
                 bizAiDataAuditTaskService.update(bizAiDataAuditTaskEntity);
             }