浏览代码

Merge branch 'task-lyh-inctype2' into test

lyhzzz 2 年之前
父节点
当前提交
2f1303a621
共有 1 个文件被更改,包括 2 次插入5 次删除
  1. 2 5
      src/main/java/com/fdkankan/ucenter/mq/consumer/ScenePayStatusConsumer.java

+ 2 - 5
src/main/java/com/fdkankan/ucenter/mq/consumer/ScenePayStatusConsumer.java

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