统一抽取 添加小组数据

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/impl/FactOriginExtractServiceImpl.java

@@ -4,10 +4,7 @@ import com.alibaba.fastjson.JSON;
 import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.utils.DateUtils;
 import com.epmet.dto.extract.form.ExtractFormDTO;
-import com.epmet.service.evaluationindex.extract.FactOriginExtractService;
-import com.epmet.service.evaluationindex.extract.FactOriginTopicMainDailyService;
-import com.epmet.service.evaluationindex.extract.IssueExtractService;
-import com.epmet.service.evaluationindex.extract.ProjectExtractService;
+import com.epmet.service.evaluationindex.extract.*;
 import com.epmet.service.stats.DimCustomerService;
 import com.epmet.util.DimIdGenerator;
 import com.google.common.util.concurrent.ThreadFactoryBuilder;
@@ -42,6 +39,8 @@ public class FactOriginExtractServiceImpl implements FactOriginExtractService {
     private ProjectExtractService projectExtractService;
     @Autowired
     private DimCustomerService dimCustomerService;
+    @Autowired
+    private GroupExtractService groupExtractService;
 
 
     @Override
@@ -74,6 +73,13 @@ public class FactOriginExtractServiceImpl implements FactOriginExtractService {
     }
 
     private void submitJob(ExtractFormDTO param) {
+        threadPool.submit(() -> {
+            try {
+                groupExtractService.extractGroupData(param);
+            } catch (Exception e) {
+                log.error("抽取【小组数据】发生异常,参数:" + JSON.toJSONString(param), e);
+            }
+        });
         threadPool.submit(() -> {
             try {
                 factOriginTopicMainDailyService.topicCleaning(param);