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

Java 实现微信扫码登录方法（提供前端及后端核心代码）_java微信扫码登录

作者：繁依Fanyi0 | 2024-06-05 08:43:21

赞

踩

java微信扫码登录

思路

1、Vue前端页面获取一个公众号的二维码，不是普通二维号，是带有场景值的

2、java后端接收前端的请求，生成一个带时效性的二维码链接返回给前端

3、公众号平台配置服务器接口地址

4、接收到关注或扫码请求并相应处理

5、前端轮询状态，如果检查到验证通过进到下一页面

前端页面

vue代码

  1.     wxlogin() {
  2.         this.$showLoading();
  3.         getTempQrCode(this.token).then((res) => {
  4.             console.log("res==========",res);
  5.             this.$closeLoading();
  6.             this.imageUrl = objToStr(res.data.message);
  7.             this.loginType='wx'
  8.             setTimeout(() => {
  9.                 this.check();               
  10.             }, 1000);
  11.         }) 
  12.     },

java代码

  1. @RequestMapping(value = "/getTempQrCode", method = RequestMethod.GET)
  2. public Result<?> getTempQrCode(@RequestParam(name = "scene_str", required = true) String sceneStr) {
  3.  
  4.         WeixinHelper.setAppId(appid);
  5.         WeixinHelper.setSecret(secret);
  6.         String result = WeixinHelper.createTempQrCode(WeixinHelper.getAccessToken(), sceneStr);
  7.         return Result.ok(result);
  8. }
  9.  
  10.  
  11. public static String createTempQrCode(String access_token, String scene_str) {
  12.         String url = "https://api.weixin.qq.com/cgi-bin/qrcode/create?access_token=" + access_token;
  13.         Map<String, Object> data = new HashMap<>();
  14.         data.put("expire_seconds", 604800);
  15.         data.put("action_name", "QR_STR_SCENE");
  16.         Map<String, Object> action_info = new HashMap<>();
  17.         Map<String, Object> scene = new HashMap<>();
  18.         scene.put("scene_str", scene_str);
  19.         action_info.put("scene", scene);
  20.         data.put("action_info", action_info);
  21.         String json = HttpUtil.createPost(url)
  22.                 .header("Content-Type", "application/json")
  23.                 .body(JSONUtil.toJsonStr(data))
  24.                 .execute().body();
  25.         System.out.println("json = " + json);
  26.         String qrcode = (String) JSONUtil.getByPath(JSONUtil.parse(json), "ticket");
  27.         return "https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=" + qrcode;
  28.     }
  29.  
  30.  
  31.  
  32. public static String getAccessToken() {
  33.         accessToken = getNewAccessToken();
  34.         return accessToken;
  35. }
  36.  
  37.  
  38. public static String getNewAccessToken() {
  39.         String access_token = "";
  40.         String grant_type = "client_credential";//获取access_token填写client_credential
  41.         String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=" + grant_type + "&appid=" + appId + "&secret=" + secret;
  42.         try {
  43.             URL urlGet = new URL(url);
  44.             HttpURLConnection http = (HttpURLConnection) urlGet.openConnection();
  45.             http.setRequestMethod("GET"); // 必须是get方式请求
  46.             http.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
  47.             http.setDoOutput(true);
  48.             http.setDoInput(true);
  49.             System.setProperty("sun.net.client.defaultConnectTimeout", "30000");// 连接超时30秒
  50.             System.setProperty("sun.net.client.defaultReadTimeout", "30000"); // 读取超时30秒
  51.             http.connect();
  52.             InputStream is = http.getInputStream();
  53.             int size = is.available();
  54.             byte[] jsonBytes = new byte[size];
  55.             is.read(jsonBytes);
  56.             String message = new String(jsonBytes, "UTF-8");
  57.             JSONObject demoJson = JSONObject.parseObject(message);
  58.             System.out.println("JSON字符串：" + demoJson);
  59.             access_token = demoJson.getString("access_token");
  60.             is.close();
  61.         } catch (Exception e) {
  62.             e.printStackTrace();
  63.         }
  64.         return access_token;
  65. }
  66.  
  67.  
  68.  
  69.

公众号配置

java提供消息接收接口代码，有两个，一个get（公众平台网址验证的时候用）,一个post（消息事件触发时用）

  1. /*
  2.      * @param signature 微信加密签名，signature结合了开发者填写的 token 参数和请求中的 timestamp 参数、nonce参数。
  3.      * @param timestamp 时间戳
  4.      * @param nonce     这是个随机数
  5.      * @param echostr   随机字符串，验证成功后原样返回
  6.      */
  7.     @GetMapping("/wx/event")
  8.     public void get(@RequestParam(required = false) String signature,
  9.                     @RequestParam(required = false) String timestamp,
  10.                     @RequestParam(required = false) String nonce,
  11.                     @RequestParam(required = false) String echostr,
  12.                     HttpServletResponse response) throws IOException {
  13.         System.out.println("接受事件===" + echostr);
  14.         response.setCharacterEncoding("UTF-8");
  15.         response.getWriter().write(echostr);
  16.         response.getWriter().flush();
  17.         response.getWriter().close();
  18.     }
  19.  
  20.     //处理微信推送事件
  21.     @PostMapping("/wx/event")
  22.     public void post(final HttpServletRequest request, HttpServletResponse response) {
  23.  
  24.         System.out.println("接受事件");
  25.         try {
  26.             // 微信加密签名
  27.             final String signature = request.getParameter("signature");
  28.             // 时间戳
  29.             final String timestamp = request.getParameter("timestamp");
  30.             // 随机数
  31.             final String nonce = request.getParameter("nonce");
  32.             // 随机字符串
  33.             final String echostr = request.getParameter("echostr");
  34.             //将xml文件转成易处理的map(下方贴出)
  35.             final Map<String, String> map = oConvertUtils.parseXml(request);
  36.             //开发者微信号
  37.             final String toUserName = map.get("ToUserName");
  38.             //OpenId
  39.             final String fromUserName = map.get("FromUserName");
  40.             //消息创建时间 （整型）
  41.             final String createTime = map.get("CreateTime");
  42.             //消息类型，event
  43.             final String msgType = map.get("MsgType");
  44.             //事件类型
  45.             final String event = map.get("Event");
  46.  
  47.             String scene_str = "";
  48.             String msg = "";
  49.             if ("event".equals(msgType)) {
  50.                 if (event.equals("subscribe")) {
  51.                     final String ticket = map.get("Ticket");
  52.                     if (ticket != null) {
  53.                         scene_str = map.get("EventKey").replace("qrscene_", "");
  54.                     }
  55.                     msg = getXmlReturnMsg(fromUserName, toUserName, (new Date()).getTime(), "欢迎您使用量子文档");
  56.                 }
  57.                 //注：事件类型为SCAN即已关注
  58.                 else if (event.equals("SCAN")) {
  59.                     final String ticket = map.get("Ticket");
  60.                     if (ticket != null) {
  61.                         scene_str = map.get("EventKey");
  62.                     }
  63.                     msg = getXmlReturnMsg(fromUserName, toUserName, (new Date()).getTime(), "您刚刚扫码登录了量子文档");
  64.  
  65.                 }
  66.             }
  67.             System.out.println("event：" + event);
  68.             System.out.println("场景值：" + scene_str);
  69.             System.out.println("openId：" + fromUserName);
  70.             System.out.println("ToUserName：" + toUserName);
  71.  
  72.             // 如果scene_str 不为空代表用户已经扫描并且关注了公众号
  73.             if (oConvertUtils.isNotEmpty(scene_str)) {
  74.                 QueryWrapper<SysUser> queryWrapper = new QueryWrapper<>();
  75.                 queryWrapper.eq("open_id", fromUserName);
  76.                 SysUser sysUser = sysUserService.getOne(queryWrapper, false);
  77.                 if (sysUser == null) {
  78.                     sysUser = new SysUser();
  79.                     sysUser.setOpenId(fromUserName);
  80.                     sysUser.setUsername(fromUserName);
  81.                     sysUser.setRealname(null);
  82.                     String salt = oConvertUtils.randomGen(8);
  83.                     String passwordEncode = PasswordUtil.encrypt(fromUserName, salt, salt);
  84.                     sysUser.setSalt(salt);
  85.                     sysUser.setMemberLevelId("1");
  86.                     sysUser.setPassword(passwordEncode);
  87.                     sysUser.setStatus(1);
  88.                     sysUser.setDelFlag(CommonConstant.DEL_FLAG_0);
  89.                     sysUserService.save(sysUser);
  90.                     LzMessage message = new LzMessage();
  91.                     message.setMsgDate(new Date());
  92.                     message.setContent("欢迎您使用量子文档");
  93.                     message.setFileId(null);
  94.                     message.setIsRead(0);
  95.                     message.setDelFlag(0);
  96.                     message.setMsgType(3);
  97.                     message.setFromUserId("001");
  98.                     message.setFromUserName("小量子");
  99.                     message.setToUserId(sysUser.getId());
  100.                     lzMessageService.save(message);
  101.                 }
  102.                 // 将微信公众号用户ID缓存到redis中，标记用户已经扫码完成，执行登录逻辑。
  103.                 redisUtil.set(scene_str, fromUserName, 60);
  104.             }
  105.             System.out.println("打印消息体=========");
  106.             System.out.println(msg);
  107.             System.out.println("=========");
  108.  
  109.             response.setCharacterEncoding("UTF-8");
  110.             PrintWriter out = response.getWriter();
  111.             out.print(msg);
  112.             out.flush();
  113.             out.close();
  114.  
  115.         } catch (Exception e) {
  116.             e.printStackTrace();
  117.         }
  118.     }

vue前端轮询

  1. check() {
  2.         if (this.loginType!='wx') return false;       
  3.         checkScanState(this.token).then((res) => {
  4.             console.log(res);
  5.             console.log("check....");
  6.             if (res.data.success == true) {
  7.                 sessionStorage.setItem('token', res.data.result.token)
  8.                 sessionStorage.setItem('userId', res.data.result.userInfo.id)
  9.                 sessionStorage.setItem('userName', res.data.result.userInfo.username)
  10.                 sessionStorage.setItem('realname', res.data.result.userInfo.realname)
  11.                 sessionStorage.setItem('sex', res.data.result.userInfo.sex)
  12.                 sessionStorage.setItem('memberLevelName', res.data.result.memberLevel.name)
  13.                 sessionStorage.setItem('maxFileCount', res.data.result.memberLevel.maxFileCount)
  14.                 this.loginType = "";
  15.                 if (objToStr(res.data.result.userInfo.realname) == "") {
  16.                     this.$showInputBox({
  17.                         caption: "输入您的姓名",
  18.                         inputValue: '',
  19.                         callback: (data) => {
  20.                             updateRealname(res.data.result.userInfo.id, data).then((res) => {
  21.                                 sessionStorage.setItem('realname', data)
  22.                                 this.$closeInputBox();    
  23.                             })
  24.                         }
  25.                     })
  26.                 }
  27.                 this.$router.push({
  28.                     path: '/person' ,
  29.                 })
  30.             } else {               
  31.                 setTimeout(() => {
  32.                     this.check();               
  33.                 }, 1000);
  34.             }
  35.         })           
  36.     },

后端接受前端查状态的轮询请求

  1. @ApiOperation("检查扫码状态")
  2. 	@GetMapping("/checkScanState")
  3. 	public Result<JSONObject> wechatLogin(@RequestParam(name = "scene_str", required = true) String sceneStr) {
  4. 		Result<JSONObject> result = new Result<JSONObject>();
  5. 		Object openId = redisUtil.get(sceneStr);
  6. 		if (openId == null) {
  7. 			result.error500("未登入");
  8. 			return result;
  9. 		}
  10.  
  11. 		QueryWrapper<SysUser> queryWrapper = new QueryWrapper<>();
  12. 		queryWrapper.eq("open_id", openId);
  13. 		SysUser sysUser = sysUserService.getOne(queryWrapper, false);
  14. 		if (sysUser != null) {
  15.  
  16. 			String syspassword = sysUser.getPassword();
  17. 			String username = sysUser.getUsername();
  18. 			// 生成token
  19. 			String token = JwtUtil.sign(username, syspassword);
  20. 			redisUtil.del(CommonConstant.PREFIX_USER_TOKEN + token);
  21. 			//清空用户登录Shiro权限缓存
  22. 			redisUtil.del(CommonConstant.PREFIX_USER_SHIRO_CACHE + sysUser.getId());
  23. 			//清空用户的缓存信息（包括部门信息），例如sys:cache:user::<username>
  24. 			redisUtil.del(String.format("%s::%s", CacheConstant.SYS_USERS_CACHE, sysUser.getUsername()));
  25.  
  26. 			result = sysUserService.checkUserIsEffective(sysUser);
  27. 			if(!result.isSuccess()) {
  28. 				return result;
  29. 			}
  30. 			//用户信息
  31. 			userInfo(sysUser, result);
  32. 			//添加日志
  33. 			sysBaseAPI.addLog("用户名: " + sysUser.getUsername() + ",登录成功！", CommonConstant.LOG_TYPE_1, null);
  34. 		}
  35. 		return result;
  36. 	}
  37.  
  38.  
  39.  
  40. 	/**
  41. 	 * 用户信息
  42. 	 *
  43. 	 * @param sysUser
  44. 	 * @param result
  45. 	 * @return
  46. 	 */
  47. 	private Result<JSONObject> userInfo(SysUser sysUser, Result<JSONObject> result) {
  48. 		String syspassword = sysUser.getPassword();
  49. 		String username = sysUser.getUsername();
  50. 		// 生成token
  51. 		String token = JwtUtil.sign(username, syspassword);
  52.         // 设置token缓存有效时间
  53. 		redisUtil.set(CommonConstant.PREFIX_USER_TOKEN + token, token);
  54. 		redisUtil.expire(CommonConstant.PREFIX_USER_TOKEN + token, JwtUtil.EXPIRE_TIME*2 / 1000);
  55.  
  56. 		// 获取用户部门信息
  57. 		JSONObject obj = new JSONObject();
  58. 		List<SysDepart> departs = sysDepartService.queryUserDeparts(sysUser.getId());
  59. 		obj.put("departs", departs);
  60. 		if (departs == null || departs.size() == 0) {
  61. 			obj.put("multi_depart", 0);
  62. 		} else if (departs.size() == 1) {
  63. 			sysUserService.updateUserDepart(username, departs.get(0).getOrgCode());
  64. 			obj.put("multi_depart", 1);
  65. 		} else {
  66. 			obj.put("multi_depart", 2);
  67. 		}
  68. 		obj.put("token", token);
  69. 		obj.put("userInfo", sysUser);
  70. 		obj.put("sysAllDictItems", sysDictService.queryAllDictItems());
  71. 		obj.put("memberLevel", lzMemberLevelService.getById(sysUser.getMemberLevelId()));
  72. 		result.setResult(obj);
  73. 		result.success("登录成功");
  74. 		return result;
  75. 	}

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

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

  

闽ICP备14008679号