<?php
if(!defined('IN_DZZ')) {
exit('Access Denied');
}
include_once(DZZ_ROOT.'./core/api/BaiduPCS/BaiduPCS.class.php');
@set_time_limit(0);
@ini_set('max_execution_time',0);
class io_baiduPCS extends io_api
{
const T ='connect_pan';
const BZ='baiduPCS';
private $icosdatas=array();
private $_root = '';
private $_rootname = '';
private $perm = 0;
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();
}
public function MoveToSpace($path,$attach,$ondup='overwrite'){
global $_G;
$filename=substr($path,strrpos($path,'/')+1);;
$fpath=substr($path,0,strrpos($path,'/'));
if(($re=$this->makeDir($fpath)) && $re['error']){ return $re;
}
$obz=io_remote::getBzByRemoteid($attach['remote']);
if($obz=='dzz'){
$opath='dzz::'.$attach['attachment'];
}else{
$opath=$obz.'/'.$attach['attachment'];
}
if($re=$this->multiUpload($opath,$fpath,$filename,$attach,$ondup)){
if($re['error']) return $re;
else{
return $re;
}
}
return false;
}
protected function makeDir($path){
$bzarr=$this->parsePath($path);
$patharr=explode('/',trim(preg_replace("/^".str_replace('/','\/',$this->_root)."/",'',$bzarr['path']),'/'));
$folderarr=array();
$p=$bzarr['bz'].$this->_root;
foreach($patharr as $value){
$p.='/'.$value;
if($re=$this->_makeDir($p)&& isset($re['error'])){
return $re;
}else{
continue;
}
}
return true;
}
protected function _makeDir($path){
global $_G;
$bzarr=self::parsePath($path);
try {
$pcs=self::init($path);
if(is_array($pcs) && $pcs['error']) return $pcs;
$response=$pcs->makeDirectory($bzarr['path']);
$result=json_decode($response,true);
if(intval($result['error_code'])==31061){
return true;
}elseif($result['error_code']){
return array('error'=>$result['error_msg'],'error_code'=>$result['error_code']);
}
return true;
}catch(Exception $e){
return array('error'=>$e->getMessage());
}
}
public function init($path,$isguest=0){
global $_G;
$bzarr=explode(':',$path);
$bd_uid=trim($bzarr[1]);
if($baidu=DB::fetch_first("select access_token,cloudname,cusername,uid from ".DB::table(self::T)." where id='{$bd_uid}'")){
if(!$isguest && $baidu['uid']>0 && $baidu['uid']!=$_G['uid']) return array('error'=>'need authorize to baiduPCS');
$access_token = $baidu['access_token'];
if($baidu['cloudname']){
$this->_rootname=$baidu['cloudname'];
}else{
$this->_rootname.=':'.$baidu['cusername'];
}
}else{
return array('error'=>'need authorize to baiduPCS');
}
return new BaiduPCS($access_token);
}
public function refresh_token($path){
require_once(DZZ_ROOT.'./core/api/BaiduPCS/BaiduOAuth2.php');
$bzarr=explode(':',$path);
$bd_uid=trim($bzarr[1]);
$cloud=DB::fetch_first("select `key` , `secret` from ".DB::table('connect')." where bz='baiduPCS'");
if($baidu=DB::fetch_first("select id,access_token,refresh_token from ".DB::table('connect_pan')." where id='{$bd_uid}'")){
$auth=new BaiduOAuth2($cloud['key'],$cloud['secret']);
if($token=$auth->getAccessTokenByRefreshToken($baidu['refresh_token'],$baidu['scope'])){
$token['refreshtime']=TIMESTAMP;
if($token['access_token']) C::t('connect_pan')->update($baidu['id'],$token);
return true;
}
}
return false;
}
public function getFolderDatasByPath($path){
$bzarr=self::parsePath($path);
$spath=$bzarr['path'];
if($this->_root){
$reg=str_replace('/','\/',$this->_root);
$spath=preg_replace("/^".$reg."/i",'',$spath);
}
$patharr=explode('/',$spath);
if(empty($patharr[0])) unset($patharr[0]);
$folderarr=array();
for($i=0;$i<=count($patharr);$i++){
$path1=$bzarr['bz'].$this->_root;
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;
}
public function authorize($refer){
global $_G,$_GET;
if(empty($_G['uid'])) {
dsetcookie('_refer', rawurlencode(BASESCRIPT.'?mod=connect&op=oauth&bz=baiduPCS'));
showmessage('to_login', '', array(), array('showmsg' => true, 'login' => 1));
}
require_once(DZZ_ROOT.'./core/api/BaiduPCS/BaiduOAuth2.php');
$cloud=DB::fetch_first("select `key` , `secret` from ".DB::table('connect')." where bz='baiduPCS'");
$auth=new BaiduOAuth2($cloud['key'],$cloud['secret']);
$auth->setRedirectUri($_G['siteurl'].'index.php?mod=connect&op=oauth&bz=baiduPCS');
if($_GET['code'] && (($state=authcode($_GET['state'],'DECODE'))==$cloud['key'] || $state=='in_admin_'.$cloud['key']) && $token=$auth->getAccessTokenByAuthorizationCode($_GET['code'])){
$token['refreshtime']=TIMESTAMP;
$token['uid']=strpos($state,'in_admin_')===0?0:$_G['uid'];
if($token['access_token'] && $userinfo= $auth->getLoggedInUser($token['access_token'])){
$token['cuid']=$userinfo['uid'];
$token['cusername']=$userinfo['uname'];
$token['portrait']=$userinfo['portrait'];
}
if($token['cuid']){
if($id=DB::result_first("select id from ".DB::table(self::T)." where uid='{$token[uid]}' and cuid='{$token[cuid]}' and bz='baiduPCS'")){
DB::update(self::T,$token,"id ='{$id}'");
}else{
$token['bz']='baiduPCS';
$token['dateline']=TIMESTAMP;
$id=DB::insert(self::T,$token,1);
}
if(strpos($state,'in_admin_')===0){ $setarr=array('name'=>lang('baidu_network_disk').':'.$token['cusername'],
'bz'=>'baiduPCS',
'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);
}
}
}
if(strpos($state,'in_admin_')===0){
$returnurl='admin.php?mod=cloud&op=space';
}else{
if(!$refer) $refer=DZZSCRIPT.'?mod=connect';
$returnurl=$refer;
}
@header('Location: '. $returnurl);
exit();
}
$clientid=$cloud['key'];
$state=authcode(defined('IN_ADMIN')?'in_admin_'.$clientid:$clientid,'ENCODE');
$authorizeurl=$auth->getAuthorizeUrl('code','basic netdisk',$state);
header('Location: ' . $authorizeurl);
}
public function parsePath($path){
$bzarr=explode(':',$path);
return array('bz'=>$bzarr[0].':'.$bzarr[1].':','path'=>$bzarr[2]);
}
function getM3U8Uri($path,$type='M3U8_854_480'){
$bzarr=self::parsePath($path);
$pcs=self::init($path,1);
if(is_array($pcs) && $pcs['error']) return $pcs;
return $pcs->streaming($bzarr['path'],$type);
}
function getStream($path){
$bzarr=self::parsePath($path);
$pcs=self::init($path,1);
if(is_array($pcs) && $pcs['error']) return $pcs;
try{
return $pcs->getStreamUri($bzarr['path']);
}catch(Exception $e){
return array('error'=>$e->getMessage());
}
}
function getFileUri($path){
$bzarr=self::parsePath($path,1);
$pcs=self::init($path,1);
if(is_array($pcs) && $pcs['error']) return $pcs;
try{
return $pcs->getStreamUri($bzarr['path']);
}catch(Exception $e){
return array('error'=>$e->getMessage());
}
}
public function deleteThumb($path){
global $_G;
$imgcachePath='./imgcache/';
$cachepath=str_replace(urlencode('/'),'/',urlencode(str_replace( 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(':','/',$path);
$cachepath=preg_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){
$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)){
return 1;
}else{
return 0;
}
}else{
$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 }
$bzarr=self::parsePath($path);
$pcs=self::init($path,1);
if(is_array($pcs) && $pcs['error']) return false;
$quality = 80;
$result = $pcs->thumbnail($bzarr['path'], $width, $height, $quality);
$targetpath = dirname($_G['setting']['attachurl'].'./'.$target);
dmkdir($targetpath);
@file_put_contents($_G['setting']['attachdir'].'./'.$target,$result);
return true;
}
public function getThumb($path,$width,$height,$original,$returnurl = false , $thumbtype = 1){
global $_G;
$imgcachePath='imgcache/';
$cachepath=str_replace(':','/',$path);
$cachepath=preg_replace("/\/+/",'/',str_replace(':','/',$path));
echo $path;
die;
$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){
$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);
}
}else{
$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']);
}
$bzarr=self::parsePath($path);
$pcs=self::init($path,1);
if(is_array($pcs) && $pcs['error']) return $pcs;
$result = $pcs->thumbnail($bzarr['path'], $width, $height,80);
$targetpath = dirname($_G['setting']['attachurl'].'./'.$target);
dmkdir($targetpath);
file_put_contents($_G['setting']['attachdir'].'./'.$target,$result);
if($returnurl) return $_G['setting']['attachurl'].'/'.$target;
$file=$_G['setting']['attachdir'].'./'.$target;
IO::output_thumb($imgurl);
}
public function setFileContent($path,$data){
$patharr=explode('/',$path);
$filename=$patharr[count($patharr)-1];
unset($patharr[count($patharr)-1]);
$path1=implode('/',$patharr);
$icoarr=self::upload($data,$path1,$filename,false,'overwrite');
if($icoarr['type']=='image'){
self::deleteThumb($path);
$icoarr['img'].='&t='.TIMESTAMP;
}
return $icoarr;
}
public function getQuota($bz) {
$pcs=self::init($bz,1);
if(is_array($pcs) && $pcs['error']) return $pcs;
return json_decode($pcs->getQuota(),true);
}
public function rename($path,$name) $arr=self::parsePath($path);
$patharr=explode('/',$arr['path']);
$arr['path1']='';
$ext=strtolower(substr(strrchr($arr['path'], '.'), 1));
foreach($patharr as $key =>$value){
if($key>=count($patharr)-1) break;
$arr['path1'].=$value.'/';
}
$arr['path1'].=$ext?(preg_replace("/\.\w+$/i",'.'.$ext,$name)):$name;
if($arr['path']!=$arr['path1']){
$pcs=self::init($path);
if(is_array($pcs) && $pcs['error']) return $pcs;
$response=$pcs->moveSingle($arr['path'],$arr['path1']);
$result=json_decode($response,true);
if($result['error_code']){
return array('error'=>$result['error_msg']);
}
}
return self::getMeta($arr['bz'].$arr['path1']);
}
public function CopyTo($opath,$path,$iscopy){
$oarr=self::parsePath($opath);
$arr=IO::parsePath($path);
try{
$pcs=self::init($opath);
if(is_array($pcs) && $pcs['error']) return $pcs;
if($arr['bz']==$oarr['bz'] && !$iscopy){ $data=self::getMeta($opath);
$response=$pcs->moveSingle($oarr['path'],$arr['path'].'/'.$data['name']);
$result=json_decode($response,true);
if($result['error_code']){
$data['success']=$result['error_msg'];
return $data;
}
$meta=$pcs->getMeta($arr['path'].'/'.$data['name']);
$meta=json_decode($meta,true);
$meta=$meta['list'][0];
$data['newdata']=self::_formatMeta($meta,$arr['bz']);
$data['success']=true;
return $data;
}else{
$data=self::getMeta($opath);
switch($data['type']){
case 'folder'://创建目录
if($re=IO::CreateFolder($path,$data['name'])){
if(isset($re['error']) && intval($re['error_code'])!=31061){
$data['success']=$re['error'];
}else{
$data['newdata']=$re['icoarr'];
$data['success']=true;
$contents=self::listFiles($opath);
foreach($contents as $key=>$value){
$data['contents'][$key]=self::CopyTo($value['path'],$re['folderarr']['path']);
}
}
}
break;
default:
if($re=IO::multiUpload($opath,$path,$data['name'])){
if($re['error']) $data['success']=$re['error'];
else{
$data['newdata']=$re;
$data['success']=true;
}
}
}
}
}catch(Exception $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; 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']);
}
if($size<$partsize){
if(!$handle=fopen($filepath, 'rb')){
return array('error'=>lang('open_file_error'));
}
while(!feof($handle)){
$fileContent.= fread($handle, 8192);
}
return self::upload($fileContent,$path,$filename,false,$ondup);
}else{ self::deleteCache($path.$filename);
if(!$handle=fopen($filepath, 'rb')){
return array('error'=>lang('open_file_error'));
}
$fileContent='';
while (!feof($handle)) {
$fileContent.= fread($handle, 8192);
if(strlen($fileContent)>=$partsize){
$re=self::upload($fileContent,$path,$filename,true,$ondup);
if($re['error']){
return $re;
}
$fileContent='';
}
}
fclose($handle);
if(!empty($fileContent)){
$re=self::upload($fileContent,$path,$filename,true,$ondup);
if($re['error']){
return $re;
}
}
return self::createSuperFile($path,$filename,$ondup);
}
}
function listFiles($path,$by='time',$order='desc',$limit='',$force=0){
global $_G,$_GET,$documentexts,$imageexts;
try{
$bzarr=self::parsePath($path);
$bz=$bzarr['bz'];
$path1=$bzarr['path'];
$pcs=self::init($path,1);
if(is_array($pcs) && $pcs['error']) return $pcs;
$data=array();
if($result = $pcs->listFiles($path1, $by, $order, $limit)){
$result=json_decode($result,true);
if($result['error_code']){
return array('error'=>$result['error_msg']);
}
else $data=$result['list'];
}
$icosdata=array();
foreach($data as $key => $value){
$icoarr=self::_formatMeta($value,$bz);
$icosdata[$icoarr['icoid']]=$icoarr;
}
return $icosdata;
}catch(Exception $e){
return array('error'=>$e->getMessage());
}
}
function getMeta($path,$force=0){
global $_G,$_GET,$documentexts,$imageexts;
$icosdata=array();
$bzarr=explode(':',$path);
$bz=$bzarr[0].':'.$bzarr[1].':';
$data=array();
$path1=$bzarr[2];
$pcs=self::init($bz,1);
if(is_array($pcs) && $pcs['error']) return $pcs;
$meta=$pcs->getMeta($path1);
$meta=json_decode($meta,true);
if($meta['error_msg']) return array('error'=>$meta['error_msg']);
$meta=$meta['list'][0];
$icosdata=self::_formatMeta($meta,$bz);
return $icosdata;
}
function _formatMeta($meta,$bz){
global $_G,$documentexts,$imageexts;
$root=$bz.$this->_root;
$icosdata=array();
$bzarr=explode(':',$bz);
if($meta['isdir']){
$icoarr=array(
'icoid'=>md5(($bz.$meta['path'])),
'path'=>$bz.$meta['path'],
'dpath'=>dzzencode($bz.$meta['path']),
'bz'=>($bz),
'gid'=>0,
'name'=>substr(strrchr($meta['path'], '/'), 1),
'username'=>$_G['username'],
'uid'=>$_G['uid'],
'oid'=>md5(($bz.$meta['path'])),
'img'=>'dzz/images/default/system/folder.png',
'type'=>'folder',
'ext'=>'',
'pfid'=>md5(str_replace(strrchr($meta['path'], '/'), '',$bz.$meta['path'])),
'size'=>0,
'dateline'=>intval($meta['mtime']),
'flag'=>''
);
if($icoarr['path']==$root){
$icoarr['name']=$this->_rootname;
$icoarr['flag']=self::BZ;
$icoarr['pfid']=0;
}
$icoarr['fsize']=formatsize($icoarr['size']);
$icoarr['ftype']=getFileTypeName($icoarr['type'],$icoarr['ext']);
$icoarr['fdateline']=dgmdate($icoarr['dateline']);
$icosdata=$icoarr;
}else{
$ext=strtoupper(substr(strrchr($meta['path'], '.'), 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($bz.$meta['path']);
$url=$_G['siteurl'].DZZSCRIPT.'?mod=io&op=thumbnail&size=large&path='.dzzencode($bz.$meta['path']);
}else{
$img=geticonfromext($ext,$type);
$url=$_G['siteurl'].DZZSCRIPT.'?mod=io&op=getStream&path='.rawurlencode($bz.$meta['path']);
}
$icoarr=array(
'icoid'=>md5(($bz.$meta['path'])),
'path'=>($bz.$meta['path']),
'dpath'=>dzzencode($bz.$meta['path']),
'bz'=>($bz),
'gid'=>0,
'name'=>substr(strrchr($meta['path'], '/'), 1),
'username'=>$_G['username'],
'uid'=>$_G['uid'],
'oid'=>md5(($bz.$meta['path'])),
'img'=>$img,
'url'=>$url,
'type'=>$type,
'ext'=>strtolower($ext),
'pfid'=>md5(str_replace(strrchr($meta['path'], '/'), '',$bz.$meta['path'])),
'size'=>$meta['size'],
'dateline'=>intval($meta['mtime']),
'flag'=>''
);
$icoarr['fsize']=formatsize($icoarr['size']);
$icoarr['ftype']=getFileTypeName($icoarr['type'],$icoarr['ext']);
$icoarr['fdateline']=dgmdate($icoarr['dateline']);
$icosdata=$icoarr;
}
return $icosdata;
}
function getFolderByIcosdata($icosdata){
global $_GET;
$folder=array();
if($icosdata['type']=='folder'){
$folder=array('fid'=>$icosdata['oid'],
'path'=>$icosdata['path'],
'fname'=>$icosdata['name'],
'uid'=>$icosdata['uid'],
'pfid'=>$icoadata['pfid'],
'iconview'=>$_GET['iconview']?intval($_GET['iconview']):1,
'disp'=>$_GET['disp']?intval($_GET['disp']):1,
'perm'=>$this->perm,
'hash'=>$icosdata['hash'],
'bz'=>$icosdata['bz'],
'gid'=>$icosdata['gid'],
'fsperm'=>perm_FolderSPerm::flagPower('baiduPCS')
);
}
return $folder;
}
function getFileContent($path){
$bzarr=explode(':',$path);
$bz=$bzarr[0].':'.$bzarr[1].';';
$path1=$bzarr[2];
try{
$pcs=self::init($bz,1);
if(is_array($pcs) && $pcs['error']) return $pcs;
return $pcs->download($path1);
}catch(Exception $e){
return $e->getMessage();
}
}
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);
$zip->finalize();
}
public function getFolderInfo($paths,$position='',&$zip){
static $data=array();
try{
foreach($paths as $path){
$arr=IO::parsePath($path);
$pcs=self::init($path,1);
if(is_array($pcs) && $pcs['error']) return $pcs;
$meta=self::getMeta($path);
switch($meta['type']){
case 'folder':
$lposition=$position.$meta['name'].'/';
$contents=self::listFiles($path);
$arr=array();
foreach($contents as $key=>$value){
$arr[]=$value['path'];
}
if($arr) self::getFolderInfo($arr,$lposition,$zip);
break;
default:
$meta['url']=self::getStream($meta['path']);
$meta['position']=$position.$meta['name'];
$zip->addLargeFile(fopen($meta['url'],'rb'), $meta['position'], $meta['dateline']);
}
}
}catch(Exception $e){
$data['error']=$e->getMessage();
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);
$url=self::getStream($path);
try {
$file=self::getMeta($path);
if($file['type']=='folder') self::zipdownload($path);
exit();
}else @header("Location: $url");
exit();
}
$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');
@readfile($url);
@flush(); @ob_flush();
exit();
} catch (Exception $e) {
topshowmessage($e->getMessage());
}
}
function upload_by_content($fileContent,$path,$filename,$isCreateSuperFile=false,$ondup='newcopy'){
return self::upload($fileContent,$path,$filename,$isCreateSuperFile,$ondup);
}
function upload($fileContent,$path,$filename,$isCreateSuperFile=false,$ondup='newcopy'){
global $_G;
$bzarr=explode(':',($path));
$bz=$bzarr[0].':'.$bzarr[1].':';
$path=$bzarr[2].'/';
try{
$pcs=self::init($bz);
if(is_array($pcs) && $pcs['error']) return $pcs;
$response = $pcs->upload($fileContent, $path, $filename,null,$isCreateSuperFile,$ondup);
unset($fileContent);
$response=json_decode($response,true);
if($response['error_msg']){
return array('error'=>$response['error_msg']);
}
if($isCreateSuperFile===true){
$path0=$bz.$path.$filename;
if($response['md5']){
self::saveCache($path0,$response['md5']);
return true;
}else{
return array('error'=>' part upload error');
}
}else{
$icoarr=self::_formatMeta($response,$bz);
return $icoarr;
}
}catch(Exception $e){
return array('error'=>$e->getMessage());
}
}
function createSuperFile($path,$filename,$ondup='newcopy'){
global $_G;
$bzarr=explode(':',($path));
$bz=$bzarr[0].':'.$bzarr[1].':';
$path=$bzarr[2].'/';
try{
$pcs=self::init($bz);
if(is_array($pcs) && $pcs['error']) return $pcs;
$path0=$bz.$path.$filename;
if(!($params=array_values(self::getCache($path0)))){
return array('error'=>lang('file_merge_error'));
}
$response = $pcs->createSuperFile($path, $filename,$params,null,$ondup);
$response=json_decode($response,true);
if($response['error_msg']){
return array('error'=>$response['error_msg']);
}
self::deleteCache($path0);
$icoarr=self::_formatMeta($response,$bz);
return $icoarr;
}catch(Exception $e){
return array('error'=>$e->getMessage());
}
}
public function Delete($path,$force=false){
$bzarr=explode(':',($path));
$bz=$bzarr[0].':'.$bzarr[1].':';
$path1=$bzarr[2];
try{
$pcs=self::init($bz,$force);
if(is_array($pcs) && $pcs['error']) return $pcs;
$response = $pcs->deleteSingle($path1);
$response=json_decode($response,true);
if($response['error_msg']){
return array('icoid'=>md5(($path)),'error'=>$response['error_msg']);
}
return array('icoid'=>md5(($path)),
'name'=>substr(strrchr($path, '/'), 1),
);
}catch(Exception $e){
return array('icoid'=>md5($path),'error'=>$e->getMessage());
}
}
public function createFolderByPath($path, $pfid = '',$noperm = false)
{
$data = array();
if(self::makeDir($path)){
$data = self::getMeta($path);
}
return $data;
}
public function CreateFolder($path,$fname){
global $_G;
$bzarr=explode(':',($path));
$bz=$bzarr[0].':'.$bzarr[1].':';
$path1=$bzarr[2].'/'.$fname;
$return=array();
try {
$pcs=self::init($bz);
if(is_array($pcs) && $pcs['error']) return $pcs;
$response=$pcs->makeDirectory($path1);
$result=json_decode($response,true);
if($result['error_code']){
$icoarr=self::getMeta($path1);
$folderarr=self::getFolderByIcosdata($path1);
return array('error'=>$result['error_msg'],'error_code'=>$result['error_code'],'icoarr'=>$icoarr,'folderarr'=>$folderarr);
}
$result['isdir']=1;
$icoarr=self::_formatMeta($result,$bz);
$folderarr=self::getFolderByIcosdata($icoarr);
$return= array('folderarr'=>$folderarr,'icoarr'=>$icoarr);
}catch(Exception $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 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;
}
private function getCache($path){
$cachekey='baidu_upload_'.md5($path);
$cache=C::t('cache')->fetch($cachekey);
return (unserialize($cache['cachevalue']));
}
private function saveCache($path,$str){
global $_G;
$cachekey='baidu_upload_'.md5($path);
$cachevalue=self::getCache($path);
$cachevalue[$str]=$str;
C::t('cache')->insert(array(
'cachekey' => $cachekey,
'cachevalue' => serialize($cachevalue),
'dateline' => $_G['timestamp'],
), false, true);
}
private function deleteCache($path){
$cachekey='baidu_upload_'.md5($path);
C::t('cache')->delete($cachekey);
}
public function uploadStream($file,$filename,$path,$relativePath,$content_range){
$data=array();
$arr=self::getPartInfo($content_range);
if($relativePath && ($arr['iscomplete'])){
$path1=$path;
$patharr=explode('/',$relativePath);
foreach($patharr as $key=> $value){
if(!$value){
unset($patharr[$key]);
continue;
}
if($patharr[$key-1]) $path1.='/'.$patharr[$key-1];
$re=self::CreateFolder($path1,$value);
if(intval($re['error_code'])==31061){
continue;
}else{
if(isset($re['error'])){
return $re;
}else{
if($key==0){
$data['icoarr'][]=$re['icoarr'];
$data['folderarr'][]=$re['folderarr'];
}
}
}
}
}
if($relativePath) $path=$path.'/'.$relativePath;
$fileContent='';
if(!$handle=fopen($file, 'rb')){
return array('error'=>lang('open_file_error'));
}
while (!feof($handle)) {
$fileContent .= fread($handle, 8192);
}
fclose($handle);
if($arr['ispart']){
if($re1=self::upload($fileContent,$path,$filename,true)){
if($re1['error']){
return $re1;
}
if($arr['iscomplete']){
$re1=self::createSuperFile($path, $filename);
if(empty($re1['error'])){
$data['icoarr'][] = $re1;
return $data;
}else{
$data['error'] = $re1['error'];
return $data;
}
}else{
return true;
}
}
}else{
$re1=self::upload($fileContent,$path,$filename);
if(empty($re1['error'])){
$data['icoarr'][] = $re1;
return $data;
}else{
$data['error'] = $re1['error'];
return $data;
}
}
}
}
?>