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