规则构建结构批量操作主键排重

ibzdst-core/src/main/java/cn/ibizlab/core/extensions/service/ExecResultExService.java

@@ -88,13 +88,19 @@ public class ExecResultExService extends ExecResultServiceImpl {
                     try {
                         synchronized (objResultSaveAsyncLock) {
                             if (resultsSaveAsync.size() > 0) {
+
                                 for (Map.Entry<String, List<ExecResult>> entry : resultsSaveAsync.entrySet()) {
                                     String execResultId = entry.getKey();
                                     String [] idArray = execResultId.split("\\|");
                                     List<ExecResult> execResults = entry.getValue();
                                     List<ExecResult> tempExecResults = new ArrayList<>();
                                     if (execResults.size() > 0 && idArray.length==3) {
-                                        for (ExecResult execResult : execResults) {
+                                        //批量操作数据主键排重
+                                        LinkedHashMap<Object,ExecResult> params=new LinkedHashMap<>();
+                                        execResults.forEach(item->{
+                                            params.put(item.getId(),item);
+                                        });
+                                        for (ExecResult execResult : params.values()) {
                                             tempExecResults.add(execResult);
                                             if (tempExecResults.size() >= saveBatchSize) {
                                                 saveResultBatch(tempExecResults, idArray[1] , idArray[2]);
@@ -148,7 +154,12 @@ public class ExecResultExService extends ExecResultServiceImpl {
                                     List<ExecResult> tempExecResults = new ArrayList<>();
                                     String [] idArray = execResultId.split("\\|");
                                     if (execResults.size() > 0 && idArray.length==3) {
-                                        for (ExecResult execResult : execResults) {
+                                        //批量操作数据主键排重
+                                        LinkedHashMap<Object,ExecResult> params=new LinkedHashMap<>();
+                                        execResults.forEach(item->{
+                                            params.put(item.getId(),item);
+                                        });
+                                        for (ExecResult execResult : params.values()) {
                                             tempExecResults.add(execResult);
                                             if (tempExecResults.size() >= deleteBatchSize) {
                                                 clearResultBatch(tempExecResults, idArray[1] , idArray[2]);