easy_retry.sql 34 KB

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