|
@@ -17,6 +17,7 @@ import org.springframework.stereotype.Service;
|
|
|
import java.time.Duration;
|
|
import java.time.Duration;
|
|
|
import java.util.HashMap;
|
|
import java.util.HashMap;
|
|
|
import java.util.Map;
|
|
import java.util.Map;
|
|
|
|
|
+import java.util.regex.Pattern;
|
|
|
|
|
|
|
|
@Service
|
|
@Service
|
|
|
@Slf4j
|
|
@Slf4j
|
|
@@ -44,7 +45,14 @@ public class RegisterListener implements RocketMQListener<RegisterEvent> {
|
|
|
redisTemplate.opsForValue().set("register::" + registerEvent.getPhone(), map, Duration.ofSeconds(600));
|
|
redisTemplate.opsForValue().set("register::" + registerEvent.getPhone(), map, Duration.ofSeconds(600));
|
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
|
map.put("status", "fail");
|
|
map.put("status", "fail");
|
|
|
- map.put("data", e.getMessage());
|
|
|
|
|
|
|
+ String message = e.getMessage();
|
|
|
|
|
+ if (Pattern.matches(".*SQL.*constraint.*user_index_phone.*", e.getMessage())) {
|
|
|
|
|
+ message = "手机号已注册";
|
|
|
|
|
+ }
|
|
|
|
|
+ if (Pattern.matches(".*SQL.*constraint.*username.*", e.getMessage())) {
|
|
|
|
|
+ message = "用户名已存在";
|
|
|
|
|
+ }
|
|
|
|
|
+ map.put("data", message);
|
|
|
redisTemplate.opsForValue().set("register::" + registerEvent.getPhone(), map, Duration.ofSeconds(600));
|
|
redisTemplate.opsForValue().set("register::" + registerEvent.getPhone(), map, Duration.ofSeconds(600));
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|