fix

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

@@ -83,7 +83,7 @@ public class AirportConsumerServiceImpl implements AirportConsumerService {
 
     @Override
     @Consumer(topic = AirportTopic.AIRPORT_CREATE_TOPIC)
-    public void  createTask(AirportTaskCreateMessage message) throws Exception {
+    public void createTask(AirportTaskCreateMessage message) throws Exception {
         // 配置Redis AI_DATA_AUDIT_TASK , 表示消息队列已经获取到任务 [用于定时任务(AiDataAuditScheduler)判断该任务下的 OCR任务是否已经全部完成]
         redisService.set("AI_DATA_AUDIT_TASK:" + message.getTaskId(), "Get");
 
@@ -203,7 +203,9 @@ public class AirportConsumerServiceImpl implements AirportConsumerService {
             bizAiDataAuditTaskEntity.setStatus("end");
             bizAiDataAuditTaskService.update(bizAiDataAuditTaskEntity);
         } catch (Exception e) {
-            throw new BusinessException(e.getMessage());
+            redisService.set("ERROR_MSG_AI_DATA_AUDIT_TASK:" + message.getTaskId(), e.getMessage(), 60 * 60 * 24 * 7);
+            bizAiDataAuditTaskEntity.setStatus("fail");
+            bizAiDataAuditTaskService.update(bizAiDataAuditTaskEntity);
         }
     }