| | |
|---|
| | | from trade import current_price_process_manager, trade_constant |
|---|
| | | import concurrent.futures |
|---|
| | | |
|---|
| | | from trade.radical_buy_data_manager import RadicalBuyDataManager, EveryLimitupBigDealOrderManager |
|---|
| | | from trade.buy_radical.radical_buy_data_manager import RadicalBuyDataManager, EveryLimitupBigDealOrderManager |
|---|
| | | from utils import tool |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | @param datas: |
|---|
| | | @return: |
|---|
| | | """ |
|---|
| | | limit_up_price = round(float(gpcode_manager.get_limit_up_price(code)), 2) |
|---|
| | | limit_up_price = gpcode_manager.get_limit_up_price_as_num(code) |
|---|
| | | 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) |
|---|
| | | EveryLimitupBigDealOrderManager.add_big_buy_order_deal(code, [x[0] for x in buy_datas]) |
|---|
| | | active_big_buy_orders = [] |
|---|
| | | if buy_datas: |
|---|
| | | for x in buy_datas: |
|---|
| | | if x[0] > x[6]: |
|---|
| | | # (买单号, 成交金额, 最后成交时间) |
|---|
| | | active_big_buy_orders.append((x[0], x[2], x[4])) |
|---|
| | | EveryLimitupBigDealOrderManager.add_big_buy_order_deal(code, active_big_buy_orders) |
|---|
| | | try: |
|---|
| | | is_placed_order = l2_data_manager.TradePointManager.is_placed_order(order_begin_pos) |
|---|
| | | if is_placed_order: |
|---|
