新增监控检测服务

services/data_manage/edb_info.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"hongze/hongze_task/models/data_manage"
 	"hongze/hongze_task/utils"
+	"rdluck_tools/http"
 	"time"
 )
 
@@ -22,7 +23,7 @@ func RefreshDataFromThs() (err error) {
 	pars = append(pars, utils.DATA_SOURCE_THS)
 	items, err := data_manage.GetEdbInfoByCondition(condition, pars)
 	if err != nil {
-		return errors.New("GetEdbInfoByCondition:"+err.Error())
+		return errors.New("GetEdbInfoByCondition:" + err.Error())
 	}
 
 	for _, v := range items {
@@ -30,16 +31,16 @@ func RefreshDataFromThs() (err error) {
 		endDate := time.Now().Format(utils.FormatDate)
 		err = SyncEdbDataByThs(int64(v.EdbInfoId), v.EdbCode, startDate, endDate)
 		if err != nil {
-			return errors.New("SyncEdbDataByThs:"+err.Error())
+			return errors.New("SyncEdbDataByThs:" + err.Error())
 		}
 		minDate, maxDate, err := data_manage.GetEdbDataThsMaxOrMinDate(v.EdbInfoId)
 		if err != nil {
-			return errors.New("GetEdbDataThsMaxOrMinDate:"+err.Error())
+			return errors.New("GetEdbDataThsMaxOrMinDate:" + err.Error())
 		}
 		fmt.Println("minDate:" + minDate + ";maxDate:" + maxDate)
 		err = data_manage.ModifyEdbDataInfoDate(v.EdbInfoId, maxDate)
 		if err != nil {
-			return errors.New("ModifyEdbDataInfoDate:"+err.Error())
+			return errors.New("ModifyEdbDataInfoDate:" + err.Error())
 		}
 	}
 	return err
@@ -82,3 +83,14 @@ func RefreshDataFromWind() (err error) {
 
 	return err
 }
+
+func CheckDataInterface() (err error) {
+	checkUrl := utils.Hz_Data_Url + `hz_server`
+	fmt.Println("checkUrl", checkUrl)
+	body, err := http.Get(checkUrl)
+	fmt.Println("CheckDataInterface:body:", string(body))
+	if string(body) != "1" {
+		go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "CheckDataInterface ErrMsg:"+string(body), utils.EmailSendToUsers)
+	}
+	return
+}

services/task.go

@@ -10,7 +10,6 @@ import (
 
 func Task() {
 	fmt.Println("task start")
-
 	//如果是生产环境，才需要走这些任务
 	if utils.RunMode == "release"{
 		releaseTask()
@@ -88,6 +87,9 @@ func releaseTask(){
 	//刷新数据
 	refreshData := toolbox.NewTask("refreshData", "0 0 18 * * *", RefreshData)
 	toolbox.AddTask("refreshData", refreshData)
+
+	checkDataInterface := toolbox.NewTask("checkDataInterface", "0 */30 * * * * ", data_manage.CheckDataInterface)
+	toolbox.AddTask("checkDataInterface", checkDataInterface)
 }
 
 func TaskTest(){