Skip to content

xiaozhan
xiaozhan
Commit 8cfd230a by 冷斌
Options

debug

parent 40a78db5
Showing with 902 additions and 902 deletions
LiveNewIM/s1.js
//引入http模块 //引入http模块
var socketio = require('socket.io'), var socketio = require('socket.io'),
fs = require('fs'), fs = require('fs'),
http = require('http'), http = require('http'),
domain = require('domain'), domain = require('domain'),
redis = require('redis'), redis = require('redis'),
redisio = require('socket.io-redis'), redisio = require('socket.io-redis'),
request = require('request'), request = require('request'),
md5 = require('md5-node'), md5 = require('md5-node'),
...@@ -12,7 +12,7 @@ var socketio = require('socket.io'), ...@@ -12,7 +12,7 @@ var socketio = require('socket.io'),
var d = domain.create(); var d = domain.create();
d.on("error", function(err) { d.on("error", function(err) {
//console.log(err); //console.log(err);
}); });
//var numscount=0;// 在线人数统计 //var numscount=0;// 在线人数统计
...@@ -33,81 +33,81 @@ var LivePK_timer={}; ...@@ -33,81 +33,81 @@ var LivePK_timer={};
var clientRedis = redis.createClient(config['REDISPORT'],config['REDISHOST']); var clientRedis = redis.createClient(config['REDISPORT'],config['REDISHOST']);
clientRedis.auth(config['REDISPASS']); clientRedis.auth(config['REDISPASS']);
var server = http.createServer(function(req, res) { var server = http.createServer(function(req, res) {
res.writeHead(200, { res.writeHead(200, {
'Content-type': 'text/html;charset=utf-8' 'Content-type': 'text/html;charset=utf-8'
}); });
//res.write("人数: " + numscount ); //res.write("人数: " + numscount );
res.end(); res.end();
}).listen(config['socket_port'], function() { }).listen(config['socket_port'], function() {
////console.log('服务开启19965'); ////console.log('服务开启19965');
}); });
var io = socketio.listen(server,{ var io = socketio.listen(server,{
pingTimeout: 60000, pingTimeout: 60000,
pingInterval: 25000 pingInterval: 25000
}); });
/* var pub = redis.createClient(config['REDISPORT'], config['REDISHOST'], { auth_pass: config['REDISPASS'] }); /* var pub = redis.createClient(config['REDISPORT'], config['REDISHOST'], { auth_pass: config['REDISPASS'] });
var sub = redis.createClient(config['REDISPORT'], config['REDISHOST'], { auth_pass: config['REDISPASS'] }); var sub = redis.createClient(config['REDISPORT'], config['REDISHOST'], { auth_pass: config['REDISPASS'] });
io.adapter(redisio({ pubClient: pub, subClient: sub })); */ io.adapter(redisio({ pubClient: pub, subClient: sub })); */
//setInterval(function(){ //setInterval(function(){
//global.gc(); //global.gc();
////console.log('GC done') ////console.log('GC done')
//}, 1000*30); //}, 1000*30);
io.on('connection', function(socket) { io.on('connection', function(socket) {
////console.log('连接成功'); ////console.log('连接成功');
//numscount++; //numscount++;
var interval; var interval;
//进入房间 //进入房间
socket.on('conn', function(data) { socket.on('conn', function(data) {
if(!data || !data.token){ if(!data || !data.token){
return !1; return !1;
} }
userid=data.uid; userid=data.uid;
old_socket = sockets[userid]; old_socket = sockets[userid];
if (old_socket && old_socket != socket) { if (old_socket && old_socket != socket) {
if(data.uid== data.roomnum && data.stream==old_socket.stream){ if(data.uid== data.roomnum && data.stream==old_socket.stream){
old_socket.reusing = 1; old_socket.reusing = 1;
////console.log("重用"); ////console.log("重用");
}else if(data.uid== data.roomnum && data.stream!=old_socket.stream){ }else if(data.uid== data.roomnum && data.stream!=old_socket.stream){
var data_str='{"retmsg":"ok","retcode":"000000","msg":[{"msgtype":"1","_method_":"StartEndLive","action":"19","ct":"直播关闭"}]}'; var data_str='{"retmsg":"ok","retcode":"000000","msg":[{"msgtype":"1","_method_":"StartEndLive","action":"19","ct":"直播关闭"}]}';
old_socket.emit('broadcastingListen',[data_str]); old_socket.emit('broadcastingListen',[data_str]);
} }
old_socket.disconnect() old_socket.disconnect()
} }
clientRedis.get(data.token,function(error,res){ clientRedis.get(data.token,function(error,res){
if(error){ if(error){
return; return;
}else if(res==null){ }else if(res==null){
////console.log("[获取token失败]"+data.uid); ////console.log("[获取token失败]"+data.uid);
}else{ }else{
if(res != null){ if(res != null){
var userInfo = evalJson(res); var userInfo = evalJson(res);
if(userInfo['id'] == data.uid ){ if(userInfo['id'] == data.uid ){
////console.log("[初始化验证成功]--"+data.uid+"---"+data.roomnum+'---'+data.stream); ////console.log("[初始化验证成功]--"+data.uid+"---"+data.roomnum+'---'+data.stream);
//获取验证token //获取验证token
socket.token = data.token; socket.token = data.token;
socket.roomnum = data.roomnum; socket.roomnum = data.roomnum;
socket.stream = data.stream; socket.stream = data.stream;
socket.nicename = userInfo['user_nicename']; socket.nicename = userInfo['user_nicename'];
socket.level = userInfo['level']; socket.level = userInfo['level'];
socket.avatar = userInfo['avatar']; socket.avatar = userInfo['avatar'];
socket.sign = Number(userInfo['sign']); socket.sign = Number(userInfo['sign']);
socket.usertype = parseInt(userInfo['usertype']); socket.usertype = parseInt(userInfo['usertype']);
socket.uid = data.uid; socket.uid = data.uid;
socket.reusing = 0; socket.reusing = 0;
socket.join(data.roomnum); socket.join(data.roomnum);
sockets[userid] = socket; sockets[userid] = socket;
socket.emit('conn',['ok']); socket.emit('conn',['ok']);
/* 重连时 处理PK */ /* 重连时 处理PK */
if(socket.roomnum==socket.uid){ if(socket.roomnum==socket.uid){
clientRedis.hget('LiveConnect',socket.uid,function(error,res){ clientRedis.hget('LiveConnect',socket.uid,function(error,res){
...@@ -117,7 +117,7 @@ io.on('connection', function(socket) { ...@@ -117,7 +117,7 @@ io.on('connection', function(socket) {
if(res){ if(res){
var pkuid=res; var pkuid=res;
LiveConnect[socket.uid]=pkuid; LiveConnect[socket.uid]=pkuid;
clientRedis.hget('LivePK',socket.uid,function(error,res){ clientRedis.hget('LivePK',socket.uid,function(error,res){
if(error){ if(error){
return; return;
...@@ -126,7 +126,7 @@ io.on('connection', function(socket) { ...@@ -126,7 +126,7 @@ io.on('connection', function(socket) {
LivePK[socket.uid]=pkuid; LivePK[socket.uid]=pkuid;
} }
}) })
clientRedis.hget('LivePK_gift',socket.uid,function(error,res){ clientRedis.hget('LivePK_gift',socket.uid,function(error,res){
if(error){ if(error){
return; return;
...@@ -138,8 +138,8 @@ io.on('connection', function(socket) { ...@@ -138,8 +138,8 @@ io.on('connection', function(socket) {
} }
}) })
} }
if( socket.roomnum!=socket.uid && socket.uid >0 ){ if( socket.roomnum!=socket.uid && socket.uid >0 ){
/* 处理有时 无座驾信息会崩溃的问题 */ /* 处理有时 无座驾信息会崩溃的问题 */
var car_id='0'; var car_id='0';
var car_swf=''; var car_swf='';
...@@ -160,891 +160,891 @@ io.on('connection', function(socket) { ...@@ -160,891 +160,891 @@ io.on('connection', function(socket) {
car_words=carinfo['words']; car_words=carinfo['words'];
} }
} }
var data_obj={ var data_obj={
"msg":[ "msg":[
{ {
"_method_":"SendMsg", "_method_":"SendMsg",
"action":"0", "action":"0",
"ct":{ "ct":{
"id":''+userInfo['id'], "id":''+userInfo['id'],
"user_nicename":''+userInfo['user_nicename'], "user_nicename":''+userInfo['user_nicename'],
"avatar":userInfo['avatar'], "avatar":userInfo['avatar'],
"avatar_thumb":userInfo['avatar_thumb'], "avatar_thumb":userInfo['avatar_thumb'],
"level":''+userInfo['level'], "level":''+userInfo['level'],
"usertype":''+userInfo['usertype'], "usertype":''+userInfo['usertype'],
"vip_type":''+userInfo['vip']['type'], "vip_type":''+userInfo['vip']['type'],
"guard_type":''+userInfo['guard_type'], "guard_type":''+userInfo['guard_type'],
"liangname":''+userInfo['liang']['name'], "liangname":''+userInfo['liang']['name'],
"car_id":''+car_id, "car_id":''+car_id,
"car_swf":''+car_swf, "car_swf":''+car_swf,
"car_swftime":''+car_swftime, "car_swftime":''+car_swftime,
"car_words":''+car_words "car_words":''+car_words
}, },
"msgtype":"0" "msgtype":"0"
} }
], ],
"retcode":"000000", "retcode":"000000",
"retmsg":"OK" "retmsg":"OK"
}; };
process_msg(io,socket.roomnum,JSON.stringify(data_obj)); process_msg(io,socket.roomnum,JSON.stringify(data_obj));
if(socket.stream){ if(socket.stream){
clientRedis.zadd('user_'+socket.stream,socket.sign,userInfo['id']); clientRedis.zadd('user_'+socket.stream,socket.sign,userInfo['id']);
} }
} }
sendSystemMsg(socket,"直播内容包含任何低俗、暴露和涉黄内容，账号会被封禁；安全部门会24小时巡查哦～"); sendSystemMsg(socket,"直播内容包含任何低俗、暴露和涉黄内容，账号会被封禁；安全部门会24小时巡查哦～");
return; return;
}else{ }else{
socket.disconnect(); socket.disconnect();
} }
} }
} }
socket.emit('conn',['no']); socket.emit('conn',['no']);
}); });
}); });
socket.on('broadcast',function(data){ socket.on('broadcast',function(data){
////console.log(data); ////console.log(data);
if(socket.token != undefined){ if(socket.token != undefined){
var dataObj = typeof data == 'object'?data:evalJson(data); var dataObj = typeof data == 'object'?data:evalJson(data);
var msg = dataObj['msg'][0]; var msg = dataObj['msg'][0];
var token = dataObj['token']; var token = dataObj['token'];
var method = msg['_method_']; var method = msg['_method_'];
var action = msg['action']; var action = msg['action'];
var data_str = typeof data == 'object'?JSON.stringify(data):data; var data_str = typeof data == 'object'?JSON.stringify(data):data;
switch(method){ switch(method){
case 'SendMsg':{ //聊天 case 'SendMsg':{ //聊天
clientRedis.hget( "super",socket.uid,function(error,res){ clientRedis.hget( "super",socket.uid,function(error,res){
if(error) return; if(error) return;
if(res != null){ if(res != null){
var data_str2={ var data_str2={
"msg":[ "msg":[
{ {
"_method_":"SystemNot", "_method_":"SystemNot",
"action":"1", "action":"1",
"ct":''+dataObj['msg'][0]['ct'], "ct":''+dataObj['msg'][0]['ct'],
"msgtype":"4" "msgtype":"4"
} }
], ],
"retcode":"000000", "retcode":"000000",
"retmsg":"OK" "retmsg":"OK"
}; };
process_msg(io,socket.roomnum,JSON.stringify(data_str2)); process_msg(io,socket.roomnum,JSON.stringify(data_str2));
}else{
clientRedis.hget(socket.roomnum + "shutup",socket.uid,function(error,res){
if(error) return;
if(res != null){
var newData = dataObj;
newData['retcode'] = '409002';
socket.emit('broadcastingListen',[JSON.stringify(newData)]);
}else{
process_msg(io,socket.roomnum,data_str);
}
});
}
});
break;
}
case 'SendGift':{ //送礼物
var gifToken = dataObj['msg'][0]['ct'];
clientRedis.get(gifToken,function(error,res){
if(!error&&res != null){
var resObj = evalJson(res);
dataObj['msg'][0]['ct'] = resObj;
var pkuid=LivePK[socket.roomnum];
var ifpk='0',
pkuid1='0',
pkuid2='0',
pktotal1='0',
pktotal2='0';
if(pkuid && pkuid>0){
ifpk='1';
var total=Number(resObj.totalcoin);
LivePK_gift[socket.roomnum]+=total;
clientRedis.hincrby('LivePK_gift',socket.roomnum,total);
pkuid1=''+socket.roomnum;
pkuid2=''+pkuid;
pktotal1=''+LivePK_gift[socket.roomnum];
pktotal2=''+LivePK_gift[pkuid];
}
dataObj['msg'][0]['ifpk']=ifpk;
dataObj['msg'][0]['pkuid1']=pkuid1;
dataObj['msg'][0]['pkuid2']=pkuid2;
dataObj['msg'][0]['pktotal1']=pktotal1;
dataObj['msg'][0]['pktotal2']=pktotal2;
io.sockets.in(socket.roomnum).emit('broadcastingListen',[JSON.stringify(dataObj)]);
if(pkuid>0){
io.sockets.in(pkuid).emit('broadcastingListen',[JSON.stringify(dataObj)]);
}
/* 幸运中奖 */
if(resObj.isluck==1 && resObj.isluckall==1 ){
var data_luck={
"msg":[
{
"_method_":"luckWin",
"action":"1",
"uid":''+ msg.uid,
"uname":''+ msg.uname,
"uhead":''+ msg.uhead,
"giftid":''+ resObj.giftid,
"giftname":''+ resObj.giftname,
"lucktimes":''+ resObj.lucktimes,
"msgtype":"4"
}
],
"retcode":"000000",
"retmsg":"OK"
};
io.emit('broadcastingListen',[JSON.stringify(data_luck)]);
}
/* 幸运中奖 */
/* 奖池升级 */
if(resObj.isup==1){
var data_up={
"msg":[
{
"_method_":"jackpotUp",
"action":"1",
"uplevel":''+ resObj.uplevel,
"msgtype":"4"
}
],
"retcode":"000000",
"retmsg":"OK"
};
io.emit('broadcastingListen',[JSON.stringify(data_up)]);
}
/* 奖池升级 */
/* 奖池中奖 */
if(resObj.iswin==1){
var data_win={
"msg":[
{
"_method_":"jackpotWin",
"action":"1",
"uid":''+ msg.uid,
"uname":''+ msg.uname,
"uhead":''+ msg.uhead,
"wincoin":''+ resObj.wincoin,
"msgtype":"4"
}
],
"retcode":"000000",
"retmsg":"OK"
};
io.emit('broadcastingListen',[JSON.stringify(data_win)]);
var data_up={
"msg":[
{
"_method_":"jackpotUp",
"action":"1",
"uplevel":'0',
"msgtype":"4"
}
],
"retcode":"000000",
"retmsg":"OK"
};
io.emit('broadcastingListen',[JSON.stringify(data_up)]);
}
/* 奖池中奖 */
clientRedis.del(gifToken);
}
});
break;
}
case 'SendBarrage':{ //弹幕
var barragetoken = dataObj['msg'][0]['ct'];
clientRedis.get(barragetoken,function(error,res){
if(!error&&res != null){
var resObj = evalJson(res);
dataObj['msg'][0]['ct'] = resObj;
var data_str=JSON.stringify(dataObj);
process_msg(io,socket.roomnum,data_str);
clientRedis.del(barragetoken);
}
});
break;
}
case 'ConnectVideo' :{ //连麦
//1：发起连麦；2；接受连麦；3:拒绝连麦；4：连麦成功通知；5.发起者断开连麦；6：主播断开连麦;7:主播正忙碌 8:主播无响应
if(action=='5' || action=='6'){
clientRedis.hget('ShowVideo',socket.roomnum,function(error,res){
if(error){
return !1;
}
if(!res){
return !1;
}
var res_j=JSON.parse(res);
if( socket.uid==res_j['uid'] || socket.uid==socket.roomnum ){
clientRedis.hdel('ShowVideo',socket.roomnum);
process_msg(io,socket.roomnum,data_str);
}
});
}else{ }else{
process_msg(io,socket.roomnum,data_str); clientRedis.hget(socket.roomnum + "shutup",socket.uid,function(error,res){
if(error) return;
if(res != null){
var newData = dataObj;
newData['retcode'] = '409002';
socket.emit('broadcastingListen',[JSON.stringify(newData)]);
}else{
process_msg(io,socket.roomnum,data_str);
}
});
} }
break; });
} break;
case 'light' :{ //点亮 }
process_msg(io,socket.roomnum,data_str); case 'SendGift':{ //送礼物
break; var gifToken = dataObj['msg'][0]['ct'];
} clientRedis.get(gifToken,function(error,res){
case 'changeLive' :{//切换房间收费 if(!error&&res != null){
process_msg(io,socket.roomnum,data_str); var resObj = evalJson(res);
break; dataObj['msg'][0]['ct'] = resObj;
} var pkuid=LivePK[socket.roomnum];
case 'updateVotes' :{//更新映票 var ifpk='0',
process_msg(io,socket.roomnum,data_str); pkuid1='0',
break; pkuid2='0',
} pktotal1='0',
case 'CloseLive' :{//关闭直播 pktotal2='0';
if(socket.usertype == 50 ){ if(pkuid && pkuid>0){
process_msg(io,socket.roomnum,data_str); ifpk='1';
} var total=Number(resObj.totalcoin);
break; LivePK_gift[socket.roomnum]+=total;
} clientRedis.hincrby('LivePK_gift',socket.roomnum,total);
case 'KickUser' :{//踢人
process_msg(io,socket.roomnum,data_str); pkuid1=''+socket.roomnum;
break; pkuid2=''+pkuid;
} pktotal1=''+LivePK_gift[socket.roomnum];
case 'ShutUpUser' :{//禁言 pktotal2=''+LivePK_gift[pkuid];
process_msg(io,socket.roomnum,data_str);
break; }
} dataObj['msg'][0]['ifpk']=ifpk;
case 'stopLive' :{//超管关播 dataObj['msg'][0]['pkuid1']=pkuid1;
clientRedis.hget( "super",socket.uid,function(error,res){ dataObj['msg'][0]['pkuid2']=pkuid2;
if(error) return; dataObj['msg'][0]['pktotal1']=pktotal1;
if(res != null){ dataObj['msg'][0]['pktotal2']=pktotal2;
process_msg(io,socket.roomnum,'stopplay');
} io.sockets.in(socket.roomnum).emit('broadcastingListen',[JSON.stringify(dataObj)]);
}); if(pkuid>0){
break; io.sockets.in(pkuid).emit('broadcastingListen',[JSON.stringify(dataObj)]);
} }
case 'ResumeUser' :{//恢复发言
if(socket.usertype == 50 || socket.usertype == 40){ /* 幸运中奖 */
process_msg(io,socket.roomnum,data_str); if(resObj.isluck==1 && resObj.isluckall==1 ){
} var data_luck={
break; "msg":[
} {
case 'setAdmin' :{//设置/取消管理员 "_method_":"luckWin",
if(socket.usertype == 50 ){ "action":"1",
process_msg(io,socket.roomnum,data_str); "uid":''+ msg.uid,
} "uname":''+ msg.uname,
break; "uhead":''+ msg.uhead,
} "giftid":''+ resObj.giftid,
case 'StartEndLive':{ "giftname":''+ resObj.giftname,
if(socket.usertype == 50 ){ "lucktimes":''+ resObj.lucktimes,
socket.broadcast.to(socket.roomnum).emit('broadcastingListen',[data_str]); "msgtype":"4"
}else{ }
clientRedis.get("LiveAuthority" + socket.uid,function(error,res){ ],
if(error) return; "retcode":"000000",
if(parseInt(res) == 5 ||parseInt(res) == 1 || parseInt(res) == 2){ "retmsg":"OK"
socket.broadcast.to(socket.roomnum).emit('broadcastingListen',[data_str]); };
} io.emit('broadcastingListen',[JSON.stringify(data_luck)]);
}) }
} /* 幸运中奖 */
break;
/* 奖池升级 */
} if(resObj.isup==1){
case 'BuyGuard':{//购买守护 var data_up={
process_msg(io,socket.roomnum,data_str); "msg":[
break; {
} "_method_":"jackpotUp",
case 'SendRed' :{//送红包 "action":"1",
process_msg(io,socket.roomnum,data_str); "uplevel":''+ resObj.uplevel,
break; "msgtype":"4"
} }
case 'LiveConnect':{//主播连麦 ],
if(socket.roomnum != socket.uid){ "retcode":"000000",
//非主播不能操作 "retmsg":"OK"
return !1; };
io.emit('broadcastingListen',[JSON.stringify(data_up)]);
}
/* 奖池升级 */
/* 奖池中奖 */
if(resObj.iswin==1){
var data_win={
"msg":[
{
"_method_":"jackpotWin",
"action":"1",
"uid":''+ msg.uid,
"uname":''+ msg.uname,
"uhead":''+ msg.uhead,
"wincoin":''+ resObj.wincoin,
"msgtype":"4"
}
],
"retcode":"000000",
"retmsg":"OK"
};
io.emit('broadcastingListen',[JSON.stringify(data_win)]);
var data_up={
"msg":[
{
"_method_":"jackpotUp",
"action":"1",
"uplevel":'0',
"msgtype":"4"
}
],
"retcode":"000000",
"retmsg":"OK"
};
io.emit('broadcastingListen',[JSON.stringify(data_up)]);
}
/* 奖池中奖 */
clientRedis.del(gifToken);
} }
var pkuid=msg['pkuid']; });
var pkpull=msg['pkpull']; break;
// console.log('action'); }
// console.log(action); case 'SendBarrage':{ //弹幕
// console.log('socket.uid'); var barragetoken = dataObj['msg'][0]['ct'];
// console.log(socket.uid); clientRedis.get(barragetoken,function(error,res){
// console.log('pkuid'); if(!error&&res != null){
// console.log(pkuid); var resObj = evalJson(res);
// console.log('pkpull'); dataObj['msg'][0]['ct'] = resObj;
// console.log(pkpull); var data_str=JSON.stringify(dataObj);
//1：发起连麦；2；接受连麦;3:拒绝连麦;4：连麦成功通知;5.手动断开连麦;7:对方正忙碌 8:对方无响应 9:主播繁忙（游戏） process_msg(io,socket.roomnum,data_str);
if(action=='1'){ clientRedis.del(barragetoken);
LiveConnect_pull[socket.uid]=pkpull;
//console.log('LiveConnect_pull--'+socket.uid+'-----'+pkpull);
clientRedis.hset('LiveConnect_pull',socket.uid,pkpull);
} }
if(action=='2'){ });
LiveConnect_pull[socket.uid]=pkpull; break;
//console.log('LiveConnect_pull--'+socket.uid+'-----'+pkpull); }
clientRedis.hset('LiveConnect_pull',socket.uid,pkpull); case 'ConnectVideo' :{ //连麦
//1：发起连麦；2；接受连麦；3:拒绝连麦；4：连麦成功通知；5.发起者断开连麦；6：主播断开连麦;7:主播正忙碌 8:主播无响应
/* 更新 连麦关系 */ if(action=='5' || action=='6'){
LiveConnect[socket.uid]=pkuid; clientRedis.hget('ShowVideo',socket.roomnum,function(error,res){
LiveConnect[pkuid]=socket.uid; if(error){
return !1;
//console.log('LiveConnect');
//console.log(socket.uid)
//console.log(pkuid);
clientRedis.hset('LiveConnect',socket.uid,pkuid);
clientRedis.hset('LiveConnect',pkuid,socket.uid);
/* 更新数据库 */
var sign_data={uid:socket.uid,pkuid:pkuid,type:1};
var sign=setSign(sign_data);
request(config['WEBADDRESS']+"?service=Livepk.changeLive&uid="+socket.uid + "&pkuid=" + pkuid+ "&type=1&sign=" +sign,function(error, response, body){});
/* 发送连麦成功信息 */
/* 当前房间 */
var data_obj={
"msg":[
{
"_method_":"LiveConnect",
"action":"4",
"msgtype":"10",
"pkuid":""+pkuid,
"pkpull":""+LiveConnect_pull[pkuid],
"uid":""+socket.uid,
"uname":""+socket.nicename
}
],
"retcode":"000000",
"retmsg":"OK"
};
process_msg(io,socket.roomnum,JSON.stringify(data_obj));
/* 对方房间 */
var data_obj_pk={
"msg":[
{
"_method_":"LiveConnect",
"action":"4",
"msgtype":"10",
"pkuid":""+socket.uid,
"pkpull":""+LiveConnect_pull[socket.uid],
"uid":""+socket.uid,
"uname":""+socket.nicename
}
],
"retcode":"000000",
"retmsg":"OK"
};
process_msg(io,pkuid,JSON.stringify(data_obj_pk));
}else if(action=='5'){
/* 清除连麦信息 */
endLiveConnect(io,socket.uid);
}else{
var socket_pkuid=sockets[pkuid];
if(socket_pkuid){
socket_pkuid.emit('broadcastingListen',[data_str]);
} }
if(!res){
} return !1;
break; }
} var res_j=JSON.parse(res);
case 'LivePK':{//主播PK
if(socket.roomnum != socket.uid){ if( socket.uid==res_j['uid'] || socket.uid==socket.roomnum ){
//非主播不能操作 clientRedis.hdel('ShowVideo',socket.roomnum);
return !1; process_msg(io,socket.roomnum,data_str);
}
});
}else{
process_msg(io,socket.roomnum,data_str);
}
break;
}
case 'light' :{ //点亮
process_msg(io,socket.roomnum,data_str);
break;
}
case 'changeLive' :{//切换房间收费
process_msg(io,socket.roomnum,data_str);
break;
}
case 'updateVotes' :{//更新映票
process_msg(io,socket.roomnum,data_str);
break;
}
case 'CloseLive' :{//关闭直播
if(socket.usertype == 50 ){
process_msg(io,socket.roomnum,data_str);
}
break;
}
case 'KickUser' :{//踢人
process_msg(io,socket.roomnum,data_str);
break;
}
case 'ShutUpUser' :{//禁言
process_msg(io,socket.roomnum,data_str);
break;
}
case 'stopLive' :{//超管关播
clientRedis.hget( "super",socket.uid,function(error,res){
if(error) return;
if(res != null){
process_msg(io,socket.roomnum,'stopplay');
} }
var uid=msg['uid']; });
var pkuid=msg['pkuid']; break;
//1：发起连麦；2；接受连麦;3:拒绝连麦;4：连麦成功通知;5.手动断开连麦;7:对方正忙碌 8:对方无响应; 9:PK结果 }
if(action=='2'){ case 'ResumeUser' :{//恢复发言
/* 更新PK状态 */ if(socket.usertype == 50 || socket.usertype == 40){
LivePK[socket.uid]=pkuid; process_msg(io,socket.roomnum,data_str);
LivePK[pkuid]=socket.uid; }
break;
LivePK_gift[socket.uid]=0; }
LivePK_gift[pkuid]=0; case 'setAdmin' :{//设置/取消管理员
if(socket.usertype == 50 ){
//console.log('LivePK'); process_msg(io,socket.roomnum,data_str);
//console.log(socket.uid); }
//console.log(pkuid); break;
}
clientRedis.hset('LivePK',socket.uid,pkuid); case 'StartEndLive':{
clientRedis.hset('LivePK',pkuid,socket.uid); if(socket.usertype == 50 ){
socket.broadcast.to(socket.roomnum).emit('broadcastingListen',[data_str]);
clientRedis.hset('LivePK_gift',socket.uid,0); }else{
clientRedis.hset('LivePK_gift',pkuid,0); clientRedis.get("LiveAuthority" + socket.uid,function(error,res){
if(error) return;
/* 发送连麦成功信息 */ if(parseInt(res) == 5 ||parseInt(res) == 1 || parseInt(res) == 2){
/* 当前房间 */ socket.broadcast.to(socket.roomnum).emit('broadcastingListen',[data_str]);
var data_obj={
"msg":[
{
"_method_":"LivePK",
"action":"4",
"msgtype":"10",
"pkuid":""+pkuid,
"uid":""+socket.uid,
"uname":""+socket.nicename
}
],
"retcode":"000000",
"retmsg":"OK"
};
process_msg(io,socket.roomnum,JSON.stringify(data_obj));
/* 对方房间 */
var data_obj_pk={
"msg":[
{
"_method_":"LivePK",
"action":"4",
"msgtype":"10",
"pkuid":""+socket.uid,
"uid":""+socket.uid,
"uname":""+socket.nicename
}
],
"retcode":"000000",
"retmsg":"OK"
};
process_msg(io,pkuid,JSON.stringify(data_obj_pk));
clearTimeout(LivePK_timer[socket.uid]);
LivePK_timer[socket.uid]=null;
var time=Math.floor( (new Date()).getTime()/1000);
//console.log('LivePK_timer_'+socket.uid+'___'+pkuid);
//console.log('LivePK_timer');
//console.log(time);
clientRedis.hset('LivePK_timer',socket.uid,time);
LivePK_timer[socket.uid]=setTimeout(function() {//定时发送结果
endLivePk(io,socket.uid,0);
}, 5*60*1000);
//5*60*1000
}else if(action=='5'){
/* 清除PK信息 */
endLivePk(io,socket.uid,1);
}else{
var socket_pkuid=sockets[pkuid];
if(socket_pkuid){
socket_pkuid.emit('broadcastingListen',[data_str]);
} }
//process_msg(io,pkuid,data_str); })
}
break;
}
case 'BuyGuard':{//购买守护
process_msg(io,socket.roomnum,data_str);
break;
}
case 'SendRed' :{//送红包
process_msg(io,socket.roomnum,data_str);
break;
}
case 'LiveConnect':{//主播连麦
if(socket.roomnum != socket.uid){
//非主播不能操作
return !1;
}
var pkuid=msg['pkuid'];
var pkpull=msg['pkpull'];
// console.log('action');
// console.log(action);
// console.log('socket.uid');
// console.log(socket.uid);
// console.log('pkuid');
// console.log(pkuid);
// console.log('pkpull');
// console.log(pkpull);
//1：发起连麦；2；接受连麦;3:拒绝连麦;4：连麦成功通知;5.手动断开连麦;7:对方正忙碌 8:对方无响应 9:主播繁忙（游戏）
if(action=='1'){
LiveConnect_pull[socket.uid]=pkpull;
//console.log('LiveConnect_pull--'+socket.uid+'-----'+pkpull);
clientRedis.hset('LiveConnect_pull',socket.uid,pkpull);
}
if(action=='2'){
LiveConnect_pull[socket.uid]=pkpull;
//console.log('LiveConnect_pull--'+socket.uid+'-----'+pkpull);
clientRedis.hset('LiveConnect_pull',socket.uid,pkpull);
/* 更新 连麦关系 */
LiveConnect[socket.uid]=pkuid;
LiveConnect[pkuid]=socket.uid;
//console.log('LiveConnect');
//console.log(socket.uid)
//console.log(pkuid);
clientRedis.hset('LiveConnect',socket.uid,pkuid);
clientRedis.hset('LiveConnect',pkuid,socket.uid);
/* 更新数据库 */
var sign_data={uid:socket.uid,pkuid:pkuid,type:1};
var sign=setSign(sign_data);
request(config['WEBADDRESS']+"?service=Livepk.changeLive&uid="+socket.uid + "&pkuid=" + pkuid+ "&type=1&sign=" +sign,function(error, response, body){});
/* 发送连麦成功信息 */
/* 当前房间 */
var data_obj={
"msg":[
{
"_method_":"LiveConnect",
"action":"4",
"msgtype":"10",
"pkuid":""+pkuid,
"pkpull":""+LiveConnect_pull[pkuid],
"uid":""+socket.uid,
"uname":""+socket.nicename
}
],
"retcode":"000000",
"retmsg":"OK"
};
process_msg(io,socket.roomnum,JSON.stringify(data_obj));
/* 对方房间 */
var data_obj_pk={
"msg":[
{
"_method_":"LiveConnect",
"action":"4",
"msgtype":"10",
"pkuid":""+socket.uid,
"pkpull":""+LiveConnect_pull[socket.uid],
"uid":""+socket.uid,
"uname":""+socket.nicename
}
],
"retcode":"000000",
"retmsg":"OK"
};
process_msg(io,pkuid,JSON.stringify(data_obj_pk));
}else if(action=='5'){
/* 清除连麦信息 */
endLiveConnect(io,socket.uid);
}else{
var socket_pkuid=sockets[pkuid];
if(socket_pkuid){
socket_pkuid.emit('broadcastingListen',[data_str]);
} }
break;
} }
case 'SystemNot':{//系统通知 break;
process_msg(io,socket.roomnum,data_str); }
break; case 'LivePK':{//主播PK
} if(socket.roomnum != socket.uid){
case 'shangzhuang' :{//上、下庄 //非主播不能操作
process_msg(io,socket.roomnum,data_str); return !1;
break; }
} var uid=msg['uid'];
var pkuid=msg['pkuid'];
case 'startGame':{//炸金花游戏 //1：发起连麦；2；接受连麦;3:拒绝连麦;4：连麦成功通知;5.手动断开连麦;7:对方正忙碌 8:对方无响应; 9:PK结果
process_msg(io,socket.roomnum,data_str); if(action=='2'){
if(action==4) /* 更新PK状态 */
{ LivePK[socket.uid]=pkuid;
var time=msg['time']*1000; LivePK[pkuid]=socket.uid;
var gameid=msg['gameid'];
setTimeout(function() {//定时发送结果 LivePK_gift[socket.uid]=0;
request(config['WEBADDRESS']+"?service=Game.endGame&liveuid="+socket.uid + "&token=" + socket.token+ "&gameid=" + gameid+"&type=1",function(error, response, body){ LivePK_gift[pkuid]=0;
if(error) return;
var res = evalJson(body); //console.log('LivePK');
if( response.statusCode == 200 && res.data.code == 0){ //console.log(socket.uid);
var resObj = res.data.info; //console.log(pkuid);
dataObj['msg'][0]['ct'] = resObj;
dataObj['msg'][0]['_method_'] = "startGame"; clientRedis.hset('LivePK',socket.uid,pkuid);
dataObj['msg'][0]['action']="6"; clientRedis.hset('LivePK',pkuid,socket.uid);
var data_str2=JSON.stringify(dataObj);
process_msg(io,socket.roomnum,data_str2); clientRedis.hset('LivePK_gift',socket.uid,0);
} clientRedis.hset('LivePK_gift',pkuid,0);
});
}, time); /* 发送连麦成功信息 */
} /* 当前房间 */
break; var data_obj={
} "msg":[
case 'startRotationGame':{//转盘 {
process_msg(io,socket.roomnum,data_str); "_method_":"LivePK",
if(action==4) "action":"4",
{ "msgtype":"10",
var time=msg['time']*1000; "pkuid":""+pkuid,
var gameid=msg['gameid']; "uid":""+socket.uid,
setTimeout(function() {//定时发送结果 "uname":""+socket.nicename
request(config['WEBADDRESS']+"?service=Game.endGame&liveuid="+socket.uid + "&token=" + socket.token+ "&gameid=" + gameid+"&type=1",function(error, response, body){ }
if(error) return; ],
////console.log(body); "retcode":"000000",
var res = evalJson(body); "retmsg":"OK"
};
if( response.statusCode == 200 && res.data.code == 0){
var resObj = res.data.info; process_msg(io,socket.roomnum,JSON.stringify(data_obj));
dataObj['msg'][0]['ct'] = resObj; /* 对方房间 */
dataObj['msg'][0]['_method_'] = "startRotationGame"; var data_obj_pk={
dataObj['msg'][0]['action']="6"; "msg":[
var data_str2=JSON.stringify(dataObj); {
process_msg(io,socket.roomnum,data_str2); "_method_":"LivePK",
} "action":"4",
}); "msgtype":"10",
}, time); "pkuid":""+socket.uid,
} "uid":""+socket.uid,
break; "uname":""+socket.nicename
} }
case 'startCattleGame':{//开心牛仔 ],
process_msg(io,socket.roomnum,data_str); "retcode":"000000",
if(action==4) "retmsg":"OK"
{ };
var time=msg['time']*1000; process_msg(io,pkuid,JSON.stringify(data_obj_pk));
var gameid=msg['gameid'];
setTimeout(function() {//定时发送结果 clearTimeout(LivePK_timer[socket.uid]);
request(config['WEBADDRESS']+"?service=Game.endGame&liveuid="+socket.uid + "&token=" + socket.token+ "&gameid=" + gameid+"&type=1",function(error, response, body){
if(error) return; LivePK_timer[socket.uid]=null;
var res = evalJson(body);
var time=Math.floor( (new Date()).getTime()/1000);
if( response.statusCode == 200 && res.data.code == 0){ //console.log('LivePK_timer_'+socket.uid+'___'+pkuid);
var resObj = res.data.info; //console.log('LivePK_timer');
dataObj['msg'][0]['ct'] = resObj; //console.log(time);
dataObj['msg'][0]['_method_'] = "startCattleGame"; clientRedis.hset('LivePK_timer',socket.uid,time);
dataObj['msg'][0]['action']="6";
var data_str2=JSON.stringify(dataObj); LivePK_timer[socket.uid]=setTimeout(function() {//定时发送结果
process_msg(io,socket.roomnum,data_str2); endLivePk(io,socket.uid,0);
} }, 5*60*1000);
}); //5*60*1000
}, time);
} }else if(action=='5'){
break; /* 清除PK信息 */
} endLivePk(io,socket.uid,1);
case 'startLodumaniGame':{//海盗船长 }else{
process_msg(io,socket.roomnum,data_str); var socket_pkuid=sockets[pkuid];
if(action==4) if(socket_pkuid){
{ socket_pkuid.emit('broadcastingListen',[data_str]);
var time=msg['time']*1000; }
var gameid=msg['gameid']; //process_msg(io,pkuid,data_str);
setTimeout(function() {//定时发送结果 }
request(config['WEBADDRESS']+"?service=Game.endGame&liveuid="+socket.uid + "&token=" + socket.token+ "&gameid=" + gameid+"&type=1",function(error, response, body){ break;
if(error) return; }
var res = evalJson(body); case 'SystemNot':{//系统通知
process_msg(io,socket.roomnum,data_str);
if( response.statusCode == 200 && res.data.code == 0){ break;
var resObj = res.data.info; }
dataObj['msg'][0]['ct'] = resObj; case 'shangzhuang' :{//上、下庄
dataObj['msg'][0]['_method_'] = "startLodumaniGame"; process_msg(io,socket.roomnum,data_str);
dataObj['msg'][0]['action']="6"; break;
var data_str2=JSON.stringify(dataObj); }
process_msg(io,socket.roomnum,data_str2);
} case 'startGame':{//炸金花游戏
}); process_msg(io,socket.roomnum,data_str);
}, time); if(action==4)
} {
break; var time=msg['time']*1000;
} var gameid=msg['gameid'];
case 'startShellGame':{//二八贝 setTimeout(function() {//定时发送结果
process_msg(io,socket.roomnum,data_str); request(config['WEBADDRESS']+"?service=Game.endGame&liveuid="+socket.uid + "&token=" + socket.token+ "&gameid=" + gameid+"&type=1",function(error, response, body){
if(action==4) if(error) return;
{ var res = evalJson(body);
var time=msg['time']*1000; if( response.statusCode == 200 && res.data.code == 0){
var gameid=msg['gameid']; var resObj = res.data.info;
setTimeout(function() {//定时发送结果 dataObj['msg'][0]['ct'] = resObj;
request(config['WEBADDRESS']+"?service=Game.endGame&liveuid="+socket.uid + "&token=" + socket.token+ "&gameid=" + gameid+"&type=1",function(error, response, body){ dataObj['msg'][0]['_method_'] = "startGame";
if(error) return; dataObj['msg'][0]['action']="6";
var res = evalJson(body); var data_str2=JSON.stringify(dataObj);
if( response.statusCode == 200 && res.data.code == 0){ process_msg(io,socket.roomnum,data_str2);
var resObj = res.data.info; }
dataObj['msg'][0]['ct'] = resObj; });
dataObj['msg'][0]['_method_'] = "startShellGame"; }, time);
dataObj['msg'][0]['action']="6"; }
var data_str2=JSON.stringify(dataObj); break;
process_msg(io,socket.roomnum,data_str2); }
} case 'startRotationGame':{//转盘
}); process_msg(io,socket.roomnum,data_str);
}, time); if(action==4)
} {
break; var time=msg['time']*1000;
} var gameid=msg['gameid'];
case 'requestFans':{ setTimeout(function() {//定时发送结果
request(config['WEBADDRESS']+"?service=Live.getZombie&stream=" + socket.stream+"&uid=" + socket.uid,function(error, response, body){ request(config['WEBADDRESS']+"?service=Game.endGame&liveuid="+socket.uid + "&token=" + socket.token+ "&gameid=" + gameid+"&type=1",function(error, response, body){
if(error) return; if(error) return;
var res = evalJson(body); ////console.log(body);
if( response.statusCode == 200 && res.data.code == 0){ var res = evalJson(body);
var data_str2="{\"msg\":[{\"_method_\":\"requestFans\",\"action\":\"3\",\"ct\": "+ body + ",\"msgtype\":\"0\"}],\"retcode\":\"000000\",\"retmsg\":\"OK\"}";
process_msg(io,socket.roomnum,data_str2); if( response.statusCode == 200 && res.data.code == 0){
} var resObj = res.data.info;
}); dataObj['msg'][0]['ct'] = resObj;
dataObj['msg'][0]['_method_'] = "startRotationGame";
} dataObj['msg'][0]['action']="6";
var data_str2=JSON.stringify(dataObj);
} process_msg(io,socket.roomnum,data_str2);
} }
});
}); }, time);
}
socket.on('superadminaction',function(data){ break;
if(data['token'] == config['TOKEN']){ }
case 'startCattleGame':{//开心牛仔
process_msg(io,socket.roomnum,data_str);
if(action==4)
{
var time=msg['time']*1000;
var gameid=msg['gameid'];
setTimeout(function() {//定时发送结果
request(config['WEBADDRESS']+"?service=Game.endGame&liveuid="+socket.uid + "&token=" + socket.token+ "&gameid=" + gameid+"&type=1",function(error, response, body){
if(error) return;
var res = evalJson(body);
if( response.statusCode == 200 && res.data.code == 0){
var resObj = res.data.info;
dataObj['msg'][0]['ct'] = resObj;
dataObj['msg'][0]['_method_'] = "startCattleGame";
dataObj['msg'][0]['action']="6";
var data_str2=JSON.stringify(dataObj);
process_msg(io,socket.roomnum,data_str2);
}
});
}, time);
}
break;
}
case 'startLodumaniGame':{//海盗船长
process_msg(io,socket.roomnum,data_str);
if(action==4)
{
var time=msg['time']*1000;
var gameid=msg['gameid'];
setTimeout(function() {//定时发送结果
request(config['WEBADDRESS']+"?service=Game.endGame&liveuid="+socket.uid + "&token=" + socket.token+ "&gameid=" + gameid+"&type=1",function(error, response, body){
if(error) return;
var res = evalJson(body);
if( response.statusCode == 200 && res.data.code == 0){
var resObj = res.data.info;
dataObj['msg'][0]['ct'] = resObj;
dataObj['msg'][0]['_method_'] = "startLodumaniGame";
dataObj['msg'][0]['action']="6";
var data_str2=JSON.stringify(dataObj);
process_msg(io,socket.roomnum,data_str2);
}
});
}, time);
}
break;
}
case 'startShellGame':{//二八贝
process_msg(io,socket.roomnum,data_str);
if(action==4)
{
var time=msg['time']*1000;
var gameid=msg['gameid'];
setTimeout(function() {//定时发送结果
request(config['WEBADDRESS']+"?service=Game.endGame&liveuid="+socket.uid + "&token=" + socket.token+ "&gameid=" + gameid+"&type=1",function(error, response, body){
if(error) return;
var res = evalJson(body);
if( response.statusCode == 200 && res.data.code == 0){
var resObj = res.data.info;
dataObj['msg'][0]['ct'] = resObj;
dataObj['msg'][0]['_method_'] = "startShellGame";
dataObj['msg'][0]['action']="6";
var data_str2=JSON.stringify(dataObj);
process_msg(io,socket.roomnum,data_str2);
}
});
}, time);
}
break;
}
case 'requestFans':{
request(config['WEBADDRESS']+"?service=Live.getZombie&stream=" + socket.stream+"&uid=" + socket.uid,function(error, response, body){
if(error) return;
var res = evalJson(body);
if( response.statusCode == 200 && res.data.code == 0){
var data_str2="{\"msg\":[{\"_method_\":\"requestFans\",\"action\":\"3\",\"ct\": "+ body + ",\"msgtype\":\"0\"}],\"retcode\":\"000000\",\"retmsg\":\"OK\"}";
process_msg(io,socket.roomnum,data_str2);
}
});
}
}
}
});
socket.on('superadminaction',function(data){
if(data['token'] == config['TOKEN']){
io.sockets.in(data['roomnum']).emit("broadcastingListen", ['stopplay']); io.sockets.in(data['roomnum']).emit("broadcastingListen", ['stopplay']);
} }
}); });
/* 系统信息 */ /* 系统信息 */
socket.on('systemadmin',function(data){ socket.on('systemadmin',function(data){
if(data['token'] == config['TOKEN']){ if(data['token'] == config['TOKEN']){
var data_obj={ var data_obj={
"msg":[
{
"_method_":"SystemNot",
"action":"1",
"ct":''+ data.content,
"msgtype":"4"
}
],
"retcode":"000000",
"retmsg":"OK"
};
io.emit('broadcastingListen',[JSON.stringify(data_obj)]);
}
});
//资源释放
socket.on('disconnect', function() {
/* numscount--;
if(numscount<0){
numscount=0;
} */
if(socket.roomnum ==null || socket.token==null || socket.uid <=0){
return !1;
}
d.run(function() {
/* 用户连麦 */
clientRedis.hget('ShowVideo',socket.roomnum,function(error,res){
if(error){
return !1;
}
if(!res){
return !1;
}
var res_j=JSON.parse(res);
if( socket.uid == res_j['uid'] || socket.uid == socket.roomnum ){
clientRedis.hdel('ShowVideo',socket.roomnum);
var data_obj={
"msg":[
{
"_method_":"ConnectVideo",
"action":"5",
"msgtype":"10",
"uid":""+socket.uid,
"uname":""+socket.nicename
}
],
"retcode":"000000",
"retmsg":"OK"
};
process_msg(io,socket.roomnum,JSON.stringify(data_obj));
}
});
if(socket.roomnum==socket.uid){
/* 主播 */
if(socket.reusing==0){
request(config['WEBADDRESS']+"?service=Live.stopRoom&uid="+socket.uid + "&token=" + socket.token+ "&type=1&stream=" + socket.stream,function(error, response, body){
console.log(body);
});
var data_obj={
"retmsg":"ok",
"retcode":"000000",
"msg":[
{
"msgtype":"1",
"_method_":"StartEndLive",
"action":"18",
"ct":"直播关闭"
}
]
};
process_msg(io,socket.roomnum,JSON.stringify(data_obj));
endLiveConnect(io,socket.uid);
}
}else{
/* 观众 */
clientRedis.zrem('user_'+socket.stream,socket.uid,function(error,res){
if(error) return;
if(res){
var data_obj={
"msg":[ "msg":[
{ {
"_method_":"SystemNot", "_method_":"disconnect",
"action":"1", "action":"1",
"ct":''+ data.content, "ct":{
"msgtype":"4" "id":''+socket.uid,
"user_nicename":''+socket.nicename,
"avatar":socket.avatar,
"level":''+socket.level
},
"msgtype":"0",
"uid":''+socket.uid,
"uname":socket.nicename
} }
], ],
"retcode":"000000", "retcode":"000000",
"retmsg":"OK" "retmsg":"OK"
}; };
io.emit('broadcastingListen',[JSON.stringify(data_obj)]); process_msg(io,socket.roomnum,JSON.stringify(data_obj));
}
});
//资源释放
socket.on('disconnect', function() {
/* numscount--;
if(numscount<0){
numscount=0;
} */
if(socket.roomnum ==null || socket.token==null || socket.uid <=0){
return !1;
}
d.run(function() {
/* 用户连麦 */
clientRedis.hget('ShowVideo',socket.roomnum,function(error,res){
if(error){
return !1;
} }
if(!res){
return !1;
}
var res_j=JSON.parse(res);
if( socket.uid == res_j['uid'] || socket.uid == socket.roomnum ){
clientRedis.hdel('ShowVideo',socket.roomnum);
var data_obj={
"msg":[
{
"_method_":"ConnectVideo",
"action":"5",
"msgtype":"10",
"uid":""+socket.uid,
"uname":""+socket.nicename
}
],
"retcode":"000000",
"retmsg":"OK"
};
process_msg(io,socket.roomnum,JSON.stringify(data_obj));
}
});
if(socket.roomnum==socket.uid){
/* 主播 */
if(socket.reusing==0){
request(config['WEBADDRESS']+"?service=Live.stopRoom&uid="+socket.uid + "&token=" + socket.token+ "&type=1&stream=" + socket.stream,function(error, response, body){
console.log(body);
});
var data_obj={
"retmsg":"ok",
"retcode":"000000",
"msg":[
{
"msgtype":"1",
"_method_":"StartEndLive",
"action":"18",
"ct":"直播关闭"
}
]
};
process_msg(io,socket.roomnum,JSON.stringify(data_obj));
endLiveConnect(io,socket.uid); });
}
}
////console.log(socket.roomnum+"==="+socket.token+"===="+socket.uid+"======"+socket.stream);
}else{ socket.leave(socket.roomnum);
/* 观众 */ delete io.sockets.sockets[socket.id];
clientRedis.zrem('user_'+socket.stream,socket.uid,function(error,res){ sockets[socket.uid] = null;
if(error) return; delete sockets[socket.uid];
if(res){
var data_obj={ });
"msg":[ });
{
"_method_":"disconnect",
"action":"1",
"ct":{
"id":''+socket.uid,
"user_nicename":''+socket.nicename,
"avatar":socket.avatar,
"level":''+socket.level
},
"msgtype":"0",
"uid":''+socket.uid,
"uname":socket.nicename
}
],
"retcode":"000000",
"retmsg":"OK"
};
process_msg(io,socket.roomnum,JSON.stringify(data_obj));
}
});
}
////console.log(socket.roomnum+"==="+socket.token+"===="+socket.uid+"======"+socket.stream);
socket.leave(socket.roomnum);
delete io.sockets.sockets[socket.id];
sockets[socket.uid] = null;
delete sockets[socket.uid];
});
});
}); });
function sendSystemMsg(socket,msg){ function sendSystemMsg(socket,msg){
let msg2 = encodeURIComponent(msg);//安卓端自动urlencode let msg2 = encodeURIComponent(msg);//安卓端自动urlencode
//let msg2 = msg; //let msg2 = msg;
var data_obj={ var data_obj={
"msg":[ "msg":[
{ {
"_method_":"SystemNot", "_method_":"SystemNot",
"action":"1", "action":"1",
"ct":""+ msg2, "ct":""+ msg2,
"msgtype":"4" "msgtype":"4"
} }
], ],
"retcode":"000000", "retcode":"000000",
"retmsg":"OK" "retmsg":"OK"
}; };
socket.emit('broadcastingListen',[JSON.stringify(data_obj)]); socket.emit('broadcastingListen',[JSON.stringify(data_obj)]);
} }
function evalJson(data){ function evalJson(data){
return eval("("+data+")"); return eval("("+data+")");
} }
function process_msg(io,roomnum,data){ function process_msg(io,roomnum,data){
if(!chat_history[roomnum]){ if(!chat_history[roomnum]){
chat_history[roomnum]=[]; chat_history[roomnum]=[];
} }
chat_history[roomnum].push(data); chat_history[roomnum].push(data);
chat_interval[roomnum] || (chat_interval[roomnum]=setInterval(function(){ chat_interval[roomnum] || (chat_interval[roomnum]=setInterval(function(){
if(chat_history[roomnum].length>0){ if(chat_history[roomnum].length>0){
send_msg(io,roomnum); send_msg(io,roomnum);
}else{ }else{
clearInterval(chat_interval[roomnum]); clearInterval(chat_interval[roomnum]);
chat_interval[roomnum]=null; chat_interval[roomnum]=null;
} }
},200)); },200));
} }
function send_msg(io,roomnum){ function send_msg(io,roomnum){
var data=chat_history[roomnum].splice(0,chat_history[roomnum].length); var data=chat_history[roomnum].splice(0,chat_history[roomnum].length);
io.sockets.in(roomnum).emit("broadcastingListen", data); io.sockets.in(roomnum).emit("broadcastingListen", data);
} }
/* 主播连麦结束处理 */ /* 主播连麦结束处理 */
function endLiveConnect(io,uid){ function endLiveConnect(io,uid){
if(LivePK_timer[uid]){ if(LivePK_timer[uid]){
clearTimeout(LivePK_timer[uid]); clearTimeout(LivePK_timer[uid]);
LivePK_timer[uid]=null; LivePK_timer[uid]=null;
} }
var pkuid=LiveConnect[uid]; var pkuid=LiveConnect[uid];
if(!pkuid || pkuid<=0){ if(!pkuid || pkuid<=0){
pkuid=0; pkuid=0;
} }
/* 更新数据库 */ /* 更新数据库 */
var sign_data={uid:uid,pkuid:pkuid,type:0}; var sign_data={uid:uid,pkuid:pkuid,type:0};
var sign=setSign(sign_data); var sign=setSign(sign_data);
request(config['WEBADDRESS']+"?service=Livepk.changeLive&uid="+uid + "&pkuid=" + pkuid+ "&type=0&sign=" +sign,function(error, response, body){}); request(config['WEBADDRESS']+"?service=Livepk.changeLive&uid="+uid + "&pkuid=" + pkuid+ "&type=0&sign=" +sign,function(error, response, body){});
LiveConnect[uid]=0; LiveConnect[uid]=0;
LiveConnect[pkuid]=0; LiveConnect[pkuid]=0;
// console.log('endLiveConnect'); // console.log('endLiveConnect');
// console.log(uid); // console.log(uid);
// console.log(pkuid); // console.log(pkuid);
clientRedis.hset('LiveConnect',uid,0); clientRedis.hset('LiveConnect',uid,0);
clientRedis.hset('LiveConnect',pkuid,0); clientRedis.hset('LiveConnect',pkuid,0);
if(LivePK_timer[pkuid]){ if(LivePK_timer[pkuid]){
clearTimeout(LivePK_timer[pkuid]); clearTimeout(LivePK_timer[pkuid]);
LivePK_timer[pkuid]=null; LivePK_timer[pkuid]=null;
} }
/* 清除PK信息 */ /* 清除PK信息 */
LivePK[uid]=0; LivePK[uid]=0;
LivePK[pkuid]=0; LivePK[pkuid]=0;
LivePK_gift[uid]=0; LivePK_gift[uid]=0;
LivePK_gift[pkuid]=0; LivePK_gift[pkuid]=0;
clientRedis.hset('LivePK',uid,0); clientRedis.hset('LivePK',uid,0);
clientRedis.hset('LivePK',pkuid,0); clientRedis.hset('LivePK',pkuid,0);
clientRedis.hset('LivePK_gift',uid,0); clientRedis.hset('LivePK_gift',uid,0);
clientRedis.hset('LivePK_gift',pkuid,0); clientRedis.hset('LivePK_gift',pkuid,0);
var data_obj={ var data_obj={
"msg":[ "msg":[
{ {
"_method_":"LiveConnect", "_method_":"LiveConnect",
"action":"5", "action":"5",
"msgtype":"10", "msgtype":"10",
"uid":""+uid, "uid":""+uid,
"uname":"" "uname":""
} }
], ],
"retcode":"000000", "retcode":"000000",
"retmsg":"OK" "retmsg":"OK"
}; };
process_msg(io,uid,JSON.stringify(data_obj)); process_msg(io,uid,JSON.stringify(data_obj));
process_msg(io,pkuid,JSON.stringify(data_obj)); process_msg(io,pkuid,JSON.stringify(data_obj));
} }
/* PK结束处理 */ /* PK结束处理 */
function endLivePk(io,uid,type){ function endLivePk(io,uid,type){
if(LivePK_timer[uid]){ if(LivePK_timer[uid]){
clearTimeout(LivePK_timer[uid]); clearTimeout(LivePK_timer[uid]);
LivePK_timer[uid]=null; LivePK_timer[uid]=null;
} }
clientRedis.hdel('LivePK_timer',uid); clientRedis.hdel('LivePK_timer',uid);
var win_uid=0; var win_uid=0;
var pkuid=LivePK[uid]; var pkuid=LivePK[uid];
if(!pkuid || pkuid<=0){ if(!pkuid || pkuid<=0){
...@@ -1052,12 +1052,12 @@ function endLivePk(io,uid,type){ ...@@ -1052,12 +1052,12 @@ function endLivePk(io,uid,type){
} }
var end_gift_uid=LivePK_gift[uid]; var end_gift_uid=LivePK_gift[uid];
var end_gift_pkuid=LivePK_gift[pkuid]; var end_gift_pkuid=LivePK_gift[pkuid];
if(LivePK_timer[pkuid]){ if(LivePK_timer[pkuid]){
clearTimeout(LivePK_timer[pkuid]); clearTimeout(LivePK_timer[pkuid]);
LivePK_timer[pkuid]=null; LivePK_timer[pkuid]=null;
} }
if(type==1){ if(type==1){
win_uid=pkuid; win_uid=pkuid;
}else if(end_gift_uid > end_gift_pkuid){ }else if(end_gift_uid > end_gift_pkuid){
...@@ -1065,14 +1065,14 @@ function endLivePk(io,uid,type){ ...@@ -1065,14 +1065,14 @@ function endLivePk(io,uid,type){
}else if(end_gift_uid < end_gift_pkuid){ }else if(end_gift_uid < end_gift_pkuid){
win_uid=pkuid; win_uid=pkuid;
} }
/* 清除PK信息 */ /* 清除PK信息 */
LivePK[uid]=0; LivePK[uid]=0;
LivePK[pkuid]=0; LivePK[pkuid]=0;
LivePK_gift[uid]=0; LivePK_gift[uid]=0;
LivePK_gift[pkuid]=0; LivePK_gift[pkuid]=0;
// console.log('endLivePk'); // console.log('endLivePk');
// console.log(type); // console.log(type);
// console.log(uid); // console.log(uid);
...@@ -1081,38 +1081,38 @@ function endLivePk(io,uid,type){ ...@@ -1081,38 +1081,38 @@ function endLivePk(io,uid,type){
// console.log(time); // console.log(time);
// console.log(end_gift_uid); // console.log(end_gift_uid);
// console.log(end_gift_pkuid); // console.log(end_gift_pkuid);
clientRedis.hset('LivePK',uid,0); clientRedis.hset('LivePK',uid,0);
clientRedis.hset('LivePK',pkuid,0); clientRedis.hset('LivePK',pkuid,0);
clientRedis.hset('LivePK_gift',uid,0); clientRedis.hset('LivePK_gift',uid,0);
clientRedis.hset('LivePK_gift',pkuid,0); clientRedis.hset('LivePK_gift',pkuid,0);
var data_obj={ var data_obj={
"msg":[ "msg":[
{ {
"_method_":"LivePK", "_method_":"LivePK",
"action":"9", "action":"9",
"msgtype":"10", "msgtype":"10",
"win_uid":""+win_uid, "win_uid":""+win_uid,
"uid":""+uid, "uid":""+uid,
"uname":"" "uname":""
} }
], ],
"retcode":"000000", "retcode":"000000",
"retmsg":"OK" "retmsg":"OK"
}; };
process_msg(io,uid,JSON.stringify(data_obj)); process_msg(io,uid,JSON.stringify(data_obj));
process_msg(io,pkuid,JSON.stringify(data_obj)); process_msg(io,pkuid,JSON.stringify(data_obj));
} }
//时间格式化 //时间格式化
function FormatNowDate(){ function FormatNowDate(){
var mDate = new Date(); var mDate = new Date();
var H = mDate.getHours(); var H = mDate.getHours();
var i = mDate.getMinutes(); var i = mDate.getMinutes();
var s = mDate.getSeconds(); var s = mDate.getSeconds();
return H + ':' + i + ':' + s; return H + ':' + i + ':' + s;
} }
/* sign加密 */ /* sign加密 */
...@@ -1126,7 +1126,7 @@ function setSign(obj) {//排序的函数 ...@@ -1126,7 +1126,7 @@ function setSign(obj) {//排序的函数
str+=newkey[i]+'='+obj[newkey[i]]+'&'; str+=newkey[i]+'='+obj[newkey[i]]+'&';
} }
str+=config['sign_key']; str+=config['sign_key'];
var sign=md5(str); var sign=md5(str);
return sign; return sign;
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment