From aac2321d1cf5536f7ea03f30d55a4aba30fbf710 Mon Sep 17 00:00:00 2001 From: peng <peng.com> Date: 星期三, 02 七月 2025 10:39:39 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into dev --- framework/src/main/java/cn/lili/modules/lmk/service/EsService.java | 68 ++++++++++++++++++++++++++++++++++ 1 files changed, 68 insertions(+), 0 deletions(-) diff --git a/framework/src/main/java/cn/lili/modules/lmk/service/EsService.java b/framework/src/main/java/cn/lili/modules/lmk/service/EsService.java new file mode 100644 index 0000000..1054162 --- /dev/null +++ b/framework/src/main/java/cn/lili/modules/lmk/service/EsService.java @@ -0,0 +1,68 @@ +package cn.lili.modules.lmk.service; + +import java.util.Map; + +/** + * es澶勭悊 + * + * @author锛歺p + * @date锛�2025/6/30 14:47 + */ +public interface EsService { + + /** + * 鑾峰彇绱㈠紩鐨勫畬鏁村悕绉� + * + * @param indexName + * @return + */ + String getIndexFullName(String indexName); + + /** + * 鍒涘缓绱㈠紩 + * + * @param indexName 绱㈠紩鍚嶇О + * @param mappingJsonPath json鏂囦欢浣嶇疆锛岀浉瀵逛簬resource鐩綍锛屼緥濡傦細/es/video.json + */ + void createIndex(String indexName, String mappingJsonPath); + + /** + * 閲嶅缓绱㈠紩锛屽苟閲嶆柊娣诲姞绱㈠紩鏁版嵁 + * + * @param indexName 绱㈠紩鍚嶇О + * @param mappingJsonPath json鏂囦欢浣嶇疆锛岀浉瀵逛簬resource鐩綍锛屼緥濡傦細/es/video.json + */ + void recreateIndex(String indexName, String mappingJsonPath); + + /** + * 娣诲姞/淇敼 鏂囨。锛屽鏋滄槸淇敼锛屽垯鏄暣鏉℃暟鎹洿鏂� + * + * @param data 鏁版嵁瀵硅薄 + */ + void addOrUpdateDocument(Object data); + + /** + * 鏇存柊鏌愪簺瀛楁鐨勫�� + * + * @param indexName 绱㈠紩鍚嶇О + * @param id 鏁版嵁id + * @param updateList 鏇存柊鍝簺瀛楁锛宬ey 瀛楁 value瑕佷慨鏀圭殑鍊� + */ + void updateSomeField(String indexName, String id, Map<String, Object> updateList); + + /** + * 鍒犻櫎鏂囨。 + * @param indexName 绱㈠紩鍚嶇О + * @param id es涓婚敭锛屽彲浼犱笟鍔′富閿� + */ + void deleteDocument(String indexName, String id); + + /** + * 绱㈠紩鏄惁瀛樺湪 + * + * @param indexName + * @return + */ + boolean indexExist(String indexName); + +} -- Gitblit v1.8.0