From 965a9bda2b5423390f6385350dc4dbe89ff5f13d Mon Sep 17 00:00:00 2001 From: "DESKTOP-5DIJMF9\\admin" <2388969634@qq.com> Date: Thu, 13 Mar 2025 18:43:44 +0800 Subject: [PATCH 1/3] =?UTF-8?q?opt=EF=BC=9A=E8=B0=83=E5=BA=A6=E6=93=8D?= =?UTF-8?q?=E4=BD=9C=E5=88=A4=E6=96=AD=E5=BD=93=E5=89=8DIP=E6=98=AF?= =?UTF-8?q?=E5=90=A6=E6=98=AF=E8=B0=83=E5=BA=A6Ip?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/quartz/utils/QuartzManage.java | 49 +++++++++++++++++-- 1 file changed, 46 insertions(+), 3 deletions(-) diff --git a/lms/nladmin-system/src/main/java/org/nl/system/service/quartz/utils/QuartzManage.java b/lms/nladmin-system/src/main/java/org/nl/system/service/quartz/utils/QuartzManage.java index 7249dd404..0dd8b368b 100644 --- a/lms/nladmin-system/src/main/java/org/nl/system/service/quartz/utils/QuartzManage.java +++ b/lms/nladmin-system/src/main/java/org/nl/system/service/quartz/utils/QuartzManage.java @@ -1,5 +1,6 @@ package org.nl.system.service.quartz.utils; +import cn.hutool.core.net.NetUtil; import lombok.extern.slf4j.Slf4j; import org.nl.modules.common.exception.BadRequestException; import org.nl.system.service.quartz.dao.SysQuartzJob; @@ -26,6 +27,14 @@ public class QuartzManage { private Scheduler scheduler; public void addJob(SysQuartzJob quartzJob) { + + + //本机IP + String localIp = NetUtil.getLocalhostStr(); + System.out.println("本机ip："+localIp); + if (!judgmentIp(quartzJob.getJob_ip())) { + throw new BadRequestException("本机ip与"+localIp+"调度ip"+quartzJob.getJob_ip()+"不同"); + } try { // 构建job信息 JobDetail jobDetail = JobBuilder.newJob(ExecutionJob.class). @@ -62,8 +71,16 @@ public class QuartzManage { * @param quartzJob / */ public void updateJobCron(SysQuartzJob quartzJob) { + + //本机IP + String localIp = NetUtil.getLocalhostStr(); + System.out.println("本机ip："+localIp); + TriggerKey triggerKey = TriggerKey.triggerKey(JOB_NAME + quartzJob.getJob_id()); + + if (!judgmentIp(quartzJob.getJob_ip())) { + throw new BadRequestException("本机ip与"+localIp+"调度ip"+quartzJob.getJob_ip()+"不同"); + } try { - TriggerKey triggerKey = TriggerKey.triggerKey(JOB_NAME + quartzJob.getJob_id()); CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey); // 如果不存在则创建一个定时任务 if (trigger == null) { @@ -93,8 +110,16 @@ public class QuartzManage { * @param quartzJob / */ public void resumeJob(SysQuartzJob quartzJob) { + + //本机IP + String localIp = NetUtil.getLocalhostStr(); + System.out.println("本机ip："+localIp); + TriggerKey triggerKey = TriggerKey.triggerKey(JOB_NAME + quartzJob.getJob_id()); + + if (!judgmentIp(quartzJob.getJob_ip())) { + throw new BadRequestException("本机ip与"+localIp+"调度ip"+quartzJob.getJob_ip()+"不同"); + } try { - TriggerKey triggerKey = TriggerKey.triggerKey(JOB_NAME + quartzJob.getJob_id()); CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey); // 如果不存在则创建一个定时任务 if (trigger == null) { @@ -129,9 +154,21 @@ public class QuartzManage { * @param quartzJob / */ public void runJobNow(SysQuartzJob quartzJob) { + + //本机IP + String localIp = NetUtil.getLocalhostStr(); + System.out.println("本机ip："+localIp); + TriggerKey triggerKey = TriggerKey.triggerKey(JOB_NAME + quartzJob.getJob_id()); + + if (!judgmentIp(quartzJob.getJob_ip())) { + throw new BadRequestException("本机ip与"+localIp+"调度ip"+quartzJob.getJob_ip()+"不同"); + } + try { - TriggerKey triggerKey = TriggerKey.triggerKey(JOB_NAME + quartzJob.getJob_id()); CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey); + log.info("定时任务:{}, 执行ip: {}, 定时任务开启", quartzJob.getJob_name(), localIp); + System.out.println("定时任务: " + quartzJob.getJob_name() + ", 执行ip: " + localIp + ", 定时任务开启"); + // 如果不存在则创建一个定时任务 if (trigger == null) { addJob(quartzJob); @@ -140,6 +177,7 @@ public class QuartzManage { dataMap.put(SysQuartzJob.JOB_KEY, quartzJob); JobKey jobKey = JobKey.jobKey(JOB_NAME + quartzJob.getJob_id()); scheduler.triggerJob(jobKey, dataMap); + } catch (Exception e) { log.error("定时任务执行失败", e); throw new BadRequestException("定时任务执行失败"); @@ -161,4 +199,9 @@ public class QuartzManage { throw new BadRequestException("删除定时任务失败"); } } + + public static Boolean judgmentIp(String ip) { + return NetUtil.localAddressList(null).stream() + .anyMatch(inet -> ip.equals(inet.getHostAddress())); + } } From ee6bec05eb09ac4555782e393975873af62f67f6 Mon Sep 17 00:00:00 2001 From: liuxy Date: Fri, 14 Mar 2025 10:08:05 +0800 Subject: [PATCH 2/3] =?UTF-8?q?rev:=E5=A2=9E=E5=8A=A0=E5=88=9B=E5=BB=BA?= =?UTF-8?q?=E6=97=B6=E9=97=B4=EF=BC=8C=E5=AD=97=E6=AE=B5=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/org/nl/common/domain/query/BaseQuery.java | 8 ++++---- .../src/main/java/org/nl/common/enums/QueryTEnum.java | 3 +++ .../org/nl/system/service/tools/dao/ToolLocalStorage.java | 3 ++- .../main/java/org/nl/wms/sch/manage/AutoSaveIvtExcel.java | 3 ++- .../java/org/nl/wms/sch/manage/AutoSaveIvtExcelTwo.java | 3 ++- .../main/java/org/nl/wms/sch/manage/AutoSendIvtExcel.java | 3 ++- 6 files changed, 15 insertions(+), 8 deletions(-) diff --git a/lms/nladmin-system/src/main/java/org/nl/common/domain/query/BaseQuery.java b/lms/nladmin-system/src/main/java/org/nl/common/domain/query/BaseQuery.java index 42cb8cad3..1c9fdeaec 100644 --- a/lms/nladmin-system/src/main/java/org/nl/common/domain/query/BaseQuery.java +++ b/lms/nladmin-system/src/main/java/org/nl/common/domain/query/BaseQuery.java @@ -32,8 +32,8 @@ public class BaseQuery { /** * 创建时间范围查询 */ - private Date start_time; - private Date end_time; + private String begin_time; + private String end_time; /** @@ -44,8 +44,8 @@ public class BaseQuery { * 通过buid构建 */ public Map doP = MapOf.of("blurry", QParam.builder().k(new String[]{"name"}).type(QueryTEnum.LK).build() - , "startTime", QParam.builder().k(new String[]{"create_time"}).type(QueryTEnum.LT).build() - , "endTime", QParam.builder().k(new String[]{"create_time"}).type(QueryTEnum.LE).build() + , "begin_time", QParam.builder().k(new String[]{"create_time"}).type(QueryTEnum.GT).build() + , "end_time", QParam.builder().k(new String[]{"create_time"}).type(QueryTEnum.LE).build() , "sort", QParam.builder().k(new String[]{"sort"}).type(QueryTEnum.BY).build() ); diff --git a/lms/nladmin-system/src/main/java/org/nl/common/enums/QueryTEnum.java b/lms/nladmin-system/src/main/java/org/nl/common/enums/QueryTEnum.java index 2275bb4f5..ef3680444 100644 --- a/lms/nladmin-system/src/main/java/org/nl/common/enums/QueryTEnum.java +++ b/lms/nladmin-system/src/main/java/org/nl/common/enums/QueryTEnum.java @@ -30,6 +30,9 @@ public enum QueryTEnum { LE((q, k, v) -> { q.le(k[0], v); }), + GT((q, k, v) -> { + q.gt(k[0], v); + }), BY((q, k, v) -> { q.orderByDesc(k[0], v); }), diff --git a/lms/nladmin-system/src/main/java/org/nl/system/service/tools/dao/ToolLocalStorage.java b/lms/nladmin-system/src/main/java/org/nl/system/service/tools/dao/ToolLocalStorage.java index 9498bf10b..d01afa4d1 100644 --- a/lms/nladmin-system/src/main/java/org/nl/system/service/tools/dao/ToolLocalStorage.java +++ b/lms/nladmin-system/src/main/java/org/nl/system/service/tools/dao/ToolLocalStorage.java @@ -80,13 +80,14 @@ public class ToolLocalStorage implements Serializable { */ private String update_time; - public ToolLocalStorage(String realName, String name, String suffix, String path, String type, String size) { + public ToolLocalStorage(String realName, String name, String suffix, String path, String type, String size, String create_time) { this.real_name = realName; this.name = name; this.suffix = suffix; this.path = path; this.type = type; this.size = size; + this.create_time = create_time; } diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AutoSaveIvtExcel.java b/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AutoSaveIvtExcel.java index 45cbf29f0..5b85cf98d 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AutoSaveIvtExcel.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AutoSaveIvtExcel.java @@ -115,7 +115,8 @@ public class AutoSaveIvtExcel { "xls", path, type, - ""); + "", + DateUtil.now()); iToolLocalStorageService.save(localStorage); workbook.write(fileOut); diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AutoSaveIvtExcelTwo.java b/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AutoSaveIvtExcelTwo.java index 57a29635a..f4ef18752 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AutoSaveIvtExcelTwo.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AutoSaveIvtExcelTwo.java @@ -110,7 +110,8 @@ public class AutoSaveIvtExcelTwo { "xls", path, type, - ""); + "", + DateUtil.now()); iToolLocalStorageService.save(localStorage); workbook.write(fileOut); diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AutoSendIvtExcel.java b/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AutoSendIvtExcel.java index dfdfa29eb..b07d1a5ce 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AutoSendIvtExcel.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AutoSendIvtExcel.java @@ -131,7 +131,8 @@ public class AutoSendIvtExcel { "xls", path, type, - ""); + "", + DateUtil.now()); iToolLocalStorageService.save(localStorage); } workbook.write(fileOut); From 65ce55dc6751ecb8ad04aa699d498dc39570a746 Mon Sep 17 00:00:00 2001 From: liuxy Date: Fri, 14 Mar 2025 10:10:52 +0800 Subject: [PATCH 3/3] =?UTF-8?q?rev=EF=BC=9A=E5=89=8D=E7=AB=AF=E5=AD=97?= =?UTF-8?q?=E6=AE=B5=E6=98=BE=E7=A4=BA=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- lms/nladmin-ui/src/views/tools/storage/index.vue | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lms/nladmin-ui/src/views/tools/storage/index.vue b/lms/nladmin-ui/src/views/tools/storage/index.vue index e22b61ddf..ac3fb2455 100644 --- a/lms/nladmin-ui/src/views/tools/storage/index.vue +++ b/lms/nladmin-ui/src/views/tools/storage/index.vue @@ -94,8 +94,8 @@ - - + +