销售客户资信批量导出优化

@@ -9,6 +9,7 @@ import com.lframework.starter.bpm.mappers.FlowTaskWrapperMapper;
 import com.lframework.starter.bpm.service.FlowInstanceWrapperService;
 import com.lframework.starter.bpm.vo.flow.task.QueryTodoTaskListVo;
 import com.lframework.starter.common.utils.StringUtil;
+import com.lframework.starter.mq.core.utils.ExportTaskUtil;
 import com.lframework.starter.web.core.annotations.security.HasPermission;
 import com.lframework.starter.web.core.components.redis.RedisHandler;
 import com.lframework.starter.web.core.components.security.SecurityUtil;
@@ -501,133 +502,18 @@ public class CustomerCreditController extends DefaultBaseController {
     }
 
     /**
-     * 按筛选条件批量导出（按导入模板结构）
+     * 按筛选条件批量导出（异步导出，按导入模板结构，核心人员只导出第一个法定代表人）
      */
-    @ApiOperation("按筛选条件批量导出")
-    @HasPermission({"customer-credit-manage:customer-credit-plan:export"})
+    @ApiOperation("按筛选条件批量导出（异步）")
     @GetMapping("/export/list")
-    public void exportByCondition(@Valid QueryCustomerCreditVo vo, HttpServletResponse response) throws IOException {
+    public InvokeResult<Void> exportByCondition(@Valid QueryCustomerCreditVo vo) {
+        //数据查询权限
         applyQueryPermission(vo);
+        vo.setExportType("CUSTOMER_CREDIT");
 
-        List<CustomerCredit> datas = customerCreditService.query(vo);
-        String fileName = "客户资信批量导出.xlsx";
-        response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
-        String encoded = URLEncoder.encode(fileName, StandardCharsets.UTF_8.name()).replace("+", "%20");
-        response.setHeader("Content-Disposition",
-                "attachment; filename=\"" + encoded + "\"; filename*=UTF-8''" + encoded);
-
-        DateTimeFormatter dateFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
-        List<CustomerCreditBatchExportModel> models = new ArrayList<>(datas.size());
-        int idx = 1;
-        for (CustomerCredit credit : datas) {
-            GetCustomerCreditBo bo = packCustomerCreditData(credit);
-            CustomerCreditBatchExportModel m = new CustomerCreditBatchExportModel();
-            m.setSort(String.valueOf(idx++));
-            m.setCode(bo.getSerialNumber());
-            m.setDeptName(bo.getDeptName());
-            m.setRegionName(bo.getRegionName());
-            m.setCustomerShortName(bo.getCustomerShortName());
-            m.setRegisterDateStr(bo.getRegisterDate() == null ? "" : bo.getRegisterDate().format(dateFormatter));
-            m.setName(bo.getCompanyName());
-            m.setEnterpriseType(convertEnterpriseType(bo.getEnterpriseType()));
-            m.setCompanyNature(bo.getCompanyNature());
-            m.setCompanyAddress(bo.getCompanyAddress());
-            m.setRegisteredCapital(bo.getRegisteredCapital());
-            m.setBankAccount(bo.getBankAccount());
-            m.setBankName(bo.getBankName());
-            m.setTaxNumber(bo.getTaxNumber());
-            m.setRegistrationTimeStr(bo.getRegistrationTime() == null ? "" : bo.getRegistrationTime().format(dateFormatter));
-            m.setBusinessYears(bo.getBusinessYears());
-
-            CorePersonnel legal = null;
-            if (CollectionUtils.isNotEmpty(bo.getCorePersonnelList())) {
-                legal = bo.getCorePersonnelList().stream()
-                        .filter(p -> "法定代表人".equals(p.getPosition()))
-                        .findFirst()
-                        .orElse(null);
-            }
-            if (legal != null) {
-                m.setUserName1(legal.getName());
-                m.setAge1(legal.getAge());
-                m.setSex1(legal.getSex());
-                m.setNativePlace1(legal.getNativePlace());
-                m.setAddress1(legal.getAddress());
-                m.setMobile1(legal.getMobile());
-                m.setPhone1(legal.getPhone());
-                m.setEmail1(legal.getEmail());
-            }
+        ExportTaskUtil.exportTask("客户资信批量导出", CustomerCreditBatchExportTaskWorker.class, vo);
 
-            m.setBusinessProperty(bo.getBusinessProperty());
-            m.setBusinessScope(bo.getBusinessScope());
-            m.setLandArea(bo.getLandArea());
-            m.setStorageConditions(bo.getStorageConditions());
-            m.setEmployeeCount(bo.getEmployeeCount());
-            m.setEquipmentAttributes(bo.getEquipmentAttributes());
-            m.setAssetEvaluation(bo.getAssetEvaluation());
-            m.setLastYearSales(bo.getLastYearSales());
-            m.setMonthlyAvgSales(bo.getMonthlyAvgSales());
-            m.setInvoiceItemUnit(bo.getInvoiceItemUnit());
-            m.setCertificationCertificate(bo.getCertificationCertificate());
-            m.setProductMatch(bo.getProductMatch());
-            m.setMajorCustomers(bo.getMajorCustomers());
-            m.setMainProjects(bo.getMainProjects());
-            m.setIndustryInvolved(bo.getIndustryInvolved());
-            m.setIndustryExperience(bo.getIndustryExperience());
-            m.setHasDispute(bo.getHasDispute());
-            m.setCooperationStartDate(
-                    StringUtil.isBlank(bo.getCooperationStartDate())
-                            ? ""
-                            : bo.getCooperationStartDate());
-            m.setMonthlyAvgVolume(bo.getMonthlyAvgVolume());
-            m.setIsVerbalAgreement(
-                    StringUtil.isBlank(bo.getIsVerbalAgreement())
-                            ? ""
-                            : bo.getIsVerbalAgreement());
-            m.setOtherAgreements(bo.getOtherAgreements());
-            m.setHasLongTermContract(
-                    StringUtil.isBlank(bo.getHasLongTermContract())
-                            ? ""
-                            : bo.getHasLongTermContract());
-            m.setContractType(bo.getContractType());
-            m.setHasInterruption(bo.getHasInterruption());
-            m.setSettlementPeriod(bo.getSettlementPeriod());
-            m.setMaterialSupplyPlan(bo.getMaterialSupplyPlan());
-            m.setSuggestedCategory(
-                    StringUtil.isNotBlank(bo.getSuggestedCategory())
-                            ? bo.getSuggestedCategory()
-                            : bo.getCompanySuggestedCategory());
-            m.setCreditLimit(
-                    StringUtil.isNotBlank(bo.getCreditLimit())
-                            ? bo.getCreditLimit()
-                            : bo.getCompanyCreditLimit());
-            m.setInvestigatorName(bo.getInvestigatorName());
-
-            models.add(m);
-        }
-
-        try (OutputStream out = response.getOutputStream()) {
-            EasyExcel.write(out, CustomerCreditBatchExportModel.class)
-                    .registerWriteHandler(new AutoColumnWidthHandler())
-                    .sheet("客户资信")
-                    .doWrite(models);
-        }
-    }
-
-    private static String convertEnterpriseType(String type) {
-        if (StringUtil.isBlank(type)) return "";
-        switch (type) {
-            case "DEALER":
-            case "经销商":
-                return "经销商";
-            case "TERMINAL":
-            case "终端":
-                return "终端";
-            case "FOREIGN":
-            case "外贸":
-                return "外贸";
-            default:
-                return type;
-        }
+        return InvokeResultBuilder.success();
     }
 
     /**

+package com.lframework.xingyun.sc.excel.customerCredit;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.lframework.starter.common.utils.CollectionUtil;
+import com.lframework.starter.common.utils.StringUtil;
+import com.lframework.starter.mq.core.components.export.ExportTaskWorker;
+import com.lframework.starter.web.core.components.resp.PageResult;
+import com.lframework.starter.web.core.utils.ApplicationUtil;
+import com.lframework.starter.web.core.utils.JsonUtil;
+import com.lframework.starter.web.core.utils.PageResultUtil;
+import com.lframework.starter.web.inner.entity.SysUser;
+import com.lframework.starter.web.inner.service.system.SysUserService;
+import com.lframework.xingyun.sc.bo.customer.credit.GetCustomerCreditBo;
+import com.lframework.xingyun.sc.entity.CorePersonnel;
+import com.lframework.xingyun.sc.entity.CustomerCredit;
+import com.lframework.xingyun.sc.service.customer.CorePersonnelService;
+import com.lframework.xingyun.sc.service.customer.CustomerCreditService;
+import com.lframework.xingyun.sc.vo.customer.credit.QueryCustomerCreditVo;
+import org.apache.commons.collections4.CollectionUtils;
+
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+/**
+ * 客户资信按筛选条件批量导出（按导入模板结构，核心人员只导出第一个法定代表人）
+ */
+public class CustomerCreditBatchExportTaskWorker implements
+        ExportTaskWorker<QueryCustomerCreditVo, GetCustomerCreditBo, CustomerCreditBatchExportModel> {
+
+    private static final DateTimeFormatter DATE_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+
+    /**
+     * 序号自增（异步导出按分页顺序逐行调用 exportData，每次任务实例新建，从 1 开始）
+     */
+    private final AtomicInteger sortCounter = new AtomicInteger(0);
+
+    @Override
+    public QueryCustomerCreditVo parseParams(String json) {
+        return JsonUtil.parseObject(json, QueryCustomerCreditVo.class);
+    }
+
+    @Override
+    public PageResult<GetCustomerCreditBo> getDataList(int pageIndex, int pageSize, QueryCustomerCreditVo params) {
+        CustomerCreditService customerCreditService = ApplicationUtil.getBean(CustomerCreditService.class);
+        PageResult<CustomerCredit> pageResult = customerCreditService.query(pageIndex, pageSize, params);
+        List<CustomerCredit> dataList = pageResult.getDatas();
+        List<GetCustomerCreditBo> results = null;
+        if (!CollectionUtil.isEmpty(dataList)) {
+            results = this.packCustomerCreditData(dataList);
+        }
+        return PageResultUtil.rebuild(pageResult, results);
+    }
+
+    @Override
+    public CustomerCreditBatchExportModel exportData(GetCustomerCreditBo data) {
+        return this.buildModel(data);
+    }
+
+    @Override
+    public Class<CustomerCreditBatchExportModel> getModelClass() {
+        return CustomerCreditBatchExportModel.class;
+    }
+
+    /**
+     * 批量封装关联数据：每个资信的第一个“法定代表人”核心人员 + 调查人姓名
+     */
+    private List<GetCustomerCreditBo> packCustomerCreditData(List<CustomerCredit> dataList) {
+        List<String> creditIds = dataList.stream()
+                .map(CustomerCredit::getId)
+                .filter(StringUtil::isNotBlank)
+                .distinct()
+                .collect(Collectors.toList());
+
+        // 每个资信的第一个法定代表人（按 id 排序保证多次导出结果稳定）
+        Map<String, CorePersonnel> legalMap = new HashMap<>();
+        if (CollectionUtils.isNotEmpty(creditIds)) {
+            CorePersonnelService corePersonnelService = ApplicationUtil.getBean(CorePersonnelService.class);
+            List<CorePersonnel> personnelList = corePersonnelService.list(
+                    Wrappers.lambdaQuery(CorePersonnel.class)
+                            .in(CorePersonnel::getCreditId, creditIds)
+                            .eq(CorePersonnel::getPosition, "法定代表人")
+                            .orderByAsc(CorePersonnel::getId));
+            if (CollectionUtils.isNotEmpty(personnelList)) {
+                for (CorePersonnel personnel : personnelList) {
+                    // keep-first：同一资信只保留第一个法定代表人
+                    legalMap.putIfAbsent(personnel.getCreditId(), personnel);
+                }
+            }
+        }
+
+        // 调查人姓名
+        List<String> investigatorIds = dataList.stream()
+                .map(CustomerCredit::getInvestigator)
+                .filter(StringUtil::isNotBlank)
+                .distinct()
+                .collect(Collectors.toList());
+        Map<String, SysUser> investigatorMap = new HashMap<>();
+        if (CollectionUtils.isNotEmpty(investigatorIds)) {
+            SysUserService sysUserService = ApplicationUtil.getBean(SysUserService.class);
+            List<SysUser> users = sysUserService.listByIds(investigatorIds);
+            if (CollectionUtils.isNotEmpty(users)) {
+                investigatorMap = users.stream()
+                        .collect(Collectors.toMap(SysUser::getId, Function.identity(), (k1, k2) -> k1));
+            }
+        }
+
+        List<GetCustomerCreditBo> result = new ArrayList<>(dataList.size());
+        for (CustomerCredit credit : dataList) {
+            GetCustomerCreditBo bo = new GetCustomerCreditBo(credit);
+            CorePersonnel legal = legalMap.get(credit.getId());
+            bo.setCorePersonnelList(legal == null
+                    ? Collections.emptyList()
+                    : Collections.singletonList(legal));
+            SysUser investigator = investigatorMap.get(credit.getInvestigator());
+            if (investigator != null) {
+                bo.setInvestigatorName(investigator.getName());
+            }
+            result.add(bo);
+        }
+        return result;
+    }
+
+    /**
+     * GetCustomerCreditBo → 导入模板结构导出行
+     */
+    private CustomerCreditBatchExportModel buildModel(GetCustomerCreditBo bo) {
+        CustomerCreditBatchExportModel m = new CustomerCreditBatchExportModel();
+        m.setSort(String.valueOf(sortCounter.incrementAndGet()));
+        m.setCode(bo.getSerialNumber());
+        m.setDeptName(bo.getDeptName());
+        m.setRegionName(bo.getRegionName());
+        m.setCustomerShortName(bo.getCustomerShortName());
+        m.setRegisterDateStr(formatDate(bo.getRegisterDate()));
+        m.setName(bo.getCompanyName());
+        m.setEnterpriseType(convertEnterpriseType(bo.getEnterpriseType()));
+        m.setCompanyNature(bo.getCompanyNature());
+        m.setCompanyAddress(bo.getCompanyAddress());
+        m.setRegisteredCapital(bo.getRegisteredCapital());
+        m.setBankAccount(bo.getBankAccount());
+        m.setBankName(bo.getBankName());
+        m.setTaxNumber(bo.getTaxNumber());
+        m.setRegistrationTimeStr(formatDate(bo.getRegistrationTime()));
+        m.setBusinessYears(bo.getBusinessYears());
+
+        if (CollectionUtils.isNotEmpty(bo.getCorePersonnelList())) {
+            CorePersonnel legal = bo.getCorePersonnelList().get(0);
+            m.setUserName1(legal.getName());
+            m.setAge1(legal.getAge());
+            m.setSex1(legal.getSex());
+            m.setNativePlace1(legal.getNativePlace());
+            m.setAddress1(legal.getAddress());
+            m.setMobile1(legal.getMobile());
+            m.setPhone1(legal.getPhone());
+            m.setEmail1(legal.getEmail());
+        }
+
+        m.setBusinessProperty(bo.getBusinessProperty());
+        m.setBusinessScope(bo.getBusinessScope());
+        m.setLandArea(bo.getLandArea());
+        m.setStorageConditions(bo.getStorageConditions());
+        m.setEmployeeCount(bo.getEmployeeCount());
+        m.setEquipmentAttributes(bo.getEquipmentAttributes());
+        m.setAssetEvaluation(bo.getAssetEvaluation());
+        m.setLastYearSales(bo.getLastYearSales());
+        m.setMonthlyAvgSales(bo.getMonthlyAvgSales());
+        m.setInvoiceItemUnit(bo.getInvoiceItemUnit());
+        m.setCertificationCertificate(bo.getCertificationCertificate());
+        m.setProductMatch(bo.getProductMatch());
+        m.setMajorCustomers(bo.getMajorCustomers());
+        m.setMainProjects(bo.getMainProjects());
+        m.setIndustryInvolved(bo.getIndustryInvolved());
+        m.setIndustryExperience(bo.getIndustryExperience());
+        m.setHasDispute(bo.getHasDispute());
+        m.setCooperationStartDate(bo.getCooperationStartDate());
+        m.setMonthlyAvgVolume(bo.getMonthlyAvgVolume());
+        m.setIsVerbalAgreement(bo.getIsVerbalAgreement());
+        m.setOtherAgreements(bo.getOtherAgreements());
+        m.setHasLongTermContract(bo.getHasLongTermContract());
+        m.setContractType(bo.getContractType());
+        m.setHasInterruption(bo.getHasInterruption());
+        m.setSettlementPeriod(bo.getSettlementPeriod());
+        m.setMaterialSupplyPlan(bo.getMaterialSupplyPlan());
+        m.setSuggestedCategory(StringUtil.isNotBlank(bo.getSuggestedCategory())
+                ? bo.getSuggestedCategory() : bo.getCompanySuggestedCategory());
+        m.setCreditLimit(StringUtil.isNotBlank(bo.getCreditLimit())
+                ? bo.getCreditLimit() : bo.getCompanyCreditLimit());
+        m.setInvestigatorName(bo.getInvestigatorName());
+        return m;
+    }
+
+    private static String formatDate(LocalDate date) {
+        return date == null ? "" : date.format(DATE_FORMATTER);
+    }
+
+    private static String convertEnterpriseType(String type) {
+        if (StringUtil.isBlank(type)) {
+            return "";
+        }
+        switch (type) {
+            case "DEALER":
+            case "经销商":
+                return "经销商";
+            case "TERMINAL":
+            case "终端":
+                return "终端";
+            case "FOREIGN":
+            case "外贸":
+                return "外贸";
+            default:
+                return type;
+        }
+    }
+}