src/Controller/StripeController.php line 29

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Services\UserService;
  6. use Carbon\Carbon;
  7. use GeoIp2\Record\Location;
  8. use Pimcore\Log\ApplicationLogger;
  9. use Pimcore\Log\Simple;
  10. use Pimcore\Model\DataObject\LocationSource;
  11. use Pimcore\Model\DataObject\Data\ElementMetadata;
  12. use Pimcore\Model\DataObject\MemberStripeAccount;
  13. use Pimcore\Model\DataObject\MembersUser;
  14. use Pimcore\Model\DataObject\Price;
  15. use Pimcore\Model\DataObject\ProductDescription;
  16. use Pimcore\Model\DataObject\Promocode;
  17. use Pimcore\Model\DataObject\PromoRules;
  18. use Pimcore\Model\DataObject\StripeAccount;
  19. use Pimcore\Model\WebsiteSetting;
  20. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  21. use Symfony\Component\HttpFoundation\Response;
  22. use Symfony\Component\Routing\Annotation\Route;
  23. use Symfony\Component\HttpFoundation\Request;
  24. use Symfony\Contracts\Cache\CacheInterface;
  25. use Symfony\Contracts\Cache\ItemInterface;
  26. use Stripe;
  27. use Symfony\Component\Security\Http\Attribute\CurrentUser;
  29. class StripeController extends AbstractController
  30. {
  31.     private CacheInterface $cache;
  33.     public function __construct(CacheInterface $cache)
  34.     {
  35.         $this->cache = $cache;
  36.     }
  38.     protected function validateAdminRole($user): ?Response
  39.     {
  40.         if ($user === null) {
  41.             return new Response(json_encode([
  42.                 'success' => false,
  43.                 'data' => 'User not authenticated'
  44.             ]), Response::HTTP_UNAUTHORIZED);
  45.         }
  46.         
  47.         $groups = $user->getGroups();
  48.         if (empty($groups) || $groups[0]->getName() !== 'Admin') {
  49.             return new Response(json_encode([
  50.                 'success' => false,
  51.                 'data' => 'Admin role required'
  52.             ]), Response::HTTP_FORBIDDEN);
  53.         }
  54.         return null;
  55.     }
  57.     private function normalizeAdditionalPriceItem(mixed $item, $membership): ?array
  58.     {
  59.         $price = null;
  60.         $forMembership = null;
  62.         if ($item instanceof Price) {
  63.             $price = $item;
  64.         } elseif ($item instanceof ElementMetadata) {
  65.             $element = $item->getElement();
  66.             if ($element instanceof Price) {
  67.                 $price = $element;
  68.             }
  70.             $forMembership = $item->getForMembership();
  71.         }
  73.         if (!$price instanceof Price) {
  74.             return null;
  75.         }
  77.         // Include the item for members when it's member-only, or for everyone when not flagged as member-only.
  78.         if (($forMembership == 1 && $membership) || $forMembership != 1) {
  79.             return [
  80.                 'id' => $price->getPriceid(),
  81.                 'title' => $price->getTitle(),
  82.                 'price' => $price->getPrice() / 100,
  83.             ];
  84.         }
  86.         return null;
  87.     }
  89.     private function freeTools(LocationSource $locationSource): array
  90.     {
  92.         $data = [];
  93.         if ($locationSource instanceof LocationSource) {
  94.             $freeTools = $locationSource->getFreeTools();
  95.             foreach($freeTools as $tool) {
  96.                 if ($tool instanceof ProductDescription) {
  97.                     $data['services'][$tool->getServiceId()] = [
  98.                         'serviceId' => $tool->getServiceId(),
  99.                         'title' => $tool->getTitle(),
  100.                         'price' => 0.0,
  101.                         'shortDescription' => $tool->getShortDescription(),
  102.                         'fullDescription' => $tool->getFullDescription(),
  103.                         'requirements' => $tool->getRequirements(),
  104.                         'requiredDocuments' => $tool->getRequiredDocuments(),
  105.                         'estimatedTime' => $tool->getEstimatedTime(),
  106.                         'required' => $tool->getRequired()
  107.                     ];
  108.                 }
  109.             }
  110.         }
  111.         return $data;
  112.     }
  114.     #[Route('/v1/api/user/stripe', name: 'user_stripe',  methods: ['GET'])]
  115.     public function userStripeAction(Request $request, #[CurrentUser] $user = null): Response
  116.     {
  117.         $sourceKey = $request->query->get('source');
  118.         if ($user === null) {
  119.             return new Response(json_encode([
  120.                 'success' => false,
  121.                 'data' => 'User not authenticated'
  122.             ]), Response::HTTP_UNAUTHORIZED);
  123.         }
  124.         $locationSource = LocationSource::getByObjectKey($sourceKey, 1);
  125.         $MemberStripeAccount = new MemberStripeAccount\Listing();
  126.         $MemberStripeAccount->setCondition('customerId = ? AND source__id = ?', [
  127.             $user->getId(),
  128.             $locationSource->getId()
  129.         ]);
  130.         $MemberStripeAccount = $MemberStripeAccount->current();
  132.         $data = [];
  133.         if (!$MemberStripeAccount instanceof MemberStripeAccount || !$MemberStripeAccount->getRules()) {
  134.             $stripeAccount = $locationSource->getStripeAccount();
  135.             $attestationPrice = Price::getByPriceid($stripeAccount->getAttestationItem(), 1);
  137.             $attestationDescription = $attestationPrice?->getDescription();
  138.             $data['services']['attestation'] = [
  139.                 'id' => $attestationPrice?->getPriceid(),
  140.                 'title' => $attestationDescription?->getTitle(),
  141.                 'shortDescription' => $attestationDescription?->getShortDescription(),
  142.                 'fullDescription' => $attestationDescription?->getFullDescription(),
  143.                 'requirements' => $attestationDescription?->getRequirements(),
  144.                 'requiredDocuments' => $attestationDescription?->getRequiredDocuments(),
  145.                 'estimatedTime' => $attestationDescription?->getEstimatedTime(),
  146.                 'required' => $attestationDescription?->getRequired(),
  147.                 'price' => $attestationPrice?->getPrice() / 100,
  148.                 'serviceId' => $attestationDescription?->getServiceId(),
  149.             ];
  151.             $assistancePrice = Price::getByPriceid($stripeAccount->getAssistanceItem(), 1);
  153.             $assistanceDescription = $assistancePrice?->getDescription();
  154.             $data['services']['assistance'] = [
  155.                 'id' => $assistancePrice?->getPriceid(),
  156.                 'title' => $assistanceDescription?->getTitle(),
  157.                 'shortDescription' => $assistanceDescription?->getShortDescription(),
  158.                 'fullDescription' => $assistanceDescription?->getFullDescription(),
  159.                 'requirements' => $assistanceDescription?->getRequirements(),
  160.                 'requiredDocuments' => $assistanceDescription?->getRequiredDocuments(),
  161.                 'estimatedTime' => $assistanceDescription?->getEstimatedTime(),
  162.                 'required' => $assistanceDescription?->getRequired(),
  163.                 'price' => $assistancePrice?->getPrice() / 100,
  164.                 'serviceId' => $assistanceDescription?->getServiceId(),
  165.             ];
  167.             $rentProtectionPrice = Price::getByPriceid($stripeAccount->getInsuranceItem(), 1);
  168.             $rentProtectionDescription = $rentProtectionPrice?->getDescription();
  169.             $data['services']['rentProtection'] = [
  170.                 'id' => $rentProtectionPrice?->getPriceid(),
  171.                 'title' => $rentProtectionDescription?->getTitle(),
  172.                 'shortDescription' => $rentProtectionDescription?->getShortDescription(),
  173.                 'fullDescription' => $rentProtectionDescription?->getFullDescription(),
  174.                 'requirements' => $rentProtectionDescription?->getRequirements(),
  175.                 'requiredDocuments' => $rentProtectionDescription?->getRequiredDocuments(),
  176.                 'estimatedTime' => $rentProtectionDescription?->getEstimatedTime(),
  177.                 'required' => $rentProtectionDescription?->getRequired(),
  178.                 'price' => $rentProtectionPrice?->getPrice() / 100,
  179.                 'serviceId' => $rentProtectionDescription?->getServiceId(),
  180.             ];
  181.         }
  182.         
  183.         if ($MemberStripeAccount && $MemberStripeAccount->getRules()){
  184.             $rules = PromoRules::getById($MemberStripeAccount->getRules());
  185.         }
  187.         
  189.         if ($MemberStripeAccount && $MemberStripeAccount->getRules() && $rules instanceof PromoRules) {
  190.             $promos = $rules->getPromo();
  191.             if (!empty($promos)) {
  192.                 foreach ($promos as $promo) {
  193.                     if ($promo['price']->getData() instanceof Price) {
  194.                         $price = $promo['price']->getData();
  195.                         $description = $price->getDescription();
  196.                         if ($description instanceof ProductDescription) {
  197.                             $data['services'][$description->getServiceKey()] = [
  198.                                 'id' => $price->getPriceid(),
  199.                                 'title' => $description->getTitle() ? $description->getTitle() : $price->getTitle(),
  200.                                 'shortDescription' => $description->getShortDescription(),
  201.                                 'fullDescription' => $description->getFullDescription(),
  202.                                 'requirements' => $description->getRequirements(),
  203.                                 'requiredDocuments' => $description->getRequiredDocuments(),
  204.                                 'estimatedTime' => $description->getEstimatedTime(),
  205.                                 'required' => $description->getRequired(),
  206.                                 'price' => $price->getPrice() / 100,
  207.                                 'serviceId' => $description->getServiceId(),
  208.                             ];
  209.                         }
  210.                     }
  211.                 }
  212.             }
  213.         }
  214.         $membership = $user->getMembershipForm();
  215.         
  216.         $stripeAccount = StripeAccount::getByAccount($locationSource->getId(), 1);
  217.        
  218.         
  219.         // Aggiungi servizi aggiuntivi se disponibili
  220.         $additionalAttestationItems = $stripeAccount->getAdditionalAttestationItem();
  221.         if (!empty($additionalAttestationItems)) {
  222.             foreach ($additionalAttestationItems as $item) {
  223.                 $normalized = $this->normalizeAdditionalPriceItem($item, $membership);
  224.                 if (!empty($normalized)) {
  225.                     $data['services']['attestation']['additional'][] = $normalized;
  226.                 }
  227.             }
  228.         }
  229.         
  230.         $additionalAssistanceItems = $stripeAccount->getAdditionalAssistanceItem();
  231.         if (!empty($additionalAssistanceItems)) {
  232.             foreach ($additionalAssistanceItems as $item) {
  233.                 $normalized = $this->normalizeAdditionalPriceItem($item, $membership);
  234.                 if (!empty($normalized)) {
  235.                     $data['services']['assistance']['additional'][] = $normalized;
  236.                 }
  237.             }
  238.         }
  239.         
  240.         $listing = new MemberStripeAccount\Listing();
  241.         $listing->setCondition('customerId = :customerId AND source__id = :sourceId', [
  242.             'customerId' => $user->getId(),
  243.             'sourceId' => $locationSource->getId()
  244.         ]);
  245.         $listing->setLimit(1);
  246.         $memberStripeAccount = $listing->current();
  247.         if ($memberStripeAccount instanceof MemberStripeAccount) {
  248.             // Verifica se ci sono promo code e aggiungi gli sconti ai servizi
  249.             if (!empty($memberStripeAccount->getPromoCode())) {
  250.                 $stripe = new \Stripe\StripeClient($stripeAccount->getStripeSecret());
  251.                 
  252.                 foreach ($memberStripeAccount->getPromoCode() as $promos) {
  253.                     $priceId = $promos[0];
  254.                     $promoId = $promos[1];
  255.                     
  256.                     // Determina quale servizio corrisponde a questo price_id
  257.                     $serviceKey = null;
  258.                     if ($priceId === $stripeAccount->getAttestationItem()) {
  259.                         $serviceKey = 'attestation';
  260.                     } elseif ($priceId === $stripeAccount->getAssistanceItem()) {
  261.                         $serviceKey = 'assistance';
  262.                     } elseif ($priceId === $stripeAccount->getInsuranceItem()) {
  263.                         $serviceKey = 'insurance';
  264.                     }
  265.                     
  266.                     // if ($serviceKey !== null) {
  267.                     //     // Cerca prima nel database Promocode
  268.                     //     $promo = Promocode::getByPromoid($promoId, 1);
  269.                     //     if ($promo !== null) {
  270.                     //         $coupon = \Pimcore\Model\DataObject\Coupon::getByPromo($promo, 1);
  271.                     //         if ($coupon instanceof \Pimcore\Model\DataObject\Coupon) {
  272.                     //             preg_match('/\d+$/', $coupon->getTitle(), $matches);
  273.                     //             if (!empty($matches)) {
  274.                     //                 $data['services'][$serviceKey]['promo'] = [
  275.                     //                     'discount' => (float) $matches[0],
  276.                     //                     'id' => $promoId,
  277.                     //                     'couponName' => $coupon->getTitle(),
  278.                     //                     'promoName' => $promo->getCode(),
  279.                     //                     'code' => $coupon->getCouponid() // Recupera il couponid dalla relazione con promo
  280.                     //                 ];
  281.                     //             }
  282.                     //         }
  283.                     //     } else {
  284.                     //         // Se non trovato nel database, recupera da Stripe
  285.                     //         try {
  286.                     //             $promoObj = $stripe->promotionCodes->retrieve($promoId, []);
  287.                     //             if ($promoObj->active) {
  288.                     //                 preg_match('/\d+$/', $promoObj->coupon->name, $matches);
  289.                     //                 if (!empty($matches)) {
  290.                     //                     $data['services'][$serviceKey]['promo'] = [
  291.                     //                         'discount' => (float) $matches[0],
  292.                     //                         'id' => $promoId,
  293.                     //                         'couponName' => '',
  294.                     //                         'promoName' => '',
  295.                     //                         'code' => $promoObj->code // Aggiungi il codice coupon da Stripe
  296.                     //                     ];
  297.                     //                 }
  298.                     //             }
  299.                     //         } catch (\Exception $e) {
  300.                     //             // Log dell'errore se necessario
  301.                     //         }
  302.                     //     }
  303.                     // }
  304.                 }
  305.             }
  306.         }
  308.         $freeToolsData = $this->freeTools($locationSource);
  309.         
  310.         // Merge correttamente i servizi gratuiti con quelli a pagamento
  311.         if (isset($freeToolsData['services'])) {
  312.             $data['services'] = array_merge($data['services'] ?? [], $freeToolsData['services']);
  313.         }
  314.         
  315.         return new Response(json_encode([
  316.             'success' => true,
  317.             'data' => $data
  318.         ]));
  319.     }
  321.     #[Route('/v1/api/stripe/dashboard-stats', name: 'stripe_dashboard_stats', methods: ['GET'])]
  322.     public function dashboardStatsAction(Request $request, #[CurrentUser] $user = null): Response
  323.     {
  324.         // Controlla autenticazione e permessi admin
  325.         $authError = $this->validateAdminRole($user);
  326.         if ($authError !== null) {
  327.             return $authError;
  328.         }
  329.         
  330.         $sourceKey = $request->query->get('source');
  331.         $period = $request->query->get('period', '30'); // giorni
  332.         
  333.         if (empty($sourceKey)) {
  334.             return new Response(json_encode([
  335.                 'success' => false,
  336.                 'data' => 'Source parameter required'
  337.             ]), Response::HTTP_BAD_REQUEST);
  338.         }
  339.         
  340.         $locationSource = LocationSource::getByObjectKey($sourceKey, 1);
  341.         if (!$locationSource instanceof LocationSource) {
  342.             return new Response(json_encode([
  343.                 'success' => false,
  344.                 'data' => 'Location source not found'
  345.             ]), Response::HTTP_NOT_FOUND);
  346.         }
  347.         
  348.         $stripeAccount = StripeAccount::getByAccount($locationSource->getId(), 1);
  349.         if (!$stripeAccount instanceof StripeAccount) {
  350.             return new Response(json_encode([
  351.                 'success' => false,
  352.                 'data' => 'Stripe account not found'
  353.             ]), Response::HTTP_NOT_FOUND);
  354.         }
  355.         
  356.         try {
  357.             $cacheKey = sprintf('stripe_dashboard_stats_%s_%s', $sourceKey, $period);
  358.             
  359.             $stats = $this->cache->get($cacheKey, function (ItemInterface $item) use ($stripeAccount, $period) {
  360.                 $item->expiresAfter(300); // 5 minuti di cache
  361.                 
  362.                 $stripe = new \Stripe\StripeClient($stripeAccount->getStripeSecret());
  363.                 
  364.                 $startDate = Carbon::now()->subDays((int)$period)->startOfDay();
  365.                 $endDate = Carbon::now()->endOfDay();
  366.                 
  367.                 // Recupera i pagamenti nel periodo
  368.                 $allPayments = $stripe->paymentIntents->all([
  369.                     'limit' => 100,
  370.                     'created' => [
  371.                         'gte' => $startDate->timestamp,
  372.                         'lte' => $endDate->timestamp
  373.                     ]
  374.                 ]);
  375.                 
  376.                 // Filtra i pagamenti completati e falliti
  377.                 $payments = [];
  378.                 $failedPayments = [];
  379.                 
  380.                 foreach ($allPayments->data as $payment) {
  381.                     if ($payment->status === 'succeeded') {
  382.                         $payments[] = $payment;
  383.                     } elseif ($payment->status === 'payment_failed') {
  384.                         $failedPayments[] = $payment;
  385.                     }
  386.                 }
  387.                 
  388.                 return $this->calculateDashboardStats($payments, $failedPayments, $period);
  389.             });
  390.             
  391.             return new Response(json_encode([
  392.                 'success' => true,
  393.                 'data' => $stats
  394.             ]));
  395.             
  396.         } catch (\Exception $e) {
  397.             $logger = ApplicationLogger::getInstance();
  398.             $logger->error('Dashboard stats error: ' . $e->getMessage());
  399.             
  400.             return new Response(json_encode([
  401.                 'success' => false,
  402.                 'data' => 'Error retrieving dashboard stats'
  403.             ]), Response::HTTP_INTERNAL_SERVER_ERROR);
  404.         }
  405.     }
  406.     
  407.     #[Route('/v1/api/stripe/sales-analytics', name: 'stripe_sales_analytics', methods: ['GET'])]
  408.     public function salesAnalyticsAction(Request $request, #[CurrentUser] $user = null): Response
  409.     {
  410.         // Controlla autenticazione e permessi admin
  411.         $authError = $this->validateAdminRole($user);
  412.         if ($authError !== null) {
  413.             return $authError;
  414.         }
  415.         
  416.         $sourceKey = $request->query->get('source');
  417.         $period = $request->query->get('period', 'month'); // day, week, month
  418.         
  419.         if (empty($sourceKey)) {
  420.             return new Response(json_encode([
  421.                 'success' => false,
  422.                 'data' => 'Source parameter required'
  423.             ]), Response::HTTP_BAD_REQUEST);
  424.         }
  425.         
  426.         $locationSource = LocationSource::getByObjectKey($sourceKey, 1);
  427.         $stripeAccount = StripeAccount::getByAccount($locationSource->getId(), 1);
  428.         
  429.         try {
  430.             $cacheKey = sprintf('stripe_sales_analytics_%s_%s', $sourceKey, $period);
  431.             
  432.             $analytics = $this->cache->get($cacheKey, function (ItemInterface $item) use ($stripeAccount, $period) {
  433.                 // Cache più lungo per analytics storiche
  434.                 $ttl = match($period) {
  435.                     'day' => 180,    // 3 minuti per dati giornalieri
  436.                     'week' => 600,   // 10 minuti per dati settimanali  
  437.                     'month' => 1800, // 30 minuti per dati mensili
  438.                     default => 600
  439.                 };
  440.                 $item->expiresAfter($ttl);
  441.                 
  442.                 $stripe = new \Stripe\StripeClient($stripeAccount->getStripeSecret());
  443.                 return $this->getSalesAnalytics($stripe, $period);
  444.             });
  445.             
  446.             return new Response(json_encode([
  447.                 'success' => true,
  448.                 'data' => $analytics
  449.             ]));
  450.             
  451.         } catch (\Exception $e) {
  452.             $logger = ApplicationLogger::getInstance();
  453.             $logger->error('Sales analytics error: ' . $e->getMessage());
  454.             
  455.             return new Response(json_encode([
  456.                 'success' => false,
  457.                 'data' => 'Error retrieving sales analytics'
  458.             ]), Response::HTTP_INTERNAL_SERVER_ERROR);
  459.         }
  460.     }
  461.     
  462.     #[Route('/v1/api/stripe/alerts', name: 'stripe_alerts', methods: ['GET'])]
  463.     public function alertsAction(Request $request, #[CurrentUser] $user = null): Response
  464.     {
  465.         // Controlla autenticazione e permessi admin
  466.         $authError = $this->validateAdminRole($user);
  467.         if ($authError !== null) {
  468.             return $authError;
  469.         }
  470.         
  471.         $sourceKey = $request->query->get('source');
  472.         $threshold = (float)$request->query->get('threshold', 20); // percentuale calo ricavi
  473.         
  474.         if (empty($sourceKey)) {
  475.             return new Response(json_encode([
  476.                 'success' => false,
  477.                 'data' => 'Source parameter required'
  478.             ]), Response::HTTP_BAD_REQUEST);
  479.         }
  480.         
  481.         $locationSource = LocationSource::getByObjectKey($sourceKey, 1);
  482.         $stripeAccount = StripeAccount::getByAccount($locationSource->getId(), 1);
  483.         
  484.         try {
  485.             $cacheKey = sprintf('stripe_alerts_%s_%.1f', $sourceKey, $threshold);
  486.             
  487.             $alerts = $this->cache->get($cacheKey, function (ItemInterface $item) use ($stripeAccount, $threshold) {
  488.                 $item->expiresAfter(120); // 2 minuti per gli alert (devono essere abbastanza freschi)
  489.                 
  490.                 $stripe = new \Stripe\StripeClient($stripeAccount->getStripeSecret());
  491.                 return $this->generateAlerts($stripe, $threshold);
  492.             });
  493.             
  494.             return new Response(json_encode([
  495.                 'success' => true,
  496.                 'data' => $alerts
  497.             ]));
  498.             
  499.         } catch (\Exception $e) {
  500.             $logger = ApplicationLogger::getInstance();
  501.             $logger->error('Alerts error: ' . $e->getMessage());
  502.             
  503.             return new Response(json_encode([
  504.                 'success' => false,
  505.                 'data' => 'Error generating alerts'
  506.             ]), Response::HTTP_INTERNAL_SERVER_ERROR);
  507.         }
  508.     }
  509.     
  510.     #[Route('/v1/api/stripe/predictions', name: 'stripe_predictions', methods: ['GET'])]
  511.     public function predictionsAction(Request $request, #[CurrentUser] $user = null): Response
  512.     {
  513.         // Controlla autenticazione e permessi admin
  514.         $authError = $this->validateAdminRole($user);
  515.         if ($authError !== null) {
  516.             return $authError;
  517.         }
  518.         
  519.         $sourceKey = $request->query->get('source');
  520.         
  521.         if (empty($sourceKey)) {
  522.             return new Response(json_encode([
  523.                 'success' => false,
  524.                 'data' => 'Source parameter required'
  525.             ]), Response::HTTP_BAD_REQUEST);
  526.         }
  527.         
  528.         $locationSource = LocationSource::getByObjectKey($sourceKey, 1);
  529.         $stripeAccount = StripeAccount::getByAccount($locationSource->getId(), 1);
  530.         
  531.         try {
  532.             $cacheKey = sprintf('stripe_predictions_%s', $sourceKey);
  533.             
  534.             $predictions = $this->cache->get($cacheKey, function (ItemInterface $item) use ($stripeAccount) {
  535.                 $item->expiresAfter(900); // 15 minuti per le previsioni
  536.                 
  537.                 $stripe = new \Stripe\StripeClient($stripeAccount->getStripeSecret());
  538.                 return $this->calculateMonthlyPrediction($stripe);
  539.             });
  540.             
  541.             return new Response(json_encode([
  542.                 'success' => true,
  543.                 'data' => $predictions
  544.             ]));
  545.             
  546.         } catch (\Exception $e) {
  547.             $logger = ApplicationLogger::getInstance();
  548.             $logger->error('Predictions error: ' . $e->getMessage());
  549.             
  550.             return new Response(json_encode([
  551.                 'success' => false,
  552.                 'data' => 'Error calculating predictions'
  553.             ]), Response::HTTP_INTERNAL_SERVER_ERROR);
  554.         }
  555.     }
  557.     #[Route('/v1/api/stripe/clear-cache', name: 'stripe_clear_cache', methods: ['POST'])]
  558.     public function clearCacheAction(Request $request, #[CurrentUser] $user = null): Response
  559.     {
  560.         // Controlla autenticazione e permessi admin
  561.         $authError = $this->validateAdminRole($user);
  562.         if ($authError !== null) {
  563.             return $authError;
  564.         }
  565.         
  566.         $sourceKey = $request->request->get('source');
  567.         
  568.         if (empty($sourceKey)) {
  569.             return new Response(json_encode([
  570.                 'success' => false,
  571.                 'data' => 'Source parameter required'
  572.             ]), Response::HTTP_BAD_REQUEST);
  573.         }
  574.         
  575.         try {
  576.             // Pattern per eliminare tutte le cache relative a questa source
  577.             $patterns = [
  578.                 'stripe_dashboard_stats_' . $sourceKey . '_*',
  579.                 'stripe_sales_analytics_' . $sourceKey . '_*',
  580.                 'stripe_alerts_' . $sourceKey . '_*',
  581.                 'stripe_predictions_' . $sourceKey
  582.             ];
  583.             
  584.             // Pimcore non ha un metodo diretto per eliminare per pattern,
  585.             // quindi eliminiamo le chiavi più comuni
  586.             $keysToDelete = [
  587.                 sprintf('stripe_dashboard_stats_%s_7', $sourceKey),
  588.                 sprintf('stripe_dashboard_stats_%s_30', $sourceKey),
  589.                 sprintf('stripe_sales_analytics_%s_day', $sourceKey),
  590.                 sprintf('stripe_sales_analytics_%s_week', $sourceKey),
  591.                 sprintf('stripe_sales_analytics_%s_month', $sourceKey),
  592.                 sprintf('stripe_alerts_%s_20.0', $sourceKey),
  593.                 sprintf('stripe_predictions_%s', $sourceKey)
  594.             ];
  595.             
  596.             foreach ($keysToDelete as $key) {
  597.                 $this->cache->delete($key);
  598.             }
  599.             
  600.             return new Response(json_encode([
  601.                 'success' => true,
  602.                 'data' => 'Cache cleared successfully'
  603.             ]));
  604.             
  605.         } catch (\Exception $e) {
  606.             $logger = ApplicationLogger::getInstance();
  607.             $logger->error('Clear cache error: ' . $e->getMessage());
  608.             
  609.             return new Response(json_encode([
  610.                 'success' => false,
  611.                 'data' => 'Error clearing cache'
  612.             ]), Response::HTTP_INTERNAL_SERVER_ERROR);
  613.         }
  614.     }
  616.     #[Route('/stripe/transfer', name: 'stripe_transfer',  methods: ['POST'])]
  617.     public function transferAction(Request $request): Response
  618.     {
  619.         $username = $request->headers->get('php-auth-user');
  620.         $password = $request->headers->get('php-auth-pw');
  621.         if (empty($username) && empty($password)) {
  622.             return new Response('', Response::HTTP_UNAUTHORIZED);
  623.         }
  624.         if ($username !== 'ariful' || $password !== 'ariful') {
  625.             return new Response('', Response::HTTP_UNAUTHORIZED);
  626.         }
  627.         $destination = $request->request->get('destination');
  628.         $amount = $request->request->get('amount');
  629.         // $message = false;
  630.         $logger = ApplicationLogger::getInstance();
  631.         // $payload = $request->getContent();
  632.         // $json = json_decode($payload, true);
  634.         try {
  635.             Stripe\Stripe::setApiKey($_ENV["STRIPE_SECRET"]);
  637.             $stripe = new \Stripe\StripeClient($_ENV["STRIPE_SECRET"]);
  639.             $result = $stripe->transfers->create([
  640.                 'amount' => $amount,
  641.                 'currency' => 'eur',
  642.                 'destination' => $destination
  643.             ]);
  644.         } catch (\Exception $e) {
  645.             $logger->error($e->getMessage());
  646.         }
  647.         return new Response($result->toJSON());
  648.     }
  650.     #[Route('/stripe/balance', name: 'stripe_balance',  methods: ['POST'])]
  651.     public function balanceAction(Request $request): Response
  652.     {
  653.         $username = $request->headers->get('php-auth-user');
  654.         $password = $request->headers->get('php-auth-pw');
  656.         if (empty($username) && empty($password)) {
  657.             return new Response('', Response::HTTP_UNAUTHORIZED);
  658.         }
  659.         if ($username !== 'ariful' || $password !== 'ariful') {
  660.             return new Response('', Response::HTTP_UNAUTHORIZED);
  661.         }
  662.         // $message = false;
  663.         $logger = ApplicationLogger::getInstance();
  664.         // $payload = $request->getContent();
  665.         // $json = json_decode($payload, true);
  666.         // dd($json);
  668.         try {
  669.             Stripe\Stripe::setApiKey($_ENV["STRIPE_SECRET"]);
  671.             $stripe = new \Stripe\StripeClient($_ENV["STRIPE_SECRET"]);
  673.             $result = $stripe->balance->retrieve([]);
  674.         } catch (\Exception $e) {
  675.             $logger->error($e->getMessage());
  676.         }
  678.         return new Response($result->toJSON());
  679.     }
  681.     private function calculateDashboardStats(array $payments, array $failedPayments, string $period): array
  682.     {
  683.         $totalRevenue = 0;
  684.         $totalTransactions = count($payments);
  685.         $dailyRevenue = [];
  686.         $lastSuccessfulPayment = null;
  687.         $lastFailedPayment = null;
  688.         
  689.         // Calcola ricavi totali e giornalieri
  690.         foreach ($payments as $payment) {
  691.             $totalRevenue += $payment->amount / 100; // Converti da centesimi
  692.             $date = Carbon::createFromTimestamp($payment->created)->format('Y-m-d');
  693.             
  694.             if (!isset($dailyRevenue[$date])) {
  695.                 $dailyRevenue[$date] = 0;
  696.             }
  697.             $dailyRevenue[$date] += $payment->amount / 100;
  698.             
  699.             if ($lastSuccessfulPayment === null || $payment->created > $lastSuccessfulPayment['created']) {
  700.                 $lastSuccessfulPayment = [
  701.                     'id' => $payment->id,
  702.                     'amount' => $payment->amount / 100,
  703.                     'currency' => $payment->currency,
  704.                     'created' => $payment->created,
  705.                     'customer' => $payment->customer ?? 'Guest'
  706.                 ];
  707.             }
  708.         }
  709.         
  710.         // Ultimo pagamento fallito
  711.         foreach ($failedPayments as $payment) {
  712.             if ($lastFailedPayment === null || $payment->created > $lastFailedPayment['created']) {
  713.                 $lastFailedPayment = [
  714.                     'id' => $payment->id,
  715.                     'amount' => $payment->amount / 100,
  716.                     'currency' => $payment->currency,
  717.                     'created' => $payment->created,
  718.                     'failure_reason' => $payment->last_payment_error->message ?? 'Unknown',
  719.                     'customer' => $payment->customer ?? 'Guest'
  720.                 ];
  721.             }
  722.         }
  723.         
  724.         // Trova best e worst day
  725.         $bestDay = null;
  726.         $worstDay = null;
  727.         $bestAmount = 0;
  728.         $worstAmount = PHP_FLOAT_MAX;
  729.         
  730.         foreach ($dailyRevenue as $date => $amount) {
  731.             if ($amount > $bestAmount) {
  732.                 $bestAmount = $amount;
  733.                 $bestDay = ['date' => $date, 'amount' => $amount];
  734.             }
  735.             if ($amount < $worstAmount) {
  736.                 $worstAmount = $amount;
  737.                 $worstDay = ['date' => $date, 'amount' => $amount];
  738.             }
  739.         }
  740.         
  741.         // Calcola media giornaliera
  742.         $avgDailyRevenue = $totalRevenue / max(1, (int)$period);
  743.         
  744.         return [
  745.             'totalRevenue' => $totalRevenue,
  746.             'totalTransactions' => $totalTransactions,
  747.             'avgDailyRevenue' => $avgDailyRevenue,
  748.             'failedTransactions' => count($failedPayments),
  749.             'dailyRevenue' => $dailyRevenue,
  750.             'bestDay' => $bestDay,
  751.             'worstDay' => $worstDay,
  752.             'lastSuccessfulPayment' => $lastSuccessfulPayment,
  753.             'lastFailedPayment' => $lastFailedPayment,
  754.             'period' => $period
  755.         ];
  756.     }
  757.     
  758.     private function getSalesAnalytics(\Stripe\StripeClient $stripe, string $period): array
  759.     {
  760.         $now = Carbon::now();
  761.         
  762.         switch ($period) {
  763.             case 'day':
  764.                 $startDate = $now->copy()->subDays(30)->startOfDay();
  765.                 $groupBy = 'day';
  766.                 break;
  767.             case 'week':
  768.                 $startDate = $now->copy()->subWeeks(12)->startOfWeek();
  769.                 $groupBy = 'week';
  770.                 break;
  771.             case 'month':
  772.             default:
  773.                 $startDate = $now->copy()->subMonths(12)->startOfMonth();
  774.                 $groupBy = 'month';
  775.                 break;
  776.         }
  777.         
  778.         $allPayments = $stripe->paymentIntents->all([
  779.             'limit' => 100,
  780.             'created' => [
  781.                 'gte' => $startDate->timestamp,
  782.                 'lte' => $now->timestamp
  783.             ]
  784.         ]);
  785.         
  786.         // Filtra solo i pagamenti completati
  787.         $payments = array_filter($allPayments->data, fn($payment) => $payment->status === 'succeeded');
  788.         
  789.         $analytics = [];
  790.         $totals = ['revenue' => 0, 'transactions' => 0];
  791.         
  792.         foreach ($payments as $payment) {
  793.             $date = Carbon::createFromTimestamp($payment->created);
  794.             
  795.             $key = match($groupBy) {
  796.                 'day' => $date->format('Y-m-d'),
  797.                 'week' => $date->format('Y-W'),
  798.                 'month' => $date->format('Y-m'),
  799.                 default => $date->format('Y-m-d')
  800.             };
  801.             
  802.             if (!isset($analytics[$key])) {
  803.                 $analytics[$key] = [
  804.                     'period' => $key,
  805.                     'revenue' => 0,
  806.                     'transactions' => 0,
  807.                     'avgTransaction' => 0
  808.                 ];
  809.             }
  810.             
  811.             $amount = $payment->amount / 100;
  812.             $analytics[$key]['revenue'] += $amount;
  813.             $analytics[$key]['transactions']++;
  814.             $analytics[$key]['avgTransaction'] = $analytics[$key]['revenue'] / $analytics[$key]['transactions'];
  815.             
  816.             $totals['revenue'] += $amount;
  817.             $totals['transactions']++;
  818.         }
  819.         
  820.         // Ordina per periodo
  821.         ksort($analytics);
  822.         
  823.         return [
  824.             'period' => $period,
  825.             'data' => array_values($analytics),
  826.             'totals' => $totals,
  827.             'avgTransactionValue' => $totals['transactions'] > 0 ? $totals['revenue'] / $totals['transactions'] : 0
  828.         ];
  829.     }
  830.     
  831.     private function generateAlerts(\Stripe\StripeClient $stripe, float $threshold): array
  832.     {
  833.         $alerts = [];
  834.         $now = Carbon::now();
  835.         
  836.         // Confronta ricavi settimana corrente vs precedente
  837.         $thisWeekStart = $now->copy()->startOfWeek();
  838.         $lastWeekStart = $now->copy()->subWeek()->startOfWeek();
  839.         $lastWeekEnd = $now->copy()->subWeek()->endOfWeek();
  840.         
  841.         $thisWeekAllPayments = $stripe->paymentIntents->all([
  842.             'created' => ['gte' => $thisWeekStart->timestamp]
  843.         ]);
  844.         
  845.         $lastWeekAllPayments = $stripe->paymentIntents->all([
  846.             'created' => [
  847.                 'gte' => $lastWeekStart->timestamp,
  848.                 'lte' => $lastWeekEnd->timestamp
  849.             ]
  850.         ]);
  851.         
  852.         // Filtra i pagamenti per stato
  853.         $thisWeekPayments = array_filter($thisWeekAllPayments->data, fn($p) => $p->status === 'succeeded');
  854.         $lastWeekPayments = array_filter($lastWeekAllPayments->data, fn($p) => $p->status === 'succeeded');
  855.         
  856.         $thisWeekRevenue = array_sum(array_map(fn($p) => $p->amount / 100, $thisWeekPayments));
  857.         $lastWeekRevenue = array_sum(array_map(fn($p) => $p->amount / 100, $lastWeekPayments));
  858.         
  859.         if ($lastWeekRevenue > 0) {
  860.             $revenueChange = (($thisWeekRevenue - $lastWeekRevenue) / $lastWeekRevenue) * 100;
  861.             
  862.             if ($revenueChange < -$threshold) {
  863.                 $alerts[] = [
  864.                     'type' => 'revenue_drop',
  865.                     'severity' => 'high',
  866.                     'message' => sprintf("Calo ricavi del %.1f%% rispetto alla settimana scorsa", $revenueChange),
  867.                     'data' => [
  868.                         'thisWeek' => $thisWeekRevenue,
  869.                         'lastWeek' => $lastWeekRevenue,
  870.                         'change' => $revenueChange
  871.                     ]
  872.                 ];
  873.             }
  874.         }
  875.         
  876.         // Alert per pagamenti falliti nelle ultime 24h
  877.         $yesterdayStart = $now->copy()->subDay()->startOfDay();
  878.         $allRecentPayments = $stripe->paymentIntents->all([
  879.             'created' => ['gte' => $yesterdayStart->timestamp]
  880.         ]);
  881.         
  882.         // Filtra i pagamenti falliti
  883.         $failedPayments = array_filter($allRecentPayments->data, fn($p) => $p->status === 'payment_failed');
  884.         
  885.         if (count($failedPayments) > 3) {
  886.             $alerts[] = [
  887.                 'type' => 'failed_payments',
  888.                 'severity' => 'medium',
  889.                 'message' => 'Numero elevato di pagamenti falliti nelle ultime 24h (' . count($failedPayments) . ')',
  890.                 'data' => [
  891.                     'count' => count($failedPayments),
  892.                     'period' => '24h'
  893.                 ]
  894.             ];
  895.         }
  896.         
  897.         return $alerts;
  898.     }
  899.     
  900.     private function calculateMonthlyPrediction(\Stripe\StripeClient $stripe): array
  901.     {
  902.         $now = Carbon::now();
  903.         $monthStart = $now->copy()->startOfMonth();
  904.         $monthEnd = $now->copy()->endOfMonth();
  905.         $daysInMonth = $monthEnd->day;
  906.         $daysPassed = $now->day;
  907.         $daysRemaining = $daysInMonth - $daysPassed;
  908.         
  909.         // Ricavi del mese corrente
  910.         $currentMonthAllPayments = $stripe->paymentIntents->all([
  911.             'created' => ['gte' => $monthStart->timestamp]
  912.         ]);
  913.         
  914.         // Filtra solo i pagamenti completati
  915.         $currentMonthPayments = array_filter($currentMonthAllPayments->data, fn($p) => $p->status === 'succeeded');
  916.         $currentMonthRevenue = array_sum(array_map(fn($p) => $p->amount / 100, $currentMonthPayments));
  917.         
  918.         // Ricavi mese precedente per confronto
  919.         $lastMonthStart = $now->copy()->subMonth()->startOfMonth();
  920.         $lastMonthEnd = $now->copy()->subMonth()->endOfMonth();
  921.         
  922.         $lastMonthAllPayments = $stripe->paymentIntents->all([
  923.             'created' => [
  924.                 'gte' => $lastMonthStart->timestamp,
  925.                 'lte' => $lastMonthEnd->timestamp
  926.             ]
  927.         ]);
  928.         
  929.         // Filtra solo i pagamenti completati
  930.         $lastMonthPayments = array_filter($lastMonthAllPayments->data, fn($p) => $p->status === 'succeeded');
  931.         $lastMonthRevenue = array_sum(array_map(fn($p) => $p->amount / 100, $lastMonthPayments));
  932.         
  933.         // Calcola trend giornaliero
  934.         $dailyAverage = $daysPassed > 0 ? $currentMonthRevenue / $daysPassed : 0;
  935.         $projectedRevenue = $dailyAverage * $daysInMonth;
  936.         
  937.         // Previsione basata su trend degli ultimi 7 giorni
  938.         $weekAgoStart = $now->copy()->subDays(7);
  939.         $recentAllPayments = $stripe->paymentIntents->all([
  940.             'created' => ['gte' => $weekAgoStart->timestamp]
  941.         ]);
  942.         
  943.         // Filtra solo i pagamenti completati
  944.         $recentPayments = array_filter($recentAllPayments->data, fn($p) => $p->status === 'succeeded');
  945.         $recentRevenue = array_sum(array_map(fn($p) => $p->amount / 100, $recentPayments));
  946.         $recentDailyAvg = $recentRevenue / 7;
  947.         $trendBasedProjection = $currentMonthRevenue + ($recentDailyAvg * $daysRemaining);
  948.         
  949.         // Media delle due previsioni
  950.         $finalPrediction = ($projectedRevenue + $trendBasedProjection) / 2;
  951.         
  952.         $confidenceLevel = $this->calculateConfidence($daysPassed, $daysInMonth, $currentMonthRevenue, $lastMonthRevenue);
  953.         
  954.         return [
  955.             'currentMonthRevenue' => $currentMonthRevenue,
  956.             'lastMonthRevenue' => $lastMonthRevenue,
  957.             'projectedRevenue' => $finalPrediction,
  958.             'dailyAverage' => $dailyAverage,
  959.             'recentDailyAverage' => $recentDailyAvg,
  960.             'daysInMonth' => $daysInMonth,
  961.             'daysPassed' => $daysPassed,
  962.             'daysRemaining' => $daysRemaining,
  963.             'confidence' => $confidenceLevel,
  964.             'changeFromLastMonth' => $lastMonthRevenue > 0 ? (($finalPrediction - $lastMonthRevenue) / $lastMonthRevenue) * 100 : 0
  965.         ];
  966.     }
  967.     
  968.     private function calculateConfidence(int $daysPassed, int $daysInMonth, float $currentRevenue, float $lastMonthRevenue): string
  969.     {
  970.         $completionPercentage = ($daysPassed / $daysInMonth) * 100;
  971.         
  972.         if ($completionPercentage < 25) {
  973.             return 'low';
  974.         } elseif ($completionPercentage < 50) {
  975.             return 'medium';
  976.         } elseif ($completionPercentage < 75) {
  977.             return 'high';
  978.         } else {
  979.             return 'very_high';
  980.         }
  981.     }
  983.     private function fetchEmailFromOrder($url, $queryParams = []): string|null
  984.     {
  985.         $logger = ApplicationLogger::getInstance();
  986.         try {
  987.             // Inizializza cURL
  988.             $ch = curl_init();
  990.             // Configura le opzioni cURL
  991.             curl_setopt($ch, CURLOPT_URL, $url);
  992.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); // Per ottenere il risultato come stringa
  993.             curl_setopt($ch, CURLOPT_HTTPGET, true); // Metodo GET
  995.             // Aggiungi query string (facoltativo)
  997.             curl_setopt($ch, CURLOPT_URL, $url . '/api/getOrderUser?' . http_build_query($queryParams));
  999.             // Esegui la richiesta
  1000.             $response = curl_exec($ch);
  1002.             // dd($url . '/api/getOrderUser?' . http_build_query($queryParams), $response);
  1003.             // Controlla eventuali errori
  1004.             if ($response === false) {
  1005.                 $error = curl_error($ch);
  1006.                 // dd($error);
  1007.                 curl_close($ch);
  1009.                 return null;
  1010.             }
  1012.             // Recupera il codice di stato HTTP
  1013.             $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  1015.             // Chiudi cURL
  1016.             curl_close($ch);
  1018.             // Decodifica JSON (se applicabile)
  1019.             $data = json_decode($response, true);
  1021.             if (isset($data['data'])) {
  1022.                 return $data['data'];
  1023.             } else {
  1024.                 return null;
  1025.             }
  1026.             
  1027.         } catch(\Exception $e) {
  1028.             $logger->error($e);
  1029.         }
  1030.         return null;
  1031.     }
  1033.     #[Route('/stripe/webhook', name: 'app_stripe_webhook',  methods: ['POST'])]
  1034.     public function verify(Request $request): Response
  1035.     {
  1036.         $message = "";
  1037.         $logger = ApplicationLogger::getInstance();
  1038.         $payload = $request->getContent();
  1039.         $json = json_decode($payload, true);
  1040.         $locationSource = null;
  1041.         $member = null;
  1042.         $userStripeAccount = null;
  1044.         $logger->info(serialize($json['data']['object']));
  1045.         
  1046.         try {
  1047.             
  1048.             if (empty($json['data']['object']['customer'])) {
  1050.                 if (isset($json['data']['object']['success_url']) && str_contains($json['data']['object']['success_url'], "https://servizi.confabitaremonzabrianza.com")) {
  1051.                     $locationSource = LocationSource::getByPath('/location-source/monzabrianza');
  1052.                     
  1053.                     
  1054.                 } elseif(isset($json['data']['object']['success_url']) && str_contains($json['data']['object']['success_url'], "https://servizi.bergamoconfabitare.com")) {
  1055.                     $locationSource = LocationSource::getByPath('/location-source/bergamo');
  1056.                     
  1057.                 } elseif(isset($json['data']['object']['metadata']['source'])) {
  1058.                     $source = $json['data']['object']['metadata']['source'];
  1059.                     $locationSource = LocationSource::getByPath("/location-source/$source");
  1060.                     $logger->info($source);
  1061.                 }
  1063.                 if ($locationSource instanceof LocationSource && isset($json['data']['object']['metadata']['order_id'])) {
  1064.                     if ( isset($json['data']['object']['recovered_from']) && $json['data']['object']['recovered_from'] !== null) {
  1065.                         $response = $this->fetchEmailFromOrder($locationSource->getServiceEndpoint()?->getHref(), [
  1066.                             'checkout_session' => $json['data']['object']['recovered_from'],
  1067.                             'order_id' => $json['data']['object']['metadata']['order_id']
  1068.                         ]);
  1069.                     } elseif(isset($json['data']['object']['id']) && $json['data']['object']['id'] !== null) {
  1070.                         $logger->info($locationSource->getServiceEndpoint()?->getHref());
  1071.                         $response = $this->fetchEmailFromOrder($locationSource->getServiceEndpoint()?->getHref(), [
  1072.                             'checkout_session' => $json['data']['object']['id'],
  1073.                             'order_id' => $json['data']['object']['metadata']['order_id']
  1074.                         ]);
  1075.                     }
  1076.                     
  1077.                     if (!empty($response)) {
  1078.                         $members = new MembersUser\Listing();
  1079.                         $members->setCondition('email = :email', [
  1080.                             'email' => $response
  1081.                         ]);
  1082.                         $members->setUnpublished(true);
  1083.                         $members->setLimit(1);
  1084.                         $member = $members->current();
  1085.                         // $member = MembersUser::getByEmail($response, 1);
  1086.         
  1087.                         if ($member instanceof MembersUser) {
  1088.                             $MemberStripeAccountListing = new MemberStripeAccount\Listing();
  1089.                             $MemberStripeAccountListing->setUnpublished(false);
  1090.                             $MemberStripeAccountListing->setCondition('customerId = :customerId AND source__id = :source', [
  1091.                                 'customerId' => $member->getId(),
  1092.                                 'source' => $locationSource->getId()
  1093.                             ]);
  1094.                             $MemberStripeAccountListing->setLimit(1);
  1095.                             $userStripeAccount = $MemberStripeAccountListing->current();
  1096.                         } else {
  1097.                             $logger->error("Member not found from order: ". $json['id']);  
  1098.                         }
  1099.                     } else {
  1100.                         $logger->info($json['data']['object']['customer_email']);
  1101.                         $members = new MembersUser\Listing();
  1102.                         $members->setCondition('email = :email', [
  1103.                             'email' => $json['data']['object']['customer_email']
  1104.                         ]);
  1105.                         $members->setUnpublished(true);
  1106.                         $members->setLimit(1);
  1107.                         $member = $members->current();
  1108.                         // $member = MembersUser::getByEmail($json['data']['object']['customer_email'], 1);
  1109.         
  1110.                         if ($member instanceof MembersUser) {
  1111.                             $MemberStripeAccountListing = new MemberStripeAccount\Listing();
  1112.                             $MemberStripeAccountListing->setUnpublished(false);
  1113.                             $MemberStripeAccountListing->setCondition('customerId = :customerId AND source__id = :source', [
  1114.                                 'customerId' => $member->getId(),
  1115.                                 'source' => $locationSource->getId()
  1116.                             ]);
  1117.                             $MemberStripeAccountListing->setLimit(1);
  1118.                             $userStripeAccount = $MemberStripeAccountListing->current();
  1119.                         } else {
  1120.                             $logger->error("Member not found: ". $json['id']);  
  1121.                         }
  1122.                     }
  1123.                 } else {
  1124.                     $logger->error("Source or order_id not found: ". $json['id']);
  1125.                 }
  1126.             } else {
  1127.                 $userStripeAccount = MemberStripeAccount::getByStripeCustomerId($json['data']['object']['customer'], 1);
  1128.             }
  1129.     
  1130.             
  1131.         } catch(\Exception $e) {
  1132.             $logger->error($e);
  1133.         }
  1135.         if ($userStripeAccount == null || !$userStripeAccount instanceof MemberStripeAccount) {
  1136.             $logger->error("STRIPE ACCOUNT NOT FOUND");
  1137.             // Invalid payload
  1138.             echo '⚠️  STRIPE ACCOUNT NOT FOUND.';
  1139.             http_response_code(200);
  1140.             exit();
  1141.         }
  1142.         
  1143.         $stripeAccount = $userStripeAccount->getSource()->getStripeAccount();
  1144.         $members = new MembersUser\Listing();
  1145.         $members->setCondition('oo_id = :id', [
  1146.             'id' => $userStripeAccount->getCustomerId()
  1147.         ]);
  1148.         $members->setUnpublished(true);
  1149.         $members->setLimit(1);
  1150.         $member = $members->current();
  1151.         // $member = MembersUser::getById($userStripeAccount->getCustomerId());
  1152.         if (!$member instanceof MembersUser) {
  1153.             $logger->error("MEMBER ACCOUNT NOT FOUND");
  1154.             // Invalid payload
  1155.             echo '⚠️  MEMBER ACCOUNT NOT FOUND.';
  1156.             http_response_code(200);
  1157.             exit();
  1158.         }
  1159.         
  1160.         Stripe\Stripe::setApiKey($stripeAccount->getStripeSecret());
  1162.         $stripe = new \Stripe\StripeClient($stripeAccount->getStripeSecret());
  1164.         
  1165.         // Replace this endpoint secret with your endpoint's unique secret
  1166.         // If you are testing with the CLI, find the secret by running 'stripe listen'
  1167.         // If you are using an endpoint defined with the API or dashboard, look in your webhook settings
  1168.         // at https://dashboard.stripe.com/webhooks
  1169.         $endpoint_secret = $stripeAccount->getStripeWebhookSecret();
  1170.         $event = null;
  1171.         try {
  1172.             $event = Stripe\Event::constructFrom($json);
  1173.         } catch (\UnexpectedValueException $e) {
  1174.             $logger->error($e);
  1175.             // Invalid payload
  1176.             echo '⚠️  Webhook error while parsing basic request.';
  1177.             http_response_code(400);
  1178.             exit();
  1179.         }
  1181.         if ($endpoint_secret) {
  1182.             // Only verify the event if there is an endpoint secret defined
  1183.             // Otherwise use the basic decoded event
  1184.             $sig_header = $_SERVER['HTTP_STRIPE_SIGNATURE'];
  1185.             try {
  1186.                 $event = \Stripe\Webhook::constructEvent(
  1187.                     $payload,
  1188.                     $sig_header,
  1189.                     $endpoint_secret
  1190.                 );
  1191.             } catch (\Stripe\Exception\SignatureVerificationException $e) {
  1192.                 $logger->error($e);
  1193.                 // Invalid signature
  1194.                 echo '⚠️  Webhook error while validating signature.';
  1195.                 http_response_code(400);
  1196.                 exit();
  1197.             }
  1198.         }
  1200.         $subscriptEventArray = [
  1201.             'customer.subscription.created',
  1202.             'customer.subscription.deleted',
  1203.             'customer.subscription.updated',
  1204.             'checkout.session.completed',
  1205.             'checkout.session.async_payment_succeeded'
  1206.         ];
  1208.         $logger->info($event->type);
  1209.         if (in_array($event->type, $subscriptEventArray)) {
  1210.             // $member = MembersUser::getByStripeCustomerId($event->data->object['customer'], ['limit' => 1, 'unpublished' => true]);
  1211.             if ($member !== null) {
  1213.                 switch ($event->type) {
  1214.                     case 'checkout.session.completed':
  1215.                     case 'checkout.session.async_payment_succeeded':
  1217.                         if ($event->data->object['status'] === 'complete' && $event->data->object['payment_status'] === 'paid') {
  1218.                             $subs = $event->data->object;
  1219.                             try {
  1220.                                 // $logger->info(count($member->getPromocode()));
  1221.                                 // $logger->info($member->getGroups()[0]->getName());
  1223.                                 if (count($userStripeAccount->getPromocode()) == 0 && isset($member->getGroups()[0]) && $member->getGroups()[0]->getName() === 'Private') {
  1225.                                     $subscriptionEnd = Carbon::now()->addYear();
  1226.                                     $promoCodeAssistenza = $stripe->promotionCodes->create([
  1227.                                         'coupon' => $stripeAccount->getPrivateAssitancePromo(),
  1228.                                         'customer' => $userStripeAccount->getStripeCustomerId(),
  1229.                                         'expires_at' => $subscriptionEnd->timestamp
  1230.                                     ]);
  1231.                                     $promoCodeAttestazione = $stripe->promotionCodes->create([
  1232.                                         'coupon' => $stripeAccount->getPrivateAttestationPromo(),
  1233.                                         'customer' => $userStripeAccount->getStripeCustomerId(),
  1234.                                         'expires_at' => $subscriptionEnd->timestamp
  1235.                                     ]);
  1236.                                     // $userStripeAccount->setPromocode([]);
  1237.                                     // $userStripeAccount->save();
  1239.                                     $promos = [];
  1240.                                     $promos[] = [$stripeAccount->getAssistanceItem(), $promoCodeAssistenza->id];
  1241.                                     $promos[] = [$stripeAccount->getAttestationItem(), $promoCodeAttestazione->id];
  1242.                                     
  1243.                                     if ($promos) {
  1244.                                         $member->setEndDate($subscriptionEnd);
  1245.                                         $userStripeAccount->setPromocode($promos);
  1246.                                         $userStripeAccount->save();
  1247.                                         $member->save();
  1248.                                     }
  1249.                                     
  1250.                                 } else {
  1251.                                     $logger->warning("Promo not applicable. Business user for event: ". $json['id']);
  1252.                                 }
  1253.                                 $logger->info($event->type . ' ->SUCCESS');
  1254.                             } catch (\Exception $e) {
  1255.                                 $logger->error($e->getMessage());
  1256.                                 $message = $e->getMessage();
  1257.                             }
  1258.                         } else {
  1259.                             $logger->error("Error status: ". $json['id']);
  1260.                         }
  1262.                         break;
  1263.                     case 'customer.subscription.created':
  1264.                         $subs = $event->data->object;
  1265.                         if ($subs instanceof \Stripe\Subscription) {
  1266.                             //                                $member->setCreatedDate(Carbon::createFromTimestamp($subs->created));
  1267.                             //                                $message = $member->save();
  1268.                         }
  1269.                         break;
  1270.                     case 'customer.subscription.deleted':
  1271.                         $subs = $event->data->object;
  1272.                         if ($subs instanceof \Stripe\Subscription) {
  1273.                             //                                $member->setEndDate(Carbon::createFromTimestamp($subs->ended_at));
  1274.                             //                                $member->setActive(false);
  1275.                             //                                $message = $member->save();
  1276.                         }
  1277.                         break;
  1278.                     case 'customer.subscription.updated':
  1279.                         $subs = $event->data->object;
  1280.                         if ($subs instanceof \Stripe\Subscription) {
  1281.                             //                                $member->setLastUpdateDate(Carbon::createFromTimestamp(time()));
  1282.                             //                                if ($subs->status === 'paid' || $subs->status === 'active') {
  1283.                             //                                    $member->setActive(true);
  1284.                             //                                } else {
  1285.                             //                                    $member->setActive(false);
  1286.                             //                                }
  1287.                             //
  1288.                             //                                $message = $member->save();
  1289.                         }
  1290.                         break;
  1291.                     default:
  1292.                         // Unexpected event type
  1293.                         $message = 'Received unknown event type';
  1294.                 }
  1295.             } else {
  1296.                 $logger->error("Member not found: ". $json['id']);
  1297.             }
  1298.         } else {
  1299.             $logger->error("Event not found: ". $json['id']);
  1300.         }
  1301.         if ($message !== "") {
  1302.             $logger->error($message);
  1303.             // Invalid payload
  1304.             echo $message;
  1305.         } else {
  1306.             echo '✅  Success!';
  1307.         }
  1308.         
  1309.         http_response_code(200);
  1310.         exit();
  1311.     }
  1313.     //    #[Route('/stripe', name: 'app_stripe')]
  1314.     //    public function index(): Response
  1315.     //    {
  1316.     //        Stripe\Stripe::setApiKey($_ENV["STRIPE_SECRET"]);
  1317.     //        $checkout_session = Stripe\Checkout\Session::create([
  1318.     //            'customer_email' => "work@mdariful.com",
  1319.     //            'line_items' => [[
  1320.     //                # Provide the exact Price ID (e.g. pr_1234) of the product you want to sell
  1321.     //                'price' => "price_1Mf1fSLneZNUF8luklGXV2KU",
  1322.     //                'quantity' => 1,
  1323.     //            ]],
  1324.     //            'allow_promotion_codes' => true,
  1325.     //            'mode' => 'subscription',
  1326.     //            'success_url' => "http://localhost:8009/stripe/success?session_id={CHECKOUT_SESSION_ID}",
  1327.     //            'cancel_url' => "http://localhost:8009/stripe/cancel?session_id={CHECKOUT_SESSION_ID}",
  1328.     //            'tax_id_collection' => [
  1329.     //                'enabled' => true,
  1330.     //            ],
  1331.     //            'billing_address_collection'=> 'required'
  1332.     //        ]);
  1333.     //
  1334.     //        return $this->redirect($checkout_session->url);
  1335.     //    }
  1336.     //
  1337.     //    #[Route('/stripe/success', name: 'app_stripe_success')]
  1338.     //    public function success(Request $request): Response
  1339.     //    {
  1340.     //        Stripe\Stripe::setApiKey($_ENV["STRIPE_SECRET"]);
  1341.     //        $session_id = $request->query->get('session_id');
  1342.     //        $return_url = "http://localhost:8009";
  1343.     //
  1344.     //        $checkout_session = Stripe\Checkout\Session::retrieve($session_id);
  1345.     //        // Authenticate your user.
  1346.     //        $session = Stripe\BillingPortal\Session::create([
  1347.     //            'customer' => $checkout_session->customer,
  1348.     //            'return_url' => $return_url,
  1349.     //        ]);
  1350.     //
  1351.     //        return $this->redirect($session->url);
  1352.     //    }
  1353.     //
  1354.     //    #[Route('/stripe/cancel', name: 'app_stripe_cancel')]
  1355.     //    public function cancel(): Response
  1356.     //    {
  1357.     //        return false;
  1358.     //    }
  1359. }