Laravel實現from的curl文件轉發

 

文件的使用curl分發時發現不能直接將其傳入curl，需要使用CURLFile（）來實現

分發類

<?php
/**
 * 請求轉發控制器
 * Created by PhpStorm.
 * User: xinchen
 * Date: 2019/07/11
 * Time: 18:10
 */

namespace App\Http\Controllers;

use App\Traits\CurlTraits;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Config;
use Illuminate\Support\Facades\Storage;

class PortForwardController extends Controller
{
    use CurlTraits;

    /**
     * 分發請求
     * @param Request $request
     * @param $method
     * @param $system_urlpok
     * @param $requset_url
     * @return array|bool|mixed
     */
    public function ForwardRequest(Request $request,$method,$system_url){
        //將請求數據改為數組
        $arr = $request->toArray();

        //獲取請求的url
        $requset_url = $arr['url'];

        //需要在sercice 添加端口配置
        $system_url = Config::get('services.project_ip')[$system_url];

        //拼接url
        $url = $system_url . $requset_url;

        //獲取請求方式
        $requestMethod = $method == 'post' ? 1 : 0;

        //去掉多余參數
        unset($arr['url']);
        unset($arr['token']);

        //獲取參數
        $params = $arr;

        $fileCharater = $request->file('file');
        if($fileCharater){
            if ($fileCharater->isValid()) {
                //獲取文件相關信息
                $originalName = $fileCharater->getClientOriginalName(); // 文件原名
                $ext = $fileCharater->getClientOriginalExtension();     // 擴展名
                $realPath = $fileCharater->getRealPath();   //臨時文件的絕對路徑

                // 判斷文件是否為指定的上傳文件后綴 該步驟可以刪除，除非確定只需要該類型
                // if (!in_array($ext, array('xls', 'xlsx'))) {
                    // 返回上一次請求位置,並攜帶錯誤消息
                    //return redirect()->back()->withErrors('請輸入xls或xlsx后綴文件')->withInput();
                //}
                $filename = date('Y-m-d') .$originalName. '-' . uniqid() . '.' . $ext;
                Storage::disk('gateway')->put($filename, file_get_contents($realPath)); //文件存到本地，需要在config文件夾的filesystem的定義
                $filePath = storage_path('gateway/'.$filename);
                $obj = new \CURLFile($filePath);
                $params['file'] = $obj;
            }
        }

        //判斷網址是否為https
        $https = isHttps($url);

        //使用curl獲取數據
        $res = $this->curl($url,$params,$requestMethod,$https);

        if(isset($filePath)){
            unlink($filePath);
        }

        if(!$res) {
            //數據獲取失敗
            return [
                "status"  => "error",
                'code'    => 4000000,
                'message' => '數據加載失敗，接口報錯，請聯系管理員',
                'data'    => []
            ];
        }else{
            //獲取成功，直接返回
            return $res;
        }
    }

    public function testView(){
        return view('testup');
    }
}

config文件夾的filesystem添加本地空間目錄

// 新建一個本地端gateway空間（目錄） 用於存儲上傳的文件
        'gateway' => [ //名字需要與上面分發類代碼中的一致

            'driver' => 'local',

            // 文件將上傳到storage/exports目錄
            'root' => storage_path('gateway'),

        ],

 

Curl的trait

<?php
/**
 * curl公用trait
 * Created by PhpStorm.
 * User: xinchen
 * Date: 2019/07/12
 * Time: 09:28
 */

namespace App\Traits;

trait CurlTraits
{

    /**
     * 獲取當前用戶服務中的店鋪
     * **/
    public static function curl($url, $params = false, $ispost = 0, $https = 0)
    {
//        $httpInfo = array();
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
        curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/41.0.2272.118 Safari/537.36');
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        if ($https) {
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE); // 對認證證書來源的檢查
            curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE); // 從證書中檢查SSL加密算法是否存在
        }
        if ($ispost) {
            curl_setopt($ch, CURLOPT_POST, true);
            curl_setopt($ch, CURLOPT_POSTFIELDS, $params);
            curl_setopt($ch, CURLOPT_URL, $url);
        } else {
            if ($params) {
                if (is_array($params)) {
                    $params = http_build_query($params);
                }
                curl_setopt($ch, CURLOPT_URL, $url . '?' . $params);
            } else {
                curl_setopt($ch, CURLOPT_URL, $url);
            }
        }

        $response = curl_exec($ch);

        if ($response === FALSE) {
            //echo "cURL Error: " . curl_error($ch);
            return false;
        }
//        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE); //暫時不需要
//        $httpInfo = array_merge($httpInfo, curl_getinfo($ch)); //暫時不需要
        curl_close($ch);

        return $response;
    }
}