# 立即执行任务
- type: "task"
  name: "Hello World"
  actions:
    - call_function: "print"
      params:
        message: "Hello from DSL Scheduler!"

# 定时任务 (每分钟执行)
- type: "task"
  name: "定时任务"
  cron: "0 * * * * *"
  actions:
    - call_function: "print"
      params:
        message: "定时任务执行中 - {{timestamp}}"

- type: "task"
  name: "简单任务"
  actions:
    - call_function: "print"
      params:
        message: "任务开始"
    - call_function: "sleep"
      params:
        duration: 1000
    - call_function: "print"
      params:
        message: "任务完成"

- type: "task"
  name: "条件任务"
  actions:
    - condition: "{{hour}} >= 9 && {{hour}} < 18"
      actions:
        - call_function: "print"
          params:
            message: "工作时间内执行"

- type: "task"
  name: "循环任务"
  actions:
    - loop_times: 5
      actions:
        - call_function: "print"
          params:
            message: "循环第 {{loop_index}} 次"

# 定义模块
- type: "module"
  name: "发送通知"
  params:
    - name: "message"
      type: "string"
  actions:
    - call_function: "print"
      params:
        message: "通知: {{message}}"

# 使用模块的任务
- type: "task"
  name: "通知任务"
  actions:
    - call_module: "发送通知"
      params:
        message: "系统启动完成"

# 定义函数
- type: "function"
  name: "calculate_area"
  params:
    - name: "width"
      type: "number"
    - name: "height"
      type: "number"
  return_type: "number"
  actions:
    - call_function: "math"
      params:
        operation: "multiply"
        a: "{{width}}"
        b: "{{height}}"

# 使用函数的任务
- type: "task"
  name: "计算任务"
  actions:
    - call_function: "calculate_area"
      params:
        width: 10
        height: 20

# PostgreSQL 查询示例
- type: "task"
  name: "用户数据查询"
  cron: "0 */10 * * * *" # 每10分钟执行
  actions:
    - db_dsn: "postgresql://username:password@localhost:5432/dbname"
      db_query: "SELECT id, username, email FROM users WHERE active = true LIMIT 10"
      for_each_result:
        - call_function: "print"
          params:
            message: "用户: {{username}}, 邮箱: {{email}}"

# MySQL 查询示例
- type: "task"
  name: "订单统计"
  actions:
    - db_dsn: "mysql://root:password@localhost:3306/shop_db"
      db_query: |
        SELECT DATE(created_at) as order_date, 
               COUNT(*) as order_count,
               SUM(total_amount) as total_sales 
        FROM orders 
        WHERE created_at >= DATE_SUB(NOW(), INTERVAL 7 DAY)
        GROUP BY DATE(created_at)
      for_each_result:
        - call_function: "print"
          params:
            message: "{{order_date}}: {{order_count}} 订单, 总额: {{total_sales}}"

# SQLite 查询示例
- type: "task"
  name: "SQLite日志分析"
  actions:
    - db_dsn: "sqlite://./logs.db"
      db_query: "SELECT level, message, timestamp FROM logs WHERE level = 'ERROR'"
      condition: "{{level}} == 'ERROR'"
      for_each_result:
        - call_function: "log"
          params:
            level: "warning"
            message: "发现错误日志: {{message}}"

# 定义全局配置
- type: config
  name: main_db
  config:
    databases:
      dsn: "postgresql://user:pass@localhost:5432/mydb"
      pool_size: "10"
      timeout: "30"

- type: config
  name: redis_cache
  config:
    redis:
      dsn: "redis://localhost:6379"
      pool_size: "5"

# 使用全局配置的任务
- type: task
  name: "使用全局配置的数据库查询"
  actions:
    # 创建用户表
    - db_query: "CREATE TABLE IF NOT EXISTS users (id SERIAL PRIMARY KEY, name VARCHAR(100), email VARCHAR(255))"
      db_config: "main_db" # 引用全局配置，无需重复写 DSN

    # 插入数据
    - db_query: "INSERT INTO users (name, email) VALUES ('Alice', 'alice@example.com')"
      db_config: "main_db"

    # 查询数据
    - db_query: "SELECT * FROM users ORDER BY id"
      db_config: "main_db"
      for_each_result:
        - call_function: "print"
          params:
            message: "用户: {{name}}, 邮箱: {{email}}"

# 定时任务也可以使用全局配置
- type: task
  name: "定时数据检查"
  cron: "0 */5 * * * *" # 每5分钟执行一次
  actions:
    - db_query: "SELECT COUNT(*) as user_count FROM users"
      db_config: "main_db" # 所有数据库操作都使用同一个配置
      for_each_result:
        - call_function: "print"
          params:
            message: "当前用户数量: {{user_count}}"

- type: "task"
  name: "数据库任务"
  actions:
    - db_query: "SELECT * FROM users WHERE active = 1"
      db_name: "main_db"
      for_each_result:
        - call_function: "print"
          params:
            message: "用户: {{user_name}}"

- type: "task"
  name: "API调用"
  actions:
    - http_request:
        url: "https://api.example.com/data"
        method: "GET"
        headers:
          Authorization: "Bearer {{token}}"

# 全局配置 - 定义一次，到处使用
- type: config
  name: main_db
  config:
    databases:
      dsn: "postgresql://user:pass@localhost/db"

# 任务中引用 - 简洁且易维护
- type: task
  actions:
    - db_query: "SELECT * FROM users"
      db_config: "main_db" # 引用全局配置