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

fix: 优化消费者部分异常处理

Browse Source
This commit is contained in:
misworga831 2023-08-03 16:13:52 +08:00
parent 557366a3ec
commit 1cc692a3c9
2 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
consumer/src/main/java/cn/lili/event/impl/NoticeMessageExecute.java
View File

@ -58,7 +58,7 @@ public class NoticeMessageExecute implements TradeEvent, OrderStatusChangeEvent,
OrderDetailVO orderDetailVO = orderService.queryDetail(orderMessage.getOrderSn()); OrderDetailVO orderDetailVO = orderService.queryDetail(orderMessage.getOrderSn());
NoticeMessageDTO noticeMessageDTO = new NoticeMessageDTO(); NoticeMessageDTO noticeMessageDTO = new NoticeMessageDTO();
//如果订单状态不为空 //如果订单状态不为空
if (orderDetailVO != null) { if (orderDetailVO != null && orderDetailVO.getOrderItems() != null && !orderDetailVO.getOrderItems().isEmpty()) {
Map<String, String> params = new HashMap<>(2); Map<String, String> params = new HashMap<>(2);
switch (orderMessage.getNewStatus()) { switch (orderMessage.getNewStatus()) {
//如果订单新的状态为已取消 则发送取消订单站内信 //如果订单新的状态为已取消 则发送取消订单站内信

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

@ -455,10 +455,8 @@ public class EsGoodsIndexServiceImpl extends BaseElasticsearchService implements
this.client.bulkAsync(request, RequestOptions.DEFAULT, new ActionListener<BulkResponse>() { this.client.bulkAsync(request, RequestOptions.DEFAULT, new ActionListener<BulkResponse>() {
@Override @Override
public void onResponse(BulkResponse bulkItemResponses) { public void onResponse(BulkResponse bulkItemResponses) {
// 判断索引如果不存在的处理
log.info("批量更新商品索引结果：{}", bulkItemResponses.buildFailureMessage()); log.info("批量更新商品索引结果：{}", bulkItemResponses.buildFailureMessage());
if (bulkItemResponses.hasFailures() && bulkItemResponses.getItems().length > 0) {
throw new RetryException("批量更新商品索引失败，" + bulkItemResponses.buildFailureMessage());
}
} }
@Override @Override