Merge branch 'feat_traderank' into 'master'

Feat traderank

See merge request server/openapi/openapi-python-sdk!231

Author: tigersk

CHANGELOG.md

@@ -1,3 +1,9 @@
+## 3.3.2 (2025-02-25)
+### New
+- `QuoteClient.get_trade_rank` 热门交易榜
+### Mod
+- Contract 添加属性 lot_size
+
 ## 3.3.1 (2024-12-31)
 ### New
 - `TradeClient.get_funding_history` 出入金历史查询

tigeropen/__init__.py

@@ -4,4 +4,4 @@
 
 @author: gaoan
 """
-__VERSION__ = '3.3.1'
+__VERSION__ = '3.3.2'

tigeropen/common/consts/service_types.py

@@ -72,6 +72,7 @@
 WARRANT_REAL_TIME_QUOTE = "warrant_real_time_quote"
 KLINE_QUOTA = "kline_quota"  # 历史k线额度
 STOCK_FUNDAMENTAL = "stock_fundamental"
+TRADE_RANK = "trade_rank"
 
 # 期权行情
 OPTION_EXPIRATION = "option_expiration"

tigeropen/quote/quote_client.py

@@ -15,7 +15,7 @@
 from tigeropen.common.consts import THREAD_LOCAL, SecurityType, CorporateActionType, IndustryLevel
 from tigeropen.common.consts.filter_fields import FieldBelongType
 from tigeropen.common.consts.service_types import GRAB_QUOTE_PERMISSION, QUOTE_DELAY, GET_QUOTE_PERMISSION, \
-    HISTORY_TIMELINE, FUTURE_CONTRACT_BY_CONTRACT_CODE, STOCK_FUNDAMENTAL, TRADING_CALENDAR, FUTURE_CONTRACTS, MARKET_SCANNER, \
+    HISTORY_TIMELINE, FUTURE_CONTRACT_BY_CONTRACT_CODE, STOCK_FUNDAMENTAL, TRADE_RANK, TRADING_CALENDAR, FUTURE_CONTRACTS, MARKET_SCANNER, \
     STOCK_BROKER, CAPITAL_FLOW, CAPITAL_DISTRIBUTION, WARRANT_REAL_TIME_QUOTE, WARRANT_FILTER, MARKET_SCANNER_TAGS, \
     KLINE_QUOTA, FUND_ALL_SYMBOLS, FUND_CONTRACTS, FUND_QUOTE, FUND_HISTORY_QUOTE, FINANCIAL_CURRENCY, \
     FINANCIAL_EXCHANGE_RATE, ALL_HK_OPTION_SYMBOLS, OPTION_DEPTH
@@ -79,6 +79,7 @@
 from tigeropen.quote.response.stock_trade_meta_response import TradeMetaResponse
 from tigeropen.quote.response.symbol_names_response import SymbolNamesResponse
 from tigeropen.quote.response.symbols_response import SymbolsResponse
+from tigeropen.quote.response.trade_rank_response import TradeRankResponse
 from tigeropen.quote.response.trading_calendar_response import TradingCalendarResponse
 from tigeropen.quote.response.warrant_briefs_response import WarrantBriefsResponse
 from tigeropen.quote.response.warrant_filter_response import WarrantFilterResponse
@@ -1887,4 +1888,18 @@ def get_stock_fundamental(self, symbols, market):
             else:
                 raise ApiException(response.code, response.message)
 
+    def get_trade_rank(self, market, lang=Language.en_US):
+        params = MarketParams()
+        params.market = get_enum_value(market)
+        params.lang = get_enum_value(lang)
+        request = OpenApiRequest(TRADE_RANK, biz_model=params)
+        response_content = self.__fetch_data(request)
+        if response_content:
+            response = TradeRankResponse()
+            response.parse_response_content(response_content)
+            if response.is_success():
+                return response.result
+            else:
+                raise ApiException(response.code, response.message)
+
 

tigeropen/quote/request/model.py

@@ -1479,3 +1479,4 @@ def to_openapi_dict(self):
         if self.with_details is not None:
             params['with_details'] = self.with_details
         return params
+    

tigeropen/quote/response/trade_rank_response.py

@@ -0,0 +1,28 @@
+from tigeropen.common.response import TigerResponse
+import pandas as pd
+from tigeropen.common.util.string_utils import camel_to_underline_obj
+
+class TradeRankResponse(TigerResponse):
+    def __init__(self):
+        super(TradeRankResponse, self).__init__()
+        self.result = pd.DataFrame()
+        self._is_success = None
+
+    def parse_response_content(self, response_content):
+        response = super(TradeRankResponse, self).parse_response_content(response_content)
+        if 'is_success' in response:
+            self._is_success = response['is_success']
+
+        if self.data:
+            df_data = []
+            for item in self.data:
+                formated_item = camel_to_underline_obj(item)
+                hour_trading = formated_item.pop('hour_trading', None)
+                if hour_trading:
+                    for key, value in hour_trading.items():
+                        formated_item['hour_trading_' + key] = value
+                df_data.append(formated_item)
+
+            self.result = pd.DataFrame(df_data)
+
+