397 lines
12 KiB
PHP
397 lines
12 KiB
PHP
|
<?php
|
|||
|
|
// +----------------------------------------------------------------------
|
|||
|
|
// | likeadmin快速开发前后端分离管理后台（PHP版）
|
|||
|
|
// +----------------------------------------------------------------------
|
|||
|
|
// | 欢迎阅读学习系统程序代码，建议反馈是我们前进的动力
|
|||
|
|
// | 开源版本可自由商用，可去除界面版权logo
|
|||
|
|
// | gitee下载：https://gitee.com/likeshop_gitee/likeadmin
|
|||
|
|
// | github下载：https://github.com/likeshop-github/likeadmin
|
|||
|
|
// | 访问官网：https://www.likeadmin.cn
|
|||
|
|
// | likeadmin团队 版权所有 拥有最终解释权
|
|||
|
|
// +----------------------------------------------------------------------
|
|||
|
|
// | author: likeadminTeam
|
|||
|
|
// +----------------------------------------------------------------------
|
|||
|
|
|
|||
|
|
|
|||
|
|
namespace app\common\service\pay;
|
|||
|
|
|
|||
|
|
|
|||
|
|
use app\common\enum\PayEnum;
|
|||
|
|
use app\common\enum\user\UserTerminalEnum;
|
|||
|
|
use app\common\logic\PayNotifyLogic;
|
|||
|
|
use app\common\model\recharge\RechargeOrder;
|
|||
|
|
use app\common\model\user\UserAuth;
|
|||
|
|
use app\common\service\wechat\WeChatConfigService;
|
|||
|
|
use EasyWeChat\Pay\Application;
|
|||
|
|
use EasyWeChat\Pay\Message;
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 微信支付
|
|||
|
|
* Class WeChatPayService
|
|||
|
|
* @package app\common\server
|
|||
|
|
*/
|
|||
|
|
class WeChatPayService extends BasePayService
|
|||
|
|
{
|
|||
|
|
/**
|
|||
|
|
* 授权信息
|
|||
|
|
* @var UserAuth|array|\think\Model
|
|||
|
|
*/
|
|||
|
|
protected $auth;
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 微信配置
|
|||
|
|
* @var
|
|||
|
|
*/
|
|||
|
|
protected $config;
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* easyWeChat实例
|
|||
|
|
* @var
|
|||
|
|
*/
|
|||
|
|
protected $app;
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 当前使用客户端
|
|||
|
|
* @var
|
|||
|
|
*/
|
|||
|
|
protected $terminal;
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 初始化微信支付配置
|
|||
|
|
* @param $terminal //用户终端
|
|||
|
|
* @param null $userId //用户id(获取授权openid)
|
|||
|
|
*/
|
|||
|
|
public function __construct($terminal, $userId = null)
|
|||
|
|
{
|
|||
|
|
$this->terminal = $terminal;
|
|||
|
|
$this->config = WeChatConfigService::getPayConfigByTerminal($terminal);
|
|||
|
|
$this->app = new Application($this->config);
|
|||
|
|
if ($userId !== null) {
|
|||
|
|
$this->auth = UserAuth::where(['user_id' => $userId, 'terminal' => $terminal])->findOrEmpty();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @notes 发起微信支付统一下单
|
|||
|
|
* @param $from
|
|||
|
|
* @param $order
|
|||
|
|
* @return array|false|string
|
|||
|
|
* @author 段誉
|
|||
|
|
* @date 2021/8/4 15:05
|
|||
|
|
*/
|
|||
|
|
public function pay($from, $order)
|
|||
|
|
{
|
|||
|
|
try {
|
|||
|
|
switch ($this->terminal) {
|
|||
|
|
case UserTerminalEnum::WECHAT_MMP:
|
|||
|
|
$config = WeChatConfigService::getMnpConfig();
|
|||
|
|
$result = $this->jsapiPay($from, $order, $config['app_id']);
|
|||
|
|
break;
|
|||
|
|
case UserTerminalEnum::WECHAT_OA:
|
|||
|
|
$config = WeChatConfigService::getOaConfig();
|
|||
|
|
$result = $this->jsapiPay($from, $order, $config['app_id']);
|
|||
|
|
break;
|
|||
|
|
case UserTerminalEnum::IOS:
|
|||
|
|
case UserTerminalEnum::ANDROID:
|
|||
|
|
$config = WeChatConfigService::getOpConfig();
|
|||
|
|
$result = $this->appPay($from, $order, $config['app_id']);
|
|||
|
|
break;
|
|||
|
|
case UserTerminalEnum::H5:
|
|||
|
|
$config = WeChatConfigService::getOaConfig();
|
|||
|
|
$result = $this->mwebPay($from, $order, $config['app_id']);
|
|||
|
|
break;
|
|||
|
|
case UserTerminalEnum::PC:
|
|||
|
|
$config = WeChatConfigService::getOaConfig();
|
|||
|
|
$result = $this->nativePay($from, $order, $config['app_id']);
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
throw new \Exception('支付方式错误');
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return [
|
|||
|
|
'config' => $result,
|
|||
|
|
'pay_way' => PayEnum::WECHAT_PAY
|
|||
|
|
];
|
|||
|
|
} catch (\Exception $e) {
|
|||
|
|
$this->setError($e->getMessage());
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @notes jsapiPay
|
|||
|
|
* @param $from
|
|||
|
|
* @param $order
|
|||
|
|
* @param $appId
|
|||
|
|
* @return mixed
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidArgumentException
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
|
|||
|
|
* @author 段誉
|
|||
|
|
* @date 2023/2/28 12:12
|
|||
|
|
*/
|
|||
|
|
public function jsapiPay($from, $order, $appId)
|
|||
|
|
{
|
|||
|
|
$response = $this->app->getClient()->postJson("v3/pay/transactions/jsapi", [
|
|||
|
|
"appid" => $appId,
|
|||
|
|
"mchid" => $this->config['mch_id'],
|
|||
|
|
"description" => $this->payDesc($from),
|
|||
|
|
"out_trade_no" => $order['pay_sn'],
|
|||
|
|
"notify_url" => $this->config['notify_url'],
|
|||
|
|
"amount" => [
|
|||
|
|
"total" => intval($order['order_amount'] * 100),
|
|||
|
|
],
|
|||
|
|
"payer" => [
|
|||
|
|
"openid" => $this->auth['openid']
|
|||
|
|
],
|
|||
|
|
'attach' => $from
|
|||
|
|
]);
|
|||
|
|
|
|||
|
|
$result = $response->toArray(false);
|
|||
|
|
$this->checkResultFail($result);
|
|||
|
|
return $this->getPrepayConfig($result['prepay_id'], $appId);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @notes 网站native
|
|||
|
|
* @param $from
|
|||
|
|
* @param $order
|
|||
|
|
* @param $appId
|
|||
|
|
* @return mixed
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidArgumentException
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
|
|||
|
|
* @author 段誉
|
|||
|
|
* @date 2023/2/28 12:12
|
|||
|
|
*/
|
|||
|
|
public function nativePay($from, $order, $appId)
|
|||
|
|
{
|
|||
|
|
$response = $this->app->getClient()->postJson('v3/pay/transactions/native', [
|
|||
|
|
'appid' => $appId,
|
|||
|
|
'mchid' => $this->config['mch_id'],
|
|||
|
|
'description' => $this->payDesc($from),
|
|||
|
|
'out_trade_no' => $order['pay_sn'],
|
|||
|
|
'notify_url' => $this->config['notify_url'],
|
|||
|
|
'amount' => [
|
|||
|
|
'total' => intval($order['order_amount'] * 100),
|
|||
|
|
],
|
|||
|
|
'attach' => $from
|
|||
|
|
]);
|
|||
|
|
$result = $response->toArray(false);
|
|||
|
|
$this->checkResultFail($result);
|
|||
|
|
return $result['code_url'];
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @notes appPay
|
|||
|
|
* @param $from
|
|||
|
|
* @param $order
|
|||
|
|
* @param $appId
|
|||
|
|
* @return mixed
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidArgumentException
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
|
|||
|
|
* @author 段誉
|
|||
|
|
* @date 2023/2/28 12:12
|
|||
|
|
*/
|
|||
|
|
public function appPay($from, $order, $appId)
|
|||
|
|
{
|
|||
|
|
$response = $this->app->getClient()->postJson('v3/pay/transactions/app', [
|
|||
|
|
'appid' => $appId,
|
|||
|
|
'mchid' => $this->config['mch_id'],
|
|||
|
|
'description' => $this->payDesc($from),
|
|||
|
|
'out_trade_no' => $order['pay_sn'],
|
|||
|
|
'notify_url' => $this->config['notify_url'],
|
|||
|
|
'amount' => [
|
|||
|
|
'total' => intval($order['order_amount'] * 100),
|
|||
|
|
],
|
|||
|
|
'attach' => $from
|
|||
|
|
]);
|
|||
|
|
$result = $response->toArray(false);
|
|||
|
|
$this->checkResultFail($result);
|
|||
|
|
return $result['prepay_id'];
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @notes h5
|
|||
|
|
* @param $from
|
|||
|
|
* @param $order
|
|||
|
|
* @param $appId
|
|||
|
|
* @param $redirectUrl
|
|||
|
|
* @return mixed
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidArgumentException
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
|
|||
|
|
* @author 段誉
|
|||
|
|
* @date 2023/2/28 12:13
|
|||
|
|
*/
|
|||
|
|
public function mwebPay($from, $order, $appId)
|
|||
|
|
{
|
|||
|
|
$response = $this->app->getClient()->postJson('v3/pay/transactions/h5', [
|
|||
|
|
'appid' => $appId,
|
|||
|
|
'mchid' => $this->config['mch_id'],
|
|||
|
|
'description' => $this->payDesc($from),
|
|||
|
|
'out_trade_no' => $order['pay_sn'],
|
|||
|
|
'notify_url' => $this->config['notify_url'],
|
|||
|
|
'amount' => [
|
|||
|
|
'total' => intval($order['order_amount'] * 100),
|
|||
|
|
],
|
|||
|
|
'attach' => $from,
|
|||
|
|
'scene_info' => [
|
|||
|
|
'payer_client_ip' => request()->ip(),
|
|||
|
|
'h5_info' => [
|
|||
|
|
'type' => 'Wap',
|
|||
|
|
]
|
|||
|
|
]
|
|||
|
|
]);
|
|||
|
|
$result = $response->toArray(false);
|
|||
|
|
$this->checkResultFail($result);
|
|||
|
|
|
|||
|
|
$domain = request()->domain();
|
|||
|
|
if (!empty(env('project.test_web_domain')) && env('APP_DEBUG')) {
|
|||
|
|
$domain = env('project.test_web_domain');
|
|||
|
|
}
|
|||
|
|
$redirectUrl = $domain . '/mobile'. $order['redirect_url'] .'?id=' . $order['id'] . '&from='. $from . '&checkPay=true';
|
|||
|
|
return $result['h5_url'] . '&redirect_url=' . urlencode($redirectUrl);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @notes 退款
|
|||
|
|
* @param array $refundData
|
|||
|
|
* @return mixed
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidArgumentException
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
|
|||
|
|
* @author 段誉
|
|||
|
|
* @date 2023/2/28 16:53
|
|||
|
|
*/
|
|||
|
|
public function refund(array $refundData)
|
|||
|
|
{
|
|||
|
|
$response = $this->app->getClient()->postJson('v3/refund/domestic/refunds', [
|
|||
|
|
'transaction_id' => $refundData['transaction_id'],
|
|||
|
|
'out_refund_no' => $refundData['refund_sn'],
|
|||
|
|
'amount' => [
|
|||
|
|
'refund' => intval($refundData['refund_amount'] * 100),
|
|||
|
|
'total' => intval($refundData['total_amount'] * 100),
|
|||
|
|
'currency' => 'CNY',
|
|||
|
|
]
|
|||
|
|
]);
|
|||
|
|
$result = $response->toArray(false);
|
|||
|
|
$this->checkResultFail($result);
|
|||
|
|
return $result;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @notes 查询退款
|
|||
|
|
* @param $refundSn
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidArgumentException
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
|
|||
|
|
* @author 段誉
|
|||
|
|
* @date 2023/3/1 11:16
|
|||
|
|
*/
|
|||
|
|
public function queryRefund($refundSn)
|
|||
|
|
{
|
|||
|
|
$response = $this->app->getClient()->get("v3/refund/domestic/refunds/{$refundSn}");
|
|||
|
|
return $response->toArray(false);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @notes 支付描述
|
|||
|
|
* @param $from
|
|||
|
|
* @return string
|
|||
|
|
* @author 段誉
|
|||
|
|
* @date 2023/2/27 17:54
|
|||
|
|
*/
|
|||
|
|
public function payDesc($from)
|
|||
|
|
{
|
|||
|
|
$desc = [
|
|||
|
|
'order' => '商品',
|
|||
|
|
'recharge' => '充值',
|
|||
|
|
];
|
|||
|
|
return $desc[$from] ?? '商品';
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @notes 捕获错误
|
|||
|
|
* @param $result
|
|||
|
|
* @throws \Exception
|
|||
|
|
* @author 段誉
|
|||
|
|
* @date 2023/2/28 12:09
|
|||
|
|
*/
|
|||
|
|
public function checkResultFail($result)
|
|||
|
|
{
|
|||
|
|
if (!empty($result['code']) || !empty($result['message'])) {
|
|||
|
|
throw new \Exception('微信:'. $result['code'] . '-' . $result['message']);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @notes 预支付配置
|
|||
|
|
* @param $prepayId
|
|||
|
|
* @param $appId
|
|||
|
|
* @return mixed[]
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidArgumentException
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
|
|||
|
|
* @author 段誉
|
|||
|
|
* @date 2023/2/28 17:38
|
|||
|
|
*/
|
|||
|
|
public function getPrepayConfig($prepayId, $appId)
|
|||
|
|
{
|
|||
|
|
return $this->app->getUtils()->buildBridgeConfig($prepayId, $appId);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @notes 支付回调
|
|||
|
|
* @return \Psr\Http\Message\ResponseInterface
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\InvalidArgumentException
|
|||
|
|
* @throws \EasyWeChat\Kernel\Exceptions\RuntimeException
|
|||
|
|
* @throws \ReflectionException
|
|||
|
|
* @throws \Throwable
|
|||
|
|
* @author 段誉
|
|||
|
|
* @date 2023/2/28 14:20
|
|||
|
|
*/
|
|||
|
|
public function notify()
|
|||
|
|
{
|
|||
|
|
$server = $this->app->getServer();
|
|||
|
|
// 支付通知
|
|||
|
|
$server->handlePaid(function (Message $message) {
|
|||
|
|
if ($message['trade_state'] === 'SUCCESS') {
|
|||
|
|
$extra['transaction_id'] = $message['transaction_id'];
|
|||
|
|
$attach = $message['attach'];
|
|||
|
|
$message['out_trade_no'] = mb_substr($message['out_trade_no'], 0, 18);
|
|||
|
|
switch ($attach) {
|
|||
|
|
case 'recharge':
|
|||
|
|
$order = RechargeOrder::where(['sn' => $message['out_trade_no']])->findOrEmpty();
|
|||
|
|
if($order->isEmpty() || $order->pay_status == PayEnum::ISPAID) {
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
PayNotifyLogic::handle('recharge', $message['out_trade_no'], $extra);
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return true;
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
// 退款通知
|
|||
|
|
$server->handleRefunded(function (Message $message) {
|
|||
|
|
return true;
|
|||
|
|
});
|
|||
|
|
return $server->serve();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|