diff --git a/server/gamepay_backend/gamemgr.go b/server/gamepay_backend/gamemgr.go
index 24ccd2c..d8cd377 100644
--- a/server/gamepay_backend/gamemgr.go
+++ b/server/gamepay_backend/gamemgr.go
@@ -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