feat:提交任务

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");
 

src/main/java/cn/com/poc/ocr/scheduler/OCRScheduler.java

@@ -3,6 +3,7 @@ package cn.com.poc.ocr.scheduler;
 import cn.com.poc.common.constant.CommonConstant;
 import cn.com.poc.common.utils.StringUtils;
 import cn.com.poc.message.entity.OCRMessage;
+import cn.com.poc.message.entity.OCRStatusMessage;
 import cn.com.poc.message.service.OCRProducerService;
 import cn.com.poc.ocr.entity.BizFileOcrCacheEntity;
 import cn.com.poc.ocr.service.BizFileOcrCacheService;
@@ -41,8 +42,11 @@ public class OCRScheduler {
 
                 if (fileOcrCacheEntity.getParseStatus().equals("create")) {
                     if (StringUtils.isBlank(fileOcrCacheEntity.getMdFileUrl())) {
-                        fileOcrCacheEntity.setParseStatus("queuing");
-                        bizFileOcrCacheService.update(fileOcrCacheEntity);
+
+                        OCRStatusMessage ocrStatusMessage = new OCRStatusMessage();
+                        ocrStatusMessage.setId(fileOcrCacheEntity.getId());
+                        ocrStatusMessage.setStatus("queuing");
+                        ocrProducerService.updateStatus(ocrStatusMessage);
 
                         OCRMessage message = new OCRMessage();
                         message.setId(fileOcrCacheEntity.getId());
@@ -52,7 +56,6 @@ public class OCRScheduler {
                     } else {
                         fileOcrCacheEntity.setParseStatus("complete");
                         bizFileOcrCacheService.update(fileOcrCacheEntity);
-
                     }
                 }