From 618b59d5308db57b4f2d624242c0db7e1c506327 Mon Sep 17 00:00:00 2001 From: luying Date: Mon, 18 Apr 2022 18:45:02 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8E=A8=E9=80=81=EF=BC=9A=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E5=85=A8=E5=B1=80=E6=8E=A8=E9=80=81bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- game-server/app/services/pushService.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/game-server/app/services/pushService.ts b/game-server/app/services/pushService.ts index a17e66e3d..d9712c346 100644 --- a/game-server/app/services/pushService.ts +++ b/game-server/app/services/pushService.ts @@ -18,7 +18,7 @@ export async function sendMessageToAll(route: string, data: any) { if (++i < n) { let users = allOnlineUsers.slice(i * PUSH_BATCH, (i + 1) * PUSH_BATCH - 1); let uids = users.map(cur => ({ uid: cur.roleId, sid: cur.sid })); - pinus.app.get('channelService').pushMessageByUids(route, data, uids); + sendMessageToUsers(route, data, uids); } else { clearInterval(interval); } @@ -118,13 +118,13 @@ export function sendMessgeToChannelByBatch(channel: Channel, route: string, data for (let uid of uidlist) { uids.push(channel.getMember(uid)); } - sendMessageToUsers(route, resResult(STATUS.SUCCESS, data), uids); + sendMessageToUsers(route, data, uids); } else { clearInterval(interval); } }, PUSH_INTERVAL); } else { - channel.pushMessage(route, resResult(STATUS.SUCCESS, data)); + channel.pushMessage(route, data); } }