产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
huminmin
9 天以前 cf99945deda3cba4b0e634abb100847f5cc2529b 
 src/main/java/com/ruoyi/basic/service/impl/CustomerServiceImpl.java


@@ -9,35 +9,33 @@


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


import com.ruoyi.basic.dto.CustomerDto;


import com.ruoyi.basic.dto.CustomerFollowUpDto;


import com.ruoyi.basic.dto.CustomerPrivatePoolDto;


import com.ruoyi.basic.mapper.CustomerMapper;


import com.ruoyi.basic.mapper.CustomerPrivatePoolMapper;


import com.ruoyi.basic.pojo.Customer;


import com.ruoyi.basic.pojo.CustomerFollowUp;


import com.ruoyi.basic.pojo.CustomerFollowUpFile;


import com.ruoyi.basic.pojo.CustomerPrivatePool;


import com.ruoyi.basic.pojo.*;


import com.ruoyi.basic.service.CustomerFollowUpFileService;


import com.ruoyi.basic.service.CustomerFollowUpService;


import com.ruoyi.basic.service.CustomerReturnVisitService;


import com.ruoyi.basic.service.CustomerUserService;


import com.ruoyi.basic.service.ICustomerService;


import com.ruoyi.basic.vo.CustomerVo;


import com.ruoyi.common.utils.SecurityUtils;


import com.ruoyi.common.utils.StringUtils;


import com.ruoyi.common.utils.bean.BeanUtils;


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


import lombok.extern.slf4j.Slf4j;


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.time.LocalDate;


import java.time.LocalDateTime;


import java.time.ZoneId;


import java.util.*;


import java.util.stream.Collectors;


@@ -50,22 +48,17 @@


 * @date 2025-05-07


 */


@Service


@AllArgsConstructor


@RequiredArgsConstructor


@Slf4j


public class CustomerServiceImpl extends ServiceImpl<CustomerMapper, Customer> implements ICustomerService {


    @Autowired


    private  SalesLedgerMapper salesLedgerMapper;


    @Autowired


    private CustomerPrivatePoolMapper customerPrivatePoolMapper;


    @Autowired


    private CustomerMapper customerMapper;


    private final SalesLedgerMapper salesLedgerMapper;


    private final CustomerPrivatePoolMapper customerPrivatePoolMapper;


    private final CustomerMapper customerMapper;




    @Autowired


    private CustomerFollowUpService customerFollowUpService;


    @Autowired


    private CustomerFollowUpFileService customerFollowUpFileService;


    @Autowired


    private CustomerReturnVisitService customerReturnVisitService;


    private final CustomerFollowUpService customerFollowUpService;


    private final CustomerReturnVisitService customerReturnVisitService;




    private CustomerUserService customerUserService;




    /**


     * 查询客户档案


@@ -85,8 +78,35 @@


     * @return 客户详情DTO


     */


    @Override


    public Customer selectCustomerDetailById(Long id) {


        return this.getById( id);


    public CustomerVo selectCustomerDetailById(Long id) {


        CustomerVo customerVo = new CustomerVo();


        BeanUtils.copyProperties(this.getById(id), customerVo);




        // 查询跟进记录


        List<CustomerFollowUp> followUpList = customerFollowUpService.list(


                new LambdaQueryWrapper<CustomerFollowUp>()


                        .eq(CustomerFollowUp::getCustomerId, id)


                        .orderByDesc(CustomerFollowUp::getFollowUpTime)


        );


        if (!com.baomidou.mybatisplus.core.toolkit.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());




            customerVo.setFollowUpList(followUpDtoList);


        }




        return customerVo;


    }




    /**


@@ -96,16 +116,18 @@


     * @return 客户档案


     */


    @Override


    public IPage<CustomerDto> selectCustomerList(Page<CustomerDto> page, CustomerDto customer) {


        IPage<CustomerDto> customerPage = customerMapper.listPage(page, customer);


    public IPage<CustomerVo> selectCustomerList(Page<CustomerDto> page, CustomerDto customer) {


        LoginUser loginUser = SecurityUtils.getLoginUser();


        Long loginUserId = loginUser.getUserId();


        IPage<CustomerVo> customerPage = customerMapper.listPage(page, customer, loginUserId);




        List<CustomerDto> records = customerPage.getRecords();


        List<CustomerVo> records = customerPage.getRecords();


        if (CollectionUtils.isEmpty(records)) {


            return customerPage;


        }




        List<Long> customerIds = records.stream()


                .map(CustomerDto::getId)


                .map(CustomerVo::getId)


                .filter(Objects::nonNull)


                .collect(Collectors.toList());




@@ -123,6 +145,16 @@


                    c.setFollowUpTime(Date.from(


                            followUp.getFollowUpTime().atZone(ZoneId.systemDefault()).toInstant()


                    ));


                }




                // 转换共享用户ID字符串为List<Long>


                String userIdsStr = c.getUserIdsStr();


                if (StringUtils.isNotEmpty(userIdsStr)) {


                    List<Long> userIds = Arrays.stream(userIdsStr.split(","))


                            .map(String::trim)


                            .map(Long::parseLong)


                            .collect(Collectors.toList());


                    c.setUserIds(userIds);


                }


            });


        }


@@ -187,11 +219,22 @@


        if (!salesLedgers.isEmpty()) {


            throw new RuntimeException("客户档案下有销售合同，请先删除销售合同");


        }


        // 查询是否有已分配的公海客户


        List<Customer> assignedPools = customerMapper.selectList(


                new QueryWrapper<Customer>().lambda()


                        .in(Customer::getId, idList)


                        .eq(Customer::getType, 1).


                        eq(Customer::getIsAssigned, 1)  // 公海客户


        );


        if (!assignedPools.isEmpty()) {


            throw new RuntimeException("客户档案下有已分配的公海客户，请先收回");


        }


        //  删除客户的同时也需要删除对应的客户跟随、附件和回访提醒


        for (Long id : ids) {


            customerFollowUpService.deleteByCustomerId(id);


            customerReturnVisitService.deleteByCustomerId(id);


        }


        customerMapper.delete(new QueryWrapper<Customer>().lambda().in(Customer::getId, idList));




        return customerMapper.deleteBatchIds(idList);


    }


@@ -241,6 +284,77 @@


        ).collect(Collectors.toList());


    }




    // 分配公海客户给私海


    @Override


    public void assignCustomer(CustomerDto customerDto) {


        Customer customer = customerMapper.selectById(customerDto.getId());


        if (customer.getType() == 1 && customer.getIsAssigned() == 0) {  // 公海且可分配


            customer.setIsAssigned(1);


            customer.setUsageStatus(1L);


            customer.setUsageUser(customerDto.getUsageUser());


            customerMapper.updateById(customer);


        }


    }




    // 回收私海客户到公海


    @Override


    @Transactional(rollbackFor = Exception.class)


    public void recycleCustomer(CustomerDto customerDto) {


        Customer customer = customerMapper.selectById(customerDto.getId());


        if (customer.getType() == 1 && customer.getIsAssigned() == 1) {  // 公海且已分配


            customer.setIsAssigned(0);


            customer.setUsageStatus(0L);


            customer.setUsageUser(0L);


            customerMapper.updateById(customer);




            // 删除该客户的所有共享关系


            customerUserService.remove(


                new QueryWrapper<CustomerUser>().lambda()


                    .eq(CustomerUser::getCustomerId, customerDto.getId())


            );


        }


    }




    // 客户共享


    @Override


    public void together(CustomerDto customerDto) {


        // 查询现有的共享记录


        List<CustomerUser> existingUsers = customerUserService.list(


                new QueryWrapper<CustomerUser>().lambda().eq(CustomerUser::getCustomerId, customerDto.getId())


        );




        // 获取已存在的用户ID列表


        List<Long> existingUserIds = existingUsers.stream()


                .map(CustomerUser::getUserId)


                .collect(Collectors.toList());




        // 过滤掉已存在的用户，只保留新用户


        List<Long> newUserIds = customerDto.getUserIds().stream()


                .filter(userId -> !existingUserIds.contains(userId))


                .collect(Collectors.toList());




        if (CollectionUtils.isEmpty(newUserIds)) {


            return;


        }




        // 获取当前租户ID


        LoginUser loginUser = SecurityUtils.getLoginUser();


        Long tenantId = loginUser.getTenantId();




        // 批量保存新的共享记录


        List<CustomerUser> customerUsers = newUserIds.stream()


                .map(userId -> {


                    CustomerUser customerUser = new CustomerUser();


                    customerUser.setCustomerId(customerDto.getId());


                    customerUser.setUserId(userId);


                    customerUser.setTenantId(tenantId);


                    return customerUser;


                })


                .collect(Collectors.toList());




        customerUserService.saveBatch(customerUsers);


    }




    /**


     * 下划线命名转驼峰命名


     */