产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
yuan
2026-04-24 b4a9e12e00b78e1aef8acda070434de9ffd0d66a 
 src/main/java/com/ruoyi/basic/service/impl/CustomerPrivateServiceImpl.java


@@ -1,34 +1,29 @@


package com.ruoyi.basic.service.impl;




import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


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.basic.dto.CustomerPrivateDto;


import com.ruoyi.basic.dto.CustomerPrivatePoolDto;


import com.ruoyi.basic.mapper.CustomerMapper;


import com.ruoyi.basic.mapper.CustomerPrivatePoolMapper;


import com.ruoyi.basic.pojo.*;


import com.ruoyi.basic.mapper.CustomerPrivateMapper;


import com.ruoyi.basic.mapper.CustomerPrivatePoolMapper;


import com.ruoyi.basic.pojo.CustomerFollowUp;


import com.ruoyi.basic.pojo.CustomerPrivate;


import com.ruoyi.basic.pojo.CustomerPrivatePool;


import com.ruoyi.basic.pojo.CustomerReturnVisit;


import com.ruoyi.basic.service.CustomerFollowUpService;


import com.ruoyi.basic.service.CustomerPrivateService;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.ruoyi.basic.service.CustomerReturnVisitService;


import com.ruoyi.common.utils.SecurityUtils;


import com.ruoyi.common.utils.poi.ExcelUtil;


import com.ruoyi.framework.security.LoginUser;


import com.ruoyi.framework.web.domain.AjaxResult;


import com.ruoyi.framework.web.domain.R;


import com.ruoyi.sales.mapper.SalesLedgerMapper;


import com.ruoyi.sales.pojo.SalesLedger;


import lombok.RequiredArgsConstructor;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


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.Collections;


import java.util.List;


import java.util.stream.Collectors;




@@ -42,19 +37,18 @@


 */


@Service


@Transactional(rollbackFor = Exception.class)


@RequiredArgsConstructor


public class CustomerPrivateServiceImpl extends ServiceImpl<CustomerPrivateMapper, CustomerPrivate> implements CustomerPrivateService {






    @Autowired


    private CustomerPrivatePoolMapper customerPrivatePoolMapper;


    private final CustomerPrivatePoolMapper customerPrivatePoolMapper;




    @Autowired


    private CustomerFollowUpService customerFollowUpService;


    private final CustomerFollowUpService customerFollowUpService;




    @Autowired


    private CustomerReturnVisitService customerReturnVisitService;


    @Autowired


    private SalesLedgerMapper salesLedgerMapper;


    private final CustomerReturnVisitService customerReturnVisitService;


    private final SalesLedgerMapper salesLedgerMapper;




    private final CustomerPrivateMapper customerPrivateMapper;






    @Override


@@ -64,6 +58,7 @@


        //新增私海记录


        CustomerPrivatePool customerPrivatePool = new CustomerPrivatePool();


        customerPrivatePool.setCustomerId(customerPrivateDto.getId());


        customerPrivatePool.setType(0L);


        customerPrivatePool.setBoundId(SecurityUtils.getLoginUser().getUserId());


        customerPrivatePoolMapper.insert(customerPrivatePool);


        return true;


@@ -93,20 +88,34 @@


    @Override


    public R importData(MultipartFile file) {


        try {


            List<CustomerPrivate> existingList = customerPrivateMapper.selectList(null);


            java.util.Set<String> existingCustomerNames = existingList.stream()


                    .map(CustomerPrivate::getCustomerName)


                    .collect(Collectors.toSet());




            ExcelUtil<CustomerPrivate> util = new ExcelUtil<CustomerPrivate>(CustomerPrivate.class);


            List<CustomerPrivate> userList = util.importExcel(file.getInputStream());


            if (CollectionUtils.isEmpty(userList)) {


                return R.fail("模板错误或导入数据为空");


            }




            int successCount = 0;


            int skipCount = 0;


            for (CustomerPrivate user : userList) {


                if (existingCustomerNames.contains(user.getCustomerName())) {


                    skipCount++;


                    continue;


                }


                CustomerPrivateDto customerPrivateDto = new CustomerPrivateDto();


                BeanUtils.copyProperties(user, customerPrivateDto);


                this.add(customerPrivateDto);


                existingCustomerNames.add(user.getCustomerName());


                successCount++;


            }


            return R.ok(true);


            return R.ok("导入完成，成功" + successCount + "条，跳过重复" + skipCount + "条");


        } catch (Exception e) {


            e.printStackTrace();


            return R.fail("导入失败");


            return R.fail("导入失败：" + e.getMessage());


        }


    }


}