exit

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/service/impl/SmileUserServiceImpl.java

@@ -107,9 +107,10 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
 
     @Override
     public AjaxResult updateUserStateById(String uid, Integer state) {
+        SmileUserVO smileUserVO = getSmileUserVOFromRedis(uid);
         //修改黑名单
         smileUserMapper.updateUserStateById(uid, state);
-        updateRedisSetUser(uid,state);
+        updateRedisSetUser(smileUserVO,uid,state);
         return AjaxResult.success();
     }
 
@@ -129,11 +130,13 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
 
     @Override
     public AjaxResult updateUserCheckById(SmileUserCheckVo smileUserCheckVo) {
+        //根据uid查询redis中的用户缓存信息
+        SmileUserVO smileUserVO = getSmileUserVOFromRedis(smileUserCheckVo.getUid());
         //判断是否通过
         if (smileUserCheckVo.getState().equals(3)) {
             //申请被驳回
             smileUserMapper.updateUserCheckByUid(smileUserCheckVo.getUid(), smileUserCheckVo.getType(), smileUserCheckVo.getReason());
-            updateRedisSetUser(smileUserCheckVo.getUid(),smileUserCheckVo.getReason());
+            updateRedisSetUser(smileUserVO,smileUserCheckVo.getUid(),smileUserCheckVo.getReason());
         } else {
             //通过审核
             //判断是否是总代
@@ -154,13 +157,23 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
                 }
             }
             //更新redis
-            updateRedisSetUser(smileUserCheckVo.getUid(), smileUserCheckVo.getOrgId(), smileUserCheckVo.getType());
+            updateRedisSetUser(smileUserVO,smileUserCheckVo.getUid(), smileUserCheckVo.getOrgId(), smileUserCheckVo.getType());
             //修改user代理 id 开启代理
             smileUserMapper.updateUserByUid(smileUserCheckVo.getUid(), smileUserCheckVo.getOrgId(), smileUserCheckVo.getType());
         }
         return AjaxResult.success();
     }
 
+    private SmileUserVO getSmileUserVOFromRedis(String uid) {
+        //根据uid查询用户
+        LambdaQueryWrapper<SmileUser> userQueryWrapper = Wrappers.lambdaQuery(SmileUser.class);
+        userQueryWrapper.eq(SmileUser::getUid, uid);
+        SmileUser smileUser = smileUserMapper.selectOne(userQueryWrapper);
+        SmileUserVO smileUserVO = new SmileUserVO();
+        BeanUtils.copyProperties(smileUser, smileUserVO);
+        return smileUserVO;
+    }
+
     //往redis中塞入用户
     private void redisSetUser(SmileUser smileUser) {
         SmileUserVO smileUserVO = new SmileUserVO();
@@ -170,8 +183,7 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
     }
 
     //更新redis中的用户数据
-    private void updateRedisSetUser(String uid,Long orgId,Integer type) {
-        SmileUserVO smileUserVO = (SmileUserVO) smileRedisUtils.get(SmileRedisConst.SMILE_USER + uid);
+    private void updateRedisSetUser(SmileUserVO smileUserVO,String uid,Long orgId,Integer type) {
         //组织id
         if (StringUtils.isNotNull(orgId)) smileUserVO.setOrgId(orgId);
         //代理 代理类型（0：未审核，1：总代，2：普代，3：未认证）
@@ -183,16 +195,23 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
     }
 
     //跟新redis中的用户  0：正常，1：黑名单
-    private void updateRedisSetUser(String uid,Integer state){
-        SmileUserVO smileUserVO = (SmileUserVO) smileRedisUtils.get(SmileRedisConst.SMILE_USER + uid);
-        //状态  0：正常，1：黑名单
-        if (StringUtils.isNotNull(state)) smileUserVO.setState(state);
-        //存入redis中
-        smileRedisUtils.set(SmileRedisConst.SMILE_USER + uid, smileUserVO);
+    private void updateRedisSetUser(SmileUserVO smileUserVO,String uid,Integer state){
+        SmileUserVO smileUserVO1 = (SmileUserVO) smileRedisUtils.get(SmileRedisConst.SMILE_USER + uid);
+        if (StringUtils.isNotNull(smileUserVO1)){
+            smileUserVO1.setState(state);
+            //存入redis中
+            smileRedisUtils.set(SmileRedisConst.SMILE_USER + uid, smileUserVO1);
+        }else {
+            //状态  0：正常，1：黑名单
+            if (StringUtils.isNotNull(state)) smileUserVO.setState(state);
+            //存入redis中
+            smileRedisUtils.set(SmileRedisConst.SMILE_USER + uid, smileUserVO);
+        }
+
     }
 
-    private void updateRedisSetUser(String uid,String reason){
-        SmileUserVO smileUserVO = (SmileUserVO) smileRedisUtils.get(SmileRedisConst.SMILE_USER + uid);
+    //审核失败插入原因
+    private void updateRedisSetUser(SmileUserVO smileUserVO,String uid,String reason){
         //审核失败原因
         if (StringUtils.isNotNull(reason)) smileUserVO.setErrorReason(reason);
         //存入redis中