Spring Boot 使用 RestTemplate 更新 Elasticsearch 索引中的 isStock 字段

您可以使用 Spring Boot 中的 RestTemplate 来发送 HTTP 请求并执行此操作。以下是一个示例代码：

首先，您需要在您的项目中添加 RestTemplate 的依赖，可以在 pom.xml 文件中添加以下代码：

<dependencies>
    <!-- 其他依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!-- 添加 RestTemplate 依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
</dependencies>

接下来，您可以创建一个名为 ElasticsearchService 的类，其中包含一个名为 updateIsStock 的方法，该方法将使用 RestTemplate 发送 HTTP 请求到 Elasticsearch 并执行您的操作。代码如下：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

@Service
public class ElasticsearchService {
    
    private final RestTemplate restTemplate;
    
    @Autowired
    public ElasticsearchService(RestTemplate restTemplate) {
        this.restTemplate = restTemplate;
    }

    public void updateIsStock(String storeId, String drugId) {
        String url = "http://localhost:9200/store_drug_index/_update_by_query";
        
        // 构造请求头
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_JSON);
        
        // 构造请求体
        String requestBody = "{\"query\":{\"bool\":{\"must\":[\"{\"term\":{\"storeId\":\""+ storeId +"\"}}",\"{\"term\":{\"drugId\":\""+ drugId +"\"}}"]}},\"script\":{\"inline\":\"ctx._source['isStock'] =  true\"}}";
        
        // 发送请求
        HttpEntity<String> requestEntity = new HttpEntity<>(requestBody, headers);
        restTemplate.exchange(url, HttpMethod.POST, requestEntity, String.class);
    }
}

注意，上述代码中的 URL 是 Elasticsearch 的默认 URL。如果您的 Elasticsearch 服务运行在其他主机或端口上，请相应地修改 URL。

最后，您可以在您的代码中注入 ElasticsearchService 并调用 updateIsStock 方法来执行索引的修改操作。例如：

@Service
public class YourService {
    
    private final ElasticsearchService elasticsearchService;
    
    @Autowired
    public YourService(ElasticsearchService elasticsearchService) {
        this.elasticsearchService = elasticsearchService;
    }
    
    public void updateIsStock(String storeId, String drugId) {
        elasticsearchService.updateIsStock(storeId, drugId);
    }
}

请确保在您的 Spring Boot 应用程序中正确配置了 RestTemplate。