|
@@ -62,8 +62,12 @@ public class TradeMqReceiver {
|
|
|
log.error("收到下单创建成功消息:" + data);
|
|
log.error("收到下单创建成功消息:" + data);
|
|
|
try {
|
|
try {
|
|
|
TradeOrderDO tradeOrderDO = tradeOrderRepositoryService.getById(Long.parseLong(data));
|
|
TradeOrderDO tradeOrderDO = tradeOrderRepositoryService.getById(Long.parseLong(data));
|
|
|
- tradeOrderHandlers.forEach(handler -> handler.processOrderCreateSuccess(tradeOrderDO));
|
|
|
|
|
- channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
|
|
|
|
|
+ if(tradeOrderDO==null){
|
|
|
|
|
+ log.error("processOrderCreateSuccess订单不存在"+data);
|
|
|
|
|
+ }else {
|
|
|
|
|
+ tradeOrderHandlers.forEach(handler -> handler.processOrderCreateSuccess(tradeOrderDO));
|
|
|
|
|
+ channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
|
|
|
+ }
|
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
|
log.error("下单创建成功MQ通知出现错误{}", e.getMessage());
|
|
log.error("下单创建成功MQ通知出现错误{}", e.getMessage());
|
|
|
channel.basicReject(message.getMessageProperties().getDeliveryTag(), false);
|
|
channel.basicReject(message.getMessageProperties().getDeliveryTag(), false);
|