Unified_Authentication_Platform/backend/app/services/backup_service.py

import os
import shutil
import zipfile
import pandas as pd
import io
import csv
from datetime import datetime
from typing import List, Dict, Any
from sqlalchemy.orm import Session
from sqlalchemy import inspect, Boolean, Integer
from fastapi import HTTPException
from app.core.database import SessionLocal
from app.models.application import Application
from app.models.mapping import AppUserMapping
from app.models.user import User
from app.models.backup import BackupRecord, BackupType, BackupSettings
from app.core.scheduler import scheduler
from app.core.security import verify_password
from app.services.captcha_service import CaptchaService
from app.services.sms_service import SmsService
from app.services.log_service import LogService
from app.schemas.operation_log import ActionType
from apscheduler.triggers.cron import CronTrigger

# Ensure backup directory exists relative to backend root
BACKUP_DIR = os.path.join(os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__)))), "backups")

class BackupService:
    @staticmethod
    def ensure_backup_dir():
        if not os.path.exists(BACKUP_DIR):
            os.makedirs(BACKUP_DIR, exist_ok=True)

    @staticmethod
    def create_backup(db: Session, backup_type: BackupType = BackupType.MANUAL) -> BackupRecord:
        BackupService.ensure_backup_dir()
        timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
        base_filename = f"backup_{timestamp}"
        zip_filename = f"{base_filename}.zip"
        zip_filepath = os.path.join(BACKUP_DIR, zip_filename)
        
        # Temp dir for csvs
        temp_dir = os.path.join(BACKUP_DIR, f"temp_{timestamp}")
        os.makedirs(temp_dir, exist_ok=True)
        
        try:
            # 1. Export Applications
            apps = db.query(Application).all()
            apps_df = pd.read_sql(db.query(Application).statement, db.bind)
            apps_df.to_csv(os.path.join(temp_dir, "applications.csv"), index=False, encoding='utf-8-sig')
            
            # 2. Export Mappings (Separate by Application)
            mappings_dir = os.path.join(temp_dir, "mappings")
            os.makedirs(mappings_dir, exist_ok=True)
            
            for app in apps:
                # Use app_id (string) for filename, sanitized
                safe_app_id = "".join([c for c in app.app_id if c.isalnum() or c in ('-', '_')])
                if not safe_app_id:
                    safe_app_id = f"app_{app.id}"
                
                app_mappings_query = db.query(AppUserMapping).filter(AppUserMapping.app_id == app.id)
                # Check if there are any mappings
                if app_mappings_query.count() > 0:
                    app_mappings_df = pd.read_sql(app_mappings_query.statement, db.bind)
                    filename = f"mappings_{safe_app_id}.csv"
                    app_mappings_df.to_csv(os.path.join(mappings_dir, filename), index=False, encoding='utf-8-sig')

            # 3. Export Users
            users_df = pd.read_sql(db.query(User).statement, db.bind)
            users_df.to_csv(os.path.join(temp_dir, "users.csv"), index=False, encoding='utf-8-sig')
            
            # 4. Zip
            with zipfile.ZipFile(zip_filepath, 'w', zipfile.ZIP_DEFLATED) as zipf:
                for root, dirs, files in os.walk(temp_dir):
                    for file in files:
                        file_path = os.path.join(root, file)
                        zipf.write(file_path, file.replace(temp_dir, "").lstrip(os.sep))
                        
            # Get file size
            file_size = os.path.getsize(zip_filepath)
            
            # Record
            backup_record = BackupRecord(
                filename=zip_filename,
                file_path=zip_filepath,
                backup_type=backup_type,
                content_types="users,applications,mappings",
                file_size=file_size
            )
            db.add(backup_record)
            db.commit()
            db.refresh(backup_record)
            
            return backup_record
            
        except Exception as e:
            # Cleanup zip if failed
            if os.path.exists(zip_filepath):
                os.remove(zip_filepath)
            raise e
            
        finally:
            # Cleanup temp
            if os.path.exists(temp_dir):
                shutil.rmtree(temp_dir)

    @staticmethod
    def get_settings(db: Session) -> BackupSettings:
        settings = db.query(BackupSettings).first()
        if not settings:
            settings = BackupSettings(auto_backup_enabled=False, backup_time="02:00")
            db.add(settings)
            db.commit()
            db.refresh(settings)
        return settings

    @staticmethod
    def update_settings(db: Session, auto_backup_enabled: bool, backup_time: str):
        settings = BackupService.get_settings(db)
        settings.auto_backup_enabled = auto_backup_enabled
        settings.backup_time = backup_time
        settings.updated_at = datetime.now()
        db.commit()
        db.refresh(settings)
        
        # Update Scheduler
        BackupService.configure_scheduler(settings)
        
        return settings

    @staticmethod
    def configure_scheduler(settings: BackupSettings):
        job_id = "auto_backup_job"
        if scheduler.get_job(job_id):
            scheduler.remove_job(job_id)
            
        if settings.auto_backup_enabled:
            try:
                hour, minute = settings.backup_time.split(":")
                trigger = CronTrigger(hour=int(hour), minute=int(minute))
                scheduler.add_job(
                    BackupService.perform_auto_backup,
                    trigger=trigger,
                    id=job_id,
                    replace_existing=True
                )
            except ValueError:
                # Handle invalid time format if necessary
                pass

    @staticmethod
    def perform_auto_backup():
        db = SessionLocal()
        try:
            BackupService.create_backup(db, BackupType.AUTO)
            # Update last_backup_at
            settings = BackupService.get_settings(db)
            settings.last_backup_at = datetime.now()
            db.commit()
        finally:
            db.close()
            
    @staticmethod
    def init_scheduler(db: Session):
        settings = BackupService.get_settings(db)
        BackupService.configure_scheduler(settings)

    # --- Restore Logic ---

    @staticmethod
    def get_model_columns(model):
        return [c.key for c in inspect(model).mapper.column_attrs]

    @staticmethod
    def preview_restore(db: Session, backup_id: int, restore_type: str):
        backup = db.query(BackupRecord).filter(BackupRecord.id == backup_id).first()
        if not backup or not os.path.exists(backup.file_path):
            raise HTTPException(status_code=404, detail="Backup file not found")

        csv_filename = ""
        model = None
        
        if restore_type == "APPLICATIONS":
            csv_filename = "applications.csv"
            model = Application
        elif restore_type == "USERS":
            csv_filename = "users.csv"
            model = User
        elif restore_type == "MAPPINGS":
            # For mappings, we just check the first file in mappings/ dir to get headers
            # Logic: list zip contents, find first file starting with mappings/
            model = AppUserMapping
        else:
             raise HTTPException(status_code=400, detail="Invalid restore type")

        db_columns = BackupService.get_model_columns(model)
        csv_headers = []

        try:
            with zipfile.ZipFile(backup.file_path, 'r') as zipf:
                target_file = None
                
                if restore_type == "MAPPINGS":
                    for name in zipf.namelist():
                        if name.startswith("mappings/") and name.endswith(".csv"):
                            target_file = name
                            break
                else:
                    if csv_filename in zipf.namelist():
                        target_file = csv_filename
                
                if not target_file:
                     # It's possible the backup doesn't have this file (e.g. empty mappings)
                     return {"csv_headers": [], "db_columns": db_columns}

                with zipf.open(target_file, 'r') as f:
                    # zipf.open returns bytes, need text wrapper
                    wrapper = io.TextIOWrapper(f, encoding='utf-8-sig')
                    reader = csv.reader(wrapper)
                    try:
                        csv_headers = next(reader)
                    except StopIteration:
                        csv_headers = []
        except zipfile.BadZipFile:
            raise HTTPException(status_code=400, detail="Invalid backup file format")

        return {"csv_headers": csv_headers, "db_columns": db_columns}
    
    @staticmethod
    def send_restore_sms(captcha_id: str, captcha_code: str, user: User):
        # 1. Verify Captcha
        if not CaptchaService.verify_captcha(captcha_id, captcha_code):
             raise HTTPException(status_code=400, detail="图形验证码错误")
        
        # 2. Send SMS to current user
        try:
            SmsService.send_code(user.mobile)
        except Exception as e:
            if hasattr(e, "detail"):
                raise e
            raise HTTPException(status_code=400, detail="发送短信失败")

    @staticmethod
    def restore_data(
        db: Session, 
        current_user: User,
        backup_id: int, 
        restore_type: str, 
        field_mapping: Dict[str, str],
        password: str,
        sms_code: str
    ):
        # 1. Verification
        # Verify Password
        if not verify_password(password, current_user.password_hash):
             raise HTTPException(status_code=400, detail="密码错误")
        
        # Verify SMS Code
        if not SmsService.verify_code(current_user.mobile, sms_code):
             raise HTTPException(status_code=400, detail="短信验证码错误或已过期")

        backup = db.query(BackupRecord).filter(BackupRecord.id == backup_id).first()
        if not backup or not os.path.exists(backup.file_path):
            raise HTTPException(status_code=404, detail="Backup file not found")

        # 2. Determine Model and Files
        model = None
        target_files = []
        
        if restore_type == "APPLICATIONS":
            target_files = ["applications.csv"]
            model = Application
        elif restore_type == "USERS":
            target_files = ["users.csv"]
            model = User
        elif restore_type == "MAPPINGS":
             with zipfile.ZipFile(backup.file_path, 'r') as zipf:
                target_files = [name for name in zipf.namelist() if name.startswith("mappings/") and name.endswith(".csv")]
             model = AppUserMapping
        else:
             raise HTTPException(status_code=400, detail="Invalid restore type")

        # 3. Process Restore
        restored_count = 0
        try:
            # Get columns and types for type conversion
            mapper = inspect(model)
            columns = mapper.columns

            with zipfile.ZipFile(backup.file_path, 'r') as zipf:
                for filename in target_files:
                    if filename not in zipf.namelist():
                        continue
                        
                    with zipf.open(filename, 'r') as f:
                        wrapper = io.TextIOWrapper(f, encoding='utf-8-sig')
                        # Use DictReader but we need to map headers manually based on field_mapping
                        # Actually we can just read rows and map values
                        reader = csv.DictReader(wrapper)
                        
                        for row in reader:
                            # Construct data dict based on mapping
                            # field_mapping: { "csv_col": "db_col" }
                            data = {}
                            for csv_col, db_col in field_mapping.items():
                                if csv_col in row and db_col: # if db_col is not empty/none
                                    val = row[csv_col]
                                    
                                    # Type Conversion
                                    if db_col in columns:
                                        col_type = columns[db_col].type
                                        
                                        # Handle Boolean
                                        if isinstance(col_type, Boolean):
                                            if str(val).lower() in ('true', '1', 't', 'yes'):
                                                val = True
                                            elif str(val).lower() in ('false', '0', 'f', 'no'):
                                                val = False
                                            else:
                                                if val == "": val = None
                                        
                                        # Handle Integer
                                        elif isinstance(col_type, Integer):
                                            if val == "":
                                                val = None
                                            else:
                                                try:
                                                    val = int(val)
                                                except ValueError:
                                                    pass # Keep as is or ignore

                                        # Handle Empty Strings for others
                                        elif val == "":
                                            val = None
                                            
                                    data[db_col] = val
                            
                            # Upsert Logic
                            # We assume 'id' is present if mapped. 
                            # If id exists, merge. Else add.
                            if 'id' in data and data['id']:
                                existing = db.query(model).filter(model.id == data['id']).first()
                                if existing:
                                    for k, v in data.items():
                                        setattr(existing, k, v)
                                else:
                                    obj = model(**data)
                                    db.add(obj)
                            else:
                                # No ID, just add? Might create duplicates.
                                # Ideally we should map unique keys. 
                                # For now, let's assume ID is required for restore to work correctly with relationships
                                obj = model(**data)
                                db.add(obj)
                            
                            restored_count += 1
            
            db.commit()
            
            # Log Operation
            LogService.create_log(
                db=db,
                operator_id=current_user.id,
                action_type=ActionType.UPDATE, # Using UPDATE generic for Restore
                details={
                    "event": "restore_data",
                    "type": restore_type,
                    "backup_id": backup_id,
                    "count": restored_count
                }
            )
            
            return {"message": f"Successfully restored {restored_count} records", "count": restored_count}

        except Exception as e:
            db.rollback()
            raise HTTPException(status_code=500, detail=f"Restore failed: {str(e)}")