package com.matrix.system.shopXcx.api.tools;
|
|
import com.alibaba.fastjson.JSON;
|
import com.matrix.core.tools.LogUtil;
|
import com.matrix.system.shopXcx.api.tools.model.request.SmsSendRequest;
|
import com.matrix.system.shopXcx.api.tools.model.response.SmsSendResponse;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
|
import java.io.BufferedReader;
|
import java.io.InputStreamReader;
|
import java.io.OutputStream;
|
import java.net.HttpURLConnection;
|
import java.net.URL;
|
|
/**
|
* @author jiangyouyao
|
*/
|
@Service("sMSVerifiTools")
|
public class SMSVerifiTools {
|
/**
|
* 用户平台API账号(非登录账号,示例:N1234567)
|
*/
|
@Value("${sms.login_accountNe}")
|
private String loginAccount;
|
/**
|
* 用户平台API密码(非登录密码)
|
*/
|
@Value("${sms.login_passwordNe}")
|
private String loginPassword;
|
/**
|
* 用户平台请求URL
|
*/
|
@Value("${sms.request_url}")
|
private String requestUrl;
|
|
/**
|
* @param phone 手机号码
|
* @param msg 短信内容
|
* @return
|
*/
|
public SmsSendResponse sendMsg(String phone, String msg) {
|
//请求地址请登录253云通讯自助通平台查看或者询问您的商务负责人获取
|
String smsSingleRequestServerUrl = requestUrl + "/msg/send/json";
|
msg = "【新诚智慧】" + msg;
|
//状态报告
|
String report = "true";
|
SmsSendRequest smsSingleRequest = new SmsSendRequest(loginAccount, loginPassword, msg, phone, report);
|
String requestJson = JSON.toJSONString(smsSingleRequest);
|
LogUtil.info("sendMsg requestParam: {}", requestJson);
|
String response = sendSmsByPost(smsSingleRequestServerUrl, requestJson);
|
SmsSendResponse smsSingleResponse = JSON.parseObject(response, SmsSendResponse.class);
|
LogUtil.info("sendMsg response: {}", smsSingleResponse.toString());
|
return smsSingleResponse;
|
}
|
|
public String sendSmsByPost(String path, String postContent) {
|
URL url;
|
try {
|
url = new URL(path);
|
HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection();
|
// 提交模式
|
httpURLConnection.setRequestMethod("POST");
|
//连接超时 单位毫秒
|
httpURLConnection.setConnectTimeout(10000);
|
//读取超时 单位毫秒
|
httpURLConnection.setReadTimeout(10000);
|
|
// 发送POST请求必须设置如下两行
|
httpURLConnection.setDoOutput(true);
|
httpURLConnection.setDoInput(true);
|
httpURLConnection.setRequestProperty("Charset", "UTF-8");
|
httpURLConnection.setRequestProperty("Content-Type", "application/json");
|
// PrintWriter printWriter = new PrintWriter(httpURLConnection.getOutputStream());
|
// printWriter.write(postContent);
|
// printWriter.flush();
|
httpURLConnection.connect();
|
OutputStream os = httpURLConnection.getOutputStream();
|
os.write(postContent.getBytes("UTF-8"));
|
os.flush();
|
StringBuilder sb = new StringBuilder();
|
int httpRspCode = httpURLConnection.getResponseCode();
|
if (httpRspCode == HttpURLConnection.HTTP_OK) {
|
// 开始获取数据
|
BufferedReader br = new BufferedReader(
|
new InputStreamReader(httpURLConnection.getInputStream(), "utf-8"));
|
String line = null;
|
while ((line = br.readLine()) != null) {
|
sb.append(line);
|
}
|
br.close();
|
return sb.toString();
|
}
|
} catch (Exception e) {
|
LogUtil.error("发送请求失败", e);
|
return null;
|
}
|
return null;
|
}
|
|
}
|
