xinyuxi/ZYZ
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

推送：修复全局推送bug

Browse Source
This commit is contained in:
luying
2022-04-18 18:45:02 +08:00
parent a3f55d1a96
commit 618b59d530
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
game-server/app/services/pushService.ts
+3 -3
View File
@@ -18,7 +18,7 @@ export async function sendMessageToAll(route: string, data: any) {
if (++i < n) { if (++i < n) {
let users = allOnlineUsers.slice(i * PUSH_BATCH, (i + 1) * PUSH_BATCH - 1); let users = allOnlineUsers.slice(i * PUSH_BATCH, (i + 1) * PUSH_BATCH - 1);
let uids = users.map(cur => ({ uid: cur.roleId, sid: cur.sid })); let uids = users.map(cur => ({ uid: cur.roleId, sid: cur.sid }));
pinus.app.get('channelService').pushMessageByUids(route, data, uids); sendMessageToUsers(route, data, uids);
} else { } else {
clearInterval(interval); clearInterval(interval);
} }
@@ -118,13 +118,13 @@ export function sendMessgeToChannelByBatch(channel: Channel, route: string, data
for (let uid of uidlist) { for (let uid of uidlist) {
uids.push(channel.getMember(uid)); uids.push(channel.getMember(uid));
} }
sendMessageToUsers(route, resResult(STATUS.SUCCESS, data), uids); sendMessageToUsers(route, data, uids);
} else { } else {
clearInterval(interval); clearInterval(interval);
} }
}, PUSH_INTERVAL); }, PUSH_INTERVAL);
} else { } else {
channel.pushMessage(route, resResult(STATUS.SUCCESS, data)); channel.pushMessage(route, data);
} }
} }