修改计算指标

models/data_manage/edb_info.go

@@ -88,6 +88,8 @@ func GetEdbInfoMaxAndMinInfo(source int, edbCode string) (item *EdbInfoMaxAndMin
 		tableName = `edb_data_wind`
 	} else if source == utils.DATA_SOURCE_PB {
 		tableName = `edb_data_pb`
+	} else if source == utils.DATA_SOURCE_CALCULATE {
+		tableName = "edb_data_calculate"
 	} else {
 		errors.New("无效的渠道:" + strconv.Itoa(source))
 		return
@@ -147,4 +149,4 @@ func GetEdbInfoById(edbInfoId int) (item *EdbInfo, err error) {
 	sql := ` SELECT * FROM edb_info WHERE edb_info_id=? `
 	err = o.Raw(sql, edbInfoId).QueryRow(&item)
 	return
-}
+}

services/data_manage/data_calculate.go

@@ -17,6 +17,7 @@ func RefreshCalculate(edbInfoIdArr []*data_manage.EdbInfo, edbInfoId int, edbCod
 	defer func() {
 		if err != nil {
 			utils.FileLog.Info("Calculate Err:%s" + err.Error())
+			go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "RefreshCalculate ErrMsg:"+err.Error(), utils.EmailSendToUsers)
 		}
 	}()
 	saveDataMap := make(map[string]map[int]float64)

services/data_manage/edb_info.go

@@ -1,13 +1,13 @@
 package data_manage
 
 import (
+	"context"
 	"errors"
 	"fmt"
 	"hongze/hongze_task/models/data_manage"
 	"hongze/hongze_task/utils"
 	"rdluck_tools/http"
 	"time"
-	"context"
 )
 
 //刷新同花顺数据

services/task.go

@@ -108,12 +108,6 @@ func TaskTest() {
 	fmt.Println("The task is end")
 }
 
-func Task123() {
-	fmt.Println("start")
-	fmt.Println("end")
-	return
-}
-
 func SendEmail(cont context.Context) (err error) {
 	//报告历史访问次数
 	go ReportViewTimes()