Преглед на файлове

fix: redis用户解锁监控,先行判断是否为子库用户

hidewnd преди 1 месец
родител
ревизия
5092f43829
променени са 1 файла, в които са добавени 4 реда и са изтрити 0 реда
  1. 4 0
      yt-question/yt-question-service/src/main/java/com/ytpm/question/monitor/RedisKeyExpirationListener.java

+ 4 - 0
yt-question/yt-question-service/src/main/java/com/ytpm/question/monitor/RedisKeyExpirationListener.java

@@ -58,6 +58,10 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene
         // 用户解锁
         if (key.startsWith("unlock_")) {
             String[] arr = key.split("_");
+            YtDyzUser user = appUserMapper.selectPrimaryKey(arr[1]);
+            if (user == null) {
+                return;
+            }
             YtDyzUser dyzUser = new YtDyzUser();
             dyzUser.setUserId(arr[1]);
             dyzUser.setUserStatus(1);