优化kafka日志
This commit is contained in:
parent
4b0fe58de6
commit
e4658a828c
@ -3,6 +3,7 @@ package game
|
||||
import (
|
||||
"fmt"
|
||||
"server/GoUtil"
|
||||
"server/conf"
|
||||
cardCfg "server/conf/card"
|
||||
chargeCfg "server/conf/charge"
|
||||
playroomCfg "server/conf/playroom"
|
||||
@ -76,6 +77,9 @@ func ReqGmCommand(args []interface{}) error {
|
||||
ChargeId, _ := strconv.Atoi(arg[1])
|
||||
player.Kafka("pay", map[string]interface{}{
|
||||
"ProductId": ChargeId,
|
||||
"AppId": conf.Server.AppID,
|
||||
"Uid": player.M_DwUin,
|
||||
"ServerId": conf.Server.ServerID,
|
||||
"Price": chargeCfg.GetMoneyCharge(ChargeId),
|
||||
"PayType": 3,
|
||||
"OrderId": "gm",
|
||||
|
||||
Loading…
Reference in New Issue
Block a user