PagarmeAnticipationService.php 5.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168
  1. <?php
  2. namespace App\Services\Pagarme;
  3. use App\Data\Pagarme\Anticipation\AnticipationLimitData;
  4. use App\Data\Pagarme\Anticipation\BulkAnticipationLimitsResponseData;
  5. use App\Data\Pagarme\Anticipation\BulkAnticipationRequestData;
  6. use App\Data\Pagarme\Anticipation\BulkAnticipationResponseData;
  7. use App\Data\Pagarme\Order\OrderRequestData;
  8. use App\Models\Payment;
  9. use App\Services\Pagarme\Concerns\SendsPagarmeRequests;
  10. use Illuminate\Support\Facades\Http;
  11. use Illuminate\Support\Facades\Log;
  12. use Throwable;
  13. class PagarmeAnticipationService
  14. {
  15. use SendsPagarmeRequests;
  16. public function createBulkAnticipation(
  17. Payment $payment,
  18. ?BulkAnticipationLimitsResponseData $limits = null,
  19. ): ?BulkAnticipationResponseData
  20. {
  21. $provider = $payment->provider()->first();
  22. if (! $provider) {
  23. return null;
  24. }
  25. $recipientId = $provider->recipient_id;
  26. if (empty($recipientId)) {
  27. return null;
  28. }
  29. $providerSplit = $payment->splits()
  30. ->where('provider_id', $payment->provider_id)
  31. ->first();
  32. if (! $providerSplit) {
  33. return null;
  34. }
  35. $requestedAmount = OrderRequestData::amountInCents((float) $providerSplit->gross_amount);
  36. if ($requestedAmount <= 0) {
  37. return null;
  38. }
  39. $paymentDate = $this->getAnticipationPaymentDate();
  40. $limits ??= $this->fetchAnticipationLimits($recipientId, $paymentDate);
  41. if ($limits && $limits->minimum->amount > 0 && $requestedAmount < $limits->minimum->amount) {
  42. Log::channel('pagarme')->warning('Antecipacao ignorada: valor abaixo do minimo do recebedor.', [
  43. 'payment_id' => $payment->id,
  44. 'provider_id' => $payment->provider_id,
  45. 'recipient_id' => $recipientId,
  46. 'requested_amount' => $requestedAmount,
  47. 'minimum_amount' => $limits->minimum->amount,
  48. 'maximum_amount' => $limits->maximum->amount,
  49. ]);
  50. return null;
  51. }
  52. try {
  53. $response = BulkAnticipationResponseData::fromArray($this->pagarmeRequest(
  54. method: 'POST',
  55. path: "/recipients/{$recipientId}/bulk_anticipations",
  56. payload: new BulkAnticipationRequestData(
  57. paymentDate: $paymentDate,
  58. timeframe: 'start',
  59. requestedAmount: $requestedAmount,
  60. automaticTransfer: false,
  61. ),
  62. idempotencyKey: "bulk-ant-{$payment->id}-{$payment->provider_id}",
  63. errorMessage: 'Erro ao criar antecipacao no Pagar.me.',
  64. ));
  65. $response->requireId();
  66. return $response;
  67. } catch (Throwable $e) {
  68. Log::channel('pagarme')->warning('Falha ao criar antecipacao no Pagar.me.', [
  69. 'payment_id' => $payment->id,
  70. 'provider_id' => $payment->provider_id,
  71. 'recipient_id' => $recipientId,
  72. 'requested_amount' => $requestedAmount,
  73. 'minimum_amount' => $limits?->minimum->amount,
  74. 'maximum_amount' => $limits?->maximum->amount,
  75. 'error' => $e->getMessage(),
  76. ]);
  77. return null;
  78. }
  79. }
  80. public function fetchAnticipationLimitsForPayment(Payment $payment): ?BulkAnticipationLimitsResponseData
  81. {
  82. $provider = $payment->provider()->first();
  83. if (! $provider || empty($provider->recipient_id)) {
  84. return null;
  85. }
  86. return $this->fetchAnticipationLimits(
  87. recipientId: $provider->recipient_id,
  88. paymentDate: $this->getAnticipationPaymentDate(),
  89. );
  90. }
  91. private function fetchAnticipationLimits(string $recipientId, string $paymentDate): ?BulkAnticipationLimitsResponseData
  92. {
  93. try {
  94. $secretKey = config('services.pagarme.secret_key');
  95. if (empty($secretKey)) {
  96. return null;
  97. }
  98. $endpoint = $this->pagarmeUrl("/recipients/{$recipientId}/bulk_anticipations/limits");
  99. $response = Http::withBasicAuth($secretKey, '')
  100. ->withHeaders([
  101. 'Content-Type' => 'application/json',
  102. 'Accept' => 'application/json',
  103. ])
  104. ->get($endpoint, [
  105. 'payment_date' => $paymentDate,
  106. 'timeframe' => 'start',
  107. ])
  108. ->throw();
  109. $body = $response->json() ?? [];
  110. return BulkAnticipationLimitsResponseData::fromArray($body);
  111. } catch (Throwable $e) {
  112. Log::channel('pagarme')->warning('Falha ao consultar limites de antecipacao.', [
  113. 'recipient_id' => $recipientId,
  114. 'payment_date' => $paymentDate,
  115. 'error' => $e->getMessage(),
  116. ]);
  117. return null;
  118. }
  119. }
  120. private function getAnticipationPaymentDate(): string
  121. {
  122. $now = now()->timezone('America/Sao_Paulo');
  123. if ($now->hour < 11) {
  124. return $now->toISOString();
  125. }
  126. $nextBusinessDay = $now->copy()->addDay();
  127. while ($nextBusinessDay->isWeekend()) {
  128. $nextBusinessDay->addDay();
  129. }
  130. return $nextBusinessDay->startOfDay()->toISOString();
  131. }
  132. }