修改总代（直接修改）

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

@@ -65,7 +65,7 @@ public class SmileOrganizationServiceImpl extends ServiceImpl<SmileOrganizationM
                 BeanUtils.copyProperties(smileOrganization, smileOrganizationVo);
                 log.info("organizationList orgId:{}", smileOrganization.getId());
                 //根据代理id  用户uid查询用户名称
-                if (StringUtils.isNotEmpty(smileOrganization.getAgentId())){
+                if (StringUtils.isNotEmpty(smileOrganization.getAgentId())) {
                     SmileUserVO smileUserVO = smileRedisUtils.getSmileUserVO(smileOrganization.getAgentId());
                     if (smileUserVO != null) {
                         smileOrganizationVo.setAgentName(smileUserVO.getName());
@@ -105,7 +105,35 @@ public class SmileOrganizationServiceImpl extends ServiceImpl<SmileOrganizationM
     @Override
     public AjaxResult update(SmileOrganization smileOrganization) {
         smileOrganization.setUpdatedDate(LocalDateTime.now());
-        smileOrganizationMapper.updateById(smileOrganization);
+        //查询组织信息
+        LambdaQueryWrapper<SmileOrganization> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.eq(SmileOrganization::getId, smileOrganization.getId());
+        lambdaQueryWrapper.eq(SmileOrganization::getDelTag, 0);
+        SmileOrganization oleOrganization = smileOrganizationMapper.selectOne(lambdaQueryWrapper);
+        //新旧总代理相同
+        if (oleOrganization.getAgentId().equals(smileOrganization.getAgentId())) {
+            //修改总代与原总代相同
+            smileOrganizationMapper.updateById(smileOrganization);
+        } else {
+            //修改总代与原总代不同
+            //查询所有原总代的普代成员
+            LambdaQueryWrapper<SmileUser> smileUserLambdaQueryWrapper = new LambdaQueryWrapper<>();
+            smileUserLambdaQueryWrapper.eq(SmileUser::getAgentId, oleOrganization.getAgentId());
+            smileUserLambdaQueryWrapper.eq(SmileUser::getDelTag, 0);
+            smileUserLambdaQueryWrapper.eq(SmileUser::getType, 2);
+            List<SmileUser> oldSmileUsers = smileUserMapper.selectList(smileUserLambdaQueryWrapper);
+            log.info("原总代id:{},修改总代id:{},受影响普代{}个", oleOrganization.getAgentId(), smileOrganization.getAgentId(), oldSmileUsers.size());
+//            List<SmileUser> newSmileUsers = oldSmileUsers.stream().peek(smileUser -> smileUser.setAddress(smileOrganization.getAgentId())).collect(Collectors.toList());
+            oldSmileUsers.forEach(smileUser -> {
+                smileUser.setAddress(smileOrganization.getAgentId());
+                //修改缓存用户redis总代信息
+                SmileUserVO smileUserVO = smileRedisUtils.getSmileUserVO(smileUser.getUid());
+                smileUserVO.setAgentId(smileOrganization.getAgentId());
+                smileRedisUtils.setSmileUserVO(smileUser.getUid(), smileUserVO);
+                //修改smile_user中普代总代信息
+                smileUserMapper.updateById(smileUser);
+            });
+        }
         return AjaxResult.success();
     }