From a4c2061113e4789a77263050d3443e596258a21c Mon Sep 17 00:00:00 2001 From: YunaiV Date: Sat, 16 Sep 2023 14:17:25 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=A4=9A=E7=A7=9F=E6=88=B7?= =?UTF-8?q?=20Job=20=E7=9A=84=E5=AE=9E=E7=8E=B0=EF=BC=8C=E4=BF=9D=E6=8C=81?= =?UTF-8?q?=E5=92=8C=20boot=20=E7=89=88=E6=9C=AC=E5=B0=BD=E9=87=8F?= =?UTF-8?q?=E4=B8=80=E8=87=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/iocoder/yudao/module/pay/job/notify/PayNotifyJob.java | 2 +- .../iocoder/yudao/module/pay/job/order/PayOrderExpireJob.java | 2 +- .../cn/iocoder/yudao/module/pay/job/order/PayOrderSyncJob.java | 2 +- .../iocoder/yudao/module/pay/job/refund/PayRefundSyncJob.java | 2 +- .../java/cn/iocoder/yudao/module/system/job/demo/DemoJob.java | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/notify/PayNotifyJob.java b/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/notify/PayNotifyJob.java index 5a961ea57..b2c14a9bd 100644 --- a/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/notify/PayNotifyJob.java +++ b/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/notify/PayNotifyJob.java @@ -15,7 +15,6 @@ import javax.annotation.Resource; * @author 芋道源码 */ @Component -@TenantJob // 多租户 @Slf4j public class PayNotifyJob { @@ -23,6 +22,7 @@ public class PayNotifyJob { private PayNotifyService payNotifyService; @XxlJob("payNotifyJob") + @TenantJob // 多租户 public void execute() throws Exception { int notifyCount = payNotifyService.executeNotify(); log.info("[execute][执行支付通知 ({}) 个]", notifyCount); diff --git a/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/order/PayOrderExpireJob.java b/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/order/PayOrderExpireJob.java index 39fbc323d..93dfe4548 100644 --- a/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/order/PayOrderExpireJob.java +++ b/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/order/PayOrderExpireJob.java @@ -16,7 +16,6 @@ import javax.annotation.Resource; * @author 芋道源码 */ @Component -@TenantJob @Slf4j public class PayOrderExpireJob { @@ -24,6 +23,7 @@ public class PayOrderExpireJob { private PayOrderService orderService; @XxlJob("payOrderExpireJob") + @TenantJob // 多租户 public void execute(String param) { int count = orderService.expireOrder(); log.info("[execute][支付过期 ({}) 个]", count); diff --git a/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/order/PayOrderSyncJob.java b/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/order/PayOrderSyncJob.java index 7cff73fcd..15de61cdd 100644 --- a/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/order/PayOrderSyncJob.java +++ b/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/order/PayOrderSyncJob.java @@ -18,7 +18,6 @@ import java.time.LocalDateTime; * @author 芋道源码 */ @Component -@TenantJob @Slf4j public class PayOrderSyncJob { @@ -35,6 +34,7 @@ public class PayOrderSyncJob { private PayOrderService orderService; @XxlJob("payOrderSyncJob") + @TenantJob // 多租户 public void execute() { LocalDateTime minCreateTime = LocalDateTime.now().minus(CREATE_TIME_DURATION_BEFORE); int count = orderService.syncOrder(minCreateTime); diff --git a/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/refund/PayRefundSyncJob.java b/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/refund/PayRefundSyncJob.java index 38a113de1..25f239dc7 100644 --- a/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/refund/PayRefundSyncJob.java +++ b/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/job/refund/PayRefundSyncJob.java @@ -16,7 +16,6 @@ import javax.annotation.Resource; * @author 芋道源码 */ @Component -@TenantJob @Slf4j public class PayRefundSyncJob { @@ -24,6 +23,7 @@ public class PayRefundSyncJob { private PayRefundService refundService; @XxlJob("payRefundSyncJob") + @TenantJob // 多租户 public void execute() { int count = refundService.syncRefund(); log.info("[execute][同步退款订单 ({}) 个]", count); diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/job/demo/DemoJob.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/job/demo/DemoJob.java index 6fa4ad62d..2b04dfdc0 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/job/demo/DemoJob.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/job/demo/DemoJob.java @@ -5,10 +5,10 @@ import com.xxl.job.core.handler.annotation.XxlJob; import org.springframework.stereotype.Component; @Component -@TenantJob public class DemoJob { @XxlJob("demoJob") + @TenantJob public void execute() { System.out.println("美滋滋"); }