疯狂的狮子Li
2024-04-30 9e5f7be1c5142b1cdafc7e7c79d88d8538265d36
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
-- Oracle DDL
 
-- er_namespace
CREATE TABLE er_namespace
(
    id          NUMBER GENERATED ALWAYS AS IDENTITY,
    name        VARCHAR2(64) NOT NULL,
    unique_id   VARCHAR2(64) NOT NULL,
    description VARCHAR2(256) DEFAULT '',
    create_dt   TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt   TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    deleted     SMALLINT      DEFAULT 0
);
 
CREATE UNIQUE INDEX uk_namespace_1 ON er_namespace (unique_id);
 
COMMENT ON TABLE er_namespace IS '命名空间';
COMMENT ON COLUMN er_namespace.id IS '主键';
COMMENT ON COLUMN er_namespace.name IS '名称';
COMMENT ON COLUMN er_namespace.unique_id IS '唯一id';
COMMENT ON COLUMN er_namespace.description IS '描述';
COMMENT ON COLUMN er_namespace.create_dt IS '创建时间';
COMMENT ON COLUMN er_namespace.update_dt IS '修改时间';
COMMENT ON COLUMN er_namespace.deleted IS '逻辑删除 1、删除';
 
-- id 为 IDENTITY 类型, 不能插入
INSERT INTO er_namespace(name, unique_id, description, create_dt, update_dt, deleted) VALUES('Development', 'dev', '', SYSDATE, SYSDATE, 0 );
INSERT INTO er_namespace(name, unique_id, description, create_dt, update_dt, deleted) VALUES ('Production', 'prod', '', sysdate, sysdate, 0);
 
-- er_group_config
CREATE TABLE er_group_config
(
    id                NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id      VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name        VARCHAR2(64) NOT NULL,
    description       VARCHAR2(256) DEFAULT '',
    token             VARCHAR2(64)  DEFAULT 'ER_cKqBTPzCsWA3VyuCfFoccmuIEGXjr5KT',
    group_status      SMALLINT      DEFAULT 0,
    version           INT          NOT NULL,
    group_partition   INT          NOT NULL,
    id_generator_mode SMALLINT      DEFAULT 1,
    init_scene        SMALLINT      DEFAULT 0,
    bucket_index      INT           DEFAULT 0,
    create_dt         TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt         TIMESTAMP     DEFAULT CURRENT_TIMESTAMP
);
 
CREATE UNIQUE INDEX uk_group_config_1 ON er_group_config (namespace_id, group_name);
 
COMMENT ON TABLE er_group_config IS '组配置';
COMMENT ON COLUMN er_group_config.id IS '主键';
COMMENT ON COLUMN er_group_config.namespace_id IS '命名空间';
COMMENT ON COLUMN er_group_config.group_name IS '组名称';
COMMENT ON COLUMN er_group_config.description IS '组描述';
COMMENT ON COLUMN er_group_config.token IS 'token';
COMMENT ON COLUMN er_group_config.group_status IS '组状态 0、未启用 1、启用';
COMMENT ON COLUMN er_group_config.version IS '版本号';
COMMENT ON COLUMN er_group_config.group_partition IS '分区';
COMMENT ON COLUMN er_group_config.id_generator_mode IS '唯一id生成模式 默认号段模式';
COMMENT ON COLUMN er_group_config.init_scene IS '是否初始化场景 0:否 1:是';
COMMENT ON COLUMN er_group_config.bucket_index IS 'bucket';
COMMENT ON COLUMN er_group_config.create_dt IS '创建时间';
COMMENT ON COLUMN er_group_config.update_dt IS '修改时间';
 
INSERT INTO er_group_config(namespace_id, group_name, description, token, group_status, version, group_partition, id_generator_mode, init_scene, bucket_index, create_dt, update_dt) VALUES ('dev', 'ruoyi_group', '', 'ER_cKqBTPzCsWA3VyuCfFoccmuIEGXjr5KT', 1, 1, 0, 1, 1, 4, SYSDATE, SYSDATE );
 
-- er_notify_config
CREATE TABLE er_notify_config
(
    id                     NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id           VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name             VARCHAR2(64)  NOT NULL,
    scene_name             VARCHAR2(64)  NOT NULL,
    notify_status          SMALLINT      DEFAULT 0,
    notify_type            SMALLINT      DEFAULT 0,
    notify_attribute       VARCHAR2(512) NOT NULL,
    notify_threshold       INT           DEFAULT 0,
    notify_scene           SMALLINT      DEFAULT 0,
    rate_limiter_status    SMALLINT      DEFAULT 0,
    rate_limiter_threshold INT           DEFAULT 0,
    description            VARCHAR2(256) DEFAULT '',
    create_dt              TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt              TIMESTAMP     DEFAULT CURRENT_TIMESTAMP
);
 
CREATE INDEX idx_notify_config_1 ON er_notify_config (namespace_id, group_name);
 
COMMENT ON TABLE er_notify_config IS '通知配置';
COMMENT ON COLUMN er_notify_config.id IS '主键';
COMMENT ON COLUMN er_notify_config.group_name IS '组名称';
COMMENT ON COLUMN er_notify_config.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_notify_config.scene_name IS '场景名称';
COMMENT ON COLUMN er_notify_config.notify_status IS '通知状态 0、未启用 1、启用';
COMMENT ON COLUMN er_notify_config.notify_type IS '通知类型 1、钉钉 2、邮件 3、企业微信';
COMMENT ON COLUMN er_notify_config.notify_attribute IS '配置属性';
COMMENT ON COLUMN er_notify_config.notify_threshold IS '通知阈值';
COMMENT ON COLUMN er_notify_config.notify_scene IS '通知场景';
COMMENT ON COLUMN er_notify_config.rate_limiter_status IS '限流状态 0、未启用 1、启用';
COMMENT ON COLUMN er_notify_config.rate_limiter_threshold IS '每秒限流阈值';
COMMENT ON COLUMN er_notify_config.description IS '描述';
COMMENT ON COLUMN er_notify_config.create_dt IS '创建时间';
COMMENT ON COLUMN er_notify_config.update_dt IS '修改时间';
 
-- er_retry_dead_letter
CREATE TABLE er_retry_dead_letter_0
(
    id            NUMBER GENERATED ALWAYS AS IDENTITY,
    unique_id     VARCHAR2(64) NOT NULL,
    namespace_id  VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name    VARCHAR2(64) NOT NULL,
    scene_name    VARCHAR2(64) NOT NULL,
    idempotent_id VARCHAR2(64) NOT NULL,
    biz_no        VARCHAR2(64)  DEFAULT '',
    executor_name VARCHAR2(512) DEFAULT '',
    args_str      CLOB          DEFAULT '',
    ext_attrs     CLOB          DEFAULT '',
    task_type     SMALLINT      DEFAULT 1,
    create_dt     TIMESTAMP     DEFAULT CURRENT_TIMESTAMP
);
 
CREATE UNIQUE INDEX uk_retry_dead_letter_0_1 ON er_retry_dead_letter_0 (namespace_id, group_name, unique_id);
CREATE INDEX idx_retry_dead_letter_0_1 ON er_retry_dead_letter_0 (namespace_id, group_name, scene_name);
CREATE INDEX idx_retry_dead_letter_0_2 ON er_retry_dead_letter_0 (idempotent_id);
CREATE INDEX idx_retry_dead_letter_0_3 ON er_retry_dead_letter_0 (biz_no);
CREATE INDEX idx_retry_dead_letter_0_4 ON er_retry_dead_letter_0 (create_dt);
 
COMMENT ON TABLE er_retry_dead_letter_0 IS '死信队列表';
COMMENT ON COLUMN er_retry_dead_letter_0.id IS '主键';
COMMENT ON COLUMN er_retry_dead_letter_0.unique_id IS '同组下id唯一';
COMMENT ON COLUMN er_retry_dead_letter_0.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_retry_dead_letter_0.group_name IS '组名称';
COMMENT ON COLUMN er_retry_dead_letter_0.scene_name IS '场景名称';
COMMENT ON COLUMN er_retry_dead_letter_0.idempotent_id IS '幂等id';
COMMENT ON COLUMN er_retry_dead_letter_0.biz_no IS '业务编号';
COMMENT ON COLUMN er_retry_dead_letter_0.executor_name IS '执行器名称';
COMMENT ON COLUMN er_retry_dead_letter_0.args_str IS '执行方法参数';
COMMENT ON COLUMN er_retry_dead_letter_0.ext_attrs IS '扩展字段';
COMMENT ON COLUMN er_retry_dead_letter_0.task_type IS '任务类型 1、重试数据 2、回调数据';
COMMENT ON COLUMN er_retry_dead_letter_0.create_dt IS '创建时间';
 
-- er_retry_task
CREATE TABLE er_retry_task_0
(
    id              NUMBER GENERATED ALWAYS AS IDENTITY,
    unique_id       VARCHAR2(64) NOT NULL,
    namespace_id    VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name      VARCHAR2(64) NOT NULL,
    scene_name      VARCHAR2(64) NOT NULL,
    idempotent_id   VARCHAR2(64) NOT NULL,
    biz_no          VARCHAR2(64)  DEFAULT '',
    executor_name   VARCHAR2(512) DEFAULT '',
    args_str        CLOB          DEFAULT '',
    ext_attrs       CLOB          DEFAULT '',
    next_trigger_at TIMESTAMP    NOT NULL,
    retry_count     INT           DEFAULT 0,
    retry_status    SMALLINT      DEFAULT 0,
    task_type       SMALLINT      DEFAULT 1,
    create_dt       TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt       TIMESTAMP     DEFAULT CURRENT_TIMESTAMP
);
 
CREATE UNIQUE INDEX uk_retry_task_0_1 ON er_retry_task_0 (namespace_id, group_name, unique_id);
CREATE INDEX idx_retry_task_0_1 ON er_retry_task_0 (namespace_id, group_name, scene_name);
CREATE INDEX idx_retry_task_0_2 ON er_retry_task_0 (namespace_id, group_name, retry_status);
CREATE INDEX idx_retry_task_0_3 ON er_retry_task_0 (idempotent_id);
CREATE INDEX idx_retry_task_0_4 ON er_retry_task_0 (biz_no);
CREATE INDEX idx_retry_task_0_5 ON er_retry_task_0 (create_dt);
 
COMMENT ON TABLE er_retry_task_0 IS '任务表';
COMMENT ON COLUMN er_retry_task_0.id IS '主键';
COMMENT ON COLUMN er_retry_task_0.unique_id IS '同组下id唯一';
COMMENT ON COLUMN er_retry_task_0.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_retry_task_0.group_name IS '组名称';
COMMENT ON COLUMN er_retry_task_0.scene_name IS '场景名称';
COMMENT ON COLUMN er_retry_task_0.idempotent_id IS '幂等id';
COMMENT ON COLUMN er_retry_task_0.biz_no IS '业务编号';
COMMENT ON COLUMN er_retry_task_0.executor_name IS '执行器名称';
COMMENT ON COLUMN er_retry_task_0.args_str IS '执行方法参数';
COMMENT ON COLUMN er_retry_task_0.ext_attrs IS '扩展字段';
COMMENT ON COLUMN er_retry_task_0.next_trigger_at IS '下次触发时间';
COMMENT ON COLUMN er_retry_task_0.retry_count IS '重试次数';
COMMENT ON COLUMN er_retry_task_0.retry_status IS '重试状态 0、重试中 1、成功 2、最大重试次数';
COMMENT ON COLUMN er_retry_task_0.task_type IS '任务类型 1、重试数据 2、回调数据';
COMMENT ON COLUMN er_retry_task_0.create_dt IS '创建时间';
COMMENT ON COLUMN er_retry_task_0.update_dt IS '修改时间';
 
-- er_retry_task_log
CREATE TABLE er_retry_task_log
(
    id            NUMBER GENERATED ALWAYS AS IDENTITY,
    unique_id     VARCHAR2(64) NOT NULL,
    namespace_id  VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name    VARCHAR2(64) NOT NULL,
    scene_name    VARCHAR2(64) NOT NULL,
    idempotent_id VARCHAR2(64) NOT NULL,
    biz_no        VARCHAR2(64)  DEFAULT '',
    executor_name VARCHAR2(512) DEFAULT '',
    args_str      CLOB          DEFAULT '',
    ext_attrs     CLOB          DEFAULT '',
    retry_status  SMALLINT      DEFAULT 0,
    task_type     SMALLINT      DEFAULT 1,
    create_dt     TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt     TIMESTAMP     DEFAULT CURRENT_TIMESTAMP
);
 
CREATE INDEX idx_retry_task_log_1 ON er_retry_task_log (namespace_id, group_name, scene_name);
CREATE INDEX idx_retry_task_log_2 ON er_retry_task_log (retry_status);
CREATE INDEX idx_retry_task_log_3 ON er_retry_task_log (idempotent_id);
CREATE INDEX idx_retry_task_log_4 ON er_retry_task_log (namespace_id, group_name, unique_id);
CREATE INDEX idx_retry_task_log_5 ON er_retry_task_log (biz_no);
CREATE INDEX idx_retry_task_log_6 ON er_retry_task_log (create_dt);
 
COMMENT ON TABLE er_retry_task_log IS '任务日志基础信息表';
COMMENT ON COLUMN er_retry_task_log.id IS '主键';
COMMENT ON COLUMN er_retry_task_log.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_retry_task_log.unique_id IS '同组下id唯一';
COMMENT ON COLUMN er_retry_task_log.group_name IS '组名称';
COMMENT ON COLUMN er_retry_task_log.scene_name IS '场景名称';
COMMENT ON COLUMN er_retry_task_log.idempotent_id IS '幂等id';
COMMENT ON COLUMN er_retry_task_log.biz_no IS '业务编号';
COMMENT ON COLUMN er_retry_task_log.executor_name IS '执行器名称';
COMMENT ON COLUMN er_retry_task_log.args_str IS '执行方法参数';
COMMENT ON COLUMN er_retry_task_log.ext_attrs IS '扩展字段';
COMMENT ON COLUMN er_retry_task_log.retry_status IS '重试状态 0、重试中 1、成功 2、最大次数';
COMMENT ON COLUMN er_retry_task_log.task_type IS '任务类型 1、重试数据 2、回调数据';
COMMENT ON COLUMN er_retry_task_log.create_dt IS '创建时间';
COMMENT ON COLUMN er_retry_task_log.update_dt IS '修改时间';
 
-- er_retry_task_log_message
CREATE TABLE er_retry_task_log_message
(
    id           NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id VARCHAR2(64) DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name   VARCHAR2(64) NOT NULL,
    unique_id    VARCHAR2(64) NOT NULL,
    create_dt    TIMESTAMP    DEFAULT CURRENT_TIMESTAMP,
    message      CLOB         DEFAULT '',
    log_num      INT          DEFAULT 1,
    real_time    NUMERIC(13)  DEFAULT 0
);
 
CREATE INDEX idx_retry_task_log_message_1 ON er_retry_task_log_message (namespace_id, group_name, unique_id);
CREATE INDEX idx_retry_task_log_message_2 ON er_retry_task_log_message (create_dt);
 
COMMENT ON TABLE er_retry_task_log_message IS '任务调度日志信息记录表';
COMMENT ON COLUMN er_retry_task_log_message.id IS '主键';
COMMENT ON COLUMN er_retry_task_log_message.namespace_id IS '命名空间';
COMMENT ON COLUMN er_retry_task_log_message.group_name IS '组名称';
COMMENT ON COLUMN er_retry_task_log_message.unique_id IS '同组下id唯一';
COMMENT ON COLUMN er_retry_task_log_message.create_dt IS '创建时间';
COMMENT ON COLUMN er_retry_task_log_message.message IS '异常信息';
COMMENT ON COLUMN er_retry_task_log_message.log_num IS '日志数量';
COMMENT ON COLUMN er_retry_task_log_message.real_time IS '上报时间';
 
-- er_scene_config
CREATE TABLE er_scene_config
(
    id               NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id     VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    scene_name       VARCHAR2(64) NOT NULL,
    group_name       VARCHAR2(64) NOT NULL,
    scene_status     SMALLINT      DEFAULT 0,
    max_retry_count  INT           DEFAULT 5,
    back_off         SMALLINT      DEFAULT 1,
    trigger_interval VARCHAR2(16)  DEFAULT '',
    deadline_request NUMBER(20)    DEFAULT 60000,
    route_key        SMALLINT      DEFAULT 4,
    executor_timeout INT           DEFAULT 5,
    description      VARCHAR2(256) DEFAULT '',
    create_dt        TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt        TIMESTAMP     DEFAULT CURRENT_TIMESTAMP
);
 
CREATE UNIQUE INDEX uk_scene_config_1 ON er_scene_config (namespace_id, group_name, scene_name);
 
COMMENT ON TABLE er_scene_config IS '场景配置';
COMMENT ON COLUMN er_scene_config.id IS '主键';
COMMENT ON COLUMN er_scene_config.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_scene_config.scene_name IS '场景名称';
COMMENT ON COLUMN er_scene_config.group_name IS '组名称';
COMMENT ON COLUMN er_scene_config.scene_status IS '组状态 0、未启用 1、启用';
COMMENT ON COLUMN er_scene_config.max_retry_count IS '最大重试次数';
COMMENT ON COLUMN er_scene_config.back_off IS '1、默认等级 2、固定间隔时间 3、CRON 表达式';
COMMENT ON COLUMN er_scene_config.trigger_interval IS '间隔时长';
COMMENT ON COLUMN er_scene_config.deadline_request IS 'Deadline Request 调用链超时 单位毫秒';
COMMENT ON COLUMN er_scene_config.description IS '描述';
COMMENT ON COLUMN er_scene_config.route_key IS '路由策略';
COMMENT ON COLUMN er_scene_config.executor_timeout IS '超时时间';
COMMENT ON COLUMN er_scene_config.create_dt IS '创建时间';
COMMENT ON COLUMN er_scene_config.update_dt IS '修改时间';
 
-- er_server_node
CREATE TABLE er_server_node
(
    id           NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name   VARCHAR2(64) NOT NULL,
    host_id      VARCHAR2(64) NOT NULL,
    host_ip      VARCHAR2(64) NOT NULL,
    context_path VARCHAR2(256) DEFAULT '/',
    host_port    INT          NOT NULL,
    expire_at    TIMESTAMP    NOT NULL,
    node_type    SMALLINT     NOT NULL,
    ext_attrs    VARCHAR2(256) DEFAULT '',
    create_dt    TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt    TIMESTAMP     DEFAULT CURRENT_TIMESTAMP
);
 
CREATE UNIQUE INDEX uk_server_node_1 ON er_server_node (host_id, host_ip);
CREATE INDEX idx_server_node_1 ON er_server_node (expire_at, node_type);
CREATE INDEX idx_server_node_2 ON er_server_node (namespace_id, group_name);
 
COMMENT ON TABLE er_server_node IS '服务器节点';
COMMENT ON COLUMN er_server_node.id IS '主键';
COMMENT ON COLUMN er_server_node.group_name IS '组名称';
COMMENT ON COLUMN er_server_node.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_server_node.host_id IS '主机id';
COMMENT ON COLUMN er_server_node.host_ip IS '机器ip';
COMMENT ON COLUMN er_server_node.context_path IS '客户端上下文路径 server.servlet.context-path';
COMMENT ON COLUMN er_server_node.host_port IS '机器端口';
COMMENT ON COLUMN er_server_node.expire_at IS '过期时间';
COMMENT ON COLUMN er_server_node.node_type IS '节点类型 1、客户端 2、是服务端';
COMMENT ON COLUMN er_server_node.ext_attrs IS '扩展字段';
COMMENT ON COLUMN er_server_node.create_dt IS '创建时间';
COMMENT ON COLUMN er_server_node.update_dt IS '修改时间';
 
-- er_distributed_lock
CREATE TABLE er_distributed_lock
(
    id         NUMBER GENERATED ALWAYS AS IDENTITY,
    name       VARCHAR2(64)  NOT NULL,
    lock_until TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    locked_at  TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    locked_by  VARCHAR2(255) NOT NULL,
    create_dt  TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    update_dt  TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);
 
ALTER TABLE er_distributed_lock
    ADD CONSTRAINT uk_name_distributed_lock UNIQUE (name);
 
COMMENT ON TABLE er_distributed_lock IS '锁定表';
COMMENT ON COLUMN er_distributed_lock.id IS '主键';
COMMENT ON COLUMN er_distributed_lock.name IS '锁名称';
COMMENT ON COLUMN er_distributed_lock.lock_until IS '锁定时长';
COMMENT ON COLUMN er_distributed_lock.locked_at IS '锁定时间';
COMMENT ON COLUMN er_distributed_lock.locked_by IS '锁定者';
COMMENT ON COLUMN er_distributed_lock.create_dt IS '创建时间';
COMMENT ON COLUMN er_distributed_lock.update_dt IS '修改时间';
 
-- er_system_user
CREATE TABLE er_system_user
(
    id        NUMBER GENERATED ALWAYS AS IDENTITY,
    username  VARCHAR2(64)  NOT NULL,
    password  VARCHAR2(128) NOT NULL,
    role      SMALLINT  DEFAULT 0,
    create_dt TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    update_dt TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);
 
CREATE UNIQUE INDEX uk_system_user_1 ON er_system_user (username);
 
COMMENT ON TABLE er_system_user IS '系统用户表';
COMMENT ON COLUMN er_system_user.id IS '主键';
COMMENT ON COLUMN er_system_user.username IS '账号';
COMMENT ON COLUMN er_system_user.password IS '密码';
COMMENT ON COLUMN er_system_user.role IS '角色:1-普通用户、2-管理员';
COMMENT ON COLUMN er_system_user.create_dt IS '创建时间';
COMMENT ON COLUMN er_system_user.update_dt IS '修改时间';
 
-- pwd: admin
INSERT INTO er_system_user(username, password, role, create_dt, update_dt) VALUES ('admin', '465c194afb65670f38322df087f0a9bb225cc257e43eb4ac5a0c98ef5b3173ac', 2, SYSDATE, SYSDATE);
 
-- er_system_user_permission
CREATE TABLE er_system_user_permission
(
    id             NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id   VARCHAR2(64) DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name     VARCHAR2(64) NOT NULL,
    system_user_id NUMBER(20)   NOT NULL,
    create_dt      TIMESTAMP    DEFAULT CURRENT_TIMESTAMP,
    update_dt      TIMESTAMP    DEFAULT CURRENT_TIMESTAMP
);
 
CREATE UNIQUE INDEX uk_system_user_permission_1 ON er_system_user_permission (namespace_id, group_name, system_user_id);
 
COMMENT ON TABLE er_system_user_permission IS '系统用户权限表';
COMMENT ON COLUMN er_system_user_permission.id IS '主键';
COMMENT ON COLUMN er_system_user_permission.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_system_user_permission.group_name IS '组名称';
COMMENT ON COLUMN er_system_user_permission.system_user_id IS '系统用户id';
COMMENT ON COLUMN er_system_user_permission.create_dt IS '创建时间';
COMMENT ON COLUMN er_system_user_permission.update_dt IS '修改时间';
 
-- er_sequence_alloc
CREATE TABLE er_sequence_alloc
(
    id           NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id VARCHAR2(64) DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name   VARCHAR2(64) DEFAULT '',
    max_id       NUMBER(20)   DEFAULT 1,
    step         INT          DEFAULT 100,
    update_dt    TIMESTAMP    DEFAULT CURRENT_TIMESTAMP
);
 
CREATE UNIQUE INDEX uk_sequence_alloc_1 ON er_sequence_alloc (namespace_id, group_name);
 
COMMENT ON TABLE er_sequence_alloc IS '号段模式序号ID分配表';
COMMENT ON COLUMN er_sequence_alloc.id IS '主键';
COMMENT ON COLUMN er_sequence_alloc.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_sequence_alloc.group_name IS '组名称';
COMMENT ON COLUMN er_sequence_alloc.max_id IS '最大id';
COMMENT ON COLUMN er_sequence_alloc.step IS '步长';
COMMENT ON COLUMN er_sequence_alloc.update_dt IS '更新时间';
 
-- er_job
CREATE TABLE er_job
(
    id               NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id     VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name       VARCHAR2(64)  NOT NULL,
    job_name         VARCHAR2(64)  NOT NULL,
    args_str         CLOB          DEFAULT '',
    args_type        SMALLINT      DEFAULT 1,
    next_trigger_at  NUMBER(20)    NOT NULL,
    job_status       SMALLINT      DEFAULT 1,
    task_type        SMALLINT      DEFAULT 1,
    route_key        SMALLINT      DEFAULT 4,
    executor_type    SMALLINT      DEFAULT 1,
    executor_info    VARCHAR2(255) DEFAULT NULL,
    trigger_type     SMALLINT      NOT NULL,
    trigger_interval VARCHAR2(255) NOT NULL,
    block_strategy   SMALLINT      DEFAULT 1,
    executor_timeout INT           DEFAULT 0,
    max_retry_times  INT           DEFAULT 0,
    parallel_num     INT           DEFAULT 1,
    retry_interval   INT           DEFAULT 0,
    bucket_index     INT           DEFAULT 0,
    resident         SMALLINT      DEFAULT 0,
    description      VARCHAR2(256) DEFAULT '',
    ext_attrs        VARCHAR2(256) DEFAULT '',
    create_dt        TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt        TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    deleted          SMALLINT      DEFAULT 0
);
 
CREATE INDEX idx_job_1 ON er_job (namespace_id, group_name);
CREATE INDEX idx_job_2 ON er_job (job_status, bucket_index);
CREATE INDEX idx_job_3 ON er_job (create_dt);
 
COMMENT ON TABLE er_job IS '任务信息';
COMMENT ON COLUMN er_job.id IS '主键';
COMMENT ON COLUMN er_job.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_job.group_name IS '组名称';
COMMENT ON COLUMN er_job.job_name IS '名称';
COMMENT ON COLUMN er_job.args_str IS '执行方法参数';
COMMENT ON COLUMN er_job.args_type IS '参数类型';
COMMENT ON COLUMN er_job.next_trigger_at IS '下次触发时间';
COMMENT ON COLUMN er_job.job_status IS '重试状态 0、关闭、1、开启';
COMMENT ON COLUMN er_job.task_type IS '任务类型 1、集群 2、广播 3、切片';
COMMENT ON COLUMN er_job.route_key IS '路由策略';
COMMENT ON COLUMN er_job.executor_type IS '执行器类型';
COMMENT ON COLUMN er_job.executor_info IS '执行器名称';
COMMENT ON COLUMN er_job.trigger_type IS '触发类型 1.CRON 表达式 2. 固定时间';
COMMENT ON COLUMN er_job.trigger_interval IS '间隔时长';
COMMENT ON COLUMN er_job.block_strategy IS '阻塞策略 1、丢弃 2、覆盖 3、并行';
COMMENT ON COLUMN er_job.executor_timeout IS '任务执行超时时间,单位秒';
COMMENT ON COLUMN er_job.max_retry_times IS '最大重试次数';
COMMENT ON COLUMN er_job.parallel_num IS '并行数';
COMMENT ON COLUMN er_job.retry_interval IS '更新重试间隔(s)';
COMMENT ON COLUMN er_job.bucket_index IS 'bucket';
COMMENT ON COLUMN er_job.resident IS '是否是常驻任务';
COMMENT ON COLUMN er_job.description IS '描述';
COMMENT ON COLUMN er_job.ext_attrs IS '扩展字段';
COMMENT ON COLUMN er_job.create_dt IS '创建时间';
COMMENT ON COLUMN er_job.update_dt IS '更新时间';
COMMENT ON COLUMN er_job.deleted IS '逻辑删除 1、删除';
 
INSERT INTO er_job (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)
VALUES ('dev', 'ruoyi_group', 'demo-job', NULL, 1, 1710344035622, 1, 1, 4, 1, 'testJobExecutor', 2, '60', 1, 60, 3, 1, 1, 116, 0, '', '', SYSDATE, SYSDATE, 0);
 
-- er_job_log_message
CREATE TABLE er_job_log_message
(
    id            NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id  VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name    VARCHAR2(64) NOT NULL,
    job_id        NUMBER(20)   NOT NULL,
    task_batch_id NUMBER(20)   NOT NULL,
    task_id       NUMBER(20)   NOT NULL,
    message       CLOB          DEFAULT '',
    log_num       INT           DEFAULT 1,
    real_time     NUMBER(20)    DEFAULT 0,
    ext_attrs     VARCHAR2(256) DEFAULT '',
    create_dt     TIMESTAMP     DEFAULT CURRENT_TIMESTAMP
);
 
CREATE INDEX idx_job_log_message_1 ON er_job_log_message (namespace_id, group_name);
CREATE INDEX idx_job_log_message_2 ON er_job_log_message (task_batch_id, task_id);
CREATE INDEX idx_job_log_message_3 ON er_job_log_message (create_dt);
 
COMMENT ON TABLE er_job_log_message IS '调度日志';
COMMENT ON COLUMN er_job_log_message.id IS '主键';
COMMENT ON COLUMN er_job_log_message.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_job_log_message.group_name IS '组名称';
COMMENT ON COLUMN er_job_log_message.job_id IS '任务信息id';
COMMENT ON COLUMN er_job_log_message.task_batch_id IS '任务批次id';
COMMENT ON COLUMN er_job_log_message.task_id IS '调度任务id';
COMMENT ON COLUMN er_job_log_message.message IS '调度信息';
COMMENT ON COLUMN er_job_log_message.log_num IS '日志序号';
COMMENT ON COLUMN er_job_log_message.real_time IS '实际时间';
COMMENT ON COLUMN er_job_log_message.create_dt IS '创建时间';
COMMENT ON COLUMN er_job_log_message.ext_attrs IS '扩展字段';
 
-- er_job_task
CREATE TABLE er_job_task
(
    id             NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id   VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name     VARCHAR2(64) NOT NULL,
    job_id         NUMBER(20)   NOT NULL,
    task_batch_id  NUMBER(20)   NOT NULL,
    parent_id      NUMBER(20)    DEFAULT 0,
    task_status    SMALLINT      DEFAULT 0,
    retry_count    INT           DEFAULT 0,
    client_info    VARCHAR2(128) DEFAULT NULL,
    result_message CLOB          DEFAULT '',
    args_str       CLOB          DEFAULT '',
    args_type      SMALLINT      DEFAULT 1,
    ext_attrs      VARCHAR2(256) DEFAULT '',
    create_dt      TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt      TIMESTAMP     DEFAULT CURRENT_TIMESTAMP
);
 
CREATE INDEX idx_job_task_1 ON er_job_task (namespace_id, group_name);
CREATE INDEX idx_job_task_2 ON er_job_task (task_batch_id, task_status);
CREATE INDEX idx_job_task_3 ON er_job_task (create_dt);
 
COMMENT ON TABLE er_job_task IS '任务实例';
COMMENT ON COLUMN er_job_task.id IS '主键';
COMMENT ON COLUMN er_job_task.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_job_task.group_name IS '组名称';
COMMENT ON COLUMN er_job_task.job_id IS '任务信息id';
COMMENT ON COLUMN er_job_task.task_batch_id IS '任务批次id';
COMMENT ON COLUMN er_job_task.parent_id IS '父执行器id';
COMMENT ON COLUMN er_job_task.task_status IS '执行的状态 0、失败 1、成功';
COMMENT ON COLUMN er_job_task.retry_count IS '重试次数';
COMMENT ON COLUMN er_job_task.client_info IS '客户端地址 clientId#ip:port';
COMMENT ON COLUMN er_job_task.result_message IS '调度信息';
COMMENT ON COLUMN er_job_task.args_str IS '执行方法参数';
COMMENT ON COLUMN er_job_task.args_type IS '参数类型';
COMMENT ON COLUMN er_job_task.create_dt IS '创建时间';
COMMENT ON COLUMN er_job_task.update_dt IS '创建时间';
COMMENT ON COLUMN er_job_task.ext_attrs IS '扩展字段';
 
-- er_job_task_batch
CREATE TABLE er_job_task_batch
(
    id                      NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id            VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name              VARCHAR2(64) NOT NULL,
    job_id                  NUMBER(20)   NOT NULL,
    workflow_node_id        NUMBER(20)    DEFAULT 0,
    parent_workflow_node_id NUMBER(20)    DEFAULT 0,
    workflow_task_batch_id  NUMBER(20)    DEFAULT 0,
    parent_id               VARCHAR2(64)  DEFAULT '',
    task_batch_status       SMALLINT      DEFAULT 0,
    operation_reason        SMALLINT      DEFAULT 0,
    execution_at            NUMBER(20)    DEFAULT 0,
    system_task_type        SMALLINT      DEFAULT 3,
    ext_attrs               VARCHAR2(256) DEFAULT '',
    deleted                 SMALLINT      DEFAULT 0,
    create_dt               TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt               TIMESTAMP     DEFAULT CURRENT_TIMESTAMP
);
 
CREATE INDEX idx_job_task_batch_1 ON er_job_task_batch (namespace_id, group_name);
CREATE INDEX idx_job_task_batch_2 ON er_job_task_batch (job_id, task_batch_status);
CREATE INDEX idx_job_task_batch_3 ON er_job_task_batch (create_dt);
CREATE INDEX idx_job_task_batch_4 ON er_job_task_batch (workflow_task_batch_id, workflow_node_id);
 
COMMENT ON TABLE er_job_task_batch IS '任务批次';
COMMENT ON COLUMN er_job_task_batch.id IS '主键';
COMMENT ON COLUMN er_job_task_batch.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_job_task_batch.group_name IS '组名称';
COMMENT ON COLUMN er_job_task_batch.job_id IS '任务信息id';
COMMENT ON COLUMN er_job_task_batch.task_batch_status IS '任务批次状态 0、失败 1、成功';
COMMENT ON COLUMN er_job_task_batch.operation_reason IS '操作原因';
COMMENT ON COLUMN er_job_task_batch.workflow_node_id IS '工作流节点id';
COMMENT ON COLUMN er_job_task_batch.parent_workflow_node_id IS '父节点';
COMMENT ON COLUMN er_job_task_batch.workflow_task_batch_id IS '任务批次id';
COMMENT ON COLUMN er_job_task_batch.system_task_type IS '任务类型 0、系统任务 1、业务任务';
COMMENT ON COLUMN er_job_task_batch.execution_at IS '任务执行时间';
COMMENT ON COLUMN er_job_task_batch.parent_id IS '父节点';
COMMENT ON COLUMN er_job_task_batch.deleted IS '逻辑删除 1、删除';
COMMENT ON COLUMN er_job_task_batch.create_dt IS '创建时间';
COMMENT ON COLUMN er_job_task_batch.update_dt IS '创建时间';
COMMENT ON COLUMN er_job_task_batch.ext_attrs IS '扩展字段';
 
CREATE TABLE er_job_notify_config
(
    id                     NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id           VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name             VARCHAR2(64)  NOT NULL,
    job_id                 NUMBER(20)    NOT NULL,
    notify_status          SMALLINT      DEFAULT 0,
    notify_type            SMALLINT      DEFAULT 0,
    notify_attribute       VARCHAR2(512) NOT NULL,
    notify_threshold       INT           DEFAULT 0,
    notify_scene           SMALLINT      DEFAULT 0,
    rate_limiter_status    SMALLINT      DEFAULT 0,
    rate_limiter_threshold INT           DEFAULT 0,
    description            VARCHAR2(256) DEFAULT '',
    create_dt              TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt              TIMESTAMP     DEFAULT CURRENT_TIMESTAMP
);
 
CREATE INDEX idx_job_notify_config_1 ON er_job_notify_config (namespace_id, group_name, job_id);
 
COMMENT ON TABLE er_job_notify_config IS '通知配置';
COMMENT ON COLUMN er_job_notify_config.id IS '主键';
COMMENT ON COLUMN er_job_notify_config.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_job_notify_config.group_name IS '组名称';
COMMENT ON COLUMN er_job_notify_config.job_id IS '任务信息id';
COMMENT ON COLUMN er_job_notify_config.notify_status IS '通知状态 0、未启用 1、启用';
COMMENT ON COLUMN er_job_notify_config.notify_type IS '通知类型 1、钉钉 2、邮件 3、企业微信';
COMMENT ON COLUMN er_job_notify_config.notify_attribute IS '配置属性';
COMMENT ON COLUMN er_job_notify_config.notify_threshold IS '通知阈值';
COMMENT ON COLUMN er_job_notify_config.notify_scene IS '通知场景';
COMMENT ON COLUMN er_job_notify_config.rate_limiter_status IS '限流状态 0、未启用 1、启用';
COMMENT ON COLUMN er_job_notify_config.rate_limiter_threshold IS '每秒限流阈值';
COMMENT ON COLUMN er_job_notify_config.description IS '描述';
COMMENT ON COLUMN er_job_notify_config.create_dt IS '创建时间';
COMMENT ON COLUMN er_job_notify_config.update_dt IS '修改时间';
 
-- er_retry_summary
CREATE TABLE er_retry_summary
(
    id            NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id  VARCHAR2(64) DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name    VARCHAR2(64) DEFAULT '',
    scene_name    VARCHAR2(50) DEFAULT '',
    trigger_at    TIMESTAMP    DEFAULT CURRENT_TIMESTAMP,
    running_num   INT          DEFAULT 0,
    finish_num    INT          DEFAULT 0,
    max_count_num INT          DEFAULT 0,
    suspend_num   INT          DEFAULT 0,
    create_dt     TIMESTAMP    DEFAULT CURRENT_TIMESTAMP,
    update_dt     TIMESTAMP    DEFAULT CURRENT_TIMESTAMP
);
 
CREATE UNIQUE INDEX uk_retry_summary_1 ON er_retry_summary (namespace_id, group_name, scene_name, trigger_at);
 
COMMENT ON TABLE er_retry_summary IS 'DashBoard_Retry';
COMMENT ON COLUMN er_retry_summary.id IS '主键';
COMMENT ON COLUMN er_retry_summary.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_retry_summary.group_name IS '组名称';
COMMENT ON COLUMN er_retry_summary.scene_name IS '场景名称';
COMMENT ON COLUMN er_retry_summary.trigger_at IS '统计时间';
COMMENT ON COLUMN er_retry_summary.running_num IS '重试中-日志数量';
COMMENT ON COLUMN er_retry_summary.finish_num IS '重试完成-日志数量';
COMMENT ON COLUMN er_retry_summary.max_count_num IS '重试到达最大次数-日志数量';
COMMENT ON COLUMN er_retry_summary.suspend_num IS '暂停重试-日志数量';
COMMENT ON COLUMN er_retry_summary.create_dt IS '创建时间';
COMMENT ON COLUMN er_retry_summary.update_dt IS '修改时间';
 
-- er_job_summary
CREATE TABLE er_job_summary
(
    id               NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id     VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name       VARCHAR2(64)  DEFAULT '',
    business_id      NUMBER(20) NOT NULL,
    system_task_type SMALLINT      DEFAULT '3',
    trigger_at       TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    success_num      INT           DEFAULT 0,
    fail_num         INT           DEFAULT 0,
    fail_reason      VARCHAR2(512) DEFAULT '',
    stop_num         INT           DEFAULT 0,
    stop_reason      VARCHAR2(512) DEFAULT '',
    cancel_num       INT           DEFAULT 0,
    cancel_reason    VARCHAR2(512) DEFAULT '',
    create_dt        TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt        TIMESTAMP     DEFAULT CURRENT_TIMESTAMP
);
 
CREATE UNIQUE INDEX uk_job_summary_1 ON er_job_summary (trigger_at, system_task_type, business_id);
CREATE INDEX idx_job_summary_1 ON er_job_summary (namespace_id, group_name, business_id);
 
COMMENT ON TABLE er_job_summary IS 'DashBoard_Job';
COMMENT ON COLUMN er_job_summary.id IS '主键';
COMMENT ON COLUMN er_job_summary.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_job_summary.group_name IS '组名称';
COMMENT ON COLUMN er_job_summary.business_id IS '业务id (job_id或workflow_id)';
COMMENT ON COLUMN er_job_summary.system_task_type IS '任务类型 3、JOB任务 4、WORKFLOW任务';
COMMENT ON COLUMN er_job_summary.trigger_at IS '统计时间';
COMMENT ON COLUMN er_job_summary.success_num IS '执行成功-日志数量';
COMMENT ON COLUMN er_job_summary.fail_num IS '执行失败-日志数量';
COMMENT ON COLUMN er_job_summary.fail_reason IS '失败原因';
COMMENT ON COLUMN er_job_summary.stop_num IS '执行失败-日志数量';
COMMENT ON COLUMN er_job_summary.stop_reason IS '失败原因';
COMMENT ON COLUMN er_job_summary.cancel_num IS '执行失败-日志数量';
COMMENT ON COLUMN er_job_summary.cancel_reason IS '失败原因';
 
-- er_workflow
CREATE TABLE er_workflow
(
    id               NUMBER GENERATED ALWAYS AS IDENTITY,
    workflow_name    VARCHAR2(64)  NOT NULL,
    namespace_id     VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name       VARCHAR2(64)  NOT NULL,
    workflow_status  SMALLINT      DEFAULT 1,
    trigger_type     SMALLINT      NOT NULL,
    trigger_interval VARCHAR2(255) NOT NULL,
    next_trigger_at  NUMBER(20)    NOT NULL,
    block_strategy   SMALLINT      DEFAULT 1,
    executor_timeout INT           DEFAULT 0,
    description      VARCHAR2(256) DEFAULT '',
    flow_info        CLOB          DEFAULT '',
    bucket_index     INT           DEFAULT 0,
    version          INT           NOT NULL,
    create_dt        TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt        TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    deleted          SMALLINT      DEFAULT 0,
    ext_attrs        VARCHAR2(256) DEFAULT ''
);
 
CREATE INDEX idx_workflow_1 ON er_workflow (create_dt);
CREATE INDEX idx_workflow_2 ON er_workflow (namespace_id, group_name);
 
COMMENT ON TABLE er_workflow IS '工作流';
COMMENT ON COLUMN er_workflow.id IS '主键';
COMMENT ON COLUMN er_workflow.workflow_name IS '工作流名称';
COMMENT ON COLUMN er_workflow.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_workflow.group_name IS '组名称';
COMMENT ON COLUMN er_workflow.workflow_status IS '工作流状态 0、关闭、1、开启';
COMMENT ON COLUMN er_workflow.trigger_type IS '触发类型 1.CRON 表达式 2. 固定时间';
COMMENT ON COLUMN er_workflow.trigger_interval IS '间隔时长';
COMMENT ON COLUMN er_workflow.next_trigger_at IS '下次触发时间';
COMMENT ON COLUMN er_workflow.block_strategy IS '阻塞策略 1、丢弃 2、覆盖 3、并行';
COMMENT ON COLUMN er_workflow.executor_timeout IS '任务执行超时时间,单位秒';
COMMENT ON COLUMN er_workflow.description IS '描述';
COMMENT ON COLUMN er_workflow.flow_info IS '流程信息';
COMMENT ON COLUMN er_workflow.bucket_index IS 'bucket';
COMMENT ON COLUMN er_workflow.version IS '版本号';
COMMENT ON COLUMN er_workflow.create_dt IS '创建时间';
COMMENT ON COLUMN er_workflow.update_dt IS '修改时间';
COMMENT ON COLUMN er_workflow.deleted IS '逻辑删除 1、删除';
COMMENT ON COLUMN er_workflow.ext_attrs IS '扩展字段';
 
-- er_workflow_node
CREATE TABLE er_workflow_node
(
    id                   NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id         VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    node_name            VARCHAR2(64) NOT NULL,
    group_name           VARCHAR2(64) NOT NULL,
    job_id               NUMBER(20)   NOT NULL,
    workflow_id          NUMBER(20)   NOT NULL,
    node_type            SMALLINT      DEFAULT 1,
    expression_type      SMALLINT      DEFAULT 0,
    fail_strategy        SMALLINT      DEFAULT 1,
    workflow_node_status SMALLINT      DEFAULT 1,
    priority_level       INT           DEFAULT 1,
    node_info            CLOB          DEFAULT '',
    version              INT          NOT NULL,
    create_dt            TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt            TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    deleted              SMALLINT      DEFAULT 0,
    ext_attrs            VARCHAR2(256) DEFAULT ''
);
 
CREATE INDEX idx_workflow_node_1 ON er_workflow_node (create_dt);
CREATE INDEX idx_workflow_node_2 ON er_workflow_node (namespace_id, group_name);
 
COMMENT ON TABLE er_workflow_node IS '工作流节点';
COMMENT ON COLUMN er_workflow_node.id IS '主键';
COMMENT ON COLUMN er_workflow_node.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_workflow_node.node_name IS '节点名称';
COMMENT ON COLUMN er_workflow_node.group_name IS '组名称';
COMMENT ON COLUMN er_workflow_node.job_id IS '任务信息id';
COMMENT ON COLUMN er_workflow_node.workflow_id IS '工作流ID';
COMMENT ON COLUMN er_workflow_node.node_type IS '1、任务节点 2、条件节点';
COMMENT ON COLUMN er_workflow_node.expression_type IS '1、SpEl、2、Aviator 3、QL';
COMMENT ON COLUMN er_workflow_node.fail_strategy IS '失败策略 1、跳过 2、阻塞';
COMMENT ON COLUMN er_workflow_node.workflow_node_status IS '工作流节点状态 0、关闭、1、开启';
COMMENT ON COLUMN er_workflow_node.priority_level IS '优先级';
COMMENT ON COLUMN er_workflow_node.node_info IS '节点信息';
COMMENT ON COLUMN er_workflow_node.version IS '版本号';
COMMENT ON COLUMN er_workflow_node.create_dt IS '创建时间';
COMMENT ON COLUMN er_workflow_node.update_dt IS '修改时间';
COMMENT ON COLUMN er_workflow_node.deleted IS '逻辑删除 1、删除';
COMMENT ON COLUMN er_workflow_node.ext_attrs IS '扩展字段';
 
-- er_workflow_task_batch
CREATE TABLE er_workflow_task_batch
(
    id                NUMBER GENERATED ALWAYS AS IDENTITY,
    namespace_id      VARCHAR2(64)  DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
    group_name        VARCHAR2(64) NOT NULL,
    workflow_id       NUMBER(20)   NOT NULL,
    task_batch_status SMALLINT      DEFAULT 0,
    operation_reason  SMALLINT      DEFAULT 0,
    flow_info         CLOB          DEFAULT '',
    execution_at      NUMBER(20)    DEFAULT 0,
    create_dt         TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    update_dt         TIMESTAMP     DEFAULT CURRENT_TIMESTAMP,
    deleted           SMALLINT      DEFAULT 0,
    ext_attrs         VARCHAR2(256) DEFAULT ''
);
 
CREATE INDEX idx_workflow_task_batch_1 ON er_workflow_task_batch (workflow_id, task_batch_status);
CREATE INDEX idx_workflow_task_batch_2 ON er_workflow_task_batch (create_dt);
CREATE INDEX idx_workflow_task_batch_3 ON er_workflow_task_batch (namespace_id, group_name);
 
COMMENT ON TABLE er_workflow_task_batch IS '工作流批次';
COMMENT ON COLUMN er_workflow_task_batch.id IS '主键';
COMMENT ON COLUMN er_workflow_task_batch.namespace_id IS '命名空间id';
COMMENT ON COLUMN er_workflow_task_batch.group_name IS '组名称';
COMMENT ON COLUMN er_workflow_task_batch.workflow_id IS '工作流任务id';
COMMENT ON COLUMN er_workflow_task_batch.task_batch_status IS '任务批次状态 0、失败 1、成功';
COMMENT ON COLUMN er_workflow_task_batch.operation_reason IS '操作原因';
COMMENT ON COLUMN er_workflow_task_batch.flow_info IS '流程信息';
COMMENT ON COLUMN er_workflow_task_batch.execution_at IS '任务执行时间';
COMMENT ON COLUMN er_workflow_task_batch.create_dt IS '创建时间';
COMMENT ON COLUMN er_workflow_task_batch.update_dt IS '修改时间';
COMMENT ON COLUMN er_workflow_task_batch.deleted IS '逻辑删除 1、删除';
COMMENT ON COLUMN er_workflow_task_batch.ext_attrs IS '扩展字段';