扫描终端支持 region 参数按区域懒加载
This commit is contained in:
@@ -26,6 +26,7 @@ async def scan_terminal(
|
|||||||
time_range: str = "today",
|
time_range: str = "today",
|
||||||
limit: int = 25,
|
limit: int = 25,
|
||||||
force_refresh: bool = False,
|
force_refresh: bool = False,
|
||||||
|
region: str = "",
|
||||||
):
|
):
|
||||||
return await get_scan_terminal_payload(
|
return await get_scan_terminal_payload(
|
||||||
request,
|
request,
|
||||||
@@ -39,6 +40,7 @@ async def scan_terminal(
|
|||||||
time_range=time_range,
|
time_range=time_range,
|
||||||
limit=limit,
|
limit=limit,
|
||||||
force_refresh=force_refresh,
|
force_refresh=force_refresh,
|
||||||
|
region=region if region else None,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -46,9 +46,10 @@ async def get_scan_terminal_payload(
|
|||||||
time_range: str = "today",
|
time_range: str = "today",
|
||||||
limit: int = 25,
|
limit: int = 25,
|
||||||
force_refresh: bool = False,
|
force_refresh: bool = False,
|
||||||
|
region: str = "",
|
||||||
) -> Dict[str, Any]:
|
) -> Dict[str, Any]:
|
||||||
legacy_routes._assert_entitlement(request)
|
legacy_routes._assert_entitlement(request)
|
||||||
filters = {
|
filters: Dict[str, Any] = {
|
||||||
"scan_mode": scan_mode,
|
"scan_mode": scan_mode,
|
||||||
"min_price": min_price,
|
"min_price": min_price,
|
||||||
"max_price": max_price,
|
"max_price": max_price,
|
||||||
@@ -59,6 +60,8 @@ async def get_scan_terminal_payload(
|
|||||||
"time_range": time_range,
|
"time_range": time_range,
|
||||||
"limit": limit,
|
"limit": limit,
|
||||||
}
|
}
|
||||||
|
if region:
|
||||||
|
filters["trading_region"] = region
|
||||||
return await run_in_threadpool(
|
return await run_in_threadpool(
|
||||||
legacy_routes.build_scan_terminal_payload,
|
legacy_routes.build_scan_terminal_payload,
|
||||||
filters,
|
filters,
|
||||||
|
|||||||
Reference in New Issue
Block a user