From 6ded2ee6a9d9097d45f8f79a7e6429cf55ed7cc3 Mon Sep 17 00:00:00 2001
From: k94314517 <8417338+k94314517@user.noreply.gitee.com>
Date: 星期五, 07 三月 2025 16:59:30 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 server/system_service/src/main/java/com/doumee/service/timer/QuartzJobService.java |   11 +++++++++++
 1 files changed, 11 insertions(+), 0 deletions(-)

diff --git a/server/system_service/src/main/java/com/doumee/service/timer/QuartzJobService.java b/server/system_service/src/main/java/com/doumee/service/timer/QuartzJobService.java
index c765b7f..b2e0c19 100644
--- a/server/system_service/src/main/java/com/doumee/service/timer/QuartzJobService.java
+++ b/server/system_service/src/main/java/com/doumee/service/timer/QuartzJobService.java
@@ -41,6 +41,11 @@
      * 鏂板浠诲姟
      */
     public int insert(QuartzJob quartzJob) {
+        if(quartzJobMapper.selectCount(new QueryWrapper<QuartzJob>().lambda()
+                .eq(QuartzJob::getModule,quartzJob.getModule())
+                .eq(QuartzJob::getBeanName,quartzJob.getBeanName())) >0){
+            throw  new BusinessException(ResponseStatus.DATA_EXISTS);
+        }
         int flag = quartzJobMapper.insert(quartzJob) ;
         if (flag > 0){
             quartzManage.createJob(quartzJob) ;
@@ -52,6 +57,12 @@
      * 鏇存柊浠诲姟
      */
     public int update(QuartzJob quartzJob) {
+        if(quartzJobMapper.selectCount(new QueryWrapper<QuartzJob>().lambda()
+                .eq(QuartzJob::getModule,quartzJob.getModule())
+                .ne(QuartzJob::getId,quartzJob.getId())
+                .eq(QuartzJob::getBeanName,quartzJob.getBeanName())) >0){
+            throw  new BusinessException(ResponseStatus.DATA_EXISTS);
+        }
         int flag = quartzJobMapper.updateById(quartzJob);
         if (flag > 0){
             quartzManage.updateJob(quartzJob);

--
Gitblit v1.9.3