134 lines
5.3 KiB
Java
134 lines
5.3 KiB
Java
package com.zhgd.xmgl.task;
|
|
|
|
import cn.hutool.core.date.DateUnit;
|
|
import cn.hutool.core.date.DateUtil;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
import com.zhgd.mybatis.Aes;
|
|
import com.zhgd.xmgl.modules.basicdata.entity.Engineering;
|
|
import com.zhgd.xmgl.modules.basicdata.entity.EngineeringMain;
|
|
import com.zhgd.xmgl.modules.basicdata.entity.SystemUser;
|
|
import com.zhgd.xmgl.modules.basicdata.service.IEngineeringMainService;
|
|
import com.zhgd.xmgl.modules.basicdata.service.IEngineeringService;
|
|
import com.zhgd.xmgl.modules.basicdata.service.ISystemUserService;
|
|
import com.zhgd.xmgl.modules.safety.entity.InspectRecord;
|
|
import com.zhgd.xmgl.modules.safety.entity.ProjectSubItem;
|
|
import com.zhgd.xmgl.modules.safety.entity.Remind;
|
|
import com.zhgd.xmgl.modules.safety.service.IInspectRecordService;
|
|
import com.zhgd.xmgl.modules.safety.service.IProjectSubItemService;
|
|
import com.zhgd.xmgl.modules.safety.service.IRemindService;
|
|
import com.zhgd.xmgl.util.SMS;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
import org.springframework.stereotype.Component;
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.Arrays;
|
|
import java.util.Date;
|
|
import java.util.List;
|
|
|
|
/**
|
|
* @description: 视频监控定时任务
|
|
**/
|
|
@Slf4j
|
|
@Component
|
|
public class SlippageTask {
|
|
|
|
@Autowired
|
|
private IProjectSubItemService projectSubItemService;
|
|
|
|
@Autowired
|
|
private IInspectRecordService inspectRecordService;
|
|
|
|
@Autowired
|
|
private IRemindService remindService;
|
|
|
|
@Autowired
|
|
private IEngineeringMainService engineeringMainService;
|
|
|
|
@Autowired
|
|
private IEngineeringService engineeringService;
|
|
|
|
@Autowired
|
|
private ISystemUserService systemUserService;
|
|
|
|
/**
|
|
* 每天凌晨计算项目进度是否逾期、临期
|
|
*/
|
|
@Scheduled(cron = "0 0 1 * * ?")
|
|
private void projectSubItem() {
|
|
List<String> phone = new ArrayList<>();
|
|
String desc = "施工进度逾期";
|
|
List<Integer> states = Arrays.asList(3, 6, 7);
|
|
List<ProjectSubItem> change = new ArrayList<>();
|
|
List<ProjectSubItem> list = projectSubItemService.list();
|
|
list.stream().forEach(l -> {
|
|
if (l.getState() < 3 && DateUtil.between(new Date(), l.getPlanEndTime(), DateUnit.DAY, false) <= 15) {
|
|
l.setState(4);
|
|
change.add(l);
|
|
}
|
|
if (!states.contains(l.getState()) && DateUtil.between(l.getPlanEndTime(), new Date(), DateUnit.DAY, false) > 0) {
|
|
l.setState(5);
|
|
change.add(l);
|
|
saveRemind(1, desc, l.getEngineeringSn(), phone);
|
|
}
|
|
});
|
|
if (change.size() > 0) {
|
|
projectSubItemService.updateBatchById(change);
|
|
}
|
|
if (phone.size() > 0) {
|
|
JSONObject params = new JSONObject();
|
|
params.put("phone", Aes.hzEncrypt(phone.toString()));
|
|
params.put("project", Aes.hzEncrypt("项目管理子系统"));
|
|
params.put("alarm", Aes.hzEncrypt(desc));
|
|
SMS.sendToPhone(params);
|
|
}
|
|
log.info("=========定时修改项目进度状态任务执行成功========");
|
|
}
|
|
|
|
private void saveRemind(Integer type, String desc, String engineeringSn, List<String> phone) {
|
|
Remind remind = new Remind();
|
|
EngineeringMain jsUser = engineeringMainService.getOne(Wrappers.<EngineeringMain>lambdaQuery()
|
|
.eq(EngineeringMain::getEngineeringSn, engineeringSn).eq(EngineeringMain::getType, 1));
|
|
if (jsUser != null) {
|
|
Engineering engineering = engineeringService.getOne(Wrappers.<Engineering>lambdaQuery().eq(Engineering::getEngineeringSn, jsUser.getEngineeringSn()));
|
|
SystemUser manager = systemUserService.getOne(Wrappers.<SystemUser>lambdaQuery().eq(SystemUser::getSn, jsUser.getEnterpriseSn()).eq(SystemUser::getIsManager, true));
|
|
remind.setType(type);
|
|
remind.setRemindDesc(desc);
|
|
remind.setCreateTime(new Date());
|
|
remind.setUserId(manager.getUserId());
|
|
remind.setUserPhone(manager.getUserTel());
|
|
remindService.save(remind);
|
|
if (StringUtils.isNotBlank(manager.getUserTel())) {
|
|
phone.add(manager.getUserTel());
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 每天凌晨计算安全质量临期
|
|
*/
|
|
@Scheduled(cron = "0 0 1 * * ?")
|
|
private void inspectRecord() {
|
|
List<Integer> states = Arrays.asList(1, 4);
|
|
List<InspectRecord> change = new ArrayList<>();
|
|
List<InspectRecord> list = inspectRecordService.list();
|
|
list.stream().forEach(l -> {
|
|
if (!states.contains(l.getState()) && DateUtil.between(new Date(), l.getDeadline(), DateUnit.DAY, false) <= 15) {
|
|
l.setSlippageState(2);
|
|
change.add(l);
|
|
}
|
|
if (!states.contains(l.getState()) && DateUtil.between(l.getDeadline(), new Date(), DateUnit.DAY, false) > 0) {
|
|
l.setSlippageState(3);
|
|
change.add(l);
|
|
}
|
|
});
|
|
if (change.size() > 0) {
|
|
inspectRecordService.updateBatchById(change);
|
|
}
|
|
log.info("=========定时修改项目进度状态任务执行成功========");
|
|
}
|
|
}
|