SpringBoot 更新 Elasticsearch 索引 store_drug_index 库存 (storeId 和 drugId)

要在 Spring Boot 中更新 Elasticsearch 索引'store_drug_index'的库存'stock'，根据'storeId'和'drugId'，可以使用 Elasticsearch 的 Update API 来实现。

首先，确保你的 Spring Boot 项目已经集成了 Elasticsearch 依赖，并且已经配置好了 Elasticsearch 的连接信息。

接下来，创建一个方法来更新索引。可以在一个 Service 或 Repository 类中添加以下方法：

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.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class StoreDrugService {

    private final RestHighLevelClient restHighLevelClient;

    @Autowired
    public StoreDrugService(RestHighLevelClient restHighLevelClient) {
        this.restHighLevelClient = restHighLevelClient;
    }

    public void updateStoreDrugStock(String storeId, String drugId, int stock) throws IOException {
        UpdateRequest request = new UpdateRequest('store_drug_index', '_doc', storeId + '_' + drugId);
        
        XContentBuilder builder = XContentFactory.jsonBuilder();
        builder.startObject();
        builder.field('stock', stock);
        builder.endObject();
        
        request.doc(builder);
        
        restHighLevelClient.update(request, RequestOptions.DEFAULT);
    }
}

在上面的代码中，我们通过构建一个 UpdateRequest 对象来指定索引名称、类型和文档 ID。然后，使用 XContentBuilder 构建一个包含新库存值的 JSON 文档，并将其设置为更新请求的文档。最后，使用 RestHighLevelClient 的 update 方法来执行更新操作。

请注意，上述代码中的'store_drug_index'、'_doc' 和'stock' 分别表示索引名称、类型和库存字段名。根据你的实际情况进行修改。

现在，你可以在需要更新库存的地方调用 updateStoreDrugStock 方法，传入正确的'storeId'、'drugId' 和新的库存值。这样，索引'store_drug_index' 中的库存字段将会被更新。