微信订阅号开发,获取openid的方式
需求:微信订阅号开发,点击微信自定义菜单,获取关注用户的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; }
相关推荐
cdkey 2020-05-04
zuoliangzhu 2020-05-16
蓝色深海 2020-03-24
caiyiii 2020-04-29
powderhose 2020-04-25
zengfanpei 2020-04-22
powderhose 2019-12-13
zengfanpei 2019-11-02
CodeAndroid 2019-05-05
资源分享 2019-04-29
newhappy 2019-04-10
czsong 2011-06-13
small 2019-07-01
klshige 2019-06-30
Donutsapps 2019-06-30
XGQ 2019-06-29