/
exportor_data.go
316 lines (295 loc) · 12.5 KB
/
exportor_data.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
// 封装需要导出数据结果
package models
import (
"context"
"github.com/283713406/q-stock/datacenter/eastmoney"
"github.com/axiaoxin-com/goutils"
"sort"
)
// ExportorData 数据模板
type ExportorData struct {
// 股票名
Name string `json:"name" csv:"股票名"`
// 股票代码
Code string `json:"code" csv:"股票代码"`
// 所属行业
Industry string `json:"industry" csv:"所属行业"`
// 题材关键词
// Keywords string `json:"keywords" csv:"题材关键词"`
// 公司信息
// CompanyProfile string `json:"company_profile" csv:"公司信息"`
// 主营构成
MainForms string `json:"main_forms" csv:"主营构成"`
// 本业营收比
// BYYSRatio float64 `json:"byys_ration" csv:"本业营收比"`
// 财报年份-类型
// ReportDateName string `json:"report_date_name" csv:"数据源"`
// 财报审计意见
// ReportOpinion interface{} `json:"report_opinion" csv:"财报审计意见"`
// 价值评估
JZPG string `json:"jzpg" csv:"价值评估"`
// 当前 ROE
// LatestROE float64 `json:"latest_roe" csv:"当前 ROE"`
// 最近财报 ROE
// LatestFinaROE float64 `json:"latest_fina_roe" csv:"最新财报 ROE"`
// ROE 同比增长
// ROETBZZ float64 `json:"roe_tbzz" csv:"ROE 同比增长 (%)"`
// 近五年 ROE
ROE5Y []float64 `json:"roe_5y" csv:"近五年 ROE"`
// 最新一期 EPS
// LatestEPS float64 `json:"latest_eps" csv:"最新一期 EPS"`
// EPS 同比增长
// EPSTBZZ float64 `json:"eps_tbzz" csv:"EPS 同比增长 (%)"`
// 近五年 EPS
EPS5Y []float64 `json:"eps_5y" csv:"近五年 EPS"`
// 营业总收入
TotalIncome interface{} `json:"total_income" csv:"营业总收入"`
// 营业总收入同比增长
TotalIncomeTBZZ float64 `json:"total_income_tbzz" csv:"营业总收入同比增长 (%)"`
// 近五年营收
TotalIncome5Y []string `json:"total_income_5y" csv:"近五年营收"`
// 归属净利润
NetProfit interface{} `json:"net_profit" csv:"归属净利润（元）"`
// 归属净利润同比增长 (%)
NetProfitTBZZ float64 `json:"net_profit_tbzz" csv:"归属净利润同比增长 (%)"`
// 近五年净利润
NetProfit5Y []string `json:"net_profit_5y" csv:"近五年净利润"`
// 最新股息率 (%)
ZXGXL float64 `json:"zxgxl" csv:"最新股息率 (%)"`
// 财报披露日期
// FinaReportDate string `json:"fina_report_date" csv:"财报披露日期"`
// 预约财报披露日期
// FinaAppointPublishDate string `json:"fina_appoint_publish_date" csv:"预约财报披露日期"`
// 实际财报披露日期
// FinaActualPublishDate string `json:"fina_actual_publish_date" csv:"实际财报披露日期"`
// 总市值（字符串）
TotalMarketCap interface{} `json:"total_market_cap" csv:"总市值"`
// 当时价格
Price float64 `json:"price" csv:"价格"`
// 估算合理价格
RightPrice interface{} `json:"right_price" csv:"估算合理价格"`
// 合理价格与当时价的价格差(%)
// PriceSpace interface{} `json:"price_space" csv:"合理价差"`
// 历史波动率
// HV float64 `json:"hv" csv:"历史波动率"`
// 最新负债率 (%)
ZXFZL float64 `json:"zxfzl" csv:"最新负债率 (%)"`
// 负债流动比
FZLDB float64 `json:"fzldb" csv:"负债流动比"`
// 净利润 3 年复合增长率 (%)
// NetprofitGrowthrate3Y float64 `json:"netprofit_growthrate_3_y" csv:"净利润 3 年复合增长率 (%)"`
// 营收 3 年复合增长率 (%)
// IncomeGrowthrate3Y float64 `json:"income_growthrate_3_y" csv:"营收 3 年复合增长率 (%)"`
// 上市以来年化收益率 (%)
ListingYieldYear float64 `json:"listing_yield_year" csv:"上市以来年化收益率 (%)"`
// 上市以来年化波动率 (%)
// ListingVolatilityYear float64 `json:"listing_volatility_year" csv:"年化波动率 (%)"`
// 市盈率
PE float64 `json:"pe" csv:"市盈率"`
// PEG
PEG float64 `json:"peg" csv:"PEG"`
// 机构评级
// OrgRating string `json:"org_rating" csv:"机构评级"`
// 盈利预测
ProfitPredict string `json:"profit_predict" csv:"盈利预测"`
// 市盈率估值
// ValuationSYL string `json:"valuation_syl" csv:"市盈率估值"`
// 市净率估值
// ValuationSJL string `json:"valuation_sjl" csv:"市净率估值"`
// 市销率估值
// ValuationSXOL string `json:"valuation_sxol" csv:"市销率估值"`
// 市现率估值
// ValuationSXNL string `json:"valuation_sxnl" csv:"市现率估值"`
// 行业均值水平
HYJZSP string `json:"hyjzsp" csv:"行业均值水平"`
// 整体质地
// ZTZD string `json:"ztzd" csv:"整体质地"`
// 近五年毛利率
MLL5Y []float64 `json:"mll_5y" csv:"近五年毛利率"`
// 近五年净利率
JLL5Y []float64 `json:"jll_5y" csv:"近五年净利率"`
// 上市时间
ListingDate string `json:"listing_date" csv:"上市时间"`
// 最新经营活动产生的现金流量净额
NetcashOperate string `json:"netcash_operate" csv:"经营现金流净额"`
// 最新投资活动产生的现金流量净额
NetcashInvest string `json:"netcash_invest" csv:"投资现金流净额"`
// 最新筹资活动产生的现金流量净额
NetcashFinance string `json:"netcash_finance" csv:"筹资现金流净额"`
// 自由现金流
NetcashFree string `json:"netcash_free" csv:"自由现金流"`
// 十大流通股东
FreeHoldersTop10 string `json:"free_holders_top_10" csv:"十大流通股东"`
// 主力净流入
// MainMoneyNetInflows string `json:"main_money_net_inflows" csv:"主力资金净流入"`
}
// GetHeaderValueMap 获取以 csv tag 为 key 的 Data map
func (d ExportorData) GetHeaderValueMap() map[string]interface{} {
return goutils.StructToMap(&d, "csv")
}
// GetHeaders 获取 csv tag 列表
func (d ExportorData) GetHeaders() []string {
return goutils.StructTagList(&d, "csv")
}
// NewExportorData 创建 ExportotData 对象
func NewExportorData(ctx context.Context, stock Stock) ExportorData {
var rightPrice interface{} = "--"
// var priceSpace interface{} = "--"
// var reportOpinion interface{} = "--"
if stock.RightPrice > 0 {
rightPrice = stock.RightPrice
// priceSpace = fmt.Sprintf("%.2f%%", (stock.RightPrice-stock.GetPrice())/stock.GetPrice()*100)
}
//if stock.FinaReportOpinion != "" {
// reportOpinion = stock.FinaReportOpinion
//}
// frd := strings.Fields(stock.FinaReportDate)
// reportDate := "--"
// if len(frd) > 0 {
// reportDate = frd[0]
// }
// fapd := strings.Fields(stock.FinaAppointPublishDate)
// appointPubDate := "--"
// if len(fapd) > 0 {
// appointPubDate = fapd[0]
// }
// frpd := strings.Fields(stock.FinaActualPublishDate)
// actualPubDate := "--"
// if len(frpd) > 0 {
// actualPubDate = frpd[0]
// }
if len(stock.HistoricalFinaMainData) == 0 {
return ExportorData{}
}
totalIncome5YList := stock.HistoricalFinaMainData.ValueList(ctx, eastmoney.ValueListTypeRevenue, 5, eastmoney.FinaReportTypeYear)
tis := []string{}
for _, ti := range totalIncome5YList {
tis = append(tis, goutils.YiWanString(ti))
}
netProfit5YList := stock.HistoricalFinaMainData.ValueList(ctx, eastmoney.ValueListTypeNetProfit, 5, eastmoney.FinaReportTypeYear)
nps := []string{}
for _, np := range netProfit5YList {
nps = append(nps, goutils.YiWanString(np))
}
fina := stock.HistoricalFinaMainData[0]
return ExportorData{
Name: stock.BaseInfo.SecurityNameAbbr,
Code: stock.BaseInfo.Secucode,
Industry: stock.BaseInfo.Industry,
// Keywords: stock.CompanyProfile.KeywordsString(),
// CompanyProfile: stock.CompanyProfile.ProfileString(),
MainForms: stock.CompanyProfile.MainFormsString(),
// BYYSRatio: stock.BYYSRatio,
// ReportDateName: fina.ReportDateName,
// ReportOpinion: reportOpinion,
JZPG: stock.JZPG.String(),
// LatestROE: stock.BaseInfo.RoeWeight,
// LatestFinaROE: fina.Roejq,
// ROETBZZ: fina.Roejqtz,
ROE5Y: stock.HistoricalFinaMainData.ValueList(ctx, eastmoney.ValueListTypeROE, 5, eastmoney.FinaReportTypeYear),
// LatestEPS: fina.Epsjb,
// EPSTBZZ: fina.Epsjbtz,
EPS5Y: stock.HistoricalFinaMainData.ValueList(ctx, eastmoney.ValueListTypeEPS, 5, eastmoney.FinaReportTypeYear),
TotalIncome: goutils.YiWanString(fina.Totaloperatereve),
TotalIncomeTBZZ: fina.Totaloperaterevetz,
TotalIncome5Y: tis,
NetProfit: goutils.YiWanString(fina.Parentnetprofit),
NetProfitTBZZ: fina.Parentnetprofittz,
NetProfit5Y: nps,
ZXGXL: stock.BaseInfo.Zxgxl,
FZLDB: fina.Ld,
// FinaReportDate: reportDate,
// FinaAppointPublishDate: appointPubDate,
// FinaActualPublishDate: actualPubDate,
TotalMarketCap: goutils.YiWanString(stock.BaseInfo.TotalMarketCap),
Price: stock.GetPrice(),
RightPrice: rightPrice,
// PriceSpace: priceSpace,
// HV: stock.HistoricalVolatility,
// ListingVolatilityYear: stock.BaseInfo.ListingVolatilityYear,
ZXFZL: fina.Zcfzl,
// NetprofitGrowthrate3Y: stock.BaseInfo.NetprofitGrowthrate3Y,
// IncomeGrowthrate3Y: stock.BaseInfo.IncomeGrowthrate3Y,
ListingYieldYear: stock.BaseInfo.ListingYieldYear,
PE: stock.BaseInfo.PE,
PEG: stock.PEG,
// OrgRating: stock.OrgRatingList.String(),
ProfitPredict: stock.ProfitPredictList.String(),
// ValuationSYL: stock.ValuationMap["市盈率"],
// ValuationSJL: stock.ValuationMap["市净率"],
// ValuationSXOL: stock.ValuationMap["市销率"],
// ValuationSXNL: stock.ValuationMap["市现率"],
HYJZSP: stock.JZPG.GetValuationScore(),
// ZTZD: stock.JZPG.GetValueTotalScore(),
MLL5Y: stock.HistoricalFinaMainData.ValueList(
ctx,
eastmoney.ValueListTypeMLL,
5,
eastmoney.FinaReportTypeYear,
),
JLL5Y: stock.HistoricalFinaMainData.ValueList(ctx, eastmoney.ValueListTypeJLL, 5, eastmoney.FinaReportTypeYear),
ListingDate: stock.BaseInfo.ListingDate,
NetcashOperate: goutils.YiWanString(stock.NetcashOperate),
NetcashInvest: goutils.YiWanString(stock.NetcashInvest),
NetcashFinance: goutils.YiWanString(stock.NetcashFinance),
NetcashFree: goutils.YiWanString(stock.NetcashFree),
FreeHoldersTop10: stock.FreeHoldersTop10.String(),
// MainMoneyNetInflows: stock.MainMoneyNetInflows.String(),
}
}
// ExportorDataList 要导出的数据列表
type ExportorDataList []ExportorData
// SortByROE 股票列表按 ROE 排序
//func (d ExportorDataList) SortByROE() {
// sort.Slice(d, func(i, j int) bool {
// return d[i].LatestROE > d[j].LatestROE
// })
//}
// SortByPrice 股票列表按股价排序
func (d ExportorDataList) SortByPrice() {
sort.Slice(d, func(i, j int) bool {
return d[i].Price < d[j].Price
})
}
// SortByZXGXL 股票列表按最新股息率排序
func (d ExportorDataList) SortByZXGXL() {
sort.Slice(d, func(i, j int) bool {
return d[i].ZXGXL > d[j].ZXGXL
})
}
// SortByHV 股票列表按历史波动率排序
//func (d ExportorDataList) SortByHV() {
// sort.Slice(d, func(i, j int) bool {
// return d[i].HV > d[j].HV
// })
//}
// GetIndustryList 获取行业分类列表
func (d ExportorDataList) GetIndustryList() []string {
result := []string{}
for _, stock := range d {
if !goutils.IsStrInSlice(stock.Industry, result) {
result = append(result, stock.Industry)
}
}
return result
}
// ChunkedBySize 将 stock 列表按大小切割分组
func (d ExportorDataList) ChunkedBySize(chunkSize int) []ExportorDataList {
result := []ExportorDataList{}
dataLen := len(d)
for i := 0; i < dataLen; i += chunkSize {
end := i + chunkSize
if end > dataLen {
end = dataLen
}
result = append(result, d[i:end])
}
return result
}
// NewExportorDataList 创建要导出的数据列表
func NewExportorDataList(ctx context.Context, stocks StockList) (result ExportorDataList) {
for _, s := range stocks {
result = append(result, NewExportorData(ctx, s))
}
return
}