diff --git a/server/backtask/task/spec_transfer721/gold_bullion.go b/server/backtask/task/spec_transfer721/gold_bullion.go index 3abfa940..7e383f19 100644 --- a/server/backtask/task/spec_transfer721/gold_bullion.go +++ b/server/backtask/task/spec_transfer721/gold_bullion.go @@ -17,3 +17,8 @@ func (this *goldBullion) onUnlock(dbIdx int64, netId int32, contractAddress stri from string, to string) bool { return true } + +func newGoldBullion() *goldBullion { + p := new(goldBullion) + return p +} diff --git a/server/backtask/task/spec_transfer721/hero.go b/server/backtask/task/spec_transfer721/hero.go index 324c29c3..b99b3b8e 100644 --- a/server/backtask/task/spec_transfer721/hero.go +++ b/server/backtask/task/spec_transfer721/hero.go @@ -17,3 +17,8 @@ func (this *hero) onUnlock(dbIdx int64, netId int32, contractAddress string, tok from string, to string) bool { return true } + +func newHero() *hero { + p := new(hero) + return p +} diff --git a/server/backtask/task/spec_transfer721/spec_transfer721.go b/server/backtask/task/spec_transfer721/spec_transfer721.go index 83a42165..d6669bd5 100644 --- a/server/backtask/task/spec_transfer721/spec_transfer721.go +++ b/server/backtask/task/spec_transfer721/spec_transfer721.go @@ -5,8 +5,8 @@ import ( "f5" "time" "fmt" - //"mt" - //"jccommon" + "mt" + "jccommon" "main/constant" ) @@ -16,8 +16,8 @@ type SpecTransfer721 struct { func (this* SpecTransfer721) Init() { this.handleHash = new(q5.ConcurrentMap[string, specTransfer721Handle]) - //this.handleHash.Store(jccommon.CONTRACT_NAME_CFHero, this.procHero) - //this.handleHash.Store(jccommon.CONTRACT_NAME_GoldBrick, this.procGoldBullion) + this.handleHash.Store(jccommon.CONTRACT_NAME_CFHero, newHero()) + this.handleHash.Store(jccommon.CONTRACT_NAME_GoldBrick, newGoldBullion()) go this.process() } @@ -46,7 +46,6 @@ SELECT * FROM t_721nft_spec_transfer WHERE idx > %d AND status = 0 AND createtim return time.Second * 60 * 1 }, func (ds *f5.DataSet) bool { - /* idx := q5.ToInt64(ds.GetByName("idx")) netId := q5.ToInt32(ds.GetByName("net_id")) contractAddress := ds.GetByName("contract_address") @@ -56,9 +55,11 @@ SELECT * FROM t_721nft_spec_transfer WHERE idx > %d AND status = 0 AND createtim contractMeta := mt.Table.Contract.GetByNetIdAddress(netId, contractAddress) if contractMeta != nil { if p, ok := this.handleHash.Load(contractMeta.GetName()); ok { - return (*p)(idx, netId, contractAddress, tokenId, fromAddress, toAddress) + if q5.IsWeb3ZeroAddress(fromAddress) { + (*p).onMint(idx, netId, contractAddress, tokenId, fromAddress, toAddress) + } } - }*/ + } return true }) }