| | |
| | | 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) |
| | |
| | | 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) |
| | |
| | | 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 |