src/OfficeBrain/Bundle/ProductBundle/Controller/ProductConfigureController.php line 405

Open in your IDE?
  1. <?php
  2. namespace App\OfficeBrain\Bundle\ProductBundle\Controller;
  4. // use Symfony\Bundle\FrameworkBundle\Controller\Controller;
  5. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  6. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
  7. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Template;
  8. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Method;
  9. use Symfony\Component\HttpFoundation\JsonResponse;
  10. use Symfony\Component\HttpFoundation\Response;
  11. use Symfony\Component\Translation\Translator;
  12. use App\OfficeBrain\Bundle\CoreBundle\CustomeHandler as FormErrorManager;
  13. use App\OfficeBrain\Bundle\CoreBundle\Cache\RedisCacheService;
  14. use App\OfficeBrain\Bundle\ProductTagBundle\Entity\ImprintProductMapping;
  15. use Symfony\Component\HttpFoundation\Request;
  16. use Symfony\Component\DependencyInjection\ContainerInterface;
  17. use App\OfficeBrain\Bundle\ProductBundle\Manager\Service\ProductAdminManager;
  18. use App\OfficeBrain\Bundle\UserBundle\Manager\Service\UserService;
  19. use App\OfficeBrain\Bundle\ProductBundle\Manager\Service\ProductDetailService;
  20. use App\OfficeBrain\Bundle\ProductBundle\Manager\Service\BrandApiManager;
  21. use App\OfficeBrain\Bundle\ProductTagBundle\Manager\Service\ProductTagManager;
  22. use App\OfficeBrain\Bundle\SolrBundle\Manager\Service\SolrService;
  23. use App\OfficeBrain\Bundle\QueueBundle\Manager\Service\ApiManager as QueueApiManager;
  24. use App\OfficeBrain\Bundle\CategoryBundle\Manager\ApiManager as CategoryApiManager;
  26. /*
  27.  * This class for base functionality related to product admin. @author Office Brain - 4808 <support@officebrain.com>
  28.  */
  30. /**
  31.  * @Route("/admin/{_locale}/product")
  32.  */
  33. class ProductConfigureController extends AbstractController
  34. {
  35.     public function __construct(ContainerInterface $container, ProductAdminManager $productAdminManager, UserService $userService, ProductDetailService $productDetailService, BrandApiManager $brandApiManager, ProductTagManager $productTagManager, SolrService $solrService, QueueApiManager $queueApiManager)
  36.     {
  37.         $this->serviceContainer = $container;
  38.         $this->productApiManager = $productAdminManager;
  39.         $this->userService = $userService->getUserExtended();
  40.         $this->productDetailManager = $productDetailService->getProductApiExtended();
  41.         $this->brandApiManager = $brandApiManager;
  42.         $this->productTagManager = $productTagManager->getProductTagManagerExtended();
  43.         $this->solrService = $solrService->getSolrServiceExtended();
  44.         $this->queueApiManager = $queueApiManager->getQueueInstance();
  45.     }
  47.     CONST PRODUCT_CACHE_CLIENT = 'product';
  48.     
  49.    /**
  50.      * @author Employee Id: 4808
  51.      * 
  52.      * Description : This function used for Set and intilize variables and request array
  53.      *
  54.      **/
  55.     public function init(Request $request){
  56.          $this->request = $request;
  57.         $this->entityManager = $this->getDoctrine()->getManager();
  58.         $this->session = $this->request->getSession();
  59.         $this->translator = $this->serviceContainer->get('translator');
  60.         $this->formErrorManager = new FormErrorManager\JsonError();
  61.         // $this->productApiManager = $this->serviceContainer->get("office_brain_product_admin_manager");
  62.         $this->productApiManager = $this->productApiManager;
  63.         // $this->brandApiManager = $this->serviceContainer->get("officebrain_brand_api_manager");
  64.         $this->brandApiManager = $this->brandApiManager;
  65.         $this->categoryApiManager = $this->serviceContainer->get("officebrain_category_api_manager");
  66.         // $this->userManager = $this->serviceContainer->get("office_brain_user_manager");
  67.         $this->userManager = $this->userService;
  68.         $this->projectSetting = $this->request->get('project_setting');
  69.         $this->projectUserSetting = $this->request->get('project_user_setting');
  70.         $this->userId = $this->projectUserSetting['user_data'] ? $this->projectUserSetting['user_data']->getId() : 0;
  71.         // $this->productDetailManager = $this->serviceContainer->get('office_brain_product_detail_manager');
  72.         $this->productDetailManager = $this->productDetailManager;
  73.         $this->productTagManager = $this->productTagManager;
  74.         
  75.         $this->user = $this->projectUserSetting['user_data'];
  76.         if (!$this->getUser() && $this->request->isXmlHttpRequest()) {
  77.            // throw new AccessDeniedHttpException();
  78.         }
  79.         // if ($this->serviceContainer->has('office_brain_queue_api_manager')) {
  80.         //     $this->request->attributes->set('object', 'Product');
  81.         //     $this->queueApiManager = $this->serviceContainer->get('office_brain_queue_api_manager');
  82.         // }
  83.         if ($this->queueApiManager) {
  84.             $this->request->attributes->set('object', 'Product');
  85.             $this->queueApiManager = $this->queueApiManager;
  86.         }
  87.         
  88.         $this->statsh_cache_wrapper = RedisCacheService::create();
  89.         $this->moduleCachePrefix='__RelatedProducts__';
  90.     }
  91.     
  92.     /**
  93.      * @author Employee Id: 4808
  94.      *
  95.      * Description : This function used for List Product Information
  96.      *
  97.      * @Route("/list/{page}",
  98.      * name="officebrain_bundle_product_list_product_wo_culture",
  99.      * requirements={"records_per_page"="12|24|48|100|996", "page"="\d+"},
  100.      * defaults={"records_per_page"=100,"page"=1})
  101.      *
  102.      * @Route("/list/{country}/{language}/{page}",
  103.      * name="officebrain_bundle_product_list_product",
  104.      * requirements={"records_per_page"="12|24|48|100|996","page"="\d+"},
  105.      * defaults={"records_per_page"=20,"page"=1})
  106.      * @Template("OfficeBrain/Bundle/ProductBundle/ProductAdmin/list.html.twig")
  107.      */
  108.     public function listProductAction(Request $request){
  109.         $this->init($request);
  110.         $projectSetting = $this->request->get('project_setting');
  111.         list($defaultCulture,$defaultCountry) = explode("_",$this->request->get("_locale"));
  112.     
  113.         $param = $this->request->get('_route_params');
  114.         $culture = $this->request->get('language',$defaultCulture);
  115.         $country = $this->request->get('country',$defaultCountry);
  116.         $activeCulture = $culture;
  117.         $searchStatus = $this->request->query->get('search_status', '');
  118.         $searchQuery = $this->request->query->get('search_query', '');
  119.         $sortBy = $this->request->query->get('sort', 'updatedAt');
  120.         $sortType = $this->request->query->get('direction', 'desc');
  121.         $searchParam = $this->request->query->get('search_param', '');
  122.         $supplier_id = $this->request->query->get('supplier_id','');
  123.         $brandIds = $this->request->query->get('brand_id','');
  124.         $catIds = $this->request->query->get('cat_id','');
  125.         $instanceType = $projectSetting['instance_type'];
  126.         $cultureCategory =  $activeCulture . "_" . $country;
  127.     
  128.         // For Pagination
  129.         $page = $this->request->get('page', '1');
  130.         $records_per_page = $param['records_per_page'];
  131.         $recordsPerPage = $this->request->query->get('recordsPerPage',$records_per_page);
  132.         $start_index = (($page - 1) * $recordsPerPage - 1);
  133.         // End Pagination
  134.         $projectSetting = $this->request->get('project_setting');
  135.     
  136.         $projectId = $projectSetting['project_id'];
  137.         $productData = $this->productApiManager->listProduct($searchStatus,$searchParam, $searchQuery, $sortType, $sortBy,$activeCulture,$country,$supplier_id,$records_per_page,$page,$projectId,$brandIds,$catIds);
  138.         $supplierData = $this->productApiManager->getSupplierNameList($projectId);
  139.         $brandData = $this->brandApiManager->getList($culture);
  140.         //GET CATEGORY AND SUBCATEGORY
  141.         $categoryAndSubCategoryData = $this->categoryApiManager->getList(array($cultureCategory),array(),true);
  142.         $this->catArrayNew = array();
  143.         if ($categoryAndSubCategoryData) {
  144.             foreach($categoryAndSubCategoryData[$cultureCategory] as $catKey=>$categoryAndSubCategory){
  145.                 $this->recursiveCategory($categoryAndSubCategory);
  146.             }
  147.             // Sort Category array using category name
  148.             usort($this->catArrayNew, function ($a, $b) {
  149.                 return strcasecmp($a['cat_name'], $b['cat_name']);
  150.             });
  151.         }
  152.         $data['category_SubCategory_data'] = $this->catArrayNew;
  153.         $paginator  = $this->serviceContainer->get('knp_paginator');
  154.         $data['pagination'] = $paginator->paginate($productData, $page, $recordsPerPage);
  155.         $data['page']=$page;
  156.         $data['search_status']=$searchStatus;
  157.         $data['search_query']=$searchQuery;
  158.         $data['sort_by']=$sortBy;
  159.         $data['sort_type']=$sortType;
  160.         $data['search_param']=$searchParam;
  161.         $data['supplier_id']=$supplier_id;
  162.         $data['records_per_page'] = $recordsPerPage;
  163.         $data['supplier_data'] = $supplierData;
  164.         $data['brand_id']=$brandIds;
  165.         $data['cat_id']=$catIds;
  166.         $data['brand_data']= $brandData[$culture];
  167.     
  168.         if(array_key_exists('status',$productData) && $productData['status'] == 'error' && is_array($productData))
  169.         {
  170.             $productSentData = array();
  171.             $data['error_message'] = $productData['error_message'];
  172.         }
  173.         else
  174.         {
  175.             if($productData['data']){
  176.                 $data['total_product'] = $productData['count'];
  177.                 $data['image_url'] = (array_key_exists('image_url',$productData)?$productData['image_url']:'');
  178.                 $productSentData = $productData['data'];
  179.             }else{
  180.                 $productSentData = array();
  181.                 $data['error_message'] = $this->serviceContainer->get('translator')->trans("product.RECORD_NOT_FOUND");
  182.             }
  183.         }
  184.     
  185.         $data['params_to_append'] = array_merge($this->request->get('_route_params'), $this->request->query->all());
  186.     
  187.         return array('data'=>$data,'activeCountry' => $country, 'activeCulture'=>$activeCulture,'productData'=>$productSentData);
  188.     }
  189.     
  190.     
  191.     /**
  192.      * @author Employee Id: 5406
  193.      * 
  194.      * Description : This function used for List Product Information
  195.      * 
  196.      * @Route("/list-product-filtered-by-category/{productId}/{page}",
  197.      * name="officebrain_bundle_product_list_product_filtered_by_category_wo_culture",
  198.      * requirements={"records_per_page"="12|24|48|100|996", "page"="\d+"},
  199.      * defaults={"records_per_page"=20,"page"=1})
  200.      *
  201.      * @Route("/list-product-filtered-by-category/{productId}/{country}/{language}/{page}",
  202.      * name="officebrain_bundle_product_list_product_filtered_by_category",
  203.      * requirements={"records_per_page"="12|24|48|100|996","page"="\d+"},
  204.      * defaults={"records_per_page"=20,"page"=1})
  205.      * @Template("OfficeBrain/Bundle/ProductBundle/ProductAdmin/listProductFilteredByCategory.html.twig")
  206.      */
  207.     public function listProductFilteredByCategoryAction(Request $request, $productId){
  208.         $this->init($request);
  209.         
  210.         list($defaultCulture,$defaultCountry) = explode("_",$this->request->get("_locale"));
  211.         
  212.         $param = $this->request->get('_route_params');
  213.         $culture = $this->request->get('language',$defaultCulture);
  214.         $country = $this->request->get('country',$defaultCountry);
  215.         $countryId = $this->serviceContainer->getParameter('country')[$country]['id'];
  216.         //echo $countryId= $this->country_;exit;
  217.         $activeCulture = $culture;
  218.         $searchStatus = $this->request->query->get('search_status', '');
  219.         $searchQuery = $this->request->query->get('search_query', '');
  220.         $sortBy = $this->request->query->get('sort', 'updatedAt');
  221.         $sortType = $this->request->query->get('direction', 'desc');
  222.         $searchParam = $this->request->query->get('search_param', '');
  223.         $supplier_id = $this->request->query->get('supplier_id','');
  224.         $brandIds = $this->request->query->get('brand_id','');
  225.         $catIds = $this->request->query->get('cat_id','');
  226.         
  227.         $cultureCategory =  $activeCulture . "_" . $country;
  228.         
  229. //      select all of the category ids from categorymapping entity, where product id of entity matches the product id passed in request, and country id of entity matches the country id passed in request
  230. //        then using those category ids we will filter out the products and then we will show only the products coming in these specific categories
  231.         $productCategoryIds = $this->productApiManager->getCategoryIds($productId,$countryId);
  232.         $catIds = implode(",",$productCategoryIds);
  233.         //print_r($productCategoryIds);exit;
  234.         $comproductreletedid =   $this->productApiManager->productreletedid($productId);
  235.         $productdetails = $this->productDetailManager->getProductDetailById($productId,$cultureCategory);
  236.         $product_title = $productdetails[$productId]['basic_information']['title'];
  237.         // For Pagination
  238.         $page = $this->request->get('page', '1');
  239.         $records_per_page = $param['records_per_page'];
  240.         $recordsPerPage = $this->request->query->get('recordsPerPage',$records_per_page);
  241.         $start_index = (($page - 1) * $recordsPerPage - 1);
  242.         // End Pagination
  243.         $projectSetting = $this->request->get('project_setting');
  244.         
  245.         $projectId = $projectSetting['project_id'];
  246.         $instanceType = $projectSetting['instance_type'];
  247.         $productData = $this->productApiManager->listProduct($searchStatus,$searchParam, $searchQuery, $sortType, $sortBy,$activeCulture,$country,$supplier_id,$records_per_page,$page,$projectId,$brandIds,$catIds);
  248.         
  249.         /* code for not showing the parent product in related products started */
  250.         if(isset($productData['data']))
  251.         {
  252.             $productIndex = 0;  
  253.             foreach($productData['data'] as $singleProductDetail)
  254.             {
  255.                 if(isset($singleProductDetail['product_master_id']))
  256.                 {
  257.                     if($singleProductDetail['product_master_id'] == $productId)
  258.                     { 
  259.                         unset($productData['data'][$productIndex]);
  260.                         //$productData['count'] = $productData['count'] - 1;
  261.                     }
  262.                 }
  263.                 $productIndex++;
  264.             }    
  265.         }
  266.         /* code for not showing the parent product in related products ended */
  267.         
  268.         $supplierData = $this->productApiManager->getSupplierNameList($projectId);
  269.         $brandData = $this->brandApiManager->getList($culture);
  270.         //GET CATEGORY AND SUBCATEGORY
  271.         $categoryAndSubCategoryData = $this->categoryApiManager->getList(array($cultureCategory),array(),true);
  272.         $this->catArrayNew = array();
  273.         if ($categoryAndSubCategoryData) {
  274.             foreach($categoryAndSubCategoryData[$cultureCategory] as $catKey=>$categoryAndSubCategory){
  275.                 $this->recursiveCategory($categoryAndSubCategory);
  276.             }
  277.             // Sort Category array using category name
  278.             usort($this->catArrayNew, function ($a, $b) {
  279.                 return strcasecmp($a['cat_name'], $b['cat_name']);
  280.             });
  281.         }
  282.         $data['category_SubCategory_data'] = $this->catArrayNew;
  283.         $paginator  = $this->serviceContainer->get('knp_paginator');
  284.         $data['pagination'] = $paginator->paginate($productData, $page, $recordsPerPage);
  285.         $data['page']=$page;
  286.         $data['search_status']=$searchStatus;
  287.         $data['search_query']=$searchQuery;
  288.         $data['sort_by']=$sortBy;
  289.         $data['sort_type']=$sortType;
  290.         $data['search_param']=$searchParam;
  291.         $data['supplier_id']=$supplier_id;
  292.         $data['records_per_page'] = $recordsPerPage;
  293.         $data['supplier_data'] = $supplierData;
  294.         $data['brand_id']=$brandIds;
  295.         $data['cat_id']=$catIds;
  296.         $data['brand_data']= $brandData[$culture];
  297.         $data['INSTANCE_TYPE'] = $instanceType;
  298.         
  299.         if(array_key_exists('status',$productData) && $productData['status'] == 'error' && is_array($productData))
  300.         {
  301.             $productSentData = array();
  302.             $data['error_message'] = $productData['error_message'];
  303.         }
  304.         else
  305.         {
  306.             if($productData['data']){
  307.                 $data['total_product'] = $productData['count'];
  308.                 $data['image_url'] = (array_key_exists('image_url',$productData)?$productData['image_url']:'');
  309.                 $productSentData = $productData['data'];
  310.             }else{
  311.                 $productSentData = array();
  312.                 $data['error_message'] = $this->serviceContainer->get('translator')->trans("product.RECORD_NOT_FOUND");
  313.             }
  314.         }
  315.         
  316.         $data['params_to_append'] = array_merge($this->request->get('_route_params'), $this->request->query->all());
  317.         return array('data'=>$data,'activeCountry' => $country, 'activeCulture'=>$activeCulture,'productData'=>$productSentData,'productId' => $productId,'comproductreletedid'=> $comproductreletedid,'product_title'=>$product_title);
  318.     }
  319.     
  320.     
  321.     /**
  322.      * EMp Id : 4246
  323.      * Description : This Function is Used For Update Product Status According To Parameter
  324.      *
  325.      * @Route("/change-relation-status/{country}/{set_status}",
  326.      * requirements = {"set_status"="1|0"},
  327.      * name="officebrain_product_change_relation_status")
  328.      */
  329.     public function changeProductRelationStatusAction(Request $request){
  330.         $this->init($request);
  331.         $param=$this->request->get('_route_params');
  332.         $productId=$this->request->get('productId');
  333.         $setStatus=$this->request->get('set_status');
  334.          
  335.         $relatedProductIds = array();
  336.         $relatedProductIds = $this->request->get('ids','');
  337.         $relatedProductIds = explode("::",$relatedProductIds);
  338.     
  339.         $projectSetting = $this->request->get('project_setting');
  340.         $locale_language = $projectSetting['locale_language'];
  341.     
  342.         //$productAdminManager = $this->get('office_brain_product_admin_manager');
  343.          
  344.         if($setStatus == 1)
  345.         {
  346.             $productData = $this->productApiManager->insertRelatedProducts($productId,$relatedProductIds,$locale_language);
  347.         }
  348.         else if($setStatus == 0)
  349.         {
  350.             $productData = $this->productApiManager->deleteRelatedProducts($productId,$relatedProductIds,$locale_language);
  351.         }
  352.     
  353.         $data = array();
  354.         $data['status'] = 'success';
  355.         $data['message'] = $this->translator->trans('product.PRODUCT_RELATION_UPDATED');
  356.         
  357.         RedisCacheService::removeCacheByPrefix($this->statsh_cache_wrapper,$this->moduleCachePrefix);
  358.         
  359.         return new JsonResponse($data);
  360.     }
  361.     
  362.     
  363.     /**
  364.      * Recursive function for category list
  365.      * 
  366.      * @param array $catArray
  367.      */
  368.     public function recursiveCategory($catArray){
  369.         if (array_key_exists("child",$catArray)) {
  370.             foreach($catArray['child'] as $subCatArray){
  371.                 if (array_key_exists("child",$subCatArray)) {
  372.                    foreach ($subCatArray['child'] as $leafCat) {
  373.                        $this->recursiveCategory($leafCat);
  374.                    }
  375.                 }
  376.                 else{
  377.                     $this->catArrayNew[] = $subCatArray;
  378.                 }
  379.             }
  380.         } 
  381.         else {
  382.               $this->catArrayNew[] = $catArray;
  383.         }
  384.     }
  385.     public function deleteCache($productId=0,$culture)
  386.     {
  387.         
  388.         if(!RedisCacheService::isCacheEnable())
  389.         {
  390.             return null;
  391.         }
  392.         $cacheClient=RedisCacheService::create(null,self::PRODUCT_CACHE_CLIENT);
  393.         //echo "===========$productId.':*'.$culture==========";
  394.         
  395.         // $cacheClient->removeCacheByPrefix($productId.':*'.$culture);
  396.     }
  397.     /**
  398.      * @author Employee Id: 4808
  399.      * 
  400.      * Description : This function used for Add Product Information 
  401.      * @return array 
  402.      * @Route("/add", name="officebrain_product_add"),
  403.      * @Template("OfficeBrain/Bundle/ProductBundle/ProductAdmin/add.html.twig")
  404.      */
  405.     public function addAction(Request $request){
  406.         $this->init($request);
  407.         $projectSetting = $this->request->get('project_setting');             
  408.         $instanceType = $projectSetting['instance_type'];
  409.         
  410.         $cultureName = $this->request->get('culture_name');
  411.         $master_product_id = $this->request->get('master_product_id', '');
  412.         $param = $this->request->get('_route_params');
  413.         $route = $this->request->get('_route');
  414.         
  415.         $locale_language = $param['_locale'];
  416.         $productAddSettings = $projectSetting['configuration_rule']['product']['add_update'];
  417.         $supplier_id = 0;
  418.         // set global_pricing_keys which are active
  419.         $globalPricingKeys = '';        
  420.         if(array_key_exists('global_pricing', $productAddSettings))
  421.         {
  422.             foreach ($productAddSettings['global_pricing'] as $key => $val) 
  423.             {
  424.                 if ($val['status'] == 1) 
  425.                 {
  426.                     $globalPricingKeys .= ($val['pricing_box_id'].':'.$val['pricing_box_name']).',';
  427.                 }
  428.             }
  429.         }
  430.         
  431.         //$supplierData = $this->productApiManager->getSupplierNameList($projectSetting['project_id']);        
  432.         
  433.         if ($this->request->isXmlHttpRequest() && $this->request->getMethod()=='POST') {
  434.             $data = $this->request->request->all();
  435.             $data['valid_up_to']=str_replace('/','-',$data['valid_up_to']);
  436.             $data['special_price_valid_up_to']=str_replace('/','-',$data['special_price_valid_up_to']);
  437.             $data['pricing_valid_until']=str_replace('/','-',$data['pricing_valid_until']);
  438.             $data['pricing_valid_starting']=str_replace('/','-',$data['pricing_valid_starting']);
  439.             $data['master_product_id'] = $master_product_id;
  440.             $data['project_id'] = $projectSetting['project_id'];
  441.             $data['locale_language'] = $locale_language;
  442.             $data['instance_type'] = $projectSetting['instance_type'];
  443.             $data['instance_id'] = $projectSetting['instance_id'];
  444.             $data['thumb_width'] =  $this->serviceContainer->getParameter('thumb_width');
  445.             $data['medium_thumb_width'] = $this->serviceContainer->getParameter('medium_thumb_width');
  446.   
  447.             $apiResponse =  $this->productApiManager->add($cultureName, $data);
  448.             if ($apiResponse['status']=='success') {
  449.                 $response = array('form_status' => $apiResponse['status'],'success_message'=>$this->serviceContainer->get('translator')->trans($apiResponse['success_message']));
  450.                 $this->session->set('product-list-success', $this->serviceContainer->get('translator')->trans($apiResponse['success_message']));
  451.                 
  452.                 $actionPerformed = 'create';
  453.                 if ($master_product_id) { 
  454.                     $actionPerformed = 'update';
  456.                     /* Remove Cache Of Product Details Page */
  457.                     $statsh_cache_wrapper = RedisCacheService::create();
  458.                     $moduleCachePrefix = '__ProductDetailsPageOtherProducts';
  459.                     RedisCacheService::removeCacheByPrefix($statsh_cache_wrapper,$moduleCachePrefix."*product_id#".$master_product_id);
  460.                     /* EO: Remove Cache Of Product Details Page */
  461.                 }
  463.                 if($data['product_name']['en']!=$data['old_name']){
  464.                     $this->deleteCache($apiResponse['master_product_id'],'en_us');
  465.                 }
  466.                 
  467.                 //SOLR SYNC CODE START
  468.                 $is_solr_syn_enabled = $this->serviceContainer->getParameter('solr_sync');
  469.                 if($is_solr_syn_enabled){
  470.                     $env = $this->serviceContainer->getParameter("kernel.environment");
  471.                     $localization_to_update = $this->serviceContainer->getParameter('localization_to_fetch');
  472.                     // $this->productApiManager->updateSolrData($apiResponse['master_product_id'],$localization_to_update,$projectSetting['project_id'],$env,'update'); // symfony 4
  473.                     $this->productApiManager->updateSolrData($apiResponse['master_product_id'],$localization_to_update,$projectSetting['project_id'],$env,$projectSetting['instance_id'],'update');
  474.                 }
  475.                 
  476.                 //SOLR SYNC CODE END
  477.                 
  478.                 // To Integrate With ERP
  479.                 $erpIntegration = $projectSetting['configuration_rule']['erp_integration'];
  480.                 if($erpIntegration && $erpIntegration['productManagement'] == 1 && !empty($this->queueApiManager)) {
  481.                     $this->productApiManager->integrateWithErp($this->queueApiManager, $actionPerformed, $apiResponse['master_product_id']);
  482.                 }
  483.                 if($this->request->get('syncflag')==1){ 
  484.                     if($productAddSettings['asi_call']['status']){
  485.                         foreach ($apiResponse['product_slugs'] as $culture => $slug){
  486.                             if($master_product_id > 0)
  487.                             {
  488.                                 $this->productDetailManager->updateSyncDetail($this->request->get('syncflag'),$data['sku']);
  489.                                 $asiurl = 'http://demoapi.officebrain.com/update_product_api.php?product_slug='.$slug;
  490.                             }
  491.                             else
  492.                             {
  493.                                 $this->productDetailManager->insertSyncDetail($this->request->get('syncflag'),$data['sku']);
  494.                                 $asiurl = 'http://demoapi.officebrain.com/product_api.php?product_slug='.$slug;
  495.                             }
  496.                             //echo $asiurl;die;
  497.                             exec("curl '$asiurl' > /dev/null &");
  498.                         }
  499.                     }
  500.                 }
  501.                 else
  502.                 {
  503.                     if($master_product_id > 0)
  504.                     {
  505.                         $this->productDetailManager->updateSyncDetail(0,$data['sku']);
  506.                     }
  507.                     else
  508.                     {
  509.                         $this->productDetailManager->insertSyncDetail(0,$data['sku']);
  510.                     }
  512.                     if(isset($data['sku']) && !empty($data['sku'])){
  513.                         $asiurl = 'http://demoapi.officebrain.com/product_delete_api.php?product_sku='.$data['sku'];
  514.                         exec("curl '$asiurl' > /dev/null &");
  515.                     }
  516.                 }
  517.                 
  518.             } else {
  519.                 $response = array('form_status' => $apiResponse['status'],'error_message'=>$this->serviceContainer->get('translator')->trans($apiResponse['message']));
  520.             }
  521.             return new JsonResponse($response);
  522.         }
  523.         $data_to_set =  $this->productApiManager->preSetDataForPlugin($projectSetting['configuration_rule']['product'],$projectSetting['project_id'],'',1);
  524.         $this->viewTwigData['plugin_data'] = $data_to_set['plugin_data'];
  525.         $this->viewTwigData['ATTR_TYPE_IDS'] = $this->serviceContainer->getParameter('attributes_types');
  526.         $this->viewTwigData['ATTR_IMPRINT_POSITION'] = $this->serviceContainer->getParameter('imprint_position_master_id');
  527.         $this->viewTwigData['ATTR_COLOR_ID'] = $this->serviceContainer->getParameter('color_attribute_id');        
  528.         $this->viewTwigData['params_to_append'] = array_merge($this->request->get('_route_params'), $this->request->query->all());
  529.         $this->viewTwigData['form_method'] = 'add';
  530.         $this->viewTwigData['global_pricing_keys'] = trim($globalPricingKeys, ',');
  531.         $this->viewTwigData['INSTANCE_TYPE'] = strtolower($instanceType);
  532.         return $this->viewTwigData;
  533.     }
  534.     
  535.     /**
  536.      * @author Employee Id: 4045
  537.      *
  538.      * Description : This function used to Edit Product Information
  539.      * @return array
  540.      * @Route("/edit/{master_product_id}", name="officebrain_product_edit"),
  541.      * @Template("OfficeBrain/Bundle/ProductBundle/ProductAdmin/add.html.twig")
  542.      */
  543.     public function editNewAction(Request $request){
  544.         $this->init($request);
  545.         $projectSetting = $this->request->get('project_setting');
  546.         $countryArray = $this->serviceContainer->getParameter('country');
  547.         $languageArray = $this->serviceContainer->getParameter('language');
  548.         $country_to_pass = array_column($countryArray,'short_name');
  549.         $language_to_pass = array_keys($languageArray);
  550.         $locale = $this->request->get('_locale',$this->serviceContainer->getParameter('locale'));
  551.         @list($default_language,$default_country) = explode("_",$locale);
  552.         $cultureName = $this->request->get('culture_name');
  553.         $masterProductId = $this->request->get('master_product_id', '');
  554.         $param = $this->request->get('_route_params');
  555.         $route = $this->request->get('_route');
  556.         $quoteId = $this->request->get('quote_id',0);
  557.         
  558.         // set global_pricing_keys which are active
  559.         $globalPricingKeys = '';
  560.         $productAddSettings = $projectSetting['configuration_rule']['product']['add_update'];
  561.         if(array_key_exists('global_pricing', $productAddSettings))
  562.         {
  563.             foreach ($productAddSettings['global_pricing'] as $key => $val)
  564.             {
  565.                 if ($val['status'] == 1)
  566.                 {
  567.                     $globalPricingKeys .= ($val['pricing_box_id'].':'.$val['pricing_box_name']).',';
  568.                 }
  569.             }
  570.         }
  572.         $productInfo = $this->productApiManager->editView($masterProductId,$language_to_pass,$country_to_pass,$default_language);
  573.         $syncentityobj= $this->productDetailManager->getSyncDetail($productInfo['en']['basic_information']['sku_number']);
  574.        //$supplierData = $this->productApiManager->getSupplierNameList($projectSetting['project_id']);
  575.         if(isset($syncentityobj))
  576.         {
  577.             $productInfo['syncflag']=$syncentityobj['isSync'];
  578.         }
  579.         else
  580.         {
  581.             $productInfo['syncflag']=0;
  582.         }
  583.         if(!count($productInfo)){
  584.             throw $this->createNotFoundException('The product does not exist');
  585.         }
  586.         
  587.         $data_to_set =  $this->productApiManager->preSetDataForPlugin($projectSetting['configuration_rule']['product'], $projectSetting['project_id'],$productInfo);
  588.         $this->viewTwigData['plugin_data'] = $data_to_set['plugin_data'];
  589.         $this->viewTwigData['ATTR_TYPE_IDS'] = $this->serviceContainer->getParameter('attributes_types');
  590.         $this->viewTwigData['ATTR_IMPRINT_POSITION'] = $this->serviceContainer->getParameter('imprint_position_master_id');
  591.         $this->viewTwigData['ATTR_COLOR_ID'] = $this->serviceContainer->getParameter('color_attribute_id');
  592.         $this->viewTwigData['params_to_append'] = array_merge($this->request->get('_route_params'), $this->request->query->all());
  593.         $this->viewTwigData['master_product_id'] = $masterProductId;
  594.         $this->viewTwigData['form_method'] = 'edit';
  595.         $this->viewTwigData['global_pricing_keys'] = trim($globalPricingKeys, ',');
  596.         return $this->viewTwigData;
  597.     }
  599.     /**
  600.      * @author: Employee Id : 4808
  601.      * Description: This Function is Related For Image Library
  602.      *
  603.      * @Route("/image-library",name="officebrain_product_image_library"),
  604.      * @Template("OfficeBrain/Bundle/ProductBundle/ProductAdmin/imageLibrary.html.twig")
  605.      */
  606.     public function imageLibraryAction(Request $request){
  607.         //TODO: need to get dynamic product once listing get done
  608.        $this->init($request);
  609.        $this->viewTwigData['data']=array('productId'=>1);
  610.         $mainErrorMessage='';
  611.         $isImageUploaded = false;
  612.         if ($this->request->getMethod() == "POST" ) {
  613.             $request = $request;
  614.             $fileData = $request->files->get("FileUpload");
  615.             $zipData = $request->files->get("zipUpload");
  617.             $fileUploadType = $request->get('FileUpload_type');
  618.             //TODO: need to get dynamic product once listing get done
  619.             $productId = 1;
  620.             $index = 0;
  621.             $imageArray = array();
  622.             foreach($fileData as $image){
  623.                 foreach($image as $v){
  624.                     if(!empty($v)){
  625.                         $isImageUploaded = true;
  626.                         break;
  627.                     }
  628.                 }
  629.                 if($isImageUploaded) break;
  630.             }
  631.             if(!$isImageUploaded){
  632.                 foreach($zipData as $image){
  633.                     foreach($image as $v){
  634.                         if(!empty($v)){
  635.                             $isImageUploaded = true;
  636.                             break;
  637.                         }
  638.                     }
  639.                     if($isImageUploaded) break;
  640.                 }
  641.             }
  642.             $mainErrorMessage='';
  643.             if(!$isImageUploaded){
  644.                 $mainErrorMessage =  $this->serviceContainer->get('translator')->trans('admin.image_template_library.select_files_error_msg');
  645.             }
  646.             $res =  $this->productApiManager->uploadfiles($productId, $fileData,'image',$fileUploadType);
  647.             $error_file_upload = $res['error_file_upload'];
  648.             $res = $this->productApiManager->uploadfiles($productId, $zipData,'zip');
  649.             $error_file_upload_zip = $res['error_file_upload'];
  650.         }
  651.         $errMsg = '';
  652.         $successMsg = '';
  653.         if (!empty($error_file_upload) || !empty($error_file_upload_zip)) {
  654.             $errMsg = '<ul>';
  655.             $arrImgType = array('web' => 'Web', 'template' => 'Template', 'high_res' => 'High Res');
  656.             foreach ($arrImgType as $type => $files) {
  657.                 if (isset($error_file_upload[$type]) || isset($error_file_upload_zip[$type])) {
  658.                     $errMsg.="<li>" . $files . "<ul>\n";
  659.                     if (isset($error_file_upload[$type])) {
  660.                         foreach ($error_file_upload[$type] as $fileName => $error) {
  661.                             $errMsg.="<li>" . $fileName . ":<i><b>" . $error . "</b></i></li>";
  662.                         }
  663.                     }
  664.                     if (isset($error_file_upload_zip[$type])) {
  665.                         foreach ($error_file_upload_zip[$type] as $fileName => $error) {
  666.                             $errMsg.="<li>" . $fileName . ":<i><b>" . $error . "</b></i></li>";
  667.                         }
  668.                     }
  669.                     $errMsg.="</ul></li>";
  670.                 }
  671.             }
  672.             $errMsg.='</ul>';
  673.         }elseif($mainErrorMessage != '' ){
  674.             $errMsg = '<ul><li>'.$mainErrorMessage.'</li></ul>';
  675.         }elseif($isImageUploaded){
  676.             $successMsg = $this->serviceContainer->get('translator')->trans('admin.image_template_library.upload_succ');
  677.         }
  678.        return $this->viewTwigData;
  679.     }
  681.     /**
  682.      * @Route("/browse-product-image", name="OfficeBrainImageLibraryAdmin_browse_product_image", methods={"POST"})
  683.      * @Template("OfficeBrain/Bundle/ProductBundle/ProductAdmin/browseProductImage.html.twig")
  684.      */
  685.     public function browseProductImageAction(Request $request) {
  686.         $this->init($request);
  687.         $this->request = $request;
  688.         $productId = intval($this->request->get('id'));
  689.         $imageType = $this->request->get('type');
  690.         $data = $this->productApiManager->productImages($productId,$imageType);
  691.         $imageArray = array();
  692.         if($data){
  693.             if($imageType =='high_res'){
  694.                 foreach($data as $image){
  695.                     
  696.                     if(trim($image['fileType'])!='imprinted')
  697.                         $imageArray['blank'][]=$image;
  698.                     else
  699.                         $imageArray['imprinted'][]=$image;
  700.                 }
  701.             } else {
  702.                 $imageArray = $data;
  703.             }
  704.         }
  705.         return array('imageArray' => $imageArray, 'imageType' => $imageType);
  706.     }
  707.     /**
  708.      * @Route("/remove-product-image",
  709.      * name="officebrain_image_library_admin_bundle_remove_product_image", methods={"GET","POST"}),
  710.      * @Template()
  711.      */
  712.     public function removeProductImageAction(Request $request) {
  713.         $this->init($request);
  714.         $productId = $this->request->get('productId');
  715.         $imageType = $this->request->get('imageType');
  716.         $imageId = $this->request->get('imageId');
  717.         
  718.         $result = $this->productApiManager->removeProductImage($productId,$imageId);
  719.         if ($result)
  720.             echo $this->serviceContainer->get('translator')->trans('admin.image_template_library.image_removed_succ');
  721.         else
  722.             echo $this->serviceContainer->get('translator')->trans('admin.image_template_library.image_removed_fail');
  723.     }
  724.     /**
  725.      * @author Employee Id: 4246
  726.      * Description : This function used for View Product Information
  727.      * @Route("/view",
  728.      * name="officebrain_product_view")
  729.      * @Template("OfficeBrain/Bundle/ProductBundle/ProductAdmin/view.html.twig")
  730.      */
  731.     public function viewAction(Request $request){
  732.         $this->init($request);
  733.         $product_culture = $this->request->get('product_culture');
  734.         $product_ids = $this->request->get('product_ids');
  735.         //$productAdminManager = $this->get('office_brain_product_admin_manager');
  736.         $productData = $this->productApiManager->view($product_ids,$product_culture,true);
  737.         
  738.         $projectSetting = $this->request->get('project_setting');
  739.         $productAddSettings = $projectSetting['configuration_rule']['product']['add_update'];
  740.         if(array_key_exists('global_pricing', $productAddSettings))
  741.         {
  742.             foreach ($productAddSettings['global_pricing'] as $key => $val)
  743.             {
  744.                 if ($val['status'] == 1)
  745.                 {
  746.                     $global_pricing_arr[$key] = 1;
  747.                 }
  748.             }
  749.         }
  750.         
  751.         $culture_id = $this->request->get('culture_id');
  752.         if(!count($productData)){
  753.             throw $this->createNotFoundException('The product does not exist');
  754.         }
  755.         if($productData['status'] == "success"){
  756.             $productInfo = $productData['data'];
  757.             if(array_key_exists('price_unit',$productInfo[$product_ids])){
  758.                 $priceUnit = $this->serviceContainer->getParameter('price_unit');
  759.                 $productInfo[$product_ids]['price_unit'] = array_key_exists(trim($productInfo[$product_ids]['price_unit']),$priceUnit)?$priceUnit[$productInfo[$product_ids]['price_unit']]:$productInfo[$product_ids]['price_unit'];
  760.             }
  761.             $this->viewTwigData['data'] = $productInfo[$product_ids];
  762.         }else{
  763.             $this->viewTwigData['error_message'] = $this->serviceContainer->get('translator')->trans('product.'.$productData['message']);
  764.         }
  765.         $this->viewTwigData['params_to_append'] = array_merge($this->request->get('_route_params'), $this->request->query->all());
  767.         $this->viewTwigData['global_pricing_arr'] = $global_pricing_arr;
  768.         return $this->viewTwigData;
  769.     }
  770.     /**
  771.      * @author Employee Id: 4246
  772.      * Description : This function used for Delete Product
  773.      * @Route("/delete",
  774.      * name="officebrain_product_delete")
  775.      */
  776.     public function deleteAction(Request $request){
  777.         $this->init($request);
  778.         $product_master_id = $this->request->get('product_master_id');
  779.         $product_country = $this->request->get('product_country');
  780.         $projectSetting = $this->request->get('project_setting');
  781.         $project_id = $projectSetting['project_id'];
  782.         $locale_language = $projectSetting['locale_language'];
  783.         $supplier_id = $projectSetting['user_id'];
  784.         $instance_type = $projectSetting['instance_type'];
  785.         $instance_id = $projectSetting['instance_id'];
  786.         $productData = $this->productApiManager->delete($product_master_id, $project_id, $supplier_id, $locale_language, $instance_type, $instance_id, $product_country);
  787.         // Data Array Convert Object To Array
  788.         $productData['data'] = (array)$productData['data'];
  789.         if($productData['status'] == 'success'){
  790.             $data['status'] = 'success_message';
  791.             //SOLR SYNC CODE START
  792.              $is_solr_syn_enabled = $this->serviceContainer->getParameter('solr_sync');
  793.              if($is_solr_syn_enabled){
  794.                  $env = $this->serviceContainer->getParameter("kernel.environment");
  795.                  $localization_to_update = $this->serviceContainer->getParameter('localization_to_fetch');
  796.                  $this->productApiManager->updateSolrData($product_master_id,$localization_to_update,$projectSetting['project_id'],$env,'delete');
  797.              }
  798.             //SOLR SYNC CODE END
  799.                 
  800.             // To Integrate with ERP
  801.             $erpIntegration = $projectSetting['configuration_rule']['erp_integration'];
  802.             if($erpIntegration && $erpIntegration['productManagement'] == 1 && !empty($this->queueApiManager)) {
  803.                 $dt = new \DateTime($productData['data']['deleted_at']);
  804.                 $params = array('product_id' => $product_master_id, 'country_id' => $productData['data']['country_id'], 'deleted_at'=> $dt->format('Y-m-d H:i:s'));
  805.                 $this->productApiManager->integrateWithErp($this->queueApiManager, 'remove', $product_master_id, $params);
  806.             }
  807.         }else{
  808.             $data['status'] = 'error_message';
  809.         }
  810.         $data['message'] = $this->translator->trans($productData['message']);
  811.         return new JsonResponse($data);
  812.     }
  813.     
  814.     /**
  815.      * EMp Id : 4246
  816.      * Description : This Function is Used For Update Product Status According To Parameter
  817.      * 
  818.      * @Route("/changestatus/{country}/{set_status}",
  819.      * requirements = {"set_status"="1|0"},
  820.      * name="officebrain_product_changestatus")
  821.      */
  822.     public function changeProductStatusAction(Request $request){
  823.         $this->init($request);
  824.         $param=$this->request->get('_route_params');
  825.         
  826.         $ids_to_pass = array();
  827.         $ids = $this->request->get('ids','');
  828.         $ids_to_pass = explode("::",$ids);
  829.         $productId = json_encode($ids_to_pass);
  830.         
  831.         list($defaultCulture,$defaultCountry) = explode("_",$this->request->get("_locale"));
  832.         $projectSetting = $this->request->get('project_setting');
  833.         $culture = $this->request->get('language',$defaultCulture);
  834.         $country = $this->request->get('country');
  835.         $setStatus = $this->request->get('set_status');
  836.         $cultureCategory =  $culture. "_" . $country;
  837.         
  838.         $project_id = $projectSetting['project_id'];
  839.         $locale_language = $projectSetting['locale_language'];
  840.         $supplier_id = $projectSetting['user_id'];
  841.         $instance_type = $projectSetting['instance_type'];
  842.         $instance_id = $projectSetting['instance_id'];
  843.         
  844.         //$productAdminManager = $this->get('office_brain_product_admin_manager');
  845.         $productData = $this->productApiManager->changeProductStatus($productId,$country,$setStatus, $project_id, $supplier_id, $locale_language, $instance_type, $instance_id);
  846.         $data = array();
  847.         if($productData['status'] == 'success'){            
  848.             //SOLR SYNC CODE START
  849.             $is_solr_syn_enabled = $this->serviceContainer->getParameter('solr_sync');
  850.             if($is_solr_syn_enabled){
  851.                 $env = $this->serviceContainer->getParameter("kernel.environment");
  852.                 $localization_to_update = $this->serviceContainer->getParameter('localization_to_fetch');
  853.                 // $solrProductManager = $this->serviceContainer->get('office_brain_solr_product_mapping_manager');
  854.                 $solrProductManager = $this->solrService;
  855.                 foreach($ids_to_pass as $product_id_to_process){
  856.                     if(!$setStatus){
  857.                         $this->productApiManager->updateSolrData($product_id_to_process,$localization_to_update,$projectSetting['project_id'],$env, $instance_id,'delete');
  858.                         $productdetails = $this->productDetailManager->getProductDetailById($product_id_to_process,$cultureCategory);
  859.                         
  860.                         if(strpos($productdetails[$product_id_to_process]['basic_information']['sku_number'], '-') != false && isset($productdetails[$product_id_to_process]['other_products'])){
  861.                             $main_sku = $productdetails[$product_id_to_process]['basic_information']['sku_number'];
  862.                             $main_sku = explode('-', $main_sku); // get main sku
  864.                             $mainSku = $main_sku[1];                 
  865.                             if(isset($productdetails[$product_id_to_process]['other_products']) && is_array($productdetails[$product_id_to_process]['other_products'])){
  866.                                 $sortOrder = array($mainSku, '80-'.$mainSku,'75-'.$mainSku, '76-'.$mainSku, '81-'.$mainSku,'82-'.$mainSku,'86-'.$mainSku, '10-'.$mainSku, '42-'.$mainSku, '20-'.$mainSku, '28-'.$mainSku, '25-'.$mainSku );
  867.                                 usort($productdetails[$product_id_to_process]['other_products'], function ($a, $b) use ($sortOrder) {
  868.                                     $pos_a = array_search($a['sku_number'], $sortOrder);
  869.                                     $pos_b = array_search($b['sku_number'], $sortOrder);
  870.                                     return $pos_a - $pos_b;
  871.                                 });
  872.                                 
  873.                             }
  874.                             else{
  875.                                 $productdetails[$product_id_to_process]['other_products'] = null;
  876.                             }
  878.                             // Update other Products
  879.                             if(isset($productdetails[$product_id_to_process]['other_products']) && !empty($productdetails[$product_id_to_process]['other_products'])){
  880.                                 foreach($productdetails[$product_id_to_process]['other_products'] as $otherProduct){
  881.                                     if( $otherProduct['id'] == $product_id_to_process ){
  882.                                         $this->productApiManager->updateSolrData($otherProduct['id'],$localization_to_update,$projectSetting['project_id'],$env, $instance_id,'delete');
  883.                                     }
  884.                                     else{
  885.                                         $this->productApiManager->updateSolrData($otherProduct['id'],$localization_to_update,$projectSetting['project_id'],$env, $instance_id,'update');
  886.                                     }
  887.                                 }
  888.                             }
  889.                         }
  890.                         // update main sku
  891.                         // if($productdetails[$product_id_to_process]['basic_information']['sku_number']){
  892.                         //     $sku_split = explode('-',$productdetails[$product_id_to_process]['basic_information']['sku_number']);
  893.                         //     if(count($sku_split) == 2){
  894.                         //         $productDetailArray =$this->productDetailManager->getProductDetailBySku($sku_split[1],$productdetails[$product_id_to_process]['supplier']['supplier_id'],$cultureCategory);
  895.                         //         $this->productApiManager->updateSolrData($productDetailArray['product_id'],$localization_to_update,$projectSetting['project_id'],$env,'update');
  896.                                 
  897.                         //     }
  898.                         // }
  899.                     }else{
  900.                         $this->productApiManager->updateSolrData($product_id_to_process,$localization_to_update,$projectSetting['project_id'],$env, $instance_id,'update');
  901.                         $productdetails = $this->productDetailManager->getProductDetailById($product_id_to_process,$cultureCategory);
  902.                         
  903.                         // Update other Products
  904.                         if(strpos($productdetails[$product_id_to_process]['basic_information']['sku_number'], '-') != false && isset($productdetails[$product_id_to_process]['other_products'])){
  905.                             $main_sku = $productdetails[$product_id_to_process]['basic_information']['sku_number'];
  906.                             $main_sku = explode('-', $main_sku); // get main sku
  908.                             $mainSku = $main_sku[1];                 
  909.                             if(isset($productdetails[$product_id_to_process]['other_products']) && is_array($productdetails[$product_id_to_process]['other_products'])){
  910.                                 $sortOrder = array($mainSku, '80-'.$mainSku,'75-'.$mainSku, '76-'.$mainSku, '81-'.$mainSku,'82-'.$mainSku,'86-'.$mainSku, '10-'.$mainSku, '42-'.$mainSku, '20-'.$mainSku, '28-'.$mainSku, '25-'.$mainSku );
  911.                                 usort($productdetails[$product_id_to_process]['other_products'], function ($a, $b) use ($sortOrder) {
  912.                                     $pos_a = array_search($a['sku_number'], $sortOrder);
  913.                                     $pos_b = array_search($b['sku_number'], $sortOrder);
  914.                                     return $pos_a - $pos_b;
  915.                                 });
  916.                                 
  917.                             }
  918.                             else{
  919.                                 $productdetails[$product_id_to_process]['other_products'] = null;
  920.                             }
  921.                         }
  922.                         if(isset($productdetails[$product_id_to_process]['other_products']) && !empty($productdetails[$product_id_to_process]['other_products'])){
  923.                             $index = 1;
  924.                             $isFound = 0;
  925.                             $operation = 'update';
  926.                             foreach($productdetails[$product_id_to_process]['other_products'] as $otherProduct){
  927.                                 if($index == 1 && $otherProduct['id'] == $product_id_to_process){
  928.                                     $isFound = 1;
  929.                                     $operation = 'update';
  930.                                 }
  931.                                 elseif( $index > 1 && $otherProduct['id'] == $product_id_to_process){
  932.                                     $isFound = 1;
  933.                                     $operation = 'delete';
  934.                                 }
  935.                                 elseif($isFound == 1){
  936.                                     $operation = 'delete';
  937.                                 }
  938.                                 else{
  939.                                     $operation = 'update';
  940.                                 }
  941.                                 $this->productApiManager->updateSolrData($otherProduct['id'],$localization_to_update,$projectSetting['project_id'],$env, $instance_id,$operation);
  942.                                 if($operation == 'delete'){
  943.                                     $this->productApiManager->updateSolrData($otherProduct['id'],$localization_to_update,$projectSetting['project_id'],$env, $instance_id,'update');
  944.                                 }
  945.                                 $index++;
  946.                             }
  947.                         }
  948.                         
  949.                         // if($productdetails[$product_id_to_process]['basic_information']['sku_number']){
  950.                         //     $sku_split = explode('-',$productdetails[$product_id_to_process]['basic_information']['sku_number']);
  951.                         //     if(count($sku_split) == 2){
  952.                         //         $productDetailArray =$this->productDetailManager->getProductDetailBySku($sku_split[1],$productdetails[$product_id_to_process]['supplier']['supplier_id'],$cultureCategory);
  953.                         //         $this->productApiManager->updateSolrData($productDetailArray['product_id'],$localization_to_update,$projectSetting['project_id'],$env,'update');
  954.                         //     }
  955.                         // }
  956.                     }
  957.                 }
  958.             }
  959.             //SOLR SYNC CODE END
  960.             
  961.             // To Integrate with ERP
  962.             $productIds = json_decode($productId);
  963.             $erpIntegration = $projectSetting['configuration_rule']['erp_integration'];
  964.             if($erpIntegration && $erpIntegration['productManagement'] == 1 && !empty($this->queueApiManager)) {
  965.                 foreach ($productData['data'] as $key => $value) {
  966.                     $params = array('product_id' => $productIds[$key], 'country_id' => $value['countryId'],'status'=> $setStatus);
  967.                     $this->productApiManager->integrateWithErp($this->queueApiManager, 'updateStatus', $productIds[$key], $params);
  968.                 }
  969.             }
  970.             $data['status'] = 'success';
  971.             RedisCacheService::removeCacheByPrefix($this->statsh_cache_wrapper,$this->moduleCachePrefix);
  972.             
  973.         }else{
  974.             $data['status'] = 'error';
  975.         }
  976.         $data['message'] = $this->translator->trans('product.'.$productData['message']);
  977.         return new JsonResponse($data);
  978.     }
  979.     
  980.     /**
  981.      * EMp Id : 4246
  982.      * Description : This Function is Used For Update Product Status According To Parameter
  983.      *
  984.      * @Route("/check-duplicate-sku",
  985.      * name="officebrain_product_check_duplicate_sku")
  986.      */
  987.     public function checkDuplicateSKU(Request $request){
  988.         $this->init($request);
  989.         $sku = $this->request->get('sku');
  990.         $supplierId = $this->request->get('supplier_id');
  991.         $productId = $this->request->get('product_id','');
  992.         $data = $this->productApiManager->checkDuplicateSKU($sku,$supplierId,$productId);
  993.         $data['message'] = $this->translator->trans('product.'.$data['message']);
  994.         return new JsonResponse($data);
  995.     }
  996.     
  997.     /**
  998.      * @author Employee Id: 5190
  999.      * Description : This function used for List Matrix Information
  1000.      * @Route("/matrix/list",
  1001.      * name="officebrain_product_matrix_list")
  1002.      * @Template("OfficeBrain/Bundle/ProductBundle/ProductAdmin/listMatrix.html.twig")
  1003.      */
  1004.     public function listMatrixAction(Request $request){
  1005.         $this->init($request);
  1006.         $projectSetting = $this->request->get('project_setting');
  1007.         $projectId = $projectSetting['project_id'];
  1008.         $data['matrix_data'] = $this->productApiManager->getMatrixList($projectId);
  1009.         return array('data'=>$data);
  1010.     }
  1011.     
  1012.     /**
  1013.      * @author Employee Id: 5540
  1014.      *
  1015.      * Description : This function used to Edit Product Information
  1016.      * @return array
  1017.      * @Route("/copy/{master_product_id}/{supplier_id}", name="officebrain_product_copy"),
  1018.      * @Template("OfficeBrain/Bundle/ProductBundle/ProductAdmin/add.html.twig")
  1019.      */
  1020.     public function copyProductAction(Request $request)
  1021.     {
  1022.         //$this->init($request);
  1023.         $supplierId = $request->get('supplier_id');
  1024.         $productId = $request->get('master_product_id','');
  1025.         $projectSetting = $request->get('project_setting');
  1026.         // $returnData = $this->serviceContainer->get("office_brain_product_admin_manager")->copy($supplierId, $productId);
  1027.         $returnData = $this->productApiManager->copy($supplierId, $productId);
  1028.         $returnData = array('status' => 'success');
  1029.          
  1030.         /*
  1031.         //SOLR SYNC CODE START
  1032.             $is_solr_syn_enabled = $this->container->getParameter('solr_sync');
  1033.                 if($is_solr_syn_enabled)
  1034.                 {
  1035.                 $env = $this->container->getParameter("kernel.environment");
  1036.                 $localization_to_update = $this->container->getParameter('localization_to_fetch');
  1037.                 $this->get("office_brain_product_admin_manager")->updateSolrData($newProductId,$localization_to_update,$projectSetting['project_id'],$env,$projectSetting['instance_id'],'update');
  1038.             }
  1039.         //SOLR SYNC CODE END
  1040.         */
  1041.          
  1042.         if($returnData['status'] == 'success')
  1043.         {
  1044.             $data['status'] = 'success_message';
  1045.             $data['message'] = $this->serviceContainer->get('translator')->trans('product_add_edit.product_copied_successfully');
  1046.         }
  1047.         else
  1048.         {
  1049.             $data['status'] = 'error_message';
  1050.             $data['message'] = $this->serviceContainer->get('translator')->trans('product_add_edit.product_not_copied');
  1051.         }
  1052.          
  1053.         return new JsonResponse($data);
  1054.     }
  1055.     
  1056.     /**
  1057.      * @author Employee Id: 5190
  1058.      *
  1059.      * Description : This function used for Export Product data culture and country wise
  1060.      * @return array
  1061.      * @Route("/export", name="officebrain_product_export"),
  1062.      * @Template("OfficeBrain/Bundle/ProductBundle/ProductAdmin/export.html.twig")
  1063.      */
  1064.     public function exportAction(Request $request)
  1065.     {
  1066.         $this->init($request);
  1067.         $projectSetting = $this->request->get('project_setting');
  1068.         $projectId = $projectSetting['project_id'];
  1069.         list($defaultCulture,$defaultCountry) = explode("_",$this->request->get("_locale"));
  1070.         $culture = $this->request->get('language',$defaultCulture);
  1071.         $country = $this->request->get('country',$defaultCountry);
  1072.         $supplier_id = $this->request->query->get('supplier_id','');
  1073.         $countryArray = $this->serviceContainer->getParameter('country');
  1074.         $languageArray = $this->serviceContainer->getParameter('language');
  1075.         $supplierData = $this->productApiManager->getSupplierNameList($projectId);
  1076.         $instanceType = $projectSetting['instance_type'];
  1077.         // if ($this->user->getUserType()=='admin' && $instanceType=='association'){ // symfony 4
  1078.         if ($this->user && $this->user->getUserType()=='admin' && $instanceType=='association'){
  1079.             $supplier_id = $this->request->query->get('supplier_id','');
  1080.         // } else if($this->user && $this->user->getUserType()=='supplier' || $this->user->getUserType()=='distributor' || ($this->user->getUserType() == 'admin' && $instanceType == 'distributor') || ($this->user->getUserType() == 'admin' && $instanceType == 'supplier')){ // symfony 4
  1081.         } elseif ($this->user && (
  1082.             $this->user->getUserType() == 'supplier' || 
  1083.             $this->user->getUserType() == 'distributor' || ( 
  1084.                 $this->user->getUserType() == 'admin' && (
  1085.                     $instanceType == 'distributor' || 
  1086.                     $instanceType == 'supplier'
  1087.                 ) 
  1088.             ) 
  1089.         ) ) {
  1090.             $supplier_id = $this->user->getObCustomerId();
  1091.             $supplier_id = str_replace(array('OB','ob'), '', $supplier_id);
  1092.     
  1093.             if(empty($supplier_id)){
  1094.                 $supplier_id = 0;
  1095.             }
  1096.         }else{
  1097.             $supplier_id = 0;
  1098.         }
  1099.     
  1100.         foreach($countryArray as $countryKey => $country){
  1101.             $data['country_data'][] = array('id'=>$country['id'],'code'=>$country['short_name'],'title'=>$country['name'],'language'=>$country['language']);
  1102.         }
  1103.     
  1104.         if ($this->request->isXmlHttpRequest() && $this->request->getMethod()=='POST') {
  1105.             $data = $this->request->request->all();
  1106.             $apiResponse =  $this->productApiManager->getExportProduct($data);
  1107.     
  1108.             return new JsonResponse($apiResponse);
  1109.         }
  1110.         $data['project_id']= $projectId;
  1111.         $data['country_array'] = $countryArray;
  1112.         $data['language_data'] = $languageArray;
  1113.         $data['supplier_data'] = $supplierData;
  1114.         $data['INSTANCE_TYPE'] = $instanceType;
  1115.         $data['supplier_id']=$supplier_id;
  1116.     
  1117.         return array('data'=>$data);
  1118.     
  1119.     }
  1121.     /**
  1122.      * @author Employee Id: 5190
  1123.      *
  1124.      * Description : This function used for Import Product data supplier, culture and country wise
  1125.      * @return array
  1126.      * @Route("/import", name="officebrain_product_import"),
  1127.      * @Template("OfficeBrain/Bundle/ProductBundle/ProductAdmin/import.html.twig")
  1128.      */
  1129.     
  1130.     public function importAction(Request $request){
  1131.         $this->init($request);
  1132.         $projectSetting = $this->request->get('project_setting');
  1133.         $projectId = $projectSetting['project_id'];
  1134.         list($defaultCulture,$defaultCountry) = explode("_",$this->request->get("_locale"));
  1135.         $culture = $this->request->get('language',$defaultCulture);
  1136.         $country = $this->request->get('country',$defaultCountry);
  1137.         $supplier_id = $this->request->query->get('supplier_id','');
  1138.         //echo $supplier_id;die;
  1139.          
  1140.         $countryArray = $this->serviceContainer->getParameter('country');
  1141.         $languageArray = $this->serviceContainer->getParameter('language');
  1142.     
  1143.         $supplierData = $this->productApiManager->getSupplierNameList($projectId);
  1144.         $instanceType = $projectSetting['instance_type'];
  1146.         if ($this->user && $this->user->getUserType()=='admin' && $instanceType=='association'){
  1147.             $supplier_id = $this->request->query->get('supplier_id','');
  1148.         // } else if($this->user->getUserType()=='supplier' || $this->user->getUserType()=='distributor' || ($this->user->getUserType() == 'admin' && $instanceType == 'distributor') || ($this->user->getUserType() == 'admin' && $instanceType == 'supplier')){ // symfony 4
  1150.         } elseif ($this->user && (
  1151.             $this->user->getUserType() == 'supplier' || 
  1152.             $this->user->getUserType() == 'distributor' || ( 
  1153.                 $this->user->getUserType() == 'admin' && (
  1154.                     $instanceType == 'distributor' || 
  1155.                     $instanceType == 'supplier'
  1156.                 ) 
  1157.             ) 
  1158.         ) ) {
  1159.             $supplier_id = $this->user->getObCustomerId();
  1160.             $supplier_id = str_replace(array('OB','ob'), '', $supplier_id);
  1162.             if(empty($supplier_id)){
  1163.                 $supplier_id = 0;
  1164.             }
  1165.         }else{
  1166.             $supplier_id = 0;
  1167.         }
  1168.         foreach($countryArray as $countryKey => $country){
  1169.             $data['country_data'][] = array('id'=>$country['id'],'code'=>$country['short_name'],'title'=>$country['name'],'language'=>$country['language']);
  1170.         }
  1171.     
  1172.         if ($this->request->isXmlHttpRequest() && $this->request->getMethod()=='POST') {
  1173.             $uploadImportFilePath = $this->serviceContainer->getParameter('tmp_image_upload_path');;
  1174.             $allwedImportFileMimeType = $this->serviceContainer->getParameter('allowed_import_file_mime_type');
  1175.             $translator = $this->serviceContainer->get('translator');
  1176.             //echo $uploadImportFilePath;die;
  1177.             if(!IS_DIR($uploadImportFilePath)){
  1178.                 mkdir($uploadImportFilePath,0777,true);
  1179.             }
  1180.     
  1181.             $importFileName = '';
  1182.             $error = false;
  1183.             $supplierId = $this->request->get('supplier_id','');
  1184.             $countryId = $this->request->get('country_id','');
  1185.             $cultureId = $this->request->get('culture_id','');
  1186.             $userId = $this->userId;
  1187.             //echo $supplierId.'---'.$countryId.'---'.$cultureId.'--'.$userId;die;
  1188.             if(!empty($_FILES) && $countryId >0 && $cultureId >0 && $supplierId>0){
  1189.                 foreach($_FILES as $file)
  1190.                 {
  1191.                     $filename = $file['name'];
  1192.                     $extension = pathinfo($filename, PATHINFO_EXTENSION);
  1193.                     if($extension != 'xls'){
  1194.                         $error = true;
  1195.                         $error_message = $translator->trans('product_import_export.allowed_import_file_type');
  1196.                     }
  1197.                     
  1198.                     if(!$error){
  1199.                         $importFileName = "import_supplierid_".$supplierId."_countryid_".$countryId."_cultureid_".$cultureId."_".time().".".$extension;
  1200.                         $uploadImportFile = $uploadImportFilePath.$importFileName;
  1201.                         $file_moved = @move_uploaded_file($file['tmp_name'], $uploadImportFile);
  1202.                         
  1203.                         if($file_moved){
  1204.                             $response = $this->productApiManager->uploadImportFile($supplierId,$countryId,$cultureId,$projectId,$uploadImportFile,$uploadImportFilePath, $userId);
  1205.                                                                     
  1206.                             if($response['status'] == 'success'){
  1207.                                 if(file_exists($uploadImportFile)){
  1208.                                     @unlink($uploadImportFile);
  1209.                                 }
  1210.                                 $error = false;
  1211.                                 $success_message = $translator->trans('product_import_export.import_process_start');
  1212.                             }
  1213.                             else{
  1214.                                 $error = true;
  1215.                                 $error_message = $translator->trans('product_import_export.file_upload_error_message');
  1216.                             }
  1217.                         }
  1218.                         else {
  1219.                             $error = true;
  1220.                             $error_message = $translator->trans('product_import_export.file_upload_error_message'); 
  1221.                         }
  1222.                     }
  1223.                 }
  1224.             }
  1225.  
  1226.             
  1227.             else{
  1228.                 $error = true;
  1229.                 $error_message = $translator->trans('product.file_not_found');   //"Please select file" ;
  1230.             }
  1231.     
  1232.             if(!$error){
  1233.                 $return = array (
  1234.                         'status' => 'success',
  1235.                         'success_message'=> $success_message,
  1236.                 );
  1237.             } else {
  1238.                 $return = array (
  1239.                         'status' => 'error',
  1240.                         'error_message' => $error_message);
  1241.             }
  1242.     
  1243.             return new JsonResponse($return);
  1244.         }
  1245.     
  1246.         $data['country_array'] = $countryArray;
  1247.         $data['language_data'] = $languageArray;
  1248.         $data['supplier_data'] = $supplierData;
  1249.         $data['INSTANCE_TYPE'] = $instanceType;
  1250.         $data['supplier_id']=$supplier_id;
  1251.     
  1252.         return array('data'=>$data);
  1253.     
  1254.     }
  1255.     
  1256.     /**
  1257.      * @author Employee Id: 5190
  1258.      *
  1259.      * Description : This function used for Import Product data supplier, culture and country wise
  1260.      * @return array
  1261.      * @Route("/check_import_status", name="officebrain_product_check_import_status"),
  1262.      * options={"expose"=true},
  1263.      * @Template("OfficeBrain/Bundle/ProductBundle/ProductAdmin/checkImportStatus.html.twig")
  1264.      */
  1265.     
  1266.     public function checkImportStatusAction(Request $request){
  1267.         $this->init($request);
  1268.         $supplierId = $request->get('supplier_id');
  1269.         $projectSetting = $this->request->get('project_setting');
  1270.         $projectId = $projectSetting['project_id'];
  1271.     
  1272.         $returnData = $this->productApiManager->checkImportStatus($supplierId,$projectId);
  1273.     
  1274.         return array('data'=>$returnData);
  1275.     
  1276.     }
  1277.     
  1278.     /**
  1279.      * @author Employee Id: 5190
  1280.      *
  1281.      * Description : This function used for add inventory message sku colour wise
  1282.      * @return array
  1283.      * @Route("/get-inventory-message/{sku}", name="officebrain_product_add_inventory_message"),
  1284.      * options={"expose"=true},
  1285.      */
  1286.     public function addInventoryMessageAction(Request $request){
  1287.         $this->init($request);
  1288.         $sku = $request->get('sku');
  1289.         $data = json_encode(array('message'=>'','sku'=>$sku));
  1290.         $obj = $this->productApiManager->getInvMessageBySku($sku);
  1291.         //var_dump($obj); die;
  1292.         if(count($obj)>0){ 
  1293.             $data =  json_encode(array('message'=>$obj[0]->getMessage(),'sku'=>$obj[0]->getProductSku()));
  1294.         }
  1295.         echo $data;
  1296.         die;  
  1297.         //$this->productApiManager;
  1298.     }
  1299.     
  1300.     /**
  1301.      * @author Employee Id: 5190
  1302.      *
  1303.      * Description : This function used for add inventory message sku colour wise
  1304.      * @return array
  1305.      * @Route("/add-inventory-message", name="officebrain_product_update_inventory_message"),
  1306.      * options={"expose"=true},
  1307.      */
  1308.     public function updateInventoryMessageAction(Request $request){
  1309.         $this->init($request);
  1310.         $parameters = $request->request->all();
  1311.         /*if($parameters['inv_message']==""){
  1312.          $data = json_encode(array('status'=>'error_message','message'=>'Enter Message'));
  1313.          }else{*/
  1314.         $object = null;
  1315.         $message = $parameters['inv_message'];
  1316.         $sku = $parameters['inv_sku'];
  1317.         $obj = $this->productApiManager->getInvMessageBySku($sku);
  1318.         if(count($obj)>0){
  1319.             $object = $obj[0];
  1320.         }
  1321.         $this->productApiManager->updateMessage($object,$message,$sku);
  1322.         $data = json_encode(array('status'=>'success_message','message'=>'Message added successfully'));
  1323.         //}
  1324.         echo $data;
  1325.         die;
  1326.     }
  1327.     /**
  1328.      * @author Employee Id: 5190
  1329.      *
  1330.      * Description : This function used for get importErrorLog using importId.
  1331.      * @return array
  1332.      * @Route("/import_error_log/{import_id}", name="officebrain_product_import_error_log"),
  1333.      * @Template("")
  1334.      */
  1335.     
  1336.     public function importErrorLogAction(Request $request){
  1337.         $this->init($request);
  1338.         $importId = $request->get('import_id');
  1339.         $returnData = $this->productApiManager->importErrorLog($importId);
  1340.         $filename = "import_error_log_" . $importId.".csv";
  1341.         $response = $this->render('OfficeBrain/Bundle/ProductBundle/ProductAdmin/importErrorLog.csv.twig',array('data' => $returnData));
  1342.         //$response->setStatusCode(200);
  1343.         $response->headers->set('Content-Type', 'text/csv');
  1344.         $response->headers->set('Content-Disposition', 'attachment; filename="'.$filename.'"');
  1345.         $response->headers->set('Pragma', 'no-cache');
  1346.         $response->headers->set('Expires', '0');
  1347.         //$response->sendHeaders();
  1348.         //$response->sendContent();
  1349.         return $response;
  1350.     
  1351.         //return array('data'=>$returnData);
  1352.     }
  1353.     
  1354.     
  1355.     /**
  1356.      * @Route("/suggestedProduct/{id}",
  1357.      * name="officebrain_product_bundle_get_suggested_product",
  1358.      * options={"expose"=true}, methods={"GET"})
  1359.      */
  1360.     public function getSuggestedProductByProductIdAction(Request $request, $id){
  1361.         $this->init($request);
  1362.         $data = $this->productApiManager->getSuggestedProductByProductId($id);
  1363.         
  1364.         return new JsonResponse($data);
  1365.     }
  1366.     
  1367.     /**
  1368.      * @Route("/suggestedProduct/{id}",
  1369.      * name="officebrain_product_bundle_set_suggested_product",
  1370.      * options={"expose"=true}, methods={"POST"})
  1371.      */
  1372.     public function setSuggestedProductByProductIdAction(Request $request, $id){
  1373.         $this->init($request);
  1374.         $pmsId = $id;
  1375.         $productsSku = $this->request->get('products_sku');
  1376.         //         $products =
  1377.         $api_manager = $this->serviceContainer->get('officebrain_category_api_manager');
  1378.         $data = $this->productApiManager->setSuggestedProductByProductId($pmsId,$productsSku);
  1379.         $data['message'] = $this->translator->trans($data['message']);
  1380.         return new JsonResponse($data);
  1381.     }
  1382.     
  1383.     /**
  1384.      * @author Employee Id: 5429
  1385.      *
  1386.      * Description : This function used for add inventory message sku colour wise
  1387.      * @return array
  1388.      * @Route("/get-rsync-status/{sku}/{slug}", name="officebrain_product_rsync_check"),
  1389.      * options={"expose"=true},
  1390.      */
  1391.    public function getRsyncStatusAction(Request $request){
  1392.         $this->init($request);
  1393.         $sku = $request->get('sku');
  1394.         $slug = $request->get('slug');
  1395.         $this->productDetailManager->updateSyncDetail(1,$sku);
  1397.         //$asiurl = 'http://demoapi.officebrain.com/update_product_api.php?product_slug=16-oz-victory-acrylic-tumbler-with-straw-lid-full-color-digital';
  1398.         //$result = exec("curl '$asiurl' > /dev/null &",$output,$return_val);
  1399.         $asiurl = 'https://demoapi.officebrain.com/update_product_api.php?product_slug='.$slug;
  1400.        //$asiurl = 'http://demoapi.officebrain.com/update_product_api.php?product_slug=halcyon-r-waterproof-wireless-speaker-full-color-digital';
  1401.       
  1402.         $curl = curl_init();
  1403.         curl_setopt_array($curl, array(
  1404.           CURLOPT_URL => $asiurl,
  1405.           CURLOPT_RETURNTRANSFER => true,
  1406.           CURLOPT_ENCODING => '',
  1407.           CURLOPT_MAXREDIRS => 10,
  1408.           CURLOPT_TIMEOUT => 0,
  1409.           CURLOPT_FOLLOWLOCATION => true,
  1410.           CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  1411.           CURLOPT_CUSTOMREQUEST => 'GET',
  1412.           CURLOPT_SSL_VERIFYPEER =>0
  1413.         ));
  1414.         $response = curl_exec($curl); 
  1415.         if (curl_errno($curl)) {
  1416.             echo $error_msg = curl_error($curl); die;
  1417.         }
  1418.         curl_close($curl); 
  1419.         echo $response;
  1422.        /* $result = exec("curl '$asiurl' 2>&1 &", $output);
  1423.         if(isset($output[3]) && $output[3]!=''){
  1424.             $msg = json_decode($output[3]);
  1425.             $reason = $msg->Errors[0]->Reason;
  1426.             $data = json_encode(array('status'=>'success_message','message'=>'Reason:'.$reason));
  1427.         }else{
  1428.             $data = json_encode(array('status'=>'success_message','message'=>'Product Sync Successfully'));
  1429.         }*/
  1430.        // echo $data;
  1431.         die;
  1432.     }
  1433.     
  1434.     /**
  1435.      * @author Employee Id: 5429
  1436.      *
  1437.      * Description : This function used for add imprint method on skus
  1438.      * @return array
  1439.      * @Route("/imprint-skus", name="officebrain_imprint_skus_product"),
  1440.      * @Template("OfficeBrain/Bundle/ProductBundle/ProductAdmin/getImprintSkus.html.twig")
  1441.      */
  1442.     public function getImprintSkusAction(Request $request){
  1443.         $searchParameters = array();
  1444.         // $productTagManager = $this->serviceContainer->get('office_brain_product_tag_manager');
  1445.         $productTagManager = $this->productTagManager;
  1446.         if(!empty($_REQUEST['sku']) && $_REQUEST['sku']!=""){
  1447.             $culture = $request->get('_locale','en_us');
  1448.             // $productDetailManager = $this->serviceContainer->get('office_brain_product_detail_manager');
  1449.             $productDetailManager = $this->productDetailManager;
  1450.             $productObj = $productDetailManager->getProductDetailBySku($_REQUEST['sku'], 5,$culture,false);
  1451.             if(isset($productObj['product_id'])){
  1452.                 $data['product_id'] = $productObj['product_id'];
  1453.                 $data['imprint'] = $_REQUEST['imprint'];
  1454.                 $data['sku'] = $productObj['basic_information']['sku_number'];
  1455.                 $data['product_title'] = $productObj['basic_information']['title'];
  1456.                 $data['product_image'] = $productObj['basic_information']['default_image_thumb_url'];
  1457.                 $productImprint = $productTagManager->getImprintProductByIdAndMethod($data['product_id'],$data['imprint']);
  1458.                 if($productImprint==NULL){
  1459.                     $productTagManager->addImprintProduct($data);
  1460.                      //SOLR SYNC CODE START
  1461.                     // $productApiManager = $this->serviceContainer->get("office_brain_product_admin_manager");
  1462.                     $productApiManager = $this->productApiManager;
  1463.                     $is_solr_syn_enabled = $this->serviceContainer->getParameter('solr_sync');
  1464.                     if($is_solr_syn_enabled){
  1465.                         $env = $this->serviceContainer->getParameter("kernel.environment");
  1466.                         $localization_to_update = $this->serviceContainer->getParameter('localization_to_fetch');
  1467.                         $productApiManager->updateSolrData($data['product_id'],$localization_to_update,5,$env,'update');
  1468.                     }
  1469.                     
  1470.                     //SOLR SYNC CODE END
  1471.                 
  1472.                     $this->get('session')->getflashbag()->add('success_message', 'Sku mapped successfully.');
  1473.                 }else{
  1474.                     $this->get('session')->getflashbag()->add('error_message', 'Sku already mapped.');
  1475.                     return $this->redirect($this->generateUrl('officebrain_imprint_skus_product'));
  1476.                 }
  1477.             }
  1478.                 
  1479.         }
  1480.         $searchParameters['search_result_array']['data'] = $productTagManager->getAllImprintProducts();
  1481.         // $this->arrayToPaginationManager = $this->serviceContainer->get('office_brain_array_to_pagination_manager');
  1482.         $this->arrayToPaginationManager = $this->arrayToPaginationManager;
  1483.         if(!empty($searchParameters['search_result_array'])){
  1484.             $this->arrayToPaginationManager->setPaginationArray($searchParameters['search_result_array']);
  1485.             $this->arrayToPaginationManager->doConvert();
  1486.             $searchParameters['pagination'] = $this->arrayToPaginationManager->getPagination();
  1487.         }
  1488.         return $searchParameters;
  1489.     }
  1490.     
  1491.     /**
  1492.      * @author Employee Id: 5429
  1493.      *
  1494.      * Description : This function used for add imprint method on skus
  1495.      * @return array
  1496.      * @Route("/remove-imprint-skus/{id}", name="officebrain_product_remove_imprint_skus"),
  1497.      */
  1498.     public function removeImprintSkusAction(Request $request){
  1499.         $id = $request->get('id');
  1500.         $productTagManager = $this->productTagManager;
  1501.         $prodData = $productTagManager->getImprintProductById($id);
  1502.         if($prodData!=NULL){
  1503.              $productId = $prodData->getProductId();
  1504.              $productTagManager->deleteImprintProductById($prodData);
  1505.               //SOLR SYNC CODE START
  1506.                     // $productApiManager = $this->serviceContainer->get("office_brain_product_admin_manager");
  1507.                     $productApiManager = $this->productApiManager;
  1508.                     $is_solr_syn_enabled = $this->serviceContainer->getParameter('solr_sync');
  1509.                     if($is_solr_syn_enabled){
  1510.                         $env = $this->serviceContainer->getParameter("kernel.environment");
  1511.                         $localization_to_update = $this->serviceContainer->getParameter('localization_to_fetch');
  1512.                         $productApiManager->updateSolrData($productId,$localization_to_update,5,$env,'update');
  1513.                     }
  1514.                     
  1515.                     //SOLR SYNC CODE END
  1516.              $this->get('session')->getflashbag()->add('success_message', 'Record deleted successfully.');
  1517.         }else{
  1518.             $this->get('session')->getflashbag()->add('error_message', 'no record found');
  1519.         }
  1520.         return $this->redirect($this->generateUrl('officebrain_imprint_skus_product'));
  1521.     }
  1522.     
  1523. }