From 7791c3285c6e44e0376a8029c67c7a4778f0e344 Mon Sep 17 00:00:00 2001
From: wangxianzhang <ZHANGYUGE6666>
Date: Fri, 4 Mar 2022 23:20:38 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E8=AF=95=EF=BC=9A=E5=B1=85=E6=B0=91?=
 =?UTF-8?q?=E5=AF=BC=E5=85=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/epmet/controller/IcResiUserController.java   |  6 +++++-
 .../service/impl/IcResiUserImportServiceImpl.java    | 12 ++++++++++--
 2 files changed, 15 insertions(+), 3 deletions(-)

diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java
index b7f737098f..9fd05b7f72 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java
@@ -88,6 +88,7 @@ import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.util.*;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutorService;
 import java.util.stream.Collectors;
 
 
@@ -130,6 +131,8 @@ public class IcResiUserController implements ResultDataResolver {
     private EpmetMessageOpenFeignClient epmetMessageOpenFeignClient;
     @Autowired
     private LoginUserUtil loginUserUtil;
+    @Autowired
+    private ExecutorService executorService;
 
     /**
      * 模板枚举
@@ -466,7 +469,8 @@ public class IcResiUserController implements ResultDataResolver {
         HashMap<String, String> headers = getHeadersFromRequest(request);
 
         // 三.异步执行导入
-        CompletableFuture.runAsync(() -> {
+
+        executorService.execute(() -> {
 
             try {
                 // 睡眠2秒钟，等待主线程先结束，主线程会清空request对象的headers，等他执行了清空之后，我们这边再手动setHeader进去
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserImportServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserImportServiceImpl.java
index 56b049bf3b..c88815c47b 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserImportServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserImportServiceImpl.java
@@ -220,8 +220,9 @@ public class IcResiUserImportServiceImpl implements IcResiUserImportService, Res
         String loginUserId = loginUserUtil.getLoginUserId();
         String loginUserApp = loginUserUtil.getLoginUserApp();
         String loginUserClient = loginUserUtil.getLoginUserClient();
+        String loginUserCustomerId = loginUserUtil.getLoginUserCustomerId();
 
-        log.info("userId:{}, app:{}, client:{}", loginUserId, loginUserApp, loginUserClient);
+        log.info("userId:{}, app:{}, client:{}, customerId:{}", loginUserId, loginUserApp, loginUserClient, loginUserCustomerId);
 
         //        LoginUserDetailsFormDTO userForm = new LoginUserDetailsFormDTO();
 //        userForm.setApp(loginUserApp);
@@ -420,6 +421,13 @@ public class IcResiUserImportServiceImpl implements IcResiUserImportService, Res
                                        String currUserAgencyId, Map<Integer, String> checkBoxOptionColumnIdxAndLabel,
                                        String currUserAgencyPids, String currentUserId, String tableName) {
 
+        String loginUserId = loginUserUtil.getLoginUserId();
+        String loginUserApp = loginUserUtil.getLoginUserApp();
+        String loginUserClient = loginUserUtil.getLoginUserClient();
+        String loginUserCustomerId = loginUserUtil.getLoginUserCustomerId();
+
+        log.info("persistIcResiBaseInfo:: userId:{}, app:{}, client:{}, customerId:{}", loginUserId, loginUserApp, loginUserClient, loginUserCustomerId);
+
         // 遍历每一行，将行内容转化为
         for (Map<Integer, String> row : dataRows) {
 
@@ -475,7 +483,7 @@ public class IcResiUserImportServiceImpl implements IcResiUserImportService, Res
 
                 columnAndValues.put("AGENCY_ID", currUserAgencyId);
                 columnAndValues.put("PIDS", currUserAgencyPids);
-                columnAndValues.put("CUSTOMER_ID", loginUserUtil.getLoginUserCustomerId());
+                columnAndValues.put("CUSTOMER_ID", loginUserCustomerId);
 
                 columnAndValues.put("UPDATED_BY", currentUserId);