| | |
| | | from trade import current_price_process_manager, trade_constant |
| | | import concurrent.futures |
| | | |
| | | from trade.radical_buy_data_manager import RedicalBuyDataManager |
| | | from utils import tool |
| | | |
| | | |
| | |
| | | buy_datas, bigger_buy_datas = HuaXinBuyOrderManager.statistic_big_buy_data(code, datas, limit_up_price) |
| | | if buy_datas: |
| | | BigOrderDealManager().add_buy_datas(code, buy_datas) |
| | | RedicalBuyDataManager.big_order_deal(code) |
| | | try: |
| | | is_placed_order = l2_data_manager.TradePointManager.is_placed_order(order_begin_pos) |
| | | if is_placed_order and bigger_buy_datas: |
| | |
| | | current_price_process_manager.set_latest_not_limit_up_time(code, |
| | | l2_huaxin_util.convert_time( |
| | | d[3], with_ms=True)) |
| | | else: |
| | | # 主动卖(板上) |
| | | if d[1] == limit_up_price: |
| | | L2LimitUpSellDataManager.clear_data(code) |
| | | break |
| | | except: |
| | | pass |
| | | |