Skip to content

D
dsk-operate-sys-cscec
Commit d2477e9c authored by Administrator's avatar Administrator
Browse files
Options

- 

Signed-off-by: Administrator's avatarAdministrator <admin@example.com>
parent a5f84e87
Hide whitespace changes
Inline Side-by-side
Showing with 50 additions and 50 deletions
dsk-module/dsk-biz-api/src/main/java/com/dsk/monitor/job/PushScheduling.java
View file @ d2477e9c
package com.dsk.monitor.job; //package com.dsk.monitor.job;
//
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; //import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.dsk.common.utils.DateUtils; //import com.dsk.common.utils.DateUtils;
import com.dsk.monitor.domain.dto.PushMonitorRules; //import com.dsk.monitor.domain.dto.PushMonitorRules;
import com.dsk.monitor.mapper.PushMonitorInfoMapper; //import com.dsk.monitor.mapper.PushMonitorInfoMapper;
import com.dsk.monitor.mapper.PushMonitorRulesMapper; //import com.dsk.monitor.mapper.PushMonitorRulesMapper;
import com.dsk.monitor.util.SendMessageUtil; //import com.dsk.monitor.util.SendMessageUtil;
import org.springframework.scheduling.annotation.Scheduled; //import org.springframework.scheduling.annotation.Scheduled;
//
import javax.annotation.Resource; //import javax.annotation.Resource;
//
/** ///**
* @ClassName PushScheduling // * @ClassName PushScheduling
* @Description 发送短信 // * @Description 发送短信
* @Author Dgm // * @Author Dgm
* @Date 2023/12/9 13:51 // * @Date 2023/12/9 13:51
* @Version // * @Version
*/ // */
public class PushScheduling { //public class PushScheduling {
//
@Resource // @Resource
private PushMonitorInfoMapper monitorInfoMapper; // private PushMonitorInfoMapper monitorInfoMapper;
//
@Resource // @Resource
private PushMonitorRulesMapper rulesMapper; // private PushMonitorRulesMapper rulesMapper;
//
@Scheduled(cron = "0 0 5 * * * ?") // @Scheduled(cron = "0 0 5 * * * ?")
public void receiveModePhone() { // public void receiveModePhone() {
// 获取当前整点时间 // // 获取当前整点时间
Integer concurrentHour = DateUtils.getHour(); // Integer concurrentHour = DateUtils.getHour();
QueryWrapper queryWrapper = new QueryWrapper(); // QueryWrapper queryWrapper = new QueryWrapper();
PushMonitorRules detail = rulesMapper.selectOne(queryWrapper); // PushMonitorRules detail = rulesMapper.selectOne(queryWrapper);
// 推送时段-起 // // 推送时段-起
Integer timePeriodStart = detail.getTimePeriodStart(); // Integer timePeriodStart = detail.getTimePeriodStart();
// 推送时段-止 // // 推送时段-止
Integer timePeriodEnd = detail.getTimePeriodEnd(); // Integer timePeriodEnd = detail.getTimePeriodEnd();
if (concurrentHour > timePeriodStart && concurrentHour < timePeriodEnd) { // if (concurrentHour > timePeriodStart && concurrentHour < timePeriodEnd) {
QueryWrapper monitorInfoWrapper = new QueryWrapper(); // QueryWrapper monitorInfoWrapper = new QueryWrapper();
// 风险类型 // // 风险类型
monitorInfoWrapper.in("risk_type", detail.getRiskType()); // monitorInfoWrapper.in("risk_type", detail.getRiskType());
// 监控维度 // // 监控维度
monitorInfoWrapper.in("dimension", detail.getDimension()); // monitorInfoWrapper.in("dimension", detail.getDimension());
Long count = monitorInfoMapper.selectCount(monitorInfoWrapper); // Long count = monitorInfoMapper.selectCount(monitorInfoWrapper);
if (count >0 ) { // if (count >0 ) {
SendMessageUtil.sendMessage(detail.getPhones(), count.toString()); // SendMessageUtil.sendMessage(detail.getPhones(), count.toString());
} // }
} // }
} // }
} //}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment