select_stocks.go

// 按我的选股指标获取股票数据，对优质公司进行初步筛选（好公司不代表股价涨）

package eastmoney

import (
	"context"
	"fmt"
	"sort"
	"strings"
	"time"

	"github.com/axiaoxin-com/goutils"
	"github.com/axiaoxin-com/logging"
	"go.uber.org/zap"
)

// Filter 我的选股指标
// 注意：指标数据取决于最新一期的财报数据，可能是年报也可能是其他季报，使用时需注意应该同期对比
type Filter struct {
	// ------ 最重要的指标！！！------
	// 最低净资产收益率（%）， ROE_WEIGHT
	MinROE float64 `json:"min_roe" form:"selector_min_roe"`

	// ------ 必要参数 ------
	// 最低净利润增长率（%） ， NETPROFIT_YOY_RATIO
	MinNetprofitYoyRatio float64 `json:"min_netprofit_yoy_ratio"      form:"selector_min_netprofit_yoy_ratio"`
	// 最低营收增长率（%） ， TOI_YOY_RATIO
	MinToiYoyRatio float64 `json:"min_toi_yoy_ratio"            form:"selector_min_toi_yoy_ratio"`
	// 最低最新股息率（%）， ZXGXL
	MinZXGXL float64 `json:"min_zxgxl"                    form:"selector_min_zxgxl"`
	// 最低净利润 3 年复合增长率（%）， NETPROFIT_GROWTHRATE_3Y
	MinNetprofitGrowthrate3Y float64 `json:"min_netprofit_growthrate_3_y" form:"selector_min_netprofit_growthrate_3_y"`
	// 最低营收 3 年复合增长率（%）， INCOME_GROWTHRATE_3Y
	MinIncomeGrowthrate3Y float64 `json:"min_income_growthrate_3_y"    form:"selector_min_income_growthrate_3_y"`
	// 最低上市以来年化收益率（%） ， LISTING_YIELD_YEAR
	MinListingYieldYear float64 `json:"min_listing_yield_year"       form:"selector_min_listing_yield_year"`
	// 最低市净率， PBNEWMRQ
	MinPBNewMRQ float64 `json:"min_pb_new_mrq"               form:"selector_min_pb_new_mrq"`
	// 最大资产负债率 (%)
	MaxDebtAssetRatio float64 `json:"max_debt_asset_ratio"         form:"selector_max_debt_asset_ratio"`

	// ------ 可选参数 ------
	// 最低预测净利润同比增长（%）， PREDICT_NETPROFIT_RATIO
	MinPredictNetprofitRatio float64 `json:"min_predict_netprofit_ratio"     form:"selector_min_predict_netprofit_ratio"`
	// 最低预测营收同比增长（%）， PREDICT_INCOME_RATIO
	MinPredictIncomeRatio float64 `json:"min_predict_income_ratio"        form:"selector_min_predict_income_ratio"`
	// 最低总市值（亿）， TOTAL_MARKET_CAP
	MinTotalMarketCap float64 `json:"min_total_market_cap"            form:"selector_min_total_market_cap"`
	// 行业名（可选参数，不设置搜全行业）， INDUSTRY
	IndustryList []string `json:"industry_list"                   form:"selector_industry_list"`
	// 股价范围最小值（元）， NEW_PRICE
	MinPrice float64 `json:"min_price"                       form:"selector_min_price"`
	// 股价范围最大值（元）， NEW_PRICE
	MaxPrice float64 `json:"max_price"                       form:"selector_max_price"`
	// 上市时间是否超过 5 年，@LISTING_DATE="OVER5Y"
	ListingOver5Y bool `json:"listing_over_5_y"                form:"selector_listing_over_5_y"`
	// 最低上市以来年化波动率， LISTING_VOLATILITY_YEAR
	MinListingVolatilityYear float64 `json:"min_listing_volatility_year"     form:"selector_min_listing_volatility_year"`
	// 是否排除创业板 300XXX
	ExcludeCYB bool `json:"exclude_cyb"                     form:"selector_exclude_cyb"`
	// 是否排除科创板 688XXX
	ExcludeKCB bool `json:"exclude_kcb"                     form:"selector_exclude_kcb"`
	// 查询指定名称
	SpecialSecurityNameAbbrList []string `json:"special_security_name_abbr_list" form:"selector_special_security_name_abbr_list"`
	// 查询指定代码
	SpecialSecurityCodeList []string `json:"special_security_code_list"      form:"selector_special_security_code_list"`
	// 最小总资产收益率 ROA
	MinROA float64 `json:"min_roa"                         form:"selector_min_roa"`
}

// String 转为字符串的请求参数
func (f Filter) String() string {
	filter := ""
	// 特定查询
	if len(f.SpecialSecurityNameAbbrList) > 0 {
		names := []string{}
		for _, name := range f.SpecialSecurityNameAbbrList {
			names = append(names, fmt.Sprintf(`"%s"`, name))
		}
		filter += fmt.Sprintf(`(SECURITY_NAME_ABBR in (%s))`, strings.Join(names, ","))
		return filter
	}
	if len(f.SpecialSecurityCodeList) > 0 {
		codes := []string{}
		for _, code := range f.SpecialSecurityCodeList {
			codes = append(codes, fmt.Sprintf(`"%s"`, code))
		}
		filter += fmt.Sprintf(`(SECURITY_CODE in (%s))`, strings.Join(codes, ","))
		return filter
	}
	// 必要参数
	filter += fmt.Sprintf(`(ROE_WEIGHT>=%f)`, f.MinROE)
	filter += fmt.Sprintf(`(NETPROFIT_YOY_RATIO>=%f)`, f.MinNetprofitYoyRatio)
	filter += fmt.Sprintf(`(TOI_YOY_RATIO>=%f)`, f.MinToiYoyRatio)
	filter += fmt.Sprintf(`(ZXGXL>=%f)`, f.MinZXGXL)
	filter += fmt.Sprintf(`(NETPROFIT_GROWTHRATE_3Y>=%f)`, f.MinNetprofitGrowthrate3Y)
	filter += fmt.Sprintf(`(INCOME_GROWTHRATE_3Y>=%f)`, f.MinIncomeGrowthrate3Y)
	filter += fmt.Sprintf(`(LISTING_YIELD_YEAR>=%f)`, f.MinListingYieldYear)
	filter += fmt.Sprintf(`(PBNEWMRQ>=%f)`, f.MinPBNewMRQ)

	// 可选参数
	if f.MaxDebtAssetRatio != 0 {
		filter += fmt.Sprintf(`(DEBT_ASSET_RATIO<=%f)`, f.MaxDebtAssetRatio)
	}
	if f.MinPredictNetprofitRatio != 0 {
		filter += fmt.Sprintf(`(PREDICT_NETPROFIT_RATIO>=%f)`, f.MinPredictNetprofitRatio)
	}
	if f.MinPredictIncomeRatio != 0 {
		filter += fmt.Sprintf(`(PREDICT_INCOME_RATIO>=%f)`, f.MinPredictIncomeRatio)
	}
	if f.MinTotalMarketCap != 0 {
		filter += fmt.Sprintf(`(TOTAL_MARKET_CAP>=%f)`, f.MinTotalMarketCap*100000000)
	}
	if len(f.IndustryList) != 0 {
		industryIn := []string{}
		for _, i := range f.IndustryList {
			industryIn = append(industryIn, fmt.Sprintf(`"%s"`, i))
		}
		filter += fmt.Sprintf(`(INDUSTRY in (%s))`, strings.Join(industryIn, ","))
	}
	if f.MinPrice != 0 {
		filter += fmt.Sprintf(`(NEW_PRICE>=%f))`, f.MinPrice)
	}
	if f.MaxPrice != 0 {
		filter += fmt.Sprintf(`(NEW_PRICE<=%f))`, f.MaxPrice)
	}
	if f.ListingOver5Y {
		filter += `(@LISTING_DATE="OVER5Y")`
	}
	if f.MinListingVolatilityYear != 0 {
		filter += fmt.Sprintf(`(LISTING_VOLATILITY_YEAR>=%f))`, f.MinListingVolatilityYear)
	}
	if f.MinROA != 0 {
		filter += fmt.Sprintf(`(JROA>=%f)`, f.MinROA)
	}
	return filter
}

var (
	// DefaultFilter 默认指标值
	DefaultFilter = Filter{
		// 存在年报 ROE 大于 8，但季报小于 8 的情况会筛选不出来
		MinROE:            8.0,
		MinTotalMarketCap: 100.0,
		MinPBNewMRQ:       1.0,
		ExcludeCYB:        true,
		ExcludeKCB:        true,
	}
)

// StockInfo 接口返回的股票信息结构
type StockInfo struct {
	// 股票代码：带后缀
	Secucode string `json:"SECUCODE"`
	// 股票代码：无后缀
	SecurityCode string `json:"SECURITY_CODE"`
	// 股票名
	SecurityNameAbbr string `json:"SECURITY_NAME_ABBR"`
	// 行业
	Industry string `json:"INDUSTRY"`
	// 最新一期 ROE
	RoeWeight float64 `json:"ROE_WEIGHT"`
	// 净利润增长率（%）
	NetprofitYoyRatio float64 `json:"NETPROFIT_YOY_RATIO"`
	// 营收增长率（%）
	ToiYoyRatio float64 `json:"TOI_YOY_RATIO"`
	// 最新股息率 (%)
	Zxgxl float64 `json:"ZXGXL"`
	// 净利润 3 年复合增长率
	NetprofitGrowthrate3Y float64 `json:"NETPROFIT_GROWTHRATE_3Y"`
	// 营收 3 年复合增长率
	IncomeGrowthrate3Y float64 `json:"INCOME_GROWTHRATE_3Y"`
	// 上市以来年化收益率
	ListingYieldYear float64 `json:"LISTING_YIELD_YEAR"`
	// 市净率
	PBNewMRQ float64 `json:"PBNEWMRQ"`
	// 预测净利润同比增长
	PredictNetprofitRatio float64 `json:"PREDICT_NETPROFIT_RATIO"`
	// 预测营收同比增长
	PredictIncomeRatio float64 `json:"PREDICT_INCOME_RATIO"`
	// 总市值
	TotalMarketCap float64 `json:"TOTAL_MARKET_CAP"`
	// 最新价（元） 未开盘价格显示为 -
	NewPrice interface{} `json:"NEW_PRICE"`
	// 上市以来年化波动率
	ListingVolatilityYear float64 `json:"LISTING_VOLATILITY_YEAR"`
	// 上市时间
	ListingDate string `json:"LISTING_DATE"`
	// 资产负债率
	DebtAssetRatio float64 `json:"DEBT_ASSET_RATIO"`
	// ROA (%)
	ROA float64 `json:"JROA"`
	// 市盈率
	PE float64 `json:"PE9"`
}

// StockInfoList 股票列表
type StockInfoList []StockInfo

// SortByROE 股票列表按 ROE 排序
func (s StockInfoList) SortByROE() {
	sort.Slice(s, func(i, j int) bool {
		return s[i].RoeWeight > s[j].RoeWeight
	})
}

// RespSelectStocks 接口返回 json 结构
type RespSelectStocks struct {
	Result struct {
		Nextpage    bool          `json:"nextpage"`
		Currentpage int           `json:"currentpage"`
		Data        StockInfoList `json:"data"`
		Config      []struct {
			IndicatorName string `json:"INDICATOR_NAME"`
			Datatype      string `json:"DATATYPE"`
		} `json:"config"`
	} `json:"result"`
	Success bool   `json:"success"`
	Message string `json:"message"`
	Code    int    `json:"code"`
}

// QuerySelectedStocks 按选股指标默认值筛选股票
func (e EastMoney) QuerySelectedStocks(ctx context.Context) (StockInfoList, error) {
	return e.QuerySelectedStocksWithFilter(ctx, DefaultFilter)
}

// QuerySelectedStocksWithFilter 自定义选股指标值筛选股票
func (e EastMoney) QuerySelectedStocksWithFilter(ctx context.Context, filter Filter) (StockInfoList, error) {
	apiurl := "https://datacenter.eastmoney.com/stock/selection/api/data/get/"
	reqData := map[string]string{
		"source": "SELECT_SECURITIES",
		"client": "APP",
		"type":   "RPTA_APP_STOCKSELECT",
		"sty":    "SECUCODE,SECURITY_CODE,SECURITY_NAME_ABBR,INDUSTRY,ROE_WEIGHT,NETPROFIT_YOY_RATIO,TOI_YOY_RATIO,ZXGXL,NETPROFIT_GROWTHRATE_3Y,INCOME_GROWTHRATE_3Y,LISTING_YIELD_YEAR,PBNEWMRQ,PREDICT_NETPROFIT_RATIO,PREDICT_INCOME_RATIO,TOTAL_MARKET_CAP,NEW_PRICE,LISTING_VOLATILITY_YEAR,LISTING_DATE,DEBT_ASSET_RATIO,JROA,PE9",
		"filter": filter.String(),
		"p":      "1",      // page
		"ps":     "100000", // page size
	}
	logging.Info(ctx, "EastMoney QuerySelectedStocksWithFilter "+apiurl+" begin", zap.Any("reqData", reqData))
	beginTime := time.Now()
	req, err := goutils.NewHTTPMultipartReq(ctx, apiurl, reqData)
	if err != nil {
		return nil, err
	}
	resp := RespSelectStocks{}
	err = goutils.HTTPPOST(ctx, e.HTTPClient, req, &resp)
	latency := time.Now().Sub(beginTime).Milliseconds()
	logging.Info(
		ctx,
		"EastMoney SelectStocksWithFilter "+apiurl+" end",
		zap.Int64("latency(ms)", latency),
		// zap.Any("resp", resp),
	)
	if err != nil {
		return nil, err
	}
	if resp.Code != 0 {
		return nil, fmt.Errorf("%s %#v", filter.String(), resp)
	}
	result := StockInfoList{}
	for _, i := range resp.Result.Data {
		// 排除创业板
		if filter.ExcludeCYB && strings.HasPrefix(i.Secucode, "300") {
			logging.Debugf(ctx, "EastMoney SelectStocksWithFilter ExcludeCYB %s %s", i.SecurityNameAbbr, i.Secucode)
			continue
		}
		// 排除科创板
		if filter.ExcludeKCB && strings.HasPrefix(i.Secucode, "688") {
			logging.Debugf(ctx, "EastMoney SelectStocksWithFilter ExcludeKCB %s %s", i.SecurityNameAbbr, i.Secucode)
			continue
		}
		result = append(result, i)
	}
	return result, nil
}