修改清除缓冲bug,内部嵌套注解不好使

parent c937ac4b
...@@ -731,6 +731,7 @@ public class InnerController implements IBaseController { ...@@ -731,6 +731,7 @@ public class InnerController implements IBaseController {
user = userService.saveUser(user); user = userService.saveUser(user);
if (!user.getEnable()) { if (!user.getEnable()) {
sessionService.deleteByUserId(userId); sessionService.deleteByUserId(userId);
sessionService.deleteUserCatch(user);
} }
LOGGER.info("去清除函谷关的缓存"); LOGGER.info("去清除函谷关的缓存");
httpService.get(hanguguanUrl.concat("/innerapi/disableUserCache"), ImmutableMap.of("phone", user.getPhoneNo())); httpService.get(hanguguanUrl.concat("/innerapi/disableUserCache"), ImmutableMap.of("phone", user.getPhoneNo()));
...@@ -752,6 +753,7 @@ public class InnerController implements IBaseController { ...@@ -752,6 +753,7 @@ public class InnerController implements IBaseController {
return JsonResult.buildErrorStateResult("未查询到该用户,用户phoneNo:" + phoneNo, null); return JsonResult.buildErrorStateResult("未查询到该用户,用户phoneNo:" + phoneNo, null);
} }
sessionService.deleteByUserId(user.getId()); sessionService.deleteByUserId(user.getId());
sessionService.deleteUserCatch(user);
LOGGER.info("删除用户缓存信息,phoneNo:{},userId:{},", user.getPhoneNo(), user.getId()); LOGGER.info("删除用户缓存信息,phoneNo:{},userId:{},", user.getPhoneNo(), user.getId());
return JsonResult.buildSuccessResult("用户缓存信息已经删除", null); return JsonResult.buildSuccessResult("用户缓存信息已经删除", null);
} }
......
...@@ -28,4 +28,6 @@ public interface ISessionService { ...@@ -28,4 +28,6 @@ public interface ISessionService {
SessionStruct findSessionBySessionId(String sessionId); SessionStruct findSessionBySessionId(String sessionId);
void deleteByUserId(long userId); void deleteByUserId(long userId);
void deleteUserCatch(User user);
} }
...@@ -200,11 +200,8 @@ public class SessionServiceImpl implements ISessionService { ...@@ -200,11 +200,8 @@ public class SessionServiceImpl implements ISessionService {
} }
//3.删除用户查询缓存
User user = userService.findById(userId);
if (null != user) {
deleteUserCatch(user);
}
} }
...@@ -220,7 +217,8 @@ public class SessionServiceImpl implements ISessionService { ...@@ -220,7 +217,8 @@ public class SessionServiceImpl implements ISessionService {
@CacheEvict(value = "contact", key = "'contact' + #user.id", cacheManager = "cacheManager"), @CacheEvict(value = "contact", key = "'contact' + #user.id", cacheManager = "cacheManager"),
@CacheEvict(value = "userSpouseCache", key = "'spouse' + #user.id", cacheManager = "cacheManager"), @CacheEvict(value = "userSpouseCache", key = "'spouse' + #user.id", cacheManager = "cacheManager"),
@CacheEvict(value = "btRegisterCache", key = "'userId' + #user.id", cacheManager = "cacheManager")}) @CacheEvict(value = "btRegisterCache", key = "'userId' + #user.id", cacheManager = "cacheManager")})
private void deleteUserCatch(User user) { @Override
public void deleteUserCatch(User user) {
} }
} }
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