feat(bpm): 全部业务审批流改回 BPM，审批统一进入协同办公

liu

2026-10-23 5421b8af862890dcf187c2ad5ece55423959ba85

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pd/techconfirm/ProductTechConfirmServiceImpl.java

@@ -1,8 +1,17 @@
package cn.iocoder.yudao.module.mes.service.pd.techconfirm;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.framework.common.exception.ServiceException;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
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.enums.task.BpmTaskStatusEnum;
import cn.iocoder.yudao.module.crm.api.customer.CrmCustomerApi;
import cn.iocoder.yudao.module.crm.api.customer.dto.CrmCustomerRespDTO;
import cn.iocoder.yudao.module.mes.controller.admin.pd.techconfirm.vo.ProductTechConfirmImportExcelVO;
import cn.iocoder.yudao.module.mes.controller.admin.pd.techconfirm.vo.ProductTechConfirmImportRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.pd.techconfirm.vo.ProductTechConfirmPageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.pd.techconfirm.vo.ProductTechConfirmSaveReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pd.techconfirm.ProductTechConfirmDO;
@@ -18,7 +27,11 @@
import org.springframework.validation.annotation.Validated;

import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Set;
import java.util.concurrent.atomic.AtomicInteger;

import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils.getLoginUserId;
@@ -50,14 +63,25 @@
     */
    private static final String TECH_CONFIRM_APPROVE_BIZ_TYPE = "pd_tech_confirm_approve";

    /**
     * 技术确认函审批的 BPM 流程定义 Key
     */
    private static final String TECH_CONFIRM_APPROVE_PROCESS_KEY = "pd_tech_confirm_approve";

    @Resource
    private ProductTechConfirmMapper techConfirmMapper;

    @Resource
    private BpmProcessInstanceApi bpmProcessInstanceApi;

    @Resource
    private AdminUserApi adminUserApi;

    @Resource
    private ApprovalConfigApi approvalConfigApi;

    @Resource
    private CrmCustomerApi customerApi;

    @Override
    @Transactional(rollbackFor = Exception.class)
@@ -132,6 +156,30 @@
        //    用 UpdateWrapper 而非 updateById：MyBatis-Plus 默认更新策略会忽略 null，
        //    直接 updateById 无法把审核不通过后残留的审核人 / 审核时间 / 审核意见真正清空。
        techConfirmMapper.submitAndResetAuditInfo(id, MesPdTechConfirmStatusEnum.PENDING_AUDIT.getStatus());
        // 4. 创建 BPM 流程实例，使审批出现在「协同办公 - 我的流程」
        bpmProcessInstanceApi.createProcessInstance(getLoginUserId(),
                new BpmProcessInstanceCreateReqDTO()
                        .setProcessDefinitionKey(TECH_CONFIRM_APPROVE_PROCESS_KEY)
                        .setBusinessKey(String.valueOf(id)));
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateTechConfirmAuditStatus(Long id, Integer bpmStatus, String reason) {
        // BPM 审批结果映射为确认函状态：通过=已审核 / 不通过=审核不通过（可修改后重新提交）
        Integer status;
        if (BpmTaskStatusEnum.APPROVE.getStatus().equals(bpmStatus)) {
            status = MesPdTechConfirmStatusEnum.AUDITED.getStatus();
        } else if (BpmTaskStatusEnum.REJECT.getStatus().equals(bpmStatus)) {
            status = MesPdTechConfirmStatusEnum.REJECTED.getStatus();
        } else {
            // 技术确认函没有「已取消」状态，其余 BPM 结果（如撤消）忽略
            log.warn("[updateTechConfirmAuditStatus] 忽略不支持的 BPM 状态({})，techConfirmId={}", bpmStatus, id);
            return;
        }
        if (techConfirmMapper.updateAuditStatusByBpm(id, status, reason) != 1) {
            log.warn("[updateTechConfirmAuditStatus] 技术确认函({}) 不处于待审核状态，忽略 BPM 结果({})", id, bpmStatus);
        }
    }

    @Override
@@ -182,6 +230,56 @@
                .build());
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public ProductTechConfirmImportRespVO importTechConfirmList(List<ProductTechConfirmImportExcelVO> importList, boolean updateSupport) {
        if (CollUtil.isEmpty(importList)) {
            throw exception(PD_TECH_CONFIRM_IMPORT_LIST_IS_EMPTY);
        }
        ProductTechConfirmImportRespVO respVO = ProductTechConfirmImportRespVO.builder()
                .createCodes(new ArrayList<>()).updateCodes(new ArrayList<>())
                .failureCodes(new LinkedHashMap<>()).build();
        AtomicInteger index = new AtomicInteger(1);
        importList.forEach(importItem -> {
            int currentIndex = index.getAndIncrement();
            String key = StrUtil.blankToDefault(importItem.getConfirmNo(), "第 " + currentIndex + " 行");
            if (StrUtil.isBlank(importItem.getConfirmNo())) {
                respVO.getFailureCodes().put(key, "确认函编号不能为空");
                return;
            }
            // 1. 解析客户名称
            Long customerId = null;
            if (StrUtil.isNotBlank(importItem.getCustomerName())) {
                CrmCustomerRespDTO customer = customerApi.getCustomerByName(importItem.getCustomerName().trim());
                if (customer == null) {
                    respVO.getFailureCodes().put(key, "客户名称[" + importItem.getCustomerName() + "]不存在");
                    return;
                }
                customerId = customer.getId();
            }
            // 2. 构建请求并创建/更新（复用现有 create/update 服务，状态由 create 固定为草稿）
            ProductTechConfirmSaveReqVO reqVO = BeanUtils.toBean(importItem, ProductTechConfirmSaveReqVO.class);
            reqVO.setCustomerId(customerId);
            try {
                ProductTechConfirmDO exist = techConfirmMapper.selectByConfirmNo(importItem.getConfirmNo().trim());
                if (exist == null) {
                    reqVO.setId(null);
                    createTechConfirm(reqVO);
                    respVO.getCreateCodes().add(importItem.getConfirmNo());
                } else if (updateSupport) {
                    reqVO.setId(exist.getId());
                    updateTechConfirm(reqVO);
                    respVO.getUpdateCodes().add(importItem.getConfirmNo());
                } else {
                    respVO.getFailureCodes().put(key, "确认函编号已存在");
                }
            } catch (ServiceException e) {
                respVO.getFailureCodes().put(key, e.getMessage());
            }
        });
        return respVO;
    }

    /**
     * 获取用户昵称
     *
@@ -197,8 +295,9 @@
    }

    private void validateConfirmNoUnique(String confirmNo, Long excludeId) {
        if (confirmNo == null) {
            return;
        // 确认函编号必填：VO 上的 @NotBlank 只覆盖接口入参，Service 内（含导入）仍需显式校验
        if (StrUtil.isBlank(confirmNo)) {
            throw exception(PD_TECH_CONFIRM_NO_REQUIRED);
        }
        ProductTechConfirmDO techConfirm = techConfirmMapper.selectOne(
                ProductTechConfirmDO::getConfirmNo, confirmNo);