package jnpf.onlinedev.util;
|
|
|
import jnpf.base.entity.DataInterfaceEntity;
|
import jnpf.base.entity.VisualdevEntity;
|
import jnpf.base.entity.VisualdevReleaseEntity;
|
import jnpf.base.model.ColumnDataModel;
|
import jnpf.base.model.VisualDevJsonModel;
|
import jnpf.base.model.VisualWebTypeEnum;
|
import jnpf.base.model.template.ColumnListField;
|
import jnpf.constant.MsgCode;
|
import jnpf.database.model.query.SuperJsonModel;
|
import jnpf.database.model.query.SuperQueryJsonModel;
|
import jnpf.exception.WorkFlowException;
|
import jnpf.model.visualjson.FieLdsModel;
|
import jnpf.model.visualjson.FormDataModel;
|
import jnpf.model.visualjson.TableModel;
|
import jnpf.model.visualjson.config.ConfigModel;
|
import jnpf.onlinedev.model.enums.MultipleControlEnum;
|
import jnpf.util.JsonUtil;
|
import jnpf.util.StringUtil;
|
import jnpf.util.XSSEscape;
|
import jnpf.util.visiual.JnpfKeyConsts;
|
import org.apache.commons.collections4.MapUtils;
|
import org.apache.commons.lang3.StringUtils;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 在线开发公用
|
*
|
* @author JNPF开发平台组
|
* @version V3.1.0
|
* @copyright 引迈信息技术有限公司（https://www.jnpfsoft.com）
|
* @date 2021/7/28
|
*/
|
public class OnlinePublicUtils {
|
OnlinePublicUtils() {
|
}
|
|
/**
|
* map key转小写
|
*
|
* @param requestMap
|
* @return
|
*/
|
public static Map<String, Object> mapKeyToLower(Map<String, ?> requestMap) {
|
// 非空校验
|
if (requestMap.isEmpty()) {
|
return Collections.emptyMap();
|
}
|
// 初始化放转换后数据的Map
|
Map<String, Object> responseMap = new HashMap<>(16);
|
// 使用迭代器进行循环遍历
|
Set<String> requestSet = requestMap.keySet();
|
Iterator<String> iterator = requestSet.iterator();
|
iterator.forEachRemaining(obj -> {
|
// 判断Key对应的Value是否为Map
|
if ((requestMap.get(obj) instanceof Map)) {
|
// 递归调用，将value中的Map的key转小写
|
responseMap.put(obj.toLowerCase(), mapKeyToLower((Map) requestMap.get(obj)));
|
} else {
|
// 直接将key小写放入responseMap
|
responseMap.put(obj.toLowerCase(), requestMap.get(obj));
|
}
|
});
|
|
return responseMap;
|
}
|
|
/**
|
* 递归控件
|
*
|
* @param allFields
|
* @param fieLdsModelList
|
* @return
|
*/
|
public static void recursionFields(List<FieLdsModel> allFields, List<FieLdsModel> fieLdsModelList) {
|
for (FieLdsModel fieLdsModel : fieLdsModelList) {
|
ConfigModel config = fieLdsModel.getConfig();
|
String jnpfKey = config.getJnpfKey();
|
if (JnpfKeyConsts.CHILD_TABLE.equals(jnpfKey)) {
|
allFields.add(fieLdsModel);
|
} else {
|
if (config.getChildren() != null) {
|
recursionFields(allFields, config.getChildren());
|
} else {
|
if (jnpfKey != null) {
|
allFields.add(fieLdsModel);
|
}
|
}
|
}
|
}
|
}
|
|
/**
|
* 判断字符串是否有某个字符存在
|
*
|
* @param var1 完整字符串
|
* @param var2 统计字符
|
* @return
|
*/
|
public static boolean getMultiple(String var1, String var2) {
|
if (var1 == null) {
|
return false;
|
}
|
return var1.startsWith(var2);
|
}
|
|
/**
|
* 数据字典处理（从缓存中取出）
|
*
|
* @param dataList
|
* @param swapModel
|
* @return
|
*/
|
public static Map<String, Object> getDataMap(List<Map<String, Object>> dataList, FieLdsModel swapModel) {
|
String label = swapModel.getProps() != null ? swapModel.getProps().getLabel() : "";
|
String value = swapModel.getProps() != null ? swapModel.getProps().getValue() : "";
|
Map<String, Object> dataInterfaceMap = new HashMap<>();
|
dataList.stream().forEach(data -> dataInterfaceMap.put(String.valueOf(data.get(value)), String.valueOf(data.get(label))));
|
return dataInterfaceMap;
|
}
|
|
/**
|
* 递归控件
|
*
|
* @return
|
*/
|
public static void recursionFormFields(List<FieLdsModel> allFields, List<FieLdsModel> fieLdsModelList) {
|
for (FieLdsModel fieLdsModel : fieLdsModelList) {
|
ConfigModel config = fieLdsModel.getConfig();
|
String jnpfKey = config.getJnpfKey();
|
if (JnpfKeyConsts.CHILD_TABLE.equals(jnpfKey)) {
|
allFields.add(fieLdsModel);
|
} else {
|
if (config.getChildren() != null) {
|
recursionFormFields(allFields, config.getChildren());
|
} else {
|
allFields.add(fieLdsModel);
|
}
|
}
|
}
|
}
|
|
/**
|
* 递归控件(取出所有子集)
|
*
|
* @return
|
*/
|
public static void recursionFormChildFields(List<FieLdsModel> allFields, List<FieLdsModel> fieLdsModelList) {
|
for (FieLdsModel fieLdsModel : fieLdsModelList) {
|
ConfigModel config = fieLdsModel.getConfig();
|
String jnpfKey = config.getJnpfKey();
|
if (JnpfKeyConsts.CHILD_TABLE.equals(jnpfKey)) {
|
String childVmodel = fieLdsModel.getVModel();
|
String childLabel = fieLdsModel.getConfig().getLabel();
|
for (FieLdsModel child : Optional.ofNullable(fieLdsModel.getConfig().getChildren()).orElse(new ArrayList<>())) {
|
if (child.getVModel() != null) {
|
child.setVModel(childVmodel + "-" + child.getVModel());
|
child.getConfig().setLabel(childLabel + "-" + child.getConfig().getLabel());
|
allFields.add(child);
|
}
|
}
|
} else {
|
if (config.getChildren() != null) {
|
recursionFormChildFields(allFields, config.getChildren());
|
} else {
|
if (StringUtil.isNotEmpty(fieLdsModel.getVModel())) {
|
allFields.add(fieLdsModel);
|
}
|
}
|
}
|
}
|
}
|
|
/**
|
* @param redisMap 缓存集合
|
* @param modelData 数据
|
* @param isMultiple 是否多选
|
* @return
|
*/
|
public static String getDataInMethod(Map<String, Object> redisMap, Object modelData, boolean isMultiple) {
|
if (redisMap == null || redisMap.isEmpty()) {
|
return modelData.toString();
|
}
|
String separator = isMultiple ? ";" : "/";
|
String s2;
|
if (OnlinePublicUtils.getMultiple(String.valueOf(modelData), MultipleControlEnum.MULTIPLE_JSON_TWO.getMultipleChar())) {
|
String[][] data = JsonUtil.getJsonToBean(String.valueOf(modelData), String[][].class);
|
List<String> addList = new ArrayList<>();
|
for (String[] AddressData : data) {
|
List<String> adList = new ArrayList<>();
|
for (String s : AddressData) {
|
adList.add(String.valueOf(redisMap.get(s)));
|
}
|
addList.add(String.join("/", adList));
|
}
|
s2 = String.join(";", addList);
|
} else if (OnlinePublicUtils.getMultiple(String.valueOf(modelData), MultipleControlEnum.MULTIPLE_JSON_ONE.getMultipleChar())) {
|
List<String> modelDataList = JsonUtil.getJsonToList(String.valueOf(modelData), String.class);
|
modelDataList = modelDataList.stream().map(s -> String.valueOf(redisMap.get(s))).collect(Collectors.toList());
|
s2 = String.join(separator, modelDataList);
|
} else {
|
String[] modelDatas = String.valueOf(modelData).split(",");
|
StringBuilder dynamicData = new StringBuilder();
|
for (int i = 0; i < modelDatas.length; i++) {
|
modelDatas[i] = String.valueOf(Objects.nonNull(redisMap.get(modelDatas[i])) ? redisMap.get(modelDatas[i]) : "");
|
dynamicData.append(modelDatas[i]);
|
dynamicData.append(separator);
|
}
|
s2 = dynamicData.deleteCharAt(dynamicData.length() - 1).toString();
|
}
|
return StringUtil.isEmpty(s2) ? modelData.toString() : s2;
|
}
|
|
public static List<String> getDataNoSwapInMethod(Object modelData) {
|
List<String> dataValueList = new ArrayList<>();
|
if (OnlinePublicUtils.getMultiple(String.valueOf(modelData), MultipleControlEnum.MULTIPLE_JSON_ONE.getMultipleChar())) {
|
List<String> modelDataList = JsonUtil.getJsonToList(String.valueOf(modelData), String.class);
|
dataValueList = modelDataList;
|
} else {
|
dataValueList.addAll(Arrays.asList(String.valueOf(modelData).split(",")));
|
}
|
return dataValueList;
|
}
|
|
public static VisualDevJsonModel getVisualJsonModel(VisualdevEntity entity) {
|
VisualDevJsonModel jsonModel = new VisualDevJsonModel();
|
if (entity.getColumnData() != null) {
|
jsonModel.setColumnData(JsonUtil.getJsonToBean(entity.getColumnData(), ColumnDataModel.class));
|
}
|
if (entity.getAppColumnData() != null) {
|
jsonModel.setAppColumnData(JsonUtil.getJsonToBean(entity.getAppColumnData(), ColumnDataModel.class));
|
}
|
FormDataModel formDataModel = JsonUtil.getJsonToBean(entity.getFormData(), FormDataModel.class);
|
jsonModel.setFormData(formDataModel);
|
if (!VisualWebTypeEnum.DATA_VIEW.getType().equals(entity.getWebType())) {
|
jsonModel.setFormListModels(JsonUtil.getJsonToList(formDataModel.getFields(), FieLdsModel.class));
|
}
|
jsonModel.setVisualTables(JsonUtil.getJsonToList(entity.getVisualTables(), TableModel.class));
|
jsonModel.setId(entity.getId());
|
jsonModel.setDbLinkId(entity.getDbLinkId());
|
jsonModel.setFullName(entity.getFullName());
|
jsonModel.setType(entity.getType());
|
jsonModel.setWebType(entity.getWebType());
|
return jsonModel;
|
}
|
|
public static VisualDevJsonModel getVisualJsonModel(VisualdevReleaseEntity entity) throws WorkFlowException {
|
if (entity == null) throw new WorkFlowException(MsgCode.VS412.get());
|
VisualDevJsonModel jsonModel = new VisualDevJsonModel();
|
if (entity.getColumnData() != null) {
|
jsonModel.setColumnData(JsonUtil.getJsonToBean(entity.getColumnData(), ColumnDataModel.class));
|
}
|
if (entity.getAppColumnData() != null) {
|
jsonModel.setAppColumnData(JsonUtil.getJsonToBean(entity.getAppColumnData(), ColumnDataModel.class));
|
}
|
FormDataModel formDataModel = JsonUtil.getJsonToBean(entity.getFormData(), FormDataModel.class);
|
jsonModel.setFormData(formDataModel);
|
if (!VisualWebTypeEnum.DATA_VIEW.getType().equals(entity.getWebType())) {
|
jsonModel.setFormListModels(JsonUtil.getJsonToList(formDataModel.getFields(), FieLdsModel.class));
|
}
|
jsonModel.setVisualTables(JsonUtil.getJsonToList(entity.getVisualTables(), TableModel.class));
|
jsonModel.setId(entity.getId());
|
jsonModel.setDbLinkId(entity.getDbLinkId());
|
jsonModel.setFullName(entity.getFullName());
|
jsonModel.setType(entity.getType());
|
jsonModel.setWebType(entity.getWebType());
|
return jsonModel;
|
}
|
|
/**
|
* 视图sql条件拼接
|
*
|
* @param info
|
* @param queryCondition
|
* @param parameterMap
|
* @return
|
*/
|
public static void getViewQuerySql(DataInterfaceEntity info, List<FieLdsModel> queryCondition,
|
Map<String, String> parameterMap, Map<String, Object> extraMap) {
|
if (!Objects.equals(info.getType(), 1) || queryCondition.isEmpty()) {
|
return;
|
}
|
|
List<String> conditions = new ArrayList<>();
|
List<String> values = new ArrayList<>();
|
|
// 处理查询条件
|
for (FieLdsModel item : queryCondition) {
|
String condition = buildSearchCondition(item, values);
|
if (StringUtil.isNotEmpty(condition)) {
|
conditions.add(condition);
|
}
|
}
|
|
// 处理额外条件
|
if (MapUtils.isNotEmpty(extraMap)) {
|
for (Map.Entry<String, Object> entry : extraMap.entrySet()) {
|
String fieldName = "t." + entry.getKey();
|
Object fieldValue = entry.getValue();
|
if (fieldValue != null && StringUtil.isNotEmpty(fieldValue.toString())) {
|
values.add(XSSEscape.escape(fieldValue.toString()));
|
conditions.add(fieldName + " = ?");
|
}
|
}
|
}
|
|
// 构建最终SQL
|
if (!conditions.isEmpty()) {
|
String searchSqlStr = String.join(" and ", conditions);
|
parameterMap.put("searchSqlStr", searchSqlStr);
|
parameterMap.put("searchValues", JsonUtil.getObjectToString(values));
|
}
|
}
|
|
/**
|
* 构建查询条件 - 合并所有搜索类型的处理逻辑
|
*/
|
private static String buildSearchCondition(FieLdsModel item, List<String> values) {
|
if (item == null) {
|
return null;
|
}
|
|
String fieldName = "t." + item.getVModel();
|
String escapedValue;
|
|
switch (item.getSearchType()) {
|
case 1: // 等于
|
Object fieldValue = item.getFieldValue();
|
if (fieldValue == null || StringUtil.isEmpty(fieldValue.toString())) {
|
return null;
|
}
|
escapedValue = XSSEscape.escape(fieldValue.toString());
|
values.add(escapedValue);
|
return fieldName + " = ?";
|
|
case 2: // 模糊查询
|
fieldValue = item.getFieldValue();
|
if (fieldValue == null || StringUtil.isEmpty(fieldValue.toString())) {
|
return null;
|
}
|
escapedValue = XSSEscape.escape(fieldValue.toString());
|
values.add("%" + escapedValue + "%");
|
return fieldName + " like ?";
|
|
case 3: // BETWEEN
|
Object valueOne = item.getFieldValueOne();
|
Object valueTwo = item.getFieldValueTwo();
|
if (valueOne == null || valueTwo == null) {
|
return null;
|
}
|
String escapedOne = XSSEscape.escape(String.valueOf(valueOne));
|
String escapedTwo = XSSEscape.escape(String.valueOf(valueTwo));
|
values.add(escapedOne);
|
values.add(escapedTwo);
|
return fieldName + " between ? and ?";
|
|
case 4: // 包含（多个值的模糊查询）
|
List<String> dataList = item.getDataList();
|
if (dataList == null || dataList.isEmpty()) {
|
return null;
|
}
|
|
List<String> likeConditions = new ArrayList<>();
|
for (String value : dataList) {
|
if (StringUtil.isNotEmpty(value)) {
|
escapedValue = XSSEscape.escape(value);
|
values.add("%" + escapedValue + "%");
|
likeConditions.add(fieldName + " like ?");
|
}
|
}
|
|
if (likeConditions.isEmpty()) {
|
return null;
|
}
|
return "(" + String.join(" or ", likeConditions) + ")";
|
|
default:
|
return null;
|
}
|
}
|
|
/**
|
* 视图非sql条件过滤
|
*
|
* @param info
|
* @param queryCondition
|
* @param dataRes
|
* @return
|
*/
|
public static List<Map<String, Object>> getViewQueryNotSql(DataInterfaceEntity info, List<FieLdsModel> queryCondition, List<Map<String, Object>> dataRes, Map<String, Object> extraMap) {
|
//是否包含页签参数
|
boolean hasExtra = false;
|
String key = "";
|
if (MapUtils.isNotEmpty(extraMap)) {
|
hasExtra = true;
|
List<String> keyList = new ArrayList<>(extraMap.keySet());
|
key = keyList.get(0);
|
}
|
List<Map<String, Object>> dataInterfaceList = new ArrayList<>();
|
if (!Objects.equals(info.getType(), 1) && !queryCondition.isEmpty()) {
|
for (Map<String, Object> map : dataRes) {
|
if (OnlinePublicUtils.mapCompar(queryCondition, map)) {
|
if (hasExtra) {
|
if (Objects.equals(map.get(key), extraMap.get(key))) dataInterfaceList.add(map);
|
} else {
|
dataInterfaceList.add(map);
|
}
|
}
|
}
|
} else {
|
for (Map<String, Object> map : dataRes) {
|
if (hasExtra) {
|
if (Objects.equals(map.get(key), extraMap.get(key))) dataInterfaceList.add(map);
|
} else {
|
dataInterfaceList.add(map);
|
}
|
}
|
}
|
return dataInterfaceList;
|
}
|
|
/**
|
* 判断两个map有相同key-value
|
*
|
* @return
|
* @copyright 引迈信息技术有限公司
|
* @date 2023/1/5
|
*/
|
public static boolean mapCompar(List<FieLdsModel> searchList, Map<String, Object> hashMap2) {
|
boolean isChange = false;
|
for (FieLdsModel item : searchList) {
|
String realValue = hashMap2.get(item.getVModel()) == null ? "" : (String) hashMap2.get(item.getVModel());
|
switch (item.getSearchType()) {
|
case 2:
|
if (realValue.indexOf(item.getFieldValue()) >= 0) {
|
isChange = true;
|
}
|
break;
|
case 3://between
|
List<String> longList = Arrays.asList(JnpfKeyConsts.NUM_INPUT, JnpfKeyConsts.DATE, JnpfKeyConsts.DATE_CALCULATE);
|
if (longList.contains(item.getConfig().getJnpfKey())) {
|
Long valueLong = Long.parseLong(realValue);
|
Long valueLongOne = (Long) item.getFieldValueOne();
|
Long valueLongTwo = (Long) item.getFieldValueTwo();
|
if (valueLong >= valueLongOne && valueLong <= valueLongTwo) {
|
isChange = true;
|
}
|
} else {
|
String valueLongOne = (String) item.getFieldValueOne();
|
String valueLongTwo = (String) item.getFieldValueTwo();
|
if (realValue.compareTo(valueLongOne) >= 0 && realValue.compareTo(valueLongTwo) <= 0) {
|
isChange = true;
|
}
|
}
|
break;
|
case 4://包含
|
List<String> dataList = item.getDataList();
|
for (String value : dataList) {
|
isChange = value.indexOf(realValue) >= 0;
|
}
|
if (isChange) {
|
return true;
|
}
|
break;
|
default://1,其他条件都按等于查询
|
isChange = item.getFieldValue().equals(realValue);
|
break;
|
}
|
}
|
return isChange;
|
}
|
|
/**
|
* 获取所有有使用的表
|
*
|
* @return
|
*/
|
public static List<String> getAllTableName(List<ColumnListField> modelList, List<SuperJsonModel> listQuery, Map<String, String> fieldTableMap) {
|
List<String> list = new ArrayList<>();
|
|
for (ColumnListField item : modelList) {
|
String table = StringUtil.isNotEmpty(item.getConfig().getRelationTable()) ?
|
item.getConfig().getRelationTable() : item.getConfig().getTableName();
|
if (StringUtils.isBlank(table)) {
|
table = fieldTableMap.get(item.getConfig().getParentVModel());
|
}
|
list.add(table);
|
}
|
for (SuperJsonModel superJsonModel : listQuery) {
|
if (superJsonModel.getConditionList() != null && !superJsonModel.getConditionList().isEmpty()) {
|
List<SuperQueryJsonModel> conditionList = superJsonModel.getConditionList();
|
for (SuperQueryJsonModel sqj : conditionList) {
|
if (sqj.getGroups() != null && !sqj.getGroups().isEmpty()) {
|
List<FieLdsModel> groups = sqj.getGroups();
|
for (FieLdsModel item : groups) {
|
String table = StringUtil.isNotEmpty(item.getConfig().getRelationTable()) ?
|
item.getConfig().getRelationTable() : item.getConfig().getTableName();
|
list.add(table);
|
}
|
}
|
}
|
}
|
}
|
return list.stream().distinct().collect(Collectors.toList());
|
}
|
|
|
/**
|
* 递归控件(取出所有子集=-字段不变)
|
*
|
* @return
|
*/
|
public static void getAllFields(List<FieLdsModel> allFields, List<FieLdsModel> fieLdsModelList) {
|
for (FieLdsModel fieLdsModel : fieLdsModelList) {
|
ConfigModel config = fieLdsModel.getConfig();
|
String jnpfKey = config.getJnpfKey();
|
if (JnpfKeyConsts.CHILD_TABLE.equals(jnpfKey)) {
|
allFields.addAll(config.getChildren());
|
} else {
|
if (config.getChildren() != null) {
|
getAllFields(allFields, config.getChildren());
|
} else {
|
if (StringUtil.isNotEmpty(fieLdsModel.getVModel())) {
|
allFields.add(fieLdsModel);
|
}
|
}
|
}
|
}
|
}
|
}
|
