From 251be431ad12399fe4ebce599c353d05dcec7888 Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期四, 29 十月 2026 12:28:34 +0800
Subject: [PATCH] feat(mes): 支持追溯二维码解析功能
---
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/pro/bagcode/MesProBagCodeMapper.java | 86 +++++++++++++++++++++++++++++++++++++++++++
1 files changed, 86 insertions(+), 0 deletions(-)
diff --git a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/pro/bagcode/MesProBagCodeMapper.java b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/pro/bagcode/MesProBagCodeMapper.java
index 6830e19..2a8f155 100644
--- a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/pro/bagcode/MesProBagCodeMapper.java
+++ b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/pro/bagcode/MesProBagCodeMapper.java
@@ -3,10 +3,13 @@
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
+import cn.iocoder.yudao.framework.mybatis.core.util.MyBatisUtils;
import cn.iocoder.yudao.module.mes.controller.admin.pro.bagcode.vo.MesProBagCodePageReqVO;
+import cn.iocoder.yudao.module.mes.controller.admin.pro.bagcode.vo.MesProBagCodeUnboundTonBagPageReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.bagcode.MesProBagCodeDO;
import cn.iocoder.yudao.module.mes.enums.pro.MesProBagCodeStatusEnum;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
@@ -106,6 +109,58 @@
.eq(MesProBagCodeDO::getBatchId, batchId)
.ne(MesProBagCodeDO::getStatus, MesProBagCodeStatusEnum.CANCELED.getStatus())
.orderByAsc(MesProBagCodeDO::getBagNo));
+ }
+
+ /**
+ * 缁熻鐢熸垚缁勪笅鍙嵃鍒风殑琚嬬爜鏁伴噺锛堜緵瀵煎嚭鍒嗘祦鍒ゆ柇锛岄伩鍏嶄负浜嗘嬁鏁伴噺鑰屽叏閲忓姞杞斤級
+ */
+ default Long selectPrintableCountByUuid(String uuid) {
+ return selectCount(new LambdaQueryWrapperX<MesProBagCodeDO>()
+ .eq(MesProBagCodeDO::getUuid, uuid)
+ .ne(MesProBagCodeDO::getStatus, MesProBagCodeStatusEnum.CANCELED.getStatus()));
+ }
+
+ /**
+ * 缁熻鎵规涓嬪彲鍗板埛鐨勮鐮佹暟閲忥紙渚涘鍑哄垎娴佸垽鏂級
+ */
+ default Long selectPrintableCountByBatchId(Long batchId) {
+ return selectCount(new LambdaQueryWrapperX<MesProBagCodeDO>()
+ .eq(MesProBagCodeDO::getBatchId, batchId)
+ .ne(MesProBagCodeDO::getStatus, MesProBagCodeStatusEnum.CANCELED.getStatus()));
+ }
+
+ /**
+ * 鍒嗛〉鏌ヨ鐢熸垚缁勪笅鍙嵃鍒风殑琚嬬爜锛堝悗鍙板鍑轰换鍔＄敤锛岄�愰〉鍙栦互鎺у埗鍐呭瓨锛�
+ * <p>
+ * 鎺掑簭涓庡叏閲忔煡璇繚鎸佷竴鑷达紙鎸夎搴忓彿鍗囧簭锛夛紝淇濊瘉 ZIP 鍐呯殑鏍囩椤哄簭涓嶅彉銆�
+ */
+ default List<MesProBagCodeDO> selectPrintablePageByUuid(String uuid, int pageNo, int pageSize) {
+ return selectPageByWrapper(new LambdaQueryWrapperX<MesProBagCodeDO>()
+ .eq(MesProBagCodeDO::getUuid, uuid)
+ .ne(MesProBagCodeDO::getStatus, MesProBagCodeStatusEnum.CANCELED.getStatus())
+ .orderByAsc(MesProBagCodeDO::getBagNo), pageNo, pageSize);
+ }
+
+ /**
+ * 鍒嗛〉鏌ヨ鎵规涓嬪彲鍗板埛鐨勮鐮侊紙鍚庡彴瀵煎嚭浠诲姟鐢級
+ */
+ default List<MesProBagCodeDO> selectPrintablePageByBatchId(Long batchId, int pageNo, int pageSize) {
+ return selectPageByWrapper(new LambdaQueryWrapperX<MesProBagCodeDO>()
+ .eq(MesProBagCodeDO::getBatchId, batchId)
+ .ne(MesProBagCodeDO::getStatus, MesProBagCodeStatusEnum.CANCELED.getStatus())
+ .orderByAsc(MesProBagCodeDO::getBagNo), pageNo, pageSize);
+ }
+
+ /**
+ * 鎸夋潯浠跺垎椤垫煡璇紝涓嶆墽琛� count 鏌ヨ锛堣皟鐢ㄦ柟閫氬父宸茬煡鎬绘暟锛�
+ */
+ private List<MesProBagCodeDO> selectPageByWrapper(
+ com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper<MesProBagCodeDO> wrapper,
+ int pageNo, int pageSize) {
+ com.baomidou.mybatisplus.extension.plugins.pagination.Page<MesProBagCodeDO> page =
+ new com.baomidou.mybatisplus.extension.plugins.pagination.Page<>(pageNo, pageSize);
+ page.setSearchCount(false);
+ return selectPage(page, wrapper).getRecords();
}
default Long selectCountByBatchId(Long batchId) {
@@ -208,11 +263,42 @@
.orderByAsc(MesProBagCodeDO::getId));
}
+ /**
+ * 鍒嗛〉鏌ヨ鍙粦瀹氭壒娆＄殑鍚ㄨ锛氭棤鎵樼洏銆佹湭缁戝畾鎵规銆佸搧绉嶈閲忓崟浣嶇被鍨嬩负鍚ㄣ��
+ * <p>
+ * 璁￠噺鍗曚綅绫诲瀷鍦� MDM 渚х淮鎶わ紝鍥犳閫氳繃 mdm_item + mdm_unit_measure 鍏宠仈杩囨护锛�
+ * 閬垮厤鎶婂叏閮ㄨ鐮佹媺鍒板唴瀛樺啀閫愪釜鏌ュ崟浣嶏紝鏁版嵁閲忓ぇ鏃朵笉鍙敤銆�
+ */
+ default PageResult<MesProBagCodeDO> selectUnboundTonBagPage(MesProBagCodeUnboundTonBagPageReqVO reqVO,
+ String unitType) {
+ IPage<MesProBagCodeDO> result = selectUnboundTonBagPage(MyBatisUtils.buildPage(reqVO), reqVO.getKeyword(),
+ unitType, List.of(MesProBagCodeStatusEnum.GENERATED.getStatus(),
+ MesProBagCodeStatusEnum.PRINTED.getStatus()));
+ return new PageResult<>(result.getRecords(), result.getTotal());
+ }
+
+ IPage<MesProBagCodeDO> selectUnboundTonBagPage(IPage<MesProBagCodeDO> page,
+ @Param("keyword") String keyword,
+ @Param("unitType") String unitType,
+ @Param("statuses") Collection<Integer> statuses);
+
/** 鎵规鍐呮湁鏁堣鐮佺殑鍝佺缂栧彿闆嗗悎锛堝拷鐣ュ巻鍙茬┖鍝佺琚嬬爜锛夛紝鐢ㄤ簬褰曞叆鎵规鏃剁殑鍝佺涓�鑷存�ф牎楠� */
@Select("SELECT DISTINCT item_id FROM mes_pro_bag_code " +
"WHERE deleted = 0 AND status <> 30 AND batch_id = #{batchId} AND item_id IS NOT NULL")
List<Long> selectDistinctItemIdsByBatchId(@Param("batchId") Long batchId);
+ /**
+ * 鐗╃悊鍒犻櫎鐢熸垚缁勪笅鐨勪竴鎵硅鐮侊紙浠呯敤浜庣敓鎴愬け璐�/鍙栨秷鍚庣殑鍗婃垚鍝佹竻鐞嗭級
+ * <p>
+ * 鍗婃垚鍝佷粠鏈澶栧睍绀猴紝閫昏緫鍒犻櫎鍙細鐣欎笅鍑犲崄涓囨潯鍨冨溇骞跺崰鐢ㄧ储寮曠┖闂达紝鍥犳杩欓噷鐩存帴鐗╃悊鍒犻櫎銆�
+ *
+ * @param uuid 鐢熸垚缁� UUID
+ * @param limit 鍗曟鏈�澶氬垹闄よ鏁�
+ * @return 瀹為檯鍒犻櫎琛屾暟
+ */
+ @org.apache.ibatis.annotations.Delete("DELETE FROM mes_pro_bag_code WHERE uuid = #{uuid} LIMIT #{limit}")
+ int deletePhysicallyByUuidChunk(@Param("uuid") String uuid, @Param("limit") int limit);
+
default List<MesProBagCodeDO> selectListByIdsForUpdate(Collection<Long> ids) {
return selectList(new LambdaQueryWrapperX<MesProBagCodeDO>()
.in(MesProBagCodeDO::getId, ids)
--
Gitblit v1.9.3