群组

aijinhui

2023-12-22 aa3706580edc249216c20db6992aaf5b249dd960

 ard-work/src/main/java/com/ruoyi/rongcloud/service/Impl/RongCloudServiceImpl.java

@@ -1,11 +1,12 @@
package com.ruoyi.rongcloud.service.Impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.rongcloud.domain.RongCloudGroupDisParam;
import com.ruoyi.rongcloud.domain.RongCloudGroupParam;
import com.ruoyi.rongcloud.domain.RongCloudParam;
import com.ruoyi.rongcloud.mapper.ArdRongGroupMapper;
import com.ruoyi.rongcloud.mapper.ArdRongGroupUserMapper;
import com.ruoyi.rongcloud.domain.*;
import com.ruoyi.rongcloud.service.RongCloudService;
import com.ruoyi.utils.forest.RongCloudClient;
import lombok.extern.slf4j.Slf4j;
@@ -31,6 +32,11 @@
    RongCloudClient rongCloudClient;
    @Resource
    RedisCache redisCache;
    @Resource
    private ArdRongGroupMapper ardRongGroupMapper;
    @Resource
    private ArdRongGroupUserMapper ardRongGroupUserMapper;


    /**
     * 获取融云token
@@ -79,7 +85,24 @@
    public AjaxResult groupCreate(RongCloudGroupParam group) {
        group.setGroupId(String.valueOf(UUID.randomUUID()));
        Map<String, Object> groupMap =  rongCloudClient.groupCreate(getRongCloudHead(),group);
        groupMap.put("userId",group.getGroupId());
        Integer code = (Integer) groupMap.get("code");
        if(code.equals(200)){
            ArdRongGroup ardRongGroup = new ArdRongGroup();
            ardRongGroup.setGroupId(group.getGroupId());
            ardRongGroup.setGroupName(group.getGroupName());
            ardRongGroup.setCreateName(SecurityUtils.getUserId());
            ardRongGroup.setCreateTime(new Date());
            ardRongGroupMapper.insert(ardRongGroup);
            List<String> userList = group.getUserId();
            for (int i = 0; i < userList.size(); i++) {
                ArdRongGroupUser ardRongGroupUser = new ArdRongGroupUser();
                ardRongGroupUser.setId(String.valueOf(UUID.randomUUID()));
                ardRongGroupUser.setGroupId(group.getGroupId());
                ardRongGroupUser.setUserId(userList.get(i));
                ardRongGroupUserMapper.insert(ardRongGroupUser);
            }
        }
        groupMap.put("userId",group.getUserId());
        groupMap.put("groupId",group.getGroupId());
        groupMap.put("group",group.getGroupName());
        return AjaxResult.success(groupMap);
@@ -88,6 +111,13 @@
    @Override
    public AjaxResult groupDismiss(RongCloudGroupDisParam groupDis) {
        Map<String, Object> groupMap =  rongCloudClient.groupDismiss(getRongCloudHead(),groupDis);
        Integer code = (Integer) groupMap.get("code");
        if(code.equals(200)){
            ardRongGroupMapper.deleteById(groupDis.getGroupId());
            QueryWrapper<ArdRongGroupUser> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("group_id",groupDis.getGroupId());
            ardRongGroupUserMapper.delete(queryWrapper);
        }
        groupMap.put("groupId",groupDis.getGroupId());
        groupMap.put("userId",groupDis.getUserId());
        return AjaxResult.success(groupMap);