package com.ruoyi.call.service.impl;

import java.util.Arrays;
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;

import com.ruoyi.common.utils.uuid.IdUtils;
import com.ruoyi.system.mapper.SysUserMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Set;
import java.util.stream.Collectors;

import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.call.mapper.ArdCallGroupUserMapper;
import com.ruoyi.call.domain.ArdCallGroupUser;
import com.ruoyi.call.service.IArdCallGroupUserService;

import javax.annotation.Resource;

/**
 * 群组用户中间Service业务层处理
 *
 * @author ard
 * @date 2024-07-03
 */
@Service
public class ArdCallGroupUserServiceImpl implements IArdCallGroupUserService {
    @Resource
    private ArdCallGroupUserMapper ardCallGroupUserMapper;
    @Resource
    private SysUserMapper sysUserMapper;
    @Resource
    private ArdCallSessionUserMapper ardCallSessionUserMapper;

    /**
     * 查询群组用户中间
     *
     * @param id 群组用户中间主键
     * @return 群组用户中间
     */
    @Override
    public ArdCallGroupUser selectArdCallGroupUserById(String id) {
        return ardCallGroupUserMapper.selectArdCallGroupUserById(id);
    }

    /**
     * 查询群组用户中间列表
     *
     * @param ardCallGroupUser 群组用户中间
     * @return 群组用户中间
     */
    @Override
    public List<ArdCallGroupUser> selectArdCallGroupUserList(ArdCallGroupUser ardCallGroupUser) {
        return ardCallGroupUserMapper.selectArdCallGroupUserList(ardCallGroupUser);
    }

    /**
     * 新增群组用户中间
     *
     * @param ardCallGroupUser 群组用户中间
     * @return 结果
     */
    @Override
    public int insertArdCallGroupUser(ArdCallGroupUser ardCallGroupUser) {
        ardCallGroupUser.setId(IdUtils.simpleUUID());
        ardCallGroupUser.setUserId(SecurityUtils.getUserId());
        ardCallGroupUser.setCreateBy(SecurityUtils.getUsername());
        ardCallGroupUser.setCreateTime(DateUtils.getNowDate());
        return ardCallGroupUserMapper.insertArdCallGroupUser(ardCallGroupUser);
    }

    /**
     * 修改群组用户中间
     *
     * @param ardCallGroupUser 群组用户中间
     * @return 结果
     */
    @Override
    public int updateArdCallGroupUser(ArdCallGroupUser ardCallGroupUser) {
        ardCallGroupUser.setUpdateBy(SecurityUtils.getUsername());
        ardCallGroupUser.setUpdateTime(DateUtils.getNowDate());
        return ardCallGroupUserMapper.updateArdCallGroupUser(ardCallGroupUser);
    }

    /**
     * 批量删除群组用户中间
     *
     * @param ids 需要删除的群组用户中间主键
     * @return 结果
     */
    @Override
    public int deleteArdCallGroupUserByIds(String[] ids) {
        return ardCallGroupUserMapper.deleteArdCallGroupUserByIds(ids);
    }

    /**
     * 删除群组用户中间信息
     *
     * @param id 群组用户中间主键
     * @return 结果
     */
    @Override
    public int deleteArdCallGroupUserById(String id) {
        return ardCallGroupUserMapper.deleteArdCallGroupUserById(id);
    }

    @Override
    public List<ArdCallGroup> getGroupListByUserId(String userId) {
        return ardCallGroupUserMapper.getGroupListByUserId(userId);
    }

    /**
     * 邀请群组用户
     *
     * @param id      群组主键
     * @param userIds 群组用户数组集合
     * @return 结果
     */
    @Override
    public int addGroupUser(String id, String[] userIds) {
        ArdCallGroupUser ardCallGroupUser = new ArdCallGroupUser();
        ardCallGroupUser.setGroupId(id);
        Arrays.stream(userIds).forEach(userId -> {
            ardCallGroupUser.setId(IdUtils.simpleUUID());
            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;
    }

    /**
     * 移除群组用户
     *
     * @param id      群组主键
     * @param userIds 群组用户数组集合
     * @return 结果
     */
    @Override
    public int removeGroupUser(String id, String[] userIds) {
        return ardCallGroupUserMapper.removeGroupUser(id, userIds);
    }

    @Override
    public List<SysUser> notInGroupUsers(String groupId) {
        //获取平台所有用户
        List<SysUser> userList = sysUserMapper.selectUserList(new SysUser());
        //获取群组内用户
        ArdCallGroupUser ardCallGroupUser = new ArdCallGroupUser();
        ardCallGroupUser.setGroupId(groupId);
        List<ArdCallGroupUser> ardCallGroupUsers = ardCallGroupUserMapper.selectArdCallGroupUserList(ardCallGroupUser);
        // 提取groupList中的userId到一个Set中
        Set<String> groupUserIds = ardCallGroupUsers.stream()
                .map(ArdCallGroupUser::getUserId)
                .collect(Collectors.toSet());
        // 过滤userList，只保留那些userId不在groupUserIds中的User对象
        List<SysUser> filteredUserList = userList.stream()
                .filter(user -> !groupUserIds.contains(user.getUserId()))
                .collect(Collectors.toList());
        return filteredUserList;
    }
}