diff --git a/packages/crawler/mq/task/collectSongs.ts b/packages/crawler/mq/task/collectSongs.ts index f5eb238..031177e 100644 --- a/packages/crawler/mq/task/collectSongs.ts +++ b/packages/crawler/mq/task/collectSongs.ts @@ -18,11 +18,12 @@ export async function collectSongs() { export async function insertIntoSongs(sql: Psql, aid: number) { await sql` - INSERT INTO songs (aid, published_at, duration) + INSERT INTO songs (aid, published_at, duration, image) VALUES ( $1, (SELECT published_at FROM bilibili_metadata WHERE aid = ${aid}), - (SELECT duration FROM bilibili_metadata WHERE aid = ${aid}) + (SELECT duration FROM bilibili_metadata WHERE aid = ${aid}), + (SELECT cover_url FROM bilibili_metadata WHERE aid = ${aid}) ) ON CONFLICT DO NOTHING `;