165 lines
4.8 KiB
PHP
Executable File
165 lines
4.8 KiB
PHP
Executable File
<?php
|
||
// 数据备份
|
||
class adminBackup extends Controller{
|
||
private $model;
|
||
function __construct() {
|
||
parent::__construct();
|
||
$this->model = Model('Backup');
|
||
}
|
||
|
||
/**
|
||
* 初始化备份计划任务
|
||
* @return void
|
||
*/
|
||
public function taskInit(){
|
||
if(Model('systemOption')->get('autoTaskInit','backup') == 'ok') return;
|
||
// 数据备份
|
||
$data = array (
|
||
'name' => LNG('admin.task.backup'),
|
||
'type' => 'method',
|
||
'event' => 'admin.backup.start',
|
||
'time' => '{"type":"day","month":"1","week":"1","day":"02:00","minute":"10"}',
|
||
'desc' => LNG('admin.task.backupDesc'),
|
||
'enable' => '0',
|
||
'system' => '1',
|
||
);
|
||
if(!Model('SystemTask')->add($data)) return;
|
||
Model('systemOption')->set('autoTaskInit','ok','backup');
|
||
}
|
||
|
||
/**
|
||
* 计划任务配置信息
|
||
* @return void
|
||
*/
|
||
public function config(){
|
||
$this->bakConfig();
|
||
$data = $this->model->config(); // 备份配置信息
|
||
if (!$data) show_json(LNG('admin.backup.errInitTask'), false);
|
||
$database = array_change_key_case($GLOBALS['config']['database']);
|
||
$data['dbType'] = Action('admin.server')->_dbType($database); // mysql/sqlite
|
||
$last = $this->model->lastItem(); // 最近一条备份记录
|
||
if($data['enable'] != '1') {
|
||
$process= null;
|
||
if(isset($last['status'])) $last['status'] = 1;
|
||
} else {
|
||
$process= $this->model->process(); // 备份进度
|
||
}
|
||
$info = array('last' => $last, 'info' => $process);
|
||
show_json($data, true, $info);
|
||
}
|
||
private function bakConfig(){
|
||
// 获取最近一条备份记录
|
||
if (Input::get('last',null,0) == '1') {
|
||
$last = $this->model->lastItem();
|
||
// if($last && $last['name'] != date('Ymd')) $last = null;
|
||
show_json($last);
|
||
}
|
||
if (Input::get('check',null,0) != '1') return;
|
||
// 检查备份是否有效
|
||
$io = Input::get('io', 'int');
|
||
if ($this->in['auto'] != '1') {
|
||
$this->checkStore($io);
|
||
show_json('ok');
|
||
}
|
||
// 默认存储，自动创建备份存储：[path]/backup/
|
||
$data = Model('Storage')->listData($io);
|
||
$data['name'] = LNG('admin.backup.storage');
|
||
$data['default'] = 0;
|
||
$config = json_decode($data['config'], true);
|
||
$config['basePath'] = rtrim($config['basePath'], '/') . '/backup';
|
||
$data['config'] = json_encode($config);
|
||
unset($data['id']);
|
||
|
||
$this->in = $data;
|
||
ActionCallResult("admin.storage.add",function(&$res){
|
||
if (!$res['code']) $res['data'] = LNG('admin.backup.errAutoStore');
|
||
return $res;
|
||
});
|
||
}
|
||
|
||
/**
|
||
* 获取备份列表
|
||
*/
|
||
public function get() {
|
||
$id = Input::get('id',null,null);
|
||
$result = $this->model->listData($id);
|
||
$info = $id ? $this->model->process() : array();
|
||
if (!$id) $this->_getDataApply($result);
|
||
show_json($result,true, $info);
|
||
}
|
||
// 追加备份所在存储，便于识别管理
|
||
private function _getDataApply(&$data){
|
||
if (empty($data)) return;
|
||
$list = Model('Storage')->listData();
|
||
$list = array_to_keyvalue($list, 'id', 'name');
|
||
foreach ($data as &$item) {
|
||
$io = $item['io'];
|
||
$item['ioName'] = isset($list[$io]) ? $list[$io] : '0';
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 删除
|
||
*/
|
||
public function remove() {
|
||
$id = Input::get('id','int');
|
||
$res = $this->model->remove($id);
|
||
$msg = $res ? LNG('explorer.success') : LNG('explorer.error');
|
||
show_json($msg,!!$res);
|
||
}
|
||
|
||
// 激活授权,自动开启备份;(没有开启时,设置仅备份数据库;备份到默认存储)
|
||
public function initStart($status){
|
||
$data = $this->model->config();
|
||
if($data['enable'] == '1') return;
|
||
$backup = Model('SystemOption')->get('backup');
|
||
$backup = json_decode($backup, true);
|
||
|
||
$driver = KodIO::defaultDriver();
|
||
$backup['io'] = $driver['id'];
|
||
$backup['content'] = 'sql'; // 备份内容：all/sql
|
||
// $backup['enable'] = 1;
|
||
Model('SystemOption')->set('backup', $backup);
|
||
$update = array('enable' => 1);
|
||
Model('SystemTask')->update($data['id'], $update);
|
||
}
|
||
|
||
// 备份——终止http请求，后台运行
|
||
public function start(){
|
||
$config = $this->model->config();
|
||
if($config['enable'] != '1') {
|
||
show_json(LNG('admin.backup.notOpen'), false);
|
||
}
|
||
$this->checkStore($config['io']);
|
||
mk_dir(TEMP_FILES);
|
||
if(!path_writeable(TEMP_FILES)) {
|
||
show_json(LNG('admin.backup.pathNoWrite'), false);
|
||
}
|
||
echo json_encode(array('code'=>true,'data'=>'OK'));
|
||
http_close();
|
||
$this->model->start();
|
||
}
|
||
// 检查存储是否有效
|
||
private function checkStore($io){
|
||
$model = Model('Storage');
|
||
$data = $model->listData($io);
|
||
if (!$data) show_json(LNG('admin.backup.storeNotExist'), false);
|
||
$model->checkConfig($data);
|
||
}
|
||
|
||
// 还原，禁止任何操作
|
||
public function restore(){
|
||
$id = Input::get('id','int');
|
||
echo json_encode(array('code'=>true,'data'=>'OK'));
|
||
http_close();
|
||
$this->model->restore($id);
|
||
}
|
||
|
||
public function kill(){
|
||
$id = Input::get('id','int');
|
||
$res = $this->model->kill($id);
|
||
$msg = $res ? LNG('explorer.success') : LNG('explorer.error');
|
||
show_json($msg,!!$res);
|
||
}
|
||
}
|