From 62c99e398d9b05a30fc80f29a0048b95bafa77d7 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 18 六月 2025 10:41:11 +0800
Subject: [PATCH] ‘功能完善
---
api/outside_api_callback.py | 15 ++++++++++++++-
1 files changed, 14 insertions(+), 1 deletions(-)
diff --git a/api/outside_api_callback.py b/api/outside_api_callback.py
index 309b376..b4b640f 100644
--- a/api/outside_api_callback.py
+++ b/api/outside_api_callback.py
@@ -3,10 +3,12 @@
import os
import threading
+import constant
+
from api.outside_api_command_manager import ActionCallback
from huaxin_client import l1_subscript_codes_manager
from huaxin_client.client_network import SendResponseSkManager
-from strategy import strategy_params_settings, env_info
+from strategy import strategy_params_settings, env_info, strategy_manager
from strategy.env_info import RealTimeEnvInfo
from strategy.strategy_variable_factory import DataLoader
from third_data.history_k_data_manager import TradeDateManager
@@ -137,6 +139,14 @@
threading.Thread(target=lambda: update(), daemon=True).start()
return {"code": 0}
+ def __on_init_data(self):
+ try:
+ strategy_manager.low_suction_strtegy.load_data()
+ return {"code": 0}
+ except Exception as e:
+ logging.exception(e)
+ return {"code": 1, "msg": str(e)}
+
def OnCommonRequest(self, client_id, request_id, data):
ctype = data["ctype"]
result_json = {}
@@ -154,4 +164,7 @@
elif ctype == 'update_kpl_code_jx_blocks_datas':
# 鏇存柊寮�鐩樺暒绮鹃�夋暟鎹�
result_json = self.__on_update_kpl_code_jx_blocks_datas()
+ elif ctype == 'init_datas':
+ # 鍒濆鍖栨暟鎹�
+ result_json = self.__on_init_data()
self.send_response(result_json, client_id, request_id)
--
Gitblit v1.8.0