预约用户才可购买

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/GoblinNftOrderServiceImpl.java

@@ -69,6 +69,12 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
                     return ResponseDto.failure("您还未开通数字账户～");
                 }
 
+                // 若开启了预约 判断用户是否预约
+                boolean userAboutAut = nftOrderUtils.getUserAboutAut(payParam.getSkuId(), uid);
+                if (!userAboutAut) {
+                    return ResponseDto.failure("此数字藏品仅限预约用户购买～");
+                }
+
                 // 是否存在此商品信息 是否隐藏
                 String skuId = payParam.getSkuId();
                 int number = 1;

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/utils/GoblinNftOrderUtils.java

@@ -176,6 +176,32 @@ public class GoblinNftOrderUtils {
         return (int) redisUtil.decr(redisKey, number);
     }
 
+    // skuId 是否开启预约
+    public boolean getValueBySkuId(String skuId) {
+        String redisKey = GoblinRedisConst.ANTICIPATE_VALUE_SKUID.concat(skuId);
+        Object obj = redisUtil.get(redisKey);
+        if (obj == null) {
+            return false;
+        } else {
+            return true;
+        }
+    }
+    // 是否预约过 没开启true
+    public boolean getUserAboutAut(String skuId, String uid) {
+        boolean valueBySkuId = getValueBySkuId(skuId);
+        if (valueBySkuId) {
+            String redisKey = GoblinRedisConst.USER_ANTICIPATE_STATE.concat(skuId).concat(uid);
+            Object obj = redisUtil.get(redisKey);
+            if (obj == null) {
+                return false;
+            } else {
+                return true;
+            }
+        } else {
+            return true;
+        }
+    }
+
     /**
      * 使用平台优惠券 只支持代金券
      *