//引入http模块 var socketio = require('socket.io'), fs = require('fs'), https = require('https'), domain = require('domain'), redis = require('redis'), redisio = require('socket.io-redis'), request = require('request'), md5 = require('md5-node'), config = require('./config.js'); var d = domain.create(); d.on("error", function(err) { // console.log(err); }); //var numscount=0;// 在线人数统计 var sockets = {}; var chat_history={}; var chat_interval={}; /* 主播连麦关系 */ var LiveConnect={}; var LiveConnect_pull={}; var options = { key:fs.readFileSync('/www/server/panel/vhost/cert/yjzb.yunchao2u.com/privkey.key'), cert:fs.readFileSync('/www/server/panel/vhost/cert/yjzb.yunchao2u.com/fullchain.pem') }; // redis 链接 var clientRedis = redis.createClient(config['REDISPORT'],config['REDISHOST']); clientRedis.auth(config['REDISPASS']); var server = https.createServer(options,function(req, res) { // var server = https.createServer(function(req, res) { res.writeHead(200, { 'Content-type': 'text/html;charset=utf-8' }); //res.write("人数: " + numscount ); res.end(); }).listen(config['socket_port'], function() { ////console.log('服务开启19965'); }); var io = socketio.listen(server,{ pingTimeout: 60000, pingInterval: 25000 }); /* var pub = 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 })); */ //setInterval(function(){ //global.gc(); ////console.log('GC done') //}, 1000*30); io.on('connection', function(socket) { //console.log('连接成功'); //numscount++; var interval; //进入房间 socket.on('conn', function(data) { if(!data || !data.token){ return !1; } userid=data.uid; old_socket = sockets[userid]; if (old_socket && old_socket != socket) { if(data.uid != data.roomnum && data.uid==old_socket.roomnum){ /* 进房间 但旧链接是 主播 */ var data_str='{"retmsg":"ok","retcode":"000000","msg":[{"msgtype":"1","_method_":"StartEndLive","action":"19","ct":"直播关闭"}]}'; old_socket.emit('broadcastingListen',[data_str]); }else if(data.uid== data.roomnum && data.stream==old_socket.stream){ /* 主播重连 */ old_socket.reusing = 1; //console.log("重用"); }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":"直播关闭"}]}'; old_socket.emit('broadcastingListen',[data_str]); } old_socket.disconnect() } clientRedis.get(data.token,function(error,res){ if(error){ return; }else if(res==null){ //console.log("[获取token失败]"+data.uid); }else{ if(res != null){ var userInfo = evalJson(res); if(userInfo['id'] == data.uid ){ //console.log("[初始化验证成功]--"+data.uid+"---"+data.roomnum+'---'+data.stream); //获取验证token socket.token = data.token; socket.roomnum = data.roomnum; socket.stream = data.stream; socket.nicename = userInfo['user_nickname']; socket.avatar = userInfo['avatar']; socket.sign = Number(userInfo['sign']); socket.usertype = parseInt(userInfo['usertype']); socket.uid = data.uid; socket.reusing = 0; socket.join(data.roomnum); sockets[userid] = socket; socket.emit('conn',['ok']); if( socket.roomnum!=socket.uid && socket.uid >0 ){ var data_obj={ "msg":[ { "_method_":"SendMsg", "action":"0", "ct":{ "id":''+userInfo['id'], "user_nickname":''+userInfo['user_nickname'], "avatar":userInfo['avatar'], "avatar_thumb":userInfo['avatar_thumb'], "usertype":''+userInfo['usertype'], "guard_type":''+userInfo['guard_type'], "contribution":''+userInfo['contribution'], }, "msgtype":"0" } ], "retcode":"000000", "retmsg":"OK" }; process_msg(io,socket.roomnum,JSON.stringify(data_obj)); if(socket.stream){ clientRedis.zadd('user_'+socket.stream,socket.sign,userInfo['id']); } } //sendSystemMsg(socket,"直播内容包含任何低俗、暴露和涉黄内容，账号会被封禁；安全部门会24小时巡查哦～"); var stemMgs='直播内容包含任何低俗、暴露和涉黄内容，账号会被封禁；安全部门会24小时巡查哦～'; if(userInfo['lang']=='en'){ stemMgs='If the live content contains any vulgar, explicit, or pornographic content, the account will be banned; The security department will conduct 24-hour inspections~'; } sendSystemMsg(socket,stemMgs); return; }else{ socket.disconnect(); } } } socket.emit('conn',['no']); }); }); socket.on('broadcast',function(data){ ////console.log(data); if(socket.token != undefined){ var dataObj = typeof data == 'object'?data:evalJson(data); //console.log('==================='+data); var msg = dataObj['msg'][0]; var token = dataObj['token']; var method = msg['_method_']; var action = msg['action']; var data_str = typeof data == 'object'?JSON.stringify(data):data; switch(method){ case 'SendMsg':{ //聊天 //sendSystemMsg(socket,"直播内容包含任何低俗、暴露和涉黄内容，账号会被封禁；安全部门会24小时巡查哦～"); clientRedis.hget( "super",socket.uid,function(error,res){ if(error) return; if(res != null){ var data_str2={ "msg":[ { "_method_":"SystemNot", "action":"1", "ct":''+dataObj['msg'][0]['ct'], "msgtype":"4" } ], "retcode":"000000", "retmsg":"OK" }; 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 ifpk='0', pkuid1='0', pkuid2='0', pktotal1='0', pktotal2='0'; //console.log('SendGift'); //console.log(resObj); if(resObj['ispk']==1 ){ ifpk='1'; pkuid1=''+resObj['pkuid1']; pkuid2=''+resObj['pkuid2']; pktotal1=''+resObj['pktotal1']; pktotal2=''+resObj['pktotal2']; //console.log('pk'); } 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; dataObj['msg'][0]['roomnum']=socket.roomnum; console.log('---------礼物信息--------------------'+[JSON.stringify(dataObj)]); io.sockets.in(socket.roomnum).emit('broadcastingListen',[JSON.stringify(dataObj)]); if(pkuid2>0){ io.sockets.in(pkuid2).emit('broadcastingListen',[JSON.stringify(dataObj)]); } clientRedis.del(gifToken); } }); 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 if(action=='2'){ //console.log('主播同意连麦'); var touid=msg['touid']; //console.log(touid); request(config['WEBADDRESS']+"?service=Live.showVideo&uid="+socket.uid + "&token=" + socket.token+ "&touid="+touid+"&pull_url=''",function(error, response, body){ //console.log('showVideo'); //console.log(body); }); 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 '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,data_str); } }); break; } case 'ResumeUser' :{//恢复发言 if(socket.usertype == 50 || socket.usertype == 40){ process_msg(io,socket.roomnum,data_str); } break; } case 'setAdmin' :{//设置/取消管理员 //console.log(data_str); //console.log(socket.usertype); if(socket.usertype == 50 ){ process_msg(io,socket.roomnum,data_str); } break; } case 'StartEndLive':{ if(socket.usertype == 50 ){ socket.broadcast.to(socket.roomnum).emit('broadcastingListen',[data_str]); }else{ 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]); } }) } break; } case 'BuyGuard':{//购买守护 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']; //1：发起连麦；2；接受连麦;3:拒绝连麦;4：连麦成功通知;5.手动断开连麦;7:对方正忙碌 8:对方无响应 9:主播繁忙（游戏） if(action=='1'){ console.log('发起连麦1'); console.log(FormatNowDate()); console.log(socket.uid+'---'+pkuid); console.log(pkpull); console.log('LiveConnect_pull--'+socket.uid+'-----'+pkpull); LiveConnect_pull[socket.uid]=pkpull; clientRedis.hset('LiveConnect_pull',socket.uid,pkpull); } if(action=='2'){ console.log('接受连麦1'); console.log(FormatNowDate()); console.log(socket.uid+'---'+pkuid); console.log(pkpull); console.log('LiveConnect_pull--'+socket.uid+'-----'+pkpull); LiveConnect_pull[socket.uid]=pkpull; clientRedis.hset('LiveConnect_pull',socket.uid,pkpull); /* 更新数据库 */ 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){ // console.log('changeLive'); // console.log(body); if(error) return; // 获取房间所有成员并通知 getRoomMembers(socket.uid, function(members) { console.log('members'); members = members.filter((element) => element !== ""); console.log(members); console.log(members.length); if(members.length >0){ notifyRoomMembers(io, members, socket.uid, pkuid, 'join'); }else{ console.log('1vs1'); /* 发送连麦成功信息 */ /* 当前房间 */ 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" }; // console.log(data_obj); 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" }; // console.log(data_obj_pk); process_msg(io,pkuid,JSON.stringify(data_obj_pk)); } }); }); }else if(action=='5'){ //主播和主播断开连麦 /* 清除连麦信息 */ //console.log('endLiveConnect--action--5'); // endLiveConnect(io,socket.uid); /* 清除连麦信息并处理房间 */ endLiveConnectWithRoom(io, socket.uid); }else{ var socket_pkuid=sockets[pkuid]; if(socket_pkuid){ socket_pkuid.emit('broadcastingListen',[data_str]); } } break; } case 'LivePK':{//主播PK console.log("----------------主播PK------------"+data_str); if(socket.roomnum != socket.uid){ //非主播不能操作 return !1; } var uid=msg['uid']; var pkuid=msg['pkuid']; //1：发起连麦；2；接受连麦;3:拒绝连麦;4：连麦成功通知;5.手动断开连麦;7:对方正忙碌 8:对方无响应; 9:PK结果 if(action=='1'){ console.log('发起PK'); console.log(FormatNowDate()); console.log(socket.uid+'---'+pkuid); } if(action=='2'){ /* 更新PK状态 */ console.log('LivePK'); console.log(socket.uid); console.log(pkuid); console.log('开始PK'); console.log(FormatNowDate()); console.log(socket.uid+'---'+pkuid); var sign_data={uid:socket.uid,pkuid:pkuid}; var sign=setSign(sign_data); request(config['WEBADDRESS']+"?service=Livepk.setPK&uid="+socket.uid + "&pkuid=" + pkuid+ "&sign=" +sign,function(error, response, body){ if(error) return; // console.log('setPK'); // console.log(body); var res = evalJson(body); if( response.statusCode == 200 && res.data.code == 0){ var info = res.data.info[0]; // console.log('info'); // console.log(info); /* 发送连麦成功信息 */ /* 当前房间 */ 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)); setTimeout(function() {//定时发送结果 // console.log('计时器'); // console.log(FormatNowDate()); // console.log('uid---'+socket.uid); endLivePk(io,socket.uid,0,info['addtime']); }, 5*60*1000); } }); }else if(action=='5'){ /* 清除PK信息 */ // console.log('endLivePk --action--5'); // console.log(FormatNowDate()); endLivePk(io,socket.uid,1,0); }else{ var socket_pkuid=sockets[pkuid]; if(socket_pkuid){ socket_pkuid.emit('broadcastingListen',[data_str]); } //process_msg(io,pkuid,data_str); } break; } case 'goodsLiveShow' :{//商品在直播间展示/不展示 process_msg(io,socket.roomnum,data_str); break; } case 'SystemNot':{//系统通知 process_msg(io,socket.roomnum,data_str); 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); } }); } case 'SystemWarning':{//警告通知 process_msg(io,socket.roomnum,data_str); break; } } } }); /*封禁通知*/ socket.on('LiveBanadmin',function(data){ if(data['token'] == config['TOKEN']){ var data_obj={ "retmsg":"ok", "retcode":"000000", "msg":[ { "msgtype":"1", "_method_":"stopLive", "action":"1", "uid":"0", "ct":''+ data['content'], } ] }; process_msg(io,data['roomnum'],JSON.stringify(data_obj)); } }); /*警告通知*/ socket.on('warningadmin',function(data){ if(data['token'] == config['TOKEN']){ var data_obj={ "retmsg":"ok", "retcode":"000000", "msg":[ { "msgtype":"1", "_method_":"SystemWarning", "action":"1", "ct":''+ data['content'], } ] }; process_msg(io,data['roomnum'],JSON.stringify(data_obj)); } }); /*关播通知*/ socket.on('superadminaction',function(data){ //console.log(data['token']); //console.log(config['TOKEN']); if(data['token'] == config['TOKEN']){ var data_obj={ "retmsg":"ok", "retcode":"000000", "msg":[ { "msgtype":"1", "_method_":"stopLive", "action":"1", "uid":"0", "ct":''+ data['content'], } ] }; process_msg(io,data['roomnum'],JSON.stringify(data_obj)); /* io.sockets.in(data['roomnum']).emit("broadcastingListen", ['stopplay']); */ } }); /* 系统信息 */ socket.on('systemadmin',function(data){ if(data['token'] == config['TOKEN']){ 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){ //console.log("主播socket断开"); /* 主播 */ if(socket.reusing==0){ //console.log("请求关播接口"); //console.log(config['WEBADDRESS']+"?service=Live.stopRoom&uid="+socket.uid + "&token=" + socket.token+ "&type=1&stream=" + socket.stream); request(config['WEBADDRESS']+"?service=Live.stopRoom&uid="+socket.uid + "&token=" + socket.token+ "&type=1&stream=" + socket.stream,function(error, response, body){ //console.log("error:"+error); var data_obj={ "retmsg":"ok", "retcode":"000000", "msg":[ { "msgtype":"1", "_method_":"StartEndLive", "action":"18", "ct":"直播关闭" } ] }; process_msg(io,socket.roomnum,JSON.stringify(data_obj)); // console.log('关播'); // console.log(FormatNowDate()); // console.log('uid---'+socket.uid); }); endLiveConnect(io,socket.uid); } }else{ /* 观众 */ clientRedis.zrem('user_'+socket.stream,socket.uid,function(error,res){ if(error) return; if(res){ //用于每日任务--用户观看直播时长统计 request(config['WEBADDRESS']+"?service=Live.signOutWatchLive&uid="+socket.uid + "&token=" + socket.token,function(error, response, body){}); var data_obj={ "msg":[ { "_method_":"disconnect", "action":"1", "ct":{ "id":''+socket.uid, "user_nickname":''+socket.nicename, "avatar":socket.avatar }, "msgtype":"0", "uid":''+socket.uid, "uname":socket.nicename } ], "retcode":"000000", "retmsg":"OK" }; //console.log(JSON.stringify(data_obj)); 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 getRoomMembers(uid, callback) { clientRedis.hget('LiveRoomMaster', uid, function(error, room_id) { console.log('room_id-' + room_id) if(error || !room_id) { callback([]); return; } clientRedis.hget('LiveRoom', room_id, function(error, members_str) { if(error || !members_str) { callback([]); return; } var members = members_str.split(','); callback(members); }); }); } // 通知房间所有成员 function notifyRoomMembers(io, members, new_uid, inviter_uid, action) { var msg_data = { "_method_": "LiveConnect", "action": "4", "msgtype": "10", "room_members": members, "new_uid": new_uid, "inviter_uid": inviter_uid, "action_type": action }; var data_obj = { "msg": [msg_data], "retcode": "000000", "retmsg": "OK" }; // 通知房间内所有成员 members.forEach(function(member_uid) { console.log('member_uid--'+ member_uid + '--new_uid' + new_uid) if(member_uid) { // 获取该成员的拉流地址 console.log('member_uid--'+ member_uid ) clientRedis.hget('LiveConnect_pull', member_uid, function(error, pull_url) { console.log('member_uid2--'+ member_uid) console.log('pull_url--'+ pull_url) var member_msg = Object.assign({}, msg_data); member_msg.pkuid = member_uid; member_msg.pkpull = pull_url || ''; console.log('member_msg--'+ JSON.stringify(member_msg)) var member_data_obj = { "msg": [member_msg], "retcode": "000000", "retmsg": "OK" }; console.log('member_data_obj--'+ JSON.stringify(member_data_obj)) process_msg(io, new_uid, JSON.stringify(member_data_obj)); }); } // 通知该成员房间有新人加入 process_msg(io, member_uid, JSON.stringify(data_obj)); }); } // 扩展的结束连麦处理 function endLiveConnectWithRoom(io, uid) { // 获取房间信息 clientRedis.hget('LiveRoomMaster', uid, function(error, room_id) { if(error || !room_id) { // 没有房间信息，使用原有逻辑 endLiveConnect(io, uid); return; } // 获取房间成员 clientRedis.hget('LiveRoom', room_id, function(error, members_str) { if(error || !members_str) { endLiveConnect(io, uid); return; } var members = members_str.split(','); // 通知房间成员有人离开 var leave_msg = { "_method_": "LiveConnect", "action": "5", "msgtype": "10", "leave_uid": uid, "room_members": members.filter(m => m != uid) }; var leave_data_obj = { "msg": [leave_msg], "retcode": "000000", "retmsg": "OK" }; members.forEach(function(member_uid) { if(member_uid != uid) { process_msg(io, member_uid, JSON.stringify(leave_data_obj)); } }); // 调用原有的结束连麦逻辑 endLiveConnect(io, uid); }); }); } function sendSystemMsg(socket,msg){ var data_obj={ "msg":[ { "_method_":"SystemNot", "action":"1", "ct":""+ msg, "msgtype":"4" } ], "retcode":"000000", "retmsg":"OK" }; socket.emit('broadcastingListen',[JSON.stringify(data_obj)]); } function evalJson(data){ // return eval("("+data+")"); try { if(!data || typeof data !== 'string') { return null; } return eval("("+data+")"); } catch(e) { console.log('JSON解析错误:', e.message, '数据:', data.substring(0, 100)); return null; } } function process_msg(io,roomnum,data){ if(!chat_history[roomnum]){ chat_history[roomnum]=[]; } chat_history[roomnum].push(data); chat_interval[roomnum] || (chat_interval[roomnum]=setInterval(function(){ if(chat_history[roomnum].length>0){ send_msg(io,roomnum); }else{ clearInterval(chat_interval[roomnum]); chat_interval[roomnum]=null; } },200)); } function send_msg(io,roomnum){ var data=chat_history[roomnum].splice(0,chat_history[roomnum].length); io.sockets.in(roomnum).emit("broadcastingListen", data); } /* 主播连麦结束处理 */ function endLiveConnect(io,uid){ //console.log('结束连麦'); //console.log(FormatNowDate()); //console.log('uid--'+uid); clientRedis.hget('LiveConnect',uid,function(error,res){ //console.log('res'); if(error){ return !1; } if(!res){ return !1; } var pkuid=res; //console.log('pkuid---'+pkuid); /* 更新数据库 */ var sign_data={uid:uid,pkuid:pkuid,type:0}; var sign=setSign(sign_data); request(config['WEBADDRESS']+"?service=Livepk.changeLive&uid="+uid + "&pkuid=" + pkuid+ "&type=0&sign=" +sign,function(error, response, body){ if(error) return; var res = evalJson(body); if( response.statusCode == 200 && res.data.code == 0){ var data_obj={ "msg":[ { "_method_":"LiveConnect", "action":"5", "msgtype":"10", "uid":""+uid, "uname":"" } ], "retcode":"000000", "retmsg":"OK" }; process_msg(io,uid,JSON.stringify(data_obj)); process_msg(io,pkuid,JSON.stringify(data_obj)); } }); }); } /* PK结束处理 */ function endLivePk(io,uid,type,addtime){ // console.log('结束PK'); //console.log('uid-'+uid); //console.log('addtime-'+addtime); //console.log('type-'+type); var sign_data={uid:uid,addtime:addtime,type:type}; var sign=setSign(sign_data); request(config['WEBADDRESS']+"?service=Livepk.endPK&uid="+uid + "&addtime=" + addtime+ "&type=" + type+ "&sign=" +sign,function(error, response, body){ if(error) return; // console.log('endPK'); // console.log(body); var res = evalJson(body); if( response.statusCode == 200 && res.data.code == 0){ var info=res.data.info[0]; var data_obj={ "msg":[ { "_method_":"LivePK", "action":"9", "msgtype":"10", "win_uid":""+info['win_uid'], "uid":""+uid, "uname":"" } ], "retcode":"000000", "retmsg":"OK" }; process_msg(io,uid,JSON.stringify(data_obj)); process_msg(io,info['pkuid'],JSON.stringify(data_obj)); } }); } //时间格式化 function FormatNowDate(){ var mDate = new Date(); var Y = mDate.getFullYear(); var M = mDate.getMonth()+1; var D = mDate.getDate(); var H = mDate.getHours(); var i = mDate.getMinutes(); var s = mDate.getSeconds(); return Y +'-' + M + '-' + D + ' ' + H + ':' + i + ':' + s; } /* sign加密 */ function setSign(obj) {//排序的函数 var str=''; var newkey = Object.keys(obj).sort(); //先用Object内置类的keys方法获取要排序对象的属性名，再利用Array原型上的sort方法对获取的属性名进行排序，newkey是一个数组 var newObj = {};//创建一个新的对象，用于存放排好序的键值对 for (var i = 0; i < newkey.length; i++) {//遍历newkey数组 //newObj[newkey[i]] = obj[newkey[i]];//向新创建的对象中按照排好的顺序依次增加键值对 str+=newkey[i]+'='+obj[newkey[i]]+'&'; } str+=config['sign_key']; var sign=md5(str); return sign; }