|
@@ -99,7 +99,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
if item == nil {
|
|
|
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
|
|
@@ -125,7 +125,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
|
|
@@ -143,7 +143,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
|
|
@@ -218,7 +218,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
|
|
@@ -296,7 +296,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
|
|
@@ -337,7 +337,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
|
|
@@ -378,7 +378,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
|
|
@@ -391,7 +391,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
|
|
@@ -433,7 +433,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
|
|
@@ -460,7 +460,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
|
|
@@ -507,7 +507,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
|
|
@@ -520,7 +520,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
|
|
@@ -560,7 +560,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
|
|
@@ -584,7 +584,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
|
|
@@ -628,7 +628,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
|
|
@@ -662,7 +662,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
|
|
@@ -707,7 +707,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
|
|
@@ -741,7 +741,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
|
|
@@ -786,7 +786,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
|
|
@@ -820,7 +820,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
|
|
@@ -865,7 +865,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
|
|
@@ -899,7 +899,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
|
|
@@ -944,7 +944,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
|
|
@@ -993,7 +993,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
|
|
@@ -1039,7 +1039,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
|
|
@@ -1101,7 +1101,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
|
|
@@ -1157,7 +1157,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
|
|
@@ -1202,7 +1202,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
|
|
@@ -1218,7 +1218,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
|
|
@@ -1253,7 +1253,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
|
|
@@ -1293,7 +1293,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
|
|
@@ -1305,7 +1305,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
|
|
@@ -1338,7 +1338,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
|
|
@@ -1350,7 +1350,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
|
|
@@ -1383,7 +1383,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
|
|
@@ -1404,7 +1404,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
|
|
@@ -1451,7 +1451,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
|
|
@@ -1464,7 +1464,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
|
|
@@ -1511,7 +1511,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
|
|
@@ -1524,7 +1524,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
|
|
@@ -1557,7 +1557,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
|
|
@@ -1569,7 +1569,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
|
|
@@ -1604,7 +1604,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
|
|
@@ -1638,7 +1638,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
|
|
@@ -1651,7 +1651,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
|
|
@@ -1685,7 +1685,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
|
|
@@ -1699,14 +1699,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
|
|
@@ -1727,7 +1727,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
|
|
@@ -1761,7 +1761,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
|
|
@@ -1774,7 +1774,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
|
|
@@ -1808,7 +1808,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
|
|
@@ -1820,7 +1820,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
|
|
@@ -1854,7 +1854,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
|
|
@@ -1867,7 +1867,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_HISUGAR { //泛糖科技
|
|
|
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
|
|
@@ -1901,7 +1901,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
//获取指标信息
|
|
|
indexInfo, err := data_manage.GetBaseInfoFromHisugarByIndexCode(edbCode)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取泛糖科技指标详情失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -2061,7 +2061,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
|
|
@@ -2081,7 +2081,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
|
|
@@ -2101,7 +2101,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
|
|
@@ -2109,7 +2109,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
|
|
@@ -2198,7 +2198,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
|
|
@@ -2228,14 +2228,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
|
|
@@ -2286,7 +2286,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
|
|
@@ -2298,7 +2298,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
|
|
@@ -2407,7 +2407,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
|
|
@@ -2760,7 +2760,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
|
|
@@ -2887,7 +2887,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
|
|
@@ -2961,7 +2961,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
|
|
@@ -2999,7 +2999,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
|
|
@@ -3142,7 +3142,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
|
|
@@ -3293,7 +3293,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
|
|
@@ -3355,7 +3355,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()
|
|
@@ -3454,7 +3454,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
|
|
@@ -3804,7 +3804,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
|
|
@@ -3880,7 +3880,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
|
|
|
}
|
|
@@ -4163,7 +4163,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
|
|
@@ -4176,7 +4176,7 @@ func (this *EdbInfoController) RelationChartList() {
|
|
|
// 查询相关性的图表
|
|
|
correlationChart := new(data_manage.ChartInfoCorrelation)
|
|
|
correlationChartId, err := correlationChart.GetChartInfoIdByEdb(edbInfoId)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取图表信息失败"
|
|
|
br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -4186,7 +4186,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
|
|
@@ -4199,7 +4199,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
|
|
@@ -4214,7 +4214,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
|
|
@@ -4245,14 +4245,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
|
|
@@ -4264,7 +4264,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
|
|
@@ -4272,7 +4272,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
|
|
@@ -4398,7 +4398,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
|
|
@@ -4415,14 +4415,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
|
|
@@ -4434,7 +4434,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
|
|
@@ -4841,7 +4841,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
|
|
@@ -4912,7 +4912,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
|
|
@@ -5880,7 +5880,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
|
|
@@ -6254,7 +6254,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
|
|
@@ -6429,7 +6429,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
|
|
@@ -6448,7 +6448,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
|
|
@@ -6518,7 +6518,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
|
|
@@ -6799,7 +6799,6 @@ func (this *EdbInfoController) ModifyEdbList() {
|
|
|
|
|
|
classifyIds := strings.Split(req.EdbClassifyIds, ",")
|
|
|
|
|
|
-
|
|
|
if !req.SelectAll && req.EdbInfoIds == "" {
|
|
|
br.Msg = "请选择图表"
|
|
|
return
|
|
@@ -6840,7 +6839,7 @@ func (this *EdbInfoController) ModifyEdbList() {
|
|
|
pars = append(pars, classifyIdsArr)
|
|
|
} else {
|
|
|
classifyAll, err := data_manage.GetNormalEdbClassifyAll()
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取数据失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -6886,7 +6885,7 @@ func (this *EdbInfoController) ModifyEdbList() {
|
|
|
// 获取当前账号的不可见指标
|
|
|
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
|
|
@@ -6901,7 +6900,7 @@ func (this *EdbInfoController) ModifyEdbList() {
|
|
|
}
|
|
|
|
|
|
count, err := data_manage.GetEdbInfoByConditionCount(condition, pars)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取数据失败,Err:" + err.Error()
|
|
|
return
|
|
@@ -6912,13 +6911,12 @@ func (this *EdbInfoController) ModifyEdbList() {
|
|
|
}
|
|
|
|
|
|
list, err := data_manage.GetEdbInfoListByCondition(condition, pars, 0, 0, "")
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ if err != nil && !utils.IsErrNoRow(err) {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取数据失败,Err:" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-
|
|
|
for _, v := range list {
|
|
|
edbInfoIds = append(edbInfoIds, v.EdbInfoId)
|
|
|
}
|
|
@@ -6952,4 +6950,4 @@ func (this *EdbInfoController) ModifyEdbList() {
|
|
|
br.Ret = 200
|
|
|
br.Success = true
|
|
|
br.Msg = "操作成功"
|
|
|
-}
|
|
|
+}
|