main.go 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687
  1. package main
  2. import (
  3. "eta_gn/eta_api/controllers"
  4. "eta_gn/eta_api/models"
  5. "eta_gn/eta_api/services/alarm_msg"
  6. "fmt"
  7. "runtime"
  8. "time"
  9. _ "eta_gn/eta_api/global"
  10. _ "eta_gn/eta_api/routers"
  11. //"eta_gn/eta_api/services"
  12. "eta_gn/eta_api/services/ice_message"
  13. "eta_gn/eta_api/utils"
  14. "github.com/beego/beego/v2/adapter/logs"
  15. "github.com/beego/beego/v2/server/web"
  16. "github.com/beego/beego/v2/server/web/context"
  17. )
  18. func main() {
  19. if web.BConfig.RunMode == "dev" {
  20. web.BConfig.WebConfig.DirectoryIndex = true
  21. web.BConfig.WebConfig.StaticDir["/swagger"] = "swagger"
  22. }
  23. // 服务名称
  24. web.BConfig.ServerName = `server`
  25. //go services.Task()
  26. url := ""
  27. // 生成taskId
  28. reportId := 1
  29. pptId := 0
  30. // 生成taskId
  31. taskId := utils.MD5(fmt.Sprintf("%s_%s_%s_%s", reportId, pptId, "1", time.Now().Format("20060102150405")))
  32. err := ice_message.PushIceMessage("测试标题", "", "", "e0174539", taskId, reportId, pptId, url, "煤炭市场日报")
  33. if err != nil {
  34. fmt.Println("PushIceMessage error:", err)
  35. } else {
  36. fmt.Println("PushIceMessage success")
  37. }
  38. // 初始化表数据入库
  39. models.AfterInitTable()
  40. // 异常处理
  41. web.ErrorController(&controllers.ErrorController{})
  42. // 内存调整
  43. web.BConfig.MaxMemory = 1024 * 1024 * 128
  44. web.BConfig.RecoverFunc = Recover
  45. web.Run()
  46. }
  47. func Recover(ctx *context.Context, conf *web.Config) {
  48. if err := recover(); err != nil {
  49. if err == web.ErrAbort {
  50. return
  51. }
  52. if !web.BConfig.RecoverPanic {
  53. panic(err)
  54. }
  55. stack := ""
  56. msg := fmt.Sprintf("The request url is %v", ctx.Input.URL())
  57. stack += msg + "</br>"
  58. logs.Critical(msg)
  59. msg = fmt.Sprintf("The request data is %v", string(ctx.Input.RequestBody))
  60. stack += msg + "</br>"
  61. logs.Critical(msg)
  62. msg = fmt.Sprintf("Handler crashed with error %v", err)
  63. stack += msg + "</br>"
  64. logs.Critical(msg)
  65. for i := 1; ; i++ {
  66. _, file, line, ok := runtime.Caller(i)
  67. if !ok {
  68. break
  69. }
  70. logs.Critical(fmt.Sprintf("%s:%d", file, line))
  71. stack = stack + fmt.Sprintln(fmt.Sprintf("%s:%d</br>", file, line))
  72. }
  73. go alarm_msg.SendAlarmMsg(utils.APPNAME+"崩了"+time.Now().Format("2006-01-02 15:04:05")+"<br/>"+stack, 3)
  74. }
  75. return
  76. }