Manager.php

<?php
/*!
 * yii2 extension - 支付系统
 * xiewulong <xiewulong@vip.qq.com>
 * https://github.com/xiewulong/yii2-payment
 * https://raw.githubusercontent.com/xiewulong/yii2-payment/master/LICENSE
 * create: 2015/1/10
 * update: 2015/11/17
 * version: 0.0.1
 */

namespace yii\payment;

use Yii;
use yii\base\ErrorException;
use yii\helpers\Json;
use yii\payment\models\Payment;
use yii\payment\models\PaymentNotify;
use yii\payment\apis\Wxpay;
use yii\payment\apis\Alipay;
use yii\payment\apis\Unionpay;
use yii\payment\apis\Baifubao;
use yii\payment\apis\Psbc;
use yii\payment\apis\Bolz;

class Manager{

	//支付单id前缀, 最高4位纯数字, 默认1000
	public $idpre = 1000;

	//认证密钥
	public $hashkey = false;

	//通知地址的协议类型, 'http'或'https'
	public $protocol = null;

	//配置支付方式
	public $modes = [];

	//交易记录
	private $payment = false;

	/**
	 * 获取openid
	 * @method getOpenId
	 * @since 0.0.1
	 * @param {string} $code 票据
	 * @return {string}
	 * @example \Yii::$app->payment->getOpenId($code);
	 */
	public function getOpenId($code){
		return Wxpay::sdk($this->modes['wxpay'])->getOpenId($code);
	}

	/**
	 * 获取微信网页授权地址
	 * @method getSnsapiUrl
	 * @since 0.0.1
	 * @param {string} $return_url 回调地址
	 * @param {string} [$state=null] 返回参数
	 * @return {string}
	 * @example \Yii::$app->payment->getSnsapiUrl($return_url, $state);
	 */
	public function getSnsapiUrl($return_url, $state = null){
		return Wxpay::sdk($this->modes['wxpay'])->getSnsapiUrl($return_url, $state);
	}

	/**
	 * 获取微信js网页支付打包信息
	 * @method getJsPackage
	 * @since 0.0.1
	 * @param {string} $openid 用户标识
	 * @param {string} $notify_url 异步通知地址
	 * @return {array}
	 * @example \Yii::$app->payment->getJsPackage($openid, $notify_url);
	 */
	public function getJsPackage($openid, $notify_url){
		$wxpayConfig = $this->modes['wxpay'];
		$wxpay = Wxpay::sdk($wxpayConfig);
		$prepay = $wxpay->createUnifiedOrder(array_merge($this->payment->toArray(), ['openid' => $openid]), $notify_url, 'JSAPI');

		$package = false;
		if($prepay['return_code'] == 'SUCCESS' && $prepay['result_code'] == 'SUCCESS'){
			$this->payment->tid = $prepay['prepay_id'];
			$this->payment->save();
			$package = [
				'appId' => $wxpayConfig['appid'],
				'timeStamp' => strval(time()),
				'nonceStr' => md5(mt_rand()),
				'package' => 'prepay_id=' . $this->payment->tid,
				'signType' => 'MD5',
			];
			$package['paySign'] = $wxpay->sign($package);
		}

		return $package;
	}

	/**
	 * 获取微信打包信息
	 * @method getPackage
	 * @since 0.0.1
	 * @param {string} $notify_url 异步通知地址
	 * @return {string}
	 * @example \Yii::$app->payment->getPackage($notify_url);
	 */
	public function getPackage($notify_url){
		$prepay = ['return_code' => 'FAIL', 'return_msg' => '签名验证失败'];
		$post = Wxpay::getXmlPostData();
		$wxpay = Wxpay::sdk($this->modes['wxpay']);
		if($wxpay->verifySign($post)){
			$payment = Payment::findById($post['product_id']);
			$prepay = $wxpay->createUnifiedOrder(array_merge($payment->toArray(), $post), $notify_url);
			if($prepay['return_code'] == 'SUCCESS' && $prepay['result_code'] == 'SUCCESS'){
				$payment->tid = $prepay['prepay_id'];
				$payment->save();
			}
		}

		return $prepay;
	}

	/**
	 * 第三方消息通知记录
	 * @method saveNotify
	 * @since 0.0.1
	 * @param {string} $mode 第三方支付端流水号
	 * @param {number} $pid 支付单id
	 * @param {number} $tid 第三方支付端流水号
	 * @param {boolean} $status 支付结果状态
	 * @param {boolean} $verified 消息验证结果
	 * @param {string} $data 消息通知数据
	 * @return {none}
	 * @example \Yii::$app->payment->saveNotify($mode, $pid, $tid, $status, $verified, $data);
	 */
	public function saveNotify($mode, $pid, $tid, $status, $verified, $data){
		$notify = new PaymentNotify;
		$notify->mode = $mode;
		$notify->pid = $pid;
		$notify->tid = $tid;
		$notify->status = $status;
		$notify->verified = $verified ? 1 : 0;
		$notify->data = Json::encode($data);
		$notify->created_at = time();
		$notify->save();
	}

	/**
	 * 完成支付
	 * @method complete
	 * @since 0.0.1
	 * @param {number} $id 支付单id
	 * @param {string} $tid 第三方支付端流水号
	 * @return {none}
	 * @example \Yii::$app->payment->complete($id);
	 */
	public function complete($id, $tid){
		$payment = $this->getPayment($id);
		if($payment->completed_at > 0){
			return false;
		}
		$payment->tid = $tid;
		$payment->completed_at = time();
		
		return $payment->save();
	}

	/**
	 * 验证签名
	 * @method verifySign
	 * @since 0.0.1
	 * @param {string} [$mode] 支付方式
	 * @param {boolean} [$async=false] 是否为异步通知
	 * @return {boolean}
	 * @example \Yii::$app->payment->verifySign($mode, $async);
	 */
	public function verifySign($mode, $async = false){
		$result = false;
		switch($mode){
			case 'wxpay':
				$result = Wxpay::sdk($this->modes[$mode])->verifySign();
				break;
			case 'alipay':
				$result = Alipay::sdk($this->modes[$mode])->verifySign($async);
				break;
			case 'unionpay':
				$result = Unionpay::sdk($this->modes[$mode])->verifySign($async);
				break;
			case 'baifubao':
				$result = Baifubao::sdk($this->modes[$mode])->verifySign($async);
				break;
			case 'psbc':
				$result = Psbc::sdk($this->modes[$mode])->verifySign();
				break;
			case 'bolz':
				$result = Bolz::sdk($this->modes[$mode])->verifySign($async);
				break;
		}

		return $result;
	}

	/**
	 * 进行支付
	 * @method getPayUrl
	 * @since 0.0.1
	 * @param {number} $id 支付单id
	 * @param {string} $async 异步通知地址
	 * @param {string} $sync 同步通知地址
	 * @param {string} [$hash=null] hash加密串
	 * @return {string}
	 * @example \Yii::$app->payment->getPayUrl($id, $async, $sync, $hash);
	 */
	public function getPayUrl($id, $async, $sync, $hash = null){
		$payUrl = null;
		$payment = $this->getPayment($id);
		if($this->hashkey === false || $payment->validateData($hash, $this->hashkey)){
			switch($payment->mode){
				case 'wxpay':
					$payUrl = $this->getWxpayPayUrl($async, $sync);
					break;
				case 'alipay':
					$payUrl = $this->getAlipayPayUrl($async, $sync);
					break;
				case 'unionpay':
					$payUrl = $this->getUnionPayUrl($async, $sync);
					break;
				case 'baifubao':
					$payUrl = $this->getBaifubaoUrl($async, $sync);
					break;
				case 'psbc':
					$payUrl = $this->getPsbcUrl($sync);
					break;
				case 'bolz':
					$payUrl = $this->getBolzPayUrl($async, $sync);
					break;
			}
		}

		return $payUrl;
	}

	/**
	 * 使用柳州银行进行支付
	 * @method getBolzPayUrl
	 * @since 0.0.1
	 * @param {string} $async 异步通知地址
	 * @param {string} $sync 同步通知地址
	 * @return {string}
	 */
	private function getBolzPayUrl($async, $sync){
		return Bolz::sdk($this->modes['bolz'])->getPayUrl($async, $sync, $this->payment->id, $this->payment->title, $this->getYuans($this->payment->amount), $this->payment->description, $this->payment->url);
	}

	/**
	 * 使用中国邮政储蓄银行进行支付
	 * @method getPsbcUrl
	 * @since 0.0.1
	 * @param {string} $sync 通知地址
	 * @return {string}
	 */
	private function getPsbcUrl($sync){
		return Psbc::sdk($this->modes['psbc'])->getPayUrl($sync, $this->payment->id, $this->getYuans($this->payment->amount));
	}

	/**
	 * 使用百付宝进行支付
	 * @method getBaifubaoUrl
	 * @since 0.0.1
	 * @param {string} $async 异步通知地址
	 * @param {string} $sync 同步通知地址
	 * @return {string}
	 */
	private function getBaifubaoUrl($async, $sync){
		return Baifubao::sdk($this->modes['baifubao'])->getPayUrl($async, $sync, $this->payment->id, $this->payment->title, $this->payment->amount);
	}

	/**
	 * 使用银联进行支付
	 * @method getUnionPayUrl
	 * @since 0.0.1
	 * @param {string} $async 异步通知地址
	 * @param {string} $sync 同步通知地址
	 * @return {string}
	 */
	private function getUnionPayUrl($async, $sync){
		return Unionpay::sdk($this->modes['unionpay'])->getPayUrl($async, $sync, $this->payment->id, $this->payment->amount);
	}

	/**
	 * 使用支付宝进行支付
	 * @method getAlipayPayUrl
	 * @since 0.0.1
	 * @param {string} $async 异步通知地址
	 * @param {string} $sync 同步通知地址
	 * @return {string}
	 */
	private function getAlipayPayUrl($async, $sync){
		return Alipay::sdk($this->modes['alipay'])->getPayUrl($async, $sync, $this->payment->id, $this->payment->title, $this->getYuans($this->payment->amount), $this->payment->description, $this->payment->url);
	}

	/**
	 * 使用微信进行支付
	 * @method getWxpayPayUrl
	 * @since 0.0.1
	 * @param {string} $async 异步通知地址
	 * @param {string} $sync 同步通知地址
	 * @return {string}
	 */
	private function getWxpayPayUrl($async, $sync){
		$this->payment->url = \Yii::$app->qrcode->create(Wxpay::sdk($this->modes['wxpay'])->createBizpayurl($this->payment->id));
		$this->payment->save();

		return [$this->modes['wxpay']['qrcodeRoute'], 'id' => $this->payment->id];
	}

	/**
	 * 获取hash加密串
	 * @method getPaymentHash
	 * @since 0.0.1
	 * @param {number} [$id=null] 支付单id
	 * @return {string}
	 */
	public function getPaymentHash($id = null){
		if($id){
			$this->getPayment($id);
		}

		return $this->payment === false ? null : $this->payment->generateDataHash($this->hashkey);
	}

	/**
	 * 获取当前支付单id
	 * @method getId
	 * @since 0.0.1
	 * @return {number}
	 */
	public function getId(){
		return $this->payment->id;
	}

	/**
	 * 创建交易记录
	 * @method create
	 * @since 0.0.1
	 * @param {number} $oid 订单id
	 * @param {number} $amount 交易总额(分)
	 * @param {string} $mode 支付方式
	 * @param {string} [$title=null] 订单名称
	 * @param {string} [$description=null] 描述信息
	 * @param {string} [$url=null] 商品展示url
	 * @return {number}
	 * @example \Yii::$app->payment->create($oid, $amount, $mode, $title, $description, $url);
	 */
	public function create($oid, $amount, $mode, $title = null, $description = null, $url = null){
		if(empty($oid)){
			throw new ErrorException('Order id must be requied');
		}
		if($amount <= 0){
			throw new ErrorException('Payment amount must be a positive integer');
		}
		if(!isset($this->modes[$mode])){
			throw new ErrorException('Unsupported payment mode');
		}
		if($this->disabledMode($mode)){
			throw new ErrorException('Payment mode has been disabled');
		}

		$this->payment = new Payment;
		$this->payment->id = $this->createId();
		$this->payment->oid = $oid;
		$this->payment->title = $title ? $title : \Yii::$app->name;
		$this->payment->amount = $amount;
		$this->payment->description = $description;
		$this->payment->url = $url;
		$this->payment->mode = $mode;
		$this->payment->save();

		return $this;
	}

	/**
	 * 创建支付单id
	 * @method createId
	 * @since 0.0.1
	 * @param {number|string} [$idpre=null] 支付单前缀
	 * @return {number}
	 */
	public function createId($idpre = null){
		return (empty($idpre) ? $this->idpre : $idpre) . floor(microtime(true) * 100) . mt_rand(100, 999);
	}

	/**
	 * 检查支付方式是否被禁用
	 * @method disabledMode
	 * @since 0.0.1
	 * @param {string} $mode 支付方式
	 * @return {boolean}
	 * @example \Yii::$app->payment->disabledMode($mode);
	 */
	public function disabledMode($mode){
		$mode = $this->modes[$mode];

		return isset($mode['disabled']) && $mode['disabled'];
	}

	/**
	 * 获取支付方式
	 * @method getMode
	 * @since 0.0.1
	 * @param {number} $id 支付单id
	 * @return {string}
	 * @example \Yii::$app->payment->getMode($id);
	 */
	public function getMode($id){
		return $this->getPayment($id)->mode;
	}

	/**
	 * 获取支付单
	 * @method getPayment
	 * @since 0.0.1
	 * @param {number} $id 支付单id
	 * @return {object}
	 */
	private function getPayment($id){
		if($this->payment === false || $this->payment->id != $id){
			$this->payment = Payment::findOne($id);
			if(!$this->payment){
				throw new ErrorException('No record of the transaction');
			}
		}

		return $this->payment;
	}

	/**
	 * 把金额转换成人民币大写
	 * @method getCapitalCny
	 * @since 0.0.1
	 * @param {float} $price 以元为单位的金额数值
	 * @return {string}
	 * @example \Yii::$app->payment->getCapitalCny($price);
	 */
	public function getCapitalCny($price){
		if($price > 999999999999999){
			throw new ErrorException('Amount out of range');
		}

		$numbers = ['零', '壹', '贰', '叁', '肆', '伍', '陆', '柒', '捌', '玖'];
		$units_integer = ['元', '拾', '佰', '仟', '万', '拾', '佰', '仟', '亿', '拾', '佰', '仟', '万', '拾', '佰', '仟'];
		$units_decimal = ['角', '分'];
		$cny = [];
		$_n = 0;

		list($integers, $decimals) = explode('.', number_format($price, 2, '.', ''));
		foreach(array_reverse(str_split($integers)) as $i => $n){
			if($i > 0 && !($i % 4) && in_array($cny[0], $units_integer)){
				array_shift($cny);
			}
			$_cny = $n > 0 || (!($i % 4) && $integers) ? ($n > 0 ? $n : null) . $units_integer[$i] : (!$_n && !$n ? null : $n);
			if($_cny !== null){
				array_unshift($cny, $_cny);
			}
			$_n = $n;
		}
		if($decimals > 0){
			foreach(str_split($decimals) as $i => $n){
				if($n > 0){
					array_push($cny, $n . $units_decimal[$i]);
				}
			}
		}else{
			array_push($cny, '整');
		}

		return str_replace(array_keys($numbers), $numbers, implode('', $cny));
	}

	/**
	 * 把金额转换成以元为单位
	 * @method getYuans
	 * @since 0.0.1
	 * @param {number} $cents 以分为单位的金额
	 * @param {boolean} [$float=false] 是否强制以浮点输出
	 * @param {number} [$decimals=2] 规定多少位小数
	 * @param {string} [$separator=''] 规定用作千位分隔符的字符串
	 * @param {string} [$decimalpoint='.'] 规定用作小数点的字符串, 默认'.'
	 * @return {number|float}
	 * @example \Yii::$app->payment->getYuans($cents, $float, $decimals, $separator, $decimalpoint);
	 */
	public function getYuans($cents, $float = false, $decimals = 2, $separator = '', $decimalpoint = '.'){
		$yuans = $cents / 100;

		return $float ? number_format($yuans, $decimals, $decimalpoint, $separator) : $yuans;
	}

}