基于微信小程序-发步订阅消息

分类：菜鸟笔记作者：qq_48157004

1.微信小程序设置消息推送

在这里插入图片描述

1.URL（服务器地址）是需要在你当前服务器写一个接口进行回调

开发者通过检验 signature 对请求进行校验（下面有校验方式）。若确认此次 GET 请求来自微信服务器，请原样返回 echostr 参数内容，则接入生效，成为开发者成功，否则接入失败。加密/校验流程如下：

将token、timestamp、nonce三个参数进行字典序排序 将三个参数字符串拼接成一个字符串进行sha1加密
开发者获得加密后的字符串可与 signature 对比，标识该请求来源于微信 验证 URL 有效性成功后即接入生效，成为开发者。

代码实例（可以不做处理，直接返回 echostr）


    @GetMapping("/wecheck")
    public String Wechake(String signature,String timestamp,String nonce,String echostr) throws IOException {
        return echostr;
    }

2. 小程序申请订阅模板

在这里插入图片描述

申请模板后，需要记住模板id，以及详细内容key的名称，比如比赛名称他的Key就是，thing1，value就是data。可以用map就存储。

在这里插入图片描述

一 次性订阅消息可满足小程序的大部分服务场景需求，但线下公共服务领域存在一次性订阅无法满足的场景， 如航班延误，需根据航班实时动态来多次发送消息提醒。

为便于服务,我们提供了长期性订阅消息，用户订阅-次后,开发者可长期下发名条消息目前长期性订阅消息仅向政务民生、疗交通、金融、教育等线下公共服务开放，后期将逐步支持到其他线下公共服务务。

在这里插入图片描述

因为一次性订阅，只会每次用户授权后才可以发送一次消息，所以需要尽量引导用户多去授权。

3. access_token 获取

access_token一天只能获取200次，一次持续2个小时。建议做缓存去处理，不要每次推送消息就去获取。

每一次推送，会根据用户的openId和access_token 去推送消息。

  /**
     *  获取token
     * @return
     */
    public  String getToken() {
    // 查看Redis 是否缓存
        if(redisService.hasKey("WechatToken")) {
            Object wechatToken = redisService.getCacheObject("WechatToken");
                return String.valueOf(wechatToken);
        }
        // 创建Httpclient对象
        CloseableHttpClient httpclient = HttpClients.createDefault();
        String resultString = "";
        CloseableHttpResponse response = null;
        String access_token;
        String urls =String.format("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + wechatConfig.appid + "&secret=" + wechatConfig.appSecret );

        try {

            URL url = new URL(urls);
            URI uri = new URI(url.getProtocol(), url.getHost(), url.getPath(), url.getQuery(), null);


            System.out.println(uri);
            // 创建http GET请求
            HttpGet httpGet = new HttpGet(uri);

            // 执行请求
            response = httpclient.execute(httpGet);
            // 判断返回状态是否为200
            if (response.getStatusLine().getStatusCode() == 200) {
                resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
            }
        } catch (Exception e) {
            e.printStackTrace();

            //System.out.println("resultString:" + resultString);
        }
        // 解析json
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(resultString);
        System.out.println(jsonObject);
        access_token = jsonObject.get("access_token").toString();
        //  token进行一个小时缓存
        redisService.setCacheObject("WechatToken",access_token, 1L, TimeUnit.HOURS );
        System.out.println("access_token"+access_token);
        return  access_token;
    }

4. 完整业务代码实现

因为我的业务涉及到多个模板推送，因此用了设计模式当中的模板模式。SubscriptionTemplate 是一个抽象类，有一个PushSubscription（）抽象方法，以及setMethod（）推送方法，和getToken（）获取方法。

@Component
public abstract class SubscriptionTemplate {

	// 推送链接
    public static final String SEND_INFO_URL = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=";

    // 学校报名模板
    public static final String SEND_TEMPLATE_EXAMINE = "";

    // 退款摸板
    public static final String SEND_TEMPLATE_REFUND = "";
    @Autowired
    private WechatConfig wechatConfig;

    @Autowired
    private  RedisService redisService;

    /**
     *  抽象推送方法
     * @param
     * @return
     */
    public  abstract   String  PushSubscription(String openId, List<TemplateData> list);

    /**
     *  推送方法
     * @param wxMssVo
     * @return
     */
    public String setMethod(WxMssVO wxMssVo){
        RestTemplate restTemplate = new RestTemplate();
        // 获取路径
        String url =  SEND_INFO_URL  + getToken();
        // 发送请求
        ResponseEntity<String> responseEntity =restTemplate.postForEntity(url, wxMssVo, String.class);

        String sessionData = responseEntity.getBody();
        System.out.println("sessionData"+sessionData);
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(sessionData);
        String errmsg = jsonObject.getString("errmsg");
        if (errmsg.equals("ok")){
            return errmsg;
        }else {
            return "推送失败"+jsonObject.getString("errcode");
        }

    }


    /**
     *  获取token
     * @return
     */
    public  String getToken() {
        if(redisService.hasKey("WechatToken")) {
            Object wechatToken = redisService.getCacheObject("WechatToken");
                return String.valueOf(wechatToken);
        }
        // 创建Httpclient对象
        CloseableHttpClient httpclient = HttpClients.createDefault();
        String resultString = "";
        CloseableHttpResponse response = null;
        String access_token;
        String urls =String.format("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + wechatConfig.appid + "&secret=" + wechatConfig.appSecret );

        try {

            URL url = new URL(urls);
            URI uri = new URI(url.getProtocol(), url.getHost(), url.getPath(), url.getQuery(), null);


            System.out.println(uri);
            // 创建http GET请求
            HttpGet httpGet = new HttpGet(uri);

            // 执行请求
            response = httpclient.execute(httpGet);
            // 判断返回状态是否为200
            if (response.getStatusLine().getStatusCode() == 200) {
                resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
            }
        } catch (Exception e) {
            e.printStackTrace();

            //System.out.println("resultString:" + resultString);
        }
        // 解析json
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(resultString);
        System.out.println(jsonObject);
        access_token = jsonObject.get("access_token").toString();
        //  token进行两个小时缓存
        redisService.setCacheObject("WechatToken",access_token, 1L, TimeUnit.HOURS );
        System.out.println("access_token"+access_token);
        return  access_token;
    }


}

ApplyCompetitionTemplate 报名订阅模板（传参用户openId,以及模板内容list）

/**
 *     报名订阅模板
 */
@Component
public class ApplyCompetitionTemplate  extends SubscriptionTemplate{

    @Override
    public String PushSubscription(String openId, List<TemplateData> list) {
        //拼接推送的模版
        WxMssVO wxMssVo = new WxMssVO();
        wxMssVo.setTouser(openId);//用户的openId
        wxMssVo.setTemplate_id(SEND_TEMPLATE_EXAMINE);//订阅消息模板id
        wxMssVo.setPage("/pages/match");
        Map<String, TemplateData> m = new HashMap<>();
        // {{thing1.DATA}}  比赛名称
        m.put("thing1",list.get(0));
        // {{thing7.DATA}}  机构名称
        m.put("thing7",list.get(1));
        // {{thing4.DATA}}  温馨提示
        m.put("thing4",list.get(2));
        wxMssVo.setData(m);

        System.out.println("学校审核推送");
        return setMethod(wxMssVo);
    }
}

RefundTemplate 退款订阅模板（传参用户openId,以及模板内容list）

/**
 *  退款模板
 */
@Component
public class RefundTemplate  extends SubscriptionTemplate{

    @Override
    public String PushSubscription(String openId, List<TemplateData> list) {
        //拼接推送的模版
        WxMssVO wxMssVo = new WxMssVO();
        wxMssVo.setTouser(openId);//用户的openId
        wxMssVo.setTemplate_id(SEND_TEMPLATE_REFUND);//订阅消息模板id
        wxMssVo.setPage("/pages/match");
        Map<String, TemplateData> m = new HashMap<>();
        // 项目
        m.put("thing1",list.get(0));
        // 退款金额
        m.put("amount2",list.get(1));
        // 退款时间
        m.put("time3",list.get(2));
        // 审核结果
        m.put("thing4",list.get(3));
        wxMssVo.setData(m);
        System.out.println("退款推送");
        return setMethod(wxMssVo);
    }
}

WxMssVO （模板内容实体类）

@Data
public class WxMssVO {
    private String touser;//用户openid
    private String template_id;//订阅消息模版id
    private String page = "";//跳转小程序链接
    private Map<String, TemplateData> data;//推送文字

}

TemplateData（模板类）

@Data
public class TemplateData {
    public TemplateData() {

    }
    public TemplateData(String value) {
        this.value = value;
    }

    private String value;
}

5.微信接收效果展示

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

小程序微信微信微信小程序

相关推荐

如何学习编程？新手菜鸟如何学编程？
学习编程是顺着互联网的发展潮流，是一件好事。新手如何学习编程？其实不难，不过在学习编程之前你得先了解你的目的是什么？这个很重要，因为目的决定你的发展方向、决定你的发展速度。
it行业都是什么工作？it行业主要做什么？
IT行业是什么工作做什么？IT行业的工作有：产品策划类、页面设计类、前端与移动、开发与测试、营销推广类、数据运营类、运营维护类、游戏相关类等，根据不同的分类下面有细分了不同的岗位。
女生学Java好就业吗？女生适合学Java编程吗？
女生学Java好就业吗？女生适合学Java编程吗？目前有不少女生学习Java开发，但要结合自身的情况，先了解自己适不适合去学习Java，不要盲目的选择不适合自己的Java培训班进行学习。只要肯下功夫钻研，多看、多想、多练
mysql-connect-confused
Can’t connect to local MySQL server through socket \'/var/lib/mysql/mysql.sock问题 1.进入mysql路径
oracle基本命令
oracle基本命令 一、登录操作 1.管理员登录 # 管理员登录 sqlplus / as sysdba 2.普通用户登录
shell判断服务是否启动
一、背景 因为项目中需要通北京网络，所以需要连vpn，但是服务器有时候会断掉，所以写个shell脚本每五分钟去判断是否连接，于是就有下面的shell脚本。
SQL BETWEEN 操作符
BETWEEN 操作符选取介于两个值之间的数据范围内的值。这些值可以是数值、文本或者日期。
​​windows上传ipa到开发者中心app store的方法
假如你已经使用过苹果开发者中心上架app，你肯定知道在苹果开发者中心的web界面，无法直接提交ipa文件，而是需要使用第三方工具，将ipa文件上传到构建版本，开...
SQL 入门篇之什么是别名？
下面的 SQL 语句指定了两个别名，一个是 name 列的别名，一个是 country 列的别名。**提示：**如果列名称包含空格，要求使用双引号或方括号：
windows上传ipa文件到app store的方法​
在使用H5混合开发的app打包后，需要将ipa文件上传到appstore进行发布，就需要去苹果开发者中心进行发布。​
SQL AND & OR 运算符
+----+--------------+---------------------------+-------+---------+
C++ 数组
数组的声明并不是声明一个个单独的变量，比如 number0、number1、...、number99，而是声明一个数组变量，比如 numbers，然后使用 nu...
最全iOS 应用上架流程提交到AppStore
第一步：到appuploader官网下载辅助工具和iCloud驱动，使用前面创建的AppID登录。
SQL ALTER TABLE 语句
如需删除表中的列，请使用下面的语法（请注意，某些数据库系统不允许这种在数据库表中删除列的方式）：
dism操作巨慢
前不久在制作win11pe，制作了一版，1.26GB，太大了，不满意，想再裁剪下，发现这次dism mount正常，commit或discard巨慢，以前都很快...
三种方法卸载Symantec Endpoint Protection 赛门铁克
赛门铁克各个版本概览：https://knowledge.broadcom.com/external/article?legacyId=tech163829
python3.6、python3.10用什么版本的pip
实测Python 3.6.6用pip 21.3.1，再高就报错了，Python 3.10.7用pip 22.3.1是可以的
博通和诺顿
Broadcom Corporation （博通公司，股票代号AVGO）是全球领先的有线和无线通信半导体公司。其产品实现向家庭、 办公室和移动环境以及在这些环境...
高版本c4d在低版本windows系统上打开后不显示窗格
发现个问题，server2016上安装了c4d这些版本，低版本的正常显示窗格，但红色圈出的高版本c4d打开后不显示窗格，
基础网络windows不要使用TAT、如何卸载TAT
TAT：https://cloud.tencent.com/document/product/1340
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot