| | |
| | | from log_module.log import logger_system, logger_local_huaxin_l1, logger_local_huaxin_l1_trade_info, printlog |
| | | |
| | | ################B类################## |
| | | from utils import socket_util |
| | | from utils import socket_util, tool |
| | | |
| | | ADDRESS = "udp://224.224.1.19:7880" |
| | | |
| | | |
| | | level1_data_dict = { |
| | | |
| | |
| | | codes_sh = [] |
| | | codes_sz = [] |
| | | for code in codes: |
| | | if code.find("60") == 0: |
| | | if tool.is_sh_code(code): |
| | | codes_sh.append(code.encode("utf-8")) |
| | | elif code.find("00") == 0: |
| | | elif tool.is_sz_code(code): |
| | | codes_sz.append(code.encode("utf-8")) |
| | | return codes_sh, codes_sz |
| | | |
| | |
| | | printlog('OnRspUnSubMarketData: OK!') |
| | | else: |
| | | printlog('OnRspUnSubMarketData: Error! [%d] [%s]' |
| | | % (pRspInfoField.ErrorID, pRspInfoField.ErrorMsg)) |
| | | % (pRspInfoField.ErrorID, pRspInfoField.ErrorMsg)) |
| | | |
| | | def OnRtnMarketData(self, pMarketDataField): |
| | | if pMarketDataField.SecurityName.find("S") == 0: |