From ab44e5afc1c86d847bce017b8b3ab431c8ed1732 Mon Sep 17 00:00:00 2001
From: jianjun <jianjun4833@163.com>
Date: Mon, 25 Apr 2022 11:02:09 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BF=94=E5=9B=9E=E6=9B=B4=E5=A4=9A=E5=B1=9E?=
 =?UTF-8?q?=E6=80=A7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dto/result/IcCustomExportResultDTO.java   |   3 +
 .../IcExportTemplateForExportResultDTO.java   |   5 +-
 .../impl/IcExportTemplateServiceImpl.java     |   4 +-
 .../resources/mapper/IcExportTemplateDao.xml  |  12 +-
 .../main/resources/mapper/IcFormItemDao.xml   |   4 +-
 .../impl/IcResiUserExportServiceImpl.java     | 117 ++++++++++++++----
 .../service/impl/IcResiUserServiceImpl.java   |   7 --
 7 files changed, 108 insertions(+), 44 deletions(-)

diff --git a/epmet-module/oper-customize/oper-customize-client/src/main/java/com/epmet/dto/result/IcCustomExportResultDTO.java b/epmet-module/oper-customize/oper-customize-client/src/main/java/com/epmet/dto/result/IcCustomExportResultDTO.java
index d3ff2b2e22..3b5ad1cdf2 100644
--- a/epmet-module/oper-customize/oper-customize-client/src/main/java/com/epmet/dto/result/IcCustomExportResultDTO.java
+++ b/epmet-module/oper-customize/oper-customize-client/src/main/java/com/epmet/dto/result/IcCustomExportResultDTO.java
@@ -40,8 +40,11 @@ public class IcCustomExportResultDTO implements Serializable {
     @AllArgsConstructor
     @Data
     public static class SqlColumn {
+        private String itemId;
         private String tableName;
         private String columnName;
+        private String optionSourceType;
+        private String optionSourceValue;
     }
 
 }
diff --git a/epmet-module/oper-customize/oper-customize-client/src/main/java/com/epmet/dto/result/IcExportTemplateForExportResultDTO.java b/epmet-module/oper-customize/oper-customize-client/src/main/java/com/epmet/dto/result/IcExportTemplateForExportResultDTO.java
index d58189084b..fc88788ac3 100644
--- a/epmet-module/oper-customize/oper-customize-client/src/main/java/com/epmet/dto/result/IcExportTemplateForExportResultDTO.java
+++ b/epmet-module/oper-customize/oper-customize-client/src/main/java/com/epmet/dto/result/IcExportTemplateForExportResultDTO.java
@@ -60,9 +60,8 @@ public class IcExportTemplateForExportResultDTO implements Serializable {
      * 列名
      */
     private String columnName;
-    /**
-     * 只有远程获取的才有值
-     */
+
     private String optionSourceValue;
+    private String optionSourceType;
 
 }
diff --git a/epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/service/impl/IcExportTemplateServiceImpl.java b/epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/service/impl/IcExportTemplateServiceImpl.java
index 3b33dcba79..8cd200b59e 100644
--- a/epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/service/impl/IcExportTemplateServiceImpl.java
+++ b/epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/service/impl/IcExportTemplateServiceImpl.java
@@ -117,7 +117,7 @@ public class IcExportTemplateServiceImpl extends BaseServiceImpl<IcExportTemplat
                     log.error("getTemplateConfigForExport item 不存在 id:{}", itemId);
                     return;
                 }
-                hiddenSqlColumns.add(new IcCustomExportResultDTO.SqlColumn(item.getTableName(), item.getColumnName()));
+                hiddenSqlColumns.add(new IcCustomExportResultDTO.SqlColumn(item.getItemId(),item.getTableName(), item.getColumnName(),item.getOptionSourceType(),item.getOptionSourceValue()));
             });
         }
 
@@ -130,7 +130,7 @@ public class IcExportTemplateServiceImpl extends BaseServiceImpl<IcExportTemplat
 
     private void digui(Map<String, List<IcExportTemplateForExportResultDTO>> resultTemp, IcExportTemplateForExportResultDTO root, List<List<String>> headerList, List<IcCustomExportResultDTO.SqlColumn> showSqlColumns, List<IcCustomExportResultDTO.SqlColumn> hiddenSqlColumns, Set<String> hasExistColumnSet) {
         if (StringUtils.isNotBlank(root.getColumnName())) {
-            showSqlColumns.add(new IcCustomExportResultDTO.SqlColumn(root.getTableName(), root.getColumnName()));
+            showSqlColumns.add(new IcCustomExportResultDTO.SqlColumn(root.getItemId(),root.getTableName(), root.getColumnName(),root.getOptionSourceType(),root.getOptionSourceValue()));
             if (StringUtils.isNotBlank(root.getOptionSourceValue())) {
                 String[] paramArr = root.getOptionSourceValue().split(StrConstant.QUESTION_MARK_TRANSFER)[NumConstant.ONE].split(StrConstant.AND_MARK);
                 //先remote中再添加 然后移除item中有的
diff --git a/epmet-module/oper-customize/oper-customize-server/src/main/resources/mapper/IcExportTemplateDao.xml b/epmet-module/oper-customize/oper-customize-server/src/main/resources/mapper/IcExportTemplateDao.xml
index 2b1c6c0b1c..d2970a6d02 100644
--- a/epmet-module/oper-customize/oper-customize-server/src/main/resources/mapper/IcExportTemplateDao.xml
+++ b/epmet-module/oper-customize/oper-customize-server/src/main/resources/mapper/IcExportTemplateDao.xml
@@ -20,17 +20,11 @@
     </resultMap>
     <select id="getTemplateConfigForExport" resultType="com.epmet.dto.result.IcExportTemplateForExportResultDTO">
         SELECT
-            c.ID,c.TEMP_ID,
-            c.LABEL,
-            c.PID,
-            c.sort,
-            ifi.ID AS itemId,
-            ifig.TABLE_NAME,
-            concat(ifi.COLUMN_NAME,if(ifi.COLUMN_NUM = 0,'',ifi.COLUMN_NUM)) columnName,
-            ifi2.OPTION_SOURCE_VALUE
+            c.ID,c.TEMP_ID,c.LABEL,c.PID,c.sort,ifi.ID AS itemId,ifig.TABLE_NAME,concat(ifi.COLUMN_NAME,if(ifi.COLUMN_NUM = 0,'',ifi.COLUMN_NUM)) columnName,
+            ifi.OPTION_SOURCE_VALUE,ifi.OPTION_SOURCE_TYPE
         FROM ic_export_template_config c
         LEFT JOIN ic_form_item ifi ON c.FORM_ITEM_ID = ifi.ID
-        LEFT JOIN ic_form_item ifi2 ON c.FORM_ITEM_ID = ifi2.ID AND ifi2.OPTION_SOURCE_TYPE ='remote' AND ifi2.OPTION_SOURCE_VALUE LIKE '%?%'
+        # LEFT JOIN ic_form_item ifi2 ON c.FORM_ITEM_ID = ifi2.ID AND ifi2.OPTION_SOURCE_TYPE ='remote' AND ifi2.OPTION_SOURCE_VALUE LIKE '%?%'
         LEFT JOIN ic_form_item_group ifig ON ifi.ITEM_GROUP_ID = ifig.ID
         WHERE TEMP_ID = #{tempId} and c.CUSTOMER_ID = #{customerId} and c.DEL_FLAG = '0'
         ORDER BY c.PID,c.SORT
diff --git a/epmet-module/oper-customize/oper-customize-server/src/main/resources/mapper/IcFormItemDao.xml b/epmet-module/oper-customize/oper-customize-server/src/main/resources/mapper/IcFormItemDao.xml
index 30631d86b3..e98c46f61f 100644
--- a/epmet-module/oper-customize/oper-customize-server/src/main/resources/mapper/IcFormItemDao.xml
+++ b/epmet-module/oper-customize/oper-customize-server/src/main/resources/mapper/IcFormItemDao.xml
@@ -243,7 +243,9 @@
          SELECT
             ifi.ID AS itemId,
             ifig.TABLE_NAME,
-            CONCAT(ifi.COLUMN_NAME, if(ifi.COLUMN_NUM = 0, '', ifi.COLUMN_NUM)) columnName
+            CONCAT(ifi.COLUMN_NAME, if(ifi.COLUMN_NUM = 0, '', ifi.COLUMN_NUM)) columnName,
+            ifi.OPTION_SOURCE_TYPE,
+            ifi.OPTION_SOURCE_VALUE
          FROM
             ic_form_item ifi
             LEFT JOIN ic_form_item_group ifig ON ifi.ITEM_GROUP_ID = ifig.ID
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserExportServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserExportServiceImpl.java
index 2e0383ccd4..8df9a74770 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserExportServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserExportServiceImpl.java
@@ -3,6 +3,7 @@ package com.epmet.service.impl;
 import com.alibaba.excel.EasyExcel;
 import com.alibaba.excel.ExcelWriter;
 import com.alibaba.excel.write.metadata.WriteSheet;
+import com.alibaba.fastjson.JSON;
 import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.constant.StrConstant;
 import com.epmet.commons.tools.dto.result.CustomerStaffInfoCacheResult;
@@ -20,6 +21,7 @@ import com.epmet.service.IcResiUserExportService;
 import com.epmet.service.IcResiUserService;
 import com.github.pagehelper.Page;
 import com.github.pagehelper.PageHelper;
+import com.google.common.cache.Cache;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -28,8 +30,10 @@ import org.springframework.stereotype.Service;
 import javax.servlet.http.HttpServletResponse;
 import java.io.IOException;
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * desc:
@@ -64,17 +68,17 @@ public class IcResiUserExportServiceImpl implements IcResiUserExportService {
             //获取模板条件
             IcExportTemplateQueryFormDTO param = new IcExportTemplateQueryFormDTO();
             param.setCustomerId(loginUserUtil.getLoginUserCustomerId());
-            param.setCustomerId("default");
             param.setTempId(pageFormDTO.getTemplateId());
             Result<IcCustomExportResultDTO> exportConfigResult = operCustomizeOpenFeignClient.getExcelHeaderAndSqlColumnForExport(param);
             if (!exportConfigResult.success() || exportConfigResult.getData() == null) {
                 log.error("获取模板失败");
                 return;
             }
-            IcCustomExportResultDTO resultDTO = exportConfigResult.getData();
+            IcCustomExportResultDTO exportConfigData = exportConfigResult.getData();
+            log.info("查询到的模板配置信息:{}", JSON.toJSONString(exportConfigData));
             FreezeAndFilter writeHandler = new FreezeAndFilter();
             excelWriter = EasyExcel.write(ExcelUtils.getOutputStreamForExcel("居民基本信息.xlsx", response)).registerWriteHandler(writeHandler).build();
-            WriteSheet writeSheet = EasyExcel.writerSheet().head(resultDTO.getHeaders()).build();
+            WriteSheet writeSheet = EasyExcel.writerSheet().head(exportConfigData.getHeaders()).build();
 
             CustomerStaffInfoCacheResult staffInfoCacheResult = CustomerStaffRedis.getStaffInfo(loginUserUtil.getLoginUserCustomerId(), loginUserUtil.getLoginUserId());
             String staffOrgPath = null;
@@ -84,8 +88,8 @@ public class IcResiUserExportServiceImpl implements IcResiUserExportService {
                 staffOrgPath = staffInfoCacheResult.getAgencyId();
             }
             Page<Map<String, Object>> mapListPage = null;
-            List<IcCustomExportResultDTO.SqlColumn> allShowColumns = new ArrayList<>(resultDTO.getShowSqlColumns());
-            allShowColumns.addAll(resultDTO.getHiddenSqlColumns());
+            List<IcCustomExportResultDTO.SqlColumn> allShowColumns = new ArrayList<>(exportConfigData.getShowSqlColumns());
+            allShowColumns.addAll(exportConfigData.getHiddenSqlColumns());
             do {
                 String finalStaffOrgPath = staffOrgPath;
                 mapListPage = PageHelper.startPage(pageFormDTO.getPageNo(), pageFormDTO.getPageSize(), pageFormDTO.getIsPage()).doSelectPage(() -> {
@@ -93,25 +97,31 @@ public class IcResiUserExportServiceImpl implements IcResiUserExportService {
                 });
                 pageFormDTO.setPageNo(pageFormDTO.getPageNo() + NumConstant.ONE);
 
-                //todo
-                if (pageFormDTO.getPageNo() == 4) {
-                    break;
-                }
-            } while (mapListPage != null && mapListPage.getResult().size() == pageFormDTO.getPageSize());
-            List<Map<String, Object>> result = mapListPage.getResult();
+                List<Map<String, Object>> result = mapListPage.getResult();
 
-            List<List<Object>> resultData = new ArrayList<>();
-            result.forEach(o -> {
-                List<Object> singleResult = new ArrayList<>();
-                o.values().forEach(value -> {
-                    if (singleResult.size() < resultDTO.getShowSqlColumns().size()) {
-                        singleResult.add(value);
-                    }
+                List<List<Object>> resultData = new ArrayList<>();
+                result.forEach(o -> {
+                    List<Object> singleResult = new ArrayList<>();
+                    o.forEach((key,value) -> {
+                        List<IcCustomExportResultDTO.SqlColumn> showSqlColumns = exportConfigData.getShowSqlColumns();
+                        Map<String, IcCustomExportResultDTO.SqlColumn> itemMap = showSqlColumns.stream().collect(Collectors.toMap(IcCustomExportResultDTO.SqlColumn::getColumnName, item -> item));
+                        if (singleResult.size() < showSqlColumns.size()) {
+                            singleResult.add(value);
+
+                            IcCustomExportResultDTO.SqlColumn sqlColumn = itemMap.get(key);
+                            String vauleStr = value == null ? StrConstant.EPMETY_STR : value.toString();
+                           /* if (Constant.OPITON_SOURCE_REMOTE.equals(sqlColumn.getOptionSourceType()) && StringUtils.isNotBlank(vauleStr)) {
+                                putRemoteValue(formItemMap.getRemoteItemConditionMap().get(e.getItemId()), currentStaffAgencyId, resiUser,originalConditionMap, e, columnName, vauleStr);
+                            } else {
+                                putOptionValue(resiUser, e, columnName, vauleStr);
+                            }*/
+                        }
+                    });
+                    resultData.add(singleResult);
                 });
-                resultData.add(singleResult);
-            });
-            log.debug("需要写入的data长度:{}", resultData.size());
-            excelWriter.write(resultData, writeSheet);
+                log.info("需要写入的data长度:{}", resultData.size());
+                excelWriter.write(resultData, writeSheet);
+            } while (mapListPage.getResult().size() == pageFormDTO.getPageSize());
         } catch (IOException e) {
             log.error("exportIcResiUser exception", e);
         } finally {
@@ -119,7 +129,70 @@ public class IcResiUserExportServiceImpl implements IcResiUserExportService {
                 excelWriter.finish();
             }
         }
+    }
+
+
 
+    /**
+     * key:itemId,value: key:columnName,中文
+     */
+    private static Map<String, Cache<String,String>> remoteOptionCacheMap = new HashMap<>();
+    /*private void putRemoteValue(Set<FormItemResult> conditionItemSet, String currentStaffAgencyId, Map<String, Object> map, Map<String, Object> originalConditionMap, FormItemResult e, String columnName, String vauleStr) {
+        try {
+            Map<String, IcResiUserImportServiceImpl.ColumnWrapper> columnWrappers = new HashMap<>();
+            if (e.getOptionSourceValue().contains(StrConstant.QUESTION_MARK)){
+                for (FormItemResult o : conditionItemSet) {
+                    String column = getColumnName(o);
+                    Object conditionValue = originalConditionMap.getOrDefault(column, map.get(column));
+                    originalConditionMap.putIfAbsent(column,conditionValue.toString());
+                    IcResiUserImportServiceImpl.ColumnWrapper value = new IcResiUserImportServiceImpl.ColumnWrapper();
+                    value.setColValue(conditionValue.toString());
+                    columnWrappers.put(o.getItemId(), value);
+                }
+            }
+            Cache<String, String> cache = remoteOptionCacheMap.getOrDefault(e.getItemId(), CacheBuilder.newBuilder().maximumSize(NumConstant.FIVE_HUNDRED).build());
+            remoteOptionCacheMap.putIfAbsent(e.getItemId(),cache);
+            String cacheValue = cache.getIfPresent(vauleStr);
+            if (StringUtils.isNotBlank(cacheValue)){
+                map.put(columnName,cacheValue);
+            } else {
+                String[] parts = icResiUserImportService.splitOptionSourceUrl(e.getOptionSourceValue());
+
+                Map<String, String> remoteOptions = icResiUserImportService.listRemoteOptions(parts[0], parts[1], columnWrappers, currentStaffAgencyId, "query");
+                if (FormItemTypeEnum.CHECKBOX.getCode().equals(e.getItemType())) {
+                    remoteOptions.forEach((label, value) -> map.put(value, vauleStr.contains(value) ? StrConstant.YES : StrConstant.NO));
+                } else if (FormItemTypeEnum.SELECT.getCode().equals(e.getItemType())) {
+                    remoteOptions.forEach((label, value) -> {
+                        if (vauleStr.equals(value)) {
+                            map.put(columnName, label);
+                        }
+                        cache.put(value,label);
+                    });
+                }
+            }
+        } catch (Exception ex) {
+            log.error("listRemoteOptions url:{}", e.getOptionSourceValue());
+        }
     }
 
+    private void putOptionValue(Map<String, Object> map, FormItemResult e, String columnName, String vauleStr) {
+        FormItemTypeEnum itemTypeEnum = FormItemTypeEnum.getEnum(e.getItemType());
+        switch (itemTypeEnum) {
+            case CHECKBOX:
+                e.getOptions().forEach(optionDTO -> {
+                    map.put(optionDTO.getValue(), vauleStr.contains(optionDTO.getValue()) ? StrConstant.YES : StrConstant.NO);
+                });
+                break;
+            case SELECT:
+            case RADIO:
+                e.getOptions().forEach(optionDTO -> {
+                    if (optionDTO.getValue().equals(vauleStr)) {
+                        map.put(columnName, optionDTO.getLabel());
+                    }
+                });
+                break;
+            default:
+        }
+    }*/
+
 }
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java
index 7aa2b83751..09d43b4949 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java
@@ -999,13 +999,6 @@ public class IcResiUserServiceImpl extends BaseServiceImpl<IcResiUserDao, IcResi
                     columnWrappers.put(o.getItemId(), value);
                 }
             }
-            /*if (e.getItemId().equals("1078")) {
-                IcResiUserImportServiceImpl.ColumnWrapper value = new IcResiUserImportServiceImpl.ColumnWrapper();
-                value.setColValue(gridId.toString());
-                columnWrappers.put("1001", value);
-            }else if (e.getOptionSourceValue().contains(StrConstant.QUESTION_MARK)){
-                continue;
-            }*/
             Cache<String, String> cache = remoteOptionCacheMap.getOrDefault(e.getItemId(), CacheBuilder.newBuilder().maximumSize(NumConstant.FIVE_HUNDRED).build());
             remoteOptionCacheMap.putIfAbsent(e.getItemId(),cache);
             String cacheValue = cache.getIfPresent(vauleStr);