src/Controller/FpsController.php line 423

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  6. use Symfony\Component\HttpFoundation\Request;
  7. use Symfony\Component\HttpFoundation\Response;
  8. use Symfony\Component\HttpFoundation\JsonResponse;
  9. use Symfony\Component\Process\Process;
  11. use FOS\RestBundle\Controller\Annotations\Get;
  12. use FOS\RestBundle\Controller\Annotations\Post;
  13. use FOS\RestBundle\Controller\Annotations\Patch;
  14. use FOS\RestBundle\Controller\Annotations\View;
  15. use FOS\RestBundle\Controller\Annotations\QueryParam;
  16. use FOS\RestBundle\Request\ParamFetcher;
  17. use Symfony\Component\HttpFoundation\StreamedResponse;
  19. use App\Exyzt\JwtAuthentificationBundle\Lib\Util;
  20. use App\Exyzt\JwtAuthentificationBundle\Services\TokenService;
  22. use App\Service\FPS\CouchConnectionService as couchDB;
  24. use App\Service\FPS\PlateValidatorService;
  25. use App\Service\FPS\CalculFpsService;
  26. use App\Service\FPS\FpsService;
  27. use App\Service\FPS\FpsCsvService;
  29. use App\Entity\Fps;
  30. use App\Entity\ActivityFPS;
  31. use App\Entity\Payment;
  32. use App\Entity\Claim;
  33. use App\Entity\FpsComment;
  35. use JsonSchema\Validator;
  36. use JsonSchema\Constraints\Constraint;
  37. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Security;
  38. use App\Exyzt\RESTBundle\Controller\AbstractRESTController;
  40. use App\Repository\FpsRepository;
  41. use App\Repository\ClaimRepository;
  43. use App\Log\CustomLogger;
  44. use Doctrine\Persistence\ManagerRegistry;
  46. class FpsController extends AbstractRESTController
  47. {
  49.     /**
  50.      * Calcul le montant du FPS en POST
  51.      * @Post("/api/{cityId}/fine-values/v1")
  52.      * @Security("is_granted('ROLE_PDA_FPS')")
  53.      *
  54.      */
  55.     public function postCalculFPSAction(Request $request, couchDB $couchDB, CalculFpsService $calculFPS, PlateValidatorService $plateValidator, FpsService $serviceFps){
  56.         
  57.         $logFile = 'FPS-FINE-VALUES-' . $request->get('cityId') . '.log';
  58.         $logger = new CustomLogger('fine-values');
  59.         $logger->setFileOptions($logFile, 30);
  61.         $data =  Util::getDataRequest($request);
  63.         $logger->info("*** CALCUL DE PRIX ", $data);
  64.         
  66.         $user = $this->getUser();
  67.         if($user->getCodeVille() != $request->get('cityId')){
  68.             $logger->error("Invalid cityId", ["Request=".$request->get('cityId'), "UserToken=".$user->getCodeVille()]);
  69.             $logger->info("* FIN DU CALCUL");
  71.             $errors[0]=array("code"=>"401","type"=>"Unauthorized");
  72.             return new JsonResponse(array("errors"=>$errors), Response::HTTP_UNAUTHORIZED,array(),false);
  73.         }
  76.         $client = $couchDB->getClient("city_".$request->get('cityId')."_ref_fps_metadata");
  78.         if(isset($data['zoneId'])){
  79.             $docName = 'ZONE_'.$data['zoneId'];
  80.         }
  81.         elseif(isset($data['parkId'])){
  82.             $docName = 'PARK_'.$data['parkId'];
  83.         }
  85.         try {
  86.             $doc = $client->getDoc($docName);
  87.         }
  88.         catch(\Exception $e){
  89.             $logger->error("Zone tarifaire ou parc inconnu", [$e]);
  90.             $logger->info("* FIN DU CALCUL");
  92.             $errors[0] = array("code"=>"1004","type"=>"Zone tarifaire inconnue");
  93.             return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  94.         }
  96.         if(substr($docName,0,4) === "ZONE" && property_exists($doc, 'error')){
  97.             $logger->error("Zone tarifaire inconnue", json_decode($doc->error, true));
  98.             $logger->info("* FIN DU CALCUL");
  100.             $errors[0]=array("code"=>"1004","type"=>"Zone tarifaire inconnue");
  101.             return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  102.         }
  103.         
  104.         if(substr($docName,0,4) === "PARK" && property_exists($doc, 'error')){
  105.             $logger->error("Parc inconnu", json_decode($doc->error, true));
  106.             $logger->info("* FIN DU CALCUL");
  107.             
  108.             $errors[0]=array("code"=>"1014","type"=>"Parc inconnu");
  109.             return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  110.         }
  112.         $prices = json_decode(json_encode($doc->prices), true);
  113.         $timeReduced = property_exists($doc, 'timeReduced') ? json_decode(json_encode($doc->timeReduced), true): null;
  114.         $timeValidity = json_decode(json_encode($doc->timeValidity), true);
  115.         $timeZone = property_exists($doc, 'timeZone') ? json_decode(json_encode($doc->timeZone), true): 'Europe/Paris';
  116.         date_default_timezone_set($timeZone);
  117.         $freeDay = json_decode(json_encode($doc->freeDay), true);
  118.         $week = json_decode(json_encode($doc->week), true);
  120.         $gracePeriod = property_exists($doc, 'gracePeriod') ? json_decode(json_encode($doc->gracePeriod), true): 0.00;
  121.         $gracePeriodMax = property_exists($doc, 'gracePeriodMax') ? json_decode(json_encode($doc->gracePeriodMax), true): 0;
  123.         $dataForSchema = json_decode(json_encode($data), FALSE);
  124.         $schema = $serviceFps->getSchema(realpath(__DIR__.'/../Schemas/calculFps.json'));
  125.         $validator = new Validator;
  126.         $validator->coerce($dataForSchema, $schema);
  128.         if ($validator->isValid()) {
  130.             if($data['licensePlate']['plateCountry'] === 'FR'){
  132.                 $plateValid = $plateValidator->analysePlate($data['licensePlate']);
  134.                 if (sizeof($plateValid['error']) > 0) {
  135.                     $logger->error("Erreur lors de la validation de plaque d'immatriculation", $plateValid['error']);
  136.                     $logger->info("* FIN DU CALCUL");
  137.                     
  138.                     return new JsonResponse(array("errors"=>$plateValid['error']), 422, array(), false);
  139.                 } else {
  140.                     $data['licensePlate'] = $plateValid['licensePlate'];
  141.                 }
  142.             }
  143.             else{
  144.                 $data['licensePlate']['plate'] =  strtoupper(str_replace(array(' ','-'), '', $data['licensePlate']['plate']));
  145.             }
  147.             $statementDatetimeString=$data['statementDatetime'];
  148.             $statementDatetime=new \DateTime($statementDatetimeString);
  149.             $statementDatetime2 = clone $statementDatetime;
  150.             if($statementDatetime2->sub(new \DateInterval('PT10M')) > new \DateTime('now')){
  151.                 $logger->error("Date de constatation invalide", [$data['statementDatetime']]);
  152.                 $logger->info("* FIN DU CALCUL");
  154.                 $errors[0]=array("code"=>"1005","type"=>"Date de constatation invalide");
  155.                 return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  156.            }
  158.             $response = $calculFPS->getCalculFps($client, $data, $week, $timeValidity, $timeZone, $freeDay, $prices, $timeReduced, $gracePeriod, $gracePeriodMax);
  159.             
  160.             $logger->info("RESPONSE OK", $response);
  161.             $logger->info("* FIN DU CALCUL");
  162.             
  163.             return new JsonResponse($response,Response::HTTP_OK,array(),false);
  164.         }
  165.         else {
  166.             $logger->error("Echec de validation des champs fournis", $validator->getErrors());
  167.             $logger->info("* FIN DU CALCUL");
  168.             
  169.             $errors[0]=array("code"=>"1001","type"=>"Structure de la requête invalide");
  170.             return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  171.         }
  172.     }
  175.     /**
  176.      * Créer un FPS
  177.      * @View()
  178.      * @Post("/api/{cityId}/fines/v1")
  179.      * @Security("is_granted('ROLE_PDA_FPS') or is_granted('ROLE_RAPO_UPDATE') or is_granted('ROLE_SVC_FPS_CREATE')")
  180.      *
  181.     */
  182.     public function postFPSAction(Request $request, $cityId, TokenService $token, PlateValidatorService $plateValidator, FPSservice $serviceFps, ManagerRegistry $registry){
  184.         $user = $this->getUser();
  185.         if ( $user->getCodeVille() != $request->get('cityId')){
  186.            $errors[0] = array("code"=>"401","type"=>"Unauthorized");
  187.            return new JsonResponse(array("errors"=>$errors), Response::HTTP_UNAUTHORIZED,array(),false);
  188.         }
  190.         $data =  Util::getDataRequest($request);
  192.         if (substr($data['fineLegalId'],0,14) !== $request->get('cityId') ){
  193.             $errors[0] = array("code"=>"401","type"=>"Unauthorized");
  194.             return new JsonResponse(array("errors"=>$errors), Response::HTTP_UNAUTHORIZED,array(),false);
  195.         }
  197.         if ($data['type']==='INITIAL'){
  198.             // INITIAL should not have 'claims', 'surcharge' should not be gretter than 0, 'finePrice' should not be 0 (== instead of === in case of value is passed as string)
  199.             if ( isset($data['claims']) || (isset( $data['surcharge'] ) && $data['surcharge'] > 0) || $data['finePrice'] == 0) {
  200.                 $errors[0] = array( "code" => "1001", "type" => "Structure de la requête invalide" );
  201.                 return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  202.             }
  203.         }
  205.         if ( intval($data['finePrice']) < 0) {
  206.             $errors[0] = array( "code" => "1001", "type" => "Structure de la requête invalide" );
  207.             return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  208.         }
  210.         $dataForSchema = json_decode(json_encode($data), FALSE);
  211.         $schema = $serviceFps->getSchema(realpath(__DIR__.'/../Schemas/fpsCreate.json'));
  212.         $validator = new Validator;
  213.         $validator->validate($dataForSchema, $schema, Constraint::CHECK_MODE_COERCE_TYPES);
  215.         if ($validator->isValid()) {
  217.             $em = $registry->getManager( self::_PREFIX_EM.$cityId);
  218.             /** @var FpsRepository $repository*/
  219.             $repository = $registry->getRepository('App:Fps', self::_PREFIX_EM.$cityId);
  221.             $fpsEntity = $repository->findOneBy( ["fineLegalId" => $data['fineLegalId']] );
  223.             if ( $fpsEntity ){
  224.                 $errors[0] = array("code" => "1003","type" => "Numéro de FPS déjà existant");
  225.                 return new JsonResponse( array("errors"=>$errors ), 422 ,array(),false);
  226.             }
  227.             if ( strlen( $data['fineLegalId']) != 26 ){
  228.                 $errors[0] = array("code" => "1002","type" => "Numéro de FPS invalide" );
  229.                 return new JsonResponse( array("errors"=>$errors ), 422 ,array(),false);
  230.             }
  231.             if ( isset( $data['fineShortId'] ) ){
  232.                 $exist = $repository->fineShortIdAvailable( $data['fineShortId'], $data['cityId']);
  233.                 if ( $exist){
  234.                     $errors[0] = array("code"=>"1101","type"=>"Numéro de FineShortId non valide");
  235.                     return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  236.                 }
  237.             }
  239.             $conn = $registry->getConnection(self::_PREFIX_CONNECT.$cityId);
  240.             $conn->beginTransaction(); // suspend auto-commit
  241.             try {
  243.                 $fps = new Fps;
  245.                 $fps->setOriginalFpsJson( $request->getContent() );
  247.                 $fps->setFineLegalId( $data['fineLegalId'] );
  249.                 $dateModified = new \DateTime('now');
  250.                 $dateModifiedRCF3339 = $dateModified->format(\DateTime::ATOM);
  251.                 $fps->setDateModified( new \DateTime( $dateModifiedRCF3339 ) );
  253.                 $fps->setType($data['type']);
  254.                 $fps->setParent(array_key_exists('parent',$data) ? $data['parent'] : null);
  255.                 $fps->setRootFineLegalId(array_key_exists('rootFineLegalId',$data) ? $data['rootFineLegalId'] : null);
  256.                 $fps->setAuthId($data['authId']);
  257.                 $fps->setAgentId($data['agent']['agentId']);
  258.                 $fps->setCityId($request->get('cityId'));
  259.                 $fps->setZoneId(array_key_exists('zoneId',$data) ? $data['zoneId'] : null);
  260.                 $fps->setParkId(array_key_exists('parkId',$data) ? $data['parkId'] : null);
  261.                 $fps->setNotificationAuthority($data['notificationAuthority']);
  262.                 $fps->setPaymentStatus($data['paymentStatus']);
  263.                 $fps->setName($data['agent']['name']);
  264.                 $fps->setStatementDatetime(new \DateTime($data['statementDatetime']));
  265.                 $fps->setTerminalId($data['terminalId']);
  267.                 if($data['licensePlate']['plateCountry'] === 'FR'){
  268.                     $plateValid = $plateValidator->analysePlate( $data['licensePlate'] );
  269.                     if (sizeof($plateValid['error']) > 0) {
  270.                         return new JsonResponse(array("errors"=>$plateValid['error']), 422, array(), false);
  271.                     } else {
  272.                         $data['licensePlate'] = $plateValid['licensePlate'];
  273.                     }
  274.                 }
  275.                 else{
  276.                     $data['licensePlate']['plate'] =  strtoupper(str_replace(array(' ','-'), '', $data['licensePlate']['plate']));
  277.                 }
  278.                 $fps->setPlate( $data['licensePlate']['plate'] );
  279.                 $fps->setPlateCountry( $data['licensePlate']['plateCountry'] );
  281.                 $fps->setBrand($data['vehicle']['brand']);
  282.                 $fps->setModel(array_key_exists('model',$data['vehicle']) ? $data['vehicle']['model'] : null);
  283.                 $fps->setFinePrice($data['finePrice']);
  284.                 $fps->setValidityDatetime(new \DateTime($data['validityDatetime']));
  285.                 $fps->setReducedFinePrice(array_key_exists('reducedFinePrice',$data) ? $data['reducedFinePrice'] : null);
  286.                 $fps->setReducedDatetime(array_key_exists('reducedDatetime',$data) ? new \DateTime($data['reducedDatetime']) : null);
  287.                 $fps->setAuthTransfertDateTime(array_key_exists('authTransfertDateTime',$data) ? new \DateTime($data['authTransfertDateTime']) : null);
  288.                 $fps->setNotificationDatetime(array_key_exists('notificationDatetime',$data) ? new \DateTime($data['notificationDatetime']) : null);
  289.                 $fps->setPricingCategory(array_key_exists('pricingCategory',$data['licensePlate']) ? $data['licensePlate']['pricingCategory'] : null);
  290.                 $fps->setVehiculeCategory(array_key_exists('vehiculeCategory',$data['vehicle']) ? $data['vehicle']['vehiculeCategory'] : null);
  291.                 $fps->setOffender(array_key_exists('offender',$data) ? $data['offender'] : null);
  292.                 $fps->setSurcharge(array_key_exists('surcharge',$data) ? $data['surcharge'] : null);
  293.                 $fps->setTerminalType(array_key_exists('terminalType', $data) ? $data['terminalType'] : null);
  295.                 if(array_key_exists('claims',$data)){
  296.                     foreach($data['claims'] as $c){
  298.                         $claim = new Claim;
  299.                         $claim->setClaimStatus($c['claimStatus']);
  300.                         $claim->setClaimType($c['claimType']);
  301.                         if(isset($c['claimReason'])){
  302.                             $claim->setClaimReason($c['claimReason']);
  303.                         }
  304.                         $claim->setDateModified(new \DateTime($c['dateModified']));
  305.                         $claim->setFps($fps);
  306.                         $fps->addClaim($claim);
  307.                         $em->persist($claim);
  308.                     }
  309.                 }
  311.                 if(!empty($data['comments'])) {
  312.                     foreach($data['comments'] as $com) {
  313.                         // Create comment
  314.                         $comment = new FpsComment;
  315.                         $comment->setAgentId($com['agent']['agentId']);
  316.                         $comment->setName($com['agent']['name']);
  317.                         $comment->setText(trim($com['text']));
  318.                         $comment->setCreationDatetime(new \Datetime($com['creationDatetime']));
  319.                         $comment->setFineId($fps);
  320.                         // Add comment to FPS
  321.                         $fps->addComment($comment);
  322.                         // Persist comment
  323.                         $em->persist($comment);
  324.                     }
  325.                 }
  327.                 if ($fps->getType() === 'CORRECTION' ){
  328.                     $fpsParent = $repository->findOneBy(['fineLegalId' => $fps->getParent() ]);
  329.                     if ($fpsParent == null){
  330.                         $errors[0] = array( "code" => "1001", "type" => "Structure de la requête invalide" );
  331.                         return new JsonResponse( array( "errors"=>$errors ), 422 , array(), false );
  332.                     }
  333.                     else {
  334.                         $fpsParent->setDateModified(new \Datetime('now'));
  335.                         $em->persist($fpsParent);
  336.                     }
  337.                 }
  340.                 $idUser = $token->getUserId( $request );
  341.                 $activity = new ActivityFPS;
  342.                 $activity->setIdUser( $idUser );
  343.                 $activity->setMethod('POST');
  344.                 $activity->setBody( $request->getContent() );
  345.                 $activity->setFps( $fps );
  347.                 $em->persist( $activity );
  348.                 $em->persist( $fps );
  349.                 $em->flush();
  350.                 $fineId = $fps->getFineId();
  351.                 if ( isset( $data['fineShortId']) ){
  352.                     $fineShortId = $data['fineShortId'];
  353.                 }else {
  354.                     $fineShortId = $serviceFps->createShortId($fineId);
  355.                 }
  356.                 $fps->setFineShortId( $fineShortId );
  357.                 $em->persist( $fps );
  358.                 $em->flush();
  359.                 $em->refresh( $fps );
  361.                 $conn->commit();
  363.             } catch (\Throwable $t) {
  364.                 $conn->rollBack();
  365.                 $errorInfo = array_values(array_filter( $t->getPrevious()->errorInfo, fn($value, $key) => str_contains($value, 'ERROR'), ARRAY_FILTER_USE_BOTH));
  366.                 $message = array_values(array_filter(explode("\n", $errorInfo[0]), fn($value, $key) => str_contains($value, 'ERROR'), ARRAY_FILTER_USE_BOTH));
  367.                 $errors[0] = array("code" => "1003", "type" => "Numéro de FPS déjà existant", "message" => count($message) > 0 ? $message[0] : "Une erreur est survenue lors de l'enregistrement du FPS");
  368.                 return new JsonResponse( array("errors"=>$errors ), 422 ,array(),false);
  369.             }
  371.             try {
  372.                 $fpsCree = $fps->getFormat();
  373.                 $codeWorkSpace = $request->get('cityId');
  374.                 $links = Util::serialize( $fps, $codeWorkSpace, array('self'), true, $expand = "");
  375.                 $jsonResponse = new JsonResponse( json_encode( $fpsCree ), Response::HTTP_CREATED, array( "Location" => json_decode( $links)->{'_links'}->self->href ), true );
  377.                 $process = new Process(['sh', $_ENV['APP_DIR'].'/scripts/FPS/send-fps.sh']);
  378.                 $process->start();
  380.                 return $jsonResponse;
  382.             } catch (\Exception $e) {
  383.                 return  $e->getMessage();
  384.             }
  386.         }
  387.         else {
  388.             $errors[0] = array( "code" => "1001", "type" => "Structure de la requête invalide" );
  389.             return new JsonResponse( array( "errors"=>$errors ), 422 , array(), false );
  390.         }
  391.     }
  395.      /**
  396.      * Récupère une liste de FPS en fonction de criteres en POST
  397.      * @Post("/api/{cityId}/fines-search/v1")
  398.      * @Security("is_granted('ROLE_PC_FPS') or is_granted('ROLE_SVC_FPS_READ')")
  399.      */
  400.     public function postFPSListAction(Request $request, $cityId, FPSService $serviceFps){
  401.         
  402.         $maxRecordsDefault = 25;
  403.         $pageDefault = 1;
  405.         // get and json decode request
  406.         $search = empty(Util::getDataRequest($request)) ? ["maxRecords" => $maxRecordsDefault] : Util::getDataRequest($request);
  407.         $user = $this->getUser();
  408.         
  409.         $verifications = $serviceFps->verificationsAuthorizationPlateFormatAndFormatJson($user->getCodeVille(),$cityId,$search );  
  411.         if ( sizeof($verifications['error']) > 0) { 
  412.             return new JsonResponse($verifications['error'], 422 ,array(),false);
  413.         }
  414.         else {
  415.             //replace search by search after verifications
  416.             $search = $verifications['search'];
  418.             // integral true for a complete FPS json
  419.             $integral = ($user->hasRole('ROLE_FPS_COMPLETE') && $request->get('integral') != null) ? 'complete' : false ;
  421.             // find FPSList - filter by search
  422.             /** @var FpsRepository $repositoryFPS */
  423.             $repositoryFPS = $this->getDoctrine()->getRepository('App:Fps',  self::_PREFIX_EM.$cityId);   
  424.             
  425.             $fpsResultSearch = $repositoryFPS->getFpsFromSearch($search, $cityId, $integral);
  427.             // for each FPS found, clean and push as json in matches table
  428.             $matches = $serviceFps->cleanFpsList($fpsResultSearch);
  430.             // informations pages, total ...
  431.             $currentPage = isset($search['page']) ? intval($search['page']) : $pageDefault;
  432.             $limit = (isset($search['maxRecords']) && $search['maxRecords'] > 0) ? intval($search['maxRecords']) : $maxRecordsDefault;
  434.             // count false if return total is not required 
  435.             $count = $request->get('count') != null ? $request->get('count') : true ;
  436.             $total_records = ( !$count ) ? 0 : $repositoryFPS->getCountFps( $search, 'count');
  437.             $total_pages = intval( ceil( $total_records / $limit ));
  439.             if ( $currentPage > $total_pages ) {
  440.                 $res = array();
  441.             } else {
  442.                 $res = array( "previousPage" => $currentPage - 1, "nextPage" => $currentPage + 1, "matches" => $matches, "total" => $total_records);
  443.                 if ( $currentPage === 1 ) {
  444.                     unset( $res['previousPage'] );
  445.                 }
  446.                 if ($currentPage === $total_pages || $total_pages === 0) {
  447.                     unset( $res['nextPage'] );
  448.                 }
  449.             }
  451.             return new JsonResponse($res, (sizeof($matches) === 0) ? Response::HTTP_NO_CONTENT : Response::HTTP_OK, array(), false);
  452.         }
  454.     }
  456.     /**
  457.      * Récupère un FPS en fonction de son fineId
  458.      * @Get("/api/{cityId}/fines/v1/{fineId}", requirements = {"fineId": "[0-9]+"})
  459.      * @Security("is_granted('ROLE_PC_FPS') or is_granted('ROLE_SVC_FPS_READ')")
  460.      */
  461.     public function getFPSAction(Request $request, $cityId, $fineId, FPSService $serviceFps){
  462.         
  463.         // User vérifications authorizations
  464.         $user = $this->getUser();
  465.         if($user->getCodeVille() != $request->get('cityId') ){
  466.                 $errors[0] = array("code"=>"401","type"=>"Unauthorized");
  467.                 return new JsonResponse(array("errors"=>$errors), Response::HTTP_UNAUTHORIZED,array(),false);
  468.         }
  470.         // fineId format verifications
  471.         if(!is_int((int) $fineId)){
  472.             $errors[0]=['code' => '1','type' => 'Fine Id doit être un entier valide'];
  473.             return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  474.         }
  476.         // integral true for a complete FPS json
  477.         $integral = ($user->hasRole('ROLE_FPS_COMPLETE') && $request->get('integral') != null) ? 'complete' : null ;
  479.         // find FPS by fineId
  480.         /** @var FpsRepository $repositoryFPS */
  481.         $repositoryFPS = $this->getDoctrine()->getRepository('App:Fps',  self::_PREFIX_EM.$cityId);          
  482.         $fps = $repositoryFPS->getFpsFormatedByfineId($fineId, $cityId, $integral);
  484.         if(empty($fps) ){
  485.             $errors[0] = ['code' => Response::HTTP_NOT_FOUND,'type' => 'Aucun FPS n’a été trouvé'];
  486.             return new JsonResponse(array("errors"=>$errors), Response::HTTP_NOT_FOUND,array(),false);
  487.         }
  489.         if ($fps['cityId'] != $request->get('cityId')){
  490.             $errors[0] = ['code' => Response::HTTP_NOT_FOUND,'type' => 'La ville du FPS ne correspond pas'];
  491.             return new JsonResponse(array("errors"=>$errors), Response::HTTP_NOT_FOUND,array(),false);
  492.         }
  494.         // clean null value
  495.         $fps = $serviceFps->cleanFps($fps);
  497.         $response = new JsonResponse(json_encode($fps), Response::HTTP_OK, array(), true);
  498.         $response->setEtag(md5($response->getContent()));
  499.         $response->headers->set('Access-Control-Expose-Headers', 'ETag');
  500.         return $response;
  501.     }
  503.     /**
  504.      * Modifie un FPS
  505.      * @Patch("/api/{cityId}/fines/v1/{fineId}",
  506.      *         requirements = {
  507.      *             "fineId": "[0-9]+"
  508.      *         })
  509.      * @Security("is_granted('ROLE_PC_FPS') or is_granted('ROLE_PDA_FPS') or is_granted('ROLE_SVC_FPS_UPDATE')")
  510.      *
  511.      */
  512.     public function patchFPSAction(Request $request, $cityId,$fineId, TokenService $token, FPSservice $serviceFps){
  513.         
  514.         /////////////////// header verifications
  515.         $user = $this->getUser();
  516.         if ( $user->getCodeVille() != $request->get('cityId') ) {
  517.             $errors[0] = array( "code" => "401", "type" => "Unauthorized");
  518.             return new JsonResponse( array( "errors" => $errors ), Response::HTTP_UNAUTHORIZED, array(), false);
  519.         }
  520.         if ( ! is_int((int) $fineId)){
  521.             $errors[0] = [ 'code' => '1', 'type' => 'Fine Id doit être un entier valide' ];
  522.             return new JsonResponse( array( "errors" => $errors ), 422 , array(), false);
  523.         }
  524.         $ifMatch = $request->headers->get('If-Match'); 
  526.         $datas =  Util::getDataRequest($request);
  528.         $dataForSchema = json_decode(json_encode($datas), FALSE);
  529.         $schema = $serviceFps->getSchema( realpath(__DIR__.'/../Schemas/updateFps.json') );
  531.         $validator = new Validator;
  532.         $validator->coerce($dataForSchema, $schema);
  534.         if ( ! $validator->isValid()) {        
  535.             $errors[0] = array( "code" => "1001", "type" => "Structure de la requête invalide" );
  536.             return new JsonResponse( array("errors" => $errors, "validation" => $validator->getErrors()), 422 , array(), false);
  537.         } 
  538.         else { 
  539.             ///////////////// connected entity manager
  540.             $em = $this->getDoctrine()->getManager(self::_PREFIX_EM.$cityId); 
  541.             /** @var FpsRepository $repositoryFPS */
  542.             $repositoryFPS = $this->getDoctrine()->getRepository('App:Fps',  self::_PREFIX_EM.$cityId);  
  543.         
  544.             ///////////////// find FPS by fineId for verifications - same format than the last format return for stade       
  545.             $fps = $repositoryFPS->getFpsFormatedByfineId($fineId, $cityId, null);
  546.             if(empty($fps) ){
  547.                 $errors[0] = ['code' => Response::HTTP_NOT_FOUND,'type' => 'Aucun FPS n’a été trouvé'];
  548.                 return new JsonResponse(array("errors"=>$errors), Response::HTTP_NOT_FOUND,array(),false);
  549.             }
  550.             if ($fps['cityId'] != $request->get('cityId')){
  551.                 $errors[0] = ['code' => Response::HTTP_NOT_FOUND,'type' => 'La ville du FPS ne correspond pas'];
  552.                 return new JsonResponse(array("errors"=>$errors), Response::HTTP_NOT_FOUND,array(),false);
  553.             }
  554.             // clean null value
  555.             $fps = $serviceFps->cleanFps($fps);
  557.             ////////////Vérification if is the same FPS, with no modification /////////////////
  558.             if(substr($ifMatch,1,strlen($ifMatch)-2) !== md5(json_encode($fps))){
  559.                 return new JsonResponse(null, Response::HTTP_PRECONDITION_FAILED,array(),false);
  560.             }
  561.             ////////////// end verifications
  563.             /////////// begin traitment//////////////
  564.             //// find FPS for modifications //////////
  565.             $fpsEntity = $repositoryFPS->find($fineId);        
  567.             foreach ($datas as $data){
  568.                 if (    substr( $data['path'], 0, 7 ) !=="/claims" && 
  569.                         $data['path'] !=="/cancelDatetime" &&
  570.                         $data['path'] !=="/debtCollectionDatetime" && 
  571.                         $data['path'] !=="/paymentStatus" &&
  572.                         substr( $data['path'], 0, 9 ) !== "/payments" && 
  573.                         $data['path'] !=="/notificationDatetime" && 
  574.                         $data['path'] !=="/offender" &&
  575.                         $data['path'] !=="/comments/-" ) {
  576.                     $errors[0] = ['code' => '1012', 'type' => 'Champs non autorisés à être modifié'];
  577.                     return new JsonResponse( array( "errors" => $errors), 422 , array(), false);
  578.                 }
  579.                 //si claims replace
  580.                 if ( substr( $data['path'], 0, 7 ) === "/claims"  && $data['op'] === "replace" ){
  581.                     //check si claims existe$
  582.                     /** @var ClaimRepository $repository */
  583.                     $repository = $this->getDoctrine()->getRepository('App:Claim',  self::_PREFIX_EM.$cityId);  
  584.                     $claims = $repository->findBy( ["fps" => $fpsEntity] );
  585.                     if ( !$claims ){
  586.                         $errors[0] = ['code' => '1013', 'type' => 'Incohérence des modifications par rapport au cycle de vie du FPS'];
  587.                         return new JsonResponse( array( "errors" => $errors), 422 , array(), false);
  588.                     }
  589.                     if(substr( $data['path'], 8) !== false && array_key_exists(substr( $data['path'], 8), $claims)){
  590.                         $claim = $fpsEntity->getClaims()[substr( $data['path'], 8)];
  591.                     }
  592.                     else{
  593.                         $errors[0]=['code' => '1013','type' => 'Incohérence des modifications par rapport au cycle de vie du FPS'];
  594.                         return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  595.                     }
  597.                     foreach($data['value'] as $c){
  599.                         if(is_array($c)){
  600.                             if(isset($c['claimStatus'])){
  601.                                 $claim->setClaimStatus($c['claimStatus']);
  602.                                 if($c['claimStatus'] === "ACCEPTED" || $c['claimStatus'] === "TRANSFERRED"){
  603.                                     $fpsEntity->setType("CANCELLED");
  604.                                 }
  605.                             }
  606.                             if(isset($c['dateModified'])){
  607.                                 $claim->setDateModified(new \DateTime($c['dateModified']));
  608.                                 $fpsEntity->setDateModified(new \DateTime('now'));
  609.                             }
  610.                             if(isset($c['claimReason'])){
  611.                                 $claim->setClaimReason($c['claimReason']);
  612.                             }
  613.                             $em->persist($claim);
  614.                         }
  615.                         else{
  616.                             if(isset($data['value']['claimStatus'])){
  617.                                 $claim->setClaimStatus($data['value']['claimStatus']);
  618.                                 if($data['value']['claimStatus'] === "ACCEPTED" || $data['value']['claimStatus'] === "TRANSFERRED"){
  619.                                     $fpsEntity->setType("CANCELLED");
  620.                                 }
  621.                             }
  622.                             if(isset($data['value']['dateModified'])){
  623.                                 $claim->setDateModified(new \DateTime($data['value']['dateModified']));
  624.                                 $fpsEntity->setDateModified(new \DateTime('now'));
  625.                             }
  626.                             if(isset($data['value']['claimReason'])){
  627.                                 $claim->setClaimReason($data['value']['claimReason']);
  628.                             }
  629.                             $em->persist($claim);
  630.                             break;
  631.                         }
  632.                     }
  635.                 }
  636.                 if(substr( $data['path'], 0, 7 ) === "/claims"  && $data['op'] === 'add' ){
  637.                     foreach($data['value'] as $c){
  638.                         if(is_array($c)){
  639.                             if($c['claimStatus'] !== "FILLED"){
  640.                                 $errors[0]=['code' => '1013','type' => 'Incohérence des modifications par rapport au cycle de vie du FPS'];
  641.                                 return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  642.                             }
  643.                             if(count($fpsEntity->getClaims())>0 && $fpsEntity->getClaims()[0]->getClaimType() === "PRELIMINARY" && $c['claimType'] ==='PRELIMINARY'){
  644.                                 $errors[0]=['code' => '1013','type' => 'Incohérence des modifications par rapport au cycle de vie du FPS'];
  645.                                 return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  646.                             }
  647.                             //si claims add
  648.                             if(!isset($c['claimType']) || ($c['claimType'] !== 'PRELIMINARY' && $c['claimType'] !== 'REGULATORY')){
  649.                                 $errors[0]=array("code"=>"1001","type"=>"Structure de la requête invalide");
  650.                                 return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  651.                             }
  652.                             if(count($fpsEntity->getClaims())>0 && $fpsEntity->getClaims()[count($fpsEntity->getClaims())-1]->getClaimType() === "REGULATORY" && $c['claimType'] ==='REGULATORY'){
  653.                                 $errors[0]=['code' => '1013','type' => 'Incohérence des modifications par rapport au cycle de vie du FPS'];
  654.                                 return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  655.                             }
  656.                             $claim = new Claim;
  657.                             $claim->setClaimStatus($c['claimStatus']);
  658.                             $claim->setClaimType($c['claimType']);
  659.                             if(isset($c['claimReason'])){
  660.                                 $claim->setClaimReason($c['claimReason']);
  661.                             }
  662.                             $claim->setDateModified(new \DateTime($c['dateModified']));
  663.                             $fpsEntity->setDateModified(new \DateTime('now'));
  664.                             $claim->setFps($fpsEntity);
  665.                             $fpsEntity->addClaim($claim);
  666.                             $em->persist($claim);
  667.                         }
  668.                         else{
  670.                             if($data['value']['claimStatus'] !== "FILLED"){
  671.                                 $errors[0]=['code' => '1013','type' => 'Incohérence des modifications par rapport au cycle de vie du FPS'];
  672.                                 return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  673.                             }
  674.                             if(count($fpsEntity->getClaims())>0 && $fpsEntity->getClaims()[0]->getClaimType() === "PRELIMINARY" && $data['value']['claimType'] ==='PRELIMINARY'){
  675.                                 $errors[0]=['code' => '1013','type' => 'Incohérence des modifications par rapport au cycle de vie du FPS'];
  676.                                 return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  677.                             }
  678.                             //si claims add
  679.                             if(!isset($data['value']['claimType']) || ($data['value']['claimType'] !== 'PRELIMINARY' && $data['value']['claimType'] !== 'REGULATORY')){
  680.                                 $errors[0]=array("code"=>"1001","type"=>"Structure de la requête invalide");
  681.                                 return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  682.                             }
  684.                             if(count($fpsEntity->getClaims())>0 && $fpsEntity->getClaims()[count($fpsEntity->getClaims())-1]->getClaimType() === "REGULATORY" && $data['value']['claimType'] === 'REGULATORY'){
  685.                                 $errors[0]=['code' => '1013','type' => 'Incohérence des modifications par rapport au cycle de vie du FPS'];
  686.                                 return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  687.                             }
  688.                             $claim = new Claim;
  689.                             $claim->setClaimStatus($data['value']['claimStatus']);
  690.                             $claim->setClaimType($data['value']['claimType']);
  691.                             if(isset($data['value']['claimReason'])){
  692.                                 $claim->setClaimReason($data['value']['claimReason']);
  693.                             }
  694.                             $claim->setDateModified(new \DateTime($data['value']['dateModified']));
  695.                             $fpsEntity->setDateModified(new \DateTime('now'));
  696.                             $claim->setFps($fpsEntity);
  697.                             $fpsEntity->addClaim($claim);
  698.                             $em->persist($claim);
  699.                             break;
  700.                         }
  701.                     }
  702.                 }
  704.                 if($data['path'] ==="/cancelDatetime" && $data['op'] === 'add'){
  705.                     if($fpsEntity->getCancelDateTime() != null && $fpsEntity->getType() === "CANCELLED"){
  706.                         $errors[0]=['code' => '1012','type' => 'Champs non autorisés à être modifié'];
  707.                         return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  708.                     }
  709.                     $fpsEntity->setCancelDatetime(new \DateTime($data['value']));
  710.                     $fpsEntity->setDateModified(new \DateTime('now'));
  711.                     $fpsEntity->setType("CANCELLED");
  712.                 }
  713.                 if($data['path'] ==="/cancelDatetime" && $data['op'] === 'replace'){
  714.                     $errors[0]=['code' => '1012','type' => 'Champs non autorisés à être modifié'];
  715.                     return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  716.                 }
  717.                 if($data['path'] ==="/debtCollectionDatetime"){
  718.                     $fpsEntity->setDebtCollectionDatetime(new \DateTime($data['value']));
  719.                     $fpsEntity->setDateModified(new \DateTime('now'));
  720.                 }
  721.                 if($data['path'] ==="/paymentStatus" ){
  722.                     if($fpsEntity->getPaymentStatus() === "PENDING" && ($data['value']==="PAID" || $data['value']==="OVERPAID")){
  723.                             if($data['path'] ==="/paymentStatus" ){
  724.                                 $fpsEntity->setPaymentStatus($data['value']);
  725.                                 $fpsEntity->setDateModified(new \DateTime('now'));
  726.                             }
  727.                     }
  728.                     else{
  729.                         $errors[0]=['code' => '1013','type' => 'Incohérence des modifications par rapport au cycle de vie du FPS'];
  730.                         return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  731.                     }
  732.                 }
  733.                 if(substr($data['path'], 0, 9) === "/payments" && $data['op'] === 'add'){
  734.                     foreach($data['value'] as $p){
  735.                         if(is_array($p)){
  736.                             $paymentType = !empty($p['paymentType']) ? $p['paymentType'] : null;
  737.                             
  738.                             $payment= new Payment;
  739.                             $payment->setPaymentDatetime(new \DateTime($p['paymentDatetime']));
  740.                             $payment->setPaymentChannel($p['paymentChannel']);
  741.                             $payment->setPaymentAmount($p['paymentAmount']);
  742.                             $payment->setPaymentType($paymentType);
  743.                             $payment->setFps($fpsEntity);
  744.                             $fpsEntity->addPayment($payment);
  745.                             $fpsEntity->setDateModified(new \DateTime('now'));
  746.                             $em->persist($payment);
  747.                         }
  748.                         else{
  749.                             $paymentType = (
  750.                                 isset($data['value']['paymentType']) && !empty($data['value']['paymentType'])
  751.                                 ) ? $data['value']['paymentType'] : null;
  752.                             
  753.                             $payment= new Payment;
  754.                             $payment->setPaymentDatetime(new \DateTime($data['value']['paymentDatetime']));
  755.                             $payment->setPaymentChannel($data['value']['paymentChannel']);
  756.                             $payment->setPaymentAmount($data['value']['paymentAmount']);
  757.                             $payment->setPaymentType($paymentType);
  758.                             $payment->setFps($fpsEntity);
  759.                             $fpsEntity->addPayment($payment);
  760.                             $fpsEntity->setDateModified(new \DateTime('now'));
  761.                             $em->persist($payment);
  762.                             break;
  763.                         }
  764.                     }
  765.                 }
  766.                 if(substr($data['path'], 0, 9) === "/payments" && $data['op'] === 'replace'){
  767.                     $errors[0]=['code' => '1012','type' => 'Champs non autorisés à être modifié'];
  768.                     return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  769.                 }
  771.                 if($data['path'] ==="/notificationDatetime" ){
  772.                     $fpsEntity->setNotificationDatetime(new \DateTime($data['value']));
  773.                     $fpsEntity->setDateModified(new \DateTime('now'));
  774.                 }
  776.                 if($data['path'] ==="/offender" && $data['op'] === 'add'){
  777.                     if($fpsEntity->getOffender() != null){
  778.                         $errors[0]=['code' => '1012','type' => 'Champs non autorisés à être modifié'];
  779.                         return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  780.                     }
  781.                     $fpsEntity->setOffender($data['value']);
  782.                     $fpsEntity->setDateModified(new \DateTime('now'));
  783.                 }
  784.                 if($data['path'] ==="/offender" && $data['op'] === 'replace'){
  785.                     $errors[0]=['code' => '1012','type' => 'Champs non autorisés à être modifié'];
  786.                     return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  787.                 }
  788.                 if ($data['path'] === "/comments/-") {
  789.                     if ($data['op'] === 'replace') {
  790.                         $errors[0]=['code' => '1012','type' => 'Champs non autorisés à être modifié'];
  791.                         return new JsonResponse(array("errors"=>$errors), 422 ,array(),false);
  792.                     }
  794.                     // Create comment
  795.                     $comment = new FpsComment;
  796.                     $comment->setAgentId($data['value']['agent']['agentId']);
  797.                     $comment->setName($data['value']['agent']['name']);
  798.                     $comment->setText(trim($data['value']['text']));
  799.                     $comment->setCreationDatetime(new \Datetime($data['value']['creationDatetime']));
  800.                     $comment->setFineId($fpsEntity);
  801.                     // Add comment to FPS
  802.                     $fpsEntity->addComment($comment);
  803.                     // Persist comment
  804.                     $em->persist($comment);
  805.                 }
  807.             }
  809.             try {
  810.                 $idUser = $token->getUserId($request);
  811.                 $activity = new ActivityFPS;
  812.                 $activity->setIdUser($idUser);
  813.                 $activity->setMethod('PATCH');
  814.                 $activity->setBody($request->getContent());
  815.                 $activity->setFps($fpsEntity);
  816.                 $em->persist($activity);
  818.                 $em->persist($fpsEntity);
  820.                 $em->flush();
  821.                 $em->refresh($fpsEntity);
  822.                 if(isset($claim)){
  823.                     $em->refresh($claim);
  824.                 }
  825.                 if(isset($payment)){
  826.                     $em->refresh($payment);
  827.                 }
  829.                 $fpsUpdate=$fpsEntity->getFormat();
  830.                 $jsonResponse= new JsonResponse(json_encode($fpsUpdate), Response::HTTP_OK, array(), true);
  832.                 return $jsonResponse;
  833.             } catch (\Exception $e) {
  834.                 return  $e->getMessage();
  835.             }
  836.         }
  838.     }
  840.     /**
  841.      * Récupère une liste de FPS en fonction de criteres en GET - csv export
  842.      * @Get("/api/v1/{cityId}/fines-export")
  843.      * @Security("is_granted('ROLE_PC_FPS') or is_granted('ROLE_SVC_FPS_READ')")
  844.      *
  845.      */
  846.     public function exportFPSListAction(Request $request, $cityId, FpsService $fpsService, FpsCsvService $fpsCsvService){
  848.         $maxRecordsDefault = 0;
  849.         $pageDefault = "1";
  851.         $search = json_decode($request->get('search'), true);
  852.         $user = $this->getUser();
  854.         $integral = $request->get('integral') != null ? $request->get('integral') === 'true' : false ;
  856.         $verifications = $fpsService->verificationsAuthorizationPlateFormatAndFormatJson($user->getCodeVille(),$request->get('cityId'),$search );  
  858.         if ( sizeof($verifications['error']) > 0) { 
  859.             return new JsonResponse($verifications['error'], 422 ,array(),false);
  860.         }
  861.         else {   
  862.             if (!isset($search['maxRecords'])) {
  863.                 $search['maxRecords'] = $maxRecordsDefault;
  864.             }
  865.             if( !isset($search['page'])){
  866.                 $search['page'] = $pageDefault;
  867.             }
  868.             if( !isset($search['orderBy']) || count($search['orderBy']) === 0){
  869.                 $search['orderBy'] = [array("field" => "fps.fineId", "sort" => "ASC")];
  870.             }
  872.             $complete = $user->hasRole('ROLE_FPS_COMPLETE') && $integral === true ? 'complete' : false;
  874.             // find FPSList - filter by search
  875.             /** @var FpsRepository $repositoryFPS */
  876.             $repositoryFPS = $this->getDoctrine()->getRepository('App:Fps',  self::_PREFIX_EM.$cityId);   
  877.             $fpsQuery = $repositoryFPS->getFpsFromSearch($search, $cityId, $complete, 'csv');
  878.             return $fpsCsvService->generateCsv($fpsQuery, $cityId);
  879.         }
  880.     }
  882.     /**
  883.      * Récupère une liste de FPS en fonction de criteres en GET - csv export
  884.      * @Get("/api/v1/{cityId}/fpsm")
  885.      * @Security("is_granted('ROLE_PC_FPS') or is_granted('ROLE_SVC_FPS_READ')")
  886.      *
  887.      */
  888.     public function exportFPSMAction(Request $request, $cityId, FpsCsvService $fpsCsvService, ManagerRegistry $registry){
  891.         $month = explode(",", $request->get('months'));
  892.         $year = $request->get('year');
  893.         $user = $this->getUser();
  895.         // User vérifications authorizations
  896.         if ($user->getCodeVille() != $cityId) {
  897.             return ['error' => ["code" => "401", "type" => "Unauthorized"]];
  898.         }
  899.         else {
  901.             // find FPSList - filter by search
  902.             /** @var FpsRepository $repositoryFPS */
  903.             $repositoryFPS = $registry->getRepository('App:Fps',  self::_PREFIX_EM.$cityId);
  904.             $fpsQuery = $repositoryFPS->getFpsM($month, $year);
  905.             return $fpsCsvService->generateCsv($fpsQuery, $cityId);
  906.         }
  907.     }
  909.     /**
  910.       * @Get("/api/{cityId}/last-fine")
  911.       * @QueryParam(name="agentId", nullable=false, description="agentId")
  912.       * @QueryParam(name="date", nullable=false, description="date")
  913.       *
  914.     */
  915.     public function getLastFPSIdAction(Request $request, ParamFetcher $paramFetcher){
  917.  
  918.         /** @var FpsRepository $repositoryFPS*/
  919.         $repositoryFPS = $this->getDoctrine()->getRepository('App:Fps',  self::_PREFIX_EM.$request->get('cityId'));  
  921.         $resId = $repositoryFPS->getLastFPSId($request->get('cityId'), $paramFetcher->get('agentId'), $paramFetcher->get('date'));
  922.         $res = ["last" => $resId];
  923.         return new JsonResponse(json_encode($res), Response::HTTP_OK, array(), true);
  924.     }
  927.  }