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

 import com.spice.profitmandi.common.web.client.RestClient;
 import com.spice.profitmandi.common.web.util.ResponseSender;
 import com.spice.profitmandi.dao.entity.catalog.Category;
 import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
+import com.spice.profitmandi.dao.entity.fofo.SuggestedPoDetail;
 import com.spice.profitmandi.dao.entity.inventory.ItemAvailabilityCache;
 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.Mongo;
 import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
+import com.spice.profitmandi.dao.repository.fofo.SuggestedPoDetailRepository;
 import com.spice.profitmandi.dao.repository.inventory.ItemAvailabilityCacheRepository;
 import com.spice.profitmandi.service.authentication.RoleManager;
 import com.spice.profitmandi.service.inventory.AvailabilityInfo;
 import com.spice.profitmandi.service.inventory.Bucket;
 import com.spice.profitmandi.service.inventory.FofoAvailabilityInfo;
 	private ItemAvailabilityCacheRepository itemAvailabilityCacheRepository;
 	@Autowired
 	private RoleManager roleManagerService;
+	@Autowired
-	List<String> filterableParams = Arrays.asList("brand");
+	private SuggestedPoDetailRepository monthlyPoDetailRepository;
+	List<String> filterableParams = Arrays.asList("brand");
 	@RequestMapping(value = "/fofo/buckets", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	public ResponseEntity<?> getBuckets(HttpServletRequest request) throws ProfitMandiBusinessException {
 		logger.info("Request " + request.getParameterMap());
 		return responseSender.ok(itemBucketService.getBuckets(Optional.of(true)));
 				.collect(Collectors.toList()).get(0);
 		bucket.setFofoCatalogResponses(dealResponse);
 		return responseSender.ok(bucket);
+	}
+	@RequestMapping(value = "/fofo/suggestedPo", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+	public ResponseEntity<?> getSuggestedPo(HttpServletRequest request, @RequestParam int id)
+			throws ProfitMandiBusinessException {
+		List<SuggestedPoDetail> mpd = monthlyPoDetailRepository.selectByPoId(id);
+		Map<Integer, Integer> itemIdsQtyMap = mpd.stream()
+				.collect(Collectors.toMap(x -> x.getItemId(), x -> x.getQuantity()));
+		Set<Integer> catalogIds = itemRepository.selectByIds(itemIdsQtyMap.keySet()).stream()
+				.map(x -> x.getCatalogItemId()).collect(Collectors.toSet());
+		RestClient rc = new RestClient();
+		Map<String, String> params = new HashMap<>();
+		List<String> mandatoryQ = new ArrayList<>();
+		mandatoryQ.add(
+				String.format("+catalogId_i:(%s) +{!parent which=\"id:catalog*\"}", StringUtils.join(catalogIds, " ")));
+		params.put("start", "0");
+		params.put("rows", "100");
+		params.put("q", StringUtils.join(mandatoryQ, " "));
+		params.put("fl", "*, [child parentFilter=id:catalog*]");
+		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");
+		List<FofoCatalogResponse> dealResponse = getCatalogSingleSkuResponse(docs, itemIdsQtyMap, false);
+		return responseSender.ok(dealResponse);
+	}
 	private String getCommaSeparateTags(int userId) {
 		UserCart uc = userAccountRepository.getUserCart(userId);
 		List<Integer> tagIds = pricingService.getTagsIdsByRetailerId(uc.getUserId());
 		List<String> strTagIds = new ArrayList<>();
 		for (Integer tagId : tagIds) {
 						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("+(subCategoryId_i:%s) +{!parent which=\"subCategoryId_i:%s\"} tagId_i:(%s)",
+						.add(String.format("+(subCategoryId_i:%s) +{!parent which=\"subCategoryId_i:%s\"} tagId_i:(%s)",
-						categoryId, categoryId, StringUtils.join(tagIds, " ")));
+								categoryId, categoryId, 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");
 			@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) {
+			if (partnerStockOnly) {
+			}
 			List<Integer> tagIds = pricingService.getTagsIdsByRetailerId(userInfo.getRetailerId());
 			RestClient rc = new RestClient();
 			Map<String, String> params = new HashMap<>();
 			List<String> mandatoryQ = new ArrayList<>();
 							fofoAvailabilityInfoMap.get(itemId).setMop((float) childItem.getDouble("mop_f"));
+						}
 					} else {
 						FofoAvailabilityInfo fdi = new FofoAvailabilityInfo();
 						fdi.setSellingPrice((float) childItem.getDouble("sellingPrice_f"));
-						fdi.setMrp((double)tl.getMrp());
+						fdi.setMrp((double) tl.getMrp());
 						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);
 						Float cashBack = schemeService.getItemSchemeCashBack().get(itemId);
-						cashBack = cashBack==null? 0 : cashBack;
+						cashBack = cashBack == null ? 0 : cashBack;
 						fdi.setCashback(cashBack);
 						Item item = itemRepository.selectById(itemId);
 						// In case its tampered glass moq should be 5
 						if (item.getCategoryId() == 10020) {
 							fdi.setMinBuyQuantity(10);

Subversion Repositories SmartDukaan

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