From 71359fba88fb9fec9c2a3d9f2caeb2327652ec0f Mon Sep 17 00:00:00 2001 From: abearxiong Date: Sat, 21 Jun 2025 21:47:26 +0800 Subject: [PATCH] fix: fix --- packages/xhs/src/routes/mentions/mention.ts | 1 + packages/xhs/src/routes/mentions/unread-task.ts | 5 ++++- src/task/routes/mention.ts | 10 ++++++---- 3 files changed, 11 insertions(+), 5 deletions(-) diff --git a/packages/xhs/src/routes/mentions/mention.ts b/packages/xhs/src/routes/mentions/mention.ts index 952addf..754838b 100644 --- a/packages/xhs/src/routes/mentions/mention.ts +++ b/packages/xhs/src/routes/mentions/mention.ts @@ -26,6 +26,7 @@ app } else { ctx.body = { unread_count: 0, + likes: 0, }; } }) diff --git a/packages/xhs/src/routes/mentions/unread-task.ts b/packages/xhs/src/routes/mentions/unread-task.ts index e473f9d..5acfb00 100644 --- a/packages/xhs/src/routes/mentions/unread-task.ts +++ b/packages/xhs/src/routes/mentions/unread-task.ts @@ -14,13 +14,16 @@ app key: 'getUnread', }); console.log('unredRes', unredRes.body, unredRes.code); + if (unredRes.code === 200) { const unread_count = unredRes.body.unread_count; + const likes = unredRes.body.likes; + const unread = unread_count - likes; const mentionRes = await app.call({ path: 'mention', key: 'getMention', payload: { - num: unread_count, + num: unread, }, }); if (mentionRes.code === 200) { diff --git a/src/task/routes/mention.ts b/src/task/routes/mention.ts index 9d97bda..26d3281 100644 --- a/src/task/routes/mention.ts +++ b/src/task/routes/mention.ts @@ -21,18 +21,20 @@ taskApp if (res.code === 200) { const data = res.body; const unread_count = data.unread_count; - if (unread_count > 0) { + const likes = data.likes; + const unread = unread_count - likes; + if (unread > 0) { queue.add( 'mention', { path: 'task', key: 'getMention', payload: { - unread_count, + unread_count: unread, }, }, { - attempts: 3, + attempts: 1, delay: 0, removeOnComplete: true, removeOnFail: { @@ -42,7 +44,7 @@ taskApp ); } ctx.body = { - job: unread_count, + job: unread, }; } })