src/Controller/AppBundle/Controller/APIController.php line 58

Open in your IDE?
  1. <?php
  2. namespace App\Controller\AppBundle\Controller;
  4. use App\Controller\AppBundle\Connector\Awacs\AwacsCreateDocumentRequest;
  5. use App\Controller\AppBundle\Connector\Awacs\AwacsResponse;
  6. use App\Controller\AppBundle\Connector\Awacs\AwacsUpdateAPIRequest;
  7. use App\Controller\AppBundle\Connector\Awacs\AwacsUpdateRequest;
  8. use App\Controller\AppBundle\Connector\Awacs\AwacsViewRequest;
  9. use App\Controller\AppBundle\Connector\Awacs\Collection;
  10. use App\Controller\AppBundle\Connector\Awacs\FieldLabel;
  11. use App\Controller\AppBundle\Connector\Awacs\FieldPrimary;
  12. use App\Controller\AppBundle\Connector\Awacs\Filter;
  13. use App\Controller\AppBundle\Connector\FasterForward\FasterForwardHelper;
  14. use App\Controller\AppBundle\Connector\FasterForward\FasterForwardUpdateSchadeverzekeringRequest;
  15. use App\Controller\AppBundle\Connector\FasterForward\Helpers\FFManualInputOvervoerHelper;
  16. use App\Controller\AppBundle\Connector\VPI\VPIHelper;
  17. use App\Controller\AppBundle\Connector\VPI\VPIMapping;
  18. use App\Controller\AppBundle\Connector\VPI\VPIMappingNew;
  19. use App\Controller\AppBundle\Connector\VPI\VPIRequest;
  20. use App\Controller\AppBundle\Helpers\AccessHelper;
  21. use App\Controller\AppBundle\Interact\RelationSearch;
  22. use App\Entity\Slotvraag;
  23. use App\Repository\GIMCacheRepository;
  24. use Httpful\Http;
  25. use Symfony\Component\HttpFoundation\JsonResponse;
  26. use Symfony\Component\Routing\Annotation\Route;
  27. use App\Controller\AppBundle\Connector\RollsVehicleInformation\ConnectorVehicle;
  28. use App\Controller\AppBundle\Entity\PolisInformation;
  29. use App\Controller\AppBundle\Helpers\Admin\ConsultantHelper;
  30. use App\Controller\AppBundle\Helpers\ConsultantCompare\ProcessCar;
  31. use App\Controller\AppBundle\Helpers\FormValidator;
  32. use App\Controller\AppBundle\Helpers\TestHelper;
  33. use App\Controller\AppBundle\Interact\Compare\CartSessionHelper;
  34. use App\Controller\AppBundle\Interact\Compare\PolisResult;
  35. use App\Controller\AppBundle\Interact\Compare\RequestBuilderCar;
  36. use App\Controller\AppBundle\Interact\CreateRelation;
  37. use App\Controller\AppBundle\Interact\UserInformationANVA;
  38. use App\Entity\CartContainer;
  39. use App\Entity\User;
  40. use Doctrine\ORM\EntityManagerInterface;
  41. use Psr\Log\LoggerInterface;
  42. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  43. use Symfony\Component\HttpFoundation\Request;
  44. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  45. use Brick\VarExporter\VarExporter;
  47. class APIController extends AbstractController
  48. {
  49.     /**
  50.      * @Route("/shoot/{datasource}", name="shoot")
  51.      */
  52.     public function test2(EntityManagerInterface $em, SessionInterface $session, $datasource, Request $request) {
  53.         if (!AccessHelper::ownIP($request->getClientIp())) {
  54.             return new JsonResponse(['access' => False]);
  55.         }
  56.         $entities = json_decode($request->getContent());
  57.         $update = new AwacsUpdateAPIRequest($entities);
  58.         $response = $update->sendAndRequest($datasource);
  59.         $request = $response[1];
  60.         $response = $response[0];
  61.         $keys = [];
  62.         $errorById = [];
  63.         if ($response->getErrors() === []) {
  65.             $output = $response->xml()->RESULT->EXECUTE;
  66.             try {
  67.                 foreach ($response->xml()->RESULT->EXECUTE->children() as $name => $xml) {
  68.                     $keys[strtolower($name)][] = (string)$xml->PK;
  70.                 }
  71.             } catch (\Exception $e) {}
  73.         } else {
  74.             $volgnums = [];
  75.             $i = 0;
  76.             try {
  77.                 foreach ($response->xml()->RESULT->RELATIES->RELATIE->PAKKETTEN->PAKKET as $pakket) {
  78.                     foreach ($pakket->POLISSEN->POLIS as $polis) {
  79.                         $volgnums[(string)$polis->TRANSACTION_VOLGNR] = $i;
  80.                         $i = $i + 1;
  81.                     }
  82.                 }
  83.             } catch (\Exception $e) {}
  84.             $i = 0;
  85.             if (count($errorById) != 0) {
  86.                 foreach ($response->xml()->RESULT->EXECUTE->ERROR as $error) {
  87.                     $errorById[$volgnums[(string)$error->TRANSACTION_VOLGNR]] = $response->getErrors()[array_keys($response->getErrors())[$i]];
  88.                     $i = $i + 1;
  89.                 }
  90.             } else {
  91.                 foreach ($response->xml()->RESULT->EXECUTE->ERROR as $error) {
  92.                     $errorById[] = (string)$error->MESSAGE;
  93.                     $i = $i + 1;
  94.                 }
  95.             }
  96.         }
  99.         return new JsonResponse([
  100.             'hasErrors' => $response->getErrors() !== [],
  101.             'errors' => $response->getErrors(),
  102.             'request' => $request,
  103.             'keys' => $keys,
  104.             'errorsById' => $errorById,
  105.         ]);
  106.     }
  108.     /**
  109.      * @Route("/insertDocument/{datasource}", name="shootDocument")
  110.      */
  111.     public function apiCallDocument(EntityManagerInterface $em, SessionInterface $session, $datasource, Request $request) {
  112.         if (!AccessHelper::ownIP($request->getClientIp())) {
  113.             return new JsonResponse(['access' => False]);
  114.         }
  115.         $entities = json_decode($request->getContent());
  116.         $result = '';
  117.         foreach ($entities->data as $key => $value) {
  118.             $result .= "$key: $value\n"; // Concatenate key-value pairs into the result string
  119.         }
  121.         # Get 16 till 20 position of entities['polisKey']
  122.         $polisKeySubset = substr($entities->polisKey, 15, 5);
  124.         # Get 21 position onwards
  125.         $polisKeySubset2 = substr($entities->polisKey, 20);
  127.         $request = new AwacsCreateDocumentRequest($result, 'OvervoerVKGExtranetData.txt', 'OvervoerVKG Data ' . $entities->data->{'Overzicht->Polisnummer'}, $entities->relatieKey, true, false, false, $polisKeySubset, $polisKeySubset2);
  128.         $response = $request->sendAndRequest($datasource);
  129.         $request = $response[1];
  130.         $response = $response[0];
  131.         $keys = [];
  132.         $errorById = [];
  133.         if ($response->getErrors() === []) {
  135.             $output = $response->xml()->RESULT->EXECUTE;
  136.             try {
  137.                 foreach ($response->xml()->RESULT->EXECUTE->children() as $name => $xml) {
  138.                     $keys[strtolower($name)][] = (string)$xml->PK;
  140.                 }
  141.             } catch (\Exception $e) {}
  143.         } else {
  144.             $volgnums = [];
  145.             $i = 0;
  146.             try {
  147.                 foreach ($response->xml()->RESULT->RELATIES->RELATIE->PAKKETTEN->PAKKET as $pakket) {
  148.                     foreach ($pakket->POLISSEN->POLIS as $polis) {
  149.                         $volgnums[(string)$polis->TRANSACTION_VOLGNR] = $i;
  150.                         $i = $i + 1;
  151.                     }
  152.                 }
  153.             } catch (\Exception $e) {}
  154.             $i = 0;
  155.             if (count($errorById) != 0) {
  156.                 foreach ($response->xml()->RESULT->EXECUTE->ERROR as $error) {
  157.                     $errorById[$volgnums[(string)$error->TRANSACTION_VOLGNR]] = $response->getErrors()[array_keys($response->getErrors())[$i]];
  158.                     $i = $i + 1;
  159.                 }
  160.             } else {
  161.                 foreach ($response->xml()->RESULT->EXECUTE->ERROR as $error) {
  162.                     $errorById[] = (string)$error->MESSAGE;
  163.                     $i = $i + 1;
  164.                 }
  165.             }
  166.         }
  169.         return new JsonResponse([
  170.             'hasErrors' => $response->getErrors() !== [],
  171.             'errors' => $response->getErrors(),
  172.             'request' => $request,
  173.             'keys' => $keys,
  174.             'errorsById' => $errorById,
  175.         ]);
  176.     }
  178.     /**
  179.      * @Route("/getPremie/{datasource}", name="getPremieAPI")
  180.      */
  181.     public function test3(EntityManagerInterface $em, SessionInterface $session, $datasource, Request $request) {
  182.         if (!AccessHelper::ownIP($request->getClientIp())) {
  183.             return new JsonResponse(['access' => False]);
  184.         }
  185.         $key = json_decode($request->getContent());
  187.         # Make length of key 25 by cutting of the right
  188.         $key = substr($key, 0, 25);
  190.         $prefix = '';
  192.         // If key contains WACBES_
  193.         if (strpos($key, 'WACBES_') !== false) {
  194.             $prefix = 'wacht';
  195.         }
  198.         $collection = new Collection($prefix . 'polissen');
  199.         $collection->addField(FieldLabel::name('polis', 'incassobedrag'));
  200.         $collection->addField(FieldLabel::name('polis', 'acceptatie'));
  201.         $collection->addField(FieldLabel::name('polis', 'prolongatiekosten'));
  202.         $collection->addField(FieldLabel::name('polis', 'termijn'));
  204.         $collection->addFilter(new Filter(new FieldPrimary(), $key, '='));
  206.         $request = new AwacsViewRequest($collection);
  208.         $res = $request->send($datasource);
  211.         return new JsonResponse([
  212.             'incassobedrag' => $res->entities()[0]->field('incassobedrag')->value(),
  213.             'acceptatie' => $res->entities()[0]->field('acceptatie')->value(),
  214.             'prolongatiekosten' => $res->entities()[0]->field('prolongatiekosten')->value(),
  215.             'termijn' => $res->entities()[0]->field('termijn')->value()
  217.         ]);
  218.     }
  220.     /**
  221.      * @Route("/getDekkingen/{datasource}", name="getDekkingenAPI")
  222.      */
  223.     public function test6(EntityManagerInterface $em, SessionInterface $session, $datasource, Request $request) {
  224.         if (!AccessHelper::ownIP($request->getClientIp())) {
  225.             return new JsonResponse(['access' => False]);
  226.         }
  227.         $key = json_decode($request->getContent());
  228.         $key = substr($key, 0, 25);
  229.         $prefix = '';
  230.         // If key contains WACBES_
  231.         if (strpos($key, 'WACBES_') !== false) {
  232.             $prefix = 'wacht';
  233.         }
  235.         $collection = new Collection($prefix .'polissen');
  236.         $collection->addFilter(new Filter(new FieldPrimary(), $key, '='));
  237.         $collectionDekkingen = new Collection($prefix .'dekkingen');
  238.         $collectionDekkingen->addField(new FieldPrimary());
  239.         $collection->addCollection($collectionDekkingen);
  240.         $request = new AwacsViewRequest($collection);
  242.         $res = $request->send($datasource);
  243.         $dekkingIds = [];
  244.         foreach ($res->entities()[0]->collection($prefix .'dekkingen') as $dekking) {
  245.             $dekkingIds[] = $dekking->key;
  246.         }
  248.         return new JsonResponse([
  249.             'keys' => $dekkingIds,
  251.         ]);
  252.     }
  254.     /**
  255.      * @Route("/getPolisIds/{datasource}", name="getPolisIdsAPI")
  256.      */
  257.     public function test6547(EntityManagerInterface $em, SessionInterface $session, $datasource, Request $request) {
  258.         if (!AccessHelper::ownIP($request->getClientIp())) {
  259.             return new JsonResponse(['access' => False]);
  260.         }
  261.         $key = json_decode($request->getContent());
  262.         $key = substr($key, 0, 16);
  263. //        if (strpos($key, 'NAWBES_') !== false) {
  264. //            $key = str_replace('NAWBES_', '', $key);
  265. //        }
  267.         $collection = new Collection('relaties');
  268.         $collection->addFilter(new Filter(new FieldPrimary(), $key, '='));
  269.         $collectionPakketten = new Collection('pakketten');
  270.         $collectionPakketten->addField(new FieldPrimary());
  271.         $collectionPolissen = new Collection('polissen');
  272.         $collectionPolissen->addField(new FieldPrimary());
  273.         $collectionPolissen->addField(FieldLabel::name('polis', 'wijzigingsreden'));
  274.         $collectionPolissen->addField(FieldLabel::name('polis', 'collectiviteit'));
  275.         $collectionPolissen->addField(FieldLabel::name('polis', 'polisnummer_oud'));
  276.         $collectionPolissen->addField(FieldLabel::name('polis', 'incassobedrag'));
  277.         $collectionPolissen->addField(FieldLabel::name('polis', 'termijn'));
  278.         $collectionPolissen->addField(FieldLabel::name('polis', 'wijzigingsreden'));
  279.         $collectionPolissen->addField(FieldLabel::name('polis', 'ingangsdatum'));
  281.         $collectionPolissen->addFilter(new Filter(new FieldLabel('10095'), '12', '='));
  285.         $collectionPakketten->addCollection($collectionPolissen);
  287.         $collectionPolissen = new Collection('wachtpolissen');
  288.         $collectionPolissen->addField(new FieldPrimary());
  289.         $collectionPolissen->addField(FieldLabel::name('polis', 'wijzigingsreden'));
  290.         $collectionPolissen->addField(FieldLabel::name('polis', 'collectiviteit'));
  291.         $collectionPolissen->addField(FieldLabel::name('polis', 'polisnummer_oud'));
  292.         $collectionPolissen->addField(FieldLabel::name('polis', 'incassobedrag'));
  293.         $collectionPolissen->addField(FieldLabel::name('polis', 'termijn'));
  294.         $collectionPolissen->addField(FieldLabel::name('polis', 'wijzigingsreden'));
  295.         $collectionPolissen->addField(FieldLabel::name('polis', 'ingangsdatum'));
  297.         $collectionPolissen->addFilter(new Filter(new FieldLabel('10095'), '12', '='));
  301.         $collectionPakketten->addCollection($collectionPolissen);
  303.         $collection->addCollection($collectionPakketten);
  304.         $request = new AwacsViewRequest($collection);
  306.         $res = $request->send($datasource);
  309.         $result = [];
  310.         $resultWacht = [];
  311.         foreach ($res->entities()[0]->collection('pakketten') as $pakket) {
  312.             foreach ($pakket->collection('polissen') as $polis) {
  313.                 if ($polis->field('collectiviteit')->value() != '') {
  314.                     $resPolis = [];
  315.                     $resPolis['wijzigingsreden'] = $polis->field('wijzigingsreden')->value();
  316.                     $resPolis['collectiviteit'] = $polis->field('collectiviteit')->value();
  317.                     $resPolis['polisnummer_oud'] = $polis->field('polisnummer_oud')->value();
  318.                     $resPolis['incassobedrag'] = $polis->field('incassobedrag')->value();
  319.                     $resPolis['termijn'] = $polis->field('termijn')->value();
  320.                     $resPolis['wijzigingsreden'] = $polis->field('wijzigingsreden')->value();
  321.                     $resPolis['ingangsdatum'] = $polis->field('ingangsdatum')->value();
  323.                     $resPolis['pakketkey'] = $pakket->key();
  324.                     $resPolis['key'] = $polis->key();
  327.                     $result[] = $resPolis;
  328.                 }
  329.             }
  330.             foreach ($pakket->collection('wachtpolissen') as $polis) {
  331.                 if ($polis->field('collectiviteit')->value() != '') {
  332.                     $resPolis = [];
  333.                     $resPolis['wijzigingsreden'] = $polis->field('wijzigingsreden')->value();
  334.                     $resPolis['collectiviteit'] = $polis->field('collectiviteit')->value();
  335.                     $resPolis['polisnummer_oud'] = $polis->field('polisnummer_oud')->value();
  336.                     $resPolis['incassobedrag'] = $polis->field('incassobedrag')->value();
  337.                     $resPolis['termijn'] = $polis->field('termijn')->value();
  338.                     $resPolis['wijzigingsreden'] = $polis->field('wijzigingsreden')->value();
  339.                     $resPolis['ingangsdatum'] = $polis->field('ingangsdatum')->value();
  341.                     $resPolis['pakketkey'] = $pakket->key();
  342.                     $resPolis['key'] = $polis->key();
  345.                     $resultWacht[] = $resPolis;
  346.                 }
  347.             }
  349.         }
  351.         return new JsonResponse([
  352.             'keys' => $result,
  353.             'keysWacht' => $resultWacht,
  355.         ]);
  356.     }
  358.     /**
  359.      * @Route("/getDekkingenPremies/{datasource}", name="getDekkingenAndPremiesAPI")
  360.      */
  361.     public function test7(EntityManagerInterface $em, SessionInterface $session, $datasource, Request $request) {
  362.         if (!AccessHelper::ownIP($request->getClientIp())) {
  363.             return new JsonResponse(['access' => False]);
  364.         }
  365.         $key = json_decode($request->getContent());
  366.         $key = substr($key, 0, 25);
  367.         $prefix = '';
  368.         // If key contains WACBES_
  369.         if (strpos($key, 'WACBES_') !== false) {
  370.             $prefix = 'wacht';
  371.         }
  373.         $collection = new Collection($prefix .'polissen');
  374.         $collection->addFilter(new Filter(new FieldPrimary(), $key, '='));
  375.         $collectionDekkingen = new Collection($prefix .'dekkingen');
  376.         $collectionDekkingen->addField(new FieldPrimary());
  377.         $collectionDekkingen->addField(new FieldLabel('*'));
  378.         $collection->addCollection($collectionDekkingen);
  379.         $request = new AwacsViewRequest($collection);
  381.         $res = $request->send($datasource);
  382.         $dekkingIds = [];
  383.         foreach ($res->entities()[0]->collection($prefix .'dekkingen') as $dekking) {
  384.             $dekkingIds[$dekking->key] = [
  385.                 'incassobedrag' => floatval($dekking->field('incassobedrag')->value()),
  386.                 'code' => $dekking->field('dekking')->value(),
  387.                 'brutopremie' => floatval($dekking->field('bruto_premie_dekking')->value()),
  388.                 'toeslag_percentage_dekking' => floatval($dekking->field('toeslag_percentage_dekking')->value()),
  389.                 'toeslag_absoluut_dekking' => floatval($dekking->field('toeslag_absoluut_dekking')->value()),
  390.                 'verzekerdbedrag' => floatval($dekking->field('verzekerdbedrag')->value()),
  391.                 'provisiepercentage' => floatval($dekking->field('provisiepercentage')->value()),
  393.             ];
  394.         }
  396.         return new JsonResponse([
  397.             'keys' => $dekkingIds,
  398.         ]);
  399.     }
  402.     /**
  403.      * @Route("/shootElements", name="shootElements")
  404.      */
  405.     public function test4(EntityManagerInterface $em, SessionInterface $session, Request $request) {
  406.         if (!AccessHelper::ownIP($request->getClientIp())) {
  407.             return new JsonResponse(['access' => False]);
  408.         }
  409.         $entities = json_decode($request->getContent());
  411.         $list = FFManualInputOvervoerHelper::processAPICall($entities);
  414.         return new JsonResponse([
  415.             $list
  416.         ]);
  417.     }
  419.     /**
  420.      * @Route("/api/elements", name="elements")
  421.      */
  422.     public function apiElements(EntityManagerInterface $em, SessionInterface $session, Request $request) {
  423.         if (!AccessHelper::ownIP($request->getClientIp())) {
  424.             return new JsonResponse(['access' => False]);
  425.         }
  426.         $entities = json_decode($request->getContent());
  428.         $request = new FasterForwardUpdateSchadeverzekeringRequest();
  429.         $request->path = $entities->url;
  430.         $request->requestData = json_decode(json_encode($entities->requestData), true);
  431.         $request->urlOnly = json_decode(json_encode($entities->urlOnly), true);
  432.         switch (json_decode(json_encode($entities->method), true)) {
  433.             case 'POST':
  434.                 $request->method = Http::POST;
  435.                 break;
  436.             case 'PUT':
  437.                 $request->method = Http::PUT;
  438.                 break;
  439.             case 'DELETE':
  440.                 $request->method = Http::DELETE;
  441.                 break;
  442.             case 'GET':
  443.                 $request->method = Http::GET;
  444.                 break;
  445.             case 'PATCH':
  446.                 $request->method = Http::PATCH;
  447.                 break;
  448.         }
  449.         $res = $request->send();
  450.         $headers = $res->headers;
  451.         $dossiernummer = -1;
  452.         if ($res->code == 201){
  453.             $exp = explode('/', $headers['location']);
  454.             # get last of exp
  455.             $dossiernummer = intval($exp[count($exp) - 1]);
  456.         }
  458.         return new JsonResponse([
  459.             'responseData' => $res->raw_body,
  460.             'responseCode' => $res->code,
  461.             'success' => $res->code == 201,
  462.             'nummer' => $dossiernummer
  463.         ]);
  464.     }
  466.     /**
  467.      * @Route("/api/elements/getdefaultids/{dossierId}", name="elementsGetDefaultIds")
  468.      */
  469.     public function apiElementsGetDefaultIds(EntityManagerInterface $em, SessionInterface $session, Request $request, $dossierId) {
  470.         if (!AccessHelper::ownIP($request->getClientIp())) {
  471.             return new JsonResponse(['access' => False]);
  472.         }
  474.         $relation =  FasterForwardHelper::getRelation($dossierId);
  477.         return new JsonResponse([
  478.             'persoonId' => $relation->id,
  479.             'adresId' => $relation->adres_id,
  480.         ]);
  481.     }
  482.     /**
  483.      * @Route("/api/elementsProduct", name="elementsProduct")
  484.      */
  485.     public function apiElementsProduct(EntityManagerInterface $em, SessionInterface $session, Request $request) {
  486.         if (!AccessHelper::ownIP($request->getClientIp())) {
  487.             return new JsonResponse(['access' => False]);
  488.         }
  489.         $entities = json_decode($request->getContent());
  492.         $request = new FasterForwardUpdateSchadeverzekeringRequest();
  493.         $request->path = $entities->url;
  494.         $request->requestData = json_decode(json_encode($entities->requestData), true);
  495.         $request->urlOnly = json_decode(json_encode($entities->urlOnly), true);
  496.         switch (json_decode(json_encode($entities->method), true)) {
  497.             case 'POST':
  498.                 $request->method = Http::POST;
  499.                 break;
  500.             case 'PUT':
  501.                 $request->method = Http::PUT;
  502.                 break;
  503.             case 'DELETE':
  504.                 $request->method = Http::DELETE;
  505.                 break;
  506.             case 'GET':
  507.                 $request->method = Http::GET;
  508.                 break;
  509.             case 'PATCH':
  510.                 $request->method = Http::PATCH;
  511.                 break;
  512.         }
  513.         $res = $request->send();
  514.         $headers = $res->headers;
  515.         $dossiernummer = -1;
  516.         if ($res->code == 201){
  517.             $exp = explode('/', $headers['location']);
  518.             # get last of exp
  519.             $dossiernummer = intval($exp[count($exp) - 1]);
  520.         }
  522.         return new JsonResponse([
  523.             'responseData' => $res->raw_body,
  524.             'responseCode' => $res->code,
  525.             'success' => $res->code == 201,
  526.             'nummer' => $dossiernummer
  527.         ]);
  528.     }
  530.     public function getRelation($relations, $input) {
  531.         $matches = [];
  532.         foreach ($relations as $relation) {
  533.             if ($relation->field('email')->value() != '' && isset($input->{'email'}) && $input->{'email'} != '' && $input->{'email'} != '-') {
  534.                 if ($relation->field('email')->value() != $input->{'email'}) {
  535.                     continue;
  536.                 }
  537.             }
  538.             if ($relation->field('postcode')->value() != '' && isset($input->{'postcode'})&& $input->{'postcode'} != '-') {
  539.                 if ($relation->field('postcode')->value() != $input->{'postcode'}) {
  540.                     continue;
  541.                 }
  542.             }
  543.             if ($relation->field('iban')->value() != '' && isset($input->{'iban'}) && $input->{'iban'} != '-' && $input->{'iban'} != '') {
  544.                 if ($relation->field('iban')->value() != $input->{'iban'}) {
  545.                     continue;
  546.                 }
  547.             }
  548.             if ($relation->field('achternaam')->value() != '' && isset($input->{'achternaam'})&& $input->{'achternaam'} != '-' && $input->{'achternaam'} != '') {
  549.                 if (strtolower($relation->field('achternaam')->value()) != strtolower($input->{'achternaam'})) {
  550.                     continue;
  551.                 }
  552.             }
  553.             if ($relation->field('voorletters')->value() != '' && isset($input->{'voorletters'})&& $input->{'voorletters'} != '-' && $input->{'voorletters'} != '') {
  554.                 if (str_replace(' ', '', str_replace( '.', '', $relation->field('voorletters')->value())) != str_replace(' ', '', str_replace( '.', '', $input->voorletters))) {
  555.                     continue;
  556.                 }
  557.             }
  558.             if ($relation->field('geboortedatum')->value() != '') {
  559.                 $reformat = \DateTime::createFromFormat('Ymd', $relation->field('geboortedatum')->value())->format('d-m-Y');
  560.                 if ($input->{'geboortedatum'} != '' && $reformat != $input->{'geboortedatum'}) {
  561.                     continue;
  562.                 }
  563.             }
  565.             $matches[] = $relation;
  566.         }
  567.         return $matches;
  568.     }
  570.     /**
  571.      * @Route("/api/findRelation/{datasource}", name="apiFindRelation")
  572.      */
  573.     public function test5(EntityManagerInterface $em, SessionInterface $session, Request $request, $datasource) {
  574.         if (!AccessHelper::ownIP($request->getClientIp())) {
  575.             return new JsonResponse(['access' => False]);
  576.         }
  577.         $entities = json_decode($request->getContent());
  579.         $relations = RelationSearch::byNAW([
  580.             'postcode' => $entities->{'postcode'},
  581.             'huisnummer' => $entities->{'huisnummer'}
  582.         ], $datasource);
  584.         $res = $this->getRelation($relations, $entities);
  586.         $output = [];
  587.         foreach ($res as $result) {
  588.             $wijziginsreden = intval($result->field('wijzigingsreden')->value());
  589.             if (empty($wijziginsreden)) {
  590.                 $vervallen = false;
  591.             } else {
  592.                 $vervallen = ($wijziginsreden >= 40 && $wijziginsreden < 50);
  593.             }
  594.             if ($vervallen) {
  595.                 continue;
  596.             }
  597. //            $isHollandia = RelationSearch::byActiveHollandia($result->field('relatienummer')->value(), $datasource);
  598. //            if ($isHollandia) {
  599.             $output[] = [
  600.                 'relatienummer' => $result->field('relatienummer')->value(),
  601.                 'achternaam' => $result->field('achternaam')->value(),
  602.                 'agent' => $result->field('agent')->value(),
  603.             ];
  604. //            }
  605.         }
  606.         return new JsonResponse($output);
  607.     }
  609.     /**
  610.      * @Route("/api/findAbbo/{datasource}", name="apiFindAbonnement")
  611.      */
  612.     public function testPakketAbonnement(EntityManagerInterface $em, SessionInterface $session, Request $request, $datasource)
  613.     {
  614.         if (!AccessHelper::ownIP($request->getClientIp())) {
  615.             return new JsonResponse(['access' => False]);
  616.         }
  617.         $entities = json_decode($request->getContent());
  618.         $poliskey = $entities->{'key'};
  620.         $collection = new Collection('polissen');
  621.         foreach ($entities->{'fields'} as $field) {
  622.             $collection->addField(new FieldLabel($field));
  624.         }
  625.         $collection->addField(FieldLabel::name('polis', 'wijzigingsreden'));
  626.         $collection->addField(FieldLabel::name('polis', 'wijzigingsdatum'));
  627.         $collection->addField(new FieldPrimary());
  629.         $collectionDekkingen = new Collection('dekkingen');
  630.         $collectionDekkingen->addField(FieldLabel::name('dekking', 'dekking'));
  631.         $collectionDekkingen->addField(FieldLabel::name('dekking', 'toeslag_percentage_dekking'));
  632.         $collectionDekkingen->addField(FieldLabel::name('dekking', 'toeslag_absoluut_dekking'));
  633.         $collectionDekkingen->addField(FieldLabel::name('dekking', 'toeslag_absoluut_dekking'));
  634.         $collectionDekkingen->addField(FieldLabel::name('dekking', 'incassobedrag'));
  636.         $collection->addCollection($collectionDekkingen);
  638.         $collection
  639.             ->addFilter(new Filter(FieldLabel::name('polis', 'polisnummer'), $poliskey))
  640.             ->addFilter(new Filter(FieldLabel::name('polis', 'maatschappij'), 'V201'));
  643.         $request = new AwacsViewRequest($collection);
  644.         $request->setDisplayOption('display');
  645.         if (isset($datasource)) {
  646.             $response = $request->send($datasource);
  647.         } else {
  648.             $response = $request->send();
  649.         }
  650.         $ret = [];
  651.         $i = 0;
  652.         foreach ($response->entities() as $entity) {
  653.             $ret[$i]['fields'] = [];
  654.             $ret[$i]['dekkingen'] = [];
  656.             foreach ($entity->fields as $field => $value) {
  657.                 $ret[$i]['fields'][$field] = $value->value();
  658.             }
  659.             foreach ($entity->collection('dekkingen') as $fieldS => $entity) {
  660.                 $ret[$i]['dekkingen'][$fieldS] = [];
  661.                 foreach ($entity->fields as $field => $value) {
  662.                     $ret[$i]['dekkingen'][$fieldS][$field] = $value->value();
  663.                 }
  665.                 $ret[$i]['key'] = $entity->key();
  666.                 $i = $i + 1;
  667.             }
  669.             return new JsonResponse($ret);
  670.         }
  671.     }
  674.     /**
  675.      * @Route("/api/findPolis/{datasource}", name="apiFindPolis")
  676.      */
  677.     public function test8(EntityManagerInterface $em, SessionInterface $session, Request $request, $datasource) {
  678.         if (!AccessHelper::ownIP($request->getClientIp())) {
  679.             return new JsonResponse(['access' => False]);
  680.         }
  681.         $entities = json_decode($request->getContent());
  682.         $poliskey = $entities->{'key'};
  684.         $collection = new Collection('polissen');
  685.         foreach ($entities->{'fields'} as $field) {
  686.             $collection->addField(new FieldLabel($field));
  687.         }
  689.         $collection
  690.             ->addFilter(new Filter(new FieldPrimary(), $poliskey, '='));
  693.         $request = new AwacsViewRequest($collection);
  694.         $request->setDisplayOption('display');
  695.         if (isset($datasource)) {
  696.             $response = $request->send($datasource);
  697.         } else {
  698.             $response = $request->send();
  699.         }
  700.         $ret = [];
  701.         foreach ($response->entities()[0]->fields as $field => $value) {
  702.             $ret[$field] = $value->value();
  703.         }
  705.         return new JsonResponse($ret);
  706.         return new JsonResponse($output);
  707.     }
  709.     /**
  710.      * @Route("/api/findAgendas/{datasource}", name="apiFindAgendas")
  711.      */
  712.     public function test24(EntityManagerInterface $em, SessionInterface $session, Request $request, $datasource) {
  713.         if (!AccessHelper::ownIP($request->getClientIp())) {
  714.             return new JsonResponse(['access' => False]);
  715.         }
  716.         $entities = json_decode($request->getContent());
  717.         $poliskey = $entities->{'key'};
  720.         $collectionAgenda = new Collection('agendaas');
  721.         $collectionAgenda->addField(new FieldLabel('*'));
  724.         $collectionAgenda
  725.             ->addFilter(new Filter(new FieldPrimary(), 'AGENDA_P'. $poliskey . "*", '='));
  728.         $request = new AwacsViewRequest($collectionAgenda);
  729.         $request->setDisplayOption('display');
  730.         if (isset($datasource)) {
  731.             $response = $request->send($datasource);
  732.         } else {
  733.             $response = $request->send();
  734.         }
  735.         $out = [];
  736.         foreach ($response->entities() as $entity) {
  737.             $ret = [];
  738.             foreach ($entity->fields as $field => $value) {
  739.                 $ret[$field] = $value->value();
  740.             }
  741.             $ret['pk'] = $response->entities()[0]->key();
  742.             $out[] = $ret;
  743.         }
  746.         return new JsonResponse($out);
  747.         return new JsonResponse($output);
  748.     }
  750.     public function responseToJson(AwacsResponse $response) {
  751.         $polis = $response->entities()[0];
  752.         $output = [
  753.             'fields' => [],
  754.             'dekkingen' => [],
  755.         ];
  756.         foreach ($polis->fields as $field => $value) {
  757.             $output['fields'][$field] = $value->value();
  758.         }
  759.         foreach ($polis->collection('dekkingen') as $field => $dekking) {
  760.             $res = [];
  761.             foreach ($dekking->fields as $fieldD => $value) {
  762.                 $res[$fieldD] = $value->value();
  763.             }
  764.             $output['dekkingen'][$dekking->field('dekking')->value()] = $res;
  765.         }
  768.         return $output;
  770.     }
  772.     /**
  773.      * @Route("/api/fieldsSjabloon/{datasource}", name="apiFieldsSjabloon")
  774.      */
  775.     public function test9(EntityManagerInterface $em, SessionInterface $session, Request $request, $datasource) {
  776.         if (!AccessHelper::ownIP($request->getClientIp())) {
  777.             return new JsonResponse(['access' => False]);
  778.         }
  780.         $entities = json_decode($request->getContent());
  781.         $poliskey = $entities->{'key'};
  782.         $productId = $entities->{'productId'};
  783.         $contextId = $entities->{'contextId'};
  784.         $functieId = $entities->{'functieId'};
  785.         $maatschappij = $entities->{'maatschappij'};
  787.         $projdir = $this->getParameter('kernel.project_dir');
  789.         switch ($maatschappij) {
  790.             case 'V059':
  791.                 $maatschappij = 'asr';
  792.                 break;
  793.             case 'N200':
  794.                 $maatschappij = 'nn';
  795.                 break;
  796.         }
  798.         $data = VPIRequest::templateEmpty('', $productId, $contextId, $functieId, 'geefSjabloon');
  799.         $result = VPIRequest::sendRequestVPI($data, $maatschappij, $projdir, true);
  801.         $collection = new Collection('polissen');
  802.         $collection->addField(new FieldLabel('*'));
  803.         $collectionDekkingen = new Collection('dekkingen');
  804.         $collectionDekkingen->addField(new FieldLabel('*'));
  806.         $collection->addCollection($collectionDekkingen);
  807.         $collection
  808.             ->addFilter(new Filter(new FieldPrimary(), $poliskey, '='));
  811.         $request = new AwacsViewRequest($collection);
  812.         $request->setDisplayOption('display');
  813.         if (isset($datasource)) {
  814.             $response = $request->send($datasource);
  815.         } else {
  816.             $response = $request->send();
  817.         }
  819.         return new JsonResponse([
  820.             'sjabloon' => $result,
  821.             'polisinfo' => self::responseToJson($response),
  822.         ]);
  824.     }
  826.     /**
  827.      * @Route("/api/vpiAcceptatie", name="apiVPIAcceptatie")
  828.      */
  829.     public function test10(EntityManagerInterface $em, SessionInterface $session, Request $request) {
  830.         if (!AccessHelper::ownIP($request->getClientIp())) {
  831.             return new JsonResponse(['access' => False]);
  832.         }
  834.         $entities = json_decode($request->getContent());
  835.         $poliskey = $entities->{'key'};
  836.         $productId = $entities->{'productId'};
  837.         $contextId = $entities->{'contextId'};
  838.         $functieId = $entities->{'functieId'};
  839.         $maatschappij = $entities->{'maatschappij'};
  840.         $data = $entities->{'requestData'};
  842.         $projdir = $this->getParameter('kernel.project_dir');
  844.         switch ($maatschappij) {
  845.             case 'V059':
  846.                 $maatschappij = 'asr';
  847.                 break;
  848.             case 'N200':
  849.                 $maatschappij = 'nn';
  850.                 break;
  851.         }
  853.         $data = VPIRequest::templateEmpty($data, $productId, $contextId, $functieId, 'doeFunctie');
  854.         $result = VPIRequest::sendRequestVPI($data, $maatschappij, $projdir);
  857.         return new JsonResponse($result);
  859.     }
  861.     /**
  862.      * @Route("/api/vpi/auto", name="apiVPIAuto")
  863.      */
  864.     public function apiVPIAuto(EntityManagerInterface $em, SessionInterface $session, Request $request) {
  865.         if (!AccessHelper::ownIP($request->getClientIp())) {
  866.             return new JsonResponse(['access' => False]);
  867.         }
  868.         if ($request->getMethod() === 'OPTIONS') {
  869.             $response = new JsonResponse();
  870.             $response->headers->set('Access-Control-Allow-Origin', 'https://chat.pivotwise.nl');
  871.             $response->headers->set('Access-Control-Allow-Methods', 'POST, GET, OPTIONS');
  872.             $response->headers->set('Access-Control-Allow-Headers', 'Content-Type');
  874.             return $response;
  875.         }
  876.         $premiebepalendeGegevens = json_decode($request->getContent());
  878.         $process = new ProcessCar();
  879.         $process->svj = $premiebepalendeGegevens->schadevrijeJaren;
  880.         $process->geboortedatum = $premiebepalendeGegevens->geboortedatum;
  881.         $process->postcode = $premiebepalendeGegevens->postcode;
  882.         $process->huisnummer = $premiebepalendeGegevens->huisnummer;
  883.         $process->toevoeging = '';
  885.         $process->relatieGeboortedatum = $premiebepalendeGegevens->geboortedatum;
  886.         $process->relatiePostcode = $premiebepalendeGegevens->postcode;
  887.         $process->relatieHuisnummer = $premiebepalendeGegevens->huisnummer;
  888.         $process->relatieToevoeging = '';
  889.         $process->dekking = $premiebepalendeGegevens->dekking;
  890.         $process->termijn = 'maand';
  892.         $process->kenteken = $premiebepalendeGegevens->kenteken;
  893.         $process->mutationIngangsdatum = new \DateTime();
  894.         $process->ingangsdatum = new \DateTime();
  896.         $projdir = $this->getParameter('kernel.project_dir');
  898.         $productId = 'VPI_NN_PersP2024ExclBM';
  899.         $maatschappij = VPIMappingNew::getMaatschappijByProductId($productId);
  900.         $dummyTemplate = VPIRequest::template('', $productId, $process, false);
  901.         $gimCache = VPIRequest::getSjabloonStdClass($em, $projdir, $maatschappij, $productId, $dummyTemplate['doeFunctieVraag']['procesInfo']['functie']['contextId'], $dummyTemplate['doeFunctieVraag']['procesInfo']['functie']['functieId']);
  903.         $data = VPIMapping::transform($process, $productId, ['vc'], $gimCache, null);
  904.         if ($data === false) {
  905.             return false;
  906.         }
  907.         $responseBin = new \stdClass();
  908.         $response = VPIRequest::sendVPI($projdir, $data, $maatschappij, $productId, $process, $responseBin);
  910.         if ($response !== null) {
  911.             $policies = VPIHelper::parsePolis($response, $productId, 'Autoverzekering', $data, $process, $responseBin, ['vc']);
  912.             if ($policies !== null) {
  913.                 foreach ($policies as $policy) {
  914.                     $process->results[] = $policy;
  915.                 }
  916.             }
  917.         }
  920.         $res = new JsonResponse($process->results);
  921.         $res->headers->set('Access-Control-Allow-Origin', 'https://chat.pivotwise.nl');
  922.         $res->headers->set('Access-Control-Allow-Methods', 'POST, GET, OPTIONS');
  923.         $res->headers->set('Access-Control-Allow-Headers', 'Content-Type');
  925.         // Add your data to the response if necessary, e.g., $response->setData([...]);
  927.         return $res;
  928.     }
  929. }