WindyMadman/dzzoffice
1
0
Fork 0
mirror of https://github.com/zyx0814/dzzoffice.git synced 2025-04-04 22:33:37 +08:00
Code Issues Packages Projects Releases Wiki Activity
dzzoffice/core/class/io/io_ALIOSS.php
小胡 4bc8ee6f49
修复部分情况下无法正常更新用户状态信息问题 (#290) 
* 更新内容：
1.條复网盘应用移动端部分情况下目录权限不正确问题
2.修复一些已知问题
3. 优化btn按钮交互效果
4.升级1avui至v2.9.23版本

* 修复一些已知问题
2025-02-26 17:14:24 +08:00

1428 lines
45 KiB
PHP
Raw Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

<?php
/*
* @copyright Leyun internet Technology(Shanghai)Co.,Ltd
* @license http://www.dzzoffice.com/licenses/license.txt
* @package DzzOffice
* @link http://www.dzzoffice.com
* @author zyx(zyx@dzz.cc)
*/
if(!defined('IN_DZZ')) {
exit('Access Denied');
}
include_once DZZ_ROOT.'./core/api/oss_sdk/sdk.class.php';
@set_time_limit(0);
@ini_set('max_execution_time',0);
class io_ALIOSS extends io_api
{
const T ='connect_storage';
const BZ ='ALIOSS';
private $icosdatas=array();
private $bucket='';
private $_root='';
private $_rootname='';
private $perm=0;
private $alc='';
public function __construct($path) {
$arr = DB::fetch_first("SELECT root,name FROM %t WHERE bz=%s",array('connect',self::BZ));
$this->_root=$arr['root'];
$this->_rootname=$arr['name'];
$this->perm=perm_binPerm::getMyPower();
//self::init($path);
}
public function MoveToSpace($path,$attach){
global $_G;
/*
*移动附件 *
*/
$filename=substr($path,strrpos($path,'/')+1);;
$fpath=substr($path,0,strrpos($path,'/')).'/';
if($re=$this->makeDir($fpath)){ //创建目录
if($re['error']) return $re;
}
$obz=io_remote::getBzByRemoteid($attach['remote']);
if($obz=='dzz'){
$opath='attach::'.$attach['aid'];
}else{
$opath=$obz.'/'.$attach['attachment'];
}
if($re=$this->multiUpload($opath,$fpath,$filename,$attach,'overwrite')){
if($re['error']) return $re;
else{
return true;
}
}
return false;
}
public function createFolderByPath($path, $pfid = '',$noperm = false)
{
$data = array();
if(self::makeDir($path)){
$data = self::getMeta($path);
}
return $data;
}
public function makeDir($path){
$arr=$this->parsePath($path);
$patharr=explode('/',trim($arr['object'],'/'));
$folderarr=array();
$p=$arr['bz'].$arr['bucket'];
foreach($patharr as $value){
$p.='/'.$value;
$re=$this->_makeDir($p);
if(isset($re['error'])){
return $re;
}else{
continue;
}
}
return true;
}
protected function _makeDir($path){
global $_G;
$arr=self::parsePath($path);
try {
$oss=self::init($path);
if(is_array($oss) && $oss['error']) return $oss;
$response=$oss->create_object_dir($arr['bucket'],$arr['object']);
if(!$response->isOk()){
return array('error'=>$response->status);
}
return true;
}catch(Exception $e){
//var_dump($e);
return array('error'=>$e->getMessage());
}
}
/*
*初始化OSS 返回oss 操作符
*/
public function init($bz,$isguest=0){
global $_G;
$bzarr=explode(':',$bz);
$id=trim($bzarr[1]);
if(!$root=DB::fetch_first("select * from ".DB::table(self::T)." where id='{$id}'")){
return array('error'=>'need authorize to '.$bzarr[0]);
}
if(!$isguest && $root['uid']>0 && $root['uid']!=$_G['uid']) return array('error'=>'need authorize to ALIOSS');
$access_id=authcode($root['access_id'],'DECODE',$root['bz']);
if(empty($access_id)) $access_id=$root['access_id'];
$access_key=authcode($root['access_key'],'DECODE',$root['bz']);
if($root['cloudname']){
$this->_rootname=$root['cloudname'];
}else{
$this->_rootname.=':'.($root['bucket']?$root['bucket']:cutstr($root['access_id'], 4, $dot = ''));
}
$this->bucket=$root['bucket'];
try{
return new ALIOSS($access_id,$access_key,$root['hostname']);
}catch(Exception $e){
return array('error'=>$e->getMessage());
}
}
public function getBucketALC($path){
$arr=self::parsePath($path);
$oss=self::init($path,1);
if(is_array($oss) && $oss['error']) return $oss;
$response=$oss->get_bucket_acl($arr['bucket']);
$alc=$response->getBody();
return $this->alc=$alc['AccessControlPolicy']['AccessControlList']['Grant'];
}
public function getBucketList($access_id,$access_key){
$re=array();
if(!$access_id || !$access_key) return array();
try{
require_once DZZ_ROOT.'./core/api/oss_sdk/sdk.class.php';
$oss = new ALIOSS($access_id,$access_key);
$response=$oss->list_bucket();
}catch(Exception $e){
return array();
}
if(!$response->isOK()){
return array();
}
$bucket=$response->getBody();
foreach($bucket['ListAllMyBucketsResult']['Buckets']['Bucket'] as $key=> $value){
if(is_array($value)){
$re[]=$value['Name'];
}else{
$re[]=$bucket['ListAllMyBucketsResult']['Buckets']['Bucket']['Name'];
break;
}
}
return $re;
}
public function authorize($refer){
global $_G,$_GET,$clouds;
if(empty($_G['uid'])) {
dsetcookie('_refer', rawurlencode(BASESCRIPT.'?mod=connect&op=oauth&bz=ALIOSS'));
showmessage('to_login', '', array(), array('showmsg' => true, 'login' => 1));
}
if(submitcheck('alisubmit')){
$access_id=$_GET['access_id'];
$access_key=$_GET['access_key'];
$hostname=$_GET['hostname'];
$bucket=$_GET['bucket'];
if(!$access_id || !$access_key) {
showmessage(lang('input_aliyun_acc_sec').'Access Key ID and Access Key Secret',dreferer());
}
if(!$bucket || !$hostname) showmessage('select_bucket_node_address',dreferer());
require_once DZZ_ROOT.'./core/api/oss_sdk/sdk.class.php';
$oss = new ALIOSS($access_id,$access_key,$hostname);
try{
$response=$oss->list_bucket();
if(!$response->isOK()){
showmessage('aliyun Access Key ID or Access Key Secret error',dreferer());
}
}catch(Exception $e){
showmessage($e->getMessage(),dreferer());
}
$type='ALIOSS';
$uid=defined('IN_ADMIN')?0:$_G['uid'];
$setarr=array( 'uid'=>$uid,
'access_id'=>$access_id,
'access_key'=>authcode($access_key,'ENCODE',$type),
'bz'=>$type,
'bucket'=>$bucket,
'hostname'=>$hostname,
'dateline'=>TIMESTAMP,
);
if($id=DB::result_first("select id from ".DB::table(self::T)." where uid='{$uid}' and access_id='{$access_id}' and bucket='{$bucket}'")){
DB::update(self::T,$setarr,"id ='{$id}'");
}else{
$id=DB::insert(self::T,$setarr,1);
}
if(defined('IN_ADMIN')){
$setarr=array('name'=>$clouds[$type]['name'].':'.($bucket?$bucket:cutstr($access_id,4,'')),
'bz'=>$type,
'isdefault'=>0,
'dname'=>self::T,
'did'=>$id,
'dateline'=>TIMESTAMP
);
if(!DB::result_first("select COUNT(*) from %t where did=%d and dname=%s ",array('local_storage',$id,self::T))){
C::t('local_storage')->insert($setarr);
}
showmessage('do_success',BASESCRIPT.'?mod=cloud&op=space');
}else{
showmessage('do_success',$refer?$refer:BASESCRIPT.'?mod=connect');
}
}else{
include template('oauth_ALIOSS');
exit();
}
}
public function getBzByPath($path){
$bzarr=explode(':',$path);
return $bzarr[0].':'.$bzarr[1].':';
}
public function getFileUri($path){
$arr=self::parsePath($path);
$oss=self::init($path,1);
if(is_array($oss) && $oss['error']) return $oss;
if(empty($this->alc)){
try{
$this->alc=$this->getBucketALC($path);
}catch(Exception $e){
return array('error'=>$e->getMessage());
}
}
if(strpos($this->alc,'read')!==false){
return ($oss->use_ssl?'https://':'http://').$arr['bucket'].'.'.$oss->hostname.'/'.$arr['object'];
}else{
return $oss->get_sign_url($arr['bucket'],$arr['object'],60*60*2);
}
}
public function deleteThumb($path){
global $_G;
$imgcachePath='./imgcache/';
$cachepath=str_replace('//','/',str_replace(':','/',$path));
foreach($_G['setting']['thumbsize'] as $value){
$target = $imgcachePath . ($cachepath) . '.' . $value['width'] . '_' . $value['height'] . '_1.jpeg';
$target1 = $imgcachePath . ($cachepath) . '.' . $value['width'] . '_' . $value['height'] . '_2.jpeg';
@unlink($_G['setting']['attachdir'].$target);
@unlink($_G['setting']['attachdir'].$target1);
}
}
public function createThumb($path,$size,$width=0,$height=0,$thumbtype = 1){
global $_G;
if(intval($width)<1) $width=$_G['setting']['thumbsize'][$size]['width'];
if(intval($height)<1) $height=$_G['setting']['thumbsize'][$size]['height'];
$imgcachePath='imgcache/';
$cachepath=str_replace(urlencode('/'),'/',urlencode(str_replace('//','/',str_replace(':','/',$path))));
$target = $imgcachePath . ($cachepath) . '.' . $width . '_' . $height . '_' .$thumbtype. '.jpeg';
if(@getimagesize($_G['setting']['attachdir'].'./'.$target)){
return 2;//已经存在缩略图
}
//调用挂载点程序生成缩略图绝对和相对地址；
$fileurls=array();
Hook::listen('thumbnail',$fileurls,$path);
if(!$fileurls){
$fileurls=array('fileurl'=>self::getFileUri($path),'filedir'=>self::getStream($path));
}
//非图片类文件的时候，直接获取文件后缀对应的图片
if(!$imginfo = @getimagesize($fileurls['filedir'])){
return -1; //非图片不能生成
}
if(($imginfo[0]<$width && $imginfo[1]<$height) ) {
return 3;//小于要求尺寸，不需要生成
}
//生成缩略图
include_once libfile('class/image');
$target_attach=$_G['setting']['attachdir'].'./'.$target;
$targetpath = dirname($target_attach);
dmkdir($targetpath);
$image=new image();
if($thumb = $image->Thumb($fileurls['filedir'], $target, $width, $height,$thumbtype)){
//if($thumb = $image->Thumb($imgurl,$target,$width, $height,1) ){
return 1;//生成缩略图成功
}else{
return 0;//生成缩略图失败
}
}
//获取缩略图
public function getThumb($path,$width,$height,$original,$returnurl = false,$thumbtype = 1){
global $_G;
$imgcachePath='imgcache/';
$cachepath=str_replace(urlencode('/'),'/',urlencode(str_replace('//','/',str_replace(':','/',$path))));
$target = $imgcachePath . ($cachepath) . '.' . $width . '_' . $height . '_' .$thumbtype. '.jpeg';
if(!$original && @getimagesize($_G['setting']['attachdir'].'./'.$target)){
if($returnurl) return $_G['setting']['attachurl'].'/'.$target;
IO::output_thumb($_G['setting']['attachdir'].'./'.$target);
}
//调用挂载点程序生成缩略图绝对和相对地址；
$fileurls=array();
Hook::listen('thumbnail',$fileurls,$path);
if(!$fileurls){
$fileurls=array('fileurl'=>self::getFileUri($path),'filedir'=>self::getStream($path));
}
//非图片类文件的时候，直接获取文件后缀对应的图片
if(!$imginfo = @getimagesize($fileurls['filedir'])){
$imgurl= geticonfromext($data['ext'],$data['type']);
if ($returnurl) return $imgurl;
IO::output_thumb($imgurl);
}
//返回原图的时候或图片小于缩略图宽高的不生成直接返回原图
if ($original || ($imginfo[0] < $width && $imginfo[1] < $height)) {
if ($returnurl) return $fileurls['fileurl'];
IO::output_thumb($fileurls['filedir']);
}
//生成图片缩略图
$imgurl = $fileurls['filedir'];
$target_attach = $_G['setting']['attachdir'] .'./'. $target;
$targetpath = dirname($target_attach);
dmkdir($targetpath);
require_once libfile('class/image');
$image = new image();
if($thumb = $image->Thumb($imgurl, $target, $width, $height,$thumbtype)){
if($returnurl) return $_G['setting']['attachurl'].'/'.$target;
IO::output_thumb($_G['setting']['attachdir'].'./'.$target);
}else{
if($returnurl) return $imgurl;
IO::output_thumb($imgurl);
}
}
//获取文件流；
//$path: 路径
function getStream($path){
$arr=self::parsePath($path);
$oss=self::init($path,1);
if(is_array($oss) && $oss['error']) return $oss;
if(empty($this->alc)){
try{
$this->alc=$this->getBucketALC($path);
}catch(Exception $e){
}
}
if(strpos($this->alc,'read')!==false){
return ($oss->use_ssl?'https://':'http://').$arr['bucket'].'.'.str_replace('-internal.aliyuncs.com','.aliyuncs.com',$oss->hostname).'/'.$arr['object'];
}else{
return $oss->get_sign_url($arr['bucket'],$arr['object'],60*60*2);
}
}
public function parsePath($path){
$arr=explode(':',$path);
$bz=$arr[0].':'.$arr[1].':';
$arr1=explode('/',$arr[2]);
//if(count($arr1)>1){
$bucket=$arr1[0];
unset($arr1[0]);
//}else $bucket='';
//if(!$bucket) return array('error'=>'bucket不能为空');
$object=implode('/',$arr1);
return array('bucket'=>$bucket,'object'=>$object,'bz'=>$bz);
}
//重写文件内容
//@param number $path 文件的路径
//@param string $data 文件的新内容
public function setFileContent($path,$data){
$patharr=explode('/',$path);
$filename=$patharr[count($patharr)-1];
unset($patharr[count($patharr)-1]);
$path1=implode('/',$patharr).'/';
$icoarr=self::upload_by_content($data,$path1,$filename,0,'overwrite');
if($icoarr['type']=='image'){
self::deleteThumb($path);
$icoarr['img'].='&t='.TIMESTAMP;
}
return $icoarr;
}
/**
* 上传文件
* @param string $fileContent 文件内容字符串
* @param string $path 上传文件的目标保存路径
* @param string $fileName 文件名
* @param string $newFileName 新文件名
* @param string $ondup overwrite：目前只支持覆盖。
* @return string
*/
function upload_by_content($fileContent,$path,$filename,$ondup='overwrite'){
global $_G;
$path.=$filename;
$arr=self::parsePath($path);
try{
$oss=self::init($path);
if(is_array($oss) && $oss['error']) return $oss;
$upload_file_options = array(
'content' => $fileContent,
'length' => strlen($fileContent)
);
$response = $oss->upload_file_by_content($arr['bucket'],$arr['object'],$upload_file_options);
if(!$response->isOk()){
return array('error'=>$response->status);
}
if(md5($fileContent)!=strtolower(trim($response->header['etag'],'"'))){ //验证上传是否完整
return array('error'=>lang('upload_file_incomplete'));
}
$meta=array(
'Key'=>$arr['object'],
'Size'=>strlen($fileContent),
'LastModified'=>$response->header['date'],
);
$icoarr=self::_formatMeta($meta,$arr);
return $icoarr;
}catch(Exception $e){
return array('error'=>$e->getMessage());
}
}
/**
* 获取当前用户空间配额信息
* @return string
*/
public function getQuota($bz) {
return 0;
}
/**
* 获取指定文件夹下的文件列表
* @param string $path 文件路径
* @param string $by 排序字段，缺省根据文件类型排序，time（修改时间），name（文件名），size（大小，注意目录无大小）
* @param string $order asc或desc，缺省采用降序排序
* @param string $limit 返回条目控制，参数格式为：n1-n2。返回结果集的[n1, n2)之间的条目，缺省返回所有条目。n1从0开始。
* @param string $force 读取缓存，大于0：忽略缓存，直接调用api数据，常用于强制刷新时。
* @return icosdatas
*/
function listFiles($path,$by='time',$marker='',$limit=100,$force=0){
global $_G,$_GET,$documentexts,$imageexts;
$arr=self::parsePath($path);
$icosdata=array();
$oss=self::init($path,1);
if(is_array($oss) && $oss['error']) return $oss;
if(!$arr['bucket']){
$response=$oss->list_bucket();
$bucket=$response->getBody();
$icosdata=array();
foreach($bucket['ListAllMyBucketsResult']['Buckets']['Bucket'] as $value){
$arr['bucket']=$value['Name'];
$value['Key']='';
$value['LastModified']=$value['CreationDate'];
$value['isdir']=true;
$value['nextMarker']='';
$value['IsTruncated']=false;
$icoarr=self::_formatMeta($value,$arr);
$icosdata[$icoarr['icoid']]=$icoarr;
}
//print_r($arr);exit($path);
//print_r($folderarr);exit('ddddd');
}else{
$response=$oss->list_object($arr['bucket'],array('prefix'=>$arr['object'],'marker'=>$marker,'max-keys'=>$limit));
$data=$response->getBody();
if($data['ListBucketResult']['Contents']) $icos=$data['ListBucketResult']['Contents'];
if($data['ListBucketResult']['CommonPrefixes']) $folders=$data['ListBucketResult']['CommonPrefixes'];
$value=array();
foreach($icos as $key => $value){
if(is_array($value)){
$icoarr=self::_formatMeta($value,$arr);
$icosdata[$icoarr['icoid']]=$icoarr;
}else{
$icoarr=self::_formatMeta($icos,$arr);
$icosdata[$icoarr['icoid']]=$icoarr;
break;
}
}
$value=array();
foreach($folders as $key => $value){
if(is_array($value)){
$value['isdir']=true;
$value['Key']=$value['Prefix'];
$value['LastModified']='';
$icoarr=self::_formatMeta($value,$arr);
$icosdata[$icoarr['icoid']]=self::getMeta($icoarr['path']);
}else{
$folders['isdir']=true;
$folders['Key']=$folders['Prefix'];
$icoarr=self::_formatMeta($folders,$arr);
$icosdata[$icoarr['icoid']]=self::getMeta($icoarr['path']);
break;
}
}
$value=array();
$value['isdir']=true;
$value['Key']=$data['ListBucketResult']['Prefix']?$data['ListBucketResult']['Prefix']:'';
$value['nextMarker']=$data['ListBucketResult']['NextMarker'];
$value['IsTruncated']=$data['ListBucketResult']['IsTruncated'];
$icoarr=self::_formatMeta($value,$arr);
if($icosdata[$icoarr['icoid']]){
$icosdata[$icoarr['icoid']]['nextMarker'] =$icoarr['nextMarker'];
$icosdata[$icoarr['icoid']]['IsTruncated'] =$icoarr['IsTruncated'];
}else{
$icosdata[$icoarr['icoid']]=$icoarr;
}
}
/*print_r($data);
print_r($icosdata);
exit('dfdsf');*/
return $icosdata;
}
/**
* 获取指定文件夹下的文件列表
* @param string $path 文件路径
* @param string $by 排序字段，缺省根据文件类型排序，time（修改时间），name（文件名），size（大小，注意目录无大小）
* @param string $order asc或desc，缺省采用降序排序
* @param string $limit 返回条目控制，参数格式为：n1-n2。返回结果集的[n1, n2)之间的条目，缺省返回所有条目。n1从0开始。
* @param string $force 读取缓存，大于0：忽略缓存，直接调用api数据，常用于强制刷新时。
* @return icosdatas
*/
function listFilesAll(&$oss,$path,$limit='1000',$marker='',$icosdata=array()){
//static $icosdata=array();
$arr=self::parsePath($path);
$response=$oss->list_object($arr['bucket'],array('prefix'=>$arr['object'],'marker'=>$marker,'max-keys'=>$limit));
$data=$response->getBody();
if($data['ListBucketResult']['Contents']) $icos=$data['ListBucketResult']['Contents'];
if($data['ListBucketResult']['CommonPrefixes']) $folders=$data['ListBucketResult']['CommonPrefixes'];
$value=array();
foreach($icos as $key => $value){
if(is_array($value)){
$icoarr=self::_formatMeta($value,$arr);
$icosdata[$icoarr['icoid']]=$icoarr;
}else{
$icoarr=self::_formatMeta($icos,$arr);
$icosdata[$icoarr['icoid']]=$icoarr;
break;
}
}
$value=array();
foreach($folders as $key => $value){
if(is_array($value)){
$value['isdir']=true;
$value['Key']=$value['Prefix'];
$value['LastModified']='';
$icoarr=self::_formatMeta($value,$arr);
$icosdata[$icoarr['icoid']]=self::getMeta($icoarr['path']);
}else{
$folders['isdir']=true;
$folders['Key']=$folders['Prefix'];
$icoarr=self::_formatMeta($folders,$arr);
$icosdata[$icoarr['icoid']]=self::getMeta($icoarr['path']);
break;
}
}
$value=array();
$value['isdir']=true;
$value['Key']=$data['ListBucketResult']['Prefix']?$data['ListBucketResult']['Prefix']:'';
$value['nextMarker']=$data['ListBucketResult']['NextMarker'];
$value['IsTruncated']=$data['ListBucketResult']['IsTruncated'];
$icoarr=self::_formatMeta($value,$arr);
//print_r($icoarr);print_r($data);exit('ddddd');
if($icosdata[$icoarr['icoid']]){
$icosdata[$icoarr['icoid']]['nextMarker'] =$icoarr['nextMarker'];
$icosdata[$icoarr['icoid']]['IsTruncated'] =$icoarr['IsTruncated'];
}else{
$icosdata[$icoarr['icoid']]=$icoarr;
}
//exit($data['ListBucketResult']['IsTruncated']);
if($data['ListBucketResult']['IsTruncated']=='true'){
$icosdata=self::listFilesAll($oss,$path,1000,$data['ListBucketResult']['nextMarker'],$icosdata);
//self::getFolderObjects($path,1000,$data['ListBucketResult']['nextMarker']);
}
return $icosdata;
}
/*
*获取文件的meta数据
*返回标准的icosdata
*$force>0 强制刷新，不读取缓存数据；
*/
function getMeta($path,$force=0){
global $_G,$_GET,$documentexts,$imageexts;
$arr=self::parsePath($path);
$icosdata=array();
$oss=self::init($path,1);
if(is_array($oss) && $oss['error']) return $oss;
if(empty($arr['object']) || empty($arr['bucket'])){
$meta=array(
'Key'=>'',
'Size'=>0,
'LastModified'=>'',
'isdir'=>true
);
}else{
try{
$response=$oss->get_object_meta($arr['bucket'],$arr['object'],array('Content-Type'=>'application/octet-stream'));
}catch(Exception $e){
return array('error'=>$e->getMessage());
}
if(!$response->isOk()){
return array('error'=>$response->status);
}
$return=$response->header;
if(!$return['content-length']) {
$headers=get_headers(self::getStream($path),1);
$return['content-length']=$headers['Content-Length'];
}
$meta=array(
'Key'=>str_replace($arr['bz'].$arr['bucket'].'/','',$path),
'Size'=>$return['content-length'],
'LastModified'=>$return['last-modified'],
);
}
$icosdata=self::_formatMeta($meta,$arr);
return $icosdata;
}
//将api获取的meta数据转化为icodata
function _formatMeta($meta,$arr){
global $_G,$documentexts,$imageexts;
$icosdata=array();
///print_r($meta);print_r($arr);exit($this->bucket);
if(strrpos($meta['Key'],'/')==(strlen($meta['Key'])-1)) $meta['isdir']=true;
if($meta['isdir']){
if(!$meta['Key']){
if($this->bucket){
$name=$this->bucket;
$pfid=0;
$pf='';
$flag=self::BZ;
}elseif($arr['bucket']){
$name=$arr['bucket'];
$pfid=md5($arr['bz']);
$pf='';
$flag=self::BZ;
}else{
$name=$this->_rootname;
$pfid=0;
$pf='';
$flag=self::BZ;
}
if($arr['bucket']) $arr['bucket'].='/';
}else{
if($arr['bucket']) $arr['bucket'].='/';
$namearr=explode('/',$meta['Key']);
$name=$namearr[count($namearr)-2];
$pf='';
for($i=0;$i<(count($namearr)-2);$i++){
$pf.=$namearr[$i].'/';
}
$pf=$arr['bucket'].$pf;
$pfid=md5($arr['bz'].$pf);
$flag='';
}
//print_r($arr);
//print_r($namearr);
$icoarr=array(
'icoid'=>md5(($arr['bz'].$arr['bucket'].$meta['Key'])),
'path'=>$arr['bz'].$arr['bucket'].$meta['Key'],
'dpath'=>dzzencode($arr['bz'].$arr['bucket'].$meta['Key']),
'bz'=>($arr['bz']),
'gid'=>0,
'name'=>$name,
'username'=>$_G['username'],
'uid'=>$_G['uid'],
'oid'=>md5($arr['bz'].$arr['bucket'].$meta['Key']),
'img'=>'dzz/images/default/system/folder.png',
'type'=>'folder',
'ext'=>'',
'pfid'=>$pfid,
'ppath'=>$arr['bz'].$pf,
'size'=>0,
'dateline'=>strtotime($meta['LastModified']),
'flag'=>$flag,
'nextMarker'=>$meta['nextMarker'],
'IsTruncated'=>$meta['IsTruncated'],
);
$icoarr['fsize']=formatsize($icoarr['size']);
$icoarr['ftype']=getFileTypeName($icoarr['type'],$icoarr['ext']);
$icoarr['fdateline']=dgmdate($icoarr['dateline']);
$icosdata=$icoarr;
/*print_r($icosdata);
exit($meta['Key']);*/
}else{
if($arr['bucket']) $arr['bucket'].='/';
$namearr=explode('/',$meta['Key']);
$name=$namearr[count($namearr)-1];
$pf='';
for($i=0;$i<count($namearr)-1;$i++){
$pf.=$namearr[$i].'/';
}
$ext=strtoupper(substr(strrchr($meta['Key'], '.'), 1));
if(in_array($ext,$imageexts)) $type='image';
elseif(in_array($ext,$documentexts)) $type='document';
else $type='attach';
if($type=='image'){
$img=$_G['siteurl'].DZZSCRIPT.'?mod=io&op=thumbnail&size=small&path='.dzzencode($arr['bz'].$arr['bucket'].$meta['Key']);
$url=$_G['siteurl'].DZZSCRIPT.'?mod=io&op=thumbnail&size=large&path='.dzzencode($arr['bz'].$arr['bucket'].$meta['Key']);
}else{
$img=geticonfromext($ext,$type);
$url=$_G['siteurl'].DZZSCRIPT.'?mod=io&op=getStream&path='.dzzencode($arr['bz'].$arr['bucket'].$meta['Key']);
}
$icoarr=array(
'icoid'=>md5(($arr['bz'].$arr['bucket'].$meta['Key'])),
'path'=>($arr['bz'].$arr['bucket'].$meta['Key']),
'dpath'=>dzzencode($arr['bz'].$arr['bucket'].$meta['Key']),
'bz'=>($arr['bz']),
'gid'=>0,
'name'=>$name,
'username'=>$_G['username'],
'uid'=>$_G['uid'],
'oid'=>md5(($arr['bz'].$arr['bucket'].$meta['Key'])),
'img'=>$img,
'url'=>$url,
'type'=>$type,
'ext'=>strtolower($ext),
'pfid'=>md5($arr['bz'].$arr['bucket'].$pf),
'ppath'=>$arr['bz'].$arr['bucket'].$pf,
'size'=>$meta['Size'],
'dateline'=>strtotime($meta['LastModified']),
'flag'=>''
);
$icoarr['fsize']=formatsize($icoarr['size']);
$icoarr['ftype']=getFileTypeName($icoarr['type'],$icoarr['ext']);
$icoarr['fdateline']=dgmdate($icoarr['dateline']);
$icosdata=$icoarr;
}
return $icosdata;
}
//根据路径获取目录树的数据；
public function getFolderDatasByPath($path){
$bzarr=self::parsePath($path);
$oss=self::init($path,1);
$spath=$bzarr['object'];
if(!$this->bucket && $bzarr['bucket']){
$spath=$bzarr['bucket'].'/'.$spath;
$bzarr['bucket']='';
}else{
$bzarr['bucket'].='/';
}
$spath=trim($spath,'/');
$patharr=explode('/',$spath);
$folderarr=array();
$path1=$bzarr['bz'].$bzarr['bucket'];
if($arr=self::getMeta($path1)){
if(!isset($arr['error'])) {
$folder=self::getFolderByIcosdata($arr);
$folderarr[$folder['fid']]=$folder;
}
}
for($i=0;$i<count($patharr);$i++){
$path1=$bzarr['bz'].$bzarr['bucket'];
for($j=0;$j<=$i;$j++){
$path1.=$patharr[$j].'/';
}
if($arr=self::getMeta($path1)){
if(isset($arr['error'])) continue;
$folder=self::getFolderByIcosdata($arr);
$folderarr[$folder['fid']]=$folder;
}
}
return $folderarr;
}
//通过icosdata获取folderdata数据
function getFolderByIcosdata($icosdata){
global $_GET;
$folder=array();
//通过path判断是否为bucket
$path=$icosdata['path'];
$arr=self::parsePath($path);
if(!$arr['bucket']){ //根目录
$fsperm=perm_FolderSPerm::flagPower('ALIOSS_root');
}else{
$fsperm=perm_FolderSPerm::flagPower('ALIOSS');
}
if($icosdata['type']=='folder'){
$folder=array('fid'=>$icosdata['oid'],
'path'=>$icosdata['path'],
'fname'=>$icosdata['name'],
'uid'=>$icosdata['uid'],
'pfid'=>$icosdata['pfid'],
'ppath'=>$icosdata['ppath'],
'iconview'=>$_GET['iconview']?intval($_GET['iconview']):0,
'disp'=>$_GET['disp']?intval($_GET['disp']):0,
'perm'=>$this->perm,
'hash'=>$icosdata['hash'],
'bz'=>$icosdata['bz'],
'gid'=>$icosdata['gid'],
'fsperm'=>$fsperm,
'icon'=>$icosdata['flag']?('dzz/images/default/system/'.$icosdata['flag'].'.png'):'',
'nextMarker'=>$icosdata['nextMarker'],
'IsTruncated'=>$icosdata['IsTruncated'],
);
//print_r($folder);
}
return $folder;
}
//获得文件内容；
function getFileContent($path){
$arr=self::parsePath($path);
$url=self::getFileUri($path);
return file_get_contents($url);
}
//打包下载文件
public function zipdownload($paths,$filename){
global $_G;
$paths=(array)$paths;
set_time_limit(0);
if(empty($filename)){
$meta=self::getMeta($paths[0]);
$filename=$meta['name'].(count($paths)>1?lang('wait'):'');
}
$filename=(strtolower(CHARSET) == 'utf-8' && (strexists($_SERVER['HTTP_USER_AGENT'], 'MSIE') || strexists($_SERVER['HTTP_USER_AGENT'], 'Edge') || strexists($_SERVER['HTTP_USER_AGENT'], 'rv:11')) ? urlencode($filename) : $filename);
include_once libfile('class/ZipStream');
$zip = new ZipStream($filename.".zip");
$data=self::getFolderInfo($paths,'',$zip);
/*if($data['error']){
topshowmessage($data['error']);
exit();
}*/
/*foreach($data as $value){
$zip->addLargeFile(fopen($value['url'],'rb'), $value['position'], $value['dateline']);
}*/
$zip->finalize();
}
public function getFolderInfo($paths,$position='',$zip){
static $data=array();
try{
foreach($paths as $path){
$arr=IO::parsePath($path);
$oss=self::init($path,1);
if(is_array($oss) && $oss['error']) return $oss;
$meta=self::getMeta($path);
switch($meta['type']){
case 'folder':
$lposition=$position.$meta['name'].'/';
$contents=self::listFilesAll($oss,$path);
$arr=array();
foreach($contents as $key=>$value){
if($value['path']!=$path){
$arr[]=$value['path'];
}
}
if($arr) self::getFolderInfo($arr,$lposition,$zip);
break;
default:
$meta['url']=self::getStream($meta['path']);
$meta['position']=$position.$meta['name'];
//$data[$meta['icoid']]=$meta;
$zip->addLargeFile(@fopen($meta['url'],'rb'), $meta['position'], $meta['dateline']);
}
}
}catch(Exception $e){
//var_dump($e);
$data['error']=$e->getMessage();
return $data;
}
return $data;
}
//下载文件
public function download($paths,$filename){
global $_G;
$paths=(array)$paths;
if(count($paths)>1){
self::zipdownload($paths,$filename);
exit();
}else{
$path=$paths[0];
}
$path=rawurldecode($path);
//header("location: $url");
try {
$url=self::getStream($path);
// Download the file
$file=self::getMeta($path);
if($file['type']=='folder'){
self::zipdownload($path);
exit();
}
if(!$fp = @fopen($url, 'rb')) {
topshowmessage(lang('file_not_exist1'));
}
$chunk = 10 * 1024 * 1024;
//$file['data'] = self::getFileContent($path);
//if($file['data']['error']) topshowmessage($file['data']['error']);
$file['name'] = '"'.(strtolower(CHARSET) == 'utf-8' && (strexists($_SERVER['HTTP_USER_AGENT'], 'MSIE') || strexists($_SERVER['HTTP_USER_AGENT'], 'Edge') || strexists($_SERVER['HTTP_USER_AGENT'], 'rv:11')) ? urlencode($file['name']) : $file['name']).'"';
$d=new FileDownload();
$d->download($url,$file['name'],$file['size'],$file['dateline'],true);
exit();
dheader('Date: '.gmdate('D, d M Y H:i:s', $file['dateline']).' GMT');
dheader('Last-Modified: '.gmdate('D, d M Y H:i:s', $file['dateline']).' GMT');
dheader('Content-Encoding: none');
dheader('Content-Disposition: attachment; filename='.$file['name']);
dheader('Content-Type: application/octet-stream');
dheader('Content-Length: '.$file['size']);
@ob_end_clean();
if(getglobal('gzipcompress')) @ob_start('ob_gzhandler');
while (!feof($fp)) {
echo fread($fp, $chunk);
@ob_flush(); // flush output
@flush();
}
fclose($fp);
exit();
} catch (Exception $e) {
// The file wasn't found at the specified path/revision
//echo 'The file was not found at the specified path/revision';
topshowmessage($e->getMessage());
}
}
//获取目录的所有下级和它自己的object
public function getFolderObjects(&$oss,$path,$limit='1000',$marker=''){
static $objects=array();
$arr=self::parsePath($path);
//echo( $path.'---------');
$response=$oss->list_object($arr['bucket'],array('prefix'=>$arr['object'],'marker'=>$marker,'max-keys'=>$limit,'delimiter'=>''));
$data=$response->getBody();
if($data['ListBucketResult']['Contents']) $icos=$data['ListBucketResult']['Contents'];
if($data['ListBucketResult']['CommonPrefixes']) $folders=$data['ListBucketResult']['CommonPrefixes'];
error_reporting(E_ERROR);
$value=array();
foreach($icos as $key => $value){
if(is_array($value)){
$objects[]=$value['Key'];
}else{
$objects[]=$icos['Key'];
break;
}
}
$value=array();
foreach($folders as $key => $value){
if(is_array($value)){
$objects[]=$value['Prefix'];
}else{
$objects[]=$folders['Prefix'];
break;
}
}
//exit('dddddd='.$data['ListBucketResult']['IsTruncated']);
if($data['ListBucketResult']['IsTruncated']=='true'){
/*if($objs=self::getFolderObjects($oss,$path,1000,$data['ListBucketResult']['nextMarker'])){
$objects=array_merge($objects,$objs);
}*/
self::getFolderObjects($path,1000,$data['ListBucketResult']['nextMarker']);
}
return $objects;
}
//删除原内容
//$path: 删除的路径
//$bz: 删除的api;
//$data：可以删除的id数组（当剪切的时候，为了保证数据不丢失，目标位置添加成功后将此id添加到data数组，
//删除时如果$data有数据，将会只删除id在$data中的数据；
//如果删除的是目录或下级有目录，需要判断此目录内是否所有元素都在删除的id中，如果有未删除的元素，则此目录保留不会删除；
//
public function Delete($path,$force=false){
//global $dropbox;
$arr=self::parsePath($path);
try{
$oss=self::init($path,$force);
if(is_array($oss) && $oss['error']) return $oss;
//判断删除的对象是否为文件夹
if(strrpos($arr['object'],'/')==(strlen($arr['object'])-1)){ //是文件夹
$objects=self::getFolderObjects($oss,$path);
$response = $oss->delete_objects($arr['bucket'],$objects,array('quiet'=>true));
}else{
$response = $oss->delete_object($arr['bucket'],$arr['object']);
}
if(!$response->isOk()){
return array('error'=>$response->status);
}
return array('icoid'=>md5(($path)),
'name'=>substr(strrchr($path, '/'), 1),
);
}catch(Exception $e){
return array('icoid'=>md5($path),'error'=>$e->getMessage());
}
}
//添加目录
//$fname：目录路径;
//$container：目标容器
//$bz：api;
public function CreateFolder($path,$fname){
global $_G;
$arr=self::parsePath($path);
//exit('createrfolder==='.$fname.'===='.$path1.'===='.$bz);
//exit($path.$fname.'vvvvvvvvvvv');
$return=array();
try {
$oss=self::init($path);
if(is_array($oss) && $oss['error']) return $oss;
$response=$oss->create_object_dir($arr['bucket'],$arr['object'].$fname);
if(!$response->isOk()){
return array('error'=>$response->status);
}
$meta=array('isdir'=>true,
'Key'=>$arr['object'].$fname.'/',
'Size'=>0,
'LastModified'=>$response->header['date'],
);
$icoarr=self::_formatMeta($meta,$arr);
$folderarr=self::getFolderByIcosdata($icoarr);
$return= array('folderarr'=>$folderarr,'icoarr'=>$icoarr);
}catch(Exception $e){
//var_dump($e);
$return=array('error'=>$e->getMessage());
}
return $return;
}
//获取不重复的目录名称
public function getFolderName($name,$path){
static $i=0;
if(!$this->icosdatas) $this->icosdatas=self::listFiles($path);
$names=array();
foreach($icosdatas as $value){
$names[]=$value['name'];
}
if(in_array($name,$names)){
$name=str_replace('('.$i.')','',$name).'('.($i+1).')';
$i+=1;
return self::getFolderName($name,$path);
}else {
return $name;
}
}
private function getCache($path){
$cachekey='ALIOSS_uploadID_'.md5($path);
$cache=C::t('cache')->fetch($cachekey);
return unserialize($cache['cachevalue']);
}
private function saveCache($path,$data){
global $_G;
$cachekey='ALIOSS_uploadID_'.md5($path);
C::t('cache')->insert(array(
'cachekey' => $cachekey,
'cachevalue' => serialize($data),
'dateline' => $_G['timestamp'],
), false, true);
}
private function deleteCache($path){
$cachekey='ALIOSS_uploadID_'.md5($path);
C::t('cache')->delete($cachekey);
}
private function getPartInfo($content_range){
$arr=array();
if(!$content_range){
$arr['ispart']=false;
$arr['iscomplete']=true;
}elseif(is_array($content_range)){
$arr['ispart']=true;
$partsize=getglobal('setting/maxChunkSize');
$arr['partnum']=ceil(($content_range[2]+1)/$partsize);
if(($content_range[2]+1)>=$content_range[3]){
$arr['iscomplete']=true;
}else{
$arr['iscomplete']=false;
}
}else{
return false;
}
return $arr;
}
public function uploadStream($file,$filename,$path,$relativePath,$content_range){
$data=array();
$arr=self::getPartInfo($content_range);
//echo ($relativePath).'vvvvvvvv';
//if($arr['partnum']>1) print_r($arr);
if($relativePath && ($arr['iscomplete'])){
$path1=$path;
$patharr=explode('/',$relativePath);
//print_r($patharr);
foreach($patharr as $key=> $value){
if(!$value){
continue;
}
// echo $path1.'---'.$value.'------';
$re=self::CreateFolder($path1,$value);
if(isset($re['error'])){
return $re;
}else{
if($key==0){
$data['icoarr'][]=$re['icoarr'];
$data['folderarr'][]=$re['folderarr'];
}
}
$path1=$path1.$value.'/';
}
}
$path.=$relativePath;
if($arr['ispart']){
if($re1=self::upload($file,$path,$filename,$arr)){
if($re1['error']){
return $re1;
}
if($arr['iscomplete']){
if(empty($re1['error'])){
$data['icoarr'][] = $re1;
return $data;
}else{
$data['error'] = $re1['error'];
return $data;
}
}else{
return true;
}
}
}else{
$re1=self::upload($file,$path,$filename);
if(empty($re1['error'])){
$data['icoarr'][] = $re1;
return $data;
}else{
$data['error'] = $re1['error'];
return $data;
}
}
}
function upload($file,$path,$filename,$partinfo=array(),$ondup='overwrite'){
global $_G;
$path.=$filename;
$arr=self::parsePath($path);
try{
$oss=self::init($path);
if(is_array($oss) && $oss['error']) return $oss;
$upload_file_options = array(
'fileUpload' => $file,
);
if($partinfo['partnum']){
$upload_file_options['partNumber']=$partinfo['partnum'];
if($partinfo['partnum']==1){//第一个分块时 初始化分块上传得到$uploadID;并缓存住，留以后分块使用
//初始化分块
$response=$oss->initiate_multipart_upload($arr['bucket'],$arr['object']);
if(!$response->isOk()){
return array('error'=>'initiate multipart error');
}
$body=$response->getBody();
$upload_id=$body['InitiateMultipartUploadResult']['UploadId'];
//上传分块
$response=$oss->upload_part($arr['bucket'],$arr['object'], $upload_id, $upload_file_options);
if(!$response->isOk()){
return array('error'=>'upload partNember 1 error');
}
if(md5_file($file)!=strtolower(trim($response->header['etag'],'"'))){ //验证上传是否完整
return array('error'=>lang('upload_file_incomplete'));
}
$data=array();
$data['upload_id']=$upload_id;
$data['filesize']=filesize($file);
$data['partnum']=1;
$data['path']=$path;
$data['parts'][$data['partnum']]=array('PartNumber'=>$data['partnum'],'ETag'=>$response->header['etag']);
self::saveCache($path,$data);
}else{
$cache=self::getCache($path);
$upload_id=$cache['upload_id'];
$cache['partnum']+=1;
//上传分块
$response=$oss->upload_part($arr['bucket'],$arr['object'], $upload_id, $upload_file_options);
if(!$response->isOk()){
return array('error'=>'upload partNember '.$cache['partnum'].' error');
}
if(md5_file($file)!=strtolower(trim($response->header['etag'],'"'))){ //验证上传是否完整
return array('error'=>lang('upload_file_incomplete'));
}
//print_r($cache);
$cache['filesize']+=filesize($file);
$cache['parts'][$partinfo['partnum']]=array('PartNumber'=>$cache['partnum'],'ETag'=>$response->header['etag']);
//print_r($cache);exit('dddd');
self::saveCache($path,$cache);
}
if($partinfo['iscomplete']){
$cache=self::getCache($path);
$response = $oss->complete_multipart_upload($arr['bucket'],$arr['object'], $cache['upload_id'], $cache['parts']);
if(!$response->isOk()){
return array('error'=>$response->status);
}
self::deleteCache($path);
$meta=array(
'Key'=>$arr['object'],
'Size'=>$cache['filesize'],
'LastModified'=>$response->header['date'],
);
$icoarr=self::_formatMeta($meta,$arr);
return $icoarr;
}else{
return true;
}
}else{
$response = $oss->upload_file_by_file($arr['bucket'],$arr['object'],$file);
if(!$response->isOk()){
return array('error'=>$response->status);
}
if(md5_file($file)!=strtolower(trim($response->header['etag'],'"'))){ //验证上传是否完整
return array('error'=>lang('upload_file_incomplete'));
}
$meta=array(
'Key'=>$arr['object'],
'Size'=>filesize($file),
'LastModified'=>$response->header['date'],
);
$icoarr=self::_formatMeta($meta,$arr);
return $icoarr;
}
}catch(Exception $e){
return array('error'=>$e->getMessage());
}
}
public function rename($path,$name){//重命名
$arr=self::parsePath($path);
//判断是否为目录
$patharr=explode('/',$arr['object']);
$arr['object1']='';
if(strrpos($path,'/')==(strlen($path)-1)){//是目录
return array('error'=>lang('folder_not_allowed_rename'));
}else{
$ext=strtolower(substr(strrchr($arr['object'], '.'), 1));
foreach($patharr as $key =>$value){
if($key>=count($patharr)-1) break;
$arr['object1'].=$value.'/';
}
$arr['object1'].=$ext?(preg_replace("/\.\w+$/i",'.'.$ext,$name)):$name;
}
if($arr['object']!=$arr['object1']){
$oss=self::init($path);
if(is_array($oss) && $oss['error']) return $oss;
$response=$oss->copy_object($arr['bucket'],$arr['object'],$arr['bucket'],$arr['object1']);
if(!$response->isOk()){
return array('error'=>$response->status);
}
$response = $oss->delete_object($arr['bucket'],$arr['object']);
}
return self::getMeta($arr['bz'].$arr['bucket'].'/'.$arr['object1']);
}
/**
* 移动文件到目标位置
* @param string $opath 被移动的文件路径
* @param string $path 目标位置（可能是同一api内或跨api，这两种情况分开处理）
* @return icosdatas
*/
public function CopyTo($opath,$path,$iscopy){
static $i=0;
$i++;
$oarr=self::parsePath($opath);
$arr=IO::parsePath($path);
$oss=self::init($opath);
if(is_array($oss) && $oss['error']) return $oss;
try{
$data=self::getMeta($opath);
switch($data['type']){
case 'folder'://创建目录
//exit($arr['path'].'===='.$data['name']);
if($re=IO::CreateFolder($path,$data['name'])){
if(isset($re['error']) && intval($re['error_code'])!=31061){
$data['success']=$arr['error'];
}else{
$data['newdata']=$re['icoarr'];
$data['success']=true;
//echo $opath.'<br>';
$contents=self::listFilesAll($oss,$opath);
$value=array();
foreach($contents as $key=>$value){
if($value['path']!=$opath){
$data['contents'][$key]=self::CopyTo($value['path'],$re['folderarr']['path']);
}
$value=array();
}
}
}else{
$data['success']='create folder failure';
}
break;
default:
if($arr['bz']==$oarr['bz']){//同一个api时
$arr=self::parsePath($path.$data['name']);
$response=$oss->copy_object($oarr['bucket'],$oarr['object'],$arr['bucket'],$arr['object']);
if(!$response->isOk()){
$data['success']=$response->status;
}
$meta=array(
'Key'=>$arr['object'],
'Size'=>$data['size'],
'LastModified'=>$response->header['date'],
);
$data['newdata']=self::_formatMeta($meta,$arr);
$data['success']=true;
}else{
if($re=IO::multiUpload($opath,$path,$data['name'])){
if($re['error']) $data['success']=$re['error'];
else{
$data['newdata']=$re;
$data['success']=true;
}
}
}
break;
}
// }
}catch(Exception $e){
//var_dump($e);
$data['success']=$e->getMessage();
return $data;
}
return $data;
}
public function multiUpload($opath,$path,$filename,$attach=array(),$ondup="newcopy"){
global $_G;
$partsize=1024*1024*5; //分块大小2M
if($attach){
$data=$attach;
$data['size']=$attach['filesize'];
}else{
$data=IO::getMeta($opath);
if($data['error']) return $data;
}
$size=$data['size'];
if(is_array($filepath=IO::getStream($opath))){
return array('error'=>$filepath['error']);
}
//exit(($size<$partsize).'===='.$size.'==='.$filepath.'===='.$path);
if($size<$partsize){
//获取文件内容
$fileContent='';
if(!$handle=fopen($filepath, 'rb')){
return array('error'=>lang('open_file_error'));
}
while (!feof($handle)) {
$fileContent .= fread($handle, 8192);
//if(strlen($fileContent)==0) return array('error'=>'文件不存在');
}
fclose($handle);
//exit('upload');
return self::upload_by_content($fileContent,$path,$filename);
}else{ //分片上传
$partinfo=array('ispart'=>true,'partnum'=>0,'iscomplete'=>false);
if(!$handle=fopen($filepath, 'rb')){
return array('error'=>lang('open_file_error'));
}
$cachefile=$_G['setting']['attachdir'].'./cache/'.md5($opath).'.dzz';
$fileContent='';
while (!feof($handle)) {
$fileContent.=fread($handle, 8192);
if(strlen($fileContent)==0) return array('error'=>lang('file_not_exist1'));
if(strlen($fileContent)>=$partsize){
if($partinfo['partnum']*$partsize+strlen($fileContent)>=$size) $partinfo['iscomplete']=true;
$partinfo['partnum']+=1;
file_put_contents($cachefile,$fileContent);
$re=self::upload($cachefile,$path,$filename,$partinfo);
if($re['error']) return $re;
if($partinfo['iscomplete']){
@unlink($cachefile);
return $re;
}
$fileContent='';
}
}
fclose($handle);
if(!empty($fileContent)){
$partinfo['partnum']+=1;
$partinfo['iscomplete']=true;
file_put_contents($cachefile,$fileContent);
$re=self::upload($cachefile,$path,$filename,$partinfo);
if($re['error']) return $re;
if($partinfo['iscomplete']){
@unlink($cachefile);
return $re;
}
}
}
}
}
?>
Reference in New Issue View Git Blame Copy Permalink