| | |
| | | cls.__dealing_order_info_dict[code][4] = data[3] |
| | | cls.__dealing_order_info_dict[code][5] = data[1] |
| | | cls.__dealing_order_info_dict[code][6] = data[7] |
| | | cls.__dealing_order_info_dict[code][7] += money |
| | | if is_limit_up: |
| | | cls.__dealing_order_info_dict[code][7] += money |
| | | else: |
| | | # 保存上一条数据 |
| | | async_log_util.info(hx_logger_l2_transaction_desc, f"{code}#{cls.__dealing_order_info_dict[code]}") |
| | |
| | | # 保存最近的成交价格:(价格,成交时间) |
| | | cls.__latest_trade_price_dict[code] = (datas[-1][1], datas[-1][3]) |
| | | |
| | | L2TradeSingleDataProcessor.process_passive_limit_up_sell_data(code, datas, limit_up_price) |
| | | # 是否还有涨停卖剩下 |
| | | no_left_limit_up_sell = L2TradeSingleDataProcessor.process_passive_limit_up_sell_data(code, datas, limit_up_price) |
| | | |
| | | for d in datas: |
| | | # 获取当前是否为主动买 |
| | |
| | | if d[1] == limit_up_price: |
| | | # 有涨停主动买 |
| | | limit_up_active_buy_datas.append(d) |
| | | L2TradeSingleDataManager.set_limit_up_active_buy(code, limit_up_active_buy_datas) |
| | | L2TradeSingleDataManager.set_limit_up_active_buy(code, limit_up_active_buy_datas, no_left_limit_up_sell) |
| | | except: |
| | | pass |
| | | |