增加并发

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

@@ -156,7 +156,7 @@ public class ContentServiceImpl implements ContentService {
         }
         articleSortRequest.setPlanId(planAccount.getPlanId());
         articleSortRequest.setPushType(planAccount.getPushType());
-
+        log.info("articleSortRequest={}",JSONObject.toJSONString(articleSortRequest));
         ArticleSortResponse articleSortResponse = sortService.publishArticleSort(articleSortRequest);
 
         if (articleSortResponse == null || articleSortResponse.getData() == null) {

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

@@ -182,7 +182,7 @@ public class CoreServiceImpl implements CoreService {
     // 定义一个线程池，设置消费线程的数量
     private static final ThreadPoolExecutor matchPoolExecutor = (ThreadPoolExecutor) Executors.newFixedThreadPool(size);
 
-    private static final int size1 = 10;
+    private static final int size1 = 20;
     private static final ThreadPoolExecutor corePoolExecutor = (ThreadPoolExecutor) Executors.newFixedThreadPool(size1);
 
 
@@ -454,6 +454,10 @@ public class CoreServiceImpl implements CoreService {
     }
 
     private void operatePlanAccount(PlanAccount planAccount) {
+        boolean flag = checkPlanAccount(planAccount);
+        if (!flag) {
+            return;
+        }
         //获取待排序数据  数量不足会返回空list
         List<PublishArticleData> rankList = contentService.getWaitingSort(planAccount);
         if (CollectionUtils.isEmpty(rankList)) {