altob.st123/controllers/reports/Update_pks_groups_40701.php

<?php
defined('BASEPATH') OR exit('No direct script access allowed');
require_once('/home/bigbang/libs/phplibs/phpMQTT.php');

class Update_pks_groups extends CI_Controller {

    public function __construct() {
        parent::__construct();
		$this->load->model('reports/Update_pks_groups_model','update_pks_groups');


    }



	public function index()
	{
		
		$station_no="40704";
		$group_type="2";
		
		$sel_pks_groups=$this->update_pks_groups->sel_pks_groups($station_no,$group_type);
		
		foreach($sel_pks_groups as $key0 => $value0){
			$station_no0=$value0['station_no'];
			$fgroup_id=$value0['group_id'];
					
			$sel_pks_all=$this->update_pks_groups->sel_pks_all($station_no, $fgroup_id);
			$sel_pks=$this->update_pks_groups->sel_pks($station_no, $fgroup_id);
			
			$data[$fgroup_id]=array(count($sel_pks_all),count($sel_pks),count($sel_pks_all)-count($sel_pks));
			
			$data0=array("tot"=>count($sel_pks_all),"parked"=>count($sel_pks),"availables"=>count($sel_pks_all)-count($sel_pks),"renum"=>count($sel_pks_all)-count($sel_pks));
			
			$this->update_pks_groups->update_pks_groups($data0, $fgroup_id);
		}
		
		//植物園
		$group_id1="P1";
		$gb_data=array('B1','B2');
		$data1=array();
		$data1tot0=0;
		$data1tot1=0;
		$data1tot2=0;
		foreach($gb_data as $key1=>$value1){
			
			$data1=$data[$value1];
			$data10=$data1[0];
			$data11=$data1[1];
			$data12=$data1[2];
			$data1tot0=$data1tot0+$data10;
			$data1tot1=$data1tot1+$data11;
			$data1tot2=$data1tot2+$data12;
			
		}
			$data19=array("tot"=>$data1tot0,"parked"=>$data1tot1,"availables"=>$data1tot2,"renum"=>$data1tot2);
			$this->update_pks_groups->update_pks_groups($data19, $group_id1);
		
		//植物園
		$group_id2="C888";
		$gb_data=array('B1','B2');
		$data2=array();
		$data2tot0=0;
		$data2tot1=0;
		$data2tot2=0;
		foreach($gb_data as $key2=>$value2){
			
			$data2=$data[$value2];
			$data20=$data2[0];
			$data21=$data2[1];
			$data22=$data2[2];
			$data2tot0=$data2tot0+$data20;
			$data2tot1=$data2tot1+$data21;
			$data2tot2=$data2tot2+$data22;
			
		}
			$data29=array("tot"=>$data2tot0,"parked"=>$data2tot1,"availables"=>$data2tot2,"renum"=>$data2tot2);
			$this->update_pks_groups->update_pks_groups($data29, $group_id2);
		
		
		$sel_pks_groups_all=$this->update_pks_groups->sel_pks_groups_all();
		
		foreach($sel_pks_groups_all as $key99 => $value99){
			$topic="SUBLEVEL";
			$mode=$value99['floors'];
			$floors=$value99['floors'];
			$availables=$value99['availables'];
			$mqtt_string=$floors.','.$availables;
			
//			$this->mq_send($topic, $mqtt_string);
			
		}
		
		

	}
	

	public function mq_send($topic, $msg)
	{
		// 取得 mqtt 設定
		$mqtt_ip = 'localhost';
		$mqtt_port = '1883';
		trigger_error("mqtt: {$mqtt_ip}:{$mqtt_port}");
		
		// mqtt subscribe
		$mqtt = new phpMQTT($mqtt_ip, $mqtt_port, uniqid());
		if($mqtt->connect()){ 

			$mqtt->publish($topic, $msg, 0);
		}
    	trigger_error("mqtt:{$topic}|{$msg}");
    }

	
	
}