监控调阅任务

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/retrieval/controller/CoreMonitoringRetrievalTaskController.java

@@ -0,0 +1,99 @@
+package com.xunmei.core.retrieval.controller;
+
+import com.xunmei.common.core.domain.edu.dto.SysLearningMaterialsPageDto;
+import com.xunmei.common.core.web.controller.BaseController;
+import com.xunmei.common.core.web.domain.AjaxResult;
+import com.xunmei.common.core.web.page.TableDataInfo;
+import com.xunmei.common.log.annotation.Log;
+import com.xunmei.common.log.enums.BusinessType;
+import com.xunmei.common.security.annotation.RequiresPermissions;
+import com.xunmei.core.retrieval.domain.CoreMonitoringRetrievalTask;
+import com.xunmei.core.retrieval.dto.RetrievalTaskPageDto;
+import com.xunmei.core.retrieval.service.ICoreMonitoringRetrievalTaskService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+/**
+ * 监控调阅任务Controller
+ *
+ * @author xunmei
+ * @date 2023-08-25
+ */
+@Api(tags = {"CoreMonitoringRetrievalTask" })
+@RestController
+@RequestMapping("/task")
+public class CoreMonitoringRetrievalTaskController extends BaseController {
+    @Autowired
+    private ICoreMonitoringRetrievalTaskService coreMonitoringRetrievalTaskService;
+
+/**
+ * 查询监控调阅任务列表
+ */
+@ApiOperation(value = "查询CoreMonitoringRetrievalTask列表")
+@GetMapping("/list")
+    public TableDataInfo list(RetrievalTaskPageDto request) {
+
+        return coreMonitoringRetrievalTaskService.selectPage( request);
+    }
+    /**
+     * 导出excel
+     */
+    @ApiOperation(value = "导出监控调阅任务")
+    @RequiresPermissions("core:task:export")
+    @Log(title = "导出监控调阅任务", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    public void export(RetrievalTaskPageDto request, HttpServletResponse response) throws IOException {
+        coreMonitoringRetrievalTaskService.export(request,response);
+    }
+
+
+
+
+    /**
+     * 获取监控调阅任务详细信息
+     */
+    @ApiOperation(value = "获取CoreMonitoringRetrievalTask详细信息")
+    @RequiresPermissions("core:task:query")
+    @GetMapping(value = "/{id}")
+    public AjaxResult getInfo(@PathVariable("id") Long id) {
+        return success(coreMonitoringRetrievalTaskService.selectCoreMonitoringRetrievalTaskById(id));
+    }
+
+    /**
+     * 新增监控调阅任务
+     */
+    @ApiOperation(value = "新增CoreMonitoringRetrievalTask")
+    @RequiresPermissions("core:task:add")
+    @Log(title = "监控调阅任务" , businessType = BusinessType.INSERT)
+    @PostMapping
+    public AjaxResult add(@RequestBody CoreMonitoringRetrievalTask CoreMonitoringRetrievalTask) {
+        return toAjax(coreMonitoringRetrievalTaskService.insertCoreMonitoringRetrievalTask(CoreMonitoringRetrievalTask));
+    }
+
+    /**
+     * 修改监控调阅任务
+     */
+    @ApiOperation(value = "修改CoreMonitoringRetrievalTask")
+    @RequiresPermissions("core:task:edit")
+    @Log(title = "监控调阅任务" , businessType = BusinessType.UPDATE)
+    @PutMapping
+    public AjaxResult edit(@RequestBody CoreMonitoringRetrievalTask CoreMonitoringRetrievalTask) {
+        return toAjax(coreMonitoringRetrievalTaskService.updateCoreMonitoringRetrievalTask(CoreMonitoringRetrievalTask));
+    }
+
+    /**
+     * 删除监控调阅任务
+     */
+    @ApiOperation(value = "删除CoreMonitoringRetrievalTask")
+    @RequiresPermissions("core:task:remove")
+    @Log(title = "监控调阅任务" , businessType = BusinessType.DELETE)
+    @DeleteMapping("/{ids}")
+    public AjaxResult remove(@PathVariable Long[] ids) {
+        return toAjax(coreMonitoringRetrievalTaskService.deleteCoreMonitoringRetrievalTaskByIds(ids));
+    }
+}

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/retrieval/domain/CoreMonitoringRetrievalTask.java

@@ -0,0 +1,200 @@
+package com.xunmei.core.retrieval.domain;
+
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.IdType;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import com.xunmei.common.core.web.domain.BaseEntity;
+
+/**
+ * 监控调阅任务对象 core_monitoring_retrieval_task
+ *
+ * @author xunmei
+ * @date 2023-08-25
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("core_monitoring_retrieval_task")
+@ApiModel(value = "CoreMonitoringRetrievalTask对象" , description = "监控调阅任务")
+public class CoreMonitoringRetrievalTask extends BaseEntity
+        {
+private static final long serialVersionUID=1L;
+
+    /** 主键 */
+    private Long id;
+
+    /** 计划id */
+    private Long planId;
+
+    /** 任务名称 */
+            @ApiModelProperty(value = "任务名称")
+    private String taskName;
+
+    /** 调阅机构 */
+    private Long orgId;
+
+    /** 调阅机构 */
+    private String orgPath;
+
+    /** 调阅机构 */
+            @ApiModelProperty(value = "调阅机构")
+    private String orgName;
+
+    /** 年月日 */
+    private Date ymdDate;
+
+    /** 年 */
+    private Long ymdYear;
+
+    /** 半年 */
+    private Long ymdHalfyear;
+
+    /** 季度 */
+    private Long ymdQuarter;
+
+    /** 月 */
+    private Long ymdMonth;
+
+    /** 周 */
+    private Long ymdWeek;
+
+    /** 日 */
+    private Long ymdDay;
+
+    /** 周期无周期、每日、每周、每月、每季度、每半年、每年（0-6） */
+    private Long cycle;
+
+    /** 开始时间 */
+            @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+            @ApiModelProperty(value = "开始时间")
+    private Date planStartTime;
+
+    /** 结束时间 */
+            @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+            @ApiModelProperty(value = "结束时间")
+    private Date planEndTime;
+
+    /** 调阅开始时间 */
+            @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+            @ApiModelProperty(value = "调阅开始时间")
+    private Date startTime;
+
+    /** 调阅结束时间 */
+            @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+            @ApiModelProperty(value = "调阅结束时间")
+    private Date endTime;
+
+    /** 状态 */
+            @ApiModelProperty(value = "状态")
+    private Long status;
+
+    /** 角色id */
+    private Long roleId;
+
+    /** 调阅人 */
+    private Long retrievalUser;
+
+    /** 第几次调阅（根据计划的频次计算的来） */
+    private Long orderNum;
+
+    /** 批次号（同一计划多频次为一个批次号） */
+    private Long batchNum;
+
+    /** 提交时间 */
+    private Date submitTime;
+
+    /** 异常数 */
+            @ApiModelProperty(value = "异常数")
+    private Long exceptionCount;
+
+                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        
+@Override
+public String toString(){
+        return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
+
+
+                .append("id" ,getId())
+
+
+                .append("planId" ,getPlanId())
+
+
+                .append("taskName" ,getTaskName())
+
+
+                .append("orgId" ,getOrgId())
+
+
+                .append("orgPath" ,getOrgPath())
+
+
+                .append("orgName" ,getOrgName())
+
+
+                .append("ymdDate" ,getYmdDate())
+
+
+                .append("ymdYear" ,getYmdYear())
+
+
+                .append("ymdHalfyear" ,getYmdHalfyear())
+
+
+                .append("ymdQuarter" ,getYmdQuarter())
+
+
+                .append("ymdMonth" ,getYmdMonth())
+
+
+                .append("ymdWeek" ,getYmdWeek())
+
+
+                .append("ymdDay" ,getYmdDay())
+
+
+                .append("cycle" ,getCycle())
+
+
+                .append("planStartTime" ,getPlanStartTime())
+
+
+                .append("planEndTime" ,getPlanEndTime())
+
+
+                .append("startTime" ,getStartTime())
+
+
+                .append("endTime" ,getEndTime())
+
+
+                .append("status" ,getStatus())
+
+
+                .append("roleId" ,getRoleId())
+
+
+                .append("retrievalUser" ,getRetrievalUser())
+
+
+                .append("orderNum" ,getOrderNum())
+
+
+                .append("batchNum" ,getBatchNum())
+
+
+                .append("submitTime" ,getSubmitTime())
+
+
+                .append("exceptionCount" ,getExceptionCount())
+        .toString();
+        }
+        }

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/retrieval/dto/RetrievalTaskPageDto.java

@@ -0,0 +1,60 @@
+package com.xunmei.core.retrieval.dto;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.xunmei.common.core.web.domain.BaseEntity;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+import java.util.Date;
+
+/**
+ * 监控调阅任务对象 core_monitoring_retrieval_task
+ *
+ * @author xunmei
+ * @date 2023-08-25
+ */
+@Data
+@ApiModel(value = "CoreMonitoringRetrievalTask对象" , description = "监控调阅任务")
+public class RetrievalTaskPageDto extends BaseEntity
+    {
+        /**
+         * 任务名称
+         */
+    private String taskName;
+
+    /** 调阅机构 */
+    private Long orgId;
+
+    /** 调阅机构 */
+    private String orgPath;
+
+
+    /** 周期无周期、每日、每周、每月、每季度、每半年、每年（0-6） */
+    private Integer cycle;
+    /** 状态 */
+    private Integer status;
+
+    /** 角色id */
+    private Long roleId;
+        /**
+         * 页面
+         */
+    private Long pageNum;
+        /**
+         * 每页大小
+         */
+    private Long pageSize;
+        /**
+         * 是否下穿
+         */
+    private Boolean checkSub = false;
+
+    private Date[] dateRange;
+}

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/retrieval/mapper/CoreMonitoringRetrievalTaskMapper.java

@@ -0,0 +1,68 @@
+package com.xunmei.core.retrieval.mapper;
+
+import java.util.List;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.xunmei.core.retrieval.domain.CoreMonitoringRetrievalTask;
+import com.xunmei.core.retrieval.dto.RetrievalTaskPageDto;
+import com.xunmei.core.retrieval.vo.CoreMonitoringRetrievalTaskVo;
+import org.apache.ibatis.annotations.Param;
+
+/**
+ * 监控调阅任务Mapper接口
+ *
+ * @author xunmei
+ * @date 2023-08-25
+ */
+public interface CoreMonitoringRetrievalTaskMapper extends BaseMapper<CoreMonitoringRetrievalTask> {
+    /**
+     * 查询监控调阅任务
+     *
+     * @param id 监控调阅任务主键
+     * @return 监控调阅任务
+     */
+    public CoreMonitoringRetrievalTask selectCoreMonitoringRetrievalTaskById(Long id);
+
+    /**
+     * 查询监控调阅任务列表
+     *
+     * @param CoreMonitoringRetrievalTask 监控调阅任务
+     * @return 监控调阅任务集合
+     */
+    public List<CoreMonitoringRetrievalTask> selectCoreMonitoringRetrievalTaskList(CoreMonitoringRetrievalTask CoreMonitoringRetrievalTask);
+
+    /**
+     * 新增监控调阅任务
+     *
+     * @param CoreMonitoringRetrievalTask 监控调阅任务
+     * @return 结果
+     */
+    public int insertCoreMonitoringRetrievalTask(CoreMonitoringRetrievalTask CoreMonitoringRetrievalTask);
+
+    /**
+     * 修改监控调阅任务
+     *
+     * @param CoreMonitoringRetrievalTask 监控调阅任务
+     * @return 结果
+     */
+    public int updateCoreMonitoringRetrievalTask(CoreMonitoringRetrievalTask CoreMonitoringRetrievalTask);
+
+    /**
+     * 删除监控调阅任务
+     *
+     * @param id 监控调阅任务主键
+     * @return 结果
+     */
+    public int deleteCoreMonitoringRetrievalTaskById(Long id);
+
+    /**
+     * 批量删除监控调阅任务
+     *
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteCoreMonitoringRetrievalTaskByIds(Long[] ids);
+
+    Page<CoreMonitoringRetrievalTaskVo> selectPageList(Page<CoreMonitoringRetrievalTaskVo> page, @Param("request") RetrievalTaskPageDto request);
+}

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/retrieval/service/ICoreMonitoringRetrievalTaskService.java

@@ -0,0 +1,79 @@
+package com.xunmei.core.retrieval.service;
+
+import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+import java.util.List;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.xunmei.common.core.web.page.TableDataInfo;
+import com.xunmei.core.retrieval.domain.CoreMonitoringRetrievalTask;
+import com.xunmei.core.retrieval.dto.RetrievalTaskPageDto;
+
+import javax.servlet.http.HttpServletResponse;
+
+/**
+ * 监控调阅任务Service接口
+ *
+ * @author xunmei
+ * @date 2023-08-25
+ */
+public interface ICoreMonitoringRetrievalTaskService extends IService<CoreMonitoringRetrievalTask> {
+    /**
+     * 查询监控调阅任务
+     *
+     * @param id 监控调阅任务主键
+     * @return 监控调阅任务
+     */
+    public CoreMonitoringRetrievalTask selectCoreMonitoringRetrievalTaskById(Long id);
+
+    /**
+     * 查询监控调阅任务列表
+     *
+     * @param CoreMonitoringRetrievalTask 监控调阅任务
+     * @return 监控调阅任务集合
+     */
+    public List<CoreMonitoringRetrievalTask> selectCoreMonitoringRetrievalTaskList(CoreMonitoringRetrievalTask CoreMonitoringRetrievalTask);
+
+    /**
+     * 新增监控调阅任务
+     *
+     * @param CoreMonitoringRetrievalTask 监控调阅任务
+     * @return 结果
+     */
+    public int insertCoreMonitoringRetrievalTask(CoreMonitoringRetrievalTask CoreMonitoringRetrievalTask);
+
+    /**
+     * 修改监控调阅任务
+     *
+     * @param CoreMonitoringRetrievalTask 监控调阅任务
+     * @return 结果
+     */
+    public int updateCoreMonitoringRetrievalTask(CoreMonitoringRetrievalTask CoreMonitoringRetrievalTask);
+
+    /**
+     * 批量删除监控调阅任务
+     *
+     * @param ids 需要删除的监控调阅任务主键集合
+     * @return 结果
+     */
+    public int deleteCoreMonitoringRetrievalTaskByIds(Long[] ids);
+
+    /**
+     * 删除监控调阅任务信息
+     *
+     * @param id 监控调阅任务主键
+     * @return 结果
+     */
+    public int deleteCoreMonitoringRetrievalTaskById(Long id);
+
+    /**
+     * 查询监控调阅任务分页数据
+     *
+     * @param CoreMonitoringRetrievalTask 查询条件对象
+     * @return Page
+     */
+    public TableDataInfo selectPage(RetrievalTaskPageDto request);
+
+    void export(RetrievalTaskPageDto request, HttpServletResponse response) throws IOException;
+}

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/retrieval/service/impl/CoreMonitoringRetrievalTaskServiceImpl.java

@@ -0,0 +1,180 @@
+package com.xunmei.core.retrieval.service.impl;
+
+import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+import java.net.URLEncoder;
+import java.util.Date;
+import java.util.List;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.poi.excel.ExcelUtil;
+import cn.hutool.poi.excel.ExcelWriter;
+import com.xunmei.common.core.constant.SecurityConstants;
+import com.xunmei.common.core.domain.R;
+import com.xunmei.common.core.utils.DateHelper;
+import com.xunmei.core.retrieval.domain.CoreMonitoringRetrievalTask;
+import com.xunmei.core.retrieval.dto.RetrievalTaskPageDto;
+import com.xunmei.core.retrieval.mapper.CoreMonitoringRetrievalTaskMapper;
+import com.xunmei.core.retrieval.service.ICoreMonitoringRetrievalTaskService;
+import com.xunmei.core.retrieval.vo.CoreMonitoringRetrievalTaskVo;
+import com.xunmei.system.api.RemoteOrgService;
+import com.xunmei.system.api.domain.SysOrg;
+import com.xunmei.system.api.function.RemoteCallHandlerExecutor;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import java.util.Arrays;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.xunmei.common.core.web.page.TableDataInfo;
+
+import javax.annotation.Resource;
+import javax.servlet.ServletOutputStream;
+import javax.servlet.http.HttpServletResponse;
+
+
+/**
+ * 监控调阅任务Service业务层处理
+ *
+ * @author xunmei
+ * @date 2023-08-25
+ */
+@Service
+public class CoreMonitoringRetrievalTaskServiceImpl extends ServiceImpl<CoreMonitoringRetrievalTaskMapper, CoreMonitoringRetrievalTask> implements ICoreMonitoringRetrievalTaskService {
+    @Resource
+    private CoreMonitoringRetrievalTaskMapper coreMonitoringRetrievalTaskMapper;
+    @Resource
+    private RemoteOrgService orgService;
+
+    @Override
+    public TableDataInfo selectPage(RetrievalTaskPageDto request) {
+
+        Page<CoreMonitoringRetrievalTaskVo> page;
+        //分页
+        if (request.getPageNum()!=null&&request.getPageSize()!=null)
+        {
+            page = new Page<>(request.getPageNum(), request.getPageSize());
+        }else{
+            page = new Page<>();
+        }
+        //下穿
+        if (request.getCheckSub()) {
+            SysOrg sysOrg = RemoteCallHandlerExecutor.executeRemoteCall(() -> orgService.selectTopOrg(SecurityConstants.INNER), "获取机构信息失败!");
+            request.setOrgPath(sysOrg.getPath());
+            request.setOrgId(null);
+        }
+        //获取数据
+        page = coreMonitoringRetrievalTaskMapper.selectPageList(page, request);
+        //抓换为TableDataInfo适配前端
+        return TableDataInfo.build(page);
+    }
+
+    @Override
+    public void export(RetrievalTaskPageDto request, HttpServletResponse response) throws IOException {
+        //不分页
+        request.setPageSize(null);
+        request.setPageNum(null);
+        SysOrg sysOrg = RemoteCallHandlerExecutor.executeRemoteCall(() -> orgService.selectTopOrg(SecurityConstants.INNER), "获取机构信息失败!");
+
+        final TableDataInfo tableDataInfo = this.selectPage(request);
+        if (ObjectUtil.isEmpty(tableDataInfo.getRows())) {
+            throw new RuntimeException("导出数据为空!");
+        }
+        List<CoreMonitoringRetrievalTaskVo> list = this.selectPage(request).getRows();
+        list.forEach(r->r.setNo(list.indexOf(r)+1));
+        ExcelWriter writer = ExcelUtil.getWriter(true);
+        writer.addHeaderAlias("序号", "no");
+        writer.addHeaderAlias("任务名称", "taskName");
+        writer.addHeaderAlias("开始时间", "planStartTime");
+        writer.addHeaderAlias("结束时间", "planEndTime");
+        writer.addHeaderAlias("状态", "");
+        writer.addHeaderAlias("调阅机构", "orgName");
+        writer.addHeaderAlias("调阅角色", "roleName");
+        writer.addHeaderAlias("调阅开始时间", "startTime");
+        writer.addHeaderAlias("调阅结束时间", "endTime");
+        writer.addHeaderAlias("调阅人", "retrievalUserName");
+        writer.addHeaderAlias("异常数", "exceptionCount");
+        //只保留别名的数据
+        writer.setOnlyAlias(true);
+        // 默认配置
+        writer.write(list, true);
+        // 设置content—type
+        response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet;charset:utf-8");
+        // 设置标题
+        String fileName = URLEncoder.encode("【" + sysOrg.getName() + "】-监控调阅任务记录" + DateHelper.getDateString(new Date()), "UTF-8");
+        //Content-disposition是MIME协议的扩展，MIME协议指示MIME用户代理如何显示附加的文件。
+        response.setHeader("Content-Disposition", "attachment;filename=" + fileName + ".et");
+        ServletOutputStream outputStream = response.getOutputStream();
+        //将Writer刷新到OutPut
+        writer.flush(outputStream, true);
+        outputStream.close();
+        writer.close();
+    }
+
+
+    /**
+     * 查询监控调阅任务
+     *
+     * @param id 监控调阅任务主键
+     * @return 监控调阅任务
+     */
+    @Override
+    public CoreMonitoringRetrievalTask selectCoreMonitoringRetrievalTaskById(Long id) {
+        return coreMonitoringRetrievalTaskMapper.selectById(id);
+    }
+
+    /**
+     * 查询监控调阅任务列表
+     *
+     * @param CoreMonitoringRetrievalTask 监控调阅任务
+     * @return 监控调阅任务
+     */
+    @Override
+    public List<CoreMonitoringRetrievalTask> selectCoreMonitoringRetrievalTaskList(CoreMonitoringRetrievalTask CoreMonitoringRetrievalTask) {
+        return coreMonitoringRetrievalTaskMapper.selectList(new QueryWrapper<>(CoreMonitoringRetrievalTask));
+    }
+
+    /**
+     * 新增监控调阅任务
+     *
+     * @param CoreMonitoringRetrievalTask 监控调阅任务
+     * @return 结果
+     */
+    @Override
+    public int insertCoreMonitoringRetrievalTask(CoreMonitoringRetrievalTask CoreMonitoringRetrievalTask) {
+            return coreMonitoringRetrievalTaskMapper.insert(CoreMonitoringRetrievalTask);
+    }
+
+    /**
+     * 修改监控调阅任务
+     *
+     * @param CoreMonitoringRetrievalTask 监控调阅任务
+     * @return 结果
+     */
+    @Override
+    public int updateCoreMonitoringRetrievalTask(CoreMonitoringRetrievalTask CoreMonitoringRetrievalTask) {
+        return coreMonitoringRetrievalTaskMapper.updateById(CoreMonitoringRetrievalTask);
+    }
+
+    /**
+     * 批量删除监控调阅任务
+     *
+     * @param ids 需要删除的监控调阅任务主键
+     * @return 结果
+     */
+    @Override
+    public int deleteCoreMonitoringRetrievalTaskByIds(Long[] ids) {
+        return coreMonitoringRetrievalTaskMapper.deleteBatchIds(Arrays.asList((ids)));
+    }
+
+    /**
+     * 删除监控调阅任务信息
+     *
+     * @param id 监控调阅任务主键
+     * @return 结果
+     */
+    @Override
+    public int deleteCoreMonitoringRetrievalTaskById(Long id) {
+        return coreMonitoringRetrievalTaskMapper.deleteById(id);
+    }
+}

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/retrieval/vo/CoreMonitoringRetrievalTaskVo.java

@@ -0,0 +1,170 @@
+package com.xunmei.core.retrieval.vo;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.xunmei.common.core.web.domain.BaseEntity;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+import java.util.Date;
+
+/**
+ * 监控调阅任务对象 core_monitoring_retrieval_task
+ *
+ * @author xunmei
+ * @date 2023-08-25
+ */
+@Data
+@ApiModel(value = "CoreMonitoringRetrievalTask对象", description = "监控调阅任务")
+public class CoreMonitoringRetrievalTaskVo extends BaseEntity {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键
+     */
+    private Long id;
+
+    /**
+     * 计划id
+     */
+    private Long planId;
+
+    /**
+     * 任务名称
+     */
+    @ApiModelProperty(value = "任务名称")
+    private String taskName;
+
+    /**
+     * 调阅机构
+     */
+    private Long orgId;
+
+    /**
+     * 调阅机构
+     */
+    private String orgPath;
+
+    /**
+     * 调阅机构
+     */
+    @ApiModelProperty(value = "调阅机构")
+    private String orgName;
+
+    /**
+     * 年月日
+     */
+    private Date ymdDate;
+
+    /**
+     * 年
+     */
+    private Long ymdYear;
+
+    /**
+     * 半年
+     */
+    private Long ymdHalfyear;
+
+    /**
+     * 季度
+     */
+    private Long ymdQuarter;
+
+    /**
+     * 月
+     */
+    private Long ymdMonth;
+
+    /**
+     * 周
+     */
+    private Long ymdWeek;
+
+    /**
+     * 日
+     */
+    private Long ymdDay;
+
+    /**
+     * 周期无周期、每日、每周、每月、每季度、每半年、每年（0-6）
+     */
+    private Long cycle;
+
+    /**
+     * 开始时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    @ApiModelProperty(value = "开始时间")
+    private Date planStartTime;
+
+    /**
+     * 结束时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    @ApiModelProperty(value = "结束时间")
+    private Date planEndTime;
+
+    /**
+     * 调阅开始时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    @ApiModelProperty(value = "调阅开始时间")
+    private Date startTime;
+
+    /**
+     * 调阅结束时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    @ApiModelProperty(value = "调阅结束时间")
+    private Date endTime;
+
+    /**
+     * 状态
+     */
+    @ApiModelProperty(value = "状态")
+    private Long status;
+
+    /**
+     * 角色id
+     */
+    private Long roleId;
+
+    private String roleName;
+
+    /**
+     * 调阅人
+     */
+    private Long retrievalUser;
+
+    private String retrievalUserName;
+
+    /**
+     * 第几次调阅（根据计划的频次计算的来）
+     */
+    private Long orderNum;
+
+    /**
+     * 批次号（同一计划多频次为一个批次号）
+     */
+    private Long batchNum;
+
+    /**
+     * 提交时间
+     */
+    private Date submitTime;
+
+    /**
+     * 异常数
+     */
+    @ApiModelProperty(value = "异常数")
+    private Long exceptionCount;
+
+
+    private Integer no;
+}

soc-modules/soc-modules-core/src/main/resources/mapper/retrieval/CoreMonitoringRetrievalTaskMapper.xml

@@ -0,0 +1,293 @@
+<?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.xunmei.core.retrieval.mapper.CoreMonitoringRetrievalTaskMapper">
+
+    <resultMap type="com.xunmei.core.retrieval.domain.CoreMonitoringRetrievalTask" id="CoreMonitoringRetrievalTaskResult">
+                <result property="id" column="id"/>
+                <result property="planId" column="plan_id"/>
+                <result property="taskName" column="task_name"/>
+                <result property="orgId" column="org_id"/>
+                <result property="orgPath" column="org_path"/>
+                <result property="orgName" column="org_name"/>
+                <result property="ymdDate" column="ymd_date"/>
+                <result property="ymdYear" column="ymd_year"/>
+                <result property="ymdHalfyear" column="ymd_halfyear"/>
+                <result property="ymdQuarter" column="ymd_quarter"/>
+                <result property="ymdMonth" column="ymd_month"/>
+                <result property="ymdWeek" column="ymd_week"/>
+                <result property="ymdDay" column="ymd_day"/>
+                <result property="cycle" column="cycle"/>
+                <result property="planStartTime" column="plan_start_time"/>
+                <result property="planEndTime" column="plan_end_time"/>
+                <result property="startTime" column="start_time"/>
+                <result property="endTime" column="end_time"/>
+                <result property="status" column="status"/>
+                <result property="roleId" column="role_id"/>
+                <result property="retrievalUser" column="retrieval_user"/>
+                <result property="orderNum" column="order_num"/>
+                <result property="batchNum" column="batch_num"/>
+                <result property="submitTime" column="submit_time"/>
+                <result property="exceptionCount" column="exception_count"/>
+    </resultMap>
+
+    <sql id="selectCoreMonitoringRetrievalTaskVo">
+        select id, plan_id, task_name, org_id, org_path, org_name, ymd_date, ymd_year, ymd_halfyear, ymd_quarter, ymd_month, ymd_week, ymd_day, cycle, plan_start_time, plan_end_time, start_time, end_time, status, role_id, retrieval_user, order_num, batch_num, submit_time, exception_count
+        from core_monitoring_retrieval_task
+    </sql>
+
+    <select id="selectCoreMonitoringRetrievalTaskList" parameterType="com.xunmei.core.retrieval.domain.CoreMonitoringRetrievalTask"
+            resultMap="CoreMonitoringRetrievalTaskResult">
+        <include refid="selectCoreMonitoringRetrievalTaskVo"/>
+        <where>
+                        <if test="taskName != null  and taskName != ''">
+                            and task_name like concat('%', #{taskName}, '%')
+                        </if>
+                        <if test="cycle != null ">
+                            and cycle = #{cycle}
+                        </if>
+                        <if test="planStartTime != null ">
+                            and plan_start_time = #{planStartTime}
+                        </if>
+                        <if test="planEndTime != null ">
+                            and plan_end_time = #{planEndTime}
+                        </if>
+                        <if test="status != null ">
+                            and status = #{status}
+                        </if>
+        </where>
+    </select>
+
+    <select id="selectCoreMonitoringRetrievalTaskById" parameterType="Long"
+            resultMap="CoreMonitoringRetrievalTaskResult">
+            <include refid="selectCoreMonitoringRetrievalTaskVo"/>
+            where id = #{id}
+    </select>
+    <select id="selectPageList" resultType="com.xunmei.core.retrieval.vo.CoreMonitoringRetrievalTaskVo">
+        select a.*,b.name as roleName,c.name as retrievalUserName from core_monitoring_retrieval_task a left join sys_role b on a.role_id = b.id left join sys_user c on a.retrieval_user = c.id
+        where 1=1
+        <if test="request.orgId != null ">
+            and a.org_id = #{request.orgId}
+        </if>
+        <if test="request.orgPath != null  and request.orgPath != ''">
+            and a.org_path = #{request.orgPath}
+        </if>
+        <if test="request.taskName != null  and request.taskName != ''">
+            and a.task_name like concat('%', #{request.taskName}, '%')
+        </if>
+        <if test="request.cycle != null ">
+            and a.cycle = #{request.cycle}
+        </if>
+        <if test="request.dateRange != null and request.dateRange.length>0">
+            and a.ymd_date >= #{request.dateRange[0]}
+            and #{request.dateRange[1]}>=a.ymd_date
+        </if>
+        <if test="request.status != null ">
+            and a.status = #{request.status}
+        </if>
+        <if test="request.roleId != null ">
+            and a.role_id = #{request.roleId}
+        </if>
+        order by a.ymd_date desc
+    </select>
+
+    <insert id="insertCoreMonitoringRetrievalTask" parameterType="com.xunmei.core.retrieval.domain.CoreMonitoringRetrievalTask">
+        insert into core_monitoring_retrieval_task
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+                    <if test="id != null">id,
+                    </if>
+                    <if test="planId != null">plan_id,
+                    </if>
+                    <if test="taskName != null">task_name,
+                    </if>
+                    <if test="orgId != null">org_id,
+                    </if>
+                    <if test="orgPath != null">org_path,
+                    </if>
+                    <if test="orgName != null">org_name,
+                    </if>
+                    <if test="ymdDate != null">ymd_date,
+                    </if>
+                    <if test="ymdYear != null">ymd_year,
+                    </if>
+                    <if test="ymdHalfyear != null">ymd_halfyear,
+                    </if>
+                    <if test="ymdQuarter != null">ymd_quarter,
+                    </if>
+                    <if test="ymdMonth != null">ymd_month,
+                    </if>
+                    <if test="ymdWeek != null">ymd_week,
+                    </if>
+                    <if test="ymdDay != null">ymd_day,
+                    </if>
+                    <if test="cycle != null">cycle,
+                    </if>
+                    <if test="planStartTime != null">plan_start_time,
+                    </if>
+                    <if test="planEndTime != null">plan_end_time,
+                    </if>
+                    <if test="startTime != null">start_time,
+                    </if>
+                    <if test="endTime != null">end_time,
+                    </if>
+                    <if test="status != null">status,
+                    </if>
+                    <if test="roleId != null">role_id,
+                    </if>
+                    <if test="retrievalUser != null">retrieval_user,
+                    </if>
+                    <if test="orderNum != null">order_num,
+                    </if>
+                    <if test="batchNum != null">batch_num,
+                    </if>
+                    <if test="submitTime != null">submit_time,
+                    </if>
+                    <if test="exceptionCount != null">exception_count,
+                    </if>
+        </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+                    <if test="id != null">#{id},
+                    </if>
+                    <if test="planId != null">#{planId},
+                    </if>
+                    <if test="taskName != null">#{taskName},
+                    </if>
+                    <if test="orgId != null">#{orgId},
+                    </if>
+                    <if test="orgPath != null">#{orgPath},
+                    </if>
+                    <if test="orgName != null">#{orgName},
+                    </if>
+                    <if test="ymdDate != null">#{ymdDate},
+                    </if>
+                    <if test="ymdYear != null">#{ymdYear},
+                    </if>
+                    <if test="ymdHalfyear != null">#{ymdHalfyear},
+                    </if>
+                    <if test="ymdQuarter != null">#{ymdQuarter},
+                    </if>
+                    <if test="ymdMonth != null">#{ymdMonth},
+                    </if>
+                    <if test="ymdWeek != null">#{ymdWeek},
+                    </if>
+                    <if test="ymdDay != null">#{ymdDay},
+                    </if>
+                    <if test="cycle != null">#{cycle},
+                    </if>
+                    <if test="planStartTime != null">#{planStartTime},
+                    </if>
+                    <if test="planEndTime != null">#{planEndTime},
+                    </if>
+                    <if test="startTime != null">#{startTime},
+                    </if>
+                    <if test="endTime != null">#{endTime},
+                    </if>
+                    <if test="status != null">#{status},
+                    </if>
+                    <if test="roleId != null">#{roleId},
+                    </if>
+                    <if test="retrievalUser != null">#{retrievalUser},
+                    </if>
+                    <if test="orderNum != null">#{orderNum},
+                    </if>
+                    <if test="batchNum != null">#{batchNum},
+                    </if>
+                    <if test="submitTime != null">#{submitTime},
+                    </if>
+                    <if test="exceptionCount != null">#{exceptionCount},
+                    </if>
+        </trim>
+    </insert>
+
+    <update id="updateCoreMonitoringRetrievalTask" parameterType="com.xunmei.core.retrieval.domain.CoreMonitoringRetrievalTask">
+        update core_monitoring_retrieval_task
+        <trim prefix="SET" suffixOverrides=",">
+                    <if test="planId != null">plan_id =
+                        #{planId},
+                    </if>
+                    <if test="taskName != null">task_name =
+                        #{taskName},
+                    </if>
+                    <if test="orgId != null">org_id =
+                        #{orgId},
+                    </if>
+                    <if test="orgPath != null">org_path =
+                        #{orgPath},
+                    </if>
+                    <if test="orgName != null">org_name =
+                        #{orgName},
+                    </if>
+                    <if test="ymdDate != null">ymd_date =
+                        #{ymdDate},
+                    </if>
+                    <if test="ymdYear != null">ymd_year =
+                        #{ymdYear},
+                    </if>
+                    <if test="ymdHalfyear != null">ymd_halfyear =
+                        #{ymdHalfyear},
+                    </if>
+                    <if test="ymdQuarter != null">ymd_quarter =
+                        #{ymdQuarter},
+                    </if>
+                    <if test="ymdMonth != null">ymd_month =
+                        #{ymdMonth},
+                    </if>
+                    <if test="ymdWeek != null">ymd_week =
+                        #{ymdWeek},
+                    </if>
+                    <if test="ymdDay != null">ymd_day =
+                        #{ymdDay},
+                    </if>
+                    <if test="cycle != null">cycle =
+                        #{cycle},
+                    </if>
+                    <if test="planStartTime != null">plan_start_time =
+                        #{planStartTime},
+                    </if>
+                    <if test="planEndTime != null">plan_end_time =
+                        #{planEndTime},
+                    </if>
+                    <if test="startTime != null">start_time =
+                        #{startTime},
+                    </if>
+                    <if test="endTime != null">end_time =
+                        #{endTime},
+                    </if>
+                    <if test="status != null">status =
+                        #{status},
+                    </if>
+                    <if test="roleId != null">role_id =
+                        #{roleId},
+                    </if>
+                    <if test="retrievalUser != null">retrieval_user =
+                        #{retrievalUser},
+                    </if>
+                    <if test="orderNum != null">order_num =
+                        #{orderNum},
+                    </if>
+                    <if test="batchNum != null">batch_num =
+                        #{batchNum},
+                    </if>
+                    <if test="submitTime != null">submit_time =
+                        #{submitTime},
+                    </if>
+                    <if test="exceptionCount != null">exception_count =
+                        #{exceptionCount},
+                    </if>
+        </trim>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteCoreMonitoringRetrievalTaskById" parameterType="Long">
+        delete
+        from core_monitoring_retrieval_task where id = #{id}
+    </delete>
+
+    <delete id="deleteCoreMonitoringRetrievalTaskByIds" parameterType="String">
+        delete from core_monitoring_retrieval_task where id in
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+</mapper>