From 2b49afb4b8fa15a3c679f1d2496e1f44a0e659d8 Mon Sep 17 00:00:00 2001 From: PigBaoBei <2739175034@qq.com> Date: Fri, 20 Dec 2024 12:39:32 +0800 Subject: [PATCH] =?UTF-8?q?=E5=9B=9E=E5=BA=93=E5=B9=BF=E6=92=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../feign/DistributionReservationClient.java | 11 +++++++++++ 1 file changed, 11 insertions(+) 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 reservationTop(Integer current, Integer size) { @@ -117,5 +123,10 @@ public class DistributionReservationClient implements IDistributionReservationCl return false; } + @Override + public void planRetention(NodeFanoutMsg nodeFanoutMsg, BladeUser user) { + distributionNodeWorkService.planRetention(nodeFanoutMsg,user); + } + }