diff --git a/src/public/scheduler/scheduler_cross_email_pull.ts b/src/public/scheduler/scheduler_cross_email_pull.ts index 652f36e..71c26da 100644 --- a/src/public/scheduler/scheduler_cross_email_pull.ts +++ b/src/public/scheduler/scheduler_cross_email_pull.ts @@ -20,7 +20,7 @@ export class CrossEmailPull extends Scheduler { async start() { /**同步跨服邮件*/ G.clientCross.callApi("email/GetCrossEmail", {server_id: G.config.serverId + ""}).then((res) => { - if(!res.isSucc)return; + if (!res.isSucc) return; res.res.emails.forEach(async (email) => { if (email.uid != "system") { await EmailFun.addEmail(email) @@ -29,6 +29,9 @@ export class CrossEmailPull extends Scheduler { } await EmailFun.addEmail(email) }) + if (res.res.emails.length > 0) { + G.clientCross.callApi("email/DelCrossEmail", {eids: res.res.emails.map(e => e._id)}) + } }) await this.ctorStartTime() }