定时任务设置 7-3

yxt_supervise/supervise-rms/supervise-rms-api/src/main/java/com/supervise/rms/api/scheduledtransmission/ScheduledTransmission.java

@@ -0,0 +1,17 @@
+package com.supervise.rms.api.scheduledtransmission;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+/**
+ * @author feikefei
+ * @create 2023-06-28-16:02
+ */
+@Data
+@ApiModel(value = "定时推送设置表")
+@TableName("scheduled_transmission")
+public class ScheduledTransmission {
+    private Integer id;
+    private String time;
+}

yxt_supervise/supervise-rms/supervise-rms-api/src/main/java/com/supervise/rms/api/scheduledtransmission/ScheduledTransmissionDto.java

@@ -0,0 +1,14 @@
+package com.supervise.rms.api.scheduledtransmission;
+
+import com.yxt.common.core.dto.Dto;
+import lombok.Data;
+
+/**
+ * @author feikefei
+ * @create 2023-06-28-16:05
+ */
+@Data
+public class ScheduledTransmissionDto implements Dto {
+    private Integer id;
+    private String time;
+}

yxt_supervise/supervise-rms/supervise-rms-api/src/main/java/com/supervise/rms/api/scheduledtransmission/ScheduledTransmissionQuery.java

@@ -0,0 +1,13 @@
+package com.supervise.rms.api.scheduledtransmission;
+
+import com.yxt.common.core.query.Query;
+import lombok.Data;
+
+/**
+ * @author feikefei
+ * @create 2023-06-28-16:07
+ */
+@Data
+public class ScheduledTransmissionQuery implements Query {
+    private String time;
+}

yxt_supervise/supervise-rms/supervise-rms-api/src/main/java/com/supervise/rms/api/scheduledtransmission/ScheduledTransmissionVo.java

@@ -0,0 +1,14 @@
+package com.supervise.rms.api.scheduledtransmission;
+
+import com.yxt.common.core.vo.Vo;
+import lombok.Data;
+
+/**
+ * @author feikefei
+ * @create 2023-06-28-16:07
+ */
+@Data
+public class ScheduledTransmissionVo implements Vo {
+    private Integer id;
+    private String time;
+}

yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/scheduledtransmission/ScheduledTransmissionMapper.java

@@ -0,0 +1,19 @@
+package com.supervise.rms.biz.scheduledtransmission;
+
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Constants;
+import com.supervise.rms.api.scheduledtransmission.ScheduledTransmission;
+import com.supervise.rms.api.scheduledtransmission.ScheduledTransmissionVo;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+/**
+ * @author feikefei
+ * @create 2023-06-28-16:11
+ */
+@Mapper
+public interface ScheduledTransmissionMapper extends BaseMapper<ScheduledTransmission> {
+    IPage<ScheduledTransmissionVo> listPage(IPage<ScheduledTransmission> page, @Param(Constants.WRAPPER) Wrapper<ScheduledTransmission> qw);
+}

yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/scheduledtransmission/ScheduledTransmissionMapper.xml

@@ -0,0 +1,10 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.supervise.rms.biz.scheduledtransmission.ScheduledTransmissionMapper">
+    <select id="listPage" resultType="com.supervise.rms.api.scheduledtransmission.ScheduledTransmissionVo">
+        select * from scheduled_transmission
+        <where>
+            ${ew.sqlSegment}
+        </where>
+    </select>
+</mapper>

yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/scheduledtransmission/ScheduledTransmissionRest.java

@@ -0,0 +1,41 @@
+package com.supervise.rms.biz.scheduledtransmission;
+
+import com.supervise.rms.api.scheduledtransmission.ScheduledTransmissionDto;
+import com.supervise.rms.api.scheduledtransmission.ScheduledTransmissionQuery;
+import com.supervise.rms.api.scheduledtransmission.ScheduledTransmissionVo;
+import com.yxt.common.core.query.PagerQuery;
+import com.yxt.common.core.result.ResultBean;
+import com.yxt.common.core.vo.PagerVo;
+import io.swagger.annotations.Api;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @author feikefei
+ * @create 2023-06-28-16:08
+ */
+@Api(tags = "定时推送设置表")
+@RestController("com.supervise.rmc.biz.scheduledtransmission.ScheduledTransmissionRest")
+@RequestMapping("v1/scheduled")
+public class ScheduledTransmissionRest {
+
+    @Autowired
+    private ScheduledTransmissionService scheduledTransmissionService;
+
+    @PostMapping("/save")
+    public ResultBean save(@RequestBody ScheduledTransmissionDto dto){
+        return scheduledTransmissionService.save(dto);
+    }
+
+    @GetMapping("/del/{id}")
+    public ResultBean del(@PathVariable Integer id){
+        return scheduledTransmissionService.del(id);
+    }
+
+    @PostMapping("/listPage")
+    public ResultBean listPage(@RequestBody PagerQuery<ScheduledTransmissionQuery> pq){
+        ResultBean rb = ResultBean.fireFail();
+        PagerVo<ScheduledTransmissionVo> pagerVo = scheduledTransmissionService.listPage(pq);
+        return rb.success().setData(pagerVo);
+    }
+}

yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/scheduledtransmission/ScheduledTransmissionService.java

@@ -0,0 +1,56 @@
+package com.supervise.rms.biz.scheduledtransmission;
+
+import cn.hutool.core.bean.BeanUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.supervise.rms.api.scheduledtransmission.ScheduledTransmission;
+import com.supervise.rms.api.scheduledtransmission.ScheduledTransmissionDto;
+import com.supervise.rms.api.scheduledtransmission.ScheduledTransmissionQuery;
+import com.supervise.rms.api.scheduledtransmission.ScheduledTransmissionVo;
+import com.yxt.common.base.service.MybatisBaseService;
+import com.yxt.common.base.utils.PagerUtil;
+import com.yxt.common.base.utils.StringUtils;
+import com.yxt.common.core.query.PagerQuery;
+import com.yxt.common.core.result.ResultBean;
+import com.yxt.common.core.vo.PagerVo;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author feikefei
+ * @create 2023-06-28-16:11
+ */
+@Service
+public class ScheduledTransmissionService extends MybatisBaseService<ScheduledTransmissionMapper, ScheduledTransmission> {
+
+    public ResultBean save(ScheduledTransmissionDto dto){
+        ResultBean rb = ResultBean.fireFail();
+        if (StringUtils.isNull(dto.getId())){
+            ScheduledTransmission scheduledTransmission = new ScheduledTransmission();
+            BeanUtil.copyProperties(dto,scheduledTransmission);
+            baseMapper.insert(scheduledTransmission);
+        }else {
+            ScheduledTransmission scheduledTransmission = fetchById(dto.getId());
+            BeanUtil.copyProperties(dto,scheduledTransmission,"id");
+            baseMapper.updateById(scheduledTransmission);
+        }
+        return rb.success().setMsg("更新成功");
+    }
+
+    public ResultBean del(Integer id){
+        ResultBean rb = ResultBean.fireFail();
+        deleteByid(id.toString());
+        return rb.success().setMsg("删除成功");
+    }
+
+    public PagerVo<ScheduledTransmissionVo> listPage(PagerQuery<ScheduledTransmissionQuery> pq){
+        ScheduledTransmissionQuery params = pq.getParams();
+        QueryWrapper<ScheduledTransmission> wq = new QueryWrapper<>();
+        if (StringUtils.isNotNull(params)){
+
+        }
+        IPage<ScheduledTransmission> page = PagerUtil.queryToPage(pq);
+        IPage<ScheduledTransmissionVo> iPage = baseMapper.listPage(page, wq);
+        PagerVo<ScheduledTransmissionVo> vo = PagerUtil.pageToVo(iPage, null);
+        return vo;
+    }
+}