lanzu_api_2021-12-26/app/Service/MqttSpeakerService.php

<?php

namespace App\Service;

use App\Model\Order;
use App\Model\Store;
use App\TaskWorker\MQTTClientTask;
use Hyperf\Utils\ApplicationContext;

class MqttSpeakerService implements MqttServiceInterface
{

    const TOPIC = 'test01';

    /**
     * @inheritDoc
     */
    public function speakToStore($orderId, $isMain = true)
    {

        // 获取订单
        $orders = Order::query()->select(['id','order_num','money', 'pay_type', 'store_id', 'type']);
        if ($isMain) {
            $orders = $orders->where(['order_main_id' => $orderId])->get()->toArray();
        } else {
            $orders = $orders->where(['id' => $orderId])->get()->toArray();
        }

        if(empty($orders)) return;

        // 循环发送
        foreach ($orders as $k => &$order) {
            $order['template'] = "懒族生活支付到账".floatval($order['money'])."元";
            // 获取终端ID
            $order['to_client_id'] = Store::query()->where(['id' => $order['store_id']])->value('loudspeaker_imei');
            // 发布订阅消息
            $this->pubToMqtt($order['template'], self::TOPIC, $order['to_client_id']);
        }
    }

    /**
     * @inheritDoc
     */
    public function pubToMqtt($message, $topic, $toClientId)
    {
        $task = ApplicationContext::getContainer()->get(MQTTClientTask::class);
        $task->publish($message, $topic, $toClientId);
    }
}