From d54fbc9d4f8981fa0f7f613b33a28a8cd4f764ea Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期日, 25 十月 2026 16:29:53 +0800
Subject: [PATCH] feat(system): 优化用户搜索功能并完善ERP和MES模块验证逻辑
---
yudao-module-mdm/src/main/java/cn/iocoder/yudao/module/mdm/service/item/MdmItemServiceImpl.java | 196 ++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 178 insertions(+), 18 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
index 14990a0..c8ced1b 100644
--- 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
@@ -2,27 +2,33 @@
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjUtil;
-import cn.iocoder.yudao.framework.common.pojo.CommonResult;
+import cn.hutool.core.util.StrUtil;
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
+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.framework.mybatis.core.mapper.BaseMapperX;
+import cn.iocoder.yudao.module.mdm.controller.admin.item.vo.MdmItemImportExcelVO;
+import cn.iocoder.yudao.module.mdm.controller.admin.item.vo.MdmItemImportReqVO;
+import cn.iocoder.yudao.module.mdm.controller.admin.item.vo.MdmItemImportRespVO;
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.brand.MdmBrandDO;
import cn.iocoder.yudao.module.mdm.dal.dataobject.category.MdmItemCategoryDO;
+import cn.iocoder.yudao.module.mdm.dal.dataobject.item.MdmItemBatchConfigDO;
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.brand.MdmBrandMapper;
+import cn.iocoder.yudao.module.mdm.dal.mysql.category.MdmItemCategoryMapper;
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.dal.mysql.unit.MdmUnitMeasureMapper;
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;
@@ -33,12 +39,13 @@
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.framework.common.util.collection.CollectionUtils.filterList;
import static cn.iocoder.yudao.module.mdm.enums.ErrorCodeConstants.*;
/**
* MDM 鐗╂枡涓绘暟鎹� Service 瀹炵幇绫�
*
- * @author 鑺嬮亾婧愮爜
+ * @author 瓒呯骇绠＄悊鍛�
*/
@Service
@Validated
@@ -55,14 +62,17 @@
private MdmBrandService brandService;
@Resource
+ private MdmItemCategoryMapper itemCategoryMapper;
+ @Resource
+ private MdmUnitMeasureMapper unitMeasureMapper;
+ @Resource
+ private MdmBrandMapper brandMapper;
+
+ @Resource
@Lazy
private MesMdItemApi mesMdItemApi;
@Resource
private MdmItemBatchConfigMapper itemBatchConfigMapper;
-
- @Resource
- private MesMdItemTypeApi mesMdItemTypeApi;
-
@Override
@Transactional(rollbackFor = Exception.class)
@@ -77,9 +87,11 @@
// 淇濆瓨鎵规閰嶇疆锛堝鏋滄湁锛�
saveBatchConfig(item.getId(), createReqVO);
- // 濮嬬粓鍚屾鍒� MES
- createReqVO.setId(item.getId());
- syncItemToMes(createReqVO);
+ // 鍕鹃�夊悓姝ユ椂锛屽悓姝ュ埌 MES
+ if (Boolean.TRUE.equals(createReqVO.getSyncMes())) {
+ createReqVO.setId(item.getId());
+ syncItemToMes(createReqVO);
+ }
return item.getId();
}
@@ -98,8 +110,12 @@
// 淇濆瓨鎵规閰嶇疆锛堝鏋滄湁锛�
saveBatchConfig(updateReqVO.getId(), updateReqVO);
- // 濮嬬粓鍚屾鍒� MES
- syncItemToMes(updateReqVO);
+ // 鏍规嵁鍚屾寮�鍏冲喅瀹氾細鎵撳紑鍒欏悓姝ュ埌 MES锛屽叧闂垯鍙栨秷鍚屾锛堜粠 MES 鍒犻櫎锛�
+ if (Boolean.TRUE.equals(updateReqVO.getSyncMes())) {
+ syncItemToMes(updateReqVO);
+ } else {
+ mesMdItemApi.deleteItem(updateReqVO.getId());
+ }
}
private void validateItemSaveData(MdmItemSaveReqVO reqVO) {
@@ -127,8 +143,11 @@
// 瑙ｆ瀽鍒嗙被 id -> code锛堜娇鐢� MDM 鏈湴鍒嗙被鏈嶅姟锛�
String itemTypeCode = null;
if (reqVO.getCategoryId() != null) {
- CommonResult<MesMdItemTypeRespDTO> itemType = mesMdItemTypeApi.getItemType(reqVO.getCategoryId());
- itemTypeCode = itemType.getData().getCode();
+ MdmItemCategoryDO category = itemCategoryService.getItemCategory(reqVO.getCategoryId());
+ if (category == null) {
+ throw exception(MDM_ITEM_CATEGORY_NOT_EXISTS);
+ }
+ itemTypeCode = category.getCode();
}
// 缁勮鍚屾 DTO
MesMdItemSyncReqDTO syncReqDTO = new MesMdItemSyncReqDTO();
@@ -143,6 +162,7 @@
syncReqDTO.setMaxStock(reqVO.getMaxStock());
syncReqDTO.setHighValue(reqVO.getIsHighValue());
syncReqDTO.setBatchFlag(reqVO.getIsBatchManaged());
+ syncReqDTO.setStatus(reqVO.getStatus());
syncReqDTO.setRemark(reqVO.getRemark());
// 鎵规閰嶇疆瀛楁
syncReqDTO.setProduceDateFlag(reqVO.getProduceDateFlag());
@@ -184,6 +204,35 @@
mesMdItemApi.deleteItem(id);
}
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void updateItemSync(Long id, Boolean sync) {
+ // 鏍￠獙瀛樺湪
+ MdmItemDO item = validateItemExists(id);
+ if (Boolean.TRUE.equals(sync)) {
+ // 鍚屾鍒� MES锛氫粠 DB 璇诲彇瀹屾暣鐗╂枡鏁版嵁缁勮鍚庤蛋 syncItemToMes
+ MdmItemSaveReqVO reqVO = BeanUtils.toBean(item, MdmItemSaveReqVO.class);
+ // DO 瀛楁鍚嶄负 highValue锛屼笌 VO 鐨� isHighValue 涓嶈嚜鍔ㄥ尮閰嶏紝鎵嬪姩琛ラ綈
+ reqVO.setIsHighValue(item.getHighValue());
+ // 琛ラ綈鎵规灞炴�ч厤缃�
+ MdmItemBatchConfigDO config = itemBatchConfigMapper.selectOne(
+ MdmItemBatchConfigDO::getItemId, id);
+ if (config != null) {
+ reqVO.setProduceDateFlag(config.getProduceDateFlag());
+ reqVO.setExpireDateFlag(config.getExpireDateFlag());
+ reqVO.setReceiptDateFlag(config.getReceiptDateFlag());
+ reqVO.setVendorFlag(config.getVendorFlag());
+ reqVO.setPurchaseOrderCodeFlag(config.getPurchaseOrderCodeFlag());
+ reqVO.setLotNumberFlag(config.getLotNumberFlag());
+ reqVO.setQualityStatusFlag(config.getQualityStatusFlag());
+ }
+ syncItemToMes(reqVO);
+ } else {
+ // 鍙栨秷鍚屾锛氫粠 MES 鍒犻櫎璇ョ墿鏂欙紙MES 鏃犳鐗╂枡鏃跺唴閮ㄤ负绌烘搷浣滐級
+ mesMdItemApi.deleteItem(id);
+ }
+ }
+
/**
* 鏍￠獙鐗╂枡鏈涓氬姟寮曠敤锛堥攢鍞�侀噰璐�佺敓浜с�佽川妫�銆佸簱瀛樼瓑锛�
*
@@ -207,6 +256,111 @@
}
// 閫愪釜鍒犻櫎锛堝鐢ㄥ崟鏉″垹闄ら�昏緫锛屼繚鎸佹牎楠岋級
ids.forEach(this::deleteItem);
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public MdmItemImportRespVO importItemList(List<MdmItemImportExcelVO> importItems,
+ MdmItemImportReqVO importReqVO) {
+ // 1. 鏍￠獙闈炵┖锛堜互鐗╂枡缂栫爜浣滀负瀵煎叆涓婚敭锛�
+ importItems = filterList(importItems, item -> StrUtil.isNotBlank(item.getCode()));
+ if (CollUtil.isEmpty(importItems)) {
+ throw exception(MDM_ITEM_IMPORT_LIST_IS_EMPTY);
+ }
+
+ // 2. 閫愭潯澶勭悊
+ MdmItemImportRespVO respVO = MdmItemImportRespVO.builder()
+ .createItemCodes(new ArrayList<>())
+ .updateItemCodes(new ArrayList<>())
+ .failureItemCodes(new LinkedHashMap<>())
+ .build();
+ importItems.forEach(importItem -> {
+ try {
+ // 2.1 瑙ｆ瀽澶栭敭锛氬垎绫� / 涓诲崟浣� / 杈呭崟浣� / 鍝佺墝锛堟寜鍚嶇О瑙ｆ瀽锛�
+ Long categoryId = resolveCategoryId(importItem.getCategoryName());
+ Long unitMeasureId = resolveUnitMeasureId(importItem.getUnitMeasureName());
+ Long unitMeasureId2 = resolveUnitMeasureId(importItem.getUnitMeasureName2());
+ Long unitMeasureId3 = resolveUnitMeasureId(importItem.getUnitMeasureName3());
+ Long brandId = resolveBrandId(importItem.getBrandName());
+ // 2.2 鍒ゆ柇鏄惁瀛樺湪锛堟寜缂栫爜鍞竴锛�
+ MdmItemDO existItem = itemMapper.selectByCode(importItem.getCode());
+ if (existItem == null) {
+ // 2.2.1 鏂板
+ MdmItemDO item = BeanUtils.toBean(importItem, MdmItemDO.class)
+ .setCategoryId(categoryId)
+ .setUnitMeasureId(unitMeasureId)
+ .setUnitMeasureId2(unitMeasureId2)
+ .setUnitMeasureId3(unitMeasureId3)
+ .setBrandId(brandId);
+ if (item.getStatus() == null) {
+ item.setStatus(CommonStatusEnum.ENABLE.getStatus());
+ }
+ itemMapper.insert(item);
+ respVO.getCreateItemCodes().add(importItem.getCode());
+ return;
+ }
+ // 2.2.2 宸插瓨鍦紝鍒ゆ柇鏄惁鍏佽鏇存柊
+ if (!importReqVO.getUpdateSupport()) {
+ respVO.getFailureItemCodes().put(importItem.getCode(),
+ StrUtil.format(MDM_ITEM_CODE_EXISTS.getMsg(), importItem.getCode()));
+ return;
+ }
+ MdmItemDO updateItem = BeanUtils.toBean(importItem, MdmItemDO.class)
+ .setId(existItem.getId())
+ .setCategoryId(categoryId)
+ .setUnitMeasureId(unitMeasureId)
+ .setUnitMeasureId2(unitMeasureId2)
+ .setUnitMeasureId3(unitMeasureId3)
+ .setBrandId(brandId);
+ itemMapper.updateById(updateItem);
+ respVO.getUpdateItemCodes().add(importItem.getCode());
+ } catch (ServiceException ex) {
+ respVO.getFailureItemCodes().put(importItem.getCode(), ex.getMessage());
+ }
+ });
+ return respVO;
+ }
+
+ /**
+ * 鎸夊悕绉拌В鏋愮墿鏂欏垎绫荤紪鍙�
+ */
+ private Long resolveCategoryId(String categoryName) {
+ if (StrUtil.isBlank(categoryName)) {
+ return null;
+ }
+ MdmItemCategoryDO category = itemCategoryMapper.selectByName(categoryName);
+ if (category == null) {
+ throw exception(MDM_ITEM_IMPORT_CATEGORY_NOT_EXISTS, categoryName);
+ }
+ return category.getId();
+ }
+
+ /**
+ * 鎸夊悕绉拌В鏋愯閲忓崟浣嶇紪鍙�
+ */
+ private Long resolveUnitMeasureId(String unitMeasureName) {
+ if (StrUtil.isBlank(unitMeasureName)) {
+ return null;
+ }
+ MdmUnitMeasureDO unitMeasure = unitMeasureMapper.selectByName(unitMeasureName);
+ if (unitMeasure == null) {
+ throw exception(MDM_ITEM_IMPORT_UNIT_NOT_EXISTS, unitMeasureName);
+ }
+ return unitMeasure.getId();
+ }
+
+ /**
+ * 鎸夊悕绉拌В鏋愬搧鐗岀紪鍙�
+ */
+ private Long resolveBrandId(String brandName) {
+ if (StrUtil.isBlank(brandName)) {
+ return null;
+ }
+ MdmBrandDO brand = brandMapper.selectByName(brandName);
+ if (brand == null) {
+ throw exception(MDM_ITEM_IMPORT_BRAND_NOT_EXISTS, brandName);
+ }
+ return brand.getId();
}
@Override
@@ -332,6 +486,12 @@
return itemMapper.selectByCode(code);
}
+ @Override
+ public List<MdmItemDO> getItemSimpleList() {
+ return itemMapper.selectList(MdmItemDO::getStatus,
+ cn.iocoder.yudao.framework.common.enums.CommonStatusEnum.ENABLE.getStatus());
+ }
+
/**
* 淇濆瓨鎵规閰嶇疆锛堝埌 MDM 鏈湴琛級
*/
@@ -379,4 +539,4 @@
}
}
-}
\ No newline at end of file
+}
--
Gitblit v1.9.3