ipc

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

type AddChannelInput struct {
	Type       string `json:"type"`        // 通道类型 (RTMP/RTSP)
	Name       string `json:"name"`        // 通道名称
	DeviceID   string `json:"device_id"`   // 可选，关联的父设备 ID
	DeviceName string `json:"device_name"` // 可选，device_id 不存在时用于创建新设备

	// RTMP/RTSP 配置
	App    string       `json:"app"`    // 应用名
	Stream string       `json:"stream"` // 流 ID
	Config StreamConfig `json:"config"` // 流配置
}

type AddDeviceInput struct {
	DeviceID string `json:"device_id"` // 20 位国标编号
	// onvif
	Username string `json:"username"` // 用户名
	IP       string `json:"ip"`       // ip
	Port     int    `json:"port"`     // port
	// 通用
	Name     string `json:"name"`     // 设备名称
	Password string `json:"password"` // 注册密码

	Type string `json:"type"` // 设备类型(ONVIF/GB28181)

}

type AddZoneInput struct {
	Name        string    `json:"name"`        // 区域名称
	Coordinates []float32 `json:"coordinates"` // 坐标
	Color       string    `json:"color"`       // 颜色，支持 hex 颜色值，如 #FF0000
	Labels      []string  `json:"labels"`      // 标签
	ChannelID   string    `json:"-"`           // 通道 id
}

type Channel struct {
	ID        string    `gorm:"primaryKey" json:"id"`
	DID       string    `gorm:"column:did;index;notNull;default:'';comment:父级 ID" json:"did"`
	DeviceID  string    `gorm:"column:device_id;index;notNull;default:'';comment:国标编码" json:"device_id"`   // 国标编码
	ChannelID string    `gorm:"column:channel_id;index;notNull;default:'';comment:国标编码" json:"channel_id"` // 国标编码
	Name      string    `gorm:"column:name;notNull;default:'';comment:通道名称" json:"name"`                   // 通道名称
	PTZ       int       `gorm:"column:ptz;notNull;default:0;comment:云台类型" json:"ptz"`                      // 云台类型
	IsOnline  bool      `gorm:"column:is_online;notNull;default:FALSE;comment:是否在线" json:"is_online"`      // 是否在线
	IsPlaying bool      `gorm:"column:is_playing;notNull;default:FALSE;comment:是否播放中" json:"is_playing"`   // 是否播放中
	Ext       DeviceExt `gorm:"column:ext;notNull;default:'{}';type:jsonb" json:"ext"`
	CreatedAt orm.Time  `gorm:"column:created_at;notNull;default:CURRENT_TIMESTAMP;comment:创建时间" json:"created_at"` // 创建时间
	UpdatedAt orm.Time  `gorm:"column:updated_at;notNull;default:CURRENT_TIMESTAMP;comment:更新时间" json:"updated_at"` // 更新时间
	Type      string    `gorm:"column:type;notNull;default:'';comment:通道类型" json:"type"`                            // 通道类型，继承父级设备类型

	// RTMP/RTSP 流配置字段
	App    string       `gorm:"column:app;index;notNull;default:'';comment:应用名" json:"app"`        // 应用名 (RTMP/RTSP)
	Stream string       `gorm:"column:stream;index;notNull;default:'';comment:流 ID" json:"stream"` // 流 ID (RTMP/RTSP)
	Config StreamConfig `gorm:"column:config;notNull;default:'{}';type:jsonb" json:"config"`       // 流配置 (RTMP/RTSP)

	// 非持久化字段，用于 API 响应
	HasRecording bool `gorm:"-" json:"has_recording"` // 是否存在录像（查询时动态填充）
}

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

	BatchEdit(context.Context, string, any, ...orm.QueryOption) error // 批量更新一个字段
	EditGB28181Config(context.Context, *Channel) error                // 直接更新 GB28181 上报的四个字段，跳过查询
	Session(ctx context.Context, changeFns ...func(*gorm.DB) error) error
}

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

type Device struct {
	ID   string `gorm:"primaryKey" json:"id"`
	Type string `gorm:"column:type;notNull;default:'GB28181';comment:设备类型(onvif)" json:"type"` // 设备类型(onvif/gb28181)

	// 自定义 id 可以简写为 did，国标 device_id 应简写成 gbid，而不是 device_id
	// 起这个名义会难以区分，但为了兼容已经部署的旧数据库...保留
	DeviceID string `gorm:"column:device_id;notNull;uniqueIndex;default:'';comment:20 位国标编号" json:"device_id"` // 20 位国标编号

	// 自定义名称
	Name         string    `gorm:"column:name;notNull;default:'';comment:设备名称" json:"name"`                                                    // 设备名称
	Transport    string    `gorm:"column:transport;notNull;default:'';comment:传输协议(tcp/udp)" json:"transport"`                                 // 传输协议(TCP/UDP)
	StreamMode   int8      `gorm:"column:stream_mode;notNull;default:1;comment:数据传输模式(0:UDP; 1:TCP_PASSIVE; 2:TCP_ACTIVE)" json:"stream_mode"` // 数据传输模式
	IP           string    `gorm:"column:ip;notNull;default:''" json:"ip"`
	Port         int       `gorm:"column:port;notNull;default:0" json:"port"`
	IsOnline     bool      `gorm:"column:is_online;notNull;default:FALSE" json:"is_online"`
	RegisteredAt orm.Time  `gorm:"column:registered_at;notNull;default:CURRENT_TIMESTAMP;comment:注册时间" json:"registered_at"` // 注册时间
	KeepaliveAt  orm.Time  `gorm:"column:keepalive_at;notNull;default:CURRENT_TIMESTAMP;comment:心跳时间" json:"keepalive_at"`   // 心跳时间
	Keepalives   int       `gorm:"column:keepalives;notNull;default:0;comment:心跳间隔" json:"keepalives"`                       // 心跳间隔
	Expires      int       `gorm:"column:expires;notNull;default:0;comment:注册有效期" json:"expires"`                            // 注册有效期
	Channels     int       `gorm:"column:channels;notNull;default:0;comment:通道数量" json:"channels"`                           // 通道数量
	CreatedAt    orm.Time  `gorm:"column:created_at;notNull;default:CURRENT_TIMESTAMP;comment:创建时间" json:"created_at"`       // 创建时间
	UpdatedAt    orm.Time  `gorm:"column:updated_at;notNull;default:CURRENT_TIMESTAMP;comment:更新时间" json:"updated_at"`       // 更新时间
	Password     string    `gorm:"column:password;notNull;default:'';comment:注册密码" json:"password"`
	Address      string    `gorm:"column:address;notNull;default:'';comment:设备网络地址" json:"address"`
	Ext          DeviceExt `gorm:"column:ext;notNull;default:'{}';type:jsonb;comment:设备属性" json:"ext"` // 设备属性
	Username     string    `gorm:"column:username;notNull;default:'';comment:用户名" json:"username"`

	Children []*Channel `gorm:"-" json:"children,omitzero"`
}

type DeviceExt struct {
	Manufacturer     string  `json:"manufacturer"`      // 生产厂商
	Model            string  `json:"model"`             // 型号
	Firmware         string  `json:"firmware"`          // 固件版本
	Name             string  `json:"name"`              // 设备名
	GBVersion        string  `json:"gb_version"`        // GB版本
	Zones            []Zone  `json:"zones"`             // 区域
	EnabledAI        bool    `json:"enabled_ai"`        // 是否启用 AI
	AnalysisInterval float32 `json:"analysis_interval"` // AI 分析间隔（秒），0 表示使用默认值

	// 空串表示 always
	RecordMode string `json:"record_mode"` // 录像模式, 一直录制:always, 按AI触发:ai, 不录制:none
}

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

	Session(ctx context.Context, changeFns ...func(*gorm.DB) error) error
}

type EditChannelInput struct {
	DeviceID string    `json:"device_id"` // 国标编码
	Name     string    `json:"name"`      // 通道名称
	PTZType  int       `json:"ptztype"`   // 云台类型
	IsOnline bool      `json:"is_online"` // 是否在线
	Ext      DeviceExt `json:"ext"`

	// RTMP/RTSP 配置
	App    string       `json:"app"`    // 应用名（RTMP/RTSP 可自定义，但不能为 rtp）
	Stream string       `json:"stream"` // 流 ID（RTMP/RTSP 可自定义）
	Config StreamConfig `json:"config"` // 流配置
}

type EditDeviceInput struct {
	DeviceID   string `json:"device_id"`   // 20 位国标编号
	Name       string `json:"name"`        // 设备名称
	Password   string `json:"password"`    // 注册密码
	StreamMode int    `json:"stream_mode"` // 数据传输模式

	Username string `json:"username"` // 用户名
	IP       string `json:"ip"`       // ip
	Port     int    `json:"port"`     // port

}

type FindChannelInput struct {
	web.PagerFilter
	DID      string `form:"did"`       // 设备 id
	DeviceID string `form:"device_id"` // 国标编码
	Key      string `form:"key"`       // 名称/国标编码 模糊搜索，id 精确搜索
	IsOnline string `form:"is_online"` // 是否在线
	Type     string `form:"type"`      // 通道类型 (GB28181/ONVIF/RTMP/RTSP)
	App      string `form:"app"`       // 应用名
	Stream   string `form:"stream"`    // 流 ID
}

type FindDeviceInput struct {
	web.PagerFilter
	Key string `form:"key"`
}

type Hooker interface {
	OnStreamNotFound(ctx context.Context, app, stream string) error
	// OnStreamChanged 流注销时调用，用于更新通道状态
	// app/stream 用于支持自定义 app/stream 的 RTMP/RTSP 通道
	OnStreamChanged(ctx context.Context, app, stream string) error
}

type OnPublisher interface {
	// OnPublish 处理推流鉴权
	// 返回 true 表示鉴权通过，false 表示鉴权失败
	// app/stream 用于支持自定义 app/stream 的 RTMP/RTSP 通道
	OnPublish(ctx context.Context, app, stream string, params map[string]string) (bool, error)
}

type PTZCommand struct {
	Action    string  `json:"action"`    // 动作类型: continuous(连续移动), absolute(绝对移动), relative(相对移动), stop(停止), preset(预置位)
	Direction string  `json:"direction"` // 方向: up, down, left, right, upleft, upright, downleft, downright, zoomin, zoomout
	Speed     float64 `json:"speed"`     // 速度 (0-1), 默认 0.5
	X         float64 `json:"x"`         // X 轴位置 (绝对/相对移动时使用, -1 到 1)
	Y         float64 `json:"y"`         // Y 轴位置 (绝对/相对移动时使用, -1 到 1)
	Zoom      float64 `json:"zoom"`      // 缩放值 (绝对/相对移动时使用, 0 到 1)
	PresetID  string  `json:"preset_id"` // 预置位 ID
	PresetOp  string  `json:"preset_op"` // 预置位操作: goto(转到), set(设置), remove(删除)
}

type PlayResponse struct {
	SSRC   string // GB28181 SSRC
	Stream string // 流 ID
	RTSP   string // RTSP 地址 (ONVIF)
}

type Protocoler interface {
	// ValidateDevice 验证设备连接（添加设备前调用）
	// 可以修改设备信息（如从 ONVIF 获取的固件版本等）
	ValidateDevice(ctx context.Context, device *Device) error

	// InitDevice 初始化设备连接（添加设备后调用）
	// 例如: GB28181 不需要主动初始化，ONVIF 需要查询 Profiles 作为通道
	InitDevice(ctx context.Context, device *Device) error

	// QueryCatalog 查询设备目录/通道
	QueryCatalog(ctx context.Context, device *Device) error

	// StartPlay 开始播放
	StartPlay(ctx context.Context, device *Device, channel *Channel) (*PlayResponse, error)

	// StopPlay 停止播放
	StopPlay(ctx context.Context, device *Device, channel *Channel) error

	DeleteDevice(ctx context.Context, device *Device) error

	// PTZControl 云台控制
	PTZControl(ctx context.Context, device *Device, channel *Channel, cmd PTZCommand) error

	Hooker
}

type Storer interface {
	Device() DeviceStorer
	Channel() ChannelStorer
}

type StreamConfig struct {
	// RTMP 推流配置
	IsAuthDisabled bool      `json:"is_auth_disabled"`    // 是否禁用推流鉴权
	Session        string    `json:"session,omitempty"`   // 推流鉴权参数（由推流客户端携带）
	PushedAt       *orm.Time `json:"pushed_at"`           // 最后推流时间
	StoppedAt      *orm.Time `json:"stopped_at"`          // 最后停止时间
	MediaServerID  string    `json:"media_server_id"`     // 媒体服务器 ID
	PushAddr       string    `json:"push_addr,omitempty"` // 推流地址（动态生成，不持久化）

	// RTSP 拉流配置
	SourceURL                 string `json:"source_url"`                   // 原始 URL
	Transport                 int    `json:"transport"`                    // 拉流方式 (0:tcp, 1:udp)
	TimeoutS                  int    `json:"timeout_s"`                    // 超时时间
	EnabledAudio              bool   `json:"enabled_audio"`                // 是否启用音频
	EnabledRemoveNoneReader   bool   `json:"enabled_remove_none_reader"`   // 无人观看时删除
	EnabledDisabledNoneReader bool   `json:"enabled_disabled_none_reader"` // 无人观看时禁用
	StreamKey                 string `json:"stream_key"`                   // ZLM 返回的 key
	Enabled                   bool   `json:"enabled"`                      // 是否启用
}

type Zone struct {
	Name        string    `json:"name"`        // 区域名称
	Coordinates []float32 `json:"coordinates"` // 坐标
	Color       string    `json:"color"`       // 颜色，支持 hex 颜色值，如 #FF0000
	Labels      []string  `json:"labels"`      // 标签
}