devbox
黑客灵魂
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

spring boot 发送微信小程序订阅消息

作者：黑客灵魂 | 2024-08-15 07:08:39

赞

踩

spring boot 发送微信小程序订阅消息

首先我们需要订阅一个消息：

订阅教程本文章并未提起，感兴趣的同学自行百度。

我们可以看到订阅消息中【消息内容】有很多参数，我们在发送消息时就需要将这些参数进行填充，当然填充的时候要注意格式，如果格式不对还是会报错。 

教程开始：

1、创建一个实体类，用来填充对应的数据

  1. import lombok.Data;
  2.  
  3. import java.util.Date;
  4.  
  5. @Data
  6. public class LeaveResultMsg {
  7.  
  8.     /**
  9.      * 请假结果通知 -- 模板ID
  10.      */
  11.     public static String RESULTID = "Qd0*************T8k";
  12.  
  13.  
  14.     /**
  15.      * 请假人OpenId
  16.      */
  17.     private String openId;
  18.  
  19.     /**
  20.      * 请假人名称
  21.      */
  22.     private String name;
  23.  
  24.     /**
  25.      * 请假开始时间
  26.      */
  27.     private Date startTime;
  28.  
  29.     /**
  30.      * 请假结束时间
  31.      */
  32.     private Date endTime;
  33.  
  34.     /**
  35.      * 审核人
  36.      */
  37.     private String examine;
  38.  
  39.     /**
  40.      * 请假结果（同意，不同意）
  41.      */
  42.     private String status;
  43.  
  44.     /**
  45.      * 请假类型
  46.      */
  47.     private String type;
  48.  
  49.  
  50. }

2、实现类

  1. import cn.hutool.http.HttpUtil;
  2. import cn.hutool.json.JSONUtil;
  3. import lombok.RequiredArgsConstructor;
  4. import org.dromara.common.api.service.ApiWeChatUtilsService;
  5. import org.dromara.common.api.utils.DateUtil;
  6. import org.dromara.school.domain.LeaveResultMsg;
  7. import org.dromara.school.service.ISubscribeMsgService;
  8. import org.dromara.system.service.ISysConfigService;
  9. import org.springframework.stereotype.Service;
  10.  
  11. import java.nio.charset.StandardCharsets;
  12. import java.util.Collections;
  13. import java.util.HashMap;
  14. import java.util.Map;
  15.  
  16.  
  17. @Service
  18. @RequiredArgsConstructor
  19. public class SubscribeMsgService implements ISubscribeMsgService {
  20.     private final static String SEND_URL = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=";
  21.  
  22. //	private final WeChatTokenUtil weChatTokenUtil;
  23.     private final ISysConfigService configService;
  24.     private final ApiWeChatUtilsService apiWeChatUtilsService;
  25.     /**
  26.      * 请假结果通知
  27.      * @param msg
  28.      * @throws Exception
  29.      */
  30.     public void leaveResultW(LeaveResultMsg msg){
  31.         try {
  32.             System.out.println(msg.toString());
  33.             Map<String, Object> params = baseParams(msg.getOpenId());
  34.             params.put("template_id", LeaveResultMsg.RESULTID);
  35.             Map<String, Object> data = new HashMap<String, Object>();
  36.             // 传入转换后的 UTF-8 编码字节数组
  37.             data.put("thing2", Collections.singletonMap("value", new String(msg.getName().getBytes(StandardCharsets.UTF_8), StandardCharsets.UTF_8)));
  38.             data.put("time3", Collections.singletonMap("value", DateUtil.getStringDateFormat(msg.getStartTime())));
  39.             data.put("time4",Collections.singletonMap("value", DateUtil.getStringDateFormat(msg.getEndTime())));
  40.             data.put("thing7", Collections.singletonMap("value",new String(msg.getExamine().getBytes(StandardCharsets.UTF_8), StandardCharsets.UTF_8)));
  41.             data.put("phrase1",Collections.singletonMap("value", new String(msg.getStatus().getBytes(StandardCharsets.UTF_8),StandardCharsets.UTF_8)));
  42.             params.put("data", data);
  43.             System.err.println(params);
  44.             String post;
  45.             try {
  46.                 post = HttpUtil.post(SEND_URL + apiWeChatUtilsService.getAccessTokenByRedis(0), JSONUtil.toJsonStr(params));
  47.             }catch (Exception e) {
  48.                 post = HttpUtil.post(SEND_URL + apiWeChatUtilsService.getAccessTokenByRedis(1), JSONUtil.toJsonStr(params));
  49.             }
  50. //			String post = HttpUtil.post(SEND_URL + weChatTokenUtil.getAccessToken(), JSONUtil.toJsonStr(params));
  51.             System.err.println(post);
  52.         }catch (Exception e){
  53.             e.printStackTrace();
  54.         }
  55.     }
  56. }

关联到的其他方法：

3、组装参数

  1. @Service
  2. @RequiredArgsConstructor
  3. public class SubscribeMsgService implements ISubscribeMsgService {
  4.         /**
  5.          * 组装基础参数
  6.          *
  7.          * @param openId
  8.          * @return
  9.          */
  10.         private Map<String, Object> baseParams(String openId) {
  11.             Map<String, Object> map = new HashMap<String, Object>();
  12.             String touser = openId;
  13.             String page = "/pages/home/index";
  14.             // 微信-小程序订阅跳转版本,developer:开发版,trial:体验版,formal:正式版
  15.             String miniprogramState = configService.selectConfigByKey("***.version"); //小程序版本
  16.             map.put("touser", touser);
  17.             map.put("page", page);
  18.             map.put("miniprogram_state", miniprogramState);
  19.             return map;
  20.         }
  21. }

4、时间转换

  1. import java.text.ParseException;
  2. import java.text.SimpleDateFormat;
  3. import java.time.LocalDate;
  4. import java.time.ZoneId;
  5. import java.time.temporal.ChronoUnit;
  6. import java.util.Calendar;
  7. import java.util.Date;
  8. import java.util.TimeZone;
  9.  
  10. public class DateUtil {   
  11.  /**
  12.      * 获取当前时间，转换成String(yyyy-MM-dd HH:mm:ss)
  13.      * @return yyyyMMddHHmmss
  14.      */
  15.     public static String getStringDateFormat(Date date){
  16.         //Thu May 11 11:08:15 GMT+08:00 2023
  17.         //设置日期格式
  18.         SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  19.         //获取String类型的时间
  20.         String str = df.format(date);
  21.         return str;
  22.     }
  23. }

5、获取token

  1. package org.dromara.system.dubbo;
  2.  
  3. import cn.hutool.http.HttpUtil;
  4. import cn.hutool.json.JSONUtil;
  5. import lombok.RequiredArgsConstructor;
  6. import lombok.extern.slf4j.Slf4j;
  7. import org.dromara.common.api.service.ApiWeChatUtilsService;
  8. import org.dromara.common.api.utils.StringUtil;
  9. import org.dromara.common.api.utils.https.HttpClientUtil;
  10. import org.dromara.common.core.exception.ServiceException;
  11. import org.dromara.common.core.exception.base.BaseException;
  12. import org.dromara.common.core.utils.StringUtils;
  13. import org.dromara.common.redis.utils.RedisUtils;
  14. import org.dromara.system.service.ISysConfigService;
  15. import org.springframework.beans.factory.annotation.Autowired;
  16. import org.springframework.http.HttpEntity;
  17. import org.springframework.http.HttpHeaders;
  18. import org.springframework.http.ResponseEntity;
  19. import org.springframework.stereotype.Service;
  20. import org.springframework.util.MultiValueMap;
  21. import org.springframework.web.client.RestTemplate;
  22.  
  23. import java.time.Duration;
  24. import java.util.HashMap;
  25. import java.util.Map;
  26.  
  27. /**
  28.  * 字典 业务层处理
  29.  *
  30.  * @author Lion Li
  31.  */
  32. @RequiredArgsConstructor
  33. @Service
  34. @Slf4j
  35. public class ApiWeChatUtilsServiceImpl implements ApiWeChatUtilsService {
  36.  
  37.     @Autowired
  38.     ISysConfigService sysConfigService;
  39.  
  40.     /**
  41.      * 0正常获取，1可能token失效了，重新获取（线上线下冲突）
  42.      * @return
  43.      */
  44.     @Override
  45.     public String getAccessTokenByRedis(int state)  {
  46.         String key = "wx.access_token";
  47.         String accessToken;
  48.         if (state==0){
  49.             accessToken = RedisUtils.getCacheObject(key);
  50.             if (StringUtil.isEmpty(accessToken)) {
  51.                 accessToken = getAccessTokenByAddress();
  52.                 if (!StringUtil.isEmpty(accessToken))
  53.                     RedisUtils.setCacheObject(key, accessToken, Duration.ofMinutes(120));
  54.             }
  55.         }else {
  56.             accessToken = getAccessTokenByAddress();
  57.             if (!StringUtil.isEmpty(accessToken))
  58.                 RedisUtils.setCacheObject(key, accessToken, Duration.ofMinutes(120));
  59.         }
  60.         return accessToken;
  61.     }
  62.  
  63.     private String getAccessTokenByAddress() {
  64.         String appid = sysConfigService.selectConfigByKey("***.appid");
  65.         String secret =sysConfigService.selectConfigByKey("***.secret");
  66.         String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appid + "&secret=" + secret;
  67.         String result = HttpUtil.get(url);
  68.         HashMap<String, String> resultMap = (HashMap<String, String>) JSONUtil.parse(result).toBean(HashMap.class);
  69.         String accessToken = resultMap.get("access_token");
  70.         if (StringUtil.isEmpty(accessToken))
  71.             throw new BaseException(resultMap.get("errmsg"));
  72.         return accessToken;
  73.     }
  74.  
  75.     /**
  76.      * 获取手机号
  77.      * @param code
  78.      * @return
  79.      */
  80.     @Override
  81.     public String getPhoneByCode(String code) {
  82.         String accessToken = getAccessTokenByRedis(0);
  83.         String url = "https://api.weixin.qq.com/wxa/business/getuserphonenumber?access_token=" + accessToken;
  84.  
  85.         HttpHeaders headers = new HttpHeaders();
  86.         RestTemplate restTemplate = new RestTemplate();
  87.         HttpEntity<Map<String, String>> httpEntity;
  88.         if (code.contains("code")) {
  89.             httpEntity = new HttpEntity(code,headers);
  90.         }else {
  91.             Map<String, String> params = new HashMap<>();
  92.             params.put("code", code);
  93.             httpEntity = new HttpEntity(params,headers);
  94.         }
  95.  
  96.         ResponseEntity<Object> response = restTemplate.postForEntity(url, httpEntity, Object.class, new Object[0]);
  97.  
  98.         HashMap<String, Object> resultMap = (HashMap<String, Object>) JSONUtil.parse(response.getBody()).toBean(HashMap.class);
  99.         int errcode = ((Integer) resultMap.get("errcode")).intValue();
  100.         if (errcode != 0) {
  101.             if (errcode == 40001){
  102.                 //可能会出现多个服务器重复获取,导致accessToken失效的情况
  103.                 accessToken = getAccessTokenByRedis(1);
  104.                 url = "https://api.weixin.qq.com/wxa/business/getuserphonenumber?access_token=" + accessToken;
  105.                 response = restTemplate.postForEntity(url, httpEntity, Object.class, new Object[0]);
  106.                 resultMap = (HashMap<String, Object>) JSONUtil.parse(response.getBody()).toBean(HashMap.class);
  107.                 errcode = ((Integer) resultMap.get("errcode")).intValue();
  108.                 if (errcode != 0){
  109.                     throw new ServiceException("获取手机号出错，报错类型------>{}",errcode);
  110.                 }
  111.             }else {
  112.                 throw new ServiceException("获取手机号出错，报错类型------>{}",errcode);
  113.             }
  114.         }
  115.         HashMap<String, Object> phoneInfo = (HashMap<String, Object>) JSONUtil.parse(resultMap.get("phone_info")).toBean(HashMap.class);
  116.         String phone = (String) phoneInfo.get("purePhoneNumber");
  117.         return phone;
  118.     }
  119.  
  120.  
  121.     /**
  122.      * 获取手机号2
  123.      * @param code
  124.      * @return
  125.      */
  126.     public String getPhoneByCode2(String code) {
  127.         String accessToken = getAccessTokenByRedis(0);
  128.  
  129.         String url = "https://api.weixin.qq.com/wxa/business/getuserphonenumber?access_token=" + accessToken;
  130. //        String jsonStr = "{\"code\":\"" + code + "\"}";
  131.         String httpOrgCreateTestRtn = HttpClientUtil.doPost(url, code, "utf-8");
  132.         System.out.println("获取到的手机号----------->"+httpOrgCreateTestRtn);
  133.         return httpOrgCreateTestRtn;
  134.     }
  135.  
  136.  
  137.  
  138.     /**
  139.      * 获取openid
  140.      * @param code
  141.      * @return
  142.      */
  143.     @Override
  144.     public String getOpenidByCode(String code) {
  145.         String appid = sysConfigService.selectConfigByKey("weChat.mini.appid");
  146.         String secret =sysConfigService.selectConfigByKey("weChat.mini.secret");
  147.         //https://api.weixin.qq.com/sns/jscode2session
  148.         String url = "https://api.weixin.qq.com/sns/jscode2session?appid=" + appid + "&secret=" + secret +
  149.             "&js_code=" + code + "&grant_type=authorization_code";
  150.         String result = HttpUtil.get(url);
  151.         HashMap<String, String> resultMap = (HashMap<String, String>) JSONUtil.parse(result).toBean(HashMap.class);
  152.         String openId = resultMap.get("openid");
  153. //        System.out.println("获取到的openId----------->"+openId);
  154.         if (StringUtils.isNotEmpty(openId)) {
  155.             return openId;
  156.         } else {
  157.             throw new ServiceException("用户信息获取错误,请稍候重试",Integer.valueOf(resultMap.get("errcode")) );
  158.         }
  159.     }
  160.  
  161.  
  162. }

以上用到的config类是配置类，配置的内容是由你申请小程序时候得到的数据。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/黑客灵魂/article/detail/982499
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号