融云建群修改提交

zhangnaisong

2024-05-17 6bddb83b1e7556aa9b2b1d4ce7ed5f4b4c62f2d0

融云建群修改提交

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

@@ -1,8 +1,10 @@
package com.ruoyi.rongcloud.service.Impl;

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.dtflys.forest.exceptions.ForestRuntimeException;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.domain.entity.SysConfig;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.utils.SecurityUtils;
@@ -11,14 +13,18 @@
import com.ruoyi.rongcloud.domain.*;
import com.ruoyi.rongcloud.param.*;
import com.ruoyi.rongcloud.service.RongCloudService;
import com.ruoyi.system.mapper.SysConfigMapper;
import com.ruoyi.system.mapper.SysUserMapper;
import com.ruoyi.utils.forest.RongCloudClient;
import lombok.extern.slf4j.Slf4j;
import okhttp3.*;
import org.apache.commons.codec.digest.DigestUtils;
import org.apache.commons.lang3.RandomStringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.io.IOException;
import java.lang.reflect.Field;
import java.util.*;

@@ -43,7 +49,8 @@
    private ArdRongGroupUserMapper ardRongGroupUserMapper;
    @Resource
    private SysUserMapper sysUserMapper;

    @Resource
    private SysConfigMapper sysConfigMapper;

    /**
     * 获取融云token
@@ -92,7 +99,14 @@
    @Override
    public AjaxResult groupCreate(RongCloudGroupParam group) {
        group.setGroupId(String.valueOf(UUID.randomUUID()));
        Map<String, Object> groupMap = rongCloudClient.groupCreate(getRongCloudHead(), group);
        //Map<String, Object> groupMap = rongCloudClient.groupCreate(getRongCloudHead(), group);
        SysConfig sysConfig = new SysConfig();
        sysConfig.setConfigKey("rongyun");
        SysConfig rySysConfig = sysConfigMapper.selectConfig(sysConfig);
        String url = rySysConfig.getConfigValue() + "/group/create.json";
        String appKey = redisCache.getCacheObject("sys_config:RongCloudAppKey");
        String appSecret = redisCache.getCacheObject("sys_config:RongCloudAppSecret");
        Map<String, Object> groupMap = createGroupChat(url, appSecret, appKey,group.getUserId(),group.getGroupId(),group.getGroupName());
        Integer code = (Integer) groupMap.get("code");
        if (code.equals(200)) {
            ArdRongGroup ardRongGroup = new ArdRongGroup();
@@ -116,6 +130,53 @@
        return AjaxResult.success(groupMap);
    }

    public Map<String,Object> createGroupChat(String url,String AppSecret,String AppKey,List<String> usersIdList,String groupId,String groupName){
        OkHttpClient okHttpClient = new OkHttpClient();
        FormBody.Builder builder = new FormBody.Builder();
        for(String usersId : usersIdList){
            builder.add("userId", usersId);
        }

        RequestBody formBody = builder.add("groupId", groupId)
                .add("groupName", groupName).build();

        String Nonce = String.valueOf(Math.random()).split("\\.")[1];
        String Timestamp = String.valueOf(new Date().getTime());
        String Signature = DigestUtils.sha1Hex(AppSecret + Nonce + Timestamp);//App Secret + Nonce + T
        /*System.out.println(Nonce);
        System.out.println(Timestamp);
        System.out.println(AppSecret + Nonce + Timestamp);
        System.out.println(Signature);*/

        Request request = new Request.Builder().url(url).post(formBody)
                .addHeader("Host","api-cn.ronghub.com")
                .addHeader("App-Key", AppKey)
                .addHeader("Nonce", Nonce)
                .addHeader("Timestamp", Timestamp)
                .addHeader("Signature", Signature)
                .addHeader("Content-Type", "application/x-www-form-urlencoded").build();

        Response response = null;
        try {
            response = okHttpClient.newCall(request).execute();
        } catch (IOException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        }

        ResponseBody responseBody = response.body();

        try {
            String message = responseBody.string();
            Map<String,Object> result = (Map<String, Object>) JSON.parse(message);
            return result;
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return new HashMap();
        }
    }

    @Override
    public AjaxResult groupDismiss(RongCloudGroupDisParam groupDis) {
        Map<String, Object> groupMap = rongCloudClient.groupDismiss(getRongCloudHead(), groupDis);