mirror of
https://github.com/rachelos/we-mp-rss.git
synced 2026-11-04 09:22:06 +08:00
36 lines
1.6 KiB
Python
36 lines
1.6 KiB
Python
# 从 sqlalchemy 导入所需的列类型和数据类型
|
|
from .base import Base,Column, Integer, String, DateTime,JSON,Text
|
|
# 从 datetime 模块导入 datetime 类，用于处理日期和时间
|
|
from datetime import datetime
|
|
|
|
# 定义 MessageTask 类，继承自 Base 基类
|
|
class MessageTask(Base):
|
|
from_attributes = True
|
|
# 指定数据库表名为 message_tasks
|
|
__tablename__ = 'message_tasks'
|
|
|
|
# 定义 id 字段，作为主键，同时创建索引
|
|
id = Column(String(255), primary_key=True, index=True)
|
|
# 定义消息类型字段，不允许为空
|
|
message_type = Column(Integer, nullable=False)
|
|
# 定义消息内容字段，使用 JSON 类型存储
|
|
name = Column(String(100), nullable=False)
|
|
|
|
# 定义消息模板字段，不允许为空
|
|
message_template = Column(Text, nullable=False)
|
|
# 定义发送接口
|
|
web_hook_url = Column(String(500), nullable=False)
|
|
# 定义请求头，JSON格式存储
|
|
headers = Column(Text, nullable=True)
|
|
# 定义Cookie，用于认证
|
|
cookies = Column(Text, nullable=True)
|
|
# 定义需要通知的微信公众号ID集合
|
|
mps_id = Column(Text, nullable=False)
|
|
# 定义 cron_exp 表达式
|
|
cron_exp=Column(String(100),nullable='* * 1 * *')
|
|
# 定义任务状态字段，默认值为 pending
|
|
status = Column(Integer, default=0)
|
|
# 定义创建时间字段，默认值为当前 UTC 时间
|
|
created_at = Column(DateTime)
|
|
# 定义更新时间字段，默认值为当前 UTC 时间，更新时自动更新为当前时间
|
|
updated_at = Column(DateTime ) |