From 9daeb6eac6e46710055e625bbbd56331b8890e21 Mon Sep 17 00:00:00 2001
From: xiaoyi <908147524@qq.com>
Date: 星期三, 04 十一月 2026 10:10:20 +0800
Subject: [PATCH] revert(energy): 撤销 energy 模块移植（与新高原有 em 模块重复）
---
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/route/MesProRouteProductServiceImpl.java | 46 ++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 46 insertions(+), 0 deletions(-)
diff --git a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/route/MesProRouteProductServiceImpl.java b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/route/MesProRouteProductServiceImpl.java
index c19f6b7..731f644 100644
--- a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/route/MesProRouteProductServiceImpl.java
+++ b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/route/MesProRouteProductServiceImpl.java
@@ -2,6 +2,10 @@
import cn.hutool.core.util.ObjUtil;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
+import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import cn.iocoder.yudao.module.mes.dal.mysql.pro.route.MesProRouteMapper;
+import cn.iocoder.yudao.module.mes.dal.dataobject.pro.route.MesProRouteDO;
import cn.iocoder.yudao.module.mes.controller.admin.pro.route.vo.product.MesProRouteProductSaveReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.route.MesProRouteProductDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemDO;
@@ -10,6 +14,7 @@
import cn.iocoder.yudao.module.mes.enums.md.MesMdItemTypeEnum;
import cn.iocoder.yudao.module.mes.service.md.item.MesMdItemService;
import cn.iocoder.yudao.module.mes.service.md.item.MesMdItemTypeService;
+import cn.iocoder.yudao.module.mes.service.wm.warehouse.MesWmWarehouseAreaService;
import jakarta.annotation.Resource;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
@@ -32,6 +37,8 @@
@Resource
private MesProRouteProductMapper routeProductMapper;
+ @Resource
+ private MesProRouteMapper routeMapper;
@Resource
@Lazy
@@ -43,6 +50,29 @@
private MesMdItemService itemService;
@Resource
private MesMdItemTypeService itemTypeService;
+ @Resource
+ private MesWmWarehouseAreaService warehouseAreaService;
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void setTemplateReference(Long id) {
+ MesProRouteProductDO initial = routeProductMapper.selectById(id);
+ validateRouteProductExists(initial);
+ MesProRouteDO route = routeMapper.selectOne(new LambdaQueryWrapperX<MesProRouteDO>()
+ .eq(MesProRouteDO::getId, initial.getRouteId()).last("FOR UPDATE"));
+ if (route == null) throw exception(PRO_ROUTE_NOT_EXISTS);
+ MesProRouteProductDO current = routeProductMapper.selectById(id);
+ validateRouteProductExists(current);
+ if (!java.util.Objects.equals(current.getRouteId(), route.getId())) throw exception(PRO_ROUTE_PRODUCT_NOT_EXISTS);
+ if (!isFinishedProduct(current.getItemId())) throw exception(PRO_ROUTE_TEMPLATE_REFERENCE_NOT_FINISHED);
+ routeProductMapper.update(null, new LambdaUpdateWrapper<MesProRouteProductDO>()
+ .eq(MesProRouteProductDO::getRouteId, route.getId())
+ .eq(MesProRouteProductDO::getTemplateReference, true)
+ .set(MesProRouteProductDO::getTemplateReference, false));
+ if (routeProductMapper.updateById(new MesProRouteProductDO().setId(id).setTemplateReference(true)) != 1) {
+ throw exception(PRO_ROUTE_PRODUCT_NOT_EXISTS);
+ }
+ }
@Override
public Long createRouteProduct(MesProRouteProductSaveReqVO createReqVO) {
@@ -52,6 +82,8 @@
validateProductItem(createReqVO.getItemId());
// 1.2 鏍￠獙浜у搧鍞竴鎬э紙涓�涓骇鍝佸彧鑳藉叧鑱斾竴鏉″伐鑹鸿矾绾匡級
validateItemUnique(null, createReqVO.getItemId());
+ warehouseAreaService.validateWarehouseAreaExists(createReqVO.getWarehouseId(),
+ createReqVO.getLocationId(), createReqVO.getAreaId());
// 2. 鎻掑叆
MesProRouteProductDO routeProduct = BeanUtils.toBean(createReqVO, MesProRouteProductDO.class);
@@ -69,6 +101,8 @@
validateProductItem(updateReqVO.getItemId());
// 1.3 鏍￠獙浜у搧鍞竴鎬�
validateItemUnique(updateReqVO.getId(), updateReqVO.getItemId());
+ warehouseAreaService.validateWarehouseAreaExists(updateReqVO.getWarehouseId(),
+ updateReqVO.getLocationId(), updateReqVO.getAreaId());
// 2. 鏇存柊
MesProRouteProductDO updateObj = BeanUtils.toBean(updateReqVO, MesProRouteProductDO.class);
@@ -102,6 +136,18 @@
}
}
+ private boolean isFinishedProduct(Long itemId) {
+ MesMdItemDO item = itemService.validateItemExists(itemId);
+ MesMdItemTypeDO type = itemTypeService.getItemType(item.getItemTypeId());
+ java.util.Set<Long> seen = new java.util.HashSet<>();
+ while (type != null && seen.add(type.getId())) {
+ if ("FG".equals(type.getCode())) return true;
+ if (type.getParentId() == null || MesMdItemTypeDO.PARENT_ID_ROOT.equals(type.getParentId())) break;
+ type = itemTypeService.getItemType(type.getParentId());
+ }
+ return false;
+ }
+
private void validateProductItem(Long itemId) {
MesMdItemDO item = itemService.validateItemExistsAndEnable(itemId);
MesMdItemTypeDO itemType = itemTypeService.getItemType(item.getItemTypeId());
--
Gitblit v1.9.3