..

kxs-product/kxs-product-biz/src/main/java/com/kxs/product/biz/mq/RabbitKxsOrderQueueListener.java

@@ -40,9 +40,8 @@ public class RabbitKxsOrderQueueListener {
 	@RabbitListener(queues = RabbitKxsOrderQueueMQ.QUEUE_NAME, ackMode = "MANUAL")
 	@RabbitHandler
 	public void onMessage(String msg, Message message, Channel channel){
-		log.info("收到客小爽订单消息: " + msg);
-		log.info("收到客小爽订单消息: " + RabbitKxsOrderQueueMQ.parse(msg));
         try {
+			log.info("收到客小爽订单消息: " + RabbitKxsOrderQueueMQ.parse(msg));
 			RabbitKxsOrderQueueMQ.MsgEntity parse = RabbitKxsOrderQueueMQ.parse(msg);
 			//处理百城千团订单，创建活动
 			if(parse.getProductId() == 100 && parse.getStatus() == 2){
@@ -54,7 +53,7 @@ public class RabbitKxsOrderQueueListener {
 
 			channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
         } catch (Exception e) {
-			log.error("客小爽订单消息消费失败:{}", JSON.toJSONString(msg), e);
+			log.error("客小爽订单消息消费失败:{}", msg, e);
 			try {
 				channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
 			} catch (IOException ex) {