修改逻辑

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

@@ -26,6 +26,8 @@ import java.time.LocalDateTime;
 import java.util.HashMap;
 import java.util.LinkedList;
 
+import static com.liquidnet.commons.lang.util.DateUtil.DTF_YMD_HMS;
+
 @Slf4j
 public abstract class AbstractOrderCloseReceiver implements StreamListener<String, MapRecord<String, String, String>> {
     @Autowired
@@ -102,6 +104,9 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
             String[] orderIds = getMasterCode(valueData);
             for (String orderId : orderIds) {
                 GoblinStoreOrderVo orderVo = getGoblinOrder(orderId);
+                if (LocalDateTime.parse(orderVo.getCreatedAt(), DTF_YMD_HMS).plusMinutes(5).isBefore(now)) {
+                    continue;
+                }
                 if (orderVo.getStatus().equals(GoblinStatusConst.Status.ORDER_STATUS_0.getValue())) {//订单回滚
                     LinkedList<String> sqls = CollectionUtil.linkedListString();
                     LinkedList<Object[]> sqlDataOrder = CollectionUtil.linkedListObjectArr();