Skip to content

o2oa
o2oa

fuyue82 / o2oa
与 Fork 源项目一致

Fork自 浙江兰德纵横网络技术股份有限公司 / o2oa

通知 1
Star 0
Fork 0
o2oa
o2oa

体验新版 GitCode，发现更多精彩内容 >>

提交 356964f1 编写于 作者: O o2null
浏览文件
操作

Merge branch 'feature/jsonScripting' into 'wrdp' 

新的JsonScripting

See merge request o2oa/o2oa!5658
上级 d0fa0f84 f53f604f
隐藏空白更改
内联 并排
Showing with 301 addition and 221 deletion
o2server/x_base_core_project/src/main/java/com/x/base/core/project/scripting/JsonScriptingExecutor.java 0 → 100644
浏览文件 @ 356964f1
package com.x.base.core.project.scripting;
import java.lang.reflect.Type;
import java.util.ArrayList;
import java.util.List;
import java.util.Map.Entry;
import java.util.Objects;
import java.util.Optional;
import javax.script.CompiledScript;
import javax.script.ScriptContext;
import javax.script.ScriptException;
import org.apache.commons.lang3.StringUtils;
import com.google.gson.JsonArray;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
import com.google.gson.reflect.TypeToken;
import com.x.base.core.entity.JpaObject;
import com.x.base.core.project.gson.XGsonBuilder;
import com.x.base.core.project.logger.Logger;
import com.x.base.core.project.logger.LoggerFactory;
public class JsonScriptingExecutor {
private JsonScriptingExecutor() {
// nothing
}
private static Logger logger = LoggerFactory.getLogger(JsonScriptingExecutor.class);
private static Type stringsType = new TypeToken<ArrayList<String>>() {
}.getType();
public static Optional<JsonElement> jsonElement(CompiledScript cs, ScriptContext scriptContext) {
Objects.requireNonNull(cs);
Objects.requireNonNull(scriptContext);
try {
Object o = cs.eval(scriptContext);
String json = Objects.toString(o, "");
JsonElement element = XGsonBuilder.instance().fromJson(json, JsonElement.class);
if (null != element && (!element.isJsonNull())) {
return Optional.of(element);
}
} catch (ScriptException e) {
logger.error(e);
}
return Optional.empty();
}
public static void jsonElement(CompiledScript cs, ScriptContext scriptContext, Consumer<JsonElement> consumer) {
Optional<JsonElement> optional = jsonElement(cs, scriptContext);
if (optional.isPresent()) {
consumer.accept(optional.get());
}
}
public static Optional<JsonArray> jsonArray(CompiledScript cs, ScriptContext scriptContext) {
Optional<JsonElement> optional = jsonElement(cs, scriptContext);
if (optional.isPresent() && optional.get().isJsonArray()) {
JsonArray jsonArray = optional.get().getAsJsonArray();
if ((null != jsonArray) && (jsonArray.size() > 0)) {
return Optional.of(jsonArray);
}
}
return Optional.of(new JsonArray());
}
public static void jsonArray(CompiledScript cs, ScriptContext scriptContext, Consumer<JsonArray> consumer) {
Optional<JsonArray> optional = jsonArray(cs, scriptContext);
consumer.accept(optional.get());
}
public static Optional<JsonObject> jsonObject(CompiledScript cs, ScriptContext scriptContext) {
Optional<JsonElement> optional = jsonElement(cs, scriptContext);
if (optional.isPresent() && optional.get().isJsonObject()) {
JsonObject jsonObject = optional.get().getAsJsonObject();
if (null != jsonObject) {
return Optional.of(jsonObject);
}
}
return Optional.empty();
}
public static void jsonObject(CompiledScript cs, ScriptContext scriptContext, Consumer<JsonObject> consumer) {
Optional<JsonObject> optional = jsonObject(cs, scriptContext);
if (optional.isPresent()) {
consumer.accept(optional.get().getAsJsonObject());
}
}
public static Optional<String> evalString(CompiledScript cs, ScriptContext scriptContext) {
Optional<JsonElement> optional = jsonElement(cs, scriptContext);
if (optional.isPresent() && optional.get().isJsonPrimitive()) {
String value = optional.get().getAsJsonPrimitive().getAsString();
if (StringUtils.isNotEmpty(value)) {
return Optional.of(value);
}
}
return Optional.empty();
}
public static void evalString(CompiledScript cs, ScriptContext scriptContext, Consumer<String> consumer) {
Optional<String> optional = evalString(cs, scriptContext);
if (optional.isPresent()) {
consumer.accept(optional.get());
}
}
public static Optional<Integer> evalInteger(CompiledScript cs, ScriptContext scriptContext) {
Optional<JsonElement> optional = jsonElement(cs, scriptContext);
if (optional.isPresent() && optional.get().isJsonPrimitive()) {
Integer value = optional.get().getAsJsonPrimitive().getAsInt();
if (null != value) {
return Optional.of(value);
}
}
return Optional.empty();
}
public static void evalInteger(CompiledScript cs, ScriptContext scriptContext, Consumer<Integer> consumer) {
Optional<Integer> optional = evalInteger(cs, scriptContext);
if (optional.isPresent()) {
consumer.accept(optional.get());
}
}
public static Optional<Double> evalDouble(CompiledScript cs, ScriptContext scriptContext) {
Optional<JsonElement> optional = jsonElement(cs, scriptContext);
if (optional.isPresent() && optional.get().isJsonPrimitive()) {
Double value = optional.get().getAsJsonPrimitive().getAsDouble();
if (null != value) {
return Optional.of(value);
}
}
return Optional.empty();
}
public static void evalDouble(CompiledScript cs, ScriptContext scriptContext, Consumer<Double> consumer) {
Optional<Double> optional = evalDouble(cs, scriptContext);
if (optional.isPresent()) {
consumer.accept(optional.get());
}
}
public static Optional<Float> evalFloat(CompiledScript cs, ScriptContext scriptContext) {
Optional<JsonElement> optional = jsonElement(cs, scriptContext);
if (optional.isPresent() && optional.get().isJsonPrimitive()) {
Float value = optional.get().getAsJsonPrimitive().getAsFloat();
if (null != value) {
return Optional.of(value);
}
}
return Optional.empty();
}
public static void evalFloat(CompiledScript cs, ScriptContext scriptContext, Consumer<Float> consumer) {
Optional<Float> optional = evalFloat(cs, scriptContext);
if (optional.isPresent()) {
consumer.accept(optional.get());
}
}
public static Optional<Number> evalNumber(CompiledScript cs, ScriptContext scriptContext) {
Optional<JsonElement> optional = jsonElement(cs, scriptContext);
if (optional.isPresent() && optional.get().isJsonPrimitive()) {
Number value = optional.get().getAsJsonPrimitive().getAsNumber();
if (null != value) {
return Optional.of(value);
}
}
return Optional.empty();
}
public static void evalNumber(CompiledScript cs, ScriptContext scriptContext, Consumer<Number> consumer) {
Optional<Number> optional = evalNumber(cs, scriptContext);
if (optional.isPresent()) {
consumer.accept(optional.get());
}
}
public static Optional<Boolean> evalBoolean(CompiledScript cs, ScriptContext scriptContext) {
Optional<JsonElement> optional = jsonElement(cs, scriptContext);
if (optional.isPresent() && optional.get().isJsonPrimitive()) {
Boolean value = optional.get().getAsJsonPrimitive().getAsBoolean();
if (null != value) {
return Optional.of(value);
}
}
return Optional.empty();
}
public static void evalBoolean(CompiledScript cs, ScriptContext scriptContext, Consumer<Boolean> consumer) {
Optional<Boolean> optional = evalBoolean(cs, scriptContext);
if (optional.isPresent()) {
consumer.accept(optional.get());
}
}
public static Optional<List<String>> evalStrings(CompiledScript cs, ScriptContext scriptContext) {
Optional<JsonElement> optional = jsonElement(cs, scriptContext);
if (optional.isPresent() && optional.get().isJsonArray()) {
List<String> list = XGsonBuilder.instance().fromJson(optional.get(), stringsType);
if (!list.isEmpty()) {
return Optional.of(list);
}
}
return Optional.of(new ArrayList<>());
}
public static void evalStrings(CompiledScript cs, ScriptContext scriptContext, Consumer<List<String>> consumer) {
Optional<List<String>> optional = evalStrings(cs, scriptContext);
consumer.accept(optional.get());
}
public static Optional<List<String>> evalDistinguishedNames(CompiledScript cs, ScriptContext scriptContext) {
List<String> list = new ArrayList<>();
Optional<JsonElement> optional = jsonElement(cs, scriptContext);
if (optional.isPresent()) {
if (optional.get().isJsonObject()) {
dfsDistinguishedNames(optional.get().getAsJsonObject(), list);
} else if (optional.get().isJsonArray()) {
for (JsonElement element : optional.get().getAsJsonArray()) {
if (element.isJsonPrimitive() && element.getAsJsonPrimitive().isString()) {
list.add(element.getAsJsonPrimitive().getAsString());
} else if (element.isJsonObject()) {
dfsDistinguishedNames(element.getAsJsonObject(), list);
}
}
}
if (!list.isEmpty()) {
return Optional.of(list);
}
}
return Optional.of(new ArrayList<>());
}
public static void evalDistinguishedNames(CompiledScript cs, ScriptContext scriptContext,
Consumer<List<String>> consumer) {
Optional<List<String>> optional = evalDistinguishedNames(cs, scriptContext);
consumer.accept(optional.get());
}
private static void dfsDistinguishedNames(JsonObject jsonObject, List<String> list) {
if ((null != jsonObject) && (!jsonObject.isJsonNull())) {
for (Entry<String, JsonElement> entry : jsonObject.entrySet()) {
if (StringUtils.equals(entry.getKey(), JpaObject.DISTINGUISHEDNAME)
&& entry.getValue().isJsonPrimitive() && entry.getValue().getAsJsonPrimitive().isString()) {
list.add((entry.getValue().getAsJsonPrimitive().getAsString()));
} else if (entry.getValue().isJsonObject()) {
dfsDistinguishedNames(entry.getValue().getAsJsonObject(), list);
}
}
}
}
public static <T> Optional<T> eval(CompiledScript cs, ScriptContext scriptContext, Class<T> clz) {
Optional<JsonElement> optional = jsonElement(cs, scriptContext);
if (optional.isPresent()) {
return Optional.of(XGsonBuilder.instance().fromJson(optional.get(), clz));
}
return Optional.empty();
}
public static <T> Optional<T> eval(CompiledScript cs, ScriptContext scriptContext, Supplier<T> supplier) {
Optional<JsonElement> optional = jsonElement(cs, scriptContext);
if (optional.isPresent()) {
T t = supplier.get(optional.get());
if (null != t) {
return Optional.of(t);
}
}
return Optional.empty();
}
public static <T> void eval(CompiledScript cs, ScriptContext scriptContext, Class<T> clz, Consumer<T> consumer) {
Optional<T> optional = eval(cs, scriptContext, clz);
if (optional.isPresent()) {
consumer.accept(optional.get());
}
}
public static <T> void eval(CompiledScript cs, ScriptContext scriptContext, Supplier<T> supplier,
Consumer<T> consumer) {
Optional<JsonElement> optional = jsonElement(cs, scriptContext);
if (optional.isPresent()) {
T t = supplier.get(optional.get());
if (null != t) {
consumer.accept(t);
}
}
}
}
o2server/x_base_core_project/src/main/java/com/x/base/core/project/scripting/ScriptingExecutor.java 已删除 100644 → 0
浏览文件 @ d0fa0f84
package com.x.base.core.project.scripting;
import java.lang.reflect.Type;
import java.util.ArrayList;
import java.util.List;
import java.util.Map.Entry;
import java.util.Objects;
import java.util.Optional;
import javax.script.CompiledScript;
import javax.script.ScriptContext;
import javax.script.ScriptException;
import org.apache.commons.lang3.StringUtils;
import com.google.gson.JsonArray;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
import com.google.gson.JsonPrimitive;
import com.google.gson.reflect.TypeToken;
import com.x.base.core.entity.JpaObject;
import com.x.base.core.project.gson.XGsonBuilder;
import com.x.base.core.project.logger.Logger;
import com.x.base.core.project.logger.LoggerFactory;
public class ScriptingExecutor {
private ScriptingExecutor() {
// nothing
}
private static Logger logger = LoggerFactory.getLogger(ScriptingExecutor.class);
private static Type stringsType = new TypeToken<ArrayList<String>>() {
}.getType();
public static Optional<JsonElement> evalResultToJsonElement(CompiledScript cs, ScriptContext scriptContext) {
try {
Object o = cs.eval(scriptContext);
String json = Objects.toString(o, "");
JsonElement jsonElement = XGsonBuilder.instance().fromJson(json, JsonElement.class);
if (null != jsonElement && (!jsonElement.isJsonNull())) {
return Optional.of(jsonElement);
}
} catch (ScriptException e) {
logger.error(e);
}
return Optional.empty();
}
public static Optional<JsonArray> evalResultToJsonArray(CompiledScript cs, ScriptContext scriptContext) {
try {
Object o = cs.eval(scriptContext);
String json = Objects.toString(o, "");
if (StringUtils.isNotEmpty(json)) {
JsonArray jsonArray = XGsonBuilder.instance().fromJson(json, JsonArray.class);
if ((null != jsonArray) && (jsonArray.size() > 0)) {
return Optional.of(jsonArray);
}
}
} catch (ScriptException e) {
logger.error(e);
}
return Optional.empty();
}
public static Optional<JsonObject> evalResultToJsonObject(CompiledScript cs, ScriptContext scriptContext) {
try {
Object o = cs.eval(scriptContext);
String json = Objects.toString(o, "");
if (StringUtils.isNotEmpty(json)) {
JsonObject jsonObject = XGsonBuilder.instance().fromJson(json, JsonObject.class);
if ((null != jsonObject) && (!jsonObject.isJsonNull())) {
return Optional.of(jsonObject);
}
}
} catch (ScriptException e) {
logger.error(e);
}
return Optional.empty();
}
public static Optional<String> evalResultToString(CompiledScript cs, ScriptContext scriptContext) {
try {
Object o = cs.eval(scriptContext);
String str = Objects.toString(o, "");
if (StringUtils.isNotEmpty(str)) {
return Optional.of(str);
}
} catch (ScriptException e) {
logger.error(e);
}
return Optional.empty();
}
public static Optional<Number> evalResultToNumber(CompiledScript cs, ScriptContext scriptContext) {
try {
Object o = cs.eval(scriptContext);
String json = Objects.toString(o, "");
if (StringUtils.isNotEmpty(json)) {
JsonPrimitive jsonPrimitive = XGsonBuilder.instance().fromJson(json, JsonPrimitive.class);
if ((null != jsonPrimitive) && (jsonPrimitive.isNumber())) {
return Optional.of(jsonPrimitive.getAsNumber());
}
}
} catch (ScriptException e) {
logger.error(e);
}
return Optional.empty();
}
public static Optional<Boolean> evalResultToBoolean(CompiledScript cs, ScriptContext scriptContext) {
try {
Object o = cs.eval(scriptContext);
String json = Objects.toString(o, "");
if (StringUtils.isNotEmpty(json)) {
JsonPrimitive jsonPrimitive = XGsonBuilder.instance().fromJson(json, JsonPrimitive.class);
if ((null != jsonPrimitive) && (jsonPrimitive.isBoolean())) {
return Optional.of(jsonPrimitive.getAsBoolean());
}
}
} catch (ScriptException e) {
logger.error(e);
}
return Optional.empty();
}
public static Optional<List<String>> evalResultToStrings(CompiledScript cs, ScriptContext scriptContext) {
try {
Object o = cs.eval(scriptContext);
String json = Objects.toString(o, "");
if (StringUtils.isNotEmpty(json)) {
List<String> list = XGsonBuilder.instance().fromJson(json, stringsType);
if (null != list && (!list.isEmpty())) {
return Optional.of(list);
}
}
} catch (ScriptException e) {
logger.error(e);
}
return Optional.empty();
}
public static Optional<List<String>> evalResultToDistinguishedNames(CompiledScript cs,
ScriptContext scriptContext) {
List<String> list = new ArrayList<>();
Optional<JsonElement> optional = evalResultToJsonElement(cs, scriptContext);
if (optional.isPresent()) {
if (optional.get().isJsonObject()) {
dfsDistinguishedNames(optional.get().getAsJsonObject(), list);
} else if (optional.get().isJsonArray()) {
for (JsonElement element : optional.get().getAsJsonArray()) {
if (element.isJsonPrimitive() && element.getAsJsonPrimitive().isString()) {
list.add(element.getAsJsonPrimitive().getAsString());
} else if (element.isJsonObject()) {
dfsDistinguishedNames(element.getAsJsonObject(), list);
}
}
}
}
return Optional.empty();
}
private static void dfsDistinguishedNames(JsonObject jsonObject, List<String> list) {
if ((null != jsonObject) && (!jsonObject.isJsonNull())) {
for (Entry<String, JsonElement> entry : jsonObject.entrySet()) {
if (StringUtils.equals(entry.getKey(), JpaObject.DISTINGUISHEDNAME)
&& entry.getValue().isJsonPrimitive() && entry.getValue().getAsJsonPrimitive().isString()) {
list.add((entry.getValue().getAsJsonPrimitive().getAsString()));
} else if (entry.getValue().isJsonObject()) {
dfsDistinguishedNames(entry.getValue().getAsJsonObject(), list);
}
}
}
}
public static <T> Optional<T> evalResultTo(CompiledScript cs, ScriptContext scriptContext, Class<T> clz) {
try {
Object o = cs.eval(scriptContext);
String json = Objects.toString(o, "");
if (StringUtils.isNotEmpty(json)) {
T t = XGsonBuilder.instance().fromJson(json, clz);
if (null != t) {
return Optional.of(t);
}
}
} catch (ScriptException e) {
logger.error(e);
}
return Optional.empty();
}
public static <T> Optional<T> evalResultTo(CompiledScript cs, ScriptContext scriptContext, Supplier<T> supplier) {
Optional<JsonElement> optional = evalResultToJsonElement(cs, scriptContext);
if (optional.isPresent() && (!optional.get().isJsonNull())) {
T t = supplier.get(optional.get());
if (null != t) {
return Optional.of(t);
}
}
return Optional.empty();
}
public static void evalResult(CompiledScript cs, ScriptContext scriptContext, Consumer<JsonElement> consumer) {
Optional<JsonElement> optional = evalResultToJsonElement(cs, scriptContext);
if (optional.isPresent() && (!optional.get().isJsonNull())) {
consumer.accept(optional.get());
}
}
}
o2server/x_base_core_project/src/main/java/com/x/base/core/project/scripting/ScriptingFactory.java
浏览文件 @ 356964f1
package com.x.base.core.project.scripting;
import java.lang.reflect.Type;
import java.util.ArrayList;
import java.util.Objects;
import javax.script.Compilable;
......@@ -10,7 +8,6 @@ import javax.script.ScriptEngine;
import javax.script.ScriptEngineManager;
import javax.script.ScriptException;
import com.google.gson.reflect.TypeToken;
import com.x.base.core.project.config.Config;
import com.x.base.core.project.logger.Logger;
import com.x.base.core.project.logger.LoggerFactory;
......@@ -58,9 +55,6 @@ public class ScriptingFactory {
public static final String BINDING_NAME_SERIAL = "serial";
public static final String BINDING_NAME_PROCESS = "process";
private static Type stringsType = new TypeToken<ArrayList<String>>() {
}.getType();
public static ScriptEngine newScriptEngine() {
return (new ScriptEngineManager()).getEngineByName(Config.SCRIPTING_ENGINE_NAME);
}
......@@ -87,12 +81,14 @@ public class ScriptingFactory {
public static String functionalization(String text) {
StringBuilder sb = new StringBuilder();
sb.append("(function(){").append(System.lineSeparator());
sb.append("JSON.stringify((function(){").append(System.lineSeparator());
sb.append(Objects.toString(text, "")).append(System.lineSeparator());
sb.append("})();");
sb.append("})());");
return sb.toString();
}
public static CompiledScript functionalizationCompile(String text) throws ScriptException {
return ((Compilable) scriptEngine).compile(functionalization(text));
}
}
\ No newline at end of file
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或