src/Controller/DebugController.php line 155

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Service\Features;
  6. use Symfony\Bundle\FrameworkBundle\Console\Application;
  7. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  8. use Symfony\Component\Console\Input\ArrayInput;
  9. use Symfony\Component\Console\Output\BufferedOutput;
  10. use Symfony\Component\Console\Output\NullOutput;
  11. use Symfony\Component\HttpFoundation\Request;
  12. use Symfony\Component\HttpFoundation\Response;
  13. use Symfony\Component\HttpKernel\Exception\UnauthorizedHttpException;
  14. use Symfony\Component\HttpKernel\KernelInterface;
  15. use Symfony\Component\Routing\Annotation\Route;
  17. class DebugController extends AbstractController
  18. {
  19.     private KernelInterface $kernel;
  20.     private Application $application;
  22.     public function __construct(KernelInterface $kernel)
  23.     {
  24.         $this->kernel = $kernel;
  26.         $this->application = new Application($this->kernel);
  27.         $this->application->setAutoExit(false);
  28.     }
  30.     #[Route(path: '/debug-features/', name: 'debug.task.debug_features')]
  31.     public function debugFeatures(Features $features): Response
  32.     {
  33.         $this->assertAvailable();
  35.         $features = [];
  36.         foreach ($_ENV as $k => $v) {
  37.             if(str_starts_with($k, 'FEATURE'))
  38.                 $features[$k] = $v;
  39.         }
  40.         ksort($features);
  42.         return $this->json($features);
  43.     }
  45.     #[Route(path: '/task-charge-placed/', name: 'debug.task.charge_placements')]
  46.     public function taskChargePlacements(): Response
  47.     {
  48.         return $this->getResponse($this->runCommand('sales:profile-saloon:adboard:charge'));
  49.     }
  51.     #[Route(path: '/task-charge-hidden/', name: 'debug.task.charge_hidings')]
  52.     public function taskChargeHidings(): Response
  53.     {
  54.         return $this->getResponse($this->runCommand('sales:profile:hiding:charge'));
  55.     }
  57.     #[Route(path: '/task-profiles-rotate/', name: 'debug.task.profiles.rotate')]
  58.     public function taskProfilesRotate(): Response
  59.     {
  60.         $output = $this->runCommand('sales:profile:adboard:rotate');
  62.         return $this->getResponse($output);
  63.     }
  65.     #[Route(path: '/task-saloons-rotate/', name: 'debug.task.saloons.rotate')]
  66.     public function taskSaloonsRotate(): Response
  67.     {
  68.         $output = $this->runCommand('sales:saloon:adboard:rotate');
  70.         return $this->getResponse($output);
  71.     }
  73.     #[Route(path: '/task-rotate/', name: 'debug.task.rotate')]
  74.     public function taskRotate(): Response
  75.     {
  76.         $output = $this->runCommand('sales:profile:adboard:rotate');
  77.         $output .= $this->runCommand('sales:saloon:adboard:rotate');
  79.         return $this->getResponse($output);
  80.     }
  82.     #[Route(path: '/task-profiles-rotate-free/', name: 'debug.task.profiles.rotate_free')]
  83.     public function taskProfilesRotateFree(): Response
  84.     {
  85.         return $this->getResponse($this->runCommand('sales:profile:adboard:rotate-free'));
  86.     }
  88.     #[Route(path: '/task-profiles-align/', name: 'debug.task.profiles.align')]
  89.     public function taskProfilesAlign(): Response
  90.     {
  91.         $output = $this->runCommand('sales:profile:adboard:align-positions');
  93.         return $this->getResponse($output);
  94.     }
  96.     #[Route(path: '/task-profiles-delete-rejected-on-moderation/', name: 'debug.task.profiles.delete_rejected_on_moderation')]
  97.     public function taskProfilesDeleteRejectedOnModeration(): Response
  98.     {
  99.         return $this->getResponse($this->runCommand('update:profiles:delete-rejected-on-moderation', [], ['interval' => '5 MINUTE']));
  100.     }
  102.     #[Route(path: '/task-users-set-trusted/', name: 'debug.task.users.set_trusted')]
  103.     public function taskUsersSetTrusted(): Response
  104.     {
  105.         return $this->getResponse($this->runCommand('update:users:set-trusted'));
  106.     }
  108.     #[Route(path: '/task-users-low-balance-notification/', name: 'debug.task.users.low_balance_notification')]
  109.     public function taskUsersLowBalanceNotification(): Response
  110.     {
  111.         return $this->getResponse($this->runCommand('sales:user:low-balance:notify'));
  112.     }
  114.     #[Route(path: '/task-persist-ctr-values-permanent/', name: 'debug.task.profile_ctr.persist_permanent')]
  115.     public function taskPersistCtrValuesPermanent(): Response
  116.     {
  117.         return $this->getResponse($this->runCommand('maintenance:profile-ctr:persist-permanent'));
  118.     }
  120.     #[Route(path: '/task-clear-ctr-values-cache/', name: 'debug.task.profile_ctr.clear_cache')]
  121.     public function taskClearCtrValuesCache(): Response
  122.     {
  123.         return $this->getResponse($this->runCommand('maintenance:profile-ctr:clear-cache'));
  124.     }
  126.     #[Route(path: '/task-refresh-cold-start-recommendations/', name: 'debug.task.recommendations.cold_start.refresh')]
  127.     public function taskRefreshColdStartRecommendations(): Response
  128.     {
  129.         return $this->getResponse($this->runCommand('maintenance:recommendations:cold-start:refresh', [], ['verbose' => true]));
  130.     }
  132.     #[Route(path: '/task-top-100-refresh/', name: 'debug.task.top_100.refresh')]
  133.     public function taskTop100Refresh(): Response
  134.     {
  135.         return $this->getResponse($this->runCommand('maintenance:top-100:refresh'));
  136.     }
  138.     #[Route(path: '/process-bulk-background-actions/', name: 'debug.task.background.bulk.process_actions')]
  139.     public function taskProcessBulkBackgroundAction(): Response
  140.     {
  141.         set_time_limit(300);
  142.         $this->runCommand('account:bulk-queue:process');
  143.         return $this->getResponse('OK');
  144.     }
  146.     #[Route(path: '/process-bulk-background-actions-via-consumer/', name: 'debug.task.background.bulk.process_actions_via_consumer')]
  147.     public function taskProcessBulkBackgroundActionViaConsumer(): Response
  148.     {
  149.         set_time_limit(600);
  150.         $this->runCommand('messenger:consume');
  151.         return $this->getResponse('OK');
  152.     }
  154.     #[Route(path: '/process-support-broadcast-via-web/', name: 'debug.task.support_broadcast.process_via_web')]
  155.     public function taskProcessSupportBroadcastViaWeb(): Response
  156.     {
  157.         set_time_limit(120);
  159.         $output = $this->runCommand('messenger:consume', ['receivers' => ['async']], [
  160.             'limit' => 100,
  161.             'time-limit' => 60,
  162.             'memory-limit' => '256M',
  163.             'no-reset' => true,
  164.         ]);
  166.         return $this->getResponse($output ?: 'OK');
  167.     }
  169.     #[Route(path: '/process-video-transcoding/', name: 'debug.task.background.process_video_transcoding')]
  170.     public function taskProcessVideoTranscoding(): Response
  171.     {
  172.         set_time_limit(600);
  173.         $this->runCommand('messenger:consume', ['receivers' => ['transcoding']], ['limit' => 1]);
  174.         return $this->getResponse('OK');
  175.     }
  177.     #[Route(path: '/process-test-data-dummy-profiles-create/', name: 'debug.task.test-data.dummy-profiles.create')]
  178.     public function taskCreateDummyProfiles(): Response
  179.     {
  180.         set_time_limit(600);
  181.         return $this->getResponse($this->runCommand('test-data:dummy-profiles:create', ['default_user' => true]));
  182.     }
  184.     #[Route(path: '/task-hide-free-unapproved-placements/', name: 'debug.task.hide_free_unapproved_placements')]
  185.     public function taskHideFreeUnapprovedPlacements(): Response
  186.     {
  187.         return $this->getResponse($this->runCommand('update:profiles:hide-free-unapproved-placements'));
  188.     }
  190.     #[Route(path: '/genereate-profiles-export/', name: 'debug.task.export.create')]
  191.     public function taskCreateProfilesExport(): Response
  192.     {
  193.         set_time_limit(600);
  194.         return $this->getResponse($this->runCommand('export:profiles', [], [
  195.             'city' => 'moscow',
  196.             'price_gte' => 15000,
  197.         ]));
  198.     }
  200.     #[Route(path: '/task-stations-update/', name: 'debug.task.stations_update')]
  201.     public function taskStationsUpdate(): Response
  202.     {
  203.         return $this->getResponse($this->runCommand('stations:update'));
  204.     }
  206.     #[Route(path: '/task-set-seo-phone-numbers-to-profiles/', name: 'debug.task.set_seo_phone_numbers_to_profiles')]
  207.     public function taskSetSeoPhoneNumbersToProfiles(): Response
  208.     {
  209.         return $this->getResponse($this->runCommand('maintenance:seo:set-phones-to-profiles'));
  210.     }
  212.     #[Route(path: '/task-set-seo-phone-numbers-to-saloons/', name: 'debug.task.set_seo_phone_numbers_to_saloons')]
  213.     public function taskSetSeoPhoneNumbersToSaloons(): Response
  214.     {
  215.         return $this->getResponse($this->runCommand('maintenance:seo:set-phones-to-saloons'));
  216.     }
  218.     #[Route(path: '/task-plan-placement-sync/', name: 'debug.task.plan_placement.sync', methods: ['GET', 'POST'])]
  219.     public function taskPlanPlacementSync(Request $request): Response
  220.     {
  221.         $this->assertAvailable();
  223.         $timezone = (string)$request->request->get('timezone', 'Europe/Moscow');
  224.         $at = (string)$request->request->get(
  225.             'at',
  226.             (new \DateTimeImmutable('now', new \DateTimeZone('Europe/Moscow')))->format('Y-m-d H:i:s')
  227.         );
  228.         $profile = trim((string)$request->request->get('profile', ''));
  229.         $onlySync = (bool)$request->request->get('only_sync', false);
  230.         $output = null;
  232.         if ($request->isMethod('POST')) {
  233.             $options = [
  234.                 'at' => $at,
  235.                 'timezone' => $timezone,
  236.             ];
  237.             if ('' !== $profile) {
  238.                 $options['profile'] = $profile;
  239.             }
  240.             if ($onlySync) {
  241.                 $options['only-sync'] = true;
  242.             }
  244.             $output = $this->runCommand('debug:plan-placement:sync', [], $options);
  245.         }
  247.         return $this->render('debug/plan_placement_sync.html.twig', [
  248.             'at' => $at,
  249.             'timezone' => $timezone,
  250.             'profile' => $profile,
  251.             'only_sync' => $onlySync,
  252.             'output' => $output,
  253.         ]);
  254.     }
  256.     protected function assertAvailable()
  257.     {
  258.         if($this->kernel->getEnvironment() != 'dev'
  259.             && $this->kernel->getEnvironment() != 'review')
  260.             throw new UnauthorizedHttpException('Not available');
  261.     }
  263.     protected function runCommand(string $command, array $arguments = [], array $options = []): string
  264.     {
  265.         $this->assertAvailable();
  267.         $arrayInput = [
  268.             'command' => $command,
  269.         ];
  271.         foreach ($arguments as $k => $v)
  272.             $arrayInput[$k] = $v;
  274.         foreach ($options as $k => $v)
  275.             $arrayInput['--'.$k] = $v;
  277.         $input = new ArrayInput($arrayInput);
  278.         $output = new BufferedOutput();
  279.         $this->application->run($input, $output);
  281.         return $output->fetch();
  282.     }
  284.     protected function getResponse(string $output): Response
  285.     {
  286.         return new Response($output, headers: ['Content-Type' => 'text/plain; charset=utf-8']);
  287.     }
  288. }