tb_sys_date

批量任务日期表。用于控制日终任务批量任务批前日期，批后日期参数。

  1. -- Create table
  2. create table TB_SYS_DATE
  3. (
  4.   order_num      NUMBER(11) not null,
  5.   bat_date       VARCHAR2(8) not null,
  6.   bat_daten      VARCHAR2(8) not null,
  7.   sts            VARCHAR2(1) not null,
  8.   trigger_time   NUMBER(3) not null,
  9.   allow_beg_time VARCHAR2(8) not null,
  10.   allow_end_time VARCHAR2(8) not null,
  11.   beg_time       DATE,
  12.   end_time       DATE
  13. );
  14. -- Add comments to the table 
  15. comment on table TB_SYS_DATE
  16.   is '批量配置表';
  17. -- Add comments to the columns 
  18. comment on column TB_SYS_DATE.order_num
  19.   is '序号';
  20. comment on column TB_SYS_DATE.bat_date
  21.   is '批量日期';
  22. comment on column TB_SYS_DATE.bat_daten
  23.   is '批后日期';
  24. comment on column TB_SYS_DATE.sts
  25.   is '状态：0-初始化，1-准备，2-运行，4-成功';
  26. comment on column TB_SYS_DATE.trigger_time
  27.   is '批量间隔时间';
  28. comment on column TB_SYS_DATE.allow_beg_time
  29.   is '启动时间段-开始';
  30. comment on column TB_SYS_DATE.allow_end_time
  31.   is '启动时间段-结束';
  32. comment on column TB_SYS_DATE.beg_time
  33.   is '启动时间';
  34. comment on column TB_SYS_DATE.end_time
  35.   is '结束时间';

tb_job_group

用于存储执行器信息。

  1. -- Create table
  2. create table TB_JOB_GROUP
  3. (
  4.   id           NUMBER(11) not null,
  5.   app_name     VARCHAR2(64) not null,
  6.   title        VARCHAR2(100) not null,
  7.   order_num    NUMBER(11) default 0 not null,
  8.   address_type NUMBER(4) default 0 not null,
  9.   address_list VARCHAR2(512),
  10.   job_taskid   VARCHAR2(32)
  11. );
  12. -- Add comments to the table
  13. comment on table TB_JOB_GROUP
  14.   is '任务组别表';
  15. -- Add comments to the columns
  16. comment on column TB_JOB_GROUP.app_name
  17.   is '执行器AppName';
  18. comment on column TB_JOB_GROUP.title
  19.   is '执行器名称';
  20. comment on column TB_JOB_GROUP.order_num
  21.   is '排序';
  22. comment on column TB_JOB_GROUP.address_type
  23.   is '执行器地址类型：0=自动注册、1=手动录入';
  24. comment on column TB_JOB_GROUP.address_list
  25.   is '执行器地址列表，多地址逗号分隔';
  26. comment on column TB_JOB_GROUP.job_taskid
  27.   is '起始配置任务ID';

tb_job_registry

用于存储自动注册执行器IP信息。

  1. -- Create table
  2. create table TB_JOB_REGISTRY
  3. (
  4.   id             NUMBER(11) not null,
  5.   registry_group VARCHAR2(255) not null,
  6.   registry_key   VARCHAR2(255) not null,
  7.   registry_value VARCHAR2(255) not null,
  8.   update_time    DATE default CURRENT_TIMESTAMP not null
  9. )；

tb_job_task

用于存储调度任务任务信息。

  1. -- Create table
  2. create table TB_JOB_TASK
  3. (
  4.   id                        VARCHAR2(32) not null,
  5.   job_group                 NUMBER(11),
  6.   job_cron                  VARCHAR2(128),
  7.   job_desc                  VARCHAR2(255),
  8.   add_time                  DATE,
  9.   update_time               DATE,
  10.   author                    VARCHAR2(64),
  11.   alarm_email               VARCHAR2(255),
  12.   executor_route_strategy   VARCHAR2(50),
  13.   executor_handler          VARCHAR2(255),
  14.   executor_param            VARCHAR2(512),
  15.   executor_block_strategy   VARCHAR2(50),
  16.   executor_timeout          NUMBER(11) default 0,
  17.   executor_fail_retry_count NUMBER(11) default 0,
  18.   glue_type                 VARCHAR2(50),
  19.   glue_source               CLOB,
  20.   glue_remark               VARCHAR2(128),
  21.   glue_updatetime           DATE,
  22.   child_jobid               VARCHAR2(2000),
  23.   trigger_status            NUMBER(4) default 0,
  24.   trigger_last_time         NUMBER(20) default 0,
  25.   trigger_next_time         NUMBER(20) default 0,
  26.   job_code                  VARCHAR2(100),
  27.   uuid                      VARCHAR2(32),
  28.   step_id                   VARCHAR2(32),
  29.   dependency_id             VARCHAR2(2000),
  30.   parallel_type             VARCHAR2(8),
  31.   field_01                  VARCHAR2(32),
  32.   field_02                  VARCHAR2(32),
  33.   field_03                  VARCHAR2(32),
  34.   status                    NUMBER(4) default 0,
  35.   first_flag                VARCHAR2(32)
  36. );
  37. -- Add comments to the columns
  38. comment on column TB_JOB_TASK.alarm_email
  39.   is '报警邮件';
  40. comment on column TB_JOB_TASK.executor_block_strategy
  41.   is '阻塞处理策略';
  42. comment on column TB_JOB_TASK.executor_timeout
  43.   is '任务执行超时时间，单位秒';
  44. comment on column TB_JOB_TASK.executor_fail_retry_count
  45.   is '失败重试次数';
  46. comment on column TB_JOB_TASK.glue_type
  47.   is 'GLUE类型';
  48. comment on column TB_JOB_TASK.glue_source
  49.   is 'GLUE源代码';
  50. comment on column TB_JOB_TASK.field_03
  51.   is '预留字段3';
  52. comment on column TB_JOB_TASK.status
  53.   is '状态(已停用)';
  54. comment on column TB_JOB_TASK.first_flag
  55.   is '是否起始任务：0-否，1-是';

tb_job_info

用于存储调度任务执行任务。日终任务执行时，根据tb_job_task中信息生成信息到tb_job_info中。调度中心每隔1秒查询tb_job_info 状态为1的任务进行触发。

  1. -- Create table
  2. create table TB_JOB_INFO
  3. (
  4.   id                        VARCHAR2(32) not null,
  5.   job_group                 NUMBER(11) not null,
  6.   job_cron                  VARCHAR2(128) not null,
  7.   job_desc                  VARCHAR2(255) not null,
  8.   add_time                  DATE,
  9.   update_time               DATE,
  10.   author                    VARCHAR2(64),
  11.   alarm_email               VARCHAR2(255),
  12.   executor_route_strategy   VARCHAR2(50),
  13.   executor_handler          VARCHAR2(255),
  14.   executor_param            VARCHAR2(2048),
  15.   executor_block_strategy   VARCHAR2(50),
  16.   executor_timeout          NUMBER(11) default 0 not null,
  17.   executor_fail_retry_count NUMBER(11) default 0 not null,
  18.   glue_type                 VARCHAR2(50) not null,
  19.   glue_source               CLOB,
  20.   glue_remark               VARCHAR2(128),
  21.   glue_updatetime           DATE,
  22.   child_jobid               VARCHAR2(255),
  23.   trigger_status            NUMBER(4) default 0 not null,
  24.   trigger_last_time         NUMBER(20) default 0 not null,
  25.   trigger_next_time         NUMBER(20) default 0 not null,
  26.   job_code                  VARCHAR2(100),
  27.   uuid                      VARCHAR2(32),
  28.   step_id                   VARCHAR2(32),
  29.   legal_org_code            VARCHAR2(32),
  30.   batch_date                VARCHAR2(8),
  31.   dependency_id             VARCHAR2(255),
  32.   parallel_type             VARCHAR2(8),
  33.   task_id                   VARCHAR2(32),
  34.   field_01                  VARCHAR2(32),
  35.   field_02                  VARCHAR2(32),
  36.   field_03                  VARCHAR2(32),
  37.   status                    NUMBER(4) default 0,
  38.   start_date                DATE,
  39.   end_time                  DATE
  40. );
  41. -- Add comments to the table
  42. comment on table TB_JOB_INFO
  43.   is '明细任务表';
  44. -- Add comments to the columns
  45. comment on column TB_JOB_INFO.id
  46.   is '任务ID';
  47. comment on column TB_JOB_INFO.job_group
  48.   is '执行器主键ID';
  49. comment on column TB_JOB_INFO.job_cron
  50.   is '任务执行CRON';
  51. comment on column TB_JOB_INFO.job_desc
  52.   is '任务描述';
  53. comment on column TB_JOB_INFO.add_time
  54.   is '新增日期';
  55. comment on column TB_JOB_INFO.update_time
  56.   is '更新日期';
  57. comment on column TB_JOB_INFO.author
  58.   is '作者';
  59. comment on column TB_JOB_INFO.alarm_email
  60.   is '报警邮件';
  61. comment on column TB_JOB_INFO.executor_route_strategy
  62.   is '执行器路由策略';
  63. comment on column TB_JOB_INFO.executor_handler
  64.   is '执行器任务handler';
  65. comment on column TB_JOB_INFO.executor_param
  66.   is '执行器任务参数';
  67. comment on column TB_JOB_INFO.executor_block_strategy
  68.   is '阻塞处理策略';
  69. comment on column TB_JOB_INFO.executor_timeout
  70.   is '任务执行超时时间，单位秒';
  71. comment on column TB_JOB_INFO.executor_fail_retry_count
  72.   is '失败重试次数';
  73. comment on column TB_JOB_INFO.glue_type
  74.   is 'GLUE类型';
  75. comment on column TB_JOB_INFO.glue_source
  76.   is 'GLUE源代码';
  77. comment on column TB_JOB_INFO.glue_remark
  78.   is 'GLUE备注';
  79. comment on column TB_JOB_INFO.glue_updatetime
  80.   is 'GLUE更新时间';
  81. comment on column TB_JOB_INFO.child_jobid
  82.   is '子任务ID，多个逗号分隔';
  83. comment on column TB_JOB_INFO.trigger_status
  84.   is '调度状态：0-停止，1-运行';
  85. comment on column TB_JOB_INFO.trigger_last_time
  86.   is '上次调度时间';
  87. comment on column TB_JOB_INFO.trigger_next_time
  88.   is '下次调度时间';
  89. comment on column TB_JOB_INFO.job_code
  90.   is '任务编号';
  91. comment on column TB_JOB_INFO.uuid
  92.   is 'UUID';
  93. comment on column TB_JOB_INFO.step_id
  94.   is '步骤ID';
  95. comment on column TB_JOB_INFO.legal_org_code
  96.   is '法人机构号';
  97. comment on column TB_JOB_INFO.batch_date
  98.   is '跑批日期';
  99. comment on column TB_JOB_INFO.dependency_id
  100.   is '依赖ID，多个逗号分隔';
  101. comment on column TB_JOB_INFO.parallel_type
  102.   is '并发类型：M-非并发，F-法人并发';
  103. comment on column TB_JOB_INFO.task_id
  104.   is '日终任务ID';
  105. comment on column TB_JOB_INFO.field_01
  106.   is '预留字段1';
  107. comment on column TB_JOB_INFO.field_02
  108.   is '预留字段2';
  109. comment on column TB_JOB_INFO.field_03
  110.   is '预留字段3';
  111. comment on column TB_JOB_INFO.status
  112.   is '状态：0-初始化，1-准备，2-待运行，3-运行中，4-成功，9-失败';
  113. comment on column TB_JOB_INFO.start_date
  114.   is '启动时间';
  115. comment on column TB_JOB_INFO.end_time
  116.   is '结束时间';

tb_job_log

  1. -- Create table
  2. create table TB_JOB_LOG
  3. (
  4.   id                        NUMBER(20) not null,
  5.   job_group                 NUMBER(11) not null,
  6.   job_id                    VARCHAR2(32) not null,
  7.   executor_address          VARCHAR2(255),
  8.   executor_handler          VARCHAR2(255),
  9.   executor_param            VARCHAR2(2048),
  10.   executor_sharding_param   VARCHAR2(20),
  11.   executor_fail_retry_count NUMBER(11) default 0 not null,
  12.   trigger_time              DATE,
  13.   trigger_code              NUMBER(11) not null,
  14.   trigger_msg               CLOB,
  15.   handle_time               DATE,
  16.   handle_code               NUMBER(11) not null,
  17.   handle_msg                CLOB,
  18.   alarm_status              NUMBER(4) default 0 not null,
  19.   legal_org_code            VARCHAR2(32),
  20.   bat_date                  VARCHAR2(8),
  21.   task_id                   VARCHAR2(32)
  22. );
  23. -- Add comments to the table
  24. comment on table TB_JOB_LOG
  25.   is '任务日志表';
  26. -- Add comments to the columns
  27. comment on column TB_JOB_LOG.job_group
  28.   is '执行器主键ID';
  29. comment on column TB_JOB_LOG.job_id
  30.   is '任务，主键ID';
  31. comment on column TB_JOB_LOG.executor_address
  32.   is '执行器地址，本次执行的地址';
  33. comment on column TB_JOB_LOG.executor_handler
  34.   is '执行器任务handler';
  35. comment on column TB_JOB_LOG.executor_param
  36.   is '执行器任务参数';
  37. comment on column TB_JOB_LOG.executor_sharding_param
  38.   is '执行器任务分片参数，格式如 1/2';
  39. comment on column TB_JOB_LOG.executor_fail_retry_count
  40.   is '失败重试次数';
  41. comment on column TB_JOB_LOG.trigger_time
  42.   is '调度-时间';
  43. comment on column TB_JOB_LOG.trigger_code
  44.   is '调度-结果';
  45. comment on column TB_JOB_LOG.trigger_msg
  46.   is '调度-日志';
  47. comment on column TB_JOB_LOG.handle_time
  48.   is '执行-时间';
  49. comment on column TB_JOB_LOG.handle_code
  50.   is '执行-状态';
  51. comment on column TB_JOB_LOG.handle_msg
  52.   is '执行-日志';
  53. comment on column TB_JOB_LOG.alarm_status
  54.   is '告警状态：0-默认、1-无需告警、2-告警成功、3-告警失败';
  55. comment on column TB_JOB_LOG.legal_org_code
  56.   is '法人机构号';
  57. comment on column TB_JOB_LOG.bat_date
  58.   is '批量日期';
  59. comment on column TB_JOB_LOG.task_id
  60.   is '任务ID';