package com.flow.controller;
|
|
import cn.hutool.json.JSONArray;
|
import cn.hutool.json.JSONObject;
|
import com.alipay.api.kms.aliyun.http.HttpRequest;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.flow.mapper.*;
|
import com.flow.pojo.*;
|
import com.flow.service.DuanxinlogService;
|
import com.flow.service.TbFuwuqiService;
|
import com.flow.util.DESUtil;
|
import com.flow.util.result;
|
import com.flow.util.resultutil;
|
import com.github.pagehelper.PageInfo;
|
import com.tencentcloudapi.common.Credential;
|
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.apache.http.HttpEntity;
|
import org.apache.http.HttpResponse;
|
import org.apache.http.client.methods.HttpPost;
|
import org.apache.http.entity.StringEntity;
|
import org.apache.http.impl.client.CloseableHttpClient;
|
import org.apache.http.impl.client.HttpClients;
|
import org.apache.http.util.EntityUtils;
|
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 org.springframework.web.servlet.ModelAndView;
|
import sun.net.www.http.HttpClient;
|
|
import javax.crypto.Mac;
|
import javax.crypto.spec.SecretKeySpec;
|
import java.io.BufferedReader;
|
import java.io.InputStreamReader;
|
import java.io.OutputStream;
|
import java.net.HttpURLConnection;
|
import java.net.URL;
|
import java.nio.charset.StandardCharsets;
|
import java.util.Objects;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
@RestController
|
@RequestMapping({"/hxzk"})
|
@Component
|
public class DuanxinlogController {
|
|
private String SecretId = "AKIDrjZOI4e6KLZu9FAsSRN8eOwSt52lbMBz";
|
private String SecretKey = "xnRtHUL3YqdMyOLVSBjKkz1pQoxujS4d";
|
@Autowired
|
DuanxinlogService duanxinlogService;
|
|
@Autowired
|
CardMapper cardMapper;
|
@Autowired
|
TbFuwuqiMapper tbFuwuqiMapper;
|
@Autowired
|
DuanxinlogMapper duanxinlogMapper;
|
|
@Autowired
|
TbFuwuqiService tbFuwuqiService;
|
|
@Autowired
|
CompanyMapper companyMapper;
|
|
@Autowired
|
ManagerMapper managerMapper;
|
|
@GetMapping({"findDuanxinlog"})
|
result<List<Duanxinlog>> findDuanxinlog(Integer page, Integer limit) {
|
PageInfo<Duanxinlog> cz = this.duanxinlogService.FindDuanxinlog(page, limit);
|
return resultutil.returnSuccess(cz.getTotal(), cz.getList());
|
}
|
|
@PostMapping({"DeleteDuanxinlog"})
|
public ModelAndView DeleteManager(String num) {
|
this.duanxinlogService.DeleteDuanxinlog(num);
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.setViewName("/page/Duanxinlog.jsp");
|
return modelAndView;
|
|
}
|
|
/*
|
* 函数名 : smsfuwuqi
|
* 说明 :
|
服务器
|
查询所有服务器数据
|
根据公司名称查询电话
|
使用当前时间减去结束时间
|
使用号码查询短信表取出发送日期，如果当前日期大于发送日期
|
发送短信
|
* 返回值 : 无
|
* 作者 : 王飞
|
// * 日期 : 2024年2月28日
|
*/
|
// @EnableScheduling
|
// @Scheduled(cron = "*/10 * * * * ?")//测试10一次
|
@Scheduled(cron = "0 51 15 * * ?")
|
// @Scheduled(cron = "0 0 */1 * * ?")//一小时执行一次
|
@Scheduled(cron = "0 0/60 8-22 * * ?")//8点到10点每10分钟执行一次
|
public void smsfuwuqi() throws Exception {
|
System.out.println("服务器定时器执行============》》》》》》》》》》》》》》》》");
|
QueryWrapper queryWrapper1 = new QueryWrapper();
|
queryWrapper1.eq("none", "0");
|
List<TbFuwuqi> fuwuqiList = (tbFuwuqiMapper).selectList(queryWrapper1);
|
for (int i = 0; i < fuwuqiList.size(); i++) {
|
QueryWrapper queryWrapper3 = new QueryWrapper();
|
queryWrapper3.eq("none", "0");
|
queryWrapper3.eq("companyName", fuwuqiList.get(i).getCompany());
|
Company companyList = (companyMapper).selectOne(queryWrapper3);
|
SimpleDateFormat date2 = new SimpleDateFormat("yyyy-MM-dd");
|
Date date = new Date();
|
|
Date endDay = date2.parse(fuwuqiList.get(i).getEnddate());//结束时间
|
Long starTime = date.getTime();
|
Long endTime = endDay.getTime();
|
Long num11 = endTime - starTime;//时间戳
|
//不足一天的算作一天，因此在到期天数上加1
|
if (+num11 / 24 / 60 / 60 / 1000 == 19 | +num11 / 24 / 60 / 60 / 1000 == 9 | +num11 / 24 / 60 / 60 / 1000 == 4 | +num11 / 24 / 60 / 60 / 1000 == 0) {
|
String dispatchDate = this.duanxinlogService.userdate(fuwuqiList.get(i).getServername());
|
if (dispatchDate == null) {
|
// SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
// Date dtext = formatter.parse(dispatchDate);//结束时间
|
// Long endTime1 = dtext.getTime();
|
// if ((endTime1-starTime) / 24 / 60 / 60 / 1000 != 0) {
|
// 实例化一个认证对象，入参需要传入腾讯云账户 SecretId 和 SecretKey，此处还需注意密钥对的保密
|
// 代码泄露可能会导致 SecretId 和 SecretKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考，建议采用更安全的方式来使用密钥，请参见：https://cloud.tencent.com/document/product/1278/85305
|
// 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
|
Credential cred = new Credential(SecretId, SecretKey);
|
// 实例化一个http选项，可选的，没有特殊需求可以跳过
|
HttpProfile httpProfile = new HttpProfile();
|
httpProfile.setEndpoint("sms.tencentcloudapi.com");
|
// 实例化一个client选项，可选的，没有特殊需求可以跳过
|
ClientProfile clientProfile = new ClientProfile();
|
clientProfile.setHttpProfile(httpProfile);
|
// 实例化要请求产品的client对象,clientProfile是可选的
|
SmsClient client = new SmsClient(cred, "ap-beijing", clientProfile);
|
// 实例化一个请求对象,每个接口都会对应一个request对象
|
SendSmsRequest req = new SendSmsRequest();
|
// String[] phoneNumberSet1 = {"18701153496"};
|
|
// if (phone.split("[,，]").length>1){
|
//
|
// }
|
|
QueryWrapper sms = new QueryWrapper();
|
sms.eq("none", "0");
|
sms.eq("smsreception", "1");
|
List<Manager> managerList = (managerMapper).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("2318088");
|
|
// String[] templateParamSet1 = {String.valueOf(+num11 / 24 / 60 / 60 / 1000)};
|
// String[] templateParamSet1 = {String.valueOf("您有流量卡将于：" + fuwuqiList.get(i).getEnddate() + "到期，")};
|
// req.setTemplateParamSet(templateParamSet1);
|
// 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
SendSmsResponse resp = client.SendSms(req);
|
}
|
String phone = DESUtil.decrypt(companyList.getLoginphone(), DESUtil.key);
|
for (int j = 0; j < phone.split("[,，]").length; j++) {
|
String[] phoneNumberSet1 = {phone.split("[,，]")[j]};
|
req.setPhoneNumberSet(phoneNumberSet1);
|
|
req.setSmsSdkAppId("1400838975");
|
req.setSignName("北京华星北斗智控");
|
req.setTemplateId("2318088");
|
|
// String[] templateParamSet1 = {String.valueOf(+num11 / 24 / 60 / 60 / 1000)};
|
String[] templateParamSet1 = {String.valueOf("您有服务器将于：" + fuwuqiList.get(i).getEnddate() + "到期，")};
|
req.setTemplateParamSet(templateParamSet1);
|
// 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
SendSmsResponse resp = client.SendSms(req);
|
// 输出json格式的字符串回包
|
Duanxinlog duanxinlog = new Duanxinlog();
|
duanxinlog.setIdentification(fuwuqiList.get(i).getServername());
|
duanxinlog.setReceiver(fuwuqiList.get(i).getCompany());
|
duanxinlog.setNumber(phone.split("[,，]")[j]);
|
// duanxinlog.setNumber(DESUtil.decrypt(companyList.getLoginphone(), DESUtil.key));
|
duanxinlog.setContent("尊敬的用户，您好！您有服务器将于" + fuwuqiList.get(i).getEnddate() + "到期，为避免影响您的正常使用请及时续费，您可登录华星智控公司物联网管理平台查询详情续费，如有疑问可咨询我公司客服人员，祝您生活愉快！");
|
this.duanxinlogService.addDuanxinlog(duanxinlog);
|
}
|
|
// }
|
} else {
|
SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
Date dtext = formatter.parse(dispatchDate);//结束时间
|
Long endTime1 = dtext.getTime();
|
if ((endTime1 - starTime) / 24 / 60 / 60 / 1000 != 0) {
|
// 实例化一个认证对象，入参需要传入腾讯云账户 SecretId 和 SecretKey，此处还需注意密钥对的保密
|
// 代码泄露可能会导致 SecretId 和 SecretKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考，建议采用更安全的方式来使用密钥，请参见：https://cloud.tencent.com/document/product/1278/85305
|
// 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
|
Credential cred = new Credential(SecretId, SecretKey);
|
// 实例化一个http选项，可选的，没有特殊需求可以跳过
|
HttpProfile httpProfile = new HttpProfile();
|
httpProfile.setEndpoint("sms.tencentcloudapi.com");
|
// 实例化一个client选项，可选的，没有特殊需求可以跳过
|
ClientProfile clientProfile = new ClientProfile();
|
clientProfile.setHttpProfile(httpProfile);
|
// 实例化要请求产品的client对象,clientProfile是可选的
|
SmsClient client = new SmsClient(cred, "ap-beijing", clientProfile);
|
// 实例化一个请求对象,每个接口都会对应一个request对象
|
SendSmsRequest req = new SendSmsRequest();
|
// String[] phoneNumberSet1 = {"18701153496"};
|
// String[] phoneNumberSet1 = {DESUtil.decrypt(companyList.getLoginphone(), DESUtil.key)};
|
QueryWrapper sms = new QueryWrapper();
|
sms.eq("none", "0");
|
sms.eq("smsreception", "1");
|
List<Manager> managerList = (managerMapper).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("2318088");
|
|
// String[] templateParamSet1 = {String.valueOf(+num11 / 24 / 60 / 60 / 1000)};
|
// String[] templateParamSet1 = {String.valueOf("您有流量卡将于：" + fuwuqiList.get(i).getEnddate() + "到期，")};
|
// req.setTemplateParamSet(templateParamSet1);
|
// 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
SendSmsResponse resp = client.SendSms(req);
|
}
|
String phone = DESUtil.decrypt(companyList.getLoginphone(), DESUtil.key);
|
for (int j = 0; j < phone.split("[,，]").length; j++) {
|
String[] phoneNumberSet1 = {phone.split("[,，]")[j]};
|
req.setPhoneNumberSet(phoneNumberSet1);
|
|
req.setSmsSdkAppId("1400838975");
|
req.setSignName("北京华星北斗智控");
|
req.setTemplateId("2318088");
|
|
// String[] templateParamSet1 = {String.valueOf(+num11 / 24 / 60 / 60 / 1000)};
|
// String[] templateParamSet1 = {String.valueOf("您有服务器将于：" + fuwuqiList.get(i).getEnddate() + "到期，")};
|
// req.setTemplateParamSet(templateParamSet1);
|
// 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
SendSmsResponse resp = client.SendSms(req);
|
// 输出json格式的字符串回包
|
Duanxinlog duanxinlog = new Duanxinlog();
|
duanxinlog.setIdentification(fuwuqiList.get(i).getServername());
|
duanxinlog.setReceiver(fuwuqiList.get(i).getCompany());
|
duanxinlog.setNumber(phone.split("[,，]")[j]);
|
// duanxinlog.setNumber(DESUtil.decrypt(companyList.getLoginphone(), DESUtil.key));
|
duanxinlog.setContent("尊敬的用户，您好！您有服务器将于" + fuwuqiList.get(i).getEnddate() + "到期，为避免影响您的正常使用请及时续费，您可登录华星智控公司物联网管理平台查询详情续费，如有疑问可咨询我公司客服人员，祝您生活愉快！");
|
this.duanxinlogService.addDuanxinlog(duanxinlog);
|
}
|
}
|
}
|
}
|
|
}
|
}
|
|
//
|
// /*
|
// * 函数名 : sms
|
// * 说明 : 查询所有卡号数据
|
// 使用当前时间减去结束时间
|
// 使用号码查询短信表取出发送日期，如果当前日期大于发送日期
|
// 发送短信
|
// 发送短信
|
//
|
// * 返回值 : 无
|
// * 作者 : 王飞
|
//// * 日期 : 2024年2月28日
|
// */
|
//// @EnableScheduling
|
//// @Scheduled(cron = "*/10 * * * * ?")//测试10秒执行一次
|
//// @Scheduled(cron = "0 48 10 * * ?")
|
// @Scheduled(cron = "0 0 */1 * * ?")//一小时执行一次
|
// public void sms() throws Exception {
|
// System.out.println("短信定时器执行============》》》》》》》》》》》》》》》》");
|
// //查询数据库中所有的引擎数据
|
// QueryWrapper queryWrapper = new QueryWrapper();
|
// queryWrapper.eq("none", "0");
|
//// queryWrapper.eq("num", "1");
|
// List<Card> cardList = (cardMapper).selectList(queryWrapper);
|
// for (int i = 0; i < cardList.size(); i++) {
|
// QueryWrapper queryWrapper3 = new QueryWrapper();
|
// queryWrapper3.eq("none", "0");
|
// queryWrapper3.eq("companyName", cardList.get(i).getCompany());
|
// Company companyList = new Company();
|
// companyList = (companyMapper).selectOne(queryWrapper3);
|
// if (companyList == null) {
|
// QueryWrapper queryWrapper4 = new QueryWrapper();
|
// queryWrapper4.eq("none", "0");
|
// queryWrapper4.eq("companyabbname", cardList.get(i).getCompany());
|
// companyList = (companyMapper).selectOne(queryWrapper4);
|
// }
|
//// System.out.println("333333");
|
// SimpleDateFormat date2 = new SimpleDateFormat("yyyy-MM-dd");
|
// Date date = new Date();
|
// Date endDay = date2.parse(cardList.get(i).getEnddate());//结束时间
|
// Long starTime = date.getTime();
|
// Long endTime = endDay.getTime();
|
// Long num11 = endTime - starTime;//时间戳
|
//// System.out.println("22222222");
|
//// System.out.println(+num11 / 24 / 60 / 60 / 1000);
|
// if (+num11 / 24 / 60 / 60 / 1000 == 19 | +num11 / 24 / 60 / 60 / 1000 == 9 | +num11 / 24 / 60 / 60 / 1000 == 4 | +num11 / 24 / 60 / 60 / 1000 == 0) {
|
// System.out.println("1111111111111111111");
|
// String dispatchDate = this.duanxinlogService.userdate(cardList.get(i).getCardnumber());
|
// if (dispatchDate==null){
|
//// SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
//// Date dtext = formatter.parse(dispatchDate);//结束时间
|
//// Long endTime1 = dtext.getTime();
|
//// if ((endTime1-starTime) / 24 / 60 / 60 / 1000 != 0) {
|
// String randomNumber = new String();
|
// // 实例化一个认证对象，入参需要传入腾讯云账户 SecretId 和 SecretKey，此处还需注意密钥对的保密
|
// // 代码泄露可能会导致 SecretId 和 SecretKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考，建议采用更安全的方式来使用密钥，请参见：https://cloud.tencent.com/document/product/1278/85305
|
// // 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
|
// Credential cred = new Credential(SecretId, SecretKey);
|
// // 实例化一个http选项，可选的，没有特殊需求可以跳过
|
// HttpProfile httpProfile = new HttpProfile();
|
// httpProfile.setEndpoint("sms.tencentcloudapi.com");
|
// // 实例化一个client选项，可选的，没有特殊需求可以跳过
|
// ClientProfile clientProfile = new ClientProfile();
|
// clientProfile.setHttpProfile(httpProfile);
|
// // 实例化要请求产品的client对象,clientProfile是可选的
|
// SmsClient client = new SmsClient(cred, "ap-beijing", clientProfile);
|
// // 实例化一个请求对象,每个接口都会对应一个request对象
|
// SendSmsRequest req = new SendSmsRequest();
|
//// String[] phoneNumberSet1 = {cardList.get(i).getCardnumber()};
|
// String[] phoneNumberSet1 = {DESUtil.decrypt(companyList.getLoginphone(), DESUtil.key)};
|
//// String[] phoneNumberSet1 = {"18701153496"};
|
// QueryWrapper sms = new QueryWrapper();
|
// sms.eq("none", "0");
|
// sms.eq("smsreception", "1");
|
// List<Manager> managerList = (managerMapper).selectList(sms);
|
// String string = new String();
|
// for (int s=0;s<managerList.size();s++){
|
//
|
// if (s!=0){
|
// string+=",";
|
// }
|
// string += managerList.get(s).getPhone();
|
// String[] phoneNumberSet12 = {managerList.get(s).getPhone()};
|
// System.out.println(phoneNumberSet12);
|
// req.setPhoneNumberSet(phoneNumberSet12);
|
//
|
// req.setSmsSdkAppId("1400838975");
|
// req.setSignName("北京华星北斗智控");
|
// req.setTemplateId("2100321");
|
//
|
//// String[] templateParamSet1 = {String.valueOf(+num11 / 24 / 60 / 60 / 1000)};
|
// String[] templateParamSet1 = {String.valueOf("您有流量卡将于：" + cardList.get(i).getEnddate()+"到期，")};
|
// req.setTemplateParamSet(templateParamSet1);
|
// // 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
// SendSmsResponse resp = client.SendSms(req);
|
// }
|
//// phoneNumberSet1[managerList.size()] = DESUtil.decrypt(companyList.getLoginphone(), DESUtil.key);
|
//// System.out.println(phoneNumberSet1);
|
// req.setPhoneNumberSet(phoneNumberSet1);
|
//
|
// req.setSmsSdkAppId("1400838975");
|
// req.setSignName("北京华星北斗智控");
|
// req.setTemplateId("2100321");
|
//
|
//// String[] templateParamSet1 = {String.valueOf(+num11 / 24 / 60 / 60 / 1000)};
|
// String[] templateParamSet1 = {String.valueOf("您有流量卡将于：" + cardList.get(i).getEnddate()+"到期，")};
|
// req.setTemplateParamSet(templateParamSet1);
|
// // 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
// SendSmsResponse resp = client.SendSms(req);
|
// System.out.println(SendSmsResponse.toJsonString(resp));
|
// // 输出json格式的字符串回包
|
// Duanxinlog duanxinlog = new Duanxinlog();
|
// duanxinlog.setIdentification(cardList.get(i).getCardnumber());
|
// duanxinlog.setReceiver(cardList.get(i).getCompany());
|
// duanxinlog.setNumber(string);
|
// duanxinlog.setContent("尊敬的用户，您好！您有流量卡将于"+cardList.get(i).getEnddate()+"到期，为避免影响您的正常使用请及时续费，您可登录华星智控公司物联网管理平台查询详情续费，如有疑问可咨询我公司客服人员，祝您生活愉快！"
|
// );
|
// this.duanxinlogService.addDuanxinlog(duanxinlog);
|
//// }
|
// }else{
|
// SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
|
// Date dtext = formatter.parse(dispatchDate);//结束时间
|
// Long endTime1 = dtext.getTime();
|
//// System.out.println(dtext);
|
//// System.out.println(dispatchDate);
|
//// System.out.println(starTime);
|
//// System.out.println(endTime1);
|
//// System.out.println((starTime-endTime1) / 24);
|
//// System.out.println((starTime-endTime1) / 24 / 60 / 60 / 1000);
|
//// System.out.println((starTime-endTime1) / 24 / 60 / 60 / 1000 > 0);
|
// if ((starTime-endTime1) / 24 / 60 / 60 / 1000 != 0) {
|
// String randomNumber = new String();
|
// // 实例化一个认证对象，入参需要传入腾讯云账户 SecretId 和 SecretKey，此处还需注意密钥对的保密
|
// // 代码泄露可能会导致 SecretId 和 SecretKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考，建议采用更安全的方式来使用密钥，请参见：https://cloud.tencent.com/document/product/1278/85305
|
// // 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
|
// Credential cred = new Credential(SecretId, SecretKey);
|
// // 实例化一个http选项，可选的，没有特殊需求可以跳过
|
// HttpProfile httpProfile = new HttpProfile();
|
// httpProfile.setEndpoint("sms.tencentcloudapi.com");
|
// // 实例化一个client选项，可选的，没有特殊需求可以跳过
|
// ClientProfile clientProfile = new ClientProfile();
|
// clientProfile.setHttpProfile(httpProfile);
|
// // 实例化要请求产品的client对象,clientProfile是可选的
|
// SmsClient client = new SmsClient(cred, "ap-beijing", clientProfile);
|
// // 实例化一个请求对象,每个接口都会对应一个request对象
|
// SendSmsRequest req = new SendSmsRequest();
|
//// String[] phoneNumberSet1 = {cardList.get(i).getCardnumber()};
|
// String[] phoneNumberSet1 = {DESUtil.decrypt(companyList.getLoginphone(), DESUtil.key)};
|
//// String[] phoneNumberSet1 = {"18701153496"};
|
// QueryWrapper sms = new QueryWrapper();
|
// sms.eq("none", "0");
|
// sms.eq("smsreception", "1");
|
// List<Manager> managerList = (managerMapper).selectList(sms);
|
// String string = new String();
|
// for (int s=0;s<managerList.size();s++){
|
//
|
// if (s!=0){
|
// string+=",";
|
// }
|
// string += managerList.get(s).getPhone();
|
// String[] phoneNumberSet12 = {managerList.get(s).getPhone()};
|
// System.out.println(phoneNumberSet12);
|
// req.setPhoneNumberSet(phoneNumberSet12);
|
//
|
// req.setSmsSdkAppId("1400838975");
|
// req.setSignName("北京华星北斗智控");
|
// req.setTemplateId("2100321");
|
//
|
//// String[] templateParamSet1 = {String.valueOf(+num11 / 24 / 60 / 60 / 1000)};
|
// String[] templateParamSet1 = {String.valueOf("您有流量卡将于：" + cardList.get(i).getEnddate()+"到期，")};
|
// req.setTemplateParamSet(templateParamSet1);
|
// // 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
// SendSmsResponse resp = client.SendSms(req);
|
// }
|
//// phoneNumberSet1[managerList.size()] = DESUtil.decrypt(companyList.getLoginphone(), DESUtil.key);
|
//// System.out.println(phoneNumberSet1);
|
// req.setPhoneNumberSet(phoneNumberSet1);
|
//
|
// req.setSmsSdkAppId("1400838975");
|
// req.setSignName("北京华星北斗智控");
|
// req.setTemplateId("2100321");
|
//
|
//// String[] templateParamSet1 = {String.valueOf(+num11 / 24 / 60 / 60 / 1000)};
|
// String[] templateParamSet1 = {String.valueOf("您有流量卡将于：" + cardList.get(i).getEnddate()+"到期，")};
|
// req.setTemplateParamSet(templateParamSet1);
|
// // 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
// SendSmsResponse resp = client.SendSms(req);
|
// System.out.println(SendSmsResponse.toJsonString(resp));
|
// // 输出json格式的字符串回包
|
// Duanxinlog duanxinlog = new Duanxinlog();
|
// duanxinlog.setIdentification(cardList.get(i).getCardnumber());
|
// duanxinlog.setReceiver(cardList.get(i).getCompany());
|
// duanxinlog.setNumber(string);
|
// duanxinlog.setContent("尊敬的用户，您好！您有流量卡将于"+cardList.get(i).getEnddate()+"到期，为避免影响您的正常使用请及时续费，您可登录华星智控公司物联网管理平台查询详情续费，如有疑问可咨询我公司客服人员，祝您生活愉快！"
|
// );
|
// this.duanxinlogService.addDuanxinlog(duanxinlog);
|
// }
|
// }
|
//// String dispatchDate = this.duanxinlogService.userdate(cardList.get(i).getCardnumber());
|
//
|
// }
|
//
|
// }
|
// }
|
|
/*
|
* 函数名 : sms
|
* 说明 : 查询所有卡号数据
|
使用当前时间减去结束时间
|
使用号码查询短信表取出发送日期，如果当前日期大于发送日期
|
发送短信
|
发送短信
|
|
* 返回值 : 无
|
* 作者 : 王飞
|
// * 日期 : 2024年2月28日
|
*/
|
// @EnableScheduling
|
// @Scheduled(cron = "*/10 * * * * ?")//测试10秒执行一次
|
// @Scheduled(cron = "0 54 15 * * ?")
|
@Scheduled(cron = "0 0/10 8-22 * * ?")//8点到10点每10分钟执行一次
|
public void sms() throws Exception {
|
System.out.println("短信定时器执行============》》》》》》》》》》》》》》》》");
|
//查询数据库中所有的公司数据
|
QueryWrapper queryWrapper = new QueryWrapper();
|
// queryWrapper.eq("num", "1");
|
queryWrapper.eq("none", "0");
|
List<Company> companyList = (companyMapper).selectList(queryWrapper);
|
//获取当前年月日时间
|
SimpleDateFormat date2 = new SimpleDateFormat("yyyy-MM-dd");
|
Date date = new Date();
|
String s = date2.format(date);
|
for (int i = 0; i < companyList.size(); i++) {
|
//判断条件是否发送短信和发送短信日期
|
if (!Objects.equals(companyList.get(i).getSenddate(), s)) {
|
//根据公司名称查询卡号
|
List<Card> cardList = this.cardMapper.findAllcompanycard(companyList.get(i).getCompanyname(), companyList.get(i).getCompanyabbname());
|
for (int j = 0; j < cardList.size(); j++) {
|
if (cardList.get(j).getEnddate()!=null){
|
Date endDay = date2.parse(cardList.get(j).getEnddate());//结束时间
|
Long starTime = date.getTime();
|
Long endTime = endDay.getTime();
|
Long num11 = endTime - starTime;//时间戳
|
|
if ((+num11 / 24 / 60 / 60 / 1000 == 19) || (+num11 / 24 / 60 / 60 / 1000 == 14) || (+num11 / 24 / 60 / 60 / 1000 == 9) || (+num11 / 24 / 60 / 60 / 1000 == 4) || (+num11 / 24 / 60 / 60 / 1000 == 0)) {
|
|
//发送短信
|
// 实例化一个认证对象，入参需要传入腾讯云账户 SecretId 和 SecretKey，此处还需注意密钥对的保密
|
// 代码泄露可能会导致 SecretId 和 SecretKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考，建议采用更安全的方式来使用密钥，请参见：https://cloud.tencent.com/document/product/1278/85305
|
// 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
|
Credential cred = new Credential(SecretId, SecretKey);
|
// 实例化一个http选项，可选的，没有特殊需求可以跳过
|
HttpProfile httpProfile = new HttpProfile();
|
httpProfile.setEndpoint("sms.tencentcloudapi.com");
|
// 实例化一个client选项，可选的，没有特殊需求可以跳过
|
ClientProfile clientProfile = new ClientProfile();
|
clientProfile.setHttpProfile(httpProfile);
|
// 实例化要请求产品的client对象,clientProfile是可选的
|
SmsClient client = new SmsClient(cred, "ap-beijing", clientProfile);
|
// 实例化一个请求对象,每个接口都会对应一个request对象
|
SendSmsRequest req = new SendSmsRequest();
|
// String[] phoneNumberSet1 = {cardList.get(i).getCardnumber()};
|
// String[] phoneNumberSet1 = {DESUtil.decrypt(companyList.get(i).getLoginphone(), DESUtil.key)};
|
// String[] phoneNumberSet1 = {"18582279726"};
|
//查询有接收短信权限的管理员给他们发送短信通知
|
QueryWrapper sms = new QueryWrapper();
|
sms.eq("none", "0");
|
sms.eq("smsreception", "1");
|
List<Manager> managerList = (managerMapper).selectList(sms);
|
String string = new String();
|
System.out.println(cardList.get(j));
|
for (int s1 = 0; s1 < managerList.size(); s1++) {
|
|
if (s1 != 0) {
|
string += ",";
|
}
|
string += managerList.get(s1).getPhone();
|
String[] phoneNumberSet12 = {managerList.get(s1).getPhone()};
|
System.out.println(phoneNumberSet12);
|
req.setPhoneNumberSet(phoneNumberSet12);
|
req.setSmsSdkAppId("1400838975");
|
req.setSignName("北京华星北斗智控");
|
req.setTemplateId("2089627");
|
String[] templateParamSet1 = {String.valueOf("有使用的物联网卡还有"+(+num11 / 24 / 60 / 60 / 1000+1)),String.valueOf(cardList.get(j).getEnddate())};
|
req.setTemplateParamSet(templateParamSet1);
|
// 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
SendSmsResponse resp = client.SendSms(req);
|
}
|
String phone = DESUtil.decrypt(companyList.get(i).getLoginphone(), DESUtil.key);
|
for (int p = 0; p < phone.split("[,，]").length; p++) {
|
String[] phoneNumberSet1 = {phone.split("[,，]")[p]};
|
System.out.println(phoneNumberSet1);
|
req.setPhoneNumberSet(phoneNumberSet1);
|
|
req.setSmsSdkAppId("1400838975");
|
req.setSignName("北京华星北斗智控");
|
req.setTemplateId("2089627");
|
String[] templateParamSet1 = {String.valueOf("有使用的物联网卡还有" + (+num11 / 24 / 60 / 60 / 1000 + 1)), String.valueOf(cardList.get(j).getEnddate())};
|
req.setTemplateParamSet(templateParamSet1);
|
// String[] templateParamSet1 = {String.valueOf("您有流量卡将于：" + cardList.get(i).getEnddate() + "到期，")};
|
// req.setTemplateParamSet(templateParamSet1);
|
// 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
SendSmsResponse resp = client.SendSms(req);
|
System.out.println(SendSmsResponse.toJsonString(resp));
|
companyList.get(i).setSenddate(s);
|
//发送短信后修改公司发送短信字段和日期字段
|
QueryWrapper queryWrapper2 = new QueryWrapper();
|
queryWrapper2.eq("companyId", companyList.get(i).getCompanyid());
|
companyMapper.update(companyList.get(i), queryWrapper2);
|
// 输出json格式的字符串回包
|
Duanxinlog duanxinlog = new Duanxinlog();
|
duanxinlog.setIdentification(cardList.get(j).getCardnumber());
|
duanxinlog.setReceiver(cardList.get(j).getCompany());
|
duanxinlog.setNumber(phone.split("[,，]")[p]);
|
duanxinlog.setContent("您有使用的物联网卡还有" + (+num11 / 24 / 60 / 60 / 1000 + 1) + "天即将到期，请在" + cardList.get(j).getEnddate() + "之前续费，如已续费忽略该提示信息，拒收请回复R"
|
);
|
this.duanxinlogService.addDuanxinlog(duanxinlog);
|
break;
|
}
|
break;
|
}
|
// }
|
//判断结束日期距当前日期还有多久
|
|
}
|
|
|
|
|
|
}
|
}
|
|
}
|
}
|
// @PostMapping({"sendudp"})
|
// public Boolean sendudp(String message,String phone) {
|
//// String phone = "";
|
// // 假设物联网卡平台的短信接口地址
|
// String apiUrl = "https://api.spruceiot.cn/api/v1/sms/send";
|
// // 假设平台的API密钥
|
// String apiKey = "your_api_key_here";
|
// // 假设平台的短信模板ID（如果需要）
|
// String templateId = "your_template_id_here";
|
// String accessKey = "448c2cedcdce41428a290d144e81ab6e";
|
// String str = "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ";
|
// String accessSecret = "RgoIWycMYGmQfrLwLuT2VWawAhwMO8w7P9zh2dZp";
|
// // 构造请求参数
|
// Map<String, String> params = new HashMap<>();
|
// params.put("apiKey", apiKey);
|
// params.put("to", phone);
|
// params.put("message", message);
|
// params.put("templateId", templateId);
|
//
|
// try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
|
// HttpPost httpPost = new HttpPost(apiUrl);
|
// httpPost.setHeader("Content-Type", "application/json");
|
// httpPost.setEntity(new StringEntity(new ObjectMapper().writeValueAsString(params)));
|
//
|
// HttpResponse response = httpClient.execute(httpPost);
|
// HttpEntity responseEntity = response.getEntity();
|
//
|
// if (response.getStatusLine().getStatusCode() == 200) {
|
// // 发送成功
|
// return true;
|
// } else {
|
// // 发送失败
|
// System.out.println("Failed to send SMS: " + EntityUtils.toString(responseEntity));
|
// return false;
|
// }
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// return false;
|
// }
|
// }
|
|
@PostMapping({"sendudp"})
|
public JSONObject sendudp(String conext,String phone) throws Exception {
|
String accessKey = "448c2cedcdce41428a290d144e81ab6e";
|
String str = "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ";
|
String accessSecret = "RgoIWycMYGmQfrLwLuT2VWawAhwMO8w7P9zh2dZp";
|
String nonce = "";
|
Date now = new Date();
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMddHHmmss");
|
String Timestamp = dateFormat.format(now);
|
int length = 30;
|
Random random = new Random();
|
|
for (int i = length; i > 0; --i) {
|
int index = random.nextInt(str.length());
|
nonce = nonce + str.charAt(index);
|
}
|
|
String stringSignTemp = accessKey + nonce + Timestamp;
|
Mac sha256Hmac = Mac.getInstance("HmacSHA256");
|
SecretKeySpec secretKeySpec = new SecretKeySpec(accessSecret.getBytes(StandardCharsets.UTF_8), "HmacSHA256");
|
sha256Hmac.init(secretKeySpec);
|
byte[] hmacBytes = sha256Hmac.doFinal(stringSignTemp.getBytes(StandardCharsets.UTF_8));
|
String sign = Base64.getEncoder().encodeToString(hmacBytes);
|
String targetUrl = "https://api.spruceiot.cn/api/v1/sms/send";
|
URL url = new URL(targetUrl);
|
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
|
connection.setRequestMethod("POST");
|
connection.setDoOutput(true);
|
connection.setRequestProperty("Accept-Charset", "UTF-8");
|
connection.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
|
connection.setRequestProperty("Access-Control-Allow-Origin", "http://localhost:8080");
|
connection.setRequestProperty("AccessKey", accessKey);
|
connection.setRequestProperty("Nonce", nonce);
|
connection.setRequestProperty("Timestamp", Timestamp);
|
connection.setRequestProperty("Sign", sign);
|
|
// 构造请求体
|
JSONObject requestBody = new JSONObject();
|
requestBody.put("msisdn",phone );
|
requestBody.put("content", conext);
|
|
// 将请求体写入输出流
|
OutputStream os = connection.getOutputStream();
|
os.write(requestBody.toString().getBytes("UTF-8"));
|
os.flush();
|
os.close();
|
|
BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
|
StringBuilder response1 = new StringBuilder();
|
|
String line;
|
while ((line = reader.readLine()) != null) {
|
response1.append(line);
|
}
|
|
reader.close();
|
connection.disconnect();
|
JSONObject jsonObject = new JSONObject(response1);
|
int code = jsonObject.getInt("code");
|
String message = jsonObject.getStr("message");
|
JSONObject result = jsonObject.getJSONObject("result");
|
// int total1 = result.getInt("total");
|
// JSONArray list = result.getJSONArray("list");
|
|
// for (int i = 0; i < list.size(); ++i) {
|
// JSONObject item = list.getJSONObject(i);
|
// String msisdn = item.getStr("msisdn");
|
// String iccid = item.getStr("iccid");
|
// String imsi = item.getStr("imsi");
|
// System.out.println("msisdn: " + msisdn + ", iccid: " + iccid + ", imsi: " + imsi);
|
// }
|
// if (code!=0){
|
// return message;
|
// }else{
|
if (code!=0){
|
|
}else{
|
result.set("eStatus", this.getendlog());
|
}
|
return jsonObject;
|
// }
|
|
}
|
|
public String getendlog( ) throws Exception {
|
|
|
String accessKey = "448c2cedcdce41428a290d144e81ab6e";
|
String str = "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ";
|
String accessSecret = "RgoIWycMYGmQfrLwLuT2VWawAhwMO8w7P9zh2dZp";
|
String nonce = "";
|
Date now = new Date();
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMddHHmmss");
|
String Timestamp = dateFormat.format(now);
|
int length = 30;
|
Random random = new Random();
|
|
for (int i = length; i > 0; --i) {
|
int index = random.nextInt(str.length());
|
nonce = nonce + str.charAt(index);
|
}
|
|
String stringSignTemp = accessKey + nonce + Timestamp;
|
Mac sha256Hmac = Mac.getInstance("HmacSHA256");
|
SecretKeySpec secretKeySpec = new SecretKeySpec(accessSecret.getBytes(StandardCharsets.UTF_8), "HmacSHA256");
|
sha256Hmac.init(secretKeySpec);
|
byte[] hmacBytes = sha256Hmac.doFinal(stringSignTemp.getBytes(StandardCharsets.UTF_8));
|
String sign = Base64.getEncoder().encodeToString(hmacBytes);
|
String targetUrl = "https://api.spruceiot.cn/api/v1/sms/log/query?pageIndex=1&pageSize=1";
|
URL url = new URL(targetUrl);
|
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
|
connection.setRequestProperty("Accept-Charset", "UTF-8");
|
connection.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
|
connection.setRequestProperty("Access-Control-Allow-Origin", "http://localhost:8080");
|
connection.setRequestProperty("AccessKey", accessKey);
|
connection.setRequestProperty("Nonce", nonce);
|
connection.setRequestProperty("Timestamp", Timestamp);
|
connection.setRequestProperty("Sign", sign);
|
connection.connect();
|
BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
|
StringBuilder response1 = new StringBuilder();
|
|
String line;
|
while ((line = reader.readLine()) != null) {
|
response1.append(line);
|
}
|
|
reader.close();
|
connection.disconnect();
|
JSONObject jsonObject = new JSONObject(response1);
|
int code = jsonObject.getInt("code");
|
String message = jsonObject.getStr("message");
|
JSONObject result = jsonObject.getJSONObject("result");
|
JSONArray list = result.getJSONArray("list");
|
// if (code!=0){
|
// return "";
|
// }else{
|
// return result.get("status").toString();
|
// }
|
// for (int i = 0; i < list.size(); ++i) {
|
JSONObject item = list.getJSONObject(0);
|
// String msisdn = item.getStr("msisdn");
|
// String iccid = item.getStr("iccid");
|
// String imsi = item.getStr("imsi");
|
// System.out.println("msisdn: " + msisdn + ", iccid: " + iccid + ", imsi: " + imsi);
|
// }
|
if (item.get("status")=="3"){
|
return item.get("message").toString();
|
}else{
|
return item.get("status").toString();
|
}
|
|
}
|
|
@PostMapping({"send"})
|
public ModelAndView send(String phone,Integer id,String vname,String enddate) throws Exception {
|
|
SimpleDateFormat date2 = new SimpleDateFormat("yyyy-MM-dd");
|
Date date = new Date();
|
String s = date2.format(date);
|
QueryWrapper queryWrapper = new QueryWrapper();
|
queryWrapper.eq("none", "0");
|
queryWrapper.eq("num", id);
|
Card cardList = (cardMapper).selectOne(queryWrapper);
|
|
Date endDay = date2.parse(enddate);//结束时间
|
Long starTime = date.getTime();
|
Long endTime = endDay.getTime();
|
Long num11 = endTime - starTime;//时间戳
|
//判断结束日期距当前日期还有多久
|
|
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("2089627");
|
|
String[] templateParamSet1 = {String.valueOf("有使用的物联网卡还有"+num11 / 24 / 60 / 60 / 1000),String.valueOf(enddate)};
|
req.setTemplateParamSet(templateParamSet1);
|
// 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
SendSmsResponse resp = client.SendSms(req);
|
System.out.println(SendSmsResponse.toJsonString(resp));
|
Company companyList = this.companyMapper.findAllcompanycompany(cardList.getCompany());
|
companyList.setSenddate(s);
|
//发送短信后修改公司发送短信字段和日期字段
|
QueryWrapper queryWrapper2 = new QueryWrapper();
|
queryWrapper2.eq("companyId", companyList.getCompanyid());
|
companyMapper.update(companyList, queryWrapper2);
|
// 输出json格式的字符串回包
|
Duanxinlog duanxinlog = new Duanxinlog();
|
duanxinlog.setIdentification(cardList.getCardnumber());
|
duanxinlog.setReceiver(cardList.getCompany());
|
duanxinlog.setNumber(phone);
|
duanxinlog.setContent("您有使用的物联网卡还有"+num11 / 24 / 60 / 60 / 1000+"天即将到期，请在" + cardList.getEnddate() + "之前续费，如已续费忽略该提示信息，拒收请回复R"
|
);
|
this.duanxinlogService.addDuanxinlog(duanxinlog);
|
ModelAndView modelAndView = new ModelAndView();
|
if (Objects.equals(vname, "index")){
|
modelAndView.setViewName("/page/index1.jsp");
|
}else{
|
modelAndView.setViewName("/page/XinXi.jsp");
|
}
|
|
return modelAndView;
|
}
|
|
|
|
@PostMapping({"sendfuwu"})
|
public ModelAndView sendfuwu(String phone,Integer id,String vname) throws Exception {
|
SimpleDateFormat date2 = new SimpleDateFormat("yyyy-MM-dd");
|
Date date = new Date();
|
String s = date2.format(date);
|
QueryWrapper queryWrapper = new QueryWrapper();
|
queryWrapper.eq("none", "0");
|
queryWrapper.eq("id", id);
|
TbFuwuqi fuwuqiList = (tbFuwuqiMapper).selectOne(queryWrapper);
|
|
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("2100321");
|
String[] templateParamSet1 = {String.valueOf("您有服务器将于：" + fuwuqiList.getEnddate() + "到期，")};
|
req.setTemplateParamSet(templateParamSet1);
|
// 返回的resp是一个SendSmsResponse的实例，与请求对象对应
|
SendSmsResponse resp = client.SendSms(req);
|
System.out.println(SendSmsResponse.toJsonString(resp));
|
Company companyList = this.companyMapper.findAllcompanycompany(fuwuqiList.getCompany());
|
companyList.setSenddate(s);
|
//发送短信后修改公司发送短信字段和日期字段
|
QueryWrapper queryWrapper2 = new QueryWrapper();
|
queryWrapper2.eq("companyId", companyList.getCompanyid());
|
companyMapper.update(companyList, queryWrapper2);
|
// 输出json格式的字符串回包
|
Duanxinlog duanxinlog = new Duanxinlog();
|
duanxinlog.setIdentification(fuwuqiList.getServername());
|
duanxinlog.setReceiver(fuwuqiList.getCompany());
|
duanxinlog.setNumber(phone);
|
duanxinlog.setContent("尊敬的用户，您好！您有服务器将于" + fuwuqiList.getEnddate() + "到期，为避免影响您的正常使用请及时续费，您可登录华星智控公司物联网管理平台查询详情续费，如有疑问可咨询我公司客服人员，祝您生活愉快！"
|
);
|
this.duanxinlogService.addDuanxinlog(duanxinlog);
|
ModelAndView modelAndView = new ModelAndView();
|
if (Objects.equals(vname, "index")){
|
modelAndView.setViewName("/page/Fuwuqi.jsp");
|
}else{
|
modelAndView.setViewName("/page/XinXi.jsp");
|
}
|
|
return modelAndView;
|
}
|
}
|
