package jnpf.base.util;
|
|
import cn.hutool.core.util.ObjectUtil;
|
import jnpf.base.entity.VisualdevEntity;
|
import jnpf.base.mapper.FlowFormDataMapper;
|
import jnpf.base.model.CheckFormModel;
|
import jnpf.base.model.ColumnDataModel;
|
import jnpf.base.model.OnlineImport.ImportDataModel;
|
import jnpf.base.model.OnlineImport.ImportFormCheckUniqueModel;
|
import jnpf.base.model.VisualConst;
|
import jnpf.base.model.VisualErrInfo;
|
import jnpf.base.model.form.FormCheckModel;
|
import jnpf.constant.JnpfConst;
|
import jnpf.constant.MsgCode;
|
import jnpf.database.model.entity.DbLinkEntity;
|
import jnpf.database.util.ConnUtil;
|
import jnpf.database.util.DynamicDataSourceUtil;
|
import jnpf.exception.DataException;
|
import jnpf.i18n.util.I18nUtil;
|
import jnpf.model.visualJson.FieLdsModel;
|
import jnpf.model.visualJson.FormDataModel;
|
import jnpf.model.visualJson.TableFields;
|
import jnpf.model.visualJson.TableModel;
|
import jnpf.model.visualJson.config.ConfigModel;
|
import jnpf.util.FlowFormConstant;
|
import jnpf.util.JsonUtil;
|
import jnpf.util.StringUtil;
|
import jnpf.util.TableFeildsEnum;
|
import jnpf.util.visiual.JnpfKeyConsts;
|
import lombok.Cleanup;
|
import org.apache.commons.collections4.CollectionUtils;
|
import org.apache.commons.collections4.MapUtils;
|
import org.apache.commons.lang3.StringUtils;
|
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.render.RenderingStrategies;
|
import org.mybatis.dynamic.sql.select.QueryExpressionDSL;
|
import org.mybatis.dynamic.sql.select.SelectModel;
|
import org.mybatis.dynamic.sql.select.join.EqualTo;
|
import org.mybatis.dynamic.sql.select.render.SelectStatementProvider;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.sql.Connection;
|
import java.sql.SQLException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
|
/**
|
* 验证表单数据
|
*
|
* @author JNPF开发平台组
|
* @version V3.4.2
|
* @copyright 引迈信息技术有限公司（https://www.jnpfsoft.com）
|
* @date 2022/5/25
|
*/
|
@Component
|
public class FormCheckUtils {
|
public static final List<String> LINK_ALLOW_KEY = Arrays.asList("alert", "card", "collapse", "collapseItem", "colorPicker", "datePicker", "divider", "editor",
|
"groupTitle", "iframe", "input", "inputNumber", "link", "location", "rate", "row", "slider", "stepItem", "steps", "switch", "tab", "tabItem", "table", "tableGrid",
|
"tableGridTd", "tableGridTr", "text", "textarea", "timePicker");
|
@Autowired
|
private FlowFormDataUtil flowDataUtil;
|
@Autowired
|
private FlowFormDataMapper flowFormDataMapper;
|
|
public String checkForm(CheckFormModel checkFormModel) {
|
List<FieLdsModel> formFieldList = checkFormModel.getFormFieldList();
|
Map<String, Object> dataMap = checkFormModel.getDataMap();
|
DbLinkEntity linkEntity = checkFormModel.getLinkEntity();
|
List<TableModel> tableModelList = checkFormModel.getTableModelList();
|
VisualdevEntity visualdevEntity = checkFormModel.getVisualdevEntity();
|
String id = checkFormModel.getId();
|
Boolean isTransfer = checkFormModel.getIsTransfer();
|
|
FormDataModel formData = JsonUtil.getJsonToBean(visualdevEntity.getFormData(), FormDataModel.class);
|
ColumnDataModel columnDataModel = JsonUtil.getJsonToBean(visualdevEntity.getColumnData(), ColumnDataModel.class);
|
boolean inlineEdit = columnDataModel != null && columnDataModel.getType() != null && columnDataModel.getType() == 4;
|
boolean logicalDelete = formData.getLogicalDelete();
|
|
List<FieLdsModel> fields = new ArrayList<>();
|
FormPublicUtils.recursionFieldsExceptChild(fields, formFieldList);
|
try {
|
//切换数据源
|
DynamicDataSourceUtil.switchToDataSource(linkEntity);
|
@Cleanup Connection conn = ConnUtil.getConnOrDefault(linkEntity);
|
String dbType = conn.getMetaData().getDatabaseProductName().trim();
|
//业务主键判断
|
VisualErrInfo visualErrInfo = this.checkBusinessKey(fields, dataMap, tableModelList, formData, id);
|
if (ObjectUtil.isNotEmpty(visualErrInfo) && StringUtil.isNotEmpty(visualErrInfo.getErrMsg())) {
|
return visualErrInfo.getErrMsg();
|
}
|
//唯一和非空判断
|
List<FormCheckModel> formCheckModels = new ArrayList<>();
|
for (FieLdsModel fieLdsModel : fields) {
|
ConfigModel config = fieLdsModel.getConfig();
|
if(checkFormModel.getIsLink() && !LINK_ALLOW_KEY.contains( config.getJnpfKey())){
|
continue;
|
}
|
Object o = dataMap.get(fieLdsModel.getVModel());
|
if (config.isRequired() && !inlineEdit && !isTransfer) {
|
if (ObjectUtil.isEmpty(o) || StringUtil.isEmpty(o.toString().trim())) {
|
return I18nUtil.getMessageStr(config.getLabelI18nCode(), config.getLabel()) + MsgCode.VS015.get();
|
}
|
}
|
if (JnpfKeyConsts.COM_INPUT.equals(config.getJnpfKey()) && config.getUnique()) {
|
o = ObjectUtil.isEmpty(o) ? null : String.valueOf(o).trim();
|
dataMap.put(fieLdsModel.getVModel(), o);
|
String tableName = fieLdsModel.getConfig().getTableName();
|
//验证唯一
|
SqlTable sqlTable = SqlTable.of(tableName);
|
String key = flowDataUtil.getTableKey(conn, tableName);
|
String vModelThis = fieLdsModel.getVModel();
|
|
String foriegKey = "";
|
String columnName = "";
|
boolean isMain = true;
|
TableModel mainTableModel = new TableModel();
|
TableModel tableModel = new TableModel();
|
for (TableModel item : tableModelList) {
|
if (Objects.equals(item.getTypeId(), "1")) {
|
mainTableModel = item;
|
}
|
|
if (StringUtil.isNotEmpty(fieLdsModel.getConfig().getRelationTable())) {
|
//子表判断
|
if (fieLdsModel.getConfig().getRelationTable().equals(item.getTable())) {
|
tableModel = item;
|
}
|
} else {
|
//主副表判断
|
if (fieLdsModel.getConfig().getTableName().equals(item.getTable())) {
|
tableModel = item;
|
}
|
}
|
}
|
|
if (tableModel != null) {
|
String fieldName = vModelThis;
|
if (!"1".equals(tableModel.getTypeId()) && vModelThis.contains(JnpfConst.SIDE_MARK)){
|
fieldName = vModelThis.split(JnpfConst.SIDE_MARK)[1];
|
isMain = false;
|
foriegKey = tableModel.getTableField();
|
}
|
String finalFieldName = fieldName;
|
TableFields tableFields = tableModel.getFields().stream().filter(t -> t.getField().equals(finalFieldName)).findFirst().orElse(null);
|
if (tableFields != null) {
|
columnName = StringUtil.isNotEmpty(tableFields.getField()) ? tableFields.getField() : fieldName;
|
}
|
}
|
|
List<BasicColumn> selectKey = new ArrayList<>();
|
selectKey.add(sqlTable.column(columnName));
|
selectKey.add(sqlTable.column(key));
|
if (StringUtil.isNotEmpty(foriegKey)) {
|
String finalForiegKey = foriegKey;
|
TableFields tableFields = tableModel.getFields().stream().filter(t -> t.getField().equals(finalForiegKey)).findFirst().orElse(null);
|
if (tableFields != null) {
|
foriegKey = StringUtil.isNotEmpty(tableFields.getField()) ? tableFields.getField() : finalForiegKey;
|
}
|
selectKey.add(sqlTable.column(foriegKey));
|
}
|
|
SqlTable sqlMainTable = SqlTable.of(mainTableModel.getTable());
|
String taskIdField = TableFeildsEnum.FLOWTASKID.getField();
|
if (dbType.contains("Oracle") || dbType.contains("DM DBMS")) {
|
taskIdField = TableFeildsEnum.FLOWTASKID.getField().toUpperCase();
|
}
|
if (dataMap.get(FlowFormConstant.FLOWID) != null && StringUtil.isNotEmpty(dataMap.get(FlowFormConstant.FLOWID).toString())) {
|
selectKey.add(sqlMainTable.column(taskIdField));
|
}
|
QueryExpressionDSL<SelectModel>.QueryExpressionWhereBuilder where;
|
//是否主表
|
if (isMain) {
|
where = SqlBuilder
|
.select(selectKey)
|
.from(sqlTable)
|
.where();
|
} else {
|
where = SqlBuilder
|
.select(selectKey)
|
.from(sqlMainTable)
|
.leftJoin(sqlTable)
|
.on(sqlTable.column(tableModel.getTableField()), new EqualTo(sqlMainTable.column(tableModel.getRelationField())))
|
.where();
|
}
|
if (ObjectUtil.isEmpty(o)) {
|
where.and(sqlTable.column(columnName), SqlBuilder.isNull());
|
} else {
|
where.and(sqlTable.column(columnName), SqlBuilder.isEqualTo(o.toString()));
|
}
|
if (StringUtils.isNotEmpty(id)) {
|
TableFields mainKeyModel = mainTableModel.getFields().stream().filter(t ->
|
Objects.equals(t.getPrimaryKey(), 1) && !t.getField().equalsIgnoreCase(TableFeildsEnum.TENANTID.getField())).findFirst().orElse(null);
|
Object realId = id;
|
if (VisualConst.DB_INT_ALL.contains(mainKeyModel.getDataType().toLowerCase())) {
|
realId = Long.parseLong(id);
|
}
|
where.and(sqlTable.column(mainKeyModel.getField()), SqlBuilder.isNotEqualTo(realId));
|
}
|
if (logicalDelete) {
|
where.and(sqlMainTable.column(TableFeildsEnum.DELETEMARK.getField()), SqlBuilder.isNull());
|
}
|
//是流程
|
if (dataMap.get(FlowFormConstant.FLOWID) != null && StringUtil.isNotEmpty(dataMap.get(FlowFormConstant.FLOWID).toString())) {
|
where.and(sqlMainTable.column(TableFeildsEnum.FLOWID.getField()), SqlBuilder.isEqualTo(dataMap.get(FlowFormConstant.FLOWID)));
|
} else {
|
where.and(sqlMainTable.column(TableFeildsEnum.FLOWID.getField()), SqlBuilder.isNull());
|
}
|
|
SelectStatementProvider render = where.build().render(RenderingStrategies.MYBATIS3);
|
FormCheckModel formCheckModel = new FormCheckModel();
|
formCheckModel.setLabel(I18nUtil.getMessageStr(fieLdsModel.getConfig().getLabelI18nCode(), fieLdsModel.getConfig().getLabel()));
|
formCheckModel.setStatementProvider(render);
|
formCheckModels.add(formCheckModel);
|
}
|
}
|
|
//主副表数据库判重
|
for (FormCheckModel formCheckModel : formCheckModels) {
|
int count = flowFormDataMapper.selectManyMappedRows(formCheckModel.getStatementProvider()).size();
|
if (count > 0) {
|
return formCheckModel.getLabel() + MsgCode.EXIST103.get();
|
}
|
}
|
|
//子表当前表单数据判重
|
List<FieLdsModel> childFieldList = fields.stream().filter(f -> JnpfKeyConsts.CHILD_TABLE.equals(f.getConfig().getJnpfKey())).collect(Collectors.toList());
|
for (FieLdsModel fieLdsModel : childFieldList) {
|
List<Map<String, Object>> childMapList = (List) dataMap.get(fieLdsModel.getVModel());
|
if (ObjectUtil.isEmpty(childMapList)) continue;
|
String tableName = I18nUtil.getMessageStr(fieLdsModel.getConfig().getLabelI18nCode(), fieLdsModel.getConfig().getLabel());
|
for (FieLdsModel childField : fieLdsModel.getConfig().getChildren()) {
|
ConfigModel config = childField.getConfig();
|
if(checkFormModel.getIsLink() && !LINK_ALLOW_KEY.contains( config.getJnpfKey())){
|
continue;
|
}
|
//判断为空
|
if (config.isRequired() && !inlineEdit && !isTransfer) {
|
for (Map<String, Object> item : childMapList) {
|
Object o = item.get(childField.getVModel());
|
if (ObjectUtil.isEmpty(o) || StringUtil.isEmpty(o.toString().trim())) {
|
return tableName + "-" + I18nUtil.getMessageStr(config.getLabelI18nCode(), config.getLabel()) + MsgCode.VS015.get();
|
}
|
}
|
}
|
//判断唯一
|
if (JnpfKeyConsts.COM_INPUT.equals(config.getJnpfKey()) && config.getUnique()) {
|
List<String> childValues = childMapList.stream().filter(ChildTbMap -> ChildTbMap.get(childField.getVModel()) != null)
|
.map(ChildTbMap -> String.valueOf(ChildTbMap.get(childField.getVModel())).trim()).collect(Collectors.toList());
|
if (childValues.size() > 0) {
|
HashSet<String> child = new HashSet<>(childValues);
|
if (child.size() != childValues.size()) {
|
return tableName + "-" + I18nUtil.getMessageStr(config.getLabelI18nCode(), config.getLabel()) + MsgCode.EXIST103.get();
|
}
|
}
|
}
|
}
|
}
|
|
if (conn != null) {
|
conn.close();
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
DynamicDataSourceUtil.clearSwitchDataSource();
|
}
|
return "";
|
}
|
|
public String getCount(Object id, SqlTable sqlTable, TableModel tableModel, DbLinkEntity linkEntity) {
|
try {
|
DynamicDataSourceUtil.switchToDataSource(linkEntity);
|
@Cleanup Connection conn = ConnUtil.getConnOrDefault(linkEntity);
|
String dbType = conn.getMetaData().getDatabaseProductName().trim();
|
String key = flowDataUtil.getKey(tableModel, dbType);
|
String flowTaskId = flowDataUtil.getFlowTaskId(tableModel, dbType);
|
List<AndOrCriteriaGroup> groupList = new ArrayList<>();
|
groupList.add(SqlBuilder.or(sqlTable.column(flowTaskId), SqlBuilder.isEqualTo(id.toString())));
|
|
SelectStatementProvider countRender = SqlBuilder
|
.select(sqlTable.column(key))
|
.from(sqlTable)
|
.where(sqlTable.column(key), SqlBuilder.isEqualTo(id), groupList)
|
.build().render(RenderingStrategies.MYBATIS3);
|
Map<String, Object> map = flowFormDataMapper.selectOneMappedRow(countRender);
|
if (MapUtils.isNotEmpty(map)) {
|
if (Objects.nonNull(map.get(key))) {
|
return map.get(key).toString();
|
}
|
}
|
} catch (DataException e) {
|
e.printStackTrace();
|
} catch (SQLException sqlException) {
|
sqlException.printStackTrace();
|
} finally {
|
DynamicDataSourceUtil.clearSwitchDataSource();
|
}
|
return null;
|
}
|
|
/**
|
* 业务主键 判断
|
*
|
* @param fields
|
* @param data
|
* @param tableList
|
* @param formData
|
* @param id
|
* @return
|
*/
|
public VisualErrInfo checkBusinessKey(List<FieLdsModel> fields, Map<String, Object> data, List<TableModel> tableList, FormDataModel formData, String id) {
|
Boolean logicalDelete = formData.getLogicalDelete();
|
if (formData.isUseBusinessKey()) {
|
List<String> businessKeyList = Arrays.asList(formData.getBusinessKeyList());
|
if (CollectionUtils.isEmpty(businessKeyList)) return null;
|
TableModel mainTable = tableList.stream().filter(t -> t.getTypeId().equals("1")).findFirst().orElse(null);
|
TableFields mainFields = mainTable.getFields().stream().filter(t -> Objects.equals(t.getPrimaryKey(), 1)
|
&& !t.getField().equalsIgnoreCase(TableFeildsEnum.TENANTID.getField())).findFirst().orElse(null);
|
|
SqlTable sqlTable = SqlTable.of(mainTable.getTable());
|
String mainKey = mainFields.getField();
|
String taskIdField = TableFeildsEnum.FLOWTASKID.getField();
|
TableFields taskIdFielde = mainTable.getFields().stream().filter(t -> TableFeildsEnum.FLOWTASKID.getField().equalsIgnoreCase(t.getField())).findFirst().orElse(null);
|
if (ObjectUtil.isNotEmpty(taskIdFielde)) {
|
taskIdField = taskIdFielde.getField();
|
}
|
List<BasicColumn> selectKey = new ArrayList<>();
|
selectKey.add(sqlTable.column(mainKey));
|
if (data.get(FlowFormConstant.FLOWID) != null && StringUtil.isNotEmpty(data.get(FlowFormConstant.FLOWID).toString())) {
|
selectKey.add(sqlTable.column(taskIdField));
|
}
|
QueryExpressionDSL<SelectModel>.QueryExpressionWhereBuilder where = SqlBuilder.select(selectKey).from(sqlTable).where();
|
|
for (FieLdsModel fieLdsModel : fields) {
|
String fieldName = fieLdsModel.getVModel();
|
Object o = data.get(fieldName);
|
if (businessKeyList.contains(fieldName)) {
|
if (ObjectUtil.isEmpty(o)) {
|
where.and(sqlTable.column(fieldName), SqlBuilder.isNull());
|
} else {
|
o = o instanceof List ? JsonUtil.getObjectToString(o) : o;
|
if (JnpfKeyConsts.DateSelect.contains(fieLdsModel.getConfig().getJnpfKey())) {
|
try {
|
o = new Date((Long) o);
|
} catch (Exception e) {
|
try {
|
String format = fieLdsModel.getFormat();
|
SimpleDateFormat sdf = new SimpleDateFormat(format);
|
o = sdf.parse(String.valueOf(o));
|
} catch (Exception ex) {
|
|
}
|
}
|
}
|
where.and(sqlTable.column(fieldName), SqlBuilder.isEqualTo(o));
|
}
|
}
|
}
|
//更新跳过本条数据
|
if (StringUtils.isNotEmpty(id)) {
|
Object realId = id;
|
if (VisualConst.DB_INT_ALL.contains(mainFields.getDataType().toLowerCase())) {
|
realId = Long.parseLong(id);
|
}
|
where.and(sqlTable.column(mainKey), SqlBuilder.isNotEqualTo(realId));
|
}
|
//流程数据过滤
|
if (data.get(FlowFormConstant.FLOWID) != null && StringUtil.isNotEmpty(data.get(FlowFormConstant.FLOWID).toString())) {
|
where.and(sqlTable.column(TableFeildsEnum.FLOWID.getField()), SqlBuilder.isEqualTo(data.get(FlowFormConstant.FLOWID)));
|
} else {
|
where.and(sqlTable.column(TableFeildsEnum.FLOWID.getField()), SqlBuilder.isNull());
|
}
|
//逻辑删除
|
if (logicalDelete) {
|
where.and(sqlTable.column(TableFeildsEnum.DELETEMARK.getField()), SqlBuilder.isNull());
|
}
|
SelectStatementProvider render = where.build().render(RenderingStrategies.MYBATIS3);
|
List<Map<String, Object>> maps;
|
try {
|
maps = flowFormDataMapper.selectManyMappedRows(render);
|
} catch (Exception e) {
|
return null;
|
}
|
int count = maps.size();
|
if (count > 0) {
|
VisualErrInfo visualErrInfo = VisualErrInfo.builder().errMsg(formData.getBusinessKeyTip()).build();
|
if (ObjectUtil.isNotEmpty(maps.get(0).get(mainKey))) {
|
visualErrInfo.setId(maps.get(0).get(mainKey).toString());
|
}
|
if (ObjectUtil.isNotEmpty(maps.get(0).get(taskIdField))) {
|
visualErrInfo.setFlowTaskId(maps.get(0).get(taskIdField).toString());
|
}
|
return visualErrInfo;
|
}
|
}
|
return null;
|
}
|
|
/**
|
* 判断excel表内业务主键是否重复
|
*
|
* @param formData
|
* @param resultMap
|
* @param uniqueModel
|
* @return
|
*/
|
public String checkBusinessKeyExcel(FormDataModel formData, Map<String, Object> resultMap, ImportFormCheckUniqueModel uniqueModel) {
|
List<String> businessKeyList = Arrays.asList(formData.getBusinessKeyList());
|
List<Map<String, Object>> successList = uniqueModel.getImportDataModel().stream().map(ImportDataModel::getResultData).collect(Collectors.toList());
|
if (com.baomidou.mybatisplus.core.toolkit.CollectionUtils.isNotEmpty(successList)) {
|
boolean exists = false;
|
for (int uniqueIndex = 0; uniqueIndex < successList.size(); uniqueIndex++) {
|
Map<String, Object> indexMap = successList.get(uniqueIndex);
|
boolean hasB = false;
|
for (String fieldsKey : businessKeyList) {
|
if ((resultMap.get(fieldsKey) == null && indexMap.get(fieldsKey) == null)
|
|| (resultMap.get(fieldsKey) != null && resultMap.get(fieldsKey).equals(indexMap.get(fieldsKey)))) {
|
hasB = true;
|
} else {
|
//有一个没匹配上就跳出循环
|
hasB = false;
|
break;
|
}
|
}
|
if (hasB) {
|
exists = true;
|
if (uniqueModel.isUpdate()) {
|
uniqueModel.getImportDataModel().get(uniqueIndex).setResultData(resultMap);
|
}
|
break;
|
}
|
}
|
if (exists) {
|
return formData.getBusinessKeyTip();
|
}
|
}
|
return null;
|
}
|
}
|
