diff --git a/modules/base/controller/admin/base_open.go b/modules/base/controller/admin/base_open.go index f011660b..cd222d42 100644 --- a/modules/base/controller/admin/base_open.go +++ b/modules/base/controller/admin/base_open.go @@ -7,7 +7,6 @@ import ( v1 "blazing/modules/base/api/v1" "blazing/modules/base/service" - config "blazing/modules/config/service" "github.com/gogf/gf/v2/frame/g" ) @@ -82,15 +81,15 @@ func (c *BaseOpen) RefreshToken(ctx context.Context, req *RefreshTokenReq) (res return } -// 获取服务器当前ip和端口 -type GetPortReq struct { - g.Meta `path:"/getport" method:"GET"` -} +// // 获取服务器当前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() +// func (c *BaseOpen) GetPort(ctx context.Context, req *GetPortReq) (res *cool.BaseRes, err error) { +// res = &cool.BaseRes{} +// res.Data = config.NewServerService().GetPort() - return +// return -} +// } diff --git a/modules/base/controller/admin/base_sys_user.go b/modules/base/controller/admin/base_sys_user.go index 7023e668..fce539b8 100644 --- a/modules/base/controller/admin/base_sys_user.go +++ b/modules/base/controller/admin/base_sys_user.go @@ -7,8 +7,10 @@ import ( "blazing/modules/base/service" + config "blazing/modules/config/service" blazing "blazing/modules/player/service" + "github.com/gogf/gf/v2/database/gdb" "github.com/gogf/gf/v2/frame/g" ) @@ -68,13 +70,13 @@ func (c *BaseSysUserController) GetSession(ctx context.Context, req *SessionReq) } else { res.LoginAddr = cool.Config.File.Domain + ":" + cool.Config.LoginPort } - + res.Server = config.NewServerService().GetPort() return } type SessionRes struct { - UserID int `json:"userid"` - Session string `json:"session"` - LoginAddr string `json:"loginaddr"` - //Server model.ServerList `json:"server"` + UserID int `json:"userid"` + Session string `json:"session"` + LoginAddr string `json:"loginaddr"` + Server gdb.List `json:"server"` } diff --git a/modules/base/middleware/middleware.go b/modules/base/middleware/middleware.go index f953dfb2..9a317901 100644 --- a/modules/base/middleware/middleware.go +++ b/modules/base/middleware/middleware.go @@ -40,9 +40,7 @@ func init() { g.Server().BindMiddleware("/admin/*", BaseAuthorityMiddleware) // g.Server().BindMiddleware("/*", AutoI18n) g.Server().BindMiddleware("/*", MiddlewareCORS) - // g.Server().BindMiddleware("/getip", func(r *ghttp.Request) { - // r.Response.Write(cool.Config.File.Domain + ":" + gconv.String(cool.Config.LoginPort)) - // }) + } if config.Config.Middleware.Log.Enable { g.Server().BindMiddleware("/admin/*", BaseLog) @@ -52,7 +50,7 @@ func init() { tt := new(ServerHandler) id := gconv.Uint16(r.URL.Query().Get("id")) - tt.ServerList = service.NewServerService().GetServerID(id) + tt.ServerList = service.NewServerService().StartUPdate(id) tt.isinstall = gconv.Uint32(r.URL.Query().Get("isinstall")) upgrader := gws.NewUpgrader(tt, &gws.ServerOption{ diff --git a/modules/base/middleware/server.go b/modules/base/middleware/server.go index 0e1530a6..a49a3f99 100644 --- a/modules/base/middleware/server.go +++ b/modules/base/middleware/server.go @@ -152,7 +152,8 @@ func (s *ServerHandler) executeFullDeployment() error { s.sendTerminalOutput(s.session.WebSocket, "开始执行完整自动化部署流程...") // 1. 获取并校验下载链接 - fileURL := config.NewServerService().GetFile() + filename := config.NewServerService().GetFile() + fileURL := "http://sun.72wo.cn/" + filename fileURL = strings.TrimSpace(fileURL) if fileURL == "" { return fmt.Errorf("下载链接为空") @@ -440,9 +441,8 @@ echo "#SCRIPT_EXECUTION_COMPLETE#" } // 6. 保存会话名称 - config.NewServerService().SetServerScreen(s.ServerList.OnlineID, fixedScreenSession) + config.NewServerService().SetServerScreen(s.ServerList.OnlineID, filename) - s.sendTerminalOutput(s.session.WebSocket, "自动化部署完成") return nil } diff --git a/modules/config/service/server.go b/modules/config/service/server.go index d3b08c2b..44064fec 100644 --- a/modules/config/service/server.go +++ b/modules/config/service/server.go @@ -85,7 +85,20 @@ func (s *ServerService) GetServer() []model.ServerList { return item } +func (s *ServerService) StartUPdate(OnlineID uint16) model.ServerList { + m := cool.DBM(s.Model).Where("online_id", OnlineID) + + var tttt model.ServerList + m.Scan(&tttt) + + tttt.IsOpen = 0 + + m.Save(tttt) + // s.CleanCache() + return tttt + +} func (s *ServerService) SetServerID(OnlineID uint16, Port uint16) error { m := cool.DBM(s.Model).Where("online_id", OnlineID) @@ -94,6 +107,7 @@ func (s *ServerService) SetServerID(OnlineID uint16, Port uint16) error { m.Scan(&tttt) tttt.Port = Port tttt.OnlineID = OnlineID + tttt.IsOpen = 1 m.Save(tttt) // s.CleanCache() @@ -108,9 +122,7 @@ func (s *ServerService) GetServerID(OnlineID uint16) model.ServerList { } -// func (s *ServerService) CleanCache() { -// g.DB().GetCore().ClearCache(context.TODO(), s.Model.TableName()) -// } +// 保存版本号 func (s *ServerService) SetServerScreen(id uint16, name string) { dbm(s.Model).Where("online_id", id).Data("old_screen", name).Update() @@ -149,7 +161,7 @@ func (s *ServerService) GetFile() string { return files[i].Time > files[j].Time }) - return "http://sun.72wo.cn/" + files[0].Name + return files[0].Name }