malei05 преди 1 седмица
родител
ревизия
336eefff87
променени са 1 файла, в които са добавени 2 реда и са изтрити 0 реда
  1. 2 0
      fn-opensearch/src/main/java/net/yaoyi/pipeline/opensearch/OpenSearchHandler.java

+ 2 - 0
fn-opensearch/src/main/java/net/yaoyi/pipeline/opensearch/OpenSearchHandler.java

@@ -72,6 +72,8 @@ public class OpenSearchHandler implements PojoRequestHandler<TaskImageMsg, TaskI
             String nsTaskFilter = String.format("sourceSendPackageDeptId = %d AND taskId = %d AND id != \"%s\" AND status > 0",
                     taskImageIndex.getSourceSendPackageDeptId(), taskImageIndex.getTaskId(), taskImageIndex.getId());
             List<TaskImageIndex.MultiResult> nsTaskResult = knnSearch(taskImageMsg.getIndexTableName(), namespace, taskImageIndex.getVector(), nsTaskFilter, "task");
+
+            nsTaskResult = nsTaskResult.stream().filter(item -> !item.getImage().equals(taskImageIndex.getImage())).collect(Collectors.toList());
             multiResultList.addAll(nsTaskResult);
             taskImageIndex.setMultiResult(JacksonUtils.toJson(multiResultList));
         }