From 6e80fe73665901ae2356b170070d3f563fd5703a Mon Sep 17 00:00:00 2001
From: jianjun <liujianjun@git.elinkit.com.cn>
Date: Thu, 15 Oct 2020 17:59:07 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=97=A5=E5=BF=97=E6=8E=92?=
 =?UTF-8?q?=E9=99=A4=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../extract/todata/impl/FactOriginExtractServiceImpl.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/todata/impl/FactOriginExtractServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/todata/impl/FactOriginExtractServiceImpl.java
index f8bfe1826c..9413b13209 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/todata/impl/FactOriginExtractServiceImpl.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/todata/impl/FactOriginExtractServiceImpl.java
@@ -27,7 +27,7 @@ import java.util.concurrent.*;
 public class FactOriginExtractServiceImpl implements FactOriginExtractService {
     ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
             .setNameFormat("factOriginExtract-pool-%d").build();
-    ExecutorService threadPool = new ThreadPoolExecutor(1, 1,
+    ExecutorService threadPool = new ThreadPoolExecutor(3, 6,
             10L, TimeUnit.MINUTES,
             new LinkedBlockingQueue<>(500), namedThreadFactory, new ThreadPoolExecutor.CallerRunsPolicy());
 
@@ -98,6 +98,7 @@ public class FactOriginExtractServiceImpl implements FactOriginExtractService {
             }
         });
         threadPool.submit(() -> {
+            log.info("extractAll start param:{}", JSON.toJSONString(param));
             if(StringUtils.isNotBlank(param.getDateId())){
                 try {
                     factOriginTopicMainDailyService.topicCleaning(param);
@@ -110,12 +111,14 @@ public class FactOriginExtractServiceImpl implements FactOriginExtractService {
                     for (int i = 0; i < daysBetween.size(); i++) {
                         String dateDimId = daysBetween.get(i);
                         param.setDateId(dateDimId);
+                        log.info("extractAll cal param:{}", JSON.toJSONString(param));
                         factOriginTopicMainDailyService.topicCleaning(param);
                     }
                 } catch (Exception e) {
                     log.error("抽取【话题数据】发生异常,参数:" + JSON.toJSONString(param), e);
                 }
             }
+            log.info("extractAll end param:{}", JSON.toJSONString(param));
         });
         threadPool.submit(() -> {
             if(StringUtils.isNotBlank(param.getDateId())){