Spring Boot Elasticsearch 批量更新索引字段 (storeId)

要批量更新 Elasticsearch 索引中的字段，可以使用 Elasticsearch 的 'update_by_query' API。以下是使用 Spring Boot 和 Elasticsearch 进行批量更新的示例代码：

首先，确保你已经在 Spring Boot 项目中集成了 Elasticsearch。在 pom.xml 文件中添加 Elasticsearch 的依赖项，并配置 Elasticsearch 连接信息。

接下来，创建一个名为 'ElasticsearchService' 的服务类，用于执行 Elasticsearch 的操作。在该类中，创建一个方法来批量更新索引中的字段。

import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.reindex.UpdateByQueryRequest;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.IOException;

@Service
public class ElasticsearchService {

    @Autowired
    private RestHighLevelClient client;

    public void updateFieldsByStoreId(String indexName, String storeId, String o2o, String b2c, String selfTake, String state,
                                      String location, String polygon) throws IOException {

        UpdateByQueryRequest request = new UpdateByQueryRequest(indexName);
        request.setQuery(QueryBuilders.termQuery('storeId', storeId));

        XContentBuilder builder = XContentFactory.jsonBuilder();
        builder.startObject();
        builder.field('o2o', o2o);
        builder.field('b2c', b2c);
        builder.field('selfTake', selfTake);
        builder.field('state', state);
        builder.field('location', location);
        builder.field('polygon', polygon);
        builder.endObject();

        request.setScript(new Script(builder));

        client.updateByQuery(request, RequestOptions.DEFAULT);
    }
}

在上述代码中，'updateFieldsByStoreId' 方法接收索引名称（indexName）和 storeId，以及要更新的字段值作为参数。通过 'UpdateByQueryRequest' 创建更新请求，并使用 'QueryBuilders' 构建一个查询条件来指定要更新的文档。

然后，使用 'XContentBuilder' 构建一个新的文档，设置要更新的字段和对应的新值。最后，使用 'client.updateByQuery' 方法执行批量更新操作。

注意：这里假设你已经配置了 Elasticsearch 的连接信息，并注入了 'RestHighLevelClient' 实例。

你可以根据需要在 Spring Boot 应用程序的其他部分调用 'updateFieldsByStoreId' 方法，传递适当的参数来执行批量更新操作。