blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
云
4 天以前 84ac2b6b12bc3e5de072661fb25e87877c01d0d7 
 yudao-module-crm/src/main/java/cn/iocoder/yudao/module/crm/service/contract/CrmContractServiceImpl.java


@@ -10,6 +10,9 @@


import cn.iocoder.yudao.framework.common.util.object.ObjectUtils;


import cn.iocoder.yudao.module.bpm.api.task.BpmProcessInstanceApi;


import cn.iocoder.yudao.module.bpm.api.task.dto.BpmProcessInstanceCreateReqDTO;


import cn.iocoder.yudao.module.bpm.dal.dataobject.definition.BpmProcessDefinitionInfoDO;


import cn.iocoder.yudao.module.bpm.service.definition.BpmCategoryService;


import cn.iocoder.yudao.module.bpm.service.definition.BpmProcessDefinitionService;


import cn.iocoder.yudao.module.crm.controller.admin.contract.vo.contract.CrmContractPageReqVO;


import cn.iocoder.yudao.module.crm.controller.admin.contract.vo.contract.CrmContractSaveReqVO;


import cn.iocoder.yudao.module.crm.controller.admin.contract.vo.contract.CrmContractTransferReqVO;


@@ -25,11 +28,11 @@


import cn.iocoder.yudao.module.crm.framework.permission.core.annotations.CrmPermission;


import cn.iocoder.yudao.module.crm.service.business.CrmBusinessService;


import cn.iocoder.yudao.module.crm.service.contact.CrmContactService;


import cn.iocoder.yudao.module.crm.api.customer.CrmCustomerApi;


import cn.iocoder.yudao.module.crm.service.customer.CrmCustomerService;


import cn.iocoder.yudao.module.crm.service.permission.CrmPermissionService;


import cn.iocoder.yudao.module.crm.service.permission.bo.CrmPermissionCreateReqBO;


import cn.iocoder.yudao.module.crm.service.permission.bo.CrmPermissionTransferReqBO;


import cn.iocoder.yudao.module.crm.service.product.CrmProductService;


import cn.iocoder.yudao.module.crm.service.receivable.CrmReceivableService;


import cn.iocoder.yudao.module.erp.api.sale.ErpSaleOrderApi;


import cn.iocoder.yudao.module.erp.api.sale.dto.ErpSaleOrderCreateReqDTO;


@@ -49,10 +52,15 @@




import java.math.BigDecimal;


import java.time.LocalDateTime;


import java.util.ArrayList;


import java.util.Collection;


import java.util.Collections;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.Set;




import org.flowable.engine.repository.ProcessDefinition;




import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;


import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.*;


@@ -75,6 +83,11 @@


     */


    public static final String BPM_PROCESS_DEFINITION_KEY = "crm-contract-audit";




    /**


     * BPM 合同审批分类编码


     */


    private static final String CONTRACT_APPROVE_CATEGORY_CODE = "contract_approve";




    @Resource


    private CrmContractMapper contractMapper;


    @Resource


@@ -86,9 +99,9 @@


    @Resource


    private CrmPermissionService crmPermissionService;


    @Resource


    private CrmProductService productService;


    @Resource


    private CrmCustomerService customerService;


    @Resource


    private CrmCustomerApi customerApi;


    @Resource


    private CrmBusinessService businessService;


    @Resource


@@ -102,6 +115,10 @@


    private AdminUserApi adminUserApi;


    @Resource


    private BpmProcessInstanceApi bpmProcessInstanceApi;


    @Resource


    private BpmCategoryService bpmCategoryService;


    @Resource


    private BpmProcessDefinitionService bpmProcessDefinitionService;


    @Resource


    private ErpSaleOrderApi saleOrderApi;


    @Resource


@@ -123,7 +140,9 @@


        }




        // 2.1 插入合同


        CrmContractDO contract = BeanUtils.toBean(createReqVO, CrmContractDO.class).setNo(no);


        CrmContractDO contract = BeanUtils.toBean(createReqVO, CrmContractDO.class)


                .setNo(no)


                .setAuditStatus(CrmAuditStatusEnum.DRAFT.getStatus()); // 默认为未提交状态


        calculateTotalPrice(contract, contractProducts);


        contractMapper.insert(contract);


        // 2.2 插入合同关联商品


@@ -308,23 +327,98 @@


    @Transactional(rollbackFor = Exception.class)


    @LogRecord(type = CRM_CONTRACT_TYPE, subType = CRM_CONTRACT_SUBMIT_SUB_TYPE, bizNo = "{{#id}}",


            success = CRM_CONTRACT_SUBMIT_SUCCESS)


    public void submitContract(Long id, Long userId) {


    public void submitContract(Long id, String processDefinitionKey, Long userId) {


        // 1. 校验合同是否在审批


        CrmContractDO contract = validateContractExists(id);


        if (ObjUtil.notEqual(contract.getAuditStatus(), CrmAuditStatusEnum.DRAFT.getStatus())) {


            throw exception(CONTRACT_SUBMIT_FAIL_NOT_DRAFT);


        }




        // 2. 创建合同审批流程实例


        String processInstanceId = bpmProcessInstanceApi.createProcessInstance(userId, new BpmProcessInstanceCreateReqDTO()


                .setProcessDefinitionKey(BPM_PROCESS_DEFINITION_KEY).setBusinessKey(String.valueOf(id)));


        // 2. 校验分类和流程定义是否存在


        validateContractApproveCategoryAndProcessDefinition();




        // 3. 更新合同工作流编号


        // 3. 校验传入的流程定义 Key 是否属于该分类且处于激活状态


        ProcessDefinition processDefinition = bpmProcessDefinitionService.getActiveProcessDefinition(processDefinitionKey);


        if (processDefinition == null) {


            throw exception(CONTRACT_BPM_PROCESS_DEFINITION_NOT_EXISTS);


        }




        // 4. 创建合同审批流程实例


        String processInstanceId = bpmProcessInstanceApi.createProcessInstance(userId, new BpmProcessInstanceCreateReqDTO()


                .setProcessDefinitionKey(processDefinitionKey).setBusinessKey(String.valueOf(id)));




        // 5. 更新合同工作流编号


        contractMapper.updateById(new CrmContractDO().setId(id).setProcessInstanceId(processInstanceId)


                .setAuditStatus(CrmAuditStatusEnum.PROCESS.getStatus()));




        // 3. 记录日志


        // 6. 记录日志


        LogRecordContext.putVariable("contractName", contract.getName());


    }




    /**


     * 校验 BPM 合同审批分类和流程定义是否存在


     */


    private void validateContractApproveCategoryAndProcessDefinition() {


        // 1. 校验分类是否存在


        List<String> codes = Collections.singletonList(CONTRACT_APPROVE_CATEGORY_CODE);


        Map<String, ?> categoryMap = bpmCategoryService.getCategoryMap(codes);


        if (!categoryMap.containsKey(CONTRACT_APPROVE_CATEGORY_CODE)) {


            throw exception(CONTRACT_BPM_PROCESS_DEFINITION_NOT_EXISTS);


        }




        // 2. 校验分类下是否有可用的流程定义


        List<BpmProcessDefinitionInfoDO> definitionInfoList = bpmProcessDefinitionService


                .getProcessDefinitionInfoListByCategory(CONTRACT_APPROVE_CATEGORY_CODE);


        if (CollUtil.isEmpty(definitionInfoList)) {


            throw exception(CONTRACT_BPM_PROCESS_DEFINITION_NOT_EXISTS);


        }




        // 3. 校验是否有激活状态的流程定义


        Set<String> processDefinitionIds = convertSet(definitionInfoList, BpmProcessDefinitionInfoDO::getProcessDefinitionId);


        List<ProcessDefinition> processDefinitions = bpmProcessDefinitionService.getProcessDefinitionList(processDefinitionIds);


        boolean hasActiveDefinition = processDefinitions.stream()


                .anyMatch(pd -> !pd.isSuspended());


        if (!hasActiveDefinition) {


            throw exception(CONTRACT_BPM_PROCESS_DEFINITION_NOT_EXISTS);


        }


    }




    @Override


    public List<Map<String, Object>> getContractApproveProcessDefinitionList() {


        // 1. 校验分类和流程定义是否存在


        validateContractApproveCategoryAndProcessDefinition();




        // 2. 获取分类下的流程定义信息


        List<BpmProcessDefinitionInfoDO> definitionInfoList = bpmProcessDefinitionService


                .getProcessDefinitionInfoListByCategory(CONTRACT_APPROVE_CATEGORY_CODE);




        // 3. 获取流程定义详情


        Set<String> processDefinitionIds = convertSet(definitionInfoList, BpmProcessDefinitionInfoDO::getProcessDefinitionId);


        List<ProcessDefinition> processDefinitions = bpmProcessDefinitionService.getProcessDefinitionList(processDefinitionIds);




        // 4. 过滤：只保留激活状态，且相同 key 只保留最新版本


        Map<String, ProcessDefinition> latestVersionMap = new HashMap<>();


        for (ProcessDefinition pd : processDefinitions) {


            if (pd.isSuspended()) {


                continue;


            }


            ProcessDefinition existing = latestVersionMap.get(pd.getKey());


            if (existing == null || pd.getVersion() > existing.getVersion()) {


                latestVersionMap.put(pd.getKey(), pd);


            }


        }




        // 5. 返回流程定义列表


        List<Map<String, Object>> result = new ArrayList<>();


        for (ProcessDefinition pd : latestVersionMap.values()) {


            Map<String, Object> item = new HashMap<>();


            item.put("id", pd.getId());


            item.put("key", pd.getKey());


            item.put("name", pd.getName());


            item.put("version", pd.getVersion());


            result.add(item);


        }


        return result;


    }




    @Override


@@ -377,8 +471,10 @@


                return PageResult.empty();


            }


        }


        // 2. 查询分页


        return contractMapper.selectPage(pageReqVO, userId, config);


        // 2. 获取用户有权限的客户 ID 列表


        List<Long> permittedCustomerIds = customerApi.getPermittedCustomerIds();


        // 3. 查询分页


        return contractMapper.selectPage(pageReqVO, userId, config, permittedCustomerIds);


    }




    @Override


@@ -462,7 +558,8 @@


        createReqDTO.setContractNo(contract.getNo());


        createReqDTO.setSaleUserId(contract.getOwnerUserId());


        createReqDTO.setOrderTime(LocalDateTime.now().toString());


        createReqDTO.setDiscountPercent(contract.getDiscountPercent());


        createReqDTO.setDiscountPercent(contract.getDiscountPercent() != null ? contract.getDiscountPercent() : BigDecimal.ZERO);


        createReqDTO.setDepositPrice(contract.getDepositPrice() != null ? contract.getDepositPrice() : BigDecimal.ZERO);


        createReqDTO.setRemark("由合同【" + contract.getNo() + "】自动生成");




        // 5. 构建订单项


@@ -494,4 +591,21 @@


        return orderId;


    }




    @Override


    public void updateContractStatus(Long id, Integer status) {


        contractMapper.updateById(new CrmContractDO()


                .setId(id)


                .setAuditStatus(status));


    }




    @Override


    public void updateContractStatusByOrderId(Long orderId, Integer status) {


        CrmContractDO contract = contractMapper.selectByOrderId(orderId);


        if (contract != null) {


            contractMapper.updateById(new CrmContractDO()


                    .setId(contract.getId())


                    .setAuditStatus(status));


        }


    }




}