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 e9126a67b..54d37bf01 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
@@ -125,7 +125,7 @@ public class NodeDataPushListener {
 				Map<String, FactoryNodePushEntity> pushEntityMap = new HashMap<>();
 				if (CollUtil.isNotEmpty(pushEntities)) {
 					pushEntityMap = pushEntities.stream().filter(pushEntity -> {
-						return pushEntity.getNode().equals(FactoryNodeEnums.FINAL_NET_ARRIVE_CAR.getCode());
+						return StrUtil.equals(pushEntity.getNode(),FactoryNodeEnums.END_WAREHOUSE_UNLOADING.getCode().toString());
 					}).collect(Collectors.toMap(FactoryNodePushEntity::getOrderCode, v -> v));
 				}
 				JSONObject mainJson = JSONUtil.parseObj(main);
@@ -191,7 +191,7 @@ public class NodeDataPushListener {
 				Map<String, FactoryNodePushEntity> pushEntityMap = new HashMap<>();
 				if (CollUtil.isNotEmpty(pushEntities)) {
 					pushEntityMap = pushEntities.stream().filter(pushEntity -> {
-						return pushEntity.getNode().equals(FactoryNodeEnums.END_WAREHOUSE_UNLOADING.getCode());
+						return StrUtil.equals(pushEntity.getNode(),FactoryNodeEnums.END_WAREHOUSE_UNLOADING.getCode().toString());
 					}).collect(Collectors.toMap(FactoryNodePushEntity::getPackageCode, v -> v));
 				}
 				for (PushData pushData : content) {
diff --git a/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/service/impl/DeliveryNoteServiceImpl.java b/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/service/impl/DeliveryNoteServiceImpl.java
index 2ea4f88f7..9abbaf48c 100644
--- a/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/service/impl/DeliveryNoteServiceImpl.java
+++ b/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/service/impl/DeliveryNoteServiceImpl.java
@@ -392,6 +392,7 @@ public class DeliveryNoteServiceImpl extends BaseServiceImpl<DeliveryNoteMapper,
 			advanceEntity.setTotalNum(CollUtil.isNotEmpty(value) ? value.size() : 0);
 			advanceEntity.setPackName("");
 			advanceEntity.setPackCode("");
+			advanceEntity.setCreateUserName("数据同步");
 			advanceEntity.setWarehouseId(warehouseId);
 			advanceEntity.setWarehouseName(warehouseName);