From f4b6c4c119a6ea7a61b3057e47bb20da6e7177ad Mon Sep 17 00:00:00 2001
From: tuqin <tuqin@tuqin.cn>
Date: 星期二, 29 九月 2026 16:02:01 +0800
Subject: [PATCH] fix(mes): 移除变基残留的 setCapacity 调用,修复编译报错

---
 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/pallet/MesProPalletServiceImpl.java |   57 +++++++++++++++++++++++++++++++++++++++++++++++++--------
 1 files changed, 49 insertions(+), 8 deletions(-)

diff --git a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/pallet/MesProPalletServiceImpl.java b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/pallet/MesProPalletServiceImpl.java
index 33794e4..fd5557a 100644
--- a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/pallet/MesProPalletServiceImpl.java
+++ b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/pallet/MesProPalletServiceImpl.java
@@ -7,11 +7,14 @@
 import cn.iocoder.yudao.module.mes.controller.admin.pro.pallet.vo.MesProPalletBindBatchReqVO;
 import cn.iocoder.yudao.module.mes.controller.admin.pro.pallet.vo.MesProPalletPageReqVO;
 import cn.iocoder.yudao.module.mes.controller.admin.pro.pallet.vo.MesProPalletPreGenerateReqVO;
+import cn.iocoder.yudao.module.mes.dal.dataobject.pro.bagcode.MesProBagCodeDO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.pro.batch.MesProBatchDO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.pro.pallet.MesProPalletDO;
 import cn.iocoder.yudao.module.mes.dal.mysql.pro.bagcode.MesProBagCodeMapper;
 import cn.iocoder.yudao.module.mes.dal.mysql.pro.batch.MesProBatchMapper;
 import cn.iocoder.yudao.module.mes.dal.mysql.pro.pallet.MesProPalletMapper;
+import cn.iocoder.yudao.module.mes.dal.redis.MesCodeRedisDAO;
+import cn.iocoder.yudao.module.mes.enums.pro.MesProBagCodeStatusEnum;
 import cn.iocoder.yudao.module.mes.enums.pro.MesProBatchStatusEnum;
 import cn.iocoder.yudao.module.mes.enums.pro.MesProPalletStatusEnum;
 import jakarta.annotation.Resource;
@@ -22,7 +25,9 @@
 
 import java.util.ArrayList;
 import java.util.Collection;
+import java.util.LinkedHashSet;
 import java.util.List;
+import java.util.Set;
 
 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
 import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;
@@ -43,6 +48,9 @@
     private MesProBagCodeMapper bagCodeMapper;
     @Resource
     private MesProBatchMapper batchMapper;
+
+    @Resource
+    private MesCodeRedisDAO codeRedisDao;
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -67,11 +75,10 @@
         for (int i = 0; i < createReqVO.getCount(); i++) {
             int palletNo = startNo + i;
             pallets.add(new MesProPalletDO()
-                    .setCode(batch.getCode() + "-P" + StrUtil.padPre(String.valueOf(palletNo), 2, '0'))
+                    .setCode(codeRedisDao.generate())
                     .setBatchId(batch.getId())
                     .setBatchCode(batch.getCode())
                     .setPalletNo(palletNo)
-                    .setCapacity(createReqVO.getCapacity())
                     .setBagCount(0)
                     .setAutoGenerated(false)
                     .setStatus(MesProPalletStatusEnum.IN_USE.getStatus())
@@ -94,8 +101,7 @@
         List<MesProPalletDO> list = new ArrayList<>(reqVO.getCount());
         for (int i = 0; i < reqVO.getCount(); i++) {
             list.add(new MesProPalletDO()
-                    .setTempCode("PL-" + StrUtil.padPre(String.valueOf(startSeq + i), 8, '0'))
-                    .setCapacity(reqVO.getCapacity())
+                    .setTempCode(codeRedisDao.generate())
                     .setBagCount(0)
                     .setAutoGenerated(false)
                     .setStatus(MesProPalletStatusEnum.IN_USE.getStatus())
@@ -136,20 +142,50 @@
             }
             pallets.add(pallet);
         }
-        // 3. 鍒嗛厤姝e紡鎵樼洏鐮侊細鎵规鍙� + -P + 2 浣嶆墭鐩樺簭鍙凤紙鍚�昏緫鍒犻櫎璁板綍鍙備笌搴忓彿锛屼繚璇佷笉鍥為��銆佺爜鍊煎敮涓�锛�
+        // 3. 绾ц仈鍑嗗锛氭墭鐩樹笅鏈粦鎵规鐨勮鐮侀殢鎵樼洏涓�璧峰綍鍏ユ壒娆★紝鍝佺椤讳笌鎵规宸叉湁琚嬬爜涓�鑷�
+        List<MesProBagCodeDO> bags = bagCodeMapper.selectUnboundListByPalletIds(ids);
+        List<Long> bindBagIds = new ArrayList<>();
+        Set<Long> bagItemIds = new LinkedHashSet<>();
+        for (MesProBagCodeDO bag : bags) {
+            if (!MesProBagCodeStatusEnum.GENERATED.getStatus().equals(bag.getStatus())
+                    && !MesProBagCodeStatusEnum.PRINTED.getStatus().equals(bag.getStatus())) {
+                continue;
+            }
+            bindBagIds.add(bag.getId());
+            if (bag.getItemId() != null) {
+                bagItemIds.add(bag.getItemId());
+            }
+        }
+        if (!bindBagIds.isEmpty()) {
+            bagItemIds.addAll(bagCodeMapper.selectDistinctItemIdsByBatchId(batch.getId()));
+            if (bagItemIds.size() > 1) {
+                throw exception(PRO_BAG_CODE_BIND_BATCH_ITEM_MISMATCH);
+            }
+        }
+        // 4. 鍒嗛厤姝e紡鎵樼洏鐮侊細鎵规鍙� + -P + 2 浣嶆墭鐩樺簭鍙凤紙鍚�昏緫鍒犻櫎璁板綍鍙備笌搴忓彿锛屼繚璇佷笉鍥為��銆佺爜鍊煎敮涓�锛�
         int startNo = palletMapper.selectMaxPalletNo(batch.getId()) + 1;
         for (int i = 0; i < pallets.size(); i++) {
             int palletNo = startNo + i;
             palletMapper.updateById(new MesProPalletDO()
                     .setId(pallets.get(i).getId())
-                    .setCode(batch.getCode() + "-P" + StrUtil.padPre(String.valueOf(palletNo), 2, '0'))
+                    .setCode(codeRedisDao.generate())
                     .setBatchId(batch.getId())
                     .setBatchCode(batch.getCode())
                     .setPalletNo(palletNo));
+            // 鎵樼洏涓嬭鐮佺殑鍐椾綑鎵樼洏鐮佺敱涓存椂鐮佹洿鏂颁负姝e紡鐮�
+            bagCodeMapper.updatePalletCodeByPalletId(pallets.get(i).getId(),
+                    batch.getCode() + "-P" + StrUtil.padPre(String.valueOf(palletNo), 2, '0'));
         }
-        // 4. 鍥炲啓鎵规鎵樼洏鐮佹暟閲�
+        // 5. 鎵樼洏涓嬭鐮佹壒閲忕粦瀹氭湰鎵规
+        if (!bindBagIds.isEmpty() && bagCodeMapper.bindBatchByIds(bindBagIds, batch.getId(), batch.getCode(),
+                List.of(MesProBagCodeStatusEnum.GENERATED.getStatus(),
+                        MesProBagCodeStatusEnum.PRINTED.getStatus())) != bindBagIds.size()) {
+            throw exception(PRO_BAG_CODE_STATUS_NOT_GENERATED);
+        }
+        // 6. 鍥炲啓鎵规鎵樼洏鐮佹暟閲忎笌鏈夋晥琚嬬爜鏁伴噺
         batchMapper.updateById(new MesProBatchDO().setId(batch.getId())
-                .setPalletQuantity((batch.getPalletQuantity() == null ? 0 : batch.getPalletQuantity()) + pallets.size()));
+                .setPalletQuantity((batch.getPalletQuantity() == null ? 0 : batch.getPalletQuantity()) + pallets.size())
+                .setBagQuantity(bagCodeMapper.selectEffectiveCountByBatchId(batch.getId())));
         return pallets.size();
     }
 
@@ -206,6 +242,11 @@
     }
 
     @Override
+    public List<MesProPalletDO> getUnboundPalletList() {
+        return palletMapper.selectUnboundList();
+    }
+
+    @Override
     public List<MesProPalletDO> getPalletListByIds(Collection<Long> ids) {
         if (CollUtil.isEmpty(ids)) {
             return List.of();

--
Gitblit v1.9.3