微信小程序消息推送

微信小程序是支持消息推送的，可是推送有個限制，只有form表單開啓report-submit，用戶點擊提交這樣表單的時候才能夠得到一個formid，推送時須要使用這個formid進行推送。因此小程序消息推送須要解決formid的存儲，小程序內部接口調用是AccessToken認證兩大問題。消息模板申請這裏就不細說了。

1.獲取formid並儲存

在小程序上 表單form上添加一個report-submit <form bindsubmit='commitForm' report-submit='true'> 這樣在在提交表單的時候就能夠得到到這個formid。

commitForm:function(e){
//獲取formid
   var fromId = e.detail.formId;
}
複製代碼

獲取到formid後只須要在提交這個表單的時候把formid一塊兒帶到後臺而後進行使用數據庫進行保存就能夠了。保存formid是最好把插入時間一塊兒加上，這樣能夠方便刪除已通過了七天失效的formid。

這裏須要注意的是每個formid只能使用一次，且只有七天的時效。

因此咱們須要使用Quartz任務調度定時清理掉超過七天失效的formid。

/** * 微信小程序刪除過時formid 天天執行一次 */
    @Scheduled(cron = "0 00 0 * * ?")
    @Transactional
    public void clearTimeoutFormId() {
        //執行sql清理過時未用的formId
        miniprogramFormIdMapper.deleteFormIdByTimeout();
    }
複製代碼

2. 獲取小程序AccessToken

官方說明：access_token 是小程序全局惟一後臺接口調用憑據，調用絕大多數後臺接口時都需使用。開發者能夠經過 getAccessToken 接口獲取並進行妥善保存。

也就是服務端須要小程序的接口必須攜帶微信官方派發的accessToken令牌做爲身份驗證。這個accessToken只有2小時的時效性，每獲取一次上次的的accessToken就會失效，爲了保證效率須要使用定時器90分鐘自動更新一次，每次須要使用accessToken就直接從數據庫去獲取便可，不用在請求微信小程序接口獲取。

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.URL;
import java.net.URLConnection;

/** * 獲取小程序全局惟一後臺接口調用憑據 access_token 每90分鐘執行一次 */
    @Scheduled(cron = "0 */90 * * * ?")
    @Transactional
    public void getWechatMiniprogramAccessToken() {
        //發送GET請求
        String result = "";
        BufferedReader in = null;
        try {
            String urlNameString = "https://api.weixin.qq.com/cgi-bin/token?" + "grant_type=client_credential&secret=123123&appid=456456";
            URL realUrl = new URL(urlNameString);
            // 打開和URL之間的鏈接
            URLConnection connection = realUrl.openConnection();
            // 設置通用的請求屬性
            connection.setRequestProperty("accept", "*/*");
            connection.setRequestProperty("connection", "Keep-Alive");
            connection.setRequestProperty("user-agent",
                    "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
            // 創建實際的鏈接
            connection.connect();
            // 定義 BufferedReader輸入流來讀取URL的響應
            in = new BufferedReader(new InputStreamReader(
                    connection.getInputStream()));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        // 使用finally塊來關閉輸入流
        finally {
            try {
                if (in != null) {
                    in.close();
                }
            } catch (Exception e2) {
                e2.printStackTrace();
            }
        }

        // 解析相應內容（轉換成json對象）
        JSONObject resultJson = JSON.parseObject(result);
        //拿到accesstoken
        String accesstoken = (String) resultJson.get("access_token");
        //保存accesstoken到數據庫
        miniprogramFormIdMapper.insertAccessToken(accesstoken);
    }
複製代碼

3.發送消息模板

有了formid和accessToken以後咱們就能夠發送消息推送了。

爲了方便咱們對消息模板的內容進行設置，最好聲明對象進行儲存，而後直接用過fastJson將對象轉成json發送給小程序消息推送接口就能夠完成消息推送。

發送消息模板對象

import java.util.Map;

public class WeiXinTeamplateMsg {
    private String touser;//用戶openid
    private String template_id;//模版id
    private String page = "index";//默認跳到小程序首頁
    private String form_id;//收集到的用戶formid
    private String emphasis_keyword = "keyword1.DATA";//放到那個推送字段
    private Map<String, TemplateData> data;//推送文字

    //getter and setter
    //.....
}
複製代碼

消息內容對象

public class TemplateData {
    private String value;

     //getter and setter
    //.....
}
複製代碼

以小程序消息模版庫中模版編號爲模板ID：AT1633 標題：客服回覆通知的模板爲例。

發送消息的方法

import model.TemplateData;
import model.WeiXinTeamplateMsg;
import util.*;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.URL;
import java.net.URLConnection;
import java.security.PrivateKey;
import java.security.PublicKey;
import java.util.HashMap;
import java.util.Map;
import java.util.ResourceBundle;

	/** * 微信小程序推送單個用戶 * * @param access_token 令牌 * @param openId 小程序用戶openId * @param formid 推送formid * @param value1 客服類型 * @param value2 回覆時間 * @param value3 回覆內容 * @param value4 詢問時間 * @param value5 詢問事項 * @param value6 舒適提示 * @return */
    public static String pushTicketReplyMsgToUser(String access_token, String openId, String formid, String value1, String value2, String value3, String value4, String value5, String value6) {
        String url = "https://api.weixin.qq.com/cgi-bin/message/wxopen/template/send?access_token=" + access_token;

        //拼接推送的模版
        WeiXinTeamplateMsg weiXinTeamplateMsg = new WeiXinTeamplateMsg();
        weiXinTeamplateMsg.setTouser(openId);//用戶openid
        weiXinTeamplateMsg.setTemplate_id("Xs1515168sdaddd15aDASda6");//申請的消息模版id
        weiXinTeamplateMsg.setForm_id(formid);//formid
        weiXinTeamplateMsg.setPage("index");//跳轉的頁面


        Map<String, TemplateData> msgMap = new HashMap<>(5);

        TemplateData keyword1 = new TemplateData();
        keyword1.setValue(value1);
        msgMap.put("keyword1", keyword1);

        TemplateData keyword2 = new TemplateData();
        keyword2.setValue(value2);
        msgMap.put("keyword2", keyword2);
        weiXinTeamplateMsg.setData(msgMap);

        TemplateData keyword3 = new TemplateData();
        keyword3.setValue(value3);
        msgMap.put("keyword3", keyword3);
        weiXinTeamplateMsg.setData(msgMap);

        TemplateData keyword4 = new TemplateData();
        keyword4.setValue(value4);
        msgMap.put("keyword4", keyword4);
        weiXinTeamplateMsg.setData(msgMap);

        TemplateData keyword5 = new TemplateData();
        keyword5.setValue(value5);
        msgMap.put("keyword5", keyword5);
        weiXinTeamplateMsg.setData(msgMap);

        TemplateData keyword6 = new TemplateData();
        keyword6.setValue(value6);
        msgMap.put("keyword6", keyword6);
        weiXinTeamplateMsg.setData(msgMap);

        RestTemplate restTemplate = new RestTemplate();
        ResponseEntity<String> responseEntity =
                restTemplate.postForEntity(url, weiXinTeamplateMsg, String.class);
        return responseEntity.getBody();
    }
複製代碼

記住要將用過的formid給刪除掉。