tuoling805 1 year ago
parent
commit
54f5f813c6
2 changed files with 15 additions and 4 deletions
  1. 11 3
      services/init_base_index.go
  2. 4 1
      services/task.go

+ 11 - 3
services/init_base_index.go

@@ -11,6 +11,14 @@ import (
 
 // 初始化基础指标数据
 func InitBaseIndexData() {
+	var err error
+
+	defer func() {
+		if err != nil {
+			fmt.Println("InitBaseIndexData Err:" + err.Error())
+		}
+	}()
+
 	//读取excel
 	path, err := filepath.Abs(os.Args[0])
 	if err != nil {
@@ -18,7 +26,7 @@ func InitBaseIndexData() {
 	}
 
 	dir := filepath.Dir(path)
-	fmt.Println(dir)
+	fmt.Println("dir:" + dir)
 	dataPath := dir + "/docs/逸诺初始化数据示例.xlsx"
 	f, err := excelize.OpenFile(dataPath)
 	if err != nil {
@@ -134,11 +142,11 @@ func InitBaseIndexData() {
 						utils.FileLog.Info("初始化指标失败:" + resp.Msg + ";" + resp.ErrMsg)
 						return
 					}
+
+					fmt.Println("add index success:" + indexCode)
 				}
 			}
 		}
-
-		fmt.Println()
 	}
 }
 

+ 4 - 1
services/task.go

@@ -3,6 +3,7 @@ package services
 import (
 	"fmt"
 	"hongze/hz_eta_data/utils"
+	"time"
 )
 
 var IndexSourceMap map[string]int
@@ -20,7 +21,9 @@ func Task() {
 	IndexSourceMap = make(map[string]int)
 	IndexSourceMap["ths"] = utils.DATA_SOURCE_THS
 	IndexSourceMap["wind"] = utils.DATA_SOURCE_WIND
-
+	time.Sleep(3 * time.Second)
+	fmt.Println("start InitBaseIndexData")
 	InitBaseIndexData()
+	fmt.Println("end InitBaseIndexData")
 	fmt.Println("task end")
 }