hongze_task/services/data/edb_info_notice.go

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 ""
	}
}