package jnpf.flowable.util;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import com.google.common.collect.ImmutableList;
|
import jnpf.base.UserInfo;
|
import jnpf.emnus.SearchMethodEnum;
|
import jnpf.flowable.entity.RecordEntity;
|
import jnpf.flowable.entity.TaskEntity;
|
import jnpf.flowable.enums.FieldEnum;
|
import jnpf.flowable.enums.NodeEnum;
|
import jnpf.flowable.model.task.FlowMethod;
|
import jnpf.flowable.model.task.FlowModel;
|
import jnpf.flowable.model.templatejson.FlowParamModel;
|
import jnpf.flowable.model.templatenode.nodejson.GroupsModel;
|
import jnpf.flowable.model.templatenode.nodejson.NodeModel;
|
import jnpf.flowable.model.templatenode.nodejson.ProperCond;
|
import jnpf.flowable.model.templatenode.nodejson.TemplateJsonModel;
|
import jnpf.permission.entity.UserEntity;
|
import jnpf.util.JsonUtil;
|
import jnpf.util.StringUtil;
|
import jnpf.util.visiual.JnpfKeyConsts;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.commons.text.StringSubstitutor;
|
|
import javax.script.ScriptEngine;
|
import javax.script.ScriptEngineManager;
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.text.NumberFormat;
|
import java.util.*;
|
import java.util.regex.Matcher;
|
import java.util.regex.Pattern;
|
|
/**
|
* 类的描述
|
*
|
* @author JNPF@YinMai Info. Co., Ltd
|
* @version 5.0.x
|
* @since 2024/4/18 20:22
|
*/
|
|
public class FlowJsonUtil {
|
|
/**
|
* 节点条件判断
|
**/
|
public static boolean nodeConditionDecide(FlowMethod flowMethod) {
|
List<ProperCond> conditionList = flowMethod.getConditions();
|
String matchLogic = flowMethod.getMatchLogic();
|
boolean flag = false;
|
ScriptEngineManager scriptEngineManager = new ScriptEngineManager();
|
ScriptEngine scriptEngine = scriptEngineManager.getEngineByName("js");
|
Map<String, Object> map = flowMethod.getFormData();
|
List<String> expressionAll = new ArrayList<>();
|
StringBuilder condition = new StringBuilder();
|
for (int k = 0; k < conditionList.size(); k++) {
|
StringBuilder expression = new StringBuilder();
|
expression.append("(");
|
ProperCond properCond = conditionList.get(k);
|
String logic = properCond.getLogic();
|
List<GroupsModel> groups = properCond.getGroups();
|
for (int i = 0; i < groups.size(); i++) {
|
GroupsModel groupsModel = groups.get(i);
|
String contain = "!=-1";
|
String field = groupsModel.getField();
|
String jnpfKey = groupsModel.getJnpfKey();
|
int fieldType = groupsModel.getFieldType();
|
String symbol = groupsModel.getSymbol();
|
boolean inLike = "like".equals(symbol) || "notLike".equals(symbol);
|
boolean includes = "in".equals(symbol) || "notIn".equals(symbol);
|
Object form = Objects.equals(FieldEnum.Field.getCode(), fieldType) ? formValue(flowMethod, jnpfKey, map.get(field)) : formula(groupsModel, map);
|
Object formValue = form;
|
if ("<>".equals(symbol)) {
|
symbol = "!=";
|
}
|
int fieldValueType = groupsModel.getFieldValueType();
|
String valueJnpfKey = StringUtil.isNotEmpty(groupsModel.getFieldValueJnpfKey()) ? groupsModel.getFieldValueJnpfKey() : jnpfKey;
|
Object filedData = groupsModel.getFieldValue();
|
|
List<Integer> valueType = ImmutableList.of(FieldEnum.Condition.getCode(), FieldEnum.System.getCode());
|
Object value = null;
|
List<Object> includeValue = new ArrayList<>();
|
if (valueType.contains(fieldValueType)) {
|
|
TemplateJsonModel templateJsonModel = new TemplateJsonModel();
|
templateJsonModel.setField(groupsModel.getField());
|
templateJsonModel.setSourceType(Objects.equals(FieldEnum.Condition.getCode(), fieldValueType) ? FieldEnum.System.getCode() : FieldEnum.Field.getCode());
|
templateJsonModel.setRelationField(String.valueOf(groupsModel.getFieldValue()));
|
|
FlowUtil flowUtil = new FlowUtil();
|
TaskEntity taskEntity = flowMethod.getTaskEntity();
|
|
Map<String, Object> mapData = new HashMap<>();
|
if (null != taskEntity) {
|
if (StringUtil.isNotEmpty(taskEntity.getGlobalParameter())) {
|
mapData = JsonUtil.stringToMap(taskEntity.getGlobalParameter());
|
}
|
}
|
if (CollectionUtil.isEmpty(mapData)) {
|
NodeModel global = flowMethod.getNodes().get(NodeEnum.global.getType());
|
if (null != global) {
|
List<FlowParamModel> paramModelList = global.getGlobalParameterList();
|
for (FlowParamModel model : paramModelList) {
|
mapData.put(model.getFieldName(), model.getDefaultValue());
|
}
|
}
|
}
|
|
List<TemplateJsonModel> list = new ArrayList<>();
|
list.add(templateJsonModel);
|
RecordEntity record = new RecordEntity();
|
record.setNodeCode(flowMethod.getNodeCode());
|
UserEntity createUser = flowMethod.getCreateUser();
|
UserEntity delegate = flowMethod.getDelegate();
|
|
FlowModel parameterModel = new FlowModel();
|
parameterModel.setFormData(mapData);
|
parameterModel.setRecordEntity(record);
|
parameterModel.setTaskEntity(taskEntity);
|
Map<String, String> resMap = flowUtil.parameterMap(parameterModel, list, createUser, delegate);
|
if (includes) {
|
if (filedData instanceof List) {
|
List<String> filedList = (List<String>) filedData;
|
for (String id : filedList) {
|
String fieldValue = resMap.get(id) != null ? resMap.get(id) : "";
|
includeValue.add("'" + fieldValue + "'");
|
}
|
}
|
} else {
|
value = resMap.get(filedData);
|
if (value != null) {
|
value = "'" + value + "'";
|
}
|
}
|
} else {
|
if (includes) {
|
if (filedData instanceof List) {
|
List<String> filedList = (List<String>) filedData;
|
for (String id : filedList) {
|
if (Objects.equals(FieldEnum.Custom.getCode(), fieldValueType)) {
|
filedValue(flowMethod, id, valueJnpfKey, form, includeValue);
|
} else {
|
filedData(flowMethod, id, valueJnpfKey, form, includeValue);
|
}
|
}
|
}
|
} else {
|
value = Objects.equals(FieldEnum.Custom.getCode(), fieldValueType) ? filedValue(flowMethod, filedData, valueJnpfKey, form, includeValue) : filedData(flowMethod, filedData, valueJnpfKey, form, includeValue);
|
}
|
}
|
Object fieldValue = value;
|
String pression = formValue + symbol + fieldValue;
|
// 比较的处理
|
if ("<=".equals(symbol) || "<".equals(symbol) || ">".equals(symbol) || ">=".equals(symbol)) {
|
try {
|
String formValueStr = formValue.toString();
|
if (formValueStr.startsWith("'") && formValueStr.endsWith("'")) {
|
formValueStr = formValueStr.substring(1, formValueStr.length() - 1);
|
}
|
fieldValue = fieldValue == null ? "" : fieldValue;
|
String fieldValueStr = fieldValue.toString();
|
if (fieldValueStr.startsWith("'") && fieldValueStr.endsWith("'")) {
|
fieldValueStr = fieldValueStr.substring(1, fieldValueStr.length() - 1);
|
}
|
BigDecimal a = new BigDecimal(formValueStr);
|
BigDecimal b = new BigDecimal(fieldValueStr);
|
boolean res = false;
|
if ("<=".equals(symbol)) {
|
res = a.compareTo(b) <= 0;
|
} else if ("<".equals(symbol)) {
|
res = a.compareTo(b) < 0;
|
} else if (">".equals(symbol)) {
|
res = a.compareTo(b) > 0;
|
} else if (">=".equals(symbol)) {
|
res = a.compareTo(b) >= 0;
|
}
|
pression = res + "";
|
} catch (Exception e) {
|
System.out.println(e.getMessage());
|
pression = "false";
|
}
|
}
|
if (inLike) {
|
if ("notLike".equals(symbol)) {
|
contain = "==-1";
|
}
|
symbol = ".indexOf";
|
if (!(formValue instanceof CharSequence)) {
|
formValue = "'" + formValue + "'";
|
}
|
if (!(fieldValue instanceof CharSequence)) {
|
fieldValue = "'" + fieldValue + "'";
|
}
|
pression = formValue + ".toString()" + symbol + "(" + fieldValue + ")" + contain;
|
}
|
if (includes) {
|
try {
|
boolean isNotIn = "notIn".equals(symbol);
|
String searchModel = isNotIn ? " && " : " || ";
|
symbol = !isNotIn ? " == " : " != ";
|
if (!(formValue instanceof CharSequence)) {
|
formValue = "'" + formValue + "'";
|
}
|
StringBuilder json = new StringBuilder();
|
json.append("(");
|
for (int s = 0; s < includeValue.size(); s++) {
|
Object valuse = includeValue.get(s);
|
if (!(valuse instanceof CharSequence)) {
|
valuse = "'" + valuse + "'";
|
}
|
json.append(formValue + symbol + valuse);
|
if (s != includeValue.size() - 1) {
|
json.append(searchModel);
|
}
|
}
|
json.append(")");
|
pression = includeValue.isEmpty() ? "false" : json.toString();
|
} catch (Exception e) {
|
System.out.println(e.getMessage());
|
pression = "false";
|
}
|
}
|
if (ObjectUtil.equals(symbol, "null")) {
|
pression = "(" + formValue + " == null || " + formValue + " == '')";
|
}
|
if (ObjectUtil.equals(symbol, "notNull")) {
|
pression = "(" + formValue + " != null && " + formValue + " != '')";
|
}
|
expression.append(pression);
|
if (!StringUtils.isEmpty(logic) && i != groups.size() - 1) {
|
expression.append(" " + search(logic) + " ");
|
}
|
}
|
expression.append(")");
|
expressionAll.add(expression.toString());
|
}
|
for (int i = 0; i < expressionAll.size(); i++) {
|
String script = expressionAll.get(i);
|
String search = i != expressionAll.size() - 1 ? search(matchLogic) : "";
|
condition.append(script + " " + search + " ");
|
}
|
try {
|
flag = (Boolean) scriptEngine.eval(condition.toString());
|
} catch (Exception e) {
|
System.out.println(e.getMessage());
|
}
|
return flag;
|
}
|
|
/**
|
* 条件表达式
|
*
|
* @param logic
|
*/
|
private static String search(String logic) {
|
return SearchMethodEnum.And.getSymbol().equalsIgnoreCase(logic) ? "&&" : "||";
|
}
|
|
/**
|
* 条件数据修改
|
*
|
* @param flowMethod
|
* @param value
|
*/
|
private static Object filedValue(FlowMethod flowMethod, Object value, String jnpfKey, Object form, List<Object> includeValue) {
|
UserInfo userInfo = flowMethod.getUserInfo();
|
if ("currentUser".equals(value)) {
|
value = userInfo.getUserId();
|
}
|
try {
|
try {
|
List<List<String>> dataAll = JsonUtil.getJsonToBean(value, List.class);
|
List<String> id = new ArrayList<>();
|
for (List<String> data : dataAll) {
|
id.addAll(data);
|
}
|
value = String.join(",", id);
|
} catch (Exception e) {
|
try {
|
List<String> id = new ArrayList<>();
|
List<String> dataAll = JsonUtil.getJsonToList(value, String.class);
|
if (JnpfKeyConsts.CURRORGANIZE.equals(jnpfKey)) {
|
value = dataAll.stream().filter(t -> ("'" + t + "'").equals(form)).findFirst().orElse(null);
|
} else {
|
for (String data : dataAll) {
|
id.add(data);
|
}
|
value = String.join(",", id);
|
}
|
} catch (Exception e1) {
|
|
}
|
}
|
} catch (Exception e) {
|
}
|
if (value instanceof CharSequence) {
|
value = "'" + value + "'";
|
}
|
includeValue.add(value);
|
return value;
|
}
|
|
/**
|
* 条件数据修改
|
*
|
* @param flowMethod
|
* @param value
|
*/
|
private static Object filedData(FlowMethod flowMethod, Object value, String jnpfKey, Object form, List<Object> includeValue) {
|
Map<String, Object> map = flowMethod.getFormData();
|
value = map.get(value);
|
UserEntity userEntity = flowMethod.getUserEntity();
|
TaskEntity taskEntity = flowMethod.getTaskEntity();
|
try {
|
try {
|
List<List<String>> dataAll = JsonUtil.getJsonToBean(value, List.class);
|
List<String> id = new ArrayList<>();
|
for (List<String> data : dataAll) {
|
id.addAll(data);
|
}
|
value = String.join(",", id);
|
} catch (Exception e) {
|
try {
|
List<String> id = new ArrayList<>();
|
List<String> dataAll = JsonUtil.getJsonToList(value, String.class);
|
if (JnpfKeyConsts.CURRORGANIZE.equals(jnpfKey) || JnpfKeyConsts.COMSELECT.equals(jnpfKey)) {
|
value = dataAll.stream().filter(t -> ("'" + t + "'").equals(form)).findFirst().orElse(null);
|
} else {
|
for (String data : dataAll) {
|
id.add(data);
|
}
|
value = String.join(",", id);
|
}
|
} catch (Exception e1) {
|
}
|
}
|
if (JnpfKeyConsts.CREATETIME.equals(jnpfKey)) {
|
Date creatorTime = taskEntity.getCreatorTime();
|
value = null == creatorTime ? null : creatorTime.getTime();
|
} else if (JnpfKeyConsts.CREATEUSER.equals(jnpfKey)) {
|
value = taskEntity.getCreatorUserId();
|
} else if (JnpfKeyConsts.CURRORGANIZE.equals(jnpfKey)) {
|
value = userEntity.getOrganizeId();
|
} else if (JnpfKeyConsts.CURRPOSITION.equals(jnpfKey)) {
|
value = userEntity.getPositionId();
|
} else if (JnpfKeyConsts.MODIFYTIME.equals(jnpfKey)) {
|
Date lastModifyTime = taskEntity.getLastModifyTime();
|
value = null == lastModifyTime ? null : lastModifyTime.getTime();
|
} else if (JnpfKeyConsts.MODIFYUSER.equals(jnpfKey)) {
|
value = taskEntity.getLastModifyUserId();
|
}
|
} catch (Exception e) {
|
}
|
if (value instanceof CharSequence) {
|
value = "'" + value + "'";
|
}
|
includeValue.add(value);
|
return value;
|
}
|
|
/**
|
* 表单数据修改
|
*
|
* @param form
|
*/
|
private static Object formValue(FlowMethod flowMethod, String jnpfKey, Object form) {
|
Object result = form;
|
UserEntity userEntity = flowMethod.getUserEntity();
|
TaskEntity flowTaskEntity = flowMethod.getTaskEntity();
|
try {
|
try {
|
List<List<String>> dataAll = JsonUtil.getJsonToBean(form, List.class);
|
List<String> id = new ArrayList<>();
|
for (List<String> data : dataAll) {
|
id.addAll(data);
|
}
|
result = String.join(",", id);
|
} catch (Exception e) {
|
try {
|
List<String> id = new ArrayList<>();
|
List<String> dataAll = JsonUtil.getJsonToList(form, String.class);
|
for (String data : dataAll) {
|
id.add(data);
|
}
|
result = String.join(",", id);
|
} catch (Exception e1) {
|
}
|
}
|
if (JnpfKeyConsts.CREATETIME.equals(jnpfKey)) {
|
Date creatorTime = flowTaskEntity.getCreatorTime();
|
result = null == creatorTime ? null : creatorTime.getTime();
|
} else if (JnpfKeyConsts.CREATEUSER.equals(jnpfKey)) {
|
result = StringUtil.isNotEmpty(flowTaskEntity.getDelegateUserId()) ? flowTaskEntity.getDelegateUserId() : flowTaskEntity.getCreatorUserId();
|
} else if (JnpfKeyConsts.CURRORGANIZE.equals(jnpfKey)) {
|
result = userEntity.getOrganizeId();
|
} else if (JnpfKeyConsts.CURRPOSITION.equals(jnpfKey)) {
|
result = userEntity.getPositionId();
|
} else if (JnpfKeyConsts.MODIFYTIME.equals(jnpfKey)) {
|
Date lastModifyTime = flowTaskEntity.getLastModifyTime();
|
result = null == lastModifyTime ? null : lastModifyTime.getTime();
|
} else if (JnpfKeyConsts.MODIFYUSER.equals(jnpfKey)) {
|
result = flowTaskEntity.getLastModifyUserId();
|
}
|
} catch (Exception e) {
|
}
|
if (result instanceof CharSequence) {
|
result = "'" + result + "'";
|
}
|
return result;
|
}
|
|
/**
|
* 表达式
|
*/
|
private static Object formula(GroupsModel properCond, Map<String, Object> data) {
|
String result = null;
|
try {
|
StringBuilder builder = new StringBuilder();
|
builder.append("function getNum(val) {\n" +
|
" return isNaN(val) ? 0 : Number(val)\n" +
|
"};\n" +
|
"// 求和\n" +
|
"function SUM() {\n" +
|
" var value = 0\n" +
|
" for (var i = 0; i < arguments.length; i++) {\n" +
|
" value += getNum(arguments[i])\n" +
|
" }\n" +
|
" return value\n" +
|
"};\n" +
|
"// 求差\n" +
|
"function SUBTRACT(num1, num2) {\n" +
|
" return getNum(num1) - getNum(num2)\n" +
|
"};\n" +
|
"// 相乘\n" +
|
"function PRODUCT() {\n" +
|
" var value = 1\n" +
|
" for (var i = 0; i < arguments.length; i++) {\n" +
|
" value = value * getNum(arguments[i])\n" +
|
" }\n" +
|
" return value\n" +
|
"};\n" +
|
"// 相除\n" +
|
"function DIVIDE(num1, num2) {\n" +
|
" return getNum(num1) / (getNum(num2) === 0 ? 1 : getNum(num2))\n" +
|
"};\n" +
|
"// 获取参数的数量\n" +
|
"function COUNT() {\n" +
|
" var value = 0\n" +
|
" for (var i = 0; i < arguments.length; i++) {\n" +
|
" value ++\n" +
|
" }\n" +
|
" return value\n" +
|
"};\n");
|
String field = field(properCond.getField(), data, null);
|
ScriptEngineManager scriptEngineManager = new ScriptEngineManager();
|
ScriptEngine scriptEngine = scriptEngineManager.getEngineByName("js");
|
String eval = builder + " var result = " + field + ";";
|
scriptEngine.eval(eval);
|
double d = (double) scriptEngine.get("result");
|
NumberFormat nf = NumberFormat.getNumberInstance();
|
nf.setRoundingMode(RoundingMode.UP);
|
result = nf.format(d);
|
} catch (Exception e) {
|
System.out.println(e.getMessage());
|
}
|
return result;
|
}
|
|
/**
|
* 替换文本值
|
*
|
* @param content
|
* @param data
|
* @return
|
*/
|
public static String field(String content, Map<String, Object> data, String type) {
|
String pattern = "[{]([^}]+)[}]";
|
Pattern patternList = Pattern.compile(pattern);
|
Matcher matcher = patternList.matcher(content);
|
Map<String, List<String>> parameterMap = data(matcher, data);
|
Map<String, Object> result = new HashMap<>();
|
if (StringUtils.isNotEmpty(type)) {
|
Map<String, String> datas = new HashMap<>();
|
for (String key : parameterMap.keySet()) {
|
datas.put(key, data.get(key) != null ? String.valueOf(data.get(key)) : "");
|
}
|
result.putAll(datas);
|
} else {
|
Map<String, Object> dataAll = new HashMap<>();
|
for (String key : parameterMap.keySet()) {
|
StringJoiner joiner = new StringJoiner(",");
|
List<String> list = parameterMap.get(key);
|
for (String id : list) {
|
joiner.add("'" + id + "'");
|
}
|
String value = joiner.toString();
|
if (list.size() > 1) {
|
value = "SUM(" + joiner + ")";
|
}
|
dataAll.put(key, value);
|
}
|
result.putAll(dataAll);
|
}
|
StringSubstitutor strSubstitutor = new StringSubstitutor(result, "{", "}");
|
String field = strSubstitutor.replace(content);
|
return field;
|
}
|
|
/**
|
* 赋值
|
*/
|
private static Map<String, List<String>> data(Matcher matcher, Map<String, Object> dataAll) {
|
Map<String, List<String>> map = new HashMap<>();
|
Map<String, String> keyAll = new HashMap<>();
|
while (matcher.find()) {
|
String group = matcher.group().replaceAll("\\{", "").replaceAll("}", "");
|
keyAll.put(group, group);
|
}
|
for (String id : keyAll.keySet()) {
|
List<String> valueData = new ArrayList<>();
|
String valueAll[] = id.split("-");
|
String key = valueAll[0];
|
Object childDataAll = dataAll.get(key) != null ? dataAll.get(key) : "";
|
if (valueAll.length > 1) {
|
String data = valueAll[1];
|
if (childDataAll instanceof List) {
|
List<Map<String, Object>> childData = (List<Map<String, Object>>) childDataAll;
|
for (Map<String, Object> childDatum : childData) {
|
Object childDatas = childDatum.get(data);
|
valueData.add(childDatas + "");
|
}
|
}
|
} else {
|
valueData.add(childDataAll + "");
|
}
|
map.put(id, valueData);
|
}
|
return map;
|
}
|
|
}
|
