package com.hxzkmonitor.controller;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.hxzkmonitor.mapper.TbDuanxinMapper;
|
import com.hxzkmonitor.pojo.TbDuanxin;
|
import com.hxzkmonitor.pojo.TbDuanxinlog;
|
import com.hxzkmonitor.pojo.TbEquipment;
|
import com.hxzkmonitor.pojo.TbSystem;
|
import com.hxzkmonitor.service.TbDuanxinlogService;
|
import com.hxzkmonitor.service.TbSystemService;
|
import com.hxzkmonitor.util.R;
|
import com.tencentcloudapi.common.Credential;
|
import com.tencentcloudapi.common.exception.TencentCloudSDKException;
|
import com.tencentcloudapi.common.profile.ClientProfile;
|
import com.tencentcloudapi.common.profile.HttpProfile;
|
import com.tencentcloudapi.sms.v20210111.SmsClient;
|
import com.tencentcloudapi.sms.v20210111.models.SendSmsRequest;
|
import com.tencentcloudapi.sms.v20210111.models.SendSmsResponse;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.text.SimpleDateFormat;
|
import java.time.Duration;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.*;
|
|
/**
|
* <p>
|
* 前端控制器
|
* </p>
|
*
|
* @author wangfei
|
* @since 2024-08-05
|
*/
|
@RestController
|
@RequestMapping("/")
|
@Component
|
public class TbSystemController {
|
|
@Autowired
|
com.hxzkmonitor.service.TbSystemService TbSystemService;
|
|
@Autowired
|
TbDuanxinMapper tbDuanxinMapper;
|
private String SecretId = "AKIDrjZOI4e6KLZu9FAsSRN8eOwSt52lbMBz";
|
private String SecretKey = "xnRtHUL3YqdMyOLVSBjKkz1pQoxujS4d";
|
@Autowired
|
TbDuanxinlogService tbDuanxinlogService;
|
Integer st = -1;
|
|
@ApiOperation(value = "分页查询", notes = "分页查询")
|
@GetMapping("/api/getSystemPage")
|
public R getSystem(Page page) {
|
IPage<TbSystem> ipage = TbSystemService.getSystemPage(page);
|
|
return R.ok(ipage);
|
}
|
|
@PostMapping("/api/addorupSystem")
|
public R addorupSystem(TbSystem tbSystem) {
|
return R.ok(TbSystemService.addorupSystem(tbSystem));
|
}
|
|
@GetMapping("/api/getSystemOne")
|
public R getSystemOne() {
|
|
List<TbSystem> list1 = TbSystemService.findsystem();
|
return R.ok(list1);
|
}
|
|
public static boolean isDifferenceGreaterThan60Seconds(String timeStr) {
|
// 定义日期时间格式
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
// 将字符串时间解析为 LocalDateTime 对象
|
LocalDateTime givenTime = LocalDateTime.parse(timeStr, formatter);
|
// 获取当前时间
|
LocalDateTime currentTime = LocalDateTime.now();
|
// 计算两个时间之间的差值
|
Duration duration = Duration.between(givenTime, currentTime);
|
// 判断差值是否大于 60 秒
|
return duration.getSeconds() > 60;
|
}
|
|
// @Scheduled(cron = "0 24 15 * * ?")
|
@Scheduled(cron = "*/10 * * * * ?")//测试10一次
|
// @Scheduled(cron = "0 0/10 8-22 * * ?")//8点到10点每10分钟执行一次
|
public void sms() throws Exception {
|
System.out.println("短信定时器执行============》》》》》》》》》》》》》》》》");
|
//查询数据库中所有的公司数据
|
List<TbSystem> list1 = TbSystemService.list();
|
|
System.out.println(list1.get(0).getAlerttime());//当前时间-获取时间大于60
|
boolean result = isDifferenceGreaterThan60Seconds(list1.get(0).getAlerttime());
|
System.out.println("时间差是否大于 60 秒: " + result);
|
//获取当前年月日时间
|
if (result) {
|
if (st == 1){
|
try {
|
Credential cred = new Credential(this.SecretId, this.SecretKey);
|
HttpProfile httpProfile = new HttpProfile();
|
httpProfile.setEndpoint("sms.tencentcloudapi.com");
|
ClientProfile clientProfile = new ClientProfile();
|
clientProfile.setHttpProfile(httpProfile);
|
SmsClient client = new SmsClient(cred, "ap-beijing", clientProfile);
|
SendSmsRequest req = new SendSmsRequest();
|
// String[] phoneNumberSet1 = new String[]{GsPhone.split("[,，]")[p]};
|
QueryWrapper sms = new QueryWrapper();
|
sms.eq("type", "引擎离线报警");
|
List<TbDuanxin> managerList = tbDuanxinMapper.selectList(sms);
|
for (int s = 0; s < managerList.size(); s++) {
|
// System.out.println(managerList.get(s).getPhone());
|
// phoneNumberSet1[s] = managerList.get(s).getPhone();
|
String[] phoneNumberSet12 = {managerList.get(s).getPhone()};
|
System.out.println(phoneNumberSet12);
|
req.setPhoneNumberSet(phoneNumberSet12);
|
|
req.setSmsSdkAppId("1400838975");
|
req.setSignName("北京华星北斗智控");
|
req.setTemplateId("2082020");
|
|
// String[] templateParamSet1 = {String.valueOf(+num11 / 24 / 60 / 60 / 1000)};
|
String[] templateParamSet1 = new String[]{managerList.get(s).getDuanxin()};
|
req.setTemplateParamSet(templateParamSet1);
|
// 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
SendSmsResponse resp = client.SendSms(req);
|
TbDuanxinlog duanxinlog = new TbDuanxinlog();
|
duanxinlog.setName(managerList.get(s).getManager());
|
duanxinlog.setPhone(managerList.get(s).getPhone());
|
|
duanxinlog.setMsg("告警提示:" + managerList.get(s).getDuanxin() + ",请尽快处理，如已处理请忽略该提示信息，如需退订短信可联系管理员删除");
|
tbDuanxinlogService.addorupDuanxinlog(duanxinlog);
|
}
|
// req.setPhoneNumberSet(phoneNumberSet1);
|
// req.setSmsSdkAppId("1400838975");
|
// req.setSignName("北京华星北斗智控");
|
// req.setTemplateId("1908206");
|
// String[] templateParamSet1 = new String[]{cardNum, "150MB"};
|
// req.setTemplateParamSet(templateParamSet1);
|
// SendSmsResponse resp = client.SendSms(req);
|
// System.out.println(SendSmsResponse.toJsonString(resp));
|
} catch (TencentCloudSDKException var15) {
|
System.out.println(var15.toString());
|
}
|
st = 0;
|
}
|
|
|
}else{
|
st=1;
|
}
|
}
|
}
|
