diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/comfac/service/impl/FactoryCommonServiceImpl.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/comfac/service/impl/FactoryCommonServiceImpl.java
index cb7a207a7..5471b98b6 100644
--- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/comfac/service/impl/FactoryCommonServiceImpl.java
+++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/comfac/service/impl/FactoryCommonServiceImpl.java
@@ -129,6 +129,7 @@ public class FactoryCommonServiceImpl implements IFactoryCommonService {
 	@Override
 	public void extracted(String status, String unitNo, String currentWarehouseId, String operationTime, Integer trayId) {
 		log.info("#############extracted: 当前处理的数据为 status={} unitNo={} currentWarehouseId={} operationTime={} trayId={}",status,unitNo,currentWarehouseId,operationTime,trayId);
+		String redisKey = "extracted:"+unitNo;
 		if ("4".equals(status) || "2".equals(status) || "1".equals(status)) {
 			//继续判断是否到达目的仓
 
@@ -152,8 +153,12 @@ public class FactoryCommonServiceImpl implements IFactoryCommonService {
 						if (OldSystemDataPushConfig.getWarehourseIdList().contains(currentWarehouseId)) {
 							try {
 								if ("1".equals(status) || "4".equals(status)) {
-									// 始发仓和目的仓入库
-									panFactoryDataService.handleDataToPlatform(unitNo, operationTime,Integer.parseInt(currentWarehouseId));
+									Boolean exists = bladeRedis.exists(redisKey);
+									if(Boolean.FALSE.equals(exists)){
+										bladeRedis.setEx(redisKey, "1", 60L);
+										// 始发仓和目的仓入库
+										panFactoryDataService.handleDataToPlatform(unitNo, operationTime,Integer.parseInt(currentWarehouseId));
+									}
 								} else {
 									log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>> 错误的状态");
 								}