src/Controller/ServicePaymentController.php line 41

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\InfoSanteSubscription;
  6. use App\Entity\InfoSanteTransaction;
  7. use App\Entity\LabbaikSubscriber;
  8. use App\Entity\LabbaikSubscription;
  9. use App\Entity\LabbaikTransaction;
  10. use App\Entity\SysCloseStatus;
  11. use App\Entity\SysSmsHistory;
  12. use App\Entity\SysTransaction;
  13. use App\Entity\SmartloyerTransaction;
  14. use App\Message\ServicePayment;
  15. use Doctrine\ORM\EntityManagerInterface;
  16. use Doctrine\Persistence\ManagerRegistry;
  17. use PhpParser\Node\Stmt\TryCatch;
  18. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  19. use Symfony\Component\HttpClient\HttpClient;
  20. use Symfony\Component\HttpFoundation\Response;
  21. use Symfony\Component\Routing\Annotation\Route;
  23. class ServicePaymentController extends AbstractController
  24. {
  25.     /**
  26.      * @Route("/service/payment", name="service_payment")
  27.      */
  28.     public function index(): Response
  29.     {
  30.         
  31.         //$this->dispatchMessage(new ServicePayment(57632,"",$this->getDoctrine()));
  32.         //$this->payment(57636,"",$this->getDoctrine());
  33.         return $this->render('service_payment/index.html.twig', [
  34.             'controller_name' => 'ServicePaymentController',
  35.         ]);
  36.     }
  38.     /**
  39.      * @Route("/service/checkPaymentStatus", name="service_payment_status")
  40.      */
  41.     public function checkPaymentStatus(): Response
  42.     {
  43.         $resultReponse = "OK";
  44.         $entityManager = $this->getDoctrine()->getManager();
  45.         $repoTrans = $entityManager->getRepository(SysTransaction::class);
  46.         $transactions = $repoTrans->findBy(['clientPayementStatus' => 'PENDING', 'isClosed' => false]);
  47.         
  48.         foreach($transactions as $transaction){
  49.             if($transaction->getIsSuccessTransaction() && !$transaction->getIsClosed()){
  50.                 $resultReponse = $resultReponse . " " . strval($transaction->getId());
  51.                 $url = "https://bridgeapi.caurispay.com/payement/requestStatus";
  52.                 $client = HttpClient::create([
  53.                     'headers' => [
  54.                     'User-Agent' => 'ReservLine',
  55.                     'Connection' => 'keep-alive',
  56.                     //'Content-Length' => strlen($body),
  57.                     //'Authorization' => $authorization,
  58.                     //'Content-Type' => 'application/json',
  59.                     'Content-Type: application/x-www-form-urlencoded'
  60.                     ],
  61.                     'verify_peer' => false,
  62.                     'verify_host' => false,
  63.                     'body' => ['requestReference' => $transaction->getClientPayementReference()]
  64.                 ]);
  65.             
  66.                 //try{
  68.                 //}catch(){
  69.                     
  70.                 //}
  71.                 $response = $client->request('POST', $url,['timeout' => 400]);
  72.                 
  73.                 //var_dump( $transaction->getClientPayementReference());
  74.                 //var_dump($response->getStatusCode());
  75.                 //var_dump($response->getInfo());
  76.                 if($response->getStatusCode() == 200 or $response->getStatusCode() ==202){
  77.                     
  78.                     $requestResponse = $response->toArray();
  79.                     //var_dump( $requestResponse);
  80.                     if(strcmp($requestResponse["status"],"PENDING") != 0 ){
  81.                         $transaction->setClientPayementTime(new \DateTime('now'));
  82.                         $transaction->setClientPayementStatus($requestResponse["status"]);
  83.                         $transaction->setClientPayementComment($requestResponse["messageText"]);
  84.                         
  85.                         $textMessageSMS = "";
  86.                         $textMessageSMSGAZADMIN ="";
  87.                         $repoClosStatus = $entityManager->getRepository(SysCloseStatus::class);
  88.                         
  89.                         if(strcmp($requestResponse["status"],"SUCCESS") == 0 ){
  90.                             $closeStatus = $repoClosStatus->findOneBy(["statusCode" => "PDPROCS"]); //TODO: Add service code in condition
  91.                             $transaction->setIsClientPaid(true);
  93.                             switch ($transaction->getService()->getCodeService()) {
  94.                                 
  95.                                 case "TTBUS":
  96.                                     //$textMessageSMS = str_replace("%idResv%", $transaction->getReservationCode() , $transaction->getService()->getTextSuccessPayementSMS());
  97.                                     $textMessageSMS = $transaction->getSmsMessage();
  98.                                     break;
  99.                                 case "RCHGAZ":
  100.                                     $textMessageSMS = $transaction->getSmsMessage();
  101.                                     
  102.                                     //Send admin notification email
  103.                                     if($transaction->getEmailNotif() != null){
  104.                                         SysNotifController::sendEmailGazNotif($transaction->getReservationCode() . "-" . $transaction->getMsisdn(), $transaction->getEmailNotif());
  105.                                         $textMessageSMSGAZADMIN = $transaction->getEmailNotif();
  106.                                     }
  107.                                     break;
  108.                                 case "SLOYER":
  109.                                     //$textMessageSMS = str_replace("%idResv%", $transaction->getReservationCode() , $transaction->getService()->getTextSuccessPayementSMS());
  110.                                     //saction = new SmartloyerTransaction();
  111.                                     $sloyerTransactionRepo = $entityManager->getRepository(SmartloyerTransaction::class);
  112.                                     $sloyerTransaction = $sloyerTransactionRepo->findOneBy(["sysTransaction" => $transaction]);
  113.                                     
  114.                                     $url = "https://smartloyer.com/apipayement/makePayement";
  115.                                     $client = HttpClient::create([
  116.                                         'headers' => [
  117.                                         'User-Agent' => 'ReservLine',
  118.                                         'Connection' => 'keep-alive',
  119.                                         //'Content-Length' => strlen($body),
  120.                                         //'Authorization' => $authorization,
  121.                                         //'Content-Type' => 'application/json',
  122.                                         'Content-Type: application/x-www-form-urlencoded'
  123.                                     ],
  124.                                     'verify_peer' => false,
  125.                                     'verify_host' => false,
  126.                                     'body' => ['payementId' => $sloyerTransaction->getPayementId(),
  127.                                             'payementRef' =>  $sloyerTransaction->getPayementRef(),
  128.                                             'ussdSessionRef' => $transaction->getSessionId(),
  129.                                             'ussdPayementRef' => $transaction->getClientPayementReference(), 
  130.                                             'ussdSessionPhone' => $transaction->getMsisdn()]
  131.                                     ]);
  132.         
  133.                                     $response = $client->request('POST', $url,['timeout' => 400]);
  134.                                     $result["statusCode"] = $response->getStatusCode();
  135.                                     //var_dump($result["statusCode"]);
  136.                                     if($result["statusCode"] == 200 or $result["statusCode"] ==202){
  137.                                         $requestResponse = $response->toArray();
  138.                                         //var_dump($requestResponse);
  139.                                         if($requestResponse["success"]){
  140.                                             $sloyerTransaction->setIsPayementUpdate(true);
  141.                                             $sloyerTransaction->setPayementUpdateTime(new \DateTime('now'));
  142.                                             $textMessageSMS = $transaction->getSmsMessage();
  143.                                             $transaction->setIsClosed(true);
  144.                                         }//TODO: Add log for the else statement
  145.                                     }else{
  146.                                         $transaction->setIsClosed(false);
  147.                                     }
  149.                                     break;
  150.                                 case "ESANTE":
  151.                                     $textMessageSMS = $transaction->getService()->getTextSuccessPayementSMS();
  152.                                     $transaction->setIsClosed(true);
  153.                                     $repoInfoSanteTransaction = $entityManager->getRepository(InfoSanteTransaction::class);
  154.                                     $infoSanteTransaction = $repoInfoSanteTransaction->findOneBy(["sysTansaction" => $transaction ]);
  155.                                     $repoSubscription = $entityManager->getRepository(InfoSanteSubscription::class);
  156.                                     $subscription = $repoSubscription->findOneBy(["msisdn"=>$transaction->getMsisdn(), "categorie" =>$infoSanteTransaction->getCategorie()]);
  157.                                     $toDay = new \DateTime('now');
  158.                                     if($subscription == null){
  159.                                         $subscription = new InfoSanteSubscription();
  160.                                         $subscription->setMsisdn($transaction->getMsisdn());
  161.                                         $subscription->setCreationDate(new \DateTime('now'));
  162.                                         $subscription->setCategorie($infoSanteTransaction->getCategorie());
  163.                                         $subscription->setIsActif(true);
  164.                                         $subscription->setStartDate(new \DateTime('now'));
  165.                                         $subscription->setExpiryDate(new \DateTime('now'));
  166.                                     }
  167.                                     $subscription->setIsActif(true);
  168.                                     $subscription->setUpdateDate(new \DateTime('now'));
  169.                                     
  170.                                     if($subscription->getExpiryDate() < $toDay){
  171.                                         $subscription->setStartDate(new \DateTime('now'));
  172.                                         $subscription->setExpiryDate($toDay);
  173.                                     }
  174.                                     $toDay = $subscription->getExpiryDate();
  175.                                     $toDay = date_add($toDay,date_interval_create_from_date_string(strval($infoSanteTransaction->getTypeAbonnement()->getNbrJours()) . " DAYS"));
  176.                                     $subscription->setExpiryDate(date_create(date_format($toDay,"Y-m-d H:i:s")) );
  177.                                     
  178.                                     $entityManager->persist($subscription);
  179.                                    
  180.                                     break;
  181.                                 case "LABBAIK":
  182.                                     $labbaikTransRepo = $entityManager->getRepository(LabbaikTransaction::class);
  183.                                     $labbaikSubscriberRepo = $entityManager->getRepository(LabbaikSubscriber::class);
  184.                                     $labbaikTransaction = $labbaikTransRepo->findOneBy(['sysTransaction' => $transaction]);
  185.                                     $closeStatus = $repoClosStatus->findOneBy(["statusCode" => "SUCCESS"]);
  186.                                     $labbaikTransaction->setTransactionStatus($closeStatus);
  187.                                     if(strcmp(strtolower($labbaikTransaction->getTransactionType()) ,"souscription")==0 or strcmp(strtolower($labbaikTransaction->getTransactionType()) ,"newsouscription")==0){
  188.                                         $textMessageSMS = "Merci pour votre nouvelle souscription au service ".$labbaikTransaction->getSubscriptionType()->getLibelle().". Faite vos paiements a tout moment de votre choix en tapant *450*6#";
  189.                                         
  190.                                         //$subscription = $labbaikTransaction->getSubscription();
  191.                                         
  192.                                         //$subscriber = $labbaikSubscriberRepo->findOneBy(['telephoneNumber' => $transaction->getMsisdn()]);
  193.                                         //if($subscription == null){
  194.                                             //$subscriber = new LabbaikSubscriber();
  195.                                             //$subscriber->setTelephoneNumber($transaction->getMsisdn());
  196.                                             //$entityManager->persist($subscriber);
  197.                                             $subscription = new LabbaikSubscription();
  198.                                             $subscription->setSubscriber($labbaikTransaction->getSubscriber());
  199.                                             $subscription->setSubscribtionType($labbaikTransaction->getSubscriptionType());
  200.                                             $subscription->setMsisdn($labbaikTransaction->getMsisdn());
  201.                                             $subscription->setFeeSubscriptionPaid(true);
  202.                                             $subscription->setSubscriptionActivated(false);
  203.                                             $subscription->setAssPolice1Enable(false);
  204.                                             $subscription->setAssPolice2Enable(false);
  205.                                             $subscription->setAssPolice1Number(sprintf("%06d",strval($labbaikTransaction->getId())));
  206.                                             $subscription->setFeeSubscriptionPaid(true);
  207.                                             $subscription->setCreateDate(new \DateTime("Now"));
  208.                                             $subscription->setUpdateTime(new \DateTime("Now"));
  209.                                             $subscription->setMainBalance($labbaikTransaction->getSubscriptionType()->getCotisationAmount());
  210.                                             $entityManager->persist($subscription);
  211.                                         //}
  212.                                         $labbaikTransaction->setPaymentTime(new \DateTime('now'));
  213.                                         $labbaikTransaction->setPaymentValidated(true);
  214.                                         $labbaikTransaction->setAffectedPoliceId(1);
  215.                                         $labbaikTransaction->setBalanceBefore(0);
  216.                                         $labbaikTransaction->setBalanceAfter($subscription->getMainBalance());
  217.                                         $labbaikTransaction->setSubscription($subscription);
  218.                                         $entityManager->persist($labbaikTransaction);
  220.                                     }elseif(strcmp(strtolower($labbaikTransaction->getTransactionType()) ,"paiement")==0){
  221.                                        
  222.                                         //$labbaikSubscriptionRepo = $entityManager->getRepository(LabbaikSubscription::class);
  223.                                         $subscription = $labbaikTransaction->getSubscription();
  224.                                         $labbaikTransaction->setAffectedPoliceId(1);
  225.                                         $labbaikTransaction->setBalanceBefore($subscription->getMainBalance());
  226.                                         $labbaikTransaction->setPaymentTime(new \DateTime('now'));
  227.                                         $labbaikTransaction->setPaymentValidated(true);
  229.                                         $subscription->setMainBalance($subscription->getMainBalance() + $labbaikTransaction->getTransactionAmount());
  230.                                         $entityManager->persist($subscription);
  231.                                         
  232.                                         $labbaikTransaction->setBalanceAfter($subscription->getMainBalance());
  233.                                         $entityManager->persist($labbaikTransaction);
  234.                                         $textMessageSMS = "Payement de ". strval(intval($labbaikTransaction->getTransactionAmount())) ." au service " . $labbaikTransaction->getSubscriptionType()->getLibelle() ." effectue avec success. votre nouveau solde est de " . strval(intval($subscription->getMainBalance())) . "F" ;
  235.                                     }
  236.                                     $transaction->setIsClosed(true);
  237.                                     //$textMessageSMS = $transaction->getSmsMessage();
  238.                                     //Send admin notification email
  239.                                     if($transaction->getEmailNotif() != null){
  240.                                         SysNotifController::sendEmailGazNotif($transaction->getReservationCode() . "-" . $transaction->getMsisdn(), $transaction->getEmailNotif());
  241.                                     }
  242.                                     break;
  243.                                 
  244.                             }
  245.                         }else{
  246.                             $closeStatus = $repoClosStatus->findOneBy(["statusCode" => "NOTPAID"]); //TODO: Add service code in condition
  247.                             $transaction->setIsClosed(true);
  248.                             $transaction->setCloseComment("Client payment fail");
  249.                             
  250.                             
  251.                             switch ($transaction->getService()->getCodeService()) {
  252.                                 
  253.                                 case "TTBUS":
  254.                                     $textMessageSMS = str_replace("%idResv%", $transaction->getReservationCode() , $transaction->getService()->getTextFailedPayementSMS());
  255.                                     break;
  256.                                 case "RCHGAZ":                                   
  257.                                     $textMessageSMS = str_replace("%idResv%", $transaction->getReservationCode() , $transaction->getService()->getTextFailedPayementSMS());
  258.                                     break;
  259.                                 case "SLOYER":
  260.                                     //$textMessageSMS = str_replace("%idResv%", $transaction->getReservationCode() , $transaction->getService()->getTextSuccessPayementSMS());
  261.                                     $textMessageSMS = str_replace("%idResv%", $transaction->getReservationCode() , $transaction->getService()->getTextFailedPayementSMS());
  262.                                     break;
  263.                                 case "ESANTE":
  264.                                     $textMessageSMS = str_replace("%idResv%", $transaction->getReservationCode() , $transaction->getService()->getTextFailedPayementSMS());
  265.                                     break;
  266.                                 case "LABBAIK":
  268.                                     $textMessageSMS =  $transaction->getService()->getTextFailedPayementSMS();
  269.                                     $labbaikTransRepo = $entityManager->getRepository(LabbaikTransaction::class);
  270.                                     $labbaikTransaction = $labbaikTransRepo->findOneBy(['sysTransaction' => $transaction]);
  271.                                     $labbaikTransaction->setTransactionStatus($closeStatus);
  272.                                     $entityManager->persist($labbaikTransaction);
  273.                                     //var_dump($textMessageSMS);
  274.                                     break;
  275.                             }
  276.                         }
  277.                         $transaction->setCloseStatus($closeStatus);
  278.                 
  279.                         if(strlen($textMessageSMS) > 0){
  280.                             //Send SMS
  281.                             //Send Message and Record SmsHistoy
  282.                             //SysSMSController::sendSMS($transaction->getMsisdn(),$textMessageSMS);
  283.                             //var_dump($textMessageSMS);
  284.                             SysSMSController::sendSMSWithParm($transaction->getMsisdn(),$textMessageSMS,$transaction->getOperator()->getCodeOperator(), $transaction->getService()->getSmsSenderName() );
  285.                             $sysSmsHistory = new SysSmsHistory();
  286.                             $sysSmsHistory->setMsisdn($transaction->getMsisdn());
  287.                             $sysSmsHistory->setMessageText($textMessageSMS);
  288.                             //$sysSmsHistory->setMessageText($textMessageSMS);
  289.                             $sysSmsHistory->setCreateTime(new \DateTime);
  290.                             $sysSmsHistory->setIsReceived(false);
  291.                             $sysSmsHistory->setTransaction($transaction);
  292.                             $sysSmsHistory->setSmsType('PAYMENT_MSG');
  293.                             $entityManager->persist($sysSmsHistory);
  294.                             //$entityManager->flush();
  295.                         }
  296.                         
  297.                         if(strlen($textMessageSMSGAZADMIN) > 0){
  298.                             //Send SMS
  299.                             //Send Message and Record SmsHistoy
  300.                             SysSMSController::sendSMSWithParm("22995000169",$textMessageSMSGAZADMIN,"MOOVBJ", "RESERVLINE" );
  301.                             $sysSmsHistory = new SysSmsHistory();
  302.                             $sysSmsHistory->setMsisdn("22995000169");
  303.                             $sysSmsHistory->setMessageText($textMessageSMSGAZADMIN);
  304.                             $sysSmsHistory->setCreateTime(new \DateTime);
  305.                             $sysSmsHistory->setIsReceived(false);
  306.                             $sysSmsHistory->setTransaction($transaction);
  307.                             $sysSmsHistory->setSmsType('ADMIN');
  308.                             $entityManager->persist($sysSmsHistory);
  309.                             //$entityManager->flush();
  310.                         }
  311.                         //$transaction->setPayementReference($result["isSuccess"]);
  312.                         $entityManager->persist($transaction);
  313.                         $entityManager->flush();
  314.                     }
  315.                 }
  316.             }
  317.         }
  318.         //$this->dispatchMessage(new ServicePayment(56,$this->getDoctrine()));
  319.         $JResponse = new Response();
  320.         $JResponse->headers->set('Content-Type', 'application/json', 'charset=utf-8');
  321.         $JResponse->setCharset('UTF-8');
  322.         $JResponse->setContent(json_encode($resultReponse));
  323.         return $JResponse;
  324.     }
  327.     public function payment(int $transctionId, string $referenceId,ManagerRegistry  $doctrineRes){
  329.         //var_dump("Start paymenet ===>");
  330.         $entityManager = $doctrineRes->getManager();
  331.         $repoTrans = $doctrineRes->getRepository(SysTransaction::class);
  332.         $transaction = $repoTrans->find($transctionId);
  333.         if($transaction->getIsSuccessTransaction() && !$transaction->getIsClosed()){
  334.             //sleep(1);
  335.             //var_dump("2Start paymenet request ===>");
  336.             $operateurCode = "";
  337.             $payeReferentId = $transaction->getReferenceId() . '+' . $transaction->getReservationCode() . '+' . strVal(rand(111,999));
  338.             $payementAmount = ceil(intval($transaction->getServiceTransactionAmount()));
  339.             if(strcmp($transaction->getOperator()->getCodeOperator(),"MOOVBJ") == 0){
  340.                 $operateurCode = "MOOVBENIN";
  341.             }    
  342.             if(strcmp($transaction->getOperator()->getCodeOperator(),"MTNBJ") == 0){
  343.                 $operateurCode = "MTNBENIN";
  344.             }
  345.             //$url = "https://caurispay.ridcode.com:8184/payement/requestPayement";
  346.             $url = "https://bridgeapi.caurispay.com/payement/requestPayement";
  347.             $client = HttpClient::create([
  348.                 'headers' => [
  349.                 'User-Agent' => 'ReservLine',
  350.                 'Connection' => 'keep-alive',
  351.                 //'Content-Length' => strlen($body),
  352.                 //'Authorization' => $authorization,
  353.                 //'Content-Type' => 'application/json',
  354.                 'Content-Type: application/x-www-form-urlencoded'
  355.                  ],
  356.                 'verify_peer' => false,
  357.                 'verify_host' => false,
  358.                 'body' => ['operatorCode' => $operateurCode, 'accountNumber' =>  $transaction->getMsisdn(),
  359.                            'payementAmount' => $payementAmount,
  360.                             'currency' => 'CFA', 'transactionType' => 'DEBIT',
  361.                              'merchantReference' => $payeReferentId,
  362.                              'merchantComment' => $transaction->getService()->getLibelle()]
  363.             ]);
  364.         
  365.             $response = $client->request('POST', $url,['timeout' => 400]);
  366.             //var_dump("Response code ===>");
  367.             //var_dump($response->getStatusCode());
  368.             
  369.             //$result["isSuccess"] = false;
  370.             $result["statusCode"] = $response->getStatusCode();
  371.             //var_dump($response->toArray());
  372.             if($result["statusCode"] == 200 or $result["statusCode"] ==202){
  373.                 $result["requestResponse"] = $response->toArray();
  374.                 if($result["requestResponse"]["isSuccess"]){
  375.                     $repoClosStatus = $entityManager->getRepository(SysCloseStatus::class);
  376.                     $closeStatus = $repoClosStatus->findOneBy(["statusCode" => "PDPAYE"]); //TODO: Add service code in condition
  377.                     $transaction->setCloseStatus($closeStatus);
  378.                     //$transaction->setClientPayementCanal("CAURISPAY");
  379.                     $transaction->setClientPayementTelephone($transaction->getMsisdn());
  380.                     $transaction->setClientPayementAccount($transaction->getMsisdn());
  381.                     $transaction->setClientPayementStatus($result["requestResponse"]["status"]);
  382.                     $transaction->setClientPayementReference($payeReferentId);
  383.                     $transaction->setClientPayementAmount($payementAmount);
  384.                     //$transaction->setPayementReference($result["isSuccess"]);
  385.                     $entityManager->persist($transaction);
  386.                     $entityManager->flush();
  387.                 }
  388.             }
  389.             //var_dump("End paymenet ===>");
  390.             return $result;
  391.         }
  393.     }
  396.     public function checkPayementStatus(SysTransaction $transaction,ManagerRegistry  $doctrineRes ){
  397.         $entityManager = $doctrineRes->getManager();
  398.         $repoTrans = $doctrineRes->getRepository(SysTransaction::class);
  399.     }
  400. }