services

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

type LinkCheckOutcome struct {
	NormalizedURL string
	Status        LinkCheckStatus
	Platform      string
	FailReason    string
}

type LinkCheckService interface {
	// CheckURL 检测单个 URL（scheduler 用）
	CheckURL(ctx context.Context, rawURL string, ignoreCache bool) ResourceCheckResult
	// CheckResources 批量检测资源（详情页用），返回 map[resourceID] -> 结论
	CheckResources(ctx context.Context, resources []*entity.Resource, ignoreCache bool) map[uint]ResourceCheckResult
	// CheckURLs 按 URL 批量检测（按 url 键返回）。供统一取链服务一次校验「原始链接 + saveUrl」（FR-013）。
	CheckURLs(ctx context.Context, urls []string, ignoreCache bool) map[string]ResourceCheckResult
}

type LinkCheckStatus string

type LinkResolution struct {
	URL         string
	Type        string // "transferred" | "original"
	Platform    string // pan.Remark（展示用）
	Transferred bool
	Note        string // 可选提示（如易和谐提醒）
}

type MeilisearchDocument struct {
	ID          uint      `json:"id"`
	Title       string    `json:"title"`
	Description string    `json:"description"`
	URL         string    `json:"url"`
	SaveURL     string    `json:"save_url"`
	FileSize    string    `json:"file_size"`
	Key         string    `json:"key"`
	Category    string    `json:"category"`
	Tags        []string  `json:"tags"`
	PanName     string    `json:"pan_name"`
	PanID       *uint     `json:"pan_id"`
	Author      string    `json:"author"`
	Cover       string    `json:"cover"`
	IsValid     bool      `json:"is_valid"`
	CreatedAt   time.Time `json:"created_at"`
	UpdatedAt   time.Time `json:"updated_at"`
	// 高亮字段
	TitleHighlight       string   `json:"_title_highlight,omitempty"`
	DescriptionHighlight string   `json:"_description_highlight,omitempty"`
	CategoryHighlight    string   `json:"_category_highlight,omitempty"`
	TagsHighlight        []string `json:"_tags_highlight,omitempty"`
}

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

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

type MeilisearchStatus struct {
	Enabled       bool      `json:"enabled"`
	Healthy       bool      `json:"healthy"`
	LastCheck     time.Time `json:"last_check"`
	ErrorCount    int       `json:"error_count"`
	LastError     string    `json:"last_error"`
	DocumentCount int64     `json:"document_count"`
}

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

type ResourceCheckResult struct {
	// Status: "valid" / "invalid" / "undetermined"（未得出结论或未启用检测）
	Status string
	// FailReason 失效原因（仅 status=invalid 时有值）
	FailReason string
	// Platform 识别到的平台
	Platform string
	// DetectionMethod: "pancheck"（启用并得出结论或启用但未得出结论）/ "disabled"（未启用）
	DetectionMethod string
}

type ResourceLinkService interface {
	Resolve(ctx context.Context, resource *entity.Resource) (LinkResolution, error)
	// ResolveWithCheck 统一取链决策树（FR-013~FR-017）：双链接批量校验 → 仅原始驱动回写 →
	// saveUrl 有效直返 / saveUrl 失效先分享 / 原始失效判失效 / 原始有效转存。
	ResolveWithCheck(ctx context.Context, resource *entity.Resource) (UnifiedLinkResult, error)
}

type ResourcesStats struct {
	Today        int64 `json:"today"`
	Yesterday    int64 `json:"yesterday"`
	Total        int64 `json:"total"`
	InvalidTotal int64 `json:"invalid_total"` // 009: 失效资源总数（is_valid=false）
	SyncedTotal  int64 `json:"synced_total"`  // 009: 已同步搜索索引资源数
	TodayInvalid int64 `json:"today_invalid"` // 009: 今日失效资源数
	TodaySynced  int64 `json:"today_synced"`  // 009: 今日新同步资源数
}

type SearchSession struct {
	UserID      string            // 用户ID
	Keyword     string            // 搜索关键字
	Resources   []entity.Resource // 搜索结果
	PageSize    int               // 每页数量
	CurrentPage int               // 当前页码
	TotalPages  int               // 总页数
	LastAccess  time.Time         // 最后访问时间
}

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

type SearchesStats struct {
	Today     int64 `json:"today"`
	Yesterday int64 `json:"yesterday"`
}

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

type StatsSummary struct {
	Resources              ResourcesStats         `json:"resources"`
	Views                  ViewsStats             `json:"views"`
	Searches               SearchesStats          `json:"searches"`
	Todos                  TodosStats             `json:"todos"`
	ViewPanDistribution    []ViewDistributionItem `json:"view_pan_distribution"`
	ViewSourceDistribution []ViewDistributionItem `json:"view_source_distribution"`
}

type SyncProgress struct {
	IsRunning      bool      `json:"is_running"`
	TotalCount     int64     `json:"total_count"`
	ProcessedCount int64     `json:"processed_count"`
	SyncedCount    int64     `json:"synced_count"`
	FailedCount    int64     `json:"failed_count"`
	StartTime      time.Time `json:"start_time"`
	EstimatedTime  string    `json:"estimated_time"`
	CurrentBatch   int       `json:"current_batch"`
	TotalBatches   int       `json:"total_batches"`
	ErrorMessage   string    `json:"error_message"`
}

type TelegramBotConfig struct {
	Enabled            bool
	ApiKey             string
	AutoReplyEnabled   bool
	AutoReplyTemplate  string
	AutoDeleteEnabled  bool
	AutoDeleteInterval int // 分钟
	SearchPageSize     int // 011：搜索每页条数（钳制 3–8）
	ProxyEnabled       bool
	ProxyType          string // http, https, socks5
	ProxyHost          string
	ProxyPort          int
	ProxyUsername      string
	ProxyPassword      string
	WelcomeEnabled     bool   // 入群欢迎开关
	WelcomeMessage     string // 入群欢迎模板（支持 {{username}} {{chatname}} 占位符）
}

type TelegramBotService interface {
	Start() error
	Stop() error
	IsRunning() bool
	ReloadConfig() error
	GetRuntimeStatus() map[string]interface{}
	ValidateApiKey(apiKey string) (bool, map[string]interface{}, error)
	ValidateApiKeyWithProxy(apiKey string, proxyEnabled bool, proxyType, proxyHost string, proxyPort int, proxyUsername, proxyPassword string) (bool, map[string]interface{}, error)
	GetBotUsername() string
	SendMessage(chatID int64, text string, img string) error
	DeleteMessage(chatID int64, messageID int) error
	RegisterChannel(chatID int64, chatName, chatType string) error
	IsChannelRegistered(chatID int64) bool
	HandleWebhookUpdate(c interface{})
	CleanupDuplicateChannels() error
	ManualPushToChannel(channelID uint) error
}

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

type TgSearchSession struct {
	SessionID string
	ChatID    int64
	UserID    int64
	Keyword   string
	PageSize  int
	Total     int64
	CreatedAt time.Time
}

type TgSearchSessionStore interface {
	Create(chatID, userID int64, keyword string, pageSize int, total int64) *TgSearchSession
	Get(sessionID string) (*TgSearchSession, bool)
	Delete(sessionID string)
}

type TodosStats struct {
	ReadyResources int64 `json:"ready_resources"`
	FailedTasks    int64 `json:"failed_tasks"`
	PendingReports int64 `json:"pending_reports"`
}

type TransferResult struct {
	Success  bool   `json:"success"`
	Fid      string `json:"fid"`
	SaveURL  string `json:"save_url"`
	ErrorMsg string `json:"error_msg"`
}

type UnifiedLinkResult struct {
	URL       string // 最终交付链接（Invalid=true 时为空）
	Type      string // "transferred" | "reshared" | "original" | "invalid"
	Invalid   bool   // 资源判定失效（原始链接失效）→ 调用方给失效提示、不交付链接
	Platform  string // 展示用平台名
	Note      string // 可选提示（如易和谐提醒）
	Refreshed bool   // 是否刷新了 saveUrl（分享/转存成功并回写）
}

type ViewDistributionItem struct {
	Key     string `json:"key"`
	Name    string `json:"name"`
	Count   int64  `json:"count"`
	Percent int    `json:"percent"`
}

type ViewsStats struct {
	Today     int64 `json:"today"`
	Yesterday int64 `json:"yesterday"`
	Total     int64 `json:"total"` // 009: 访问（获取资源）总次数
}

type WechatBotConfig struct {
	Enabled          bool
	AppID            string
	AppSecret        string
	Token            string
	EncodingAesKey   string
	WelcomeMessage   string
	AutoReplyEnabled bool
	SearchLimit      int
}

type WechatBotService interface {
	Start() error
	Stop() error
	IsRunning() bool
	ReloadConfig() error
	HandleMessage(msg *message.MixMessage) (interface{}, error)
	SendWelcomeMessage(openID string) error
	GetRuntimeStatus() map[string]interface{}
	GetConfig() *WechatBotConfig
}

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