> deleteSchedulers(@RequestBody SchedulersOperationDto dto) {
+ schedulersService.deleteSchedulers(dto);
+ return Mono.just(Result.success(ResultCodeEnum.DELETE_SUCCESS));
}
}
diff --git a/service/src/main/java/cn/bunny/services/mapper/SchedulersMapper.java b/service/src/main/java/cn/bunny/services/mapper/SchedulersMapper.java
index bd405d0..664b5e7 100644
--- a/service/src/main/java/cn/bunny/services/mapper/SchedulersMapper.java
+++ b/service/src/main/java/cn/bunny/services/mapper/SchedulersMapper.java
@@ -1,25 +1,23 @@
package cn.bunny.services.mapper;
import cn.bunny.dao.dto.schedulers.SchedulersDto;
-import cn.bunny.dao.entity.schedulers.ViewSchedulers;
+import cn.bunny.dao.entity.schedulers.Schedulers;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
-import java.util.List;
-
/**
*
* Schedulers视图 Mapper 接口
*
*
* @author Bunny
- * @since 2024-10-14 20:59:25
+ * @since 2024-10-15 16:35:10
*/
@Mapper
-public interface SchedulersMapper extends BaseMapper {
+public interface SchedulersMapper extends BaseMapper {
/**
* * 分页查询Schedulers视图内容
@@ -28,12 +26,5 @@ public interface SchedulersMapper extends BaseMapper {
* @param dto Schedulers视图查询表单
* @return Schedulers视图分页结果
*/
- IPage selectListByPage(@Param("page") Page pageParams, @Param("dto") SchedulersDto dto);
-
- /**
- * 物理删除Schedulers视图
- *
- * @param ids 删除 id 列表
- */
- void deleteBatchIdsWithPhysics(List ids);
+ IPage selectListByPage(@Param("page") Page pageParams, @Param("dto") SchedulersDto dto);
}
diff --git a/service/src/main/java/cn/bunny/services/service/SchedulersService.java b/service/src/main/java/cn/bunny/services/service/SchedulersService.java
index 057b037..37d366e 100644
--- a/service/src/main/java/cn/bunny/services/service/SchedulersService.java
+++ b/service/src/main/java/cn/bunny/services/service/SchedulersService.java
@@ -3,32 +3,29 @@ package cn.bunny.services.service;
import cn.bunny.dao.dto.schedulers.SchedulersAddDto;
import cn.bunny.dao.dto.schedulers.SchedulersDto;
import cn.bunny.dao.dto.schedulers.SchedulersOperationDto;
-import cn.bunny.dao.dto.schedulers.SchedulersUpdateDto;
-import cn.bunny.dao.entity.schedulers.ViewSchedulers;
+import cn.bunny.dao.entity.schedulers.Schedulers;
import cn.bunny.dao.pojo.result.PageResult;
import cn.bunny.dao.vo.schedulers.SchedulersVo;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import jakarta.validation.Valid;
-import java.util.List;
-
/**
*
* Schedulers视图 服务类
*
*
* @author Bunny
- * @since 2024-10-14 20:59:25
+ * @since 2024-10-15 16:35:10
*/
-public interface SchedulersService extends IService {
+public interface SchedulersService extends IService {
/**
* * 获取Schedulers视图列表
*
* @return Schedulers视图返回列表
*/
- PageResult getSchedulersList(Page pageParams, SchedulersDto dto);
+ PageResult getSchedulersList(Page pageParams, SchedulersDto dto);
/**
* * 添加Schedulers视图
@@ -37,20 +34,6 @@ public interface SchedulersService extends IService {
*/
void addSchedulers(@Valid SchedulersAddDto dto);
- /**
- * * 更新Schedulers视图
- *
- * @param dto 更新表单
- */
- void updateSchedulers(@Valid SchedulersUpdateDto dto);
-
- /**
- * * 删除|批量删除Schedulers视图类型
- *
- * @param ids 删除id列表
- */
- void deleteSchedulers(List ids);
-
/**
* * 暂停Schedulers任务
*
@@ -70,5 +53,5 @@ public interface SchedulersService extends IService {
*
* @param dto Schedulers公共操作表单
*/
- void removeScheduler(SchedulersOperationDto dto);
+ void deleteSchedulers(SchedulersOperationDto dto);
}
diff --git a/service/src/main/java/cn/bunny/services/service/impl/SchedulersServiceImpl.java b/service/src/main/java/cn/bunny/services/service/impl/SchedulersServiceImpl.java
index c025eab..af017b2 100644
--- a/service/src/main/java/cn/bunny/services/service/impl/SchedulersServiceImpl.java
+++ b/service/src/main/java/cn/bunny/services/service/impl/SchedulersServiceImpl.java
@@ -1,10 +1,10 @@
package cn.bunny.services.service.impl;
+import cn.bunny.common.service.exception.BunnyException;
import cn.bunny.dao.dto.schedulers.SchedulersAddDto;
import cn.bunny.dao.dto.schedulers.SchedulersDto;
import cn.bunny.dao.dto.schedulers.SchedulersOperationDto;
-import cn.bunny.dao.dto.schedulers.SchedulersUpdateDto;
-import cn.bunny.dao.entity.schedulers.ViewSchedulers;
+import cn.bunny.dao.entity.schedulers.Schedulers;
import cn.bunny.dao.pojo.result.PageResult;
import cn.bunny.dao.vo.schedulers.SchedulersVo;
import cn.bunny.services.mapper.SchedulersMapper;
@@ -13,9 +13,12 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import jakarta.validation.Valid;
+import org.quartz.*;
import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import java.lang.reflect.Constructor;
import java.util.List;
/**
@@ -24,10 +27,13 @@ import java.util.List;
*
*
* @author Bunny
- * @since 2024-10-14 20:59:25
+ * @since 2024-10-15 16:35:10
*/
@Service
-public class SchedulersServiceImpl extends ServiceImpl implements SchedulersService {
+public class SchedulersServiceImpl extends ServiceImpl implements SchedulersService {
+
+ @Autowired
+ private Scheduler scheduler;
/**
* * Schedulers视图 服务实现类
@@ -37,9 +43,9 @@ public class SchedulersServiceImpl extends ServiceImpl getSchedulersList(Page pageParams, SchedulersDto dto) {
+ public PageResult getSchedulersList(Page pageParams, SchedulersDto dto) {
// 分页查询菜单图标
- IPage page = baseMapper.selectListByPage(pageParams, dto);
+ IPage page = baseMapper.selectListByPage(pageParams, dto);
List voList = page.getRecords().stream().map(schedulers -> {
SchedulersVo schedulersVo = new SchedulersVo();
@@ -60,35 +66,36 @@ public class SchedulersServiceImpl extends ServiceImpl ids) {
- baseMapper.deleteBatchIdsWithPhysics(ids);
+ // 动态创建Class对象
+ Class className = Class.forName(jobClassName);
+ Constructor constructor = className.getConstructor(); // 获取无参构造函数
+ constructor.newInstance(); // 创建实例
+
+ // 创建任务
+ JobDetail jobDetail = JobBuilder.newJob((Class) className).withIdentity(jobName, jobGroup)
+ .withDescription(description).build();
+ jobDetail.getJobDataMap().put("jobMethodName", jobMethodName);
+
+ // 执行任务
+ CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);
+ CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger" + jobName, jobGroup)
+ .startNow().withSchedule(cronScheduleBuilder).build();
+ scheduler.scheduleJob(jobDetail, trigger);
+ } catch (Exception exception) {
+ throw new BunnyException(exception.getMessage());
+ }
}
/**
@@ -98,7 +105,12 @@ public class SchedulersServiceImpl extends ServiceImpl
-
+
@@ -19,7 +19,7 @@
-