From c18a3c3d1e319f6ba3f3ab6a99bea7d1d7030130 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 29 五月 2024 16:29:18 +0800
Subject: [PATCH] 获取最近的市场行情
---
main.py | 23 ++++++++++++++++++++---
1 files changed, 20 insertions(+), 3 deletions(-)
diff --git a/main.py b/main.py
index 65848e3..e0964ff 100644
--- a/main.py
+++ b/main.py
@@ -10,7 +10,7 @@
from code_attribute import target_codes_manager, gpcode_manager, code_market_manager, history_k_data_util
from huaxin_client import l2_client_for_cb, trade_client_for_cb
from huaxin_client.client_network import SendResponseSkManager
-from log_module import async_log_util
+from log_module import async_log_util, log_export
from records import huaxin_trade_record_manager
from trade import huaxin_trade_api, huaxin_trade_data_update, huaxin_sell_util
from utils import middle_api_protocol, outside_api_command_manager, constant, tool, huaxin_util, socket_util, sell_util, \
@@ -171,8 +171,10 @@
# 鑾峰彇涔扮偣涓庡崠鐐�
buys = huaxin_trade_record_manager.DealRecordManager().list_buy_by_code_cache(cb_code)
sells = huaxin_trade_record_manager.DealRecordManager().list_sell_by_code_cache(cb_code)
- r["buy_list"] = [{"price": str(x["price"]), "tradeTime": x["tradeTime"], "volume": x["volume"]} for x in buys]
- r["sell_list"] = [{"price": str(x["price"]), "tradeTime": x["tradeTime"], "volume": x["volume"]} for x in sells]
+ r["buy_list"] = [{"price": str(x["price"]), "tradeTime": x["tradeTime"], "volume": x["volume"]} for x in
+ buys]
+ r["sell_list"] = [{"price": str(x["price"]), "tradeTime": x["tradeTime"], "volume": x["volume"]} for x in
+ sells]
send_response({"code": 0, "data": results}, client_id, request_id)
elif type_ == "refresh_trade_data":
# 鍒锋柊浜ゆ槗鏁版嵁
@@ -251,6 +253,19 @@
pass
+def __init_data():
+ """
+ 鍒濆鍖栧弬鏁�
+ :return:
+ """
+ try:
+ market_dict = log_export.load_latest_market_info()
+ for k in market_dict:
+ code_market_manager.set_market_info(market_dict[k])
+ except Exception as e:
+ logger_debug.exception(e)
+
+
if __name__ == '__main__':
# ===========鍒濆鍖栨暟鎹�==========
try:
@@ -258,6 +273,8 @@
except Exception as e:
logger_debug.exception(e)
+ __init_data()
+
trade_call_back_queue = multiprocessing.Queue()
# 鍗庨懌浜ゆ槗鏁版嵁鏇存柊
--
Gitblit v1.8.0