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

+		}
 		JSONObject solrResponseJSONObj = new JSONObject(response).getJSONObject("response");
 		JSONArray docs = solrResponseJSONObj.getJSONArray("docs");
 		List<FofoCatalogResponse> dealResponse = getCatalogSingleSkuResponse(docs, itemIdsQtyMap, false);
-		Bucket bucket = itemBucketService.getBuckets(Optional.of(true)).stream().filter(x->x.getId()==id).collect(Collectors.toList()).get(0);
+		Bucket bucket = itemBucketService.getBuckets(Optional.of(true)).stream().filter(x -> x.getId() == id)
+				.collect(Collectors.toList()).get(0);
 		bucket.setFofoCatalogResponses(dealResponse);
 		return responseSender.ok(bucket);
+	}
 	private String getCommaSeparateTags(int userId) {
 				throw new ProfitMandiBusinessException("", "", "Could not connect to host");
+			}
 			JSONObject solrResponseJSONObj = new JSONObject(response).getJSONObject("response");
 			JSONArray docs = solrResponseJSONObj.getJSONArray("docs");
 			dealResponse = getCatalogResponse(docs, hotDeal);
+			/*
-			if (Mongo.PARTNER_BLoCKED_BRANDS.containsKey(userInfo.getEmail())) {
+			 * if (Mongo.PARTNER_BLoCKED_BRANDS.containsKey(userInfo.getEmail())) {
-				dealResponse.stream()
+			 * dealResponse.stream() .filter(x ->
-						.filter(x -> Mongo.PARTNER_BLoCKED_BRANDS.get(userInfo.getEmail()).contains(x.getBrand()));
+			 * Mongo.PARTNER_BLoCKED_BRANDS.get(userInfo.getEmail()).contains(x.getBrand()))
+			 * ; }
+			 */
+		} else {
+			return responseSender.badRequest(
+					new ProfitMandiBusinessException("Retailer id", userInfo.getUserId(), "NOT_FOFO_RETAILER"));
+		}
+		return responseSender.ok(dealResponse);
+	}
+	@ApiImplicitParams({
+			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
+	@RequestMapping(value = "/partnerStock", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+	public ResponseEntity<?> partnerStock(HttpServletRequest request,
+			@RequestParam(value = "categoryId", required = false, defaultValue = "(3 OR 6)") String categoryId,
+			@RequestParam(value = "offset") String offset, @RequestParam(value = "limit") String limit,
+			@RequestParam(value = "sort", required = false) String sort,
+			@RequestParam(value = "brand", required = false) String brand,
+			@RequestParam(value = "subCategoryId", required = false) int subCategoryId,
+			@RequestParam(value = "q", required = false) String queryTerm,
+			@RequestParam(value = " ", required = false, defaultValue = "true") boolean partnerStockOnly)
+			throws Throwable {
+		List<FofoCatalogResponse> dealResponse = new ArrayList<>();
+		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
+		UserCart uc = userAccountRepository.getUserCart(userInfo.getUserId());
+		logger.info("Retiler Id ==> {}", uc.getUserId());
+		if (roleManagerService.isPartner(userInfo.getRoleIds())) {
+			if(partnerStockOnly) {
+			}
+			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));
+			} else {
+				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, " ")));
+			} 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, " ")));
+			} else {
+				mandatoryQ.add(
+						String.format("+{!parent which=\"id:catalog*\"} tagId_i:(%s)", StringUtils.join(tagIds, " ")));
+			}
+			params.put("q", StringUtils.join(mandatoryQ, " "));
+			params.put("fl", "*, [child parentFilter=id:catalog*]");
+			if (queryTerm == null) {
+				params.put("sort", "create_s desc");
+			}
+			params.put("start", String.valueOf(offset));
+			params.put("rows", String.valueOf(limit));
+			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");
+			dealResponse = getCatalogResponse(docs, false);
+			/*
+			 * if (Mongo.PARTNER_BLoCKED_BRANDS.containsKey(userInfo.getEmail())) {
+			 * dealResponse.stream() .filter(x ->
+			 * Mongo.PARTNER_BLoCKED_BRANDS.get(userInfo.getEmail()).contains(x.getBrand()))
+			 * ; }
+			 */
 		} else {
 			return responseSender.badRequest(
 					new ProfitMandiBusinessException("Retailer id", userInfo.getUserId(), "NOT_FOFO_RETAILER"));
+		}
 		return responseSender.ok(dealResponse);
 		List<Integer> tagIds = Arrays.asList(4);
 		if (docs.length() > 0) {
 			HashSet<Integer> itemsSet = new HashSet<>();
 			for (int i = 0; i < docs.length(); i++) {
 				JSONObject doc = docs.getJSONObject(i);
-				if(doc.has("_childDocuments_")) {
+				if (doc.has("_childDocuments_")) {
 					for (int j = 0; j < doc.getJSONArray("_childDocuments_").length(); j++) {
 						JSONObject childItem = doc.getJSONArray("_childDocuments_").getJSONObject(j);
 						int itemId = childItem.getInt("itemId_i");
 						itemsSet.add(itemId);
+					}
+				}
+			}
-			if(itemsSet.size() == 0) {
+			if (itemsSet.size() == 0) {
 				return dealResponse;
+			}
 			itemTagListingMap = tagListingRepository.selectByItemIdsAndTagIds(itemsSet, new HashSet<>(tagIds)).stream()
 					.collect(Collectors.toMap(x -> x.getItemId(), x -> x));
+		}
 			} catch (Exception e) {
 				ffdr.setFeature(null);
 				logger.info("Could not find Feature_s for {}", ffdr.getCatalogId());
+			}
 			ffdr.setBrand(doc.getJSONArray("brand_ss").getString(0));
-			if(doc.has("_childDocuments_")) {
+			if (doc.has("_childDocuments_")) {
 				for (int j = 0; j < doc.getJSONArray("_childDocuments_").length(); j++) {
 					JSONObject childItem = doc.getJSONArray("_childDocuments_").getJSONObject(j);
 					int itemId = childItem.getInt("itemId_i");
 					TagListing tl = itemTagListingMap.get(itemId);
 					if (tl == null) {
 							fdi.setMinBuyQuantity(10);
 						} else {
 							fdi.setMinBuyQuantity(1);
+						}
 						if (hotDeal || !tl.isActive()) {
 							int totalAvailability = 0; // Using item availability
 							// cache for now but can be
 							// changed to
 							// use caching later.
 							try {
 	private List<FofoCatalogResponse> getCatalogSingleSkuResponse(JSONArray docs, Map<Integer, Integer> itemFilter,
 			boolean hotDeal) throws ProfitMandiBusinessException {
 		Map<Integer, TagListing> itemTagListingMap = null;
 		List<FofoCatalogResponse> dealResponse = new ArrayList<>();
 		List<Integer> tagIds = Arrays.asList(4);
 		itemTagListingMap = tagListingRepository.selectByItemIdsAndTagIds(itemFilter.keySet(), new HashSet<>(tagIds))
 				.stream().collect(Collectors.toMap(x -> x.getItemId(), x -> x));
 		for (int i = 0; i < docs.length(); i++) {
 			Map<Integer, FofoAvailabilityInfo> fofoAvailabilityInfoMap = new HashMap<>();
 			for (int j = 0; j < doc.getJSONArray("_childDocuments_").length(); j++) {
 				JSONObject childItem = doc.getJSONArray("_childDocuments_").getJSONObject(j);
 				int itemId = childItem.getInt("itemId_i");
 				TagListing tl = itemTagListingMap.get(itemId);
-				if(tl==null) {
+				if (tl == null) {
 					continue;
+				}
 				if (hotDeal) {
 					if (!tl.isHotDeals()) {
 						continue;

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/DealsController.java – Rev 26575 → 26589