qy-platform/ThinkPHP/Library/Think/Pay.class.php

<?php

/**
 * 通用支付接口类
 * @author yunwuxin<448901948@qq.com>
 */

namespace Think;

use Org\UcenterSDK\Ucservice;
use Think\Log;

class Pay
{

    /**
     * 支付驱动实例
     * @var Object
     */
    private $payer;

    /**
     * 配置参数
     * @var type
     */
    private $config;

    /**
     * 支付类型
     * @var type
     */
    private $apitype;

    /**
     * 构造方法，用于构造上传实例
     * @param string $driver 要使用的支付驱动
     * @param array $config 配置
     */
    public function __construct($driver, $config = array())
    {
        /* 配置 */
        $pos = strrpos($driver, '\\');
        $pos = $pos === false ? 0 : $pos + 1;
        $apitype = strtolower(substr($driver, $pos));
        $this->apitype = $apitype;
        $this->config['notify_url'] = 'http://' . $_SERVER ['HTTP_HOST'] . "/callback.php/Notify/notify/apitype/" . $apitype . '/method/notify';
        $this->config['return_url'] = 'http://' . $_SERVER ['HTTP_HOST'] . "/callback.php/Notify/notify/apitype/" . $apitype . '/method/return/model/'.MODULE_NAME .'/c/'.CONTROLLER_NAME;
        $config = array_merge($this->config, $config);
        /* 设置支付驱动 */
        $class = strpos($driver, '\\') ? $driver : 'Think\\Pay\\Driver\\' . ucfirst(strtolower($driver));
        $this->setDriver($class, $config);
    }

    public function buildRequestForm(Pay\PayVo $vo, $uc = 0, $param=array())
    {
        $this->payer->check();
        $result = false;
        if ($uc == 0) {
            switch ($vo->getTable()) {
                case 'spend':
                    $result = $this->add_spend($vo, $param);
                    break;
                case 'deposit':
                    $result = $this->add_deposit($vo);
                    break;
                case 'agent':
                    $result = $this->add_agent($vo);
                    break;
                case 'balance':
                    $result = $this->add_balance($vo);
                    break;
                case 'RefundRecord':
                    $result = 1;
                    break;
                case "bind_recharge":
                    $result = $this->add_bind_recharge($vo);
                    break;
                case 'Withdraw':
                    $result=1;
                    break;
				case 'order':{
					$result = $this->add_order($vo);
				};break;
				case 'supersign' :
					$result=1;
					break;
                default:
                    $result = false;
                    break;
            }
            if ($result !== false) {//$check !== false
                if ($this->apitype == "alipay" && C('alipay.usenew')) {
                    if (C('alipay.appid')) {
                        return $this->newbuildRequestForm($vo);
                    } else {
                        E("appid未设置");
                        exit('新版appid未填写');
                    }
                } else {
                    return $this->payer->buildRequestForm($vo);
                }
            } else {
                E(M($vo->getTable(), "tab_")->getDbError());
            }
        } else {
            return $this->payer->buildRequestForm($vo);
        }

    }

    /**
     * 新版支付宝接口调用
     * */
    public function newbuildRequestForm(Pay\PayVo $vo)
    {
        Vendor('Alipay.AopSdk');
        $aop = new \AopClient();
        $aop->appId = C('alipay.appid');
        $aop->signType = 'RSA2';
        $aop->rsaPrivateKey = file_get_contents("./Application/Sdk/SecretKey/alipay/rsa2_private_key.txt");
        $type = $vo->getPayMethod();
		//file_put_contents(dirname(__FILE__) . '/newbuildRequestForm.txt',json_encode($vo->getOrderNo()));
        switch ($type) {
            case 'direct':
                $productcode = 'FAST_INSTANT_TRADE_PAY';
                $request = new \AlipayTradePagePayRequest();
                $request->setReturnUrl('http://' . $_SERVER ['HTTP_HOST'] . '/callback.php/Notify2/notify/apitype/alipay/methodtype/return');
                break;
            case 'direct_dc':
                $productcode = 'FAST_INSTANT_TRADE_PAY';
                $request = new \AlipayTradePagePayRequest();
                $request->setReturnUrl('http://' . $_SERVER ['HTTP_HOST'] . '/callback.php/Notify2/notify/apitype/alipay/methodtype/return_dc');
                break;
            case 'direct_tb'://推广平台支付
                $productcode = 'FAST_INSTANT_TRADE_PAY';
                $request = new \AlipayTradePagePayRequest();
                $request->setReturnUrl('http://' . $_SERVER ['HTTP_HOST'] . '/callback.php/Notify2/notify/apitype/alipay/methodtype/return_tb');
                break;
            case 'wap':
            	$returnurl = $vo->getCallback();
            	if (!$returnurl)
            		$returnurl = 'http://' . $_SERVER ['HTTP_HOST'] . "/sdk.php/Spend/pay_success";
                $productcode = 'QUICK_WAP_PAY';
                $request = new \AlipayTradeWapPayRequest();
                $request->setReturnUrl($returnurl);
                break;
			case 'trade':
                $productcode = 'QUICK_WAP_PAY';
                $request = new \AlipayTradeWapPayRequest();
                $request->setReturnUrl('http://' . $_SERVER ['HTTP_HOST'] . "/mobile.php/Trade/success");
                break;
            case 'mobile':
                $aop->alipayrsaPublicKey = file_get_contents("./Application/Sdk/SecretKey/alipay/alipay2_public_key.txt");
                $productcode = 'QUICK_MSECURITY_PAY';
                $request = new \AlipayTradeAppPayRequest();
                break;
            case 'refund':
                $aop->alipayrsaPublicKey = file_get_contents("./Application/Sdk/SecretKey/alipay/alipay2_public_key.txt");
                $request = new \AlipayTradeRefundRequest();
                break;
            case 'transfer':
                $aop->alipayrsaPublicKey = file_get_contents("./Application/Sdk/SecretKey/alipay/alipay2_public_key.txt");
                $request = new \AlipayFundTransToaccountTransferRequest ();
                break;
            default:
                $productcode = 'FAST_INSTANT_TRADE_PAY';
                $request = new \AlipayTradePagePayRequest();
                break;
        }
        $notifyurl = $vo->getNotifyUrl();
        if (!$notifyurl){
            $notifyurl = 'https://' . $_SERVER ['HTTP_HOST'] . '/callback.php/Notify2/notify/apitype/alipay/methodtype/notify';
        }
        $request->setNotifyUrl($notifyurl);

        switch ($type) {
            case 'direct':
                $request->setBizContent('{"product_code":"' . $productcode . '","body":"' . $vo->getBody() . '","subject":"' . $vo->getTitle() . '","total_amount":"' . $vo->getFee() . '","out_trade_no":"' . $vo->getOrderNo() . '"}');
                return $aop->pageExecute($request, 'POST');
                break;
            case 'direct_dc':
                $request->setBizContent('{"product_code":"' . $productcode . '","body":"' . $vo->getBody() . '","subject":"' . $vo->getTitle() . '","total_amount":"' . $vo->getFee() . '","out_trade_no":"' . $vo->getOrderNo() . '"}');
                return $aop->pageExecute($request, 'POST');
                break;
            case 'direct_tb':
                $request->setBizContent('{"product_code":"' . $productcode . '","body":"' . $vo->getBody() . '","subject":"' . $vo->getTitle() . '","total_amount":"' . $vo->getFee() . '","out_trade_no":"' . $vo->getOrderNo() . '"}');
                return $aop->pageExecute($request, 'POST');
                break;
            case 'wap':
                /*参数  out_trade_no：系统订单号*/
                $request->setBizContent('{"product_code":"' . $productcode . '","body":"' . $vo->getBody() . '","subject":"' . $vo->getTitle() . '","total_amount":"' . $vo->getFee() . '","out_trade_no":"' . $vo->getOrderNo() . '"}');
                return $aop->pageExecute($request, 'GET');
                break;
			case 'trade':
                /*参数  out_trade_no：系统订单号*/
                $request->setBizContent('{"product_code":"' . $productcode . '","body":"' . $vo->getBody() . '","subject":"' . $vo->getTitle() . '","total_amount":"' . $vo->getFee() . '","out_trade_no":"' . $vo->getOrderNo() . '"}');
                return $aop->pageExecute($request, 'GET');
                break;
            case 'mobile':
                /*参数  out_trade_no：系统订单号*/
                $request->setBizContent('{"body":"' . $vo->getBody() . '","subject":"' . $vo->getTitle() . '","out_trade_no":"' . $vo->getOrderNo() . '","timeout_express":"30m","total_amount":"' . $vo->getFee() . '","product_code":"' . $productcode . '"}');
                $response = $aop->sdkExecute($request);
                $sHtml['arg'] = $response['orderstr'];
                $sHtml['sign'] = $response['sign'];
                $sHtml['out_trade_no'] = $vo->getOrderNo();
                return $sHtml;
                break;
            case 'refund':
                $batch_no = $vo->getBatchNo();
                $map['batch_no'] = $batch_no;
                $refund = M('refund_record', 'tab_')->where($map)->find();
                /*参数  out_trade_no：系统订单号  trade_no：支付宝订单号 refund_amount：退款金额  out_request_no：退款请求号  refund_reason：退款原因*/
                $request->setBizContent('{"out_trade_no":"","trade_no":"' . $vo->getOrderNo() . '","refund_amount":"' . $refund['pay_amount'] . '","out_request_no":"' . $batch_no . '","refund_reason":"调单"}');
                $result = $aop->execute($request);
                $responseNode = str_replace(".", "_", $request->getApiMethodName()) . "_response";
                $resultCode = $result->$responseNode->code;
                if (!empty($resultCode) && $resultCode == 10000) {
                    $date['tui_status'] = 1;
                    $date['tui_time'] = time();
                    M('refund_record', 'tab_')->where($map)->save($date);
                    $map_spend['pay_order_number'] = get_refund_pay_order_number($batch_no);
                    $spen_date['sub_status'] = 1;
                    $spen_date['settle_check'] = 1;
                    M('spend', 'tab_')->where($map_spend)->save($spen_date);
                    return "10000";//退款成功
                } else {
                    return "退款失败";
                }
            case 'transfer':
                $settlement_number = $vo->getOrderNo();
                $WidthdrawNo = $vo->getBatchNo();
                $map['settlement_number'] = $settlement_number;
                $widthdraw = M('withdraw', 'tab_')->where($map)->find();

                $promote = get_promote_entity($widthdraw['promote_id']);
                /*参数  out_biz_no：打款单号  payee_type：账户类型 payee_account：支付账号  amount：转账金额  remark：备注*/
                // var_dump('{"out_biz_no":"'.$WidthdrawNo.'","payee_type":"ALIPAY_LOGONID","payee_a1ccount":"'.$promote['alipay_account'].'","amount":"'.$widthdraw['sum_money'].'","payer_show_name":"","payee_real_name":"","remark":"'.$vo->getDetailData().'"}');exit;

                $request->setBizContent('{"out_biz_no":"'.$WidthdrawNo.'","payee_type":"ALIPAY_LOGONID","payee_account":"'.$promote['alipay_account'].'","amount":"'.$widthdraw['sum_money'].'","payer_show_name":"","payee_real_name":"","remark":"'.$vo->getDetailData().'"}');

                $result = $aop->execute($request);
                $responseNode = str_replace(".", "_", $request->getApiMethodName()) . "_response";
                $resultCode = $result->$responseNode->code;
                $remark = date('Y-m-d H:i:s')."  提现单号：".$WidthdrawNo.", 提现";
                if(!empty($resultCode)&&$resultCode == 10000){
                    $data['status'] = 1;
                    $data['end_time'] = time();
                    $data['widthdraw_number'] = $WidthdrawNo;
                    $data['tx_account'] = $promote['alipay_account'];
                    $data['respond'] = $remark."成功<br/>".$widthdraw['respond'];
                    M('withdraw', 'tab_')->where($map)->save($data);
                    $se_data['ti_status']=1;
                    M('settlement','tab_')->where($map)->save($se_data);
                    return "10000";//提现成功
                } else {
                    $msg = $result->$responseNode->sub_msg;
                    $data['respond'] = $remark."失败:".$msg."<br/>".$widthdraw['respond'];
                    M('withdraw', 'tab_')->where($map)->save($data);
                    return $msg;
                }
                break;
                break;
        }

    }


		/**
		 * 商品订单表添加数据
		 * @param   PayVo   $vo
		 * @author  鹿文学
		 */
		private function add_order(Pay\PayVo $vo) {
			$order=M('order','tab_');

			$da = $order->where(['merchandise_id'=>$vo->getParam(),'buyer_id'=>$vo->getBuyerId()])->find();
			if(is_array($da)) {
				if($da['pay_status']==1) {return false;}
				$vo->setOrderNo($da['order_number']);
				return $da['id'];
			}

			$order_data['order_number']=$vo->getOrderNo();
			$order_data['buyer_id']=$vo->getBuyerId();
			$order_data['buyer_account']=$vo->getBuyerAccount();
			$order_data['seller_id']=$vo->getSellerId();
			$order_data['seller_account']=$vo->getSellerAccount();
			$order_data['seller_account']=$vo->getSellerAccount();
			$order_data['order_small_id']=$vo->getSmallId();
			$order_data['order_small_account']=$vo->getSmallAccount();
			$order_data['merchandise_id']=$vo->getParam();
			$order_data['order_price']=$vo->getFee();
			$order_data['poundage']=$vo->getPoundage();
			$order_data['real_money']=$vo->getMoney();
			$order_data['pay_way'] = $vo->getPayWay();
      $order_data['order_time'] = NOW_TIME;
			$order_data['pay_status'] = 0;
			$order_data['game_id'] = $vo->getGameId();

			$result = $order->add($order_data);
      return $result;
		}

    /**
     *消费表添加数据
     */
    private function add_spend(Pay\PayVo $vo, $param=array())
    {
        $spend = M("spend", "tab_");
        $spend_data['user_id'] = $vo->getUserId();
        $spend_data['user_account'] = $vo->getAccount();
        $spend_data['user_nickname'] = $vo->getUserNickName();
        $spend_data['game_id'] = $vo->getGameId();
        $spend_data['game_appid'] = $vo->getGameAppid();
        $spend_data['game_name'] = $vo->getGameName();
        $spend_data['server_id'] = $vo->getServerId();
        $spend_data['server_name'] = $vo->getServerName();
        $spend_data['game_player_id'] = $vo->getGameplayerId();
        $spend_data['game_player_name'] = $vo->getGameplayerName();
        $spend_data['promote_id'] = $vo->getPromoteId();
        $spend_data['promote_account'] = $vo->getPromoteName();
        $spend_data['order_number'] = "";
        $spend_data['selle_ratio'] = $vo->getRatio();
        $spend_data['pay_order_number'] = $vo->getOrderNo();
        $spend_data['props_name'] = $vo->getTitle();
        $spend_data['cost'] = $vo->getFee();
        $discount = $vo->getDiscount() == 0 ? 10 : $vo->getDiscount(); //获取折扣
        $price = $vo->getFee(); //获取原价
        $pay_amount = $discount * $price / 10; //计算折扣后的价格
        $vo->setFee($pay_amount);//构造表单 设置金额为折扣后的价格
        $spend_data['pay_amount'] = $pay_amount;
        $spend_data['pay_way'] = $vo->getPayWay();
        $spend_data['pay_time'] = NOW_TIME;
        $spend_data['pay_status'] = 0;
        $spend_data['pay_game_status'] = 0;
        $spend_data['extend'] = $vo->getExtend();
        $spend_data['spend_ip'] = get_client_ip();
        $spend_data['sdk_version'] = $vo->getSdkVersion();
        if($vo->getSmallId() !=  $vo->getUserId()) {
            $spend_data['small_id'] = $vo->getSmallId();
            $spend_data['small_account'] = $vo->getSmallAccount();
        }
        if ($param) {
        	$spend_data['deduction_amount'] = $param['deduction_amount'];
        	$spend_data['discount_amount'] = $param['discount_amount'];
        }
        $result = $spend->add($spend_data);
        return $result;
    }

    /**
     *平台币充值记录
     */
    private function add_deposit(Pay\PayVo $vo)
    {
        if (!empty($vo->getUc())) {
            $uc = new Ucservice();
            $uc_user = $uc->get_user_from_uid($vo->getUserId());
            $uc_id = $uc->uc_deposit($vo->getUserId(), $vo->getAccount(), $vo->getUserNickName(), $vo->getGameId(), $vo->getGameAppid(), $vo->getGameName(), 0, '', $vo->getPromoteId(), $vo->getPromoteName(), "", $vo->getOrderNo(), $vo->getFee(), time(), $vo->getExtend(), $vo->getPayWay(), get_client_ip(), '', 5, $uc_user['platform'], '', '');
        } else {
            $deposit = M("deposit", "tab_");
            // $ordercheck = $deposit->where(array('pay_order_number'=>$data["order_no"]))->find();
            // if($ordercheck)$this->error("订单已经存在，请刷新充值页面重新下单！");
            $deposit_data['order_number'] = "";
            $deposit_data['pay_order_number'] = $vo->getOrderNo();
            $deposit_data['user_id'] = $vo->getUserId();
            $deposit_data['user_account'] = $vo->getAccount();
            $deposit_data['user_nickname'] = $vo->getUserNickName();
            $deposit_data['promote_id'] = $vo->getPromoteId();
            $deposit_data['promote_account'] = $vo->getPromoteName();
            $deposit_data['pay_amount'] = $vo->getFee();
            $deposit_data['reality_amount'] = $vo->getFee();
            $deposit_data['pay_status'] = 0;
            $deposit_data['pay_way'] = $vo->getPayWay();
            $deposit_data['pay_source'] = 0;
            $deposit_data['pay_ip'] = get_client_ip();
            $deposit_data['pay_source'] = 0;
            $deposit_data['create_time'] = NOW_TIME;
            $deposit_data['sdk_version'] = $vo->getSdkVersion();
            $result = $deposit->add($deposit_data);
            return $result;
        }
    }

    /**
     *添加代充记录 支付宝 /威富通
     */
    private function add_agent(Pay\PayVo $vo)
    {
        $agent = M("agent", "tab_");
        $agnet_data['order_number'] = "";
        $agnet_data['pay_order_number'] = $vo->getOrderNo();
        $agnet_data['game_id'] = $vo->getGameId();
        $agnet_data['game_appid'] = $vo->getGameAppid();
        $agnet_data['game_name'] = $vo->getGameName();
        $agnet_data['promote_id'] = $vo->getPromoteId();
        $agnet_data['promote_account'] = $vo->getPromoteName();
        $agnet_data['user_id'] = $vo->getUserId();
        $agnet_data['user_account'] = $vo->getAccount();
        $agnet_data['user_nickname'] = $vo->getUserNickName();
        $agnet_data['pay_type'] = 0;//代充 转移
        $agnet_data['amount'] = $vo->getMoney();
        $agnet_data['real_amount'] = $vo->getFee();
        $agnet_data['pay_status'] = 0;
        $agnet_data['pay_way'] = $vo->getPayWay();
        $agnet_data['create_time'] = time();
        $agnet_data['zhekou'] = $vo->getParam();
        // $agnet_data['sdk_version']       = $vo->getSdkVersion();
        $agent->create($agnet_data);
        $result = $agent->add();
        return $result;
    }

    /**
     * @函数或方法说明
     * @支付宝查询订单信息
     * @param $order_no
     *
     * @author: 郭家屯
     * @since: 2019/5/7 9:31
     */
    public function alipay_orderquery($order_no,$out_trade_no){
        Vendor('Alipay.AopSdk');
        $aop = new \AopClient();
        $aop->gatewayUrl = 'https://openapi.alipay.com/gateway.do';
        $aop->appId = C('alipay.appid');
        $aop->signType = 'RSA2';
        $aop->rsaPrivateKey = file_get_contents("./Application/Sdk/SecretKey/alipay/rsa2_private_key.txt");
        $aop->alipayrsaPublicKey = file_get_contents("./Application/Sdk/SecretKey/alipay/alipay2_public_key.txt");
        $aop->apiVersion = '1.0';
        $aop->postCharset='UTF-8';
        $aop->format='json';
        $request = new \AlipayTradeQueryRequest();
        $data['out_trade_no'] = $out_trade_no;
        $data['trade_no'] = $order_no;
        $request->setBizContent(json_encode($data));
        $result = $aop->execute ($request);

        $responseNode = str_replace(".", "_", $request->getApiMethodName()) . "_response";

        $resultCode = $result->$responseNode->code;

        if(!empty($resultCode)&&$resultCode == 10000){
            return $result->$responseNode->total_amount;
        } else {
            return $result->$responseNode->sub_msg;
        }

    }
    /**
     * 绑币充值记录
     * @param Pay\PayVo $vo
     * @return mixed
     * author: xmy 280564871@qq.com
     */
    private function add_bind_recharge(Pay\PayVo $vo)
    {
        $agent = M("bind_recharge", "tab_");
        $agnet_data['order_number'] = "";
        $agnet_data['pay_order_number'] = $vo->getOrderNo();
        $agnet_data['game_id'] = $vo->getGameId();
        $agnet_data['game_appid'] = $vo->getGameAppid();
        $agnet_data['game_name'] = $vo->getGameName();
        $agnet_data['promote_id'] = $vo->getPromoteId();
        $agnet_data['promote_account'] = $vo->getPromoteName();
        $agnet_data['user_id'] = $vo->getUserId();
        $agnet_data['user_account'] = $vo->getAccount();
        $agnet_data['user_nickname'] = $vo->getUserNickName();
        $agnet_data['pay_type'] = 0;
        $agnet_data['amount'] = $vo->getMoney();
        $agnet_data['real_amount'] = $vo->getFee();
        $agnet_data['pay_status'] = 0;
        $agnet_data['pay_way'] = $vo->getPayWay();
        $agnet_data['create_time'] = time();
        $agnet_data['zhekou'] = $vo->getDiscount();
        $agnet_data['recharge_ip']      = get_client_ip();
        $agent->create($agnet_data);
        $result = $agent->add();
        return $result;
    }

		private function add_balance(Pay\PayVo $vo) {
        $balance = M("balance", "tab_");
        $balance_data['order_number'] = "";
        $balance_data['pay_order_number'] = $vo->getOrderNo();
        $balance_data['promote_id'] = $vo->getPromoteId();
        $balance_data['promote_account'] = $vo->getPromoteName();
        $balance_data['recharge_id'] = $vo->getUserId();
        $balance_data['recharge_account'] = $vo->getAccount();
        $balance_data['balance'] = $vo->getMoney();
        $balance_data['money'] = $vo->getFee();
        $balance_data['pay_status'] = 0;
        $balance_data['recharge_type'] = $vo->getPayWay();
        $balance_data['create_time'] = time();
        $balance->create($balance_data);
        $result = $balance->add();
        return $result;
    }

    /**
     * 设置支付驱动
     * @param string $class 驱动类名称
     */
    private function setDriver($class, $config)
    {
        $this->payer = new $class($config);
        if (!$this->payer) {
            E("不存在支付驱动：{$class}");
        }
    }

    public function __call($method, $arguments)
    {
        if (method_exists($this, $method)) {
            return call_user_func_array(array(&$this, $method), $arguments);
        } elseif (!empty($this->payer) && $this->payer instanceof Pay\Pay && method_exists($this->payer, $method)) {
            return call_user_func_array(array(&$this->payer, $method), $arguments);
        }
    }

}