基于SpringBoot+Avue實現短信通知功能

更新時間：2023年09月19日 09:45:20 作者：DaenCode

Avue是基于vue和element-ui的快速開發(fā)框架 ,它的核心是數據驅動UI的思想,讓我們從繁瑣的crud開發(fā)中解脫出來,本文將給大家介紹一下使用SpringBoot+Avue實現短信通知功能,文中有詳細的代碼示例,需要的朋友可以參考下

前置介紹

Avue是基于vue和element-ui的快速開發(fā)框架。它的核心是數據驅動UI的思想，讓我們從繁瑣的crud開發(fā)中解脫出來，它的寫法類似easyUI，但是寫起來比easyui更容易，因為它是基礎數據雙向綁定以及其他vue的特性。同時不知局限于crud，它還有我們經常用的一些組件例如，表單，數據展示卡，人物展示卡等等組件。

一.官網參照

云MAS業(yè)務平臺_中國移動

二.實現方式

基于HTTPS方式云MAS平臺

三.使用文檔

可以在云MAS官網進行下載,下方文檔存放在了我的語雀筆記中。下載時注意下載HTTPS文檔，內含接口使用規(guī)范。

HTTPS短信接口文檔.docx

四.代碼實現

4.1.接口對接代碼

4.1.1.SMSHttpClient.java—接口調用

此類為對接云MAS平臺接口的類。

import com.alibaba.fastjson.JSON;
import org.apache.commons.codec.binary.Base64;
import org.springframework.util.DigestUtils;
import javax.net.ssl.*;
import java.io.*;
import java.net.URL;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
public class SMSHttpClient {
    private static String apId="";//用戶名
    private static String secretKey="";//密碼
    private static String ecName = "";//集團名稱   接口聯(lián)調賬號  zsywz
    private static String sign = "";//網關簽名編碼
    private static String addSerial = "106509773";//拓展碼 填空
    private static String templateid = "";//模板ID
    public static String msg = "123456";
    public static String url = "https://****:28888/sms/tmpsubmit";//請求url
    public static int sendMsg(String mobiles,String content) throws UnsupportedEncodingException {
        SendReq sendReq = new SendReq();
        String [] params = {"content","test","test2"};
        sendReq.setEcName(ecName);
        sendReq.setApId(apId);
        sendReq.setSecretKey(secretKey);
        sendReq.setMobiles(mobiles);
        sendReq.setParams(JSON.toJSONString(params));
        sendReq.setSign(sign);
        sendReq.setAddSerial(addSerial);
        sendReq.setTemplateId(templateid);
        StringBuffer stringBuffer = new StringBuffer();
        stringBuffer.append(sendReq.getEcName());
        stringBuffer.append(sendReq.getApId());
        stringBuffer.append(sendReq.getSecretKey());
        stringBuffer.append(sendReq.getTemplateId());
        stringBuffer.append(sendReq.getMobiles());
        stringBuffer.append(sendReq.getParams());
        stringBuffer.append(sendReq.getSign());
        stringBuffer.append(sendReq.getAddSerial());
        System.out.println(stringBuffer.toString());
        sendReq.setMac(DigestUtils.md5DigestAsHex(stringBuffer.toString().getBytes("UTF-8")).toLowerCase());
        System.out.println(sendReq.getMac());
        String reqText = JSONUtils.obj2json(sendReq);
        System.out.println("發(fā)送短信參數："+reqText);
        String encode = Base64.encodeBase64String(reqText.getBytes("UTF-8"));
        System.out.println("發(fā)送短信base64："+encode);
        //System.out.println(encode);
        String resStr = sendPost(url,encode);
        System.out.println("發(fā)送短信結果："+resStr);
        System.out.println(new  String(Base64.decodeBase64(encode)));
        SendRes sendRes = JSONUtils.json2pojo(resStr,SendRes.class);
        if(sendRes.isSuccess() && !"".equals(sendRes.getMsgGroup()) && "success".equals(sendRes.getRspcod())){
            return 1;
        }else{
            return 0;
        }
    }
    /**
* main方法測試發(fā)送短信，返回1表示成功，0表示失敗
*/
    public static void main(String[] args) throws UnsupportedEncodingException {
        int result = sendMsg("手機號",msg);
        System.out.println(result);
        //        System.out.println( Md5Util.MD5(Hex.encodeHexString("demo0123qwe38516fabae004eddbfa3ace1d419469613800138000[\"abcde\"]4sEuJxDpC".getBytes(StandardCharsets.UTF_8))));
    }
    /**
* 向指定 URL 發(fā)送POST方法的請求
*
* @param url
*            發(fā)送請求的 URL
* @param param
*            請求參數
* @return 所代表遠程資源的響應結果
*/
    private static String sendPost(String url, String param) {
    OutputStreamWriter out = null;
    BufferedReader in = null;
    String result = "";
    try {
    URL realUrl = new URL(url);
    trustAllHosts();
    HttpsURLConnection conn = (HttpsURLConnection) realUrl.openConnection();
    conn.setHostnameVerifier(DO_NOT_VERIFY);
    conn.setRequestProperty("accept", "*/*");
    conn.setRequestProperty("contentType","utf-8");
    conn.setRequestProperty("connection", "Keep-Alive");
    conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)");
    conn.setDoOutput(true);
    conn.setDoInput(true);
    out = new OutputStreamWriter(conn.getOutputStream());
    out.write(param);
    out.flush();
    in = new BufferedReader(
    new InputStreamReader(conn.getInputStream()));
    String line;
    while ((line = in.readLine()) != null) {
    result += "\n" + line;
    }
    } catch (Exception e) {
    e.printStackTrace();
    } finally {
    try {
    if (out != null) {
    out.close();
    }
    if (in != null) {
    in.close();
    }
    } catch (IOException ex) {
    ex.printStackTrace();
    }
    }
    return result;
    }
    /**
    * 不檢查任何證書
    */
    private static void trustAllHosts() {
    final String TAG = "trustAllHosts";
    // 創(chuàng)建信任管理器
    TrustManager[] trustAllCerts = new TrustManager[]{new X509TrustManager() {
    public java.security.cert.X509Certificate[] getAcceptedIssuers() {
    return new java.security.cert.X509Certificate[]{};
    }
    public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {
    //                Log.i(TAG, "checkClientTrusted");
    }
    public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {
    //                Log.i(TAG, "checkServerTrusted");
    }
    }};
    // Install the all-trusting trust manager
    try {
    SSLContext sc = SSLContext.getInstance("TLS");
    sc.init(null, trustAllCerts, new java.security.SecureRandom());
    HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory());
    } catch (Exception e) {
    e.printStackTrace();
    }
    }
    final static HostnameVerifier DO_NOT_VERIFY = new HostnameVerifier() {
    public boolean verify(String hostname, SSLSession session) {
    return true;
    }	//將所有驗證的結果都設為true
    };
    }

4.1.2.JSONUtils—JSON工具

此類為JSON處理類

import com.fasterxml.jackson.core.JsonParseException;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.JsonMappingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
 * @author daencode
 * @description  json工具
 */
public class JSONUtils {
    private final static ObjectMapper objectMapper = new ObjectMapper();
    private static Logger log = LoggerFactory.getLogger(JSONUtils.class);
    private JSONUtils() {
    }
    public static ObjectMapper getInstance() {
        return objectMapper;
    }
    /**
     * javaBean,list,array convert to json string
     */
    public static String obj2json(Object obj) {
        try {
            return objectMapper.writeValueAsString(obj);
        } catch (JsonProcessingException e) {
            // TODO Auto-generated catch block
            log.error(e.getMessage());
        }
        return null;
    }
    /**
     * javaBean,list,array convert to json string
     */
    public static String obj2jsonInoreString(Object obj)  {
        try {
            return objectMapper.writeValueAsString(obj);
        } catch (JsonProcessingException e) {
            // TODO Auto-generated catch block
            log.error(e.getMessage());
        }
        return null;
    }
    /**
     * json string convert to javaBean
     */
    public static <T> T json2pojo(String jsonStr, Class<T> clazz) {
        try {
            return objectMapper.readValue(jsonStr, clazz);
        } catch (JsonParseException e) {
            // TODO Auto-generated catch block
            log.error(e.getMessage());
        } catch (JsonMappingException e) {
            // TODO Auto-generated catch block
            log.error(e.getMessage());
        } catch (IOException e) {
            // TODO Auto-generated catch block
            log.error(e.getMessage());
        }
        return null;
    }
    /**
     * json string convert to map
     */
    public static <T> Map<String, Object> json2map(String jsonStr) {
        try {
            return objectMapper.readValue(jsonStr, Map.class);
        } catch (JsonParseException e) {
            // TODO Auto-generated catch block
            log.error(e.getMessage());
        } catch (JsonMappingException e) {
            // TODO Auto-generated catch block
            log.error(e.getMessage());
        } catch (IOException e) {
            // TODO Auto-generated catch block
            log.error(e.getMessage());
        }
        return null;
    }
    /**
     * json string convert to map with javaBean
     */
    public static <T> Map<String, T> json2map(String jsonStr, Class<T> clazz){
        Map<String, Map<String, Object>> map = null;
        try {
            map = (Map<String, Map<String, Object>>) objectMapper.readValue(jsonStr,
                    new TypeReference<Map<String, T>>() {
                    });
        } catch (JsonParseException e) {
            // TODO Auto-generated catch block
            log.error(e.getMessage());
        } catch (JsonMappingException e) {
            // TODO Auto-generated catch block
            log.error(e.getMessage());
        } catch (IOException e) {
            // TODO Auto-generated catch block
            log.error(e.getMessage());
        }
        Map<String, T> result = new HashMap<String, T>();
        for (Map.Entry<String, Map<String, Object>> entry : map.entrySet()) {
            result.put(entry.getKey(), map2pojo(entry.getValue(), clazz));
        }
        return result;
    }
    /**
     * json array string convert to list with javaBean
     */
    public static <T> List<T> json2list(String jsonArrayStr, Class<T> clazz)
    {
        List<Map<String, Object>> list = null;
        try {
            list = (List<Map<String, Object>>) objectMapper.readValue(jsonArrayStr,
                    new TypeReference<List<T>>() {
                    });
        } catch (JsonParseException e) {
            // TODO Auto-generated catch block
            log.error(e.getMessage());
        } catch (JsonMappingException e) {
            // TODO Auto-generated catch block
            log.error(e.getMessage());
        } catch (IOException e) {
            // TODO Auto-generated catch block
            log.error(e.getMessage());
        }
        List<T> result = new ArrayList<T>();
        for (Map<String, Object> map : list) {
            result.add(map2pojo(map, clazz));
        }
        return result;
    }
    /**
     * map convert to javaBean
     */
    public static <T> T map2pojo(Map map, Class<T> clazz) {
        return objectMapper.convertValue(map, clazz);
    }
}

4.1.3.SendReq.java—請求實體

此類為發(fā)送短信的請求實體。

/**
 * 發(fā)送短信請求實體
 */
public class SendReq {
    private String ecName;//集團客戶名稱
    private String apId;//用戶名
    private String secretKey;//密碼
    private String mobiles;//手機號碼逗號分隔。(如“18137282928,18137282922,18137282923”)
//    private String content;//發(fā)送短信內容
    private String params;//發(fā)送短信內容
    private String sign;//網關簽名編碼，必填，簽名編碼在中國移動集團開通帳號后分配，可以在云MAS網頁端管理子系統(tǒng)-SMS接口管理功能中下載。
    private String addSerial;//擴展碼，根據向移動公司申請的通道填寫，如果申請的精確匹配通道，則填寫空字符串("")，否則添加移動公司允許的擴展碼。
    private String mac;//API輸入參數簽名結果，簽名算法：將ecName，apId，secretKey，mobiles，content ，sign，addSerial按照順序拼接，然后通過md5(32位小寫)計算后得出的值。
    /**
     * 模板id
     */
    private String templateId;
    public String getEcName() {
        return ecName;
    }
    public void setEcName(String ecName) {
        this.ecName = ecName;
    }
    public String getApId() {
        return apId;
    }
    public void setApId(String apId) {
        this.apId = apId;
    }
    public String getSecretKey() {
        return secretKey;
    }
    public void setSecretKey(String secretKey) {
        this.secretKey = secretKey;
    }
    public String getMobiles() {
        return mobiles;
    }
    public void setMobiles(String mobiles) {
        this.mobiles = mobiles;
    }
//    public String getContent() {
//        return content;
//    }
//
//    public void setContent(String content) {
//        this.content = content;
//    }
    public String getSign() {
        return sign;
    }
    public void setSign(String sign) {
        this.sign = sign;
    }
    public String getAddSerial() {
        return addSerial;
    }
    public void setAddSerial(String addSerial) {
        this.addSerial = addSerial;
    }
    public String getMac() {
        return mac;
    }
    public void setMac(String mac) {
        this.mac = mac;
    }
    public String getTemplateId() {
        return templateId;
    }
    public void setTemplateId(String templateId) {
        this.templateId = templateId;
    }
    public String getParams() {
        return params;
    }
    public void setParams(String params) {
        this.params = params;
    }
}

4.1.4.SendRes.java—響應實體

此類為發(fā)送短信的響應實體。

/**
 * 發(fā)送短信響應實體
 */
public class SendRes {
    private String rspcod;//響應碼
    private String msgGroup;//消息批次號，由云MAS平臺生成，用于驗證短信提交報告和狀態(tài)報告的一致性（取值msgGroup）注:如果數據驗證不通過msgGroup為空
    private boolean success;
    public String getRspcod() {
        return rspcod;
    }
    public void setRspcod(String rspcod) {
        this.rspcod = rspcod;
    }
    public String getMsgGroup() {
        return msgGroup;
    }
    public void setMsgGroup(String msgGroup) {
        this.msgGroup = msgGroup;
    }
    public boolean isSuccess() {
        return success;
    }
    public void setSuccess(boolean success) {
        this.success = success;
    }
}

4.2.功能實現代碼

此JS文件為Avue框架中封裝的統(tǒng)一JS文件，在此文件中存放統(tǒng)一業(yè)務的前端接口。

4.2.1.封裝統(tǒng)一接口js文件

export const noteCompany = (itemType) => {
  return request({
  url: '接口地址',
  method: 'post',
  params: {
  itemType,
  }
  })
  }

4.2.2.功能頁面文件

此文件為頁面文件中功能按鈕部分代碼（觸發(fā)發(fā)送短信的功能按鈕）

//按鈕
  <el-button :type="type"
    icon="el-icon-check" 
    :size="size" 
    @click.native="note(row)">短信通知
    </el-button>
      //方法，根據類型匹配查出相應接收短信的人員
      note(row){
        noteCompany(row.itemType).then(() => {
          this.onLoad(this.page);
          this.$message({
            type: "success",
            message:"成功發(fā)送"
          });
        }
        );
      },

4.2.3.Controller層接口

下方為后端代碼中Controller層觸發(fā)短信功能的代碼。

/**
* 短信通知
*/
@PostMapping("/noteCompany")
    @ApiOperationSupport(order = 6)
    @ApiOperation(value = "短信通知", notes = "傳入project")
    public R noteCompany(String itemType) throws UnsupportedEncodingException {
    //查詢條件
    List<String> companyIds=projectService.getCompanyByItem(itemType);
    for (int i=0;i<companyIds.size();i++){
        String companyId="";
        companyId=companyIds.get(i);
        String mobile=projectService.getMobile(companyId);
        SMSHttpClient.sendMsg(mobile, msg);
    }
    return R.success("成功發(fā)送"+companyIds.size()+"信息");
}

以上就是基于SpringBoot+Avue實現短信通知功能的詳細內容，更多關于SpringBoot+Avue短信通知功能的資料請關注腳本之家其它相關文章！

您可能感興趣的文章: