|
|
|
|
@ -1,14 +1,7 @@
|
|
|
|
|
package com.hongshu.web.service.impl;
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.collection.CollectionUtil;
|
|
|
|
|
import co.elastic.clients.elasticsearch.ElasticsearchClient;
|
|
|
|
|
import co.elastic.clients.elasticsearch._types.SortOrder;
|
|
|
|
|
import co.elastic.clients.elasticsearch.core.*;
|
|
|
|
|
import co.elastic.clients.elasticsearch.core.bulk.BulkOperation;
|
|
|
|
|
import co.elastic.clients.elasticsearch.core.search.Hit;
|
|
|
|
|
import co.elastic.clients.elasticsearch.core.search.TotalHits;
|
|
|
|
|
import co.elastic.clients.elasticsearch.indices.CreateIndexRequest;
|
|
|
|
|
import co.elastic.clients.elasticsearch.indices.DeleteIndexRequest;
|
|
|
|
|
import com.alibaba.fastjson2.JSON;
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
|
|
@ -32,6 +25,26 @@ import com.hongshu.web.service.IWebEsNoteService;
|
|
|
|
|
import lombok.SneakyThrows;
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
|
|
import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
|
|
|
|
|
import org.elasticsearch.client.indices.CreateIndexRequest;
|
|
|
|
|
import org.elasticsearch.action.bulk.BulkRequest;
|
|
|
|
|
import org.elasticsearch.action.bulk.BulkResponse;
|
|
|
|
|
import org.elasticsearch.action.delete.DeleteRequest;
|
|
|
|
|
import org.elasticsearch.action.delete.DeleteResponse;
|
|
|
|
|
import org.elasticsearch.action.index.IndexRequest;
|
|
|
|
|
import org.elasticsearch.action.index.IndexResponse;
|
|
|
|
|
import org.elasticsearch.action.search.SearchRequest;
|
|
|
|
|
import org.elasticsearch.action.search.SearchResponse;
|
|
|
|
|
import org.elasticsearch.action.update.UpdateRequest;
|
|
|
|
|
import org.elasticsearch.action.update.UpdateResponse;
|
|
|
|
|
import org.elasticsearch.client.RequestOptions;
|
|
|
|
|
import org.elasticsearch.client.RestHighLevelClient;
|
|
|
|
|
import org.elasticsearch.common.xcontent.XContentType;
|
|
|
|
|
import org.elasticsearch.index.query.BoolQueryBuilder;
|
|
|
|
|
import org.elasticsearch.index.query.QueryBuilders;
|
|
|
|
|
import org.elasticsearch.search.SearchHit;
|
|
|
|
|
import org.elasticsearch.search.builder.SearchSourceBuilder;
|
|
|
|
|
import org.elasticsearch.search.sort.SortOrder;
|
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
|
|
@ -54,7 +67,7 @@ public class WebEsNoteServiceImpl extends ServiceImpl<WebNoteMapper, WebNote> im
|
|
|
|
|
@Autowired
|
|
|
|
|
private WebNoteMapper noteMapper;
|
|
|
|
|
@Autowired
|
|
|
|
|
private ElasticsearchClient elasticsearchClient;
|
|
|
|
|
private RestHighLevelClient restHighLevelClient;
|
|
|
|
|
@Autowired
|
|
|
|
|
private WebLikeOrCollectMapper likeOrCollectionMapper;
|
|
|
|
|
|
|
|
|
|
@ -71,40 +84,48 @@ public class WebEsNoteServiceImpl extends ServiceImpl<WebNoteMapper, WebNote> im
|
|
|
|
|
Page<NoteSearchVO> page = new Page<>();
|
|
|
|
|
List<NoteSearchVO> noteSearchVOList = new ArrayList<>();
|
|
|
|
|
try {
|
|
|
|
|
SearchRequest.Builder builder = new SearchRequest.Builder().index(NoteConstant.NOTE_INDEX);
|
|
|
|
|
SearchRequest searchRequest = new SearchRequest(NoteConstant.NOTE_INDEX);
|
|
|
|
|
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
|
|
|
|
|
BoolQueryBuilder mainQuery = QueryBuilders.boolQuery();
|
|
|
|
|
|
|
|
|
|
if (StringUtils.isNotBlank(esNoteDTO.getKeyword())) {
|
|
|
|
|
builder.query(q -> q.bool(b -> b
|
|
|
|
|
.should(h -> h.match(f -> f.field("title").boost(1f).query(esNoteDTO.getKeyword())))
|
|
|
|
|
.should(h -> h.match(f -> f.field("username").boost(0.5f).query(esNoteDTO.getKeyword())))
|
|
|
|
|
.should(h -> h.match(f -> f.field("content").boost(1f).query(esNoteDTO.getKeyword())))
|
|
|
|
|
.should(h -> h.match(f -> f.field("tags").boost(4f).query(esNoteDTO.getKeyword())))
|
|
|
|
|
.should(h -> h.match(f -> f.field("categoryName").boost(2f).query(esNoteDTO.getKeyword())))
|
|
|
|
|
.should(h -> h.match(f -> f.field("categoryParentName").boost(1.5f).query(esNoteDTO.getKeyword())))
|
|
|
|
|
));
|
|
|
|
|
BoolQueryBuilder keywordQuery = QueryBuilders.boolQuery()
|
|
|
|
|
.should(QueryBuilders.matchQuery("title", esNoteDTO.getKeyword()).boost(1f))
|
|
|
|
|
.should(QueryBuilders.matchQuery("username", esNoteDTO.getKeyword()).boost(0.5f))
|
|
|
|
|
.should(QueryBuilders.matchQuery("content", esNoteDTO.getKeyword()).boost(1f))
|
|
|
|
|
.should(QueryBuilders.matchQuery("tags", esNoteDTO.getKeyword()).boost(4f))
|
|
|
|
|
.should(QueryBuilders.matchQuery("categoryName", esNoteDTO.getKeyword()).boost(2f))
|
|
|
|
|
.should(QueryBuilders.matchQuery("categoryParentName", esNoteDTO.getKeyword()).boost(1.5f));
|
|
|
|
|
mainQuery.must(keywordQuery);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (StringUtils.isNotBlank(esNoteDTO.getCpid()) && StringUtils.isNotBlank(esNoteDTO.getCid())) {
|
|
|
|
|
builder.query(q -> q.bool(b -> b
|
|
|
|
|
.must(h -> h.match(m -> m.field("cid").query(esNoteDTO.getCid())))
|
|
|
|
|
.must(h -> h.match(m -> m.field("cpid").query(esNoteDTO.getCpid())))
|
|
|
|
|
));
|
|
|
|
|
mainQuery.must(QueryBuilders.matchQuery("cid", esNoteDTO.getCid()))
|
|
|
|
|
.must(QueryBuilders.matchQuery("cpid", esNoteDTO.getCpid()));
|
|
|
|
|
} else if (StringUtils.isNotBlank(esNoteDTO.getCpid())) {
|
|
|
|
|
builder.query(h -> h.match(m -> m.field("cpid").query(esNoteDTO.getCpid())));
|
|
|
|
|
mainQuery.must(QueryBuilders.matchQuery("cpid", esNoteDTO.getCpid()));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (mainQuery.hasClauses()) {
|
|
|
|
|
sourceBuilder.query(mainQuery);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (esNoteDTO.getType() == 1) {
|
|
|
|
|
builder.sort(o -> o.field(f -> f.field("likeCount").order(SortOrder.Desc)));
|
|
|
|
|
sourceBuilder.sort("likeCount", SortOrder.DESC);
|
|
|
|
|
} else if (esNoteDTO.getType() == 2) {
|
|
|
|
|
builder.sort(o -> o.field(f -> f.field("time").order(SortOrder.Desc)));
|
|
|
|
|
}
|
|
|
|
|
builder.from((int) (currentPage - 1) * (int) pageSize);
|
|
|
|
|
builder.size((int) pageSize);
|
|
|
|
|
SearchRequest searchRequest = builder.build();
|
|
|
|
|
SearchResponse<NoteSearchVO> searchResponse = elasticsearchClient.search(searchRequest, NoteSearchVO.class);
|
|
|
|
|
TotalHits totalHits = searchResponse.hits().total();
|
|
|
|
|
page.setTotal(Objects.requireNonNull(totalHits).value());
|
|
|
|
|
List<Hit<NoteSearchVO>> hits = searchResponse.hits().hits();
|
|
|
|
|
for (Hit<NoteSearchVO> hit : hits) {
|
|
|
|
|
NoteSearchVO noteSearchVo = hit.source();
|
|
|
|
|
sourceBuilder.sort("time", SortOrder.DESC);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
sourceBuilder.from((int) (currentPage - 1) * (int) pageSize);
|
|
|
|
|
sourceBuilder.size((int) pageSize);
|
|
|
|
|
searchRequest.source(sourceBuilder);
|
|
|
|
|
|
|
|
|
|
SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
|
|
|
|
|
long totalHits = searchResponse.getHits().getTotalHits().value;
|
|
|
|
|
page.setTotal(totalHits);
|
|
|
|
|
|
|
|
|
|
for (SearchHit hit : searchResponse.getHits().getHits()) {
|
|
|
|
|
NoteSearchVO noteSearchVo = JSON.parseObject(hit.getSourceAsString(), NoteSearchVO.class);
|
|
|
|
|
noteSearchVOList.add(noteSearchVo);
|
|
|
|
|
}
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
@ -139,23 +160,25 @@ public class WebEsNoteServiceImpl extends ServiceImpl<WebNoteMapper, WebNote> im
|
|
|
|
|
List<NoteSearchVO> noteSearchVOList = new ArrayList<>();
|
|
|
|
|
//得到当前用户的浏览记录
|
|
|
|
|
try {
|
|
|
|
|
SearchRequest.Builder builder = new SearchRequest.Builder().index(NoteConstant.NOTE_INDEX);
|
|
|
|
|
builder.size(1000);
|
|
|
|
|
SearchRequest searchRequest = builder.build();
|
|
|
|
|
SearchResponse<NoteSearchVO> searchResponse = elasticsearchClient.search(searchRequest, NoteSearchVO.class);
|
|
|
|
|
TotalHits totalHits = searchResponse.hits().total();
|
|
|
|
|
//得到所有的数据
|
|
|
|
|
List<Hit<NoteSearchVO>> hits = searchResponse.hits().hits();
|
|
|
|
|
if (CollectionUtil.isNotEmpty(hits)) {
|
|
|
|
|
for (Hit<NoteSearchVO> hit : hits) {
|
|
|
|
|
NoteSearchVO noteSearchVo = hit.source();
|
|
|
|
|
SearchRequest searchRequest = new SearchRequest(NoteConstant.NOTE_INDEX);
|
|
|
|
|
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
|
|
|
|
|
sourceBuilder.size(1000);
|
|
|
|
|
searchRequest.source(sourceBuilder);
|
|
|
|
|
|
|
|
|
|
SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
|
|
|
|
|
long totalHits = searchResponse.getHits().getTotalHits().value;
|
|
|
|
|
|
|
|
|
|
SearchHit[] hits = searchResponse.getHits().getHits();
|
|
|
|
|
if (hits.length > 0) {
|
|
|
|
|
for (SearchHit hit : hits) {
|
|
|
|
|
NoteSearchVO noteSearchVo = JSON.parseObject(hit.getSourceAsString(), NoteSearchVO.class);
|
|
|
|
|
noteSearchVOList.add(noteSearchVo);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
Collections.shuffle(noteSearchVOList);
|
|
|
|
|
List<List<NoteSearchVO>> partition = Lists.partition(noteSearchVOList, (int) pageSize);
|
|
|
|
|
List<NoteSearchVO> noteSearchVOS = partition.get((int) currentPage - 1);
|
|
|
|
|
page.setTotal(totalHits != null ? totalHits.value() : 0);
|
|
|
|
|
page.setTotal(totalHits);
|
|
|
|
|
page.setRecords(noteSearchVOS);
|
|
|
|
|
}
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
@ -176,15 +199,19 @@ public class WebEsNoteServiceImpl extends ServiceImpl<WebNoteMapper, WebNote> im
|
|
|
|
|
Page<WebUser> page = new Page<>();
|
|
|
|
|
String userId = WebUtils.getRequestHeader(UserConstant.USER_ID);
|
|
|
|
|
// 用户ID为空 默认随机加载100条数据
|
|
|
|
|
List<WebUser> recommendList = null;
|
|
|
|
|
List<WebUser> recommendList = new ArrayList<>();
|
|
|
|
|
if (StringUtils.isBlank(userId)) {
|
|
|
|
|
SearchRequest searchRequest = SearchRequest.of(s -> s
|
|
|
|
|
.index(NoteConstant.NOTE_INDEX)
|
|
|
|
|
.size(100));
|
|
|
|
|
SearchResponse<WebUser> searchResponse = elasticsearchClient.search(searchRequest, WebUser.class);
|
|
|
|
|
recommendList = searchResponse.hits().hits().stream()
|
|
|
|
|
.map(Hit::source)
|
|
|
|
|
.collect(Collectors.toList());
|
|
|
|
|
SearchRequest searchRequest = new SearchRequest(NoteConstant.NOTE_INDEX);
|
|
|
|
|
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
|
|
|
|
|
sourceBuilder.size(100);
|
|
|
|
|
searchRequest.source(sourceBuilder);
|
|
|
|
|
|
|
|
|
|
SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
|
|
|
|
|
|
|
|
|
|
for (SearchHit hit : searchResponse.getHits().getHits()) {
|
|
|
|
|
WebUser user = JSON.parseObject(hit.getSourceAsString(), WebUser.class);
|
|
|
|
|
recommendList.add(user);
|
|
|
|
|
}
|
|
|
|
|
// 随机排序
|
|
|
|
|
Collections.shuffle(recommendList, new Random());
|
|
|
|
|
} else {
|
|
|
|
|
@ -198,6 +225,7 @@ public class WebEsNoteServiceImpl extends ServiceImpl<WebNoteMapper, WebNote> im
|
|
|
|
|
page.setRecords(Collections.emptyList());
|
|
|
|
|
return page;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
List<WebUser> userList = partition.get((int) currentPage - 1);
|
|
|
|
|
page.setTotal(recommendList.size());
|
|
|
|
|
page.setRecords(userList);
|
|
|
|
|
@ -216,35 +244,29 @@ public class WebEsNoteServiceImpl extends ServiceImpl<WebNoteMapper, WebNote> im
|
|
|
|
|
List<NoteSearchVO> noteSearchVOList = new ArrayList<>();
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
// 构建搜索请求
|
|
|
|
|
SearchRequest.Builder builder = new SearchRequest.Builder()
|
|
|
|
|
.index(NoteConstant.NOTE_INDEX)
|
|
|
|
|
.from(Math.toIntExact((currentPage - 1) * pageSize)) // 设置分页起始点
|
|
|
|
|
.size(Math.toIntExact(pageSize)) // 设置分页大小
|
|
|
|
|
.sort(s -> s.field(f -> f.field("likeCount").order(SortOrder.Desc))); // 按 likeCount 降序排序
|
|
|
|
|
|
|
|
|
|
SearchRequest searchRequest = builder.build();
|
|
|
|
|
|
|
|
|
|
// 执行搜索请求
|
|
|
|
|
SearchResponse<NoteSearchVO> searchResponse = elasticsearchClient.search(searchRequest, NoteSearchVO.class);
|
|
|
|
|
TotalHits totalHits = searchResponse.hits().total();
|
|
|
|
|
|
|
|
|
|
// 获取搜索结果
|
|
|
|
|
List<Hit<NoteSearchVO>> hits = searchResponse.hits().hits();
|
|
|
|
|
if (CollectionUtil.isNotEmpty(hits)) {
|
|
|
|
|
for (Hit<NoteSearchVO> hit : hits) {
|
|
|
|
|
NoteSearchVO noteSearchVo = hit.source();
|
|
|
|
|
SearchRequest searchRequest = new SearchRequest(NoteConstant.NOTE_INDEX);
|
|
|
|
|
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
|
|
|
|
|
sourceBuilder.from(Math.toIntExact((currentPage - 1) * pageSize));
|
|
|
|
|
sourceBuilder.size(Math.toIntExact(pageSize));
|
|
|
|
|
sourceBuilder.sort("likeCount", SortOrder.DESC);
|
|
|
|
|
searchRequest.source(sourceBuilder);
|
|
|
|
|
|
|
|
|
|
SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
|
|
|
|
|
long totalHits = searchResponse.getHits().getTotalHits().value;
|
|
|
|
|
|
|
|
|
|
SearchHit[] hits = searchResponse.getHits().getHits();
|
|
|
|
|
if (hits.length > 0) {
|
|
|
|
|
for (SearchHit hit : hits) {
|
|
|
|
|
NoteSearchVO noteSearchVo = JSON.parseObject(hit.getSourceAsString(), NoteSearchVO.class);
|
|
|
|
|
noteSearchVOList.add(noteSearchVo);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 设置分页结果
|
|
|
|
|
page.setTotal(totalHits != null ? totalHits.value() : 0);
|
|
|
|
|
page.setTotal(totalHits);
|
|
|
|
|
page.setRecords(noteSearchVOList);
|
|
|
|
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
// 这里可以进一步处理异常，比如记录日志或者抛出自定义异常
|
|
|
|
|
}
|
|
|
|
|
return page;
|
|
|
|
|
}
|
|
|
|
|
@ -257,8 +279,11 @@ public class WebEsNoteServiceImpl extends ServiceImpl<WebNoteMapper, WebNote> im
|
|
|
|
|
@Override
|
|
|
|
|
public void addNote(NoteSearchVO noteSearchVo) {
|
|
|
|
|
try {
|
|
|
|
|
CreateResponse createResponse = elasticsearchClient.create(e -> e.index(NoteConstant.NOTE_INDEX).id(noteSearchVo.getId()).document(noteSearchVo));
|
|
|
|
|
log.info("createResponse.result{}", createResponse.result());
|
|
|
|
|
IndexRequest indexRequest = new IndexRequest(NoteConstant.NOTE_INDEX)
|
|
|
|
|
.id(noteSearchVo.getId())
|
|
|
|
|
.source(JSON.toJSONString(noteSearchVo), XContentType.JSON);
|
|
|
|
|
IndexResponse indexResponse = restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);
|
|
|
|
|
log.info("indexResponse.result{}", indexResponse.getResult());
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
}
|
|
|
|
|
@ -272,8 +297,10 @@ public class WebEsNoteServiceImpl extends ServiceImpl<WebNoteMapper, WebNote> im
|
|
|
|
|
@Override
|
|
|
|
|
public void updateNote(NoteSearchVO noteSearchVo) {
|
|
|
|
|
try {
|
|
|
|
|
UpdateResponse<NoteSearchVO> updateResponse = elasticsearchClient.update(e -> e.index(NoteConstant.NOTE_INDEX).id(noteSearchVo.getId()).doc(noteSearchVo), NoteSearchVO.class);
|
|
|
|
|
log.info("updateResponse.result() = " + updateResponse.result());
|
|
|
|
|
UpdateRequest updateRequest = new UpdateRequest(NoteConstant.NOTE_INDEX, noteSearchVo.getId())
|
|
|
|
|
.doc(JSON.toJSONString(noteSearchVo), XContentType.JSON);
|
|
|
|
|
UpdateResponse updateResponse = restHighLevelClient.update(updateRequest, RequestOptions.DEFAULT);
|
|
|
|
|
log.info("updateResponse.result() = " + updateResponse.getResult());
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
}
|
|
|
|
|
@ -287,8 +314,9 @@ public class WebEsNoteServiceImpl extends ServiceImpl<WebNoteMapper, WebNote> im
|
|
|
|
|
@Override
|
|
|
|
|
public void deleteNote(String noteId) {
|
|
|
|
|
try {
|
|
|
|
|
DeleteResponse deleteResponse = elasticsearchClient.delete(e -> e.index(NoteConstant.NOTE_INDEX).id(String.valueOf(noteId)));
|
|
|
|
|
log.info("deleteResponse.result() ={} ", deleteResponse.result());
|
|
|
|
|
DeleteRequest deleteRequest = new DeleteRequest(NoteConstant.NOTE_INDEX, String.valueOf(noteId));
|
|
|
|
|
DeleteResponse deleteResponse = restHighLevelClient.delete(deleteRequest, RequestOptions.DEFAULT);
|
|
|
|
|
log.info("deleteResponse.result() ={} ", deleteResponse.getResult());
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
}
|
|
|
|
|
@ -316,13 +344,15 @@ public class WebEsNoteServiceImpl extends ServiceImpl<WebNoteMapper, WebNote> im
|
|
|
|
|
noteSearchVo.setIsLike(likeOrCollectionIds.contains(noteSearchVo.getId()));
|
|
|
|
|
}
|
|
|
|
|
try {
|
|
|
|
|
List<BulkOperation> result = new ArrayList<>();
|
|
|
|
|
BulkRequest bulkRequest = new BulkRequest();
|
|
|
|
|
for (NoteSearchVO noteSearchVo : noteSearchVOList) {
|
|
|
|
|
result.add(new BulkOperation.Builder().create(
|
|
|
|
|
d -> d.document(noteSearchVo).id(noteSearchVo.getId()).index(NoteConstant.NOTE_INDEX)).build());
|
|
|
|
|
IndexRequest indexRequest = new IndexRequest(NoteConstant.NOTE_INDEX)
|
|
|
|
|
.id(noteSearchVo.getId())
|
|
|
|
|
.source(JSON.toJSONString(noteSearchVo), XContentType.JSON);
|
|
|
|
|
bulkRequest.add(indexRequest);
|
|
|
|
|
}
|
|
|
|
|
BulkResponse bulkResponse = elasticsearchClient.bulk(e -> e.index(NoteConstant.NOTE_INDEX).operations(result));
|
|
|
|
|
log.info("createResponse.result{}", bulkResponse.toString());
|
|
|
|
|
BulkResponse bulkResponse = restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
|
|
|
|
|
log.info("createResponse.result{}", bulkResponse.hasFailures() ? "has failures" : "success");
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
}
|
|
|
|
|
@ -335,16 +365,19 @@ public class WebEsNoteServiceImpl extends ServiceImpl<WebNoteMapper, WebNote> im
|
|
|
|
|
public void delNoteBulkData() {
|
|
|
|
|
try {
|
|
|
|
|
// 删除索引
|
|
|
|
|
DeleteIndexRequest deleteIndexRequest = DeleteIndexRequest.of(builder -> builder.index(NoteConstant.NOTE_INDEX));
|
|
|
|
|
elasticsearchClient.indices().delete(deleteIndexRequest);
|
|
|
|
|
DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest(NoteConstant.NOTE_INDEX);
|
|
|
|
|
restHighLevelClient.indices().delete(deleteIndexRequest, RequestOptions.DEFAULT);
|
|
|
|
|
log.info("删除索引:{}", NoteConstant.NOTE_INDEX);
|
|
|
|
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("删除索引异常 (可能不存在): {}", NoteConstant.NOTE_INDEX);
|
|
|
|
|
}
|
|
|
|
|
try {
|
|
|
|
|
// 重新创建索引
|
|
|
|
|
CreateIndexRequest createIndexRequest = CreateIndexRequest.of(builder -> builder.index(NoteConstant.NOTE_INDEX));
|
|
|
|
|
elasticsearchClient.indices().create(createIndexRequest);
|
|
|
|
|
CreateIndexRequest createIndexRequest = new CreateIndexRequest(NoteConstant.NOTE_INDEX);
|
|
|
|
|
restHighLevelClient.indices().create(createIndexRequest, RequestOptions.DEFAULT);
|
|
|
|
|
log.info("创建索引:{}", NoteConstant.NOTE_INDEX);
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("Error occurred while deleting and recreating index: {}", NoteConstant.NOTE_INDEX, e);
|
|
|
|
|
log.error("Error occurred while creating index: {}", NoteConstant.NOTE_INDEX, e);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
mf-xuao