add top200 analysis

analysis_pipeline.py

@@ -42,13 +42,12 @@ sales_stage_definition = '''
 '''
 
 # Read the Excel file
-df = pd.read_excel('output_top20.xlsx')
+df = pd.read_excel('output_top200.xlsx')
 
 # Iterate over each row in the DataFrame
 for index, row in df.iterrows():
     # Extract the information from the column "当前详细状态及Close节奏"
-    if index > 3:
-        break
+
     try:
         detailed_status = row['当前详细状态及Close节奏']
         print(f"Processing row {index}")
@@ -79,5 +78,5 @@ for index, row in df.iterrows():
         df.at[index, '销售动作分析'] = f"Error: {e}"  # Log the error in the DataFrame
 
 
-df.to_excel('analysis_result.xlsx', index=False)
+df.to_excel('analysis_result_top200.xlsx', index=False)