func main() {
	app, err := igo.NewApp("") //初始化各个组件,igo.App 全局实例自动设置
	if err != nil {
		fmt.Println("初始化失败:", err)
		os.Exit(1)
	}
	app.EnableHealthCheck()          //可选:开启 GET /health(带 db/redis 连通性检测)
	app.Web.Router.Use(web.Cors())   //可选:开启跨域

	Router(app.Web.Router) //引入 gin路由

	//启动并等待退出信号,自动优雅关闭(Web → Cache → DB 依次关闭)
	//Web 启动失败(如端口被占用)会立即返回错误
	if err := app.Run(); err != nil {
		os.Exit(1)
	}
}

func Router(r *gin.Engine) {
	r.GET("ping", Ping)
}

func Ping(c *gin.Context) {
	res.Rsucc(c, gin.H{"message": "Hello World."})
}

//配置文件 Conf是viper的封装(热重载时并发安全,请使用 Conf 的 Get* 方法读取)
igo.App.Conf.GetString("xxx.xxx") //直接通过viper读取
util.ConfGetString("local.debug") //util方法读取配置文件

//日志 log是zap的封装
log.Info("hello igo", log.Any("now_time", time.Now().Unix())) //不带traceId
log.Error("error", log.Any("now_time", time.Now().Unix())) //不带traceId
ctx.LogInfo("main-info", log.Any("info", "test")) //包含traceId
ctx.LogError("main-error", log.Any("error", "test")) //包含traceId

//xorm db是xorm的封装
db := igo.App.DB.NewDBTable("dbname", "news")
session := db.Where("")
err := session.OrderBy("id desc").Find(&rows)
//带 context 的查询:请求取消/超时后查询自动中断(推荐)
err = db.WithCtx(ctx).Where("uid = ?", uid).Find(&rows)

//redis(go-redis v9)
//igorediskey是配置文件中的redis配置项
redis, err := igo.App.Cache.Get("igorediskey")
getRedisKey, err := redis.Get(ctx, "redis_key").Result()

//统一响应
res.Rsucc(c, data)                //{"code":0,"msg":"success","data":..}
res.Rfail(c, "错误信息")           //{"code":1,"msg":"..","data":null}
res.Rlist(c, total, items)        //{"code":0,"data":{"total":..,"items":..}}
res.SetCodes(200, 1)              //可选:全局调整成功/失败业务码

//分页(内嵌进业务 Search 结构)
type NoteSearch struct {
	util.PageQuery //Page/PageSize
	Keyword string `form:"keyword"`
}
search.Normalize(20, 100) //Page 从1起,PageSize 默认20、上限100
session.Limit(search.PageSize, search.Offset())
//排序白名单,防SQL注入
orderBy := util.SafeOrderBy(search.Sort, map[string]string{"created": "created_at desc"}, "id desc")

err := igo.App.DB.Transaction("dbname", func(sess *xorm.Session) error {
	if _, err := sess.Table("users").Insert(&user); err != nil {
		return err // 返回 error 自动回滚
	}
	_, err := sess.Table("orders").Insert(&order)
	return err // 返回 nil 自动提交
})

sess, err := igo.App.DB.BeginTx("dbname")
if err != nil {
	return err
}
defer sess.Close()
sess.Table("users").Insert(&user)
sess.Table("orders").Insert(&order)
err = sess.Commit() //失败时 sess.Rollback()

client := httpclient.New(
	httpclient.WithTimeout(3*time.Second),
	httpclient.WithRetries(2),          //网络层错误重试,HTTP 状态码错误不重试
	httpclient.WithUserAgent("my-app"),
)

//JSON 便捷方法
var out SomeResp
err := client.PostJSON(ctx, url, reqBody, &out)
err = client.GetJSON(ctx, url, &out)

//通用请求
resp, err := client.Get(ctx, url)
fmt.Println(resp.StatusCode, resp.String())

//下载原始内容(非 2xx 自动报错)
data, err := client.GetBytes(ctx, url)

//单次请求附加 header
err = client.GetJSON(ctx, url, &out, httpclient.WithReqHeader("Authorization", "Bearer xxx"))

//表单提交 + JSON 响应
err = client.PostFormJSON(ctx, url, formValues, &out)

//代理与自签证书场景
proxyClient := httpclient.New(
	httpclient.WithProxyURL("http://127.0.0.1:7890"), //固定代理;动态代理用 WithProxyFunc
	httpclient.WithInsecureSkipVerify(),               //跳过 TLS 校验(生产慎用)
)

//简单场景直接用包级默认客户端
resp, err = httpclient.Get(ctx, url)

type MyHook struct{}
func (h *MyHook) Levels() []zapcore.Level {
	return []zapcore.Level{zapcore.ErrorLevel, zapcore.FatalLevel}
}
func (h *MyHook) Fire(entry *log.LogEntry) error {
	// 发送到飞书、企业微信等(异步执行,不阻塞日志)
	return nil
}
log.AddHook(&MyHook{})

app.AddStartupHook(func() error { ... })   //Run 时按注册顺序执行
app.AddShutdownHook(func() error { ... })  //关闭时按注册反序执行,默认10秒超时
app.AddConfigChangeCallback(func() { ... })//配置热重载后触发
app.GetShutdownContext()                   //应用关闭时被 cancel,用于停止后台goroutine