記錄移動雲MAS短信平台發送模板短信+獲取回執狀態

直接上代碼，清晰明了(所有發送短信代碼是寫在一個工具類)，也參考了網上一些博主的文章，非常感謝，以下內容只是記錄平時做東西的內容，如有不正確的地方，歡迎指正。

PS:（寫在前面）需要注意的幾個點：

（1）需要先在mas平台上配置相關信息和接口（主頁-管理-接口管理），https請求需要將短信平台上的短信接口創建為http協議模式，否則請求失敗；http請求同理，只要短信接口的用戶名、密碼和協議對應正確，一般沒有太大問題；

（2）如果是發送模板短信需要先申請短信模板，且傳入參數必須和模板中變量所包含的類型一致，否則mas平台上數據校驗無法通過（有條件還是獲取一下回執報告，因為有時候即使響應狀態返回success，最后沒有收到短信，進入平台查看可以看到其實回執狀態報錯，並沒有發送成功）;

（3）如果短信模板中的變量長度不能滿足需要，可以聯系客戶經理申請特殊變量，特殊變量一個模板中可以使用兩次；

  (4)https短信接口文檔中寫得很清楚：【請客戶側忽略證書校驗，移動側不提供證書秘鑰】，所以在做post請求的時候一定要記得【忽略證書校驗】，否則請求失敗，返回值為空；http請求不用管。

（5）短信響應狀態成功返回的是：{"msgGroup":"0906163415000000332084","rspcod":"success","success":true}，有錯誤的時候是：{ "msgGroup": "",    "rspcod": "InvalidUsrOrPwd",    "success": false}

（6）短信發送成功回執狀態返回的是“[]”，有錯誤的時候是：[{"errorCode":"CM:2007","mobile":"13888888888","msgGroup":"0906144506000001364223","receiveDate":"20210906244506","reportStatus":"CM:2007","submitDate":"20210906144506"}]

（7）上面說的其實平台上和提供的文檔中基本都有說明，多看提供的接口文檔，對實現自己想要的功能有幫助！！！

 

 

1.SMSUtil.java

a.通過https請求發送模板短信（網上很多的都是用http方式請求，只不過獲取回執狀態需要自己搭建http服務，太菜了感覺比較麻煩就采用了https請求，可以自己主動獲取回執報告，這個因人而異）

    /**
     * 雲MAS-發送模板短信(https)
     *
     * @param mobiles 手機號
     * @param templateId 模板id
     * @param param 參數列表
     * @return
     * @throws UnsupportedEncodingException
     */
    public static  AjaxResult sendTemplateSms(String mobiles, String templateId, List<String> param) throws UnsupportedEncodingException {
        apId="xxx";//用戶名
        secretKey="xxx";//密碼
        ecName = "xxx";    //集團名稱
        sign = "xxx";    //網關簽名編碼
        addSerial = "";    //拓展碼 填空
        templateurl = "https://112.35.10.201:28888/sms/tmpsubmit";//和http請求地址不一樣  http://112.35.1.155:1992/sms/tmpsubmit
 
        //發送短信--start--
        String params = null;
        if(param != null){
            params = JSON.toJSONString(param.toArray());
        }else{
            params = "[]";
        }
        SendRequest submitReq = new SendRequest();
        submitReq.setApId(apId);
        submitReq.setEcName(ecName);
        submitReq.setSecretKey(secretKey);
        submitReq.setParams(params);
        submitReq.setMobiles(mobiles);
        submitReq.setSign(sign);
        submitReq.setAddSerial(addSerial);
        submitReq.setTemplateId(templateId);

        StringBuffer stringBuffer = new StringBuffer();
        stringBuffer.append(submitReq.getEcName());
        stringBuffer.append(submitReq.getApId());
        stringBuffer.append(submitReq.getSecretKey());
        stringBuffer.append(submitReq.getTemplateId());
        stringBuffer.append(submitReq.getMobiles());
        stringBuffer.append(submitReq.getParams());
        stringBuffer.append(submitReq.getSign());
        stringBuffer.append(submitReq.getAddSerial());
        String encode = "";
        try {
            //接口要求參數為MD5加密后的值
            submitReq.setMac(Md5Utils.hash(stringBuffer.toString()));
            String reqText = JSON.toJSONString(submitReq);
            //base64編碼
            encode =new String(Base64.encodeBase64Chunked(reqText.getBytes("UTF-8")));  //有中文時使用UTF-8
        } catch (UnsupportedEncodingException e1) {
            e1.printStackTrace();
        }
        String resStr = "";
        try {
            resStr = new String(HttpUtils.sendPostTrust(templateurl,encode,"utf-8","POST"));//https鏈接
        } catch (Exception e) {
            e.printStackTrace();
        }
        //發送短信--end--

        //響應狀態、回執狀態處理--start--
        SendResponse sendRes = JSON.parseObject(resStr,SendResponse.class);//響應狀態
        String receiptReport=getReport(apId,secretKey,ecName);//回執狀態
        String errorCode="";
        if(receiptReport!="[]"){
            JSONArray jsonArray= JSONArray.parseArray(receiptReport);
            if(receiptReport.contains("errorCode")){
                for(int index=0;index<jsonArray.size();index++){
                    JSONObject jsonObject = jsonArray.getJSONObject(index);
                    if(jsonObject.getString("mobile").equals(mobiles)) {
                        errorCode=jsonObject.get("errorCode").toString();
                    }
                }
            }
        }
        else{
           errorCode="";
        }
        if(sendRes.getSuccess() && !"".equals(sendRes.getMsgGroup()) && "success".equals(sendRes.getRspcod())){
            switch (sendRes.getRspcod()) {
                case "success":
                    if (errorCode != null && errorCode != "") {
                        return AjaxResult.error(11, "其他錯誤：" + errorCode+",請聯系管理員!");
                    } else {
                        return AjaxResult.error(0, "發送成功");
                    }
                case "IllegalMac ":
                    return AjaxResult.error(1, "mac校驗不通過");
                case "IllegalSignId ":
                    return AjaxResult.error(2, "無效的簽名編碼");
                case "InvalidMessage ":
                    return AjaxResult.error(3, "非法消息，請求數據解析失敗");
                case "InvalidUsrOrPwd ":
                    return AjaxResult.error(4, "非法用戶名/密碼");
                case "NoSignId ":
                    return AjaxResult.error(5, "未匹配到對應的簽名信息");
                case "TooManyMobiles ":
                    return AjaxResult.error(6, "手機號數量超限,應≤5000");
                default:
                    return AjaxResult.error(-1, "系統異常");
            }
        }
        else{
            return AjaxResult.error(-2,"請求異常");
        }
        //響應狀態、回執狀態處理--end--
    }

    //獲取狀態報告
    public static String getReport(String apId,String secretKey,String ecName){
        String reporturl = "https://112.35.10.201:28888/sms/report";

        SendRequest submitReq = new SendRequest();
        submitReq.setApId(apId);
        submitReq.setEcName(ecName);
        submitReq.setSecretKey(secretKey);

        StringBuffer stringBuffer = new StringBuffer();
        stringBuffer.append(submitReq.getEcName());
        stringBuffer.append(submitReq.getApId());
        stringBuffer.append(submitReq.getSecretKey());
        stringBuffer.append(submitReq.getTemplateId());
        String encode = "";
        try {
            //接口要求參數為MD5加密后的值
            submitReq.setMac(Md5Utils.hash(stringBuffer.toString()));
            String reqText = JSON.toJSONString(submitReq);
            //base64編碼
            encode =new String(Base64.encodeBase64Chunked(reqText.getBytes("UTF-8")));  //有中文時使用UTF-8
        } catch (UnsupportedEncodingException e1) {
            e1.printStackTrace();
        }
        String receiptReport = "";
        try {
            receiptReport = new String(HttpUtils.sendPostTrust(reporturl,encode,"utf-8","POST"));//https鏈接

        } catch (Exception e) {
            e.printStackTrace();
        }
        return receiptReport;
    }

 

2.HttpUtils.java---->sendPostTrust

   //添加信任主機
    private static void trustAllHosts() {
        // 創建不驗證證書鏈的信任管理器 這里使用的是x509證書
        TrustManager[] trustAllCerts = new TrustManager[]{new TrustAnyTrustManager() {
            public java.security.cert.X509Certificate[] getAcceptedIssuers() {
                return new java.security.cert.X509Certificate[]{};
            }

            public void checkClientTrusted(X509Certificate[] chain, String authType) {
            }

            public void checkServerTrusted(X509Certificate[] chain, String authType) {
            }
        }};
        // 安裝所有信任的信任管理器
        try {
            SSLContext sc = SSLContext.getInstance("TLS");
            sc.init(null, trustAllCerts, new java.security.SecureRandom());
            //HttpsURLConnection通過SSLSocket來建立與HTTPS的安全連接，SSLSocket對象是由SSLSocketFactory生成的。
            HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     *  發送post 數據並忽略證書校驗
     * @param urls
     * @return
     */
    public static String sendPostTrust(String urls, String param, String contentType, String method) {
        StringBuffer sb=new StringBuffer();
        DataOutputStream out = null;
        BufferedReader responseReader = null;
        InputStream in1 = null;
        try {
            trustAllHosts();
            // 創建url資源
            URL url = new URL(urls);
            // 建立http連接
            HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();
            conn.setHostnameVerifier(DO_NOT_VERIFY);
            // 設置不用緩存
            conn.setUseCaches(false);
            // 設置允許輸出
            conn.setDoOutput(true);
            // 設置允許輸入
            conn.setDoInput(true);
            // 設置傳遞方式
            conn.setRequestMethod(method);
            //System.out.println(conn.getRequestMethod());
            // 設置維持長連接
            conn.setRequestProperty("Connection", "Keep-Alive");
            // 設置文件字符集:
            conn.setRequestProperty("Charset", "UTF-8");
            // 轉換為字節數組
//            byte[] data = (param).getBytes();
//            // 設置文件長度
//            conn.setRequestProperty("Content-Length", String.valueOf(data.length));
            // 設置文件類型:
            conn.setRequestProperty("Content-Type", contentType);
            // 開始連接請求
            conn.connect();
            out = new DataOutputStream(conn.getOutputStream());
            // 寫入請求的字符串
            out.writeBytes(param);
            out.flush();

            //System.out.println(conn.getResponseCode());

            // 請求返回的狀態
            if (HttpURLConnection.HTTP_OK == conn.getResponseCode()) {
                System.out.println("連接成功");
                // 請求返回的數據
                in1 = conn.getInputStream();
                String readLine;
                responseReader = new BufferedReader(new InputStreamReader(in1));
                while((readLine=responseReader.readLine()) != null){
                    sb.append(readLine).append("\n");
                }
            } else {
                System.out.println("error++");
            }
        } catch (Exception e) {

        } finally {
            try {
                if (null != responseReader)
                    responseReader.close();
                if (null != in1)
                    in1.close();
            } catch(Exception e) {}
            try {
                out.close();
            } catch(Exception e) {}
        }

        return sb.toString();

    }