| | |
| | | } |
| | | |
| | | String openId = json.getString("openid"); |
| | | String sessionKey = json.getString("session_key"); |
| | | log.info("openId={},sessionKey={}", openId, sessionKey); |
| | | String accessToken = json.getString("access_token"); |
| | | log.info("openId={}", openId); |
| | | // 查询用户是否存在 |
| | | MallMember mallMember = null; |
| | | synchronized (this) { |
| | | mallMember = this.baseMapper.selectMemberByOpenId(openId); |
| | | if (ObjectUtil.isEmpty(mallMember)) { |
| | | // 新增用户 |
| | | agentProducer.sendMemberSubMsg(openId); |
| | | } else { |
| | | mallMember.setSessionKey(sessionKey); |
| | | this.baseMapper.updateById(mallMember); |
| | | } |
| | | MallMember mallMember = this.baseMapper.selectMemberByOpenId(openId); |
| | | if (ObjectUtil.isEmpty(mallMember)) { |
| | | return febsResponse.fail().message("请先关注公众号"); |
| | | } |
| | | // 存放redis |
| | | String redisKey = AppContants.XCX_LOGIN_PREFIX + mallMember.getId(); |
| | |
| | | authInfo.put("appid", xcxProperties.getXcxAppid()); |
| | | authInfo.put("member", mallMember); |
| | | authInfo.put("rasToken", generateAsaToken(token)); |
| | | authInfo.put("accessToken",accessToken); |
| | | authInfo.put("openId",openId); |
| | | agentProducer.sendMemberInfoMsg(accessToken+"|"+openId); |
| | | febsResponse.success().data(authInfo); |
| | | } else { |
| | | return febsResponse.fail().message("自动登录失败"); |