证书形式使用authCode获取支付宝授权，并获取用户基础信息

app/common/repositories/user/UserRepository.php

@@ -11,6 +11,8 @@
 namespace app\common\repositories\user;
 
 
+use alipay\aop\AlipayConfig;
+use alipay\aop\AopCertClient;
 use app\common\dao\BaseDao;
 use app\common\dao\user\UserDao;
 use app\common\model\merchant\order\OrderMerchant;
@@ -3321,6 +3323,170 @@ class UserRepository extends BaseRepository
             return $w->getMessage();
         }
     }
+
+    /**
+     * 使用证书方式，通过 authCode 换取支付宝 AccessToken 和用户信息
+     *
+     * @param string $authorization_code 从 APP 获取的授权码
+     * @param bool   $info               是否在获取 Token 后立即获取用户信息 (true: 获取, false: 只获取 Token)
+     * @return array|string              成功时返回包含 token 或用户信息的数组，失败时返回错误信息数组或字符串
+     * @throws \Exception
+     */
+    public function getTokenByCodeWithCert($authorization_code, $info = false)
+    {
+        try {
+            // --- 1. 配置证书信息 ---
+            // *** 请确保这里的 AppID 和 PrivateKey 是你进行【授权登录】的那个支付宝应用的 ***
+            // *** 它可能与你进行【转账】的应用是同一个，也可能是不同的，请仔细核对 ***
+            $app_id = "你的授权登录应用的AppID"; // 例如: 20210021XXXXXXXXXX
+            $privateKey = "你的应用私钥(PKCS1格式内容或路径)"; // 从.pem文件读取 或 直接粘贴（不推荐）
+
+            // *** 证书文件路径 ***
+            // 建议使用绝对路径或相对于项目根目录的路径，确保PHP有读取权限
+            $app_cert_path = dirname(__FILE__) . '/../../../../extend/alipay/aop/cert/appCertPublicKey.crt'; // 应用公钥证书路径
+            $alipay_cert_path = dirname(__FILE__) . '/../../../../extend/alipay/aop/cert/alipayCertPublicKey.crt'; // 支付宝公钥证书路径
+            $alipay_root_cert_path = dirname(__FILE__) . '/../../../../extend/alipay/aop/cert/alipayRootCert.crt'; // 支付宝根证书路径
+
+            $url = "https://openapi.alipay.com/gateway.do"; // 支付宝网关
+
+            // --- 2. 初始化支付宝配置 (使用 AlipayConfig) ---
+            $alipayConfig = new AlipayConfig();
+            $alipayConfig->setAppId($app_id);
+            $alipayConfig->setCharset("utf-8");
+            $alipayConfig->setFormat("json");
+            $alipayConfig->setSignType("RSA2");
+            $alipayConfig->setServerUrl($url);
+            $alipayConfig->setPrivateKey($privateKey); // 设置应用私钥
+
+            // *** 设置证书路径 ***
+            $alipayConfig->setAppCertPath($app_cert_path);
+            $alipayConfig->setAlipayPublicCertPath($alipay_cert_path);
+            $alipayConfig->setRootCertPath($alipay_root_cert_path);
+
+            // --- 3. 实例化证书模式客户端 (使用 AopCertClient) ---
+            $aop = new AopCertClient($alipayConfig);
+            $aop->isCheckAlipayPublicCert = true; // 强烈建议启用支付宝公钥证书校验
+
+            // --- 4. 创建并执行获取 Token 的请求 ---
+            $request = new AlipaySystemOauthTokenRequest();
+            $request->setGrantType("authorization_code");
+            $request->setCode($authorization_code); // 设置从 APP 获取的 authCode
+
+            // 执行请求
+            $result = $aop->execute($request); // R 返回的是原始响应字符串，需要解码
+            $responseNode = str_replace(".", "_", $request->getApiMethodName()) . "_response"; // 结果节点的 key，例如 "alipay_system_oauth_token_response"
+
+            // 解析 JSON 响应
+            $resultObj = json_decode($result);
+
+            // --- 5. 处理 Token 响应 ---
+            if (isset($resultObj->$responseNode) && $resultObj->$responseNode->code == '10000') {
+                // 成功获取 Token
+                $response = $resultObj->$responseNode;
+                $return_data = [
+                    'code' => 200,
+                    'msg' => 'Token fetched successfully',
+                    'user_id' => $response->user_id,
+                    'access_token' => $response->access_token,
+                    'refresh_token' => $response->refresh_token, // 注意保存 refresh token 以便后续刷新
+                    'expires_in' => $response->expires_in,
+                    're_expires_in' => $response->re_expires_in,
+                ];
+                $access_token = $response->access_token; // 保存 access_token 供后续使用
+
+                // --- 6. (可选) 获取用户信息 ---
+                if ($info) {
+                    $userInfoRequest = new AlipayUserInfoShareRequest; // 注意命名空间
+                    // 使用获取到的 access_token 执行请求
+                    // 注意：AopCertClient 的 execute 方法第二个参数是 accessToken
+                    $userInfoResult = $aop->execute($userInfoRequest, $access_token);
+                    $userInfoResponseNode = str_replace(".", "_", $userInfoRequest->getApiMethodName()) . "_response"; // 例如 "alipay_user_info_share_response"
+                    $userInfoResultObj = json_decode($userInfoResult);
+
+                    if (isset($userInfoResultObj->$userInfoResponseNode) && $userInfoResultObj->$userInfoResponseNode->code == '10000') {
+                        // 成功获取用户信息
+                        $userInfoResponse = $userInfoResultObj->$userInfoResponseNode;
+                        // 将用户信息合并到返回结果中
+                        $return_data['user_info'] = [
+                            'user_id' => $userInfoResponse->user_id, // 支付宝用户ID
+                            'nick_name' => $userInfoResponse->nick_name ?? null, // 昵称
+                            'avatar' => $userInfoResponse->avatar ?? null,     // 头像
+                            // 根据你的授权范围，还可能包含性别(gender), 省份(province), 城市(city)等
+                            // 'gender' => $userInfoResponse->gender ?? null,
+                            // 'province' => $userInfoResponse->province ?? null,
+                            // 'city' => $userInfoResponse->city ?? null,
+                        ];
+                        Db::name('log')->insert(['data' => '支付宝用户信息获取成功: ' . json_encode($userInfoResponse, JSON_UNESCAPED_UNICODE)]);
+                        return $return_data; // 返回包含 Token 和用户信息的完整数据
+                    } else {
+                        // 获取用户信息失败
+                        $errorMsg = 'Failed to get user info';
+                        $subMsg = '';
+                        if (isset($userInfoResultObj->$userInfoResponseNode)) {
+                            $errorMsg .= ': ' . $userInfoResultObj->$userInfoResponseNode->sub_msg;
+                            $subMsg = $userInfoResultObj->$userInfoResponseNode->sub_msg;
+                        } elseif (isset($userInfoResultObj->error_response)) {
+                            $errorMsg .= ': ' . $userInfoResultObj->error_response->sub_msg;
+                            $subMsg = $userInfoResultObj->error_response->sub_msg;
+                        }
+                        Db::name('log')->insert(['data' => '支付宝用户信息获取失败: ' . $errorMsg . ' | Raw: ' . $userInfoResult]);
+                        // 即使获取用户信息失败，Token 仍然是有效的，可以选择只返回 Token 信息
+                        // 或者标记用户信息获取失败
+                        $return_data['user_info_error'] = $subMsg ?: $errorMsg;
+                        return $return_data; // 返回 Token 信息和用户信息获取失败标记
+                        // 或者直接返回错误
+                        // return ['code' => 500, 'msg' => $errorMsg];
+                    }
+                } else {
+                    // 不需要获取用户信息，直接返回 Token 数据
+                    Db::name('log')->insert(['data' => '支付宝Token获取成功: ' . json_encode($response, JSON_UNESCAPED_UNICODE)]);
+                    return $return_data;
+                }
+
+            } else {
+                // 获取 Token 失败
+                $errorMsg = 'Failed to exchange token';
+                $subMsg = '';
+                if (isset($resultObj->$responseNode)) {
+                    $errorMsg .= ': ' . ($resultObj->$responseNode->sub_msg ?? 'Unknown error');
+                    $subMsg = $resultObj->$responseNode->sub_msg ?? '';
+                } elseif (isset($resultObj->error_response)) {
+                    $errorMsg .= ': ' . ($resultObj->error_response->sub_msg ?? 'Unknown error');
+                    $subMsg = $resultObj->error_response->sub_msg ?? '';
+                }
+                Db::name('log')->insert(['data' => '支付宝Token获取失败: ' . $errorMsg . ' | Raw: ' . $result]);
+                return ['code' => 500, 'msg' => $subMsg ?: $errorMsg];
+            }
+
+        } catch (\Exception $e) { // 捕获 SDK 或其他异常
+            Db::name("log")->insert(['data' => 'Alipay Token/Info Error: '.$e->getFile() . '：' . $e->getLine() . '【' . $e->getMessage() . '】']); //日志记录
+            return ['code' => 500, 'msg' => 'System Error: ' . $e->getMessage()];
+        }
+    }
+
+    // 你可以在 Controller 的其他方法中调用这个函数
+    public function handleAlipayCallback($authCode)
+    {
+        if (!$authCode) {
+            return ['status' => 'error', 'message' => 'Auth code is missing'];
+        }
+        // 调用上面封装的方法，并请求获取用户信息
+        $result = $this->getTokenByCodeWithCert($authCode, true); // 第二个参数为 true
+
+        // 根据 $result 处理后续逻辑 (如用户登录注册，返回 token 给 APP 等)
+        if ($result['code'] == 200) {
+            // 成功处理
+            // $alipay_user_id = $result['user_id'];
+            // $nick_name = $result['user_info']['nick_name'] ?? 'Unknown';
+            // $avatar = $result['user_info']['avatar'] ?? '';
+
+            return ['status' => 'success', 'data' => $result];
+        } else {
+            // 处理失败
+            return ['status' => 'error', 'message' => $result['msg']];
+        }
+    }
+
     /**
      * @param $id
      * @return Form