<?php
session_start();
if( !defined('IN') ) die('bad request!');
include_once( AROOT . 'controller' . DS . 'app.class.php');
header("Content-Type: text/html; charset=utf-8");

//定义错误码
define( 'LR_API_TOKEN_ERROR', 10001); 
define( 'LR_API_USER_ERROR', 10002);
define( 'LR_API_DB_ERROR', 10003);
define( 'LR_API_DB_EMPTY_RESULT', 10004);
define( 'LR_API_USER_CLOSED', 10005);
define( 'LR_API_FORBIDDEN', 10006);
define( 'LR_API_NO_PARAM', 10007);
define( 'LR_API_NO_AUTH', 10008);
define( 'LR_API_BAD_DEVICE', 10009);
define( 'LR_API_BAD_TIME', 10010);

class homeController extends appController
{
	public function __construct(){
		parent::__construct();
	}

	// 发送错误结果集
	public function send_error($number,$msg)
	{
		$obj = array();
		$obj['code'] = intval($number);
		$obj['result'] = $msg;

		if( g('API_EMBED_MODE') == 1 ){
			return json_encode($obj);
		}else{
			header("Content-Type: application/json");
			die(json_encode($obj));
		}
	}

	// 发送结果集
	public function send_result($data)
	{
		$obj = array();
		$obj['code'] = 0;
		$obj['result'] = 'success';
		$obj['data'] = $data;

		if( g('API_EMBED_MODE') == 1 ){
			return json_encode($obj);
		}else{
			header("Content-Type: application/json");
			die(json_encode($obj));
		}
	}

	/**
	 *  返回首页
	 */
	public function index()
	{
		$default_id = v("id");

		if (!empty($_SESSION))
		{

			// 获取登录账号的项目ID
			$project_id = $_SESSION['project_id'];

			// 判断账号的权限
			if($project_id == '0')
			{

				// 判断是否存在默认ID
				if(empty($default_id))
				{
					// 项目列表
					$sql_project = "select id,name from project";
					$data['projects'] = get_data($sql_project);

					// 场站数量
					$sql_terminal = "select count(id) from terminal";
					$data['terminal_count'] = get_var($sql_terminal);

					// 智慧调控次数(主污泵+备污泵+雨水+闸门上+闸门下)
					$sql_device = "select id from device where status = 1 and type = 1";
					$device_data= get_data($sql_device);
					for ($i=0; $i < count($device_data); $i++) 
					{ 
						$device_id = $device_data[$i]['id'];

						// 循环查询次数
						$sql_count = prepare("select (main_sewage_pump_count+standby_sewage_pump_count+main_rain_pump_count+gate_up_count+gate_down_count) as control_count from data where device_id = ?i order by id desc limit 1",array($device_id));
						$all_control_count += get_var($sql_count);
					}
					$data['control_count'] = $all_control_count;

				}
				else
				{
					// 项目列表
					$sql_project = "select id,name from project";
					$data['projects'] = get_data($sql_project);

					// 场站数量
					$sql_terminal = prepare("select count(id) from terminal where project_id = ?i",array($default_id));
					$data['terminal_count'] = get_var($sql_terminal);

					// 智慧调控次数(主污泵+备污泵+雨水+闸门上+闸门下)
					$sql_device = prepare("select id from device where status = 1 and type = 1 and project_id = ?i",array($default_id));
					$device_data= get_data($sql_device);
					for ($i=0; $i < count($device_data); $i++) 
					{ 
						$device_id = $device_data[$i]['id'];

						// 循环查询次数
						$sql_count = prepare("select (main_sewage_pump_count+standby_sewage_pump_count+main_rain_pump_count+gate_up_count+gate_down_count) as control_count from data where device_id = ?i order by id desc limit 1",array($device_id));
						$all_control_count += get_var($sql_count);
					}
					$data['control_count'] = $all_control_count;
				}
				
			}else{

				if(empty($default_id))
				{

					// 项目列表
					$sql_project = prepare("select id,name from project where id = ?i",array($project_id));
					$data['projects'] = get_data($sql_project);

					// 场站数量
					$sql_terminal = prepare("select count(id) from terminal where project_id = ?i",array($project_id));
					$data['terminal_count'] = get_var($sql_terminal);

					// 智慧调控次数(主污泵+备污泵+雨水+闸门上+闸门下)
					$sql_device = prepare("select id from device where status = 1 and type = 1 and project_id = ?i",array($project_id));
					$device_data= get_data($sql_device);
					for ($i=0; $i < count($device_data); $i++) 
					{ 
						$device_id = $device_data[$i]['id'];

						// 循环查询次数
						$sql_count = prepare("select (main_sewage_pump_count+standby_sewage_pump_count+main_rain_pump_count+gate_up_count+gate_down_count) as control_count from data where device_id = ?i order by id desc limit 1",array($device_id));
						$all_control_count += get_var($sql_count);
					}
					$data['control_count'] = $all_control_count;

				}
				else
				{
					// 项目列表
					$sql_project = prepare("select id,name from project where id = ?i",array($default_id));
					$data['projects'] = get_data($sql_project);

					// 场站数量
					$sql_terminal = prepare("select count(id) from terminal where project_id = ?i",array($default_id));
					$data['terminal_count'] = get_var($sql_terminal);

					// 智慧调控次数(主污泵+备污泵+雨水+闸门上+闸门下)
					$sql_device = prepare("select id from device where status = 1 and type = 1 and project_id = ?i",array($default_id));
					$device_data= get_data($sql_device);
					for ($i=0; $i < count($device_data); $i++) 
					{ 
						$device_id = $device_data[$i]['id'];

						// 循环查询次数
						$sql_count = prepare("select (main_sewage_pump_count+standby_sewage_pump_count+main_rain_pump_count+gate_up_count+gate_down_count) as control_count from data where device_id = ?i order by id desc limit 1",array($device_id));
						$all_control_count += get_var($sql_count);
					}
					$data['control_count'] = $all_control_count;

				}
			}
			render($data, "web", "index");
		}else {
			header("Location:?c=index&a=index");
		}
	}


	/**
	 *  策略管理
	 */
	public function strategy()
	{

		$default_id = v("id");

		if (!empty($_SESSION))
		{
			
			$project_id = $_SESSION['project_id'];

			if($project_id == '0')
			{
				
				$sql = "select id,name from project";
				$project_array = get_data($sql);

			}
			else
			{
				if(empty($default_id)){

					$sql = prepare("select id,name from project where id=?i",array($default_id));
					$project_array = get_data($sql);
					
				}else{
					
					$sql = prepare("select id,name from project where id=?i",array($project_id));
					$project_array = get_data($sql);
					
				}
				
			}
			$data['projects'] =$project_array;
			render($data, 'web', 'strategy');
		}else{
			header("Location:?c=index&a=index");
		}
	}

	/**
	 *  返回场站详情
	 */
	public function station_details()
	{
		$terminal_id = v("id");

		$sql_count_device = prepare("select count(*) from device where terminal_id = ?i",array($terminal_id));
		$data['device_count'] = get_var($sql_count_device);

		// 累计调控次数
		$sql_device = prepare("select id from device where status = 1 and type = 1 and terminal_id = ?i",array($terminal_id));
		$device_data= get_data($sql_device);
		for ($i=0; $i < count($device_data); $i++) 
		{ 
			$device_id = $device_data[$i]['id'];

			// 循环查询次数
			$sql_count = prepare("select (main_sewage_pump_count+standby_sewage_pump_count+main_rain_pump_count+gate_up_count+gate_down_count) as control_count from data where device_id = ?i order by id desc limit 1",array($device_id));
			$all_control_count += get_var($sql_count);
		}
		$data['control_count'] = $all_control_count;

		$sql_warn = prepare("select count(warn.id) from warn,device where device.id=warn.device_id and device.terminal_id=?i ",array($terminal_id));
		$warn_count = get_var($sql_warn);
		$data['warn_count'] = get_var($sql_warn);

		//基本信息 场站名称 地址 负责人  联系方式
		$sql = prepare("select * from terminal where id=?i",array($terminal_id));
		$data['info'] = get_line($sql);

		//设备情况   控制状态 控制模式 闸门状态  1主污泵状态 2备污泵状态 3雨水泵
		$sql_strategy = prepare("select strategy.name from strategy,device where strategy.id=device.strategy_id and device.terminal_id=?i",array($terminal_id));
		$data['strategy'] = get_var($sql_strategy);

		$sql_controlmodel = prepare("select CASE WHEN control_model = 1 THEN '手动模式' else '自动模式' END from device where terminal_id=?i limit 1",array($terminal_id));
		$data['controlmodel'] = get_var($sql_controlmodel);

		$sql_device_status = prepare("select if(main_sewage_pump=1,'开启','关闭') as main_sewage_pump,if(standby_sewage_pump=1,'开启','关闭') as standby_sewage_pump,if(main_rain_pump=1,'开启','关闭') as main_rain_pump,if(gate_up=1,'闸门上升','闸门上升停止') as gate_up,if(gate_down=1,'闸门下降','闸门下降停止') as gate_down from data where device_id = (select id from device where terminal_id = ?i limit 1) order by id desc limit 1",array($terminal_id));

        $data['gate_up'] 			 = get_line($sql_device_status)['gate_up'];
        $data['gate_down'] 			 = get_line($sql_device_status)['gate_down'];
        $data['main_sewage_pump'] 	 = get_line($sql_device_status)['main_sewage_pump'];
        $data['standby_sewage_pump'] = get_line($sql_device_status)['standby_sewage_pump'];
		$data['main_rain_pump'] 	 = get_line($sql_device_status)['main_rain_pump'];
		
		if (!empty($_SESSION)) {
			render($data, 'web', 'station_details');
		} else {
			header("Location:?c=index&a=index");
		}
	}

	/**
	 *  返回视频管理
	 */
	public function video()
	{

		$module_hanyupinyin = v("id");
		if (!empty($_SESSION)){
			// echo 1;
			$project_id = $_SESSION['project_id'];
			if($project_id == '0'){
				// echo 1;
				//项目列表
				$sql = "select id,name from project order by id asc";
				$project_array = get_data($sql);
				if(empty($module_hanyupinyin)){
					
				}else{
					
				}
				

			}else{
				if(empty($module_hanyupinyin)){
					// echo 3;
					//项目列表
					$sql = prepare("select id,name from project where id=?i order by id asc",array($module_hanyupinyin));
					$project_array = get_data($sql);
					
				}else{
					// echo 4;
					//项目列表
					$sql = prepare("select id,name from project where id=?i order by id asc",array($project_id));
					$project_array = get_data($sql);
					
				}
				
			}
			$data['projects'] =$project_array;
			render($data, 'web', 'video');
		}else{
			header("Location:?c=index&a=index");
		}
		
	}

	/**
	 *  返回视频详情
	 */
	public function video_details()
	{

		if (!empty($_SESSION)) {
			render(null, 'web', 'video_details');
		
		} else {

			header("Location:?c=index&a=index");

		}
		
	}

	/**
	 *  返回事件管理
	 */
	public function event()
	{
		$module_hanyupinyin = v("id");
		if (!empty($_SESSION)){
			// echo 1;
			$project_id = $_SESSION['project_id'];
			if($project_id == '0'){
				if(empty($module_hanyupinyin)){
					//项目列表
					$sql = "select id,name from project order by id asc";
					$project_array = get_data($sql);
					$data['projects'] =$project_array;
					//事件总数  
					$sql_event = "select count(*) from event";
					$event_count = get_var($sql_event);
					$data['event_count']=$event_count;
				}else{
					//项目列表
					$sql = "select id,name from project order by id asc";
					$project_array = get_data($sql);
					$data['projects'] =$project_array;
					//事件总数  
					$sql_event = prepare("select count(*) from event where device_id in (select id from device where project_id = ?i)",array($module_hanyupinyin));
					$event_count = get_var($sql_event);
					$data['event_count']=$event_count;
				}
				
			}else{
				//项目列表
				if(empty($module_hanyupinyin)){
					$sql = prepare("select id,name from project where id=?i order by id asc",array($project_id));
					$project_array = get_data($sql);
					$data['projects'] =$project_array;
					//事件总数  
					$sql_event = prepare("select count(*) from event where device_id in (select id from device where project_id = ?i)",array($project_id));
					$event_count = get_var($sql_event);
					$data['event_count']=$event_count;
				}else{
					$sql = prepare("select id,name from project where id=?i order by id asc",array($module_hanyupinyin));
					$project_array = get_data($sql);
					$data['projects'] =$project_array;
					//事件总数  
					$sql_event = prepare("select count(*) from event where device_id in (select id from device where project_id = ?i)",array($module_hanyupinyin));
					$event_count = get_var($sql_event);
					$data['event_count']=$event_count;
				}
			}
			

			render($data, "web", "event");
		}else {
			header("Location:?c=index&a=index");
		}
		
	}

	/**
	 *  返回设备管理
	 */
	public function device()
	{
		if (!empty($_SESSION)) {
			$project_id = $_SESSION['project_id'];
			//项目 场站
			if($project_id == '0'){
				$sql_project = "select id,name from project";
				$project = get_data($sql_project);
				$data['projects'] = $project;
				// $sql_terminal = "select  terminal.id,terminal.name from terminal,project where project.id=terminal.project_id";
				// $terminal = get_data($sql_terminal);
				// $data['terminals'] = $terminal;
			}else{
				$sql_project = prepare("select id,name from project where id=?i",array($project_id));
				$project = get_data($sql_project);
				$data['projects'] = $project;
				// $sql_terminal = prepare("select terminal.name from terminal,project where project.id=terminal.project_id and project.id=?i",array($project_id));
				// $terminal = get_data($sql_terminal);
				// $data['terminals'] = $terminal;
			}

			// echo '<pre>';
			// 	var_dump($data);
			// echo '</pre>';
			render($data, 'web', 'device');
		} else {
			header("Location:?c=index&a=index");
		}
		
	}

	/**
	 *  返回SIM卡管理
	 */
	public function sim()
	{
		$module_hanyupinyin = v("id");
		if (!empty($_SESSION)){
			
			$project_id = $_SESSION['project_id'];

			if($project_id == '0'){
				
				//项目列表
				$sql = "select id,name from project order by id asc";
				$project_array = get_data($sql);
				if(empty($module_hanyupinyin)){
					//sim卡总数量 流量告警数量 欠费停机数量 累计使用流量
					$sql_total = "select count(sim.id) from sim,device where sim.device_id=device.id";
					$total = get_var($sql_total);
					$sql_arrears = "select count(sim.id) from sim,device where sim.device_id =device.id and round(total_traffic-used_traffic,2) <= 20";
					$arrears = get_var($sql_arrears);
					$sql_use = "select round(sum(sim.used_traffic),2) from sim,device where sim.device_id =device.id";
					$used = get_var($sql_use);
					$sql_down = "select count(sim.id) from sim,device where sim.device_id=device.id and sim.status=3";
					$down = get_var($sql_down);
				}else{
					//sim卡总数量 流量告警数量 欠费停机数量 累计使用流量
					$sql_total = prepare("select count(sim.id) from sim,device where sim.device_id=device.id and device.project_id = ?i",array($module_hanyupinyin));
					$total = get_var($sql_total);
					$sql_arrears =  prepare("select count(sim.id) from sim,device where sim.device_id =device.id and round(total_traffic-used_traffic,2) <= 20 and device.project_id = ?i",array($module_hanyupinyin));
					$arrears = get_var($sql_arrears);
					$sql_use = prepare("select round(sum(sim.used_traffic),2) from sim,device where sim.device_id =device.id and device.project_id = ?i",array($module_hanyupinyin));
					$used = get_var($sql_use);
					$sql_down = prepare("select count(sim.id) from sim,device where sim.device_id=device.id and sim.status=3 and device.project_id=?i",array($module_hanyupinyin));
					$down = get_var($sql_down);
				}
				

			}else{
				if(empty($module_hanyupinyin)){

					//项目列表
					$sql = prepare("select id,name from project where id=?i order by id asc",array($project_id));
					$project_array = get_data($sql);
					//sim卡总数量 流量告警数量 欠费停机数量 累计使用流量
					$sql_total = prepare("select count(sim.id) from sim,device where  sim.device_id=device.id and device.project_id=?i",array($project_id));
					$total = get_var($sql_total);
					$sql_arrears =  prepare("select count(sim.id) from sim,device where sim.device_id =device.id and round(total_traffic-used_traffic,2) <= 20 and device.project_id=?i",array($project_id));
					$arrears = get_var($sql_arrears);
					$sql_use = prepare("select round(sum(sim.used_traffic),2) from sim,device where sim.device_id =device.id and device.project_id=?i",array($project_id));
					$used = get_var($sql_use);
					$sql_down = prepare("select count(sim.id) from sim,device where sim.device_id=device.id and sim.status=3 and device.project_id=?i",array($project_id));
					$down = get_var($sql_down);
				}else{
					//项目列表
					$sql = prepare("select id,name from project where id=?i order by id asc",array($project_id));
					$project_array = get_data($sql);
					//sim卡总数量 流量告警数量 欠费停机数量 累计使用流量
					$sql_total = prepare("select count(sim.id) from sim,device where sim.device_id=device.id and device.project_id=?i",array($project_id));
					$total = get_var($sql_total);
					$sql_arrears =  prepare("select count(sim.id) from sim,device where sim.device_id =device.id and round(total_traffic-used_traffic,2) <= 20 and device.project_id=?i",array($project_id));
					$arrears = get_var($sql_arrears);
					$sql_use = prepare("select round(sum(sim.used_traffic),2) from sim,device where sim.device_id =device.id and device.project_id=?i",array($project_id));
					$used = get_var($sql_use);
					$sql_down = prepare("select count(sim.id) from sim,device where sim.device_id=device.id and sim.status=3 and device.project_id=?i",array($project_id));
					$down = get_var($sql_down);
				}
				
			}
			$data['total'] =$total;
			$data['arrears'] =$arrears;
			$data['used'] =$used;
			$data['projects'] =$project_array;
			$data['down'] =  $down;
			render($data, 'web', 'sim');
		}else {
			header("Location:?c=index&a=index");
		}
		
	}
	
	/**
	 *  返回用户管理
	 */
	public function user()
	{
		if (!empty($_SESSION)){
			// echo 1;
			$project_id = $_SESSION['project_id'];
			if($project_id == '0'){
				//项目列表
				$sql = "select id,name from project order by id asc";
				$project_array = get_data($sql);
			}else{
				//项目列表
				$sql = prepare("select id,name from project where id=?i order by id asc",array($project_id));
				$project_array = get_data($sql);
			}
			$data['projects'] =$project_array;
			render($data, 'web', 'user');
		}else {
			header("Location:?c=index&a=index");
		}
		
	}

	/*
		大屏
	*/
	public function dashboard(){
		if (!empty($_SESSION)) {
			render(null, 'web', 'big_screen_index');
		
		} else {

			header("Location:?c=index&a=index");

		}
	}

	//新增 点位页面
	public function addPosition(){
		if (!empty($_SESSION)) {
			render(null, 'web', 'addPosition');
		
		} else {

			header("Location:?c=index&a=index");

		}
	}
	

	/*
	*
	*  记录登录页面
	*/
	public function RecordFootLog()
	{
		$token = $_SESSION['token'];
		
		// 通过token获取login_id
		$sql = prepare("select id from user where token = ?s limit 1",array($token));
		$user_id = get_var($sql);
		return $user_id;
	}


}	
?>