diff --git a/models/Carpayment_model.php b/models/Carpayment_model.php index e0976d5..954e3e0 100644 --- a/models/Carpayment_model.php +++ b/models/Carpayment_model.php @@ -865,6 +865,14 @@ class Carpayment_model extends CI_Model $results = $this->db->query($sql)->result_array(); return $results; + } + + // 送出至message queue(目前用mqtt) + public function mq_send($topic, $msg) + { + $this->vars['mqtt']->publish($topic, $msg, 0); + trigger_error("mqtt:{$topic}|{$msg}"); + usleep(100000); // delay 0.1 sec (避免漏訊號) } }