136 lines
3.9 KiB
PHP
136 lines
3.9 KiB
PHP
<?php
|
|
/*+*******************************************************************************
|
|
* The contents of this file are subject to the vtiger CRM Public License Version 1.0
|
|
* ("License"); You may not use this file except in compliance with the License
|
|
* The Original Code is: vtiger CRM Open Source
|
|
* The Initial Developer of the Original Code is vtiger.
|
|
* Portions created by vtiger are Copyright (C) vtiger.
|
|
* All Rights Reserved.
|
|
*
|
|
*********************************************************************************/
|
|
|
|
require_once 'modules/VtigerBackup/Locations/Location.php';
|
|
|
|
/**
|
|
* Description of FTPBackup
|
|
*
|
|
* @author MAK
|
|
*/
|
|
class Vtiger_FTPBackup extends Vtiger_Location{
|
|
|
|
protected $server;
|
|
protected $username;
|
|
protected $password;
|
|
protected $connection;
|
|
private $initialized = false;
|
|
|
|
public function __construct($limit) {
|
|
parent::__construct($limit);
|
|
$db = PearDatabase::getInstance();
|
|
$details = array();
|
|
$query = "select * from vtiger_systems where server_type=?";
|
|
$result = $db->pquery($query, array('ftp_backup'));
|
|
$rowCount = $db->num_rows($result);
|
|
if($rowCount > 0) {
|
|
$this->server = $db->query_result($result,0,'server');
|
|
$this->username = $db->query_result($result,0,'server_username');
|
|
$this->password = $db->query_result($result,0,'server_password');
|
|
}else{
|
|
//TODO handler error;
|
|
}
|
|
}
|
|
|
|
public function init() {
|
|
$this->connection = @ftp_connect($this->server);
|
|
if(empty($this->connection)) {
|
|
throw new VtigerBackupException(VtigerBackupErrorCode::$FTP_CONNECT_FAILED,
|
|
getTranslatedString('LBL_FTP_CONNECT_FAILED', 'VtigerBackup'));
|
|
}
|
|
$result = @ftp_login($this->connection, $this->username, $this->password);
|
|
if(empty($result)) {
|
|
throw new VtigerBackupException(VtigerBackupErrorCode::$FTP_LOGIN_FAILED,
|
|
getTranslatedString('LBL_FTP_LOGIN_FAILED', 'VtigerBackup'));
|
|
}
|
|
ftp_pasv($this->connection, true);
|
|
$this->initialized = true;
|
|
}
|
|
|
|
public function limitbackup() {
|
|
$fileList = $this->getBackupTimeList();
|
|
$connection = $this->getConnection();
|
|
for ($index=0; count($fileList) > $this->limit -1 ; ++$index) {
|
|
$fileName = Vtiger_BackupZip::getDefaultFileName($fileList[$index]);
|
|
@ftp_delete($connection, $fileName);
|
|
unset($fileList[$index]);
|
|
}
|
|
}
|
|
|
|
public function getBackupTimeList() {
|
|
$backupFileList = array();
|
|
$connection = $this->getConnection();
|
|
$fileList = ftp_nlist($connection, '.');
|
|
foreach ($fileList as $file) {
|
|
if ($file == "." || $file == "..") {
|
|
continue;
|
|
}
|
|
$fileName = $this->getFileName($file,'/');
|
|
$fileName = explode('-',$fileName);
|
|
$fileName = $fileName[1];
|
|
$date = substr($fileName, 0, strrpos($fileName,'.'));
|
|
$date = str_replace('_',':',$date);
|
|
if(strtotime($date) !== false) {
|
|
$backupFileList[] = strtotime($date);
|
|
}
|
|
}
|
|
sort($backupFileList);
|
|
return $backupFileList;
|
|
}
|
|
|
|
public function getBackupFileList() {
|
|
$backupFileList = array();
|
|
$connection = $this->getConnection();
|
|
$fileList = ftp_nlist($connection, '.');
|
|
foreach ($fileList as $file) {
|
|
if ($file == "." || $file == "..") {
|
|
continue;
|
|
}
|
|
$origFileName = $this->getFileName($file, '/');
|
|
$fileName = explode('-',$origFileName);
|
|
$fileName = $fileName[1];
|
|
$date = substr($fileName, 0, strrpos($fileName,'.'));
|
|
$date = str_replace('_',':',$date);
|
|
if(strtotime($date) !== false) {
|
|
$backupFileList[] = $origFileName;
|
|
}
|
|
}
|
|
return $backupFileList;
|
|
}
|
|
|
|
public function save($source) {
|
|
$dest=$this->getFileName($source);
|
|
$connection = $this->getConnection();
|
|
$upload = @ftp_put($connection, $dest, $source, FTP_BINARY);
|
|
// check upload status
|
|
if (empty($upload)) {
|
|
//TODO handle error
|
|
}
|
|
$this->close();
|
|
if(file_exists($source)){
|
|
unlink($source);
|
|
}
|
|
}
|
|
|
|
public function close() {
|
|
$connection = $this->getConnection();
|
|
ftp_close($connection);
|
|
$this->initialized = false;
|
|
}
|
|
|
|
public function getConnection() {
|
|
if(!$this->initialized) {
|
|
$this->init();
|
|
}
|
|
return $this->connection;
|
|
}
|
|
}
|
|
?>
|