封装一些工具类

liquidnet-bus-api/liquidnet-service-goblin-api/src/main/java/com/liquidnet/service/goblin/constant/GoblinRedisConst.java

@@ -324,4 +324,7 @@ public class GoblinRedisConst {
 
     /* ----------------------------------------------------------------- */
     /* ----------------------------------------------------------------- */
+    public static final String GOBLIN_NUM_LIST = PREFIX.concat("nft:num:");//$key+":"+$skuId 根据skuId获取序号list
+    public static final String GOBLIN_NUM_DETAILS = PREFIX.concat("nft:num:details:");//$key+$num+$skuId 根据num+skuId获取DTO
+
 }

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/pom.xml

@@ -151,6 +151,11 @@
             <artifactId>liquidnet-service-goblin-api</artifactId>
             <version>1.0-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>com.liquidnet</groupId>
+            <artifactId>liquidnet-service-galaxy-api</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
         <dependency>
             <groupId>com.liquidnet</groupId>
             <artifactId>liquidnet-service-smile-do</artifactId>

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/goblin/utils/GoblinRedisUtils.java

 package com.liquidnet.client.admin.zhengzai.goblin.utils;
 
 import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
-import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.commons.lang.util.CollectionUtil;
+import com.liquidnet.service.galaxy.constant.GalaxyConstant;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftPublishAndBuyReqDto;
 import com.liquidnet.service.goblin.constant.GoblinRedisConst;
 import com.liquidnet.service.goblin.constant.NftAccStatusEnum;
 import com.liquidnet.service.goblin.dto.GoblinUserNftAccInfoVo;
@@ -151,4 +153,37 @@ public class GoblinRedisUtils {
             return true;
         }
     }
+
+    //获取 当前xx链上SkuId 发行的数量
+    public int getNftCountBySku(String routerType, String skuId) {
+        String redisKey = GalaxyConstant.REDIS_KEY_GALAXY_PUBLISH_NFT.concat(routerType).concat(":").concat(skuId);
+        Object obj = redisDataSourceUtil.getRedisGoblinUtil().get(redisKey);
+        if (obj == null) {
+            return -1;
+        } else {
+            return (int) obj;
+        }
+    }
+
+    public List<String> getNftList(String routerType, String skuId) {
+        String redisKey = GoblinRedisConst.GOBLIN_NUM_LIST.concat(routerType).concat(":").concat(skuId);
+        Object obj = redisDataSourceUtil.getRedisGoblinUtil().get(redisKey);
+        if (obj == null) {
+            return CollectionUtil.arrayListString();
+        } else {
+            return (List<String>) obj;
+        }
+    }
+
+    public void addNftList(String routerType, String skuId, String num) {
+        String redisKey = GoblinRedisConst.GOBLIN_NUM_LIST.concat(routerType).concat(":").concat(skuId);
+        List<String> voList = getNftList(routerType, skuId);
+        voList.add(num);
+        redisDataSourceUtil.getRedisGoblinUtil().set(redisKey, voList);
+    }
+
+    public void setNftNumDetails(String num, String skuId, GalaxyNftPublishAndBuyReqDto dto) {
+        String redisKey = GoblinRedisConst.GOBLIN_NUM_DETAILS.concat(num).concat(skuId);
+        redisDataSourceUtil.getRedisGoblinUtil().set(redisKey, dto);
+    }
 }

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/controller/inner/GoblinInnerNftController.java

@@ -38,4 +38,15 @@ public class GoblinInnerNftController {
         return iGoblinNftOrderService.exchange(code, userId, "systemAdmin", 4);
     }
 
+    @PostMapping("airdrop")
+    @ApiOperation("空投")
+    @ApiImplicitParams({
+            @ApiImplicitParam(type = "from", required = true, dataType = "String", name = "userId", value = "用户ID", example = "1"),
+    })
+    public ResponseDto<Boolean> exchange(
+            @RequestParam("userId") @NotBlank(message = "用户ID不能为空") String userId
+
+    ) {
+        return iGoblinNftOrderService.exchange("EXCODE", userId, "systemAdmin", 4);
+    }
 }