src/Controller/Cronjob/SubTransactions/StreamMastersController.php line 28

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Cronjob\SubTransactions;
  5. use App\Repository\SubTransactions\StreamMastersRepository;
  6. use App\Service\SettingService;
  7. use App\Service\StreamMasterApi;
  8. use App\Service\TransactionService;
  9. use App\Service\Util\NotificationService;
  10. use Doctrine\ORM\EntityManagerInterface;
  11. use Doctrine\Persistence\ManagerRegistry;
  12. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  13. use Symfony\Component\HttpFoundation\JsonResponse;
  14. use Symfony\Component\Routing\Annotation\Route;
  16. class StreamMastersController extends AbstractController
  17. {
  19.     public TransactionService $transaction;
  20.     public function __construct(TransactionService $transaction)
  21.     {
  22.         $this->transaction = $transaction;
  23.     }
  27.     #[Route('/cronjob/sub/transactions/stream-masters', name: 'app_cronjob_stream_master_cron')]
  28.     public function index(StreamMastersRepository $repository , EntityManagerInterface $managerRegistry,NotificationService $notificationService)
  29.     {
  30.         $settingObject = new SettingService($managerRegistry);
  31.         $api = new StreamMasterApi();
  32.         foreach ($repository->findBy(['isPaid' => false]) as $payment4Object) {
  33.             $res =  $api->getPaymentStatus($settingObject->getSetting('streamMaster_token'),$payment4Object->getRefId());
  34.             if ($res['status'] == 'success'){
  35.                 try {
  36.                     $user = $payment4Object->getOwner();
  37.                     $amount = $payment4Object->getPrice();
  38.                     $setting = new SettingService($managerRegistry);
  39.                     $payment4Object->setIsPaid(true);
  40.                     $this->transaction->createTransaction($user, $amount, "افزایش اعتبار کیف پول  - درگاه استریم مستر-
  41.                   {$amount}
  42.                   تومان
  43.                   - پیگیری : "
  44.                         . $payment4Object->getRefId(), 1, 0, null, 0, null, 'StreamMaster', null, null);
  45.                     $managerRegistry->flush();
  46.                     $managerRegistry->clear();
  47.                 } catch (\Exception $exception) {
  48.                     $notificationService->exception($exception);
  49. //                    $this->telegram->exception($exception);
  50.                 }
  51.             }
  53.         }
  54.         return $this->json(['res' => true]);
  55.     }
  56. }