cron

type Job struct {
	ID             string   `json:"id"`                         // 唯一标识符
	Name           string   `json:"name"`                       // 任务显示名称
	Enabled        bool     `json:"enabled"`                    // 是否处于启用状态
	Schedule       Schedule `json:"schedule"`                   // 调度计划
	Payload        Payload  `json:"payload"`                    // 待执行载荷
	State          JobState `json:"state"`                      // 运行状态
	CreatedAtMS    int64    `json:"created_at_ms"`              // 创建时间
	UpdatedAtMS    int64    `json:"updated_at_ms"`              // 更新时间
	DeleteAfterRun bool     `json:"delete_after_run,omitempty"` // 执行完成后是否自动从存储中删除
}

type JobHandler func(*Job) error

type JobState struct {
	NextRunAtMS *int64 `json:"next_run_at_ms,omitempty"` // 下次预定执行时间
	LastRunAtMS *int64 `json:"last_run_at_ms,omitempty"` // 最近一次执行时间
	LastStatus  string `json:"last_status,omitempty"`    // 最近执行状态 ("ok", "error")
	LastError   string `json:"last_error,omitempty"`     // 最近一次执行产生的错误消息
}

type Payload struct {
	Kind    string `json:"kind"`    // 载荷类型（如 "agent_turn"）
	Message string `json:"message"` // 发送给 Agent 的指令内容
	Channel string `json:"channel"` // 目标回复通道名称
	ChatID  string `json:"chat_id"` // 目标聊天 ID
	Deliver bool   `json:"deliver"` // 是否直接交付结果而跳过 Agent 思考
}

type Schedule struct {
	Kind    string `json:"kind"`               // 调度类型："at" (单次), "every" (间隔), "cron" (表达式)
	AtMS    *int64 `json:"at_ms,omitempty"`    // 单次执行的时间戳（毫秒）
	EveryMS *int64 `json:"every_ms,omitempty"` // 执行间隔时长（毫秒）
	Expr    string `json:"expr,omitempty"`     // 5 段式 Cron 表达式
}

type Service struct {
	// contains filtered or unexported fields
}

type Store struct {
	// contains filtered or unexported fields
}