xinbi-new.git - Gitblit

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();
    }
}