From 8145b74169ef66c9e12663f2d4ca5b60d1f70dd0 Mon Sep 17 00:00:00 2001 From: weigang Date: Fri, 14 Aug 2020 15:04:00 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E6=8E=89Debug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/Libs/MQTTClient.php | 4 ---- app/Service/MqttSpeakerService.php | 7 +------ 2 files changed, 1 insertion(+), 10 deletions(-) diff --git a/app/Libs/MQTTClient.php b/app/Libs/MQTTClient.php index 7c02ad7..0d08a87 100644 --- a/app/Libs/MQTTClient.php +++ b/app/Libs/MQTTClient.php @@ -219,7 +219,6 @@ class MQTTClient { */ public function sendConnect($clientId, $cleanSession=false, $keepAlive=10, $timeout=5000) { - var_dump('serverAddress', $this->serverAddress); if (!$this->serverAddress) return false; // Basic validation of clientid @@ -392,9 +391,7 @@ class MQTTClient { * @return boolean */ public function sendPublish($topic, $message, $qos = self::MQTT_QOS1, $retain = 0) { - var_dump('connect:', $this->isConnected()); if(!$this->isConnected()) return false; -var_dump('sendpublish', [$topic, $message, $qos]); if($qos!=self::MQTT_QOS0 && $qos!=self::MQTT_QOS1 && $qos!=self::MQTT_QOS2) return false; $packetId = $this->getNextPacketId(); @@ -408,7 +405,6 @@ var_dump('sendpublish', [$topic, $message, $qos]); $dupFlag = 0; $header = $this->createHeader(self::MQTT_PUBLISH + ($dupFlag<<3) + ($qos<<1) + $retain, $payload); $this->debugMessage('Sending PUBLISH'); - var_dump('sendpublish-$payload', $header.$payload); $this->send($header . $payload); if($qos == self::MQTT_QOS1) { diff --git a/app/Service/MqttSpeakerService.php b/app/Service/MqttSpeakerService.php index 617eb3a..d058ae7 100644 --- a/app/Service/MqttSpeakerService.php +++ b/app/Service/MqttSpeakerService.php @@ -17,7 +17,7 @@ class MqttSpeakerService implements MqttServiceInterface */ public function speakToStore($orderId, $isMain = true) { - var_dump('speaker-orderid', $orderId); + // 获取订单 $orders = Order::query()->select(['id','order_num','money', 'pay_type', 'store_id', 'type']); if ($isMain) { @@ -26,8 +26,6 @@ class MqttSpeakerService implements MqttServiceInterface $orders = $orders->where(['id' => $orderId])->get()->toArray(); } - var_dump('speaker-orders', $orders); - if(empty($orders)) return; // 循环发送 @@ -35,10 +33,8 @@ class MqttSpeakerService implements MqttServiceInterface $order['template'] = "懒族支付到账".floatval($order['money'])."元"; // 获取终端ID $order['to_client_id'] = Store::query()->where(['id' => $order['store_id']])->value('loudspeaker_imei'); - var_dump('speaker-$order', $order); // 发布订阅消息 $res = $this->publish($order['template'], self::TOPIC, $order['to_client_id']); - var_dump('speaker-$res', $res); } } @@ -76,7 +72,6 @@ class MqttSpeakerService implements MqttServiceInterface $curClientId OR $curClientId = (string)rand(1,999999999); $success = $client->sendConnect($curClientId); - var_dump('$success', $success); if ($success) { $client->sendPublish($topic, json_encode($msgArr), MQTTClient::MQTT_QOS2); $client->sendDisconnect();