| | |
| | | # 从网络上加载精选板块 |
| | | def load_jx_blocks(self, code, buy_1_price, limit_up_price): |
| | | try: |
| | | logger_kpl_block_can_buy.info(f"准备更新精选板块:{code}-{buy_1_price}-{limit_up_price}") |
| | | if limit_up_price and buy_1_price: |
| | | # 处理买1,卖1信息 |
| | | pre_close_price = round(float(limit_up_price) / 1.1, 2) |
| | |
| | | TradeServerProcessor.l2_transaction(code, datas) |
| | | |
| | | def OnMarketData(self, code, data): |
| | | try: |
| | | TradeServerProcessor.l2_market_data(code, data) |
| | | except Exception as e: |
| | | logger_debug.exception(e) |
| | | |
| | | def OnTradingOrderCancel(self, code, buy_no): |
| | | TradeServerProcessor.trading_order_canceled(code, buy_no) |