记得上下班打卡 | git大法好,push需谨慎

Commit 24dbe7cd authored by anjiabin's avatar anjiabin

提交galaxy系列表结构

parent f685c281
...@@ -63,7 +63,12 @@ public class GalaxySeriesInfoBo implements Serializable,Cloneable { ...@@ -63,7 +63,12 @@ public class GalaxySeriesInfoBo implements Serializable,Cloneable {
/** /**
* 系列声明时间 * 系列声明时间
*/ */
private String seriesClaimTime; private String chainTimestamp;
/**
* 系列链上交易hash
*/
private String tradeHash;
/** /**
* 系列声明中nftHash * 系列声明中nftHash
......
...@@ -43,7 +43,7 @@ public class GalaxyArtSeriesClaimResultQueryRespDto implements Serializable,Clo ...@@ -43,7 +43,7 @@ public class GalaxyArtSeriesClaimResultQueryRespDto implements Serializable,Clo
* 链上交易时间戳 * 链上交易时间戳
*/ */
@ApiModelProperty(position = 3, required = true, value = "chainTimestamp") @ApiModelProperty(position = 3, required = true, value = "chainTimestamp")
private Long chainTimestamp; private String chainTimestamp;
/** /**
* 系列声明中nftHash * 系列声明中nftHash
......
...@@ -59,6 +59,16 @@ public class GalaxySeriesInfoVo implements Serializable,Cloneable { ...@@ -59,6 +59,16 @@ public class GalaxySeriesInfoVo implements Serializable,Cloneable {
*/ */
private String seriesDesc; private String seriesDesc;
/**
* 系列声明时间
*/
private String chainTimestamp;
/**
* 系列链上交易hash
*/
private String tradeHash;
/** /**
* 系列声明中nftHash * 系列声明中nftHash
*/ */
......
...@@ -52,6 +52,7 @@ create table galaxy_series_nft_info ...@@ -52,6 +52,7 @@ create table galaxy_series_nft_info
series_id varchar(200) COMMENT '区块链上系列ID', series_id varchar(200) COMMENT '区块链上系列ID',
nft_total_count varchar(50) COMMENT '系列nft发行总量', nft_total_count varchar(50) COMMENT '系列nft发行总量',
nft_crt_count varchar(200) COMMENT '系列nft已发行个数', nft_crt_count varchar(200) COMMENT '系列nft已发行个数',
nft_id_begin varchar(200) COMMENT '系列nft发行开始id',
original_nft_url varchar(1000) COMMENT 'nft素材原始地址', original_nft_url varchar(1000) COMMENT 'nft素材原始地址',
original_display_url varchar(1000) COMMENT 'nft显示素材原始地址', original_display_url varchar(1000) COMMENT 'nft显示素材原始地址',
author varchar(200) COMMENT '作者名', author varchar(200) COMMENT '作者名',
......
...@@ -338,13 +338,16 @@ public class ZxinArtworkBiz { ...@@ -338,13 +338,16 @@ public class ZxinArtworkBiz {
//设置系列声明状态 //设置系列声明状态
seriesInfoBo.setSeriesClaimStatus(GalaxyEnum.SeriesClaimStatusEnum.SUCCESS.getCode()); seriesInfoBo.setSeriesClaimStatus(GalaxyEnum.SeriesClaimStatusEnum.SUCCESS.getCode());
String nowTimeStr = DateUtil.format(new Date(resp.getData().getChainTimestamp().longValue()*1000),DateUtil.Formatter.yyyyMMddHHmmss); String nowTimeStr = DateUtil.format(new Date(resp.getData().getChainTimestamp().longValue()*1000),DateUtil.Formatter.yyyyMMddHHmmss);
seriesInfoBo.setSeriesClaimTime(nowTimeStr); seriesInfoBo.setChainTimestamp(nowTimeStr);
seriesInfoBo.setTradeHash(resp.getData().getTxHash());
seriesInfoBo.setSeriesId(resp.getData().getSeriesId()); seriesInfoBo.setSeriesId(resp.getData().getSeriesId());
dataUtils.updateSeriesClaimStatus(reqDto.getRouterType(),seriesCode,seriesInfoBo); dataUtils.updateSeriesClaimStatus(reqDto.getRouterType(),seriesCode,seriesInfoBo);
//设置成功返回参数 //设置成功返回参数
GalaxyArtSeriesClaimResultQueryRespDto resultQueryRespDto = GalaxyArtSeriesClaimResultQueryRespDto.getNew(); GalaxyArtSeriesClaimResultQueryRespDto resultQueryRespDto = GalaxyArtSeriesClaimResultQueryRespDto.getNew();
BeanUtil.copy(resp.getData(),resultQueryRespDto); resultQueryRespDto.setSeriesId(seriesInfoBo.getSeriesId());
resultQueryRespDto.setChainTimestamp(seriesInfoBo.getChainTimestamp());
resultQueryRespDto.setTxHash(seriesInfoBo.getTradeHash());
resultQueryRespDto.setTaskStatus(Integer.valueOf(GalaxyEnumBiz.getTaskStatusEnum(reqDto.getRouterType(),resp.getData().getTaskStatus().toString()).getCode())); resultQueryRespDto.setTaskStatus(Integer.valueOf(GalaxyEnumBiz.getTaskStatusEnum(reqDto.getRouterType(),resp.getData().getTaskStatus().toString()).getCode()));
//获取sku对应nft信息 //获取sku对应nft信息
......
...@@ -219,7 +219,7 @@ public class DataUtils { ...@@ -219,7 +219,7 @@ public class DataUtils {
try{ try{
queueUtil.sendMySqlRedis( queueUtil.sendMySqlRedis(
SqlMapping.get("galaxy_series_info.updateSeriesIdAndStatus"), SqlMapping.get("galaxy_series_info.updateSeriesIdAndStatus"),
new Object[]{seriesInfoBo.getSeriesId(),seriesInfoBo.getSeriesClaimStatus(),nowTimeStr,seriesInfoBo.getSeriesCode()} new Object[]{seriesInfoBo.getSeriesId(),seriesInfoBo.getChainTimestamp(),seriesInfoBo.getTradeHash(),seriesInfoBo.getSeriesClaimStatus(),nowTimeStr,seriesInfoBo.getSeriesCode()}
, MQConst.GalaxyQueue.SQL_SERIES_INFO.getKey() , MQConst.GalaxyQueue.SQL_SERIES_INFO.getKey()
); );
......
...@@ -10,7 +10,10 @@ galaxy_nft_order_info.insert=insert into galaxy_nft_order_info (nft_order_pay_id ...@@ -10,7 +10,10 @@ 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 (nft_id, series_id, trade_hash, chain_timestamp, from_address, to_address,trade_price, trade_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_series_info.updateSeriesIdAndStatus=update galaxy_series_info t set t.series_id = ?,t.series_claim_status = ? ,t.updated_at =? where t.series_code = ? galaxy_series_info.updateSeriesIdAndStatus=update galaxy_series_info t set t.series_id = ?,t.chain_timestamp = ?,t.trade_hash = ?,t.series_claim_status = ? ,t.updated_at =? where t.series_code = ?
galaxy_series_nft_info.updateSeriesIdAndStatus=update galaxy_series_nft_info t set t.series_id = ? ,t.updated_at =? where t.series_code = ?
galaxy_series_nft_info.updateSeriesIdAndStatus=update galaxy_series_nft_info t set t.series_id = ?,t.updated_at =? where t.series_code = ?
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.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 = ? 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 = ?
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment