| | |
|---|
| | | @classmethod |
|---|
| | | def l2_order(cls, code, _datas, timestamp): |
|---|
| | | now_timestamp = int(time.time() * 1000) |
|---|
| | | async_log_util.info(hx_logger_l2_orderdetail, |
|---|
| | | f"{code}#耗时：{int((time.time() - timestamp)*1000)}-{now_timestamp}#{_datas}") |
|---|
| | | # async_log_util.info(hx_logger_l2_orderdetail, |
|---|
| | | # f"{code}#耗时：{int((time.time() - timestamp)*1000)}-{now_timestamp}#{_datas}") |
|---|
| | | thread_id = random.randint(0, 100000) |
|---|
| | | l2_log.threadIds[code] = thread_id |
|---|
| | | l2_data_log.l2_time_log(code, "开始处理L2逐笔委托") |
|---|
| | | # l2_data_log.l2_time_log(code, "开始处理L2逐笔委托") |
|---|
| | | try: |
|---|
| | | l2_data_manager_new.L2TradeDataProcessor.process_huaxin(code, _datas) |
|---|
| | | finally: |
|---|
| | | l2_data_log.l2_time_log(code, |
|---|
| | | f"处理L2逐笔委托结束：处理数据数量: {len(_datas)} 最终处理时间:{round(time.time() * 1000) - now_timestamp}") |
|---|
| | | pass |
|---|
| | | # l2_data_log.l2_time_log(code, |
|---|
| | | # f"处理L2逐笔委托结束：处理数据数量: {len(_datas)} 最终处理时间:{round(time.time() * 1000) - now_timestamp}") |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | | def l2_transaction(cls, code, datas): |
|---|
