Files
kami_gateway/main.go
2025-02-24 21:37:26 +08:00

38 lines
980 B
Go

package main
import (
_ "gateway/internal/models"
"gateway/internal/otelTrace"
_ "gateway/internal/routers"
"gateway/internal/schema/query"
"gateway/internal/service"
_ "gateway/internal/service/message"
"gateway/internal/service/notify"
_ "gateway/internal/service/supplier/third_party"
_ "net/http/pprof"
"github.com/beego/beego/v2/server/web"
_ "github.com/go-sql-driver/mysql"
)
func main() {
cleanup1, cleanup2, cleanup3 := otelTrace.InitTracer()
defer func() {
if cleanup1 != nil {
_ = cleanup1(otelTrace.InitCtx)
}
if cleanup2 != nil {
_ = cleanup2(otelTrace.InitCtx)
}
if cleanup3 != nil {
_ = cleanup3(otelTrace.InitCtx)
}
}()
go notify.CreateOrderNotifyConsumer(otelTrace.InitCtx)
go query.CreatePayForQueryConsumer(otelTrace.InitCtx)
go service.OrderSettleInit(otelTrace.InitCtx)
go query.CreateSupplierOrderQueryCuConsumer(otelTrace.InitCtx)
otelTrace.Logger.WithContext(otelTrace.InitCtx).Info("gateway start")
web.Run()
}