caojiahao/dev_caojiahao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 优化积分商品，移除异步删除索引 (pg)

Browse Source 
- 重构deleteByQuery方法，移除异步调用，改为同步处理。
添加了异常处理以记录删除索引时的错误日志。
This commit is contained in:
misworga831 2024-12-11 16:18:37 +08:00
parent 82f3223a03
commit 2f180a73ed
1 changed files with 6 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java
View File

@ -72,6 +72,7 @@ import org.springframework.data.elasticsearch.core.SearchPage;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder; import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.io.IOException;
import java.lang.reflect.Field; import java.lang.reflect.Field;
import java.util.*; import java.util.*;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@ -484,20 +485,12 @@ public class EsGoodsIndexServiceImpl extends BaseElasticsearchService implements
deleteByQueryRequest.setQuery(boolQueryBuilder); deleteByQueryRequest.setQuery(boolQueryBuilder);
deleteByQueryRequest.indices(getIndexName()); deleteByQueryRequest.indices(getIndexName());
deleteByQueryRequest.setConflicts("proceed"); deleteByQueryRequest.setConflicts("proceed");
this.client.deleteByQueryAsync(deleteByQueryRequest, RequestOptions.DEFAULT, new ActionListener<BulkByScrollResponse>() {
@Override try {
public void onResponse(BulkByScrollResponse bulkByScrollResponse) { this.client.deleteByQuery(deleteByQueryRequest, RequestOptions.DEFAULT);
if (bulkByScrollResponse.getVersionConflicts() > 0) { } catch (IOException e) {
throw new RetryException("删除索引失败，es内容版本冲突"); log.error("删除索引出现异常", e);
} }
}
@Override
public void onFailure(Exception e) {
throw new RetryException("删除索引失败，" + e.getMessage());
}
});
} }