yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/wm/productissue/MesWmProductIssueLineController.java
@@ -12,14 +12,14 @@ import cn.iocoder.yudao.module.mes.controller.admin.wm.productissue.vo.line.MesWmProductIssueLineSaveReqVO; import cn.iocoder.yudao.module.mdm.api.item.MdmItemModelApi; import cn.iocoder.yudao.module.mdm.api.item.dto.MdmItemModelRespDTO; 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.task.MesProTaskDO; 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.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.task.MesProTaskService; import cn.iocoder.yudao.module.mes.service.pro.workorder.MesProWorkOrderBomService; import cn.iocoder.yudao.module.mes.service.wm.productissue.MesWmProductIssueLineService; @@ -58,7 +58,7 @@ @Resource private MesProWorkOrderBomService workOrderBomService; @Resource private MesMdItemService mdmItemService; private MesMdmItemService mdmItemService; @Resource private MesMdUnitMeasureService unitMeasureService; @Resource @@ -143,12 +143,12 @@ requiredQtyMap.merge(bom.getItemId(), quantity, BigDecimal::add); } // 3. 批量获取物料与单位信息，拼接 VO Map<Long, MesMdItemDO> itemMap = mdmItemService.getItemMap(requiredQtyMap.keySet()); Map<Long, MesMdmItemDO> itemMap = mdmItemService.getItemMap(requiredQtyMap.keySet()); Map<Long, MesMdUnitMeasureDO> unitMeasureMap = unitMeasureService.getUnitMeasureMap( convertSet(itemMap.values(), MesMdItemDO::getUnitMeasureId)); convertSet(itemMap.values(), MesMdmItemDO::getUnitMeasureId)); List<MesWmProductIssueBomItemRespVO> result = new ArrayList<>(requiredQtyMap.size()); requiredQtyMap.forEach((itemId, requiredQuantity) -> { MesMdItemDO item = itemMap.get(itemId); MesMdmItemDO item = itemMap.get(itemId); if (item == null) { return; } @@ -178,10 +178,10 @@ return Collections.emptyList(); } // 1. 获得关联数据 Map<Long, MesMdItemDO> itemMap = mdmItemService.getItemMap( Map<Long, MesMdmItemDO> itemMap = mdmItemService.getItemMap( convertSet(list, MesWmProductIssueLineDO::getItemId)); // 物料主单位与录入单位都要解析名称 Set<Long> unitMeasureIds = new HashSet<>(convertSet(itemMap.values(), MesMdItemDO::getUnitMeasureId)); Set<Long> unitMeasureIds = new HashSet<>(convertSet(itemMap.values(), MesMdmItemDO::getUnitMeasureId)); unitMeasureIds.addAll(convertSet(list, MesWmProductIssueLineDO::getEnterUnitMeasureId)); Map<Long, MesMdUnitMeasureDO> unitMeasureMap = unitMeasureService.getUnitMeasureMap(unitMeasureIds); Map<Long, MdmItemModelRespDTO> itemModelMap = mdmItemModelApi.getItemModelMap( @@ -191,7 +191,7 @@ // 2. 构建结果 return BeanUtils.toBean(list, MesWmProductIssueLineRespVO.class, vo -> { MapUtils.findAndThen(itemMap, vo.getItemId(), item -> { vo.setItemCode(item.getCode()).setItemName(item.getName()).setSpecification(item.getSpecification()).setMdmItemId(item.getMdmItemId()); vo.setItemCode(item.getCode()).setItemName(item.getName()).setSpecification(item.getSpecification()).setMdmItemId(item.getId()); vo.setUnitMeasureId(item.getUnitMeasureId()); MapUtils.findAndThen(unitMeasureMap, item.getUnitMeasureId(), unit -> vo.setUnitMeasureName(unit.getName())); yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/wm/productissue/MesWmProductIssueDetailServiceImpl.java
@@ -4,23 +4,23 @@ import cn.iocoder.yudao.framework.common.util.object.BeanUtils; import cn.iocoder.yudao.framework.common.util.object.ObjectUtils; import cn.iocoder.yudao.module.mes.controller.admin.wm.productissue.vo.detail.MesWmProductIssueDetailSaveReqVO; import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemDO; import cn.iocoder.yudao.module.mes.dal.dataobject.mdm.MesMdmItemDO; import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productissue.MesWmProductIssueDetailDO; 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.mysql.wm.productissue.MesWmProductIssueDetailMapper; 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.mdm.MesMdmItemService; import cn.iocoder.yudao.module.mes.service.wm.materialstock.MesWmMaterialStockService; import cn.iocoder.yudao.module.mes.service.wm.warehouse.MesWmWarehouseAreaService; import jakarta.annotation.Resource; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; import org.springframework.validation.annotation.Validated; import java.util.List; 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.*; @@ -46,7 +46,7 @@ @Resource private MesWmMaterialStockService materialStockService; @Resource private MesMdItemService mesMdItemService; private MesMdmItemService mdmItemService; @Override public Long createProductIssueDetail(MesWmProductIssueDetailSaveReqVO createReqVO) { @@ -128,7 +128,6 @@ private void validateProductIssueDetailSaveData(MesWmProductIssueDetailSaveReqVO reqVO) { // 校验父数据存在 MesWmProductIssueLineDO line = issueLineService.validateProductIssueLineExists(reqVO.getLineId()); MesMdItemDO item = mesMdItemService.getItem(line.getItemId()); if (ObjUtil.notEqual(line.getIssueId(), reqVO.getIssueId())) { throw exception(WM_PRODUCT_ISSUE_DETAIL_LINE_NOT_MATCH); } @@ -137,8 +136,8 @@ if (ObjUtil.notEqual(MesWmProductIssueStatusEnum.APPROVING.getStatus(), issue.getStatus())) { throw exception(WM_PRODUCT_ISSUE_STATUS_INVALID); } // 校验物料匹配（明细 itemId 必须与行 itemId 一致） validateDetailItemMatch(reqVO.getItemId(), item.getMdmItemId()); // 校验物料匹配（明细 itemId 必须与行 itemId 一致，两者都是 MDM 物料主数据 mdm_item.id） validateDetailItemMatch(reqVO.getItemId(), line.getItemId()); // 校验仓库、库区、库位的关联关系 warehouseAreaService.validateWarehouseAreaExists( reqVO.getWarehouseId(), reqVO.getLocationId(), reqVO.getAreaId()); @@ -153,8 +152,23 @@ */ private void validateDetailItemMatch(Long detailItemId, Long lineItemId) { if (ObjUtil.notEqual(detailItemId, lineItemId)) { throw exception(WM_PRODUCT_ISSUE_DETAIL_ITEM_MISMATCH); // 名称解析放在异常分支，避免正常保存时多查表 throw new ServiceException(WM_PRODUCT_ISSUE_DETAIL_ITEM_MISMATCH.getCode(), "拣货明细的物料与领料出库单行的物料不一致：明细物料[" + describeItem(detailItemId) + "]，单据行物料[" + describeItem(lineItemId) + "]。" + "请重新选择该行的物料后重试，或删除本条明细后重新添加。"); } } /** * 描述物料，用于异常提示：优先给出「编码 名称」，查不到时回退为物料编号 */ private String describeItem(Long itemId) { if (itemId == null) { return "未选择"; } MesMdmItemDO item = mdmItemService.getItem(itemId); return item != null ? item.getCode() + " " + item.getName() : "物料编号 ID=" + itemId; } } yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/wm/productissue/MesWmProductIssueLineServiceImpl.java
@@ -9,16 +9,16 @@ 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; @@ -35,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.*; @@ -53,7 +55,7 @@ @Lazy private MesWmProductIssueService issueService; @Resource private MesMdItemService mdmItemService; private MesMdmItemService mdmItemService; @Resource @Lazy private MesWmReturnIssueLineService returnIssueLineService; @@ -158,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) { @@ -206,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<>(); @@ -226,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()); yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/wm/productissue/MesWmProductIssueServiceImpl.java
@@ -8,7 +8,7 @@ import cn.iocoder.yudao.framework.common.util.object.ObjectUtils; import cn.iocoder.yudao.module.mes.controller.admin.wm.productissue.vo.MesWmProductIssuePageReqVO; import cn.iocoder.yudao.module.mes.controller.admin.wm.productissue.vo.MesWmProductIssueSaveReqVO; import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemDO; import cn.iocoder.yudao.module.mes.dal.dataobject.mdm.MesMdmItemDO; import cn.iocoder.yudao.module.mes.dal.dataobject.pro.task.MesProTaskDO; import cn.iocoder.yudao.module.mes.dal.dataobject.pro.task.MesProTaskIssueDO; import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productissue.MesWmProductIssueDetailDO; @@ -20,8 +20,8 @@ import cn.iocoder.yudao.module.mes.enums.wm.MesWmProductIssueStatusEnum; import cn.iocoder.yudao.module.mes.enums.wm.MesWmStockReserveBizTypeEnum; import cn.iocoder.yudao.module.mes.enums.wm.MesWmTransactionTypeEnum; import cn.iocoder.yudao.module.mes.service.md.item.MesMdItemService; import cn.iocoder.yudao.module.mes.service.md.workstation.MesMdWorkstationService; import cn.iocoder.yudao.module.mes.service.mdm.MesMdmItemService; import cn.iocoder.yudao.module.mes.service.pro.task.MesProTaskIssueService; import cn.iocoder.yudao.module.mes.service.pro.task.MesProTaskService; import cn.iocoder.yudao.module.mes.service.pro.workorder.MesProWorkOrderService; @@ -72,7 +72,7 @@ @Resource private MesProTaskIssueMapper taskIssueMapper; @Resource private MesMdItemService mdmItemService; private MesMdmItemService mdmItemService; @Resource private MesWmTransactionService wmTransactionService; @Resource @@ -275,7 +275,7 @@ } // 批量查询物料信息（获取 unitMeasureId） Map<Long, MesMdItemDO> itemMap = mdmItemService.getItemMap( Map<Long, MesMdmItemDO> itemMap = mdmItemService.getItemMap( CollectionUtils.convertSet(lines, MesWmProductIssueLineDO::getItemId)); // 获取明细列表，用于提取 batchCode @@ -291,7 +291,7 @@ } // 获取物料单位 MesMdItemDO item = itemMap.get(line.getItemId()); MesMdmItemDO item = itemMap.get(line.getItemId()); Long unitMeasureId = item != null ? item.getUnitMeasureId() : null; // 获取批次号：取该行第一个明细的 batchCode
