package cn.iocoder.yudao.module.mdm.api.item;
|
|
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
|
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
|
import cn.iocoder.yudao.module.mdm.api.item.dto.MdmItemSyncReqDTO;
|
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.mysql.item.MdmItemBatchConfigMapper;
|
import cn.iocoder.yudao.module.mdm.dal.mysql.item.MdmItemMapper;
|
import jakarta.annotation.Resource;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
|
|
/**
|
* MDM 物料同步 API 实现类
|
*
|
* @author 芋道源码
|
*/
|
@RestController
|
@Validated
|
public class MdmItemSyncApiImpl implements MdmItemSyncApi {
|
|
@Resource
|
private MdmItemMapper itemMapper;
|
|
@Resource
|
private MdmItemBatchConfigMapper itemBatchConfigMapper;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public CommonResult<Long> syncItemToMdm(MdmItemSyncReqDTO syncReqDTO) {
|
// 1. 按 code 查询是否已存在
|
MdmItemDO existingItem = itemMapper.selectByCode(syncReqDTO.getCode());
|
|
// 2. 保存或更新物料主数据
|
MdmItemDO item = BeanUtils.toBean(syncReqDTO, MdmItemDO.class);
|
Long itemId;
|
if (existingItem != null) {
|
// 更新
|
item.setId(existingItem.getId());
|
itemMapper.updateById(item);
|
itemId = existingItem.getId();
|
} else {
|
// 新增
|
itemMapper.insert(item);
|
itemId = item.getId();
|
}
|
|
// 3. 同步批次属性配置
|
syncBatchConfig(itemId, syncReqDTO);
|
|
return success(itemId);
|
}
|
|
/**
|
* 同步批次属性配置
|
*/
|
private void syncBatchConfig(Long itemId, MdmItemSyncReqDTO syncReqDTO) {
|
// 检查是否有批次配置数据
|
if (syncReqDTO.getProduceDateFlag() == null
|
&& syncReqDTO.getExpireDateFlag() == null
|
&& syncReqDTO.getReceiptDateFlag() == null
|
&& syncReqDTO.getVendorFlag() == null
|
&& syncReqDTO.getPurchaseOrderCodeFlag() == null
|
&& syncReqDTO.getLotNumberFlag() == null
|
&& syncReqDTO.getQualityStatusFlag() == null) {
|
return;
|
}
|
|
// 查询已有配置
|
MdmItemBatchConfigDO existing = itemBatchConfigMapper.selectOne(MdmItemBatchConfigDO::getItemId, itemId);
|
|
MdmItemBatchConfigDO config = new MdmItemBatchConfigDO();
|
config.setItemId(itemId);
|
config.setProduceDateFlag(Boolean.TRUE.equals(syncReqDTO.getProduceDateFlag()));
|
config.setExpireDateFlag(Boolean.TRUE.equals(syncReqDTO.getExpireDateFlag()));
|
config.setReceiptDateFlag(Boolean.TRUE.equals(syncReqDTO.getReceiptDateFlag()));
|
config.setVendorFlag(Boolean.TRUE.equals(syncReqDTO.getVendorFlag()));
|
config.setPurchaseOrderCodeFlag(Boolean.TRUE.equals(syncReqDTO.getPurchaseOrderCodeFlag()));
|
config.setLotNumberFlag(Boolean.TRUE.equals(syncReqDTO.getLotNumberFlag()));
|
config.setQualityStatusFlag(Boolean.TRUE.equals(syncReqDTO.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);
|
}
|
}
|
|
}
|
