分支自 ard/ruoyi-api
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
zhangnaisong
2024-05-17 6bddb83b1e7556aa9b2b1d4ce7ed5f4b4c62f2d0 
 ard-work/src/main/java/com/ruoyi/rongcloud/service/Impl/RongCloudServiceImpl.java


@@ -1,7 +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;


@@ -10,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.*;




@@ -42,7 +49,8 @@


    private ArdRongGroupUserMapper ardRongGroupUserMapper;


    @Resource


    private SysUserMapper sysUserMapper;




    @Resource


    private SysConfigMapper sysConfigMapper;




    /**


     * 获取融云token


@@ -61,8 +69,9 @@


            Map<String, Object> map = rongCloudClient.getToken(getRongCloudHead(), param);


            token = (String) map.get("token");


            log.debug("用户" + userId + "获取到融云token:" + token);


        } catch (Exception ex) {


            log.error("获取token异常:" + ex.getMessage());


        }catch(ForestRuntimeException ex)


        {


            log.error("获取融云token异常:" + ex.getMessage());


        }


        return token;


    }


@@ -90,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();


@@ -112,6 +128,53 @@


        groupMap.put("groupId", group.getGroupId());


        groupMap.put("group", group.getGroupName());


        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


@@ -164,9 +227,14 @@


        Map<String, Object> groupMap = rongCloudClient.groupQuit(getRongCloudHead(), groupParam);


        Integer code = (Integer) groupMap.get("code");


        if (code.equals(200)) {


            ArdRongGroup ardRongGroup = ardRongGroupMapper.selectById(groupParam.getGroupId());


            ardRongGroup.setGroupName(groupParam.getGroupName());


            ardRongGroupMapper.updateById(ardRongGroup);


            List<String> list = groupParam.getUserId();


            for (int i = 0; i < list.size(); i++) {


                String userId = list.get(i);


                QueryWrapper<ArdRongGroupUser> queryWrapper = new QueryWrapper<>();


                queryWrapper.eq("group_id",groupParam.getGroupId())


                        .eq("user_id",userId);


                ardRongGroupUserMapper.delete(queryWrapper);


            }


        }


        groupMap.put("groupId", groupParam.getGroupId());


        groupMap.put("groupName", groupParam.getGroupName());


@@ -194,16 +262,16 @@


        Map<String, Object> groupMap = rongCloudClient.groupRefresh(getRongCloudHead(), groupParam);


        Integer code = (Integer) groupMap.get("code");


        if (code.equals(200)) {


            List<String> userList = groupParam.getUserId();


            for (int i = 0; i < userList.size(); i++) {


                QueryWrapper<ArdRongGroupUser> queryWrapper = new QueryWrapper<>();


                queryWrapper.eq("user_id", groupParam.getGroupId())


                        .eq("group_id", groupParam.getUserId());


                ardRongGroupUserMapper.delete(queryWrapper);


            }


            String groupId = groupParam.getGroupId();


            String groupName = groupParam.getGroupName();


            QueryWrapper<ArdRongGroup> queryWrapper = new QueryWrapper<>();


            queryWrapper.eq("group_id",groupId);


            ArdRongGroup ardRongGroup = ardRongGroupMapper.selectOne(queryWrapper);


            ardRongGroup.setGroupName(groupName);


            ardRongGroupMapper.updateById(ardRongGroup);


        }


        groupMap.put("groupId", groupParam.getGroupId());


        groupMap.put("userId", groupParam.getUserId());


        groupMap.put("groupName", groupParam.getGroupName());


        return AjaxResult.success(groupMap);


    }




@@ -238,7 +306,9 @@


    @Override


    public AjaxResult groupInfo(String groupId) {


        Map<String,Object> map = new HashMap<>();


        ArdRongGroup ardRongGroup = ardRongGroupMapper.selectById(groupId);


        QueryWrapper<ArdRongGroup> ardRongGroupQueryWrapper = new QueryWrapper<>();


        ardRongGroupQueryWrapper.eq("group_id",groupId);


        ArdRongGroup ardRongGroup = ardRongGroupMapper.selectOne(ardRongGroupQueryWrapper);


        map.put("group",ardRongGroup);


        QueryWrapper<ArdRongGroupUser> queryWrapper = new QueryWrapper<>();


        queryWrapper.eq("group_id",groupId);


@@ -257,14 +327,18 @@


    public AjaxResult groupUserAll(String groupId) {


        ArdRongGroup ardRongGroup = ardRongGroupMapper.selectById(groupId);


        QueryWrapper<ArdRongGroupUser> queryWrapper = new QueryWrapper<>();


        queryWrapper.eq("group_id",groupId);


        queryWrapper.eq("group_id",ardRongGroup.getGroupId());


        List<ArdRongGroupUser> list = ardRongGroupUserMapper.selectList(queryWrapper);


        List<String> userList = new ArrayList<>();


        for (int i = 0; i < list.size(); i++) {


            userList.add(list.get(i).getUserId());


        }


        QueryWrapper<SysUser> queryWrapper1 = new QueryWrapper<>();


        queryWrapper1.notIn("user_id",userList);


        if(userList.size()>0){


            queryWrapper1.notIn("user_id",userList).eq("del_flag","0");


        }else {


            queryWrapper1.eq("del_flag","0");


        }


        List<SysUser> sysUsers = sysUserMapper.selectList(queryWrapper1);


        return AjaxResult.success(sysUsers);


    }