优化：流媒体同步任务

liusuyi

2024-07-10 016aa105789fca71e86cdbb0d26a181812f200f9

 ard-work/src/main/java/com/ruoyi/call/service/impl/ArdCallGroupUserServiceImpl.java

@@ -4,6 +4,8 @@
import java.util.List;

import com.ruoyi.call.domain.ArdCallGroup;
import com.ruoyi.call.domain.ArdCallSessionUser;
import com.ruoyi.call.mapper.ArdCallSessionUserMapper;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.utils.DateUtils;

@@ -36,6 +38,8 @@
    private ArdCallGroupUserMapper ardCallGroupUserMapper;
    @Resource
    private SysUserMapper sysUserMapper;
    @Resource
    private ArdCallSessionUserMapper ardCallSessionUserMapper;

    /**
     * 查询群组用户中间
@@ -130,6 +134,19 @@
            ardCallGroupUser.setCreateTime(DateUtils.getNowDate());
            ardCallGroupUser.setUserId(userId);
            ardCallGroupUserMapper.insertArdCallGroupUser(ardCallGroupUser);
            //邀请成员成功后创建session
            //通过群id获取群session
            String sessionId = ardCallSessionUserMapper.getGroupSessionId("1", id);
            if (StringUtils.isNotEmpty(sessionId)) {
                ArdCallSessionUser ardCallSessionUser = new ArdCallSessionUser();
                ardCallSessionUser.setId(IdUtils.simpleUUID());
                ardCallSessionUser.setType("1");
                ardCallSessionUser.setSessionId(sessionId);
                ardCallSessionUser.setUserId(userId);
                ardCallSessionUser.setTargetId(id);
                ardCallSessionUser.setCreateTime(DateUtils.getNowDate());
                ardCallSessionUserMapper.insertArdCallSessionUser(ardCallSessionUser);
            }
        });
        return userIds.length;
    }
@@ -151,7 +168,7 @@
        //获取平台所有用户
        List<SysUser> userList = sysUserMapper.selectUserList(new SysUser());
        //获取群组内用户
        ArdCallGroupUser ardCallGroupUser=new ArdCallGroupUser();
        ArdCallGroupUser ardCallGroupUser = new ArdCallGroupUser();
        ardCallGroupUser.setGroupId(groupId);
        List<ArdCallGroupUser> ardCallGroupUsers = ardCallGroupUserMapper.selectArdCallGroupUserList(ardCallGroupUser);
        // 提取groupList中的userId到一个Set中