src/Controller/ApiController.php line 178

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\Catalog;
  6. use App\Entity\StanMag;
  7. use App\Entity\StanMagStatus;
  8. use App\Entity\SystemConfig;
  9. use App\Integration\Marketplace\Allegro\AllegroRestApi;
  10. use Doctrine\ORM\EntityManager;
  11. use Doctrine\Persistence\ManagerRegistry;
  12. use Psr\Log\LoggerInterface;
  13. use Symfony\Component\Routing\Annotation\Route;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Symfony\Component\HttpFoundation\JsonResponse;
  16. use Symfony\Component\HttpFoundation\Request;
  17. use Symfony\Component\HttpFoundation\Response;
  18. use Symfony\Component\Security\Core\User\UserInterface;
  21. class ApiController extends ApiBaseController
  22. {
  26.     /**
  27.      * @Route("/api/stanmagReactivate/{id}", name="api_stanmag_reactivate", methods={"GET"})
  28.      * @param string $id
  29.      * @return JsonResponse
  30.      */
  31.     public function getApiStanmagReactivate(string $id = ''): Response
  32.     {
  33.         $output = [];
  34.         /** @var StanMag $item */
  35.         $id = preg_replace("/-/","/",$id);
  37.         /** @var StanMag $item */
  38.         $item = $this->em->getRepository(StanMag::class)->findOneBy(['nrEtykiety'=> $id]);
  39.         if (!$item) {
  40.             return $this->respondWithErrors("No item found");
  41.         }
  42.         // if already active - return with error
  43.         if ($item->getStanMagStatus()->getAllegroActive() > 0) {
  44.             return $this->respondWithErrors("Item already published");
  45.         }
  46. #        if ($item->getStanMagStatus()->getIsEligible() > 0) {
  47. #            return $this->respondWithErrors("Item already active");
  48. #            $item->makeAvailable();
  49. #        }
  51.         if (!$item->makeAvailable()) {
  52.             return $this->respondWithErrors("Item activation failed");
  53.         }
  54.         $this->em->persist($item);
  55.         $this->em->flush();
  57.         // if sold - make previous auctions as ignore
  58.         // update sold dates
  59.         // update active status
  60.         // update ilosc = 1
  61.         // udpate usun = 0
  63.         return $this->respondWithText("Produkt ".$item->getNrEtykiety()." może być ponownie wystawiony na Allegro");
  64.         return $this->respondWithSuccess($output);
  65.     }
  68.     /**
  69.      * @Route("/api/stanmagDeactivate/{id}", name="api_stanmag_deactivate", methods={"GET"})
  70.      * @param string $id
  71.      * @return JsonResponse
  72.      */
  73.     public function getApiStanmagDeactivate(string $id = ''): JsonResponse
  74.     {
  75.         $output = [];
  76.         /** @var StanMag $item */
  77.         $id = preg_replace("/-/","/",$id);
  79.         /** @var StanMag $item */
  80.         $item = $this->em->getRepository(StanMag::class)->findOneBy(['nrEtykiety'=> $id]);
  81.         if (!$item) {
  82.             return $this->respondWithErrors("No item found");
  83.         }
  84.         // if already active - return with error
  85.         if ($item->getStanMagStatus()->getAllegroActive() > 0) {
  86.             return $this->respondWithErrors("Item already published");
  87.         }
  88.         if ($item->getStanMagStatus()->getIsEligible() == 0) {
  89.             return $this->respondWithErrors("Item already inactive");
  90.         }
  92.         if (!$item->makeUnavailable()) {
  93.             return $this->respondWithErrors("Item deactivation failed");
  94.         }
  95.         $this->em->persist($item);
  96.         $this->em->flush();
  98.         // update ilosc = 0
  99.         // udpate usun = 98
  101.         return $this->respondWithSuccess($output);
  102.     }
  107.     /**
  108.      * @Route("/api/stanmagUnpublish/{id}", name="api_stanmag_unpublish", methods={"GET"})
  109.      * @param string $id
  110.      * @return JsonResponse
  111.      */
  112.     public function getApiStanmagUnpublish(string $id = ''): Response
  113.     {
  114.         $output = [];
  115.         /** @var StanMag $item */
  116.         $id = preg_replace("/-/","/",$id);
  118.         /** @var StanMag $item */
  119.         $item = $this->em->getRepository(StanMag::class)->findOneBy(['nrEtykiety'=> $id]);
  120.         if (!$item) {
  121.             return $this->respondWithErrors("ERROR: UNABLE TO UNPUBLISH THIS ITEM No item found");
  122.         }
  125.         if (!$item->getAllegroOffers()) {
  126.             return $this->respondWithErrors("ERROR: UNABLE TO UNPUBLISH THIS ITEM No Allegro offers found");
  127.         } else {
  128.             $output['log'][] = "Found ".count($item->getAllegroOffers())." Allegro offers ";
  129.         }
  131.         $activeOffer = null;
  132.         foreach($item->getAllegroOffers() as $offer) {
  133.             if (strtoupper($offer->getStatus()) == 'ACTIVE' || strtoupper($offer->getStatus()) == 'PLACEHOLDER') {
  134.                 $activeOffer = $offer;
  135.                 $output['log'][] = "Found active offer ".$offer->getId()." ";
  136.             }
  137.         }
  138.         if (null === $activeOffer) {
  139.             return $this->respondWithErrors("ERROR: UNABLE TO UNPUBLISH THIS ITEM No Active Allegro offer found");
  140.         }
  143.         $source = ($item->getKodLokalizacji() == 12) ? "waw" : "gru";
  144.         if ($item->getKodLokalizacji() == 99) {
  145.             $source = "aga";
  146.         }
  148.         $allegroClientId = $this->em->getRepository(SystemConfig::class)->getParameter('allegroClientId','allegro');
  149.         $allegroClientSecret = $this->em->getRepository(SystemConfig::class)->getParameter('allegroClientSecret','allegro');
  150.         $allegroAccessToken = $this->em->getRepository(SystemConfig::class)->getParameter('allegroAccessToken.'.$source,'allegro');
  152.         $api = new AllegroRestApi();
  153.         $api->setAccessToken($allegroAccessToken)
  154.             ->setClientId($allegroClientId)
  155.             ->setClientSecret($allegroClientSecret);
  157.         $output['log'][] = "Active offer removed - ".$activeOffer->getId()." ";
  158.         $res = $api->removeOfferFromAllegro($activeOffer->getId());
  159.         $output['response'] = $res;
  161.         $activeOffer->setStatus("ENDED");
  162.         $this->em->persist($activeOffer);
  163.         $this->em->flush();
  164.         $output['log'][] = "Active offer status set to ENDED - ".$activeOffer->getId()." ";
  167.         //return $this->respondWithText("PRODUKT BYL WYSTAWIONY I JEST TERAZ USUNIETY");
  169.         return $this->respondWithSuccess($output);
  170.     }
  173.     /**
  174.      * @Route("/api/stanmagStatus/{location}", name="api_stanmag_status", methods={"GET"})
  175.      * @param string $location
  176.      * @return JsonResponse
  177.      */
  178.     public function getApiStanmagStatus(string $location = '00'): JsonResponse
  179.     {
  180.         $output = [];
  181.         $alias = "s";
  182.         $prefix = $alias.'.';
  184.         $start = 0;
  185.         $limit = 10000;
  187.         $countQuery = $this->em->createQueryBuilder();
  188.         $countQuery->select('count(s.nrEtykiety)')->from(StanMagStatus::class, $alias);
  189.         $countQuery->where('1=1');
  190.         $countQuery->andWhere(" s.kodLokalizacji = '".$location."' ");
  191.         $countRecords = $countQuery->getQuery()->getSingleScalarResult();
  193.         //$output['log'][] = "Total records: ".$countRecords." ";
  195.         if ($countRecords > 0) {
  196.             while ($start < $countRecords) {
  197.                 //$output['log'][] = "Batch start [".$start."] limit [".$limit."]  ";
  199.                 $query = $this->em->createQueryBuilder();
  200. //        $query->select('s','st')->from(StanMagStatus::class, $alias)->leftJoin($alias.'.stanMag', 'st');
  201.                 $query->select('s')->from(StanMagStatus::class, $alias);
  202.                 $query->where('1=1');
  203.                 $query->andWhere(" s.kodLokalizacji = '".$location."' ");
  204.                 $items = $query->getQuery()
  205.                     ->setFirstResult($start)
  206.                     ->setMaxResults($limit)
  207.                     ->getArrayResult();
  208.                     //->getResult();
  209.                 if (is_array($items) && count($items) > 0) {
  211.             foreach($items as $item) {
  212.                 $row = [
  213.                     'nr_etykiety'    => $item['nrEtykiety'],
  214.                     'location'       => $item['kodLokalizacji'],
  215.                     'allegro_active' => $item['allegroActive'],
  216.                     'allegro_sold'   => $item['allegroSold'],
  217.                     'status'         => $item['isAvailable'],
  218.                     'is_eligible'    => $item['isEligible'],
  219.                     'status_allegro' => $this->getStatusAllegro($item),
  220.                 ];
  221.                 $output[] = $row;
  223.             }
  227.                 } else {
  228.                     return $this->respondWithErrors("No data to render");
  229.                 }
  230.                 $start += $limit;
  231.             }
  232.         } else {
  233.             // no count records received
  234.             return $this->respondWithErrors("No data received");
  235.         }
  239. //
  240. //
  241. //        //$items = $this->em->getRepository(StanMagStatus::class)->findBy(['kodLokalizacji'=> $location]);
  242. //        if (is_array($items) && count($items) > 0) {
  243. //
  244. ////            /** @var StanMagStatus $item */
  245. ////            foreach($items as $item) {
  246. ////                $row = [
  247. ////                    'nr_etykiety'    => $item->getNrEtykiety(),
  248. ////                    'location'       => $item->getKodLokalizacji(),
  249. ////                    'allegro_active' => $item->getAllegroActive(),
  250. ////                    'allegro_sold'   => $item->getAllegroSold(),
  251. ////                    'status'         => $item->getIsAvailable(),
  252. ////                    'is_eligible'    => $item->getIsEligible(),
  253. ////                    'status_allegro' => $item->getStatusAllegro(),
  254. ////                ];
  255. ////                $output[] = $row;
  256. ////            }
  257. //
  258. //            foreach($items as $item) {
  259. //                $row = [
  260. //                    'nr_etykiety'    => $item['nrEtykiety'],
  261. //                    'location'       => $item['kodLokalizacji'],
  262. //                    'allegro_active' => $item['allegroActive'],
  263. //                    'allegro_sold'   => $item['allegroSold'],
  264. //                    'status'         => $item['isAvailable'],
  265. //                    'is_eligible'    => $item['isEligible'],
  266. //                    'status_allegro' => $this->getStatusAllegro($item),
  267. //                ];
  268. //                $output[] = $row;
  269. ////                print_r($item);
  270. ////                print_r($row);
  271. ////                die();
  272. //
  273. //            }
  274. //
  275. //        } else {
  276. //            return $this->respondWithErrors("No data to render");
  277. //        }
  279.         return $this->respondWithSuccess($output);
  280.     }
  293.     
  308.     private function getStatusAllegro(array $item) : ?string
  309.     {
  310.         if ($item['allegroActive'] > 0) return "wystawione";
  311.         if ($item['allegroSold'] > 0) return "sprzedane";
  312.         if ($item['isAvailable'] < 1) return "sprzedane sisd";
  313.         if ($item['hasPhotoPrimary'] < 1 || $item['hasPhotos'] < 1) return "brak zdjec";
  314.         if($item['isEligible'] == 1) return "gotowe do wystawiania";
  315.         return null;
  316.     }
  319. //
  320. //    /**
  321. //     * @Route("/api/login_check", name="login-check", methods={"POST"})
  322. //     * @return JsonResponse
  323. //     */
  324. //    public function getTokenUser(): JsonResponse
  325. //    {
  326. //        return new JsonResponse(['token' => 'TOKEN']);
  327. //    }
  335. }