<?php


function ReadFileContent($filepath){
	$htmlfp=@fopen($filepath,"r");
	while($data=@fread($htmlfp,1000)){
		$string.=$data;
	}
	@fclose($htmlfp);
	return $string;
}

function WriteString2File($filepath,$string){
	global $filechmod;
	$fp=@fopen($filepath,"w");
	@fputs($fp,$string);
	@fclose($fp);
	if(empty($filechmod)){
		@chmod($filepath,0777);
	}
}

function DoMkdir($path){
	global $public_r;

	if(!file_exists($path)){

		if($public_r[phpmode]){
			$pr[0]=$path;
			FtpMkdir($ftpid,$pr);
			$mk=1;
		}else{
			$mk=@mkdir($path,0777);
		}
		@chmod($path,0777);
		if(empty($mk)){
			
		}
	}
	return true;
}


function ToChangeUseTime($time){
	global $fun_r;
	$usetime=time()-$time;
	if($usetime<60){
		$tstr=$usetime.'秒';
	}else{
		$usetime=round($usetime/60);
		$tstr=$usetime.'分';
	}
	return $tstr;
}

function BackupDatabaseInit($add){
	global $db,$fun_r,$phpyun_db_ver,$config,$adminDir;
    $res=$db->query("select VERSION()");
    $row=$db->fetch_row($res);
    $phpyun_db_ver=$row[0];
	$dbname=$add['mydbname'];
    $bakpath=$add['backuppath'];
	
	$tablename=$add['tablename'];

	$count=count($tablename);

	if($count == 1){
		if (!preg_match('/^[_a-z]{2,30}$/i',$add['tablename'][0])){
			return false;
		}
	}
	if(empty($count)){
		
	}
	$add['baktype']=(int)$add['baktype'];
	$add['filesize']=(int)$add['filesize'];
	$add['bakline']=(int)$add['bakline'];
	$add['autoauf']=(int)$add['autoauf'];
	
	if($count > 1){		
		if(empty($add['mypath'])){
			$salt = substr(uniqid(rand()), -6);
			$add['mypath']=$dbname."_".md5(date("YmdHis").$salt);
		}
	}else{		
		if(empty($add['mypath'])){
			$add['mypath']=$dbname."_".$add['tablename'][0]."_".date("YmdHis");
		}
	}
	
    DoMkdir($bakpath."/".$add['mypath']);
	
	$readme=$add['readme'];
	$rfile=$bakpath."/".$add['mypath']."/readme.txt";
	$readme.="\r\n\r\nBaktime: ".date("Y-m-d H:i:s");
	WriteString2File($rfile,$readme);
	$b_table="";
	$d_table="";
	for($i=0;$i<$count;$i++){
		$b_table.=$tablename[$i].",";
		$d_table.="\$tb[".$tablename[$i]."]=0;\r\n";
    }
	
	$b_table=substr($b_table,0,strlen($b_table)-1);
	$bakstru=(int)$add['bakstru'];
	$bakstrufour=(int)$add['bakstrufour'];
	$beover=(int)$add['beover'];
	$waitbaktime=(int)$add['waitbaktime'];
	$bakdatatype=(int)$add['bakdatatype'];
	if($add['insertf']=='insert'){
		$insertf='insert';
	}else{
		$insertf='replace';
	}
	if($phpyun_db_ver=='4.0'&&$add['dbchar']=='auto'){
		$add['dbchar']='';
	}
	$string="<?php
	\$b_table=\"".$b_table."\";
	".$d_table."
	\$b_baktype=".$add['baktype'].";
	\$b_filesize=".$add['filesize'].";
	\$b_bakline=".$add['bakline'].";
	\$b_autoauf=".$add['autoauf'].";
	\$b_dbname=\"".$dbname."\";
	\$b_stru=".$bakstru.";
    \$b_version=\"".$phpyun_db_ver."\";
    \$b_time=\"".time()."\";
	\$b_strufour=".$bakstrufour.";
	\$b_dbchar=\"".addslashes($add['dbchar'])."\";
	\$b_beover=".$beover.";
	\$b_insertf=\"".addslashes($insertf)."\";
	\$b_autofield=\",".addslashes($add['autofield']).",\";
	\$b_bakdatatype=".$bakdatatype.";
	?>";
	$cfile=$bakpath."/".$add['mypath']."/config.php";
	WriteString2File($cfile,$string);
	if($add['baktype']){
		$phome='BackupDatabaseRecordNum';
	}else{
		$phome='BackupDatabaseFileSize';
	}
	$data=array(
			'c'=>$phome,
			't'=>0,
			's'=>0,
			'p'=>0,
			'mypath'=>$add[mypath],
			'waitbaktime'=>$waitbaktime
	);
	echo json_encode($data);
	
	exit();
}

function SetCharset($Charset){
	global $db;
	if($Charset&&$Charset!='auto'){
		$db->query('set character_set_connection='.$Charset.',character_set_results='.$Charset.',character_set_client=binary;');
	}
}

function BackupDatabaseFileSize($t,$s,$p,$mypath,$alltotal,$thenof,$fnum,$stime=0){	
	global $db,$bakpath,$limittype,$fun_r,$db_config,$config,$adminDir;
  
    ob_start();
	if(empty($mypath)){
    
	}
    $b_dbname=$db_config['dbname'];
	$path=PLUS_PATH.'/bdata/'.$mypath;
	@include($path."/config.php");
	if(empty($b_table)){
	
	}
	$waitbaktime=(int)$_GET['waitbaktime'];
	if(empty($stime)){
		$stime=time();
	}
	$header="<?php
		require(dirname(dirname(dirname(dirname(dirname(__FILE__))))).\"/app/include/dbbackup/inc/header.php\");
	";
	$footer="
		require(dirname(dirname(dirname(dirname(dirname(__FILE__))))).\"/app/include/dbbackup/inc/footer.php\");
	?>";
	$btb=explode(",",$b_table);
	$count=count($btb);
	$t=(int)$t;
	$s=(int)$s;
	$p=(int)$p;

	$data['bt']=$t;
	if($t>=$count){
		$data['msg']="备份成功！<br>整个过程耗时：".ToChangeUseTime($stime);
		echo json_encode($data);
		
		die;
    }
	
	$u=$db->query("use `$b_dbname`");
	
	SetCharset($b_dbchar);
	
	$status_r=GetTableRows($b_dbname,$btb[$t]);
	$num=$status_r['Rows'];
	$allnum = $status_r['Rows'];
	
	//增加控制 每个文件最多存储5000条信息 防止内存溢出
	$maxLimit = 5000;
	if($num>=$maxLimit){
		$num = $maxLimit;
	}
	$dumpsql = '';
	if(empty($p)){
		$dumpsql.=GetTableStructSql($btb[$t],$b_strufour);
	}
	$sql=$db->select_only($btb[$t],'1 limit '.$s.','.$num);
	
	if(empty($fnum)){
		$return_fr=GetTableFields($b_dbname,$btb[$t],$b_autofield);
		$fieldnum=$return_fr['num'];
		$noautof=$return_fr['autof'];
	}else{
		$fieldnum=$fnum;
		$noautof=$thenof;
	}
	
	$inf='';
	if($b_beover==1){
		$inf='('.GetTableInsertFields($b_dbname,$btb[$t]).')';
	}
	
	$hexf='';
	if($b_bakdatatype==1){
		$hexf=GetTableStringFields($b_dbname,$btb[$t]);
	}
	$b=0;
	foreach($sql as $k=>$r){
		
        ob_flush();
        flush();  
       
		$b=1;
		$s++;

		$dumpsql.="ExcuteSQL(\"insert into `".$btb[$t]."`".$inf." values(";
		$first=1;
		for($i=0;$i<$fieldnum;$i++){
			
			if(empty($first)){
				$dumpsql.=',';
			}else{
				$first=0;
			}
			$myi=$i+1;
			
			if(!isset($r[$i])||strstr($noautof,','.$myi.',')){
				$dumpsql.='NULL';
			}else{
				$dumpsql.=GetFieldContent($r[$i],$b_bakdatatype,$myi,$hexf);
			}
		}
		$dumpsql.=");\");\r\n";
		
		if(strlen($dumpsql)>=$b_filesize*1024 || (($k+1)>=$maxLimit && $s<$allnum)){
			$p++;
			$sfile=$path."/".$btb[$t]."_".$p.".php";
			$dumpsql=$header.$dumpsql.$footer;
			WriteString2File($sfile,$dumpsql);
			$db->free($sql);
			
			$data=array(
					'c'=>'BackupDatabaseFileSize',
					'phome'=>'BakExe',
					't'=>$t,
					's'=>$s,
					'p'=>$p,
					'mypath'=>$mypath,
					'alltotal'=>$num,
					'thenof'=>$noautof,
					'fieldnum'=>$fieldnum,
					'stime'=>$stime,
					'waitbaktime'=>$waitbaktime,
					'collation'=>$collation
			);
			echo json_encode($data);die;
			
		}
	}
	
	if(empty($p)||$b==1){
		$p++;
		$sfile=$path."/".$btb[$t]."_".$p.".php";
		$dumpsql=$header.$dumpsql.$footer;
		WriteString2File($sfile,$dumpsql);
	}
	FetchFileNumber($p,$btb[$t],$path);
	$t++;
	$db->free($sql);
	
	$data=array(
			'c'=>'BackupDatabaseFileSize',
			'phome'=>'BakExe',
			't'=>$t,
			's'=>0,
			'p'=>0,
			'mypath'=>$mypath,
			'stime'=>$stime,
			'waitbaktime'=>$waitbaktime
	);
	echo json_encode($data);
	
	exit();
}


function BackupDatabaseRecordNum($t,$s,$p,$mypath,$alltotal,$thenof,$fnum,$auf='',$aufval=0,$stime=0){
	global $db,$bakpath,$limittype,$fun_r,$adminDir;
	if(empty($mypath)){

	}
	$path=PLUS_PATH.'/bdata/'.$mypath;
	@include($path."/config.php");
	if(empty($b_table)){

	}
	$waitbaktime=(int)$_GET['waitbaktime'];
	if(empty($stime)){
		$stime=time();
	}
	$header="<?php
	require(LIB_PATH.\"dbbackup/inc/header.php\");
	";
	$footer="
	require(LIB_PATH.\"dbbackup/inc/footer.php\");
	?>";
	$btb=explode(",",$b_table);
	$count=count($btb);
	$t=(int)$t;
	$s=(int)$s;
	$p=(int)$p;

	if($t>=$count){
		echo"<script>alert('".$fun_r['BakSuccess']."\\n\\n".$fun_r['TotalUseTime'].ToChangeUseTime($stime)."');self.location.href='".$config['sy_weburl']."/".$adminDir."/index.php?m=database';</script>";
		exit();
    }

	$u=$db->query("use `$b_dbname`");
	$dumpsql = '';
	if($b_dbchar=='auto'){
		if(!empty($s)){
			$status_r=GetTableRows($b_dbname,$btb[$t]);
			$collation=GetCharset($status_r['Collation']);
			SetCharset($collation);
			
			$num=$limittype?-1:$status_r['Rows'];
		}else{
			$collation=$_GET['collation'];
			SetCharset($collation);
			$num=(int)$alltotal;
		}
		$dumpsql.=ExcuteSetCharset($collation);
	}else{
		SetCharset($b_dbchar);
		if(!empty($s)){
			
			if($limittype){
				$num=-1;
			}else{
				$status_r=GetTableRows($b_dbname,$btb[$t]);
				$num=$status_r['Rows'];
			}
		}else{
			$num=(int)$alltotal;
		}
	}
	
	if($b_stru&&$s){
		$dumpsql.=GetTableStructSql($btb[$t],$b_strufour);
	}

	if(empty($fnum)){
		$return_fr=GetTableFields($b_dbname,$btb[$t],$b_autofield);
		$fieldnum=$return_fr['num'];
		$noautof=$return_fr['autof'];
		$auf=$return_fr['auf'];
	}else{
		$fieldnum=$fnum;
		$noautof=$thenof;
	}
	
	$aufval=(int)$aufval;
	if($b_autoauf==1&&$auf){
		$sql=$db->query("select * from `".$btb[$t]."` where ".$auf.">".$aufval." order by ".$auf." limit $b_bakline");
	}else{
		$sql=$db->query("select * from `".$btb[$t]."` limit $s,$b_bakline");
	}
	
	$inf='';
	if($b_beover==1){
		$inf='('.GetTableInsertFields($b_dbname,$btb[$t]).')';
	}

	$hexf='';
	if($b_bakdatatype==1){
		$hexf=GetTableStringFields($b_dbname,$btb[$t]);
	}
	$b=0;
	while($r=$db->fetch($sql)){
		if($auf){
			$lastaufval=$r[$auf];
		}
		$b=1;
		$s++;
		$dumpsql.="ExcuteSQL(\"into `".$btb[$t]."`".$inf." values(";
		$first=1;
		for($i=0;$i<$fieldnum;$i++){
			
			if(empty($first)){
				$dumpsql.=',';
			}else{
				$first=0;
			}
			$myi=$i+1;
			if(!isset($r[$i])||strstr($noautof,','.$myi.',')){
				$dumpsql.='NULL';
			}else{
				$dumpsql.=GetFieldContent($r[$i],$b_bakdatatype,$myi,$hexf);
			}
		}
		$dumpsql.=");\");\r\n";
	}
	if(empty($b)){
		
		if(empty($p)){
			$p++;
			$sfile=$path."/".$btb[$t]."_".$p.".php";
			$dumpsql=$header.$dumpsql.$footer;
			WriteString2File($sfile,$dumpsql);
		}
		FetchFileNumber($p,$btb[$t],$path);
		$t++;
		$db->free($sql);
		
		echo"<meta http-equiv=\"refresh\" content=\"".$waitbaktime.";url=".$config['sy_weburl']."/".$adminDir."/index.php?m=database&c=BackupDatabaseRecordNum&s=0&p=0&t=$t&mypath=$mypath&stime=$stime&waitbaktime=$waitbaktime\">".$fun_r['OneTableBakSuccOne'].$btb[$t-1].$fun_r['OneTableBakSuccTwo'];
		exit();
	}
	
	$p++;
	$sfile=$path."/".$btb[$t]."_".$p.".php";
	$dumpsql=$header.$dumpsql.$footer;
	WriteString2File($sfile,$dumpsql);
	$db->free($sql);
	echo"<meta http-equiv=\"refresh\" content=\"".$waitbaktime.";url=".$config['sy_weburl']."/".$adminDir."/index.php?m=database&c=BackupDatabaseRecordNum&s=$s&p=$p&t=$t&mypath=$mypath&alltotal=$num&thenof=$noautof&fieldnum=$fieldnum&auf=$auf&aufval=$lastaufval&stime=$stime&waitbaktime=$waitbaktime&collation=$collation\">".$fun_r['BakOneDataSuccess'].EchoBackupProcesser($btb[$t],$count,$t,$num,$s);
	exit();
}

function EchoBackupProcesser($tbname,$tbnum,$tb,$rnum,$r){
	$table=($tb+1).'/'.$tbnum;
	$record=$r;
	if($rnum!=-1){
		$record=$r.'/'.$rnum;
	}
}

function EchoRecoverProcesser($tbname,$tbnum,$tb,$pnum,$p){
	$table=($tb+1).'/'.$tbnum;
	$record=$p.'/'.$pnum;
}

function GetTableRows($dbname,$tbname){
	global $db;
	$tr=$db->DB_query_all("SHOW TABLE STATUS LIKE '".$tbname."';");
	return $tr;
}

function GetCharset($char){
	global $db;
	if(empty($char)){
		return '';
	}
	$r=$db->DB_query_all("SHOW COLLATION LIKE '".$char."';");
	return $r[0]['Charset'];
}

function GetTableFields($dbname,$tbname,$autofield){
	global $db;
	$sql=$db->query("SHOW FIELDS FROM `".$tbname."`");
	$i=0;
	$autof=",";
	$f='';
    while($r=$db->fetch_array_old($sql)){
		$i++;
		if(strstr($autofield,",".$tbname.".".$r[Field].",")){
			$autof.=$i.",";
	    }
		if($r['Extra']=='auto_increment'){
			$f=$r['Field'];
		}
    }
	$return_r['num']=$i;
	$return_r['autof']=$autof;
	$return_r['auf']=$f;
	return $return_r;
}

function GetTableInsertFields($dbname,$tbname){
	global $db;
	$sql=$db->query("SHOW FIELDS FROM `".$tbname."`");
	$f='';
	$dh='';
	while($r=$db->fetch($sql)){
		$f.=$dh.'`'.$r['Field'].'`';
		$dh=',';
    }
	return $f;
}

function GetTableStringFields($dbname,$tbname){
	global $db;
	$sql=$db->query("SHOW FIELDS FROM `".$tbname."`");
	$i=0;
	$f='';
	$dh='';
	while($r=$db->fetch($sql)){
		$i++;
		if(!(stristr($r[Type],'char')||stristr($r[Type],'text'))){
			continue;
		}
		$f.=$dh.$i;
		$dh=',';
    }
	if($f){
		$f=','.$f.',';
	}
	return $f;
}


function EscapeString($str){
	global $db;
	$str=$db->escape_string($str);
	$str=str_replace('\\\'','\'\'',$str);
	$str=str_replace("\\\\","\\\\\\\\",$str);
	$str=str_replace('$','\$',$str);
	return $str;
}

function GetFieldContent($str,$bakdatatype,$i,$tbstrf){
	if($bakdatatype==1&&!empty($str)&&strstr($tbstrf,','.$i.',')){
		$restr='0x'.bin2hex($str);
	}else{
		$restr='\''.EscapeString($str).'\'';
	}
	return $restr;
}

function FetchFileNumber($p,$table,$path){
	if(empty($p)){$p=0;}
	$file=$path."/config.php";
	$text=ReadFileContent($file);
	$rep1="\$tb[".$table."]=0;";
	$rep2="\$tb[".$table."]=".$p.";";
	$text=str_replace($rep1,$rep2,$text);
	WriteString2File($file,$text);
}

function ExcuteSQL($sql){
	global $db;
	$db->query($sql);
}

function CreateTable($sql){
	global $db;
	$db->query(FetchDbcharset($sql));
}

function Convert2Mysql4($query){
	$exp="ENGINE=";
	if(!strstr($query,$exp)){
		return $query;
	}
	$exp1=" ";
	$r=explode($exp,$query);

	$r1=explode($exp1,$r[1]);
	$returnquery=$r[0]."TYPE=".$r1[0];
	return $returnquery;
}

function GetTableStructSql($table,$strufour){
	global $db;
	$dumpsql ="ExcuteSQL(\"DROP TABLE IF EXISTS `".$table."`;\");\r\n";

	$usql=$db->query("SET SQL_QUOTE_SHOW_CREATE=1;");

    $CreatTable = $db->query("SHOW CREATE TABLE $table");
    $r=$db->fetch_array_old($CreatTable);
	$create=str_replace("\"","\\\"",$r[1]);

	if($strufour){
		$create=Convert2Mysql4($create);
	}
	$dumpsql.="CreateTable(\"".$create."\");\r\n";
	return $dumpsql;
}

function ExcuteSetCharset($char){
	if(empty($char)){
		return '';
	}
	$dumpsql="ExcuteSQL('set names \'".$char."\'');\r\n";
	return $dumpsql;
}

function DeleteDbcharset($sql){
	global $phpyun_db_ver;
	if($phpyun_db_ver=='4.0'&&strstr($sql,' character set ')){
		$preg_str="/ character set (.+?) collate (.+?) /is";
		$sql=preg_replace($preg_str,' ',$sql);
	}
	return $sql;
}

function FetchDbcharset($sql){
	global $phpyun_db_ver,$phpyun_db_char,$b_dbchar;

	if($phpyun_db_ver>='4.1'&&!strstr($sql,'ENGINE=')&&($phpyun_db_char||$b_dbchar)&&$b_dbchar!='auto'){
		$dbcharset=$b_dbchar?$b_dbchar:$phpyun_db_char;
		$sql=GetCreateTableSql($sql,$phpyun_db_ver,$dbcharset);
	}elseif($phpyun_db_ver=='4.0'&&strstr($sql,'ENGINE=')){
		$sql=Convert2Mysql4($sql);
	}

	$sql=DeleteDbcharset($sql);
	return $sql;
}

function GetCreateTableSql($sql,$mysqlver,$dbcharset){
	$type=strtoupper(preg_replace("/^\s*CREATE TABLE\s+.+\s+\(.+?\).*(ENGINE|TYPE)\s*=\s*([a-z]+?).*$/isU","\\2",$sql));
	$type=in_array($type,array('MYISAM','HEAP'))?$type:'MYISAM';
	return preg_replace("/^\s*(CREATE TABLE\s+.+\s+\(.+?\)).*$/isU","\\1",$sql).
		($mysqlver>='4.1'?" ENGINE=$type DEFAULT CHARSET=$dbcharset":" TYPE=$type");
}

function RecoverData($add,$mypath){
	global $db,$bakpath,$config;
	if(empty($mypath)||empty($add[mydbname])){

	}
    $path=PLUS_PATH.'/bdata/'.$mypath;
	if(!file_exists($path)){

    }
	@include($path."/config.php");
	if(empty($b_table)){

	}
	$waitbaktime=(int)$add['waitbaktime'];
	$btb=explode(",",$b_table);
	$nfile='data/plus/bdata/'.$mypath."/".$btb[0]."_1.php?t=0&p=0&mydbname=$add[mydbname]&mypath=$mypath&waitbaktime=$waitbaktime";
	Header("Location:".$config['sy_weburl']."/$nfile");
	exit();
}

?>