ry_job.sql 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535
  1. SET NAMES utf8mb4;
  2. CREATE TABLE `sj_namespace`
  3. (
  4. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  5. `name` varchar(64) NOT NULL COMMENT '名称',
  6. `unique_id` varchar(64) NOT NULL COMMENT '唯一id',
  7. `description` varchar(256) NOT NULL DEFAULT '' COMMENT '描述',
  8. `deleted` tinyint(4) NOT NULL DEFAULT 0 COMMENT '逻辑删除 1、删除',
  9. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  10. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  11. PRIMARY KEY (`id`),
  12. KEY `idx_name` (`name`),
  13. UNIQUE KEY `uk_unique_id` (`unique_id`)
  14. ) ENGINE = InnoDB
  15. DEFAULT CHARSET = utf8mb4 COMMENT ='命名空间';
  16. INSERT INTO `sj_namespace` VALUES (1, 'Development', 'dev', '', 0, now(), now());
  17. INSERT INTO `sj_namespace` VALUES (2, 'Production', 'prod', '', 0, now(), now());
  18. CREATE TABLE `sj_group_config`
  19. (
  20. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  21. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  22. `group_name` varchar(64) NOT NULL DEFAULT '' COMMENT '组名称',
  23. `description` varchar(256) NOT NULL DEFAULT '' COMMENT '组描述',
  24. `token` varchar(64) NOT NULL DEFAULT 'SJ_cKqBTPzCsWA3VyuCfFoccmuIEGXjr5KT' COMMENT 'token',
  25. `group_status` tinyint(4) NOT NULL DEFAULT 0 COMMENT '组状态 0、未启用 1、启用',
  26. `version` int(11) NOT NULL COMMENT '版本号',
  27. `group_partition` int(11) NOT NULL COMMENT '分区',
  28. `id_generator_mode` tinyint(4) NOT NULL DEFAULT 1 COMMENT '唯一id生成模式 默认号段模式',
  29. `init_scene` tinyint(4) NOT NULL DEFAULT 0 COMMENT '是否初始化场景 0:否 1:是',
  30. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  31. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  32. PRIMARY KEY (`id`),
  33. UNIQUE KEY `uk_namespace_id_group_name` (`namespace_id`, `group_name`)
  34. ) ENGINE = InnoDB
  35. AUTO_INCREMENT = 0
  36. DEFAULT CHARSET = utf8mb4 COMMENT ='组配置';
  37. INSERT INTO `sj_group_config` VALUES (1, 'dev', 'ruoyi_group', '', 'SJ_cKqBTPzCsWA3VyuCfFoccmuIEGXjr5KT', 1, 1, 0, 1, 1, now(), now());
  38. INSERT INTO `sj_group_config` VALUES (2, 'prod', 'ruoyi_group', '', 'SJ_cKqBTPzCsWA3VyuCfFoccmuIEGXjr5KT', 1, 1, 0, 1, 1, now(), now());
  39. CREATE TABLE `sj_notify_config`
  40. (
  41. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  42. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  43. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  44. `notify_name` varchar(64) NOT NULL DEFAULT '' COMMENT '通知名称',
  45. `system_task_type` tinyint(4) NOT NULL DEFAULT 3 COMMENT '任务类型 1. 重试任务 2. 重试回调 3、JOB任务 4、WORKFLOW任务',
  46. `notify_status` tinyint(4) NOT NULL DEFAULT 0 COMMENT '通知状态 0、未启用 1、启用',
  47. `recipient_ids` varchar(128) NOT NULL COMMENT '接收人id列表',
  48. `notify_threshold` int(11) NOT NULL DEFAULT 0 COMMENT '通知阈值',
  49. `notify_scene` tinyint(4) NOT NULL DEFAULT 0 COMMENT '通知场景',
  50. `rate_limiter_status` tinyint(4) NOT NULL DEFAULT 0 COMMENT '限流状态 0、未启用 1、启用',
  51. `rate_limiter_threshold` int(11) NOT NULL DEFAULT 0 COMMENT '每秒限流阈值',
  52. `description` varchar(256) NOT NULL DEFAULT '' COMMENT '描述',
  53. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  54. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  55. PRIMARY KEY (`id`),
  56. KEY `idx_namespace_id_group_name_scene_name` (`namespace_id`, `group_name`)
  57. ) ENGINE = InnoDB
  58. AUTO_INCREMENT = 0
  59. DEFAULT CHARSET = utf8mb4 COMMENT ='通知配置';
  60. CREATE TABLE `sj_notify_recipient`
  61. (
  62. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  63. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  64. `recipient_name` varchar(64) NOT NULL COMMENT '接收人名称',
  65. `notify_type` tinyint(4) NOT NULL DEFAULT 0 COMMENT '通知类型 1、钉钉 2、邮件 3、企业微信 4 飞书 5 webhook',
  66. `notify_attribute` varchar(512) NOT NULL COMMENT '配置属性',
  67. `description` varchar(256) NOT NULL DEFAULT '' COMMENT '描述',
  68. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  69. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  70. PRIMARY KEY (`id`),
  71. KEY `idx_namespace_id` (`namespace_id`)
  72. ) ENGINE = InnoDB
  73. AUTO_INCREMENT = 0
  74. DEFAULT CHARSET = utf8mb4 COMMENT ='告警通知接收人';
  75. CREATE TABLE `sj_retry_dead_letter`
  76. (
  77. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  78. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  79. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  80. `group_id` bigint(20) NOT NULL COMMENT '组Id',
  81. `scene_name` varchar(64) NOT NULL COMMENT '场景名称',
  82. `scene_id` bigint(20) NOT NULL COMMENT '场景ID',
  83. `idempotent_id` varchar(64) NOT NULL COMMENT '幂等id',
  84. `biz_no` varchar(64) NOT NULL DEFAULT '' COMMENT '业务编号',
  85. `executor_name` varchar(512) NOT NULL DEFAULT '' COMMENT '执行器名称',
  86. -- jackson 兼容历史数据 预计1.8.0默认改为fury
  87. `serializer_name` varchar(32) NOT NULL DEFAULT 'jackson' COMMENT '执行方法参数序列化器名称',
  88. `args_str` text NOT NULL COMMENT '执行方法参数',
  89. `ext_attrs` text NOT NULL COMMENT '扩展字段',
  90. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  91. PRIMARY KEY (`id`),
  92. KEY `idx_namespace_id_group_name_scene_name` (`namespace_id`, `group_name`, `scene_name`),
  93. KEY `idx_idempotent_id` (`idempotent_id`),
  94. KEY `idx_biz_no` (`biz_no`),
  95. KEY `idx_create_dt` (`create_dt`)
  96. ) ENGINE = InnoDB
  97. AUTO_INCREMENT = 0
  98. DEFAULT CHARSET = utf8mb4 COMMENT ='死信队列表';
  99. CREATE TABLE `sj_retry`
  100. (
  101. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  102. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  103. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  104. `group_id` bigint(20) NOT NULL COMMENT '组Id',
  105. `scene_name` varchar(64) NOT NULL COMMENT '场景名称',
  106. `scene_id` bigint(20) NOT NULL COMMENT '场景ID',
  107. `idempotent_id` varchar(64) NOT NULL COMMENT '幂等id',
  108. `biz_no` varchar(64) NOT NULL DEFAULT '' COMMENT '业务编号',
  109. `executor_name` varchar(512) NOT NULL DEFAULT '' COMMENT '执行器名称',
  110. `args_str` text NOT NULL COMMENT '执行方法参数',
  111. `ext_attrs` text NOT NULL COMMENT '扩展字段',
  112. -- jackson 兼容历史数据 预计1.8.0默认改为fury
  113. `serializer_name` varchar(32) NOT NULL DEFAULT 'jackson' COMMENT '执行方法参数序列化器名称',
  114. `next_trigger_at` bigint(13) NOT NULL COMMENT '下次触发时间',
  115. `retry_count` int(11) NOT NULL DEFAULT 0 COMMENT '重试次数',
  116. `retry_status` tinyint(4) NOT NULL DEFAULT 0 COMMENT '重试状态 0、重试中 1、成功 2、最大重试次数',
  117. `task_type` tinyint(4) NOT NULL DEFAULT 1 COMMENT '任务类型 1、重试数据 2、回调数据',
  118. `bucket_index` int(11) NOT NULL DEFAULT 0 COMMENT 'bucket',
  119. `parent_id` bigint(20) NOT NULL DEFAULT 0 COMMENT '父节点id',
  120. `deleted` bigint(20) NOT NULL DEFAULT 0 COMMENT '逻辑删除',
  121. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  122. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  123. PRIMARY KEY (`id`),
  124. KEY `idx_biz_no` (`biz_no`),
  125. KEY `idx_idempotent_id` (`idempotent_id`),
  126. KEY `idx_retry_status_bucket_index` (`retry_status`, `bucket_index`),
  127. KEY `idx_parent_id` (`parent_id`),
  128. KEY `idx_create_dt` (`create_dt`),
  129. UNIQUE KEY `uk_scene_tasktype_idempotentid_deleted` (`scene_id`, `task_type`, `idempotent_id`, `deleted`)
  130. ) ENGINE = InnoDB
  131. AUTO_INCREMENT = 0
  132. DEFAULT CHARSET = utf8mb4 COMMENT ='重试信息表';
  133. CREATE TABLE `sj_retry_task`
  134. (
  135. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  136. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  137. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  138. `scene_name` varchar(64) NOT NULL COMMENT '场景名称',
  139. `retry_id` bigint(20) NOT NULL COMMENT '重试信息Id',
  140. `ext_attrs` text NOT NULL COMMENT '扩展字段',
  141. `task_status` tinyint(4) NOT NULL DEFAULT 1 COMMENT '重试状态',
  142. `task_type` tinyint(4) NOT NULL DEFAULT 1 COMMENT '任务类型 1、重试数据 2、回调数据',
  143. `operation_reason` tinyint(4) NOT NULL DEFAULT 0 COMMENT '操作原因',
  144. `client_info` varchar(128) DEFAULT NULL COMMENT '客户端地址 clientId#ip:port',
  145. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  146. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  147. PRIMARY KEY (`id`),
  148. KEY `idx_group_name_scene_name` (`namespace_id`, `group_name`, `scene_name`),
  149. KEY `task_status` (`task_status`),
  150. KEY `idx_create_dt` (`create_dt`),
  151. KEY `idx_retry_id` (`retry_id`)
  152. ) ENGINE = InnoDB
  153. AUTO_INCREMENT = 0
  154. DEFAULT CHARSET = utf8mb4 COMMENT ='重试任务表';
  155. CREATE TABLE `sj_retry_task_log_message`
  156. (
  157. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  158. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  159. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  160. `retry_id` bigint(20) NOT NULL COMMENT '重试信息Id',
  161. `retry_task_id` bigint(20) NOT NULL COMMENT '重试任务Id',
  162. `message` longtext NOT NULL COMMENT '异常信息',
  163. `log_num` int(11) NOT NULL DEFAULT 1 COMMENT '日志数量',
  164. `real_time` bigint(13) NOT NULL DEFAULT 0 COMMENT '上报时间',
  165. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  166. PRIMARY KEY (`id`),
  167. KEY `idx_namespace_id_group_name_retry_task_id` (`namespace_id`, `group_name`, `retry_task_id`),
  168. KEY `idx_create_dt` (`create_dt`)
  169. ) ENGINE = InnoDB
  170. AUTO_INCREMENT = 0
  171. DEFAULT CHARSET = utf8mb4 COMMENT ='任务调度日志信息记录表';
  172. CREATE TABLE `sj_retry_scene_config`
  173. (
  174. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  175. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  176. `scene_name` varchar(64) NOT NULL COMMENT '场景名称',
  177. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  178. `scene_status` tinyint(4) NOT NULL DEFAULT 0 COMMENT '组状态 0、未启用 1、启用',
  179. `max_retry_count` int(11) NOT NULL DEFAULT 5 COMMENT '最大重试次数',
  180. `back_off` tinyint(4) NOT NULL DEFAULT 1 COMMENT '1、默认等级 2、固定间隔时间 3、CRON 表达式',
  181. `trigger_interval` varchar(16) NOT NULL DEFAULT '' COMMENT '间隔时长',
  182. `notify_ids` varchar(128) NOT NULL DEFAULT '' COMMENT '通知告警场景配置id列表',
  183. `deadline_request` bigint(20) unsigned NOT NULL DEFAULT 60000 COMMENT 'Deadline Request 调用链超时 单位毫秒',
  184. `executor_timeout` int(11) unsigned NOT NULL DEFAULT 5 COMMENT '任务执行超时时间,单位秒',
  185. `route_key` tinyint(4) NOT NULL DEFAULT 4 COMMENT '路由策略',
  186. `block_strategy` tinyint(4) NOT NULL DEFAULT 1 COMMENT '阻塞策略 1、丢弃 2、覆盖 3、并行',
  187. `cb_status` tinyint(4) NOT NULL DEFAULT 0 COMMENT '回调状态 0、不开启 1、开启',
  188. `cb_trigger_type` tinyint(4) NOT NULL DEFAULT 1 COMMENT '1、默认等级 2、固定间隔时间 3、CRON 表达式',
  189. `cb_max_count` int(11) NOT NULL DEFAULT 16 COMMENT '回调的最大执行次数',
  190. `cb_trigger_interval` varchar(16) NOT NULL DEFAULT '' COMMENT '回调的最大执行次数',
  191. `owner_id` bigint(20) NULL DEFAULT NULL COMMENT '负责人id',
  192. `labels` varchar(512) NULL DEFAULT '' COMMENT '标签',
  193. `description` varchar(256) NOT NULL DEFAULT '' COMMENT '描述',
  194. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  195. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  196. PRIMARY KEY (`id`),
  197. UNIQUE KEY `uk_namespace_id_group_name_scene_name` (`namespace_id`, `group_name`, `scene_name`)
  198. ) ENGINE = InnoDB
  199. AUTO_INCREMENT = 0
  200. DEFAULT CHARSET = utf8mb4 COMMENT ='场景配置';
  201. CREATE TABLE `sj_server_node`
  202. (
  203. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  204. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  205. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  206. `host_id` varchar(64) NOT NULL COMMENT '主机id',
  207. `host_ip` varchar(64) NOT NULL COMMENT '机器ip',
  208. `host_port` int(16) NOT NULL COMMENT '机器端口',
  209. `expire_at` datetime NOT NULL COMMENT '过期时间',
  210. `node_type` tinyint(4) NOT NULL COMMENT '节点类型 1、客户端 2、是服务端',
  211. `ext_attrs` varchar(256) NULL DEFAULT '' COMMENT '扩展字段',
  212. `labels` varchar(512) NULL DEFAULT '' COMMENT '标签',
  213. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  214. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  215. PRIMARY KEY (`id`),
  216. KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`),
  217. KEY `idx_expire_at_node_type` (`expire_at`, `node_type`),
  218. UNIQUE KEY `uk_host_id_host_ip` (`host_id`, `host_ip`)
  219. ) ENGINE = InnoDB
  220. AUTO_INCREMENT = 0
  221. DEFAULT CHARSET = utf8mb4 COMMENT ='服务器节点';
  222. CREATE TABLE `sj_distributed_lock`
  223. (
  224. `name` varchar(64) NOT NULL COMMENT '锁名称',
  225. `lock_until` timestamp(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3) COMMENT '锁定时长',
  226. `locked_at` timestamp(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT '锁定时间',
  227. `locked_by` varchar(255) NOT NULL COMMENT '锁定者',
  228. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  229. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
  230. PRIMARY KEY (`name`)
  231. ) ENGINE = InnoDB
  232. AUTO_INCREMENT = 0
  233. DEFAULT CHARSET = utf8mb4 COMMENT ='锁定表';
  234. CREATE TABLE `sj_system_user`
  235. (
  236. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  237. `username` varchar(64) NOT NULL COMMENT '账号',
  238. `password` varchar(128) NOT NULL COMMENT '密码',
  239. `role` tinyint(4) NOT NULL DEFAULT 0 COMMENT '角色:1-普通用户、2-管理员',
  240. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  241. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  242. PRIMARY KEY (`id`),
  243. UNIQUE KEY `uk_username` (`username`) USING BTREE
  244. ) ENGINE = InnoDB
  245. DEFAULT CHARSET = utf8mb4 COMMENT ='系统用户表';
  246. -- pwd: admin
  247. INSERT INTO `sj_system_user` (username, password, role)
  248. VALUES ('admin', '465c194afb65670f38322df087f0a9bb225cc257e43eb4ac5a0c98ef5b3173ac', 2);
  249. CREATE TABLE `sj_system_user_permission`
  250. (
  251. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  252. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  253. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  254. `system_user_id` bigint(20) NOT NULL COMMENT '系统用户id',
  255. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  256. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  257. PRIMARY KEY (`id`),
  258. UNIQUE KEY `uk_namespace_id_group_name_system_user_id` (`namespace_id`, `group_name`, `system_user_id`)
  259. ) ENGINE = InnoDB
  260. DEFAULT CHARSET = utf8mb4 COMMENT ='系统用户权限表';
  261. -- 分布式调度DDL
  262. CREATE TABLE `sj_job`
  263. (
  264. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  265. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  266. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  267. `job_name` varchar(64) NOT NULL COMMENT '名称',
  268. `args_str` text DEFAULT NULL COMMENT '执行方法参数',
  269. `args_type` tinyint(4) NOT NULL DEFAULT 1 COMMENT '参数类型 ',
  270. `next_trigger_at` bigint(13) NOT NULL COMMENT '下次触发时间',
  271. `job_status` tinyint(4) NOT NULL DEFAULT 1 COMMENT '任务状态 0、关闭、1、开启',
  272. `task_type` tinyint(4) NOT NULL DEFAULT 1 COMMENT '任务类型 1、集群 2、广播 3、切片',
  273. `route_key` tinyint(4) NOT NULL DEFAULT 4 COMMENT '路由策略',
  274. `executor_type` tinyint(4) NOT NULL DEFAULT 1 COMMENT '执行器类型',
  275. `executor_info` varchar(255) DEFAULT NULL COMMENT '执行器名称',
  276. `trigger_type` tinyint(4) NOT NULL COMMENT '触发类型 1.CRON 表达式 2. 固定时间',
  277. `trigger_interval` varchar(255) NOT NULL COMMENT '间隔时长',
  278. `block_strategy` tinyint(4) NOT NULL DEFAULT 1 COMMENT '阻塞策略 1、丢弃 2、覆盖 3、并行 4、恢复',
  279. `executor_timeout` int(11) NOT NULL DEFAULT 0 COMMENT '任务执行超时时间,单位秒',
  280. `max_retry_times` int(11) NOT NULL DEFAULT 0 COMMENT '最大重试次数',
  281. `parallel_num` int(11) NOT NULL DEFAULT 1 COMMENT '并行数',
  282. `retry_interval` int(11) NOT NULL DEFAULT 0 COMMENT '重试间隔(s)',
  283. `bucket_index` int(11) NOT NULL DEFAULT 0 COMMENT 'bucket',
  284. `resident` tinyint(4) NOT NULL DEFAULT 0 COMMENT '是否是常驻任务',
  285. `notify_ids` varchar(128) NOT NULL DEFAULT '' COMMENT '通知告警场景配置id列表',
  286. `owner_id` bigint(20) NULL DEFAULT NULL COMMENT '负责人id',
  287. `labels` varchar(512) NULL DEFAULT '' COMMENT '标签',
  288. `description` varchar(256) NOT NULL DEFAULT '' COMMENT '描述',
  289. `ext_attrs` varchar(256) NULL DEFAULT '' COMMENT '扩展字段',
  290. `deleted` tinyint(4) NOT NULL DEFAULT 0 COMMENT '逻辑删除 1、删除',
  291. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  292. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  293. PRIMARY KEY (`id`),
  294. KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`),
  295. KEY `idx_job_status_bucket_index` (`job_status`, `bucket_index`),
  296. KEY `idx_create_dt` (`create_dt`)
  297. ) ENGINE = InnoDB
  298. AUTO_INCREMENT = 0
  299. DEFAULT CHARSET = utf8mb4 COMMENT ='任务信息';
  300. INSERT INTO `sj_job` VALUES (1, 'dev', 'ruoyi_group', 'demo-job', null, 1, 1710344035622, 1, 1, 4, 1, 'testJobExecutor', 2, '60', 1, 60, 3, 1, 1, 116, 0, '', 1, '','', '', 0 , now(), now());
  301. CREATE TABLE `sj_job_log_message`
  302. (
  303. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  304. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  305. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  306. `job_id` bigint(20) NOT NULL COMMENT '任务信息id',
  307. `task_batch_id` bigint(20) NOT NULL COMMENT '任务批次id',
  308. `task_id` bigint(20) NOT NULL COMMENT '调度任务id',
  309. `message` longtext NOT NULL COMMENT '调度信息',
  310. `log_num` int(11) NOT NULL DEFAULT 1 COMMENT '日志数量',
  311. `real_time` bigint(13) NOT NULL DEFAULT 0 COMMENT '上报时间',
  312. `ext_attrs` varchar(256) NULL DEFAULT '' COMMENT '扩展字段',
  313. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  314. PRIMARY KEY (`id`),
  315. KEY `idx_task_batch_id_task_id` (`task_batch_id`, `task_id`),
  316. KEY `idx_create_dt` (`create_dt`),
  317. KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`)
  318. ) ENGINE = InnoDB
  319. AUTO_INCREMENT = 0
  320. DEFAULT CHARSET = utf8mb4 COMMENT ='调度日志';
  321. CREATE TABLE `sj_job_task`
  322. (
  323. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  324. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  325. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  326. `job_id` bigint(20) NOT NULL COMMENT '任务信息id',
  327. `task_batch_id` bigint(20) NOT NULL COMMENT '调度任务id',
  328. `parent_id` bigint(20) NOT NULL DEFAULT 0 COMMENT '父执行器id',
  329. `task_status` tinyint NOT NULL DEFAULT 0 COMMENT '执行的状态 0、失败 1、成功',
  330. `retry_count` int(11) NOT NULL DEFAULT 0 COMMENT '重试次数',
  331. `mr_stage` tinyint DEFAULT NULL COMMENT '动态分片所处阶段 1:map 2:reduce 3:mergeReduce',
  332. `leaf` tinyint NOT NULL DEFAULT '1' COMMENT '叶子节点',
  333. `task_name` varchar(255) NOT NULL DEFAULT '' COMMENT '任务名称',
  334. `client_info` varchar(128) DEFAULT NULL COMMENT '客户端地址 clientId#ip:port',
  335. `wf_context` text DEFAULT NULL COMMENT '工作流全局上下文',
  336. `result_message` text NOT NULL COMMENT '执行结果',
  337. `args_str` text DEFAULT NULL COMMENT '执行方法参数',
  338. `args_type` tinyint NOT NULL DEFAULT 1 COMMENT '参数类型 ',
  339. `ext_attrs` varchar(256) NULL DEFAULT '' COMMENT '扩展字段',
  340. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  341. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  342. PRIMARY KEY (`id`),
  343. KEY `idx_task_batch_id_task_status` (`task_batch_id`, `task_status`),
  344. KEY `idx_create_dt` (`create_dt`),
  345. KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`)
  346. ) ENGINE = InnoDB
  347. AUTO_INCREMENT = 0
  348. DEFAULT CHARSET = utf8mb4 COMMENT ='任务实例';
  349. CREATE TABLE `sj_job_task_batch`
  350. (
  351. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  352. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  353. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  354. `job_id` bigint(20) NOT NULL COMMENT '任务id',
  355. `workflow_node_id` bigint(20) NOT NULL DEFAULT 0 COMMENT '工作流节点id',
  356. `parent_workflow_node_id` bigint(20) NOT NULL DEFAULT 0 COMMENT '工作流任务父批次id',
  357. `workflow_task_batch_id` bigint(20) NOT NULL DEFAULT 0 COMMENT '工作流任务批次id',
  358. `task_batch_status` tinyint(4) NOT NULL DEFAULT 0 COMMENT '任务批次状态 0、失败 1、成功',
  359. `operation_reason` tinyint(4) NOT NULL DEFAULT 0 COMMENT '操作原因',
  360. `execution_at` bigint(13) NOT NULL DEFAULT 0 COMMENT '任务执行时间',
  361. `system_task_type` tinyint(4) NOT NULL DEFAULT 3 COMMENT '任务类型 3、JOB任务 4、WORKFLOW任务',
  362. `parent_id` varchar(64) NOT NULL DEFAULT '' COMMENT '父节点',
  363. `ext_attrs` varchar(256) NULL DEFAULT '' COMMENT '扩展字段',
  364. `deleted` tinyint(4) NOT NULL DEFAULT 0 COMMENT '逻辑删除 1、删除',
  365. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  366. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  367. PRIMARY KEY (`id`),
  368. KEY `idx_job_id_task_batch_status` (`job_id`, `task_batch_status`),
  369. KEY `idx_create_dt` (`create_dt`),
  370. KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`),
  371. KEY `idx_workflow_task_batch_id_workflow_node_id` (`workflow_task_batch_id`, `workflow_node_id`)
  372. ) ENGINE = InnoDB
  373. AUTO_INCREMENT = 0
  374. DEFAULT CHARSET = utf8mb4 COMMENT ='任务批次';
  375. CREATE TABLE `sj_job_summary`
  376. (
  377. `id` bigint unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  378. `namespace_id` VARCHAR(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  379. `group_name` VARCHAR(64) NOT NULL DEFAULT '' COMMENT '组名称',
  380. `business_id` bigint NOT NULL COMMENT '业务id (job_id或workflow_id)',
  381. `system_task_type` tinyint(4) NOT NULL DEFAULT 3 COMMENT '任务类型 3、JOB任务 4、WORKFLOW任务',
  382. `trigger_at` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '统计时间',
  383. `success_num` int NOT NULL DEFAULT 0 COMMENT '执行成功-日志数量',
  384. `fail_num` int NOT NULL DEFAULT 0 COMMENT '执行失败-日志数量',
  385. `fail_reason` varchar(512) NOT NULL DEFAULT '' COMMENT '失败原因',
  386. `stop_num` int NOT NULL DEFAULT 0 COMMENT '执行失败-日志数量',
  387. `stop_reason` varchar(512) NOT NULL DEFAULT '' COMMENT '失败原因',
  388. `cancel_num` int NOT NULL DEFAULT 0 COMMENT '执行失败-日志数量',
  389. `cancel_reason` varchar(512) NOT NULL DEFAULT '' COMMENT '失败原因',
  390. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  391. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  392. PRIMARY KEY (`id`),
  393. KEY `idx_namespace_id_group_name_business_id` (`namespace_id`, `group_name`, business_id),
  394. UNIQUE KEY `uk_trigger_at_system_task_type_business_id` (`trigger_at`, `system_task_type`, `business_id`) USING BTREE
  395. ) ENGINE = InnoDB
  396. AUTO_INCREMENT = 1
  397. DEFAULT CHARSET = utf8mb4 COMMENT ='DashBoard_Job';
  398. CREATE TABLE `sj_retry_summary`
  399. (
  400. `id` bigint unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  401. `namespace_id` VARCHAR(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  402. `group_name` VARCHAR(64) NOT NULL DEFAULT '' COMMENT '组名称',
  403. `scene_name` VARCHAR(50) NOT NULL DEFAULT '' COMMENT '场景名称',
  404. `trigger_at` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '统计时间',
  405. `running_num` int NOT NULL DEFAULT 0 COMMENT '重试中-日志数量',
  406. `finish_num` int NOT NULL DEFAULT 0 COMMENT '重试完成-日志数量',
  407. `max_count_num` int NOT NULL DEFAULT 0 COMMENT '重试到达最大次数-日志数量',
  408. `suspend_num` int NOT NULL DEFAULT 0 COMMENT '暂停重试-日志数量',
  409. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  410. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  411. PRIMARY KEY (`id`),
  412. KEY `idx_trigger_at` (`trigger_at`),
  413. UNIQUE KEY `uk_scene_name_trigger_at` (`namespace_id`, `group_name`, `scene_name`, `trigger_at`) USING BTREE
  414. ) ENGINE = InnoDB
  415. AUTO_INCREMENT = 1
  416. DEFAULT CHARSET = utf8mb4 COMMENT ='DashBoard_Retry';
  417. CREATE TABLE `sj_workflow`
  418. (
  419. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  420. `workflow_name` varchar(64) NOT NULL COMMENT '工作流名称',
  421. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  422. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  423. `workflow_status` tinyint(4) NOT NULL DEFAULT 1 COMMENT '工作流状态 0、关闭、1、开启',
  424. `trigger_type` tinyint(4) NOT NULL COMMENT '触发类型 1.CRON 表达式 2. 固定时间',
  425. `trigger_interval` varchar(255) NOT NULL COMMENT '间隔时长',
  426. `next_trigger_at` bigint NOT NULL COMMENT '下次触发时间',
  427. `block_strategy` tinyint(4) NOT NULL DEFAULT 1 COMMENT '阻塞策略 1、丢弃 2、覆盖 3、并行',
  428. `executor_timeout` int(11) NOT NULL DEFAULT 0 COMMENT '任务执行超时时间,单位秒',
  429. `description` varchar(256) NOT NULL DEFAULT '' COMMENT '描述',
  430. `flow_info` text DEFAULT NULL COMMENT '流程信息',
  431. `wf_context` text DEFAULT NULL COMMENT '上下文',
  432. `notify_ids` varchar(128) NOT NULL DEFAULT '' COMMENT '通知告警场景配置id列表',
  433. `bucket_index` int(11) NOT NULL DEFAULT 0 COMMENT 'bucket',
  434. `version` int(11) NOT NULL COMMENT '版本号',
  435. `owner_id` bigint(20) NULL DEFAULT NULL COMMENT '负责人id',
  436. `ext_attrs` varchar(256) NULL DEFAULT '' COMMENT '扩展字段',
  437. `deleted` tinyint(4) NOT NULL DEFAULT 0 COMMENT '逻辑删除 1、删除',
  438. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  439. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  440. PRIMARY KEY (`id`),
  441. KEY `idx_create_dt` (`create_dt`),
  442. KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`)
  443. ) ENGINE = InnoDB
  444. AUTO_INCREMENT = 0
  445. DEFAULT CHARSET = utf8mb4 COMMENT ='工作流';
  446. CREATE TABLE `sj_workflow_node`
  447. (
  448. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  449. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  450. `node_name` varchar(64) NOT NULL COMMENT '节点名称',
  451. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  452. `job_id` bigint(20) NOT NULL COMMENT '任务信息id',
  453. `workflow_id` bigint(20) NOT NULL COMMENT '工作流ID',
  454. `node_type` tinyint(4) NOT NULL DEFAULT 1 COMMENT '1、任务节点 2、条件节点',
  455. `expression_type` tinyint(4) NOT NULL DEFAULT 0 COMMENT '1、SpEl、2、Aviator 3、QL',
  456. `fail_strategy` tinyint(4) NOT NULL DEFAULT 1 COMMENT '失败策略 1、跳过 2、阻塞',
  457. `workflow_node_status` tinyint(4) NOT NULL DEFAULT 1 COMMENT '工作流节点状态 0、关闭、1、开启',
  458. `priority_level` int(11) NOT NULL DEFAULT 1 COMMENT '优先级',
  459. `node_info` text DEFAULT NULL COMMENT '节点信息 ',
  460. `version` int(11) NOT NULL COMMENT '版本号',
  461. `ext_attrs` varchar(256) NULL DEFAULT '' COMMENT '扩展字段',
  462. `deleted` tinyint(4) NOT NULL DEFAULT 0 COMMENT '逻辑删除 1、删除',
  463. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  464. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  465. PRIMARY KEY (`id`),
  466. KEY `idx_create_dt` (`create_dt`),
  467. KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`)
  468. ) ENGINE = InnoDB
  469. AUTO_INCREMENT = 0
  470. DEFAULT CHARSET = utf8mb4 COMMENT ='工作流节点';
  471. CREATE TABLE `sj_workflow_task_batch`
  472. (
  473. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  474. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  475. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  476. `workflow_id` bigint(20) NOT NULL COMMENT '工作流任务id',
  477. `task_batch_status` tinyint(4) NOT NULL DEFAULT 0 COMMENT '任务批次状态 0、失败 1、成功',
  478. `operation_reason` tinyint(4) NOT NULL DEFAULT 0 COMMENT '操作原因',
  479. `flow_info` text DEFAULT NULL COMMENT '流程信息',
  480. `wf_context` text DEFAULT NULL COMMENT '全局上下文',
  481. `execution_at` bigint(13) NOT NULL DEFAULT 0 COMMENT '任务执行时间',
  482. `ext_attrs` varchar(256) NULL DEFAULT '' COMMENT '扩展字段',
  483. `version` int(11) NOT NULL DEFAULT 1 COMMENT '版本号',
  484. `deleted` tinyint(4) NOT NULL DEFAULT 0 COMMENT '逻辑删除 1、删除',
  485. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  486. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  487. PRIMARY KEY (`id`),
  488. KEY `idx_job_id_task_batch_status` (`workflow_id`, `task_batch_status`),
  489. KEY `idx_create_dt` (`create_dt`),
  490. KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`)
  491. ) ENGINE = InnoDB
  492. AUTO_INCREMENT = 0
  493. DEFAULT CHARSET = utf8mb4 COMMENT ='工作流批次';
  494. CREATE TABLE `sj_job_executor`
  495. (
  496. `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  497. `namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
  498. `group_name` varchar(64) NOT NULL COMMENT '组名称',
  499. `executor_info` varchar(256) NOT NULL COMMENT '任务执行器名称',
  500. `executor_type` varchar(3) NOT NULL COMMENT '1:java 2:python 3:go',
  501. `create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  502. `update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
  503. PRIMARY KEY (`id`),
  504. KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`),
  505. KEY `idx_create_dt` (`create_dt`)
  506. ) ENGINE = InnoDB
  507. AUTO_INCREMENT = 0
  508. DEFAULT CHARSET = utf8mb4 COMMENT ='任务执行器信息';