src/Zsdev/MarketplaceBundle/Controller/ProductSyncDataAddController.php line 19

Open in your IDE?
  1. <?php
  4. namespace App\Zsdev\MarketplaceBundle\Controller;
  6. use App\Zsdev\MarketplaceBundle\Entity\ProductSyncItem;
  7. use Doctrine\ORM\EntityManagerInterface;
  8. use Pimcore\Db;
  9. use Pimcore\Model\DataObject;
  10. use Pimcore\Model\Asset;
  11. use Pimcore\Controller\FrontendController;
  12. use Symfony\Component\HttpFoundation\Request;
  13. use Symfony\Component\Routing\Annotation\Route;
  14. use Pimcore\Model\DataObject\Service;
  15. use Pimcore\Model\DataObject\Classificationstore\KeyConfig;
  17. class ProductSyncDataAddController extends FrontendController
  18. {
  19.     public function addDataAction(
  20.         Request $request,
  21.         EntityManagerInterface $entityManager
  22.     )
  23.     {
  24.         $response = [
  25.             'success' => false,
  26.             'recieved' => 0,
  27.             'error' => ''
  28.         ];
  30.         try {
  32.             $requestData = json_decode($request->getContent(), true);
  34.             if (empty($requestData)) {
  35.                 $response['error'] = 'No request data, or invalid request data!';
  36.                 return $this->json($response);
  37.             }
  39.             foreach($requestData as $item) {
  40.                 $response['recieved']++;
  42.                 /**
  43.                  * Save in table
  44.                  */
  45.                 $sku = $item['sku'];
  47.                 $syncProduct = new ProductSyncItem();
  48.                 $syncProduct->setStatus('pending');
  49.                 $syncProduct->setSku($sku);
  50.                 $syncProduct->setContent(json_encode($item));
  51.                 $syncProduct->setCreatedAt(new \DateTime('now'));
  53.                 $entityManager->persist($syncProduct);
  54.                 $entityManager->flush($syncProduct);
  56.                 unset($syncProduct);
  57.                 unset($item);
  58.             }
  60.             $response['success'] = true;
  62.         } catch (\Exception $e) {
  63.             $response['error'] = 'Exception: '.$e->getMessage();
  64.         }
  66.         return $this->json($response);
  67.     }
  69. }