优化同花顺期货刷新

services/data/future_good/future_good_edb_info.go

@@ -15,16 +15,15 @@ func RefreshFutureGoodDataFromThs() (err error) {
 	errMsgList := make([]string, 0)
 	defer func() {
 		if err != nil {
-			fmt.Println("RefreshDataFromThs Err:" + err.Error())
-			//go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "RefreshDataFromThs ErrMsg:"+err.Error(), utils.EmailSendToUsers)
-			go alarm_msg.SendAlarmMsg("RefreshDataFromThs ErrMsg:"+err.Error(), 3)
+			tips := fmt.Sprintf("RefreshFutureGoodDataFromThs Err: %v", err)
+			//fmt.Println(tips)
+			utils.FileLog.Info(tips)
+			go alarm_msg.SendAlarmMsg(tips, 3)
 		}
 		if len(errMsgList) > 0 {
-			go alarm_msg.SendAlarmMsg("部分商品数据刷新失败 ErrMsg:"+strings.Join(errMsgList, "/n"), 3)
-			//fmt.Println("总共",len(errMsgList),"条商品数据刷新失败:")
-			//for _,v:=range errMsgList{
-			//	fmt.Println(v)
-			//}
+			tips := fmt.Sprintf("RefreshFutureGoodDataFromThs部分商品刷新失败, ErrMsg: %s", strings.Join(errMsgList, "\n"))
+			utils.FileLog.Info(tips)
+			go alarm_msg.SendAlarmMsg(tips, 3)
 		}
 	}()
 	var condition string
@@ -43,7 +42,13 @@ func RefreshFutureGoodDataFromThs() (err error) {
 
 	lenList := len(list)
 	fmt.Println("总共", lenList, "条")
+
+	// 简单限制一下请求速度, 同花顺EDB函数限制为5/s
+	ticker := time.NewTicker(250 * time.Millisecond)
+	defer ticker.Stop()
 	for k, v := range list {
+		<-ticker.C
+
 		fmt.Println("剩余", lenList-k-1, "条")
 		fmt.Println("编码:", v.FutureGoodEdbCode, ";名称:", v.FutureGoodEdbName)
 		var startDateTime time.Time