RoServer/RO_Server_Trunk-branch_bt/roserver/gmweb/msg/web_paymsg.go

package msg

import (
	"crypto/hmac"
	"crypto/md5"
	"encoding/hex"
	"encoding/json"
	"encoding/xml"
	"fmt"
	"github.com/gin-gonic/gin"
	"net/http"
	"net/url"
	"rocommon/service"
	"rocommon/util"
	"roserver/baseserver/model"
	selfmodel "roserver/gmweb/model"
	"roserver/serverproto"
	"sort"
	"strconv"
	"strings"
)

//https://blog.csdn.net/chunyouhai5703/article/details/100978656?utm_medium=distribute.pc_relevant.none-task-blog-title-1&spm=1001.2101.3001.4242
type QuickPayNotify struct {
	XMLName xml.Name    `xml:"quicksdk_message"`
	Message QuickTBData `xml:"message"`
}
type QuickTBData struct {
	IsTest       bool    `xml:"is_test"`
	Channel      string  `xml:"channel"`
	ChannelUid   string  `xml:"channel_uid"`
	GameOrder    string  `xml:"game_order"`
	PayTime      string  `xml:"pay_time"`
	Amount       float32 `xml:"amount"`
	Status       int32   `xml:"status"`
	ExtrasParams string  `xml:"extras_params"`
}

/*
<?xml version="1.0" encoding="UTF-8" standalone="no">
<quicksdk_message>
<message>
<is_test>0</is_test>
<channel>8888</channel>
<channel_uid>231845</channel_uid>
<game_order>123456789</game_order>
<order_no>12520160612114220441168433</order_no>
<pay_time>2016-06-12 11:42:20</pay_time>
<amount>1.00</amount>
<status>0</status>
<extras_params>{1}_{2}</extras_params>
</message>
</quicksdk_message>
*/
func WebPayQuickNotify(c *gin.Context) {
	//ntData := c.PostForm("nt_data")
	//sign := c.PostForm("sign")
	//md5Sign := c.PostForm("md5Sign")
	//
	//data := ntData + sign + service.GetServiceConfig().SDKConfig.QuickMd5key
	//tmpSign := md5.Sum([]byte(data))
	//md5Str := fmt.Sprintf("%x", tmpSign)
	//util.DebugF("WebPayQuickNotify ntData=%v sign=%v md5sign=%v tmpsign=%v", ntData, sign, md5Sign, md5Str)
	//if md5Str == md5Sign {
	//	util.InfoF("WebPayQuickNotify ok")
	//} else {
	//	util.ErrorF("WebPayQuickNotify sign invalid!!!")
	//	c.JSON(http.StatusOK, "FAILED")
	//	return
	//}
	//
	////decode nt_data
	//tmpNtDataList := strings.Split(ntData, "@")
	//tmpNtData := make([]byte, len(tmpNtDataList))
	//tmpKeyData := []byte(service.GetServiceConfig().SDKConfig.QuickCallbackKey)
	//for idx := 1; idx < len(tmpNtDataList); idx++ {
	//	tmpVal, _ := strconv.Atoi(tmpNtDataList[idx])
	//	tmpNtData[idx] = (byte)(tmpVal - (int)(0xff&tmpKeyData[(idx-1)%len(tmpKeyData)]))
	//}
	////字符串最前面会有一个空格
	//if string(tmpNtData[0]) == "\u0000" {
	//	tmpNtData = append(tmpNtData[:0], tmpNtData[1:]...)
	//}
	//util.InfoF("WebPayQuickNotify ntdata=%v", string(tmpNtData))
	//
	//tmpSt := &QuickPayNotify{}
	//err := xml.Unmarshal(tmpNtData, tmpSt)
	//if err != nil {
	//	util.ErrorF("WebPayQuickNotify xml decode err=%v", err)
	//	c.JSON(http.StatusOK, "FAILED")
	//	return
	//}
	//
	//ntfData := &WebNotifyData{}
	//ntfData.CpOrderId = tmpSt.Message.GameOrder
	//ntfData.SdkOrderId = ""
	//ntfData.PayMethod = ""
	//ntfData.PayCurrency = ""
	//ntfData.PayTime = uint64(util.GetTimeSeconds())
	//ntfData.PayChannel = ""
	//webPayNotify(ntfData, tmpSt.Message.Amount, c)
	//c.JSON(http.StatusOK, "SUCCESS")

	game_order := c.PostForm("game_order") //游戏订单号
	order_no := c.PostForm("order_no")     //SDK订单ID
	amount := c.PostForm("amount")         //充值金额
	PayChannel := c.PostForm("channel")    //充值渠道
	serverId := c.PostForm("server_id")    //充值服ID

	util.DebugF("收到充值订单：GameOrder=%v, SdkOfderId=%v, PauAmount=%v， PayChannel=%v, serverId=%v", game_order, order_no, amount, PayChannel, serverId)

	checkPayAmount, _ := model.Str2Float32(amount)

	ntfData := &WebNotifyData{}
	ntfData.CpOrderId = game_order
	ntfData.SdkOrderId = order_no
	ntfData.PayMethod = ""
	ntfData.PayCurrency = ""
	ntfData.PayTime = uint64(util.GetTimeSeconds())
	ntfData.PayChannel = PayChannel
	retState := webPayNotify(ntfData, checkPayAmount, c)

	//c.JSON(http.StatusOK, `success`)
	c.Data(http.StatusOK, "text/plain; charset=utf-8", []byte(retState))
}

type KVSt struct {
	ParamKey string
	ParamVal string
}

func WebPayNBSDKNotify(c *gin.Context) {
	tmpReq := c.Request
	err := tmpReq.ParseMultipartForm(32 << 20)
	if err != nil {
		return
	}
	formCache := tmpReq.PostForm
	//util.DebugF("formCache2=%v", formCache)

	var kvList []*KVSt
	for k, v := range formCache {
		if k == "sign" {
			continue
		}
		kv := &KVSt{
			ParamKey: k,
			ParamVal: v[0],
		}
		kvList = append(kvList, kv)
	}
	sort.Slice(kvList, func(i, j int) bool {
		return kvList[i].ParamKey < kvList[j].ParamKey
	})
	//util.DebugF("kvlist=%v", kvList)
	verifyStr := ""
	for idx := 0; idx < len(kvList); idx++ {
		key := url.QueryEscape(kvList[idx].ParamKey)
		val := url.QueryEscape(kvList[idx].ParamVal)
		if idx == 0 {
			verifyStr += key + "=" + val
		} else {
			verifyStr += "&" + key + "=" + val
		}
	}

	sign := c.PostForm("sign")
	sdkOrderId := c.PostForm("sdk_order_id") //SDK订单ID
	cpOrderId := c.PostForm("cp_order_id")   //游戏方订单ID，由游戏客户端生成(服务器生成给到客户端)
	serverId := c.PostForm("server_id")      //游戏区服ID
	pfUid := c.PostForm("pf_uid")            //渠道平台的UID
	roleId := c.PostForm("role_id")          //游戏方自己的角色ID
	payAmount := c.PostForm("pay_amount")    //支付金额(int,单位分,CP方需要验证是否与计费点金额一致，不做此判断，后果自负哦！！！)

	gameKey := service.GetServiceConfig().SDKConfig.NbGameKey
	tmpHmac := hmac.New(md5.New, []byte(gameKey))
	tmpHmac.Write([]byte(verifyStr))
	tmpSign := hex.EncodeToString(tmpHmac.Sum([]byte("")))
	util.DebugF("uid=%v verifyStr=%v cpOrderId=%v pfUid=%v sdkOrderId=%v serverId=%v tmpSign=%v sign=%v gamekey=%v", roleId, verifyStr, cpOrderId, pfUid,
		sdkOrderId, serverId, tmpSign, sign, gameKey)
	if tmpSign != sign {
		util.InfoF("uid=%v WebPayNBSDKNotify sign verify failed cpOrderId=%v", roleId, cpOrderId)
		return
	}

	checkPayAmount, _ := model.Str2Num(payAmount)

	ntfData := &WebNotifyData{}
	ntfData.CpOrderId = cpOrderId
	ntfData.SdkOrderId = sdkOrderId
	ntfData.PayMethod = ""
	ntfData.PayCurrency = ""
	ntfData.PayTime = uint64(util.GetTimeSeconds())
	ntfData.PayChannel = ""
	ret := webPayNotify(ntfData, float32(checkPayAmount)/100, c)

	//c.JSON(http.StatusOK, `success`)
	c.Data(http.StatusOK, "text/plain; charset=utf-8", []byte(ret))
}

type UniSDKPayExtraST struct {
	Aid           int    `json:"aid"` //用户唯一标识
	PrivateParam  string `json:"privateparam"`
	PayChannel    string `json:"paychannel"` //支付渠道
	AppChannel    string `json:"appchannel"` //appchannel
	Platform      string `json:"platfrom"`
	UidId         string `json:"uidid"`       //设备id
	GoodsCount    int    `json:"goodscount"`  //商品数量
	PayMoney      string `json:"paymoney"`    //玩家实际支付金额
	FreeMoney     string `json:"freemoney"`   //免费总价，供游戏服写运营日志（如果渠道不提供，该字段为0）
	PayCurrency   string `json:"paycurrency"` //玩家实际支付币种
	Deduct        int    `json:"deduct"`
	DeductPercent string `json:"deductpercent"`
	DeductReason  string `json:"deductreason"` //扣除原因，是黑设备还是黑币种
	JsonData      string `json:"jsondata"`
	InitTime      int    `json:"inittime"` //订单创建时间戳，精确到秒;若订单不通过create_order接口创建（例如web 支付），则此值为0
	PayTime       int    `json:"paytime"`  //订单支付时间戳，精确到秒
	IsTest        int    `json:"istest"`   //订单来源：0，正式环境订单；1，测试环境订单(v3.6.2新增)
	FreeYuanBao   int    `json:"free_yuanbao"`
	PayYuanBao    int    `json:"pay_yuanbao"`
	PayMethod     string `json:"paymethod"`
}
type UniSDKPayST struct {
	GameId    string `json:"gameid"`
	HostId    int    `json:"hostid"`
	RoleId    string `json:"roleid"`
	GoodsId   string `json:"goodsid"`
	UserName  string `json:"username"`  //玩家渠道帐号(玩家帐号被sdk渠道转换之后的字符串)
	SN        string `json:"sn"`        //游戏订单号
	ConsumeSN string `json:"consumesn"` //渠道流水订单号(苹果渠道对应为transaction-id)
	ExtraData UniSDKPayExtraST
}
type UniSDKPayResponseST struct {
	Code int         `json:"code"`
	Msg  string      `json:"msg"`
	Data interface{} `json:"data"`
}

func WebPayUniSDKNotify(c *gin.Context) {
	sign := c.GetHeader("Gas-Ship-Signature")

	payInfo := &UniSDKPayST{}
	bodyData, err := c.GetRawData()
	if err != nil {
		util.ErrorF("WebPayUniSDKNotify body get error=%v", err)
		return
	}
	err = json.Unmarshal(bodyData, payInfo)
	if err != nil {
		util.ErrorF("WebPayUniSDKNotify body Unmarshal error=%v", err)
		return
	}

	secretKey := service.GetServiceConfig().SDKConfig.UniSecretKey
	tmpHmac := hmac.New(md5.New, []byte(secretKey))
	tmpHmac.Write(bodyData)
	tmpSign := hex.EncodeToString(tmpHmac.Sum([]byte("")))
	if tmpSign != sign {
		util.InfoF("uid=%v WebPayUniSDKNotify sign verify failed cpOrderId=%v", payInfo.RoleId, payInfo.SN)
		c.Header("Gas-Ship-Signature", tmpSign)
		responseSt := &UniSDKPayResponseST{
			Code: 403,
			Msg:  "ok",
			Data: nil,
		}
		c.JSON(http.StatusOK, responseSt)
		return
	}

	checkPayAmount, _ := model.Str2Num(payInfo.ExtraData.PayMoney)

	ntfData := &WebNotifyData{}
	ntfData.CpOrderId = payInfo.SN
	ntfData.SdkOrderId = payInfo.ConsumeSN
	ntfData.PayMethod = payInfo.ExtraData.PayMethod
	ntfData.PayCurrency = payInfo.ExtraData.PayCurrency
	ntfData.PayTime = uint64(payInfo.ExtraData.PayTime)
	ntfData.PayChannel = payInfo.ExtraData.PayChannel
	ret := webPayNotify(ntfData, float32(checkPayAmount)/100, c)

	if ret == "FAILED" {
		c.JSON(http.StatusOK, "FAILED")
	}
	c.Header("Gas-Ship-Signature", tmpSign)
	responseSt := &UniSDKPayResponseST{
		Code: 200,
		Msg:  "ok",
		Data: nil,
	}
	c.JSON(http.StatusOK, responseSt)
}

func WebPayNBH5Notify(c *gin.Context) {
	sdkOrderId := c.PostForm("sdk_order_id") //SDK订单ID
	cpOrderId := c.PostForm("cp_order_id")   //游戏方订单ID，由游戏客户端生成(服务器生成给到客户端)
	serverId := c.PostForm("server_id")      //游戏区服ID
	pfUid := c.PostForm("pf_uid")            //渠道平台的UID
	roleId := c.PostForm("role_id")          //游戏方自己的角色ID(uid)
	payAmount := c.PostForm("pay_amount")    //支付金额(int,单位分,CP方需要验证是否与计费点金额一致，不做此判断，后果自负哦！！！)

	util.InfoF("WebPayH5Notify roleId=%v pfUid=%v sdkOrderId=%v serverId=%v", roleId, pfUid, sdkOrderId, serverId)
	if cpOrderId == "" {
		cpOrderId = "WebPayH5Notify"
	}
	gameRoleId, _ := model.Str2NumU64(roleId)
	checkPayAmount, _ := model.Str2Num(payAmount)
	if gameRoleId <= 0 || checkPayAmount <= 0 {
		c.Data(http.StatusOK, "text/plain; charset=utf-8", []byte("FAILED"))
		return
	}

	ntfData := &WebNotifyData{}
	ntfData.GameRoleId = gameRoleId
	ntfData.CpOrderId = cpOrderId
	ntfData.SdkOrderId = sdkOrderId
	ntfData.PayMethod = ""
	ntfData.PayCurrency = ""
	ntfData.PayTime = uint64(util.GetTimeSeconds())
	ntfData.PayChannel = "WebPayH5Notify"
	ret := webPayNotifyH5(ntfData, float32(checkPayAmount)/100, c)

	c.Data(http.StatusOK, "text/plain; charset=utf-8", []byte(ret))
}

type WebNotifyData struct {
	CpOrderId   string
	SdkOrderId  string
	PayMethod   string
	PayCurrency string
	PayTime     uint64
	PayChannel  string
	GameRoleId  uint64
}

func webPayNotify(webNtf *WebNotifyData, payAmount float32, c *gin.Context) string {
	//流程处理gmweb保存订单状态到redis中设置为 成功充值状态
	//发送给gameserver，成功收到后设置订单状态为成功获取充值状态，如果gameserver没有收到
	//每次玩家上线时，重新获取一次订单状态如果是成功充值，但是没有获取成功就获取一次
	// 充值成功获取对应的ntdata数据
	// 1，回复成/失败消息给quick
	// 2，订单状态写入redis（判重处理），并发送给social做获取奖励处理
	msgStr, err := service.GetRedis().HGet(model.PayOrderPrefix, webNtf.CpOrderId).Result()
	if err != nil {
		//util.ErrorF("WebPayQuickNotify order not exist err=%v", err)
		util.ErrorF("WebPayQuickNotify order not exist err=%v, cpOrderId=%v, sdkOrderId=%v", err, webNtf.CpOrderId, webNtf.SdkOrderId)
		//c.JSON(http.StatusOK, "FAILED")

		//return "FAILED"
		return fmt.Sprintf("FAILED,cpOrderId=%v err=%v", webNtf.CpOrderId, err)
	}

	payInfo := &serverproto.PayOrderSaveInfo{}
	err = model.GetDecodeMessage(payInfo, msgStr)
	if err != nil {
		util.ErrorF("WebPayQuickNotify GetDecodeMessage err=%， cpOrderId=%v, sdkOrderId=%v", err, webNtf.CpOrderId, webNtf.SdkOrderId)
		//util.ErrorF("WebPayQuickNotify GetDecodeMessage err=%v", err)
		//c.JSON(http.StatusOK, "FAILED")
		//return "FAILED"
		return fmt.Sprintf("FAILED,cpOrderId=%v err=%v", webNtf.CpOrderId, err)
	}
	if payInfo.OrderState == int32(serverproto.PayOrderState_EPayOrderState_Gen) {
		//实际支付 == 订单的钱,否则为支付失败
		payAmount := int32(payAmount * 1000)
		//服务器订单实际金额：
		orderAmount := int32(payInfo.Amount * 1000)
		if payAmount == orderAmount {
			payInfo.OrderState = int32(serverproto.PayOrderState_EPayOrderState_PayOk)
		} else {
			payInfo.OrderState = int32(serverproto.PayOrderState_EPayOrderState_PayFailed)
			util.ErrorF("uid=%v WebPayQuickNotify failed payAmount:%v order=%v", payInfo.Uid, payAmount, payInfo)
		}
		payInfo.OrderProcessTime = util.GetTimeMilliseconds()
		payInfo.SdkOrderId = webNtf.SdkOrderId //sdk订单id\
		payInfo.PayMethod = webNtf.PayMethod
		payInfo.PayCurrency = webNtf.PayCurrency
		payInfo.PayTime = webNtf.PayTime
		payInfo.PayChannel = webNtf.PayChannel

		//订单状态修改，写入数据库(后续玩家发货成功后会再次修改订单状态为PayOrderState_EPayOrderState_PayOkReward)
		err, newPayInfoStr := model.GetEncodeMessage(payInfo)
		if err == nil {
			service.GetRedis().HSet(model.PayOrderPrefix, webNtf.CpOrderId, newPayInfoStr)
		}
		//完成订单id列表(避免上次发货不成功，玩家下次登陆时可以重新获取一次奖励)
		uidStr := strconv.FormatUint(payInfo.Uid, 10)
		okListKeyStr := model.PayOrderOKIdListPrefix + uidStr
		service.GetRedis().SAdd(okListKeyStr, payInfo.CpOrderId)

		if payInfo.OrderState == int32(serverproto.PayOrderState_EPayOrderState_PayOk) {
			ssNtfMsg := &serverproto.SSPayInfoOrderNtf{
				PayOrderInfo: payInfo,
			}
			selfmodel.SendSocial(ssNtfMsg)
		}
		util.InfoF("uid=%v WebPayQuickNotify ok order=%v", payInfo.Uid, payInfo)
	} else {
		util.ErrorF("WebPayQuickNotify uid=%v state error state=%v", payInfo.Uid, payInfo.OrderState)
		//return "FAILED"
		return fmt.Sprintf("FAILED,cpOrderId=%v state error=%v", webNtf.CpOrderId, payInfo.OrderState)
	}
	return "SUCCESS"
}

//外层发起主动充值(不走游戏流程)
func webPayNotifyH5(webNtf *WebNotifyData, payAmount float32, c *gin.Context) string {
	payInfo := &serverproto.PayOrderSaveInfo{}
	payInfo.Uid = webNtf.GameRoleId
	payInfo.Amount = payAmount
	payInfo.OrderProcessTime = util.GetTimeMilliseconds()
	payInfo.SdkOrderId = webNtf.SdkOrderId //sdk订单id\
	payInfo.PayMethod = webNtf.PayMethod
	payInfo.PayCurrency = webNtf.PayCurrency
	payInfo.PayTime = webNtf.PayTime
	payInfo.PayChannel = webNtf.PayChannel
	payInfo.GoodsType = int32(serverproto.PayGoodsType_EPayType_NBH5)

	rewardStr := c.DefaultQuery("reward", "")
	//reward
	rewardStrList := strings.Split(rewardStr, ",")
	for idx := 0; idx < len(rewardStrList); idx++ {
		key, val := model.Str2Res(rewardStrList[idx])
		if key > 0 && val > 0 {
			payInfo.RewardList = append(payInfo.RewardList, &serverproto.KeyValueType{Key: key, Value: val})
		}
	}
	payInfo.OrderState = int32(serverproto.PayOrderState_EPayOrderState_PayOk)

	//订单状态修改，写入数据库(后续玩家发货成功后会再次修改订单状态为PayOrderState_EPayOrderState_PayOkReward)
	err, newPayInfoStr := model.GetEncodeMessage(payInfo)
	if err == nil {
		service.GetRedis().HSet(model.PayOrderPrefix, webNtf.CpOrderId, newPayInfoStr)
	}
	//完成订单id列表(避免上次发货不成功，玩家下次登陆时可以重新获取一次奖励)
	uidStr := strconv.FormatUint(payInfo.Uid, 10)
	okListKeyStr := model.PayOrderOKIdListPrefix + uidStr
	service.GetRedis().SAdd(okListKeyStr, payInfo.CpOrderId)

	ssNtfMsg := &serverproto.SSPayInfoOrderNtf{
		PayOrderInfo: payInfo,
	}
	selfmodel.SendSocial(ssNtfMsg)

	return "SUCCESS"
}