WebSVN – SmartDukaan – Diff – /trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/StoreController.java

 package com.spice.profitmandi.web.controller;
 import java.time.LocalTime;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.Comparator;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 import java.util.Set;
 import java.util.stream.Collectors;
 import javax.servlet.http.HttpServletRequest;
 import org.apache.logging.log4j.Logger;
 import org.json.JSONArray;
 import org.json.JSONObject;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Controller;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
 import com.eclipsesource.json.JsonObject;
+import com.google.common.collect.Ordering;
 import com.google.gson.Gson;
 import com.google.gson.reflect.TypeToken;
 import com.spice.profitmandi.common.enumuration.SchemeType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.CreatePendingOrderRequest;
 import com.spice.profitmandi.common.solr.SolrService;
 import com.spice.profitmandi.common.web.client.RestClient;
 import com.spice.profitmandi.common.web.util.ResponseSender;
 import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
+import com.spice.profitmandi.dao.entity.dtr.WebListing;
 import com.spice.profitmandi.dao.entity.fofo.CurrentInventorySnapshot;
 import com.spice.profitmandi.dao.entity.fofo.PincodePartner;
 import com.spice.profitmandi.dao.entity.inventory.ItemAvailabilityCache;
 import com.spice.profitmandi.dao.enumuration.dtr.OtpType;
 import com.spice.profitmandi.dao.model.AddCartRequest;
 import com.spice.profitmandi.dao.model.CartItem;
 import com.spice.profitmandi.dao.model.CartItemResponseModel;
 import com.spice.profitmandi.dao.model.CartResponse;
-import com.spice.profitmandi.dao.model.UserCart;
-import com.spice.profitmandi.dao.repository.catalog.CategoryRepository;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
-import com.spice.profitmandi.dao.repository.dtr.Mongo;
 import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
+import com.spice.profitmandi.dao.repository.dtr.WebListingRepository;
+import com.spice.profitmandi.dao.repository.dtr.WebProductListingRepository;
 import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
 import com.spice.profitmandi.dao.repository.fofo.PendingOrderService;
 import com.spice.profitmandi.dao.repository.fofo.PincodePartnerRepository;
 import com.spice.profitmandi.dao.repository.inventory.ItemAvailabilityCacheRepository;
 import com.spice.profitmandi.service.authentication.RoleManager;
 import com.spice.profitmandi.service.inventory.FofoAvailabilityInfo;
 import com.spice.profitmandi.service.inventory.FofoCatalogResponse;
-import com.spice.profitmandi.service.pricing.PricingService;
 import com.spice.profitmandi.service.scheme.SchemeService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.web.processor.OtpProcessor;
 import com.spice.profitmandi.web.res.DealBrands;
 import com.spice.profitmandi.web.res.DealObjectResponse;
 public class StoreController {
 	private static final Logger logger = LogManager.getLogger(StoreController.class);
 	private static final LocalTime CUTOFF_TIME = LocalTime.of(15, 0);
+	private static final List<Integer> TAG_IDS = Arrays.asList(4);
 	private static final int DEFAULT_STORE = 171912487;
 	@Value("${python.api.host}")
 	private String host;
 	// This is now unused as we are not supporting multiple companies.
 	@Value("${gadgetCops.invoice.cc}")
 	private String[] ccGadgetCopInvoiceTo;
 	@Autowired
-	private PricingService pricingService;
-	@Autowired
 	private PincodePartnerRepository pincodePartnerRepository;
 	@Autowired
 	private FofoStoreRepository fofoStoreRepository;
 	@Autowired
 	private RetailerService retailerService;
 	@Autowired
 	private PendingOrderService pendingOrderService;
 	@Autowired
-	private CategoryRepository categoryRepository;
-	@Autowired
 	private SolrService commonSolrService;
 	@Autowired
-	private Mongo mongoClient;
-	@Autowired
 	private OtpProcessor otpProcessor;
 	@Autowired
 	private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;
 	@Autowired
-	private UserAccountRepository userAccountRepository;
-	@Autowired
 	private ResponseSender<?> responseSender;
 	@Autowired
 	private TagListingRepository tagListingRepository;
 	@Autowired
 	private ItemAvailabilityCacheRepository itemAvailabilityCacheRepository;
 	@Autowired
-	private RoleManager roleManagerService;
+	private WebListingRepository webListingRepository;
+	@Autowired
-	List<String> filterableParams = Arrays.asList("brand");
+	private WebProductListingRepository webProductListingRepository;
-	private Set<Integer> bestSellers = new HashSet<>(Arrays.asList(1022090, 1022346, 1022344, 1022343, 1022336, 1021933,
-			1022025, 1003800, 1022322, 1022307, 1022304, 1022004, 1022004, 1021934, 1021897, 1021768));
+	@Autowired
-	private Set<Integer> latestArrivals = new HashSet<>(Arrays.asList(1022382, 1022335, 1022381, 1022386, 1022380,
+	private RoleManager roleManagerService;
-			1022377, 1022376, 1022375, 1022374, 1022373, 1022372, 1022371, 1022370));
-	private Set<Integer> healthGadgets = new HashSet<>(Arrays.asList(1022383, 1022384));
+	List<String> filterableParams = Arrays.asList("brand");
-	private Set<Integer> topGadgets = new HashSet<>(Arrays.asList(1022167, 1022174, 1022177, 1022184, 1022185, 1022359,
-			1022359, 1022359, 1022369, 1022369, 1022369, 1022361, 1022361, 1022361, 1022361, 1022368, 1022368, 1022368,
-			1022368, 1021443, 1021439, 1021440, 1021441, 1022313, 1022312, 1022311));
 	@ApiImplicitParams({
 			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
 	@RequestMapping(value = "/store/fofo", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	public ResponseEntity<?> getFofo(HttpServletRequest request,
 			@RequestParam(value = "categoryId", required = false, defaultValue = "(3 OR 6)") String categoryId,
 			@RequestParam(value = "hotDeal", required = false) boolean hotDeal) throws Throwable {
 		List<FofoCatalogResponse> dealResponse = new ArrayList<>();
 		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
 		if (roleManagerService.isPartner(userInfo.getRoleIds())) {
 			// UserCart uc = userAccountRepository.getUserCart(userInfo.getUserId());
-			List<Integer> tagIds = pricingService.getTagsIdsByRetailerId(userInfo.getRetailerId());
 			RestClient rc = new RestClient();
 			Map<String, String> params = new HashMap<>();
 			List<String> mandatoryQ = new ArrayList<>();
 			if (queryTerm != null && !queryTerm.equals("null")) {
 				mandatoryQ.add(String.format("+(%s)", queryTerm));
 				queryTerm = null;
+			}
 			if (subCategoryId != 0) {
 				mandatoryQ
 						.add(String.format("+(subCategoryId_i:%s) +{!parent which=\"subCategoryId_i:%s\"} tagId_i:(%s)",
-								subCategoryId, subCategoryId, StringUtils.join(tagIds, " ")));
+								subCategoryId, subCategoryId, StringUtils.join(TAG_IDS, " ")));
 			} else if (hotDeal) {
 				mandatoryQ.add(String.format("+{!parent which=\"hot_deals_b=true\"} tagId_i:(%s)",
-						StringUtils.join(tagIds, " ")));
+						StringUtils.join(TAG_IDS, " ")));
 			} else if (StringUtils.isNotBlank(brand)) {
 				mandatoryQ.add(
 						String.format("+(categoryId_i:%s) +(brand_ss:%s) +{!parent which=\"brand_ss:%s\"} tagId_i:(%s)",
-								categoryId, brand, brand, StringUtils.join(tagIds, " ")));
+								categoryId, brand, brand, StringUtils.join(TAG_IDS, " ")));
 			} else {
 				mandatoryQ.add(
-						String.format("+{!parent which=\"id:catalog*\"} tagId_i:(%s)", StringUtils.join(tagIds, " ")));
+						String.format("+{!parent which=\"id:catalog*\"} tagId_i:(%s)", StringUtils.join(TAG_IDS, " ")));
+			}
 			params.put("q", StringUtils.join(mandatoryQ, " "));
 			params.put("fl", "*, [child parentFilter=id:catalog*]");
 			if (queryTerm == null) {
 				params.put("sort", "create_s desc");
 		List<FofoCatalogResponse> dealResponse = new ArrayList<>();
 		List<Integer> tagIds = Arrays.asList(4);
 		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
 		if (roleManagerService.isPartner(userInfo.getRoleIds())) {
 			String categoryId = "(3 OR 6)";
-			UserCart uc = userAccountRepository.getUserCart(userInfo.getUserId());
 			RestClient rc = new RestClient();
 			Map<String, String> params = new HashMap<>();
 			List<String> mandatoryQ = new ArrayList<>();
 			String catalogString = "catalog" + id;
 		}.getType());
 		return responseSender.ok(dealBrandsResponse);
+	}
-	@RequestMapping(value = "/store/tag/{tag}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+	@RequestMapping(value = "/store/listing/{listingUrl}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
-	public ResponseEntity<?> bestSellers(HttpServletRequest request, @PathVariable String tag) throws Exception {
+	public ResponseEntity<?> bestSellers(HttpServletRequest request, @PathVariable String listingUrl) throws Exception {
 		List<FofoCatalogResponse> dealResponse = new ArrayList<>();
-		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
+		// UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
 		// UserCart uc = userAccountRepository.getUserCart(userInfo.getUserId());
 		List<Integer> tagIds = Arrays.asList(4);
+		WebListing webListing = webListingRepository.selectByUrl("url");
+		if (webListing == null) {
+			throw new ProfitMandiBusinessException("Url", listingUrl, "Could not find the Url");
+		}
+		List<Integer> webProducts = webProductListingRepository.selectAllByWebListingId(webListing.getId()).stream()
+				.filter(x -> x.getRank() > 0).map(x -> x.getEntityId()).collect(Collectors.toList());
 		RestClient rc = new RestClient();
 		Map<String, String> params = new HashMap<>();
 		List<String> mandatoryQ = new ArrayList<>();
-		Set<Integer> catalogIds = this.bestSellers;
-		if (tag.equalsIgnoreCase("latestArrivals")) {
-			catalogIds = this.latestArrivals;
-		} else if (tag.equalsIgnoreCase("topGadgets")) {
-			catalogIds = this.topGadgets;
-		} else if (tag.equalsIgnoreCase("healthGadgets")) {
-		catalogIds = this.healthGadgets;
-	}
-		mandatoryQ.add(
+		mandatoryQ.add(String.format(
-				String.format("+{!parent which=\"catalogId_i:" + StringUtils.join(catalogIds, " ") + "\"} tagId_i:(%s)",
+				"+{!parent which=\"catalogId_i:" + StringUtils.join(webProducts, " ") + "\"} tagId_i:(%s)",
-						StringUtils.join(tagIds, " ")));
+				StringUtils.join(tagIds, " ")));
 		params.put("q", StringUtils.join(mandatoryQ, " "));
 		params.put("fl", "*, [child parentFilter=id:catalog*]");
 		// params.put("sort", "create_s desc");
 		params.put("start", String.valueOf(0));
 		params.put("rows", String.valueOf(30));
 		} catch (HttpHostConnectException e) {
 			throw new ProfitMandiBusinessException("", "", "Could not connect to host");
+		}
 		JSONObject solrResponseJSONObj = new JSONObject(response).getJSONObject("response");
 		JSONArray docs = solrResponseJSONObj.getJSONArray("docs");
+		final Ordering<Integer> rankOrdering = Ordering.explicit(webProducts);
+		dealResponse = getCatalogResponse(docs, false).stream().sorted(new Comparator<FofoCatalogResponse>() {
+			@Override
+			public int compare(FofoCatalogResponse o1, FofoCatalogResponse o2) {
+				return rankOrdering.compare(o1.getCatalogId(), o2.getCatalogId());
+			}
+		}).collect(Collectors.toList());
-		dealResponse = getCatalogResponse(docs, false);
+		webListing.setFofoCatalogResponses(dealResponse);
-		return responseSender.ok(dealResponse);
+		return responseSender.ok(webListing);
+	}
 	@RequestMapping(value = "/store/otp/generateOTP", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	public ResponseEntity<?> generateOtp(HttpServletRequest request, @RequestParam String email,
 			@RequestParam String phone) throws Exception {
 		CustomRetailer customRetailer = retailerService.getFofoRetailer(storeId);
 		return responseSender.ok(customRetailer.getAddress());
+	}
 	@RequestMapping(value = "/store/address/{pincode}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	@ApiImplicitParams({
-		@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
+			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
 	@ApiOperation(value = "Get brand list and count for category")
-	public ResponseEntity<?> getStoresByPincode(HttpServletRequest request, @PathVariable String pincode) throws Exception {
+	public ResponseEntity<?> getStoresByPincode(HttpServletRequest request, @PathVariable String pincode)
+			throws Exception {
 		List<PincodePartner> pincodePartners = pincodePartnerRepository.selectPartnersByPincode(pincode);
 		int fofoId = DEFAULT_STORE;
-		if(pincodePartners.size()>0) {
+		if (pincodePartners.size() > 0) {
 			fofoId = pincodePartners.get(0).getFofoId();
+		}
 		return responseSender.ok(fofoStoreRepository.selectByRetailerId(fofoId).getCode());
+	}
+	@RequestMapping(value = "/store/listing", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+	@Cacheable(value = "storelisting.all", cacheManager = "thirtyMinsTimeOutCacheManager")
+	public ResponseEntity<?> getStoresListing(HttpServletRequest request, @PathVariable String pincode)
+			throws Exception {
+		List<WebListing> webListings = webListingRepository.selectAllWebListing(Optional.of(true));
+		for (WebListing webListing : webListings) {
+			List<Integer> webProducts = webProductListingRepository.selectAllByWebListingId(webListing.getId()).stream()
+					.filter(x -> x.getRank() > 0).map(x -> x.getEntityId()).collect(Collectors.toList());
+			RestClient rc = new RestClient();
+			Map<String, String> params = new HashMap<>();
+			List<String> mandatoryQ = new ArrayList<>();
+			mandatoryQ.add(String.format(
+					"+{!parent which=\"catalogId_i:" + StringUtils.join(webProducts, " ") + "\"} tagId_i:(%s)",
+					StringUtils.join(TAG_IDS, " ")));
+			params.put("q", StringUtils.join(mandatoryQ, " "));
+			params.put("fl", "*, [child parentFilter=id:catalog*]");
+			// params.put("sort", "create_s desc");
+			params.put("start", String.valueOf(0));
+			params.put("rows", String.valueOf(30));
+			params.put("wt", "json");
+			String response = null;
+			try {
+				response = rc.get(SchemeType.HTTP, "50.116.10.120", 8984, "solr/demo/select", params);
+			} catch (HttpHostConnectException e) {
+				throw new ProfitMandiBusinessException("", "", "Could not connect to host");
+			}
+			JSONObject solrResponseJSONObj = new JSONObject(response).getJSONObject("response");
+			JSONArray docs = solrResponseJSONObj.getJSONArray("docs");
+			final Ordering<Integer> colorOrdering = Ordering.explicit(webProducts);
+			List<FofoCatalogResponse> dealResponse = getCatalogResponse(docs, false).stream()
+					.sorted(new Comparator<FofoCatalogResponse>() {
+						@Override
+						public int compare(FofoCatalogResponse o1, FofoCatalogResponse o2) {
+							return colorOrdering.compare(o1.getCatalogId(), o2.getCatalogId());
+						}
+					}).collect(Collectors.toList());
+			webListing.setFofoCatalogResponses(dealResponse);
+		}
+		return responseSender.ok(webListings);
+	}
 	@RequestMapping(value = "/store/cart", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
 	@ApiImplicitParams({
 			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
 	@ApiOperation(value = "Get brand list and count for category")
 	public ResponseEntity<?> cart(HttpServletRequest request, @RequestBody AddCartRequest cartRequest)
 				ffdr.setItems(new ArrayList<FofoAvailabilityInfo>(fofoAvailabilityInfoMap.values()));
 				dealResponse.add(ffdr);
+			}
+		}
 		return dealResponse;
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/StoreController.java – Rev 26720 → 26745