1.添加机构小组功能 2.适配学生老师小组群

cooleshow-app/src/main/java/com/yonge/cooleshow/admin/controller/TenantGroupController.java

@@ -0,0 +1,43 @@
+package com.yonge.cooleshow.admin.controller;
+
+import com.microsvc.toolkit.common.response.paging.PageInfo;
+import com.microsvc.toolkit.common.response.paging.QueryInfo;
+import com.microsvc.toolkit.common.response.template.R;
+import com.yonge.cooleshow.biz.dal.service.TenantGroupService;
+import com.yonge.cooleshow.biz.dal.wrapper.TenantGroupWrapper;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@Slf4j
+@Validated
+@RestController
+@RequestMapping("${app-config.url.admin:}/tenantGroup")
+@Api(tags = "机构小组表")
+public class TenantGroupController {
+
+    @Autowired
+    private TenantGroupService tenantGroupService;
+
+    @ApiOperation(value = "查询分页", notes = "机构小组表- 传入 TenantGroupWrapper.TenantGroupQuery")
+    @PreAuthorize("@auditsvc.hasPermissions('tenantGroup/page', {'BACKEND'})")
+    @PostMapping("/page")
+    public R<PageInfo<TenantGroupWrapper.TenantGroup>> page(@RequestBody TenantGroupWrapper.TenantGroupQuery query) {
+        return R.from(QueryInfo.pageInfo(tenantGroupService.selectPage(QueryInfo.getPage(query), query)));
+    }
+
+    @ApiOperation(value = "处理机构小组交接", notes = "处理机构小组交接")
+    @PreAuthorize("@auditsvc.hasPermissions('tenantGroup/adjustTenantGroup', {'BACKEND'})")
+    @PostMapping("/adjustTenantGroup")
+    public R<Boolean> adjustTenantGroup(@RequestBody TenantGroupWrapper.AdjustTenantGroup adjustTenantGroup) {
+        return R.from(tenantGroupService.adjustTenantGroup(adjustTenantGroup));
+    }
+
+}

cooleshow-app/src/main/java/com/yonge/cooleshow/tenant/controller/TenantActivationCodeController.java

@@ -21,12 +21,14 @@ import com.yonge.cooleshow.biz.dal.entity.TenantAlbumPurchase;
 import com.yonge.cooleshow.biz.dal.entity.TenantInfo;
 import com.yonge.cooleshow.biz.dal.entity.TenantStaff;
 import com.yonge.cooleshow.biz.dal.entity.UserOrder;
+import com.yonge.cooleshow.biz.dal.service.OssFileService;
 import com.yonge.cooleshow.biz.dal.service.TenantActivationCodeService;
 import com.yonge.cooleshow.biz.dal.service.TenantAlbumPurchaseService;
 import com.yonge.cooleshow.biz.dal.service.TenantAlbumService;
 import com.yonge.cooleshow.biz.dal.service.TenantInfoService;
 import com.yonge.cooleshow.biz.dal.service.TenantStaffService;
 import com.yonge.cooleshow.biz.dal.service.UserOrderService;
+import com.yonge.cooleshow.biz.dal.wrapper.OssFileWrapper;
 import com.yonge.cooleshow.biz.dal.wrapper.TenantActivationCodeWrapper;
 import com.yonge.cooleshow.common.controller.BaseController;
 import com.yonge.cooleshow.common.entity.HttpResponseResult;
@@ -90,6 +92,8 @@ public class TenantActivationCodeController extends BaseController {
     private UserOrderService userOrderService;
     @Autowired
     private TenantAlbumService tenantAlbumService;
+    @Autowired
+    private OssFileService ossFileService;
 
     @ApiOperation(value = "详情", notes = "机构激活码-根据详情ID查询单条, 传入id")
 //    @GetMapping("/detail/{id}")
@@ -195,7 +199,7 @@ public class TenantActivationCodeController extends BaseController {
 
     @GetMapping("/exportActiveCode")
     @ApiOperation(value = "导出模板")
-    public HttpResponseResult<TenantActivationCodeWrapper.ExportFile> exportActiveCode(HttpServletResponse response, String orderNo) {
+    public HttpResponseResult<OssFileWrapper.ExportFile> exportActiveCode(HttpServletResponse response, String orderNo) {
         SysUser sysUser = sysUserFeignService.queryUserInfo();
         if (sysUser == null) {
             throw new BizException("请登录");
@@ -227,7 +231,8 @@ public class TenantActivationCodeController extends BaseController {
 
         String format = new SimpleDateFormat("yyyyMMddHHmm").format(userOrder.getCreateTime());
 
-        TenantActivationCodeWrapper.ExportFile exportFile = generateExportExcelFile(templates,
+
+        OssFileWrapper.ExportFile exportFile = ossFileService.uploadFile(templates,
                 TenantActivationCodeWrapper.ExportTemplate.class, format + tenantAlbum.getName(), "激活码");
         return succeed(exportFile);
     }

cooleshow-app/src/main/java/com/yonge/cooleshow/tenant/controller/TenantGroupController.java

@@ -0,0 +1,98 @@
+package com.yonge.cooleshow.tenant.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.microsvc.toolkit.common.response.paging.PageInfo;
+import com.microsvc.toolkit.common.response.paging.QueryInfo;
+import com.microsvc.toolkit.common.response.template.R;
+import com.yonge.cooleshow.auth.api.client.SysUserFeignService;
+import com.yonge.cooleshow.auth.api.entity.SysUser;
+import com.yonge.cooleshow.biz.dal.entity.TenantGroup;
+import com.yonge.cooleshow.biz.dal.service.TenantGroupService;
+import com.yonge.cooleshow.biz.dal.wrapper.TenantGroupWrapper;
+import com.yonge.cooleshow.tenant.vo.TenantGroupVo;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+@Slf4j
+@Validated
+@RestController
+@RequestMapping("${app-config.url.tenant:}/tenantGroup")
+@Api(tags = "机构小组表")
+public class TenantGroupController {
+
+    @Autowired
+    private TenantGroupService tenantGroupService;
+
+    @Resource
+    private SysUserFeignService sysUserFeignService;
+
+    @ApiOperation(value = "详情", notes = "机构小组表-根据详情ID查询单条, 传入id")
+    @GetMapping("/detail/{id}")
+    public R<TenantGroup> detail(@PathVariable("id") Long id) {
+        TenantGroup wrapper = tenantGroupService.detail(id);
+        return R.from(wrapper);
+    }
+
+    @ApiOperation(value = "详情", notes = "机构小组表-根据详情ID查询单条, 传入id")
+    @GetMapping("/queryGroupMember/{tenantGroupId}")
+    public R<List<TenantGroupWrapper.TenantGroupMember>> queryGroupMember(@PathVariable("tenantGroupId") Long tenantGroupId) {
+        SysUser sysUser = sysUserFeignService.queryUserInfo();
+        return R.from(tenantGroupService.queryGroupMember(sysUser.getTenantId(), tenantGroupId));
+    }
+
+    @ApiOperation(value = "查询分页", notes = "机构小组表- 传入 TenantGroupWrapper.TenantGroupQuery")
+    @PostMapping("/page")
+    public R<PageInfo<TenantGroupWrapper.TenantGroup>> page(@RequestBody TenantGroupWrapper.TenantGroupQuery query) {
+
+        IPage<TenantGroupWrapper.TenantGroup> pages = tenantGroupService.selectPage(QueryInfo.getPage(query), query);
+
+        return R.from(QueryInfo.pageInfo(pages));
+    }
+
+    @ApiOperation(value = "新增", notes = "机构小组表- 传入 TenantGroupWrapper.TenantGroup")
+    @PostMapping("/save")
+    public R<JSONObject> add(@Validated @RequestBody TenantGroupVo.TenantGroup tenantGroup) {
+        SysUser sysUser = sysUserFeignService.queryUserInfo();
+        TenantGroupWrapper.TenantGroup group = TenantGroupWrapper.TenantGroup.from(tenantGroup.jsonString());
+        group.setCreateBy(sysUser.getId());
+        group.setTenantId(sysUser.getTenantId());
+        // 新增数据
+        tenantGroupService.add(group);
+
+        return R.defaultR();
+    }
+
+    @ApiOperation(value = "修改", notes = "机构小组表- 传入 TenantGroupWrapper.TenantGroup")
+    @PostMapping("/update")
+    public R<JSONObject> update(@Validated @RequestBody TenantGroupVo.TenantGroup tenantGroup) {
+        // 更新数据
+        SysUser sysUser = sysUserFeignService.queryUserInfo();
+        TenantGroupWrapper.TenantGroup group = TenantGroupWrapper.TenantGroup.from(tenantGroup.jsonString());
+        group.setCreateBy(sysUser.getId());
+        group.setTenantId(sysUser.getTenantId());
+        tenantGroupService.update(group);
+
+        return R.defaultR();
+    }
+
+    @ApiOperation(value = "删除", notes = "机构小组表- 传入id")
+    @PostMapping("/remove")
+    public R<Boolean> remove(@RequestParam Long id) {
+
+        return R.from(tenantGroupService.delete(id));
+    }
+}

cooleshow-app/src/main/java/com/yonge/cooleshow/tenant/vo/TenantGroupVo.java

@@ -0,0 +1,69 @@
+package com.yonge.cooleshow.tenant.vo;
+
+import com.alibaba.fastjson.JSON;
+import com.microsvc.toolkit.common.response.paging.QueryInfo;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.NotNull;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 机构小组表
+ * 2023-10-11 09:24:50
+ */
+@ApiModel(value = "TenantGroupVo对象", description = "机构小组表查询视图对象")
+public class TenantGroupVo {
+
+    @Data
+    @ApiModel(" TenantGroupQuery-机构小组表")
+    public static class TenantGroupQuery implements QueryInfo {
+
+        @ApiModelProperty("当前页")
+        private Integer page;
+
+        @ApiModelProperty("分页行数")
+        private Integer rows;
+
+        public String jsonString() {
+            return JSON.toJSONString(this);
+        }
+
+        public static TenantGroupQuery from(String json) {
+            return JSON.parseObject(json, TenantGroupQuery.class);
+        }
+    }
+
+    @Data
+    @ApiModel(" TenantGroup-机构小组表")
+    public static class TenantGroup {
+
+        @ApiModelProperty("主键ID")
+        private Long id;
+
+        @ApiModelProperty("机构ID")
+        private Long tenantId;
+
+        @ApiModelProperty("小组名称")
+        @NotNull(message = "小组名称不能为空")
+        private String name;
+
+        @ApiModelProperty("小组负责人")
+        @NotNull(message = "小组负责人不能为空")
+        private Long adminId;
+
+        @ApiModelProperty("群成员列表")
+        private List<Long> userIds = new ArrayList<>();
+
+        public String jsonString() {
+            return JSON.toJSONString(this);
+        }
+
+        public static TenantGroup from(String json) {
+            return JSON.parseObject(json, TenantGroup.class);
+        }
+    }
+
+}

cooleshow-user/user-admin/src/main/java/com/yonge/cooleshow/admin/controller/TenantGroupController.java

@@ -0,0 +1,46 @@
+package com.yonge.cooleshow.admin.controller;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.microsvc.toolkit.common.response.paging.PageInfo;
+import com.microsvc.toolkit.common.response.paging.QueryInfo;
+import com.microsvc.toolkit.common.response.template.R;
+import com.yonge.cooleshow.biz.dal.service.TenantGroupService;
+import com.yonge.cooleshow.biz.dal.wrapper.TenantGroupWrapper;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@Slf4j
+@Validated
+@RestController
+@RequestMapping("/tenantGroup")
+@Api(tags = "机构小组表")
+public class TenantGroupController {
+
+    @Autowired
+    private TenantGroupService tenantGroupService;
+
+    @ApiOperation(value = "查询分页", notes = "机构小组表- 传入 TenantGroupWrapper.TenantGroupQuery")
+    @PreAuthorize("@auditsvc.hasPermissions('tenantGroup/page', {'BACKEND'})")
+    @PostMapping("/page")
+    public R<PageInfo<TenantGroupWrapper.TenantGroup>> page(@RequestBody TenantGroupWrapper.TenantGroupQuery query) {
+        return R.from(QueryInfo.pageInfo(tenantGroupService.selectPage(QueryInfo.getPage(query), query)));
+    }
+
+    @ApiOperation(value = "处理机构小组交接", notes = "处理机构小组交接")
+    @PreAuthorize("@auditsvc.hasPermissions('tenantGroup/adjustTenantGroup', {'BACKEND'})")
+    @PostMapping("/adjustTenantGroup")
+    public R<Boolean> adjustTenantGroup(@RequestBody TenantGroupWrapper.AdjustTenantGroup adjustTenantGroup) {
+        return R.from(tenantGroupService.adjustTenantGroup(adjustTenantGroup));
+    }
+
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/dao/StudentDao.java

@@ -11,6 +11,7 @@ import com.yonge.cooleshow.biz.dal.entity.Student;
 import com.yonge.cooleshow.biz.dal.entity.Subject;
 import com.yonge.cooleshow.biz.dal.vo.MyFollow;
 import com.yonge.cooleshow.biz.dal.vo.StudentVo;
+import com.yonge.cooleshow.biz.dal.wrapper.StudentWrapper;
 import com.yonge.cooleshow.biz.dal.wrapper.TenantInfoWrapper;
 import org.apache.ibatis.annotations.Param;
 
@@ -79,4 +80,6 @@ public interface StudentDao extends BaseMapper<Student> {
     List<TenantInfoWrapper.UserCount> countTeacherByTenantIds(@Param("tenantIdList") List<Long> tenantIdList);
 
     Integer queryStudentCounts(@Param("id") Long id);
+
+    List<StudentWrapper.UserCount> countStudentByTenantGroupIds(@Param("tenantId") Long tenantId, @Param("groupIdList") List<Long> groupIdList);
 }

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/entity/TenantGroup.java

@@ -0,0 +1,53 @@
+package com.yonge.cooleshow.biz.dal.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.IdType;
+import lombok.Data;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import java.io.Serializable;
+import java.util.Date;
+
+
+/**
+ * 机构小组表
+ * 2023-10-11 09:24:50
+ */
+@Data
+@ApiModel(" TenantGroup-机构小组表")
+@TableName("tenant_group")
+public class TenantGroup implements Serializable {
+
+    @ApiModelProperty("主键ID")
+    @TableId(value = "id_", type = IdType.AUTO)
+    private Long id;
+
+    @ApiModelProperty("机构ID")
+    @TableField(value = "tenant_id_")
+    private Long tenantId;
+
+    @ApiModelProperty("小组名称")
+    @TableField(value = "name_")
+    private String name;
+
+    @ApiModelProperty("管理员ID")
+    @TableField(value = "admin_id_")
+    private Long adminId;
+
+    @ApiModelProperty("IM群ID")
+    @TableField(value = "im_group_id_")
+    private String imGroupId;
+
+    @ApiModelProperty("创建人")
+    @TableField(value = "create_by_")
+    private Long createBy;
+
+    @ApiModelProperty("创建时间")
+    @TableField(value = "create_time_")
+    private Date createTime;
+
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/mapper/TenantGroupMapper.java

@@ -0,0 +1,31 @@
+package com.yonge.cooleshow.biz.dal.mapper;
+
+import java.util.List;
+import java.util.Map;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Constants;
+import org.apache.ibatis.annotations.Param;
+import org.apache.poi.ss.formula.functions.T;
+import org.springframework.stereotype.Repository;
+import com.yonge.cooleshow.biz.dal.entity.TenantGroup;
+import com.yonge.cooleshow.biz.dal.wrapper.TenantGroupWrapper;
+
+/**
+ * 机构小组表
+ * 2023-10-11 09:24:50
+ */
+@Repository
+public interface TenantGroupMapper extends BaseMapper<TenantGroup> {
+
+    /**
+     * 分页查询
+     * @param page IPage<TenantGroupWrapper.TenantGroup>
+     * @param param TenantGroupWrapper.TenantGroupQuery
+     * @return List<TenantGroupWrapper.TenantGroup>
+     */
+    List<TenantGroupWrapper.TenantGroup> selectPage(@Param("page") IPage<TenantGroupWrapper.TenantGroup> page,
+                                                    @Param("param") TenantGroupWrapper.TenantGroupQuery param);
+
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/ImGroupService.java

@@ -79,7 +79,7 @@ public interface ImGroupService extends IService<ImGroup> {
     * @author zx
     * @date 2022/3/22 11:17
     */
-    void create(ImGroupWrapper.ImGroup imGroup) throws Exception;
+    String create(ImGroupWrapper.ImGroup imGroup) throws Exception;
 
     /**
     * @description: 成课后自动创建群聊，建议放在最后执行

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/OssFileService.java

@@ -12,4 +12,7 @@ public interface OssFileService {
 
     OssFileWrapper.ExportFile uploadFile(List<?> dataList, Class<?> clazz,
                                          String fileName, String sheetName);
+
+    OssFileWrapper.ExportFile uploadFileWithShortUrl(List<?> dataList, Class<?> clazz,
+                                                     String fileName, String sheetName);
 }

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/TenantGroupService.java

@@ -0,0 +1,52 @@
+package com.yonge.cooleshow.biz.dal.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.microsvc.toolkit.common.response.ParamResponse;
+import com.yonge.cooleshow.biz.dal.wrapper.TenantGroupWrapper;
+import com.yonge.cooleshow.biz.dal.entity.TenantGroup;
+
+import java.util.List;
+
+/**
+ * 机构小组表
+ * 2023-10-11 09:24:50
+ */
+public interface TenantGroupService extends IService<TenantGroup>  {
+
+    /**
+     * 查询详情
+     * @param id 详情ID
+     * @return TenantGroup
+     */
+    TenantGroup detail(Long id);
+
+    /**
+     * 分页查询
+     * @param page IPage<TenantGroup>
+     * @param query TenantGroupWrapper.TenantGroupQuery
+     * @return IPage<TenantGroup>
+     */
+    IPage<TenantGroupWrapper.TenantGroup> selectPage(IPage<TenantGroupWrapper.TenantGroup> page,
+                                                     TenantGroupWrapper.TenantGroupQuery query);
+
+    /**
+     * 添加
+     * @param tenantGroup TenantGroupWrapper.TenantGroup
+     * @return Boolean
+     */
+    Boolean add(TenantGroupWrapper.TenantGroup tenantGroup);
+
+    /**
+     * 更新
+     * @param tenantGroup TenantGroupWrapper.TenantGroup
+     * @return Boolean
+     */
+    Boolean update(TenantGroupWrapper.TenantGroup tenantGroup);
+
+    Boolean delete(Long id);
+
+    List<TenantGroupWrapper.TenantGroupMember> queryGroupMember(Long tenantId, Long tenantGroupId);
+
+    Boolean adjustTenantGroup(TenantGroupWrapper.AdjustTenantGroup adjustTenantGroup);
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/ImGroupServiceImpl.java

@@ -303,7 +303,7 @@ public class ImGroupServiceImpl extends ServiceImpl<ImGroupDao, ImGroup> impleme
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void create(ImGroupWrapper.ImGroup imGroup) throws Exception {
+    public String create(ImGroupWrapper.ImGroup imGroup) throws Exception {
         Date now = new Date();
         if (imGroup.getType() == null) {
             imGroup.setType(ImGroupType.FAN.getCode());
@@ -317,6 +317,7 @@ public class ImGroupServiceImpl extends ServiceImpl<ImGroupDao, ImGroup> impleme
         if (!imGroup.getStudentIdList().isEmpty()) {
             addGroupMember(groupId,imGroup.getStudentIdList());
         }
+        return groupId;
 
 
 //        String imGroupId = UUID.randomUUID() + imGroup.getType().getCode();

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/OssFileServiceImpl.java

@@ -40,6 +40,47 @@ public class OssFileServiceImpl implements OssFileService {
         String uploadOssPath = MessageFormat.format("excel-download/{0}", DateTime.now().toString("yyyy-MM"));
 
         // 文件上传下载地址
+        String uploadPath = MessageFormat.format("{0}/{1}-{2}/{3}.xlsx", uploadOssPath,
+                String.valueOf(IdWorker.getId()),
+                DateTime.now().toString("MMddHHmmss"),fileName);
+
+        // 本地文件地址
+        String localPath = DownloadManager.getInstance().path(uploadPath);
+        log.debug("pageExport localPath={}", localPath);
+
+        EasyExcel
+                .write(localPath, clazz)
+                //.withTemplate(resource.getStream()) // 利用模板的输出流
+                .sheet(0, sheetName)
+                .doWrite(dataList);
+
+        // 上传本地文件到OSS服务器
+        String downloadPath = ossPluginContext.getPluginService(TencentOssPlugin.PLUGIN_NAME)
+                .uploadFile(uploadOssPath, new File(localPath));
+        log.debug("pageExport downloadPath={}", downloadPath);
+
+        // 删除本地缓存文件
+        DownloadManager.getInstance().deleteOnExit(localPath);
+
+        // 学生统计下载
+        return OssFileWrapper.ExportFile
+                .builder()
+                .fileName(MessageFormat.format("{0}.xlsx", fileName))
+                .downloadPath(downloadPath)
+                .build();
+    }
+
+    @Override
+    public OssFileWrapper.ExportFile uploadFileWithShortUrl(List<?> dataList, Class<?> clazz,
+                                                            String fileName, String sheetName) {
+        if (CollectionUtils.isEmpty(dataList)) {
+            throw new BizException("导出数据为空");
+        }
+
+        // OSS上传文件目录
+        String uploadOssPath = MessageFormat.format("excel-download/{0}", DateTime.now().toString("yyyy-MM"));
+
+        // 文件上传下载地址
         String uploadPath = MessageFormat.format("{0}/{1}-{2}.xlsx", uploadOssPath, String.valueOf(IdWorker.getId()),
                 DateTime.now().toString("MMddHHmmss"));
 

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/StudentServiceImpl.java

@@ -4,9 +4,9 @@ import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
+import com.baomidou.mybatisplus.core.toolkit.IdWorker;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.yonge.cooleshow.api.feign.dto.ImUserInfo;
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.Lists;
 import com.microsvc.toolkit.common.webportal.exception.BizException;
@@ -25,18 +25,16 @@ import com.yonge.cooleshow.biz.dal.enums.ClientEnum;
 import com.yonge.cooleshow.biz.dal.enums.ImGroupMemberRoleType;
 import com.yonge.cooleshow.biz.dal.enums.ImGroupType;
 import com.yonge.cooleshow.biz.dal.mapper.SysUserMapper;
+import com.yonge.cooleshow.biz.dal.mapper.TenantGroupMapper;
 import com.yonge.cooleshow.biz.dal.service.ImGroupService;
 import com.yonge.cooleshow.biz.dal.mapper.TenantAlbumMapper;
-import com.yonge.cooleshow.biz.dal.mapper.TenantAlbumPurchaseMapper;
 import com.yonge.cooleshow.biz.dal.mapper.TenantAlbumRefMapper;
 import com.yonge.cooleshow.biz.dal.service.ImGroupMemberService;
-import com.yonge.cooleshow.biz.dal.service.ImGroupService;
 import com.yonge.cooleshow.biz.dal.service.ImUserFriendService;
 import com.yonge.cooleshow.biz.dal.service.StudentService;
 import com.yonge.cooleshow.biz.dal.service.StudentTotalService;
 import com.yonge.cooleshow.biz.dal.service.im.ImGroupCoreService;
 import com.yonge.cooleshow.biz.dal.service.SysConfigService;
-import com.yonge.cooleshow.biz.dal.service.TeacherService;
 import com.yonge.cooleshow.biz.dal.service.TenantInfoService;
 import com.yonge.cooleshow.biz.dal.service.UserTenantAlbumRecordService;
 import com.yonge.cooleshow.biz.dal.vo.MyFollow;
@@ -67,7 +65,6 @@ import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import java.text.MessageFormat;
-import java.text.ParseException;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
@@ -129,6 +126,9 @@ public class StudentServiceImpl extends ServiceImpl<StudentDao, Student> impleme
     @Autowired
     private ImGroupCoreService imGroupCoreService;
 
+    @Autowired
+    private TenantGroupMapper tenantGroupMapper;
+
     @Override
     public StudentVo detail(Long userId) {
         return baseMapper.detail(userId);
@@ -434,6 +434,16 @@ public class StudentServiceImpl extends ServiceImpl<StudentDao, Student> impleme
     @Transactional(rollbackFor = Exception.class)
     @Override
     public Boolean save(StudentWrapper.Student studentInfo) {
+        if (studentInfo.getTenantGroupId() == null) {
+            studentInfo.setTenantGroupId(-1L);
+        }
+
+        Long tenantGroupId = studentInfo.getTenantGroupId();
+        TenantGroup tenantGroup = tenantGroupMapper.selectById(tenantGroupId);
+        if (tenantGroup == null) {
+            throw new BizException("机构小组不存在");
+        }
+
         if (studentInfo.getId() == null) {
             return createStudent(studentInfo);
         } else {
@@ -569,6 +579,7 @@ public class StudentServiceImpl extends ServiceImpl<StudentDao, Student> impleme
             }
         }
         this.lambdaUpdate().set(Student::getTenantId, toTenantId)
+                .set(Student::getTenantGroupId, -1L)
                 .eq(Student::getUserId, student.getUserId())
                 .update();
     }
@@ -605,6 +616,22 @@ public class StudentServiceImpl extends ServiceImpl<StudentDao, Student> impleme
 //             删除好友
             imUserFriendService.delTeacherFriendByTenantId(student.getTenantId(), student.getUserId(),
                     ClientEnum.STUDENT.getCode());
+
+            // 与新机构老师成为好友
+            if (newTenantId != -1L) {
+                // 自动与机构老师成为好友
+                QueryWrapper<Teacher> queryWrapper = new QueryWrapper<>();
+                queryWrapper.lambda().eq(Teacher::getTenantId, student.getTenantId());
+                List<Teacher> teacherList = teacherDao.selectList(queryWrapper);
+                teacherList.forEach(next -> imUserFriendService.saveUserFriend(next.getUserId(),
+                        new HashSet<>(ImmutableList.of(student.getUserId()))));
+            }
+        }
+
+        // 加入机构小组群
+        if (studentInfo.getTenantGroupId() != -1L && !studentInfo.getTenantGroupId().equals(student.getTenantGroupId())) {
+            quitFromTenantGroupIM(student.getTenantGroupId(), student.getUserId());
+            add2TenantGroupIM(studentInfo.getTenantGroupId(), studentInfo.getId());
         }
 
 
@@ -615,6 +642,7 @@ public class StudentServiceImpl extends ServiceImpl<StudentDao, Student> impleme
                     .set(Student::getTenantId, studentInfo.getTenantId())
                     .set(Student::getUserId, sysUser.getId())
                     .set(Student::getUpdateTime, new Date())
+                    .set(Student::getTenantGroupId, studentInfo.getTenantGroupId())
                     .set(StringUtils.isNotEmpty(studentInfo.getAvatar()), Student::getAvatar, studentInfo.getAvatar())
                     .eq(Student::getUserId, studentInfo.getId())
                     .update();
@@ -625,6 +653,7 @@ public class StudentServiceImpl extends ServiceImpl<StudentDao, Student> impleme
             newStudent.setUpdateTime(new Date());
             newStudent.setTenantId(studentInfo.getTenantId());
             newStudent.setAvatar(studentInfo.getAvatar());
+            newStudent.setTenantGroupId(studentInfo.getTenantGroupId());
             this.getBaseMapper().updateById(newStudent);
         }
         com.yonge.cooleshow.biz.dal.entity.SysUser sysUser = sysUserMapper.selectById(studentInfo.getId());
@@ -647,6 +676,66 @@ public class StudentServiceImpl extends ServiceImpl<StudentDao, Student> impleme
         return true;
     }
 
+    private void quitFromTenantGroupIM(Long tenantGroupId, Long studentId) {
+        TenantGroup tenantGroup = tenantGroupMapper.selectById(tenantGroupId);
+        if (tenantGroup == null || StringUtils.isEmpty(tenantGroup.getImGroupId())) {
+            return;
+        }
+        String imGroupId = tenantGroup.getImGroupId();
+        ImGroup imGroup = imGroupService.getById(imGroupId);
+        if (imGroup == null) {
+            return;
+        }
+        Integer count = imGroupMemberService.lambdaQuery()
+                .eq(ImGroupMember::getId, imGroupId)
+                .eq(ImGroupMember::getUserId, studentId)
+                .eq(ImGroupMember::getRoleType, ImGroupMemberRoleType.STUDENT)
+                .count();
+        if (count == 0) {
+            return;
+        }
+        try {
+            imGroupService.quit(imGroupId, studentId, ClientEnum.STUDENT, true);
+        } catch (Exception e) {
+            log.error("退出机构小组群失败", e);
+            throw new BizException("退出机构小组群失败");
+        }
+    }
+
+    /**
+     * 添加到机构小组IM群
+     * @param tenantGroupId 机构小组ID
+     * @param studentId 学生ID
+     */
+    private void add2TenantGroupIM(Long tenantGroupId, Long studentId) {
+        TenantGroup tenantGroup = tenantGroupMapper.selectById(tenantGroupId);
+        String imGroupId = tenantGroup.getImGroupId();
+        if (imGroupId == null) {
+            // 建群
+            try {
+                ImGroupWrapper.ImGroup imGroup = new ImGroupWrapper.ImGroup();
+                imGroup.setId(IdWorker.getId());
+                imGroup.setCreateBy(tenantGroup.getAdminId());
+                imGroup.setType(ImGroupType.ORG.getCode());
+                imGroup.setName(tenantGroup.getName());
+                imGroupId = imGroupService.create(imGroup);
+                tenantGroup.setImGroupId(imGroupId);
+                tenantGroupMapper.updateById(tenantGroup);
+            } catch (Exception e) {
+                log.error("创建机构小组群失败", e);
+                throw new BizException("创建机构小组群失败");
+            }
+        }
+        try {
+            Set<Long> userIds = new HashSet<>();
+            userIds.add(studentId);
+            imGroupService.addGroupMember(imGroupId, userIds);
+        } catch (Exception e) {
+            log.error("加入机构小组群失败", e);
+            throw new BizException("加入机构小组群失败");
+        }
+    }
+
     private Boolean createStudent(StudentWrapper.Student studentInfo) {
         String avatar = studentInfo.getAvatar();
         if (StringUtils.isEmpty(avatar)) {
@@ -661,6 +750,7 @@ public class StudentServiceImpl extends ServiceImpl<StudentDao, Student> impleme
         student.setAvatar(studentInfo.getAvatar());
         student.setCreateTime(new Date());
         student.setLockFlag(UserLockFlag.NORMAL);
+        student.setTenantGroupId(studentInfo.getTenantGroupId());
 
         save(student);
         try {
@@ -696,6 +786,11 @@ public class StudentServiceImpl extends ServiceImpl<StudentDao, Student> impleme
             }
         }
 
+        // 加入机构小组群
+        if (studentInfo.getTenantGroupId() != -1L) {
+            add2TenantGroupIM(student.getTenantGroupId(), student.getUserId());
+        }
+
         return true;
     }
 

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/TeacherServiceImpl.java

@@ -20,10 +20,12 @@ import com.yonge.cooleshow.biz.dal.dto.search.TeacherSearch;
 import com.yonge.cooleshow.biz.dal.entity.*;
 import com.yonge.cooleshow.biz.dal.enums.AuthStatusEnum;
 import com.yonge.cooleshow.biz.dal.enums.ClientEnum;
+import com.yonge.cooleshow.biz.dal.enums.ImGroupMemberRoleType;
 import com.yonge.cooleshow.biz.dal.enums.ImGroupType;
 import com.yonge.cooleshow.biz.dal.enums.MessageTypeEnum;
 import com.yonge.cooleshow.biz.dal.enums.TeacherTagEnum;
 import com.yonge.cooleshow.biz.dal.enums.TeacherTypeEnum;
+import com.yonge.cooleshow.biz.dal.mapper.TenantGroupMapper;
 import com.yonge.cooleshow.biz.dal.queryInfo.TeacherQueryInfo;
 import com.yonge.cooleshow.biz.dal.service.ImGroupService;
 import com.yonge.cooleshow.biz.dal.service.StudentService;
@@ -204,6 +206,9 @@ public class TeacherServiceImpl extends ServiceImpl<TeacherDao, Teacher> impleme
     @Autowired
     private SysUserMapper sysUserMapper;
 
+    @Autowired
+    private TenantGroupMapper tenantGroupMapper;
+
 
     @Override
     public TeacherVo detail(Long userId) {
@@ -1046,7 +1051,7 @@ public class TeacherServiceImpl extends ServiceImpl<TeacherDao, Teacher> impleme
         return wrapper;
     }
 
-//    @Transactional(rollbackFor = Exception.class)
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public void updateTenant(TeacherWrapper.UpdateTenant updateTenant,Long userId) {
         Teacher teacher = this.getById(updateTenant.getTeacherId());
@@ -1055,6 +1060,16 @@ public class TeacherServiceImpl extends ServiceImpl<TeacherDao, Teacher> impleme
         }
         Long oldTenantId = teacher.getTenantId();
         if (oldTenantId != -1L) {
+            // 判断是否存在机构小组群主身份
+            QueryWrapper<TenantGroup> queryWrapper = new QueryWrapper<>();
+            queryWrapper.lambda()
+                    .eq(TenantGroup::getTenantId, oldTenantId)
+                    .eq(TenantGroup::getAdminId, teacher.getUserId());
+            Integer count = tenantGroupMapper.selectCount(queryWrapper);
+            if (count > 0) {
+                throw new BizException(5100, "该老师存在机构小组负责人身份，请先移交小组或者解散小组");
+            }
+
             // 机构老师处理流程
             List<ImGroup> imGroups = imGroupService.lambdaQuery()
                     .eq(ImGroup::getCreateBy, teacher.getUserId())

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/TenantGroupServiceImpl.java

@@ -0,0 +1,420 @@
+package com.yonge.cooleshow.biz.dal.service.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.IdWorker;
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yonge.cooleshow.auth.api.entity.SysUser;
+import com.yonge.cooleshow.biz.dal.dao.StudentDao;
+import com.yonge.cooleshow.biz.dal.dao.SubjectDao;
+import com.yonge.cooleshow.biz.dal.dao.TeacherDao;
+import com.yonge.cooleshow.biz.dal.dto.search.StudentSearch;
+import com.yonge.cooleshow.biz.dal.entity.ImGroup;
+import com.yonge.cooleshow.biz.dal.entity.ImGroupMember;
+import com.yonge.cooleshow.biz.dal.entity.Student;
+import com.yonge.cooleshow.biz.dal.entity.Subject;
+import com.yonge.cooleshow.biz.dal.entity.Teacher;
+import com.yonge.cooleshow.biz.dal.entity.TenantGroup;
+import com.yonge.cooleshow.biz.dal.enums.ClientEnum;
+import com.yonge.cooleshow.biz.dal.enums.ImGroupMemberRoleType;
+import com.yonge.cooleshow.biz.dal.enums.ImGroupType;
+import com.yonge.cooleshow.biz.dal.mapper.TenantGroupMapper;
+import com.yonge.cooleshow.biz.dal.service.ImGroupMemberService;
+import com.yonge.cooleshow.biz.dal.service.ImGroupService;
+import com.yonge.cooleshow.biz.dal.service.SysUserService;
+import com.yonge.cooleshow.biz.dal.service.TenantGroupService;
+import com.yonge.cooleshow.biz.dal.service.im.ImGroupCoreService;
+import com.yonge.cooleshow.biz.dal.vo.StudentVo;
+import com.yonge.cooleshow.biz.dal.wrapper.StudentWrapper;
+import com.yonge.cooleshow.biz.dal.wrapper.TenantGroupWrapper;
+import com.yonge.cooleshow.biz.dal.wrapper.im.ImGroupWrapper;
+import com.yonge.toolset.base.exception.BizException;
+import com.yonge.toolset.mybatis.support.PageUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+/**
+ * 机构小组表
+ * 2023-10-11 09:24:50
+ */
+@Slf4j
+@Service
+public class TenantGroupServiceImpl extends ServiceImpl<TenantGroupMapper, TenantGroup> implements TenantGroupService {
+
+    @Autowired
+    private ImGroupService imGroupService;
+    @Autowired
+    private ImGroupCoreService imGroupCoreService;
+    @Autowired
+    private StudentDao studentDao;
+    @Autowired
+    private SubjectDao subjectDao;
+    @Autowired
+    private TeacherDao teacherDao;
+    @Autowired
+    private ImGroupMemberService imGroupMemberService;
+    @Autowired
+    private SysUserService sysUserService;
+
+    /**
+     * 查询详情
+     *
+     * @param id 详情ID
+     * @return TenantGroup
+     */
+    @Override
+    public TenantGroup detail(Long id) {
+
+        return baseMapper.selectById(id);
+    }
+
+    /**
+     * 分页查询
+     *
+     * @param page  IPage<TenantGroup>
+     * @param query TenantGroupWrapper.TenantGroupQuery
+     * @return IPage<TenantGroup>
+     */
+    @Override
+    public IPage<TenantGroupWrapper.TenantGroup> selectPage(IPage<TenantGroupWrapper.TenantGroup> page,
+                                                            TenantGroupWrapper.TenantGroupQuery query) {
+
+        IPage<TenantGroupWrapper.TenantGroup> iPage = page.setRecords(baseMapper.selectPage(page, query));
+        List<TenantGroupWrapper.TenantGroup> records = iPage.getRecords();
+        // 设置小组成员数量
+        if (!records.isEmpty()) {
+            List<Long> groupIdList =
+                    records.stream().map(TenantGroupWrapper.TenantGroup::getId).collect(Collectors.toList());
+            List<StudentWrapper.UserCount> userCounts = studentDao.countStudentByTenantGroupIds(query.getTenantId(),
+                    groupIdList);
+            Map<Long, Integer> groupBy =
+                    userCounts.stream().collect(Collectors.toMap(StudentWrapper.UserCount::getTenantGroupId
+                            , StudentWrapper.UserCount::getCount));
+            for (TenantGroupWrapper.TenantGroup record : records) {
+                record.setGroupUserCount(groupBy.getOrDefault(record.getId(), 0));
+            }
+        }
+        return iPage;
+    }
+
+    /**
+     * 添加
+     *
+     * @param tenantGroup TenantGroupWrapper.TenantGroup
+     * @return Boolean
+     */
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public Boolean add(TenantGroupWrapper.TenantGroup tenantGroup) {
+        TenantGroup entity = JSON.parseObject(tenantGroup.jsonString(), TenantGroup.class);
+        Integer count = this.lambdaQuery()
+                .eq(TenantGroup::getTenantId, tenantGroup.getTenantId())
+                .eq(TenantGroup::getName, entity.getName())
+                .count();
+        if (count > 0) {
+            throw new BizException("小组名称已存在");
+        }
+        this.save(entity);
+        List<Long> userIds = tenantGroup.getUserIds();
+        // 有群成员才建立机构小组群
+        if (!userIds.isEmpty()) {
+            // 建群
+            try {
+                ImGroupWrapper.ImGroup imGroup = new ImGroupWrapper.ImGroup();
+                imGroup.setId(IdWorker.getId());
+                imGroup.setCreateBy(tenantGroup.getAdminId());
+                imGroup.setType(ImGroupType.ORG.getCode());
+                imGroup.setName(tenantGroup.getName());
+                String imGroupId = imGroupService.create(imGroup);
+                entity.setImGroupId(imGroupId);
+                this.updateById(entity);
+            } catch (Exception e) {
+                log.error("创建机构小组群失败", e);
+                throw new BizException("创建机构小组群失败");
+            }
+            // 加群成员
+            try {
+                imGroupService.addGroupMember(entity.getImGroupId(), new HashSet<>(userIds));
+            } catch (Exception e) {
+                log.error("加入机构小组群失败", e);
+                throw new BizException("加入机构小组群失败");
+            }
+            studentDao.update(null, Wrappers.<Student>lambdaUpdate()
+                    .in(Student::getUserId, userIds)
+                    .eq(Student::getTenantId, tenantGroup.getTenantId())
+                    .set(Student::getTenantGroupId, entity.getId()));
+        }
+        return true;
+    }
+
+    /**
+     * 更新
+     *
+     * @param tenantGroup TenantGroupWrapper.TenantGroup
+     * @return Boolean
+     */
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public Boolean update(TenantGroupWrapper.TenantGroup tenantGroup) {
+        TenantGroup oldGroup = this.getById(tenantGroup.getId());
+
+        Integer count = this.lambdaQuery()
+                .ne(TenantGroup::getId, tenantGroup.getId())
+                .eq(TenantGroup::getTenantId, tenantGroup.getTenantId())
+                .eq(TenantGroup::getName, tenantGroup.getName())
+                .count();
+        if (count > 0) {
+            throw new BizException("小组名称已经存在");
+        }
+
+        TenantGroup entity = JSON.parseObject(tenantGroup.jsonString(), TenantGroup.class);
+        // 修改小组负责人，调整群主，更换群主需要新的群主为该群成员
+        if (oldGroup.getImGroupId() != null && !oldGroup.getAdminId().equals(entity.getAdminId())) {
+
+            // 如果新负责人不在群，先加入群
+            Integer toAdminInThisGroup = imGroupMemberService.lambdaQuery()
+                    .eq(ImGroupMember::getGroupId, oldGroup.getImGroupId())
+                    .eq(ImGroupMember::getUserId, entity.getAdminId())
+                    .count();
+            if (toAdminInThisGroup == 0) {
+                // 新负责人加入群
+                try {
+                    SysUser newTeacher = sysUserService.getByUserId(entity.getAdminId());
+                    ImGroupMember imGroupMember = new ImGroupMember();
+                    imGroupMember.setGroupId(oldGroup.getImGroupId());
+                    imGroupMember.setUserId(entity.getAdminId());
+                    imGroupMember.setRoleType(ImGroupMemberRoleType.TEACHER);
+                    imGroupMember.setAvatar(newTeacher.getAvatar());
+                    imGroupMember.setNickname(newTeacher.getUsername());
+                    imGroupMember.setIsAdmin(false);
+                    imGroupMember.setRoleType(ImGroupMemberRoleType.TEACHER);
+
+                    imGroupMemberService.join(Collections.singletonList(imGroupMember), oldGroup.getImGroupId());
+                } catch (Exception e) {
+                    log.error("负责人加入群失败", e);
+                    throw new BizException("负责人加入群失败");
+                }
+            }
+
+            ImGroup oldImGroup = imGroupService.getById(oldGroup.getImGroupId());
+            if (oldImGroup != null) {
+                try {
+                    imGroupCoreService.changeGroupOwner(oldGroup.getImGroupId(),
+                            String.valueOf(tenantGroup.getAdminId()),
+                            String.valueOf(oldGroup.getAdminId()));
+                    imGroupCoreService.groupQuit(oldGroup.getAdminId(), ClientEnum.TEACHER.getCode(),
+                            oldGroup.getImGroupId(), true);
+                } catch (Exception e) {
+                    log.error("更换群主失败", e);
+                    throw new BizException("更换群主失败");
+                }
+            }
+        }
+        QueryWrapper<Student> queryWrapper = new QueryWrapper<>();
+        queryWrapper.lambda()
+                .eq(Student::getTenantId, tenantGroup.getTenantId())
+                .eq(Student::getTenantGroupId, tenantGroup.getId());
+        List<Long> oldGroupUsers = studentDao.selectList(queryWrapper).stream().map(Student::getUserId)
+                .collect(Collectors.toList());
+
+        List<Long> newGroupUsers = tenantGroup.getUserIds();
+
+        List<Long> removeGroupUsers = oldGroupUsers.stream()
+                .filter(next -> !newGroupUsers.contains(next)).collect(Collectors.toList());
+        // 移除的群成员，退群
+        if (!removeGroupUsers.isEmpty()) {
+            try {
+                for (Long removeUserId : removeGroupUsers) {
+                    imGroupCoreService.groupQuit(removeUserId, ClientEnum.STUDENT.getCode(), oldGroup.getImGroupId(),
+                            true);
+                }
+            } catch (Exception e) {
+                log.error("群成员移出群失败", e);
+                throw new BizException("群成员移出群失败");
+            }
+            studentDao.update(null, Wrappers.<Student>lambdaUpdate()
+                    .in(Student::getUserId, removeGroupUsers)
+                    .eq(Student::getTenantId, tenantGroup.getTenantId())
+                    .set(Student::getTenantGroupId, -1L));
+        }
+        // 新增的群成员
+        List<Long> newAddGroupUsers = newGroupUsers.stream().filter(next -> !oldGroupUsers.contains(next))
+                .collect(Collectors.toList());
+        if (!newAddGroupUsers.isEmpty()) {
+            // 加群成员
+            try {
+                imGroupService.addGroupMember(oldGroup.getImGroupId(), new HashSet<>(newAddGroupUsers));
+            } catch (Exception e) {
+                log.error("加入机构小组群失败", e);
+                throw new BizException("加入机构小组群失败");
+            }
+            studentDao.update(null, Wrappers.<Student>lambdaUpdate()
+                    .in(Student::getUserId, newAddGroupUsers)
+                    .eq(Student::getTenantId, tenantGroup.getTenantId())
+                    .set(Student::getTenantGroupId, entity.getId()));
+        }
+        return this.updateById(entity);
+    }
+
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public Boolean delete(Long id) {
+        TenantGroup group = this.getById(id);
+        if (group == null) {
+            throw new BizException("机构小组不存在");
+        }
+        String imGroupId = group.getImGroupId();
+        if (imGroupId != null) {
+            ImGroup imGroup = imGroupService.getById(imGroupId);
+            if (imGroup != null) {
+                try {
+                    imGroupCoreService.groupDismiss(imGroupId);
+                } catch (Exception e) {
+                    log.error("解散群失败", e);
+                }
+            }
+        }
+        studentDao.update(null, Wrappers.<Student>lambdaUpdate()
+                .eq(Student::getTenantId, group.getTenantId())
+                .set(Student::getTenantGroupId, -1L));
+        return removeById(id);
+    }
+
+    /**
+     * 查询机构小组群成员
+     *
+     * @param tenantId      机构ID
+     * @param tenantGroupId 机构小组ID
+     * @return 机构小组成员列表
+     */
+    @Override
+    public List<TenantGroupWrapper.TenantGroupMember> queryGroupMember(Long tenantId, Long tenantGroupId) {
+        StudentSearch studentSearch = new StudentSearch();
+        studentSearch.setRows(1);
+        studentSearch.setPage(9999);
+        List<StudentVo> studentVos = studentDao.selectPage(PageUtil.getPage(studentSearch), studentSearch);
+        if (studentVos.isEmpty()) {
+            return new ArrayList<>();
+        }
+        Map<String, String> subjectIdNameMap = new HashMap<>();
+        List<String> subjectIds = studentVos.stream().map(Student::getSubjectId).filter(StringUtils::isNotEmpty)
+                .distinct().collect(Collectors.toList());
+
+        if (!subjectIds.isEmpty()) {
+            List<Subject> subject = subjectDao.findBySubjectByIdList(String.join(",", subjectIds));
+            Map<String, String> map = subject.stream().collect(Collectors.toMap(next -> next.getId().toString(),
+                    Subject::getName));
+            subjectIdNameMap.putAll(map);
+        }
+
+
+        return studentVos.stream().map(next -> {
+            TenantGroupWrapper.TenantGroupMember member = new TenantGroupWrapper.TenantGroupMember();
+            member.setUserId(next.getUserId());
+            member.setTenantId(next.getTenantId());
+            member.setName(next.getUsername());
+            member.setGender(next.getGender());
+            member.setBirthdate(next.getBirthdate());
+            member.setPhone(next.getPhone());
+            member.setAvatar(next.getAvatar());
+            member.setSubjectId(next.getSubjectId());
+            member.setSubjectName(subjectIdNameMap.getOrDefault(next.getSubjectId(), ""));
+            return member;
+        }).collect(Collectors.toList());
+    }
+
+    /**
+     * 小组交接
+     *
+     * @param adjustTenantGroup 入参
+     * @return 成功/失败
+     */
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public Boolean adjustTenantGroup(TenantGroupWrapper.AdjustTenantGroup adjustTenantGroup) {
+        Long teacherId = adjustTenantGroup.getTeacherId();
+        Teacher teacher = teacherDao.selectById(teacherId);
+        if (teacher == null) {
+            throw new BizException("移交的老师不存在");
+        }
+        List<TenantGroupWrapper.AdjustTenantGroupDetail> details = adjustTenantGroup.getAdjustTenantGroupDetails();
+        if (details.isEmpty()) {
+            throw new BizException("未选择移交信息");
+        }
+        List<Long> tenantGroupIds =
+                details.stream().map(TenantGroupWrapper.AdjustTenantGroupDetail::getTenantGroupId).collect(Collectors.toList());
+        List<TenantGroup> tenantGroups = this.lambdaQuery().in(TenantGroup::getId, tenantGroupIds).list();
+        Map<Long, String> groupBy = tenantGroups.stream().collect(Collectors.toMap(TenantGroup::getId,
+                TenantGroup::getImGroupId));
+        for (TenantGroupWrapper.AdjustTenantGroupDetail detail : details) {
+            Long toTeacher = detail.getTeacherId();
+            if (teacherId.equals(toTeacher) && Boolean.FALSE.equals(detail.getDismiss())) {
+                continue;
+            }
+            String imGroupId = groupBy.get(detail.getTenantGroupId());
+            if (toTeacher != null) {
+                // 更换群主
+                if (!StringUtils.isEmpty(imGroupId)) {
+                    // 新负责人加入群
+                    try {
+                        SysUser newTeacher = sysUserService.getByUserId(toTeacher);
+                        ImGroupMember imGroupMember = new ImGroupMember();
+                        imGroupMember.setGroupId(imGroupId);
+                        imGroupMember.setUserId(toTeacher);
+                        imGroupMember.setRoleType(ImGroupMemberRoleType.TEACHER);
+                        imGroupMember.setAvatar(newTeacher.getAvatar());
+                        imGroupMember.setNickname(newTeacher.getUsername());
+                        imGroupMember.setIsAdmin(false);
+                        imGroupMember.setRoleType(ImGroupMemberRoleType.TEACHER);
+
+                        imGroupMemberService.join(Collections.singletonList(imGroupMember), imGroupId);
+                    } catch (Exception e) {
+                        log.error("负责人加入群失败", e);
+                        throw new BizException("负责人加入群失败");
+                    }
+
+                    try {
+                        imGroupCoreService.changeGroupOwner(imGroupId, String.valueOf(toTeacher),
+                                String.valueOf(teacherId));
+                        imGroupCoreService.groupQuit(teacherId, ClientEnum.TEACHER.getCode(),
+                                imGroupId, true);
+                    } catch (Exception e) {
+                        log.error("移交负责人失败", e);
+                        throw new BizException("移交负责人失败");
+                    }
+                }
+                this.lambdaUpdate()
+                        .set(TenantGroup::getAdminId, toTeacher)
+                        .eq(TenantGroup::getId, detail.getTenantGroupId())
+                        .update();
+            } else if (Boolean.TRUE.equals(detail.getDismiss())) {
+                // 解散群
+                if (!StringUtils.isEmpty(imGroupId)) {
+                    try {
+                        imGroupCoreService.groupDismiss(imGroupId);
+                    } catch (Exception e) {
+                        log.error("解散群失败", e);
+                        throw new BizException("解散群失败");
+                    }
+                }
+                this.removeById(detail.getTenantGroupId());
+            }
+        }
+        return true;
+    }
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/TenantUnbindRecordServiceImpl.java

@@ -16,6 +16,7 @@ import com.yonge.cooleshow.biz.dal.enums.ClientEnum;
 import com.yonge.cooleshow.biz.dal.enums.ImGroupType;
 import com.yonge.cooleshow.biz.dal.enums.MessageTypeEnum;
 import com.yonge.cooleshow.biz.dal.mapper.SysAreaMapper;
+import com.yonge.cooleshow.biz.dal.mapper.TenantGroupMapper;
 import com.yonge.cooleshow.biz.dal.mapper.TenantUnbindRecordMapper;
 import com.yonge.cooleshow.biz.dal.service.*;
 import com.yonge.cooleshow.biz.dal.wrapper.TenantUnbindRecordWrapper;
@@ -85,6 +86,9 @@ public class TenantUnbindRecordServiceImpl extends ServiceImpl<TenantUnbindRecor
     @Autowired
     private ImUserFriendService imUserFriendService;
 
+    @Autowired
+    private TenantGroupMapper tenantGroupMapper;
+
     /**
      * @param id 详情ID
      * @return TenantUnbindRecord
@@ -211,6 +215,18 @@ public class TenantUnbindRecordServiceImpl extends ServiceImpl<TenantUnbindRecor
         if (unbindRecord == null || !ETenantUnBindAuditStatus.DOING.equals(unbindRecord.getStatus())) {
             throw new BizException("审核记录不存在");
         }
+        Teacher teacher = teacherDao.selectById(unbindRecord.getUserId());
+
+        // 判断是否存在机构小组群主身份
+        QueryWrapper<TenantGroup> queryWrapper = new QueryWrapper<>();
+        queryWrapper.lambda()
+                .eq(TenantGroup::getTenantId, teacher.getTenantId())
+                .eq(TenantGroup::getAdminId, teacher.getUserId());
+        Integer count = tenantGroupMapper.selectCount(queryWrapper);
+        if (count > 0) {
+            throw new BizException(5100, "该老师存在机构小组负责人身份，请先移交小组或者解散小组");
+        }
+
         this.lambdaUpdate()
                 .set(TenantUnbindRecord::getStatus, Boolean.TRUE.equals(audio.getStatus()) ?
                         ETenantUnBindAuditStatus.PASS : ETenantUnBindAuditStatus.UNPASS)
@@ -221,7 +237,6 @@ public class TenantUnbindRecordServiceImpl extends ServiceImpl<TenantUnbindRecor
                 .eq(TenantUnbindRecord::getStatus, ETenantUnBindAuditStatus.DOING)
                 .update();
         if (Boolean.TRUE.equals(audio.getStatus())) {
-            Teacher teacher = teacherDao.selectById(unbindRecord.getUserId());
             Long tenantId = teacher.getTenantId();
             if (tenantId != -1L) {
                 // 解散机构群

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/wrapper/StudentWrapper.java

@@ -102,6 +102,9 @@ public class StudentWrapper {
         @ApiModelProperty("所属机构，开放接口必填")
         private Long tenantId;
 
+        @ApiModelProperty("机构小组ID")
+        private Long tenantGroupId;
+
         @ApiModelProperty("姓名")
         private String name;
 
@@ -215,4 +218,10 @@ public class StudentWrapper {
         @NotNull
         private String password;
     }
+
+    @Data
+    public static class UserCount {
+        private Long tenantGroupId;
+        private Integer count;
+    }
 }

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/wrapper/TenantGroupWrapper.java

@@ -0,0 +1,171 @@
+package com.yonge.cooleshow.biz.dal.wrapper;
+
+import com.alibaba.fastjson.JSON;
+import com.microsvc.toolkit.common.response.paging.QueryInfo;
+import com.yonge.cooleshow.biz.dal.enums.GenderEnum;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Optional;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.apache.commons.lang3.StringUtils;
+
+import javax.validation.constraints.NotNull;
+
+/**
+ * 机构小组表
+ * 2023-10-11 09:24:50
+ */
+@ApiModel(value = "TenantGroupWrapper对象", description = "机构小组表查询对象")
+public class TenantGroupWrapper {
+
+    @Data
+    @Builder
+    @NoArgsConstructor
+    @AllArgsConstructor
+    @ApiModel(" TenantGroupQuery-机构小组表")
+    public static class TenantGroupQuery implements QueryInfo {
+
+        @ApiModelProperty("当前页")
+        private Integer page;
+
+        @ApiModelProperty("分页行数")
+        private Integer rows;
+
+        @ApiModelProperty("关键字匹配")
+        private String keyword;
+
+        @ApiModelProperty("机构ID")
+        private Long tenantId;
+
+        @ApiModelProperty("机构小组负责人")
+        private Long adminId;
+
+        public String getKeyword() {
+            return Optional.ofNullable(keyword).filter(StringUtils::isNotBlank).orElse(null);
+        }
+
+        public String jsonString() {
+            return JSON.toJSONString(this);
+        }
+
+        public static TenantGroupQuery from(String json) {
+            return JSON.parseObject(json, TenantGroupQuery.class);
+        }
+    }
+
+    @Data
+    @ApiModel(" TenantGroup-机构小组表")
+    public static class TenantGroup {
+
+        @ApiModelProperty("主键ID")
+        private Long id;
+
+        @ApiModelProperty("机构ID")
+        private Long tenantId;
+
+        @ApiModelProperty("小组名称")
+        private String name;
+
+        @ApiModelProperty("管理员ID")
+        private Long adminId;
+
+        @ApiModelProperty("IM群聊ID")
+        private String imGroupId;
+
+        @ApiModelProperty("创建人")
+        private Long createBy;
+
+        @ApiModelProperty("创建时间")
+        private Date createTime;
+
+        @ApiModelProperty("群成员列表")
+        private List<Long> userIds = new ArrayList<>();
+
+        @ApiModelProperty("群成员数量")
+        private Integer groupUserCount = 0;
+
+        public String jsonString() {
+            return JSON.toJSONString(this);
+        }
+
+        public static TenantGroup from(String json) {
+            return JSON.parseObject(json, TenantGroup.class);
+        }
+    }
+
+    @Data
+    @ApiModel(" TenantGroup-机构小组成员")
+    public static class TenantGroupMember {
+
+        @ApiModelProperty("userId")
+        private Long userId;
+
+        @ApiModelProperty("所属机构，开放接口必填")
+        private Long tenantId;
+
+        @ApiModelProperty("姓名")
+        private String name;
+
+        @ApiModelProperty("性别。0：女 1：男")
+        private GenderEnum gender;
+
+        @ApiModelProperty("生日")
+        private Date birthdate;
+
+        @ApiModelProperty("手机号码")
+        private String phone;
+
+        @ApiModelProperty("头像")
+        private String avatar;
+
+        @ApiModelProperty("声部")
+        private String subjectId;
+
+        @ApiModelProperty("声部")
+        private String subjectName;
+
+        public String jsonString() {
+            return JSON.toJSONString(this);
+        }
+
+        public static TenantGroup from(String json) {
+            return JSON.parseObject(json, TenantGroup.class);
+        }
+    }
+
+    @Data
+    @ApiModel("调整机构小组")
+    public static class AdjustTenantGroup {
+
+        @ApiModelProperty("移交前的负责人ID")
+        @NotNull
+        private Long teacherId;
+
+        @ApiModelProperty("机构小组调整详情")
+        private List<AdjustTenantGroupDetail> adjustTenantGroupDetails = new ArrayList<>();
+
+    }
+
+    @Data
+    @ApiModel("调整机构小组详情")
+    public static class AdjustTenantGroupDetail{
+        @ApiModelProperty("机构小组ID")
+        private Long tenantGroupId;
+
+        @ApiModelProperty("移交后的负责人ID")
+        private Long teacherId;
+
+        @ApiModelProperty("是否解散")
+        private Boolean dismiss = false;
+    }
+
+}

cooleshow-user/user-biz/src/main/resources/config/mybatis/StudentMapper.xml

@@ -14,6 +14,7 @@
         <result column="create_time_" property="createTime"/>
         <result column="update_time_" property="updateTime"/>
         <result column="avatar_" property="avatar"/>
+        <result column="tenant_group_id_" property="tenantGroupId"/>
     </resultMap>
 
     <!-- 表字段 -->
@@ -31,6 +32,7 @@
         , t.tenant_id_ as tenantId
         , t.create_time_ as `createTime`
         , t.update_time_ as `updateTime`
+        , t.tenant_group_id_ as `tenantGroupId`
         </sql>
     <update id="setSubject">
         update student set subject_id_ = #{subjectIds},update_time_ = now() where user_id_ = #{id}
@@ -353,4 +355,22 @@
             </if>
         </where>
     </select>
+
+    <select id="countStudentByTenantGroupIds" resultType="com.yonge.cooleshow.biz.dal.wrapper.StudentWrapper$UserCount">
+        select ifnull(tenant_group_id_,-1) tenantGroupId, count(user_id_) count
+        from student
+        <where>
+            lock_flag_ = 0
+            <if test="tenantId != null">
+                AND tenant_id_ =#{tenantId}
+            </if>
+            <if test="groupIdList != null and groupIdList.size() > 0">
+                AND tenant_group_id_ in
+                <foreach collection="groupIdList" item="item" separator="," open="(" close=")">
+                    #{item}
+                </foreach>
+            </if>
+        </where>
+        group by tenant_group_id_
+    </select>
 </mapper>

cooleshow-user/user-biz/src/main/resources/config/mybatis/TenantGroupMapper.xml

@@ -0,0 +1,35 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE  mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.yonge.cooleshow.biz.dal.mapper.TenantGroupMapper">
+
+
+
+    <!-- 表字段 -->
+    <sql id="baseColumns">
+        t.id_ AS id
+        , t.tenant_id_ AS tenantId
+        , t.name_ AS name
+        , t.admin_id_ AS adminId
+        , t.im_group_id_ AS imGroupId
+        , t.create_by_ AS createBy
+        , t.create_time_ AS createTime
+    </sql>
+
+    <select id="selectPage" resultType="com.yonge.cooleshow.biz.dal.wrapper.TenantGroupWrapper$TenantGroup">
+        SELECT
+        <include refid="baseColumns" />
+        FROM tenant_group t
+        <where>
+            <if test="param.keyword != null and param.keyword.trim() !=''">
+                t.name_ like concat('%',#{param.keyword},'%')
+            </if>
+            <if test="param.tenantId != null">
+                t.tenant_id_ = #{param.tenantId}
+            </if>
+            <if test="param.adminId != null">
+                t.admin_id_ = #{param.adminId}
+            </if>
+        </where>
+    </select>
+
+</mapper>

cooleshow-user/user-tenant/src/main/java/com/yonge/cooleshow/tenant/controller/TenantActivationCodeController.java

@@ -21,12 +21,14 @@ import com.yonge.cooleshow.biz.dal.entity.TenantAlbumPurchase;
 import com.yonge.cooleshow.biz.dal.entity.TenantInfo;
 import com.yonge.cooleshow.biz.dal.entity.TenantStaff;
 import com.yonge.cooleshow.biz.dal.entity.UserOrder;
+import com.yonge.cooleshow.biz.dal.service.OssFileService;
 import com.yonge.cooleshow.biz.dal.service.TenantActivationCodeService;
 import com.yonge.cooleshow.biz.dal.service.TenantAlbumPurchaseService;
 import com.yonge.cooleshow.biz.dal.service.TenantAlbumService;
 import com.yonge.cooleshow.biz.dal.service.TenantInfoService;
 import com.yonge.cooleshow.biz.dal.service.TenantStaffService;
 import com.yonge.cooleshow.biz.dal.service.UserOrderService;
+import com.yonge.cooleshow.biz.dal.wrapper.OssFileWrapper;
 import com.yonge.cooleshow.biz.dal.wrapper.TenantActivationCodeWrapper;
 import com.yonge.cooleshow.common.controller.BaseController;
 import com.yonge.cooleshow.common.entity.HttpResponseResult;
@@ -58,6 +60,9 @@ import org.springframework.web.multipart.MultipartFile;
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletResponse;
 import java.io.File;
+import java.io.UnsupportedEncodingException;
+import java.net.URL;
+import java.net.URLEncoder;
 import java.text.MessageFormat;
 import java.text.ParsePosition;
 import java.text.SimpleDateFormat;
@@ -93,6 +98,8 @@ public class TenantActivationCodeController extends BaseController {
     private UserOrderService userOrderService;
     @Autowired
     private TenantAlbumService tenantAlbumService;
+    @Autowired
+    private OssFileService ossFileService;
 
     @ApiOperation(value = "详情", notes = "机构激活码-根据详情ID查询单条, 传入id")
 //    @GetMapping("/detail/{id}")
@@ -198,7 +205,7 @@ public class TenantActivationCodeController extends BaseController {
 
     @GetMapping("/exportActiveCode")
     @ApiOperation(value = "导出模板")
-    public HttpResponseResult<TenantActivationCodeWrapper.ExportFile> exportActiveCode(HttpServletResponse response, String orderNo) {
+    public HttpResponseResult<OssFileWrapper.ExportFile> exportActiveCode(HttpServletResponse response, String orderNo) {
         SysUser sysUser = sysUserFeignService.queryUserInfo();
         if (sysUser == null) {
             throw new BizException("请登录");
@@ -230,7 +237,8 @@ public class TenantActivationCodeController extends BaseController {
 
         String format = new SimpleDateFormat("yyyyMMddHHmm").format(userOrder.getCreateTime());
 
-        TenantActivationCodeWrapper.ExportFile exportFile = generateExportExcelFile(templates,
+
+        OssFileWrapper.ExportFile exportFile = ossFileService.uploadFile(templates,
                 TenantActivationCodeWrapper.ExportTemplate.class, format + tenantAlbum.getName(), "激活码");
         return succeed(exportFile);
     }

cooleshow-user/user-tenant/src/main/java/com/yonge/cooleshow/tenant/controller/TenantGroupController.java

@@ -0,0 +1,105 @@
+package com.yonge.cooleshow.tenant.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.microsvc.toolkit.common.response.paging.PageInfo;
+import com.microsvc.toolkit.common.response.paging.QueryInfo;
+import com.microsvc.toolkit.common.response.template.R;
+import com.yonge.cooleshow.auth.api.client.SysUserFeignService;
+import com.yonge.cooleshow.auth.api.entity.SysUser;
+import com.yonge.cooleshow.biz.dal.entity.TenantGroup;
+import com.yonge.cooleshow.biz.dal.service.TenantGroupService;
+import com.yonge.cooleshow.biz.dal.wrapper.TenantGroupWrapper;
+import com.yonge.cooleshow.tenant.vo.TenantGroupVo;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+@Slf4j
+@Validated
+@RestController
+@RequestMapping("/tenantGroup")
+@Api(tags = "机构小组表")
+public class TenantGroupController {
+
+    @Autowired
+    private TenantGroupService tenantGroupService;
+
+    @Resource
+    private SysUserFeignService sysUserFeignService;
+
+    @ApiOperation(value = "详情", notes = "机构小组表-根据详情ID查询单条, 传入id")
+    @GetMapping("/detail/{id}")
+    public R<TenantGroup> detail(@PathVariable("id") Long id) {
+        TenantGroup wrapper = tenantGroupService.detail(id);
+        return R.from(wrapper);
+    }
+
+    @ApiOperation(value = "详情", notes = "机构小组表-根据详情ID查询单条, 传入id")
+    @GetMapping("/queryGroupMember/{tenantGroupId}")
+    public R<List<TenantGroupWrapper.TenantGroupMember>> queryGroupMember(@PathVariable("tenantGroupId") Long tenantGroupId) {
+        SysUser sysUser = sysUserFeignService.queryUserInfo();
+        return R.from(tenantGroupService.queryGroupMember(sysUser.getTenantId(), tenantGroupId));
+    }
+
+    @ApiOperation(value = "查询分页", notes = "机构小组表- 传入 TenantGroupWrapper.TenantGroupQuery")
+    @PostMapping("/page")
+    public R<PageInfo<TenantGroupWrapper.TenantGroup>> page(@RequestBody TenantGroupWrapper.TenantGroupQuery query) {
+
+        IPage<TenantGroupWrapper.TenantGroup> pages = tenantGroupService.selectPage(QueryInfo.getPage(query), query);
+
+        return R.from(QueryInfo.pageInfo(pages));
+    }
+
+    @ApiOperation(value = "新增", notes = "机构小组表- 传入 TenantGroupWrapper.TenantGroup")
+    @PostMapping("/save")
+    public R<JSONObject> add(@Validated @RequestBody TenantGroupVo.TenantGroup tenantGroup) {
+        SysUser sysUser = sysUserFeignService.queryUserInfo();
+        TenantGroupWrapper.TenantGroup group = TenantGroupWrapper.TenantGroup.from(tenantGroup.jsonString());
+        group.setCreateBy(sysUser.getId());
+        group.setTenantId(sysUser.getTenantId());
+        // 新增数据
+        tenantGroupService.add(group);
+
+        return R.defaultR();
+    }
+
+    @ApiOperation(value = "修改", notes = "机构小组表- 传入 TenantGroupWrapper.TenantGroup")
+    @PostMapping("/update")
+    public R<JSONObject> update(@Validated @RequestBody TenantGroupVo.TenantGroup tenantGroup) {
+        // 更新数据
+        SysUser sysUser = sysUserFeignService.queryUserInfo();
+        TenantGroupWrapper.TenantGroup group = TenantGroupWrapper.TenantGroup.from(tenantGroup.jsonString());
+        group.setCreateBy(sysUser.getId());
+        group.setTenantId(sysUser.getTenantId());
+        tenantGroupService.update(group);
+
+        return R.defaultR();
+    }
+
+    @ApiOperation(value = "删除", notes = "机构小组表- 传入id")
+    @PostMapping("/remove")
+    public R<Boolean> remove(@RequestParam Long id) {
+
+        return R.from(tenantGroupService.delete(id));
+    }
+
+    @ApiOperation(value = "处理机构小组交接", notes = "处理机构小组交接")
+    @PostMapping("/adjustTenantGroup")
+    public R<Boolean> adjustTenantGroup(@RequestBody TenantGroupWrapper.AdjustTenantGroup adjustTenantGroup) {
+        return R.from(tenantGroupService.adjustTenantGroup(adjustTenantGroup));
+    }
+}

cooleshow-user/user-tenant/src/main/java/com/yonge/cooleshow/tenant/vo/TenantGroupVo.java

@@ -0,0 +1,72 @@
+package com.yonge.cooleshow.tenant.vo;
+
+import com.alibaba.fastjson.JSON;
+import com.microsvc.toolkit.common.response.paging.QueryInfo;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotNull;
+
+/**
+ * 机构小组表
+ * 2023-10-11 09:24:50
+ */
+@ApiModel(value = "TenantGroupVo对象", description = "机构小组表查询视图对象")
+public class TenantGroupVo {
+
+    @Data
+    @ApiModel(" TenantGroupQuery-机构小组表")
+    public static class TenantGroupQuery implements QueryInfo {
+
+        @ApiModelProperty("当前页")
+        private Integer page;
+
+        @ApiModelProperty("分页行数")
+        private Integer rows;
+
+        public String jsonString() {
+            return JSON.toJSONString(this);
+        }
+
+        public static TenantGroupQuery from(String json) {
+            return JSON.parseObject(json, TenantGroupQuery.class);
+        }
+    }
+
+    @Data
+    @ApiModel(" TenantGroup-机构小组表")
+    public static class TenantGroup {
+
+        @ApiModelProperty("主键ID")
+        private Long id;
+
+        @ApiModelProperty("机构ID")
+        private Long tenantId;
+
+        @ApiModelProperty("小组名称")
+        @NotNull(message = "小组名称不能为空")
+        private String name;
+
+        @ApiModelProperty("小组负责人")
+        @NotNull(message = "小组负责人不能为空")
+        private Long adminId;
+
+        @ApiModelProperty("群成员列表")
+        private List<Long> userIds = new ArrayList<>();
+
+        public String jsonString() {
+            return JSON.toJSONString(this);
+        }
+
+        public static TenantGroup from(String json) {
+            return JSON.parseObject(json, TenantGroup.class);
+        }
+    }
+
+}