| | |
|---|
| | | import threading |
|---|
| | | import time |
|---|
| | | |
|---|
| | | import constant |
|---|
| | | from db import redis_manager_delegate as redis_manager |
|---|
| | | from l2 import l2_log |
|---|
| | | from l2.huaxin import huaxin_target_codes_manager |
|---|
| | | from l2.subscript import l2_subscript_manager |
|---|
| | | from log_module import async_log_util |
|---|
| | | from log_module.log import logger_system, logger_l2_codes_subscript, logger_debug |
|---|
| | | from servers.huaxin_trade_server import TradeServerProcessor |
|---|
| | |
|---|
| | | codes = [d[0] for d in datas] |
|---|
| | | for code in codes: |
|---|
| | | block_info.init_code(code) |
|---|
| | | if constant.IS_L2_NEW: |
|---|
| | | process_manager: l2_subscript_manager.TargetCodeProcessManager = l2_subscript_manager\ |
|---|
| | | .process_manager |
|---|
| | | queue_codes_list = process_manager.set_codes(set(codes)) |
|---|
| | | code_data_dict = {d[0]: d for d in datas} |
|---|
| | | for queue_codes in queue_codes_list: |
|---|
| | | root_data = {"type": ClientSocketManager.CLIENT_TYPE_CMD_L2, |
|---|
| | | "data": [code_data_dict.get(c) for c in queue_codes[1]]} |
|---|
| | | queue_codes[0].put_nowait(json.dumps(root_data)) |
|---|
| | | else: |
|---|
| | | root_data = {"type": ClientSocketManager.CLIENT_TYPE_CMD_L2, |
|---|
| | | "data": datas} |
|---|
| | | queue_other_w_l2_r.put_nowait(json.dumps(root_data)) |
|---|
