package jnpf.base.util;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.dynamic.datasource.annotation.DSTransactional;
|
import jnpf.base.UserInfo;
|
import jnpf.base.entity.VisualdevEntity;
|
import jnpf.base.mapper.FlowFormDataMapper;
|
import jnpf.base.model.ColumnDataModel;
|
import jnpf.base.model.OnlineInfoModel;
|
import jnpf.base.model.VisualConst;
|
import jnpf.base.model.VisualDevJsonModel;
|
import jnpf.base.model.flow.DataModel;
|
import jnpf.base.model.form.ModuleFormModel;
|
import jnpf.config.ConfigValueUtil;
|
import jnpf.constant.MsgCode;
|
import jnpf.database.model.dbtable.JdbcTableModel;
|
import jnpf.database.model.entity.DbLinkEntity;
|
import jnpf.database.util.ConnUtil;
|
import jnpf.database.util.DbTypeUtil;
|
import jnpf.database.util.DynamicDataSourceUtil;
|
import jnpf.database.util.TenantDataSourceUtil;
|
import jnpf.exception.DataException;
|
import jnpf.exception.WorkFlowException;
|
import jnpf.model.visualJson.*;
|
import jnpf.model.visualJson.analysis.*;
|
import jnpf.permission.entity.OrganizeEntity;
|
import jnpf.permission.entity.UserEntity;
|
import jnpf.permissions.PermissionInterfaceImpl;
|
import jnpf.util.*;
|
import jnpf.util.visiual.JnpfKeyConsts;
|
import lombok.Cleanup;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.collections4.CollectionUtils;
|
import org.apache.commons.collections4.MapUtils;
|
import org.apache.commons.collections4.map.CaseInsensitiveMap;
|
import org.mybatis.dynamic.sql.AndOrCriteriaGroup;
|
import org.mybatis.dynamic.sql.BasicColumn;
|
import org.mybatis.dynamic.sql.SqlBuilder;
|
import org.mybatis.dynamic.sql.SqlTable;
|
import org.mybatis.dynamic.sql.delete.render.DeleteStatementProvider;
|
import org.mybatis.dynamic.sql.insert.GeneralInsertDSL;
|
import org.mybatis.dynamic.sql.insert.render.GeneralInsertStatementProvider;
|
import org.mybatis.dynamic.sql.render.RenderingStrategies;
|
import org.mybatis.dynamic.sql.select.QueryExpressionDSL;
|
import org.mybatis.dynamic.sql.select.SelectModel;
|
import org.mybatis.dynamic.sql.select.render.SelectStatementProvider;
|
import org.mybatis.dynamic.sql.update.UpdateDSL;
|
import org.mybatis.dynamic.sql.update.UpdateModel;
|
import org.mybatis.dynamic.sql.update.render.UpdateStatementProvider;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.math.BigDecimal;
|
import java.sql.Connection;
|
import java.sql.SQLException;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
@Component
|
@Slf4j
|
public class FlowFormDataUtil {
|
|
@Autowired
|
private ConfigValueUtil configValueUtil;
|
@Autowired
|
private ServiceBaseUtil serviceUtil;
|
@Autowired
|
private FlowFormDataMapper flowFormDataMapper;
|
@Autowired
|
private FormInfoUtils formInfoUtils;
|
@Autowired
|
private VisualBillUtil visualBillUtil;
|
|
/**
|
* 从数据库取表主键
|
*
|
* @param conn
|
* @param tableName 表名
|
* @return
|
*/
|
public String getTableKey(Connection conn, String tableName) throws SQLException {
|
String pKeyName = JdbcTableModel.getPrimaryExculde(conn, tableName, configValueUtil.getMultiTenantColumn());
|
if (StringUtil.isEmpty(pKeyName)) {
|
pKeyName = TableFeildsEnum.FID.getField();
|
}
|
String databaseProductName = conn.getMetaData().getDatabaseProductName().trim();
|
if (DbTypeUtil.needToUpperCase(databaseProductName)) {
|
pKeyName = pKeyName.toUpperCase();
|
}
|
return pKeyName;
|
}
|
|
/**
|
* 从配置取主键
|
*
|
* @param tableModel
|
* @return String
|
*/
|
public String getKey(TableModel tableModel, String databaseProductName) {
|
boolean toUpperCase = false;
|
if (StringUtil.isNotEmpty(databaseProductName)) {
|
if (DbTypeUtil.needToUpperCase(databaseProductName)) {
|
toUpperCase = !toUpperCase;
|
}
|
}
|
String pKeyName = toUpperCase ? TableFeildsEnum.FID.getField().toUpperCase() : TableFeildsEnum.FID.getField();
|
if (tableModel != null && tableModel.getFields() != null) {
|
TableFields tableFields = tableModel.getFields().stream().filter(t -> Objects.equals(t.getPrimaryKey(), 1)
|
&& !t.getField().toLowerCase().contains(TableFeildsEnum.TENANTID.getField())).findFirst().orElse(null);
|
pKeyName = Objects.nonNull(tableFields) ? tableFields.getField() : pKeyName;
|
}
|
return pKeyName;
|
}
|
|
/**
|
* 获取流程任务id原字段 flowTaskId
|
*
|
* @param tableModel
|
* @param databaseProductName
|
* @return
|
*/
|
public String getFlowTaskId(TableModel tableModel, String databaseProductName) {
|
boolean toUpperCase = false;
|
if (StringUtil.isNotEmpty(databaseProductName)) {
|
if (DbTypeUtil.needToUpperCase(databaseProductName)) {
|
toUpperCase = !toUpperCase;
|
}
|
}
|
String pKeyName = toUpperCase ? TableFeildsEnum.FLOWTASKID.getField().toUpperCase() : TableFeildsEnum.FLOWTASKID.getField();
|
if (tableModel != null && tableModel.getFields() != null) {
|
TableFields tableFields = tableModel.getFields().stream().filter(t ->
|
t.getField().toLowerCase().contains(TableFeildsEnum.FLOWTASKID.getField())).findFirst().orElse(null);
|
pKeyName = Objects.nonNull(tableFields) ? tableFields.getField() : pKeyName;
|
}
|
return pKeyName;
|
}
|
|
//---------------------------------------------信息---------------------------------------------
|
|
/**
|
* 获取编辑页数据
|
*
|
* @param visualdevEntity
|
* @param id
|
* @return
|
*/
|
public Map<String, Object> getEditDataInfo(VisualdevEntity visualdevEntity, String id, OnlineInfoModel infoModel) {
|
Map<String, Object> allDataMap = new HashMap<>();
|
|
FormDataModel formData = JsonUtil.getJsonToBean(visualdevEntity.getFormData(), FormDataModel.class);
|
Boolean logicalDelete = formData.getLogicalDelete();
|
|
//权限参数
|
ColumnDataModel columnDataModel = JsonUtil.getJsonToBean(visualdevEntity.getColumnData(), ColumnDataModel.class);
|
Boolean needP = false;
|
List<String> formPerList = new ArrayList<>();
|
if (columnDataModel != null && StringUtil.isNotEmpty(infoModel.getMenuId())) {
|
needP = columnDataModel.getUseFormPermission();
|
Map<String, Object> pMap = PermissionInterfaceImpl.getFormMap();
|
if (pMap.get(infoModel.getMenuId()) != null) {
|
formPerList = JsonUtil.getJsonToList(pMap.get(infoModel.getMenuId()), ModuleFormModel.class).stream()
|
.map(ModuleFormModel::getEnCode).collect(Collectors.toList());
|
}
|
}
|
|
Object mainId = id;
|
boolean autoIncrement = Objects.equals(formData.getPrimaryKeyPolicy(), 2);
|
if (autoIncrement) {
|
mainId = Long.parseLong(id);
|
}
|
//是否开启并发锁
|
String version = "";
|
if (formData.getConcurrencyLock()) {
|
//查询
|
version = TableFeildsEnum.VERSION.getField();
|
}
|
|
List<FieLdsModel> list = JsonUtil.getJsonToList(formData.getFields(), FieLdsModel.class);
|
List<TableModel> tableModelList = JsonUtil.getJsonToList(visualdevEntity.getVisualTables(), TableModel.class);
|
RecursionForm recursionForm = new RecursionForm();
|
recursionForm.setList(list);
|
recursionForm.setTableModelList(tableModelList);
|
List<FormAllModel> formAllModel = new ArrayList<>();
|
FormCloumnUtil.recursionForm(recursionForm, formAllModel);
|
//form的属性
|
List<FormAllModel> mast = formAllModel.stream().filter(t -> FormEnum.mast.getMessage().equals(t.getJnpfKey())).collect(Collectors.toList());
|
List<FormAllModel> table = formAllModel.stream().filter(t -> FormEnum.table.getMessage().equals(t.getJnpfKey())).collect(Collectors.toList());
|
List<FormAllModel> mastTable = formAllModel.stream().filter(t -> FormEnum.mastTable.getMessage().equals(t.getJnpfKey())).collect(Collectors.toList());
|
|
TableModel mainTable = tableModelList.stream().filter(t -> t.getTypeId().equals("1")).findFirst().orElse(null);
|
|
DbLinkEntity linkEntity = serviceUtil.getDbLink(visualdevEntity.getDbLinkId());
|
try {
|
DynamicDataSourceUtil.switchToDataSource(linkEntity);
|
@Cleanup Connection conn = ConnUtil.getConnOrDefault(linkEntity);
|
String dbType = conn.getMetaData().getDatabaseProductName();
|
String pKeyName = this.getKey(mainTable, dbType);
|
SqlTable mainSqlTable = SqlTable.of(mainTable.getTable());
|
|
String flowTaskId = this.getFlowTaskId(mainTable, dbType);
|
|
List<AndOrCriteriaGroup> groupList = new ArrayList<>();
|
groupList.add(SqlBuilder.or(mainSqlTable.column(flowTaskId), SqlBuilder.isEqualTo(mainId.toString())));
|
|
SelectStatementProvider render = SqlBuilder.select(mainSqlTable.allColumns())
|
.from(mainSqlTable)
|
.where(mainSqlTable.column(pKeyName), SqlBuilder.isEqualTo(mainId), groupList)
|
.build().render(RenderingStrategies.MYBATIS3);
|
Map<String, Object> mainAllMap = Optional.ofNullable(flowFormDataMapper.selectOneMappedRow(render)).orElse(new HashMap<>());
|
if (mainAllMap.size() == 0) {
|
return new HashMap<>();
|
}
|
//主表
|
List<String> mainTableFields = mast.stream().filter(m -> StringUtil.isNotEmpty(m.getFormColumnModel().getFieLdsModel().getVModel()))
|
.map(s -> s.getFormColumnModel().getFieLdsModel().getVModel()).collect(Collectors.toList());
|
//开启权限移除字段
|
if (needP) {
|
if (CollectionUtils.isEmpty(formPerList)) {
|
mainTableFields = Collections.EMPTY_LIST;
|
} else {
|
List<String> newList = new ArrayList<>();
|
for (String item : mainTableFields) {
|
if (formPerList.contains(item)) {
|
newList.add(item);
|
}
|
}
|
mainTableFields = newList;
|
}
|
}
|
if (StringUtil.isNotEmpty(version)) {
|
mainTableFields.add(version);
|
}
|
mainTableFields.add(pKeyName);
|
mainTableFields.add(flowTaskId);
|
List<BasicColumn> mainTableBasicColumn = mainTableFields.stream().map(m -> SqlTable.of(mainTable.getTable()).column(m)).collect(Collectors.toList());
|
SelectStatementProvider mainRender = SqlBuilder.select(mainTableBasicColumn)
|
.from(mainSqlTable)
|
.where(mainSqlTable.column(pKeyName), SqlBuilder.isEqualTo(mainId), groupList)
|
.build().render(RenderingStrategies.MYBATIS3);
|
Map<String, Object> mainMap = flowFormDataMapper.selectOneMappedRow(mainRender);
|
if (ObjectUtil.isNotEmpty(mainMap)) {
|
//转换主表里的数据
|
List<FieLdsModel> mainFieldList = mast.stream().filter(m -> StringUtil.isNotEmpty(m.getFormColumnModel().getFieLdsModel().getVModel()))
|
.map(t -> t.getFormColumnModel().getFieLdsModel()).collect(Collectors.toList());
|
mainMap = formInfoUtils.swapDataInfoType(mainFieldList, mainMap);
|
allDataMap.putAll(mainMap);
|
allDataMap.put(FlowFormConstant.FLOWTASKID, mainMap.get(flowTaskId));
|
}
|
|
//副表
|
Map<String, List<FormMastTableModel>> groupByTableNames = mastTable.stream().map(mt -> mt.getFormMastTableModel()).collect(Collectors.groupingBy(ma -> ma.getTable()));
|
Iterator<Map.Entry<String, List<FormMastTableModel>>> entryIterator = groupByTableNames.entrySet().iterator();
|
while (entryIterator.hasNext()) {
|
Map.Entry<String, List<FormMastTableModel>> next = entryIterator.next();
|
String childTableName = next.getKey();
|
List<FormMastTableModel> childMastTableList = next.getValue();
|
//开启权限移除字段
|
if (needP) {
|
if (CollectionUtils.isEmpty(formPerList)) {
|
childMastTableList = Collections.EMPTY_LIST;
|
} else {
|
List<FormMastTableModel> newList = new ArrayList<>();
|
for (FormMastTableModel item : childMastTableList) {
|
if (formPerList.contains(item.getVModel())) {
|
newList.add(item);
|
}
|
}
|
childMastTableList = newList;
|
}
|
}
|
TableModel childTableModel = tableModelList.stream().filter(t -> t.getTable().equals(childTableName)).findFirst().orElse(null);
|
SqlTable mastSqlTable = SqlTable.of(childTableName);
|
List<BasicColumn> mastTableBasicColumn = childMastTableList.stream().filter(m -> StringUtil.isNotEmpty(m.getField()))
|
.map(m -> mastSqlTable.column(m.getField())).collect(Collectors.toList());
|
//添加副表关联字段，不然数据会空没有字段名称
|
mastTableBasicColumn.add(mastSqlTable.column(childTableModel.getTableField()));
|
//主表主键
|
String mainField = childTableModel.getRelationField();
|
Object mainValue = new CaseInsensitiveMap(mainAllMap).get(mainField);
|
//子表外键
|
String childFoIdFiled = childTableModel.getTableField();
|
//外键字段是否varchar转换
|
TableFields fogIdField = childTableModel.getFields().stream().filter(t -> t.getField().equals(childFoIdFiled)).findFirst().orElse(null);
|
boolean fogIdTypeString = Objects.nonNull(fogIdField) ? fogIdField.getDataType().toLowerCase().contains("varchar") : false;
|
if (fogIdTypeString) {
|
mainValue = mainValue.toString();
|
}
|
|
QueryExpressionDSL<SelectModel>.QueryExpressionWhereBuilder mastWhere = SqlBuilder.select(mastTableBasicColumn).from(mastSqlTable).where();
|
mastWhere.and(mastSqlTable.column(childFoIdFiled), SqlBuilder.isEqualTo(mainValue));
|
//逻辑删除不展示
|
if (logicalDelete) {
|
mastWhere.and(mastSqlTable.column(TableFeildsEnum.DELETEMARK.getField()), SqlBuilder.isNull());
|
}
|
SelectStatementProvider mastRender = mastWhere.build().render(RenderingStrategies.MYBATIS3);
|
List<Map<String, Object>> childMapList = flowFormDataMapper.selectManyMappedRows(mastRender);
|
if (CollectionUtils.isNotEmpty(childMapList)) {
|
Map<String, Object> soloDataMap = childMapList.get(0);
|
Map<String, Object> renameKeyMap = new HashMap<>();
|
for (Map.Entry entry : soloDataMap.entrySet()) {
|
FormMastTableModel model = childMastTableList.stream().filter(child -> child.getField().equalsIgnoreCase(String.valueOf(entry.getKey()))).findFirst().orElse(null);
|
if (model != null) renameKeyMap.put(model.getVModel(), entry.getValue());
|
}
|
List<FieLdsModel> columnChildFields = childMastTableList.stream().map(cl -> cl.getMastTable().getFieLdsModel()).collect(Collectors.toList());
|
renameKeyMap = formInfoUtils.swapDataInfoType(columnChildFields, renameKeyMap);
|
allDataMap.putAll(renameKeyMap);
|
}
|
}
|
|
//设计子表
|
Boolean finalNeedP = needP;
|
List<String> finalFormPerList = formPerList;
|
table.stream().map(t -> t.getChildList()).forEach(
|
t1 -> {
|
try {
|
String childTableName = t1.getTableName();
|
TableModel tableModel = tableModelList.stream().filter(tm -> tm.getTable().equals(childTableName)).findFirst().orElse(null);
|
SqlTable childSqlTable = SqlTable.of(childTableName);
|
List<FormColumnModel> chilFieldList = t1.getChildList().stream().filter(t2 -> StringUtil.isNotEmpty(t2.getFieLdsModel().getVModel())).collect(Collectors.toList());
|
String tableModelName = t1.getTableModel();
|
//开启权限移除字段
|
if (finalNeedP) {
|
if (CollectionUtils.isEmpty(finalFormPerList)) {
|
chilFieldList = Collections.EMPTY_LIST;
|
} else {
|
List<FormColumnModel> newList = new ArrayList<>();
|
for (FormColumnModel item : chilFieldList) {
|
if (finalFormPerList.contains(tableModelName + "-" + item.getFieLdsModel().getVModel())) {
|
newList.add(item);
|
}
|
}
|
chilFieldList = newList;
|
}
|
}
|
List<BasicColumn> childFields = chilFieldList.stream().map(t2 -> childSqlTable.column(t2.getFieLdsModel().getVModel())).collect(Collectors.toList());
|
childFields.add(childSqlTable.column(tableModel.getTableField()));
|
String childKeyName = this.getKey(tableModel, dbType);
|
childFields.add(childSqlTable.column(childKeyName));
|
//主表主键
|
String mainField = tableModel.getRelationField();
|
Object mainValue = new CaseInsensitiveMap(mainAllMap).get(mainField);
|
//子表外键
|
String childFoIdFiled = tableModel.getTableField();
|
TableFields fogIdField = tableModel.getFields().stream().filter(t -> t.getField().equals(childFoIdFiled)).findFirst().orElse(null);
|
if (VisualConst.DB_INT_ALL.contains(fogIdField.getField().toLowerCase())) {
|
mainValue = Long.parseLong(String.valueOf(mainValue));
|
}
|
|
QueryExpressionDSL<SelectModel>.QueryExpressionWhereBuilder childWhere = SqlBuilder.select(childFields).from(childSqlTable).where();
|
childWhere.and(childSqlTable.column(childFoIdFiled), SqlBuilder.isEqualTo(mainValue));
|
//逻辑删除不展示
|
if (logicalDelete) {
|
childWhere.and(childSqlTable.column(TableFeildsEnum.DELETEMARK.getField()), SqlBuilder.isNull());
|
}
|
SelectStatementProvider childRender = childWhere.build().render(RenderingStrategies.MYBATIS3);
|
List<Map<String, Object>> childMapList = flowFormDataMapper.selectManyMappedRows(childRender);
|
if (ObjectUtil.isNotEmpty(childMapList)) {
|
List<FieLdsModel> childFieldModels = t1.getChildList().stream().map(t2 -> t2.getFieLdsModel()).collect(Collectors.toList());
|
childMapList = childMapList.stream().map(c1 -> {
|
try {
|
return formInfoUtils.swapDataInfoType(childFieldModels, c1);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return c1;
|
}).collect(Collectors.toList());
|
Map<String, Object> childMap = new HashMap<>(1);
|
childMap.put(t1.getTableModel(), childMapList);
|
allDataMap.putAll(childMap);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
);
|
for (String key : allDataMap.keySet()) {
|
if (pKeyName.equalsIgnoreCase(key)) {
|
allDataMap.put("id", allDataMap.get(key));
|
break;
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
DynamicDataSourceUtil.clearSwitchDataSource();
|
}
|
return allDataMap;
|
}
|
|
//---------------------------------------------新增---------------------------------------------
|
|
/**
|
* 新增数据处理
|
**/
|
@DSTransactional
|
public Map<String, Object> create(DataModel dataModel) throws WorkFlowException {
|
try {
|
//处理好的数据
|
Map<String, Object> result = this.createDataList(dataModel);
|
return result;
|
} catch (DataException dataException) {
|
throw new WorkFlowException(dataException.getMessage());
|
} catch (Exception e) {
|
//close
|
e.printStackTrace();
|
log.error("新增异常：{}", e.getMessage());
|
throw new WorkFlowException(MsgCode.FA028.get(), e.getMessage());
|
}
|
}
|
|
/**
|
* 新增数据
|
**/
|
public Map<String, Object> createDataList(DataModel dataModel) throws SQLException, DataException {
|
//处理好的数据
|
Map<String, Object> result = new HashMap<>(16);
|
List<TableModel> tableModelList = dataModel.getTableModelList();
|
List<FormAllModel> formAllModel = dataModel.getFormAllModel();
|
//有表数据处理
|
if (tableModelList.size() > 0) {
|
DbLinkEntity link = dataModel.getLink();
|
DynamicDataSourceUtil.switchToDataSource(link);
|
try {
|
@Cleanup Connection conn = ConnUtil.getConnOrDefault(link);
|
String dbType = conn.getMetaData().getDatabaseProductName().trim();
|
dataModel.setDbType(dbType);
|
//主表
|
this.createMast(formAllModel, dataModel, result);
|
//子表
|
this.createTable(formAllModel, dataModel, result);
|
//副表
|
this.createMastTable(formAllModel, dataModel, result);
|
} finally {
|
DynamicDataSourceUtil.clearSwitchDataSource();
|
}
|
} else {
|
//无表数据处理
|
result = this.createAll(dataModel, formAllModel);
|
}
|
return result;
|
}
|
|
/**
|
* 子表数据
|
**/
|
private void createTable(List<FormAllModel> formAllModel, DataModel dataModel, Map<String, Object> result) throws SQLException {
|
List<TableModel> tableModelList = dataModel.getTableModelList();
|
Map<String, Object> dataNewMap = dataModel.getDataNewMap();
|
boolean autoIncrement = Objects.equals(dataModel.getPrimaryKeyPolicy(), 2);
|
String flowId = "";
|
if (dataNewMap.get(FlowFormConstant.FLOWID) != null && StringUtil.isNotEmpty(dataNewMap.get(FlowFormConstant.FLOWID).toString())) {
|
flowId = dataNewMap.get(FlowFormConstant.FLOWID).toString();
|
}
|
|
UserEntity userEntity = dataModel.getUserEntity();
|
//子表
|
List<FormAllModel> tableForm = formAllModel.stream().filter(t -> FormEnum.table.getMessage().equals(t.getJnpfKey())).collect(Collectors.toList());
|
|
for (FormAllModel itemModel : tableForm) {
|
FormColumnTableModel childModel = itemModel.getChildList();
|
if (childModel.getDisabled()) continue;
|
String key = childModel.getTableModel();
|
String tableName = childModel.getTableName();
|
//子表数据
|
List<Map<String, Object>> chidList = dataNewMap.get(key) != null ? (List<Map<String, Object>>) dataNewMap.get(key) : new ArrayList<>();
|
List<FormColumnModel> formColumnModels = childModel.getChildList().stream().filter(g -> StringUtil.isNotEmpty(g.getFieLdsModel().getVModel())).collect(Collectors.toList());
|
// if (CollectionUtils.isEmpty(formColumnModels)) continue;
|
if (Objects.equals(childModel.getIsNumLimit(), true) && chidList.size() > childModel.getNumLimit()) {
|
throw new DataException(MsgCode.VS033.get(childModel.getLabel()));
|
}
|
|
//子表主键
|
TableModel tableModel = tableModelList.stream().filter(k -> k.getTable().equals(tableName)).findFirst().orElse(null);
|
String table = tableModel.getTable();
|
//子表主键
|
String childKeyName = this.getKey(tableModel, dataModel.getDbType());
|
|
//子表外键字段
|
String foreignKey = tableModel.getTableField();
|
TableFields foreignField = tableModel.getFields().stream().filter(t -> t.getField().equalsIgnoreCase(foreignKey)).findFirst().orElse(null);
|
if (foreignField == null) {
|
throw new SQLException(MsgCode.COD001.get());
|
}
|
//主表关联字段
|
Object foreignValue = dataNewMap.get(tableModel.getRelationField());
|
if (VisualConst.DB_INT_ALL.contains(foreignField.getDataType())) {
|
foreignValue = Long.parseLong(String.valueOf(foreignValue));
|
}
|
|
SqlTable sqlTable = SqlTable.of(table);
|
for (Map<String, Object> objectMap : chidList) {
|
if (StringUtil.isNotEmpty(flowId)) {
|
objectMap.put(FlowFormConstant.FLOWID, flowId);
|
}
|
GeneralInsertDSL generalInsertDSL = SqlBuilder.insertInto(sqlTable).set(sqlTable.column(foreignKey)).toValue(foreignValue);
|
for (FormColumnModel column : formColumnModels) {
|
FieLdsModel fieLdsModel = column.getFieLdsModel();
|
String childKey = fieLdsModel.getVModel();
|
//表单字段和外键字段重复不写入（写入外键值）
|
if (Objects.equals(foreignKey, childKey)) {
|
continue;
|
}
|
Object data = objectMap.get(childKey);
|
String fieldKey = fieLdsModel.getConfig().getParentVModel() + "-" + childKey;
|
//流程表单权限
|
if (CollectionUtils.isNotEmpty(dataModel.getFlowFormOperates())) {
|
boolean hasOperate = isHasOperate(dataModel, fieldKey);
|
if (!hasOperate) {
|
continue;
|
}
|
} else if (dataModel.getNeedPermission()) {
|
if (CollectionUtil.isNotEmpty(dataModel.getFormPerList())) {
|
if (!dataModel.getFormPerList().contains(fieldKey)) {
|
continue;
|
}
|
} else {
|
continue;
|
}
|
}
|
//处理系统自动生成
|
data = this.create(fieLdsModel, data, true, userEntity, dataModel.isLinkOpen());
|
data = visualBillUtil.getBillNumber(dataModel.getVisualId(), fieLdsModel, objectMap, data);
|
getDSL(sqlTable, null, generalInsertDSL, fieLdsModel.getFormat(), childKey, data);
|
}
|
if (!autoIncrement) {
|
generalInsertDSL = generalInsertDSL.set(sqlTable.column(childKeyName)).toValue(RandomUtil.uuId());
|
}
|
//租户信息
|
addTenantId(generalInsertDSL, sqlTable);
|
|
GeneralInsertStatementProvider insertRender = generalInsertDSL.build().render(RenderingStrategies.MYBATIS3);
|
flowFormDataMapper.generalInsert(insertRender);
|
}
|
}
|
}
|
|
/**
|
* 副表数据
|
**/
|
private void createMastTable(List<FormAllModel> formAllModel, DataModel dataModel, Map<String, Object> result) throws SQLException {
|
List<TableModel> tableModelList = dataModel.getTableModelList();
|
Map<String, Object> dataNewMap = dataModel.getDataNewMap();
|
Integer primaryKeyPolicy = dataModel.getPrimaryKeyPolicy();
|
|
UserEntity userEntity = dataModel.getUserEntity();
|
//副表
|
Map<String, List<FormAllModel>> mastTableAll = formAllModel.stream().filter(t -> FormEnum.mastTable.getMessage().equals(t.getJnpfKey())).collect(Collectors.groupingBy(e -> e.getFormMastTableModel().getTable()));
|
for (String key : mastTableAll.keySet()) {
|
Optional<TableModel> first = tableModelList.stream().filter(t -> t.getTable().equals(key)).findFirst();
|
if (!first.isPresent()) {
|
throw new SQLException(MsgCode.COD001.get());
|
}
|
TableModel tableModel = first.get();
|
String tableModelTable = tableModel.getTable();
|
String childKeyName = this.getKey(tableModel, dataModel.getDbType());
|
|
//副表外键字段
|
String foreignKey = tableModel.getTableField();
|
TableFields foreignField = tableModel.getFields().stream().filter(t -> t.getField().equalsIgnoreCase(foreignKey)).findFirst().orElse(null);
|
if (foreignField == null) {
|
throw new SQLException(MsgCode.COD001.get());
|
}
|
//主表关联字段
|
Object foreignValue = dataNewMap.get(tableModel.getRelationField());
|
if (VisualConst.DB_INT_ALL.contains(foreignField.getDataType())) {
|
foreignValue = Long.parseLong(String.valueOf(foreignValue));
|
}
|
|
List<FormAllModel> masTableList = mastTableAll.get(key);
|
SqlTable sqlTable = SqlTable.of(tableModelTable);
|
GeneralInsertDSL generalInsertDSL = SqlBuilder.insertInto(sqlTable).set(sqlTable.column(foreignKey)).toValue(foreignValue);
|
|
for (FormAllModel model : masTableList) {
|
FormMastTableModel formMastTableModel = model.getFormMastTableModel();
|
FormColumnModel mastTable = formMastTableModel.getMastTable();
|
FieLdsModel fieLdsModel = mastTable.getFieLdsModel();
|
String mostTableKey = fieLdsModel.getVModel();
|
String field = formMastTableModel.getField();
|
//表单字段和外键字段重复不写入（写入外键值）
|
if (StringUtil.isEmpty(mostTableKey) || Objects.equals(foreignKey, field)) {
|
continue;
|
}
|
Object data = dataNewMap.get(mostTableKey);
|
//流程表单权限
|
if (CollectionUtils.isNotEmpty(dataModel.getFlowFormOperates())) {
|
boolean hasOperate = isHasOperate(dataModel, mostTableKey);
|
if (!hasOperate) {
|
continue;
|
}
|
} else if (dataModel.getNeedPermission()) {
|
if (CollectionUtil.isNotEmpty(dataModel.getFormPerList())) {
|
if (!dataModel.getFormPerList().contains(mostTableKey)) {
|
continue;
|
}
|
} else {
|
continue;
|
}
|
}
|
//处理系统自动生成
|
data = this.create(fieLdsModel, data, true, userEntity, dataModel.isLinkOpen());
|
data = visualBillUtil.getBillNumber(dataModel.getVisualId(), fieLdsModel, dataNewMap, data);
|
//返回值
|
result.put(mostTableKey, data);
|
getDSL(sqlTable, null, generalInsertDSL, fieLdsModel.getFormat(), field, data);
|
}
|
//sql主键
|
if (primaryKeyPolicy == 1) {
|
generalInsertDSL = generalInsertDSL.set(sqlTable.column(childKeyName)).toValue(RandomUtil.uuId());
|
}
|
//租户信息
|
addTenantId(generalInsertDSL, sqlTable);
|
|
GeneralInsertStatementProvider insertRender = generalInsertDSL.build().render(RenderingStrategies.MYBATIS3);
|
flowFormDataMapper.generalInsert(insertRender);
|
}
|
}
|
|
/**
|
* 主表数据
|
**/
|
private void createMast(List<FormAllModel> formAllModel, DataModel dataModel, Map<String, Object> result) throws SQLException {
|
List<TableModel> tableModelList = dataModel.getTableModelList();
|
Map<String, Object> dataNewMap = dataModel.getDataNewMap();
|
Object mainId = dataModel.getMainId();
|
boolean autoIncrement = Objects.equals(dataModel.getPrimaryKeyPolicy(), 2);
|
if (autoIncrement) {
|
mainId = Long.parseLong(dataModel.getMainId());
|
}
|
UserEntity userEntity = dataModel.getUserEntity();
|
Optional<TableModel> first = tableModelList.stream().filter(t -> "1".equals(t.getTypeId())).findFirst();
|
if (!first.isPresent()) {
|
throw new SQLException(MsgCode.COD001.get());
|
}
|
TableModel tableModel = first.get();
|
String mastTableName = tableModel.getTable();
|
List<FormAllModel> mastForm = formAllModel.stream().filter(t -> FormEnum.mast.getMessage().equals(t.getJnpfKey())).filter(t -> StringUtil.isNotEmpty(t.getFormColumnModel().getFieLdsModel().getVModel())).collect(Collectors.toList());
|
//新增字段
|
String keyName = this.getKey(tableModel, dataModel.getDbType());
|
|
SqlTable sqlTable = SqlTable.of(mastTableName);
|
String flowTaskId = this.getFlowTaskId(tableModel, dataModel.getDbType());
|
GeneralInsertDSL generalInsertDSL = SqlBuilder.insertInto(sqlTable).set(sqlTable.column(keyName)).toValue(mainId)
|
.set(sqlTable.column(flowTaskId)).toValue(mainId.toString());
|
if (autoIncrement) {
|
generalInsertDSL = SqlBuilder.insertInto(sqlTable).set(sqlTable.column(flowTaskId)).toValue(mainId.toString());
|
}
|
|
for (FormAllModel model : mastForm) {
|
FieLdsModel fieLdsModel = model.getFormColumnModel().getFieLdsModel();
|
String field = fieLdsModel.getVModel();
|
Object data = dataNewMap.get(field);
|
data = data instanceof List ? JsonUtil.getObjectToString(data) : data;
|
//流程表单权限
|
if (CollectionUtils.isNotEmpty(dataModel.getFlowFormOperates())) {
|
boolean hasOperate = isHasOperate(dataModel, field);
|
if (!hasOperate) {
|
continue;
|
}
|
} else if (dataModel.getNeedPermission()) {
|
if (CollectionUtil.isNotEmpty(dataModel.getFormPerList())) {
|
if (!dataModel.getFormPerList().contains(field)) {
|
continue;
|
}
|
} else {
|
continue;
|
}
|
}
|
//处理系统自动生成
|
data = this.create(fieLdsModel, data, true, userEntity, dataModel.isLinkOpen());
|
data = visualBillUtil.getBillNumber(dataModel.getVisualId(), fieLdsModel, dataNewMap, data);
|
if (JnpfKeyConsts.BILLRULE.equals(fieLdsModel.getConfig().getJnpfKey())) dataNewMap.put(field, data);
|
getDSL(sqlTable, null, generalInsertDSL, fieLdsModel.getFormat(), field, data);
|
}
|
//判断是否开启锁
|
if (dataModel.getConcurrencyLock()) {
|
generalInsertDSL = generalInsertDSL.set(sqlTable.column(TableFeildsEnum.VERSION.getField())).toValue(dataNewMap.get(TableFeildsEnum.VERSION.getField()));
|
}
|
//添加流程引擎信息
|
if (dataNewMap.get(FlowFormConstant.FLOWID) != null && StringUtil.isNotEmpty(dataNewMap.get(FlowFormConstant.FLOWID).toString())) {
|
generalInsertDSL = generalInsertDSL.set(sqlTable.column(TableFeildsEnum.FLOWID.getField())).toValue(dataNewMap.get(FlowFormConstant.FLOWID));
|
}
|
//租户信息
|
addTenantId(generalInsertDSL, sqlTable);
|
|
GeneralInsertStatementProvider insertRender = generalInsertDSL.build().render(RenderingStrategies.MYBATIS3);
|
flowFormDataMapper.generalInsert(insertRender);
|
//设置实际主键id
|
getRealMainId(dataModel, tableModel, keyName, autoIncrement, mastTableName, mainId);
|
dataNewMap.put(keyName, dataModel.getMainId());
|
}
|
|
/**
|
* 获取实际主键id
|
*
|
* @param dataModel
|
* @param realIdKey 主表主键
|
* @param autoIncrement 自增设置id
|
* @param mastTableName
|
* @throws SQLException
|
*/
|
private void getRealMainId(DataModel dataModel, TableModel tableModel, String realIdKey, boolean autoIncrement, String mastTableName, Object flowTaskId) {
|
if (autoIncrement) {
|
String flowTaskKey = this.getFlowTaskId(tableModel, dataModel.getDbType());
|
List<String> mastFile = new ArrayList<>();
|
mastFile.add(flowTaskKey);
|
mastFile.add(realIdKey);
|
SqlTable mastSqlTable = SqlTable.of(mastTableName);
|
SelectStatementProvider mastRender = SqlBuilder.select(mastFile.stream().map(m -> mastSqlTable.column(m)).collect(Collectors.toList()))
|
.from(mastSqlTable)
|
.where(mastSqlTable.column(flowTaskKey), SqlBuilder.isEqualTo(flowTaskId.toString()))
|
.build().render(RenderingStrategies.MYBATIS3);
|
Map<String, Object> map = flowFormDataMapper.selectOneMappedRow(mastRender);
|
dataModel.setMainId(map.get(realIdKey) != null ? map.get(realIdKey).toString() : dataModel.getMainId());
|
}
|
}
|
|
/**
|
* 新增系统赋值
|
**/
|
private Object create(FieLdsModel fieLdsModel, Object dataValue, boolean isTable, UserEntity userEntity, boolean isLink) {
|
UserInfo user = UserProvider.getUser();
|
String jnpfKey = fieLdsModel.getConfig().getJnpfKey();
|
String rule = fieLdsModel.getConfig().getRule();
|
String format = DateTimeFormatConstant.getFormat(fieLdsModel.getFormat());
|
Object value = dataValue;
|
//外链跳过系统参数生成
|
if (isLink) {
|
List<String> systemAttList = new ArrayList<>();
|
systemAttList.add(JnpfKeyConsts.CREATEUSER);
|
systemAttList.add(JnpfKeyConsts.CURRORGANIZE);
|
systemAttList.add(JnpfKeyConsts.CURRPOSITION);
|
systemAttList.add(JnpfKeyConsts.CURRDEPT);
|
systemAttList.add(JnpfKeyConsts.MODIFYUSER);
|
if (systemAttList.contains(jnpfKey)) {
|
return null;
|
}
|
}
|
switch (jnpfKey) {
|
case JnpfKeyConsts.CREATEUSER:
|
value = userEntity.getId();
|
break;
|
case JnpfKeyConsts.CREATETIME:
|
value = new Date();
|
break;
|
case JnpfKeyConsts.CURRORGANIZE:
|
case JnpfKeyConsts.CURRDEPT:
|
if (user != null && CollectionUtil.isNotEmpty(user.getOrganizeIds())) {
|
value = JsonUtil.getObjectToString(user.getOrganizeIds());
|
}
|
break;
|
case JnpfKeyConsts.MODIFYTIME:
|
value = null;
|
break;
|
case JnpfKeyConsts.MODIFYUSER:
|
value = null;
|
break;
|
case JnpfKeyConsts.CURRPOSITION:
|
if (user != null && CollectionUtil.isNotEmpty(user.getPositionIds())) {
|
value = JsonUtil.getObjectToString(user.getPositionIds());
|
}
|
break;
|
case JnpfKeyConsts.BILLRULE:
|
if (fieLdsModel.getConfig().getRuleType() == null || Objects.equals(fieLdsModel.getConfig().getRuleType(), 1)) {
|
try {
|
value = serviceUtil.getBillNumber(rule);
|
} catch (Exception e) {
|
value = null;
|
}
|
}
|
break;
|
case JnpfKeyConsts.DATE:
|
case JnpfKeyConsts.DATE_CALCULATE:
|
if (isTable) {
|
try {
|
if (dataValue == null || "".equals(dataValue)) {
|
return null;
|
}
|
if (dataValue instanceof String) {
|
try {
|
SimpleDateFormat formatter = new SimpleDateFormat(format);
|
value = formatter.parse(dataValue.toString());
|
} catch (ParseException var3) {
|
return null;
|
}
|
} else {
|
value = new Date(Long.valueOf(String.valueOf(dataValue)));
|
}
|
} catch (Exception e) {
|
}
|
}
|
break;
|
case JnpfKeyConsts.NUM_INPUT:
|
case JnpfKeyConsts.CALCULATE:
|
if (isTable) {
|
try {
|
value = new BigDecimal(String.valueOf(dataValue));
|
} catch (Exception e) {
|
|
}
|
}
|
break;
|
default:
|
if (isTable) {
|
value = this.valueToNull(value);
|
}
|
break;
|
}
|
return value;
|
}
|
|
/**
|
* 无表插入数据
|
**/
|
private Map<String, Object> createAll(DataModel dataModel, List<FormAllModel> formAllModel) {
|
Map<String, Object> dataNewMap = dataModel.getDataNewMap();
|
UserEntity userEntity = dataModel.getUserEntity();
|
//处理好的数据
|
Map<String, Object> result = new HashMap<>(16);
|
List<FormAllModel> mastForm = formAllModel.stream().filter(t -> FormEnum.mast.getMessage().equals(t.getJnpfKey())).collect(Collectors.toList());
|
List<FormAllModel> tableForm = formAllModel.stream().filter(t -> FormEnum.table.getMessage().equals(t.getJnpfKey())).collect(Collectors.toList());
|
for (String key : dataNewMap.keySet()) {
|
FormAllModel model = mastForm.stream().filter(t -> key.equals(t.getFormColumnModel().getFieLdsModel().getVModel())).findFirst().orElse(null);
|
if (model != null) {
|
FieLdsModel fieLdsModel = model.getFormColumnModel().getFieLdsModel();
|
Object data = dataNewMap.get(key);
|
//处理系统自动生成
|
data = this.create(fieLdsModel, data, false, userEntity, dataModel.isLinkOpen());
|
result.put(key, data);
|
} else {
|
FormAllModel childModel = tableForm.stream().filter(t -> key.equals(t.getChildList().getTableModel())).findFirst().orElse(null);
|
if (childModel != null) {
|
//子表主键
|
List<FormColumnModel> childList = childModel.getChildList().getChildList();
|
List<Map<String, Object>> childDataMap = (List<Map<String, Object>>) dataNewMap.get(key);
|
//子表处理的数据
|
List<Map<String, Object>> childResult = new ArrayList<>();
|
for (Map<String, Object> objectMap : childDataMap) {
|
//子表单体处理的数据
|
Map<String, Object> childOneResult = new HashMap<>(16);
|
for (String childKey : objectMap.keySet()) {
|
FormColumnModel columnModel = childList.stream().filter(t -> childKey.equals(t.getFieLdsModel().getVModel())).findFirst().orElse(null);
|
if (columnModel != null) {
|
FieLdsModel fieLdsModel = columnModel.getFieLdsModel();
|
Object data = objectMap.get(childKey);
|
//处理系统自动生成
|
data = this.create(fieLdsModel, data, false, userEntity, dataModel.isLinkOpen());
|
childOneResult.put(childKey, data);
|
}
|
}
|
childResult.add(childOneResult);
|
}
|
result.put(key, childResult);
|
}
|
}
|
}
|
return result;
|
}
|
|
//--------------------------------------------修改 ----------------------------------------------------
|
|
/**
|
* 修改数据处理
|
**/
|
@DSTransactional
|
public Map<String, Object> update(DataModel dataModel) throws WorkFlowException {
|
try {
|
//处理好的数据
|
Map<String, Object> result = this.updateDataList(dataModel);
|
return result;
|
} catch (DataException dataException) {
|
throw new WorkFlowException(dataException.getMessage());
|
} catch (Exception e) {
|
//close
|
e.printStackTrace();
|
log.error("修改异常：{}", e.getMessage());
|
throw new WorkFlowException(MsgCode.FA029.get(), e.getMessage());
|
}
|
}
|
|
/**
|
* 修改数据
|
**/
|
public Map<String, Object> updateDataList(DataModel dataModel) throws SQLException, DataException {
|
//处理好的数据
|
Map<String, Object> result = new HashMap<>(16);
|
List<TableModel> tableModelList = dataModel.getTableModelList();
|
List<FormAllModel> formAllModel = dataModel.getFormAllModel();
|
//有表数据处理
|
if (tableModelList.size() > 0) {
|
DbLinkEntity link = dataModel.getLink();
|
DynamicDataSourceUtil.switchToDataSource(link);
|
try {
|
//系统数据
|
@Cleanup Connection conn = ConnUtil.getConnOrDefault(link);
|
String dbType = conn.getMetaData().getDatabaseProductName().trim();
|
dataModel.setDbType(dbType);
|
conn.setAutoCommit(false);
|
//主表
|
this.updateMast(formAllModel, dataModel, conn, result);
|
//子表
|
this.updateTable(formAllModel, dataModel, conn, result);
|
//副表
|
this.updateMastTable(formAllModel, dataModel, conn, result);
|
} finally {
|
DynamicDataSourceUtil.clearSwitchDataSource();
|
}
|
} else {
|
//无表数据处理
|
result = this.updateAll(dataModel, formAllModel);
|
}
|
return result;
|
}
|
|
/**
|
* 子表数据
|
**/
|
private void updateTable(List<FormAllModel> formAllModel, DataModel dataModel, Connection conn, Map<String, Object> result) throws SQLException {
|
Boolean onlyUpdate = dataModel.getOnlyUpdate();
|
Boolean logicalDelete = dataModel.getLogicalDelete();
|
List<TableModel> tableModelList = dataModel.getTableModelList();
|
Map<String, Object> dataNewMap = dataModel.getDataNewMap();
|
Map<String, Object> oldMainData = dataModel.getOldMainData();
|
if (MapUtils.isEmpty(oldMainData)) {
|
return;
|
}
|
boolean autoIncrement = Objects.equals(dataModel.getPrimaryKeyPolicy(), 2);
|
String flowId = "";
|
if (dataNewMap.get(FlowFormConstant.FLOWID) != null && StringUtil.isNotEmpty(dataNewMap.get(FlowFormConstant.FLOWID).toString())) {
|
flowId = dataNewMap.get(FlowFormConstant.FLOWID).toString();
|
}
|
|
//子表
|
List<FormAllModel> tableForm = formAllModel.stream().filter(t -> FormEnum.table.getMessage().equals(t.getJnpfKey())).collect(Collectors.toList());
|
|
for (FormAllModel itemModel : tableForm) {
|
FormColumnTableModel childModel = itemModel.getChildList();
|
if (childModel.getDisabled()) continue;
|
String key = childModel.getTableModel();
|
String tableName = childModel.getTableName();
|
//子表数据
|
List<Map<String, Object>> chidList = dataNewMap.get(key) != null ? (List<Map<String, Object>>) dataNewMap.get(key) : new ArrayList<>();
|
List<FormColumnModel> formColumnModels = childModel.getChildList().stream().filter(g -> StringUtil.isNotEmpty(g.getFieLdsModel().getVModel())).collect(Collectors.toList());
|
// if (CollectionUtils.isEmpty(formColumnModels)) continue;
|
if (Objects.equals(childModel.getIsNumLimit(), true) && chidList.size() > childModel.getNumLimit()) {
|
throw new DataException(MsgCode.VS033.get(childModel.getLabel()));
|
}
|
|
//子表主键
|
TableModel tableModel = tableModelList.stream().filter(k -> k.getTable().equals(tableName)).findFirst().orElse(null);
|
String table = tableModel.getTable();
|
SqlTable sqlTable = SqlTable.of(table);
|
String childPrimary = this.getKey(tableModel, dataModel.getDbType());
|
|
//子表表外键字段
|
String foreignKey = tableModel.getTableField();
|
TableFields foreignField = tableModel.getFields().stream().filter(t -> t.getField().equalsIgnoreCase(foreignKey)).findFirst().orElse(null);
|
if (foreignField == null) {
|
throw new SQLException(MsgCode.COD001.get());
|
}
|
//主表关联字段
|
Object foreignValue = dataNewMap.get(tableModel.getRelationField());
|
Object oldForeignValue = oldMainData.get(tableModel.getRelationField());
|
if (VisualConst.DB_INT_ALL.contains(foreignField.getDataType())) {
|
foreignValue = Long.parseLong(String.valueOf(foreignValue));
|
oldForeignValue = Long.parseLong(String.valueOf(oldForeignValue));
|
}
|
|
//查询旧的子表数据
|
SelectStatementProvider render = SqlBuilder.select(sqlTable.column(childPrimary))
|
.from(sqlTable)
|
.where(sqlTable.column(foreignKey), SqlBuilder.isEqualTo(oldForeignValue))
|
.build().render(RenderingStrategies.MYBATIS3);
|
List<Object> childIdList = flowFormDataMapper.selectManyMappedRows(render).stream().map(t -> new CaseInsensitiveMap(t).get(childPrimary)).collect(Collectors.toList());
|
List<Object> formDataIdList = chidList.stream().filter(t -> new CaseInsensitiveMap(t).containsKey(childPrimary)).map(t -> new CaseInsensitiveMap(t).get(childPrimary)).collect(Collectors.toList());
|
List<Object> deleteList = childIdList.stream().filter(t -> {
|
List<String> jsonToList = JsonUtil.getJsonToList(formDataIdList, String.class);
|
if (!jsonToList.contains(String.valueOf(t))) {
|
return true;
|
}
|
return false;
|
}).collect(Collectors.toList());
|
|
if (CollectionUtils.isNotEmpty(deleteList) && !onlyUpdate) {//删除子表id数据
|
//是否开启逻辑删除
|
if (logicalDelete) {
|
UpdateDSL<UpdateModel> updateModelUpdateDSL = SqlBuilder.update(sqlTable);
|
updateModelUpdateDSL.set(sqlTable.column(TableFeildsEnum.DELETEMARK.getField())).equalTo(1);
|
updateModelUpdateDSL.set(sqlTable.column(TableFeildsEnum.DELETETIME.getField())).equalTo(new Date());
|
updateModelUpdateDSL.set(sqlTable.column(TableFeildsEnum.DELETEUSERID.getField())).equalTo(UserProvider.getUser().getUserId());
|
UpdateStatementProvider updateRender = updateModelUpdateDSL
|
.where(sqlTable.column(childPrimary), SqlBuilder.isIn(deleteList))
|
.build().render(RenderingStrategies.MYBATIS3);
|
flowFormDataMapper.update(updateRender);
|
} else {
|
DeleteStatementProvider deleteRender = SqlBuilder.deleteFrom(sqlTable)
|
.where(sqlTable.column(childPrimary), SqlBuilder.isIn(deleteList))
|
.build().render(RenderingStrategies.MYBATIS3);
|
flowFormDataMapper.delete(deleteRender);
|
}
|
}
|
|
for (Map<String, Object> objectMap : chidList) {
|
objectMap = new CaseInsensitiveMap(objectMap);
|
boolean isUpdate = false;
|
if (CollectionUtil.isNotEmpty(childIdList)) {
|
List<String> jsonToList = JsonUtil.getJsonToList(childIdList, String.class);
|
if (objectMap.get(childPrimary) != null && jsonToList.contains(String.valueOf(objectMap.get(childPrimary)))) {
|
isUpdate = true;
|
}
|
}
|
if (StringUtil.isNotEmpty(flowId)) {
|
objectMap.put(FlowFormConstant.FLOWID, flowId);
|
}
|
GeneralInsertDSL generalInsertDSL = SqlBuilder.insertInto(sqlTable).set(sqlTable.column(foreignKey)).toValue(foreignValue);
|
UpdateDSL<UpdateModel> updateModelUpdateDSL = SqlBuilder.update(sqlTable).set(sqlTable.column(foreignKey)).equalTo(foreignValue);
|
for (FormColumnModel column : formColumnModels) {
|
FieLdsModel fieLdsModel = column.getFieLdsModel();
|
String childKey = fieLdsModel.getVModel();
|
String jnpfkey = fieLdsModel.getConfig().getJnpfKey();
|
Object data = objectMap.get(childKey);
|
String fieldKey = fieLdsModel.getConfig().getParentVModel() + "-" + childKey;
|
if (foreignKey.equalsIgnoreCase(childKey)) {
|
continue;
|
}
|
//流程表单权限
|
if (CollectionUtils.isNotEmpty(dataModel.getFlowFormOperates())) {
|
boolean hasOperate = isHasOperate(dataModel, fieldKey);
|
if (!hasOperate) {
|
continue;
|
}
|
} else if (dataModel.getNeedPermission()) {
|
if (CollectionUtil.isNotEmpty(dataModel.getFormPerList())) {
|
if (!dataModel.getFormPerList().contains(fieldKey)) {
|
continue;
|
}
|
} else {
|
continue;
|
}
|
}
|
if (isUpdate) {
|
if (JnpfKeyConsts.CURRORGANIZE.equals(jnpfkey) || JnpfKeyConsts.CURRPOSITION.equals(jnpfkey)
|
|| JnpfKeyConsts.CREATETIME.equals(jnpfkey) || JnpfKeyConsts.CREATEUSER.equals(jnpfkey)) {
|
continue;
|
}
|
} else {
|
if (JnpfKeyConsts.MODIFYUSER.equals(jnpfkey) || JnpfKeyConsts.MODIFYTIME.equals(jnpfkey)) {
|
continue;
|
}
|
}
|
//处理系统自动生成
|
data = this.update(fieLdsModel, data, true, objectMap.get(childPrimary) == null);
|
data = visualBillUtil.getBillNumber(dataModel.getVisualId(), fieLdsModel, objectMap, data);
|
getDSL(sqlTable, null, generalInsertDSL, fieLdsModel.getFormat(), childKey, data);
|
getDSL(sqlTable, updateModelUpdateDSL, null, fieLdsModel.getFormat(), childKey, data);
|
}
|
|
if (isUpdate) {//修改
|
updateModelUpdateDSL.where(sqlTable.column(childPrimary), SqlBuilder.isEqualTo(objectMap.get(childPrimary)));
|
UpdateStatementProvider render1 = updateModelUpdateDSL.build().render(RenderingStrategies.MYBATIS3);
|
flowFormDataMapper.update(render1);
|
} else {//新增
|
//添加主键值和外键值
|
if (!autoIncrement) {
|
generalInsertDSL = generalInsertDSL.set(sqlTable.column(childPrimary)).toValue(RandomUtil.uuId());
|
}
|
//租户信息
|
addTenantId(generalInsertDSL, sqlTable);
|
GeneralInsertStatementProvider insertRender = generalInsertDSL.build().render(RenderingStrategies.MYBATIS3);
|
flowFormDataMapper.generalInsert(insertRender);
|
}
|
}
|
}
|
}
|
|
/**
|
* 副表数据
|
**/
|
private void updateMastTable(List<FormAllModel> formAllModel, DataModel dataModel, Connection conn, Map<String, Object> result) throws SQLException {
|
List<TableModel> tableModelList = dataModel.getTableModelList();
|
Map<String, Object> dataNewMap = dataModel.getDataNewMap();
|
Map<String, Object> oldMainData = dataModel.getOldMainData();
|
if (MapUtils.isEmpty(oldMainData)) {
|
return;
|
}
|
|
//副表
|
Map<String, List<FormAllModel>> mastTableAll = formAllModel.stream().filter(t -> FormEnum.mastTable.getMessage().equals(t.getJnpfKey())).collect(Collectors.groupingBy(e -> e.getFormMastTableModel().getTable()));
|
for (String key : mastTableAll.keySet()) {
|
List<FormAllModel> masTableList = mastTableAll.get(key);
|
//副表
|
Optional<TableModel> first = tableModelList.stream().filter(t -> t.getTable().equals(key)).findFirst();
|
if (!first.isPresent()) {
|
throw new SQLException(MsgCode.COD001.get());
|
}
|
TableModel tableModel = first.get();
|
String tableModelTable = tableModel.getTable();
|
SqlTable sqlTable = SqlTable.of(tableModelTable);
|
String childKeyName = this.getKey(tableModel, dataModel.getDbType());
|
|
//副表外键字段
|
String foreignKey = tableModel.getTableField();
|
TableFields foreignField = tableModel.getFields().stream().filter(t -> t.getField().equalsIgnoreCase(foreignKey)).findFirst().orElse(null);
|
if (foreignField == null) {
|
throw new SQLException(MsgCode.COD001.get());
|
}
|
//主表关联字段
|
Object foreignValue = dataNewMap.get(tableModel.getRelationField());
|
Object oldForeignValue = oldMainData.get(tableModel.getRelationField());
|
if (VisualConst.DB_INT_ALL.contains(foreignField.getDataType())) {
|
foreignValue = Long.parseLong(String.valueOf(foreignValue));
|
oldForeignValue = Long.parseLong(String.valueOf(oldForeignValue));
|
}
|
|
UpdateDSL<UpdateModel> updateModelUpdateDSL = SqlBuilder.update(sqlTable).set(sqlTable.column(foreignKey)).equalTo(foreignValue);
|
|
for (FormAllModel model : masTableList) {
|
FormMastTableModel formMastTableModel = model.getFormMastTableModel();
|
FormColumnModel mastTable = formMastTableModel.getMastTable();
|
FieLdsModel fieLdsModel = mastTable.getFieLdsModel();
|
String mostTableKey = fieLdsModel.getVModel();
|
String jnpfkey = fieLdsModel.getConfig().getJnpfKey();
|
Object data = dataNewMap.get(mostTableKey);
|
String field = formMastTableModel.getField();
|
//外键值写入不覆盖
|
if (foreignKey.equalsIgnoreCase(field)) {
|
continue;
|
}
|
//流程表单权限
|
if (CollectionUtils.isNotEmpty(dataModel.getFlowFormOperates())) {
|
boolean hasOperate = isHasOperate(dataModel, mostTableKey);
|
if (!hasOperate) {
|
continue;
|
}
|
} else if (dataModel.getNeedPermission()) {
|
if (CollectionUtil.isNotEmpty(dataModel.getFormPerList())) {
|
if (!dataModel.getFormPerList().contains(mostTableKey)) {
|
continue;
|
}
|
} else {
|
continue;
|
}
|
}
|
|
if (JnpfKeyConsts.CURRORGANIZE.equals(jnpfkey) || JnpfKeyConsts.CURRPOSITION.equals(jnpfkey)
|
|| JnpfKeyConsts.CREATETIME.equals(jnpfkey) || JnpfKeyConsts.CREATEUSER.equals(jnpfkey)) {
|
continue;
|
}
|
//处理系统自动生成
|
data = this.update(fieLdsModel, data, true, false);
|
data = visualBillUtil.getBillNumber(dataModel.getVisualId(), fieLdsModel, dataNewMap, data);
|
getDSL(sqlTable, updateModelUpdateDSL, null, fieLdsModel.getFormat(), field, data);
|
}
|
|
UpdateStatementProvider updateStatementProvider = updateModelUpdateDSL
|
.where(sqlTable.column(foreignKey), SqlBuilder.isEqualTo(oldForeignValue))
|
.build().render(RenderingStrategies.MYBATIS3);
|
flowFormDataMapper.update(updateStatementProvider);
|
}
|
}
|
|
/**
|
* 主表数据
|
**/
|
private void updateMast(List<FormAllModel> formAllModel, DataModel dataModel, Connection conn, Map<String, Object> result) throws SQLException {
|
List<TableModel> tableModelList = dataModel.getTableModelList();
|
Map<String, Object> dataNewMap = dataModel.getDataNewMap();
|
List<FormAllModel> mastForm = formAllModel.stream().filter(t -> FormEnum.mast.getMessage().equals(t.getJnpfKey())).filter(
|
t -> StringUtil.isNotEmpty(t.getFormColumnModel().getFieLdsModel().getVModel())).collect(Collectors.toList());
|
|
Optional<TableModel> first = tableModelList.stream().filter(t -> "1".equals(t.getTypeId())).findFirst();
|
if (!first.isPresent()) {
|
throw new SQLException(MsgCode.COD001.get());
|
}
|
TableModel tableModel = first.get();
|
String mastTableName = tableModel.getTable();
|
SqlTable sqlTable = SqlTable.of(mastTableName);
|
TableFields keyFieldModel = tableModel.getFields().stream().filter(t -> Objects.equals(t.getPrimaryKey(), 1)
|
&& !t.getField().toLowerCase().contains(TableFeildsEnum.TENANTID.getField())).findFirst().orElse(null);
|
if (keyFieldModel == null) {
|
throw new SQLException(MsgCode.COD001.get());
|
}
|
String keyName = keyFieldModel.getField();
|
|
//设置实际主键id
|
Object mainId = dataModel.getMainId();
|
if (VisualConst.DB_INT_ALL.contains(keyFieldModel.getDataType().toLowerCase())) {
|
mainId = Long.parseLong(dataModel.getMainId());
|
}
|
dataNewMap.put(keyName, mainId);
|
|
//查询旧的主表数据（用于确定修改时外键字段信息）
|
SelectStatementProvider render = SqlBuilder.select(sqlTable.allColumns())
|
.from(sqlTable)
|
.where(sqlTable.column(keyName), SqlBuilder.isEqualTo(mainId))
|
.build().render(RenderingStrategies.MYBATIS3);
|
List<Map<String, Object>> maps = flowFormDataMapper.selectManyMappedRows(render);
|
if (CollectionUtils.isEmpty(maps)) {
|
return;
|
}
|
dataModel.setOldMainData(maps.get(0));
|
|
UpdateDSL<UpdateModel> updateModelUpdateDSL = SqlBuilder.update(sqlTable);
|
int num = 0;
|
|
for (FormAllModel model : mastForm) {
|
FieLdsModel fieLdsModel = model.getFormColumnModel().getFieLdsModel();
|
String jnpfkey = fieLdsModel.getConfig().getJnpfKey();
|
String field = fieLdsModel.getVModel();
|
Object data = dataNewMap.get(field);
|
|
//流程表单权限
|
if (CollectionUtils.isNotEmpty(dataModel.getFlowFormOperates())) {
|
boolean hasOperate = isHasOperate(dataModel, field);
|
if (!hasOperate) {
|
continue;
|
}
|
} else if (dataModel.getNeedPermission()) {
|
if (CollectionUtil.isNotEmpty(dataModel.getFormPerList())) {
|
if (!dataModel.getFormPerList().contains(field)) {
|
continue;
|
}
|
} else {
|
continue;
|
}
|
}
|
|
if (JnpfKeyConsts.CURRORGANIZE.equals(jnpfkey) || JnpfKeyConsts.CURRPOSITION.equals(jnpfkey)
|
|| JnpfKeyConsts.CREATETIME.equals(jnpfkey) || JnpfKeyConsts.CREATEUSER.equals(jnpfkey)) {
|
continue;
|
}
|
//处理系统自动生成
|
data = this.update(fieLdsModel, data, true, false);
|
data = visualBillUtil.getBillNumber(dataModel.getVisualId(), fieLdsModel, dataNewMap, data);
|
getDSL(sqlTable, updateModelUpdateDSL, null, fieLdsModel.getFormat(), field, data);
|
num++;
|
}
|
//判断是否开启锁
|
if (dataModel.getConcurrencyLock()) {
|
updateModelUpdateDSL = updateModelUpdateDSL.set(sqlTable.column(TableFeildsEnum.VERSION.getField())).equalTo(dataNewMap.get(TableFeildsEnum.VERSION.getField()));
|
}
|
|
//添加流程引擎信息
|
if (dataNewMap.get(FlowFormConstant.FLOWID) != null && StringUtil.isNotEmpty(dataNewMap.get(FlowFormConstant.FLOWID).toString())) {
|
updateModelUpdateDSL = updateModelUpdateDSL.set(sqlTable.column(TableFeildsEnum.FLOWID.getField())).equalTo(dataNewMap.get(FlowFormConstant.FLOWID));
|
}
|
|
UpdateStatementProvider updateStatementProvider = updateModelUpdateDSL
|
.where(sqlTable.column(keyName), SqlBuilder.isEqualTo(mainId))
|
.build().render(RenderingStrategies.MYBATIS3);
|
if (num > 0) {
|
flowFormDataMapper.update(updateStatementProvider);
|
}
|
}
|
|
/**
|
* 修改无表数据
|
**/
|
private Map<String, Object> updateAll(DataModel dataModel, List<FormAllModel> formAllModel) {
|
Map<String, Object> dataNewMap = dataModel.getDataNewMap();
|
//处理好的数据
|
Map<String, Object> result = new HashMap<>(16);
|
//系统数据
|
List<FormAllModel> mastForm = formAllModel.stream().filter(t -> FormEnum.mast.getMessage().equals(t.getJnpfKey())).collect(Collectors.toList());
|
List<FormAllModel> tableForm = formAllModel.stream().filter(t -> FormEnum.table.getMessage().equals(t.getJnpfKey())).collect(Collectors.toList());
|
for (String key : dataNewMap.keySet()) {
|
FormAllModel model = mastForm.stream().filter(t -> key.equals(t.getFormColumnModel().getFieLdsModel().getVModel())).findFirst().orElse(null);
|
if (model != null) {
|
FieLdsModel fieLdsModel = model.getFormColumnModel().getFieLdsModel();
|
Object data = dataNewMap.get(key);
|
//处理系统自动生成
|
data = this.update(fieLdsModel, data, false, false);
|
result.put(key, data);
|
} else {
|
FormAllModel childModel = tableForm.stream().filter(t -> key.equals(t.getChildList().getTableModel())).findFirst().orElse(null);
|
if (childModel != null) {
|
List<Map<String, Object>> childDataMap = (List<Map<String, Object>>) dataNewMap.get(key);
|
//子表处理的数据
|
List<Map<String, Object>> childResult = new ArrayList<>();
|
for (Map<String, Object> objectMap : childDataMap) {
|
//子表单体处理的数据
|
Map<String, Object> childOneResult = new HashMap<>(16);
|
for (String childKey : objectMap.keySet()) {
|
FormColumnModel columnModel = childModel.getChildList().getChildList().stream().filter(t -> childKey.equals(t.getFieLdsModel().getVModel())).findFirst().orElse(null);
|
if (columnModel != null) {
|
FieLdsModel fieLdsModel = columnModel.getFieLdsModel();
|
Object data = objectMap.get(childKey);
|
data = this.update(fieLdsModel, data, false, false);
|
childOneResult.put(childKey, data);
|
}
|
}
|
childResult.add(childOneResult);
|
}
|
result.put(key, childResult);
|
}
|
}
|
}
|
return result;
|
}
|
|
/**
|
* childNeedAdd子表id为空需要生成单据规则（除子表外其他都是false）
|
* 修改系统赋值
|
**/
|
private Object update(FieLdsModel fieLdsModel, Object dataValue, boolean isTable, boolean childNeedAdd) {
|
String jnpfKey = fieLdsModel.getConfig().getJnpfKey();
|
String rule = fieLdsModel.getConfig().getRule();
|
String format = DateTimeFormatConstant.getFormat(fieLdsModel.getFormat());
|
UserInfo user = UserProvider.getUser();
|
Object value = dataValue;
|
switch (jnpfKey) {
|
case JnpfKeyConsts.CREATEUSER:
|
value = user.getUserId();
|
break;
|
case JnpfKeyConsts.CREATETIME:
|
value = new Date();
|
break;
|
case JnpfKeyConsts.CURRORGANIZE:
|
case JnpfKeyConsts.CURRDEPT:
|
if (user != null && CollectionUtil.isNotEmpty(user.getOrganizeIds())) {
|
value = JsonUtil.getObjectToString(user.getOrganizeIds());
|
}
|
break;
|
case JnpfKeyConsts.MODIFYTIME:
|
if (!childNeedAdd) {
|
value = new Date();
|
}
|
break;
|
case JnpfKeyConsts.MODIFYUSER:
|
if (!childNeedAdd) {
|
value = user.getUserId();
|
}
|
break;
|
case JnpfKeyConsts.CURRPOSITION:
|
if (user != null && CollectionUtil.isNotEmpty(user.getPositionIds())) {
|
value = JsonUtil.getObjectToString(user.getPositionIds());
|
}
|
break;
|
case JnpfKeyConsts.BILLRULE:
|
if (Objects.equals(fieLdsModel.getConfig().getRuleType(), 1) && (childNeedAdd || ObjectUtil.isEmpty(dataValue))) {
|
try {
|
value = serviceUtil.getBillNumber(rule);
|
} catch (Exception e) {
|
value = null;
|
}
|
}
|
break;
|
case JnpfKeyConsts.DATE:
|
case JnpfKeyConsts.DATE_CALCULATE:
|
if (isTable) {
|
try {
|
if (dataValue == null || "".equals(dataValue)) {
|
return null;
|
}
|
if (dataValue instanceof String) {
|
try {
|
SimpleDateFormat formatter = new SimpleDateFormat(format);
|
value = formatter.parse(dataValue.toString());
|
} catch (ParseException var3) {
|
return null;
|
}
|
} else {
|
value = new Date(Long.valueOf(String.valueOf(dataValue)));
|
}
|
} catch (Exception e) {
|
}
|
}
|
break;
|
case JnpfKeyConsts.NUM_INPUT:
|
case JnpfKeyConsts.CALCULATE:
|
if (isTable) {
|
try {
|
value = new BigDecimal(String.valueOf(dataValue));
|
} catch (Exception e) {
|
|
}
|
}
|
break;
|
default:
|
if (isTable) {
|
value = this.valueToNull(value);
|
}
|
break;
|
}
|
return value;
|
}
|
|
/**
|
* 删除有表单条数据
|
*
|
* @param id
|
* @param visualDevJsonModel
|
* @return
|
* @throws SQLException
|
* @throws DataException
|
*/
|
@DSTransactional
|
public boolean deleteTable(String id, VisualDevJsonModel visualDevJsonModel, DbLinkEntity linkEntity) throws Exception {
|
Boolean logicalDelete = visualDevJsonModel.getFormData().getLogicalDelete();
|
Integer primaryKeyPolicy = visualDevJsonModel.getFormData().getPrimaryKeyPolicy();
|
List<TableModel> tableModels = visualDevJsonModel.getVisualTables();
|
|
List<FieLdsModel> list = JsonUtil.getJsonToList(visualDevJsonModel.getFormData().getFields(), FieLdsModel.class);
|
RecursionForm recursionForm = new RecursionForm(list, tableModels);
|
List<FormAllModel> formAllModel = new ArrayList<>();
|
FormCloumnUtil.recursionForm(recursionForm, formAllModel);
|
List<FormAllModel> tableForm = formAllModel.stream().filter(t -> FormEnum.table.getMessage().equals(t.getJnpfKey())).collect(Collectors.toList());
|
Map<String, Boolean> disableMap = new HashMap<>();
|
for (FormAllModel allModel : tableForm) {
|
disableMap.put(allModel.getChildList().getTableName(), allModel.getChildList().getDisabled());
|
}
|
//主表
|
TableModel mainTableModel = tableModels.stream().filter(t -> "1".equals(t.getTypeId())).findFirst().orElse(null);
|
String mainTable = mainTableModel.getTable();
|
DynamicDataSourceUtil.switchToDataSource(linkEntity);
|
try {
|
@Cleanup Connection conn = ConnUtil.getConnOrDefault(linkEntity);
|
String dbType = conn.getMetaData().getDatabaseProductName().trim();
|
String pKeyName = this.getKey(mainTableModel, dbType);
|
|
String flowTaskId = this.getFlowTaskId(mainTableModel, dbType);
|
List<AndOrCriteriaGroup> groupList = new ArrayList<>();
|
groupList.add(SqlBuilder.or(SqlTable.of(mainTable).column(flowTaskId), SqlBuilder.isEqualTo(id)));
|
|
boolean autoIncrement = Objects.equals(primaryKeyPolicy, 2);
|
Object selectId = id;
|
if (autoIncrement) {
|
selectId = Long.parseLong(id);
|
}
|
SelectStatementProvider queryMain = SqlBuilder.select(SqlTable.of(mainTable).allColumns())
|
.from(SqlTable.of(mainTable))
|
.where(SqlTable.of(mainTable).column(pKeyName), SqlBuilder.isEqualTo(selectId), groupList)
|
.build().render(RenderingStrategies.MYBATIS3);
|
Map<String, Object> mainMap = flowFormDataMapper.selectOneMappedRow(queryMain);
|
|
if (MapUtils.isNotEmpty(mainMap)) {
|
Object realId = mainMap.get(pKeyName);
|
//是否开启逻辑删除
|
if (logicalDelete) {
|
SqlTable sqlt = SqlTable.of(mainTable);
|
UpdateDSL<UpdateModel> updateModelUpdateDSL = SqlBuilder.update(sqlt);
|
updateModelUpdateDSL.set(sqlt.column(TableFeildsEnum.DELETEMARK.getField())).equalTo(1);
|
updateModelUpdateDSL.set(sqlt.column(TableFeildsEnum.DELETETIME.getField())).equalTo(new Date());
|
updateModelUpdateDSL.set(sqlt.column(TableFeildsEnum.DELETEUSERID.getField())).equalTo(UserProvider.getUser().getUserId());
|
UpdateStatementProvider mainUpdate = updateModelUpdateDSL
|
.where(SqlTable.of(mainTable).column(pKeyName), SqlBuilder.isEqualTo(realId))
|
.build().render(RenderingStrategies.MYBATIS3);
|
flowFormDataMapper.update(mainUpdate);
|
} else {
|
DeleteStatementProvider mainDelete = SqlBuilder.deleteFrom(SqlTable.of(mainTable))
|
.where(SqlTable.of(mainTable).column(pKeyName), SqlBuilder.isEqualTo(realId))
|
.build().render(RenderingStrategies.MYBATIS3);
|
flowFormDataMapper.delete(mainDelete);
|
}
|
|
if (tableModels.size() > 1) {
|
//去除主表
|
tableModels.remove(mainTableModel);
|
for (TableModel table : tableModels) {
|
if (CollectionUtil.isNotEmpty(disableMap) && disableMap.get(table.getTable()) != null && disableMap.get(table.getTable())) {
|
continue;
|
}
|
//主表关联-字段值
|
Object relationFieldValue = mainMap.get(table.getRelationField());
|
//子表字段-key
|
String tableField = table.getTableField();
|
|
if (logicalDelete) {
|
SqlTable sqlt = SqlTable.of(table.getTable());
|
UpdateDSL<UpdateModel> updateModelUpdateDSL = SqlBuilder.update(sqlt);
|
updateModelUpdateDSL.set(sqlt.column(TableFeildsEnum.DELETEMARK.getField())).equalTo(1);
|
updateModelUpdateDSL.set(sqlt.column(TableFeildsEnum.DELETETIME.getField())).equalTo(new Date());
|
updateModelUpdateDSL.set(sqlt.column(TableFeildsEnum.DELETEUSERID.getField())).equalTo(UserProvider.getUser().getUserId());
|
UpdateStatementProvider mainUpdate = updateModelUpdateDSL
|
.where(SqlTable.of(table.getTable()).column(tableField), SqlBuilder.isEqualTo(relationFieldValue))
|
.build().render(RenderingStrategies.MYBATIS3);
|
flowFormDataMapper.update(mainUpdate);
|
} else {
|
DeleteStatementProvider childDeleteProvider = SqlBuilder.deleteFrom(SqlTable.of(table.getTable()))
|
.where(SqlTable.of(table.getTable()).column(tableField), SqlBuilder.isEqualTo(relationFieldValue))
|
.build().render(RenderingStrategies.MYBATIS3);
|
flowFormDataMapper.delete(childDeleteProvider);
|
}
|
}
|
}
|
}
|
} finally {
|
DynamicDataSourceUtil.clearSwitchDataSource();
|
}
|
return true;
|
}
|
|
/**
|
* 获取锁字段信息
|
*
|
* @param table
|
* @param linkEntity
|
* @param dataMap
|
* @param id
|
* @return
|
*/
|
public Boolean getVersion(String table, DbLinkEntity linkEntity, Map dataMap, Object id) {
|
boolean canUpdate = true;
|
try {
|
DynamicDataSourceUtil.switchToDataSource(linkEntity);
|
@Cleanup Connection conn = ConnUtil.getConnOrDefault(linkEntity);
|
String pKeyName = this.getTableKey(conn, table);
|
SqlTable sqlTable = SqlTable.of(table);
|
SelectStatementProvider render = SqlBuilder.select(sqlTable.column(TableFeildsEnum.VERSION.getField()))
|
.from(sqlTable)
|
.where(sqlTable.column(pKeyName), SqlBuilder.isEqualTo(id))
|
.and(sqlTable.column(TableFeildsEnum.VERSION.getField()), SqlBuilder.isEqualTo(dataMap.get(TableFeildsEnum.VERSION.getField())))
|
.build().render(RenderingStrategies.MYBATIS3);
|
int count = flowFormDataMapper.selectManyMappedRows(render).size();
|
canUpdate = count > 0;
|
} catch (DataException | SQLException e) {
|
log.error("切换数据源异常");
|
} finally {
|
DynamicDataSourceUtil.clearSwitchDataSource();
|
}
|
return canUpdate;
|
}
|
|
/**
|
* 添加sql语句
|
*
|
* @param
|
* @return
|
* @copyright 引迈信息技术有限公司
|
* @date 2023/3/29
|
*/
|
private void getDSL(SqlTable sqlTable, UpdateDSL<UpdateModel> updateModelUpdateDSL, GeneralInsertDSL generalInsertDSL,
|
String format, String field, Object data) {
|
boolean dataTimestamp = StringUtil.isNotEmpty(format) ? format.length() > 10 : true;
|
String dateFunc = dataTimestamp ? "to_timestamp" : "to_date";
|
if (data == null || StringUtil.isEmpty(data.toString())) {
|
if (generalInsertDSL != null) {
|
generalInsertDSL = generalInsertDSL.set(sqlTable.column(field)).toNull();
|
} else {
|
updateModelUpdateDSL = updateModelUpdateDSL.set(sqlTable.column(field)).equalToNull();
|
}
|
} else {
|
if (generalInsertDSL != null) {
|
generalInsertDSL = generalInsertDSL.set(sqlTable.column(field)).toValue(data);
|
} else {
|
updateModelUpdateDSL = updateModelUpdateDSL.set(sqlTable.column(field)).equalTo(data);
|
}
|
}
|
}
|
|
/**
|
* 判断数据为空或空数组转换成null
|
*
|
* @param value
|
* @return
|
*/
|
private Object valueToNull(Object value) {
|
if (value instanceof List || value instanceof String[][]) {
|
List l = (List) value;
|
if (l.size() > 0) {
|
value = JsonUtil.getObjectToString(value);
|
} else {
|
value = null;
|
}
|
} else if (value instanceof CharSequence) {
|
if (StrUtil.isEmpty((CharSequence) value) || "[]".equals(value)) {
|
value = null;
|
}
|
}
|
return value;
|
}
|
|
/**
|
* 获取当前组织完整路径
|
*
|
* @param orgId
|
* @return
|
*/
|
public String getCurrentOrgIds(String orgId, String showLevel) {
|
String orgIds = null;
|
OrganizeEntity organizeEntity = serviceUtil.getOrganizeInfo(orgId);
|
if (organizeEntity != null) {
|
if (StringUtil.isNotEmpty(organizeEntity.getOrganizeIdTree())) {
|
String[] split = organizeEntity.getOrganizeIdTree().split(",");
|
orgIds = split.length > 0 ? JsonUtil.getObjectToString(Arrays.asList(split)) : null;
|
}
|
}
|
if (!"all".equals(showLevel) && organizeEntity != null && "company".equals(organizeEntity.getCategory())) {
|
orgIds = null;
|
}
|
return orgIds;
|
}
|
|
/**
|
* 是否有流程表单权限
|
*
|
* @param dataModel
|
* @param field
|
* @return false 没有权限(需要跳过)
|
*/
|
private boolean isHasOperate(DataModel dataModel, String field) {
|
boolean hasOperate = true;
|
for (Map<String, Object> item : dataModel.getFlowFormOperates()) {
|
if (field.equals(item.get("id")) && (item.get("write") == null || "false".equals(item.get("write").toString()))) {
|
hasOperate = false;
|
}
|
}
|
return hasOperate;
|
}
|
|
/**
|
* 添加租户信息
|
*
|
* @param generalInsertDSL
|
* @param sqlTable
|
*/
|
private void addTenantId(GeneralInsertDSL generalInsertDSL, SqlTable sqlTable) {
|
//租户信息
|
String tenantId = TenantDataSourceUtil.getTenantColumn();
|
generalInsertDSL.set(sqlTable.column(TableFeildsEnum.TENANTID.getField())).toValue(tenantId);
|
}
|
|
public void saveState(VisualdevEntity visualdevEntity, String flowTaskId, Integer flowState) {
|
List<TableModel> tableModels = JsonUtil.getJsonToList(visualdevEntity.getVisualTables(), TableModel.class);
|
TableModel mainT = tableModels.stream().filter(t -> t.getTypeId().equals("1")).findFirst().orElse(null);
|
DbLinkEntity linkEntity = serviceUtil.getDbLink(visualdevEntity.getDbLinkId());
|
try {
|
DynamicDataSourceUtil.switchToDataSource(linkEntity);
|
SqlTable sqlt = SqlTable.of(mainT.getTable());
|
UpdateDSL<UpdateModel> updateModelUpdateDSL = SqlBuilder.update(sqlt);
|
updateModelUpdateDSL.set(sqlt.column(TableFeildsEnum.FLOWSTATE.getField())).equalTo(flowState);
|
UpdateStatementProvider mainUpdate = updateModelUpdateDSL
|
.where(SqlTable.of(mainT.getTable()).column(TableFeildsEnum.FLOWTASKID.getField()), SqlBuilder.isEqualTo(flowTaskId))
|
.build().render(RenderingStrategies.MYBATIS3);
|
flowFormDataMapper.update(mainUpdate);
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
DynamicDataSourceUtil.clearSwitchDataSource();
|
}
|
}
|
}
|
