新增初始化指标更新状态

models/data_manage/edb_info.go

@@ -147,3 +147,11 @@ func GetQuarterEdbInfo() (item []*EdbInfo, err error) {
 	_, err = o.Raw(sql).QueryRows(&item)
 	return
 }
+
+func ResetEdbInfoIsUpdate() (err error) {
+	o := orm.NewOrm()
+	o.Using("data")
+	sql := ` UPDATE edb_info SET is_update=1  `
+	_, err = o.Raw(sql).Exec()
+	return
+}

services/data/edb_info.go

@@ -632,3 +632,8 @@ func RefreshDataFromGl(wg *sync.WaitGroup) (err error) {
 	}
 	return err
 }
+
+func ResetEdbInfoIsUpdate(cont context.Context) (err error) {
+	go data_manage.ResetEdbInfoIsUpdate()
+	return nil
+}

services/task.go

@@ -13,7 +13,6 @@ import (
 	"strings"
 	"sync"
 	"time"
-
 )
 
 func Task() {
@@ -70,12 +69,6 @@ func Task() {
 	fmt.Println("task end")
 }
 
-func Task123() {
-	fmt.Println("start")
-	data.FixEdbInfoCalculateMapping()
-	fmt.Println("end")
-}
-
 //生产环境需要走的任务
 func releaseTask() {
 
@@ -143,6 +136,10 @@ func releaseTask() {
 
 	checkPbDataInterface := task.NewTask("checkPbDataInterface", "0 */5 * * * * ", data.CheckPbDataInterface)
 	task.AddTask("checkPbDataInterface", checkPbDataInterface)
+
+	//初始化指标更新状态
+	resetEdbInfoIsUpdate := task.NewTask("resetEdbInfoIsUpdate", "0 0 0 * * *", data.ResetEdbInfoIsUpdate)
+	task.AddTask("resetEdbInfoIsUpdate", resetEdbInfoIsUpdate)
 }
 
 func TaskTest() {