|
@@ -124,10 +124,13 @@ public class BpmProcessConfigurationServiceImpl implements IBpmProcessConfigurat
|
|
|
AjaxResult ajaxResult = responseEntity.getBody();
|
|
|
List<String> tableNameList = (List<String>) ajaxResult.get("data");
|
|
|
nodeVo.getTableNameList().stream().filter(tableName -> !tableNameList.contains(tableName)).collect(Collectors.toList());
|
|
|
+ String addField = ",task_key varchar(64) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT '' COMMENT '任务编码'," +
|
|
|
+ "task_node_key varchar(64) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT '' COMMENT '任务节点编码') ENGINE=InnoDB";
|
|
|
// 新建流程节点所需数据表
|
|
|
for (String tableName : nodeVo.getTableNameList()){
|
|
|
String createTableSql = commonService.selectTableSql(tableName).get("create table");
|
|
|
createTableSql = createTableSql.replace("CREATE TABLE","CREATE TABLE IF NOT EXISTS {DBNAME}.");
|
|
|
+ createTableSql = createTableSql.replace(") ENGINE=InnoDB",addField);
|
|
|
try {
|
|
|
commonService.executeSql(createTableSql);
|
|
|
}catch (Exception e){
|
|
@@ -162,10 +165,13 @@ public class BpmProcessConfigurationServiceImpl implements IBpmProcessConfigurat
|
|
|
AjaxResult ajaxResult = responseEntity.getBody();
|
|
|
List<String> tableNameList = (List<String>) ajaxResult.get("data");
|
|
|
nodeVo.getTableNameList().stream().filter(tableName -> !tableNameList.contains(tableName)).collect(Collectors.toList());
|
|
|
+ String addField = ",task_key varchar(64) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT '' COMMENT '任务编码'," +
|
|
|
+ "task_node_key varchar(64) CHARACTER SET utf8 COLLATE utf8_bin NULL DEFAULT '' COMMENT '任务节点编码') ENGINE=InnoDB";
|
|
|
// 新建流程节点所需数据表
|
|
|
for (String tableName : nodeVo.getTableNameList()){
|
|
|
String createTableSql = commonService.selectTableSql(tableName).get("create table");
|
|
|
createTableSql = createTableSql.replace("CREATE TABLE","CREATE TABLE IF NOT EXISTS {DBNAME}.");
|
|
|
+ createTableSql = createTableSql.replace(") ENGINE=InnoDB",addField);
|
|
|
try {
|
|
|
commonService.executeSql(createTableSql);
|
|
|
}catch (Exception e){
|