TestMq.php 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556
  1. <?php
  2. namespace App\Console\Commands;
  3. use Illuminate\Console\Command;
  4. use App\Http\Api\Mq;
  5. use App\Models\Discussion;
  6. use App\Http\Resources\DiscussionResource;
  7. use Illuminate\Support\Str;
  8. class TestMq extends Command
  9. {
  10. /**
  11. * The name and signature of the console command.
  12. *
  13. * @var string
  14. */
  15. protected $signature = 'test:mq {--discussion=}';
  16. /**
  17. * The console command description.
  18. *
  19. * @var string
  20. */
  21. protected $description = 'Command description';
  22. /**
  23. * Create a new command instance.
  24. *
  25. * @return void
  26. */
  27. public function __construct()
  28. {
  29. parent::__construct();
  30. }
  31. /**
  32. * Execute the console command.
  33. *
  34. * @return int
  35. */
  36. public function handle()
  37. {
  38. if(\App\Tools\Tools::isStop()){
  39. return 0;
  40. }
  41. Mq::publish('hello',['hello world']);
  42. $discussion = $this->option('discussion');
  43. if($discussion && Str::isUuid($discussion)){
  44. Mq::publish('discussion',new DiscussionResource(Discussion::find($discussion)));
  45. }
  46. return 0;
  47. }
  48. }