src/Controller/WelcomeController.php line 353

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\LoginLog;
  6. use App\Repository\AwbexportRepository;
  7. use App\Repository\C4rgoNewsRepository;
  8. use App\Repository\DecodeRepository;
  9. use App\Repository\LoginLogRepository;
  10. use App\Repository\LuoghiRepository;
  11. use App\Repository\UserRepository;
  12. use App\Repository\VettoriRepository;
  13. use App\Services\OktaApiService;
  14. use App\Utils\Counters;
  15. use App\Utils\Formatter;
  16. use Doctrine\ORM\EntityManagerInterface;
  17. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  18. use Symfony\Component\HttpFoundation\JsonResponse;
  19. use Symfony\Component\HttpFoundation\Request;
  20. use Symfony\Component\HttpFoundation\Response;
  21. use Symfony\Component\HttpFoundation\Session\Session;
  22. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  23. use Symfony\Component\Routing\Annotation\Route;
  24. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  25. use Symfony\Component\Security\Core\Authentication\Token\UsernamePasswordToken;
  26. use Symfony\Contracts\Translation\TranslatorInterface;
  28. class WelcomeController extends AbstractController
  29. {
  30. private SessionInterface $session;
  31. private OktaApiService $okta;
  32. private UserRepository $userRepository;
  33. private EntityManagerInterface $em;
  34. private VettoriRepository $vettoriRepository;
  35. private LuoghiRepository $luoghiRepository;
  36. private LoginLogRepository $loginLogRepository;
  37. private DecodeRepository $decodeRepository;
  38. private C4rgoNewsRepository $c4rgoNewsRepository;
  39. private AwbexportRepository $awbexportRepository;
  40. private TokenStorageInterface $tokenStorage;
  42. public function __construct(
  43. SessionInterface $session,
  44. OktaApiService $okta,
  45. UserRepository $UserRepository,
  46. EntityManagerInterface $em,
  47. VettoriRepository $vettoriRepository,
  48. LuoghiRepository $luoghiRepository,
  49. LoginLogRepository $loginLogRepository,
  50. DecodeRepository $decodeRepository,
  51. C4rgoNewsRepository $c4rgoNewsRepository,
  52. AwbexportRepository $awbexportRepository,
  53. TokenStorageInterface $tokenStorage
  54. ) {
  55. $this->session = $session;
  56. $this->okta = $okta;
  57. $this->userRepository = $UserRepository;
  58. $this->em = $em;
  59. $this->vettoriRepository = $vettoriRepository;
  60. $this->luoghiRepository = $luoghiRepository;
  61. $this->loginLogRepository = $loginLogRepository;
  62. $this->decodeRepository = $decodeRepository;
  63. $this->c4rgoNewsRepository = $c4rgoNewsRepository;
  64. $this->awbexportRepository = $awbexportRepository;
  65. $this->tokenStorage = $tokenStorage;
  66. }
  68. protected function getValue(TranslatorInterface $translator, Counters $counters, string $data = "D", string $filtri = "N") {
  70. /* Anagrafiche utente loggato */
  71. $filtriVect = explode('&', $filtri);
  72. $delivered = FALSE;
  73. $mode = FALSE;
  74. $warehouse = FALSE;
  75. $customer = FALSE;
  76. foreach($filtriVect as $val) {
  77. $v = explode("=", $val);
  78. if (count($v) == 2 && $v[1] !== 'null') {
  79. switch($v[0]) {
  80. case 'delivered':
  81. $delivered = $v[1];
  82. break;
  83. case 'mode':
  84. $mode = $v[1];
  85. break;
  86. case 'warehouse':
  87. $warehouse = $v[1];
  88. break;
  89. case 'customer':
  90. $customer = $v[1];
  91. break;
  92. }
  93. }
  94. }
  95. // throw new \Exception(print_r($customer, true));
  96. $counters->setGlobalFilter($delivered, $mode, $warehouse, $customer);
  97. $user = $this->getUser();
  98. $profilo = $user->getProfilo();
  99. $azienda = $user->getAzienda();
  100. if ($this->isGranted('ROLE_ALL_LOC')) {
  101. $vettori = $this->vettoriRepository->findAll();
  102. $luoghi = $this->luoghiRepository->findAll();
  103. }
  104. else {
  105. $vettori = $this->vettoriRepository->findByCliente($azienda->getId());
  106. $luoghi = $this->luoghiRepository->findByAzienda($azienda);
  107. }
  108. $loginLog = $this->loginLogRepository->findOneByUserId($user);
  109. $formattatore = new Formatter();
  111. /* Tempi medi macchina / persona */
  112. $tempo_medio_macchina = (double) $this->decodeRepository->getDECValue("CONFIG", "tempo.medio.macchina");
  113. $tempo_medio_persona = (double) $this->decodeRepository->getDECValue("CONFIG", "tempo.medio.persona");
  115. $news = $this->c4rgoNewsRepository->findPub();
  117. $awbRep = $this->awbexportRepository;
  119. $d = new \DateTime();
  120. if ($data !== '') {
  121. if (strlen($data) > 1) {
  122. $d = new \DateTime(substr($data, 1));
  123. }
  124. /* else {
  125. if ($data == 'L') {
  126. $em = $this->getDoctrine()->getManager();
  127. $stmt = $em->getConnection()->prepare(" SELECT MAX(DataIns) AS dt FROM awbexport ");
  128. $results = $stmt->executeQuery()->fetchAllAssociative();
  129. if ($results !== null && count($results) > 0) {
  130. $d = new \DateTime($results[0]['dt']);
  131. }
  132. else {
  133. $d = new \DateTime();
  134. }
  135. }
  136. }*/
  137. }
  139. // throw new \Exception($d->format("Y"));
  140. $rilday = "";
  141. $nawb = $counters->countAWB($d->format("Y-m-d"));
  142. $nawbY = $counters->countAWB("Y" . $d->format("Y"));
  144. // $nawby = $awbRep->countAWB("Y");
  145. $sumV = $awbRep->sumV($d->format("Y-m-d"));
  146. $sumW = 0; //$counters->totaliPesi("D" . $d->format("Y"));
  147. // $sumW = $awbRep->sumW($d->format("Y-m-d"));
  148. $countRec = $awbRep->countRec($d->format("Y-m-d"));
  150. $countRecY = $awbRep->countRec("Y" . $d->format("Y"));
  151. $tottempoelaborazionedati = 0;
  152. $tottemporisparmiato = 0;
  153. if ($tempo_medio_persona !== null && $tempo_medio_macchina !== null && $countRecY !== null) {
  154. $tottemporisparmiato = (double)(($tempo_medio_persona - $tempo_medio_macchina) * $countRecY) / 3600.0;
  155. }
  156. if ($tempo_medio_macchina !== null && $countRecY !== null) {
  157. $tottempoelaborazionedati = (double)($tempo_medio_macchina * $countRecY) / 3600.0;
  158. }
  159. $differenzaGiorni = 5;
  160. $dMin7 = clone $d;
  161. $dMin7->sub(new \DateInterval("P{$differenzaGiorni}D"));
  163. $giornitot = $counters->totaliGiorni("P" . $d->format("Y-m-d"));
  164. $giorni = $counters->totaliGiorni("D" . $d->format("Y-m-d"));
  165. $giornisettimana = $counters->totaliGiorni("W" . $d->format("Y-W"));
  166. $giornimese = $counters->totaliGiorni("M" . $d->format("Y-m"));
  168. $pesitot = $counters->totaliPesi("P" . $d->format("Y-m-d"));
  169. $pesigiorno = $counters->totaliPesi("D" . $d->format("Y-m-d"));
  170. $pesisettimana = $counters->totaliPesi("W" . $d->format("Y-W"));
  171. $pesimese = $counters->totaliPesi("M" . $d->format("Y-m"));
  173. if ($giornitot !== FALSE && $pesitot !== FALSE) {
  174. $pesigiornomedio = ($giornitot > 0) ? ((float) $pesitot['valore']) / ((float) $giornitot) : 0.0;
  175. $pesigiornomediogiorno = $pesigiornomedio * $giorni;
  176. $pesigiornomediosettimana = $pesigiornomedio * $giornisettimana;
  177. $pesigiornomediomese = $pesigiornomedio * $giornimese;
  179. $pesigiornoincrementogiorno = ((int) ($pesigiornomediogiorno * 1000) > 0) ? ((((float) $pesigiorno['valore']) / $pesigiornomediogiorno) - 1) * 100.0 : FALSE;
  180. $pesigiornoincrementosettimana = ((int) ($pesigiornomediosettimana * 1000) > 0) ? ((((float) $pesisettimana['valore']) / $pesigiornomediosettimana) - 1) * 100.0 : FALSE;
  181. $pesigiornoincrementomese = ((int) ($pesigiornomediomese * 1000) > 0) ? ((((float) $pesimese['valore']) / $pesigiornomediomese) - 1) * 100.0 : FALSE;
  182. }
  183. else {
  184. $pesigiornoincrementogiorno = FALSE;
  185. $pesigiornoincrementosettimana = FALSE;
  186. $pesigiornoincrementomese = FALSE;
  187. }
  189. $volumitot = $counters->totaliVolumi("P" . $d->format("Y-m-d"));
  190. $volumigiorno = $counters->totaliVolumi("D" . $d->format("Y-m-d"));
  191. $volumisettimana = $counters->totaliVolumi("W" . $d->format("Y-W"));
  192. $volumimese = $counters->totaliVolumi("M" . $d->format("Y-m"));
  193. if ($giornitot !== FALSE && $volumitot !== FALSE) {
  194. $volgiornomedio = ($giornitot > 0) ? ((float) $volumitot['valore']) / ((float) $giornitot) : 0.0;
  195. $volgiornomediogiorno = $volgiornomedio * $giorni;
  196. $volgiornomediosettimana = $volgiornomedio * $giornisettimana;
  197. $volgiornomediomese = $volgiornomedio * $giornimese;
  199. $volgiornoincrementogiorno = ((int) ($volgiornomediogiorno * 1000) > 0) ? ((((float) $volumigiorno['valore']) / $volgiornomediogiorno) - 1) * 100.0 : FALSE;
  200. $volgiornoincrementosettimana = ((int) ($volgiornomediosettimana * 1000) > 0) ? ((((float) $volumisettimana['valore']) / $volgiornomediosettimana) - 1) * 100.0 : FALSE;
  201. $volgiornoincrementomese = ((int) ($volgiornomediomese * 1000) > 0) ? ((((float) $volumimese['valore']) / $volgiornomediomese) - 1) * 100.0 : FALSE;
  202. }
  203. else {
  204. $volgiornoincrementogiorno = FALSE;
  205. $volgiornoincrementosettimana = FALSE;
  206. $volgiornoincrementomese = FALSE;
  207. }
  209. $objtot = $counters->conteggiObj("P" . $d->format("Y-m-d"));
  210. $objgiorno = $counters->conteggiObj("D" . $d->format("Y-m-d"));
  211. if ($giornitot !== FALSE && $objtot !== FALSE) {
  212. $awbgiornomediogiorno = (float) (($giornitot > 0) ? ((float) $objtot['nawb']) / ((float) $giornitot) : 0.0) * $giorni;
  213. $objgiornomediogiorno = (($giornitot > 0) ? ((float) $objtot['nobj']) / ((float) $giornitot) : 0.0) * $giorni;
  214. $ncolligiornomediogiorno = (($giornitot > 0) ? ((float) $objtot['ncolli']) / ((float) $giornitot) : 0.0) * $giorni;
  216. $awbgiornoincrementogiorno = ((int) ($awbgiornomediogiorno * 1000) > 0) ? ((((float) $objtot['nawb']) / $awbgiornomediogiorno) - 1) * 100.0 : FALSE;
  217. $objgiornoincrementogiorno = ((int) ($objgiornomediogiorno * 1000) > 0) ? ((((float) $objtot['nobj']) / $objgiornomediogiorno) - 1) * 100.0 : FALSE;
  218. $ncolligiornoincrementogiorno = ((int) ($ncolligiornomediogiorno * 1000) > 0) ? ((((float) $objtot['ncolli']) / $ncolligiornomediogiorno) - 1) * 100.0 : FALSE;
  219. }
  220. else {
  221. $awbgiornomediogiorno = 0;
  222. $objgiornomediogiorno = 0;
  223. $ncolligiornomediogiorno = 0;
  224. $awbgiornoincrementogiorno = FALSE;
  225. $objgiornoincrementosettimana = FALSE;
  226. $ncolligiornoincrementomese = FALSE;
  227. }
  230. // throw new \Exception($d->format("Y") . " $pesigiornomediogiorno = $pesigiornomedio * $giorni $pesigiornoincrementogiorno $pesigiornoincrementosettimana $pesigiornoincrementomese $giornitot $giorni $giornisettimana $giornimese {$pesitot['valore']} {$pesigiorno['valore']} {$pesisettimana['valore']} {$pesimese['valore']} {$volumitot['valore']} {$volumigiorno['valore']} {$volumisettimana['valore']} {$volumimese['valore']}");
  231. $totpesianno = $counters->totaliPesi("A" . $d->format("Y"));
  232. $totpesigiorno = $counters->totaliPesi("D" . $d->format("Y-m-d"));
  233. $totpesiannoparziale = $counters->totaliPesi("P" . $d->format("Y-m-d"));
  234. if ($totpesigiorno !== false) {
  235. if ($totpesiannoparziale !== FALSE) {
  236. $tempPesi = ((float) $totpesianno['valore']) - ((float) $totpesigiorno['valore']);
  237. }
  238. else {
  239. $tempPesi = (float) $totpesigiorno['valore'];
  240. }
  241. $incremento = ($tempPesi > 0) ? ((float) $totpesigiorno['valore'] / $tempPesi) * 100.0 : 0.0;
  242. }
  244. $sospesi = $counters->contaSospesi('A' . $d->format("Y"));
  245. $sql = "
  246. SELECT d.decvalue, IFNULL(t.termine, IFNULL(tdef.termine, d.decvalue)) AS termine
  247. FROM
  248. decode as d LEFT JOIN
  249. traduzioni AS t ON d.decvalue = t.idtermine AND t.area = 3 AND t.codice = ? LEFT JOIN
  250. traduzioni AS tdef ON d.decvalue = tdef.idtermine AND tdef.area = 3 AND tdef.codice = 'en'
  251. WHERE
  252. d.decclass = 'TIPOVETTORE'
  253. ORDER BY d.decorder ASC
  254. ";
  255. $stmt = $this->em->getConnection()->prepare($sql);
  256. $stmt->bindValue(1, $translator->getLocale(), \PDO::PARAM_STR);
  257. $deliveredby = $stmt->executeQuery()->fetchAllAssociative();
  258. //throw new \Exception(print_r($loginLog->getGeoLoc(), true));
  260. $loghipath = $this->getParameter('logo_path');
  261. $logoUrl = '';
  262. if ($azienda !== null) {
  263. $logoUrl = "$loghipath/" . $azienda->getLogo();
  264. }
  267. return [
  268. 'controller_name' => 'WelcomeController',
  269. 'deliveredby' => $deliveredby,
  270. 'data' => $data,
  271. 'delivered' => $delivered,
  272. 'mode' => $mode,
  273. 'warehouse' => $warehouse,
  274. 'customer' => $customer,
  275. 'target_annuale' => $translator->trans('welcome.on.target.year', array('%year%' => $d->format('Y'))),
  276. 'news' => $news,
  277. 'rilday' => $rilday,
  278. 'awbgestite' => $nawb,
  279. 'awbgestiteanno' => $nawbY,
  280. 'datenow' => $d,
  281. 'tempomediocollo' => $tempo_medio_macchina,
  282. 'recordstrasferiti' => $countRec,
  283. 'volumirilevati' => $formattatore->floatValue(($sumV === null) ? 0 : $sumV, 2, "", ""),
  284. 'pesirilevati' => $formattatore->floatValue(($sumW === null) ? 0: $sumW, 2, "", ""),
  286. 'totvolumirilevati' => $counters->totaliVolumi("A" . $d->format("Y")),
  287. 'totpesirilevati' => $counters->totaliPesi("A" . $d->format("Y")),
  289. 'pesigiornoincrementogiorno' => $pesigiornoincrementogiorno,
  290. 'pesigiornoincrementosettimana' => $pesigiornoincrementosettimana,
  291. 'pesigiornoincrementomese' => $pesigiornoincrementomese,
  293. 'pesigiorno' => $pesigiorno,
  294. 'pesisettimana' => $pesisettimana,
  295. 'pesimese' => $pesimese,
  297. 'volgiornoincrementogiorno' => $volgiornoincrementogiorno,
  298. 'volgiornoincrementosettimana' => $volgiornoincrementosettimana,
  299. 'volgiornoincrementomese' => $volgiornoincrementomese,
  301. 'volumigiorno' => $volumigiorno,
  302. 'volumisettimana' => $volumisettimana,
  303. 'volumimese' => $volumimese,
  304. 'awbgiornomediogiorno' => $awbgiornomediogiorno,
  305. 'objgiornomediogiorno' => $objgiornomediogiorno,
  306. 'ncolligiornomediogiorno' => $ncolligiornomediogiorno,
  307. 'objgiorno' => $objgiorno,
  308. 'totpesigiorno' => array('valore' => $totpesianno, 'incremento' => ''),
  309. // Pesi espressi in grammi: minore o uguale a 100,999, maggiore di 100,999 e minore o uguale a 1000,999 e maggiore di 1000,999
  310. 'pesilimiti' => $counters->contaPesiLimiti("A" . $d->format("Y"), [100999, 1000999]),
  311. 'pesinocongruita' => $counters->totaliPesiNoCongruita("A" . $d->format("Y")),
  312. // Volumi espressi in Mc * 1000: minore o uguale a 5,999, maggiore di 5,999 e minore o uguale a 30,999 e maggiore di 30,999
  313. 'volumilimiti' => $counters->contaVolumiLimiti("A" . $d->format("Y"), [999, 5999]),
  314. 'voluminocongruita' => $counters->totaliVolumiNoCongruita("A" . $d->format("Y")),
  316. // 'awbsosspese' => $counters->contaSospesi("R" . $dMin7->format("Y-m-d") . ';' . $d->format("Y-m-d")),
  317. 'awbsosspese' => ($sospesi !== FALSE) ? $sospesi['valore'] : '', //$counters->contaSospesi('R;' . $d->format("Y-m-d"))['val'],
  318. 'awbsosspesediffgiorni' => ($sospesi !== FALSE) ? $sospesi['data']->diff($d)->format("%a") : '', // $differenzaGiorni,
  320. 'tottemporisparmiato' => $formattatore->floatValue($tottemporisparmiato, 2, "", ""),
  321. 'totrecordtrasferiti' => $countRecY,
  322. 'tottempoelaborazionedati' => $formattatore->floatValue($tottempoelaborazionedati, 2, "", ""),
  323. 'numluoghi' => count($luoghi),
  324. 'listaluoghi' => $luoghi,
  325. 'listavettori' => $vettori,
  326. 'pageicon' => 'fa fa-search',
  327. 'logoazienda' => $azienda->getLogo(),
  328. 'logoUrl' => $logoUrl,
  329. 'fullname' => ($profilo !== null) ? $profilo->getNome() . ' ' . $profilo->getCognome() : $user->getFullname(),
  330. 'lastlogin' => ($loginLog != null) ? $loginLog->getDataLogin() : null,
  331. 'lastlogininfo' => ($loginLog != null) ? $loginLog->getGeoLoc() : null,
  332. 'filtri' => $filtri,
  333. ];
  336. }
  338. /**
  339. * @Route("/welcomejson", name="welcome_json", defaults={"data": "D"})
  340. * @Route("/welcomejson/{data}", name="welcome_json", defaults={"data": "D"})
  341. * @Route("/welcomejson/{data}/{filtri}", name="welcome_json", defaults={"data": "D","filtri":"N"})
  342. */
  343. public function welcomejson(TranslatorInterface $translator, Counters $counter, string $data = "D", string $filtri = "N"): JsonResponse {
  344. $value = $this->getValue($translator, $counter, $data, $filtri);
  345. return new JsonResponse($value);
  346. }
  348. /**
  349. * @Route("/secwelcome", name="welcome_page", defaults={"data": "D"})
  350. * @Route("/secwelcome/{data}", name="welcome_page", defaults={"data": "D"})
  351. * @Route("/secwelcome/{data}/{filtri}", name="welcome_page", defaults={"data": "D","filtri":"N"})
  352. */
  353. public function index(Session $session, TranslatorInterface $translator, Counters $counter, string $data = "D", string $filtri = "N")
  354. {
  356. $value = $this->getValue($translator, $counter, $data, $filtri);
  357. return $this->render('welcome/index.html.twig', $value);
  359. }
  361. private function LoginLog($user, $username, $action, $attuale, $request) {
  362. $ip = $request->getClientIp();
  363. $location = unserialize(file_get_contents('https://ipinfo.io/' . $ip . '/json')); //$_SERVER['REMOTE_ADDR']);
  364. $loginLog = new LoginLog();
  365. $loginLog->setUser($user);
  366. $loginLog->setUsername($username);
  367. $loginLog->setDataLogin(new \DateTime());
  368. $loginLog->setAttuale($attuale);
  369. $loginLog->setAAction($action);
  370. $loginLog->setAIp($ip);
  371. $loginLog->setAAgent($request->headers->get('User-Agent'));
  372. $loginLog->setGeoLoc($location);
  373. $this->em->persist($loginLog);
  374. $this->em->flush();
  375. }
  376. /**
  377. * @Route("/welcome", name="callbackwelcome_page")
  378. */
  379. public function callback(Request $request, Session $session, TranslatorInterface $translator)
  380. {
  382. $token = $this->okta->authorizeUser($request);
  383. if (!$token) {
  384. $this->LoginLog(null, "", 9005, 0, $request);
  385. return $this->redirectToRoute('security_errorlogin');
  386. }
  387. //throw new \Exception(print_r($token, true));
  388. $email = $token->email;
  389. $username = $token->preferred_username;
  390. $username = str_replace('@ent.bhicorp.com', '', $username);
  391. $user = $this->userRepository->loadUserByUsername($username);
  393. if ($user) {
  394. //throw new \Exception(print_r($token, true));
  395. $token = new UsernamePasswordToken($user, null, 'main', $user->getRoles());
  396. $this->tokenStorage->setToken($token);
  397. $this->session->set('_security_main', serialize($token));
  398. $query = "
  399. UPDATE login_log
  400. SET
  401. attuale = 0
  402. WHERE
  403. user_id = ?";
  404. $statement = $this->em->getConnection()->prepare($query);
  405. $statement->bindValue(1, $user->getId(), \PDO::PARAM_INT);
  406. $statement->execute();
  407. $this->LoginLog($user, $username, 9002, 1, $request);
  408. if ($this->getParameter('app.site_online') === 'Y') {
  409. return $this->redirectToRoute('welcome_page');
  410. }
  411. else {
  412. return $this->redirectToRoute('monitor_page');
  413. }
  414. } else {
  415. $this->LoginLog(null, $username, 9004, 0, $request);
  416. return $this->redirectToRoute('security_errorlogin');
  417. }
  418. }
  420. }