<?php

defined('IN_PHPCMS') or exit('No permission resources.');

pc_base::load_app_class('admin', 'admin', 0);

class index extends admin {

	private $db, $siteid, $site, $point;

	public function __construct() {

		parent::__construct();

		$this->db = pc_base::load_model('release_point_model');

		$this->siteid = $this->get_siteid();

		$site = pc_base::load_app_class('sites', 'admin');

		$this->site = $site->get_by_id($this->siteid);

		$this->point = explode(',', $this->site['release_point']);

		pc_base::load_app_func('global');

		del_queue();

	}

	

	public function init() {

		if (empty($this->point[0])) {

			showmessage(L("the_site_not_release").'<script type="text/javascript">window.top.$(\'#display_center_id\').css(\'display\',\'none\');</script>');

		}

		$ids = isset($_GET['ids']) && trim($_GET['ids']) ? trim($_GET['ids']) : 0;

		$statuses = isset($_GET['statuses']) && intval($_GET['statuses']) ? intval($_GET['statuses']) : 0;

		if(isset($_GET['iniframe']))$show_header = true;

		include $this->admin_tpl('release_list');

	}

	

	public function public_sync() {

		$id = isset($_GET['id']) && intval($_GET['id']) ? intval($_GET['id']) : 0;

		$ids = isset($_GET['ids']) && trim($_GET['ids']) ? trim($_GET['ids']) : 0;

		$total = isset($_GET['total']) && intval($_GET['total']) ? intval($_GET['total']) : 0;

		$page = isset($_GET['page']) && intval($_GET['page']) ? intval($_GET['page']) : 1;

		$statuses = isset($_GET['statuses']) && intval($_GET['statuses']) ? intval($_GET['statuses']) : 0;

		$pagesize = 5;

		$queue = pc_base::load_model('queue_model');

		set_time_limit(600);

		if (!empty($ids)) {

			$ids = explode(',', $ids);

			if (empty($total)) {

				$total = count($ids);

			}

			$sql = "siteid = '".$this->get_siteid()."' AND status".($id+1)." = $statuses AND id in ('".implode('\',\'', $ids)."')";

			$data = $queue->select($sql, 'id, type, path');

		}else {

			if (empty($total)) {

				$total = $queue->count(array("siteid"=>$this->get_siteid(), "status".($id+1)=>$statuses));

			}

			$totalpage = ceil($total/$pagesize);

			$data = $queue->select(array("siteid"=>$this->get_siteid(), "status".($id+1)=>$statuses), 'id, type, path', $pagesize);

		}

		$release_point = $this->db->get_one(array('id'=>$this->point[$id]));

		$ftps = pc_base::load_sys_class('ftps');

		if(is_array($data) && !empty($data)) if ($ftps->connect($release_point['host'], $release_point['username'], $release_point['password'], $release_point['port'], $release_point['pasv'], $release_point['ssl'])) {

			if ($release_point['path']) {

				$ftps->chdir($release_point['path']);

			}

			foreach ($data as $v) {

				$status = -1;

				switch ($v['type']) {

					case 'del':

						if ($ftps->f_delete($release_point['path'].$v['path'])) {

							$status = 1;

						}

						break;

					case 'add':

					case 'edit':

						if ($ftps->put($release_point['path'].$v['path'], PHPCMS_PATH.$v['path'])) {

							$status = 1;

						}

						break;

				}

				$queue->update(array('status'.($id+1)=>$status, 'times'=>SYS_TIME), array('id'=>$v['id']));

			}

		} else {

			exit('<script type="text/javascript">alert("'.L("release_point_connect_failure",array('name'=>$release_point['name'])).'");</script>');

		}

		

		include $this->admin_tpl('release_sync');

	}

	

	public function failed() {

		if (empty($this->point[0])) {

			showmessage(L("the_site_not_release").'<script type="text/javascript">window.top.$(\'#display_center_id\').css(\'display\',\'none\');</script>');

		}

		

		$page = isset($_GET['page']) && intval($_GET['page']) ? intval($_GET['page']) : 1;

		

		$sql = '';

		$i = 1;

		foreach ($this->point as $v) {

			$sql .= $sql ? " or status".$i." = '-1'" :" status".$i." = '-1'";

			$i++;

		}

		$sql .= ' AND siteid = \''.$this->get_siteid().'\'';

		$queue = pc_base::load_model('queue_model');

		$list = $queue->listinfo($sql, 'id desc', $page, 20);

		pc_base::load_sys_class('format', '', 0);

		include $this->admin_tpl('release_failed_list');

	}

	

	public function del() {

		$ids = isset($_POST['ids']) ? $_POST['ids'] : showmessage(L('illegal_operation'), HTTP_REFERER);

		if (is_array($ids))$ids = implode('\',\'', $ids);

		$queue = pc_base::load_model('queue_model');

		$queue->delete("id in ('$ids')");

		showmessage(L('operation_success'), HTTP_REFERER);

	}

}