shrx/application/api/controller/Huifu.php

<?php

namespace app\api\controller;

use app\common\model\VideoOrder;
use think\Log;

class Huifu
{
    const pay = 'https://api.huifu.com/v2/trade/payment/jspay';
    const micropay = 'https://api.huifu.com/v2/trade/payment/micropay';
    const refund = 'https://api.huifu.com/v2/trade/payment/scanpay/refund';
    const preorder = 'https://api.huifu.com/v2/trade/hosting/payment/preorder';
    const htRefund = 'https://api.huifu.com/v2/trade/hosting/payment/htRefund';
    private static $sys_id = '6666000157488006';
    private static $SDK_VERSION ='php#v2.0.11';
    private static  $config = [

    ];
    /*
    private static $buyer_id = '6666000155248241';
    private static $rsa_merch_private_key = 'MIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDVzaC2yYLzmNosv9BLqAw2f6EqqbF7e01y4kLuhhLL0RhiIB3boex9egcb1Z4wuxo7uNOmLzkRgtQg/q+gwMIl6UpvGx+LdFBP5szQfu0T6NP1Q+IeN1Nl3hyNQrwhO0sqKGguv3rAXo58c9VZVH7BCpnsI+X0j8HTrtnADw+ixKKWAcmMKh9WbIJO0xYpPL7smmiMFuwYU2oYF5Y79RdzPYqTvs+M4WMdxfamHxggpVme40+3eJdc8nT/03ihhPumpHpyqorJx2Q2UhSg5fviOrh3LTKsoNwvsA4V9QeOt5PO67muR6wTvwJbXoiqPZ0xxP0cWUajs/FtQB57j+/RAgMBAAECggEAWU5mNlPgBj6vy4dny2Jrj4wqVvbA8xJjHHzUdmu8iDRUGhDOSALQFO2W8JJ/XF2bLJ0ck0sgbGcYkpuv4tcBgfJ7rANJXuf78BQ5M1IBV5KmjsmHNxXnGSL5DCx3Bu6MjBSKyBQlgxs8K1H7KTA5Lgtulgu8rzYpQXHE9QuVfWgf/9QrOJyxJ8ekOJT6CteOB0Hi2wvTh1MtLhS9apdAgSZVApeWJVB2oHi0txp6pF6UnhZqAYxyb0fu+EarFfav3woRh/6XVgxiJdc2+SOfP7DxJJM02ASoXaD32Sb7GhIDxcHkOpQi+oluZc7WrnXgxgNhr0oGcb+vE5aR5N/GEQKBgQDu92Mfv68X9kMFVlF1ZdfGbS/zhLpS/xtfxovNEuIZAxbiV3wmOOfEEcMRyCUC8zU8R+iV3tUkLU5gJBTZvt9gJ8YMYs6OwcOMw3wJJHU+/Y1u2HRjMrbmUEsmkR6q0AhE0HhXBi7ANZ4ngkXwDn0OcSrZzM9wB/KH3Eq9unX5rQKBgQDlCxGVqE81mwN5Uk7TAtbkoJibMXmVJpXJDSPM+26hGvppy6STOytAMbuHvH8QmLxxRgGGERlkeB8qNMQPVRgI/JU9LjkKBlDNrI9lMVKhpi2q+YNorm2D37yu8Ms2ekbaScMlMYsxUzdDDPeZX1hQLCdEBpIUXlVA3/k1JMYbNQKBgQDtreFJkr30d1vx0wjyW3liQveOnlU0d8giWrhyIHYBqrD4L0usOK1Mtt3uscMeTAiHDH6pkhktAmMR/NFAQjiqyuSRLTWFh/OX7ldQQJLdNBOYTHJ2t9py+SnGElEOVBvlVfRbmiqlwq6rXUdynPaFhsm4F527MCxqNRGh4/OzgQKBgQCvdbxB1o7fdOHDZf9GfM1clX5ynQMT9FwYib1cQVztg/pDY6Kuu0wVwEN15zu73hW1/LgcGStHoRHWxldPm5NvBvfYx3kgqdfqx3+OOKuhc+lWKhC197GjrZkgtwwlrqRqgslAy+Rio+oYrm1bDAReXoSyAwqTGfTbXvjM8l/k5QKBgQCjUpkWibbLxT3HhlCddwwZ1nYSktUw4yF6l91NOTLvzCJgAP6/ucq0W5uN4FPW87f4KkO64xOlTcWiGNUb9zZQXOPM9mFecZeorI+dPaR466vMA2jWDeYEaUi4973knKW8uaSAsykz0JahXNBQEYM2T/sLedsW6RUcexXlTFvBNg==';
    private static $public_key = 'MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAn56S55hWOVW1d0b5LMASBhQ11TXjBo/gogo6YcmC6zpD3cL9WxHE8rfHbJhrLSOsHT2FM+meJ7l3InjIro6/dTNv3lQQsecjRM2Dlnlbr+lX3C20d52JMxFNGxGbY+ai/htlGNG9MEMDw0KgKbFs92pHhSGTlPubuRWu9XN07HmO3eTzzTFusKo8lzIPA3Dm2KM+L66OGiNQT0cGOV+JS12/OcSRP5+XX1GwqBF9TRENZnIeO9l+uS2x12QWMeezf6PaTMPLIUjR/mfz8uiYd3lfJDBd8hwWsfD16M0F/KqXrHykmEw0sTgA6dgIl43Hbo4u5DFHoB2C8QR04Y7ekwIDAQAB';
*/
    private static $buyer_id = '2088160921651421';
    private static $rsa_merch_private_key = 'MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCQ1CFgS8IceyBFlMbsJFOGHjf9X4BF7MDGK7cqZi7n7nKFsxIoxcaMX+iGWumK6505BvbupIGBF1nG/ikwLDXk0eaQKusmscGOIAaLmb2jQX+lz7lj/zGfPGUpLT74+RI3hfYCycjaAGy/hnMY6Esckly8WD3urxj1LANwU6LklGYeuO8kdkQjfTd893uuuK9Zyvm7BFn4hWW4Ymi/c7JUx866FHIu4nxyBTx1PhJvZtX7zYVltDI/oGU6RiNml83wVgFivEhJno5+XYA9/KA7AWUPE2t19y2Y7cj4Sf9a8yfCFTSh/Qj73x/ZqR16oR29YXm1leP3Lycajc73PhLfAgMBAAECggEALy9t0FneXDkhQoo+ZSFQtRmTVFGRETcZd3c2rfGsxpPBbB3zhKUrEwEMWPm1rTUmfDXwrb+bEdvxvAuCj9dXl71rSP0yr+CqFwwIFeN5DX+Bfxw2YoX6PM8IhmnfYm6DqONUS4RClAQfaib7yNml3yEwZYy6YNFbaEV2uVoGcEILmiM3NEEXt7Mz+8r+BxnxO4vPeBDBuRV8fI9vB0QU3vA7hcxtT08VLi1+Ow2ClVO7QYQvyrYM5BTebxVED+NP87lhOnM/KQ9NFTfPD5gnnxcP69w/iUp7Evc/mg2ANd/Veq3+RfX61W4OL18V6O9VJ3DNqClYQO61V0d8NlkLQQKBgQDG9y/JU/PL47U/+vh4Wd4c7b42b51IIDTekzi+4h5yJYLLmBIMx62DbCGxgpHkrFULGGAt4O5bY3hYPLiI3nWKZJ0vC2LgFN3dbJeTrLdHjKiqQKfou66Q/h2KgGT7kWL5YugDsvqGDBHh+NuJdo7AxPNb5C6k0JogDrgBc03PMwKBgQC6WC3qWlZliTfCxBg3lKNqjRSXgqXHAiS5MFaCXN01yhzjyrnxNDkLFovSlzg+m/S5FLwSwpGR3uq671At/SixMH1j5VjofXm8bePMcVcZrFkgDwR0wOCuquZGIEMU0ehJrX+SVkKrd+VehTxk0zAGLlwF7F4hMpWHHkoC3uZdpQKBgQCVnRDJAqEkI2GK7+zhiypTdI8BHiMWNmmrKOeV2jDswro84GhKReh7F9eqRLXyT4hPpI/GUArMm9rF9zsIaMfYPlpYIubB+87uDxdYC5tyaRn3lFDu2Bqnmv6ZxHyrEyNqxm4TQgXSwMa9tsVW89jaqf8ZjVdpxhbvnkHNjWfoMwKBgEgs71veMaiSRW7C1T5x6/nROzCUAfHa+q5f8qH7phK3fgkc9HhgadfJm86tk7NsZJVrWo1Jn2iIlxJgrwWhEKnQxkBzDMTAFO7PAXSmUb436y1no6o1KtF8kESJKnJd+0LOWKMtlhUkE0tQ/9ttkSRTwIDq1Gq3VQNI0BHclA2hAoGBAKnWIcyOH8gbtrnf7+3YWNwDiUIMM2vPtAWP1C93WlxW4s+bDBYIm0ypxVj9ukTnySZ7FPdXr2cvJ/nf4Jt4GS66dnLqbEhJNO4aCaqwIRfFEj2NBj9tK9Klb4bcXPj1v054NY9vHsmu0ZxpJ7AsbFyN/dh3lt7NqPlqggrSNoqN';
    private static $public_key = 'MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAnE/txn9A63HmNInKbfLPuzPWXWuVZ7e6SR0ENRB1Bl8l1w9bGpmF+/LH4+ItXI4s1EcedBS2GU/PEHo4v4wB1H3+U4PF8z4IQMmtbOIKMNBtzguKnYStVfKsmGnVea/emxbKzYaUyoQd9hXGN/4BmpLXey5huN8qxulicjBAl4ywXmQBfdmp77XABPFOcFBuRw1ejP4npcE+lU4RHjgUPAaGIqlISg95HNBjtM8Ce06sYu4Ev7yTBwaHsUnjVMhvfw1TnrdHW9hmoQ4J5udDyUT4tDra5pvh3f7oKkYJn54uRmXxxSfhhAfSgJu0Oy4t8+QKEJ8Dc+NboGVyL0ojMwIDAQAB';
    private static $product_id = 'HSK';

//    private static $notify_url = "https://ts.shanghairongxuan.top/api/hj/notify";
    private static $notify_url = "https://ts.shanghairongxuan.top/api/pay/notify";
    private static $refund_notify_url = "https://ts.shanghairongxuan.top/api/hj/refund";
    # 请求头
    private static $httpHeaders;
    # 网络应答码
    private static $httpStateCode;
    # 请求数据
    private  static $reqDatas;
    # 应答数据
    private static $rspDatas;

    # 请求报错
    private  static $error = null;

    public static function curlRequest( $url, $postFields = null, $file = null,  $headers = array('Content-type: application/json'), $is_json=true) {
        // $postFields['needSign'] 是否需要添加签名， $postFields['needVerfySign'] 是否需要验证签名
        $needSign = isset($postFields['needSign']) ? $postFields['needSign'] : true;
        $needVerfySign = isset($postFields['needVerfySign']) ? $postFields['needVerfySign'] : true;
        unset($postFields['needSign'],$postFields['needVerfySign']);
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_FAILONERROR, false);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_HEADER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        if (is_array($postFields) && 0 < count($postFields)) {
            curl_setopt($ch, CURLOPT_POST, true);
            $body = self::createBody( $postFields, $file);
            if (!$needSign) {
                unset($body['sign']);
            }
            if ($is_json) {
                $json_data = json_encode($body);
                array_push($headers, "Content-Length:" . strlen($json_data));
                curl_setopt($ch, CURLOPT_POSTFIELDS, $json_data);
            } else {
                curl_setopt($ch, CURLOPT_POSTFIELDS, $body);
            }
            self::$reqDatas = $body;
        }
        # 拼装请求头
        self::$httpHeaders = self::createHeaders($headers);
        curl_setopt($ch, CURLOPT_HTTPHEADER, self::$httpHeaders );
        # 执行网络请求
        $resultString = curl_exec($ch);
        # 处理系统的报错
        if (curl_errno($ch)) {
            self::$error = curl_error($ch);
            curl_close($ch);
            return self::$error;
        }

        # http应答码
        self::$httpStateCode = curl_getinfo($ch,CURLINFO_HTTP_CODE);
        # 关闭本次会话
        curl_close($ch);
        self::$rspDatas = json_decode($resultString, true);
        @file_put_contents('hfcuel.txt',json_encode(self::$rspDatas)."\r\n");
        @file_put_contents('hfcuel.txt',json_encode(self::$httpStateCode),8);
        $resp_sign = isset(self::$rspDatas['sign']) ? self::$rspDatas['sign'] : '';
        # 不需要对应答数据验签的逻辑分支，斗拱存在一些不用验签的接口，例如：页面版的快捷支付、手机网页支等
        if (!$resp_sign ||  self::$httpStateCode== 401) {
            if ($needVerfySign) {
                self::$error = array(
                    'code' => 'RESP_SIGN_VERIFY_UNDO',
                    'msg' => '无法对应答数据进行验签',
                );
            }
            if (!self::$rspDatas) {
                # 无法解析出json格式的情况，就直接就把应答数据返回出去，针对返回数据为html页面的接口，例如：页面版的快捷支付等
                self::$rspDatas = $resultString;
            }
            return self::$error;;
        }

        $resp_data = isset(self::$rspDatas['data']) ? self::$rspDatas['data'] : '';

        // TODO response 应答错误 hardcode 待优化 --- Charles.huang 2021/09/09

        # 对返回数据验签失败的逻辑分支
        if (!self::verifySign_sort($resp_sign, $resp_data, self::$public_key)) {
            self::$error = array(
                'code' => 'RESP_SIGN_VERIFY_FAILED',
                'msg' => '接口结果返回签名验证失败',
            );
            return self::$error;
        }

        # 应答码异常情况
        if (self::$httpStateCode < 200 || self::$httpStateCode >= 400) {
            self::$error = array(
                'code' => 'HTTP_REQUEST_FAILED',
                'msg' =>  "请求失败: HTTP_STATE_CODE-".self::$httpStateCode,
            );
            return self::$error;
        }
        return self::$rspDatas;
    }

    private static function createHeaders($header_data = array()){
        $headers = $header_data;
        if (empty($header_data)){
            $headers = array('Content-type: application/x-www-form-urlencoded');
        }
        array_push($headers, 'sdk_version:' .self::$SDK_VERSION);
        array_push($headers, 'charset:UTF-8');
        return $headers;
    }

    private static function createBody($post_data, $file = null){
        $body = array();
        $body['sys_id'] = self::$sys_id;
        $body['product_id'] =self::$product_id;
        ksort($post_data);  // 根据key排序
        $body['data'] = $post_data;
        #  执行签名
        $sign = self::sha_with_rsa_sign(
            json_encode($post_data, JSON_UNESCAPED_SLASHES|JSON_UNESCAPED_UNICODE),    // 数据里有中文和斜杠都不转码
            self::$rsa_merch_private_key);
        $body['sign'] = $sign;
        if(!empty($file)){
            $body['file'] = $file;
            $body['data'] = json_encode($post_data, JSON_UNESCAPED_UNICODE);
        }
        return $body;
    }

    /**
     * 本次请求的http头信息
     */
    public static function getHttpHeaders()
    {
        return self::$httpHeaders;
    }

    /**
     * 本次请求应答的 http状态码
     */
    public static function getHttpStateCode()
    {
        return self::$httpStateCode;
    }

    /**
     * 本次请求的数据
     */
    public static function getReqDatas()
    {
        return self::$reqDatas;
    }

    /**
     * 本次请求的应答数据
     */
    public static function getRspDatas()
    {
        return self::$rspDatas;
    }

    /**
     * 获取请求执行失败信息
     */
    public static function getErrorInfo()
    {
        return self::$error;
    }

    /**
     * 请求是否成功执行
     */
    public static function isError()
    {
        return self::$error != null;
    }

    public static function wxJsPay($OpenId,$order_id,$order_amount,$order_name,$attach='product')
    {
        $order_amount = bcmul($order_amount,'1',2);
        $data['time_expire'] = date('YmdHis',time()+60);
        $data['req_date'] = date('Ymd');
        $data['req_seq_id'] = $order_id;
        $data['huifu_id'] = self::$sys_id;
        $data['goods_desc'] = $order_name;
        $data['trans_amt'] = $order_amount;
        $data['trade_type'] = 'T_MINIAPP';
        $data['wx_data']['attach'] = $attach;
        if($OpenId) {
            $data['wx_data']['sub_appid'] = 'wx9d53e46a38eda4b9';
            $data['wx_data']['sub_openid'] = $OpenId;
        }
        if($attach=='user_recharge') {
            $huifu_id = '6666000158522222';
            $rs['acct_infos'] = [
                [
                    'huifu_id' => $huifu_id,
                    'percentage_div' => '100.00'
                ],
                [
                    'huifu_id' => self::$sys_id,
                    'percentage_div' => '0.00'
                ]
            ];
            $rs['percentage_flag'] = 'Y';
            $rs['is_clean_split'] = 'Y';
            $data['acct_split_bunch'] = json_encode($rs, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);
        }
        elseif($attach=='product') {
            $order1 = explode('_',$order_id);
            if(sizeof($order1)==2) $order_id = $order1[1];
            $store_id = VideoOrder::where('out_trade_no', $order_id)->value('store_id');
        }
        $data['notify_url'] = self::$notify_url."/weixin";

        $result = self::curlRequest(self::pay,$data);
        return $result;
        if (!$result || self::isError()) {  //失败处理
            var_dump(self::getErrorInfo());
        } else {    //成功处理
            var_dump($result);
        }
    }
    public static function Ali_NATIVE($order_id,$order_amount,$order_name,$attach='product')
    {
        $order_amount = bcmul($order_amount,'1',2);
        $data['pay_scene'] = '02';
        $data['time_expire'] = date('YmdHis',time()+60);
        $data['req_date'] = date('Ymd');
        $data['req_seq_id'] = $order_id;
        $data['huifu_id'] = self::$sys_id;
        $data['goods_desc'] = $order_name;
        $data['trans_amt'] = $order_amount;
        $data['trade_type'] = 'A_NATIVE';
        $data['alipay_data']['buyer_id'] = self::$buyer_id;
        $data['notify_url'] = self::$notify_url."/alipay";
        $result = self::curlRequest(self::pay,$data);
        if (!$result || self::isError()) {  //失败处理
            var_dump(self::getErrorInfo());
        } else {    //成功处理
            var_dump($result);
        }
    }
    public static function micropay($auth_code,$order_id,$order_amount,$order_name,$attach='product')
    {

        $order_amount = bcmul($order_amount,'1',2);
        $data['pay_scene'] = '02';
        $data['time_expire'] = date('YmdHis',time()+60);
        $data['req_date'] = date('Ymd');
        $data['req_seq_id'] = $order_id;
        $data['huifu_id'] = self::$sys_id;
        $data['goods_desc'] = $order_name;
        $data['trans_amt'] = $order_amount;
        $data['auth_code'] = $auth_code;

        if($attach=='user_recharge') {
            $huifu_id = '6666000158522222';
            $rs['acct_infos'] = [
                [
                    'huifu_id' => $huifu_id,
                    'percentage_div' => '100.00'
                ],
                [
                    'huifu_id' => self::$sys_id,
                    'percentage_div' => '0.00'
                ]
            ];
            $rs['percentage_flag'] = 'Y';
            $rs['is_clean_split'] = 'Y';
            $data['acct_split_bunch'] = json_encode($rs, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);
        }
        elseif($attach=='product') {
            $order1 = explode('_',$order_id);
            if(sizeof($order1)==2) $order_id = $order1[1];
            $store_id = StoreOrder::where('order_id', $order_id)->value('store_id');
            if ($store_id > 0) {
                $huifu_id = \app\model\store\SystemStore::where('id', $store_id)->value('huifu_id');
                if ($huifu_id) {
                    $rs['acct_infos'] = [
                        [
                            'huifu_id' => $huifu_id,
                            'percentage_div' => '100.00'
                        ],
                        [
                            'huifu_id' => self::$sys_id,
                            'percentage_div' => '0.00'
                        ]
                    ];
                    $rs['percentage_flag'] = 'Y';
                    $rs['is_clean_split'] = 'Y';
                    $data['acct_split_bunch'] = json_encode($rs, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);
                }

            } else {

            }
        }
        $data['risk_check_data']['ip_addr'] = app()->request->ip();
        $data['notify_url'] = self::$notify_url."/micropay?attach=".$attach;
        @file_put_contents("micropay.txt",json_encode($data)."\r\n");
        $rs = self::curlRequest(self::micropay,$data);
        @file_put_contents("micropay.txt",json_encode($rs),FILE_APPEND);
        if($rs['data']['resp_code']=='00000000' && $rs['data']['trans_stat']=='S') {
            (new Hook(PayNotifyServices::class, 'huifu'))->listen($attach, $order_id, $rs['data']['out_trans_id'],$rs['data']['req_seq_id']);
            return $rs;
        }elseif($rs['data']['resp_code']=='00000100')
        {
            return $rs;
        }
        else
        {
            self::$error = $rs['data']['resp_desc'];
            return false;
        }
    }
    public static function refund($order_id,$pay_time,$refund_amount,$refund_reason,$attach="product")
    {
        $data['req_date'] = date('Ymd');
        $data['req_seq_id'] = 'ref'.uniqid(true);
        $data['huifu_id'] = self::$sys_id;
        $data['ord_amt'] = bcmul($refund_amount,'1',2);
        $data['remark'] = $refund_reason;
        $data['org_req_date'] = date("Ymd",$pay_time);
        $data['org_req_seq_id'] = $order_id;
        $data['notify_url'] = self::$refund_notify_url."/micropay?attach=".$attach;
        $result = self::curlRequest(self::refund,$data);
        @file_put_contents("hf1.txt", json_encode($result));
        if(($result['data']['trans_stat']=='S' || $result['data']['trans_stat']=='P')) {
            return true;
        }
        else
        {
            return false;
        }
    }
    public static function miniapp_pay($OpenId,$order_id,$order_amount,$order_name,$attach='product')
    {
        //$data['time_expire'] = date('YmdHis',time()+120);
        $order_amount = bcmul($order_amount,'1',2);
        $data['req_date'] = date('Ymd');
        $data['req_seq_id'] = $order_id;
        $data['huifu_id'] = self::$sys_id;
        $data['goods_desc'] = $order_name;
        $data['trade_type'] = 'T_MINIAPP';
        $data['trans_amt'] = $order_amount;
        if($OpenId) {
            $data['wx_data']['sub_appid'] = 'wx9d53e46a38eda4b9';
            $data['wx_data']['sub_openid'] = $OpenId;
        }
        $data['openid'] = $OpenId;


        if($attach=='user_recharge') {
            $huifu_id = '6666000158522222';
            $rs['acct_infos'] = [
                [
                    'huifu_id' => $huifu_id,
                    'percentage_div' => '100.00'
                ],
                [
                    'huifu_id' => self::$sys_id,
                    'percentage_div' => '0.00'
                ]
            ];
            $rs['percentage_flag'] = 'Y';
            $rs['is_clean_split'] = 'Y';
            $data['acct_split_bunch'] = json_encode($rs, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);
        }
        elseif($attach=='product') {
            $order1 = explode('_',$order_id);
            if(sizeof($order1)==2) $order_id = $order1[1];
            $store_id = StoreOrder::where('order_id', $order_id)->value('store_id');
            if ($store_id > 0) {
                $huifu_id = \app\model\store\SystemStore::where('id', $store_id)->value('huifu_id');
                if ($huifu_id) {
                    $rs['acct_infos'] = [
                        [
                            'huifu_id' => $huifu_id,
                            'percentage_div' => '100.00'
                        ],
                        [
                            'huifu_id' => self::$sys_id,
                            'percentage_div' => '0.00'
                        ]
                    ];
                    $rs['percentage_flag'] = 'Y';
                    $rs['is_clean_split'] = 'Y';
                    $data['acct_split_bunch'] = json_encode($rs, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);
                }
            } else {

            }
        }
        $data['notify_url'] = self::$notify_url."/weixin?attach=".$attach;
        @file_put_contents("miniapp_pay.txt", json_encode($data));
        $result = self::curlRequest(self::pay,$data);
        return $result;
    }
    public static function notify( callable $notifyFn)
    {
        if(input('resp_code')!='00000000') return false;
        $data = json_decode(input('resp_data'),true);
        //商户订单号
        $postOrder['out_trade_no'] = $data['req_seq_id'];
        $postOrder['req_seq_id'] = $data['req_seq_id'];
        //支付宝交易号
        $postOrder['trade_no'] = $data['out_trans_id'];
        $postOrder['out_trans_id'] = $data['out_trans_id'];
        //交易状态
        $postOrder['trade_status'] = $data['trans_stat'];
        //备注
        $postOrder['attach'] = input('attach','product');
        if($data['trans_stat']=='S')
        {
            try {
                if ($notifyFn((object)$postOrder)) {
                    return 'SUCCESS';
                }
            } catch
            (\Exception $e) {
                Log::error('辉聚异步会回调成功,执行函数错误。错误单号：' . $postOrder['out_trade_no'] . PHP_EOL . $e->getMessage());
            }
        }
        return 'FAIL';
    }
    /**
     * 私钥加签（对数据源排序），可用于 V2 版本接口数据加签
     *
     * @param @param array $data 原数据( 排序后的json字符串; 数组参数排序后转json字符串(数据的中文和斜杠均不转码):
    ksort($post_data); json_encode($post_data, JSON_UNESCAPED_SLASHES|JSON_UNESCAPED_UNICODE); )
     * @param string $rsaPrivateKey 私钥
     * @param int $alg 默认 OPENSSL_ALGO_SHA256
     *
     * @return string 签名串
     */
    public static function sha_with_rsa_sign($data, $rsaPrivateKey, $alg=OPENSSL_ALGO_SHA256){
        $key = "-----BEGIN PRIVATE KEY-----\n".wordwrap($rsaPrivateKey, 64, "\n", true)."\n-----END PRIVATE KEY-----";
        $signature= '';
        try {
            openssl_sign($data, $signature, $key, $alg);
        } catch (\Exception $e) {
            echo $e->getMessage();
        }
        return base64_encode($signature);
    }

    public static function encrypt_with_rsa_pubkey($data, $rsaPublicKey, $padding=OPENSSL_PKCS1_PADDING){
        $key = "-----BEGIN PUBLIC KEY-----\n".wordwrap($rsaPublicKey, 64, "\n", true)."\n-----END PUBLIC KEY-----";
        $encryptResult= '';
        try {
            openssl_public_encrypt($data, $encryptResult, $key, $padding);
        } catch (\Exception $e) {
            echo $e->getMessage();
        }
        return base64_encode($encryptResult);
    }

    /**
     * 使用公钥验签，可用于异步应答验签
     *
     * @param string $signature 签文
     * @param string $data 原数据(string)
     * @param string $rsaPublicKey 公钥
     * @param int $alg 默认 OPENSSL_ALGO_SHA256
     *
     * @return false|int 验证结果：成功/失败
     */
    public static function verifySign($signature, $data, $rsaPublicKey, $alg=OPENSSL_ALGO_SHA256){
        $key = "-----BEGIN PUBLIC KEY-----\n".wordwrap($rsaPublicKey, 64, "\n", true)."\n-----END PUBLIC KEY-----";
        return openssl_verify($data, base64_decode($signature), $key, $alg);
    }

    /**
     * 使用公钥验签（对数据源排序），可用于 V2 版本接口返回数据验签
     *
     * @param string $signature 签文
     * @param array $data 原数据(array)
     * @param string $rsaPublicKey 公钥
     * @param int $alg 默认 OPENSSL_ALGO_SHA256
     *
     * @return false|int 验证结果：成功/失败
     */
    public static function verifySign_sort($signature, $data, $rsaPublicKey, $alg=OPENSSL_ALGO_SHA256){
        $key = "-----BEGIN PUBLIC KEY-----\n".wordwrap($rsaPublicKey, 64, "\n", true)."\n-----END PUBLIC KEY-----";
        ksort($data);
        $data = json_encode($data, JSON_UNESCAPED_SLASHES|JSON_UNESCAPED_UNICODE);
        $data = str_replace("\n","\\n",$data);
        $data = str_replace('"enter_fee":0,','"enter_fee":0.00,',$data); // 单独替换指定类型格式不正确的字段 如 enter_fee
        return openssl_verify($data, base64_decode($signature), $key, $alg);
    }

    public static function checkEmpty($value) {
        return !isset($value) || trim($value) === "";
    }

    public static function endWith($str, $suffix) {
        $length = strlen($suffix);
        if($length == 0){
            return false;
        }
        return (substr($str, -$length) === $suffix);
    }

    /**
     * 校验 webhook 返回报文签名
     *
     * @param string $signature 签文
     * @param array $data 原数据(array)
     * @param string $key 加签 key
     * @param int $alg 默认 OPENSSL_ALGO_SHA256
     *
     * @return true|false 验证结果：成功/失败
     */
    public static function verify_webhook_sign($signature, $data, $key){
        $sign = md5(json_encode($data, JSON_UNESCAPED_SLASHES|JSON_UNESCAPED_UNICODE).$key);
        return $sign == strtolower($signature);
    }
}