fusian/fusiancrm/service/common/pay/yunfu/PayHandler.php

<?php

namespace common\pay\yunfu;

use backend\models\Config;
use backend\models\Deposit;
use backend\models\SyncDesposit;
use common\helpers\Utils;
use common\pay\BasePayHandler;
use Yii;

class PayHandler extends BasePayHandler
{
    public $payUrl;     //支付网关
    public $merNo;      //商户号码
    public $secretKey;  //密钥

    /**
     * @inheritdoc
     */
    public function init()
    {
        parent::init();
        if ($this->payUrl == null) {
            $this->payUrl = Yii::$app->params['yunfu.payUrl'];
        }
        if ($this->merNo == null) {
            $this->merNo = Yii::$app->params['yunfu.merNo'];
        }
        if ($this->secretKey == null) {
            $this->secretKey = Yii::$app->params['yunfu.secretKey'];
        }
    }

    /**
     * @param array $deposit
     * @param array $params
     * @return string
     */
    public function outPay($deposit, $params = [])
    {
        $data = [];

       //提交的参数
       $data['version'] = '1.8';                            //版本号码
       $data['merchantId']  =  $this->merNo;                //商户号码
       $data['goodsName']  =  $deposit['order_sn'];         //商品名称

       $data['payType'] = 'b2c';                           //支付类型(B2C网银)
       $data['bankCode']  = $params['bankCode'];           //网银支付(额外参数:什么银行)
       $data['orderId']  =   $deposit['order_sn'];         //订单号码

       $data['amount']  = sprintf("%.2f",$deposit['rmb']); //订单金额（以元为单位，保留两位小数）
       $data['notifyUrl']  =  $this->notifyUrl;            //异步地址
       $data['returnUrl']  =  $this->returnUrl;            //同步地址
       $data['signType']  = 'MD5';                         //签名方式
       
       $data['sign'] = PayUtils::makeSign($data, $this->secretKey); // 签名

       return self::createHtml($data, $this->payUrl);
    }

    /**
     * @param array $data
     * @return bool
     */
    public function handleNotify($data)
    {
       
        if (PayUtils::checkSign($data, $this->secretKey)) {

            if ( isset($data['status']) && $data['status'] == "SUCCESS" ) {
                $merOrderId = trim($data['orderId']);
                /** @var Deposit $model */
                $reuslt = Deposit::find()->where(['order_sn' => $merOrderId])->asArray()->limit(1)->one();
                if ($reuslt['type'] != 1) {
                    $res = Deposit::updateAll(['type' => 1], "order_sn = $merOrderId");
                    $configData = Config::find()->asArray()->one();
                    if ($configData['auto_deposit'] == 1 && $res) {
                        $syncDespositModel = new SyncDesposit();
                        $syncDespositModel->login = $reuslt['login'];
                        $syncDespositModel->amount = $reuslt['amount'];
                        $syncDespositModel->comment = 'Deposit';
                        $syncDespositModel->memo = $merOrderId;
                        $syncDespositModel->type = 2;
                        $syncDespositModel->in_time = time();
                        $syncDespositModel->save();
                    }
                }
                return true;
            }
        }
        return false;
    }

    public function outNotify($success)
    {
        if ($success == true) {
            return "SUCCESS";
        } else {
            return "FAIL";
        }
    }

    /**
     * @param array $data
     * @return bool
     */
    public function handleReturn($data)
    {
        if (PayUtils::checkSign($data, $this->secretKey)) {
            if (isset($data['status']) && $data['status'] == "SUCCESS") {
                $merOrderId = trim($data['orderId']);
                /** @var Deposit $model */
                $model = Deposit::find()->where(['id' => $merOrderId])->asArray()->limit(1)->one();
                if ($model) {
                    return true;
                }
            }
        }
        return false;
    }

    public function outReturn($success)
    {
    }
}