package main import ( _ "eta/eta_task/routers" "eta/eta_task/services" "eta/eta_task/services/alarm_msg" "eta/eta_task/utils" "fmt" "github.com/beego/beego/v2/server/web" "runtime" "time" "github.com/beego/beego/v2/adapter/logs" "github.com/beego/beego/v2/server/web/context" ) func main() { if web.BConfig.RunMode == "dev" { web.BConfig.WebConfig.DirectoryIndex = true web.BConfig.WebConfig.StaticDir["/swagger"] = "swagger" } go services.Task() //services.TaskInit() web.BConfig.RecoverFunc = Recover web.Run() } func Recover(ctx *context.Context, conf *web.Config) { if err := recover(); err != nil { if err == web.ErrAbort { return } if !web.BConfig.RecoverPanic { panic(err) } stack := "" msg := fmt.Sprintf("The request url is %v", ctx.Input.URL()) stack += msg + "
" logs.Critical(msg) msg = fmt.Sprintf("The request data is %v", string(ctx.Input.RequestBody)) stack += msg + "
" logs.Critical(msg) msg = fmt.Sprintf("Handler crashed with error %v", err) stack += msg + "
" logs.Critical(msg) for i := 1; ; i++ { _, file, line, ok := runtime.Caller(i) if !ok { break } logs.Critical(fmt.Sprintf("%s:%d", file, line)) stack = stack + fmt.Sprintln(fmt.Sprintf("%s:%d
", file, line)) } //go utils.SendEmail(utils.APPNAME+"崩了"+time.Now().Format("2006-01-02 15:04:05"), stack, utils.EmailSendToUsers) go alarm_msg.SendAlarmMsg(utils.APPNAME+"崩了"+time.Now().Format("2006-01-02 15:04:05")+"\n"+stack, 3) } return }