123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138 |
- package data
- import (
- "errors"
- "fmt"
- "hongze/hongze_task/models/data_manage"
- "hongze/hongze_task/utils"
- "time"
- )
- //指标更新通知
- func RefreshNotice() (err error) {
- defer func() {
- if err != nil {
- fmt.Println("RefreshNotice Err:" + err.Error())
- go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "RefreshNotice ErrMsg:"+err.Error(), utils.EmailSendToUsers)
- }
- }()
- var condition string
- var pars []interface{}
- items, err := data_manage.GetEdbInfoByCondition(condition, pars, 1)
- if err != nil {
- return errors.New("GetEdbInfoByCondition:" + err.Error())
- }
- //日度
- dayDiv := `<div>日度指标,超过3天未更新:</div>`
- dayTable := `<table border="1" style="border-collapse: collapse;">
- <thead>
- <tr>
- <td>指标编码</td>
- <td>指标名称</td>
- <td>指标来源</td>
- <td>频度</td>
- <td>指标数据最后日期</td>
- <td>指标数据更新日期</td>
- </tr>
- </thead>`
- dayTableBody := `<tbody>`
- dayDate := time.Now().AddDate(0, 0, -3)
- for _, v := range items {
- if v.Frequency == "日度" && v.EndDate.Before(dayDate) {
- dayTableBody += getTableTr(v)
- }
- }
- dayTable += dayTableBody
- dayTable += ` </tbody></table>`
- noticeSendBody := dayDiv + dayTable
- noticeSendBody += `<br/>`
- //周度
- weekDiv := `<div>周度指标,超过7天未更新:</div>`
- weekTable := `<table border="1" style="border-collapse: collapse;">
- <thead>
- <tr>
- <td>指标编码</td>
- <td>指标名称</td>
- <td>指标来源</td>
- <td>频度</td>
- <td>指标数据最后日期</td>
- <td>指标数据更新日期</td>
- </tr>
- </thead>`
- weekTableBody := `<tbody>`
- weekDate := time.Now().AddDate(0, 0, -7)
- for _, v := range items {
- if v.Frequency == "周度" && v.EndDate.Before(weekDate) {
- weekTableBody += getTableTr(v)
- }
- }
- weekTable += weekTableBody
- weekTable += ` </tbody></table>`
- noticeSendBody += weekDiv + weekTable
- noticeSendBody += `<br/>`
- //月度
- monthDiv := `<div>月度指标,超过一个月未更新:</div>`
- monthTable := `<table border="1" style="border-collapse: collapse;">
- <thead>
- <tr>
- <td>指标编码</td>
- <td>指标名称</td>
- <td>指标来源</td>
- <td>频度</td>
- <td>指标数据最后日期</td>
- <td>指标数据更新日期</td>
- </tr>
- </thead>`
- monthTableBody := `<tbody>`
- monthDate := time.Now().AddDate(0, -1, 0)
- for _, v := range items {
- if v.Frequency == "月度" && v.EndDate.Before(monthDate) {
- monthTableBody += getTableTr(v)
- }
- }
- monthTable += monthTableBody
- monthTable += ` </tbody></table>`
- noticeSendBody += monthDiv + monthTable
- noticeSendBody += `<br/>`
- //所有指标
- allDiv := `<hr style="color: red">`
- allDiv = `<div>当前所有指标,按数据日期升序排列:</div>`
- allTable := `<table border="1" style="border-collapse: collapse;">
- <thead>
- <tr>
- <td>指标编码</td>
- <td>指标名称</td>
- <td>指标来源</td>
- <td>频度</td>
- <td>指标数据最后日期</td>
- <td>指标数据更新日期</td>
- </tr>
- </thead>`
- allTableBody := `<tbody>`
- for _, v := range items {
- allTableBody += getTableTr(v)
- }
- allTable += allTableBody
- allTable += ` </tbody></table>`
- noticeSendBody += allDiv + allTable
- utils.SendEmailByHongze("指标更新情况通知", noticeSendBody, utils.RefreshEdbInfoEmailSendToUsers, "", "")
- return
- }
- func getTableTr(item *data_manage.EdbInfoList) string {
- if item != nil {
- trHtml := ` <tr>
- <td>` + item.EdbCode + `</td>
- <td>` + item.EdbName + `</td>
- <td>` + item.SourceName + `</td>
- <td>` + item.Frequency + `</td>
- <td>` + item.EndDate.Format(utils.FormatDate) + `</td>
- <td>` + item.ModifyTime + `</td>
- </tr>`
- return trHtml
- } else {
- return ""
- }
- }
|