From e93bcc02b1087c12fda93d71a974536f768e9f58 Mon Sep 17 00:00:00 2001
From: hahwu <31872165+hahwu@users.noreply.github.com>
Date: Mon, 13 Jan 2025 10:58:04 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96kafka=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/server/game/RegisterNetworkFunc.go | 17 ++++++++++++-----
 1 file changed, 12 insertions(+), 5 deletions(-)

diff --git a/src/server/game/RegisterNetworkFunc.go b/src/server/game/RegisterNetworkFunc.go
index a4cc17b9..04125a61 100644
--- a/src/server/game/RegisterNetworkFunc.go
+++ b/src/server/game/RegisterNetworkFunc.go
@@ -6,6 +6,7 @@ import (
 	"math"
 	"server/GoUtil"
 	"server/MergeConst"
+	"server/conf"
 	cardCfg "server/conf/card"
 	limitedTimeEventCfg "server/conf/limitedTimeEvent"
 	mergeDataCfg "server/conf/mergeData"
@@ -2194,11 +2195,17 @@ func ReqShippingOrder(args []interface{}) error {
 		db.UpdatePlayerChargeData(OrderData)
 	}
 	player.PlayMod.save()
-	player.Kafka("order", map[string]interface{}{
-		"order_sn":     OrderSn,
-		"pay_order_sn": OrderData.PayChannelOrderId,
-		"status":       OrderData.PayStatus,
-	})
+	orderDataMap := map[string]interface{}{
+		"AppId":             conf.Server.AppID,
+		"ServerId":          conf.Server.ServerID,
+		"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{
 		Code: msg.RES_CODE_SUCCESS,
 	})