接口对接

app/Http/Controllers/Api/ImportController.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace App\Http\Controllers\Api;
+
+use App\Service\ImportService;
+use Illuminate\Http\Request;
+
+class ImportController extends BaseController
+{
+    public function getFileData(Request $request)
+    {
+        $service = new ImportService();
+        list($status,$data) = $service->getFileData($request->all());
+
+        if($status){
+            return $this->json_return(200,'',$data);
+        }else{
+            return $this->json_return(201,$data);
+        }
+    }
+}

app/Service/ImportService.php

@@ -0,0 +1,278 @@
+<?php
+
+namespace App\Service;
+
+use App\Exports\TableHeadExport;
+use App\Import\Import;
+use App\Import\ImportAll;
+use App\Model\BasicType;
+use App\Model\Customer;
+use App\Model\CustomerInfo;
+use App\Model\Depart;
+use App\Model\Employee;
+use App\Model\Product;
+use App\Model\ProductCategory;
+use App\Model\ProductPriceDetail;
+use App\Model\SalesOrder;
+use App\Model\SalesOrderInfo;
+use App\Model\SalesOrderProductInfo;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Facades\Storage;
+use Maatwebsite\Excel\Facades\Excel;
+use PhpOffice\PhpSpreadsheet\IOFactory;
+
+class ImportService extends Service
+{
+    const tmp_dir = 'upload_occ';
+
+    const string = '/api/getFile/';
+
+    //文件类型
+    const FILE_TYPE = [
+        'txt',
+        'jpg',
+        'png',
+        'gif',
+        'jpeg',
+        'zip',
+        'rar',
+        'xlsx',
+        'xls'
+    ];
+
+    //导入入口
+    public function import($data){
+//        //不超时
+//        ini_set('max_execution_time', 0);
+//        //内存设置
+//        ini_set('memory_limit', -1);
+//        $reader = IOFactory::createReader('Xlsx');
+//        $reader->setReadDataOnly(true); // 只读取有数据的单元格
+//        $spreadsheet = $reader->load($data['file']);
+//        dd($spreadsheet);
+//        // 创建一个Reader对象
+//        $reader = IOFactory::createReader('Xlsx'); // 根据你的文件格式选择合适的reader
+//
+//// 加载Excel文件
+//        $spreadsheet = $reader->load($data['file']);
+//
+//// 获取第一个工作表
+//        $worksheet = $spreadsheet->getActiveSheet();
+//
+//// 获取总行数
+//        $totalRows = $worksheet->getHighestRow();dd($totalRows);
+        if(empty($data['file'])) return [false,'导入文件不能为空'];
+
+        try {
+           $this->uploadFile($data['file']);
+        }catch (\Throwable $exception) {
+            return [false, $exception->getMessage() . ' (Code: ' . $exception->getCode() . ', Line: ' . $exception->getLine() . ')'];
+        }
+
+        return [true, ''];
+    }
+
+    public function uploadFile($file){
+        if(empty($file)) return [false, '请上传文件'];
+        // 获取文件相关信息
+        $ext = $file->getClientOriginalExtension();     // 扩展名
+        $realPath = $file->getRealPath();   //临时文件的绝对路径
+
+        $ext = strtolower($ext);
+        if (! in_array($ext, self::FILE_TYPE)){
+            $str = '文件格式为:';
+            foreach (self::FILE_TYPE as $value){
+                $str.= $value . ' ' ;
+            }
+            return [false, $str];
+        }
+
+        $date = date("Y-m-d");
+        //文件名
+        $file_name = date("Ymd").time().rand(1000,9999);
+        $filename =  $file_name.'.' . $ext;
+
+        $dir = self::tmp_dir . '/' . $date . '/' . $filename;
+        Storage::disk('public')->put($dir, file_get_contents($realPath));
+
+        return [true, self::string . $filename];
+    }
+
+    public function getFileData($data){
+        if(empty($data['url'])) return [false, '文件路径不能为空'];
+
+        try{
+            // 发送 HTTP 请求获取文件内容
+            $response = file_get_contents($data['url']);
+        }catch (\Throwable $exception){
+            return [false, $exception->getMessage()];
+        }
+        if ($response === false) return [false, '文件获取失败'];
+
+        // 创建一个临时文件资源
+        $tempFile = tempnam(sys_get_temp_dir(), 'xlsx_');
+        file_put_contents($tempFile, $response);
+
+        // 使用 phpspreadsheet 读取文件
+        try {
+            // 创建一个 Xlsx 读取器
+            $reader = IOFactory::createReader('Xlsx');
+
+            // 加载临时文件
+            $spreadsheet = $reader->load($tempFile);
+
+            // 初始化一个数组来存储所有工作表的数据
+            $allSheetData = [];
+
+            // 遍历所有工作表
+            foreach ($spreadsheet->getWorksheetIterator() as $worksheet) {
+                $sheetData = [];
+                foreach ($worksheet->getRowIterator() as $row) {
+                    $cellIterator = $row->getCellIterator();
+                    $cellIterator->setIterateOnlyExistingCells(false); // Loop all cells, even if it is not set
+                    $rowData = [];
+
+                    foreach ($cellIterator as $cell) {
+                        $rowData[] = $cell->getValue();
+                    }
+
+                    $sheetData[] = $rowData;
+                }
+
+                // 将当前工作表的数据添加到总数据数组中
+                $allSheetData[$worksheet->getTitle()] = $sheetData;
+            }
+
+            // 删除临时文件
+            unlink($tempFile);
+        } catch (\Exception $e) {
+            // 删除临时文件
+            unlink($tempFile);
+            return [false, $e->getMessage()];
+        }
+
+        return [true , $allSheetData];
+    }
+
+    public function saveFile1($data){
+        if(empty($data['url'])) return [false, '文件路径不能为空'];
+
+        $this->downloadFile($data['url']);
+    }
+
+    public function downloadFile($url)
+    {
+        // 发送 HEAD 请求获取响应头
+        $ch = curl_init();
+        curl_setopt($ch, CURLOPT_URL, $url);
+        curl_setopt($ch, CURLOPT_NOBODY, true); // 只获取头部信息
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+        curl_setopt($ch, CURLOPT_HEADER, true);
+        curl_setopt($ch, CURLOPT_FAILONERROR, true);
+        curl_setopt($ch, CURLOPT_TIMEOUT, 30); // 设置超时时间
+        curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.3');
+        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // 忽略 SSL 证书验证（仅用于测试）
+        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); // 忽略 SSL 主机验证（仅用于测试）
+        curl_setopt($ch, CURLOPT_VERBOSE, true); // 启用详细调试信息
+
+        // 打开一个文件句柄来捕获调试信息
+        $verbose = fopen('php://temp', 'w+');
+        curl_setopt($ch, CURLOPT_STDERR, $verbose);
+
+        // 执行请求
+        $response = curl_exec($ch);
+        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+        $error = curl_error($ch);
+
+        // 读取调试信息
+        rewind($verbose);
+        $verboseLog = stream_get_contents($verbose);
+        fclose($verbose);
+
+        if ($response === false || $httpCode !== 200) {
+            curl_close($ch);
+            return [false, '打开URL下的文件内容失败,请更换URL'];
+        }dd($response);
+
+        // 获取 Content-Disposition
+        $contentDisposition = null;
+        $headers = explode("\r\n", $response);
+        foreach ($headers as $headerLine) {
+            if (strpos($headerLine, 'Content-Disposition:') === 0) {
+                $contentDisposition = trim(str_replace('Content-Disposition:', '', $headerLine));
+                break;
+            }
+        }dd($headers);
+
+        if ($contentDisposition === null) {
+            curl_close($ch);
+            return response()->json(['error' => 'Failed to determine file name from Content-Disposition'], 500);
+        }
+
+        // 从 Content-Disposition 中提取文件名
+        preg_match('/fileName="?([^"]+)"?/', $contentDisposition, $matches);
+        if (empty($matches)) {
+            curl_close($ch);
+            return response()->json(['error' => 'Failed to extract file name from Content-Disposition'], 500);
+        }
+
+        $filename = urldecode($matches[1]);
+        $extension = pathinfo($filename, PATHINFO_EXTENSION);
+dd($extension);
+        if ($extension === '') {
+            curl_close($ch);
+            return response()->json(['error' => 'Failed to determine file extension'], 500);
+        }
+
+        // 关闭 cURL 资源
+        curl_close($ch);
+
+        // 发送 GET 请求获取文件内容
+        $ch = curl_init();
+        curl_setopt($ch, CURLOPT_URL, $url);
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+        curl_setopt($ch, CURLOPT_FAILONERROR, true);
+        curl_setopt($ch, CURLOPT_TIMEOUT, 30); // 设置超时时间
+        curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.3');
+        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // 忽略 SSL 证书验证（仅用于测试）
+        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); // 忽略 SSL 主机验证（仅用于测试）
+
+        // 执行请求
+        $response = curl_exec($ch);
+        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+        $error = curl_error($ch);
+
+        if ($response === false || $httpCode !== 200) {
+            curl_close($ch);
+            return response()->json(['error' => 'Failed to download file: HTTP status code ' . $httpCode . ', Error: ' . $error], 500);
+        }
+
+        // 关闭 cURL 资源
+        curl_close($ch);
+
+        // 将文件内容保存到本地存储
+        Storage::put($filename, $response);
+
+        return response()->json(['message' => 'File downloaded and saved successfully', 'file' => $filename]);
+    }
+
+    private function getFileTypeExtension($contentType)
+    {
+        $mimeTypeMap = [
+            'application/pdf' => 'pdf',
+            'application/msword' => 'doc',
+            'application/vnd.openxmlformats-officedocument.wordprocessingml.document' => 'docx',
+            'application/vnd.ms-excel' => 'xls',
+            'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet' => 'xlsx',
+            'image/jpeg' => 'jpg',
+            'image/png' => 'png',
+            'image/gif' => 'gif',
+            'text/plain' => 'txt',
+            // 添加其他 MIME 类型和扩展名映射
+        ];
+
+        return isset($mimeTypeMap[$contentType]) ? $mimeTypeMap[$contentType] : null;
+    }
+}
+

routes/api.php

@@ -30,6 +30,7 @@ Route::any('pdfData', 'Api\ThirdController@pdfData');
 Route::any('testdwy','Api\TestController@testdwy');
 Route::any('testdwyget','Api\TestController@testdwyget');
 Route::any('testdwyput','Api\TestController@testdwyput');
+Route::any('getFileData','Api\ImportController@getFileData');
 
 Route::group(['middleware'=> ['CheckJRFIDLogin']],function ($route){
     //站点获取登录后