修改消费日志

liquidnet-bus-service/liquidnet-service-consumer/src/main/java/com/liquidnet/service/consumer/service/processor/ConsumerProcessor.java

@@ -86,11 +86,12 @@ public class ConsumerProcessor {
 
     // 处理长sql语句
     private void consumerOperationOrderClose(Message msg, Channel channel) {
-            String jsonStr = StringEscapeUtils.unescapeJava(new String(msg.getBody()));
-            OrderCloseMapping.orderCloseMessage mqMessage = JsonUtils.fromJson(jsonStr.substring(1,jsonStr.length()-1), OrderCloseMapping.orderCloseMessage.class);
-            log.debug("consumer  ==> mqMessage:{}", mqMessage);
+        String jsonStr = StringEscapeUtils.unescapeJava(new String(msg.getBody()));
+        OrderCloseMapping.orderCloseMessage mqMessage = JsonUtils.fromJson(jsonStr.substring(1, jsonStr.length() - 1), OrderCloseMapping.orderCloseMessage.class);
+        log.debug("consumer  ==> mqMessage:{}", mqMessage.getOrderTicketIds());
         try {
-            mqMessage.getOrderTicketIds().forEach(t -> {
+            for (int x = 0; x< mqMessage.getOrderTicketIds().size(); x++) {
+                String t = mqMessage.getOrderTicketIds().get(x);
                 String orderTicketId = t.split(",")[0];
                 String uid = t.split(",")[1];
                 KylinOrderTicketVo vo = (KylinOrderTicketVo) redisUtil.get("kylin:order:id:" + orderTicketId);
@@ -103,7 +104,7 @@ public class ConsumerProcessor {
                     KylinOrderTicketEntitiesVo items = vo.getEntitiesVoList().get(i);
                     kylinUtils.changeBuyInfo(items.getUserId(), items.getEnterIdCode(), items.getPerformanceId(), items.getTicketId(), -1);
                 }
-            });
+            }
             channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
         } catch (Exception e) {
             e.printStackTrace();
@@ -455,6 +456,7 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_REFUND   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
+
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_REFUND), key = MQConst.ROUTING_KEY_SQL_ORDER_REFUND,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_REFUND)
@@ -463,6 +465,7 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_REFUND   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
+
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_REFUND), key = MQConst.ROUTING_KEY_SQL_ORDER_REFUND,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_REFUND)
@@ -471,6 +474,7 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_REFUND   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
+
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_REFUND), key = MQConst.ROUTING_KEY_SQL_ORDER_REFUND,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_REFUND)
@@ -479,6 +483,7 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_REFUND   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
+
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_REFUND), key = MQConst.ROUTING_KEY_SQL_ORDER_REFUND,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_REFUND)
@@ -497,6 +502,7 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_WITHDRAW   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
+
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_WITHDRAW), key = MQConst.ROUTING_KEY_SQL_ORDER_WITHDRAW,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_WITHDRAW)
@@ -505,6 +511,7 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_WITHDRAW   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
+
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_WITHDRAW), key = MQConst.ROUTING_KEY_SQL_ORDER_WITHDRAW,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_WITHDRAW)
@@ -513,6 +520,7 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_WITHDRAW   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
+
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_WITHDRAW), key = MQConst.ROUTING_KEY_SQL_ORDER_WITHDRAW,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_WITHDRAW)
@@ -521,6 +529,7 @@ public class ConsumerProcessor {
         log.info("===   CONSUMER_ORDER_WITHDRAW   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }
+
     @RabbitListener(bindings = @QueueBinding(
             exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_WITHDRAW), key = MQConst.ROUTING_KEY_SQL_ORDER_WITHDRAW,
             value = @Queue(MQConst.QUEUES_SQL_ORDER_WITHDRAW)