From a90747878ea659f4fe87eb78b7b47ec5502ad115 Mon Sep 17 00:00:00 2001
From: alikia2x <alikia2x@outlook.com>
Date: Sun, 6 Apr 2025 16:21:46 +0800
Subject: [PATCH] fix: incorrect SQL ingetVideosNearMilestone

---
 packages/crawler/db/snapshot.ts          | 2 +-
 packages/crawler/mq/exec/snapshotTick.ts | 2 --
 2 files changed, 1 insertion(+), 3 deletions(-)

diff --git a/packages/crawler/db/snapshot.ts b/packages/crawler/db/snapshot.ts
index 5be2d62..d3678a8 100644
--- a/packages/crawler/db/snapshot.ts
+++ b/packages/crawler/db/snapshot.ts
@@ -3,7 +3,7 @@ import { LatestSnapshotType } from "db/schema.d.ts";
 
 export async function getVideosNearMilestone(client: Client) {
 	const queryResult = await client.queryObject<LatestSnapshotType>(`
-        SELECT ls
+        SELECT ls.*
         FROM latest_video_snapshot ls
         WHERE
             (views >= 90000 AND views < 100000) OR
diff --git a/packages/crawler/mq/exec/snapshotTick.ts b/packages/crawler/mq/exec/snapshotTick.ts
index 237b923..f12db84 100644
--- a/packages/crawler/mq/exec/snapshotTick.ts
+++ b/packages/crawler/mq/exec/snapshotTick.ts
@@ -153,9 +153,7 @@ export const collectMilestoneSnapshotsWorker = async (_job: Job) => {
 		const videos = await getVideosNearMilestone(client);
 		for (const video of videos) {
 			const aid = Number(video.aid);
-			console.debug(aid, video.aid);
 			const eta = await getAdjustedShortTermETA(client, aid);
-			logger.log(`ETA for ${aid}: ${eta}`)
 			if (eta > 72) continue;
 			const now = Date.now();
 			const scheduledNextSnapshotDelay = eta * HOUR;