46 lines
1.3 KiB
Go
46 lines
1.3 KiB
Go
package agent
|
|
|
|
import (
|
|
"context"
|
|
v1 "likedream-goframe/internal/api/v1"
|
|
"likedream-goframe/internal/service"
|
|
"likedream-goframe/internal/utils"
|
|
)
|
|
|
|
type AgentCtrlV1 struct {
|
|
}
|
|
|
|
func NewV1() IAgentCtrl {
|
|
return &AgentCtrlV1{}
|
|
}
|
|
|
|
// List 获取代理列表
|
|
func (a AgentCtrlV1) List(ctx context.Context, req *v1.AgentListReq) (res *utils.Response[[]v1.AgentListRes], err error) {
|
|
defer utils.Pass(&err)
|
|
return service.Global.Agent.List(ctx, req), nil
|
|
}
|
|
|
|
// Add 添加下级代理
|
|
func (a AgentCtrlV1) Add(ctx context.Context, req *v1.AgentAddReq) (res *utils.Response[any], err error) {
|
|
defer utils.Pass(&err)
|
|
panic("implement me")
|
|
}
|
|
|
|
// Ban 禁用代理
|
|
func (a AgentCtrlV1) Ban(ctx context.Context, req *v1.AgentBanReq) (res *utils.Response[any], err error) {
|
|
defer utils.Pass(&err)
|
|
return service.Global.Agent.Ban(ctx, req), nil
|
|
}
|
|
|
|
// Recharge 代理充值
|
|
func (a AgentCtrlV1) Recharge(ctx context.Context, req *v1.AgentRechargeReq) (res *utils.Response[any], err error) {
|
|
defer utils.Pass(&err)
|
|
return service.Global.Agent.Recharge(ctx, req), nil
|
|
}
|
|
|
|
// 修改代理信息
|
|
func (a *AgentCtrlV1) AgentPutInfoReq(ctx context.Context, req *v1.AgentPutInfoReq) (res *utils.Response[any], err error) {
|
|
defer utils.Pass(&err)
|
|
return service.Global.Agent.AgentPutInfoReq(ctx, req), nil
|
|
}
|