提交任务相关信息

src/main/java/com/mokamrp/privates/controller/pangu/TaskListController.java

@@ -0,0 +1,118 @@
+package com.mokamrp.privates.controller.pangu;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.mokamrp.privates.constant.Constants;
+import com.mokamrp.privates.constant.HttpMsg;
+import com.mokamrp.privates.constant.HttpStatus;
+import com.mokamrp.privates.controller.BaseController;
+import com.mokamrp.privates.entity.PostBasePageHandle;
+import com.mokamrp.privates.help.AjaxResult;
+import com.mokamrp.privates.help.Analysis;
+import com.mokamrp.privates.interceptor.AuthUser;
+import com.mokamrp.privates.mapper.pangu.pojo.TaskList;
+import com.mokamrp.privates.mapper.pojo.User;
+import com.mokamrp.privates.service.pangu.TaskListService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.validation.Valid;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicInteger;
+
+
+/**
+ * <p>
+ * 盘古微信任务列表 前端控制器
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+@RestController
+@RequestMapping("/taskList")
+public class TaskListController extends BaseController<TaskList> {
+
+    @Autowired
+    public TaskListService taskListService;
+
+    /*
+     * @fast
+     * 默认生成的控制器所继承的父类中有index/add/edit/del四个基础方法,均为post json请求
+     * 如果需要定制化，需要将BaseController中对应的方法复制到当前控制器,然后进行修改
+     */
+
+    @PostMapping("/list")
+    public Object list(@RequestParam(required = false) String taskName,
+                       @RequestParam(required = false) String taskContent,
+                       @Valid @RequestBody PostBasePageHandle postBasePageHandle, BindingResult bindingResult) {
+        if (bindingResult.hasErrors()) {
+            return AjaxResult.error(HttpStatus.ERROR, bindingResult.getFieldError().getDefaultMessage());
+        }
+        Map<String, Object> res = taskListService.getList(postBasePageHandle, taskName, taskContent);
+        return AjaxResult.success(res);
+    }
+
+    @GetMapping("/getMaxTaskName")
+    public Object getMaxTaskName(String templateId) {
+        LambdaQueryWrapper<TaskList> taskListLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        taskListLambdaQueryWrapper.eq(TaskList::getTemplateId, templateId);
+        taskListLambdaQueryWrapper.orderByDesc(TaskList::getTaskName);
+        taskListLambdaQueryWrapper.last("Limit 1");
+
+        TaskList taskList = taskListService.getOne(taskListLambdaQueryWrapper);
+
+        if (null == taskList) {
+            return AjaxResult.success(Constants.SUCCESS, "Day1");
+        } else {
+            String taskName = taskList.getTaskName();
+            return AjaxResult.success(Constants.SUCCESS, "Day" + Integer.valueOf(taskName.replace("Day", "") + 1));
+        }
+    }
+
+    /**
+     * 导入
+     *
+     * @param file
+     * @param authUser
+     * @return
+     */
+    @PostMapping("/import")
+    @Transactional(rollbackFor = Exception.class)
+    public Object uploadFile(@RequestParam Integer templateId, @RequestBody MultipartFile file, @AuthUser User authUser) {
+        Map<Integer, String> field = new HashMap<>(1);
+        field.put(0, "taskContent");
+        List<Map<String, String>> row = new ArrayList<>();
+        try {
+            row = Analysis.analysis(file, field);
+        } catch (Exception e) {
+            return AjaxResult.error(e.getMessage());
+        }
+        AtomicInteger i = new AtomicInteger(0);
+        row.forEach(map -> {
+            i.getAndIncrement();
+            TaskList taskList = new TaskList();
+            taskList.setTemplateId(templateId);
+            taskList.setTaskName("Day" + i);
+            taskList.setTaskContent(map.get("taskContent"));
+            taskList.setDelFlg(1);
+            taskList.setCreateUid(authUser.getId());
+            taskList.setUpdateUid(authUser.getId());
+            taskList.setCreateAt(LocalDateTime.now());
+            taskList.setUpdateAt(LocalDateTime.now());
+
+            taskListService.save(taskList);
+        });
+
+        return AjaxResult.success(HttpMsg.importSuccess);
+    }
+
+
+}
+

src/main/java/com/mokamrp/privates/controller/pangu/TaskScheduleController.java

@@ -0,0 +1,52 @@
+package com.mokamrp.privates.controller.pangu;
+
+import com.mokamrp.privates.constant.HttpStatus;
+import com.mokamrp.privates.controller.BaseController;
+import com.mokamrp.privates.entity.PostBasePageHandle;
+import com.mokamrp.privates.help.AjaxResult;
+import com.mokamrp.privates.mapper.pangu.pojo.TaskSchedule;
+import com.mokamrp.privates.service.pangu.TaskScheduleService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.Valid;
+import java.util.Map;
+
+
+/**
+ * <p>
+ * 盘古微信任务排期 前端控制器
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+@RestController
+@RequestMapping("/taskSchedule")
+public class TaskScheduleController extends BaseController<TaskSchedule> {
+
+    @Autowired
+    public TaskScheduleService taskScheduleService;
+
+    /*
+     * @fast
+     * 默认生成的控制器所继承的父类中有index/add/edit/del四个基础方法,均为post json请求
+     * 如果需要定制化，需要将BaseController中对应的方法复制到当前控制器,然后进行修改
+     */
+
+    @PostMapping("/list")
+    public Object list(@Valid @RequestBody PostBasePageHandle postBasePageHandle, BindingResult bindingResult) {
+        if (bindingResult.hasErrors()) {
+            return AjaxResult.error(HttpStatus.ERROR, bindingResult.getFieldError().getDefaultMessage());
+        }
+        Map<String, Object> res = taskScheduleService.getList(postBasePageHandle);
+        return AjaxResult.success(res);
+    }
+
+
+}
+

src/main/java/com/mokamrp/privates/controller/pangu/TaskTemplateController.java

@@ -0,0 +1,49 @@
+package com.mokamrp.privates.controller.pangu;
+
+import com.mokamrp.privates.constant.HttpStatus;
+import com.mokamrp.privates.controller.BaseController;
+import com.mokamrp.privates.entity.PostBasePageHandle;
+import com.mokamrp.privates.help.AjaxResult;
+import com.mokamrp.privates.mapper.pangu.pojo.TaskTemplate;
+import com.mokamrp.privates.service.pangu.TaskTemplateService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.*;
+
+import javax.validation.Valid;
+import java.util.Map;
+
+
+/**
+ * <p>
+ * 盘古微信任务模版 前端控制器
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+@RestController
+@RequestMapping("/taskTemplate")
+public class TaskTemplateController extends BaseController<TaskTemplate> {
+
+    @Autowired
+    public TaskTemplateService taskTemplateService;
+
+    /*
+     * @fast
+     * 默认生成的控制器所继承的父类中有index/add/edit/del四个基础方法,均为post json请求
+     * 如果需要定制化，需要将BaseController中对应的方法复制到当前控制器,然后进行修改
+     */
+
+    @PostMapping("/list")
+    public Object list(@RequestParam(required = false) String templateName, @Valid @RequestBody PostBasePageHandle postBasePageHandle, BindingResult bindingResult) {
+        if (bindingResult.hasErrors()) {
+            return AjaxResult.error(HttpStatus.ERROR, bindingResult.getFieldError().getDefaultMessage());
+        }
+        Map<String, Object> res = taskTemplateService.getList(postBasePageHandle, templateName);
+        return AjaxResult.success(res);
+    }
+
+
+}
+

src/main/java/com/mokamrp/privates/mapper/pangu/TaskListMapper.java

@@ -0,0 +1,21 @@
+package com.mokamrp.privates.mapper.pangu;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.mokamrp.privates.mapper.pangu.pojo.TaskList;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 盘古微信任务列表 Mapper 接口
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+@Component
+public interface TaskListMapper extends BaseMapper<TaskList> {
+    public List<TaskList> getList(Page<TaskList> pageObj);
+}

src/main/java/com/mokamrp/privates/mapper/pangu/TaskListMapper.xml

@@ -0,0 +1,27 @@
+<?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.mokamrp.privates.mapper.pangu.TaskListMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.mokamrp.privates.mapper.pangu.pojo.TaskList">
+        <id column="id" property="id"/>
+        <result column="template_id" property="templateId"/>
+        <result column="task_name" property="taskName"/>
+        <result column="task_content" property="taskContent"/>
+        <result column="del_flg" property="delFlg"/>
+        <result column="create_uid" property="createUid"/>
+        <result column="update_uid" property="updateUid"/>
+        <result column="create_at" property="createAt"/>
+        <result column="update_at" property="updateAt"/>
+    </resultMap>
+
+    <!-- 通用查询结果列 -->
+    <sql id="Base_Column_List">
+        id
+        , template_id, task_name, task_content, del_flg, create_uid, update_uid, create_at, update_at
+    </sql>
+    <select id="getList" resultType="com.mokamrp.privates.mapper.pangu.pojo.TaskList">
+        SELECT *
+        FROM pan_task_list
+    </select>
+</mapper>

src/main/java/com/mokamrp/privates/mapper/pangu/TaskScheduleMapper.java

@@ -0,0 +1,21 @@
+package com.mokamrp.privates.mapper.pangu;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.mokamrp.privates.mapper.pangu.pojo.TaskSchedule;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 盘古微信任务排期 Mapper 接口
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+@Component
+public interface TaskScheduleMapper extends BaseMapper<TaskSchedule> {
+    public List<TaskSchedule> getList(Page<TaskSchedule> pageObj);
+}

src/main/java/com/mokamrp/privates/mapper/pangu/TaskScheduleMapper.xml

@@ -0,0 +1,35 @@
+<?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.mokamrp.privates.mapper.pangu.TaskScheduleMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.mokamrp.privates.mapper.pangu.pojo.TaskSchedule">
+        <id column="id" property="id"/>
+        <result column="station_id" property="stationId"/>
+        <result column="station_name" property="stationName"/>
+        <result column="mobile_code" property="mobileCode"/>
+        <result column="template_id" property="templateId"/>
+        <result column="task_id" property="taskId"/>
+        <result column="task_status" property="taskStatus"/>
+        <result column="task_send_status" property="taskSendStatus"/>
+        <result column="send_date" property="sendDate"/>
+        <result column="send_time" property="sendTime"/>
+        <result column="err_msg" property="errMsg"/>
+        <result column="mark" property="mark"/>
+        <result column="del_flg" property="delFlg"/>
+        <result column="create_uid" property="createUid"/>
+        <result column="update_uid" property="updateUid"/>
+        <result column="create_at" property="createAt"/>
+        <result column="update_at" property="updateAt"/>
+    </resultMap>
+
+    <!-- 通用查询结果列 -->
+    <sql id="Base_Column_List">
+        id
+        , station_id, station_name, mobile_code, template_id, task_id, task_status, task_send_status, send_date, send_time, err_msg, mark, del_flg, create_uid, update_uid, create_at, update_at
+    </sql>
+    <select id="getList" resultType="com.mokamrp.privates.mapper.pangu.pojo.TaskSchedule">
+        SELECT *
+        FROM pan_task_schedule
+    </select>
+</mapper>

src/main/java/com/mokamrp/privates/mapper/pangu/TaskTemplateMapper.java

@@ -0,0 +1,21 @@
+package com.mokamrp.privates.mapper.pangu;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.mokamrp.privates.mapper.pangu.pojo.TaskTemplate;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 盘古微信任务模版 Mapper 接口
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+@Component
+public interface TaskTemplateMapper extends BaseMapper<TaskTemplate> {
+    public List<TaskTemplate> getList(Page<TaskTemplate> pageObj);
+}

src/main/java/com/mokamrp/privates/mapper/pangu/TaskTemplateMapper.xml

@@ -0,0 +1,25 @@
+<?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.mokamrp.privates.mapper.pangu.TaskTemplateMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.mokamrp.privates.mapper.pangu.pojo.TaskTemplate">
+        <id column="id" property="id"/>
+        <result column="template_name" property="templateName"/>
+        <result column="del_flg" property="delFlg"/>
+        <result column="create_uid" property="createUid"/>
+        <result column="update_uid" property="updateUid"/>
+        <result column="create_at" property="createAt"/>
+        <result column="update_at" property="updateAt"/>
+    </resultMap>
+
+    <!-- 通用查询结果列 -->
+    <sql id="Base_Column_List">
+        id
+        , template_name, del_flg, create_uid, update_uid, create_at, update_at
+    </sql>
+    <select id="getList" resultType="com.mokamrp.privates.mapper.pangu.pojo.TaskTemplate">
+        SELECT *
+        FROM pan_task_template
+    </select>
+</mapper>

src/main/java/com/mokamrp/privates/mapper/pangu/pojo/TaskList.java

@@ -0,0 +1,162 @@
+package com.mokamrp.privates.mapper.pangu.pojo;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 盘古微信任务列表
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+@TableName("pan_task_list")
+public class TaskList extends Model<TaskList> {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 模板id
+     */
+    private Integer templateId;
+
+    /**
+     * 任务名称
+     */
+    private String taskName;
+
+    /**
+     * 任务内容
+     */
+    private String taskContent;
+
+    /**
+     * 删除标志
+     */
+    private Integer delFlg;
+
+    /**
+     * 创建人
+     */
+    private Integer createUid;
+
+    /**
+     * 更新人
+     */
+    private Integer updateUid;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updateAt;
+
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public Integer getTemplateId() {
+        return templateId;
+    }
+
+    public void setTemplateId(Integer templateId) {
+        this.templateId = templateId;
+    }
+
+    public String getTaskName() {
+        return taskName;
+    }
+
+    public void setTaskName(String taskName) {
+        this.taskName = taskName;
+    }
+
+    public String getTaskContent() {
+        return taskContent;
+    }
+
+    public void setTaskContent(String taskContent) {
+        this.taskContent = taskContent;
+    }
+
+    public Integer getDelFlg() {
+        return delFlg;
+    }
+
+    public void setDelFlg(Integer delFlg) {
+        this.delFlg = delFlg;
+    }
+
+    public Integer getCreateUid() {
+        return createUid;
+    }
+
+    public void setCreateUid(Integer createUid) {
+        this.createUid = createUid;
+    }
+
+    public Integer getUpdateUid() {
+        return updateUid;
+    }
+
+    public void setUpdateUid(Integer updateUid) {
+        this.updateUid = updateUid;
+    }
+
+    public LocalDateTime getCreateAt() {
+        return createAt;
+    }
+
+    public void setCreateAt(LocalDateTime createAt) {
+        this.createAt = createAt;
+    }
+
+    public LocalDateTime getUpdateAt() {
+        return updateAt;
+    }
+
+    public void setUpdateAt(LocalDateTime updateAt) {
+        this.updateAt = updateAt;
+    }
+
+    @Override
+    protected Serializable pkVal() {
+        return this.id;
+    }
+
+    @Override
+    public String toString() {
+        return "TaskList{" +
+                "id=" + id +
+                ", templateId=" + templateId +
+                ", taskName=" + taskName +
+                ", taskContent=" + taskContent +
+                ", delFlg=" + delFlg +
+                ", createUid=" + createUid +
+                ", updateUid=" + updateUid +
+                ", createAt=" + createAt +
+                ", updateAt=" + updateAt +
+                "}";
+    }
+}

src/main/java/com/mokamrp/privates/mapper/pangu/pojo/TaskSchedule.java

@@ -0,0 +1,275 @@
+package com.mokamrp.privates.mapper.pangu.pojo;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 盘古微信任务排期
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+@TableName("pan_task_schedule")
+public class TaskSchedule extends Model<TaskSchedule> {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 站点id(pan_fosterwx_station.id)
+     */
+    private Integer stationId;
+
+    /**
+     * 站点名称
+     */
+    private String stationName;
+
+    /**
+     * 手机编号
+     */
+    private Integer mobileCode;
+
+    /**
+     * 模板id
+     */
+    private Integer templateId;
+
+    /**
+     * 任务id
+     */
+    private Integer taskId;
+
+    /**
+     * 任务完成状态(0:待完成,1:已完成,2:已过期)
+     */
+    private Integer taskStatus;
+
+    /**
+     * 任务发送状态(0:等待发送,1:发送成功)
+     */
+    private Integer taskSendStatus;
+
+    /**
+     * 发送日期
+     */
+    private LocalDate sendDate;
+
+    /**
+     * 发送时间
+     */
+    private LocalDateTime sendTime;
+
+    /**
+     * 异常情况反馈
+     */
+    private String errMsg;
+
+    /**
+     * 检查备注
+     */
+    private String mark;
+
+    /**
+     * 删除标志
+     */
+    private Integer delFlg;
+
+    /**
+     * 创建人
+     */
+    private Integer createUid;
+
+    /**
+     * 更新人
+     */
+    private Integer updateUid;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updateAt;
+
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public Integer getStationId() {
+        return stationId;
+    }
+
+    public void setStationId(Integer stationId) {
+        this.stationId = stationId;
+    }
+
+    public String getStationName() {
+        return stationName;
+    }
+
+    public void setStationName(String stationName) {
+        this.stationName = stationName;
+    }
+
+    public Integer getMobileCode() {
+        return mobileCode;
+    }
+
+    public void setMobileCode(Integer mobileCode) {
+        this.mobileCode = mobileCode;
+    }
+
+    public Integer getTemplateId() {
+        return templateId;
+    }
+
+    public void setTemplateId(Integer templateId) {
+        this.templateId = templateId;
+    }
+
+    public Integer getTaskId() {
+        return taskId;
+    }
+
+    public void setTaskId(Integer taskId) {
+        this.taskId = taskId;
+    }
+
+    public Integer getTaskStatus() {
+        return taskStatus;
+    }
+
+    public void setTaskStatus(Integer taskStatus) {
+        this.taskStatus = taskStatus;
+    }
+
+    public Integer getTaskSendStatus() {
+        return taskSendStatus;
+    }
+
+    public void setTaskSendStatus(Integer taskSendStatus) {
+        this.taskSendStatus = taskSendStatus;
+    }
+
+    public LocalDate getSendDate() {
+        return sendDate;
+    }
+
+    public void setSendDate(LocalDate sendDate) {
+        this.sendDate = sendDate;
+    }
+
+    public LocalDateTime getSendTime() {
+        return sendTime;
+    }
+
+    public void setSendTime(LocalDateTime sendTime) {
+        this.sendTime = sendTime;
+    }
+
+    public String getErrMsg() {
+        return errMsg;
+    }
+
+    public void setErrMsg(String errMsg) {
+        this.errMsg = errMsg;
+    }
+
+    public String getMark() {
+        return mark;
+    }
+
+    public void setMark(String mark) {
+        this.mark = mark;
+    }
+
+    public Integer getDelFlg() {
+        return delFlg;
+    }
+
+    public void setDelFlg(Integer delFlg) {
+        this.delFlg = delFlg;
+    }
+
+    public Integer getCreateUid() {
+        return createUid;
+    }
+
+    public void setCreateUid(Integer createUid) {
+        this.createUid = createUid;
+    }
+
+    public Integer getUpdateUid() {
+        return updateUid;
+    }
+
+    public void setUpdateUid(Integer updateUid) {
+        this.updateUid = updateUid;
+    }
+
+    public LocalDateTime getCreateAt() {
+        return createAt;
+    }
+
+    public void setCreateAt(LocalDateTime createAt) {
+        this.createAt = createAt;
+    }
+
+    public LocalDateTime getUpdateAt() {
+        return updateAt;
+    }
+
+    public void setUpdateAt(LocalDateTime updateAt) {
+        this.updateAt = updateAt;
+    }
+
+    @Override
+    protected Serializable pkVal() {
+        return this.id;
+    }
+
+    @Override
+    public String toString() {
+        return "TaskSchedule{" +
+                "id=" + id +
+                ", stationId=" + stationId +
+                ", stationName=" + stationName +
+                ", mobileCode=" + mobileCode +
+                ", templateId=" + templateId +
+                ", taskId=" + taskId +
+                ", taskStatus=" + taskStatus +
+                ", taskSendStatus=" + taskSendStatus +
+                ", sendDate=" + sendDate +
+                ", sendTime=" + sendTime +
+                ", errMsg=" + errMsg +
+                ", mark=" + mark +
+                ", delFlg=" + delFlg +
+                ", createUid=" + createUid +
+                ", updateUid=" + updateUid +
+                ", createAt=" + createAt +
+                ", updateAt=" + updateAt +
+                "}";
+    }
+}

src/main/java/com/mokamrp/privates/mapper/pangu/pojo/TaskTemplate.java

@@ -0,0 +1,134 @@
+package com.mokamrp.privates.mapper.pangu.pojo;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 盘古微信任务模版
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+@TableName("pan_task_template")
+public class TaskTemplate extends Model<TaskTemplate> {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 模板名称
+     */
+    private String templateName;
+
+    /**
+     * 删除标志
+     */
+    private Integer delFlg;
+
+    /**
+     * 创建人
+     */
+    private Integer createUid;
+
+    /**
+     * 更新人
+     */
+    private Integer updateUid;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updateAt;
+
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getTemplateName() {
+        return templateName;
+    }
+
+    public void setTemplateName(String templateName) {
+        this.templateName = templateName;
+    }
+
+    public Integer getDelFlg() {
+        return delFlg;
+    }
+
+    public void setDelFlg(Integer delFlg) {
+        this.delFlg = delFlg;
+    }
+
+    public Integer getCreateUid() {
+        return createUid;
+    }
+
+    public void setCreateUid(Integer createUid) {
+        this.createUid = createUid;
+    }
+
+    public Integer getUpdateUid() {
+        return updateUid;
+    }
+
+    public void setUpdateUid(Integer updateUid) {
+        this.updateUid = updateUid;
+    }
+
+    public LocalDateTime getCreateAt() {
+        return createAt;
+    }
+
+    public void setCreateAt(LocalDateTime createAt) {
+        this.createAt = createAt;
+    }
+
+    public LocalDateTime getUpdateAt() {
+        return updateAt;
+    }
+
+    public void setUpdateAt(LocalDateTime updateAt) {
+        this.updateAt = updateAt;
+    }
+
+    @Override
+    protected Serializable pkVal() {
+        return this.id;
+    }
+
+    @Override
+    public String toString() {
+        return "TaskTemplate{" +
+                "id=" + id +
+                ", templateName=" + templateName +
+                ", delFlg=" + delFlg +
+                ", createUid=" + createUid +
+                ", updateUid=" + updateUid +
+                ", createAt=" + createAt +
+                ", updateAt=" + updateAt +
+                "}";
+    }
+}

src/main/java/com/mokamrp/privates/service/pangu/TaskListService.java

@@ -0,0 +1,20 @@
+package com.mokamrp.privates.service.pangu;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.mokamrp.privates.entity.PostBasePageHandle;
+import com.mokamrp.privates.mapper.pangu.pojo.TaskList;
+
+import java.util.Map;
+
+/**
+ * <p>
+ * 盘古微信任务列表 服务类
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+public interface TaskListService extends IService<TaskList> {
+    //.@leon 获取数据列表
+    public Map<String, Object> getList(PostBasePageHandle handle, String taskName, String taskContent);
+}

src/main/java/com/mokamrp/privates/service/pangu/TaskScheduleService.java

@@ -0,0 +1,20 @@
+package com.mokamrp.privates.service.pangu;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.mokamrp.privates.entity.PostBasePageHandle;
+import com.mokamrp.privates.mapper.pangu.pojo.TaskSchedule;
+
+import java.util.Map;
+
+/**
+ * <p>
+ * 盘古微信任务排期 服务类
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+public interface TaskScheduleService extends IService<TaskSchedule> {
+    //.@leon 获取数据列表
+    public Map<String, Object> getList(PostBasePageHandle handle);
+}

src/main/java/com/mokamrp/privates/service/pangu/TaskTemplateService.java

@@ -0,0 +1,20 @@
+package com.mokamrp.privates.service.pangu;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.mokamrp.privates.entity.PostBasePageHandle;
+import com.mokamrp.privates.mapper.pangu.pojo.TaskTemplate;
+
+import java.util.Map;
+
+/**
+ * <p>
+ * 盘古微信任务模版 服务类
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+public interface TaskTemplateService extends IService<TaskTemplate> {
+    //.@leon 获取数据列表
+    public Map<String, Object> getList(PostBasePageHandle handle, String templateName);
+}

src/main/java/com/mokamrp/privates/service/pangu/impl/TaskListServiceImpl.java

@@ -0,0 +1,51 @@
+package com.mokamrp.privates.service.pangu.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.mokamrp.privates.entity.PostBasePageHandle;
+import com.mokamrp.privates.mapper.pangu.TaskListMapper;
+import com.mokamrp.privates.mapper.pangu.pojo.TaskList;
+import com.mokamrp.privates.service.pangu.TaskListService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * <p>
+ * 盘古微信任务列表 服务实现类
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+@Service
+public class TaskListServiceImpl extends ServiceImpl<TaskListMapper, TaskList> implements TaskListService {
+
+    @Autowired
+    public TaskListMapper taskListMapper;
+
+    /**
+     * 获取数据列表 支持分页
+     * @param handle
+     * @param taskName
+     * @param taskContent
+     * @return
+     */
+    @Override
+    public Map<String, Object> getList(PostBasePageHandle handle, String taskName, String taskContent) {
+        Integer pageSize = handle.getPagesize();
+        Integer page = handle.getPage();
+        Page<TaskList> pageObj = new Page<TaskList>(page, pageSize);
+        LambdaQueryWrapper<TaskList> taskListLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        taskListLambdaQueryWrapper.eq(TaskList::getTaskName, taskName);
+        taskListLambdaQueryWrapper.eq(TaskList::getTaskContent, taskContent);
+        pageObj = taskListMapper.selectPage(pageObj, taskListLambdaQueryWrapper);
+        Map<String, Object> resMap = new HashMap<String, Object>();
+        resMap.put("list", pageObj.getRecords());
+        resMap.put("total", pageObj.getTotal());
+        return resMap;
+    }
+}

src/main/java/com/mokamrp/privates/service/pangu/impl/TaskScheduleServiceImpl.java

@@ -0,0 +1,45 @@
+package com.mokamrp.privates.service.pangu.impl;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.mokamrp.privates.entity.PostBasePageHandle;
+import com.mokamrp.privates.mapper.pangu.TaskScheduleMapper;
+import com.mokamrp.privates.mapper.pangu.pojo.TaskSchedule;
+import com.mokamrp.privates.service.pangu.TaskScheduleService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * <p>
+ * 盘古微信任务排期 服务实现类
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+@Service
+public class TaskScheduleServiceImpl extends ServiceImpl<TaskScheduleMapper, TaskSchedule> implements TaskScheduleService {
+
+    @Autowired
+    public TaskScheduleMapper taskScheduleMapper;
+
+    /**
+     * 获取数据列表 支持分页
+     * @param handle
+     * @return
+     */
+    public Map<String, Object> getList(PostBasePageHandle handle) {
+        Integer pagesize = handle.getPagesize();
+        Integer page = handle.getPage();
+        Page<TaskSchedule> pageObj = new Page<TaskSchedule>(page, pagesize);
+        List<TaskSchedule> list = taskScheduleMapper.getList(pageObj);
+        Map<String, Object> resMap = new HashMap<String, Object>();
+        resMap.put("list", list);
+        resMap.put("total", pageObj.getTotal());
+        return resMap;
+    }
+}

src/main/java/com/mokamrp/privates/service/pangu/impl/TaskTemplateServiceImpl.java

@@ -0,0 +1,52 @@
+package com.mokamrp.privates.service.pangu.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.mokamrp.privates.entity.PostBasePageHandle;
+import com.mokamrp.privates.mapper.pangu.TaskTemplateMapper;
+import com.mokamrp.privates.mapper.pangu.pojo.TaskTemplate;
+import com.mokamrp.privates.service.pangu.TaskTemplateService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * <p>
+ * 盘古微信任务模版 服务实现类
+ * </p>
+ *
+ * @author leon
+ * @since 2021-07-23
+ */
+@Service
+public class TaskTemplateServiceImpl extends ServiceImpl<TaskTemplateMapper, TaskTemplate> implements TaskTemplateService {
+
+    @Autowired
+    public TaskTemplateMapper taskTemplateMapper;
+
+    /**
+     * 获取数据列表 支持分页
+     * @param handle
+     * @param templateName
+     * @return
+     */
+    @Override
+    public Map<String, Object> getList(PostBasePageHandle handle, String templateName) {
+        Integer pageSize = handle.getPagesize();
+        Integer page = handle.getPage();
+        LambdaQueryWrapper<TaskTemplate> taskTemplateLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        taskTemplateLambdaQueryWrapper.eq(TaskTemplate::getTemplateName, templateName);
+
+        Page<TaskTemplate> taskTemplatePage = new Page<>(page, pageSize);
+
+        taskTemplatePage = taskTemplateMapper.selectPage(taskTemplatePage, taskTemplateLambdaQueryWrapper);
+
+        Map<String, Object> resMap = new HashMap<String, Object>();
+        resMap.put("list", taskTemplatePage.getRecords());
+        resMap.put("total", taskTemplatePage.getTotal());
+        return resMap;
+    }
+}