| | |
| | | from l2.huaxin import l2_huaxin_util, huaxin_delegate_postion_manager |
| | | from l2.l2_sell_manager import L2MarketSellManager, L2LimitUpSellManager |
| | | from l2.l2_transaction_data_manager import HuaXinSellOrderStatisticManager |
| | | from l2.place_order_single_data_manager import L2TradeSingleManager |
| | | from l2.place_order_single_data_manager import L2TradeSingleDataProcessor |
| | | from l2.transaction_progress import TradeBuyQueue |
| | | from log_module import async_log_util, log_export |
| | | from third_data import kpl_data_manager, block_info |
| | |
| | | try: |
| | | for d in add_datas: |
| | | if L2DataUtil.is_limit_up_price_sell(d['val']): |
| | | L2TradeSingleManager.add_l2_delegate_limit_up_sell(code,d) |
| | | L2TradeSingleDataProcessor.add_l2_delegate_limit_up_sell(code,d) |
| | | elif L2DataUtil.is_limit_up_price_sell_cancel(d['val']): |
| | | L2TradeSingleManager.add_l2_delegate_limit_up_sell_cancel(code,d['val']['orderNo']) |
| | | L2TradeSingleDataProcessor.add_l2_delegate_limit_up_sell_cancel(code,d['val']['orderNo']) |
| | | except Exception as e: |
| | | logger_debug.exception(e) |
| | | |