po.py 2.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. # -*- coding: utf-8 -*-
  2. # @Author : YY
  3. from typing import Optional
  4. from sqlalchemy import CHAR, DateTime, String, text
  5. from sqlalchemy.dialects.mysql import BIGINT
  6. from sqlalchemy.orm import Mapped, mapped_column
  7. import datetime
  8. from ruoyi_admin.ext import db
  9. class SysJobPo(db.Model):
  10. __tablename__ = 'sys_job'
  11. __table_args__ = {'comment': '定时任务调度表'}
  12. job_id: Mapped[int] = mapped_column(BIGINT(20), primary_key=True, comment='任务ID')
  13. job_name: Mapped[str] = mapped_column(String(64), primary_key=True, server_default=text("''"), comment='任务名称')
  14. job_group: Mapped[str] = mapped_column(String(64), primary_key=True, server_default=text("'DEFAULT'"), comment='任务组名')
  15. invoke_target: Mapped[str] = mapped_column(String(500), comment='调用目标字符串')
  16. cron_expression: Mapped[Optional[str]] = mapped_column(String(255), server_default=text("''"), comment='cron执行表达式')
  17. misfire_policy: Mapped[Optional[str]] = mapped_column(String(20), server_default=text("'3'"), comment='计划执行错误策略(1立即执行 2执行一次 3放弃执行)')
  18. concurrent: Mapped[Optional[str]] = mapped_column(CHAR(1), server_default=text("'1'"), comment='是否并发执行(0允许 1禁止)')
  19. status: Mapped[Optional[str]] = mapped_column(CHAR(1), server_default=text("'0'"), comment='状态(0正常 1暂停)')
  20. create_by: Mapped[Optional[str]] = mapped_column(String(64), server_default=text("''"), comment='创建者')
  21. create_time: Mapped[Optional[datetime.datetime]] = mapped_column(DateTime, comment='创建时间')
  22. update_by: Mapped[Optional[str]] = mapped_column(String(64), server_default=text("''"), comment='更新者')
  23. update_time: Mapped[Optional[datetime.datetime]] = mapped_column(DateTime, comment='更新时间')
  24. remark: Mapped[Optional[str]] = mapped_column(String(500), server_default=text("''"), comment='备注信息')
  25. class SysJobLogPo(db.Model):
  26. __tablename__ = 'sys_job_log'
  27. __table_args__ = {'comment': '定时任务调度日志表'}
  28. job_log_id: Mapped[int] = mapped_column(BIGINT(20), primary_key=True, comment='任务日志ID')
  29. job_name: Mapped[str] = mapped_column(String(64), comment='任务名称')
  30. job_group: Mapped[str] = mapped_column(String(64), comment='任务组名')
  31. invoke_target: Mapped[str] = mapped_column(String(500), comment='调用目标字符串')
  32. job_message: Mapped[Optional[str]] = mapped_column(String(500), comment='日志信息')
  33. status: Mapped[Optional[str]] = mapped_column(CHAR(1), server_default=text("'0'"), comment='执行状态(0正常 1失败)')
  34. exception_info: Mapped[Optional[str]] = mapped_column(String(2000), server_default=text("''"), comment='异常信息')
  35. create_time: Mapped[Optional[datetime.datetime]] = mapped_column(DateTime, comment='创建时间')