feat(mes): 完善物料分类与物料产品后端功能

1. Service 层重构：接口只返回 DO，VO 拼接移至 Controller 2. Mapper 合并两个 selectPage 为一个方法（inIfPresent 兼容空集合） 3. 新增物料批量导入功能（ImportExcelVO + ImportRespVO + Controller 端点） 4. 分类查询支持子分类递归（getItemTypeChildrenList） 5. 物料分页查询自动包含选中分类的所有子分类 6. 分类删除移除 export-excel 端点 7. 校验逻辑简化：ObjUtil.notEqual 替代双 if 判断 8. collectChildren 重命名为 collectItemTypeChildren

feat(mes): 完善物料分类与物料产品后端功能
1. Service 层重构：接口只返回 DO，VO 拼接移至 Controller 2. Mapper 合并两个 selectPage 为一个方法（inIfPresent 兼容空集合） 3. 新增物料批量导入功能（ImportExcelVO + ImportRespVO + Controller 端点） 4. 分类查询支持子分类递归（getItemTypeChildrenList） 5. 物料分页查询自动包含选中分类的所有子分类 6. 分类删除移除 export-excel 端点 7. 校验逻辑简化：ObjUtil.notEqual 替代双 if 判断 8. collectChildren 重命名为 collectItemTypeChildren
YunaiV
1 parent 977fdca6
Showing 8 changed files with 224 additions and 91 deletions
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/md/item/MesMdItemController.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/md/item/MesMdItemTypeController.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/md/item/MesMdItemMapper.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/enums/ErrorCodeConstants.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/md/item/MesMdItemService.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/md/item/MesMdItemServiceImpl.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/md/item/MesMdItemTypeService.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/md/item/MesMdItemTypeServiceImpl.java
 package cn.iocoder.yudao.module.mes.controller.admin.md.item;
+import cn.hutool.core.collection.CollUtil;
 import cn.iocoder.yudao.framework.apilog.core.annotation.ApiAccessLog;
 import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
 import cn.iocoder.yudao.framework.common.pojo.CommonResult;
 import cn.iocoder.yudao.framework.common.pojo.PageParam;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.framework.common.util.collection.MapUtils;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
 import cn.iocoder.yudao.framework.excel.core.util.ExcelUtils;
+import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemImportExcelVO;
+import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemImportRespVO;
 import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemPageReqVO;
 import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemRespVO;
 import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemSaveReqVO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemDO;
+import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemTypeDO;
 import cn.iocoder.yudao.module.mes.service.md.item.MesMdItemService;
+import cn.iocoder.yudao.module.mes.service.md.item.MesMdItemTypeService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.Parameters;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.annotation.Resource;
 import jakarta.servlet.http.HttpServletResponse;
@@ -21,13 +28,17 @@ import jakarta.validation.Valid;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
 import java.io.IOException;
+import java.util.Collections;
 import java.util.List;
+import java.util.Map;
 import static cn.iocoder.yudao.framework.apilog.core.enums.OperateTypeEnum.EXPORT;
 import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
 import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList;
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertSet;
 @Tag(name = "管理后台 - MES 物料产品")
 @RestController
@@ -38,6 +49,9 @@ public class MesMdItemController {
     @Resource
     private MesMdItemService itemService;
+    @Resource
+    private MesMdItemTypeService itemTypeService;
+
     @PostMapping("/create")
     @Operation(summary = "创建物料产品")
     @PreAuthorize("@ss.hasPermission('mes:md-item:create')")
@@ -75,14 +89,15 @@ public class MesMdItemController {
     @Operation(summary = "获得物料产品分页")
     @PreAuthorize("@ss.hasPermission('mes:md-item:query')")
     public CommonResult<PageResult<MesMdItemRespVO>> getItemPage(@Valid MesMdItemPageReqVO pageReqVO) {
-        return success(itemService.getItemVOPage(pageReqVO));
+        PageResult<MesMdItemDO> pageResult = itemService.getItemPage(pageReqVO);
+        return success(new PageResult<>(buildItemVOList(pageResult.getList()), pageResult.getTotal()));
     }
     @GetMapping("/simple-list")
     @Operation(summary = "获得物料产品精简列表", description = "只包含被开启的物料，主要用于前端的下拉选项")
     public CommonResult<List<MesMdItemRespVO>> getItemSimpleList() {
-        List<MesMdItemRespVO> list = itemService.getItemVOListByStatus(CommonStatusEnum.ENABLE.getStatus());
-        return success(convertList(list, item -> new MesMdItemRespVO()
+        List<MesMdItemDO> list = itemService.getItemListByStatus(CommonStatusEnum.ENABLE.getStatus());
+        return success(convertList(buildItemVOList(list), item -> new MesMdItemRespVO()
                 .setId(item.getId()).setName(item.getName()).setCode(item.getCode())
                 .setItemTypeId(item.getItemTypeId()).setItemTypeName(item.getItemTypeName())
                 .setUnitOfMeasure(item.getUnitOfMeasure())));
@@ -95,12 +110,52 @@ public class MesMdItemController {
     public void exportItemExcel(@Valid MesMdItemPageReqVO pageReqVO,
               HttpServletResponse response) throws IOException {
         pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE);
-        PageResult<MesMdItemRespVO> pageResult = itemService.getItemVOPage(pageReqVO);
+        PageResult<MesMdItemDO> pageResult = itemService.getItemPage(pageReqVO);
         // 导出 Excel
         ExcelUtils.write(response, "物料产品.xls", "数据", MesMdItemRespVO.class,
-                pageResult.getList());
+                buildItemVOList(pageResult.getList()));
     }
-    // TODO @AI：缺少批量导入；
+    @GetMapping("/get-import-template")
+    @Operation(summary = "获得物料导入模板")
+    public void importTemplate(HttpServletResponse response) throws IOException {
+        // 手动创建导出 demo
+        List<MesMdItemImportExcelVO> list = Collections.singletonList(
+                MesMdItemImportExcelVO.builder().code("ITEM001").name("螺丝").specification("M6*20")
+                        .unitOfMeasure("PCS").itemTypeId(1L).status(0).build()
+        );
+        // 输出
+        ExcelUtils.write(response, "物料导入模板.xls", "物料列表", MesMdItemImportExcelVO.class, list);
+    }
+
+    @PostMapping("/import")
+    @Operation(summary = "导入物料")
+    @Parameters({
+            @Parameter(name = "file", description = "Excel 文件", required = true),
+            @Parameter(name = "updateSupport", description = "是否支持更新，默认为 false", example = "true")
+    })
+    @PreAuthorize("@ss.hasPermission('mes:md-item:create')")
+    public CommonResult<MesMdItemImportRespVO> importExcel(@RequestParam("file") MultipartFile file,
+                                                           @RequestParam(value = "updateSupport", required = false,
+                                                                   defaultValue = "false") Boolean updateSupport) throws Exception {
+        List<MesMdItemImportExcelVO> list = ExcelUtils.read(file, MesMdItemImportExcelVO.class);
+        return success(itemService.importItemList(list, updateSupport));
+    }
+
+    // ==================== 拼接 VO ====================
+
+    private List<MesMdItemRespVO> buildItemVOList(List<MesMdItemDO> list) {
+        if (CollUtil.isEmpty(list)) {
+            return Collections.emptyList();
+        }
+        Map<Long, MesMdItemTypeDO> itemTypeMap = itemTypeService.getItemTypeMap(
+                convertSet(list, MesMdItemDO::getItemTypeId));
+        return BeanUtils.toBean(list, MesMdItemRespVO.class, item ->
+                MapUtils.findAndThen(itemTypeMap, item.getItemTypeId(),
+                        itemType -> {
+                            item.setItemTypeName(itemType.getName());
+                            item.setItemOrProduct(itemType.getItemOrProduct());
+                        }));
+    }
 }
 package cn.iocoder.yudao.module.mes.controller.admin.md.item;
-import cn.iocoder.yudao.framework.apilog.core.annotation.ApiAccessLog;
 import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
 import cn.iocoder.yudao.framework.common.pojo.CommonResult;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
-import cn.iocoder.yudao.framework.excel.core.util.ExcelUtils;
 import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.type.MesMdItemTypeListReqVO;
 import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.type.MesMdItemTypeRespVO;
 import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.type.MesMdItemTypeSaveReqVO;
@@ -14,16 +12,13 @@ import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.annotation.Resource;
-import jakarta.servlet.http.HttpServletResponse;
 import jakarta.validation.Valid;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
-import java.io.IOException;
 import java.util.List;
-import static cn.iocoder.yudao.framework.apilog.core.enums.OperateTypeEnum.EXPORT;
 import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
 import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList;
@@ -86,17 +81,4 @@ public class MesMdItemTypeController {
                 .setId(itemType.getId()).setName(itemType.getName()).setParentId(itemType.getParentId())));
     }
-    // TODO @AI：不需要导出；
-    @GetMapping("/export-excel")
-    @Operation(summary = "导出物料产品分类 Excel")
-    @PreAuthorize("@ss.hasPermission('mes:md-item-type:export')")
-    @ApiAccessLog(operateType = EXPORT)
-    public void exportItemTypeExcel(@Valid MesMdItemTypeListReqVO listReqVO,
-              HttpServletResponse response) throws IOException {
-        List<MesMdItemTypeDO> list = itemTypeService.getItemTypeList(listReqVO);
-        // 导出 Excel
-        ExcelUtils.write(response, "物料产品分类.xls", "数据", MesMdItemTypeRespVO.class,
-                        BeanUtils.toBean(list, MesMdItemTypeRespVO.class));
-    }
-
 }
@@ -7,6 +7,7 @@ import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemPageReqV
 import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemDO;
 import org.apache.ibatis.annotations.Mapper;
+import java.util.Collection;
 import java.util.List;
 /**
@@ -17,11 +18,11 @@ import java.util.List;
 @Mapper
 public interface MesMdItemMapper extends BaseMapperX<MesMdItemDO> {
-    default PageResult<MesMdItemDO> selectPage(MesMdItemPageReqVO reqVO) {
+    default PageResult<MesMdItemDO> selectPage(MesMdItemPageReqVO reqVO, Collection<Long> itemTypeIds) {
         return selectPage(reqVO, new LambdaQueryWrapperX<MesMdItemDO>()
                 .likeIfPresent(MesMdItemDO::getCode, reqVO.getCode())
                 .likeIfPresent(MesMdItemDO::getName, reqVO.getName())
-                .eqIfPresent(MesMdItemDO::getItemTypeId, reqVO.getItemTypeId())
+                .inIfPresent(MesMdItemDO::getItemTypeId, itemTypeIds)
                 .eqIfPresent(MesMdItemDO::getStatus, reqVO.getStatus())
                 .betweenIfPresent(MesMdItemDO::getCreateTime, reqVO.getCreateTime())
                 .orderByDesc(MesMdItemDO::getId));
@@ -21,11 +21,13 @@ public interface ErrorCodeConstants {
     // ========== MES 基础数据-计量单位（1-040-101-000） ==========
     ErrorCode MD_UNIT_MEASURE_NOT_EXISTS = new ErrorCode(1_040_101_000, "计量单位不存在");
+    ErrorCode MD_UNIT_MEASURE_CODE_DUPLICATE = new ErrorCode(1_040_101_001, "计量单位编码已存在");
     // ========== MES 基础数据-物料（1-040-102-000） ==========
     ErrorCode MD_ITEM_NOT_EXISTS = new ErrorCode(1_040_102_000, "物料不存在");
     ErrorCode MD_ITEM_CODE_DUPLICATE = new ErrorCode(1_040_102_001, "物料编码已存在");
     ErrorCode MD_ITEM_NAME_DUPLICATE = new ErrorCode(1_040_102_002, "物料名称已存在");
+    ErrorCode MD_ITEM_IMPORT_LIST_IS_EMPTY = new ErrorCode(1_040_102_003, "导入物料数据不能为空");
     // ========== MES 基础数据-客户（1-040-103-000） ==========
     ErrorCode MD_CLIENT_NOT_EXISTS = new ErrorCode(1_040_103_000, "客户不存在");
 package cn.iocoder.yudao.module.mes.service.md.item;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemImportExcelVO;
+import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemImportRespVO;
 import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemPageReqVO;
-import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemRespVO;
 import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemSaveReqVO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemDO;
 import jakarta.validation.Valid;
@@ -51,37 +52,37 @@ public interface MesMdItemService {
     MesMdItemDO getItem(Long id);
     /**
-     * 获得物料产品 VO 分页
+     * 获得物料产品分页
      *
      * @param pageReqVO 分页查询
      * @return 物料产品分页
      */
-    PageResult<MesMdItemRespVO> getItemVOPage(MesMdItemPageReqVO pageReqVO);
+    PageResult<MesMdItemDO> getItemPage(MesMdItemPageReqVO pageReqVO);
     /**
-     * 获得指定状态的物料产品 VO 列表
+     * 获得指定状态的物料产品列表
      *
      * @param status 状态
-     * @return 物料产品 VO 列表
+     * @return 物料产品列表
      */
-    List<MesMdItemRespVO> getItemVOListByStatus(Integer status);
+    List<MesMdItemDO> getItemListByStatus(Integer status);
     /**
-     * 获得物料产品 VO 列表
+     * 获得物料产品列表
      *
      * @param ids 编号数组
-     * @return 物料产品 VO 列表
+     * @return 物料产品列表
      */
-    List<MesMdItemRespVO> getItemVOList(Collection<Long> ids);
+    List<MesMdItemDO> getItemList(Collection<Long> ids);
     /**
-     * 获得物料产品 VO Map
+     * 获得物料产品 Map
      *
      * @param ids 编号数组
-     * @return 物料产品 VO Map
+     * @return 物料产品 Map
      */
-    default Map<Long, MesMdItemRespVO> getItemVOMap(Collection<Long> ids) {
-        return convertMap(getItemVOList(ids), MesMdItemRespVO::getId);
+    default Map<Long, MesMdItemDO> getItemMap(Collection<Long> ids) {
+        return convertMap(getItemList(ids), MesMdItemDO::getId);
     }
     /**
@@ -92,4 +93,13 @@ public interface MesMdItemService {
      */
     Long getItemCountByItemTypeId(Long itemTypeId);
+    /**
+     * 批量导入物料
+     *
+     * @param importItems 导入物料列表
+     * @param updateSupport 是否支持更新
+     * @return 导入结果
+     */
+    MesMdItemImportRespVO importItemList(List<MesMdItemImportExcelVO> importItems, boolean updateSupport);
+
 }
 package cn.iocoder.yudao.module.mes.service.md.item;
 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.collection.MapUtils;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
+import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemImportExcelVO;
+import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemImportRespVO;
 import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemPageReqVO;
-import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemRespVO;
 import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemSaveReqVO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemDO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemTypeDO;
 import cn.iocoder.yudao.module.mes.dal.mysql.md.item.MesMdItemMapper;
 import jakarta.annotation.Resource;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
 import java.math.BigDecimal;
-import java.util.Collection;
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
+import java.util.*;
+import java.util.concurrent.atomic.AtomicInteger;
 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
 import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertSet;
@@ -51,10 +51,8 @@ public class MesMdItemServiceImpl implements MesMdItemService {
         // 插入
         MesMdItemDO item = BeanUtils.toBean(createReqVO, MesMdItemDO.class);
-        // 如果未启用安全库存，清零库存上下限
-        clearStockIfNotSafe(item);
+        clearStockIfNotSafe(item); // 如果未启用安全库存，清零库存上下限
         itemMapper.insert(item);
-        // 返回
         return item.getId();
     }
@@ -71,8 +69,7 @@ public class MesMdItemServiceImpl implements MesMdItemService {
         // 更新
         MesMdItemDO updateObj = BeanUtils.toBean(updateReqVO, MesMdItemDO.class);
-        // 如果未启用安全库存，清零库存上下限
-        clearStockIfNotSafe(updateObj);
+        clearStockIfNotSafe(updateObj); // 如果未启用安全库存，清零库存上下限
         itemMapper.updateById(updateObj);
     }
@@ -129,8 +126,7 @@ public class MesMdItemServiceImpl implements MesMdItemService {
         if (Boolean.TRUE.equals(item.getSafeStockFlag())) {
             return;
         }
-        item.setMinStock(BigDecimal.ZERO);
-        item.setMaxStock(BigDecimal.ZERO);
+        item.setMinStock(BigDecimal.ZERO).setMaxStock(BigDecimal.ZERO);
     }
     @Override
@@ -139,39 +135,30 @@ public class MesMdItemServiceImpl implements MesMdItemService {
     }
     @Override
-    public PageResult<MesMdItemRespVO> getItemVOPage(MesMdItemPageReqVO pageReqVO) {
-        PageResult<MesMdItemDO> pageResult = itemMapper.selectPage(pageReqVO);
-        return new PageResult<>(buildItemVOList(pageResult.getList()), pageResult.getTotal());
+    public PageResult<MesMdItemDO> getItemPage(MesMdItemPageReqVO pageReqVO) {
+        // 查找时，如果查找某个分类编号，则包含它的子分类
+        Set<Long> itemTypeIds = null;
+        if (pageReqVO.getItemTypeId() != null) {
+            itemTypeIds = new HashSet<>();
+            itemTypeIds.add(pageReqVO.getItemTypeId());
+            List<MesMdItemTypeDO> children = itemTypeService.getItemTypeChildrenList(pageReqVO.getItemTypeId());
+            itemTypeIds.addAll(convertSet(children, MesMdItemTypeDO::getId));
+        }
+        // 分页查询
+        return itemMapper.selectPage(pageReqVO, itemTypeIds);
     }
     @Override
-    public List<MesMdItemRespVO> getItemVOListByStatus(Integer status) {
-        List<MesMdItemDO> list = itemMapper.selectListByStatus(status);
-        return buildItemVOList(list);
+    public List<MesMdItemDO> getItemListByStatus(Integer status) {
+        return itemMapper.selectListByStatus(status);
     }
     @Override
-    public List<MesMdItemRespVO> getItemVOList(Collection<Long> ids) {
+    public List<MesMdItemDO> getItemList(Collection<Long> ids) {
         if (CollUtil.isEmpty(ids)) {
             return Collections.emptyList();
         }
-        List<MesMdItemDO> list = itemMapper.selectByIds(ids);
-        return buildItemVOList(list);
-    }
-
-    private List<MesMdItemRespVO> buildItemVOList(List<MesMdItemDO> list) {
-        if (CollUtil.isEmpty(list)) {
-            return Collections.emptyList();
-        }
-        Map<Long, MesMdItemTypeDO> itemTypeMap = itemTypeService.getItemTypeMap(
-                convertSet(list, MesMdItemDO::getItemTypeId));
-        return BeanUtils.toBean(list, MesMdItemRespVO.class, item -> {
-            MapUtils.findAndThen(itemTypeMap, item.getItemTypeId(),
-                    itemType -> {
-                        item.setItemTypeName(itemType.getName());
-                        item.setItemOrProduct(itemType.getItemOrProduct());
-                    });
-        });
+        return itemMapper.selectByIds(ids);
     }
     @Override
@@ -179,4 +166,80 @@ public class MesMdItemServiceImpl implements MesMdItemService {
         return itemMapper.selectCountByItemTypeId(itemTypeId);
     }
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public MesMdItemImportRespVO importItemList(List<MesMdItemImportExcelVO> importItems, boolean updateSupport) {
+        // 1. 参数校验
+        if (CollUtil.isEmpty(importItems)) {
+            throw exception(MD_ITEM_IMPORT_LIST_IS_EMPTY);
+        }
+
+        // 2. 遍历，逐个创建 or 更新
+        MesMdItemImportRespVO respVO = MesMdItemImportRespVO.builder()
+                .createCodes(new ArrayList<>()).updateCodes(new ArrayList<>())
+                .failureCodes(new LinkedHashMap<>()).build();
+        AtomicInteger index = new AtomicInteger(1);
+        importItems.forEach(importItem -> {
+            int currentIndex = index.getAndIncrement();
+            // 2.1 校验字段
+            String key = StrUtil.blankToDefault(importItem.getCode(), "第 " + currentIndex + " 行");
+            if (StrUtil.isBlank(importItem.getCode())) {
+                respVO.getFailureCodes().put(key, "物料编码不能为空");
+                return;
+            }
+            if (StrUtil.isBlank(importItem.getName())) {
+                respVO.getFailureCodes().put(key, "物料名称不能为空");
+                return;
+            }
+            if (StrUtil.isBlank(importItem.getUnitOfMeasure())) {
+                respVO.getFailureCodes().put(key, "单位编码不能为空");
+                return;
+            }
+            if (importItem.getItemTypeId() == null) {
+                respVO.getFailureCodes().put(key, "物料分类编号不能为空");
+                return;
+            }
+            // 2.2 校验分类是否存在
+            try {
+                validateItemTypeExists(importItem.getItemTypeId());
+            } catch (ServiceException ex) {
+                respVO.getFailureCodes().put(key, ex.getMessage());
+                return;
+            }
+
+            // 2.3 判断：创建 or 更新
+            MesMdItemDO existItem = itemMapper.selectByCode(importItem.getCode());
+            if (existItem == null) {
+                // 2.3.1 创建
+                try {
+                    validateItemNameUnique(null, importItem.getName());
+                } catch (ServiceException ex) {
+                    respVO.getFailureCodes().put(key, ex.getMessage());
+                    return;
+                }
+                MesMdItemDO item = BeanUtils.toBean(importItem, MesMdItemDO.class);
+                clearStockIfNotSafe(item);
+                itemMapper.insert(item);
+                respVO.getCreateCodes().add(importItem.getCode());
+            } else if (updateSupport) {
+                // 2.3.2 更新
+                try {
+                    validateItemNameUnique(existItem.getId(), importItem.getName());
+                } catch (ServiceException ex) {
+                    respVO.getFailureCodes().put(key, ex.getMessage());
+                    return;
+                }
+                MesMdItemDO updateObj = BeanUtils.toBean(importItem, MesMdItemDO.class);
+                updateObj.setId(existItem.getId());
+                clearStockIfNotSafe(updateObj);
+                itemMapper.updateById(updateObj);
+                respVO.getUpdateCodes().add(importItem.getCode());
+            } else {
+                // 不支持更新
+                respVO.getFailureCodes().put(key, "物料编码已存在");
+            }
+        });
+        return respVO;
+    }
+
 }
@@ -74,4 +74,12 @@ public interface MesMdItemTypeService {
         return convertMap(getItemTypeList(ids), MesMdItemTypeDO::getId);
     }
+    /**
+     * 获得指定分类的所有子分类列表（递归）
+     *
+     * @param parentId 父分类编号
+     * @return 子分类列表
+     */
+    List<MesMdItemTypeDO> getItemTypeChildrenList(Long parentId);
+
 }
 package cn.iocoder.yudao.module.mes.service.md.item;
+import cn.hutool.core.util.ObjUtil;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
 import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.type.MesMdItemTypeListReqVO;
 import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.type.MesMdItemTypeSaveReqVO;
@@ -10,9 +11,7 @@ import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
 import org.springframework.validation.annotation.Validated;
-import java.util.Collection;
-import java.util.List;
-import java.util.Objects;
+import java.util.*;
 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
 import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;
@@ -45,7 +44,6 @@ public class MesMdItemTypeServiceImpl implements MesMdItemTypeService {
         // 插入
         MesMdItemTypeDO itemType = BeanUtils.toBean(createReqVO, MesMdItemTypeDO.class);
         itemTypeMapper.insert(itemType);
-        // 返回
         return itemType.getId();
     }
@@ -77,6 +75,7 @@ public class MesMdItemTypeServiceImpl implements MesMdItemTypeService {
         if (itemService.getItemCountByItemTypeId(id) > 0) {
             throw exception(MD_ITEM_TYPE_EXITS_ITEM);
         }
+
         // 2. 删除
         itemTypeMapper.deleteById(id);
     }
@@ -126,11 +125,7 @@ public class MesMdItemTypeServiceImpl implements MesMdItemTypeService {
         if (itemType == null) {
             return;
         }
-        // 如果 id 为空，说明不用比较是否为相同 id 的分类
-        if (id == null) {
-            throw exception(MD_ITEM_TYPE_NAME_DUPLICATE);
-        }
-        if (!Objects.equals(itemType.getId(), id)) {
+        if (ObjUtil.notEqual(itemType.getId(), id)) {
             throw exception(MD_ITEM_TYPE_NAME_DUPLICATE);
         }
     }
@@ -140,11 +135,7 @@ public class MesMdItemTypeServiceImpl implements MesMdItemTypeService {
         if (itemType == null) {
             return;
         }
-        // 如果 id 为空，说明不用比较是否为相同 id 的分类
-        if (id == null) {
-            throw exception(MD_ITEM_TYPE_CODE_DUPLICATE);
-        }
-        if (!Objects.equals(itemType.getId(), id)) {
+        if (ObjUtil.notEqual(itemType.getId(), id)) {
             throw exception(MD_ITEM_TYPE_CODE_DUPLICATE);
         }
     }
@@ -164,4 +155,25 @@ public class MesMdItemTypeServiceImpl implements MesMdItemTypeService {
         return itemTypeMapper.selectByIds(ids);
     }
+    @Override
+    public List<MesMdItemTypeDO> getItemTypeChildrenList(Long parentId) {
+        List<MesMdItemTypeDO> allList = itemTypeMapper.selectList(); // 分类总量小，全量查
+        // 递归收集所有子分类
+        List<MesMdItemTypeDO> result = new ArrayList<>();
+        collectItemTypeChildren(result, parentId, allList);
+        return result;
+    }
+
+    /**
+     * 递归收集所有子分类
+     */
+    private void collectItemTypeChildren(List<MesMdItemTypeDO> result, Long parentId, List<MesMdItemTypeDO> allList) {
+        for (MesMdItemTypeDO itemType : allList) {
+            if (Objects.equals(itemType.getParentId(), parentId)) {
+                result.add(itemType);
+                collectItemTypeChildren(result, itemType.getId(), allList);
+            }
+        }
+    }
+
 }