| | |
| | | import cn.hutool.core.util.ObjUtil; |
| | | 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.CommonResult; |
| | | import cn.iocoder.yudao.framework.common.util.object.BeanUtils; |
| | | import cn.iocoder.yudao.module.mdm.api.category.MdmItemCategoryApi; |
| | | import cn.iocoder.yudao.module.mdm.api.category.dto.MdmItemCategoryRespDTO; |
| | | import cn.iocoder.yudao.module.mdm.api.category.dto.MdmItemCategorySaveReqDTO; |
| | | import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.type.MesMdItemTypeImportExcelVO; |
| | | import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.type.MesMdItemTypeImportRespVO; |
| | | 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; |
| | | import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemTypeDO; |
| | | import cn.iocoder.yudao.module.mes.dal.mysql.md.item.MesMdItemTypeMapper; |
| | | import jakarta.annotation.Resource; |
| | | import org.springframework.context.annotation.Lazy; |
| | | import org.springframework.stereotype.Service; |
| | |
| | | /** |
| | | * MES ç©æäº§ååç±» Service å®ç°ç±» |
| | | * |
| | | * å
¼å®¹å±å®ç°ï¼æ°æ®åå¨å¨ mes_md_item_type 表ï¼ä½ä¼å
ä» MDM åç±» API è·å |
| | | * å®é
åç±»æ°æ®å·²è¿ç§»å° mdm_item_category 表 |
| | | * ç©æå类已ç»ä¸ç± MDM 管çï¼æ°æ®åå¨å¨ mdm_item_category 表ã |
| | | * æ¬æå¡ä¿ç MES çåç±»æ¥å£ï¼åºå±å
¨é¨éè¿ {@link MdmItemCategoryApi} 读å MDM åç±»ã |
| | | * |
| | | * @author è¶
级管çå |
| | | */ |
| | |
| | | @Validated |
| | | public class MesMdItemTypeServiceImpl implements MesMdItemTypeService { |
| | | |
| | | @Resource |
| | | private MdmItemCategoryApi mdmItemCategoryApi; |
| | | /** MDM ç©æç±»åï¼ç©æ */ |
| | | private static final Integer MDM_ITEM_TYPE_MATERIAL = 1; |
| | | /** MDM ç©æç±»åï¼äº§å */ |
| | | private static final Integer MDM_ITEM_TYPE_PRODUCT = 2; |
| | | /** MES ç©æ/äº§åæ è¯ï¼äº§å */ |
| | | private static final String ITEM_OR_PRODUCT_PRODUCT = "PRODUCT"; |
| | | |
| | | @Resource |
| | | private MesMdItemTypeMapper itemTypeMapper; |
| | | private MdmItemCategoryApi mdmItemCategoryApi; |
| | | |
| | | @Resource |
| | | @Lazy |
| | | private MesMdItemService itemService; |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public Long createItemType(MesMdItemTypeSaveReqVO createReqVO) { |
| | | // æ ¡éªæ°æ® |
| | | validateItemTypeSaveData(createReqVO); |
| | | |
| | | // æå
¥å°æ¬å°è¡¨ï¼ä¿æå
¼å®¹ï¼ |
| | | MesMdItemTypeDO itemType = BeanUtils.toBean(createReqVO, MesMdItemTypeDO.class); |
| | | itemTypeMapper.insert(itemType); |
| | | return itemType.getId(); |
| | | // æ ¡éªç¶åç±» |
| | | validateParentItemType(createReqVO.getId(), createReqVO.getParentId()); |
| | | // åå
¥ MDM å类表 |
| | | CommonResult<Long> result = mdmItemCategoryApi.createItemCategory(buildSaveDTO(createReqVO)); |
| | | return result.getData(); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void updateItemType(MesMdItemTypeSaveReqVO updateReqVO) { |
| | | // æ ¡éªåå¨ |
| | | validateItemTypeExists(updateReqVO.getId()); |
| | | // æ ¡éªæ°æ® |
| | | validateItemTypeSaveData(updateReqVO); |
| | | |
| | | // æ´æ°æ¬å°è¡¨ |
| | | MesMdItemTypeDO updateObj = BeanUtils.toBean(updateReqVO, MesMdItemTypeDO.class); |
| | | itemTypeMapper.updateById(updateObj); |
| | | // æ ¡éªç¶åç±» |
| | | validateParentItemType(updateReqVO.getId(), updateReqVO.getParentId()); |
| | | // æ´æ° MDM å类表 |
| | | MdmItemCategorySaveReqDTO updateDTO = buildSaveDTO(updateReqVO); |
| | | updateDTO.setId(updateReqVO.getId()); |
| | | mdmItemCategoryApi.updateItemCategory(updateDTO); |
| | | } |
| | | |
| | | private void validateItemTypeSaveData(MesMdItemTypeSaveReqVO reqVO) { |
| | | // æ ¡éªç¶åç±»ç¼å·çæææ§ |
| | | validateParentItemType(reqVO.getId(), reqVO.getParentId()); |
| | | // æ ¡éªåç±»åç§°çå¯ä¸æ§ |
| | | validateItemTypeNameUnique(reqVO.getId(), reqVO.getParentId(), reqVO.getName()); |
| | | // æ ¡éªåç±»ç¼ç çå¯ä¸æ§ |
| | | validateItemTypeCodeUnique(reqVO.getId(), reqVO.getParentId(), reqVO.getCode()); |
| | | private MdmItemCategorySaveReqDTO buildSaveDTO(MesMdItemTypeSaveReqVO reqVO) { |
| | | MdmItemCategorySaveReqDTO dto = new MdmItemCategorySaveReqDTO(); |
| | | dto.setParentId(ObjUtil.defaultIfNull(reqVO.getParentId(), MesMdItemTypeDO.PARENT_ID_ROOT)); |
| | | dto.setCode(reqVO.getCode()); |
| | | dto.setName(reqVO.getName()); |
| | | dto.setItemOrProduct(reqVO.getItemOrProduct()); |
| | | dto.setItemType(convertMdmItemType(reqVO.getItemOrProduct())); |
| | | dto.setSort(ObjUtil.defaultIfNull(reqVO.getSort(), 0)); |
| | | dto.setStatus(ObjUtil.defaultIfNull(reqVO.getStatus(), CommonStatusEnum.ENABLE.getStatus())); |
| | | dto.setRemark(reqVO.getRemark()); |
| | | return dto; |
| | | } |
| | | |
| | | /** |
| | | * MES ç©æ/äº§åæ è¯ -> MDM ç©æç±»å |
| | | */ |
| | | private Integer convertMdmItemType(String itemOrProduct) { |
| | | if (StrUtil.isBlank(itemOrProduct)) { |
| | | return null; |
| | | } |
| | | return ITEM_OR_PRODUCT_PRODUCT.equalsIgnoreCase(itemOrProduct) |
| | | ? MDM_ITEM_TYPE_PRODUCT : MDM_ITEM_TYPE_MATERIAL; |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void deleteItemType(Long id) { |
| | | // 1.1 æ ¡éªåå¨ |
| | | validateItemTypeExists(id); |
| | | // 1.2 æ ¡éªæ¯å¦æååç±» |
| | | if (itemTypeMapper.selectCountByParentId(id) > 0) { |
| | | throw exception(MD_ITEM_TYPE_EXITS_CHILDREN); |
| | | } |
| | | // 1.3 æ ¡éªæ¯å¦æç©æ |
| | | // 1.2 æ ¡éªæ¯å¦æç©æ |
| | | if (itemService.getItemCountByItemTypeId(id) > 0) { |
| | | throw exception(MD_ITEM_TYPE_EXITS_ITEM); |
| | | } |
| | | |
| | | // 2. å é¤ |
| | | itemTypeMapper.deleteById(id); |
| | | // 2. å é¤ï¼ååç±»ãMDM ç©æå¼ç¨ç± MDM ä¾§æ ¡éªï¼ |
| | | mdmItemCategoryApi.deleteItemCategory(id); |
| | | } |
| | | |
| | | private void validateItemTypeExists(Long id) { |
| | | // ä¼å
ä» MDM è·å |
| | | CommonResult<MdmItemCategoryRespDTO> result = mdmItemCategoryApi.getItemCategory(id); |
| | | if (result.isSuccess() && result.getData() != null) { |
| | | return; |
| | | } |
| | | // åéå°æ¬å°è¡¨ |
| | | if (itemTypeMapper.selectById(id) == null) { |
| | | if (getItemType(id) == null) { |
| | | throw exception(MD_ITEM_TYPE_NOT_EXISTS); |
| | | } |
| | | } |
| | |
| | | if (Objects.equals(id, parentId)) { |
| | | throw exception(MD_ITEM_TYPE_PARENT_ERROR); |
| | | } |
| | | // 2. ç¶åç±»ä¸åå¨ - ä¼å
ä» MDM è·å |
| | | CommonResult<MdmItemCategoryRespDTO> result = mdmItemCategoryApi.getItemCategory(parentId); |
| | | MesMdItemTypeDO parentItemType = null; |
| | | if (result.isSuccess() && result.getData() != null) { |
| | | parentItemType = convertToMesDO(result.getData()); |
| | | } else { |
| | | parentItemType = itemTypeMapper.selectById(parentId); |
| | | } |
| | | // 2. ç¶åç±»ä¸åå¨ |
| | | MesMdItemTypeDO parentItemType = getItemType(parentId); |
| | | if (parentItemType == null) { |
| | | throw exception(MD_ITEM_TYPE_PARENT_NOT_EXITS); |
| | | } |
| | |
| | | if (parentId == null || MesMdItemTypeDO.PARENT_ID_ROOT.equals(parentId)) { |
| | | break; |
| | | } |
| | | // ç»§ç»æ¥æ¾ç¶çº§ |
| | | CommonResult<MdmItemCategoryRespDTO> parentResult = mdmItemCategoryApi.getItemCategory(parentId); |
| | | if (parentResult.isSuccess() && parentResult.getData() != null) { |
| | | parentItemType = convertToMesDO(parentResult.getData()); |
| | | } else { |
| | | parentItemType = itemTypeMapper.selectById(parentId); |
| | | } |
| | | parentItemType = getItemType(parentId); |
| | | if (parentItemType == null) { |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | |
| | | private void validateItemTypeNameUnique(Long id, Long parentId, String name) { |
| | | MesMdItemTypeDO itemType = itemTypeMapper.selectByParentIdAndName(parentId, name); |
| | | if (itemType == null) { |
| | | return; |
| | | } |
| | | if (ObjUtil.notEqual(itemType.getId(), id)) { |
| | | throw exception(MD_ITEM_TYPE_NAME_DUPLICATE); |
| | | } |
| | | } |
| | | |
| | | private void validateItemTypeCodeUnique(Long id, Long parentId, String code) { |
| | | MesMdItemTypeDO itemType = itemTypeMapper.selectByParentIdAndCode(parentId, code); |
| | | if (itemType == null) { |
| | | return; |
| | | } |
| | | if (ObjUtil.notEqual(itemType.getId(), id)) { |
| | | throw exception(MD_ITEM_TYPE_CODE_DUPLICATE); |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public MesMdItemTypeDO getItemType(Long id) { |
| | | // ä¼å
ä» MDM è·å |
| | | CommonResult<MdmItemCategoryRespDTO> result = mdmItemCategoryApi.getItemCategory(id); |
| | | if (result.isSuccess() && result.getData() != null) { |
| | | return convertToMesDO(result.getData()); |
| | | } |
| | | // åéå°æ¬å°è¡¨ |
| | | return itemTypeMapper.selectById(id); |
| | | return result.isSuccess() ? convertToMesDO(result.getData()) : null; |
| | | } |
| | | |
| | | @Override |
| | | public MesMdItemTypeDO getItemTypeByCode(String code) { |
| | | // 仿¬å°è¡¨æ¥ |
| | | return itemTypeMapper.selectByCode(code); |
| | | CommonResult<MdmItemCategoryRespDTO> result = mdmItemCategoryApi.getItemCategoryByCode(code); |
| | | return result.isSuccess() ? convertToMesDO(result.getData()) : null; |
| | | } |
| | | |
| | | @Override |
| | | public List<MesMdItemTypeDO> getItemTypeList(MesMdItemTypeListReqVO listReqVO) { |
| | | // 仿¬å°è¡¨æ¥ |
| | | return itemTypeMapper.selectList(listReqVO); |
| | | List<MesMdItemTypeDO> list = getAllItemTypeList(); |
| | | return list.stream() |
| | | .filter(itemType -> StrUtil.isBlank(listReqVO.getName()) |
| | | || StrUtil.contains(itemType.getName(), listReqVO.getName())) |
| | | .filter(itemType -> listReqVO.getStatus() == null |
| | | || Objects.equals(listReqVO.getStatus(), itemType.getStatus())) |
| | | .sorted(Comparator.comparing(itemType -> ObjUtil.defaultIfNull(itemType.getSort(), 0))) |
| | | .toList(); |
| | | } |
| | | |
| | | @Override |
| | |
| | | if (CollUtil.isEmpty(ids)) { |
| | | return Collections.emptyList(); |
| | | } |
| | | return itemTypeMapper.selectByIds(ids); |
| | | CommonResult<List<MdmItemCategoryRespDTO>> result = mdmItemCategoryApi.getItemCategoryList(ids); |
| | | return convertToMesDOList(result.isSuccess() ? result.getData() : null); |
| | | } |
| | | |
| | | private List<MesMdItemTypeDO> getAllItemTypeList() { |
| | | CommonResult<List<MdmItemCategoryRespDTO>> result = mdmItemCategoryApi.getItemCategoryAllList(); |
| | | return convertToMesDOList(result.isSuccess() ? result.getData() : null); |
| | | } |
| | | |
| | | private List<MesMdItemTypeDO> convertToMesDOList(List<MdmItemCategoryRespDTO> list) { |
| | | if (CollUtil.isEmpty(list)) { |
| | | return new ArrayList<>(); |
| | | } |
| | | return new ArrayList<>(list.stream().map(this::convertToMesDO).toList()); |
| | | } |
| | | |
| | | @Override |
| | | public List<MesMdItemTypeDO> getItemTypeChildrenList(Long parentId) { |
| | | List<MesMdItemTypeDO> allList = itemTypeMapper.selectList(); |
| | | List<MesMdItemTypeDO> allList = getAllItemTypeList(); |
| | | List<MesMdItemTypeDO> result = new ArrayList<>(); |
| | | collectItemTypeChildren(result, parentId, allList); |
| | | return result; |
| | |
| | | * è½¬æ¢ MDM åç±» DTO 为 MES DO |
| | | */ |
| | | private MesMdItemTypeDO convertToMesDO(MdmItemCategoryRespDTO dto) { |
| | | if (dto == null) { |
| | | return null; |
| | | } |
| | | MesMdItemTypeDO mesDO = new MesMdItemTypeDO(); |
| | | mesDO.setId(dto.getId()); |
| | | mesDO.setCode(dto.getCode()); |
| | |
| | | mesDO.setItemOrProduct(dto.getItemOrProduct()); |
| | | mesDO.setSort(dto.getSort()); |
| | | mesDO.setStatus(dto.getStatus()); |
| | | mesDO.setRemark(dto.getRemark()); |
| | | mesDO.setCreateTime(dto.getCreateTime()); |
| | | return mesDO; |
| | | } |
| | | |
| | |
| | | MesMdItemTypeImportRespVO respVO = MesMdItemTypeImportRespVO.builder() |
| | | .createCodes(new ArrayList<>()).updateCodes(new ArrayList<>()) |
| | | .failureCodes(new LinkedHashMap<>()).build(); |
| | | List<MesMdItemTypeDO> allList = getAllItemTypeList(); |
| | | AtomicInteger index = new AtomicInteger(1); |
| | | importItemTypeList.forEach(importItem -> { |
| | | int currentIndex = index.getAndIncrement(); |
| | |
| | | // 2.1 è§£æç¶åç±»ï¼ä¸ºç©ºåé»è®¤ä¸ºæ ¹åç±»ï¼ |
| | | Long parentId = MesMdItemTypeDO.PARENT_ID_ROOT; |
| | | if (StrUtil.isNotBlank(importItem.getParentCode())) { |
| | | MesMdItemTypeDO parentItemType = itemTypeMapper.selectByCode(importItem.getParentCode()); |
| | | MesMdItemTypeDO parentItemType = allList.stream() |
| | | .filter(itemType -> Objects.equals(importItem.getParentCode(), itemType.getCode())) |
| | | .findFirst().orElse(null); |
| | | if (parentItemType == null) { |
| | | respVO.getFailureCodes().put(key, "ç¶åç±»ç¼ç [" + importItem.getParentCode() + "]ä¸åå¨"); |
| | | return; |
| | |
| | | parentId = parentItemType.getId(); |
| | | } |
| | | // 2.2 夿æ¯å¦åå¨ï¼åä¸ç¶åç±»ä¸ç¼ç å¯ä¸ï¼ |
| | | MesMdItemTypeDO existItemType = itemTypeMapper.selectByParentIdAndCode(parentId, importItem.getCode()); |
| | | if (existItemType == null) { |
| | | // 2.2.1 æ°å¢ |
| | | MesMdItemTypeDO itemType = BeanUtils.toBean(importItem, MesMdItemTypeDO.class); |
| | | itemType.setParentId(parentId); |
| | | itemType.setSort(ObjUtil.defaultIfNull(importItem.getSort(), 0)); |
| | | itemType.setStatus(ObjUtil.defaultIfNull(importItem.getStatus(), CommonStatusEnum.ENABLE.getStatus())); |
| | | itemTypeMapper.insert(itemType); |
| | | respVO.getCreateCodes().add(importItem.getCode()); |
| | | } else if (updateSupport) { |
| | | // 2.2.2 æ´æ° |
| | | MesMdItemTypeDO updateObj = BeanUtils.toBean(importItem, MesMdItemTypeDO.class); |
| | | updateObj.setId(existItemType.getId()); |
| | | updateObj.setParentId(parentId); |
| | | itemTypeMapper.updateById(updateObj); |
| | | respVO.getUpdateCodes().add(importItem.getCode()); |
| | | } else { |
| | | respVO.getFailureCodes().put(key, "åç±»ç¼ç å·²åå¨"); |
| | | Long finalParentId = parentId; |
| | | MesMdItemTypeDO existItemType = allList.stream() |
| | | .filter(itemType -> Objects.equals(finalParentId, itemType.getParentId()) |
| | | && Objects.equals(importItem.getCode(), itemType.getCode())) |
| | | .findFirst().orElse(null); |
| | | try { |
| | | MdmItemCategorySaveReqDTO dto = new MdmItemCategorySaveReqDTO(); |
| | | dto.setParentId(parentId); |
| | | dto.setCode(importItem.getCode()); |
| | | dto.setName(importItem.getName()); |
| | | dto.setItemOrProduct(importItem.getItemOrProduct()); |
| | | dto.setItemType(convertMdmItemType(importItem.getItemOrProduct())); |
| | | dto.setSort(ObjUtil.defaultIfNull(importItem.getSort(), 0)); |
| | | dto.setStatus(ObjUtil.defaultIfNull(importItem.getStatus(), CommonStatusEnum.ENABLE.getStatus())); |
| | | dto.setRemark(importItem.getRemark()); |
| | | if (existItemType == null) { |
| | | // 2.2.1 æ°å¢ |
| | | dto.setId(null); |
| | | Long id = mdmItemCategoryApi.createItemCategory(dto).getData(); |
| | | MesMdItemTypeDO created = new MesMdItemTypeDO(); |
| | | created.setId(id); |
| | | created.setParentId(parentId); |
| | | created.setCode(importItem.getCode()); |
| | | created.setName(importItem.getName()); |
| | | created.setItemOrProduct(importItem.getItemOrProduct()); |
| | | created.setSort(dto.getSort()); |
| | | created.setStatus(dto.getStatus()); |
| | | created.setRemark(importItem.getRemark()); |
| | | allList.add(created); |
| | | respVO.getCreateCodes().add(importItem.getCode()); |
| | | } else if (updateSupport) { |
| | | // 2.2.2 æ´æ° |
| | | dto.setId(existItemType.getId()); |
| | | mdmItemCategoryApi.updateItemCategory(dto); |
| | | respVO.getUpdateCodes().add(importItem.getCode()); |
| | | } else { |
| | | respVO.getFailureCodes().put(key, "åç±»ç¼ç å·²åå¨"); |
| | | } |
| | | } catch (ServiceException e) { |
| | | respVO.getFailureCodes().put(key, e.getMessage()); |
| | | } |
| | | }); |
| | | return respVO; |
| | | } |
| | | |
| | | } |
| | | } |