Browse Source

订单或设备号异常直接ACK应答

master
weigang 5 years ago
parent
commit
b81edf8cd5
  1. 4
      app/Amqp/Consumer/DevicOrderConsumer.php

4
app/Amqp/Consumer/DevicOrderConsumer.php

@ -36,7 +36,7 @@ class DevicOrderConsumer extends ConsumerMessage
->first(); ->first();
if (is_null($order)||!$order) { if (is_null($order)||!$order) {
return Result::REQUEUE;
return Result::ACK;
} }
$deviceNames = SpeakerDevic::query() $deviceNames = SpeakerDevic::query()
@ -46,7 +46,7 @@ class DevicOrderConsumer extends ConsumerMessage
->toArray(); ->toArray();
if (empty($deviceNames)||!$deviceNames) { if (empty($deviceNames)||!$deviceNames) {
return Result::REQUEUE;
return Result::ACK;
} }
$msg = "{\"msg\":\"到账".$order['money']."\"}"; $msg = "{\"msg\":\"到账".$order['money']."\"}";

Loading…
Cancel
Save