src/Controller/DefaultController.php line 42

Open in your IDE?
  1. <?php
  2. // src/Controller/DefaultController.php
  3. namespace App\Controller;
  5. use App\Service\CrmCompteManager;
  6. use App\Service\CrmContactManager;
  7. use App\Service\CrmObjectifManager;
  8. use App\Service\NotificationManager;
  9. use App\Service\Geocoder;
  10. use App\Service\Simplexlsx;
  11. use DateTime;
  12. use Doctrine\ORM\EntityManagerInterface;
  13. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  14. use Symfony\Component\HttpFoundation\Request;
  15. use Symfony\Component\HttpFoundation\Response;
  16. use Symfony\Component\Routing\Annotation\Route;
  17. use Symfony\Component\Security\Core\Encoder\UserPasswordEncoderInterface;
  18. use Symfony\Contracts\HttpClient\HttpClientInterface;
  20. class DefaultController extends AbstractController
  21. {
  22.     public function __construct(
  23.         UserPasswordEncoderInterface $encoder,
  24.         EntityManagerInterface $entityManager,
  25.         NotificationManager $notificationManager,
  26.         CrmCompteManager $crmCompteManager,
  27.         CrmContactManager $crmContactManager,
  28.         CrmObjectifManager $crmObjectifManager
  29.     ) {
  30.         $this->encoder = $encoder;
  31.         $this->entityManager = $entityManager;
  32.         $this->notificationManager = $notificationManager;
  33.         $this->crmCompteManager = $crmCompteManager;
  34.         $this->crmContactManager = $crmContactManager;
  35.         $this->crmObjectifManager = $crmObjectifManager;
  36.     }
  38.     /**
  39.      * @Route("/", name="homepage")
  40.      * @Route("/dashboard", name="dashboard")
  41.      */
  42.     public function dashboard(Request $request, HttpClientInterface $gpClient): Response
  43.     {
  44.         // Clears *all* the session, use at your own risk !
  45.         // $request->getSession()->clear();
  48.         /** @var \Doctrine\DBAL\Connection */
  49.         $now = new DateTime('now');
  50.         // echo 'now <br/>';
  51.         // echo '<pre>';
  52.         // print_r($now);
  53.         // echo '</pre>';  
  54.         $dateFinMois  =  $now->modify('last day of this month')->format('Y-m-d');    
  55.         // $date = $now->modify('first day of this month + 1 month')->format('d-m-Y');
  56.         // $dateNextMonth = $now->modify('last day of this month')->format('d-m-Y');
  57.         // echo 'dateFinMois <br/>';
  58.         // echo '<pre>';
  59.         // print_r($dateFinMois);
  60.         // echo '</pre>';  
  61.         $date = $now->modify('first day of this month + 1 month')->format('Y-m-d');
  62.         $dateNextMonth = $now->modify('last day of this month')->format('Y-m-d');
  64. // echo 'date <br/>';
  65. // echo '<pre>';
  66. // print_r($date);
  67. // echo '</pre>';
  68. // echo 'dateNextMonth <br/>';
  69. // echo '<pre>';
  70. // print_r($dateNextMonth);
  71. // echo '</pre>';
  72. // exit();
  74.         $connection = $this->getDoctrine()->getConnection();
  75.         $facture_impayees = $connection->fetchAssociative("SELECT count(id_facture), SUM (total_ht) AS total FROM search_factu_facture WHERE id_statut = 2 AND archived = 'f'");
  76.         $contrat_maintenance = $connection->fetchAssociative("SELECT count(id_contrat) FROM search_contrats WHERE (id_type = 1 OR id_type = 2) AND date_fin BETWEEN '$date'::timestamp AND  '$dateNextMonth'::timestamp AND archived = 'f'");
  78.         $contrats = $connection->fetchAllAssociative("SELECT * FROM search_contrats WHERE archived = 'f'");
  81.         $contrats_afacturer = $connection->fetchAssociative("SELECT count(c.id_contrat)
  82.                                                             FROM contrat c
  83.                                                             LEFT JOIN factu_facture f ON f.id_contrat = c.id_contrat
  84.                                                             WHERE c.date_fin < now()
  85.                                                             AND (f.id IS NULL OR f.id_statut = 1)");
  88.         // $date = date_format(date_create($date), 'Y-m-d H:i:s');
  89.         // $dateNextMonth = date_format(date_create($dateNextMonth), 'Y-m-d H:i:s');
  92.         $detailResponse = $gpClient->request(
  93.             'GET',
  94.             "/api/contracts/hours/detail"
  95.         );
  97.         $detailResponse = $detailResponse->toArray(false);
  99.         $forfaits = array(); // statut 4
  100.         $credit_temps = array(); // statut 2
  101.         $credit_temps_recurrent = array(); // statut 2
  103.         foreach ($detailResponse['project_time_entries'] as $key => $value) {
  105.             $contrat = array();
  106.             if (isset($value['id_contrat_factu'])){
  107.                 $contrat = $connection->fetchAssociative("SELECT * FROM search_contrats WHERE archived = 'f' AND id_contrat = " . $value['id_contrat_factu']);
  108.                 if (isset($contrat['id_devis'])) {
  109.                     $devis = $connection->fetchAssociative("SELECT * FROM search_factu_devis WHERE archived = 'f' AND id_devis = " . $contrat['id_devis']);
  110.                     $value['totalHT'] = $devis['total_ht'];
  111.                 }
  112.                 if (isset($contrat['heures'])) {
  113.                     $value['heuresTotales'] = $contrat['heures'];
  114.                 }
  115.             }
  117.             if ($value['type'] == 4){
  118.                 $forfaits[] = $value;
  119.             } else if ($value['type'] == 2 and (isset($contrat['frequence']) != null)){
  120.                 $credit_temps_recurrent[] = $value;
  121.             } else if ($value['type'] == 2) {
  122.                 $credit_temps[] = $value;
  123.             } else {
  125.             }
  126.         }
  128.         return $this->render('dashboard.html.twig', [
  129.             'facturesImpayees' => $facture_impayees,
  130.             'contratMaintenance' => $contrat_maintenance,
  131.             'contrats' => $contrats,
  132.             'contratsAFacturer' => $contrats_afacturer,
  133.             'forfaits' => $forfaits,
  134.             'credit_temps' => $credit_temps,
  135.             'credit_temps_recurrent' => $credit_temps_recurrent
  136.         ]);
  137.     }
  139.     /**
  140.      * @Route("/calendar", name="crm_calendar", methods={"GET"})
  141.      */
  142.     public function calendar(Request $request): Response
  143.     {
  144.         return $this->render('calendar.html.twig', [
  145.             'feed_route' => 'crm_act_co_calendar_feed',
  146.             'feed_url' => $this->generateUrl('crm_act_co_calendar_feed'),
  147.         ]);
  148.     }
  152.     /**
  153.      * @Route("/products/import", name="products_import")
  154.      */
  155.     public function importProducts(Request $request): Response
  156.     {
  157.         /** @var \Doctrine\DBAL\Connection */
  158.         $connection = $this->getDoctrine()->getConnection();
  160.         $xlsx = new Simplexlsx('');
  161.         $dimension = $xlsx->dimension();
  162.         $entetes = $xlsx->rows();
  164.         $agence = $connection->fetchAssociative("SELECT id_agence FROM agences WHERE nom_agence = 'France'");
  165.         $id_agence = $agence['id_agence'];
  167.         $results = array();
  169.         $countCreates = array('familles' => 0, 'modeles' => 0, 'ssmodeles' => 0, 'versions' => 0, 'options' => 0);
  170.         $countFound = array('familles' => 0, 'modeles' => 0, 'ssmodeles' => 0, 'versions' => 0, 'options' => 0);
  172.         $errors = array();
  174.         for ($i = 3; $i < count($entetes); $i++) {
  175.             $line = $entetes[$i];
  176.             if ($line[5] != '') {
  178.                 $famille = trim($line[6]);
  179.                 $modele = trim($line[7]);
  180.                 $ssmodele = trim($line[8]);
  181.                 $version = trim($line[9]);
  182.                 $description = trim($line[21]);
  183.                 $prixht = (trim($line[22]) == '') ? 0 : trim($line[22]);
  185.                 // CREATION FAMILLE / MODELE / SOUS MODELE
  186.                 if (trim($line[5]) == 'Description racine') {
  189.                     // create famille
  190.                     if (!isset($results[$famille])) {
  191.                         // find famille
  192.                         $f = $connection->fetchAssociative("SELECT id_famille FROM produit_famille WHERE id_agence = " . $id_agence . " AND nom_famille = " . $connection->quote($famille));
  193.                         if ($f) {
  194.                             $famille_id = $f['id_famille'];
  195.                             $countFound['familles']++;
  196.                         } else {
  197.                             $dbFamille = array('nom_famille' =>  $famille, 'id_agence' => $id_agence);
  198.                             $result = $connection->insert('produit_famille', $dbFamille);
  199.                             $famille_id = $connection->lastInsertId();
  200.                             $countCreates['familles']++;
  201.                         }
  202.                         $results[$famille] = array('id' => $famille_id, 'options' => array(), 'modeles' => array());
  203.                     } else {
  204.                         $famille_id = $results[$famille]['id'];
  205.                     }
  207.                     // create modele
  208.                     if (!isset($results[$famille]['modeles'][$modele])) {
  209.                         // find modele
  210.                         $m = $connection->fetchAssociative("SELECT id_modele FROM produit_modele WHERE id_agence = " . $id_agence . " AND id_famille = " . $famille_id . " AND nom_modele = " . $connection->quote($modele));
  211.                         if ($m) {
  212.                             $modele_id = $m['id_modele'];
  213.                             $countFound['modeles']++;
  214.                         } else {
  215.                             $dbModele = array('nom_modele' => $modele, 'id_famille' =>  $famille_id, 'id_agence' => $id_agence);
  216.                             $result = $connection->insert('produit_modele', $dbModele);
  217.                             $modele_id = $connection->lastInsertId();
  218.                             $countCreates['modeles']++;
  219.                         }
  220.                         $results[$famille]['modeles'][$modele] = array('id' => $modele_id, 'options' => array(), 'ssmodeles' => array());
  221.                     } else {
  222.                         $modele_id = $results[$famille]['modeles'][$modele]['id'];
  223.                     }
  225.                     // create sous modele
  226.                     if (!isset($results[$famille]['modeles'][$modele]['ssmodeles'][$ssmodele])) {
  227.                         // find ssmodele
  228.                         $sm = $connection->fetchAssociative("SELECT id_sub_modele FROM produit_sub_modele WHERE id_agence = " . $id_agence . " AND id_modele = " . $modele_id . " AND nom_sub_modele = " . $connection->quote($ssmodele));
  229.                         if ($sm) {
  230.                             $ssmodele_id = $sm['id_sub_modele'];
  231.                             $countFound['ssmodeles']++;
  232.                         } else {
  233.                             $dbSsModele = array('nom_sub_modele' => $ssmodele, 'description_sub_modele' => $description, 'id_modele' =>  $modele_id, 'id_agence' => $id_agence);
  234.                             $result = $connection->insert('produit_sub_modele', $dbSsModele);
  235.                             $ssmodele_id = $connection->lastInsertId();
  236.                             $countCreates['ssmodeles']++;
  237.                         }
  238.                         $results[$famille]['modeles'][$modele]['ssmodeles'][$ssmodele] = array('id' => $ssmodele_id, 'options' => array(), 'versions' => array());
  239.                     } else {
  240.                         $ssmodele_id = $results[$famille]['modeles'][$modele]['ssmodeles'][$ssmodele]['id'];
  241.                     }
  243.                     // CREATION VERSIONS
  244.                 } elseif (trim($line[5]) == 'Description machine') {
  246.                     //identification famille
  247.                     if (!isset($results[$famille])) {
  248.                         $errors[] = array('line' => $i + 1, 'message' => 'famille ' . $famille . ' non trouvée');
  249.                         continue;
  250.                     } else {
  251.                         $famille_id = $results[$famille]['id'];
  252.                     }
  254.                     //identification modele
  255.                     if (!isset($results[$famille]['modeles'][$modele])) {
  256.                         $errors[] = array('line' => $i + 1, 'message' => 'modele ' . $modele . ' non trouvée');
  257.                         continue;
  258.                     } else {
  259.                         $modele_id = $results[$famille]['modeles'][$modele]['id'];
  260.                     }
  262.                     //identification ssmodele
  263.                     if (!isset($results[$famille]['modeles'][$modele]['ssmodeles'][$ssmodele])) {
  264.                         $errors[] = array('line' => $i + 1, 'message' => 'sous modele ' . $ssmodele . ' non trouvée');
  265.                         continue;
  266.                     } else {
  267.                         $ssmodele_id = $results[$famille]['modeles'][$modele]['ssmodeles'][$ssmodele]['id'];
  268.                     }
  270.                     // create versions
  271.                     if (!isset($results[$famille]['modeles'][$modele]['ssmodeles'][$ssmodele]['versions'][$version])) {
  272.                         // find ssmodele
  273.                         $v = $connection->fetchAssociative("SELECT id_version FROM produit_version WHERE id_agence = " . $id_agence . " AND id_sub_modele = " . $ssmodele_id . " AND nom_version = " . $connection->quote($version));
  274.                         if ($v) {
  275.                             $version_id = $v['id_version'];
  276.                             $countFound['versions']++;
  277.                         } else {
  278.                             $dbversion = array('nom_version' => $version, 'description_version' => $description, 'prix_ht_version' => $prixht, 'id_sub_modele' =>  $ssmodele_id, 'id_agence' => $id_agence);
  279.                             $result = $connection->insert('produit_version', $dbversion);
  280.                             $version_id = $connection->lastInsertId();
  281.                             $countCreates['versions']++;
  282.                         }
  283.                         $results[$famille]['modeles'][$modele]['ssmodeles'][$ssmodele]['versions'][$version] = array('id' => $version_id, 'options' => array());
  284.                     } else {
  285.                         $version_id = $results[$famille]['modeles'][$modele]['ssmodeles'][$ssmodele]['versions'][$version]['id'];
  286.                     }
  288.                     // CREATION OPTIONS
  289.                 } elseif (trim($line[5]) != '') {
  291.                     //identification famille
  292.                     if (!isset($results[$famille])) {
  293.                         $errors[] = array('line' => $i + 1, 'message' => 'famille ' . $famille . ' non trouvée');
  294.                         continue;
  295.                     } else {
  296.                         $famille_id = $results[$famille]['id'];
  297.                     }
  299.                     //identification modele
  300.                     if (!isset($results[$famille]['modeles'][$modele])) {
  301.                         $errors[] = array('line' => $i + 1, 'message' => 'modele ' . $modele . ' non trouvée');
  302.                         continue;
  303.                     } else {
  304.                         $modele_id = $results[$famille]['modeles'][$modele]['id'];
  305.                     }
  307.                     $optionDb = array();
  308.                     $optionDb['nom_option'] = $description;
  309.                     $optionDb['description_option'] = $description;
  310.                     $optionDb['prix_ht_option'] = $prixht;
  311.                     $optionDb['type_option'] = 1;
  312.                     $optionDb['code_option'] = trim($line[10]);
  313.                     $optionDb['qtt_min'] = (trim($line[11]) == '') ? 0 : trim($line[1]);
  314.                     $optionDb['qtt_max'] = (trim($line[12]) == '') ? 0 : trim($line[12]);
  316.                     if (trim($line[13]) != '') $optionDb['incompat_1'] = trim($line[13]);
  317.                     if (trim($line[14]) != '') $optionDb['incompat_2'] = trim($line[14]);
  318.                     if (trim($line[15]) != '') $optionDb['incompat_3'] = trim($line[15]);
  320.                     if (trim($line[16]) != '') $optionDb['oblig_1'] = trim($line[16]);
  321.                     if (trim($line[17]) != '') $optionDb['oblig_2'] = trim($line[17]);
  322.                     if (trim($line[18]) != '') $optionDb['oblig_3'] = trim($line[18]);
  323.                     if (trim($line[19]) != '') $optionDb['oblig_4'] = trim($line[19]);
  326.                     if ($ssmodele == 'Option commune') {
  327.                         $optionDb['id_modele'] = $modele_id;
  329.                         // find options
  330.                         $o = $connection->fetchAssociative("SELECT id_option FROM produit_option WHERE id_modele = " . $modele_id . " AND nom_option = " . $connection->quote($optionDb['nom_option']));
  332.                         if ($o) {
  333.                             $option_id = $o['id_option'];
  334.                             $countFound['options']++;
  335.                         } else {
  336.                             $result = $connection->insert('produit_option', $optionDb);
  337.                             $option_id = $connection->lastInsertId();
  338.                             $countCreates['options']++;
  339.                         }
  340.                         $results[$famille]['modeles'][$modele]['options'][] = array('id' => $option_id);
  341.                     } else {
  342.                         //identification ssmodele
  343.                         if (!isset($results[$famille]['modeles'][$modele]['ssmodeles'][$ssmodele])) {
  344.                             $errors[] = array('line' => $i + 1, 'message' => 'sous modele ' . $ssmodele . ' non trouvée');
  345.                             continue;
  346.                         } else {
  347.                             $ssmodele_id = $results[$famille]['modeles'][$modele]['ssmodeles'][$ssmodele]['id'];
  348.                         }
  350.                         if ($version == 'Option commune') {
  351.                             $optionDb['id_sub_modele'] = $ssmodele_id;
  353.                             // find options
  354.                             $o = $connection->fetchAssociative("SELECT id_option FROM produit_option WHERE id_sub_modele = " . $ssmodele_id . " AND nom_option = " . $connection->quote($optionDb['nom_option']));
  355.                             if ($o) {
  356.                                 $option_id = $o['id_option'];
  357.                                 $countFound['options']++;
  358.                             } else {
  359.                                 $result = $connection->insert('produit_option', $optionDb);
  360.                                 $option_id = $connection->lastInsertId();
  361.                                 $countCreates['options']++;
  362.                             }
  363.                             $results[$famille]['modeles'][$modele]['ssmodeles'][$ssmodele]['options'][] = array('id' => $option_id);
  364.                         } else {
  365.                             //identification version
  366.                             if (!isset($results[$famille]['modeles'][$modele]['ssmodeles'][$ssmodele]['versions'][$version])) {
  367.                                 $errors[] = array('line' => $i + 1, 'message' => 'version ' . $version . ' non trouvée');
  368.                                 continue;
  369.                             } else {
  370.                                 $version_id = $results[$famille]['modeles'][$modele]['ssmodeles'][$ssmodele]['versions'][$version]['id'];
  371.                             }
  372.                             $optionDb['id_version'] = $version_id;
  374.                             // find options
  375.                             $o = $connection->fetchAssociative("SELECT id_option FROM produit_option WHERE id_version = " . $version_id . " AND nom_option = " . $connection->quote($optionDb['nom_option']));
  376.                             if ($o) {
  377.                                 $option_id = $o['id_option'];
  378.                                 $countFound['options']++;
  379.                             } else {
  380.                                 $result = $connection->insert('produit_option', $optionDb);
  381.                                 $option_id = $connection->lastInsertId();
  382.                                 $countCreates['options']++;
  383.                             }
  384.                             $results[$famille]['modeles'][$modele]['ssmodeles'][$ssmodele]['versions'][$version]['options'][] = array('id' => $option_id);
  385.                         }
  386.                     }
  387.                 }
  388.             }
  389.         }
  390.         echo '<pre>';
  391.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  392.         print_r($countCreates);
  393.         echo '</pre>';
  394.         echo '<pre>';
  395.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  396.         print_r($countFound);
  397.         echo '</pre>';
  398.         echo '<pre>';
  399.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  400.         print_r($errors);
  401.         echo '</pre>';
  402.         exit();
  404.         return $this->render('dashboard.html.twig', []);
  405.     }
  409.     /**
  410.      * @Route("/crm/comptes/import", name="crm_comptes_import")
  411.      */
  412.     public function importCRMComptes(Request $request): Response
  413.     {
  414.         /** @var \Doctrine\DBAL\Connection */
  415.         $connection = $this->getDoctrine()->getConnection();
  416.         $agence = $connection->fetchAssociative("SELECT id_agence FROM agences WHERE nom_agence = 'France'");
  417.         $id_agence = $agence['id_agence'];
  419.         $xlsx = new Simplexlsx('');
  420.         $dimension = $xlsx->dimension();
  421.         $rows = $xlsx->rows();
  423.         $entetes = array_flip(array_filter($rows[4]));
  425.         $results = array();
  427.         $countCreates = array('accounts' => 0);
  428.         $countFound = array('accounts' => 0);
  429.         $found = [];
  431.         $errors = array();
  433.         for ($i = 5; $i < count($rows); $i++) {
  434.             $line = $rows[$i];
  435.             if ($line[4] != '') {
  437.                 $revendeur_ref = trim($line[27]);
  438.                 $r = $connection->fetchAssociative("SELECT id_revendeur FROM revendeurs WHERE ref_revendeur = " . $connection->quote($revendeur_ref));
  440.                 if ($r !== false) {
  441.                     $ref = trim($line[4]);
  442.                     $nom = trim($line[3]);
  443.                     $siret = trim($line[5]);
  444.                     $type = trim($line[7]);
  445.                     $code_activite = trim($line[8]);
  446.                     $secteur_activite = trim($line[9]);
  447.                     $telephone = trim($line[12]);
  448.                     $site_internet = trim($line[13]);
  449.                     $adresse = trim($line[14]);
  450.                     $comp_adresse = trim($line[15]);
  451.                     $code_postal = trim($line[16]);
  452.                     $ville = trim($line[17]);
  453.                     $region = trim($line[18]);
  454.                     $pays = trim($line[19]);
  455.                     $surface = trim($line[32]);
  456.                     $largeur_min = trim($line[33]);
  457.                     $largeur_max = trim($line[34]);
  458.                     $cave = (trim($line[35]) == 'X') ? 't' : 'f';
  459.                     $commentaire = trim($line[36]);
  460.                     $id_revendeur = $r['id_revendeur'];
  462.                     $account = $ref;
  464.                     // create compte
  465.                     if (!isset($results[$account])) {
  466.                         $dbCompte = array(
  467.                             'compte_nom' =>  $nom,
  468.                             'compte_revendeur_ref' => $ref,
  469.                             'activite_code' => $code_activite,
  470.                             'site_internet' => $site_internet,
  471.                             'adresse' => $adresse,
  472.                             'comp_adresse' => $comp_adresse,
  473.                             'code_postal' => $code_postal,
  474.                             'ville' => $ville,
  475.                             'code_pays' => $pays,
  476.                             'compte_comment' => $commentaire,
  477.                             'id_revendeur' => $id_revendeur
  478.                         );
  479.                         $geocoder = new Geocoder();
  480.                         $geocoder->setAddress($adresse, $code_postal, $ville, '', $pays);
  481.                         if ($geocoder->geocode() !== false) {
  482.                             $dbCompte['latitude'] = $geocoder->pnt['lat'];
  483.                             $dbCompte['longitude'] = $geocoder->pnt['lng'];
  484.                         }
  485.                         // find compte
  486.                         $c = $connection->fetchAssociative("SELECT id_compte FROM crm_compte WHERE compte_revendeur_ref = " . $connection->quote($ref));
  487.                         if ($c) {
  488.                             $compte_id = $c['id_compte'];
  489.                             $countFound['accounts']++;
  490.                             $found[] = ['ref' => $account, 'id' => $compte_id];
  492.                             try {
  493.                                 $result = $connection->update('crm_compte', $dbCompte, ['id_compte' => $compte_id]);
  494.                             } catch (\Exception $e) {
  495.                                 $errors[$i] = $e->getMessage();
  496.                             }
  497.                         } else {
  498.                             try {
  499.                                 $result = $connection->insert('crm_compte', $dbCompte);
  500.                                 if ($result === 1) {
  501.                                     $compte_id = $connection->lastInsertId();
  502.                                     $countCreates['accounts']++;
  503.                                 } else {
  504.                                     $errors[$i] = 'Db error';
  505.                                 }
  506.                             } catch (\Exception $e) {
  507.                                 $errors[$i] = $e->getMessage();
  508.                             }
  509.                         }
  510.                         $results[$account] = array('id' => $compte_id);
  511.                     } else {
  512.                         $compte_id = $results[$account]['id'];
  513.                         $found[] = ['ref' => $account, 'id' => $compte_id];
  514.                     }
  515.                 } else {
  516.                     $errors[$i] = 'Revendeur non trouvé : ' . $revendeur_ref;
  517.                 }
  518.             }
  519.         }
  520.         echo '<pre>';
  521.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  522.         print_r($countCreates);
  523.         echo '</pre>';
  524.         echo '<pre>';
  525.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  526.         print_r($countFound);
  527.         echo '</pre>';
  528.         echo '<pre>';
  529.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  530.         print_r($errors);
  531.         echo '</pre>';
  532.         echo '<pre>';
  533.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  534.         print_r($found);
  535.         echo '</pre>';
  536.         exit();
  538.         return $this->render('dashboard.html.twig', []);
  539.     }
  543.     /**
  544.      * @Route("/crm/contacts/import", name="crm_contacts_import")
  545.      */
  546.     public function importCRMContacts(Request $request): Response
  547.     {
  548.         /** @var \Doctrine\DBAL\Connection */
  549.         $connection = $this->getDoctrine()->getConnection();
  550.         $agence = $connection->fetchAssociative("SELECT id_agence FROM agences WHERE nom_agence = 'France'");
  551.         $id_agence = $agence['id_agence'];
  553.         $xlsx = new Simplexlsx('');
  554.         $dimension = $xlsx->dimension();
  555.         $rows = $xlsx->rows(2);
  557.         $entetes = array_flip(array_filter($rows[4]));
  559.         $results = array();
  561.         $countCreates = array('contacts' => 0);
  562.         $countFound = array('contacts' => 0);
  564.         $errors = array();
  565.         $found = [];
  566.         $treated = 0;
  567.         for ($i = 5; $i < count($rows); $i++) {
  568.             $treated++;
  569.             $line = $rows[$i];
  570.             if ($line[3] != '') {
  572.                 $ref = trim($line[3]);
  573.                 $civilite = (trim($line[4]) == 'M') ? 1 : 2;
  574.                 $nom = trim($line[5]);
  575.                 $prenom = trim($line[6]);
  576.                 $telephone = trim($line[7]);
  577.                 $mobile = trim($line[8]);
  578.                 $email = trim($line[9]);
  579.                 $fonction_contact = trim($line[10]);
  580.                 $service = trim($line[11]);
  581.                 $departement = trim($line[12]);
  583.                 $contact = $nom . ' ' . $prenom . ' ' . $ref;
  585.                 // find account
  586.                 $a = $connection->fetchAssociative("SELECT id_compte FROM crm_compte WHERE compte_revendeur_ref = " . $connection->quote($ref));
  588.                 // create contact
  589.                 if ($a) {
  590.                     // find contact
  591.                     $c = $connection->fetchAssociative("SELECT id_contact FROM crm_contact WHERE nom_contact = " . $connection->quote($nom) . " AND prenom_contact = " . $connection->quote($prenom) . " AND id_compte = " . $a['id_compte']);
  592.                     if ($c) {
  593.                         $contact_id = $c['id_contact'];
  594.                         $countFound['contacts']++;
  595.                     } else {
  597.                         if (!isset($results[$contact])) {
  598.                             $dbContact = array(
  599.                                 'id_compte' =>  $a['id_compte'],
  600.                                 'nom_contact' => $nom,
  601.                                 'prenom_contact' => $prenom,
  602.                                 'civ_contact' => $civilite,
  603.                                 'tel_contact' => $telephone,
  604.                                 'mob_contact' => $mobile,
  605.                                 'email_contact' => $email,
  606.                                 'service_contact' => $service,
  607.                                 'departement_contact' => $departement
  608.                             );
  609.                             $result = $connection->insert('crm_contact', $dbContact);
  610.                             $contact_id = $connection->lastInsertId();
  611.                             $countCreates['contacts']++;
  612.                         } else {
  613.                             $contact_id = $results[$contact]['id'];
  614.                             $found[] = $nom . ' ' . $prenom . ' ' . $ref;
  615.                         }
  616.                     }
  617.                     $results[$contact] = array('id' => $contact_id);
  618.                 } else {
  619.                     $errors[$i] = "Account " . $ref . " not found";
  620.                 }
  621.             }
  622.         }
  623.         echo '<pre>';
  624.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  625.         print_r($countCreates);
  626.         echo '</pre>';
  627.         echo '<pre>';
  628.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  629.         print_r($countFound);
  630.         echo '</pre>';
  631.         echo '<pre>';
  632.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  633.         print_r($found);
  634.         echo '</pre>';
  635.         echo '<pre>';
  636.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  637.         print_r($treated);
  638.         echo '</pre>';
  639.         exit();
  641.         exit();
  643.         return $this->render('dashboard.html.twig', []);
  644.     }
  648.     /**
  649.      * @Route("/structure/revendeurs/import", name="structure_revendeurs_import")
  650.      */
  651.     public function importRevendeurs(Request $request): Response
  652.     {
  653.         /** @var \Doctrine\DBAL\Connection */
  654.         $connection = $this->getDoctrine()->getConnection();
  655.         $agence = $connection->fetchAssociative("SELECT id_agence FROM agences WHERE nom_agence = 'France'");
  656.         $id_agence = $agence['id_agence'];
  658.         $secteur = $connection->fetchAssociative("SELECT id_secteur FROM secteurs WHERE nom_secteur = 'Sud-Ouest' AND id_agence = " . $id_agence);
  659.         $id_secteur = $secteur['id_secteur'];
  661.         $xlsx = new Simplexlsx('');
  662.         $dimension = $xlsx->dimension();
  663.         $rows = $xlsx->rows();
  665.         $entetes = array_flip(array_filter($rows[0]));
  667.         $results = array();
  669.         $countCreates = array('revendeurs' => 0);
  670.         $countFound = array('revendeurs' => 0);
  671.         $found = [];
  673.         $errors = array();
  675.         for ($i = 1; $i < count($rows); $i++) {
  676.             $line = $rows[$i];
  677.             if ($line[4] != '') {
  679.                 $ref_revendeur = trim($line[0]);
  680.                 $nom_revendeur = trim($line[1]);
  681.                 $description_revendeur = trim($line[2]);
  683.                 $revendeur = $ref_revendeur;
  685.                 // create revendeur
  686.                 if (!isset($results[$revendeur])) {
  687.                     // find revendeur
  688.                     $c = $connection->fetchAssociative("SELECT id_revendeur FROM revendeurs WHERE ref_revendeur = " . $connection->quote($ref_revendeur));
  689.                     if ($c) {
  690.                         $revendeur_id = $c['id_revendeur'];
  691.                         $countFound['revendeurs']++;
  692.                         $found[] = ['ref' => $revendeur, 'id' => $revendeur_id];
  693.                     } else {
  694.                         $dbRevendeur = array(
  695.                             'ref_revendeur' =>  $ref_revendeur,
  696.                             'nom_revendeur' => $nom_revendeur,
  697.                             'description_revendeur' => $description_revendeur,
  698.                             'id_secteur' => $id_secteur
  699.                         );
  700.                         try {
  701.                             $result = $connection->insert('revendeurs', $dbRevendeur);
  702.                             if ($result === 1) {
  703.                                 $revendeur_id = $connection->lastInsertId();
  704.                                 $countCreates['revendeurs']++;
  705.                             } else {
  706.                                 $errors[$i] = 'Db error';
  707.                             }
  708.                         } catch (\Exception $e) {
  709.                             $errors[$i] = $e->getMessage();
  710.                         }
  711.                     }
  712.                     $results[$revendeur] = array('id' => $revendeur_id);
  713.                 } else {
  714.                     $revendeur_id = $results[$revendeur]['id'];
  715.                     $found[] = ['ref' => $revendeur, 'id' => $revendeur_id];
  716.                 }
  717.             }
  718.         }
  719.         echo '<pre>';
  720.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  721.         print_r($countCreates);
  722.         echo '</pre>';
  723.         echo '<pre>';
  724.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  725.         print_r($countFound);
  726.         echo '</pre>';
  727.         echo '<pre>';
  728.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  729.         print_r($errors);
  730.         echo '</pre>';
  731.         echo '<pre>';
  732.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  733.         print_r($found);
  734.         echo '</pre>';
  735.         exit();
  737.         return $this->render('dashboard.html.twig', []);
  738.     }
  742.     /**
  743.      * @Route("/options/create/service/", name="options_create_service")
  744.      */
  745.     public function createOptionsServiceContacts(Request $request): Response
  746.     {
  747.         /** @var \Doctrine\DBAL\Connection */
  748.         $connection = $this->getDoctrine()->getConnection();
  749.         $agence = $connection->fetchAssociative("SELECT id_agence FROM agences WHERE nom_agence = 'France'");
  750.         $id_agence = $agence['id_agence'];
  752.         $xlsx = new Simplexlsx('');
  753.         $dimension = $xlsx->dimension();
  754.         $rows = $xlsx->rows();
  756.         $entetes = array_flip(array_filter($rows[0]));
  758.         $results = array();
  760.         $countCreates = array('options' => 0);
  761.         $countFound = array('options' => 0);
  763.         $errors = array();
  765.         for ($i = 1; $i < count($rows); $i++) {
  766.             $line = $rows[$i];
  767.             if ($line[1] != '') {
  769.                 $nom_agence = trim($line[0]);
  770.                 $nom_option = trim($line[1]);
  771.                 $code_option = trim($line[2]);
  773.                 $option = $nom_option;
  775.                 // create option
  776.                 if (!isset($results[$nom_agence . $option])) {
  777.                     // find agence
  778.                     $a = $connection->fetchAssociative("SELECT id_agence FROM agences WHERE nom_agence = " . $connection->quote($nom_agence));
  779.                     if ($a) {
  780.                         // find option
  781.                         $o = $connection->fetchAssociative("SELECT id_option FROM produit_option WHERE nom_option = " . $connection->quote($nom_option) . " AND id_agence = " . $a['id_agence']);
  783.                         if ($o) {
  784.                             $option_id = $o['id_option'];
  785.                             $countFound['options']++;
  786.                         } else {
  787.                             $dbOption = array(
  788.                                 'id_agence' =>  $a['id_agence'],
  789.                                 'nom_option' => $nom_option,
  790.                                 'code_option' => $code_option,
  791.                                 'qtt_min' => 1,
  792.                                 'qtt_max' => 1,
  793.                                 'type_option' => 2,
  794.                                 'prix_modifiable' => 't'
  795.                             );
  797.                             try {
  798.                                 $result = $connection->insert('produit_option', $dbOption);
  799.                                 if ($result === 1) {
  800.                                     $option_id = $connection->lastInsertId();
  801.                                     $countCreates['options']++;
  802.                                 } else {
  803.                                     $errors[$i] = 'Db error';
  804.                                 }
  805.                             } catch (\Exception $e) {
  806.                                 $errors[$i] = $e->getMessage();
  807.                             }
  808.                         }
  809.                         $results[$nom_agence . $option] = array('id' => $option_id);
  810.                     } else {
  811.                         $errors[$i] = "Agence " . $nom_agence . " not found";
  812.                     }
  813.                 } else {
  814.                     $option_id = $results[$nom_agence . $option]['id'];
  815.                 }
  816.             }
  817.         }
  818.         echo '<pre>';
  819.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  820.         print_r($countCreates);
  821.         echo '</pre>';
  822.         echo '<pre>';
  823.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  824.         print_r($countFound);
  825.         echo '</pre>';
  826.         echo '<pre>';
  827.         print_r(__FILE__ . " Ligne " . __LINE__ . " : ");
  828.         print_r($errors);
  829.         echo '</pre>';
  830.         exit();
  832.         return $this->render('dashboard.html.twig', []);
  833.     }
  837.     /**
  838.      * @Route("/map", name="crm_map")
  839.      */
  840.     public function map(Request $request): Response
  841.     {
  842.         return $this->render('map-leaflet.html.twig', [
  843.             'layer_route' => 'crm_compte_geojson',
  844.             'layer_url' => $this->generateUrl('crm_compte_geojson'),
  845.         ]);
  846.     }
  848.     /**
  849.      * @Route("/autocomplete", name="autocomplete", methods={"GET"})
  850.      */
  851.     public function autocomplete(Request $request): Response
  852.     {
  853.         $dataset = $request->get('dataset');
  854.         $datavalue = $request->get('datavalue');
  855.         $datasource = $request->get('datasource');
  857.         $connection = $this->getDoctrine()->getConnection();
  859.         switch ($dataset) {
  860.             case 'commune':
  861.                 if ($datasource == 'crm_compte_ville' || $datasource == 'crm_contact_ville') {
  862.                     $results = $connection->fetchAllAssociative("SELECT nom_commune, code_postal FROM communes WHERE code_postal LIKE UPPER('" . $datavalue . "%') OR nom_commune LIKE UPPER('" . $datavalue . "%') ORDER BY nom_commune");
  863.                 } else {
  864.                     $results = $connection->fetchAllAssociative("SELECT nom_commune, code_postal FROM communes WHERE code_postal LIKE UPPER('" . $datavalue . "%') ORDER BY code_postal");
  865.                 }
  866.                 break;
  867.             case 'crm_compte':
  868.                 $filters = array('compte_nom' => $datavalue);
  869.                 $filters['is_actif'] = true;
  870.                 if ($request->get('id_agence') != '') {
  871.                     $filters['id_agence'] = $request->get('id_agence');
  872.                 }
  873.                 if ($request->get('id_secteur') != '') {
  874.                     $filters['id_secteur'] = $request->get('id_secteur');
  875.                 }
  876.                 if ($request->get('id_revendeur') != '') {
  877.                     $filters['id_revendeur'] = $request->get('id_revendeur');
  878.                 }
  880.                 $results = $this->crmCompteManager->search($filters, array('sort' => 'compte_nom'), array("compte_nom|| ' - ' || nom_revendeur AS compte_nom ", 'id_compte'));
  881.                 break;
  882.         }
  884.         return $this->json($results, 200, [], [
  885.             'groups' => 'autocomplete',
  886.         ]);
  887.     }
  889.     /**
  890.      * @Route("/get/entities", name="get_entities", methods={"GET","POST"})
  891.      */
  892.     public function getEntities(Request $request): Response
  893.     {
  894.         $typeEntity = $request->get('type_entity');
  895.         $idParentEntity = $request->get('id_parent_entity');
  897.         switch ($typeEntity) {
  898.             case 'account':
  899.             case 'crm_compte':
  900.                 $results = $this->crmCompteManager->search(array(), array('sort' => 'compte_nom'), array('compte_nom AS nom_entite', 'id_compte AS id_entite'));
  901.                 break;
  902.             case 'contact':
  903.             case 'crm_contact':
  904.                 $results = $this->crmContactManager->search(array('id_compte' => $idParentEntity), array('sort' => 'nom_contact'), array("nom_contact || ' ' || prenom_contact AS nom_entite", 'id_contact AS id_entite'));
  905.                 break;
  906.             case 'objective':
  907.             case 'crm_objectif':
  908.                 $results = $this->crmObjectifManager->search(array(), array('sort' => 'title'), array("title AS nom_entite", 'id AS id_entite'));
  909.                 break;
  910.         }
  912.         return $this->json($results['rows'], 200, [], [
  913.             'groups' => 'entities'
  914.         ]);
  915.     }
  917.     /**
  918.      * @Route("/top/nav", name="top_nav", methods={"GET"})
  919.      */
  920.     public function topNav(Request $request): Response
  921.     {
  922.         $maintenanceMode = ($_ENV["MAINTENANCE"] == "ENABLED") ? true : false;
  924.         return $this->render('_top_nav.html.twig', ['maintenanceMode' => $maintenanceMode]);
  925.     }
  927.     /**
  928.      * @Route("/top/notifications", name="top_notifications", methods={"GET"})
  929.      *
  930.      */
  931.     public function topNotifications(Request $request): Response
  932.     {
  933.         $notifications = $this->notificationManager->search([],['sort' => 'date_received DESC']);
  934.         $countNotRead = 0;
  935.         foreach($notifications['rows'] as $notif){
  936.             if($notif['date_read'] == ''){
  937.                 $countNotRead++;
  938.             }
  939.         }
  940.         return $this->render('_top_notifications.html.twig', ['notifications' => $notifications['rows'], 'countNotRead' => $countNotRead]);
  941.     }
  942. }