From 0891b6708cc09c2672a19661a8555aae0e742df1 Mon Sep 17 00:00:00 2001
From: tuqin <tuqin@tuqin.cn>
Date: 星期四, 24 九月 2026 16:54:27 +0800
Subject: [PATCH] feat: 新增多模块导入导出功能
---
src/main/java/com/ruoyi/aftersalesservice/service/impl/AfterSalesServiceServiceImpl.java | 148 +++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 148 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/ruoyi/aftersalesservice/service/impl/AfterSalesServiceServiceImpl.java b/src/main/java/com/ruoyi/aftersalesservice/service/impl/AfterSalesServiceServiceImpl.java
index 0feab41..a9e4f43 100644
--- a/src/main/java/com/ruoyi/aftersalesservice/service/impl/AfterSalesServiceServiceImpl.java
+++ b/src/main/java/com/ruoyi/aftersalesservice/service/impl/AfterSalesServiceServiceImpl.java
@@ -1,22 +1,31 @@
package com.ruoyi.aftersalesservice.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.aftersalesservice.dto.AfterSalesServiceImportDto;
import com.ruoyi.aftersalesservice.dto.AfterSalesServiceNewDto;
import com.ruoyi.aftersalesservice.dto.CountDto;
import com.ruoyi.aftersalesservice.mapper.AfterSalesServiceMapper;
import com.ruoyi.aftersalesservice.pojo.AfterSalesService;
import com.ruoyi.aftersalesservice.service.AfterSalesServiceService;
+import com.ruoyi.basic.mapper.CustomerMapper;
+import com.ruoyi.basic.pojo.Customer;
import com.ruoyi.common.utils.OrderUtils;
import com.ruoyi.common.utils.SecurityUtils;
+import com.ruoyi.common.utils.poi.ExcelUtil;
+import com.ruoyi.framework.web.domain.AjaxResult;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.project.system.domain.SysDept;
import com.ruoyi.project.system.domain.SysUser;
import com.ruoyi.project.system.mapper.SysDeptMapper;
+import com.ruoyi.project.system.domain.SysDictData;
+import com.ruoyi.project.system.mapper.SysDictDataMapper;
import com.ruoyi.project.system.mapper.SysUserMapper;
import com.ruoyi.sales.dto.SalesLedgerDto;
+import com.ruoyi.sales.mapper.SalesLedgerMapper;
import com.ruoyi.sales.pojo.SalesLedger;
import com.ruoyi.sales.pojo.SalesLedgerProduct;
import com.ruoyi.sales.service.ISalesLedgerProductService;
@@ -25,8 +34,12 @@
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+import org.springframework.web.multipart.MultipartFile;
+import java.util.ArrayList;
import java.util.Arrays;
+import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
@@ -45,6 +58,9 @@
private final ISalesLedgerProductService salesLedgerProductService;
private final ISalesLedgerService salesLedgerService;
private final com.ruoyi.sales.mapper.ShippingInfoMapper shippingInfoMapper;
+ private final CustomerMapper customerMapper;
+ private final SalesLedgerMapper salesLedgerMapper;
+ private final SysDictDataMapper sysDictDataMapper;
@Override
public IPage<AfterSalesServiceNewDto> listPage(Page page, AfterSalesServiceNewDto afterSalesService) {
@@ -138,4 +154,136 @@
return stringIntegerHashMap;
}
+
+ @Override
+ public AjaxResult importData(MultipartFile file) {
+ List<AfterSalesServiceImportDto> rows;
+ try {
+ ExcelUtil<AfterSalesServiceImportDto> util = new ExcelUtil<>(AfterSalesServiceImportDto.class);
+ rows = util.importExcel(file.getInputStream());
+ } catch (Exception e) {
+ log.error("鍙嶉鐧昏瀵煎叆-瑙ｆ瀽excel澶辫触", e);
+ return AjaxResult.error("瑙ｆ瀽Excel澶辫触锛�" + e.getMessage());
+ }
+ if (CollectionUtils.isEmpty(rows)) {
+ return AjaxResult.error("瀵煎叆鏂囦欢鏃犳暟鎹�");
+ }
+ Long tenantId = SecurityUtils.getLoginUser().getTenantId();
+ Long userId = SecurityUtils.getUserId();
+ int success = 0;
+ List<String> errors = new ArrayList<>();
+ for (int i = 0; i < rows.size(); i++) {
+ AfterSalesServiceImportDto row = rows.get(i);
+ int rowNo = i + 2; // 棣栬涓鸿〃澶�
+ try {
+ String customerName = trim(row.getCustomerName());
+ if (StringUtils.isEmpty(customerName)) {
+ errors.add("绗�" + rowNo + "琛岋細瀹㈡埛鍚嶇О涓虹┖");
+ continue;
+ }
+ Customer customer = findCustomerByName(customerName, tenantId);
+ if (customer == null) {
+ errors.add("绗�" + rowNo + "琛岋細瀹㈡埛[" + customerName + "]涓嶅瓨鍦�");
+ continue;
+ }
+
+ String serviceTypeName = trim(row.getServiceType());
+ String serviceTypeValue = dictValueByLabel("post_sale_waiting_list", serviceTypeName);
+ if (StringUtils.isEmpty(serviceTypeValue)) {
+ errors.add("绗�" + rowNo + "琛岋細鍞悗绫诲瀷[" + serviceTypeName + "]涓嶅瓨鍦�");
+ continue;
+ }
+
+ String urgencyName = trim(row.getUrgency());
+ String urgencyValue = dictValueByLabel("degree_of_urgency", urgencyName);
+ if (StringUtils.isEmpty(urgencyValue)) {
+ errors.add("绗�" + rowNo + "琛岋細绱ф�ョ▼搴" + urgencyName + "]涓嶅瓨鍦�");
+ continue;
+ }
+
+ Long salesLedgerId = null;
+ String contractNo = trim(row.getSalesContractNo());
+ if (StringUtils.isNotEmpty(contractNo)) {
+ SalesLedger ledger = salesLedgerMapper.selectOne(new LambdaQueryWrapper<SalesLedger>()
+ .eq(SalesLedger::getSalesContractNo, contractNo)
+ .eq(SalesLedger::getCustomerId, customer.getId())
+ .last("limit 1"));
+ if (ledger == null) {
+ ledger = salesLedgerMapper.selectOne(new LambdaQueryWrapper<SalesLedger>()
+ .eq(SalesLedger::getSalesContractNo, contractNo)
+ .last("limit 1"));
+ }
+ if (ledger == null) {
+ errors.add("绗�" + rowNo + "琛岋細閿�鍞崟鍙穂" + contractNo + "]涓嶅瓨鍦�");
+ continue;
+ }
+ salesLedgerId = ledger.getId();
+ }
+
+ AfterSalesServiceNewDto dto = new AfterSalesServiceNewDto();
+ dto.setCustomerName(customer.getCustomerName());
+ dto.setSalesLedgerId(salesLedgerId);
+ dto.setServiceType(serviceTypeValue);
+ dto.setUrgency(urgencyValue);
+ dto.setProDesc(row.getProDesc());
+ dto.setFeedbackDate(row.getFeedbackDate() != null ? row.getFeedbackDate() : new Date());
+ dto.setCheckUserId(userId);
+ dto.setProductModelIds("");
+ dto.setProductModelQuantities("");
+
+ if (addAfterSalesServiceDto(dto)) {
+ success++;
+ } else {
+ errors.add("绗�" + rowNo + "琛岋細淇濆瓨澶辫触");
+ }
+ } catch (Exception e) {
+ log.error("鍙嶉鐧昏瀵煎叆绗瑊}琛屽け璐�", rowNo, e);
+ errors.add("绗�" + rowNo + "琛岋細" + e.getMessage());
+ }
+ }
+
+ AjaxResult result = AjaxResult.success();
+ result.put("totalCount", rows.size());
+ result.put("successCount", success);
+ result.put("failCount", rows.size() - success);
+ result.put("errors", errors);
+ result.put("msg", "瀵煎叆瀹屾垚锛氭垚鍔� " + success + " 鏉★紝澶辫触 " + (rows.size() - success) + " 鏉�");
+ return result;
+ }
+
+ private String trim(String value) {
+ return value == null ? null : value.trim();
+ }
+
+ private Customer findCustomerByName(String name, Long tenantId) {
+ List<Customer> customers = customerMapper.selectList(new LambdaQueryWrapper<Customer>()
+ .eq(Customer::getCustomerName, name));
+ if (CollectionUtils.isEmpty(customers)) {
+ return null;
+ }
+ if (tenantId != null) {
+ for (Customer c : customers) {
+ if (tenantId.equals(c.getTenantId())) {
+ return c;
+ }
+ }
+ }
+ return customers.get(0);
+ }
+
+ private String dictValueByLabel(String dictType, String label) {
+ if (StringUtils.isEmpty(label)) {
+ return null;
+ }
+ List<SysDictData> datas = sysDictDataMapper.selectDictDataByType(dictType);
+ if (CollectionUtils.isEmpty(datas)) {
+ return null;
+ }
+ for (SysDictData d : datas) {
+ if (label.equals(d.getDictLabel())) {
+ return d.getDictValue();
+ }
+ }
+ return null;
+ }
}
--
Gitblit v1.9.3