54 lines
1.3 KiB
JavaScript
54 lines
1.3 KiB
JavaScript
|
export function startPlazaTasks({
|
||
|
|
pool,
|
||
|
|
plazaRedis,
|
||
|
|
recalculateHotScores,
|
||
|
|
writebackPublications,
|
||
|
|
}) {
|
||
|
|
const timers = [];
|
||
|
|
|
||
|
|
const schedule = (fn, intervalMs, label) => {
|
||
|
|
const run = async () => {
|
||
|
|
try {
|
||
|
|
await fn();
|
||
|
|
} catch (error) {
|
||
|
|
console.error(`Plaza task ${label} failed:`, error.message);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
void run();
|
||
|
|
const timer = setInterval(run, intervalMs);
|
||
|
|
timer.unref?.();
|
||
|
|
timers.push(timer);
|
||
|
|
};
|
||
|
|
|
||
|
|
schedule(async () => {
|
||
|
|
const result = await recalculateHotScores(pool);
|
||
|
|
if (result.updated > 0) await plazaRedis.invalidateFeedCaches();
|
||
|
|
}, 10 * 60 * 1000, 'hot_score');
|
||
|
|
|
||
|
|
schedule(async () => {
|
||
|
|
await plazaRedis.syncCountersToMySQL();
|
||
|
|
}, 5 * 60 * 1000, 'redis_sync');
|
||
|
|
|
||
|
|
schedule(async () => {
|
||
|
|
await writebackPublications(pool);
|
||
|
|
}, 60 * 60 * 1000, 'publication_writeback');
|
||
|
|
|
||
|
|
return {
|
||
|
|
stop() {
|
||
|
|
for (const timer of timers) clearInterval(timer);
|
||
|
|
},
|
||
|
|
};
|
||
|
|
}
|
||
|
|
|
||
|
|
export async function writebackPublications(pool) {
|
||
|
|
const now = Date.now();
|
||
|
|
const [result] = await pool.query(
|
||
|
|
`UPDATE h5_publish_records p
|
||
|
|
JOIN plaza_posts pp ON pp.publication_id = p.id
|
||
|
|
SET p.plaza_view_count = pp.view_count,
|
||
|
|
p.plaza_like_count = pp.like_count
|
||
|
|
WHERE pp.status = 'published'`,
|
||
|
|
);
|
||
|
|
return { updated: result.affectedRows ?? 0, at: now };
|
||
|
|
}
|