uniapp微信小程序消息订阅快速上手

一、微信公众平台小程序开通消息订阅并设置模板

在这里插入图片描述

这边的模板id和详细内容后续前后端需要使用

二、uniapp前端

需要是一个button触发
js：

wx.getSetting({
	success(res){
		console.log(res)
		if(res.authSetting['scope.subscribeMessage']){
			// 业务逻辑
		}else{
			uni.requestSubscribeMessage({
			  tmplIds: [_config.TEMPLATE_ID],
			  success (res) {
				  console.log("订阅成功！")
				  // 业务逻辑
			  },
			  fail(res) {
			     // 即使用户拒绝订阅也要继续原来的业务逻辑
			  }
			})
		}
	}
})

三、java后端

@Component
@Slf4j
public class WxAccessTokenUtil {
    @Value("${WX_APPID}")
    String APP_ID;
    @Value("${WX_SECREAT}")
    String SECREAT;
    @Value("${WX_TEMPLATE_ID}")
    String TEMPLATE_ID;

    public String getWxAccessToken(){
        String res = HttpClient.doGet("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid="+APP_ID+"&secret="+SECREAT);
        JSONObject jsonObject = JSON.parseObject(res);
        return jsonObject.getString("access_token");
    }


    public void sendReservationSubscribeMsg(String touser,String id,String apparatusName,String state){
        String token = getWxAccessToken();
        JSONObject jsonObject2 = new JSONObject();
        jsonObject2.put("access_token",token);
        jsonObject2.put("touser",touser);
        jsonObject2.put("template_id",TEMPLATE_ID);
        jsonObject2.put("page","/pages/appointment_detail/appointment_detail?id="+id);
        JSONObject data = new JSONObject();
        JSONObject thing2 = new JSONObject();
        thing2.put("value",apparatusName);
        data.put("thing2",thing2);
        JSONObject phrase3 = new JSONObject();
        phrase3.put("value",state);
        data.put("phrase3",phrase3);
        jsonObject2.put("data",data);
        String res = HttpClient.doPost("https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token="+token,jsonObject2.toString());

        log.warn("微信小程序订阅消息：{}",res);
    }
}

其中thing2、phrase3是模板的字段名，根据自己模板去修改即可

HttpClient.java

public class HttpClient {

    public static void main(String[] args) {
        String APP_ID = "xxx";
        String SECREAT = "xxx";
        String res = HttpClient.doGet("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid="+APP_ID+"&secret="+SECREAT);
        com.alibaba.fastjson.JSONObject jsonObject = JSON.parseObject(res);
        String token = jsonObject.getString("access_token");

        JSONObject jsonObject2 = new JSONObject();

        jsonObject2.put("access_token",token);
        jsonObject2.put("touser","xxxxx");
        jsonObject2.put("template_id","xxxx");
        jsonObject2.put("page","/pages/tabbar/mine/mine");
        JSONObject data = new JSONObject();
        JSONObject phrase1 = new JSONObject();
        phrase1.put("value","待审核");
        data.put("phrase1",phrase1);
        JSONObject thing2 = new JSONObject();
        thing2.put("value","已成功提交预约申请，请耐心等待审核。");
        data.put("thing2",thing2);
        jsonObject2.put("data",data);
        jsonObject2.put("miniprogram_state","trial");
        System.out.println(HttpClient.doPost("https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token="+token,jsonObject2.toString()));


    }

    public static String doGet(String httpurl) {
        HttpURLConnection connection = null;
        InputStream is = null;
        BufferedReader br = null;
        String result = null;// 返回结果字符串
        try {
            // 创建远程url连接对象
            URL url = new URL(httpurl);
            // 通过远程url连接对象打开一个连接，强转成httpURLConnection类
            connection = (HttpURLConnection) url.openConnection();
            // 设置连接方式：get
            connection.setRequestMethod("GET");
            // 设置连接主机服务器的超时时间：15000毫秒
            connection.setConnectTimeout(15000);
            // 设置读取远程返回的数据时间：60000毫秒
            connection.setReadTimeout(60000);
            // 发送请求
            connection.connect();
            // 通过connection连接，获取输入流
            if (connection.getResponseCode() == 200) {
                is = connection.getInputStream();
                // 封装输入流is，并指定字符集
                br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
                // 存放数据
                StringBuffer sbf = new StringBuffer();
                String temp = null;
                while ((temp = br.readLine()) != null) {
                    sbf.append(temp);
                    sbf.append("\r\n");
                }
                result = sbf.toString();
            }
        } catch (MalformedURLException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            if (null != br) {
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

            if (null != is) {
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

            connection.disconnect();// 关闭远程连接
        }

        return result;
    }

    public static String doPost(String httpUrl, String param) {

        HttpURLConnection connection = null;
        InputStream is = null;
        OutputStream os = null;
        BufferedReader br = null;
        String result = null;
        try {
            URL url = new URL(httpUrl);
            // 通过远程url连接对象打开连接
            connection = (HttpURLConnection) url.openConnection();
            // 设置连接请求方式
            connection.setRequestMethod("POST");
            // 设置连接主机服务器超时时间：15000毫秒
            connection.setConnectTimeout(15000);
            // 设置读取主机服务器返回数据超时时间：60000毫秒
            connection.setReadTimeout(60000);

            // 默认值为：false，当向远程服务器传送数据/写数据时，需要设置为true
            connection.setDoOutput(true);
            // 默认值为：true，当前向远程服务读取数据时，设置为true，该参数可有可无
            connection.setDoInput(true);
            // 设置传入参数的格式:请求参数应该是 name1=value1&name2=value2 的形式。
            connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
            // 设置鉴权信息：Authorization: Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0
            connection.setRequestProperty("Authorization", "Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0");
            // 通过连接对象获取一个输出流
            os = connection.getOutputStream();
            // 通过输出流对象将参数写出去/传输出去,它是通过字节数组写出的
            os.write(param.getBytes());
            // 通过连接对象获取一个输入流，向远程读取
            if (connection.getResponseCode() == 200) {

                is = connection.getInputStream();
                // 对输入流对象进行包装:charset根据工作项目组的要求来设置
                br = new BufferedReader(new InputStreamReader(is, "UTF-8"));

                StringBuffer sbf = new StringBuffer();
                String temp = null;
                // 循环遍历一行一行读取数据
                while ((temp = br.readLine()) != null) {
                    sbf.append(temp);
                    sbf.append("\r\n");
                }
                result = sbf.toString();
            }
        } catch (MalformedURLException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            if (null != br) {
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (null != os) {
                try {
                    os.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (null != is) {
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            // 断开与远程地址url的连接
            connection.disconnect();
        }
        return result;
    }
}