1
This commit is contained in:
parent
0bce451b13
commit
b10ec40add
@ -17,7 +17,7 @@ type SpecTransfer721 struct {
|
|||||||
func (this* SpecTransfer721) Init() {
|
func (this* SpecTransfer721) Init() {
|
||||||
this.handleHash = new(q5.ConcurrentMap[string, specTransfer721Handle])
|
this.handleHash = new(q5.ConcurrentMap[string, specTransfer721Handle])
|
||||||
this.handleHash.Store(jccommon.CONTRACT_NAME_CFHero, newHero())
|
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()
|
go this.process()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -102,6 +102,7 @@ func (this *sysMail) writeMail(ds *f5.DataSet) bool {
|
|||||||
userRegStartTime := q5.ToInt32(ds.GetByName("user_reg_start_time"))
|
userRegStartTime := q5.ToInt32(ds.GetByName("user_reg_start_time"))
|
||||||
userRegEndTime := q5.ToInt32(ds.GetByName("user_reg_end_time"))
|
userRegEndTime := q5.ToInt32(ds.GetByName("user_reg_end_time"))
|
||||||
var ok = false
|
var ok = false
|
||||||
|
nowTime := f5.GetApp().GetRealSeconds()
|
||||||
f5.GetGoStyleDb().Upsert(
|
f5.GetGoStyleDb().Upsert(
|
||||||
constant.MAIL_DB,
|
constant.MAIL_DB,
|
||||||
"t_mail",
|
"t_mail",
|
||||||
@ -124,6 +125,8 @@ func (this *sysMail) writeMail(ds *f5.DataSet) bool {
|
|||||||
{"tag1", q5.ToString(tag1)},
|
{"tag1", q5.ToString(tag1)},
|
||||||
{"tag2", q5.ToString(tag2)},
|
{"tag2", q5.ToString(tag2)},
|
||||||
{"expiretime", q5.ToString(expireTime)},
|
{"expiretime", q5.ToString(expireTime)},
|
||||||
|
{"createtime", q5.ToString(nowTime)},
|
||||||
|
{"modifytime", q5.ToString(nowTime)},
|
||||||
},
|
},
|
||||||
func (err error, lastInsertId int64, rowsAffected int64) {
|
func (err error, lastInsertId int64, rowsAffected int64) {
|
||||||
ok = err == nil
|
ok = err == nil
|
||||||
|
@ -2,7 +2,6 @@ package task
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
//"fmt"
|
//"fmt"
|
||||||
"f5"
|
|
||||||
"sync"
|
"sync"
|
||||||
"main/task/spec_transfer721"
|
"main/task/spec_transfer721"
|
||||||
)
|
)
|
||||||
@ -22,15 +21,10 @@ type taskMgr struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (this *taskMgr) Init() {
|
func (this *taskMgr) Init() {
|
||||||
if f5.IsOnlineEnv() {
|
|
||||||
this.nftLock.init()
|
|
||||||
this.refreshMeta.init()
|
|
||||||
return
|
|
||||||
}
|
|
||||||
//t.HourlyTaskMgr.Init()
|
//t.HourlyTaskMgr.Init()
|
||||||
//t.DailyTaskMgr.Init()
|
//t.DailyTaskMgr.Init()
|
||||||
this.webHook.init()
|
this.webHook.init()
|
||||||
this.goldBullionReturn.init()
|
//this.goldBullionReturn.init()
|
||||||
this.SpecTransfer721.Init()
|
this.SpecTransfer721.Init()
|
||||||
this.repairNft.init()
|
this.repairNft.init()
|
||||||
this.sysMail.init()
|
this.sysMail.init()
|
||||||
@ -40,18 +34,13 @@ func (this *taskMgr) Init() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (this *taskMgr) UnInit() {
|
func (this *taskMgr) UnInit() {
|
||||||
if f5.IsOnlineEnv() {
|
|
||||||
this.nftLock.unInit()
|
|
||||||
this.refreshMeta.unInit()
|
|
||||||
return
|
|
||||||
}
|
|
||||||
this.nftLock.unInit()
|
this.nftLock.unInit()
|
||||||
this.refreshMeta.unInit()
|
this.refreshMeta.unInit()
|
||||||
this.repairOrder.unInit()
|
this.repairOrder.unInit()
|
||||||
this.sysMail.unInit()
|
this.sysMail.unInit()
|
||||||
this.repairNft.unInit()
|
this.repairNft.unInit()
|
||||||
this.SpecTransfer721.UnInit()
|
this.SpecTransfer721.UnInit()
|
||||||
this.goldBullionReturn.unInit()
|
//this.goldBullionReturn.unInit()
|
||||||
this.webHook.unInit()
|
this.webHook.unInit()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user