| | |
| | | import cn.lili.common.security.token.Token; |
| | | import cn.lili.common.security.token.TokenUtil; |
| | | import cn.lili.common.security.token.base.AbstractTokenGenerate; |
| | | import cn.lili.modules.member.entity.dos.Clerk; |
| | | import cn.lili.modules.member.entity.dos.Member; |
| | | import cn.lili.modules.member.service.ClerkService; |
| | | import cn.lili.rocketmq.RocketmqSendCallbackBuilder; |
| | | import cn.lili.rocketmq.tags.MemberTagsEnum; |
| | | import org.apache.rocketmq.spring.core.RocketMQTemplate; |
| | |
| | | @Autowired |
| | | private RocketMQTemplate rocketMQTemplate; |
| | | |
| | | @Autowired |
| | | private ClerkService clerkService; |
| | | |
| | | @Override |
| | | public Token createToken(Member member, Boolean longTerm) { |
| | | |
| | |
| | | String destination = rocketmqCustomProperties.getMemberTopic() + ":" + MemberTagsEnum.MEMBER_LOGIN.name(); |
| | | rocketMQTemplate.asyncSend(destination, member, RocketmqSendCallbackBuilder.commonCallback()); |
| | | |
| | | Clerk clerk = clerkService.getClerkByMemberId(member.getId()); |
| | | |
| | | AuthUser authUser = AuthUser.builder() |
| | | .username(member.getUsername()) |
| | | .face(member.getFace()) |
| | | .id(member.getId()) |
| | | .role(UserEnums.MEMBER) |
| | | .role(clerk == null ? UserEnums.MEMBER : UserEnums.STORE) |
| | | .storeId(clerk == null ? null : clerk.getStoreId()) |
| | | .nickName(member.getNickName()) |
| | | .longTerm(longTerm) |
| | | .build(); |