src/Services/FournisseurService.php line 111

Open in your IDE?
  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  */
  6. namespace App\Services;
  10. use App\Entity\AvoirFactureFinance;
  11. use App\Entity\DocUpload;
  12. use App\Entity\Etap1;
  13. use App\Entity\Etap160;
  14. use App\Entity\Etap2;
  15. use App\Entity\Etap3;
  16. use App\Entity\Etap4;
  17. use App\Entity\Etap5;
  18. use App\Entity\Etap6;
  19. use App\Entity\Etap7;
  20. use App\Entity\Etap8;
  21. use App\Entity\Etap9;
  22. use App\Entity\Etap10;
  23. use App\Entity\Etap11;
  24. use App\Entity\Etap12;
  25. use App\Entity\Etap13;
  26. use App\Entity\Etap14;
  27. use App\Entity\Etap15;
  28. use App\Entity\Etap16;
  29. use App\Entity\Etap17;
  30. use App\Entity\Etap18;
  31. use App\Entity\Etap19;
  32. use App\Entity\Etap20;
  33. use App\Entity\Etap21;
  34. use App\Entity\Etap22;
  35. use App\Entity\Etaps;
  36. use App\Entity\EtapsCategory;
  37. use App\Entity\FactureFinance;
  38. use App\Entity\Avoir;
  39. use App\Entity\Fournisseur;
  40. use App\Entity\FournisseurProject;
  41. use App\Entity\Project;
  42. use App\Entity\ProjectEdit;
  43. use App\Entity\ProjectFactureFinance;
  44. use App\Entity\Rib;
  45. use App\Entity\Spv;
  46. use App\Entity\User;
  47. use App\Form\AvoirType;
  48. use App\Form\FactureFinanceType;
  49. use App\Form\ProjectEditType;
  50. use App\Form\ProjectType;
  51. use App\Form\UserType;
  53. use Kunnu\Dropbox\Dropbox;
  54. use Kunnu\Dropbox\DropboxApp;
  55. use Kunnu\Dropbox\Exceptions\DropboxClientException;
  56. use PhpOffice\PhpSpreadsheet\Shared\Date;
  57. use PhpOffice\PhpSpreadsheet\Spreadsheet;
  58. use PhpOffice\PhpSpreadsheet\Style\Border;
  59. use PhpOffice\PhpSpreadsheet\Style\Color;
  60. use PhpOffice\PhpSpreadsheet\Style\Fill;
  61. use PhpOffice\PhpSpreadsheet\Style\NumberFormat;
  62. use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
  63. use Spipu\Html2Pdf\Html2Pdf;
  64. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  65. use Doctrine\ORM\EntityManagerInterface;
  66. use Symfony\Component\Form\FormFactoryInterface;
  67. use Symfony\Component\HttpFoundation\File\UploadedFile;
  68. use Symfony\Component\HttpFoundation\Session\Flash\FlashBagInterface;
  69. use Symfony\Component\Routing\RouterInterface;
  70. use Symfony\Component\Security\Core\Encoder\UserPasswordEncoderInterface;
  71. use Symfony\Contracts\Translation\TranslatorInterface;
  72. use Symfony\Component\Security\Core\Security;
  73. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  74. use Twig\Environment;
  75. use App\Entity\Centrale;
  76. use Symfony\Component\Validator\Constraints as Assert;
  77. use Symfony\Component\Validator\Validator\ValidatorInterface;
  79. class FournisseurService
  80. {
  82.     private $em;
  83.     private $trans;
  84.     private $params;
  85.     private $security;
  86.     private $session;
  87.     private $twig;
  88.     private $notification;
  90.     public function __construct(
  91.         Environment $twig,
  92.         SessionInterface $session,
  93.         Security $security,
  94.         ParameterBagInterface $params,
  95.         EntityManagerInterface $em,
  96.         TranslatorInterface $trans,
  97.         ValidatorInterface $validator,
  98.         FlashBagInterface $flashBag,
  99.         UserPasswordEncoderInterface $passwordEncoder,
  100.         Notifications $notifications,
  101.         FormFactoryInterface $form,
  102.         RouterInterface $router
  103.     ) {
  104.         $this->em = $em;
  105.         $this->trans = $trans;
  106.         $this->params = $params;
  107.         $this->security = $security;
  108.         $this->session = $session;
  109.         $this->twig = $twig;
  110.         $this->validator = $validator;
  111.         $this->form = $form;
  112.         $this->flashBag = $flashBag;
  113.         $this->passwordEncoder = $passwordEncoder;
  114.         $this->notification = $notifications;
  115.         $this->router = $router;
  116.     }
  118.     public function importAuto(){
  119.         $path = '/altarea/fournisseurs';
  120.         $ftp_server="162.19.120.192";
  121.         $ftp_user_name="altarea-prod";
  122.         $ftp_user_pass="E_AeX_red2xi2vf1";
  124.         $dateJour = new \DateTime('now', new \DateTimeZone('Europe/Paris'));
  125.         $dateJour->modify('-3 days');
  127.         $conn_id = ftp_ssl_connect($ftp_server);
  128.         $login_result = ftp_login($conn_id, $ftp_user_name, $ftp_user_pass);
  129.         ftp_pasv($conn_id, true) or die("Cannot switch to passive mode");
  130.         $contents = ftp_mlsd($conn_id, $path);
  131.         $results = array();
  132.         foreach ($contents as $content) {
  133.             if((int)($dateJour->format('Ymd').'000000') < (int)$content['modify']){
  134.                 $results[] = array('name' => $content['name'], 'timestamp' => $content['modify']);
  135.             }
  136.         }
  137.         usort($results, function($a, $b) { return $a['timestamp'] - $b['timestamp']; });
  138.         $file = null;
  139.         $files = [];
  140.         ftp_close($conn_id);
  141.         if($results) {
  142.             foreach ($results as $result) {
  143.                 $conn_id = ftp_ssl_connect($ftp_server);
  144.                 $login_result = ftp_login($conn_id, $ftp_user_name, $ftp_user_pass);
  145.                 ftp_pasv($conn_id, true) or die("Cannot switch to passive mode");
  146.                 $name = $result['name'];
  147.                 $namePos = strpos($name, 'ERPI-');
  148.                 if ($namePos !== false) {
  149.                     if (ftp_get($conn_id, $this->params->get('fournisseur_altarea_import_directory') . "/" . $name, $path . '/' . $name, FTP_BINARY)) {
  150.                         $file = $this->params->get('fournisseur_altarea_import_directory') . "/" . $name;
  151.                         $files[]=$file;
  152.                     } else {
  153.                         return false;
  154.                     }
  155.                 }
  156.                 ftp_close($conn_id);
  157.             }
  158.         }
  159.         if($files){
  160.             foreach ($files as $item){
  161.                 if($item && file_exists($item)){
  162.                     $array = [];
  163.                     $flag = true;
  164.                     $i = 0;
  165.                     $header = [];
  166.                     $fichier = file($item);
  167.                     foreach ($fichier as $line_num => $line) {
  168. //               if($line_num == 0 ){
  169. //                   continue;
  170. //               }
  171.                         $colonnes = explode('|',$line);
  172.                         if($flag) {
  173.                             $header = [];
  174.                             foreach ($colonnes as $key1 => $cell) {
  175.                                 $header[] = trim($cell);
  176.                             }
  177.                             $flag = false;
  178.                             continue;
  179.                         }
  180.                         foreach ($colonnes as $key => $cell) {
  181.                             $array[$i][$header[$key]] = trim(htmlspecialchars($cell));
  182.                         }
  183.                         $i++ ;
  184.                     }
  185.                     if($array){
  186.                         foreach ($array as $item){
  187.                             $fournisseur = null;
  188.                             $isModif = true;
  189.                             if(isset($item['CodeFournisseur']) && $item['CodeFournisseur']){
  190.                                 $fournisseurs = $this->em->getRepository(Fournisseur::class)->findNotArchiveByCode($item['CodeFournisseur']);
  191.                                 if(!$fournisseurs){
  192.                                     if(isset($item['Adresse messagerie 1']) && $item['Adresse messagerie 1']){
  193.                                         $fournisseurs = $this->em->getRepository(Fournisseur::class)->findBy(['email'=>$item['Adresse messagerie 1']]);
  194.                                     }
  195.                                 }
  196.                             }
  197.                             if($fournisseurs) {
  198.                                 foreach ($fournisseurs as $fournisseur) {
  199.                                     $this->updateOrAddFournissuerByFichier($item, $fournisseur);
  200.                                 }
  201.                             }else{
  202.                                 $fournisseur = new Fournisseur();
  203.                                 $isModif = false;
  204.                                 $this->updateOrAddFournissuerByFichier($item, $fournisseur);
  205.                             }
  206.                         }
  207.                     }
  209.                 }
  210.             }
  211.         }
  212.     }
  213.    private function updateOrAddFournissuerByFichier($item,$fournisseur){
  214.        if($fournisseur->getName()){
  216.        }else{
  217.            if(isset($item['Raison sociale']) && $item['Raison sociale']){$fournisseur->setName($item['Raison sociale']);}
  218.        }
  219.        if(isset($item['CodeFournisseur']) && $item['CodeFournisseur']){$fournisseur->setCodeFournisseur($item['CodeFournisseur']);}
  220.        if(isset($item['Adresse messagerie 1']) && $item['Adresse messagerie 1']){$fournisseur->setEmail($item['Adresse messagerie 1']);}
  221.        if(isset($item['Code pays ISO']) && $item['Code pays ISO']){$fournisseur->setCountryCode($item['Code pays ISO']);}
  222.        if(isset($item['Code postal']) && $item['Code postal']){$fournisseur->setCodePostal($item['Code postal']);}
  223.        if(isset($item['Ville']) && $item['Ville']){$fournisseur->setCity($item['Ville']);}
  224.        if(isset($item['Rue ou voie']) && $item['Rue ou voie']){$fournisseur->setRueVoie($item['Rue ou voie']);}
  226.        if(isset($item['Téléphone 1']) && $item['Téléphone 1']){$fournisseur->setTel($item['Téléphone 1']);}
  227.        if(isset($item['Complément Siret']) && $item['Complément Siret']){$fournisseur->setComplementSiret($item['Complément Siret']);}
  228.        if(isset($item['Boite postale ou Commune']) && $item['Boite postale ou Commune']){$fournisseur->setBoitePostaleCommune($item['Boite postale ou Commune']);}
  229.        if(isset($item['CodeBlocage']) && $item['CodeBlocage']){
  230.            $fournisseur->setCodeBlocage($item['CodeBlocage']);
  231.        }
  232.        if(isset($item['Code NAF (APE)']) && $item['Code NAF (APE)']){$fournisseur->setCodeNaf($item['Code NAF (APE)']);}
  233.        if(isset($item["Complément d'adresse"]) && $item["Complément d'adresse"]){$fournisseur->setComplementAdresse($item["Complément d'adresse"]);}
  234.        if(isset($item['Complément Identification']) && $item['Complément Identification']){$fournisseur->setComplementIdenetification($item['Complément Identification']);}
  235.        if(isset($item['Devise']) && $item['Devise']){$fournisseur->setDevise($item['Devise']);}
  236.        if(isset($item['Forme juridique']) && $item['Forme juridique']){$fournisseur->setFormuleJuridique($item['Forme juridique']);}
  237.        if(isset($item['Inscription au RCS ou RM']) && $item['Inscription au RCS ou RM']){$fournisseur->setRcsRm($item['Inscription au RCS ou RM']);}
  238.        if(isset($item['Téléphone 2']) && $item['Téléphone 2']){$fournisseur->setTel2($item['Téléphone 2']);}
  239.        if(isset($item['Télécopie']) && $item['Télécopie']){$fournisseur->setTelecopie($item['Télécopie']);}
  240.        if(isset($item['Numéro de TVA intracommunautaire']) && $item['Numéro de TVA intracommunautaire']){$fournisseur->setTvaIntracommunautaire($item['Numéro de TVA intracommunautaire']);}
  241.        if(isset($item['Code mode reglt']) && $item['Code mode reglt']){$fournisseur->setCodeModeReglt($item['Code mode reglt']);}
  242.        if(isset($item['ReverseFactoring']) && $item['ReverseFactoring']){$fournisseur->setReverseFactoring($item['ReverseFactoring']);}
  243.        if(isset($item['TVA Débit']) && $item['TVA Débit']){$fournisseur->setTvaDebit($item['TVA Débit']);}
  244.        $fournisseur->setIsFlux(true);
  245.        $fournisseur->setIsEnabled(true);
  246.        $this->em->persist($fournisseur);
  247.        $this->em->flush();
  249.        if(isset($item['IBAN']) && $item['IBAN']){
  250.            $ribs = $this->em->getRepository(Rib::class)->findBy(['fournisseur'=>$fournisseur->getId()]);
  252.            $rib = $this->em->getRepository(Rib::class)->findOneBy(['fournisseur'=>$fournisseur->getId(),'iban'=>$item['IBAN']]);
  253.            if(!$rib){
  254.                $rib = new Rib();
  255.            }
  256.            $rib->setFournisseur($fournisseur);
  257.            $rib->setIsDefault(true);
  258.            if(isset($item['Code BIC']) && $item['Code BIC']){  $rib->setBic($item['Code BIC']);}
  259.            if(isset($item['IBAN']) && $item['IBAN']){  $rib->setIban($item['IBAN']);}
  260.            if(isset($item['Clé RIB']) && $item['Clé RIB']){  $rib->setCleRib($item['Clé RIB']);}
  261.            if(isset($item['Code guichet']) && $item['Code guichet']){  $rib->setCodeGuichet($item['Code guichet']);}
  262.            if(isset($item['Code banque']) && $item['Code banque']){  $rib->setCodeBanque($item['Code banque']);}
  263.            if(isset($item['Numéro de compte']) && $item['Numéro de compte']){  $rib->setNumeroCompte($item['Numéro de compte']);}
  264.            if(isset($item['Domiciliée à']) && $item['Domiciliée à']){  $rib->setDomiiciliee($item['Domiciliée à']);}
  265.            if(isset($item['RIB Actif'])){
  266.                if(trim($item['RIB Actif']) == 'O'){
  267.                    if($ribs){
  268.                        foreach ($ribs as $ribItem){
  269.                            $ribItem->setIsDefault(false);
  270.                            $this->em->persist($ribItem);
  271.                            $this->em->flush();
  272.                        }
  273.                    }
  274.                    $rib->setIsActive(true);
  275.                    $rib->setIsDefault(true);
  276.                }elseif ($item['RIB Actif'] == 'N'){
  277.                    $rib->setIsActive(false);
  278.                    $rib->setIsDefault(false);
  279.                }
  280.            }
  281.            $this->em->persist($rib);
  282.            $this->em->flush();
  283.        }
  284.    }
  285.    public function checkFournisseurRibActive($fournisseur){
  286.        $isActive = false;
  287.        if($fournisseur){
  288.            $ribs = $this->em->getRepository(Rib::class)->findBy(['fournisseur'=>$fournisseur->getId()]);
  289.            if($fournisseur->getIsFlux()){
  290.                foreach ($ribs as $rib){
  291.                    if($rib->getIsActive()){
  292.                        $isActive = true;
  293.                    }
  294.                }
  295.            }else{
  296.                if($ribs){
  297.                    $isActive = false;
  298.                }
  299.            }
  300.        }
  301.        return $isActive;
  302.    }
  304.     public function importAutoManuel(){
  306.         $files[] = $this->params->get('fournisseur_altarea_import_directory') . "/ERPI-2025040210-30-17.txt";
  307.         $files[] = $this->params->get('fournisseur_altarea_import_directory') . "/ERPI-2025040211-13-02.txt";
  308.         $files[] = $this->params->get('fournisseur_altarea_import_directory') . "/ERPI-2025040212-05-05.txt";
  309.         $files[] = $this->params->get('fournisseur_altarea_import_directory') . "/ERPI-2025040212-10-14.txt";
  310.         $files[] = $this->params->get('fournisseur_altarea_import_directory') . "/ERPI-2025040215-00-22.txt";
  311.         $files[] = $this->params->get('fournisseur_altarea_import_directory') . "/ERPI-2025040218-00-25.txt";
  312.        foreach ($files as $file) {
  313.            if ($file && file_exists($file)) {
  314.                $array = [];
  315.                $flag = true;
  316.                $i = 0;
  317.                $header = [];
  318.                $fichier = file($file);
  319.                foreach ($fichier as $line_num => $line) {
  320. //               if($line_num == 0 ){
  321. //                   continue;
  322. //               }
  323.                    $colonnes = explode('|', $line);
  324.                    if ($flag) {
  325.                        $header = [];
  326.                        foreach ($colonnes as $key1 => $cell) {
  327.                            $header[] = trim($cell);
  328.                        }
  329.                        $flag = false;
  330.                        continue;
  331.                    }
  332.                    foreach ($colonnes as $key => $cell) {
  333.                        $array[$i][$header[$key]] = trim(htmlspecialchars($cell));
  334.                    }
  335.                    $i++;
  336.                }
  337.                if ($array) {
  338.                    foreach ($array as $item) {
  339.                        $fournisseur = null;
  340.                        $isModif = true;
  341.                        if (isset($item['CodeFournisseur']) && $item['CodeFournisseur']) {
  342.                            $fournisseurs = $this->em->getRepository(Fournisseur::class)->findNotArchiveByCode($item['CodeFournisseur']);
  343.                            if (!$fournisseurs) {
  344.                                if (isset($item['Adresse messagerie 1']) && $item['Adresse messagerie 1']) {
  345.                                    $fournisseurs = $this->em->getRepository(Fournisseur::class)->findBy(['email' => $item['Adresse messagerie 1']]);
  346.                                }
  347.                            }
  348.                        }
  349.                        if ($fournisseurs) {
  350.                            foreach ($fournisseurs as $fournisseur) {
  351.                                $this->updateOrAddFournissuerByFichier($item, $fournisseur);
  352.                            }
  353.                        } else {
  354.                            $fournisseur = new Fournisseur();
  355.                            $isModif = false;
  356.                            $this->updateOrAddFournissuerByFichier($item, $fournisseur);
  357.                        }
  358.                    }
  359.                }
  361.            }
  362.        }
  363.     }
  365.     public function getUserNotaire(){
  366.         $notaires = $this->em->getRepository(User::class)->getNotaires();
  367.         return $notaires ;
  368.     }
  370.     public function getUserByTitreIntervenant($titre){
  371.         $fournisseurProjects = $this->em->getRepository(FournisseurProject::class)->getFournisseurProjectByTitre($titre);
  372.         $fournisseurs = [];
  373.         if($fournisseurProjects){
  374.             foreach ($fournisseurProjects as $fournisseurProject){
  375.                 $fournisseurs[] = $fournisseurProject;
  376.             }
  377.         }
  378.         return $fournisseurs ;
  379.     }
  380. }