src/Command/DetectInvalidPricesCommand.php line 43

Open in your IDE?
  1. <?php
  3. namespace App\Command;
  5. use App\Entity\Currency;
  6. use App\Entity\ProductPrice;
  7. use Doctrine\ORM\EntityManagerInterface;
  8. use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
  9. use Symfony\Component\Console\Helper\Table;
  10. use Symfony\Component\Console\Input\InputInterface;
  11. use Symfony\Component\Console\Output\OutputInterface;
  12. use Symfony\Component\DependencyInjection\ContainerInterface;
  13. use Symfony\Component\Console\Command\Command;
  15. /**
  16.  * Symfony console command that scans every price in every language version of the store,
  17.  * compares it with the reference Polish (language‑id = 1) price and reports anomalies.
  18.  *
  19.  * An anomaly is logged when:
  20.  *   1. A numeric price is identical in the foreign language and in Polish
  21.  *      (e.g. 400 PLN vs. 400 EUR).
  22.  *   2. After converting the foreign price to PLN using Currency.factorPln the value differs
  23.  *      by more than ±50 % (ratio > 1.5 or < 0.6667) from the Polish price.
  24.  * Only prices that belong to the same *variant combination* are compared.
  25.  * A variant combination is identified by the set of ProductParameterValue ids linked
  26.  * to a ProductPrice through ProductPriceVariants.
  27.  *
  28.  * The command prints a nice table to the CLI **and** mails an HTML report via
  29.  * GetResponse transactional‑emails API.  Hook it into a cron‑job (e.g. at 6:00 every morning)
  30.  * or use Symfony Scheduler so that your team has fresh data each day.
  31.  */
  32. class DetectInvalidPricesCommand extends Command
  33. {
  35.     protected static $defaultName = 'app:detect-invalid-prices';
  37.     protected function configure()
  38.     {
  39.         $this->setName('app:detect-invalid-prices')
  40.             ->setDescription('Detect invalid prices');
  41.     }
  43.     public function __construct($name = null, ContainerInterface $container)
  44.     {
  45.         parent::__construct($name);
  46.         $this->container = $container;
  47.     }
  49.     protected function execute(InputInterface $input, OutputInterface $output): int
  50.     {
  51.         $em   = $this->container->get('doctrine')->getManager();
  52.         $twig = $this->container->get('twig');
  54.         // 1. Cache currencies.
  55.         $currencies = [];
  56.         foreach ($em->getRepository(Currency::class)->findAll() as $currency) {
  57.             $currencies[$currency->getId()] = $currency;
  58.         }
  60.         // 2. Reference (Polish) prices.
  61.         $plPrices = $this->getPricesIndexed($em, 1);
  63.         // 3. Active foreign languages.
  64.         $foreignLangs = $em->getRepository(\App\Entity\Language::class)
  65.             ->createQueryBuilder('l')
  66.             ->where('l.id != 1')
  67.             ->andWhere('l.isActive = 1')
  68.             ->getQuery()
  69.             ->getResult();
  71.         $rows = [];
  72.         foreach ($foreignLangs as $lang) {
  73.             $langPrices = $this->getPricesIndexed($em, $lang->getId());
  75.             foreach ($langPrices as $productId => $variants) {
  76.                 foreach ($variants as $variantKey => $pp) {
  77.                     if (!isset($plPrices[$productId][$variantKey])) {
  78.                         continue; // No reference price.
  79.                     }
  81.                     $plPP         = $plPrices[$productId][$variantKey];
  82.                     $plPrice      = (float) $plPP->getPrice();
  83.                     $foreignPrice = (float) $pp->getPrice();
  84.                     $currency     = $currencies[$pp->getCurrency()->getId()];
  86.                     $factor = (float) $currency->getFactorPln();
  87.                     if ($factor <= 0) {
  88.                         // mis-configured currency – skip comparison
  89.                         continue;
  90.                     }
  91.                     $foreignInPln = $foreignPrice / $factor;   // correct way
  93.                     $ratio        = $plPrice > 0 ? $foreignInPln / $plPrice : 1;
  94.                     $numericEqual = abs($foreignPrice - $plPrice) < 0.01;
  95.                     $outOfRange   = $ratio > 1.5 || $ratio < (1 / 1.5);
  97.                     if (!$numericEqual && !$outOfRange) {
  98.                         continue; // looks fine
  99.                     }
  101.                     $rows[] = [
  102.                         'lang'          => strtoupper($lang->getLocale()),
  103.                         'product'       => sprintf('%s (ID %d)', $pp->getProduct()->getName(), $productId),
  104.                         'variant'       => $this->getVariantLabel($pp),
  105.                         'pl_price'      => number_format($plPrice, 2, ',', ' ') . ' zł',
  106.                         'foreign_price' => number_format($foreignPrice, 2, ',', ' ') . ' ' . $currency->getSign(),
  107.                         'pln_value'     => number_format($foreignInPln, 2, ',', ' ') . ' zł',
  108.                         'ratio'         => number_format($ratio, 2),
  109.                         'reason'        => $numericEqual ? 'Same numeric price' : 'Outside ±50 %',
  110.                     ];
  111.                 }
  112.             }
  113.         }
  115.         if (!$rows) {
  116.             $output->writeln('<info>No anomalies detected – prices look good 🙂</info>');
  117.             return 0;
  118.         }
  120.         (new Table($output))->setHeaders(array_keys($rows[0]))->setRows($rows)->render();
  122.         $html = $twig->render('emails/invalid_prices.html.twig', [
  123.             'rows'        => $rows,
  124.             'generatedAt' => new \DateTimeImmutable('now', new \DateTimeZone('Europe/Warsaw')),
  125.         ]);
  127.         $this->sendEmailViaGetResponse($html);
  129.         $output->writeln(sprintf('<info>Email sent with %d anomaly%s.</info>', count($rows), count($rows) === 1 ? '' : 'ies'));
  130.         return 0;
  131.     }
  133.     /**
  134.      * Returns active prices **for visible products** in the given language, indexed by [productId][variantKey].
  135.      */
  136.     private function getPricesIndexed(EntityManagerInterface $em, int $languageId): array
  137.     {
  138.         $qb = $em->createQueryBuilder()
  139.             ->select('pp, v, p')
  140.             ->from(ProductPrice::class, 'pp')
  141.             ->leftJoin('pp.variants', 'v')
  142.             ->innerJoin('pp.product', 'p')
  143.             ->innerJoin('App\\Entity\\ProductLangParam', 'plp', 'WITH', 'plp.product = p AND plp.language = :lang AND plp.deletedBy IS NULL')
  144.             ->where('pp.language = :lang')
  145.             ->andWhere('pp.active = 1')
  146.             ->andWhere('pp.deletedBy IS NULL')
  147.             ->andWhere('p.deletedBy IS NULL')
  148.             // Product must be visible in that language; if no ProductLangParam row exists, we treat it as visible.
  149.             ->andWhere('(plp.id IS NULL OR plp.visible = 1)')
  150.             ->setParameter('lang', $languageId);
  152.         $indexed = [];
  153.         foreach ($qb->getQuery()->getResult() as $pp) {
  154.             $productId  = $pp->getProduct()->getId();
  155.             $variantKey = $this->buildVariantKey($pp);
  156.             $indexed[$productId][$variantKey] = $pp;
  157.         }
  159.         return $indexed;
  160.     }
  162.     /**
  163.      * Builds a stable key (e.g. v12‑g3) covering both single values and value‑groups.
  164.      */
  165.     private function buildVariantKey(ProductPrice $pp): string
  166.     {
  167.         if ($pp->getVariants()->isEmpty()) {
  168.             return '_base';
  169.         }
  170.         $keys = [];
  171.         foreach ($pp->getVariants() as $variant) {
  172.             if ($variant->getParameterValue()) {
  173.                 $keys[] = 'v' . $variant->getParameterValue()->getId();
  174.             } elseif ($variant->getParameterValueGroup()) {
  175.                 $keys[] = 'g' . $variant->getParameterValueGroup()->getId();
  176.             }
  177.         }
  178.         sort($keys);
  179.         return implode('-', $keys);
  180.     }
  182.     private function getVariantLabel(ProductPrice $pp): string
  183.     {
  184.         if ($pp->getVariants()->isEmpty()) {
  185.             return '—';
  186.         }
  187.         $parts = [];
  188.         foreach ($pp->getVariants() as $variant) {
  189.             $paramName = $variant->getParameter()->getName();
  190.             if ($variant->getParameterValue()) {
  191.                 $valueName = $variant->getParameterValue()->getName();
  192.             } elseif ($variant->getParameterValueGroup()) {
  193.                 $valueName = $variant->getParameterValueGroup()->getName();
  194.             } else {
  195.                 $valueName = '';
  196.             }
  197.             $parts[] = sprintf('%s: %s', $paramName, $valueName);
  198.         }
  199.         return implode(', ', $parts);
  200.     }
  202.     private function sendEmailViaGetResponse($htmlBody)
  203.     {
  204.         $content = [
  205.             'fromField' => ['fromFieldId' => 'f'],
  206.             'subject' => 'Invalid prices report',
  207.             'content' => [
  208.                 'html' => $htmlBody,
  209.                 'plain' => strip_tags($htmlBody),
  210.             ],
  211.             'recipients' => [
  212.                 'to' => ['email' => 'krzysiek.gaudy@gmail.com']
  213.             ],
  214.         ];
  216.         $body = json_encode($content);
  218.         $ch = curl_init();
  219.         curl_setopt($ch, CURLOPT_URL, "https://api3.getresponse360.pl/v3/transactional-emails");
  220.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  221.         curl_setopt($ch, CURLOPT_POSTFIELDS, $body);
  222.         curl_setopt($ch, CURLOPT_POST, 1);
  223.         curl_setopt($ch, CURLOPT_HTTPHEADER, [
  224.             "Content-Type: application/json",
  225.             "X-Auth-Token: api-key gs478s9uv59n5ekulmpmgn5p0uqpepbn",
  226.             "X-Domain: echairs.eu"
  227.         ]);
  228.         curl_exec($ch);
  229.         curl_close($ch);
  230.     }
  231. }