~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

@@ -12,6 +12,7 @@ import com.liquidnet.service.goblin.dto.vo.GoblinStoreOrderVo;
 import com.mongodb.BasicDBObject;
 import com.mongodb.client.result.UpdateResult;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.convert.MongoConverter;
@@ -64,10 +65,12 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
 
     private boolean consumerOrderCloseHandler(Map<String, String> messageMap) {
         try {
-            String orderCode = messageMap.get("id"), type = messageMap.get("type");
-            LocalDateTime createdAt = LocalDateTime.parse(messageMap.get("time"));
+            String orderCode = messageMap.get("id"), type = messageMap.get("type"), time = messageMap.get("time");
 
-            long durationToMillis = Duration.between(createdAt.plusMinutes(5), LocalDateTime.now()).toMillis();
+            LocalDateTime now = LocalDateTime.now();
+            LocalDateTime createdAt = StringUtils.isEmpty(time) ? now.minusMinutes(5) : LocalDateTime.parse(time);
+
+            long durationToMillis = Duration.between(createdAt.plusMinutes(5), now).toMillis();
 
             if (durationToMillis > 0) {
                 return checkOrderTime(orderCode, type);