From 34981c30a78e8bbd7791131059a9210f9928b62c Mon Sep 17 00:00:00 2001
From: 刘光辉 <347230014@qq.com>
Date: 星期四, 17 九月 2026 09:24:09 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master' into master
---
jnpf-flowable/jnpf-flowable-biz/src/main/java/jnpf/flowable/util/FlowJsonUtil.java | 684 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 684 insertions(+), 0 deletions(-)
diff --git a/jnpf-flowable/jnpf-flowable-biz/src/main/java/jnpf/flowable/util/FlowJsonUtil.java b/jnpf-flowable/jnpf-flowable-biz/src/main/java/jnpf/flowable/util/FlowJsonUtil.java
new file mode 100644
index 0000000..dc4d169
--- /dev/null
+++ b/jnpf-flowable/jnpf-flowable-biz/src/main/java/jnpf/flowable/util/FlowJsonUtil.java
@@ -0,0 +1,684 @@
+package jnpf.flowable.util;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.lang.PatternPool;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.ReUtil;
+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 lombok.extern.slf4j.Slf4j;
+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
+ */
+
+@Slf4j
+public class FlowJsonUtil {
+
+ private FlowJsonUtil() {}
+
+ public static final String FALSE = "false";
+
+
+ /**
+ * 鑺傜偣鏉′欢鍒ゆ柇
+ **/
+ 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 (ProperCond cond : conditionList) {
+ StringBuilder expression = new StringBuilder();
+ expression.append("(");
+ String logic = cond.getLogic();
+ List<GroupsModel> groups = cond.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);
+ List<Object> formIncludeValue = new ArrayList<>();
+ Object form = Objects.equals(FieldEnum.FIELD.getCode(), fieldType) ? formValue(flowMethod, jnpfKey, map.get(field), formIncludeValue) : formula(groupsModel, map, formIncludeValue);
+ 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> filedIncludeValue = new ArrayList<>();
+ if (valueType.contains(fieldValueType)) {
+
+ TemplateJsonModel templateJsonModel = new TemplateJsonModel();
+ templateJsonModel.setField(String.valueOf(groupsModel.getFieldValue()));
+ templateJsonModel.setSourceType(Objects.equals(FieldEnum.CONDITION.getCode(), fieldValueType) ? FieldEnum.SYSTEM.getCode() : FieldEnum.FIELD.getCode());
+ templateJsonModel.setRelationField(String.valueOf(groupsModel.getFieldValue()));
+
+
+ TaskEntity taskEntity = flowMethod.getTaskEntity();
+
+ Map<String, Object> mapData = new HashMap<>();
+ if (null != taskEntity && StringUtils.isNotEmpty(taskEntity.getGlobalParameter())) {
+
+ mapData = JsonUtil.stringToMap(taskEntity.getGlobalParameter());
+
+ }
+ if (CollUtil.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 recordEntity = new RecordEntity();
+ recordEntity.setNodeCode(flowMethod.getNodeCode());
+ UserEntity createUser = flowMethod.getCreateUser();
+ UserEntity delegate = flowMethod.getDelegate();
+
+ FlowModel parameterModel = new FlowModel();
+ parameterModel.setFormData(mapData);
+ parameterModel.setRecordEntity(recordEntity);
+ parameterModel.setTaskEntity(taskEntity);
+ Map<String, String> resMap = FlowUtil.parameterMap(parameterModel, list, createUser, delegate);
+ if (includes) {
+ if (filedData instanceof List) {
+ try {
+ List<List<String>> dataAll = (List<List<String>>) filedData;
+ for (List<String> data : dataAll) {
+ for (int s = 0; s < data.size(); s++) {
+ if (s == data.size() - 1) {
+ filedIncludeValue.add("'" + data.get(s) + "'");
+ }
+ }
+ }
+ } catch (Exception e) {
+ List<String> filedList = (List<String>) filedData;
+ for (String id : filedList) {
+ filedIncludeValue.add("'" + resMap.get(id) + "'");
+ }
+ }
+ }
+ } else {
+ value = resMap.get(filedData);
+ if (value != null) {
+ value = "'" + value + "'";
+ }
+ }
+ } else {
+ if (includes) {
+ if (filedData instanceof List) {
+ List<String> filedList = new ArrayList<>();
+ try {
+ List<List<String>> dataAll = JsonUtil.getJsonToBean(filedData, List.class);
+ for (List<String> data : dataAll) {
+ for (int s = 0; s < data.size(); s++) {
+ if (s == data.size() - 1) {
+ filedList.add(data.get(s));
+ }
+ }
+ }
+ } catch (Exception e) {
+ List<String> dataAll = JsonUtil.getJsonToBean(filedData, List.class);
+ for (String data : dataAll) {
+ filedList.add(data);
+ }
+ }
+ for (String id : filedList) {
+ List<Object> includeValue = new ArrayList<>();
+ if (Objects.equals(FieldEnum.CUSTOM.getCode(), fieldValueType)) {
+ filedValue(flowMethod, id, valueJnpfKey, form, includeValue);
+ } else {
+ filedData(flowMethod, id, valueJnpfKey, form, includeValue);
+ }
+ filedIncludeValue.addAll(includeValue);
+ }
+ } else {
+ List<String> filedList = ImmutableList.of(String.valueOf(filedData));
+ for (String id : filedList) {
+ List<Object> includeValue = new ArrayList<>();
+ if (Objects.equals(FieldEnum.CUSTOM.getCode(), fieldValueType)) {
+ filedValue(flowMethod, id, valueJnpfKey, form, includeValue);
+ } else {
+ filedData(flowMethod, id, valueJnpfKey, form, includeValue);
+ }
+ filedIncludeValue.addAll(includeValue);
+ }
+ }
+ } else {
+ value = Objects.equals(FieldEnum.CUSTOM.getCode(), fieldValueType) ? filedValue(flowMethod, filedData, valueJnpfKey, form, filedIncludeValue) : filedData(flowMethod, filedData, valueJnpfKey, form, filedIncludeValue);
+ }
+ }
+ Object fieldValue = value;
+ String pression = formValue + symbol + fieldValue;
+ // 姣旇緝鐨勫鐞�
+ if ("<=".equals(symbol) || "<".equals(symbol) || ">".equals(symbol) || ">=".equals(symbol)) {
+ try {
+ String formValueStr = formValue == null ? "" : formValue.toString();
+ if (formValueStr.startsWith("'") && formValueStr.endsWith("'")) {
+ formValueStr = formValueStr.substring(1, formValueStr.length() - 1);
+ }
+ boolean time = ReUtil.isMatch(PatternPool.TIME, formValueStr);
+ if (time) {
+ formValueStr = DateUtil.parse(formValueStr).getTime() + "";
+ }
+ BigDecimal a = new BigDecimal(formValueStr);
+ String fieldValueStr = fieldValue == null ? "" : fieldValue.toString();
+ if (fieldValueStr.startsWith("'") && fieldValueStr.endsWith("'")) {
+ fieldValueStr = fieldValueStr.substring(1, fieldValueStr.length() - 1);
+ }
+ boolean valTime = ReUtil.isMatch(PatternPool.TIME, fieldValueStr);
+ if (valTime) {
+ fieldValueStr = DateUtil.parse(fieldValueStr).getTime() + "";
+ }
+ 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) {
+ log.info(e.getMessage());
+ pression = FALSE;
+ }
+ }
+ if (Objects.equals(symbol, "between")) {
+ try {
+ String formValueStr = formValue == null ? "" : formValue.toString();
+ if (formValueStr.startsWith("'") && formValueStr.endsWith("'")) {
+ formValueStr = formValueStr.substring(1, formValueStr.length() - 1);
+ }
+ boolean time = ReUtil.isMatch(PatternPool.TIME, formValueStr);
+ if (time) {
+ formValueStr = DateUtil.parse(formValueStr).getTime() + "";
+ }
+ String fieldValueStr = fieldValue == null ? "" : fieldValue.toString();
+ if (fieldValueStr.startsWith("'") && fieldValueStr.endsWith("'")) {
+ fieldValueStr = fieldValueStr.substring(1, fieldValueStr.length() - 1);
+ }
+ String[] split = fieldValueStr.split(",");
+ StringBuilder json = new StringBuilder();
+ String searchModel = " && ";
+ StringJoiner joiner = new StringJoiner(searchModel);
+ json.append("(");
+ if (split.length > 1) {
+ BigDecimal a = new BigDecimal(formValueStr);
+ List<String> valueList = new ArrayList<>();
+ valueList.addAll(Arrays.asList(fieldValueStr.split(",")));
+ for (int j = 0; j < valueList.size(); j++) {
+ String val = valueList.get(j);
+ if ("null".equals(val)) {
+ val = "0";
+ }
+ boolean valTime = ReUtil.isMatch(PatternPool.TIME, val);
+ if (valTime) {
+ val = DateUtil.parse(val).getTime() + "";
+ }
+ BigDecimal b = new BigDecimal(val);
+ if (j == 0) {
+ joiner.add((a.compareTo(b) >= 0) + "");
+ } else {
+ joiner.add((a.compareTo(b) <= 0) + "");
+ }
+ }
+ json.append(joiner);
+ json.append(")");
+ pression = json + "";
+ } else {
+ pression = formValue + "==" + fieldValue;
+ }
+ } catch (Exception e) {
+ FlowJsonUtil.log.info(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 ? " == " : " != ";
+ StringBuilder json = new StringBuilder();
+ json.append("(");
+ for (int formIndex = 0; formIndex < formIncludeValue.size(); formIndex++) {
+ Object formData = formIncludeValue.get(formIndex);
+ if (!(formData instanceof CharSequence)) {
+ formData = "'" + formData + "'";
+ }
+ for (int fieldIndex = 0; fieldIndex < filedIncludeValue.size(); fieldIndex++) {
+ Object fieldData = filedIncludeValue.get(fieldIndex);
+ if (!(fieldData instanceof CharSequence)) {
+ fieldData = "'" + fieldData + "'";
+ }
+ json.append(formData).append(symbol).append(fieldData);
+ if (!(formIndex == formIncludeValue.size() - 1 && fieldIndex == filedIncludeValue.size() - 1)) {
+ json.append(searchModel);
+ }
+ }
+ }
+ json.append(")");
+ pression = formIncludeValue.isEmpty() || filedIncludeValue.isEmpty() ? FALSE : json.toString();
+ } catch (Exception e) {
+ log.info(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(" ").append(search(logic)).append(" ");
+ }
+ }
+ 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).append(" ").append(search).append(" ");
+ }
+ try {
+ flag = (Boolean) scriptEngine.eval(condition.toString());
+ } catch (Exception e) {
+ log.info(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> filedIncludeValue) {
+ UserInfo userInfo = flowMethod.getUserInfo();
+ if ("currentUser".equals(value)) {
+ value = userInfo.getUserId();
+ }
+ try {
+ List<List<String>> dataAll = JsonUtil.getJsonToBean(value, List.class);
+ List<String> id = new ArrayList<>();
+ for (List<String> data : dataAll) {
+ for (int i = 0; i < data.size(); i++) {
+ if (i == data.size() - 1) {
+ id.add(data.get(i));
+ filedIncludeValue.add("'" + data.get(i) + "'");
+ }
+ }
+ }
+ 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);
+ filedIncludeValue.add("'" + data + "'");
+ }
+ value = String.join(",", id);
+ }
+ } catch (Exception e1) {
+ log.info(e1.getMessage());
+ }
+ }
+ if (value instanceof CharSequence) {
+ value = "'" + value + "'";
+ }
+ if (value instanceof BigDecimal) {
+ BigDecimal bigDecimal = (BigDecimal) value;
+ value = new BigDecimal(bigDecimal.stripTrailingZeros().toPlainString());
+ }
+ if (filedIncludeValue.isEmpty()) {
+ filedIncludeValue.add(value);
+ }
+ return value;
+ }
+
+ /**
+ * 鏉′欢鏁版嵁淇敼
+ *
+ * @param flowMethod
+ * @param value
+ */
+ private static Object filedData(FlowMethod flowMethod, Object value, String jnpfKey, Object form, List<Object> filedIncludeValue) {
+ Map<String, Object> map = flowMethod.getFormData();
+ value = map.get(value);
+ UserEntity userEntity = flowMethod.getUserEntity();
+ TaskEntity taskEntity = flowMethod.getTaskEntity();
+ try {
+ List<List<String>> dataAll = JsonUtil.getJsonToBean(value, List.class);
+ List<String> id = new ArrayList<>();
+ for (List<String> data : dataAll) {
+ for (int i = 0; i < data.size(); i++) {
+ if (i == data.size() - 1) {
+ id.add(data.get(i));
+ filedIncludeValue.add("'" + data.get(i) + "'");
+ }
+ }
+ }
+ 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);
+ filedIncludeValue.add("'" + data + "'");
+ }
+ value = String.join(",", id);
+ }
+ } catch (Exception ignored) {
+ log.info(ignored.getMessage());
+ }
+ }
+ 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();
+ }
+ if (value instanceof CharSequence) {
+ value = "'" + value + "'";
+ }
+ if (value instanceof BigDecimal) {
+ BigDecimal bigDecimal = (BigDecimal) value;
+ value = new BigDecimal(bigDecimal.stripTrailingZeros().toPlainString());
+ }
+ if (filedIncludeValue.isEmpty()) {
+ filedIncludeValue.add(value);
+ }
+ return value;
+ }
+
+ /**
+ * 琛ㄥ崟鏁版嵁淇敼
+ *
+ * @param form
+ */
+ private static Object formValue(FlowMethod flowMethod, String jnpfKey, Object form, List<Object> fieldIncludeValue) {
+ Object result = form;
+ UserEntity userEntity = flowMethod.getUserEntity();
+ TaskEntity taskEntity = flowMethod.getTaskEntity();
+ try {
+ List<List<String>> dataAll = JsonUtil.getJsonToBean(form, List.class);
+ List<String> id = new ArrayList<>();
+ for (List<String> data : dataAll) {
+ for (int i = 0; i < data.size(); i++) {
+ if (i == data.size() - 1) {
+ id.add(data.get(i));
+ fieldIncludeValue.add("'" + data.get(i) + "'");
+ }
+ }
+ }
+ 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);
+ fieldIncludeValue.add("'" + data + "'");
+ }
+ result = String.join(",", id);
+ } catch (Exception e1) {
+ log.info(e1.getMessage());
+ }
+ }
+ if (JnpfKeyConsts.CREATETIME.equals(jnpfKey)) {
+ Date creatorTime = taskEntity.getCreatorTime();
+ result = null == creatorTime ? null : creatorTime.getTime();
+ } else if (JnpfKeyConsts.CREATEUSER.equals(jnpfKey)) {
+ result = StringUtil.isNotEmpty(taskEntity.getDelegateUserId()) ? taskEntity.getDelegateUserId() : taskEntity.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 = taskEntity.getLastModifyTime();
+ result = null == lastModifyTime ? null : lastModifyTime.getTime();
+ } else if (JnpfKeyConsts.MODIFYUSER.equals(jnpfKey)) {
+ result = taskEntity.getLastModifyUserId();
+ }
+ if (result instanceof CharSequence) {
+ result = "'" + result + "'";
+ }
+ if (result instanceof BigDecimal) {
+ BigDecimal bigDecimal = (BigDecimal) result;
+ result = new BigDecimal(bigDecimal.stripTrailingZeros().toPlainString());
+ }
+ if (fieldIncludeValue.isEmpty()) {
+ fieldIncludeValue.add(result);
+ }
+ return result;
+ }
+
+ /**
+ * 琛ㄨ揪寮�
+ */
+ private static Object formula(GroupsModel properCond, Map<String, Object> data, List<Object> fieldIncludeValue) {
+ Object 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, false);
+ 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) {
+ log.info(e.getMessage());
+ }
+ if (result != null) {
+ result = "'" + result + "'";
+ }
+ fieldIncludeValue.add(result);
+ return result;
+ }
+
+ /**
+ * 鏇挎崲鏂囨湰鍊�
+ *
+ * @param content
+ * @param data
+ * @return
+ */
+ public static String field(String content, Map<String, Object> data, boolean isData) {
+ 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 (isData) {
+ 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 (Map.Entry<String, List<String>> stringListEntry : parameterMap.entrySet()) {
+ String key = stringListEntry.getKey();
+ 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, "{", "}");
+ return strSubstitutor.replace(content);
+ }
+
+ /**
+ * 璧嬪��
+ */
+ 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().replace("{", "").replace("}", "");
+ 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;
+ }
+
+}
--
Gitblit v1.8.0