浏览代码

新增初始化刷新Edb数据功能并调用

在eta_bridge服务中添加了InitRefreshEdb函数,用于初始化刷新Edb明细数据。该函数包括打印日志、错误处理和解锁等逻辑。在task_gn.go中,将GnTask函数中的SyncGnIndex调用替换为InitRefreshEdb调用。此修改旨在优化Edb数据的刷新流程,提高数据同步的效率和稳定性。
Roc 5 月之前
父节点
当前提交
387a6c6a06
共有 2 个文件被更改,包括 3 次插入2 次删除
  1. 1 1
      services/eta_bridge/gn.go
  2. 2 1
      services/task_gn.go

+ 1 - 1
services/eta_bridge/gn.go

@@ -806,7 +806,7 @@ func InitRefreshEdb(cont context.Context) (err error) {
 	for _, v := range CurrEdbInfoMap {
 		count--
 		fmt.Println("剩余:", count, "条数据待初始化")
-		fmt.Println(data.RefreshEdbData(v.EdbInfoId, v.Source, v.SubSource, v.EdbCode, v.EndDate.Format(utils.FormatDate)))
+		fmt.Println(data.RefreshEdbData(v.EdbInfoId, v.Source, v.SubSource, v.EdbCode, "1899-01-01"))
 	}
 	return
 }

+ 2 - 1
services/task_gn.go

@@ -3,13 +3,14 @@ package services
 import (
 	"eta_gn/eta_task/services/eta_bridge"
 	"eta_gn/eta_task/utils"
+	"fmt"
 	"github.com/beego/beego/v2/task"
 )
 
 func GnTask() {
 	// 初始化一次
 	//fmt.Println(eta_bridge.SyncGnIndex(nil))
-	//fmt.Println(eta_bridge.InitRefreshEdb(nil))
+	fmt.Println(eta_bridge.InitRefreshEdb(nil))
 
 	// 指标相关