增加：群聊业务

liusuyi

2024-07-06 0ab014198a8b4e40fa26da394373a4bcdb571148

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
package com.ruoyi.call.service.impl;
 
import java.util.Collections;
import java.util.List;
 
import com.ruoyi.call.compare.ArdCallSessionUserComparator;
import com.ruoyi.call.domain.ArdCallGroupUser;
import com.ruoyi.call.domain.ArdCallHistory;
import com.ruoyi.call.domain.ArdCallUnreadMessages;
import com.ruoyi.call.mapper.ArdCallGroupUserMapper;
import com.ruoyi.call.mapper.ArdCallHistoryMapper;
import com.ruoyi.call.mapper.ArdCallUnreadMessagesMapper;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.uuid.IdUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
 
import java.util.ArrayList;
import java.util.stream.Collectors;
 
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.call.mapper.ArdCallSessionUserMapper;
import com.ruoyi.call.domain.ArdCallSessionUser;
import com.ruoyi.call.service.IArdCallSessionUserService;
 
import javax.annotation.Resource;
 
/**
 * 会话用户中间表Service业务层处理
 *
 * @author ard
 * @date 2024-07-04
 */
@Service
public class ArdCallSessionUserServiceImpl implements IArdCallSessionUserService {
    @Resource
    private ArdCallSessionUserMapper ardCallSessionUserMapper;
    @Resource
    private ArdCallHistoryMapper ardCallHistoryMapper;
    @Resource
    private ArdCallSessionUserComparator ardCallSessionUserComparator;
    @Resource
    private ArdCallUnreadMessagesMapper ardCallUnreadMessagesMapper;
 
    /**
     * 查询会话用户中间表
     *
     * @param id 会话用户中间表主键
     * @return 会话用户中间表
     */
    @Override
    public ArdCallSessionUser selectArdCallSessionUserById(String id) {
        return ardCallSessionUserMapper.selectArdCallSessionUserById(id);
    }
 
    /**
     * 查询会话用户中间表列表
     *
     * @param ardCallSessionUser 会话用户中间表
     * @return 会话用户中间表
     */
    @Override
    public List<ArdCallSessionUser> selectArdCallSessionUserList(ArdCallSessionUser ardCallSessionUser) {
        //获取用户的会话/未读消息数量/最后一条消息
        List<ArdCallSessionUser> ardCallSessionUsers = ardCallSessionUserMapper.selectArdCallSessionUserList(ardCallSessionUser);
        ardCallSessionUsers.stream().forEach(callSessionUser -> {
            ArdCallUnreadMessages ardCallUnreadMessages = ardCallUnreadMessagesMapper.getUnreadMessage(callSessionUser.getSessionId(), ardCallSessionUser.getUserId());
            if (ardCallUnreadMessages != null) {
                callSessionUser.setUnReadCount(ardCallUnreadMessages.getUnreadCount());
            } else {
                callSessionUser.setUnReadCount(0);
            }
            //获取最后一条消息实体
            ArdCallHistory ardCallHistory = ardCallHistoryMapper.selectLastArdCallHistory(callSessionUser.getSessionId());
            callSessionUser.setArdCallHistory(ardCallHistory);
        });
        //过滤掉没有历史记录的会话
        ardCallSessionUsers = ardCallSessionUsers.stream().filter(obj -> obj.getArdCallHistory() != null).collect(Collectors.toList());
        // 使用定义的 ardCallSessionUserComparator 进行排序
        Collections.sort(ardCallSessionUsers, ardCallSessionUserComparator);
        return ardCallSessionUsers;
    }
 
    /**
     * 新增会话用户中间表
     *
     * @param ardCallSessionUser 会话用户中间表
     * @return 结果
     */
    @Override
    public int insertArdCallSessionUser(ArdCallSessionUser ardCallSessionUser) {
        ardCallSessionUser.setId(IdUtils.simpleUUID());
        ardCallSessionUser.setCreateTime(DateUtils.getNowDate());
        return ardCallSessionUserMapper.insertArdCallSessionUser(ardCallSessionUser);
    }
 
    /**
     * 修改会话用户中间表
     *
     * @param ardCallSessionUser 会话用户中间表
     * @return 结果
     */
    @Override
    public int updateArdCallSessionUser(ArdCallSessionUser ardCallSessionUser) {
        return ardCallSessionUserMapper.updateArdCallSessionUser(ardCallSessionUser);
    }
 
    /**
     * 批量删除会话用户中间表
     *
     * @param ids 需要删除的会话用户中间表主键
     * @return 结果
     */
    @Override
    public int deleteArdCallSessionUserByIds(String[] ids) {
        return ardCallSessionUserMapper.deleteArdCallSessionUserByIds(ids);
    }
 
    /**
     * 删除会话用户中间表信息
     *
     * @param id 会话用户中间表主键
     * @return 结果
     */
    @Override
    public int deleteArdCallSessionUserById(String id) {
        return ardCallSessionUserMapper.deleteArdCallSessionUserById(id);
    }
 
 
    @Override
    public String getSessionId(String type, String userId, String targetId) {
        return ardCallSessionUserMapper.getSessionId(type, userId, targetId);
    }
 
    @Override
    public int deleteArdCallSessionUserBySessionId(String sessionId) {
        return ardCallSessionUserMapper.deleteArdCallSessionUserBySessionId(sessionId);
    }
 
    @Override
    public String getGroupSessionId(String type, String targetId) {
        return ardCallSessionUserMapper.getGroupSessionId(type, targetId);
    }
 
}