feat(mes): 物料新增「颜色」字段并补齐物料导入功能

xiaoyi

10 天以前 e5c709000047e1f784390772d8db94164c6e3df4

feat(mes): 物料新增「颜色」字段并补齐物料导入功能

1. mes_md_item 新增 color 字段，DO/SaveReqVO/RespVO/PageReqVO 同步，支持按颜色模糊搜索

2. 物料导出 Excel 模板新增「颜色」列

3. 新增物料导入接口 get-import-template / import，导入模板含颜色列并带示例数据，逐行校验失败不影响整批

4. 导入支持「是否覆盖」更新已存在物料

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/md/item/MesMdItemController.java

@@ -8,6 +8,8 @@
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;
@@ -19,6 +21,7 @@
import cn.iocoder.yudao.module.mes.service.md.unitmeasure.MesMdUnitMeasureService;
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;
@@ -26,8 +29,11 @@
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.math.BigDecimal;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.Map;
@@ -103,6 +109,37 @@
                buildItemVOList(pageResult.getList()));
    }

    @GetMapping("/get-import-template")
    @Operation(summary = "获得物料导入模板")
    @PreAuthorize("@ss.hasPermission('mes:md-item:import')")
    public void importTemplate(HttpServletResponse response) throws IOException {
        List<MesMdItemImportExcelVO> list = Arrays.asList(
                MesMdItemImportExcelVO.builder()
                        .code("ITEM_RAW_001").name("铜杆").specification("Φ8mm").color("红色")
                        .unitMeasureName("千克").itemTypeName("原材料")
                        .safeStockFlag(true).minStock(new BigDecimal("100")).maxStock(new BigDecimal("10000"))
                        .highValue(false).batchFlag(true).remark("示例：计量单位、物料分类请填写系统中已存在的名称").build(),
                MesMdItemImportExcelVO.builder()
                        .code("ITEM_RAW_002").name("铝杆").specification("Φ9.5mm").color("蓝色")
                        .unitMeasureName("千克").itemTypeName("原材料")
                        .safeStockFlag(false).highValue(false).batchFlag(false).remark("示例：颜色用于区分同型号不同颜色的物料").build()
        );
        ExcelUtils.writeTemplate(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:import')")
    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) {

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/md/item/vo/MesMdItemImportExcelVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,58 @@
package cn.iocoder.yudao.module.mes.controller.admin.md.item.vo;

import cn.idev.excel.annotation.ExcelProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.math.BigDecimal;

/**
 * MES ç‰©æ–™äº§å“å¯¼å…¥ Excel VO
 *
 * @author è¶…级管理员
 */
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class MesMdItemImportExcelVO {

    @ExcelProperty("物料编码")
    private String code;

    @ExcelProperty("物料名称")
    private String name;

    @ExcelProperty("规格型号")
    private String specification;

    @ExcelProperty("颜色")
    private String color;

    @ExcelProperty("计量单位")
    private String unitMeasureName;

    @ExcelProperty("物料分类")
    private String itemTypeName;

    @ExcelProperty("是否启用安全库存")
    private Boolean safeStockFlag;

    @ExcelProperty("最低库存量")
    private BigDecimal minStock;

    @ExcelProperty("最高库存量")
    private BigDecimal maxStock;

    @ExcelProperty("是否高值物料")
    private Boolean highValue;

    @ExcelProperty("是否启用批次管理")
    private Boolean batchFlag;

    @ExcelProperty("备注")
    private String remark;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/md/item/vo/MesMdItemImportRespVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,34 @@
package cn.iocoder.yudao.module.mes.controller.admin.md.item.vo;

import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Builder;
import lombok.Data;

import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

@Schema(description = "管理后台 - MES ç‰©æ–™äº§å“å¯¼å…¥ Response VO")
@Data
@Builder
public class MesMdItemImportRespVO {

    @Schema(description = "创建成功的物料编码数组", requiredMode = Schema.RequiredMode.REQUIRED)
    private List<String> createCodes;

    @Schema(description = "更新成功的物料编码数组", requiredMode = Schema.RequiredMode.REQUIRED)
    private List<String> updateCodes;

    @Schema(description = "导入失败的物料编码集合 key ä¸ºç‰©æ–™ç¼–码（或行号），value ä¸ºå¤±è´¥åŽŸå› ", requiredMode = Schema.RequiredMode.REQUIRED)
    private Map<String, String> failureCodes;

    public static MesMdItemImportRespVO empty() {
        return MesMdItemImportRespVO.builder()
                .createCodes(new ArrayList<>())
                .updateCodes(new ArrayList<>())
                .failureCodes(new LinkedHashMap<>())
                .build();
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/md/item/vo/MesMdItemPageReqVO.java

@@ -26,6 +26,9 @@
    @Schema(description = "规格型号", example = "60g")
    private String specification;

    @Schema(description = "颜色", example = "红色")
    private String color;

    @Schema(description = "物料分类编号", example = "1")
    private Long itemTypeId;


 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/md/item/vo/MesMdItemRespVO.java

@@ -32,6 +32,10 @@
    @ExcelProperty("规格型号")
    private String specification;

    @Schema(description = "颜色", example = "红色")
    @ExcelProperty("颜色")
    private String color;

    @Schema(description = "计量单位编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "202")
    private Long unitMeasureId;
    @Schema(description = "计量单位名称", example = "个")

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/md/item/vo/MesMdItemSaveReqVO.java

@@ -25,6 +25,9 @@
    @Schema(description = "规格型号", example = "M6*20")
    private String specification;

    @Schema(description = "颜色", example = "红色")
    private String color;

    @Schema(description = "计量单位编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "202")
    @NotNull(message = "计量单位不能为空")
    private Long unitMeasureId;

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/dataobject/md/item/MesMdItemDO.java

@@ -48,6 +48,12 @@
     */
    private String specification;
    /**
     * é¢œè‰²
     *
     * ç”¨äºŽåŒºåˆ†åŒåž‹å·ä¸åŒé¢œè‰²çš„物料
     */
    private String color;
    /**
     * è®¡é‡å•ä½ç¼–号
     *
     * å…³è” {@link MesMdUnitMeasureDO#getId()}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/md/item/MesMdItemMapper.java

@@ -37,6 +37,7 @@
                .inIfPresent(MesMdItemDO::getItemTypeId, itemTypeIds)
                .inIfPresent(MesMdItemDO::getId,
                        StrUtil.isBlank(reqVO.getIds()) ? null : StrUtils.splitToLong(reqVO.getIds(), ","))
                .likeIfPresent(MesMdItemDO::getColor, reqVO.getColor())
                .eqIfPresent(MesMdItemDO::getStatus, reqVO.getStatus())
                .betweenIfPresent(MesMdItemDO::getCreateTime, reqVO.getCreateTime())
                .orderByAsc(MesMdItemTypeDO::getSort)

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/md/item/MesMdItemService.java

@@ -2,6 +2,8 @@

import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.MesMdItemPageReqVO;
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.MesMdItemSaveReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemDO;
import jakarta.validation.Valid;
@@ -140,4 +142,13 @@
     */
    MesMdItemDO validateItemExistsByMdmItemId(Long mdmItemId);

    /**
     * æ‰¹é‡å¯¼å…¥ç‰©æ–™äº§å“
     *
     * @param importList    å¯¼å…¥æ•°æ®
     * @param updateSupport æ˜¯å¦æ”¯æŒæ›´æ–°å·²å­˜åœ¨çš„物料
     * @return å¯¼å…¥ç»“æžœ
     */
    MesMdItemImportRespVO importItemList(List<MesMdItemImportExcelVO> importList, Boolean updateSupport);

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/md/item/MesMdItemServiceImpl.java

@@ -2,8 +2,11 @@

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjUtil;
import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
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.MesMdItemSaveReqVO;
import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
@@ -12,6 +15,7 @@
import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemTypeDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.md.unitmeasure.MesMdUnitMeasureDO;
import cn.iocoder.yudao.module.mes.dal.mysql.md.item.MesMdItemMapper;
import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.type.MesMdItemTypeListReqVO;
import cn.iocoder.yudao.module.mes.enums.md.MesMdItemTypeEnum;

import cn.iocoder.yudao.module.mes.enums.wm.BarcodeBizTypeEnum;
@@ -408,4 +412,82 @@
        return item;
    }

}
    @Override
    @Transactional(rollbackFor = Exception.class)
    public MesMdItemImportRespVO importItemList(List<MesMdItemImportExcelVO> importList, Boolean updateSupport) {
        MesMdItemImportRespVO respVO = MesMdItemImportRespVO.empty();
        if (CollUtil.isEmpty(importList)) {
            return respVO;
        }
        // é¢„加载计量单位、物料分类，按名称建索引，避免逐行查库
        Map<String, Long> unitMeasureMap = new HashMap<>();
        unitMeasureService.getUnitMeasureListByStatus(CommonStatusEnum.ENABLE.getStatus())
                .forEach(unit -> unitMeasureMap.put(unit.getName().trim(), unit.getId()));
        Map<String, Long> itemTypeMap = new HashMap<>();
        itemTypeService.getItemTypeList(new MesMdItemTypeListReqVO())
                .forEach(type -> itemTypeMap.put(type.getName().trim(), type.getId()));

        int index = 0;
        for (MesMdItemImportExcelVO row : importList) {
            index++;
            String key = StrUtil.isNotBlank(row.getCode()) ? row.getCode().trim() : "第 " + index + " è¡Œ";
            // 1. åŸºç¡€æ ¡éªŒ
            if (StrUtil.isBlank(row.getCode())) {
                respVO.getFailureCodes().put(key, "物料编码不能为空");
                continue;
            }
            if (StrUtil.isBlank(row.getName())) {
                respVO.getFailureCodes().put(key, "物料名称不能为空");
                continue;
            }
            String code = row.getCode().trim();
            String unitName = StrUtil.trim(row.getUnitMeasureName());
            Long unitMeasureId = unitName == null ? null : unitMeasureMap.get(unitName);
            if (unitMeasureId == null) {
                respVO.getFailureCodes().put(key, "计量单位[" + unitName + "]不存在");
                continue;
            }
            String typeName = StrUtil.trim(row.getItemTypeName());
            Long itemTypeId = typeName == null ? null : itemTypeMap.get(typeName);
            if (itemTypeId == null) {
                respVO.getFailureCodes().put(key, "物料分类[" + typeName + "]不存在");
                continue;
            }

            // 2. ç»„装保存对象（颜色一并写入）
            MesMdItemSaveReqVO saveReqVO = new MesMdItemSaveReqVO();
            saveReqVO.setCode(code);
            saveReqVO.setName(row.getName().trim());
            saveReqVO.setSpecification(StrUtil.trim(row.getSpecification()));
            saveReqVO.setColor(StrUtil.trim(row.getColor()));
            saveReqVO.setUnitMeasureId(unitMeasureId);
            saveReqVO.setItemTypeId(itemTypeId);
            saveReqVO.setSafeStockFlag(row.getSafeStockFlag());
            saveReqVO.setMinStock(row.getMinStock());
            saveReqVO.setMaxStock(row.getMaxStock());
            saveReqVO.setHighValue(row.getHighValue());
            saveReqVO.setBatchFlag(row.getBatchFlag());
            saveReqVO.setRemark(StrUtil.trim(row.getRemark()));

            // 3. æ–°å¢žæˆ–更新，单行失败不影响整批
            MesMdItemDO existItem = itemMapper.selectByCode(code);
            try {
                if (existItem == null) {
                    createItem(saveReqVO);
                    respVO.getCreateCodes().add(code);
                } else if (!Boolean.TRUE.equals(updateSupport)) {
                    respVO.getFailureCodes().put(key, "物料编码已存在（勾选「是否覆盖」可更新）");
                } else {
                    saveReqVO.setId(existItem.getId());
                    saveReqVO.setMdmItemId(existItem.getMdmItemId());
                    updateItem(saveReqVO);
                    respVO.getUpdateCodes().add(code);
                }
            } catch (Exception e) {
                respVO.getFailureCodes().put(key, e.getMessage() == null ? "导入失败" : e.getMessage());
            }
        }
        return respVO;
    }

}