| | |
|---|
| | | use_time = time.time() - __start_time |
|---|
| | | if use_time > 0.01: |
|---|
| | | # 记录10ms以上的数据 |
|---|
| | | huaxin_l2_log.info(logger_local_huaxin_l2_error, f"耗时:{use_time}s 结束数据：{last_data}") |
|---|
| | | huaxin_l2_log.info(logger_local_huaxin_l2_error, f"耗时:{use_time}s 结束数据：{last_data} 数据数量：{len(temp_list)}") |
|---|
| | | temp_list = [] |
|---|
| | | else: |
|---|
| | | if code not in self.temp_order_queue_dict: |
|---|
| | |
|---|
| | | now_time_str = tool.get_now_time_str() |
|---|
| | | # 将本次中断设置为 |
|---|
| | | cls.__break_current_batch_data_for_buy_dict[code] = False |
|---|
| | | if len(add_datas) > 0: |
|---|
| | | if add_datas: |
|---|
| | | # 记录当前批数据的索引 |
|---|
| | | cls.__processing_data_indexes[code] = (add_datas[0]["index"], add_datas[-1]["index"]) |
|---|
| | | if code not in cls.__trade_log_placr_order_info_dict: |
|---|
