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

 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.HashMap;
-import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 import javax.servlet.http.HttpServletRequest;
 import javax.transaction.Transactional;
+import org.apache.commons.io.output.ByteArrayOutputStream;
+import org.apache.commons.lang.StringUtils;
 import org.apache.http.HttpResponse;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.json.JSONArray;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.core.io.ByteArrayResource;
+import org.springframework.http.HttpHeaders;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Controller;
 import org.springframework.ui.Model;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
-import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.JavaType;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.ObjectReader;
 import com.spice.profitmandi.common.enumuration.ReporticoProject;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.ClosingStockOnDate;
 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.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.service.pricing.PriceDropService;
 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 PriceDropRepository priceDropRepository;
+	@Autowired
-	private ObjectMapper objectMapper = new ObjectMapper();
+	private ObjectMapper objectMapper;
 	@Autowired
 	private PriceDropIMEIRepository priceDropIMEIRepository;
 	@Autowired
 	 * "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());
+		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)
 	public String paymentAgainstPriceDropIMEI(HttpServletRequest request, @PathVariable int priceDropId,
 			@PathVariable int processedamount, Model model) throws Exception {
 		int noOfIMEIForPartner = 1;
 		Map<Integer, Integer> noOfPriceDropToPartners = new HashMap<>();
 		PriceDrop priceDrop = priceDropRepository.selectById(priceDropId);
-		Item item = itemRepository.selectById(priceDrop.getItemId());
+		List<Item> items = itemRepository.selectAllByCatalogItemId(priceDrop.getCatalogItemId());
 		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, Integer> priceDropIMEIfofoIds = priceDropService.getIMEIAndfofoIdForPriceDrop(lineItemImeis,
 				priceDrop);
 				} else {
 					noOfPriceDropToPartners.put(fofoId, noOfIMEIForPartner);
+				}
+			}
-			for (Map.Entry<Integer, Integer> noOfPriceDropToPartner : noOfPriceDropToPartners.entrySet()) {
-				String description = String.format("Price Drop amount added for %s, total %d pcs.",
-						item.getItemDescription(), noOfPriceDropToPartner.getValue());
-				walletService.addAmountToWallet(noOfPriceDropToPartner.getKey(), priceDrop.getId(),
-						WalletReferenceType.PRICE_DROP, description,
-						(noOfPriceDropToPartner.getValue() * processedamount));
-				LOGGER.info(
-						"Price Drop amount [{}] has been added with retailerId [{}]'s wallet, referenceId [{}], No Of serialNumber [{}]",
-						(noOfPriceDropToPartner.getValue() * processedamount), noOfPriceDropToPartner.getKey(),
-						priceDrop.getId(), noOfPriceDropToPartner.getValue());
-			}
 			priceDrop.setProcessTimestamp(LocalDateTime.now());
 			priceDrop.setPartnerPayout(processedamount);
 			priceDropRepository.persist(priceDrop);
 			model.addAttribute("response", mvcResponseSender.createResponseString(true));
 			return "response";
 						vip.setMop(priceDropModel.getMop());
 						vip.setNlc(priceDropModel.getNlc());
 						vip.setTp(priceDropModel.getTp());
 						vendorItemPricingRepository.persist(vip);
+					}
-					PriceDrop priceDrop = new PriceDrop();
-					priceDrop.setAffectedOn(priceDropModel.getAffectedDate());
-					priceDrop.setAmount(priceDropModel.getPd());
-					priceDrop.setCreatedOn(LocalDateTime.now());
-					priceDrop.setItemId(item.getId());
-					priceDropRepository.persist(priceDrop);
 					transactionService.updatePriceDrop(item.getId(), newDp);
+				}
+				PriceDrop priceDrop = new PriceDrop();
+				priceDrop.setAffectedOn(priceDropModel.getAffectedDate());
+				priceDrop.setAmount(priceDropModel.getPd());
+				priceDrop.setCreatedOn(LocalDateTime.now());
+				priceDrop.setCatalogItemId(currentItem.getCatalogItemId());
+				priceDropRepository.persist(priceDrop);
 				response = true;
 			} else {
 				throw new ProfitMandiBusinessException("Price Drop", priceDropModel.getPd(),
 						"Price Drop Cannot be more than Current DP");
+			}
 	@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);
+		return new ResponseEntity<Boolean>(true, null, HttpStatus.OK);
+	}
+	private ByteArrayOutputStream getByteArrayOutputStream(LocalDateTime affectedOn, Integer catalogItemId)
+			throws Exception {
 		Map<String, String> params = new HashMap<>();
-		params.put("MANUAL_criteria1_FROMDATE", FormattingUtils.formatReporitcoDate(priceDrop.getAffectedOn()));
+		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", String.valueOf(priceDrop.getItemId()));
+		params.put("MANUAL_itemId", StringUtils.join(itemIds, ","));
 		Map<String, String> params1 = new HashMap<>();
-		params1.put("MANUAL_criteriaDate_FROMDATE", FormattingUtils.formatReporitcoDate(priceDrop.getAffectedOn()));
+		params1.put("MANUAL_criteriaDate_FROMDATE", FormattingUtils.formatReporitcoDate(affectedOn));
-		params1.put("MANUAL_criteriaItemId", String.valueOf(priceDrop.getItemId()));
+		params1.put("MANUAL_criteriaItemId", StringUtils.join(itemIds, ","));
 		Map<String, String> params2 = new HashMap<>();
-		params2.put("MANUAL_Criteria2_FROMDATE", FormattingUtils.formatReporitcoDate(priceDrop.getAffectedOn()));
+		params2.put("MANUAL_Criteria2_FROMDATE", FormattingUtils.formatReporitcoDate(affectedOn));
-		params2.put("MANUAL_Criteria1", String.valueOf(priceDrop.getItemId()));
+		params2.put("MANUAL_Criteria1", StringUtils.join(itemIds, ","));
-		List<GrnPendingDataModel> grnPendingList = getReports(GrnPendingDataModel.class, ReporticoProject.FOCO, "imeispendinggrn.xml", params);
+		List<? extends ImeiDropSummaryModel> grnPendingList = getReports(GrnPendingDataModel.class,
+				ReporticoProject.FOCO, "imeispendinggrn.xml", params);
-		List<PartnerImeiNotSold> partnerImeiNotSoldList = getReports(PartnerImeiNotSold.class, ReporticoProject.FOCO, "PartnerIMEINotSold.xml", params1);
+		List<? extends ImeiDropSummaryModel> partnerImeiNotSoldList = getReports(PartnerImeiNotSold.class,
+				ReporticoProject.FOCO, "PartnerIMEINotSold.xml", params1);
-		List<ClosingStockOnDate> itemStockOnDateList = getReports(ClosingStockOnDate.class, ReporticoProject.WAREHOUSENEW, "itemstockondate.xml", params2);
+		List<? extends ImeiDropSummaryModel> itemStockOnDateList = getReports(ClosingStockOnDate.class,
-		return new ResponseEntity<Boolean>(true, null, HttpStatus.OK);
+				ReporticoProject.WAREHOUSENEW, "itemstockondate.xml", params2);
-		//List<Strng>
-		/*
-		 * ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
+		List<ImeiDropSummaryModel> mergedImeis = new ArrayList<>();
-		 * ExcelUtils.writePriceDropForAllIMEI(priceDropIMEIAndItemId,
+		mergedImeis.addAll(grnPendingList);
-		 * byteArrayOutputStream); final HttpHeaders headers = new HttpHeaders();
+		mergedImeis.addAll(partnerImeiNotSoldList);
-		 * headers.set("Content-Type",
+		mergedImeis.addAll(itemStockOnDateList);
-		 * "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
+		List<List<Object>> rows = new ArrayList<>();
-		 * headers.set("Content-disposition", "inline; filename=totalPriceDropIMEI" +
+		for (ImeiDropSummaryModel imeiDropSummaryModel : mergedImeis) {
-		 * priceDrop.getItemId() + ".xlsx");
+			List<Object> row = new ArrayList<>();
-		 * headers.setContentLength(byteArrayOutputStream.toByteArray().length); final
+			row.add(imeiDropSummaryModel.getSerialNumber());
-		 * InputStream inputStream = new
+			row.add(imeiDropSummaryModel.getStoreName());
-		 * ByteArrayInputStream(byteArrayOutputStream.toByteArray()); final
+			row.add(imeiDropSummaryModel.getPartnerCode());
-		 * InputStreamResource inputStreamResource = new
+			row.add(imeiDropSummaryModel.getItemId());
-		 * InputStreamResource(inputStream); return new
+			row.add(imeiDropSummaryModel.getBrand());
-		 * ResponseEntity<InputStreamResource>(inputStreamResource, headers,
+			row.add(imeiDropSummaryModel.getModelName());
-		 * HttpStatus.OK); } else { priceDrop.setProcessTimestamp(LocalDateTime.now());
+			row.add(imeiDropSummaryModel.getModelNumber());
-		 * throw new ProfitMandiBusinessException("IMEI", 1,
+			row.add(imeiDropSummaryModel.getColor());
+			row.add(FormattingUtils.formatReporitcoDate(imeiDropSummaryModel.getLastScanned()));
-		 * "IMEI not Found For PriceDrop"); }
+			rows.add(row);
-		 */
+		}
+		return FileUtil.getCSVByteStream(Arrays.asList("IMEI Number", "Store Name", "Store Code", "Item ID", "Brand",
+				"Model Name", "Model Number", "Color", "Last Scanned"), rows);
+	}
 	private <T> List<T> getReports(Class<T> className, ReporticoProject project, String reportName,
 			Map<String, String> params) throws Exception {
 		HttpResponse reportResponse = reporticoService.getJsonFile(project, reportName, params);
-		TypeReference<ReporticoResponseModel<T>> typeReference = new TypeReference<ReporticoResponseModel<T>>() {
+		JavaType type = objectMapper.getTypeFactory().constructParametricType(ReporticoResponseModel.class, className);
-		};
-		ObjectReader or = objectMapper.readerFor(typeReference);
+		ObjectReader or = objectMapper.readerFor(type);
 		ReporticoResponseModel<T> responseObj = or.readValue(reportResponse.getEntity().getContent());
 		return responseObj.getData();
+	}
 	private boolean validatePriceDrop(PriceDropModel priceDropModel) throws ProfitMandiBusinessException {
 			return true;
+		}
 		return false;
+	}
-	private Map<String, String> getpriceDropIMEIAndItemDescription(PriceDrop priceDrop)
-			throws ProfitMandiBusinessException {
-		Map<String, String> priceDropIMEIAndItemId = new LinkedHashMap<>();
-		List<InventoryItem> inventoryInStock = inventoryService.getInventoryInStock(priceDrop.getItemId(),
-				priceDrop.getAffectedOn());
-		return priceDropIMEIAndItemId;
-	}
+}

Subversion Repositories SmartDukaan

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