diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java b/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java new file mode 100644 index 0000000..366f789 --- /dev/null +++ b/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java @@ -0,0 +1,61 @@ +package com.ruoyi.web.task; + +import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.quartz.domain.SysJob; +import com.ruoyi.quartz.service.ISysJobService; +import org.quartz.SchedulerException; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.net.URI; +import java.net.http.HttpClient; +import java.net.http.HttpRequest; +import java.net.http.HttpResponse; +import java.util.concurrent.CompletableFuture; + +/** + * 定时任务调度测试 + * + * @author ruoyi + */ +@Component("ryTask") +public class RyTask { + @Autowired + private ISysJobService jobService; + + /** + * 抢票 + * + * @param pid + */ + public void rob(Long pid, Long jobId) throws SchedulerException { + System.out.println(pid + "," + jobId); + + for (int i = 0; i < 100; i++) { + System.out.println("开始"); + HttpClient client = HttpClient.newHttpClient(); + HttpRequest request = HttpRequest.newBuilder() + .uri(URI.create("http://example.com")) + .GET() + .build(); + // 发起异步请求，但不等待结果 + CompletableFuture> future2 = client.sendAsync(request, HttpResponse.BodyHandlers.ofString()); + future2.thenAccept(response -> { + // 处理响应（例如，记录日志） + System.out.println("Response received: " + response.statusCode()); + }).exceptionally(ex -> { + // 处理异常 + ex.printStackTrace(); + return null; + }); + System.out.println("异步任务完成"); + } + + + //执行完成停止任务 + SysJob job = new SysJob(); + job.setJobId(jobId); + job.setStatus("1"); + jobService.changeStatus(job); + } +} diff --git a/ruoyi-common/src/main/java/com/ruoyi/common/constant/Constants.java b/ruoyi-common/src/main/java/com/ruoyi/common/constant/Constants.java index 0c384c6..7950f20 100644 --- a/ruoyi-common/src/main/java/com/ruoyi/common/constant/Constants.java +++ b/ruoyi-common/src/main/java/com/ruoyi/common/constant/Constants.java @@ -163,7 +163,7 @@ public class Constants /** * 定时任务白名单配置（仅允许访问的包名，如其他需要可以自行添加） */ - public static final String[] JOB_WHITELIST_STR = { "com.ruoyi.quartz.task" }; + public static final String[] JOB_WHITELIST_STR = { "com.ruoyi.quartz.task", "com.ruoyi.web.task" }; /** * 定时任务违规的字符 diff --git a/ruoyi-quartz/pom.xml b/ruoyi-quartz/pom.xml index 0421087..a57aaa5 100644 --- a/ruoyi-quartz/pom.xml +++ b/ruoyi-quartz/pom.xml @@ -34,7 +34,6 @@ com.ruoyi ruoyi-common - \ No newline at end of file diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java deleted file mode 100644 index 853243b..0000000 --- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java +++ /dev/null @@ -1,28 +0,0 @@ -package com.ruoyi.quartz.task; - -import org.springframework.stereotype.Component; -import com.ruoyi.common.utils.StringUtils; - -/** - * 定时任务调度测试 - * - * @author ruoyi - */ -@Component("ryTask") -public class RyTask -{ - public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) - { - System.out.println(StringUtils.format("执行多参方法： 字符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i)); - } - - public void ryParams(String params) - { - System.out.println("执行有参方法：" + params); - } - - public void ryNoParams() - { - System.out.println("执行无参方法"); - } -} diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/PerformServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/PerformServiceImpl.java index f49910e..776d70b 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/PerformServiceImpl.java +++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/PerformServiceImpl.java @@ -1,11 +1,16 @@ package com.ruoyi.system.service.impl; +import java.text.SimpleDateFormat; +import java.util.Calendar; import java.util.Date; import java.util.List; +import java.util.TimeZone; +import com.ruoyi.common.exception.job.TaskException; import com.ruoyi.common.utils.DateUtils; import com.ruoyi.quartz.domain.SysJob; import com.ruoyi.quartz.service.ISysJobService; +import org.quartz.SchedulerException; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.ruoyi.system.mapper.PerformMapper; @@ -74,16 +79,45 @@ public class PerformServiceImpl implements IPerformService { //未开始 perform.setStatus("1"); + int result = performMapper.insertPerform(perform); + initJob(perform.getId(), perform.getName(), perform.getStartTime(), userName); + return result; + } + + /** + * 任务 + */ + private void initJob(Long pid, String name, Date date, String userName) throws SchedulerException, TaskException { + Calendar calendar = Calendar.getInstance(); + calendar.setTime(date); + calendar.add(Calendar.HOUR_OF_DAY, -1); + // 获取年、月、日、时、分、秒 + int year = calendar.get(Calendar.YEAR); + int month = calendar.get(Calendar.MONTH) + 1; // 月份从0开始，所以加1 + int day = calendar.get(Calendar.DAY_OF_MONTH); + int hour = calendar.get(Calendar.HOUR_OF_DAY); // 24小时制 + int minute = calendar.get(Calendar.MINUTE); + int second = calendar.get(Calendar.SECOND); + String cron = String.format("%d %d %d %d %d ? %d", second, minute, hour, day, month, year); + + // 定义日期格式 + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + + // 格式化当前日期和时间 + String formattedDate = sdf.format(date); + SysJob job = new SysJob(); - job.setJobName(perform.getName() + " " + perform.getStartTime()); - job.setCronExpression("* * * * * ?"); - job.setInvokeTarget("ryTask.ryParams('ry')"); + job.setJobName(name + " " + formattedDate); + job.setCronExpression(cron); + job.setInvokeTarget("ryTask.rob(" + pid + "L)"); job.setJobGroup("DEFAULT"); - job.setMisfirePolicy("2"); + job.setMisfirePolicy("3"); job.setStatus("0"); job.setCreateBy(userName); jobService.insertJob(job); - return performMapper.insertPerform(perform); + + job.setInvokeTarget("ryTask.rob(" + pid + "L, " + job.getJobId() + "L)"); + jobService.updateJob(job); } /**