src/Controller/DebugController.php line 203

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-top-100-refresh/', name: 'debug.task.top_100.refresh')]
  127.     public function taskTop100Refresh(): Response
  128.     {
  129.         return $this->getResponse($this->runCommand('maintenance:top-100:refresh'));
  130.     }
  132.     #[Route(path: '/process-bulk-background-actions/', name: 'debug.task.background.bulk.process_actions')]
  133.     public function taskProcessBulkBackgroundAction(): Response
  134.     {
  135.         set_time_limit(300);
  136.         $this->runCommand('account:bulk-queue:process');
  137.         return $this->getResponse('OK');
  138.     }
  140.     #[Route(path: '/process-bulk-background-actions-via-consumer/', name: 'debug.task.background.bulk.process_actions_via_consumer')]
  141.     public function taskProcessBulkBackgroundActionViaConsumer(): Response
  142.     {
  143.         set_time_limit(600);
  144.         $this->runCommand('messenger:consume');
  145.         return $this->getResponse('OK');
  146.     }
  148.     #[Route(path: '/process-support-broadcast-via-web/', name: 'debug.task.support_broadcast.process_via_web')]
  149.     public function taskProcessSupportBroadcastViaWeb(): Response
  150.     {
  151.         set_time_limit(120);
  153.         $output = $this->runCommand('messenger:consume', ['receivers' => ['async']], [
  154.             'limit' => 100,
  155.             'time-limit' => 60,
  156.             'memory-limit' => '256M',
  157.             'no-reset' => true,
  158.         ]);
  160.         return $this->getResponse($output ?: 'OK');
  161.     }
  163.     #[Route(path: '/process-video-transcoding/', name: 'debug.task.background.process_video_transcoding')]
  164.     public function taskProcessVideoTranscoding(): Response
  165.     {
  166.         set_time_limit(600);
  167.         $this->runCommand('messenger:consume', ['receivers' => ['transcoding']], ['limit' => 1]);
  168.         return $this->getResponse('OK');
  169.     }
  171.     #[Route(path: '/process-test-data-dummy-profiles-create/', name: 'debug.task.test-data.dummy-profiles.create')]
  172.     public function taskCreateDummyProfiles(): Response
  173.     {
  174.         set_time_limit(600);
  175.         return $this->getResponse($this->runCommand('test-data:dummy-profiles:create', ['default_user' => true]));
  176.     }
  178.     #[Route(path: '/task-hide-free-unapproved-placements/', name: 'debug.task.hide_free_unapproved_placements')]
  179.     public function taskHideFreeUnapprovedPlacements(): Response
  180.     {
  181.         return $this->getResponse($this->runCommand('update:profiles:hide-free-unapproved-placements'));
  182.     }
  184.     #[Route(path: '/genereate-profiles-export/', name: 'debug.task.export.create')]
  185.     public function taskCreateProfilesExport(): Response
  186.     {
  187.         set_time_limit(600);
  188.         return $this->getResponse($this->runCommand('export:profiles', [], [
  189.             'city' => 'moscow',
  190.             'price_gte' => 15000,
  191.         ]));
  192.     }
  194.     #[Route(path: '/task-stations-update/', name: 'debug.task.stations_update')]
  195.     public function taskStationsUpdate(): Response
  196.     {
  197.         return $this->getResponse($this->runCommand('stations:update'));
  198.     }
  200.     #[Route(path: '/task-set-seo-phone-numbers-to-profiles/', name: 'debug.task.set_seo_phone_numbers_to_profiles')]
  201.     public function taskSetSeoPhoneNumbersToProfiles(): Response
  202.     {
  203.         return $this->getResponse($this->runCommand('maintenance:seo:set-phones-to-profiles'));
  204.     }
  206.     #[Route(path: '/task-set-seo-phone-numbers-to-saloons/', name: 'debug.task.set_seo_phone_numbers_to_saloons')]
  207.     public function taskSetSeoPhoneNumbersToSaloons(): Response
  208.     {
  209.         return $this->getResponse($this->runCommand('maintenance:seo:set-phones-to-saloons'));
  210.     }
  212.     #[Route(path: '/task-plan-placement-sync/', name: 'debug.task.plan_placement.sync', methods: ['GET', 'POST'])]
  213.     public function taskPlanPlacementSync(Request $request): Response
  214.     {
  215.         $this->assertAvailable();
  217.         $timezone = (string)$request->request->get('timezone', 'Europe/Moscow');
  218.         $at = (string)$request->request->get(
  219.             'at',
  220.             (new \DateTimeImmutable('now', new \DateTimeZone('Europe/Moscow')))->format('Y-m-d H:i:s')
  221.         );
  222.         $profile = trim((string)$request->request->get('profile', ''));
  223.         $onlySync = (bool)$request->request->get('only_sync', false);
  224.         $output = null;
  226.         if ($request->isMethod('POST')) {
  227.             $options = [
  228.                 'at' => $at,
  229.                 'timezone' => $timezone,
  230.             ];
  231.             if ('' !== $profile) {
  232.                 $options['profile'] = $profile;
  233.             }
  234.             if ($onlySync) {
  235.                 $options['only-sync'] = true;
  236.             }
  238.             $output = $this->runCommand('debug:plan-placement:sync', [], $options);
  239.         }
  241.         return $this->render('debug/plan_placement_sync.html.twig', [
  242.             'at' => $at,
  243.             'timezone' => $timezone,
  244.             'profile' => $profile,
  245.             'only_sync' => $onlySync,
  246.             'output' => $output,
  247.         ]);
  248.     }
  250.     protected function assertAvailable()
  251.     {
  252.         if($this->kernel->getEnvironment() != 'dev'
  253.             && $this->kernel->getEnvironment() != 'review')
  254.             throw new UnauthorizedHttpException('Not available');
  255.     }
  257.     protected function runCommand(string $command, array $arguments = [], array $options = []): string
  258.     {
  259.         $this->assertAvailable();
  261.         $arrayInput = [
  262.             'command' => $command,
  263.         ];
  265.         foreach ($arguments as $k => $v)
  266.             $arrayInput[$k] = $v;
  268.         foreach ($options as $k => $v)
  269.             $arrayInput['--'.$k] = $v;
  271.         $input = new ArrayInput($arrayInput);
  272.         $output = new BufferedOutput();
  273.         $this->application->run($input, $output);
  275.         return $output->fetch();
  276.     }
  278.     protected function getResponse(string $output): Response
  279.     {
  280.         return new Response($output, headers: ['Content-Type' => 'text/plain; charset=utf-8']);
  281.     }
  282. }