加息概率测试

services/meeting_probabilities.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"encoding/json"
 	"eta/eta_crawler/models"
+	"eta/eta_crawler/services/alarm_msg"
 	"eta/eta_crawler/utils"
 	"fmt"
 	"github.com/xuri/excelize/v2"
@@ -11,6 +12,14 @@ import (
 )
 
 func RefreshMeetingProbabilities(cont context.Context) (err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println("RefreshMeetingProbabilities Err:" + err.Error())
+			msg := "失败提醒" + "RefreshMeetingProbabilities ErrMsg:" + err.Error()
+			go alarm_msg.SendAlarmMsg(msg, 3)
+			//go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "RefreshDataFromCoalJsm ErrMsg:"+err.Error(), utils.EmailSendToUsers)
+		}
+	}()
 	templatePath := "/home/code/python/meeting_probabilities/file/%s.xlsx"
 	templatePath = fmt.Sprintf(templatePath, time.Now().Format(utils.FormatDate))
 	fmt.Println(templatePath)

services/task.go

@@ -20,7 +20,7 @@ func Task() {
 	refreshData := task.NewTask("refreshData", "0 0,30 16-18 * * *", RefreshData)
 	refreshEic := task.NewTask("RefreshEic", "0 0 2,6 * * *", RefreshEic)
 	refreshCoal := task.NewTask("RefreshCoal", "0 0,30 16-23 * * *", RefreshCoal)
-	refreshMeeting := task.NewTask("RefreshMeeting", "0 50 20 * * *", RefreshMeetingProbabilities)
+	refreshMeeting := task.NewTask("RefreshMeeting", "0 55 20 * * *", RefreshMeetingProbabilities)
 	refreshVisitors := task.NewTask("RefreshChangesVisitorsCovid", "0 30 2-22/10 * * *", RefreshChangesVisitorsCovid)
 	syncEiaSteoData := task.NewTask("SyncEiaSteoData", "0 0 22 * * *", SyncEiaSteoData)
 	syncYearComTrade := task.NewTask("SyncYearComTrade", "0 0 3 1 1 *", SyncYearComTrade)                // 每年一月一号同步