From 3cc54d41c3f33e2d3557fd34eed163f3af48c19e Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 18 七月 2023 18:05:53 +0800
Subject: [PATCH] 新增掘金检测接口
---
trade/huaxin/trade_api_server.py | 30 ++++++++++++++++++++++++++----
1 files changed, 26 insertions(+), 4 deletions(-)
diff --git a/trade/huaxin/trade_api_server.py b/trade/huaxin/trade_api_server.py
index 34a127a..14409e7 100644
--- a/trade/huaxin/trade_api_server.py
+++ b/trade/huaxin/trade_api_server.py
@@ -13,9 +13,9 @@
from code_attribute import gpcode_manager
from l2 import l2_data_manager_new
from l2.huaxin import huaxin_target_codes_manager
-from log_module.log import hx_logger_trade_debug
+from log_module.log import hx_logger_trade_debug
from third_data import block_info
-from third_data.history_k_data_util import HistoryKDatasUtils
+from third_data.history_k_data_util import HistoryKDatasUtils, JueJinApi
from trade import trade_manager, trade_huaxin
from trade.huaxin import huaxin_trade_api as trade_api, huaxin_trade_api, huaxin_trade_record_manager
@@ -273,12 +273,34 @@
except Exception as e:
logging.exception(e)
return_str = json.dumps(
- {"code": 1, "msg": str(e)})
+ {"code": 1, "msg": str(e)})
elif type_ == 'everyday_init':
# 姣忔棩鍒濆鍖�
inited_data.everyday_init()
return_str = json.dumps(
{"code": 0, "data": {}, "msg": ""})
+ elif type_ == 'huaxin_channel_state':
+ # 鍗庨懌閫氶亾鐘舵��
+ types = [huaxin_trade_api.ClientSocketManager.CLIENT_TYPE_TRADE,
+ huaxin_trade_api.ClientSocketManager.CLIENT_TYPE_CMD_L2,
+ huaxin_trade_api.ClientSocketManager.CLIENT_TYPE_DEAL_LIST,
+ huaxin_trade_api.ClientSocketManager.CLIENT_TYPE_DELEGATE_LIST,
+ huaxin_trade_api.ClientSocketManager.CLIENT_TYPE_MONEY,
+ huaxin_trade_api.ClientSocketManager.CLIENT_TYPE_POSITION_LIST]
+ fdata = {}
+ for t in types:
+ trade_list = huaxin_trade_api.ClientSocketManager.list_client(t)
+ fdata[t] = len(trade_list)
+ elif type_ == 'juejin_is_valid':
+ # 鎺橀噾鏄惁鍙敤
+ try:
+ date = JueJinApi.get_previous_trading_date(tool.get_now_date_str())
+ if date:
+ return_str = json.dumps(
+ {"code": 0, "msg": ""})
+ except Exception as e:
+ return_str = json.dumps(
+ {"code": 0, "msg": str(e)})
# 鏌ヨ濮旀墭鍒楄〃
elif type_ == 'test':
# 鍗栧嚭
@@ -350,7 +372,7 @@
# 璁剧疆鍙敤璧勯噾
elif type_ == "deal_list":
dataJSON = huaxin_trade_api.get_deal_list()
- print("鎴愪氦鍝嶅簲锛�",dataJSON)
+ print("鎴愪氦鍝嶅簲锛�", dataJSON)
if dataJSON["code"] == 0:
data = dataJSON["data"]
huaxin_trade_record_manager.DealRecordManager.add(data)
--
Gitblit v1.8.0