提交galaxy消费相关

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

@@ -4,6 +4,7 @@ import com.liquidnet.commons.lang.util.JsonUtils;
 import lombok.Data;
 
 import java.io.Serializable;
+import java.time.LocalDateTime;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
@@ -68,6 +69,18 @@ public class GalaxyNftOrderBo implements Serializable,Cloneable {
      * @return
      */
     private String nftBuyPayTaskId;
+    /**
+     * 路由类型
+     */
+    private String routerType;
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updatedAt;
 
     @Override
     public String toString(){

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

@@ -5,6 +5,7 @@ import lombok.Data;
 
 import java.io.Serializable;
 import java.math.BigDecimal;
+import java.time.LocalDateTime;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
@@ -111,7 +112,18 @@ public class GalaxySeriesInfoBo implements Serializable,Cloneable {
      * 系列声明中nftHash
      */
     private String nftHash;
-
+    /**
+     * 路由类型
+     */
+    private String routerType;
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updatedAt;
 
     @Override
     public String toString(){

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

@@ -30,7 +30,6 @@ public class GalaxyUserInfoBo implements Serializable,Cloneable{
     private String userPriKey;
     private String routerType;
     private String blockChainAddress;
-
     public String getUserPubKey() {
         String pubKey = null;
         try {
@@ -51,6 +50,8 @@ public class GalaxyUserInfoBo implements Serializable,Cloneable{
         return priKey;
     }
 
+
+
     @Override
     public String toString(){
         return JsonUtils.toJson(this);

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/vo/mongo/GalaxyNftOrderVo.java

@@ -4,6 +4,7 @@ import com.liquidnet.commons.lang.util.JsonUtils;
 import lombok.Data;
 
 import java.io.Serializable;
+import java.time.LocalDateTime;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
@@ -77,12 +78,11 @@ public class GalaxyNftOrderVo implements Serializable,Cloneable {
     /**
      * 创建时间
      */
-    private String createdAt;
-
+    private LocalDateTime createdAt;
     /**
      * 更新时间
      */
-    private String updatedAt;
+    private LocalDateTime updatedAt;
 
     @Override
     public String toString(){

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/vo/mongo/GalaxyNftTradeVo.java

+package com.liquidnet.service.galaxy.dto.vo.mongo;
+
+import com.liquidnet.commons.lang.util.JsonUtils;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: GalaxyNftOrderBo
+ * @Package com.liquidnet.service.galaxy.dto.bo
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/3/17 11:16
+ */
+@Data
+public class GalaxyNftTradeVo implements Serializable,Cloneable {
+    /**
+     * 应用系统购买系列唯一ID
+     */
+    private String nftId;
+    /**
+     * 系列的唯一Id
+     */
+    private String seriesId;
+    /**
+     * nftId
+     */
+    private String tradeHash;
+    /**
+     * nft价格
+     */
+    private String chainTimestamp;
+
+    /**
+     * 转出方地址
+     */
+    private String fromAddress;
+
+    /**
+     * 转入方地址
+     */
+    private String toAddress;
+
+    /**
+     * nft发行任务ID
+     */
+    private Long tradePrice;
+
+    /**
+     * nft购买任务id
+     * @return
+     */
+    private String tradeType;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updatedAt;
+
+    @Override
+    public String toString(){
+        return JsonUtils.toJson(this);
+    }
+
+    private static final GalaxyNftTradeVo obj = new GalaxyNftTradeVo();
+
+    public static GalaxyNftTradeVo getNew() {
+        try {
+            return (GalaxyNftTradeVo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new GalaxyNftTradeVo();
+        }
+    }
+}

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/vo/mongo/GalaxySeriesInfoVo.java

@@ -5,6 +5,7 @@ import lombok.Data;
 
 import java.io.Serializable;
 import java.math.BigDecimal;
+import java.time.LocalDateTime;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
@@ -116,11 +117,11 @@ public class GalaxySeriesInfoVo implements Serializable,Cloneable {
     /**
      * 创建时间
      */
-    private String createdAt;
+    private LocalDateTime createdAt;
     /**
      * 更新时间
      */
-    private String updatedAt;
+    private LocalDateTime updatedAt;
 
     @Override
     public String toString(){

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/vo/mongo/GalaxyUserInfoVo.java

@@ -4,6 +4,7 @@ import com.liquidnet.commons.lang.util.JsonUtils;
 import lombok.Data;
 
 import java.io.Serializable;
+import java.time.LocalDateTime;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
@@ -64,11 +65,11 @@ public class GalaxyUserInfoVo implements Serializable,Cloneable{
     /**
      * 创建时间
      */
-    private String createdAt;
+    private LocalDateTime createdAt;
     /**
      * 更新时间
      */
-    private String updatedAt;
+    private LocalDateTime updatedAt;
 
     @Override
     public String toString(){

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/docu/mysql_db_ddl.sql

@@ -8,7 +8,7 @@ create table galaxy_user_info
     id_card_type varchar(3)  NOT NULL COMMENT '证件类型( 1-身份证 2-护照 3-港澳通行证 4-台湾通行证 5-外国人永居身份证 6-港澳台居民居住证 7-其它)',
     id_card varchar(50)  NOT NULL COMMENT '证件号码',
     mnemonic varchar(200)  COMMENT '助记词',
-    index varchar(3)  NOT NULL DEFAULT '0' COMMENT '助记词索引',
+    mnemonic_index varchar(3)  NOT NULL DEFAULT '0' COMMENT '助记词索引',
     user_identification varchar(200) COMMENT '用户链上唯一ID',
     user_pub_key varchar(200) COMMENT '用户公钥',
     user_pri_key varchar(200) COMMENT '用户私钥',

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.RedisUtil;
+import com.liquidnet.commons.lang.util.BASE64Util;
 import com.liquidnet.commons.lang.util.BeanUtil;
 import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
+import com.liquidnet.service.base.SqlMapping;
+import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.galaxy.constant.GalaxyConstant;
+import com.liquidnet.service.galaxy.constant.GalaxyEnum;
 import com.liquidnet.service.galaxy.dto.bo.GalaxyNftOrderBo;
 import com.liquidnet.service.galaxy.dto.bo.GalaxySeriesInfoBo;
 import com.liquidnet.service.galaxy.dto.bo.GalaxyUserInfoBo;
 import com.liquidnet.service.galaxy.dto.vo.mongo.GalaxyNftOrderVo;
+import com.liquidnet.service.galaxy.dto.vo.mongo.GalaxyNftTradeVo;
 import com.liquidnet.service.galaxy.dto.vo.mongo.GalaxySeriesInfoVo;
+import com.liquidnet.service.galaxy.dto.vo.mongo.GalaxyUserInfoVo;
 import com.mongodb.client.result.UpdateResult;
 import lombok.extern.slf4j.Slf4j;
 import org.bson.Document;
@@ -20,7 +26,9 @@ import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.stereotype.Component;
 
+import java.io.UnsupportedEncodingException;
 import java.time.LocalDateTime;
+import java.util.Date;
 
 @Slf4j
 @Component
@@ -31,11 +39,47 @@ public class DataUtils {
     @Autowired
     private MongoTemplate mongoTemplate;
 
+    @Autowired
+    private QueueUtil queueUtil;
+
     private long keyExpireTime = 3600*24*30;
 
     public void setGalaxyUserInfo(String routeType,String userId, GalaxyUserInfoBo userInfoBo) {
+        String userType = GalaxyEnum.RegisterTypeEnum.COMPANY.getCode();
         redisUtil.set(GalaxyConstant.REDIS_KET_GALAXY_USER.concat(routeType).concat(":") + userId,userInfoBo,keyExpireTime);
-        mongoTemplate.save(userInfoBo,GalaxyUserInfoBo.class.getSimpleName());
+        //入库mongo
+        GalaxyUserInfoVo userInfoVo = GalaxyUserInfoVo.getNew();
+        BeanUtil.copy(userInfoBo,userInfoVo);
+        //保持原始base64编码存储
+        try {
+            userInfoVo.setUserPubKey(BASE64Util.encoded(userInfoBo.getUserPubKey()));
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
+        try {
+            userInfoVo.setUserPriKey(BASE64Util.encoded(userInfoBo.getUserPriKey()));
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
+
+        userInfoVo.setCreatedAt(LocalDateTime.now());
+        mongoTemplate.save(userInfoVo,GalaxyUserInfoVo.class.getSimpleName());
+//        insert into galaxy_user_info (mid, user_id, user_name, user_type, mobile, id_card_type
+//                , id_card, mnemonic, index,user_identification, user_pub_key
+//                , user_pri_key, block_chain_address, router_type,created_at, updated_at)
+        try{
+            queueUtil.sendMySqlRedis(
+                    SqlMapping.get("galaxy_user_info.insert"),
+                    new Object[]{userId,userInfoBo.getUserName(),userType,userInfoBo.getMobile(),userInfoBo.getIdCardType()
+                                 ,userInfoBo.getIdCard(),userInfoBo.getMnemonic(),userInfoBo.getIndex(),userInfoBo.getUserIdentification(),userInfoBo.getUserPubKey()
+                                 ,userInfoBo.getUserPriKey(),userInfoBo.getBlockChainAddress(),userInfoBo.getRouterType(),new Date(),null
+                    }
+                    , MQConst.GalaxyQueue.SQL_USER_INFO.getKey()
+            );
+        }catch(Exception e){
+            log.error(e.getMessage(),e);
+            log.error("#setGalaxyUserInfo error ==> MESSAGE:{}",e.getMessage());
+        }
     }
 
     public GalaxyUserInfoBo getGalaxyUserInfo(String routeType,String userId) {
@@ -54,7 +98,33 @@ public class DataUtils {
 
     public void setSeriesInfoBo(String routeType,String skuId, GalaxySeriesInfoBo seriesInfoBo) {
         redisUtil.set(GalaxyConstant.REDIS_KET_GALAXY_SERIES.concat(routeType).concat(":") + skuId,seriesInfoBo,keyExpireTime);
-        mongoTemplate.save(seriesInfoBo,GalaxySeriesInfoBo.class.getSimpleName());
+
+        //mongo入库
+        GalaxySeriesInfoVo seriesInfoVo = GalaxySeriesInfoVo.getNew();
+        BeanUtil.copy(seriesInfoBo,seriesInfoVo);
+        seriesInfoVo.setCreatedAt(LocalDateTime.now());
+        mongoTemplate.save(seriesInfoVo,GalaxySeriesInfoVo.class.getSimpleName());
+
+//        insert into galaxy_series_info (mid, sku_id, series_name, series_id, total_count, crt_count
+//                , original_nft_url,original_display_url, series_claim_task_id, series_claim_status, author
+//                , nft_name,nft_url, display_url, nft_desc, nft_flag
+//                , sell_count, cover_url, series_desc, nft_hash,router_type
+//                , created_at, updated_at)
+        try{
+            queueUtil.sendMySqlRedis(
+                    SqlMapping.get("galaxy_series_info.insert"),
+                    new Object[]{skuId,seriesInfoBo.getSeriesName(),seriesInfoBo.getSeriesId(),seriesInfoBo.getTotalCount(),seriesInfoBo.getCrtCount()
+                            ,seriesInfoBo.getOriginalNftUrl(),seriesInfoBo.getOriginalDisplayUrl(),seriesInfoBo.getSeriesClaimTaskId(),seriesInfoBo.getSeriesClaimStatus(),seriesInfoBo.getAuthor()
+                            ,seriesInfoBo.getNftName(),seriesInfoBo.getNftUrl(),seriesInfoBo.getDisplayUrl(),seriesInfoBo.getNftDesc(),seriesInfoBo.getNftFlag()
+                            ,seriesInfoBo.getSellCount(),seriesInfoBo.getCoverUrl(),seriesInfoBo.getSeriesDesc(),seriesInfoBo.getNftHash(),seriesInfoBo.getRouterType()
+                            ,LocalDateTime.now()
+                    }
+                    , MQConst.GalaxyQueue.SQL_SERIES_INFO.getKey()
+            );
+        }catch(Exception e){
+            log.error(e.getMessage(),e);
+            log.error("#setSeriesInfoBo error ==> MESSAGE:{}",e.getMessage());
+        }
     }
 
     public GalaxySeriesInfoBo getSeriesInfoBo(String routeType, String skuId) {
@@ -92,6 +162,23 @@ public class DataUtils {
         GalaxyNftOrderVo nftOrderVo = GalaxyNftOrderVo.getNew();
         BeanUtil.copy(nftOrderBo,nftOrderVo);
         mongoTemplate.save(nftOrderVo,GalaxyNftOrderVo.class.getSimpleName());
+
+//        insert into galaxy_nft_order_info (mid, nft_order_pay_id, user_id, sku_id, series_name, series_id
+//                , nft_id, nft_price,from_address, to_address, nft_publish_task_id, nft_buy_task_id
+//                , nft_buy_pay_task_id,router_type, created_at, updated_at)
+        try{
+            queueUtil.sendMySqlRedis(
+                    SqlMapping.get("galaxy_nft_order_info.insert"),
+                    new Object[]{nftOrderPayId,nftOrderBo.getUserId(),nftOrderBo.getSkuId(),nftOrderBo.getSeriesName(),nftOrderBo.getSeriesId()
+                            ,nftOrderBo.getNftId(),nftOrderBo.getNftPrice(),nftOrderBo.getFromAddress(),nftOrderBo.getToAddress(),nftOrderBo.getNftPublishTaskId()
+                            ,nftOrderBo.getNftBuyTaskId(),nftOrderBo.getNftBuyPayTaskId(),nftOrderBo.getRouterType(),LocalDateTime.now(),null
+                    }
+                    , MQConst.GalaxyQueue.SQL_NFT_ORDER_INFO.getKey()
+            );
+        }catch(Exception e){
+            log.error(e.getMessage(),e);
+            log.error("#setNftOrderBo error ==> MESSAGE:{}",e.getMessage());
+        }
     }
 
     public GalaxyNftOrderBo getNftOrderBo(String routeType, String nftOrderPayId) {
@@ -120,6 +207,17 @@ public class DataUtils {
         update.set("updatedAt",nowTimeStr);
         UpdateResult result = mongoTemplate.updateFirst(query,update, GalaxyNftOrderBo.class,GalaxyNftOrderBo.class.getSimpleName());
         log.info("updateNftOrderInfo result:{}",result.toString());
+
+        try{
+            queueUtil.sendMySqlRedis(
+                    SqlMapping.get("galaxy_nft_order_info.updateNftId"),
+                    new Object[]{nftOrderBo.getNftId(),LocalDateTime.now(),nftOrderBo.getNftOrderPayId()}
+                    , MQConst.GalaxyQueue.SQL_NFT_TRADE_INFO.getKey()
+            );
+        }catch(Exception e){
+            log.error(e.getMessage(),e);
+            log.error("#setNftTradeInfo error ==> MESSAGE:{}",e.getMessage());
+        }
     }
 
     public void updateNftOrderBuyTaskId(String routeType,String nftOrderPayId,GalaxyNftOrderBo nftOrderBo) {
@@ -132,6 +230,39 @@ public class DataUtils {
         update.set("updatedAt",nowTimeStr);
         UpdateResult result = mongoTemplate.updateFirst(query,update, GalaxyNftOrderBo.class,GalaxyNftOrderBo.class.getSimpleName());
         log.info("updateNftOrderInfo result:{}",result.toString());
+
+        try{
+            queueUtil.sendMySqlRedis(
+                    SqlMapping.get("galaxy_nft_order_info.updateNftBuyTaskId"),
+                    new Object[]{nftOrderBo.getNftBuyTaskId(),LocalDateTime.now(),nftOrderBo.getNftOrderPayId()}
+                    , MQConst.GalaxyQueue.SQL_NFT_TRADE_INFO.getKey()
+            );
+        }catch(Exception e){
+            log.error(e.getMessage(),e);
+            log.error("#setNftTradeInfo error ==> MESSAGE:{}",e.getMessage());
+        }
+    }
+
+    public void setNftTradeInfo(String routeType, GalaxyNftTradeVo nftTradeVo) {
+        /**
+         * 入库mongo
+         */
+        mongoTemplate.save(nftTradeVo,GalaxyNftTradeVo.class.getSimpleName());
+
+//        insert into galaxy_nft_trade_info (mid, nft_id, series_id, trade_hash, chain_timestamp, from_address
+//        , to_address,trade_price, trade_type, created_at, updated_at)
+        try{
+            queueUtil.sendMySqlRedis(
+                    SqlMapping.get("galaxy_nft_trade_info.insert"),
+                    new Object[]{nftTradeVo.getNftId(),nftTradeVo.getSeriesId(),nftTradeVo.getTradeHash(),nftTradeVo.getChainTimestamp(),nftTradeVo.getFromAddress()
+                            ,nftTradeVo.getToAddress(),nftTradeVo.getTradePrice(),nftTradeVo.getTradeType(),LocalDateTime.now(),null
+                    }
+                    , MQConst.GalaxyQueue.SQL_NFT_TRADE_INFO.getKey()
+            );
+        }catch(Exception e){
+            log.error(e.getMessage(),e);
+            log.error("#setNftTradeInfo error ==> MESSAGE:{}",e.getMessage());
+        }
     }
 
 }

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

+package com.liquidnet.service.galaxy.utils;
+
+import com.liquidnet.service.base.SqlMapping;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.StreamRecords;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.LinkedList;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: QueueUtil
+ * @Package com.liquidnet.service.galaxy.utils
+ * @Copyright: LightNet @ Copyright (c) 2022
+ * @date 2022/3/25 15:35
+ */
+@Component
+public class QueueUtil {
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+    /**
+     * 给 REDIS 队列发送消息 数据库相关
+     *
+     * @param sql  sql语句
+     * @param data 需要操作的数据
+     * @return
+     */
+    public boolean sendMySqlRedis(String sql, Object[] data , String redisKey) {
+        try {
+            LinkedList<String> sqls = ObjectUtil.cloneLinkedListStr();
+            sqls.add(sql);
+            LinkedList<Object[]> sqlsData = ObjectUtil.cloneLinkedListObj();
+            sqlsData.add(data);
+            String sqlData = SqlMapping.gets(sqls, sqlsData);
+
+            HashMap<String, String> map = ObjectUtil.cloneHashMapStringAndString();
+            map.put("message", sqlData);
+            MapRecord<String, String, String> record = StreamRecords.mapBacked(map).withStreamKey(redisKey);
+            stringRedisTemplate.opsForStream().add(record);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+}

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/resources/sqlmap.properties

+# ------------------------用户注册信息----------------------------
+galaxy_user_info.insert=insert into galaxy_user_info (user_id, user_name, user_type, mobile, id_card_type, id_card, mnemonic, mnemonic_index,user_identification, user_pub_key, user_pri_key, block_chain_address, router_type,created_at, updated_at)values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
+# ------------------------数字藏品系列信息----------------------------
+galaxy_series_info.insert=insert into galaxy_series_info (sku_id, series_name, series_id, total_count, crt_count, original_nft_url,original_display_url, series_claim_task_id, series_claim_status, author, nft_name,nft_url, display_url, nft_desc, nft_flag, sell_count, cover_url, series_desc, nft_hash,router_type, created_at, updated_at)values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
+# ------------------------数字藏品订单信息----------------------------
+galaxy_nft_order_info.insert=insert into galaxy_nft_order_info (nft_order_pay_id, user_id, sku_id, series_name, series_id, nft_id, nft_price,from_address, to_address, nft_publish_task_id, nft_buy_task_id, nft_buy_pay_task_id,router_type, created_at, updated_at)values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
+# ------------------------数字藏品交易信息----------------------------
+galaxy_nft_trade_info.insert=insert into galaxy_nft_trade_info (nft_id, series_id, trade_hash, chain_timestamp, from_address, to_address,trade_price, trade_type, created_at, updated_at)values (?,?,?,?,?,?,?,?,?,?)
+
+#更新信息
+galaxy_nft_order_info.updateNftId=update galaxy_nft_order_info t set t.nft_id = ? ,t.updated_at =? where t.nft_order_pay_id = ?
+galaxy_nft_order_info.updateNftBuyTaskId=update galaxy_nft_order_info t set t.nft_buy_task_id = ? ,t.updated_at =? where t.nft_order_pay_id = ?