xiaoyi
2026-10-30 2964b7707a8b24067d938d7a52d1c6edfbabee37
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
package cn.iocoder.yudao.module.mes.service.md.item;
 
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.batchconfig.MesMdItemBatchConfigSaveReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemBatchConfigDO;
import cn.iocoder.yudao.module.mes.dal.mysql.md.item.MesMdItemBatchConfigMapper;
import cn.iocoder.yudao.module.mdm.api.item.MdmItemApi;
import cn.iocoder.yudao.module.mdm.api.item.MdmItemBatchConfigApi;
import cn.iocoder.yudao.module.mdm.api.item.dto.MdmItemBatchConfigRespDTO;
import cn.iocoder.yudao.module.mdm.dal.dataobject.item.MdmItemBatchConfigDO;
import jakarta.annotation.Resource;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;
 
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MD_ITEM_BATCH_CONFIG_NOT_EXISTS;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MD_ITEM_NOT_EXISTS;
 
/**
 * MES 物料批次属性配置 Service 实现类
 *
 * 批次配置统一存储在 MDM 表(mdm_item_batch_config)
 * MES 本地表(mes_md_item_batch_config)仅用于兼容历史数据和 MES 模块内部查询
 *
 * @author 超级管理员
 */
@Service
@Validated
public class MesMdItemBatchConfigServiceImpl implements MesMdItemBatchConfigService {
 
    @Resource
    private MesMdItemBatchConfigMapper itemBatchConfigMapper;
 
    @Resource
    @Lazy
    private MesMdItemService itemService;
 
    @Resource
    @Lazy
    private MdmItemApi mdmItemApi;
 
    @Resource
    private MdmItemBatchConfigApi mdmItemBatchConfigApi;
 
    @Override
    public MesMdItemBatchConfigDO getItemBatchConfigByItemId(Long itemId) {
        // 优先从 MES 本地表查询(性能更好)
        MesMdItemBatchConfigDO mesConfig = itemBatchConfigMapper.selectByItemId(itemId);
        if (mesConfig != null) {
            return mesConfig;
        }
        // 本地表不存在,尝试从 MDM 获取(不写入本地,避免副作用)
        MdmItemBatchConfigRespDTO mdmConfig = mdmItemBatchConfigApi.getItemBatchConfig(itemId);
        if (mdmConfig != null) {
            return BeanUtils.toBean(mdmConfig, MesMdItemBatchConfigDO.class);
        }
        return null;
    }
 
    @Override
    public MesMdItemBatchConfigDO validateItemBatchConfigExists(Long itemId) {
        MesMdItemBatchConfigDO config = getItemBatchConfigByItemId(itemId);
        if (config == null) {
            throw exception(MD_ITEM_BATCH_CONFIG_NOT_EXISTS);
        }
        return config;
    }
 
    @Override
    @Transactional(rollbackFor = Exception.class)
    public Long saveItemBatchConfig(MesMdItemBatchConfigSaveReqVO saveReqVO) {
        // 1. 校验物料存在(从 MDM 校验)
        if (mdmItemApi.getItem(saveReqVO.getItemId()).getCheckedData() == null) {
            throw exception(MD_ITEM_NOT_EXISTS);
        }
 
        // 2. 全字段透传
        // 注意:这里曾经有一份「只保留 7 个字段」的白名单,把产品侧的
        // clientFlag / salesOrderCodeFlag / workOrderFlag / taskFlag /
        // workstationFlag / toolFlag / moldFlag 全部丢掉了,
        // 导致物料(半成品)和产品页面上的这些复选框勾了保存后不回显。
        // 批次属性是完整的 15 项,不再做字段裁剪。
        MesMdItemBatchConfigSaveReqVO cleanReqVO = saveReqVO;
 
        // 3. 保存到 MDM 表
        MdmItemBatchConfigDO mdmConfig = BeanUtils.toBean(cleanReqVO, MdmItemBatchConfigDO.class);
        Long configId = mdmItemBatchConfigApi.saveItemBatch(mdmConfig);
 
        // 4. 同步保存到 MES 本地表
        saveToMesTable(cleanReqVO);
 
        return configId;
    }
 
    @Override
    public void deleteItemBatchConfigByItemId(Long itemId) {
        itemBatchConfigMapper.deleteByItemId(itemId);
    }
 
    /**
     * 保存到 MES 本地表
     */
    private void saveToMesTable(MesMdItemBatchConfigSaveReqVO saveReqVO) {
        MesMdItemBatchConfigDO existing = itemBatchConfigMapper.selectByItemId(saveReqVO.getItemId());
        MesMdItemBatchConfigDO mesConfig = BeanUtils.toBean(saveReqVO, MesMdItemBatchConfigDO.class);
 
        if (existing != null) {
            // 存在则更新,使用已有的 ID
            mesConfig.setId(existing.getId());
            itemBatchConfigMapper.updateById(mesConfig);
        } else {
            // 不存在则插入,让数据库自动生成 ID
            mesConfig.setId(null);
            itemBatchConfigMapper.insert(mesConfig);
        }
    }
 
}