AIGatewayService.php 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751
  1. <?php
  2. namespace app\service;
  3. use think\Db;
  4. use think\Queue;
  5. class AIGatewayService{
  6. /**
  7. * 接口访问配置
  8. *
  9. * 每个模块包含:
  10. * - api_key:API 调用密钥(Token)
  11. * - api_url:对应功能的服务端地址
  12. */
  13. protected $config = [
  14. //图生文 gemini-2.5-flash-preview
  15. 'imgtotxt' => [
  16. 'api_key' => 'sk-LVcDfTx5SYK6pWiGpfcAN2KA0LunymnMiYSVfzUKQXrjlkZv',
  17. 'api_url' => 'https://chatapi.onechats.top/v1/chat/completions'
  18. ],
  19. //文生文 gtp-4
  20. 'txttotxtgtp' => [
  21. 'api_key' => 'sk-fxlawqVtbbQbNW0wInR3E4wsLo5JHozDC2XOHzMa711su6ss',
  22. 'api_url' => 'https://chatapi.onechats.top/v1/chat/completions'
  23. ],
  24. //文生文 gemini-2.0-flash
  25. 'txttotxtgemini' => [
  26. 'api_key' => 'sk-cqfCZFiiSIdpDjIHLMBbH6uWfeg7iVsASvlubjrNEmfUXbpX',
  27. 'api_url' => 'https://chatapi.onechats.top/v1/chat/completions'
  28. ],
  29. //文生图 black-forest-labs/FLUX.1-kontext-pro、dall-e-3、gpt-image-1
  30. 'txttoimg' => [
  31. 'api_key' => 'sk-MB6SR8qNaTjO80U7HJl4ztivX3zQKPgKVka9oyfVSXIkHSYZ',
  32. 'api_url' => 'https://chatapi.onechats.ai/v1/images/generations'
  33. ],
  34. //gemini-3-pro-image-preview
  35. 'txttoimgfour' => [
  36. 'api_key' => 'sk-8yavOx3JxkiNqfgONHS4eSjFDLfErKj9W91PJc8Qvw8y95sT',
  37. 'api_url' => 'https://chatapi.onechats.ai/v1beta/models/gemini-3-pro-image-preview:streamGenerateContent'
  38. ],
  39. //文生图 MID_JOURNEY
  40. 'submitimage' => [
  41. 'api_key' => 'sk-iURfrAgzAjhZ4PpPLwzmWIAhM7zKfrkwDvyxk4RVBQ4ouJNK',
  42. 'api_url' => 'https://chatapi.onechats.ai/mj/submit/imagine'
  43. ]
  44. ];
  45. /**
  46. * 图生文
  47. * @param string $imageUrl 图像 URL,支持公网可访问地址
  48. * @param string $prompt 对图像的提问内容或提示文本
  49. */
  50. public function callGptApi($imageUrl, $prompt,$imgtotxt_selectedOption)
  51. {
  52. //方式一
  53. $data = [
  54. "model" => $imgtotxt_selectedOption,
  55. "messages" => [[
  56. "role" => "user",
  57. "content" => [
  58. ["type" => "text", "text" => $prompt],
  59. ["type" => "image_url", "image_url" => [
  60. "url" => $imageUrl,
  61. "detail" => "auto"
  62. ]]
  63. ]
  64. ]],
  65. "max_tokens" => 1000
  66. ];
  67. //方式二
  68. // $data = [
  69. // "model" => "gpt-4-vision-preview",
  70. // "messages" => [[
  71. // "role" => "user",
  72. // "content" => [
  73. // ["type" => "text", "text" => $prompt],
  74. // ["type" => "image_url", "image_url" => [
  75. // "url" => $imageUrl,
  76. // "detail" => "auto"
  77. // ]]
  78. // ]
  79. // ]],
  80. // "max_tokens" => 1000
  81. // ];
  82. return $this->callApi($this->config['imgtotxt']['api_url'], $this->config['imgtotxt']['api_key'], $data);
  83. }
  84. /**
  85. * 文生文
  86. * @param string $prompt 用户输入的文本提示内容
  87. */
  88. public function txtGptApi($prompt,$txttotxt_selectedOption)
  89. {
  90. if (empty($prompt)) {
  91. throw new \Exception("Prompt 不允许为空");
  92. }
  93. //判断使用模型
  94. if ($txttotxt_selectedOption === 'gemini-2.0-flash') {
  95. $data = [
  96. 'model' => 'gemini-2.0-flash',
  97. 'messages' => [
  98. ['role' => 'user', 'content' => $prompt]
  99. ],
  100. 'temperature' => 0.7,
  101. 'max_tokens' => 1024
  102. ];
  103. return $this->callApi(
  104. $this->config['txttotxtgemini']['api_url'],
  105. $this->config['txttotxtgemini']['api_key'],
  106. $data
  107. );
  108. }else if ($txttotxt_selectedOption === 'gpt-4') {
  109. $data = [
  110. 'model' => 'gpt-4',
  111. 'messages' => [
  112. ['role' => 'user', 'content' => $prompt]
  113. ],
  114. 'temperature' => 0.7,
  115. 'max_tokens' => 1024
  116. ];
  117. return $this->callApi(
  118. $this->config['txttotxtgtp']['api_url'],
  119. $this->config['txttotxtgtp']['api_key'],
  120. $data
  121. );
  122. }
  123. }
  124. /**
  125. * 文生图
  126. *
  127. * @param string $prompt 提示文本,用于指导图像生成(最长建议 1000 字符)
  128. * @param string $selectedOption 模型名称,例如 'dall-e-3' 或其他兼容模型
  129. *
  130. * 默认参数说明(适用于所有模型):
  131. * - n: 1(生成 1 张图)
  132. * - size: '1024x1024'(标准正方形图像)
  133. * - quality: 'hd'(高清质量)
  134. * - style: 'vivid'(鲜明风格)
  135. *
  136. * response_format 参数差异:
  137. * - 若模型为 'dall-e-3':返回 base64 图像,字段为 `b64_json`
  138. * - 其他模型默认返回图像 URL,字段为 `url`
  139. *
  140. * ⚠️ 注意:使用此方法后,需在 Job/TextToImageJob.php 中按 response_format 判断提取方式:
  141. * 提取 url 图像
  142. * $base64Image = $dalle1024['data'][0]['url'] ?? null;
  143. * 提取 base64 图像
  144. * $base64Image = $dalle1024['data'][0]['b64_json'] ?? null;
  145. *
  146. * @return array 返回接口响应,成功时包含 'data' 字段,失败时包含 'error' 信息
  147. */
  148. public function callDalleApi($prompt, $selectedOption)
  149. {
  150. if ($selectedOption === 'dall-e-3') {
  151. $data = [
  152. 'prompt' => $prompt,
  153. 'model' => $selectedOption,
  154. 'n' => 1,
  155. 'size' => '1024x1024',
  156. 'quality' => 'hd'
  157. ];
  158. return $this->callApi($this->config['txttoimg']['api_url'],$this->config['txttoimg']['api_key'],$data);
  159. } else if ($selectedOption === 'black-forest-labs/FLUX.1-kontext-pro') {
  160. $data = [
  161. 'prompt' => $prompt,
  162. 'model' => $selectedOption,
  163. 'n' => 1,
  164. 'size' => '1024x1024',
  165. 'quality' => 'hd'
  166. ];
  167. return $this->callApi($this->config['txttoimg']['api_url'],$this->config['txttoimg']['api_key'],$data);
  168. } else if ($selectedOption === 'MID_JOURNEY') {
  169. $data = [
  170. 'botType' => $selectedOption,
  171. 'prompt' => $prompt,
  172. 'base64Array' => [],
  173. 'accountFilter' => [
  174. 'channelId' => "",
  175. 'instanceId' => "",
  176. 'modes' => [],
  177. 'remark' => "",
  178. 'remix' => true,
  179. 'remixAutoConsidered' => true
  180. ],
  181. 'notifyHook' => "",
  182. 'state' => ""
  183. ];
  184. return $this->callApi($this->config['submitimage']['api_url'],$this->config['submitimage']['api_key'],$data);
  185. }else if ($selectedOption === 'gpt-image-1') {
  186. $data = [
  187. 'prompt' => $prompt,
  188. 'model' => $selectedOption,
  189. 'n' => 1,
  190. 'size' => '1024x1024',
  191. 'quality' => 'hd'
  192. ];
  193. return $this->callApi($this->config['txttoimg']['api_url'],$this->config['txttoimg']['api_key'],$data);
  194. } else if ($selectedOption === 'gemini-3-pro-image-preview') {
  195. // 使用Google Gemini模型的正确参数格式,与curl命令保持一致
  196. $data = [
  197. "contents" => [
  198. [
  199. "role" => "user",
  200. "parts" => [
  201. ["text" => $prompt]
  202. ]
  203. ]
  204. ],
  205. "generationConfig" => [
  206. "responseModalities" => ["TEXT", "IMAGE"],
  207. "imageConfig" => [
  208. "aspectRatio" => "16:9"
  209. // 移除imageSize字段,与curl命令保持一致
  210. ]
  211. ]
  212. ];
  213. return $this->callApi($this->config['txttoimgfour']['api_url'],$this->config['txttoimgfour']['api_key'],$data);
  214. }else{
  215. return [
  216. 'code' => 400,
  217. 'msg' => '未配置的文生图模型: ' . $selectedOption,
  218. 'data' => null
  219. ];
  220. }
  221. }
  222. /**
  223. * 图生图
  224. * @param string $prompt 用户输入的文本提示内容
  225. * @param string $new_image_url 原图路径
  226. * @param array $options 可选参数,可覆盖默认配置
  227. * @return array
  228. */
  229. public function txt2imgWithControlNet($prompt, $controlImgUrl, $options = []) {
  230. $apiUrl = "http://20.0.17.188:45001/sdapi/v1/txt2img";
  231. $headers = ['Content-Type: application/json'];
  232. $imgPath = ROOT_PATH . 'public/' . ltrim($controlImgUrl, '/');
  233. if (!file_exists($imgPath)) {
  234. return ['code' => 1, 'msg' => '图片不存在:' . $controlImgUrl];
  235. }
  236. $imgData = file_get_contents($imgPath);
  237. $base64Img = 'data:image/png;base64,' . base64_encode($imgData);
  238. $params = [
  239. 'prompt' => $prompt,
  240. 'negative_prompt' => '(deformed, distorted, disfigured:1.3), poorly drawn, bad anatomy',
  241. 'steps' => 20,
  242. 'sampler_name' => 'DPM++ 2M SDE',
  243. 'cfg_scale' => 7,
  244. 'seed' => -1,
  245. 'width' => 1024,
  246. 'height' => 1303,
  247. 'override_settings' => [
  248. 'sd_model_checkpoint' => 'realisticVisionV51_v51VAE-inpainting',
  249. 'sd_vae' => 'vae-ft-mse-840000-ema-pruned',
  250. 'CLIP_stop_at_last_layers' => 2
  251. ],
  252. 'clip_skip' => 2,
  253. 'alwayson_scripts' => [
  254. 'controlnet' => [
  255. 'args' => [[
  256. 'enabled' => true,
  257. 'input_image' => $base64Img,
  258. 'module' => 'inpaint_only+lama',
  259. 'model' => 'control_v11p_sd15_inpaint_fp16 [be8bc0ed]',
  260. 'weight' => 1,
  261. 'resize_mode' => 'Resize and Fill',
  262. 'pixel_perfect' => false,
  263. 'control_mode' => 'ControlNet is more important',
  264. 'starting_control_step' => 0,
  265. 'ending_control_step' => 1
  266. ]]
  267. ]
  268. ]
  269. ];
  270. if (!empty($options)) {
  271. $params = array_merge($params, $options);
  272. }
  273. $ch = curl_init();
  274. curl_setopt($ch, CURLOPT_URL, $apiUrl);
  275. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  276. curl_setopt($ch, CURLOPT_POST, true);
  277. curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
  278. curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($params, JSON_UNESCAPED_UNICODE));
  279. curl_setopt($ch, CURLOPT_TIMEOUT, 180);
  280. $response = curl_exec($ch);
  281. $error = curl_error($ch);
  282. curl_close($ch);
  283. if ($error) {
  284. return ['code' => 1, 'msg' => '请求失败:' . $error];
  285. }
  286. $data = json_decode($response, true);
  287. if (!isset($data['images'][0])) {
  288. return ['code' => 1, 'msg' => '接口未返回图像数据'];
  289. }
  290. return [
  291. 'code' => 0,
  292. 'msg' => '成功',
  293. 'data' => [
  294. 'base64' => $data['images'][0],
  295. 'info' => $data['info'] ?? ''
  296. ]
  297. ];
  298. }
  299. // 第一阶段:图生图
  300. public function upscaleWithImg2Img($prompt, $imgPath)
  301. {
  302. if (!file_exists($imgPath)) {
  303. return ['code' => 1, 'msg' => '原图不存在:' . $imgPath];
  304. }
  305. // 获取原始图像尺寸
  306. [$origWidth, $origHeight] = getimagesize($imgPath);
  307. if (!$origWidth || !$origHeight) {
  308. return ['code' => 1, 'msg' => '无法识别图片尺寸'];
  309. }
  310. // 按2倍尺寸计算目标大小
  311. $targetWidth = $origWidth * 2;
  312. $targetHeight = $origHeight * 2;
  313. // 编码图像为 base64
  314. $imgData = file_get_contents($imgPath);
  315. $base64Img = 'data:image/png;base64,' . base64_encode($imgData);
  316. // 构造参数
  317. $params = [
  318. 'init_images' => [$base64Img],
  319. 'prompt' => $prompt,
  320. 'steps' => 20,
  321. 'sampler_name' => 'DPM++ 2M SDE Heun',
  322. 'cfg_scale' => 7,
  323. 'seed' => 1669863506,
  324. 'width' => $targetWidth,
  325. 'height' => $targetHeight,
  326. 'denoising_strength' => 0.2,
  327. 'clip_skip' => 2,
  328. 'override_settings' => [
  329. 'sd_model_checkpoint' => 'realisticVisionV51_v51VAE-inpainting.safetensors [f0d4872d24]',
  330. 'sd_vae' => 'vae-ft-mse-840000-ema-pruned.safetensors',
  331. 'CLIP_stop_at_last_layers' => 2
  332. ],
  333. 'override_settings_restore_afterwards' => true
  334. ];
  335. $apiUrl = "http://20.0.17.188:45001/sdapi/v1/img2img";
  336. $headers = ['Content-Type: application/json'];
  337. // 发起请求
  338. $ch = curl_init();
  339. curl_setopt_array($ch, [
  340. CURLOPT_URL => $apiUrl,
  341. CURLOPT_RETURNTRANSFER => true,
  342. CURLOPT_POST => true,
  343. CURLOPT_HTTPHEADER => $headers,
  344. CURLOPT_POSTFIELDS => json_encode($params),
  345. CURLOPT_TIMEOUT => 180
  346. ]);
  347. $response = curl_exec($ch);
  348. $error = curl_error($ch);
  349. curl_close($ch);
  350. if ($error) return ['code' => 1, 'msg' => '图生图请求失败:' . $error];
  351. $data = json_decode($response, true);
  352. if (!isset($data['images'][0])) return ['code' => 1, 'msg' => '图生图接口未返回图像'];
  353. return ['code' => 0, 'data' => ['base64' => $data['images'][0]]];
  354. }
  355. // 第二阶段:高清超分
  356. public function imgtogqGptApi($imageRelPath, $options = [])
  357. {
  358. $imgPath = ROOT_PATH . 'public/' . $imageRelPath;
  359. if (!file_exists($imgPath)) {
  360. return ['code' => 1, 'msg' => '原图不存在:' . $imageRelPath];
  361. }
  362. $defaultParams = [
  363. 'resize_mode' => 0,
  364. 'show_extras_results' => true,
  365. 'gfpgan_visibility' => 0,
  366. 'codeformer_visibility' => 0,
  367. 'codeformer_weight' => 0,
  368. 'upscaling_resize' => 1.62,
  369. 'upscaling_crop' => true,
  370. 'upscaler_1' => 'R-ESRGAN 4x+ Anime6B',
  371. 'upscaler_2' => 'None',
  372. 'extras_upscaler_2_visibility' => 0,
  373. 'upscale_first' => false
  374. ];
  375. $params = array_merge($defaultParams, $options);
  376. try {
  377. $imgData = file_get_contents($imgPath);
  378. if ($imgData === false) {
  379. throw new Exception('无法读取图片文件');
  380. }
  381. $params['image'] = base64_encode($imgData);
  382. } catch (Exception $e) {
  383. return ['code' => 1, 'msg' => '图片读取失败:' . $e->getMessage()];
  384. }
  385. $apiUrl = "http://20.0.17.188:45001/sdapi/v1/extra-single-image";
  386. $headers = ['Content-Type: application/json'];
  387. $ch = curl_init();
  388. curl_setopt_array($ch, [
  389. CURLOPT_URL => $apiUrl,
  390. CURLOPT_RETURNTRANSFER => true,
  391. CURLOPT_POST => true,
  392. CURLOPT_HTTPHEADER => $headers,
  393. CURLOPT_POSTFIELDS => json_encode($params),
  394. CURLOPT_TIMEOUT => 120
  395. ]);
  396. $response = curl_exec($ch);
  397. $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  398. $curlErr = curl_error($ch);
  399. curl_close($ch);
  400. if ($curlErr) {
  401. return ['code' => 1, 'msg' => '请求失败:' . $curlErr];
  402. }
  403. if ($httpCode !== 200) {
  404. return ['code' => 1, 'msg' => 'API请求失败,HTTP状态码:' . $httpCode];
  405. }
  406. $data = json_decode($response, true);
  407. if (json_last_error() !== JSON_ERROR_NONE) {
  408. return ['code' => 1, 'msg' => 'API返回数据解析失败:' . json_last_error_msg()];
  409. }
  410. if (empty($data['image'])) {
  411. return ['code' => 1, 'msg' => '接口未返回有效的图像数据'];
  412. }
  413. return [
  414. 'code' => 0,
  415. 'msg' => '高清图生成成功',
  416. 'data' => [
  417. 'base64_image' => $data['image'],
  418. 'original_size' => strlen($imgData),
  419. 'processed_size' => strlen(base64_decode($data['image']))
  420. ]
  421. ];
  422. }
  423. // public function imgtogqGptApi($imageRelPath, $options = [])
  424. // {
  425. // // 构造图片路径
  426. // $imgPath = ROOT_PATH . 'public/' . $imageRelPath;
  427. //
  428. // if (!file_exists($imgPath)) {
  429. // return ['code' => 1, 'msg' => '原图不存在:' . $imageRelPath];
  430. // }
  431. //
  432. // // 默认放大配置
  433. // $defaultParams = [
  434. // 'resize_mode' => 0,
  435. // 'show_extras_results' => true,
  436. // 'gfpgan_visibility' => 0,
  437. // 'codeformer_visibility' => 0,
  438. // 'codeformer_weight' => 0,
  439. // 'upscaling_resize' => 2.45,
  440. // 'upscaling_crop' => true,
  441. // 'upscaler_1' => 'R-ESRGAN 4x+ Anime6B',
  442. // 'upscaler_2' => 'None',
  443. // 'extras_upscaler_2_visibility' => 0,
  444. // 'upscale_first' => false
  445. // ];
  446. //
  447. // // 合并配置参数
  448. // $params = array_merge($defaultParams, $options);
  449. //
  450. // // 编码原始图片
  451. // try {
  452. // $imgData = file_get_contents($imgPath);
  453. // if ($imgData === false) {
  454. // throw new Exception('无法读取图片文件');
  455. // }
  456. // $params['image'] = base64_encode($imgData);
  457. // } catch (Exception $e) {
  458. // return ['code' => 1, 'msg' => '图片读取失败:' . $e->getMessage()];
  459. // }
  460. //
  461. // $apiUrl = "http://20.0.17.188:45001/sdapi/v1/extra-single-image";
  462. // $headers = ['Content-Type: application/json'];
  463. //
  464. // // 调用接口
  465. // $ch = curl_init();
  466. // curl_setopt_array($ch, [
  467. // CURLOPT_URL => $apiUrl,
  468. // CURLOPT_RETURNTRANSFER => true,
  469. // CURLOPT_POST => true,
  470. // CURLOPT_HTTPHEADER => $headers,
  471. // CURLOPT_POSTFIELDS => json_encode($params),
  472. // CURLOPT_TIMEOUT => 120
  473. // ]);
  474. //
  475. // $response = curl_exec($ch);
  476. // $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  477. // $curlErr = curl_error($ch);
  478. // curl_close($ch);
  479. //
  480. // // 网络请求失败
  481. // if ($curlErr) {
  482. // return ['code' => 1, 'msg' => '请求失败:' . $curlErr];
  483. // }
  484. //
  485. // // 状态码错误
  486. // if ($httpCode !== 200) {
  487. // return ['code' => 1, 'msg' => 'API请求失败,HTTP状态码:' . $httpCode];
  488. // }
  489. //
  490. // // 解析响应
  491. // $data = json_decode($response, true);
  492. // if (json_last_error() !== JSON_ERROR_NONE) {
  493. // return ['code' => 1, 'msg' => 'API返回数据解析失败:' . json_last_error_msg()];
  494. // }
  495. //
  496. // if (empty($data['image'])) {
  497. // return ['code' => 1, 'msg' => '接口未返回有效的图像数据'];
  498. // }
  499. //
  500. // // 保存新图片
  501. // try {
  502. // $baseName = pathinfo($imageRelPath, PATHINFO_FILENAME);
  503. // $ext = pathinfo($imageRelPath, PATHINFO_EXTENSION);
  504. // $outputDir = 'uploads/extra_image/';
  505. // $outputPath = ROOT_PATH . 'public/' . $outputDir;
  506. //
  507. // if (!is_dir($outputPath)) {
  508. // mkdir($outputPath, 0755, true);
  509. // }
  510. //
  511. // $saveFileName = $baseName . '-hd.' . $ext;
  512. // $saveFullPath = $outputPath . $saveFileName;
  513. // $resultImg = base64_decode($data['image']);
  514. //
  515. // if ($resultImg === false || file_put_contents($saveFullPath, $resultImg) === false) {
  516. // throw new Exception('保存图片失败');
  517. // }
  518. //
  519. // return [
  520. // 'code' => 0,
  521. // 'msg' => '高清图生成成功',
  522. // 'data' => [
  523. // 'url' => '/' . $outputDir . $saveFileName,
  524. // 'original_size' => filesize($imgPath),
  525. // 'processed_size' => filesize($saveFullPath),
  526. // 'resolution' => getimagesize($saveFullPath)
  527. // ]
  528. // ];
  529. // } catch (Exception $e) {
  530. // return ['code' => 1, 'msg' => '保存失败:' . $e->getMessage()];
  531. // }
  532. // }
  533. /**
  534. * 通用 API 调用方法(支持重试机制)
  535. *
  536. * @param string $url 接口地址
  537. * @param string $apiKey 授权密钥(Bearer Token)
  538. * @param array $data 请求数据(JSON 格式)
  539. *
  540. * 功能说明:
  541. * - 使用 cURL 发送 POST 请求到指定 API 接口
  542. * - 设置请求头和超时时间等参数
  543. * - 支持最多重试 2 次,当接口调用失败时自动重试
  544. * - 返回成功时解析 JSON 响应为数组
  545. *
  546. * 异常处理:
  547. * - 若全部重试失败,将抛出异常并包含最后一次错误信息
  548. *
  549. * @return array 接口响应数据(成功时返回解析后的数组)
  550. * @throws \Exception 接口请求失败时抛出异常
  551. */
  552. public function callApi($url, $apiKey, $data)
  553. {
  554. $maxRetries = 2;
  555. $attempt = 0;
  556. $lastError = '';
  557. $httpCode = 0;
  558. $apiErrorDetail = '';
  559. while ($attempt <= $maxRetries) {
  560. try {
  561. $ch = curl_init();
  562. curl_setopt_array($ch, [
  563. CURLOPT_URL => $url,
  564. CURLOPT_RETURNTRANSFER => true,
  565. CURLOPT_POST => true,
  566. CURLOPT_POSTFIELDS => json_encode($data),
  567. CURLOPT_HTTPHEADER => [
  568. 'Content-Type: application/json',
  569. 'Authorization: Bearer ' . $apiKey
  570. ],
  571. CURLOPT_TIMEOUT => 120,
  572. CURLOPT_SSL_VERIFYPEER => true,
  573. CURLOPT_SSL_VERIFYHOST => 2,
  574. CURLOPT_CONNECTTIMEOUT => 30,
  575. CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  576. CURLOPT_FAILONERROR => false
  577. ]);
  578. $response = curl_exec($ch);
  579. $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  580. $curlError = curl_error($ch);
  581. if ($response === false) {
  582. // 尝试从curl错误信息中提取HTTP状态码
  583. if (preg_match('/HTTP\/[0-9.]+\s+([0-9]+)/', $curlError, $matches)) {
  584. $httpCode = (int)$matches[1];
  585. }
  586. throw new \Exception("请求发送失败: " . $curlError);
  587. }
  588. $result = json_decode($response, true);
  589. // 检查API返回的错误
  590. if (isset($result['error'])) {
  591. $apiErrorDetail = $result['error']['message'] ?? '';
  592. $errorType = $result['error']['type'] ?? '';
  593. $errorCode = $result['error']['code'] ?? '';
  594. // 常见错误类型映射
  595. $errorMessages = [
  596. 'invalid_request_error' => '请求参数错误',
  597. 'authentication_error' => '认证失败',
  598. 'rate_limit_error' => '请求频率过高',
  599. 'insufficient_quota' => '额度不足',
  600. 'billing_not_active' => '账户未开通付费',
  601. 'content_policy_violation' => '内容违反政策',
  602. 'model_not_found' => '模型不存在或无可用渠道'
  603. ];
  604. // 优先使用errorCode进行映射,如果没有则使用errorType
  605. $friendlyMessage = $errorMessages[$errorCode] ?? ($errorMessages[$errorType] ?? 'API服务错误');
  606. // 构建详细的错误信息,包含错误代码、类型和详细描述
  607. $detailedError = "{$friendlyMessage}";
  608. if ($errorCode) {
  609. $detailedError .= " (错误代码: {$errorCode})";
  610. }
  611. if ($apiErrorDetail) {
  612. $detailedError .= ": {$apiErrorDetail}";
  613. }
  614. throw new \Exception($detailedError);
  615. }
  616. if ($httpCode !== 200) {
  617. // HTTP状态码映射
  618. $statusMessages = [
  619. 400 => '请求参数不合法',
  620. 401 => 'API密钥无效或权限不足',
  621. 403 => '访问被拒绝',
  622. 404 => 'API端点不存在',
  623. 429 => '请求过于频繁,请稍后再试',
  624. 500 => '服务器内部错误',
  625. 503 => '服务暂时不可用'
  626. ];
  627. $statusMessage = $statusMessages[$httpCode] ?? "HTTP错误({$httpCode})";
  628. throw new \Exception($statusMessage);
  629. }
  630. curl_close($ch);
  631. return $result;
  632. } catch (\Exception $e) {
  633. $lastError = $e->getMessage();
  634. $attempt++;
  635. if ($attempt <= $maxRetries) {
  636. sleep(pow(2, $attempt));
  637. } else {
  638. // 最终失败时的详细错误信息
  639. $errorDetails = [
  640. '错误原因' => $this->getErrorCause($httpCode, $apiErrorDetail),
  641. '解决方案' => $this->getErrorSolution($httpCode),
  642. '请求参数' => json_encode($data, JSON_UNESCAPED_UNICODE),
  643. 'HTTP状态码' => $httpCode,
  644. '重试次数' => $attempt
  645. ];
  646. // 构建最终的错误信息,优先显示原始的详细错误消息
  647. $finalError = "API请求失败\n";
  648. $finalError .= "失败说明: " . $lastError . "\n"; // 使用原始的详细错误消息
  649. $finalError .= "建议解决方案: " . $errorDetails['解决方案'] . "\n";
  650. $finalError .= "技术详情: HTTP {$httpCode} - " . $errorDetails['错误原因'];
  651. throw new \Exception($finalError);
  652. }
  653. }
  654. }
  655. }
  656. /**
  657. * 根据错误类型获取友好的错误原因
  658. */
  659. private function getErrorCause($httpCode, $apiError)
  660. {
  661. $causes = [
  662. 401 => 'API密钥无效、过期或没有访问权限',
  663. 400 => $apiError ?: '请求参数不符合API要求',
  664. 429 => '已达到API调用频率限制',
  665. 403 => '您的账户可能没有开通相关服务权限',
  666. 500 => 'OpenAI服务器处理请求时出错',
  667. 503 => 'API服务暂时不可用,可能是服务器维护或负载过高'
  668. ];
  669. return $causes[$httpCode] ?? '未知错误,请检查网络连接和API配置';
  670. }
  671. /**
  672. * 根据错误类型获取解决方案建议
  673. */
  674. private function getErrorSolution($httpCode)
  675. {
  676. $solutions = [
  677. 401 => '1. 检查API密钥是否正确 2. 确认密钥是否有访问权限 3. 尝试创建新密钥',
  678. 400 => '1. 检查请求参数 2. 验证提示词内容 3. 参考API文档修正参数',
  679. 429 => '1. 等待1分钟后重试 2. 升级账户提高限额 3. 优化调用频率',
  680. 403 => '1. 检查账户状态 2. 确认是否已开通付费 3. 联系OpenAI支持',
  681. 500 => '1. 等待几分钟后重试 2. 检查OpenAI服务状态页',
  682. 503 => '1. 等待几分钟后重试 2. 检查API服务提供商状态 3. 联系服务提供商确认服务可用性'
  683. ];
  684. return $solutions[$httpCode] ?? '1. 检查网络连接 2. 查看服务日志 3. 联系技术支持';
  685. }
  686. }