// +---------------------------------------------------------------------- namespace crmeb\services; use app\services\other\ExpressServices; use think\exception\ValidateException; /** * 文件操作类 * Class FileService * @package crmeb\services */ class FileService { /** * 创建目录 * @param string $dir * @return bool */ public static function mkDir(string $dir) { $dir = rtrim($dir, '/') . '/'; if (!is_dir($dir)) { if (mkdir($dir, 0700) == false) { return false; } return true; } return true; } /** * @param $filename 写入文件名 * @param $writetext 保存内容 * @param string $openmod 打开方式 * @return bool */ public static function writeFile(string $filename, string $writetext, string $openmod = 'w') { if (@$fp = fopen($filename, $openmod)) { flock($fp, 2); fwrite($fp, $writetext); fclose($fp); return true; } else { return false; } } /** * 删除目录下所有满足条件文件 * @param $path 文件目录 * @param $start 开始时间 * @param $end 结束时间 * return bool */ public static function del_where_dir($path, $start = '', $end = '') { if (!file_exists($path)) { return false; } $dh = @opendir($path); if ($dh) { while (($d = readdir($dh)) !== false) { if ($d == '.' || $d == '..') {//如果为.或.. continue; } $tmp = $path . '/' . $d; if (!is_dir($tmp)) {//如果为文件 $file_time = filemtime($tmp); if ($file_time) { if ($start != '' && $end != '') { if ($file_time >= $start && $file_time <= $end) { @unlink($tmp); } } elseif ($start != '' && $end == '') { if ($file_time >= $start) { @unlink($tmp); } } elseif ($start == '' && $end != '') { if ($file_time <= $end) { @unlink($tmp); } } else { @unlink($tmp); } } } else {//如果为目录 self::delDir($tmp, $start, $end); } } //判断文件夹下是否 还有文件 $count = count(scandir($path)); closedir($dh); if ($count <= 2) @rmdir($path); } return true; } /** * 删除目录 * @param $dirName * @return bool */ public static function delDir($dirName) { if (!file_exists($dirName)) { return false; } $dir = opendir($dirName); while ($fileName = readdir($dir)) { $file = $dirName . '/' . $fileName; if ($fileName != '.' && $fileName != '..') { if (is_dir($file)) { self::delDir($file); } else { unlink($file); } } } closedir($dir); return rmdir($dirName); } /** * 拷贝目录 * @param string $surDir * @param string $toDir * @return bool */ public function copyDir(string $surDir, string $toDir) { $surDir = rtrim($surDir, '/') . '/'; $toDir = rtrim($toDir, '/') . '/'; if (!file_exists($surDir)) { return false; } if (!file_exists($toDir)) { $this->createDir($toDir); } $file = opendir($surDir); while ($fileName = readdir($file)) { $file1 = $surDir . '/' . $fileName; $file2 = $toDir . '/' . $fileName; if ($fileName != '.' && $fileName != '..') { if (is_dir($file1)) { $this->copyDir($file1, $file2); } else { copy($file1, $file2); } } } closedir($file); return true; } /** * 列出目录 * @param $dir 目录名 * @return array 列出文件夹下内容,返回数组 $dirArray['dir']:存文件夹;$dirArray['file']:存文件 */ static function getDirs($dir) { $dir = rtrim($dir, '/') . '/'; $dirArray [][] = NULL; if (false != ($handle = opendir($dir))) { $i = 0; $j = 0; while (false !== ($file = readdir($handle))) { if (is_dir($dir . $file)) { //判断是否文件夹 $dirArray ['dir'] [$i] = $file; $i++; } else { $dirArray ['file'] [$j] = $file; $j++; } } closedir($handle); } return $dirArray; } /** * 统计文件夹大小 * @param $dir * @return int 文件夹大小(单位 B) */ public static function getSize($dir) { $dirlist = opendir($dir); $dirsize = 0; while (false !== ($folderorfile = readdir($dirlist))) { if ($folderorfile != "." && $folderorfile != "..") { if (is_dir("$dir/$folderorfile")) { $dirsize += self::getSize("$dir/$folderorfile"); } else { $dirsize += filesize("$dir/$folderorfile"); } } } closedir($dirlist); return $dirsize; } /** * 检测是否为空文件夹 * @param $dir * @return bool */ static function emptyDir($dir) { return (($files = @scandir($dir)) && count($files) <= 2); } /** * 创建多级目录 * @param string $dir * @param int $mode * @return boolean */ public function createDir(string $dir, int $mode = 0777) { return is_dir($dir) or ($this->createDir(dirname($dir)) and mkdir($dir, $mode)); } /** * 创建指定路径下的指定文件 * @param string $path (需要包含文件名和后缀) * @param boolean $over_write 是否覆盖文件 * @param int $time 设置时间。默认是当前系统时间 * @param int $atime 设置访问时间。默认是当前系统时间 * @return boolean */ public function createFile(string $path, bool $over_write = FALSE, int $time = NULL, int $atime = NULL) { $path = $this->dirReplace($path); $time = empty($time) ? time() : $time; $atime = empty($atime) ? time() : $atime; if (file_exists($path) && $over_write) { $this->unlinkFile($path); } $aimDir = dirname($path); $this->createDir($aimDir); return touch($path, $time, $atime); } /** * 关闭文件操作 * @param string $path * @return boolean */ public function close(string $path) { return fclose($path); } /** * 读取文件操作 * @param string $file * @return boolean */ public static function readFile(string $file) { return @file_get_contents($file); } /** * 确定服务器的最大上传限制(字节数) * @return int 服务器允许的最大上传字节数 */ public function allowUploadSize() { $val = trim(ini_get('upload_max_filesize')); return $val; } /** * 字节格式化 把字节数格式为 B K M G T P E Z Y 描述的大小 * @param int $size 大小 * @param int $dec 显示类型 * @return int */ public static function byteFormat($size, $dec = 2) { $a = ["B", "KB", "MB", "GB", "TB", "PB", "EB", "ZB", "YB"]; $pos = 0; while ($size >= 1024) { $size /= 1024; $pos++; } return round($size, $dec) . " " . $a[$pos]; } /** * 删除非空目录 * 说明:只能删除非系统和特定权限的文件,否则会出现错误 * @param string $dirName 目录路径 * @param boolean $is_all 是否删除所有 * @param boolean $delDir 是否删除目录 * @return boolean */ public function removeDir(str $dir_path, bool $is_all = FALSE) { $dirName = $this->dirReplace($dir_path); $handle = @opendir($dirName); while (($file = @readdir($handle)) !== FALSE) { if ($file != '.' && $file != '..') { $dir = $dirName . '/' . $file; if ($is_all) { is_dir($dir) ? $this->removeDir($dir) : $this->unlinkFile($dir); } else { if (is_file($dir)) { $this->unlinkFile($dir); } } } } closedir($handle); return @rmdir($dirName); } /** * 获取完整文件名 * @param string $fn 路径 * @return string */ public function getBasename(string $file_path) { $file_path = $this->dirReplace($file_path); return basename(str_replace('\\', '/', $file_path)); //return pathinfo($file_path,PATHINFO_BASENAME); } /** * 获取文件后缀名 * @param string $file_name 文件路径 * @return string */ public static function getExt(string $file) { $file = self::dirReplace($file); return pathinfo($file, PATHINFO_EXTENSION); } /** * 取得指定目录名称 * @param string $path 文件路径 * @param int $num 需要返回以上级目录的数 * @return string */ public function fatherDir(string $path, $num = 1) { $path = $this->dirReplace($path); $arr = explode('/', $path); if ($num == 0 || count($arr) < $num) return pathinfo($path, PATHINFO_BASENAME); return substr(strrev($path), 0, 1) == '/' ? $arr[(count($arr) - (1 + $num))] : $arr[(count($arr) - $num)]; } /** * 删除文件 * @param string $path * @return boolean */ public function unlinkFile(string $path) { $path = $this->dirReplace($path); if (file_exists($path)) { return unlink($path); } } /** * 文件操作(复制/移动) * @param string $old_path 指定要操作文件路径(需要含有文件名和后缀名) * @param string $new_path 指定新文件路径(需要新的文件名和后缀名) * @param string $type 文件操作类型 * @param boolean $overWrite 是否覆盖已存在文件 * @return boolean */ public function handleFile(string $old_path, string $new_path, string $type = 'copy', bool $overWrite = FALSE) { $old_path = $this->dirReplace($old_path); $new_path = $this->dirReplace($new_path); if (file_exists($new_path) && $overWrite = FALSE) { return FALSE; } else if (file_exists($new_path) && $overWrite = TRUE) { $this->unlinkFile($new_path); } $aimDir = dirname($new_path); $this->createDir($aimDir); switch ($type) { case 'copy': return copy($old_path, $new_path); break; case 'move': return @rename($old_path, $new_path); break; } } /** * 文件夹操作(复制/移动) * @param string $old_path 指定要操作文件夹路径 * @param string $aimDir 指定新文件夹路径 * @param string $type 操作类型 * @param boolean $overWrite 是否覆盖文件和文件夹 * @return boolean */ public function handleDir(string $old_path, string $new_path, string $type = 'copy', bool $overWrite = FALSE) { $new_path = $this->checkPath($new_path); $old_path = $this->checkPath($old_path); if (!is_dir($old_path)) return FALSE; if (!file_exists($new_path)) $this->createDir($new_path); $dirHandle = opendir($old_path); if (!$dirHandle) return FALSE; $boolean = TRUE; while (FALSE !== ($file = readdir($dirHandle))) { if ($file == '.' || $file == '..') continue; if (!is_dir($old_path . $file)) { $boolean = $this->handleFile($old_path . $file, $new_path . $file, $type, $overWrite); } else { $this->handleDir($old_path . $file, $new_path . $file, $type, $overWrite); } } switch ($type) { case 'copy': closedir($dirHandle); return $boolean; break; case 'move': closedir($dirHandle); return @rmdir($old_path); break; } } /** * 替换相应的字符 * @param string $path 路径 * @return string */ public static function dirReplace(string $path) { return str_replace('//', '/', str_replace('\\', '/', $path)); } /** * 读取指定路径下模板文件 * @param string $path 指定路径下的文件 * @return string $rstr */ public static function getTempltes(string $path) { $path = self::dirReplace($path); if (file_exists($path)) { $fp = fopen($path, 'r'); $rstr = fread($fp, filesize($path)); fclose($fp); return $rstr; } else { return ''; } } /** * @param string $oldname 原始名称 * @param string $newname 新名称 * @return bool */ public function rename(string $oldname, string $newname) { if (($newname != $oldname) && is_writable($oldname)) { return rename($oldname, $newname); } } /** * 获取指定路径下的信息 * @param string $dir 路径 * @return ArrayObject */ public function getDirInfo(string $dir) { $handle = @opendir($dir);//打开指定目录 $directory_count = 0; while (FALSE !== ($file_path = readdir($handle))) { if ($file_path != "." && $file_path != "..") { //is_dir("$dir/$file_path") ? $sizeResult += $this->get_dir_size("$dir/$file_path") : $sizeResult += filesize("$dir/$file_path"); $next_path = $dir . '/' . $file_path; if (is_dir($next_path)) { $directory_count++; $result_value = self::getDirInfo($next_path); $total_size += $result_value['size']; $file_cout += $result_value['filecount']; $directory_count += $result_value['dircount']; } elseif (is_file($next_path)) { $total_size += filesize($next_path); $file_cout++; } } } closedir($handle);//关闭指定目录 $result_value['size'] = $total_size; $result_value['filecount'] = $file_cout; $result_value['dircount'] = $directory_count; return $result_value; } /** * 指定文件编码转换 * @param string $path 文件路径 * @param string $input_code 原始编码 * @param string $out_code 输出编码 * @return boolean */ public function changeFileCode(string $path, string $input_code, string $out_code) { if (is_file($path))//检查文件是否存在,如果存在就执行转码,返回真 { $content = file_get_contents($path); $content = string::chang_code($content, $input_code, $out_code); $fp = fopen($path, 'w'); $res = (bool)fputs($fp, $content); fclose($fp); return $res; } } /** * 指定目录下指定条件文件编码转换 * @param string $dirname 目录路径 * @param string $input_code 原始编码 * @param string $out_code 输出编码 * @param boolean $is_all 是否转换所有子目录下文件编码 * @param string $exts 文件类型 * @return boolean */ public function changeDirFilesCode(string $dirname, string $input_code, string $out_code, bool $is_all = TRUE, string $exts = '') { if (is_dir($dirname)) { $fh = opendir($dirname); while (($file = readdir($fh)) !== FALSE) { if (strcmp($file, '.') == 0 || strcmp($file, '..') == 0) { continue; } $filepath = $dirname . '/' . $file; if (is_dir($filepath) && $is_all == TRUE) { $files = $this->changeDirFilesCode($filepath, $input_code, $out_code, $is_all, $exts); } else { if ($this->getExt($filepath) == $exts && is_file($filepath)) { $boole = $this->changeFileCode($filepath, $input_code, $out_code, $is_all, $exts); if (!$boole) continue; } } } closedir($fh); return TRUE; } else { return FALSE; } } /** * 列出指定目录下符合条件的文件和文件夹 * @param string $dirname 路径 * @param boolean $is_all 是否列出子目录中的文件 * @param string $exts 需要列出的后缀名文件 * @param string $sort 数组排序 * @return ArrayObject */ public function listDirInfo(string $dirname, bool $is_all = FALSE, string $exts = '', string $sort = 'ASC') { //处理多于的/号 $new = strrev($dirname); if (strpos($new, '/') == 0) { $new = substr($new, 1); } $dirname = strrev($new); $sort = strtolower($sort);//将字符转换成小写 $files = []; $subfiles = []; if (is_dir($dirname)) { $fh = opendir($dirname); while (($file = readdir($fh)) !== FALSE) { if (strcmp($file, '.') == 0 || strcmp($file, '..') == 0) continue; $filepath = $dirname . '/' . $file; switch ($exts) { case '*': if (is_dir($filepath) && $is_all == TRUE) { $files = array_merge($files, self::listDirInfo($filepath, $is_all, $exts, $sort)); } array_push($files, $filepath); break; case 'folder': if (is_dir($filepath) && $is_all == TRUE) { $files = array_merge($files, self::listDirInfo($filepath, $is_all, $exts, $sort)); array_push($files, $filepath); } elseif (is_dir($filepath)) { array_push($files, $filepath); } break; case 'file': if (is_dir($filepath) && $is_all == TRUE) { $files = array_merge($files, self::listDirInfo($filepath, $is_all, $exts, $sort)); } elseif (is_file($filepath)) { array_push($files, $filepath); } break; default: if (is_dir($filepath) && $is_all == TRUE) { $files = array_merge($files, self::listDirInfo($filepath, $is_all, $exts, $sort)); } elseif (preg_match("/\.($exts)/i", $filepath) && is_file($filepath)) { array_push($files, $filepath); } break; } switch ($sort) { case 'asc': sort($files); break; case 'desc': rsort($files); break; case 'nat': natcasesort($files); break; } } closedir($fh); return $files; } else { return FALSE; } } /** * 返回指定路径的文件夹信息,其中包含指定路径中的文件和目录 * @param string $dir * @return ArrayObject */ public function dirInfo(string $dir) { return scandir($dir); } /** * 判断目录是否为空 * @param string $dir * @return boolean */ public function isEmpty(string $dir) { $handle = opendir($dir); while (($file = readdir($handle)) !== false) { if ($file != '.' && $file != '..') { closedir($handle); return true; } } closedir($handle); return false; } /** * 返回指定文件和目录的信息 * @param string $file * @return ArrayObject */ public static function listInfo(string $file) { $dir = []; $dir['filename'] = basename($file);//返回路径中的文件名部分。 $dir['pathname'] = strstr(php_uname('s'), 'Windows') ? str_replace('\\', '\\\\', realpath($file)) : realpath($file);//返回绝对路径名。 $dir['owner'] = fileowner($file);//文件的 user ID (所有者)。 $dir['perms'] = fileperms($file);//返回文件的 inode 编号。 $dir['inode'] = fileinode($file);//返回文件的 inode 编号。 $dir['group'] = filegroup($file);//返回文件的组 ID。 $dir['path'] = dirname($file);//返回路径中的目录名称部分。 $dir['atime'] = fileatime($file);//返回文件的上次访问时间。 $dir['ctime'] = filectime($file);//返回文件的上次改变时间。 $dir['perms'] = fileperms($file);//返回文件的权限。 $dir['size'] = self::byteFormat(filesize($file), 2);//返回文件大小。 $dir['type'] = filetype($file);//返回文件类型。 $dir['ext'] = is_file($file) ? pathinfo($file, PATHINFO_EXTENSION) : '';//返回文件后缀名 $dir['mtime'] = filemtime($file);//返回文件的上次修改时间。 $dir['isDir'] = is_dir($file);//判断指定的文件名是否是一个目录。 $dir['isFile'] = is_file($file);//判断指定文件是否为常规的文件。 $dir['isLink'] = is_link($file);//判断指定的文件是否是连接。 $dir['isReadable'] = is_readable($file);//判断文件是否可读。 $dir['isWritable'] = is_writable($file);//判断文件是否可写。 $dir['isUpload'] = is_uploaded_file($file);//判断文件是否是通过 HTTP POST 上传的。 return $dir; } /** * 返回关于打开文件的信息 * @param $file * @return ArrayObject * 数字下标 关联键名(自 PHP 4.0.6) 说明 * 0 dev 设备名 * 1 ino 号码 * 2 mode inode 保护模式 * 3 nlink 被连接数目 * 4 uid 所有者的用户 id * 5 gid 所有者的组 id * 6 rdev 设备类型,如果是 inode 设备的话 * 7 size 文件大小的字节数 * 8 atime 上次访问时间(Unix 时间戳) * 9 mtime 上次修改时间(Unix 时间戳) * 10 ctime 上次改变时间(Unix 时间戳) * 11 blksize 文件系统 IO 的块大小 * 12 blocks 所占据块的数目 */ public function openInfo(string $file) { $file = fopen($file, "r"); $result = fstat($file); fclose($file); return $result; } /** * 改变文件和目录的相关属性 * @param string $file 文件路径 * @param string $type 操作类型 * @param string $ch_info 操作信息 * @return boolean */ public function change_file($file, $type, $ch_info) { switch ($type) { case 'group' : $is_ok = chgrp($file, $ch_info);//改变文件组。 break; case 'mode' : $is_ok = chmod($file, $ch_info);//改变文件模式。 break; case 'ower' : $is_ok = chown($file, $ch_info);//改变文件所有者。 break; } } /** * 取得文件路径信息 * @param $full_path 完整路径 * @return ArrayObject */ public function getFileType(string $path) { //pathinfo() 函数以数组的形式返回文件路径的信息。 //---------$file_info = pathinfo($path); echo file_info['extension'];----------// //extension取得文件后缀名【pathinfo($path,PATHINFO_EXTENSION)】-----dirname取得文件路径【pathinfo($path,PATHINFO_DIRNAME)】-----basename取得文件完整文件名【pathinfo($path,PATHINFO_BASENAME)】-----filename取得文件名【pathinfo($path,PATHINFO_FILENAME)】 return pathinfo($path); } /** * 取得上传文件信息 * @param $file file属性信息 * @return array */ public function getUploadFileInfo($file) { $file_info = request()->file($file);//取得上传文件基本信息 $info = []; $info['type'] = strtolower(trim(stripslashes(preg_replace("/^(.+?);.*$/", "\\1", $file_info['type'])), '"'));//取得文件类型 $info['temp'] = $file_info['tmp_name'];//取得上传文件在服务器中临时保存目录 $info['size'] = $file_info['size'];//取得上传文件大小 $info['error'] = $file_info['error'];//取得文件上传错误 $info['name'] = $file_info['name'];//取得上传文件名 $info['ext'] = $this->getExt($file_info['name']);//取得上传文件后缀 return $info; } /** * 设置文件命名规则 * @param string $type 命名规则 * @param string $filename 文件名 * @return string */ public function setFileName(string $type) { switch ($type) { case 'hash' : mt_srand(); $new_file = md5(uniqid(mt_rand()));//mt_srand()以随机数md5加密来命名 break; case 'time' : $new_file = time(); break; default : $new_file = date($type, time());//以时间格式来命名 break; } return $new_file; } /** * 文件保存路径处理 * @return string */ public function checkPath($path) { return (preg_match('/\/$/', $path)) ? $path : $path . '/'; } /** * 文件下载 * $save_dir 保存路径 * $filename 文件名 * @return array */ public static function downRemoteFile(string $url, string $save_dir = '', string $filename = '', int $type = 0) { if (trim($url) == '') { return ['file_name' => '', 'save_path' => '', 'error' => 1]; } if (trim($save_dir) == '') { $save_dir = './'; } if (trim($filename) == '') {//保存文件名 $ext = strrchr($url, '.'); // if($ext!='.gif'&&$ext!='.jpg'){ // return ['file_name'=>'','save_path'=>'','error'=>3]; // } $filename = time() . $ext; } if (0 !== strrpos($save_dir, '/')) { $save_dir .= '/'; } //创建保存目录 if (!file_exists($save_dir) && !mkdir($save_dir, 0777, true)) { return ['file_name' => '', 'save_path' => '', 'error' => 5]; } //获取远程文件所采用的方法 if ($type) { $ch = curl_init(); $timeout = 5; curl_setopt($ch, CURLOPT_URL, $url); curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout); $img = curl_exec($ch); curl_close($ch); } else { ob_start(); readfile($url); $img = ob_get_contents(); ob_end_clean(); } //$size=strlen($img); //文件大小 $fp2 = fopen($save_dir . $filename, 'a'); fwrite($fp2, $img); fclose($fp2); unset($img, $url); return ['file_name' => $filename, 'save_path' => $save_dir . $filename, 'error' => 0]; } /** * 解压zip文件 * @param string $filename * @param string $savename * @return bool */ public static function zipOpen(string $filename, string $savename) { $zip = new \ZipArchive; $zipfile = $filename; $res = $zip->open($zipfile); $toDir = $savename; if (!file_exists($toDir)) mkdir($toDir, 0777); $docnum = $zip->numFiles; for ($i = 0; $i < $docnum; $i++) { $statInfo = $zip->statIndex($i); if ($statInfo['crc'] == 0 && $statInfo['comp_size'] != 2) { //新建目录 mkdir($toDir . '/' . substr($statInfo['name'], 0, -1), 0777); } else { //拷贝文件 copy('zip://' . $zipfile . '#' . $statInfo['name'], $toDir . '/' . $statInfo['name']); } } $zip->close(); return true; } /** *设置字体格式 * @param $title string 必选 * return string */ public static function setUtf8($title) { return iconv('utf-8', 'gb2312', $title); } /** *检查指定文件是否能写入 * @param $file string 必选 * return boole */ public static function isWritable($file) { $file = str_replace('\\', '/', $file); if (!file_exists($file)) return false; return is_writable($file); } /**读取excel文件内容 * @param $filePath * @param $row_num * @param $suffix * @return array|false * @throws \PhpOffice\PhpSpreadsheet\Reader\Exception */ public function readExcel($filePath, $row_num = 2, $suffix = 'Xlsx') { if (!$filePath) return false; $pathInfo = pathinfo($filePath, PATHINFO_EXTENSION); if (!$pathInfo || $pathInfo != "xlsx") throw new ValidateException('必须上传xlsx格式文件'); //加载读取模型 $readModel = \PhpOffice\PhpSpreadsheet\IOFactory::createReader($suffix); // 创建读操作 // 打开文件 载入excel表格 try { $spreadsheet = $readModel->load($filePath); $sheet = $spreadsheet->getActiveSheet(); $sheet->getHighestColumn(); $highestRow = $sheet->getHighestRow(); $lines = $highestRow - 1; if ($lines <= 0) { throw new ValidateException('物流数据不能为空'); } // 用于存储表格数据 /** @var ExpressServices $expressService */ $expressService = app()->make(ExpressServices::class); $data = $expressCode = []; for ($i = $row_num; $i <= $highestRow; $i++) { $t1 = $this->objToStr($sheet->getCellByColumnAndRow(1, $i)->getValue()); $t2 = $this->objToStr($sheet->getCellByColumnAndRow(2, $i)->getValue()); $t3 = $this->objToStr($sheet->getCellByColumnAndRow(3, $i)->getValue()); $t4 = $this->objToStr($sheet->getCellByColumnAndRow(4, $i)->getValue()); $t5 = $this->objToStr($sheet->getCellByColumnAndRow(5, $i)->getValue()); if ($t1 && $t2 && $t3 && $t4 && $t5) { $data[] = [$t1, $t2, $t3, $t4, $t5]; $expressCode[] = $t4; } } if ($expressCode) { $expressCode = array_unique(array_map('trim', $expressCode)); $expressId = $expressService->getColumn([['code', 'in', $expressCode]], 'id', 'code'); foreach ($expressCode as $code) { if (!isset($expressId[$code])) { throw new ValidateException($code . '订单物流公司不在平台收录内'); } } } return $data; } catch (\Exception $e) { throw new ValidateException($e->getMessage()); } } /** * 读取商品卡密excel文件内容 * @param $filePath * @param int $row_num * @param string $suffix * @return array|false * @throws \PhpOffice\PhpSpreadsheet\Reader\Exception */ public function readProductCardExcel($filePath, $row_num = 1, $suffix = 'Xlsx') { if (!$filePath) return false; $pathInfo = pathinfo($filePath, PATHINFO_EXTENSION); if (!$pathInfo || $pathInfo != "xlsx") throw new ValidateException('必须上传xlsx格式文件'); //加载读取模型 $readModel = \PhpOffice\PhpSpreadsheet\IOFactory::createReader($suffix); // 创建读操作 // 打开文件 载入excel表格 try { $spreadsheet = $readModel->load($filePath); $sheet = $spreadsheet->getActiveSheet(); $sheet->getHighestColumn(); $highestRow = $sheet->getHighestRow(); $lines = $highestRow - 1; if ($lines <= 0) { throw new ValidateException('数据不能为空'); } // 用于存储表格数据 $data = []; for ($i = $row_num; $i <= $highestRow; $i++) { $t1 = $this->objToStr($sheet->getCellByColumnAndRow(1, $i)->getValue()) ?? ''; $t2 = $this->objToStr($sheet->getCellByColumnAndRow(2, $i)->getValue()); if ($t2) { $data[] = [ 'key' => $t1, 'value' => $t2 ]; } } return $data; } catch (\Exception $e) { throw new ValidateException($e->getMessage()); } } /**对象转字符 * @param $value * @return mixed */ public function objToStr($value) { return is_object($value) ? $value->__toString() : $value; } /** * 压缩文件夹及文件 * @param string $source 需要压缩的文件夹/文件路径 * @param string $destination 压缩后的保存地址 * @param string $folder 文件夹前缀,保存时需要去掉的父级文件夹 * @return boolean */ function addZip($source, $destination, $folder = '') { if (!extension_loaded('zip') || !file_exists($source)) { return false; } $zip = new \ZipArchive; if (!$zip->open($destination, $zip::CREATE)) { return false; } $source = str_replace('\\', '/', $source); $folder = str_replace('\\', '/', $folder); if (is_dir($source) === true) { $files = new \RecursiveIteratorIterator(new \RecursiveDirectoryIterator($source), \RecursiveIteratorIterator::SELF_FIRST); foreach ($files as $file) { $file = str_replace('\\', '/', $file); if (in_array(substr($file, strrpos($file, '/') + 1), array('.', '..'))) continue; if (is_dir($file) === true) { $zip->addEmptyDir(str_replace($folder . '/', '', $file . '/')); } else if (is_file($file) === true) { $zip->addFromString(str_replace($folder . '/', '', $file), file_get_contents($file)); } } } else if (is_file($source) === true) { $zip->addFromString(basename($source), file_get_contents($source)); } return $zip->close(); } }