edb_info_notice.go 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138
  1. package data
  2. import (
  3. "errors"
  4. "fmt"
  5. "hongze/hongze_task/models/data_manage"
  6. "hongze/hongze_task/utils"
  7. "time"
  8. )
  9. //指标更新通知
  10. func RefreshNotice() (err error) {
  11. defer func() {
  12. if err != nil {
  13. fmt.Println("RefreshNotice Err:" + err.Error())
  14. go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "RefreshNotice ErrMsg:"+err.Error(), utils.EmailSendToUsers)
  15. }
  16. }()
  17. var condition string
  18. var pars []interface{}
  19. items, err := data_manage.GetEdbInfoByCondition(condition, pars, 1)
  20. if err != nil {
  21. return errors.New("GetEdbInfoByCondition:" + err.Error())
  22. }
  23. //日度
  24. dayDiv := `<div>日度指标,超过3天未更新:</div>`
  25. dayTable := `<table border="1" style="border-collapse: collapse;">
  26. <thead>
  27. <tr>
  28. <td>指标编码</td>
  29. <td>指标名称</td>
  30. <td>指标来源</td>
  31. <td>频度</td>
  32. <td>指标数据最后日期</td>
  33. <td>指标数据更新日期</td>
  34. </tr>
  35. </thead>`
  36. dayTableBody := `<tbody>`
  37. dayDate := time.Now().AddDate(0, 0, -3)
  38. for _, v := range items {
  39. if v.Frequency == "日度" && v.EndDate.Before(dayDate) {
  40. dayTableBody += getTableTr(v)
  41. }
  42. }
  43. dayTable += dayTableBody
  44. dayTable += ` </tbody></table>`
  45. noticeSendBody := dayDiv + dayTable
  46. noticeSendBody += `<br/>`
  47. //周度
  48. weekDiv := `<div>周度指标,超过7天未更新:</div>`
  49. weekTable := `<table border="1" style="border-collapse: collapse;">
  50. <thead>
  51. <tr>
  52. <td>指标编码</td>
  53. <td>指标名称</td>
  54. <td>指标来源</td>
  55. <td>频度</td>
  56. <td>指标数据最后日期</td>
  57. <td>指标数据更新日期</td>
  58. </tr>
  59. </thead>`
  60. weekTableBody := `<tbody>`
  61. weekDate := time.Now().AddDate(0, 0, -7)
  62. for _, v := range items {
  63. if v.Frequency == "周度" && v.EndDate.Before(weekDate) {
  64. weekTableBody += getTableTr(v)
  65. }
  66. }
  67. weekTable += weekTableBody
  68. weekTable += ` </tbody></table>`
  69. noticeSendBody += weekDiv + weekTable
  70. noticeSendBody += `<br/>`
  71. //月度
  72. monthDiv := `<div>月度指标,超过一个月未更新:</div>`
  73. monthTable := `<table border="1" style="border-collapse: collapse;">
  74. <thead>
  75. <tr>
  76. <td>指标编码</td>
  77. <td>指标名称</td>
  78. <td>指标来源</td>
  79. <td>频度</td>
  80. <td>指标数据最后日期</td>
  81. <td>指标数据更新日期</td>
  82. </tr>
  83. </thead>`
  84. monthTableBody := `<tbody>`
  85. monthDate := time.Now().AddDate(0, -1, 0)
  86. for _, v := range items {
  87. if v.Frequency == "月度" && v.EndDate.Before(monthDate) {
  88. monthTableBody += getTableTr(v)
  89. }
  90. }
  91. monthTable += monthTableBody
  92. monthTable += ` </tbody></table>`
  93. noticeSendBody += monthDiv + monthTable
  94. noticeSendBody += `<br/>`
  95. //所有指标
  96. allDiv := `<hr style="color: red">`
  97. allDiv = `<div>当前所有指标,按数据日期升序排列:</div>`
  98. allTable := `<table border="1" style="border-collapse: collapse;">
  99. <thead>
  100. <tr>
  101. <td>指标编码</td>
  102. <td>指标名称</td>
  103. <td>指标来源</td>
  104. <td>频度</td>
  105. <td>指标数据最后日期</td>
  106. <td>指标数据更新日期</td>
  107. </tr>
  108. </thead>`
  109. allTableBody := `<tbody>`
  110. for _, v := range items {
  111. allTableBody += getTableTr(v)
  112. }
  113. allTable += allTableBody
  114. allTable += ` </tbody></table>`
  115. noticeSendBody += allDiv + allTable
  116. utils.SendEmailByHongze("指标更新情况通知", noticeSendBody, utils.RefreshEdbInfoEmailSendToUsers, "", "")
  117. return
  118. }
  119. func getTableTr(item *data_manage.EdbInfoList) string {
  120. if item != nil {
  121. trHtml := ` <tr>
  122. <td>` + item.EdbCode + `</td>
  123. <td>` + item.EdbName + `</td>
  124. <td>` + item.SourceName + `</td>
  125. <td>` + item.Frequency + `</td>
  126. <td>` + item.EndDate.Format(utils.FormatDate) + `</td>
  127. <td>` + item.ModifyTime + `</td>
  128. </tr>`
  129. return trHtml
  130. } else {
  131. return ""
  132. }
  133. }