| | |
|---|
| | | user.setFace("https://i.loli.net/2020/11/19/LyN6JF7zZRskdIe.png"); |
|---|
| | | memberService.registerHandler(user); |
|---|
| | | } |
|---|
| | | |
|---|
| | | ConnectAuthUser connectAuthUser = new ConnectAuthUser(); |
|---|
| | | connectAuthUser.setUuid(openId); |
|---|
| | | connectAuthUser.setNickname(user.getNickName()); |
|---|
| | | connectAuthUser.setAvatar(user.getFace()); |
|---|
| | | |
|---|
| | | |
|---|
| | | connectAuthUser.setUsername(UuidUtils.getUUID()); |
|---|
| | | |
|---|
| | | connectAuthUser.setSource(ConnectEnum.WECHAT); |
|---|
| | | connectAuthUser.setType(ClientTypeEnum.WECHAT_MP); |
|---|
| | | |
|---|
| | | AuthToken authToken = new AuthToken(); |
|---|
| | | authToken.setUnionId(unionId); |
|---|
| | | connectAuthUser.setToken(authToken); |
|---|
| | | |
|---|
| | | //发送用户第三方登录消息 |
|---|
| | | MemberConnectLoginMessage memberConnectLoginMessage = new MemberConnectLoginMessage(); |
|---|
| | | memberConnectLoginMessage.setMember(user); |
|---|
| | | memberConnectLoginMessage.setConnectAuthUser(connectAuthUser); |
|---|
| | | String destination = |
|---|
| | | rocketmqCustomProperties.getMemberTopic() + ":" + MemberTagsEnum.MEMBER_CONNECT_LOGIN.name(); |
|---|
| | | //发送用户第三方登录消息 |
|---|
| | | rocketMQTemplate.asyncSend(destination, JSONUtil.toJsonStr(memberConnectLoginMessage), |
|---|
| | | RocketmqSendCallbackBuilder.commonCallback()); |
|---|
| | | Token token = memberTokenGenerate.createToken(user, Boolean.TRUE); |
|---|
| | | return Result.ok().data(token); |
|---|
| | | } |
|---|
