lius
2023-08-05 7cb1edced371099f4fa55f0645d9223e7f04e66e
定时任务功能维护
已添加8个文件
已修改4个文件
480 ■■■■■ 文件已修改
lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/job/GenerateWeekDaysJob.java 26 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/job/RunningAllEquipmentShiftStatisticalProcessJob.java 27 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/job/RunningAllEquipmentStatisticalProcessJob.java 27 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/job/RunningAllEquipmentTraceProcessJob.java 26 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/controller/SysQuartzLogController.java 61 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/dto/SysQuartzLogDto.java 35 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/entity/SysQuartzLog.java 77 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/mapper/SysQuartzLogMapper.java 23 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/mapper/xml/SysQuartzLogMapper.xml 68 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/service/ISysQuartzLogService.java 36 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/service/impl/SysQuartzLogServiceImpl.java 50 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/vo/SysQuartzLogVo.java 24 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/job/GenerateWeekDaysJob.java
@@ -3,11 +3,16 @@
import lombok.extern.slf4j.Slf4j;
import org.jeecg.common.util.DateUtils;
import org.jeecg.modules.mdc.service.IMdcVacationManagementService;
import org.jeecg.modules.quartz.entity.QuartzJob;
import org.jeecg.modules.quartz.entity.SysQuartzLog;
import org.jeecg.modules.quartz.service.IQuartzJobService;
import org.jeecg.modules.quartz.service.ISysQuartzLogService;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import javax.annotation.Resource;
import java.util.List;
/**
 * ç”ŸæˆåŒä¼‘日定时任务
@@ -21,15 +26,30 @@
    @Resource
    private IMdcVacationManagementService mdcVacationManagementService;
    @Resource
    private ISysQuartzLogService sysQuartzLogService;
    @Resource
    private IQuartzJobService quartzJobService;
    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        SysQuartzLog quartzLog = new SysQuartzLog();
        List<QuartzJob> byJobClassName = this.quartzJobService.findByJobClassName(this.getClass().getName());
        if (byJobClassName != null && !byJobClassName.isEmpty()) {
            quartzLog.setJobId(byJobClassName.get(0).getId());
        }
        log.info("定时生成双休日任务 GenerateWeekDaysJob start!  æ—¶é—´:" + DateUtils.now());
        long startTime = System.currentTimeMillis();
        try {
            mdcVacationManagementService.generateWeekDays();
            log.info("定时生成双休日任务 GenerateWeekDaysJob æ‰§è¡ŒæˆåŠŸ!");
            quartzLog.setIsSuccess(0);
        } catch (Exception e) {
            log.error("定时生成双休日任务 GenerateWeekDaysJob æ‰§è¡Œå¤±è´¥!");
            log.error(e.getMessage(), e);
            quartzLog.setIsSuccess(-1);
            quartzLog.setExceptionDetail(e.toString());
        }
        long endTime = System.currentTimeMillis();
        quartzLog.setExecutionTime(Integer.parseInt(String.valueOf(endTime - startTime)));
        sysQuartzLogService.save(quartzLog);
    }
}
lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/job/RunningAllEquipmentShiftStatisticalProcessJob.java
@@ -3,9 +3,14 @@
import lombok.extern.slf4j.Slf4j;
import org.jeecg.common.util.DateUtils;
import org.jeecg.modules.mdc.service.IMdcEquipmentStatisticalShiftInfoService;
import org.jeecg.modules.quartz.entity.QuartzJob;
import org.jeecg.modules.quartz.entity.SysQuartzLog;
import org.jeecg.modules.quartz.service.IQuartzJobService;
import org.jeecg.modules.quartz.service.ISysQuartzLogService;
import org.quartz.*;
import javax.annotation.Resource;
import java.util.List;
/**
 * @Description: å®šæ—¶ç»Ÿè®¡å•日班次数据任务
@@ -29,15 +34,31 @@
    @Resource
    private IMdcEquipmentStatisticalShiftInfoService mdcEquipmentStatisticalShiftInfoService;
    @Resource
    private ISysQuartzLogService sysQuartzLogService;
    @Resource
    private IQuartzJobService quartzJobService;
    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        SysQuartzLog quartzLog = new SysQuartzLog();
        List<QuartzJob> byJobClassName = this.quartzJobService.findByJobClassName(this.getClass().getName());
        if (byJobClassName != null && !byJobClassName.isEmpty()) {
            quartzLog.setJobId(byJobClassName.get(0).getId());
        }
        quartzLog.setParams(this.parameter);
        log.info(String.format("定时统计单日班次数据任务 param: %s RunningAllEquipmentShiftStatisticalProcessJob start!  æ—¶é—´:" + DateUtils.now(), this.parameter));
        long startTime = System.currentTimeMillis();
        try {
            mdcEquipmentStatisticalShiftInfoService.runningAllEquipmentShiftStatisticalProcess(this.parameter);
            log.info("定时统计单日班次数据任务 RunningAllEquipmentShiftStatisticalProcessJob æ‰§è¡ŒæˆåŠŸ!");
            quartzLog.setIsSuccess(0);
        } catch (Exception e) {
            log.error("定时统计单日班次数据任务 RunningAllEquipmentShiftStatisticalProcessJob æ‰§è¡Œå¤±è´¥!");
            log.error(e.getMessage(), e);
            quartzLog.setIsSuccess(-1);
            quartzLog.setExceptionDetail(e.toString());
        }
        long endTime = System.currentTimeMillis();
        quartzLog.setExecutionTime(Integer.parseInt(String.valueOf(endTime - startTime)));
        sysQuartzLogService.save(quartzLog);
    }
}
lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/job/RunningAllEquipmentStatisticalProcessJob.java
@@ -3,9 +3,14 @@
import lombok.extern.slf4j.Slf4j;
import org.jeecg.common.util.DateUtils;
import org.jeecg.modules.mdc.service.IMdcEquipmentStatisticalInfoService;
import org.jeecg.modules.quartz.entity.QuartzJob;
import org.jeecg.modules.quartz.entity.SysQuartzLog;
import org.jeecg.modules.quartz.service.IQuartzJobService;
import org.jeecg.modules.quartz.service.ISysQuartzLogService;
import org.quartz.*;
import javax.annotation.Resource;
import java.util.List;
/**
 * @Description: å®šæ—¶ç»Ÿè®¡å•日数据任务
@@ -29,15 +34,31 @@
    @Resource
    private IMdcEquipmentStatisticalInfoService mdcEquipmentStatisticalInfoService;
    @Resource
    private ISysQuartzLogService sysQuartzLogService;
    @Resource
    private IQuartzJobService quartzJobService;
    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        SysQuartzLog quartzLog = new SysQuartzLog();
        List<QuartzJob> byJobClassName = this.quartzJobService.findByJobClassName(this.getClass().getName());
        if (byJobClassName != null && !byJobClassName.isEmpty()) {
            quartzLog.setJobId(byJobClassName.get(0).getId());
        }
        quartzLog.setParams(this.parameter);
        log.info(String.format("定时统计单日数据任务 param: %s RunningAllEquipmentStatisticalProcessJob start!  æ—¶é—´:" + DateUtils.now(), this.parameter));
        long startTime = System.currentTimeMillis();
        try {
            mdcEquipmentStatisticalInfoService.runningAllEquipmentStatisticalProcess(this.parameter);
            log.info("定时统计单日数据任务 RunningAllEquipmentStatisticalProcessJob æ‰§è¡ŒæˆåŠŸ!");
            quartzLog.setIsSuccess(0);
        } catch (Exception e) {
            log.error("定时统计单日数据任务 RunningAllEquipmentStatisticalProcessJob æ‰§è¡Œå¤±è´¥!");
            log.error(e.getMessage(), e);
            quartzLog.setIsSuccess(-1);
            quartzLog.setExceptionDetail(e.toString());
        }
        long endTime = System.currentTimeMillis();
        quartzLog.setExecutionTime(Integer.parseInt(String.valueOf(endTime - startTime)));
        sysQuartzLogService.save(quartzLog);
    }
}
lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/job/RunningAllEquipmentTraceProcessJob.java
@@ -3,9 +3,14 @@
import lombok.extern.slf4j.Slf4j;
import org.jeecg.common.util.DateUtils;
import org.jeecg.modules.mdc.service.IMdcEquipmentRunningSectionService;
import org.jeecg.modules.quartz.entity.QuartzJob;
import org.jeecg.modules.quartz.entity.SysQuartzLog;
import org.jeecg.modules.quartz.service.IQuartzJobService;
import org.jeecg.modules.quartz.service.ISysQuartzLogService;
import org.quartz.*;
import javax.annotation.Resource;
import java.util.List;
/**
 * @Description: å®šæ—¶è®¡ç®—段时间
@@ -20,15 +25,30 @@
    @Resource
    private IMdcEquipmentRunningSectionService mdcEquipmentRunningSectionService;
    @Resource
    private ISysQuartzLogService sysQuartzLogService;
    @Resource
    private IQuartzJobService quartzJobService;
    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        SysQuartzLog quartzLog = new SysQuartzLog();
        List<QuartzJob> byJobClassName = this.quartzJobService.findByJobClassName(this.getClass().getName());
        if (byJobClassName != null && !byJobClassName.isEmpty()) {
            quartzLog.setJobId(byJobClassName.get(0).getId());
        }
        log.info("定时统计段时间任务 RunningAllEquipmentTraceProcessJob start!  æ—¶é—´:" + DateUtils.now());
        long startTime = System.currentTimeMillis();
        try {
            mdcEquipmentRunningSectionService.runningAllEquipmentTraceProcess();
            log.info("定时统计段时间任务 RunningAllEquipmentTraceProcessJob æ‰§è¡ŒæˆåŠŸ!");
            quartzLog.setIsSuccess(0);
        } catch (Exception e) {
            log.error("定时统计段时间任务 RunningAllEquipmentTraceProcessJob æ‰§è¡Œå¤±è´¥!");
            log.error(e.getMessage(), e);
            quartzLog.setIsSuccess(-1);
            quartzLog.setExceptionDetail(e.toString());
        }
        long endTime = System.currentTimeMillis();
        quartzLog.setExecutionTime(Integer.parseInt(String.valueOf(endTime - startTime)));
        sysQuartzLogService.save(quartzLog);
    }
}
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/controller/SysQuartzLogController.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,61 @@
package org.jeecg.modules.quartz.controller;
import com.baomidou.mybatisplus.core.metadata.IPage;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.SecurityUtils;
import org.jeecg.common.api.vo.Result;
import org.jeecg.common.aspect.annotation.AutoLog;
import org.jeecg.common.system.base.controller.JeecgController;
import org.jeecg.common.system.vo.LoginUser;
import org.jeecg.modules.quartz.dto.SysQuartzLogDto;
import org.jeecg.modules.quartz.entity.SysQuartzLog;
import org.jeecg.modules.quartz.service.ISysQuartzLogService;
import org.jeecg.modules.quartz.vo.SysQuartzLogVo;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.ModelAndView;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
/**
 * @Description: å®šæ—¶ä»»åŠ¡æ—¥å¿—
 * @author: LiuS
 * @create: 2023-08-05 14:01
 */
@Slf4j
@Api(tags = "定时任务日志接口")
@RestController
@RequestMapping("/sys/quartzLog")
public class SysQuartzLogController extends JeecgController<SysQuartzLog, ISysQuartzLogService> {
    @Resource
    private ISysQuartzLogService sysQuartzLogService;
    @AutoLog(value = "定时任务日志接口-分页列表查询")
    @ApiOperation(value = "定时任务日志接口-分页列表查询", notes = "定时任务日志接口-分页列表查询")
    @GetMapping(value = "/list")
    public Result<IPage<SysQuartzLogDto>> queryList(SysQuartzLogVo sysQuartzLogVo,
                                                    @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
                                                    @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) {
        if (StringUtils.isBlank(sysQuartzLogVo.getJobId())) {
            return Result.error("任务ID不能为空!");
        }
        IPage<SysQuartzLogDto> result = sysQuartzLogService.pageList(pageNo, pageSize, sysQuartzLogVo);
        return Result.OK(result);
    }
    @AutoLog(value = "定时任务日志接口-导出")
    @ApiOperation(value = "定时任务日志接口-导出", notes = "定时任务日志接口-导出")
    @RequestMapping("/exportXls")
    public ModelAndView exportXls(HttpServletRequest request, SysQuartzLogVo sysQuartzLogVo) {
        return this.sysQuartzLogService.exportXls(sysQuartzLogVo);
    }
}
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/dto/SysQuartzLogDto.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,35 @@
package org.jeecg.modules.quartz.dto;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import org.jeecgframework.poi.excel.annotation.Excel;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
/**
 * @author: LiuS
 * @create: 2023-08-05 14:05
 */
@Data
public class SysQuartzLogDto {
    @Excel(name = "任务类名", width = 40)
    private String jobClassName;
    @Excel(name = "cron表达式", width = 30)
    private String cronExpression;
    @Excel(name = "参数", width = 15)
    private String parameter;
    @Excel(name = "描述", width = 40)
    private String description;
    @Excel(name = "报错信息", width = 50)
    private String exceptionDetail;
    @Excel(name = "成功标志 0成功 -1失败", width = 15)
    private Integer isSuccess;
    @Excel(name = "执行时间", width = 15)
    private Integer executionTime;
    @Excel(name = "创建时间", width = 20, format = "yyyy-MM-dd HH:mm:ss")
    @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private Date createTime;
}
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/entity/SysQuartzLog.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,77 @@
package org.jeecg.modules.quartz.entity;
import java.io.Serializable;
import java.util.Date;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import com.fasterxml.jackson.annotation.JsonFormat;
import org.springframework.format.annotation.DateTimeFormat;
import org.jeecgframework.poi.excel.annotation.Excel;
/**
 * @Description: å®šæ—¶ä»»åŠ¡æ—¥å¿—
 * @Author: Lius
 * @Date: 2023-08-05
 * @Version: V1.0
 */
@Data
@TableName("sys_quartz_log")
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@ApiModel(value = "sys_quartz_log对象", description = "定时任务日志")
public class SysQuartzLog implements Serializable {
    private static final long serialVersionUID = 1804183004277004124L;
    /**
     * id
     */
    @TableId(type = IdType.ASSIGN_ID)
    @ApiModelProperty(value = "id")
    private String id;
    /**
     * ä»»åŠ¡id
     */
    @Excel(name = "任务id", width = 15)
    @ApiModelProperty(value = "任务id")
    private String jobId;
    /**
     * æŠ¥é”™ä¿¡æ¯
     */
    @Excel(name = "报错信息", width = 15)
    @ApiModelProperty(value = "报错信息")
    private String exceptionDetail;
    /**
     * æˆåŠŸæ ‡å¿— 0成功 -1失败
     */
    @Excel(name = "成功标志 0成功 -1失败", width = 15)
    @ApiModelProperty(value = "成功标志 0成功 -1失败")
    private Integer isSuccess;
    /**
     * å‚æ•°
     */
    @Excel(name = "参数", width = 15)
    @ApiModelProperty(value = "参数")
    private String params;
    /**
     * æ‰§è¡Œæ—¶é—´
     */
    @Excel(name = "执行时间", width = 15)
    @ApiModelProperty(value = "执行时间")
    private Integer executionTime;
    /**
     * åˆ›å»ºæ—¶é—´
     */
    @Excel(name = "创建时间", width = 20, format = "yyyy-MM-dd HH:mm:ss")
    @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    @ApiModelProperty(value = "创建时间")
    private Date createTime;
}
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/mapper/SysQuartzLogMapper.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,23 @@
package org.jeecg.modules.quartz.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.apache.ibatis.annotations.Param;
import org.jeecg.modules.quartz.dto.SysQuartzLogDto;
import org.jeecg.modules.quartz.entity.SysQuartzLog;
import org.jeecg.modules.quartz.vo.SysQuartzLogVo;
import java.util.List;
/**
 * @Description: å®šæ—¶ä»»åŠ¡æ—¥å¿—
 * @Author: Lius
 * @Date: 2023-08-05
 * @Version: V1.0
 */
public interface SysQuartzLogMapper extends BaseMapper<SysQuartzLog> {
    IPage<SysQuartzLogDto> pageList(IPage<SysQuartzLogDto> page, @Param("sysQuartzLogVo") SysQuartzLogVo sysQuartzLogVo);
    List<SysQuartzLogDto> list(@Param("sysQuartzLogVo") SysQuartzLogVo sysQuartzLogVo);
}
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/mapper/xml/SysQuartzLogMapper.xml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,68 @@
<?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="org.jeecg.modules.quartz.mapper.SysQuartzLogMapper">
    <!--分页列表查询-->
    <select id="pageList" resultType="org.jeecg.modules.quartz.dto.SysQuartzLogDto">
        SELECT
            t2.job_class_name jobClassName,
            t2.cron_expression cronExpression,
            t1.params params,
            t2.description description,
            t1.exception_detail exceptionDetail,
            t1.is_success isSuccess,
            t1.execution_time executionTime,
            t1.create_time createTime
        FROM
            sys_quartz_log t1
            LEFT JOIN sys_quartz_job t2 ON t1.job_id = t2.id
        <where>
            AND t2.id = #{ sysQuartzLogVo.jobId }
            <if test="sysQuartzLogVo.isSuccess != null">
                AND t1.is_success = #{ sysQuartzLogVo.isSuccess }
            </if>
            <if test="sysQuartzLogVo.startTime != null and sysQuartzLogVo.startTime != '' and sysQuartzLogVo.endTime != null and sysQuartzLogVo.endTime != ''">
                AND t1.create_time BETWEEN #{ sysQuartzLogVo.startTime } AND #{ sysQuartzLogVo.endTime }
            </if>
            <if test="sysQuartzLogVo.jobClassName != null and sysQuartzLogVo.jobClassName != ''">
                AND t2.job_class_name LIKE CONCAT(CONCAT('%',#{ sysQuartzLogVo.jobClassName }),'%')
            </if>
            <if test="sysQuartzLogVo.description != null and sysQuartzLogVo.description != ''">
                AND t2.description LIKE CONCAT(CONCAT('%',#{ sysQuartzLogVo.description }),'%')
            </if>
        </where>
        ORDER BY t1.create_time DESC
    </select>
    <select id="list" resultType="org.jeecg.modules.quartz.dto.SysQuartzLogDto">
        SELECT
            t2.job_class_name jobClassName,
            t2.cron_expression cronExpression,
            t1.params params,
            t2.description description,
            t1.exception_detail exceptionDetail,
            t1.is_success isSuccess,
            t1.execution_time executionTime,
            t1.create_time createTime
        FROM
            sys_quartz_log t1
            LEFT JOIN sys_quartz_job t2 ON t1.job_id = t2.id
            <where>
            AND t2.id = #{ sysQuartzLogVo.jobId }
            <if test="sysQuartzLogVo.isSuccess != null">
                AND t1.is_success = #{ sysQuartzLogVo.isSuccess }
            </if>
            <if test="sysQuartzLogVo.startTime != null and sysQuartzLogVo.startTime != '' and sysQuartzLogVo.endTime != null and sysQuartzLogVo.endTime != ''">
                AND t1.create_time BETWEEN #{ sysQuartzLogVo.startTime } AND #{ sysQuartzLogVo.endTime }
            </if>
            <if test="sysQuartzLogVo.jobClassName != null and sysQuartzLogVo.jobClassName != ''">
                AND t2.job_class_name LIKE CONCAT(CONCAT('%',#{ sysQuartzLogVo.jobClassName }),'%')
            </if>
            <if test="sysQuartzLogVo.description != null and sysQuartzLogVo.description != ''">
                AND t2.description LIKE CONCAT(CONCAT('%',#{ sysQuartzLogVo.description }),'%')
            </if>
        </where>
        ORDER BY t1.create_time DESC
    </select>
</mapper>
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/service/ISysQuartzLogService.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,36 @@
package org.jeecg.modules.quartz.service;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.IService;
import org.jeecg.modules.quartz.dto.SysQuartzLogDto;
import org.jeecg.modules.quartz.entity.SysQuartzLog;
import org.jeecg.modules.quartz.vo.SysQuartzLogVo;
import org.springframework.web.servlet.ModelAndView;
/**
 * @Description: å®šæ—¶ä»»åŠ¡æ—¥å¿—
 * @Author: Lius
 * @Date: 2023-08-05
 * @Version: V1.0
 */
public interface ISysQuartzLogService extends IService<SysQuartzLog> {
    /**
     * åˆ†é¡µåˆ—表
     *
     * @param pageNo
     * @param pageSize
     * @param sysQuartzLogVo
     * @return
     */
    IPage<SysQuartzLogDto> pageList(Integer pageNo, Integer pageSize, SysQuartzLogVo sysQuartzLogVo);
    /**
     * å¯¼å‡º
     *
     * @param sysQuartzLogVo
     * @return
     */
    ModelAndView exportXls(SysQuartzLogVo sysQuartzLogVo);
}
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/service/impl/SysQuartzLogServiceImpl.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,50 @@
package org.jeecg.modules.quartz.service.impl;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.shiro.SecurityUtils;
import org.jeecg.common.system.vo.LoginUser;
import org.jeecg.modules.quartz.dto.SysQuartzLogDto;
import org.jeecg.modules.quartz.entity.SysQuartzLog;
import org.jeecg.modules.quartz.mapper.SysQuartzLogMapper;
import org.jeecg.modules.quartz.service.ISysQuartzLogService;
import org.jeecg.modules.quartz.vo.SysQuartzLogVo;
import org.jeecgframework.poi.excel.def.NormalExcelConstants;
import org.jeecgframework.poi.excel.entity.ExportParams;
import org.jeecgframework.poi.excel.view.JeecgEntityExcelView;
import org.springframework.stereotype.Service;
import org.springframework.web.servlet.ModelAndView;
import java.util.List;
/**
 * @Description: å®šæ—¶ä»»åŠ¡æ—¥å¿—
 * @Author: Lius
 * @Date: 2023-08-05
 * @Version: V1.0
 */
@Service
public class SysQuartzLogServiceImpl extends ServiceImpl<SysQuartzLogMapper, SysQuartzLog> implements ISysQuartzLogService {
    @Override
    public IPage<SysQuartzLogDto> pageList(Integer pageNo, Integer pageSize, SysQuartzLogVo sysQuartzLogVo) {
        IPage<SysQuartzLogDto> page = new Page<>(pageNo, pageSize);
        return this.baseMapper.pageList(page, sysQuartzLogVo);
    }
    @Override
    public ModelAndView exportXls(SysQuartzLogVo sysQuartzLogVo) {
        ModelAndView mv = new ModelAndView(new JeecgEntityExcelView());
        List<SysQuartzLogDto> list = this.baseMapper.list(sysQuartzLogVo);
        // å¯¼å‡ºæ–‡ä»¶åç§°
        mv.addObject(NormalExcelConstants.FILE_NAME, "定时任务日志列表");
        mv.addObject(NormalExcelConstants.CLASS, SysQuartzLogDto.class);
        LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
        mv.addObject(NormalExcelConstants.PARAMS, new ExportParams("定时任务日志列表数据", "导出人:"+user.getRealname(), "导出信息"));
        //update-end---author:wangshuai ---date:20211227  for:[JTC-116]导出人写死了------------
        mv.addObject(NormalExcelConstants.DATA_LIST, list);
        return mv;
    }
}
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/vo/SysQuartzLogVo.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,24 @@
package org.jeecg.modules.quartz.vo;
import lombok.Data;
/**
 * @author: LiuS
 * @create: 2023-08-05 14:07
 */
@Data
public class SysQuartzLogVo {
    private String jobId;
    private Integer isSuccess;
    private String startTime;
    private String endTime;
    private String jobClassName;
    private String description;
}