Compare commits
No commits in common. "13ed20cf5c5f119401fcb0c36e20f9af5cd2ff45" and "b4205049cb1fed5bdf15a223e7e00ef57e2ca69b" have entirely different histories.
13ed20cf5c
...
b4205049cb
@ -3,9 +3,13 @@ import { LatestSnapshotType } from "db/schema.d.ts";
|
|||||||
|
|
||||||
export async function getVideosNearMilestone(client: Client) {
|
export async function getVideosNearMilestone(client: Client) {
|
||||||
const queryResult = await client.queryObject<LatestSnapshotType>(`
|
const queryResult = await client.queryObject<LatestSnapshotType>(`
|
||||||
SELECT ls
|
SELECT ls.*
|
||||||
FROM latest_video_snapshot ls
|
FROM latest_video_snapshot ls
|
||||||
|
INNER JOIN
|
||||||
|
songs s ON ls.aid = s.aid
|
||||||
|
AND s.deleted = false
|
||||||
WHERE
|
WHERE
|
||||||
|
s.deleted = false AND
|
||||||
(views >= 90000 AND views < 100000) OR
|
(views >= 90000 AND views < 100000) OR
|
||||||
(views >= 900000 AND views < 1000000) OR
|
(views >= 900000 AND views < 1000000) OR
|
||||||
(views >= 9900000 AND views < 10000000)
|
(views >= 9900000 AND views < 10000000)
|
||||||
|
@ -4,4 +4,4 @@
|
|||||||
// SO HERE'S A PLACHOLDER EXPORT FOR DENO:
|
// SO HERE'S A PLACHOLDER EXPORT FOR DENO:
|
||||||
export const DENO = "FUCK YOU DENO";
|
export const DENO = "FUCK YOU DENO";
|
||||||
// Oh, maybe export the version is a good idea
|
// Oh, maybe export the version is a good idea
|
||||||
export const VERSION = "1.0.18";
|
export const VERSION = "1.0.17";
|
||||||
|
@ -161,7 +161,7 @@ export const collectMilestoneSnapshotsWorker = async (_job: Job) => {
|
|||||||
const minInterval = 1 * SECOND;
|
const minInterval = 1 * SECOND;
|
||||||
const delay = truncate(scheduledNextSnapshotDelay, minInterval, maxInterval);
|
const delay = truncate(scheduledNextSnapshotDelay, minInterval, maxInterval);
|
||||||
const targetTime = now + delay;
|
const targetTime = now + delay;
|
||||||
await scheduleSnapshot(client, aid, "milestone", targetTime, true);
|
await scheduleSnapshot(client, aid, "milestone", targetTime);
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
logger.error(e as Error, "mq", "fn:collectMilestoneSnapshotsWorker");
|
logger.error(e as Error, "mq", "fn:collectMilestoneSnapshotsWorker");
|
||||||
|
@ -42,18 +42,6 @@ export async function insertVideoInfo(client: Client, aid: number) {
|
|||||||
[data.Card.follower, uid],
|
[data.Card.follower, uid],
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
const stat = data.View.stat;
|
|
||||||
|
|
||||||
const query: string = `
|
|
||||||
INSERT INTO video_snapshot (aid, views, danmakus, replies, likes, coins, shares, favorites)
|
|
||||||
VALUES ($1, $2, $3, $4, $5, $6, $7, $8)
|
|
||||||
`;
|
|
||||||
await client.queryObject(
|
|
||||||
query,
|
|
||||||
[aid, stat.view, stat.danmaku, stat.reply, stat.like, stat.coin, stat.share, stat.favorite],
|
|
||||||
);
|
|
||||||
|
|
||||||
logger.log(`Inserted video metadata for aid: ${aid}`, "mq");
|
logger.log(`Inserted video metadata for aid: ${aid}`, "mq");
|
||||||
await ClassifyVideoQueue.add("classifyVideo", { aid });
|
await ClassifyVideoQueue.add("classifyVideo", { aid });
|
||||||
}
|
}
|
||||||
|
@ -1 +1 @@
|
|||||||
export const VERSION = "1.3.8";
|
export const VERSION = "1.2.7";
|
||||||
|
Loading…
Reference in New Issue
Block a user