Function scheduleTask

sum/sum.ts:790–826

(task: SummaryTask)

  } catch (e: any) {
    return { success: false, message: `总结失败: ${e?.message || e}` };
  }
}

// 调度任务
async function scheduleTask(task: SummaryTask) {
  const key = makeCronKey(task.id);
  if (task.disabled || cronManager.has(key)) return;

  console.log(`[sum] 注册任务 ${task.id}: ${task.cron}`);

  cronManager.set(key, task.cron, async () => {
    console.log(`[sum] 开始执行任务 ${task.id}`);

    const db = await getDB();
    const idx = db.data.tasks.findIndex((t: SummaryTask) => t.id === task.id);
    const now = Date.now();

    try {
      const result = await executeSummary(task);

      if (idx >= 0) {
        db.data.tasks[idx].lastRunAt = String(now);
        if (result.success) {
          db.data.tasks[idx].lastResult = result.message;
          db.data.tasks[idx].lastError = undefined;
        } else {
          db.data.tasks[idx].lastError = result.message;
        }
        await db.write();
      }
      console.log(`[sum] 任务 ${task.id} 执行完成: ${result.success ? '成功' : '失败'}`);
    } catch (e: any) {
      console.error(`[sum] 任务 ${task.id} 执行失败:`, e);
      if (idx >= 0) {
        db.data.tasks[idx].lastRunAt = String(now);
        db.data.tasks[idx].lastError = String(e?.message || e);
        await db.write();
      }
    }
  });