ZDXX/2_3banben/models.py

from datetime import datetime
# 引入 UserMixin 是 Flask 标准做法，虽然你主要用 JWT，但保留它可以方便未来扩展或使用某些 Flask 插件
from flask_login import UserMixin
from werkzeug.security import generate_password_hash, check_password_hash
from extensions import db


# =======================
# 数据库 1: 业务数据 (默认数据库 / devices.db)
# =======================

class Device(db.Model):
    __tablename__ = 'devices'
    # 默认数据库，无需 bind_key

    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(100), unique=True, index=True)
    source = db.Column(db.String(50))

    # 快照字段（爬虫自动更新）
    status = db.Column(db.String(50))
    current_value = db.Column(db.String(200))
    latest_time = db.Column(db.String(50))
    json_data = db.Column(db.Text)  # 存储完整原始JSON
    check_time = db.Column(db.String(50))
    reason = db.Column(db.String(255))
    offset = db.Column(db.String(50))  # 时间偏移量说明

    # 手动录入字段 (管理员/工程师可改)
    install_site = db.Column(db.String(100), default="")
    is_maintaining = db.Column(db.Boolean, default=False)
    is_hidden = db.Column(db.Boolean, default=False)

    def to_dict(self):
        """
        转换为前端友好的字典格式
        """
        # 简单处理状态：只要不是明确的离线/异常，就视为 online
        api_status = 'offline' if self.status in ['离线', '异常', '已离线'] else 'online'
        return {
            'id': self.id,
            'name': self.name,
            'source': self.source,
            'latest_time': self.latest_time,
            'status': api_status,  # 给前端图标用的状态 (online/offline)
            'status_text': self.status,  # 显示在界面的原始状态文字
            'value': self.current_value,
            'reason': self.reason,
            'install_site': self.install_site or '',
            'is_maintaining': self.is_maintaining,
            'is_hidden': self.is_hidden,
            'offset': self.offset
        }


class DeviceHistory(db.Model):
    __tablename__ = 'device_history'

    id = db.Column(db.Integer, primary_key=True)
    # 这里虽有 ForeignKey，但在 SQLite 中如果不开启外键约束检查通常没事
    # 但建议逻辑上视为级联删除
    device_id = db.Column(db.Integer, db.ForeignKey('devices.id'))

    data_time = db.Column(db.String(50))
    status = db.Column(db.String(50))
    result_data = db.Column(db.String(200), default="")
    json_data = db.Column(db.Text)
    file_path = db.Column(db.String(255))  # 如果有文件下载功能
    recorded_at = db.Column(db.DateTime, default=datetime.now)


class MaintenanceLog(db.Model):
    __tablename__ = 'maintenance_logs'

    id = db.Column(db.Integer, primary_key=True)
    device_name = db.Column(db.String(100), nullable=False)
    engineer = db.Column(db.String(50))
    location = db.Column(db.String(100))
    content = db.Column(db.Text)
    timestamp = db.Column(db.DateTime, default=datetime.now)

    def to_dict(self):
        return {
            'id': self.id,
            'device_name': self.device_name,
            'engineer': self.engineer or '',
            'location': self.location or '',
            'content': self.content,
            'timestamp': self.timestamp.strftime('%Y-%m-%d %H:%M:%S')
        }


# =======================
# 数据库 2: 用户管理 (users.db)
# =======================

class User(UserMixin, db.Model):
    __bind_key__ = 'users_db'  # 关键：指定存储在 users.db
    __tablename__ = 'users'

    id = db.Column(db.Integer, primary_key=True)
    username = db.Column(db.String(80), unique=True, nullable=False)
    password_hash = db.Column(db.String(128))

    # 🟢 核心字段：角色权限
    # 可选值: 'admin' (超管), 'engineer' (工程师), 'client' (客户)
    role = db.Column(db.String(20), default='client')

    created_at = db.Column(db.DateTime, default=datetime.now)

    def set_password(self, password):
        self.password_hash = generate_password_hash(password)

    def check_password(self, password):
        return check_password_hash(self.password_hash, password)


class UserDevicePermission(db.Model):
    """
    关联表：存储用户ID和设备ID的对应关系。
    注意：因为跨数据库，这里不能使用 ForeignKey 约束指向 Device 表。
    我们只存储纯整数 ID (device_id)，逻辑关联在 api.py 中处理。
    """
    __bind_key__ = 'users_db'
    __tablename__ = 'user_device_permissions'

    id = db.Column(db.Integer, primary_key=True)
    # 关联 User 表 (同库)
    user_id = db.Column(db.Integer, db.ForeignKey('users.id'), nullable=False)
    # 关联 Device 表 (异库，只存 ID)
    device_id = db.Column(db.Integer, nullable=False)