增加 sql

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

@@ -98,9 +98,6 @@ 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();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/resources/sqlmap.properties

+#----                   订单关闭
+goblin_order.close.order=UPDATE goblin_store_order SET status = ? ,updated_at = ? , cancel_time = ? , cancel_reason=?  WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
+goblin_order.close.sku=UPDATE goblin_order_sku SET status = ? ,updated_at = ? WHERE order_sku_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
\ No newline at end of file