From bea4a3fe74735e351a9ba53ce51c37ca54c86783 Mon Sep 17 00:00:00 2001 From: wuzongyong <13203449218@163.com> Date: Wed, 14 Jan 2026 15:21:42 +0800 Subject: [PATCH] =?UTF-8?q?feat(job):=20=E6=B7=BB=E5=8A=A0=E6=B5=8B?= =?UTF-8?q?=E8=AF=95=E7=9A=84xxljob?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/zt/plat/module/base/job/TestJob.java | 60 +++++++++++++++++++ 1 file changed, 60 insertions(+) create mode 100644 zt-module-base/zt-module-base-server/src/main/java/com/zt/plat/module/base/job/TestJob.java diff --git a/zt-module-base/zt-module-base-server/src/main/java/com/zt/plat/module/base/job/TestJob.java b/zt-module-base/zt-module-base-server/src/main/java/com/zt/plat/module/base/job/TestJob.java new file mode 100644 index 00000000..ef389213 --- /dev/null +++ b/zt-module-base/zt-module-base-server/src/main/java/com/zt/plat/module/base/job/TestJob.java @@ -0,0 +1,60 @@ +package com.zt.plat.module.base.job; + +import com.xxl.job.core.handler.annotation.XxlJob; +import com.zt.plat.framework.tenant.core.job.TenantJob; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; + +/** + * 测试定时任务 + * + * @author base + */ +@Component +@Slf4j +public class TestJob { + + private static final DateTimeFormatter FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + + /** + * 简单测试任务 + */ + @XxlJob("testSimpleJob") + @TenantJob + public void testSimpleJob() { + String currentTime = LocalDateTime.now().format(FORMATTER); + log.info("[testSimpleJob][开始执行] 当前时间: {}", currentTime); + + try { + // 模拟业务处理 + Thread.sleep(2000); + log.info("[testSimpleJob][执行成功] 任务已完成"); + } catch (Exception e) { + log.error("[testSimpleJob][执行失败] 错误信息: {}", e.getMessage(), e); + throw new RuntimeException(e); + } + } + + /** + * 带参数的测试任务 + */ + @XxlJob("testParamJob") + @TenantJob + public void testParamJob() { + String currentTime = LocalDateTime.now().format(FORMATTER); + log.info("[testParamJob][开始执行] 当前时间: {}", currentTime); + + try { + // 模拟带参数的业务处理 + log.info("[testParamJob][处理中] 正在处理业务逻辑..."); + Thread.sleep(1000); + log.info("[testParamJob][执行成功] 任务已完成"); + } catch (Exception e) { + log.error("[testParamJob][执行失败] 错误信息: {}", e.getMessage(), e); + throw new RuntimeException(e); + } + } +}