JAVA整合微信公众平台，实现分享功能

╰+哭是因爲堅強的太久メ 2023-10-15 08:09 82阅读 0赞

##  ##

## 一、获取微信加密信息，实现分享 ##

### 1. 地址统一管理 ###

public interface WeChatConstants {
    
        // 获取全局access_token地址
        String getTokenUrl = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s";
    
        String getTicket = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=%s&type=jsapi";
    
        // 获取客户信息
        String getUserUtl = "https://api.weixin.qq.com/cgi-bin/user/info";
    
        // 用户授权 获取access_token地址
        String getUserTokenUrl = "https://api.weixin.qq.com/sns/oauth2/access_token";
        //String getUserTokenUrl = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=%s&secret=%s&code=%s&grant_type=authorization_code";
    
        //公众号推送消息
        String templateSendUrl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=";
    
        // 获取客户信息(授权版)
        String getUserInfoUrl = "https://api.weixin.qq.com/sns/userinfo";
        // appid
        String appid = "xxx";
    
        // secret
        String secret = "xxxx";
    
    }

### 2. 接口 ###

/**
         * 获取微信加密信息
         * @return
         */
        @RequestMapping(value = "/getSignature")
        @ResponseBody
        public JsonResult toTranscript(@RequestParam("url") String url) {
            Map<String, Object> wxInfo = new HashMap<>();
            try {
                String accessToken = weChatService.getAccessToken();
                if (StringUtil.isNotEmpty(accessToken)) {
                    String jsapiTicket = weChatService.getTicket(accessToken);
                    String noncestr = UUID.randomUUID().toString().replace("-", "").substring(0, 16);//随机字符串
                    String timestamp = String.valueOf(System.currentTimeMillis() / 1000);// 时间戳
                    String params = "jsapi_ticket=" + jsapiTicket + "&noncestr=" + noncestr + "&timestamp=" + timestamp + "&url=" + url;
                    //将字符串进行sha1加密
                    String signature = CheckUtil.shal(params);
                    //微信appId
                    String appId = WeChatConstants.appid;
                    wxInfo.put("appId", appId);
                    wxInfo.put("accessToken", accessToken);
                    wxInfo.put("jsapi_ticket", jsapiTicket);
                    wxInfo.put("timestamp", timestamp);
                    wxInfo.put("nonceStr", noncestr);
                    wxInfo.put("signature", signature);
                    System.out.println("微信分享成功");
                    return JsonResult.success(wxInfo);
                }else {
                    return JsonResult.failure("accessToken获取失败");
                }
            } catch (Exception e) {
                System.out.println("获取微信加密信息" + e.getMessage());
                return JsonResult.failure("生成加密信息错误");
            }
        }

### 3. accessToken的获取（缓存一个半小时） ###

public String getAccessToken() {
            //从缓存中获取
            Object obj = redisTemplate.opsForValue().get("access_token");
            if (obj != null){
                String access_token = (String)obj;
                return access_token;
            }else {
                String url = String.format(WeChatConstants.getTokenUrl, WeChatConstants.appid, WeChatConstants.secret);
                String result = NetWorkUtil.getHttpsResponse(url, "GET");
                if (StringUtils.isBlank(result)) {
                    return "";
                }
                JSONObject json = JSON.parseObject(result);
                // 获取token
                String access_token = json.getString("access_token");
                redisTemplate.opsForValue().set("access_token", access_token);
                redisTemplate.expire("access_token", 90, TimeUnit.MINUTES);
                return access_token;
            }
        }

### 4. 获取ticket（缓存一个半小时） ###

public String getTicket(String accessToken) {
            //从缓存中获取
            Object obj = redisTemplate.opsForValue().get("jsapi_ticket");
            if (obj != null){
                String ticket = (String)obj;
                return ticket;
            }else {
                String url = String.format(WeChatConstants.getTicket, accessToken);
                String result = NetWorkUtil.getHttpsResponse(url, "GET");
                if (StringUtils.isBlank(result)) {
                    return "";
                }
                JSONObject json = JSON.parseObject(result);
                String ticket = json.getString("ticket");
                redisTemplate.opsForValue().set("jsapi_ticket", ticket);
                redisTemplate.expire("jsapi_ticket", 90, TimeUnit.MINUTES);
                return ticket;
            }
        }

### 5. 字符串加密（sha1） ###

/***
         * SHA加密 生成40位SHA码
         * @param  str 待加密字符串
         * @return 返回40位SHA码
         */
        public static String shal(String str){
            try {
                MessageDigest digest = MessageDigest.getInstance("SHA-1");
                digest.update(str.getBytes());
                byte messageDigest[] = digest.digest();
    
                StringBuffer hexString = new StringBuffer();
                // 字节数组转换为 十六进制 数
                for (int i = 0; i < messageDigest.length; i++) {
                    String shaHex = Integer.toHexString(messageDigest[i] & 0xFF);
                    if (shaHex.length() < 2) {
                        hexString.append(0);
                    }
                    hexString.append(shaHex);
                }
                return hexString.toString();
    
            } catch (NoSuchAlgorithmException e) {
                e.printStackTrace();
            }
            return "";
        }

## 二、用户是否关注公众号 ##

public  JsonResult isSubscribe(String code,HttpServletResponse response){
            //获取基础token
            String access_token = weChatService.getAccessToken();
            if (StringUtil.isNotEmpty(access_token)) {
                //获取openId
                Map<String, Object> map = new HashMap<>();
                map.put("appid", WeChatConstants.appid);
                map.put("secret", WeChatConstants.secret);
                map.put("code", code);
                map.put("grant_type", "authorization_code");
                String wxResult = HttpUtil.get(WeChatConstants.getUserTokenUrl, map);
                JSONObject object = JSONObject.parseObject(wxResult);
                String openid = (String) object.get("openid");
    
                //获取关注状态
                if (StringUtil.isNotEmpty(openid)) {
                    Map<String, Object> map2 = new HashMap<>();
                    map2.put("access_token",access_token);
                    map2.put("openid",openid);
                    map2.put("lang","zh_CN");
                    //HttpUtil为hutool工具包下的
                    String wxSubResult = HttpUtil.get(WeChatConstants.getUserUtl, map2);
                    JSONObject object2 = JSONObject.parseObject(wxSubResult);
                    //关注字段  关注为1 未关注为0
                    Integer subscribe =  object2.getInteger("subscribe");
                    if (subscribe != null && subscribe == 1){
                        return JsonResult.success(true);
                    }else {
                        return JsonResult.success(false);
                    }
                }
                return JsonResult.failure("获取openid失败");
    
            }
            return JsonResult.failure("获取access_token失败");
       }