| | |
|---|
| | | from code_atrribute.history_k_data_util import JueJinHttpApi, JueJinApi |
|---|
| | | from huaxin_client import command_manager |
|---|
| | | from huaxin_client import constant |
|---|
| | | from huaxin_client import l2_data_manager |
|---|
| | | import lev2mdapi |
|---|
| | | from huaxin_client.code_queue_distribute_manager import CodeDataCallbackDistributeManager |
|---|
| | | from huaxin_client.command_manager import L2ActionCallback |
|---|
| | | from huaxin_client.l2_data_manager import L2DataUploadManager |
|---|
| | | from log_module import log, async_log_util |
|---|
| | | from log_module.async_log_util import huaxin_l2_log |
|---|
| | | from log_module.log import logger_local_huaxin_l2_subscript, logger_system, logger_l2_codes_subscript, \ |
|---|
| | |
|---|
| | | add_codes = codes - self.subscripted_codes |
|---|
| | | del_codes = self.subscripted_codes - codes |
|---|
| | | print("add del codes", add_codes, del_codes) |
|---|
| | | try: |
|---|
| | | for c in del_codes: |
|---|
| | | l2_data_manager.del_target_code(c) |
|---|
| | | for c in codes: |
|---|
| | | l2_data_manager.add_target_code(c) |
|---|
| | | except Exception as e: |
|---|
| | | logger_system.error(f"L2代码分配上传队列出错:{str(e)}") |
|---|
| | | logger_system.exception(e) |
|---|
| | | self.__subscribe(add_codes) |
|---|
| | | self.__unsubscribe(del_codes) |
|---|
| | | if add_codes: |
|---|
| | |
|---|
| | | |
|---|
| | | def OnRspUserLogin(self, pRspUserLogin, pRspInfo, nRequestID, bIsLast): |
|---|
| | | if pRspInfo['ErrorID'] == 0: |
|---|
| | | print("----L2行情登录成功----") |
|---|
| | | self.is_login = True |
|---|
| | | logger_system.info(f"L2行情登录成功") |
|---|
| | | self.set_codes_data(self.codes) |
|---|
