Merge branch 'bzq1/eia_steo_custom' of eta_server/eta_api into debug

controllers/data_manage/eia_steo.go

@@ -5,6 +5,7 @@ import (
 	"eta/eta_api/models"
 	"eta/eta_api/models/data_manage"
 	"eta/eta_api/models/system"
+	"eta/eta_api/services/alarm_msg"
 	"eta/eta_api/services/data"
 	"eta/eta_api/services/data_stat"
 	etaTrialService "eta/eta_api/services/eta_trial"
@@ -136,6 +137,7 @@ func (this *EdbInfoController) EiaSteoData() {
 		br.ErrMsg = "获取数据失败,Err:" + err.Error()
 		return
 	}
+	alarm_msg.SendAlarmMsg("指标数："+strconv.Itoa(len(indexList)), 1)
 	resultList := make([]data_manage.EiaSteoIndexListResp, 0)
 	for _, v := range indexList {
 

models/data_manage/base_from_eia_stero.go

@@ -1,6 +1,7 @@
 package data_manage
 
 import (
+	"eta/eta_api/services/alarm_msg"
 	"eta/eta_api/utils"
 	"time"
 
@@ -128,6 +129,7 @@ func GetEiaSteoIndexList(condition string, pars []interface{}) (items []*BaseFro
 	sql += condition
 	sql += ` ORDER BY base_from_eia_steo_index_id ASC `
 	o := orm.NewOrmUsingDB("data")
+	alarm_msg.SendAlarmMsg(sql, 1)
 	_, err = o.Raw(sql, pars).QueryRows(&items)
 	return
 }