1597 lines
42 KiB
JavaScript
1597 lines
42 KiB
JavaScript
|
/**
|
|||
|
|
* @file liveroom.js 直播模式房间管理sdk
|
|||
|
|
* @author binniexu
|
|||
|
|
*/
|
|||
|
|
var webim = require('./webim_wx.js');
|
|||
|
|
var webimhandler = require('./webim_handler.js');
|
|||
|
|
|
|||
|
|
|
|||
|
|
//移动直播（<mlvb-live-room>）使用此地址实现房间服务和连麦功能
|
|||
|
|
var RoomServiceUrl = "https://liveroom.qcloud.com/weapp/live_room/",
|
|||
|
|
|
|||
|
|
heart = '', // 判断心跳变量
|
|||
|
|
requestSeq = 0, // 请求id
|
|||
|
|
requestTask = [], // 请求task
|
|||
|
|
// 用户信息
|
|||
|
|
accountInfo = {
|
|||
|
|
userID: '', // 用户ID
|
|||
|
|
userName: '', // 用户昵称
|
|||
|
|
userAvatar: '', // 用户头像URL
|
|||
|
|
userSig: '', // IM登录凭证
|
|||
|
|
sdkAppID: '', // IM应用ID
|
|||
|
|
accountType: '', // 账号集成类型
|
|||
|
|
accountMode: 0, //帐号模式，0-表示独立模式，1-表示托管模式
|
|||
|
|
token: '' //登录RoomService后使用的票据
|
|||
|
|
},
|
|||
|
|
// 房间信息
|
|||
|
|
roomInfo = {
|
|||
|
|
roomID: '', // 视频位房间ID
|
|||
|
|
roomInfo: '', // 房间名称
|
|||
|
|
mixedPlayURL: '', // 混流地址
|
|||
|
|
isCreator: false, // 是否为创建者
|
|||
|
|
pushers: [], // 当前用户信息
|
|||
|
|
isLoginIM: false, // 是否登录IM
|
|||
|
|
isJoinGroup: false, // 是否加入群
|
|||
|
|
isDestory: false, // 是否已解散
|
|||
|
|
hasJoinAnchor: false,
|
|||
|
|
roomStatusCode: 0
|
|||
|
|
},
|
|||
|
|
// 事件
|
|||
|
|
event = {
|
|||
|
|
onAnchorEnter: function () {}, // 进房通知
|
|||
|
|
onAnchorExit: function () {}, // 退房通知
|
|||
|
|
onRoomDestroy: function() {}, // 群解散通知
|
|||
|
|
onRecvRoomTextMsg: function() {}, // 消息通知
|
|||
|
|
onRequestJoinAnchor: function() {}, //大主播收到小主播连麦请求通知
|
|||
|
|
onKickoutJoinAnchor: function() {}, //小主播被踢通知
|
|||
|
|
onRecvRoomCustomMsg: function() {}, //自定义消息通知
|
|||
|
|
onSketchpadData: function(){}
|
|||
|
|
};
|
|||
|
|
// 随机昵称
|
|||
|
|
var userName = ['林静晓', '陆杨', '江辰', '付小司', '陈小希', '吴柏松', '肖奈', '芦苇微微', '一笑奈何', '立夏'];
|
|||
|
|
// 请求数
|
|||
|
|
var requestNum = 0;
|
|||
|
|
var requestJoinCallback = null;
|
|||
|
|
var bigAnchorStreamID = '';
|
|||
|
|
var bigAnchorWidth = 360;
|
|||
|
|
var bigAnchorHeight = 640;
|
|||
|
|
var gTimeoutID = null;
|
|||
|
|
var mTimeDiff = 0;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [request 封装request请求]
|
|||
|
|
* @param {options}
|
|||
|
|
* url: 请求接口url
|
|||
|
|
* data: 请求参数
|
|||
|
|
* success: 成功回调
|
|||
|
|
* fail: 失败回调
|
|||
|
|
* complete: 完成回调
|
|||
|
|
*/
|
|||
|
|
function request(options) {
|
|||
|
|
requestNum++;
|
|||
|
|
console.log('requestNum: ', requestNum);
|
|||
|
|
requestTask[requestSeq++] = wx.request({
|
|||
|
|
url: RoomServiceUrl + options.url + (options.params?('?' + formatParams(options.params) + '&'):'?') + 'userID=' + accountInfo.userID + (accountInfo.token?'&token=' + accountInfo.token:""),
|
|||
|
|
data: options.data || {},
|
|||
|
|
method: 'POST',
|
|||
|
|
header: {
|
|||
|
|
'content-type': 'application/json' // 默认值
|
|||
|
|
},
|
|||
|
|
// dataType: 'json',
|
|||
|
|
success: options.success || function() {},
|
|||
|
|
fail: options.fail || function() {},
|
|||
|
|
complete: options.complete || function() {
|
|||
|
|
requestNum--;
|
|||
|
|
// console.log('complete requestNum: ',requestNum);
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//url encode编码
|
|||
|
|
function formatParams(data) {
|
|||
|
|
var arr = [];
|
|||
|
|
for (var name in data) {
|
|||
|
|
arr.push(encodeURIComponent(name) + "=" + encodeURIComponent(data[name]));
|
|||
|
|
}
|
|||
|
|
return arr.join("&");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [login 初始化登录信息]
|
|||
|
|
* @param {options}
|
|||
|
|
* data: {
|
|||
|
|
* userID: 用户ID
|
|||
|
|
* userSig: 用户sig
|
|||
|
|
* sdkAppID: IM应用ID
|
|||
|
|
* userName: 用户昵称
|
|||
|
|
* userAvatar: 用户头像地址
|
|||
|
|
* }
|
|||
|
|
* success: 成功回调
|
|||
|
|
* fail: 失败回调
|
|||
|
|
*
|
|||
|
|
* @return success
|
|||
|
|
* userName: 用户昵称
|
|||
|
|
*/
|
|||
|
|
function login(options) {
|
|||
|
|
if (!options || !options.data.sdkAppID || !options.data.userID || !options.data.userSig) {
|
|||
|
|
console.log('init参数错误',options);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: -9,
|
|||
|
|
errMsg: 'init参数错误'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
accountInfo.userID = options.data.userID;
|
|||
|
|
accountInfo.userSig = options.data.userSig;
|
|||
|
|
accountInfo.sdkAppID = options.data.sdkAppID;
|
|||
|
|
accountInfo.userName = options.data.userName || userName[Math.floor(Math.random()*10)] || accountInfo.userID;
|
|||
|
|
accountInfo.userAvatar = options.data.userAvatar || '123';
|
|||
|
|
|
|||
|
|
request({
|
|||
|
|
url: 'login',
|
|||
|
|
params: {
|
|||
|
|
accountType: '0',
|
|||
|
|
sdkAppID: accountInfo.sdkAppID,
|
|||
|
|
userSig: accountInfo.userSig,
|
|||
|
|
platform: "WeChat"
|
|||
|
|
},
|
|||
|
|
data: {},
|
|||
|
|
success: function(ret) {
|
|||
|
|
if (ret.data.code) {
|
|||
|
|
console.error("登录到RoomService后台失败:", JSON.stringify(ret));
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: ret.data.code,
|
|||
|
|
errMsg: ret.data.message
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
accountInfo.token = ret.data.token;
|
|||
|
|
accountInfo.userID = ret.data.userID;
|
|||
|
|
mTimeDiff = Math.round(Date.now()) - ret.data.timestamp;
|
|||
|
|
// // 登录IM
|
|||
|
|
// loginIM({
|
|||
|
|
// success: function(ret) {
|
|||
|
|
// options.success && options.success({
|
|||
|
|
// userID: accountInfo.userID,
|
|||
|
|
// userName: accountInfo.userName
|
|||
|
|
// });
|
|||
|
|
// },
|
|||
|
|
// fail: function(ret) {
|
|||
|
|
// console.error("IM登录失败:", JSON.stringify(ret));
|
|||
|
|
// options.fail && options.fail({
|
|||
|
|
// errCode: -999,
|
|||
|
|
// errMsg: "IM登录失败"
|
|||
|
|
// });
|
|||
|
|
// }
|
|||
|
|
// });
|
|||
|
|
},
|
|||
|
|
fail: function(ret) {
|
|||
|
|
console.error("登录到RoomService后台失败:", JSON.stringify(ret));
|
|||
|
|
options.fail && options.fail(ret);
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [logout 结束初始化信息]
|
|||
|
|
*/
|
|||
|
|
function logout() {
|
|||
|
|
request({
|
|||
|
|
url: "logout",
|
|||
|
|
success: function(ret){},
|
|||
|
|
fail: function(ret){}
|
|||
|
|
});
|
|||
|
|
accountInfo.userID = '';
|
|||
|
|
accountInfo.userSig = '';
|
|||
|
|
accountInfo.sdkAppID = '';
|
|||
|
|
accountInfo.userName = '';
|
|||
|
|
accountInfo.userAvatar = '';
|
|||
|
|
accountInfo.token = '';
|
|||
|
|
// 退出IM登录
|
|||
|
|
webimhandler.logout();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [loginIM 登录IM]
|
|||
|
|
* @param {options}
|
|||
|
|
* data: {
|
|||
|
|
* roomID: 房间ID
|
|||
|
|
* }
|
|||
|
|
* success: 成功回调
|
|||
|
|
* fail: 失败回调
|
|||
|
|
*/
|
|||
|
|
function loginIM(options) {
|
|||
|
|
// 初始化设置参数
|
|||
|
|
webimhandler.init({
|
|||
|
|
accountMode: accountInfo.accountMode,
|
|||
|
|
accountType: '0',
|
|||
|
|
sdkAppID: accountInfo.sdkAppID,
|
|||
|
|
avChatRoomId: options.roomID || 0,
|
|||
|
|
selType: webim.SESSION_TYPE.GROUP,
|
|||
|
|
selToID: options.roomID || 0,
|
|||
|
|
selSess: null //当前聊天会话
|
|||
|
|
});
|
|||
|
|
//当前用户身份
|
|||
|
|
var loginInfo = {
|
|||
|
|
'sdkAppID': accountInfo.sdkAppID, //用户所属应用id,必填
|
|||
|
|
'appIDAt3rd': accountInfo.sdkAppID, //用户所属应用id，必填
|
|||
|
|
'accountType': "0", //用户所属应用帐号类型，填0
|
|||
|
|
'identifier': accountInfo.userID, //当前用户ID,必须是否字符串类型，选填
|
|||
|
|
'identifierNick': accountInfo.userID, //当前用户昵称，选填
|
|||
|
|
'userSig': accountInfo.userSig, //当前用户身份凭证，必须是字符串类型，选填
|
|||
|
|
};
|
|||
|
|
//监听（多终端同步）群系统消息方法，方法都定义在demo_group_notice.js文件中
|
|||
|
|
var onGroupSystemNotifys = {
|
|||
|
|
// 群被解散(全员接收)
|
|||
|
|
"5": function (notify) {
|
|||
|
|
roomInfo.isDestory = true;
|
|||
|
|
event.onRoomDestroy();
|
|||
|
|
},
|
|||
|
|
"11": webimhandler.onRevokeGroupNotify, //群已被回收(全员接收)
|
|||
|
|
// 用户自定义通知(默认全员接收)
|
|||
|
|
"255": function (notify) {
|
|||
|
|
// console.error('收到系统通知：', notify.UserDefinedField);
|
|||
|
|
// var content = JSON.parse(notify.UserDefinedField);
|
|||
|
|
// if (content && content.cmd == 'notifyPusherChange') {
|
|||
|
|
// mergeAnchors();
|
|||
|
|
// }
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
//监听连接状态回调变化事件
|
|||
|
|
var onConnNotify = function (resp) {
|
|||
|
|
switch (resp.ErrorCode) {
|
|||
|
|
case webim.CONNECTION_STATUS.ON:
|
|||
|
|
//webim.Log.warn('连接状态正常...');
|
|||
|
|
break;
|
|||
|
|
case webim.CONNECTION_STATUS.OFF:
|
|||
|
|
webim.Log.warn('连接已断开，无法收到新消息，请检查下你的网络是否正常');
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
webim.Log.error('未知连接状态,status=' + resp.ErrorCode);
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
//监听事件
|
|||
|
|
var listeners = {
|
|||
|
|
"onConnNotify": webimhandler.onConnNotify, //选填
|
|||
|
|
"onBigGroupMsgNotify": function (msg) {
|
|||
|
|
webimhandler.onBigGroupMsgNotify(msg, function (msgs) {
|
|||
|
|
receiveMsg(msgs);
|
|||
|
|
}, function (datas) {
|
|||
|
|
//收到白板数据
|
|||
|
|
console.log("LiveRoom callback --> 收到白板数据")
|
|||
|
|
onSketchpadData(datas);
|
|||
|
|
})
|
|||
|
|
// webimhandler.onBigGroupMsgNotify(msg, function (msgs) {
|
|||
|
|
// receiveMsg(msgs);
|
|||
|
|
// })
|
|||
|
|
}, //监听新消息(大群)事件，必填
|
|||
|
|
"onMsgNotify": function (newMsgList) { //监听新消息(私聊(包括普通消息和全员推送消息)，普通群(非直播聊天室)消息)事件，必填
|
|||
|
|
webimhandler.onMsgNotify(newMsgList, function(msg) {
|
|||
|
|
recvC2CMsg(msg);
|
|||
|
|
});
|
|||
|
|
},
|
|||
|
|
"onGroupSystemNotifys": onGroupSystemNotifys, //监听（多终端同步）群系统消息事件，必填
|
|||
|
|
"onGroupInfoChangeNotify": webimhandler.onGroupInfoChangeNotify,
|
|||
|
|
// 'onKickedEventCall': self.onKickedEventCall // 踢人操作
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
//其他对象，选填
|
|||
|
|
var others = {
|
|||
|
|
'isAccessFormalEnv': true, //是否访问正式环境，默认访问正式，选填
|
|||
|
|
'isLogOn': false //是否开启控制台打印日志,默认开启，选填
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
if (accountInfo.accountMode == 1) { //托管模式
|
|||
|
|
webimhandler.sdkLogin(loginInfo, listeners, others, 0, afterLoginIM, options);
|
|||
|
|
} else { //独立模式
|
|||
|
|
//sdk登录
|
|||
|
|
webimhandler.sdkLogin(loginInfo, listeners, others, 0, afterLoginIM, options);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
function afterLoginIM(options) {
|
|||
|
|
if (options.errCode) {
|
|||
|
|
// webim登录失败
|
|||
|
|
console.log('webim登录失败:', options);
|
|||
|
|
options.callback.fail && options.callback.fail({
|
|||
|
|
errCode: -2,
|
|||
|
|
errMsg: 'IM登录失败，如果你是在配置线上环境，请将IM域名[https://webim.tim.qq.com]配置到小程序request合法域名'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
// webim登录成功
|
|||
|
|
console.log('webim登录成功');
|
|||
|
|
roomInfo.isLoginIM = true;
|
|||
|
|
options.callback.success && options.callback.success({
|
|||
|
|
userName: accountInfo.userName
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
function afterJoinBigGroup(options) {
|
|||
|
|
if (options.errCode && options.errCode != 10025) {
|
|||
|
|
console.log('webim进群失败: ', options);
|
|||
|
|
options.callback.fail && options.callback.fail({
|
|||
|
|
errCode: -2,
|
|||
|
|
errMsg: 'IM进群失败'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
roomInfo.isJoinGroup = true;
|
|||
|
|
console.log('进入IM房间成功: ', roomInfo.roomID);
|
|||
|
|
options.callback.success && options.callback.success({});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function onSketchpadData(data){
|
|||
|
|
event.onSketchpadData(data);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [receiveMsg 接收消息处理]
|
|||
|
|
* @param {options}
|
|||
|
|
*
|
|||
|
|
* @return event.onRecvRoomTextMsg
|
|||
|
|
* roomID: 房间ID
|
|||
|
|
* userID: 用户ID
|
|||
|
|
* nickName: 用户昵称
|
|||
|
|
* headPic: 用户头像
|
|||
|
|
* textMsg: 文本消息
|
|||
|
|
* time: 消息时间
|
|||
|
|
*/
|
|||
|
|
function receiveMsg(msg) {
|
|||
|
|
if (!msg.content) {
|
|||
|
|
console.log('消息内容为空',msg)
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
console.log('IM消息0: ',msg);
|
|||
|
|
var time = new Date();
|
|||
|
|
var h = time.getHours()+'', m = time.getMinutes()+'', s = time.getSeconds()+'';
|
|||
|
|
h.length == 1 ? (h='0'+h) : '';
|
|||
|
|
m.length == 1 ? (m='0'+m) : '';
|
|||
|
|
s.length == 1 ? (s='0'+s) : '';
|
|||
|
|
time = h + ':' + m + ':' + s;
|
|||
|
|
msg.time = time;
|
|||
|
|
|
|||
|
|
if(msg.fromAccountNick == '@TIM#SYSTEM') {//群提示消息
|
|||
|
|
msg.fromAccountNick = '';
|
|||
|
|
msg.content = msg.content.split(';');
|
|||
|
|
msg.content = msg.content[0];
|
|||
|
|
event.onRecvRoomTextMsg && event.onRecvRoomTextMsg({
|
|||
|
|
roomID: roomInfo.roomID,
|
|||
|
|
userID: msg.fromAccountNick,
|
|||
|
|
userName: msg.userName,
|
|||
|
|
userAvatar: msg.userAvatar,
|
|||
|
|
message: msg.content,
|
|||
|
|
time: msg.time,
|
|||
|
|
nature:0//1进群
|
|||
|
|
});
|
|||
|
|
} else {
|
|||
|
|
var contentObj,newContent;
|
|||
|
|
try {
|
|||
|
|
newContent = msg.content.split('}}');
|
|||
|
|
contentObj = JSON.parse(newContent[0] + '}}');
|
|||
|
|
} catch (e) {
|
|||
|
|
console.warn("IM消息解析异常，重新按json格式解析");
|
|||
|
|
newContent = new Array(1);
|
|||
|
|
newContent[0] = msg.content;
|
|||
|
|
contentObj = JSON.parse(msg.content);
|
|||
|
|
}
|
|||
|
|
console.log('contentObj',contentObj)
|
|||
|
|
if(contentObj.cmd == 'CustomTextMsg') {//自定义发送消息
|
|||
|
|
msg.userName = contentObj.data.nickname;
|
|||
|
|
msg.userAvatar = contentObj.data.avatarurl;
|
|||
|
|
var content = '';
|
|||
|
|
for(var i = 1; i < newContent.length; i++) {
|
|||
|
|
if(i == newContent.length - 1)
|
|||
|
|
content += newContent[i];
|
|||
|
|
else content += newContent[i] + '}}';
|
|||
|
|
}
|
|||
|
|
msg.content = content;
|
|||
|
|
event.onRecvRoomTextMsg && event.onRecvRoomTextMsg({
|
|||
|
|
roomID: roomInfo.roomID,
|
|||
|
|
userID: msg.fromAccountNick,
|
|||
|
|
userName: msg.userName,
|
|||
|
|
userAvatar: msg.userAvatar,
|
|||
|
|
message: msg.content,
|
|||
|
|
time: msg.time,
|
|||
|
|
nature:contentObj.data.nature,//2//发送消息
|
|||
|
|
userid:contentObj.data.userid,
|
|||
|
|
gift_name:contentObj.data.gift_name?contentObj.data.gift_name:'',
|
|||
|
|
gift_ico:contentObj.data.gift_ico?contentObj.data.gift_ico:'',
|
|||
|
|
number:contentObj.data.number?contentObj.data.number:''
|
|||
|
|
|
|||
|
|
});
|
|||
|
|
} else if (contentObj.cmd == 'CustomCmdMsg') {//
|
|||
|
|
msg.userName = contentObj.data.nickName;
|
|||
|
|
msg.userAvatar = contentObj.data.headPic;
|
|||
|
|
msg.cmd = contentObj.data.cmd;
|
|||
|
|
var content = '';
|
|||
|
|
for(var i = 1; i < newContent.length; i++) {
|
|||
|
|
if(i == newContent.length - 1)
|
|||
|
|
content += newContent[i];
|
|||
|
|
else content += newContent[i] + '}}';
|
|||
|
|
}
|
|||
|
|
msg.content = content;
|
|||
|
|
event.onRecvRoomCustomMsg && event.onRecvRoomCustomMsg({
|
|||
|
|
roomID: roomInfo.roomID,
|
|||
|
|
userID: msg.fromAccountNick,
|
|||
|
|
userName: msg.userName,
|
|||
|
|
userAvatar: msg.userAvatar,
|
|||
|
|
cmd: msg.cmd,
|
|||
|
|
message: msg.content,
|
|||
|
|
time: msg.time,
|
|||
|
|
nature:4//未知
|
|||
|
|
});
|
|||
|
|
} else if (contentObj.cmd == 'notifyPusherChange') {
|
|||
|
|
mergeAnchors();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
function recvC2CMsg(msg) {
|
|||
|
|
console.log("收到C2C消息:", JSON.stringify(msg));
|
|||
|
|
var contentObj = JSON.parse(msg.content);
|
|||
|
|
if (contentObj) {
|
|||
|
|
if (contentObj.cmd == 'linkmic') {
|
|||
|
|
if (contentObj.data.type && contentObj.data.type == 'request') {
|
|||
|
|
event.onRequestJoinAnchor({
|
|||
|
|
userID: msg.fromAccountNick,
|
|||
|
|
userName: contentObj.data.userName,
|
|||
|
|
userAvatar: contentObj.data.userAvatar
|
|||
|
|
})
|
|||
|
|
} else if (contentObj.data.type && contentObj.data.type == 'response') {
|
|||
|
|
if (contentObj.data.result == 'accept') {
|
|||
|
|
requestJoinCallback && requestJoinCallback({
|
|||
|
|
errCode: 0,
|
|||
|
|
errMsg: ''
|
|||
|
|
});
|
|||
|
|
} else if (contentObj.data.result == 'reject') {
|
|||
|
|
requestJoinCallback && requestJoinCallback({
|
|||
|
|
errCode: -999,
|
|||
|
|
errMsg: '主播拒绝了你的请求'
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
} else if (contentObj.data.type && contentObj.data.type == 'kickout') {
|
|||
|
|
event.onKickoutJoinAnchor && event.onKickoutJoinAnchor({
|
|||
|
|
roomID: contentObj.data.roomID
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function notifyPusherChange() {
|
|||
|
|
var customMsg = {
|
|||
|
|
cmd: "notifyPusherChange",
|
|||
|
|
data: {}
|
|||
|
|
}
|
|||
|
|
var strCustomMsg = JSON.stringify(customMsg);
|
|||
|
|
webimhandler.sendCustomMsg({data:strCustomMsg, text:"notify"}, null)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function mergeAnchors() {
|
|||
|
|
if (!roomInfo.hasJoinAnchor) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
getAnchors({
|
|||
|
|
data: {
|
|||
|
|
roomID: roomInfo.roomID
|
|||
|
|
},
|
|||
|
|
success: function(ret) {
|
|||
|
|
ret = ret.data;
|
|||
|
|
|
|||
|
|
innerMergerAnchors(ret)
|
|||
|
|
},
|
|||
|
|
fail: function(ret) {
|
|||
|
|
// event.onRoomDestroy && event.onRoomDestroy({
|
|||
|
|
// errCode: ret.errCode,
|
|||
|
|
// errMsg: ret.errMsg
|
|||
|
|
// });
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
function innerMergerAnchors(data) {
|
|||
|
|
/**
|
|||
|
|
* enterPushers：新进推流人员信息
|
|||
|
|
* leavePushers：退出推流人员信息
|
|||
|
|
* ishave：用于判断去重操作
|
|||
|
|
*/
|
|||
|
|
var enterPushers = [],leavePushers = [],ishave = 0;
|
|||
|
|
console.log('去重操作');
|
|||
|
|
console.log('旧', JSON.stringify(roomInfo.pushers));
|
|||
|
|
console.log('新',JSON.stringify(data.pushers));
|
|||
|
|
console.log('用户信息:', JSON.stringify(accountInfo));
|
|||
|
|
data.pushers && data.pushers.forEach(function(val1){
|
|||
|
|
ishave = 0;
|
|||
|
|
roomInfo.pushers && roomInfo.pushers.forEach(function(val2) {
|
|||
|
|
if(val1.userID == val2.userID) {
|
|||
|
|
ishave = 1;
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
if(!ishave && val1.userID != accountInfo.userID)
|
|||
|
|
enterPushers.push(val1);
|
|||
|
|
ishave = 0;
|
|||
|
|
});
|
|||
|
|
roomInfo.pushers && roomInfo.pushers.forEach(function(val1) {
|
|||
|
|
ishave = 0;
|
|||
|
|
data.pushers && data.pushers.forEach(function(val2) {
|
|||
|
|
if(val1.userID == val2.userID) {
|
|||
|
|
ishave = 1;
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
if(!ishave)
|
|||
|
|
leavePushers.push(val1);
|
|||
|
|
ishave = 0;
|
|||
|
|
});
|
|||
|
|
if (data.roomStatusCode) {
|
|||
|
|
roomInfo.roomStatusCode = data.roomStatusCode
|
|||
|
|
}
|
|||
|
|
// 重置roomInfo.pushers
|
|||
|
|
roomInfo.pushers = data.pushers;
|
|||
|
|
// 通知有人进入房间
|
|||
|
|
if(enterPushers.length) {
|
|||
|
|
console.log('进房:', JSON.stringify(enterPushers));
|
|||
|
|
event.onAnchorEnter && event.onAnchorEnter({
|
|||
|
|
pushers: enterPushers
|
|||
|
|
});
|
|||
|
|
//混流
|
|||
|
|
mergeStream(1);
|
|||
|
|
}
|
|||
|
|
// 通知有人退出房间
|
|||
|
|
if(leavePushers.length) {
|
|||
|
|
console.log('退房:', JSON.stringify(leavePushers));
|
|||
|
|
event.onAnchorExit && event.onAnchorExit({
|
|||
|
|
pushers: leavePushers
|
|||
|
|
});
|
|||
|
|
//混流
|
|||
|
|
mergeStream(1);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
function getAnchors(object) {
|
|||
|
|
var data = {};
|
|||
|
|
if (object.data && object.data.roomID) {
|
|||
|
|
data.roomID = object.data.roomID;
|
|||
|
|
} else if (roomInfo.roomID) {
|
|||
|
|
data.roomID = roomInfo.roomID;
|
|||
|
|
} else {
|
|||
|
|
object.fail && object.fail({
|
|||
|
|
errCode: -999,
|
|||
|
|
errMsg: '无roomID'
|
|||
|
|
})
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
//获取房间信息
|
|||
|
|
request({
|
|||
|
|
url: 'get_anchors',
|
|||
|
|
data: data,
|
|||
|
|
success: function (ret) {
|
|||
|
|
if (ret.data.code) {
|
|||
|
|
console.log('请求CGI:get_anchors失败', ret);
|
|||
|
|
object.fail && object.fail({errCode: ret.data.code, errMsg: '请求CGI:get_anchors失败:' + ret.data.message + + '[' + ret.data.code + ']'});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
console.log("房间信息0：");
|
|||
|
|
console.log(ret)
|
|||
|
|
object.success && object.success(ret);
|
|||
|
|
},
|
|||
|
|
fail: object.fail
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [sendRoomTextMsg 发送文本消息]
|
|||
|
|
* @param {options}
|
|||
|
|
* data: {
|
|||
|
|
* msg: 文本消息
|
|||
|
|
* }
|
|||
|
|
*/
|
|||
|
|
function sendRoomTextMsg(options) {
|
|||
|
|
if (!options || !options.data.msg || !options.data.msg.replace(/^\s*|\s*$/g, '')) {
|
|||
|
|
console.log('sendRoomTextMsg参数错误',options);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: -9,
|
|||
|
|
errMsg: 'sendRoomTextMsg参数错误'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
console.log('sendRoomTextMsg 发送文本消息',options)
|
|||
|
|
webimhandler.sendCustomMsg({
|
|||
|
|
data: '{"cmd":"CustomTextMsg","data":{"nickname":"'+options.data.nickname+'","avatarurl":"'+options.data.avatarurl+'","nature":"'+options.data.nature+'","gift_name":"'+options.data.gift_name+'","gift_ico":"'+options.data.gift_ico+'","number":"'+options.data.number+'","userid":"'+options.data.userid+'"}}',
|
|||
|
|
text: options.data.msg
|
|||
|
|
},function() {
|
|||
|
|
options.success && options.success();
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
/*
|
|||
|
|
发送礼物
|
|||
|
|
*/
|
|||
|
|
function sendRoomGiftMsg(options) {
|
|||
|
|
if (!options || !options.data.msg || !options.data.msg.replace(/^\s*|\s*$/g, '')) {
|
|||
|
|
console.log('sendRoomGiftMsg参数错误',options);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: -9,
|
|||
|
|
errMsg: 'sendRoomGiftMsg参数错误'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
console.log('sendRoomGiftMsg 发送礼物消息',options)
|
|||
|
|
webimhandler.sendCustomMsg({
|
|||
|
|
data: '{"cmd":"CustomTextMsg","data":{"nickname":"'+options.data.nickname+'","avatarurl":"'+options.data.avatarurl+'","nature":"3"}}',
|
|||
|
|
text: '发送礼物'
|
|||
|
|
},function() {
|
|||
|
|
options.success && options.success();
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* [pusherHeartBeat 推流者心跳]
|
|||
|
|
* @param {options}
|
|||
|
|
*/
|
|||
|
|
function pusherHeartBeat(options) {
|
|||
|
|
if (options) {
|
|||
|
|
setTimeout(function () {
|
|||
|
|
proto_pusherHeartBeat();
|
|||
|
|
}, 3000);
|
|||
|
|
}
|
|||
|
|
if (heart) {
|
|||
|
|
setTimeout(function () {
|
|||
|
|
proto_pusherHeartBeat();
|
|||
|
|
pusherHeartBeat();
|
|||
|
|
}, 7000);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
function proto_pusherHeartBeat() {
|
|||
|
|
console.log('心跳请求');
|
|||
|
|
request({
|
|||
|
|
url: 'anchor_heartbeat',
|
|||
|
|
data: {
|
|||
|
|
roomID: roomInfo.roomID,
|
|||
|
|
userID: accountInfo.userID,
|
|||
|
|
roomStatusCode: roomInfo.roomStatusCode
|
|||
|
|
},
|
|||
|
|
success: function (ret) {
|
|||
|
|
if (ret.data.code) {
|
|||
|
|
console.log('心跳失败：', ret);
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
if (ret.data.pushers) {
|
|||
|
|
innerMergerAnchors(ret.data);
|
|||
|
|
}
|
|||
|
|
console.log('心跳成功', ret);
|
|||
|
|
},
|
|||
|
|
fail: function (ret) {
|
|||
|
|
console.log('心跳失败：', ret);
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [stopPusherHeartBeat 停止推流者心跳]
|
|||
|
|
* @param {options}
|
|||
|
|
*/
|
|||
|
|
function stopPusherHeartBeat() {
|
|||
|
|
heart = false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [getRoomList 获取房间列表]
|
|||
|
|
* @param {options}
|
|||
|
|
* data: {
|
|||
|
|
* index: 获取的房间开始索引，从0开始计算
|
|||
|
|
* cnt: 获取的房间个数
|
|||
|
|
* }
|
|||
|
|
* success: 成功回调
|
|||
|
|
* fail: 失败回调
|
|||
|
|
*
|
|||
|
|
* @return success
|
|||
|
|
* rooms: 房间列表信息
|
|||
|
|
*/
|
|||
|
|
function getRoomList(options) {
|
|||
|
|
if (!options) {
|
|||
|
|
console.log('getRoomList参数错误',options);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: -9,
|
|||
|
|
errMsg: 'getRoomList参数错误'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
request({
|
|||
|
|
url: 'get_room_list',
|
|||
|
|
data: {
|
|||
|
|
index: options.data.index || 0,
|
|||
|
|
cnt: options.data.cnt || 20
|
|||
|
|
},
|
|||
|
|
success: function (ret) {
|
|||
|
|
if (ret.data.code) {
|
|||
|
|
console.error('获取房间列表失败: ', ret);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: ret.data.code,
|
|||
|
|
errMsg: ret.data.message + '[' + ret.data.code + ']'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
console.log("房间列表信息:", ret);
|
|||
|
|
options.success && options.success({
|
|||
|
|
rooms: ret.data.rooms
|
|||
|
|
});
|
|||
|
|
},
|
|||
|
|
fail: function (ret) {
|
|||
|
|
console.log('获取房间列表失败: ', ret);
|
|||
|
|
if(ret.errMsg == 'request:fail timeout') {
|
|||
|
|
var errCode = -1;
|
|||
|
|
var errMsg = '网络请求超时，请检查网络状态';
|
|||
|
|
}
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: errCode || -1,
|
|||
|
|
errMsg: errMsg || '获取房间列表失败'
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [getPushURL 获取推流地址]
|
|||
|
|
* @param {options}
|
|||
|
|
* success: 成功回调
|
|||
|
|
* fail: 失败回调
|
|||
|
|
*
|
|||
|
|
* @return success
|
|||
|
|
* pushURL: 推流地址
|
|||
|
|
*/
|
|||
|
|
function getPushURL(options) {
|
|||
|
|
if (!options) {
|
|||
|
|
console.log('getPushURL参数错误',options);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: -9,
|
|||
|
|
errMsg: 'getPushURL参数错误'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
request({
|
|||
|
|
url: 'get_anchor_url',
|
|||
|
|
data: {
|
|||
|
|
userID: accountInfo.userID
|
|||
|
|
},
|
|||
|
|
success: function (ret) {
|
|||
|
|
if (ret.data.code) {
|
|||
|
|
console.log('获取推流地址失败: ', ret);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: ret.data.code,
|
|||
|
|
errMsg: ret.data.message + '[' + ret.data.code + ']'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
console.log('获取推流地址成功：', ret.data.pushURL);
|
|||
|
|
options.success && options.success({
|
|||
|
|
pushURL: ret.data.pushURL
|
|||
|
|
});
|
|||
|
|
},
|
|||
|
|
fail: function (ret) {
|
|||
|
|
if(ret.errMsg == 'request:fail timeout') {
|
|||
|
|
var errCode = -1;
|
|||
|
|
var errMsg = '网络请求超时，请检查网络状态';
|
|||
|
|
}
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: errCode || -1,
|
|||
|
|
errMsg: errMsg || '获取推流地址失败'
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [setListener 设置监听事件]
|
|||
|
|
* @param {options}
|
|||
|
|
* onRoomDestroy: 群解散通知
|
|||
|
|
* onRecvRoomTextMsg: 消息通知
|
|||
|
|
*/
|
|||
|
|
function setListener(options) {
|
|||
|
|
if (!options) { console.log('setListener参数错误',options); return; }
|
|||
|
|
event.onAnchorEnter = options.onAnchorEnter || function () {};
|
|||
|
|
event.onAnchorExit = options.onAnchorExit || function () {};
|
|||
|
|
event.onRoomDestroy = options.onRoomDestroy || function () {};
|
|||
|
|
event.onRecvRoomTextMsg = options.onRecvRoomTextMsg || function () {};
|
|||
|
|
event.onRequestJoinAnchor = options.onRequestJoinAnchor || function () {};
|
|||
|
|
event.onKickoutJoinAnchor = options.onKickoutJoinAnchor || function () {};
|
|||
|
|
event.onRecvRoomCustomMsg = options.onRecvRoomCustomMsg || function () {};
|
|||
|
|
event.onSketchpadData = options.onSketchpadData || function(){};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [createRoom 创建房间]
|
|||
|
|
* @param {options}
|
|||
|
|
* data: {
|
|||
|
|
* roomInfo: 房间名称
|
|||
|
|
* pushURL: 推流地址
|
|||
|
|
* }
|
|||
|
|
* success: 成功回调
|
|||
|
|
* fail: 失败回调
|
|||
|
|
*/
|
|||
|
|
function createRoom(options) {
|
|||
|
|
roomInfo.isCreator = true;
|
|||
|
|
roomInfo.isDestory = false;
|
|||
|
|
roomInfo.isJoinGroup = false;
|
|||
|
|
if (!options || !options.data.roomInfo || !options.data.pushURL) {
|
|||
|
|
console.log('createRoom参数错误',options);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: -9,
|
|||
|
|
errMsg: 'createRoom参数错误'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
roomInfo.roomInfo = options.data.roomInfo;
|
|||
|
|
proto_createRoom(options);
|
|||
|
|
}
|
|||
|
|
function proto_createRoom(options) {
|
|||
|
|
var createRoomInfo = {
|
|||
|
|
userID: accountInfo.userID,
|
|||
|
|
roomInfo: roomInfo.roomInfo
|
|||
|
|
};
|
|||
|
|
if (options.data.roomID && options.data.roomID.length > 0) {
|
|||
|
|
createRoomInfo.roomID = options.data.roomID;
|
|||
|
|
}
|
|||
|
|
request({
|
|||
|
|
url: 'create_room',
|
|||
|
|
data: createRoomInfo,
|
|||
|
|
success: function (ret) {
|
|||
|
|
if (ret.data.code) {
|
|||
|
|
console.log('创建房间失败:', ret);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: ret.data.code,
|
|||
|
|
errMsg: ret.data.message + '[' + ret.data.code + ']'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
console.log('--->创建房间成功:', ret);
|
|||
|
|
roomInfo.roomID = ret.data.roomID;
|
|||
|
|
roomInfo.roomCreator = accountInfo.userID;
|
|||
|
|
if (roomInfo.isDestory) {
|
|||
|
|
roomInfo.isDestory = false;
|
|||
|
|
destoryRoom({});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
options.data.roomID = ret.data.roomID;
|
|||
|
|
// 创建IM群
|
|||
|
|
var createIMGroupInfo = {
|
|||
|
|
roomID: options.data.roomID,
|
|||
|
|
userID: accountInfo.userID,
|
|||
|
|
roomName: options.data.roomID
|
|||
|
|
}
|
|||
|
|
webimhandler.createBigGroup(createIMGroupInfo, afterJoinBigGroup, {
|
|||
|
|
success: function() {
|
|||
|
|
joinAnchor(options);
|
|||
|
|
},
|
|||
|
|
fail: options.fail
|
|||
|
|
});
|
|||
|
|
},
|
|||
|
|
fail: function (ret) {
|
|||
|
|
console.log('创建后台房间失败:', ret);
|
|||
|
|
if(ret.errMsg == 'request:fail timeout') {
|
|||
|
|
var errCode = -1;
|
|||
|
|
var errMsg = '网络请求超时，请检查网络状态';
|
|||
|
|
}
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: errCode || -3,
|
|||
|
|
errMsg: errMsg || '创建房间失败'
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [joinAnchor 加入推流]
|
|||
|
|
* @param {options}
|
|||
|
|
* data: {
|
|||
|
|
* roomID: 房间ID
|
|||
|
|
* pushURL: 推流地址
|
|||
|
|
* }
|
|||
|
|
* success: 成功回调
|
|||
|
|
* fail: 失败回调
|
|||
|
|
*/
|
|||
|
|
function joinAnchor(options) {
|
|||
|
|
if(!options || !options.data.roomID || !options.data.pushURL) {
|
|||
|
|
console.log('joinAnchor参数错误',options);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: -9,
|
|||
|
|
errMsg: 'joinAnchor参数错误'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
roomInfo.roomID = options.data.roomID;
|
|||
|
|
roomInfo.isDestory = false;
|
|||
|
|
proto_joinAnchor(options);
|
|||
|
|
}
|
|||
|
|
function proto_joinAnchor(options) {
|
|||
|
|
request({
|
|||
|
|
url: 'add_anchor',
|
|||
|
|
data: {
|
|||
|
|
roomID: roomInfo.roomID,
|
|||
|
|
userID: accountInfo.userID,
|
|||
|
|
userName: accountInfo.userName,
|
|||
|
|
userAvatar: accountInfo.userAvatar,
|
|||
|
|
pushURL: options.data.pushURL
|
|||
|
|
},
|
|||
|
|
success: function(ret) {
|
|||
|
|
if(ret.data.code) {
|
|||
|
|
console.log('进入房间失败:',ret);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: ret.data.code,
|
|||
|
|
errMsg: ret.data.message + '[' + ret.data.code + ']'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
roomInfo.hasJoinAnchor = true;
|
|||
|
|
mergeAnchors();
|
|||
|
|
console.log('加入推流成功');
|
|||
|
|
// 开始心跳
|
|||
|
|
heart = true;
|
|||
|
|
pusherHeartBeat(1);
|
|||
|
|
//通知房间内其他主播
|
|||
|
|
notifyPusherChange();
|
|||
|
|
options.success && options.success({roomID: roomInfo.roomID});
|
|||
|
|
},
|
|||
|
|
fail: function(ret) {
|
|||
|
|
console.log('进入房间失败:',ret);
|
|||
|
|
if(ret.errMsg == 'request:fail timeout') {
|
|||
|
|
var errCode = -1;
|
|||
|
|
var errMsg = '网络请求超时，请检查网络状态';
|
|||
|
|
}
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: errCode || -4,
|
|||
|
|
errMsg: errMsg || '进入房间失败'
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [enterRoom 进入房间]
|
|||
|
|
* @param {options}
|
|||
|
|
* data: {
|
|||
|
|
* roomID: 房间ID
|
|||
|
|
* }
|
|||
|
|
* success: 成功回调
|
|||
|
|
* fail: 失败回调
|
|||
|
|
*/
|
|||
|
|
function enterRoom(options) {
|
|||
|
|
roomInfo.isCreator = false;
|
|||
|
|
roomInfo.isJoinGroup = false;
|
|||
|
|
if (!options || !options.data.roomID) {
|
|||
|
|
console.log('enterRoom参数错误',options);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: -9,
|
|||
|
|
errMsg: 'enterRoom参数错误'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
roomInfo.roomID = options.data.roomID;
|
|||
|
|
proto_enterRoom({
|
|||
|
|
success: function(ret) {
|
|||
|
|
options.success && options.success(ret);
|
|||
|
|
var userInfo = {
|
|||
|
|
userName: accountInfo.userName,
|
|||
|
|
userAvatar: accountInfo.userAvatar
|
|||
|
|
}
|
|||
|
|
addAudience({
|
|||
|
|
data: {
|
|||
|
|
roomID: options.data.roomID,
|
|||
|
|
userID: accountInfo.userID,
|
|||
|
|
userInfo: JSON.stringify(userInfo)
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
},
|
|||
|
|
fail: options.fail
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
function proto_enterRoom(options) {
|
|||
|
|
console.log('开始IM: ', roomInfo.roomID);
|
|||
|
|
webimhandler.applyJoinBigGroup(roomInfo.roomID, afterJoinBigGroup, {
|
|||
|
|
success: function(ret) {
|
|||
|
|
getAnchors({
|
|||
|
|
data: {
|
|||
|
|
roomID: roomInfo.roomID
|
|||
|
|
},
|
|||
|
|
success: function(ret) {
|
|||
|
|
roomInfo.roomID = ret.data.roomID;
|
|||
|
|
roomInfo.roomInfo = ret.data.roomInfo;
|
|||
|
|
roomInfo.roomCreator = ret.data.roomCreator;
|
|||
|
|
roomInfo.mixedPlayURL = ret.data.mixedPlayURL;
|
|||
|
|
options.success && options.success({
|
|||
|
|
roomID: roomInfo.roomID,
|
|||
|
|
roomCreator: roomInfo.roomCreator,
|
|||
|
|
mixedPlayURL: roomInfo.mixedPlayURL,
|
|||
|
|
pushers: ret.data.pushers
|
|||
|
|
});
|
|||
|
|
},
|
|||
|
|
fail: function(ret) {
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: ret.errCode,
|
|||
|
|
errMsg: ret.errMsg || '拉取主播信息失败'
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
},
|
|||
|
|
fail: options.fail
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [clearRequest 中断请求]
|
|||
|
|
* @param {options}
|
|||
|
|
*/
|
|||
|
|
function clearRequest() {
|
|||
|
|
for(var i = 0; i < requestSeq; i++) {
|
|||
|
|
requestTask[i].abort();
|
|||
|
|
}
|
|||
|
|
requestTask = [];
|
|||
|
|
requestSeq = 0;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [exitRoom 退出房间]
|
|||
|
|
* @param {options}
|
|||
|
|
*/
|
|||
|
|
function exitRoom(options) {
|
|||
|
|
if (roomInfo.isCreator) {
|
|||
|
|
destoryRoom(options);
|
|||
|
|
} else {
|
|||
|
|
leaveRoom(options);
|
|||
|
|
}
|
|||
|
|
roomInfo.isDestory = true;
|
|||
|
|
roomInfo.roomID = '';
|
|||
|
|
roomInfo.pushers = [];
|
|||
|
|
roomInfo.mixedPlayURL = "";
|
|||
|
|
roomInfo.roomInfo = "";
|
|||
|
|
accountInfo.pushURL = "";
|
|||
|
|
accountInfo.isCreator = false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [leaveRoom 退出房间]
|
|||
|
|
*/
|
|||
|
|
function leaveRoom(options) {
|
|||
|
|
// 停止心跳
|
|||
|
|
stopPusherHeartBeat();
|
|||
|
|
//通知房间内其他主播
|
|||
|
|
notifyPusherChange();
|
|||
|
|
// clearRequest();
|
|||
|
|
roomInfo.isJoinGroup && webimhandler.quitBigGroup();
|
|||
|
|
request({
|
|||
|
|
url: 'delete_anchor',
|
|||
|
|
data: {
|
|||
|
|
roomID: roomInfo.roomID,
|
|||
|
|
userID: accountInfo.userID
|
|||
|
|
},
|
|||
|
|
success: function(ret) {
|
|||
|
|
if(ret.data.code) {
|
|||
|
|
console.log('退出推流失败:',ret);
|
|||
|
|
console.error('退房信息: roomID:' + roomInfo.roomID + ", userID:" + accountInfo.userID);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: ret.data.code,
|
|||
|
|
errMsg: ret.data.message + '[' + ret.data.code + ']'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
console.log('退出推流成功');
|
|||
|
|
options.success && options.success({});
|
|||
|
|
},
|
|||
|
|
fail: function(ret) {
|
|||
|
|
console.log('退出推流失败:',ret);
|
|||
|
|
var errCode = ret.errCode || -1;
|
|||
|
|
var errMsg = ret.errMsg || '退出房间失败'
|
|||
|
|
if(ret.errMsg == 'request:fail timeout') {
|
|||
|
|
errCode = -1;
|
|||
|
|
errMsg = '网络请求超时，请检查网络状态';
|
|||
|
|
}
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: errCode,
|
|||
|
|
errMsg: errMsg
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
delAudience({
|
|||
|
|
data: {
|
|||
|
|
userID: accountInfo.userID,
|
|||
|
|
roomID: roomInfo.roomID
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* [destoryRoom 销毁房间]
|
|||
|
|
*/
|
|||
|
|
function destoryRoom(options) {
|
|||
|
|
// 停止心跳
|
|||
|
|
stopPusherHeartBeat();
|
|||
|
|
// clearRequest();
|
|||
|
|
roomInfo.isJoinGroup && webimhandler.destroyGroup();
|
|||
|
|
if(roomInfo.isDestory) return;
|
|||
|
|
request({
|
|||
|
|
url: 'destroy_room',
|
|||
|
|
data: {
|
|||
|
|
roomID: roomInfo.roomID,
|
|||
|
|
userID: accountInfo.userID
|
|||
|
|
},
|
|||
|
|
success: function(ret) {
|
|||
|
|
if(ret.data.code) {
|
|||
|
|
console.log('关闭房间失败:',ret);
|
|||
|
|
console.error('关闭房间失败: roomID:' + roomInfo.roomID + ", userID:" + accountInfo.userID);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: ret.data.code,
|
|||
|
|
errMsg: ret.data.message + '[' + ret.data.code + ']'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
console.log('关闭房间成功');
|
|||
|
|
options.success && options.success({});
|
|||
|
|
},
|
|||
|
|
fail: function(ret) {
|
|||
|
|
console.log('关闭房间失败:',ret);
|
|||
|
|
var errCode = ret.errCode || -1;
|
|||
|
|
var errMsg = ret.errMsg || '关闭房间失败'
|
|||
|
|
if(ret.errMsg == 'request:fail timeout') {
|
|||
|
|
errCode = -1;
|
|||
|
|
errMsg = '网络请求超时，请检查网络状态';
|
|||
|
|
}
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: errCode,
|
|||
|
|
errMsg: errMsg
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function quitJoinAnchor(options) {
|
|||
|
|
stopPusherHeartBeat();
|
|||
|
|
request({
|
|||
|
|
url: 'delete_anchor',
|
|||
|
|
data: {
|
|||
|
|
roomID: roomInfo.roomID,
|
|||
|
|
userID: accountInfo.userID
|
|||
|
|
},
|
|||
|
|
success: function(ret) {
|
|||
|
|
if(ret.data.code) {
|
|||
|
|
console.log('退出推流失败:',ret);
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: ret.data.code,
|
|||
|
|
errMsg: ret.data.message + '[' + ret.data.code + ']'
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
console.log('退出推流成功');
|
|||
|
|
roomInfo.pushers = [];
|
|||
|
|
//通知房间内其他主播
|
|||
|
|
notifyPusherChange();
|
|||
|
|
options.success && options.success({});
|
|||
|
|
},
|
|||
|
|
fail: function(ret) {
|
|||
|
|
console.log('退出推流失败:',ret);
|
|||
|
|
if(ret.errMsg == 'request:fail timeout') {
|
|||
|
|
var errCode = -1;
|
|||
|
|
var errMsg = '网络请求超时，请检查网络状态';
|
|||
|
|
}
|
|||
|
|
options.fail && options.fail({
|
|||
|
|
errCode: errCode || -1,
|
|||
|
|
errMsg: errMsg || '退出房间失败'
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
roomInfo.hasJoinAnchor = false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function requestJoinAnchor (object) {
|
|||
|
|
var body = {
|
|||
|
|
cmd: 'linkmic',
|
|||
|
|
data: {
|
|||
|
|
type: 'request',
|
|||
|
|
roomID: roomInfo.roomID,
|
|||
|
|
userID: accountInfo.userID,
|
|||
|
|
userName: accountInfo.userName,
|
|||
|
|
userAvatar: accountInfo.userAvatar,
|
|||
|
|
timestamp: Math.round(Date.now()) - mTimeDiff
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
requestJoinCallback = function(ret) {
|
|||
|
|
if (gTimeoutID) {
|
|||
|
|
clearTimeout(gTimeoutID);
|
|||
|
|
gTimeoutID = null;
|
|||
|
|
}
|
|||
|
|
if (ret.errCode) {
|
|||
|
|
object.fail && object.fail(ret);
|
|||
|
|
} else {
|
|||
|
|
object.success && object.success(ret);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var isTimeout = false;
|
|||
|
|
gTimeoutID = setTimeout(function () {
|
|||
|
|
gTimeoutID = null;
|
|||
|
|
console.error('申请连麦超时:', JSON.stringify(object.data));
|
|||
|
|
isTimeout = true;
|
|||
|
|
requestJoinCallback && requestJoinCallback({
|
|||
|
|
errCode: -999,
|
|||
|
|
errMsg: '申请加入连麦超时'
|
|||
|
|
});
|
|||
|
|
}, (object.data && object.data.timeout)? object.data.timeout : 30000);
|
|||
|
|
|
|||
|
|
var msg = {
|
|||
|
|
data: JSON.stringify(body)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
webimhandler.sendC2CCustomMsg(roomInfo.roomCreator, msg, function (ret) {
|
|||
|
|
if (isTimeout) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
if (ret && ret.errCode) {
|
|||
|
|
console.log('请求连麦失败:', JSON.stringify(ret));
|
|||
|
|
requestJoinCallback && requestJoinCallback(ret);
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function acceptJoinAnchor (object) {
|
|||
|
|
var body = {
|
|||
|
|
cmd: 'linkmic',
|
|||
|
|
data: {
|
|||
|
|
type: 'response',
|
|||
|
|
result: 'accept',
|
|||
|
|
reason: '',
|
|||
|
|
roomID: roomInfo.roomID,
|
|||
|
|
timestamp: Math.round(Date.now()) - mTimeDiff
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
console.log('要连麦房间信息')
|
|||
|
|
console.log(body)
|
|||
|
|
var msg = {
|
|||
|
|
data: JSON.stringify(body)
|
|||
|
|
}
|
|||
|
|
webimhandler.sendC2CCustomMsg(object.data.userID, msg, function (ret) {});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function rejectJoinAnchor (object) {
|
|||
|
|
var body = {
|
|||
|
|
cmd: 'linkmic',
|
|||
|
|
data: {
|
|||
|
|
type: 'response',
|
|||
|
|
result: 'reject',
|
|||
|
|
reason: object.data.reason || '主播拒绝了您的连麦请求',
|
|||
|
|
roomID: roomInfo.roomID,
|
|||
|
|
timestamp: Math.round(Date.now()) - mTimeDiff
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var msg = {
|
|||
|
|
data: JSON.stringify(body)
|
|||
|
|
}
|
|||
|
|
webimhandler.sendC2CCustomMsg(object.data.userID, msg, function (ret) {});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function kickoutJoinAnchor (object) {
|
|||
|
|
var body = {
|
|||
|
|
cmd: 'linkmic',
|
|||
|
|
data: {
|
|||
|
|
type: 'kickout',
|
|||
|
|
roomID: roomInfo.roomID,
|
|||
|
|
timestamp: Math.round(Date.now()) - mTimeDiff
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var msg = {
|
|||
|
|
data: JSON.stringify(body)
|
|||
|
|
}
|
|||
|
|
webimhandler.sendC2CCustomMsg(object.data.userID, msg, function (ret) {
|
|||
|
|
if (ret && ret.errCode==0) {
|
|||
|
|
object.success && object.success(ret);
|
|||
|
|
} else {
|
|||
|
|
object.fail && object.fail(ret);
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function getAccountInfo() {
|
|||
|
|
return accountInfo;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
*
|
|||
|
|
* @param {Int} retryCount
|
|||
|
|
*/
|
|||
|
|
function mergeStream(retryCount) {
|
|||
|
|
if (accountInfo.userID != roomInfo.roomCreator) {
|
|||
|
|
//大主播才能混流
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
var mergeStreams = [];
|
|||
|
|
if (roomInfo.pushers && roomInfo.pushers.length > 0) {
|
|||
|
|
roomInfo.pushers.forEach(function (val) {
|
|||
|
|
if (val.userID != roomInfo.roomCreator) {
|
|||
|
|
//获取流id
|
|||
|
|
var streamID = getStreamIDByStreamUrl(val.accelerateURL);
|
|||
|
|
if (streamID) {
|
|||
|
|
mergeStreams.push({
|
|||
|
|
userID: val.userID,
|
|||
|
|
streamID: streamID,
|
|||
|
|
width: val.width,
|
|||
|
|
height: val.height
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
bigAnchorStreamID = getStreamIDByStreamUrl(val.accelerateURL);
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
console.log("混流信息:", JSON.stringify(mergeStreams));
|
|||
|
|
|
|||
|
|
sendStreamMergeRequest(retryCount, mergeStreams);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function getStreamIDByStreamUrl(streamUrl) {
|
|||
|
|
if (!streamUrl) {
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
//推流地址格式: rtmp://8888.livepush.myqcloud.com/path/8888_test_12345?txSecret=aaa&txTime=bbb
|
|||
|
|
//拉流地址格式: rtmp://8888.livepush.myqcloud.com/path/8888_test_12345
|
|||
|
|
// http://8888.livepush.myqcloud.com/path/8888_test_12345.flv
|
|||
|
|
// http://8888.livepush.myqcloud.com/path/8888_test_12345.m3u8
|
|||
|
|
|
|||
|
|
var subStr = streamUrl;
|
|||
|
|
var index = subStr.indexOf('?');
|
|||
|
|
if (index >= 0) {
|
|||
|
|
subStr = subStr.substring(0, index);
|
|||
|
|
}
|
|||
|
|
if (!subStr) {
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
index = subStr.lastIndexOf('/');
|
|||
|
|
if (index >= 0) {
|
|||
|
|
subStr = subStr.substring(index + 1);
|
|||
|
|
}
|
|||
|
|
if (!subStr) {
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
index = subStr.indexOf('.');
|
|||
|
|
if (index >= 0) {
|
|||
|
|
subStr = subStr.substring(0, index);
|
|||
|
|
}
|
|||
|
|
if (!subStr) {
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
return subStr;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function sendStreamMergeRequest(retryCount, mergeStreams) {
|
|||
|
|
if (retryCount < 0) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var mergeInfo = createMergeInfo(mergeStreams);
|
|||
|
|
console.log('混流信息:', JSON.stringify(mergeInfo));
|
|||
|
|
|
|||
|
|
doMergeRequest(mergeInfo, function (ret) {
|
|||
|
|
if (ret) {
|
|||
|
|
console.log('混流成功');
|
|||
|
|
} else {
|
|||
|
|
console.log('混流失败');
|
|||
|
|
setTimeout(() => {
|
|||
|
|
retryCount--;
|
|||
|
|
sendStreamMergeRequest(retryCount, mergeStreams);
|
|||
|
|
}, 2000);
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function doMergeRequest(mergeInfo, callback) {
|
|||
|
|
request({
|
|||
|
|
url: 'merge_stream',
|
|||
|
|
data: {
|
|||
|
|
userID: accountInfo.userID,
|
|||
|
|
roomID: roomInfo.roomID,
|
|||
|
|
mergeParams: JSON.stringify(mergeInfo)
|
|||
|
|
},
|
|||
|
|
success: function (ret) {
|
|||
|
|
if (ret.data.code || ret.data.merge_code) {
|
|||
|
|
console.error('混流失败:', JSON.stringify(ret));
|
|||
|
|
callback(false);
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
callback(true);
|
|||
|
|
},
|
|||
|
|
fail: function (ret) {
|
|||
|
|
callback(false);
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function createMergeInfo(mergeStreams) {
|
|||
|
|
console.log("混流原始信息:", JSON.stringify(mergeStreams));
|
|||
|
|
|
|||
|
|
var smallAnchorWidth = 160;
|
|||
|
|
var smallAnchorHeight = 240;
|
|||
|
|
var offsetHeight = 90;
|
|||
|
|
if (bigAnchorWidth < 540 || bigAnchorHeight < 960) {
|
|||
|
|
smallAnchorWidth = 120;
|
|||
|
|
smallAnchorHeight = 180;
|
|||
|
|
offsetHeight = 60;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//组装混流JSON结构体
|
|||
|
|
var streamInfoArray = [];
|
|||
|
|
if (mergeStreams && mergeStreams.length > 0) {
|
|||
|
|
|
|||
|
|
//大主播
|
|||
|
|
var bigAnchorInfo = {
|
|||
|
|
input_stream_id: bigAnchorStreamID || '',
|
|||
|
|
layout_params: {
|
|||
|
|
image_layer: 1
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
streamInfoArray.push(bigAnchorInfo);
|
|||
|
|
|
|||
|
|
//小主播
|
|||
|
|
var subLocationX = bigAnchorWidth - smallAnchorWidth;
|
|||
|
|
var subLocationY = bigAnchorHeight - smallAnchorHeight - offsetHeight;
|
|||
|
|
if (mergeStreams && mergeStreams.length > 0) {
|
|||
|
|
var layerIndex = 0
|
|||
|
|
mergeStreams.forEach(function (val) {
|
|||
|
|
//组装JSON
|
|||
|
|
var smallAchorInfo = {
|
|||
|
|
input_stream_id: val.streamID,
|
|||
|
|
layout_params: {
|
|||
|
|
image_layer: layerIndex + 2,
|
|||
|
|
image_width: smallAnchorWidth,
|
|||
|
|
image_height: smallAnchorHeight,
|
|||
|
|
location_x: subLocationX,
|
|||
|
|
location_y: subLocationY - layerIndex * smallAnchorHeight
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
streamInfoArray.push(smallAchorInfo);
|
|||
|
|
layerIndex++;
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
var bigAnchorInfo = {
|
|||
|
|
input_stream_id: bigAnchorStreamID || '',
|
|||
|
|
layout_params: {
|
|||
|
|
image_layer: 1
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
streamInfoArray.push(bigAnchorInfo);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var para = {
|
|||
|
|
app_id: accountInfo.sdkAppID.toString(),
|
|||
|
|
interface: 'mix_streamv2.start_mix_stream_advanced',
|
|||
|
|
mix_stream_session_id: bigAnchorStreamID,
|
|||
|
|
output_stream_id: bigAnchorStreamID,
|
|||
|
|
input_stream_list: streamInfoArray
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var interfaceObj = {
|
|||
|
|
interfaceName: 'Mix_StreamV2',
|
|||
|
|
para: para
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var reqParam = {
|
|||
|
|
timestamp: Math.round((Date.now() / 1000)),
|
|||
|
|
eventId: Math.round((Date.now() / 1000)),
|
|||
|
|
interface: interfaceObj
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return reqParam;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function setVideoRatio(ratio) {
|
|||
|
|
if (ratio == 1) {
|
|||
|
|
//9:16
|
|||
|
|
bigAnchorWidth = 360;
|
|||
|
|
bigAnchorHeight = 640;
|
|||
|
|
} else {
|
|||
|
|
//3:4
|
|||
|
|
bigAnchorWidth = 480;
|
|||
|
|
bigAnchorHeight = 640;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function sendC2CCustomMsg(object) {
|
|||
|
|
console.log('sendC2CCustomMsg',object)
|
|||
|
|
var body = {
|
|||
|
|
cmd: object.cmd,
|
|||
|
|
data: {
|
|||
|
|
userID: accountInfo.userID,
|
|||
|
|
userName: accountInfo.userName,
|
|||
|
|
userAvatar: accountInfo.userAvatar,
|
|||
|
|
msg: object.msg || ''
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
var msg = {
|
|||
|
|
data: JSON.stringify(body)
|
|||
|
|
}
|
|||
|
|
webimhandler.sendC2CCustomMsg(object.toUserID?object.toUserID:roomInfo.roomCreator, msg, function (ret) {
|
|||
|
|
if (ret && ret.errCode) {
|
|||
|
|
console.log('请求连麦失败:', JSON.stringify(ret));
|
|||
|
|
object.fail && object.fail(ret);
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
object.success && object.success({});
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//观众进房时，向后台发送进房通知
|
|||
|
|
function addAudience(object) {
|
|||
|
|
console.log('观众进房时，向后台发送进房通知',object)
|
|||
|
|
request({
|
|||
|
|
url: 'add_audience',
|
|||
|
|
data: {
|
|||
|
|
userID: accountInfo.userID,
|
|||
|
|
roomID: object.data.roomID,
|
|||
|
|
userInfo: object.data.userInfo
|
|||
|
|
},
|
|||
|
|
success: function (ret) {
|
|||
|
|
if (ret.data.code) {
|
|||
|
|
console.log('增加观众请求失败', ret);
|
|||
|
|
object.fail && object.fail({errCode: ret.data.code, errMsg: '增加观众请求失败:' + ret.data.message + + '[' + ret.data.code + ']'});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
object.success && object.success(ret);
|
|||
|
|
},
|
|||
|
|
fail: object.fail
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//观众退房时，向后台发送退房通知
|
|||
|
|
function delAudience(object) {
|
|||
|
|
request({
|
|||
|
|
url: 'delete_audience',
|
|||
|
|
data: {
|
|||
|
|
userID: object.data.userID,
|
|||
|
|
roomID: object.data.roomID
|
|||
|
|
},
|
|||
|
|
success: function (ret) {
|
|||
|
|
if (ret.data.code) {
|
|||
|
|
console.log('减少观众请求失败', ret);
|
|||
|
|
object.fail && object.fail({errCode: ret.data.code, errMsg: '减少观众请求失败:' + ret.data.message + + '[' + ret.data.code + ']'});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
object.success && object.success(ret);
|
|||
|
|
},
|
|||
|
|
fail: object.fail
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 对外暴露函数
|
|||
|
|
* @type {Object}
|
|||
|
|
*/
|
|||
|
|
module.exports = {
|
|||
|
|
login: login, // 初始化
|
|||
|
|
logout: logout, // 结束初始化
|
|||
|
|
getRoomList: getRoomList, // 拉取房间列表
|
|||
|
|
getPushURL: getPushURL, // 拉取推流地址
|
|||
|
|
createRoom: createRoom, // 创建房间
|
|||
|
|
enterRoom: enterRoom, // 加入房间
|
|||
|
|
exitRoom: exitRoom, // 退出房间
|
|||
|
|
sendRoomTextMsg: sendRoomTextMsg, // 发送文本消息
|
|||
|
|
sendRoomGiftMsg: sendRoomGiftMsg, // 发送文本消息
|
|||
|
|
setListener: setListener, // 设置监听事件
|
|||
|
|
joinAnchor: joinAnchor, //加入连麦
|
|||
|
|
quitJoinAnchor: quitJoinAnchor, //退出连麦
|
|||
|
|
requestJoinAnchor: requestJoinAnchor,
|
|||
|
|
acceptJoinAnchor: acceptJoinAnchor,
|
|||
|
|
rejectJoinAnchor: rejectJoinAnchor,
|
|||
|
|
kickoutJoinAnchor: kickoutJoinAnchor,
|
|||
|
|
getAccountInfo: getAccountInfo,
|
|||
|
|
setVideoRatio: setVideoRatio,
|
|||
|
|
sendC2CCustomMsg: sendC2CCustomMsg,
|
|||
|
|
getAnchors: getAnchors
|
|||
|
|
// addRemoteView: addRemoteView,
|
|||
|
|
// deleteRemoteView: deleteRemoteView
|
|||
|
|
}
|