weigang 5 years ago
parent
commit
cc3b2eb749
  1. 2
      app/Controller/NotifyController.php
  2. 1
      app/Service/MqttSpeakerService.php

2
app/Controller/NotifyController.php

@ -140,7 +140,7 @@ class NotifyController extends BaseController
->update(['score' => Db::raw('score+1')]);
// 更新商品库存和销量
$orders = Order::query()->select(['id', 'money', 'user_id', 'store_id'])
$orders = Order::query()->select(['id', 'money', 'user_id', 'store_id', 'pay_time'])
->where(['order_main_id' => $orderMain->id])
->get()
->toArray();

1
app/Service/MqttSpeakerService.php

@ -5,6 +5,7 @@ namespace App\Service;
use App\Model\Order;
use App\Model\Store;
use App\TaskWorker\MQTTClientTask;
use Hyperf\Utils\ApplicationContext;
class MqttSpeakerService implements MqttServiceInterface
{

Loading…
Cancel
Save