From 9f84003544d02993ea4e4fe5efdcd63403d4ce4c Mon Sep 17 00:00:00 2001 From: alikia2x Date: Mon, 17 Nov 2025 02:54:35 +0800 Subject: [PATCH] fix: some bugs in crawler package --- packages/crawler/db/snapshotSchedule.ts | 2 +- packages/crawler/mq/exec/snapshotVideo.ts | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/packages/crawler/db/snapshotSchedule.ts b/packages/crawler/db/snapshotSchedule.ts index 7205f5f..38e4f29 100644 --- a/packages/crawler/db/snapshotSchedule.ts +++ b/packages/crawler/db/snapshotSchedule.ts @@ -154,7 +154,7 @@ export async function findSnapshotBefore( SELECT created_at, views FROM video_snapshot WHERE aid = ${aid} - AND created_at <= ${targetTime}::timestamptz + AND created_at <= ${targetTime.toISOString()}::timestamptz ORDER BY created_at DESC LIMIT 1 `; diff --git a/packages/crawler/mq/exec/snapshotVideo.ts b/packages/crawler/mq/exec/snapshotVideo.ts index 1c539d7..fe32b30 100644 --- a/packages/crawler/mq/exec/snapshotVideo.ts +++ b/packages/crawler/mq/exec/snapshotVideo.ts @@ -34,7 +34,7 @@ export const snapshotVideoWorker = async (job: Job): Promise => { return; } - const status = await getBiliVideoStatus(sql, aid); + const status = await getBiliVideoStatus(aid); if (status !== 0) { logger.warn( `Video ${aid} has status ${status} in the database. Abort snapshoting.`, @@ -47,7 +47,7 @@ export const snapshotVideoWorker = async (job: Job): Promise => { await setSnapshotStatus(sql, id, "processing"); const stat = await insertVideoSnapshot(sql, aid, task); if (typeof stat === "number") { - await setBiliVideoStatus(sql, aid, stat); + await setBiliVideoStatus(aid, stat); await setSnapshotStatus(sql, id, "bili_error"); logger.warn( `Bilibili return status ${status} when snapshoting for ${aid}.`,