altob.st123/models/Pks_model.php

<?php
/*
file: pks_model.php 	車位在席資料庫處理模組
*/

class Pks_model extends CI_Model
{
    var $vars = array();

	function __construct()
	{
		parent::__construct();
		$this->load->database();
    }

	public function init($vars)
	{
		$this->vars = $vars;
    }


    // 車輛進出傳入車牌號碼
    public function pksio($parms)
	{
    	switch($parms['io'])
        {
          	case 'KL':	// 車輛入席車辨(lpr)及圖檔
            	if ($parms['lpr'] == 'NONE')	// 在席車辨失敗, 不處理
                {
                  	trigger_error('在席車辨失敗' . print_r($parms, true));
                    return false;	// 中斷
                }
				
				$new_file_name = "pks-{$parms['pksno']}-{$parms['lpr']}-{$parms['ivsno']}-" . date('Ymd') .".jpg";
				$test_check_str = file_exists(PKS_PIC . $new_file_name) ? 'exists' : 'not_exists';
				trigger_error(__FUNCTION__ . '..' . PKS_PIC . $new_file_name . '..' . $test_check_str);
				
				// 清除舊照片
				foreach(glob(PKS_PIC."pks-{$parms['pksno']}-*.jpg") as $old_file_path)
				{
					if($old_file_path != PKS_PIC . $new_file_name)
					{
						unlink($old_file_path);
						trigger_error('remove old image:'. $old_file_path. ', replace by: ' . $new_file_name);
					}
				}
				
				$parms['pic_name'] = $new_file_name;
				
				if(!file_exists(PKS_PIC . $new_file_name))
				{				
					$config['upload_path'] = PKS_PIC;
					$config['allowed_types'] = 'gif|jpg|png';
					$config['file_name'] = $new_file_name;
					
					$this->load->library('upload', $config);

					if($this->upload->do_upload('cars'))
					{
						// 若無錯誤，則上傳檔案
						$file = $this->upload->data('cars');
					}
					else
					{
						trigger_error('入席傳檔錯誤:'. print_r($parms, true));
					}	
				}
				
            	// 讀取在席資料(pks)
                $rows_pks = $this->db
        					->select('cario_no, lpr, status, confirms, pic_name')
        					->from('pks')
                			->where(array('pksno' => $parms['pksno'], 'station_no' => $parms['sno']))
                  			->limit(1)
                			->get()
                			->row_array();

                trigger_error('KL read pks:'.print_r($rows_pks, true));
				
				// 如果在席表未建立, 自動產生
				if($this->gen_pks_row($rows_pks, $parms))
				{
					trigger_error(__FUNCTION__ . '..auto gen pks..' . print_r($parms, true));
				}
				
                // 如果已經人工確認或之前已比對有入場資料者, 則重覆再送來的車辨不予理會
				if (($rows_pks['confirms'] == 1 || $rows_pks['lpr'] == $parms['lpr']) && $rows_pks['pic_name'] == $parms['pic_name'])
                {
                	trigger_error('KL ignored:'.$rows_pks['lpr']);
					return true;	// 中斷
                }
				
				// 讀取進場時間, 如讀不到資料, 以目前時間取代(add by TZUSS 2016-02-23)
				$rows_cario = $this->db
								->select('cario_no, in_time')
								->from('cario')
								->where(array('in_out' => 'CI', 'obj_id' => $parms['lpr'], 'finished' => 0, 'err' => 0, 'station_no' => $parms['sno']))
								->order_by('cario_no', 'desc')
								->limit(1)
								->get()
								->row_array();
				if (!empty($rows_cario['cario_no']))		// 有入場資料
				{
					$cario_no = $rows_cario['cario_no'];	// 入場序號
					$in_time = $rows_cario['in_time'];
					// 在席與入場資料相符, 分別在cario與pks記錄之
					$data_cario = array
					(
						'pksno' => $parms['pksno'],
						'pks_time' => date('Y-m-d H:i:s')
					);
					$this->db->update('cario', $data_cario, array('cario_no' => $cario_no, 'station_no' => $parms['sno']));
				}
				else	// 查無入場資料, 即時通知
				{
					$cario_no = 0;
					$in_time = date('Y-m-d H:i:s');
					trigger_error('在席無進場資料:'. print_r($parms, true));
				}
					
				$data = array
				(
					'cario_no' => $cario_no,
					'lpr' => $parms['lpr'],
					'status' => 'LR',	// 車格佔用並有車號
					'confirms' => 0,    // 預設人工未確認
					'pic_name' => $parms['pic_name'],
					'in_time' => $in_time
				);
				// 車號及照片檔名填入資料庫內
				$this->db->update('pks', $data, array('pksno' => $parms['pksno'], 'station_no' => $parms['sno']));
				break;

          	case 'KI':	// 車輛入席, 各區空車位與佔位各加減1
    			$rows = $this->db->select('status')
        			->from('pks')
                    ->where(array('pksno' => $parms['pksno'], 'station_no' => $parms['sno']))
                    ->get()
                    ->row_array();
					
				// 如果在席表未建立, 自動產生
				if($this->gen_pks_row($rows, $parms))
				{
					trigger_error(__FUNCTION__ . '..auto gen pks..' . print_r($parms, true));
				}
					
                // if (!empty($rows['status']) && $rows['status'] == 'LR')	break;	// 仍有車在席, 不應再有KI, ignore
                if (!empty($rows['status']) && $rows['status'] == 'LR')	return true;	// 仍有車在席, 不應再有KI, ignore

        		$data = array
            	(
                	'cario_no' => 0,
              		'lpr' => '',
                	'status' => 'OC',	// 車格佔用但尚無車號
                    'confirms' => 0,
                	'pic_name' => '',
                    'in_time' => null
            	);
            	$this->db->update('pks', $data, array('pksno' => $parms['pksno'], 'station_no' => $parms['sno']));
            	break;

          	case 'KO':	// 車輛離席, 各區空車位與佔位各加減1
        		$data = array
            	(
                	'cario_no' => 0,
              		'lpr' => '',
                	'status' => 'VA',	// 車格佔用但尚無車號
                    'confirms' => 0,
                	'pic_name' => '',
                    'in_time' => null
            	);
            	$this->db->update('pks', $data, array('pksno' => $parms['pksno'], 'station_no' => $parms['sno']));
            	break;
        }

		// 找出與與此車位相關的群組
    	$sql = "select group_id, tot, renum, availables, station_no
        		from pks_groups
				where group_id in
        		(select group_id from pks_group_member where station_no = {$parms['sno']} and pksno = {$parms['pksno']})";

        $retults = $this->db->query($sql)->result_array();

        foreach ($retults as $rows)
        {
        	// 計算群組異動後的空車位數, 先讀出已停車位數
        	//$sql = "select count(*) as parked from pks where status != 'VA' and pksno in (select pksno from pks_group_member where group_id = '{$rows['group_id']}')";
			$sql = "select count(*) as parked from pks where lpr != '' and pksno in (select pksno from pks_group_member where group_id = '{$rows['group_id']}')";
            $row_group = $this->db->query($sql)->row_array();
            $group_va = $rows['tot'] + $rows['renum'] -  $row_group['parked'];	// 群組空車位數

			// 有變動才處理更新
			if($rows['availables'] != $group_va) 
			{
				// 防止負值
				if($group_va < 0){
					$group_va = 0;
				}
				
				$group_va_pad = str_pad($group_va, 3, '0', STR_PAD_LEFT); // 補零
				$this->db->update('pks_groups', array('parked' => $row_group['parked'], 'availables' => $group_va), array('group_id' => $rows['group_id']));

				//$this->vars['mqtt']->publish(MQ_TOPIC_SUBLEVEL, "{$rows['group_id']},{$group_va_pad}", 0);			// 送出剩餘車位數給字幕機
				$this->mq_send(MQ_TOPIC_SUBLEVEL, "{$rows['group_id']},{$group_va_pad}");

				if($rows['station_no'] == 12171)
				{
					$this->carno_updata_12171();
				}
				else if($rows['station_no'] == 40668)
				{
					$this->carno_updata_40668();
				}
			}
        }
		
		return true;
    }
	
	// 如果在席表未建立, 自動產生
	function gen_pks_row($rows, $parms)
	{
		if(empty($rows['status']))
		{
			$new_pks_data = array( 'station_no' => $parms['sno'], 'pksno' => $parms['pksno'], 'prioritys' => $parms['pksno'] );
			$this->db->insert('pks', $new_pks_data);
			trigger_error(__FUNCTION__ . '://..'. print_r($new_pks_data, true));
			return true;
		}
		return false;
	}

	 // 送出至message queue(目前用mqtt)
	function mq_send($topic, $msg)
	{
		$this->vars['mqtt']->publish($topic, $msg, 0);
    	trigger_error("mqtt:{$topic}|{$msg}");
		usleep(300000); // delay 0.3 sec (避免漏訊號)
    }

    // 重新計算
    public function reculc()
	{
        // 找出與與此車位相關的群組
    	$sql = "select group_id, tot, renum
        		from pks_groups";

        $retults = $this->db->query($sql)->result_array();

        foreach ($retults as $rows)
        {
        	// 計算群組異動後的空車位數, 先讀出已停車位數
        	$sql = "select count(*) as parked from pks where status != 'VA' and pksno in (select pksno from pks_group_member where group_id = '{$rows['group_id']}')";
            $row_group = $this->db->query($sql)->row_array();
            $group_va = $rows['tot'] + $rows['renum'] -  $row_group['parked'];	// 群組空車位數
            $this->db->update('pks_groups', array('parked' => $row_group['parked'], 'availables' => $group_va), array('group_id' => $rows['group_id']));

            // $this->vars['mqtt']->publish("VA-{$rows['group_id']}", "{$group_va}", 0);			// 送出剩餘車位數給字幕機

            get_headers("http://192.168.51.15/set_num.php?group_id={$rows['group_id']}&num={$group_va}");

            echo "group_id:{$rows['group_id']}, tot:{$rows['tot']}, availables:{$group_va}, parked:{$row_group['parked']}, renum:{$rows['renum']}<br />";
        }
    }

	// 取得所有車位使用狀態
	public function query_station_status($station_no)
	{
		/* 沒有group_id, pks不能直接用, 要多撈兩張表

		$sql = "select pksno, posx, posy, in_time
        		FROM pks
				WHERE station_no = '".$station_no."' and lpr != ''";
		*/
		$sql = "SELECT 	pks.pksno AS pksno, pks.posx AS posx, pks.posy AS posy, pks.in_time AS in_time,
						pks_groups.group_id AS group_id
        		FROM pks
				LEFT JOIN pks_group_member ON pks.pksno = pks_group_member.pksno AND pks.station_no = pks_group_member.station_no
				LEFT JOIN pks_groups ON pks_group_member.group_id = pks_groups.group_id
				WHERE pks.lpr != '' AND pks.station_no = '".$station_no."' AND pks_groups.group_type = '1' ";

        $retults = $this->db->query($sql)->result_array();

		$currentTime = new DateTime("now");
		foreach ($retults as $idx => $rows)
        {
			$startTime = new DateTime($rows['in_time']); // 進場時間
			$interval = $startTime->diff($currentTime);
			$status = $this->gen_pks_s($interval); // 一般:0, 隔日:1, 超過3日:3, 隔週:7, 隔20日:20

			$data['result'][$idx] = array
            (
				'g'=> $rows['group_id'],
				'id'=> $rows['pksno'],
            	'x' => $rows['posx'],
            	'y' => $rows['posy'],
				's' => $status
            );
		}
		return $data;
	}

	// 取得車位狀態
	private function gen_pks_s($interval)
	{
		$status = 0; // 一般:0, 隔日:1, 超過3日:3, 隔週:7, 隔20日:20
		if($interval->y > 0 || $interval->m > 0 || $interval->d >= 20){
			$status = 20;
		}else if($interval->d >= 7){
			$status = 7;
		}else if($interval->d >= 3){
			$status = 3;
		}else if($interval->d >= 1){
			$status = 1;
		}
		return $status;
	}

	// 取得指定車位使用狀態
	public function query_station_pks($station_no, $pksno)
	{
		$sql = "SELECT 	pks.pksno AS pksno, pks.lpr AS lpr, pks.in_time AS in_time, pks.station_no AS station_no,
						pks_groups.group_id AS group_id, pks_groups.group_name AS group_name, pks_groups.group_type AS type
        		FROM pks
				LEFT JOIN pks_group_member ON pks.pksno = pks_group_member.pksno AND pks.station_no = pks_group_member.station_no
				LEFT JOIN pks_groups ON pks_group_member.group_id = pks_groups.group_id
				WHERE pks.pksno = '".$pksno."' AND pks.station_no = '".$station_no."' AND pks_groups.group_type = '1' ";

        $retults = $this->db->query($sql)->result_array();

		$currentTime = new DateTime("now");
		foreach ($retults as $idx => $rows)
        {
			$startTime = new DateTime($rows['in_time']); // 進場時間
			$interval = $startTime->diff($currentTime);
			$status = $this->gen_pks_s($interval); // 一般:0, 隔日:1, 超過3日:3, 隔週:7, 隔20日:20

			$data['result'][$idx] = array
            (
				'pksno'=> $rows['pksno'],
				'lpr' => $rows['lpr'],
				'time' => $rows['in_time'],
				'station_no' => $rows['station_no'],
				'group_id' => $rows['group_id'],
				'group_name' => $rows['group_name'],
				'status' => $status
            );
		}
		return $data;
	}

	//40668紅樹林特殊計數
	public function carno_updata_40668()
	{
		$sql = "SELECT (B.parked - A.sum_parked) as parked, (B.tot - A.sum_tot) - (B.parked - A.sum_parked) as availables FROM (SELECT SUM(parked) as sum_parked,SUM(tot) as sum_tot FROM pks_groups WHERE group_type > 1 AND group_id !=\"3F\") A, pks_groups B WHERE B.group_id = \"C888\"";
		$result = $this->db->query($sql)->result_array();
		$sql = "UPDATE `pks_groups` SET `parked`={$result[0]['parked']},`availables`={$result[0]['availables']} WHERE group_id = \"3F\";";
		$this->db->query($sql);
		$this->mq_send(MQ_TOPIC_SUBLEVEL, "3F,{$result[0]['availables']}");
	}

	//12171金城特殊計數
	public function carno_updata_12171()
	{
		$sql = "SELECT (B.parked - A.sum_parked) as parked, (B.tot - A.sum_tot) - (B.parked - A.sum_parked) as availables FROM (SELECT SUM(parked) as sum_parked,SUM(tot) as sum_tot FROM pks_groups WHERE group_id !=\"RF\" AND group_type > 1) A, pks_groups B WHERE B.group_id = \"P1\"";
		$result = $this->db->query($sql)->result_array();
		$sql = "UPDATE `pks_groups` SET `parked`={$result[0]['parked']},`availables`={$result[0]['availables']} WHERE group_id = \"RF\";";
		$this->db->query($sql);
		$this->mq_send(MQ_TOPIC_SUBLEVEL, "RF,{$result[0]['availables']}");
	}

}