| | |
| | | l2_data_source_util, cancel_buy_strategy |
| | | from l2.code_price_manager import Buy1PriceManager |
| | | |
| | | from l2.l2_data_manager import TradePointManager |
| | | from l2.l2_data_manager import TradePointManager, OrderBeginPosInfo |
| | | from l2.l2_data_util import L2DataUtil |
| | | from l2.l2_transaction_data_manager import HuaXinBuyOrderManager, BigOrderDealManager |
| | | from log_module import async_log_util, log_export |
| | |
| | | code_list_type = data["code_list_type"] |
| | | operate = data["operate"] |
| | | code = data.get("code") |
| | | if code and not tool.is_can_buy_code(code): |
| | | raise Exception(f"不是可以交易的代码:{code}") |
| | | fresult = {"code": 0} |
| | | if code_list_type == outside_api_command_manager.CODE_LIST_WANT: |
| | | if operate == outside_api_command_manager.OPERRATE_SET: |
| | |
| | | black = l2_trade_util.is_in_forbidden_trade_codes(code) |
| | | pause_buy = gpcode_manager.PauseBuyCodesManager().is_in_cache(code) |
| | | must_buy = gpcode_manager.MustBuyCodesManager().is_in_cache(code) |
| | | green = gpcode_manager.GreenListCodeManager().is_in_cache(code) |
| | | desc_list = [] |
| | | if want: |
| | | desc_list.append("【想买单】") |
| | |
| | | desc_list.append("【暂不买】") |
| | | if must_buy: |
| | | desc_list.append("【红名单】") |
| | | if green: |
| | | desc_list.append("【绿名单】") |
| | | |
| | | |
| | | result = {"code": 0, "data": {"code_info": (code, code_name), "desc": "".join(desc_list)}} |
| | | self.send_response(result, client_id, request_id) |
| | |
| | | # 获取下单位置信息 |
| | | order_begin_pos = TradePointManager().get_buy_compute_start_data_cache(code) |
| | | if order_begin_pos is None or order_begin_pos.buy_single_index is None: |
| | | continue |
| | | order_begin_pos = OrderBeginPosInfo(buy_single_index=0, buy_exec_index=0) |
| | | l2_data_util.load_l2_data(code) |
| | | total_datas = l2_data_util.local_today_datas.get(code) |
| | | trade_index, is_default = transaction_progress.TradeBuyQueue().get_traded_index(code) |
| | |
| | | trade_index = 0 |
| | | # 下单位置 |
| | | place_order_index = SCancelBigNumComputer().get_real_place_order_index_cache(code) |
| | | if place_order_index is None: |
| | | place_order_index = 0 |
| | | # 计算信号位置到真实下单位置的总买(不管是否已撤) |
| | | total_nums = 0 |
| | | for i in range(order_begin_pos.buy_single_index, place_order_index): |