优化kafka日志

This commit is contained in:
hahwu 2025-01-13 11:11:26 +08:00
parent e93bcc02b1
commit 356358f011

View File

@ -3,6 +3,7 @@ package game
import ( import (
"fmt" "fmt"
"server/GoUtil" "server/GoUtil"
"server/conf"
cardCfg "server/conf/card" cardCfg "server/conf/card"
chargeCfg "server/conf/charge" chargeCfg "server/conf/charge"
playroomCfg "server/conf/playroom" playroomCfg "server/conf/playroom"
@ -76,6 +77,9 @@ func ReqGmCommand(args []interface{}) error {
ChargeId, _ := strconv.Atoi(arg[1]) ChargeId, _ := strconv.Atoi(arg[1])
player.Kafka("pay", map[string]interface{}{ player.Kafka("pay", map[string]interface{}{
"ProductId": ChargeId, "ProductId": ChargeId,
"AppId": conf.Server.AppID,
"Uid": player.M_DwUin,
"ServerId": conf.Server.ServerID,
"Price": chargeCfg.GetMoneyCharge(ChargeId), "Price": chargeCfg.GetMoneyCharge(ChargeId),
"PayType": 3, "PayType": 3,
"OrderId": "gm", "OrderId": "gm",