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

1

Browse Source
This commit is contained in:
aozhiwei 2020-12-14 13:07:33 +08:00
parent a63b4d883a
commit f912f92885
1 changed files with 21 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
server/gamepay_backend/gamemgr.go
View File

@ -79,11 +79,12 @@ func (this *GameMgr) getMysqlCluster(index int) *MtwMysqlConf {
}
func (this *GameMgr) FetchEventOneDB(conf *MtwMysqlConf, conn *q5.Mysql) bool {
lastIdx := 0
var lastIdx int64 = 0
for true {
rows, err := conn.Query("SELECT idx, sender_id, event_name, param1, param2, createtime " +
"FROM `event` " +
"WHERE idx > ? AND status = 0 AND event_name = 'vip_level_up' " +
rows, err := conn.Query("SELECT idx, account_id, orderid, roleid, server_id, " +
" channel, poly_sdk_channel, unified_channel, try_count, price " +
"FROM `orderinfo` " +
"WHERE idx > ? AND sp_pay_result = 1 AND status = 0 " +
"LIMIT 0, 1000;",
lastIdx)
if err != nil {
@ -96,6 +97,22 @@ func (this *GameMgr) FetchEventOneDB(conf *MtwMysqlConf, conn *q5.Mysql) bool {
defer rows.Close()
hasData := false
for rows.Next() {
var idx int64
var accountId string
var orderId string
var roleId string
var serverId int32
var channel int32
var polySdkChannel int32
var unifiedChannel int32
var tryCount int32
var price int32
hasData = true
rows.Scan(&idx, &accountId, &orderId, &roleId, &serverId,
&channel, &polySdkChannel, &unifiedChannel, &tryCount, &price)
if idx > lastIdx {
lastIdx = idx
}
}
if !hasData {
break