| | |
| | | @classmethod |
| | | def process_huaxin_transaction_datas(cls, code, datas): |
| | | __start_time = time.time() |
| | | limit_up_price = gpcode_manager.get_limit_up_price(code) |
| | | if limit_up_price: |
| | | limit_up_price = round(float(limit_up_price), 2) |
| | | limit_up_price = gpcode_manager.get_limit_up_price_as_num(code) |
| | | # 设置成交价 |
| | | try: |
| | | current_price_process_manager.set_trade_price(code, datas[-1][1]) |
| | |
| | | # GCancelBigNumComputer().set_big_sell_order_info(code, big_sell_order_info) |
| | | use_time_list.append(("处理卖单相关撤数据", time.time() - _start_time)) |
| | | _start_time = time.time() |
| | | HuaXinSellOrderStatisticManager.statistic_total_deal_volume(code, datas) |
| | | HuaXinSellOrderStatisticManager.statistic_total_deal_volume(code, datas, limit_up_price) |
| | | use_time_list.append(("统计成交量数据", time.time() - _start_time)) |
| | | except Exception as e: |
| | | async_log_util.error(logger_debug, f"卖单统计异常:{big_sell_order_info}") |