|
|
|
@ -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(); |
|
|
|
|