he/DzzOffice
1
0
Fork 0
mirror of https://github.com/DzzXH/DzzOffice.git synced 2026-04-07 07:56:43 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity
Files
46deb899fc0ce2fc8acbba6735d3d62db02baacf
DzzOffice/core/class/io/io_ALIOSS.php

1427 lines
45 KiB
PHP
Raw Normal View History

发布小胡版V1.61
2022-11-02 23:21:46 +08:00
<?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');
}
}
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 Copy Permalink