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

 package com.spice.profitmandi.web.controller;
+import java.text.MessageFormat;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import com.spice.profitmandi.common.model.GrnPendingDataModel;
 import com.spice.profitmandi.common.model.ImeiDropSummaryModel;
 import com.spice.profitmandi.common.model.ItemDescriptionModel;
 import com.spice.profitmandi.common.model.PartnerImeiNotSold;
 import com.spice.profitmandi.common.model.PriceDropModel;
+import com.spice.profitmandi.common.model.PriceDropProcessModel;
 import com.spice.profitmandi.common.model.ReporticoResponseModel;
 import com.spice.profitmandi.common.services.ReporticoService;
 import com.spice.profitmandi.common.util.FileUtil;
 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.entity.transaction.PriceDropIMEI;
 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.PriceDropIMEIRepository;
 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;
+import in.shop2020.model.v1.order.WalletReferenceType;
 @Controller
 @Transactional
 public class PriceDropController {
 	private static final Logger LOGGER = LogManager.getLogger(PriceDropController.class);
 	@Autowired
 	private ObjectMapper objectMapper;
 	@Autowired
-	private PriceDropIMEIRepository priceDropIMEIRepository;
-	@Autowired
 	private VendorItemPricingRepository vendorItemPricingRepository;
 	@Autowired
-	private PriceDropService priceDropService;
-	@Autowired
 	@Qualifier("fofoInventoryService")
 	private InventoryService inventoryService;
 	@Autowired
-	private MVCResponseSender mvcResponseSender;
+	private InventoryItemRepository inventoryItemRepository;
 	@Autowired
-	private WalletService walletService;
+	private MVCResponseSender mvcResponseSender;
 	@Autowired
-	private LineItemImeisRepository lineItemImeisRepository;
+	private WalletService walletService;
 	@Autowired
 	private TagListingRepository tagListingRepository;
 	@Autowired
 	@Autowired
 	@Qualifier("catalogItemRepository")
 	private ItemRepository itemRepository;
 	@Autowired
+	private SchemeService schemeService;
+	@Autowired
 	ReporticoService reporticoService;
 	@RequestMapping(value = "/getItemDescription", method = RequestMethod.GET)
 	public String getItemDescription(HttpServletRequest request, Model model) throws Throwable {
 		List<TagListing> tagListings = tagListingRepository.selectAll(false);
 		Map<Integer, TagListing> tagListingMap = new HashMap<>();
 		List<ItemDescriptionModel> customItems = new ArrayList<>();
+		Map<Integer, String> catalogDescription = new HashMap<>();
 		for (TagListing tagListing : tagListings) {
+			Item item = itemRepository.selectById(tagListing.getItemId());
-			tagListing.setItemDescription(itemRepository.selectById(tagListing.getItemId()).getItemDescription());
+			tagListing.setItemDescription(item.getItemDescription());
 			tagListingMap.put(tagListing.getItemId(), tagListing);
 			ItemDescriptionModel itemDescriptionModel = new ItemDescriptionModel();
 			itemDescriptionModel.setItemId(tagListing.getItemId());
 			itemDescriptionModel
 					.setItemDescription(tagListing.getItemDescription() + "(" + tagListing.getItemId() + ")");
 			customItems.add(itemDescriptionModel);
+			catalogDescription.put(item.getCatalogItemId(), item.getItemDescriptionNoColor());
+		}
 		List<PriceDrop> priceDrops = priceDropRepository.selectAll();
 		model.addAttribute("tagListingMap", tagListingMap);
 		model.addAttribute("customItems", new JSONArray(customItems).toString());
 		model.addAttribute("priceDrops", priceDrops);
+		model.addAttribute("catalogDescription", catalogDescription);
 		return "price-drop";
+	}
 	/*
 	@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,
+		ByteArrayOutputStream baos = getByteArrayOutputStream(affectedDate, item.getCatalogItemId());
-				item.getCatalogItemId());
 		final HttpHeaders headers = new HttpHeaders();
 		headers.set("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
 		headers.set("Content-disposition", "inline; filename=imei-" + item.getItemDescriptionNoColor() + ".csv");
 		byte[] byteArray = baos.toByteArray();
 		headers.setContentLength(byteArray.length);
 		return new ResponseEntity<ByteArrayResource>(new ByteArrayResource(byteArray), headers, HttpStatus.OK);
+	}
-	@RequestMapping(value = "/paymentAgainstPriceDrop/{priceDropId}/{processedamount}", method = RequestMethod.POST)
+	@RequestMapping(value = "/processPriceDrop", method = RequestMethod.POST)
-	public String paymentAgainstPriceDropIMEI(HttpServletRequest request, @PathVariable int priceDropId,
+	public String processPriceDrop(HttpServletRequest request, @RequestBody PriceDropProcessModel priceDropProcess,
-			@PathVariable int processedamount, Model model) throws Exception {
+			Model model) throws Exception {
+		PriceDrop priceDrop = priceDropRepository.selectById(priceDropProcess.getPriceDropId());
+		boolean response = false;
+		if (priceDrop.getProcessTimestamp() == null) {
+			priceDrop.setPartnerPayout(priceDropProcess.getPartnerPayout());
+			priceDrop.setPriceDropIn(priceDropProcess.getPriceDropIn());
+			priceDrop.setProcessTimestamp(LocalDateTime.now());
+			priceDropRepository.persist(priceDrop);
+			List<ImeiDropSummaryModel> partnerPendingImeis = getPartnerPendingImeis(priceDrop.getAffectedOn(),
+					priceDrop.getCatalogItemId());
+			if (partnerPendingImeis.size() > 0) {
+				Map<Integer, List<ImeiDropSummaryModel>> partnerImeiMap = new HashMap<>();
+				for (ImeiDropSummaryModel pendingImei : partnerPendingImeis) {
+					if (!partnerImeiMap.containsKey(pendingImei.getRetailerId())) {
+						partnerImeiMap.put(pendingImei.getRetailerId(), new ArrayList<>());
+					}
+					partnerImeiMap.get(pendingImei.getRetailerId()).add(pendingImei);
+				}
-		int noOfIMEIForPartner = 1;
-		Map<Integer, Integer> noOfPriceDropToPartners = new HashMap<>();
+				for (Map.Entry<Integer, List<ImeiDropSummaryModel>> pendingPartnerImei : partnerImeiMap.entrySet()) {
-		PriceDrop priceDrop = priceDropRepository.selectById(priceDropId);
+					List<ImeiDropSummaryModel> retailerImeiList = pendingPartnerImei.getValue();
-		List<Item> items = itemRepository.selectAllByCatalogItemId(priceDrop.getCatalogItemId());
+					int fofoId = pendingPartnerImei.getKey();
-		List<PriceDropIMEI> priceDropIMEIs = priceDropIMEIRepository.selectByPriceDropId(priceDrop.getId());
+					List<InventoryItem> inventoryItems = inventoryItemRepository.selectByFofoIdSerialNumbers(fofoId,
-		List<String> imeis = priceDropIMEIs.stream().map(x -> x.getImei()).collect(Collectors.toList());
+							retailerImeiList.stream().map(x -> x.getSerialNumber()).collect(Collectors.toSet()), true);
+					String reversalReason = MessageFormat.format(
-		List<LineItemImei> lineItemImeis = lineItemImeisRepository.selectByIMEI(imeis);
+							"Scheme amount reversal due to Price Drop of Rs.{0} on {1}. Affected on {3}, Total {2} item(s)",
-		Map<String, Integer> priceDropIMEIfofoIds = priceDropService.getIMEIAndfofoIdForPriceDrop(lineItemImeis,
+							priceDrop.getAmount(), priceDrop.getDescription(), pendingPartnerImei.getValue().size(),
-				priceDrop);
+							FormattingUtils.formatDate(priceDrop.getAffectedOn()));
-		if (priceDropIMEIfofoIds.size() > 0) {
+					String aReason = MessageFormat.format(
-			for (Map.Entry<String, Integer> priceDropIMEIAndFofoId : priceDropIMEIfofoIds.entrySet()) {
+							"Per unit payout of Rs.{4} Price Drop of Rs.{0} on {1} affected on {3}. Total {2} item(s)",
-				int fofoId = priceDropIMEIAndFofoId.getValue();
+							priceDrop.getAmount(), priceDrop.getDescription(), pendingPartnerImei.getValue().size(),
+							FormattingUtils.formatDate(priceDrop.getAffectedOn()), priceDropProcess.getPartnerPayout());
+					schemeService.reverseSchemes(inventoryItems, priceDropProcess.getPriceDropId(), reversalReason);
-				if (noOfPriceDropToPartners.containsKey(fofoId)) {
+					inventoryService.updatePriceDrop(inventoryItems, priceDrop.getAmount());
-					noOfPriceDropToPartners.put(fofoId, noOfPriceDropToPartners.get(fofoId) + 1);
+					walletService.addAmountToWallet(fofoId, priceDrop.getId(), WalletReferenceType.PRICE_DROP,
-				} else {
-					noOfPriceDropToPartners.put(fofoId, noOfIMEIForPartner);
+							aReason, priceDropProcess.getPartnerPayout()*pendingPartnerImei.getValue().size());
+				}
+			}
-			priceDrop.setProcessTimestamp(LocalDateTime.now());
-			priceDrop.setPartnerPayout(processedamount);
-			priceDropRepository.persist(priceDrop);
-			model.addAttribute("response", mvcResponseSender.createResponseString(true));
-			return "response";
-		} else {
-			priceDrop.setProcessTimestamp(LocalDateTime.now());
-			model.addAttribute("response", mvcResponseSender.createResponseString(false));
-			return "false";
+			response = true;
+		}
+		model.addAttribute("response", mvcResponseSender.createResponseString(response));
+		return "response";
+	}
 	@RequestMapping(value = "/priceDrop", method = RequestMethod.POST)
 	public String addPriceDrop(HttpServletRequest request, Model model, @RequestBody PriceDropModel priceDropModel)
 			throws Exception {
 		boolean response = false;
+		priceDropModel.setAllColors(true);
 		if (this.validatePriceDrop(priceDropModel)) {
 			TagListing tagListing = tagListingRepository.selectByItemId(priceDropModel.getItemId());
 			float newDp = tagListing.getSellingPrice() - priceDropModel.getPd();
 			if (newDp > 0) {
 				List<Item> allItems = null;
+					}
 					transactionService.updatePriceDrop(item.getId(), newDp);
+				}
 				PriceDrop priceDrop = new PriceDrop();
 				priceDrop.setAffectedOn(priceDropModel.getAffectedDate());
+				priceDrop.setOldDp(newDp + priceDropModel.getPd());
 				priceDrop.setAmount(priceDropModel.getPd());
+				priceDrop.setNewDp(newDp);
+				priceDrop.setNlc(priceDropModel.getNlc());
+				priceDrop.setTp(priceDropModel.getTp());
 				priceDrop.setCreatedOn(LocalDateTime.now());
 				priceDrop.setCatalogItemId(currentItem.getCatalogItemId());
 				priceDropRepository.persist(priceDrop);
 				response = true;
 			} else {
 	@RequestMapping(value = "/downloadtotalPriceDropIMEI/{priceDropId}", method = RequestMethod.GET)
 	public ResponseEntity<?> downloadTotalPriceDropIMEI(HttpServletRequest request, @PathVariable int priceDropId,
 			Model model) throws ProfitMandiBusinessException, Exception {
 		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", "inline; filename=pricedrop-" + item.getItemDescriptionNoColor() + "-"
+				+ FormattingUtils.formatDate(priceDrop.getAffectedOn()) + ".csv");
+		byte[] byteArray = baos.toByteArray();
+		headers.setContentLength(byteArray.length);
+		return new ResponseEntity<ByteArrayResource>(new ByteArrayResource(byteArray), headers, HttpStatus.OK);
-		return new ResponseEntity<Boolean>(true, null, HttpStatus.OK);
+	}
-	private ByteArrayOutputStream getByteArrayOutputStream(LocalDateTime affectedOn, Integer catalogItemId)
+	private List<ImeiDropSummaryModel> getPartnerPendingImeis(LocalDateTime affectedOn, 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());
 		List<? extends ImeiDropSummaryModel> itemStockOnDateList = getReports(ClosingStockOnDate.class,
 				ReporticoProject.WAREHOUSENEW, "itemstockondate.xml", params2);
 		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));
+		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(itemStockOnDateList);
+		mergedImeis.addAll(grnPendingList);
+		mergedImeis.addAll(partnerImeiNotSoldList);
 		List<List<Object>> rows = new ArrayList<>();
 		for (ImeiDropSummaryModel imeiDropSummaryModel : mergedImeis) {
 			List<Object> row = new ArrayList<>();
 			row.add(imeiDropSummaryModel.getSerialNumber());
 			row.add(imeiDropSummaryModel.getStoreName());

Subversion Repositories SmartDukaan

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