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

 import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
 import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
 import com.spice.profitmandi.dao.entity.inventory.VendorItemPricing;
+import com.spice.profitmandi.dao.entity.transaction.LineItemImei;
 import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
-import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
 import com.spice.profitmandi.dao.repository.inventory.VendorItemPricingRepository;
+import com.spice.profitmandi.dao.repository.transaction.LineItemImeisRepository;
 import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
 import com.spice.profitmandi.service.inventory.InventoryService;
+import com.spice.profitmandi.service.pricing.PriceDropService;
 import com.spice.profitmandi.service.scheme.SchemeService;
 import com.spice.profitmandi.service.transaction.TransactionService;
 import com.spice.profitmandi.service.wallet.WalletService;
 import com.spice.profitmandi.web.util.MVCResponseSender;
 	@Autowired
 	@Qualifier("fofoInventoryService")
 	private InventoryService inventoryService;
 	@Autowired
-	private InventoryItemRepository inventoryItemRepository;
-	@Autowired
 	private MVCResponseSender mvcResponseSender;
 	@Autowired
+	private PriceDropService priceDropService;
+	@Autowired
 	private WalletService walletService;
 	@Autowired
 	private TagListingRepository tagListingRepository;
 	@Autowired
 	private SchemeService schemeService;
 	@Autowired
 	ReporticoService reporticoService;
+	@Autowired
+	LineItemImeisRepository lineItemImeisRepository;
 	@RequestMapping(value = "/getItemDescription", method = RequestMethod.GET)
 	public String getItemDescription(HttpServletRequest request, Model model) throws Throwable {
 		List<TagListing> tagListings = tagListingRepository.selectAll(false);
 		model.addAttribute("catalogDescription", catalogDescription);
 		return "price-drop";
+	}
-	/*
-	 * @RequestMapping(value = "/downloadtotalPriceDropIMEI/{priceDropId}", method =
-	 * RequestMethod.GET) public ResponseEntity<?>
-	 * downloadPriceDropIMEI(HttpServletRequest request, @PathVariable int
-	 * priceDropId, Model model) throws ProfitMandiBusinessException {
-	 *
-	 * PriceDrop priceDrop = priceDropRepository.selectById(priceDropId);
-	 * List<PriceDropIMEI> priceDropIMEIs =
-	 * priceDropIMEIRepository.selectByPriceDropId(priceDrop.getId()); List<String>
-	 * imeis = priceDropIMEIs.stream().map(x ->
-	 * x.getImei()).collect(Collectors.toList()); List<LineItemImei> lineItemImeis =
-	 * lineItemImeisRepository.selectByIMEI(imeis); Map<String, String>
-	 * priceDropIMEIfofoId = priceDropService.getIMEIandRetailerName(lineItemImeis,
-	 * priceDrop); if (priceDropIMEIfofoId.size() > 0) { ByteArrayOutputStream
-	 * byteArrayOutputStream = new ByteArrayOutputStream();
-	 * ExcelUtils.writePriceDrop(priceDropIMEIfofoId, priceDrop.getItemId(),
-	 * byteArrayOutputStream); final HttpHeaders headers = new HttpHeaders(); //
-	 * private static final String CONTENT_TYPE_XLSX = //
-	 * "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet"
-	 * headers.set("Content-Type",
-	 * "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet"); //
-	 * headers.set("Content-Type", "application/vnd.ms-excel");
-	 * headers.set("Content-disposition", "inline; filename=priceDrop" +
-	 * priceDrop.getId() + ".xlsx");
-	 * headers.setContentLength(byteArrayOutputStream.toByteArray().length); final
-	 * InputStream inputStream = new
-	 * ByteArrayInputStream(byteArrayOutputStream.toByteArray()); final
-	 * InputStreamResource inputStreamResource = new
-	 * InputStreamResource(inputStream); return new
-	 * ResponseEntity<InputStreamResource>(inputStreamResource, headers,
-	 * HttpStatus.OK); } else { throw new
-	 * ProfitMandiBusinessException("priceDropId", priceDropId,
-	 * "No IMEI is Eligible For PriceDrop"); }
-	 *
-	 * }
-	 */
 	@RequestMapping(value = "/price-drop/imes/download")
 	public ResponseEntity<ByteArrayResource> downloadPriceDropImeis(HttpServletRequest request,
 			@RequestParam LocalDateTime affectedDate, @RequestParam int itemId) throws Exception {
 		Item item = itemRepository.selectById(itemId);
 		ByteArrayOutputStream baos = getByteArrayOutputStream(affectedDate, item.getCatalogItemId());
 		if (priceDrop.getProcessTimestamp() == null) {
 			priceDrop.setPartnerPayout(priceDropProcess.getPartnerPayout());
 			priceDrop.setPriceDropIn(priceDropProcess.getPriceDropIn());
 			priceDrop.setProcessTimestamp(LocalDateTime.now());
 			priceDropRepository.persist(priceDrop);
-			String description  = itemRepository.selectAllByCatalogItemId(priceDrop.getCatalogItemId()).get(0).getItemDescriptionNoColor();
+			String description = itemRepository.selectAllByCatalogItemId(priceDrop.getCatalogItemId()).get(0)
+					.getItemDescriptionNoColor();
-			List<ImeiDropSummaryModel> partnerPendingImeis = getPartnerPendingImeis(priceDrop.getAffectedOn(),
+			List<ImeiDropSummaryModel> imeiDropSummaryModels = this.getAllSerialNumbersByAffectedDate(priceDrop.getAffectedOn(),
 					priceDrop.getCatalogItemId());
-			if (partnerPendingImeis.size() > 0) {
+			if (imeiDropSummaryModels.size() > 0) {
-				Map<Integer, List<ImeiDropSummaryModel>> partnerImeiMap = new HashMap<>();
+				List<String> serialNumbers = imeiDropSummaryModels.stream().map(x->x.getSerialNumber()).collect(Collectors.toList());
-				for (ImeiDropSummaryModel pendingImei : partnerPendingImeis) {
-					if (!partnerImeiMap.containsKey(pendingImei.getRetailerId())) {
+				List<LineItemImei> lineItemImeis = lineItemImeisRepository.selectByIMEI(serialNumbers);
-						partnerImeiMap.put(pendingImei.getRetailerId(), new ArrayList<>());
+				Map<Integer, List<InventoryItem>> pendingPartnerInventoryMap = priceDropService.getInventoryForPriceDrop(lineItemImeis, priceDrop).
-					}
-					partnerImeiMap.get(pendingImei.getRetailerId()).add(pendingImei);
+						stream().collect(Collectors.groupingBy(InventoryItem::getFofoId));
-				}
-				for (Map.Entry<Integer, List<ImeiDropSummaryModel>> pendingPartnerImei : partnerImeiMap.entrySet()) {
+				for (Map.Entry<Integer, List<InventoryItem>> pendingPartnerInventory : pendingPartnerInventoryMap.entrySet()) {
-					List<ImeiDropSummaryModel> retailerImeiList = pendingPartnerImei.getValue();
+					List<InventoryItem> fofoInventoryList = pendingPartnerInventory.getValue();
-					int fofoId = pendingPartnerImei.getKey();
+					int fofoId = pendingPartnerInventory.getKey();
-					List<InventoryItem> inventoryItems = inventoryItemRepository.selectByFofoIdSerialNumbers(fofoId,
-							retailerImeiList.stream().map(x -> x.getSerialNumber()).collect(Collectors.toSet()), false);
 					String reversalReason = MessageFormat.format(
-							"Scheme amount reversal due to Price Drop of Rs.{0} on {1}. Affected on {3}, Total {2} item(s)",
+							"Scheme  differential for Price Drop of Rs.{0} on {1}, on {3}. Total {2} item(s)",
-							priceDrop.getAmount(), description, pendingPartnerImei.getValue().size(),
+							priceDrop.getAmount(), description, fofoInventoryList.size(),
 							FormattingUtils.formatDate(priceDrop.getAffectedOn()));
 					String aReason = MessageFormat.format(
-							"Per unit payout of Rs.{4} Price Drop of Rs.{0} on {1} affected on {3}. Total {2} item(s)",
+							"Payout of Rs.{4} per unit for Price Drop of Rs.{0} on {1}, on {3}. Total {2} item(s)",
-							priceDrop.getAmount(), description, pendingPartnerImei.getValue().size(),
+							priceDrop.getAmount(), description, fofoInventoryList.size(),
 							FormattingUtils.formatDate(priceDrop.getAffectedOn()), priceDropProcess.getPartnerPayout());
-					inventoryService.updatePriceDrop(inventoryItems, priceDrop.getAmount());
+					inventoryService.updatePriceDrop(fofoInventoryList, priceDrop.getAmount());
-					schemeService.reverseSchemes(inventoryItems, priceDropProcess.getPriceDropId(), reversalReason);
+					schemeService.reverseSchemes(fofoInventoryList, priceDropProcess.getPriceDropId(), reversalReason);
-					walletService.addAmountToWallet(fofoId, priceDrop.getId(), WalletReferenceType.PRICE_DROP,
+					walletService.addAmountToWallet(fofoId, priceDrop.getId(), WalletReferenceType.PRICE_DROP, aReason,
-							aReason, priceDropProcess.getPartnerPayout()*pendingPartnerImei.getValue().size());
+							priceDropProcess.getPartnerPayout() * fofoInventoryList.size());
+				}
+			}
 			response = true;
+		}
 		PriceDrop priceDrop = priceDropRepository.selectById(priceDropId);
 		Item item = itemRepository.selectAllByCatalogItemId(priceDrop.getCatalogItemId()).get(0);
 		ByteArrayOutputStream baos = getByteArrayOutputStream(priceDrop.getAffectedOn(), priceDrop.getCatalogItemId());
 		final HttpHeaders headers = new HttpHeaders();
 		headers.set("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
+		headers.set("Content-disposition",
-		headers.set("Content-disposition", "inline; filename=pricedrop-" + item.getItemDescriptionNoColor().replaceAll("\\s?,\\s?", " ") + "-"
+				"inline; filename=pricedrop-" + item.getItemDescriptionNoColor().replaceAll("\\s?,\\s?", " ") + "-"
-				+ FormattingUtils.formatDate(priceDrop.getAffectedOn()) + ".csv");
+						+ FormattingUtils.formatDate(priceDrop.getAffectedOn()) + ".csv");
 		byte[] byteArray = baos.toByteArray();
 		headers.setContentLength(byteArray.length);
 		return new ResponseEntity<ByteArrayResource>(new ByteArrayResource(byteArray), headers, HttpStatus.OK);
+	}
-	private List<ImeiDropSummaryModel> getPartnerPendingImeis(LocalDateTime affectedOn, Integer catalogItemId)
+	private List<ImeiDropSummaryModel> getAllSerialNumbersByAffectedDate(LocalDateTime affectedOn,
-			throws Exception {
+			Integer catalogItemId) throws Exception {
-		Map<String, String> params = new HashMap<>();
-		params.put("MANUAL_criteria1_FROMDATE", FormattingUtils.formatReporitcoDate(affectedOn));
-		List<Item> items = itemRepository.selectAllByCatalogItemId(catalogItemId);
-		List<String> itemIds = items.stream().map(x -> String.valueOf(x.getId())).collect(Collectors.toList());
-		params.put("MANUAL_itemId", StringUtils.join(itemIds, ","));
-		Map<String, String> params1 = new HashMap<>();
-		params1.put("MANUAL_criteriaDate_FROMDATE", FormattingUtils.formatReporitcoDate(affectedOn));
-		params1.put("MANUAL_criteriaItemId", StringUtils.join(itemIds, ","));
-		List<? extends ImeiDropSummaryModel> grnPendingList = getReports(GrnPendingDataModel.class,
-				ReporticoProject.FOCO, "imeispendinggrn.xml", params);
-		List<? extends ImeiDropSummaryModel> partnerImeiNotSoldList = getReports(PartnerImeiNotSold.class,
-				ReporticoProject.FOCO, "PartnerIMEINotSold.xml", params1);
-		List<ImeiDropSummaryModel> mergedImeis = new ArrayList<>();
-		mergedImeis.addAll(grnPendingList);
-		mergedImeis.addAll(partnerImeiNotSoldList);
-		return mergedImeis;
-	}
-	private ByteArrayOutputStream getByteArrayOutputStream(LocalDateTime affectedOn, Integer catalogItemId)
-			throws Exception {
 		List<Item> items = itemRepository.selectAllByCatalogItemId(catalogItemId);
 		List<String> itemIds = items.stream().map(x -> String.valueOf(x.getId())).collect(Collectors.toList());
 		Map<String, String> params = new HashMap<>();
 		params.put("MANUAL_criteria1_FROMDATE", FormattingUtils.formatReporitcoDate(affectedOn));
 		params.put("MANUAL_itemId", StringUtils.join(itemIds, ","));
 		Map<String, String> params1 = new HashMap<>();
 		params1.put("MANUAL_criteriaDate_FROMDATE", FormattingUtils.formatReporitcoDate(affectedOn.minusDays(1)));
 		params1.put("MANUAL_criteriaItemId", StringUtils.join(itemIds, ","));
 		Map<String, String> params2 = new HashMap<>();
 		params2.put("MANUAL_Criteria2_FROMDATE", FormattingUtils.formatReporitcoDate(affectedOn.minusDays(1)));
 		params2.put("MANUAL_Criteria1", StringUtils.join(itemIds, ","));
 		List<? extends ImeiDropSummaryModel> grnPendingList = getReports(GrnPendingDataModel.class,
 				ReporticoProject.FOCO, "imeispendinggrn.xml", params);
 		List<? extends ImeiDropSummaryModel> partnerImeiNotSoldList = getReports(PartnerImeiNotSold.class,
 				ReporticoProject.FOCO, "PartnerIMEINotSold.xml", params1);
 		List<? extends ImeiDropSummaryModel> itemStockOnDateList = getReports(ClosingStockOnDate.class,
 				ReporticoProject.WAREHOUSENEW, "itemstockondate.xml", params2);
 		List<ImeiDropSummaryModel> mergedImeis = new ArrayList<>();
 		mergedImeis.addAll(grnPendingList);
 		mergedImeis.addAll(partnerImeiNotSoldList);
 		mergedImeis.addAll(itemStockOnDateList);
+		return mergedImeis;
+	}
+	private ByteArrayOutputStream getByteArrayOutputStream(LocalDateTime affectedOn, Integer catalogItemId)
+			throws Exception {
+		List<ImeiDropSummaryModel> imeiDropSummaryModelList = this.getAllSerialNumbersByAffectedDate(affectedOn, catalogItemId);
 		List<List<Object>> rows = new ArrayList<>();
-		for (ImeiDropSummaryModel imeiDropSummaryModel : mergedImeis) {
+		for (ImeiDropSummaryModel imeiDropSummaryModel : imeiDropSummaryModelList) {
 			List<Object> row = new ArrayList<>();
 			row.add(imeiDropSummaryModel.getSerialNumber());
 			row.add(imeiDropSummaryModel.getStoreName());
 			row.add(imeiDropSummaryModel.getPartnerCode());
 			row.add(imeiDropSummaryModel.getItemId());

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/PriceDropController.java – Rev 23982 → 23983