src/Controller/WHOController.php line 518

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  6. use App\Core\AccManager;
  7. use App\Core\Messages;
  8. use App\Core\Models\Events\PageLoaded;
  9. use App\Core\Models\Events\UserSettingsSave;
  10. use App\Core\Models\Quest\AbstractedQuest;
  11. use App\Core\ResearchManager;
  12. use App\WHO\Models\Quest\Report01UpdateManual;
  13. use App\WHO\Models\QuestLine;
  14. use App\WHO\Models\Report\ReportAgentAwaiting;
  15. use App\WHO\Models\Report\ReportCoAwaiting;
  16. use App\WHO\SettingsManager;
  17. use App\MyStore\API\MSJF;
  18. use App\WHO\Models\UserSettings;
  19. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  20. use Symfony\Component\HttpFoundation\JsonResponse;
  21. use Symfony\Component\HttpFoundation\Request;
  22. use Symfony\Component\HttpFoundation\Response;
  23. use Symfony\Component\Routing\Annotation\Route;
  24. use Twig\Environment;
  26. /**
  27.  * Controller used to manage qrCodes.
  28.  *
  29.  * @Route("/who")
  30.  *
  31.  */
  32. class WHOController extends AbstractController
  33. {
  34.     use  \App\Core\TraitExecSQL;
  36.     public function __construct()
  37.     {
  38.         @session_start();
  39.     }
  42.     /**
  43.      * @Route("/settings/save", methods="POST", name="whoSettingsPersists")
  44.      */
  45.     public function whoSettingsPersists(
  46.         Request $request,
  47.         SettingsManager $settingsManager,
  48.         AccManager $accManager,
  49.         MSJF $MSJF
  50.     ): Response {
  51.         if (!$accManager->currentAccId(0)) {
  52.             return new JsonResponse(['error' => 'Сессия завершена, обновите страничку и повторите операцию']);
  53.         }
  54.         $answer = ['result' => false, 'error' => 'Внутренняя ошибка сервера, мы уже работаем над ее исправлением!'];
  55.         if ($accManager->isAdmin()) {
  56.             try {
  57.                 $data = file_get_contents('php://input');
  58.                 $accId = $accManager->currentAccId();
  59.                 if (($accId) > 0) {
  60.                     $data = \json_decode($data, true);
  61.                     if (isset($data['settings'])) {
  62.                         $s = $data['settings'];
  63.                         $us = new UserSettings();
  64.                         $us::fillFromDB($us, $s);
  66.                         if (1) {
  67.                             /**
  68.                              * @TODO зарефакторить эту отправку сообщений клиенту через квесты.
  69.                              * Нужно уметь отправлять напрямую, наверное.
  70.                              */
  71.                             $ql = new AbstractedQuest($accManager);
  72.                             $ql->msgManager->reg('UPDATE_SETTINGS');
  73.                         }
  75.                         if ($saveAnswer = $settingsManager->persists($us)) {
  76.                             $answer = [
  77.                                 'result' => true,
  78.                                 'settings' => $settingsManager->loadSettings()
  79.                             ];
  80.                             /**
  81.                              * если установлена галочка, пробуем проставить вебхук на приемку.
  82.                              */
  83.                             if ($us->report01UpdateByWebhooks || $us->isCreateTaskByWebhook) {
  84.                                 try {
  85.                                     $whs = $MSJF->webhook()->all();
  86.                                 } catch (\Throwable $t) {
  87.                                     $this->logException($t);
  88.                                 }
  89.                                 if ($accId == 104) {
  90.                                     $answer['d'] = 1;
  91.                                 }
  92.                                 if (is_array($whs)) {
  93.                                     $MSJF->webhook()->create(
  94.                                         MSJF::DT_SUPPLY,
  95.                                         'https://' . $_SERVER['HTTP_HOST'],
  96.                                         $accManager->currentAccId()
  97.                                     );
  98.                                     // $ql->msgManager->reg($_SERVER['HTTP_HOST'].'::'.$accManager->currentAccId());
  99.                                 } else {
  100.                                     $ql->msgManager->reg(
  101.                                         'Для установки вебхуков приложению требуются права администратора. Переустановите приложение, пожалуйста.'
  102.                                     );
  103.                                 }
  104.                             } else {
  105.                                 $isDeleted = false;
  107.                                 try {
  108.                                     $whs = $MSJF->webhook()->all();
  109.                                 } catch (\Throwable $t) {
  110.                                     $this->logException($t);
  111.                                 }
  112.                                 if ($accId == 104) {
  113.                                     $answer['d'] = is_array($whs);
  114.                                 }
  115.                                 if (is_array($whs)) {
  116.                                     foreach ($whs as $wh) {
  117.                                         if ($wh->entityType == MSJF::DT_SUPPLY && stripos(
  118.                                                 $wh->url,
  119.                                                 $_SERVER['HTTP_HOST'],
  120.                                             ) !== false) {
  121.                                             $MSJF->webhook()->delete($wh->id);
  122.                                             $isDeleted = true;
  123.                                         }
  124.                                     }
  125.                                 }
  126.                                 if ($isDeleted) {
  127.                                     $ql->msgManager->reg('Вебхуки успешно удалены.');
  128.                                 }
  129.                             }
  130.                         } else {
  131.                             $answer = ['result' => false, 'error' => $settingsManager->getLog()];
  132.                         }
  133.                     } else {
  134.                         $answer = [
  135.                             'result' => false,
  136.                             'error' => 'Ошибка разбора запроса. Попробуйте обновить страницу и повторить.'
  137.                         ];
  138.                     }
  139.                 } else {
  140.                     $answer['error'] = 'Сессия завершена из-за отсутствия активности, обновите страницу';
  141.                 }
  142.             } catch (\Throwable $t) {
  143.                 $answer = ['result' => false, 'error' => $t->getMessage(), 'trace' => $t->getTraceAsString()];
  144.             }
  145.         } else {
  146.             $answer['error'] = 'Только администратор аккаунта может изменять настройки.';
  147.         }
  148.         return new JsonResponse($answer);
  149.     }
  151.     /**
  152.      * @Route("/settings", methods="GET", name="whoSettings")
  153.      */
  154.     public function whoSettings(
  155.         Request $request,
  156.         SettingsManager $settingsManager,
  157.         AccManager $accManager,
  158.         MSJF $MSJF
  159.     ): Response {
  160.         if (!$accManager->currentAccId(false)) {
  161.             return new JsonResponse(['error' => 'Сессия завершена, обновите страничку и повторите операцию']);
  162.         }
  163.         $MSJF->setAccount($accManager);
  164.         $this->fireEventPageLoad($accManager);
  166.         $answer = $this->generateDefTemplateAnswer($accManager, $settingsManager);
  167.         $answer['settings'] = json_decode($answer['settings']);
  169.         try {
  170.             $answer['settings']->employees = $MSJF->employee()->toSelect()->all();
  171.             usleep(500);
  172.             $answer['settings']->coStatesAsOptions = $MSJF->states()->forDocument(MSJF::DT_CUSTOMER_ORDER)->toSelect(
  173.             )->all();
  174.         } catch (\Throwable $t) {
  175.             sleep(1);
  176.             try {
  177.                 $answer['settings']->coStatesAsOptions = $MSJF->states()->forDocument(
  178.                     MSJF::DT_CUSTOMER_ORDER
  179.                 )->toSelect()->all();
  180.             } catch (\Throwable $t) {
  181.                 $this->logException($t);
  182.             }
  183.         }
  184.         $answer['settings'] = json_encode($answer['settings']);
  185.         return $this->render('who/settings.html.twig', $answer);
  186.     }
  188.     /**
  189.      * @Route("/settings/get", methods="GET", name="whoSettingsGet")
  190.      */
  191.     public function whoSettingsGet(
  192.         Request $request,
  193.         SettingsManager $settingsManager,
  194.         AccManager $accManager,
  195.         MSJF $MSJF
  196.     ): Response {
  197.         //-- проще мотануть вот эту дичь, чем создавать запросы ИМХО.
  198.         $answer = $this->generateDefTemplateAnswer($accManager, $settingsManager, false);
  200.         $answer['settings'] = json_decode($answer['settings']);
  201.         $answer['settings']->coStatesAsOptions = $MSJF->states()->forDocument(MSJF::DT_CUSTOMER_ORDER)->toSelect()->all(
  202.         );
  203.         // $answer['accId'] = $accManager->currentAccId();
  204.         // $answer['settings']->miBPMS = rand(0,1);
  205.         // $answer['settings']->miReports = rand(0,1);
  206.         return new JsonResponse($answer);
  207.     }
  209.     /**
  210.      * @Route("/report01", methods="GET", name="whoReport01")
  211.      */
  212.     public function whoReport01(Request $request, AccManager $accManager, SettingsManager $settingsManager): Response
  213.     {
  214.         $this->fireEventPageLoad($accManager);
  215.         $answer = $this->generateDefTemplateAnswer($accManager, $settingsManager);
  216.         return $this->render('who/report01.html.twig', $answer);
  217.     }
  219.     /**
  220.      * @Route("/report01/get", methods="GET", name="whoReports01Get")
  221.      */
  222.     public function whoReports01Get(
  223.         Request $request,
  224.         AccManager $accManager
  226.     ): Response {
  227.         if (!$accManager->currentAccId()) {
  228.             return new JsonResponse(['error' => 'Сессия завершена, обновите страничку и повторите операцию']);
  229.         }
  231.         $report = new ReportCoAwaiting($accManager);
  232.         $reportData = $report->getReportData();
  233.         //$reportData['result'] = array_slice( $reportData['result'] ,0,1);
  234.         if (is_array($reportData) && $reportData['updated']) {
  235.             $reportData['updatedDate'] = date('d.m.Y H:i', $reportData['updated'] ?? 0);
  236.         } else {
  237.             $reportData = ['updatedDate' => 0];
  238.         }
  239.         return new JsonResponse([
  240.                                     'report01' => $reportData,
  241.                                     'd' => date('Y-m-d'),
  242.                                     //'l' => $report->getLog()
  243.                                 ]
  244.         );
  245.     }
  247.     /**
  248.      * запрос на обновление данных по отчету.
  249.      * @Route("/report01/reload", methods="POST", name="whoReports01Reload")
  250.      */
  251.     public function whoReports01Reload(
  252.         Request $request,
  253.         AccManager $accManager
  255.     ): Response {
  256.         $this->fireEventPageLoad($accManager);
  257.         if (!$accManager->currentAccId()) {
  258.             return new JsonResponse(['error' => 'Сессия завершена, обновите страничку и повторите операцию']);
  259.         }
  261.         $updater = new Report01UpdateManual($accManager);
  262.         $updater->install();
  263.         return new JsonResponse([
  264.                                 ]
  265.         );
  266.     }
  268.     /**
  269.      * @Route("/report02", methods="GET", name="whoReport02")
  270.      */
  271.     public function whoReport02(Request $request, AccManager $accManager, SettingsManager $settingsManager): Response
  272.     {
  273.         $this->fireEventPageLoad($accManager);
  274.         /** @var Environment $twig */
  275.         $twig = $this->container->get('twig');
  276.         try {
  277.             $twig->setCache(false);
  278.             $twig->enableAutoReload();
  279.         } catch (\Throwable $t) {
  280.             print_r($t->getMessage());
  281.             die();
  282.         }
  283.         $answer = $this->generateDefTemplateAnswer($accManager, $settingsManager);
  284.         return $this->render('who/report02.html.twig', $answer);
  285.     }
  287.     /**
  288.      * @Route("/report02/get", methods="GET", name="whoReports02Get")
  289.      */
  290.     public function whoReports02Get(
  291.         Request $request,
  292.         AccManager $accManager
  294.     ): Response {
  295.         if (!$accManager->currentAccId()) {
  296.             return new JsonResponse(['error' => 'Сессия завершена, обновите страничку и повторите операцию']);
  297.         }
  299.         $report = new ReportAgentAwaiting($accManager);
  300.         $reportData = $report->getReportData();
  301.         if (is_array($reportData) && $reportData['updated']) {
  302.             $reportData['updatedDate'] = date('d.m.Y H:i', $reportData['updated'] ?? 0);
  303.         } else {
  304.             $reportData = ['updatedDate' => 0];
  305.         }
  307.         /**
  308.          * подсчет потоварной статистики.
  309.          * @TODO перенести это в формирование отчета!
  310.          */
  311.         $byAssortmentId = [];
  312.         $rData = $reportData['result'];
  313.         if (is_array($rData)) {
  314.             foreach ($rData as $supplierInfo) {
  315.                 foreach ($supplierInfo['positions'] as $order) {
  316.                     $assortmentId = $order['position']['assortment']['id'];
  317.                     $storeId = $order['store']['id'];
  318.                     if (!isset($byAssortmentId[$assortmentId])) {
  319.                         $byAssortmentId[$assortmentId] = [];
  320.                     }
  321.                     if (!isset($byAssortmentId[$assortmentId][$storeId])) {
  322.                         $byAssortmentId[$assortmentId][$storeId] = [
  323.                             'assortment' => $order['position']['assortment'],
  324.                             'quantity' => 0,
  325.                             'intransit' => 0,
  326.                             'stock' => 0,
  327.                             'expectedDate' => $order['position']['expectedDate'] ?? '-',
  328.                             'storeName' => $order['store']['name'],
  329.                         ];
  330.                     }
  331.                     $byAssortmentId[$assortmentId][$storeId]['stock'] = $order['position']['stock']['quantity'];
  332.                     $byAssortmentId[$assortmentId][$storeId]['quantity'] += $order['position']['quantity'];
  333.                     $byAssortmentId[$assortmentId][$storeId]['intransit'] = $order['position']['stock']['intransit'];
  334.                 }
  335.             }
  336.         }
  337.         $reportData['assortment'] = $byAssortmentId;
  338.         return new JsonResponse([
  339.                                     'report02' => $reportData,
  340.                                     'd' => date('Y-m-d'),
  341.                                     //'l' => $report->getLog()
  342.                                 ]
  343.         );
  344.     }
  346.     /**
  347.      * отменяет всё, что было сделано в аккаунте.
  348.      * @Route("/reset", methods="POST", name="whoSettingsReset")
  349.      */
  350.     public function whoSettingsReset(
  351.         Request $request,
  352.         SettingsManager $settingsManager,
  353.         AccManager $accManager
  354.     ): Response {
  355.         if (!$accManager->currentAccId()) {
  356.             return new JsonResponse(['error' => 'Сессия завершена, обновите страничку и повторите операцию']);
  357.         }
  358.         $answer = ['result' => false, 'error' => 'Внутренняя ошибка сервера, мы уже работаем над ее исправлением!'];
  359.         if ($accManager->isAdmin()) {
  360.             try {
  361.                 $data = file_get_contents('php://input');
  362.                 $accId = $accManager->currentAccId();
  363.                 if (($accId) > 0) {
  364.                     $data = \json_decode($data, true);
  366.                     $us = new UserSettings();
  367.                     $sm = new SettingsManager($accManager);
  368.                     $sm->persists($us);
  370.                     $ql = new QuestLine($accManager);
  371.                     $ql->fillLine4Acc(['Core', 'WHO']);
  372.                     $msg = new Messages($accManager);
  373.                     $msg->reg('База данных аккаунта очищена, все настройки удалены');
  374.                     $msg->reg('UPDATE_SETTINGS');
  377.                     if ($saveAnswer = $settingsManager->persists($us)) {
  378.                         $response = $this->forward('App\Controller\WHOController::whoSettingsGet', [
  379.                         ]);
  380.                         return $response;
  381.                     } else {
  382.                         $answer = ['result' => false, 'error' => $settingsManager->getLog()];
  383.                     }
  384.                 } else {
  385.                     $answer = [
  386.                         'result' => false,
  387.                         'error' => 'Ошибка разбора запроса. Попробуйте обновить страницу и повторить.'
  388.                     ];
  389.                 }
  390.             } catch (\Throwable $t) {
  391.                 $answer = ['result' => false, 'error' => $t->getMessage(), 'trace' => $t->getTraceAsString()];
  392.             }
  393.         } else {
  394.             $answer['error'] = 'Только администратор аккаунта может изменять настройки.';
  395.         }
  396.         return new JsonResponse($answer);
  397.     }
  399.     public function generateDefTemplateAnswer(
  400.         AccManager $accManager,
  401.         SettingsManager $settingsManager,
  402.         $isRegEvent = true
  403.     ) {
  404.         $settings = $settingsManager->loadSettings();
  405.         $questLine = new QuestLine($accManager);
  406.         $settings->activeQuests = $questLine->getActiveQuests();
  407.         $settings->role = $accManager->isAdmin() ? 'admin' : 'user';
  408.         $settings->expCurrent = $questLine->calcCurrentExp();
  409.         $settings->expMax = 2000;
  410.         $settings->lvl = 0;
  411.         $settings->version = 220301;
  412.         $settings->company = $accManager->getName4Acc($accManager->currentAccId());
  413.         $settings->sid = session_id();
  414.         $settings->accId = $accManager->currentAccId();
  416.         return [
  417.             'settings' => \json_encode($settings),
  418.             'role' => $accManager->isAdmin() ? 'admin' : 'user',
  419.         ];
  420.     }
  422.     protected function fireEventPageLoad(AccManager $accManager)
  423.     {
  424.         if ($accId = $accManager->currentAccId()) {
  425.             $questLine = new QuestLine($accManager);
  426.             try {
  427.                 $pageRoute = debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS, 2)[1]['function'];
  428.             } catch (\Throwable $t) {
  429.                 $this->logException($t);
  430.                 $pageRoute = '';
  431.             }
  432.             try {
  433.                 $e = (new PageLoaded())->setRoute($pageRoute);
  434.                 $questLine->fireEvent($e);
  435.             } catch (\Throwable $t) {
  436.                 $this->logException($t);
  437.             }
  438.             return $pageRoute;
  439.         } else {
  440.             return false;
  441.         }
  442.     }
  445.     /**
  446.      * @Route("/laboratory", methods="GET", name="whoLabs")
  447.      */
  448.     public function whoLabs(
  449.         Request $request,
  450.         SettingsManager $settingsManager,
  451.         AccManager $accManager,
  452.         MSJF $MSJF
  453.     ): Response {
  454.         //$accManager->setAccId($_SESSION['ad']);
  455.         $accManager->currentAccId();
  456.         $MSJF->setAccount($accManager);
  457.         $this->fireEventPageLoad($accManager);
  459.         $answer = $this->generateDefTemplateAnswer($accManager, $settingsManager);
  460.         $answer['settings'] = json_decode($answer['settings']);
  462.         $answer['settings'] = json_encode($answer['settings']);
  463.         return $this->render('who/lab.html.twig', $answer);
  464.     }
  467.     /**
  468.      * @Route("/research/get", methods="GET", name="whoLabGetResearch")
  469.      */
  470.     public function whoLabGetResearch(
  471.         Request $request,
  472.         SettingsManager $settingsManager,
  473.         AccManager $accManager,
  474.         ResearchManager $researchManager
  475.     ): Response {
  476.         if (!$accManager->currentAccId()) {
  477.             die('Сессия завершена из-за отсутствия активности, обновите страничку и повторите операцию');
  478.         }
  479.         $this->fireEventPageLoad($accManager);
  481.         $answer = [
  482.             'research' => $researchManager->load(1)
  483.         ];
  486.         return new JsonResponse($answer);
  487.     }
  489.     /**
  490.      * @Route("/empl/test", methods="GET", name="whoTest")
  491.      */
  492.     public function whoTest(
  493.         Request $request,
  494.         SettingsManager $settingsManager,
  495.         AccManager $accManager,
  496.         MSJF $MSJF
  497.     ): Response {
  498.         var_dump($accManager->currentAccId());
  499.         if (!$accManager->currentAccId()) {
  500.             die('Сессия завершена из-за отсутствия активности, обновите страничку и повторите операцию');
  501.         }
  502.         $MSJF->setAccount($accManager);
  503.         $this->fireEventPageLoad($accManager);
  505.         $answer = $this->generateDefTemplateAnswer($accManager, $settingsManager);
  506.         $answer['settings'] = json_decode($answer['settings']);
  507.         $answer['settings']->coStatesAsOptions = $MSJF->states()->forDocument(MSJF::DT_CUSTOMER_ORDER)->toSelect()->all(
  508.         );
  509.         $answer['settings'] = json_encode($answer['settings']);
  510.         $customerController = 'App\Controller\Customer\User' . $_SESSION['ad'] . 'Controller::' . ($_GET['ac'] ?? 'defAction');
  511.         $response = $this->forward($customerController, ['answer' => $answer]);
  512.         return $response;
  513.     }
  515.     /**
  516.      * @Route("/ping", methods="GET", name="whoPingMessages")
  517.      */
  518.     public function whoPingMessages(
  519.         Request $request,
  520.         SettingsManager $settingsManager,
  521.         AccManager $accManager,
  522.         Messages $messages
  523.     ): Response {
  524.         $answer = ['result' => false, 'error' => 'Внутренняя ошибка сервера, мы уже работаем над ее исправлением!'];
  526.         if (!$accManager->currentAccId()) {
  527.             $answer['error'] = 'Сессия завершена из-за отсутствия активности, обновите страницу';
  528.         }
  530.         $answer = ['result' => true];
  531.         unset($answer['error']);
  533.         $msg = $messages->getMessages4UI();
  534.         //$msg[1] = 'EMIT_on-update-users';
  535.         //$msg[1] = 'UPDATE_SETTINGS';
  537.         if (sizeof($msg)) {
  538.             $answer['messages'] = $msg;
  539.         }
  540.         //
  541.         $answer['s'] = $accManager->currentAccId();
  542.         return new JsonResponse($answer);
  543.     }
  545.     protected function _cleanTwigCache(): void
  546.     {
  547.         /** @var Environment $twig */
  548.         $twig = $this->container->get('twig');
  549.         try {
  550.             $twig->setCache(false);
  551.             $twig->enableAutoReload();
  552.         } catch (\Throwable $t) {
  553.             print_r($t->getMessage());
  554.             die();
  555.         }
  556.     }
  557. }