From 045e713ec1ac2f7c92c69ef31c02035661fc98dc Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 16 七月 2025 14:05:52 +0800
Subject: [PATCH] 续买金额设置/L后撤日志修改
---
api/outside_api_command_callback.py | 41 ++++++++++++++++++++++++++++++++++++++---
1 files changed, 38 insertions(+), 3 deletions(-)
diff --git a/api/outside_api_command_callback.py b/api/outside_api_command_callback.py
index 6c171fe..d02205a 100644
--- a/api/outside_api_command_callback.py
+++ b/api/outside_api_command_callback.py
@@ -60,7 +60,7 @@
from trade.sell import sell_manager
from trade.sell.sell_rule_manager import TradeRuleManager, SellRule
from trade.trade_data_manager import RadicalBuyDealCodesManager
-from trade.trade_manager import TradeTargetCodeModeManager, AutoCancelSellModeManager
+from trade.trade_manager import TradeTargetCodeModeManager, AutoCancelSellModeManager, CodesContinueBuyMoneyManager
from settings.trade_setting import MarketSituationManager, TradeBlockBuyModeManager
from utils import socket_util, data_export_util, tool, huaxin_util, output_util, global_util, init_data_util
from servers import server_util
@@ -1503,11 +1503,15 @@
client_id,
request_id)
return
- TotalDealBigOrderThresholdMoneyManager().set_money(code, int(money), trade_manager.CodesTradeStateManager().get_trade_state_cache(code))
+ TotalDealBigOrderThresholdMoneyManager().set_money(code, int(money),
+ trade_manager.CodesTradeStateManager().get_trade_state_cache(
+ code))
# 濡傛灉鏄姞绾㈢姸鎬侊紝涓斿ぇ鍗曚笉澶熷氨闇�瑕佺Щ绾�
if gpcode_manager.MustBuyCodesManager().is_in_cache(code):
- deal_big_order_info = radical_buy_data_manager.get_total_deal_big_order_info(code, gpcode_manager.get_limit_up_price_as_num(code))
+ deal_big_order_info = radical_buy_data_manager.get_total_deal_big_order_info(code,
+ gpcode_manager.get_limit_up_price_as_num(
+ code))
if deal_big_order_info[0] > 0:
gpcode_manager.MustBuyCodesManager().remove_code(code)
trade_record_log_util.add_common_msg(code, "绉荤孩", f"澶у崟闃堝�间慨鏀癸紙{money}锛�")
@@ -1529,6 +1533,37 @@
client_id,
request_id)
+ elif ctype == "get_continue_buy_info":
+ # 璁剧疆L鍚庢挙鍗曟瘮渚�
+ code = data.get("code")
+ money = CodesContinueBuyMoneyManager().get_continue_buy_money(code)
+ if money is None:
+ money = 0
+ self.send_response({"code": 0, "data": {"money": money, "money_list": constant.AVAILABLE_BUY_MONEYS}},
+ client_id,
+ request_id)
+ elif ctype == "set_continue_buy_money":
+ # 璁剧疆L鍚庢挙鍗曟瘮渚�
+ code = data.get("code")
+ money = data.get("money")
+ if money <= 0:
+ # 琛ㄧず绉婚櫎缁拱閲戦
+ CodesContinueBuyMoneyManager().remove_continue_buy_money(code)
+ self.send_response({"code": 0, "data": {}},
+ client_id,
+ request_id)
+ return
+ if money not in constant.AVAILABLE_BUY_MONEYS:
+ self.send_response({"code": 1, "msg": f"閲戦锛坽money}锛夋病鍦▄constant.AVAILABLE_BUY_MONEYS}涓�"},
+ client_id,
+ request_id)
+ return
+ CodesContinueBuyMoneyManager().set_continue_buy_money(code, money)
+ l2_trade_util.remove_from_forbidden_trade_codes(code)
+ self.send_response({"code": 0, "data": {}},
+ client_id,
+ request_id)
+
except Exception as e:
logging.exception(e)
logger_debug.exception(e)
--
Gitblit v1.8.0