diff --git a/blade-service/logpm-factory-data/logpm-factory-data-zbom/src/main/java/com/logpm/factorydata/zbom/mapper/OrderPackageMapper.xml b/blade-service/logpm-factory-data/logpm-factory-data-zbom/src/main/java/com/logpm/factorydata/zbom/mapper/OrderPackageMapper.xml
index 5af4ea546..07669e4c4 100644
--- a/blade-service/logpm-factory-data/logpm-factory-data-zbom/src/main/java/com/logpm/factorydata/zbom/mapper/OrderPackageMapper.xml
+++ b/blade-service/logpm-factory-data/logpm-factory-data-zbom/src/main/java/com/logpm/factorydata/zbom/mapper/OrderPackageMapper.xml
@@ -64,7 +64,7 @@
         group by re.depart_code, t.platform_order_code
     </select>
     <select id="findByPackageCodes" resultType="com.logpm.factorydata.zbom.vo.OrderPackageDTO">
-        select t.package_code,t.sign_status,t.push_status from zb_order_package t
+        select t.package_code from zb_order_package t
         where exists(
         select 1 from (
         <foreach collection="packageCodeList" index="ind" item="item">
@@ -76,7 +76,7 @@
                 select #{item} pid
             </if>
         </foreach>
-        ) packageCodeIds where packageCodeIds.pid = t.package_code)
+        ) packageCodes where packageCodes.pid = t.package_code)
     </select>
 
 </mapper>
diff --git a/blade-service/logpm-factory-data/logpm-factory-data-zbom/src/main/java/com/logpm/factorydata/zbom/mq/ZbomFactoryOrderListener.java b/blade-service/logpm-factory-data/logpm-factory-data-zbom/src/main/java/com/logpm/factorydata/zbom/mq/ZbomFactoryOrderListener.java
index 819de6934..2ae6874a7 100644
--- a/blade-service/logpm-factory-data/logpm-factory-data-zbom/src/main/java/com/logpm/factorydata/zbom/mq/ZbomFactoryOrderListener.java
+++ b/blade-service/logpm-factory-data/logpm-factory-data-zbom/src/main/java/com/logpm/factorydata/zbom/mq/ZbomFactoryOrderListener.java
@@ -50,11 +50,14 @@ import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
+import java.util.Set;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
+import java.util.stream.Collectors;
 
 /**
  * 监听志邦订单数据
@@ -81,7 +84,7 @@ public class ZbomFactoryOrderListener {
 		key = FactoryDataConstants.Mq.RoutingKeys.ZBOM_FACTORY_ORDER
 	))
 	@Transactional(rollbackFor = Exception.class)
-	public void factoryOrder(String msg) {
+	public void factoryOrder(String msg, Set<String> packageCodeSet) {
 		if (StrUtil.isEmpty(msg)) {
 			log.error("消息内容为空");
 			return;
@@ -101,15 +104,34 @@ public class ZbomFactoryOrderListener {
 			log.error("入库单号已推送过了");
 			return;
 		}
+		// 查询当前这次推送的数据中的所有包件，校验其是否在数据库中已存在，存在则不保存
+		Set<String> packageCode = new HashSet<>();
+		List<OrderPackageDTO> details = zbReceiptDTO.getDetails();
+		if (CollUtil.isNotEmpty(details)) {
+			// 收集包件编码
+			List<String> collect = details.stream().map(OrderPackageDTO::getPackageCode).collect(Collectors.toList());
+			if (CollUtil.isNotEmpty(collect)) {
+				List<OrderPackageDTO> packageCodes = orderPackageService.findByPackageCodes(collect);
+				if (CollUtil.isNotEmpty(packageCodes)) {
+					// 将packageCodes中的数据存到packageCode中
+					packageCodes.forEach(item -> {
+						packageCode.add(item.getPackageCode());
+					});
+				}
+			}
+		}
 		ZbReceiptEntity zbReceiptEntity = new ZbReceiptEntity();
 		BeanUtil.copyProperties(zbReceiptDTO, zbReceiptEntity);
 		// 保存订单数据
 		receiptService.save(zbReceiptEntity);
-		List<OrderPackageDTO> details = zbReceiptDTO.getDetails();
 		if (CollUtil.isNotEmpty(details)) {
 			List<ZbOrderPackageEntity> packageEntities = new ArrayList<>();
 			List<ZbPackageInfoEntity> packageInfoEntities = new ArrayList<>();
 			for (OrderPackageDTO detail : details) {
+				if (packageCode.contains(detail.getPackageCode())) {
+					log.info(" 接收志邦数据：包条码 {} 已存在数据库中，不保存。", detail.getPackageCode());
+					continue;
+				}
 				ZbOrderPackageEntity packageEntity = new ZbOrderPackageEntity();
 				BeanUtil.copyProperties(detail, packageEntity);
 				packageEntity.setReceiptId(zbReceiptEntity.getId());
@@ -118,6 +140,9 @@ public class ZbomFactoryOrderListener {
 			// 保存包件数据
 			orderPackageService.saveBatch(packageEntities);
 			for (OrderPackageDTO detail : details) {
+				if (packageCode.contains(detail.getPackageCode())) {
+					continue;
+				}
 				Long detailId = null;
 				for (ZbOrderPackageEntity packageEntity : packageEntities) {
 					if (ObjectUtil.equal(packageEntity.getPackageCode(), detail.getPackageCode())) {
@@ -138,10 +163,10 @@ public class ZbomFactoryOrderListener {
 			packageInfoService.saveBatch(packageInfoEntities);
 		}
 		// 处理暂存单
-		buildAdvance(zbReceiptDTO);
+		buildAdvance(zbReceiptDTO, packageCode);
 	}
 
-	private void buildAdvance(ZBReceiptDTO zbReceiptDTO) {
+	private void buildAdvance(ZBReceiptDTO zbReceiptDTO, Set packageCode) {
 		// 新起线程构建暂存单发送mq
 		ThreadPoolUtil.getThreadPool().submit(() -> {
 			Long startWarehouseId = null;
@@ -161,6 +186,10 @@ public class ZbomFactoryOrderListener {
 			List<OrderPackageDTO> details = zbReceiptDTO.getDetails();
 			// 入库单号 + 订单自编号 + 发车单号 一个暂存单
 			for (OrderPackageDTO detail : details) {
+				if (packageCode.contains(detail.getPackageCode())) {
+					log.info(" 接收志邦数据：包条码 {} 已存在数据库中，不生成暂存单。", detail.getPackageCode());
+					continue;
+				}
 				String taskCode = zbReceiptDTO.getTaskCode();
 				String departCode = zbReceiptDTO.getDepartCode();
 				String platformOrderCode = detail.getPlatformOrderCode();
diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineAdvanceDetailMapper.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineAdvanceDetailMapper.java
index 029f43f2b..b4ed1808f 100644
--- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineAdvanceDetailMapper.java
+++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineAdvanceDetailMapper.java
@@ -12,6 +12,7 @@ import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
+import java.util.Set;
 
 @Mapper
 public interface TrunklineAdvanceDetailMapper extends BaseMapper<TrunklineAdvanceDetailEntity> {
@@ -47,4 +48,15 @@ public interface TrunklineAdvanceDetailMapper extends BaseMapper<TrunklineAdvanc
     List<String> findNoIncomingPackageCode(@Param("advanceId") Long advanceId);
 
     Integer findListByAdvanceIdAndPackageStatus(@Param("advanceId") Long advanceId, @Param("packageStatus") String packageStatus);
+
+    /**
+     * ���ݰ������뼯�ϲ������ݿ��д��ڵİ������롣
+     *
+     * @param orderPackageCodes ������������ļ��ϣ�����ΪSet<String>��
+     *                          ����һ������Ϊ�յļ��ϣ�����ָ����Ҫ��ѯ�Ķ����������롣
+     * @return ����һ��List<String>���͵ļ��ϣ����������붩������������ƥ��İ������롣
+     *         ���û���ҵ�ƥ��İ������룬�򷵻�һ���ռ��ϡ�
+     */
+    List<String> findPackageCodeByCodes(@Param("orderPackageCodes") Set<String> orderPackageCodes);
+
 }
diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineAdvanceDetailMapper.xml b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineAdvanceDetailMapper.xml
index 84a453172..c6f498d1d 100644
--- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineAdvanceDetailMapper.xml
+++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineAdvanceDetailMapper.xml
@@ -196,5 +196,20 @@
         and package_status = #{packageStatus}
         and is_deleted = 0
     </select>
+    <select id="findPackageCodeByCodes" resultType="java.lang.String">
+        select t.order_package_code from logpm_trunkline_advance_detail t
+        where exists(
+        select 1 from (
+        <foreach collection="orderPackageCodes" index="ind" item="item">
+            <if test="ind == 0">
+                select #{item} pid
+            </if>
+            <if test="ind != 0">
+                union all
+                select #{item} pid
+            </if>
+        </foreach>
+        ) packageCodes where packageCodes.pid = t.order_package_code)
+    </select>
 
 </mapper>
diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mq/AdvanceOrderListener.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mq/AdvanceOrderListener.java
index 7e43cf89f..3ae1af344 100644
--- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mq/AdvanceOrderListener.java
+++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mq/AdvanceOrderListener.java
@@ -24,7 +24,9 @@ import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.ArrayList;
+import java.util.HashSet;
 import java.util.List;
+import java.util.Set;
 
 /**
  * 监听工厂数据转暂存单
@@ -50,19 +52,49 @@ public class AdvanceOrderListener {
 	public void advanceOrder(String msg) {
 		// 新增暂存单
 		if (StrUtil.isNotBlank(msg)) {
+			log.info("收到工厂数据暂存单消息：{}", msg);
 			JSONObject entries = JSONUtil.parseObj(msg);
+			JSONArray details = entries.getJSONArray("details");
 			TrunklineAdvanceEntity advanceEntity = JSONUtil.toBean(entries, TrunklineAdvanceEntity.class);
+			Set<String> packageCodeSet = new HashSet<>();
+			if (CollUtil.isNotEmpty(details)) {
+				// 使用HashSet代替ArrayList以优化内存使用和检查重复值
+				Set<String> orderPackageCodes = new HashSet<>();
+				details.forEach(detail -> {
+					try {
+						// 更具描述性的变量命名
+						JSONObject jsonObject = JSONUtil.parseObj(detail);
+						TrunklineAdvanceDetailEntity entity = JSONUtil.toBean(jsonObject, TrunklineAdvanceDetailEntity.class);
+						// 检查转换后的实体不为null，且其orderPackageCode非null
+						if (!ObjectUtil.hasEmpty(entity, entity.getOrderPackageCode())) {
+							orderPackageCodes.add(entity.getOrderPackageCode());
+						}
+					} catch (Exception e) {
+						// 异常处理，可根据实际情况记录日志或进行其他处理
+						log.error("暂存单转换时发生异常: " + detail + "，异常：" + e.getMessage());
+					}
+				});
+				// 查询数据库，校验订单包件编码是否重复
+				if (CollUtil.isNotEmpty(orderPackageCodes)) {
+					List<String> codes = advanceDetailService.findPackageCodeByCodes(orderPackageCodes);
+					if (CollUtil.isNotEmpty(codes)) {
+						packageCodeSet.addAll(codes);
+					}
+				}
+			}
 			if (ObjectUtil.isNotNull(advanceEntity)) {
 				advanceService.save(advanceEntity);
 			}
-			JSONArray details = entries.getJSONArray("details");
-			if (CollUtil.isNotEmpty(details)) {
+			if (ObjectUtil.isNotEmpty(advanceEntity) && CollUtil.isNotEmpty(details)) {
 				List<TrunklineAdvanceDetailEntity> advanceDetailEntityList = new ArrayList<>();
 				List<TrunklineDetailProductEntity> detailProductEntityList = new ArrayList<>();
 				for (Object detailObj : details) {
 					JSONObject detail = JSONUtil.parseObj(detailObj);
 					TrunklineAdvanceDetailEntity advanceDetailEntity = JSONUtil.toBean(detail, TrunklineAdvanceDetailEntity.class);
 					if (ObjectUtil.isNotNull(advanceDetailEntity)) {
+						if (CollUtil.isNotEmpty(packageCodeSet) && packageCodeSet.contains(advanceDetailEntity.getOrderPackageCode())) {
+							continue;
+						}
 						advanceDetailEntity.setAdvanceId(advanceEntity.getId());
 						advanceDetailEntityList.add(advanceDetailEntity);
 						JSONArray items = detail.getJSONArray("items");
diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineAdvanceDetailService.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineAdvanceDetailService.java
index 6b05d8fca..b208f07ab 100644
--- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineAdvanceDetailService.java
+++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineAdvanceDetailService.java
@@ -13,48 +13,61 @@ import org.springblade.core.tool.api.R;
 
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
 
 public interface ITrunklineAdvanceDetailService extends BaseService<TrunklineAdvanceDetailEntity> {
 
-    void updatePackageStatusById(String packageStatus, Long advanceDetailId,Long warehouseId,String warehouseName);
+	void updatePackageStatusById(String packageStatus, Long advanceDetailId, Long warehouseId, String warehouseName);
 
-    TrunklineAdvanceDetailEntity findEntityByOrderPackageCodeAndWarehouseId(String orderPackageCode, Long warehouseId);
+	TrunklineAdvanceDetailEntity findEntityByOrderPackageCodeAndWarehouseId(String orderPackageCode, Long warehouseId);
 
-    List<TrunklineAdvanceDetailVO> findList(Long advanceId);
+	List<TrunklineAdvanceDetailVO> findList(Long advanceId);
 
-    List<AdvanceDetailGoodsVO> findGoodsListByAdvanceIds(List<Long> advanceIds);
+	List<AdvanceDetailGoodsVO> findGoodsListByAdvanceIds(List<Long> advanceIds);
 
 	AdvanceDetailStockNumVO findStockNumByAdvanceIds(List<Long> advanceIds);
 
 	List<BillladingPackageVO> findBillladingPackageByAdvanceIdsAnd(List<Long> advanceIds);
 
-    IPage<TrunklineAdvanceDetailVO> advanceDetailPageList(AdvanceDetailDTO advanceDetailDTO);
+	IPage<TrunklineAdvanceDetailVO> advanceDetailPageList(AdvanceDetailDTO advanceDetailDTO);
 
-    TrunklineAdvanceDetailEntity findEntityByOrderPackageCode(String orderPackageCode);
+	TrunklineAdvanceDetailEntity findEntityByOrderPackageCode(String orderPackageCode);
 
-    Integer getIncomingNum(Long advanceId);
+	Integer getIncomingNum(Long advanceId);
 
-    TrunklineAdvanceDetailEntity findEntityByOrderPackageCodeAndTrainNumberAndServiceNumAndOrderCode(String orderPackageCode, String trainNumber, String serviceNum, String orderCode);
+	TrunklineAdvanceDetailEntity findEntityByOrderPackageCodeAndTrainNumberAndServiceNumAndOrderCode(String orderPackageCode, String trainNumber, String serviceNum, String orderCode);
 
 	Integer getNumByAdvanceId(Long advanceId);
 
-    OrderPackgeCodeDataVO showAdvancePackgeCode(Map<String, Object> params) throws Exception;
+	OrderPackgeCodeDataVO showAdvancePackgeCode(Map<String, Object> params) throws Exception;
 
 	List<TrunklineAdvanceDetailEntity> findListByAdvanceId(Long advanceId);
 
 	List<String> findOrderPackageCodesByAdvanceId(Long advanceId);
 
-    void deleteByAdvanceId(Long advanceId);
+	void deleteByAdvanceId(Long advanceId);
 
-    R deleteAdvanceDetail(AdvanceDetailDTO advanceDetailDTO);
+	R deleteAdvanceDetail(AdvanceDetailDTO advanceDetailDTO);
 
-    Integer findTotalNumByOrderCode(String orderCode);
+	Integer findTotalNumByOrderCode(String orderCode);
 
 	void updateWaybillNoByAdvanceId(Long advanceId, String waybillNo, Long waybillId);
 
 	List<String> findIncomingWarehouseName(Long advanceId);
 
-    List<String> findNoIncomingPackageCode(Long advanceId);
+	List<String> findNoIncomingPackageCode(Long advanceId);
+
+	Integer findListByAdvanceIdAndPackageStatus(Long advanceId, String packageStatus);
+
+
+	/**
+	 * ���ݰ������뼯�ϲ����ݴ浥�д��ڵİ������롣
+	 *
+	 * @param orderPackageCodes ������������ļ��ϣ�����ΪSet<String>��
+	 *                          ������Ҫ��ѯ�Ķ���������Ψһ��ʶ�����ϡ�
+	 * @return ����һ��List<String>���͵��б�������������Ķ�������������ƥ������а������롣
+	 * ���û���ҵ�ƥ��İ������룬�򷵻ؿ��б���
+	 */
+	List<String> findPackageCodeByCodes(Set<String> orderPackageCodes);
 
-    Integer findListByAdvanceIdAndPackageStatus(Long advanceId, String packageStatus);
 }
diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineAdvanceDetailServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineAdvanceDetailServiceImpl.java
index f42bee842..c29ddb416 100644
--- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineAdvanceDetailServiceImpl.java
+++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineAdvanceDetailServiceImpl.java
@@ -35,6 +35,7 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
+import java.util.Set;
 
 @Slf4j
 @Service
@@ -250,4 +251,9 @@ public class TrunklineAdvanceDetailServiceImpl extends BaseServiceImpl<Trunkline
 	public Integer findListByAdvanceIdAndPackageStatus(Long advanceId, String packageStatus) {
 		return baseMapper.findListByAdvanceIdAndPackageStatus(advanceId,packageStatus);
 	}
+
+    @Override
+    public List<String> findPackageCodeByCodes(Set<String> orderPackageCodes) {
+		return baseMapper.findPackageCodeByCodes(orderPackageCodes);
+    }
 }