|
|
@@ -1,11 +1,14 @@
|
|
|
package com.scbfkj.uni.service;
|
|
|
|
|
|
+import com.fasterxml.jackson.databind.JsonNode;
|
|
|
+import com.jayway.jsonpath.JsonPath;
|
|
|
import com.scbfkj.uni.library.DataAliasGetUtil;
|
|
|
+import com.scbfkj.uni.library.DataFormatUtil;
|
|
|
import com.scbfkj.uni.library.ScriptEngineUtil;
|
|
|
import com.scbfkj.uni.library.UniReturnUtil;
|
|
|
import com.scbfkj.uni.process.DataBase;
|
|
|
+import com.scbfkj.uni.system.Config;
|
|
|
import jakarta.el.MethodNotFoundException;
|
|
|
-import org.springframework.stereotype.Service;
|
|
|
|
|
|
import java.io.File;
|
|
|
import java.lang.reflect.Method;
|
|
|
@@ -17,33 +20,64 @@ import java.util.stream.Collectors;
|
|
|
|
|
|
public class DataProcessService {
|
|
|
|
|
|
- private String id;
|
|
|
|
|
|
- public DataProcessService(String id) {
|
|
|
- this.id = id;
|
|
|
- }
|
|
|
+ public static Map<String, Object> process(Map<String, Object> inData) throws Exception {
|
|
|
|
|
|
- public Map<String, Object> process(Map<String, Object> inData) throws Exception {
|
|
|
Optional<String> serviceIdOpt = DataAliasGetUtil.getValue("serviceid", inData);
|
|
|
- if (serviceIdOpt.isEmpty()) {
|
|
|
+ if (Objects.isNull(inData) || inData.isEmpty() || serviceIdOpt.isEmpty())
|
|
|
return UniReturnUtil.fail("服务编号不能为空");
|
|
|
- }
|
|
|
+
|
|
|
+ List<Map<String, Object>> resource = new ArrayList<>();
|
|
|
+ resource.add(inData);
|
|
|
String serviceId = serviceIdOpt.get();
|
|
|
-// todo
|
|
|
+
|
|
|
+ List<Map<String, Object>> algorithmLibraries = DataBase.query(Config.centerConnectionStr, "select * from algorithmlibrary where serviceid=?", Collections.singletonList(new Object[]{serviceId}));
|
|
|
+ for (Map<String, Object> algorithmLibrary : algorithmLibraries) {
|
|
|
+ resource.add(processByAlgorithm(algorithmLibrary, resource, null, null));
|
|
|
+ }
|
|
|
return UniReturnUtil.success(null);
|
|
|
}
|
|
|
|
|
|
- public Object processByAlgorithm(String type, String targetSource, String className, String event, String expression,List<String> filterColumns, Map<String, Object> filterLines, Object... args) throws Exception {
|
|
|
+ public static Map<String, Object> processByAlgorithm(Map<String, Object> algorithmLibrary, List<Map<String, Object>> args, List<String> filterColumns, Map<String, Object> filterLines) throws Exception {
|
|
|
+
|
|
|
+ Object type = algorithmLibrary.get("algorithmtype");
|
|
|
+ Object expression = algorithmLibrary.get("computingexpression");
|
|
|
+ Object parameterSet = algorithmLibrary.get("parameterset");
|
|
|
+ Object preConditions = algorithmLibrary.get("preconditions");
|
|
|
+ Object executionNumber = algorithmLibrary.get("executionnumber");
|
|
|
+ Object dataSourceId = algorithmLibrary.get("datasourceid");
|
|
|
+ List<Map<String, Object>> datasourceList = DataBase.query(Config.centerConnectionStr, "select * from datasource where datasourceid=?", Collections.singletonList(new Object[]{dataSourceId}));
|
|
|
+ Map<String, Object> datasource = datasourceList.get(0);
|
|
|
+
|
|
|
+ if (Objects.nonNull(preConditions)) {
|
|
|
+ String result = preConditionScript(preConditions.toString(), args);
|
|
|
+ if (Objects.equals("1", result) || Objects.equals("2", result)) {
|
|
|
+ return UniReturnUtil.success(result);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ List<Object> parameters = new ArrayList<>();
|
|
|
+// 获取入参列表
|
|
|
+ if (Objects.nonNull(parameterSet)) {
|
|
|
+ HashMap<String, Object> source = new HashMap<>();
|
|
|
+ source.put("args", args);
|
|
|
+ source.put("algorithm", algorithmLibrary);
|
|
|
+ source.put("datasource", datasource);
|
|
|
+ parameters.add(getParams(parameterSet.toString(), source));
|
|
|
+ }
|
|
|
|
|
|
- switch (type) {
|
|
|
+ switch (type.toString()) {
|
|
|
// java反射
|
|
|
case "1" -> {
|
|
|
- if (Objects.nonNull(targetSource)) {
|
|
|
- File file = new File(System.getProperty("user.dir").concat(File.separator).concat("plugins").concat(File.separator).concat(targetSource));
|
|
|
+ Object connectset = datasource.get("connectset");
|
|
|
+ JsonNode jsonNode = DataFormatUtil.toJsonNode(connectset);
|
|
|
+ JsonNode path = jsonNode.get("path");
|
|
|
+ if (Objects.nonNull(path)) {
|
|
|
+ File file = new File(System.getProperty("user.dir").concat(File.separator).concat("plugins").concat(File.separator).concat(path.asText()));
|
|
|
if (!file.exists()) {
|
|
|
- return "外部文件加载不存在：".concat(System.getProperty("user.dir")).concat(File.separator).concat("plugins").concat(File.separator).concat(targetSource);
|
|
|
+ throw new RuntimeException("外部文件加载不存在：".concat(System.getProperty("user.dir")).concat(File.separator).concat("plugins").concat(File.separator).concat(path.asText()));
|
|
|
}
|
|
|
Method addURLMethod = null;
|
|
|
+
|
|
|
boolean accessible = false;
|
|
|
try {
|
|
|
addURLMethod = URLClassLoader.class.getDeclaredMethod("addURL", URL.class);
|
|
|
@@ -59,121 +93,52 @@ public class DataProcessService {
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
+ JsonNode className = jsonNode.get("className");
|
|
|
|
|
|
- Class<?> classExample = Class.forName(className); //获取类实例
|
|
|
+ Class<?> classExample = Class.forName(className.asText()); //获取类实例
|
|
|
Method javaMethod = null;
|
|
|
+ Method closeMethod = null;
|
|
|
Object classInstance = classExample.getConstructor().newInstance();//类实例接口 无参数构造
|
|
|
for (Method currentMethod : classExample.getMethods()) {//循环所有方法
|
|
|
String methodName = currentMethod.getName();
|
|
|
if (methodName.equals(expression)) {
|
|
|
javaMethod = currentMethod;
|
|
|
- break;
|
|
|
+ }else if(methodName.equals("close")){
|
|
|
+ closeMethod=currentMethod;
|
|
|
}
|
|
|
}
|
|
|
if (Objects.isNull(javaMethod)) {
|
|
|
throw new MethodNotFoundException(expression + "： 没找到");
|
|
|
}
|
|
|
- return javaMethod.invoke(classInstance, args);
|
|
|
+
|
|
|
+ Object invoke = javaMethod.invoke(classInstance, parameters.toArray());
|
|
|
+// 关闭 因为没有做实例的缓存 所以要关闭算法
|
|
|
+ if(Objects.nonNull(closeMethod)){
|
|
|
+ closeMethod.invoke(classInstance);
|
|
|
+ }
|
|
|
+ return UniReturnUtil.success(invoke);
|
|
|
}
|
|
|
// JS表达式
|
|
|
case "2" -> {
|
|
|
- return ScriptEngineUtil.eval(expression, args);
|
|
|
+ return UniReturnUtil.success(ScriptEngineUtil.eval(expression.toString(), parameters.toArray()));
|
|
|
}
|
|
|
// 数据库
|
|
|
case "3" -> {
|
|
|
- String eventStr = expression.trim().substring(0, 6);
|
|
|
- if (Objects.equals(eventStr, "insert") || Objects.equals(eventStr, "update") || Objects.equals(eventStr, "delete") || Objects.equals(eventStr, "select")) {
|
|
|
- switch (event) {
|
|
|
- case "1", "2", "3" -> {
|
|
|
- List<Object[]> argsList = Arrays.stream(args).map(it -> ((Object[]) it)).toList();
|
|
|
- return DataBase.updateBatch(targetSource, expression, argsList);
|
|
|
-
|
|
|
- }
|
|
|
- case "0" -> {
|
|
|
- List<Object[]> argsList = Arrays.stream(args).map(it -> ((Object[]) it)).toList();
|
|
|
- return DataBase.query(targetSource, expression, argsList);
|
|
|
- }
|
|
|
- default -> {
|
|
|
- throw new RuntimeException("event 不能为空");
|
|
|
- }
|
|
|
- }
|
|
|
- } else {
|
|
|
- switch (event) {
|
|
|
- case "6" -> {
|
|
|
-
|
|
|
- Map<String, List<Map<String, Object>>> insertOrUpdate = splitDBData(targetSource, expression, Arrays.stream(args).map(it -> ((Map<String, Object>) it)).toList());
|
|
|
- List<Map<String, Object>> insertList = insertOrUpdate.get("1");
|
|
|
- Object o = processByAlgorithm(type, targetSource, className, "1", expression, filterColumns,filterLines,insertList.toArray());
|
|
|
- List<Map<String, Object>> updateList = insertOrUpdate.get("2");
|
|
|
- Object o2 = processByAlgorithm(type, targetSource, className, "2", expression,filterColumns,filterLines, updateList.toArray());
|
|
|
- return null;
|
|
|
- }
|
|
|
- case "0" -> {
|
|
|
- expression = """
|
|
|
- select * from %s where 《whereStr》
|
|
|
- """.formatted(expression);
|
|
|
- List<Map<String, Object>> result = DataBase.query(targetSource, expression, Arrays.stream(args).map(it -> ((Map<String, Object>) it)).toList(), filterColumns, filterLines);
|
|
|
-
|
|
|
- }
|
|
|
- case "1" -> {
|
|
|
- List<Map<String,Object>> objects = Arrays.stream(args).map(it -> (Map<String,Object>)((Map<String, Object>) it).getOrDefault("value", it)).toList();
|
|
|
-
|
|
|
- Map<String,Object> o = objects.get(0);
|
|
|
- List<String> names = o.keySet().stream().filter(it->{
|
|
|
- if(Objects.isNull(filterColumns) || filterColumns.isEmpty()) return true;
|
|
|
- return filterColumns.contains(it);
|
|
|
- }).toList();
|
|
|
- String sql = "insert into %s(%s) values(%s)".formatted(expression, String.join(",", names), names.stream().map(it->"?").collect(Collectors.joining(",")));
|
|
|
+// 下放到Database中处理数据
|
|
|
|
|
|
- return DataBase.updateBatch(targetSource, sql, objects.stream().map(value -> names.stream().map(value::get).toArray()).toList());
|
|
|
- }
|
|
|
- case "2" -> {
|
|
|
-
|
|
|
- }
|
|
|
- case "3" -> {
|
|
|
-
|
|
|
- }
|
|
|
- default -> {
|
|
|
-
|
|
|
- throw new RuntimeException("event 不能为空");
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- public Map<String, List<Map<String, Object>>> splitDBData(String connectionStr, String tableName, List<Map<String, Object>> argsList) throws Exception {
|
|
|
-
|
|
|
- Map<String, List<Map<String, Object>>> result = new HashMap<>() {{
|
|
|
- put("1", new ArrayList<>());
|
|
|
- put("2", new ArrayList<>());
|
|
|
- }};
|
|
|
- for (Map<String, Object> args : argsList) {
|
|
|
-
|
|
|
- if (exist(connectionStr, tableName, args)) {
|
|
|
- result.get("2").add(args);
|
|
|
- } else {
|
|
|
- result.get("1").add(args);
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
- return result;
|
|
|
+ return UniReturnUtil.fail("");
|
|
|
}
|
|
|
|
|
|
- public boolean exist(String connectionStr, String tableName, Map<String, Object> args) throws Exception {
|
|
|
-
|
|
|
- List<Map<String, Object>> mapList = DataBase.query(connectionStr, "select count(1) as existscount from %s where 《whereStr》 ".formatted(tableName), List.of(args), null, null);
|
|
|
-
|
|
|
- return !mapList.get(0).get("existscount").equals("0");
|
|
|
+ private static String preConditionScript(String script, List<Map<String, Object>> args) throws Exception {
|
|
|
+ return ScriptEngineUtil.eval(script, args);
|
|
|
}
|
|
|
|
|
|
- public void close() {
|
|
|
-
|
|
|
+ // 参数使用标准的jsonPath表达式 $.a.b[0].c,多个参数之间使用;;分隔
|
|
|
+ private static List<Object> getParams(String parameterSet, Object source) {
|
|
|
+ String[] paths = parameterSet.split(";;");
|
|
|
+ return Arrays.stream(paths).map(it -> JsonPath.read(source, it.trim())).toList();
|
|
|
}
|
|
|
|
|
|
- public Object getErrorMessage() {
|
|
|
- return null;
|
|
|
- }
|
|
|
}
|
