LJH_Shop/niucloud/core/pay/Alipay.php

<?php

namespace core\pay;

use app\dict\pay\OnlinePayDict;
use app\dict\pay\RefundDict;
use app\dict\pay\TransferDict;
use core\exception\PayException;
use Psr\Http\Message\ResponseInterface;
use Throwable;
use Yansongda\Pay\Pay;
use Yansongda\Supports\Collection;


/**
 * 文件管理驱动类
 * Class FileDriver
 * @package core\file
 */
class Alipay extends BasePay
{

    /**
     * @param array $config
     * @return void
     */
    protected function initialize(array $config = [])
    {
        parent::initialize($config);
        $config['app_public_cert_path'] = url_to_path($config['app_public_cert_path'] ?? '');
        $config['alipay_public_cert_path'] = url_to_path($config['alipay_public_cert_path'] ?? '');
        $config['alipay_root_cert_path'] = url_to_path($config['alipay_root_cert_path'] ?? '');
        $config['mode'] = Pay::MODE_NORMAL;
        $this->config = $this->payConfig($config, 'alipay');
        Pay::config($this->config);
    }

    public function mp(array $params)
    {

    }

    /**
    * 网页支付
    * @param array $params
    * @return array
    */
   public function web(array $params)
   {
       return $this->returnFormat(Pay::alipay()->web([
           'out_trade_no' => $params['out_trade_no'],
           'total_amount' => $params['money'],
           'subject' => $params['body'],
           '_method' => 'get',
       ]));
   }

   /**
    * 手机网页支付
    * @param array $params
    * @return array
    */
   public function wap(array $params)
   {
       $response = Pay::alipay()->h5([
           'out_trade_no' => $params['out_trade_no'],
           'total_amount' => $params['money'],
           'subject' => $params['body'],
           'quit_url' => $params['quit_url'] ?? '',//用户付款中途退出返回商户网站的地址, 一般是商品详情页或购物车页
           '_method' => 'get',
       ]);

       $redirects = $response->getHeader('Location');
       $effective_url = end($redirects);
       return ['url' => $effective_url];
   }

    /**
     * app支付
     * @param array $params
     * @return array
     */
    public function app(array $params)

    {
        return $this->returnFormat(Pay::alipay()->app([
            'out_trade_no' => $params['out_trade_no'],
            'total_amount' => $params['money'],
            'subject' => $params['body'],//用户付款中途退出返回商户网站的地址, 一般是商品详情页或购物车页
        ]));
    }

    /**
     * 小程序支付
     * @param array $params
     * @return Collection
     */
    public function mini(array $params)
    {
        return Pay::alipay()->mini([
            'out_trade_no' => $params['out_trade_no'],
            'total_amount' => $params['money'],
            'subject' => $params['body'],
            'buyer_id' => $params['buyer_id'],//买家支付宝用户ID  注：交易的买家与卖家不能相同。
        ]);
    }

    /**
     * 付款码支付
     * @param array $params
     * @return Collection
     */
    public function pos(array $params)
    {
        return Pay::alipay()->pos([
            'out_trade_no' => $params['out_trade_no'],
            'auth_code' => $params['auth_code'],//付授权码。 当面付场景传买家的付款码（25~30开头的长度为16~24位的数字，实际字符串长度以开发者获取的付款码长度为准）或者刷脸标识串（fp开头的35位字符串）。
            'total_amount' => $params['money'],
            'subject' => $params['body'],
        ]);
    }

    /**
     * 扫码支付
     * @param array $params
     * @return Collection
     */
    public function scan(array $params)
    {
        return Pay::alipay()->scan([
            'out_trade_no' => $params['out_trade_no'],
            'total_amount' => $params['money'],
            'subject' => $params['body'],
        ]);
    }

    /**
     * 转账
     * @param array $params
     * @return array
     */
    public function transfer(array $params)
    {

        $result = $this->returnFormat(Pay::alipay()->transfer([
            'out_biz_no' => $params['transfer_no'],
            'trans_amount' => $params['money'],
            'product_code' => $params['product_code'] ?: 'TRANS_ACCOUNT_NO_PWD',//业务产品码，单笔无密转账到支付宝账户固定为 : TRANS_ACCOUNT_NO_PWD； 收发现金红包固定为 : STD_RED_PACKET；
            'biz_scene' => $params['scene'] ?: 'DIRECT_TRANSFER',//描述特定的业务场景，可传的参数如下：DIRECT_TRANSFER：单笔无密转账到支付宝，B2C现金红包;PERSONAL_COLLECTION：C2C现金红包-领红包
            'payee_info' => [//收款方信息
                'identity' => $params['to_no'],//参与方的唯一标识
                'identity_type' => $params['to_type'] ?: 'ALIPAY_LOGON_ID',//参与方的标识类型，目前支持如下类型：1、ALIPAY_USER_ID 支付宝的会员ID2、ALIPAY_LOGON_ID：支付宝登录号，支持邮箱和手机号格式3、ALIPAY_OPEN_ID：支付宝openid
                'name' => $params['to_name'],//参与方真实姓名，如果非空，将校验收款支付宝账号姓名一致性。当identity_type=ALIPAY_LOGON_ID时，本字段必填。
            ],
        ]));
        if (!empty($result['msg']) && $result['msg'] != 'Success') {
            throw new PayException($result['sub_msg']);
        } else {
            $status = $result['status'];
            $status_array = array(
                'SUCCESS' => TransferDict::SUCCESS,
                'WAIT_PAY' => TransferDict::WAIT,
                'CLOSED' => TransferDict::FAIL,
                'FAIL' => TransferDict::FAIL
            );
            $res = array(
                'status' => $status_array[$status],
            );
            if ($status == 'FAIL') {
                $res['fail_reason'] = $result['fail_reason'];
            }
        }
        return $res;
    }

    /**
     * 支付关闭
     * @param string $out_trade_no
     * @return bool
     */
    public function close(string $out_trade_no)
    {
        $result = $this->returnFormat(Pay::alipay()->close([
            'out_trade_no' => $out_trade_no,
        ]));
        //todo  支付宝关闭异步回调
        if (isset($result['sub_code']) && in_array($result['sub_code'], ['ACQ.REASON_ILLEGAL_STATUS', 'ACQ.REASON_TRADE_STATUS_INVALID', 'ACQ.TRADE_NOT_EXIST', 'ACQ.TRADE_STATUS_ERROR'])) {
            return true;
        }
        if (!empty($result['msg']) && $result['msg'] == 'Success') {
            return true;
        } else {
            return false;
        }
    }

    /**
     * 退款
     * @param array $params
     * @return array|false
     */
    public function refund(array $params)
    {
        $out_trade_no = $params['out_trade_no'];
        $money = $params['money'];
//        $total = $params['total'];
        $refund_no = $params['refund_no'];
        $result = $this->returnFormat(Pay::alipay()->refund([
            'out_trade_no' => $out_trade_no,
            'refund_amount' => $money,
            'out_request_no' => $refund_no
        ]));
        if (!empty($result['msg']) && $result['msg'] == 'Success') {
            $fund_change = $result['fund_change'];//退款是否成功可以根据同步响应的 fund_change 参数来判断，fund_change 表示本次退款是否发生了资金变化，返回 Y 表示退款成功，返回 N 则表示本次退款未发生资金变动 。
            if ($fund_change == 'Y') {
                $status = RefundDict::SUCCESS;
            } else {
                $status = RefundDict::DEALING;
            }
            return [
                'status' => $status,
                'refund_no' => $refund_no,
                'out_trade_no' => $out_trade_no
            ];
        } else {
            //todo 这儿可以抛出错误
            return false;
        }
    }


    /**
     * 支部异步回调
     * @param string $action
     * @param callable $callback
     * @return ResponseInterface|string
     */
    public function notify(string $action, callable $callback)
    {
        try {
            $result = Pay::alipay()->callback();
            //通过返回的值
            if (!empty($result)) {//成功
                if ($action == 'pay') {
                    //todo  这儿需要具体设计
                    $temp_data = array(
                        'mchid' => $result['seller_id'],
                        'trade_no' => $result['trade_no'],
                        'result' => $result,
                        'status' => OnlinePayDict::getAliPayStatus($result['trade_status'])
                    );
                    $callback_result = $callback($result['out_trade_no'], $temp_data);
                    if (is_bool($callback_result) && $callback_result) {
                        return Pay::alipay()->success();
                    }
                }

            }
            return $this->fail();
        } catch ( Throwable $e ) {
            return $this->fail();
        }


    }

    /**
     * 查询普通支付订单
     * @param array $params
     * @return array
     */
    public function getOrder(array $params = [])
    {
        $out_trade_no = $params['out_trade_no'];
        $order = [
            'out_trade_no' => $out_trade_no,
        ];
        $result = $this->returnFormat(Pay::alipay()->query($order));
        if (!empty($result['msg']) && $result['msg'] == 'Success') {
            return [
                'status' => OnlinePayDict::getAliPayStatus($result['trade_status'])
            ];
        } else {
            if (!empty($result['sub_code']) && $result['sub_code'] == 'ACQ.ACQ.SYSTEM_ERROR') {
                throw new PayException($result['msg']);
            } else {
                return [];
            }
        }
    }

    /**
     * 查询退款单据
     * @param string $out_trade_no
     * @param string|null $refund_no
     * @return array
     */
    public function getRefund(string $out_trade_no, ?string $refund_no)
    {
        $order = [
            'out_trade_no' => $out_trade_no,
            'out_request_no' => $refund_no,
            '_action' => 'refund', // 默认值，查询退款网页订单
        ];

        $result = $this->returnFormat(Pay::alipay()->query($order));
        if (!empty($result['msg']) && $result['msg'] == 'Success') {
            $refund_status = $result['refund_status'] ?? '';
            if ($refund_status == 'REFUND_SUCCESS') {
                $status = RefundDict::SUCCESS;
            } else {
                $status = RefundDict::DEALING;
            }
            return [
                'status' => $status,
                'refund_no' => $refund_no,
                'out_trade_no' => $out_trade_no
            ];
        } else {
            if (!empty($result['sub_code']) && $result['sub_code'] == 'ACQ.ACQ.SYSTEM_ERROR') {
                throw new PayException($result['msg']);
            } else {
                return [];
            }
        }
    }

    /**
     * 获取转账订单
     * @param string $transfer_no
     * @return array
     */
    public function getTransfer(string $transfer_no, $out_transfer_no = '')
    {
        $order = [
            'out_biz_no' => $transfer_no,
            '_action' => 'transfer'
        ];
        $result = $this->returnFormat(Pay::alipay()->query($order));
        if (!empty($result['msg']) && $result['msg'] == 'Success') {
            $status = $result['SUCCESS'] ?? '';
            $status_array = array(
                'SUCCESS' => TransferDict::SUCCESS,
                'WAIT_PAY' => TransferDict::WAIT,
                'CLOSED' => TransferDict::FAIL,
                'FAIL' => TransferDict::FAIL
            );
            return [
                'status' => $status_array[$status],
                'transfer_no' => $transfer_no
            ];
        } else {
            if (!empty($result['sub_code']) && $result['sub_code'] == 'ACQ.ACQ.SYSTEM_ERROR') {
                throw new PayException($result['msg']);
            } else {
                return [];
            }
        }
    }

    /**
     * 转账取消
     * @param array $params
     * @return array
     */
    public function transferCancel(array $params)
    {

    }

    public function fail()
    {
        return 'fail';
    }

    public function returnUrl($params)
    {
        return ['url' => $params->getHeader('Location')[0] ?? ''];
    }
}