fix(wm/productissue): 修复物料匹配校验逻辑并迁移至 MDM 物料服务

gaoluyang

15 小时以前 bc9d77f6061a5c7f7deceaabc7c5ed6c17ad8c2f

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/wm/productissue/MesWmProductIssueLineServiceImpl.java

@@ -9,21 +9,22 @@
import cn.iocoder.yudao.module.mes.controller.admin.wm.productissue.vo.line.MesWmProductIssueLineRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.wm.productissue.vo.line.MesWmProductIssueLineReturnableRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.wm.productissue.vo.line.MesWmProductIssueLineSaveReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.md.unitmeasure.MesMdUnitMeasureDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.mdm.MesMdmItemDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.workorder.MesProWorkOrderBomDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productissue.MesWmProductIssueDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productissue.MesWmProductIssueLineDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.returnissue.MesWmReturnIssueLineDO;
import cn.iocoder.yudao.module.mes.dal.mysql.wm.productissue.MesWmProductIssueLineMapper;
import cn.iocoder.yudao.module.mes.enums.wm.MesWmProductIssueStatusEnum;
import cn.iocoder.yudao.module.mes.service.md.item.MesMdItemService;
import cn.iocoder.yudao.module.mes.service.md.unitmeasure.MesMdUnitMeasureService;
import cn.iocoder.yudao.module.mes.service.mdm.MesMdmItemService;
import cn.iocoder.yudao.module.mes.service.pro.workorder.MesProWorkOrderBomService;
import cn.iocoder.yudao.module.mes.service.wm.productissue.MesWmProductIssueDetailService;
import cn.iocoder.yudao.module.mes.service.wm.productissue.MesWmProductIssueLineService;
import cn.iocoder.yudao.module.mes.service.wm.productissue.MesWmProductIssueService;
import cn.iocoder.yudao.module.mes.service.wm.returnissue.MesWmReturnIssueLineService;
import cn.iocoder.yudao.module.mes.service.wm.unitconvert.MesWmItemUnitConvertService;
import jakarta.annotation.Resource;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
@@ -34,6 +35,8 @@
import java.util.Collections;
import java.util.List;
import java.util.Map;

import cn.iocoder.yudao.framework.common.exception.ServiceException;

import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;
@@ -52,7 +55,7 @@
    @Lazy
    private MesWmProductIssueService issueService;
    @Resource
    private MesMdItemService mdmItemService;
    private MesMdmItemService mdmItemService;
    @Resource
    @Lazy
    private MesWmReturnIssueLineService returnIssueLineService;
@@ -63,10 +66,14 @@
    private MesWmProductIssueDetailService issueDetailService;
    @Resource
    private MesProWorkOrderBomService workOrderBomService;
    @Resource
    private MesWmItemUnitConvertService itemUnitConvertService;

    @Override
    public Long createProductIssueLine(MesWmProductIssueLineSaveReqVO createReqVO) {
        validateProductIssueLineSaveData(createReqVO);
        // 双单位换算：按录入单位换算为物料主单位数量
        fillPrimaryQuantity(createReqVO);

        // 插入
        MesWmProductIssueLineDO line = BeanUtils.toBean(createReqVO, MesWmProductIssueLineDO.class);
@@ -79,10 +86,31 @@
        // 校验存在
        validateProductIssueLineExists(updateReqVO.getId());
        validateProductIssueLineSaveData(updateReqVO);
        // 双单位换算：按录入单位换算为物料主单位数量
        fillPrimaryQuantity(updateReqVO);

        // 更新
        MesWmProductIssueLineDO updateObj = BeanUtils.toBean(updateReqVO, MesWmProductIssueLineDO.class);
        issueLineMapper.updateById(updateObj);
    }

    /**
     * 双单位换算：选择了录入单位时，按「录入数量 × 换算比率」得到物料主单位口径的领料数量
     *
     * 未按辅单位录入时必须直接填写领料数量
     */
    private void fillPrimaryQuantity(MesWmProductIssueLineSaveReqVO reqVO) {
        if (reqVO.getEnterUnitMeasureId() != null) {
            BigDecimal primaryQuantity = itemUnitConvertService.convertToPrimaryUnit(
                    reqVO.getItemId(), reqVO.getItemModelId(),
                    reqVO.getEnterUnitMeasureId(), reqVO.getEnterQuantity());
            if (primaryQuantity != null) {
                reqVO.setQuantity(primaryQuantity);
            }
        }
        if (reqVO.getQuantity() == null) {
            throw exception(WM_PRODUCT_ISSUE_LINE_QUANTITY_REQUIRED);
        }
    }

    @Override
@@ -132,10 +160,30 @@
    private void validateProductIssueLineSaveData(MesWmProductIssueLineSaveReqVO reqVO) {
        // 校验父数据存在 + 草稿状态才允许新增/修改行
        issueService.validateProductIssueExistsAndPrepare(reqVO.getIssueId());
        // 校验物料存在且启用（itemId 口径为 MDM 物料主数据 mdm_item.id）
        validateIssueItemExistsAndEnable(reqVO.getItemId());
        // 校验物料在工单 BOM 中
        validateItemInWorkOrderBom(reqVO.getIssueId(), reqVO.getItemId());
        // 校验物料存在
        mdmItemService.validateItemExists(reqVO.getItemId());
    }

    /**
     * 校验领料物料在 MDM 物料主数据中存在且已启用
     *
     * 分别给出「查不到该物料」「物料已停用」两种具体原因，并带上物料的业务标识与下一步动作，
     * 避免统一抛出笼统的“物料不存在”让用户无从判断。
     */
    private void validateIssueItemExistsAndEnable(Long itemId) {
        MesMdmItemDO item = mdmItemService.getItem(itemId);
        if (item == null) {
            throw new ServiceException(MD_ITEM_NOT_EXISTS.getCode(),
                    "领料出库单行物料不存在：提交的物料编号[ID=" + itemId + "]在 MDM 物料主数据中查不到。"
                            + "请重新选择物料；若该物料已被删除，请改选其它物料。");
        }
        if (item.getStatus() != null && item.getStatus() == 1) {
            throw new ServiceException(MD_ITEM_IS_DISABLE.getCode(),
                    "领料出库单行物料已停用：物料[" + item.getCode() + " " + item.getName() + "]当前为停用状态，不能领料出库。"
                            + "请先在「基础数据 - MDM 物料」中启用该物料，或改选其它已启用的物料。");
        }
    }

    private void validateItemInWorkOrderBom(Long issueId, Long itemId) {
@@ -180,10 +228,10 @@
        }

        // 4. 批量查询物料和单位信息
        Map<Long, MesMdItemDO> itemMap = mdmItemService.getItemMap(
        Map<Long, MesMdmItemDO> itemMap = mdmItemService.getItemMap(
                CollectionUtils.convertSet(lines, MesWmProductIssueLineDO::getItemId));
        Map<Long, MesMdUnitMeasureDO> unitMap = unitMeasureService.getUnitMeasureMap(
                CollectionUtils.convertSet(itemMap.values(), MesMdItemDO::getUnitMeasureId));
                CollectionUtils.convertSet(itemMap.values(), MesMdmItemDO::getUnitMeasureId));

        // 5. 组装结果，过滤可退数量 > 0 的行
        List<MesWmProductIssueLineReturnableRespVO> result = new ArrayList<>();
@@ -200,7 +248,7 @@
                vo.setQuantity(returnableQty);

                // 填充物料信息
                MesMdItemDO item = itemMap.get(line.getItemId());
                MesMdmItemDO item = itemMap.get(line.getItemId());
                if (item != null) {
                    vo.setItemCode(item.getCode());
                    vo.setItemName(item.getName());