Site RA

README.md

@@ -1040,3 +1040,226 @@ For support and questions:
 ---
 
 **Built with ❤️ for enterprise risk management and business continuity**
+
+---
+
+## Site Risk Assessment Endpoint
+
+### Overview
+The Site Risk Assessment endpoint provides comprehensive risk analysis for physical locations based on detailed site characteristics, building information, and compliance status. This endpoint is specifically designed for facilities management and safety assessment.
+
+### Endpoint Details
+- **Method**: `POST`
+- **URL**: `/api/site-risk-assessment`
+- **Purpose**: Generate detailed site-specific risk assessments based on physical location characteristics
+
+### Use Cases
+- **Facilities Risk Management**: Comprehensive assessment of physical site risks
+- **Fire Safety Compliance**: Detailed fire risk analysis for commercial buildings
+- **Insurance Risk Assessment**: Site-specific risk evaluation for insurance purposes
+- **Regulatory Compliance**: Assessment against building codes and safety standards
+- **Emergency Planning**: Risk analysis for emergency response planning
+- **Property Management**: Ongoing risk monitoring for managed properties
+
+### Request Body
+```json
+{
+  "riskCategory": "Fire Safety",
+  "controlQuestion": "Are fire extinguishers available and regularly inspected?",
+  "complianceStatus": "Yes, fire extinguishers are available on each floor and inspected monthly.",
+  "address_of_location": "123 Corporate Park, Mumbai",
+  "nature_of_occupancy": "Office space with attached cafeteria",
+  "building_construction_details": "RCC framed structure with glass facade",
+  "nature_of_other_occupancies": "Shared with retail stores on ground floor, clear separation exists",
+  "total_floors_and_communication": "10 floors with 2 staircases and 3 elevators",
+  "total_floor_area": "25,000 sq. ft.",
+  "maximum_undivided_area": "3,000 sq. ft.",
+  "floors_occupied": "3",
+  "building_age": "12 years",
+  "stability_certificate": "Yes",
+  "fire_noc_availability": "Yes, renewed annually",
+  "people_working_floor_wise": "Ground: 10, 1st: 50, 2nd: 45",
+  "max_visitors_peak_day": "Around 80",
+  "business_hours": "Mon–Fri, 9:00 AM to 6:00 PM",
+  "power_backup_details": "100 kVA DG installed with 8-hour backup",
+  "store_room_stacking": "Properly labeled, no obstruction to exits",
+  "floor_covering_nature": "Antistatic carpet in work areas",
+  "false_ceiling_details": "Gypsum tiles with concealed lighting",
+  "hvac_system_details": "Centralized HVAC with AHUs on each floor",
+  "area_passage_around_building": "2-meter fire vehicle access on all sides"
+}
+```
+
+### Response Format
+```json
+{
+  "risk_id": "RISK-001",
+  "category": "Fire Safety",
+  "business_unit": "Facilities",
+  "risk_owner": "Fire Safety Officer",
+  "timeline": "Immediate",
+  "risk_name": "Inadequate fire suppression coverage for office complex",
+  "question": "Are fire extinguishers available and regularly inspected?",
+  "compliance_status": "Yes, fire extinguishers are available on each floor and inspected monthly.",
+  "identified_threat": "Fire spread risk due to limited suppression systems in high-occupancy areas",
+  "likelihood": 6,
+  "impact": 8,
+  "risk_value": 48,
+  "residual_risk": "High",
+  "current_control_description": "Manual fire extinguishers with monthly inspections, no automated suppression",
+  "current_control_rating": "Fair",
+  "mitigation_plan": "Install automated fire suppression systems in high-risk areas, upgrade emergency evacuation systems, and enhance fire detection coverage",
+  "site_details": {
+    "site_name": "Corporate Office Complex - Mumbai",
+    "address": "123 Corporate Park, Mumbai",
+    "building_type": "Commercial Office",
+    "floor_area_sq_ft": 25000,
+    "occupancy_type": "Office space with attached cafeteria",
+    "year_of_construction": 2012,
+    "no_of_floors": 10
+  },
+  "risk_classification_summary": "High-priority fire safety risk due to building age, occupancy density, and limited automated suppression systems. Requires immediate attention per NFPA guidelines.",
+  "mitigation_suggestions": [
+    "Install automatic sprinkler systems per NFPA 13 standards",
+    "Upgrade fire alarm systems with voice evacuation capabilities",
+    "Implement quarterly fire drills and emergency response training",
+    "Establish fire safety committee and regular risk assessments"
+  ],
+  "risk_trends": {
+    "top_category": "Fire Safety",
+    "risk_severity": "High",
+    "observations": [
+      "Buildings over 10 years require enhanced fire safety measures",
+      "High-density office occupancy increases evacuation complexity",
+      "Mixed-use buildings require comprehensive fire separation strategies"
+    ]
+  }
+}
+```
+
+### Key Features
+
+#### **Comprehensive Site Analysis**
+- **Building Characteristics**: Construction type, age, and structural details
+- **Occupancy Patterns**: Personnel distribution, visitor capacity, and usage patterns
+- **Safety Systems**: Fire protection, HVAC, electrical, and emergency systems
+- **Compliance Status**: Regulatory certifications and inspection records
+
+#### **Evidence-Based Assessment**
+- **Building Code References**: NFPA standards, International Building Code (IBC)
+- **Occupancy Load Analysis**: Egress capacity and evacuation requirements
+- **Historical Risk Data**: Industry-specific incident patterns and trends
+- **Regulatory Compliance**: Local fire codes and safety regulations
+
+#### **Actionable Recommendations**
+- **Specific Mitigation Plans**: Targeted improvements based on site characteristics
+- **Timeline Prioritization**: Risk-based scheduling for remediation activities
+- **Cost-Effectiveness**: Practical solutions considering budget constraints
+- **Compliance Alignment**: Recommendations aligned with regulatory requirements
+
+### Integration Examples
+
+#### **cURL Example**
+```bash
+curl -X POST "http://localhost:8000/api/site-risk-assessment" \
+  -H "Content-Type: application/json" \
+  -d '{
+    "riskCategory": "Fire Safety",
+    "controlQuestion": "Are fire extinguishers available and regularly inspected?",
+    "complianceStatus": "Yes, fire extinguishers are available on each floor and inspected monthly.",
+    "address_of_location": "123 Corporate Park, Mumbai",
+    "nature_of_occupancy": "Office space with attached cafeteria",
+    "building_construction_details": "RCC framed structure with glass facade",
+    "nature_of_other_occupancies": "Shared with retail stores on ground floor, clear separation exists",
+    "total_floors_and_communication": "10 floors with 2 staircases and 3 elevators",
+    "total_floor_area": "25,000 sq. ft.",
+    "maximum_undivided_area": "3,000 sq. ft.",
+    "floors_occupied": "3",
+    "building_age": "12 years",
+    "stability_certificate": "Yes",
+    "fire_noc_availability": "Yes, renewed annually",
+    "people_working_floor_wise": "Ground: 10, 1st: 50, 2nd: 45",
+    "max_visitors_peak_day": "Around 80",
+    "business_hours": "Mon–Fri, 9:00 AM to 6:00 PM",
+    "power_backup_details": "100 kVA DG installed with 8-hour backup",
+    "store_room_stacking": "Properly labeled, no obstruction to exits",
+    "floor_covering_nature": "Antistatic carpet in work areas",
+    "false_ceiling_details": "Gypsum tiles with concealed lighting",
+    "hvac_system_details": "Centralized HVAC with AHUs on each floor",
+    "area_passage_around_building": "2-meter fire vehicle access on all sides"
+  }'
+```
+
+#### **Python Integration**
+```python
+import requests
+
+# Site risk assessment request
+site_data = {
+    "riskCategory": "Fire Safety",
+    "controlQuestion": "Are fire extinguishers available and regularly inspected?",
+    "complianceStatus": "Yes, fire extinguishers are available on each floor and inspected monthly.",
+    "address_of_location": "123 Corporate Park, Mumbai",
+    "nature_of_occupancy": "Office space with attached cafeteria",
+    # ... other site details
+}
+
+response = requests.post(
+    "http://localhost:8000/api/site-risk-assessment",
+    json=site_data
+)
+
+if response.status_code == 200:
+    assessment = response.json()
+    print(f"Risk Level: {assessment['residual_risk']}")
+    print(f"Risk Score: {assessment['risk_value']}")
+    print(f"Mitigation Plan: {assessment['mitigation_plan']}")
+else:
+    print(f"Error: {response.text}")
+```
+
+#### **JavaScript Integration**
+```javascript
+const siteAssessment = async (siteData) => {
+  try {
+    const response = await fetch('/api/site-risk-assessment', {
+      method: 'POST',
+      headers: {
+        'Content-Type': 'application/json',
+      },
+      body: JSON.stringify(siteData)
+    });
+    
+    if (response.ok) {
+      const assessment = await response.json();
+      return {
+        riskId: assessment.risk_id,
+        riskLevel: assessment.residual_risk,
+        mitigationPlan: assessment.mitigation_plan,
+        siteDetails: assessment.site_details
+      };
+    } else {
+      throw new Error('Assessment failed');
+    }
+  } catch (error) {
+    console.error('Site assessment error:', error);
+    return null;
+  }
+};
+```
+
+### Error Handling
+
+The endpoint provides comprehensive error handling with specific error codes:
+
+- **400 Bad Request**: Invalid input data or missing required fields
+- **422 Validation Error**: Data validation failures
+- **500 Internal Server Error**: AI processing errors with fallback responses
+
+### Fallback Mechanism
+
+If AI processing fails, the endpoint provides intelligent fallback responses based on:
+- **Building Age Analysis**: Risk assessment based on construction year
+- **Occupancy Density**: Risk factors related to personnel count
+- **Floor Area Considerations**: Space-based risk calculations
+- **Compliance Status**: Assessment based on current safety measures

app.py

@@ -1,10 +1,12 @@
 # app.py
-from fastapi import FastAPI
+from fastapi import FastAPI, HTTPException
 from pydantic import BaseModel
 from typing import List, Optional
 import os
 import openai
 import json
+import uuid
+import re
 
 # Import the new routers
 from enterprise_ra import enterprise_ra_router
@@ -264,6 +266,68 @@ class RiskAnalysis(BaseModel):
 class RiskMitigationResponse(BaseModel):
     risk_analysis: RiskAnalysis
 
+# Site Risk Assessment Models
+class SiteDetails(BaseModel):
+    site_name: Optional[str] = ""
+    address: str
+    building_type: Optional[str] = ""
+    floor_area_sq_ft: Optional[int] = 0
+    occupancy_type: str
+    year_of_construction: Optional[int] = 0
+    no_of_floors: Optional[int] = 0
+
+class SiteRiskAssessmentRequest(BaseModel):
+    riskCategory: str
+    controlQuestion: str
+    complianceStatus: str
+    address_of_location: str
+    nature_of_occupancy: str
+    building_construction_details: str
+    nature_of_other_occupancies: str
+    total_floors_and_communication: str
+    total_floor_area: str
+    maximum_undivided_area: str
+    floors_occupied: str
+    building_age: str
+    stability_certificate: str
+    fire_noc_availability: str
+    people_working_floor_wise: str
+    max_visitors_peak_day: str
+    business_hours: str
+    power_backup_details: str
+    store_room_stacking: str
+    floor_covering_nature: str
+    false_ceiling_details: str
+    hvac_system_details: str
+    area_passage_around_building: str
+
+class SiteRiskTrends(BaseModel):
+    top_category: str
+    risk_severity: str
+    observations: List[str]
+
+class SiteRiskAssessmentResponse(BaseModel):
+    risk_id: str
+    category: str
+    business_unit: str
+    risk_owner: str
+    timeline: str
+    risk_name: str
+    question: str
+    compliance_status: str
+    identified_threat: str
+    likelihood: int
+    impact: int
+    risk_value: int
+    residual_risk: str
+    current_control_description: str
+    current_control_rating: str
+    mitigation_plan: str
+    site_details: SiteDetails
+    risk_classification_summary: str
+    mitigation_suggestions: List[str]
+    risk_trends: SiteRiskTrends
+
 @app.post("/api/risk-mitigation", response_model=RiskMitigationResponse)
 def generate_risk_mitigation(request: RiskRequestModel):
     """
@@ -569,3 +633,250 @@ Provide a comprehensive risk analysis with mitigation plan based on this respons
         )
         
         return RiskMitigationResponse(risk_analysis=risk_analysis)
+
+@app.post("/api/site-risk-assessment", response_model=SiteRiskAssessmentResponse)
+def generate_site_risk_assessment(request: SiteRiskAssessmentRequest):
+    """
+    Generate comprehensive site-specific risk assessment based on physical location details
+    """
+    
+    system_prompt = """You are a comprehensive risk assessment expert specializing in site-specific risk analysis. Your task is to analyze physical site details and generate detailed risk assessments based on the provided information.
+
+CRITICAL: You must respond with ONLY a valid JSON object. Do not include any markdown formatting, code blocks, or additional text.
+
+For the site risk assessment, consider:
+- Physical building characteristics and construction details
+- Occupancy patterns and usage
+- Fire safety systems and compliance status
+- Emergency egress and accessibility
+- HVAC and electrical systems
+- Regulatory compliance (fire NOC, stability certificates)
+- Site-specific vulnerabilities and threats
+- Industry standards (NFPA, building codes, occupational safety)
+
+Provide evidence-based assessments that reference:
+- Building codes and fire safety standards (NFPA 101, IBC)
+- Occupancy load calculations and egress requirements
+- Construction type fire ratings and vulnerability factors
+- Historical incident data for similar occupancies
+- Industry best practices for risk mitigation
+- Regulatory compliance requirements
+
+RESPOND WITH ONLY THIS EXACT JSON FORMAT:
+{
+  "risk_id": "Unique risk identifier starting with RISK-",
+  "category": "Risk category from input",
+  "business_unit": "Relevant business unit",
+  "risk_owner": "Appropriate risk owner role",
+  "timeline": "Risk mitigation timeline",
+  "risk_name": "Specific risk name based on site analysis",
+  "question": "Control question from input",
+  "compliance_status": "Compliance status from input", 
+  "identified_threat": "Specific threat based on site characteristics",
+  "likelihood": "Numeric likelihood score 1-10",
+  "impact": "Numeric impact score 1-10",
+  "risk_value": "Calculated risk value",
+  "residual_risk": "Risk level (Low/Medium/High/Critical)",
+  "current_control_description": "Description of current controls",
+  "current_control_rating": "Rating of current controls",
+  "mitigation_plan": "Specific mitigation recommendations",
+  "site_details": {
+    "site_name": "Derived site name",
+    "address": "Address from input",
+    "building_type": "Building type derived from occupancy",
+    "floor_area_sq_ft": "Numeric floor area",
+    "occupancy_type": "Occupancy type from input",
+    "year_of_construction": "Calculated year",
+    "no_of_floors": "Number of floors from input"
+  },
+  "risk_classification_summary": "Summary of risk classification and reasoning",
+  "mitigation_suggestions": ["List of specific mitigation suggestions"],
+  "risk_trends": {
+    "top_category": "Risk category",
+    "risk_severity": "Severity level",
+    "observations": ["List of trend observations"]
+  }
+}"""
+
+    # Convert request to structured input
+    input_data = {
+        "risk_category": request.riskCategory,
+        "control_question": request.controlQuestion,
+        "compliance_status": request.complianceStatus,
+        "site_information": {
+            "address": request.address_of_location,
+            "occupancy_nature": request.nature_of_occupancy,
+            "building_construction": request.building_construction_details,
+            "neighboring_occupancies": request.nature_of_other_occupancies,
+            "floors_and_communication": request.total_floors_and_communication,
+            "total_floor_area": request.total_floor_area,
+            "max_undivided_area": request.maximum_undivided_area,
+            "floors_occupied": request.floors_occupied,
+            "building_age": request.building_age,
+            "stability_certificate": request.stability_certificate,
+            "fire_noc": request.fire_noc_availability,
+            "occupancy_details": request.people_working_floor_wise,
+            "visitor_capacity": request.max_visitors_peak_day,
+            "operating_hours": request.business_hours,
+            "power_systems": request.power_backup_details,
+            "storage_conditions": request.store_room_stacking,
+            "flooring": request.floor_covering_nature,
+            "ceiling_details": request.false_ceiling_details,
+            "hvac_system": request.hvac_system_details,
+            "building_access": request.area_passage_around_building
+        }
+    }
+
+    user_message = f"""Analyze the following site information and generate a comprehensive risk assessment:
+
+{json.dumps(input_data, indent=2)}
+
+Provide a detailed site-specific risk assessment considering all physical characteristics, occupancy patterns, compliance status, and potential vulnerabilities. Include specific recommendations based on the building details and current control status."""
+
+    try:
+        result = generate_response(system_prompt, user_message)
+        
+        # Clean the response - remove markdown code blocks if present
+        cleaned_result = result.strip()
+        if cleaned_result.startswith('```json'):
+            cleaned_result = cleaned_result[7:]
+        elif cleaned_result.startswith('```'):
+            cleaned_result = cleaned_result[3:]
+        if cleaned_result.endswith('```'):
+            cleaned_result = cleaned_result[:-3]
+        cleaned_result = cleaned_result.strip()
+        
+        # Extract JSON from the response
+        json_start = cleaned_result.find('{')
+        json_end = cleaned_result.rfind('}') + 1
+        
+        if json_start != -1 and json_end > json_start:
+            json_str = cleaned_result[json_start:json_end]
+            # Clean up any problematic characters
+            json_str = re.sub(r'\r\s*', ' ', json_str)
+            json_str = re.sub(r'\t+', ' ', json_str)
+            json_str = re.sub(r'\s+', ' ', json_str)
+            assessment_data = json.loads(json_str)
+            
+            # Extract site details
+            site_info = assessment_data.get("site_details", {})
+            site_details = SiteDetails(
+                site_name=site_info.get("site_name", ""),
+                address=site_info.get("address", request.address_of_location),
+                building_type=site_info.get("building_type", ""),
+                floor_area_sq_ft=site_info.get("floor_area_sq_ft", 0),
+                occupancy_type=site_info.get("occupancy_type", request.nature_of_occupancy),
+                year_of_construction=site_info.get("year_of_construction", 0),
+                no_of_floors=site_info.get("no_of_floors", 0)
+            )
+            
+            # Extract risk trends
+            trends_info = assessment_data.get("risk_trends", {})
+            risk_trends = SiteRiskTrends(
+                top_category=trends_info.get("top_category", request.riskCategory),
+                risk_severity=trends_info.get("risk_severity", "Medium"),
+                observations=trends_info.get("observations", [])
+            )
+            
+            return SiteRiskAssessmentResponse(
+                risk_id=assessment_data.get("risk_id", f"RISK-{str(uuid.uuid4())[:8].upper()}"),
+                category=assessment_data.get("category", request.riskCategory),
+                business_unit=assessment_data.get("business_unit", "Facilities"),
+                risk_owner=assessment_data.get("risk_owner", "Risk Manager"),
+                timeline=assessment_data.get("timeline", "Short-term"),
+                risk_name=assessment_data.get("risk_name", f"Site-specific {request.riskCategory} risk"),
+                question=assessment_data.get("question", request.controlQuestion),
+                compliance_status=assessment_data.get("compliance_status", request.complianceStatus),
+                identified_threat=assessment_data.get("identified_threat", f"Site-specific {request.riskCategory} vulnerability"),
+                likelihood=assessment_data.get("likelihood", 5),
+                impact=assessment_data.get("impact", 5),
+                risk_value=assessment_data.get("risk_value", 25),
+                residual_risk=assessment_data.get("residual_risk", "Medium"),
+                current_control_description=assessment_data.get("current_control_description", "Standard site controls in place"),
+                current_control_rating=assessment_data.get("current_control_rating", "Fair"),
+                mitigation_plan=assessment_data.get("mitigation_plan", "Implement enhanced site-specific controls"),
+                site_details=site_details,
+                risk_classification_summary=assessment_data.get("risk_classification_summary", "Site risk requiring attention"),
+                mitigation_suggestions=assessment_data.get("mitigation_suggestions", []),
+                risk_trends=risk_trends
+            )
+        else:
+            raise ValueError("No valid JSON found in response")
+            
+    except (json.JSONDecodeError, ValueError) as e:
+        # Fallback response based on input data
+        building_age_num = 0
+        try:
+            # Extract numeric age from building age string
+            age_match = re.search(r'\d+', request.building_age)
+            if age_match:
+                building_age_num = int(age_match.group())
+        except:
+            building_age_num = 10
+            
+        # Extract floor area
+        floor_area_num = 0
+        try:
+            area_match = re.search(r'[\d,]+', request.total_floor_area.replace(',', ''))
+            if area_match:
+                floor_area_num = int(area_match.group().replace(',', ''))
+        except:
+            floor_area_num = 25000
+            
+        # Extract number of floors
+        floors_num = 0
+        try:
+            floors_match = re.search(r'\d+', request.total_floors_and_communication)
+            if floors_match:
+                floors_num = int(floors_match.group())
+        except:
+            floors_num = 3
+        
+        fallback_response = SiteRiskAssessmentResponse(
+            risk_id=f"RISK-{str(uuid.uuid4())[:8].upper()}",
+            category=request.riskCategory,
+            business_unit="Facilities Management",
+            risk_owner="Fire Safety Officer" if "fire" in request.riskCategory.lower() else "Risk Manager",
+            timeline="Immediate" if "critical" in request.complianceStatus.lower() else "Short-term",
+            risk_name=f"Site-specific {request.riskCategory} control deficiency",
+            question=request.controlQuestion,
+            compliance_status=request.complianceStatus,
+            identified_threat=f"Inadequate {request.riskCategory.lower()} controls may lead to property damage, personnel injury, and operational disruption",
+            likelihood=7 if building_age_num > 15 else 5,
+            impact=8 if floor_area_num > 20000 else 6,
+            risk_value=56 if building_age_num > 15 and floor_area_num > 20000 else 30,
+            residual_risk="High" if building_age_num > 15 and floor_area_num > 20000 else "Medium",
+            current_control_description=f"Current {request.riskCategory.lower()} controls include basic safety measures as described in compliance status",
+            current_control_rating="Fair" if "yes" in request.complianceStatus.lower() else "Poor",
+            mitigation_plan=f"Enhance {request.riskCategory.lower()} control systems, implement regular inspections, and ensure compliance with relevant safety standards",
+            site_details=SiteDetails(
+                site_name=f"Commercial Facility - {request.address_of_location.split(',')[-1].strip() if ',' in request.address_of_location else 'Location'}",
+                address=request.address_of_location,
+                building_type=request.nature_of_occupancy.split()[0] if request.nature_of_occupancy else "Commercial",
+                floor_area_sq_ft=floor_area_num,
+                occupancy_type=request.nature_of_occupancy,
+                year_of_construction=2024 - building_age_num if building_age_num > 0 else 2010,
+                no_of_floors=floors_num
+            ),
+            risk_classification_summary=f"Site-specific {request.riskCategory} risk assessment based on building characteristics and current control status",
+            mitigation_suggestions=[
+                f"Upgrade {request.riskCategory.lower()} detection and suppression systems",
+                "Conduct regular safety training and emergency drills",
+                "Implement preventive maintenance programs",
+                "Ensure compliance with local safety regulations"
+            ],
+            risk_trends=SiteRiskTrends(
+                top_category=request.riskCategory,
+                risk_severity="High" if building_age_num > 15 else "Medium",
+                observations=[
+                    f"Building age of {building_age_num} years increases maintenance requirements",
+                    f"Floor area of {floor_area_num:,} sq ft requires comprehensive safety systems",
+                    f"Multi-floor occupancy increases emergency response complexity"
+                ]
+            )
+        )
+        
+        return fallback_response
+    
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"Error generating site risk assessment: {str(e)}")