1

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

@@ -42,10 +42,7 @@ import java.io.IOException;
 import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.concurrent.CopyOnWriteArrayList;
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.ThreadPoolExecutor;
-import java.util.concurrent.TimeUnit;
+import java.util.concurrent.*;
 import java.util.stream.Collectors;
 
 /**
@@ -59,7 +56,7 @@ public class AirportConsumerServiceImpl implements AirportConsumerService {
 
     private ThreadPoolExecutor executor = new ThreadPoolExecutor(10, 20, 10L,
             TimeUnit.SECONDS,
-            new java.util.concurrent.ArrayBlockingQueue<>(20),
+            new ArrayBlockingQueue<>(20),
             new ThreadFactoryBuilder().setNameFormat("pdf-paper-%d").build(),
             new ThreadPoolExecutor.DiscardPolicy());
 
@@ -155,15 +152,13 @@ public class AirportConsumerServiceImpl implements AirportConsumerService {
     @Override
     @Consumer(topic = AirportTopic.AIRPORT_PDF_PAPER_TOPIC)
     public void pdfPaper(AirportPDFPaperMessage message) throws Exception {
-        BizAiDataAuditTaskEntity bizAiDataAuditTaskEntity;
+        BizAiDataAuditTaskEntity bizAiDataAuditTaskEntity = null;
         try {
             List<AuditResultDto> results = new CopyOnWriteArrayList<>();
-
             Long taskId = message.getTaskId();
 
             //根据任务id查找任务
             bizAiDataAuditTaskEntity = bizAiDataAuditTaskService.getWithToken(taskId);
-
             if (bizAiDataAuditTaskEntity == null) {
                 throw new BusinessException("任务不存在");
             }
@@ -177,18 +172,11 @@ public class AirportConsumerServiceImpl implements AirportConsumerService {
                 throw new BusinessException("找不到该任务下的文件");
             }
 
-            Map<String, List<BizAiDataAuditFileEntity>> groupedByTemplateCode = bizAiDataAuditFileEntities.stream()
-                    .collect(Collectors.groupingBy(BizAiDataAuditFileEntity::getOrginalTemplateCode));
-
-
             //获取所有的规则
             AiDataAuditRuleQueryCondition aiDataAuditRuleQueryCondition = new AiDataAuditRuleQueryCondition();
             List<AiDataAuditRuleQueryItem> aiDataAuditRuleQueryItems = bizAiDataAuditRuleService.aiDataAuditRuleQueryItemList(aiDataAuditRuleQueryCondition, null);
-
-
             CountDownLatch countDownLatch = new CountDownLatch(aiDataAuditRuleQueryItems.size());
 
-            //
             for (AiDataAuditRuleQueryItem aiDataAuditRuleQueryItem : aiDataAuditRuleQueryItems) {
                 String ruleType = aiDataAuditRuleQueryItem.getDataAuditRuleType();
                 if (ruleType.equals("c2c")) {
@@ -209,8 +197,10 @@ public class AirportConsumerServiceImpl implements AirportConsumerService {
             bizAiDataAuditTaskService.update(bizAiDataAuditTaskEntity);
         } catch (Exception e) {
             redisService.set("ERROR_MSG_AI_DATA_AUDIT_TASK:" + message.getTaskId(), e.getMessage(), 60 * 60 * 24 * 7);
-            bizAiDataAuditTaskEntity.setStatus("fail");
-            bizAiDataAuditTaskService.update(bizAiDataAuditTaskEntity);
+            if (bizAiDataAuditTaskEntity != null) {
+                bizAiDataAuditTaskEntity.setStatus("fail");
+                bizAiDataAuditTaskService.update(bizAiDataAuditTaskEntity);
+            }
         }
     }
 

src/test/java/cn/com/poc/utils/FileUtilsTest.java

@@ -63,7 +63,7 @@ public class FileUtilsTest {
 
     @Test
     public void test_pdf() {
-        File file = new File("C:\\Users\\52747\\Desktop\\港口基础设施维护管理信息系统建设规范JTST3302025.pdf");
+        File file = new File("D:\\项目\\【W-001】万讯\\【001】香港机场\\Sample Data_2025-10-17\\Sample Document\\WP Data\\WP057940\\1. Work Method Statement - 1.BCJV-3408-Z-00685C Method Statement for Installation of VDC Works(A.pdf");
         String pdfResult = DocumentLoad.documentToText(file);
         System.out.println(pdfResult);
     }