Merge branch 'feature/eta1.2.2_edb_source' of eta_server/eta_task into master

services/data/base_edb_lib.go

@@ -117,6 +117,20 @@ func postRefreshEdbData(param map[string]interface{}, urlStr string) (resp *mode
 	return resp, nil
 }
 
+// SetEdbSourceStat 指标终端更新情况定时汇总
+func SetEdbSourceStat() (resp *models.BaseResponse, err error) {
+	postUrl := utils.EDB_LIB_URL + "edb_stat/source_update"
+	result, err := HttpPost(postUrl, "", "application/json")
+	if err != nil {
+		return
+	}
+	err = json.Unmarshal(result, &resp)
+	if err != nil {
+		return
+	}
+	return resp, nil
+}
+
 func HttpPost(url, postData string, params ...string) ([]byte, error) {
 	body := ioutil.NopCloser(strings.NewReader(postData))
 	client := &http.Client{}

services/data_stat/edb_info_stat.go

@@ -0,0 +1,28 @@
+package data_stat
+
+import (
+	"context"
+	"errors"
+	"eta/eta_task/services/data"
+	"eta/eta_task/utils"
+	"time"
+)
+
+// SetEdbSourceStatTask 设置数据源指标更新情况定时任务
+func SetEdbSourceStatTask(cont context.Context) (err error) {
+	now := time.Now().Format(utils.FormatDate)
+	if now <= "2023-12-04" { //上线之后隔天再执行
+		return
+	}
+	utils.FileLog.Info("SetEdbSourceStatTask 开始")
+	resp, err := data.SetEdbSourceStat()
+	if err != nil {
+		utils.FileLog.Info("SetEdbSourceStatTask 定时更新出错 Err:" + err.Error())
+		return errors.New("SetEdbSourceStat Err:" + err.Error())
+	}
+	if resp.Ret != 200 {
+		return errors.New("SetEdbSourceStat Err:" + resp.Msg + ";ErrMsg:" + resp.ErrMsg)
+	}
+	utils.FileLog.Info("SetEdbSourceStatTask 结束")
+	return
+}

services/task.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"eta/eta_task/services/data"
 	"eta/eta_task/services/data/future_good"
+	"eta/eta_task/services/data_stat"
 	"eta/eta_task/utils"
 	"fmt"
 	"github.com/beego/beego/v2/task"
@@ -21,6 +22,9 @@ func Task() {
 	// 定时发布智能研报
 	publishSmartReport := task.NewTask("publishSmartReport", "0 */1 * * * *", PublishSmartReport)
 	task.AddTask("定时发布智能研报", publishSmartReport)
+	// 定时汇总数据源终端指标更新情况
+	setEdbSourceStatTask := task.NewTask("setEdbSourceStatTask", "0 20 19,23 * * *", data_stat.SetEdbSourceStatTask)
+	task.AddTask("数据源统计表", setEdbSourceStatTask)
 
 	task.StartTask()
 	fmt.Println("task end")