From 9af5090f5d4597fbcfdf53a71189175892d29109 Mon Sep 17 00:00:00 2001
From: maven <2163098428@qq.com>
Date: 星期四, 05 三月 2026 17:44:35 +0800
Subject: [PATCH] yys 人力资源-员工台账模块优化

---
 src/main/java/com/ruoyi/basic/service/impl/CustomerServiceImpl.java |  128 ++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 121 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/ruoyi/basic/service/impl/CustomerServiceImpl.java b/src/main/java/com/ruoyi/basic/service/impl/CustomerServiceImpl.java
index afc1c30..b7cb426 100644
--- a/src/main/java/com/ruoyi/basic/service/impl/CustomerServiceImpl.java
+++ b/src/main/java/com/ruoyi/basic/service/impl/CustomerServiceImpl.java
@@ -2,19 +2,36 @@
 
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.basic.dto.CustomerDto;
+import com.ruoyi.basic.dto.CustomerFollowUpDto;
 import com.ruoyi.basic.mapper.CustomerMapper;
 import com.ruoyi.basic.pojo.Customer;
+import com.ruoyi.basic.pojo.CustomerFollowUp;
+import com.ruoyi.basic.pojo.CustomerFollowUpFile;
+import com.ruoyi.basic.service.CustomerFollowUpFileService;
+import com.ruoyi.basic.service.CustomerFollowUpService;
+import com.ruoyi.basic.service.CustomerReturnVisitService;
 import com.ruoyi.basic.service.ICustomerService;
 import com.ruoyi.common.utils.SecurityUtils;
 import com.ruoyi.common.utils.StringUtils;
+import com.ruoyi.common.utils.poi.ExcelUtil;
 import com.ruoyi.framework.security.LoginUser;
+import com.ruoyi.framework.web.domain.AjaxResult;
+import com.ruoyi.project.system.domain.SysUser;
+import com.ruoyi.sales.mapper.SalesLedgerMapper;
+import com.ruoyi.sales.pojo.SalesLedger;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.CollectionUtils;
+import org.springframework.web.multipart.MultipartFile;
 
 import java.util.Arrays;
 import java.util.List;
@@ -33,7 +50,14 @@
 @AllArgsConstructor
 @Slf4j
 public class CustomerServiceImpl extends ServiceImpl<CustomerMapper, Customer> implements ICustomerService {
+    private final SalesLedgerMapper salesLedgerMapper;
     private CustomerMapper customerMapper;
+
+    private CustomerFollowUpService customerFollowUpService;
+
+    private CustomerFollowUpFileService customerFollowUpFileService;
+
+    private CustomerReturnVisitService customerReturnVisitService;
 
     /**
      * 鏌ヨ瀹㈡埛妗f
@@ -47,13 +71,57 @@
     }
 
     /**
+     * 鏌ヨ瀹㈡埛璇︽儏锛堝惈璺熻繘璁板綍鍜岄檮浠讹級
+     *
+     * @param id 瀹㈡埛妗f涓婚敭
+     * @return 瀹㈡埛璇︽儏DTO
+     */
+    @Override
+    public CustomerDto selectCustomerDetailById(Long id) {
+        Customer customer = customerMapper.selectById(id);
+        if (customer == null) {
+            return null;
+        }
+
+        CustomerDto dto = new CustomerDto();
+        BeanUtils.copyProperties(customer, dto);
+
+        // 鏌ヨ璺熻繘璁板綍
+        List<CustomerFollowUp> followUpList = customerFollowUpService.list(
+                new LambdaQueryWrapper<CustomerFollowUp>()
+                        .eq(CustomerFollowUp::getCustomerId, id)
+                        .orderByDesc(CustomerFollowUp::getFollowUpTime)
+        );
+
+        if (!CollectionUtils.isEmpty(followUpList)) {
+            List<CustomerFollowUpDto> followUpDtoList = followUpList.stream().map(followUp -> {
+                CustomerFollowUpDto followUpDto = new CustomerFollowUpDto();
+                BeanUtils.copyProperties(followUp, followUpDto);
+
+                // 鏌ヨ闄勪欢
+                List<CustomerFollowUpFile> fileList = customerFollowUpFileService.list(
+                        new LambdaQueryWrapper<CustomerFollowUpFile>()
+                                .eq(CustomerFollowUpFile::getFollowUpId, followUp.getId())
+                );
+                followUpDto.setFileList(fileList);
+
+                return followUpDto;
+            }).collect(Collectors.toList());
+
+            dto.setFollowUpList(followUpDtoList);
+        }
+
+        return dto;
+    }
+
+    /**
      * 鏌ヨ瀹㈡埛妗f鍒楄〃
      *
      * @param customer 瀹㈡埛妗f
      * @return 瀹㈡埛妗f
      */
     @Override
-    public IPage<Customer> selectCustomerList(Page page, Customer customer) {
+    public IPage<Customer> selectCustomerList(Page<Customer> page, Customer customer) {
         // 1. 澶勭悊绌哄�煎満鏅紙鍙傛暟鏍¢獙锛�
         if (page == null) {
             page = Page.of(1, 10); // 榛樿绗�1椤碉紝姣忛〉10鏉℃暟鎹�
@@ -65,8 +133,12 @@
         // 2. 鏋勫缓鏌ヨ鏉′欢锛堝寮虹┖鍊煎畨鍏級
         LambdaQueryWrapper<Customer> queryWrapper = new LambdaQueryWrapper<>();
         String customerName = customer.getCustomerName();
+        String customerType = customer.getCustomerType();
         if (StringUtils.isNotBlank(customerName)) {
             queryWrapper.like(Customer::getCustomerName, customerName);
+        }
+        if (StringUtils.isNotBlank(customerType)) {
+            queryWrapper.like(Customer::getCustomerType, customerType);
         }
 
         // 3. 鎵ц鍒嗛〉鏌ヨ锛堜繚鐣欏垎椤靛厓鏁版嵁锛�
@@ -79,12 +151,26 @@
                     // 瀹夊叏鑾峰彇瀛楁锛岄伩鍏峮ull鍊兼嫾鎺�
                     String address = StringUtils.defaultString(c.getCompanyAddress(), "");
                     String phone = StringUtils.defaultString(c.getCompanyPhone(), "");
-                    c.setAddressPhone(address + "(" + phone + ")"); // 浼樺寲瀛楃涓叉嫾鎺�
+                    c.setAddressPhone(address + "(" + phone + ")");
+
+                    // 鏌ヨ鏈�鏂扮殑璺熻繘璁板綍
+                    CustomerFollowUp followUp = customerFollowUpService.getOne(
+                            new LambdaQueryWrapper<CustomerFollowUp>()
+                                    .eq(CustomerFollowUp::getCustomerId, c.getId())
+                                    .orderByDesc(CustomerFollowUp::getFollowUpTime)
+                                    .last("LIMIT 1")
+                    );
+
+                    if (followUp != null) {
+                        c.setFollowUpLevel(followUp.getFollowUpLevel());
+                        c.setFollowUpTime(followUp.getFollowUpTime());
+                    }
                 })
                 .collect(Collectors.toList());
 
         // 5. 鏇存柊鍒嗛〉缁撴灉涓殑鏁版嵁锛堜繚鎸佸垎椤典俊鎭畬鏁达級
-        customerPage.setRecords(processedList);
+        IPage<Customer> resultPage = new Page<>(customerPage.getCurrent(), customerPage.getSize(), customerPage.getTotal());
+        resultPage.setRecords(processedList);
 
         return customerPage; // 杩斿洖鍖呭惈鍒嗛〉淇℃伅鐨処Page瀵硅薄
     }
@@ -98,8 +184,8 @@
     @Override
     public int insertCustomer(Customer customer) {
         LoginUser loginUser = SecurityUtils.getLoginUser();
-        Integer tenantId = loginUser.getTenantId();
-        customer.setTenantId(Long.valueOf(tenantId));
+        Long tenantId = loginUser.getTenantId();
+        customer.setTenantId(tenantId);
         return customerMapper.insert(customer);
     }
 
@@ -112,8 +198,8 @@
     @Override
     public int updateCustomer(Customer customer) {
         LoginUser loginUser = SecurityUtils.getLoginUser();
-        Integer tenantId = loginUser.getTenantId();
-        customer.setTenantId(Long.valueOf(tenantId));
+        Long tenantId = loginUser.getTenantId();
+        customer.setTenantId(tenantId);
         return customerMapper.updateById(customer);
     }
 
@@ -124,8 +210,19 @@
      * @return 缁撴灉
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public int deleteCustomerByIds(Long[] ids) {
         List<Long> idList = Arrays.asList(ids);
+        List<SalesLedger> salesLedgers = salesLedgerMapper.selectList(new QueryWrapper<SalesLedger>().lambda().in(SalesLedger::getCustomerId, idList));
+        if (!salesLedgers.isEmpty()) {
+            throw new RuntimeException("瀹㈡埛妗f涓嬫湁閿�鍞悎鍚岋紝璇峰厛鍒犻櫎閿�鍞悎鍚�");
+        }
+        //  鍒犻櫎瀹㈡埛鐨勫悓鏃朵篃闇�瑕佸垹闄ゅ搴旂殑瀹㈡埛璺熼殢銆侀檮浠跺拰鍥炶鎻愰啋
+        for (Long id : ids) {
+            customerFollowUpService.deleteByCustomerId(id);
+            customerReturnVisitService.deleteByCustomerId(id);
+        }
+
         return customerMapper.deleteBatchIds(idList);
     }
 
@@ -142,6 +239,23 @@
     }
 
     @Override
+    public AjaxResult importData(MultipartFile file) {
+        try {
+            ExcelUtil<Customer> util = new ExcelUtil<Customer>(Customer.class);
+            List<Customer> userList = util.importExcel(file.getInputStream());
+            if (CollectionUtils.isEmpty(userList)) {
+                return AjaxResult.warn("妯℃澘閿欒鎴栧鍏ユ暟鎹负绌�");
+            }
+            this.saveOrUpdateBatch(userList);
+            return AjaxResult.success(true);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return AjaxResult.error("瀵煎叆澶辫触");
+        }
+
+    }
+
+    @Override
     public List<Map<String, Object>> customerList(Customer customer) {
         LambdaQueryWrapper<Customer> queryWrapper = Wrappers.lambdaQuery();
         queryWrapper.select(Customer::getId, Customer::getCustomerName, Customer::getTaxpayerIdentificationNumber);

--
Gitblit v1.9.3