|
@@ -4,7 +4,7 @@ import (
|
|
|
"errors"
|
|
|
"eta/eta_chart_lib/models"
|
|
|
"eta/eta_chart_lib/models/data_manage"
|
|
|
- "eta/eta_chart_lib/models/data_manage/future_good"
|
|
|
+ future_good2 "eta/eta_chart_lib/models/data_manage/future_good"
|
|
|
"eta/eta_chart_lib/services/alarm_msg"
|
|
|
"eta/eta_chart_lib/services/data"
|
|
|
"eta/eta_chart_lib/utils"
|
|
@@ -16,42 +16,47 @@ import (
|
|
|
)
|
|
|
|
|
|
// GetChartEdbData 获取图表的指标数据
|
|
|
-func GetChartEdbData(chartInfoId int, startDate, endDate string, edbInfoMapping, futureGoodEdbInfoMapping *models.ChartEdbInfoMapping, barChartInfoDateList []data_manage.BarChartInfoDateReq) (barConfigEdbInfoIdList []data_manage.BarChartInfoEdbItemReq, edbList []*models.ChartEdbInfoMapping, xEdbIdValue []int, xDataList []models.XData, yDataList []models.YData, err error) {
|
|
|
+func GetChartEdbData(chartInfoId int, startDate, endDate string, baseEdbInfoMapping *models.ChartEdbInfoMapping, edbInfoMappingList []*models.ChartEdbInfoMapping, futureGoodEdbInfoMapping *models.ChartEdbInfoMapping, barChartInfoConf data_manage.FutureGoodBarChartInfoReq, needData bool) (barConfigEdbInfoIdList []data_manage.BarChartInfoEdbItemReq, edbList []*models.ChartEdbInfoMapping, xEdbIdValue []int, xDataList []data_manage.XData, yDataList []models.YData, err error) {
|
|
|
edbList = make([]*models.ChartEdbInfoMapping, 0)
|
|
|
-
|
|
|
+ barChartInfoDateList := barChartInfoConf.DateList
|
|
|
+ baseEdbInfoId := barChartInfoConf.BaseEdbInfoId
|
|
|
if futureGoodEdbInfoMapping == nil {
|
|
|
err = errors.New("商品指标未选取")
|
|
|
return
|
|
|
}
|
|
|
- if edbInfoMapping == nil {
|
|
|
+ if len(edbInfoMappingList) == 0 {
|
|
|
err = errors.New("ETA指标未选取")
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
// 指标对应的所有数据
|
|
|
edbDataListMap := make(map[int][]*models.EdbDataList)
|
|
|
|
|
|
- item := new(data_manage.ChartEdbInfoMapping)
|
|
|
- edbInfoMapping.FrequencyEn = data.GetFrequencyEn(edbInfoMapping.Frequency)
|
|
|
+ // todo item
|
|
|
+ //item := new(models.ChartEdbInfoMapping)
|
|
|
|
|
|
- if edbInfoMapping.Unit == `无` {
|
|
|
- edbInfoMapping.Unit = ``
|
|
|
- }
|
|
|
if futureGoodEdbInfoMapping.Unit == `无` {
|
|
|
futureGoodEdbInfoMapping.Unit = ``
|
|
|
}
|
|
|
|
|
|
if chartInfoId <= 0 {
|
|
|
- edbInfoMapping.IsAxis = 1
|
|
|
- edbInfoMapping.LeadValue = 0
|
|
|
- edbInfoMapping.LeadUnit = ""
|
|
|
- edbInfoMapping.ChartEdbMappingId = 0
|
|
|
- edbInfoMapping.ChartInfoId = 0
|
|
|
- edbInfoMapping.IsOrder = false
|
|
|
- edbInfoMapping.EdbInfoType = 1
|
|
|
- edbInfoMapping.ChartStyle = ""
|
|
|
- edbInfoMapping.ChartColor = ""
|
|
|
- edbInfoMapping.ChartWidth = 0
|
|
|
-
|
|
|
+ for k, edbInfoMapping := range edbInfoMappingList {
|
|
|
+ edbInfoMapping.FrequencyEn = data.GetFrequencyEn(edbInfoMapping.Frequency)
|
|
|
+ if edbInfoMapping.Unit == `无` {
|
|
|
+ edbInfoMapping.Unit = ``
|
|
|
+ }
|
|
|
+ edbInfoMapping.IsAxis = 1
|
|
|
+ edbInfoMapping.LeadValue = 0
|
|
|
+ edbInfoMapping.LeadUnit = ""
|
|
|
+ edbInfoMapping.ChartEdbMappingId = 0
|
|
|
+ edbInfoMapping.ChartInfoId = 0
|
|
|
+ edbInfoMapping.IsOrder = false
|
|
|
+ edbInfoMapping.EdbInfoType = 1
|
|
|
+ edbInfoMapping.ChartStyle = ""
|
|
|
+ edbInfoMapping.ChartColor = ""
|
|
|
+ edbInfoMapping.ChartWidth = 0
|
|
|
+ edbInfoMappingList[k] = edbInfoMapping
|
|
|
+ }
|
|
|
futureGoodEdbInfoMapping.IsAxis = 1
|
|
|
futureGoodEdbInfoMapping.LeadValue = 0
|
|
|
futureGoodEdbInfoMapping.LeadUnit = ""
|
|
@@ -63,37 +68,53 @@ func GetChartEdbData(chartInfoId int, startDate, endDate string, edbInfoMapping,
|
|
|
futureGoodEdbInfoMapping.ChartColor = ""
|
|
|
futureGoodEdbInfoMapping.ChartWidth = 0
|
|
|
} else {
|
|
|
- edbInfoMapping.LeadUnitEn = data.GetLeadUnitEn(edbInfoMapping.LeadUnit)
|
|
|
+ for k, edbInfoMapping := range edbInfoMappingList {
|
|
|
+ edbInfoMapping.FrequencyEn = data.GetFrequencyEn(edbInfoMapping.Frequency)
|
|
|
+ if edbInfoMapping.Unit == `无` {
|
|
|
+ edbInfoMapping.Unit = ``
|
|
|
+ }
|
|
|
+ edbInfoMapping.LeadUnitEn = data.GetLeadUnitEn(edbInfoMapping.LeadUnit)
|
|
|
+ edbInfoMappingList[k] = edbInfoMapping
|
|
|
+ }
|
|
|
futureGoodEdbInfoMapping.LeadUnitEn = data.GetLeadUnitEn(futureGoodEdbInfoMapping.LeadUnit)
|
|
|
}
|
|
|
|
|
|
+ //查询横轴配置项
|
|
|
+ xDataItemMap := make(map[int]data_manage.XData)
|
|
|
+ for k, v := range barChartInfoConf.XDataList {
|
|
|
+ xDataItemMap[k] = v
|
|
|
+ }
|
|
|
+
|
|
|
// 普通的指标数据
|
|
|
{
|
|
|
- dataList := make([]*models.EdbDataList, 0)
|
|
|
-
|
|
|
- dataList, err = models.GetEdbDataList(edbInfoMapping.Source, edbInfoMapping.SubSource, edbInfoMapping.EdbInfoId, startDate, endDate)
|
|
|
- edbDataListMap[edbInfoMapping.EdbInfoId] = dataList
|
|
|
- item.DataList = dataList
|
|
|
-
|
|
|
- edbList = append(edbList, edbInfoMapping)
|
|
|
-
|
|
|
- barConfigEdbInfoIdList = append(barConfigEdbInfoIdList, data_manage.BarChartInfoEdbItemReq{
|
|
|
- EdbInfoId: edbInfoMapping.EdbInfoId,
|
|
|
- //Name: edbInfoMapping.EdbName,
|
|
|
- Name: "现货价",
|
|
|
- NameEn: "Spot Price",
|
|
|
- Source: edbInfoMapping.Source,
|
|
|
- })
|
|
|
+ edbList = edbInfoMappingList
|
|
|
+
|
|
|
+ for k, edbInfoMapping := range edbInfoMappingList {
|
|
|
+ tmp := data_manage.BarChartInfoEdbItemReq{
|
|
|
+ EdbInfoId: edbInfoMapping.EdbInfoId,
|
|
|
+ Name: edbInfoMapping.EdbName,
|
|
|
+ NameEn: edbInfoMapping.EdbNameEn,
|
|
|
+ Source: edbInfoMapping.Source,
|
|
|
+ }
|
|
|
+ // 如果有配置,则用配置中的指标名称替换
|
|
|
+ xItem, ok := xDataItemMap[k]
|
|
|
+ if ok && xItem.Name != "" {
|
|
|
+ tmp.Name = xItem.Name
|
|
|
+ tmp.NameEn = xItem.NameEn
|
|
|
+ tmp.IsHide = xItem.IsHide
|
|
|
+ }
|
|
|
+ barConfigEdbInfoIdList = append(barConfigEdbInfoIdList, tmp)
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
// 获取主力合约和最新日期
|
|
|
- var zlFutureGoodEdbInfo *future_good.FutureGoodEdbInfo
|
|
|
+ var zlFutureGoodEdbInfo *future_good2.FutureGoodEdbInfo
|
|
|
var latestDate string // 最新日期是这个
|
|
|
var regionType string // 交易所来源:“国内”,“海外”
|
|
|
var futureGoodEdbType int
|
|
|
{
|
|
|
// 寻找主力合约
|
|
|
- zlFutureGoodEdbInfo, err = future_good.GetFutureGoodEdbInfo(futureGoodEdbInfoMapping.EdbInfoId)
|
|
|
+ zlFutureGoodEdbInfo, err = future_good2.GetFutureGoodEdbInfo(futureGoodEdbInfoMapping.EdbInfoId)
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -102,7 +123,7 @@ func GetChartEdbData(chartInfoId int, startDate, endDate string, edbInfoMapping,
|
|
|
|
|
|
// 如果当前合约配置的 "画图时,日期来源的指标id" 并不是自己的话,那么就去查找对应配置的合约
|
|
|
if zlFutureGoodEdbInfo.DateSourceId != zlFutureGoodEdbInfo.FutureGoodEdbInfoId {
|
|
|
- sourceDateFutureGoodEdbInfo, tmpErr := future_good.GetFutureGoodEdbInfo(zlFutureGoodEdbInfo.DateSourceId)
|
|
|
+ sourceDateFutureGoodEdbInfo, tmpErr := future_good2.GetFutureGoodEdbInfo(zlFutureGoodEdbInfo.DateSourceId)
|
|
|
if tmpErr != nil {
|
|
|
err = tmpErr
|
|
|
return
|
|
@@ -118,7 +139,7 @@ func GetChartEdbData(chartInfoId int, startDate, endDate string, edbInfoMapping,
|
|
|
}
|
|
|
|
|
|
// 获取期货指标以及期货数据
|
|
|
- tmpFutureGoodEdbInfoList, err := future_good.GetFutureGoodEdbInfoListByParentId(futureGoodEdbInfoMapping.EdbInfoId)
|
|
|
+ tmpFutureGoodEdbInfoList, err := future_good2.GetFutureGoodEdbInfoListByParentId(futureGoodEdbInfoMapping.EdbInfoId)
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -139,30 +160,30 @@ func GetChartEdbData(chartInfoId int, startDate, endDate string, edbInfoMapping,
|
|
|
EdbName: v.FutureGoodEdbName,
|
|
|
EdbAliasName: v.FutureGoodEdbName,
|
|
|
EdbNameEn: v.FutureGoodEdbNameEn,
|
|
|
- EdbType: edbInfoMapping.EdbType,
|
|
|
- Frequency: edbInfoMapping.Frequency,
|
|
|
- FrequencyEn: edbInfoMapping.FrequencyEn,
|
|
|
- Unit: edbInfoMapping.Unit,
|
|
|
- UnitEn: edbInfoMapping.UnitEn,
|
|
|
+ EdbType: baseEdbInfoMapping.EdbType, //todo baseEdbInfoMapping
|
|
|
+ Frequency: baseEdbInfoMapping.Frequency,
|
|
|
+ FrequencyEn: baseEdbInfoMapping.FrequencyEn,
|
|
|
+ Unit: baseEdbInfoMapping.Unit,
|
|
|
+ UnitEn: baseEdbInfoMapping.UnitEn,
|
|
|
StartDate: v.StartDate,
|
|
|
EndDate: v.EndDate,
|
|
|
ModifyTime: v.ModifyTime.Format(utils.FormatDateTime),
|
|
|
ChartEdbMappingId: v.FutureGoodEdbInfoId,
|
|
|
- ChartInfoId: edbInfoMapping.ChartInfoId,
|
|
|
+ ChartInfoId: baseEdbInfoMapping.ChartInfoId,
|
|
|
MaxData: v.MaxValue,
|
|
|
MinData: v.MinValue,
|
|
|
- IsOrder: edbInfoMapping.IsOrder,
|
|
|
- IsAxis: edbInfoMapping.IsAxis,
|
|
|
- EdbInfoType: edbInfoMapping.EdbInfoType,
|
|
|
- EdbInfoCategoryType: edbInfoMapping.EdbInfoCategoryType,
|
|
|
- LeadValue: edbInfoMapping.LeadValue,
|
|
|
- LeadUnit: edbInfoMapping.LeadUnit,
|
|
|
- LeadUnitEn: edbInfoMapping.LeadUnitEn,
|
|
|
- ChartStyle: edbInfoMapping.ChartStyle,
|
|
|
- ChartColor: edbInfoMapping.ChartColor,
|
|
|
- PredictChartColor: edbInfoMapping.PredictChartColor,
|
|
|
- ChartWidth: edbInfoMapping.ChartWidth,
|
|
|
- ChartType: edbInfoMapping.ChartType,
|
|
|
+ IsOrder: baseEdbInfoMapping.IsOrder,
|
|
|
+ IsAxis: baseEdbInfoMapping.IsAxis,
|
|
|
+ EdbInfoType: baseEdbInfoMapping.EdbInfoType,
|
|
|
+ EdbInfoCategoryType: baseEdbInfoMapping.EdbInfoCategoryType,
|
|
|
+ LeadValue: baseEdbInfoMapping.LeadValue,
|
|
|
+ LeadUnit: baseEdbInfoMapping.LeadUnit,
|
|
|
+ LeadUnitEn: baseEdbInfoMapping.LeadUnitEn,
|
|
|
+ ChartStyle: baseEdbInfoMapping.ChartStyle,
|
|
|
+ ChartColor: baseEdbInfoMapping.ChartColor,
|
|
|
+ PredictChartColor: baseEdbInfoMapping.PredictChartColor,
|
|
|
+ ChartWidth: baseEdbInfoMapping.ChartWidth,
|
|
|
+ ChartType: baseEdbInfoMapping.ChartType,
|
|
|
LatestDate: v.LatestDate.Format(utils.FormatDateTime),
|
|
|
LatestValue: v.LatestValue,
|
|
|
UniqueCode: futureGoodEdbInfoMapping.UniqueCode + strconv.Itoa(k),
|
|
@@ -173,19 +194,93 @@ func GetChartEdbData(chartInfoId int, startDate, endDate string, edbInfoMapping,
|
|
|
}
|
|
|
futureGoodMappingList = append(futureGoodMappingList, newMappingInfo)
|
|
|
|
|
|
- barConfigEdbInfoIdList = append(barConfigEdbInfoIdList, data_manage.BarChartInfoEdbItemReq{
|
|
|
+ tmp := data_manage.BarChartInfoEdbItemReq{
|
|
|
EdbInfoId: newMappingInfo.EdbInfoId,
|
|
|
Name: fmt.Sprint("M+", v.Month),
|
|
|
NameEn: fmt.Sprint("M+", v.Month),
|
|
|
Source: newMappingInfo.Source,
|
|
|
- })
|
|
|
+ }
|
|
|
+ // 判断如果有配置,需要替换为配置内容
|
|
|
+ xItem, ok := xDataItemMap[k]
|
|
|
+ if ok && xItem.Name != "" {
|
|
|
+ tmp.Name = xItem.Name
|
|
|
+ tmp.NameEn = xItem.NameEn
|
|
|
+ tmp.IsHide = xItem.IsHide
|
|
|
+ }
|
|
|
+ barConfigEdbInfoIdList = append(barConfigEdbInfoIdList, tmp)
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ if regionType == `海外` {
|
|
|
+ zlFutureGoodEdbMapping := &models.ChartEdbInfoMapping{
|
|
|
+ EdbInfoId: zlFutureGoodEdbInfo.FutureGoodEdbInfoId,
|
|
|
+ SourceName: zlFutureGoodEdbInfo.Exchange,
|
|
|
+ Source: 0,
|
|
|
+ EdbCode: zlFutureGoodEdbInfo.FutureGoodEdbCode,
|
|
|
+ EdbName: zlFutureGoodEdbInfo.FutureGoodEdbName,
|
|
|
+ EdbAliasName: zlFutureGoodEdbInfo.FutureGoodEdbName,
|
|
|
+ EdbNameEn: zlFutureGoodEdbInfo.FutureGoodEdbNameEn,
|
|
|
+ EdbType: baseEdbInfoMapping.EdbType,
|
|
|
+ Frequency: baseEdbInfoMapping.Frequency,
|
|
|
+ FrequencyEn: baseEdbInfoMapping.FrequencyEn,
|
|
|
+ Unit: baseEdbInfoMapping.Unit,
|
|
|
+ UnitEn: baseEdbInfoMapping.UnitEn,
|
|
|
+ StartDate: zlFutureGoodEdbInfo.StartDate,
|
|
|
+ EndDate: zlFutureGoodEdbInfo.EndDate,
|
|
|
+ ModifyTime: zlFutureGoodEdbInfo.ModifyTime.Format(utils.FormatDateTime),
|
|
|
+ ChartEdbMappingId: zlFutureGoodEdbInfo.FutureGoodEdbInfoId,
|
|
|
+ ChartInfoId: baseEdbInfoMapping.ChartInfoId,
|
|
|
+ MaxData: zlFutureGoodEdbInfo.MaxValue,
|
|
|
+ MinData: zlFutureGoodEdbInfo.MinValue,
|
|
|
+ IsOrder: baseEdbInfoMapping.IsOrder,
|
|
|
+ IsAxis: baseEdbInfoMapping.IsAxis,
|
|
|
+ EdbInfoType: baseEdbInfoMapping.EdbInfoType,
|
|
|
+ EdbInfoCategoryType: baseEdbInfoMapping.EdbInfoCategoryType,
|
|
|
+ LeadValue: baseEdbInfoMapping.LeadValue,
|
|
|
+ LeadUnit: baseEdbInfoMapping.LeadUnit,
|
|
|
+ LeadUnitEn: baseEdbInfoMapping.LeadUnitEn,
|
|
|
+ ChartStyle: baseEdbInfoMapping.ChartStyle,
|
|
|
+ ChartColor: baseEdbInfoMapping.ChartColor,
|
|
|
+ PredictChartColor: baseEdbInfoMapping.PredictChartColor,
|
|
|
+ ChartWidth: baseEdbInfoMapping.ChartWidth,
|
|
|
+ ChartType: baseEdbInfoMapping.ChartType,
|
|
|
+ LatestDate: zlFutureGoodEdbInfo.LatestDate.Format(utils.FormatDateTime),
|
|
|
+ LatestValue: zlFutureGoodEdbInfo.LatestValue,
|
|
|
+ UniqueCode: futureGoodEdbInfoMapping.UniqueCode + strconv.Itoa(0),
|
|
|
+ MinValue: zlFutureGoodEdbInfo.MinValue,
|
|
|
+ MaxValue: zlFutureGoodEdbInfo.MaxValue,
|
|
|
+ DataList: nil,
|
|
|
+ IsNullData: false,
|
|
|
+ }
|
|
|
+ edbList = append(edbList, zlFutureGoodEdbMapping)
|
|
|
+ edbList = append(edbList, futureGoodMappingList...)
|
|
|
+ } else {
|
|
|
+ edbList = append(edbList, futureGoodMappingList...)
|
|
|
+ }
|
|
|
+
|
|
|
+ if !needData {
|
|
|
+ return
|
|
|
}
|
|
|
|
|
|
// 获取数据
|
|
|
+
|
|
|
+ // 现货数据
|
|
|
+ for _, edbInfoMapping := range edbInfoMappingList {
|
|
|
+ dataList := make([]*models.EdbDataList, 0)
|
|
|
+ dataList, err = models.GetEdbDataList(edbInfoMapping.Source, edbInfoMapping.SubSource, edbInfoMapping.EdbInfoId, startDate, endDate)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ edbDataListMap[edbInfoMapping.EdbInfoId] = dataList
|
|
|
+ // todo item
|
|
|
+ //item.DataList = dataList
|
|
|
+ }
|
|
|
+
|
|
|
+ // 期货数据
|
|
|
for _, v := range futureGoodMappingList {
|
|
|
dataList := make([]*models.EdbDataList, 0)
|
|
|
|
|
|
- tmpDataList, tmpErr := future_good.GetFutureGoodEdbDataListByDate(v.EdbInfoId, startDate, endDate)
|
|
|
+ tmpDataList, tmpErr := future_good2.GetFutureGoodEdbDataListByDate(v.EdbInfoId, startDate, endDate)
|
|
|
if tmpErr != nil {
|
|
|
return
|
|
|
}
|
|
@@ -202,18 +297,22 @@ func GetChartEdbData(chartInfoId int, startDate, endDate string, edbInfoMapping,
|
|
|
v.DataList = dataList
|
|
|
}
|
|
|
|
|
|
- edbList = append(edbList, futureGoodMappingList...)
|
|
|
-
|
|
|
- xEdbIdValue, yDataList, err = BarChartData(edbList[0], futureGoodEdbInfoList, edbDataListMap, barChartInfoDateList, regionType, edbInfoMapping.EndDate)
|
|
|
+ xEdbIdValue, yDataList, err = BarChartData(baseEdbInfoMapping, edbInfoMappingList, futureGoodEdbInfoList, edbDataListMap, barChartInfoDateList, regionType, baseEdbInfoMapping.EndDate)
|
|
|
|
|
|
- xDataList = []models.XData{
|
|
|
- {
|
|
|
- Name: "现货价",
|
|
|
- NameEn: "Spot Price",
|
|
|
- },
|
|
|
+ if len(barChartInfoConf.XDataList) > 0 {
|
|
|
+ xDataList = barChartInfoConf.XDataList
|
|
|
+ } else {
|
|
|
+ for _, v := range edbInfoMappingList {
|
|
|
+ xDataList = append(xDataList, data_manage.XData{
|
|
|
+ Name: v.EdbName,
|
|
|
+ NameEn: v.EdbNameEn,
|
|
|
+ IsHide: 0,
|
|
|
+ })
|
|
|
+ }
|
|
|
}
|
|
|
- //yDataList =make([]data_manage.YData,0)
|
|
|
- //data_manage.YData{
|
|
|
+
|
|
|
+ //yDataList =make([]models.YData,0)
|
|
|
+ //models.YData{
|
|
|
// Date: "",
|
|
|
// Color: "",
|
|
|
// Name: "",
|
|
@@ -242,13 +341,12 @@ func GetChartEdbData(chartInfoId int, startDate, endDate string, edbInfoMapping,
|
|
|
|
|
|
// 基础指标
|
|
|
{
|
|
|
- baseEdbInfId := edbList[0].EdbInfoId
|
|
|
- edbInfoIdList = append(edbInfoIdList, baseEdbInfId)
|
|
|
- tmpVal, ok := yDataMap[baseEdbInfId]
|
|
|
+ edbInfoIdList = append(edbInfoIdList, baseEdbInfoId)
|
|
|
+ tmpVal, ok := yDataMap[baseEdbInfoId]
|
|
|
valueList = append(valueList, tmpVal)
|
|
|
if !ok || tmpVal == 0 {
|
|
|
- noDataEdbInfoIdList = append(noDataEdbInfoIdList, baseEdbInfId)
|
|
|
- noDataEdbIdMap[baseEdbInfId] = baseEdbInfId
|
|
|
+ noDataEdbInfoIdList = append(noDataEdbInfoIdList, baseEdbInfoId)
|
|
|
+ noDataEdbIdMap[baseEdbInfoId] = baseEdbInfoId
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -312,29 +410,38 @@ func GetChartEdbData(chartInfoId int, startDate, endDate string, edbInfoMapping,
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
- xDataList = append(xDataList, tmpXDataList...)
|
|
|
+ if len(barChartInfoConf.XDataList) == 0 {
|
|
|
+ xDataList = append(xDataList, tmpXDataList...)
|
|
|
+ }
|
|
|
+
|
|
|
yDataList = newYDataList
|
|
|
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-// BarChartData 柱方图的数据处理
|
|
|
-func BarChartData(edbInfoMapping *models.ChartEdbInfoMapping, futureGoodMappingList []*future_good.FutureGoodEdbInfo, edbDataListMap map[int][]*models.EdbDataList, barChartInfoDateList []data_manage.BarChartInfoDateReq, regionType, latestDate string) (edbIdList []int, yDataList []models.YData, err error) {
|
|
|
+// BarChartData 获取数据
|
|
|
+func BarChartData(baseEdbInfoMapping *models.ChartEdbInfoMapping, edbInfoMappingList []*models.ChartEdbInfoMapping, futureGoodMappingList []*future_good2.FutureGoodEdbInfo, edbDataListMap map[int][]*models.EdbDataList, barChartInfoDateList []data_manage.BarChartInfoDateReq, regionType, latestDate string) (edbIdList []int, yDataList []models.YData, err error) {
|
|
|
// 指标数据数组(10086:{"2022-12-02":100.01,"2022-12-01":102.3})
|
|
|
// 现货指标数据map
|
|
|
- baseEdbDataMap := make(map[string]float64)
|
|
|
+ baseEdbDataMap := make(map[int]map[string]float64)
|
|
|
+ edbInfoMappingMap := make(map[int]struct{})
|
|
|
+ for _, v := range edbInfoMappingList {
|
|
|
+ edbInfoMappingMap[v.EdbInfoId] = struct{}{}
|
|
|
+ }
|
|
|
for edbInfoId, edbDataList := range edbDataListMap {
|
|
|
- if edbInfoId == edbInfoMapping.EdbInfoId {
|
|
|
+ if _, ok1 := edbInfoMappingMap[edbInfoId]; ok1 {
|
|
|
+ edbDateData := make(map[string]float64)
|
|
|
for _, edbData := range edbDataList {
|
|
|
- baseEdbDataMap[edbData.DataTime] = edbData.Value
|
|
|
+ edbDateData[edbData.DataTime] = edbData.Value
|
|
|
}
|
|
|
+ baseEdbDataMap[edbInfoId] = edbDateData
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// 期货指标数据map
|
|
|
futureGoodEdbDataMap := make(map[int]map[string]float64)
|
|
|
for edbInfoId, edbDataList := range edbDataListMap {
|
|
|
- if edbInfoId == edbInfoMapping.EdbInfoId {
|
|
|
+ if _, ok := edbInfoMappingMap[edbInfoId]; ok {
|
|
|
continue
|
|
|
}
|
|
|
edbDateData := make(map[string]float64)
|
|
@@ -344,18 +451,12 @@ func BarChartData(edbInfoMapping *models.ChartEdbInfoMapping, futureGoodMappingL
|
|
|
futureGoodEdbDataMap[edbInfoId] = edbDateData
|
|
|
}
|
|
|
|
|
|
- edbDataMap := make(map[int]map[string]float64)
|
|
|
- for edbInfoId, edbDataList := range edbDataListMap {
|
|
|
- edbDateData := make(map[string]float64)
|
|
|
- for _, edbData := range edbDataList {
|
|
|
- edbDateData[edbData.DataTime] = edbData.Value
|
|
|
- }
|
|
|
- edbDataMap[edbInfoId] = edbDateData
|
|
|
- }
|
|
|
-
|
|
|
// edbIdList 指标展示顺序;x轴的指标顺序
|
|
|
edbIdList = make([]int, 0)
|
|
|
- edbIdList = append(edbIdList, edbInfoMapping.EdbInfoId)
|
|
|
+ for _, v := range edbInfoMappingList {
|
|
|
+ edbIdList = append(edbIdList, v.EdbInfoId)
|
|
|
+ }
|
|
|
+
|
|
|
for _, v := range futureGoodMappingList {
|
|
|
edbIdList = append(edbIdList, v.FutureGoodEdbInfoId)
|
|
|
}
|
|
@@ -396,19 +497,43 @@ func BarChartData(edbInfoMapping *models.ChartEdbInfoMapping, futureGoodMappingL
|
|
|
noDataIdMap := make(map[int]int, 0) // 没有数据的指标map
|
|
|
xEdbInfoIdList := make([]int, 0) // 当前数据的指标id列表
|
|
|
|
|
|
- // 现货指标
|
|
|
- realDateTime, findDataValue, isFind, tmpErr := GetNeedDateData(findDateTime, edbDataListMap[edbInfoMapping.EdbInfoId], baseEdbDataMap, futureGoodEdbDataMap)
|
|
|
+ // 先找到基准日期
|
|
|
+ var realDateTime time.Time
|
|
|
+ realDateTime, findDataValue, isFind, tmpErr := GetNeedDateData(findDateTime, edbDataListMap[baseEdbInfoMapping.EdbInfoId], baseEdbDataMap[baseEdbInfoMapping.EdbInfoId], futureGoodEdbDataMap)
|
|
|
if tmpErr != nil {
|
|
|
err = tmpErr
|
|
|
return
|
|
|
}
|
|
|
- findDataList = append(findDataList, findDataValue)
|
|
|
- yDataMap[edbInfoMapping.EdbInfoId] = findDataValue
|
|
|
- if isFind {
|
|
|
- maxDate = realDateTime
|
|
|
- } else {
|
|
|
- noDataIdList = append(noDataIdList, edbInfoMapping.EdbInfoId)
|
|
|
- noDataIdMap[edbInfoMapping.EdbInfoId] = edbInfoMapping.EdbInfoId
|
|
|
+ // 处理其余现货指标
|
|
|
+ for _, v := range edbInfoMappingList {
|
|
|
+ if v.EdbInfoId == baseEdbInfoMapping.EdbInfoId {
|
|
|
+ findDataList = append(findDataList, findDataValue)
|
|
|
+ yDataMap[baseEdbInfoMapping.EdbInfoId] = findDataValue
|
|
|
+ if isFind {
|
|
|
+ maxDate = realDateTime
|
|
|
+ } else {
|
|
|
+ noDataIdList = append(noDataIdList, baseEdbInfoMapping.EdbInfoId)
|
|
|
+ noDataIdMap[baseEdbInfoMapping.EdbInfoId] = baseEdbInfoMapping.EdbInfoId
|
|
|
+ }
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ tmpRealDateTime, findDataValueTmp, isFindTmp, e := GetNeedDateData(realDateTime, edbDataListMap[v.EdbInfoId], baseEdbDataMap[v.EdbInfoId], futureGoodEdbDataMap)
|
|
|
+ if e != nil {
|
|
|
+ err = e
|
|
|
+ return
|
|
|
+ }
|
|
|
+ findDataList = append(findDataList, findDataValueTmp)
|
|
|
+ yDataMap[v.EdbInfoId] = findDataValue
|
|
|
+ if isFindTmp {
|
|
|
+ // todo 是否需要变更 maxDate
|
|
|
+ if maxDate.IsZero() || maxDate.Before(tmpRealDateTime) {
|
|
|
+ maxDate = tmpRealDateTime
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ noDataIdList = append(noDataIdList, v.EdbInfoId)
|
|
|
+ noDataIdMap[v.EdbInfoId] = v.EdbInfoId
|
|
|
+ }
|
|
|
+ xEdbInfoIdList = append(xEdbInfoIdList, v.EdbInfoId)
|
|
|
}
|
|
|
//currMonth := findDateTime.Month() // 当前月份
|
|
|
//currYear := findDateTime.Year() // 当前年份
|
|
@@ -417,7 +542,6 @@ func BarChartData(edbInfoMapping *models.ChartEdbInfoMapping, futureGoodMappingL
|
|
|
currMonth := realDateTime.Month() // 当前月份
|
|
|
currYear := realDateTime.Year() // 当前年份
|
|
|
|
|
|
- xEdbInfoIdList = append(xEdbInfoIdList, edbInfoMapping.EdbInfoId)
|
|
|
mList := make([]int, 0) // 间隔月份
|
|
|
indexList := make([]int, 0)
|
|
|
if regionType == `国内` {
|
|
@@ -536,111 +660,9 @@ func BarChartData(edbInfoMapping *models.ChartEdbInfoMapping, futureGoodMappingL
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-// GetNeedDateData 获取合约内需要的日期数据
|
|
|
-func GetNeedDateData(needDateTime time.Time, dataList []*models.EdbDataList, edbDataMap map[string]float64, allEdbDataMap map[int]map[string]float64) (findDateTime time.Time, findDataValue float64, isFind bool, err error) {
|
|
|
- //dataList := edbDataListMap[edbInfoId] //指标的所有数据值
|
|
|
- if len(dataList) <= 0 {
|
|
|
- // 没有数据的指标id
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- //最早的日期
|
|
|
- minDateTime, err := time.ParseInLocation(utils.FormatDate, dataList[0].DataTime, time.Local)
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- // 该日期存在数据的期货指标的最小数量,目前是现货和期货各1个,总共2个
|
|
|
- maxCount := 1
|
|
|
-
|
|
|
- for tmpDateTime := needDateTime; tmpDateTime.After(minDateTime) || tmpDateTime.Equal(minDateTime); tmpDateTime = tmpDateTime.AddDate(0, 0, -1) {
|
|
|
- tmpDate := tmpDateTime.Format(utils.FormatDate)
|
|
|
- tmpValue, ok := edbDataMap[tmpDate]
|
|
|
- if !ok {
|
|
|
- continue
|
|
|
- }
|
|
|
-
|
|
|
- // 该日期存在数据的指标数量
|
|
|
- count := 0
|
|
|
-
|
|
|
- for _, currEdbDataMap := range allEdbDataMap {
|
|
|
- _, tmpIsFind := currEdbDataMap[tmpDate]
|
|
|
- if tmpIsFind {
|
|
|
- count++
|
|
|
- if count >= maxCount {
|
|
|
- continue
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- // 该日期存在数据的期货指标数量小于2个,那么要继续往前找
|
|
|
- if count < maxCount {
|
|
|
- continue
|
|
|
- }
|
|
|
-
|
|
|
- //如果能找到数据,那么就返回
|
|
|
- // 数据为0,也直接返回,做无值处理
|
|
|
- if tmpValue == 0 {
|
|
|
- return
|
|
|
- }
|
|
|
- findDateTime, _ = time.ParseInLocation(utils.FormatDate, tmpDate, time.Local)
|
|
|
- findDataValue = tmpValue
|
|
|
- isFind = true
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-// FutureGoodChartInfoRefresh
|
|
|
-// @author Roc
|
|
|
-// @datetime 2023-2-2 18:44:46
|
|
|
-// @description 商品价格曲线图表刷新
|
|
|
-func FutureGoodChartInfoRefresh(chartInfoId int) (err error) {
|
|
|
- var errMsg string
|
|
|
- defer func() {
|
|
|
- if err != nil {
|
|
|
- go alarm_msg.SendAlarmMsg("ChartInfoRefresh:"+errMsg, 3)
|
|
|
- fmt.Println("ChartInfoRefresh Err:" + errMsg)
|
|
|
- }
|
|
|
- }()
|
|
|
-
|
|
|
- edbInfoMapping, err := models.GetEtaEdbChartEdbMapping(chartInfoId)
|
|
|
- if err != nil {
|
|
|
- errMsg = "获取需要刷新的ETA指标失败:Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- // 获取期货指标
|
|
|
- futureGoodEdbInfoMapping, err := models.GetFutureGoodEdbChartEdbMapping(chartInfoId)
|
|
|
- if err != nil {
|
|
|
- errMsg = "获取需要刷新的商品期货指标失败:Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- // 获取期货指标以及期货数据
|
|
|
- futureGoodEdbInfoList, err := future_good.GetFutureGoodEdbInfoListByParentId(futureGoodEdbInfoMapping.EdbInfoId)
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- // 批量刷新ETA指标
|
|
|
- err, _ = data.EdbInfoRefreshAllFromBase([]int{edbInfoMapping.EdbInfoId}, false)
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- // 批量刷新期货指标
|
|
|
- err = FutureGoodEdbInfoRefreshAllFromBase(futureGoodEdbInfoList, false)
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
// handleResultData 处理成最终的结果数据
|
|
|
-func handleResultData(regionType string, futureGoodEdbType int, yDataList []models.YData, futureGoodEdbInfoList []*future_good.FutureGoodEdbInfo, maxIndex int) (xDataList []models.XData, newYDataList []models.YData, err error) {
|
|
|
- xDataList = make([]models.XData, 0)
|
|
|
+func handleResultData(regionType string, futureGoodEdbType int, yDataList []models.YData, futureGoodEdbInfoList []*future_good2.FutureGoodEdbInfo, maxIndex int) (xDataList []data_manage.XData, newYDataList []models.YData, err error) {
|
|
|
+ xDataList = make([]data_manage.XData, 0)
|
|
|
newYDataList = yDataList
|
|
|
|
|
|
if regionType == `国内` {
|
|
@@ -648,7 +670,8 @@ func handleResultData(regionType string, futureGoodEdbType int, yDataList []mode
|
|
|
if i > maxIndex {
|
|
|
break
|
|
|
}
|
|
|
- xDataList = append(xDataList, models.XData{
|
|
|
+ // todo x轴 内容调整
|
|
|
+ xDataList = append(xDataList, data_manage.XData{
|
|
|
Name: fmt.Sprint("M+", i),
|
|
|
NameEn: fmt.Sprint("M+", i),
|
|
|
})
|
|
@@ -656,7 +679,7 @@ func handleResultData(regionType string, futureGoodEdbType int, yDataList []mode
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- futureGoodEdbInfoMap := make(map[int]*future_good.FutureGoodEdbInfo)
|
|
|
+ futureGoodEdbInfoMap := make(map[int]*future_good2.FutureGoodEdbInfo)
|
|
|
for _, v := range futureGoodEdbInfoList {
|
|
|
futureGoodEdbInfoMap[v.FutureGoodEdbInfoId] = v
|
|
|
}
|
|
@@ -664,7 +687,7 @@ func handleResultData(regionType string, futureGoodEdbType int, yDataList []mode
|
|
|
if futureGoodEdbType == 2 { // FutureGoodEdbType int `description:"指标类型,1:年月是固定的合约;2:只有M+N期的合约,未固定年月"`
|
|
|
nList := []int{3, 15, 27}
|
|
|
for _, i := range nList {
|
|
|
- xDataList = append(xDataList, models.XData{
|
|
|
+ xDataList = append(xDataList, data_manage.XData{
|
|
|
Name: fmt.Sprint("M+", i),
|
|
|
NameEn: fmt.Sprint("M+", i),
|
|
|
})
|
|
@@ -780,7 +803,7 @@ func handleResultData(regionType string, futureGoodEdbType int, yDataList []mode
|
|
|
//prevMonth := 1
|
|
|
|
|
|
for _, n := range nList {
|
|
|
- xDataList = append(xDataList, models.XData{
|
|
|
+ xDataList = append(xDataList, data_manage.XData{
|
|
|
Name: fmt.Sprint("M+", n),
|
|
|
NameEn: fmt.Sprint("M+", n),
|
|
|
})
|
|
@@ -859,14 +882,13 @@ func handleResultData(regionType string, futureGoodEdbType int, yDataList []mode
|
|
|
newYDataList[yIndex].Value = yData.Value[0 : maxI+1]
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// getFutureGoodEdbInfoList 获取适用的指标列表
|
|
|
-func getFutureGoodEdbInfoList(latestDateTime time.Time, tmpFutureGoodEdbInfoList []*future_good.FutureGoodEdbInfo, barChartInfoDateList []data_manage.BarChartInfoDateReq) (earliestDateTime time.Time, futureGoodEdbInfoList []*future_good.FutureGoodEdbInfo, err error) {
|
|
|
+func getFutureGoodEdbInfoList(latestDateTime time.Time, tmpFutureGoodEdbInfoList []*future_good2.FutureGoodEdbInfo, barChartInfoDateList []data_manage.BarChartInfoDateReq) (earliestDateTime time.Time, futureGoodEdbInfoList []*future_good2.FutureGoodEdbInfo, err error) {
|
|
|
maxM := 36 //最大36期合约
|
|
|
- futureGoodEdbInfoList = make([]*future_good.FutureGoodEdbInfo, 0)
|
|
|
+ futureGoodEdbInfoList = make([]*future_good2.FutureGoodEdbInfo, 0)
|
|
|
earliestDateTime = latestDateTime // 数据的最早日期,目的是为了找出最早的合约
|
|
|
for _, barChartInfoDate := range barChartInfoDateList {
|
|
|
var findDateTime time.Time
|
|
@@ -934,3 +956,109 @@ func getFutureGoodEdbInfoList(latestDateTime time.Time, tmpFutureGoodEdbInfoList
|
|
|
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
+// GetNeedDateData 获取合约内需要的日期数据
|
|
|
+func GetNeedDateData(needDateTime time.Time, dataList []*models.EdbDataList, edbDataMap map[string]float64, allEdbDataMap map[int]map[string]float64) (findDateTime time.Time, findDataValue float64, isFind bool, err error) {
|
|
|
+ //dataList := edbDataListMap[edbInfoId] //指标的所有数据值
|
|
|
+ if len(dataList) <= 0 {
|
|
|
+ // 没有数据的指标id
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //最早的日期
|
|
|
+ minDateTime, err := time.ParseInLocation(utils.FormatDate, dataList[0].DataTime, time.Local)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 该日期存在数据的期货指标的最小数量,目前是现货和期货各1个,总共2个
|
|
|
+ maxCount := 1
|
|
|
+
|
|
|
+ for tmpDateTime := needDateTime; tmpDateTime.After(minDateTime) || tmpDateTime.Equal(minDateTime); tmpDateTime = tmpDateTime.AddDate(0, 0, -1) {
|
|
|
+ tmpDate := tmpDateTime.Format(utils.FormatDate)
|
|
|
+ tmpValue, ok := edbDataMap[tmpDate]
|
|
|
+ if !ok {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+
|
|
|
+ // 该日期存在数据的指标数量
|
|
|
+ count := 0
|
|
|
+
|
|
|
+ for _, currEdbDataMap := range allEdbDataMap {
|
|
|
+ _, tmpIsFind := currEdbDataMap[tmpDate]
|
|
|
+ if tmpIsFind {
|
|
|
+ count++
|
|
|
+ if count >= maxCount {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 该日期存在数据的期货指标数量小于2个,那么要继续往前找
|
|
|
+ if count < maxCount {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+
|
|
|
+ //如果能找到数据,那么就返回
|
|
|
+ // 数据为0,也直接返回,做无值处理
|
|
|
+ if tmpValue == 0 {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ findDateTime, _ = time.ParseInLocation(utils.FormatDate, tmpDate, time.Local)
|
|
|
+ findDataValue = tmpValue
|
|
|
+ isFind = true
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// FutureGoodChartInfoRefresh
|
|
|
+// @author Roc
|
|
|
+// @datetime 2023-2-2 18:44:46
|
|
|
+// @description 商品价格曲线图表刷新
|
|
|
+func FutureGoodChartInfoRefresh(chartInfoId int) (err error) {
|
|
|
+ var errMsg string
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ go alarm_msg.SendAlarmMsg("ChartInfoRefresh:"+errMsg, 3)
|
|
|
+ fmt.Println("ChartInfoRefresh Err:" + errMsg)
|
|
|
+ }
|
|
|
+ }()
|
|
|
+
|
|
|
+ edbInfoMappingList, err := models.GetEtaEdbChartEdbMappingList(chartInfoId)
|
|
|
+ if err != nil {
|
|
|
+ errMsg = "获取需要刷新的ETA指标失败:Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ edbInfoIds := make([]int, 0)
|
|
|
+ for _, edbInfoMapping := range edbInfoMappingList {
|
|
|
+ edbInfoIds = append(edbInfoIds, edbInfoMapping.EdbInfoId)
|
|
|
+ }
|
|
|
+ // 获取期货指标
|
|
|
+ futureGoodEdbInfoMapping, err := models.GetFutureGoodEdbChartEdbMapping(chartInfoId)
|
|
|
+ if err != nil {
|
|
|
+ errMsg = "获取需要刷新的商品期货指标失败:Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 获取期货指标以及期货数据
|
|
|
+ futureGoodEdbInfoList, err := future_good2.GetFutureGoodEdbInfoListByParentId(futureGoodEdbInfoMapping.EdbInfoId)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 批量刷新ETA指标
|
|
|
+ err, _ = data.EdbInfoRefreshAllFromBase(edbInfoIds, false)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 批量刷新期货指标
|
|
|
+ err = FutureGoodEdbInfoRefreshAllFromBase(futureGoodEdbInfoList, false)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|