|
|
|
|
@ -1,233 +1,528 @@
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
-- Table structure for pj_app_info
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
DROP TABLE IF EXISTS `pj_app_info`;
|
|
|
|
|
CREATE TABLE `pj_app_info` (
|
|
|
|
|
`id` bigint(0) NOT NULL AUTO_INCREMENT,
|
|
|
|
|
`app_name` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`current_server` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_create` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_modified` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`password` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
PRIMARY KEY (`id`) USING BTREE,
|
|
|
|
|
UNIQUE INDEX `uidx01_app_info`(`app_name`) USING BTREE
|
|
|
|
|
) ENGINE = InnoDB AUTO_INCREMENT = 2 ROW_FORMAT = Dynamic;
|
|
|
|
|
SET NAMES utf8mb4;
|
|
|
|
|
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
-- Records of pj_app_info
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
INSERT INTO `pj_app_info` VALUES (1, 'ruoyi-worker', '127.0.0.1:10010', '2023-06-13 16:32:59.263000', '2023-07-04 17:25:49.798000', '123456');
|
|
|
|
|
CREATE TABLE `er_namespace`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`name` varchar(64) NOT NULL COMMENT '名称',
|
|
|
|
|
`unique_id` varchar(64) NOT NULL COMMENT '唯一id',
|
|
|
|
|
`description` varchar(256) NOT NULL DEFAULT '' COMMENT '描述',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
`deleted` tinyint(4) NOT NULL DEFAULT '0' COMMENT '逻辑删除 1、删除',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_name` (`name`),
|
|
|
|
|
UNIQUE KEY `uk_unique_id` (`unique_id`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='命名空间';
|
|
|
|
|
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
-- Table structure for pj_container_info
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
DROP TABLE IF EXISTS `pj_container_info`;
|
|
|
|
|
CREATE TABLE `pj_container_info` (
|
|
|
|
|
`id` bigint(0) NOT NULL AUTO_INCREMENT,
|
|
|
|
|
`app_id` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`container_name` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_create` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_modified` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`last_deploy_time` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`source_info` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`source_type` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`status` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`version` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
PRIMARY KEY (`id`) USING BTREE,
|
|
|
|
|
INDEX `idx01_container_info`(`app_id`) USING BTREE
|
|
|
|
|
) ENGINE = InnoDB AUTO_INCREMENT = 1 ROW_FORMAT = Dynamic;
|
|
|
|
|
INSERT INTO `er_namespace` VALUES (1, 'Development', 'dev', '', now(), now(), 0);
|
|
|
|
|
INSERT INTO `er_namespace` VALUES (2, 'Production', 'prod', '', now(), now(), 0);
|
|
|
|
|
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
-- Table structure for pj_instance_info
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
DROP TABLE IF EXISTS `pj_instance_info`;
|
|
|
|
|
CREATE TABLE `pj_instance_info` (
|
|
|
|
|
`id` bigint(0) NOT NULL AUTO_INCREMENT,
|
|
|
|
|
`actual_trigger_time` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`app_id` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`expected_trigger_time` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`finished_time` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_create` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_modified` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`instance_id` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`instance_params` longtext NULL,
|
|
|
|
|
`job_id` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`job_params` longtext NULL,
|
|
|
|
|
`last_report_time` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`result` longtext NULL,
|
|
|
|
|
`running_times` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`status` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`task_tracker_address` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`type` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`wf_instance_id` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
PRIMARY KEY (`id`) USING BTREE,
|
|
|
|
|
INDEX `idx01_instance_info`(`job_id`, `status`) USING BTREE,
|
|
|
|
|
INDEX `idx02_instance_info`(`app_id`, `status`) USING BTREE,
|
|
|
|
|
INDEX `idx03_instance_info`(`instance_id`, `status`) USING BTREE
|
|
|
|
|
) ENGINE = InnoDB AUTO_INCREMENT = 4 ROW_FORMAT = Dynamic;
|
|
|
|
|
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
-- Table structure for pj_job_info
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
DROP TABLE IF EXISTS `pj_job_info`;
|
|
|
|
|
CREATE TABLE `pj_job_info` (
|
|
|
|
|
`id` bigint(0) NOT NULL AUTO_INCREMENT,
|
|
|
|
|
`alarm_config` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`app_id` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`concurrency` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`designated_workers` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`dispatch_strategy` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`execute_type` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`extra` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_create` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_modified` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`instance_retry_num` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`instance_time_limit` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`job_description` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`job_name` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`job_params` longtext NULL,
|
|
|
|
|
`lifecycle` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`log_config` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`max_instance_num` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`max_worker_count` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`min_cpu_cores` double NOT NULL,
|
|
|
|
|
`min_disk_space` double NOT NULL,
|
|
|
|
|
`min_memory_space` double NOT NULL,
|
|
|
|
|
`next_trigger_time` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`notify_user_ids` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`processor_info` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`processor_type` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`status` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`tag` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`task_retry_num` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`time_expression` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`time_expression_type` int(0) NULL DEFAULT NULL,
|
|
|
|
|
PRIMARY KEY (`id`) USING BTREE,
|
|
|
|
|
INDEX `idx01_job_info`(`app_id`, `status`, `time_expression_type`, `next_trigger_time`) USING BTREE
|
|
|
|
|
) ENGINE = InnoDB AUTO_INCREMENT = 5 ROW_FORMAT = Dynamic;
|
|
|
|
|
CREATE TABLE `er_group_config`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`group_name` varchar(64) NOT NULL DEFAULT '' COMMENT '组名称',
|
|
|
|
|
`description` varchar(256) NOT NULL DEFAULT '' COMMENT '组描述',
|
|
|
|
|
`token` varchar(64) NOT NULL DEFAULT 'ER_cKqBTPzCsWA3VyuCfFoccmuIEGXjr5KT' COMMENT 'token',
|
|
|
|
|
`group_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '组状态 0、未启用 1、启用',
|
|
|
|
|
`version` int(11) NOT NULL COMMENT '版本号',
|
|
|
|
|
`group_partition` int(11) NOT NULL COMMENT '分区',
|
|
|
|
|
`id_generator_mode` tinyint(4) NOT NULL DEFAULT '1' COMMENT '唯一id生成模式 默认号段模式',
|
|
|
|
|
`init_scene` tinyint(4) NOT NULL DEFAULT '0' COMMENT '是否初始化场景 0:否 1:是',
|
|
|
|
|
`bucket_index` int(11) NOT NULL DEFAULT '0' COMMENT 'bucket',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
UNIQUE KEY `uk_namespace_id_group_name` (`namespace_id`, `group_name`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='组配置'
|
|
|
|
|
;
|
|
|
|
|
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
-- Records of pj_job_info
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
INSERT INTO `pj_job_info` VALUES (1, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 2, 1, NULL, '2023-06-02 15:01:27.717000', '2023-07-04 17:22:12.374000', 1, 0, '', '单机处理器执行测试', NULL, '{}', '{\"type\":1}', 0, 0, 0, 0, 0, NULL, NULL, 'org.dromara.job.processors.StandaloneProcessorDemo', 1, 2, NULL, 1, '30000', 3);
|
|
|
|
|
INSERT INTO `pj_job_info` VALUES (2, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 1, 2, NULL, '2023-06-02 15:04:45.342000', '2023-07-04 17:22:12.816000', 0, 0, NULL, '广播处理器测试', NULL, '{}', '{\"type\":1}', 0, 0, 0, 0, 0, NULL, NULL, 'org.dromara.job.processors.BroadcastProcessorDemo', 1, 2, NULL, 1, '30000', 3);
|
|
|
|
|
INSERT INTO `pj_job_info` VALUES (3, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 1, 4, NULL, '2023-06-02 15:13:23.519000', '2023-06-02 16:03:22.421000', 0, 0, NULL, 'Map处理器测试', NULL, '{}', '{\"type\":1}', 0, 0, 0, 0, 0, NULL, NULL, 'org.dromara.job.processors.MapProcessorDemo', 1, 2, NULL, 1, '1000', 3);
|
|
|
|
|
INSERT INTO `pj_job_info` VALUES (4, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 1, 3, NULL, '2023-06-02 15:45:25.896000', '2023-06-02 16:03:23.125000', 0, 0, NULL, 'MapReduce处理器测试', NULL, '{}', '{\"type\":1}', 0, 0, 0, 0, 0, NULL, NULL, 'org.dromara.job.processors.MapReduceProcessorDemo', 1, 2, NULL, 1, '1000', 3);
|
|
|
|
|
INSERT INTO `er_group_config` VALUES (1, 'dev', 'ruoyi_group', '', 'ER_cKqBTPzCsWA3VyuCfFoccmuIEGXjr5KT', 1, 1, 0, 1, 1, 4, now(), now());
|
|
|
|
|
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
-- Table structure for pj_oms_lock
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
DROP TABLE IF EXISTS `pj_oms_lock`;
|
|
|
|
|
CREATE TABLE `pj_oms_lock` (
|
|
|
|
|
`id` bigint(0) NOT NULL AUTO_INCREMENT,
|
|
|
|
|
`gmt_create` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_modified` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`lock_name` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`max_lock_time` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`ownerip` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
PRIMARY KEY (`id`) USING BTREE,
|
|
|
|
|
UNIQUE INDEX `uidx01_oms_lock`(`lock_name`) USING BTREE
|
|
|
|
|
) ENGINE = InnoDB AUTO_INCREMENT = 6 ROW_FORMAT = Dynamic;
|
|
|
|
|
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
-- Table structure for pj_server_info
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
DROP TABLE IF EXISTS `pj_server_info`;
|
|
|
|
|
CREATE TABLE `pj_server_info` (
|
|
|
|
|
`id` bigint(0) NOT NULL AUTO_INCREMENT,
|
|
|
|
|
`gmt_create` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_modified` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`ip` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
PRIMARY KEY (`id`) USING BTREE,
|
|
|
|
|
UNIQUE INDEX `uidx01_server_info`(`ip`) USING BTREE,
|
|
|
|
|
INDEX `idx01_server_info`(`gmt_modified`) USING BTREE
|
|
|
|
|
) ENGINE = InnoDB AUTO_INCREMENT = 2 ROW_FORMAT = Dynamic;
|
|
|
|
|
CREATE TABLE `er_notify_config`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`scene_name` varchar(64) NOT NULL COMMENT '场景名称',
|
|
|
|
|
`notify_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '通知状态 0、未启用 1、启用',
|
|
|
|
|
`notify_type` tinyint(4) NOT NULL DEFAULT '0' COMMENT '通知类型 1、钉钉 2、邮件 3、企业微信',
|
|
|
|
|
`notify_attribute` varchar(512) NOT NULL COMMENT '配置属性',
|
|
|
|
|
`notify_threshold` int(11) NOT NULL DEFAULT '0' COMMENT '通知阈值',
|
|
|
|
|
`notify_scene` tinyint(4) NOT NULL DEFAULT '0' COMMENT '通知场景',
|
|
|
|
|
`rate_limiter_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '限流状态 0、未启用 1、启用',
|
|
|
|
|
`rate_limiter_threshold` int(11) NOT NULL DEFAULT '0' COMMENT '每秒限流阈值',
|
|
|
|
|
`description` varchar(256) NOT NULL DEFAULT '' COMMENT '描述',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_namespace_id_group_name_scene_name` (`namespace_id`, `group_name`, `scene_name`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='通知配置'
|
|
|
|
|
;
|
|
|
|
|
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
-- Table structure for pj_user_info
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
DROP TABLE IF EXISTS `pj_user_info`;
|
|
|
|
|
CREATE TABLE `pj_user_info` (
|
|
|
|
|
`id` bigint(0) NOT NULL AUTO_INCREMENT,
|
|
|
|
|
`email` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`extra` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_create` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_modified` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`password` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`phone` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`username` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`web_hook` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
PRIMARY KEY (`id`) USING BTREE,
|
|
|
|
|
INDEX `uidx01_user_info`(`username`) USING BTREE,
|
|
|
|
|
INDEX `uidx02_user_info`(`email`) USING BTREE
|
|
|
|
|
) ENGINE = InnoDB AUTO_INCREMENT = 1 ROW_FORMAT = Dynamic;
|
|
|
|
|
CREATE TABLE `er_retry_dead_letter_0`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`unique_id` varchar(64) NOT NULL COMMENT '同组下id唯一',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`scene_name` varchar(64) NOT NULL COMMENT '场景名称',
|
|
|
|
|
`idempotent_id` varchar(64) NOT NULL COMMENT '幂等id',
|
|
|
|
|
`biz_no` varchar(64) NOT NULL DEFAULT '' COMMENT '业务编号',
|
|
|
|
|
`executor_name` varchar(512) NOT NULL DEFAULT '' COMMENT '执行器名称',
|
|
|
|
|
`args_str` text NOT NULL COMMENT '执行方法参数',
|
|
|
|
|
`ext_attrs` text NOT NULL COMMENT '扩展字段',
|
|
|
|
|
`task_type` tinyint(4) NOT NULL DEFAULT '1' COMMENT '任务类型 1、重试数据 2、回调数据',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_namespace_id_group_name_scene_name` (`namespace_id`, `group_name`, `scene_name`),
|
|
|
|
|
KEY `idx_idempotent_id` (`idempotent_id`),
|
|
|
|
|
KEY `idx_biz_no` (`biz_no`),
|
|
|
|
|
KEY `idx_create_dt` (`create_dt`),
|
|
|
|
|
UNIQUE KEY `uk_namespace_id_group_name_unique_id` (`namespace_id`, `group_name`, `unique_id`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='死信队列表'
|
|
|
|
|
;
|
|
|
|
|
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
-- Table structure for pj_workflow_info
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
DROP TABLE IF EXISTS `pj_workflow_info`;
|
|
|
|
|
CREATE TABLE `pj_workflow_info` (
|
|
|
|
|
`id` bigint(0) NOT NULL AUTO_INCREMENT,
|
|
|
|
|
`app_id` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`extra` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_create` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_modified` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`lifecycle` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`max_wf_instance_num` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`next_trigger_time` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`notify_user_ids` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`pedag` longtext NULL,
|
|
|
|
|
`status` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`time_expression` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`time_expression_type` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`wf_description` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`wf_name` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
PRIMARY KEY (`id`) USING BTREE,
|
|
|
|
|
INDEX `idx01_workflow_info`(`app_id`, `status`, `time_expression_type`, `next_trigger_time`) USING BTREE
|
|
|
|
|
) ENGINE = InnoDB AUTO_INCREMENT = 1 ROW_FORMAT = Dynamic;
|
|
|
|
|
CREATE TABLE `er_retry_task_0`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`unique_id` varchar(64) NOT NULL COMMENT '同组下id唯一',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`scene_name` varchar(64) NOT NULL COMMENT '场景名称',
|
|
|
|
|
`idempotent_id` varchar(64) NOT NULL COMMENT '幂等id',
|
|
|
|
|
`biz_no` varchar(64) NOT NULL DEFAULT '' COMMENT '业务编号',
|
|
|
|
|
`executor_name` varchar(512) NOT NULL DEFAULT '' COMMENT '执行器名称',
|
|
|
|
|
`args_str` text NOT NULL COMMENT '执行方法参数',
|
|
|
|
|
`ext_attrs` text NOT NULL COMMENT '扩展字段',
|
|
|
|
|
`next_trigger_at` datetime NOT NULL COMMENT '下次触发时间',
|
|
|
|
|
`retry_count` int(11) NOT NULL DEFAULT '0' COMMENT '重试次数',
|
|
|
|
|
`retry_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '重试状态 0、重试中 1、成功 2、最大重试次数',
|
|
|
|
|
`task_type` tinyint(4) NOT NULL DEFAULT '1' COMMENT '任务类型 1、重试数据 2、回调数据',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_namespace_id_group_name_scene_name` (`namespace_id`, `group_name`, `scene_name`),
|
|
|
|
|
KEY `idx_namespace_id_group_name_task_type` (`namespace_id`, `group_name`, `task_type`),
|
|
|
|
|
KEY `idx_namespace_id_group_name_retry_status` (`namespace_id`, `group_name`, `retry_status`),
|
|
|
|
|
KEY `idx_idempotent_id` (`idempotent_id`),
|
|
|
|
|
KEY `idx_biz_no` (`biz_no`),
|
|
|
|
|
KEY `idx_create_dt` (`create_dt`),
|
|
|
|
|
UNIQUE KEY `uk_name_unique_id` (`namespace_id`, `group_name`, `unique_id`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='任务表'
|
|
|
|
|
;
|
|
|
|
|
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
-- Table structure for pj_workflow_instance_info
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
DROP TABLE IF EXISTS `pj_workflow_instance_info`;
|
|
|
|
|
CREATE TABLE `pj_workflow_instance_info` (
|
|
|
|
|
`id` bigint(0) NOT NULL AUTO_INCREMENT,
|
|
|
|
|
`actual_trigger_time` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`app_id` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`dag` longtext NULL,
|
|
|
|
|
`expected_trigger_time` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`finished_time` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_create` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`gmt_modified` datetime(6) NULL DEFAULT NULL,
|
|
|
|
|
`parent_wf_instance_id` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`result` longtext NULL,
|
|
|
|
|
`status` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`wf_context` longtext NULL,
|
|
|
|
|
`wf_init_params` longtext NULL,
|
|
|
|
|
`wf_instance_id` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`workflow_id` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
PRIMARY KEY (`id`) USING BTREE,
|
|
|
|
|
UNIQUE INDEX `uidx01_wf_instance`(`wf_instance_id`) USING BTREE,
|
|
|
|
|
INDEX `idx01_wf_instance`(`workflow_id`, `status`, `app_id`, `expected_trigger_time`) USING BTREE
|
|
|
|
|
) ENGINE = InnoDB AUTO_INCREMENT = 1 ROW_FORMAT = Dynamic;
|
|
|
|
|
CREATE TABLE `er_retry_task_log`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`unique_id` varchar(64) NOT NULL COMMENT '同组下id唯一',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`scene_name` varchar(64) NOT NULL COMMENT '场景名称',
|
|
|
|
|
`idempotent_id` varchar(64) NOT NULL COMMENT '幂等id',
|
|
|
|
|
`biz_no` varchar(64) NOT NULL DEFAULT '' COMMENT '业务编号',
|
|
|
|
|
`executor_name` varchar(512) NOT NULL DEFAULT '' COMMENT '执行器名称',
|
|
|
|
|
`args_str` text NOT NULL COMMENT '执行方法参数',
|
|
|
|
|
`ext_attrs` text NOT NULL COMMENT '扩展字段',
|
|
|
|
|
`retry_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '重试状态 0、重试中 1、成功 2、最大次数',
|
|
|
|
|
`task_type` tinyint(4) NOT NULL DEFAULT '1' COMMENT '任务类型 1、重试数据 2、回调数据',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_group_name_scene_name` (`namespace_id`, `group_name`, `scene_name`),
|
|
|
|
|
KEY `idx_retry_status` (`retry_status`),
|
|
|
|
|
KEY `idx_idempotent_id` (`idempotent_id`),
|
|
|
|
|
KEY `idx_unique_id` (`unique_id`),
|
|
|
|
|
KEY `idx_biz_no` (`biz_no`),
|
|
|
|
|
KEY `idx_create_dt` (`create_dt`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='任务日志基础信息表'
|
|
|
|
|
;
|
|
|
|
|
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
-- Table structure for pj_workflow_node_info
|
|
|
|
|
-- ----------------------------
|
|
|
|
|
DROP TABLE IF EXISTS `pj_workflow_node_info`;
|
|
|
|
|
CREATE TABLE `pj_workflow_node_info` (
|
|
|
|
|
`id` bigint(0) NOT NULL AUTO_INCREMENT,
|
|
|
|
|
`app_id` bigint(0) NOT NULL,
|
|
|
|
|
`enable` bit(1) NOT NULL,
|
|
|
|
|
`extra` longtext NULL,
|
|
|
|
|
`gmt_create` datetime(6) NULL,
|
|
|
|
|
`gmt_modified` datetime(6) NULL,
|
|
|
|
|
`job_id` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
`node_name` varchar(255) NULL DEFAULT NULL,
|
|
|
|
|
`node_params` longtext NULL,
|
|
|
|
|
`skip_when_failed` bit(1) NOT NULL,
|
|
|
|
|
`type` int(0) NULL DEFAULT NULL,
|
|
|
|
|
`workflow_id` bigint(0) NULL DEFAULT NULL,
|
|
|
|
|
PRIMARY KEY (`id`) USING BTREE,
|
|
|
|
|
INDEX `idx01_workflow_node_info`(`workflow_id`, `gmt_create`) USING BTREE
|
|
|
|
|
) ENGINE = InnoDB AUTO_INCREMENT = 1 ROW_FORMAT = Dynamic;
|
|
|
|
|
CREATE TABLE `er_retry_task_log_message`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`unique_id` varchar(64) NOT NULL COMMENT '同组下id唯一',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`message` longtext NOT NULL COMMENT '异常信息',
|
|
|
|
|
`log_num` int(11) NOT NULL DEFAULT 1 COMMENT '日志数量',
|
|
|
|
|
`real_time` bigint(13) NOT NULL DEFAULT 0 COMMENT '上报时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_namespace_id_group_name_scene_name` (`namespace_id`, `group_name`, `unique_id`),
|
|
|
|
|
KEY `idx_create_dt` (`create_dt`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='任务调度日志信息记录表'
|
|
|
|
|
;
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_scene_config`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`scene_name` varchar(64) NOT NULL COMMENT '场景名称',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`scene_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '组状态 0、未启用 1、启用',
|
|
|
|
|
`max_retry_count` int(11) NOT NULL DEFAULT '5' COMMENT '最大重试次数',
|
|
|
|
|
`back_off` tinyint(4) NOT NULL DEFAULT '1' COMMENT '1、默认等级 2、固定间隔时间 3、CRON 表达式',
|
|
|
|
|
`trigger_interval` varchar(16) NOT NULL DEFAULT '' COMMENT '间隔时长',
|
|
|
|
|
`deadline_request` bigint(20) unsigned NOT NULL DEFAULT '60000' COMMENT 'Deadline Request 调用链超时 单位毫秒',
|
|
|
|
|
`executor_timeout` int(11) unsigned NOT NULL DEFAULT '5' COMMENT '任务执行超时时间,单位秒',
|
|
|
|
|
`route_key` tinyint(4) NOT NULL DEFAULT '4' COMMENT '路由策略',
|
|
|
|
|
`description` varchar(256) NOT NULL DEFAULT '' COMMENT '描述',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
UNIQUE KEY `uk_namespace_id_group_name_scene_name` (`namespace_id`, `group_name`, `scene_name`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='场景配置'
|
|
|
|
|
;
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_server_node`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`host_id` varchar(64) NOT NULL COMMENT '主机id',
|
|
|
|
|
`host_ip` varchar(64) NOT NULL COMMENT '机器ip',
|
|
|
|
|
`context_path` varchar(256) NOT NULL DEFAULT '/' COMMENT '客户端上下文路径 server.servlet.context-path',
|
|
|
|
|
`host_port` int(16) NOT NULL COMMENT '机器端口',
|
|
|
|
|
`expire_at` datetime NOT NULL COMMENT '过期时间',
|
|
|
|
|
`node_type` tinyint(4) NOT NULL COMMENT '节点类型 1、客户端 2、是服务端',
|
|
|
|
|
`ext_attrs` varchar(256) NULL default '' COMMENT '扩展字段',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`),
|
|
|
|
|
KEY `idx_expire_at_node_type` (`expire_at`, `node_type`),
|
|
|
|
|
UNIQUE KEY `uk_host_id_host_ip` (`host_id`, `host_ip`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='服务器节点'
|
|
|
|
|
;
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_distributed_lock`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`name` varchar(64) NOT NULL COMMENT '锁名称',
|
|
|
|
|
`lock_until` timestamp(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3) COMMENT '锁定时长',
|
|
|
|
|
`locked_at` timestamp(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT '锁定时间',
|
|
|
|
|
`locked_by` varchar(255) NOT NULL COMMENT '锁定者',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
UNIQUE KEY `uk_name` (`name`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='锁定表'
|
|
|
|
|
;
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_system_user`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`username` varchar(64) NOT NULL COMMENT '账号',
|
|
|
|
|
`password` varchar(128) NOT NULL COMMENT '密码',
|
|
|
|
|
`role` tinyint(4) NOT NULL DEFAULT '0' COMMENT '角色:1-普通用户、2-管理员',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
UNIQUE KEY `uk_username` (`username`) USING BTREE
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='系统用户表';
|
|
|
|
|
|
|
|
|
|
-- pwd: admin
|
|
|
|
|
INSERT INTO `er_system_user` VALUES (1, 'admin', '465c194afb65670f38322df087f0a9bb225cc257e43eb4ac5a0c98ef5b3173ac', 2, now(), now());
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_system_user_permission`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`system_user_id` bigint(20) NOT NULL COMMENT '系统用户id',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
UNIQUE KEY `uk_namespace_id_group_name_system_user_id` (`namespace_id`, `group_name`, `system_user_id`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='系统用户权限表';
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_sequence_alloc`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`group_name` varchar(64) NOT NULL DEFAULT '' COMMENT '组名称',
|
|
|
|
|
`max_id` bigint(20) NOT NULL DEFAULT '1' COMMENT '最大id',
|
|
|
|
|
`step` int(11) NOT NULL DEFAULT '100' COMMENT '步长',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
UNIQUE KEY `uk_namespace_id_group_name` (`namespace_id`, `group_name`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='号段模式序号ID分配表';
|
|
|
|
|
|
|
|
|
|
-- 分布式调度DDL
|
|
|
|
|
CREATE TABLE `er_job`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`job_name` varchar(64) NOT NULL COMMENT '名称',
|
|
|
|
|
`args_str` text DEFAULT NULL COMMENT '执行方法参数',
|
|
|
|
|
`args_type` tinyint(4) NOT NULL DEFAULT '1' COMMENT '参数类型 ',
|
|
|
|
|
`next_trigger_at` bigint(13) NOT NULL COMMENT '下次触发时间',
|
|
|
|
|
`job_status` tinyint(4) NOT NULL DEFAULT '1' COMMENT '任务状态 0、关闭、1、开启',
|
|
|
|
|
`task_type` tinyint(4) NOT NULL DEFAULT '1' COMMENT '任务类型 1、集群 2、广播 3、切片',
|
|
|
|
|
`route_key` tinyint(4) NOT NULL DEFAULT '4' COMMENT '路由策略',
|
|
|
|
|
`executor_type` tinyint(4) NOT NULL DEFAULT '1' COMMENT '执行器类型',
|
|
|
|
|
`executor_info` varchar(255) DEFAULT NULL COMMENT '执行器名称',
|
|
|
|
|
`trigger_type` tinyint(4) NOT NULL COMMENT '触发类型 1.CRON 表达式 2. 固定时间',
|
|
|
|
|
`trigger_interval` varchar(255) NOT NULL COMMENT '间隔时长',
|
|
|
|
|
`block_strategy` tinyint(4) NOT NULL DEFAULT '1' COMMENT '阻塞策略 1、丢弃 2、覆盖 3、并行',
|
|
|
|
|
`executor_timeout` int(11) NOT NULL DEFAULT '0' COMMENT '任务执行超时时间,单位秒',
|
|
|
|
|
`max_retry_times` int(11) NOT NULL DEFAULT '0' COMMENT '最大重试次数',
|
|
|
|
|
`parallel_num` int(11) NOT NULL DEFAULT '1' COMMENT '并行数',
|
|
|
|
|
`retry_interval` int(11) NOT NULL DEFAULT '0' COMMENT '重试间隔(s)',
|
|
|
|
|
`bucket_index` int(11) NOT NULL DEFAULT '0' COMMENT 'bucket',
|
|
|
|
|
`resident` tinyint(4) NOT NULL DEFAULT '0' COMMENT '是否是常驻任务',
|
|
|
|
|
`description` varchar(256) NOT NULL DEFAULT '' COMMENT '描述',
|
|
|
|
|
`ext_attrs` varchar(256) NULL default '' COMMENT '扩展字段',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
`deleted` tinyint(4) NOT NULL DEFAULT '0' COMMENT '逻辑删除 1、删除',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`),
|
|
|
|
|
KEY `idx_job_status_bucket_index` (`job_status`, `bucket_index`),
|
|
|
|
|
KEY `idx_create_dt` (`create_dt`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='任务信息';
|
|
|
|
|
|
|
|
|
|
INSERT INTO `er_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, '', '', now(), now(), 0);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_job_log_message`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`job_id` bigint(20) NOT NULL COMMENT '任务信息id',
|
|
|
|
|
`task_batch_id` bigint(20) NOT NULL COMMENT '任务批次id',
|
|
|
|
|
`task_id` bigint(20) NOT NULL COMMENT '调度任务id',
|
|
|
|
|
`message` longtext NOT NULL COMMENT '调度信息',
|
|
|
|
|
`log_num` int(11) NOT NULL DEFAULT 1 COMMENT '日志数量',
|
|
|
|
|
`real_time` bigint(13) NOT NULL DEFAULT 0 COMMENT '上报时间',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`ext_attrs` varchar(256) NULL default '' COMMENT '扩展字段',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_task_batch_id_task_id` (`task_batch_id`, `task_id`),
|
|
|
|
|
KEY `idx_create_dt` (`create_dt`),
|
|
|
|
|
KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='调度日志';
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_job_task`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`job_id` bigint(20) NOT NULL COMMENT '任务信息id',
|
|
|
|
|
`task_batch_id` bigint(20) NOT NULL COMMENT '调度任务id',
|
|
|
|
|
`parent_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '父执行器id',
|
|
|
|
|
`task_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '执行的状态 0、失败 1、成功',
|
|
|
|
|
`retry_count` int(11) NOT NULL DEFAULT '0' COMMENT '重试次数',
|
|
|
|
|
`client_info` varchar(128) DEFAULT NULL COMMENT '客户端地址 clientId#ip:port',
|
|
|
|
|
`result_message` text NOT NULL COMMENT '执行结果',
|
|
|
|
|
`args_str` text DEFAULT NULL COMMENT '执行方法参数',
|
|
|
|
|
`args_type` tinyint(4) NOT NULL DEFAULT '1' COMMENT '参数类型 ',
|
|
|
|
|
`ext_attrs` varchar(256) NULL default '' COMMENT '扩展字段',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_task_batch_id_task_status` (`task_batch_id`, `task_status`),
|
|
|
|
|
KEY `idx_create_dt` (`create_dt`),
|
|
|
|
|
KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='任务实例';
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_job_task_batch`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`job_id` bigint(20) NOT NULL COMMENT '任务id',
|
|
|
|
|
`workflow_node_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '工作流节点id',
|
|
|
|
|
`parent_workflow_node_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '工作流任务父批次id',
|
|
|
|
|
`workflow_task_batch_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '工作流任务批次id',
|
|
|
|
|
`task_batch_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '任务批次状态 0、失败 1、成功',
|
|
|
|
|
`operation_reason` tinyint(4) NOT NULL DEFAULT '0' COMMENT '操作原因',
|
|
|
|
|
`execution_at` bigint(13) NOT NULL DEFAULT '0' COMMENT '任务执行时间',
|
|
|
|
|
`system_task_type` tinyint(4) NOT NULL DEFAULT '3' COMMENT '任务类型 3、JOB任务 4、WORKFLOW任务',
|
|
|
|
|
`parent_id` varchar(64) NOT NULL DEFAULT '' COMMENT '父节点',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
`deleted` tinyint(4) NOT NULL DEFAULT '0' COMMENT '逻辑删除 1、删除',
|
|
|
|
|
`ext_attrs` varchar(256) NULL default '' COMMENT '扩展字段',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_job_id_task_batch_status` (`job_id`, `task_batch_status`),
|
|
|
|
|
KEY `idx_create_dt` (`create_dt`),
|
|
|
|
|
KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`),
|
|
|
|
|
KEY `idx_workflow_task_batch_id_workflow_node_id` (`workflow_task_batch_id`, `workflow_node_id`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='任务批次';
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_job_notify_config`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`job_id` bigint(20) NOT NULL COMMENT '任务id',
|
|
|
|
|
`notify_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '通知状态 0、未启用 1、启用',
|
|
|
|
|
`notify_type` tinyint(4) NOT NULL DEFAULT '0' COMMENT '通知类型 1、钉钉 2、邮件 3、企业微信',
|
|
|
|
|
`notify_attribute` varchar(512) NOT NULL COMMENT '配置属性',
|
|
|
|
|
`notify_threshold` int(11) NOT NULL DEFAULT '0' COMMENT '通知阈值',
|
|
|
|
|
`notify_scene` tinyint(4) NOT NULL DEFAULT '0' COMMENT '通知场景',
|
|
|
|
|
`rate_limiter_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '限流状态 0、未启用 1、启用',
|
|
|
|
|
`rate_limiter_threshold` int(11) NOT NULL DEFAULT '0' COMMENT '每秒限流阈值',
|
|
|
|
|
`description` varchar(256) NOT NULL DEFAULT '' COMMENT '描述',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_namespace_id_group_name_job_id` (`namespace_id`, `group_name`, job_id)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 4
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='job通知配置';
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_job_summary`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` VARCHAR(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`group_name` VARCHAR(64) NOT NULL DEFAULT '' COMMENT '组名称',
|
|
|
|
|
`business_id` bigint NOT NULL COMMENT '业务id (job_id或workflow_id)',
|
|
|
|
|
`system_task_type` tinyint(4) NOT NULL DEFAULT '3' COMMENT '任务类型 3、JOB任务 4、WORKFLOW任务',
|
|
|
|
|
`trigger_at` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '统计时间',
|
|
|
|
|
`success_num` int NOT NULL DEFAULT '0' COMMENT '执行成功-日志数量',
|
|
|
|
|
`fail_num` int NOT NULL DEFAULT '0' COMMENT '执行失败-日志数量',
|
|
|
|
|
`fail_reason` varchar(512) NOT NULL DEFAULT '' COMMENT '失败原因',
|
|
|
|
|
`stop_num` int NOT NULL DEFAULT '0' COMMENT '执行失败-日志数量',
|
|
|
|
|
`stop_reason` varchar(512) NOT NULL DEFAULT '' COMMENT '失败原因',
|
|
|
|
|
`cancel_num` int NOT NULL DEFAULT '0' COMMENT '执行失败-日志数量',
|
|
|
|
|
`cancel_reason` varchar(512) NOT NULL DEFAULT '' COMMENT '失败原因',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_namespace_id_group_name_business_id` (`namespace_id`, `group_name`, business_id),
|
|
|
|
|
UNIQUE KEY `uk_trigger_at_system_task_type_business_id` (`trigger_at`, `system_task_type`, `business_id`) USING BTREE
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 1
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='DashBoard_Job';
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_retry_summary`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` VARCHAR(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`group_name` VARCHAR(64) NOT NULL DEFAULT '' COMMENT '组名称',
|
|
|
|
|
`scene_name` VARCHAR(50) NOT NULL DEFAULT '' COMMENT '场景名称',
|
|
|
|
|
`trigger_at` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '统计时间',
|
|
|
|
|
`running_num` int NOT NULL DEFAULT '0' COMMENT '重试中-日志数量',
|
|
|
|
|
`finish_num` int NOT NULL DEFAULT '0' COMMENT '重试完成-日志数量',
|
|
|
|
|
`max_count_num` int NOT NULL DEFAULT '0' COMMENT '重试到达最大次数-日志数量',
|
|
|
|
|
`suspend_num` int NOT NULL DEFAULT '0' COMMENT '暂停重试-日志数量',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_trigger_at` (`trigger_at`),
|
|
|
|
|
UNIQUE KEY `uk_scene_name_trigger_at` (`namespace_id`, `group_name`, `scene_name`, `trigger_at`) USING BTREE
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 1
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='DashBoard_Retry';
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_workflow`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`workflow_name` varchar(64) NOT NULL COMMENT '工作流名称',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`workflow_status` tinyint(4) NOT NULL DEFAULT '1' COMMENT '工作流状态 0、关闭、1、开启',
|
|
|
|
|
`trigger_type` tinyint(4) NOT NULL COMMENT '触发类型 1.CRON 表达式 2. 固定时间',
|
|
|
|
|
`trigger_interval` varchar(255) NOT NULL COMMENT '间隔时长',
|
|
|
|
|
`next_trigger_at` bigint(13) NOT NULL COMMENT '下次触发时间',
|
|
|
|
|
`block_strategy` tinyint(4) NOT NULL DEFAULT '1' COMMENT '阻塞策略 1、丢弃 2、覆盖 3、并行',
|
|
|
|
|
`executor_timeout` int(11) NOT NULL DEFAULT '0' COMMENT '任务执行超时时间,单位秒',
|
|
|
|
|
`description` varchar(256) NOT NULL DEFAULT '' COMMENT '描述',
|
|
|
|
|
`flow_info` text DEFAULT NULL COMMENT '流程信息',
|
|
|
|
|
`bucket_index` int(11) NOT NULL DEFAULT '0' COMMENT 'bucket',
|
|
|
|
|
`version` int(11) NOT NULL COMMENT '版本号',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
`deleted` tinyint(4) NOT NULL DEFAULT '0' COMMENT '逻辑删除 1、删除',
|
|
|
|
|
`ext_attrs` varchar(256) NULL default '' COMMENT '扩展字段',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_create_dt` (`create_dt`),
|
|
|
|
|
KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='工作流';
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_workflow_node`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`node_name` varchar(64) NOT NULL COMMENT '节点名称',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`job_id` bigint(20) NOT NULL COMMENT '任务信息id',
|
|
|
|
|
`workflow_id` bigint(20) NOT NULL COMMENT '工作流ID',
|
|
|
|
|
`node_type` tinyint(4) NOT NULL DEFAULT 1 COMMENT '1、任务节点 2、条件节点',
|
|
|
|
|
`expression_type` tinyint(4) NOT NULL DEFAULT 0 COMMENT '1、SpEl、2、Aviator 3、QL',
|
|
|
|
|
`fail_strategy` tinyint(4) NOT NULL DEFAULT 1 COMMENT '失败策略 1、跳过 2、阻塞',
|
|
|
|
|
`workflow_node_status` tinyint(4) NOT NULL DEFAULT 1 COMMENT '工作流节点状态 0、关闭、1、开启',
|
|
|
|
|
`priority_level` int(11) NOT NULL DEFAULT 1 COMMENT '优先级',
|
|
|
|
|
`node_info` text DEFAULT NULL COMMENT '节点信息 ',
|
|
|
|
|
`version` int(11) NOT NULL COMMENT '版本号',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
`deleted` tinyint(4) NOT NULL DEFAULT '0' COMMENT '逻辑删除 1、删除',
|
|
|
|
|
`ext_attrs` varchar(256) NULL default '' COMMENT '扩展字段',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_create_dt` (`create_dt`),
|
|
|
|
|
KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='工作流节点';
|
|
|
|
|
|
|
|
|
|
CREATE TABLE `er_workflow_task_batch`
|
|
|
|
|
(
|
|
|
|
|
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
|
|
|
|
|
`namespace_id` varchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a' COMMENT '命名空间id',
|
|
|
|
|
`group_name` varchar(64) NOT NULL COMMENT '组名称',
|
|
|
|
|
`workflow_id` bigint(20) NOT NULL COMMENT '工作流任务id',
|
|
|
|
|
`task_batch_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '任务批次状态 0、失败 1、成功',
|
|
|
|
|
`operation_reason` tinyint(4) NOT NULL DEFAULT '0' COMMENT '操作原因',
|
|
|
|
|
`flow_info` text DEFAULT NULL COMMENT '流程信息',
|
|
|
|
|
`execution_at` bigint(13) NOT NULL DEFAULT '0' COMMENT '任务执行时间',
|
|
|
|
|
`create_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
|
|
|
|
|
`update_dt` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
|
|
|
|
|
`deleted` tinyint(4) NOT NULL DEFAULT '0' COMMENT '逻辑删除 1、删除',
|
|
|
|
|
`ext_attrs` varchar(256) NULL default '' COMMENT '扩展字段',
|
|
|
|
|
PRIMARY KEY (`id`),
|
|
|
|
|
KEY `idx_job_id_task_batch_status` (`workflow_id`, `task_batch_status`),
|
|
|
|
|
KEY `idx_create_dt` (`create_dt`),
|
|
|
|
|
KEY `idx_namespace_id_group_name` (`namespace_id`, `group_name`)
|
|
|
|
|
) ENGINE = InnoDB
|
|
|
|
|
AUTO_INCREMENT = 0
|
|
|
|
|
DEFAULT CHARSET = utf8mb4 COMMENT ='工作流批次';
|
|
|
|
|
|