| | |
| | | self.__compute_watch_index(code, buy_single_index) |
| | | |
| | | |
| | | |
| | | |
| | | # ---------------------------------D撤------------------------------- |
| | | # 计算 成交位->真实下单位置 总共还剩下多少手没有撤单 |
| | | # 成交位变化之后重新计算 |
| | |
| | | logger_l2_l_cancel.exception(e) |
| | | raise e |
| | | return can_cancel, cancel_data, extra_msg |
| | | |
| | | |
| | | |
| | | |
| | | def place_order_success(self, code): |
| | | self.clear(code) |
| | |
| | | continue |
| | | if L2DataUtil.time_sub_as_ms(val, exec_data['val']) >= 1000: |
| | | continue |
| | | if not L2DataUtil.is_buy(val): |
| | | continue |
| | | shadow_place_order_index = d["index"] |
| | | break |
| | | if shadow_place_order_index is None: |
| | |
| | | return True |
| | | return False |
| | | |
| | | # 是否为买 |
| | | @classmethod |
| | | def is_buy(cls, val): |
| | | if int(val["operateType"]) == 0: |
| | | return True |
| | | return False |
| | | |
| | | # l2时间差值 |
| | | @classmethod |
| | | def time_sub_as_ms(cls, val1, val2): |