diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionReservationClient.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionReservationClient.java
index c675f46d2..df57878f0 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionReservationClient.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionReservationClient.java
@@ -20,12 +20,16 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.logpm.distribution.dto.DistributionCancelReservationPackageDTO;
 import com.logpm.distribution.entity.DistributionReservationEntity;
+import com.logpm.distribution.service.IDistributionNodeWorkService;
 import com.logpm.distribution.service.IDistributionReservationService;
 import com.logpm.distribution.vo.DistributionRetentionScanVo;
 import lombok.AllArgsConstructor;
+import org.springblade.common.model.NodeFanoutMsg;
+import org.springblade.common.model.ReservationVO;
 import org.springblade.core.mp.support.BladePage;
 import org.springblade.core.mp.support.Condition;
 import org.springblade.core.mp.support.Query;
+import org.springblade.core.secure.BladeUser;
 import org.springblade.core.tool.api.R;
 import org.springblade.core.tool.utils.Func;
 import org.springframework.transaction.annotation.Transactional;
@@ -49,6 +53,8 @@ public class DistributionReservationClient implements IDistributionReservationCl
 
     private final IDistributionReservationService reservationService;
 
+	private final IDistributionNodeWorkService distributionNodeWorkService;
+
     @Override
     @GetMapping(TOP)
     public BladePage<DistributionReservationEntity> reservationTop(Integer current, Integer size) {
@@ -117,5 +123,10 @@ public class DistributionReservationClient implements IDistributionReservationCl
 		return false;
 	}
 
+	@Override
+	public void planRetention(NodeFanoutMsg<ReservationVO> nodeFanoutMsg, BladeUser user) {
+		distributionNodeWorkService.planRetention(nodeFanoutMsg,user);
+	}
+
 
 }