| | |
|---|
| | | 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, \ |
|---|
| | | logger_local_huaxin_l2_transaction |
|---|
| | | from log_module.log import logger_local_huaxin_l2_subscript, logger_system, logger_l2_codes_subscript |
|---|
| | | from utils import tool |
|---|
| | | |
|---|
| | | ###B类### |
|---|
| | |
|---|
| | | print("----L2行情登录成功----") |
|---|
| | | self.is_login = True |
|---|
| | | logger_system.info(f"L2行情登录成功") |
|---|
| | | # TODO 测试 |
|---|
| | | self.__subscribe(["600355"]) |
|---|
| | | # 初始设置值 |
|---|
| | | if tool.trade_time_sub(tool.get_now_time_str(), "09:20:00") > 0: |
|---|
| | | threading.Thread( |
|---|
| | |
|---|
| | | @return: |
|---|
| | | """ |
|---|
| | | try: |
|---|
| | | # TODO:测试 |
|---|
| | | logger_local_huaxin_l2_transaction.info(f"{pTick}") |
|---|
| | | if pTick['TickType'] == b'T': |
|---|
| | | # 成交 |
|---|
| | | item = {"SecurityID": pTick['SecurityID'], "TradePrice": pTick['Price'], |
|---|
