package smsmoduyun.v1.yun;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import java.io.BufferedReader;
|
import java.io.InputStreamReader;
|
import java.io.OutputStreamWriter;
|
import java.net.HttpURLConnection;
|
import java.util.ArrayList;
|
|
|
public class SmsSingleSender {
|
String accesskey;
|
String secretkey;
|
// 同时支持http和https两种协议，具体根据自己实际情况使用。
|
String url = "https://live.mordula.com/sms/v1/sendsinglesms";
|
private static int TIMEOUT = 30 * 1000;
|
|
SmsSenderUtil util = new SmsSenderUtil();
|
|
public SmsSingleSender(String accesskey, String secretkey) throws Exception {
|
this.accesskey = accesskey;
|
this.secretkey = secretkey;
|
}
|
|
/**
|
* 普通单发短信接口，明确指定内容，如果有多个签名，请在内容中以【】的方式添加到信息内容中，否则系统将使用默认签名
|
*
|
* @param type 短信类型，0 为普通短信，1 营销短信
|
* @param nationCode 国家码，如 86 为中国
|
* @param phoneNumber 不带国家码的手机号
|
* @param msg 信息内容，必须与申请的模板格式一致，否则将返回错误
|
* @param extend 扩展码，可填空
|
* @param ext 服务端原样返回的参数，可填空
|
* @return {@link}SmsSingleSenderResult
|
* @throws Exception
|
*/
|
public SmsSingleSenderResult send(int type, String nationCode, String phoneNumber, String msg, String extend,
|
String ext) throws Exception {
|
/*
|
* 请求包体 { "tel": { "nationcode": "86", "mobile": "13788888888" }, "type": 0,
|
* "msg": "你的验证码是1234", "sig": "fdba654e05bc0d15796713a1a1a2318c", "time":
|
* 1479888540, "extend": "", "ext": "" } 应答包体 { "result": 0, "errmsg": "OK",
|
* "ext": "", "sid": "xxxxxxx", "fee": 1 }
|
*/
|
// 校验 type 类型
|
if (0 != type && 1 != type) {
|
throw new Exception("type " + type + " error");
|
}
|
if (null == extend) {
|
extend = "";
|
}
|
if (null == ext) {
|
ext = "";
|
}
|
|
// 按照协议组织 post 请求包体
|
long random = util.getRandom();
|
long curTime = System.currentTimeMillis() / 1000;
|
|
JSONObject data = new JSONObject();
|
|
JSONObject tel = new JSONObject();
|
tel.put("nationcode", nationCode);
|
tel.put("mobile", phoneNumber);
|
|
data.put("type", type);
|
data.put("msg", msg);
|
data.put("sig", util.strToHash(
|
String.format("secretkey=%s&random=%d&time=%d&mobile=%s", secretkey, random, curTime, phoneNumber)));
|
data.put("tel", tel);
|
data.put("time", curTime);
|
data.put("extend", extend);
|
data.put("ext", ext);
|
|
// 与上面的 random 必须一致
|
String wholeUrl = String.format("%s?accesskey=%s&random=%d", url, accesskey, random);
|
HttpURLConnection conn = util.getPostHttpConn(wholeUrl);
|
|
conn.setConnectTimeout(TIMEOUT);
|
conn.setReadTimeout(TIMEOUT);
|
|
OutputStreamWriter wr = new OutputStreamWriter(conn.getOutputStream(), "utf-8");
|
|
wr.write(data.toString());
|
wr.flush();
|
System.out.println(wholeUrl);
|
System.out.println(data.toString());
|
|
// 显示 POST 请求返回的内容
|
StringBuilder sb = new StringBuilder();
|
int httpRspCode = conn.getResponseCode();
|
SmsSingleSenderResult result;
|
if (httpRspCode == HttpURLConnection.HTTP_OK) {
|
BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream(), "utf-8"));
|
String line = null;
|
while ((line = br.readLine()) != null) {
|
sb.append(line);
|
}
|
br.close();
|
JSONObject json = JSONObject.parseObject(sb.toString());
|
result = util.jsonToSmsSingleSenderResult(json);
|
} else {
|
result = new SmsSingleSenderResult();
|
result.result = httpRspCode;
|
result.errMsg = "http error " + httpRspCode + " " + conn.getResponseMessage();
|
}
|
|
return result;
|
}
|
|
/**
|
* 指定模板单发
|
*
|
* @param nationCode 国家码，如 86 为中国
|
* @param phoneNumber 不带国家码的手机号
|
* @param templId 信息内容
|
* @param params 模板参数列表，如模板 {1}...{2}...{3}，那么需要带三个参数
|
* @param sign 签名，如果填空，系统会使用默认签名
|
* @param extend 扩展码，可填空
|
* @param ext 服务端原样返回的参数，可填空
|
* @return {@link}SmsSingleSenderResult
|
* @throws Exception
|
*/
|
public SmsSingleSenderResult sendWithParam(String nationCode, String phoneNumber, int templId,
|
ArrayList<String> params, String sign, String extend, String ext) throws Exception {
|
/*
|
* 请求包体 { "tel": { "nationcode": "86", "mobile": "13788888888" }, "sign":
|
* "Kewail云", "tpl_id": 19, "params": [ "验证码", "1234", "4" ], "sig":
|
* "fdba654e05bc0d15796713a1a1a2318c", "time": 1479888540, "extend": "", "ext":
|
* "" } 应答包体 { "result": 0, "errmsg": "OK", "ext": "", "sid": "xxxxxxx", "fee":
|
* 1 }
|
*/
|
if (null == nationCode || 0 == nationCode.length()) {
|
nationCode = "86";
|
}
|
if (null == params) {
|
params = new ArrayList<>();
|
}
|
if (null == sign) {
|
sign = "";
|
}
|
if (null == extend) {
|
extend = "";
|
}
|
if (null == ext) {
|
ext = "";
|
}
|
|
long random = util.getRandom();
|
long curTime = System.currentTimeMillis() / 1000;
|
|
JSONObject data = new JSONObject();
|
|
JSONObject tel = new JSONObject();
|
tel.put("nationcode", nationCode);
|
tel.put("mobile", phoneNumber);
|
|
data.put("tel", tel);
|
data.put("sig", util.calculateSigForTempl(secretkey, random, curTime, phoneNumber));
|
data.put("tpl_id", templId);
|
data.put("params", util.smsParamsToJSONArray(params));
|
data.put("sign", sign);
|
data.put("time", curTime);
|
data.put("extend", extend);
|
data.put("ext", ext);
|
|
String wholeUrl = String.format("%s?accesskey=%d&random=%d", url, accesskey, random);
|
HttpURLConnection conn = util.getPostHttpConn(wholeUrl);
|
conn.setConnectTimeout(TIMEOUT);
|
conn.setReadTimeout(TIMEOUT);
|
OutputStreamWriter wr = new OutputStreamWriter(conn.getOutputStream(), "utf-8");
|
wr.write(data.toString());
|
wr.flush();
|
|
// 显示 POST 请求返回的内容
|
StringBuilder sb = new StringBuilder();
|
int httpRspCode = conn.getResponseCode();
|
SmsSingleSenderResult result;
|
if (httpRspCode == HttpURLConnection.HTTP_OK) {
|
BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream(), "utf-8"));
|
String line = null;
|
while ((line = br.readLine()) != null) {
|
sb.append(line);
|
}
|
br.close();
|
JSONObject json = JSONObject.parseObject(sb.toString());
|
result = util.jsonToSmsSingleSenderResult(json);
|
} else {
|
result = new SmsSingleSenderResult();
|
result.result = httpRspCode;
|
result.errMsg = "http error " + httpRspCode + " " + conn.getResponseMessage();
|
}
|
|
return result;
|
}
|
|
public static void main(String[] args) throws Exception {
|
SmsSenderUtil util = new SmsSenderUtil();
|
HttpURLConnection conn = util.getPostHttpConn("https://www.baidu.com");
|
|
conn.setConnectTimeout(TIMEOUT);
|
conn.setReadTimeout(TIMEOUT);
|
|
OutputStreamWriter wr = new OutputStreamWriter(conn.getOutputStream(), "utf-8");
|
wr.write("");
|
wr.flush();
|
}
|
}
|
