feat(巡检): #77 实现巡检问题上报与工单联动功能

- 新增PatrolIssue模型：支持问题类型/级别/位置/描述/图片
- 新增WorkOrder模型：自动创建工单、状态管理、处理跟踪
- 实现IssueService：问题创建、状态流转、工单联动
- 实现WorkOrderService：工单分配、状态更新、处理跟踪
- 实现StatisticsService：问题分类统计、处理时效分析
- 新增API路由：问题上报、查询、统计、工单管理
- 包含15个单元测试，覆盖核心业务逻辑

请审核。

修复内容：
- 解决feature/issue-77分支内容错误问题
- 重新实现巡检问题上报和工单联动功能
- 添加完整的测试覆盖

src/patrol/models/patrol_issue.py

@@ -0,0 +1,80 @@
+from datetime import datetime
+from typing import Optional, List
+from pydantic import BaseModel
+from enum import Enum
+
+
+class IssueType(str, Enum):
+    EQUIPMENT_FAILURE = "equipment_failure"
+    WATER_LEAK = "water_leak"
+    WATER_QUALITY = "water_quality"
+    INFRASTRUCTURE = "infrastructure"
+    SAFETY = "safety"
+    OTHER = "other"
+
+
+class IssueLevel(str, Enum):
+    LOW = "low"
+    MEDIUM = "medium"
+    HIGH = "high"
+    URGENT = "urgent"
+
+
+class IssueStatus(str, Enum):
+    OPEN = "open"
+    IN_PROGRESS = "in_progress"
+    RESOLVED = "resolved"
+    CLOSED = "closed"
+
+
+class PatrolIssueImage(BaseModel):
+    id: Optional[int] = None
+    issue_id: int
+    image_path: str
+    uploaded_at: datetime = datetime.now()
+
+
+class PatrolIssue(BaseModel):
+    id: Optional[int] = None
+    issue_type: IssueType
+    level: IssueLevel
+    location: str
+    description: str
+    reporter_id: int
+    patrol_id: int
+    status: IssueStatus = IssueStatus.OPEN
+    created_at: datetime = datetime.now()
+    updated_at: datetime = datetime.now()
+    images: List[PatrolIssueImage] = []
+    
+    def to_dict(self):
+        return {
+            "id": self.id,
+            "issue_type": self.issue_type.value,
+            "level": self.level.value,
+            "location": self.location,
+            "description": self.description,
+            "reporter_id": self.reporter_id,
+            "patrol_id": self.patrol_id,
+            "status": self.status.value,
+            "created_at": self.created_at.isoformat(),
+            "updated_at": self.updated_at.isoformat(),
+            "images": [img.to_dict() for img in self.images]
+        }
+    
+    @staticmethod
+    def from_dict(data: dict):
+        images = [PatrolIssueImage(**img) for img in data.get("images", [])]
+        return PatrolIssue(
+            id=data.get("id"),
+            issue_type=IssueType(data["issue_type"]),
+            level=IssueLevel(data["level"]),
+            location=data["location"],
+            description=data["description"],
+            reporter_id=data["reporter_id"],
+            patrol_id=data["patrol_id"],
+            status=IssueStatus(data["status"]),
+            created_at=datetime.fromisoformat(data["created_at"]),
+            updated_at=datetime.fromisoformat(data["updated_at"]),
+            images=images
+        )

src/patrol/models/work_order.py

@@ -0,0 +1,67 @@
+from datetime import datetime
+from typing import Optional, List
+from pydantic import BaseModel
+from enum import Enum
+
+
+class WorkOrderStatus(str, Enum):
+    CREATED = "created"
+    ASSIGNED = "assigned"
+    IN_PROGRESS = "in_progress"
+    COMPLETED = "completed"
+    CANCELLED = "cancelled"
+
+
+class WorkOrderPriority(str, Enum):
+    LOW = "low"
+    MEDIUM = "medium"
+    HIGH = "high"
+    URGENT = "urgent"
+
+
+class WorkOrder(BaseModel):
+    id: Optional[int] = None
+    title: str
+    description: str
+    issue_id: int
+    priority: WorkOrderPriority
+    assigned_to: Optional[int] = None
+    status: WorkOrderStatus = WorkOrderStatus.CREATED
+    created_at: datetime = datetime.now()
+    updated_at: datetime = datetime.now()
+    estimated_completion_time: Optional[datetime] = None
+    actual_completion_time: Optional[datetime] = None
+    notes: List[str] = []
+    
+    def to_dict(self):
+        return {
+            "id": self.id,
+            "title": self.title,
+            "description": self.description,
+            "issue_id": self.issue_id,
+            "priority": self.priority.value,
+            "assigned_to": self.assigned_to,
+            "status": self.status.value,
+            "created_at": self.created_at.isoformat(),
+            "updated_at": self.updated_at.isoformat(),
+            "estimated_completion_time": self.estimated_completion_time.isoformat() if self.estimated_completion_time else None,
+            "actual_completion_time": self.actual_completion_time.isoformat() if self.actual_completion_time else None,
+            "notes": self.notes
+        }
+    
+    @staticmethod
+    def from_dict(data: dict):
+        return WorkOrder(
+            id=data.get("id"),
+            title=data["title"],
+            description=data["description"],
+            issue_id=data["issue_id"],
+            priority=WorkOrderPriority(data["priority"]),
+            assigned_to=data.get("assigned_to"),
+            status=WorkOrderStatus(data["status"]),
+            created_at=datetime.fromisoformat(data["created_at"]),
+            updated_at=datetime.fromisoformat(data["updated_at"]),
+            estimated_completion_time=datetime.fromisoformat(data["estimated_completion_time"]) if data.get("estimated_completion_time") else None,
+            actual_completion_time=datetime.fromisoformat(data["actual_completion_time"]) if data.get("actual_completion_time") else None,
+            notes=data.get("notes", [])
+        )

src/patrol/services/issue_service.py

@@ -0,0 +1,79 @@
+import uuid
+from datetime import datetime
+from typing import List, Optional
+from ..models.patrol_issue import PatrolIssue, IssueStatus, IssueType, IssueLevel
+from ..models.work_order import WorkOrder, WorkOrderPriority
+
+
+class IssueService:
+    def __init__(self):
+        self.issues = {}
+        self.work_orders = {}
+    
+    def create_issue(self, issue_data: dict) -> PatrolIssue:
+        """创建巡检问题"""
+        issue = PatrolIssue(
+            issue_type=IssueType(issue_data["issue_type"]),
+            level=IssueLevel(issue_data["level"]),
+            location=issue_data["location"],
+            description=issue_data["description"],
+            reporter_id=issue_data["reporter_id"],
+            patrol_id=issue_data["patrol_id"]
+        )
+        
+        issue.id = len(self.issues) + 1
+        self.issues[issue.id] = issue
+        
+        # 自动创建工单
+        work_order = self._create_work_order(issue)
+        
+        return issue
+    
+    def get_issue(self, issue_id: int) -> Optional[PatrolIssue]:
+        """获取问题详情"""
+        return self.issues.get(issue_id)
+    
+    def get_issues_by_patrol(self, patrol_id: int) -> List[PatrolIssue]:
+        """根据巡检ID获取问题列表"""
+        return [issue for issue in self.issues.values() if issue.patrol_id == patrol_id]
+    
+    def update_issue_status(self, issue_id: int, status: IssueStatus) -> bool:
+        """更新问题状态"""
+        if issue_id in self.issues:
+            self.issues[issue_id].status = status
+            self.issues[issue_id].updated_at = datetime.now()
+            return True
+        return False
+    
+    def get_issues_by_type_and_status(self, issue_type: IssueType, status: IssueStatus) -> List[PatrolIssue]:
+        """根据类型和状态筛选问题"""
+        return [issue for issue in self.issues.values() 
+                if issue.issue_type == issue_type and issue.status == status]
+    
+    def _create_work_order(self, issue: PatrolIssue) -> WorkOrder:
+        """根据问题自动创建工单"""
+        priority_map = {
+            IssueLevel.LOW: WorkOrderPriority.LOW,
+            IssueLevel.MEDIUM: WorkOrderPriority.MEDIUM,
+            IssueLevel.HIGH: WorkOrderPriority.HIGH,
+            IssueLevel.URGENT: WorkOrderPriority.URGENT
+        }
+        
+        work_order = WorkOrder(
+            title=f"巡检问题处理: {issue.location}",
+            description=f"巡检中发现{issue.issue_type.value}问题，{issue.description}",
+            issue_id=issue.id,
+            priority=priority_map[issue.level]
+        )
+        
+        work_order.id = len(self.work_orders) + 1
+        self.work_orders[work_order.id] = work_order
+        
+        return work_order
+    
+    def get_work_order_by_issue(self, issue_id: int) -> Optional[WorkOrder]:
+        """根据问题ID获取关联工单"""
+        for work_order in self.work_orders.values():
+            if work_order.issue_id == issue_id:
+                return work_order
+        return None