From b92ca63c89b74404c3684f18c734d83531a9dd3f Mon Sep 17 00:00:00 2001
From: liukangdong <898885815@qq.com>
Date: 星期四, 06 三月 2025 16:01:45 +0800
Subject: [PATCH] Merge branch 'master' of http://139.186.142.91:10010/r/productDev/dmvisit
---
server/system_service/src/main/java/com/doumee/service/timer/QuartzJobService.java | 19 +++++++++++++------
1 files changed, 13 insertions(+), 6 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 bfe0442..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
@@ -1,24 +1,20 @@
package com.doumee.service.timer;
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
-import com.doumee.core.model.PageData;
-import com.doumee.core.model.PageWrap;
+import com.doumee.service.business.third.model.PageData;
+import com.doumee.service.business.third.model.PageWrap;
import com.doumee.core.utils.Utils;
import com.doumee.dao.timer.entity.JobState;
import com.doumee.dao.timer.entity.QuartzJob;
import com.doumee.dao.timer.mapper.QuartzJobMapper;
import com.doumee.dao.timer.scheduler.QuartzManage;
-import org.quartz.CronTrigger;
import org.springframework.stereotype.Service;
-import javax.annotation.PostConstruct;
import javax.annotation.Resource;
-import java.util.List;
import java.util.Objects;
/**
@@ -45,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) ;
@@ -56,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