diff --git a/update.js b/update.js index afec097..55edfe0 100644 --- a/update.js +++ b/update.js @@ -82,17 +82,17 @@ export async function update(table, rank, views) { // 0=文章/游戏/作品 1=短视频 2=图片 const TYPE = { - 'web_images': 'type=2', + 'web_images': 'type=2', 'web_article': 'type=0', } // 定义查询时间范围 const WHERE = { - 'day_rank': `create_time >= CURDATE() AND ${TYPE[table]}`, - 'week_rank': `create_time >= CURDATE() - INTERVAL 7 DAY AND ${TYPE[table]}`, + 'day_rank': `create_time >= CURDATE() AND ${TYPE[table]}`, + 'week_rank': `create_time >= CURDATE() - INTERVAL 7 DAY AND ${TYPE[table]}`, 'month_rank': `create_time >= CURDATE() - INTERVAL 1 MONTH AND ${TYPE[table]}`, - 'year_rank': `create_time >= CURDATE() - INTERVAL 1 YEAR AND ${TYPE[table]}`, - 'aeon_rank': `${TYPE[table]}` + 'year_rank': `create_time >= CURDATE() - INTERVAL 1 YEAR AND ${TYPE[table]}`, + 'aeon_rank': `${TYPE[table]}` } const JOIN = { @@ -111,10 +111,15 @@ export async function update(table, rank, views) { 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) + // 打印临时表前 10 条数据 + console.log('打印临时表前 10 条数据') + const [tempData] = await conn.query("SELECT * FROM temp_updates LIMIT 10") + console.log('临时表数据:', tempData) + console.log('更新数据从临时表转入生产库', table) 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('更新完成') }