diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionSignforController.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionSignforController.java
index b3622a502..83ba58abb 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionSignforController.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionSignforController.java
@@ -30,6 +30,7 @@ import com.logpm.distribution.entity.DistributionSignPrintEntity;
 import com.logpm.distribution.entity.DistributionSignforEntity;
 import com.logpm.distribution.excel.DistributionSignforExcel;
 import com.logpm.distribution.excel.DistributionSignforOwnExcel;
+import com.logpm.distribution.service.IDistributionAsyncService;
 import com.logpm.distribution.service.IDistributionReservationService;
 import com.logpm.distribution.service.IDistributionSignforService;
 import com.logpm.distribution.service.impl.DistributionAddvalueServiceImpl;
@@ -82,6 +83,8 @@ public class DistributionSignforController extends BladeController {
 
 	private final IBasicdataWarehouseClient warehouseClient;
 
+	private final IDistributionAsyncService distributionAsyncService;
+
 	/**
 	 * 签收管理 详情
 	 */
@@ -268,9 +271,18 @@ public class DistributionSignforController extends BladeController {
 	@ApiOperation(value = "新增", notes = "传入distributionSignfor")
 	public R oneclick(@Valid @RequestBody DistributionSignforDTO distributionSignfor) {
 		distributionSignfor.setIsClerk(true);
+		BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
+
 		R r	= distributionSignforService.oneclick(distributionSignfor);
 		List<String> packageCodes = (List<String>)r.getData();
 		try{
+			Map<String,Object> data = (Map<String, Object>) r.getData();
+			if (Func.isNotEmpty(data)){
+				List<Long> packageIds = (List<Long>) data.get("packageIds");
+				Long signId = (Long) data.get("signId");
+				distributionAsyncService.handlPakcage(packageIds, myCurrentWarehouse.getId());
+				distributionAsyncService.sendReviewFactory(signId,myCurrentWarehouse.getName() ,myCurrentWarehouse.getId());
+			}
 			String orderPackageCodes = null;
 			for (String packageCode : packageCodes) {
 				if(StringUtils.isBlank(orderPackageCodes)){
@@ -279,7 +291,6 @@ public class DistributionSignforController extends BladeController {
 					orderPackageCodes = orderPackageCodes + "," +packageCode;
 				}
 			}
-			BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
 			updownTypeClient.downPackageOrDelTray(orderPackageCodes,myCurrentWarehouse.getId());
 		}catch (Exception e){
 			log.error("##############oneclick: 更新包件下架状态失败 packageCodes={}",packageCodes);
diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java
index e535a0b4a..6fc8880f2 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java
@@ -2768,6 +2768,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 			log.error("#############deliveryId参数错误:{}", distributionSignfor.getDeliveryId());
 			return R.fail("服务器正忙~~");
 		}
+		Map<String,Object> map = new HashMap<>();
+
 		DistributionDeliverySelfEntity distributionDeliverySelfEntity = null;
 		if (distributionDeliveryListEntity.getKind().equals("1")) {
 			//自主
@@ -3139,11 +3141,13 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 				distributionStockArticleService.maintenanceOrderInfo(orderCode,myCurrentWarehouse.getId());
 			}
 
-
 			if (Func.isNotEmpty(packageIds)) {
-				distributionAsyncService.handlPakcage(packageIds, myCurrentWarehouse.getId());
+				map.put("packageIds",packageIds);
+				map.put("signId",distributionSignforEntity.getId());
+				map.put("warehouse",myCurrentWarehouse);
+//				distributionAsyncService.handlPakcage(packageIds, myCurrentWarehouse.getId());
 				//批量推送
-				distributionAsyncService.sendReviewFactory(distributionSignforEntity.getId(),myCurrentWarehouse.getName() ,myCurrentWarehouse.getId());
+//				distributionAsyncService.sendReviewFactory(distributionSignforEntity.getId(),myCurrentWarehouse.getName() ,myCurrentWarehouse.getId());
 			}
 		}
 
@@ -3179,9 +3183,9 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 		boolean update = this.update(set);
 		//维护配送信息
 		distributionDeliveryListService.maintenanceDeliveryInfo(distributionSignforEntity.getDeliveryId());
-		return R.status(true);
-	}	@Override
-
+		return R.data(map);
+	}
+	@Override
 	@Transactional
 	public R oneclickPDA(DistributionSignforDTO distributionSignfor) {