remove(@RequestBody SchedulersOperationDto dto) {
+ schedulersService.removeScheduler(dto);
return Result.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 ca152a3..f5d577d 100644
--- a/service/src/main/java/cn/bunny/services/mapper/SchedulersMapper.java
+++ b/service/src/main/java/cn/bunny/services/mapper/SchedulersMapper.java
@@ -1,18 +1,39 @@
package cn.bunny.services.mapper;
-import cn.bunny.dao.entity.view.Schedulers;
+import cn.bunny.dao.dto.schedulers.SchedulersDto;
+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;
/**
*
- * VIEW Mapper 接口
+ * Schedulers视图 Mapper 接口
*
*
* @author Bunny
- * @since 2024-10-14
+ * @since 2024-10-14 20:59:25
*/
@Mapper
public interface SchedulersMapper extends BaseMapper {
+ /**
+ * * 分页查询Schedulers视图内容
+ *
+ * @param pageParams Schedulers视图分页参数
+ * @param dto Schedulers视图查询表单
+ * @return Schedulers视图分页结果
+ */
+ IPage selectListByPage(@Param("page") Page pageParams, @Param("dto") SchedulersDto dto);
+
+ /**
+ * 物理删除Schedulers视图
+ *
+ * @param ids 删除 id 列表
+ */
+ void deleteBatchIdsWithPhysics(List ids);
}
diff --git a/service/src/main/java/cn/bunny/services/quartz/job/JobHello.java b/service/src/main/java/cn/bunny/services/quartz/job/JobHello.java
new file mode 100644
index 0000000..7f65561
--- /dev/null
+++ b/service/src/main/java/cn/bunny/services/quartz/job/JobHello.java
@@ -0,0 +1,19 @@
+package cn.bunny.services.quartz.job;
+
+import lombok.extern.slf4j.Slf4j;
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+
+@Slf4j
+public class JobHello implements Job {
+ public void start() {
+ log.error("执行任务--JobHello。。。。。。。。。");
+ System.out.print("执行任务--JobHello。。。。。。。。。");
+ }
+
+ @Override
+ public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
+ start();
+ }
+}
diff --git a/service/src/main/java/cn/bunny/services/quartz/job/JobHello2.java b/service/src/main/java/cn/bunny/services/quartz/job/JobHello2.java
new file mode 100644
index 0000000..b9fcec9
--- /dev/null
+++ b/service/src/main/java/cn/bunny/services/quartz/job/JobHello2.java
@@ -0,0 +1,19 @@
+package cn.bunny.services.quartz.job;
+
+import lombok.extern.slf4j.Slf4j;
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+
+@Slf4j
+public class JobHello2 implements Job {
+ public void start() {
+ log.error("执行任务---JobHello2。。。。。。。。。");
+ System.out.print("执行任务--JobHello2。。。。。。。。。");
+ }
+
+ @Override
+ public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
+ start();
+ }
+}
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 92b22f7..c98c61f 100644
--- a/service/src/main/java/cn/bunny/services/service/SchedulersService.java
+++ b/service/src/main/java/cn/bunny/services/service/SchedulersService.java
@@ -1,16 +1,74 @@
package cn.bunny.services.service;
-import cn.bunny.dao.entity.view.Schedulers;
+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.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;
/**
*
- * VIEW 服务类
+ * Schedulers视图 服务类
*
*
* @author Bunny
- * @since 2024-10-14
+ * @since 2024-10-14 20:59:25
*/
public interface SchedulersService extends IService {
+ /**
+ * * 获取Schedulers视图列表
+ *
+ * @return Schedulers视图返回列表
+ */
+ PageResult getSchedulersList(Page pageParams, SchedulersDto dto);
+
+ /**
+ * * 添加Schedulers视图
+ *
+ * @param dto 添加表单
+ */
+ void addSchedulers(@Valid SchedulersAddDto dto);
+
+ /**
+ * * 更新Schedulers视图
+ *
+ * @param dto 更新表单
+ */
+ void updateSchedulers(@Valid SchedulersUpdateDto dto);
+
+ /**
+ * * 删除|批量删除Schedulers视图类型
+ *
+ * @param ids 删除id列表
+ */
+ void deleteSchedulers(List ids);
+
+ /**
+ * * 暂停Schedulers任务
+ *
+ * @param dto Schedulers公共操作表单
+ */
+ void pauseScheduler(SchedulersOperationDto dto);
+
+ /**
+ * * 恢复Schedulers任务
+ *
+ * @param dto Schedulers公共操作表单
+ */
+ void resumeScheduler(SchedulersOperationDto dto);
+
+ /**
+ * * 移出Schedulers任务
+ *
+ * @param dto Schedulers公共操作表单
+ */
+ void removeScheduler(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 7bf532a..545008b 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,20 +1,123 @@
package cn.bunny.services.service.impl;
-import cn.bunny.dao.entity.view.Schedulers;
+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.Schedulers;
+import cn.bunny.dao.pojo.result.PageResult;
+import cn.bunny.dao.vo.schedulers.SchedulersVo;
import cn.bunny.services.mapper.SchedulersMapper;
import cn.bunny.services.service.SchedulersService;
+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.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
+import java.util.List;
+
/**
*
- * VIEW 服务实现类
+ * Schedulers视图 服务实现类
*
*
* @author Bunny
- * @since 2024-10-14
+ * @since 2024-10-14 20:59:25
*/
@Service
public class SchedulersServiceImpl extends ServiceImpl implements SchedulersService {
+ /**
+ * * Schedulers视图 服务实现类
+ *
+ * @param pageParams Schedulers视图分页查询page对象
+ * @param dto Schedulers视图分页查询对象
+ * @return 查询分页Schedulers视图返回对象
+ */
+ @Override
+ public PageResult getSchedulersList(Page pageParams, SchedulersDto dto) {
+ // 分页查询菜单图标
+ IPage page = baseMapper.selectListByPage(pageParams, dto);
+
+ List voList = page.getRecords().stream().map(schedulers -> {
+ SchedulersVo schedulersVo = new SchedulersVo();
+ BeanUtils.copyProperties(schedulers, schedulersVo);
+ return schedulersVo;
+ }).toList();
+
+ return PageResult.builder()
+ .list(voList)
+ .pageNo(page.getCurrent())
+ .pageSize(page.getSize())
+ .total(page.getTotal())
+ .build();
+ }
+
+ /**
+ * 添加Schedulers视图
+ *
+ * @param dto Schedulers视图添加
+ */
+ @Override
+ public void addSchedulers(@Valid SchedulersAddDto dto) {
+ // 保存数据
+ Schedulers schedulers = new Schedulers();
+ BeanUtils.copyProperties(dto, schedulers);
+ save(schedulers);
+ }
+
+ /**
+ * 更新Schedulers视图
+ *
+ * @param dto Schedulers视图更新
+ */
+ @Override
+ public void updateSchedulers(@Valid SchedulersUpdateDto dto) {
+ // 更新内容
+ Schedulers schedulers = new Schedulers();
+ BeanUtils.copyProperties(dto, schedulers);
+ updateById(schedulers);
+ }
+
+ /**
+ * 删除|批量删除Schedulers视图
+ *
+ * @param ids 删除id列表
+ */
+ @Override
+ public void deleteSchedulers(List ids) {
+ baseMapper.deleteBatchIdsWithPhysics(ids);
+ }
+
+ /**
+ * * 暂停Schedulers任务
+ *
+ * @param dto Schedulers公共操作表单
+ */
+ @Override
+ public void pauseScheduler(SchedulersOperationDto dto) {
+
+ }
+
+ /**
+ * * 恢复Schedulers任务
+ *
+ * @param dto Schedulers公共操作表单
+ */
+ @Override
+ public void resumeScheduler(SchedulersOperationDto dto) {
+
+ }
+
+ /**
+ * * 移出Schedulers任务
+ *
+ * @param dto Schedulers公共操作表单
+ */
+ @Override
+ public void removeScheduler(SchedulersOperationDto dto) {
+
+ }
}
diff --git a/service/src/main/resources/mapper/SchedulersMapper.xml b/service/src/main/resources/mapper/SchedulersMapper.xml
index 5b3c35d..24b31df 100644
--- a/service/src/main/resources/mapper/SchedulersMapper.xml
+++ b/service/src/main/resources/mapper/SchedulersMapper.xml
@@ -3,14 +3,14 @@
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
@@ -18,4 +18,42 @@
job_name, job_group, description, job_class_name, cron_expression, trigger_name, trigger_state
+
+
+
+
+
+ delete
+ from v_schedulers
+ where id in
+
+ #{id}
+
+
+