diff --git a/server/backtask/common/types.go b/server/backtask/common/types.go index 8a6ebbff..b403eba2 100644 --- a/server/backtask/common/types.go +++ b/server/backtask/common/types.go @@ -6,10 +6,3 @@ type App interface { type TaskMgr interface { } - -type SpecTransfer721Handle interface { - OnMint(dbIdx int64, netId int32, contractAddress string, tokenId string, - from string, to string) bool - OnLock() bool - OnUnlock() bool -} diff --git a/server/backtask/task/spec_transfer721/spec_transfer721.go b/server/backtask/task/spec_transfer721/spec_transfer721.go index 43e606be..83a42165 100644 --- a/server/backtask/task/spec_transfer721/spec_transfer721.go +++ b/server/backtask/task/spec_transfer721/spec_transfer721.go @@ -1,4 +1,4 @@ -package task +package spec_transfer721 import ( "q5" @@ -8,24 +8,23 @@ import ( //"mt" //"jccommon" "main/constant" - "main/common" ) -type specTransfer721 struct { - handleHash *q5.ConcurrentMap[string, common.SpecTransfer721Handle] +type SpecTransfer721 struct { + handleHash *q5.ConcurrentMap[string, specTransfer721Handle] } -func (this* specTransfer721) init() { - this.handleHash = new(q5.ConcurrentMap[string, common.SpecTransfer721Handle]) +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) go this.process() } -func (this* specTransfer721) unInit() { +func (this* SpecTransfer721) UnInit() { } -func (this* specTransfer721) process() { +func (this* SpecTransfer721) process() { f5.GetGoStyleDb().LoopLoad( constant.BCEVENT_DB, func (lastIdx int64) string { diff --git a/server/backtask/task/spec_transfer721/types.go b/server/backtask/task/spec_transfer721/types.go new file mode 100644 index 00000000..535f1c14 --- /dev/null +++ b/server/backtask/task/spec_transfer721/types.go @@ -0,0 +1,8 @@ +package spec_transfer721 + +type specTransfer721Handle interface { + onMint(dbIdx int64, netId int32, contractAddress string, tokenId string, + from string, to string) bool + onLock() bool + onUnlock() bool +} diff --git a/server/backtask/task/taskmgr.go b/server/backtask/task/taskmgr.go index 8455ef8e..0a77c9f3 100644 --- a/server/backtask/task/taskmgr.go +++ b/server/backtask/task/taskmgr.go @@ -2,6 +2,7 @@ package task import ( //"fmt" + "main/task/spec_transfer721" ) type taskMgr struct { @@ -9,7 +10,7 @@ type taskMgr struct { //DailyTaskMgr webHook goldBullionReturn - specTransfer721 + spec_transfer721.SpecTransfer721 repairNft } @@ -18,13 +19,13 @@ func (this *taskMgr) Init() { //t.DailyTaskMgr.Init() this.webHook.init() this.goldBullionReturn.init() - this.specTransfer721.init() + this.SpecTransfer721.Init() this.repairNft.init() } func (this *taskMgr) UnInit() { this.repairNft.unInit() - this.specTransfer721.unInit() + this.SpecTransfer721.UnInit() this.goldBullionReturn.unInit() this.webHook.unInit() }