from sqlalchemy import Boolean, Column, Integer, String
from app.database import Base

import requests
from sqlalchemy.orm import Session
from sqlalchemy import event
from sqlalchemy.orm.attributes import get_history

class User(Base):
    __tablename__ = "users"

    id = Column(Integer, primary_key=True, index=True)
    nickname = Column(String, index=True)
    remark = Column(String)
    wechat_number = Column(String)
    wxid = Column(String, index=True, unique=True)
    gender = Column(String)
    friendaddtime = Column(String)
    openid = Column(String, index=True)
    ebook = Column(Boolean, default=False)  # 新增电子书字段
    activity_status = Column(String, default="0")  # 新增活动报名字段
    vip_member = Column(Boolean, default=False)  # 新增VIP会员字段


def sengTgmesage(message):
    url = "http://192.168.31.38:8521/send_message"
    data = {"message":message}
    headers = {"Content-Type": "application/json"}
    response = requests.post(url, json=data, headers=headers)
    try:
        response_data = response.json()
        print(response_data)
    except requests.exceptions.JSONDecodeError:
        print("Response content is not in JSON format")
        print("Response content:", response.text)
    


def handle_change(mapper, connection, target):
    """监听器函数"""
    if target.__class__.__name__ == 'User':  # 确保只监听User类的变动
        changed_fields = []
        original_value=None
        new_value=None
        
        
        for attr in target.__mapper__.column_attrs:
            history = get_history(target, attr.key)
            if history.has_changes():
                changed_fields.append(attr.key)
                original_value = history.deleted[0] if history.deleted else None
                new_value = history.added[0] if history.added else None
                
        
        if changed_fields:
            print(f"检测到用户 {target.nickname}-{target.remark} 的字段变化: {changed_fields}-{new_value}")
            msg=f"检测到用户 {target.nickname}-{target.remark} 的字段变化: {changed_fields}-{new_value}"
            sengTgmesage(msg)
            # 发起HTTP请求
            # requests.post("http://your-fastapi-endpoint/notify_change", json={"user_id": target.id, "changed_fields": changed_fields})

event.listen(User, "after_update", handle_change)