| | |
|---|
| | | return cls._instance |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | | def init(cls, trade_action_callback: TradeActionCallback, pipe_l2, queue_strategy_trade_read: multiprocessing.Queue): |
|---|
| | | def init(cls, trade_action_callback: TradeActionCallback, queue_strategy_trade_read: multiprocessing.Queue): |
|---|
| | | cls.action_callback = trade_action_callback |
|---|
| | | cls.pipe_l2 = pipe_l2 |
|---|
| | | cls.queue_strategy_trade_read = queue_strategy_trade_read |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | | def process_command(cls, _type, client_id, result_json, sk=None): |
|---|
| | | async_log_util.info(logger_local_huaxin_contact_debug, f"process_command： {result_json}") |
|---|
| | | # 查看是否是设置L2的代码 |
|---|
| | | if _type == CLIENT_TYPE_CMD_L2: |
|---|
| | | cls.pipe_l2.send( |
|---|
| | | json.dumps({"type": "set_l2_codes", "data": result_json["data"]})) |
|---|
| | | return |
|---|
| | | |
|---|
| | | try: |
|---|
| | | data = result_json["data"] |
|---|
| | | request_id = result_json.get('request_id') |
|---|
