| | |
|---|
| | | import logging |
|---|
| | | import threading |
|---|
| | | |
|---|
| | | import data_process |
|---|
| | | import client_manager |
|---|
| | | import gpcode_manager |
|---|
| | | import l2_data_manager |
|---|
| | | import l2_trade_util |
|---|
| | | |
|---|
| | | import server |
|---|
| | | import tool |
|---|
| | | import trade_manager |
|---|
| | | import time |
|---|
| | | import redis_manager |
|---|
| | | from log import logger_code_operate |
|---|
| | |
|---|
| | | if client_id is not None and pos is not None: |
|---|
| | | L2CodeOperate.setGPCode(client_id, pos, "") |
|---|
| | | elif type == 1: |
|---|
| | | if trade_manager.is_in_forbidden_trade_codes(code): |
|---|
| | | if l2_trade_util.is_in_forbidden_trade_codes(code): |
|---|
| | | continue |
|---|
| | | |
|---|
| | | if not gpcode_manager.is_listen(code) and not gpcode_manager.is_operate( |
|---|
| | |
|---|
| | | |
|---|
| | | # 矫正客户端代码 |
|---|
| | | def correct_client_codes(): |
|---|
| | | client_ids = data_process.getValidL2Clients() |
|---|
| | | client_ids = client_manager.getValidL2Clients() |
|---|
| | | for client_id in client_ids: |
|---|
| | | try: |
|---|
| | | index_codes = get_listen_codes_from_client(client_id) |
|---|
