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