[![crates.io](https://img.shields.io/crates/v/spring-job.svg)](https://crates.io/crates/spring-job)
[![Documentation](https://docs.rs/spring-job/badge.svg)](https://docs.rs/spring-job)

## 依赖

```toml
spring-job = { version = "<version>" }
```

## API接口

App实现了[JobConfigurator](https://docs.rs/spring-job/latest/spring_job/trait.JobConfigurator.html)特征，可以通过该特征配置调度任务：

```rust, linenos, hl_lines=6 11-18
#[tokio::main]
async fn main() {
    App::new()
        .add_plugin(JobPlugin)
        .add_plugin(SqlxPlugin)
        .add_jobs(jobs())
        .run()
        .await
}

fn jobs() -> Jobs {
    Jobs::new().typed_job(cron_job)
}

#[cron("1/10 * * * * *")]
async fn cron_job() {
    println!("cron scheduled: {:?}", SystemTime::now())
}
```

你也可以使用`auto_config`宏来实现自动配置，这个过程宏会自动将被过程宏标记的调度任务注册进app中：

```diff
+#[auto_config(JobConfigurator)]
 #[tokio::main]
 async fn main() {
     App::new()
         .add_plugin(JobPlugin)
         .add_plugin(SqlxPlugin)
-        .add_jobs(jobs())
         .run()
         .await
}
```

## 提取插件注册的Component

上面的`SqlxPlugin`插件为我们自动注册了一个Sqlx连接池组件，我们可以使用`Component`从App中提取这个连接池。需要注意`spring-job`的[`Component`](https://docs.rs/spring-job/latest/spring_job/extractor/struct.Component.html)和`spring-web`的[`Component`](https://docs.rs/spring-web/latest/spring_web/extractor/struct.Component.html)虽然实现原理类似，但这两个extractor归属不同的crate下。

```rust
use spring_sqlx::{
    sqlx::{self, Row}, ConnectPool
};
use spring_job::cron;
use spring_job::extractor::Component;

#[cron("1/10 * * * * *")]
async fn cron_job(Component(db): Component<ConnectPool>) {
    let time: String = sqlx::query("select DATE_FORMAT(now(),'%Y-%m-%d %H:%i:%s') as time")
        .fetch_one(&db)
        .await
        .context("query failed")
        .unwrap()
        .get("time");
    println!("cron scheduled: {:?}", time)
}
```