PHP实现阿里云OSS文件上传(支持批量)

  1 <?php
  2 /**
  3  * @Class: do_upload.php
  4  * @Description: 控制器
  5  * @Date: 2019/10/16
  6  */
  7 header("Content-Type:text/html;charset=utf-8");
  8 set_time_limit(0);
  9 // error_reporting(E_ALL);
 10 require __DIR__.‘/AliyunOss.php‘;
 11 if(!empty($_FILES[‘oss_file‘]) && !empty($_POST[‘type‘])){
 12     $file_arr = getFiles();
 13     $AliyunOss = new AliyunOss();
 14 　　 foreach ($file_arr as $file){
 15         $res = upload_File($file,$type_name.‘/‘.$user_info[‘contact‘],$user_info);
 16         if(isset($res[‘fname‘]) && isset($res[‘dest‘]) && isset($res[‘file_name‘])){
 17             $result = $AliyunOss->upload_file($res[‘dest‘],$res[‘fname‘]);
 18             if($result){
 19                 //1、存入数据库 此处部分变量及入库代码补全 知道逻辑即可
 20                 $insert_time = date(‘Y-m-d H:i:s‘,time());
 21                 $fileData = array(
 22                     ‘phone‘ => "‘{$phone}‘",
 23                     ‘company_name‘ =>  "‘{$oss_db->escape($user_info[‘contact‘])}‘",
 24                     ‘insert_time‘ => "‘{$insert_time}‘",
 25                     ‘file_name‘ => "‘{$res[‘file_name‘]}‘",
 26                     ‘file_url‘ => "‘{$result[‘oss_file‘]}‘"
 27                 );
 28                 $sql = "insert into `oss_file` (".implode(‘,‘, array_keys($fileData)).") values (".implode(‘,‘, array_values($fileData)).")";
 29                 $oss_db->query($sql);
 30                 if($oss_db->insert_id()){
 31                     //2、删除临时文件
 32                     unlink($res[‘dest‘]);
 33                 }
 34             }
 35         }
 36     }
 37     echo ‘上传成功‘;
 38     header(‘Location:list.php‘);
 39     die;
 40 }else{
 41     echo ‘上传失败‘;
 42 }
 43 
 44 /**
 45  * 文件上传
 46  * @description
 47  * @param        $file
 48  * @param string $path
 49  * @param        $max_size
 50  * @param        $allowExt
 51  * @return mixed
 52  */
 53 function upload_File($file,$oss_dir = ‘‘,$user_info,$path = __DIR__.‘/temp‘){
 54     $filename=$file[‘name‘];
 55     $temp_name=$file[‘tmp_name‘];
 56     $error=$file[‘error‘];
 57     $res = [];
 58     if ($error==UPLOAD_ERR_OK) {
 59         // if ($size>$max_size) {
 60         //     $res[‘mes‘]=$filename."文件超过规定上传大小";
 61         // }
 62         $ext = getExt($filename);
 63         if (in_array($ext, array(‘exe‘))) {
 64             $res[‘mes‘]=$filename.‘非法的文件‘;
 65         }
 66         if (!is_uploaded_file($temp_name)) {
 67             $res[‘mes‘]=$filename."文件不是通过HTTP POST 方法上传上传过来的";
 68         }
 69 
 70         if ($res) {
 71             return  $res;
 72         }
 73 
 74         if (!file_exists($path)) {
 75             mkdir($path,0777,true);
 76             chmod($path, 0777);
 77         }
 78         $fname = getUniName($filename,$user_info);
 79         $destination = $path.‘/‘.$fname.‘.‘.$ext;
 80         if (move_uploaded_file($temp_name, $destination)) {
 81             $res[‘mes‘] = $filename.‘上传成功‘;
 82             $res[‘dest‘] = $destination;
 83             $res[‘fname‘] = $oss_dir.‘/‘.$fname.‘.‘.$ext;
 84             $res[‘file_name‘] = $fname.‘.‘.$ext;
 85         }else{
 86             $res[‘mes‘]=$filename."文件上传失败";
 87         }
 88     }else{
 89         switch ($error) {
 90             case ‘1‘:
 91                 $res[‘mes‘]="超过了配置文件上传文件的大小";
 92                 break;
 93             case ‘2‘:
 94                 $res[‘mes‘]="超过表单设置上传文件文件的大小";
 95                 break;
 96             case ‘3‘:
 97                 $res[‘mes‘]="文件部分被上传";
 98                 break;
 99             case ‘4‘:
100                 $res[‘mes‘]="没有文件被上传";
101 
102                 break;
103             case ‘6‘:
104                 $res[‘mes‘]="没有找到临时目录";
105                 break;
106             case ‘7‘:
107                 $res[‘mes‘]="文件不可写";
108 
109                 break;
110             default:
111                 $res[‘mes‘]="上传文件失败";
112                 break;
113         }
114     }
115 
116     return $res;
117 
118 }
119 /**
120  * 获得文件扩展名
121  * @param  string $filename 上传文件名
122  * @return string           返回扩展名
123  */
124 function getExt($filename){
125     $arr=explode(‘.‘, basename($filename));
126 
127     return end($arr);
128 }
129 /**
130  * 获得文件唯一扩展名
131  * @return string 经过md5后生成32位唯一的上传文件名
132  */
133 function getUniName($fileName, $user_info)
134 {
135     $new_fileName =  substr($fileName,0,strrpos($fileName,‘.‘));
136     $oss_db = new data_base(‘10.1.51.64‘, ‘root‘, ‘abc@123456‘, ‘dahua_oss‘);
137     $has_file = $oss_db->getRow("select * from `oss_file` where `phone` = ‘{$user_info[‘phone‘]}‘ and  locate(‘{$fileName}‘,`file_url`)>0 ");
138     if ($has_file) {
139         $new_fileName .= ‘-1‘;
140     }
141     return  $new_fileName;
142 }
143 
144 /**
145  * 整理多个文件
146  * @description
147  * @return mixed
148  */
149 function getFiles(){
150     $files = array();
151     foreach($_FILES as $file){
152         $fileNum=count($file[‘name‘]);
153         for ($i=0; $i < $fileNum; $i++) {
154             $files[$i][‘name‘]=$file[‘name‘][$i];
155             $files[$i][‘type‘]=$file[‘type‘][$i];
156             $files[$i][‘tmp_name‘]=$file[‘tmp_name‘][$i];
157             $files[$i][‘error‘]=$file[‘error‘][$i];
158             $files[$i][‘size‘]=$file[‘size‘][$i];
159         }
160     }
161     return $files;
162 }
163 
164 ?>

 1 <?php
 2 /**
 3  * @Class: AliyunOss.php
 4  * @Description: 控制器
 5  * @Date: 2019/10/16
 6  */
 7 header("Content-Type:text/html;charset=utf-8");
 8 // error_reporting(E_ALL);
 9 
10 if (is_file(__DIR__ . ‘/aliyun_oss/autoload.php‘)) {
11     require_once __DIR__ . ‘/aliyun_oss/autoload.php‘;
12 }
13 
14 use OSS\OssClient;
15 use OSS\Core\OssException;
16 
17 // 阿里云主账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维，请登录 https://ram.console.aliyun.com 创建RAM账号。
18 
19 class AliyunOss
20 {
21     private $accessKeyId;
22     private $accessKeySecret;
23     private $endpoint;
24     private $bucket;
25 
26     public function __construct()
27 
28     {
29         require_once __DIR__ . ‘/aliyun_oss/config.php‘;
30         $this->accessKeyId = $oss_config[‘accessKeyId‘];
31         $this->accessKeySecret = $oss_config[‘accessKeySecret‘];
32         // Endpoint以杭州为例，其它Region请按实际情况填写。 $endpoint="http://oss-cn-hangzhou.aliyuncs.com";
33         $this->endpoint = $oss_config[‘endpoint‘];
34         // 存储空间名称 
35         $this->bucket = $oss_config[‘bucket‘];
36     }
37 　　//$file_path  oss文件名称 （支持中文如：商务/科技/项目计划.doc）会自动创建目录
　　　　//$file_name  由本地文件绝对路径加文件名包括后缀组成，例如/users/local/myfile.txt
38     public function upload_file($file_path, $file_name)
39     {
40         try {
41             $ossClient = new OssClient($this->accessKeyId, $this->accessKeySecret, $this->endpoint);
42             $result = $ossClient->uploadFile($this->bucket, $file_name, $file_path);//$result[‘info‘][‘url‘] 返回上传成功的oss文件地址
43             $arr = array(
44                 ‘oss_file‘ =>$result[‘info‘][‘url‘],
45                 ‘local_path‘ => $file_name
46             );
47             return $arr;
48         } catch (OssException $e) {
49             // printf(__FUNCTION__ . ": FAILED\n");
50             // printf($e->getMessage() . "\n");
51             log_msg(‘文件上传失败‘,$e->getMessage());
52             log_msg(‘文件上传失败‘,$file_path.‘---‘.$file_name);
53             return false;
54         }
55     }
56 }