Administrator
2025-05-29 8afcdeb7cbf3875d16185053940cc4f73050b4ee
日志添加
2个文件已修改
4 ■■■■ 已修改文件
servers/data_server.py 2 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
trade/buy_radical/radical_buy_data_manager.py 2 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
servers/data_server.py
@@ -960,6 +960,7 @@
                                    limit_up_price_money_list = [x[0] for x in buy_datas if x[1] == limit_up_price]
                                    threshold_money = BeforeSubDealBigOrderManager().compute_re_limit_up_big_money_threshold(
                                        limit_up_price_money_list)
                                    logger_debug.info(f"{code}-临时回封均大单:{threshold_money}")
                                    # 设置买单阈值
                                    th_buy = threshold_money
                                    buy_money = sum(limit_up_price_money_list)
@@ -970,6 +971,7 @@
                                        2] = radical_buy_data_manager.compute_total_deal_big_order_threshold_money(code,
                                                                                                                   limit_up_price,
                                                                                                                   threshold_money)
                                    logger_debug.info(f"{code}-累计大单阈值:{deal_big_money_info[2]}")
                            big_money_rate = radical_buy_data_manager.TotalDealBigOrderInfoManager.get_big_order_rate(
                                code)
trade/buy_radical/radical_buy_data_manager.py
@@ -2166,7 +2166,9 @@
        datas = response_data["data"]
        async_log_util.info(logger_debug, f"拉取订阅之前的数据:{code_}-{datas}")
        if datas:
            # [(金额,价格,订单号)]
            buy_datas = datas["buy"]
            # [(金额,价格,订单号)]
            sell_datas = datas["sell"]
            return buy_datas, sell_datas
    return None