server/game2006go
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

log

Browse Source
This commit is contained in:
yangduo 2024-08-20 17:32:50 +08:00
parent 13586dd0d5
commit 8ad879c3ee
1 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
server/marketserver/service/contribution.go
View File

@ -19,9 +19,10 @@ type accountContribution struct {
}
type contribution struct {
historyContribution float64
globalContribution float64
gcTime int64
historyContribution float64
rechargeContribution float64
globalContribution float64
gcTime int64
accountContributionlist q5.ConcurrentMap[string, *accountContribution]
emailContributionlist q5.ConcurrentMap[string, *accountContribution]
@ -204,8 +205,7 @@ func (this *contribution) GetAddressContribution(accountAddress string, onlyrech
}
if ds.Next() {
tmp, _ := q5.ToFloat64Ex(ds.GetByIndex(0))
(*accinfo).rechargeContri = tmp
(*accinfo).rechargeContri, _ = q5.ToFloat64Ex(ds.GetByIndex(0))
}
})
}
@ -290,11 +290,11 @@ func (this *contribution) GetGlobalContribution(instant bool) (float64, error) {
}
if ds.Next() {
tmp, _ := q5.ToFloat64Ex(ds.GetByIndex(0))
this.globalContribution += tmp
this.rechargeContribution, _ = q5.ToFloat64Ex(ds.GetByIndex(0))
}
})
this.globalContribution += this.rechargeContribution
this.globalContribution += this.historyContribution
this.gcTime = nowseconds
}
@ -322,7 +322,15 @@ func (this *contribution) checkContributionList() {
}
this.accountContributionlist.Delete(account)
}
f5.GetSysLog().Info("delete contribution address cache count:%d", len(deletelist))
}
time.Sleep((time.Second * 1800))
f5.GetSysLog().Info("<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<")
f5.GetSysLog().Info("contribution cache total:%.2f, recharge:%.2f, history:%.2f",
this.globalContribution,
this.rechargeContribution,
this.historyContribution)
f5.GetSysLog().Info(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>")
time.Sleep((time.Second * 60))
}
}