1

server/backtask/common/types.go

@@ -5,4 +5,6 @@ type App interface {
 }
 
 type TaskMgr interface {
+	LockOpenGodBullion()
+	UnLockOpenGodBullion()
 }

server/backtask/service/mail.go

@@ -1,5 +1,6 @@
 package service
 
-func SendSysMail(uniKey string, to string, subject string, content string, expireTime int32, tag1 int32, tag2 int32) bool {
+func SendSysMail(uniKey string, to string, subject string, content string, expireTime int32,
+	tag1 int32, tag2 int32) bool {
 	return true
 }

server/backtask/service/spec_transfer.go

@@ -1,5 +1,30 @@
 package service
 
+import (
+	"q5"
+	"f5"
+	"main/constant"
+)
+
 func UpdateSpecTransferStatus(dbIdx int64, status int32) bool {
 	return true
 }
+
+func OpenGoldBullion(accountId string, netId int32, tokenId string, goldNum int32) bool {
+	result := false
+	f5.GetGoStyleDb().OrmSelectOne(
+		constant.GAME_DB,
+		"t_gold_bullion",
+		[][]string {
+			{"net_id", q5.ToString(netId)},
+			{"token_id", tokenId},
+		},
+		func (err error, ds *f5.DataSet) {
+			if err != nil {
+				return
+			}
+			if ds.Next() {
+			}
+		})
+	return result
+}

server/backtask/task/taskmgr.go

@@ -2,6 +2,7 @@ package task
 
 import (
 	//"fmt"
+	"sync"
 	"main/task/spec_transfer721"
 )
 
@@ -12,6 +13,7 @@ type taskMgr struct {
 	goldBullionReturn
 	spec_transfer721.SpecTransfer721
 	repairNft
+	openGoldLock sync.Mutex
 }
 
 func (this *taskMgr) Init() {
@@ -29,3 +31,11 @@ func (this *taskMgr) UnInit() {
 	this.goldBullionReturn.unInit()
 	this.webHook.unInit()
 }
+
+func (this *taskMgr) LockOpenGodBullion() {
+	this.openGoldLock.Lock()
+}
+
+func (this *taskMgr) UnLockOpenGodBullion() {
+	this.openGoldLock.Unlock()
+}