fix:wind服务监控

services/data/edb_info.go

@@ -282,47 +282,6 @@ func RefreshDataFromPbFinance(wg *sync.WaitGroup) (err error) {
 	return err
 }
 
-func CheckDataInterface(cont context.Context) (err error) {
-	go func() {
-		//杭州办公室服务器
-		{
-			checkUrl := utils.Hz_Data_Url + `hz_server`
-			body, err := http.Get(checkUrl)
-			if err != nil {
-				//go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"检测数据接口：失败提醒", "CheckDataInterface ErrMsg:"+err.Error(), utils.EmailSendToUsers)
-				msg := "检测wind数据服务器失败：CheckDataInterface ErrMsg:" + err.Error()
-				go alarm_msg.SendAlarmMsg(msg, 3)
-			} else {
-				result := string(body)
-				if result != "1" {
-					//go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"检测数据接口：失败提醒", "CheckDataInterface ErrMsg:"+string(body), utils.EmailSendToUsers)
-					msg := "检测wind数据服务器失败：CheckDataInterface ErrMsg:" + string(body)
-					go alarm_msg.SendAlarmMsg(msg, 3)
-				}
-			}
-		}
-
-		//阿里服务器监听
-		{
-			checkUrl2 := utils.Hz_Server_Data_Url + `hz_server`
-			body, err := http.Get(checkUrl2)
-			if err != nil {
-				//go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"检测服务器数据接口：失败提醒", "CheckDataInterface ErrMsg:"+err.Error(), utils.EmailSendToUsers)
-				msg := "检测同花顺数据-阿里云服务器失败：CheckPbDataInterface ErrMsg:" + err.Error()
-				go alarm_msg.SendAlarmMsg(msg, 3)
-			} else {
-				result := string(body)
-				if result != "1" {
-					//go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"检测服务器数据接口：失败提醒", "CheckDataInterface ErrMsg:"+string(body), utils.EmailSendToUsers)
-					msg := "检测同花顺数据-阿里云服务器失败：CheckPbDataInterface ErrMsg:" + err.Error()
-					go alarm_msg.SendAlarmMsg(msg, 3)
-				}
-			}
-		}
-	}()
-	return
-}
-
 func CheckPbDataInterface(cont context.Context) (err error) {
 	go func() {
 		checkUrl := utils.Hz_Data_PB_Url + `hz_server`

services/task.go

@@ -172,9 +172,6 @@ func releaseTask() {
 	syncThsWxGroupEveryDay := task.NewTask("syncThsWxGroupEveryDay", "0 1 4 * * * ", SyncWxGroupEveryDay)
 	task.AddTask("定时往同花顺同步微信群的截止日期", syncThsWxGroupEveryDay)
 
-	checkDataInterface := task.NewTask("checkDataInterface", "0 */2 * * * * ", data.CheckDataInterface)
-	task.AddTask("checkDataInterface", checkDataInterface)
-
 	checkPbDataInterface := task.NewTask("checkPbDataInterface", "0 */2 * * * * ", data.CheckPbDataInterface)
 	task.AddTask("checkPbDataInterface", checkPbDataInterface)
 
@@ -276,7 +273,6 @@ func RefreshTradeData(cont context.Context) (err error) {
 	return
 }
 
-
 // RefreshEicData 刷新欧洲天然气数据
 func RefreshEicData(cont context.Context) (err error) {
 	wg := sync.WaitGroup{}