指标查询时更新

models/edb_info.go

@@ -126,10 +126,10 @@ type EdbInfoSearchResp struct {
 	StockSearchList []*EdbInfoSearch
 }
 
-func GetEdbInfoByEdbCode(source int, edbCode string) (item *EdbInfo, err error) {
+func GetEdbInfoByEdbCode(edbCode string) (item *EdbInfo, err error) {
 	o := orm.NewOrm()
-	sql := ` SELECT * FROM edb_info WHERE source=? AND edb_code=? `
-	err = o.Raw(sql, source, edbCode).QueryRow(&item)
+	sql := ` SELECT * FROM edb_info WHERE edb_code=? `
+	err = o.Raw(sql, edbCode).QueryRow(&item)
 	return
 }
 

services/edb_info.go

@@ -73,7 +73,7 @@ func BatchAddOrUpdateEdbInfo(edbList []*models.EdbInfo, edbMapping []*models.Edb
 func AddOrUpdateEdbInfo(edbItem *models.EdbInfo, sysUserId int, sysUserRealName string) (edbInfo *models.EdbInfo, err error, errMsg string, isSendEmail bool) {
 	isSendEmail = true
 	//判断指标是否存在
-	edbInfo, err = models.GetEdbInfoByEdbCode(edbItem.Source, edbItem.EdbCode)
+	edbInfo, err = models.GetEdbInfoByEdbCode(edbItem.EdbCode)
 	if err != nil {
 		if err.Error() == utils.ErrNoRow() {
 			err = nil