\dzz_io

<?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');
}



class dzz_io
{
	protected function initIO($path){
		$path=self::clean($path);
		$bzarr=explode(':',$path);
		$allowbz=C::t('connect')->fetch_all_bz();//array('baiduPCS','ALIOSS','dzz','JSS','disk');
		if(strpos($path,'dzz::')!==false){
			$classname= 'io_dzz';
		}elseif(strpos($path,'attach::')!==false){
			$classname= 'io_dzz';
		}elseif(strpos($path,'TMP::')!==false){
			$classname= 'io_dzz';
		}elseif(is_numeric($bzarr[0])){
			$classname= 'io_dzz';
		}elseif(in_array($bzarr[0],$allowbz)){
			$classname= 'io_'.$bzarr[0];
		}elseif(preg_match('/\w{32}/i',$path)){
			$classname = 'io_dzz';
		}else{
			return false;
		}

		return new $classname($path);
	}
	function MoveToSpace($path,$attach,$ondup='overwrite'){
		$path=self::clean($path);
		if($io=self::initIO($path)){
			return $io->MoveToSpace($path,$attach,$ondup);
		}else{
			return false;
		}
	}
	function authorize($bz,$refer=''){
		if($io=self::initIO($bz)){
			$io->authorize($refer);
		}
	}
	function getQuota($bz){
		if($io=self::initIO($bz)){
			return $io->getQuota($bz);
		}else{
			return false;
		}
	}
	function chmod($path,$chmod,$son=0){
		if($io=self::initIO($path)){
			return $io->chmod($path,$chmod,$son);
		}else{
			return false;
		}
	}
	function parsePath($path){
		$path=self::clean($path);
		if($io=self::initIO($path)){
			return $io->parsePath($path);
		}else{
			return false;
		}
	}
	function output_thumb($file,$mine='image/JPEG'){//根据文件地址，输出图像流
		global $_G;
		$last_modified_time = filemtime($file);
		if($last_modified_time){
            $etag = md5_file($file);
            header("Last-Modified: " . gmdate("D, d M Y H:i:s", $last_modified_time) . " GMT");
            header("Etag: $etag");
            if (@strtotime($_SERVER['HTTP_IF_MODIFIED_SINCE']) == $last_modified_time ||
                trim($_SERVER['HTTP_IF_NONE_MATCH']) == $etag
            ) {
                header("HTTP/1.1 304 Not Modified");
                exit;
            }
		}
		/*if(!$last_modified_time) $last_modified_time = TIMESTAMP;*/
		@header('cache-control:public');
		header('Content-Type: '.$mine);
		@ob_end_clean();
		if (getglobal('gzipcompress')) @ob_start('ob_gzhandler');
		@readfile($file);
		@flush();
		@ob_flush();
		exit();
	}
	//获取缩略图
	function getThumb($path,$width,$height,$original,$returnurl=false,$thumbtype = 1){
		$path=self::clean($path);
		if($io=self::initIO($path)) return $io->getThumb($path,$width,$height,$original,$returnurl,$thumbtype);
	}
	/*
	 *通过icosdata获取folderdata数据	
	*/
	function getFolderByIcosdata($icosdata){ 
		if($io=self::initIO($icosdata['path']))	return $io->getFolderByIcosdata($icosdata);
		else return false;
	}
	//获取icosdata数组；
	//$path: 路径
	//$force==1时不使用api的缓存数据，强制重新获取api数据；
	//$bz==''是表示获取的是本地；此时path为icoid；
	function getMeta($path,$force=0){
		$path=self::clean($path);
		if($io=self::initIO($path))	return $io->getMeta($path,$force);
		else return false;
	}
	//重命名文件
	function rename($path,$newname){ 
		$path=self::clean($path);
		$newname=self::name_filter($newname);
		if($io=self::initIO($path)){
            $return =  $io->rename($path,$newname);
            Hook::listen('renameafter_updateindex',$return);
            return $return;
		}
		else return false;
	}
	
	
	//根据路径获取目录树的数据；
	function getFolderDatasByPath($path){ 
		$path=self::clean($path);
		if($io=self::initIO($path))	return $io->getFolderDatasByPath($path);
		else return false;
	}
	
	
	//获取文件流；
	//$path: 路径
	public function getStream($path,$fop=0){
		$path=self::clean($path);
		$io=self::initIO($path);
		if($io)	return $io->getStream($path,$fop);
		else return $path;
	}
	//获取文件地址；
	//$path: 路径
	function getFileUri($path,$fop=0){ 
		$path=self::clean($path);
		if($io=self::initIO($path))	return $io->getFileUri($path,$fop);
		else return $path;
	}
	
	/**
	 * 获取指定文件夹下的文件列表
	 * @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',$order='DESC',$limit='',$force=0){  
		$path=self::clean($path);
		if($io=self::initIO($path))	return $io->listFiles($path,$by,$order,$limit,$force);
		else return false;
	}
	
	//目标位置新建内容
	//$path:原路径
	//$container:目标位置；
	//$tbz:目标api；
	//返回：
	//$icosdata数组；
	function CopyTo($opath,$path,$iscopy=0,$force=0){
		$path=self::clean($path);
		$opath=self::clean($opath);
		if($io=self::initIO($opath)) return $io->CopyTo($opath,$path,$iscopy,$force);
		else return false;
	}

	/**
	 * 删除指定的元素
	 * @param string $opath 被移动的文件路径
	 * @param string $path 目标位置（可能是同一api内或跨api，这两种情况分开处理）
	 * @return icosdatas
	 */
	public function DeleteByData($data,$force = false){
		$havesubitem=0;
		if(isset($data['contents'])){
			foreach($data['contents'] as $key => $value){
				$return=self::DeleteByData($value);
				if(intval($return['delete'])<1) {
					$havesubitem=1;
				}
				$data['contents'][$key]=$return;
			}
		}
		if($data['success']===true && !$havesubitem){
			
			if($data['icoid']==$data['newdata']['icoid']){
				$data['newdata']['move']=1;
			}else{
				$arr=IO::Delete($data['path']);
				if($arr['icoid']) $data['delete']=1;
				else $data['success']=$arr['error'];
			}
		}
		return $data;
	}
	
	//添加目录
	//$fname：目录名称;
	//$path：目录位置路径，如果是本地，$path 为pfid
	function CreateFolder($path,$fname,$perm=0,$params=array(),$ondup='newcopy',$force=false){
		$path=self::clean($path);//11
		$fname=self::name_filter($fname);
		if($io=self::initIO($path))	return $io->CreateFolder($path,$fname,$perm,$params,$ondup,$force);
		else return false;
	}
	//添加多层目录
	//$fid：父级目录id;
	//$path：目录位置路径，如aaa/bbb/ccc
	function CreateFolderByPath($path,$fid,$bz='dzz',$params=array()){
		$path=self::clean($path);
		if($io=self::initIO($bz))	{
			return $io->CreateFolderByPath($path,$fid,$params);
		}
		else return false;
	}
	/*将文件缓存到本地,并且返回本地的访问地址*/
	function cacheFile($data){
		global $_G;
		$subdir = $subdir1 = $subdir2 = '';
		$subdir1 = date('Ym');
		$subdir2 = date('d');
		$subdir = $subdir1.'/'.$subdir2.'/';
		$target1='dzzcache/'.$subdir.'index.html';
		$target='dzzcache/'.$subdir.random(10);
		$target_attach=$_G['setting']['attachdir'].$target1;
		$targetpath = dirname($target_attach);
		dmkdir($targetpath);
		if(file_put_contents($target,$data)){
			return $target;
		}else{
			return false;
		}
	}
	
	//获取文件数据
	//$data：文件的信息数组 
	//返回我文件data；
	function getFileContent($path){
		$path=self::clean($path);
		if($io=self::initIO($path))	return $io->getFileContent($path);
		else return false;
	}
	//覆盖文件内容
	//$data：文件的信息数组 
	//返回我文件data；
	function setFileContent($path,$data,$force=false,$nocover = true){
		$path=self::clean($path);
		if($io=self::initIO($path))	{
		    if($data = $io->setFileContent($path,$data,$force,$nocover)){
		    	$filedata = $data;
                \Hook::listen('setfilecontent_after', $filedata);
                return $data;
			}else{
                return false;
			}

		}
		else return false;
	}
	
	//分片上传文件；
	//$path: 路径
	function multiUpload($file,$path,$filename,$attach=array(),$ondup="newcopy"){
		$path=self::clean($path);
		$filename=self::name_filter($filename);
		if($io=self::initIO($path))	return $io->multiUpload($file,$path,$filename,$attach,$ondup);
		else return false;
	}
	
	//添加文件
	//$fileContent：源文件数据;
	//$container：目标位置;
	//$bz：api;
	function upload($fileContent,$path,$filename){
		$path=self::clean($path);
		$filename=self::name_filter($filename);
		if($io=self::initIO($path)){
            $return = $io->upload($fileContent,$path,$filename);
            Hook::listen('createafter_addindex',$return);
            return $return;
		}
		else return false;
	}
	
	function upload_by_content($fileContent,$path,$filename,$partinfo=array()){
		$path=self::clean($path);
		$filename=self::name_filter($filename);
		if($io=self::initIO($path)){
            $return =  $io->upload_by_content($fileContent,$path,$filename,$partinfo);
            Hook::listen('createafter_addindex',$return);
            return $return;
		}
		else return false;
	}
	
	public function uploadStream($file,$name,$path,$relativePath='',$content_range=''){
	  	$path=self::clean(urldecode($path));
		$name=self::name_filter(urldecode($name));
	  	$relativePath=self::clean(urldecode($relativePath));
	 	if($io=self::initIO($path)) {
            $return=$io->uploadStream($file,$name,$path,$relativePath,$content_range);
            Hook::listen('createafter_addindex',$return['icoarr'][0]);
            return $return;
		}
	 	else return false;
  }
	
	function Delete($path,$force=false){
		$path=self::clean($path);
		if($io=self::initIO($path))	{
			$return =  $io->Delete($path,$force);
			Hook::listen("deleteafter_delindex",$return);
			return $return;
		}
		else return false;
	}
	//恢复文件
	function Recover($path,$combine=true,$force=false){
		$path=self::clean($path);
		if($io=self::initIO($path))	{
			return $io->Recover($path,$combine,$force);
		}
		else return false;
	}
	
 //获取不重复的目录名称
  public function getFolderName($fname,$path){
	  $path=self::clean($path);
	  $fname=self::name_filter($fname);
	  if($io=self::initIO($path))	  return $io->getFolderName($fname,$path);
	  else return false;
  }
  
 
  public function download($paths,$filename='',$checkperm = true){
  		 $paths = (array)$paths;
		 $paths=self::clean($paths);
		 if($io=self::initIO($paths[0]))  $io->download($paths,$filename,$checkperm);
		 else return false;
	 }
	 
	public function getCloud($bz){
		$bzarr=explode(':',$bz);
		$cloud=DB::fetch_first("select * from ".DB::table('connect')." where bz='{$bzarr[0]}'");
		if($cloud['type']=='pan'){
			$root=DB::fetch_first("select * from ".DB::table($cloud['dname'])." where  id='{$bzarr[1]}'");
			if(!$root['cloudname']) $root['cloudname']=$cloud['name'].':'.($root['cusername']?$root['cusername']:$root['cuid']);
		}elseif($cloud['type']=='storage'){
			$root=DB::fetch_first("select * from ".DB::table($cloud['dname'])." where id='{$bzarr[1]}'");
			$root['access_id']=authcode($root['access_id'],'DECODE',$root['bz']);
			if(!$root['cloudname']) $root['cloudname']=$cloud['name'].':'.($root['bucket']?$root['bucket']:cutstr($root['access_id'], 4, $dot = ''));
		}elseif($cloud['type']=='ftp'){
			$root=DB::fetch_first("select * from ".DB::table($cloud['dname'])." where id='{$bzarr[1]}'");
		}elseif($cloud['type']=='disk'){
			$root=DB::fetch_first("select * from ".DB::table($cloud['dname'])." where id='{$bzarr[1]}'");
		}else{
			$root=DB::fetch_first("select * from ".DB::table($cloud['dname'])." where id='{$bzarr[1]}'");
		}
		$root['cloudtype']=$cloud['type'];
		return $root;
	}
	
	public function clean($str) {//清除路径
		if(is_array($str)){
			foreach($str as $key=> $value){
				$str[$key]=str_replace(array( "\n", "\r", '../'), '', $value);
			}
		}else{
			$str= str_replace(array( "\n", "\r", '../'), '', $str);
		}
		return $str;
	}
	public function name_filter($name){
		return str_replace(array('/','\\',':','*','?','<','>','|','"',"\n"),'',$name);
	}
	public function saveToAttachment($file_path,$filename,$tospace=1,$width=256,$height=256) {
        $md5=md5_file($file_path);
		$filesize=filesize($file_path);
		if($md5 && $attach=DB::fetch_first("select * from %t where md5=%s and filesize=%d",array('attachment',$md5,$filesize))){
			$attach['filename']=$filename;
			$pathinfo = pathinfo($filename);
			$ext = $pathinfo['extension']?$pathinfo['extension']:'';
			$attach['filetype']=$ext;
			if(in_array(strtolower($attach['filetype']),array('png','jpeg','jpg','gif','bmp'))){
				$attach['img']=C::t('attachment')->getThumbByAid($attach,$width,$height);
				$attach['isimage']=1;
			}else{
				//$attach['img']=geticonfromext($ext);
				$attach['isimage']=0;
			}
			//$attach['ffilesize']=formatsize($tattach['filesize']);
			@unlink($file_path);
			return $attach;
		}else{
			$target=self::getPath($filename);
			$pathinfo = pathinfo($filename);
			$ext = $pathinfo['extension']?$pathinfo['extension']:'';
			if($ext && in_array(strtolower($ext) ,getglobal('setting/unRunExts'))){
				$unrun=1;
			}else{
				$unrun=0;
			}
			$filepath=getglobal('setting/attachdir').$target;
			$handle=fopen($file_path, 'r');
			$handle1=fopen($filepath,'w');
			while (!feof($handle)) {
			   fwrite($handle1,fread($handle, 8192));
			}
			fclose($handle);
			fclose($handle1);
			@unlink($file_path);
			
			$filesize=filesize($filepath);
			$remote=0;
			
        	$attach=array(
			
				'filesize'=>$filesize,
				'attachment'=>$target,
				'filetype'=>strtolower($ext),
				'filename' =>$filename,
				'remote'=>$remote,
				'copys' => 0,
				'md5'=>$md5,
				'unrun'=>$unrun,
				'dateline' => $_G['timestamp'],
			);
			
			if($attach['aid']=C::t('attachment')->insert($attach,1)){
				C::t('local_storage')->update_usesize_by_remoteid($attach['remote'],$attach['filesize']);
				if($tospace) dfsockopen(getglobal('siteurl').'misc.php?mod=movetospace&aid='.$attach['aid'].'&remoteid=0',0, '', '', FALSE, '',1);
				if(in_array(strtolower($attach['filetype']),array('png','jpeg','jpg','gif','bmp'))){
					$attach['img']=C::t('attachment')->getThumbByAid($attach['aid'],$this->options['thumbnail']['max-width'],$this->options['thumbnail']['max-height']);
					$attach['isimage']=1;
				}else{
					$attach['img']=geticonfromext($ext);
					$attach['isimage']=0;
				}
				//$attach['ffilesize']=formatsize($tattach['filesize']);
				return $attach;
			}else{
				return false;
			}
		}
    }
	public function getPath($filename,$dir='dzz'){
			$pathinfo = pathinfo($filename);
			$ext = $pathinfo['extension']?($pathinfo['extension']):'';
			if($ext && in_array(strtolower($ext) ,getglobal('setting/unRunExts'))){
				$ext='dzz';
			}
		    $subdir = $subdir1 = $subdir2 = '';
			$subdir1 = date('Ym');
			$subdir2 = date('d');
			$subdir = $subdir1.'/'.$subdir2.'/';
			$target1=$dir.'/'.$subdir.'index.html';
			$target=$dir.'/'.$subdir;
			$target_attach=getglobal('setting/attachdir').$target1;
			$targetpath = dirname($target_attach);
			dmkdir($targetpath);
			return $target.date('His').''.strtolower(random(16)).'.'.$ext;
	 }
}
?>