GzcApiRequest.php 6.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181
  1. <?php
  2. declare (strict_types=1);
  3. namespace app\traits;
  4. use think\facade\Log;
  5. /**
  6. * 请求公证处统一请求API
  7. * Trait GzcApiRequest
  8. * @package app\traits
  9. */
  10. trait GzcApiRequest
  11. {
  12. /**
  13. * 发送请求
  14. * @return mixed|string
  15. * @author php迷途小书童
  16. * @created 2021/1/14 14:34
  17. */
  18. public static function request(string $method, string $url, array $params = [], array $options = [])
  19. {
  20. $base_uri = env('GZC.HOSTNAME');
  21. $request_uri = $base_uri.$url;
  22. try {
  23. $data = json_encode($params);
  24. $headerArray =array(
  25. "Content-type:application/json;charset='utf-8'",
  26. "Accept:application/json"
  27. );
  28. if ($url != '/v1/api/third/auth/token') {
  29. $Token = self::getTokenFromServer();
  30. $accessToken = $Token['extendData']['accessToken'];
  31. array_push($headerArray, "token:".$accessToken);
  32. }
  33. Log::info($data);
  34. $curl = curl_init();
  35. curl_setopt($curl, CURLOPT_URL, $request_uri);
  36. curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE);
  37. curl_setopt($curl, CURLOPT_SSL_VERIFYHOST,FALSE);
  38. curl_setopt($curl, CURLOPT_POST, 1);
  39. curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
  40. curl_setopt($curl,CURLOPT_HTTPHEADER,$headerArray);
  41. curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
  42. $output = curl_exec($curl);
  43. curl_close($curl);
  44. return json_decode($output, true);
  45. } catch (\Throwable $e) {
  46. return $e->getMessage();
  47. }
  48. }
  49. /**
  50. * 查询账户余额
  51. * @author php迷途小书童
  52. * @created 2021/1/14 16:34
  53. */
  54. public static function checkAmount($user)
  55. {
  56. // $data = [
  57. // 'platformNo' => env('GZC.PLATFORM_NO'),
  58. // 'appNo' => env('GZC.APP_NO'),
  59. // 'conName' => $user['user_name'],
  60. // 'conCertType' => 1,
  61. // 'conCertNo' => $user['user_card'],
  62. // ];
  63. // return self::request('POST', '/v1/api/third/in/in30', $data);
  64. $debug = [];
  65. $data = [
  66. 'platformNo' => env('GZC.PLATFORM_NO'),
  67. 'appNo' => env('GZC.APP_NO'),
  68. 'conName' => $user['user_name'] ?? '',
  69. 'conCertType'=> 1,
  70. 'conCertNo' => $user['user_card'] ?? '',
  71. ];
  72. $debug['request'] = $data;
  73. try {
  74. // 记录请求(原有日志可保留或删除)
  75. Log::info('[checkAmount] request', $data);
  76. $res = self::request('POST', '/v1/api/third/in/in30', $data);
  77. $debug['raw_response'] = $res;
  78. // 尝试解析 amount(以分为单位常见)
  79. $amountCents = $res['extendData']['amount'] ?? $res['data']['amount'] ?? $res['amount'] ?? null;
  80. $debug['parsed_amount'] = $amountCents;
  81. // 如果没有 amount 字段或为0,附加简单推测
  82. if ($amountCents === null) {
  83. $debug['note'] = 'missing_amount';
  84. Log::warning('[checkAmount] missing amount', ['user' => $user, 'response' => $res]);
  85. } elseif ($amountCents == 0) {
  86. $msg = $res['msg'] ?? $res['message'] ?? '';
  87. $reasons = [];
  88. if (stripos($msg, '未开户') !== false || stripos($msg, '未实名') !== false) $reasons[] = 'third_party_unopened_or_unverified';
  89. if (stripos($msg, '无账户') !== false) $reasons[] = 'account_not_found';
  90. if (stripos($msg, 'token') !== false) $reasons[] = 'token_issue_possible';
  91. if (empty($reasons)) $reasons[] = 'balance_is_zero';
  92. $debug['zero_reasons'] = $reasons;
  93. Log::warning('[checkAmount] amount is 0', ['user' => $user, 'reasons' => $reasons]);
  94. }
  95. // 把 debug 附加到返回(不破坏原始返回结构)
  96. if (is_array($res)) {
  97. $res['debug'] = $debug;
  98. return $res;
  99. }
  100. // 如果不是数组,包装返回
  101. return ['code' => 200, 'msg' => 'ok', 'extendData' => ['amount' => $amountCents], 'debug' => $debug];
  102. } catch (\Throwable $e) {
  103. $debug['exception'] = $e->getMessage();
  104. Log::error('[checkAmount] exception', ['user' => $user, 'err' => $e->getMessage()]);
  105. return ['code' => 500, 'msg' => 'exception', 'debug' => $debug];
  106. }
  107. }
  108. public function getAmountFromGzc()
  109. {
  110. $uid = $this->request->uid();
  111. $userInfo = Db::name('UserCertification')->where('uid', $uid)->field('user_name,user_card')->find();
  112. if (empty($userInfo['user_name']) || empty($userInfo['user_card'])) {
  113. Log::error('[getAmountFromGzc] 用户实名信息缺失', ['uid' => $uid, 'userInfo' => $userInfo]);
  114. return app('json')->fail('未找到用户实名信息');
  115. }
  116. try {
  117. $res = GzcApiRequest::checkAmount($userInfo);
  118. } catch (\Throwable $e) {
  119. Log::error('[getAmountFromGzc] 调用异常', ['uid' => $uid, 'error' => $e->getMessage()]);
  120. return app('json')->fail('查询失败(第三方异常)');
  121. }
  122. // 提取 amount(兼容多种字段位置)
  123. $amountCents = $res['extendData']['amount'] ?? $res['data']['amount'] ?? $res['amount'] ?? null;
  124. $amount = $amountCents === null ? 0.0 : floatval($amountCents) * 0.01;
  125. $formatted = sprintf('%.2f', $amount);
  126. // 从 checkAmount 返回的 debug(若存在)
  127. $debug = $res['debug'] ?? null;
  128. // 返回 amount 与 debug 给调用方(前端 / 调试)
  129. return app('json')->success([
  130. 'amount' => $formatted,
  131. 'debug' => $debug
  132. ]);
  133. }
  134. /**
  135. * 获取TOKEN
  136. * @return mixed|string
  137. * @author php迷途小书童
  138. * @created 2021/1/14 14:38
  139. */
  140. public static function getTokenFromServer()
  141. {
  142. $timestamp = (int)(microtime(true) * 1000);
  143. $appid = env('GZC.APP_ID');
  144. $data = [
  145. 'appid' => $appid,
  146. 'sign' => self::getSignContent($timestamp, $appid),
  147. 'timestamp' => $timestamp
  148. ];
  149. return self::request('POST', '/v1/api/third/auth/token', $data);
  150. }
  151. /**
  152. * 获取签名
  153. * @return string
  154. * @author php迷途小书童
  155. * @created 2020/10/29 9:35
  156. */
  157. public static function getSignContent(int $timestamp, string $appid) {
  158. $appsecret = md5(env('GZC.APP_SECRET'));
  159. $stringToBeSigned = "appid={$appid}&secret={$appsecret}&timestamp={$timestamp}";
  160. return md5($stringToBeSigned);
  161. }
  162. }