Administrator
10 天以前 045e713ec1ac2f7c92c69ef31c02035661fc98dc
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)