SpringBoot 使用 Elasticsearch 更新门店药品库存

要直接根据门店 ID (storeId) 和药品 ID (drugId) 更新库存 (stock)，可以使用 Elasticsearch 的 Update API。

首先，您需要在 Spring Boot 应用程序中使用 Elasticsearch 的 Java 客户端库，例如 Spring Data Elasticsearch，来与 Elasticsearch 进行交互。

假设您已经配置了 Spring Data Elasticsearch，并创建了一个与索引 'StoreDrugIndex' 相关联的实体类 'StoreDrug'，其中包含 storeId、drugId 和 stock 属性。

以下是一个示例代码片段，演示如何使用 Spring Data Elasticsearch 来更新库存：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.elasticsearch.core.ElasticsearchOperations;
import org.springframework.data.elasticsearch.core.query.UpdateQuery;
import org.springframework.data.elasticsearch.core.query.UpdateQueryBuilder;
import org.springframework.stereotype.Service;

@Service
public class StoreDrugService {

    @Autowired
    private ElasticsearchOperations elasticsearchOperations;

    public void updateStockByStoreIdAndDrugId(String storeId, String drugId, int newStock) {
        UpdateQuery updateQuery = new UpdateQueryBuilder()
                .withId(storeId + "-" + drugId) // 使用storeId和drugId作为文档的唯一ID
                .withIndexName("StoreDrugIndex")
                .withType("StoreDrug")
                .withScript("ctx._source.stock = params.newStock")
                .withParam("newStock", newStock)
                .build();

        elasticsearchOperations.update(updateQuery);
    }
}

在上述代码中，我们首先创建了一个 UpdateQueryBuilder 对象，指定了需要更新的索引名称、文档类型和更新脚本。脚本中使用了 Elasticsearch 的上下文对象 (ctx._source) 来更新文档的 stock 属性。我们还通过 withParam() 方法将新的库存值作为参数传递给脚本。

然后，我们使用 ElasticsearchOperations 对象的 update() 方法执行更新操作。

调用 updateStockByStoreIdAndDrugId() 方法时，将传递门店 ID、药品 ID 和新的库存值作为参数。根据这些参数，我们构建了一个唯一的文档 ID (storeId + "-" + drugId)，使用它来更新相应的文档。

请注意，这只是一个简单的示例，您可能需要根据您的实际需求进行适当的修改和调整。