easy_retry.sql 35 KB

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