| | |
| | | import constant |
| | | import inited_data |
| | | import outside_api_command_manager |
| | | from cancel_strategy.s_l_h_cancel_strategy import SCancelBigNumComputer, LCancelRateManager |
| | | from cancel_strategy.s_l_h_cancel_strategy import SCancelBigNumComputer, LCancelRateManager, \ |
| | | CancelRateHumanSettingManager |
| | | from code_attribute import gpcode_manager, code_volumn_manager, zyltgb_util, code_nature_analyse |
| | | from code_attribute.code_data_util import ZYLTGBUtil |
| | | from code_attribute.code_l1_data_manager import L1DataManager |
| | |
| | | from trade.huaxin import huaxin_trade_api, huaxin_trade_data_update, \ |
| | | huaxin_trade_record_manager, huaxin_trade_order_processor, huaxin_sell_util |
| | | from trade.huaxin.huaxin_trade_record_manager import PositionManager, DealRecordManager, DelegateRecordManager |
| | | from trade.buy_radical.radical_buy_data_manager import RadicalBuyBlockManager, BeforeSubDealBigOrderManager |
| | | from trade.buy_radical.radical_buy_data_manager import RadicalBuyBlockManager, BeforeSubDealBigOrderManager, \ |
| | | TotalDealBigOrderThresholdMoneyManager |
| | | from trade.sell import sell_manager |
| | | from trade.sell.sell_rule_manager import TradeRuleManager, SellRule |
| | | from trade.trade_data_manager import RadicalBuyDealCodesManager |
| | |
| | | "l_down_cancel_rate": l_down_cancel_rate, |
| | | "expire_rate": expire_rate |
| | | } |
| | | l_down_cancel_rate = CancelRateHumanSettingManager().get_l_down(code) |
| | | if l_down_cancel_rate is not None: |
| | | fdata["l_down_cancel_rate"] = l_down_cancel_rate |
| | | |
| | | limit_up_data = kpl_data_manager.KPLLimitUpDataRecordManager.record_code_dict.get(code) |
| | | # 获取当前板块 |
| | | try: |
| | |
| | | if volumes_data: |
| | | is_new_top = code_nature_analyse.is_new_top(code, |
| | | gpcode_manager.get_limit_up_price_by_preprice(code, |
| | | volumes_data[0]["close"]), |
| | | volumes_data[ |
| | | 0][ |
| | | "close"]), |
| | | volumes_data) |
| | | |
| | | data = { |
| | |
| | | client_id, |
| | | request_id) |
| | | |
| | | elif ctype == "test_cancel_order": |
| | | # 获取相同板块的涨停代码数量 |
| | | code = data.get("code") |
| | | trade_manager.start_cancel_buy(code, force=True) |
| | | self.send_response({"code": 0, "data": {}}, |
| | | client_id, |
| | | request_id) |
| | | |
| | | elif ctype == "set_total_deal_big_order_threshold_money": |
| | | code = data.get("code") |
| | | money = data.get("money") |
| | | if not code or not money: |
| | | self.send_response({"code": 1, "data": {}, "msg": "code/money为空"}, |
| | | client_id, |
| | | request_id) |
| | | return |
| | | TotalDealBigOrderThresholdMoneyManager().set_money(code, int(money)) |
| | | self.send_response({"code": 0, "data": {}}, |
| | | client_id, |
| | | request_id) |
| | | elif ctype == "set_l_down_rate": |
| | | # 设置L后撤单比例 |
| | | code = data.get("code") |
| | | rate = data.get("rate") |
| | | if rate < 0 or rate > 1: |
| | | self.send_response({"code": 1, "msg": "比例范围不在0-1之间"}, |
| | | client_id, |
| | | request_id) |
| | | return |
| | | CancelRateHumanSettingManager().set_l_down(code, rate) |
| | | self.send_response({"code": 0, "data": {}}, |
| | | client_id, |
| | | request_id) |
| | | |
| | | except Exception as e: |
| | | logging.exception(e) |