|
@@ -89,7 +89,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
// 如果是钢联的话,那么就先判断是不是存在钢联化工
|
|
|
item, err = data_manage.GetEdbInfoByEdbCode(utils.DATA_SOURCE_MYSTEEL_CHEMICAL, edbCode)
|
|
|
if err != nil {
|
|
|
- if err.Error() != utils.ErrNoRow() {
|
|
|
+ if !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -102,7 +102,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
// 判断是不是已经在钢联这边已经存在了
|
|
|
item, err = data_manage.GetEdbInfoByEdbCode(utils.DATA_SOURCE_GL, edbCode)
|
|
|
if err != nil {
|
|
|
- if err.Error() != utils.ErrNoRow() {
|
|
|
+ if !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -114,7 +114,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
if item == nil {
|
|
|
tmpInfo, err := data_manage.GetBaseFromMysteelChemicalIndexByCode(edbCode)
|
|
|
if err != nil {
|
|
|
- if err.Error() != utils.ErrNoRow() {
|
|
|
+ if !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -133,7 +133,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
item, err = data_manage.GetEdbInfoByEdbCode(source, edbCode)
|
|
|
}
|
|
|
if err != nil {
|
|
|
- if err.Error() != utils.ErrNoRow() {
|
|
|
+ if !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -157,7 +157,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
// 查询该指标是否有权限
|
|
|
obj := data_manage.EdbInfoNoPermissionAdmin{}
|
|
|
conf, err := obj.GetByEdbInfoIdAndAdminId(this.SysUser.AdminId, item.EdbInfoId)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取当前账号的不可见指标配置失败,err:" + err.Error()
|
|
|
return
|
|
@@ -175,7 +175,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
fmt.Println("subSource:", subSource)
|
|
|
if subSource == utils.DATA_SUB_SOURCE_EDB {
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_THS, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取Ths已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -250,7 +250,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
fmt.Println("subSource:", subSource)
|
|
|
if subSource == utils.DATA_SUB_SOURCE_EDB {
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_WIND, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取Wind已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -328,7 +328,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
} else if source == utils.DATA_SOURCE_PB || source == utils.DATA_SOURCE_PB_FINANCE {
|
|
|
fmt.Println("pb data exist")
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取Pb已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -369,7 +369,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_MANUAL { //手工数据指标
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_MANUAL, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取Ths已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -410,7 +410,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
//获取指标信息
|
|
|
manualInfo, err := models.GetEdbinfoByTradeCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取手工指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -423,7 +423,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
} else if source == utils.DATA_SOURCE_LZ {
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_LZ, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取隆众已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -465,7 +465,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
//获取指标信息
|
|
|
lzInfo, err := data_manage.GetLongzhongSurveyProductByCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取手工指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -492,7 +492,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_YS { //有色网
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_YS, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取Ys已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -539,7 +539,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
smmInfo, err := data_manage.GetBaseFromSmmIndexByIndexCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取有色指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -552,7 +552,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
} else if source == utils.DATA_SOURCE_GL { //钢联
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取钢联已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -592,7 +592,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
//获取指标信息
|
|
|
glInfo, err := data_manage.GetGlIndexByCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取钢联指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -616,7 +616,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
return
|
|
|
}
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取郑商所已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -660,7 +660,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
allInfo, err := data_manage.GetBaseInfoFromZhengzhouByIndexCode(edbCode, suffix)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取郑商所指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -694,7 +694,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
return
|
|
|
}
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取大商所已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -739,7 +739,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
allInfo, err := data_manage.GetBaseInfoFromDalianByIndexCode(edbCode, suffix)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取大商所指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -773,7 +773,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
return
|
|
|
}
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取上期所已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -818,7 +818,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
allInfo, err := data_manage.GetBaseInfoFromShByIndexCode(edbCode, suffix)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取上期所指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -852,7 +852,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
return
|
|
|
}
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取中金所已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -897,7 +897,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
allInfo, err := data_manage.GetBaseInfoFromCffexByIndexCode(edbCode, suffix)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取中金所指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -931,7 +931,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
return
|
|
|
}
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取上期能源已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -976,7 +976,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
allInfo, err := data_manage.GetBaseInfoFromShfeByIndexCode(edbCode, suffix)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取上期能源指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1025,7 +1025,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
return
|
|
|
}
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取欧洲天然气已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1071,7 +1071,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
allInfo, err := data_manage.GetBaseFromEicDataAllByIndexCodeV2(edbCode, suffix)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取欧洲天然气指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1133,7 +1133,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
return
|
|
|
}
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_LT, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取 lt 已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1189,7 +1189,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
return
|
|
|
}
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取煤炭网已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1234,7 +1234,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
allInfo, err := data_manage.GetBaseInfoFromCoalByIndexCode(edbCode, suffix)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取煤炭网指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1250,7 +1250,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_GOOGLE_TRAVEL { //谷歌出行数据
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取煤炭网已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1285,7 +1285,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_MYSTEEL_CHEMICAL { //钢联化工
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取钢联已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1325,7 +1325,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
//获取指标信息
|
|
|
glInfo, err := data_manage.GetBaseFromMysteelChemicalIndexByCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取钢联指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1337,7 +1337,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_EIA_STEO { //eia steo报告
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取钢联已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1370,7 +1370,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
//获取指标信息
|
|
|
eiasteoInfo, err := data_manage.GetBaseFromEiaSteoIndexByCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取钢联指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1382,7 +1382,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_COM_TRADE { // un数据源
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取联合国商品贸易数据已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1415,7 +1415,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
//获取指标信息
|
|
|
eiasteoInfo, err := data_manage.GetComTradeIndex(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取钢联指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1436,7 +1436,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_SCI { //卓创数据(红桃三)
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取SCI已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1483,7 +1483,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
smmInfo, err := data_manage.GetBaseFromSciIndexByIndexCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取Sci指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1496,7 +1496,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
} else if source == utils.DATA_SOURCE_BAIINFO { //百川盈孚
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取BAIINFO已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1543,7 +1543,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
baiInfo, err := data_manage.GetBaseFromBaiinfoIndexByIndexCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取Baiinfo指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1556,7 +1556,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
} else if source == utils.DATA_SOURCE_NATIONAL_STATISTICS { // 国家统计局
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取国家统计局已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1589,7 +1589,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
//获取指标信息
|
|
|
nationalInfo, err := data_manage.GetBaseFromNationalStatisticsIndexByIndexCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取国家统计局详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1601,7 +1601,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_FUBAO { //数宝
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_FUBAO, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取Fubao已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1636,7 +1636,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_GFEX { //广州期货交易所
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取上期所已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1670,7 +1670,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
indexInfo, err := data_manage.GetBaseInfoFromGzByIndexCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取上期所指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1683,7 +1683,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_ICPI { //消费者指数
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取上期所已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1717,7 +1717,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
indexInfo, err := data_manage.GetBaseInfoFromIcpiByIndexCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取上期所指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1731,14 +1731,14 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
} else if source == utils.DATA_SOURCE_BUSINESS { //自有数据
|
|
|
indexObj := data_manage.BaseFromBusinessIndex{}
|
|
|
indexInfo, err := indexObj.GetDetailByEdbCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取自有数据指标信息失败,Err:" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
|
|
|
_, tmpDataList, err := data.GetPageBaseBusinessIndexData(edbCode, 1, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取自有数据已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1759,7 +1759,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
searchItem.EdbName = indexInfo.IndexName
|
|
|
} else if source == utils.DATA_SOURCE_SCI99 { //卓创资讯
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取上期所已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1793,7 +1793,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
indexInfo, err := data_manage.GetBaseInfoFromSci99ByIndexCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取上期所指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1806,7 +1806,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_SCI_HQ {
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取SCIHQ已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1840,7 +1840,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
//获取指标信息
|
|
|
sciHqInfo, err := data_manage.GetSciHqIndexByIndexCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取SciHq指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1852,7 +1852,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_OILCHEM { //隆众资讯
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取隆众资讯已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1886,7 +1886,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
indexInfo, err := data_manage.GetBaseInfoFromOilchemByIndexCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取上期所指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -1917,7 +1917,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
searchItem.DataList = dataList
|
|
|
// 获取最大最小值
|
|
|
edbInfoMaxAndMinInfo, e := data_manage.GetEdbInfoMaxAndMinInfo(source, subSource, edbCode)
|
|
|
- if e != nil && e.Error() != utils.ErrNoRow() {
|
|
|
+ if e != nil && !utils.IsErrNoRow(e) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取数据失败, GetEdbInfoMaxAndMinInfo Err:" + e.Error()
|
|
|
return
|
|
@@ -2046,7 +2046,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
indexCode := utils.WindDbWsd + stockCode + v
|
|
|
|
|
|
dataList, err := data_manage.GetEdbDataAllByEdbCodeAndSubSource(indexCode, source, utils.DATA_SUB_SOURCE_DATE, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取数据失败,GetEdbDataAllByEdbCode Err:" + err.Error()
|
|
|
return
|
|
@@ -2066,7 +2066,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
indexCode := utils.ThsDs + stockCode + v
|
|
|
|
|
|
dataList, err := data_manage.GetEdbDataAllByEdbCodeAndSubSource(indexCode, source, utils.DATA_SUB_SOURCE_DATE, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取数据失败,GetEdbDataAllByEdbCode Err:" + err.Error()
|
|
|
return
|
|
@@ -2086,7 +2086,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
} else {
|
|
|
dataList, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取数据失败,GetEdbDataAllByEdbCode Err:" + err.Error()
|
|
|
return
|
|
@@ -2094,7 +2094,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
searchItem.DataList = dataList
|
|
|
|
|
|
edbInfoMaxAndMinInfo, err := data_manage.GetEdbInfoMaxAndMinInfo(source, subSource, edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取数据失败,GetEdbInfoMaxAndMinInfo Err:" + err.Error()
|
|
|
return
|
|
@@ -2183,7 +2183,7 @@ func (this *EdbInfoController) EdbInfoList() {
|
|
|
// 获取当前账号的不可见指标配置
|
|
|
obj := data_manage.EdbInfoNoPermissionAdmin{}
|
|
|
conf, err := obj.GetByEdbInfoIdAndAdminId(this.SysUser.AdminId, edbInfoId)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取当前账号的不可见指标配置失败,err:" + err.Error()
|
|
|
return
|
|
@@ -2213,14 +2213,14 @@ func (this *EdbInfoController) EdbInfoList() {
|
|
|
}
|
|
|
//获取指标信息
|
|
|
edbInfoItem, err := data_manage.GetEdbInfoByCondition(condition, pars)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Success = true
|
|
|
br.Msg = "获取指标信息失败"
|
|
|
br.ErrMsg = "获取指标信息失败,Err:" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- if edbInfoItem == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
|
|
|
+ if edbInfoItem == nil || (err != nil && utils.IsErrNoRow(err)) {
|
|
|
item := new(data_manage.EdbInfoList)
|
|
|
resp.Paging = page
|
|
|
resp.Item = item
|
|
@@ -2271,7 +2271,7 @@ func (this *EdbInfoController) EdbInfoList() {
|
|
|
// 如果有数据权限,那么就去获取指标数据
|
|
|
if edbInfoItem.HaveOperaAuth {
|
|
|
dataCount, dataList, err := data.GetPageData(edbInfoItem.EdbInfoId, edbInfoItem.Source, edbInfoItem.SubSource, "", startSize, pageSize)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取指标信息失败"
|
|
|
br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -2283,7 +2283,7 @@ func (this *EdbInfoController) EdbInfoList() {
|
|
|
// 获取指标插入配置
|
|
|
{
|
|
|
edbDataInsertConfig, err := data_manage.GetEdbDataInsertConfigByEdbId(edbInfoId)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取指标信息失败"
|
|
|
br.ErrMsg = "获取指标数据失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -2392,7 +2392,7 @@ func (this *EdbInfoController) EdbInfoAdd() {
|
|
|
// 如果是钢联的话,那么就先判断是不是存在钢联化工
|
|
|
tmpInfo, err := data_manage.GetBaseFromMysteelChemicalIndexByCode(req.EdbCode)
|
|
|
if err != nil {
|
|
|
- if err.Error() != utils.ErrNoRow() {
|
|
|
+ if !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -2742,7 +2742,7 @@ func (this *EdbInfoController) EdbEnInfoEdit() {
|
|
|
|
|
|
edbExist, err := data_manage.GetEdbInfoByCondition(condition, pars)
|
|
|
if err != nil {
|
|
|
- if err.Error() != utils.ErrNoRow() {
|
|
|
+ if !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "判断英文指标名称是否存在失败"
|
|
|
br.ErrMsg = "判断英文指标名称是否存在失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -2869,7 +2869,7 @@ func (this *EdbInfoController) EdbInfoBaseEdit() {
|
|
|
|
|
|
edbExist, err := data_manage.GetEdbInfoByCondition(condition, pars)
|
|
|
if err != nil {
|
|
|
- if err.Error() != utils.ErrNoRow() {
|
|
|
+ if !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "判断英文指标名称是否存在失败"
|
|
|
br.ErrMsg = "判断英文指标名称是否存在失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -2943,7 +2943,7 @@ func (this *EdbInfoController) EdbInfoNewest() {
|
|
|
this.ServeJSON()
|
|
|
}()
|
|
|
item, err := data_manage.GetEdbInfoByNewest()
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取最新指标失败"
|
|
|
br.ErrMsg = "获取最新指标失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -2981,7 +2981,7 @@ func (this *EdbInfoController) EdbInfoRefresh() {
|
|
|
}
|
|
|
_, err := data_manage.GetEdbInfoById(edbInfoId)
|
|
|
if err != nil {
|
|
|
- if err.Error() == utils.ErrNoRow() {
|
|
|
+ if utils.IsErrNoRow(err) {
|
|
|
br.Msg = "数据已被删除,请刷新页面"
|
|
|
br.ErrMsg = "数据已被删除,请刷新页面,edbInfoId:" + strconv.Itoa(edbInfoId)
|
|
|
return
|
|
@@ -3124,7 +3124,7 @@ func (this *EdbInfoController) EdbInfoMove() {
|
|
|
|
|
|
} else {
|
|
|
firstClassify, err := data_manage.GetFirstEdbInfoByClassifyId(req.ClassifyId)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "移动失败"
|
|
|
br.ErrMsg = "获取获取当前父级分类下的排序第一条的分类信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -3273,7 +3273,7 @@ func (this *EdbInfoController) EdbInfoFilter() {
|
|
|
{
|
|
|
obj := data_manage.EdbInfoNoPermissionAdmin{}
|
|
|
confList, err := obj.GetAllListByAdminId(this.SysUser.AdminId)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取不可见指标配置数据失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -3293,7 +3293,7 @@ func (this *EdbInfoController) EdbInfoFilter() {
|
|
|
edbInfoList := make([]*data_manage.EdbInfoList, 0)
|
|
|
//if keyWord == "" {
|
|
|
// edbInfoList, err = data_manage.GetEdbInfoFilter(condition, pars)
|
|
|
- // if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ // if err != nil && !utils.IsErrNoRow(err) {
|
|
|
// br.Success = true
|
|
|
// br.Msg = "获取指标信息失败"
|
|
|
// br.ErrMsg = "获取指标信息失败,Err:" + err.Error()
|
|
@@ -3303,7 +3303,7 @@ func (this *EdbInfoController) EdbInfoFilter() {
|
|
|
// //获取指标信息
|
|
|
// indexName := utils.DATA_INDEX_NAME
|
|
|
// edbInfoList, err = data.EsSearchEdbInfo(indexName, keyWord,filterSource)
|
|
|
- // if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ // if err != nil && !utils.IsErrNoRow(err) {
|
|
|
// br.Success = true
|
|
|
// br.Msg = "获取指标信息失败"
|
|
|
// br.ErrMsg = "获取指标信息失败,Err:" + err.Error()
|
|
@@ -3335,7 +3335,7 @@ func (this *EdbInfoController) EdbInfoFilter() {
|
|
|
|
|
|
condition += conditionWhere + baseCondition
|
|
|
newEdbInfoList, err := data_manage.GetEdbInfoFilter(condition, pars)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Success = true
|
|
|
br.Msg = "获取指标信息失败"
|
|
|
br.ErrMsg = "获取指标信息失败,Err:" + err.Error()
|
|
@@ -3434,7 +3434,7 @@ func (this *EdbInfoController) EdbInfoFilterByEs() {
|
|
|
{
|
|
|
obj := data_manage.EdbInfoNoPermissionAdmin{}
|
|
|
confList, err := obj.GetAllListByAdminId(this.SysUser.AdminId)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取不可见指标配置数据失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -3759,7 +3759,7 @@ func (this *EdbInfoController) EdbInfoAllRefresh() {
|
|
|
}
|
|
|
edbInfo, err := data_manage.GetEdbInfoById(edbInfoId)
|
|
|
if err != nil {
|
|
|
- if err.Error() == utils.ErrNoRow() {
|
|
|
+ if utils.IsErrNoRow(err) {
|
|
|
br.Msg = "数据已被删除,请刷新页面"
|
|
|
br.ErrMsg = "数据已被删除,请刷新页面,edbInfoId:" + strconv.Itoa(edbInfoId)
|
|
|
return
|
|
@@ -3835,7 +3835,7 @@ func (this *ChartInfoController) EdbInfoData() {
|
|
|
|
|
|
edbInfo, err := data_manage.GetEdbInfoById(edbInfoId)
|
|
|
if err != nil {
|
|
|
- if err.Error() == utils.ErrNoRow() {
|
|
|
+ if utils.IsErrNoRow(err) {
|
|
|
br.Ret = 200
|
|
|
return
|
|
|
}
|
|
@@ -4083,7 +4083,7 @@ func (this *EdbInfoController) RelationChartList() {
|
|
|
chartIdMap := make(map[int]bool)
|
|
|
// 查询指标绑定的图表
|
|
|
edbListTemp, err := data_manage.GetEdbMappingListByEdbInfoId(edbInfoId)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取图表信息失败"
|
|
|
br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -4095,7 +4095,7 @@ func (this *EdbInfoController) RelationChartList() {
|
|
|
}
|
|
|
// 查询跨品种的图表
|
|
|
tagXList, err := cross_variety.GetChartInfoCrossVarietyByXEdbInfoId(edbInfoId)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取图表信息失败"
|
|
|
br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -4108,7 +4108,7 @@ func (this *EdbInfoController) RelationChartList() {
|
|
|
}
|
|
|
|
|
|
tagYList, err := cross_variety.GetChartInfoCrossVarietyByYEdbInfoId(edbInfoId)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取图表信息失败"
|
|
|
br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -4123,7 +4123,7 @@ func (this *EdbInfoController) RelationChartList() {
|
|
|
{
|
|
|
obj := data_manage.EdbInfoNoPermissionAdmin{}
|
|
|
confList, err := obj.GetAllChartListByAdminId(this.SysUser.AdminId)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取不可见指标配置数据失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -4154,14 +4154,14 @@ func (this *EdbInfoController) RelationChartList() {
|
|
|
// 得到图表ID
|
|
|
//获取关联图表列表
|
|
|
list, err := data_manage.GetRelationChartListByCondition(condition, pars, startSize, pageSize)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Success = true
|
|
|
br.Msg = "获取图表信息失败"
|
|
|
br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- if list == nil || len(list) <= 0 || (err != nil && err.Error() == utils.ErrNoRow()) {
|
|
|
+ if list == nil || len(list) <= 0 || (err != nil && utils.IsErrNoRow(err)) {
|
|
|
items := make([]*data_manage.ChartInfoView, 0)
|
|
|
resp.Paging = page
|
|
|
resp.List = items
|
|
@@ -4173,7 +4173,7 @@ func (this *EdbInfoController) RelationChartList() {
|
|
|
|
|
|
// 获取关联图表总数
|
|
|
dataCount, err := data_manage.GetRelationChartListCountByCondition(condition, pars)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取指标信息失败"
|
|
|
br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -4181,7 +4181,7 @@ func (this *EdbInfoController) RelationChartList() {
|
|
|
|
|
|
// 获取MY ETA 图表,用来判断是否加入我的图库
|
|
|
myChartList, err := data_manage.GetMyChartListByAdminId(sysUser.AdminId)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取图表信息失败"
|
|
|
br.ErrMsg = "获取我的图表信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -4307,7 +4307,7 @@ func (this *EdbInfoController) RelationEdbList() {
|
|
|
{
|
|
|
obj := data_manage.EdbInfoNoPermissionAdmin{}
|
|
|
confList, err := obj.GetAllListByAdminId(this.SysUser.AdminId)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取不可见指标配置数据失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -4324,14 +4324,14 @@ func (this *EdbInfoController) RelationEdbList() {
|
|
|
|
|
|
//获取关联图表列表
|
|
|
list, err := data_manage.GetRelationEdbInfoListByCondition(condition, pars, startSize, pageSize)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Success = true
|
|
|
br.Msg = "获取图表信息失败"
|
|
|
br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- if list == nil || len(list) <= 0 || (err != nil && err.Error() == utils.ErrNoRow()) {
|
|
|
+ if list == nil || len(list) <= 0 || (err != nil && utils.IsErrNoRow(err)) {
|
|
|
items := make([]*data_manage.ChartEdbInfoMapping, 0)
|
|
|
resp.Paging = page
|
|
|
resp.List = items
|
|
@@ -4343,7 +4343,7 @@ func (this *EdbInfoController) RelationEdbList() {
|
|
|
|
|
|
// 获取关联图表总数
|
|
|
dataCount, err := data_manage.GetRelationEdbInfoListCountByCondition(condition, pars)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取指标信息失败"
|
|
|
br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -4750,7 +4750,7 @@ func (this *EdbInfoController) TraceEdbInfo() {
|
|
|
if err != nil {
|
|
|
br.Msg = "获取失败"
|
|
|
br.Msg = "获取失败,Err:" + err.Error()
|
|
|
- if err.Error() == utils.ErrNoRow() {
|
|
|
+ if utils.IsErrNoRow(err) {
|
|
|
br.Msg = "指标不存在"
|
|
|
}
|
|
|
return
|
|
@@ -4821,7 +4821,7 @@ func (this *EdbInfoController) AllEdbInfoByEs() {
|
|
|
{
|
|
|
obj := data_manage.EdbInfoNoPermissionAdmin{}
|
|
|
confList, err := obj.GetAllListByAdminId(this.SysUser.AdminId)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取不可见指标配置数据失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -5426,7 +5426,7 @@ func (this *EdbInfoController) EdbChartList() {
|
|
|
classifyId, _ := this.GetInt("ClassifyId")
|
|
|
if classifyId > 0 {
|
|
|
childClassify, e, _ := data.GetChildClassifyByClassifyId(classifyId)
|
|
|
- if e != nil && e.Error() != utils.ErrNoRow() {
|
|
|
+ if e != nil && !utils.IsErrNoRow(e) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取分类信息失败, GetEdbClassify,Err:" + e.Error()
|
|
|
return
|
|
@@ -5681,7 +5681,7 @@ func (this *EdbInfoController) ChartImageSet() {
|
|
|
|
|
|
edbInfo, e := data_manage.GetEdbInfoById(req.EdbInfoId)
|
|
|
if e != nil {
|
|
|
- if e.Error() == utils.ErrNoRow() {
|
|
|
+ if utils.IsErrNoRow(e) {
|
|
|
br.Msg = "找不到该指标"
|
|
|
return
|
|
|
}
|
|
@@ -5767,7 +5767,7 @@ func (this *EdbInfoController) EdbInfoExistCheck() {
|
|
|
}
|
|
|
}
|
|
|
indexList, err := data_manage.GetEdbInfoByEdbCodeList(source, indexCodeArr)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "校验指标是否存在失败"
|
|
|
br.ErrMsg = "校验指标是否存在失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -6141,7 +6141,7 @@ func (this *EdbInfoController) SmmExistCheck() {
|
|
|
}
|
|
|
|
|
|
indexList, err := data_manage.GetEdbInfoByEdbCodeList(utils.DATA_SOURCE_YS, edbCodeArr)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "校验指标是否存在失败"
|
|
|
br.ErrMsg = "校验指标是否存在失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -6316,7 +6316,7 @@ func (this *EdbInfoController) EdbInfoSmmSearch() {
|
|
|
}
|
|
|
edbCodeStr = strings.Trim(edbCodeStr, ",")
|
|
|
smmInfoList, err := data_manage.GetBaseFromSmmIndexByIndexCodes(edbCodeStr)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取有色指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -6335,7 +6335,7 @@ func (this *EdbInfoController) EdbInfoSmmSearch() {
|
|
|
|
|
|
for _, edbCode := range edbCodeArr {
|
|
|
dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_YS, utils.DATA_SUB_SOURCE_EDB, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取Ys已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -6405,7 +6405,7 @@ func (this *EdbInfoController) EdbInfoSmmSearch() {
|
|
|
searchItem.EdbName = smmInfo.IndexName
|
|
|
searchItem.EdbCode = smmInfo.IndexCode
|
|
|
dataList, err := data_manage.GetEdbDataAllByEdbCode(smmInfo.IndexCode, utils.DATA_SOURCE_YS, utils.DATA_SUB_SOURCE_EDB, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取数据失败,GetEdbDataAllByEdbCode Err:" + err.Error()
|
|
|
return
|
|
@@ -6632,7 +6632,7 @@ func (this *EdbInfoController) ChartImageSetBySvg() {
|
|
|
|
|
|
edbInfo, e := data_manage.GetEdbInfoById(edbInfoId)
|
|
|
if e != nil {
|
|
|
- if e.Error() == utils.ErrNoRow() {
|
|
|
+ if utils.IsErrNoRow(e) {
|
|
|
br.Msg = "找不到该指标"
|
|
|
return
|
|
|
}
|