AddRadarPlugin.php 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. <?php
  2. declare(strict_types=1);
  3. namespace Yansongda\Pay\Plugin\Unipay;
  4. use Closure;
  5. use GuzzleHttp\Psr7\Request;
  6. use Yansongda\Artful\Contract\PluginInterface;
  7. use Yansongda\Artful\Exception\ContainerException;
  8. use Yansongda\Artful\Exception\InvalidParamsException;
  9. use Yansongda\Artful\Exception\ServiceNotFoundException;
  10. use Yansongda\Artful\Logger;
  11. use Yansongda\Artful\Rocket;
  12. use function Yansongda\Artful\get_radar_method;
  13. use function Yansongda\Pay\get_provider_config;
  14. use function Yansongda\Pay\get_unipay_body;
  15. use function Yansongda\Pay\get_unipay_url;
  16. class AddRadarPlugin implements PluginInterface
  17. {
  18. /**
  19. * @throws ContainerException
  20. * @throws ServiceNotFoundException
  21. * @throws InvalidParamsException
  22. */
  23. public function assembly(Rocket $rocket, Closure $next): Rocket
  24. {
  25. Logger::debug('[Unipay][AddRadarPlugin] 插件开始装载', ['rocket' => $rocket]);
  26. $params = $rocket->getParams();
  27. $config = get_provider_config('unipay', $params);
  28. $payload = $rocket->getPayload();
  29. $rocket->setRadar(new Request(
  30. get_radar_method($payload) ?? 'POST',
  31. get_unipay_url($config, $payload),
  32. $this->getHeaders(),
  33. get_unipay_body($payload),
  34. ));
  35. Logger::info('[Unipay][AddRadarPlugin] 插件装载完毕', ['rocket' => $rocket]);
  36. return $next($rocket);
  37. }
  38. protected function getHeaders(): array
  39. {
  40. return [
  41. 'User-Agent' => 'yansongda/pay-v3',
  42. 'Content-Type' => 'application/x-www-form-urlencoded;charset=utf-8',
  43. ];
  44. }
  45. }