|
|
@@ -2,6 +2,8 @@ package com.izouma.nineth.listener;
|
|
|
|
|
|
import com.izouma.nineth.domain.User;
|
|
|
import com.izouma.nineth.event.RegisterEvent;
|
|
|
+import com.izouma.nineth.security.JwtTokenUtil;
|
|
|
+import com.izouma.nineth.security.JwtUserFactory;
|
|
|
import com.izouma.nineth.service.UserService;
|
|
|
import lombok.AllArgsConstructor;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
@@ -25,8 +27,9 @@ import java.util.Map;
|
|
|
consumeMode = ConsumeMode.ORDERLY)
|
|
|
@ConditionalOnProperty(value = "general.notify-server", havingValue = "false", matchIfMissing = true)
|
|
|
public class RegisterListener implements RocketMQListener<RegisterEvent> {
|
|
|
- private UserService userService;
|
|
|
- private RedisTemplate<String, Object> redisTemplate;
|
|
|
+ private UserService userService;
|
|
|
+ private RedisTemplate<String, Object> redisTemplate;
|
|
|
+ private final JwtTokenUtil jwtTokenUtil;
|
|
|
|
|
|
@Override
|
|
|
public void onMessage(RegisterEvent registerEvent) {
|
|
|
@@ -37,6 +40,7 @@ public class RegisterListener implements RocketMQListener<RegisterEvent> {
|
|
|
registerEvent.getInvitor(), registerEvent.getCollectionId());
|
|
|
map.put("status", "success");
|
|
|
map.put("data", user);
|
|
|
+ map.put("token", jwtTokenUtil.generateToken(JwtUserFactory.create(user)));
|
|
|
redisTemplate.opsForValue().set("register::" + registerEvent.getPhone(), map, Duration.ofSeconds(600));
|
|
|
} catch (Exception e) {
|
|
|
map.put("status", "fail");
|