shanxia2.0/backend/app/models/wechat_notice.py

"""服务号绑定及事务内通知 outbox；不复用小程序 OpenID。"""
from datetime import datetime

from sqlalchemy import Column, String, DateTime, Integer, SmallInteger, Text, UniqueConstraint, Index
from app.core.database import Base


class NoticePublicFields:
    tenant_no = Column(String(64), nullable=False)
    order_num = Column(Integer, nullable=True)
    remark = Column(String(512), nullable=True)
    create_by = Column(String(64), nullable=True)
    create_dept_id = Column(String(64), nullable=False, default="")
    create_time = Column(DateTime, nullable=False, default=datetime.now)
    update_by = Column(String(64), nullable=True)
    update_time = Column(DateTime, nullable=False, default=datetime.now, onupdate=datetime.now)
    del_flag = Column(SmallInteger, nullable=False, default=0)


class WechatBinding(NoticePublicFields, Base):
    __tablename__ = "sys_wechat_oa_binding"
    id = Column(String(64), primary_key=True)
    user_id = Column(String(64), nullable=False)
    appid = Column(String(64), nullable=False)
    openid = Column(String(64), nullable=True)
    subscribed = Column(SmallInteger, nullable=False, default=0)
    __table_args__ = (
        UniqueConstraint("tenant_no", "appid", "user_id", name="uk_oa_binding_user"),
        UniqueConstraint("tenant_no", "appid", "openid", name="uk_oa_binding_openid"),
    )


class WechatApprovalCycle(NoticePublicFields, Base):
    __tablename__ = "sys_wechat_approval_cycle"
    id = Column(String(64), primary_key=True)
    business_type = Column(String(32), nullable=False)
    business_id = Column(String(64), nullable=False)
    cycle_id = Column(String(64), nullable=False)
    submitted_at = Column(DateTime, nullable=False)
    # 当前任务集合及分配版本。转交 A→B→A 仍产生一次新的待办。
    assignments = Column(Text, nullable=False, default="{}")
    __table_args__ = (UniqueConstraint("tenant_no", "business_type", "business_id", name="uk_oa_cycle_business"),)


class WechatNotice(NoticePublicFields, Base):
    __tablename__ = "sys_wechat_notice"
    id = Column(String(64), primary_key=True)
    appid = Column(String(64), nullable=False)
    business_type = Column(String(32), nullable=False)
    business_id = Column(String(64), nullable=False)
    cycle_id = Column(String(64), nullable=False)
    event_key = Column(String(64), nullable=False, unique=True)
    kind = Column(String(16), nullable=False)
    task_key = Column(String(256), nullable=False, default="")
    recipient_id = Column(String(64), nullable=False)
    result = Column(String(16), nullable=True)
    template_id = Column(String(128), nullable=False)
    payload = Column(Text, nullable=False)
    page = Column(String(1024), nullable=False, default="")
    status = Column(String(16), nullable=False, default="pending")
    attempts = Column(Integer, nullable=False, default=0)
    next_attempt_at = Column(DateTime, nullable=False, default=datetime.now)
    claimed_at = Column(DateTime, nullable=True)
    sent_at = Column(DateTime, nullable=True)
    message_id = Column(String(128), nullable=True)
    last_error = Column(String(256), nullable=True)
    __table_args__ = (Index("idx_oa_notice_due", "status", "next_attempt_at"),)