实现百度链转让-消费

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-common/src/main/java/com/liquidnet/service/galaxy/utils/AbstractDataUtils.java

@@ -567,17 +567,17 @@ public abstract class AbstractDataUtils {
     public void updateTransferNftInfoBo(String routerType,String nftId, GalaxyTransferNftInfoBo transferNftInfoBo) {
         this.getRedisUtil().set(GalaxyConstant.REDIS_KEY_GALAXY_TRANSFER_NFTID.concat(routerType).concat(":") + nftId,transferNftInfoBo);
 
-//        try{
-//            this.getQueueUtil().sendMySqlRedis(
-//                    SqlMapping.get("galaxy_nft_order_info.updateNftBuyInfo"),
-//                    new Object[]{nftOrderBo.getNftBuyTaskId(),nftOrderBo.getNftBuyChainTimestamp(),nftOrderBo.getNftBuyStatus()
-//                            ,nftOrderBo.getNftBuyTradeHash(),nftOrderBo.getNftBuyPayTaskId()
-//                            ,LocalDateTime.now(),nftOrderBo.getNftOrderPayId()}
-//                    , MQConst.GalaxyQueue.SQL_NFT_ORDER_INFO.getKey()
-//            );
-//        }catch(Exception e){
-//            log.error(e.getMessage(),e);
-//            log.error("#setNftTradeInfo error ==> MESSAGE:{}",e.getMessage());
-//        }
+        try{
+            this.getQueueUtil().sendMySqlRedis(
+                    SqlMapping.get("galaxy_nft_transfer_info.insert"),
+                    new Object[]{transferNftInfoBo.getUserId(),transferNftInfoBo.getNftId(),transferNftInfoBo.getAddress(),transferNftInfoBo.getReceiveUserId(),transferNftInfoBo.getReceiveAddress(),
+                            transferNftInfoBo.getOwnerUserId(),transferNftInfoBo.getOwnerAddress(),transferNftInfoBo.getTransferHash(),transferNftInfoBo.getSeriesId(),transferNftInfoBo.getRouterType(),
+                            transferNftInfoBo.getTransferStatus(),transferNftInfoBo.getErrorCode(),transferNftInfoBo.getErrorMsg(),transferNftInfoBo.getCreatedAt(),transferNftInfoBo.getUpdatedAt()}
+                    , 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-goblin/liquidnet-service-goblin-common/src/main/resources/sqlmap-galaxy.properties

@@ -10,6 +10,8 @@ galaxy_nft_order_info.insert=insert into galaxy_nft_order_info (nft_order_pay_id
 galaxy_nft_trade_info.insert=insert into galaxy_nft_trade_info (user_id, nft_id, nft_name, series_name, series_id, series_code, trade_hash,chain_timestamp, from_address, to_address, trade_price, trade_type, router_type,created_at, updated_at)values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
 # ------------------------数字藏品发行购买失败记录----------------------------
 galaxy_nft_order_fail_log.insert=insert into galaxy_nft_order_fail_log (nft_order_pay_id, user_id, nft_id, nft_name, series_name, series_id,series_code, taskId, fail_reason_desc, fail_reason_desc_second, deal_with_status, trade_type,router_type, created_at, updated_at)values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
+# ------------------------数字藏品转让记录----------------------------
+galaxy_nft_transfer_info.insert=insert into galaxy_nft_transfer_info (user_id, nft_id, address, receive_user_id, receive_address, owner_user_id,owner_address, transfer_hash, series_id, router_type, transfer_status, error_code,error_msg, created_at, updated_at) values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
 
 # ------------------------更新用户注册信息----------------------------
 galaxy_user_info.update=update galaxy_user_info set user_name = ?,id_card_type = ?,id_card = ?,mobile = ?,block_chain_address = ?,user_identification = ?,updated_at =? where router_type = ? and user_id = ?
@@ -31,3 +33,5 @@ galaxy_nft_order_fail_log.updateDealWithStatus=update galaxy_nft_order_fail_log
 galaxy_series_nft_info.updateSeriesNftPublishStatus=update galaxy_series_nft_info t set t.publish_status = ?,t.publish_trade_hash = ?,t.updated_at =? where t.sku_id = ?
 # ------------------------同步用户数字账户信息到adam---------------------------
 adam_user_busi_acct.add=INSERT INTO adam_user_busi_acct (`uid`, busi, uuid, `work`, ppwd, `state`, created_at) VALUES (?,?,?,?,?,?,?) 
+# ------------------------更新nft转让信息----------------------------
+galaxy_nft_transfer_info.updateNftTransferInfo=update galaxy_nft_transfer_info t set t.owner_user_id = ?,t.owner_address = ?,t.transfer_hash =?,t.transfer_status =?,t.error_code =?,t.error_msg =? ,t.updated_at =? where t.nft_id = ?

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/docu/db_galaxy_20220715.sql

@@ -13,3 +13,28 @@ alter table galaxy_nft_order_fail_log modify series_name varchar(30) not null co
 alter table galaxy_nft_order_info modify series_name varchar(30) not null comment '系列的唯一名称(前缀+skuid)';
 
 alter table galaxy_nft_trade_info modify series_name varchar(30) not null comment '系列的唯一名称';
+
+-- nft转让新增表galaxy_nft_transfer_info
+drop TABLE if exists `galaxy_nft_transfer_info`;
+create table galaxy_nft_transfer_info
+(
+    mid bigint unsigned NOT NULL AUTO_INCREMENT,
+    user_id varchar(200)  NOT NULL COMMENT '用户ID',
+    nft_id varchar(200)   COMMENT 'nftId',
+    address varchar(200)   COMMENT '转出方地址',
+    receive_user_id varchar(200)  NOT NULL COMMENT '接收者用户id',
+    receive_address varchar(200)  NOT NULL COMMENT '接收者地址',
+    owner_user_id varchar(200)  NOT NULL COMMENT '拥有者用户id',
+    owner_address varchar(200)  NOT NULL COMMENT '拥有者地址',
+    transfer_hash varchar(200)  NOT NULL COMMENT '转让hash',
+    series_id varchar(200) COMMENT '系列的唯一Id',
+    router_type varchar(20)  NOT NULL COMMENT '路由类型(zxinchain、eth、antchain)',
+    transfer_status varchar(30)  NOT NULL COMMENT '转让状态(-1初始化 0转让中 1转让成功 2转让失败 )',
+    error_code varchar(200) NOT NULL COMMENT '错误code',
+    error_msg varchar(200)   COMMENT '错误信息',
+    created_at timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    updated_at timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '更新时间',
+    PRIMARY KEY (`mid`)
+) ENGINE = InnoDB comment '数字藏品转让信息';
+create index gntri_idx_user_id on galaxy_nft_transfer_info (user_id);
+create index gntri_idx_nft_id on galaxy_nft_transfer_info (nft_id);