NN2026012201/app/Services/PaymentService.php

<?php
// +----------------------------------------------------------------------
// | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
// +----------------------------------------------------------------------
// | 版权所有 2017~2021 LARAVEL研发中心
// +----------------------------------------------------------------------
// | 官方网站: http://www.laravel.cn
// +----------------------------------------------------------------------
// | Author: laravel开发员 <laravel.qq.com>
// +----------------------------------------------------------------------

namespace App\Services;

use App\Models\OrderModel;
use App\Models\PaymentModel;
use App\Models\PayOrdersModel;
use App\Services\Api\SettleService;
use Illuminate\Support\Facades\DB;
use Yansongda\Pay\Pay;
use Yansongda\Pay\Plugin\Wechat\Fund\Profitsharing\AddReceiverPlugin;
use Yansongda\Pay\Plugin\Wechat\Fund\Profitsharing\CreatePlugin;
use Yansongda\Pay\Provider\Wechat;

/**
 * 支付-服务类
 * @author laravel开发员
 * @since 2020/11/11
 * Class PaymentService
 * @package App\Services\Api
 */
class PaymentService extends BaseService
{
    protected static $instance = null;

    private $config = [];

    /**
     * 构造函数
     * @author laravel开发员
     * @since 2020/11/11
     * PaymentService constructor.
     */
    public function __construct()
    {
        $this->model = new PaymentModel();
    }

    /**
     * 静态入口
     * @return static|null
     */
    public static function make()
    {
        if (!self::$instance) {
            self::$instance = (new static());
        }
        return self::$instance;
    }

    /**
     * 创建支付
     * @param string $scene 场景，store-购物消费，pay-生活充值，refund-退款
     * @param int $payType
     * @param int $isMin 是否是小程序
     * @return false|\Yansongda\Pay\Provider\Alipay|Wechat
     */
    public function createPay($scene, $payType = 10, $payPt = '')
    {
        $config = ConfigService::make()->getConfigOptionByGroup(6);
        try {
            if ($payType == 10) {
                $appid = isset($config['wxpay_appid']) ? $config['wxpay_appid'] : '';
                $mpAppid = isset($config['wxpay_mp_appid']) ? $config['wxpay_mp_appid'] : '';
                $minAppid = isset($config['wxpay_min_appid']) ? $config['wxpay_min_appid'] : '';
                $mchid = isset($config['wxpay_mchd']) ? $config['wxpay_mchd'] : '';
                $secretV3Key = isset($config['wxpay_key_v3']) ? $config['wxpay_key_v3'] : '';
                $secretV2Key = isset($config['wxpay_key_v2']) ? $config['wxpay_key_v2'] : '';
                $wxpaySecretCert = isset($config['wxpay_secret_cert']) ? $config['wxpay_secret_cert'] : '';
                $wxpayPublicCert = isset($config['wxpay_public_cert']) ? $config['wxpay_public_cert'] : '';
                if (empty($appid) || empty($mchid) || empty($secretV3Key)) {
                    $this->error = 2616;
                    return false;
                }

                // 支付参数
                $payConfig = config('payment.wechat');
                $payConfig['wechat']['default']['mch_id'] = $mchid;

                if ($payPt == 'min') {
                    // 小程序支付
                    $payConfig['wechat']['default']['mini_app_id'] = $minAppid ? $minAppid : $appid;
                } else if ($payPt == 'mp') {
                    // 公众号
                    $payConfig['wechat']['default']['mp_app_id'] = $mpAppid ? $mpAppid : $appid;
                } else {
                    // APP支付
                    $payConfig['wechat']['default']['app_id'] = $appid;
                }

                if ($secretV3Key) {
                    $payConfig['wechat']['default']['mch_secret_key'] = $secretV3Key;
                } else if ($secretV2Key) {
                    $payConfig['wechat']['default']['mch_secret_key_v2'] = $secretV2Key;
                }

                if ($wxpaySecretCert) {
                    $payConfig['wechat']['default']['mch_secret_cert'] = $wxpaySecretCert;
                }
                if ($wxpayPublicCert) {
                    $payConfig['wechat']['default']['mch_public_cert_path'] = $wxpayPublicCert;
                }
                //$payConfig['wechat']['default']['notify_url'] = url('/api/notify/' . $scene . '/10');
                $payConfig['wechat']['default']['notify_url'] = url(env('APP_URL') . 'api/notify/' . $scene . '/10');

                $this->config = $payConfig;
                //var_dump($payConfig);
                return Pay::wechat($payConfig);
            } else if ($payType == 20) {
                $appid = isset($config['alipay_appid']) ? $config['alipay_appid'] : '';
                $appSecretCert = isset($config['alipay_secret_cert']) ? $config['alipay_secret_cert'] : '';
                $appPublicCert = isset($config['alipay_app_public_cert_path']) ? $config['alipay_app_public_cert_path'] : '';
                $alipayPublicCert = isset($config['alipay_public_cert_path']) ? $config['alipay_public_cert_path'] : '';
                $alipayRootCert = isset($config['alipay_root_cert_path']) ? $config['alipay_root_cert_path'] : '';
                if (empty($appid) || empty($appSecretCert)) {
                    $this->error = 2619;
                    return false;
                }

                // 支付参数
                $payConfig = config('payment.alipay');
                $payConfig['alipay']['default']['app_id'] = $appid;
                $payConfig['alipay']['default']['app_secret_cert'] = $appSecretCert;
                if ($appPublicCert) {
                    $payConfig['alipay']['default']['app_public_cert_path'] = $appPublicCert;
                }
                if ($alipayPublicCert) {
                    $payConfig['alipay']['default']['alipay_public_cert_path'] = $alipayPublicCert;
                }
                if ($alipayRootCert) {
                    $payConfig['alipay']['default']['alipay_root_cert_path'] = $alipayRootCert;
                }
                $payConfig['alipay']['default']['notify_url'] = url('/api/notify/' . $scene . '/20');

                $this->config = $payConfig;
                return Pay::alipay($payConfig);
            } else if ($payType == 30) {
                return true;
            }

            return false;
        } catch (\Exception $exception){
            $this->errorData =  $this->config;
            $this->error = '请检查支付配置是否正常：'.$exception->getMessage();
            return false;
        }
    }

    /**
     * 微信小程序支付
     * @param $userInfo
     * @param $order
     * @param string $scene
     * @return false|\Yansongda\Supports\Collection
     */
    public function minPay($userInfo, $order, $scene = 'store')
    {
        $amount = isset($order['pay_money']) ? $order['pay_money'] : 0;
        $openid = isset($order['openid']) ? $order['openid'] : '';
        if ($amount < 0) {
            $this->error = 2615;
            return false;
        }

        if (empty($openid)) {
            $this->error = 2614;
            return false;
        }

        $outTradeNo = isset($order['order_no']) && $order['order_no'] ? $order['order_no'] : get_order_num('PR');
        // 是否调用过支付，是则用新的支付单号
        if ($outTradeNo && $this->model->where(['out_trade_no' => $outTradeNo, 'mark' => 1])->value('id')) {
            $outTradeNo = $outTradeNo . date('is') . rand(1, 9);
        }
        $body = isset($order['body']) ? $order['body'] : '';
        $payData = [
            'out_trade_no' => $outTradeNo,
            'description' => $body ? $body : '订单支付',
            'amount' => [
                'total' => intval($amount * 100),
                'currency' => 'CNY'
            ],
            'payer' => [
                'openid' => $openid,
            ],
        ];

        // 创建支付
        try {
            $pay = $this->createPay($scene, 10, 'min');
            RedisService::set("caches:payments:wechat:{$scene}_{$outTradeNo}", ['order' => $order, 'config' => $this->config], 7200);
            if (empty($pay)) {
                $this->error = 2616;
                return false;
            }

            $pay = $pay->mini($payData);
        } catch (\Exception $exception) {
            RedisService::set("caches:payments:wechat:{$scene}_{$outTradeNo}_error", ['order' => $order, 'error' => $exception->getTrace(), 'config' => $this->config], 7200);
            $this->error = $exception->getMessage();
            return false;
        }

        if ($pay->package) {
            $data = [
                'user_id' => $userInfo['id'],
                'out_trade_no' => $outTradeNo,
                'order_no' => $order['order_no'],
                'params' => json_encode($pay, 256),
                'total_fee' => $amount,
                'pay_type' => 10,
                'create_time' => time(),
                'status' => 2,
                'mark' => 1,
            ];
            if ($this->model->insertGetId($data)) {
                $this->error = 2617;
                return $pay;
            }
        }

        $this->error = 2618;
        return false;
    }

    /**
     * 微信支付
     * @param $userInfo
     * @param $order
     * @param string $scene
     * @return false|\Yansongda\Supports\Collection
     */
    public function wechatPay($userInfo, $order, $scene = 'store')
    {
        $amount = isset($order['pay_money']) ? $order['pay_money'] : 0;
        if ($amount < 0) {
            $this->error = 2615;
            return false;
        }

        $outTradeNo = isset($order['order_no']) && $order['order_no'] ? $order['order_no'] : get_order_num('PR');
        // 是否调用过支付，是则用新的支付单号
        if ($outTradeNo && $this->model->where(['out_trade_no' => $outTradeNo, 'mark' => 1])->value('id')) {
            $outTradeNo = $outTradeNo . date('is') . rand(1, 9);
        }
        $body = isset($order['body']) ? $order['body'] : '';
        $type = isset($order['type']) ? $order['type'] : 0;
        $payData = [
            'out_trade_no' => $outTradeNo,
            'attach' => "order-{$type}",
            'description' => $body ? $body : '订单支付',
            'amount' => [
                'total' => intval($amount * 100),
                'currency' => 'CNY'
            ],
        ];

        // 创建支付
        try {
            $pay = $this->createPay($scene, 10);
            RedisService::set("caches:payments:wechat:{$scene}_{$outTradeNo}", ['order' => $order, 'config' => $this->config], 7200);
            if (empty($pay)) {
                $this->error = 2616;
                return false;
            }

            $pay = $pay->app($payData);
        } catch (\Exception $exception) {
            RedisService::set("caches:payments:wechat:{$scene}_{$outTradeNo}_error", ['order' => $order, 'error' => $exception->getTrace(), 'config' => $this->config], 7200);
            $this->error = $exception->getMessage();
            return false;
        }
        if ($pay->prepayid) {
            $data = [
                'user_id' => $userInfo['id'],
                'out_trade_no' => $outTradeNo,
                'order_no' => $order['order_no'],
                'params' => json_encode($pay, 256),
                'total_fee' => $amount,
                'pay_type' => 10,
                'create_time' => time(),
                'status' => 2,
                'mark' => 1,
            ];
            if ($this->model->insertGetId($data)) {
                $this->error = 2617;
                return $pay;
            }
        }

        $this->error = 2618;
        return false;
    }

    /**
     * 支付宝支付
     * @param $userInfo
     * @param $order
     * @return bool
     */
    public function aliPay($userInfo, $order, $scene = 'shop')
    {
        $amount = isset($order['pay_money']) ? $order['pay_money'] : 0;
        if ($amount < 0) {
            $this->error = 2615;
            return false;
        }

        // 是否调用过支付，是则用新的支付单号
        $outTradeNo = isset($order['order_no']) && $order['order_no'] ? $order['order_no'] : get_order_num('PY');
        if ($outTradeNo && $this->model->where(['out_trade_no' => $outTradeNo, 'mark' => 1])->value('id')) {
            $outTradeNo = $outTradeNo . date('is') . rand(1, 9);
        }
        $body = isset($order['body']) ? $order['body'] : '';
        $payData = [
            'out_trade_no' => $outTradeNo,
            'subject' => $body ? $body : '订单支付',
            'total_amount' => $amount,
        ];

        // 创建支付
        $pay = $this->createPay($scene, 20);
        RedisService::set("caches:payments:alipay:{$scene}_{$outTradeNo}", ['order' => $order, 'config' => $this->config], 7200);
        if (empty($pay)) {
            $this->error = 2619;
            return false;
        }

        $pay = $pay->app($payData);
        if ($pay->getStatusCode() == 200) {
            $data = [
                'user_id' => $userInfo['id'],
                'out_trade_no' => $outTradeNo,
                'order_no' => $order['order_no'],
                'params' => json_encode($pay, 256),
                'total_fee' => $amount,
                'pay_type' => 20,
                'create_time' => time(),
                'status' => 2,
                'mark' => 1,
            ];
            if ($this->model->insertGetId($data)) {
                $this->error = 2620;
                return $pay->getBody()->getContents();
            }
        }

        $this->error = 2621;
        return false;
    }

    /**
     * 订单支付回调处理
     * @param string $scene 场景 store-购物消费，pay-充值，refund-退款
     * @param int $payType 支付方式,10-微信支付，20-支付宝支付
     * @param array $data 回调数据
     * @return bool
     */
    public function catchNotify($scene, $payType, $data)
    {
        $outTradeNo = '';
        $payTotal = 0;
        $transactionId = '';
        $payAt = '';
        $notifyData = [];

        try {

            // 微信支付
            if ($payType == 10) {
                $resource = isset($data['resource']) ? $data['resource'] : [];
                $ciphertext = isset($resource['ciphertext']) ? $resource['ciphertext'] : [];
                $tradeStatus = isset($ciphertext['trade_state']) ? $ciphertext['trade_state'] : '';
                if ($tradeStatus != 'SUCCESS') {
                    $this->error = 2622;
                    return false;
                }

                $outTradeNo = isset($ciphertext['out_trade_no']) ? $ciphertext['out_trade_no'] : '';
                $transactionId = isset($ciphertext['transaction_id']) ? $ciphertext['transaction_id'] : '';
                if (empty($outTradeNo)) {
                    $this->error = 2623;
                    return false;
                }
                $payAt = isset($ciphertext['success_time']) ? date('Y-m-d H:i:s', strtotime($ciphertext['success_time'])) : date('Y-m-d H:i:s');
                $amount = isset($ciphertext['amount']) ? $ciphertext['amount'] : [];
                $payTotal = isset($amount['total']) ? moneyFormat($amount['total'] / 100, 3) : 0;
                $notifyData = $ciphertext;
                if ($payTotal <= 0) {
                    $this->error = 2624;
                    return false;
                }
            } // 支付宝支付
            else if ($payType == 20) {
                // TRADE_SUCCESS
                $tradeStatus = isset($data['trade_status']) ? $data['trade_status'] : '';
                if ($tradeStatus != 'TRADE_SUCCESS' && $tradeStatus != 'TRADE_FINISHED') {
                    $this->error = 2622;
                    return false;
                }

                $outTradeNo = isset($data['out_trade_no']) ? $data['out_trade_no'] : '';
                if (empty($outTradeNo)) {
                    $this->error = 2623;
                    return false;
                }

                $payTotal = isset($data['total_amount']) ? floatval($data['total_amount']) : 0;
                $transactionId = isset($data['trade_no']) ? trim($data['trade_no']) : '';
                $payAt = isset($data['send_pay_date']) ? trim($data['send_pay_date']) : date('Y-m-d H:i:s');
                $notifyData = $data;
                if ($payTotal <= 0) {
                    $this->error = 2624;
                    return false;
                }
            }

            // 支付信息
            $paymentInfo = $this->model->with(['user'])->where(['out_trade_no' => $outTradeNo, 'mark' => 1])
                ->select(['user_id', 'order_no', 'pay_type', 'total_fee', 'status'])
                ->first();
            $status = isset($paymentInfo['status']) ? $paymentInfo['status'] : 0;
            $totalFee = isset($paymentInfo['total_fee']) ? $paymentInfo['total_fee'] : 0;
            $paymentPayType = isset($paymentInfo['pay_type']) ? $paymentInfo['pay_type'] : 0;
            $orderNo = isset($paymentInfo['order_no']) ? $paymentInfo['order_no'] : '';
            $payUserId = isset($paymentInfo['user_id']) ? $paymentInfo['user_id'] : 0;
            if (empty($paymentInfo) || empty($orderNo) || $payUserId <= 0) {
                $this->error = 2625;
                return false;
            }

            // 验证支付状态
            if ($status == 1) {
                $this->error = 2626;
                return false;
            }

            // 验证支付方式
            if ($paymentPayType != $payType) {
                $this->error = 2627;
                return false;
            }

            if ($payTotal != $totalFee || $payTotal <= 0) {
                $this->error = 2628;
                return false;
            }

            // 删除久远旧记录
            $this->model->where(['mark' => 1])->where('create_time', '<=', time() - 60 * 86400)->delete();

            // 更新订单数据
            DB::beginTransaction();
            $updateData = ['transaction_id' => $transactionId, 'result' => json_encode($notifyData, 256), 'pay_at' => $payAt, 'status' => 1, 'update_time' => time()];
            if (!$this->model->where(['out_trade_no' => $outTradeNo, 'mark' => 1])->update($updateData)) {
                $this->error = 2632;
                DB::rollBack();
                return false;
            }

            /* TODO 订单验证和状态处理 */
            $orderInfo = [];
            // 商城订单支付
            if ($scene == 'store') {
                $orderInfo = OrderModel::with(['user'])->where(['order_no' => $orderNo, 'mark' => 1])
                    ->select(['id as order_id', 'user_id', 'order_no', 'total as pay_money', 'pay_at as pay_time', 'remark', 'status'])
                    ->first();
                $orderStatus = isset($orderInfo['status']) ? $orderInfo['status'] : 0;
                // 验证订单
                if (empty($orderInfo)) {
                    DB::rollBack();
                    $this->error = 2629;
                    return false;
                }

                // 订单状态
                if ($orderStatus != 1) {
                    DB::rollBack();
                    $this->error = 2630;
                    return false;
                }

                $updateData = ['pay_at' => $payAt, 'transaction_id' => $transactionId, 'status' => 2, 'update_time' => time()];
                if (!OrderModel::where(['order_no' => $orderNo, 'mark' => 1])->update($updateData)) {
                    $this->error = 2633;
                    DB::rollBack();
                    return false;
                }
            }
            // 生活充值
            else if ($scene == 'pay') {
                $orderInfo = PayOrdersModel::where(['order_no' => $orderNo, 'mark' => 1])
                    ->select(['id as order_id', 'user_id','meal_id','product_id', 'order_no','transaction_id','account', 'total as pay_money','area','ytype','city','id_card_no','pay_total', 'pay_at as pay_time', 'remark', 'status'])
                    ->first();
                $orderStatus = isset($orderInfo['status']) ? $orderInfo['status'] : 0;
                // 验证订单
                if (empty($orderInfo)) {
                    DB::rollBack();
                    $this->error = 2629;
                    return false;
                }

                // 订单状态
                if ($orderStatus != 1) {
                    DB::rollBack();
                    $this->error = 2630;
                    return false;
                }

                $updateData = ['pay_at' => $payAt, 'transaction_id' => $transactionId, 'status' => 2, 'update_time' => time()];
                if (!PayOrdersModel::where(['order_no' => $orderNo, 'mark' => 1])->update($updateData)) {
                    $this->error = 2633;
                    DB::rollBack();
                    return false;
                }
            }
            // 退款
            else if ($scene == 'refund') {
                $orderInfo = OrderModel::where(['order_no' => $orderNo, 'mark' => 1])
                    ->select(['id as order_id', 'user_id', 'order_no', 'total as pay_money', 'remark', 'refund_remark', 'pay_at as pay_time', 'refund_status as status'])
                    ->first();
                $refundRemark = isset($orderInfo['refund_remark']) ? $orderInfo['refund_remark'] : 'refund_remark';
                $orderStatus = isset($orderInfo['status']) ? $orderInfo['status'] : 0;
                // 验证订单
                if (empty($orderInfo)) {
                    DB::rollBack();
                    $this->error = 2629;
                    return false;
                }

                // 订单状态
                if ($orderStatus != 2) {
                    DB::rollBack();
                    $this->error = 2639;
                    return false;
                }

                // 订单打款状态
                if ($orderStatus == 1) {
                    DB::rollBack();
                    $this->error = 2630;
                    return false;
                }

                $updateData = ['refund_status' => 1, 'refund_remark' => $refundRemark ? $refundRemark . ' 已退款成功' : '已退款成功', 'update_time' => time()];
                if (!OrderModel::where(['order_no' => $orderNo, 'mark' => 1])->update($updateData)) {
                    $this->error = 2633;
                    DB::rollBack();
                    return false;
                }
            }

            // TODO 场景业务回调处理
            $orderUserId = isset($orderInfo['user_id']) ? $orderInfo['user_id'] : 0;
            $this->saveLog("caches:payments:notify_{$scene}:catch_{$orderNo}_{$orderUserId}", ['order' => $orderInfo, 'notify' => $data]);
            switch ($scene) {
                case 'store': //
                    break;
                case 'pay': //
                    // 调起 接口充值
                    $orderId = isset($orderInfo['order_id'])? $orderInfo['order_id'] : 0;
                    $productId = isset($orderInfo['product_id'])? $orderInfo['product_id'] : '';
                    $orderNo = isset($orderInfo['order_no'])? $orderInfo['order_no'] : '';
                    $account = isset($orderInfo['account'])? $orderInfo['account'] : '';
                    $total = isset($orderInfo['pay_money'])? $orderInfo['pay_money'] : 0;
                    $payTotal = isset($orderInfo['pay_total'])? $orderInfo['pay_total'] : 0;
                    $amount = $total;
                    $params = [
                        'price'=>$payTotal,
                        'ytype'=>isset($orderInfo['ytype'])?$orderInfo['ytype']:0,
                        'id_card_no'=>isset($orderInfo['id_card_no'])?$orderInfo['id_card_no']:'',
                        'area'=>isset($orderInfo['area'])?$orderInfo['area']:'',
                        'city'=>isset($orderInfo['city'])?$orderInfo['city']:'',
                    ];

                    $result = DyrPayService::make()->recharge($orderNo, $account, $productId, $amount, $params);
                    $errno = isset($result['errno'])?$result['errno'] : -1;
                    $errmsg = isset($result['errmsg'])?$result['errmsg'] : '';
                    $res = isset($result['data'])?$result['data']:[];
                    $order_number = isset($res['order_number'])?$res['order_number']:'';
                    $total_price = isset($res['total_price'])?$res['total_price']:'';
                    if(empty($result) || $errno != 0 || empty($order_number)){

                        $this->error = '充值调用失败：'.$errmsg;

                        // 退款
                        $orderInfo['money'] = $payTotal;
                        $orderInfo['remark'] = '充值失败退款';
                        $refundStatus = PaymentService::make()->refund($orderInfo,'pay');
                        $updateData = ['refund_status'=> $refundStatus?1:3,'status'=>5,'result'=>json_encode(['amount'=>$amount,'params'=>$params,'result'=>$result],256),'failed_remark'=> $errmsg,'refund_at'=>date('Y-m-d H:i:s'),'refund_money'=>$refundStatus?$payTotal:0,'update_time'=>time()];
                        $this->saveLog("caches:payments:notify_{$scene}:pay_failed_{$orderNo}_{$orderUserId}", ['error'=>$this->error,'update'=>$updateData,'order' => $orderInfo,'result'=>$result, 'notify' => $data]);
                        if(!PayOrdersModel::where(['id'=>$orderId])->update($updateData)){
                            $this->error = '订单退款状态更新错误～';
                        }

                        DB::commit();
                        return false;
                    }

                    $updateData = ['status'=>3,'result'=>json_encode(['amount'=>$amount,'params'=>$params,'result'=>$result],256),'out_trade_no'=>$order_number,'update_time'=>time()+1];
                    $this->saveLog("caches:payments:notify_{$scene}:pay_success_{$orderNo}_{$orderUserId}", ['error'=> '充值调用成功','id'=>$orderId,'update'=>$updateData,'order' => $orderInfo,'result'=>$result, 'notify' => $data]);
                    if(!PayOrdersModel::where(['id'=>$orderId])->update($updateData)){
                        DB::commit();
                        $this->error = '更新充值订单失败';
                        $this->saveLog("caches:payments:notify_{$scene}:pay_failed_{$orderNo}_{$orderUserId}", ['error'=>$this->error,'update'=>$updateData,'order' => $orderInfo,'result'=>$result, 'notify' => $data]);
                        return false;
                    }

                    DB::commit();
                    return true;
                default:
                    break;
            }

            $this->error = '回调处理成功';
            DB::commit();
            return true;
        } catch (\Exception $exception) {
            $this->error = $exception->getMessage();
            RedisService::set("caches:payments:notify_{$scene}:catch_" . $orderNo . '_error', ['notify' => $data, 'error' => $exception->getMessage(), 'trace' => $exception->getTrace()], 7200);
            return false;
        }
    }

    /**
     * 充值回调
     * @param $productId
     * @param $data
     * @return bool
     * @throws \Yansongda\Pay\Exception\ContainerException
     * @throws \Yansongda\Pay\Exception\InvalidParamsException
     * @throws \Yansongda\Pay\Exception\ServiceNotFoundException
     */
    public function catchPayNotify($productId, $data)
    {
        $out_trade_num = isset($data['out_trade_num'])?$data['out_trade_num']:'';
        $state = isset($data['state'])? $data['state'] : 0;
        $charge_kami = isset($data['charge_kami'])?$data['charge_kami'] : '';
        $amount = isset($data['charge_amount'])?floatval($data['charge_amount']) : 0;
        if($state==0){
            $this->error = '充值处理中～';
            return false;
        }

        $orderInfo = PayOrdersModel::with(['user'])->where(['order_no'=>$out_trade_num,'mark'=>1])->first();
        $orderId = isset($orderInfo['id'])? $orderInfo['id'] : 0;
        $orderUserId = isset($orderInfo['user_id'])? $orderInfo['user_id'] : 0;
        $status = isset($orderInfo['status'])? $orderInfo['status'] : 0;
        $total = isset($orderInfo['pay_total'])? $orderInfo['pay_total'] : 0;
        $userInfo = isset($orderInfo['user'])? $orderInfo['user'] : [];
        $parentId = isset($userInfo['parent_id'])?$userInfo['parent_id'] : 0;
        if(empty($orderInfo) || $orderId<=0 || $total<=0){
            $this->error = '充值订单不存在';
            $this->saveLog("caches:payments:payNotify_{$productId}:notify_{$out_trade_num}_error", ['error'=>$this->error,'order' => $orderInfo, 'notify' => $data]);
            return false;
        }

        if($status!=3){
            $this->error = '充值订单状态错误，状态非充值中';
            $this->saveLog("caches:payments:payNotify_{$productId}:notify_{$out_trade_num}_error", ['error'=>$this->error,'order' => $orderInfo, 'notify' => $data]);
            return false;
        }

        // 成功
        $status = 4;
        $refundAmount = 0;
        if($state == 1){
            $this->error = '充值成功～';
        }
        //部分成功，退部分
        else if($state == 3) {
            $status = 6;
            $refundAmount = moneyFormat($total - $amount,2);
            $this->error = '充值成功部分退款';
        }
        //失败，退全款
        else if(in_array($state,[-1,2])){
            $status = 5;
            $refundAmount = $total;
            $this->error = '充值失败退款';
        }

        // 更新订单状态
        DB::beginTransaction();
        $this->saveLog("caches:payments:payNotify_{$productId}:notify_{$out_trade_num}", ['error'=>$this->error,'order' => $orderInfo, 'notify' => $data]);
        if(!PayOrdersModel::where(['id'=>$orderId])->update(['status'=>$status,'charge_kami'=>$charge_kami,'refund_status'=>$status!=4?2:0,'charge_amount'=>$amount,'update_time'=>time()])){
            $this->error = '更新订单状态错误～';
            DB::rollBack();
            return false;
        }

        // 是否要退款
        if($refundAmount>0){
            $orderInfo['money'] = $refundAmount;
            $orderInfo['remark'] = $this->error;
            $orderInfo['out_trade_no'] = '';
            $refundStatus = PaymentService::make()->refund($orderInfo,'pay');
            if(!PayOrdersModel::where(['id'=>$orderId])->update(['refund_status'=> $refundStatus?1:3,'refund_remark'=>$this->error,'refund_money'=>$refundStatus?$refundAmount:0,'refund_at'=>date('Y-m-d H:i:s'),'update_time'=>time()])){
                $this->saveLog("caches:payments:payNotify_{$productId}:notify_{$out_trade_num}_error", ['error'=>$this->error,'order' => $orderInfo, 'notify' => $data]);
                $this->error = '订单退款状态更新错误～';
                DB::rollBack();
                return false;
            }
        }

        // 订单完成，代理收益结算
        if($status == 4 && $amount>0)
        {
            // 代理佣金结算
            if (SettleService::make()->agentBonus($orderUserId, $amount, $orderInfo, $parentId) < 0) {
                DB::rollBack();
                $this->error = SettleService::make()->getError();
                return false;
            }
        }

        DB::commit();
        $this->error = '充值订单处理成功～';
        return ['id'=>$orderId,'amount'=>$amount,'status'=>$status,'refund'=>$refundAmount];
    }

    /**
     * 日志
     * @param $key
     * @param $data
     */
    public function saveLog($key, $data)
    {
        if(env('APP_DEBUG')){
            RedisService::set($key,$data,7200);
        }
    }

    /**
     * 退款请求
     * @param $order
     * @param string $scene
     * @return bool
     * @throws \Yansongda\Pay\Exception\ContainerException
     * @throws \Yansongda\Pay\Exception\InvalidParamsException
     * @throws \Yansongda\Pay\Exception\ServiceNotFoundException
     */
    public function refund($order, $scene = 'store')
    {
        $money = isset($order['money']) ? $order['money'] : 0;
        $payType = isset($order['pay_type']) && $order['pay_type']? $order['pay_type'] : 10;
        $orderNo = isset($order['order_no']) ? $order['order_no'] : '';
        $outTradeNo = isset($order['out_trade_no']) ? $order['out_trade_no'] : '';
        $transactionId = isset($order['transaction_id']) ? $order['transaction_id'] : '';
        $remark = isset($order['remark']) && $order['remark'] ? $order['remark'] : '退款';

        $pay = PaymentService::make()->createPay($scene, $payType);
        if (empty($pay)) {
            DB::rollBack();
            $this->error = '创建退款支付失败';
            return false;
        }
        // 保证金退款处理
        $refundStatus = false;
        switch ($payType) {
            case 10: // 微信支付
                $data = [
                    'out_trade_no' => $outTradeNo?$outTradeNo:$orderNo,
                    'out_refund_no' => get_order_num('RF'),
                    'transaction_id' => $transactionId,
                    'notify_url' => url("/api/notify/{$scene}/{$payType}"),
                    'reason' => $remark,
                    'amount' => [
                        'refund' => intval($money * 100),
                        'total' => intval($money * 100),
                        'currency' => 'CNY',
                    ],
                ];

                // 请求退款
                $pay = $pay->refund($data);
                RedisService::set("caches:refunds:order:{$orderNo}_wxpay", ['data' => $data, 'pay' => $pay, 'type' => $payType, 'date' => date('Y-m-d H:i:s')], 7200);
                if ($pay->status == 'SUCCESS' || $pay->status == 'PROCESSING') {
                    $refundStatus = true;
                } else {
                    DB::rollBack();
                    $this->errorData = $data;
                    $this->error = '微信退款处理失败：'.$pay->message;
                    return false;
                }
                break;
            case 20: // 支付宝
                $data = [
                    'out_request_no' => $outTradeNo?$outTradeNo:$orderNo,
                    'trade_no' => $transactionId,
                    'refund_amount' => $money,
                    'query_options' => ['deposit_back_info'],
                    'refund_reason' => $remark,
                ];
                $payResult = $pay->refund($data);
                RedisService::set("caches:refunds:order:{$orderNo}_alipay", ['data' => $data, 'pay' => $payResult, 'type' => $payType, 'date' => date('Y-m-d H:i:s')], 7200);
                if ($payResult->code == 10000 || intval($payResult->code) == 40004) {
                    $refundStatus = true;
                } else {
                    $this->errorData = $data;
                    $this->error = '支付宝退款处理失败：'.$payResult->code;
                    return false;
                }
                break;
            default:
                $this->error = '退款支付类型错误';
                return false;
        }

        $this->error = '退款处理成功';
        return $refundStatus;
    }

    /**
     * 分账
     * @param $openid
     * @param $order
     * @param string $scene
     * @return array|\Psr\Http\Message\MessageInterface|\Yansongda\Supports\Collection|null
     * @throws \Yansongda\Pay\Exception\ContainerException
     * @throws \Yansongda\Pay\Exception\InvalidParamsException
     */
    public function profitsharing($openid, $order ,$scene='sharing')
    {
        $data = [
            'type' => 'PERSONAL_OPENID',
            'account' => $openid,
            'relation_type' => 'SERVICE_PROVIDER'
        ];

        $pay = PaymentService::make()->createPay($scene, 10);
        $plugin = $pay->mergeCommonPlugins([
            AddReceiverPlugin::class
        ], $data);

        // 添加分账插件配置
        $pay->pay($plugin, $data);

        // 分账数据
        $transactionId = isset($order['transaction_id'])? $order['transaction_id'] : ''; // 支付交易单号
        $profitsharingOrderNo = isset($order['out_order_no'])? $order['out_order_no'] : ''; // 分账单号，非支付单号
        $body = isset($order['body'])? $order['body'] : ''; // 分账备注描述
        $amount = isset($order['amount'])? $order['amount'] : ''; // 分账金额
        $unsplit = isset($order['unsplit'])? $order['unsplit'] : true; // 是否限制只分账一次
        $postData = [
            'transaction_id' => $transactionId,
            'out_order_no' => $profitsharingOrderNo,
            'receivers' => [
                [
                    'type' => 'PERSONAL_OPENID',
                    'account' => $openid,
                    'amount' => $amount, // 分账金额，单位：分
                    'description' => $body, //分账描述
                ],
            ],
            'unfreeze_unsplit' => $unsplit,
        ];

        // 创建分账数据
        $createPlugin = $pay->mergeCommonPlugins([
            CreatePlugin::class
        ], $postData);

        // 发起分账
        $result = $pay->pay($createPlugin, $postData);
        var_dump($result);

        return $result;
    }
}