diff --git a/app/Amqp/Consumer/DevicOrderConsumer.php b/app/Amqp/Consumer/DevicOrderConsumer.php index 773f0dd..2bf258a 100644 --- a/app/Amqp/Consumer/DevicOrderConsumer.php +++ b/app/Amqp/Consumer/DevicOrderConsumer.php @@ -35,8 +35,16 @@ class DevicOrderConsumer extends ConsumerMessage ->where(['order_main_id' => $orderMainId, 'type' => 4, 'dm_state' => 2]) ->first(); + if (is_null($order)||!$order) { + return Result::REQUEUE; + } + $deviceName = SpeakerDevic::query()->where(['store_id' => $order['store_id']])->value('device_name'); + if (is_null($deviceName)||!$deviceName) { + return Result::REQUEUE; + } + $msg = "{\"msg\":\"到账".$order['money']."元\"}"; $res = $this->deviceService->pubMsgToStoreByDevName($deviceName, $msg);