| | |
|---|
| | | szse_codes = [] |
|---|
| | | sse_codes = [] |
|---|
| | | for code in codes: |
|---|
| | | if code.find("00") == 0 or code.find("30") == 0 : |
|---|
| | | if code.find("00") == 0 or code.find("30") == 0: |
|---|
| | | szse_codes.append(code.encode()) |
|---|
| | | elif code.find("60") == 0 or code.find("68") == 0: |
|---|
| | | sse_codes.append(code.encode()) |
|---|
| | |
|---|
| | | logger_system.info(f"L2行情登录成功") |
|---|
| | | |
|---|
| | | def OnRspSubTransaction(self, pSpecificSecurity, pRspInfo, nRequestID, bIsLast): |
|---|
| | | async_log_util.info(logger_local_huaxin_l2_subscript, |
|---|
| | | f"订阅结果：{pSpecificSecurity['SecurityID']} {pRspInfo['ErrorID']} {pRspInfo['ErrorMsg']}") |
|---|
| | | huaxin_l2_log.info(logger_local_huaxin_l2_subscript, |
|---|
| | | f"订阅结果：{pSpecificSecurity['SecurityID']} {pRspInfo['ErrorID']} {pRspInfo['ErrorMsg']}") |
|---|
| | | if pRspInfo["ErrorID"] == 0: |
|---|
| | | self.subscripted_codes.add(pSpecificSecurity['SecurityID']) |
|---|
| | | if bIsLast == 1: |
|---|
| | |
|---|
| | | |
|---|
| | | pipe_strategy = None |
|---|
| | | |
|---|
| | | |
|---|
| | | def get_subscript_codes(): |
|---|
| | | """ |
|---|
| | | 获取需要订阅的代码 |
|---|
