package com.ruoyi.require.task;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.ruoyi.require.mapper.CollectLaboratoryMapper;
|
import com.ruoyi.require.mapper.CollectTemperatureHumidityMapper;
|
import com.ruoyi.require.mapper.FeTempHumDateMapper;
|
import com.ruoyi.require.mapper.FeTempHumRecordMapper;
|
import com.ruoyi.require.pojo.CollectLaboratory;
|
import com.ruoyi.require.pojo.CollectTemperatureHumidity;
|
import com.ruoyi.require.pojo.FeTempHumDate;
|
import com.ruoyi.require.pojo.FeTempHumRecord;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.lang.reflect.Field;
|
import java.text.SimpleDateFormat;
|
import java.time.LocalDate;
|
import java.time.LocalTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.Calendar;
|
import java.util.List;
|
|
/**
|
* Author: yuan
|
* Date: 2024-12-19 星期四 8:33:56
|
* Description:
|
*/
|
@Component
|
public class FeTempHumDateSchedule {
|
|
@Autowired
|
private CollectLaboratoryMapper collectLaboratoryMapper;
|
@Autowired
|
private FeTempHumDateMapper feTempHumDateMapper;
|
@Autowired
|
private CollectTemperatureHumidityMapper collectTemperatureHumidityMapper;
|
@Autowired
|
private FeTempHumRecordMapper feTempHumRecordMapper;
|
|
// 获取当前年份和月份 如：2024-11
|
private final SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM");
|
private String formattedDate = sdf.format(Calendar.getInstance().getTime());
|
|
/**
|
* 检查实验室是否有任务
|
*/
|
public synchronized void checkLaboratoriesSchedule() {
|
// 获取当前年份和月份 如：2024-11
|
formattedDate = sdf.format(Calendar.getInstance().getTime());
|
// 查询所有的实验室
|
List<CollectLaboratory> collectLaboratories = collectLaboratoryMapper.selectList(null);
|
// 遍历实验室，判断任务列表中是否存该实验室的任务
|
for (CollectLaboratory collectLaboratory : collectLaboratories) {
|
// 查询数据库中是否存在该实验室的任务
|
int count = feTempHumDateMapper.selectFeTempHumDateIncludeFormattedDate(collectLaboratory.getLaboratory(), formattedDate);
|
// 查询结果为0，说明数据库中不存在该实验室的任务，需要新增
|
if (count == 0) {
|
FeTempHumDate feTempHumDate = new FeTempHumDate();
|
feTempHumDate.setMonthDate(formattedDate);
|
feTempHumDate.setTestAreaName(collectLaboratory.getLaboratory());
|
feTempHumDateMapper.insert(feTempHumDate);
|
}
|
}
|
}
|
|
/**
|
* 每天9点执行一次 除了星期天
|
* 获取温度湿度
|
*/
|
// @Scheduled(cron = "0/5 * * * * *")
|
@Scheduled(cron = "0 0 9 * * 1-6") // 每天9点执行一次 除了星期天
|
public void task1() {
|
checkLaboratoriesSchedule();
|
// 根据时间降序，获取到最新的一条数据
|
CollectTemperatureHumidity collectTemperatureHumidity = collectTemperatureHumidityMapper.selectOne(Wrappers.<CollectTemperatureHumidity>lambdaQuery()
|
.orderByDesc(CollectTemperatureHumidity::getCollectTime)
|
.last("limit 1"));
|
|
// 获取所有的实验室
|
List<CollectLaboratory> collectLaboratories = collectLaboratoryMapper.selectList(null);
|
// 遍历获取实验室编号 获取温湿度 保存在对应的
|
for (CollectLaboratory collectLaboratory : collectLaboratories) {
|
// 实验室编号
|
int labNumber = Integer.parseInt(collectLaboratory.getDeviceCode());
|
// 根据实验室编号拼接对应的湿度和温度字段
|
String temperatureField = "code" + labNumber + "Temperature";
|
String humidityField = "code" + labNumber + "Humidity";
|
// 获取温度
|
Double temperature = getFieldValue(collectTemperatureHumidity, temperatureField) != null ? (Double) getFieldValue(collectTemperatureHumidity, temperatureField) : Double.valueOf(00.0);
|
// 获取湿度
|
Double humidity = getFieldValue(collectTemperatureHumidity, humidityField) != null ? (Double) getFieldValue(collectTemperatureHumidity, humidityField) : Double.valueOf(00.0);
|
// 查询试验区域
|
FeTempHumDate feTempHumDate = feTempHumDateMapper.selectOne(Wrappers.<FeTempHumDate>lambdaQuery()
|
.eq(FeTempHumDate::getMonthDate, formattedDate)
|
.eq(FeTempHumDate::getTestAreaName, collectLaboratory.getLaboratory())
|
.orderByDesc(FeTempHumDate::getCreateTime)
|
.last("limit 1"));
|
Integer dateId = feTempHumDate.getDateId();
|
// 判断今天是否有温湿度记录
|
FeTempHumRecord feTempHumRecord = record(dateId);
|
// 查询出来就代表今天记录过了就不记录
|
if (feTempHumRecord != null) {
|
// 有温度湿度记录就不记录
|
continue;
|
}
|
|
// 创建今天温湿度记录对象 记录上午温度湿度
|
FeTempHumRecord newFeTempHumRecord = new FeTempHumRecord();
|
newFeTempHumRecord.setRecordDate(LocalDate.now());
|
newFeTempHumRecord.setMorningTestTime(LocalTime.now());
|
newFeTempHumRecord.setMorningTemp(temperature.toString());
|
newFeTempHumRecord.setMorningHum(humidity.toString());
|
newFeTempHumRecord.setDateId(dateId);
|
feTempHumRecordMapper.insert(newFeTempHumRecord);
|
}
|
}
|
|
/**
|
* 判断今天是否有温湿度记录
|
*/
|
private FeTempHumRecord record(Integer dateId) {
|
// 获取今天的日期
|
LocalDate today = LocalDate.now();
|
DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("HH:mm:ss");
|
// 获取今天的 00:00:00 和 23:59:59
|
String start = today.atStartOfDay().format(dateTimeFormatter); // 00:00:00
|
String end = today.atTime(LocalTime.MAX).format(dateTimeFormatter); // 23:59:59
|
// 查询今天是否有温湿度记录
|
return feTempHumRecordMapper.selectOne(Wrappers.<FeTempHumRecord>lambdaQuery()
|
// 哪个实验室
|
.eq(FeTempHumRecord::getDateId, dateId)
|
// 记录时间在今天之内
|
.eq(FeTempHumRecord::getRecordDate, today)
|
.between(FeTempHumRecord::getMorningTestTime, start, end)
|
.orderByDesc(FeTempHumRecord::getTempHumId)
|
.last("limit 1"));
|
}
|
|
/**
|
* 每天14点执行一次 除了星期六和星期天
|
* 获取温度湿度
|
*/
|
// @Scheduled(cron = "0/5 * * * * *")
|
@Scheduled(cron = "0 0 14 * * 1-5") // 每天14点执行一次 除了星期六和星期天
|
public void task2() {
|
|
// 检查实验室是否有任务 如果没有新增任务
|
checkLaboratoriesSchedule();
|
// 根据时间降序，获取到最新的一条数据
|
CollectTemperatureHumidity collectTemperatureHumidity = collectTemperatureHumidityMapper.selectOne(Wrappers.<CollectTemperatureHumidity>lambdaQuery()
|
.orderByDesc(CollectTemperatureHumidity::getCollectTime)
|
.last("limit 1"));
|
// 获取所有的实验室
|
List<CollectLaboratory> collectLaboratories = collectLaboratoryMapper.selectList(null);
|
// 遍历获取实验室编号 获取温湿度 保存在对应的
|
for (CollectLaboratory collectLaboratory : collectLaboratories) {
|
// 实验室编号
|
int labNumber = Integer.parseInt(collectLaboratory.getDeviceCode());
|
// 根据实验室编号拼接对应的湿度和温度字段
|
String temperatureField = "code" + labNumber + "Temperature";
|
String humidityField = "code" + labNumber + "Humidity";
|
// 获取温度
|
Double temperature = getFieldValue(collectTemperatureHumidity, temperatureField) != null ? (Double) getFieldValue(collectTemperatureHumidity, temperatureField) : Double.valueOf(00.0);
|
// 获取湿度
|
Double humidity = getFieldValue(collectTemperatureHumidity, humidityField) != null ? (Double) getFieldValue(collectTemperatureHumidity, humidityField) : Double.valueOf(00.0);
|
// 查询试验区域
|
FeTempHumDate feTempHumDate = feTempHumDateMapper.selectOne(Wrappers.<FeTempHumDate>lambdaQuery()
|
.eq(FeTempHumDate::getMonthDate, formattedDate)
|
.eq(FeTempHumDate::getTestAreaName, collectLaboratory.getLaboratory())
|
.orderByDesc(FeTempHumDate::getCreateTime)
|
.last("limit 1"));
|
Integer dateId = feTempHumDate.getDateId();
|
// 查询今天是否有温湿度记录
|
FeTempHumRecord feTempHumRecord = record(dateId);
|
// 如果没有查询结果就说明上午没有记录
|
if (feTempHumRecord == null) {
|
// 创建今天温湿度记录对象 记录下午温度湿度
|
FeTempHumRecord newFeTempHumRecord = new FeTempHumRecord();
|
newFeTempHumRecord.setAfternoonTime(LocalTime.now());
|
newFeTempHumRecord.setAfternoonTemp(temperature.toString());
|
newFeTempHumRecord.setAfternoonHum(humidity.toString());
|
newFeTempHumRecord.setDateId(dateId);
|
feTempHumRecordMapper.insert(newFeTempHumRecord);
|
continue;
|
}
|
|
// 查询出来就代表今天记录过 再判断下午有记录过没有
|
// 温度是否记录过
|
if (feTempHumRecord.getAfternoonTemp() == null) {
|
// 没有就自动记录
|
feTempHumRecord.setAfternoonTemp(temperature.toString());
|
// 修改记录时间
|
feTempHumRecord.setAfternoonTime(LocalTime.now());
|
}
|
// 湿度是否记录过
|
if (feTempHumRecord.getAfternoonHum() == null) {
|
// 没有就自动记录
|
feTempHumRecord.setAfternoonHum(humidity.toString());
|
// 修改记录时间
|
feTempHumRecord.setAfternoonTime(LocalTime.now());
|
}
|
feTempHumRecordMapper.updateById(feTempHumRecord);
|
|
}
|
}
|
|
/**
|
* 星期天执行添加空白数据
|
* 获取温度湿度
|
*/
|
// @Scheduled(cron = "0/5 * * * * *")
|
@Scheduled(cron = "0 0 9 * * 7") //
|
public void task3() {
|
checkLaboratoriesSchedule();
|
|
// 获取所有的实验室
|
List<CollectLaboratory> collectLaboratories = collectLaboratoryMapper.selectList(null);
|
// 遍历获取实验室编号 获取温湿度 保存在对应的
|
for (CollectLaboratory collectLaboratory : collectLaboratories) {
|
// 查询试验区域
|
FeTempHumDate feTempHumDate = feTempHumDateMapper.selectOne(Wrappers.<FeTempHumDate>lambdaQuery()
|
.eq(FeTempHumDate::getMonthDate, formattedDate)
|
.eq(FeTempHumDate::getTestAreaName, collectLaboratory.getLaboratory())
|
.orderByDesc(FeTempHumDate::getCreateTime)
|
.last("limit 1"));
|
Integer dateId = feTempHumDate.getDateId();
|
// 判断今天是否有温湿度记录
|
// 获取今天的日期
|
LocalDate today = LocalDate.now();
|
// 查询今天是否有温湿度记录
|
Long count = feTempHumRecordMapper.selectCount(Wrappers.<FeTempHumRecord>lambdaQuery()
|
// 哪个实验室
|
.eq(FeTempHumRecord::getDateId, dateId)
|
// 记录时间在今天之内
|
.eq(FeTempHumRecord::getRecordDate, today));
|
// 查询出来就代表今天记录过了就不记录
|
if (!count.equals(0L)) {
|
// 有温度湿度记录就不记录
|
continue;
|
}
|
|
// 创建今天温湿度记录对象 记录上午温度湿度
|
FeTempHumRecord newFeTempHumRecord = new FeTempHumRecord();
|
newFeTempHumRecord.setRecordDate(LocalDate.now());
|
newFeTempHumRecord.setDateId(dateId);
|
feTempHumRecordMapper.insert(newFeTempHumRecord);
|
}
|
}
|
|
/**
|
* 根据实验室编号获取温度湿度
|
*
|
* @param collectTemperatureHumidity 温度湿度数据
|
* @param fieldName 字段名
|
* @return 字段值
|
*/
|
public static Object getFieldValue(CollectTemperatureHumidity collectTemperatureHumidity, String fieldName) {
|
try {
|
Field field = collectTemperatureHumidity.getClass().getDeclaredField(fieldName);
|
field.setAccessible(true); // 设置可以访问私有字段
|
return field.get(collectTemperatureHumidity); // 获取字段的值
|
} catch (NoSuchFieldException | IllegalAccessException e) {
|
e.printStackTrace();
|
return null;
|
}
|
}
|
}
|
