package com.ruoyi.process.task;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
import com.ruoyi.common.core.domain.entity.User;
|
import com.ruoyi.common.utils.WxCpUtils;
|
import com.ruoyi.process.mapper.QualitySuperviseDetailsMapper;
|
import com.ruoyi.process.pojo.QualitySuperviseDetails;
|
import com.ruoyi.system.mapper.UserMapper;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.List;
|
|
/**
|
* 培训计划使用提醒记录提醒
|
*/
|
@Component
|
public class QualitySuperviseSchedule {
|
@Resource
|
private QualitySuperviseDetailsMapper qualitySuperviseDetailsMapper;
|
@Resource
|
private UserMapper userMapper;
|
@Resource
|
private ThreadPoolTaskExecutor threadPoolTaskExecutor;
|
|
/**
|
* 提醒填写设备使用记录
|
*/
|
// @Scheduled(cron = "0/5 * * * * *")
|
// @Scheduled(cron = "0 0 9 1 * *") // 每月1号执行
|
public void task1() {
|
// 查询当月监督计划
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy.M");
|
String format = LocalDateTime.now().format(formatter);
|
List<QualitySuperviseDetails> qualitySuperviseDetails = qualitySuperviseDetailsMapper.selectList(Wrappers.<QualitySuperviseDetails>lambdaQuery()
|
.eq(QualitySuperviseDetails::getSuperviseTime, format));
|
|
for (QualitySuperviseDetails qualitySuperviseDetail : qualitySuperviseDetails) {
|
threadPoolTaskExecutor.execute(() -> {
|
// 查询被监督人信息
|
User user = userMapper.selectById(qualitySuperviseDetail.getSupervisedUserId());
|
// 企业微信通知培训
|
String message = "";
|
message += "质量监督计划提醒通知";
|
message += "\n监督日期: " + qualitySuperviseDetail.getSuperviseTime();
|
message += "\n监督目的: " + qualitySuperviseDetail.getSupervisePurpose();
|
message += "\n监督项目: " + qualitySuperviseDetail.getSuperviseProject();
|
message += "\n被监督人: " + qualitySuperviseDetail.getSupervisee();
|
message += "\n计划当月进行监督计划";
|
|
//发送企业微信消息通知
|
try {
|
WxCpUtils.inform(user.getAccount(), message, null);
|
} catch (Exception e) {
|
throw new RuntimeException(e);
|
}
|
});
|
}
|
}
|
|
}
|
