获取最新前10大流通股东

datacenter/eastmoney/free_holders.go

@@ -0,0 +1,73 @@
+// 获取十大流通股东
+
+package eastmoney
+
+import (
+	"context"
+	"fmt"
+	"strings"
+	"time"
+
+	"github.com/axiaoxin-com/goutils"
+	"github.com/axiaoxin-com/logging"
+
+	"go.uber.org/zap"
+)
+
+// FreeHolder 流通股东
+type FreeHolder struct {
+	EndDate          string  `json:"END_DATE"`
+	HolderName       string  `json:"HOLDER_NAME"`
+	HolderCode       string  `json:"HOLDER_CODE"`
+	HoldNum          int     `json:"HOLD_NUM"`
+	FreeHoldnumRatio float64 `json:"FREE_HOLDNUM_RATIO"`
+	FreeRatioQoq     string  `json:"FREE_RATIO_QOQ"`
+	IsHoldorg        string  `json:"IS_HOLDORG"`
+	HolderRank       int     `json:"HOLDER_RANK"`
+}
+
+// RespFreeHolders QueryFreeHolders 返回json结构
+type RespFreeHolders struct {
+	Version string `json:"version"`
+	Result  struct {
+		Pages int          `json:"pages"`
+		Data  []FreeHolder `json:"data"`
+		Count int          `json:"count"`
+	} `json:"result"`
+	Success bool   `json:"success"`
+	Message string `json:"message"`
+	Code    int    `json:"code"`
+}
+
+// QueryFreeHolders 获取前十大流通股东信息
+func (e EastMoney) QueryFreeHolders(ctx context.Context, secuCode string) ([]FreeHolder, error) {
+	apiurl := "https://datacenter.eastmoney.com/securities/api/data/v1/get"
+	params := map[string]string{
+		"reportName": "RPT_F10_EH_FREEHOLDERS",
+		"columns":    "END_DATE,HOLDER_NAME,HOLDER_CODE,HOLD_NUM,FREE_HOLDNUM_RATIO,FREE_RATIO_QOQ,IS_HOLDORG,HOLDER_RANK",
+		"filter":     fmt.Sprintf(`(SECUCODE="%s")`, strings.ToUpper(secuCode)),
+		"pageSize":   "10",
+	}
+	logging.Debug(ctx, "EastMoney QueryFreeHolders "+apiurl+" begin", zap.Any("params", params))
+	beginTime := time.Now()
+	apiurl, err := goutils.NewHTTPGetURLWithQueryString(ctx, apiurl, params)
+	if err != nil {
+		return nil, err
+	}
+	resp := RespFreeHolders{}
+	err = goutils.HTTPGET(ctx, e.HTTPClient, apiurl, &resp)
+	latency := time.Now().Sub(beginTime).Milliseconds()
+	logging.Debug(
+		ctx,
+		"EastMoney QueryFreeHolders "+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", secuCode, resp)
+	}
+	return resp.Result.Data, nil
+}

datacenter/eastmoney/free_holders_test.go

@@ -0,0 +1,14 @@
+package eastmoney
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/require"
+)
+
+func TestQueryFreeHolders(t *testing.T) {
+	data, err := _em.QueryFreeHolders(_ctx, "600031.sh")
+	t.Log(data)
+	require.Nil(t, err)
+	require.Len(t, data, 10)
+}