pet_home/pet_home_server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化kafka日志

Browse Source
This commit is contained in:
hahwu 2025-01-13 10:58:04 +08:00
parent fa00657ead
commit 00fe38dadc
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/server/game/RegisterNetworkFunc.go
View File

@ -6,6 +6,7 @@ import (
"math" "math"
"server/GoUtil" "server/GoUtil"
"server/MergeConst" "server/MergeConst"
"server/conf"
cardCfg "server/conf/card" cardCfg "server/conf/card"
limitedTimeEventCfg "server/conf/limitedTimeEvent" limitedTimeEventCfg "server/conf/limitedTimeEvent"
mergeDataCfg "server/conf/mergeData" mergeDataCfg "server/conf/mergeData"
@ -2196,11 +2197,17 @@ func ReqShippingOrder(args []interface{}) error {
db.UpdatePlayerChargeData(OrderData) db.UpdatePlayerChargeData(OrderData)
} }
player.PlayMod.save() player.PlayMod.save()
player.Kafka("order", map[string]interface{}{ orderDataMap := map[string]interface{}{
"order_sn": OrderSn, "AppId": conf.Server.AppID,
"pay_order_sn": PayOrderSn, "ServerId": conf.Server.ServerID,
"status": Status, "OrderId": OrderData.OrderId,
}) "PayChannelOrderId": OrderData.PayChannelOrderId,
"ProductId": OrderData.ProductId,
"CreateTime": OrderData.CreateTime,
"PayTime": OrderData.PayTime,
"PayType": OrderData.PayType,
}
player.Kafka("pay", orderDataMap)
player.PushClientRes(&msg.ResShippingOrder{ player.PushClientRes(&msg.ResShippingOrder{
Code: msg.RES_CODE_SUCCESS, Code: msg.RES_CODE_SUCCESS,
}) })