浏览代码

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

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

+ 34 - 0
services/eta_bridge/gn.go

@@ -776,3 +776,37 @@ func SyncGnUser(cont context.Context) (err error) {
 	fmt.Println("结束同步OA用户")
 	return
 }
+
+// InitRefreshEdb
+// @Description: 初始化明细数据指标
+// @param cont
+// @return err
+func InitRefreshEdb(cont context.Context) (err error) {
+	fmt.Println("准备更新指标明细数据")
+	lockSyncGnIndex.Lock()
+	errMsgList := make([]string, 0)
+	fmt.Println("开始更新指标明细数据")
+
+	defer func() {
+		fmt.Println("初始化指标明细数据结束")
+		if err != nil {
+			tips := "SyncGnIndex-初始化指标明细数据结束到ETA失败, ErrMsg:\n" + err.Error()
+			utils.FileLog.Info(tips)
+		}
+		if len(errMsgList) > 0 {
+			tips := "SyncGnIndex-初始化指标明细数据结束到ETA失败, ErrMsg:\n" + strings.Join(errMsgList, "\n")
+			utils.FileLog.Info(tips)
+		}
+		lockSyncGnIndex.Unlock()
+	}()
+
+	initCurrEdbInfoMap()
+
+	count := len(CurrEdbInfoMap)
+	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)))
+	}
+	return
+}

+ 2 - 1
services/task_gn.go

@@ -9,7 +9,8 @@ import (
 
 func GnTask() {
 	// 初始化一次
-	fmt.Println(eta_bridge.SyncGnIndex(nil))
+	//fmt.Println(eta_bridge.SyncGnIndex(nil))
+	fmt.Println(eta_bridge.InitRefreshEdb(nil))
 
 	// 指标相关