缓存user代理ID问题修改

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

@@ -177,6 +177,9 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
                         smileOrganization.setUpdatedDate(LocalDateTime.now());
                         smileOrganization.setAgentId(smileUserCheckVo.getUid());
                         smileOrganizationMapper.updateById(smileOrganization);
+                        //查询该代理下是否有普代
+                        updateUserVoRedis(smileUserCheckVo, smileOrganization);
+                        //缓存redis  和修改用户状态
                         userCheck(smileUserCheckVo, smileUserVO, smileOrganization);
                         return AjaxResult.success();
                     } else {
@@ -194,12 +197,26 @@ public class SmileUserServiceImpl extends ServiceImpl<SmileUserMapper, SmileUser
         return AjaxResult.warn("参数错误");
     }
 
+    private void updateUserVoRedis(SmileUserCheckVo smileUserCheckVo, SmileOrganization smileOrganization) {
+        LambdaQueryWrapper<SmileUser> smileUserQueryWrapper = Wrappers.lambdaQuery(SmileUser.class);
+        smileUserQueryWrapper.eq(SmileUser::getOrgId, smileOrganization.getId());
+        smileUserQueryWrapper.ne(SmileUser::getUid, smileUserCheckVo.getUid());
+        List<SmileUser> smileUsers = smileUserMapper.selectList(smileUserQueryWrapper);
+        if (smileUsers != null && smileUsers.size() > 0) {
+            //更新普代redis缓存
+            smileUsers.forEach(smileUser -> {
+                SmileUserVO userVO = (SmileUserVO) smileRedisUtils.get(SmileRedisConst.SMILE_USER.concat(smileUser.getUid()));
+                userVO.setAgentId(smileOrganization.getAgentId());
+            });
+        }
+    }
+
     private void userCheck(SmileUserCheckVo smileUserCheckVo, SmileUserVO smileUserVO, SmileOrganization smileOrganization) {
         //更新redis
         updateRedisSetUser(smileUserVO, smileUserCheckVo.getUid(),
                 smileUserCheckVo.getOrgId(),
                 smileUserCheckVo.getType(),
-                StringUtils.isEmpty(smileOrganization.getAgentId()) ? smileOrganization.getAgentId() : smileUserCheckVo.getUid());
+                smileOrganization.getAgentId());
         //修改user代理 id 开启代理
         smileUserMapper.updateUserByUid(smileUserCheckVo.getUid(), smileUserCheckVo.getOrgId(), smileUserCheckVo.getType(), smileOrganization.getAgentId());
     }