| | |
|---|
| | | code = data["code"] |
|---|
| | | datas = data["data"] |
|---|
| | | logger_l2_orderdetail.info(f"{code}#{datas}") |
|---|
| | | origin_start_time = round(time.time() * 1000) |
|---|
| | | try: |
|---|
| | | # 转换数据格式 |
|---|
| | | _start_index = 0 |
|---|
| | | if local_today_datas.get(code) is not None and len( |
|---|
| | | local_today_datas[code]) > 0: |
|---|
| | | _start_index = local_today_datas[code][-1]["index"] + 1 |
|---|
| | | datas = l2_huaxin_util.get_format_l2_datas(code, datas, |
|---|
| | | gpcode_manager.get_limit_up_price(code), _start_index) |
|---|
| | | __start_time = round(time.time() * 1000) |
|---|
| | | l2_data_manager_new.L2TradeDataProcessor().process_add_datas(code, datas, 0, __start_time) |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
| | | logger_l2_error.exception(e) |
|---|
| | | finally: |
|---|
| | | l2_data_log.l2_time(code, round(time.time() * 1000) - origin_start_time, |
|---|
| | | "l2数据处理总耗时", |
|---|
| | | True) |
|---|
| | | l2.l2_data_util.save_l2_data(code, None, datas) |
|---|
| | | l2_data_manager_new.L2TradeDataProcessor.process_huaxin(code, datas) |
|---|
| | | sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8')) |
|---|
| | | |
|---|
| | | elif data_json["type"] == "l2_trans": |
|---|
