From bccc14e6d890cefb5309c904a6413bea1270ff03 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 01 七月 2025 10:59:46 +0800
Subject: [PATCH] bug修复/策略完善
---
api/outside_api_callback.py | 24 ++++++++++++++++++++----
1 files changed, 20 insertions(+), 4 deletions(-)
diff --git a/api/outside_api_callback.py b/api/outside_api_callback.py
index bc65062..e43b9f4 100644
--- a/api/outside_api_callback.py
+++ b/api/outside_api_callback.py
@@ -6,11 +6,13 @@
import constant
from api.outside_api_command_manager import ActionCallback
+from code_attribute import gpcode_manager
from huaxin_client import l1_subscript_codes_manager
from huaxin_client.client_network import SendResponseSkManager
from strategy import strategy_params_settings, env_info, strategy_manager
from strategy.env_info import RealTimeEnvInfo
from strategy.strategy_manager import PlateWhiteListManager
+from strategy.strategy_params_settings import StrategyParamsSettingsManager, StrategyParamsSettings
from strategy.strategy_variable_factory import DataLoader
from third_data.history_k_data_manager import TradeDateManager
from third_data.kpl_block_manager import KPLCodeJXBlocksManager
@@ -22,6 +24,7 @@
OPERRATE_DELETE = 2 # 鍒犻櫎
OPERRATE_GET = 3 # 鑾峰彇
OPERRATE_ADD = 4 # 鏂板
+
class MyAPICallback(ActionCallback):
@@ -170,8 +173,8 @@
def __on_plate_white_list(self, data):
operate = data["operate"]
if operate == OPERRATE_GET:
- plates = PlateWhiteListManager().get_plates()
- return {"code": 0, "data": list(plates)}
+ plates = PlateWhiteListManager().get_plates()
+ return {"code": 0, "data": list(plates)}
elif operate == OPERRATE_ADD:
plate = data["plate"]
PlateWhiteListManager().add_plate(plate)
@@ -180,8 +183,6 @@
plate = data["plate"]
PlateWhiteListManager().remove_plate(plate)
return {"code": 0}
-
-
def OnCommonRequest(self, client_id, request_id, data):
ctype = data["ctype"]
@@ -206,7 +207,22 @@
elif ctype == 'get_place_order_records':
# 鑾峰彇涓嬪崟璁板綍
datas = trade_record_log_util.get_trade_records(trade_record_log_util.TYPE_PLACE_ORDER)
+ for data in datas:
+ data[3]["code_name"] = gpcode_manager.CodesNameManager().get_code_name(data[3]["code"])
result_json = {"code": 0, "data": datas}
+ elif ctype == 'get_can_buy_plates':
+ # 鑾峰彇鍙互涔扮殑鏉垮潡
+ settings: StrategyParamsSettings = StrategyParamsSettingsManager().get_settings()
+ try:
+ current_limit_up_plate_codes = strategy_manager.low_suction_strtegy.current_limit_up_plate_codes
+ plates = [plate for plate, codes in current_limit_up_plate_codes.items() if
+ len(codes) >= settings.limit_up_count_of_new_plate]
+ except:
+ plates = []
+ result_json = {"code": 0, "data": plates}
+
+
+
elif ctype == 'plate_white_list':
result_json = self.__on_plate_white_list(data)
self.send_response(result_json, client_id, request_id)
--
Gitblit v1.8.0