微信小程序模板消息限制实现无限制主动推送的示例代码

// 收集推送码Page({  formSubmit: funcition(e) {let formId = e.detail.formId;this.collectFormIds(formId); //保存推送码let type = e.detail.target.dataset.type; // 根据type执行点击事件},   collectFormIds: function(formId) { let formIds = app.globalData.globalFormIds; // 获取全局推送码数组if (!formIds)      formIds = [];let data = {      formId: formId,      expire: new Data().getTime() + 60480000 // 7天后的过期时间戳}    formIds.push(data);    app.globalData.globalFormIds = formIds;},})

// 上报推送码Page({  onLoad: funcition(e) {this.uploadFormIds(); //上传推送码},   collectFormIds: function(formId) { var formIds = app.globalData.globalFormIds; // 获取全局推送码if (formIds.length) {      formIds = JSON.stringify(formIds); // 转换成JSON字符串      app.globalData.gloabalFomIds = ''; // 清空当前全局推送码}    wx.request({ // 发送到服务器      url: 'http://xxx',      method: 'POST',      data: {        openId: 'openId',        formIds: formIds},      success: function(res) {}});},})

/*** 收集用户推送码** @param openId    用户的openid* @param formTemplates 用户的表单模板*/public void collect(String openId, List<FormTemplateVO> formTemplates) {  redisTemplate.opsForList().rightPushAll("mina:openid:" + openId, formTemplates);}

/*** 推送消息** @param templateId 模板消息id* @param page    跳转页面* @param keyWords  模板内容*/public void push(String templateId, String page, String keyWords) {String logPrefix = "推送消息"; // 获取access tokenString accessToken = this.getAccessToken(); // 创建消息通用模板MsgTemplateVO msgTemplateVO = MsgTemplateVO.builder().template_id(templateId).build();// 跳转页面  msgTemplateVO.setPage(StringUtils.isNotBlank(page) ? page : "");// 模板内容if (StringUtils.isNotBlank(keyWords)) {String[] keyWordArr = keyWords.split(BaseConsts.COMMA_STR);Map<String, MsgTemplateVO.KeyWord> keyWordMap = new HashMap<>(8);for (int i = 0; i < keyWordArr.length; i++) {MsgTemplateVO.KeyWord keyWord = msgTemplateVO.new KeyWord(keyWordArr[i]);      keyWordMap.put(MsgTemplateVO.KEYWORD + (i + 1), keyWord);}    msgTemplateVO.setData(keyWordMap);} else {    msgTemplateVO.setData(Collections.emptyMap());} // 获取所有用户List<String> openIdList = minaRedisDao.getAllOpenIds(); for (String openId : openIdList) {// 获取有效推送码String formId = minaRedisDao.getValidFormId(openId);if (StringUtils.isBlank(formId)) {      LOGGER.error("{}>>>openId={}>>>已无有效推送码[失败]", logPrefix, openId);continue;} // 指派消息MsgTemplateVO assignMsgTemplateVO = msgTemplateVO.assign(openId, formId); // 发送消息Map<String, Object> resultMap;try {String jsonBody = JsonUtils.getObjectMapper().writeValueAsString(assignMsgTemplateVO); String resultBody = OkHttpUtils.getInstance().postAsString(messageUrl + accessToken, jsonBody);      resultMap = JsonUtils.getObjectMapper().readValue(resultBody, Map.class);} catch (IOException e) {      LOGGER.error("{}>>>openId={}>>>{}[失败]", logPrefix, openId, e.getMessage(), e);continue;} if ((int) resultMap.get(ResponseConsts.Mina.CODE) != 0) {      LOGGER.error("{}>>>openId={}>>>{}[失败]", logPrefix, openId, resultMap.get(ResponseConsts.Mina.MSG));continue;}     LOGGER.info("{}>>>openId={}>>>[成功]", logPrefix, openId);}} /*** 根据用户获取有效的推送码** @param openId 用户的openid* @return 推送码*/public String getValidFormId(String openId) {List<FormTemplateVO> formTemplates = redisTemplate.opsForList().range("mina:openid:" + openId, 0, -1); String validFormId = "";int trimStart = 0; int size;for (int i = 0; i < (size = formTemplates.size()); i++) {if (formTemplates.get(i).getExpire() > System.currentTimeMillis()) {      validFormId = formTemplates.get(i).getFormId();      trimStart = i + 1;break;}} // 移除本次使用的和已过期的  redisTemplate.opsForList().trim(KEY_MINA_PUSH + openId, trimStart == 0 ? size : trimStart, -1); return validFormId;}