|
|
@ -42,7 +42,7 @@ public class WebrtcPrivateServiceImpl implements WebrtcPrivateService { |
|
|
@Override |
|
|
@Override |
|
|
public void call(Long uid, String mode, String offer) { |
|
|
public void call(Long uid, String mode, String offer) { |
|
|
UserSession session = SessionContext.getSession(); |
|
|
UserSession session = SessionContext.getSession(); |
|
|
log.info("发起呼叫,sid:{},uid:{}", session.getUserId(), uid); |
|
|
// log.info("发起呼叫,sid:{},uid:{}", session.getUserId(), uid);
|
|
|
// 创建webrtc会话
|
|
|
// 创建webrtc会话
|
|
|
WebrtcPrivateSession webrtcSession = new WebrtcPrivateSession(); |
|
|
WebrtcPrivateSession webrtcSession = new WebrtcPrivateSession(); |
|
|
webrtcSession.setCallerId(session.getUserId()); |
|
|
webrtcSession.setCallerId(session.getUserId()); |
|
|
@ -52,12 +52,12 @@ public class WebrtcPrivateServiceImpl implements WebrtcPrivateService { |
|
|
// 校验
|
|
|
// 校验
|
|
|
if (!imClient.isOnline(uid)) { |
|
|
if (!imClient.isOnline(uid)) { |
|
|
this.sendActMessage(webrtcSession, MessageStatus.PENDING, "未接通"); |
|
|
this.sendActMessage(webrtcSession, MessageStatus.PENDING, "未接通"); |
|
|
log.info("对方不在线,uid:{}", uid); |
|
|
// log.info("对方不在线,uid:{}", uid);
|
|
|
throw new GlobalException("对方目前不在线"); |
|
|
throw new GlobalException("对方目前不在线"); |
|
|
} |
|
|
} |
|
|
if (userStateUtils.isBusy(uid)) { |
|
|
if (userStateUtils.isBusy(uid)) { |
|
|
this.sendActMessage(webrtcSession, MessageStatus.PENDING, "未接通"); |
|
|
this.sendActMessage(webrtcSession, MessageStatus.PENDING, "未接通"); |
|
|
log.info("对方正忙,uid:{}", uid); |
|
|
// log.info("对方正忙,uid:{}", uid);
|
|
|
throw new GlobalException("对方正忙"); |
|
|
throw new GlobalException("对方正忙"); |
|
|
} |
|
|
} |
|
|
// 保存rtc session
|
|
|
// 保存rtc session
|
|
|
@ -88,7 +88,7 @@ public class WebrtcPrivateServiceImpl implements WebrtcPrivateService { |
|
|
@Override |
|
|
@Override |
|
|
public void accept(Long uid, @RequestBody String answer) { |
|
|
public void accept(Long uid, @RequestBody String answer) { |
|
|
UserSession session = SessionContext.getSession(); |
|
|
UserSession session = SessionContext.getSession(); |
|
|
log.info("接受通话,sid:{},uid:{}", session.getUserId(), uid); |
|
|
// log.info("接受通话,sid:{},uid:{}", session.getUserId(), uid);
|
|
|
// 查询webrtc会话
|
|
|
// 查询webrtc会话
|
|
|
WebrtcPrivateSession webrtcSession = getWebrtcSession(session.getUserId(), uid); |
|
|
WebrtcPrivateSession webrtcSession = getWebrtcSession(session.getUserId(), uid); |
|
|
// 更新接受者信息
|
|
|
// 更新接受者信息
|
|
|
@ -118,7 +118,7 @@ public class WebrtcPrivateServiceImpl implements WebrtcPrivateService { |
|
|
@Override |
|
|
@Override |
|
|
public void reject(Long uid) { |
|
|
public void reject(Long uid) { |
|
|
UserSession session = SessionContext.getSession(); |
|
|
UserSession session = SessionContext.getSession(); |
|
|
log.info("拒绝通话,sid:{},uid:{}", session.getUserId(), uid); |
|
|
// log.info("拒绝通话,sid:{},uid:{}", session.getUserId(), uid);
|
|
|
// 查询webrtc会话
|
|
|
// 查询webrtc会话
|
|
|
WebrtcPrivateSession webrtcSession = getWebrtcSession(session.getUserId(), uid); |
|
|
WebrtcPrivateSession webrtcSession = getWebrtcSession(session.getUserId(), uid); |
|
|
// 删除会话信息
|
|
|
// 删除会话信息
|
|
|
@ -148,7 +148,7 @@ public class WebrtcPrivateServiceImpl implements WebrtcPrivateService { |
|
|
@Override |
|
|
@Override |
|
|
public void cancel(Long uid) { |
|
|
public void cancel(Long uid) { |
|
|
UserSession session = SessionContext.getSession(); |
|
|
UserSession session = SessionContext.getSession(); |
|
|
log.info("取消通话,sid:{},uid:{}", session.getUserId(), uid); |
|
|
// log.info("取消通话,sid:{},uid:{}", session.getUserId(), uid);
|
|
|
// 查询webrtc会话
|
|
|
// 查询webrtc会话
|
|
|
WebrtcPrivateSession webrtcSession = getWebrtcSession(session.getUserId(), uid); |
|
|
WebrtcPrivateSession webrtcSession = getWebrtcSession(session.getUserId(), uid); |
|
|
// 删除会话信息
|
|
|
// 删除会话信息
|
|
|
@ -177,7 +177,7 @@ public class WebrtcPrivateServiceImpl implements WebrtcPrivateService { |
|
|
@Override |
|
|
@Override |
|
|
public void failed(Long uid, String reason) { |
|
|
public void failed(Long uid, String reason) { |
|
|
UserSession session = SessionContext.getSession(); |
|
|
UserSession session = SessionContext.getSession(); |
|
|
log.info("通话失败,sid:{},uid:{},reason:{}", session.getUserId(), uid, reason); |
|
|
// log.info("通话失败,sid:{},uid:{},reason:{}", session.getUserId(), uid, reason);
|
|
|
// 查询webrtc会话
|
|
|
// 查询webrtc会话
|
|
|
WebrtcPrivateSession webrtcSession = getWebrtcSession(session.getUserId(), uid); |
|
|
WebrtcPrivateSession webrtcSession = getWebrtcSession(session.getUserId(), uid); |
|
|
// 删除会话信息
|
|
|
// 删除会话信息
|
|
|
@ -208,7 +208,7 @@ public class WebrtcPrivateServiceImpl implements WebrtcPrivateService { |
|
|
@Override |
|
|
@Override |
|
|
public void handup(Long uid) { |
|
|
public void handup(Long uid) { |
|
|
UserSession session = SessionContext.getSession(); |
|
|
UserSession session = SessionContext.getSession(); |
|
|
log.info("挂断通话,sid:{},uid:{}", session.getUserId(), uid); |
|
|
// log.info("挂断通话,sid:{},uid:{}", session.getUserId(), uid);
|
|
|
// 查询webrtc会话
|
|
|
// 查询webrtc会话
|
|
|
WebrtcPrivateSession webrtcSession = getWebrtcSession(session.getUserId(), uid); |
|
|
WebrtcPrivateSession webrtcSession = getWebrtcSession(session.getUserId(), uid); |
|
|
// 删除会话信息
|
|
|
// 删除会话信息
|
|
|
|