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

class deviceController 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($total,$data)
	{
		$obj = array();
		$obj['rows'] = $data;
		// $obj['result'] = 'success';
		$obj['total'] = $total;

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

	// 发送结果集
	public function send_resu($data)
	{
		$obj = array();
		$obj['code'] = 0;
		$obj['message'] = '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 total(){
		$module_hanyupinyin = v("id");
		$terminal = v("terminal");
		$project_id = $_SESSION['project_id'];
		$sql_terminal = prepare("select id from terminal where name=?s",array($terminal));
		$terminal_id = get_var($sql_terminal);
		if($project_id == '0'){
			if(empty($module_hanyupinyin)){
				if(empty($terminal)){
					//设备总数
					$sql_total = "select count(id) from device";
					$total = get_var($sql_total);
					//控制柜数量 type =1 
					$sql_1 = "select count(id) from device where type=1";
					$total_1 = get_var($sql_1);
					//曝气机数量 type=2
					$sql_2 = "select count(id) from device where type=2";
					$total_2 = get_var($sql_2);
					//管网设备数量 type=3
					$sql_3 = "select count(id) from device where type=3";
					$total_3 = get_var($sql_3);
				}else{
					//设备总数
					$sql_total = prepare("select count(id) from device where terminal_id=?i",array($terminal_id));
					$total = get_var($sql_total);
					//控制柜数量 type =1 
					$sql_1 = prepare("select count(id) from device where type=1 and terminal_id=?i",array($terminal_id));
					$total_1 = get_var($sql_1);
					//曝气机数量 type=2
					$sql_2 = prepare("select count(id) from device where type=2 and terminal_id=?i",array($terminal_id));
					$total_2 = get_var($sql_2);
					//管网设备数量 type=3
					$sql_3 = prepare("select count(id) from device where type=3 and terminal_id=?i",array($terminal_id));
					$total_3 = get_var($sql_3);
				}
				
			}else{
				if(empty($terminal)){
					//设备总数
					$sql_total = prepare("select count(id) from device where project_id=?i",array($module_hanyupinyin));
					$total = get_var($sql_total);
					//控制柜数量 type =1 
					$sql_1 = prepare("select count(id) from device where type=1 and project_id=?i",array($module_hanyupinyin));
					$total_1 = get_var($sql_1);
					//曝气机数量 type=2
					$sql_2 = prepare("select count(id) from device where type=2 and project_id=?i",array($module_hanyupinyin));
					$total_2 = get_var($sql_2);
					//管网设备数量 type=3
					$sql_3 = prepare("select count(id) from device where type=3 and project_id=?i",array($module_hanyupinyin));
					$total_3 = get_var($sql_3);
				}else{
					//设备总数
					$sql_total = prepare("select count(id) from device where project_id=?i and terminal_id=?i",array($module_hanyupinyin,$terminal_id));
					$total = get_var($sql_total);
					//控制柜数量 type =1 
					$sql_1 = prepare("select count(id) from device where type=1 and project_id=?i and terminal_id=?i",array($module_hanyupinyin,$terminal_id));
					$total_1 = get_var($sql_1);
					//曝气机数量 type=2
					$sql_2 = prepare("select count(id) from device where type=2 and project_id=?i and terminal_id=?i",array($module_hanyupinyin,$terminal_id));
					$total_2 = get_var($sql_2);
					//管网设备数量 type=3
					$sql_3 = prepare("select count(id) from device where type=3 and project_id=?i and terminal_id=?i",array($module_hanyupinyin,$terminal_id));
					$total_3 = get_var($sql_3);
				}
			}
		}else{
			if(!empty($module_hanyupinyin)){
				if(empty($terminal)){
					//设备总数
					$sql_total = prepare("select count(id) from device where project_id=?i",array($module_hanyupinyin));
					$total = get_var($sql_total);
					//控制柜数量 type =1 
					$sql_1 = prepare("select count(id) from device where type=1 and project_id=?i",array($module_hanyupinyin));
					$total_1 = get_var($sql_1);
					//曝气机数量 type=2
					$sql_2 = prepare("select count(id) from device where type=2 and project_id=?i",array($module_hanyupinyin));
					$total_2 = get_var($sql_2);
					//管网设备数量 type=3
					$sql_3 = prepare("select count(id) from device where type=3 and project_id=?i",array($module_hanyupinyin));
					$total_3 = get_var($sql_3);
				}else{
					//设备总数
					$sql_total = prepare("select count(id) from device where project_id=?i and terminal_id=?i",array($module_hanyupinyin,$terminal_id));
					$total = get_var($sql_total);
					//控制柜数量 type =1 
					$sql_1 = prepare("select count(id) from device where type=1 and project_id=?i and terminal_id=?i",array($module_hanyupinyin,$terminal_id));
					$total_1 = get_var($sql_1);
					//曝气机数量 type=2
					$sql_2 = prepare("select count(id) from device where type=2 and project_id=?i and terminal_id=?i",array($module_hanyupinyin,$terminal_id));
					$total_2 = get_var($sql_2);
					//管网设备数量 type=3
					$sql_3 = prepare("select count(id) from device where type=3 and project_id=?i and terminal_id=?i",array($module_hanyupinyin,$terminal_id));
					$total_3 = get_var($sql_3);
				}
			}else{
				if(empty($terminal)){
					//设备总数
					$sql_total = prepare("select count(id) from device where project_id=?i ",array($project_id));
					$total = get_var($sql_total);
					//控制柜数量 type =1 
					$sql_1 = prepare("select count(id) from device where type=1 and project_id=?i ",array($project_id));
					$total_1 = get_var($sql_1);
					//曝气机数量 type=2
					$sql_2 = prepare("select count(id) from device where type=2 and project_id=?i ",array($project_id));
					$total_2 = get_var($sql_2);
					//管网设备数量 type=3
					$sql_3 = prepare("select count(id) from device where type=3 and project_id=?i ",array($project_id));
					$total_3 = get_var($sql_3);
				}else{
					//设备总数
					$sql_total = prepare("select count(id) from device where project_id=?i and terminal_id=?i",array($project_id,$terminal_id));
					$total = get_var($sql_total);
					//控制柜数量 type =1 
					$sql_1 = prepare("select count(id) from device where type=1 and project_id=?i and terminal_id=?i",array($project_id,$terminal_id));
					$total_1 = get_var($sql_1);
					//曝气机数量 type=2
					$sql_2 = prepare("select count(id) from device where type=2 and project_id=?i and terminal_id=?i",array($project_id,$terminal_id));
					$total_2 = get_var($sql_2);
					//管网设备数量 type=3
					$sql_3 = prepare("select count(id) from device where type=3 and project_id=?i and terminal_id=?i",array($project_id,$terminal_id));
					$total_3 = get_var($sql_3);
				}
			}
		}

		$data = array('total'=>$total,'total_1'=>$total_1,'total_2'=>$total_2,'total_3'=>$total_3);

		return self::send_resu($data);
	}	

	public function deviceDataTable(){
		// $projectid  = v('project_id');
		$module_hanyupinyin = v("id");
		$terminal = v('terminal');
		$project_id = $_SESSION['project_id'];
		if($project_id == '0'){
			if(empty($module_hanyupinyin)){
				if(empty($terminal)){
					$sql = 'select device.id,project.name as project,terminal.name as terminal,device.name,device.sn,device.type,device.register_address,device.status,device.note,device.longitude,device.latitude from project,terminal,device where project.id=device.project_id and terminal.id=device.terminal_id';
				}else{
					$sql = prepare('select device.id,project.name as project,terminal.name as terminal,device.name,device.sn,device.type,device.register_address,device.status,device.note,device.longitude,device.latitude from project,terminal,device where project.id=device.project_id and terminal.id=device.terminal_id and terminal.name=?s',array($terminal));
				}
			}else{
				if(empty($terminal)){
					$sql = prepare('select device.id,project.name as project,terminal.name as terminal,device.name,device.sn,device.type,device.register_address,device.status,device.note,device.longitude,device.latitude from project,terminal,device where project.id=device.project_id and terminal.id=device.terminal_id and device.project_id=?i',array($module_hanyupinyin));
				}else{
					$sql = prepare('select device.id,project.name as project,terminal.name as terminal,device.name,device.sn,device.type,device.register_address,device.status,device.note,device.longitude,device.latitude from project,terminal,device where project.id=device.project_id and terminal.id=device.terminal_id and device.project_id=?i and terminal.name=?s',array($module_hanyupinyin,$terminal));
				}
			}
		}else{
			if(empty($module_hanyupinyin)){
				if(empty($terminal)){
					$sql = prepare("select device.id,project.name as project,terminal.name as terminal,device.name,device.sn,device.type,device.register_address,device.status,device.note,device.longitude,device.latitude from project,terminal,device where project.id=device.project_id and terminal.id=device.terminal_id and device.project_id=?i ",array($project_id));
				}else{
					$sql = prepare("select device.id,project.name as project,terminal.name as terminal,device.name,device.sn,device.type,device.register_address,device.status,device.note,device.longitude,device.latitude from project,terminal,device where project.id=device.project_id and terminal.id=device.terminal_id and device.project_id=?i and terminal.name=?s",array($project_id,$terminal));
				}
			}else{
				if(empty($terminal)){
					$sql = prepare("select device.id,project.name as project,terminal.name as terminal,device.name,device.sn,device.type,device.register_address,device.status,device.note,device.longitude,device.latitude from project,terminal,device where project.id=device.project_id and terminal.id=device.terminal_id and device.project_id=?i ",array($project_id));
				}else{
					$sql = prepare("select device.id,project.name as project,terminal.name as terminal,device.name,device.sn,device.type,device.register_address,device.status,device.note,device.longitude,device.latitude from project,terminal,device where project.id=device.project_id and terminal.id=device.terminal_id and device.project_id=?i and terminal.name=?s",array($project_id,$terminal));
				}
			}
		}
		$data = get_data($sql);
		$total = count($data);
		return self::send_result($total,$data);
	}

	/**
	 *  返回设备详情
	 */
	public function device_details()
	{
		$device_id = v("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));
		$data['control_count'] = get_var($sql_count);

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

		//基本信息 场站名称 地址 负责人  联系方式
		$sql = prepare("select project.name as project_name,terminal.name as terminal_name,device.name,device.register_address,if(device.status=1,'使用中','实施中') as status,device.created_at from device left join project on project.id = device.project_id left join terminal on terminal.id = device.terminal_id where device.id=?i",array($device_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.id=?i",array($device_id));
		$data['strategy'] = get_var($sql_strategy);

		$sql_controlmodel = prepare("select CASE WHEN control_model = 1 THEN '手动模式' else '自动模式' END from device where id=?i limit 1",array($device_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 = ?i order by id desc limit 1",array($device_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', 'device_details');
		} else {
			header("Location:?c=index&a=index");
		}
	}

	// 设备详情列表
	public function deviceDetailsDataTable(){
		$id = v("id");
		$sql = prepare("select elec_conductivity_data,elec_resistivity_data,elec_conductivity_tds_data,rainfall_data,rainsnow,level_data,ph_data,ammonia_data,created_at from data where device_id = ?i order by created_at desc limit 200",array($id));
		$data = get_data($sql);
		$total = count($data);
		return self::send_result($total,$data);
	}

	public function terminal(){
		$module_hanyupinyin = 1;
		if(empty($module_hanyupinyin)){
			$sql_terminal = prepare("select terminal.id,terminal.name from terminal,project where project.id=terminal.project_id",array($module_hanyupinyin));
			$terminal = get_data($sql_terminal);
		}else{
			$sql_terminal = prepare("select  terminal.id,terminal.name from terminal,project where project.id=terminal.project_id and terminal.project_id=?i",array($module_hanyupinyin));
			$terminal = get_data($sql_terminal);
		}
		return self::send_resu($terminal);
	}

	// 设备修改
	public function device_edit()
	{
		$device_id = v('id');

		$sql = prepare("select device.id,project.name as project_name,terminal.name as terminal_name,device.name,device.register_address as address,device.sn,device.longitude,device.latitude,device.created_at from device left join project on project.id = device.project_id left join terminal on terminal.id = device.terminal_id where device.id=?i",array($device_id));
		$data= get_line($sql);

		render($data, 'web', 'device_edit');
	}

	// 设备修改
	public function device_update()
	{
		$id 		   = $_POST['id'];
		$project_name  = $_POST['project_name'];
		$terminal_name = $_POST['terminal_name'];
		$name 		   = $_POST['name'];
		$address 	   = $_POST['address'];
		$longitude 	   = $_POST['longitude'];
		$latitude 	   = $_POST['latitude'];
		$sn 		   = $_POST['sn'];

		$sql = prepare("update device set name=?s,register_address=?s,longitude=?s,latitude=?s,sn=?s where id=?i",array($name,$address,$longitude,$latitude,$sn,$id));

		$impact = run_sql($sql);

		if($impact)
		{
			$result = "success";
		}else
		{
			$result = "false";
		}
		return self::send_resu($result);
	}
}