Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import com.spice.profitmandi.common.solr.SolrService;
import com.spice.profitmandi.common.web.util.ResponseSender;
import com.spice.profitmandi.dao.entity.dtr.WebOffer;
import com.spice.profitmandi.dao.entity.dtr.WebOfferProduct;
import com.spice.profitmandi.dao.repository.dtr.WebOfferProductRepository;
import com.spice.profitmandi.dao.repository.dtr.WebOfferRepository;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.json.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import javax.transaction.Transactional;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.stream.Collectors;

@Controller
@Transactional(rollbackOn = Throwable.class)
public class WebOffersController {

        private static final Logger LOGGER = LogManager.getLogger(WebOffersController.class);

        
        @Autowired
        ResponseSender<?> responseSender;
        
        @Autowired
        WebOfferRepository webOfferRepository;
        
        @Autowired
        WebOfferProductRepository webOfferProductRepository;

        @Autowired
        SolrService solrService;

        @RequestMapping(value = "/web-offers", method = RequestMethod.GET)
        public String getOfferListing(HttpServletRequest request, Model model) {
                List<WebOffer> webListing = webOfferRepository.selectAllWebListing(Optional.of(true));
                model.addAttribute("webListings", webListing);
                return "web-offer";
        }

        @RequestMapping(value = "/web-offer/add", method = RequestMethod.POST)
        public String addWebListing(HttpServletRequest request, @RequestBody WebOffer webOffer, Model model) {
                webOffer.setCreatedDate(LocalDateTime.now());
                webOffer.setDetailedText("");
                webOfferRepository.persist(webOffer);
                return getOfferListing(request, model);
        }
        
        @RequestMapping(value = "/web-offer/{webOfferId}", method = RequestMethod.GET)
        public String getWebProductListing(HttpServletRequest request, Model model, @PathVariable int webOfferId)
                        throws Exception {
                List<WebOfferProduct> webOfferProducts = webOfferProductRepository.selectAllByWebOfferId(webOfferId);
                if (webOfferProducts.size() > 0) {
                        Map<Integer, JSONObject> entityMap = solrService.getContentByCatalogIds(
                                        webOfferProducts.stream().map(x -> x.getEntityId()).collect(Collectors.toList()));
                        webOfferProducts.stream()
                                        .forEach(x -> x.setProductName(entityMap.get(x.getEntityId()).getString("title_s")));
                }

                WebOffer webOffer = webOfferRepository.selectById(webOfferId);
                model.addAttribute("productListings", webOfferProducts);
                model.addAttribute("webListing", webOffer);
                return "web-offer-product";
        }
        
        @RequestMapping(value = "/web-offer-product/add", method = RequestMethod.POST)
        public String addWebOfferProduct(HttpServletRequest request,
                        @RequestBody List<WebOfferProduct> webOfferProducts, Model model) throws Exception {
                webOfferProducts.stream().forEach(webOfferProduct -> {
                        boolean exists = webOfferProductRepository.isExists(webOfferProduct.getWebOfferId(),
                                        webOfferProduct.getEntityId());
                        if (!exists) {
                                webOfferProductRepository.persist(webOfferProduct);
                        }

                });
                return getWebProductListing(request, model, webOfferProducts.get(0).getWebOfferId());
        }
        
        @RequestMapping(value = "/web-offer-product/remove", method = RequestMethod.DELETE)
        public String addWebOfferProduct(HttpServletRequest request,
                        @RequestParam int webOfferProductId, Model model) throws Exception {
                WebOfferProduct webOfferProduct = webOfferProductRepository.selectById(webOfferProductId);
                webOfferProductRepository.delete(webOfferProduct);
                return getWebProductListing(request, model, webOfferProduct.getWebOfferId());
        }
        

/*      @RequestMapping(value = "/web-listing/order/{webListingId}", method = RequestMethod.POST)
        public String orderWebProductListing(HttpServletRequest request, Model model, @PathVariable int webListingId,
                        @RequestBody List<Integer> webListingProductIds) throws Exception {
                List<WebProductListing> productListings = webProductListingRepository.selectAllByWebListingId(webListingId);

                productListings.forEach(productListing -> {
                        productListing.setRank(webListingProductIds.indexOf(productListing.getId()) + 1);
                });
                return getWebProductListing(request, model, webListingId);
        }

        @RequestMapping(value = "/web-listing/order-listing", method = RequestMethod.POST)
        public String orderWebListing(HttpServletRequest request, Model model, @RequestBody List<Integer> webListingIds)
                        throws Exception {
                LOGGER.info("webListingId" + webListingIds);
                List<WebListing> webListings = webListingRepository.selectByIds(webListingIds);
                webListings.forEach(webListing -> {
                        webListing.setRank(webListingIds.indexOf(webListing.getId()) + 1);
                });
                return getWebListing(request, model);
        }*/



}