Commit f47e11b3 authored by xiaoguang.xu's avatar xiaoguang.xu

处理没有 session 情况下的 cache 过期问题

parent 98425f41
......@@ -9,6 +9,7 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
import java.util.List;
......@@ -27,7 +28,12 @@ public class CacheEvictPhoneNoUpdateEventListener implements ApplicationListener
String oldPhoneNo = event.getOldPhoneNo();
User user = event.getUser();
userService.userCacheEvict(user.getUuid(), oldPhoneNo);
List<SessionStruct> sessionStructList = sessionService.findByUserId(user.getId());
if (CollectionUtils.isEmpty(sessionStructList)) {
return;
}
for (SessionStruct sessionStruct : sessionStructList) {
SessionValue values = sessionStruct.getValues();
User sessionUser = values.getUser();
......@@ -37,6 +43,5 @@ public class CacheEvictPhoneNoUpdateEventListener implements ApplicationListener
}
sessionService.persistSession(sessionStructList);
userService.userCacheEvict(user.getUuid(), oldPhoneNo);
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment