### 计算股票主买成交金额、净买入金额及比例 为了实现这一目标，在 PTrade 环境下可以采用 Python 编写脚本，通过访问历史交易数据来计算特定时间范围内每只股票的主要买入成交金额、净买入金额及其占比。这通常涉及到获取买卖记录并对其进行分析。 #### 获取所需的数据集 首先需要从数据库或其他存储介质中提取出给定日期区间内的所有交易明细，这些明细应至少包含如下字段：`stock_code`, `trade_time`, `buy_sell_flag`, 和 `amount` (成交量)，以及价格信息以便后续处理 [^1]。 #### 处理逻辑概述 对于每一笔交易： - 如果标记为买入，则增加到总买入量； - 若为卖出则累加至总的卖出席位上； 最后根据上述累积的结果得出最终统计指标： ```python import pandas as pd def calculate_trade_metrics(trades_df, start_date, end_date): """ Calculate main buy trade amount, net buy amount and ratio within a specified period. :param trades_df: DataFrame containing columns ['stock_code', 'trade_time', 'buy_sell_flag', 'price', 'volume'] where 'buy_sell_flag' is either "B" or "S". :param start_date: Start date of the calculation window. :param end_date: End date of the calculation window. """ filtered_trades = trades_df[(trades_df['trade_time'] >= start_date) & (trades_df['trade_time'] <= end_date)] grouped_by_stock = filtered_trades.groupby('stock_code') results = [] for stock_code, group in grouped_by_stock: buys = group[group['buy_sell_flag'] == 'B'] sells = group[group['buy_sell_flag'] == 'S'] total_buy_amount = (buys['price'] * buys['volume']).sum() total_sell_amount = (sells['price'] * sells['volume']).sum() net_buy_amount = total_buy_amount - total_sell_amount try: proportion_of_main_buys = abs(net_buy_amount / (total_buy_amount + total_sell_amount)) except ZeroDivisionError: proportion_of_main_buys = float('nan') # Handle division by zero case result_entry = { 'Stock Code': stock_code, 'Main Buy Amount': total_buy_amount, 'Net Buy Amount': net_buy_amount, 'Proportion Of Main Buys (%)': round(proportion_of_main_buys*100, 2), } results.append(result_entry) return pd.DataFrame(results) # Example usage with dummy data frame creation dummy_data = [ {'stock_code':'AAPL','trade_time':'2023-09-01T10:00:00Z','buy_sell_flag':'B','price':150,'volume':10}, {'stock_code':'GOOG','trade_time':'2023-09-01T10:05:00Z','buy_sell_flag':'S','price':2700,'volume':5} ] df_example = pd.DataFrame(dummy_data) metrics_result = calculate_trade_metrics(df_example, '2023-09-01T00:00:00Z', '2023-09-01T23:59:59Z') print(metrics_result.to_string(index=False)) ``` 此代码片段展示了如何基于输入的时间段筛选符合条件的交易条目，并据此计算所需的三个关键性能指标——主要买入额、净购入额度以及相应的百分比表示形式[^2]。