去掉redis

main
zhaokai 2025-11-14 13:32:06 +08:00
parent b01cec1375
commit 56622a7e55
9 changed files with 40 additions and 40 deletions

View File

@ -42,10 +42,10 @@ public class UserController {
@ApiOperation("新增用户") @ApiOperation("新增用户")
@PostMapping("/test") @PostMapping("/test")
public SingleResponse<UserCO> test(@RequestBody UserCO cmd) { public SingleResponse<UserCO> test(@RequestBody UserCO cmd) {
SSOUser ssoUser = AuthContext.getCurrentUser(); // SSOUser ssoUser = AuthContext.getCurrentUser();
List<UserCO> userCOS = translateField.translateZcloudCommonInformation(Arrays.asList(cmd), UserCO.class); // List<UserCO> userCOS = translateField.translateZcloudCommonInformation(Arrays.asList(cmd), UserCO.class);
ZcloudDepartmentInfoCo zcloudDpetInfoById = translateField.getZcloudDpetInfoById(1985993429287899137L); // ZcloudDepartmentInfoCo zcloudDpetInfoById = translateField.getZcloudDpetInfoById(1985993429287899137L);
ZcloudUserCo zcloudUserInfoById = translateField.getZcloudUserInfoById(1985972624130953218L); // ZcloudUserCo zcloudUserInfoById = translateField.getZcloudUserInfoById(1985972624130953218L);
return SingleResponse.of(cmd); return SingleResponse.of(cmd);
} }

View File

@ -20,8 +20,8 @@ import org.springframework.transaction.annotation.Transactional;
@AllArgsConstructor @AllArgsConstructor
public class CorpInfoRemoveExe { public class CorpInfoRemoveExe {
private final CorpInfoGateway corpInfoGateway; private final CorpInfoGateway corpInfoGateway;
@Autowired // @Autowired
private ZcloudRedisUtil zcloudRedisUtil; // private ZcloudRedisUtil zcloudRedisUtil;
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public boolean execute(Long id) { public boolean execute(Long id) {
@ -30,7 +30,7 @@ public class CorpInfoRemoveExe {
throw new BizException("删除失败"); throw new BizException("删除失败");
} }
//删除redis数据 //删除redis数据
zcloudRedisUtil.del(Const.REDIS_CORP_PREFIX+id); // zcloudRedisUtil.del(Const.REDIS_CORP_PREFIX+id);
return true; return true;
} }
@ -40,9 +40,9 @@ public class CorpInfoRemoveExe {
if (!res) { if (!res) {
throw new BizException("删除失败"); throw new BizException("删除失败");
} }
for (Long id : ids) { // for (Long id : ids) {
zcloudRedisUtil.del(Const.REDIS_CORP_PREFIX+id); // zcloudRedisUtil.del(Const.REDIS_CORP_PREFIX+id);
} // }
return true; return true;
} }
} }

View File

@ -34,8 +34,8 @@ public class CorpInfoUpdateExe {
private final CorpInfoRepository corpInfoRepository; private final CorpInfoRepository corpInfoRepository;
@DubboReference @DubboReference
private TenantFacade tenantFacade; private TenantFacade tenantFacade;
@Autowired // @Autowired
private ZcloudRedisUtil zcloudRedisUtil; // private ZcloudRedisUtil zcloudRedisUtil;
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void execute(CorpInfoUpdateCmd corpInfoUpdateCmd) { public void execute(CorpInfoUpdateCmd corpInfoUpdateCmd) {
@ -46,7 +46,7 @@ public class CorpInfoUpdateExe {
throw new BizException("修改失败"); throw new BizException("修改失败");
} }
//删除redis数据 //删除redis数据
zcloudRedisUtil.del(Const.REDIS_CORP_PREFIX+corpInfoUpdateCmd.getId()); // zcloudRedisUtil.del(Const.REDIS_CORP_PREFIX+corpInfoUpdateCmd.getId());
} }
public void changeCompanyName(CorpInfoUpdateCmd corpInfoUpdateCmd) { public void changeCompanyName(CorpInfoUpdateCmd corpInfoUpdateCmd) {
@ -57,7 +57,7 @@ public class CorpInfoUpdateExe {
corpInfoGateway.changeCompanyName(corpInfoE); corpInfoGateway.changeCompanyName(corpInfoE);
//删除redis数据 //删除redis数据
zcloudRedisUtil.del(Const.REDIS_CORP_PREFIX+corpInfoUpdateCmd.getId()); // zcloudRedisUtil.del(Const.REDIS_CORP_PREFIX+corpInfoUpdateCmd.getId());
// OtaPlatformUserUpdateCmd otaUpdateCmd = new OtaPlatformUserUpdateCmd(); // OtaPlatformUserUpdateCmd otaUpdateCmd = new OtaPlatformUserUpdateCmd();
// otaUpdateCmd.setAccount(corpInfoE.getCorpName()); // otaUpdateCmd.setAccount(corpInfoE.getCorpName());

View File

@ -42,8 +42,8 @@ public class DepartmentRemoveExe {
private final DepartmentSuperviseGateway departmentSuperviseGateway; private final DepartmentSuperviseGateway departmentSuperviseGateway;
@DubboReference @DubboReference
private DeptFacade deptFacade; private DeptFacade deptFacade;
@Autowired // @Autowired
private ZcloudRedisUtil zcloudRedisUtil; // private ZcloudRedisUtil zcloudRedisUtil;
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public boolean execute(Long id) { public boolean execute(Long id) {
@ -71,7 +71,7 @@ public class DepartmentRemoveExe {
deptFacade.deleteById( id); deptFacade.deleteById( id);
//删除redis数据 //删除redis数据
zcloudRedisUtil.del(Const.REDIS_DEPT_PREFIX+id); // zcloudRedisUtil.del(Const.REDIS_DEPT_PREFIX+id);
return true; return true;
} }
@ -90,10 +90,10 @@ public class DepartmentRemoveExe {
throw new BizException("删除失败"); throw new BizException("删除失败");
} }
// 批量删除 Redis 缓存 - 循环处理每个ID // 批量删除 Redis 缓存 - 循环处理每个ID
for (Long id : ids) { // for (Long id : ids) {
deptFacade.deleteById( id); // deptFacade.deleteById( id);
zcloudRedisUtil.del(Const.REDIS_DEPT_PREFIX + id); // zcloudRedisUtil.del(Const.REDIS_DEPT_PREFIX + id);
} // }
//ids转成成list //ids转成成list
departmentSuperviseGateway.deletedDepartmentBySuperviseIdList(Arrays.asList(ids)); departmentSuperviseGateway.deletedDepartmentBySuperviseIdList(Arrays.asList(ids));

View File

@ -42,8 +42,8 @@ public class DepartmentUpdateExe {
private final DepartmentSuperviseGateway departmentSuperviseGateway; private final DepartmentSuperviseGateway departmentSuperviseGateway;
@DubboReference @DubboReference
private DeptFacade deptFacade; private DeptFacade deptFacade;
@Autowired // @Autowired
private ZcloudRedisUtil zcloudRedisUtil; // private ZcloudRedisUtil zcloudRedisUtil;
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void execute(DepartmentUpdateCmd departmentUpdateCmd) { public void execute(DepartmentUpdateCmd departmentUpdateCmd) {
@ -70,7 +70,7 @@ public class DepartmentUpdateExe {
BeanUtils.copyProperties(deptE, deptCmd); BeanUtils.copyProperties(deptE, deptCmd);
//删除redis数据 //删除redis数据
zcloudRedisUtil.del(Const.REDIS_DEPT_PREFIX+departmentDO.getCorpinfoId()+":"+departmentUpdateCmd.getId()); // zcloudRedisUtil.del(Const.REDIS_DEPT_PREFIX+departmentDO.getCorpinfoId()+":"+departmentUpdateCmd.getId());
// deptFacade.updateDept(deptCmd); // deptFacade.updateDept(deptCmd);
if(!departmentDO.getName().equals(departmentE.getName())){ if(!departmentDO.getName().equals(departmentE.getName())){

View File

@ -37,8 +37,8 @@ public class PostRemoveExe {
private final PostDepartmentGateway postDepartmentGateway; private final PostDepartmentGateway postDepartmentGateway;
private final UserRepository userRepository; private final UserRepository userRepository;
private final PostRepository postRepository; private final PostRepository postRepository;
@Autowired // @Autowired
private ZcloudRedisUtil zcloudRedisUtil; // private ZcloudRedisUtil zcloudRedisUtil;
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public boolean execute(Long id) { public boolean execute(Long id) {
@ -53,7 +53,7 @@ public class PostRemoveExe {
throw new BizException("删除失败"); throw new BizException("删除失败");
} }
//删除redis数据 //删除redis数据
zcloudRedisUtil.del(Const.REDIS_POST_PREFIX+id); // zcloudRedisUtil.del(Const.REDIS_POST_PREFIX+id);
return true; return true;
} }
@ -73,7 +73,7 @@ public class PostRemoveExe {
throw new BizException("删除失败"); throw new BizException("删除失败");
} }
for (Long id : ids) { for (Long id : ids) {
zcloudRedisUtil.del(Const.REDIS_POST_PREFIX+id); // zcloudRedisUtil.del(Const.REDIS_POST_PREFIX+id);
} }
return true; return true;

View File

@ -35,8 +35,8 @@ public class PostUpdateExe {
private final PostGateway postGateway; private final PostGateway postGateway;
private final PostDepartmentGateway postDepartmentGateway; private final PostDepartmentGateway postDepartmentGateway;
private final PostRepository postRepository; private final PostRepository postRepository;
@Autowired // @Autowired
private ZcloudRedisUtil zcloudRedisUtil; // private ZcloudRedisUtil zcloudRedisUtil;
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void execute(PostUpdateCmd postUpdateCmd) { public void execute(PostUpdateCmd postUpdateCmd) {
@ -68,7 +68,7 @@ public class PostUpdateExe {
throw new BizException("修改失败"); throw new BizException("修改失败");
} }
//删除redis数据 //删除redis数据
zcloudRedisUtil.del(Const.REDIS_POST_PREFIX+postDO.getId()); // zcloudRedisUtil.del(Const.REDIS_POST_PREFIX+postDO.getId());
} }
} }

View File

@ -21,8 +21,8 @@ import org.springframework.transaction.annotation.Transactional;
@AllArgsConstructor @AllArgsConstructor
public class UserRemoveExe { public class UserRemoveExe {
private final UserGateway userGateway; private final UserGateway userGateway;
@Autowired // @Autowired
private ZcloudRedisUtil zcloudRedisUtil; // private ZcloudRedisUtil zcloudRedisUtil;
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public boolean execute(Long id) { public boolean execute(Long id) {
@ -30,7 +30,7 @@ public class UserRemoveExe {
if(!res){ if(!res){
throw new BizException("删除失败"); throw new BizException("删除失败");
} }
zcloudRedisUtil.del(Const.REDIS_USER_PREFIX+id); // zcloudRedisUtil.del(Const.REDIS_USER_PREFIX+id);
return true; return true;
} }
@ -40,9 +40,9 @@ public class UserRemoveExe {
if(!res){ if(!res){
throw new BizException("删除失败"); throw new BizException("删除失败");
} }
for (Long id : ids) { // for (Long id : ids) {
zcloudRedisUtil.del(Const.REDIS_USER_PREFIX+id); // zcloudRedisUtil.del(Const.REDIS_USER_PREFIX+id);
} // }
return true; return true;
} }
} }

View File

@ -35,8 +35,8 @@ public class UserUpdateExe {
private final UserEmploymentLogGateway userEmploymentLogGateway; private final UserEmploymentLogGateway userEmploymentLogGateway;
private final CorpInfoRepository corpInfoRepository; private final CorpInfoRepository corpInfoRepository;
@Autowired // @Autowired
private ZcloudRedisUtil zcloudRedisUtil; // private ZcloudRedisUtil zcloudRedisUtil;
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void execute(UserUpdateCmd userUpdateCmd) { public void execute(UserUpdateCmd userUpdateCmd) {
@ -70,7 +70,7 @@ public class UserUpdateExe {
throw new BizException("修改失败"); throw new BizException("修改失败");
} }
//删除redis数据 //删除redis数据
zcloudRedisUtil.del(Const.REDIS_USER_PREFIX+userUpdateCmd.getId()); // zcloudRedisUtil.del(Const.REDIS_USER_PREFIX+userUpdateCmd.getId());
} }
} }