From b2c8345798e55b401d348ed6aafc43284482b84f Mon Sep 17 00:00:00 2001 From: satori Date: Sat, 28 Dec 2024 02:43:35 +0800 Subject: [PATCH] =?UTF-8?q?=E6=89=93=E5=8D=B0=E8=B0=83=E8=AF=95=E4=BF=A1?= =?UTF-8?q?=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- update.js | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/update.js b/update.js index 5507420..afec097 100644 --- a/update.js +++ b/update.js @@ -103,14 +103,18 @@ export async function update(table, rank, views) { for (let name of ['comment', 'praise', 'collect']) { console.log(`统计 ${rank} 时间段内 ${name} 数到临时表`) - await conn.query(`UPDATE temp_updates t JOIN(${JOIN[name]}) stats ON t.id = stats.id SET t.${name}_count = stats.${name}_count`) + const updateResult = await conn.query(`UPDATE temp_updates t JOIN(${JOIN[name]}) stats ON t.id = stats.id SET t.${name}_count = stats.${name}_count`) + console.log(`${name} 更新结果:`, updateResult) } console.log('统计当天时间段内排行榜到临时表') - await conn.query("UPDATE temp_updates SET rank = collect_count * 35 + praise_count * 20 + comment_count * 20 + views_count * 25") + const rankUpdateResult = await conn.query("UPDATE temp_updates SET rank = collect_count * 35 + praise_count * 20 + comment_count * 20 + views_count * 25") + console.log('排行榜更新结果:', rankUpdateResult) console.log('更新数据从临时表转入生产库', table) - await conn.query(`UPDATE ${table} t LEFT JOIN temp_updates tu ON t.id = tu.id SET t.${rank} = IFNULL(tu.rank, 0)`) + const finalUpdateResult = await conn.query(`UPDATE ${table} t LEFT JOIN temp_updates tu ON t.id = tu.id SET t.${rank} = IFNULL(tu.rank, 0)`) + console.log('生产库更新结果:', finalUpdateResult) + await conn.end() console.log('更新完成') }