AutoSendPayOrderSmsListen.php 947 B

12345678910111213141516171819202122232425262728293031323334
  1. <?php
  2. namespace ln\listens;
  3. use app\common\repositories\store\order\StoreGroupOrderRepository;
  4. use ln\interfaces\ListenerInterface;
  5. use ln\jobs\SendSmsJob;
  6. use ln\services\TimerService;
  7. use Swoole\Timer;
  8. use think\facade\Queue;
  9. class AutoSendPayOrderSmsListen extends TimerService implements ListenerInterface
  10. {
  11. public function handle($event): void
  12. {
  13. $this->tick(1000 * 60 * 5, function () {
  14. $storeGroupOrderRepository = app()->make(StoreGroupOrderRepository::class);
  15. $time = date('Y-m-d H:i:s', strtotime("- 10 minutes"));
  16. $groupOrderIds = $storeGroupOrderRepository->getTimeOutIds($time, true);
  17. foreach ($groupOrderIds as $id) {
  18. Queue::push(SendSmsJob::class, [
  19. 'tempId' => 'ORDER_PAY_FALSE',
  20. 'id' => $id
  21. ]);
  22. $storeGroupOrderRepository->isRemind($id);
  23. }
  24. });
  25. }
  26. }