1.mq避免二次消费

blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/OpenOrderHandler.java

@@ -55,6 +55,7 @@ public class OpenOrderHandler {
 		if(Objects.isNull(advanceEntity)){
 			log.info("##################openOrderStatusHandler: 未找到对应订单 orderNo={}",orderNo);
 			channel.basicAck(deliveryTag,true);
+			return;
 		}
 		String type = advanceEntity.getType();//品牌
 

blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/OrderStatusHandler.java

@@ -55,6 +55,7 @@ public class OrderStatusHandler {
 		if(Objects.isNull(advanceEntity)){
 			log.info("##################orderStatusHandler: 未找到对应订单 orderNo={}",orderNo);
 			channel.basicAck(deliveryTag,true);
+			return;
 		}
 		String type = advanceEntity.getType();//品牌
 

blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/ReceiveInfoHandler.java

@@ -59,6 +59,7 @@ public class ReceiveInfoHandler {
 		if(Objects.isNull(advanceEntity)){
 			log.info("##################receiveInfoHandler: 未找到对应订单 orderCode={}",orderCode);
 			channel.basicAck(deliveryTag,true);
+			return;
 		}
 		String type = advanceEntity.getType();//品牌