DedeV6/src/dede/sys_data_done.php

<?php
/**
 * 数据库操作
 *
 * @version        $Id: sys_data_done.php 1 17:19 2010年7月20日Z tianya $
 * @package        DedeCMS.Administrator
 * @copyright      Copyright (c) 2007 - 2018, DesDev, Inc.
 * @copyright      Copyright (c) 2020, DedeBIZ.COM
 * @license        https://www.dedebiz.com/license/v6
 * @link           https://www.dedebiz.com
 */
@ob_start();
@set_time_limit(0);
require_once(dirname(__FILE__).'/config.php');
CheckPurview('sys_Data');
if(empty($dopost)) $dopost = '';

$bkdir = DEDEDATA.'/'.$cfg_backup_dir;

//跳转到一下页的JS
$gotojs = "function GotoNextPage(){
    document.gonext."."submit();
}"."\r\nset"."Timeout('GotoNextPage()',500);";

$dojs = "<script language='javascript'>$gotojs</script>";

/*--------------------
备份数据
function __bak_data();
--------------------*/
if($dopost=='bak')
{
    if(empty($tablearr))
    {
        ShowMsg('你没选中任何表！', 'javascript:;');
        exit();
    }
    if(!is_dir($bkdir))
    {
        MkdirAll($bkdir, $cfg_dir_purview);
        CloseFtp();
    }

    //初始化使用到的变量
    $tables = explode(',', $tablearr);
    if(!isset($isstruct))
    {
        $isstruct = 0;
    }
    if(!isset($startpos))
    {
        $startpos = 0;
    }
    if(!isset($iszip))
    {
        $iszip = 0;
    }
    if(empty($nowtable))
    {
        $nowtable = '';
    }
    if(empty($fsize))
    {
        $fsize = 2048;
    }
    $fsizeb = $fsize * 1024;

    //第一页的操作
    if($nowtable=='')
    {
        $tmsg = '';
        $dh = dir($bkdir);
        while($filename = $dh->read())
        {
            if(!preg_match("#txt$#", $filename))
            {
                continue;
            }
            $filename = $bkdir."/$filename";
            if(!is_dir($filename))
            {
                unlink($filename);
            }
        }
        $dh->close();
        $tmsg .= "清除备份目录旧数据完成...<br />";

        if($isstruct==1)
        {
            $bkfile = $bkdir."/tables_struct_".substr(md5(time().mt_rand(1000,5000).$cfg_cookie_encode),0,16).".txt";
            $mysql_version = $dsql->GetVersion();
            $fp = fopen($bkfile, "w");
            foreach($tables as $t)
            {
                fwrite($fp, "DROP TABLE IF EXISTS `$t`;\r\n\r\n");
                $dsql->SetQuery("SHOW CREATE TABLE ".$dsql->dbName.".".$t);
                $dsql->Execute('me');
                $row = $dsql->GetArray('me', MYSQL_BOTH);

                //去除AUTO_INCREMENT
                $row[1] = preg_replace("#AUTO_INCREMENT=([0-9]{1,})[ \r\n\t]{1,}#i", "", $row[1]);

                //4.1以下版本备份为低版本
                if($datatype==4.0 && $mysql_version > 4.0)
                {
                    $eng1 = "#ENGINE=MyISAM[ \r\n\t]{1,}DEFAULT[ \r\n\t]{1,}CHARSET=".$cfg_db_language."#i";
                    $tableStruct = preg_replace($eng1, "TYPE=MyISAM", $row[1]);
                }

                //4.1以下版本备份为高版本
                else if($datatype==4.1 && $mysql_version < 4.1)
                {
                    $eng1 = "#ENGINE=MyISAM DEFAULT CHARSET={$cfg_db_language}#i";
                    $tableStruct = preg_replace("TYPE=MyISAM", $eng1, $row[1]);
                }
                //普通备份
                else
                {
                    $tableStruct = $row[1];
                }
                fwrite($fp,''.$tableStruct.";\r\n\r\n");
            }
            fclose($fp);
            $tmsg .= "备份数据表结构信息完成...<br />";
        }
        $tmsg .= "<font color='red'>正在进行数据备份的初始化工作，请稍后...</font>";
        $doneForm = "<form name='gonext' method='post' action='sys_data_done.php'>
           <input type='hidden' name='isstruct' value='$isstruct' />
           <input type='hidden' name='dopost' value='bak' />
           <input type='hidden' name='fsize' value='$fsize' />
           <input type='hidden' name='tablearr' value='$tablearr' />
           <input type='hidden' name='nowtable' value='{$tables[0]}' />
           <input type='hidden' name='startpos' value='0' />
           <input type='hidden' name='iszip' value='$iszip' />\r\n</form>\r\n{$dojs}\r\n";
        PutInfo($tmsg, $doneForm);
        exit();
    }
    //执行分页备份
    else
    {
        $j = 0;
        $fs = array();
        $bakStr = '';

        //分析表里的字段信息
        $dsql->GetTableFields($nowtable);
        $intable = "INSERT INTO `$nowtable` VALUES(";
        while($r = $dsql->GetFieldObject())
        {
            
            $fs[$j] = trim($r->name);
            $j++;
        }
        $fsd = $j-1;

        //读取表的内容
        $dsql->SetQuery("SELECT * FROM `$nowtable` ");
        $dsql->Execute();
        $m = 0;
        $bakfilename = "$bkdir/{$nowtable}_{$startpos}_".substr(md5(time().mt_rand(1000,5000).$cfg_cookie_encode),0,16).".txt";
        while($row2 = $dsql->GetArray())
        {
            if($m < $startpos)
            {
                $m++;
                continue;
            }

            //检测数据是否达到规定大小
            if(strlen($bakStr) > $fsizeb)
            {
                $fp = fopen($bakfilename,"w");
                fwrite($fp,$bakStr);
                fclose($fp);
                $tmsg = "<font color='red'>完成到{$m}条记录的备份，继续备份{$nowtable}...</font>";
                $doneForm = "<form name='gonext' method='post' action='sys_data_done.php'>
                <input type='hidden' name='isstruct' value='$isstruct' />
                <input type='hidden' name='dopost' value='bak' />
                <input type='hidden' name='fsize' value='$fsize' />
                <input type='hidden' name='tablearr' value='$tablearr' />
                <input type='hidden' name='nowtable' value='$nowtable' />
                <input type='hidden' name='startpos' value='$m' />
                <input type='hidden' name='iszip' value='$iszip' />\r\n</form>\r\n{$dojs}\r\n";
                PutInfo($tmsg,$doneForm);
                exit();
            }

            //正常情况
            $line = $intable;
            
            for($j=0; $j<=$fsd; $j++)
            {
                if($j < $fsd)
                {
                    $line .= "'".RpLine(addslashes($row2[$fs[$j]]))."',";
                }
                else
                {
                    $line .= "'".RpLine(addslashes($row2[$fs[$j]]))."');\r\n";
                }
            }
            $m++;
            $bakStr .= $line;
        }

        //如果数据比卷设置值小
        if($bakStr!='')
        {
            $fp = fopen($bakfilename,"w");
            fwrite($fp,$bakStr);
            fclose($fp);
        }
        for($i=0; $i<count($tables); $i++)
        {
            if($tables[$i] == $nowtable)
            {
                if(isset($tables[$i+1]))
                {
                    $nowtable = $tables[$i+1];
                    $startpos = 0;
                    break;
                }else
                {
                    PutInfo("完成所有数据备份！","");
                    exit();
                }
            }
        }
        $tmsg = "<font color='red'>完成到{$m}条记录的备份，继续备份{$nowtable}...</font>";
        $doneForm = "<form name='gonext' method='post' action='sys_data_done.php?dopost=bak'>
          <input type='hidden' name='isstruct' value='$isstruct' />
          <input type='hidden' name='fsize' value='$fsize' />
          <input type='hidden' name='tablearr' value='$tablearr' />
          <input type='hidden' name='nowtable' value='$nowtable' />
          <input type='hidden' name='startpos' value='$startpos'>\r\n</form>\r\n{$dojs}\r\n";
        PutInfo($tmsg,$doneForm);
        exit();
    }
    //分页备份代码结束
}
/*-------------------------
还原数据
function __re_data();
-------------------------*/
else if($dopost=='redat')
{
    if($bakfiles=='')
    {
        ShowMsg('没指定任何要还原的文件!', 'javascript:;');
        exit();
    }
    $bakfilesTmp = $bakfiles;
    $bakfiles = explode(',', $bakfiles);
    if(empty($structfile))
    {
        $structfile = "";
    }
    if(empty($delfile))
    {
        $delfile = 0;
    }
    if(empty($startgo))
    {
        $startgo = 0;
    }
    if($startgo==0 && $structfile!='')
    {
        $tbdata = '';
        $fp = fopen("$bkdir/$structfile", 'r');
        while(!feof($fp))
        {
            $tbdata .= fgets($fp, 1024);
        }
        fclose($fp);
        $querys = explode(';', $tbdata);

        foreach($querys as $q)
        {
            $dsql->ExecuteNoneQuery(trim($q).';');
        }
        if($delfile==1)
        {
            @unlink("$bkdir/$structfile");
        }
        $tmsg = "<font color='red'>完成数据表信息还原，准备还原数据...</font>";
        $doneForm = "<form name='gonext' method='post' action='sys_data_done.php?dopost=redat'>
        <input type='hidden' name='startgo' value='1' />
        <input type='hidden' name='delfile' value='$delfile' />
        <input type='hidden' name='bakfiles' value='$bakfilesTmp' />
        </form>\r\n{$dojs}\r\n";
        PutInfo($tmsg, $doneForm);
        exit();
    }
    else
    {
        $nowfile = $bakfiles[0];
        $bakfilesTmp = preg_replace("#".$nowfile."[,]{0,1}#", "", $bakfilesTmp);
        $oknum=0;
        if( filesize("$bkdir/$nowfile") > 0 )
        {
            $fp = fopen("$bkdir/$nowfile", 'r');
            while(!feof($fp))
            {
                $line = trim(fgets($fp, 512*1024));
                if($line=="") continue;
                $rs = $dsql->ExecuteNoneQuery($line);
                if($rs) $oknum++;
            }
            fclose($fp);
        }
        if($delfile==1)
        {
            @unlink("$bkdir/$nowfile");
        }
        if($bakfilesTmp=="")
        {
            ShowMsg('成功还原所有的文件的数据!', 'javascript:;');
            exit();
        }
        $tmsg = "成功还原{$nowfile}的{$oknum}条记录<br/><br/>正在准备还原其它数据...";
        $doneForm = "<form name='gonext' method='post' action='sys_data_done.php?dopost=redat'>
        <input type='hidden' name='startgo' value='1' />
        <input type='hidden' name='delfile' value='$delfile' />
        <input type='hidden' name='bakfiles' value='$bakfilesTmp' />
        </form>\r\n{$dojs}\r\n";
        PutInfo($tmsg, $doneForm);
        exit();
    }
}

function PutInfo($msg1,$msg2)
{
    global $cfg_dir_purview,$cfg_soft_lang;
    $msginfo = "<html>\n<head>
        <meta http-equiv='Content-Type' content='text/html; charset={$cfg_soft_lang}' />
        <title>DEDECMS 提示信息</title>
        <base target='_self'/>\n</head>\n<body leftmargin='0' topmargin='0'>\n<center>
        <br/>
        <div style='width:400px;padding-top:4px;height:24;font-size:10pt;border-left:1px solid #cccccc;border-top:1px solid #cccccc;border-right:1px solid #cccccc;background-color:#DBEEBD;'>DEDECMS 提示信息！</div>
        <div style='width:400px;height:100px;font-size:10pt;border:1px solid #cccccc;background-color:#F4FAEB'>
        <span style='line-height:160%'><br/>{$msg1}</span>
        <br/><br/></div>\r\n{$msg2}";
    echo $msginfo."</center>\n</body>\n</html>";
}

function RpLine($str)
{
    $str = str_replace("\r", "\\r", $str);
    $str = str_replace("\n", "\\n", $str);
    return $str;
}