增加定时任务1.每个月清理一次已读数据2.每15分钟刷新培训计划状态

zss

昨天 1a4f300568a44f17153fb405efdee6baccb64869

增加定时任务1.每个月清理一次已读数据2.每15分钟刷新培训计划状态

 src/main/java/com/ruoyi/ScheduleTask.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,58 @@
package com.ruoyi;

import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.ruoyi.project.system.domain.SysNotice;
import com.ruoyi.project.system.mapper.SysNoticeMapper;
import com.ruoyi.safe.mapper.SafeTrainingMapper;
import com.ruoyi.safe.pojo.SafeTraining;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.List;

@Component
//定时任务汇总
public class ScheduleTask {

    @Autowired
    private SafeTrainingMapper safeTrainingMapper;

    @Autowired
    private SysNoticeMapper noticeMapper;

    //定时任务(15分钟执行一次--判断培训计划数据,状态做变更)
    @Scheduled(cron = "0 0/15 * * * ?")
    public void testScheduleTask() {
        List<SafeTraining> safeTrainings = safeTrainingMapper.selectList(Wrappers.<SafeTraining>lambdaQuery().ne(SafeTraining::getState, 2));
        if (safeTrainings.size() > 0) {
            for (SafeTraining safeTraining : safeTrainings) {
                //根据时间判断培训状态
                String trainingDate = safeTraining.getTrainingDate().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
                LocalDateTime openingTime = LocalDateTime.parse((trainingDate + safeTraining.getOpeningTime()), DateTimeFormatter.ofPattern("yyyy-MM-ddHH:mm:ss"));
                LocalDateTime endTime = LocalDateTime.parse((trainingDate + safeTraining.getEndTime()), DateTimeFormatter.ofPattern("yyyy-MM-ddHH:mm:ss"));
                if (LocalDateTime.now().isBefore(openingTime)) {
                    //未开始
                    safeTraining.setState(0);
                } else if (LocalDateTime.now().isAfter(endTime)) {
                    //已结束
                    safeTraining.setState(2);
                } else {
                    //进行中
                    safeTraining.setState(1);
                }
                safeTrainingMapper.updateById(safeTraining);
            }
        }
    }

    //已读数据做一个定时任务(每月1号1点清理一次上个月已读数据)
    @Scheduled(cron = "0 0 1 1 * ?")
    public void cleanReadData() {
        noticeMapper.delete(Wrappers.<SysNotice>lambdaQuery()
                .eq(SysNotice::getStatus,"1")
                .lt(SysNotice::getCreateTime, LocalDateTime.now()));
    }
}

 src/main/java/com/ruoyi/project/system/mapper/SysDeptMapper.java

@@ -1,19 +1,22 @@
package com.ruoyi.project.system.mapper;



import java.util.List;



import org.apache.ibatis.annotations.Mapper;

import org.apache.ibatis.annotations.Param;

import com.ruoyi.project.system.domain.SysDept;



/**

 * éƒ¨é—¨ç®¡ç† æ•°æ®å±‚

 * 
 *

 * @author ruoyi

 */

@Mapper

public interface SysDeptMapper

{

    /**

     * æŸ¥è¯¢éƒ¨é—¨ç®¡ç†æ•°æ®

     * 
     *

     * @param dept éƒ¨é—¨ä¿¡æ¯

     * @return éƒ¨é—¨ä¿¡æ¯é›†åˆ

     */

@@ -21,7 +24,7 @@


    /**

     * æ ¹æ®è§’色ID查询部门树信息

     * 
     *

     * @param roleId è§’色ID

     * @param deptCheckStrictly éƒ¨é—¨æ ‘选择项是否关联显示

     * @return é€‰ä¸­éƒ¨é—¨åˆ—表

@@ -30,7 +33,7 @@


    /**

     * æ ¹æ®éƒ¨é—¨ID查询信息

     * 
     *

     * @param deptId éƒ¨é—¨ID

     * @return éƒ¨é—¨ä¿¡æ¯

     */

@@ -38,7 +41,7 @@


    /**

     * æ ¹æ®ID查询所有子部门

     * 
     *

     * @param deptId éƒ¨é—¨ID

     * @return éƒ¨é—¨åˆ—表

     */

@@ -46,7 +49,7 @@


    /**

     * æ ¹æ®ID查询所有子部门（正常状态）

     * 
     *

     * @param deptId éƒ¨é—¨ID

     * @return å­éƒ¨é—¨æ•°

     */

@@ -54,7 +57,7 @@


    /**

     * æ˜¯å¦å­˜åœ¨å­èŠ‚点

     * 
     *

     * @param deptId éƒ¨é—¨ID

     * @return ç»“æžœ

     */

@@ -62,7 +65,7 @@


    /**

     * æŸ¥è¯¢éƒ¨é—¨æ˜¯å¦å­˜åœ¨ç”¨æˆ·

     * 
     *

     * @param deptId éƒ¨é—¨ID

     * @return ç»“æžœ

     */

@@ -70,7 +73,7 @@


    /**

     * æ ¡éªŒéƒ¨é—¨åç§°æ˜¯å¦å”¯ä¸€

     * 
     *

     * @param deptName éƒ¨é—¨åç§°

     * @param parentId çˆ¶éƒ¨é—¨ID

     * @return ç»“æžœ

@@ -79,7 +82,7 @@


    /**

     * æ–°å¢žéƒ¨é—¨ä¿¡æ¯

     * 
     *

     * @param dept éƒ¨é—¨ä¿¡æ¯

     * @return ç»“æžœ

     */

@@ -87,7 +90,7 @@


    /**

     * ä¿®æ”¹éƒ¨é—¨ä¿¡æ¯

     * 
     *

     * @param dept éƒ¨é—¨ä¿¡æ¯

     * @return ç»“æžœ

     */

@@ -95,14 +98,14 @@


    /**

     * ä¿®æ”¹æ‰€åœ¨éƒ¨é—¨æ­£å¸¸çŠ¶æ€

     * 
     *

     * @param deptIds éƒ¨é—¨ID组

     */

    public void updateDeptStatusNormal(Long[] deptIds);



    /**

     * ä¿®æ”¹å­å…ƒç´ å…³ç³»

     * 
     *

     * @param depts å­å…ƒç´ 

     * @return ç»“æžœ

     */

@@ -110,7 +113,7 @@


    /**

     * åˆ é™¤éƒ¨é—¨ç®¡ç†ä¿¡æ¯

     * 
     *

     * @param deptId éƒ¨é—¨ID

     * @return ç»“æžœ

     */


 src/main/java/com/ruoyi/project/system/service/impl/SysNoticeServiceImpl.java

@@ -1,5 +1,6 @@
package com.ruoyi.project.system.service.impl;



import java.time.LocalDateTime;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

@@ -22,6 +23,7 @@
import com.ruoyi.project.system.mapper.SysUserMapper;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.context.annotation.Lazy;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Service;

import com.ruoyi.project.system.domain.SysNotice;

import com.ruoyi.project.system.mapper.SysNoticeMapper;

@@ -210,4 +212,5 @@
        sysNotice.setTenantId(tenantId);

        return sysNotice;

    }



}


 src/main/java/com/ruoyi/safe/service/impl/SafeTrainingServiceImpl.java

@@ -10,6 +10,7 @@
import com.ruoyi.common.utils.HackLoopTableRenderPolicy;
import com.ruoyi.production.pojo.ProductOrder;
import com.ruoyi.production.pojo.ProductWorkOrder;
import com.ruoyi.project.system.domain.SysNotice;
import com.ruoyi.safe.dto.SafeTrainingDetailsDto;
import com.ruoyi.safe.dto.SafeTrainingDto;
import com.ruoyi.safe.mapper.SafeTrainingDetailsMapper;
@@ -21,15 +22,20 @@
import com.ruoyi.safe.service.SafeTrainingService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import javax.servlet.http.HttpServletResponse;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URLEncoder;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.Date;
import java.util.HashMap;
import java.util.List;

@@ -106,12 +112,12 @@
    @Override
    public SafeTrainingDto getSafeTraining(Long id) {
        //主表数据
        SafeTrainingDto safeTrainingDto=safeTrainingMapper.getSafeTraining(id);
        SafeTrainingDto safeTrainingDto = safeTrainingMapper.getSafeTraining(id);
        //附件
        List<SafeTrainingFile> safeTrainingFiles = safeTrainingFileMapper.selectList(Wrappers.<SafeTrainingFile>lambdaQuery().eq(SafeTrainingFile::getSafeTrainingId, id));
        safeTrainingDto.setSafeTrainingFileList(safeTrainingFiles);
        //培训记录详情
        List<SafeTrainingDetailsDto> safeTrainingDetailsDto=safeTrainingDetailsMapper.getSafeTraining(id);
        List<SafeTrainingDetailsDto> safeTrainingDetailsDto = safeTrainingDetailsMapper.getSafeTraining(id);
        safeTrainingDto.setSafeTrainingDetailsDtoList(safeTrainingDetailsDto);
        return safeTrainingDto;
    }
@@ -132,16 +138,16 @@
        //删除主表
        safeTrainingMapper.deleteBatchIds(ids);
        //删除附件
        safeTrainingFileMapper.delete(Wrappers.<SafeTrainingFile>lambdaQuery().in(SafeTrainingFile::getSafeTrainingId,ids));
        safeTrainingFileMapper.delete(Wrappers.<SafeTrainingFile>lambdaQuery().in(SafeTrainingFile::getSafeTrainingId, ids));
        //删除培训记录
        safeTrainingDetailsMapper.delete(Wrappers.<SafeTrainingDetails>lambdaQuery().in(SafeTrainingDetails::getSafeTrainingId,ids));
        safeTrainingDetailsMapper.delete(Wrappers.<SafeTrainingDetails>lambdaQuery().in(SafeTrainingDetails::getSafeTrainingId, ids));
        return 0;
    }

    @Override
    public void export(HttpServletResponse response, Long id) {
        SafeTrainingDto safeTrainingDto = safeTrainingMapper.getSafeTraining(id);
        List<SafeTrainingDetailsDto> safeTrainingDetailsDtoList=safeTrainingDetailsMapper.getSafeTraining(id);
        List<SafeTrainingDetailsDto> safeTrainingDetailsDtoList = safeTrainingDetailsMapper.getSafeTraining(id);
        InputStream inputStream = this.getClass().getResourceAsStream("/static/safe-training.docx");
        Configure configure = Configure.builder()
                .bind("safeTrainingDetailsDtoList", new HackLoopTableRenderPolicy())
@@ -155,7 +161,7 @@
        try {
            response.setContentType("application/msword");
            String fileName = URLEncoder.encode(
                    safeTrainingDto.getCourseCode()+"培训与考核计划", "UTF-8");
                    safeTrainingDto.getCourseCode() + "培训与考核计划", "UTF-8");
            response.setHeader("Access-Control-Expose-Headers", "Content-Disposition");
            response.setHeader("Content-disposition",
                    "attachment;filename=" + fileName + ".docx");