handlers

package
v1.3.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 12, 2026 License: GPL-3.0 Imports: 47 Imported by: 0

Documentation

Index

Constants

View Source
const SITEMAP_MAX_URLS = 50000 // 每个sitemap最多5万个URL

Variables

This section is empty.

Functions

func BatchCheckResourceValidity added in v1.3.5

func BatchCheckResourceValidity(c *gin.Context)

BatchCheckResourceValidity 批量检查资源链接有效性

func BatchCreateReadyResources

func BatchCreateReadyResources(c *gin.Context)

BatchCreateReadyResources 批量创建待处理资源

func BatchDeleteResources added in v1.0.8

func BatchDeleteResources(c *gin.Context)

BatchDeleteResources 批量删除资源

func BatchRestoreToReadyPool added in v1.2.0

func BatchRestoreToReadyPool(c *gin.Context)

BatchRestoreToReadyPool 批量将失败资源重新放入待处理池

func BatchRestoreToReadyPoolByQuery added in v1.2.0

func BatchRestoreToReadyPoolByQuery(c *gin.Context)

BatchRestoreToReadyPoolByQuery 根据查询条件批量将失败资源重新放入待处理池

func ChangePassword

func ChangePassword(c *gin.Context)

ChangePassword 修改用户密码(管理员)

func CheckResourceExists

func CheckResourceExists(c *gin.Context)

CheckResourceExists 检查资源是否存在(测试FindExists函数)

func CheckResourceValidity added in v1.3.5

func CheckResourceValidity(c *gin.Context)

CheckResourceValidity 检查资源链接有效性

func CheckUpdate

func CheckUpdate(c *gin.Context)

CheckUpdate 检查更新

func ClearAPIAccessLogs added in v1.3.1

func ClearAPIAccessLogs(c *gin.Context)

ClearAPIAccessLogs 清理API访问日志

func ClearAllErrorsByQuery added in v1.2.0

func ClearAllErrorsByQuery(c *gin.Context)

ClearAllErrorsByQuery 根据查询条件批量清除错误信息并删除资源

func ClearErrorMsg added in v1.0.10

func ClearErrorMsg(c *gin.Context)

ClearErrorMsg 清除指定资源的错误信息

func ClearReadyResources

func ClearReadyResources(c *gin.Context)

ClearReadyResources 清空所有待处理资源

func ClearSystemLogs added in v1.3.2

func ClearSystemLogs(c *gin.Context)

ClearSystemLogs 清理系统日志

func CreateCategory

func CreateCategory(c *gin.Context)

CreateCategory 创建分类

func CreateCks

func CreateCks(c *gin.Context)

CreateCks 创建Cookie

func CreateHotDrama

func CreateHotDrama(c *gin.Context)

CreateHotDrama 创建热播剧记录

func CreatePan

func CreatePan(c *gin.Context)

CreatePan 创建平台

func CreateReadyResourcesFromText

func CreateReadyResourcesFromText(c *gin.Context)

CreateReadyResourcesFromText 从文本创建待处理资源

func CreateResource

func CreateResource(c *gin.Context)

CreateResource 创建资源

func CreateTag

func CreateTag(c *gin.Context)

CreateTag 创建标签

func CreateUser

func CreateUser(c *gin.Context)

CreateUser 创建用户(管理员)

func DeleteCategory

func DeleteCategory(c *gin.Context)

DeleteCategory 删除分类

func DeleteCks

func DeleteCks(c *gin.Context)

DeleteCks 删除Cookie

func DeleteHotDrama

func DeleteHotDrama(c *gin.Context)

DeleteHotDrama 删除热播剧记录

func DeletePan

func DeletePan(c *gin.Context)

DeletePan 删除平台

func DeleteReadyResource

func DeleteReadyResource(c *gin.Context)

DeleteReadyResource 删除待处理资源

func DeleteReadyResourcesByKey added in v1.0.10

func DeleteReadyResourcesByKey(c *gin.Context)

DeleteReadyResourcesByKey 根据key删除待处理资源

func DeleteRelatedResources added in v1.3.4

func DeleteRelatedResources(c *gin.Context)

DeleteRelatedResources 删除关联资源

func DeleteResource

func DeleteResource(c *gin.Context)

DeleteResource 删除资源

func DeleteTag

func DeleteTag(c *gin.Context)

DeleteTag 删除标签

func DeleteUser

func DeleteUser(c *gin.Context)

DeleteUser 删除用户(管理员)

func ErrorResponse

func ErrorResponse(c *gin.Context, message string, code int)

ErrorResponse 错误响应

func FetchHotDramaNames

func FetchHotDramaNames(c *gin.Context)

手动获取热播剧名字

func GenerateFullSitemap added in v1.3.5

func GenerateFullSitemap(c *gin.Context)

手动生成完整sitemap文件

func GenerateSitemap added in v1.3.5

func GenerateSitemap(c *gin.Context)

GenerateSitemap 手动生成sitemap

func GetAPIAccessLogStats added in v1.3.1

func GetAPIAccessLogStats(c *gin.Context)

GetAPIAccessLogStats 获取API访问日志统计

func GetAPIAccessLogSummary added in v1.3.1

func GetAPIAccessLogSummary(c *gin.Context)

GetAPIAccessLogSummary 获取API访问日志汇总

func GetAPIAccessLogs added in v1.3.1

func GetAPIAccessLogs(c *gin.Context)

GetAPIAccessLogs 获取API访问日志

func GetCategories

func GetCategories(c *gin.Context)

GetCategories 获取分类列表

func GetCks

func GetCks(c *gin.Context)

GetCks 获取Cookie列表

func GetCksByID

func GetCksByID(c *gin.Context)

GetCksByID 根据ID获取Cookie详情

func GetCksByIDGlobal

func GetCksByIDGlobal(c *gin.Context)

GetCksByID 根据ID获取Cookie详情(使用全局repoManager)

func GetConfigStatus added in v1.2.3

func GetConfigStatus(c *gin.Context)

新增:配置监控端点

func GetDailyStats

func GetDailyStats(c *gin.Context)

GetDailyStats 获取每日统计(使用全局repoManager)

func GetFullVersionInfo

func GetFullVersionInfo(c *gin.Context)

GetFullVersionInfo 获取完整版本信息

func GetHotDramaByID

func GetHotDramaByID(c *gin.Context)

GetHotDramaByID 根据ID获取热播剧详情(使用全局repoManager)

func GetHotDramaList

func GetHotDramaList(c *gin.Context)

GetHotDramaList 获取热播剧列表(使用全局repoManager)

func GetHotKeywords

func GetHotKeywords(c *gin.Context)

GetHotKeywords 获取热门关键词(使用全局repoManager)

func GetHotResources added in v1.3.5

func GetHotResources(c *gin.Context)

GetHotResources 获取热门资源

func GetKeywordTrend

func GetKeywordTrend(c *gin.Context)

GetKeywordTrend 获取关键词趋势(使用全局repoManager)

func GetPan

func GetPan(c *gin.Context)

GetPan 根据ID获取平台

func GetPans

func GetPans(c *gin.Context)

GetPans 获取平台列表

func GetPerformanceStats

func GetPerformanceStats(c *gin.Context)

GetPerformanceStats 获取性能监控信息

func GetPosterImage added in v1.3.0

func GetPosterImage(c *gin.Context)

GetPosterImage 获取海报图片代理

func GetProfile

func GetProfile(c *gin.Context)

GetProfile 获取用户资料

func GetPublicSiteVerificationCode added in v1.3.5

func GetPublicSiteVerificationCode(c *gin.Context)

GetPublicSiteVerificationCode 获取网站验证代码(公开访问)

func GetPublicSystemConfig added in v1.0.8

func GetPublicSystemConfig(c *gin.Context)

新增:公开获取系统配置(不含api_token)

func GetReadyResources

func GetReadyResources(c *gin.Context)

GetReadyResources 获取待处理资源列表

func GetReadyResourcesByKey added in v1.0.10

func GetReadyResourcesByKey(c *gin.Context)

GetReadyResourcesByKey 根据key获取待处理资源

func GetReadyResourcesWithErrors added in v1.0.10

func GetReadyResourcesWithErrors(c *gin.Context)

GetReadyResourcesWithErrors 获取有错误信息的待处理资源

func GetRelatedResources added in v1.3.5

func GetRelatedResources(c *gin.Context)

GetRelatedResources 获取相关资源

func GetResourceByID

func GetResourceByID(c *gin.Context)

GetResourceByID 根据ID获取资源

func GetResourceLink(c *gin.Context)

GetResourceLink 获取资源链接(智能转存)

func GetResources

func GetResources(c *gin.Context)

GetResources 获取资源列表

func GetResourcesByKey added in v1.3.5

func GetResourcesByKey(c *gin.Context)

GetResourcesByKey 根据Key获取资源组

func GetSchedulerStatus

func GetSchedulerStatus(c *gin.Context)

GetSchedulerStatus 获取调度器状态

func GetSearchStats

func GetSearchStats(c *gin.Context)

GetSearchStats 获取搜索统计(使用全局repoManager)

func GetSearchStatsSummary added in v1.0.8

func GetSearchStatsSummary(c *gin.Context)

GetSearchStatsSummary 获取搜索统计汇总

func GetSearchTrend

func GetSearchTrend(c *gin.Context)

GetSearchTrend 获取搜索趋势(使用全局repoManager)

func GetSearchesTrend added in v1.2.0

func GetSearchesTrend(c *gin.Context)

GetSearchesTrend 获取搜索量趋势数据

func GetSitemapConfig added in v1.3.5

func GetSitemapConfig(c *gin.Context)

GetSitemapConfig 获取sitemap配置

func GetSitemapStatus added in v1.3.5

func GetSitemapStatus(c *gin.Context)

GetSitemapStatus 获取sitemap生成状态

func GetStats

func GetStats(c *gin.Context)

GetStats 获取基础统计信息

func GetSystemConfig

func GetSystemConfig(c *gin.Context)

GetSystemConfig 获取系统配置(使用全局repoManager)

func GetSystemInfo

func GetSystemInfo(c *gin.Context)

GetSystemInfo 获取系统信息

func GetSystemLogFiles added in v1.3.2

func GetSystemLogFiles(c *gin.Context)

GetSystemLogFiles 获取系统日志文件列表

func GetSystemLogSummary added in v1.3.2

func GetSystemLogSummary(c *gin.Context)

GetSystemLogSummary 获取系统日志统计摘要

func GetSystemLogs added in v1.3.2

func GetSystemLogs(c *gin.Context)

GetSystemLogs 获取系统日志

func GetTagByID

func GetTagByID(c *gin.Context)

GetTagByID 根据ID获取标签详情

func GetTagByIDGlobal

func GetTagByIDGlobal(c *gin.Context)

GetTagByID 根据ID获取标签详情(使用全局repoManager)

func GetTags

func GetTags(c *gin.Context)

GetTags 获取标签列表

func GetTagsByCategory

func GetTagsByCategory(c *gin.Context)

GetTagsByCategory 根据分类ID获取标签列表

func GetTagsGlobal

func GetTagsGlobal(c *gin.Context)

GetTags 获取标签列表(使用全局repoManager)

func GetUsers

func GetUsers(c *gin.Context)

GetUsers 获取用户列表(管理员)

func GetVersion

func GetVersion(c *gin.Context)

GetVersion 获取版本信息

func GetVersionString

func GetVersionString(c *gin.Context)

GetVersionString 获取版本字符串

func GetViewsTrend added in v1.2.0

func GetViewsTrend(c *gin.Context)

GetViewsTrend 获取访问量趋势数据

func IncrementResourceViewCount added in v1.0.8

func IncrementResourceViewCount(c *gin.Context)

增加资源浏览次数

func ListResponse

func ListResponse(c *gin.Context, data interface{}, total int64)

ListResponse 列表响应

func Login

func Login(c *gin.Context)

Login 用户登录

func PageResponse

func PageResponse(c *gin.Context, data interface{}, total int64, page, limit int)

PageResponse 分页响应

func RecordSearch

func RecordSearch(c *gin.Context)

RecordSearch 记录搜索

func RefreshCapacity

func RefreshCapacity(c *gin.Context)

RefreshCapacity 刷新账号容量信息

func Register

func Register(c *gin.Context)

Register 用户注册

func RegisterCopyrightClaimRoutes added in v1.3.5

func RegisterCopyrightClaimRoutes(router *gin.RouterGroup, copyrightClaimRepo repo.CopyrightClaimRepository, resourceRepo repo.ResourceRepository)

RegisterCopyrightClaimRoutes 注册版权申述相关路由

func RegisterReportRoutes added in v1.3.5

func RegisterReportRoutes(router *gin.RouterGroup, reportRepo repo.ReportRepository, resourceRepo repo.ResourceRepository)

RegisterReportRoutes 注册举报相关路由

func RetryFailedResources added in v1.0.10

func RetryFailedResources(c *gin.Context)

RetryFailedResources 重试失败的资源

func SearchResources

func SearchResources(c *gin.Context)

SearchResources 搜索资源

func SetMeilisearchManager added in v1.2.4

func SetMeilisearchManager(manager *services.MeilisearchManager)

SetMeilisearchManager 设置Meilisearch管理器

func SetRepositoryManager

func SetRepositoryManager(manager *repo.RepositoryManager)

SetRepositoryManager 设置Repository管理器

func SetSitemapDependencies added in v1.3.5

func SetSitemapDependencies(
	resourceRepository repo.ResourceRepository,
	systemConfigRepository repo.SystemConfigRepository,
	hotDramaRepository repo.HotDramaRepository,
	readyResourceRepository repo.ReadyResourceRepository,
	panRepository repo.PanRepository,
	cksRepository repo.CksRepository,
	tagRepository repo.TagRepository,
	categoryRepository repo.CategoryRepository,
)

SetSitemapDependencies 注册Sitemap处理器依赖

func SitemapIndexHandler added in v1.3.5

func SitemapIndexHandler(c *gin.Context)

SitemapIndexHandler sitemap索引文件处理器

func SitemapPageHandler added in v1.3.5

func SitemapPageHandler(c *gin.Context)

SitemapPageHandler sitemap页面处理器

func StartHotDramaScheduler

func StartHotDramaScheduler(c *gin.Context)

启动热播剧定时任务

func StartReadyResourceScheduler

func StartReadyResourceScheduler(c *gin.Context)

启动待处理资源自动处理任务

func StopHotDramaScheduler

func StopHotDramaScheduler(c *gin.Context)

停止热播剧定时任务

func StopReadyResourceScheduler

func StopReadyResourceScheduler(c *gin.Context)

停止待处理资源自动处理任务

func SuccessResponse

func SuccessResponse(c *gin.Context, data interface{})

SuccessResponse 成功响应

func ToggleAutoProcess added in v1.0.10

func ToggleAutoProcess(c *gin.Context)

新增:切换自动处理配置

func TriggerHotDramaScheduler

func TriggerHotDramaScheduler(c *gin.Context)

手动触发热播剧定时任务

func TriggerReadyResourceScheduler

func TriggerReadyResourceScheduler(c *gin.Context)

手动触发待处理资源自动处理任务

func UpdateCategory

func UpdateCategory(c *gin.Context)

UpdateCategory 更新分类

func UpdateCks

func UpdateCks(c *gin.Context)

UpdateCks 更新Cookie

func UpdateHotDrama

func UpdateHotDrama(c *gin.Context)

UpdateHotDrama 更新热播剧记录

func UpdatePan

func UpdatePan(c *gin.Context)

UpdatePan 更新平台

func UpdateResource

func UpdateResource(c *gin.Context)

UpdateResource 更新资源

func UpdateSitemapConfig added in v1.3.5

func UpdateSitemapConfig(c *gin.Context)

UpdateSitemapConfig 更新sitemap配置

func UpdateSystemConfig

func UpdateSystemConfig(c *gin.Context)

UpdateSystemConfig 更新系统配置(使用全局repoManager)

func UpdateTag

func UpdateTag(c *gin.Context)

UpdateTag 更新标签

func UpdateUser

func UpdateUser(c *gin.Context)

UpdateUser 更新用户(管理员)

Types

type BatchTransferResource added in v1.2.0

type BatchTransferResource struct {
	Title      string `json:"title" binding:"required"`
	URL        string `json:"url" binding:"required"`
	CategoryID uint   `json:"category_id,omitempty"`
	PanID      uint   `json:"pan_id,omitempty"`
	Tags       []uint `json:"tags,omitempty"`
}

批量转存任务资源项

type BingHandler added in v1.3.5

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

BingHandler Bing相关处理器

func NewBingHandler added in v1.3.5

func NewBingHandler(siteURL string, repoManager *repo.RepositoryManager) *BingHandler

NewBingHandler 创建Bing处理器

func (*BingHandler) GetBingIndexConfig added in v1.3.5

func (h *BingHandler) GetBingIndexConfig(c *gin.Context)

GetBingIndexConfig 获取Bing索引配置

func (*BingHandler) UpdateBingIndexConfig added in v1.3.5

func (h *BingHandler) UpdateBingIndexConfig(c *gin.Context)

UpdateBingIndexConfig 更新Bing索引配置

type CopyrightClaimHandler added in v1.3.5

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

func NewCopyrightClaimHandler added in v1.3.5

func NewCopyrightClaimHandler(copyrightClaimRepo repo.CopyrightClaimRepository, resourceRepo repo.ResourceRepository) *CopyrightClaimHandler

func (*CopyrightClaimHandler) CreateCopyrightClaim added in v1.3.5

func (h *CopyrightClaimHandler) CreateCopyrightClaim(c *gin.Context)

CreateCopyrightClaim 创建版权申述 @Summary 创建版权申述 @Description 提交资源版权申述 @Tags CopyrightClaim @Accept json @Produce json @Param request body dto.CopyrightClaimCreateRequest true "版权申述信息" @Success 200 {object} Response{data=dto.CopyrightClaimResponse} @Failure 400 {object} Response @Failure 500 {object} Response @Router /copyright-claims [post]

func (*CopyrightClaimHandler) DeleteCopyrightClaim added in v1.3.5

func (h *CopyrightClaimHandler) DeleteCopyrightClaim(c *gin.Context)

DeleteCopyrightClaim 删除版权申述 @Summary 删除版权申述 @Description 删除版权申述记录 @Tags CopyrightClaim @Produce json @Param id path int true "版权申述ID" @Success 200 {object} Response @Failure 400 {object} Response @Failure 500 {object} Response @Router /copyright-claims/{id} [delete]

func (*CopyrightClaimHandler) GetCopyrightClaim added in v1.3.5

func (h *CopyrightClaimHandler) GetCopyrightClaim(c *gin.Context)

GetCopyrightClaim 获取版权申述详情 @Summary 获取版权申述详情 @Description 根据ID获取版权申述详情 @Tags CopyrightClaim @Produce json @Param id path int true "版权申述ID" @Success 200 {object} Response{data=dto.CopyrightClaimResponse} @Failure 400 {object} Response @Failure 404 {object} Response @Failure 500 {object} Response @Router /copyright-claims/{id} [get]

func (*CopyrightClaimHandler) GetCopyrightClaimByResource added in v1.3.5

func (h *CopyrightClaimHandler) GetCopyrightClaimByResource(c *gin.Context)

GetCopyrightClaimByResource 获取某个资源的版权申述列表 @Summary 获取资源版权申述列表 @Description 获取某个资源的所有版权申述记录 @Tags CopyrightClaim @Produce json @Param resource_key path string true "资源Key" @Success 200 {object} Response{data=[]dto.CopyrightClaimResponse} @Failure 400 {object} Response @Failure 500 {object} Response @Router /copyright-claims/resource/{resource_key} [get]

func (*CopyrightClaimHandler) ListCopyrightClaims added in v1.3.5

func (h *CopyrightClaimHandler) ListCopyrightClaims(c *gin.Context)

ListCopyrightClaims 获取版权申述列表 @Summary 获取版权申述列表 @Description 获取版权申述列表(支持分页和状态筛选) @Tags CopyrightClaim @Produce json @Param page query int false "页码" default(1) @Param page_size query int false "每页数量" default(10) @Param status query string false "处理状态" @Success 200 {object} Response{data=object{items=[]dto.CopyrightClaimResponse,total=int}} @Failure 400 {object} Response @Failure 500 {object} Response @Router /copyright-claims [get]

func (*CopyrightClaimHandler) UpdateCopyrightClaim added in v1.3.5

func (h *CopyrightClaimHandler) UpdateCopyrightClaim(c *gin.Context)

UpdateCopyrightClaim 更新版权申述状态 @Summary 更新版权申述状态 @Description 更新版权申述处理状态 @Tags CopyrightClaim @Accept json @Produce json @Param id path int true "版权申述ID" @Param request body dto.CopyrightClaimUpdateRequest true "更新信息" @Success 200 {object} Response{data=dto.CopyrightClaimResponse} @Failure 400 {object} Response @Failure 404 {object} Response @Failure 500 {object} Response @Router /copyright-claims/{id} [put]

type ExecutionStats added in v1.3.6

type ExecutionStats struct {
	TotalExecutions int64      `json:"total_executions"`
	SuccessRate     float64    `json:"success_rate"`
	AverageTime     int64      `json:"average_time"`
	LastExecution   *time.Time `json:"last_execution,omitempty"`
}

ExecutionStats 执行统计

type FileHandler added in v1.2.3

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

FileHandler 文件处理器

func NewFileHandler added in v1.2.3

func NewFileHandler(fileRepo repo.FileRepository, systemConfigRepo repo.SystemConfigRepository, userRepo repo.UserRepository) *FileHandler

NewFileHandler 创建文件处理器

func (*FileHandler) DeleteFiles added in v1.2.3

func (h *FileHandler) DeleteFiles(c *gin.Context)

DeleteFiles 删除文件

func (*FileHandler) GetFileList added in v1.2.3

func (h *FileHandler) GetFileList(c *gin.Context)

GetFileList 获取文件列表

func (*FileHandler) UpdateFile added in v1.2.3

func (h *FileHandler) UpdateFile(c *gin.Context)

UpdateFile 更新文件信息

func (*FileHandler) UploadFile added in v1.2.3

func (h *FileHandler) UploadFile(c *gin.Context)

UploadFile 上传文件

func (*FileHandler) UploadWechatVerifyFile added in v1.3.3

func (h *FileHandler) UploadWechatVerifyFile(c *gin.Context)

UploadWechatVerifyFile 上传微信公众号验证文件(TXT文件) 无需认证,仅支持TXT文件,不记录数据库,直接保存到uploads目录

type GoogleIndexHandler added in v1.3.5

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

GoogleIndexHandler Google索引处理程序

func NewGoogleIndexHandler added in v1.3.5

func NewGoogleIndexHandler(
	repoMgr *repo.RepositoryManager,
	taskManager *task.TaskManager,
) *GoogleIndexHandler

NewGoogleIndexHandler 创建Google索引处理程序

func (*GoogleIndexHandler) CreateTask added in v1.3.5

func (h *GoogleIndexHandler) CreateTask(c *gin.Context)

CreateTask 创建Google索引任务

func (*GoogleIndexHandler) DiagnosePermissions added in v1.3.5

func (h *GoogleIndexHandler) DiagnosePermissions(c *gin.Context)

DiagnosePermissions 诊断Google API权限

func (*GoogleIndexHandler) GetAllConfig added in v1.3.5

func (h *GoogleIndexHandler) GetAllConfig(c *gin.Context)

GetAllConfig 获取所有Google索引配置(以分组形式返回)

func (*GoogleIndexHandler) GetConfig added in v1.3.5

func (h *GoogleIndexHandler) GetConfig(c *gin.Context)

GetConfig 获取Google索引配置(原有接口,为保持兼容性)

func (*GoogleIndexHandler) GetStatus added in v1.3.5

func (h *GoogleIndexHandler) GetStatus(c *gin.Context)

GetStatus 获取Google索引状态

func (*GoogleIndexHandler) GetTaskItems added in v1.3.5

func (h *GoogleIndexHandler) GetTaskItems(c *gin.Context)

GetTaskItems 获取任务项列表

func (*GoogleIndexHandler) GetTaskStatus added in v1.3.5

func (h *GoogleIndexHandler) GetTaskStatus(c *gin.Context)

GetTaskStatus 获取任务状态

func (*GoogleIndexHandler) GetTasks added in v1.3.5

func (h *GoogleIndexHandler) GetTasks(c *gin.Context)

GetTasks 获取任务列表

func (*GoogleIndexHandler) StartTask added in v1.3.5

func (h *GoogleIndexHandler) StartTask(c *gin.Context)

StartTask 启动Google索引任务

func (*GoogleIndexHandler) SubmitURLsToIndex added in v1.3.5

func (h *GoogleIndexHandler) SubmitURLsToIndex(c *gin.Context)

SubmitURLsToIndex 提交URL到Google索引

func (*GoogleIndexHandler) UpdateConfig added in v1.3.5

func (h *GoogleIndexHandler) UpdateConfig(c *gin.Context)

UpdateConfig 更新Google索引配置

func (*GoogleIndexHandler) UpdateGoogleIndexConfig added in v1.3.5

func (h *GoogleIndexHandler) UpdateGoogleIndexConfig(c *gin.Context)

UpdateGoogleIndexConfig 更新Google索引配置(支持分组配置)

func (*GoogleIndexHandler) UploadCredentials added in v1.3.5

func (h *GoogleIndexHandler) UploadCredentials(c *gin.Context)

UploadCredentials 上传Google索引凭据

func (*GoogleIndexHandler) ValidateCredentials added in v1.3.5

func (h *GoogleIndexHandler) ValidateCredentials(c *gin.Context)

ValidateCredentials 验证Google索引凭据

type HotDramaHandler

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

HotDramaHandler 热播剧处理器

func NewHotDramaHandler

func NewHotDramaHandler(hotDramaRepo repo.HotDramaRepository) *HotDramaHandler

NewHotDramaHandler 创建热播剧处理器

func (*HotDramaHandler) GetHotDramaByID

func (h *HotDramaHandler) GetHotDramaByID(c *gin.Context)

GetHotDramaByID 根据ID获取热播剧详情

func (*HotDramaHandler) GetHotDramaList

func (h *HotDramaHandler) GetHotDramaList(c *gin.Context)

GetHotDramaList 获取热播剧列表

type MeilisearchHandler added in v1.2.4

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

MeilisearchHandler Meilisearch处理器

func NewMeilisearchHandler added in v1.2.4

func NewMeilisearchHandler(meilisearchManager *services.MeilisearchManager) *MeilisearchHandler

NewMeilisearchHandler 创建Meilisearch处理器

func (*MeilisearchHandler) ClearIndex added in v1.2.4

func (h *MeilisearchHandler) ClearIndex(c *gin.Context)

ClearIndex 清空索引

func (*MeilisearchHandler) GetAllResources added in v1.2.4

func (h *MeilisearchHandler) GetAllResources(c *gin.Context)

GetAllResources 获取所有资源

func (*MeilisearchHandler) GetStatus added in v1.2.4

func (h *MeilisearchHandler) GetStatus(c *gin.Context)

GetStatus 获取Meilisearch状态

func (*MeilisearchHandler) GetSyncProgress added in v1.2.4

func (h *MeilisearchHandler) GetSyncProgress(c *gin.Context)

GetSyncProgress 获取同步进度

func (*MeilisearchHandler) GetSyncedResources added in v1.2.4

func (h *MeilisearchHandler) GetSyncedResources(c *gin.Context)

GetSyncedResources 获取已同步的资源

func (*MeilisearchHandler) GetUnsyncedCount added in v1.2.4

func (h *MeilisearchHandler) GetUnsyncedCount(c *gin.Context)

GetUnsyncedCount 获取未同步资源数量

func (*MeilisearchHandler) GetUnsyncedResources added in v1.2.4

func (h *MeilisearchHandler) GetUnsyncedResources(c *gin.Context)

GetUnsyncedResources 获取未同步的资源

func (*MeilisearchHandler) StopSync added in v1.2.4

func (h *MeilisearchHandler) StopSync(c *gin.Context)

StopSync 停止同步

func (*MeilisearchHandler) SyncAllResources added in v1.2.4

func (h *MeilisearchHandler) SyncAllResources(c *gin.Context)

SyncAllResources 同步所有资源

func (*MeilisearchHandler) TestConnection added in v1.2.4

func (h *MeilisearchHandler) TestConnection(c *gin.Context)

TestConnection 测试Meilisearch连接

func (*MeilisearchHandler) UpdateIndexSettings added in v1.2.4

func (h *MeilisearchHandler) UpdateIndexSettings(c *gin.Context)

UpdateIndexSettings 更新索引设置

type OGImageHandler added in v1.3.5

type OGImageHandler struct{}

OGImageHandler 处理OG图片生成请求

func NewOGImageHandler added in v1.3.5

func NewOGImageHandler() *OGImageHandler

NewOGImageHandler 创建新的OG图片处理器

func (*OGImageHandler) GenerateOGImage added in v1.3.5

func (h *OGImageHandler) GenerateOGImage(c *gin.Context)

GenerateOGImage 生成OG图片

type PluginHandler added in v1.3.6

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

PluginHandler 插件管理处理器

func NewPluginHandler added in v1.3.6

func NewPluginHandler(repoManager *repo.RepositoryManager, pluginManager *plugin.Manager) *PluginHandler

NewPluginHandler 创建插件处理器

func (*PluginHandler) DisablePlugin added in v1.3.6

func (h *PluginHandler) DisablePlugin(c *gin.Context)

DisablePlugin 禁用插件

func (*PluginHandler) EnablePlugin added in v1.3.6

func (h *PluginHandler) EnablePlugin(c *gin.Context)

EnablePlugin 启用插件

func (*PluginHandler) GetInstalledPlugins added in v1.3.6

func (h *PluginHandler) GetInstalledPlugins(c *gin.Context)

GetInstalledPlugins 获取已安装的插件列表

func (*PluginHandler) GetPlugin added in v1.3.6

func (h *PluginHandler) GetPlugin(c *gin.Context)

GetPlugin 获取插件详情

func (*PluginHandler) GetPluginLogs added in v1.3.6

func (h *PluginHandler) GetPluginLogs(c *gin.Context)

GetPluginLogs 获取插件日志

func (*PluginHandler) GetPluginStats added in v1.3.6

func (h *PluginHandler) GetPluginStats(c *gin.Context)

GetPluginStats 获取插件统计信息

func (*PluginHandler) GetPlugins added in v1.3.6

func (h *PluginHandler) GetPlugins(c *gin.Context)

GetPlugins 获取插件列表

func (*PluginHandler) InstallPlugin added in v1.3.6

func (h *PluginHandler) InstallPlugin(c *gin.Context)

InstallPlugin 安装插件

func (*PluginHandler) LoadPlugin added in v1.3.6

func (h *PluginHandler) LoadPlugin(c *gin.Context)

LoadPlugin 加载插件

func (*PluginHandler) ReloadPlugin added in v1.3.6

func (h *PluginHandler) ReloadPlugin(c *gin.Context)

ReloadPlugin 重新加载插件

func (*PluginHandler) UninstallPlugin added in v1.3.6

func (h *PluginHandler) UninstallPlugin(c *gin.Context)

UninstallPlugin 卸载插件

func (*PluginHandler) UnloadPlugin added in v1.3.6

func (h *PluginHandler) UnloadPlugin(c *gin.Context)

UnloadPlugin 卸载已加载的插件

func (*PluginHandler) UpdatePluginConfig added in v1.3.6

func (h *PluginHandler) UpdatePluginConfig(c *gin.Context)

UpdatePluginConfig 更新插件配置

type PluginInfo added in v1.3.6

type PluginInfo struct {
	ID               string                 `json:"id"`
	Name             string                 `json:"name"`
	DisplayName      string                 `json:"display_name"`
	Version          string                 `json:"version"`
	Description      string                 `json:"description"`
	Author           string                 `json:"author"`
	License          string                 `json:"license"`
	Category         string                 `json:"category"`
	Status           string                 `json:"status"`
	Enabled          bool                   `json:"enabled"`
	Config           map[string]interface{} `json:"config"`
	ConfigFields     map[string]interface{} `json:"config_fields"`
	ScheduledTasks   []ScheduledTaskInfo    `json:"scheduled_tasks"`    // 定时任务列表
	HasScheduledTask bool                   `json:"has_scheduled_task"` // 是否包含定时任务
	FileSize         int64                  `json:"file_size"`
	LastUpdated      time.Time              `json:"last_updated"`
	ExecutionStats   *ExecutionStats        `json:"execution_stats,omitempty"`
}

PluginInfo 插件信息

type PluginListResponse added in v1.3.6

type PluginListResponse struct {
	Success bool         `json:"success"`
	Data    []PluginInfo `json:"data"`
	Total   int          `json:"total"`
}

PluginListResponse 插件列表响应

type PublicAPIHandler

type PublicAPIHandler struct{}

PublicAPIHandler 公开API处理器

func NewPublicAPIHandler

func NewPublicAPIHandler() *PublicAPIHandler

NewPublicAPIHandler 创建公开API处理器

func (*PublicAPIHandler) AddBatchResources

func (h *PublicAPIHandler) AddBatchResources(c *gin.Context)

AddBatchResources godoc @Summary 批量添加资源 @Description 通过公开API批量添加多个资源到待处理列表 @Tags PublicAPI @Accept json @Produce json @Param X-API-Token header string true "API访问令牌" @Param data body dto.BatchReadyResourceRequest true "批量资源信息" @Success 200 {object} map[string]interface{} "批量添加成功" @Failure 400 {object} map[string]interface{} "请求参数错误" @Failure 401 {object} map[string]interface{} "认证失败" @Failure 500 {object} map[string]interface{} "服务器内部错误" @Router /api/public/resources/batch-add [post]

func (*PublicAPIHandler) GetHotDramas

func (h *PublicAPIHandler) GetHotDramas(c *gin.Context)

GetHotDramas godoc @Summary 获取热门剧列表 @Description 获取热门剧列表,支持分页 @Tags PublicAPI @Accept json @Produce json @Param X-API-Token header string true "API访问令牌" @Param page query int false "页码" default(1) @Param page_size query int false "每页数量" default(20) maximum(100) @Success 200 {object} map[string]interface{} "获取成功" @Failure 401 {object} map[string]interface{} "认证失败" @Failure 500 {object} map[string]interface{} "服务器内部错误" @Router /api/public/hot-dramas [get]

func (*PublicAPIHandler) SearchResources

func (h *PublicAPIHandler) SearchResources(c *gin.Context)

SearchResources godoc @Summary 资源搜索 @Description 搜索资源,支持关键词、标签、分类过滤,自动过滤包含违禁词的资源 @Tags PublicAPI @Accept json @Produce json @Param X-API-Token header string true "API访问令牌" @Param keyword query string false "搜索关键词" @Param tag query string false "标签过滤" @Param category query string false "分类过滤" @Param page query int false "页码" default(1) @Param page_size query int false "每页数量" default(20) maximum(100) @Success 200 {object} map[string]interface{} "搜索成功,如果存在违禁词过滤会返回forbidden_words_filtered字段" @Failure 401 {object} map[string]interface{} "认证失败" @Failure 500 {object} map[string]interface{} "服务器内部错误" @Router /api/public/resources/search [get]

type ReportHandler added in v1.3.5

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

func NewReportHandler added in v1.3.5

func NewReportHandler(reportRepo repo.ReportRepository, resourceRepo repo.ResourceRepository) *ReportHandler

func (*ReportHandler) CreateReport added in v1.3.5

func (h *ReportHandler) CreateReport(c *gin.Context)

CreateReport 创建举报 @Summary 创建举报 @Description 提交资源举报 @Tags Report @Accept json @Produce json @Param request body dto.ReportCreateRequest true "举报信息" @Success 200 {object} Response{data=dto.ReportResponse} @Failure 400 {object} Response @Failure 500 {object} Response @Router /reports [post]

func (*ReportHandler) DeleteReport added in v1.3.5

func (h *ReportHandler) DeleteReport(c *gin.Context)

DeleteReport 删除举报 @Summary 删除举报 @Description 删除举报记录 @Tags Report @Produce json @Param id path int true "举报ID" @Success 200 {object} Response @Failure 400 {object} Response @Failure 500 {object} Response @Router /reports/{id} [delete]

func (*ReportHandler) GetReport added in v1.3.5

func (h *ReportHandler) GetReport(c *gin.Context)

GetReport 获取举报详情 @Summary 获取举报详情 @Description 根据ID获取举报详情 @Tags Report @Produce json @Param id path int true "举报ID" @Success 200 {object} Response{data=dto.ReportResponse} @Failure 400 {object} Response @Failure 404 {object} Response @Failure 500 {object} Response @Router /reports/{id} [get]

func (*ReportHandler) GetReportByResource added in v1.3.5

func (h *ReportHandler) GetReportByResource(c *gin.Context)

GetReportByResource 获取某个资源的举报列表 @Summary 获取资源举报列表 @Description 获取某个资源的所有举报记录 @Tags Report @Produce json @Param resource_key path string true "资源Key" @Success 200 {object} Response{data=[]dto.ReportResponse} @Failure 400 {object} Response @Failure 500 {object} Response @Router /reports/resource/{resource_key} [get]

func (*ReportHandler) ListReports added in v1.3.5

func (h *ReportHandler) ListReports(c *gin.Context)

ListReports 获取举报列表 @Summary 获取举报列表 @Description 获取举报列表(支持分页和状态筛选) @Tags Report @Produce json @Param page query int false "页码" default(1) @Param page_size query int false "每页数量" default(10) @Param status query string false "处理状态" @Success 200 {object} Response{data=object{items=[]dto.ReportResponse,total=int}} @Failure 400 {object} Response @Failure 500 {object} Response @Router /reports [get]

func (*ReportHandler) UpdateReport added in v1.3.5

func (h *ReportHandler) UpdateReport(c *gin.Context)

UpdateReport 更新举报状态 @Summary 更新举报状态 @Description 更新举报处理状态 @Tags Report @Accept json @Produce json @Param id path int true "举报ID" @Param request body dto.ReportUpdateRequest true "更新信息" @Success 200 {object} Response{data=dto.ReportResponse} @Failure 400 {object} Response @Failure 404 {object} Response @Failure 500 {object} Response @Router /reports/{id} [put]

type Resource added in v1.3.5

type Resource struct {
	Title       string
	Description string
	Cover       string
	Key         string
}

Resource 简化的资源结构体

type Response

type Response struct {
	Success bool        `json:"success"`
	Message string      `json:"message"`
	Data    interface{} `json:"data"`
	Code    int         `json:"code"`
}

Response 统一响应格式

type ScheduledTaskInfo added in v1.3.6

type ScheduledTaskInfo struct {
	Name      string                 `json:"name"`      // 任务名称
	Schedule  string                 `json:"schedule"`  // 调度表达式
	Line      int                    `json:"line"`      // 所在行号
	Frequency map[string]interface{} `json:"frequency"` // 执行频率信息
}

ScheduledTaskInfo 定时任务信息

type Sitemap added in v1.3.5

type Sitemap struct {
	Loc     string `xml:"loc"`
	LastMod string `xml:"lastmod"`
}

Sitemap 单个sitemap信息

type SitemapConfig added in v1.3.5

type SitemapConfig struct {
	AutoGenerate bool      `json:"autoGenerate"`
	LastGenerate time.Time `json:"lastGenerate"`
	LastUpdate   time.Time `json:"lastUpdate"`
}

SitemapConfig sitemap配置

type SitemapFileInfo added in v1.3.5

type SitemapFileInfo struct {
	Name       string `json:"name"`
	Size       int64  `json:"size"`
	ModTime    string `json:"mod_time"`
	SizeFormat string `json:"size_format"`
}

SitemapFileInfo sitemap文件信息

type SitemapIndex added in v1.3.5

type SitemapIndex struct {
	XMLName  xml.Name  `xml:"sitemapindex"`
	XMLNS    string    `xml:"xmlns,attr"`
	Sitemaps []Sitemap `xml:"sitemap"`
}

SitemapIndex sitemap索引结构

type SystemConfigHandler

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

SystemConfigHandler 系统配置处理器

func NewSystemConfigHandler

func NewSystemConfigHandler(systemConfigRepo repo.SystemConfigRepository) *SystemConfigHandler

NewSystemConfigHandler 创建系统配置处理器

func (*SystemConfigHandler) GetConfig

func (h *SystemConfigHandler) GetConfig(c *gin.Context)

GetConfig 获取系统配置

func (*SystemConfigHandler) UpdateConfig

func (h *SystemConfigHandler) UpdateConfig(c *gin.Context)

UpdateConfig 更新系统配置

type TaskHandler added in v1.2.0

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

TaskHandler 任务处理器

func NewTaskHandler added in v1.2.0

func NewTaskHandler(repoMgr *repo.RepositoryManager, taskManager *task.TaskManager) *TaskHandler

NewTaskHandler 创建任务处理器

func (*TaskHandler) CreateBatchTransferTask added in v1.2.0

func (h *TaskHandler) CreateBatchTransferTask(c *gin.Context)

CreateBatchTransferTask 创建批量转存任务

func (*TaskHandler) CreateExpansionTask added in v1.3.0

func (h *TaskHandler) CreateExpansionTask(c *gin.Context)

CreateExpansionTask 创建扩容任务

func (*TaskHandler) DeleteTask added in v1.2.0

func (h *TaskHandler) DeleteTask(c *gin.Context)

DeleteTask 删除任务

func (*TaskHandler) GetExpansionAccounts added in v1.3.0

func (h *TaskHandler) GetExpansionAccounts(c *gin.Context)

GetExpansionAccounts 获取支持扩容的账号列表

func (*TaskHandler) GetExpansionOutput added in v1.3.0

func (h *TaskHandler) GetExpansionOutput(c *gin.Context)

GetExpansionOutput 获取账号扩容输出数据

func (*TaskHandler) GetTaskItems added in v1.2.0

func (h *TaskHandler) GetTaskItems(c *gin.Context)

GetTaskItems 获取任务项列表

func (*TaskHandler) GetTaskStatus added in v1.2.0

func (h *TaskHandler) GetTaskStatus(c *gin.Context)

GetTaskStatus 获取任务状态

func (*TaskHandler) GetTasks added in v1.2.0

func (h *TaskHandler) GetTasks(c *gin.Context)

GetTasks 获取任务列表

func (*TaskHandler) PauseTask added in v1.2.0

func (h *TaskHandler) PauseTask(c *gin.Context)

PauseTask 暂停任务

func (*TaskHandler) StartTask added in v1.2.0

func (h *TaskHandler) StartTask(c *gin.Context)

StartTask 启动任务

func (*TaskHandler) StopTask added in v1.2.0

func (h *TaskHandler) StopTask(c *gin.Context)

StopTask 停止任务

type TelegramHandler added in v1.3.0

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

TelegramHandler Telegram 处理器

func NewTelegramHandler added in v1.3.0

func NewTelegramHandler(
	telegramChannelRepo repo.TelegramChannelRepository,
	systemConfigRepo repo.SystemConfigRepository,
	telegramBotService services.TelegramBotService,
) *TelegramHandler

NewTelegramHandler 创建 Telegram 处理器

func (*TelegramHandler) ClearTelegramLogs added in v1.3.0

func (h *TelegramHandler) ClearTelegramLogs(c *gin.Context)

ClearTelegramLogs 清理旧的Telegram日志

func (*TelegramHandler) CreateChannel added in v1.3.0

func (h *TelegramHandler) CreateChannel(c *gin.Context)

CreateChannel 创建频道

func (*TelegramHandler) DebugBotConnection added in v1.3.0

func (h *TelegramHandler) DebugBotConnection(c *gin.Context)

DebugBotConnection 调试机器人连接

func (*TelegramHandler) DeleteChannel added in v1.3.0

func (h *TelegramHandler) DeleteChannel(c *gin.Context)

DeleteChannel 删除频道

func (*TelegramHandler) GetBotConfig added in v1.3.0

func (h *TelegramHandler) GetBotConfig(c *gin.Context)

GetBotConfig 获取机器人配置

func (*TelegramHandler) GetBotStatus added in v1.3.0

func (h *TelegramHandler) GetBotStatus(c *gin.Context)

GetBotStatus 获取机器人状态

func (*TelegramHandler) GetChannels added in v1.3.0

func (h *TelegramHandler) GetChannels(c *gin.Context)

GetChannels 获取频道列表

func (*TelegramHandler) GetTelegramLogStats added in v1.3.0

func (h *TelegramHandler) GetTelegramLogStats(c *gin.Context)

GetTelegramLogStats 获取Telegram日志统计信息

func (*TelegramHandler) GetTelegramLogs added in v1.3.0

func (h *TelegramHandler) GetTelegramLogs(c *gin.Context)

GetTelegramLogs 获取Telegram相关的日志

func (*TelegramHandler) HandleWebhook added in v1.3.0

func (h *TelegramHandler) HandleWebhook(c *gin.Context)

HandleWebhook 处理 Telegram Webhook

func (*TelegramHandler) ManualPushToChannel added in v1.3.5

func (h *TelegramHandler) ManualPushToChannel(c *gin.Context)

ManualPushToChannel 手动推送到频道

func (*TelegramHandler) RegisterChannelByCommand added in v1.3.0

func (h *TelegramHandler) RegisterChannelByCommand(chatID int64, chatName, chatType string) error

RegisterChannelByCommand 通过命令注册频道(供内部调用)

func (*TelegramHandler) ReloadBotConfig added in v1.3.0

func (h *TelegramHandler) ReloadBotConfig(c *gin.Context)

ReloadBotConfig 重新加载机器人配置

func (*TelegramHandler) TestBotMessage added in v1.3.0

func (h *TelegramHandler) TestBotMessage(c *gin.Context)

TestBotMessage 测试机器人消息发送

func (*TelegramHandler) UpdateBotConfig added in v1.3.0

func (h *TelegramHandler) UpdateBotConfig(c *gin.Context)

UpdateBotConfig 更新机器人配置

func (*TelegramHandler) UpdateChannel added in v1.3.0

func (h *TelegramHandler) UpdateChannel(c *gin.Context)

UpdateChannel 更新频道

func (*TelegramHandler) ValidateApiKey added in v1.3.0

func (h *TelegramHandler) ValidateApiKey(c *gin.Context)

ValidateApiKey 校验 API Key

type TransferResult added in v1.2.0

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

TransferResult 转存结果

type Url added in v1.3.5

type Url struct {
	Loc        string  `xml:"loc"`
	LastMod    string  `xml:"lastmod"`
	ChangeFreq string  `xml:"changefreq"`
	Priority   float64 `xml:"priority"`
}

Url 单个URL信息

type UrlSet added in v1.3.5

type UrlSet struct {
	XMLName xml.Name `xml:"urlset"`
	XMLNS   string   `xml:"xmlns,attr"`
	URLs    []Url    `xml:"url"`
}

UrlSet sitemap内容

type VersionResponse

type VersionResponse struct {
	Success bool        `json:"success"`
	Data    interface{} `json:"data"`
	Message string      `json:"message"`
	Time    time.Time   `json:"time"`
}

VersionResponse 版本响应结构

type WechatHandler added in v1.3.3

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

WechatHandler 微信公众号处理器

func NewWechatHandler added in v1.3.3

func NewWechatHandler(
	wechatService services.WechatBotService,
	systemConfigRepo repo.SystemConfigRepository,
) *WechatHandler

NewWechatHandler 创建微信公众号处理器

func (*WechatHandler) GetBotConfig added in v1.3.3

func (h *WechatHandler) GetBotConfig(c *gin.Context)

GetBotConfig 获取微信机器人配置

func (*WechatHandler) GetBotStatus added in v1.3.3

func (h *WechatHandler) GetBotStatus(c *gin.Context)

GetBotStatus 获取机器人状态

func (*WechatHandler) HandleWechatMessage added in v1.3.3

func (h *WechatHandler) HandleWechatMessage(c *gin.Context)

HandleWechatMessage 处理微信消息推送

func (*WechatHandler) UpdateBotConfig added in v1.3.3

func (h *WechatHandler) UpdateBotConfig(c *gin.Context)

UpdateBotConfig 更新微信机器人配置

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL