package main import ( "eta_gn/eta_api/controllers" "eta_gn/eta_api/models" "eta_gn/eta_api/services/alarm_msg" "fmt" "runtime" "time" _ "eta_gn/eta_api/global" _ "eta_gn/eta_api/routers" //"eta_gn/eta_api/services" "eta_gn/eta_api/services/ice_message" "eta_gn/eta_api/utils" "github.com/beego/beego/v2/adapter/logs" "github.com/beego/beego/v2/server/web" "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" } // 服务名称 web.BConfig.ServerName = `server` //go services.Task() url := "" // 生成taskId reportId := 1 pptId := 0 // 生成taskId taskId := utils.MD5(fmt.Sprintf("%s_%s_%s_%s", reportId, pptId, "1", time.Now().Format("20060102150405"))) err := ice_message.PushIceMessage("测试标题", "", "", "e0174539", taskId, reportId, pptId, url, "煤炭市场日报") if err != nil { fmt.Println("PushIceMessage error:", err) } else { fmt.Println("PushIceMessage success") } // 初始化表数据入库 models.AfterInitTable() // 异常处理 web.ErrorController(&controllers.ErrorController{}) // 内存调整 web.BConfig.MaxMemory = 1024 * 1024 * 128 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 alarm_msg.SendAlarmMsg(utils.APPNAME+"崩了"+time.Now().Format("2006-01-02 15:04:05")+"
"+stack, 3) } return }