|
|
@@ -246,6 +246,17 @@ func SyncJiaYueNewIndex(item models.BridgeJiaYueIndexAndData, menus []models.Bri
|
|
|
return
|
|
|
}
|
|
|
|
|
|
+ // 查询指标是否已存在, 存在则忽略
|
|
|
+ exist, e := models.GetEdbInfoByEdbCode(sourceId, indexCode)
|
|
|
+ if e != nil && e.Error() != utils.ErrNoRow() {
|
|
|
+ err = fmt.Errorf("查询指标是否存在失败, err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if exist != nil && exist.EdbInfoId > 0 {
|
|
|
+ utils.FileLog.Info(fmt.Sprintf("指标%s已存在, 忽略同步", indexCode))
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
// 从桥接服务获取指标和数据
|
|
|
var params models.BridgeJiaYueIndexDataParams
|
|
|
params.IndexCode = indexCode
|
