update

node/message.js

@@ -629,7 +629,6 @@ us.polling = function (requset, response, userid, pageid, type) {
     //     console.log("--------" + userid + "-------------" + pageid);
     //     //us.offLine(response, userid, pageid)
     // });
-
     //判断轮询的用户是否在连接池中
     if (us.connect[userid]) {
         var _userarray = us.connect[userid], //用户连接池，获取制定用户连接的数量,
@@ -650,19 +649,20 @@ us.polling = function (requset, response, userid, pageid, type) {
                 _messagearray.message = [];
             }
             else {
-                us.offLineMessage[pageid] = us.userOffLineMessage(type); //初始化用户离线消息记录
+                us.offLineMessage[pageid] = us.offLineMessage[pageid] || us.userOffLineMessage(type); //初始化用户离线消息记录
             }
-            return;
         }
-        //如果用户连接不存在
-        _userarray[pageid] = us.userConnect(pageid, response); //那么直接添加用户连接 添加到用户连接数组里
-        us.offLineMessage[pageid] = us.userOffLineMessage(type); //初始化用户离线消息记录
+        else {
+            //如果用户连接不存在
+            _userarray[pageid] = us.userConnect(pageid, response); //那么直接添加用户连接 添加到用户连接数组里
+            us.offLineMessage[pageid] = us.userOffLineMessage(type); //初始化用户离线消息记录
+        }
     }
     else {
         var _userconect = us.userConnect(pageid, response); //创建用户连接对象
         us.connect[userid] = {}; //添加用户连接对象
         us.connect[userid][pageid] = _userconect;
-        us.offLineMessage[pageid] = us.userOffLineMessage(type); //初始化用户离线消息记录
+        us.offLineMessage[pageid] = us.offLineMessage[pageid] || us.userOffLineMessage(type); //初始化用户离线消息记录
     }
 }