kiri-wchat/wchat/qq/pay/Enterprise_payment.php

<?php


namespace wchat\qq\pay;


use Exception;
use wchat\common\Help;
use wchat\common\HttpClient;
use wchat\common\Result;
use wchat\qq\SmallProgram;

/**
 * Class Enterprise_payment
 * @package wchat\qq\pay
 */
class Enterprise_payment extends SmallProgram
{
	public $_cash = '/cgi-bin/epay/qpay_epay_b2c.cgi';

	private $_errors = [
		'SYSTEMERROR'              => '系统错误',
		'PARAM_ERROR'              => '请求参数未按指引进行填写',
		'SIGNERROR'                => '参数签名结果不正确',
		'OP_USER_PASSWD_ERROR'     => '操作员密码校验失败',
		'OP_USER_AUTH_ERROR'       => '操作员权限错误',
		'TRANSFER_FEE_LIMIT_ERROR' => '转账限额错误',
		'TRANSFER_FAIL'            => '收款用户的账户不支持收款，收款失败',
		'NOTENOUGH'                => '商户营销账户的余额不足',
		'ORDERNOTEXIST'            => '转账订单不存在',
		'APPID_OR_OPENID_ERR'      => 'appid 或 openid 非法',
		'TOTAL_FEE_OUT_OF_LIMIT'   => '单笔限额检查失败',
		'SPID_NOT_ALLOW'           => '当前商户不支持企业付款',
		'REALNAME_CHECK_ERROR'     => '实名检查失败',
		'RE_USER_NAME_CHECK_ERROR' => '用户真实姓名校验失败',
		'INVALID_CERTIFICATE'      => '证书非法',
	];

	private $_requestParams = [];

	/**
	 * @param $value
	 */
	public function setOpUserId($value)
	{
		$this->_requestParams['op_user_id'] = $value;
	}

	/**
	 * @param $value
	 */
	public function setOpUserPassword($value)
	{
		$this->_requestParams['op_user_passwd'] = $value;
	}

	/**
	 * @param $value
	 */
	public function setSpbillCreateIp($value)
	{
		$this->_requestParams['spbill_create_ip'] = $value;
	}

	/**
	 * @param $mch_billno
	 * @param $openId
	 * @param $price
	 * @return mixed
	 * @throws Exception
	 */
	public function mch_send($mch_billno, $openId, $price)
	{
		$client = HttpClient::NewRequest();
		$client->setIsSSL(true);
		$client->setSslCertFile($this->getConfig()->getSslCert());
		$client->setSslKeyFile($this->getConfig()->getSslKey());
		$client->setCa($this->getConfig()->getSslCa());
		$client->setUseSwoole($this->getConfig()->isUsrSwoole());
		$client->setHost('api.qpay.qq.com');
		$client->setCallback(function ($response, $requestParam) {
			$json = json_decode($response, true);
			if (isset($json['return_code']) && $json['return_code'] != 'SUCCESS') {
				$array['code'] = 500;
				$array['message'] = $json['return_msg'] ?? $json['retmsg'];
			} else if ($json['result_code'] != 'SUCCESS') {
				$array['code'] = 500;
				$array['message'] = $this->_errors[$json['err_code']] ?? $json['err_code_desc'];
			} else {
				$array['code'] = 0;
				$array['message'] = 'system success';
				$array['data'] = $json;
			}
			$array['data']['request'] = $requestParam;
			return new Result($array);
		});
		$response = $client->post($this->_cash, $this->orderConfig($mch_billno, $openId, $price));
		if (!$response->isResultsOK()) {
			throw new Exception($response->getMessage());
		}
		return $response->getData();
	}

	/**
	 * @param $mch_billno
	 * @param $openId
	 * @param $price
	 * @return array
	 */
	private function orderConfig($mch_billno, $openId, $price)
	{
		$requestParam['input_charset'] = 'UTF-8';
		$requestParam['nonce_str'] = Help::random(32);
		$requestParam['out_trade_no'] = $mch_billno;
		$requestParam['mch_id'] = $this->getConfig()->getMchId();
		$requestParam['appid'] = $this->getConfig()->getAppid();
		$requestParam['openid'] = $openId;
		$requestParam['fee_type'] = 'CNY';
		$requestParam['total_fee'] = $price * 100;
		$requestParam['memo'] = $this->getConfig()->getBody();
		$requestParam['notify_url'] = $this->getConfig()->getNotifyUrl();
		$requestParam['spbill_create_ip'] = $this->getConfig()->getNotifyUrl();

		if (!empty($this->_requestParams) && is_array($this->_requestParams)) {
			$requestParam = array_merge($requestParam, $this->_requestParams);
		}

		$requestParam['sign'] = Help::sign($requestParam, $this->getConfig()->getKey(), 'MD5');

		return $requestParam;
	}


	/**
	 * @return string
	 * @throws Exception
	 */
	public function mchOrderNo()
	{
		return implode([
			$this->getConfig()->getMchId(),
			date('Ymd'),
			random_int(11, 99),
			date('His'),
			random_int(11, 99)
		]);
	}


	/**
	 * @param array $requestParams
	 * @return bool
	 */
	public function validator(array $requestParams)
	{
		$notifySign = $requestParams['sign'];
		unset($requestParams['sign']);
		$sign = Help::sign($requestParams, $this->getConfig()->getKey(), 'MD5');

		if ($sign !== $notifySign) {
			return false;
		}

		return true;
	}

}