微信订阅号开发,获取openid的方式

时间:2024-03-08 12:38:28

需求:微信订阅号开发,点击微信自定义菜单,获取关注用户的openid,并且传到后台与前端页面

说明:订阅号无法直接获取关注用户的openid传到前端,只能通过微信开放平台将订阅号和服务号关联起来,获取用户的uionid,这样就可以确定当前操作的微信用户

场景:

1. 菜单类型为 view,创建view的代码:

// 网页跳转菜单
Map<String, String> menu1_1 = new HashMap<>();
menu1_1.put("type", "view");
menu1_1.put("name", "进入生态圈");
menu1_1.put("url", "http://域名/menu/auth?redirect_uri=http://域名/menu/index");

Controller 代码:

/**
* 授权入口:订阅号设置了业务域名后才会进入此方法
* @param request
* @param response
*/
@RequestMapping(value = "/auth",method = RequestMethod.GET)
@ResponseBody
public void auth(HttpServletRequest request, HttpServletResponse response) {
    try {

        Map<String, String[]> paramterMap = request.getParameterMap();
        log.info("auth click Parameter: [");
        paramterMap.forEach((k,v)->{
            log.info("key : " + k + ";value : " + Arrays.toString(v));
        });
        log.info("]");

        // 跳转的URL必须要做encode
        String redirectUrl = URLEncoder.encode(request.getParameter("redirect_uri"), SysConst.ENCODE_UTF8);

        // 使用服务号的appid授权获取用户基本信息,然后跳转到redirect_uri,跳转到redirect_uri后,回接收到code
        String authUrl = "https://open.weixin.qq.com/connect/oauth2/authorize?appid="+WeChatConfigDYH.APP_ID_FWH
        +"&redirect_uri="+redirectUrl
        +"&response_type=code&scope=snsapi_userinfo&state=STATE&connect_redirect=1#wechat_redirect"; //跳转授权页面 response.sendRedirect(authUrl); } catch (Exception e) { e.printStackTrace(); } } /** * 授权接口跳转uri入口 * @param request * @param response */ @RequestMapping(value = "/index",method = RequestMethod.GET) public String index(HttpServletRequest request, HttpServletResponse response) { try { Map<String, String[]> paramterMap = request.getParameterMap(); log.info("view click Parameter: ["); paramterMap.forEach((k,v)->{ log.info("key : " + k + ";value : " + Arrays.toString(v)); }); log.info("]"); String code = request.getParameter("code"); log.debug("auth redirect_uri code = " + code); JSONObject weChatCode = _dataCache.getWeChatCode(code); if (weChatCode == null) { //通过code换取网页授权access_token(与基础支持中的access_token不同) String requestUrl = "https://api.weixin.qq.com/sns/oauth2/access_token?appid="+WeChatConfigDYH.APP_ID_FWH
          +"&secret="+WeChatConfigDYH.APP_SECRET_FWH
          +"&code="+code+"&grant_type=authorization_code"; //返回信息:包含unionid,标志唯一用户 String accessInfoStr = _restTemplate.getForObject(requestUrl, String.class); // 转化成JSONObject weChatCode = JSONObject.parseObject(accessInfoStr); // 存入缓存 _dataCache.putWeChatCode(code, weChatCode); } log.debug(weChatCode.toString()); // 微信unionid,唯一 String unionid = weChatCode.getString("unionid"); // 客户ID String fcustomerid495 = null; // 获取用户信息 Customer customer = _customerService.findByUnionId(unionid); if (customer != null) { fcustomerid495 = customer.getFcustomerid495(); } // 设置unionid和fcustomerid到前端 request.setAttribute("unionid", unionid); request.setAttribute("fcustomerid", fcustomerid495); } catch (Exception e) { e.printStackTrace(); } return "index"; }

 

2. 菜单类型为 click 创建代码:

// 按钮click
Map<String, String> menu1_1 = new HashMap<>();
menu1_1.put("type", "click");
menu1_1.put("name", "进入生态圈");
menu1_1.put("key", "self_edit");

Controller代码:

/**
* 写法二
* @param requestBody
* @param signature
* @param timestamp
* @param nonce
* @param openid
* @param encType
* @param msgSignature
* @return
*/
@RequestMapping(method = RequestMethod.POST)
public String post(HttpServletRequest request, HttpServletResponse response,
        @RequestBody String requestBody,
        @RequestParam("signature") String signature,
        @RequestParam("timestamp") String timestamp,
        @RequestParam("nonce") String nonce,
        @RequestParam("openid") String openid,
        @RequestParam(name = "encrypt_type", required = false) String encType,
        @RequestParam(name = "msg_signature", required = false) String msgSignature) {

    // 返回给微信加密后的消息
    String respMessageEncrypt = "";
    try {
        request.setCharacterEncoding("UTF-8");
        response.setCharacterEncoding("UTF-8");

        Map<String, String> encryptMap = MessageUtil.fromEncryptedMap(requestBody, timestamp, nonce, msgSignature);
        log.info("菜单事件:" + encryptMap.toString());

        // 消息处理
        respMessageEncrypt = _weChatMessageService.newsMessage(encryptMap);

    } catch (Exception e) {
        e.printStackTrace();
    } finally {

    }

    return respMessageEncrypt;
}
/**
* 处理消息发送:图文消息
* @param request
* @return 加密消息字符传
*/
public String newsMessage(Map<String, String> requestMap) {
    // 返回加密消息字符串
    String respMessageEncrypt = null;
    try {
        // 发送方帐号(open_id)
        String fromUserName = requestMap.get("FromUserName");
        // 公众帐号
        String toUserName = requestMap.get("ToUserName");

        // 根据openid获取客户信息
        String fcustomerid495 = null;
        Customer customer = _customerService.findByOpenId(fromUserName);
        if (customer != null) {
            fcustomerid495 = customer.getFcustomerid495();
        }

        // 设置链接消息
        NewsMessageResp newsMessage = new NewsMessageResp();
        newsMessage.setToUserName(fromUserName);
        newsMessage.setFromUserName(toUserName);
        newsMessage.setCreateTime(new Date().getTime());
        newsMessage.setMsgId(UUID.randomUUID().toString());
        newsMessage.setMsgType(WeChatConst.RESP_MESSAGE_TYPE_NEWS);
        newsMessage.setArticleCount("1");

        // Articles
        List<Article> articleList = new ArrayList<Article>();
        Article article = new Article();
        article.setTitle("生态圈链接");
        article.setDescription("点击进入【生态圈】");
        article.setPicUrl("http://域名/img/htlogo.png");
        article.setUrl("http://域名?openid=" + fromUserName + "&fcustomerid=" + fcustomerid495);
        articleList.add(article);
        newsMessage.setArticles(articleList);

        // 链接消息xml
        String respMessage = MessageUtil.newsMessageToXml(newsMessage);
        log.info("链接消息 = " + respMessage);

        // 消息加密
        WxCryptUtil wxCryptUtil = new WxCryptUtil();
        respMessageEncrypt = wxCryptUtil.encrypt(respMessage);
        log.info("加密后的链接消息 = " + respMessageEncrypt);

    } catch (Exception e) {
        e.printStackTrace();
    }

    return respMessageEncrypt;
}