From aa59fcad64c630c356ea8c1139c4951bacc7317f Mon Sep 17 00:00:00 2001
From: QxQ <ch19940729@gmail.com>
Date: Fri, 11 Jan 2019 16:36:07 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=AD=A3mqtt=E6=A8=A1=E7=B5=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 models/Carpayment_model.php | 8 ++++++++
 1 file changed, 8 insertions(+)

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 (避免漏訊號)
     }
 	
 }