From 36731498e1b7c65a69cd15d626fedca4c92c1042 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期四, 20 二月 2025 17:39:54 +0800
Subject: [PATCH] 增加撤单
---
utils/juejin_api.py | 33 +++++++++++++++++++++++++++++----
1 files changed, 29 insertions(+), 4 deletions(-)
diff --git a/utils/juejin_api.py b/utils/juejin_api.py
index bb3a746..fcdec00 100644
--- a/utils/juejin_api.py
+++ b/utils/juejin_api.py
@@ -38,6 +38,10 @@
{"exchanges": exchanges, "sec_types": sec_types, "skip_suspended": skip_suspended,
"skip_st": skip_st, "fields": fields})
+ @classmethod
+ def current(cls, symbols, fields):
+ return cls.__request("current", {"symbols": symbols, "fields": fields})
+
class JueJinApi:
# 鑾峰彇浜ゆ槗鎵�鐨勪唬鐮�
@@ -54,7 +58,7 @@
鑾峰彇鐩爣浠ｇ爜
:return:
"""
- datas = JueJinApi.get_exchanges_codes(["SHSE", "SZSE"])
+ datas = cls.get_exchanges_codes(["SHSE", "SZSE"])
fdatas = []
for d in datas:
if d["sec_level"] != 1:
@@ -62,12 +66,33 @@
fdatas.append(d)
return fdatas
+ # 鑾峰彇鐩爣鑲＄エ鑼冨洿鍐呯殑寮�鐩樹环
+ @classmethod
+ def get_codes_open(cls, symbols, fields):
+ current = JueJinHttpApi.current(symbols, fields)
+ # print(f"current=={current}")
+ # current_datas==[{'symbol': 'SZSE.001288', 'open': 30.27, 'high': 31.77, 'low': 30.27, 'price': 30.77, 'quotes': [{'bid_p': 30.77, 'bid_v': 500, 'ask_p': 30.78, 'ask_v': 3900}, {'bid_p': 30.76, 'bid_v': 800, 'ask_p': 30.79, 'ask_v': 3100}, {'bid_p': 30.75, 'bid_v': 21900, 'ask_p': 30.8, 'ask_v': 22100}, {'bid_p': 30.72, 'bid_v': 1300, 'ask_p': 30.82, 'ask_v': 300}, {'bid_p': 30.7, 'bid_v': 600, 'ask_p': 30.83, 'ask_v': 2700}], 'cum_volume': 2586914, 'cum_amount': 80020708.18, 'trade_type': 8, 'created_at': datetime.datetime(2025, 2, 12, 14, 50, 18, tzinfo=datetime.timezone(datetime.timedelta(seconds=28800)))}]
+ return current
+
+ # 鑾峰彇鐩爣鑲＄エ鑼冨洿鍐呯殑鏃ュ唴瀹炴椂鏈�楂樹环鍜屾渶浣庝环
+ @classmethod
+ def get_codes_high_and_low(cls, symbols, fields):
+ current = JueJinHttpApi.current(symbols, fields)
+ # print(f"current=={current}")
+ # current_datas==[{'symbol': 'SZSE.001288', 'open': 30.27, 'high': 31.77, 'low': 30.27, 'price': 30.77, 'quotes': [{'bid_p': 30.77, 'bid_v': 500, 'ask_p': 30.78, 'ask_v': 3900}, {'bid_p': 30.76, 'bid_v': 800, 'ask_p': 30.79, 'ask_v': 3100}, {'bid_p': 30.75, 'bid_v': 21900, 'ask_p': 30.8, 'ask_v': 22100}, {'bid_p': 30.72, 'bid_v': 1300, 'ask_p': 30.82, 'ask_v': 300}, {'bid_p': 30.7, 'bid_v': 600, 'ask_p': 30.83, 'ask_v': 2700}], 'cum_volume': 2586914, 'cum_amount': 80020708.18, 'trade_type': 8, 'created_at': datetime.datetime(2025, 2, 12, 14, 50, 18, tzinfo=datetime.timezone(datetime.timedelta(seconds=28800)))}]
+ return current
+
if __name__ == '__main__':
# 鑾峰彇鐩爣浠ｇ爜锛堣幏鍙栫洰鏍囩エ锛�
- print(JueJinApi.get_exchanges_codes(["SHSE", "SZSE"]))
+ # print(f"JueJinApi.get_exchanges_codes==={JueJinApi.get_exchanges_codes(['SHSE', 'SZSE'])}")
+ symbols = ['SZSE.001288', 'SZSE.000042']
+ fields = 'symbol,open'
+ # JueJinApi.get_codes_open(symbols, fields)
#
- strategy.data_cache.all_stocks = JueJinApi.get_exchanges_codes(["SHSE", "SZSE"])
- print(len(JueJinApi.get_exchanges_codes(["SHSE", "SZSE"])))
+ # strategy.data_cache.all_stocks = JueJinApi.get_exchanges_codes(["SHSE", "SZSE"])
+ # current = JueJinHttpApi.current(symbols, fields)
+ # print(current)
+ # print(f"JueJinApi.get_exchanges_codes(['SHSE', 'SZSE'])=={len(JueJinApi.get_exchanges_codes(['SHSE', 'SZSE']))}")
--
Gitblit v1.8.0