From 0d58b8db40c4607f589b08010b38d127b1080836 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期五, 13 六月 2025 15:23:55 +0800
Subject: [PATCH] 1.板上盯卖 L2决策分支简化/外部接口优化
---
data_server.py | 30 +++++++++++++++++-------------
strategy/buying_strategy.py | 8 ++++++++
strategy/data_cache.py | 2 ++
3 files changed, 27 insertions(+), 13 deletions(-)
diff --git a/data_server.py b/data_server.py
index bfa1449..361bcee 100644
--- a/data_server.py
+++ b/data_server.py
@@ -110,19 +110,6 @@
"auto_buy": TradeSetting().get_auto_buy()}
response_data = json.dumps({"code": 0, "data": fdata})
- elif url.path == "/set_trade_settings":
- logger_debug.info(f"set_trade_settings: {params_dict}")
- running = params_dict.get("running")
- auto_sell = params_dict.get("auto_sell")
- auto_buy = params_dict.get("auto_buy")
- if running is not None:
- TradeSetting().set_running(int(running))
- if auto_sell is not None:
- TradeSetting().set_auto_sell(int(auto_sell))
- if auto_buy is not None:
- TradeSetting().set_auto_buy(int(auto_buy))
- response_data = json.dumps({"code": 0, "data": {}})
-
elif url.path == "/get_env":
request_id = params_dict.get("request_id")
use_time_list = []
@@ -287,6 +274,23 @@
else:
huaxin_trade_api.add_trade_callback_data(body)
result_str = json.dumps({"code": 0})
+ elif url.path == "/set_trade_settings":
+ params = self.__parse_request()
+ if not self.__is_sign_right(params):
+ result_str = json.dumps({"code": 1001, "msg": "绛惧悕閿欒"})
+ return
+ logger_debug.info(f"set_trade_settings: {params}")
+ running = params.get("running")
+ auto_sell = params.get("auto_sell")
+ auto_buy = params.get("auto_buy")
+ if running is not None:
+ TradeSetting().set_running(int(running))
+ if auto_sell is not None:
+ TradeSetting().set_auto_sell(int(auto_sell))
+ if auto_buy is not None:
+ TradeSetting().set_auto_buy(int(auto_buy))
+ result_str = json.dumps({"code": 0, "data": {}})
+
elif url.path == "/buy":
# 绛惧悕楠岃瘉
params = self.__parse_request()
diff --git a/strategy/buying_strategy.py b/strategy/buying_strategy.py
index 6cc30ae..3eaafe2 100644
--- a/strategy/buying_strategy.py
+++ b/strategy/buying_strategy.py
@@ -430,6 +430,14 @@
data_cache.bought_plate.extend(limit_up_plate_included_list)
logger_info(
f"銆恵k_line_data[0]['sec_name']}銆戜氦鏄撴垚鍔燂紒鎸佷粨闆嗗悎锛歿data_cache.position_symbols_set}")
+ purchased_stock_details = {
+ "name": k_line_data[0]['sec_name'],
+ "policy_name": "鏈夋蹇垫湁寮哄害绛栫暐鍒嗘敮",
+ "plate_name": limit_up_plate_included,
+ "buy_time_trading_volume_ratio":(current_volume / k_line_data[0]['volume']),
+ }
+ data_cache.purchased_stocks_details_list.append(purchased_stock_details)
+ logger_info(f"宸叉垚浜よ偂绁ㄨ鎯呭垪琛細{purchased_stocks_details_list} ")
# 鏈夋蹇垫棤寮哄害瑙嗙晫
if strength_list_have_it is False:
diff --git a/strategy/data_cache.py b/strategy/data_cache.py
index d573437..0771658 100644
--- a/strategy/data_cache.py
+++ b/strategy/data_cache.py
@@ -278,5 +278,7 @@
# 鏈夋剰璐拱鐨勮偂绁ㄥ悕绉板垪琛�
willing_buy_list = []
+# 宸叉垚浜よ偂绁ㄨ鎯呭垪琛�
+purchased_stocks_details_list = []
logging.info(f"鍏ㄥ眬鍒濆鍖栨暟鎹� 瀹屾垚銆娿�娿�� - {os.getpid()}")
--
Gitblit v1.8.0