xianglian_test_api/application/api/controller/CloudWallet.php

<?php
namespace app\api\controller;
use app\common\library\LianLianPay;

use llianpay\accp\security\LLianPayAccpSignature;
use think\Db;
use llianpay\accp\client\LLianPayClient;
date_default_timezone_set('Asia/Shanghai');
header('Content-type:application/json;charset=utf-8');
require_once env('root_path').'application/common/library/llp/src/cfg.php';
require_once env('root_path').'application/common/library/llp/src/client/LLianPayClient.php';
/**
 * @title 云钱包【提现、充值和支付还是用之前接接口】
 * @desc 用的是测试环境的用户钱包，测试环境忽略user_id不同接口结果不一致的场景
 * @controller CloudWallet
 * @package app\api\controller
 * @group worker
 */
class CloudWallet extends Base
{

    protected $env = 0; //  0 测试环境 1正式环境
    protected $prefix = 'xl_';
    protected static $domain_name = 'test';
    protected $cloud_url = [
        //用户申请接入[云钱包申请开户]
        'apply'=>[
            'https://accpgw-ste.lianlianpay-inc.com/v1/acctmgr/openacct-apply',//测试环境
            'https://accpgw.lianlianpay.com/v1/acctmgr/openacct-apply',//生产环境
        ],
        // 激活云钱包
        'activate'=>[
            'https://accpapi-ste.lianlianpay-inc.com/v1/acctmgr/openacct-activate-apply',//测试环境
            'https://accpapi.lianlianpay.com/v1/acctmgr/openacct-activate-apply',//生产环境
        ],
        // 随机因子
        'random'=>[
            'https://accpapi-ste.lianlianpay-inc.com/v1/acctmgr/get-random',//测试环境
            'https://accpapi.lianlianpay.com/v1/acctmgr/get-random',//生产环境
        ],
        // 获取云钱包用户信息
        'userinfo'=>[
            'https://accpapi-ste.lianlianpay-inc.com/v1/acctmgr/query-userinfo',//测试环境
            'https://accpapi.lianlianpay.com/v1/acctmgr/query-userinfo',//生产环境
        ],
        //  获取云钱包账号信息
        'acctinfo'=>[
            'https://accpapi-ste.lianlianpay-inc.com/v1/acctmgr/query-acctinfo',//测试环境
            'https://accpapi.lianlianpay.com/v1/acctmgr/query-acctinfo',//生产环境
        ],
        // 云钱包提现
        'withdrawal'=>[
            'https://accpapi-ste.lianlianpay-inc.com/v1/txn/withdrawal',//测试环境
            'https://accpapi.lianlianpay.com/v1/txn/withdrawal',//生产环境
        ],
        //交易二次短信验证
        'validation'=>[
            'https://accpapi-ste.lianlianpay-inc.com/v1/txn/validation-sms',//测试环境
            'https://accpapi.lianlianpay.com/v1/txn/validation-sms',//生产环境
        ],
        // 支付
        'cashier'=>[
            'https://accpgw-ste.lianlianpay-inc.com/v1/cashier/paycreate',//测试环境
            'https://accpgw.lianlianpay.com/v1/cashier/paycreate',//生产环境
        ],
    ];
    public function initialize(){
        parent::initialize();
        //parent::check_login();
    }

    /**
     * @title 申请接入[开户]
     * @desc 申请接入[开户]
     * @author qc
     * @method POST
     * @tag 编辑信息
     * @url /api/Cloud_wallet/openAcctApply
     * @header name:Authorization require:1 desc:Token
     * @param name:user_id type:int require:0 default:0 desc:用户id
     * @return name:ret_code type:string default:0 desc:0000:成功，其他异常
     * @return name:ret_msg type:string default:0 desc:请求结果描述
     * @return name:user_status type:string default:0 desc:用户状态【NORMAL：正常，其他异常】
     * @return name:bank_open_flag type:int default:0 desc:银行开户标识【0未开户，1已开户，2开户中】
     * @return name:bank_account type:string default:0 desc:ACCP合作银行账户
     */
    public function openAcctApply()
    {
        $user_id = input('post.user_id');
        $user_info  = Db::name('store_member')->find($user_id);
        //if(empty($user_info)) $user_info  = Db::name('store_member')->find(6);
        if(empty($user_info)) $this->error('用户信息有误');
        if(!$user_info['true_name'] || !$user_info['id_card']) $this->error('请先实名认证');
        //if(!$user_info['bank_num']) $this->error('请绑定银行卡');
        $current = date("YmdHis");
        $params = [
            'timestamp' => $current,
            'oid_partner' => OID_PARTNER,
            'user_id' => $this->prefix.$user_id,
            'txn_seqno' => get_order_sn(),
            'txn_time' =>$current,
            'flag_chnl' => "H5",
            'notify_url' => 'https://'.$_SERVER['HTTP_HOST'] . '/api/Notify/openAcctApplyNotify',
            'user_type' =>  'INNERUSER',
            'basicInfo'=>[
                'reg_phone' => $user_info['phone'] ,
                'user_name' => $user_info['true_name'] ,
                'id_type' => 'ID_CARD',
                'id_no' => $user_info['id_card'] ,
                'occupation' =>18,
            ],
            'accountInfo' => [
                //'account_type' => 'PERSONAL_PAYMENT_ACCOUNT'
            ],
            'linkedAcctInfo'=>[
                //'linked_accttype'=> 'LEGALREPT_BANK_CARD',
                //'linked_acctno'=> $user_info['bank_num'] ,
            ],
        ];
        $url = $this->cloud_url['apply'][$this->env];
        $result = LLianPayClient::sendRequest($url, json_encode($params,JSON_UNESCAPED_UNICODE));
        $this->success('ok',json_decode($result,true));
    }

    /**
     * @title 激活申请
     * @desc 激活申请
     * @author qc
     * @method POST
     * @tag 编辑信息
     * @url /api/Cloud_wallet/activateApply
     * @header name:Authorization require:1 desc:Token
     * @param name:user_id type:int require:0 default:0 desc:用户id
     * @param name:password type:string require:0 default:0 desc:支付密码。6-12位的字母、数字，不可以是连续或者重复的数字和字母，正则：^[a-zA-Z0-9]{6,12}$。通过密码控件加密成密文传输
     * @param name:pkg_name type:string require:0 default:test desc:APP包名[h5或是测试不用传]
     * @param name:app_name type:string require:0 default:test desc:APP应用名[h5或是测试不用传]
     * @param name:flag_chnl type:string require:0 default:H5 desc:交易发起渠道传H5或APP

     * @return name:ret_code type:string default:0 desc:0000:成功，其他异常
     * @return name:ret_msg type:string default:0 desc:请求结果描述
     * @return name:user_status type:string default:0 desc:用户状态【NORMAL：正常，其他异常】
     * @return name:bank_open_flag type:int default:0 desc:银行开户标识【0未开户，1已开户，2开户中】
     * @return name:bank_account type:string default:0 desc:ACCP合作银行账户
     */
    public function activateApply()
    {
        $user_id = input('post.user_id');
        $password = input('post.password');
        $flag_chnl = input('get.flag_chnl','H5');
        $pkg_name = input('get.pkg_name');
        $app_name = input('get.app_name');
        $current = date("YmdHis");
        $rand_arr = self::getRandomKey($this->prefix.$user_id, $this->cloud_url['random'][$this->env],$flag_chnl,$pkg_name,$app_name);
        if($rand_arr['ret_code'] != '0000') $this->error($rand_arr['ret_msg']);
        $params = [
            'timestamp' => $current,
            'oid_partner' => OID_PARTNER,
            'user_id' => $this->prefix.$user_id,
            'txn_seqno' => get_order_sn(),
            'txn_time' =>$current,
            'notify_url' => 'https://'.$_SERVER['HTTP_HOST'] . '/api/Notify/openAcctApplyNotify',
            'password' =>  $password,
            'random_key' =>  $rand_arr['random_key'],
            'accountInfo'=>[
                //'account_type' => 'PERSONAL_PAYMENT_ACCOUNT'
            ]
        ];
        $url = $this->cloud_url['activate'][$this->env];
        $result = LLianPayClient::sendRequest($url, json_encode($params,JSON_UNESCAPED_UNICODE));
        $this->success('ok',json_decode($result,true));
    }

    /**
     * @title 获取随机因子
     * @desc 获取随机因子
     * @author qc
     * @method GET
     * @tag 编辑信息
     * @url /api/Cloud_wallet/getRandomKeys
     * @header name:Authorization require:1 desc:Token
     * @param name:user_id type:int require:0 default:0 desc:用户id
     * @param name:pkg_name type:string require:0 default:test desc:APP包名[h5或是测试不用传]
     * @param name:app_name type:string require:0 default:test desc:APP应用名[h5或是测试不用传]
     * @param name:flag_chnl type:string require:0 default:H5 desc:交易发起渠道传H5或APP

     * @return name:ret_code type:string default:0 desc:0000:成功，其他异常
     * @return name:ret_msg type:string default:0 desc:请求结果描述
     * @return name:random_key type:string default:0 desc:随机因子key，有效期30分钟
     * @return name:random_value type:string default:0 desc:随机因子值，有效期30分钟
     */
    public function getRandomKeys()
    {
        $user_id = input('get.user_id');
        $flag_chnl = input('get.flag_chnl','H5');
        $pkg_name = input('get.pkg_name');
        $app_name = input('get.app_name');
        $res =  self::getRandomKey($this->prefix.$user_id, $this->cloud_url['random'][$this->env],$flag_chnl,$pkg_name,$app_name);
        $this->success('ok',$res);
    }
    // 获取随机因子
    public static function getRandomKey($user_id,$url,$flag_chnl,$pkg_name,$app_name)
    {
        $current = date("YmdHis");
        $params = [
            'timestamp' => $current,
            'oid_partner' => OID_PARTNER,
            'user_id' => $user_id,
            'flag_chnl' => $flag_chnl,
            'pkg_name' => $flag_chnl == 'H5' ? static::$domain_name :($pkg_name ? $pkg_name : 'test') ,
            'app_name' => $flag_chnl == 'H5' ? static::$domain_name :($app_name ? $app_name : 'test') ,

        ];
        //var_dump($params);
        $result = LLianPayClient::sendRequest($url, json_encode($params,JSON_UNESCAPED_UNICODE));
        return json_decode($result,JSON_UNESCAPED_UNICODE);
    }

    /**
     * @title 获取云钱包用户信息
     * @desc 获取云钱包用户信息
     * @author qc
     * @method GET
     * @tag 编辑信息
     * @url /api/Cloud_wallet/getUserInfo
     * @header name:Authorization require:1 desc:Token
     * @param name:user_id type:int require:0 default:0 desc:用户id
     * @return name:ret_code type:string default:0 desc:0000:成功，其他异常
     * @return name:ret_msg type:string default:0 desc:请求结果描述
     * @return name:user_status type:string default:0 desc:用户状态【NORMAL：正常，其他异常】
     * @return name:bank_open_flag type:int default:0 desc:银行开户标识【0未开户，1已开户，2开户中】
     * @return name:bank_account type:string default:0 desc:ACCP合作银行账户
     */
    public function getUserInfo()
    {
        $user_id = input('get.user_id');
        $current = date("YmdHis");
        $params = [
            'timestamp' => $current,
            'oid_partner' => OID_PARTNER,
            'user_id' => $this->prefix.$user_id,
        ];
        $url =  $url = $this->cloud_url['userinfo'][$this->env];
        $result = LLianPayClient::sendRequest($url, json_encode($params,JSON_UNESCAPED_UNICODE));
        $this->success('ok',json_decode($result,true));
    }

    /**
     * @title 获取云钱包账户信息
     * @desc 获取云钱包账户信息
     * @author qc
     * @method GET
     * @tag 编辑信息
     * @url /api/Cloud_wallet/getAcctInfo
     * @header name:Authorization require:1 desc:Token
     * @param name:user_id type:int require:0 default:0 desc:用户id
     * @return name:ret_code type:string default:0 desc:0000:成功，其他异常
     * @return name:ret_msg type:string default:0 desc:请求结果描述
     * @return name:ret_msg type:string default:0 desc:请求结果描述
     * @return name:acctinfo_list type:array default:0 desc:账户列表
     * @return name:acctinfo_list.oid_acctno type:string default:0 desc:账户号
     * @return name:acctinfo_list.acct_state type:string default:0 desc:账户状态【NORMAL：正常，其他异常】
     * @return name:acctinfo_list.amt_balcur type:float default:0 desc:资金余额[单位:元]
     * @return name:acctinfo_list.amt_balaval type:float default:0 desc:可用余额[单位:元]
     * @return name:acctinfo_list.amt_balfrz type:float default:0 desc:冻结金额[单位:元]
     * @return name:acctinfo_list.amt_lastbal type:float default:0 desc:昨日资金余额[单位:元]
     * @return name:acctinfo_list.amt_lastaval type:float default:0 desc:昨日可用余额[单位:元]
     * @return name:acctinfo_list.amt_lastfrz type:float default:0 desc:昨日冻结金额[单位:元]
     *
     */
    public function getAcctInfo()
    {
        $user_id = input('get.user_id');
        $current = date("YmdHis");
        $params = [
            'timestamp' => $current,
            'oid_partner' => OID_PARTNER,
            'user_id' => $this->prefix.$user_id,
            'user_type' => 'INNERUSER',
        ];
        $url =  $url = $this->cloud_url['acctinfo'][$this->env];
        $result = LLianPayClient::sendRequest($url, json_encode($params,JSON_UNESCAPED_UNICODE));
        $this->success('ok',json_decode($result,true));
    }

    /**
     * @title 交易二次短信验证
     * @desc 交易二次短信验证
     * @author qc
     * @method GET
     * @tag 编辑信息
     * @url /api/Cloud_wallet/validationSms
     * @header name:Authorization require:1 desc:Token
     * @param name:user_id type:int require:0 default:0 desc:用户id
     * @param name:txn_seqno type:int require:0 default:0 desc:订单号
     * @param name:total_amount type:int require:0 default:0 desc:订单金额【提现金额】
     * @param name:token type:int require:0 default:0 desc:token
     * @param name:verify_code type:int require:0 default:0 desc:验证码
     * @return name:ret_code type:string default:0 desc:0000:成功，其他异常
     * @return name:ret_msg type:string default:0 desc:请求结果描述
     */
    public function validationSms()
    {
        $user_id = input('get.user_id');
        $token = input('get.token');
        $txn_seqno = input('get.txn_seqno');
        $total_amount = input('get.total_amount');
        $verify_code = input('get.verify_code');
        $current = date("YmdHis");
        $params = [
            'timestamp' => $current,
            'oid_partner' => OID_PARTNER,
            'payer_type'=>"USER",
            'payer_id' => $this->prefix.$user_id,
            'txn_seqno'=>$txn_seqno,
            'total_amount'=>$total_amount,
            'token'=>$token,
            'verify_code'=>$verify_code
        ];
        $url = $this->cloud_url['validation'][$this->env];
        $result = LLianPayClient::sendRequest($url, json_encode($params,JSON_UNESCAPED_UNICODE));
        $this->success('ok',json_decode($result,true));
    }




    /**
     * @title 收银台支付测试【测试用不对接】
     * @desc 收银台支付测试
     * @author qc
     * @method GET
     * @tag 编辑信息
     * @url /api/Cloud_wallet/cashierPay
     */
    public function cashierPay()
    {
        $voucher_order = [];
        $voucher_order['order_no'] = get_order_sn();
        $money = 10;
        $from = input('post.from',1);
        $user = Db::name('store_member')->where('id',$this->uid)->find();
        $notify_url = 'https://'.$_SERVER['HTTP_HOST'] . '/api/Pay/lianLianNotify';
        $return_url ='https://'.$_SERVER['HTTP_HOST']."/h5/pages/mine/mine";//回调地址
        $risk_item= risk_item($user,'余额充值',$from == 1 ? 16 : 10);
        $res= LianLianPay::cashierPay($voucher_order['order_no'],$money,$this->uid,$notify_url,$return_url,'余额充值',[[
            'payee_id'=>OID_PARTNER,
            'payee_type' => 'MERCHANT',
            'payee_amount' => $money,
        ]],$risk_item);
        $this->success('ok',$res);
    }

    /**
     * @title 云钱包提现【测试用不对接】
     * @desc 云钱包提现
     * @author qc
     * @method POST
     * @tag 编辑信息
     * @url /api/Cloud_wallet/withdrawal
     * @header name:Authorization require:1 desc:Token
     * @param name:user_id type:int require:0 default:0 desc:用户id
     * @param name:source type:int require:0 default:10 desc:app传10,h5传16
     * @param name:pkg_name type:string require:0 default:test desc:APP包名[h5或是测试不用传]
     * @param name:app_name type:string require:0 default:test desc:APP应用名[h5或是测试不用传]
     * @param name:flag_chnl type:string require:0 default:H5 desc:交易发起渠道传H5或ANDROID或IOS
     * @return name:ret_code type:string default:0 desc:0000:成功，其他异常
     * @return name:ret_msg type:string default:0 desc:请求结果描述
     */
    public function withdrawal()
    {
        $user_id = input('post.user_id');
        $money = input('post.money');
        $password = input('post.password');
        $flag_chnl = input('get.flag_chnl','H5');
        $pkg_name = input('get.pkg_name');
        $app_name = input('get.app_name');
        $random_key = self::getRandomKey($this->prefix.$user_id, $this->cloud_url['random'][$this->env],$flag_chnl,$pkg_name,$app_name);
        $current = date("YmdHis");
        $user_info = Db::name('store_member')->where('id',$user_id)->find();
        $risk_item = risk_item($user_info,'余额提现',input('post,source',10));
        $notify_url = 'https://'.$_SERVER['HTTP_HOST'] . '/api/Pay/withdrawalNotify';
        $params = [
            'timestamp' => $current,
            'oid_partner' => OID_PARTNER,
            'notify_url'=> $notify_url,
            'risk_item'=>json_encode($risk_item),
            'linked_acctno'=>$user_info['bank_num'],
            'check_flag'=> 'N',
            'pay_time_type'=> 'TRANS_NORMAL',
            'orderInfo'=>[
                'txn_seqno'=>get_order_sn(),
                'txn_time' => $current,
                'total_amount' => $money,
            ],
            'payerInfo'=>[
                'payer_type'=> 'USER',
                'payer_id'=> $this->prefix.$user_id,
                'payer_accttype'=> 'USEROWN',
                'password'=> $password,
                'random_key'=> $random_key['random_key'],
            ]
        ];
        $url =  $url = $this->cloud_url['withdrawal'][$this->env];
        $result = LLianPayClient::sendRequest($url, json_encode($params,JSON_UNESCAPED_UNICODE));
        $this->success('ok',json_decode($result,true));
    }



    public function payNotifyTest()
    {
        $result = '{"oid_partner":"2020042200284052","payerInfo":[{"amount":"1.00","method":"BALANCE","payer_type":"USER","payer_id":"1"}],"txn_type":"GENERAL_CONSUME","payeeInfo":[{"amount":"1.00","payee_id":"2020042200284052","payee_type":"MERCHANT"}],"orderInfo":{"total_amount":"1.00","txn_seqno":"202210091020109197255438","txn_time":"20221009102010"},"txn_status":"TRADE_SUCCESS","accounting_date":"20221009","finish_time":"20221009102029","accp_txno":"2022100916760526"}';
        $header = '{"accept-encoding":"gzip,deflate","host":"xianglian-api.hdlkeji.com","content-length":"458","signature-type":"RSA","signature-data":"a5BMrkODcWl6FJ2vOEMG\/dnDbHfsBp34yY9ls9KmaWv5zYYO2EoK+DwL9PAFWTFzb0sKKYaOgrO8mFjl4CclTEd5UWvDFTAhv+EijImHTm4rGwbv1k2fpiw5MCSci1JTAE3ROsocgDWbLSsuFbTQ\/d97oR9KJbrjIInlVPEjO04=","correlationid":"2b9369df-ca95-49df-8f25-10fca9854c02","user-agent":"httpcomponents","connection":"Close","content-type":"text\/json;charset=UTF-8"}';
        $result = json_decode($result,true);
        $header = json_decode($header,true);
        // var_dump($result,$header);
        $check_sign = LLianPayAccpSignature::checkSign(json_encode($result,JSON_UNESCAPED_UNICODE),$header['signature-data']);
        var_dump($check_sign);
        $orderNo = $result['orderInfo']['txn_seqno'];
        var_dump(['out_trade_no' => $orderNo,'user_id'=> trim($result['payerInfo'][0]['payer_id'],$this->prefix)]);

    }



}