Skip to content

Instantly share code, notes, and snippets.

@anson0370
Created January 18, 2012 10:50
Show Gist options
  • Save anson0370/1632413 to your computer and use it in GitHub Desktop.
Save anson0370/1632413 to your computer and use it in GitHub Desktop.
quick start of kongur

Quick Start

Dependencies

使用maven管理依赖,最新的PMC版本是2.1.2.11

一个全功能的嵌入式的简单依赖可能是这样的

<properties>
    <kongur.version>2.1.2.11</kongur.version>
</properties>

<dependency>
    <groupId>com.taobao.pamirs.kongur.modules</groupId>
    <artifactId>kongur-dschedule</artifactId>
    <version>${kongur.version}</version>
</dependency>
<dependency>
    <groupId>com.taobao.pamirs.kongur.modules</groupId>
    <artifactId>kongur-management</artifactId>
    <version>${kongur.version}</version>
</dependency>

如果你只需要远程调用PMC的HSF,那么只需要依赖

<dependency>
    <groupId>com.taobao.pamirs.kongur.modules</groupId>
    <artifactId>kongur-appclient</artifactId>
    <version>${kongur.version}</version>
</dependency>
<!-- kongur-config这个依赖是可选的,不过有它将会使你配置PMC的时候更加简单 -->
<dependency>
    <groupId>com.taobao.pamirs.kongur.modules</groupId>
    <artifactId>kongur-config</artifactId>
    <version>${kongur.version}</version>
</dependency>

需要注意的是PMC还有一些scope为provided的依赖,一般来说应用中都会依赖到,如果遇到ClassNotFoundException这样疑似缺少jar的错误请联系我

下面列出provided的依赖

待补充

Init

使用Spring初始化PMC

嵌入使用PMC只需要配置一个bean:PmcConfig,下面是一个典型的配置

<bean id="pmcConfig" class="com.taobao.pamirs.kongur.config.PmcConfig">
    <!-- 开发模式:主要用户单元测试,通过单元测试的方式依赖外部hsf -->
    <property name="developMode" value="false" />
    <!-- 本地流程模板:是否使用本地文件系统下的模板,开发阶段方便调试 -->
    <property name="localProcess" value="false" />
    <!-- 运行环境:用于隔离不同的环境,取值自定,如product, pre, daily, dev等 -->
    <property name="runtimeEnv" value="${runtimeEnv}" />
    <!-- 启用cache 请开启 -->
    <property name="enableCache" value="true" />
    <!-- 启用event 涉及一些异步消息 -->
    <property name="enableEvent" value="true" />
    <!-- 启用job 涉及自动重试、超时等特性 -->
    <property name="enableJob" value="true" />
    <!-- 启用Mbean 发布一些Mbean来管理 -->
    <property name="enableMbean" value="true" />
    <!-- 启用默认的MC消息中心 使用消息中心发送消息 -->
    <property name="enableDefaultMC" value="true" />
    <!-- 消息中心的hsf版本 默认为1.0.0.daily -->
    <property name="mcHsfVersion" value="${mc.version}" />
    <!-- 启用默认的用户控制依赖 既后台hecla 主要作用是获取用户的邮件和旺旺等信息 -->
    <property name="enableDefaultUC" value="true" />
    <!-- hecla的hsf版本 默认是1.0.0.daily -->
    <property name="heclaHsfVersion" value="${hecla.version}" />
    <!-- 启用调度器 推荐启用 -->
    <property name="enableDschedule" value="true" />
    <!-- 是否在应用重启的时候重试因应用关闭而停在半路的流程 -->
    <property name="initFailedActivity" value="true" />
    <!-- 应用名 -->
    <property name="bizApp">
        <value><![CDATA[${kongur.bizApp}]]></value>
    </property>
    <!-- 当前应用所属执行域 -->
    <property name="metaDomain">
        <value><![CDATA[${kongur.executeDomain}]]></value>
    </property>
    <!-- 当前应用可执行域 逗号分隔多个 -->
    <property name="executableDomain">
        <value><![CDATA[${kongur.executeDomain}]]></value>
    </property>
    <!-- DB类型 MYSQL or ORACLE -->
    <property name="dbType" value="MYSQL" />
    <!-- tddl sequence使用的表名称 -->
    <property name="sequenceTableName" value="${sequenceTableName}" />
    <!-- 使用的数据源 -->
    <property name="exDataSource" ref="kunlunDS" />
</bean>

如果中心化使用PMC,也只需要配置一个PmcConfig

<bean id="pmcConfig" class="com.taobao.pamirs.kongur.config.PmcConfig">
    <!-- 开发模式 如果为true则连接PMC的hsf服务使用的是hsfunit -->
    <property name="developMode" value="false" />
    <!-- client模式 这个模式下只调用中心式PMC的hsf服务 -->
    <property name="clientMode" value="true" />
    <!-- 中心式PMC的hsf version 日常为2.0.0.daily 线上为2.0.0 -->
    <property name="hsfVersion" value="2.0.0.daily" />
    <!-- 中心式PMC的hsf group -->
    <property name="hsfGroup" value="kunlun" />
</bean>

创建持久化需要的数据表 // TODO

初始化表数据

需要填充初始化数据的表有两部分

-   TDDL-Sequence使用的序列表

        kongur_sequence

-   taobao-pamirs-schedule使用的配置表

        pamirs_schedule_tasktype
        pamirs_schedule_queue

// TODO

Use

com.taobao.pamirs.kongur.appclient.PmcServiceHoldercom.taobao.pamirs.kongur.api.PmcExServiceHolder中可以获取到所有的接口

所有接口详细信息可以在source的jar里看接口上的javadoc

  • TaskAccessor API DOC

    任务的查询、审批、转交、申领等动作

  • ProcessAccessor API DOC

    流程的查询、取消、发起等动作

  • WebflowAccessor

    页面流节点的查询、流转等动作

@fromcth
Copy link

fromcth commented Mar 27, 2013

数据库建表:

CREATE TABLE kongur_activity (
id BIGINT(20) UNSIGNED NOT NULL,
activity_name VARCHAR(255) NULL DEFAULT NULL,
is_success TINYINT(4) NULL DEFAULT NULL,
process_instance_id BIGINT(20) NULL DEFAULT NULL,
state VARCHAR(20) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NULL DEFAULT NULL,
out_going VARCHAR(255) NULL DEFAULT NULL,
execute_domain VARCHAR(255) NULL DEFAULT NULL,
PRIMARY KEY (id),
INDEX idx_act_pinsid (process_instance_id),
INDEX idx_act_excdomain (execute_domain(30))
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT


CREATE TABLE kongur_config (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
execute_domain VARCHAR(255) NULL DEFAULT NULL,
biz_app VARCHAR(255) NULL DEFAULT NULL,
task_deal_url VARCHAR(255) NULL DEFAULT NULL,
process_info_url VARCHAR(255) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NULL DEFAULT NULL,
timer_server VARCHAR(64) NULL DEFAULT NULL,
server_ip VARCHAR(64) NULL DEFAULT NULL,
jmx_service_url VARCHAR(255) NULL DEFAULT NULL,
runtime_env VARCHAR(30) NULL DEFAULT NULL,
PRIMARY KEY (id)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=1178002


CREATE TABLE kongur_definition (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
definition_key VARCHAR(255) NOT NULL,
alias_name VARCHAR(255) NULL DEFAULT NULL,
version INT(11) NOT NULL,
key_version VARCHAR(255) NOT NULL,
is_default TINYINT(4) NOT NULL,
state VARCHAR(20) NOT NULL,
lob_id BIGINT(20) NULL DEFAULT NULL,
biz_app VARCHAR(255) NOT NULL,
biz_module VARCHAR(255) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NOT NULL,
create_user_id BIGINT(20) NULL DEFAULT NULL,
create_user_name VARCHAR(80) NULL DEFAULT NULL,
runtime_env VARCHAR(30) NULL DEFAULT NULL,
PRIMARY KEY (id),
INDEX idx_kondef_bizapp (biz_app),
INDEX idx_kondef_dkey (definition_key(30), version, biz_app(30)),
INDEX idx_kondef_kversion (key_version(30))
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=1152004


CREATE TABLE kongur_dschedule_node (
id BIGINT(20) UNSIGNED NOT NULL,
biz_app VARCHAR(255) NULL DEFAULT NULL,
process_instance_id BIGINT(20) NULL DEFAULT NULL,
current_execute_domain VARCHAR(255) NULL DEFAULT NULL,
current_execute_node VARCHAR(255) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NULL DEFAULT NULL,
runtime_env VARCHAR(30) NULL DEFAULT NULL,
state TINYINT(4) NULL DEFAULT NULL,
mod_num BIGINT(20) NULL DEFAULT NULL,
PRIMARY KEY (id),
INDEX idx_node_bizapp (biz_app(30)),
INDEX idx_node_domain (current_execute_domain(30))
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT


CREATE TABLE kongur_exception (
id BIGINT(20) NOT NULL,
code VARCHAR(20) NULL DEFAULT NULL,
process_instance_id BIGINT(20) NULL DEFAULT NULL,
process_key VARCHAR(255) NULL DEFAULT NULL,
activity_name VARCHAR(255) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NULL DEFAULT NULL,
exception_stack TEXT NULL,
biz_app VARCHAR(255) NULL DEFAULT NULL,
biz_module VARCHAR(255) NULL DEFAULT NULL,
PRIMARY KEY (id),
INDEX idx_excep_pinsid (process_instance_id, activity_name(20))
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT


CREATE TABLE kongur_hist_activity (
id BIGINT(20) UNSIGNED NOT NULL,
activity_name VARCHAR(255) NULL DEFAULT NULL,
is_success TINYINT(4) NULL DEFAULT NULL,
process_instance_id BIGINT(20) NULL DEFAULT NULL,
state VARCHAR(20) NULL DEFAULT NULL,
gmt_create DATETIME NULL DEFAULT NULL,
gmt_modified DATETIME NULL DEFAULT NULL,
out_going VARCHAR(255) NULL DEFAULT NULL,
execute_domain VARCHAR(255) NULL DEFAULT NULL,
PRIMARY KEY (id)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT


CREATE TABLE kongur_hist_participation (
id BIGINT(20) UNSIGNED NOT NULL,
group_id BIGINT(20) NULL DEFAULT NULL COMMENT '组ID',
user_id BIGINT(20) NULL DEFAULT NULL COMMENT '用户ID',
user_name VARCHAR(80) NULL DEFAULT NULL COMMENT '用户名',
type VARCHAR(255) NULL DEFAULT NULL COMMENT '类型',
task_id BIGINT(20) NOT NULL COMMENT '任务编号',
gmt_create DATETIME NOT NULL COMMENT '创建时间',
gmt_modified DATETIME NULL DEFAULT NULL COMMENT '修改时间',
state TINYINT(4) NULL DEFAULT NULL COMMENT '状态位',
PRIMARY KEY (id)
)
COMMENT='历史任务处理人表'
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT


CREATE TABLE kongur_hist_task (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
name VARCHAR(255) NOT NULL,
alias_name VARCHAR(255) NULL DEFAULT NULL,
clazz VARCHAR(255) NOT NULL,
description VARCHAR(255) NULL DEFAULT NULL,
state VARCHAR(20) NOT NULL,
assignee VARCHAR(255) NULL DEFAULT NULL,
end_time DATETIME NULL DEFAULT NULL,
duration BIGINT(20) NOT NULL,
activity_name VARCHAR(255) NULL DEFAULT NULL,
process_instance_id BIGINT(20) NOT NULL,
process_key VARCHAR(255) NULL DEFAULT NULL,
user_id BIGINT(20) NULL DEFAULT NULL,
user_name VARCHAR(255) NULL DEFAULT NULL,
group_id BIGINT(20) NULL DEFAULT NULL,
group_name VARCHAR(255) NULL DEFAULT NULL,
deal_result VARCHAR(255) NULL DEFAULT NULL,
biz_app VARCHAR(255) NOT NULL,
biz_module VARCHAR(255) NULL DEFAULT NULL,
user_sys VARCHAR(20) NULL DEFAULT NULL,
process_create_user_id BIGINT(20) NULL DEFAULT NULL,
process_create_user_name VARCHAR(80) NULL DEFAULT NULL,
assign_user_id BIGINT(20) NULL DEFAULT NULL,
assign_user_name VARCHAR(80) NULL DEFAULT NULL,
assign_time DATETIME NULL DEFAULT NULL,
type VARCHAR(20) NOT NULL,
update_user_id BIGINT(20) NULL DEFAULT NULL,
update_user_name VARCHAR(80) NULL DEFAULT NULL,
update_desc VARCHAR(255) NULL DEFAULT NULL,
transition_to VARCHAR(255) NULL DEFAULT NULL,
parent_task_id BIGINT(20) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NOT NULL,
biz_info VARCHAR(255) NULL DEFAULT NULL,
PRIMARY KEY (id),
INDEX idx_khtask_pinstid (process_instance_id)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=3116003


CREATE TABLE kongur_hist_var (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
clazz VARCHAR(80) NOT NULL,
var_key VARCHAR(255) NOT NULL,
converter VARCHAR(255) NULL DEFAULT NULL,
process_instance_id BIGINT(20) NOT NULL,
task_id BIGINT(20) NULL DEFAULT NULL,
date_value DATETIME NULL DEFAULT NULL,
double_value DOUBLE NULL DEFAULT NULL,
long_value BIGINT(20) NULL DEFAULT NULL,
string_value VARCHAR(255) NULL DEFAULT NULL,
text_value TEXT NULL,
lob_id BIGINT(20) NULL DEFAULT NULL,
biz_app VARCHAR(255) NOT NULL,
biz_module VARCHAR(255) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NOT NULL,
PRIMARY KEY (id),
INDEX idx_khistvar_pinstid (process_instance_id)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=3593006


CREATE TABLE kongur_hist_var_trace (
id BIGINT(20) UNSIGNED NOT NULL,
process_instance_id BIGINT(20) NULL DEFAULT NULL,
process_key VARCHAR(255) NULL DEFAULT NULL,
activity_id BIGINT(20) NULL DEFAULT NULL,
activity_name VARCHAR(255) NULL DEFAULT NULL,
variables TEXT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NULL DEFAULT NULL,
PRIMARY KEY (id)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT


CREATE TABLE kongur_hist_webpage (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
name VARCHAR(255) NOT NULL,
alias_name VARCHAR(255) NULL DEFAULT NULL,
url VARCHAR(255) NULL DEFAULT NULL,
process_instance_id BIGINT(20) NULL DEFAULT NULL,
state VARCHAR(80) NOT NULL,
end_time DATETIME NULL DEFAULT NULL,
biz_app VARCHAR(255) NOT NULL,
biz_module VARCHAR(255) NULL DEFAULT NULL,
deal_result VARCHAR(255) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NOT NULL,
PRIMARY KEY (id),
INDEX idx_konwebpage_pid (process_instance_id, biz_app(30))
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT


CREATE TABLE kongur_job (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
process_instance_id BIGINT(20) NULL DEFAULT NULL,
process_key VARCHAR(255) NULL DEFAULT NULL,
task_id BIGINT(20) NULL DEFAULT NULL,
event_type VARCHAR(255) NOT NULL,
repeat_ VARCHAR(255) NULL DEFAULT NULL,
exp_time VARCHAR(255) NULL DEFAULT NULL,
end_time DATETIME NULL DEFAULT NULL,
duration BIGINT(20) NULL DEFAULT NULL,
biz_app VARCHAR(255) NULL DEFAULT NULL,
biz_module VARCHAR(255) NULL DEFAULT NULL,
state VARCHAR(80) NOT NULL,
ignore_weekend TINYINT(4) NULL DEFAULT NULL,
deal_strategy VARCHAR(255) NULL DEFAULT NULL,
transition_to VARCHAR(255) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NOT NULL,
duedate VARCHAR(255) NULL DEFAULT NULL,
duedatetime VARCHAR(255) NULL DEFAULT NULL,
node_name VARCHAR(255) NULL DEFAULT NULL,
repeat_times BIGINT(20) NULL DEFAULT NULL,
runtime_env VARCHAR(30) NULL DEFAULT NULL COMMENT '运行时',
PRIMARY KEY (id),
INDEX idx_konjob_etype (event_type(30), biz_app(30)),
INDEX idx_konjob_state (state(20)),
INDEX idx_kongur_job_tid (task_id, event_type)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=2515003


CREATE TABLE kongur_lob (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
blob_value BLOB NULL,
name VARCHAR(255) NOT NULL,
type VARCHAR(255) NULL DEFAULT NULL,
biz_app VARCHAR(255) NOT NULL,
biz_module VARCHAR(255) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NOT NULL,
PRIMARY KEY (id)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=2330002


CREATE TABLE kongur_participation (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
group_id BIGINT(20) NULL DEFAULT NULL,
user_id BIGINT(20) NULL DEFAULT NULL,
user_name VARCHAR(80) NULL DEFAULT NULL,
type VARCHAR(255) NOT NULL,
task_id BIGINT(20) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NOT NULL,
state TINYINT(4) NULL DEFAULT NULL,
PRIMARY KEY (id),
INDEX idx_kparti_taskid (task_id)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=2046003


CREATE TABLE kongur_process (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
name VARCHAR(255) NOT NULL,
alias_name VARCHAR(255) NULL DEFAULT NULL,
definition_id BIGINT(20) NOT NULL,
end_time DATETIME NULL DEFAULT NULL,
duration BIGINT(20) NULL DEFAULT NULL,
state VARCHAR(20) NOT NULL,
last_activity VARCHAR(255) NULL DEFAULT NULL,
currnt_activity VARCHAR(255) NULL DEFAULT NULL,
last_task_id BIGINT(20) NULL DEFAULT NULL,
last_deal_result VARCHAR(255) NULL DEFAULT NULL,
last_update_desc VARCHAR(255) NULL DEFAULT NULL,
biz_app VARCHAR(255) NOT NULL,
biz_module VARCHAR(255) NULL DEFAULT NULL,
update_user_id BIGINT(20) NULL DEFAULT NULL,
update_user_name VARCHAR(255) NULL DEFAULT NULL,
create_user_id BIGINT(20) NULL DEFAULT NULL,
create_user_name VARCHAR(255) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NOT NULL,
parent_id BIGINT(20) UNSIGNED NULL DEFAULT NULL,
is_hist TINYINT(4) UNSIGNED NULL DEFAULT NULL,
description VARCHAR(255) NULL DEFAULT NULL,
biz_info VARCHAR(255) NULL DEFAULT NULL,
biz_id VARCHAR(255) NULL DEFAULT NULL,
runtime_env VARCHAR(30) NULL DEFAULT NULL COMMENT '运行时',
PRIMARY KEY (id),
INDEX idx_konprocess_name (name(30), biz_app(30)),
INDEX idx_konprocess_cuid (create_user_id, alias_name(30)),
INDEX idx_konprocess_pid (parent_id)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=4238002


CREATE TABLE kongur_retry_record (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
process_instance_id BIGINT(20) NULL DEFAULT NULL,
process_key VARCHAR(255) NULL DEFAULT NULL,
biz_app VARCHAR(255) NULL DEFAULT NULL,
biz_module VARCHAR(255) NULL DEFAULT NULL,
activity_name VARCHAR(255) NULL DEFAULT NULL,
last_exception_stack MEDIUMTEXT NULL,
biz_id VARCHAR(255) NULL DEFAULT NULL,
is_resolve TINYINT(4) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NULL DEFAULT NULL,
retry_count TINYINT(8) NULL DEFAULT NULL,
PRIMARY KEY (id)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=1630002


CREATE TABLE kongur_sequence (
name VARCHAR(64) NOT NULL,
value BIGINT(20) NULL DEFAULT NULL,
gmt_modified DATETIME NOT NULL,
PRIMARY KEY (name)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT


CREATE TABLE kongur_stat (
id BIGINT(20) UNSIGNED NOT NULL,
config_id BIGINT(20) NOT NULL,
item_key VARCHAR(255) NOT NULL,
item_value INT(11) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
PRIMARY KEY (id)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT


CREATE TABLE kongur_stat_config (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
name VARCHAR(255) NULL DEFAULT NULL,
handler_class VARCHAR(255) NULL DEFAULT NULL,
status SMALLINT(2) NULL DEFAULT NULL,
repeat_ INT(11) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NULL DEFAULT NULL,
creator VARCHAR(80) NOT NULL,
modifier VARCHAR(80) NULL DEFAULT NULL,
invoke_time DATETIME NULL DEFAULT NULL,
report_id BIGINT(20) NULL DEFAULT NULL COMMENT '报告id',
PRIMARY KEY (id)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT


CREATE TABLE kongur_task (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
name VARCHAR(255) NOT NULL,
alias_name VARCHAR(255) NULL DEFAULT NULL,
clazz VARCHAR(255) NOT NULL,
description VARCHAR(255) NULL DEFAULT NULL,
state VARCHAR(20) NOT NULL,
assignee VARCHAR(255) NULL DEFAULT NULL,
end_time DATETIME NULL DEFAULT NULL,
duration BIGINT(20) NULL DEFAULT NULL,
activity_name VARCHAR(255) NULL DEFAULT NULL,
process_instance_id BIGINT(20) NOT NULL,
process_key VARCHAR(255) NOT NULL,
parent_task_id BIGINT(20) NULL DEFAULT NULL,
user_id BIGINT(20) NULL DEFAULT NULL,
user_name VARCHAR(80) NULL DEFAULT NULL,
group_id BIGINT(20) NULL DEFAULT NULL,
group_name VARCHAR(255) NULL DEFAULT NULL,
deal_result VARCHAR(255) NULL DEFAULT NULL,
biz_app VARCHAR(255) NOT NULL,
biz_module VARCHAR(255) NULL DEFAULT NULL,
user_sys VARCHAR(20) NULL DEFAULT NULL,
process_create_user_id BIGINT(20) NULL DEFAULT NULL,
process_create_user_name VARCHAR(80) NULL DEFAULT NULL,
assign_user_id BIGINT(20) NULL DEFAULT NULL,
assign_user_name VARCHAR(80) NULL DEFAULT NULL,
assign_time DATETIME NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NOT NULL,
type VARCHAR(20) NOT NULL,
update_user_id BIGINT(20) NULL DEFAULT NULL,
update_user_name VARCHAR(80) NULL DEFAULT NULL,
update_desc VARCHAR(255) NULL DEFAULT NULL,
transition_to VARCHAR(255) NULL DEFAULT NULL,
biz_info VARCHAR(255) NULL DEFAULT NULL,
PRIMARY KEY (id),
INDEX idx_kontask_name (name(30), biz_app(30)),
INDEX idx_kontask_pinstid (process_instance_id),
INDEX idx_kontask_userid (user_id, alias_name(30), process_key(30))
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=3118002


CREATE TABLE kongur_variable (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
clazz VARCHAR(80) NOT NULL,
var_key VARCHAR(255) NOT NULL,
converter VARCHAR(255) NULL DEFAULT NULL,
process_instance_id BIGINT(20) NULL DEFAULT NULL,
task_id BIGINT(20) NULL DEFAULT NULL,
date_value DATETIME NULL DEFAULT NULL,
double_value DOUBLE NULL DEFAULT NULL,
long_value BIGINT(20) NULL DEFAULT NULL,
string_value VARCHAR(255) NULL DEFAULT NULL,
text_value TEXT NULL,
lob_id BIGINT(20) NULL DEFAULT NULL,
biz_app VARCHAR(255) NOT NULL,
biz_module VARCHAR(255) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NOT NULL,
PRIMARY KEY (id),
INDEX idx_konvariable_varkey (var_key(30), biz_app(30), process_instance_id),
INDEX idx_konvariable_bizapp (biz_app(30)),
INDEX idx_konvariable_pinstid (process_instance_id, var_key(30))
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=3596003


CREATE TABLE kongur_variable_trace (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
process_instance_id BIGINT(20) NULL DEFAULT NULL,
process_key VARCHAR(255) NULL DEFAULT NULL,
activity_id BIGINT(20) NULL DEFAULT NULL,
activity_name VARCHAR(255) NULL DEFAULT NULL,
variables TEXT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NULL DEFAULT NULL,
PRIMARY KEY (id),
INDEX idx_trace_pid (process_instance_id)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=1712003


CREATE TABLE kongur_webpage (
id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
name VARCHAR(255) NOT NULL,
alias_name VARCHAR(255) NULL DEFAULT NULL,
url VARCHAR(255) NULL DEFAULT NULL,
process_instance_id BIGINT(20) NULL DEFAULT NULL,
state VARCHAR(80) NOT NULL,
end_time DATETIME NULL DEFAULT NULL,
biz_app VARCHAR(255) NOT NULL,
biz_module VARCHAR(255) NULL DEFAULT NULL,
deal_result VARCHAR(255) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NOT NULL,
PRIMARY KEY (id),
INDEX idx_konwebpage_pid (process_instance_id, biz_app(30)),
INDEX idx_konwebpage_state (state(30), gmt_create)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT


CREATE TABLE pamirs_schedule_queue (
id BIGINT(20) NOT NULL AUTO_INCREMENT,
task_type VARCHAR(50) NOT NULL,
queue_id VARCHAR(50) NULL DEFAULT NULL,
cur_server VARCHAR(100) NULL DEFAULT NULL,
req_server VARCHAR(100) NULL DEFAULT NULL,
gmt_create DATETIME NULL DEFAULT NULL,
gmt_modified DATETIME NULL DEFAULT NULL,
own_sign VARCHAR(50) NULL DEFAULT NULL COMMENT '环境;例如:开发、测试、预发、线上。缺省BASE',
base_task_type VARCHAR(50) NULL DEFAULT NULL COMMENT '基础任务类型',
PRIMARY KEY (id)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=2979040374


CREATE TABLE pamirs_schedule_server (
id BIGINT(20) NOT NULL AUTO_INCREMENT,
uuid VARCHAR(100) NOT NULL,
task_type VARCHAR(50) NULL DEFAULT NULL,
ip VARCHAR(50) NULL DEFAULT NULL,
host_name VARCHAR(50) NULL DEFAULT NULL,
manager_port INT(11) NULL DEFAULT NULL,
thread_num SMALLINT(6) NULL DEFAULT NULL,
register_time DATETIME NOT NULL,
heartbeat_time DATETIME NOT NULL,
version INT(11) NULL DEFAULT NULL,
dealinfo_desc VARCHAR(1000) NULL DEFAULT NULL,
jmx_url VARCHAR(200) NULL DEFAULT NULL,
next_run_start_time VARCHAR(100) NULL DEFAULT NULL,
next_run_end_time VARCHAR(100) NULL DEFAULT NULL,
gmt_create DATETIME NULL DEFAULT NULL,
gmt_modified DATETIME NULL DEFAULT NULL,
own_sign VARCHAR(50) NULL DEFAULT NULL COMMENT '环境;例如:开发、测试、预发、线上。缺省BASE',
base_task_type VARCHAR(50) NULL DEFAULT NULL COMMENT '基础任务类型',
PRIMARY KEY (id)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=13032787237827


CREATE TABLE pamirs_schedule_server_his (
id BIGINT(20) NOT NULL,
uuid VARCHAR(100) NOT NULL,
task_type VARCHAR(50) NOT NULL,
ip VARCHAR(50) NOT NULL,
host_name VARCHAR(50) NOT NULL,
manager_port BIGINT(20) NOT NULL,
thread_num BIGINT(20) NOT NULL,
register_time DATETIME NOT NULL,
gmt_create DATETIME NOT NULL COMMENT '记录创建时间',
gmt_modified DATETIME NOT NULL COMMENT '记录最后修改时间',
heartbeat_time DATETIME NOT NULL,
version BIGINT(20) NOT NULL,
jmx_url VARCHAR(200) NULL DEFAULT NULL,
dealinfo_desc VARCHAR(1000) NULL DEFAULT NULL,
next_run_start_time VARCHAR(100) NULL DEFAULT NULL,
next_run_end_time VARCHAR(100) NULL DEFAULT NULL,
own_sign VARCHAR(50) NULL DEFAULT NULL,
base_task_type VARCHAR(50) NULL DEFAULT NULL,
id2 BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
PRIMARY KEY (id2)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=7043


CREATE TABLE pamirs_schedule_tasktrun (
id BIGINT(20) NOT NULL AUTO_INCREMENT,
task_type VARCHAR(100) NOT NULL COMMENT '任务类型',
own_sign VARCHAR(50) NULL DEFAULT NULL COMMENT '环境;例如:开发、测试、预发、线上。缺省BASE',
base_task_type VARCHAR(50) NULL DEFAULT NULL COMMENT '基础任务类型',
last_assign_time DATETIME NULL DEFAULT NULL COMMENT '最近一次任务分配时间',
last_assign_uuid VARCHAR(100) NULL DEFAULT NULL COMMENT '最近一次进行任务分配的服务器',
gmt_create DATETIME NOT NULL COMMENT '创建时间',
gmt_modified DATETIME NOT NULL COMMENT '修改时间',
PRIMARY KEY (id)
)
COMMENT='流程统计配置'
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT
AUTO_INCREMENT=2503219035


CREATE TABLE pamirs_schedule_tasktype (
task_type VARCHAR(100) NOT NULL,
last_assign_time DATETIME NULL DEFAULT NULL,
last_assign_uuid VARCHAR(100) NULL DEFAULT NULL,
heartbeat_rate INT(11) NULL DEFAULT NULL,
judge_dead_interval INT(11) NULL DEFAULT NULL,
thread_number INT(11) NULL DEFAULT NULL,
execute_number INT(11) NULL DEFAULT NULL,
fetch_number INT(11) NULL DEFAULT NULL,
sleep_time_nodata FLOAT NULL DEFAULT NULL,
permit_run_start_time VARCHAR(100) NULL DEFAULT NULL,
permit_run_end_time VARCHAR(100) NULL DEFAULT NULL,
processor_type VARCHAR(20) NULL DEFAULT NULL,
id BIGINT(20) NULL DEFAULT NULL,
gmt_create DATETIME NOT NULL,
gmt_modified DATETIME NULL DEFAULT NULL,
sleep_time_interval FLOAT NULL DEFAULT NULL,
deal_bean_name VARCHAR(100) NULL DEFAULT NULL COMMENT '处理任务Bean的名称,Spring中的配置',
expire_own_sign_interval INT(11) NULL DEFAULT NULL COMMENT '清除过期环境数据的时间间隔,单位是天',
PRIMARY KEY (task_type)
)
COLLATE='gbk_chinese_ci'
ENGINE=InnoDB
ROW_FORMAT=DEFAULT


Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment