Browse Source

优化 eta_bridge 服务中的指标同步逻辑

- 移除了 SyncGnIndex 函数中的冗余代码
- 添加了同步指标的起始页信息的打印
- 在任务调度器中注释了 GnTask 函数的指标同步部分
Roc 5 months ago
parent
commit
2403a93ce3
2 changed files with 2 additions and 62 deletions
  1. 2 61
      services/eta_bridge/gn.go
  2. 0 1
      services/task_gn.go

+ 2 - 61
services/eta_bridge/gn.go

@@ -40,67 +40,7 @@ type CurrClassify struct {
 // @param cont context.Context
 // @return err error
 func SyncGnIndex(cont context.Context) (err error) {
-	//by, _ := json.Marshal(CurrLevelParentClassifyMap)
-	//utils.FileLog.Info(string(by))
-	//
-	//list := make([]IndexInfo, 0)
-	//list = []IndexInfo{
-	//	{
-	//		ClassifyNameOne:   "宏观经济",
-	//		ClassifyNameTwo:   "美国",
-	//		ClassifyNameThree: "房地产",
-	//	},
-	//	{
-	//		ClassifyNameOne:   "宏观经济",
-	//		ClassifyNameTwo:   "美国",
-	//		ClassifyNameThree: "土地销售面积",
-	//	},
-	//	{
-	//		ClassifyNameOne:   "宏观经济",
-	//		ClassifyNameTwo:   "美国",
-	//		ClassifyNameThree: "GDP",
-	//	},
-	//	{
-	//		ClassifyNameOne:   "宏观经济",
-	//		ClassifyNameTwo:   "中国",
-	//		ClassifyNameThree: "房地产",
-	//	},
-	//	{
-	//		ClassifyNameOne:   "宏观经济",
-	//		ClassifyNameTwo:   "中国",
-	//		ClassifyNameThree: "土地销售面积",
-	//	},
-	//	{
-	//		ClassifyNameOne:   "宏观经济",
-	//		ClassifyNameTwo:   "中国",
-	//		ClassifyNameThree: "GDP",
-	//	},
-	//	{
-	//		ClassifyNameOne:   "宏观经济",
-	//		ClassifyNameTwo:   "韩国",
-	//		ClassifyNameThree: "房地产",
-	//	},
-	//	{
-	//		ClassifyNameOne:   "宏观经济",
-	//		ClassifyNameTwo:   "韩国",
-	//		ClassifyNameThree: "土地销售面积",
-	//	},
-	//	{
-	//		ClassifyNameOne:   "宏观经济",
-	//		ClassifyNameTwo:   "韩国",
-	//		ClassifyNameThree: "GDP",
-	//	},
-	//	{
-	//		ClassifyNameOne:   "宏观经济",
-	//		ClassifyNameTwo:   "中国",
-	//		ClassifyNameThree: "GDP",
-	//	},
-	//}
-	//for _, v := range list {
-	//	fmt.Println(handleClassify(v))
-	//}
-	//return
-
+	fmt.Println("开始同步指标")
 	lockSyncGnIndex.Lock()
 	errMsgList := make([]string, 0)
 
@@ -234,6 +174,7 @@ type BridgeGnIndexParams struct {
 // @return err error
 // @return errMsgList []string
 func syncGnIndex(currIndex, pageSize int, baseLastUpdateTimeStr string) (err error, errMsgList []string) {
+	fmt.Println("开始第", currIndex, "页的更新")
 	errMsgList = make([]string, 0)
 
 	lastUpdateTimeStr := baseLastUpdateTimeStr

+ 0 - 1
services/task_gn.go

@@ -7,7 +7,6 @@ import (
 )
 
 func GnTask() {
-
 	// 指标相关
 	// 每小时同步一次指标列表
 	syncIndexTime := utils.SyncIndexTime