优化kafka日志

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,
 	})