| | |
|---|
| | | 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.*; |
|---|
| | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | */ |
|---|
| | | @Autowired |
|---|
| | | private Cache cache; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private VideoAccountService videoAccountService; |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Member findByUsername(String userName) { |
|---|
| | |
|---|
| | | 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(), |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
