| | |
| | | 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 |
| | |
| | | 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})") |
| | |
| | | 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) |