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

 import com.spice.profitmandi.service.transaction.TransactionService;
 import com.spice.profitmandi.service.wallet.WalletService;
 import com.spice.profitmandi.web.util.MVCResponseSender;
 @Controller
-@Transactional(rollbackFor=Throwable.class)
+@Transactional(rollbackFor = Throwable.class)
 public class PriceDropController {
 	private static final Logger LOGGER = LogManager.getLogger(PriceDropController.class);
 	@Autowired
 	@Autowired
 	private MVCResponseSender mvcResponseSender;
 	@Autowired
 	private PriceDropService priceDropService;
 	@Autowired
 	private ItemPricingHistoryRepository itemPricingHistoryRepository;
 	@Autowired
 	private WalletService walletService;
+	}
 	@RequestMapping(value = "/item", method = RequestMethod.GET)
 	public String getItemPricing(HttpServletRequest request, Model model, @RequestParam String query) throws Throwable {
 		String query1 = query.toLowerCase();
-		List<ItemDescriptionModel> partnersItemDescription = inventoryService.getAllPartnerItemStringDescription().parallelStream()
+		List<ItemDescriptionModel> partnersItemDescription = inventoryService.getAllPartnerItemStringDescription()
-				.filter(x -> x.getItemDescription().toLowerCase().matches(".*?" + query1 + ".*?"))
+				.parallelStream().filter(x -> x.getItemDescription().toLowerCase().matches(".*?" + query1 + ".*?"))
 				.collect(Collectors.toList());
 		model.addAttribute("response", mvcResponseSender.createResponseString(partnersItemDescription));
 		return "response";
+	}
 			throws Exception {
 		PriceDropImeisModel priceDropImeisModel = new PriceDropImeisModel();
 		// This call is used to persit imeis to pricedrop imeis in case its not there.
-		//This should be called while creating price drop.
+		// This should be called while creating price drop.
-		//priceDropService.priceDropStatus(priceDropId);
+		// priceDropService.priceDropStatus(priceDropId);
 		List<String> pendingImeis = new ArrayList<>();
 		List<String> approvedImeis = new ArrayList<>();
 		List<String> rejectedImeis = new ArrayList<>();
 		List<PriceDropIMEI> priceDropImeis = priceDropIMEIRepository.selectByPriceDropId(priceDropId);
 		model.addAttribute("response", mvcResponseSender.createResponseString(priceDropImeisModel));
 		return "response";
+	}
 	@RequestMapping(value = "/processPriceDrop", method = RequestMethod.POST)
-	public String processPriceDrop(HttpServletRequest request, @RequestBody PriceDropProcessModel priceDropProcess,
+	public String processPriceDrop(HttpServletRequest request, @RequestBody PriceDropProcessModel priceDropProcessModel,
 			Model model) throws Exception {
-		PriceDrop priceDrop = priceDropRepository.selectById(priceDropProcess.getPriceDropId());
+		PriceDrop priceDrop = priceDropRepository.selectById(priceDropProcessModel.getPriceDropId());
 		boolean response = false;
-		if (priceDrop.getProcessTimestamp() == null) {
+		if(priceDrop.getPartnerPayout()==0) {
-			priceDropService.processPriceDrop(priceDrop.getId());
+			priceDrop.setPartnerPayout(priceDropProcessModel.getPartnerPayout());
-			priceDrop.setProcessTimestamp(LocalDateTime.now());
-			priceDropRepository.persist(priceDrop);
-			response = true;
+		}
+		priceDrop.setProcessTimestamp(LocalDateTime.now());
+		priceDropRepository.persist(priceDrop);
+		priceDropService.processPriceDrop(priceDrop.getId(), priceDropProcessModel.isActivatedOnly());
+			response = true;
 		model.addAttribute("response", mvcResponseSender.createResponseString(response));
 		return "response";
+	}
 	@RequestMapping(value = "/priceDrop", method = RequestMethod.POST)
 						vip.setTp(priceDropModel.getTp());
 						vendorItemPricingRepository.persist(vip);
+					}
 					transactionService.updatePriceDrop(item.getId(), newDp);
+				}
-				//Add to itemPricing history
+				// Add to itemPricing history
 				ItemPricingHistory iph = new ItemPricingHistory();
 				iph.setCatalogId(currentItem.getCatalogItemId());
 				iph.setTp(priceDropModel.getTp());
 				iph.setDp(priceDropModel.getDp());
 				iph.setMop(priceDropModel.getMop());
-				//TODO: changedBy
+				// TODO: changedBy
 				iph.setChangedBy("me");
 				iph.setCreateTimestamp(LocalDateTime.now());
 				itemPricingHistoryRepository.persist(iph);
 				PriceDrop priceDrop = new PriceDrop();
 				priceDrop.setAffectedOn(priceDropModel.getAffectedDate());
 				priceDrop.setTp(oldTp);
 				priceDrop.setNlc(oldTp);
 				priceDrop.setMop(oldMop);
 	@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);
-		Map<String, PriceDropIMEI> priceDropIMEIsMap = priceDropIMEIRepository.selectByPriceDropId(priceDropId).
+		Map<String, PriceDropIMEI> priceDropIMEIsMap = priceDropIMEIRepository.selectByPriceDropId(priceDropId).stream()
-				stream().collect(Collectors.toMap(x->x.getImei(), x->x));
+				.collect(Collectors.toMap(x -> x.getImei(), x -> x));
-		if(priceDropIMEIsMap.size()==0 && priceDrop.getProcessTimestamp()==null) {
+		if (priceDropIMEIsMap.size() == 0 && priceDrop.getProcessTimestamp() == null) {
 			priceDrop.setProcessTimestamp(LocalDateTime.now());
 		} else {
 			priceDropService.priceDropStatus(priceDrop.getId());
+		}
 		Item item = itemRepository.selectAllByCatalogItemId(priceDrop.getCatalogItemId()).get(0);
-		ByteArrayOutputStream baos = getByteArrayOutputStream(priceDrop.getAffectedOn(), priceDrop.getCatalogItemId(), priceDropIMEIsMap);
+		ByteArrayOutputStream baos = getByteArrayOutputStream(priceDrop.getAffectedOn(), priceDrop.getCatalogItemId(),
+				priceDropIMEIsMap);
 		final HttpHeaders headers = new HttpHeaders();
 		headers.set("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
 		headers.set("Content-disposition",
 				"inline; filename=pricedrop-" + item.getItemDescriptionNoColor().replaceAll("\\s?,\\s?", " ") + "-"
 						+ FormattingUtils.formatDate(priceDrop.getAffectedOn()) + ".csv");
 		return new ResponseEntity<ByteArrayResource>(new ByteArrayResource(byteArray), headers, HttpStatus.OK);
+	}
 	@RequestMapping(value = "/updatePriceDropImeis-DNC", method = RequestMethod.POST)
-	public String updatePriceDropImeis(HttpServletRequest request,
+	public String updatePriceDropImeis(HttpServletRequest request, @RequestBody PriceDropImeisModel priceDropImeisModel,
-			@RequestBody PriceDropImeisModel priceDropImeisModel, Model model)
-			throws ProfitMandiBusinessException, Exception {
+			Model model) throws ProfitMandiBusinessException, Exception {
 		PriceDropImeiStatus status = PriceDropImeiStatus.PENDING;
 		switch (priceDropImeisModel.getUpdatedStatus()) {
-			case "approved": {
+		case "approved": {
-				status = PriceDropImeiStatus.APPROVED_OURS;
+			status = PriceDropImeiStatus.APPROVED_OURS;
-				break;
-			}
-			case "rejected": {
-				status = PriceDropImeiStatus.REJECTED;
-				break;
+			break;
-			}
+		}
+		case "rejected": {
-		if(PriceDropImeiStatus.PENDING.equals(status)) {
+			status = PriceDropImeiStatus.REJECTED;
-			throw new ProfitMandiBusinessException("INVALID STATUS", "PENDING", "only approved and rejected is allowed");
+			break;
+		}
+		}
+		if (PriceDropImeiStatus.PENDING.equals(status)) {
+			throw new ProfitMandiBusinessException("INVALID STATUS", "PENDING",
+					"only approved and rejected is allowed");
+		}
-		//TODO:PD
+		// TODO:PD
 		List<PriceDropIMEI> priceDropIMEIs = priceDropIMEIRepository
 				.selectByPriceDropId(priceDropImeisModel.getPriceDropId());
 		List<PriceDropIMEI> priceDropIMEIsToProcess = new ArrayList<>();
 		for (PriceDropIMEI priceDropIMEI : priceDropIMEIs) {
 			if (!priceDropImeisModel.getUpdatedImeis().contains(priceDropIMEI.getImei())
 					|| priceDropIMEI.getStatus().equals(status)) {
 				continue;
+			}
 			priceDropIMEIsToProcess.add(priceDropIMEI);
-			if(status.equals(PriceDropImeiStatus.REJECTED)) {
+			if (status.equals(PriceDropImeiStatus.REJECTED)) {
 				priceDropIMEI.setRejectionReason(priceDropImeisModel.getRejectionReason());
+			}
 			priceDropIMEI.setUpdateTimestamp(LocalDateTime.now());
+		}
+		/*
-		/*if (priceDropIMEIsToProcess.size() > 0) {
+		 * if (priceDropIMEIsToProcess.size() > 0) {
-			priceDropService.processManualPriceDrop(priceDropImeisModel.getPriceDropId(), priceDropIMEIsToProcess, status);
+		 * priceDropService.processManualPriceDrop(priceDropImeisModel.getPriceDropId(),
+		 * priceDropIMEIsToProcess, status); }
-		}*/
+		 */
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
-	private ByteArrayOutputStream getByteArrayOutputStream(LocalDateTime affectedOn, Integer catalogItemId, Map<String, PriceDropIMEI> priceDropImeis)
+	private ByteArrayOutputStream getByteArrayOutputStream(LocalDateTime affectedOn, Integer catalogItemId,
-			throws Exception {
+			Map<String, PriceDropIMEI> priceDropImeis) throws Exception {
 		List<ImeiDropSummaryModel> imeiDropSummaryModelList = priceDropService
 				.getAllSerialNumbersByAffectedDate(affectedOn, catalogItemId);
 		List<List<?>> rows = new ArrayList<>();
 		for (ImeiDropSummaryModel imeiDropSummaryModel : imeiDropSummaryModelList) {
-			if(priceDropImeis == null) {
+			if (priceDropImeis == null) {
 				rows.add(this.getRow(imeiDropSummaryModel, null));
-			} else if(priceDropImeis.get(imeiDropSummaryModel.getSerialNumber()) != null) {
+			} else if (priceDropImeis.get(imeiDropSummaryModel.getSerialNumber()) != null) {
 				rows.add(this.getRow(imeiDropSummaryModel, priceDropImeis.get(imeiDropSummaryModel.getSerialNumber())));
+			}
+		}
 		return FileUtil.getCSVByteStream(Arrays.asList("IMEI Number", "Store Name", "Store Code", "Item ID", "Brand",
-				"Model Name", "Model Number", "Color", "Status", "Rejection Reason", "Last Scanned", "Vendor Name", "Grn On", "Activation Timestamp", "Activation Added On"), rows);
+				"Model Name", "Model Number", "Color", "Status", "Rejection Reason", "Last Scanned", "Vendor Name",
+				"Grn On", "Activation Timestamp", "Activation Added On"), rows);
+	}
-	private List<? extends Serializable> getRow(ImeiDropSummaryModel imeiDropSummaryModel, PriceDropIMEI priceDropIMEI) {
+	private List<? extends Serializable> getRow(ImeiDropSummaryModel imeiDropSummaryModel,
+			PriceDropIMEI priceDropIMEI) {
 		List<Serializable> row = new ArrayList<>();
 		row.add(imeiDropSummaryModel.getSerialNumber());
 		row.add(imeiDropSummaryModel.getStoreName());
 		row.add(imeiDropSummaryModel.getPartnerCode());
 		row.add(imeiDropSummaryModel.getItemId());
 		row.add(imeiDropSummaryModel.getBrand());
 		row.add(imeiDropSummaryModel.getModelName());
 		row.add(imeiDropSummaryModel.getModelNumber());
 		row.add(imeiDropSummaryModel.getColor());
-		if(priceDropIMEI != null) {
+		if (priceDropIMEI != null) {
 			row.add(priceDropIMEI.getStatus());
 			row.add(priceDropIMEI.getRejectionReason());
 		} else {
 			row.add(PriceDropImeiStatus.PENDING);
 			row.add("");

Subversion Repositories SmartDukaan

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