银行支付接口调用

tp6 实现支付接口调用

1.支付参数配置（config/pay.php）

传递参数可以使用props，传递函数可以直接在调用子组件的时候传递自定义事件，并使用$emit来调用，例如：

1
2
3
4
5
6
7
8
9
10
11
12
  <?php
return [
    'abc_bank' => [ // 农业银行配置
        'merchant_id'      => '你的商户号',
        'merchant_key'     => '你的商户密钥',
        'pay_url'         => 'https://gateway.abc.com/payment/api',
        'notify_url'      => url('payment/notify', '', true, true), // 异步回调
        'return_url'      => url('payment/return', '', true, true), // 同步返回
        'sign_type'       => 'MD5',
        'version'         => '1.0.0',
    ],
];

2.支付服务类（app/common/PayService.php）

首先建立一个vue实例空白页（js文件）

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
<?php
namespace app\common;

use think\facade\Config;

class PayService
{
    protected $config;
    
    public function __construct($bankType = 'abc_bank')
    {
        $this->config = Config::get('pay.' . $bankType);
    }
    
    /**
     * 生成支付订单
     */
    public function createPayment($orderData)
    {
        // 1. 参数校验
        $required = ['order_no', 'amount', 'subject', 'user_id'];
        foreach ($required as $field) {
            if (empty($orderData[$field])) {
                throw new \Exception("缺少必要参数: {$field}");
            }
        }
        
        // 2. 保存订单到数据库
        $order = [
            'order_no'    => $orderData['order_no'],
            'amount'      => $orderData['amount'],
            'subject'     => $orderData['subject'],
            'user_id'     => $orderData['user_id'],
            'status'      => 'pending',
            'create_time' => time(),
            'update_time' => time(),
        ];
        
        // 保存到orders表
        Db::name('orders')->insert($order);
        
        // 3. 构造支付参数
        $payParams = $this->buildPayParams($order);
        
        // 4. 生成签名
        $payParams['sign'] = $this->generateSign($payParams);
        
        return $payParams;
    }
    
    /**
     * 构造支付参数
     */
    protected function buildPayParams($order)
    {
        return [
            'merchant_id'   => $this->config['merchant_id'],
            'out_trade_no'  => $order['order_no'],
            'total_amount'  => $this->formatAmount($order['amount']), // 单位：分
            'subject'       => $order['subject'],
            'timestamp'     => time(),
            'nonce_str'     => $this->generateNonceStr(),
            'notify_url'    => $this->config['notify_url'],
            'return_url'    => $this->config['return_url'],
            'version'       => $this->config['version'],
        ];
    }
    
    /**
     * 生成随机字符串
     */
    protected function generateNonceStr($length = 16)
    {
        $chars = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
        $str = "";
        for ($i = 0; $i < $length; $i++) {
            $str .= substr($chars, mt_rand(0, strlen($chars) - 1), 1);
        }
        return $str;
    }
    
    /**
     * 金额格式化（元转分）
     */
    protected function formatAmount($amount)
    {
        return intval(floatval($amount) * 100);
    }
    
    /**
     * 生成签名
     */
    public function generateSign($data)
    {
        // 1. 参数排序
        ksort($data);
        
        // 2. 拼接参数
        $string = '';
        foreach ($data as $key => $value) {
            if ($value !== '' && $key != 'sign' && !is_array($value)) {
                $string .= $key . '=' . $value . '&';
            }
        }
        
        // 3. 拼接密钥
        $string = rtrim($string, '&') . '&key=' . $this->config['merchant_key'];
        
        // 4. 生成签名
        if ($this->config['sign_type'] == 'MD5') {
            return strtoupper(md5($string));
        } else {
            // 其他签名方式如RSA
            return $this->generateRSASign($string);
        }
    }
    
    /**
     * 验证签名
     */
    public function verifySign($data)
    {
        if (!isset($data['sign'])) {
            return false;
        }
        
        $sign = $data['sign'];
        unset($data['sign']);
        
        $localSign = $this->generateSign($data);
        
        return $sign === $localSign;
    }
    
    /**
     * 构建支付表单（自动提交）
     */
    public function buildPayForm($payParams, $payUrl)
    {
        $html = "<form id='payForm' action='{$payUrl}' method='post'>";
        foreach ($payParams as $key => $value) {
            $html .= "<input type='hidden' name='{$key}' value='{$value}' />";
        }
        $html .= "</form><script>document.getElementById('payForm').submit();</script>";
        
        return $html;
    }
}

3.支付控制器（app/controller/Payment.php）

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155

<?php
namespace app\controller;

use app\BaseController;
use app\common\PayService;
use think\facade\Db;
use think\facade\View;

class Payment extends BaseController
{
    /**
     * 发起支付请求
     */
    public function index()
    {
        try {
            $orderData = [
                'order_no' => 'ORDER_' . date('YmdHis') . mt_rand(1000, 9999),
                'amount'   => $this->request->param('amount', 0.01),
                'subject'  => $this->request->param('subject', '测试商品'),
                'user_id'  => $this->request->param('user_id', 1),
            ];
            
            $payService = new PayService('abc_bank');
            $payParams = $payService->createPayment($orderData);
            
            // 方式1：直接输出表单自动提交
            return $payService->buildPayForm($payParams, $this->config['pay_url']);
            
            // 方式2：返回参数给前端处理
            // return json([
            //     'code' => 0,
            //     'data' => [
            //         'pay_url' => $this->config['pay_url'],
            //         'params' => $payParams
            //     ]
            // ]);
            
        } catch (\Exception $e) {
            return json(['code' => 1, 'msg' => $e->getMessage()]);
        }
    }
    
    /**
     * 支付异步回调（重要！）
     * 银行服务器会POST调用这个接口
     */
    public function notify()
    {
        // 获取回调数据
        $postData = $this->request->post();
        
        // 记录日志
        trace('支付回调数据: ' . json_encode($postData), 'pay');
        
        try {
            $payService = new PayService('abc_bank');
            
            // 1. 验证签名
            if (!$payService->verifySign($postData)) {
                throw new \Exception('签名验证失败');
            }
            
            // 2. 查询本地订单
            $order = Db::name('orders')
                      ->where('order_no', $postData['out_trade_no'])
                      ->find();
            
            if (!$order) {
                throw new \Exception('订单不存在: ' . $postData['out_trade_no']);
            }
            
            // 3. 防止重复处理
            if ($order['status'] == 'paid') {
                return 'SUCCESS'; // 已处理，直接返回成功
            }
            
            // 4. 验证金额
            $callbackAmount = $postData['total_amount'] / 100; // 分转元
            if (abs($callbackAmount - $order['amount']) > 0.01) { // 允许1分误差
                throw new \Exception('金额不一致: 本地' . $order['amount'] . ', 回调' . $callbackAmount);
            }
            
            // 5. 更新订单状态
            Db::name('orders')
              ->where('order_no', $postData['out_trade_no'])
              ->update([
                  'status' => 'paid',
                  'pay_time' => time(),
                  'transaction_id' => $postData['transaction_id'],
                  'update_time' => time(),
              ]);
            
            // 6. 处理后续业务（如发货、通知等）
            $this->afterPaymentSuccess($order);
            
            // 必须返回SUCCESS，否则银行会重复回调
            return 'SUCCESS';
            
        } catch (\Exception $e) {
            // 记录错误日志
            trace('支付回调处理失败: ' . $e->getMessage(), 'error');
            return 'FAIL';
        }
    }
    
    /**
     * 支付同步返回（用户可见）
     */
    public function return()
    {
        $getData = $this->request->get();
        
        try {
            $payService = new PayService('abc_bank');
            
            if ($payService->verifySign($getData)) {
                $orderNo = $getData['out_trade_no'];
                
                // 查询订单状态
                $order = Db::name('orders')->where('order_no', $orderNo)->find();
                
                if ($order && $order['status'] == 'paid') {
                    return View::fetch('pay_success', [
                        'order' => $order,
                        'message' => '支付成功'
                    ]);
                }
            }
            
            return View::fetch('pay_fail', ['message' => '支付失败或验证错误']);
            
        } catch (\Exception $e) {
            return View::fetch('pay_fail', ['message' => $e->getMessage()]);
        }
    }
    
    /**
     * 支付成功后的业务处理
     */
    protected function afterPaymentSuccess($order)
    {
        // 1. 记录支付成功日志
        trace("订单支付成功: {$order['order_no']}", 'pay');
        
        // 2. 发送邮件/短信通知
        // $this->sendNotification($order);
        
        // 3. 更新库存、发货等业务逻辑
        // $this->updateInventory($order);
        
        // 4. 其他后续处理...
    }
}

4.数据库表结构

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
CREATE TABLE `orders` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `order_no` varchar(32) NOT NULL COMMENT '订单号',
  `amount` decimal(10,2) NOT NULL COMMENT '订单金额',
  `subject` varchar(255) NOT NULL COMMENT '订单标题',
  `user_id` int(11) NOT NULL COMMENT '用户ID',
  `status` enum('pending','paid','failed','refunded') DEFAULT 'pending' COMMENT '订单状态',
  `transaction_id` varchar(64) DEFAULT NULL COMMENT '银行交易号',
  `create_time` int(11) DEFAULT NULL COMMENT '创建时间',
  `update_time` int(11) DEFAULT NULL COMMENT '更新时间',
  `pay_time` int(11) DEFAULT NULL COMMENT '支付时间',
  PRIMARY KEY (`id`),
  UNIQUE KEY `uniq_order_no` (`order_no`),
  KEY `idx_user_id` (`user_id`),
  KEY `idx_status` (`status`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='订单表';

🔒 安全注意事项

1.签名验证：必须验证银行回调的签名

2.金额校验：回调金额必须与订单金额一致

3.幂等性处理：防止重复处理同一笔回调

4.日志记录：完整记录所有支付相关操作

5.异常处理：妥善处理各种异常情况

6.超时设置：设置合理的HTTP请求超时时间

这个实现方案涵盖了支付的全流程，包括参数构造、签名生成、异步回调处理等关键环节，你可以根据具体银行的API文档进行调整。

赏

谢谢你请我吃糖果

扫一扫，分享到微信

微信分享二维码

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true

很惭愧<br><br>只做了一点微小的工作<br>谢谢大家