<?php
|
|
namespace PayOrder;
|
|
include_once '/Common/CommFunc.php';
|
include_once "/db/DBOper.php";
|
include_once "/ProjComm/CfgReader.php";
|
|
/**
|
* 中心执行创建充值订单
|
*/
|
function CreatePayOrder($Channel, $AccountID, $ServerID, $OrderAmount, $OrderInfo)
|
{
|
$OrderID = date("YmdHis") . rand(10000, 99999) . rand(10000, 99999);
|
if (!\DBOper\Insert("PayOrder", array(
|
"OrderID" => $OrderID,
|
"Channel" => $Channel,
|
"AccountID" => $AccountID,
|
"ServerID" => intval($ServerID),
|
"OrderInfo" => $OrderInfo,
|
"OrderAmount" => $OrderAmount,
|
"Createtime" => date("Y-m-d H:i:s"),
|
"State" => 0,
|
"SyncRet" => array(),
|
))) {
|
return "";
|
}
|
return $OrderID;
|
}
|
|
/**
|
* 中心执行平台充值订单回调
|
* @param string $appID appID
|
* @param string $OrderID cp订单ID
|
* @param string $OrderIDSDK sp订单ID
|
* @param string $AccountID sp账号，如果有区分渠道ID，需要组合上渠道ID
|
* @param int $ServerID 区服ID
|
* @param string $OrderInfo 商品编号
|
* @param string $OrderAmount 订单金额，精确到小数点后面两位，如果有区分支付金额及下单金额（原价），则参数格式为： "支付金额|下单金额"
|
* @param string $payTime 支付时间，具体看sp是否有同步，没有的话传空即可，格式 Y-m-d H:i:s
|
* @param string $checkCreate 是否检查订单号是否存在，如果有先创建订单的步骤，额需要传true进行检查，否则可不检查，直接等sp回调后插入订单信息
|
* @param string $checkFunc 额外逻辑函数名，根据不同平台对接sdk决定，默认参数传入 $dbOrderInfo
|
* @param bool $repeat 是否补单
|
* @param array $extras 扩展数据，json字符串格式
|
* @return array {"errorcode":返回码, "errordesc":"描述信息"} 返回码为0时代表失败，1-成功，2-重复成功记录
|
*/
|
function DoReceivePayOrder($appID, $OrderID, $OrderIDSDK, $AccountID, $ServerID, $OrderInfo, $OrderAmount, $payTime, $checkCreate, $checkFunc = null, $repeat = false, $extras = "")
|
{
|
\Logging\LogInfo("DoReceivePayOrder appID:" . $appID . " OrderID:" . $OrderID . " OrderIDSDK:" . $OrderIDSDK . " AccountID:" . $AccountID .
|
" ServerID:" . $ServerID . " OrderInfo:" . $OrderInfo . " OrderAmount:" . $OrderAmount . " payTime:" . $payTime .
|
" checkCreate:" . $checkCreate);
|
if (!$OrderID) {
|
$OrderID = $OrderIDSDK;
|
}
|
$OriginalAmount = $OrderAmount; // 下单金额
|
$ServerID = intval($ServerID);
|
$returnArr = array("errorcode" => 0, "errordesc" => "failed");
|
if (!\DBOper\FindOne("PayOrder", array("OrderID" => $OrderID), $dbOrderInfo, null, false)) {
|
$returnArr["errordesc"] = "failed:find error";
|
return $returnArr;
|
}
|
\Logging\LogInfo("dbOrderInfo:" . print_r($dbOrderInfo, true));
|
|
if ($checkCreate && !isset($dbOrderInfo)) {
|
$returnArr["errordesc"] = "failed:orderID is not exist";
|
\Logging\LogWarn("orderID is not exist: OrderID:" . $OrderID);
|
return $returnArr;
|
}
|
|
if ($checkFunc) {
|
$errordesc = $checkFunc($dbOrderInfo);
|
if ($errordesc) {
|
$returnArr["errordesc"] = $errordesc;
|
return $returnArr;
|
}
|
}
|
|
// 有创建订单的，验证数据是否一致
|
if (isset($dbOrderInfo)) {
|
// 已经处理过的订单
|
if (!$repeat && $dbOrderInfo["State"] == 1) {
|
$returnArr["errorcode"] = 2;
|
$returnArr["errordesc"] = "failed:repeat commit";
|
\Logging\LogWarn("repeat payorder: OrderID:" . $OrderID);
|
return $returnArr;
|
}
|
|
if ($appID && $appID != $dbOrderInfo["Channel"]) {
|
$returnArr["errordesc"] = "failed:order appID error";
|
return $returnArr;
|
}
|
$appID = $dbOrderInfo["Channel"];
|
|
if ($AccountID && $AccountID != $dbOrderInfo["AccountID"]) {
|
$returnArr["errordesc"] = "failed:order AccountID error";
|
return $returnArr;
|
}
|
$AccountID = $dbOrderInfo["AccountID"];
|
|
if ($ServerID && $ServerID != $dbOrderInfo["ServerID"]) {
|
$returnArr["errordesc"] = "failed:order ServerID error";
|
return $returnArr;
|
}
|
$ServerID = $dbOrderInfo["ServerID"];
|
|
if ($OrderAmount && $OrderAmount != $dbOrderInfo["OrderAmount"]) {
|
$returnArr["errordesc"] = "failed:order OrderAmount error";
|
return $returnArr;
|
}
|
$OrderAmount = $dbOrderInfo["OrderAmount"];
|
|
if ($dbOrderInfo["OriginalAmount"]) {
|
$OriginalAmount = $dbOrderInfo["OriginalAmount"];
|
}
|
|
if ($OrderInfo && $OrderInfo != $dbOrderInfo["OrderInfo"]) {
|
$returnArr["errordesc"] = "failed:order OrderInfo error";
|
return $returnArr;
|
}
|
$OrderInfo = $dbOrderInfo["OrderInfo"];
|
|
if ($dbOrderInfo["PayTime"]) {
|
$payTime = $dbOrderInfo["PayTime"];
|
}
|
|
if ($dbOrderInfo["Extras"]) {
|
$extras = $dbOrderInfo["Extras"];
|
}
|
} else {
|
$amounts = explode("|", $OrderAmount);
|
if (count($amounts) > 1) {
|
$OrderAmount = $amounts[0];
|
$OriginalAmount = $amounts[1];
|
\Logging\LogInfo("OrderAmount:" . $OrderAmount . " OriginalAmount:" . $OriginalAmount);
|
}
|
}
|
|
if (!$appID || !$AccountID || !$ServerID || !$OrderInfo || !$OrderAmount) {
|
$returnArr["errordesc"] = "failed:order param error";
|
return $returnArr;
|
}
|
|
if (!$payTime) {
|
$payTime = date("Y-m-d H:i:s");
|
}
|
|
$setDBOrderData = array(
|
"OrderID" => $OrderID,
|
"OrderIDSDK" => $OrderIDSDK,
|
"Channel" => $appID,
|
"AccountID" => $AccountID,
|
"ServerID" => $ServerID,
|
"OrderInfo" => $OrderInfo,
|
"OrderAmount" => $OrderAmount, // 中心的这个字段是实际支付金额
|
"OriginalAmount" => $OriginalAmount,
|
"PayTime" => $payTime,
|
"State" => 0,
|
"SyncRet" => "", // 同步游戏服务器结果明细
|
"Extras" => $extras,
|
);
|
|
$payData = array(
|
"AccountID" => $AccountID,
|
"RegionName" => "s" . $ServerID,
|
"OrderAmount" => $OriginalAmount, // 同步给游戏服务器的这个是用原价
|
"BillNO" => $OrderID,
|
"OrderInfo" => $OrderInfo,
|
"OperatorID" => $appID,
|
"Extras" => $extras,
|
);
|
|
if (!isset($dbOrderInfo)) {
|
$setDBOrderData["Createtime"] = date("Y-m-d H:i:s");
|
}
|
$returnArr = SendExchangeToGameServers($appID, $ServerID, $appID, $payData);
|
$setDBOrderData["UpdateTime"] = date("Y-m-d H:i:s");
|
switch ($returnArr["errorcode"]) {
|
case 1:
|
$setDBOrderData["State"] = 1;
|
$setDBOrderData["SyncRet"] = $returnArr;
|
break;
|
case 2:
|
$setDBOrderData["State"] = 1;
|
$setDBOrderData["SyncRet"] = $returnArr;
|
break;
|
default:
|
$setDBOrderData["State"] = 2;
|
$setDBOrderData["SyncRet"] = $returnArr;
|
$returnArr["errordesc"] = "failed:" . $returnArr["errordesc"];
|
break;
|
}
|
|
if (!\DBOper\Update("PayOrder", array("OrderID" => $OrderID), $setDBOrderData, false, true)) {
|
$returnArr["errorcode"] = 0;
|
$returnArr["errordesc"] = "failed:update error";
|
} else {
|
\Logging\LogInfo("setDBOrderData:" . print_r($setDBOrderData, true));
|
}
|
AddAccountFirstPay($appID, $AccountID, $setDBOrderData);
|
return $returnArr;
|
}
|
|
/**添加平台账号首充 */
|
function AddAccountFirstPay($appID, $AccountID, $payOrderInfo)
|
{
|
$find = array("Channel" => $appID, "AccountID" => $AccountID);
|
if (!\DBOper\FindOne("AccountFirstPay", $find, $findData, null, false)) {
|
return;
|
}
|
if (isset($findData)) {
|
// 已存在，不再重复添加
|
return;
|
}
|
$insArray = array(
|
"Channel" => $appID,
|
"AccountID" => $AccountID,
|
"OrderID" => $payOrderInfo["OrderID"],
|
"OrderIDSDK" => $payOrderInfo["OrderIDSDK"],
|
"ServerID" => $payOrderInfo["ServerID"],
|
"OrderInfo" => $payOrderInfo["OrderInfo"],
|
"OrderAmount" => $payOrderInfo["OrderAmount"], // 中心的这个字段是实际支付金额
|
"OriginalAmount" => $payOrderInfo["OriginalAmount"],
|
"PayTime" => $payOrderInfo["PayTime"],
|
"PayYMD" => substr($payOrderInfo["PayTime"], 0, 10),
|
"Extras" => $payOrderInfo["Extras"],
|
);
|
\DBOper\Insert("AccountFirstPay", $insArray);
|
}
|
|
/**
|
* 发送渠道回调充值到游戏服务器
|
* @param string $spid 渠道
|
* @param int $serverID 服务器ID
|
* @param string $appID appID
|
* @param array $payData 同步游戏服务器的充值数据
|
* array(
|
* "AccountID" => 渠道账号,
|
* "RegionName" => "s" . 区服ID,
|
* "OrderAmount" => 充值金额，单位分,
|
* "BillNO" => 订单编号,
|
* "OrderInfo" => 商品编号,
|
* "OperatorID" => $appID,
|
* );
|
* @return array array("errorcode" => xxx, "errordesc" => "xxx") errorcode:1-成功，2-成功重复数据，其他失败
|
*/
|
function SendExchangeToGameServers($spid, $serverID, $appID, $payData)
|
{
|
\Logging\LogInfo("SendExchangeToGameServers spid:" . $spid . " serverID:" . $serverID . " appID:" . $appID);
|
$returnArr = array("errorcode" => 0, "errordesc" => "fail");
|
$serverIDArray = array($serverID);
|
$serverPageInfo = \CommFunc\GetGameServerPageInfo($spid, $serverIDArray);
|
if (count($serverPageInfo) <= 0) {
|
$returnArr["errordesc"] = "not serverPageInfo";
|
return $returnArr;
|
}
|
|
// 目标角色对应游戏服务器gmtool地址
|
$serverPageValues = array_values($serverPageInfo);
|
|
$pageUrl = $serverPageValues[0]["Page"];
|
if (!$pageUrl) {
|
$returnArr["errordesc"] = "not page url";
|
return $returnArr;
|
}
|
|
if (!\CfgReader\ReadConfig()) {
|
$returnArr["errordesc"] = "cfgreader error";
|
return $returnArr;
|
}
|
|
if (
|
!\CfgReader\GetConfigData("ExChange", "Key_" . $appID, $strKey) ||
|
!\CfgReader\GetConfigData("Config", "IsDecryptKey", $isDecryptKey)
|
) {
|
$returnArr["errordesc"] = "not exChange appid key";
|
return $returnArr;
|
}
|
|
//如果配置了需要解密，对登录key进行解密
|
if ($isDecryptKey == 1) {
|
$strKey = \CommFunc\GetDecodePsw($strKey);
|
}
|
|
\Logging\LogInfo("strKey: " . $strKey);
|
|
$postUrl = str_replace("Server/Tool.php", "api/exchange/index.php", $pageUrl);
|
\Logging\LogInfo("postUrl: " . $postUrl);
|
|
$opqid = $payData['AccountID'];
|
$orderID = $payData["BillNO"];
|
$orderAmount = $payData['OrderAmount'];
|
$getServer_id = $payData['RegionName'];
|
$sign = md5($opqid . $orderAmount . $orderID . $getServer_id . $strKey);
|
$payData["Sign"] = $sign;
|
\Logging\LogInfo("payData: " . print_r($payData, true));
|
$payretStr = \CommFunc\DoPost($postUrl, $payData);
|
\Logging\LogInfo("payretStr: " . $payretStr);
|
$ret = json_decode($payretStr, true);
|
\Logging\LogInfo("ret: " . print_r($ret, true));
|
if (isset($ret)) {
|
return $ret;
|
}
|
return $returnArr;
|
}
|
