昔念
808612cc1e
feat(config): 添加服务器端口获取功能 添加GetPort方法用于获取服务器当前IP和端口信息， 新增Name和Owner字段到ServerList模型中 refactor(login): 优化调试参数处理 将命令行参数解析改为使用parser.GetOpt获取debug选项， 移除未使用的fmt和qqwry导入包 refactor(main): 清理示例代码 移除main.go中的
97 lines
2.3 KiB
Go
97 lines
2.3 KiB
Go
package admin
|
|
|
|
import (
|
|
"context"
|
|
|
|
"blazing/cool"
|
|
|
|
v1 "blazing/modules/base/api/v1"
|
|
"blazing/modules/base/service"
|
|
config "blazing/modules/config/service"
|
|
|
|
"github.com/gogf/gf/v2/frame/g"
|
|
)
|
|
|
|
type BaseOpen struct {
|
|
*cool.ControllerSimple
|
|
baseSysLoginService *service.BaseSysLoginService
|
|
baseOpenService *service.BaseOpenService
|
|
}
|
|
|
|
func init() {
|
|
var open = &BaseOpen{
|
|
ControllerSimple: &cool.ControllerSimple{Prefix: "/admin/base/open"},
|
|
baseSysLoginService: service.NewBaseSysLoginService(),
|
|
baseOpenService: service.NewBaseOpenService(),
|
|
}
|
|
// 注册路由
|
|
cool.RegisterControllerSimple(open)
|
|
}
|
|
|
|
// 验证码接口
|
|
func (c *BaseOpen) BaseOpenCaptcha(ctx context.Context, req *v1.BaseOpenCaptchaReq) (res *cool.BaseRes, err error) {
|
|
data, err := c.baseSysLoginService.Captcha(req)
|
|
res = cool.Ok(data)
|
|
return
|
|
}
|
|
|
|
// eps 接口请求
|
|
type BaseOpenEpsReq struct {
|
|
g.Meta `path:"/eps" method:"GET"`
|
|
}
|
|
|
|
// eps 接口
|
|
func (c *BaseOpen) Eps(ctx context.Context, req *BaseOpenEpsReq) (res *cool.BaseRes, err error) {
|
|
if !cool.Config.Eps {
|
|
cool.Logger.Error(ctx, "eps is not open")
|
|
res = cool.Ok(nil)
|
|
return
|
|
}
|
|
data, err := c.baseOpenService.AdminEPS(ctx)
|
|
if err != nil {
|
|
cool.Logger.Error(ctx, "eps error", err)
|
|
return cool.Fail(err.Error()), err
|
|
}
|
|
res = cool.Ok(data)
|
|
return
|
|
}
|
|
|
|
// login 接口
|
|
func (c *BaseOpen) Login(ctx context.Context, req *v1.BaseOpenLoginReq) (res *cool.BaseRes, err error) {
|
|
data, err := c.baseSysLoginService.Login(ctx, req)
|
|
if err != nil {
|
|
return
|
|
}
|
|
res = cool.Ok(data)
|
|
return
|
|
}
|
|
|
|
// RefreshTokenReq 刷新token请求
|
|
type RefreshTokenReq struct {
|
|
g.Meta `path:"/refreshToken" method:"GET"`
|
|
RefreshToken string `json:"refreshToken" v:"required#refreshToken不能为空"`
|
|
}
|
|
|
|
// RefreshToken 刷新token
|
|
func (c *BaseOpen) RefreshToken(ctx context.Context, req *RefreshTokenReq) (res *cool.BaseRes, err error) {
|
|
data, err := c.baseSysLoginService.RefreshToken(ctx, req.RefreshToken)
|
|
if err != nil {
|
|
return
|
|
}
|
|
res = cool.Ok(data)
|
|
return
|
|
}
|
|
|
|
// 获取服务器当前ip和端口
|
|
type GetPortReq struct {
|
|
g.Meta `path:"/getport" method:"GET"`
|
|
}
|
|
|
|
func (c *BaseOpen) GetPort(ctx context.Context, req *GetPortReq) (res *cool.BaseRes, err error) {
|
|
res = &cool.BaseRes{}
|
|
res.Data = config.NewServerService().GetPort()
|
|
|
|
return
|
|
|
|
}
|