ReportCharge.php 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. <?php
  2. namespace App\Jobs\Callback;
  3. use App\Service\Callback\JuliangAccountReportChargeService;
  4. use App\Service\Util\Support\Trace\TraceContext;
  5. use Illuminate\Bus\Queueable;
  6. use Illuminate\Contracts\Queue\ShouldBeUnique;
  7. use Illuminate\Contracts\Queue\ShouldQueue;
  8. use Illuminate\Foundation\Bus\Dispatchable;
  9. use Illuminate\Queue\InteractsWithQueue;
  10. use Illuminate\Queue\SerializesModels;
  11. use Predis\Command\Traits\DB;
  12. class ReportCharge implements ShouldQueue
  13. {
  14. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  15. /***
  16. * @var array
  17. * <pre>
  18. * [
  19. * 'uid' => '1',
  20. * 'orderId' => 1
  21. * 'ranseId' => 1,
  22. * ]
  23. * </pre>
  24. */
  25. private $info;
  26. /**
  27. * Create a new job instance.
  28. */
  29. public function __construct($info)
  30. {
  31. $this->info = $info;
  32. }
  33. /**
  34. * Execute the job.
  35. */
  36. public function handle(): void
  37. {
  38. /**
  39. * 1, 所有的订单日志都记录
  40. */
  41. $traceContext = TraceContext::newFromParent($this->info['traceInfo']);
  42. myLog('reportCharge')->info('开始处理订单回传', [
  43. 'orderInfo' => $this->info,
  44. 'traceInfo' => $traceContext->getTraceInfo()
  45. ]);
  46. $reportService = new JuliangAccountReportChargeService($this->info['uid'], $this->info['orderId'], $this->info['traceInfo']);
  47. $reportService->report();
  48. }
  49. }