| | |
|---|
| | | def l2_transaction(cls, code, datas): |
|---|
| | | # async_log_util.info(hx_logger_l2_transaction, f"{code}#{datas}") |
|---|
| | | if datas: |
|---|
| | | HuaXinTransactionDatasProcessor().process_huaxin_transaction_datas_v2(code, datas) |
|---|
| | | HuaXinTransactionDatasProcessor().process_huaxin_transaction_datas(code, datas) |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | | def l2_market_data(cls, code, data): |
|---|
| | |
|---|
| | | l2_log.info(code, logger_debug, f"扫入处理时长：{code}-{use_time}") |
|---|
| | | |
|---|
| | | def OnLimitUpActiveBuy(self, code, transaction_datas, no_left_limit_up_sell): |
|---|
| | | # can_clear_before_data = self.process_limit_up_active_buy(code, transaction_datas, |
|---|
| | | # no_left_limit_up_sell=no_left_limit_up_sell) |
|---|
| | | # if can_clear_before_data: |
|---|
| | | # # 清除 |
|---|
| | | # EveryLimitupBigDealOrderManager.clear(code, "处理涨停成交数据") |
|---|
| | | can_clear_before_data = self.process_limit_up_active_buy(code, transaction_datas, |
|---|
| | | no_left_limit_up_sell=no_left_limit_up_sell) |
|---|
| | | if can_clear_before_data: |
|---|
| | | # 清除 |
|---|
| | | EveryLimitupBigDealOrderManager.clear(code, "处理涨停成交数据") |
|---|
| | | pass |
|---|
| | | |
|---|
| | | def OnLastLimitUpSellDeal(self, code, data): |
|---|
| | |
|---|
| | | @param data: (data['SecurityID'], data['TradePrice'], data['TradeVolume'], data['OrderTime'], data['MainSeq'], data['SubSeq'], data['BuyNo'], data['SellNo'], data['ExecType']) |
|---|
| | | @return: |
|---|
| | | """ |
|---|
| | | if True: |
|---|
| | | return |
|---|
| | | |
|---|
| | | if data[6] < data[7]: |
|---|
| | | # 非主动买 |
|---|
| | | return |
|---|
