fix:新增检测同花顺数据服务校验任务

打开彭博、路透服务检测

services/data/edb_info.go

@@ -283,7 +283,6 @@ func RefreshDataFromPbFinance(wg *sync.WaitGroup) (err error) {
 }
 
 func CheckPbDataInterface(cont context.Context) (err error) {
-	return
 	go func() {
 		checkUrl := utils.Hz_Data_PB_Url + `hz_server`
 		body, err := http.Get(checkUrl)
@@ -305,7 +304,6 @@ func CheckPbDataInterface(cont context.Context) (err error) {
 
 // CheckLtDataInterface 检测路透数据服务器
 func CheckLtDataInterface(cont context.Context) (err error) {
-	return
 	go func() {
 		checkUrl := utils.Hz_Data_LT_Url + `hz_server`
 		body, err := http.Get(checkUrl)
@@ -325,6 +323,27 @@ func CheckLtDataInterface(cont context.Context) (err error) {
 	return
 }
 
+// CheckThsDataInterface 检测同花顺数据服务器
+func CheckThsDataInterface(cont context.Context) (err error) {
+	go func() {
+		checkUrl := utils.Hz_Server_Data_Url + `hz_server`
+		body, err := http.Get(checkUrl)
+		if err != nil {
+			//go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"检测数据接口：失败提醒", "CheckPbDataInterface 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+"】"+"检测数据接口：失败提醒", "CheckPbDataInterface ErrMsg:"+string(body), utils.EmailSendToUsers)
+				msg := "检测同花顺数据服务器失败：CheckPbDataInterface ErrMsg:" + string(body)
+				go alarm_msg.SendAlarmMsg(msg, 3)
+			}
+		}
+	}()
+	return
+}
+
 ////刷新所有计算指标
 //func RefreshDataFromCalculateAll() (err error) {
 //	defer func() {

services/task.go

@@ -113,12 +113,10 @@ func Task() {
 	syncSubStatus := task.NewTask("syncSubStatus", "0 0 2 * * *", SyncSubStatus)
 	task.AddTask("syncSubStatus", syncSubStatus)
 
-
 	//删除日志 report_save_log，ppt_v2_save_log，保留一个月的
 	deleteLog := task.NewTask("syncSubStatus", "0 0 2 1 * *", DeleteLog)
 	task.AddTask("deleteLog", deleteLog)
 
-
 	task.StartTask()
 
 	fmt.Println("task end")
@@ -196,6 +194,10 @@ func releaseTask() {
 	checkWindDataInterface := task.NewTask("checkWindDataInterface", "0 */2 * * * * ", data.CheckWindDataInterface)
 	task.AddTask("checkWindDataInterface", checkWindDataInterface)
 
+	// 检测同花顺数据服务器
+	checkThsDataInterface := task.NewTask("checkThsDataInterface", "0 */2 * * * * ", data.CheckThsDataInterface)
+	task.AddTask("checkThsDataInterface", checkThsDataInterface)
+
 	//初始化指标更新状态
 	resetEdbInfoIsUpdate := task.NewTask("resetEdbInfoIsUpdate", "0 0 0 * * *", data.ResetEdbInfoIsUpdate)
 	task.AddTask("resetEdbInfoIsUpdate", resetEdbInfoIsUpdate)