From 93d3238254a44934c3fd7e1a1f9d5f2f369da42d Mon Sep 17 00:00:00 2001 From: liyongde <1419499670@qq.com> Date: Tue, 18 Feb 2025 10:13:30 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=AE=9A=E6=97=B6=E5=99=A8ip=E6=A0=A1?= =?UTF-8?q?=E9=AA=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../org/nl/system/service/quartz/config/JobRunner.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/lms/nladmin-system/src/main/java/org/nl/system/service/quartz/config/JobRunner.java b/lms/nladmin-system/src/main/java/org/nl/system/service/quartz/config/JobRunner.java index 1041e14d5..c18855cac 100644 --- a/lms/nladmin-system/src/main/java/org/nl/system/service/quartz/config/JobRunner.java +++ b/lms/nladmin-system/src/main/java/org/nl/system/service/quartz/config/JobRunner.java @@ -15,6 +15,8 @@ import org.springframework.boot.ApplicationRunner; import org.springframework.core.annotation.Order; import org.springframework.stereotype.Component; +import java.net.InetAddress; +import java.util.LinkedHashSet; import java.util.List; @Component @@ -39,7 +41,7 @@ public class JobRunner implements ApplicationRunner { log.info("--------------------注入定时任务---------------------"); List quartzJobs = quartzJobService.findByIsPauseIsFalse(); quartzJobs.forEach(job -> { - if (localIp.equals(job.getJob_ip())) { + if (judgmentIp(job.getJob_ip())) { log.info("定时任务:{}, 执行ip: {}, 定时任务开启", job.getJob_name(), localIp); System.out.println("定时任务: " + job.getJob_name() + ", 执行ip: " + localIp + ", 定时任务开启"); quartzManage.addJob(job); @@ -52,4 +54,9 @@ public class JobRunner implements ApplicationRunner { log.info("--------------------定时任务注入完成---------------------"); } + public static Boolean judgmentIp(String ip) { + return NetUtil.localAddressList(null).stream() + .anyMatch(inet -> ip.equals(inet.getHostAddress())); + } + }