handler

package
v0.3.3 Latest Latest
Warning

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

 Go to latest Published: Jul 23, 2026 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PermGuard added in v0.2.1 

func PermGuard(
	permSvc PermGuarder,
	resourceType types.ResourceType,
	action types.Action,
	extractPublicID PublicIDExtractor,
) gin.HandlerFunc

PermGuard 返回一个声明式权限校验中间件（单 action），可直接挂在路由链上。

func PermGuardActions added in v0.2.1 

func PermGuardActions(
	permSvc PermGuarder,
	resourceType types.ResourceType,
	extractPublicID PublicIDExtractor,
	actions ...types.Action,
) gin.HandlerFunc

PermGuardActions 与 PermGuard 相同，但支持对同一资源校验多个 action。

func PermGuardNewMessage added in v0.2.1 

func PermGuardNewMessage(permSvc PermGuarder) gin.HandlerFunc

PermGuardNewMessage 校验 CreateInitialMessage 的资源权限组合。

func PermGuardOptionalProject added in v0.2.1 

func PermGuardOptionalProject(permSvc PermGuarder, extractProjectID PublicIDExtractor) gin.HandlerFunc

PermGuardOptionalProject 当 body 含 project_id 时校验 project:view，否则放行。

func PermGuardPath added in v0.2.1 

func PermGuardPath(
	permSvc PermGuarder,
	resourceType types.ResourceType,
	paramName string,
	actions ...types.Action,
) gin.HandlerFunc

PermGuardPath 从 URL path 参数提取 public_id 并校验权限，适用于 REST 风格路由。

func PermGuardProjectTaskAction added in v0.2.1 

func PermGuardProjectTaskAction(
	permSvc PermGuarder,
	extractProjectPublicID PublicIDExtractor,
	action types.Action,
) gin.HandlerFunc

PermGuardProjectTaskAction 校验 caller 是否能在项目下执行 task 类 action（如 task:create）。

func PermGuardViaMessage added in v0.2.1 

func PermGuardViaMessage(permSvc PermGuarder) gin.HandlerFunc

PermGuardViaMessage 从 body 提取 message_id，反查 session 并校验访问权限。

func PermGuardViaSession added in v0.2.1 

func PermGuardViaSession(permSvc PermGuarder) gin.HandlerFunc

PermGuardViaSession 从 body 提取 session_id 并校验 session 访问权限。

func PermGuardViaSessionPath added in v0.2.1 

func PermGuardViaSessionPath(permSvc PermGuarder, paramName string) gin.HandlerFunc

PermGuardViaSessionPath 从 URL path 参数提取 session_id 并校验访问权限。

func RegisterAITeammateTemplateRoutes added in v0.1.22 

func RegisterAITeammateTemplateRoutes(r gin.IRouter, service contract.AITeammateTemplateService)

RegisterAITeammateTemplateRoutes registers AI teammate template routes.

func RegisterAuthRoutes 

func RegisterAuthRoutes(r gin.IRouter, service account.AuthProvider)

func RegisterClientUpdateRoutes added in v0.1.13 

func RegisterClientUpdateRoutes(r gin.IRouter, cfg *config.ClientUpdateConfig)

RegisterClientUpdateRoutes registers client update policy endpoints.

func RegisterDepartmentRoutes added in v0.1.23 

func RegisterDepartmentRoutes(r gin.IRouter, service account.DepartmentRepository)

func RegisterDigitalAssistantRoutes 

func RegisterDigitalAssistantRoutes(r gin.IRouter, service contract.DigitalAssistantService)

func RegisterFeedbackRoutes added in v0.2.1 

func RegisterFeedbackRoutes(r gin.IRouter, svc *service.FeedbackService)

func RegisterFrontendEventRoutes added in v0.3.3 

func RegisterFrontendEventRoutes(r gin.IRouter)

func RegisterGlobalEventRoutes added in v0.1.23 

func RegisterGlobalEventRoutes(r gin.IRouter, service contract.SessionService)

RegisterGlobalEventRoutes 注册全局事件路由。

func RegisterGlobalRoutes added in v0.3.3 

func RegisterGlobalRoutes(r gin.IRouter, edition adapter.Edition)

func RegisterLLMModelRoutes 

func RegisterLLMModelRoutes(r gin.IRouter, service contract.LLMModelService)

func RegisterMemberDepartmentRoutes added in v0.1.23 

func RegisterMemberDepartmentRoutes(r gin.IRouter, service contract.MemberDepartmentService)

func RegisterOrgRoutes 

func RegisterOrgRoutes(r gin.IRouter, service account.OrgRepository)

func RegisterPermissionRoutes added in v0.2.1 

func RegisterPermissionRoutes(r gin.IRouter, checker PermissionBatchChecker)

RegisterPermissionRoutes 注册权限路由。

func RegisterPresignedRoutes added in v0.1.4 

func RegisterPresignedRoutes(r gin.IRouter)

RegisterPresignedRoutes registers routes that handle presigned URL consumption

func RegisterProjectRoutes 

func RegisterProjectRoutes(r gin.IRouter, service contract.ProjectService, permSvc PermGuarder)

func RegisterSessionRoutes 

func RegisterSessionRoutes(r gin.IRouter, service contract.SessionService, permSvc PermGuarder)

func RegisterSkillMarketplaceRoutes added in v0.1.1 

func RegisterSkillMarketplaceRoutes(r gin.IRouter, service contract.SkillMarketplaceService)

RegisterSkillMarketplaceRoutes 注册 Skill 市场相关路由。

func RegisterSkillRoutes added in v0.1.15 

func RegisterSkillRoutes(r gin.IRouter, service contract.SkillService)

RegisterSkillRoutes registers skill management routes.

func RegisterStaticRoutes added in v0.1.4 

func RegisterStaticRoutes(r gin.IRouter)

RegisterStaticRoutes registers static resource presign routes

func RegisterTaskRoutes 

func RegisterTaskRoutes(r gin.IRouter, service contract.TaskService, permSvc PermGuarder)

func RegisterUserRoutes 

func RegisterUserRoutes(r gin.IRouter, service account.UserRepository)

func RegisterWorkerAuthRoutes added in v0.1.12 

func RegisterWorkerAuthRoutes(r gin.IRouter, parser middleware.TokenParser)

RegisterWorkerAuthRoutes registers worker auth routes.

Types

type AITeammateTemplateHandler added in v0.1.22 

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

AITeammateTemplateHandler handles preset AI teammate template APIs.

func NewAITeammateTemplateHandler added in v0.1.22 

func NewAITeammateTemplateHandler(service contract.AITeammateTemplateService) *AITeammateTemplateHandler

NewAITeammateTemplateHandler creates an AI teammate template handler.

func (*AITeammateTemplateHandler) GetAITeammateTemplate added in v0.1.22 

func (h *AITeammateTemplateHandler) GetAITeammateTemplate(ctx *gin.Context)

GetAITeammateTemplate gets a preset AI teammate template.

func (*AITeammateTemplateHandler) IncrementAITeammateTemplateRecommendCount added in v0.1.22 

func (h *AITeammateTemplateHandler) IncrementAITeammateTemplateRecommendCount(ctx *gin.Context)

IncrementAITeammateTemplateRecommendCount increments a template's recommendation count.

func (*AITeammateTemplateHandler) IncrementAITeammateTemplateUseCount added in v0.1.22 

func (h *AITeammateTemplateHandler) IncrementAITeammateTemplateUseCount(ctx *gin.Context)

IncrementAITeammateTemplateUseCount increments a template's successful-use count.

func (*AITeammateTemplateHandler) ListAITeammateTemplates added in v0.1.22 

func (h *AITeammateTemplateHandler) ListAITeammateTemplates(ctx *gin.Context)

ListAITeammateTemplates lists active preset AI teammate templates.

func (*AITeammateTemplateHandler) RegisterRoutes added in v0.1.22 

func (h *AITeammateTemplateHandler) RegisterRoutes(r gin.IRouter)

RegisterRoutes registers AI teammate template routes.

type AddMessageRequest 

type AddMessageRequest struct {
	SessionID string `json:"session_id" binding:"required"`
	contract.AddMessageRequest
}

type AuthHandler 

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

func NewAuthHandler 

func NewAuthHandler(service account.AuthProvider) *AuthHandler

func (*AuthHandler) AuthSession added in v0.1.23 

func (h *AuthHandler) AuthSession(ctx *gin.Context)

@Summary 当前登录会话 @Description 获取当前用户、当前组织和可切换组织列表 @Tags Auth @Produce json @Success 200 {object} dto.Response "成功响应" @Failure 401 {object} dto.ErrorResponse "认证失败" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /AuthSession [get]

func (*AuthHandler) ChooseUin added in v0.3.3 

func (h *AuthHandler) ChooseUin(ctx *gin.Context)

@Summary 选择组织 @Description 使用 refresh token 选择组织并获取访问令牌 @Tags Auth @Accept json @Produce json @Param body body contract.ChooseUinRequest true "选择组织请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "认证失败" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ChooseUin [post]

func (*AuthHandler) CreateOrganization added in v0.1.23 

func (h *AuthHandler) CreateOrganization(ctx *gin.Context)

@Summary 创建组织并切换 @Description 创建新组织/企业并切换当前登录组织 @Tags Auth @Accept json @Produce json @Param body body contract.CreateOrganizationRequest true "创建组织请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "认证失败" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateOrganization [post]

func (*AuthHandler) LoginByEmail 

func (h *AuthHandler) LoginByEmail(ctx *gin.Context)

@Summary 邮箱登录 @Description 使用邮箱和密码登录并获取访问令牌 @Tags Auth @Accept json @Produce json @Param body body contract.LoginByEmailRequest true "邮箱登录请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "认证失败" @Failure 429 {object} dto.ErrorResponse "登录失败次数过多" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /LoginByEmail [post]

func (*AuthHandler) LoginByPhoneCode added in v0.1.12 

func (h *AuthHandler) LoginByPhoneCode(ctx *gin.Context)

@Summary 手机验证码登录 @Description 使用手机号和验证码登录；首次登录会自动注册 @Tags Auth @Accept json @Produce json @Param body body contract.LoginByPhoneCodeRequest true "手机验证码登录请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "认证失败" @Failure 429 {object} dto.ErrorResponse "登录失败次数过多" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /LoginByPhoneCode [post]

func (*AuthHandler) RefreshToken 

func (h *AuthHandler) RefreshToken(ctx *gin.Context)

@Summary 刷新令牌 @Description 使用 refresh token 换取新的访问令牌 @Tags Auth @Accept json @Produce json @Param body body contract.RefreshTokenRequest true "刷新令牌请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "认证失败" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /RefreshToken [post]

func (*AuthHandler) RegisterByEmail 

func (h *AuthHandler) RegisterByEmail(ctx *gin.Context)

@Summary 邮箱注册 @Description 使用邮箱和密码注册本地用户 @Tags Auth @Accept json @Produce json @Param body body contract.RegisterByEmailRequest true "邮箱注册请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /RegisterByEmail [post]

func (*AuthHandler) RegisterRoutes 

func (h *AuthHandler) RegisterRoutes(r gin.IRouter)

func (*AuthHandler) SendPhoneLoginCode added in v0.1.12 

func (h *AuthHandler) SendPhoneLoginCode(ctx *gin.Context)

@Summary 发送手机登录验证码 @Description 向手机号发送验证码；未配置短信服务时使用测试验证码 @Tags Auth @Accept json @Produce json @Param body body contract.SendPhoneLoginCodeRequest true "发送手机验证码请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 429 {object} dto.ErrorResponse "验证码发送太频繁" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /SendPhoneLoginCode [post]

func (*AuthHandler) SwitchOrganization added in v0.1.23 

func (h *AuthHandler) SwitchOrganization(ctx *gin.Context)

@Summary 切换组织 @Description 切换当前登录组织并获取新的访问令牌 @Tags Auth @Accept json @Produce json @Param body body contract.SwitchOrganizationRequest true "切换组织请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "认证失败" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /SwitchOrganization [post]

type ClearSessionMessagesRequest 

type ClearSessionMessagesRequest struct {
	SessionID string `json:"session_id" binding:"required"`
}

type ClientVersionReportRequest added in v0.1.13 

type ClientVersionReportRequest struct {
	App      string `json:"app"`
	Version  string `json:"version"`
	Platform string `json:"platform,omitempty"`
	Arch     string `json:"arch,omitempty"`
	Channel  string `json:"channel,omitempty"`
}

ClientVersionReportRequest reports the client build that is currently running.

type ClientVersionReportResponse added in v0.1.13 

type ClientVersionReportResponse struct {
	ForceUpdate         bool   `json:"force_update"`
	App                 string `json:"app,omitempty"`
	CurrentVersion      string `json:"current_version,omitempty"`
	MinSupportedVersion string `json:"min_supported_version,omitempty"`
	LatestVersion       string `json:"latest_version,omitempty"`
	UpdateURL           string `json:"update_url,omitempty"`
	Message             string `json:"message,omitempty"`
}

ClientVersionReportResponse describes update policy for the reported client.

type DeleteDigitalAssistantRequest 

type DeleteDigitalAssistantRequest struct {
	ID uint `json:"id" binding:"required"`
}

type DeleteLLMModelRequest 

type DeleteLLMModelRequest struct {
	ID uint `json:"id" binding:"required"`
}

type DeleteMessageRequest 

type DeleteMessageRequest struct {
	MessageID uint `json:"message_id" binding:"required"`
}

type DeleteOrgRequest 

type DeleteOrgRequest struct {
	PublicID string `json:"public_id" binding:"required"`
}

type DeleteProjectRequest 

type DeleteProjectRequest struct {
	PublicID string `json:"public_id" binding:"required"`
}

type DeleteSessionRequest 

type DeleteSessionRequest struct {
	SessionID string `json:"session_id" binding:"required"`
}

type DeleteTaskRequest 

type DeleteTaskRequest struct {
	PublicID string `json:"public_id" binding:"required"`
}

type DeleteUserRequest 

type DeleteUserRequest struct {
	PublicID string `json:"public_id" binding:"required"`
}

type DepartmentHandler added in v0.1.23 

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

func NewDepartmentHandler added in v0.1.23 

func NewDepartmentHandler(service account.DepartmentRepository) *DepartmentHandler

func (*DepartmentHandler) CreateDepartment added in v0.1.23 

func (h *DepartmentHandler) CreateDepartment(ctx *gin.Context)

@Summary 创建部门 @Description 创建一个新部门 @Tags Department @Accept json @Produce json @Param body body contract.CreateDepartmentRequest true "创建部门请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateDepartment [post]

func (*DepartmentHandler) DeleteDepartment added in v0.1.23 

func (h *DepartmentHandler) DeleteDepartment(ctx *gin.Context)

@Summary 删除部门 @Description 根据 ID 删除部门 @Tags Department @Accept json @Produce json @Param body body handler.deleteDepartmentRequest true "删除部门请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteDepartment [post]

func (*DepartmentHandler) GetDepartment added in v0.1.23 

func (h *DepartmentHandler) GetDepartment(ctx *gin.Context)

@Summary 获取部门 @Description 根据 ID 获取部门详情 @Tags Department @Accept json @Produce json @Param body body handler.getDepartmentRequest true "获取部门请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetDepartment [post]

func (*DepartmentHandler) ListDepartment added in v0.3.3 

func (h *DepartmentHandler) ListDepartment(ctx *gin.Context)

@Summary 部门列表 @Description 查询部门列表 @Tags Department @Accept json @Produce json @Param body body contract.ListDepartmentRequest true "查询部门列表请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListDepartment [post]

func (*DepartmentHandler) RegisterRoutes added in v0.1.23 

func (h *DepartmentHandler) RegisterRoutes(r gin.IRouter)

func (*DepartmentHandler) UpdateDepartment added in v0.1.23 

func (h *DepartmentHandler) UpdateDepartment(ctx *gin.Context)

@Summary 更新部门 @Description 更新部门信息 @Tags Department @Accept json @Produce json @Param body body handler.updateDepartmentRequest true "更新部门请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateDepartment [post]

type DigitalAssistantHandler 

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

func NewDigitalAssistantHandler 

func NewDigitalAssistantHandler(service contract.DigitalAssistantService) *DigitalAssistantHandler

func (*DigitalAssistantHandler) CheckDigitalAssistantName added in v0.3.0 

func (h *DigitalAssistantHandler) CheckDigitalAssistantName(ctx *gin.Context)

CheckDigitalAssistantName checks whether a teammate name is available in the caller organization.

func (*DigitalAssistantHandler) CreateDigitalAssistant 

func (h *DigitalAssistantHandler) CreateDigitalAssistant(ctx *gin.Context)

@Summary 创建数字助手 @Description 创建一个新的数字助手实例 @Tags DigitalAssistant @Accept json @Produce json @Param body body contract.CreateDigitalAssistantRequest true "创建数字助手请求" @Success 200 {object} dto.CreateDigitalAssistantResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateDigitalAssistant [post]

func (*DigitalAssistantHandler) CreateDigitalAssistantFromTemplate added in v0.1.22 

func (h *DigitalAssistantHandler) CreateDigitalAssistantFromTemplate(ctx *gin.Context)

@Summary 基于模板创建数字助手 @Description 使用 AI 队友模板创建一个新的数字助手实例 @Tags DigitalAssistant @Accept json @Produce json @Param body body contract.CreateDigitalAssistantFromTemplateRequest true "基于模板创建数字助手请求" @Success 200 {object} dto.CreateDigitalAssistantResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateDigitalAssistantFromTemplate [post]

func (*DigitalAssistantHandler) DeleteDigitalAssistant 

func (h *DigitalAssistantHandler) DeleteDigitalAssistant(ctx *gin.Context)

@Summary 删除数字助手 @Description 根据ID删除数字助手 @Tags DigitalAssistant @Accept json @Produce json @Param body body DeleteDigitalAssistantRequest true "删除数字助手请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 403 {object} dto.ErrorResponse "权限不足" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteDigitalAssistant [post]

func (*DigitalAssistantHandler) GetDigitalAssistant 

func (h *DigitalAssistantHandler) GetDigitalAssistant(ctx *gin.Context)

@Summary 获取数字助手详情 @Description 根据ID或PublicID获取数字助手详情 @Tags DigitalAssistant @Accept json @Produce json @Param body body GetDigitalAssistantRequest true "获取数字助手请求" @Success 200 {object} dto.CreateDigitalAssistantResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 403 {object} dto.ErrorResponse "权限不足" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetDigitalAssistant [post]

func (*DigitalAssistantHandler) ListDigitalAssistant 

func (h *DigitalAssistantHandler) ListDigitalAssistant(ctx *gin.Context)

@Summary 查询数字助手列表 @Description 分页查询数字助手列表 @Tags DigitalAssistant @Accept json @Produce json @Param body body contract.ListDigitalAssistantRequest true "查询列表请求" @Success 200 {object} dto.CreateDigitalAssistantResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListDigitalAssistant [post]

func (*DigitalAssistantHandler) RegisterRoutes 

func (h *DigitalAssistantHandler) RegisterRoutes(r gin.IRouter)

func (*DigitalAssistantHandler) UpdateDigitalAssistant 

func (h *DigitalAssistantHandler) UpdateDigitalAssistant(ctx *gin.Context)

@Summary 更新数字助手 @Description 更新数字助手基本信息 @Tags DigitalAssistant @Accept json @Produce json @Param body body UpdateDigitalAssistantRequest true "更新数字助手请求" @Success 200 {object} dto.CreateDigitalAssistantResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 403 {object} dto.ErrorResponse "权限不足" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateDigitalAssistant [post]

func (*DigitalAssistantHandler) UpdateDigitalAssistantStatus 

func (h *DigitalAssistantHandler) UpdateDigitalAssistantStatus(ctx *gin.Context)

@Summary 更新数字助手状态 @Description 更新数字助手的运行状态 @Tags DigitalAssistant @Accept json @Produce json @Param body body UpdateDigitalAssistantStatusRequest true "更新状态请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 403 {object} dto.ErrorResponse "权限不足" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateDigitalAssistantStatus [post]

type FeedbackHandler added in v0.2.1 

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

func NewFeedbackHandler added in v0.2.1 

func NewFeedbackHandler(service *service.FeedbackService) *FeedbackHandler

func (*FeedbackHandler) SubmitFeedback added in v0.2.1 

func (h *FeedbackHandler) SubmitFeedback(ctx *gin.Context)

type FileHandler added in v0.1.2 

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

func NewFileHandler added in v0.1.2 

func NewFileHandler(service contract.FileService) *FileHandler

func (*FileHandler) DownloadFile added in v0.1.2 

func (h *FileHandler) DownloadFile(ctx *gin.Context)

@Summary 下载文件 @Description 通过 publicID 或 storageURI 流式返回文件内容 @Tags File @Produce octet-stream @Param public_id query string false "文件公共ID" @Param storage_uri query string false "文件存储URI（格式 {schema}://{bucket}/{key}）" @Success 200 {file} binary "文件内容" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "文件不存在" @Router /files/download [get]

func (*FileHandler) PresignDownloadURL added in v0.1.14 

func (h *FileHandler) PresignDownloadURL(ctx *gin.Context)

@Summary 获取预签名下载地址 @Description 通过 publicID 或 storageURI 生成预签名下载 URL 并 302 重定向 @Tags File @Produce json @Param public_id query string false "文件公共ID" @Param storage_uri query string false "文件存储URI（格式 {schema}://{bucket}/{key}）" @Success 302 {string} string "重定向到预签名下载 URL" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "文件不存在" @Router /files/preview [get]

func (*FileHandler) RegisterRoutes added in v0.1.2 

func (h *FileHandler) RegisterRoutes(r gin.IRouter)

func (*FileHandler) UploadFile added in v0.1.2 

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

@Summary 上传文件 @Description 上传文件到系统 @Tags File @Accept multipart/form-data @Produce json @Param file formData file true "上传文件" @Param purpose formData string false "文件用途（默认 attachment）" @Param source_id formData string false "来源ID（可选）" @Success 200 {object} dto.Response "上传成功" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Router /files/upload [post]

type FrontendEventHandler added in v0.3.3 

type FrontendEventHandler struct{}

func NewFrontendEventHandler added in v0.3.3 

func NewFrontendEventHandler() *FrontendEventHandler

func (*FrontendEventHandler) CollectFrontendEvent added in v0.3.3 

func (h *FrontendEventHandler) CollectFrontendEvent(ctx *gin.Context)

type GetDigitalAssistantRequest 

type GetDigitalAssistantRequest struct {
	ID       *uint   `json:"id,omitempty"`
	PublicID *string `json:"public_id,omitempty"`
}

type GetLLMModelRequest 

type GetLLMModelRequest struct {
	ID   *uint   `json:"id,omitempty"`
	Code *string `json:"code,omitempty"`
}

type GetOrgMemberRequest 

type GetOrgMemberRequest struct {
	ID  *uint `json:"id,omitempty"`
	Uin *uint `json:"uin,omitempty"`
}

type GetOrgRequest 

type GetOrgRequest struct {
	PublicID string `json:"public_id,omitempty"`
	Code     string `json:"code,omitempty"`
}

type GetProjectRequest 

type GetProjectRequest struct {
	PublicID *string `json:"public_id,omitempty"`
}

type GetSessionMessagesRequest 

type GetSessionMessagesRequest struct {
	SessionID string `json:"session_id" binding:"required"`
	Page      int    `json:"page,omitempty"`
	PerPage   int    `json:"per_page,omitempty"`
}

type GetSessionRequest 

type GetSessionRequest struct {
	SessionID string `json:"session_id" binding:"required"`
}

type GetTaskRequest 

type GetTaskRequest struct {
	PublicID *string `json:"public_id,omitempty"`
}

type GetUserRequest 

type GetUserRequest struct {
	PublicID string `json:"public_id,omitempty"`
	Phone    string `json:"phone,omitempty"`
}

type GlobalEventsHandler added in v0.1.23 

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

GlobalEventsHandler 提供 project 级全局 SSE 通知端点。

func NewGlobalEventsHandler added in v0.1.23 

func NewGlobalEventsHandler(service contract.SessionService) *GlobalEventsHandler

NewGlobalEventsHandler 创建 GlobalEventsHandler 实例。

func (*GlobalEventsHandler) GlobalEvents added in v0.1.23 

func (h *GlobalEventsHandler) GlobalEvents(ctx *gin.Context)

GlobalEvents 建立 project 级持久 SSE 连接，向调用方推送其所属所有 project 的 全局通知事件（message.created 等）。

连接生命周期由客户端控制：客户端断开或 ctx 取消时结束。 服务端通过 15s 间隔的 keep-alive 心跳维持连接活跃。

@Summary 全局事件流 @Description 建立 project 级全局 SSE 长连接，实时推送新消息等通知 @Tags GlobalEvents @Accept json @Produce text/event-stream @Param request body GlobalEventsRequest false "replay 控制参数" @Success 200 {string} string "text/event-stream" @Router /v1/GlobalEvents [post]

type GlobalEventsRequest added in v0.1.23 

type GlobalEventsRequest struct {
	ReplaySinceSeq uint64 `json:"replay_since_seq,omitempty"`
}

GlobalEventsRequest 是 GlobalEvents 端点的请求体。 所有身份信息均从 caller 派生，请求体仅含可选的 replay 控制位。

type GlobalHandler added in v0.3.3 

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

func NewGlobalHandler added in v0.3.3 

func NewGlobalHandler(edition adapter.Edition) *GlobalHandler

func (*GlobalHandler) GetGlobalConfig added in v0.3.3 

func (h *GlobalHandler) GetGlobalConfig(ctx *gin.Context)

GetGlobalConfig 返回服务端通用全局配置信息

@Summary 获取全局配置 @Description 返回服务端通用全局配置信息（当前返回 edition 字段） @Tags Global @Produce json @Success 200 {object} dto.Response{data=dto.GlobalConfigData} "成功响应" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GlobalConfig [get]

func (*GlobalHandler) RegisterRoutes added in v0.3.3 

func (h *GlobalHandler) RegisterRoutes(r gin.IRouter)

type LLMModelHandler 

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

func NewLLMModelHandler 

func NewLLMModelHandler(service contract.LLMModelService) *LLMModelHandler

func (*LLMModelHandler) CreateLLMModel 

func (h *LLMModelHandler) CreateLLMModel(ctx *gin.Context)

@Summary 创建LLM模型 @Description 创建一个新的LLM模型配置 @Tags LLMModel @Accept json @Produce json @Param body body contract.CreateLLMModelRequest true "创建LLM模型请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateLLMModel [post]

func (*LLMModelHandler) DeleteLLMModel 

func (h *LLMModelHandler) DeleteLLMModel(ctx *gin.Context)

@Summary 删除LLM模型 @Description 根据ID删除LLM模型配置 @Tags LLMModel @Accept json @Produce json @Param body body DeleteLLMModelRequest true "删除LLM模型请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 403 {object} dto.ErrorResponse "权限不足" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteLLMModel [post]

func (*LLMModelHandler) GetDefaultLLMModel 

func (h *LLMModelHandler) GetDefaultLLMModel(ctx *gin.Context)

@Summary 获取默认LLM模型 @Description 获取组织的默认LLM模型配置 @Tags LLMModel @Accept json @Produce json @Success 200 {object} dto.Response "成功响应" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "默认模型不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetDefaultLLMModel [post]

func (*LLMModelHandler) GetLLMModel 

func (h *LLMModelHandler) GetLLMModel(ctx *gin.Context)

@Summary 获取LLM模型详情 @Description 根据ID或Code获取LLM模型配置详情 @Tags LLMModel @Accept json @Produce json @Param body body GetLLMModelRequest true "获取LLM模型请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 403 {object} dto.ErrorResponse "权限不足" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetLLMModel [post]

func (*LLMModelHandler) ListLLMModels 

func (h *LLMModelHandler) ListLLMModels(ctx *gin.Context)

@Summary 查询LLM模型列表 @Description 分页查询LLM模型配置列表 @Tags LLMModel @Accept json @Produce json @Param body body contract.ListLLMModelsRequest true "查询列表请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListLLMModels [post]

func (*LLMModelHandler) RegisterRoutes 

func (h *LLMModelHandler) RegisterRoutes(r gin.IRouter)

func (*LLMModelHandler) TestLLMModel 

func (h *LLMModelHandler) TestLLMModel(ctx *gin.Context)

@Summary 测试LLM模型 @Description 测试LLM模型配置的连通性 @Tags LLMModel @Accept json @Produce json @Param body body contract.TestLLMModelRequest true "测试LLM模型请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /TestLLMModel [post]

func (*LLMModelHandler) UpdateLLMModel 

func (h *LLMModelHandler) UpdateLLMModel(ctx *gin.Context)

@Summary 更新LLM模型 @Description 更新LLM模型配置信息 @Tags LLMModel @Accept json @Produce json @Param body body UpdateLLMModelRequest true "更新LLM模型请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 403 {object} dto.ErrorResponse "权限不足" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateLLMModel [post]

type LeaveProjectRequest added in v0.2.1 

type LeaveProjectRequest struct {
	PublicID string `json:"public_id" binding:"required"`
}

type MemberDepartmentHandler added in v0.1.23 

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

func NewMemberDepartmentHandler added in v0.1.23 

func NewMemberDepartmentHandler(service contract.MemberDepartmentService) *MemberDepartmentHandler

func (*MemberDepartmentHandler) CreateMemberDepartment added in v0.1.23 

func (h *MemberDepartmentHandler) CreateMemberDepartment(ctx *gin.Context)

@Summary 创建成员部门关系 @Description 创建成员与部门的关联 @Tags MemberDepartment @Accept json @Produce json @Param body body contract.CreateMemberDepartmentRequest true "创建成员部门关系请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateMemberDepartment [post]

func (*MemberDepartmentHandler) DeleteMemberDepartment added in v0.1.23 

func (h *MemberDepartmentHandler) DeleteMemberDepartment(ctx *gin.Context)

@Summary 删除成员部门关系 @Description 根据 ID 删除成员部门关联 @Tags MemberDepartment @Accept json @Produce json @Param body body handler.deleteMemberDepartmentRequest true "删除成员部门关系请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteMemberDepartment [post]

func (*MemberDepartmentHandler) GetMemberDepartment added in v0.1.23 

func (h *MemberDepartmentHandler) GetMemberDepartment(ctx *gin.Context)

@Summary 获取成员部门关系 @Description 根据 ID 获取成员部门关系详情 @Tags MemberDepartment @Accept json @Produce json @Param body body handler.getMemberDepartmentRequest true "获取成员部门关系请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetMemberDepartment [post]

func (*MemberDepartmentHandler) ListMemberDepartments added in v0.1.23 

func (h *MemberDepartmentHandler) ListMemberDepartments(ctx *gin.Context)

@Summary 查询成员部门关系列表 @Description 分页查询成员部门关系列表 @Tags MemberDepartment @Accept json @Produce json @Param body body contract.ListMemberDepartmentsRequest true "查询成员部门关系列表请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListMemberDepartments [post]

func (*MemberDepartmentHandler) RegisterRoutes added in v0.1.23 

func (h *MemberDepartmentHandler) RegisterRoutes(r gin.IRouter)

func (*MemberDepartmentHandler) UpdateMemberDepartment added in v0.1.23 

func (h *MemberDepartmentHandler) UpdateMemberDepartment(ctx *gin.Context)

@Summary 更新成员部门关系 @Description 更新成员部门关联信息 @Tags MemberDepartment @Accept json @Produce json @Param body body handler.updateMemberDepartmentRequest true "更新成员部门关系请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateMemberDepartment [post]

type OrgHandler 

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

func NewOrgHandler 

func NewOrgHandler(service account.OrgRepository) *OrgHandler

func (*OrgHandler) CreateOrg 

func (h *OrgHandler) CreateOrg(ctx *gin.Context)

@Summary 创建组织（已废弃） @Description 创建一个新组织。已废弃，请使用 POST /v1/CreateOrganization 替代。 @Tags Organization @Accept json @Produce json @Param body body contract.CreateOrgRequest true "创建组织请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateOrg [post]

func (*OrgHandler) CreateOrgMember 

func (h *OrgHandler) CreateOrgMember(ctx *gin.Context)

@Summary 创建组织成员 @Description 添加用户到组织 @Tags OrgMember @Accept json @Produce json @Param body body contract.CreateOrgMemberRequest true "创建组织成员请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateOrgMember [post]

func (*OrgHandler) DeleteOrg 

func (h *OrgHandler) DeleteOrg(ctx *gin.Context)

@Summary 删除组织 @Description 根据PublicID删除组织（软删除） @Tags Organization @Accept json @Produce json @Param body body DeleteOrgRequest true "删除组织请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteOrg [post]

func (*OrgHandler) GetOrg 

func (h *OrgHandler) GetOrg(ctx *gin.Context)

@Summary 获取组织详情 @Description 根据PublicID或Code获取组织详情 @Tags Organization @Accept json @Produce json @Param body body GetOrgRequest true "获取组织请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetOrg [post]

func (*OrgHandler) GetOrgMember 

func (h *OrgHandler) GetOrgMember(ctx *gin.Context)

@Summary 获取组织成员 @Description 根据ID或Uin获取组织成员详情 @Tags OrgMember @Accept json @Produce json @Param body body GetOrgMemberRequest true "获取组织成员请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetOrgMember [post]

func (*OrgHandler) ListOrgMembers 

func (h *OrgHandler) ListOrgMembers(ctx *gin.Context)

@Summary 查询组织成员列表 @Description 分页查询组织成员列表 @Tags OrgMember @Accept json @Produce json @Param body body contract.ListOrgMembersRequest true "查询列表请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListOrgMembers [post]

func (*OrgHandler) ListOrgs 

func (h *OrgHandler) ListOrgs(ctx *gin.Context)

@Summary 查询组织列表 @Description 分页查询组织列表 @Tags Organization @Accept json @Produce json @Param body body contract.ListOrgsRequest true "查询列表请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListOrgs [post]

func (*OrgHandler) RegisterRoutes 

func (h *OrgHandler) RegisterRoutes(r gin.IRouter)

func (*OrgHandler) UpdateOrg 

func (h *OrgHandler) UpdateOrg(ctx *gin.Context)

@Summary 更新组织 @Description 更新组织信息 @Tags Organization @Accept json @Produce json @Param body body UpdateOrgRequest true "更新组织请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateOrg [post]

func (*OrgHandler) UpdateOrgMember 

func (h *OrgHandler) UpdateOrgMember(ctx *gin.Context)

@Summary 更新组织成员 @Description 更新组织成员信息 @Tags OrgMember @Accept json @Produce json @Param body body UpdateOrgMemberRequest true "更新组织成员请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateOrgMember [post]

type PermGuarder added in v0.2.1 

type PermGuarder interface {
	GuardProject(ctx context.Context, caller types.PermissionCaller, publicID string, actions ...types.Action) error
	GuardTask(ctx context.Context, caller types.PermissionCaller, publicID string, actions ...types.Action) error
	GuardProjectTaskAction(ctx context.Context, caller types.PermissionCaller, projectPublicID string, action types.Action) error
	GuardByPublicID(ctx context.Context, caller types.PermissionCaller, resourceType types.ResourceType, publicID string, actions ...types.Action) error
	GuardSessionAccess(ctx context.Context, caller types.PermissionCaller, sessionPublicID string) error
	GuardSessionAccessByMessageID(ctx context.Context, caller types.PermissionCaller, messageID uint) error
	GuardNewMessageRequest(ctx context.Context, caller types.PermissionCaller, projectID, taskID string) error
}

PermGuarder 是 handler 层对权限校验能力的依赖接口。 由 *service.PermissionService 实现，通过构造函数注入。 使用接口而非具体类型，避免 handler → service → handler（测试）的导入环。

type PermissionBatchCheckItem added in v0.2.1 

type PermissionBatchCheckItem struct {
	Action       string
	ResourceType types.ResourceType
	PublicID     string
}

PermissionBatchCheckItem 描述单次基于 public_id 的权限检查请求。

type PermissionBatchCheckResult added in v0.2.1 

type PermissionBatchCheckResult struct {
	Action       string
	ResourceType types.ResourceType
	PublicID     string
	Allowed      bool
	Reason       string
	Role         string
	Inherited    bool
}

PermissionBatchCheckResult 是单次权限检查的返回结果。

type PermissionBatchChecker added in v0.2.1 

type PermissionBatchChecker interface {
	BatchCheckByPublicID(
		ctx context.Context,
		caller types.PermissionCaller,
		items []PermissionBatchCheckItem,
	) ([]PermissionBatchCheckResult, error)
}

PermissionBatchChecker 批量权限检查能力，由 api 层适配器注入，避免 handler 直接依赖 service 包。

type PermissionHandler added in v0.2.1 

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

PermissionHandler 暴露权限查询 API，供前端批量判断按钮可见性。

func NewPermissionHandler added in v0.2.1 

func NewPermissionHandler(checker PermissionBatchChecker) *PermissionHandler

NewPermissionHandler 创建权限 handler。

func (*PermissionHandler) BatchCheckPermission added in v0.2.1 

func (h *PermissionHandler) BatchCheckPermission(ctx *gin.Context)

@Summary 批量检查权限 @Description 批量检查当前用户对多个资源/动作的权限（用于前端控制按钮可见性） @Tags Permission @Accept json @Produce json @Param body body handler.batchCheckPermissionRequest true "批量权限检查请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /BatchCheckPermission [post]

func (*PermissionHandler) RegisterRoutes added in v0.2.1 

func (h *PermissionHandler) RegisterRoutes(r gin.IRouter)

RegisterRoutes 注册权限相关路由。

type ProjectFileHandler 

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

ProjectFileHandler 项目文件相关接口

func NewProjectFileHandler 

func NewProjectFileHandler(service contract.ProjectService, permSvc PermGuarder) *ProjectFileHandler

NewProjectFileHandler 创建项目文件处理器

func (*ProjectFileHandler) DownloadProjectFile 

func (h *ProjectFileHandler) DownloadProjectFile(ctx *gin.Context)

DownloadProjectFile 下载项目中的文件 @Summary 下载项目文件 @Description 通过文件路径下载项目仓库中的文件 @Tags Project @Produce octet-stream @Param project_id path string true "项目 public_id" @Param filepath path string true "文件相对路径，如 /src/main.go" @Success 200 {file} binary "文件内容" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /projects/{project_id}/files/{filepath} [get]

func (*ProjectFileHandler) DownloadProjectFileByPublicID added in v0.2.3 

func (h *ProjectFileHandler) DownloadProjectFileByPublicID(ctx *gin.Context)

DownloadProjectFileByPublicID 下载一个指定的项目文件版本。

func (*ProjectFileHandler) GetProjectFileTree 

func (h *ProjectFileHandler) GetProjectFileTree(ctx *gin.Context)

GetProjectFileTree 获取项目文件树 @Summary 获取项目文件树 @Description 获取项目 artifacts/ 和 uploads/ 目录的文件树，可通过 resource_type 参数筛选。 @Description 文件节点包含 created_at 字段（Unix 秒级时间戳），表示该文件关联记录创建的时间，未找到时为 0。 @Tags Project @Produce json @Param project_id path string true "项目 public_id" @Param resource_type query string false "资源类型：user_upload | artifact | plan；默认排除 plan" @Param task_id query string false "Task public ID，传入时仅返回该任务的产物文件" @Param node_type query string false "节点类型：folder | file；默认返回文件与文件夹" @Param file_ext query string false "文件类型分组：pdf | docx | xlsx | pptx | md | image | text" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /projects/{project_id}/files [get]

func (*ProjectFileHandler) GetProjectFileVersions added in v0.2.3 

func (h *ProjectFileHandler) GetProjectFileVersions(ctx *gin.Context)

GetProjectFileVersions 获取项目文件历史版本。

func (*ProjectFileHandler) GetProjectMemory 

func (h *ProjectFileHandler) GetProjectMemory(ctx *gin.Context)

GetProjectMemory 获取项目记忆 @Summary 获取项目记忆 @Description 根据 project_id 获取项目的持久记忆条目 @Tags Project @Produce json @Param project_id path string true "项目 public_id" @Success 200 {object} dto.Response "成功响应" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /projects/{project_id}/memory [get]

func (*ProjectFileHandler) RegisterRoutes 

func (h *ProjectFileHandler) RegisterRoutes(r gin.IRouter)

RegisterRoutes 注册路由

func (*ProjectFileHandler) RestoreProjectFileVersion added in v0.2.3 

func (h *ProjectFileHandler) RestoreProjectFileVersion(ctx *gin.Context)

RestoreProjectFileVersion 恢复一个历史版本并创建新的最新版本。

type ProjectHandler 

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

func NewProjectHandler 

func NewProjectHandler(service contract.ProjectService, permSvc PermGuarder) *ProjectHandler

func (*ProjectHandler) CreateProject 

func (h *ProjectHandler) CreateProject(ctx *gin.Context)

@Summary 创建项目 @Description 创建一个新项目 @Tags Project @Accept json @Produce json @Param body body contract.CreateProjectRequest true "创建项目请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateProject [post]

func (*ProjectHandler) DeleteProject 

func (h *ProjectHandler) DeleteProject(ctx *gin.Context)

@Summary 删除项目 @Description 根据PublicId删除项目（软删除） @Tags Project @Accept json @Produce json @Param body body DeleteProjectRequest true "删除项目请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteProject [post]

func (*ProjectHandler) DetailProject 

func (h *ProjectHandler) DetailProject(ctx *gin.Context)

@Summary 获取项目详情（含任务、会话、产物、成员） @Description 根据PublicId获取项目完整详情 @Tags Project @Accept json @Produce json @Param body body GetProjectRequest true "获取项目详情请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DetailProject [post]

func (*ProjectHandler) GetProject 

func (h *ProjectHandler) GetProject(ctx *gin.Context)

@Summary 获取项目详情 @Description 根据PublicId获取项目详情 @Tags Project @Accept json @Produce json @Param body body GetProjectRequest true "获取项目请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetProject [post]

func (*ProjectHandler) GetWorkbenchRecentContext added in v0.1.21 

func (h *ProjectHandler) GetWorkbenchRecentContext(ctx *gin.Context)

func (*ProjectHandler) LeaveProject added in v0.2.1 

func (h *ProjectHandler) LeaveProject(ctx *gin.Context)

LeaveProject 当前用户退出项目。

func (*ProjectHandler) ListProjectActivities added in v0.2.1 

func (h *ProjectHandler) ListProjectActivities(ctx *gin.Context)

@Summary 查询项目操作动态 @Description 按项目和操作人筛选项目操作动态 @Tags Project @Accept json @Produce json @Param body body contract.ListProjectActivitiesRequest true "查询项目动态请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListProjectActivities [post]

func (*ProjectHandler) ListProjects 

func (h *ProjectHandler) ListProjects(ctx *gin.Context)

@Summary 查询项目列表 @Description 分页查询项目列表 @Tags Project @Accept json @Produce json @Param body body contract.ListProjectsRequest true "查询列表请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListProjects [post]

func (*ProjectHandler) RegisterRoutes 

func (h *ProjectHandler) RegisterRoutes(r gin.IRouter)

func (*ProjectHandler) SaveWorkbenchRecentContext added in v0.1.21 

func (h *ProjectHandler) SaveWorkbenchRecentContext(ctx *gin.Context)

func (*ProjectHandler) UpdateProject 

func (h *ProjectHandler) UpdateProject(ctx *gin.Context)

@Summary 更新项目 @Description 更新项目信息 @Tags Project @Accept json @Produce json @Param body body UpdateProjectRequest true "更新项目请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateProject [post]

type PublicIDExtractor added in v0.2.1 

type PublicIDExtractor func(body []byte) (string, error)

PublicIDExtractor 从原始请求 body 字节中提取资源 public_id。 由调用方根据具体请求结构提供；返回的 string 为资源的 public_id， error 表示提取失败（通常是 body 格式不合法或字段缺失）。

type SessionEventsRequest 

type SessionEventsRequest struct {
	SessionID   string `json:"session_id" binding:"required"`
	Replay      bool   `json:"replay,omitempty"`
	AssistantID string `json:"assistant_id,omitempty"`
}

type SessionHandler 

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

func NewSessionHandler 

func NewSessionHandler(service contract.SessionService, permSvc PermGuarder) *SessionHandler

func (*SessionHandler) AddMessage 

func (h *SessionHandler) AddMessage(ctx *gin.Context)

@Summary 添加会话消息 @Description 向指定会话添加一条消息 @Tags Session @Accept json @Produce json @Param body body AddMessageRequest true "添加消息请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /AddMessage [post]

func (*SessionHandler) CancelSessionRun added in v0.1.17 

func (h *SessionHandler) CancelSessionRun(ctx *gin.Context)

CancelSessionRun cancels an active agent run for the given session. POST /CancelSessionRun

func (*SessionHandler) ClearSessionMessages 

func (h *SessionHandler) ClearSessionMessages(ctx *gin.Context)

@Summary 清空会话消息 @Description 清空指定会话的所有消息 @Tags Session @Accept json @Produce json @Param body body ClearSessionMessagesRequest true "清空消息请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ClearSessionMessages [post]

func (*SessionHandler) CreateInitialMessage added in v0.1.25 

func (h *SessionHandler) CreateInitialMessage(ctx *gin.Context)

CreateInitialMessage atomically creates Project + Task + Session and optionally posts the first message, then dispatches to the allocated AgentWorker. POST /CreateInitialMessage

func (*SessionHandler) CreateSession 

func (h *SessionHandler) CreateSession(ctx *gin.Context)

@Summary 创建会话 @Description 创建一个新的会话实例 @Tags Session @Accept json @Produce json @Param body body contract.CreateSessionRequest true "创建会话请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateSession [post]

func (*SessionHandler) DeleteMessage 

func (h *SessionHandler) DeleteMessage(ctx *gin.Context)

@Summary 删除会话消息 @Description 根据ID删除会话消息 @Tags Session @Accept json @Produce json @Param body body DeleteMessageRequest true "删除消息请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteMessage [post]

func (*SessionHandler) DeleteSession 

func (h *SessionHandler) DeleteSession(ctx *gin.Context)

@Summary 删除会话 @Description 根据ID删除会话 @Tags Session @Accept json @Produce json @Param body body DeleteSessionRequest true "删除会话请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteSession [post]

func (*SessionHandler) GetSession 

func (h *SessionHandler) GetSession(ctx *gin.Context)

@Summary 获取会话详情 @Description 根据SessionID获取会话详情 @Tags Session @Accept json @Produce json @Param body body GetSessionRequest true "获取会话请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetSession [post]

func (*SessionHandler) GetSessionMessages 

func (h *SessionHandler) GetSessionMessages(ctx *gin.Context)

@Summary 获取会话消息列表 @Description 分页获取指定会话的消息列表 @Tags Session @Accept json @Produce json @Param body body GetSessionMessagesRequest true "获取消息列表请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetSessionMessages [post]

func (*SessionHandler) ListSessions 

func (h *SessionHandler) ListSessions(ctx *gin.Context)

@Summary 查询会话列表 @Description 分页查询会话列表 @Tags Session @Accept json @Produce json @Param body body contract.ListSessionsRequest true "查询列表请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListSessions [post]

func (*SessionHandler) RegisterRoutes 

func (h *SessionHandler) RegisterRoutes(r gin.IRouter)

func (*SessionHandler) SessionEvents 

func (h *SessionHandler) SessionEvents(ctx *gin.Context)

@Summary 订阅会话事件流 @Description 通过SSE订阅会话的事件流 @Tags Session @Accept json @Produce text/event-stream @Param body body SessionEventsRequest true "订阅事件请求" @Success 200 {string} string "SSE事件流" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /SessionEvents [post]

func (*SessionHandler) SubmitApproval 

func (h *SessionHandler) SubmitApproval(ctx *gin.Context)

SubmitApproval 处理前端提交的审批决策或问题答案，委托给 service 层通过 NATS 转发。 POST /v1/sessions/:session_id/approvals

支持的交互类型：

  • "approval.decide": 审批决策，payload 为 {request_id, action, reason}
  • "question.answer": 问题答案，payload 为 {request_id, answers}

func (*SessionHandler) UpdateSession 

func (h *SessionHandler) UpdateSession(ctx *gin.Context)

@Summary 更新会话 @Description 更新会话基本信息 @Tags Session @Accept json @Produce json @Param body body UpdateSessionRequest true "更新会话请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateSession [post]

type TaskHandler 

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

func NewTaskHandler 

func NewTaskHandler(service contract.TaskService, permSvc PermGuarder) *TaskHandler

func (*TaskHandler) CreateTask 

func (h *TaskHandler) CreateTask(ctx *gin.Context)

@Summary 创建任务 @Description 创建一个新任务 @Tags Task @Accept json @Produce json @Param body body contract.CreateTaskRequest true "创建任务请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateTask [post]

func (*TaskHandler) DeleteTask 

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

@Summary 删除任务 @Description 根据PublicId删除任务（软删除） @Tags Task @Accept json @Produce json @Param body body DeleteTaskRequest true "删除任务请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteTask [post]

func (*TaskHandler) GetTask 

func (h *TaskHandler) GetTask(ctx *gin.Context)

@Summary 获取任务详情 @Description 根据PublicId获取任务详情 @Tags Task @Accept json @Produce json @Param body body GetTaskRequest true "获取任务请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetTask [post]

func (*TaskHandler) ListTasks 

func (h *TaskHandler) ListTasks(ctx *gin.Context)

@Summary 查询任务列表 @Description 分页查询任务列表 @Tags Task @Accept json @Produce json @Param body body contract.ListTasksRequest true "查询列表请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListTasks [post]

func (*TaskHandler) RegisterRoutes 

func (h *TaskHandler) RegisterRoutes(r gin.IRouter)

func (*TaskHandler) UpdateTask 

func (h *TaskHandler) UpdateTask(ctx *gin.Context)

@Summary 更新任务 @Description 更新任务信息 @Tags Task @Accept json @Produce json @Param body body UpdateTaskRequest true "更新任务请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateTask [post]

type UpdateDigitalAssistantRequest 

type UpdateDigitalAssistantRequest struct {
	ID uint `json:"id" binding:"required"`
	contract.UpdateDigitalAssistantRequest
}

type UpdateDigitalAssistantStatusRequest 

type UpdateDigitalAssistantStatusRequest struct {
	ID uint `json:"id" binding:"required"`
	contract.UpdateDigitalAssistantStatusRequest
}

type UpdateLLMModelRequest 

type UpdateLLMModelRequest struct {
	ID uint `json:"id" binding:"required"`
	contract.UpdateLLMModelRequest
}

type UpdateOrgMemberRequest 

type UpdateOrgMemberRequest struct {
	ID uint `json:"id" binding:"required"`
	contract.UpdateOrgMemberRequest
}

type UpdateOrgRequest 

type UpdateOrgRequest struct {
	PublicID string `json:"public_id" binding:"required"`
	contract.UpdateOrgRequest
}

type UpdateProjectRequest 

type UpdateProjectRequest struct {
	PublicID string `json:"public_id" binding:"required"`
	contract.UpdateProjectRequest
}

type UpdateSessionRequest 

type UpdateSessionRequest struct {
	SessionID string `json:"session_id" binding:"required"`
	contract.UpdateSessionRequest
}

type UpdateTaskRequest 

type UpdateTaskRequest struct {
	PublicID string `json:"public_id" binding:"required"`
	contract.UpdateTaskRequest
}

type UpdateUserRequest 

type UpdateUserRequest struct {
	PublicID string `json:"public_id" binding:"required"`
	contract.UpdateUserRequest
}

type UserHandler 

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

func NewUserHandler 

func NewUserHandler(service account.UserRepository) *UserHandler

func (*UserHandler) CreateUser 

func (h *UserHandler) CreateUser(ctx *gin.Context)

@Summary 创建用户 @Description 创建一个新用户 @Tags User @Accept json @Produce json @Param body body contract.CreateUserRequest true "创建用户请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateUser [post]

func (*UserHandler) DeleteUser 

func (h *UserHandler) DeleteUser(ctx *gin.Context)

@Summary 删除用户 @Description 根据PublicID删除用户（软删除） @Tags User @Accept json @Produce json @Param body body DeleteUserRequest true "删除用户请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteUser [post]

func (*UserHandler) GetUser 

func (h *UserHandler) GetUser(ctx *gin.Context)

@Summary 获取用户详情 @Description 根据PublicID或Phone获取用户详情 @Tags User @Accept json @Produce json @Param body body GetUserRequest true "获取用户请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetUser [post]

func (*UserHandler) ListUin added in v0.3.3 

func (h *UserHandler) ListUin(ctx *gin.Context)

@Summary 查询用户身份标识列表 @Description 获取当前登录用户的所有UIN（用户身份标识）列表，包含个人和企业身份 @Tags User @Accept json @Produce json @Param body body contract.ListUinRequest true "查询请求（可为空）" @Success 200 {object} dto.Response "成功响应" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListUin [post]

func (*UserHandler) ListUser added in v0.3.3 

func (h *UserHandler) ListUser(ctx *gin.Context)

@Summary 查询用户列表 @Description 分页查询用户列表 @Tags User @Accept json @Produce json @Param body body contract.ListUserRequest true "查询列表请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListUser [post]

func (*UserHandler) RegisterRoutes 

func (h *UserHandler) RegisterRoutes(r gin.IRouter)

func (*UserHandler) UpdateUser 

func (h *UserHandler) UpdateUser(ctx *gin.Context)

@Summary 更新用户 @Description 更新用户信息 @Tags User @Accept json @Produce json @Param body body UpdateUserRequest true "更新用户请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateUser [post]

type WorkerAuthHandler added in v0.1.12 

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

WorkerAuthHandler exchanges worker bootstrap tokens for short-lived access tokens by delegating to a TokenParser.

func NewWorkerAuthHandler added in v0.1.12 

func NewWorkerAuthHandler(parser middleware.TokenParser) *WorkerAuthHandler

NewWorkerAuthHandler creates a worker auth handler backed by the given TokenParser.

func (*WorkerAuthHandler) IssueToken added in v0.1.12 

func (h *WorkerAuthHandler) IssueToken(ctx *gin.Context)

@Summary 获取 Worker 访问令牌 @Description 使用 Worker 启动令牌（bootstrap token）换取短期访问令牌 @Tags WorkerAuth @Accept json @Produce json @Param body body handler.issueWorkerTokenRequest true "Worker 令牌请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "认证失败" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /workers/token [post]

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.