src/Service/ContactsBaseService.php line 124

Open in your IDE?
  1. <?php
  3. namespace App\Service;
  5. use App\Entity\ContactsBase\ContactsBase;
  6. use App\Repository\ContactsBase\ContactsBaseRepository;
  7. use App\Repository\ContactsBaseList\ContactsBaseListRepository;
  8. use Symfony\Component\HttpFoundation\RequestStack;
  10. class ContactsBaseService
  11. {
  12.     private ValidationService $validation;
  13.     private ContactsBaseRepository $repository;
  14.     private RequestStack $request;
  15.     public ContactsBaseListRepository $list;
  17.     public function __construct(ValidationService $validationService, ContactsBaseListRepository $contactsBaseListRepository, ContactsBaseRepository $contactsBaseRepository, RequestStack $requestStack)
  18.     {
  19.         $this->validation = $validationService;
  20.         $this->request = $requestStack;
  21.         $this->repository = $contactsBaseRepository;
  22.         $this->list = $contactsBaseListRepository;
  23.     }
  25.     public function getImportedContactsByFile($file): array
  26.     {
  27.         // funkcja przetwarza plik csv zawierający kontakty i wywołuje funkcję dzielącą kontakty na kolumny
  28.         $importedEmailsArray = [];
  29.         // $typ = explode('.', strtolower($file['name']));
  31.         // weryfikacji poprawności typu pliku
  32.         // if ('csv' == htmlspecialchars($typ[count($typ) - 1])) {
  33.         // odczyt pliku
  34.         // $file = fopen($file['tmp_name'], 'r');
  35.         $file = fopen($file, 'r');
  37.         while (!feof($file)) {
  38.             $row = fgets($file);
  39.             $row = strip_tags($row);
  40.             if ('' != $row) {
  41.                 $wypisz = explode(';', $row);
  42.                 $contactArray = [];
  43.                 // sanityzacja przesłanej wartości
  44.                 foreach ($wypisz as $item) {
  45.                     $contactArray[] = mb_convert_encoding($this->validation->sanitizeString($item), "UTF-8");
  46.                 }
  47.                 $importedEmailsArray[] = $contactArray;
  48.             }
  49.         }
  50.         // $this->analyzingImportedContacts($importedEmailsArray);
  51.         // }
  52.         return $importedEmailsArray;
  53.     }
  55.     public function getImportedContactsByPasteFromExcel($contacts): array
  56.     {
  57.         // funkcja przetwarza dane wklejone z excela i wysłane za pomocą textarea zawierające
  58.         // kontakty i wywołuje funkcję dzielącą kontakty na kolumny
  59.         $importedEmailsArray = [];
  61.         // obsługa wysyłki textarea
  62.         $sendData = trim($contacts);
  63.         $sendData = explode("\n", $sendData);
  64.         $sendData = array_filter($sendData, 'trim');
  66.         foreach ($sendData as $line) {
  67.             $email = explode('    ', $line);
  68.             $contactArray = [];
  69.             // sanityzacja przesłanej wartości
  70.             foreach ($email as $item) {
  71.                 $contactArray[] = $this->validation->sanitizeString($item);
  72.             }
  73.             if (count($contactArray) > 0) {
  74.                 $importedEmailsArray[] = $contactArray;
  75.             }
  76.         }
  77.         // $this->analyzingImportedContacts($importedEmailsArray);
  78.         return $importedEmailsArray;
  79.     }
  81.     public function analyzingImportedContacts($importedEmailsArray): array
  82.     {
  83.         // funkcja przetwarza tablicę kontaktów rozdzielonych na kolumny i określa liczbę kolumn
  84.         // oraz maksymalną liczbę wierszy do wyświetlenia podczas przypisywania nazw kolumn
  86.         // określam ilość kolumn
  87.         $parameters['columns'] = $columnNumber = max(array_map('count', $importedEmailsArray));
  89.         // ustalam liczbę wyświetlanych pozycji
  90.         $maxResults = 3;
  91.         if (count($importedEmailsArray) < 3) {
  92.             $maxResults = count($importedEmailsArray);
  93.         }
  94.         $parameters['rows'] = $maxResults;
  96.         return $parameters;
  97.     }
  99.     public function takeContactFieldsNames(): array
  100.     {
  101.         $fields['email'] = 'Adres e-mail';
  102.         $fields['phone'] = 'Numer telefonu';
  103.         $fields['name'] = 'Imię';
  104.         $fields['lastName'] = 'Nazwisko';
  105.         $fields['company'] = 'Nazwa firmy';
  106.         $fields['country'] = 'Kraj';
  108.         return $fields;
  109.     }
  111.     public function saveContacts($sendingData, $group, $list)
  112.     {
  113.         $contacts = json_decode($sendingData['contacts']);
  114.         // $contacts = json_decode($sendingData);
  115.         // rozpoczynamy zapis do bazy
  117.         foreach ($contacts as $item) {
  118.             $contact = new ContactsBase();
  119.             $contact->setUserGroup($group);
  120.             $contact->setList($list);
  121.             $contact->setDateAdd(new \DateTime());
  122.             // $contact->setStatus(1);
  123.             for ($i = 0; $i < $sendingData['columns']; ++$i) {
  124.                 $name = $sendingData['column-'.$i + 1];
  125.                 if (0 != $name && '' != $name) {
  126.                     $value = $this->validation->sanitizeString($item[$i]);
  127.                     $contact->{'set'.ucwords($name)}($value);
  128.                 }
  129.             }
  130.             $this->repository->add($contact, true);
  131.         }
  132.     }
  133. }