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

+	}
 	@ApiImplicitParams({
 			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
 	@RequestMapping(value = "/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 = "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 = "hotDeal", required = false) boolean hotDeal)
+			@RequestParam(value = "hotDeal", required = false) boolean hotDeal) throws Throwable {
-		throws Throwable {
 		List<FofoCatalogResponse> dealResponse = new ArrayList<>();
 		UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
 		if (roleManagerService.isPartner(userInfo.getRoleIds())) {
 			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<>();
 			if (brand != null) {
+				mandatoryQ.add(
-				mandatoryQ.add(String.format("+(categoryId_i:%s) +(brand_ss:%s) +{!parent which=\"brand_ss:%s\"} tagId_i:(%s)", categoryId, brand, brand,
+						String.format("+(categoryId_i:%s) +(brand_ss:%s) +{!parent which=\"brand_ss:%s\"} tagId_i:(%s)",
-						StringUtils.join(tagIds, " ")));
+								categoryId, brand, brand, StringUtils.join(tagIds, " ")));
 			} else if (hotDeal) {
 				mandatoryQ.add(String.format("+{!parent which=\"hot_deals_b=true\"} tagId_i:(%s)",
 						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*]");
 			params.put("sort", "rank_i asc, create_s desc");
 			params.put("start", String.valueOf(offset));
 			} catch (HttpHostConnectException e) {
 				throw new ProfitMandiBusinessException("", "", "Could not connect to host");
+			}
 			JSONObject solrResponseJSONObj = new JSONObject(response).getJSONObject("response");
 			JSONArray docs = solrResponseJSONObj.getJSONArray("docs");
-			Map<Integer, TagListing> itemTagListingMap = null;
-			if (docs.length() > 0) {
-				HashSet<Integer> itemsSet = new HashSet<>();
-				for (int i = 0; i < docs.length(); i++) {
-					JSONObject doc = docs.getJSONObject(i);
-					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);
-					}
-				}
-				itemTagListingMap = tagListingRepository.selectByItemIdsAndTagIds(itemsSet, 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<>();
-				JSONObject doc = docs.getJSONObject(i);
-				FofoCatalogResponse ffdr = new FofoCatalogResponse();
+			dealResponse=getCatalogResponse(docs,hotDeal);
-				ffdr.setCatalogId(doc.getInt("catalogId_i"));
-				ffdr.setImageUrl(doc.getString("imageUrl_s"));
-				ffdr.setTitle(doc.getString("title_s"));
-				if(brand != null) {
-					ffdr.setBrand(brand);
-				} else {
-					ffdr.setBrand(doc.getJSONArray("brand_ss").getString(0));
-				}
-				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 (hotDeal) {
-						if (!tl.isHotDeals()) {
-							continue;
-						}
-					}
-					float sellingPrice = (float) childItem.getDouble("sellingPrice_f");
-					if (fofoAvailabilityInfoMap.containsKey(itemId)) {
-						if (fofoAvailabilityInfoMap.get(itemId).getSellingPrice() > sellingPrice) {
-							fofoAvailabilityInfoMap.get(itemId).setSellingPrice(sellingPrice);
-							fofoAvailabilityInfoMap.get(itemId).setMop((float) childItem.getDouble("mop_f"));
-						}
-					} else {
-						FofoAvailabilityInfo fdi = new FofoAvailabilityInfo();
-						fdi.setSellingPrice((float) childItem.getDouble("sellingPrice_f"));
-						fdi.setMop((float) childItem.getDouble("mop_f"));
-						fdi.setColor(childItem.has("color_s") ? childItem.getString("color_s") : "");
-						fdi.setTagId(childItem.getInt("tagId_i"));
-						fdi.setItem_id(itemId);
-						Item item = itemRepository.selectById(itemId);
-						// In case its tampered glass moq should be 5
-						if (item.getCategoryId() == 10020) {
-							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 {
-								ItemAvailabilityCache iac = itemAvailabilityCacheRepository.selectByItemId(itemId);
-								totalAvailability = iac.getTotalAvailability();
-								fdi.setAvailability(totalAvailability);
-							} catch (Exception e) {
-								continue;
-							}
-							if (totalAvailability <= 0) {
-								continue;
-							}
-						} else {
-							fdi.setAvailability(10);
-						}
-						fdi.setQuantityStep(1);
-						fdi.setMaxQuantity(Math.min(fdi.getAvailability(), 100));
-						fofoAvailabilityInfoMap.put(itemId, fdi);
-					}
-				}
-				if (fofoAvailabilityInfoMap.values().size() > 0) {
-					ffdr.setItems(new ArrayList<FofoAvailabilityInfo>(fofoAvailabilityInfoMap.values()));
-					dealResponse.add(ffdr);
-				}
-			}
 		} else {
 			return responseSender.badRequest(
 					new ProfitMandiBusinessException("Retailer id", userInfo.getUserId(), "NOT_FOFO_RETAILER"));
+		}
 		return responseSender.ok(dealResponse);
+		}
 		return responseSender.ok(responseObject);
+	}
 	/*
-	 * @RequestMapping(value = "/direct-deals", method=RequestMethod.GET,produces =
+	 * @RequestMapping(value = "/direct-deals",
-	 * MediaType.APPLICATION_JSON_VALUE)
+	 * method=RequestMethod.GET,produces = MediaType.APPLICATION_JSON_VALUE)
+	 *
 	 * @ApiImplicitParams({
+	 *
-	 * @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true,
+	 * @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required =
-	 * dataType = "string", paramType = "header") }) public ResponseEntity<?>
+	 * true, dataType = "string", paramType = "header") }) public
+	 * ResponseEntity<?> getDirectDeals(HttpServletRequest
-	 * getDirectDeals(HttpServletRequest request, @RequestParam(value="categoryId")
+	 * request, @RequestParam(value="categoryId") String
-	 * String categoryId,@RequestParam(value="offset") String offset,
+	 * categoryId,@RequestParam(value="offset") String offset,
+	 *
 	 * @RequestParam(value="limit") String limit, @RequestParam(value="sort",
-	 * required=false) String sort, @RequestParam(value="direction", required=false)
+	 * required=false) String sort, @RequestParam(value="direction",
-	 * String direction,
+	 * required=false) String direction,
+	 *
 	 * @RequestParam(value="filterData", required=false) String filterData ){
+	 *
 	 * return new ResponseEntity<>(profitMandiResponse,HttpStatus.OK); }
 	 */
+			}
+		}
 		/*
 		 * final ProfitMandiResponse<?> profitMandiResponse = new
 		 * ProfitMandiResponse<>(LocalDateTime.now(),
-		 * request.getRequestURL().toString(), HttpStatus.OK.toString(), HttpStatus.OK,
+		 * request.getRequestURL().toString(), HttpStatus.OK.toString(),
-		 * ResponseStatus.SUCCESS, dealsResponse);
+		 * HttpStatus.OK, ResponseStatus.SUCCESS, dealsResponse);
 		 */
 		return responseSender.ok(dealsResponse);
+	}
+	@RequestMapping(value = "/partnerdeals/{id}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+	@ApiImplicitParams({
+			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
+	@ApiOperation(value = "Get unit deal object")
+	public ResponseEntity<?> getUnitFocoDeal(HttpServletRequest request, @PathVariable(value = "id") long id)
+			throws ProfitMandiBusinessException {
+		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;
+				mandatoryQ.add(
+						String.format("+(categoryId_i:%s) +(id:%s) +{!parent which=\"id:%s\"} tagId_i:(%s)",
+								categoryId, catalogString, catalogString, StringUtils.join(tagIds, " ")));
+			params.put("q", StringUtils.join(mandatoryQ, " "));
+			params.put("fl", "*, [child parentFilter=id:catalog*]");
+			params.put("sort", "rank_i asc, create_s desc");
+			params.put("wt", "json");
+			String response = null;
+			try {
+				response = rc.get(SchemeType.HTTP, "dtr", 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);
+		} else {
+			return responseSender.badRequest(
+					new ProfitMandiBusinessException("Retailer id", userInfo.getUserId(), "NOT_FOFO_RETAILER"));
+		}
+		return responseSender.ok(dealResponse.get(0));
+	}
 	@RequestMapping(value = "/fofo/brands", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
-	public ResponseEntity<?> getBrandsToDisplay(@RequestParam(required=false, defaultValue="0") int categoryId) {
+	public ResponseEntity<?> getBrandsToDisplay(@RequestParam(required = false, defaultValue = "0") int categoryId) {
 		return new ResponseEntity<>(mongoClient.getBrandsToDisplay(categoryId), HttpStatus.OK);
+	}
 	@RequestMapping(value = "/banners/{bannerType}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	public ResponseEntity<?> getBanners(@PathVariable String bannerType) {
+			}
+		}
 		return responseSender.ok(responseObject);
+	}
+	private List<FofoCatalogResponse> getCatalogResponse(JSONArray docs, boolean hotDeal) throws ProfitMandiBusinessException {
+		Map<Integer, TagListing> itemTagListingMap = null;
+		List<FofoCatalogResponse> dealResponse = new ArrayList<>();
+		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);
+				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);
+				}
+			}
+			itemTagListingMap = tagListingRepository.selectByItemIdsAndTagIds(itemsSet, 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<>();
+			JSONObject doc = docs.getJSONObject(i);
+			FofoCatalogResponse ffdr = new FofoCatalogResponse();
+			ffdr.setCatalogId(doc.getInt("catalogId_i"));
+			ffdr.setImageUrl(doc.getString("imageUrl_s"));
+			ffdr.setTitle(doc.getString("title_s"));
+			ffdr.setBrand(doc.getJSONArray("brand_ss").getString(0));
+			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 (hotDeal) {
+					if (!tl.isHotDeals()) {
+						continue;
+					}
+				}
+				float sellingPrice = (float) childItem.getDouble("sellingPrice_f");
+				if (fofoAvailabilityInfoMap.containsKey(itemId)) {
+					if (fofoAvailabilityInfoMap.get(itemId).getSellingPrice() > sellingPrice) {
+						fofoAvailabilityInfoMap.get(itemId).setSellingPrice(sellingPrice);
+						fofoAvailabilityInfoMap.get(itemId).setMop((float) childItem.getDouble("mop_f"));
+					}
+				} else {
+					FofoAvailabilityInfo fdi = new FofoAvailabilityInfo();
+					fdi.setSellingPrice((float) childItem.getDouble("sellingPrice_f"));
+					fdi.setMop((float) childItem.getDouble("mop_f"));
+					fdi.setColor(childItem.has("color_s") ? childItem.getString("color_s") : "");
+					fdi.setTagId(childItem.getInt("tagId_i"));
+					fdi.setItem_id(itemId);
+					Item item = itemRepository.selectById(itemId);
+					// In case its tampered glass moq should be 5
+					if (item.getCategoryId() == 10020) {
+						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 {
+							ItemAvailabilityCache iac = itemAvailabilityCacheRepository.selectByItemId(itemId);
+							totalAvailability = iac.getTotalAvailability();
+							fdi.setAvailability(totalAvailability);
+						} catch (Exception e) {
+							continue;
+						}
+						if (totalAvailability <= 0) {
+							continue;
+						}
+					} else {
+						fdi.setAvailability(10);
+					}
+					fdi.setQuantityStep(1);
+					fdi.setMaxQuantity(Math.min(fdi.getAvailability(), 100));
+					fofoAvailabilityInfoMap.put(itemId, fdi);
+				}
+			}
+			if (fofoAvailabilityInfoMap.values().size() > 0) {
+				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/DealsController.java – Rev 24038 → 24091