|
1 | 1 | from datetime import datetime |
2 | | -from sqlalchemy import BigInteger, CHAR, Column, DateTime, String |
| 2 | +from sqlalchemy import BigInteger, CHAR, Column, DateTime, DOUBLE, Index, LargeBinary, String |
3 | 3 | from config.database import Base |
| 4 | +from config.env import DataBaseConfig |
| 5 | +from utils.common_util import SqlalchemyUtil |
4 | 6 |
|
5 | 7 |
|
6 | 8 | class SysJob(Base): |
@@ -54,3 +56,19 @@ class SysJobLog(Base): |
54 | 56 | status = Column(CHAR(1), nullable=True, server_default='0', comment='执行状态(0正常 1失败)') |
55 | 57 | exception_info = Column(String(2000), nullable=True, server_default="''", comment='异常信息') |
56 | 58 | create_time = Column(DateTime, nullable=True, default=datetime.now(), comment='创建时间') |
| 59 | + |
| 60 | + |
| 61 | +class ApschedulerJobs(Base): |
| 62 | + """ |
| 63 | + 定时任务调度任务表 |
| 64 | + """ |
| 65 | + |
| 66 | + __tablename__ = 'apscheduler_jobs' |
| 67 | + |
| 68 | + id = Column(String(191), primary_key=True, nullable=False) |
| 69 | + next_run_time = Column( |
| 70 | + DOUBLE, nullable=True, server_default=SqlalchemyUtil.get_server_default_null(DataBaseConfig.db_type, False) |
| 71 | + ) |
| 72 | + job_state = Column(LargeBinary, nullable=False) |
| 73 | + |
| 74 | + idx_sys_logininfor_s = Index('ix_apscheduler_jobs_next_run_time', next_run_time) |
0 commit comments