| | |
| | | } |
| | | |
| | | String openId = json.getString("openid"); |
| | | String sessionKey = json.getString("session_key"); |
| | | log.info("openId={},sessionKey={}", openId, sessionKey); |
| | | // String sessionKey = json.getString("session_key"); |
| | | log.info("openId={}", openId); |
| | | // 查询用户是否存在 |
| | | MallMember mallMember = null; |
| | | synchronized (this) { |
| | | mallMember = this.baseMapper.selectMemberByOpenId(openId); |
| | | if (ObjectUtil.isEmpty(mallMember)) { |
| | | // 新增用户 |
| | | agentProducer.sendMemberSubMsg(openId); |
| | | // agentProducer.sendMemberSubMsg(openId); |
| | | return febsResponse.fail().message("请先关注公众号"); |
| | | } else { |
| | | mallMember.setSessionKey(sessionKey); |
| | | mallMember.setOpenId(openId); |
| | | this.baseMapper.updateById(mallMember); |
| | | } |
| | | } |