钢联指标刷新

logic/base_edb_info.go

@@ -25,6 +25,8 @@ func RefreshBaseEdbInfo(edbInfo *models.EdbInfo, startDate string) (isHandling b
 		err = models.RefreshEdbDataFromSci(edbInfo.EdbInfoId, edbInfo.EdbCode, startDate)
 	case utils.DATA_SOURCE_BAIINFO:
 		err = models.RefreshEdbDataFromBaiinfo(edbInfo.EdbInfoId, edbInfo.EdbCode, startDate)
+	case utils.DATA_SOURCE_MYSTEEL_CHEMICAL:
+		err = models.RefreshEdbDataFromMysteelChemical(edbInfo.EdbInfoId, edbInfo.EdbCode, startDate)
 	default:
 		return
 	}

services/base_from_mysteel_chemical.go

@@ -1,7 +1,9 @@
 package services
 
 import (
+	"eta/eta_index_lib/logic"
 	"eta/eta_index_lib/models"
+	"eta/eta_index_lib/services/alarm_msg"
 	"eta/eta_index_lib/utils"
 	"fmt"
 	"strings"
@@ -154,5 +156,26 @@ func handleIndex(indexItem *models.HandleMysteelIndex) (err error) {
 			fmt.Println("dataObj.Add() Err:" + err.Error())
 		}
 	}
+
+	// 同步刷新图库钢联的指标
+	go func() {
+		var indexErr error
+		defer func() {
+			if indexErr != nil {
+				tips := fmt.Sprintf("钢联数据刷新-ETA指标刷新异常, 指标编码: %s, err: %s", indexObj.IndexCode, indexErr.Error())
+				alarm_msg.SendAlarmMsg(tips, 3)
+			}
+		}()
+
+		edbInfo, e := models.GetEdbInfoByEdbCode(utils.DATA_SOURCE_MYSTEEL_CHEMICAL, indexObj.IndexCode)
+		if e != nil && e.Error() != utils.ErrNoRow() {
+			indexErr = e
+			return
+		}
+		if edbInfo != nil {
+			logic.RefreshBaseEdbInfo(edbInfo, ``)
+		}
+	}()
+
 	return
 }