~opt:queue.order.close;

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/AbstractOrderCloseReceiver.java

@@ -53,7 +53,7 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
             stringRedisTemplate.opsForStream().acknowledge(getRedisStreamGroup(), message);
             stringRedisTemplate.opsForStream().delete(this.getRedisStreamKey(), message.getId());
         } catch (Exception e) {
-            log.error("#CONSUMER SQL RESULT:{} ==> DEL_REDIS_QUEUE_MSG_EXCEPTION[MESSAGE_ID:{},MSG:{}]", result, message.getId(), JsonUtils.toJson(message), e);
+            log.error("#CONSUMER ORDER_CLOSE RESULT:{} ==> DEL_REDIS_QUEUE_MSG_EXCEPTION[MESSAGE_ID:{},MSG:{}]", result, message.getId(), message.getValue(), e);
         } finally {
             try {
                 stringRedisTemplate.opsForStream().acknowledge(getRedisStreamGroup(), message);
@@ -67,12 +67,11 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
         try {
             String orderCode = messageMap.get("id"), type = messageMap.get("type"), time = messageMap.get("time");
 
-            LocalDateTime now = LocalDateTime.now();
-            LocalDateTime createdAt = StringUtils.isEmpty(time) ? now.minusMinutes(5) : LocalDateTime.parse(time);
+            LocalDateTime now = LocalDateTime.now(), closeTime = now.minusMinutes(5);
+            LocalDateTime createdAt = StringUtils.isEmpty(time) ? closeTime : LocalDateTime.parse(time);
+            long durationToMillis = Duration.between(createdAt, closeTime).toMillis();
 
-            long durationToMillis = Duration.between(createdAt.plusMinutes(5), now).toMillis();
-
-            if (durationToMillis > 0) {
+            if (durationToMillis >= 0) {
                 return checkOrderTime(orderCode, type);
             } else {
                 try {