This commit is contained in:
2025-07-28 16:13:59 +08:00
parent c12bd0f0db
commit f3bb7b8a7b
2 changed files with 18 additions and 0 deletions

View File

@@ -78,6 +78,8 @@ func (a *Application) Run() error {
a.logger.Error("Failed to start container", zap.Error(err))
return err
}
a.logger.Info("Container started successfully, setting up graceful shutdown...")
// 设置优雅关闭
a.setupGracefulShutdown()

View File

@@ -146,8 +146,19 @@ func NewContainer() *Container {
}
db, err := database.NewConnection(dbCfg)
if err != nil {
logger.Error("数据库连接失败",
zap.String("host", cfg.Database.Host),
zap.String("port", cfg.Database.Port),
zap.String("database", cfg.Database.Name),
zap.String("user", cfg.Database.User),
zap.Error(err))
return nil, err
}
logger.Info("数据库连接成功",
zap.String("host", cfg.Database.Host),
zap.String("port", cfg.Database.Port),
zap.String("database", cfg.Database.Name))
// 设置GORM缓存插件
if err := SetupGormCache(db.DB, cacheService, cfg, logger); err != nil {
@@ -572,6 +583,7 @@ func RegisterLifecycleHooks(
lifecycle.Append(fx.Hook{
OnStart: func(context.Context) error {
logger.Info("应用启动中...")
logger.Info("所有依赖注入完成,开始启动应用服务")
return nil
},
OnStop: func(context.Context) error {
@@ -644,8 +656,12 @@ func RegisterRoutes(
if err := router.Start(addr); err != nil {
logger.Error("HTTP服务器启动失败", zap.Error(err))
} else {
logger.Info("HTTP服务器启动成功", zap.String("addr", addr))
}
}()
logger.Info("路由注册完成HTTP服务器启动中...")
}
// ================ 中间件包装函数 ================