记得上下班打卡 | git大法好,push需谨慎

Commit aac84974 authored by GaoHu's avatar GaoHu

exit SmileUserVO

parent 6dbd52cf
...@@ -24,6 +24,7 @@ import java.time.LocalDateTime; ...@@ -24,6 +24,7 @@ import java.time.LocalDateTime;
@ApiModel(value = "smileUser", description = "smile的user") @ApiModel(value = "smileUser", description = "smile的user")
@Data @Data
public class SmileUserVO implements Serializable { public class SmileUserVO implements Serializable {
public interface saveOne{} public interface saveOne{}
public interface saveTwo{} public interface saveTwo{}
public interface saveThree{} public interface saveThree{}
...@@ -34,6 +35,9 @@ public class SmileUserVO implements Serializable { ...@@ -34,6 +35,9 @@ public class SmileUserVO implements Serializable {
@ApiModelProperty(value = "用户id") @ApiModelProperty(value = "用户id")
private String uid; private String uid;
@ApiModelProperty(value = "总代理id,如果总代理是其本身则是本uid,如果不是则是上级uid")
private String agentId;
/** /**
* 照片 * 照片
*/ */
......
...@@ -58,7 +58,7 @@ public class SmileUserController extends BaseController { ...@@ -58,7 +58,7 @@ public class SmileUserController extends BaseController {
} }
@PostMapping("/create") @PostMapping("/create")
@ApiOperation(value = "保存用户") @ApiOperation(value = "保存用户(后端不用此接口)")
@ResponseBody @ResponseBody
public AjaxResult create(@RequestBody SmileUser smileUser) { public AjaxResult create(@RequestBody SmileUser smileUser) {
if (iSmileUserService.create(smileUser)) { if (iSmileUserService.create(smileUser)) {
...@@ -101,13 +101,6 @@ public class SmileUserController extends BaseController { ...@@ -101,13 +101,6 @@ public class SmileUserController extends BaseController {
return iSmileUserService.updateUserCheckById(smileUserCheckVo); return iSmileUserService.updateUserCheckById(smileUserCheckVo);
} }
@PostMapping("/redisDelUserByUid")
@ApiOperation("根据uid删除redis中的用户")
@ResponseBody
public AjaxResult redisDelUserByUid(String uid) {
return iSmileUserService.redisDelUserByUid(uid);
}
@RequestMapping("getAreaJson") @RequestMapping("getAreaJson")
@ApiOperation("省市区json") @ApiOperation("省市区json")
@ResponseBody @ResponseBody
......
...@@ -26,5 +26,4 @@ public interface ISmileUserService extends IService<SmileUser> { ...@@ -26,5 +26,4 @@ public interface ISmileUserService extends IService<SmileUser> {
AjaxResult updateUserCheckById(SmileUserCheckVo smileUserCheck); AjaxResult updateUserCheckById(SmileUserCheckVo smileUserCheck);
AjaxResult redisDelUserByUid(String uid);
} }
...@@ -100,6 +100,7 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile ...@@ -100,6 +100,7 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile
public AjaxResult del(Long id) { public AjaxResult del(Long id) {
smileSchoolMapper.updateDel(id); smileSchoolMapper.updateDel(id);
smileRedisUtils.del(SmileRedisConst.SMILE_SCHOOL.concat(":").concat(String.valueOf(id))); smileRedisUtils.del(SmileRedisConst.SMILE_SCHOOL.concat(":").concat(String.valueOf(id)));
return AjaxResult.success(); return AjaxResult.success();
} }
......
...@@ -146,14 +146,14 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser ...@@ -146,14 +146,14 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
smileUserMapper.updateUserCheckByUid(smileUserCheckVo.getUid(), smileUserCheckVo.getType(), smileUserCheckVo.getReason()); smileUserMapper.updateUserCheckByUid(smileUserCheckVo.getUid(), smileUserCheckVo.getType(), smileUserCheckVo.getReason());
updateRedisSetUser(smileUserVO,smileUserCheckVo.getUid(),smileUserCheckVo.getReason()); updateRedisSetUser(smileUserVO,smileUserCheckVo.getUid(),smileUserCheckVo.getReason());
} else { } else {
//查询代理信息 查询组织是否有总代 没有则设置 有则返回异常
LambdaQueryWrapper<SmileOrganization> orgQueryWrapper = Wrappers.lambdaQuery(SmileOrganization.class);
orgQueryWrapper.eq(SmileOrganization::getId, smileUserCheckVo.getOrgId());
orgQueryWrapper.eq(SmileOrganization::getDelTag, 0);
SmileOrganization smileOrganization = smileOrganizationMapper.selectOne(orgQueryWrapper);
//通过审核 //通过审核
//判断是否是总代 //判断是否是总代
if (smileUserCheckVo.getType().equals(1)) { if (smileOrganization != null && smileUserCheckVo.getType().equals(1)) {
//查询组织是否有总代 没有则设置 有则返回异常
LambdaQueryWrapper<SmileOrganization> orgQueryWrapper = Wrappers.lambdaQuery(SmileOrganization.class);
orgQueryWrapper.eq(SmileOrganization::getId, smileUserCheckVo.getOrgId());
orgQueryWrapper.eq(SmileOrganization::getDelTag, 0);
SmileOrganization smileOrganization = smileOrganizationMapper.selectOne(orgQueryWrapper);
if (smileOrganization != null && StringUtils.isEmpty(smileOrganization.getAgentId())) { if (smileOrganization != null && StringUtils.isEmpty(smileOrganization.getAgentId())) {
//没有总代 修改代理 //没有总代 修改代理
smileOrganization.setUpdatedDate(LocalDateTime.now()); smileOrganization.setUpdatedDate(LocalDateTime.now());
...@@ -163,21 +163,21 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser ...@@ -163,21 +163,21 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
//有总代 //有总代
return AjaxResult.warn("该分组已经存在总代身份"); return AjaxResult.warn("该分组已经存在总代身份");
} }
}else {
return AjaxResult.warn("组织不存在");
} }
//更新redis //更新redis
updateRedisSetUser(smileUserVO,smileUserCheckVo.getUid(), smileUserCheckVo.getOrgId(), smileUserCheckVo.getType()); updateRedisSetUser(smileUserVO,smileUserCheckVo.getUid(),
smileUserCheckVo.getOrgId(),
smileUserCheckVo.getType(),
StringUtils.isEmpty(smileOrganization.getAgentId())?smileOrganization.getAgentId():smileUserCheckVo.getUid());
//修改user代理 id 开启代理 //修改user代理 id 开启代理
smileUserMapper.updateUserByUid(smileUserCheckVo.getUid(), smileUserCheckVo.getOrgId(), smileUserCheckVo.getType()); smileUserMapper.updateUserByUid(smileUserCheckVo.getUid(), smileUserCheckVo.getOrgId(), smileUserCheckVo.getType());
} }
return AjaxResult.success(); return AjaxResult.success();
} }
@Override
public AjaxResult redisDelUserByUid(String uid) {
smileRedisUtils.del(SmileRedisConst.SMILE_USER + uid);
return AjaxResult.success();
}
private SmileUserVO getSmileUserVOFromRedis(String uid) { private SmileUserVO getSmileUserVOFromRedis(String uid) {
//根据uid查询用户 //根据uid查询用户
LambdaQueryWrapper<SmileUser> userQueryWrapper = Wrappers.lambdaQuery(SmileUser.class); LambdaQueryWrapper<SmileUser> userQueryWrapper = Wrappers.lambdaQuery(SmileUser.class);
...@@ -197,7 +197,7 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser ...@@ -197,7 +197,7 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
} }
//更新redis中的用户数据 //更新redis中的用户数据
private void updateRedisSetUser(SmileUserVO smileUserVO,String uid,Long orgId,Integer type) { private void updateRedisSetUser(SmileUserVO smileUserVO,String uid,Long orgId,Integer type,String agentId) {
//组织id //组织id
if (StringUtils.isNotNull(orgId)) smileUserVO.setOrgId(orgId); if (StringUtils.isNotNull(orgId)) smileUserVO.setOrgId(orgId);
//代理 代理类型(0:未审核,1:总代,2:普代,3:未认证) //代理 代理类型(0:未审核,1:总代,2:普代,3:未认证)
...@@ -206,6 +206,8 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser ...@@ -206,6 +206,8 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
smileUserVO.setAgent(1); smileUserVO.setAgent(1);
//清除审核 //清除审核
smileUserVO.setErrorReason(null); smileUserVO.setErrorReason(null);
//存入总代理id
smileUserVO.setAgentId(agentId);
//存入redis中 //存入redis中
smileRedisUtils.set(SmileRedisConst.SMILE_USER + uid, smileUserVO); smileRedisUtils.set(SmileRedisConst.SMILE_USER + uid, smileUserVO);
} }
......
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