root 1 year ago
parent
commit
d0161950ef
1 changed files with 10 additions and 8 deletions
  1. 10 8
      node/message.js

+ 10 - 8
node/message.js

@@ -1435,14 +1435,14 @@ us.broadcast = function (messageinfo, pageid, type) {
     for (i in messageinfo) {
         _messageinfo = messageinfo[i]; //记录消息消息
         _users = us[type][i] ? us[type][i].user : {}; //记录用户集合
-        console.log("=================e=============");
-        console.log(type);
-        console.log("=================a=============");
-        console.log(_users);
-        console.log("=================c=============");
-        console.log(us.connect);
-        console.log("=================g=============");
-        console.log(_messageinfo);
+        // console.log("=================e=============");
+        // console.log(type);
+        // console.log("=================a=============");
+        // console.log(_users);
+        // console.log("=================c=============");
+        // console.log(us.connect);
+        // console.log("=================g=============");
+        // console.log(_messageinfo);
         for (j in _users) { //循环处理每个用户处理 给每个用户集合下的用户发送消息
             _pageids = _users[j]; //记录当前用户在每个端登录的页面唯一识别ID
             console.log(_pageids);
@@ -1450,6 +1450,8 @@ us.broadcast = function (messageinfo, pageid, type) {
                 _recievedpageid = _pageids[o]; //记录接受者页面唯一识别ID  用于区分是否是发送用户
                 if (_recievedpageid != pageid) { //如果接受用户不等于发送用户则发送消息
                     try {
+                        console.log("=================b=============");
+                        console.log(_userconnect[j]);
                         if (_userconnect[j] && _userconnect[j][_recievedpageid]) {
                             _issend = _userconnect[j][_recievedpageid].response.end(JSON.stringify(_messageinfo)); //发送消息
                             if (!_issend) { //如果用户下线了,那么发送消息就会失败