Subversion Repositories SmartDukaan

import com.spice.profitmandi.dao.model.DelayDayModel;

import com.spice.profitmandi.dao.model.MarkDeliveredModel;

		List<CSVRecord> records = this.readFile(file);

		for (CSVRecord record : records) {

			BilledOrderListModel blm = createBilleOrder(record);

			billedOrderList.add(blm);

			LOGGER.info("records" + record.get(1));

		}

		List<CSVRecord> records = this.readFile(file);

		for (CSVRecord record : records) {

			ProviderTatModel sgr = createProviderTat(record);

			providerTatList.add(sgr);

		}

	@RequestMapping(value = "/downloadDelayDayTemplate", method = RequestMethod.GET)

	public ResponseEntity<?> downloadDelayDayTemplate(HttpServletRequest request) throws Exception {

		List<List<?>> rows = new ArrayList<>();

		org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil

				.getCSVByteStream(Arrays.asList("AirwayBillNumber", "Delay Day", "Reason"), rows);

		final HttpHeaders headers = new HttpHeaders();

		headers.set("Content-Type", "text/csv");

		headers.set("Content-disposition", "inline; filename=delay-day-template.csv");

		headers.setContentLength(baos.toByteArray().length);

		final InputStream inputStream = new ByteArrayInputStream(baos.toByteArray());

		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);

		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);

	}

	@RequestMapping(value = "/delayDayFileUpload", method = RequestMethod.POST)

	public String delayDayFileUpload(HttpServletRequest request, Model model, HttpServletResponse response,

			@RequestPart MultipartFile file) throws Throwable {

		List<CSVRecord> records = this.readFile(file);

		List<DelayDayModel> delayDayList = new ArrayList<>();

		for (CSVRecord record : records) {

			DelayDayModel ddm = createDelayDay(record);

			delayDayList.add(ddm);

		}

		if (!delayDayList.isEmpty()) {

			List<Order> vorders = orderRepository.selectByAirwayBillNumber(

					delayDayList.stream().map(x -> x.getAirwayBIllNumber()).collect(Collectors.toList()));

			List<Order> filteredorders = vorders.stream()

					.filter(x -> !x.getStatus().equals(OrderStatus.SHIPPED_FROM_WH)).collect(Collectors.toList());

			if (!filteredorders.isEmpty()) {

				throw new ProfitMandiBusinessException("Upload File", "",

						"Order status should be shipped from warehouse");

			}

			Map<String, List<Order>> airwayBillOrderMap = vorders.stream()

					.collect(Collectors.groupingBy(Order::getAirwayBillNumber));

			for (DelayDayModel ddm : delayDayList) {

				List<Order> orders = airwayBillOrderMap.get(ddm.getAirwayBIllNumber());

				if (!orders.isEmpty()) {

					Double totalAmount = orders.stream().mapToDouble(x -> x.getTotalAmount()).sum();

					List<String> invoiceNumbers = orders.stream().map(x -> x.getInvoiceNumber())

							.collect(Collectors.toList());

					int totalQty = orders.stream().mapToInt(x -> x.getLineItem().getQuantity()).sum();

					Order order = orders.get(0);

					ProviderTat pt = providerTatRepository.selectByProviderId(order.getLogisticsProviderId(),

							order.getWarehouseId(), order.getRetailerPinCode());

					LocalDate deliveryDate = logisticsService.calculateDeliveryTimeline(

							order.getShippingTimestamp().toLocalDate(), pt, ddm.getDelayDay());

					orders.forEach(x -> x.setExpectedDeliveryTime(deliveryDate.atStartOfDay()));

					SendNotificationModel sendNotificationModel = new SendNotificationModel();

					sendNotificationModel.setCampaignName("Order Update");

					sendNotificationModel.setTitle("Order Update");

					sendNotificationModel.setMessage(String

							.format("Dear partner, your items with Invoice Number " + String.join(",", invoiceNumbers)

									+ " worth Rs." + totalAmount + " and qty " + totalQty + " has been shipped through "

									+ providerRepository.selectById(order.getLogisticsProviderId()).getName()

									+ " via your track id " + ddm.getAirwayBIllNumber() + " has been delayed for "

									+ ddm.getReason() + " and will be delivered by "

									+ deliveryDate.format(DateTimeFormatter.ofPattern("dd-MM-yyyy"))));

					sendNotificationModel.setType("url");

					sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");

					sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));

					sendNotificationModel.setMessageType(MessageType.notification);

					int userId = userAccountRepository.selectUserIdByRetailerId(order.getRetailerId());

					sendNotificationModel.setUserIds(Arrays.asList(userId));

					notificationService.sendNotification(sendNotificationModel);

				} else {

					throw new ProfitMandiBusinessException("Upload File", "",

							"No order available for " + ddm.getAirwayBIllNumber() + " airwaybill Number");

				}

			}

		}

		model.addAttribute("response", mvcResponseSender.createResponseString(true));

		return "response";

	}

	private DelayDayModel createDelayDay(CSVRecord record) {

		DelayDayModel ddm = new DelayDayModel();

		ddm.setAirwayBIllNumber(record.get(0));

		ddm.setDelayDay(Integer.parseInt(record.get(1)));

		ddm.setReason(record.get(2));

		return ddm;

	}

	@RequestMapping(value = "/downloadMarkDeliveredTemplate", method = RequestMethod.GET)

	public ResponseEntity<?> downloadMarkDeliveredTemplate(HttpServletRequest request) throws Exception {

		List<List<?>> rows = new ArrayList<>();

		org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil

				.getCSVByteStream(Arrays.asList("AirwayBillNumber", "Delivered On", "Delivered By"), rows);

		final HttpHeaders headers = new HttpHeaders();

		headers.set("Content-Type", "text/csv");

		headers.set("Content-disposition", "inline; filename=mark-delivered-template.csv");

		headers.setContentLength(baos.toByteArray().length);

		final InputStream inputStream = new ByteArrayInputStream(baos.toByteArray());

		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);

		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);

	}

	@RequestMapping(value = "/markDeliveredFileUpload", method = RequestMethod.POST)

	public String markDeliveredFileUpload(HttpServletRequest request, Model model, HttpServletResponse response,

			@RequestPart MultipartFile file) throws Throwable {

		List<CSVRecord> records = this.readFile(file);

		List<MarkDeliveredModel> deliveredList = new ArrayList<>();

		for (CSVRecord record : records) {

			MarkDeliveredModel ddm = createMarkDeliveredModel(record);

			deliveredList.add(ddm);

		}

		if (!deliveredList.isEmpty()) {

			List<Order> vorders = orderRepository.selectByAirwayBillNumber(

					deliveredList.stream().map(x -> x.getAirwayBillNumber()).collect(Collectors.toList()));

			List<Order> filteredorders = vorders.stream()

					.filter(x -> !x.getStatus().equals(OrderStatus.SHIPPED_FROM_WH)).collect(Collectors.toList());

			if (!filteredorders.isEmpty()) {

				throw new ProfitMandiBusinessException("Upload File", "",

						"Order status should be shipped from warehouse");

			}

			Map<String, List<Order>> airwayBillOrderMap = vorders.stream()

					.collect(Collectors.groupingBy(Order::getAirwayBillNumber));

			for (MarkDeliveredModel dl : deliveredList) {

				List<Order> orders = airwayBillOrderMap.get(dl.getAirwayBillNumber());

				if (!orders.isEmpty()) {

					for (Order order : orders) {

						order.setDeliveryTimestamp(dl.getDeliveredOn());

						order.setStatus(OrderStatus.DELIVERY_SUCCESS);

					}

					SendNotificationModel sendNotificationModel = new SendNotificationModel();

					sendNotificationModel.setCampaignName("Order Delivered");

					sendNotificationModel.setTitle("Order Delivered");

					sendNotificationModel.setMessage(String.format("Dear partner, your SmartDukaan ORDER "

							+ dl.getAirwayBillNumber() + "has been delivered to you in a safe, sealed bag by "

							+ dl.getDeliveredBy() + "."));

					sendNotificationModel.setType("url");

					sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");

					sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));

					sendNotificationModel.setMessageType(MessageType.notification);

					int userId = userAccountRepository.selectUserIdByRetailerId(orders.get(0).getRetailerId());

					sendNotificationModel.setUserIds(Arrays.asList(userId));

					notificationService.sendNotification(sendNotificationModel);

				} else {

					throw new ProfitMandiBusinessException("Upload File", "",

							"No order available for " + dl.getAirwayBillNumber() + " airwaybill Number");

				}

			}

		}

		model.addAttribute("response", mvcResponseSender.createResponseString(true));

		return "response";

	}

	private MarkDeliveredModel createMarkDeliveredModel(CSVRecord record) {

		MarkDeliveredModel mdm = new MarkDeliveredModel();

		mdm.setAirwayBillNumber(record.get(0));

		DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");

		LocalDateTime dateTime = LocalDateTime.parse(record.get(1), formatter);

		mdm.setDeliveredOn(dateTime);

		mdm.setDeliveredBy(record.get(2));

		return mdm;

	}

	private List<CSVRecord> readFile(MultipartFile file) throws IOException, ProfitMandiBusinessException {

		CSVParser parser = new CSVParser(new InputStreamReader(file.getInputStream()), CSVFormat.DEFAULT);

		List<CSVRecord> records = parser.getRecords();

		LOGGER.info("records" + records);

		LOGGER.info("parser" + parser);

		if (records.size() < 2) {

			parser.close();

			throw new ProfitMandiBusinessException("Uploaded File", "", "No records Found");

		}

		// Remove header

		records.remove(0);

		parser.close();

		return records;

	}