From b874fdb322d0740838f73e5ed260f800bf43ad1a Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 22 三月 2024 15:51:57 +0800
Subject: [PATCH] 增加外部端口
---
utils/hosting_api_util.py | 67 +++++++++++++++++----------------
1 files changed, 34 insertions(+), 33 deletions(-)
diff --git a/utils/hosting_api_util.py b/utils/hosting_api_util.py
index 4a1e3cb..4d65ac5 100644
--- a/utils/hosting_api_util.py
+++ b/utils/hosting_api_util.py
@@ -23,7 +23,7 @@
CODE_LIST_BLACK = "black"
CODE_LIST_WANT = "want"
CODE_LIST_PAUSE_BUY = "pause_buy"
-
+CODE_LIST_MUST_BUY = "must_buy"
# 绫诲瀷
API_TYPE_TRADE = "trade" # 浜ゆ槗
API_TYPE_TRADE_STATE = "trade_state" # 浜ゆ槗鐘舵��
@@ -131,13 +131,14 @@
# blocking鏄惁闃诲杩涚▼
def trade_order(direction, code, volume, price, price_type=2, blocking=True):
print("瀹㈡埛绔�", ClientSocketManager.socket_client_dict)
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
- {"type": API_TYPE_TRADE, "trade_type": 1,
- "direction": direction,
- "code": code,
- "volume": volume,
- "price_type": price_type,
- "price": price, "sinfo": f"order_{code}_{round(time.time() * 1000)}"})
+ request_id, client = __request(
+ ClientSocketManager.CLIENT_TYPE_TRADE if direction == 1 else ClientSocketManager.CLIENT_TYPE_TRADE_SELL,
+ {"type": API_TYPE_TRADE, "trade_type": 1,
+ "direction": direction,
+ "code": code,
+ "volume": volume,
+ "price_type": price_type,
+ "price": price, "sinfo": f"order_{code}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking)
@@ -156,7 +157,7 @@
# 璁剧疆浜ゆ槗鐘舵��
def set_trade_state(state, blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_TRADE_STATE, "operate": OPERRATE_SET,
"state": state,
"sinfo": f"cb_{API_TYPE_TRADE_STATE}_{round(time.time() * 1000)}"})
@@ -165,7 +166,7 @@
# 鑾峰彇浜ゆ槗鐘舵��
def get_trade_state(blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_TRADE_STATE, "operate": OPERRATE_GET,
"sinfo": f"cb_{API_TYPE_TRADE_STATE}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking)
@@ -173,7 +174,7 @@
# 璁剧疆浜ゆ槗妯″紡
def set_trade_mode(mode, blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_TRADE_MODE, "operate": OPERRATE_SET, "mode": mode,
"sinfo": f"cb_{API_TYPE_TRADE_MODE}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking)
@@ -181,7 +182,7 @@
# 鑾峰彇浜ゆ槗妯″紡
def get_trade_mode(blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_TRADE_MODE, "operate": OPERRATE_GET,
"sinfo": f"cb_{API_TYPE_TRADE_MODE}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking)
@@ -189,7 +190,7 @@
# -----浠ｇ爜鍚嶅崟鎿嶄綔----
def add_code_list(code, code_list_type, blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_CODE_LIST, "code_list_type": code_list_type, "code": code,
"operate": OPERRATE_SET,
"sinfo": f"cb_{API_TYPE_CODE_LIST}_{round(time.time() * 1000)}"})
@@ -197,7 +198,7 @@
def remove_code_list(code, code_list_type, blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_CODE_LIST, "code_list_type": code_list_type, "code": code,
"operate": OPERRATE_DELETE,
"sinfo": f"cb_{API_TYPE_CODE_LIST}_{round(time.time() * 1000)}"})
@@ -205,7 +206,7 @@
def get_code_list(code_list_type, blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_CODE_LIST, "code_list_type": code_list_type,
"operate": OPERRATE_GET,
"sinfo": f"cb_{API_TYPE_CODE_LIST}_{round(time.time() * 1000)}"})
@@ -214,7 +215,7 @@
# -----瀵煎嚭L2鏁版嵁----
def export_l2_data(code, blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_EXPORT_L2, "code": code,
"sinfo": f"cb_{API_TYPE_EXPORT_L2}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking)
@@ -222,7 +223,7 @@
# -----姣忔棩鍒濆鍖�----
def everyday_init(blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_INIT,
"sinfo": f"cb_{API_TYPE_INIT}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking)
@@ -230,7 +231,7 @@
# 鍒锋柊浜ゆ槗鏁版嵁
def refresh_trade_data(type, blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_REFRESH_TRADE_DATA, "ctype": type,
"sinfo": f"cb_{API_TYPE_REFRESH_TRADE_DATA}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking)
@@ -238,7 +239,7 @@
# 鑾峰彇浠ｇ爜灞炴��
def get_code_attribute(code, blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_CODE_ATRRIBUTE, "code": code,
"sinfo": f"cb_{API_TYPE_CODE_ATRRIBUTE}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking)
@@ -246,7 +247,7 @@
# 鑾峰彇浠ｇ爜浜ゆ槗鐘舵��
def get_code_trade_state(code, blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_CODE_TRADE_STATE, "code": code,
"sinfo": f"{API_TYPE_CODE_TRADE_STATE}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking)
@@ -254,7 +255,7 @@
# 鑾峰彇鐜淇℃伅
def get_env_info(blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_GET_ENV,
"sinfo": f"cb_{API_TYPE_GET_ENV}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking)
@@ -262,7 +263,7 @@
# 鑾峰彇鐜淇℃伅
def sync_l1_subscript_codes(blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_SYNC_L1_TARGET_CODES,
"sinfo": f"cb_{API_TYPE_SYNC_L1_TARGET_CODES}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking)
@@ -270,7 +271,7 @@
# 鑾峰彇绯荤粺鏃ュ織
def get_system_logs(start_index, count, blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_SYSTEM_LOG, "start_index": start_index, "count": count,
"sinfo": f"cb_{API_TYPE_SYSTEM_LOG}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking)
@@ -278,7 +279,7 @@
# 鎷夊彇data_server鐨勫唴瀹�
def get_from_data_server(path, params, blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_GET_FROM_DATA_SERVER, "path": path, "params": params,
"sinfo": f"cb_{API_TYPE_GET_FROM_DATA_SERVER}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking, timeout=30)
@@ -286,7 +287,7 @@
# 鑾峰彇浠ｇ爜鐨勪氦鏄撲俊鎭�
def get_code_trade_info(code, blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_CODE_TRADE_INFO, "code": code,
"sinfo": f"cb_{API_TYPE_CODE_TRADE_INFO}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking, timeout=30)
@@ -294,7 +295,7 @@
# L2鏈夋晥鐩戝惉鏁伴噺
def get_l2_listen_active_count(blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_CODE_L2_LISTEN_ACTIVE_COUNT,
"sinfo": f"cb_{API_TYPE_CODE_L2_LISTEN_ACTIVE_COUNT}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking, timeout=30)
@@ -302,7 +303,7 @@
# 淇濆瓨姝ｅ湪杩愯鐨勬暟鎹�
def save_running_data(blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,
{"type": API_TYPE_SAVE_RUNNING_DATA,
"sinfo": f"cb_{API_TYPE_SAVE_RUNNING_DATA}_{round(time.time() * 1000)}"})
return __read_response(client, request_id, blocking, timeout=30)
@@ -310,18 +311,18 @@
# 淇濆瓨姝ｅ湪杩愯鐨勬暟鎹�
def sell_rule(operate, data={}, blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE_SELL,
{"type": API_TYPE_SELL_RULE, "operate": operate, "data": data,
"sinfo": f"cb_{API_TYPE_SELL_RULE}_{round(time.time() * 1000)}"})
- return __read_response(client, request_id, blocking, timeout=30)
+ return __read_response(client, request_id, blocking, timeout=10)
# 鑾峰彇浠ｇ爜鎸佷粨淇℃伅
def get_code_position_info(code, blocking=True):
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE_SELL,
{"type": API_TYPE_GET_CODE_POSITION_INFO, "code": code,
"sinfo": f"cb_{API_TYPE_GET_CODE_POSITION_INFO}_{round(time.time() * 1000)}"})
- return __read_response(client, request_id, blocking, timeout=30)
+ return __read_response(client, request_id, blocking)
def common_request(params={}, blocking=True):
@@ -330,8 +331,8 @@
if params:
for k in params:
data[k] = params[k]
- request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE, data)
- return __read_response(client, request_id, blocking, timeout=30)
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON, data)
+ return __read_response(client, request_id, blocking, timeout=10)
if __name__ == "__main__":
--
Gitblit v1.8.0