| | |
| | | import ths_industry_util |
| | | import ths_util |
| | | import tool |
| | | import trade_gui |
| | | import trade_manager |
| | | import l2_code_operate |
| | | from code_data_util import ZYLTGBUtil |
| | |
| | | if limit_up_time_manager.get_limit_up_time(d["code"]) is None: |
| | | limit_up_time_manager.save_limit_up_time(d["code"], d["time"]) |
| | | |
| | | |
| | | elif type == 3: |
| | | # 交易成功信息 |
| | | dataList = data_process.parseList(_str) |
| | |
| | | trade_manager.save_trade_success_data(dataList) |
| | | |
| | | elif type == 5: |
| | | logger_trade_delegate.debug("接收到委托信息") |
| | | # 交易委托信息 |
| | | dataList = data_process.parseList(_str) |
| | | if self.last_trade_delegate_data != _str: |
| | |
| | | except Exception as e: |
| | | logging.exception(e) |
| | | trade_manager.save_trade_delegate_data(dataList) |
| | | # 刷新交易界面 |
| | | trade_gui.THSGuiTrade().refresh_data() |
| | | |
| | | elif type == 4: |
| | | # 行业代码信息 |
| | |
| | | elif type == 50: |
| | | data = data_process.parse(_str)["data"] |
| | | if data is not None: |
| | | print(data) |
| | | index = data["index"] |
| | | code_name = data["codeName"] |
| | | code_name = data["codeName"].replace(" ", "") |
| | | volumn = data["volumn"] |
| | | price = data["price"] |
| | | time_ = data["time"] |