• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

快速接入微信小程序的订阅消息

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

快速接入微信小程序的订阅消息

官方文档:https://developers.weixin.qq.com/miniprogram/dev/framework/open-ability/subscribe-message.html

2020年11月17日15:59:14  以下内容如有变更,请以官方文档为准。

 

小程序订阅消息

消息能力是小程序能力中的重要组成,我们为开发者提供了订阅消息能力,以便实现服务的闭环和更优的体验。

订阅消息推送位置:服务通知

订阅消息下发条件:用户自主订阅

订阅消息卡片跳转能力:点击查看详情可跳转至该小程序的页面

订阅消息包括两种:

一次性订阅消息

一次性订阅消息用于解决用户使用小程序后,后续服务环节的通知问题。用户自主订阅后,开发者可不限时间地下发一条对应的服务消息;每条消息可单独订阅或退订。

长期订阅消息

一次性订阅消息可满足小程序的大部分服务场景需求,但线下公共服务领域存在一次性订阅无法满足的场景,如航班延误,需根据航班实时动态来多次发送消息提醒。为便于服务,我们提供了长期性订阅消息,用户订阅一次后,开发者可长期下发多条消息。

目前长期性订阅消息仅向政务民生、医疗、交通、金融、教育等线下公共服务开放,后期将逐步支持到其他线下公共服务业务。

 

使用说明

步骤一:获取模板 ID

在微信公众平台手动配置获取模板 ID:

登录 https://mp.weixin.qq.com 获取模板,如果没有合适的模板,可以申请添加新模板,审核通过后可使用。

步骤二:获取下发权限

详见小程序端消息订阅接口 wx.requestSubscribeMessage

步骤三:调用接口下发订阅消息

详见服务端消息发送接口 subscribeMessage.send

注意事项

用户勾选 “总是保持以上选择,不再询问” 之后,下次订阅调用 wx.requestSubscribeMessage 不会弹窗,保持之前的选择,修改选择需要打开小程序设置进行修改。

 

快速接入

请先按照官文文档写的步骤开通好订阅消息模板。

1、小程序代码

 <!--index.wxml-->

<view class="container">
  <text class="user-motto">{{openId}}</text>
  <button class="btn green" bindtap="onSubscribe" hover-class="btn-hover">
  订阅
  </button>
</view>

  

//index.js
//获取应用实例
const app = getApp()

Page({
  data: {
    openId: \'\',
    userInfo: {},
    hasUserInfo: false,
    canIUse: wx.canIUse(\'button.open-type.getUserInfo\')
  },
  //事件处理函数
  bindViewTap: function() {
    wx.navigateTo({
      url: \'../logs/logs\'
    })
  },
  //订阅按钮事件
  onSubscribe: function(e) {
    let that = this 
    //申请订阅消息 模板IDXXX
    wx.requestSubscribeMessage({
      tmplIds: [\'模板IDXXX\'],
      success(res) {
        let status = res[\'模板IDXXX\']
        if(status === "reject"){
          console.log("拒绝")
          //提示: 您拒绝了消息提示,后续将接收不到消息通知,打开小程序设置进行修改。
        }
        console.log(that.openId)
        //发送测试消息
        wx.request({
          url: \'http://localhost:8080/api/wxmini/sendSubscribeMessage\',
          data: {
            openId: that.data.openId
          },
          success(res){
            console.log(res.data)
          }
        })
      }});
  },
  onLoad: function () {
      let that =this
      //获取微信登录openId
      wx.login({
        success (res) {
          //console.log(res.code)
          if (res.code) {
            //发起网络请求
            wx.request({
              url: \'http://localhost:8080/api/wxmini/jscode2session\',
              data: {
                code: res.code
              },
              success(res){
                console.log(res.data.openId)
                that.setData({
                  openId: res.data.openId
                })
              }
            })
          } else {
            console.log(\'登录失败!\' + res.errMsg)
          }
        }
      })
  }
})

  

2、后台接口核心代码
package com.zhaojie.wechat.demo.controller;

import com.zhaojie.wechat.demo.service.IWxService;
import com.zhaojie.wechat.demo.vo.Jscode2sessionVo;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@Api(tags = {"微信小程序"})
@Slf4j
@Validated
@RestController
@RequestMapping("/api/wxmini")
public class WxMiniController {

    @Autowired
private IWxService wxService; 

@ApiOperation(value = "获取小程序用户的openid")
    @GetMapping("/jscode2session")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "code", value = "wx.login返回的code", required = true, dataType = "String")
    })
    public Object jscode2session(@RequestParam String code) {
        Jscode2sessionVo jscode2sessionVo = wxService.jscode2session(code);
        return jscode2sessionVo;
}

    @ApiOperation(value = "小程序订阅消息发送")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "openId", value = "接收者(用户)的 openid", required = true, dataType = "String")
    })
    @GetMapping("/sendSubscribeMessage")
    public Object sendSubscribeMessage(@RequestParam String openId) {
        return "小程序订阅消息" + wxService.sendSubscribeMessage(openId);
}
}

 

package com.zhaojie.wechat.demo.service.impl;

import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.zhaojie.wechat.demo.common.Constant;
import com.zhaojie.wechat.demo.service.IWxService;
import com.zhaojie.wechat.demo.vo.Jscode2sessionVo;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.*;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

@Slf4j
@Service
public class WxServiceImpl implements IWxService {

    @Autowired
    private RestTemplate restTemplate;

    @Override
    public Jscode2sessionVo jscode2session(String code) {
        //登录凭证校验。通过 wx.login 接口获得临时登录凭证 code 后传到开发者服务器调用此接口完成登录流程。
        String url = "https://api.weixin.qq.com/sns/jscode2session?appid=" + Constant.WX_APP_ID +
                "&secret=" + Constant.WX_SECRET + "&js_code=" + code + "&grant_type=authorization_code";
        String forObject = restTemplate.getForObject(url, String.class);
        //返回的 JSON 数据包
        //属性   类型 说明
        //openid   string 用户唯一标识
        //session_key  string 会话密钥
        //unionid  string 用户在开放平台的唯一标识符,在满足 UnionID 下发条件的情况下会返回,详见 UnionID 机制说明。
        //errcode  number 错误码
        //errmsg   string 错误信息
        JSONObject result = JSONUtil.parseObj(forObject);
        Jscode2sessionVo jscode2sessionVo = new Jscode2sessionVo();
        jscode2sessionVo.setOpenId(result.getStr("openid"));
        jscode2sessionVo.setErrmsg(result.getStr("errmsg"));
        jscode2sessionVo.setErrcode(result.getStr("errcode"));
        return jscode2sessionVo;
    }

    @Override
    public String getAccessToken() {
        try {
            // 线上不需要每次都去获取access_token,需要把它缓存起来。我这里仅测试就不缓存了!!!
            /*String redisAccessToken = redisSeConstantrvice.get(Constant.WX_ACCESS_TOKEN);
            if (StrUtil.isNotEmpty(redisAccessToken)) {
                return redisAccessToken;
            }*/
            //获取小程序全局唯一后台接口调用凭据(access_token)。调用绝大多数后台接口时都需使用 access_token,开发者需要进行妥善保存。
            String url = "https://api.weixin.qq.com/cgi-bin/token?appid=" + Constant.WX_APP_ID +
                    "&secret=" + Constant.WX_SECRET + "&grant_type=client_credential";
            String forObject = restTemplate.getForObject(url, String.class);
            //返回的 JSON 数据包
            //属性   类型 说明
            //access_token string 获取到的凭证
            //expires_in   number 凭证有效时间,单位:秒。目前是7200秒之内的值。
            //errcode  number 错误码
            //errmsg   string 错误信息
            log.error("获取小程序全局唯一后台接口调用凭据,msg{}", forObject);
            JSONObject result = JSONUtil.parseObj(forObject);
            String accessToken = result.getStr("access_token");
            /*if (StrUtil.isNotEmpty(accessToken)) {
                //存入Redis
                redisService.set(Constant.WX_ACCESS_TOKEN, accessToken, 7200 * 1000L);
            }*/
            return accessToken;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    @Override
    public String sendSubscribeMessage(String openId) {
        String accessToken = this.getAccessToken();
        log.info("accessToken {}", accessToken);
        HttpHeaders httpHeaders = new HttpHeaders();
        //注意这里要是json格式的提交
        httpHeaders.setContentType(MediaType.APPLICATION_JSON);
        //我这里测试直接拼接的,请按照你自己模板的配置去改下面的json字符串
        //官方文档:https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/subscribe-message/subscribeMessage.send.html
        StringBuffer jsonParam = new StringBuffer();
        jsonParam.append("{");
        jsonParam.append("\"touser\": \"" + openId + "\",");
        jsonParam.append("\"template_id\": \"" + Constant.WX_TMPL_ID + "\",");
        jsonParam.append("\"page\": \"" + Constant.WX_TMPL_PAGE + "\",");
        jsonParam.append("\"data\": {");
        jsonParam.append("\"name1\": { \"value\": \"zhaojie\"},");
        jsonParam.append("\"thing13\": { \"value\": \"预约产品\"},");
        jsonParam.append("\"date3\": { \"value\": \"2020年11月17日 16:59\"},");
        jsonParam.append("\"phrase9\": { \"value\": \"预约中\"},");
        jsonParam.append("\"thing7\": { \"value\": \"如有疑问请联系客服人员\"}");
        jsonParam.append("}");
        jsonParam.append("}");
        HttpEntity<String> httpEntity = new HttpEntity<>(jsonParam.toString(), httpHeaders);
        ResponseEntity<String> entity = restTemplate.exchange("https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" + accessToken,
                HttpMethod.POST, httpEntity, String.class);
        String result = entity.getBody();
        log.info("result {}", result);
        return result;
    }
}

  

package com.zhaojie.wechat.demo.common;

/**
 * 常量
 */
public class Constant {
    // 系统前缀
    public static final String SYS_PREFIX = "WECHAT-DEMO:";
    // 小程序全局唯一后台接口调用凭据(access_token)。调用绝大多数后台接口时都需使用 access_token,开发者需要进行妥善保存。
    public static final String WX_ACCESS_TOKEN = SYS_PREFIX + "WX_ACCESS_TOKEN";
    // 小程序订阅消息模板 改成自己的参数
    public static final String WX_TMPL_ID = "XXXXX;
    public static final String WX_TMPL_PAGE = "pages/index/index";
    // 小程序配置信息 改成自己的
    public static final String WX_APP_ID = "XXXX";
    public static final String WX_SECRET = "XXXX";
}

  

 

 

3、运行结果

注意未发布体验版无法接收到消息

 

 

 

 

 


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap