<?
// src/Service/SyncTMProducts.php
namespace App\Service;

use App\Entity\Product;
use Doctrine\ORM\EntityManagerInterface;
use Symfony\Component\HttpFoundation\Response;
use App\Entity\Category;


class SyncTMProducts
{

    private $connectionParams;
    private $conn;
    private $em;

    public function __construct(EntityManagerInterface $em)
    {

        if($_SERVER['SERVER_NAME'] == "hotdeals")
            $this->connectionParams = array(
                'dbname' => 'ae000_parser',
                'user' => 'root',
                'password' => '',
                'host' => 'localhost',
                'driver' => 'pdo_mysql',
                'charset'  => 'utf8mb4'
            );
        else
            $this->connectionParams = array(
                'dbname' => 'tm_parser',
                'user' => 'timodna',
                'password' => '8073Rjkz',
                'host' => '0.0.0.0:3310',
                'driver' => 'pdo_mysql',
                'charset'  => 'utf8mb4'
            );

        $config = new \Doctrine\DBAL\Configuration();
        $this->conn = \Doctrine\DBAL\DriverManager::getConnection($this->connectionParams, $config);

        $this->em=$em;

    }

    public function getProducts($with_discount=1, $from=0, $limit=20)
    {

        $sql="select * from product where status=1 and discount>0 order by id desc limit 20";
        $result = $this->conn->query($sql);

        $products=[];
        while ($row = $result->fetch()) {
            $products[]=$row;
        }
        
        
        return $products;
    }

    public function syncCategories()
    {
        $sql = "Select * from categories";
        $result = $this->conn->query($sql);

        $added = [];

        while($category = $result->fetch()) {

            //check if category does not exist - add.
            if(!$this->em->getRepository(Category::class)->findOneBy(['tmId'=>$category['id']]))
            {
                $newCat=new Category();
                $newCat->setName($category['name']);
                $newCat->setParent($category['parent']);
                $newCat->setDescription($category['meta_description']);
                $newCat->setKeywords($category['keywords']);
                $newCat->setTmId($category['id']);

                $this->em->persist($newCat);
                $this->em->flush();
                array_push($added,$newCat->getTmId());
            }

        }
        return $added;
    }
    public function syncProducts()
    {

        $sql="select * from product where status=1 and discount>0 order by id";// desc limit 20
        $result = $this->conn->query($sql);

        //sett all products to status 0, then sync with TM
        $this->em->createQueryBuilder()->update('product')->set('status',0);

        $added = 0;

        while($item = $result->fetch()) {

            //new product - add, old - update
            $product = $this->em->getRepository(Product::class)->findOneBy(['tmId'=>$item['id']]);
            if(!$product)
            {
                $new=new Product();
                $new->setTmId($item['id']);
                $new->setName($item['name']);
                $new->setKeywords($item['keywords']);
                $new->setDescription($item['description']);
                $new->setArticul($item['articul']);
                $new->setCategory($item['cat_main']);
                $new->setDateParsed(new \DateTime($item['date_parsed']));
                $new->setDiscount($item['discount']);
                $new->setHasDiscount($item['has_discount']);
                $new->setImagesTimodna($item['images_timodna']);
                $new->setIsNew($item['is_new']);
                $new->setMetaDescription($item['meta_description']);
                $new->setModel($item['model']);
                $new->setParams(json_decode($item['params']));//json_encode($item['params'])
                $new->setPrice($item['price']);
                $new->setSizes($item['sizes']);
                $new->setSale($item['on_sale']);
                $new->setStatus($item['status']);
                $new->setArticul($item['articul']);

                $this->em->persist($new);
                $this->em->flush();

                $new = NULL;

            }else{//update

                $product->setName($item['name']);
                $product->setKeywords($item['keywords']);
                $product->setDescription($item['description']);
                $product->setArticul($item['articul']);
                $product->setCategory($item['cat_main']);
                $product->setDateParsed(new \DateTime($item['date_parsed']));
                $product->setDiscount($item['discount']);
                $product->setHasDiscount($item['has_discount']);
                $product->setImagesTimodna($item['images_timodna']);
                $product->setIsNew($item['is_new']);
                $product->setMetaDescription($item['meta_description']);
                $product->setModel($item['model']);
                $product->setParams(json_decode($item['params']));
                $product->setPrice($item['price']);
                $product->setSizes($item['sizes']);
                $product->setSale($item['on_sale']);
                $product->setStatus($item['status']);

                $this->em->flush();

                $product=NULL;
            }
            $added++;
        }
        return $added;
    }


}<br />
<b>Fatal error</b>:  Uncaught Symfony\Component\DependencyInjection\Exception\InvalidArgumentException: Expected to find class &quot;App\Service\SyncTMProducts&quot; in file &quot;/home/okhwulkq/app/src/Service/SyncTMProducts.php&quot; while importing services from resource &quot;../src/*&quot;, but it was not found! Check the namespace prefix used with the resource. in /home/okhwulkq/app/vendor/symfony/dependency-injection/Loader/FileLoader.php:224
Stack trace:
#0 /home/okhwulkq/app/vendor/symfony/dependency-injection/Loader/FileLoader.php(105): Symfony\Component\DependencyInjection\Loader\FileLoader-&gt;findClasses()
#1 /home/okhwulkq/app/vendor/symfony/dependency-injection/Loader/YamlFileLoader.php(699): Symfony\Component\DependencyInjection\Loader\FileLoader-&gt;registerClasses()
#2 /home/okhwulkq/app/vendor/symfony/dependency-injection/Loader/YamlFileLoader.php(256): Symfony\Component\DependencyInjection\Loader\YamlFileLoader-&gt;parseDefinition()
#3 /home/okhwulkq/app/vendor/symfony/dependency-injection/Loader/YamlFileLoader.php(176): Symfony\Component\DependencyInjection\Loader\YamlFileLoader-&gt;parseDefinitions()
#4 /home/okhwulkq/app/vendor/symfony/dependency-injection/Loader/YamlFileLoader.php(132): Symfony\Component\DependencyInjection\Loader\YamlFileLoader-&gt;loadContent()
#5 /home/okhwulkq/app/vendor/symfony/config/Loader/FileLoader.php(159): Symfony\Component\DependencyInjection\Loader\YamlFileLoader-&gt;load()
#6 /home/okhwulkq/app/vendor/symfony/config/Loader/FileLoader.php(98): Symfony\Component\Config\Loader\FileLoader-&gt;doImport()
#7 /home/okhwulkq/app/vendor/symfony/dependency-injection/Loader/FileLoader.php(66): Symfony\Component\Config\Loader\FileLoader-&gt;import()
#8 /home/okhwulkq/app/vendor/symfony/dependency-injection/Loader/GlobFileLoader.php(27): Symfony\Component\DependencyInjection\Loader\FileLoader-&gt;import()
#9 /home/okhwulkq/app/vendor/symfony/config/Loader/DelegatingLoader.php(40): Symfony\Component\DependencyInjection\Loader\GlobFileLoader-&gt;load()
#10 /home/okhwulkq/app/src/Kernel.php(42): Symfony\Component\Config\Loader\DelegatingLoader-&gt;load()
#11 /home/okhwulkq/app/vendor/symfony/framework-bundle/Kernel/MicroKernelTrait.php(81): App\Kernel-&gt;configureContainer()
#12 /home/okhwulkq/app/vendor/symfony/dependency-injection/Loader/ClosureLoader.php(39): App\Kernel-&gt;Symfony\Bundle\FrameworkBundle\Kernel\{closure}()
#13 /home/okhwulkq/app/vendor/symfony/config/Loader/DelegatingLoader.php(40): Symfony\Component\DependencyInjection\Loader\ClosureLoader-&gt;load()
#14 /home/okhwulkq/app/vendor/symfony/framework-bundle/Kernel/MicroKernelTrait.php(84): Symfony\Component\Config\Loader\DelegatingLoader-&gt;load()
#15 /home/okhwulkq/app/vendor/symfony/http-kernel/Kernel.php(651): App\Kernel-&gt;registerContainerConfiguration()
#16 /home/okhwulkq/app/vendor/symfony/http-kernel/Kernel.php(547): Symfony\Component\HttpKernel\Kernel-&gt;buildContainer()
#17 /home/okhwulkq/app/vendor/symfony/http-kernel/Kernel.php(789): Symfony\Component\HttpKernel\Kernel-&gt;initializeContainer()
#18 /home/okhwulkq/app/vendor/symfony/http-kernel/Kernel.php(190): Symfony\Component\HttpKernel\Kernel-&gt;preBoot()
#19 /home/okhwulkq/app/public/index.php(25): Symfony\Component\HttpKernel\Kernel-&gt;handle()
#20 {main}

Next Symfony\Component\Config\Exception\LoaderLoadException: Expected to find class &quot;App\Service\SyncTMProducts&quot; in file &quot;/home/okhwulkq/app/src/Service/SyncTMProducts.php&quot; while importing services from resource &quot;../src/*&quot;, but it was not found! Check the namespace prefix used with the resource in /home/okhwulkq/app/config/services.yaml (which is loaded in resource &quot;/home/okhwulkq/app/config/services.yaml&quot;). in /home/okhwulkq/app/vendor/symfony/config/Loader/FileLoader.php:174
Stack trace:
#0 /home/okhwulkq/app/vendor/symfony/config/Loader/FileLoader.php(98): Symfony\Component\Config\Loader\FileLoader-&gt;doImport()
#1 /home/okhwulkq/app/vendor/symfony/dependency-injection/Loader/FileLoader.php(66): Symfony\Component\Config\Loader\FileLoader-&gt;import()
#2 /home/okhwulkq/app/vendor/symfony/dependency-injection/Loader/GlobFileLoader.php(27): Symfony\Component\DependencyInjection\Loader\FileLoader-&gt;import()
#3 /home/okhwulkq/app/vendor/symfony/config/Loader/DelegatingLoader.php(40): Symfony\Component\DependencyInjection\Loader\GlobFileLoader-&gt;load()
#4 /home/okhwulkq/app/src/Kernel.php(42): Symfony\Component\Config\Loader\DelegatingLoader-&gt;load()
#5 /home/okhwulkq/app/vendor/symfony/framework-bundle/Kernel/MicroKernelTrait.php(81): App\Kernel-&gt;configureContainer()
#6 /home/okhwulkq/app/vendor/symfony/dependency-injection/Loader/ClosureLoader.php(39): App\Kernel-&gt;Symfony\Bundle\FrameworkBundle\Kernel\{closure}()
#7 /home/okhwulkq/app/vendor/symfony/config/Loader/DelegatingLoader.php(40): Symfony\Component\DependencyInjection\Loader\ClosureLoader-&gt;load()
#8 /home/okhwulkq/app/vendor/symfony/framework-bundle/Kernel/MicroKernelTrait.php(84): Symfony\Component\Config\Loader\DelegatingLoader-&gt;load()
#9 /home/okhwulkq/app/vendor/symfony/http-kernel/Kernel.php(651): App\Kernel-&gt;registerContainerConfiguration()
#10 /home/okhwulkq/app/vendor/symfony/http-kernel/Kernel.php(547): Symfony\Component\HttpKernel\Kernel-&gt;buildContainer()
#11 /home/okhwulkq/app/vendor/symfony/http-kernel/Kernel.php(789): Symfony\Component\HttpKernel\Kernel-&gt;initializeContainer()
#12 /home/okhwulkq/app/vendor/symfony/http-kernel/Kernel.php(190): Symfony\Component\HttpKernel\Kernel-&gt;preBoot()
#13 /home/okhwulkq/app/public/index.php(25): Symfony\Component\HttpKernel\Kernel-&gt;handle()
#14 {main}
  thrown in <b>/home/okhwulkq/app/vendor/symfony/config/Loader/FileLoader.php</b> on line <b>174</b><br />