MeasuringMachineQueue.php 1.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. <?php
  2. namespace App\Jobs;
  3. use App\Events\WeighedEvent;
  4. use App\MeasuringMachine;
  5. use App\OrderPackage;
  6. use Carbon\Carbon;
  7. use Illuminate\Bus\Queueable;
  8. use Illuminate\Queue\SerializesModels;
  9. use Illuminate\Queue\InteractsWithQueue;
  10. use Illuminate\Contracts\Queue\ShouldQueue;
  11. use Illuminate\Foundation\Bus\Dispatchable;
  12. /**
  13. * @Deprecated 设备状态推送
  14. */
  15. class MeasuringMachineQueue implements ShouldQueue
  16. {
  17. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  18. protected $measuringMachine;
  19. /**
  20. * Create a new job instance.
  21. *
  22. * @param MeasuringMachine$measuringMachine
  23. *
  24. * @return void
  25. */
  26. public function __construct(MeasuringMachine $measuringMachine)
  27. {
  28. $this->measuringMachine=$measuringMachine;
  29. }
  30. /**
  31. * Execute the job.
  32. *
  33. * @return void
  34. */
  35. public function handle()
  36. {
  37. if ($this->measuringMachine->updated_at<Carbon::now()->subMinutes(30)){
  38. $this->measuringMachine->status="离线";
  39. $this->measuringMachine->save();
  40. $package=OrderPackage::with(['order'=>function($query){
  41. $query->with('owner','logistic');
  42. },'paperBox','measuringMachine'])->
  43. where('measuring_machine_id',$this->measuringMachine->id)->orderBy('id','DESC')->first();
  44. if (!$package){
  45. $package=new OrderPackage();
  46. if ($this->measuringMachine)$package->measuringMachine=$this->measuringMachine;
  47. }
  48. event(new WeighedEvent($package));
  49. }
  50. }
  51. }