Update response_formatter.py

response_formatter.py

@@ -1,10 +1,14 @@
 # response_formatter.py
-from typing import Dict, List, Any
+from typing import Dict, List, Any, Tuple
+import re
 
 class ResponseFormatter:
     @staticmethod
     def format_healthcare_response(scenario_text: str, analysis_results: Dict[str, Any]) -> str:
-        """Format healthcare analysis response with detailed structure"""
+        """Format healthcare analysis response based on scenario tasks"""
+        # Extract tasks from scenario
+        tasks = ResponseFormatter._extract_scenario_tasks(scenario_text)
+        
         response = "# Healthcare Scenario Analysis\n\n"
         
         # Executive Summary
@@ -12,62 +16,20 @@ class ResponseFormatter:
         response += ResponseFormatter._generate_executive_summary(analysis_results)
         response += "\n\n"
         
-        # Data Preparation
-        if "data_preparation" in analysis_results:
-            response += "## 1. Data Preparation\n\n"
-            response += ResponseFormatter._format_data_preparation(analysis_results["data_preparation"])
-            response += "\n\n"
-        
-        # Facility Distribution Analysis
-        if "facility_distribution" in analysis_results:
-            response += "## 2. Facility Distribution Analysis\n\n"
-            response += ResponseFormatter._format_facility_distribution(analysis_results["facility_distribution"])
-            response += "\n\n"
-        
-        # Capacity Analysis
-        if "capacity_analysis" in analysis_results:
-            response += "## 3. Capacity Analysis\n\n"
-            response += ResponseFormatter._format_capacity_analysis(analysis_results["capacity_analysis"])
-            response += "\n\n"
-        
-        # Long-Term Care Assessment
-        if "long_term_care_assessment" in analysis_results:
-            response += "## 4. Long-Term Care Capacity Assessment\n\n"
-            response += ResponseFormatter._format_long_term_care_assessment(analysis_results["long_term_care_assessment"])
-            response += "\n\n"
-        
-        # Resource Allocation Analysis
-        if "resource_allocation" in analysis_results:
-            response += "## 5. Resource Allocation Analysis\n\n"
-            response += ResponseFormatter._format_resource_allocation(analysis_results["resource_allocation"])
-            response += "\n\n"
-        
-        # Trend Analysis
-        if "trends" in analysis_results:
-            response += "## 6. Trend Analysis\n\n"
-            response += ResponseFormatter._format_trends(analysis_results["trends"])
-            response += "\n\n"
-        
-        # Operational Recommendations
-        if "recommendations" in analysis_results:
-            response += "## 7. Operational Recommendations\n\n"
-            response += ResponseFormatter._format_recommendations(analysis_results["recommendations"])
-            response += "\n\n"
-        
-        # Future Integration
-        if "future_integration" in analysis_results:
-            response += "## 8. Future Integration Opportunities\n\n"
-            response += ResponseFormatter._format_integration_opportunities(analysis_results["future_integration"])
-            response += "\n\n"
+        # Process each task
+        for task in tasks:
+            section_content = ResponseFormatter._process_task(task, analysis_results)
+            if section_content:
+                response += section_content + "\n\n"
         
         # Validation Results
         if "validation" in analysis_results:
-            response += "## 9. Analysis Validation\n\n"
+            response += "## Analysis Validation\n\n"
             response += ResponseFormatter._format_validation_results(analysis_results["validation"])
             response += "\n\n"
         
         # Provenance
-        response += "## 10. Provenance\n\n"
+        response += "## Provenance\n\n"
         response += "This analysis is based on:\n"
         response += "- Scenario description provided by the user\n"
         response += "- Uploaded data files\n"
@@ -76,86 +38,104 @@ class ResponseFormatter:
         return response
     
     @staticmethod
-    def _generate_executive_summary(results: Dict[str, Any]) -> str:
-        """Generate executive summary based on analysis results"""
-        summary = []
-        
-        if "capacity_analysis" in results:
-            capacity = results["capacity_analysis"]
-            if "total_capacity" in capacity:
-                summary.append(f"Total system capacity: {capacity['total_capacity']:,} beds")
-            if "average_utilization" in capacity:
-                summary.append(f"Average utilization: {capacity['average_utilization']:.1%}")
-        
-        if "facility_distribution" in results:
-            dist = results["facility_distribution"]
-            if "geographic_inequality" in dist:
-                inequality = dist["geographic_inequality"]
-                level = "High" if inequality > 0.4 else "Moderate" if inequality > 0.2 else "Low"
-                summary.append(f"Geographic distribution inequality: {level} (Gini: {inequality:.2f})")
-        
-        if "recommendations" in results:
-            high_priority = [r for r in results["recommendations"] if r.get("priority") == "High"]
-            if high_priority:
-                summary.append(f"{len(high_priority)} high-priority recommendations identified")
-        
-        if "validation" in results:
-            completion_rate = results["validation"].get("completion_rate", 0)
-            summary.append(f"Analysis completion rate: {completion_rate:.1%}")
-        
-        return " | ".join(summary) if summary else "No key metrics identified"
+    def _extract_scenario_tasks(scenario_text: str) -> List[str]:
+        """Extract specific tasks from scenario text"""
+        tasks = []
+        lines = scenario_text.split('\n')
+        in_tasks = False
+        current_task = ""
+        
+        for line in lines:
+            line = line.strip()
+            
+            # Check if we're entering the tasks section
+            if line.lower().startswith('tasks'):
+                in_tasks = True
+                continue
+            
+            # Check if we're leaving the tasks section
+            if in_tasks and (line.lower().startswith('operational recommendations') or 
+                            line.lower().startswith('future integration') or
+                            line.lower().startswith('prepare your findings')):
+                in_tasks = False
+                if current_task:
+                    tasks.append(current_task)
+                continue
+            
+            # Collect task content
+            if in_tasks:
+                if line and (line.startswith(('1.', '2.', '3.', '4.', '5.', '6.', '7.', '8.', '9.')) or 
+                           line.startswith(('•', '-', '*'))):
+                    if current_task:
+                        tasks.append(current_task)
+                    current_task = line
+                elif line:
+                    current_task += " " + line
+        
+        # Add the last task if exists
+        if current_task:
+            tasks.append(current_task)
+            
+        return tasks
     
     @staticmethod
-    def _generate_data_section(results: Dict[str, Any]) -> str:
-        """Generate data preparation section"""
-        data_sources = []
+    def _process_task(task: str, analysis_results: Dict[str, Any]) -> str:
+        """Process a single task and return formatted content"""
+        task_lower = task.lower()
         
-        if "facility_distribution" in results:
-            data_sources.append("Facility registry data")
+        # Data Preparation Task
+        if "data preparation" in task_lower or "load the data" in task_lower:
+            return ResponseFormatter._handle_data_preparation_task(task, analysis_results)
         
-        if "capacity_analysis" in results:
-            data_sources.append("Bed capacity and utilization data")
+        # Bed Capacity Analysis Tasks
+        elif "bed capacity" in task_lower or "summarize bed capacity" in task_lower:
+            return ResponseFormatter._handle_bed_capacity_task(task, analysis_results)
         
-        if "resource_allocation" in results:
-            data_sources.append("Resource allocation data")
+        elif "facilities with the greatest declines" in task_lower:
+            return ResponseFormatter._handle_facility_declines_task(task, analysis_results)
         
-        if "trends" in results:
-            data_sources.append("Historical trend data")
+        elif "long-term care capacity" in task_lower or "assess long-term care" in task_lower:
+            return ResponseFormatter._handle_long_term_care_task(task, analysis_results)
         
-        if not data_sources:
-            return "No relevant data sources identified"
+        # Operational Recommendations Tasks
+        elif "operational recommendations" in task_lower or "recommend actions" in task_lower:
+            return ResponseFormatter._handle_recommendations_task(task, analysis_results)
         
-        response = "The following data sources were used in this analysis:\n\n"
-        for source in data_sources:
-            response += f"- {source}\n"
+        elif "future integration" in task_lower or "augmented ai" in task_lower:
+            return ResponseFormatter._handle_integration_task(task, analysis_results)
         
-        response += "\nData quality checks and transformations were applied to ensure accuracy and consistency."
-        return response
+        # Generic task handler
+        else:
+            return ResponseFormatter._handle_generic_task(task, analysis_results)
     
     @staticmethod
-    def _format_data_preparation(data_prep_results: Dict[str, Any]) -> str:
-        """Format data preparation results"""
-        response = ""
+    def _handle_data_preparation_task(task: str, analysis_results: Dict[str, Any]) -> str:
+        """Handle data preparation task"""
+        response = "## Data Preparation\n\n"
         
-        if "total_facilities" in data_prep_results:
-            response += f"**Total Facilities Analyzed**: {data_prep_results['total_facilities']:,}\n\n"
+        if "data_preparation" not in analysis_results:
+            return response + "No data preparation results available"
         
-        if "facility_type_frequency" in data_prep_results:
+        data_prep = analysis_results["data_preparation"]
+        
+        # Facility type frequency
+        if "facility_type_frequency" in data_prep:
             response += "### Facility Type Frequency\n\n"
             response += "| Facility Type | Count |\n"
             response += "|---------------|-------|\n"
-            for ftype, count in data_prep_results["facility_type_frequency"].items():
+            for ftype, count in data_prep["facility_type_frequency"].items():
                 response += f"| {ftype} | {count} |\n"
             response += "\n"
         
-        if "top_cities" in data_prep_results and "city_facility_breakdown" in data_prep_results:
+        # Top cities with facility breakdown
+        if "top_cities" in data_prep and "city_facility_breakdown" in data_prep:
             response += "### Top Cities by Facility Count\n\n"
             response += "| City | Hospitals | Nursing/Residential | Ambulatory | Total |\n"
             response += "|------|-----------|-------------------|------------|-------|\n"
             
-            for city in data_prep_results["top_cities"]:
-                if city in data_prep_results["city_facility_breakdown"]:
-                    breakdown = data_prep_results["city_facility_breakdown"][city]
+            for city in data_prep["top_cities"]:
+                if city in data_prep["city_facility_breakdown"]:
+                    breakdown = data_prep["city_facility_breakdown"][city]
                     hospitals = breakdown.get("Hospitals", 0)
                     nursing = breakdown.get("Nursing and residential care facilities", 0)
                     ambulatory = breakdown.get("Ambulatory health care services", 0)
@@ -164,32 +144,95 @@ class ResponseFormatter:
             
             response += "\n"
         
-        return response if response else "No data preparation results available"
+        return response
     
     @staticmethod
-    def _format_long_term_care_assessment(ltc_results: Dict[str, Any]) -> str:
-        """Format long-term care assessment results"""
-        response = ""
+    def _handle_bed_capacity_task(task: str, analysis_results: Dict[str, Any]) -> str:
+        """Handle bed capacity analysis task"""
+        response = "## Bed Capacity Analysis\n\n"
+        
+        if "capacity_analysis" not in analysis_results:
+            return response + "No capacity analysis results available"
+        
+        capacity = analysis_results["capacity_analysis"]
+        
+        # Bed capacity by zone
+        if "bed_capacity_by_zone" in capacity:
+            response += "### Bed Capacity by Zone\n\n"
+            response += "| Zone | Current Beds | Previous Beds | Absolute Change | Percentage Change |\n"
+            response += "|------|--------------|---------------|-----------------|-------------------|\n"
+            for zone, data in capacity["bed_capacity_by_zone"].items():
+                current = data.get("beds_current", 0)
+                previous = data.get("beds_prev", 0)
+                abs_change = current - previous
+                perc_change = (abs_change / previous * 100) if previous > 0 else 0
+                response += f"| {zone} | {current:,} | {previous:,} | {abs_change:+,} | {perc_change:+.1f}% |\n"
+            response += "\n"
+        
+        # Zones with largest decreases
+        if "zone_with_largest_absolute_decrease" in capacity:
+            response += f"**Zone with Largest Absolute Decrease**: {capacity['zone_with_largest_absolute_decrease']}\n\n"
+        
+        if "zone_with_largest_percentage_decrease" in capacity:
+            response += f"**Zone with Largest Percentage Decrease**: {capacity['zone_with_largest_percentage_decrease']}\n\n"
+        
+        return response
+    
+    @staticmethod
+    def _handle_facility_declines_task(task: str, analysis_results: Dict[str, Any]) -> str:
+        """Handle facilities with greatest declines task"""
+        response = "## Facilities with Greatest Declines\n\n"
+        
+        if "capacity_analysis" not in analysis_results or "facilities_with_declines" not in analysis_results["capacity_analysis"]:
+            return response + "No facility decline data available"
+        
+        facilities = analysis_results["capacity_analysis"]["facilities_with_declines"]
         
-        if "zone_with_largest_decrease" in ltc_results:
-            response += f"**Zone with Largest Percentage Decrease**: {ltc_results['zone_with_largest_decrease']}\n\n"
+        response += "| Facility Name | Zone | Teaching Status | Bed Change |\n"
+        response += "|---------------|------|----------------|------------|\n"
+        for facility in facilities[:5]:  # Top 5
+            name = facility.get("facility_name", "")
+            zone = facility.get("zone", "")
+            teaching = facility.get("teaching_status", "")
+            change = facility.get("bed_change", 0)
+            response += f"| {name} | {zone} | {teaching} | {change:+,} |\n"
         
-        if "major_city" in ltc_results:
-            response += f"**Major City in Zone**: {ltc_results['major_city']}\n\n"
+        return response
+    
+    @staticmethod
+    def _handle_long_term_care_task(task: str, analysis_results: Dict[str, Any]) -> str:
+        """Handle long-term care capacity assessment task"""
+        response = "## Long-Term Care Capacity Assessment\n\n"
+        
+        if "long_term_care_assessment" not in analysis_results:
+            return response + "No long-term care assessment results available"
+        
+        ltc = analysis_results["long_term_care_assessment"]
         
-        if "facility_counts" in ltc_results:
-            counts = ltc_results["facility_counts"]
+        # Zone with largest percentage decrease
+        if "zone_with_largest_percentage_decrease" in ltc:
+            response += f"**Zone with Largest Percentage Decrease**: {ltc['zone_with_largest_percentage_decrease']}\n\n"
+        
+        # Major city in that zone
+        if "major_city_in_zone" in ltc:
+            response += f"**Major City in Zone**: {ltc['major_city_in_zone']}\n\n"
+        
+        # Facility counts in major city
+        if "facility_counts" in ltc:
+            counts = ltc["facility_counts"]
             response += "### Facility Counts in Major City\n\n"
-            response += f"- Hospitals: {counts['hospitals']}\n"
-            response += f"- Nursing/Residential Care Facilities: {counts['nursing_residential_care']}\n"
-            response += f"- Ambulatory Health Services: {counts['ambulatory']}\n\n"
+            response += f"- Hospitals: {counts.get('hospitals', 0)}\n"
+            response += f"- Nursing/Residential Care Facilities: {counts.get('nursing_residential_care', 0)}\n"
+            response += f"- Ambulatory Health Services: {counts.get('ambulatory', 0)}\n\n"
         
-        if "nursing_to_hospital_ratio" in ltc_results:
-            ratio = ltc_results["nursing_to_hospital_ratio"]
+        # Nursing to hospital ratio
+        if "nursing_to_hospital_ratio" in ltc:
+            ratio = ltc["nursing_to_hospital_ratio"]
             response += f"**Nursing/Residential to Hospital Ratio**: {ratio:.2f}\n\n"
         
-        if "capacity_assessment" in ltc_results:
-            assessment = ltc_results["capacity_assessment"]
+        # Capacity assessment
+        if "capacity_assessment" in ltc:
+            assessment = ltc["capacity_assessment"]
             response += f"**Long-Term Care Capacity Assessment**: {assessment.upper()}\n\n"
             
             if assessment == "insufficient":
@@ -199,7 +242,147 @@ class ResponseFormatter:
                 response += "The ratio of nursing/residential care facilities to hospitals meets or exceeds the recommended threshold. "
                 response += "This indicates sufficient long-term care capacity.\n\n"
         
-        return response if response else "No long-term care assessment results available"
+        return response
+    
+    @staticmethod
+    def _handle_recommendations_task(task: str, analysis_results: Dict[str, Any]) -> str:
+        """Handle operational recommendations task"""
+        response = "## Operational Recommendations\n\n"
+        
+        if "recommendations" not in analysis_results or not analysis_results["recommendations"]:
+            return response + "No recommendations available"
+        
+        recommendations = analysis_results["recommendations"]
+        
+        # Group by priority
+        high_priority = [r for r in recommendations if r.get("priority") == "High"]
+        medium_priority = [r for r in recommendations if r.get("priority") == "Medium"]
+        low_priority = [r for r in recommendations if r.get("priority") == "Low"]
+        
+        if high_priority:
+            response += "### High Priority Recommendations\n\n"
+            for i, rec in enumerate(high_priority, 1):
+                response += f"**{i}. {rec.get('title', 'Recommendation')}**\n\n"
+                response += f"{rec.get('description', '')}\n\n"
+                if "justification" in rec:
+                    response += f"**Justification**: {rec['justification']}\n\n"
+                if "expected_impact" in rec:
+                    response += f"**Expected Impact**: {rec['expected_impact']}\n\n"
+                response += "---\n\n"
+        
+        if medium_priority:
+            response += "### Medium Priority Recommendations\n\n"
+            for i, rec in enumerate(medium_priority, 1):
+                response += f"**{i}. {rec.get('title', 'Recommendation')}**\n\n"
+                response += f"{rec.get('description', '')}\n\n"
+                if "justification" in rec:
+                    response += f"**Justification**: {rec['justification']}\n\n"
+                if "expected_impact" in rec:
+                    response += f"**Expected Impact**: {rec['expected_impact']}\n\n"
+                response += "---\n\n"
+        
+        if low_priority:
+            response += "### Low Priority Recommendations\n\n"
+            for i, rec in enumerate(low_priority, 1):
+                response += f"**{i}. {rec.get('title', 'Recommendation')}**\n\n"
+                response += f"{rec.get('description', '')}\n\n"
+                if "justification" in rec:
+                    response += f"**Justification**: {rec['justification']}\n\n"
+                if "expected_impact" in rec:
+                    response += f"**Expected Impact**: {rec['expected_impact']}\n\n"
+                response += "---\n\n"
+        
+        return response
+    
+    @staticmethod
+    def _handle_integration_task(task: str, analysis_results: Dict[str, Any]) -> str:
+        """Handle future integration opportunities task"""
+        response = "## Future Integration Opportunities\n\n"
+        
+        if "future_integration" not in analysis_results:
+            return response + "No integration opportunities identified"
+        
+        integration = analysis_results["future_integration"]
+        
+        # Summary
+        if "summary" in integration:
+            response += f"{integration['summary']}\n\n"
+        
+        # Opportunities
+        if "opportunities" in integration:
+            for i, opp in enumerate(integration["opportunities"], 1):
+                response += f"**{i}. {opp.get('title', 'Opportunity')}**\n\n"
+                response += f"{opp.get('description', '')}\n\n"
+                
+                if "benefits" in opp:
+                    response += "**Benefits:**\n"
+                    for benefit in opp["benefits"]:
+                        response += f"- {benefit}\n"
+                    response += "\n"
+                
+                if "challenges" in opp:
+                    response += "**Challenges:**\n"
+                    for challenge in opp["challenges"]:
+                        response += f"- {challenge}\n"
+                    response += "\n"
+                
+                if "example_metric_or_model" in opp:
+                    response += f"**Example Metric/Model**: {opp['example_metric_or_model']}\n\n"
+                
+                if "timeline" in opp:
+                    response += f"**Timeline**: {opp['timeline']}\n\n"
+                
+                response += "---\n\n"
+        
+        return response
+    
+    @staticmethod
+    def _handle_generic_task(task: str, analysis_results: Dict[str, Any]) -> str:
+        """Handle generic task"""
+        # Try to match task to any available analysis results
+        task_lower = task.lower()
+        
+        if "distribution" in task_lower and "facility_distribution" in analysis_results:
+            return "## Facility Distribution Analysis\n\n" + ResponseFormatter._format_facility_distribution(analysis_results["facility_distribution"])
+        
+        if "resource" in task_lower and "resource_allocation" in analysis_results:
+            return "## Resource Allocation Analysis\n\n" + ResponseFormatter._format_resource_allocation(analysis_results["resource_allocation"])
+        
+        if "trend" in task_lower and "trends" in analysis_results:
+            return "## Trend Analysis\n\n" + ResponseFormatter._format_trends(analysis_results["trends"])
+        
+        # If no specific match, return a generic section
+        return f"## {task}\n\nNo specific analysis results available for this task."
+    
+    @staticmethod
+    def _generate_executive_summary(results: Dict[str, Any]) -> str:
+        """Generate executive summary based on analysis results"""
+        summary = []
+        
+        if "capacity_analysis" in results:
+            capacity = results["capacity_analysis"]
+            if "total_capacity" in capacity:
+                summary.append(f"Total system capacity: {capacity['total_capacity']:,} beds")
+            if "average_utilization" in capacity:
+                summary.append(f"Average utilization: {capacity['average_utilization']:.1%}")
+        
+        if "facility_distribution" in results:
+            dist = results["facility_distribution"]
+            if "geographic_inequality" in dist:
+                inequality = dist["geographic_inequality"]
+                level = "High" if inequality > 0.4 else "Moderate" if inequality > 0.2 else "Low"
+                summary.append(f"Geographic distribution inequality: {level} (Gini: {inequality:.2f})")
+        
+        if "recommendations" in results:
+            high_priority = [r for r in results["recommendations"] if r.get("priority") == "High"]
+            if high_priority:
+                summary.append(f"{len(high_priority)} high-priority recommendations identified")
+        
+        if "validation" in results:
+            completion_rate = results["validation"].get("completion_rate", 0)
+            summary.append(f"Analysis completion rate: {completion_rate:.1%}")
+        
+        return " | ".join(summary) if summary else "No key metrics identified"
     
     @staticmethod
     def _format_validation_results(validation: Dict[str, Any]) -> str:
@@ -216,6 +399,7 @@ class ResponseFormatter:
         
         return response
     
+    # Legacy formatting methods for generic tasks
     @staticmethod
     def _format_facility_distribution(dist_results: Dict[str, Any]) -> str:
         """Format facility distribution analysis results"""
@@ -237,77 +421,8 @@ class ResponseFormatter:
                 level = "High" if inequality > 0.4 else "Moderate" if inequality > 0.2 else "Low"
                 response += f"**Geographic Inequality**: {level} (Gini coefficient: {inequality:.2f})\n\n"
         
-        if "facility_type_distribution" in dist_results:
-            response += "### Facility Type Distribution\n\n"
-            response += "| Facility Type | Count |\n"
-            response += "|---------------|-------|\n"
-            for ftype, count in dist_results["facility_type_distribution"].items():
-                response += f"| {ftype} | {count} |\n"
-            response += "\n"
-            
-            if "facility_diversity" in dist_results:
-                diversity = dist_results["facility_diversity"]
-                response += f"**Facility Diversity Index**: {diversity:.2f} (higher values indicate more diversity)\n\n"
-        
-        if "top_cities" in dist_results and "city_breakdown" in dist_results:
-            response += "### Top Cities by Facility Count\n\n"
-            response += "| City | Hospitals | Nursing/Residential | Ambulatory | Total |\n"
-            response += "|------|-----------|-------------------|------------|-------|\n"
-            
-            for city in dist_results["top_cities"]:
-                if city in dist_results["city_breakdown"]:
-                    breakdown = dist_results["city_breakdown"][city]
-                    hospitals = breakdown.get("Hospitals", 0)
-                    nursing = breakdown.get("Nursing and residential care facilities", 0)
-                    ambulatory = breakdown.get("Ambulatory health care services", 0)
-                    total = hospitals + nursing + ambulatory
-                    response += f"| {city} | {hospitals} | {nursing} | {ambulatory} | {total} |\n"
-            
-            response += "\n"
-        
         return response if response else "No facility distribution data available"
     
-    @staticmethod
-    def _format_capacity_analysis(capacity_results: Dict[str, Any]) -> str:
-        """Format capacity analysis results"""
-        response = ""
-        
-        if "total_capacity" in capacity_results:
-            response += f"**Total System Capacity**: {capacity_results['total_capacity']:,} beds\n\n"
-        
-        if "capacity_by_type" in capacity_results:
-            response += "### Capacity by Facility Type\n\n"
-            response += "| Facility Type | Capacity |\n"
-            response += "|---------------|----------|\n"
-            for ftype, capacity in capacity_results["capacity_by_type"].items():
-                response += f"| {ftype} | {capacity:,} |\n"
-            response += "\n"
-        
-        if "average_utilization" in capacity_results:
-            response += f"**Average System Utilization**: {capacity_results['average_utilization']:.1%}\n\n"
-            
-            if "utilization_by_type" in capacity_results:
-                response += "### Utilization by Facility Type\n\n"
-                response += "| Facility Type | Utilization |\n"
-                response += "|---------------|-------------|\n"
-                for ftype, util in capacity_results["utilization_by_type"].items():
-                    response += f"| {ftype} | {util:.1%} |\n"
-                response += "\n"
-        
-        if "capacity_trends" in capacity_results:
-            response += "### Capacity Trends\n\n"
-            response += "| Year | Capacity |\n"
-            response += "|------|----------|\n"
-            for year, capacity in capacity_results["capacity_trends"].items():
-                response += f"| {year} | {capacity:,} |\n"
-            response += "\n"
-            
-            if "capacity_growth_rate" in capacity_results:
-                growth = capacity_results["capacity_growth_rate"]
-                response += f"**Annual Growth Rate**: {growth:.1%}\n\n"
-        
-        return response if response else "No capacity analysis data available"
-    
     @staticmethod
     def _format_resource_allocation(allocation_results: Dict[str, Any]) -> str:
         """Format resource allocation analysis results"""
@@ -325,26 +440,6 @@ class ResponseFormatter:
                 response += f"| {ftype} | {count:,} | {percentage:.1f}% |\n"
             response += "\n"
         
-        if "allocation_by_region" in allocation_results:
-            response += "### Allocation by Region\n\n"
-            response += "| Region | Resource Count | Percentage |\n"
-            response += "|--------|----------------|------------|\n"
-            for region, count in allocation_results["allocation_by_region"].items():
-                percentage = count / allocation_results.get("total_resources", 1) * 100
-                response += f"| {region} | {count:,} | {percentage:.1f}% |\n"
-            response += "\n"
-        
-        if "efficiency_metrics" in allocation_results:
-            response += "### Efficiency Metrics\n\n"
-            response += "| Metric | Value |\n"
-            response += "|--------|-------|\n"
-            for metric, value in allocation_results["efficiency_metrics"].items():
-                if isinstance(value, float):
-                    response += f"| {metric} | {value:.2f} |\n"
-                else:
-                    response += f"| {metric} | {value} |\n"
-            response += "\n"
-        
         return response if response else "No resource allocation data available"
     
     @staticmethod
@@ -369,115 +464,4 @@ class ResponseFormatter:
                 prev_count = count
             response += "\n"
         
-        if "capacity_trends" in trends_results:
-            response += "### Capacity Trends\n\n"
-            response += "| Year | Total Capacity | Growth Rate |\n"
-            response += "|------|----------------|-------------|\n"
-            prev_capacity = None
-            for year, capacity in trends_results["capacity_trends"].items():
-                if prev_capacity is not None:
-                    growth_rate = (capacity - prev_capacity) / prev_capacity
-                    response += f"| {year} | {capacity:,} | {growth_rate:.1%} |\n"
-                else:
-                    response += f"| {year} | {capacity:,} | N/A |\n"
-                prev_capacity = capacity
-            response += "\n"
-        
-        if "utilization_trends" in trends_results:
-            response += "### Utilization Trends\n\n"
-            response += "| Year | Average Utilization |\n"
-            response += "|------|---------------------|\n"
-            for year, utilization in trends_results["utilization_trends"].items():
-                response += f"| {year} | {utilization:.1%} |\n"
-            response += "\n"
-        
-        if "forecast" in trends_results:
-            response += "### Forecast\n\n"
-            response += trends_results["forecast"] + "\n\n"
-        
-        return response if response else "No trend data available"
-    
-    @staticmethod
-    def _format_recommendations(recommendations_results: List[Dict[str, Any]]) -> str:
-        """Format operational recommendations"""
-        response = ""
-        
-        if not recommendations_results:
-            return "No recommendations available"
-        
-        # Group by priority
-        high_priority = [r for r in recommendations_results if r.get("priority") == "High"]
-        medium_priority = [r for r in recommendations_results if r.get("priority") == "Medium"]
-        low_priority = [r for r in recommendations_results if r.get("priority") == "Low"]
-        
-        if high_priority:
-            response += "### High Priority Recommendations\n\n"
-            for i, rec in enumerate(high_priority, 1):
-                response += f"**{i}. {rec.get('title', 'Recommendation')}**\n\n"
-                response += f"{rec.get('description', '')}\n\n"
-                if "expected_impact" in rec:
-                    response += f"Expected Impact: {rec['expected_impact']}\n\n"
-                if "implementation" in rec:
-                    response += f"Implementation: {rec['implementation']}\n\n"
-                response += "---\n\n"
-        
-        if medium_priority:
-            response += "### Medium Priority Recommendations\n\n"
-            for i, rec in enumerate(medium_priority, 1):
-                response += f"**{i}. {rec.get('title', 'Recommendation')}**\n\n"
-                response += f"{rec.get('description', '')}\n\n"
-                if "expected_impact" in rec:
-                    response += f"Expected Impact: {rec['expected_impact']}\n\n"
-                if "implementation" in rec:
-                    response += f"Implementation: {rec['implementation']}\n\n"
-                response += "---\n\n"
-        
-        if low_priority:
-            response += "### Low Priority Recommendations\n\n"
-            for i, rec in enumerate(low_priority, 1):
-                response += f"**{i}. {rec.get('title', 'Recommendation')}**\n\n"
-                response += f"{rec.get('description', '')}\n\n"
-                if "expected_impact" in rec:
-                    response += f"Expected Impact: {rec['expected_impact']}\n\n"
-                if "implementation" in rec:
-                    response += f"Implementation: {rec['implementation']}\n\n"
-                response += "---\n\n"
-        
-        return response
-    
-    @staticmethod
-    def _format_integration_opportunities(integration_results: Dict[str, Any]) -> str:
-        """Format future integration opportunities"""
-        response = ""
-        
-        if "summary" in integration_results:
-            response += f"**Integration Summary**: {integration_results['summary']}\n\n"
-        
-        if "opportunities" in integration_results:
-            response += "### Integration Opportunities\n\n"
-            for i, opp in enumerate(integration_results["opportunities"], 1):
-                response += f"**{i}. {opp.get('title', 'Opportunity')}**\n\n"
-                response += f"{opp.get('description', '')}\n\n"
-                if "benefits" in opp:
-                    response += "**Benefits:**\n"
-                    for benefit in opp["benefits"]:
-                        response += f"- {benefit}\n"
-                    response += "\n"
-                if "challenges" in opp:
-                    response += "**Challenges:**\n"
-                    for challenge in opp["challenges"]:
-                        response += f"- {challenge}\n"
-                    response += "\n"
-                if "timeline" in opp:
-                    response += f"**Timeline:** {opp['timeline']}\n\n"
-                response += "---\n\n"
-        
-        if "roadmap" in integration_results:
-            response += "### Integration Roadmap\n\n"
-            response += "| Phase | Activities | Timeline |\n"
-            response += "|-------|------------|----------|\n"
-            for phase in integration_results["roadmap"]:
-                response += f"| {phase['name']} | {phase['activities']} | {phase['timeline']} |\n"
-            response += "\n"
-        
-        return response if response else "No integration opportunities identified"
+        return response if response else "No trend data available"