feat(mes): 新增业务码支持并优化追溯查询功能

云

22 小时以前 704265308b1227dbada5a36b2027b588c062ded2

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/pallet/MesProPalletServiceImpl.java

@@ -51,6 +51,8 @@

    @Resource
    private MesCodeRedisDAO codeRedisDao;
    @Resource
    private cn.iocoder.yudao.module.mes.service.trace.integrity.MesTraceIntegrityService integrityService;

    @Override
    @Transactional(rollbackFor = Exception.class)
@@ -76,6 +78,8 @@
            int palletNo = startNo + i;
            pallets.add(new MesProPalletDO()
                    .setCode(codeRedisDao.generate())
                    .setBusinessCode(codeRedisDao.generate())
                    .setItemId(batch.getItemId())
                    .setBatchId(batch.getId())
                    .setBatchCode(batch.getCode())
                    .setPalletNo(palletNo)
@@ -96,12 +100,12 @@
    @Override
    @Transactional(rollbackFor = Exception.class)
    public List<MesProPalletDO> preGeneratePallet(MesProPalletPreGenerateReqVO reqVO) {
        // 1. 生成临时托盘码（全局 8 位序号，格式 PL-00000001）
        int startSeq = palletMapper.selectMaxTempCodeSeq() + 1;
        // 1. 通过统一编码生成器分配临时码及业务码，不再解析历史临时码序号。
        List<MesProPalletDO> list = new ArrayList<>(reqVO.getCount());
        for (int i = 0; i < reqVO.getCount(); i++) {
            list.add(new MesProPalletDO()
                    .setTempCode(codeRedisDao.generate())
                    .setBusinessCode(codeRedisDao.generate())
                    .setBagCount(0)
                    .setAutoGenerated(false)
                    .setStatus(MesProPalletStatusEnum.IN_USE.getStatus())
@@ -142,6 +146,14 @@
            }
            pallets.add(pallet);
        }
        Long itemId = batch.getItemId();
        for (Long existing : bagCodeMapper.selectDistinctItemIdsByBatchId(batch.getId()))
            itemId = MesProPalletItemResolver.merge(itemId, existing);
        for (MesProPalletDO pallet : pallets) {
            Long palletItem = MesProPalletItemResolver.resolve(pallet, bagCodeMapper.selectListByPalletId(pallet.getId()));
            if (palletItem == null) throw new cn.iocoder.yudao.framework.common.exception.ServiceException(400, "托盘缺少品种，请先绑定同品种袋码");
            itemId = MesProPalletItemResolver.merge(itemId, palletItem);
        }
        // 3. 级联准备：托盘下未绑批次的袋码随托盘一起录入批次，品种须与批次已有袋码一致
        List<MesProBagCodeDO> bags = bagCodeMapper.selectUnboundListByPalletIds(ids);
        List<Long> bindBagIds = new ArrayList<>();
@@ -158,6 +170,7 @@
        }
        if (!bindBagIds.isEmpty()) {
            bagItemIds.addAll(bagCodeMapper.selectDistinctItemIdsByBatchId(batch.getId()));
            if (itemId != null) bagItemIds.add(itemId);
            if (bagItemIds.size() > 1) {
                throw exception(PRO_BAG_CODE_BIND_BATCH_ITEM_MISMATCH);
            }
@@ -166,15 +179,17 @@
        int startNo = palletMapper.selectMaxPalletNo(batch.getId()) + 1;
        for (int i = 0; i < pallets.size(); i++) {
            int palletNo = startNo + i;
            String palletCode = codeRedisDao.generate();
            palletMapper.updateById(new MesProPalletDO()
                    .setId(pallets.get(i).getId())
                    .setCode(codeRedisDao.generate())
                    .setItemId(itemId)
                    .setCode(palletCode)
                    .setBatchId(batch.getId())
                    .setBatchCode(batch.getCode())
                    .setPalletNo(palletNo));
            // 托盘下袋码的冗余托盘码由临时码更新为正式码
            bagCodeMapper.updatePalletCodeByPalletId(pallets.get(i).getId(),
                    batch.getCode() + "-P" + StrUtil.padPre(String.valueOf(palletNo), 2, '0'));
                    palletCode);
        }
        // 5. 托盘下袋码批量绑定本批次
        if (!bindBagIds.isEmpty() && bagCodeMapper.bindBatchByIds(bindBagIds, batch.getId(), batch.getCode(),
@@ -182,10 +197,11 @@
                        MesProBagCodeStatusEnum.PRINTED.getStatus())) != bindBagIds.size()) {
            throw exception(PRO_BAG_CODE_STATUS_NOT_GENERATED);
        }
        // 6. 回写批次托盘码数量与有效袋码数量
        batchMapper.updateById(new MesProBatchDO().setId(batch.getId())
        // 6. 回写批次品种、托盘码数量与有效袋码数量
        batchMapper.updateById(new MesProBatchDO().setId(batch.getId()).setItemId(itemId)
                .setPalletQuantity((batch.getPalletQuantity() == null ? 0 : batch.getPalletQuantity()) + pallets.size())
                .setBagQuantity(bagCodeMapper.selectEffectiveCountByBatchId(batch.getId())));
        integrityService.recordBatchIntegrity(batch.getId());
        return pallets.size();
    }

@@ -214,6 +230,33 @@
    }

    @Override
    public MesProPalletDO getPalletByScanCode(String code) {
        return palletMapper.selectByScanCode(code);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public int generateBusinessCodes(java.util.List<Long> ids) {
        if (ids == null || ids.isEmpty() || ids.size() > 200 || ids.stream().anyMatch(java.util.Objects::isNull))
            throw new cn.iocoder.yudao.framework.common.exception.ServiceException(400, "请选择 1 至 200 条记录");
        java.util.List<MesProPalletDO> records = new java.util.ArrayList<>();
        for (Long id : ids.stream().distinct().sorted().toList()) {
            MesProPalletDO record = palletMapper.selectByIdForUpdate(id);
            if (record == null) throw exception(PRO_PALLET_NOT_EXISTS);
            if (MesProPalletStatusEnum.CANCELED.getStatus().equals(record.getStatus()))
                throw new cn.iocoder.yudao.framework.common.exception.ServiceException(400, "已作废记录不可补生成业务码");
            records.add(record);
        }
        int count = 0;
        for (MesProPalletDO record : records) {
            if (StrUtil.isNotBlank(record.getBusinessCode())) continue;
            palletMapper.updateById(new MesProPalletDO().setId(record.getId()).setBusinessCode(codeRedisDao.generate()));
            count++;
        }
        return count;
    }

    @Override
    public MesProPalletDO getPalletByCode(String code) {
        MesProPalletDO pallet = palletMapper.selectByCode(code);
        if (pallet == null) {