From 7c038921c9242db70ea751ac45f6cdc6c35e4a2e Mon Sep 17 00:00:00 2001
From: zxl <763096477@qq.com>
Date: 星期二, 15 七月 2025 14:59:07 +0800
Subject: [PATCH] 商家端活动申请

---
 framework/src/main/java/cn/lili/modules/connect/serviceimpl/ConnectServiceImpl.java |   28 +++++++++++++++++++++++++++-
 1 files changed, 27 insertions(+), 1 deletions(-)

diff --git a/framework/src/main/java/cn/lili/modules/connect/serviceimpl/ConnectServiceImpl.java b/framework/src/main/java/cn/lili/modules/connect/serviceimpl/ConnectServiceImpl.java
index b281073..f0c599a 100644
--- a/framework/src/main/java/cn/lili/modules/connect/serviceimpl/ConnectServiceImpl.java
+++ b/framework/src/main/java/cn/lili/modules/connect/serviceimpl/ConnectServiceImpl.java
@@ -259,9 +259,35 @@
             user.setUsername(UuidUtils.getUUID());
             user.setNickName("寰俊鐢ㄦ埛");
             user.setPassword(DEFAULT_PASSWORD);
-            user.setFace("https://i.loli.net/2020/11/19/LyN6JF7zZRskdIe.png");
+            user.setFace("");
+            user.setDisabled(Boolean.TRUE);
             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);
     }

--
Gitblit v1.8.0