2 Star 7 Fork 11

王布衣/engine

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
finance.go 8.50 KB
一键复制 编辑 原始数据 按行查看 历史
王布衣 提交于 2024-01-11 11:15 . 适配exchange工具包
package dfcf
import (
"encoding/json"
"fmt"
"gitee.com/quant1x/exchange"
"gitee.com/quant1x/gox/http"
urlpkg "net/url"
"strings"
)
const (
urlFinanceReports = "https://datacenter-web.eastmoney.com/api/data/v1/get"
EastmoneyFinanceReportsPageSize = 100
)
// PreviewQuarterlyReport 业绩预报详情
type PreviewQuarterlyReport struct {
SecurityCode string `name:"证券代码" json:"SECURITY_CODE"`
SecurityName string `name:"证券名称" json:"SECURITY_NAME"`
OrgCode string `name:"机构代码" json:"ORG_CODE"`
NoticeDate string `name:"公告日期" json:"NOTICE_DATE"`
ReportDate string `name:"报告日期" json:"REPORT_DATE"`
PredictFinanceCode string `name:"预告代码" json:"PREDICT_FINANCE_CODE"`
PredictFinance string `name:"预告财报" json:"PREDICT_FINANCE"`
PredictAmtLower float64 `name:"预计营收下限" json:"PREDICT_AMT_LOWER"`
PredictAmtUpper float64 `name:"预计营收上限" json:"PREDICT_AMT_UPPER"`
AddAmpLower float64 `name:"增长下限" json:"ADD_AMP_LOWER"`
AddAmpUpper float64 `name:"增长下限" json:"ADD_AMP_UPPER"`
PredictContent string `name:"预告内容" json:"PREDICT_CONTENT"`
ChangeReasonExplain string `name:"改变原因" json:"CHANGE_REASON_EXPLAIN"`
PredictType string `name:"预计类型" json:"PREDICT_TYPE"`
PreyearSamePeriod float64 `name:"上年同期" json:"PREYEAR_SAME_PERIOD"`
TradeMarket string `name:"所在交易所" json:"TRADE_MARKET"`
TradeMarketCode string `name:"场内交易代码" json:"TRADE_MARKET_CODE"`
SecurityType string `name:"证券类型" json:"SECURITY_TYPE"`
SecurityTypeCode string `name:"证券类型代码" json:"SECURITY_TYPE_CODE"`
IncreaseJz float64 `name:"增长均值" json:"INCREASE_JZ"`
ForecastJz float64 `name:"预测均值" json:"FORECAST_JZ"`
ForecastState string `name:"预测状态" json:"FORECAST_STATE"`
IsLatest string `name:"是否最新财报" json:"IS_LATEST"`
PredictRatioLower float64 `name:"预测增速下限" json:"PREDICT_RATIO_LOWER"`
PredictRatioUpper float64 `name:"预测增速上限" json:"PREDICT_RATIO_UPPER"`
PredictHbmean float64 `name:"预计每股盈利?" json:"PREDICT_HBMEAN"`
}
func (f PreviewQuarterlyReport) GetDate() string {
return f.NoticeDate
}
func (f PreviewQuarterlyReport) GetSecurityCode() string {
return f.SecurityCode
}
// FinanceReports 获取哪天开始的财报数据
// https://data.eastmoney.com/bbsj/202303/yjyg.html?type=increase
// https://data.eastmoney.com/bbsj/202303/yjbb.html
func FinanceReports(date string, pageNumber ...int) (reports []PreviewQuarterlyReport, pages, originalRecords int, err error) {
pageNo := 1
pageSize := EastmoneyFinanceReportsPageSize
if len(pageNumber) > 0 {
pageNo = pageNumber[0]
}
beginDate := exchange.FixTradeDate(date)
params := urlpkg.Values{
"page_size": {fmt.Sprintf("%d", pageSize)},
"page_index": {fmt.Sprintf("%d", pageNo)},
"sortColumns": {"NOTICE_DATE", "SECURITY_CODE"},
"sortTypes": {"-1", "-1"},
"reportName": {"RPT_PUBLIC_OP_NEWPREDICT"},
"columns": {"ALL"},
"filter": {fmt.Sprintf("(REPORT_DATE>='%s')", beginDate)},
//"callback": {"jQuery1123017378221241641723_1683879528446"},
}
url := urlFinanceReports + "?" + params.Encode()
data, err := http.Get(url)
if err != nil {
return
}
//fmt.Println(api.Bytes2String(data))
var raw rawFinanceReport
err = json.Unmarshal(data, &raw)
if err != nil {
return
}
if !raw.Success || raw.Code != 0 || len(raw.Result.Data) == 0 {
err = ErrNoticeNotFound
return
}
//pages = functions.GetPages(pageSize, raw.Result.Count)
pages = raw.Result.Pages
originalRecords = len(raw.Result.Data)
for _, v := range raw.Result.Data {
securityName := strings.TrimSpace(v.SECURITY_NAME_ABBR)
if len(v.SECUCODE) == 0 || len(securityName) == 0 {
continue
}
code := strings.TrimSpace(v.SECUCODE)
_, mflag, msymbol := exchange.DetectMarket(code)
securityCode := mflag + msymbol
report := PreviewQuarterlyReport{
SecurityCode: securityCode,
SecurityName: securityName,
ReportDate: v.REPORT_DATE,
NoticeDate: v.NOTICE_DATE,
OrgCode: v.ORG_CODE,
//PredictFinanceCode string `name:"预告代码" json:"PREDICT_FINANCE_CODE"`
PredictFinanceCode: v.PREDICT_FINANCE_CODE,
//PredictFinance string `name:"预告财报" json:"PREDICT_FINANCE"`
PredictFinance: v.PREDICT_FINANCE,
//PredictAmtLower float64 `name:"预计营收下限" json:"PREDICT_AMT_LOWER"`
PredictAmtLower: v.PREDICT_AMT_LOWER,
//PredictAmtUpper float64 `name:"预计营收上限" json:"PREDICT_AMT_UPPER"`
PredictAmtUpper: v.PREDICT_AMT_UPPER,
//AddAmpLower float64 `name:"增长下限" json:"ADD_AMP_LOWER"`
AddAmpLower: v.ADD_AMP_LOWER,
//AddAmpUpper float64 `name:"增长下限" json:"ADD_AMP_UPPER"`
AddAmpUpper: v.ADD_AMP_UPPER,
//PredictContent string `name:"预告内容" json:"PREDICT_CONTENT"`
PredictContent: v.PREDICT_CONTENT,
//ChangeReasonExplain string `name:"改变原因" json:"CHANGE_REASON_EXPLAIN"`
ChangeReasonExplain: v.CHANGE_REASON_EXPLAIN,
//PredictType string `name:"预计类型" json:"PREDICT_TYPE"`
PredictType: v.PREDICT_TYPE,
//PreyearSamePeriod float64 `name:"上年同期" json:"PREYEAR_SAME_PERIOD"`
PreyearSamePeriod: v.PREYEAR_SAME_PERIOD,
//TradeMarket string `name:"所在交易所" json:"TRADE_MARKET"`
TradeMarket: v.TRADE_MARKET,
//TradeMarketCode string `name:"场内交易代码" json:"TRADE_MARKET_CODE"`
TradeMarketCode: v.TRADE_MARKET_CODE,
//SecurityType string `name:"证券类型" json:"SECURITY_TYPE"`
SecurityType: v.SECURITY_TYPE,
//SecurityTypeCode string `name:"证券类型代码" json:"SECURITY_TYPE_CODE"`
SecurityTypeCode: v.SECURITY_TYPE_CODE,
//IncreaseJz float64 `name:"增长均值" json:"INCREASE_JZ"`
IncreaseJz: v.INCREASE_JZ,
//ForecastJz float64 `name:"预测均值" json:"FORECAST_JZ"`
ForecastJz: v.FORECAST_JZ,
//ForecastState string `name:"预测状态" json:"FORECAST_STATE"`
ForecastState: v.FORECAST_STATE,
//IsLatest string `name:"是否最新财报" json:"IS_LATEST"`
IsLatest: v.IS_LATEST,
//PredictRatioLower float64 `name:"预测增速下限" json:"PREDICT_RATIO_LOWER"`
PredictRatioLower: v.PREDICT_RATIO_LOWER,
//PredictRatioUpper float64 `name:"预测增速上限" json:"PREDICT_RATIO_UPPER"`
PredictRatioUpper: v.PREDICT_RATIO_UPPER,
//PredictHbmean float64 `name:"预计每股盈利?" json:"PREDICT_HBMEAN"`
PredictHbmean: v.PREDICT_HBMEAN,
}
reports = append(reports, report)
}
return
}
// 财报原始数据结构
type rawFinanceReport struct {
Version string `json:"version"`
Result struct {
Pages int `json:"pages"`
Data []struct {
SECUCODE string `json:"SECUCODE"`
SECURITY_CODE string `json:"SECURITY_CODE"`
SECURITY_NAME_ABBR string `json:"SECURITY_NAME_ABBR"`
ORG_CODE string `json:"ORG_CODE"`
NOTICE_DATE string `json:"NOTICE_DATE"`
REPORT_DATE string `json:"REPORT_DATE"`
PREDICT_FINANCE_CODE string `json:"PREDICT_FINANCE_CODE"`
PREDICT_FINANCE string `json:"PREDICT_FINANCE"`
PREDICT_AMT_LOWER float64 `json:"PREDICT_AMT_LOWER"`
PREDICT_AMT_UPPER float64 `json:"PREDICT_AMT_UPPER"`
ADD_AMP_LOWER float64 `json:"ADD_AMP_LOWER"`
ADD_AMP_UPPER float64 `json:"ADD_AMP_UPPER"`
PREDICT_CONTENT string `json:"PREDICT_CONTENT"`
CHANGE_REASON_EXPLAIN string `json:"CHANGE_REASON_EXPLAIN"`
PREDICT_TYPE string `json:"PREDICT_TYPE"`
PREYEAR_SAME_PERIOD float64 `json:"PREYEAR_SAME_PERIOD"`
TRADE_MARKET string `json:"TRADE_MARKET"`
TRADE_MARKET_CODE string `json:"TRADE_MARKET_CODE"`
SECURITY_TYPE string `json:"SECURITY_TYPE"`
SECURITY_TYPE_CODE string `json:"SECURITY_TYPE_CODE"`
INCREASE_JZ float64 `json:"INCREASE_JZ"`
FORECAST_JZ float64 `json:"FORECAST_JZ"`
FORECAST_STATE string `json:"FORECAST_STATE"`
IS_LATEST string `json:"IS_LATEST"`
PREDICT_RATIO_LOWER float64 `json:"PREDICT_RATIO_LOWER"`
PREDICT_RATIO_UPPER float64 `json:"PREDICT_RATIO_UPPER"`
PREDICT_HBMEAN float64 `json:"PREDICT_HBMEAN"`
} `json:"data"`
Count int `json:"count"`
} `json:"result"`
Success bool `json:"success"`
Message string `json:"message"`
Code int `json:"code"`
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/quant1x/engine.git
git@gitee.com:quant1x/engine.git
quant1x
engine
engine
v1.8.45

搜索帮助

0d507c66 1850385 C8b1a773 1850385