Subversion Repositories SmartDukaan

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

							|| !x.getStatus().equals(OrderStatus.DELIVERY_SUCCESS)))

					.collect(Collectors.toList());

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

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

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

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

				.getCSVByteStream(Arrays.asList("Invoice Number", "Reason"), rows);

		final HttpHeaders headers = new HttpHeaders();

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

		headers.set("Content-disposition", "inline; filename=delay-billing-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 = "/getDelayBillingFileUploader", method = RequestMethod.POST)

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

			@RequestPart MultipartFile file) throws Throwable {

		LOGGER.info("file" + file.toString());

		String fileName = file.getName();

		String fileNames = file.getOriginalFilename();

		LOGGER.info("fileName" + fileName);

		LOGGER.info("fileNames" + fileNames);

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

		List<DelayBillingModel> delayBillingModel = new ArrayList<DelayBillingModel>();

		for (CSVRecord record : records) {

			DelayBillingModel dbm = new DelayBillingModel();

			dbm.setInvoiceNumber(record.get(0));

			dbm.setReason(record.get(1));

			delayBillingModel.add(dbm);

		}

		if (!delayBillingModel.isEmpty()) {

			for (DelayBillingModel delayBilling : delayBillingModel) {

				List<Order> orders = orderRepository.selectByInvoiceNumber(delayBilling.getInvoiceNumber());

				for (Order order : orders) {

					order.setDelayReasonText(delayBilling.getReason());

					if (!order.getStatus().equals(OrderStatus.BILLED)) {

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

								"Order" + order.getInvoiceNumber() + "status should be Billed");

					}

				}

				SendNotificationModel sendNotificationModel = new SendNotificationModel();

				sendNotificationModel.setCampaignName("Order Hold");

				sendNotificationModel.setTitle("Order Hold");

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

						+ delayBilling.getInvoiceNumber() + "has been delayed for " + delayBilling.getReason() + "."));

				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);

			}

		}

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

		return "response";

	}