From 44840942aba889088a86d2b3d93856530bb2dc25 Mon Sep 17 00:00:00 2001
From: hsy <1029150275@qq.com>
Date: 星期二, 25 八月 2026 16:51:29 +0800
Subject: [PATCH] Merge branch 'dev_business' into fix/hsy/20260811
---
yudao-module-mdm/src/main/java/cn/iocoder/yudao/module/mdm/service/unit/MdmUnitMeasureServiceImpl.java | 200 ++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 200 insertions(+), 0 deletions(-)
diff --git a/yudao-module-mdm/src/main/java/cn/iocoder/yudao/module/mdm/service/unit/MdmUnitMeasureServiceImpl.java b/yudao-module-mdm/src/main/java/cn/iocoder/yudao/module/mdm/service/unit/MdmUnitMeasureServiceImpl.java
new file mode 100644
index 0000000..8660a6a
--- /dev/null
+++ b/yudao-module-mdm/src/main/java/cn/iocoder/yudao/module/mdm/service/unit/MdmUnitMeasureServiceImpl.java
@@ -0,0 +1,200 @@
+package cn.iocoder.yudao.module.mdm.service.unit;
+
+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.mdm.controller.admin.unit.vo.MdmUnitMeasureImportExcelVO;
+import cn.iocoder.yudao.module.mdm.controller.admin.unit.vo.MdmUnitMeasureImportRespVO;
+import cn.iocoder.yudao.module.mdm.controller.admin.unit.vo.MdmUnitMeasurePageReqVO;
+import cn.iocoder.yudao.module.mdm.controller.admin.unit.vo.MdmUnitMeasureSaveReqVO;
+import cn.iocoder.yudao.module.mdm.dal.dataobject.unit.MdmUnitMeasureDO;
+import cn.iocoder.yudao.module.mdm.dal.mysql.item.MdmItemMapper;
+import cn.iocoder.yudao.module.mdm.dal.mysql.unit.MdmUnitMeasureMapper;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.validation.annotation.Validated;
+
+import java.util.*;
+
+import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.iocoder.yudao.module.mdm.enums.ErrorCodeConstants.*;
+
+/**
+ * MDM 璁￠噺鍗曚綅 Service 瀹炵幇绫�
+ *
+ * @author 瓒呯骇绠＄悊鍛�
+ */
+@Service
+@Validated
+public class MdmUnitMeasureServiceImpl implements MdmUnitMeasureService {
+
+ @Resource
+ private MdmUnitMeasureMapper unitMeasureMapper;
+
+ @Resource
+ private MdmItemMapper itemMapper;
+
+ @Override
+ public Long createUnitMeasure(MdmUnitMeasureSaveReqVO createReqVO) {
+ // 鏍￠獙鏁版嵁
+ validateUnitMeasureSaveData(createReqVO);
+
+ // 鎻掑叆
+ MdmUnitMeasureDO unitMeasure = BeanUtils.toBean(createReqVO, MdmUnitMeasureDO.class);
+ unitMeasureMapper.insert(unitMeasure);
+ return unitMeasure.getId();
+ }
+
+ @Override
+ public void updateUnitMeasure(MdmUnitMeasureSaveReqVO updateReqVO) {
+ // 鏍￠獙瀛樺湪
+ validateUnitMeasureExists(updateReqVO.getId());
+ // 鏍￠獙鏁版嵁
+ validateUnitMeasureSaveData(updateReqVO);
+
+ // 鏇存柊
+ MdmUnitMeasureDO updateObj = BeanUtils.toBean(updateReqVO, MdmUnitMeasureDO.class);
+ unitMeasureMapper.updateById(updateObj);
+ }
+
+ @Override
+ public void updateUnitMeasureStatus(Long id, Integer status) {
+ // 鏍￠獙瀛樺湪
+ validateUnitMeasureExists(id);
+ // 鏇存柊鐘舵��
+ unitMeasureMapper.updateById(new MdmUnitMeasureDO().setId(id).setStatus(status));
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void deleteUnitMeasure(Long id) {
+ // 鏍￠獙瀛樺湪
+ MdmUnitMeasureDO unitMeasure = validateUnitMeasureExists(id);
+ // 鏍￠獙鏄惁琚墿鏂欎娇鐢紙鐩存帴浣跨敤 Mapper 閬垮厤寰幆渚濊禆锛�
+ if (itemMapper.selectCountByUnitMeasureId(id) > 0) {
+ throw exception(MDM_UNIT_MEASURE_EXISTS_ITEM);
+ }
+ // 鍏堟竻鐞嗗悓缂栫爜鐨勫凡杞垹闄よ剰鏁版嵁锛岄伩鍏嶅綋鍓嶈褰曡蒋鍒犳椂瑙﹀彂鍞竴閿啿绐�
+ unitMeasureMapper.physicalDeleteByCode(unitMeasure.getCode());
+ // 鍒犻櫎
+ unitMeasureMapper.deleteById(id);
+ }
+
+ @Override
+ public MdmUnitMeasureDO validateUnitMeasureExists(Long id) {
+ MdmUnitMeasureDO unitMeasure = unitMeasureMapper.selectById(id);
+ if (unitMeasure == null) {
+ throw exception(MDM_UNIT_MEASURE_NOT_EXISTS);
+ }
+ return unitMeasure;
+ }
+
+ private void validateUnitMeasureSaveData(MdmUnitMeasureSaveReqVO reqVO) {
+ // 鏍￠獙缂栫爜鍞竴
+ MdmUnitMeasureDO unit = unitMeasureMapper.selectByCode(reqVO.getCode());
+ if (unit != null && ObjUtil.notEqual(unit.getId(), reqVO.getId())) {
+ throw exception(MDM_UNIT_MEASURE_CODE_DUPLICATE);
+ }
+ // 鏍￠獙鍚嶇О鍞竴
+ MdmUnitMeasureDO sameName = unitMeasureMapper.selectByName(reqVO.getName());
+ if (sameName != null && ObjUtil.notEqual(sameName.getId(), reqVO.getId())) {
+ throw exception(MDM_UNIT_MEASURE_NAME_DUPLICATE);
+ }
+ }
+
+ @Override
+ public MdmUnitMeasureDO getUnitMeasure(Long id) {
+ return unitMeasureMapper.selectById(id);
+ }
+
+ @Override
+ public PageResult<MdmUnitMeasureDO> getUnitMeasurePage(MdmUnitMeasurePageReqVO pageReqVO) {
+ return unitMeasureMapper.selectPage(pageReqVO);
+ }
+
+ @Override
+ public List<MdmUnitMeasureDO> getUnitMeasureList(Collection<Long> ids) {
+ if (CollUtil.isEmpty(ids)) {
+ return Collections.emptyList();
+ }
+ return unitMeasureMapper.selectBatchIds(ids);
+ }
+
+ @Override
+ public MdmUnitMeasureDO getUnitMeasureByCode(String code) {
+ return unitMeasureMapper.selectByCode(code);
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public MdmUnitMeasureImportRespVO importUnitMeasureList(List<MdmUnitMeasureImportExcelVO> importList, Boolean isUpdateSupport) {
+ if (CollUtil.isEmpty(importList)) {
+ throw exception(MDM_UNIT_MEASURE_IMPORT_LIST_IS_EMPTY);
+ }
+ MdmUnitMeasureImportRespVO respVO = MdmUnitMeasureImportRespVO.builder()
+ .createList(new ArrayList<>()).updateList(new ArrayList<>())
+ .failureList(new LinkedHashMap<>()).build();
+
+ // 1. 寤虹珛缂栫爜 -> ID 鏄犲皠锛堝厛鍔犺浇鐜版湁鍗曚綅锛屽啀鍙犲姞鏈鏂板缓鐨勫崟浣嶏級锛岀敤浜庤В鏋�"涓诲崟浣嶇紪鐮�"鍒�
+ Map<String, Long> codeIdMap = new HashMap<>();
+ for (MdmUnitMeasureDO unit : unitMeasureMapper.selectList()) {
+ codeIdMap.put(unit.getCode(), unit.getId());
+ }
+ // 璁板綍鏈瀵煎叆宸插鐞嗚繃鐨勭紪鐮侊紝閬垮厤鍚屼竴鏂囦欢鍐呭悗缁鎵句笉鍒板垰瀵煎叆鐨勪富鍗曚綅
+ Map<String, Long> importedCodeIdMap = new HashMap<>();
+
+ // 2. 閬嶅巻瀵煎叆
+ for (MdmUnitMeasureImportExcelVO importVO : importList) {
+ // 2.1 鍩虹鏍￠獙
+ if (StrUtil.isBlank(importVO.getCode()) || StrUtil.isBlank(importVO.getName())) {
+ respVO.getFailureList().put(StrUtil.blankToDefault(importVO.getName(), importVO.getCode()), "鍗曚綅缂栫爜鍜屽崟浣嶅悕绉颁笉鑳戒负绌�");
+ continue;
+ }
+ // 2.2 瑙ｆ瀽涓诲崟浣� ID锛堥潪涓诲崟浣嶆椂蹇呭～涓诲崟浣嶇紪鐮侊級
+ Long primaryId = null;
+ if (StrUtil.isNotBlank(importVO.getPrimaryCode())) {
+ primaryId = importedCodeIdMap.get(importVO.getPrimaryCode()) != null
+ ? importedCodeIdMap.get(importVO.getPrimaryCode())
+ : codeIdMap.get(importVO.getPrimaryCode());
+ if (primaryId == null) {
+ respVO.getFailureList().put(importVO.getName(), "涓诲崟浣嶇紪鐮佷笉瀛樺湪锛�" + importVO.getPrimaryCode());
+ continue;
+ }
+ }
+
+ // 2.3 宸插瓨鍦紙鎸夌紪鐮佸垽鏂級
+ MdmUnitMeasureDO existByCode = unitMeasureMapper.selectByCode(importVO.getCode());
+ if (existByCode != null) {
+ if (!Boolean.TRUE.equals(isUpdateSupport)) {
+ respVO.getFailureList().put(importVO.getName(), "鍗曚綅缂栫爜宸插瓨鍦�");
+ continue;
+ }
+ // 鏀寔鏇存柊锛氫互缂栫爜涓哄噯鏇存柊
+ MdmUnitMeasureDO updateObj = BeanUtils.toBean(importVO, MdmUnitMeasureDO.class);
+ updateObj.setId(existByCode.getId());
+ updateObj.setPrimaryId(primaryId);
+ unitMeasureMapper.updateById(updateObj);
+ respVO.getUpdateList().add(importVO.getName());
+ } else {
+ // 2.4 鏍￠獙鍚嶇О鍞竴锛堟柊澧炲満鏅級
+ MdmUnitMeasureDO existByName = unitMeasureMapper.selectByName(importVO.getName());
+ if (existByName != null) {
+ respVO.getFailureList().put(importVO.getName(), "鍗曚綅鍚嶇О宸插瓨鍦�");
+ continue;
+ }
+ // 2.5 鏂板
+ MdmUnitMeasureDO newObj = BeanUtils.toBean(importVO, MdmUnitMeasureDO.class);
+ newObj.setPrimaryId(primaryId);
+ unitMeasureMapper.insert(newObj);
+ respVO.getCreateList().add(importVO.getName());
+ // 璁板綍鏈鏂板缓鐨勭紪鐮侊紝渚涘悓鏂囦欢鍚庣画琛屽紩鐢�
+ importedCodeIdMap.put(importVO.getCode(), newObj.getId());
+ }
+ }
+ return respVO;
+ }
+
+}
--
Gitblit v1.9.3