package com.hxzk.util;
|
|
import com.hxzk.deo.TbWarning;
|
import com.hxzk.pojo.TbSmsLog;
|
import com.hxzk.pojo.TbSmsReminder;
|
import com.hxzk.service.SmsLogService;
|
import com.hxzk.service.TbSmsReminderService;
|
import com.hxzk.service.WarningService;
|
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 org.springframework.stereotype.Component;
|
|
import java.sql.SQLOutput;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Random;
|
|
@Component
|
public class MyThreadTask implements Runnable {
|
private String SecretId = "AKIDrjZOI4e6KLZu9FAsSRN8eOwSt52lbMBz";
|
private String SecretKey = "xnRtHUL3YqdMyOLVSBjKkz1pQoxujS4d";
|
private WarningService warningService;
|
private TbSmsReminderService smsReminderService;
|
|
private SmsLogService smsLogService;
|
|
public MyThreadTask(WarningService warningService,TbSmsReminderService smsReminderService,SmsLogService smsLogService) {
|
this.warningService = warningService;
|
this.smsReminderService = smsReminderService;
|
this.smsLogService = smsLogService;
|
|
}
|
|
@Override
|
public void run() {
|
try {
|
while (true) {
|
//获取当前定义的短信提示类型
|
List<TbSmsReminder> smsReminders = smsReminderService.findAllSMSReminder();
|
List<Integer> ids = new ArrayList<>();
|
//循环短信提示(根据类型)查找需要发送短信的告警
|
for (int i = 0 ; i< smsReminders.size();i++){
|
String type = smsReminders.get(i).getSmstype();
|
//拿着当前type 在数据库中查询在之前6秒和现在满足告警条件的数据
|
List<TbWarning> a = warningService.findNowAll(type);
|
for (int j = 0 ; j <a.size();j++){
|
if (type.equals("SOS")){
|
String[] weizhi = a.get(j).getBaoliu1().split(";");
|
if(a.get(j).getPdepartment().equals(smsReminders.get(i).getBumen())){
|
String sms = smsReminders.get(i).getMsg()+"，我的位置，经度："+weizhi[0]+",纬度："+weizhi[1]+"我的电话是："+a.get(j).getPphone()+"，我的名称是："+a.get(j).getPname()+"，我的设备编号："+a.get(j).getPtagid();
|
String phone = smsReminders.get(i).getPhone();
|
smsRemin(phone,sms);
|
//发送成功，则添加日志
|
TbSmsLog tbSmsLog = new TbSmsLog();
|
tbSmsLog.setAddtime(gettime());
|
tbSmsLog.setType(type);
|
tbSmsLog.setPhone(phone);
|
tbSmsLog.setMsg(sms);
|
tbSmsLog.setName(smsReminders.get(i).getName());
|
tbSmsLog.setBumen(smsReminders.get(i).getBumen());
|
smsLogService.addSMSLog(tbSmsLog);
|
//同时修改标识，只发一次短信
|
ids.add(a.get(j).getId());
|
}
|
}else{
|
if(a.get(j).getPdepartment().equals(smsReminders.get(i).getBumen())){
|
String sms = smsReminders.get(i).getMsg()+"，我的电话是："+a.get(j).getPphone()+"，我的名称："+a.get(j).getPname()+"，我的设备编号："+a.get(j).getPtagid();
|
String phone = smsReminders.get(i).getPhone();
|
smsRemin(phone,sms);
|
//发送成功，则添加日志
|
TbSmsLog tbSmsLog = new TbSmsLog();
|
tbSmsLog.setAddtime(gettime());
|
tbSmsLog.setType(type);
|
tbSmsLog.setPhone(phone);
|
tbSmsLog.setMsg(sms);
|
tbSmsLog.setName(smsReminders.get(i).getName());
|
tbSmsLog.setBumen(smsReminders.get(i).getBumen());
|
smsLogService.addSMSLog(tbSmsLog);
|
//同时修改标识，只发一次短信
|
ids.add(a.get(j).getId());
|
}
|
}
|
}
|
|
}
|
|
for (int i = 0;i< ids.size();i++){
|
warningService.updateIDWarning(ids.get(i));
|
}
|
|
Thread.sleep(5000); // 线程休眠5秒
|
}
|
} catch (InterruptedException e) {
|
// 处理线程中断异常
|
e.printStackTrace();
|
}
|
}
|
|
public String gettime(){
|
Date now = new Date();
|
// 创建日期格式化对象，设置格式为 "yyyy-MM-dd HH:mm"
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
// 格式化日期对象，输出字符串结果
|
String formattedDate = sdf.format(now);
|
return formattedDate;
|
}
|
|
public void smsRemin(String phone,String neirong){
|
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[]{phone};
|
req.setPhoneNumberSet(phoneNumberSet1);
|
req.setSmsSdkAppId("1400838975");
|
req.setSignName("北京华星北斗智控");
|
req.setTemplateId("2082020");
|
String[] templateParamSet1 = new String[]{String.valueOf(neirong)};
|
req.setTemplateParamSet(templateParamSet1);
|
SendSmsResponse resp = client.SendSms(req);
|
} catch (TencentCloudSDKException var12) {
|
System.out.println(var12.toString());
|
}
|
}
|
}
|
