| | |
| | | # 处理华鑫L2数据 |
| | | @classmethod |
| | | def process_huaxin(cls, code, datas): |
| | | print("process_huaxin", code, len(datas)) |
| | | origin_start_time = round(t.time() * 1000) |
| | | try: |
| | | # 加载历史的L2数据 |
| | |
| | | datas = l2_huaxin_util.get_format_l2_datas(code, datas, |
| | | gpcode_manager.get_limit_up_price(code), _start_index) |
| | | __start_time = round(t.time() * 1000) |
| | | print("格式化L2数据成功", code) |
| | | cls.process_add_datas(code, datas, 0, __start_time) |
| | | print("huaxin L2数据处理成功", code) |
| | | except Exception as e: |
| | | print("huaxin L2数据处理异常", code, str(e)) |
| | | logging.exception(e) |
| | | logger_l2_error.exception(e) |
| | | finally: |
| | |
| | | # buy_params_info.append("未识别") |
| | | pass |
| | | else: |
| | | if trade_progress<len(total_datas): |
| | | data = total_datas[trade_progress] |
| | | params["trade_data"]["trade_progress"] = {"time": data['val']['time'], |
| | | "num": data['val']['num'], "money": round( |