recording

type AddRecordingInput struct {
	CID       string   `json:"-"`          // 通道 ID（由 API 层填充）
	App       string   `json:"app"`        // ZLM 应用名
	Stream    string   `json:"stream"`     // ZLM 流 ID
	StartedAt orm.Time `json:"started_at"` // 录像开始时间
	EndedAt   orm.Time `json:"ended_at"`   // 录像结束时间
	Duration  float64  `json:"duration"`   // 持续时长（秒）
	Path      string   `json:"path"`       // 文件相对路径
	Size      int64    `json:"size"`       // 文件大小（字节）
}

type ChannelInfo struct {
	ID         string // 通道唯一 ID
	App        string // 应用名（如 rtp / live）
	Stream     string // 流 ID
	Type       string // 通道类型（gb28181 / onvif / rtmp / rtsp）
	RecordMode string // 录像模式（always / ai / none / 空串=always）
}

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

type EditRecordingInput struct {
	ObjectCount int `json:"object_count"` // AI检测对象数量（从event表统计）
}

type FindRecordingInput struct {
	web.PagerFilter
	web.DateFilter
	CID    string `form:"cid"`    // 通道 ID (channel.ID)
	App    string `form:"app"`    // ZLM 应用名
	Stream string `form:"stream"` // ZLM 流 ID
}

type IPCProvider interface {
	ListOnlineChannels(ctx context.Context) ([]ChannelInfo, error)
}

type MonthlyStatsInput struct {
	CID   string `form:"cid"`   // 通道 ID（可选，不传则查所有通道）
	Year  int    `form:"year"`  // 年份，如 2024
	Month int    `form:"month"` // 月份，1-12
}

type MonthlyStatsOutput struct {
	Year     int    `json:"year"`      // 年份
	Month    int    `json:"month"`     // 月份
	Days     int    `json:"days"`      // 该月总天数
	HasVideo string `json:"has_video"` // 位图字符串，如 "10101010..." 第 1 天有录像则第 1 位为 1
}

type Option func(*Core)

type PlayProvider interface {
	TriggerStream(ctx context.Context, info ChannelInfo) error
}

type Recording struct {
	ID          int64    `gorm:"primaryKey" json:"id"`
	CID         string   `gorm:"column:cid;notNull;index;default:'';comment:通道 ID (channel.ID)" json:"cid"`                  // 通道 ID (channel.ID)
	App         string   `gorm:"column:app;notNull;default:'';comment:ZLM 应用名" json:"app"`                                   // ZLM 应用名
	Stream      string   `gorm:"column:stream;notNull;default:'';comment:ZLM 流 ID" json:"stream"`                            // ZLM 流 ID
	StartedAt   orm.Time `gorm:"column:started_at;notNull;index;default:CURRENT_TIMESTAMP;comment:录像开始时间" json:"started_at"` // 录像开始时间
	EndedAt     orm.Time `gorm:"column:ended_at;notNull;default:CURRENT_TIMESTAMP;comment:录像结束时间" json:"ended_at"`           // 录像结束时间
	Duration    float64  `gorm:"column:duration;notNull;default:0;comment:持续时长（秒）" json:"duration"`                          // 持续时长（秒）
	Path        string   `gorm:"column:path;notNull;default:'';comment:文件相对路径" json:"path"`                                  // 文件相对路径
	Size        int64    `gorm:"column:size;notNull;default:0;index;comment:文件大小（字节）" json:"size"`                           // 文件大小（字节）
	ObjectCount int      `gorm:"column:object_count;notNull;default:0;comment:AI检测对象数量（从event表统计）" json:"object_count"`      // AI检测对象数量（从event表统计）
	DeleteFlag  bool     `gorm:"column:delete_flag;notNull;default:false;comment:待删除标记" json:"delete_flag"`                  // 待删除标记（即将被清理）
	CreatedAt   orm.Time `gorm:"column:created_at;notNull;default:CURRENT_TIMESTAMP" json:"created_at"`
	UpdatedAt   orm.Time `gorm:"column:updated_at;notNull;default:CURRENT_TIMESTAMP" json:"updated_at"`
}

type RecordingStorer interface {
	List(context.Context, *[]*Recording, orm.Pager, ...orm.QueryOption) (int64, error)
	Get(context.Context, *Recording, ...orm.QueryOption) error
	Create(context.Context, *Recording) error
	Update(context.Context, *Recording, func(*Recording), ...orm.QueryOption) error
	Delete(context.Context, *Recording, ...orm.QueryOption) error
	Count(context.Context, ...orm.QueryOption) (int64, error)

	Session(context.Context, ...func(*gorm.DB) error) error
	UpdateWithSession(*gorm.DB, *Recording, func(b *Recording) error, ...orm.QueryOption) error
}

type SMSProvider interface {
	StartRecord(app, stream, customPath string, maxSecond int) error
	StopRecord(app, stream string) error
	// ListRecordingStreams 批量获取所有在线流的录制状态
	// 返回 map[app/stream]bool，true 表示正在录制 MP4
	ListRecordingStreams() (map[string]bool, error)
}

type Storer interface {
	Recording() RecordingStorer
}

type TimeRange struct {
	ID          int64   `json:"id"`           // 录像记录 ID
	StartMs     int64   `json:"start_ms"`     // 开始时间（毫秒时间戳）
	EndMs       int64   `json:"end_ms"`       // 结束时间（毫秒时间戳）
	Duration    float64 `json:"duration"`     // 时长（秒）
	ObjectCount int     `json:"object_count"` // AI检测对象数量
	DeleteFlag  bool    `json:"delete_flag"`  // 待删除标记（已被标记即将清理）
}

type TimelineInput struct {
	web.DateFilter
	CID string `form:"cid"` // 通道 ID
}