package cn.iocoder.yudao.module.im.service.websocket.notification.rtc;
|
|
import cn.iocoder.yudao.module.im.dal.dataobject.rtc.ImRtcCallDO;
|
import cn.iocoder.yudao.module.im.enums.rtc.ImRtcParticipantStatusEnum;
|
import cn.iocoder.yudao.module.system.api.user.dto.AdminUserRespDTO;
|
import lombok.Data;
|
|
import java.util.Collection;
|
import java.util.List;
|
|
/**
|
* RTC_CALL 通话信令通知（通话信令统一入口）
|
* <p>
|
* 不入库；走 imWebSocketService 仅推参与方
|
* <p>
|
* status 字段复用 {@link ImRtcParticipantStatusEnum}，表达「本次信令对应的参与者状态变迁」
|
*
|
* @author 芋道源码
|
*/
|
@Data
|
public class ImRtcCallNotification {
|
|
/**
|
* 信令对应的参与者状态
|
*
|
* 取值参见 {@link ImRtcParticipantStatusEnum}
|
*/
|
private Integer status;
|
|
/**
|
* 业务通话编号
|
*/
|
private String room;
|
/**
|
* 会话类型
|
*/
|
private Integer conversationType;
|
/**
|
* 媒体类型
|
*/
|
private Integer mediaType;
|
/**
|
* 群编号：群通话场景必填
|
*/
|
private Long groupId;
|
|
// ========== INVITE 专属字段 ==========
|
|
/**
|
* LiveKit Server WebSocket 地址；INVITE 专属
|
*/
|
private String livekitUrl;
|
/**
|
* 该被叫专属的 LiveKit 接听 Token；接通后直接 connect 用；INVITE 专属
|
*/
|
private String token;
|
/**
|
* 发起人用户编号；INVITE 专属
|
*/
|
private Long inviterUserId;
|
/**
|
* 发起人昵称；INVITE 专属，前端来电界面展示
|
*/
|
private String inviterNickname;
|
/**
|
* 发起人头像；INVITE 专属，前端来电界面展示
|
*/
|
private String inviterAvatar;
|
/**
|
* 本次被邀请人列表；INVITE 专属，前端来电界面展示「邀请的其他人」
|
*
|
* 注意：包含收件人自身，前端按需过滤
|
*/
|
private List<Long> inviteeIds;
|
|
// ========== REJECT 专属字段 ==========
|
|
/**
|
* 操作者用户编号；REJECT 触发本次状态变迁的人
|
*/
|
private Long operatorUserId;
|
/**
|
* 操作者昵称；前端按需展示（被某某拒接）；普通文案不依赖
|
*/
|
private String operatorNickname;
|
/**
|
* 操作者头像；前端按需展示；普通文案不依赖
|
*/
|
private String operatorAvatar;
|
|
/**
|
* 构造 INVITE 信令；推被邀请人，invitee 状态变为 INVITING
|
*
|
* @param call 通话主表
|
* @param inviter 发起人；可空，缺失时 inviterNickname / inviterAvatar 留空
|
* @param livekitUrl LiveKit Server WebSocket 地址
|
* @param token 被叫的接听 Token；按收件人单独签发
|
* @param inviteeIds 本次被邀请人列表；前端来电界面展示「邀请的其他人」用
|
* @return INVITE 信令
|
*/
|
public static ImRtcCallNotification ofInvite(ImRtcCallDO call, AdminUserRespDTO inviter,
|
String livekitUrl, String token,
|
Collection<Long> inviteeIds) {
|
ImRtcCallNotification notification = baseOf(call, ImRtcParticipantStatusEnum.INVITING.getStatus());
|
notification.livekitUrl = livekitUrl;
|
notification.token = token;
|
notification.inviterUserId = call.getInviterUserId();
|
if (inviter != null) {
|
notification.inviterNickname = inviter.getNickname();
|
notification.inviterAvatar = inviter.getAvatar();
|
}
|
notification.inviteeIds = inviteeIds != null ? new java.util.ArrayList<>(inviteeIds) : null;
|
return notification;
|
}
|
|
/**
|
* 构造 REJECT 信令；仅群通话场景；推主叫
|
*
|
* @param call 通话主表
|
* @param operatorUserId 拒接者用户编号
|
* @param operator 拒接者；可空，缺失时 operatorNickname / operatorAvatar 留空
|
* @return REJECT 信令
|
*/
|
public static ImRtcCallNotification ofReject(ImRtcCallDO call, Long operatorUserId, AdminUserRespDTO operator) {
|
ImRtcCallNotification notification = baseOf(call, ImRtcParticipantStatusEnum.REJECTED.getStatus());
|
notification.operatorUserId = operatorUserId;
|
if (operator != null) {
|
notification.operatorNickname = operator.getNickname();
|
notification.operatorAvatar = operator.getAvatar();
|
}
|
return notification;
|
}
|
|
/**
|
* 构造 NO_ANSWER 信令；仅群通话场景；推主叫；超时未接听语义独立于 REJECT
|
*
|
* @param call 通话主表
|
* @param operatorUserId 未接听者用户编号
|
* @param operator 未接听者；可空，缺失时 operatorNickname / operatorAvatar 留空
|
* @return NO_ANSWER 信令
|
*/
|
public static ImRtcCallNotification ofNoAnswer(ImRtcCallDO call, Long operatorUserId, AdminUserRespDTO operator) {
|
ImRtcCallNotification notification = baseOf(call, ImRtcParticipantStatusEnum.NO_ANSWER.getStatus());
|
notification.operatorUserId = operatorUserId;
|
if (operator != null) {
|
notification.operatorNickname = operator.getNickname();
|
notification.operatorAvatar = operator.getAvatar();
|
}
|
return notification;
|
}
|
|
/**
|
* 公共骨架；填充 call 上下文 + status
|
*/
|
private static ImRtcCallNotification baseOf(ImRtcCallDO call, Integer status) {
|
ImRtcCallNotification notification = new ImRtcCallNotification();
|
notification.status = status;
|
notification.room = call.getRoom();
|
notification.conversationType = call.getConversationType();
|
notification.mediaType = call.getMediaType();
|
notification.groupId = call.getGroupId();
|
return notification;
|
}
|
|
}
|
