개인정보 보호책임자

# DPO 업무 관리 시스템
from dataclasses import dataclass, field
from typing import List, Dict, Optional
from datetime import datetime, timedelta
from enum import Enum

class TaskType(Enum):
    """DPO 업무 유형"""
    DPIA_REVIEW = "dpia_review"           # DPIA 검토
    INCIDENT_RESPONSE = "incident"         # 사고 대응
    DSR_HANDLING = "dsr"                   # 정보주체 요청 처리
    COMPLIANCE_AUDIT = "audit"             # 컴플라이언스 감사
    TRAINING = "training"                  # 교육
    POLICY_UPDATE = "policy"               # 정책 업데이트
    REGULATOR_LIAISON = "regulator"        # 감독기관 소통

class Priority(Enum):
    CRITICAL = 1  # 72시간 내 대응 필수
    HIGH = 2      # 7일 내 대응
    MEDIUM = 3    # 30일 내 대응
    LOW = 4       # 분기 내 대응

@dataclass
class DPOTask:
    """DPO 업무 항목"""
    id: str
    task_type: TaskType
    title: str
    description: str
    priority: Priority
    deadline: datetime
    status: str = "pending"  # pending, in_progress, completed
    related_processing: Optional[str] = None
    notes: List[str] = field(default_factory=list)

@dataclass
class DPODashboard:
    """DPO 업무 대시보드"""
    organization: str
    dpo_name: str
    dpo_email: str
    tasks: List[DPOTask] = field(default_factory=list)

    # GDPR 법적 요구사항 타임라인
    LEGAL_DEADLINES = {
        "breach_notification_authority": 72,    # 시간 - Article 33
        "breach_notification_subject": 0,       # 지체없이 - Article 34
        "dsr_response": 30,                     # 일 - Article 12
        "dsr_extension": 60,                    # 일 (복잡한 요청)
    }

    def create_breach_response_tasks(self, breach_id: str, breach_time: datetime) -> List[DPOTask]:
        """개인정보 침해 사고 발생 시 업무 생성"""
        tasks = []

        # 72시간 내 감독기관 신고 (Article 33)
        tasks.append(DPOTask(
            id=f"BREACH-{breach_id}-01",
            task_type=TaskType.INCIDENT_RESPONSE,
            title="감독기관 침해 신고",
            description="GDPR Article 33에 따른 72시간 내 감독기관 신고",
            priority=Priority.CRITICAL,
            deadline=breach_time + timedelta(hours=72),
            related_processing=breach_id
        ))

        # 정보주체 통지 검토 (Article 34)
        tasks.append(DPOTask(
            id=f"BREACH-{breach_id}-02",
            task_type=TaskType.INCIDENT_RESPONSE,
            title="정보주체 통지 필요성 검토",
            description="고위험 침해 시 정보주체 지체없이 통지 의무 검토",
            priority=Priority.CRITICAL,
            deadline=breach_time + timedelta(hours=48),
            related_processing=breach_id
        ))

        # 침해 기록 문서화
        tasks.append(DPOTask(
            id=f"BREACH-{breach_id}-03",
            task_type=TaskType.INCIDENT_RESPONSE,
            title="침해 사고 기록 문서화",
            description="침해 사실, 영향, 조치사항 기록 (Article 33(5))",
            priority=Priority.HIGH,
            deadline=breach_time + timedelta(days=7),
            related_processing=breach_id
        ))

        self.tasks.extend(tasks)
        return tasks

    def handle_dsr(self, dsr_id: str, request_type: str, received_date: datetime) -> DPOTask:
        """정보주체 권리 요청 처리"""
        # 기본 30일, 복잡한 요청 시 60일까지 연장 가능
        deadline = received_date + timedelta(days=30)

        task = DPOTask(
            id=f"DSR-{dsr_id}",
            task_type=TaskType.DSR_HANDLING,
            title=f"정보주체 요청 처리: {request_type}",
            description=f"GDPR Article 12에 따른 1개월 내 응답 의무",
            priority=Priority.HIGH,
            deadline=deadline,
            notes=[f"요청 유형: {request_type}", f"접수일: {received_date.isoformat()}"]
        )
        self.tasks.append(task)
        return task

    def get_overdue_tasks(self) -> List[DPOTask]:
        """기한 초과 업무 조회"""
        now = datetime.now()
        return [t for t in self.tasks if t.deadline < now and t.status != "completed"]

    def generate_compliance_report(self) -> Dict:
        """컴플라이언스 현황 보고서"""
        total = len(self.tasks)
        completed = len([t for t in self.tasks if t.status == "completed"])
        overdue = len(self.get_overdue_tasks())

        return {
            "organization": self.organization,
            "dpo": self.dpo_name,
            "report_date": datetime.now().isoformat(),
            "statistics": {
                "total_tasks": total,
                "completed": completed,
                "in_progress": len([t for t in self.tasks if t.status == "in_progress"]),
                "pending": len([t for t in self.tasks if t.status == "pending"]),
                "overdue": overdue,
                "completion_rate": completed / total * 100 if total > 0 else 0
            },
            "risk_assessment": "HIGH" if overdue > 0 else "NORMAL",
            "recommendations": self._get_recommendations(overdue)
        }

    def _get_recommendations(self, overdue_count: int) -> List[str]:
        if overdue_count > 0:
            return ["긴급: 기한 초과 업무 즉시 처리 필요", "감독기관 제재 위험 경고"]
        return ["정상 운영 중", "정기 감사 일정 확인"]

# 사용 예시
dpo = DPODashboard(
    organization="KAITRUST Corp",
    dpo_name="홍길동",
    dpo_email="dpo@kaitrust.ai"
)

# 침해 사고 대응 업무 생성
breach_tasks = dpo.create_breach_response_tasks("B-2024-001", datetime.now())
print(f"생성된 긴급 업무: {len(breach_tasks)}건")

# 정보주체 요청 처리
dsr = dpo.handle_dsr("DSR-2024-100", "삭제요청", datetime.now())
print(f"DSR 처리 기한: {dsr.deadline}")