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