eta_bridge/models/pcsg/bloomberg.go

package pcsg

import (
	"strings"
	"time"
)

// PythonBloombergDailyPriceData 日度-价格数据
type PythonBloombergDailyPriceData struct {
	IDENTIFIER    string  `json:"IDENTIFIER" description:"指标编码"`
	PX_YEST_CLOSE float64 `json:"PX_YEST_CLOSE" description:"数据值"`
	PX_CLOSE_DT   string  `json:"PX_CLOSE_DT" description:"数据日期"`
	NAME          string  `json:"NAME" description:"指标名称"`
}

// PythonBloombergGeneralData 通用数据
type PythonBloombergGeneralData struct {
	IDENTIFIER     string  `json:"IDENTIFIER" description:"指标编码"`
	NAME           string  `json:"NAME" description:"指标名称"`
	PX_LAST        float64 `json:"PX_LAST" description:"数据值"`
	LAST_UPDATE_DT string  `json:"LAST_UPDATE_DT" description:"数据日期"`
}

// PythonBloombergDailyResult 日度指标API响应体
type PythonBloombergDailyResult struct {
	Code int                            `json:"code"`
	Msg  string                         `json:"msg"`
	Data PythonBloombergDailyResultData `json:"data"`
}

// PythonBloombergDailyResultData 日度指标API响应数据
type PythonBloombergDailyResultData struct {
	PriceData   []PythonBloombergDailyPriceData `json:"price_data" description:"价格数据"`
	GeneralData []PythonBloombergGeneralData    `json:"general_data" description:"一般数据"`
}

// PythonBloombergWeeklyResult 周度指标API响应体
type PythonBloombergWeeklyResult struct {
	Code int                          `json:"code"`
	Msg  string                       `json:"msg"`
	Data []PythonBloombergGeneralData `json:"data"`
}

// PythonBloombergMonthlyResult 月度指标API响应体
type PythonBloombergMonthlyResult struct {
	Code int                          `json:"code"`
	Msg  string                       `json:"msg"`
	Data []PythonBloombergGeneralData `json:"data"`
}

// BaseFromBloombergApiIndexAndData Bloomberg原始指标及数据
type BaseFromBloombergApiIndexAndData struct {
	BaseFromBloombergIndexId int                             `description:"指标ID"`
	IndexCode                string                          `description:"指标编码"`
	IndexName                string                          `description:"指标名称"`
	Unit                     string                          `description:"单位"`
	Source                   string                          `description:"来源"`
	Frequency                string                          `description:"频度"`
	CreateTime               time.Time                       `description:"创建时间"`
	ModifyTime               time.Time                       `description:"修改时间"`
	Data                     []BaseFromBloombergApiIndexData `description:"数据列表"`
}

// BaseFromBloombergApiIndexData Bloomberg原始指标数据
type BaseFromBloombergApiIndexData struct {
	DataTime time.Time `description:"数据日期"`
	Value    float64   `description:"数据值"`
}

func FormatPythonBloombergDailyPriceData2Base(origin PythonBloombergDailyPriceData) (item BaseFromBloombergApiIndexAndData) {
	if origin.IDENTIFIER == "" {
		return
	}
	item.IndexCode = strings.TrimSpace(origin.IDENTIFIER)
	item.IndexName = strings.TrimSpace(origin.NAME)
	item.Frequency = "日度"
	item.Unit = "无"
	item.Data = make([]BaseFromBloombergApiIndexData, 0)
	t, _ := time.ParseInLocation(time.DateOnly, origin.PX_CLOSE_DT, time.Local)
	item.Data = append(item.Data, BaseFromBloombergApiIndexData{
		DataTime: t,
		Value:    origin.PX_YEST_CLOSE,
	})
	return
}

func FormatPythonBloombergGeneralData2Base(origin PythonBloombergGeneralData, frequency string) (item BaseFromBloombergApiIndexAndData) {
	if origin.IDENTIFIER == "" {
		return
	}
	item.IndexCode = strings.TrimSpace(origin.IDENTIFIER)
	item.IndexName = strings.TrimSpace(origin.NAME)
	item.Frequency = frequency
	item.Unit = "无"
	item.Data = make([]BaseFromBloombergApiIndexData, 0)
	t, _ := time.ParseInLocation(time.DateOnly, origin.LAST_UPDATE_DT, time.Local)
	item.Data = append(item.Data, BaseFromBloombergApiIndexData{
		DataTime: t,
		Value:    origin.PX_LAST,
	})
	return
}