diff --git a/cf-module-prod-executor/cf-module-prod-executor-biz/src/main/java/com/cf/imes/module/executor/util/elasticsearch/EsUtils.java b/cf-module-prod-executor/cf-module-prod-executor-biz/src/main/java/com/cf/imes/module/executor/util/elasticsearch/EsUtils.java index 9e05c957d..0062ff445 100644 --- a/cf-module-prod-executor/cf-module-prod-executor-biz/src/main/java/com/cf/imes/module/executor/util/elasticsearch/EsUtils.java +++ b/cf-module-prod-executor/cf-module-prod-executor-biz/src/main/java/com/cf/imes/module/executor/util/elasticsearch/EsUtils.java @@ -8,7 +8,10 @@ import co.elastic.clients.elasticsearch._types.FieldValue; import co.elastic.clients.elasticsearch._types.SortOrder; import co.elastic.clients.elasticsearch._types.Time; import co.elastic.clients.elasticsearch._types.query_dsl.Query; -import co.elastic.clients.elasticsearch.core.*; +import co.elastic.clients.elasticsearch.core.DeleteByQueryRequest; +import co.elastic.clients.elasticsearch.core.ScrollResponse; +import co.elastic.clients.elasticsearch.core.SearchRequest; +import co.elastic.clients.elasticsearch.core.SearchResponse; import co.elastic.clients.elasticsearch.core.search.Hit; import co.elastic.clients.elasticsearch.indices.RefreshRequest; import co.elastic.clients.json.JsonData; @@ -17,9 +20,6 @@ import com.cf.imes.framework.common.exception.ServiceException; import com.cf.imes.framework.common.util.json.JsonUtils; import com.cf.imes.framework.es.core.dal.ESDocument; import com.cf.imes.framework.es.core.service.ESDocumentService; -import com.cf.imes.framework.security.core.LoginUser; -import com.cf.imes.framework.security.core.util.SecurityFrameworkUtils; -import com.cf.imes.module.executor.dal.dataobject.ordermodel.OrderModelDataTest; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; @@ -566,31 +566,6 @@ public class EsUtils { - public void savePlateModelEs(String index,List targetClass) { - try { - - BulkRequest.Builder br = new BulkRequest.Builder(); - LoginUser loginUser = SecurityFrameworkUtils.getLoginUser(); - targetClass.forEach(esDocument -> { - esDocument.setOrganId(loginUser.getOrganId()); - br.operations(op -> op.index(idx -> idx - .index(index) - .document(esDocument))); - }); - elasticsearchClient.bulk(br.build()); - - } catch (IOException | ElasticsearchException e) { - e.printStackTrace(); - log.error(e.getMessage()); - throw new ServiceException(DATA_DATA_ERROR); - } - - } - - - - - // ES 文档数据刷新 public void refresh( String index) {