From dfdd4bd5d112a17ccd1483ad11fe023817d54d26 Mon Sep 17 00:00:00 2001
From: whywhyo <1511349576@qq.com>
Date: 星期六, 22 七月 2023 15:20:13 +0800
Subject: [PATCH] 45648

---
 zhang-content/src/main/java/com/ruoyi/service/impl/ZfFamilyServiceImpl.java |   90 +++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 90 insertions(+), 0 deletions(-)

diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfFamilyServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfFamilyServiceImpl.java
index 48cb8b8..d76aa4f 100644
--- a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfFamilyServiceImpl.java
+++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfFamilyServiceImpl.java
@@ -1,14 +1,26 @@
 package com.ruoyi.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.core.domain.entity.SysUser;
+import com.ruoyi.common.utils.SecurityUtils;
+import com.ruoyi.domain.ZInfoUser;
 import com.ruoyi.domain.ZfEvent;
 import com.ruoyi.domain.ZfFamily;
+import com.ruoyi.domain.dto.UserInfoDto;
 import com.ruoyi.mapper.ZfEventMapper;
 import com.ruoyi.mapper.ZfFamilyMapper;
+import com.ruoyi.service.ZInfoUserService;
 import com.ruoyi.service.ZfEventService;
 import com.ruoyi.service.ZfFamilyService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * @Author Jinquan_Ou
@@ -18,10 +30,88 @@
  **/
 @Service
 public class ZfFamilyServiceImpl extends ServiceImpl<ZfFamilyMapper, ZfFamily> implements ZfFamilyService {
+    @Autowired
+    ZInfoUserService zInfoUserService;
+
+
     @Override
     public ZfFamily getByName(String familyName) {
         LambdaQueryWrapper<ZfFamily> lqw = new LambdaQueryWrapper<>();
         lqw.eq(ZfFamily::getName,familyName);
         return getOne(lqw);
     }
+
+    @Override
+    public List<UserInfoDto> getByFamilyId(Long fid) {
+        LambdaQueryWrapper<ZInfoUser> lqw = new LambdaQueryWrapper<>();
+        lqw.eq(ZInfoUser::getFamilyId,fid);
+        List<ZInfoUser> list = zInfoUserService.list(lqw);
+        return list.stream().map(
+                zInfoUser -> {
+                    UserInfoDto userInfoDto = new UserInfoDto();
+                    userInfoDto.setId(zInfoUser.getUserId());
+                    userInfoDto.setFamilyId(zInfoUser.getFamilyId());
+                    userInfoDto.setName(zInfoUser.getNickName());
+                    userInfoDto.setFamilyName(getById(zInfoUser.getFamilyId()).getName());
+                    return userInfoDto;
+                }
+        ).collect(Collectors.toList());
+
+    }
+
+    @Override
+    public List<UserInfoDto> getNowMember() {
+
+        SysUser user = SecurityUtils.getLoginUser().getUser();
+        Long userId = user.getUserId();
+        ZInfoUser myself = zInfoUserService.getById(userId);
+        return getByFamilyId(myself.getFamilyId());
+    }
+
+    @Override
+    public AjaxResult addMember(UserInfoDto userInfoDto) {
+
+        SysUser user = SecurityUtils.getLoginUser().getUser();
+        Long userId = user.getUserId();
+        ZInfoUser myself = zInfoUserService.getById(userId);
+
+        //鏌ョ湅褰撳墠鐢ㄦ埛鏄笉鏄鐞嗗憳
+        if(myself.getRoleId()!=1 && myself.getRoleId()!=2){
+            throw new RuntimeException("浣犱笉鏄搴鐞嗗憳锛屾病鏈夋潈闄愭搷浣�");
+        }
+
+        Long uid = userInfoDto.getId();
+//        Long targetFamilyId = zInfoUserService.getById(uid).getFamilyId();
+        UpdateWrapper<ZInfoUser> luw = new UpdateWrapper<>();
+        luw.eq("user_id",uid);
+        //update from z_info_user set family_id = #{targetFamilyId where user_id = #{uid}
+        luw.setSql("family_id = "+myself.getFamilyId());
+
+        zInfoUserService.update(luw);
+        return AjaxResult.success();
+
+    }
+
+    @Override
+    public AjaxResult removeMember(UserInfoDto userInfoDto) {
+        SysUser user = SecurityUtils.getLoginUser().getUser();
+        Long userId = user.getUserId();
+        ZInfoUser myself = zInfoUserService.getById(userId);
+
+        //鏌ョ湅褰撳墠鐢ㄦ埛鏄笉鏄鐞嗗憳
+        if(myself.getRoleId()!=1 && myself.getRoleId()!=2){
+            throw new RuntimeException("浣犱笉鏄搴鐞嗗憳锛屾病鏈夋潈闄愭搷浣�");
+        }
+
+        Long uid = userInfoDto.getId();
+//        Long targetFamilyId = zInfoUserService.getById(uid).getFamilyId();
+        UpdateWrapper<ZInfoUser> luw = new UpdateWrapper<>();
+        luw.eq("user_id",uid);
+        //update from z_info_user set family_id = #{targetFamilyId where user_id = #{uid}
+        luw.setSql("family_id = "+null);
+
+        zInfoUserService.update(luw);
+        return AjaxResult.success();
+
+    }
 }

--
Gitblit v1.9.1