S4/S8 定时任务后端: - 新增 scheduled_tasks 表 (migration v7) - 新增 scheduled_task CRUD 模块 (handlers/service/types) - 注册 /api/scheduler/tasks 路由 (GET/POST/PATCH/DELETE) - 新增 start_user_task_scheduler() 30秒轮询循环 - 支持 cron/interval/once 三种调度类型 - once 类型执行后自动禁用 修复: - pipeline_commands.rs: 修复 pipeline.trigger 字段不存在的编译错误 (Pipeline 结构体无 trigger 字段,改用 metadata.tags/description)
16 lines
492 B
Rust
16 lines
492 B
Rust
//! 用户定时任务管理模块
|
|
|
|
pub mod types;
|
|
pub mod service;
|
|
pub mod handlers;
|
|
|
|
use axum::routing::{get, post, patch, delete};
|
|
use crate::state::AppState;
|
|
|
|
/// 定时任务路由 (需要认证)
|
|
pub fn routes() -> axum::Router<AppState> {
|
|
axum::Router::new()
|
|
.route("/api/scheduler/tasks", get(handlers::list_tasks).post(handlers::create_task))
|
|
.route("/api/scheduler/tasks/:id", get(handlers::get_task).patch(handlers::update_task).delete(handlers::delete_task))
|
|
}
|