1. <?php
3. namespace App\Controller;
5. use App\Document\TrapData;
6. use App\Entity\Action;
7. use App\Entity\Address;
8. use App\Entity\Area;
9. use App\Entity\Article;
10. use App\Entity\ArticleCategory;
11. use App\Entity\Contract;
12. use App\Entity\Detergent;
13. use App\Entity\GroundPlan;
14. use App\Entity\GroundPlanTraps;
15. use App\Entity\Log;
16. use App\Entity\MediaObject;
17. use App\Entity\Person;
18. use App\Entity\Project;
19. use App\Entity\Report;
20. use App\Entity\Timesheet;
21. use App\Entity\Trap;
22. use App\Entity\TrapCategory;
23. use App\Entity\TrapQuestion;
24. use App\Entity\TrapScan;
25. use App\Entity\TrapScanTrap;
26. use App\Entity\User;
27. use App\Message\XignalClient;
28. use App\Service\SoapService;
29. use Doctrine\ODM\MongoDB\DocumentManager;
30. use Doctrine\ORM\EntityManagerInterface;
31. use ErrorException;
32. use Psr\Log\LoggerInterface;
33. use Symfony\Bridge\Twig\Mime\TemplatedEmail;
34. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
35. use Symfony\Component\HttpFoundation\BinaryFileResponse;
36. use Symfony\Component\HttpFoundation\Request;
37. use Symfony\Component\HttpFoundation\Response;
38. use Symfony\Component\HttpClient\HttpClient;
39. use Symfony\Component\HttpKernel\Exception\HttpException;
40. use Symfony\Component\HttpKernel\Exception\ServiceUnavailableHttpException;
41. use Symfony\Component\HttpKernel\KernelInterface;
42. use Symfony\Component\Mailer\MailerInterface;
43. use Symfony\Component\PasswordHasher\Hasher\UserPasswordHasherInterface;
44. use Symfony\Component\Routing\Annotation\Route;
45. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
46. use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
48. class DefaultController extends AbstractController
49. {
50.   private $logger;
51.   private $em;
52.   private $projectDir;
53.   private $userPasswordHasher;
54.   private $mailer;
55.   private $soap;
56.   private $documentManager;
57.   private $xignalClient;
58.   private $dm;
59.   private $apiServer;
60.   private $apiPort;
61.   private $apiSlug;
62.   private $apiUsername;
63.   private $apiPassword;
64.   private $parameterBag;
66.   public function __construct(
67.       $projectDir,
68.       LoggerInterface $logger,
69.       EntityManagerInterface $em,
70.       UserPasswordHasherInterface $userPasswordHasher,
71.       MailerInterface $mailer,
72.       SoapService $soap,
73.       DocumentManager $documentManager,
74.       XignalClient $xignalClient,
75.       DocumentManager $dm,
76.       ParameterBagInterface $parameterBag
77.   ) {
78.       $this->logger = $logger;
79.       $this->em = $em;
80.       $this->projectDir = $projectDir;
81.       $this->userPasswordHasher = $userPasswordHasher;
82.       $this->mailer = $mailer;
83.       $this->soap = $soap;
84.       $this->documentManager = $documentManager;
85.       $this->xignalClient = $xignalClient;
86.       $this->dm = $dm;
87.       $this->parameterBag = $parameterBag;
88.       $this->apiServer = $parameterBag->get('consolit_api_server');
89.       $this->apiSlug = $parameterBag->get('consolit_api_slug');
90.       $this->apiUsername = $parameterBag->get('consolit_api_username');
91.       $this->apiPassword = $parameterBag->get('consolit_api_password');
92.   }
94.   #[Route(path: '/')]
95.   public function home(): Response
96.   {
97.     return $this->render('base.html.twig');
98.   }
100.   /**
101.    * Corrector for address names
102.    */
103.   #[Route('/corrector_address_names', name: 'corrector_address_names')]
104.   public function correctorAddressNames(Request $request): Response
105.   {
106.     // Haal alle adressen op
107.     $addresses = $this->em->getRepository(Address::class)->findAll();
108.     
109.     // Resultaten bijhouden
110.     $dryRunResults = [];
111.     $totalFound = 0;
112.     
113.     // Regex patroon voor adresherkenning
114.     // Zoekt naar patronen zoals: "straat 123", "1234 AB", "Plaats", etc.
115.     $addressPattern = '/\s-\s.*(\d+[a-zA-Z]*\s|\d{4}\s?[A-Z]{2}|straat|weg|laan|plein|singel)/i';
116.     
117.     // Controleer alle adressen
118.     foreach ($addresses as $address) {
119.       $name = $address->getName();
120.       
121.       // Controleer of de naam een streepje bevat
122.       if ($name && strpos($name, ' - ') !== false) {
123.         // Splits de naam op het eerste streepje
124.         $parts = explode(' - ', $name, 2);
125.         $afterDash = $parts[1] ?? '';
126.         
127.         // Sla namen over met "stal" of "PLAEEN" (hoofdletterongevoelig) na het streepje
128.         if (stripos($afterDash, 'stal') !== false || stripos($afterDash, 'PLAEEN') !== false) {
129.           continue;
130.         }
131.         
132.         $totalFound++;
133.         $newName = trim($parts[0]);
134.         
135.         // Controleer of het deel na het streepje op een adres lijkt
136.         $isLikelyAddress = preg_match($addressPattern, $name);
137.         
138.         // Voeg toe aan resultaten
139.         $dryRunResults[] = [
140.           'id' => $address->getId(),
141.           'uuid' => $address->getUuid(),
142.           'oldName' => $name,
143.           'newName' => $newName,
144.           'isLikelyAddress' => $isLikelyAddress
145.         ];
146.       }
147.     }
148.     
149.     // Voer de echte update uit als dit is bevestigd
150.     if ($request->query->has('confirm') && $request->query->get('confirm') === 'true') {
151.       $updatedCount = 0;
152.       
153.       foreach ($dryRunResults as $result) {
154.         $address = $this->em->getRepository(Address::class)->find($result['id']);
155.         if ($address) {
156.           $address->setName($result['newName']);
157.           $updatedCount++;
158.         }
159.       }
160.       
161.       $this->em->flush();
162.       
163.       $html = '<html><body>';
164.       $html .= '<h1>Adres Corrector - Live Run</h1>';
165.       $html .= '<p>Aantal adressen bijgewerkt: ' . $updatedCount . ' van ' . $totalFound . '</p>';
166.       $html .= '<p><a href="/corrector">Terug naar dry run</a></p>';
167.       $html .= '</body></html>';
168.       
169.       return new Response($html);
170.     }
171.     
172.     // Toon de dry run resultaten
173.     $html = '<html><body>';
174.     $html .= '<h1>Adres Corrector - Dry Run</h1>';
175.     $html .= '<p>Totaal aantal adressen met streepje gevonden: ' . $totalFound . '</p>';
176.     
177.     $html .= '<h2>Alle items (' . count($dryRunResults) . ')</h2>';
178.     $html .= '<table border="1" cellpadding="5" style="border-collapse: collapse;">';
179.     $html .= '<tr><th>ID</th><th>Oude naam</th><th>Nieuwe naam</th><th>Lijkt op adres?</th></tr>';
180.     
181.     foreach ($dryRunResults as $result) {
182.       $html .= '<tr>';
183.       $html .= '<td>' . $result['id'] . '</td>';
184.       $html .= '<td>' . htmlspecialchars($result['oldName']) . '</td>';
185.       $html .= '<td>' . htmlspecialchars($result['newName']) . '</td>';
186.       $html .= '<td>' . ($result['isLikelyAddress'] ? 'Ja' : '<strong style="color: red;">NEE</strong>') . '</td>';
187.       $html .= '</tr>';
188.     }
189.     
190.     $html .= '</table>';
191.     
192.     if (count($dryRunResults) > 0) {
193.       $html .= '<p><a href="/corrector?confirm=true" style="background-color: #4CAF50; color: white; padding: 10px 20px; text-decoration: none; display: inline-block; margin-top: 20px;">Voer wijzigingen door</a></p>';
194.     }
195.     
196.     $html .= '</body></html>';
197.     
198.     return new Response($html);
199.   }
201.   #[Route('/import_visit_frequency_and_last_visit', name: 'cron_import_visit_frequency_and_last_visit')]
202.   public function importVisitFrequencyAndLastVisit(): Response
203.   {
205.     die(); // comment to enable import function
207.     $csvFilePath = 'visit_frequency.csv';
209.     if (!file_exists($csvFilePath)) {
210.       $this->logger->error("CSV-bestand niet gevonden op {$csvFilePath}");
211.       return new Response("CSV-bestand niet gevonden.", Response::HTTP_NOT_FOUND);
212.     }
214.     $handle = fopen($csvFilePath, 'r');
215.     if (!$handle) {
216.       $this->logger->error("Kan CSV-bestand niet openen op {$csvFilePath}");
217.       return new Response("Kan CSV-bestand niet openen.", Response::HTTP_INTERNAL_SERVER_ERROR);
218.     }
220.     $updatedCount = 0;
222.     // Lees CSV regels
223.     while (($data = fgetcsv($handle, 1000, ';')) !== false) {
224.       $projectId = $data[16] ?? null;      // Projectkaart (kolom 17)
225.       $eckId = $data[17] ?? null;          // Onderdeel (kolom 18)
226.       $visitFrequency = $data[14] ?? null; // Normweken (kolom 15)
227.       $lastVisitDate = $data[8] ?? null;   // Afgewerkt (kolom 9)
229.       if (!$projectId || !$eckId || !is_numeric($visitFrequency) || stripos($data[3] ?? '', 'TEST TEST TEST') !== false) {
230.         continue;
231.       }
233.       // Zoek adres op basis van Projectkaart en Onderdeel
234.       $addresses = $this->em->getRepository(Address::class)->createQueryBuilder('address')
235.       ->leftJoin('address.project', 'project')
236.       ->where('project.projectId = :projectId')
237.       ->andWhere('address.eckId = :eckId')
238.       ->andWhere('address.deletedAt IS NULL')
239.       ->setParameter('projectId', $projectId)
240.         ->setParameter('eckId', $eckId)
241.         ->getQuery()
242.         ->getResult();
244.       if (count($addresses)) {
245.         foreach ($addresses as $address) {
246.           // Stel bezoekfrequentie in
247.           $address->setVisitFrequency((int) $visitFrequency);
249.           // Parse en stel laatste bezoekdatum in
250.           if ($lastVisitDate) {
251.             try {
252.               $lastVisitDateObj = \DateTime::createFromFormat('d-m-Y H:i', $lastVisitDate);
253.               if ($lastVisitDateObj) {
254.                 $address->setLastVisitDate($lastVisitDateObj);
255.               }
256.             } catch (\Exception $e) {
257.               $this->logger->error("Ongeldige datum in CSV: {$lastVisitDate}");
258.             }
259.           }
261.           $this->em->persist($address);
262.           $updatedCount++;
263.         }
264.       }
265.     }
267.     fclose($handle);
268.     $this->em->flush();
270.     $this->logger->info("Import voltooid. {$updatedCount} adressen bijgewerkt.");
271.     return new Response("Import voltooid. {$updatedCount} adressen bijgewerkt.");
272.   }
274.   /**
275.    * Importeer adressen vanuit ObjectenContracten CSV bestanden
276.    */
277.   #[Route(path: '/addressImporter')]
278.   public function addressImporter(Request $request): Response
279.   {
280.     $csvFiles = [
281.       0 => $this->projectDir . 'ObjectenContracten.csv',
282.       8 => $this->projectDir . 'ObjectenContracten_essen.csv',
283.     ];
285.     $logs = [];
286.     $csvData = [];
287.     foreach ($csvFiles as $werkm => $filePath) {
288.       if (!file_exists($filePath)) {
289.         $logs[] = "<b>CSV-bestand niet gevonden:</b> {$filePath}";
290.         continue;
291.       }
292.       $handle = fopen($filePath, 'r');
293.       if (!$handle) {
294.         $logs[] = "<b>Kan CSV-bestand niet openen:</b> {$filePath}";
295.         continue;
296.       }
297.       $header = fgetcsv($handle, 0, ';');
298.       // Zoek index van eerste kolom 'Onderdeel' (voor eckId)
299.       $headerMap = [];
300.       $eckIdIndex = null;
301.       foreach ($header as $idx => $col) {
302.         $colName = trim($col);
303.         // Sla alleen de eerste 'Onderdeel' index op
304.         if ($colName === 'Onderdeel' && $eckIdIndex === null) {
305.           $eckIdIndex = $idx;
306.         }
307.         $headerMap[$colName] = $idx;
308.       }
309.       $rowCount = 0;
310.       $sampleRows = [];
311.       while (($data = fgetcsv($handle, 0, ';')) !== false) {
312.         $rowCount++;
313.         // Gebruik per werkm de juiste indexen voor projectkaart en eckId
314.         if ($werkm == 8) { // _essen
315.           $projectkaart = isset($data[2]) ? trim($data[2]) : null;
316.           $eckId = isset($data[3]) ? trim($data[3]) : null;
317.         } else { // standaard
318.           $projectkaart = isset($data[3]) ? trim($data[3]) : null;
319.           $eckId = isset($data[4]) ? trim($data[4]) : null;
320.         }
321.         if ($projectkaart && $eckId) {
322.           $csvData[$werkm][(string)$projectkaart][(string)$eckId] = $data;
323.           if (count($sampleRows) < 3) {
324.             $sampleRows[] = [
325.               'projectkaart' => $projectkaart,
326.               'eckId' => $eckId,
327.               'row' => $data
328.             ];
329.           }
330.         }
331.       }
332.       fclose($handle);
333.       $logs[] = "CSV geladen: <code>{$filePath}</code>, regels ingelezen: <b>{$rowCount}</b>";
334.       $logs[] = 'Keys voor werkm ' . $werkm . ': <code>' . htmlspecialchars(json_encode(array_keys($csvData[$werkm] ?? []))) . '</code>';
335.       $logs[] = 'Voorbeeld eerste 3 entries werkm ' . $werkm . ': <pre>' . htmlspecialchars(print_r($sampleRows, true)) . '</pre>';
336.     }
338.     // Find addresses with missing address data (street, housenumber, postal, city)
339.     $addresses = $this->em->getRepository(Address::class)->createQueryBuilder('address')
340.       ->leftJoin('address.project', 'project')
341.       ->where('address.deletedAt IS NULL')
342.       ->andWhere('address.street IS NULL OR address.housenumber IS NULL OR address.postal IS NULL OR address.city IS NULL')
343.       ->getQuery()
344.       ->getResult();
345.     $logs[] = 'Aantal adressen met ontbrekende data: <b>' . count($addresses) . '</b>';
347.     $updatedCount = 0;
348.     $batchSize = 500;
349.     // Inverted dry run: default is dry run, only execute if ?live=1
350.     $dryRun = $request->query->get('live', '0') !== '1';
351.     $overview = [];
353.     foreach ($addresses as $address) {
354.       $project = $address->getProject();
355.       if (!$project) {
356.         $logs[] = 'Adres zonder project: <b>' . (method_exists($address, 'getId') ? $address->getId() : 'onbekend') . '</b>';
357.         continue;
358.       }
359.       $werkm = $project->getWerkm();
360.       if (!isset($csvData[$werkm])) {
361.         $logs[] = 'Geen CSV data voor werkm: <b>' . $werkm . '</b> (adres ID: <b>' . (method_exists($address, 'getId') ? $address->getId() : 'onbekend') . '</b>)';
362.         continue;
363.       }
364.       $projectkaart = (string)trim($project->getProjectId());
365.       $eckId = $address->getEckId();
366.       $eckIds = method_exists($address, 'getEckIds') ? $address->getEckIds() : [];
367.       $eckIdsList = [];
368.       if ($eckId) $eckIdsList[] = $eckId;
369.       if (is_array($eckIds)) {
370.         foreach ($eckIds as $eid) {
371.           if ($eid && !in_array($eid, $eckIdsList, true)) {
372.             $eckIdsList[] = $eid;
373.           }
374.         }
375.       }
376.       // alles als string getrimd
377.       $eckIdsList = array_map(function($v) { return (string)trim($v); }, $eckIdsList);
378.       if (!$projectkaart || count($eckIdsList) === 0) {
379.         $logs[] = 'Adres zonder projectkaart of eckId(s): <b>' . (method_exists($address, 'getId') ? $address->getId() : 'onbekend') . '</b>';
380.         continue;
381.       }
382.       $row = null;
383.       $matchedEckId = null;
384.       foreach ($eckIdsList as $tryEckId) {
385.         if (isset($csvData[$werkm][$projectkaart][$tryEckId])) {
386.           $row = $csvData[$werkm][$projectkaart][$tryEckId];
387.           $matchedEckId = $tryEckId;
388.           break;
389.         }
390.       }
391.       if (!$row) {
392.         $logs[] = 'Geen match in CSV voor werkm: <b>' . $werkm . '</b>, projectkaart: <b>' . htmlspecialchars($projectkaart) . '</b>, eckIds: <b>' . htmlspecialchars(implode(", ", $eckIdsList)) . '</b> (adres ID: <b>' . (method_exists($address, 'getId') ? $address->getId() : 'onbekend') . '</b>)';
393.         $logs[] = 'Beschikbare projectkaarten voor werkm ' . $werkm . ': <code>' . htmlspecialchars(json_encode(array_keys($csvData[$werkm] ?? []))) . '</code>';
394.         $logs[] = 'Beschikbare eckIds voor projectkaart ' . $projectkaart . ': <code>' . htmlspecialchars(json_encode(array_keys($csvData[$werkm][$projectkaart] ?? []))) . '</code>';
395.         continue;
396.       }
397.       $logs[] = 'Match gevonden voor adres ID: <b>' . (method_exists($address, 'getId') ? $address->getId() : 'onbekend') . '</b> op projectkaart <b>' . htmlspecialchars($projectkaart) . '</b> en eckId <b>' . htmlspecialchars($matchedEckId) . '</b>';
399.       $changed = false;
400.       $changes = [];
401.       // Haal adresvelden op via juiste indexen per werkm
402.       if ($werkm == 8) { // _essen
403.         $streetIdx = 15;
404.         $housenumberIdx = 16;
405.         $postalIdx = 17;
406.         $cityIdx = 18;
407.       } else {
408.         $streetIdx = 16;
409.         $housenumberIdx = 17;
410.         $postalIdx = 18;
411.         $cityIdx = 19;
412.       }
413.       if (!$address->getStreet() && isset($row[$streetIdx]) && trim($row[$streetIdx])) {
414.         $changes['street'] = trim($row[$streetIdx]);
415.         if (!$dryRun) $address->setStreet(trim($row[$streetIdx]));
416.         $changed = true;
417.       }
418.       if (!$address->getHousenumber() && isset($row[$housenumberIdx]) && trim($row[$housenumberIdx])) {
419.         $parsedHousenumber = $this->parseHousenumberToInt(trim($row[$housenumberIdx]));
420.         $changes['housenumber'] = $parsedHousenumber;
421.         if (!$dryRun) $address->setHousenumber($parsedHousenumber);
422.         $changed = true;
423.       }
424.       if (!$address->getPostal() && isset($row[$postalIdx]) && trim($row[$postalIdx])) {
425.         $changes['postal'] = trim($row[$postalIdx]);
426.         if (!$dryRun) $address->setPostal(trim($row[$postalIdx]));
427.         $changed = true;
428.       }
429.       if (!$address->getCity() && isset($row[$cityIdx]) && trim($row[$cityIdx])) {
430.         $changes['city'] = trim($row[$cityIdx]);
431.         if (!$dryRun) $address->setCity(trim($row[$cityIdx]));
432.         $changed = true;
433.       }
435.       if ($changed) {
436.         $updatedCount++;
437.         // Add to overview for dry run or reporting
438.         $overview[] = [
439.           'addressId' => method_exists($address, 'getId') ? $address->getId() : null,
440.           'projectkaart' => $projectkaart,
441.           'eckId' => $eckId,
442.           'changes' => $changes,
443.         ];
444.         if (!$dryRun) {
445.           $this->em->persist($address);
446.           if ($updatedCount % $batchSize === 0) {
447.             $this->em->flush();
448.             $this->em->clear();
449.           }
450.         }
451.       }
452.     }
454.     if (!$dryRun) {
455.       $this->em->flush();
456.       $this->em->clear();
457.     }
459.     $summary = "Corrector " . ($dryRun ? "(dry run) " : "") . "voltooid. {$updatedCount} adressen " . ($dryRun ? "zouden worden" : "bijgewerkt") . ".";
460.     $logs[] = '<b>' . htmlspecialchars($summary) . '</b>';
462.     // HTML output with all logs and overview
463.     $html = '<!DOCTYPE html><html><head><meta charset="utf-8"><title>Corrector Resultaat</title></head><body>';
464.     $html .= '<h2>Corrector Resultaat</h2>';
465.     $html .= '<ul>';
466.     foreach ($logs as $log) {
467.       $html .= '<li>' . $log . '</li>';
468.     }
469.     $html .= '</ul>';
470.     if ($dryRun && count($overview)) {
471.       $html .= '<h3>Wijzigingen die zouden worden uitgevoerd:</h3>';
472.       $html .= '<table border="1" cellpadding="4" style="border-collapse:collapse"><tr><th>Address ID</th><th>Projectkaart</th><th>EckId</th><th>Changes</th></tr>';
473.       foreach ($overview as $row) {
474.         $html .= '<tr>';
475.         $html .= '<td>' . htmlspecialchars($row['addressId']) . '</td>';
476.         $html .= '<td>' . htmlspecialchars($row['projectkaart']) . '</td>';
477.         $html .= '<td>' . htmlspecialchars($row['eckId']) . '</td>';
478.         $html .= '<td><pre>' . htmlspecialchars(print_r($row['changes'], true)) . '</pre></td>';
479.         $html .= '</tr>';
480.       }
481.       $html .= '</table>';
482.     }
483.     $html .= '</body></html>';
484.     return new Response($html);
485.   }
487.   /**
488.    * Parse a housenumber string to int (returns first integer found, or null if none found)
489.    */
490.   private function parseHousenumberToInt(?string $input): ?int
491.   {
492.     if (is_null($input) || $input === '') return null;
493.     if (preg_match('/(\d+)/', $input, $matches)) {
494.       return (int)$matches[1];
495.     }
496.     return null;
497.   }
499.   #[Route(path: '/adrescheck')]
500.   public function adrescheck(): Response
501.   {
502.     $addresses = $this->em->getRepository(Address::class)->createQueryBuilder('address')
503.       ->leftJoin('address.project', 'project')
504.       ->where('address.deletedAt IS NULL')
505.       ->andWhere('address.street IS NULL OR address.housenumber IS NULL OR address.postal IS NULL OR address.city IS NULL')
506.       ->getQuery()
507.       ->getResult();
509.     $html = '<!DOCTYPE html><html><head><meta charset="utf-8"><title>Adressen met ontbrekende data</title></head><body>';
510.     $html .= '<h2>Adressen met ontbrekende data</h2>';
511.     $html .= '<table border="1" cellpadding="4" style="border-collapse:collapse">';
512.     $html .= '<tr><th>Address ID</th><th>Projectkaart</th><th>EckId</th><th>Straat</th><th>Huisnummer</th><th>Postcode</th><th>Woonplaats</th></tr>';
513.     foreach ($addresses as $address) {
514.       $project = $address->getProject();
515.       $html .= '<tr>';
516.       $html .= '<td>' . htmlspecialchars(method_exists($address, 'getId') ? $address->getId() : '') . '</td>';
517.       $html .= '<td>' . htmlspecialchars($project && method_exists($project, 'getProjectId') ? $project->getProjectId() : '') . '</td>';
518.       $html .= '<td>' . htmlspecialchars(method_exists($address, 'getEckId') ? $address->getEckId() : '') . '</td>';
519.       $html .= '<td>' . htmlspecialchars($address->getStreet()) . '</td>';
520.       $html .= '<td>' . htmlspecialchars($address->getHousenumber()) . '</td>';
521.       $html .= '<td>' . htmlspecialchars($address->getPostal()) . '</td>';
522.       $html .= '<td>' . htmlspecialchars($address->getCity()) . '</td>';
523.       $html .= '</tr>';
524.     }
525.     $html .= '</table>';
526.     $html .= '<p>Totaal: <b>' . count($addresses) . '</b> adressen met ontbrekende data.</p>';
527.     $html .= '</body></html>';
528.     return new Response($html);
529.   }
531.   #[Route(path: '/corrector_report_scores')]
532.   public function correctorReportScores(): Response
533.   {
534.     $isEnabled = false;
535.     $trapQuestions = $this->em->getRepository(TrapQuestion::class)->findAll();
536.     $questions = [];
537.     foreach ($trapQuestions as $trapQuestion) {
538.         if ($trapQuestion->isCountsForScore()) {
539.             $questions[] = $trapQuestion->getId();
540.         }
541.     }
542.     if (count($questions) < 1) {
543.         return new Response('no questions');
544.     }
545.     $projects = $this->em->getRepository(Project::class)->findAll();
546.     if (!count($projects)) {
547.       return new Response('no projects');
548.     }
549.     foreach ($projects as $project) {
550.       $addresses = $this->em->getRepository(Address::class)->findBy(['project' => $project->getId()]);
551.       if (count($addresses) < 1) {
552.         continue;
553.       }
554.       $i = 0;
555.       foreach ($addresses as $address) {
556.           $reports = $this->em->getRepository(Report::class)->findBy(['address' => $address->getId()]);
557.           foreach ($reports as $report) {
558.               $catches = 0;
559.               $trapScans = $this->em->getRepository(TrapScan::class)->findBy(['report' => $report->getId()]);
560.               if (count($trapScans) < 1) {
561.                   continue;
562.               }
563.               foreach ($trapScans as $scan) {
564.                   $trapData = $this->dm->createQueryBuilder(TrapData::class)
565.                       ->find()
566.                       ->hydrate(false)
567.                       ->field('trapScan')->equals($scan->getId())
568.                       ->field('trapQuestion')->in($questions)
569.                       ->getQuery()
570.                       ->execute()
571.                       ->toArray();
572.                   if (count($trapData) < 1) {
573.                       continue;
574.                   }
575.                   foreach ($trapData as $data) {
576.                     if ($data['value'] && (int) $data['value'] > 0) {
577.                       $catches = $catches + (int) $data['value'];
578.                     }
579.                   }
580.               }
581.               if ($catches <= 1) {
582.                 $score = 'green';
583.             }
584.             if ($catches > 1 && $catches <= 3) {
585.                 $score = 'orange';
586.             }
587.             if ($catches > 3) {
588.                 $score = 'red';
589.             }
590.             $report->setScore($score);
591.             $this->em->persist($report);
592.             $i++;
593.             if ($isEnabled && ($i % 500 == 0)) {
594.               $this->em->flush();
595.             }
596.           }
597.       }
598.     }
599.     if ($isEnabled) {
600.       $this->em->flush();
601.     }
602.     return new Response('processed ' . $i . ' reports');
603.   }
606.   #[Route(path: '/start_mqtt_client')]
607.   public function startMqttClient(): Response
608.   {
609.     $this->xignalClient->init();
610.     return $this->render('base.html.twig');
611.   }
613.   #[Route(path: '/send_welcome_mail')]
614.   public function sendWelcomeMail(): Response
615.   {
616.       exit('not enabled');
617.       // TODO: Check for createdAt date to not process EVERY user
618.       $users = $this->em->getRepository(User::class)->findAll();
619.       foreach ($users as $user) {
620.           if (0 == count($user->getAddresses()) || 0 == count($user->getProjects()) || in_array('ROLE_EMPLOYEE', $user->getRoles())) {
621.               dump('skipping '.$user->getEmail());
622.               continue;
623.           }
624.           // generate password
625.           $comb = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890';
626.           $pass = [];
627.           $combLen = strlen($comb) - 1;
628.           for ($i = 0; $i < 12; ++$i) {
629.               $n = rand(0, $combLen);
630.               $pass[] = $comb[$n];
631.           }
632.           $newPassword = implode($pass);
633.           // update password
634.           $user->setPassword($this->userPasswordHasher->hashPassword($user, $newPassword));
635.           $user->eraseCredentials();
636.           $user->setModifiedAt(new \DateTime());
637.           $this->em->persist($user);
638.           // send email
639.           if (!filter_var($user->getEmail(), FILTER_VALIDATE_EMAIL)) {
640.               dump('incorrect email '.$user->getEmail());
641.               continue;
642.           }
643.           try {
644.               $message = (new TemplatedEmail());
645.               $message->sender('noreply@mailgun.vaneckbv.nl');
646.             $message->replyTo('info@vaneckbv.nl');
647.             $message->from('Van Eck Bedrijfshygiene <info@vaneckbv.nl>');
648.               $message->addTo($user->getEmail());
649.               $message->subject('Welkom in ons digitaal logboek');
650.               $message->htmlTemplate('Email/welcome.html.twig');
651.               $message->context([
652.                   'user' => $user,
653.                   'password' => $newPassword,
654.               ]);
655.               $this->mailer->send($message);
656.           } catch (ServiceUnavailableHttpException $e) {
657.               // throw new ServiceUnavailableHttpException('sending_email_failed');
658.               dump($e->getMessage());
659.           }
660.       }
661.       $this->em->flush();
663.       return new Response('done');
664.   }
666.   #[Route(path: '/send_2fa_mail')]
667.   public function send2FAMail(): Response
668.   {
669.       exit('not enabled');
670.       $users = $this->em->getRepository(User::class)->findAll();
671.       $message = (new TemplatedEmail());
672.       $message->sender('noreply@mailgun.vaneckbv.nl');
673.       $message->replyTo('info@vaneckbv.nl');
674.       $message->from('Van Eck Bedrijfshygiene <info@vaneckbv.nl>');
675.       $message->subject('Tweestapsverificatie vereist in het Digitale Logboek per 4 april 2023');
676.       $message->htmlTemplate('Email/introducing_2fa.html.twig');
677.       $count = 0;
678.       foreach ($users as $user) {
679.           $count++;
680.           if (0 == count($user->getAddresses()) || 0 == count($user->getProjects()) || in_array('ROLE_EMPLOYEE', $user->getRoles())) {
681.               continue;
682.           }
683.           $valid = false;
684.           foreach ($user->getAddresses() as $address) {
685.             if ($address->getSoapUsername()) {
686.               $valid = true;
687.             }
688.           } 
689.           foreach ($user->getProjects() as $project) {
690.             if ($project->getSoapUsername()) {
691.               $valid = true;
692.             }
693.           }
694.           if (!$valid) {
695.             continue;
696.           }
697.           // send email
698.           if (!filter_var($user->getEmail(), FILTER_VALIDATE_EMAIL)) {
699.               continue;
700.           }
701.           try {
702.               $message->to($user->getEmail());
703.               $message->context([
704.                   'user' => $user
705.               ]);
706.               $this->mailer->send($message);
707.           } catch (ServiceUnavailableHttpException $e) {
708.               // throw new ServiceUnavailableHttpException('sending_email_failed');
709.               // dump($e->getMessage());
710.           }
711.           if(($count%100) == 0) {
712.               sleep(1);
713.           }
714.       }
716.       return new Response('done');
717.   }
718.     
719.   #[Route(path: '/remove_duplicate_areas', name: 'remove_duplicate_aras', methods: ['GET'])]
720.   public function cronRemoveDuplicateAreas(Request $request): Response
721.   {
722.     exit('DISABLED. COMMENT FIRST LINE TO ENABLE.');
723.     $addressId = $request->query->get('address_id');
724.     if (!$addressId) {
725.       return new Response('no address_id provided');
726.     }
727.     $areas = $this->em->getRepository(Area::class)->findBy(['address' => $addressId], []);
728.     if (!count($areas)) {
729.       return new Response('no areas found for address');
730.     }
731.     $areaToSet = $areas[0];
732.     foreach ($areas as $area) {
733.       if ($area->getId() === $areaToSet->getId() || $area->getName() !== $areaToSet->getName()) { // also check if is duplicate by name
734.         continue;
735.       }
736.       $traps = $this->em->getRepository(Trap::class)->findBy(['area' => $area->getId()]);
737.       foreach ($traps as $trap) {
738.           $trap->setArea($areaToSet);
739.           $this->em->persist($trap);
740.       }
741.       $this->em->remove($area);
742.       $trapData = $this->documentManager->getRepository(TrapData::class)->findBy(['area' => $area->getId()]);
743.       foreach ($trapData as $data) {
744.           $data->setArea($areaToSet->getId());
745.           $this->documentManager->persist($data);
746.       }
747.       $this->documentManager->flush();
748.       $this->em->flush();
749.     }
750.     return new Response('done');
751. }
753. #[Route(path: '/remove_duplicate_traps', name: 'remove_duplicate_traps', methods: ['GET'])]
754. public function cronRemoveDuplicateTraps(Request $request): Response
755. {
756.   // Activeren middels $isLive wanneer er nieuwe dubbele lokazen in de DB staan, vooraf controleren of het script werkt.
757.   /////////
758.   $isLive = false;
759.   /////////
760.   $addresses = $this->em->getRepository(Address::class)->findBy([], []);
761.   foreach ($addresses as $address) {
762.     $trapNumbers = [];
763.     $trapsR = $this->em->getRepository(Trap::class)->findBy(['address' => $address->getId()]);
764.     $traps = [];
765.     foreach ($trapsR as $trap) {
766.       if ($trap->getArchivedAt() || $trap->getDeletedAt() || !$trap->getArea()) {
767.         continue;
768.       }
769.       $traps[] = $trap;
770.       $trapNumbers[] = $trap->getIndentificatie() . '_' . ($trap->getArea() ? $trap->getArea()->getId() : '_no_area');
771.     }
772.     $duplicates = array_count_values($trapNumbers);
773.     $duplicates = array_diff($duplicates, [1]); // only keep duplicates
774.     $seenFirst = [];
775.     $withTrapData = [];
776.     foreach ($duplicates as $trapNumber => $n) {
777.       foreach ($traps as $trap) {
778.         if ($trap->getIndentificatie() . '_' . ($trap->getArea() ? $trap->getArea()->getId() : '_no_area') != $trapNumber) {
779.           continue;
780.         }
781.         if (in_array($trap->getIndentificatie() . '_' . ($trap->getArea() ? $trap->getArea()->getId() : '_no_area'), $seenFirst)) {
782.           $trapData = $this->documentManager->getRepository(TrapData::class)->findBy(['trap' => $trap->getId()]);
783.           if (!count($trapData)) {
784.             $this->em->remove($trap);
785.             $groundPlanTrap = $this->em->getRepository(GroundPlanTraps::class)->findOneBy(['trap' => $trap->getId()]);
786.             if ($groundPlanTrap) {
787.               $this->em->remove($groundPlanTrap);
788.             }
789.             echo 'Deleting ID #' . $trap->getId() . ' with indentificatie ' . $trap->getIndentificatie() . ' (' . $trap->getArea()->getName() . ' - ' . $trap->getArea()->getAddress()->getName() .' - ' . $trap->getArea()->getAddress()->getProject()->getName() . ')<br /><br />';
790.           } else {
791.             echo 'Skipping ID #' . $trap->getId() . ' with indentificatie ' . $trap->getIndentificatie() . ' (' . $trap->getArea()->getName() . ' - ' . $trap->getArea()->getAddress()->getName() .' - ' . $trap->getArea()->getAddress()->getProject()->getName() . ') - Has trapData - Trying to set trapData to sibling<br />';
792.             try {
793.               $siblingTraps = $this->em->createQueryBuilder()
794.                 ->from(Trap::class, 't')
795.                 ->select('t')
796.                 ->where('t.number = :number')
797.                 ->andWhere('t.indentificatie = :indentificatie')
798.                 ->andWhere('t.area = :area')
799.                 ->andWhere('t.id <> :id')
800.                 ->andWhere('t.deletedAt IS NULL')
801.                 ->setParameter('number', $trap->getNumber())
802.                 ->setParameter('indentificatie', $trap->getIndentificatie())
803.                 ->setParameter('area', $trap->getArea())
804.                 ->setParameter('id', $trap->getId())
805.                 ->getQuery()
806.                 ->getResult();
807.               if (count($siblingTraps)) {
808.                 foreach ($siblingTraps as $siblingTrap) {
809.                   $siblingTrapData = $this->documentManager->getRepository(TrapData::class)->findOneBy(['trap' => $siblingTrap->getId()]);
810.                   if (!$siblingTrapData) {
811.                     echo '-- Sibling with trap ID #' . $siblingTrap->getId() . ' has no associated trapData, deleting this trap object instead<br />';
812.                     $this->em->remove($siblingTrap);
813.                     $groundPlanTrap = $this->em->getRepository(GroundPlanTraps::class)->findOneBy(['trap' => $siblingTrap->getId()]);
814.                     if ($groundPlanTrap) {
815.                       $this->em->remove($groundPlanTrap);
816.                     }
817.                     echo '-- Deleting ID #' . $siblingTrap->getId() . ' with indentificatie ' . $siblingTrap->getIndentificatie() . ' (' . $siblingTrap->getArea()->getName() . ' - ' . $siblingTrap->getArea()->getAddress()->getName() .' - ' . $siblingTrap->getArea()->getAddress()->getProject()->getName() . ')<br /><br />';
818.                   } else {
819.                     foreach ($trapData as $data) {
820.                       $data->setTrap($siblingTrap->getId());
821.                       $this->documentManager->persist($data);
822.                     }
823.                     if ($isLive) {
824.                       $this->documentManager->flush();
825.                     }
826.                     echo '-- Reset trapData to trap ID #' . $siblingTrap->getId() . '<br />';
827.                     $this->em->remove($trap);
828.                     $groundPlanTrap = $this->em->getRepository(GroundPlanTraps::class)->findOneBy(['trap' => $trap->getId()]);
829.                     if ($groundPlanTrap) {
830.                       $this->em->remove($groundPlanTrap);
831.                     }
832.                     echo '-- Deleting ID #' . $trap->getId() . ' with indentificatie ' . $trap->getIndentificatie() . ' (' . $trap->getArea()->getName() . ' - ' . $trap->getArea()->getAddress()->getName() .' - ' . $trap->getArea()->getAddress()->getProject()->getName() . ')<br /><br />';
833.                   }
834.                 }
835.               } else {
836.                 echo '-- No sibling traps found for indentificatie ' . $trap->getIndentificatie() . ')<br /><br />';
837.               }
838.             } catch (\Exception $e) {
839.               echo '!!-- Error looking for sibling for trap ' . $trap->getId() . ': <i>' . $e->getMessage() . '</i><br /><br />';
840.             }
841.           }
842.           continue;
843.         }
844.         $seenFirst[] = $trap->getIndentificatie() . '_' . ($trap->getArea() ? $trap->getArea()->getId() : '_no_area');
845.       }
846.     }
847.   }
848.   if ($isLive) {
849.     $this->em->flush();
850.   }
851.   return new Response('done');
852. }
854.   #[Route(path: '/lokazen_check')]
855.   public function lokazenCheck(): Response
856.   {
857.       /*
858.       $addressIds = [ 5536, 5539, 5540, 4550, 4551 ];
859.       $queryBuilder = $this->em->createQueryBuilder()
860.         ->from(Trap::class, 't')
861.         ->select('t')
862.         ->where('v.address IN :addressIds')
863.         ->setParameter('addressIds', $addressIds);
864.       $traps = $queryBuilder->getQuery()->getResult();
865.       foreach ($traps as $trap) {
866.         if ($trap->getArea()->getAddress() !== $trap->getAddress()) {
867.           // location exists for the real address?
868.           $area = $this->em->getRepository(Area::class)->findBy(['address' => $trap->getAddress(), 'name' => $trap->getArea()->getName()]);
869.           if ($area) {
870.             $trap->setArea($area);
871.           } else {
872.             $area = new Area();
873.             $area->setAddress($trap->getAddress());
874.             $area->setName($trap->getArea()->getName());
875.             $this->em->persist($area);
876.           }
877.           $trap->setArea($area);
878.           $this->em->persist($trap);
879.           //$this->em->flush();
880.         }
881.       }
882.       */
883.       return new Response('done');
884.   }
886.   #[Route(path: '/csv_import')]
887.   public function csvImport(): Response
888.   {
890.     // TODO: 9-11 LIJKT GEREED VOOR IMPORT HYGIENE
892.       $werkm = 2;
893.       $isLive = false;
894.       $i = 0;
895.       $counter = 0;
896.       $counter2 = 0;
897.       $counter3 = 0;
898.       $trapcats = [];
899.       $errors = [];
900.       $res = $this->em->getRepository(TrapCategory::class)->findAll();
901.       foreach ($res as $v) {
902.           $trapcats[$v->getCode()] = $v;
903.       }
904.       $eckIds = [];
905.       $addresses = $this->em->getRepository(Address::class)->findBy([], []);
906.       foreach ($addresses as $address) {
907.         if ($address->getProject()->getWerkm() === $werkm) {
908.           $eckIds[$address->getEckId()] = $address;
909.           echo $address->getId() . ' - ';
910.         }
911.       }
912.       $areas = [];
913.       $groundPlans = [];
914.       if (($handle = fopen('20231025_Objectenvaneck_H.csv', 'r')) !== false) {
915.           while (($cols = fgetcsv($handle, null, ';')) !== false) {
916.               $cols = array_map('utf8_encode', $cols);
917.               if (0 == $i) {
918.                   foreach ($cols as $k => $v) {
919.                       $lookup[$v] = $k;
920.                   }
921.               }
923.               /*
924.       //
925.               // OBJECT MI LOGIN/PASS UPDATEN
926.       //
927.               if ($i > 0) {
928.                   if ('A' == substr($cols[2], 0, 1)) {
929.                       continue;
930.                   }
931.                   $projectId = $cols[$lookup['Projectkaart']];
932.                   $addressId = $cols[$lookup['Onderdeel']];
933.                   // find or create project
934.                   $project = $this->em->getRepository(Project::class)->findOneBy(['projectId' => $projectId]);
935.                   if (!$project) {
936.                       continue;
937.                   }
938.                   $address = $this->em->getRepository(Address::class)->findOneBy(['project' => $project, 'eckId' => $addressId]);
939.                   if ($address) {
940.                       if ($cols[$lookup['inlog_debiteur']] && $cols[$lookup['ww_debiteur']]) {
941.                           $project = $address->getProject();
942.                           $project->setSoapUsername($cols[$lookup['inlog_debiteur']]);
943.                           $project->setSoapPassword($cols[$lookup['ww_debiteur']]);
944.                           $this->em->persist($project);
945.                       }
946.                       if ($cols[$lookup['inlog']] && $cols[$lookup['ww']]) {
947.                           $address->setSoapUsername($cols[$lookup['inlog']]);
948.                           $address->setSoapPassword($cols[$lookup['ww']]);
949.                           $this->em->persist($address);
950.                       }
951.                   }
952.                   if (0 == $i % 1000) {
953.                       $this->em->flush();
954.                   }
955.                   ++$i;
956.               }
957.               */
959.               /*
960.               //
961.               // OBJECT CONTACT UPDATEN
962.               //
963.               if ($i > 0) {
964.                 if (substr($cols[2], 0, 1) == 'A') {
965.                   continue;
966.                 }
967.                 if ($cols[$lookup['Telecomsoort']] != 'E-mail') {
968.                   continue;
969.                 }
970.                 $projectId = $cols[current($lookup)];
971.                 // find or create project
972.                 $project = $this->em->getRepository(Project::class)->findOneBy(['projectId' => $projectId]);
973.                 if ($project) {
974.                   if ($cols[$lookup['Nummer']] && strpos($cols[$lookup['Nummer']], '@') !== false) {
975.                     $project->setEmail($cols[$lookup['Nummer']]);
976.                   }
977.                   if ($cols[$lookup['E-mail']] && strpos($cols[$lookup['E-mail']], '@') !== false) {
978.                     $project->setEmail($cols[$lookup['E-mail']]);
979.                   }
980.                   $this->em->persist($project);
981.                 }
982.                 if($i % 4000 ==0) {
983.                   $this->em->flush();
984.                 }
985.                 $i++;
986.               }
987.               */
989.       //
990.               // LOKAZEN UIT OUDE DATABASE
991.       //
992.               /*
993.               if ($i > 0) {
994.                 $project = $this->em->getRepository(Project::class)->findBy(['projectId' => $cols[$lookup['project_id']]]);
995.                 if (count($project) == 0) {
996.                   continue;
997.                 } else {
998.                   $project = $project[0];
999.                 }
1000.                 $address = $this->em->getRepository(Address::class)->findBy([ 'project' => $project->getId(), 'eckId' => $cols[$lookup['eck_id']] ]);
1001.                 if (count($address) == 0) {
1002.                   continue;
1003.                 } else {
1004.                   $address = $address[0];
1005.                 }
1006.                 if (array_key_exists($address->getId().$cols[$lookup['name']], $areas)) {
1007.                   $area = $areas[$address->getId().$cols[$lookup['name']]];
1008.                 } else {
1009.                   $area = $this->em->getRepository(Area::class)->findBy([ 'address' => $address->getId(), 'name' => $cols[$lookup['name']] ]);
1010.                   if (count($area) == 0) {
1011.                     $area = new Area();
1012.                     $area->setName($cols[$lookup['name']]);
1013.                     $area->setAddress($address);
1014.                     $this->em->persist($area);
1015.                     $counter3++;
1016.                   } else {
1017.                     $area = $area[0];
1018.                   }
1019.                 }
1020.                 $areas[$address->getId().$cols[$lookup['name']]] = $area;
1022.                 if (array_key_exists($address->getId().$cols[$lookup['name']], $groundPlans)) {
1023.                   $groundPlan = $groundPlans[$address->getId().$cols[$lookup['name']]];
1024.                 } else {
1025.                   $groundPlan = $this->em->getRepository(GroundPlan::class)->findBy([ 'area' => $area->getId() ]);
1026.                   if (count($groundPlan) == 0) {
1027.                     $media = new MediaObject();
1028.                     $media->setUploadTimestamp(new \DateTime());
1029.                     $media->setFileName($area->getName());
1030.                     $uri = str_replace('/uploads', '/media/2021/07', $cols[$lookup['map']]);
1031.                     $media->setUri($uri);
1032.                     $this->em->persist($media);
1033.                     $groundPlan = new GroundPlan();
1034.                     $groundPlan->setImage($media);
1035.                     $groundPlan->setArea($area);
1036.                     $groundPlan->setDate(new \DateTime());
1037.                     $groundPlan->setName($cols[$lookup['name']]);
1038.                     $this->em->persist($groundPlan);
1039.                     $counter2++;
1040.                   } else {
1041.                     $groundPlan = $groundPlan[0];
1042.                     // re-set all media objects to current uri if first batch went wrong due to MediaObjectAddedListener
1043.                     //$uri = str_replace('/uploads', '/media/2021/07', $cols[$lookup['map']]);
1044.                     //$media = $groundPlan->getImage();
1045.                     //if ($media->getUri() !== $uri) {
1046.                       //$media->setUri($uri);
1047.                       //$this->em->persist($media);
1048.                     //}
1049.                   }
1050.                 }
1051.                 $groundPlans[$address->getId().$cols[$lookup['name']]] = $groundPlan;
1053.                 if (!array_key_exists($cols[$lookup['klasse']], $trapcats)) {
1054.                   $trapCat = new TrapCategory();
1055.                   $trapCat->setName($cols[$lookup['klasse']]);
1056.                   $trapCat->setCode($cols[$lookup['klasse']]);
1057.                   $this->em->persist($trapCat);
1058.                   $this->em->flush();
1059.                   $trapCat[$cols[$lookup['klasse']]] = $trapCat->getId();
1060.                 }
1062.                 $trap = $this->em->getRepository(Trap::class)->findBy([ 'indentificatie' => $cols[$lookup['indentificatie']], 'number' => $cols[$lookup['lokaas_id']], 'address' => $address->getId() ]);
1063.                 if (count($trap) == 0) {
1064.                   $trap = new Trap();
1065.                   $trap->setCategory($trapcats[$cols[$lookup['klasse']]]);
1066.                   $trap->setIndentificatie($cols[$lookup['indentificatie']]);
1067.                   $trap->setNumber($cols[$lookup['lokaas_id']]);
1068.                   $trap->setArea($area);
1069.                   $trap->setAddress($address);
1070.                   $trap->setLocation($cols[$lookup['locatie']]);
1071.                   $this->em->persist($trap);
1073.                   $groundPlanTrap = new GroundPlanTraps();
1074.                   $groundPlanTrap->setGroundPlan($groundPlan);
1075.                   $groundPlanTrap->setPosX($cols[$lookup['pos_x']]);
1076.                   $groundPlanTrap->setPosY($cols[$lookup['pos_y']]);
1077.                   $this->em->persist($groundPlanTrap);
1079.                   $groundPlan->addTrap($groundPlanTrap);
1080.                   $trap->addGroundPlan($groundPlanTrap);
1081.                   $counter++;
1082.                 }
1084.                 if($i % 4000 ==0) {
1085.                   $this->em->flush();
1086.                 }
1087.               }
1088.               $i++;
1089.               */
1091.               //
1092.               // OBJECTEN
1093.               //
1094.               if ($i > 0) {
1095.                 if (substr($cols[2], 0, 1) == 'A') {
1096.                   continue;
1097.                 }
1098.                 $projectId = $cols[current($lookup)];
1099.                 // find or create contract
1100.                 $contract = $this->em->getRepository(Contract::class)->findBy(['name' => $cols[$lookup['Naam debiteur']]]);
1101.                 if (count($contract) == 0) {
1102.                   $contract = new Contract();
1103.                   $contract->setCreatedAt(new \DateTime());
1104.                   $contract->setName(htmlentities($cols[$lookup['Naam debiteur']]));
1105.                   $contract->setContractId(intval($cols[$lookup['Debiteurnr.']]));
1106.                   //dump('-------- NEW CONTRACT:');
1107.                   //dump($contract);
1108.                   $this->em->persist($contract);
1109.                   if ($isLive) {
1110.                     $this->em->flush();
1111.                   }
1112.                 } else {
1113.                   $contract = $contract[0];
1114.                   //dump($contract);
1115.                 }
1116.                 // find or create project
1117.                 $project = $this->em->getRepository(Project::class)->findBy(['projectId' => $projectId]);
1118.                 if (count($project) == 0) {
1119.                   $project = new Project();
1120.                   $project->setCreatedAt(new \DateTime());
1121.                   $project->setContract($contract);
1122.                   $project->setProjectId(intval($projectId));
1123.                   if ($cols[$lookup['Naam object']]) {
1124.                     $project->setName(htmlentities($cols[$lookup['Naam object']]));
1125.                   } else {
1126.                     $project->setName($contract->getName());
1127.                   }
1128.                   $project->setEmail($cols[$lookup['Nummer']]);
1129.                   $project->setWerkm($werkm);
1130.                   $project->setStreet(htmlentities(ucfirst(strtolower($cols[$lookup['Adres 1']]))));
1131.                   $project->setHousenumber(intval($cols[$lookup['Huisnr.']]));
1132.                   $project->setPostal(strtoupper($cols[$lookup['Postcode']]));
1133.                   $project->setCity(htmlentities(ucfirst(strtolower($cols[$lookup['Woonplaats']]))));
1134.                   $project->setCountry(strtolower($cols[$lookup['Land']]));
1135.                   //dump('-------- NEW PROJECT:');
1136.                   //dump($project);
1137.                   $this->em->persist($project);
1138.                   if ($isLive) {
1139.                     $this->em->flush();
1140.                   }
1141.                 } else {
1142.                   $project = $project[0];
1143.                   //dump($project);
1144.                 }
1145.                 if (array_key_exists(intval($cols[1]), $eckIds)) {
1146.                   $address = $eckIds[intval($cols[1])];
1147.                   if ($address->getId()) {
1148.                     echo $address->getId() . ': ' . $address->getStreet() . ' ' . $address->getHousenumber() . '<br />';
1149.                   }
1150.                   //dump(intval($cols[1]));
1151.                   //dump($address);
1152.                 } else {
1153.                   // create address
1154.                   $address = new Address();
1155.                   $address->setCreatedAt(new \DateTime());
1156.                   $address->setName(htmlentities($cols[$lookup['Omschrijving']]));
1157.                   $address->setProject($project);
1158.                   $address->setEckId(intval($cols[1]));
1159.                   $address->setContract(strtoupper(preg_replace('/[0-9]+/', '', $cols[2])));
1160.                   if ($cols[$lookup['Adres 2']] && strlen((string) $cols[$lookup['Adres 2']] > 0)) {
1161.                     $address->setStreet(ucfirst(htmlentities(strtolower($cols[$lookup['Adres 2']]))));
1162.                   } else {
1163.                     $address->setStreet(ucfirst(htmlentities(strtolower($cols[$lookup['Adres 1']]))));
1164.                   }
1165.                   $address->setHousenumber(intval($cols[$lookup['Huisnr.']]));
1166.                   $address->setPostal(strtoupper($cols[$lookup['Postcode']]));
1167.                   $address->setCity(htmlentities(ucfirst(strtolower($cols[$lookup['Woonplaats']]))));
1168.                   $address->setCountry(substr(strtolower($cols[$lookup['Land']]), 0, 2));
1169.                   $address->setShowTrapAlert(false);
1170.                   $address->setShowMap(false);
1171.                   $address->setEmail(strtolower(trim($cols[$lookup['E-mail']])));
1172.                   //dump('-------- NEW ADDRESS:');
1173.                   //dump($address);
1174.                   $this->em->persist($address);
1175.                   $eckIds[intval($cols[1])] = $address;
1176.                   echo 'NIEUW' . ': ' . $address->getStreet() . ' ' . $address->getHousenumber() . '<br />';
1177.                 }
1178.                 // find or create user
1179.                 if (strtolower(trim($cols[$lookup['E-mail']]))) {
1180.                   $user = $this->em->getRepository(User::class)->findBy(['email' => strtolower(trim($cols[$lookup['E-mail']]))]);
1181.                   if (count($user) == 0) {
1182.                     $user = new User();
1183.                     $user->setCreatedAt(new \DateTime());
1184.                     $user->setEmail(strtolower(trim($cols[$lookup['E-mail']])));
1185.                     $user->setPassword(
1186.                       $this->userPasswordHasher->hashPassword($user, 'Eck123')
1187.                     );
1188.                     $user->setLocale(substr(strtolower(trim($cols[$lookup['Land']])), 0, 2));
1189.                     $user->setRoles(['ROLE_CUSTOMER']);
1190.                     $person = new Person();
1191.                     if (strpos(strtolower(htmlentities($cols[$lookup['Contactpersoon']])), 'dhr') !== false) {
1192.                       $person->setGender('m');
1193.                     }
1194.                     if (strpos(strtolower(htmlentities($cols[$lookup['Contactpersoon']])), 'mw') !== false || strpos(strtolower(htmlentities($cols[$lookup['Contactpersoon']])), 'mevr') !== false) {
1195.                       $person->setGender('f');
1196.                     }
1197.                     $name = htmlentities($cols[$lookup['Contactpersoon']]);
1198.                     $name = str_replace('Dhr', '', $name);
1199.                     $name = str_replace('Dhr ', '', $name);
1200.                     $name = str_replace('Dhr.', '', $name);
1201.                     $name = str_replace('Mw', '', $name);
1202.                     $name = str_replace('Mw ', '', $name);
1203.                     $name = str_replace('Mw.', '', $name);
1204.                     $name = explode(' ', $name, 2);
1205.                     $person->setFirstname($name[0]);
1206.                     if (array_key_exists(1, $name)) {
1207.                       $person->setLastname($name[1]);
1208.                     }
1209.                     $person->setPhone($cols[$lookup['Telefoon']]);
1210.                     $person->setEmail(strtolower(trim($cols[$lookup['E-mail']])));
1211.                     $this->em->persist($person);
1212.                     $user->setPerson($person);
1213.                     //dump('-------- NEW USER:');
1214.                     //dump($user);
1215.                     $this->em->persist($user);
1216.                     if ($isLive) {
1217.                       $this->em->flush();
1218.                     }
1219.                   } else {
1220.                     $user = $user[0];
1221.                     //dump($user->getId());
1222.                   }
1223.                   $projectAdded = false;
1224.                   foreach ($user->getProjects() as $project) {
1225.                     if ($project->getId() === $address->getProject()->getId()) {
1226.                       $projectAdded = true;
1227.                     }
1228.                   }
1229.                   if (!$projectAdded) {
1230.                     $user->addProject($project);
1231.                     if ($isLive) {
1232.                       $this->em->flush();
1233.                     }
1234.                   }
1235.                   $user->addAddress($address);
1236.                   $this->em->persist($user);
1237.                 }
1238.               }
1239.               if($i % 1000 == 0) {
1240.                 if ($isLive) {
1241.                   $this->em->flush();
1242.                 }
1243.               }
1244.               $i++;
1246.               /*
1247.               //
1248.               // SOAP USERNAME + PASSWORDS
1249.               //
1250.               if ($i > 0) {
1251.                 $projectId = $cols[0];
1252.                 $eckId = $cols[9];
1253.                 $pUser = $cols[5];
1254.                 $pPass = $cols[6];
1255.                 $aUser = $cols[7];
1256.                 $aPass = $cols[8];
1258.                 $project = [];
1259.                 $address = [];
1261.                 $project = $this->em->getRepository(Project::class)->findBy(['projectId' => $projectId]);
1262.                 if (count($project) == 0) {
1263.                   continue;
1264.                 }
1265.                 $project = $project[0];
1266.                 if ($pUser && $pPass) {
1267.                   $project->setSoapUsername($pUser);
1268.                   $project->setSoapPassword($pPass);
1269.                   $this->em->persist($project);
1270.                   $this->em->flush();
1271.                 }
1272.                 if ($aUser && $aPass) {
1273.                   $address = $this->em->getRepository(Address::class)->findBy(['project' => $project->getId(), 'eckId' => $eckId ]);
1274.                   if (count($address) == 0) {
1275.                     continue;
1276.                   }
1277.                   $address = $address[0];
1278.                   $address->setSoapUsername($aUser);
1279.                   $address->setSoapPassword($aPass);
1280.                   $this->em->persist($address);
1281.                   $this->em->flush();
1282.                 }
1283.               }
1284.               if($i % 400 ==0) {
1285.                 $this->em->flush();
1286.               }
1287.               $i++;
1288.               */
1290.               /*
1291.               //
1292.               // ACTIES
1293.               //
1294.               if ($i > 0) {
1295.                 try {
1296.                   $projectId = $cols[0];
1297.                   $eckId = $cols[1];
1298.                   $projects = $this->em->getRepository(Project::class)->findBy(['projectId' => $projectId]);
1299.                   if (count($projects) == 0) {
1300.                     array_push($errors, 'Project not found: '.$projectId.' on row '.$i);
1301.                     continue;
1302.                   }
1303.                   $project = $projects[0];
1304.                   $addresses = $this->em->getRepository(Address::class)->findBy(['project' => $project->getId(), 'eckId' => $eckId ]);
1305.                   if (count($addresses) == 0) {
1306.                     array_push($errors, 'Address not found: '.$eckId.', for project: '.$project->getName().' on row '.$i);
1307.                     continue;
1308.                   }
1309.                   $address = $addresses[0];
1310.                   $a = new Action();
1311.                   $createdAt = new \DateTime('now');
1312.                   try {
1313.                     $createdAt = new \DateTime($cols[3]);
1314.                   } catch(\Exception $e){}
1315.                   try {
1316.                     $a->setCreatedAt($createdAt);
1317.                   } catch(\Exception $e){}
1318.                   $a->setAddress($address);
1319.                   $areaCustom = $cols[11];
1320.                   $area = $this->em->getRepository(Area::class)->findBy(['name' => $areaCustom, 'address' => $address->getId() ]);
1321.                   if (count($area) > 0) {
1322.                     $a->setArea($area[0]);
1323.                   } else {
1324.                     $a->setAreaCustom(htmlspecialchars($areaCustom));
1325.                   }
1326.                   $a->setTitle(htmlspecialchars(strlen($cols[5]) > 50 ? substr($cols[5],0,50)."..." : $cols[5]));
1327.                   $closedAt = null;
1328.                   try {
1329.                     $closedAt = new \DateTime($cols[8]);
1330.                   } catch(\Exception $e){}
1331.                   try {
1332.                     $a->setClosedAt($cols[7] == 'True' ? $closedAt : null);
1333.                   } catch(\Exception $e){}
1334.                   $a->setDescription(htmlspecialchars($cols[5]));
1335.                   $a->setMiRegel($cols[2]);
1336.                   $a->setPriority('low');
1337.                   $a->setStatus($cols[7] == 'True' ? 'afgemeld' : 'open');
1338.                   $a->setType('actie');
1339.                   switch ($cols[6]) {
1340.                     case 'L':
1341.                       $a->setOwner('Van Eck');
1342.                       break;
1343.                     case 'D':
1344.                       $a->setOwner('Derde');
1345.                       break;
1346.                     case 'K':
1347.                       $a->setOwner('Klant');
1348.                       break;
1349.                   }
1350.                   $this->em->persist($a);
1351.                   //$this->em->flush();
1352.               } catch(\Exception $e) {
1353.                   array_push($errors, $e);
1354.                 }
1355.               }
1356.               if($i % 2000 ==0) {
1357.                 $this->em->flush();
1358.               }
1359.               */
1361.               /*
1362.               //
1363.               // USERS
1364.               //
1365.               if ($i > 0) {
1366.                 $person = new Person();
1367.                 $person->setFirstname($cols[$lookup['firstname']]);
1368.                 $person->setLastname($cols[$lookup['lastname']]);
1369.                 $person->setHoursWeek($cols[$lookup['uren_week']] ? $cols[$lookup['uren_week']] : null);
1370.                 $person->setHoursDay($cols[$lookup['uren_day']] ? $cols[$lookup['uren_day']] : null);
1371.                 $this->em->persist($person);
1372.                 $user = new User();
1373.                 $user->setPerson($person);
1374.                 $user->setEmail($cols[$lookup['email']]);
1375.                 $user->setPassword(
1376.                   $this->userPasswordHasher->hashPassword($user, 'Eck173!')
1377.                 );
1378.                 $user->setLocale('nl');
1379.                 $user->setRoles(['ROLE_EMPLOYEE']);
1380.                 $this->em->persist($user);
1381.               }
1382.               if($i % 2000 ==0) {
1383.                 $this->em->flush();
1384.               }
1385.               */
1387.               /*
1388.               //
1389.               // TIMESHEETS
1390.               //
1391.               if ($i > 0) {
1392.                 $user = $this->em->getRepository(User::class)->findBy(['email' => $cols[$lookup['email']]]);
1393.                 if (count($user) == 0) {
1394.                   continue;
1395.                 }
1396.                 $existing = $this->em->getRepository(Timesheet::class)->findBy(['start' => new \DateTime($cols[$lookup['start']]), 'end' => new \DateTime($cols[$lookup['end']]), 'user' => $user[0]->getId()]);
1397.                 if ($existing) {
1398.                   continue;
1399.                 }
1400.                 $timesheet = new Timesheet();
1401.                 $timesheet->setUser($user[0]);
1402.                 $timesheet->setDescription($cols[$lookup['description']]);
1403.                 $timesheet->setStart(new \DateTime($cols[$lookup['start']]));
1404.                 $timesheet->setEnd(new \DateTime($cols[$lookup['end']]));
1405.                 $timesheet->setTotalHours($cols[$lookup['total_hours']]);
1406.                 $timesheet->setTotalMinutes($cols[$lookup['total_minutes']]);
1407.                 $timesheet->setLocation($cols[$lookup['location']]);
1408.                 $timesheet->setStatus($cols[$lookup['status']]);
1409.                 $timesheet->setOvernachting($cols[$lookup['overnachting']] ? $cols[$lookup['overnachting']] : null);
1410.                 $timesheet->setBedrijfsauto($cols[$lookup['bedrijfsauto']] ? $cols[$lookup['bedrijfsauto']] : null);
1411.                 $timesheet->setBreak($cols[$lookup['break']] ? $cols[$lookup['break']] : null);
1412.                 $timesheet->setCreatedAt(new \DateTime($cols[$lookup['created_at']]));
1413.                 $timesheet->setType($cols[$lookup['type']]);
1414.                 $this->em->persist($timesheet);
1415.               }
1416.               if($i % 500 ==0) {
1417.                 $this->em->flush();
1418.               }
1419.               */
1421.               ++$i;
1422.           }
1424.           //dump($errors);
1425.       }
1427.       // dump($areas);
1428.       // dump($groundPlans);
1430.       // dump($counter);
1431.       // dump($counter2);
1432.       // dump($counter3);
1433.       if ($isLive) {
1434.         $this->em->flush();
1435.       }
1436.       fclose($handle);
1438.       return new Response('done');
1439.   }
1441.   #[Route(path: '/fetch_media', name: 'fetch_media')]
1442.   public function fetchMedia(Request $request, KernelInterface $kernel): Response
1443.   {
1444.       $data = json_decode($request->getContent(), true);
1445.       if (!$data || ($data && !$data['contentUrl'])) {
1446.           $data['contentUrl'] = $request->query->get('contentUrl');
1447.           if (!$data) {
1448.               throw new HttpException(404, 'no contentUrl parameter was received');
1449.           }
1450.       }
1451.       $rootDir = $kernel->getProjectDir();
1452.       $file = $rootDir.'/public'.$data['contentUrl'];
1453.       if (!file_exists($file)) {
1454.           throw new HttpException(404, 'requested file url not found on server');
1455.       }
1457.       return new BinaryFileResponse($file);
1458.   }
1460.   #[Route(path: '/fetch_visit_rapport', name: 'fetch_visit_rapport')]
1461.   public function fetchVisitRapport(Request $request)
1462.   {
1463.       $data = json_decode($request->getContent(), true);
1464.       if (!$data || ($data && (!$data['address'] || !$data['storing']))) {
1465.           $data['address'] = $request->query->get('address');
1466.           $data['storing'] = $request->query->get('storing');
1467.           if (!$data || ($data && (!$data['address'] || !$data['storing']))) {
1468.               throw new HttpException(404, 'no address or storing parameter was received');
1469.           }
1470.       }
1471.       $address = $this->em->getRepository(Address::class)->findOneBy(['uuid' => $data['address']]);
1472.       $method = 'GetServiceRapport';
1473.       $werkm = $address->getProject()->getWerkm() ? $address->getProject()->getWerkm() : 0;
1474.       $operationBody = [
1475.           'Werkm' => $werkm,
1476.           'Storing' => $data['storing'],
1477.       ];
1478.       $result = $this->soap->callSoap($method, $operationBody, $werkm);
1479.       if (!$result->Result) {
1480.           throw new HttpException(404, 'requested file url not found on server');
1481.       }
1483.       return new Response($result->Rapport);
1484.   }
1486.   #[Route(path: '/fetch_document_bestand', name: 'fetch_document_bestand')]
1487.   public function fetchDocument(Request $request)
1488.   {
1489.       $data = json_decode($request->getContent(), true);
1490.       if (!$data || ($data && (!$data['address'] || !$data['type']))) {
1491.           $data['address'] = $request->query->get('address');
1492.           $data['type'] = $request->query->get('type');
1493.           $data['artikelnummer'] = $request->query->get('artikelnummer');
1494.           $data['bestandnaam'] = $request->query->get('bestandnaam');
1495.           $data['onderdeel'] = $request->query->get('onderdeel');
1496.           $data['werknemer'] = $request->query->get('werknemer');
1497.           if (!$data || ($data && (!$data['address'] || !$data['type']))) {
1498.               throw new HttpException(404, 'no type parameter was received');
1499.           }
1500.       }
1501.       $method = $data['type'];
1502.       $address = $this->em->getRepository(Address::class)->findOneBy(['uuid' => $data['address']]);
1503.       $werkm = $address->getProject()->getWerkm() ? $address->getProject()->getWerkm() : 0;
1504.       switch ($data['type']) {
1505.           case 'GetBestandenProduct':
1506.               $operationBody = [
1507.                 'Werkm' => $werkm,
1508.                 'Artikelnummer' => $data['artikelnummer'],
1509.                 'Bestanden' => '[]',
1510.               ];
1511.               $result = $this->soap->callSoap($method, $operationBody, $werkm);
1512.               $res = [];
1513.               if ($result->Bestanden && property_exists($result->Bestanden, 'string')) {
1514.                   $res = (array) $result->Bestanden->string;
1515.               }
1517.               return new Response(json_encode($res));
1518.               break;
1519.           case 'GetBestandProduct':
1520.               $operationBody = [
1521.                 'Werkm' => $werkm,
1522.                 'Artikelnummer' => $data['artikelnummer'],
1523.                 'Bestandnaam' => $data['bestandnaam'],
1524.                 'Bestand' => '[]',
1525.               ];
1526.               $result = $this->soap->callSoap($method, $operationBody, $werkm);
1528.               return new Response($result->Bestand);
1529.               break;
1530.           case 'GetBestandenWerknemer':
1531.               $operationBody = [
1532.                 'Werkm' => $werkm,
1533.                 'Werknemer' => $data['werknemer'],
1534.                 'Bestanden' => '[]',
1535.               ];
1536.               $result = $this->soap->callSoap($method, $operationBody, $werkm);
1537.               $res = [];
1538.               if ($result->Bestanden && property_exists($result->Bestanden, 'string')) {
1539.                   $res = (array) $result->Bestanden->string;
1540.               }
1542.               return new Response(json_encode($res));
1543.               break;
1544.           case 'GetBestandWerknemer':
1545.               $operationBody = [
1546.                 'Werkm' => $werkm,
1547.                 'Werknemer' => $data['werknemer'],
1548.                 'Bestandnaam' => $data['bestandnaam'],
1549.                 'Bestand' => '[]',
1550.               ];
1551.               $result = $this->soap->callSoap($method, $operationBody, $werkm);
1553.               return new Response($result->Bestand);
1554.               break;
1555.           case 'GetBestandKlant':
1556.               $eckIds = $address->getEckIds();
1557.               foreach ($eckIds as $eckId) {
1558.                   $operationBody = [
1559.                     'Werkm' => $werkm,
1560.                     'Project' => $address->getProject()->getProjectId(),
1561.                     'ID' => $eckId,
1562.                     'Bestandnaam' => $data['bestandnaam'],
1563.                     'Bestand' => '[]',
1564.                   ];
1565.                   $result = $this->soap->callSoap($method, $operationBody, $werkm);
1566.                   if (property_exists($result, 'Bestand')) {
1567.                       return new Response($result->Bestand);
1568.                   }
1569.               }
1570.               break;
1571.       }
1572.   }
1573. }