修改状态

long-article-server/src/main/java/com/tzld/piaoquan/longarticle/common/enums/ContentStatusEnum.java

@@ -1,5 +1,8 @@
 package com.tzld.piaoquan.longarticle.common.enums;
 
+import java.util.ArrayList;
+import java.util.List;
+
 public enum ContentStatusEnum {
 
     DEFAULT(0, "初始状态"),
@@ -33,9 +36,16 @@ public enum ContentStatusEnum {
         return contentStatus == SUCCESS_3.statusCode || contentStatus == SUCCESS_4.statusCode;
     }
 
+    public static List<Integer> list = new ArrayList<Integer>() {{
+        add(DEFAULT.statusCode);
+        add(KIMI_SUCCESS.statusCode);
+        add(CRAWLER_SUCCESS.statusCode);
+        add(SUCCESS_3.statusCode);
+        add(SUCCESS_4.statusCode);
+    }};
+
     public static boolean isFail(int contentStatus) {
-        return contentStatus == ERROR_95.statusCode || contentStatus == ERROR_96.statusCode
-                || contentStatus == ERROR_97.statusCode || contentStatus == ERROR_99.statusCode;
+        return !list.contains(contentStatus);
     }
 
     // 获取错误信息
@@ -45,6 +55,6 @@ public enum ContentStatusEnum {
                 return status.message;
             }
         }
-        return null;
+        return "";
     }
 }

long-article-server/src/main/java/com/tzld/piaoquan/longarticle/service/local/impl/CoreServiceImpl.java

@@ -330,7 +330,7 @@ public class CoreServiceImpl implements CoreService {
     private static final ArrayBlockingQueue<PlanAccount> coreQueue = new ArrayBlockingQueue<>(1000000);
 
 
-    private static final int size = 10;
+    private static final int size = 20;
     // 定义一个线程池，设置消费线程的数量
     private static final ThreadPoolExecutor matchPoolExecutor = (ThreadPoolExecutor) Executors.newFixedThreadPool(size);
 
@@ -351,6 +351,7 @@ public class CoreServiceImpl implements CoreService {
                         try {
                             // 超过 2 分钟没有数据，销毁当前线程
                             MatchContent matchContent = matchQueue.poll(2, TimeUnit.MINUTES); // 等待最多 2 分钟
+                            log.info("matchContent size={}", matchQueue.size());
                             if (matchContent == null) {
                                 break; // 退出当前线程
                             }