From b10ec40add9c9f1c417c8d5f31c6d898003688cc Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Thu, 4 Jul 2024 03:12:21 +0800 Subject: [PATCH] 1 --- .../task/spec_transfer721/spec_transfer721.go | 2 +- server/backtask/task/sysmail.go | 3 +++ server/backtask/task/taskmgr.go | 15 ++------------- 3 files changed, 6 insertions(+), 14 deletions(-) diff --git a/server/backtask/task/spec_transfer721/spec_transfer721.go b/server/backtask/task/spec_transfer721/spec_transfer721.go index 2511ea2c..579eb51c 100644 --- a/server/backtask/task/spec_transfer721/spec_transfer721.go +++ b/server/backtask/task/spec_transfer721/spec_transfer721.go @@ -17,7 +17,7 @@ type SpecTransfer721 struct { func (this* SpecTransfer721) Init() { this.handleHash = new(q5.ConcurrentMap[string, specTransfer721Handle]) this.handleHash.Store(jccommon.CONTRACT_NAME_CFHero, newHero()) - this.handleHash.Store(jccommon.CONTRACT_NAME_GoldBrick, newGoldBullion()) + //this.handleHash.Store(jccommon.CONTRACT_NAME_GoldBrick, newGoldBullion()) go this.process() } diff --git a/server/backtask/task/sysmail.go b/server/backtask/task/sysmail.go index efb07633..af8307d4 100644 --- a/server/backtask/task/sysmail.go +++ b/server/backtask/task/sysmail.go @@ -102,6 +102,7 @@ func (this *sysMail) writeMail(ds *f5.DataSet) bool { userRegStartTime := q5.ToInt32(ds.GetByName("user_reg_start_time")) userRegEndTime := q5.ToInt32(ds.GetByName("user_reg_end_time")) var ok = false + nowTime := f5.GetApp().GetRealSeconds() f5.GetGoStyleDb().Upsert( constant.MAIL_DB, "t_mail", @@ -124,6 +125,8 @@ func (this *sysMail) writeMail(ds *f5.DataSet) bool { {"tag1", q5.ToString(tag1)}, {"tag2", q5.ToString(tag2)}, {"expiretime", q5.ToString(expireTime)}, + {"createtime", q5.ToString(nowTime)}, + {"modifytime", q5.ToString(nowTime)}, }, func (err error, lastInsertId int64, rowsAffected int64) { ok = err == nil diff --git a/server/backtask/task/taskmgr.go b/server/backtask/task/taskmgr.go index 747057c4..c1d5cecf 100644 --- a/server/backtask/task/taskmgr.go +++ b/server/backtask/task/taskmgr.go @@ -2,7 +2,6 @@ package task import ( //"fmt" - "f5" "sync" "main/task/spec_transfer721" ) @@ -22,15 +21,10 @@ type taskMgr struct { } func (this *taskMgr) Init() { - if f5.IsOnlineEnv() { - this.nftLock.init() - this.refreshMeta.init() - return - } //t.HourlyTaskMgr.Init() //t.DailyTaskMgr.Init() this.webHook.init() - this.goldBullionReturn.init() + //this.goldBullionReturn.init() this.SpecTransfer721.Init() this.repairNft.init() this.sysMail.init() @@ -40,18 +34,13 @@ func (this *taskMgr) Init() { } func (this *taskMgr) UnInit() { - if f5.IsOnlineEnv() { - this.nftLock.unInit() - this.refreshMeta.unInit() - return - } this.nftLock.unInit() this.refreshMeta.unInit() this.repairOrder.unInit() this.sysMail.unInit() this.repairNft.unInit() this.SpecTransfer721.UnInit() - this.goldBullionReturn.unInit() + //this.goldBullionReturn.unInit() this.webHook.unInit() }