新增万得服务检测接口

services/data_manage/edb_info.go

@@ -144,7 +144,7 @@ func RefreshDataFromPb() (err error) {
 	return err
 }
 
-func CheckDataInterface() (err error) {
+func CheckDataInterface(cont context.Context) (err error) {
 	go func() {
 		checkUrl := utils.Hz_Data_Url + `hz_server`
 		body, err := http.Get(checkUrl)

services/task.go

@@ -12,7 +12,7 @@ import (
 func Task() {
 	fmt.Println("task start")
 	//如果是生产环境，才需要走这些任务
-	if utils.RunMode == "release"{
+	if utils.RunMode == "release" {
 		releaseTask()
 	}
 	//每日定时合同处理
@@ -39,7 +39,6 @@ func Task() {
 	//deleteReportSaveLog := task.NewTask("deleteReportSaveLog", "0 30 08 * * *", DeleteReportSaveLog)
 	//task.AddTask("deleteReportSaveLog", deleteReportSaveLog)
 
-
 	// 存量客户数据统计
 	stackCompanyStatistic := task.NewTask("stackCompanyStatistic", "0 35 0 * * *", StackCompanyStatistic)
 	task.AddTask("存量客户数据统计", stackCompanyStatistic)
@@ -54,7 +53,7 @@ func Task() {
 }
 
 //生产环境需要走的任务
-func releaseTask(){
+func releaseTask() {
 
 	//隆众指标获取
 	getLzProductList := task.NewTask("getLzProductList", "0 0 11-19/1 * * * ", GetLzProductList)
@@ -93,11 +92,14 @@ func releaseTask(){
 	refreshCalculateData := task.NewTask("refreshCalculateData", "0 10 18 * * *", RefreshCalculateData)
 	task.AddTask("refreshCalculateData", refreshCalculateData)
 
+	checkDataInterface := task.NewTask("checkDataInterface", "0 */2 * * * * ", data_manage.CheckDataInterface)
+	task.AddTask("checkDataInterface", checkDataInterface)
+
 	checkPbDataInterface := task.NewTask("checkPbDataInterface", "0 */5 * * * * ", data_manage.CheckPbDataInterface)
 	task.AddTask("checkPbDataInterface", checkPbDataInterface)
 }
 
-func TaskTest(){
+func TaskTest() {
 	fmt.Println("The task is start")
 	//companyReportPermissionClose := task.NewTask("companyTryOut", "0 5 0 * * *", CompanyReportPermissionClose)
 	companyReportPermissionClose := task.NewTask("companyReportPermissionClose", "0/30 * * * * *", CompanyReportPermissionClose)
@@ -134,7 +136,7 @@ func OneMinute(cont context.Context) (err error) {
 	return
 }
 
-func RefreshData(cont context.Context) (err error){
+func RefreshData(cont context.Context) (err error) {
 	//wind
 	go data_manage.RefreshDataFromWind()
 	//同花顺
@@ -144,8 +146,8 @@ func RefreshData(cont context.Context) (err error){
 	return
 }
 
-func RefreshCalculateData(cont context.Context) (err error){
+func RefreshCalculateData(cont context.Context) (err error) {
 	//计算指标
 	go data_manage.RefreshDataFromCalculate()
 	return
-}
+}