|
@@ -11,6 +11,7 @@ import (
|
|
|
"eta/eta_api/models/system"
|
|
|
"eta/eta_api/services/alarm_msg"
|
|
|
"eta/eta_api/services/data"
|
|
|
+ "eta/eta_api/services/data_stat"
|
|
|
"eta/eta_api/services/elastic"
|
|
|
etaTrialService "eta/eta_api/services/eta_trial"
|
|
|
"eta/eta_api/utils"
|
|
@@ -160,50 +161,84 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
searchItem := new(data_manage.EdbInfoSearch)
|
|
|
if source == utils.DATA_SOURCE_THS {
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_THS, utils.EDB_DATA_LIMIT)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
- br.Msg = "获取失败"
|
|
|
- br.ErrMsg = "获取Ths已存在信息失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- fmt.Println("ths len:", len(dataItems))
|
|
|
- if len(dataItems) > 0 {
|
|
|
- fmt.Println("ths data exist")
|
|
|
- searchItem.EdbCode = edbCode
|
|
|
- minDate, maxDate, err := data_manage.GetEdbDataThsMaxOrMinDate(edbCode)
|
|
|
- if err != nil {
|
|
|
+ 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() {
|
|
|
br.Msg = "获取失败"
|
|
|
- br.ErrMsg = "获取Ths日期信息失败,Err:" + err.Error()
|
|
|
+ br.ErrMsg = "获取Ths已存在信息失败,Err:" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
- searchItem.DataList = dataItems
|
|
|
- searchItem.StartDate = minDate
|
|
|
- searchItem.EndDate = maxDate
|
|
|
- } else {
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
- respItem, err := data.AddEdbData(source, edbCode)
|
|
|
+
|
|
|
+ fmt.Println("ths len:", len(dataItems))
|
|
|
+ if len(dataItems) > 0 {
|
|
|
+ fmt.Println("ths data exist")
|
|
|
+ searchItem.EdbCode = edbCode
|
|
|
+ minDate, maxDate, err := data_manage.GetEdbDataThsMaxOrMinDate(edbCode)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取Ths日期信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ searchItem.DataList = dataItems
|
|
|
+ searchItem.StartDate = minDate
|
|
|
+ searchItem.EndDate = maxDate
|
|
|
+ } else {
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ respItem, err := data.AddEdbData(source, edbCode)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if respItem.Ret != 200 {
|
|
|
+ br.Msg = "未搜索到该指标"
|
|
|
+ br.ErrMsg = respItem.ErrMsg + ";EdbCode:" + edbCode
|
|
|
+ return
|
|
|
+ }
|
|
|
+ isAdd = true
|
|
|
+ }
|
|
|
+ } else if subSource == utils.DATA_SUB_SOURCE_DATE {
|
|
|
+ if stockCode == "" {
|
|
|
+ br.Msg = "请输入证券代码"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if edbCode == "" {
|
|
|
+ br.Msg = "请输入指标代码"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ respItem, err := data.AddEdbDataThsDs(source, stockCode, edbCode)
|
|
|
if err != nil {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取失败,Err:" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
if respItem.Ret != 200 {
|
|
|
- br.Msg = "未搜索到该指标"
|
|
|
+ if respItem.Ret == 421 {
|
|
|
+ br.Msg = "该渠道已超过添加上限"
|
|
|
+ } else if respItem.Ret == 4052 {
|
|
|
+ br.Msg = "该指标已下架"
|
|
|
+ } else {
|
|
|
+ br.Msg = "未搜索到该指标"
|
|
|
+ }
|
|
|
br.ErrMsg = respItem.ErrMsg + ";EdbCode:" + edbCode
|
|
|
return
|
|
|
}
|
|
|
isAdd = true
|
|
|
+ } else {
|
|
|
+ br.Msg = "无效的渠道来源"
|
|
|
+ return
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_WIND {
|
|
|
+ fmt.Println("subSource:", subSource)
|
|
|
if subSource == utils.DATA_SUB_SOURCE_EDB {
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_WIND, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_WIND, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取Wind已存在信息失败,Err:" + err.Error()
|
|
@@ -281,7 +316,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, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取Pb已存在信息失败,Err:" + err.Error()
|
|
@@ -322,7 +357,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
isAdd = true
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_MANUAL {
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_MANUAL, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_MANUAL, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取Ths已存在信息失败,Err:" + err.Error()
|
|
@@ -376,7 +411,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
|
|
|
} else if source == utils.DATA_SOURCE_LZ {
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_LZ, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_LZ, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取隆众已存在信息失败,Err:" + err.Error()
|
|
@@ -445,7 +480,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
searchItem.EdbName = lzInfo.SampleName + lzInfo.BreedName + lzInfo.QuotaName
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_YS {
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_YS, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_YS, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取Ys已存在信息失败,Err:" + err.Error()
|
|
@@ -505,7 +540,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
|
|
|
} else if source == utils.DATA_SOURCE_GL {
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取钢联已存在信息失败,Err:" + err.Error()
|
|
@@ -569,7 +604,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
br.ErrMsg = "指标code异常"
|
|
|
return
|
|
|
}
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取郑商所已存在信息失败,Err:" + err.Error()
|
|
@@ -647,7 +682,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
br.ErrMsg = "指标code异常"
|
|
|
return
|
|
|
}
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取大商所已存在信息失败,Err:" + err.Error()
|
|
@@ -726,7 +761,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
br.ErrMsg = "指标code异常"
|
|
|
return
|
|
|
}
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取上期所已存在信息失败,Err:" + err.Error()
|
|
@@ -805,7 +840,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
br.ErrMsg = "指标code异常"
|
|
|
return
|
|
|
}
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取中金所已存在信息失败,Err:" + err.Error()
|
|
@@ -884,7 +919,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
br.ErrMsg = "指标code异常"
|
|
|
return
|
|
|
}
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取上期能源已存在信息失败,Err:" + err.Error()
|
|
@@ -978,7 +1013,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
br.ErrMsg = "指标code异常"
|
|
|
return
|
|
|
}
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取欧洲天然气已存在信息失败,Err:" + err.Error()
|
|
@@ -1086,7 +1121,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
br.ErrMsg = "暂不支持编码中含有=的指标"
|
|
|
return
|
|
|
}
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_LT, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_LT, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取 lt 已存在信息失败,Err:" + err.Error()
|
|
@@ -1095,7 +1130,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
fmt.Println("lt dataItems:", len(dataItems))
|
|
|
if len(dataItems) > 0 {
|
|
|
searchItem.EdbCode = edbCode
|
|
|
- edbInfoMaxAndMinInfo, err := data_manage.GetEdbInfoMaxAndMinInfo(source, edbCode)
|
|
|
+ edbInfoMaxAndMinInfo, err := data_manage.GetEdbInfoMaxAndMinInfo(source, subSource, edbCode)
|
|
|
if err != nil {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取lt日期信息失败,Err:" + err.Error()
|
|
@@ -1142,7 +1177,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
br.ErrMsg = "指标code异常"
|
|
|
return
|
|
|
}
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取煤炭网已存在信息失败,Err:" + err.Error()
|
|
@@ -1203,7 +1238,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
searchItem.EdbName = coalInfo.IndexName
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_GOOGLE_TRAVEL {
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取煤炭网已存在信息失败,Err:" + err.Error()
|
|
@@ -1212,7 +1247,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
if len(dataItems) > 0 {
|
|
|
searchItem.EdbCode = edbCode
|
|
|
- item, err := data_manage.GetEdbInfoMaxAndMinInfo(source, edbCode)
|
|
|
+ item, err := data_manage.GetEdbInfoMaxAndMinInfo(source, subSource, edbCode)
|
|
|
if err != nil {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取煤炭网日期信息失败,Err:" + err.Error()
|
|
@@ -1238,7 +1273,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
isAdd = true
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_MYSTEEL_CHEMICAL {
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取钢联已存在信息失败,Err:" + err.Error()
|
|
@@ -1290,7 +1325,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
searchItem.EdbName = glInfo.IndexName
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_EIA_STEO {
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取钢联已存在信息失败,Err:" + err.Error()
|
|
@@ -1299,7 +1334,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
if len(dataItems) > 0 {
|
|
|
searchItem.EdbCode = edbCode
|
|
|
- item, err := data_manage.GetEdbInfoMaxAndMinInfo(source, edbCode)
|
|
|
+ item, err := data_manage.GetEdbInfoMaxAndMinInfo(source, subSource, edbCode)
|
|
|
if err != nil {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取eia steo日期信息失败,Err:" + err.Error()
|
|
@@ -1335,7 +1370,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
searchItem.EdbName = eiasteoInfo.IndexName
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_COM_TRADE {
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取联合国商品贸易数据已存在信息失败,Err:" + err.Error()
|
|
@@ -1344,7 +1379,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
if len(dataItems) > 0 {
|
|
|
searchItem.EdbCode = edbCode
|
|
|
- item, err := data_manage.GetEdbInfoMaxAndMinInfo(source, edbCode)
|
|
|
+ item, err := data_manage.GetEdbInfoMaxAndMinInfo(source, subSource, edbCode)
|
|
|
if err != nil {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取联合国商品贸易数据日期信息失败,Err:" + err.Error()
|
|
@@ -1389,7 +1424,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
searchItem.EdbName = eiasteoInfo.Name
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_SCI {
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取SCI已存在信息失败,Err:" + err.Error()
|
|
@@ -1449,7 +1484,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
|
|
|
} else if source == utils.DATA_SOURCE_BAIINFO {
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取BAIINFO已存在信息失败,Err:" + err.Error()
|
|
@@ -1509,7 +1544,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
|
|
|
} else if source == utils.DATA_SOURCE_NATIONAL_STATISTICS {
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取国家统计局已存在信息失败,Err:" + err.Error()
|
|
@@ -1518,7 +1553,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
|
|
|
if len(dataItems) > 0 {
|
|
|
searchItem.EdbCode = edbCode
|
|
|
- item, err := data_manage.GetEdbInfoMaxAndMinInfo(source, edbCode)
|
|
|
+ item, err := data_manage.GetEdbInfoMaxAndMinInfo(source, subSource, edbCode)
|
|
|
if err != nil {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取国家统计局日期信息失败,Err:" + err.Error()
|
|
@@ -1554,7 +1589,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
searchItem.EdbName = fmt.Sprintf("%s%s", nationalInfo.Reg, nationalInfo.IndexName)
|
|
|
}
|
|
|
} else if source == utils.DATA_SOURCE_FUBAO {
|
|
|
- dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_FUBAO, utils.EDB_DATA_LIMIT)
|
|
|
+ dataItems, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_FUBAO, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取Fubao已存在信息失败,Err:" + err.Error()
|
|
@@ -1597,7 +1632,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
|
|
|
|
|
|
- dataList, e := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataList, e := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if e != nil {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取指标数据失败, Err: " + e.Error()
|
|
@@ -1607,7 +1642,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
searchItem.EdbCode = edbCode
|
|
|
searchItem.DataList = dataList
|
|
|
|
|
|
- edbInfoMaxAndMinInfo, e := data_manage.GetEdbInfoMaxAndMinInfo(source, edbCode)
|
|
|
+ edbInfoMaxAndMinInfo, e := data_manage.GetEdbInfoMaxAndMinInfo(source, subSource, edbCode)
|
|
|
if e != nil && e.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取数据失败, GetEdbInfoMaxAndMinInfo Err:" + e.Error()
|
|
@@ -1668,19 +1703,115 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
if isAdd {
|
|
|
if subSource == utils.DATA_SUB_SOURCE_DATE {
|
|
|
- var indexCodeArr []string
|
|
|
- edbCodeArr := strings.Split(edbCode, ",")
|
|
|
- stockCodeArr := strings.Split(stockCode, ",")
|
|
|
-
|
|
|
- for _, sv := range stockCodeArr {
|
|
|
- for _, ev := range edbCodeArr {
|
|
|
- indexCode := utils.WindDbWsd + sv + ev
|
|
|
- indexCodeArr = append(indexCodeArr, indexCode)
|
|
|
+ if source == utils.DATA_SOURCE_WIND {
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ stockList := make([]*data_manage.StockInfo, 0)
|
|
|
+ edbCodeArr := strings.Split(edbCode, ",")
|
|
|
+ for _, v := range edbCodeArr {
|
|
|
+ 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() {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取数据失败,GetEdbDataAllByEdbCode Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ stockInfo := new(data_manage.StockInfo)
|
|
|
+ stockInfo.StockCode = stockCode
|
|
|
+ stockInfo.EdbCode = v
|
|
|
+ stockInfo.DataList = dataList
|
|
|
+ stockList = append(stockList, stockInfo)
|
|
|
}
|
|
|
- }
|
|
|
+ searchItem.StockList = stockList
|
|
|
+ } else if source == utils.DATA_SOURCE_THS {
|
|
|
+ stockList := make([]*data_manage.StockInfo, 0)
|
|
|
+ edbCodeArr := strings.Split(edbCode, ",")
|
|
|
+ for _, v := range edbCodeArr {
|
|
|
+ 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() {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取数据失败,GetEdbDataAllByEdbCode Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
|
|
|
+ stockInfo := new(data_manage.StockInfo)
|
|
|
+ stockInfo.StockCode = stockCode
|
|
|
+ stockInfo.EdbCode = v
|
|
|
+ stockInfo.DataList = dataList
|
|
|
+ stockList = append(stockList, stockInfo)
|
|
|
+ }
|
|
|
+ searchItem.StockList = stockList
|
|
|
+ } else {
|
|
|
+ br.Msg = "来源错误"
|
|
|
+ br.ErrMsg = "来源错误"
|
|
|
+ return
|
|
|
+ }
|
|
|
} else {
|
|
|
- dataList, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, utils.EDB_DATA_LIMIT)
|
|
|
+ dataList, err := data_manage.GetEdbDataAllByEdbCode(edbCode, source, subSource, utils.EDB_DATA_LIMIT)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取数据失败,GetEdbDataAllByEdbCode Err:" + err.Error()
|
|
@@ -1688,7 +1819,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
|
|
|
}
|
|
|
searchItem.DataList = dataList
|
|
|
|
|
|
- edbInfoMaxAndMinInfo, err := data_manage.GetEdbInfoMaxAndMinInfo(source, edbCode)
|
|
|
+ edbInfoMaxAndMinInfo, err := data_manage.GetEdbInfoMaxAndMinInfo(source, subSource, edbCode)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取数据失败,GetEdbInfoMaxAndMinInfo Err:" + err.Error()
|
|
@@ -1834,20 +1965,58 @@ func (this *EdbInfoController) EdbInfoList() {
|
|
|
dataCondition += ` AND edb_info_id=? `
|
|
|
dataPars = append(dataPars, edbInfoItem.EdbInfoId)
|
|
|
|
|
|
- dataCount, err := data_manage.GetEdbDataCountByCondition(dataCondition, dataPars, edbInfoItem.Source)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
- br.Msg = "获取指标信息失败"
|
|
|
- br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- page = paging.GetPaging(currentIndex, pageSize, dataCount)
|
|
|
- dataList, err := data_manage.GetEdbDataListByCondition(dataCondition, dataPars, edbInfoItem.Source, pageSize, startSize)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取指标信息失败"
|
|
|
- br.ErrMsg = "获取指标数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
+ if edbInfoItem.SubSource == utils.DATA_SUB_SOURCE_DATE {
|
|
|
+ if edbInfoItem.Source == utils.DATA_SOURCE_WIND {
|
|
|
+ dataCount, err := data_manage.GetEdbWsdDataCountByCondition(dataCondition, dataPars, edbInfoItem.Source)
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ br.Msg = "获取指标信息失败"
|
|
|
+ br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ page = paging.GetPaging(currentIndex, pageSize, dataCount)
|
|
|
+ dataList, err := data_manage.GetEdbWsdDataListByCondition(dataCondition, dataPars, edbInfoItem.Source, pageSize, startSize)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取指标信息失败"
|
|
|
+ br.ErrMsg = "获取指标数据失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ edbInfoItem.DataList = dataList
|
|
|
+ } else if edbInfoItem.Source == utils.DATA_SOURCE_THS {
|
|
|
+ dataCount, err := data_manage.GetTHsDsDataCountByCondition(dataCondition, dataPars, edbInfoItem.Source)
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ br.Msg = "获取指标信息失败"
|
|
|
+ br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ page = paging.GetPaging(currentIndex, pageSize, dataCount)
|
|
|
+ dataList, err := data_manage.GetThsDsDataListByCondition(dataCondition, dataPars, edbInfoItem.Source, pageSize, startSize)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取指标信息失败"
|
|
|
+ br.ErrMsg = "获取指标数据失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ edbInfoItem.DataList = dataList
|
|
|
+ } else {
|
|
|
+ br.Msg = "指标数据源id错误"
|
|
|
+ br.ErrMsg = "指标数据源id错误"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ dataCount, err := data_manage.GetEdbDataCountByCondition(dataCondition, dataPars, edbInfoItem.Source, edbInfoItem.SubSource)
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ br.Msg = "获取指标信息失败"
|
|
|
+ br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ page = paging.GetPaging(currentIndex, pageSize, dataCount)
|
|
|
+ dataList, err := data_manage.GetEdbDataListByCondition(dataCondition, dataPars, edbInfoItem.Source, edbInfoItem.SubSource, pageSize, startSize)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取指标信息失败"
|
|
|
+ br.ErrMsg = "获取指标数据失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ edbInfoItem.DataList = dataList
|
|
|
}
|
|
|
- edbInfoItem.DataList = dataList
|
|
|
|
|
|
|
|
|
{
|
|
@@ -1986,7 +2155,7 @@ func (this *EdbInfoController) EdbInfoAdd() {
|
|
|
}
|
|
|
|
|
|
|
|
|
- edbInfo, err, errMsg, isSendEmail := data.EdbInfoAdd(source, req.ClassifyId, req.EdbCode, req.EdbName, req.Frequency, req.Unit, req.StartDate, req.EndDate, sysUser.AdminId, sysUser.RealName)
|
|
|
+ edbInfo, err, errMsg, isSendEmail := data.EdbInfoAdd(source, utils.DATA_SUB_SOURCE_EDB, req.ClassifyId, req.EdbCode, req.EdbName, req.Frequency, req.Unit, req.StartDate, req.EndDate, sysUser.AdminId, sysUser.RealName)
|
|
|
if err != nil {
|
|
|
br.Msg = "保存失败"
|
|
|
if errMsg != `` {
|
|
@@ -2030,6 +2199,9 @@ func (this *EdbInfoController) EdbInfoAdd() {
|
|
|
go data_manage.AddEdbInfoLog(edbLog)
|
|
|
}
|
|
|
|
|
|
+
|
|
|
+ go data.AddOrEditEdbInfoToEs(edbInfo.EdbInfoId)
|
|
|
+
|
|
|
resp := new(data_manage.AddEdbInfoResp)
|
|
|
resp.EdbInfoId = edbInfo.EdbInfoId
|
|
|
resp.UniqueCode = edbInfo.UniqueCode
|
|
@@ -2188,6 +2360,11 @@ func (this *EdbInfoController) EdbInfoEdit() {
|
|
|
|
|
|
go data.ModifyPredictEdbBaseInfoBySourceEdb(edbInfo)
|
|
|
|
|
|
+
|
|
|
+ if edbInfo.Source == utils.DATA_SOURCE_MYSTEEL_CHEMICAL {
|
|
|
+ go data_stat.AddEdbInfoUpdateLog(req.EdbInfoId, 1, "", sysUser)
|
|
|
+ }
|
|
|
+
|
|
|
br.Ret = 200
|
|
|
br.Success = true
|
|
|
br.Msg = "保存成功"
|
|
@@ -2364,7 +2541,7 @@ func (this *EdbInfoController) EdbInfoRefresh() {
|
|
|
br.ErrMsg = "获取指标信息失败,Err:" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
- err, isAsync := data.EdbInfoRefreshAllFromBaseV2(edbInfoId, false)
|
|
|
+ err, isAsync := data.EdbInfoRefreshAllFromBaseV2(edbInfoId, false, false)
|
|
|
if err != nil {
|
|
|
br.Msg = "刷新失败"
|
|
|
br.ErrMsg = "刷新指标失败,EdbInfoRefresh Err:" + err.Error()
|
|
@@ -3047,7 +3224,7 @@ func (this *EdbInfoController) EdbInfoAllRefresh() {
|
|
|
br.ErrMsg = "数据已被删除,请刷新页面,edbInfoId:" + strconv.Itoa(edbInfoId)
|
|
|
return
|
|
|
}
|
|
|
- err, isAsync := data.EdbInfoRefreshAllFromBaseV2(edbInfoId, true)
|
|
|
+ err, isAsync := data.EdbInfoRefreshAllFromBaseV2(edbInfoId, true, false)
|
|
|
if err != nil {
|
|
|
br.Msg = "刷新失败"
|
|
|
br.ErrMsg = "刷新指标失败,EdbInfoRefreshAllFromBase Err:" + err.Error()
|
|
@@ -3117,9 +3294,9 @@ func (this *ChartInfoController) EdbInfoData() {
|
|
|
latestDateT, _ := time.Parse(utils.FormatDate, edbInfo.LatestDate)
|
|
|
maxYear = latestDateT.Year()
|
|
|
}
|
|
|
-
|
|
|
+ dataList := make([]*data_manage.EdbDataList, 0)
|
|
|
startDate, endDate = utils.GetDateByDateTypeV2(dateType, startDate, endDate, startYear, maxYear)
|
|
|
- dataList, err := data_manage.GetEdbDataList(edbInfo.Source, edbInfoId, startDate, endDate)
|
|
|
+ dataList, err = data_manage.GetEdbDataList(edbInfo.Source, edbInfo.SubSource, edbInfoId, startDate, endDate)
|
|
|
if err != nil {
|
|
|
br.Msg = "获取失败"
|
|
|
br.ErrMsg = "获取失败,Err:" + err.Error()
|
|
@@ -3578,7 +3755,7 @@ func (this *EdbInfoController) RelationEdbList() {
|
|
|
|
|
|
dataList := make([]*data_manage.EdbDataList, 0)
|
|
|
if v.EdbInfoType == 0 {
|
|
|
- dataList, err = data_manage.GetEdbDataList(v.Source, v.EdbInfoId, "", "")
|
|
|
+ dataList, err = data_manage.GetEdbDataList(v.Source, v.SubSource, v.EdbInfoId, "", "")
|
|
|
} else {
|
|
|
_, dataList, _, _, err, _ = data.GetPredictDataListByPredictEdbInfoId(v.EdbInfoId, "", "", false)
|
|
|
}
|
|
@@ -3853,7 +4030,7 @@ func (this *ChartInfoController) EdbInfoDataTb() {
|
|
|
|
|
|
startDate = startDateTime.AddDate(-1, 0, -35).Format(utils.FormatDate)
|
|
|
}
|
|
|
- tmpDataList, err := data_manage.GetEdbDataList(edbInfo.Source, edbInfoId, startDate, endDate)
|
|
|
+ tmpDataList, err := data_manage.GetEdbDataList(edbInfo.Source, edbInfo.SubSource, edbInfoId, startDate, endDate)
|
|
|
if err != nil {
|
|
|
br.Msg = "获取失败"
|
|
|
br.Msg = "获取失败,Err:" + err.Error()
|
|
@@ -4939,7 +5116,7 @@ func (this *EdbInfoController) EdbInfoExistCheck() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- if source != utils.DATA_SOURCE_WIND {
|
|
|
+ if source != utils.DATA_SOURCE_WIND && source != utils.DATA_SOURCE_THS {
|
|
|
br.Msg = "无效的数据来源"
|
|
|
return
|
|
|
}
|
|
@@ -4952,9 +5129,19 @@ func (this *EdbInfoController) EdbInfoExistCheck() {
|
|
|
edbCodeArr := strings.Split(edbCode, ",")
|
|
|
stockCodeArr := strings.Split(stockCode, ",")
|
|
|
|
|
|
+ var prefix string
|
|
|
+ if source == utils.DATA_SOURCE_WIND {
|
|
|
+ prefix = utils.WindDbWsd
|
|
|
+ } else if source == utils.DATA_SOURCE_THS {
|
|
|
+ prefix = utils.ThsDs
|
|
|
+ } else {
|
|
|
+ br.Msg = "来源错误"
|
|
|
+ br.ErrMsg = "来源错误"
|
|
|
+ return
|
|
|
+ }
|
|
|
for _, sv := range stockCodeArr {
|
|
|
for _, ev := range edbCodeArr {
|
|
|
- indexCode := utils.WindDbWsd + sv + ev
|
|
|
+ indexCode := prefix + sv + ev
|
|
|
indexCodeArr = append(indexCodeArr, indexCode)
|
|
|
}
|
|
|
}
|
|
@@ -4966,6 +5153,9 @@ func (this *EdbInfoController) EdbInfoExistCheck() {
|
|
|
}
|
|
|
var existStockCodeArr []string
|
|
|
var existEdbCodeArr []string
|
|
|
+ var existClassifyId []int
|
|
|
+ var existIndexId []int
|
|
|
+
|
|
|
for _, indexItem := range indexList {
|
|
|
for _, sv := range stockCodeArr {
|
|
|
for _, ev := range edbCodeArr {
|
|
@@ -4974,6 +5164,8 @@ func (this *EdbInfoController) EdbInfoExistCheck() {
|
|
|
}
|
|
|
if strings.Contains(indexItem.EdbCode, ev) {
|
|
|
existEdbCodeArr = append(existEdbCodeArr, ev)
|
|
|
+ existClassifyId = append(existClassifyId, indexItem.ClassifyId)
|
|
|
+ existIndexId = append(existIndexId, indexItem.EdbInfoId)
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -4985,8 +5177,188 @@ func (this *EdbInfoController) EdbInfoExistCheck() {
|
|
|
}
|
|
|
resp.ExistEdbCodeArr = existEdbCodeArr
|
|
|
resp.ExistStockCodeArr = existStockCodeArr
|
|
|
+ resp.ExistClassifyId = existClassifyId
|
|
|
+ resp.ExistIndexId = existIndexId
|
|
|
+ resp.ExistEdbInfo = indexList
|
|
|
br.Ret = 200
|
|
|
br.Success = true
|
|
|
br.Msg = "获取成功"
|
|
|
br.Data = resp
|
|
|
}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func (this *EdbInfoController) EdbInfoBatchAdd() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+ deleteCache := true
|
|
|
+ cacheKey := "CACHE_EDB_INFO_BATCH_ADD_" + strconv.Itoa(sysUser.AdminId)
|
|
|
+ defer func() {
|
|
|
+ if deleteCache {
|
|
|
+ utils.Rc.Delete(cacheKey)
|
|
|
+ }
|
|
|
+ }()
|
|
|
+ if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
|
|
|
+ deleteCache = false
|
|
|
+ br.Msg = "系统处理中,请稍后重试!"
|
|
|
+ br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(this.Ctx.Input.RequestBody)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var req data_manage.BatchAddEdbInfoReq
|
|
|
+ err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "参数解析异常!"
|
|
|
+ br.ErrMsg = "参数解析失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ resp := new(data_manage.AddEdbInfoResp)
|
|
|
+
|
|
|
+ var edbNames string
|
|
|
+ for _, v := range req.BatchList {
|
|
|
+ edbNames += "'" + v.EdbName + "',"
|
|
|
+ }
|
|
|
+ edbNames = strings.Trim(edbNames, ",")
|
|
|
+ infoList, err := data_manage.GetEdbInfoByNames(edbNames)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "查询指标名称重复错误!"
|
|
|
+ br.ErrMsg = "GetEdbInfoByNames,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(infoList) > 0 {
|
|
|
+ for _, v := range infoList {
|
|
|
+ resp.ExistEdbName = append(resp.ExistEdbName, v.EdbName)
|
|
|
+ }
|
|
|
+ br.Data = resp
|
|
|
+ br.Msg = "指标名称重复!"
|
|
|
+ br.ErrMsg = "指标名称重复"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ for k, v := range req.BatchList {
|
|
|
+ v.EdbName = strings.Trim(v.EdbName, " ")
|
|
|
+ v.EdbCode = strings.Trim(v.EdbCode, " ")
|
|
|
+ v.StockCode = strings.Trim(v.StockCode, " ")
|
|
|
+
|
|
|
+ if v.Source <= 0 {
|
|
|
+ br.Msg = "无效的数据来源"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if v.EdbCode == "" {
|
|
|
+ br.Msg = "指标ID不能为空"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if v.StockCode == "" {
|
|
|
+ br.Msg = "证券代码不能为空"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if v.EdbName == "" {
|
|
|
+ br.Msg = "指标名称不能为空"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if v.Frequency == "" {
|
|
|
+ br.Msg = "频率不能为空"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if v.ClassifyId <= 0 {
|
|
|
+ br.Msg = "请选择分类"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ edbInfoItem := new(data_manage.EdbInfo)
|
|
|
+ edbInfoItem.Source = v.Source
|
|
|
+ switch v.Source {
|
|
|
+ case utils.DATA_SOURCE_WIND:
|
|
|
+ edbInfoItem.SourceName = "wind"
|
|
|
+ edbInfoItem.EdbCode = utils.WindDbWsd + v.StockCode + v.EdbCode
|
|
|
+ case utils.DATA_SOURCE_THS:
|
|
|
+ edbInfoItem.SourceName = "ths"
|
|
|
+ edbInfoItem.EdbCode = utils.ThsDs + v.StockCode + v.EdbCode
|
|
|
+ }
|
|
|
+ edbInfoItem.SubSource = 1
|
|
|
+ edbInfoItem.SubSourceName = "日期序列"
|
|
|
+ edbInfoItem.EdbName = v.EdbName
|
|
|
+ edbInfoItem.Frequency = v.Frequency
|
|
|
+ edbInfoItem.Unit = v.Unit
|
|
|
+ edbInfoItem.ClassifyId = v.ClassifyId
|
|
|
+ edbInfoItem.SysUserId = sysUser.AdminId
|
|
|
+ edbInfoItem.SysUserRealName = sysUser.RealName
|
|
|
+ edbInfoItem.IndicatorCode = v.EdbCode
|
|
|
+ edbInfoItem.StockCode = v.StockCode
|
|
|
+
|
|
|
+
|
|
|
+ edbInfo, err, errMsg, isSendEmail := data.EdbInfoWsdAdd(edbInfoItem)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "保存失败"
|
|
|
+ if errMsg != `` {
|
|
|
+ br.Msg = errMsg
|
|
|
+ }
|
|
|
+ br.ErrMsg = err.Error()
|
|
|
+ br.IsSendEmail = isSendEmail
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ {
|
|
|
+ edbLog := new(data_manage.EdbInfoLog)
|
|
|
+ edbLog.EdbInfoId = edbInfo.EdbInfoId
|
|
|
+ edbLog.SourceName = edbInfo.SourceName
|
|
|
+ edbLog.Source = edbInfo.Source
|
|
|
+ edbLog.EdbCode = edbInfo.EdbCode
|
|
|
+ edbLog.EdbName = edbInfo.EdbName
|
|
|
+ edbLog.ClassifyId = edbInfo.ClassifyId
|
|
|
+ edbLog.SysUserId = sysUser.AdminId
|
|
|
+ edbLog.SysUserRealName = sysUser.RealName
|
|
|
+ edbLog.CreateTime = time.Now()
|
|
|
+ edbLog.Content = string(this.Ctx.Input.RequestBody)
|
|
|
+ edbLog.Status = "新增指标"
|
|
|
+ edbLog.Method = this.Ctx.Input.URI()
|
|
|
+ go data_manage.AddEdbInfoLog(edbLog)
|
|
|
+ }
|
|
|
+
|
|
|
+ if k <= 0 {
|
|
|
+ resp.EdbInfoId = edbInfo.EdbInfoId
|
|
|
+ resp.UniqueCode = edbInfo.UniqueCode
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ adminItem, e := system.GetSysAdminById(sysUser.AdminId)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = "获取系统用户数据失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if utils.BusinessCode == utils.BusinessCodeSandbox && adminItem.DepartmentName == "ETA试用客户" {
|
|
|
+ go func() {
|
|
|
+ var r etaTrialService.EtaTrialUserReq
|
|
|
+ r.Mobile = adminItem.Mobile
|
|
|
+ _, _ = etaTrialService.UpdateUserIndexNum(r)
|
|
|
+ }()
|
|
|
+ }
|
|
|
+
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "保存成功"
|
|
|
+ br.Data = resp
|
|
|
+ br.IsAddLog = true
|
|
|
+}
|