root 1 year ago
parent
commit
4f56db24da
1 changed files with 9 additions and 5 deletions
  1. 9 5
      node/message.js

+ 9 - 5
node/message.js

@@ -1429,21 +1429,25 @@ us.broadcast = function (messageinfo, pageid, type) {
         _messageinfo = messageinfo[i]; //记录消息消息
         _users = us[type][i] ? us[type][i].user : {}; //记录用户集合
         console.log("=================e=============");
-        console.log(us[type]);
+        console.log(us[type][i]);
+        console.log(us.connect);
         console.log(_messageinfo);
         for (j in _users) { //循环处理每个用户处理 给每个用户集合下的用户发送消息
             _pageids = _users[j]; //记录当前用户在每个端登录的页面唯一识别ID
+            console.log(_pageids);
             for (o = 0; o < _pageids.length; o++) { //循环发送给当前用户在每个端登录的用户
                 _recievedpageid = _pageids[o]; //记录接受者页面唯一识别ID  用于区分是否是发送用户
                 if (_recievedpageid != pageid) { //如果接受用户不等于发送用户则发送消息
                     try {
-                        _issend = _userconnect[j][_recievedpageid].response.end(JSON.stringify(_messageinfo)); //发送消息
-                        if (!_issend) { //如果用户下线了,那么发送消息就会失败
-                            us.offLineMessage[_recievedpageid].message.push(_messageinfo); //将消息加入用户离线消息中
+                        if (_userconnect[j] && _userconnect[j]][_recievedpageid]) {
+                            _issend = _userconnect[j][_recievedpageid].response.end(JSON.stringify(_messageinfo)); //发送消息
+                            if (!_issend) { //如果用户下线了,那么发送消息就会失败
+                                us.offLineMessage[_recievedpageid].message.push(_messageinfo); //将消息加入用户离线消息中
+                            }
                         }
                     }
                     catch (e) {
-                        console.error(e.message)
+                        console.log(e)
                     }
                 }
             }