656 lines
26 KiB
PHP
656 lines
26 KiB
PHP
<?php
|
||
/**
|
||
* Created by PhpStorm.
|
||
* Author:
|
||
* Date: 2017/3/17
|
||
* Time: 下午12:00
|
||
*/
|
||
|
||
namespace app\common\services;
|
||
|
||
use app\common\events\payment\ChargeComplatedEvent;
|
||
use app\common\exceptions\AppException;
|
||
use app\common\exceptions\ShopException;
|
||
use app\common\facades\EasyWeChat;
|
||
use app\common\helpers\Client;
|
||
use app\common\helpers\Url;
|
||
use app\common\models\McMappingFans;
|
||
use app\common\models\Member;
|
||
use app\common\models\OrderPay;
|
||
use app\common\models\PayOrder;
|
||
use app\common\models\PayType;
|
||
use app\common\models\WechatWithdrawLog;
|
||
use app\common\services\finance\Withdraw;
|
||
use app\common\services\payment\WechatMinPay;
|
||
use app\common\services\wechatApiV3\ApiV3Status;
|
||
use app\frontend\modules\member\services\factory\MemberFactory;
|
||
use app\frontend\modules\order\services\OrderPaySuccessService;
|
||
use app\frontend\modules\order\services\OrderService;
|
||
use Yunshop\WechatTrade\services\AddOrderService;
|
||
|
||
class WechatPay extends Pay
|
||
{
|
||
private $pay_type;
|
||
private static $attach_type = 'account';
|
||
|
||
public function __construct()
|
||
{
|
||
$this->pay_type = config('app.pay_type');
|
||
}
|
||
|
||
public function doPay($data = [], $payType = 1)
|
||
{
|
||
|
||
$min_client_type = \YunShop::request()->client_type;
|
||
if ($min_client_type && $min_client_type == 2) {
|
||
return (new WechatMinPay())->doPay($data);
|
||
|
||
}
|
||
|
||
|
||
$client_type = null;
|
||
$text = $data['extra']['type'] == 1 ? '支付' : '充值';
|
||
$op = '微信订单' . $text . ' 订单号：' . $data['order_no'];
|
||
$pay_type_name = PayType::get_pay_type_name($payType);
|
||
$pay_order_model = $this->log($data['extra']['type'], $pay_type_name, $data['amount'], $op, $data['order_no'], Pay::ORDER_STATUS_NON, \YunShop::app()->getMemberId());
|
||
|
||
if (empty(\YunShop::app()->getMemberId())) {
|
||
throw new AppException('无法获取用户ID');
|
||
}
|
||
|
||
if (\YunShop::request()->client_type) {
|
||
$client_type = \YunShop::request()->client_type;
|
||
} else {
|
||
$client_type = $payType;
|
||
}
|
||
|
||
$openid = Member::getOpenIdForType(\YunShop::app()->getMemberId(), $client_type);
|
||
\Log::debug('-----pay_member_id-----'. \YunShop::app()->getMemberId());
|
||
//不同支付类型选择参数
|
||
$pay = $this->payParams($payType);
|
||
|
||
if (empty($pay['weixin_mchid']) || empty($pay['weixin_apisecret'])
|
||
|| empty($pay['weixin_appid']) || empty($pay['weixin_secret'])) {
|
||
|
||
throw new AppException('没有设定支付参数');
|
||
}
|
||
|
||
$notify_url = Url::shopSchemeUrl('payment/wechat/notifyUrl.php');
|
||
$payment = $this->getEasyWeChatApp($pay, $notify_url);
|
||
|
||
|
||
//支付方式不等于微信app
|
||
if (in_array($payType, [PayFactory::PAY_APP_WEACHAT, PayFactory::WECHAT_CPS_APP_PAY])) {
|
||
$data['trade_type'] = 'APP';
|
||
} else {
|
||
$data['trade_type'] = 'JSAPI';
|
||
}
|
||
|
||
$order = self::getEasyWeChatOrder($data, $openid, $pay_order_model,$payType);
|
||
|
||
$prepayId = null;
|
||
|
||
//支付方式不等于微信app
|
||
if ($payType == PayFactory::PAY_APP_WEACHAT) {
|
||
return true;
|
||
} else {
|
||
$result = $payment->order->unify($order);
|
||
\Log::debug('预下单', $result);
|
||
if ($result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS'){
|
||
$prepayId = $result['prepay_id'];
|
||
|
||
$this->changeOrderStatus($pay_order_model, Pay::ORDER_STATUS_WAITPAY,'');
|
||
} elseif ($result['return_code'] == 'SUCCESS') {
|
||
throw new AppException($result['err_code_des']);
|
||
} else {
|
||
throw new AppException($result['return_msg']);
|
||
}
|
||
$config = $payment->jssdk->sdkConfig($prepayId);
|
||
$config['appId'] = $pay['weixin_appid'];
|
||
$config['prepayId'] = $prepayId;
|
||
|
||
if($data['trade_type'] == 'APP'){
|
||
$config['partnerid'] = $pay['weixin_mchid'] ? : '';
|
||
}
|
||
$js['appId'] = $config['appId'];
|
||
|
||
return ['config'=>$config, 'js'=>json_encode($js)];
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 微信退款
|
||
*
|
||
* @param 订单号 $out_trade_no
|
||
* @param 订单总金额 $totalmoney
|
||
* @param 退款金额 $refundmoney
|
||
* @return array
|
||
*/
|
||
public function doRefund($out_trade_no, $totalmoney, $refundmoney)
|
||
{
|
||
$out_refund_no = $this->setUniacidNo(\YunShop::app()->uniacid);
|
||
$op = '微信退款 订单号：' . $out_trade_no . '退款单号：' . $out_refund_no . '退款总金额：' . $totalmoney;
|
||
if (empty($out_trade_no)) {
|
||
throw new AppException('参数错误');
|
||
}
|
||
$pay_type_id = OrderPay::get_paysn_by_pay_type_id($out_trade_no);
|
||
$pay_type_name = PayType::get_pay_type_name($pay_type_id);
|
||
$pay_order_model = $this->refundlog(Pay::PAY_TYPE_REFUND, $pay_type_name, $refundmoney, $op, $out_trade_no, Pay::ORDER_STATUS_NON, 0);
|
||
//app退款查询app配置中的微信支付信息
|
||
if ($pay_type_id == PayFactory::PAY_APP_WEACHAT) {
|
||
$pay = \Setting::get('shop_app.pay');
|
||
} else {
|
||
$pay = $this->payParams($pay_type_id);
|
||
}
|
||
|
||
|
||
if (empty($pay['weixin_mchid']) || empty($pay['weixin_apisecret'])) {
|
||
throw new AppException('没有设定支付参数');
|
||
}
|
||
|
||
if (empty($pay['weixin_cert']) || empty($pay['weixin_key'])) {
|
||
throw new AppException('未上传完整的微信支付证书，请到【系统设置】->【支付方式】中上传!');
|
||
}
|
||
|
||
|
||
|
||
$notify_url = '';
|
||
$payment = $this->getEasyWeChatApp($pay, $notify_url);
|
||
|
||
try {
|
||
$totalmoney = bcmul($totalmoney, 100,0);
|
||
$refundmoney = bcmul($refundmoney, 100,0);
|
||
$result = $payment->refund->byOutTradeNumber($out_trade_no, $out_refund_no, $totalmoney, $refundmoney);
|
||
} catch (\Exception $e) {
|
||
\Log::debug('---微信退款接口请求错误---', $e->getMessage());
|
||
|
||
throw new AppException('微信接口错误:' . $e->getMessage());
|
||
}
|
||
|
||
$this->payResponseDataLog($out_trade_no, '微信退款', json_encode($result));
|
||
|
||
//微信申请退款失败
|
||
if (isset($result['result_code']) && strtoupper($result['result_code']) == 'FAIL') {
|
||
\Log::debug('---微信退款申请错误---', $result);
|
||
throw new AppException('微信退款申请错误:'.$result['err_code'] . '-' . $result['err_code_des']);
|
||
}
|
||
|
||
$status = $this->queryRefund($payment, $out_trade_no);
|
||
\Log::debug('---退款状态---', [$status]);
|
||
if ($status == 'PROCESSING' || $status == 'SUCCESS' || ($status == 'fail' && $result->refund_id)){
|
||
$this->changeOrderStatus($pay_order_model, Pay::ORDER_STATUS_COMPLETE, $result['transaction_id']);
|
||
return true;
|
||
} else {
|
||
\Log::debug('---微信退款接口返回错误---', $result);
|
||
|
||
throw new AppException('微信接口错误:'.$result['return_msg'] . '-' . $result['err_code_des'] . '/' . $status);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 微信提现
|
||
*
|
||
* @param 提现者用户ID $member_id
|
||
* @param 提现金额 $money
|
||
* @param string $desc
|
||
* @param int $type
|
||
* @param int $withdraw_type 0商城提现1供应商提现
|
||
* @return array
|
||
*/
|
||
public function doWithdraw($member_id, $out_trade_no, $money, $desc='', $type=1,$withdraw_type = 0)
|
||
{
|
||
//判断是否使用新版V3接口
|
||
$income_set = \Setting::get('shop.pay');
|
||
if ($type == 1 && $income_set['weixin_apiv3']) {//使用新版V3接口并且是打款到钱包
|
||
return $this->doWithdrawV3($member_id, $out_trade_no, $money, $desc, $type,$withdraw_type);
|
||
}
|
||
|
||
//$out_trade_no = $this->setUniacidNo(\YunShop::app()->uniacid);
|
||
|
||
$op = '微信钱包提现 订单号：' . $out_trade_no . '提现金额：' . $money;
|
||
$pay_order_model = $this->withdrawlog(Pay::PAY_TYPE_WITHDRAW, $this->pay_type[Pay::PAY_MODE_WECHAT], $money, $op, $out_trade_no, Pay::ORDER_STATUS_NON, $member_id);
|
||
|
||
$pay = $this->payParams($type);
|
||
|
||
if (empty($pay['weixin_mchid']) || empty($pay['weixin_apisecret'])) {
|
||
throw new AppException('没有设定支付参数');
|
||
}
|
||
|
||
if (empty($pay['weixin_cert']) || empty($pay['weixin_key'])) {
|
||
throw new AppException('\'未上传完整的微信支付证书，请到【系统设置】->【支付方式】中上传!\'');
|
||
}
|
||
if (\YunShop::request()->type) {
|
||
$client_type = \YunShop::request()->type;
|
||
} else {
|
||
$client_type = $type;
|
||
}
|
||
|
||
$openid = Member::getOpenIdForType($member_id, $client_type);
|
||
if (empty($openid)) {
|
||
throw new AppException('提现用户不存在');
|
||
}
|
||
// $mc_mapping_fans_model = McMappingFans::getFansById($member_id);
|
||
//
|
||
// if ($mc_mapping_fans_model) {
|
||
// $openid = $mc_mapping_fans_model->openid;
|
||
// } else {
|
||
// throw new AppException('提现用户不存在');
|
||
// }
|
||
|
||
$notify_url = '';
|
||
$app = $this->getEasyWeChatApp($pay, $notify_url);
|
||
if ($type == 1) {//钱包
|
||
$merchantPay = $app->transfer;
|
||
|
||
$merchantPayData = [
|
||
'partner_trade_no' => empty($out_trade_no) ? time() . Client::random(4, true) : $out_trade_no,
|
||
'openid' => $openid,
|
||
'check_name' => 'NO_CHECK',
|
||
'amount' => $money * 100,
|
||
'desc' => empty($desc) ? '佣金提现' : $desc,
|
||
'spbill_create_ip' => self::getClientIP(),
|
||
];
|
||
|
||
//请求数据日志
|
||
$this->payRequestDataLog($pay_order_model->id, $pay_order_model->type,
|
||
$pay_order_model->type, json_encode($merchantPayData));
|
||
|
||
$pay_result = $merchantPay->toBalance($merchantPayData);
|
||
|
||
if (isset($pay_result['partner_trade_no'])) {
|
||
$result = $merchantPay->queryBalanceOrder($pay_result['partner_trade_no']);
|
||
|
||
if ($result['result_code'] == 'FAIL') {
|
||
$result = $pay_result;
|
||
}
|
||
} else {
|
||
$result = $pay_result;
|
||
}
|
||
|
||
|
||
} else {//红包
|
||
$luckyMoney = $app->redpack;
|
||
|
||
$luckyMoneyData = [
|
||
'mch_billno' => $pay['weixin_mchid'] . date('YmdHis') . rand(1000, 9999),
|
||
'send_name' => \YunShop::app()->account['name'],
|
||
're_openid' => $openid,
|
||
'total_num' => 1,
|
||
'total_amount' => $money * 100,
|
||
'wishing' => empty($desc) ? '佣金提现红包' : $desc,
|
||
'client_ip' => self::getClientIP(),
|
||
'act_name' => empty($act_name) ? '佣金提现红包' : $act_name,
|
||
'remark' => empty($remark) ? '佣金提现红包' : $remark,
|
||
];
|
||
|
||
//请求数据日志
|
||
$this->payRequestDataLog($pay_order_model->id, $pay_order_model->type,
|
||
$pay_order_model->type, json_encode($luckyMoneyData));
|
||
|
||
$pay_result = $luckyMoney->sendNormal($luckyMoneyData);
|
||
|
||
if (isset($pay_result['mch_billno'])) {
|
||
$result = $luckyMoney->info($pay_result['mch_billno']);
|
||
|
||
if ($result['result_code'] == 'FAIL') {
|
||
$result = $pay_result;
|
||
}
|
||
} else {
|
||
$result = $pay_result;
|
||
}
|
||
|
||
}
|
||
|
||
//响应数据
|
||
$this->payResponseDataLog($pay_order_model->out_order_no, $pay_order_model->type, json_encode($result));
|
||
\Log::debug('---提现状态---', [$result['status']]);
|
||
if (isset($result['status']) && ($result['status'] == 'PROCESSING' || $result['status'] == 'SUCCESS' || $result['status'] == 'SENDING' || $result['status'] == 'SENT')){
|
||
\Log::debug('提现返回结果', $result);
|
||
$this->changeOrderStatus($pay_order_model, Pay::ORDER_STATUS_COMPLETE, $result['payment_no']);
|
||
|
||
$this->payResponseDataLog($out_trade_no, '微信提现', json_encode($result));
|
||
|
||
// Withdraw::paySuccess($result['partner_trade_no']);todo 打款成功之后也会执行，为啥要在这里执行一次？导致重复事件
|
||
|
||
return ['errno' => 0, 'message' => '微信提现成功'];
|
||
} else {
|
||
\Log::debug('---微信提现返回接口错误---', $result);
|
||
|
||
return ['errno' => 1, 'message' => '微信接口错误:' . $result['return_msg'] . '-' . $result['err_code_des']];
|
||
}
|
||
}
|
||
|
||
public function doWithdrawV3($member_id, $out_trade_no, $money, $desc='', $type=1,$withdraw_type = 0)
|
||
{
|
||
try {
|
||
$pay = $this->payParams($type);
|
||
if (empty($pay['weixin_mchid']) || empty($pay['weixin_apisecret'])) {
|
||
// throw new AppException('没有设定支付参数');
|
||
}
|
||
if (empty($pay['weixin_cert']) || empty($pay['weixin_key'])) {
|
||
throw new AppException('\'未上传完整的微信支付证书，请到【系统设置】->【支付方式】中上传!\'');
|
||
}
|
||
if (empty($pay['weixin_apiv3_secret'])) {
|
||
throw new AppException('\'未设置ApiV3密钥!\'');
|
||
}
|
||
|
||
$op = '微信钱包提现 订单号：' . $out_trade_no . '提现金额：' . $money;
|
||
$pay_order_model = $this->withdrawlog(Pay::PAY_TYPE_WITHDRAW, $this->pay_type[Pay::PAY_MODE_WECHAT], $money, $op, $out_trade_no, Pay::ORDER_STATUS_NON, $member_id);
|
||
|
||
// $client_type = \YunShop::request()->type ? : $type;
|
||
$openid = Member::getOpenIdForType($member_id, 1);
|
||
if (empty($openid)) {
|
||
throw new AppException('提现用户不存在');
|
||
}
|
||
|
||
$notify_url = '';
|
||
$app = $this->getEasyWeChatApp($pay, $notify_url);
|
||
|
||
if (WechatWithdrawLog::uniacid()->search(['withdraw_sn' => $out_trade_no,'type' => $withdraw_type,
|
||
'many_status'=>[1,2]])->count()
|
||
) {
|
||
// throw new \Exception('提现正在进行中或已完成');
|
||
return ['errno' => 0, 'message' => '提现正在进行中'];
|
||
}
|
||
|
||
//取最后一条发送了请求的数据 todo 判断是否原参数请求
|
||
$oldLog = WechatWithdrawLog::uniacid()
|
||
->search(['withdraw_sn' => $out_trade_no])
|
||
->where('status','!=',0)
|
||
->orderBy('id','desc')
|
||
->first();
|
||
if ($oldLog && in_array($oldLog->fail_code,['NOT_ENOUGH','FREQUENCY_LIMITED','SYSTEM_ERROR'])) {
|
||
$logFill = [
|
||
'uniacid' => $oldLog->uniacid,
|
||
'withdraw_sn' => $oldLog->withdraw_sn,
|
||
'out_batch_no' => $oldLog->out_batch_no,
|
||
'out_detail_no' => $oldLog->out_detail_no,
|
||
];
|
||
} else {
|
||
$logFill = [
|
||
'uniacid' => \YunShop::app()->uniacid,
|
||
'withdraw_sn' => $out_trade_no,
|
||
'out_batch_no' => WechatWithdrawLog::createOrderSn('WW','out_batch_no'),
|
||
'out_detail_no' => $out_trade_no,
|
||
];
|
||
}
|
||
|
||
$logFill['type'] = $withdraw_type;
|
||
$logFill['pay_type'] = 1;
|
||
$wechatWithdrawLog = WechatWithdrawLog::saveLog($logFill);
|
||
$params = [
|
||
'appid' => $pay['weixin_appid'],
|
||
'out_batch_no' => $wechatWithdrawLog->out_batch_no,
|
||
'batch_name' => empty($desc) ? '佣金提现' : $desc,
|
||
'batch_remark' => empty($desc) ? '佣金提现' : $desc,
|
||
'total_amount' => intval(bcmul($money,100)),
|
||
'total_num' => 1,
|
||
'transfer_detail_list' => [
|
||
[
|
||
'out_detail_no' => $wechatWithdrawLog->out_detail_no,
|
||
'transfer_amount' => intval(bcmul($money,100)),
|
||
'transfer_remark' => empty($desc) ? '佣金提现' : $desc,
|
||
'openid' => $openid,
|
||
]
|
||
]
|
||
];
|
||
if ($money >= 2000) {
|
||
$member = Member::find($member_id);
|
||
$username = $member->realname;
|
||
if (!$username) {
|
||
throw new \Exception('提现大于2000元，会员需在会员信息里设置真实姓名，否则微信不予打款!');
|
||
}
|
||
$params['transfer_detail_list'][0]['user_name'] = $username;
|
||
}
|
||
$res = $app->transfer_v3->batches($params);
|
||
\Log::debug('提现返回结果v3', $res);
|
||
$this->payResponseDataLog($pay_order_model->out_order_no, $pay_order_model->type, json_encode($res));
|
||
$wechatWithdrawLog->http_code = $res['http_code'];
|
||
if ($res['code'] == 0) {//失败了
|
||
$wechatWithdrawLog->fail_code = $res['data']['code'] ? : '';//错误码
|
||
$wechatWithdrawLog->fail_msg = $res['message'] ? : '';
|
||
$wechatWithdrawLog->status = -2;
|
||
$wechatWithdrawLog->save();
|
||
throw new \Exception($wechatWithdrawLog->fail_msg?:'打款失败');
|
||
// return ['errno' => 1, 'message' => '微信接口错误:' . $wechatWithdrawLog->fail_code . '-' . $wechatWithdrawLog->fail_msg];
|
||
}
|
||
$wechatWithdrawLog->status = 1;
|
||
$wechatWithdrawLog->batch_id = $res['data']['batch_id'];
|
||
$wechatWithdrawLog->save();
|
||
//响应数据
|
||
$this->payResponseDataLog($out_trade_no, '微信提现', json_encode($res));
|
||
$this->changeOrderStatus($pay_order_model, Pay::ORDER_STATUS_COMPLETE, $res['data']['out_batch_no']);
|
||
return ['errno' => 0, 'message' => '微信提现成功'];
|
||
} catch (\Exception $e) {//抛出异常会返回代打款状态
|
||
\Log::debug('微信支付-商家转账到零钱错误：'.$e->getMessage(),[$member_id, $out_trade_no, $money, $desc, $type,$withdraw_type]);
|
||
throw new ShopException($e->getMessage());
|
||
}
|
||
}
|
||
|
||
public function doReward($member_id, $out_trade_no, $money, $desc='', $type=1)
|
||
{
|
||
$op = '微信钱包奖励打款 订单号：' . $out_trade_no . '奖励金额：' . $money;
|
||
//访问日志
|
||
self::payAccessLog();
|
||
//支付日志
|
||
self::payLog(Pay::PAY_TYPE_WITHDRAW, $this->pay_type[Pay::PAY_MODE_WECHAT], $money, $op, $member_id);
|
||
|
||
$pay = $this->payParams($type);
|
||
|
||
if (empty($pay['weixin_mchid']) || empty($pay['weixin_apisecret'])) {
|
||
throw new AppException('没有设定支付参数');
|
||
}
|
||
|
||
if (empty($pay['weixin_cert']) || empty($pay['weixin_key'])) {
|
||
throw new AppException('\'未上传完整的微信支付证书，请到【系统设置】->【支付方式】中上传!\'');
|
||
}
|
||
|
||
if (\YunShop::request()->type) {
|
||
$client_type = \YunShop::request()->type;
|
||
} else {
|
||
$client_type = $type;
|
||
}
|
||
|
||
$openid = Member::getOpenIdForType($member_id, $client_type);
|
||
if (empty($openid)) {
|
||
throw new AppException('奖励用户不存在');
|
||
}
|
||
|
||
$notify_url = '';
|
||
$app = $this->getEasyWeChatApp($pay, $notify_url);
|
||
|
||
if ($type == 1) {//钱包
|
||
$merchantPay = $app->transfer;
|
||
|
||
$merchantPayData = [
|
||
'partner_trade_no' => empty($out_trade_no) ? time() . Client::random(4, true) : $out_trade_no,
|
||
'openid' => $openid,
|
||
'check_name' => 'NO_CHECK',
|
||
'amount' => $money * 100,
|
||
'desc' => empty($desc) ? '用户奖励' : $desc,
|
||
'spbill_create_ip' => self::getClientIP(),
|
||
];
|
||
|
||
//请求数据日志
|
||
$this->payRequestDataLog($out_trade_no, $this->pay_type[Pay::PAY_MODE_WECHAT], $this->pay_type[Pay::PAY_MODE_WECHAT], json_encode($merchantPayData));
|
||
|
||
$pay_result = $merchantPay->toBalance($merchantPayData);
|
||
|
||
if (isset($pay_result['partner_trade_no'])) {
|
||
$result = $merchantPay->queryBalanceOrder($pay_result['partner_trade_no']);
|
||
|
||
if ($result['result_code'] == 'FAIL') {
|
||
$result = $pay_result;
|
||
}
|
||
} else {
|
||
$result = $pay_result;
|
||
}
|
||
} else {//红包
|
||
$luckyMoney = $app->redpack;
|
||
|
||
$luckyMoneyData = [
|
||
'mch_billno' => $pay['weixin_mchid'] . date('YmdHis') . rand(1000, 9999),
|
||
'send_name' => \YunShop::app()->account['name'],
|
||
're_openid' => $openid,
|
||
'total_num' => 1,
|
||
'total_amount' => $money * 100,
|
||
'wishing' => empty($desc) ? '用户奖励红包' : $desc,
|
||
'client_ip' => self::getClientIP(),
|
||
'act_name' => empty($act_name) ? '用户奖励红包' : $act_name,
|
||
'remark' => empty($remark) ? '用户奖励红包' : $remark,
|
||
];
|
||
|
||
//请求数据日志
|
||
$this->payRequestDataLog($out_trade_no, $this->pay_type[Pay::PAY_MODE_WECHAT], $this->pay_type[Pay::PAY_MODE_WECHAT], json_encode($luckyMoneyData));
|
||
|
||
$pay_result = $luckyMoney->sendNormal($luckyMoneyData);
|
||
|
||
if (isset($pay_result['mch_billno'])) {
|
||
$result = $luckyMoney->info($pay_result['mch_billno']);
|
||
|
||
if ($result['result_code'] == 'FAIL') {
|
||
$result = $pay_result;
|
||
}
|
||
} else {
|
||
$result = $pay_result;
|
||
}
|
||
|
||
}
|
||
|
||
//响应数据
|
||
$this->payResponseDataLog($out_trade_no, $this->pay_type[Pay::PAY_MODE_WECHAT], json_encode($result));
|
||
\Log::debug('---奖励状态---', [$result['status']]);
|
||
if (isset($result['status']) && ($result['status'] == 'PROCESSING' || $result['status'] == 'SUCCESS' || $result['status'] == 'SENDING' || $result['status'] == 'SENT')){
|
||
\Log::debug('奖励返回结果', $result);
|
||
$this->payResponseDataLog($out_trade_no, $desc, json_encode($result));
|
||
return ['errno' => 0, 'message' => '奖励成功'];
|
||
} else {
|
||
\Log::debug('---奖励返回接口错误---', $result);
|
||
return ['errno' => 1, 'message' => '微信接口错误:' . $result['return_msg'] . '-' . $result['err_code_des']];
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 构造签名
|
||
*
|
||
* @var void
|
||
*/
|
||
public function buildRequestSign()
|
||
{
|
||
// TODO: Implement buildRequestSign() method.
|
||
}
|
||
|
||
/**
|
||
* 创建支付对象
|
||
*
|
||
* @param $pay
|
||
* @return \EasyWeChat\Payment\Payment
|
||
*/
|
||
public function getEasyWeChatApp($pay, $notify_url)
|
||
{
|
||
$options = [
|
||
'app_id' => $pay['weixin_appid'],
|
||
'secret' => $pay['weixin_secret'],
|
||
'mch_id' => $pay['weixin_mchid'],
|
||
'key' => $pay['weixin_apisecret'],
|
||
'cert_path' => $pay['weixin_cert'],
|
||
'key_path' => $pay['weixin_key'],
|
||
'key_v3' => $pay['weixin_apiv3_secret'] ? : '',
|
||
'notify_url' => $notify_url
|
||
];
|
||
$app = EasyWeChat::payment($options);
|
||
return $app;
|
||
}
|
||
|
||
/**
|
||
* 创建预下单
|
||
*
|
||
* @param $data
|
||
* @param $openid
|
||
* @param $pay_order_model
|
||
* @return easyOrder
|
||
*/
|
||
public static function getEasyWeChatOrder($data, $openid, &$pay_order_model,$payType='')
|
||
{
|
||
$attributes = [
|
||
'trade_type' => $data['trade_type'], // JSAPI，NATIVE，APP...
|
||
'body' => mb_substr($data['subject'], 0, 40),
|
||
'out_trade_no' => $data['order_no'],
|
||
'total_fee' => $data['amount'] * 100, // 单位：分
|
||
'nonce_str' => Client::random(8) . "",
|
||
'device_info' => 'yun_shop',
|
||
'attach' => \YunShop::app()->uniacid . ':' . self::$attach_type,
|
||
'spbill_create_ip' => self::getClientIP(),
|
||
'openid' => $openid
|
||
];
|
||
|
||
|
||
if ($payType){
|
||
$attributes['attach'] .= ':'.$payType;
|
||
}
|
||
|
||
//请求数据日志
|
||
self::payRequestDataLog($attributes['out_trade_no'], $pay_order_model->type,
|
||
$pay_order_model->third_type, json_encode($attributes));
|
||
return $attributes;
|
||
}
|
||
|
||
private function changeOrderStatus($model, $status, $trade_no)
|
||
{
|
||
$model->status = $status;
|
||
$model->trade_no = $trade_no;
|
||
$model->save();
|
||
}
|
||
|
||
/**
|
||
* 支付参数
|
||
* @return array|mixed
|
||
*/
|
||
private function payParams($payType = 1)
|
||
{
|
||
|
||
$pay = \Setting::get('shop.pay');
|
||
|
||
if ($payType == 9){
|
||
|
||
$pay = \Setting::get('shop_app.pay');
|
||
} else{
|
||
if (!is_null($event_arr = \app\common\modules\shop\ShopConfig::current()->get('special_wechat_app_pay_config'))) {
|
||
foreach ($event_arr as $event){
|
||
$class = array_get($event, 'class');
|
||
$function = array_get($event, 'function');
|
||
$res = $class::$function(['payType'=>$payType]);
|
||
if ($res['result']){
|
||
$pay = $res['data']['setting'];
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
return $pay;
|
||
}
|
||
|
||
/**
|
||
* 订单退款查询
|
||
*
|
||
* @param $payment
|
||
* @param $out_trade_no
|
||
* @return mixed
|
||
*/
|
||
public function queryRefund($payment, $out_trade_no)
|
||
{
|
||
$result = $payment->refund->queryByOutTradeNumber($out_trade_no);
|
||
|
||
foreach ($result as $key => $value) {
|
||
if (preg_match('/refund_status_\d+/', $key)) {
|
||
return $value;
|
||
}
|
||
}
|
||
|
||
return 'fail';
|
||
}
|
||
|
||
|
||
|
||
} |