| | |
|---|
| | | |
|---|
| | | # 板块关键字准备 |
|---|
| | | for code in codes: |
|---|
| | | if not self.__CodesPlateKeysManager.get_history_limit_up_reason(code) is None: |
|---|
| | | if self.__CodesPlateKeysManager.get_history_limit_up_reason(code) is None: |
|---|
| | | self.__CodesPlateKeysManager.set_history_limit_up_reason(code, |
|---|
| | | KPLLimitUpDataRecordManager.get_latest_blocks_set( |
|---|
| | | code)) |
|---|
| | |
|---|
| | | hx_logger_trade_debug.info(f"获取交易数据开始：{type_}") |
|---|
| | | try: |
|---|
| | | if type_ == "delegate_list": |
|---|
| | | dataJSON = huaxin_trade_api.get_delegate_list(can_cancel=False, timeout=5) |
|---|
| | | dataJSON = huaxin_trade_api.get_delegate_list(can_cancel=False) |
|---|
| | | print("获取委托列表", dataJSON) |
|---|
| | | if dataJSON["code"] == 0: |
|---|
| | | data = dataJSON["data"] |
|---|
| | |
|---|
| | | sk.sendall(json.dumps( |
|---|
| | | {"code": 100, "msg": f"JSON解析失败：字符串内容：{data_str[:30]}......{data_str[-20:]}"}).encode( |
|---|
| | | encoding='utf-8')) |
|---|
| | | logging.exception( |
|---|
| | | hx_logger_trade_callback.error( |
|---|
| | | f"json解析失败，字符串长度：{len(data_str)},字符串内容：\"{data_str[:30]}......{data_str[-20:]}\"") |
|---|
| | | continue |
|---|
| | | if data_json["type"] == 'register': |
|---|
