From eccad5a129106377a275be4f7cdc58e99e9b95d4 Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期二, 21 七月 2026 13:45:14 +0800
Subject: [PATCH] feat(mes): 实现库存移库功能

---
 yudao-module-mdm/src/main/java/cn/iocoder/yudao/module/mdm/service/item/MdmItemServiceImpl.java |  369 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 369 insertions(+), 0 deletions(-)

diff --git a/yudao-module-mdm/src/main/java/cn/iocoder/yudao/module/mdm/service/item/MdmItemServiceImpl.java b/yudao-module-mdm/src/main/java/cn/iocoder/yudao/module/mdm/service/item/MdmItemServiceImpl.java
new file mode 100644
index 0000000..5acea4b
--- /dev/null
+++ b/yudao-module-mdm/src/main/java/cn/iocoder/yudao/module/mdm/service/item/MdmItemServiceImpl.java
@@ -0,0 +1,369 @@
+package cn.iocoder.yudao.module.mdm.service.item;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.ObjUtil;
+import cn.iocoder.yudao.framework.common.pojo.CommonResult;
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
+import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
+import cn.iocoder.yudao.module.mdm.controller.admin.item.vo.MdmItemPageReqVO;
+import cn.iocoder.yudao.module.mdm.controller.admin.item.vo.MdmItemSaveReqVO;
+import cn.iocoder.yudao.module.mdm.dal.dataobject.category.MdmItemCategoryDO;
+import cn.iocoder.yudao.module.mdm.dal.dataobject.item.MdmItemDO;
+import cn.iocoder.yudao.module.mdm.dal.dataobject.unit.MdmUnitMeasureDO;
+import cn.iocoder.yudao.module.mdm.dal.mysql.item.MdmItemBatchConfigMapper;
+import cn.iocoder.yudao.module.mdm.dal.mysql.item.MdmItemMapper;
+import cn.iocoder.yudao.module.mdm.service.brand.MdmBrandService;
+import cn.iocoder.yudao.module.mdm.service.category.MdmItemCategoryService;
+import cn.iocoder.yudao.module.mdm.service.unit.MdmUnitMeasureService;
+import cn.iocoder.yudao.module.mes.api.item.MesMdItemApi;
+import cn.iocoder.yudao.module.mes.api.item.MesMdItemTypeApi;
+import cn.iocoder.yudao.module.mes.api.item.dto.MesMdItemSyncReqDTO;
+import cn.iocoder.yudao.module.mes.api.item.dto.MesMdItemTypeRespDTO;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+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.transaction.annotation.Transactional;
+import org.springframework.validation.annotation.Validated;
+
+import java.util.*;
+import java.util.stream.Collectors;
+
+import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertSet;
+import static cn.iocoder.yudao.module.mdm.enums.ErrorCodeConstants.*;
+
+/**
+ * MDM 鐗╂枡涓绘暟鎹� Service 瀹炵幇绫�
+ *
+ * @author 鑺嬮亾婧愮爜
+ */
+@Service
+@Validated
+public class MdmItemServiceImpl implements MdmItemService {
+
+    @Resource
+    private MdmItemMapper itemMapper;
+
+    @Resource
+    private MdmItemCategoryService itemCategoryService;
+    @Resource
+    private MdmUnitMeasureService unitMeasureService;
+    @Resource
+    private MdmBrandService brandService;
+
+    @Resource
+    @Lazy
+    private MesMdItemApi mesMdItemApi;
+    @Resource
+    private MdmItemBatchConfigMapper itemBatchConfigMapper;
+
+    @Resource
+    private MesMdItemTypeApi mesMdItemTypeApi;
+
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public Long createItem(MdmItemSaveReqVO createReqVO) {
+        // 鏍￠獙鏁版嵁
+        validateItemSaveData(createReqVO);
+
+        // 鎻掑叆 MDM 鐗╂枡
+        MdmItemDO item = BeanUtils.toBean(createReqVO, MdmItemDO.class);
+        itemMapper.insert(item);
+
+        // 淇濆瓨鎵规閰嶇疆锛堝鏋滄湁锛�
+        saveBatchConfig(item.getId(), createReqVO);
+
+        // 鍚屾鍒� MES锛堝嬀閫� syncMes 鏃讹級
+        createReqVO.setId(item.getId());
+        if (Boolean.TRUE.equals(createReqVO.getSyncMes())) {
+            syncItemToMes(createReqVO);
+        }
+        return item.getId();
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void updateItem(MdmItemSaveReqVO updateReqVO) {
+        // 鏍￠獙瀛樺湪
+        validateItemExists(updateReqVO.getId());
+        // 鏍￠獙鏁版嵁
+        validateItemSaveData(updateReqVO);
+
+        // 鏇存柊 MDM 鐗╂枡
+        MdmItemDO updateObj = BeanUtils.toBean(updateReqVO, MdmItemDO.class);
+        itemMapper.updateById(updateObj);
+
+        // 淇濆瓨鎵规閰嶇疆锛堝鏋滄湁锛�
+        saveBatchConfig(updateReqVO.getId(), updateReqVO);
+
+        // 鍚屾鍒� MES锛堝嬀閫� syncMes 鏃讹級
+        if (Boolean.TRUE.equals(updateReqVO.getSyncMes())) {
+            syncItemToMes(updateReqVO);
+        }
+    }
+
+    private void validateItemSaveData(MdmItemSaveReqVO reqVO) {
+        // 鏍￠獙鐗╂枡缂栫爜鐨勫敮涓�鎬�
+        validateItemCodeUnique(reqVO.getId(), reqVO.getCode());
+    }
+
+    /**
+     * 鍚屾鐗╂枡鍒� MES锛堝崟浣�/鍒嗙被鎸� code 鏄犲皠锛�
+     *
+     * MDM 鐨� unitMeasureId/categoryId 涓� MES 鐨� unitMeasureId/itemTypeId 鍒嗗睘涓ゅ涓绘暟鎹紝
+     * 杩欓噷鍏堝湪 MDM 渚цВ鏋愬嚭 code锛屽啀浜ょ敱 MesMdItemApi 鍦� MES 渚цВ鏋愪负瀵瑰簲 id銆�
+     * 鍚屾澶辫触灏嗘姏鍑哄紓甯革紝瑙﹀彂澶栧眰 @Transactional 鏁翠綋鍥炴粴锛圡DM 鎿嶄綔涓�骞跺洖婊氾級銆�
+     */
+    private void syncItemToMes(MdmItemSaveReqVO reqVO) {
+        // 瑙ｆ瀽璁￠噺鍗曚綅 id -> code
+        String unitCode = null;
+        if (reqVO.getUnitMeasureId() != null) {
+            MdmUnitMeasureDO unitMeasure = unitMeasureService.getUnitMeasure(reqVO.getUnitMeasureId());
+            if (unitMeasure == null) {
+                throw exception(MDM_UNIT_MEASURE_NOT_EXISTS);
+            }
+            unitCode = unitMeasure.getCode();
+        }
+        // 瑙ｆ瀽鍒嗙被 id -> code锛堜娇鐢� MDM 鏈湴鍒嗙被鏈嶅姟锛�
+        String itemTypeCode = null;
+        if (reqVO.getCategoryId() != null) {
+            CommonResult<MesMdItemTypeRespDTO> itemType = mesMdItemTypeApi.getItemType(reqVO.getCategoryId());
+            itemTypeCode = itemType.getData().getCode();
+        }
+        // 缁勮鍚屾 DTO
+        MesMdItemSyncReqDTO syncReqDTO = new MesMdItemSyncReqDTO();
+        syncReqDTO.setCode(reqVO.getCode());
+        syncReqDTO.setMdmItemId(reqVO.getId());
+        syncReqDTO.setName(reqVO.getName());
+        syncReqDTO.setSpecification(reqVO.getSpecification());
+        syncReqDTO.setUnitCode(unitCode);
+        syncReqDTO.setItemTypeCode(itemTypeCode);
+        syncReqDTO.setSafeStockFlag(Boolean.TRUE); // 淇濈暀 MDM 鐨� minStock/maxStock锛岄伩鍏嶈 MES 娓呴浂
+        syncReqDTO.setMinStock(reqVO.getMinStock());
+        syncReqDTO.setMaxStock(reqVO.getMaxStock());
+        syncReqDTO.setHighValue(reqVO.getIsHighValue());
+        syncReqDTO.setBatchFlag(reqVO.getIsBatchManaged());
+        syncReqDTO.setRemark(reqVO.getRemark());
+        // 鎵规閰嶇疆瀛楁
+        syncReqDTO.setProduceDateFlag(reqVO.getProduceDateFlag());
+        syncReqDTO.setExpireDateFlag(reqVO.getExpireDateFlag());
+        syncReqDTO.setReceiptDateFlag(reqVO.getReceiptDateFlag());
+        syncReqDTO.setVendorFlag(reqVO.getVendorFlag());
+        syncReqDTO.setPurchaseOrderCodeFlag(reqVO.getPurchaseOrderCodeFlag());
+        syncReqDTO.setLotNumberFlag(reqVO.getLotNumberFlag());
+        syncReqDTO.setQualityStatusFlag(reqVO.getQualityStatusFlag());
+        // create 璧� createItem锛寀pdate 璧� updateItem锛圡ES 渚ф寜 code upsert锛�
+        if (reqVO.getId() == null) {
+            mesMdItemApi.createItem(syncReqDTO);
+        } else {
+            mesMdItemApi.updateItem(syncReqDTO);
+        }
+    }
+
+    @Override
+    public void updateItemStatus(Long id, Integer status) {
+        // 鏍￠獙瀛樺湪
+        validateItemExists(id);
+        // 鏇存柊鐘舵��
+        itemMapper.updateById(new MdmItemDO().setId(id).setStatus(status));
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void deleteItem(Long id) {
+        // 鏍￠獙瀛樺湪
+        MdmItemDO item = validateItemExists(id);
+        // 瑙ｅ喅杞垹闄ゅ敮涓�閿啿绐侊細濡傛灉宸插瓨鍦ㄧ浉鍚� code 涓斿凡杞垹闄ょ殑璁板綍锛屽厛鐗╃悊鍒犻櫎瀹�
+//        MdmItemDO existingDeleted = itemMapper.selectByCodeAndDeleted(item.getCode(), true);
+//        if (existingDeleted != null && !existingDeleted.getId().equals(id)) {
+//            itemMapper.physicalDeleteById(existingDeleted.getId());
+//        }
+        // 杞垹闄ゅ綋鍓嶈褰�
+        itemMapper.deleteById(id);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void deleteItemList(Collection<Long> ids) {
+        if (CollUtil.isEmpty(ids)) {
+            return;
+        }
+        // 閫愪釜鍒犻櫎锛堝鐢ㄥ崟鏉″垹闄ら�昏緫锛屼繚鎸佹牎楠岋級
+        ids.forEach(this::deleteItem);
+    }
+
+    @Override
+    public MdmItemDO validateItemExists(Long id) {
+        MdmItemDO item = itemMapper.selectById(id);
+        if (item == null) {
+            throw exception(MDM_ITEM_NOT_EXISTS);
+        }
+        return item;
+    }
+
+    @Override
+    public MdmItemDO validateItemExistsAndEnable(Long id) {
+        MdmItemDO item = validateItemExists(id);
+        if (ObjUtil.notEqual(cn.iocoder.yudao.framework.common.enums.CommonStatusEnum.ENABLE.getStatus(), item.getStatus())) {
+            throw exception(MDM_ITEM_IS_DISABLE);
+        }
+        return item;
+    }
+
+    private void validateItemCodeUnique(Long id, String code) {
+        MdmItemDO item = itemMapper.selectByCode(code);
+        if (item == null) {
+            return;
+        }
+        if (ObjUtil.notEqual(item.getId(), id)) {
+            throw exception(MDM_ITEM_CODE_DUPLICATE);
+        }
+    }
+
+    private void validateCategoryExists(Long categoryId) {
+        if (categoryId == null) {
+            return;
+        }
+        // 浣跨敤 MDM 鏈湴鍒嗙被鏈嶅姟鏍￠獙
+        MdmItemCategoryDO category = itemCategoryService.getItemCategory(categoryId);
+        if (category == null) {
+            throw exception(MDM_ITEM_CATEGORY_NOT_EXISTS);
+        }
+    }
+
+    private void validateUnitMeasureExists(Long unitMeasureId) {
+        if (unitMeasureService.getUnitMeasure(unitMeasureId) == null) {
+            throw exception(MDM_UNIT_MEASURE_NOT_EXISTS);
+        }
+    }
+
+    private void validateBrandExists(Long brandId) {
+        if (brandService.getBrand(brandId) == null) {
+            throw exception(MDM_BRAND_NOT_EXISTS);
+        }
+    }
+
+    /**
+     * 灏� itemType 杞崲涓轰腑鏂囧悕绉�
+     *
+     * @param itemType 鐗╂枡绫诲瀷锛�1鍘熸枡, 2鍗婃垚鍝�, 3鎴愬搧, 4杈呮枡
+     * @return 涓枃鍚嶇О
+     */
+    private String convertItemTypeToName(Integer itemType) {
+        if (itemType == null) {
+            return null;
+        }
+        switch (itemType) {
+            case 1:
+                return "鍘熸枡";
+            case 2:
+                return "鍗婃垚鍝�";
+            case 3:
+                return "鎴愬搧";
+            case 4:
+                return "杈呮枡";
+            default:
+                return null;
+        }
+    }
+
+    @Override
+    public MdmItemDO getItem(Long id) {
+        return itemMapper.selectById(id);
+    }
+
+    @Override
+    public PageResult<MdmItemDO> getItemPage(MdmItemPageReqVO pageReqVO) {
+        // 鏌ユ壘鏃讹紝濡傛灉鏌ユ壘鏌愪釜鍒嗙被缂栧彿锛屽垯鍖呭惈瀹冪殑瀛愬垎绫�
+        Set<Long> categoryIds = null;
+        if (pageReqVO.getCategoryId() != null) {
+            categoryIds = new HashSet<>();
+            categoryIds.add(pageReqVO.getCategoryId());
+            List<cn.iocoder.yudao.module.mdm.dal.dataobject.category.MdmItemCategoryDO> children =
+                    itemCategoryService.getItemCategoryChildrenList(pageReqVO.getCategoryId());
+            categoryIds.addAll(convertSet(children, cn.iocoder.yudao.module.mdm.dal.dataobject.category.MdmItemCategoryDO::getId));
+        }
+        // 鍒嗛〉鏌ヨ
+        return itemMapper.selectPage(pageReqVO, categoryIds);
+    }
+
+    @Override
+    public List<MdmItemDO> getItemList(Collection<Long> ids) {
+        if (CollUtil.isEmpty(ids)) {
+            return Collections.emptyList();
+        }
+        return itemMapper.selectBatchIds(ids);
+    }
+
+    @Override
+    public Long getItemCountByCategoryId(Long categoryId) {
+        return itemMapper.selectCountByCategoryId(categoryId);
+    }
+
+    @Override
+    public Long getItemCountByUnitMeasureId(Long unitMeasureId) {
+        return itemMapper.selectCountByUnitMeasureId(unitMeasureId);
+    }
+
+    @Override
+    public Long getItemCountByBrandId(Long brandId) {
+        return itemMapper.selectCountByBrandId(brandId);
+    }
+
+    @Override
+    public MdmItemDO getItemByCode(String code) {
+        return itemMapper.selectByCode(code);
+    }
+
+    /**
+     * 淇濆瓨鎵规閰嶇疆锛堝埌 MDM 鏈湴琛級
+     */
+    private void saveBatchConfig(Long itemId, MdmItemSaveReqVO reqVO) {
+        // 妫�鏌ユ槸鍚︽湁鎵规閰嶇疆鏁版嵁
+        if (reqVO.getProduceDateFlag() == null
+                && reqVO.getExpireDateFlag() == null
+                && reqVO.getReceiptDateFlag() == null
+                && reqVO.getVendorFlag() == null
+                && reqVO.getPurchaseOrderCodeFlag() == null
+                && reqVO.getLotNumberFlag() == null
+                && reqVO.getQualityStatusFlag() == null) {
+            return;
+        }
+
+        // 鏌ヨ宸叉湁閰嶇疆
+        cn.iocoder.yudao.module.mdm.dal.dataobject.item.MdmItemBatchConfigDO existing =
+                itemBatchConfigMapper.selectOne(
+                        cn.iocoder.yudao.module.mdm.dal.dataobject.item.MdmItemBatchConfigDO::getItemId, itemId);
+
+        cn.iocoder.yudao.module.mdm.dal.dataobject.item.MdmItemBatchConfigDO config =
+                new cn.iocoder.yudao.module.mdm.dal.dataobject.item.MdmItemBatchConfigDO();
+        config.setItemId(itemId);
+        config.setProduceDateFlag(Boolean.TRUE.equals(reqVO.getProduceDateFlag()));
+        config.setExpireDateFlag(Boolean.TRUE.equals(reqVO.getExpireDateFlag()));
+        config.setReceiptDateFlag(Boolean.TRUE.equals(reqVO.getReceiptDateFlag()));
+        config.setVendorFlag(Boolean.TRUE.equals(reqVO.getVendorFlag()));
+        config.setPurchaseOrderCodeFlag(Boolean.TRUE.equals(reqVO.getPurchaseOrderCodeFlag()));
+        config.setLotNumberFlag(Boolean.TRUE.equals(reqVO.getLotNumberFlag()));
+        config.setQualityStatusFlag(Boolean.TRUE.equals(reqVO.getQualityStatusFlag()));
+        // 娓呯┖涓嶉渶瑕佺殑瀛楁
+        config.setClientFlag(false);
+        config.setSalesOrderCodeFlag(false);
+        config.setWorkOrderFlag(false);
+        config.setTaskFlag(false);
+        config.setWorkstationFlag(false);
+        config.setToolFlag(false);
+        config.setMoldFlag(false);
+
+        if (existing != null) {
+            config.setId(existing.getId());
+            itemBatchConfigMapper.updateById(config);
+        } else {
+            itemBatchConfigMapper.insert(config);
+        }
+    }
+
+}
\ No newline at end of file

--
Gitblit v1.9.3