1

src/main/java/com/fdkankan/ucenter/mq/consumer/ScenePayStatusConsumer.java

@@ -37,12 +37,9 @@ public class ScenePayStatusConsumer {
         try {
             String messageId = message.getMessageProperties().getMessageId();
             String msg = new String(message.getBody(), StandardCharsets.UTF_8);
-            log.info("接受mq--messageId:{},msg:{}",messageId,msg);
+            log.info("scene-pay-status-mq--messageId:{},msg:{}",messageId,msg);
 
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
-            msg = msg.substring(1, msg.length() - 1);
-
-            msg = StringEscapeUtils.unescapeJava(msg);
 
             ScenePayStatusVo vo = JSONObject.parseObject(msg, ScenePayStatusVo.class);
             if(vo == null){
@@ -55,7 +52,7 @@ public class ScenePayStatusConsumer {
             }
 
         }catch (Exception e){
-            log.error("scene-pay-status----消费失败",e);
+            log.info("scene-pay-status----消费失败",e);
         }finally {
 
         }