go-svc-mercury/main.go

package main

import (
	"log"

	"git.x2erp.com/qdy/go-db/factory/database"
	"git.x2erp.com/qdy/go-db/sqldef"

	"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-svc-mercury/internal/tables" // 导入表定义包，触发 init() 函数
)

var (
	appName    = "svc-mercury"
	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)

	// 同步表定义到配置中心
	syncTablesToConfigure(cfg)

	//启用运行日志
	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 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("数据库表建立完成！")
}

func syncTablesToConfigure(cfg config.IConfig) {

}