TestService.php 5.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150
  1. <?php
  2. namespace App\Service;
  3. use Illuminate\Support\Facades\Log;
  4. class TestService extends Service
  5. {
  6. public function testdwy($data){
  7. if(empty($data['url']) || empty($data['post']) || empty($data['header'])) return [false,'API请求参数不能为空'];
  8. $url = $data['url'];
  9. $post = $data['post'];
  10. $header = $data['header'];
  11. $json = json_encode($post);
  12. $json = str_replace('"workflowSearchBean":[]','"workflowSearchBean":{}',$json);
  13. $json = str_replace('"loginBindingParameters":[]','"loginBindingParameters":{}',$json);
  14. list($status, $result) = $this->post_helper($url,$json, $header, 40);
  15. if(! $status) return [false, $result];
  16. return [true, $result];
  17. }
  18. public function testdwyget($data){
  19. if(empty($data['url']) || empty($data['header'])) return [false,'API请求参数不能为空'];
  20. $url = $data['url'];
  21. $header = $data['header'];
  22. list($status,$result) = $this->get_helper($url,$header);
  23. if(! $status) return [false, $result];
  24. return [true, $result];
  25. }
  26. public function testdwyput($data){
  27. if(empty($data['url']) || empty($data['post']) || empty($data['header'])) return [false,'API请求参数不能为空'];
  28. $url = $data['url'];
  29. $post = $data['post'];
  30. $header = $data['header'];
  31. $json = json_encode($post);
  32. $json = str_replace('"workflowSearchBean":{}','"workflowSearchBean":[]',json_encode($post));
  33. $json = str_replace('"workflowSearchBean":[]','"workflowSearchBean":{}',json_encode($post));
  34. list($status, $result) = $this->put_helper($url,$json, $header,40);
  35. if(! $status) return [false, $result];
  36. return [true, $result];
  37. }
  38. public function post_helper($url, $data, $header = [], $timeout = 20){
  39. Log::channel('apiLog')->info('大王椰POST', ["api" => $url , "param" => $data ,"header" => $header]);
  40. $ch = curl_init();
  41. curl_setopt($ch, CURLOPT_URL, $url);
  42. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  43. curl_setopt($ch, CURLOPT_ENCODING, '');
  44. curl_setopt($ch, CURLOPT_POST, 1);
  45. curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');
  46. curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
  47. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  48. curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
  49. if(!is_null($data)) curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
  50. $r = curl_exec($ch);
  51. if ($r === false) {
  52. // 获取错误号
  53. $errorNumber = curl_errno($ch);
  54. // 获取错误信息
  55. $errorMessage = curl_error($ch);
  56. $message = "cURL Error #{$errorNumber}: {$errorMessage}";
  57. Log::channel('apiLog')->info('大王椰POST结果', ["message" => $message ]);
  58. return [false, $message];
  59. }
  60. curl_close($ch);
  61. Log::channel('apiLog')->info('大王椰POST结果', ["message" => json_decode($r, true) ]);
  62. return [true, json_decode($r, true)];
  63. }
  64. public function get_helper($url,$header=[],$timeout = 20){
  65. $ch = curl_init();
  66. curl_setopt_array($ch, array(
  67. CURLOPT_URL => $url,
  68. CURLOPT_RETURNTRANSFER => true,
  69. CURLOPT_ENCODING => '',
  70. CURLOPT_MAXREDIRS => 10,
  71. CURLOPT_TIMEOUT => $timeout,
  72. CURLOPT_FOLLOWLOCATION => true,
  73. CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  74. CURLOPT_CUSTOMREQUEST => 'GET',
  75. CURLOPT_SSL_VERIFYPEER => false,
  76. CURLOPT_HTTPHEADER => $header,
  77. ));
  78. $r = curl_exec($ch);
  79. if ($r === false) {
  80. // 获取错误号
  81. $errorNumber = curl_errno($ch);
  82. // 获取错误信息
  83. $errorMessage = curl_error($ch);
  84. $message = "cURL Error #{$errorNumber}: {$errorMessage}";
  85. Log::channel('apiLog')->info('大王椰GET结果', ["message" => $message]);
  86. return [false, $message];
  87. }
  88. curl_close($ch);
  89. Log::channel('apiLog')->info('大王椰GET结果', ["message" => json_decode($r, true)]);
  90. return [true, json_decode($r, true)];
  91. }
  92. public function put_helper($url, $data, $header = [], $timeout = 20){
  93. Log::channel('apiLog')->info('大王椰PUT', ["api" => $url , "param" => $data ,"header" => $header]);
  94. $ch = curl_init();
  95. curl_setopt($ch, CURLOPT_URL, $url);
  96. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  97. curl_setopt($ch, CURLOPT_ENCODING, '');
  98. curl_setopt($ch, CURLOPT_POST, 1);
  99. curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'PUT');
  100. curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
  101. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  102. curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
  103. if(!is_null($data)) curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
  104. $r = curl_exec($ch);
  105. if ($r === false) {
  106. // 获取错误号
  107. $errorNumber = curl_errno($ch);
  108. // 获取错误信息
  109. $errorMessage = curl_error($ch);
  110. $message = "cURL Error #{$errorNumber}: {$errorMessage}";
  111. Log::channel('apiLog')->info('大王椰PUT结果', ["message" => $message]);
  112. return [false, $message];
  113. }
  114. curl_close($ch);
  115. Log::channel('apiLog')->info('大王椰PUT结果', ["message" => json_decode($r, true)]);
  116. return [true, json_decode($r, true)];
  117. }
  118. }