活动:用膳刷新时间
This commit is contained in:
@@ -12,13 +12,16 @@ export async function sendMessageToAllWithSuc(route: string, data: any) {
|
||||
export async function sendMessageToAll(route: string, data: any) {
|
||||
let allOnlineUsers = await getAllOnlineRoles();
|
||||
let n = Math.ceil(allOnlineUsers.length / PUSH_BATCH); // 一共多少批
|
||||
|
||||
let sendToUser = (i: number) => {
|
||||
let users = allOnlineUsers.slice(i * PUSH_BATCH, (i + 1) * PUSH_BATCH - 1);
|
||||
let uids = users.map(cur => ({ uid: cur.roleId, sid: cur.sid }));
|
||||
sendMessageToUsers(route, data, uids);
|
||||
}
|
||||
let i = -1;
|
||||
sendToUser(++i);
|
||||
let interval = setInterval(() => {
|
||||
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 }));
|
||||
sendMessageToUsers(route, data, uids);
|
||||
sendToUser(i);
|
||||
} else {
|
||||
clearInterval(interval);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user