diff --git a/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/enums/FactoryNodeEnums.java b/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/enums/FactoryNodeEnums.java
index 8567c7f34..cecd2b86f 100644
--- a/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/enums/FactoryNodeEnums.java
+++ b/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/enums/FactoryNodeEnums.java
@@ -21,7 +21,7 @@ public enum FactoryNodeEnums {
 	/**
 	 * 包件入库
 	 */
-	END_WAREHOUSE_UNLOADING(105010,"包件入库", 1)
+	END_WAREHOUSE_UNLOADING(105010,"包件入库", 1),
 	;
 
 	private Integer code;
diff --git a/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/enums/NodeMappingEnums.java b/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/enums/NodeMappingEnums.java
index 94ee47af4..2390623a1 100644
--- a/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/enums/NodeMappingEnums.java
+++ b/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/enums/NodeMappingEnums.java
@@ -21,6 +21,7 @@ public enum NodeMappingEnums {
 	 * 包件入库
 	 */
 	END_WAREHOUSE_UNLOADING(FactoryNodeEnums.END_WAREHOUSE_UNLOADING, WorkNodeEnums.END_WAREHOUSE_UNLOADING, 1),
+	UNLOAD_INCOMING_WAREHOUSE(FactoryNodeEnums.END_WAREHOUSE_UNLOADING, WorkNodeEnums.UNLOAD_INCOMING_WAREHOUSE, 1),
 	;
 
 	/**
diff --git a/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/enums/NodeNeedEnums.java b/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/enums/NodeNeedEnums.java
index 624a144b4..9d8459e6f 100644
--- a/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/enums/NodeNeedEnums.java
+++ b/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/enums/NodeNeedEnums.java
@@ -21,6 +21,7 @@ public enum NodeNeedEnums implements Serializable {
 	 * 包件入库
 	 */
 	END_WAREHOUSE_UNLOADING(105040, "末端仓卸车确认"),
+	UNLOAD_INCOMING_WAREHOUSE(105010, "末端仓卸车确认"),
 	;
 
 	private Integer code;
diff --git a/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/mq/NodeDataPushListener.java b/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/mq/NodeDataPushListener.java
index bc5559fbb..c6c3434e5 100644
--- a/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/mq/NodeDataPushListener.java
+++ b/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/mq/NodeDataPushListener.java
@@ -93,6 +93,10 @@ public class NodeDataPushListener {
 		// 3 拿到所有必推节点的code
 		List<Integer> mustPushCode = FactoryNodeEnums.getMustPushCode();
 		if (CollUtil.isNotEmpty(content)) {
+			// 卸车扫描节点 判断是否是末端仓卸车，末端仓卸车推送的数据推送
+			if (NodeNeedEnums.UNLOAD_INCOMING_WAREHOUSE.getCode().equals(workNodeEnums.getCode())) {
+				content = content.stream().filter(item -> ObjectUtil.equal(item.getWarehouseName(), item.getDestinationWarehouse())).collect(Collectors.toList());
+			}
 			// 查询出本次操作的所有订单
 			Set<String> orderCodes = content.stream().map(PushData::getOrderCode).collect(Collectors.toSet());
 			if (CollUtil.isEmpty(orderCodes)) {