实现zxtnft购买功能

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/constant/GalaxyConstant.java

@@ -10,6 +10,8 @@ package com.liquidnet.service.galaxy.constant;
  * @date 2022/3/8 11:25
  */
 public class GalaxyConstant {
+    public static final String REDIS_KET_GALAXY_USER="galaxy:user:";
+    public static final String REDIS_KET_GALAXY_ART_SERIES="galaxy:series:";
     public static final String SERIES_STORE_NAME="NOW_ZXL_NFT_PIC";// 系列存储目录名称
 
     public enum RouterTypeEnum{

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/bo/GalaxySeriesInfoBo.java

+package com.liquidnet.service.galaxy.dto.bo;
+
+import com.liquidnet.commons.lang.util.JsonUtils;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: GalaxySeriesInfoBo
+ * @Package com.liquidnet.service.galaxy.dto.bo
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/3/15 15:03
+ */
+@Data
+public class GalaxySeriesInfoBo implements Serializable,Cloneable {
+    private String skuId;
+    private String seriesName;
+    private String seriesId;
+    private Long totalCount;
+
+    @Override
+    public String toString(){
+        return JsonUtils.toJson(this);
+    }
+
+    private static final GalaxySeriesInfoBo obj = new GalaxySeriesInfoBo();
+
+    public static GalaxySeriesInfoBo getNew() {
+        try {
+            return (GalaxySeriesInfoBo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new GalaxySeriesInfoBo();
+        }
+    }
+}

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/bo/GalaxyUserInfoBo.java

+package com.liquidnet.service.galaxy.dto.bo;
+
+import com.liquidnet.commons.lang.util.JsonUtils;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: 用户注册信息
+ * @class: GalaxyUserInfoBo
+ * @Package com.liquidnet.service.galaxy
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/3/15 14:34
+ */
+@Data
+public class GalaxyUserInfoBo implements Serializable,Cloneable{
+    private String userId;
+    private String userName;
+    private String mobile;
+    private String idCardType;
+    private String idCard;
+    private String mnemonic;
+    private String index;
+    private String userIdentification;
+    private String userPubKey;
+    private String userPriKey;
+
+    @Override
+    public String toString(){
+        return JsonUtils.toJson(this);
+    }
+
+    private static final GalaxyUserInfoBo obj = new GalaxyUserInfoBo();
+
+    public static GalaxyUserInfoBo getNew() {
+        try {
+            return (GalaxyUserInfoBo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new GalaxyUserInfoBo();
+        }
+    }
+}
+

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/GalaxyArtSeriesClaimReqDto.java → liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/param/GalaxyArtSeriesClaimReqDto.java

-package com.liquidnet.service.galaxy.dto;
+package com.liquidnet.service.galaxy.dto.param;
 
 import com.liquidnet.commons.lang.util.JsonUtils;
 import io.swagger.annotations.ApiModel;

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/GalaxyArtSeriesClaimRespDto.java → liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/param/GalaxyArtSeriesClaimRespDto.java

-package com.liquidnet.service.galaxy.dto;
+package com.liquidnet.service.galaxy.dto.param;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/GalaxyBaseReqDto.java → liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/param/GalaxyBaseReqDto.java

-package com.liquidnet.service.galaxy.dto;
+package com.liquidnet.service.galaxy.dto.param;
 
 import com.liquidnet.commons.lang.util.JsonUtils;
+import com.liquidnet.service.galaxy.constant.GalaxyConstant;
+import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
+import javax.validation.constraints.NotBlank;
 import java.io.Serializable;
 
 /**
@@ -16,7 +19,12 @@ import java.io.Serializable;
  */
 @Data
 public class GalaxyBaseReqDto implements Serializable,Cloneable{
-    private String routeType;
+    /**
+     * 路由类型(至信链zxinchain、以太坊eth)
+     */
+    @ApiModelProperty(position = 1, required = true, value = "路由类型(至信链zxinchain、以太坊eth)")
+    @NotBlank(message = "路由类型不能为空！")
+    private String routeType = GalaxyConstant.RouterTypeEnum.ZXINCHAIN.getCode();
 
     @Override
     public String toString(){

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/GalaxyNftBuyReqDto.java → liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/param/GalaxyNftBuyReqDto.java

-package com.liquidnet.service.galaxy.dto;
+package com.liquidnet.service.galaxy.dto.param;
 
 import com.liquidnet.commons.lang.util.JsonUtils;
 import io.swagger.annotations.ApiModel;
@@ -29,16 +29,20 @@ public class GalaxyNftBuyReqDto extends GalaxyBaseReqDto implements Serializable
     @NotBlank(message = "用户ID不能为空！")
     @Size(min = 1, max = 30, message = "用户ID限制2-30位且不能包含特殊字符")
     private String userId;
+
     /**
      * skuId
      */
     @ApiModelProperty(position = 1, required = true, value = "系列唯一id标识，不超过20个字符")
+    @NotBlank(message = "skuId不能为空！")
     @Size(min = 2, max = 20, message = "skuId限制2-20位且不能包含特殊字符")
     private String skuId;
+
     /**
      * 作者名，中文+英文(数字或符号为非法输入) 不超过30个字符
      */
     @ApiModelProperty(position = 1, required = true, value = "作者名，中文+英文(数字或符号为非法输入) 不超过20个字符")
+    @NotBlank(message = "author不能为空！")
     @Size(max = 20, message = "中文+英文(数字或符号为非法输入) 不超过20个字符")
     private String author;
 
@@ -46,26 +50,33 @@ public class GalaxyNftBuyReqDto extends GalaxyBaseReqDto implements Serializable
      * nft名字(sku名称)，中英文数字均可，不超过256个字符
      */
     @ApiModelProperty(position = 1, required = true, value = "nft名字(sku名称)，中英文数字均可，不超过100个字符")
+    @NotBlank(message = "nft名字不能为空！")
     @Size(max = 100, message = "nft名字不能超过100个字符")
     private String name;
     /**
      * nftUrl，不超过1024个字符
      */
     @ApiModelProperty(position = 1, required = true, value = "nftUrl，不超过500个字符")
+    @NotBlank(message = "url不能为空！")
     @Size(max = 500, message = "nftUrl，不超过500个字符")
     private String url;
+
     /**
      * 预览图url，不超过1024个字符。(至信链浏览器展示预览图尺寸为290*290，请上传比例为1:1的图片)
      */
     @ApiModelProperty(position = 1, required = true, value = "预览图url，不超过500个字符")
+    @NotBlank(message = "显示url不能为空！")
     @Size(max = 500, message = "预览图url，不超过500个字符")
     private String displayUrl;
+
     /**
      * nft简介，500个字符以内
      */
     @ApiModelProperty(position = 1, required = true, value = "nft简介，300个字符以内")
+    @NotBlank(message = "描述不能为空！")
     @Size(max = 300, message = "nft简介，300个字符以内")
     private String desc;
+
     /**
      * 标签，【文创】，游戏，动漫，30个字符以内
      * 非必填
@@ -73,10 +84,12 @@ public class GalaxyNftBuyReqDto extends GalaxyBaseReqDto implements Serializable
     @ApiModelProperty(position = 1, required = false, value = "标签，文创，游戏，动漫，30个字符以内")
     @Size(max = 20, message = "标签，文创，游戏，动漫，20个字符以内")
     private String flag;
+
     /**
      * 可售状态下有意义，表示售卖多少积分
      */
     @ApiModelProperty(position = 1, required = true, value = "sku价格，金额必须是数字格式，例：211.23 后续不可修改")
+    @NotBlank(message = "购买价格不能为空！")
     @Digits(integer = 10,fraction = 2,message = "金额必须是数字格式")
     private String sellCount;
 

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/GalaxyNftBuyRespDto.java → liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/param/GalaxyNftBuyRespDto.java

-package com.liquidnet.service.galaxy.dto;
+package com.liquidnet.service.galaxy.dto.param;
 
 import com.liquidnet.commons.lang.util.JsonUtils;
 import io.swagger.annotations.ApiModel;

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/GalaxyNftUploadReqDto.java → liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/param/GalaxyNftUploadReqDto.java

-package com.liquidnet.service.galaxy.dto;
+package com.liquidnet.service.galaxy.dto.param;
 
 import com.liquidnet.commons.lang.util.JsonUtils;
 import io.swagger.annotations.ApiModel;

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/GalaxyNftUploadRespDto.java → liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/param/GalaxyNftUploadRespDto.java

-package com.liquidnet.service.galaxy.dto;
+package com.liquidnet.service.galaxy.dto.param;
 
 import com.liquidnet.commons.lang.util.JsonUtils;
 import io.swagger.annotations.ApiModel;

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/GalaxyUserRegisterReqDto.java → liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/param/GalaxyUserRegisterReqDto.java

-package com.liquidnet.service.galaxy.dto;
+package com.liquidnet.service.galaxy.dto.param;
 
 import com.liquidnet.commons.lang.util.JsonUtils;
 import io.swagger.annotations.ApiModel;

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/GalaxyUserRegisterRespDto.java → liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/param/GalaxyUserRegisterRespDto.java

-package com.liquidnet.service.galaxy.dto;
+package com.liquidnet.service.galaxy.dto.param;
 
 import com.liquidnet.commons.lang.util.JsonUtils;
 import io.swagger.annotations.ApiModel;

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/service/IGalaxyArtworkService.java

 package com.liquidnet.service.galaxy.service;
 
 import com.liquidnet.service.base.ResponseDto;
-import com.liquidnet.service.galaxy.dto.GalaxyArtSeriesClaimReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyArtSeriesClaimRespDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftUploadReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftUploadRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyArtSeriesClaimReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyArtSeriesClaimRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftUploadReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftUploadRespDto;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/service/IGalaxyPublishService.java

@@ -2,8 +2,8 @@ package com.liquidnet.service.galaxy.service;
 
 
 import com.liquidnet.service.base.ResponseDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftBuyReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftBuyRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftBuyReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftBuyRespDto;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/service/IGalaxyUserService.java

@@ -2,8 +2,8 @@ package com.liquidnet.service.galaxy.service;
 
 
 import com.liquidnet.service.base.ResponseDto;
-import com.liquidnet.service.galaxy.dto.GalaxyUserRegisterReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyUserRegisterRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyUserRegisterReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyUserRegisterRespDto;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/config/RedisGalaxyConfig.java

+package com.liquidnet.common.cache.redis.config;//package com.liquidnet.common.cache.redis.config;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.List;
+
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: RedisConfig
+ * @Package com.liquidnet.common.cache.redis.config
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/8/10 16:28
+ */
+@Slf4j
+@Configuration
+public class RedisGalaxyConfig extends AbstractRedisConfig{
+
+    @Value("${spring.redis.galaxy.host:null}")
+    private String host;
+    @Value("${spring.redis.galaxy.port:-1}")
+    private int port;
+    @Value("${spring.redis.galaxy.password:null}")
+    private String password;
+    @Value("${spring.redis.galaxy.lettuce.pool.max-active:-1}")
+    private int maxActive;
+    @Value("${spring.redis.galaxy.lettuce.pool.max-idle:-1}")
+    private int maxIdle;
+    @Value("${spring.redis.galaxy.lettuce.pool.min-idle:-1}")
+    private int minIdle;
+    @Value("${spring.redis.galaxy.lettuce.pool.max-wait:-1}")
+    private int maxWait;
+
+    @Value("${spring.redis.galaxy.dbs:${spring.redis.galaxy.database:-1}}")
+    private List<Integer> dbs;
+
+    String getHost(){
+        return this.host;
+    }
+
+    int getPort(){
+        return this.port;
+    }
+    String getPassword(){
+        return this.password;
+    }
+    int getMaxActive(){
+        return this.maxActive;
+    }
+    int getMaxIdle(){
+        return this.maxIdle;
+    }
+    int getMinIdle(){
+        return this.minIdle;
+    }
+    int getMaxWait(){
+        return this.maxWait;
+    }
+    List<Integer> getDbs(){
+        return this.dbs;
+    }
+}
\ No newline at end of file

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisDataSourceUtil.java

@@ -32,6 +32,9 @@ public class RedisDataSourceUtil {
     @Autowired
     private RedisCandyUtil redisCandyUtil;
 
+    @Autowired
+    private RedisGalaxyUtil redisGalaxyUtil;
+
     public AbstractRedisUtil getRedisKylinUtil(){
         return this.redisKylinUtil;
     }
@@ -59,4 +62,7 @@ public class RedisDataSourceUtil {
     public AbstractRedisUtil getRedisGoblinUtil(){
         return this.redisGoblinUtil;
     }
+    public AbstractRedisUtil getRedisGalaxyUtil(){
+        return this.redisGalaxyUtil;
+    }
 }

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisGalaxyUtil.java

+package com.liquidnet.common.cache.redis.util;
+
+import com.liquidnet.common.cache.redis.config.AbstractRedisConfig;
+import com.liquidnet.common.cache.redis.config.RedisGalaxyConfig;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author AnJiabin <jiabin.an@lightnet.io>
+ * @version V1.0
+ * @Description: Redis工具类
+ * @class: RedisUtil
+ * @Package com.liquidnet.stellar.utils
+ * @Copyright: LightNet @ Copyright (c) 2020
+ * @date 2022/3/15 13:11
+ */
+@Slf4j
+@Component("redisGalaxyUtil")
+public final class RedisGalaxyUtil extends AbstractRedisUtil{
+    @Autowired
+    private RedisGalaxyConfig redisConfig;
+
+    @Override
+    public int getDbs() {
+        log.info("RedisGalaxyUtil.totalDbs===",redisConfig.totalDbs);
+        return redisConfig.totalDbs;
+    }
+
+    @Override
+    AbstractRedisConfig getRedisConfig() {
+        return this.redisConfig;
+    }
+}

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/docu/mongo_db_ddl-dev.sql

+use dev_ln_scene;
+#创建集合
+db.createCollection("GalaxyUserInfoBo");
+db.createCollection("GalaxySeriesInfoBo");
+
+
+#创建索引
+db.GalaxyUserInfoBo.createIndex({userId:"hashed"});
+db.GalaxySeriesInfoBo.createIndex({skuId:"hashed"});
+
+#创建分片
+sh.enableSharding("dev_ln_scene");
+sh.shardCollection("dev_ln_scene.GalaxyUserInfoBo",{"userId":"hashed"});
+sh.shardCollection("dev_ln_scene.GalaxySeriesInfoBo",{"skuId":"hashed"});
\ No newline at end of file

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/controller/GalaxyArtworkController.java

@@ -3,10 +3,10 @@ package com.liquidnet.service.galaxy.controller;
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.galaxy.aop.annotation.ControllerLog;
-import com.liquidnet.service.galaxy.dto.GalaxyArtSeriesClaimReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyArtSeriesClaimRespDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftUploadReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftUploadRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyArtSeriesClaimReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyArtSeriesClaimRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftUploadReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftUploadRespDto;
 import com.liquidnet.service.galaxy.service.IGalaxyArtworkService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/controller/GalaxyPublishController.java

@@ -3,8 +3,8 @@ package com.liquidnet.service.galaxy.controller;
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.galaxy.aop.annotation.ControllerLog;
-import com.liquidnet.service.galaxy.dto.GalaxyNftBuyReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftBuyRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftBuyReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftBuyRespDto;
 import com.liquidnet.service.galaxy.service.IGalaxyPublishService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/controller/GalaxyUserController.java

@@ -3,8 +3,8 @@ package com.liquidnet.service.galaxy.controller;
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.galaxy.aop.annotation.ControllerLog;
-import com.liquidnet.service.galaxy.dto.GalaxyUserRegisterReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyUserRegisterRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyUserRegisterReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyUserRegisterRespDto;
 import com.liquidnet.service.galaxy.service.IGalaxyUserService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/IGalaxyRouterStrategy.java

 package com.liquidnet.service.galaxy.router.strategy;
 
 import com.liquidnet.service.base.ResponseDto;
-import com.liquidnet.service.galaxy.dto.*;
+import com.liquidnet.service.galaxy.dto.param.*;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/impl/AbstractGalaxyRouterStrategyImpl.java

 package com.liquidnet.service.galaxy.router.strategy.impl;
 
 import com.liquidnet.service.base.ResponseDto;
-import com.liquidnet.service.galaxy.dto.*;
+import com.liquidnet.service.galaxy.dto.param.*;
 import com.liquidnet.service.galaxy.router.strategy.IGalaxyRouterStrategy;
 import lombok.extern.slf4j.Slf4j;
 

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/impl/GalaxyRouterStrategyEthImpl.java

@@ -2,7 +2,7 @@ package com.liquidnet.service.galaxy.router.strategy.impl;
 
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.galaxy.constant.GalaxyConstant;
-import com.liquidnet.service.galaxy.dto.*;
+import com.liquidnet.service.galaxy.dto.param.*;
 import com.liquidnet.service.galaxy.router.strategy.annotation.StrategyGalaxyRouterHandler;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/impl/GalaxyRouterStrategyZxlImpl.java

@@ -2,7 +2,7 @@ package com.liquidnet.service.galaxy.router.strategy.impl;
 
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.galaxy.constant.GalaxyConstant;
-import com.liquidnet.service.galaxy.dto.*;
+import com.liquidnet.service.galaxy.dto.param.*;
 import com.liquidnet.service.galaxy.router.strategy.annotation.StrategyGalaxyRouterHandler;
 import com.liquidnet.service.galaxy.router.zxin.biz.ZxinArtworkBiz;
 import com.liquidnet.service.galaxy.router.zxin.biz.ZxinPublishBiz;

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/biz/ZxinArtworkBiz.java

@@ -14,10 +14,10 @@ import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.commons.lang.util.StringUtil;
 import com.liquidnet.service.base.ResponseDto;
-import com.liquidnet.service.galaxy.dto.GalaxyArtSeriesClaimReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyArtSeriesClaimRespDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftUploadReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftUploadRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyArtSeriesClaimReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyArtSeriesClaimRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftUploadReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftUploadRespDto;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/biz/ZxinPublishBiz.java

@@ -9,8 +9,8 @@ import com.liquidnet.common.third.zxlnft.util.ZxlnftSdkUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.commons.lang.util.StringUtil;
 import com.liquidnet.service.base.ResponseDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftBuyReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftBuyRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftBuyReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftBuyRespDto;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/biz/ZxinUserBiz.java

@@ -16,8 +16,8 @@ import com.liquidnet.commons.lang.util.BASE64Util;
 import com.liquidnet.commons.lang.util.StringUtil;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.galaxy.constant.GalaxyConstant;
-import com.liquidnet.service.galaxy.dto.GalaxyUserRegisterReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyUserRegisterRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyUserRegisterReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyUserRegisterRespDto;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/service/impl/GalaxyArtworkServiceImpl.java

 package com.liquidnet.service.galaxy.service.impl;
 
 import com.liquidnet.service.base.ResponseDto;
-import com.liquidnet.service.galaxy.dto.GalaxyArtSeriesClaimReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyArtSeriesClaimRespDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftUploadReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftUploadRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyArtSeriesClaimReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyArtSeriesClaimRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftUploadReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftUploadRespDto;
 import com.liquidnet.service.galaxy.router.strategy.GalaxyRouterStrategyContext;
 import com.liquidnet.service.galaxy.service.IGalaxyArtworkService;
 import lombok.extern.slf4j.Slf4j;

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/service/impl/GalaxyPublishServiceImpl.java

 package com.liquidnet.service.galaxy.service.impl;
 
 import com.liquidnet.service.base.ResponseDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftBuyReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyNftBuyRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftBuyReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyNftBuyRespDto;
 import com.liquidnet.service.galaxy.router.strategy.GalaxyRouterStrategyContext;
 import com.liquidnet.service.galaxy.service.IGalaxyPublishService;
 import lombok.extern.slf4j.Slf4j;

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/service/impl/GalaxyUserServiceImpl.java

 package com.liquidnet.service.galaxy.service.impl;
 
 import com.liquidnet.service.base.ResponseDto;
-import com.liquidnet.service.galaxy.dto.GalaxyUserRegisterReqDto;
-import com.liquidnet.service.galaxy.dto.GalaxyUserRegisterRespDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyUserRegisterReqDto;
+import com.liquidnet.service.galaxy.dto.param.GalaxyUserRegisterRespDto;
 import com.liquidnet.service.galaxy.router.strategy.GalaxyRouterStrategyContext;
 import com.liquidnet.service.galaxy.service.IGalaxyUserService;
 import lombok.extern.slf4j.Slf4j;

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/utils/DataUtils.java

+package com.liquidnet.service.galaxy.utils;
+
+import com.liquidnet.common.cache.redis.util.RedisGalaxyUtil;
+import com.liquidnet.service.galaxy.constant.GalaxyConstant;
+import com.liquidnet.service.galaxy.dto.bo.GalaxySeriesInfoBo;
+import com.liquidnet.service.galaxy.dto.bo.GalaxyUserInfoBo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.stereotype.Component;
+
+@Component
+public class DataUtils {
+    @Autowired
+    private RedisGalaxyUtil redisUtil;
+
+    @Autowired
+    private MongoTemplate mongoTemplate;
+
+    private long keyExpireTime = 3600*24*30;
+
+    public void setGalaxyUserInfo(String routeType,String userId, GalaxyUserInfoBo userInfoBo) {
+        redisUtil.set(GalaxyConstant.REDIS_KET_GALAXY_USER.concat(routeType).concat(":") + userId,userInfoBo,keyExpireTime);
+    }
+
+    public GalaxyUserInfoBo getGalaxyUserInfo(String routeType,String userId) {
+        Object obj = redisUtil.get(GalaxyConstant.REDIS_KET_GALAXY_USER.concat(routeType).concat(":") + userId);
+        if(obj!=null){
+            return (GalaxyUserInfoBo) obj;
+        }else {
+            GalaxyUserInfoBo userInfoBo = mongoTemplate.findOne(Query.query(Criteria.where("userId").is(userId)), GalaxyUserInfoBo.class, GalaxyUserInfoBo.class.getSimpleName());
+            if (userInfoBo == null) {
+                return null;
+            }
+            redisUtil.set(GalaxyConstant.REDIS_KET_GALAXY_USER.concat(routeType).concat(":") + userId, userInfoBo);
+            return userInfoBo;
+        }
+    }
+
+    public void setSeriesInfoBo(String routeType,String userId, GalaxyUserInfoBo userInfoBo) {
+        redisUtil.set(GalaxyConstant.REDIS_KET_GALAXY_USER.concat(routeType).concat(":") + userId,userInfoBo,keyExpireTime);
+    }
+
+    public GalaxySeriesInfoBo getSeriesInfoBo(String routeType, String skuId) {
+        Object obj = redisUtil.get(GalaxyConstant.REDIS_KET_GALAXY_ART_SERIES.concat(routeType).concat(":") + skuId);
+        if(obj!=null){
+            return (GalaxySeriesInfoBo) obj;
+        }else {
+            GalaxySeriesInfoBo seriesInfoBo = mongoTemplate.findOne(Query.query(Criteria.where("skuId").is(skuId)), GalaxySeriesInfoBo.class, GalaxySeriesInfoBo.class.getSimpleName());
+            if (seriesInfoBo == null) {
+                return null;
+            }
+            redisUtil.set(GalaxyConstant.REDIS_KET_GALAXY_ART_SERIES.concat(routeType).concat(":") + skuId, seriesInfoBo);
+            return seriesInfoBo;
+        }
+    }
+
+//    public void updateOrderStatus(String code, DragonOrdersDto dragonOrdersDto) {
+//        redisUtil.set(GalaxyConstant.REDIS_KET_PAY_CODE + code, dragonOrdersDto,keyExpireTime);
+//    }
+//
+//    public void setRefundNotifyUrl(String code, String notifyUrl) {
+//        redisUtil.set(GalaxyConstant.REFUND_REDIS_KET + code, notifyUrl,keyExpireTime);
+//    }
+}

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/utils/ObjectUtil.java

+package com.liquidnet.service.galaxy.utils;
+
+import com.alibaba.fastjson.JSONObject;
+import org.springframework.stereotype.Component;
+import org.springframework.util.LinkedMultiValueMap;
+
+import java.util.HashMap;
+import java.util.LinkedList;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: ObjectUtil
+ * @Package com.liquidnet.service.dragon.utils
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/3/15 16:00
+ */
+@Component
+public class ObjectUtil {
+    private static final LinkedList<Object[]> linkedListObj = new LinkedList<Object[]>();
+    private static final LinkedList<String> linkedListStr = new LinkedList<String>();
+    private static final HashMap<String, String> hashMapStringAndString = new HashMap<>();
+    private static final HashMap<String, Object> hashMapStringAndObj = new HashMap<>();
+    private static final JSONObject jsonObjectObj = new JSONObject();
+    private static final LinkedMultiValueMap<String, String> linkedMultiValueMapStringAndString = new LinkedMultiValueMap<String, String>();
+
+    public static LinkedList<Object[]> cloneLinkedListObj() {
+        return (LinkedList<Object[]>) linkedListObj.clone();
+    }
+
+    public static LinkedList<String> cloneLinkedListStr() {
+        return (LinkedList<String>) linkedListStr.clone();
+    }
+
+    public static HashMap<String, String> cloneHashMapStringAndString() {
+        return (HashMap<String, String>) hashMapStringAndString.clone();
+    }
+
+    public static HashMap<String, Object> cloneHashMapStringAndObj() {
+        return (HashMap<String, Object>) hashMapStringAndObj.clone();
+    }
+
+    public static JSONObject cloneJsonObjectObj() {
+        return (JSONObject) jsonObjectObj.clone();
+    }
+
+    public static LinkedMultiValueMap<String, String> cloneLinkedMultiValueMapStringAndString() {
+        return linkedMultiValueMapStringAndString.clone();
+    }
+}