package main import ( "log" "git.x2erp.com/qdy/go-base/config" "git.x2erp.com/qdy/go-base/container" "git.x2erp.com/qdy/go-base/graceful" "git.x2erp.com/qdy/go-base/logger" "git.x2erp.com/qdy/go-base/webx" "git.x2erp.com/qdy/go-base/webx/router" "git.x2erp.com/qdy/go-db/factory/database" "git.x2erp.com/qdy/go-db/sqldef" "git.x2erp.com/qdy/go-svc-configure/internal/routes" _ "git.x2erp.com/qdy/go-svc-configure/internal/tables" // 导入表定义包,触发 init() 函数 ) ////go:embed web/dist //var frontendFS embed.FS var ( appName = "svc-configure" appVersion = "1" ) func main() { // 0. 初始化日志 logBootFactory := logger.InitBootLog() // 1. 获取配置文件 cfg := config.GetConfig() cfg.SetAppName(appName) cfg.SetAppVersion(appVersion) // 2. 创建关闭容器 ctr := container.NewContainer(cfg) // 注册日志,实现自动关闭 container.Reg(ctr, logBootFactory) // 3. 创建数据库工厂 dbFactory := container.Create(ctr, database.CreateDBFactory) dbFactory.TestConnection() // 创建表 creteTabel(dbFactory) //启用运行日志 container.Create(ctr, logger.InitRuntimeLogger) //建立httpservice //得到webservice服务工厂 webxFactory := webx.GetWebServiceFactory() //建立hhtpService服务 webServcie, _ := webxFactory.CreateService(cfg.GetServiceConfig()) //建立路由-api routerService := router.NewWebService(webServcie.GetRouter()) //注册路由--api registerRoutes(routerService, dbFactory) // 注册前端静态文件服务 //frontendHandler := ServeFrontend() //webServcie.GetRouter().Handle("/", frontendHandler) //启动服务 webServcie.Run() //等待关闭 graceful.WaitForShutdown(cfg.GetServiceConfig().ServiceName, ctr, webServcie.GetServer()) } // 注册所有路由 func registerRoutes(ws *router.RouterService, dbFactory *database.DBFactory) { // Token 管理路由 routes.RegisterTokenRoutes(ws, dbFactory) // SVC 启动配置路由 routes.RegisterSvcstartupRoutes(ws, dbFactory) // 微服务管理路由 routes.RegisterServiceManagementRoutes(ws, dbFactory) // 启动配置路由 routes.RegisterStartupRoutes(ws, dbFactory) // Boot 配置路由 routes.RegisterBootconfigRoutes(ws, dbFactory) // 初始化配置元数据路由 routes.RegisterRegisterRoutes(ws, dbFactory) // 配置元数据管理路由 routes.RegisterMetaManagementRoutes(ws, dbFactory) // 项目技能管理路由 routes.RegisterSkillRoutes(ws, dbFactory) // 项目管理路由 routes.RegisterProjectRoutes(ws, dbFactory) // 项目树结构路由 routes.RegisterProjectTreeRoutes(ws, dbFactory) // 同步方案管理路由 routes.RegisterSolutionManagementRoutes(ws, dbFactory) // 数据库字典管理路由 routes.RegisterDicManagementRoutes(ws, dbFactory) // 别名字典管理路由 routes.RegisterAliasManagementRoutes(ws, dbFactory) // 项目代理管理路由 routes.RegisterProjectAgentRoutes(ws, dbFactory) // 租户管理路由 routes.RegisterTenantRoutes(ws, dbFactory) // 角色管理路由 routes.RegisterRoleRoutes(ws, dbFactory) // 用户认证路由 routes.RegisterUserRoutes(ws, dbFactory) // 管理员登录路由(无需 dbFactory) routes.RegisterAdminRoutes(ws) } func creteTabel(factory *database.DBFactory) { // 获取数据库连接和类型 db := factory.GetDB() dbType := factory.GetDBType() // 创建表同步器 syncer, err := sqldef.NewTableSyncer(db, dbType) if err != nil { log.Printf("创建 - 建立器失败: %v", err) } // 创建表 if err := syncer.CreateTables(); err != nil { log.Printf("建表失败: %v", err) } log.Println("数据库表建立完成!") } // // ServeFrontend 返回处理前端静态文件的服务处理器 // func ServeFrontend() http.Handler { // // 从嵌入的文件系统中获取 dist 子目录 // fsys, err := fs.Sub(frontendFS, "web/dist") // if err != nil { // // 如果失败,回退到空文件系统 // return http.FileServer(http.FS(frontendFS)) // } // // 创建自定义文件服务器,处理 SPA 路由 // return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { // // 只处理 GET 和 HEAD 请求 // if r.Method != "GET" && r.Method != "HEAD" { // // 对于非 GET/HEAD 请求,返回 404 让 API 路由处理 // http.NotFound(w, r) // return // } // // API 路径不处理 // if strings.HasPrefix(r.URL.Path, "/api/") { // http.NotFound(w, r) // return // } // // 尝试从文件系统读取请求的文件 // filePath := strings.TrimPrefix(r.URL.Path, "/") // if filePath == "" { // filePath = "index.html" // } // // 检查文件是否存在 // _, err := fs.Stat(fsys, filePath) // if err != nil { // // 文件不存在,返回 index.html 用于 SPA 路由 // indexData, err := frontendFS.ReadFile("web/dist/index.html") // if err != nil { // http.Error(w, "Not Found", http.StatusNotFound) // return // } // w.Header().Set("Content-Type", "text/html; charset=utf-8") // w.Write(indexData) // return // } // // 文件存在,正常提供 // http.FileServer(http.FS(fsys)).ServeHTTP(w, r) // }) // }