From 7d7653d13ff86e0990b82430f11fc764bd542580 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 29 十一月 2023 15:59:51 +0800
Subject: [PATCH] bug修复
---
utils/hosting_api_util.py | 39 +++++++++++++++++++++++++++++++++++++++
1 files changed, 39 insertions(+), 0 deletions(-)
diff --git a/utils/hosting_api_util.py b/utils/hosting_api_util.py
index 09ed1c1..4a1e3cb 100644
--- a/utils/hosting_api_util.py
+++ b/utils/hosting_api_util.py
@@ -16,6 +16,7 @@
OPERRATE_SET = 1 # 璁剧疆
OPERRATE_DELETE = 2 # 鍒犻櫎
OPERRATE_GET = 3 # 鑾峰彇
+OPERRATE_ADD = 4 # 娣诲姞
# 浠ｇ爜鍚嶅崟绫诲瀷
CODE_LIST_WHITE = "white"
@@ -27,6 +28,7 @@
API_TYPE_TRADE = "trade" # 浜ゆ槗
API_TYPE_TRADE_STATE = "trade_state" # 浜ゆ槗鐘舵��
API_TYPE_TRADE_MODE = "trade_mode" # 浜ゆ槗妯″紡
+API_TYPE_SELL_RULE = "sell_rule" # 鍗栧嚭瑙勫垯
API_TYPE_CODE_LIST = "code_list" # 浠ｇ爜鍚嶅崟
API_TYPE_EXPORT_L2 = "export_l2" # 瀵煎嚭L2鏁版嵁
API_TYPE_INIT = "init" # 鍒濆鍖�
@@ -39,6 +41,9 @@
API_TYPE_GET_FROM_DATA_SERVER = "get_from_data_server" # 浠庢暟鎹湇鍔″櫒鎷夊彇鏁版嵁
API_TYPE_CODE_TRADE_INFO = "code_trade_info" # 浠ｇ爜浜ゆ槗淇℃伅
API_TYPE_CODE_L2_LISTEN_ACTIVE_COUNT = "l2_listen_active_count" # L2鏈夋晥鐩戝惉鏁伴噺
+API_TYPE_SAVE_RUNNING_DATA = "save_running_data" # 淇濆瓨杩愯鏃舵暟鎹�
+API_TYPE_GET_CODE_POSITION_INFO = "get_code_position_info" # 鑾峰彇浠ｇ爜鎸佷粨淇℃伅
+API_TYPE_COMMON_REQUEST = "common_request" # 閫氱敤璇锋眰
# 瓒呮椂鏃堕棿2s
TIMEOUT = 5.0
@@ -295,6 +300,40 @@
return __read_response(client, request_id, blocking, timeout=30)
+# 淇濆瓨姝ｅ湪杩愯鐨勬暟鎹�
+def save_running_data(blocking=True):
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ {"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)
+
+
+# 淇濆瓨姝ｅ湪杩愯鐨勬暟鎹�
+def sell_rule(operate, data={}, blocking=True):
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ {"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)
+
+
+# 鑾峰彇浠ｇ爜鎸佷粨淇℃伅
+def get_code_position_info(code, blocking=True):
+ request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,
+ {"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)
+
+
+def common_request(params={}, blocking=True):
+ data = {"type": API_TYPE_COMMON_REQUEST,
+ "sinfo": f"cb_{API_TYPE_COMMON_REQUEST}_{round(time.time() * 1000)}"}
+ 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)
+
+
if __name__ == "__main__":
d = {"id": "123123"}
print(d.pop("id"))
--
Gitblit v1.8.0