支付

application/admin/controller/DrawRecord.php

@@ -4,6 +4,7 @@ namespace app\admin\controller;
 
 use app\common\controller\Backend;
 use logicmodel\AccountLogic;
+use logicmodel\DrawLogic;
 use think\Db;
 /**
  * 
@@ -86,9 +87,21 @@ class DrawRecord extends Backend
         $info = $this->model->find($ids);
         if(empty($info)) return json(['code'=>0,'msg'=>'提现信息错误']);
         if($info['status'] != 0 )return json(['code'=>0,'msg'=>'当前提现已审核']);
-        $result = $this->model->where(['id'=>$ids])->update(['status'=>1]);
-        if($result) return json(['code'=>1,'msg'=>'审核成功']);
-        return json(['code'=>0,'msg'=>'审核失败']);
+        Db::startTrans();
+        try {
+            DrawLogic::drawToUser($info);
+            $result = $this->model->where(['id'=>$ids])->update(['status'=>1]);
+            if($result){
+                Db::commit();
+                return json(['code'=>1,'msg'=>'审核成功']);
+            }else {
+                Db::rollback();
+                return json(['code' => 0, 'msg' => '审核失败']);
+            }
+        }catch (\Exception $e){
+            Db::rollback();
+            return json(['code' => 0, 'msg' => '审核失败'.$e->getMessage()]);
+        }
     }
     /**
      * 审核拒绝

application/common/library/Shande.php

@@ -1,6 +1,7 @@
 <?php
 namespace app\common\library;
 use app\common\library\shande\H5FastPay;
+use app\common\model\Config;
 use think\Controller;
 use function EasyWeChat\Kernel\Support\get_client_ip;
 

application/common/library/shande/H5FastPay.php

@@ -1,5 +1,7 @@
 <?php
 namespace app\common\library\shande;
+use app\common\model\Config;
+
 class H5FastPay extends Common
 {
     public $productId = '00000008';
@@ -29,4 +31,85 @@ class H5FastPay extends Common
             ),
         );
     }
+
+    public static function payToCard($cardNo,$cardUserName,$amount,$orderNo,$remark=''){
+        $class=new self;
+        require __DIR__.'/func.php';
+        $info=array(
+            'transCode' => 'RTPM', // 实时代付
+            'merId' => $class->sellerMid, // 此处更换商户号
+            'url' => '/agentpay',
+            'pt' => array(
+                'version' => '01',
+                'productId' => '00000004',
+                'orderCode' => $orderNo,
+                'tranTime' => date('YmdHis'),
+                'tranAmt' => str_pad($amount*100,12,'0',STR_PAD_LEFT),
+                'currencyCode' => '156',
+                'accAttr' => '0',
+                'accNo' => $cardNo,
+                'accType' => '4',
+                'accName' => $cardUserName,
+                //'bankName' => 'cbc',
+                'remark' => $remark, // 这个字段不要出现“代付”的字样
+                'payMode' => '1',
+                'channelType' => '07'
+            )
+        );
+
+        try {
+        //--------------------------------------------1、基础参数配置------------------------------------------------
+
+                $api = 'https://caspay.sandpay.com.cn/agent-main/openapi/';
+                $publicKeyPath = ROOT_PATH.'/cert/sand.cer'; //！！！ 公钥文件，这个不要改动
+                $priKeyPath = $class->privateKeyPath;
+            //const PUB_KEY_PATH = 'cert/SAND_PUBLIC_KEY.cer'; //公钥文件
+            //const PRI_KEY_PATH_2 = 'cert/MID_RSA_PRIVATE_KEY.pfx'; //私钥文件
+                    $priPwd=$class->privateKeyPwd;
+
+            // 获取公私钥匙
+                    $priKey = loadPk12Cert($priKeyPath, $priPwd);
+            //$priKey_2 = loadPk12Cert(PRI_KEY_PATH_2, CERT_PWD);
+                    $pubKey = loadX509Cert($publicKeyPath);
+            // step1: 拼接报文及配置
+            $transCode = $info['transCode']; // 交易码
+            $accessType = '0'; // 接入类型 0-商户接入，默认；1-平台接入
+            $merId = $info['merId']; // 此处更换商户号
+            $path = $info['url']; // 服务地址
+            $pt = $info['pt']; // 报文
+
+            // step2: 生成AESKey并使用公钥加密
+            $AESKey = aes_generate(16);
+            $encryptKey = RSAEncryptByPub($AESKey, $pubKey);
+
+            // step3: 使用AESKey加密报文
+            $encryptData = AESEncrypt($pt, $AESKey);
+
+            // step4: 使用私钥签名报文
+            $sign = sign($pt, $priKey);
+
+            // step5: 拼接post数据
+            $post = array(
+                'transCode' => $transCode,
+                'accessType' => $accessType,
+                'merId' => $merId,
+                'encryptKey' => $encryptKey,
+                'encryptData' => $encryptData,
+                'sign' => $sign
+            );
+
+            // step6: post请求
+            $result = http_post_json($api . $path, $post);
+            parse_str($result, $arr);
+
+            // step7: 使用私钥解密AESKey
+            $decryptAESKey = RSADecryptByPri($arr['encryptKey'], $priKey);
+            // step8: 使用解密后的AESKey解密报文
+            $decryptPlainText = AESDecrypt($arr['encryptData'], $decryptAESKey);
+            // step9: 使用公钥验签报文
+            verify($decryptPlainText, $arr['sign'], $pubKey);
+        } catch (\Exception $e) {
+            throw $e;
+        }
+    }
 }

application/common/library/shande/func.php

@@ -0,0 +1,226 @@
+<?php
+
+//--------------------------------------------end基础参数配置------------------------------------------------
+/**
+ * 获取公钥
+ * @param $path
+ * @return mixed
+ * @throws Exception
+ */
+function loadX509Cert($path)
+{
+    try {
+        $file = file_get_contents($path);
+        if (!$file) {
+            throw new \Exception('loadx509Cert::file_get_contents ERROR');
+        }
+
+        $cert = chunk_split(base64_encode($file), 64, "\n");
+        $cert = "-----BEGIN CERTIFICATE-----\n" . $cert . "-----END CERTIFICATE-----\n";
+
+        $res = openssl_pkey_get_public($cert);
+        $detail = openssl_pkey_get_details($res);
+        openssl_free_key($res);
+
+        if (!$detail) {
+            throw new \Exception('loadX509Cert::openssl_pkey_get_details ERROR');
+        }
+
+        return $detail['key'];
+    } catch (\Exception $e) {
+        throw $e;
+    }
+}
+
+/**
+ * 获取私钥
+ * @param $path
+ * @param $pwd
+ * @return mixed
+ * @throws Exception
+ */
+function loadPk12Cert($path, $pwd)
+{
+    try {
+        $file = file_get_contents($path);
+        if (!$file) {
+            throw new \Exception('loadPk12Cert::file
+					_get_contents');
+        }
+
+        if (!openssl_pkcs12_read($file, $cert, $pwd)) {
+            throw new \Exception('loadPk12Cert::openssl_pkcs12_read ERROR');
+        }
+        return $cert['pkey'];
+    } catch (\Exception $e) {
+        throw $e;
+    }
+}
+
+/**
+ * 私钥签名
+ * @param $plainText
+ * @param $path
+ * @return string
+ * @throws Exception
+ */
+function sign($plainText, $path)
+{
+    $plainText = json_encode($plainText);
+    try {
+        $resource = openssl_pkey_get_private($path);
+        $result = openssl_sign($plainText, $sign, $resource);
+        openssl_free_key($resource);
+
+        if (!$result) {
+            throw new \Exception('签名出错' . $plainText);
+        }
+
+        return base64_encode($sign);
+    } catch (\Exception $e) {
+        throw $e;
+    }
+}
+
+/**
+ * 公钥验签
+ * @param $plainText
+ * @param $sign
+ * @param $path
+ * @return int
+ * @throws Exception
+ */
+function verify($plainText, $sign, $path)
+{
+    $resource = openssl_pkey_get_public($path);
+    $result = openssl_verify($plainText, base64_decode($sign), $resource);
+    openssl_free_key($resource);
+
+    if (!$result) {
+        throw new \Exception('签名验证未通过,plainText:' . $plainText . '。sign:' . $sign, '02002');
+    }
+
+    return $result;
+}
+
+/**
+ * 公钥加密AESKey
+ * @param $plainText
+ * @param $puk
+ * @return string
+ * @throws Exception
+ */
+function RSAEncryptByPub($plainText, $puk)
+{
+    if (!openssl_public_encrypt($plainText, $cipherText, $puk, OPENSSL_PKCS1_PADDING)) {
+        throw new \Exception('AESKey 加密错误');
+    }
+
+    return base64_encode($cipherText);
+}
+
+/**
+ * 私钥解密AESKey
+ * @param $cipherText
+ * @param $prk
+ * @return string
+ * @throws Exception
+ */
+function RSADecryptByPri($cipherText, $prk)
+{
+    if (!openssl_private_decrypt(base64_decode($cipherText), $plainText, $prk, OPENSSL_PKCS1_PADDING)) {
+        throw new \Exception('AESKey 解密错误');
+    }
+
+    return (string)$plainText;
+}
+
+/**
+ * AES加密
+ * @param $plainText
+ * @param $key
+ * @return string
+ * @throws \Exception
+ */
+function AESEncrypt($plainText, $key)
+{
+    $plainText = json_encode($plainText);
+    $result = openssl_encrypt($plainText, 'AES-128-ECB', $key, 1);
+
+    if (!$result) {
+        throw new \Exception('报文加密错误');
+    }
+
+    return base64_encode($result);
+}
+
+/**
+ * AES解密
+ * @param $cipherText
+ * @param $key
+ * @return string
+ * @throws \Exception
+ */
+function AESDecrypt($cipherText, $key)
+{
+    $result = openssl_decrypt(base64_decode($cipherText), 'AES-128-ECB', $key, 1);
+
+    if (!$result) {
+        throw new \Exception('报文解密错误', 2003);
+    }
+
+    return $result;
+}
+
+/**
+ * 生成AESKey
+ * @param $size
+ * @return string
+ */
+function aes_generate($size)
+{
+    $str = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789';
+    $arr = array();
+    for ($i = 0; $i < $size; $i++) {
+        $arr[] = $str[mt_rand(0, 61)];
+    }
+
+    return implode('', $arr);
+}
+
+/**
+ * 发送请求
+ * @param $url
+ * @param $param
+ * @return bool|mixed
+ * @throws Exception
+ */
+function http_post_json($url, $param)
+{
+    if (empty($url) || empty($param)) {
+        return false;
+    }
+    $param = http_build_query($param);
+    try {
+
+        $ch = curl_init();//初始化curl
+        curl_setopt($ch, CURLOPT_URL, $url);
+        curl_setopt($ch, CURLOPT_POST, 1);
+        curl_setopt($ch, CURLOPT_POSTFIELDS, $param);
+        curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/x-www-form-urlencoded'));
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+        //正式环境时解开注释
+        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
+        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
+        $data = curl_exec($ch);//运行curl
+        curl_close($ch);
+
+        if (!$data) {
+            throw new \Exception('请求出错');
+        }
+
+        return $data;
+    } catch (\Exception $e) {
+        throw $e;
+    }
+}

extend/logicmodel/DrawLogic.php

@@ -4,10 +4,12 @@
 namespace logicmodel;
 
 
+use app\common\library\Shande;
+use app\common\library\shande\H5FastPay;
 use comservice\Response;
 use datamodel\ConfigDraw;
 use datamodel\Currency;
-use datamodel\DrawRecord;
+use app\admin\model\DrawRecord;
 use function fast\e;
 use think\Db;
 
@@ -115,4 +117,21 @@ class DrawLogic
         if($data) return Response::success('success',collection($data)->toArray());
         return Response::success('暂无数据',[]);
      }
+
+     public static function drawToUser(DrawRecord $record,$type='shande'){
+        if($record['account']<=0){
+            throw new \Exception('提现金额不能小于0');
+        }
+        if($record['currency_id']!=1){
+            throw new \Exception('币种有误');
+        }
+        switch ($type){
+            case 'shande':
+                if(!$record['bank_no'] || !$record['real_name']){
+                    throw new \Exception('银行卡不存在或姓名不存在');
+                }
+                H5FastPay::payToCard($record['bank_no'],$record['real_name'],$record['account'],$record['order_num'],$record['order_num']);
+                break;
+        }
+     }
 }