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

<?php

namespace common\pay\lzf;

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['lzf.payUrl'];
        }
        if ($this->merNo == null) {
            $this->merNo = Yii::$app->params['lzf.merNo'];
        }
        if ($this->secretKey == null) {
            $this->secretKey = Yii::$app->params['lzf.secretKey'];
        }
    }

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

       //提交的参数
       $data['orderid']  =   $deposit['order_sn'];                  //订单号码
       $data['value']  = sprintf("%.2f",$deposit['rmb']);           //订单金额（以元为单位，保留两位小数）
       $data['parter']  =  $this->merNo;                            //商户号码
       //$data['type']  = $params['bankCode'];                      //业务代码
       $data['type']  = '965';                                      //业务代码
       $data['callbackurl']  =  $this->notifyUrl;                   //异步地址
       $data['hrefbackurl']  =  $this->returnUrl;                   //同步地址
       $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['restate']) && $data['restate'] == "0" ) {
                $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 "ok";
        } else {
            return "FAIL";
        }
    }

    /**
     * @param array $data
     * @return bool
     */
    public function handleReturn($data)
    {
        if (PayUtils::checkSign($data, $this->secretKey)) {
            if (isset($data['restate']) && $data['restate'] == "0") {
                $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)
    {
    }
}