本文中使用的编程语言是PHP，PHP框架是thinkPHP3.2.3.
一、支付类，含有支付、退款等接口。
<?php
/**
* 微信支付类
* Created by PhpStorm.
* User: 科技
* Date: 2020/4/26
* Time: 10:30
*/
namespace Api;
class WxPayController
{
/**
* 小程序appid
* @var string
*/
private $appId;
/**
* 小程序secret
* @var string
*/
private $appSecret;
/**
* 商户平台商户id
* @var string
*/
private $mchId;
/**
* 商户平台密钥key
* @var string
*/
private $key;
/**
* 支付回掉地址
* @var string
*/
private $notifyUrl;
/**
* 获取用户唯一标识open_id api 接口地址
* @var string
*/
private $code2SessionApiUrl;
/**
* 统一下单api 接口地址
* @var string
*/
private $unifiedOrderApiUrl;
/**
* 错误信息
* @var string
*/
public $errorInfo;
/**
* WxPay constructor.
*/
public function __construct()
{
$this->appId = C(\'APP_ID\');
$this->appSecret = C("APP_SECRET");
$this->mchId = C("MCH_ID");
$this->key = C("KEY");
$this->notifyUrl = (isset($_SERVER[\'REQUEST_SCHEME\']) ? ($_SERVER[\'REQUEST_SCHEME\'] . \'://\') : \'\') . $_SERVER[\'HTTP_HOST\'].\'/Api/Pay/notifyPay.html\';
$this->code2SessionApiUrl = \'https://api.weixin.qq.com/sns/jscode2session\';
$this->unifiedOrderApiUrl = \'https://api.mch.weixin.qq.com/pay/unifiedorder\';
}
/**
* 添加错误信息
* @param $err
*/
public function setError($err)
{
$this->errorInfo = $err;
}
/**
* 获取错误信息
* @return string
*/
public function getError()
{
return $this->errorInfo;
}
/**
* 获取支付签名
* @param $open_id
* @param $order_no
* @param $money
* @return array
*/
public function paySign($open_id, $order_no, $money)
{
if (!$open_id || !$order_no || !$money) {
$this->setError(\'参数错误\');
return [];
}
$prepay_id = $this->unifiedorder($open_id, $order_no, $money);
if (!$prepay_id) {
return [];
}
$params = array(
\'appId\' => $this->appId,
\'timeStamp\' => time(),
\'nonceStr\' => encrypt(16),
\'package\' => \'prepay_id=\' . $prepay_id,
\'signType\' => \'MD5\',
);
$params[\'paySign\'] = $this->getSign($params);
return $params;
}
/**
* 异步签名验证
* @param $data
* @return bool
*/
public function checkNotifySign($data)
{
if (!$data) {
return false;
}
$sign = $data[\'sign\'];
unset($data[\'sign\']);
if ($sign == $this->getSign($data)) {
return true;
}
return false;
}
/**
* 异步回调处理成功时返回内容
* @param $msg
* @return string
*/
public function notifyReturnSuccess($msg = \'OK\')
{
return \'<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[\' . $msg . \']]></return_msg></xml>\';
}
/**
* 异步回调处理失败时返回内容
* @param $msg
* @return string
*/
public function notifyReturnFail($msg = \'FAIL\')
{
return \'<xml><return_code><![CDATA[FAIL]]></return_code><return_msg><![CDATA[\' . $msg . \']]></return_msg></xml>\';
}
/**
* 统一下单
* @param $open_id
* @param $order_no
* @param $money
* @return string
*/
private function unifiedOrder($open_id, $order_no, $money)
{
$params = [
\'appid\' => $this->appId,
\'mch_id\' => $this->mchId,
\'nonce_str\' => encrypt(16),
\'body\' => \'食品-订单\', //商品简单描述
\'out_trade_no\' => $order_no, //商户系统内部订单号
\'total_fee\' => priceyuantofen($money), //订单总金额，单位为分
\'spbill_create_ip\' => get_client_ip(), //用户端ips
\'notify_url\' => $this->notifyUrl, //通知地址
\'trade_type\' => \'JSAPI\', //交易类型
\'openid\' => $open_id, //用户标识
];
$params[\'sign\'] = $this->getSign($params);
$xmlData = arrayToXml($params);
$returnXml = postXml($xmlData, $this->unifiedOrderApiUrl);
$returnArr = xmlToArray($returnXml);
if ($returnArr[\'return_code\'] == \'FAIL\') {
$this->setError($returnArr[\'return_msg\']);
return \'\';
}
return $returnArr[\'prepay_id\'];
}
/**
* 获取签名
* @param $params
* @return string
*/
private function getSign($params)
{
if (!$params) {
return \'\';
}
//step1: 排序
ksort($params);
//step2：格式化参数
$paramUrl = formatParams($params, false);
//step3：追加key
$paramUrl = $paramUrl . \'&key=\' . $this->key;
//step4: md5加密
$paramUrl = md5($paramUrl);
//step5：转化为大写
$sign = strtoupper($paramUrl);
return $sign;
}
/*
* 查询支付结果
* @param $params
* @return string
*
* */
public function query($out_trade_no)
{
//对外暴露的退款接口
$result = $this->wxQueryApi($out_trade_no);
return $result;
}
/*
* 查询支付结果
* */
private function wxQueryApi($out_trade_no)
{
//通过微信api进行退款流程
$parma = array(
\'appid\' => $this->appId,
\'mch_id\' => $this->mchId,
\'nonce_str\' => encrypt(16),
\'out_trade_no\' => $out_trade_no,
);
$parma[\'sign\'] = $this->getSign($parma);
$xmldata = arrayToXml($parma);
$returnXml = postXml($xmldata, \'https://api.mch.weixin.qq.com/pay/orderquery\');
$result = xmlToArray($returnXml);
return $result;
}
/*
* 微信退款
* @param $params
* @return string
*
* */
public function refund($out_trade_no, $total_fee, $refund_fee, $out_refund_no)
{
//对外暴露的退款接口
$result = $this->wxRefundApi($out_trade_no, $total_fee, $refund_fee, $out_refund_no);
return $result;
}
/*
* 退款接口
* */
private function wxRefundApi($out_trade_no, $total_fee, $refund_fee, $out_refund_no)
{
//通过微信api进行退款流程
$parma = array(
\'appid\' => $this->appId,
\'mch_id\' => $this->mchId,
\'nonce_str\' => encrypt(16),
\'out_refund_no\' => $out_refund_no,
\'out_trade_no\' => $out_trade_no,
\'total_fee\' => priceyuantofen($total_fee),
\'refund_fee\' => priceyuantofen($refund_fee),
\'notify_url\' => (isset($_SERVER[\'REQUEST_SCHEME\']) ? ($_SERVER[\'REQUEST_SCHEME\'] . \'://\') : \'\') . $_SERVER[\'HTTP_HOST\'].\'/Api/Pay/notifyRefund.html\',
);
$parma[\'sign\'] = $this->getSign($parma);
$xmldata = arrayToXml($parma);
$xmlresult = curl_post_ssl(\'https://api.mch.weixin.qq.com/secapi/pay/refund\', $xmldata, \'/apiclient_cert.pem\', \'/apiclient_key.pem\');
$result = xmlToArray($xmlresult);
return $result;
}
/*
* 查看微信退款
* @param $params
* @return string
*
* */
public function seeRefund($order_number)
{
//对外暴露的退款接口
$result = $this->wxSeeRefundApi($order_number);
return $result;
}
/*
* 查看微信退款接口
* */
private function wxSeeRefundApi($order_number)
{
//通过微信api进行退款流程
$parma = array(
\'appid\' => $this->appId,
\'mch_id\' => $this->mchId,
\'nonce_str\' => encrypt(16),
\'out_trade_no\' => $order_number,
);
$parma[\'sign\'] = $this->getSign($parma);
$xmldata = arrayToXml($parma);
$returnXml = postXml($xmldata, \'https://api.mch.weixin.qq.com/pay/refundquery\');
$result = xmlToArray($returnXml);
return $result;
}
}
二、以上方法中所用的一些工具方法。
/**
* PHP精确计算 主要用于货币的计算用
* @param $n1 第一个数
* @param $symbol 计算符号 + - * / %
* @param $n2 第二个数
* @param string $scale 精度 默认为小数点后两位
* @return string
*/
function pricecalc($n1, $symbol, $n2, $scale = \'2\')
{
$res = "";
switch ($symbol) {
case "+"://加法
$res = bcadd($n1, $n2, $scale);
break;
case "-"://减法
$res = bcsub($n1, $n2, $scale);
break;
case "*"://乘法
$res = bcmul($n1, $n2, $scale);
break;
case "/"://除法
$res = bcdiv($n1, $n2, $scale);
break;
case "%"://求余、取模
$res = bcmod($n1, $n2, $scale);
break;
default:
$res = "";
break;
}
return $res;
}
/**
* 价格由元转分(用于微信支付单位转换)
* @param $price 金额
* @return int
*/
function priceyuantofen($price)
{
$price = intval(pricecalc(100, "*", $price));
return $price;
}
/**
* 价格由分转元
* @param $price 金额
* @return float
*/
function pricefentoyuan($price)
{
$price = pricecalc(priceformat($price), "/", 100);
return $price;
}
/**
* 价格格式化
*
* @param int $price
* @return string $price_format
*/
function priceformat($price)
{
$price_format = number_format($price, 2, \'.\', \'\');
return $price_format;
}
/**
* array to xml
* @param $arr
* @return string
*/
function arrayToXml($arr)
{
$xml = "<xml>";
foreach ($arr as $key => $val) {
if (is_array($val)) {
$xml .= "<" . $key . ">" . arrayToXml($val) . "</" . $key . ">";
} else {
$xml .= "<" . $key . ">" . $val . "</" . $key . ">";
}
}
$xml .= "</xml>";
return $xml;
}
/**
* xml to array
* @param $xml
* @return mixed
*/
function xmlToArray($xml)
{
//禁止引用外部xml实体
libxml_disable_entity_loader(true);
$xmlstring = simplexml_load_string($xml, \'SimpleXMLElement\', LIBXML_NOCDATA);
$val = json_decode(json_encode($xmlstring), true);
return $val;
}
/**
* 格式化参数 array to key1=valve1&key2=value2
* @param $params
* @param $url_encode
* @return string
*/
function formatParams($params, $url_encode)
{
if (!$params) {
return \'\';
}
$paramUrl = "";
ksort($params);
foreach ($params as $k => $v) {
if ($url_encode) {
$v = urlencode($v);
}
$paramUrl .= $k . "=" . $v . "&";
}
if (strlen($paramUrl) > 0) {
$paramUrl = substr($paramUrl, 0, strlen($paramUrl) - 1);
}
return $paramUrl;
}
/**
* curl post xml
* @param $xml 参数
* @param $url 请求地址
* @param int $second 设置超时
* @return mixed
*/
function postXml($xml, $url, $second = 60)
{
$ch = curl_init();
//设置超时
curl_setopt($ch, CURLOPT_TIMEOUT, $second);
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE); //严格校验
//设置header
curl_setopt($ch, CURLOPT_HEADER, FALSE);
//要求结果为字符串且输出到屏幕上
curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
//post提交方式
curl_setopt($ch, CURLOPT_POST, TRUE);
curl_setopt($ch, CURLOPT_POSTFIELDS, $xml);
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 20);
curl_setopt($ch, CURLOPT_TIMEOUT, 40);
set_time_limit(0);
//运行curl
$data = curl_exec($ch);
curl_close($ch);
return $data;
}
//需要使用证书的请求
//file_cert_pem,file_key_pem两个退款必须的文件
function curl_post_ssl($url, $vars, $file_cert_pem, $file_key_pem, $second = 30, $aHeader = array())
{
$ch = curl_init();
//超时时间
curl_setopt($ch, CURLOPT_TIMEOUT, $second);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
//这里设置代理，如果有的话
//curl_setopt($ch,CURLOPT_PROXY, \'10.206.30.98\');
//curl_setopt($ch,CURLOPT_PROXYPORT, 8080);
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
//以下两种方式需选择一种
//第一种方法，cert 与 key 分别属于两个.pem文件
//默认格式为PEM，可以注释
curl_setopt($ch, CURLOPT_SSLCERTTYPE, \'PEM\');
// curl_setopt($ch,CURLOPT_SSLCERT,getcwd().\'/cert.pem\');
curl_setopt($ch, CURLOPT_SSLCERT, __DIR__.$file_cert_pem);
//默认格式为PEM，可以注释
curl_setopt($ch, CURLOPT_SSLKEYTYPE, \'PEM\');
// curl_setopt($ch,CURLOPT_SSLKEY,getcwd().\'/private.pem\');
curl_setopt($ch, CURLOPT_SSLKEY, __DIR__.$file_key_pem);
//第二种方式，两个文件合成一个.pem文件
// curl_setopt($ch, CURLOPT_SSLCERT, getcwd() . \'/all.pem\');
//要求结果为字符串且输出到屏幕上
curl_setopt($ch,CURLOPT_RETURNTRANSFER,TRUE);
if (count($aHeader) >= 1) {
curl_setopt($ch, CURLOPT_HTTPHEADER, $aHeader);
}
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, $vars);
$data = curl_exec($ch);
if ($data) {
curl_close($ch);
return $data;
} else {
$error = curl_errno($ch);
// echo "call faild, errorCode:$error\n";
// echo "curl出错，错误码:$error";
curl_close($ch);
return false;
}
}
要说明的是退款接口wxRefundApi调用的curl_post_ssl方法需要传两个以pem结尾的文件，这两个文件需要传绝对路径，根据代码中的写法，只有把这两个文件放到curl_post_ssl所在文件同一级目录下面，才能正确的找到。
三、支付回调类。
<?php
/**
* Created by PhpStorm.
* User: 科技
* Date: 2020/4/26
* Time: 10:52
*/
namespace Api\Controller;
use Api\WxPayController;
use Common\Model\OrderModel;
class PayController
{
/**
* 状态 0已取消 1已下单 2已支付 3用户申请退款 4订单已完成 5商家同意退款 6微信平台接受退款异步返回申请成功 7异步返回退款申请失败 8统一下单异步返回支付失败 9退款成功 10统一下单异步返回成功
*/
const STATUS_WAITING = 1;
const STATUS_FAILED = 2;
const STATUS_SUCCESS = 3;
const STATUS_LOSE = 4;
const STATUS_OTHER = 5;
const STATUS_PROCESSING = 6;
/**
* 错误信息
* @var string
*/
public $errorInfo;
/**
* 小程序支付异步回调
*
*/
public function notifyPay()
{
$xml = file_get_contents(\'php://input\', \'r\');
$resData = xmlToArray($xml);
$wxPay = new WxPayController();
M(\'pay_log\')->add([\'type\'=>1,\'data\'=>json_encode($resData),\'create_time\'=>time()]);
if ($wxPay->checkNotifySign($resData)) {
$result = $this->updateNotifyPayOrder($resData[\'return_code\'], $resData[\'openid\'], $resData[\'out_trade_no\'], pricefentoyuan($resData[\'total_fee\']), $resData[\'transaction_id\'], $resData);
if ($result) {
$resStr = $wxPay->notifyReturnSuccess();
} else {
$resStr = $wxPay->notifyReturnFail($this->errorInfo);
}
} else {
$resStr = $wxPay->notifyReturnFail(\'签名验证失败\');
}
echo $resStr;
}
/**
* 支付成功修改数据库
* @param $result 支付状态
* @param $open_id open_id
* @param $out_trade_no 客户订单号
* @param $money 金额
* @param $wx_trade_no 微信支付订单号
* @param $data
* @return bool
* @throws \Exception
*/
public function updateNotifyPayOrder($result, $open_id, $out_trade_no, $money, $wx_trade_no, $data)
{
//记录异步通知日志
//订单查询
$orderInfo = (new orderModel())->getorderInfo([\'order_number\' => $out_trade_no], \'id,order_number,shop_id,pay_money,status,user_id\');
if (empty($orderInfo)) {
$this->errorInfo = \'订单不存在\';
return false;
}
//如果订单状态为成功直接返回
if (in_array($orderInfo[\'status\'],[2,10,4])) {
return true;
}
//订单支付状态为未处理
if ($orderInfo[\'status\'] == 1 || $orderInfo[\'status\'] == 8) {
//验证金额
if (bccomp($orderInfo[\'pay_money\'],$money,2)) {
$this->errorInfo = \'订单金额有误\';
return false;
}
//判断订单支付状态
if ($result == \'SUCCESS\') {
$model = new OrderModel();
//开启事务处理机制
$model->startTrans();
//修改订单状态为成功
$res_success = (new orderModel())->editOrder([\'status\' => 10], [\'id\' => $orderInfo[\'id\']]);
if ($res_success) {
//如果都成立就提交
$model->commit();
return true;
}else {
//先将原先的预处理进行回滚
$model->rollback();
$this->errorInfo = \'订单状态修改失败\';
return false;
}
} else {
//修改订单状态为支付失败
$res = (new orderModel())->editOrder([\'status\' => 8], [\'id\' => $orderInfo[\'id\']]);
if (!$res) {
$this->errorInfo = \'订单状态修改失败\';
return false;
}
}
}
$this->errorInfo = \'订单处理失败！\';
return false;
}
/**
* 小程序申请退款异步回调
*
*/
public function notifyRefund()
{
$xml = file_get_contents(\'php://input\', \'r\');
$resData = xmlToArray($xml);
$wxPay = new WxPayController();
M(\'pay_log\')->add([\'type\'=>2,\'data\'=>json_encode($resData),\'create_time\'=>time()]);
if ($wxPay->checkNotifySign($resData)) {
$result = $this->updateNotifyRefundOrder($resData[\'return_code\'], $resData[\'out_trade_no\'], pricefentoyuan($resData[\'total_fee\']), $resData[\'transaction_id\'], $resData);
if ($result) {
$resStr = $wxPay->notifyReturnSuccess();
} else {
$resStr = $wxPay->notifyReturnFail($this->errorInfo);
}
} else {
$resStr = $wxPay->notifyReturnFail(\'签名验证失败\');
}
echo $resStr;
}
/**
* 退款成功修改数据库
* @param $result 支付状态
* @param $open_id open_id
* @param $out_trade_no 客户订单号
* @param $money 金额
* @param $wx_trade_no 微信支付订单号
* @param $data
* @return bool
* @throws \Exception
*/
public function updateNotifyRefundOrder($result, $out_trade_no, $money, $wx_trade_no, $data)
{
//记录异步通知日志
//订单查询
$orderInfo = (new orderModel())->getorderInfo([\'order_number\' => $out_trade_no], \'id,order_number，pay_money,status,user_id\');
if (empty($orderInfo)) {
$this->errorInfo = \'订单不存在\';
return false;
}
//如果订单状态为成功直接返回
if (in_array($orderInfo[\'status\'],[5,6,4])) {
return true;
}
//订单支付状态为用户已经申请退款
if ($orderInfo[\'status\'] == 3 ||$orderInfo[\'status\'] == 7) {
//验证金额
if (bccomp($orderInfo[\'pay_money\'],$money,2)) {
$this->errorInfo = \'订单金额有误\';
return false;
}
//判断订单支付状态
if ($result == \'SUCCESS\') {
$model = new OrderModel();
//开启事务处理机制
$model->startTrans();
//修改订单状态为成功
$res_success = (new orderModel())->editOrder([\'status\' => 6], [\'id\' => $orderInfo[\'id\']]);
if ($res_success) {
//如果都成立就提交
$model->commit();
return true;
}else {
//先将原先的预处理进行回滚
$model->rollback();
$this->errorInfo = \'订单状态修改失败\';
return false;
}
} else {
//修改订单状态为退款申请失败
$res = (new orderModel())->editOrder([\'status\' => 7], [\'id\' => $orderInfo[\'id\']]);
if (!$res) {
$this->errorInfo = \'订单状态修改失败\';
return false;
}
}
}
$this->errorInfo = \'订单处理失败！\';
return false;
}
}
四、接口调用。
/**
* 订单支付，统一下单接口，获取支付签名
* @access public
* @param string $orderId 订单id
* @param string $token
* @return array
*/
public function pay()
{
try {
$orderInfo = $this->orderHandelCheck($this->data[\'orderId\']);
if ($orderInfo[\'status\'] != 1 ) {
$this->json(201, \'订单不是待支付状态\');
}
//调用支付类
$wxPay = new WxPayController();
//获取签名
$paySign = $wxPay->paySign($this->openid, $orderInfo[\'order_number\'], $orderInfo[\'pay_money\']);
if (!$paySign) {
$this->json(201, $wxPay->getError());
}
$this->json(200, \'请求成功\', $paySign);
} catch (\Exception $e) {
// $this->json($e->getMessage());
$this->json(0);
}
}
/**
* 查询订单支付结果，以进行下一步动作
* @access public
* @param int $orderId 订单id
* @param string $token
* @return array
*/
public function payResult()
{
try {
$orderInfo = $this->orderHandelCheck($this->data[\'orderId\']);
if (!in_array($orderInfo[\'status\'],[1,10])) {
if($orderInfo[\'status\']==8){
$this->json(201, \'统一下单接口返回失败\');
}
$this->json(201, \'订单不是待支付状态\');
}
//调用支付类
$wxPay = new WxPayController();
//获取查询结果
$query_res = $wxPay->query($orderInfo[\'order_number\']);
if ($query_res[\'return_code\']==\'SUCCESS\') { //请求成功
if ($query_res[\'result_code\']==\'SUCCESS\') { //订单接收成功
if ($query_res[\'trade_state\']==\'SUCCESS\') { //交易状态
$model = new OrderModel();
//开启事务处理机制
$model->startTrans();
$ModelThink = new \Think\Model(); // 实例化一个model对象 没有对应任何数据表
$sql = sprintf("SELECT `id`,`order_number`,`shop_id`,`create_time`,`pay_money`,`status` FROM `pre_order` WHERE `id` = %s FOR UPDATE ", $orderInfo[\'id\']);//查询语句
$orderInfo=$ModelThink->query($sql)[0];
//修改订单状态为成功
$res_success = (new orderModel())->editOrder([\'pay_status\' => 1, \'status\' => 2], [\'id\' => $orderInfo[\'id\']]);
if (!$res_success) {
//先将原先的预处理进行回滚
$model->rollback();
$this->json(201,\'订单状态修改失败\');
}
//保存账户余额表
$walletModel = new ShopWalletModel();
$shopWallet = $walletModel->getShopWalletInfo([\'shop_id\' => $orderInfo[\'shop_id\']], \'account\');
if ($shopWallet) {
if ($walletModel->editShopWallet([\'account\' => bcadd($shopWallet[\'account\'], $orderInfo[\'pay_money\'], 2)], [\'shop_id\' => $orderInfo[\'shop_id\']])) { //修改钱包金额
if ((new ShopWalletFlowModel())->addShopWalletFlow([\'shop_id\' => $orderInfo[\'shop_id\'], \'account\' => $orderInfo[\'pay_money\'], \'create_time\' => time(), \'order_id\' => $orderInfo[\'id\']])) { //添加钱包流水
//如果都成立就提交
$model->commit();
$this->json(200, \'支付成功\');
} else {
//先将原先的预处理进行回滚
$model->rollback();
$this->json(201,\'商户钱包流水添加失败！\');
}
} else {
//先将原先的预处理进行回滚
$model->rollback();
$this->json(201,\'账户信息保存失败！\');
}
} else {
//先将原先的预处理进行回滚
$model->rollback();
$this->json(201,\'商户钱包有误！\');
}
}elseif($query_res[\'trade_state\']==\'REFUND\'){
$this->json(201, \'转入退款\');
}elseif($query_res[\'trade_state\']==\'NOTPAY\'){
$this->json(201, \'未支付\');
}elseif($query_res[\'trade_state\']==\'CLOSED\'){
$this->json(201, \'已关闭\');
}elseif($query_res[\'trade_state\']==\'USERPAYING\'){
$this->json(201, \'用户支付中\');
}elseif($query_res[\'trade_state\']==\'PAYERROR\'){
$this->json(201, \'支付失败\');
}else{
$this->json(201, \'交易状态未知\');
}
}else{
$this->json(201, $query_res[\'err_code_des\']);
}
}else{
$this->json(201, $query_res[\'return_msg\']);
}
} catch (\Exception $e) {
$this->json(0);
}
}
/**
* 请求退款
* @access public
* @param string $orderId 订单id
* @param string $token
* @return array
*/
public function refund(){
$wxPay = new WxPayController();
//申请退款
$res_refund = $wxPay->refund($Order_info[\'order_number\'], $Order_info[\'pay_money\'], $Order_info[\'pay_money\'], $Order_info[\'refund_number\']);
if ($res_refund[\'return_code\'] == \'SUCCESS\') { //接口请求成功
if ($res_refund[\'result_code\'] == \'SUCCESS\') { //退款申请接受成功
if ($model->editOrder([\'status\' => 5, \'Refund\' => [\'status\' => 2, \'handle_time\' => time()]], [\'id\' => $id], \'Refund\')) {
$this->success("提交成功,等待微信平台审核通过！", \'\', true);
}else{
$this->error("修改订单状态失败,请尽快联系管理员处理！！！", \'\', true);
}
} else {
$this->error("申请失败，微信接受退款失败，" . $res_refund[\'err_code_des\'], \'\', true);
}
}else{
$this->error("请求失败，" . $res_refund[\'return_msg\'], \'\', true);
}
}
/**
* 查询订单退款结果，以进行下一步动作
* @access public
* @param int $orderId 订单id
* @param string $token
* @return array
*/
function checkRefund(){
$wxPay = new WxPayController();
//退款进度
$see_res = $wxPay->seeRefund($order_info[\'order_number\']);
if($see_res[\'return_code\']==\'SUCCESS\'){ //请求成功
if($see_res[\'result_code\']==\'SUCCESS\'){ //退款申请接收成功
if($see_res[\'refund_status_0\']==\'SUCCESS\'){ //退款状态
$model = new OrderModel();
//由于要计算流水，开启事务
//开启事务处理机制
$model->startTrans();
$ModelThink = new \Think\Model(); // 实例化一个model对象 没有对应任何数据表
$sql = sprintf("SELECT `id`,`order_number`,`shop_id`,`create_time`,`pay_money`,`status` FROM `pre_order` WHERE `id` = %s FOR UPDATE ", $order_info[\'id\']);//查询语句
$order_info=$ModelThink->query($sql)[0];
if ($model->editOrder([\'status\' => 9], [\'id\' => $id])) {
$walletModel = new ShopWalletModel();
$shopWallet = $walletModel->getShopWalletInfo([\'shop_id\' => $order_info[\'shop_id\']], \'account\');
if ($shopWallet) {
if ($walletModel->editShopWallet([\'account\' => bcsub($shopWallet[\'account\'], $order_info[\'pay_money\'], 2)], [\'shop_id\' => $order_info[\'shop_id\']])) {
if ((new ShopWalletFlowModel())->addShopWalletFlow([\'shop_id\' => $order_info[\'shop_id\'], \'account\' => -$order_info[\'pay_money\'], \'create_time\' => time(), \'order_id\' => $id, \'scene\' => 2])) {
//如果都成立就提交
$model->commit();
$this->success("退款成功！", \'\', true);
} else {
//先将原先的预处理进行回滚
$model->rollback();
$this->error("流水添加失败,请重试或尽快联系管理员处理！！！", \'\', true);
}
} else {
//先将原先的预处理进行回滚
$model->rollback();
$this->error("钱包操作失败,请重试或尽快联系管理员处理！！！", \'\', true);
}
} else {
//先将原先的预处理进行回滚
$model->rollback();
$this->error("钱包有误,请重试或尽快联系管理员处理！！！", \'\', true);
}
} else {
//先将原先的预处理进行回滚
$model->rollback();
$this->error("修改订单状态失败！请重试或尽快联系管理员处理！！", \'\', true);
}
}elseif($see_res[\'refund_status_0\']==\'REFUNDCLOSE\'){
$this->success("退款关闭,请尽快联系管理员处理！！！", \'\', true);
}elseif($see_res[\'refund_status_0\']==\'PROCESSING\'){
$this->success("退款处理中！", \'\', true);
}elseif($see_res[\'refund_status_0\']==\'CHANGE\'){
$this->success("退款退款异常,请尽快联系管理员处理！！！", \'\', true);
}
}else{
$this->error(\'退款申请接收失败，\'.$see_res[\'err_code_des\'], \'\', true);
}
}else{
$this->error(\'请求失败，\'.$see_res[\'return_msg\'], \'\', true);
}
}
接口使用的返回方法：
protected function json($code=0,$message=\'\',$data=[])
{
if (empty($message)) {
//通用提示信息
switch ($code) {
case 200:
$message = \'请求成功\';
break;
case 0:
$message = \'请求失败\';
break;
case -2:
$message = \'参数缺失\';
break;
default:
$message = $message;
break;
}
}
return $this -> ajaxReturn([\'code\' => $code, \'message\' => $message, \'data\' => $data]);
}