resolved the issue about Emergency and High-Severity Grievance.

backend/models.py

@@ -144,7 +144,10 @@ class Issue(Base):
     longitude = Column(Float, nullable=True, index=True)
     location = Column(String, nullable=True)
     action_plan = Column(JSONEncodedDict, nullable=True)
+    Emergency-and-High-Severity-#290
+    severity = Column(Enum(SeverityLevel), default=SeverityLevel.MEDIUM, index=True)
     integrity_hash = Column(String, nullable=True)  # Blockchain integrity seal
+    main
 
 class PushSubscription(Base):
     __tablename__ = "push_subscriptions"

backend/routers/grievances.py

@@ -1,14 +1,17 @@
 from fastapi import APIRouter, Depends, HTTPException, Query, Request
 from sqlalchemy.orm import Session, joinedload
-from sqlalchemy import func
+from sqlalchemy import func, case
 from typing import List, Optional
 import os
 import json
 import logging
 from datetime import datetime, timezone
 
 from backend.database import get_db
+ Emergency-and-High-Severity-#290
+from backend.models import Grievance, EscalationAudit, SeverityLevel
 from backend.models import Grievance, EscalationAudit, GrievanceFollower, ClosureConfirmation
+ main
 from backend.schemas import (
     GrievanceSummaryResponse, EscalationAuditResponse, EscalationStatsResponse,
     ResponsibilityMapResponse,
@@ -44,6 +47,16 @@ def get_grievances(
         if category:
             query = query.filter(Grievance.category == category)
 
+        # Priority Queue Logic: Sort by Severity (Critical > High > Medium > Low) then by Date (Oldest first for resolution)
+        severity_order = case(
+            (Grievance.severity == SeverityLevel.CRITICAL, 1),
+            (Grievance.severity == SeverityLevel.HIGH, 2),
+            (Grievance.severity == SeverityLevel.MEDIUM, 3),
+            (Grievance.severity == SeverityLevel.LOW, 4),
+            else_=5
+        )
+        query = query.order_by(severity_order.asc(), Grievance.created_at.asc())
+
         grievances = query.offset(offset).limit(limit).all()
 
         # Convert to response format

backend/routers/issues.py

@@ -42,6 +42,7 @@ async def create_issue(
     background_tasks: BackgroundTasks,
     description: str = Form(..., min_length=10, max_length=1000),
     category: str = Form(..., pattern=f"^({'|'.join([cat.value for cat in IssueCategory])})$"),
+    severity: str = Form('medium', pattern="^(low|medium|high|critical)$"),
     language: str = Form('en'),
     user_email: str = Form(None),
     latitude: float = Form(None, ge=-90, le=90),
@@ -187,7 +188,10 @@ async def create_issue(
                 longitude=longitude,
                 location=location,
                 action_plan=None,
+        Emergency-and-High-Severity-#290
+                severity=severity
                 integrity_hash=integrity_hash
+         main
             )
 
             # Offload blocking DB operations to threadpool
@@ -592,6 +596,22 @@ def get_recent_issues(
 
     # Convert to Pydantic models for validation and serialization
     data = []
+     Emergency-and-High-Severity-#290
+    for i in issues:
+        data.append(IssueSummaryResponse(
+            id=i.id,
+            category=i.category,
+            description=i.description[:100] + "..." if len(i.description) > 100 else i.description,
+            created_at=i.created_at,
+            image_path=i.image_path,
+            status=i.status,
+            upvotes=i.upvotes if i.upvotes is not None else 0,
+            location=i.location,
+            latitude=i.latitude,
+            longitude=i.longitude,
+            severity=i.severity.value if hasattr(i.severity, 'value') else i.severity
+            # action_plan is deferred and excluded
+        ).model_dump(mode='json'))
     for row in results:
         # Manually construct dict from named tuple row to avoid full object overhead
         desc = row.description or ""
@@ -609,6 +629,7 @@ def get_recent_issues(
             "latitude": row.latitude,
             "longitude": row.longitude
         })
+     main
 
     # Thread-safe cache update
     recent_issues_cache.set(data, cache_key)

backend/schemas.py

@@ -44,11 +44,17 @@ class IssueSummaryResponse(BaseModel):
     location: Optional[str] = None
     latitude: Optional[float] = None
     longitude: Optional[float] = None
+      Emergency-and-High-Severity-#290
+    severity: Optional[str] = "medium"
+    action_plan: Optional[Any] = None
+
+    model_config = ConfigDict(from_attributes=True)
 
     model_config = ConfigDict(from_attributes=True)
 
 class IssueResponse(IssueSummaryResponse):
     action_plan: Optional[Union[Dict[str, Any], Any]] = Field(None, description="Generated action plan")
+     main
 
 class IssueCreateRequest(BaseModel):
     description: str = Field(..., min_length=10, max_length=1000, description="Issue description")
@@ -57,6 +63,7 @@ class IssueCreateRequest(BaseModel):
     latitude: Optional[float] = Field(None, ge=-90, le=90, description="Latitude coordinate")
     longitude: Optional[float] = Field(None, ge=-180, le=180, description="Longitude coordinate")
     location: Optional[str] = Field(None, max_length=200, description="Location description")
+    severity: Optional[str] = Field("medium", pattern="^(low|medium|high|critical)$", description="Severity level")
 
     @field_validator('description')
     @classmethod
@@ -156,6 +163,7 @@ class NearbyIssueResponse(BaseModel):
     upvotes: int = Field(..., description="Number of upvotes")
     created_at: datetime = Field(..., description="Issue creation timestamp")
     status: str = Field(..., description="Issue status")
+    severity: str = Field(default="medium", description="Issue severity")
 
 
 class DeduplicationCheckResponse(BaseModel):

backend/sla_config_service.py

@@ -83,6 +83,17 @@ def get_sla_hours(self, severity: SeverityLevel, jurisdiction_level: Jurisdictio
                 return sla_config.sla_hours
 
             # Return default
+            # Return default based on severity if available
+            severity_defaults = {
+                SeverityLevel.CRITICAL: 6,
+                SeverityLevel.HIGH: 24,
+                SeverityLevel.MEDIUM: 48,
+                SeverityLevel.LOW: 72
+            }
+
+            if severity in severity_defaults:
+                return severity_defaults[severity]
+
             return self.default_sla_hours
 
         finally:

backend/tasks.py

@@ -1,6 +1,7 @@
 import logging
 import json
 import os
+import hashlib
 from pywebpush import webpush, WebPushException
 from backend.database import SessionLocal
 from backend.models import Issue, PushSubscription
@@ -59,7 +60,19 @@ async def create_grievance_from_issue_background(issue_id: int):
             'vandalism': 'medium'
         }
 
-        severity = severity_mapping.get(issue.category.lower(), 'medium')
+        # Prefer issue's own severity if set, otherwise fallback to mapping
+        if hasattr(issue, 'severity') and issue.severity:
+            severity = issue.severity.value if hasattr(issue.severity, 'value') else issue.severity
+        else:
+            severity = severity_mapping.get(issue.category.lower(), 'medium')
+
+        # Check for immediate escalation triggers (e.g. Critical severity)
+        if severity == 'critical':
+            # Log critical issue with safe identifiers only (no PII)
+            description_text = issue.description or ""
+            desc_hash = hashlib.sha256(description_text.encode('utf-8')).hexdigest()[:12]
+            logger.warning(f"CRITICAL ISSUE REPORTED: ID={issue.id} [Hash={desc_hash}]")
+            # Here we could trigger immediate SMS/Call alerts or specialized notifications
 
         # Create grievance data
         grievance_data = {

frontend/src/locales/en.json

@@ -14,7 +14,13 @@
       "civicServices": "Civic Services",
       "management": "Management"
     },
+    "urgent": "URGENT",
     "issues": {
+      "noise": "Noise",
+      "crowd": "Crowd",
+      "waterLeak": "Water Leak",
+      "wasteSorter": "Waste Sorter",
+      "civicEye": "Civic Eye",
       "pothole": "Pothole",
       "blockedRoad": "Blocked Road",
       "illegalParking": "Illegal Parking",