diff --git a/scripts/data_platform/fundamentals_dmsk_download.py b/scripts/data_platform/fundamentals_dmsk_download.py index f08f5ae..c2e6a3d 100644 --- a/scripts/data_platform/fundamentals_dmsk_download.py +++ b/scripts/data_platform/fundamentals_dmsk_download.py @@ -388,7 +388,10 @@ def fetch_period_rows(client, domain, report_date): while True: params = { "sortColumns": "SECURITY_CODE", "sortTypes": "1", - "pageSize": str(DC_PAGE_SIZE), "pageNum": str(page), + "pageSize": str(DC_PAGE_SIZE), + "pageNumber": str(page), # 东财 datacenter 用 pageNumber(cninfo + # 才是 pageNum; 写错被静默忽略=翻页 + # 失效, 每页都回第一页, 冒烟 12 页同 500 行实锤) "reportName": DOMAINS[domain], "columns": "ALL", "filter": f"(REPORT_DATE='{report_date}')", } diff --git a/tests/data_platform/test_fundamentals_dmsk_download.py b/tests/data_platform/test_fundamentals_dmsk_download.py index 171c958..7b3c6f2 100644 --- a/tests/data_platform/test_fundamentals_dmsk_download.py +++ b/tests/data_platform/test_fundamentals_dmsk_download.py @@ -99,7 +99,7 @@ def test_fetch_period_rows_paginates_to_pages_end(root, monkeypatch): def fake_request(method, url, **kw): calls.append(kw["params"]) - page = int(kw["params"]["pageNum"]) + page = int(kw["params"]["pageNumber"]) return FakeResp({"result": {"pages": 3, "count": 6, "data": [ _raw(code=f"60000{page}")] * 2}, "success": True})