From 4833a836e3c180275bc72d7023477c407e2e43f2 Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期二, 03 六月 2025 19:16:54 +0800
Subject: [PATCH] 注册用户时同时增加一个视频账户
---
framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberServiceImpl.java | 41 +++++++++++++++++++----------------------
1 files changed, 19 insertions(+), 22 deletions(-)
diff --git a/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberServiceImpl.java b/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberServiceImpl.java
index 469bfba..2fa2972 100644
--- a/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberServiceImpl.java
+++ b/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberServiceImpl.java
@@ -22,6 +22,8 @@
import cn.lili.modules.connect.entity.Connect;
import cn.lili.modules.connect.entity.dto.ConnectAuthUser;
import cn.lili.modules.connect.service.ConnectService;
+import cn.lili.modules.lmk.domain.entity.VideoAccount;
+import cn.lili.modules.lmk.service.VideoAccountService;
import cn.lili.modules.member.aop.annotation.PointLogPoint;
import cn.lili.modules.member.entity.dos.Member;
import cn.lili.modules.member.entity.dto.*;
@@ -47,6 +49,7 @@
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import lombok.RequiredArgsConstructor;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
@@ -67,44 +70,33 @@
* @since 2021-03-29 14:10:16
*/
@Service
+@RequiredArgsConstructor
public class MemberServiceImpl extends ServiceImpl<MemberMapper, Member> implements MemberService {
/**
* 浼氬憳token
*/
- @Autowired
- private MemberTokenGenerate memberTokenGenerate;
+ private final MemberTokenGenerate memberTokenGenerate;
/**
* 鍟嗗token
*/
- @Autowired
- private StoreTokenGenerate storeTokenGenerate;
+ private final StoreTokenGenerate storeTokenGenerate;
/**
* 鑱斿悎鐧诲綍
*/
- @Autowired
- private ConnectService connectService;
+ private final ConnectService connectService;
/**
* 搴楅摵
*/
- @Autowired
- private StoreService storeService;
+ private final StoreService storeService;
/**
* RocketMQ 閰嶇疆
*/
- @Autowired
- private RocketmqCustomProperties rocketmqCustomProperties;
-
- @Autowired
- private RocketMQTemplate rocketMQTemplate;
-
- @Autowired
- private ApplicationEventPublisher applicationEventPublisher;
- /**
- * 缂撳瓨
- */
- @Autowired
- private Cache cache;
+ private final RocketmqCustomProperties rocketmqCustomProperties;
+ private final RocketMQTemplate rocketMQTemplate;
+ private final ApplicationEventPublisher applicationEventPublisher;
+ private final Cache cache;
+ private final VideoAccountService videoAccountService;
@Override
public Member findByUsername(String userName) {
@@ -310,6 +302,11 @@
member.setId(SnowFlake.getIdStr());
//淇濆瓨浼氬憳
this.save(member);
+ // 鍚屾椂鏂板涓�涓棰戣处鍙�
+ VideoAccount videoAccount = new VideoAccount();
+ videoAccount.setUserId(member.getId());
+ videoAccountService.save(videoAccount);
+
UserContext.settingInviter(member.getId(), cache);
// 鍙戦�佷細鍛樻敞鍐屼俊鎭�
applicationEventPublisher.publishEvent(new TransactionCommitSendMQEvent("new member register", rocketmqCustomProperties.getMemberTopic(),
@@ -844,4 +841,4 @@
}
}
-}
\ No newline at end of file
+}
--
Gitblit v1.8.0