fe / YOHOBUYPC · Commits

Go to a project

Authored by Rock Zhang
Commit 7257e35d8dcbe469a56d0167503cf907fffc456f 1 parent c6a22b93

添加详细的支付日志记录

Inline Side-by-side
Showing 8 changed files with 308 additions and 185 deletions
... ... @@ -10,25 +10,25 @@ use WebPlugin\PhpLog;
class Service extends PayAbstract
{
public $config;
public $config;
private $log;
public function __construct(array $paymentParams)
{
$this->logProjectPrefix = 'alibank';
$this->config = new Config();
$myConfig = json_decode($paymentParams["pay_params"]) ;
$this->config->partner = $myConfig->merchant_id;
$this->config->alipay_key = $myConfig->merchant_key;
$this->config->sellerMail = $myConfig->merchant_other_code;
public function __construct(array $paymentParams)
{
$this->logProjectPrefix = 'alibank';
$this->config = new Config();
$myConfig = json_decode($paymentParams["pay_params"]);
$this->config->partner = $myConfig->merchant_id;
$this->config->alipay_key = $myConfig->merchant_key;
$this->config->sellerMail = $myConfig->merchant_other_code;
$this->log = new PhpLog($this->config->logDir, "PRC", $this->config->logLevel);
}
/**
* 获取时间戳
*/
private function getTimestamp()
}
/**
* 获取时间戳
*/
private function getTimestamp()
{
$url = "https://mapi.alipay.com/gateway.do?service=query_timestamp&partner=" . trim(strtolower($this->config->partner)) . "&_input_charset=" . trim(strtolower($this->config->input_charset));
... ... @@ -38,173 +38,178 @@ class Service extends PayAbstract
$encrypt_key = $itemEncrypt_key->item(0)->nodeValue;
return $encrypt_key;
}
public function getPayRequestPars(Reqparams $params)
{
$baseUrl = $this->getBaseNoticeUrl($params->isTest);
$loseTime = intval(($params->orderTime + 7200 -time())/60);
// $loseTime = intval((strtotime(date("Y-m-d 10:00:00", strtotime("+1 day")))-time())/60);
$parameter = array(
'service' => $this->config->service,
'partner' => $this->config->partner,
'_input_charset' => $this->config->input_charset,
'notify_url' => $baseUrl . $this->config->notify_url,
'return_url' => $baseUrl . $this->config->return_url,
/* 业务参数 */
'subject' => $params->goodsName,
'out_trade_no' => $params->orderCode.'_'.$params->paymentParameter,
'total_fee' => $params->totalFee / 100, //单位为元
'payment_type' => $this->config->payment_type,
'defaultbank' => $params->paymentParameter,
'seller_email' => $this->config->sellerMail,
}
public function getPayRequestPars(Reqparams $params)
{
$baseUrl = $this->getBaseNoticeUrl($params->isTest);
$loseTime = intval(($params->orderTime + 7200 - time()) / 60);
// $loseTime = intval((strtotime(date("Y-m-d 10:00:00", strtotime("+1 day")))-time())/60);
$parameter = array(
'service' => $this->config->service,
'partner' => $this->config->partner,
'_input_charset' => $this->config->input_charset,
'notify_url' => $baseUrl . $this->config->notify_url,
'return_url' => $baseUrl . $this->config->return_url,
/* 业务参数 */
'subject' => $params->goodsName,
'out_trade_no' => $params->orderCode . '_' . $params->paymentParameter,
'total_fee' => $params->totalFee / 100, //单位为元
'payment_type' => $this->config->payment_type,
'defaultbank' => $params->paymentParameter,
'seller_email' => $this->config->sellerMail,
// 'it_b_pay' => $loseTime . 'm'
);
if($this->config->anti_fishing['timestamp_enable']) {
$anti_phishing_key = $this->getTimestamp();
if(!empty($anti_phishing_key)) {
$parameter['anti_phishing_key'] = $anti_phishing_key;
}
}
if($this->config->anti_fishing['ip_enable']) {
$parameter['exter_invoke_ip'] = $params->spbill_create_ip;
}
);
if ($this->config->anti_fishing['timestamp_enable']) {
$anti_phishing_key = $this->getTimestamp();
if (!empty($anti_phishing_key)) {
$parameter['anti_phishing_key'] = $anti_phishing_key;
}
}
if ($this->config->anti_fishing['ip_enable']) {
$parameter['exter_invoke_ip'] = $params->spbill_create_ip;
}
// 除去数组中的空值和签名参数
$para_filter = array();
foreach ($parameter AS $k => $v) {
if($k == "sign" || $k == "sign_type" || $v == "") {
if ($k == "sign" || $k == "sign_type" || $v == "") {
continue;
} else {
$para_filter[$k] = $parameter[$k];
}
}
ksort($para_filter);
reset($para_filter);
$param = '';
$sign = '';
foreach ($para_filter AS $key => $val) {
$param .= "$key=" .urlencode($val). "&";
$sign .= "$key=$val&";
}
$param = substr($param, 0, -1);
$sign = substr($sign, 0, -1);
ksort($para_filter);
reset($para_filter);
$param = '';
$sign = '';
foreach ($para_filter AS $key => $val) {
$param .= "$key=" . urlencode($val) . "&";
$sign .= "$key=$val&";
}
$param = substr($param, 0, -1);
$sign = substr($sign, 0, -1);
//如果存在转义字符，那么去掉转义
if(get_magic_quotes_gpc()){$sign = stripslashes($sign);}
if (get_magic_quotes_gpc()) {
$sign = stripslashes($sign);
}
$sign .= $this->config->alipay_key;
$result = array(
$result = array(
'pay_url' => $this->config->pay_url,
'pars' => $param . "&sign=" . md5($sign). "&sign_type=" . $this->config-> sign_type,
'pars' => $param . "&sign=" . md5($sign) . "&sign_type=" . $this->config->sign_type,
'reqType' => 'get'
);
return $result;
}
public function parseResponse(array $arrResponse)
{
/* 返回示例
* http://www.yohobuy.com/pay/notice/alipayreturn?buyer_email=tds%40smartunite.com&buyer_id=2088302294447308&exterface=create_direct_pay_by_user&is_success=T&notify_id=RqPnCoPT3K9%252Fvwbh3I7xtEV5W65QRToFQ5fPrXsVxt12e%252FExCtC1XNiKnuRwupLaVLAR&notify_time=2011-06-11+07%3A48%3A10&notify_type=trade_status_sync&out_trade_no=1061003000&payment_type=1&seller_email=shop%40yoho.cn&seller_id=2088001550230585&subject=YOHO%E5%95%86%E5%93%81&total_fee=0.01&trade_no=2011061199833830&trade_status=TRADE_SUCCESS&sign=ca1c49f58d17eaa57aac308d0ac64434&sign_type=MD5
*/
);
return $result;
}
public function parseResponse(array $arrResponse)
{
/* 返回示例
* http://www.yohobuy.com/pay/notice/alipayreturn?buyer_email=tds%40smartunite.com&buyer_id=2088302294447308&exterface=create_direct_pay_by_user&is_success=T&notify_id=RqPnCoPT3K9%252Fvwbh3I7xtEV5W65QRToFQ5fPrXsVxt12e%252FExCtC1XNiKnuRwupLaVLAR&notify_time=2011-06-11+07%3A48%3A10&notify_type=trade_status_sync&out_trade_no=1061003000&payment_type=1&seller_email=shop%40yoho.cn&seller_id=2088001550230585&subject=YOHO%E5%95%86%E5%93%81&total_fee=0.01&trade_no=2011061199833830&trade_status=TRADE_SUCCESS&sign=ca1c49f58d17eaa57aac308d0ac64434&sign_type=MD5
*/
$this->log->LogInfo("===开始解析支付宝银行的回调参数===");
$this->log->logInfo("-----回调参数为---");
$this->log->logInfo(var_export($arrResponse), true);
if(isset($arrResponse['q'])){
unset($arrResponse['q']);
}
$rsp = new Rspparams();
if(!$this->checkResponse($arrResponse))
{
$this->log->LogInfo("验证支付宝银行的回调参数失败");
//验证不成功
$rsp->payResult = -1;
}
else
{
$rsp->bankName = "";
$outTradeNo = $arrResponse["out_trade_no"];
if (isset($arrResponse['q'])) {
unset($arrResponse['q']);
}
$rsp = new Rspparams();
if (!$this->checkResponse($arrResponse)) {
$this->log->LogInfo("---验证支付宝银行的回调参数失败---");
//验证不成功
$rsp->payResult = -1;
} else {
$this->log->LogInfo("---验证支付宝银行的回调参数成功---");
$rsp->bankName = "";
$outTradeNo = $arrResponse["out_trade_no"];
// if(strlen($outTradeNo) > 9) {
// $outTradeNo = substr($outTradeNo, 2);
// }
//支付订单处理
$orderCodeArr = explode('_',$outTradeNo);
if(count($orderCodeArr) == 2){
$rsp->orderCode = $orderCodeArr[0];
$rsp->bankName = $orderCodeArr[1];
}else{
$rsp->orderCode = $outTradeNo;
$rsp->bankName = "";
}
$rsp->payResult = $this->convertResult($arrResponse["trade_status"]);
$rsp->payTime = isset($arrResponse["gmt_payment"]) ? $arrResponse["gmt_payment"] : time();
$rsp->totalFee = $arrResponse["total_fee"];
$rsp->resultMsg = $arrResponse["notify_type"];
//添加支付订单号和交易号和银行的流水号
$rsp->payOrderCode = $outTradeNo;
$rsp->tradeNo = $arrResponse['trade_no'];
$rsp->bankBillNo = $arrResponse['bank_seq_no'] ? $arrResponse['bank_seq_no'] : "";
}
return $rsp;
}
protected function convertResult($resultCode)
{
if($resultCode == "TRADE_SUCCESS")
{
return 200;
}
return 400;
}
/**
* 除去数组中的空值和签名参数
* @param $para 签名参数组
* return 去掉空值与签名参数后的新签名参数组
*/
private function paraFilter($para) {
$para_filter = array();
foreach ($para as $key=>$val) {
if($key == "sign" || $key == "sign_type" || $val == "")continue;
else $para_filter[$key] = $para[$key];
}
return $para_filter;
}
/**
* 对数组排序
* @param $para 排序前的数组
* return 排序后的数组
*/
private function argSort($para) {
ksort($para);
reset($para);
return $para;
}
/**
* 验证回复的正确性
* @see QPay_Utils_Abstract::verifResponse()
*/
protected function checkResponse(array $arrResponse)
{
ksort($arrResponse);
reset($arrResponse);
$sign = '';
foreach ($arrResponse AS $key=>$val)
{
if ($key != 'sign' && $key != 'sign_type' && $key != 'code')
{
$sign .= "$key=$val&";
}
}
$sign = substr($sign, 0, -1) . $this->config->alipay_key;
return md5($sign) != $arrResponse['sign'] ? false : true;
}
//支付订单处理
$orderCodeArr = explode('_', $outTradeNo);
if (count($orderCodeArr) == 2) {
$rsp->orderCode = $orderCodeArr[0];
$rsp->bankName = $orderCodeArr[1];
} else {
$rsp->orderCode = $outTradeNo;
$rsp->bankName = "";
}
$rsp->payResult = $this->convertResult($arrResponse["trade_status"]);
$rsp->payTime = isset($arrResponse["gmt_payment"]) ? $arrResponse["gmt_payment"] : time();
$rsp->totalFee = $arrResponse["total_fee"];
$rsp->resultMsg = $arrResponse["notify_type"];
//添加支付订单号和交易号和银行的流水号
$rsp->payOrderCode = $outTradeNo;
$rsp->tradeNo = $arrResponse['trade_no'];
$rsp->bankBillNo = $arrResponse['bank_seq_no'] ? $arrResponse['bank_seq_no'] : "";
$this->log->LogInfo('----支付宝银行回调处理结果为----');
$this->log->LogInfo(var_export($rsp, true));
}
return $rsp;
}
protected function convertResult($resultCode)
{
if ($resultCode == "TRADE_SUCCESS") {
return 200;
}
return 400;
}
/**
* 除去数组中的空值和签名参数
* @param $para 签名参数组
* return 去掉空值与签名参数后的新签名参数组
*/
private function paraFilter($para)
{
$para_filter = array();
foreach ($para as $key => $val) {
if ($key == "sign" || $key == "sign_type" || $val == "") continue;
else $para_filter[$key] = $para[$key];
}
return $para_filter;
}
/**
* 对数组排序
* @param $para 排序前的数组
* return 排序后的数组
*/
private function argSort($para)
{
ksort($para);
reset($para);
return $para;
}
/**
* 验证回复的正确性
* @see QPay_Utils_Abstract::verifResponse()
*/
protected function checkResponse(array $arrResponse)
{
ksort($arrResponse);
reset($arrResponse);
$sign = '';
foreach ($arrResponse AS $key => $val) {
if ($key != 'sign' && $key != 'sign_type' && $key != 'code') {
$sign .= "$key=$val&";
}
}
$sign = substr($sign, 0, -1) . $this->config->alipay_key;
return md5($sign) != $arrResponse['sign'] ? false : true;
}
}
\ No newline at end of file
... ...
... ... @@ -100,6 +100,10 @@ class Service extends PayAbstract
'pars' => $param . "&sign=" . md5($sign) . "&sign_type=" . $this->config->sign_type,
'reqType' => 'get'
);
$this->log->LogInfo('----支付宝回调处理结果为----');
$this->log->LogInfo(var_export($result, true));
return $result;
}
... ... @@ -117,9 +121,11 @@ class Service extends PayAbstract
}
$rsp = new Rspparams();
if (!$this->checkResponse($arrResponse)) {
$this->log->logInfo("-----支付宝回调参数验证签名失败---");
//验证不成功
$rsp->payResult = -1;
} else {
$this->log->logInfo("-----支付宝回调参数验证签名成功---");
$rsp->bankName = "";
$outTradeNo = $arrResponse["out_trade_no"];
$rsp->orderCode = $outTradeNo;
... ...
... ... @@ -5,10 +5,12 @@ namespace WebPlugin\Pay\Allinpay;
use WebPlugin\Pay\PayAbstract;
use WebPlugin\Pay\Reqparams;
use WebPlugin\Pay\Rspparams;
use WebPlugin\PhpLog;
class Service extends PayAbstract
{
var $config;
public $config;
private $log;
public function __construct(array $paymentParams)
{
... ... @@ -17,6 +19,8 @@ class Service extends PayAbstract
$myConfig = json_decode($paymentParams["pay_params"]);
$this->config->merchantId = $myConfig->merchant_id;
$this->config->merchantKey = $myConfig->merchant_key;
$this->log = new PhpLog($this->config->logDir, 'PRC', $this->config->logLevel);
}
/**
... ... @@ -63,10 +67,18 @@ class Service extends PayAbstract
*/
public function parseResponse(array $arrResponse)
{
$this->log->LogInfo("===开始处理通联支付的回调参数===");
$this->log->logInfo("-----回调参数为---");
$this->log->logInfo(var_export($arrResponse, true));
$rsp = new Rspparams();
if (!$this->checkResponse($arrResponse)) {
$this->log->logInfo("-----验证通联支付回调参数失败---");
$rsp->payResult = -1;
} else {
$this->log->logInfo("-----验证通联支付回调参数成功---");
$rsp->bankName = "";
$rsp->orderCode = $arrResponse["orderNo"];
$rsp->payResult = $this->convertResult($arrResponse["payResult"]);
... ...
... ... @@ -108,15 +108,19 @@ class Service extends PayAbstract
*/
function parseResponse(Array $arrResponse)
{
$this->log->LogInfo("===开始处理盛付通的请求参数===");
$this->log->logInfo("-----请求参数为---");
$this->log->LogInfo("===开始处理盛付通的回调参数===");
$this->log->logInfo("-----回调参数为---");
$this->log->logInfo(var_export($arrResponse, true));
$rsp = new Rspparams();
if (!$this->checkResponse($arrResponse)) {
$this->log->logInfo("-----验证盛付通回调参数失败---");
//验证不成功
$rsp->payResult = -1;
} else {
$this->log->logInfo("-----验证盛付通回调参数成功---");
$rsp->bankName = "";
$rsp->orderCode = $arrResponse["OrderNo"];
$rsp->payResult = $this->convertResult($arrResponse["Status"]);
... ...
... ... @@ -35,20 +35,22 @@ class Service extends PayAbstract
*/
public function parseResponse(array $package)
{
$this->log->logInfo("===开始解析银联支付的回调参数===");
$this->log->logInfo("===回调参数为===");
$this->log->LogInfo(var_export($package, true));
$verify = false;
$responseData = new Rspparams();
if (!isset($package['respCode']) || $package['respCode'] !== '00') {
$this->log->LogInfo('支付返回码有误');
$this->log->LogInfo('银联支付返回码有误');
$responseData->payResult = -1;
return $responseData;
}
if (isset($package['signature'])) { // TODO isset($package['signature']) && verify($package)验证签名待做
$verify = true;
$this->log->LogInfo('验签成功');
$this->log->LogInfo('银联支付验签成功');
}
if ($verify) {
... ... @@ -67,6 +69,7 @@ class Service extends PayAbstract
$responseData->payResult = -1;
}
$this->log->logInfo("===银联支付的回调参数处理结果为===");
$this->log->LogInfo(var_export($responseData, true));
return $responseData;
... ...
... ... @@ -21,10 +21,11 @@ class Service extends PayAbstract
private $payCurl;
private $log;
public function __construct(array $paymentParams) {
public function __construct(array $paymentParams)
{
$this->logProjectPrefix = 'wechatpay';
$this->config = new Config();
$environParam = 'pay_'.APPLICATION_ENV.'_url';
$environParam = 'pay_' . APPLICATION_ENV . '_url';
$this->payCurl = $this->config->$environParam;
$this->appKey = $this->config->app_key;
$this->privateKey = $this->config->private_key;
... ... @@ -33,7 +34,8 @@ class Service extends PayAbstract
$this->log = new PhpLog($this->config->logDir, 'PRC', $this->config->logLevel);
}
public function getPayRequestPars(Reqparams $params) {
public function getPayRequestPars(Reqparams $params)
{
$this->orderCode = $params->orderCode;
$result = array(
'pay_url' => $this->config->payment_url,
... ... @@ -49,7 +51,8 @@ class Service extends PayAbstract
* @return string
* @internal param array $orderCode
*/
public function pay(array $orderInfo) {
public function pay(array $orderInfo)
{
$this->log->LogInfo("===开始处理微信扫码支付的请求参数===");
$this->log->logInfo("-----请求参数为---");
$this->log->logInfo(var_export($orderInfo, true));
... ... @@ -74,7 +77,7 @@ class Service extends PayAbstract
);
$pars = '';
foreach ($parameter as $p_key => $p_val) {
$pars.=$p_key . '=' . urlencode($p_val) . '&';
$pars .= $p_key . '=' . urlencode($p_val) . '&';
}
$payUrlInfo = array(
'pay_url' => $this->payCurl,
... ... @@ -90,7 +93,8 @@ class Service extends PayAbstract
return array('pay_url' => $payUrl);
}
public function parseResponse(array $data) {
public function parseResponse(array $data)
{
/* 返回示例
* http://www.yohobuy.com/pay/notice/wechatqrcodereturn?ordercode=93465435
*/
... ... @@ -108,7 +112,7 @@ class Service extends PayAbstract
$rsp = new Rspparams();
// 支付成功
if(isset($result['trade_state']) && $result['trade_state'] === 'SUCCESS'){
if (isset($result['trade_state']) && $result['trade_state'] === 'SUCCESS') {
$rsp->payResult = 200;
$rsp->bankName = "WX";
$rsp->orderCode = $data['orderCode'];
... ... @@ -119,7 +123,8 @@ class Service extends PayAbstract
$rsp->payOrderCode = $data["orderCode"];
$rsp->tradeNo = $result["out_trade_no"];
$rsp->bankBillNo = $result['bank_type'];
}else{
} else {
$this->log->logInfo("===微信扫码支付失败===");
$rsp->payResult = -1;
}
... ...
... ... @@ -14,6 +14,7 @@ use WebPlugin\Pay\weixin\lib\WxPayConfig;
use WebPlugin\Pay\weixin\lib\WxPayNativePay;
use WebPlugin\Pay\weixin\lib\WxPayOrderQuery;
use WebPlugin\Pay\weixin\lib\WxPayUnifiedOrder;
use WebPlugin\PhpLog;
/**
* 支付有关方法
... ... @@ -25,6 +26,22 @@ use WebPlugin\Pay\weixin\lib\WxPayUnifiedOrder;
*/
class PayModel
{
// 日志等级，2表示记录信息等级的日志
const LOG_LEVEL = 2;
// 支付方式有关接口调用日志
const PAYMENT_LIST_LOG = '/Data/logs/pc_pay/payment_list';
// 向ERP提交订单状态有关接口调用日志和更新订单状态有关接口调用日志
const ORDER_STATUS_LOG = '/Data/logs/pc_pay/order_status';
// 获取或者更新订单支付银行的接口调用日志
const ORDER_BANK_LOG = '/Data/logs/pc_pay/order_bank';
// 根据用户UID获取订单数有关接口调用日志
const ORDER_COUNT_LOG = '/Data/logs/pc_pay/order_count';
// 发送短信有关接口调用日志
const SEND_MESSAGE_LOG = '/Data/logs/pc_pay/send_message';
// 是否老用户订单数判断值
const OLD_USER_LIMIT = 1;
/**
* 获取支付方式选择页面有关信息
*
... ... @@ -94,8 +111,14 @@ class PayModel
// 用户ID
$result['uid'] = $uid;
// 初始化日志
$log = new PhpLog(self::PAYMENT_LIST_LOG, 'PRC', self::LOG_LEVEL);
// 获取支付途径列表
$log->LogInfo('===开始调用支付方式列表接口,接口方法为web.SpaceOrders.getPaymentList===');
$payTypes = PayData::getPaymentList();
$log->LogInfo('===结束调用支付方式列表接口,返回结果为===');
$log->LogInfo(var_export($payTypes, true));
$defaultPayType = 0;
$types = array();
if (isset($payTypes['data']) && !empty($payTypes['data'])) {
... ... @@ -125,16 +148,37 @@ class PayModel
// 无需付款
if (isset($order["payment_amount"]) && $order["payment_amount"] == 0) {
// 初始化日志
$log = new PhpLog(self::ORDER_STATUS_LOG, 'PRC', self::LOG_LEVEL);
$log->LogInfo('===[' . $orderCode . ']===');
// ERP提交订单状态
PayData::submitOrderStatus($orderCode, 0, '', '', 0, '', '', '');
$log->LogInfo('===开始调用ERP提交订单状态接口,接口方法为web.SpaceOrders.submitOrderStatus===');
$log->LogInfo('===请求参数为orderCode=' . $orderCode . '===');
$erpReturn = PayData::submitOrderStatus($orderCode, 0, '', '', 0, '', '', '');
$log->LogInfo('===结束调用ERP提交订单状态接口,返回结果为===');
$log->LogInfo(var_export($erpReturn, true));
// 更新订单的状态
PayData::updateOrderStatus($order['order_id'], $uid, 0, 'Y', '');
$log->LogInfo('===开始调用更新订单状态接口,接口方法为web.SpaceOrders.updatePaymentStatus===');
$log->LogInfo('===请求参数为orderId=' . $order['order_id'] . 'uid=' . $uid . '===');
$updateOrderStatus = PayData::updateOrderStatus($order['order_id'], $uid, 0, 'Y', '');
$log->LogInfo('===结束调用更新订单状态接口,返回结果为===');
$log->LogInfo(var_export($updateOrderStatus, true));
$result['notNeedPay'] = true;
break;
}
// 记录支付方式
// 初始化日志
$log = new PhpLog(self::ORDER_BANK_LOG, 'PRC', self::LOG_LEVEL);
$log->LogInfo('===开始调用记录支付方式接口,接口方法为web.SpaceOrders.getOrderPayBank===');
$log->LogInfo('===请求参数为orderCode=' . $orderCode . '===');
$bankRecord = PayData::getBankByOrder($orderCode);
$log->LogInfo('===结束调用记录支付方式接口,返回结果为===');
$log->LogInfo(var_export($bankRecord, true));
if (isset($bankRecord['data']['bankCode']) && !empty($bankRecord['data']['bankCode'])) {
$payRecord = $bankRecord['data']['bankCode'];
} else {
... ... @@ -158,11 +202,17 @@ class PayModel
// 是否是老用户（用于订单统计）
$orderCount = 0;
// 初始化日志
$log = new PhpLog(self::ORDER_COUNT_LOG, 'PRC', self::LOG_LEVEL);
$log->LogInfo('===开始调用查询用户订单数接口,接口方法为web.SpaceOrders.getOrderCountByUid===');
$orders = PayData::getOrderCountByUid($uid);
$log->LogInfo('===结束调用查询用户订单数接口,返回结果为===');
$log->LogInfo(var_export($orders, true));
if (isset($orders['data']) && !empty($orders['data'])) {
$orderCount = $orders['data']['total'];
}
$result['isOldUser'] = (intval($orderCount) > 1) ? true : false;
$result['isOldUser'] = (intval($orderCount) > self::OLD_USER_LIMIT) ? true : false;
// 订单数（用于订单统计）
$result['orderCount'] = $orderCount;
$result['is_advance'] = $order['attribute'] == 5 ? 'Y' : 'N';
... ... @@ -424,6 +474,11 @@ class PayModel
break;
}
// 初始化日志
$log = new PhpLog(self::ORDER_STATUS_LOG, 'PRC', self::LOG_LEVEL);
$log->LogInfo('========[' . $orderCode . ']========');
$log->LogInfo('========开始查询微信扫码支付状态========');
// 组装微信支付的订单号
$tradeNo = 'YOHOBuy_' . $orderCode;
$input = new WxPayOrderQuery();
... ... @@ -431,6 +486,7 @@ class PayModel
$payResult = WxPayApi::orderQuery($input);
if (isset($payResult['trade_state']) && $payResult['trade_state'] === 'SUCCESS') {
$log->LogInfo('========微信扫码支付成功========');
$result = array(
'code' => '200',
'message' => 'success'
... ... @@ -457,8 +513,18 @@ class PayModel
);
do {
// 初始化日志
$log = new PhpLog(self::ORDER_STATUS_LOG, 'PRC', self::LOG_LEVEL);
$log->LogInfo('========[' . $payResult->orderCode . ']========');
$log->LogInfo(var_export($payResult, true));
$log->LogInfo('===开始调用获取订单详情方式接口,接口方法为app.SpaceOrders.detail===');
$orderInfo = OrderData::getOrderDetail($uid, $payResult->orderCode);
$log->LogInfo('===结束调用获取订单详情方式接口,返回结果为===');
$log->LogInfo(var_export($orderInfo, true));
if (!isset($orderInfo['data']) || empty($orderInfo['data'])) {
$log->LogInfo('===订单支付失败，未获取到订单详情信息===');
break;
}
... ... @@ -470,7 +536,14 @@ class PayModel
// 订单已取消
if ($orderData['is_cancel'] === 'Y' && $paymentStatus === 'N') {
// 给用户发送短信
PayData::sendMessage($orderData['mobile'], 'error_sms', '支付成功,但订单已取消，订单号为' . $orderCode);
// 初始化日志
$log = new PhpLog(self::SEND_MESSAGE_LOG, 'PRC', self::LOG_LEVEL);
$log->LogInfo('===[' . $orderCode . ']===');
$log->LogInfo('===开始调用订单取消时给用户发短信接口,接口方法为app.message.sendMsg===');
$messageReturn = PayData::sendMessage($orderData['mobile'], 'error_sms', '支付成功,但订单已取消，订单号为' . $orderCode);
$log->LogInfo('===结束调用给用户发短信接口,返回结果为===');
$log->LogInfo(var_export($messageReturn, true));
$result['code'] = 417;
$result['message'] = '支付成功，但订单已取消，需联系客服';
break;
... ... @@ -478,6 +551,8 @@ class PayModel
// 支付金额与订单金额不一致
if (round($amount, 2) != round($payResult->totalFee, 2)) {
$log = new PhpLog(self::ORDER_STATUS_LOG, 'PRC', self::LOG_LEVEL);
$log->LogInfo('===订单支付失败，支付金额与订单金额不一致===');
$result['code'] = 415;
$result['message'] = '支付金额与订单金额不一致';
break;
... ... @@ -489,10 +564,25 @@ class PayModel
$bankBillNo = $payResult->bankBillNo ? $payResult->bankBillNo : "";
$bankName = $payResult->bankName;
$bankCode = $payResult->bankCode;
// 初始化日志
$log = new PhpLog(self::ORDER_STATUS_LOG, 'PRC', self::LOG_LEVEL);
$log->LogInfo('===[' . $orderCode . ']===');
$log->LogInfo('===开始调用ERP提交订单状态接口,接口方法为web.SpaceOrders.submitOrderStatus===');
$log->LogInfo('===请求参数为orderCode=' . $orderCode . '===');
// ERP提交订单状态
PayData::submitOrderStatus($orderCode, $payment, $bankName, $bankCode, $amount, $payOrderCode, $tradeNo, $bankBillNo);
$erpReturn = PayData::submitOrderStatus($orderCode, $payment, $bankName, $bankCode, $amount, $payOrderCode, $tradeNo, $bankBillNo);
$log->LogInfo('===结束调用ERP提交订单状态接口,返回结果为===');
$log->LogInfo(var_export($erpReturn, true));
$log->LogInfo('===开始调用更新订单状态接口,接口方法为web.SpaceOrders.updatePaymentStatus===');
$log->LogInfo('===请求参数为orderId=' . $orderData['order_id'] . 'uid=' . $uid . '===');
// 更新订单的状态
PayData::updateOrderStatus($orderData['order_id'], $uid, $payment, 'Y', $bankCode);
$updateOrderStatus = PayData::updateOrderStatus($orderData['order_id'], $uid, $payment, 'Y', $bankCode);
$log->LogInfo('===结束调用更新订单状态接口,返回结果为===');
$log->LogInfo(var_export($updateOrderStatus, true));
$log->LogInfo('===订单支付成功，请等待发货===');
$result['code'] = 200;
$result['message'] = '支付成功，请等待发货';
... ...
... ... @@ -200,8 +200,6 @@ class NoticeController extends WebAction
*/
public function shengpayreturnAction()
{
// $strData = '{"Amount":"0.01","PayAmount":"0.01","OrderNo":"1070021504","serialno":"B000110726001873577","Status":"01","MerchantNo":"408258","PayChannel":"04","Discount":"1","SignType":"2","PayTime":"20110726162126","CurrencyType":"RMB","ProductNo":"","ProductDesc":"","Remark1":"","Remark2":"","ExInfo":"bankid:SDTBNK","Branch":"SHB","MAC":"8ABC0FBAA3EE3202F16A915B42571B58"}';
// $pars = json_decode($strData, true);
$payment = PayModel::getPaymentById(11);
$payService = PayFactory::factory($payment);
$res = $payService->parseResponse($_POST);
... ...