|
@@ -295,121 +295,27 @@ func (this *PredictEdbInfoController) List() {
|
|
|
br.ErrMsg = "查找预测指标关联信息失败"
|
|
|
return
|
|
|
}
|
|
|
- if edbInfoItem.EdbType == 1 {
|
|
|
- //普通的预测指标
|
|
|
- // 查找该预测指标配置
|
|
|
- predictEdbConfList, err := data_manage.GetPredictEdbConfListById(edbInfoId)
|
|
|
+
|
|
|
+ //获取指标数据(实际已生成)
|
|
|
+ {
|
|
|
+ dataCount, dataList, err := data.GetPageData(edbInfoItem.EdbInfoId, edbInfoItem.Source, edbInfoItem.SubSource, edbInfoItem.LatestDate, startSize, pageSize)
|
|
|
if err != nil && !utils.IsErrNoRow(err) {
|
|
|
- br.Msg = "获取失败"
|
|
|
- br.ErrMsg = "获取预测指标配置信息失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- if len(predictEdbConfList) == 0 {
|
|
|
- br.Msg = "找不到该预测指标配置"
|
|
|
- br.ErrMsg = "找不到该预测指标配置"
|
|
|
+ br.Msg = "获取指标信息失败"
|
|
|
+ br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
- predictEdbConf := predictEdbConfList[0]
|
|
|
-
|
|
|
- //预测数据的配置
|
|
|
- edbInfoItem.RuleType = predictEdbConf.RuleType
|
|
|
- edbInfoItem.FixedValue = predictEdbConf.FixedValue
|
|
|
+ page = paging.GetPaging(currentIndex, pageSize, dataCount)
|
|
|
+ edbInfoItem.DataList = dataList
|
|
|
+ }
|
|
|
|
|
|
- // 来源指标
|
|
|
- //sourceEdbInfoId := sourceEdbInfoCalculateMappingList[0].FromEdbInfoId
|
|
|
- sourceEdbInfoId := predictEdbConf.SourceEdbInfoId
|
|
|
- sourceEdbInfoItem, err := data_manage.GetEdbInfoById(sourceEdbInfoId)
|
|
|
+ // 第一页才需要 获取预测指标未来的数据
|
|
|
+ if currentIndex == 1 {
|
|
|
+ predictDataList, err = data_manage.GetAllEdbDataListData(edbInfoItem.EdbInfoId, edbInfoItem.Source, edbInfoItem.SubSource, edbInfoItem.LatestDate)
|
|
|
if err != nil {
|
|
|
- br.Msg = "获取来源指标信息失败"
|
|
|
- br.ErrMsg = "获取来源指标信息失败"
|
|
|
- if !utils.IsErrNoRow(err) {
|
|
|
- br.ErrMsg = "获取来源指标信息失败,Err:" + err.Error()
|
|
|
- }
|
|
|
- br.Success = true
|
|
|
+ br.Msg = "获取预测指标数据失败"
|
|
|
+ br.ErrMsg = "获取预测指标数据失败" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
-
|
|
|
- //获取指标数据(实际已生成)
|
|
|
- {
|
|
|
- dataCount, dataList, err := data.GetPageData(sourceEdbInfoItem.EdbInfoId, sourceEdbInfoItem.Source, sourceEdbInfoItem.SubSource, "", startSize, pageSize)
|
|
|
- if err != nil && !utils.IsErrNoRow(err) {
|
|
|
- br.Msg = "获取指标信息失败"
|
|
|
- br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- page = paging.GetPaging(currentIndex, pageSize, dataCount)
|
|
|
- edbInfoItem.DataList = dataList
|
|
|
- }
|
|
|
-
|
|
|
- // 第一页才需要 获取预测指标未来的数据
|
|
|
- if currentIndex == 1 {
|
|
|
- allDataList, err := data_manage.GetEdbDataList(sourceEdbInfoItem.Source, sourceEdbInfoItem.SubSource, sourceEdbInfoItem.EdbInfoId, "", "")
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取失败"
|
|
|
- br.Msg = "获取失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- predictEdbConfDataList := make([]data_manage.PredictEdbConfAndData, 0)
|
|
|
- for _, v := range predictEdbConfList {
|
|
|
- predictEdbConfDataList = append(predictEdbConfDataList, data_manage.PredictEdbConfAndData{
|
|
|
- ConfigId: v.ConfigId,
|
|
|
- PredictEdbInfoId: v.PredictEdbInfoId,
|
|
|
- SourceEdbInfoId: v.SourceEdbInfoId,
|
|
|
- RuleType: v.RuleType,
|
|
|
- FixedValue: v.FixedValue,
|
|
|
- Value: v.Value,
|
|
|
- EndDate: v.EndDate,
|
|
|
- ModifyTime: v.ModifyTime,
|
|
|
- CreateTime: v.CreateTime,
|
|
|
- DataList: make([]*data_manage.EdbDataList, 0),
|
|
|
- })
|
|
|
- }
|
|
|
- tmpPredictDataList, _, _, err, _ := data.GetChartPredictEdbInfoDataListByConfList(predictEdbConfDataList, sourceEdbInfoItem.LatestDate, sourceEdbInfoItem.LatestDate, edbInfoItem.EndDate, sourceEdbInfoItem.Frequency, edbInfoItem.DataDateType, allDataList)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取预测指标数据失败"
|
|
|
- br.ErrMsg = "获取预测指标数据失败" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- lenTmpPredictDataList := len(tmpPredictDataList)
|
|
|
- if lenTmpPredictDataList > 0 {
|
|
|
- for i := lenTmpPredictDataList - 1; i >= 0; i-- {
|
|
|
- v := tmpPredictDataList[i]
|
|
|
- predictDataList = append(predictDataList, &data_manage.EdbData{
|
|
|
- EdbDataId: v.EdbDataId,
|
|
|
- EdbInfoId: v.EdbInfoId,
|
|
|
- DataTime: v.DataTime,
|
|
|
- Value: v.Value,
|
|
|
- })
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- } else {
|
|
|
- //获取指标数据(实际已生成)
|
|
|
- {
|
|
|
- dataCount, dataList, err := data.GetPageData(edbInfoItem.EdbInfoId, edbInfoItem.Source, edbInfoItem.SubSource, edbInfoItem.LatestDate, startSize, pageSize)
|
|
|
- if err != nil && !utils.IsErrNoRow(err) {
|
|
|
- br.Msg = "获取指标信息失败"
|
|
|
- br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- page = paging.GetPaging(currentIndex, pageSize, dataCount)
|
|
|
- edbInfoItem.DataList = dataList
|
|
|
- }
|
|
|
-
|
|
|
- // 第一页才需要 获取预测指标未来的数据
|
|
|
- if currentIndex == 1 {
|
|
|
- predictDataList, err = data_manage.GetAllEdbDataListData(edbInfoItem.EdbInfoId, edbInfoItem.Source, edbInfoItem.SubSource, edbInfoItem.LatestDate)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取指标信息失败"
|
|
|
- br.ErrMsg = "获取指标数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取预测指标数据失败"
|
|
|
- br.ErrMsg = "获取预测指标数据失败" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- }
|
|
|
}
|
|
|
|
|
|
// 如果预测数据没有,那么返回空数组
|
|
@@ -480,7 +386,7 @@ func (this *PredictEdbInfoController) Add() {
|
|
|
cacheKey := "CACHE_EDB_INFO_ADD_" + strconv.Itoa(sysUser.AdminId)
|
|
|
defer func() {
|
|
|
if deleteCache {
|
|
|
- utils.Rc.Delete(cacheKey)
|
|
|
+ _ = utils.Rc.Delete(cacheKey)
|
|
|
}
|
|
|
}()
|
|
|
if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
|