| @@ -51,7 +51,7 @@ class Carpark extends CI_Controller | |||||
| // 資料介接模組 | // 資料介接模組 | ||||
| $this->load->model('sync_data_model'); | $this->load->model('sync_data_model'); | ||||
| $this->sync_data_model->init($this->vars); | |||||
| $this->sync_data_model->init($this->vars); // for memcache | |||||
| // mqtt subscribe | // mqtt subscribe | ||||
| $station_setting = $this->sync_data_model->station_setting_query(); | $station_setting = $this->sync_data_model->station_setting_query(); | ||||
| @@ -60,6 +60,9 @@ class Carpark extends CI_Controller | |||||
| $this->vars['mqtt'] = new phpMQTT($mqtt_ip, $mqtt_port, uniqid()); | $this->vars['mqtt'] = new phpMQTT($mqtt_ip, $mqtt_port, uniqid()); | ||||
| $this->vars['mqtt']->connect(); | $this->vars['mqtt']->connect(); | ||||
| // init again | |||||
| $this->sync_data_model->init($this->vars); // for mqtt | |||||
| // 產生 excel 報表 | // 產生 excel 報表 | ||||
| $this->load->model('excel_model'); | $this->load->model('excel_model'); | ||||
| $this->excel_model->init($this->vars); | $this->excel_model->init($this->vars); | ||||
| @@ -98,7 +98,7 @@ class Cars extends CI_Controller | |||||
| // 資料介接模組 | // 資料介接模組 | ||||
| $this->load->model('sync_data_model'); | $this->load->model('sync_data_model'); | ||||
| $this->sync_data_model->init($this->vars); | |||||
| $this->sync_data_model->init($this->vars); // for memcache | |||||
| // mqtt subscribe | // mqtt subscribe | ||||
| $station_setting = $this->sync_data_model->station_setting_query(); | $station_setting = $this->sync_data_model->station_setting_query(); | ||||
| @@ -106,6 +106,9 @@ class Cars extends CI_Controller | |||||
| $mqtt_port = isset($station_setting['mqtt_port']) ? $station_setting['mqtt_port'] : MQ_PORT; | $mqtt_port = isset($station_setting['mqtt_port']) ? $station_setting['mqtt_port'] : MQ_PORT; | ||||
| $this->vars['mqtt'] = new phpMQTT($mqtt_ip, $mqtt_port, uniqid()); | $this->vars['mqtt'] = new phpMQTT($mqtt_ip, $mqtt_port, uniqid()); | ||||
| $this->vars['mqtt']->connect(); | $this->vars['mqtt']->connect(); | ||||
| // init again | |||||
| $this->sync_data_model->init($this->vars); // for mqtt | |||||
| $this->load->model('cars_model'); | $this->load->model('cars_model'); | ||||
| $this->cars_model->init($this->vars); | $this->cars_model->init($this->vars); | ||||
| @@ -91,7 +91,7 @@ class Pks extends CI_Controller | |||||
| // 資料介接模組 | // 資料介接模組 | ||||
| $this->load->model('sync_data_model'); | $this->load->model('sync_data_model'); | ||||
| $this->sync_data_model->init($this->vars); | |||||
| $this->sync_data_model->init($this->vars); // for memcache | |||||
| // mqtt subscribe | // mqtt subscribe | ||||
| $station_setting = $this->sync_data_model->station_setting_query(); | $station_setting = $this->sync_data_model->station_setting_query(); | ||||
| @@ -99,6 +99,9 @@ class Pks extends CI_Controller | |||||
| $mqtt_port = isset($station_setting['mqtt_port']) ? $station_setting['mqtt_port'] : MQ_PORT; | $mqtt_port = isset($station_setting['mqtt_port']) ? $station_setting['mqtt_port'] : MQ_PORT; | ||||
| $this->vars['mqtt'] = new phpMQTT($mqtt_ip, $mqtt_port, uniqid()); | $this->vars['mqtt'] = new phpMQTT($mqtt_ip, $mqtt_port, uniqid()); | ||||
| $this->vars['mqtt']->connect(); | $this->vars['mqtt']->connect(); | ||||
| // init again | |||||
| $this->sync_data_model->init($this->vars); // for mqtt | |||||
| } | } | ||||