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

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}/{processSource}", name="shoot")
  51.      */
  52.     public function test2(EntityManagerInterface $em, SessionInterface $session, $datasource, $processSource, Request $request) {
  53.         if (!AccessHelper::ownIP($request->getClientIp())) {
  54.             return new JsonResponse(['access' => False]);
  55.         }
  57.         $entities = json_decode($request->getContent());
  58.         $update = new AwacsUpdateAPIRequest($entities);
  59.         $response = $update->sendAndRequest($datasource, null, null, $processSource);
  60.         $request = $response[1];
  61.         $response = $response[0];
  62.         $keys = [];
  63.         $errorById = [];
  64.         if ($response->getErrors() === []) {
  66.             $output = $response->xml()->RESULT->EXECUTE;
  67.             try {
  68.                 foreach ($response->xml()->RESULT->EXECUTE->children() as $name => $xml) {
  69.                     $keys[strtolower($name)][] = (string)$xml->PK;
  71.                 }
  72.             } catch (\Exception $e) {}
  74.         } else {
  75.             $volgnums = [];
  76.             $i = 0;
  77.             try {
  78.                 foreach ($response->xml()->RESULT->RELATIES->RELATIE->PAKKETTEN->PAKKET as $pakket) {
  79.                     foreach ($pakket->POLISSEN->POLIS as $polis) {
  80.                         $volgnums[(string)$polis->TRANSACTION_VOLGNR] = $i;
  81.                         $i = $i + 1;
  82.                     }
  83.                 }
  84.             } catch (\Exception $e) {}
  85.             $i = 0;
  86.             if (count($errorById) != 0) {
  87.                 foreach ($response->xml()->RESULT->EXECUTE->ERROR as $error) {
  88.                     $errorById[$volgnums[(string)$error->TRANSACTION_VOLGNR]] = $response->getErrors()[array_keys($response->getErrors())[$i]];
  89.                     $i = $i + 1;
  90.                 }
  91.             } else {
  92.                 foreach ($response->xml()->RESULT->EXECUTE->ERROR as $error) {
  93.                     $errorById[] = (string)$error->MESSAGE;
  94.                     $i = $i + 1;
  95.                 }
  96.             }
  97.         }
  100.         return new JsonResponse([
  101.             'hasErrors' => $response->getErrors() !== [],
  102.             'errors' => $response->getErrors(),
  103.             'request' => $request,
  104.             'keys' => $keys,
  105.             'errorsById' => $errorById,
  106.         ]);
  107.     }
  109.     /**
  110.      * @Route("/insertDocument/{datasource}", name="shootDocument")
  111.      */
  112.     public function apiCallDocument(EntityManagerInterface $em, SessionInterface $session, $datasource, Request $request) {
  113.         if (!AccessHelper::ownIP($request->getClientIp())) {
  114.             return new JsonResponse(['access' => False]);
  115.         }
  116.         $entities = json_decode($request->getContent());
  117.         $result = '';
  118.         foreach ($entities->data as $key => $value) {
  119.             $result .= "$key: $value\n"; // Concatenate key-value pairs into the result string
  120.         }
  122.         # Get 16 till 20 position of entities['polisKey']
  123.         $polisKeySubset = substr($entities->polisKey, 15, 5);
  125.         # Get 21 position onwards
  126.         $polisKeySubset2 = substr($entities->polisKey, 20);
  128.         $request = new AwacsCreateDocumentRequest($result, 'OvervoerVKGExtranetData.txt', 'OvervoerVKG Data ' . $entities->data->{'Overzicht->Polisnummer'}, $entities->relatieKey, true, false, false, $polisKeySubset, $polisKeySubset2);
  129.         $response = $request->sendAndRequest($datasource);
  130.         $request = $response[1];
  131.         $response = $response[0];
  132.         $keys = [];
  133.         $errorById = [];
  134.         if ($response->getErrors() === []) {
  136.             $output = $response->xml()->RESULT->EXECUTE;
  137.             try {
  138.                 foreach ($response->xml()->RESULT->EXECUTE->children() as $name => $xml) {
  139.                     $keys[strtolower($name)][] = (string)$xml->PK;
  141.                 }
  142.             } catch (\Exception $e) {}
  144.         } else {
  145.             $volgnums = [];
  146.             $i = 0;
  147.             try {
  148.                 foreach ($response->xml()->RESULT->RELATIES->RELATIE->PAKKETTEN->PAKKET as $pakket) {
  149.                     foreach ($pakket->POLISSEN->POLIS as $polis) {
  150.                         $volgnums[(string)$polis->TRANSACTION_VOLGNR] = $i;
  151.                         $i = $i + 1;
  152.                     }
  153.                 }
  154.             } catch (\Exception $e) {}
  155.             $i = 0;
  156.             if (count($errorById) != 0) {
  157.                 foreach ($response->xml()->RESULT->EXECUTE->ERROR as $error) {
  158.                     $errorById[$volgnums[(string)$error->TRANSACTION_VOLGNR]] = $response->getErrors()[array_keys($response->getErrors())[$i]];
  159.                     $i = $i + 1;
  160.                 }
  161.             } else {
  162.                 foreach ($response->xml()->RESULT->EXECUTE->ERROR as $error) {
  163.                     $errorById[] = (string)$error->MESSAGE;
  164.                     $i = $i + 1;
  165.                 }
  166.             }
  167.         }
  170.         return new JsonResponse([
  171.             'hasErrors' => $response->getErrors() !== [],
  172.             'errors' => $response->getErrors(),
  173.             'request' => $request,
  174.             'keys' => $keys,
  175.             'errorsById' => $errorById,
  176.         ]);
  177.     }
  179.     /**
  180.      * @Route("/getPremie/{datasource}", name="getPremieAPI")
  181.      */
  182.     public function test3(EntityManagerInterface $em, SessionInterface $session, $datasource, Request $request) {
  183.         if (!AccessHelper::ownIP($request->getClientIp())) {
  184.             return new JsonResponse(['access' => False]);
  185.         }
  186.         $key = json_decode($request->getContent());
  188.         # Make length of key 25 by cutting of the right
  189.         if (!str_contains($key, 'WACBES_')) {
  190.             $key = substr($key, 0, 25);
  191.         }
  193.         $prefix = '';
  195.         // If key contains WACBES_
  196.         if (strpos($key, 'WACBES_') !== false) {
  197.             $prefix = 'wacht';
  198.         }
  201.         $collection = new Collection($prefix . 'polissen');
  202.         $collection->addField(FieldLabel::name('polis', 'incassobedrag'));
  203.         $collection->addField(FieldLabel::name('polis', 'acceptatie'));
  204.         $collection->addField(FieldLabel::name('polis', 'prolongatiekosten'));
  205.         $collection->addField(FieldLabel::name('polis', 'termijn'));
  207.         $collection->addFilter(new Filter(new FieldPrimary(), $key, '='));
  209.         $request = new AwacsViewRequest($collection);
  211.         $res = $request->send($datasource);
  213.         if (count($res->entities()) == 0) {
  214.             return new JsonResponse([
  215.                 'found' => false,
  216.             ]);
  217.         }
  219.         return new JsonResponse([
  220.             'found' => true,
  221.             'incassobedrag' => $res->entities()[0]->field('incassobedrag')->value(),
  222.             'acceptatie' => $res->entities()[0]->field('acceptatie')->value(),
  223.             'prolongatiekosten' => $res->entities()[0]->field('prolongatiekosten')->value(),
  224.             'termijn' => $res->entities()[0]->field('termijn')->value()
  226.         ]);
  227.     }
  229.     /**
  230.      * @Route("/getStatus/{datasource}", name="getStatusAPI")
  231.      */
  232.     public function test11(EntityManagerInterface $em, SessionInterface $session, $datasource, Request $request) {
  233.         if (!AccessHelper::ownIP($request->getClientIp())) {
  234.             return new JsonResponse(['access' => False]);
  235.         }
  236.         $key = json_decode($request->getContent());
  238.         # Make length of key 25 by cutting of the right
  239.         if (!str_contains($key, 'WACBES_')) {
  240.             $key = substr($key, 0, 25);
  241.         }
  243.         $prefix = '';
  245.         // If key contains WACBES_
  246.         if (strpos($key, 'WACBES_') !== false) {
  247.             $prefix = 'wacht';
  248.         }
  251.         $collection = new Collection($prefix . 'polissen');
  252.         $collection->addField(FieldLabel::name('polis', 'incassobedrag'));
  253.         $collection->addField(FieldLabel::name('polis', 'acceptatie'));
  254.         $collection->addField(FieldLabel::name('polis', 'prolongatiekosten'));
  255.         $collection->addField(FieldLabel::name('polis', 'termijn'));
  256.         $collection->addField(FieldLabel::name('polis', 'wijzigingsreden'));
  257.         $collection->addFilter(new Filter(new FieldPrimary(), $key, '='));
  259.         $request = new AwacsViewRequest($collection);
  261.         $res = $request->send($datasource);
  263.         if (count($res->entities()) == 0) {
  264.             return new JsonResponse([
  265.                 'found' => false,
  266.             ]);
  267.         }
  269.         $isGeroyeerd = ((int)$res->entities()[0]->field('wijzigingsreden')->value()) >= 40 && ((int)$res->entities()[0]->field('wijzigingsreden')->value()) < 50;
  270.         $isNietProlongerend = ((int)$res->entities()[0]->field('wijzigingsreden')->value()) >= 14 && ((int)$res->entities()[0]->field('wijzigingsreden')->value()) < 30;
  272.         return new JsonResponse([
  273.             'found' => true,
  274.             'incassobedrag' => $res->entities()[0]->field('incassobedrag')->value(),
  275.             'acceptatie' => $res->entities()[0]->field('acceptatie')->value(),
  276.             'prolongatiekosten' => $res->entities()[0]->field('prolongatiekosten')->value(),
  277.             'termijn' => $res->entities()[0]->field('termijn')->value(),
  278.             'isGeroyeerd' => $isGeroyeerd,
  279.             'isNietProlongerend' => $isNietProlongerend,
  280.             'wijzigingsreden' => $res->entities()[0]->field('wijzigingsreden')->value()
  282.         ]);
  283.     }
  285.     /**
  286.      * @Route("/getDekkingen/{datasource}", name="getDekkingenAPI")
  287.      */
  288.     public function test6(EntityManagerInterface $em, SessionInterface $session, $datasource, Request $request) {
  289.         if (!AccessHelper::ownIP($request->getClientIp())) {
  290.             return new JsonResponse(['access' => False]);
  291.         }
  292.         $key = json_decode($request->getContent());
  293.         $prefix = '';
  294.         // If key contains WACBES_
  295.         if (strpos($key, 'WACBES_') !== false) {
  296.             $prefix = 'wacht';
  297.         } else {
  298.             $key = substr($key, 0, 25);
  299.         }
  301.         $collection = new Collection($prefix .'polissen');
  302.         $collection->addFilter(new Filter(new FieldPrimary(), $key, '='));
  303.         $collectionDekkingen = new Collection($prefix .'dekkingen');
  304.         $collectionDekkingen->addField(new FieldPrimary());
  305.         $collection->addCollection($collectionDekkingen);
  306.         $request = new AwacsViewRequest($collection);
  308.         $res = $request->send($datasource);
  309.         $dekkingIds = [];
  310.         foreach ($res->entities()[0]->collection($prefix .'dekkingen') as $dekking) {
  311.             $dekkingIds[] = $dekking->key;
  312.         }
  314.         return new JsonResponse([
  315.             'keys' => $dekkingIds,
  317.         ]);
  318.     }
  320.     /**
  321.      * @Route("/getPolisIds/{datasource}", name="getPolisIdsAPI")
  322.      */
  323.     public function test6547(EntityManagerInterface $em, SessionInterface $session, $datasource, Request $request) {
  324.         if (!AccessHelper::ownIP($request->getClientIp())) {
  325.             return new JsonResponse(['access' => False]);
  326.         }
  327.         $key = json_decode($request->getContent());
  328.         $key = substr($key, 0, 16);
  329. //        if (strpos($key, 'NAWBES_') !== false) {
  330. //            $key = str_replace('NAWBES_', '', $key);
  331. //        }
  333.         $collection = new Collection('relaties');
  334.         $collection->addFilter(new Filter(new FieldPrimary(), $key, '='));
  335.         $collectionPakketten = new Collection('pakketten');
  336.         $collectionPakketten->addField(new FieldPrimary());
  337.         $collectionPolissen = new Collection('polissen');
  338.         $collectionPolissen->addField(new FieldPrimary());
  339.         $collectionPolissen->addField(FieldLabel::name('polis', 'wijzigingsreden'));
  340.         $collectionPolissen->addField(FieldLabel::name('polis', 'collectiviteit'));
  341.         $collectionPolissen->addField(FieldLabel::name('polis', 'polisnummer_oud'));
  342.         $collectionPolissen->addField(FieldLabel::name('polis', 'incassobedrag'));
  343.         $collectionPolissen->addField(FieldLabel::name('polis', 'termijn'));
  344.         $collectionPolissen->addField(FieldLabel::name('polis', 'wijzigingsreden'));
  345.         $collectionPolissen->addField(FieldLabel::name('polis', 'ingangsdatum'));
  347.         $collectionPolissen->addFilter(new Filter(new FieldLabel('10095'), '12', '='));
  351.         $collectionPakketten->addCollection($collectionPolissen);
  353.         $collectionPolissen = new Collection('wachtpolissen');
  354.         $collectionPolissen->addField(new FieldPrimary());
  355.         $collectionPolissen->addField(FieldLabel::name('polis', 'wijzigingsreden'));
  356.         $collectionPolissen->addField(FieldLabel::name('polis', 'collectiviteit'));
  357.         $collectionPolissen->addField(FieldLabel::name('polis', 'polisnummer_oud'));
  358.         $collectionPolissen->addField(FieldLabel::name('polis', 'incassobedrag'));
  359.         $collectionPolissen->addField(FieldLabel::name('polis', 'termijn'));
  360.         $collectionPolissen->addField(FieldLabel::name('polis', 'wijzigingsreden'));
  361.         $collectionPolissen->addField(FieldLabel::name('polis', 'ingangsdatum'));
  363.         $collectionPolissen->addFilter(new Filter(new FieldLabel('10095'), '12', '='));
  367.         $collectionPakketten->addCollection($collectionPolissen);
  369.         $collection->addCollection($collectionPakketten);
  370.         $request = new AwacsViewRequest($collection);
  372.         $res = $request->send($datasource);
  375.         $result = [];
  376.         $resultWacht = [];
  377.         foreach ($res->entities()[0]->collection('pakketten') as $pakket) {
  378.             foreach ($pakket->collection('polissen') as $polis) {
  379.                 if ($polis->field('collectiviteit')->value() != '') {
  380.                     $resPolis = [];
  381.                     $resPolis['wijzigingsreden'] = $polis->field('wijzigingsreden')->value();
  382.                     $resPolis['collectiviteit'] = $polis->field('collectiviteit')->value();
  383.                     $resPolis['polisnummer_oud'] = $polis->field('polisnummer_oud')->value();
  384.                     $resPolis['incassobedrag'] = $polis->field('incassobedrag')->value();
  385.                     $resPolis['termijn'] = $polis->field('termijn')->value();
  386.                     $resPolis['wijzigingsreden'] = $polis->field('wijzigingsreden')->value();
  387.                     $resPolis['ingangsdatum'] = $polis->field('ingangsdatum')->value();
  389.                     $resPolis['pakketkey'] = $pakket->key();
  390.                     $resPolis['key'] = $polis->key();
  393.                     $result[] = $resPolis;
  394.                 }
  395.             }
  396.             foreach ($pakket->collection('wachtpolissen') as $polis) {
  397.                 if ($polis->field('collectiviteit')->value() != '') {
  398.                     $resPolis = [];
  399.                     $resPolis['wijzigingsreden'] = $polis->field('wijzigingsreden')->value();
  400.                     $resPolis['collectiviteit'] = $polis->field('collectiviteit')->value();
  401.                     $resPolis['polisnummer_oud'] = $polis->field('polisnummer_oud')->value();
  402.                     $resPolis['incassobedrag'] = $polis->field('incassobedrag')->value();
  403.                     $resPolis['termijn'] = $polis->field('termijn')->value();
  404.                     $resPolis['wijzigingsreden'] = $polis->field('wijzigingsreden')->value();
  405.                     $resPolis['ingangsdatum'] = $polis->field('ingangsdatum')->value();
  407.                     $resPolis['pakketkey'] = $pakket->key();
  408.                     $resPolis['key'] = $polis->key();
  411.                     $resultWacht[] = $resPolis;
  412.                 }
  413.             }
  415.         }
  417.         return new JsonResponse([
  418.             'keys' => $result,
  419.             'keysWacht' => $resultWacht,
  421.         ]);
  422.     }
  424.     /**
  425.      * @Route("/getDekkingenPremies/{datasource}", name="getDekkingenAndPremiesAPI")
  426.      */
  427.     public function test7(EntityManagerInterface $em, SessionInterface $session, $datasource, Request $request) {
  428.         if (!AccessHelper::ownIP($request->getClientIp())) {
  429.             return new JsonResponse(['access' => False]);
  430.         }
  431.         $key = json_decode($request->getContent());
  432.         $prefix = '';
  433.         // If key contains WACBES_
  434.         if (strpos($key, 'WACBES_') !== false) {
  435.             $prefix = 'wacht';
  436.         } else {
  437.             $key = substr($key, 0, 25);
  439.         }
  443.         $collection = new Collection($prefix .'polissen');
  444.         $collection->addFilter(new Filter(new FieldPrimary(), $key, '='));
  445.         $collectionDekkingen = new Collection($prefix .'dekkingen');
  446.         $collectionDekkingen->addField(new FieldPrimary());
  447.         $collectionDekkingen->addField(new FieldLabel('*'));
  448.         $collectionDekkingen->addField(new FieldLabel('10020'));
  449.         $collection->addCollection($collectionDekkingen);
  450.         $request = new AwacsViewRequest($collection);
  452.         $res = $request->send($datasource);
  453.         if (count($res->entities()) == 0) {
  454.             return new JsonResponse([
  455.                 'found' => false,
  456.             ]);
  457.         }
  459.         $dekkingIds = [];
  460.         foreach ($res->entities()[0]->collection($prefix .'dekkingen') as $dekking) {
  461.             $dekkingIds[$dekking->key] = [
  462.                 'incassobedrag' => floatval($dekking->field('incassobedrag')->value()),
  463.                 'code' => $dekking->field('dekking')->value(),
  464.                 'brutopremie' => floatval($dekking->field('bruto_premie_dekking')->value()),
  465.                 'toeslag_percentage_dekking' => floatval($dekking->field('toeslag_percentage_dekking')->value()),
  466.                 'toeslag_absoluut_dekking' => floatval($dekking->field('toeslag_absoluut_dekking')->value()),
  467.                 'verzekerdbedrag' => floatval($dekking->field('verzekerdbedrag')->value()),
  468.                 'provisiepercentage' => floatval($dekking->field('provisiepercentage')->value()),
  470.             ];
  471.         }
  473.         return new JsonResponse([
  474.             'keys' => $dekkingIds,
  475.         ]);
  476.     }
  479.     /**
  480.      * @Route("/shootElements", name="shootElements")
  481.      */
  482.     public function test4(EntityManagerInterface $em, SessionInterface $session, Request $request) {
  483.         if (!AccessHelper::ownIP($request->getClientIp())) {
  484.             return new JsonResponse(['access' => False]);
  485.         }
  486.         $entities = json_decode($request->getContent());
  488.         $list = FFManualInputOvervoerHelper::processAPICall($entities);
  491.         return new JsonResponse([
  492.             $list
  493.         ]);
  494.     }
  496.     /**
  497.      * @Route("/api/elements", name="elements")
  498.      */
  499.     public function apiElements(EntityManagerInterface $em, SessionInterface $session, Request $request) {
  500.         if (!AccessHelper::ownIP($request->getClientIp())) {
  501.             return new JsonResponse(['access' => False]);
  502.         }
  503.         $entities = json_decode($request->getContent());
  505.         $request = new FasterForwardUpdateSchadeverzekeringRequest();
  506.         $request->path = $entities->url;
  507.         $request->requestData = json_decode(json_encode($entities->requestData), true);
  508.         $request->urlOnly = json_decode(json_encode($entities->urlOnly), true);
  509.         switch (json_decode(json_encode($entities->method), true)) {
  510.             case 'POST':
  511.                 $request->method = Http::POST;
  512.                 break;
  513.             case 'PUT':
  514.                 $request->method = Http::PUT;
  515.                 break;
  516.             case 'DELETE':
  517.                 $request->method = Http::DELETE;
  518.                 break;
  519.             case 'GET':
  520.                 $request->method = Http::GET;
  521.                 break;
  522.             case 'PATCH':
  523.                 $request->method = Http::PATCH;
  524.                 break;
  525.         }
  526.         $res = $request->send();
  527.         $headers = $res->headers;
  528.         $dossiernummer = -1;
  529.         if ($res->code == 201){
  530.             $exp = explode('/', $headers['location']);
  531.             # get last of exp
  532.             $dossiernummer = intval($exp[count($exp) - 1]);
  533.         }
  535.         return new JsonResponse([
  536.             'responseData' => $res->raw_body,
  537.             'responseCode' => $res->code,
  538.             'success' => $res->code == 201,
  539.             'nummer' => $dossiernummer
  540.         ]);
  541.     }
  543.     /**
  544.      * @Route("/api/elements/getdefaultids/{dossierId}", name="elementsGetDefaultIds")
  545.      */
  546.     public function apiElementsGetDefaultIds(EntityManagerInterface $em, SessionInterface $session, Request $request, $dossierId) {
  547.         if (!AccessHelper::ownIP($request->getClientIp())) {
  548.             return new JsonResponse(['access' => False]);
  549.         }
  551.         $relation =  FasterForwardHelper::getRelation($dossierId);
  554.         return new JsonResponse([
  555.             'persoonId' => $relation->id,
  556.             'adresId' => $relation->adres_id,
  557.         ]);
  558.     }
  559.     /**
  560.      * @Route("/api/elementsProduct", name="elementsProduct")
  561.      */
  562.     public function apiElementsProduct(EntityManagerInterface $em, SessionInterface $session, Request $request) {
  563.         if (!AccessHelper::ownIP($request->getClientIp())) {
  564.             return new JsonResponse(['access' => False]);
  565.         }
  566.         $entities = json_decode($request->getContent());
  569.         $request = new FasterForwardUpdateSchadeverzekeringRequest();
  570.         $request->path = $entities->url;
  571.         $request->requestData = json_decode(json_encode($entities->requestData), true);
  572.         $request->urlOnly = json_decode(json_encode($entities->urlOnly), true);
  573.         switch (json_decode(json_encode($entities->method), true)) {
  574.             case 'POST':
  575.                 $request->method = Http::POST;
  576.                 break;
  577.             case 'PUT':
  578.                 $request->method = Http::PUT;
  579.                 break;
  580.             case 'DELETE':
  581.                 $request->method = Http::DELETE;
  582.                 break;
  583.             case 'GET':
  584.                 $request->method = Http::GET;
  585.                 break;
  586.             case 'PATCH':
  587.                 $request->method = Http::PATCH;
  588.                 break;
  589.         }
  590.         $res = $request->send();
  591.         $headers = $res->headers;
  592.         $dossiernummer = -1;
  593.         if ($res->code == 201){
  594.             $exp = explode('/', $headers['location']);
  595.             # get last of exp
  596.             $dossiernummer = intval($exp[count($exp) - 1]);
  597.         }
  599.         return new JsonResponse([
  600.             'responseData' => $res->raw_body,
  601.             'responseCode' => $res->code,
  602.             'success' => $res->code == 201,
  603.             'nummer' => $dossiernummer
  604.         ]);
  605.     }
  607.     public function getRelation($relations, $input) {
  608.         $matches = [];
  609.         foreach ($relations as $relation) {
  610.             if ($relation->field('email')->value() != '' && isset($input->{'email'}) && $input->{'email'} != '' && $input->{'email'} != '-') {
  611.                 if ($relation->field('email')->value() != $input->{'email'}) {
  612.                     continue;
  613.                 }
  614.             }
  615.             if ($relation->field('postcode')->value() != '' && isset($input->{'postcode'})&& $input->{'postcode'} != '-') {
  616.                 if ($relation->field('postcode')->value() != $input->{'postcode'}) {
  617.                     continue;
  618.                 }
  619.             }
  620.             if ($relation->field('iban')->value() != '' && isset($input->{'iban'}) && $input->{'iban'} != '-' && $input->{'iban'} != '') {
  621.                 if ($relation->field('iban')->value() != $input->{'iban'}) {
  622.                     continue;
  623.                 }
  624.             }
  625.             if ($relation->field('achternaam')->value() != '' && isset($input->{'achternaam'})&& $input->{'achternaam'} != '-' && $input->{'achternaam'} != '') {
  626.                 if (strtolower($relation->field('achternaam')->value()) != strtolower($input->{'achternaam'})) {
  627.                     continue;
  628.                 }
  629.             }
  630.             if ($relation->field('voorletters')->value() != '' && isset($input->{'voorletters'})&& $input->{'voorletters'} != '-' && $input->{'voorletters'} != '') {
  631.                 if (str_replace(' ', '', str_replace( '.', '', $relation->field('voorletters')->value())) != str_replace(' ', '', str_replace( '.', '', $input->voorletters))) {
  632.                     continue;
  633.                 }
  634.             }
  635.             if ($relation->field('geboortedatum')->value() != '') {
  636.                 $reformat = \DateTime::createFromFormat('Ymd', $relation->field('geboortedatum')->value())->format('d-m-Y');
  637.                 if ($input->{'geboortedatum'} != '' && $reformat != $input->{'geboortedatum'}) {
  638.                     continue;
  639.                 }
  640.             }
  642.             $matches[] = $relation;
  643.         }
  644.         return $matches;
  645.     }
  647.     /**
  648.      * @Route("/api/findRelation/{datasource}", name="apiFindRelation")
  649.      */
  650.     public function test5(EntityManagerInterface $em, SessionInterface $session, Request $request, $datasource) {
  651.         if (!AccessHelper::ownIP($request->getClientIp())) {
  652.             return new JsonResponse(['access' => False]);
  653.         }
  654.         $entities = json_decode($request->getContent());
  656.         $relations = RelationSearch::byNAW([
  657.             'postcode' => $entities->{'postcode'},
  658.             'huisnummer' => $entities->{'huisnummer'}
  659.         ], $datasource);
  661.         $res = $this->getRelation($relations, $entities);
  663.         $output = [];
  664.         foreach ($res as $result) {
  665.             $wijziginsreden = intval($result->field('wijzigingsreden')->value());
  666.             if (empty($wijziginsreden)) {
  667.                 $vervallen = false;
  668.             } else {
  669.                 $vervallen = ($wijziginsreden >= 40 && $wijziginsreden < 50);
  670.             }
  671.             if ($vervallen) {
  672.                 continue;
  673.             }
  674. //            $isHollandia = RelationSearch::byActiveHollandia($result->field('relatienummer')->value(), $datasource);
  675. //            if ($isHollandia) {
  676.             $output[] = [
  677.                 'relatienummer' => $result->field('relatienummer')->value(),
  678.                 'achternaam' => $result->field('achternaam')->value(),
  679.                 'agent' => $result->field('agent')->value(),
  680.                 'kantoor' => $result->field('kantoorcode')->value(),
  681.             ];
  682. //            }
  683.         }
  684.         return new JsonResponse($output);
  685.     }
  687.     /**
  688.      * @Route("/api/findAbbo/{datasource}", name="apiFindAbonnement")
  689.      */
  690.     public function testPakketAbonnement(EntityManagerInterface $em, SessionInterface $session, Request $request, $datasource)
  691.     {
  692.         if (!AccessHelper::ownIP($request->getClientIp())) {
  693.             return new JsonResponse(['access' => False]);
  694.         }
  695.         $entities = json_decode($request->getContent());
  696.         $poliskey = $entities->{'key'};
  698.         $collection = new Collection('polissen');
  699.         foreach ($entities->{'fields'} as $field) {
  700.             $collection->addField(new FieldLabel($field));
  702.         }
  703.         $collection->addField(FieldLabel::name('polis', 'wijzigingsreden'));
  704.         $collection->addField(FieldLabel::name('polis', 'wijzigingsdatum'));
  705.         $collection->addField(new FieldPrimary());
  707.         $collectionDekkingen = new Collection('dekkingen');
  708.         $collectionDekkingen->addField(FieldLabel::name('dekking', 'dekking'));
  709.         $collectionDekkingen->addField(FieldLabel::name('dekking', 'toeslag_percentage_dekking'));
  710.         $collectionDekkingen->addField(FieldLabel::name('dekking', 'toeslag_absoluut_dekking'));
  711.         $collectionDekkingen->addField(FieldLabel::name('dekking', 'toeslag_absoluut_dekking'));
  712.         $collectionDekkingen->addField(FieldLabel::name('dekking', 'incassobedrag'));
  714.         $collection->addCollection($collectionDekkingen);
  716.         $collection
  717.             ->addFilter(new Filter(FieldLabel::name('polis', 'polisnummer'), $poliskey))
  718.             ->addFilter(new Filter(FieldLabel::name('polis', 'maatschappij'), 'V201'));
  721.         $request = new AwacsViewRequest($collection);
  722.         $request->setDisplayOption('display');
  723.         if (isset($datasource)) {
  724.             $response = $request->send($datasource);
  725.         } else {
  726.             $response = $request->send();
  727.         }
  728.         $ret = [];
  729.         $i = 0;
  730.         foreach ($response->entities() as $entity) {
  731.             $ret[$i]['fields'] = [];
  732.             $ret[$i]['dekkingen'] = [];
  734.             foreach ($entity->fields as $field => $value) {
  735.                 $ret[$i]['fields'][$field] = $value->value();
  736.             }
  737.             foreach ($entity->collection('dekkingen') as $fieldS => $entity) {
  738.                 $ret[$i]['dekkingen'][$fieldS] = [];
  739.                 foreach ($entity->fields as $field => $value) {
  740.                     $ret[$i]['dekkingen'][$fieldS][$field] = $value->value();
  741.                 }
  743.                 $ret[$i]['key'] = $entity->key();
  744.                 $i = $i + 1;
  745.             }
  747.             return new JsonResponse($ret);
  748.         }
  749.     }
  752.     /**
  753.      * @Route("/api/findPolis/{datasource}", name="apiFindPolis")
  754.      */
  755.     public function test8(EntityManagerInterface $em, SessionInterface $session, Request $request, $datasource) {
  756.         if (!AccessHelper::ownIP($request->getClientIp())) {
  757.             return new JsonResponse(['access' => False]);
  758.         }
  759.         $entities = json_decode($request->getContent());
  760.         $poliskey = $entities->{'key'};
  762.         $collection = new Collection('polissen');
  763.         foreach ($entities->{'fields'} as $field) {
  764.             $collection->addField(new FieldLabel($field));
  765.         }
  767.         $collection
  768.             ->addFilter(new Filter(new FieldPrimary(), $poliskey, '='));
  771.         $request = new AwacsViewRequest($collection);
  772.         $request->setDisplayOption('display');
  773.         if (isset($datasource)) {
  774.             $response = $request->send($datasource);
  775.         } else {
  776.             $response = $request->send();
  777.         }
  778.         $ret = [];
  779.         foreach ($response->entities()[0]->fields as $field => $value) {
  780.             $ret[$field] = $value->value();
  781.         }
  783.         return new JsonResponse($ret);
  784.         return new JsonResponse($output);
  785.     }
  787.     /**
  788.      * @Route("/api/findAgendas/{datasource}", name="apiFindAgendas")
  789.      */
  790.     public function test24(EntityManagerInterface $em, SessionInterface $session, Request $request, $datasource) {
  791.         if (!AccessHelper::ownIP($request->getClientIp())) {
  792.             return new JsonResponse(['access' => False]);
  793.         }
  794.         $entities = json_decode($request->getContent());
  795.         $poliskey = $entities->{'key'};
  798.         $collectionAgenda = new Collection('agendaas');
  799.         $collectionAgenda->addField(new FieldLabel('*'));
  802.         $collectionAgenda
  803.             ->addFilter(new Filter(new FieldPrimary(), 'AGENDA_P'. $poliskey . "*", '='));
  806.         $request = new AwacsViewRequest($collectionAgenda);
  807.         $request->setDisplayOption('display');
  808.         if (isset($datasource)) {
  809.             $response = $request->send($datasource);
  810.         } else {
  811.             $response = $request->send();
  812.         }
  813.         $out = [];
  814.         foreach ($response->entities() as $entity) {
  815.             $ret = [];
  816.             foreach ($entity->fields as $field => $value) {
  817.                 $ret[$field] = $value->value();
  818.             }
  819.             $ret['pk'] = $response->entities()[0]->key();
  820.             $out[] = $ret;
  821.         }
  824.         return new JsonResponse($out);
  825.         return new JsonResponse($output);
  826.     }
  828.     public function responseToJson(AwacsResponse $response) {
  829.         $polis = $response->entities()[0];
  830.         $output = [
  831.             'fields' => [],
  832.             'dekkingen' => [],
  833.         ];
  834.         foreach ($polis->fields as $field => $value) {
  835.             $output['fields'][$field] = $value->value();
  836.         }
  837.         foreach ($polis->collection('dekkingen') as $field => $dekking) {
  838.             $res = [];
  839.             foreach ($dekking->fields as $fieldD => $value) {
  840.                 $res[$fieldD] = $value->value();
  841.             }
  842.             $output['dekkingen'][$dekking->field('dekking')->value()] = $res;
  843.         }
  846.         return $output;
  848.     }
  850.     /**
  851.      * @Route("/api/fieldsSjabloon/{datasource}", name="apiFieldsSjabloon")
  852.      */
  853.     public function test9(EntityManagerInterface $em, SessionInterface $session, Request $request, $datasource) {
  854.         if (!AccessHelper::ownIP($request->getClientIp())) {
  855.             return new JsonResponse(['access' => False]);
  856.         }
  858.         $entities = json_decode($request->getContent());
  859.         $poliskey = $entities->{'key'};
  860.         $productId = $entities->{'productId'};
  861.         $contextId = $entities->{'contextId'};
  862.         $functieId = $entities->{'functieId'};
  863.         $maatschappij = $entities->{'maatschappij'};
  865.         $projdir = $this->getParameter('kernel.project_dir');
  867.         switch ($maatschappij) {
  868.             case 'V059':
  869.                 $maatschappij = 'asr';
  870.                 break;
  871.             case 'N200':
  872.                 $maatschappij = 'nn';
  873.                 break;
  874.         }
  876.         $data = VPIRequest::templateEmpty('', $productId, $contextId, $functieId, 'geefSjabloon');
  877.         $result = VPIRequest::sendRequestVPI($data, $maatschappij, $projdir, true);
  879.         $collection = new Collection('polissen');
  880.         $collection->addField(new FieldLabel('*'));
  881.         $collectionDekkingen = new Collection('dekkingen');
  882.         $collectionDekkingen->addField(new FieldLabel('*'));
  884.         $collection->addCollection($collectionDekkingen);
  885.         $collection
  886.             ->addFilter(new Filter(new FieldPrimary(), $poliskey, '='));
  889.         $request = new AwacsViewRequest($collection);
  890.         $request->setDisplayOption('display');
  891.         if (isset($datasource)) {
  892.             $response = $request->send($datasource);
  893.         } else {
  894.             $response = $request->send();
  895.         }
  897.         return new JsonResponse([
  898.             'sjabloon' => $result,
  899.             'polisinfo' => self::responseToJson($response),
  900.         ]);
  902.     }
  904.     /**
  905.      * @Route("/api/vpiAcceptatie", name="apiVPIAcceptatie")
  906.      */
  907.     public function test10(EntityManagerInterface $em, SessionInterface $session, Request $request) {
  908.         if (!AccessHelper::ownIP($request->getClientIp())) {
  909.             return new JsonResponse(['access' => False]);
  910.         }
  912.         $entities = json_decode($request->getContent());
  913.         $poliskey = $entities->{'key'};
  914.         $productId = $entities->{'productId'};
  915.         $contextId = $entities->{'contextId'};
  916.         $functieId = $entities->{'functieId'};
  917.         $maatschappij = $entities->{'maatschappij'};
  918.         $data = $entities->{'requestData'};
  920.         $projdir = $this->getParameter('kernel.project_dir');
  922.         switch ($maatschappij) {
  923.             case 'V059':
  924.                 $maatschappij = 'asr';
  925.                 break;
  926.             case 'N200':
  927.                 $maatschappij = 'nn';
  928.                 break;
  929.         }
  931.         $data = VPIRequest::templateEmpty($data, $productId, $contextId, $functieId, 'doeFunctie');
  932.         $result = VPIRequest::sendRequestVPI($data, $maatschappij, $projdir);
  935.         return new JsonResponse($result);
  937.     }
  939.     /**
  940.      * @Route("/api/vpi/auto", name="apiVPIAuto")
  941.      */
  942.     public function apiVPIAuto(EntityManagerInterface $em, SessionInterface $session, Request $request) {
  943.         if (!AccessHelper::ownIP($request->getClientIp())) {
  944.             return new JsonResponse(['access' => False]);
  945.         }
  946.         if ($request->getMethod() === 'OPTIONS') {
  947.             $response = new JsonResponse();
  948.             $response->headers->set('Access-Control-Allow-Origin', 'https://chat.pivotwise.nl');
  949.             $response->headers->set('Access-Control-Allow-Methods', 'POST, GET, OPTIONS');
  950.             $response->headers->set('Access-Control-Allow-Headers', 'Content-Type');
  952.             return $response;
  953.         }
  954.         error_log($request->getContent());
  956.         $premiebepalendeGegevens = json_decode($request->getContent());
  957.         error_log($request->getContent());
  959.         $process = new ProcessCar();
  960.         $process->svj = $premiebepalendeGegevens->schadevrijeJaren;
  961.         $process->geboortedatum = $premiebepalendeGegevens->geboortedatum;
  962.         $process->postcode = $premiebepalendeGegevens->postcode;
  963.         $process->huisnummer = $premiebepalendeGegevens->huisnummer;
  964.         $process->kilometers = str_replace('km_', '', $premiebepalendeGegevens->kilometrage);
  965.         $process->toevoeging = '';
  967.         $process->relatieGeboortedatum = $premiebepalendeGegevens->geboortedatum;
  968.         $process->relatiePostcode = $premiebepalendeGegevens->postcode;
  969.         $process->relatieHuisnummer = $premiebepalendeGegevens->huisnummer;
  970.         $process->relatieToevoeging = '';
  971.         $process->dekking = $premiebepalendeGegevens->dekking;
  972.         $process->termijn = 'maand';
  974.         $process->kenteken = $premiebepalendeGegevens->kenteken;
  975.         $process->mutationIngangsdatum = new \DateTime();
  976.         $process->ingangsdatum = new \DateTime();
  978.         $projdir = $this->getParameter('kernel.project_dir');
  980.         $productId = 'VPI_NN_PersP2024ExclBM';
  981.         $maatschappij = VPIMappingNew::getMaatschappijByProductId($productId);
  982.         $dummyTemplate = VPIRequest::template('', $productId, $process, false);
  983.         $gimCache = VPIRequest::getSjabloonStdClass($em, $projdir, $maatschappij, $productId, $dummyTemplate['doeFunctieVraag']['procesInfo']['functie']['contextId'], $dummyTemplate['doeFunctieVraag']['procesInfo']['functie']['functieId']);
  985.         $data = VPIMapping::transform($process, $productId, ['vc'], $gimCache, null);
  986.         if ($data === false) {
  987.             return false;
  988.         }
  989.         $responseBin = new \stdClass();
  990.         $response = VPIRequest::sendVPI($projdir, $data, $maatschappij, $productId, $process, $responseBin);
  992.         if ($response !== null) {
  993.             $policies = VPIHelper::parsePolis($response, $productId, 'Autoverzekering', $data, $process, $responseBin, ['vc']);
  994.             if ($policies !== null) {
  995.                 foreach ($policies as $policy) {
  996.                     $process->results[] = $policy;
  997.                 }
  998.             }
  999.         }
  1002.         $res = new JsonResponse($process->results);
  1003.         $res->headers->set('Access-Control-Allow-Origin', 'https://chat.pivotwise.nl');
  1004.         $res->headers->set('Access-Control-Allow-Methods', 'POST, GET, OPTIONS');
  1005.         $res->headers->set('Access-Control-Allow-Headers', 'Content-Type');
  1007.         // Add your data to the response if necessary, e.g., $response->setData([...]);
  1009.         return $res;
  1010.     }
  1011. }