Rev 35210 | Go to most recent revision | View as "text/plain" | Blame | Compare with Previous | Last modification | View Log | RSS feed
package com.spice.profitmandi.web.controller;import com.google.gson.Gson;import com.spice.profitmandi.common.enumuration.MessageType;import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;import com.spice.profitmandi.common.model.CustomRetailer;import com.spice.profitmandi.common.model.ProfitMandiConstants;import com.spice.profitmandi.common.model.SendNotificationModel;import com.spice.profitmandi.common.util.FileUtil;import com.spice.profitmandi.common.util.FormattingUtils;import com.spice.profitmandi.dao.entity.auth.AuthUser;import com.spice.profitmandi.dao.entity.cs.Position;import com.spice.profitmandi.dao.entity.logistics.Provider;import com.spice.profitmandi.dao.entity.logistics.ProviderDetails;import com.spice.profitmandi.dao.entity.logistics.ProviderTat;import com.spice.profitmandi.dao.entity.logistics.PublicHolidays;import com.spice.profitmandi.dao.entity.transaction.Order;import com.spice.profitmandi.dao.entity.user.Address;import com.spice.profitmandi.dao.enumuration.cs.EscalationType;import com.spice.profitmandi.dao.model.*;import com.spice.profitmandi.dao.repository.auth.AuthRepository;import com.spice.profitmandi.dao.repository.cs.CsService;import com.spice.profitmandi.dao.repository.cs.PositionRepository;import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;import com.spice.profitmandi.dao.repository.logistics.ProviderDetailsRepository;import com.spice.profitmandi.dao.repository.logistics.ProviderRepository;import com.spice.profitmandi.dao.repository.logistics.ProviderTatRepository;import com.spice.profitmandi.dao.repository.logistics.PublicHolidaysRepository;import com.spice.profitmandi.dao.repository.transaction.OrderRepository;import com.spice.profitmandi.dao.repository.user.AddressRepository;import com.spice.profitmandi.dao.repository.user.UserRepository;import com.spice.profitmandi.dao.service.biuedart.BluedartService;import com.spice.profitmandi.service.LogisticsService;import com.spice.profitmandi.service.NotificationService;import com.spice.profitmandi.web.model.LoginDetails;import com.spice.profitmandi.web.util.CookiesProcessor;import com.spice.profitmandi.web.util.MVCResponseSender;import in.shop2020.logistics.DeliveryType;import in.shop2020.logistics.PickUpType;import in.shop2020.model.v1.order.OrderStatus;import org.apache.commons.csv.CSVRecord;import org.apache.commons.lang3.tuple.Pair;import org.apache.logging.log4j.LogManager;import org.apache.logging.log4j.Logger;import org.json.JSONArray;import org.json.JSONObject;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.core.io.InputStreamResource;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.*;import org.springframework.web.multipart.MultipartFile;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;import javax.transaction.Transactional;import java.io.ByteArrayInputStream;import java.io.InputStream;import java.time.LocalDate;import java.time.LocalDateTime;import java.time.format.DateTimeFormatter;import java.util.*;import java.util.Map.Entry;import java.util.stream.Collectors;@Controller@Transactional(rollbackOn = Throwable.class)public class LogisticsController {@Autowiredprivate OrderRepository orderRepository;@Autowiredprivate ProviderRepository providerRepository;@Autowiredprivate ProviderDetailsRepository providerDetailsRepository;@Autowiredprivate MVCResponseSender mvcResponseSender;@Autowiredprivate ProviderTatRepository providerTatRepository;@Autowiredprivate PublicHolidaysRepository publicHolidaysRepository;@Autowiredprivate LogisticsService logisticsService;@Autowiredprivate UserAccountRepository userAccountRepository;@Autowiredprivate NotificationService notificationService;@Autowiredprivate AuthRepository authRepository;@Autowiredprivate PositionRepository positionRepository;@Autowiredprivate CookiesProcessor cookiesProcessor;@AutowiredCsService csService;@Autowiredprivate Gson gson;@Autowiredprivate AddressRepository addressRepository;@Autowiredprivate UserRepository userUserRepository;@Autowiredprivate BluedartService bluedartService;private static final Logger LOGGER = LogManager.getLogger(LogisticsController.class);@RequestMapping(value = "/logistics", method = RequestMethod.GET)public String logistics(HttpServletRequest request, Model model) throws Exception {ProviderTat pt = providerTatRepository.selectByProviderId(1, 7678, "110018");return "logistics";}@RequestMapping(value = "/authorisedWarehouses")public String authorisedWarehouses(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);String email = loginDetails.getEmailId();AuthUser authUser = authRepository.selectByEmailOrMobile(email);List<Position> positions = positionRepository.selectAllByAuthUserId(authUser.getId());List<Position> warehousePositions = positions.stream().filter(x -> x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_WAREHOUSE).collect(Collectors.toList());Set<CustomRetailer> positionRetailers = new HashSet<>();csService.getPositionCustomRetailerMap(warehousePositions).values().forEach(customRetailers -> {positionRetailers.addAll(customRetailers);});Map<Integer, String> warehouseMap = this.getWarehouses(positionRetailers);JSONArray response = new JSONArray();warehouseMap.keySet().stream().filter(x -> warehouseMap.get(x) != null).forEach(x -> {response.put(new JSONObject().put("id", x).put("name", warehouseMap.get(x)));});LOGGER.info("response1", response.toString());model.addAttribute("response1", response.toString());return "response";}@RequestMapping(value = "/billedOrderFileUploader", method = RequestMethod.POST)public String getBilledOrderFileUploader(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 = FileUtil.readFile(file);List<BilledOrderListModel> billedOrderListModels = new ArrayList<>();for (CSVRecord record : records) {BilledOrderListModel billedOrderListModel = createBilleOrder(record);billedOrderListModels.add(billedOrderListModel);LOGGER.info("records" + record.get(1));}//Add Validation//This is server side validationMap<String, Set<String>> providerWayBillNumberMap = billedOrderListModels.stream().collect(Collectors.groupingBy(x -> x.getLogisticsProviderName(), Collectors.mapping(BilledOrderListModel::getAirwayBillNumber, Collectors.toSet())));List<Order> ordersByWaybill = orderRepository.selectByAirwayBillNumber(providerWayBillNumberMap.values().stream().flatMap(x -> x.stream()).collect(Collectors.toList()));Map<Integer, String> providerMap = providerRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getName()));Map<Integer, List<Order>> existingProviderOrderMap = ordersByWaybill.stream().collect(Collectors.groupingBy(x -> x.getLogisticsProviderId()));for (Entry<Integer, List<Order>> existingProviderEntrySet : existingProviderOrderMap.entrySet()) {String providerName = providerMap.get(existingProviderEntrySet.getKey());LOGGER.info("Provider Name - {}", providerName);Set<String> wayBillNumbers = providerWayBillNumberMap.get(providerName);if (wayBillNumbers == null) continue;for (Order order : ordersByWaybill) {if (wayBillNumbers.contains(order.getAirwayBillNumber())) {String errorMessage = "Provider " + providerName + ", wayBillNumber " + order.getAirwayBillNumber() + " already exists";throw new ProfitMandiBusinessException(errorMessage, errorMessage, errorMessage);}}}LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);String email = loginDetails.getEmailId();AuthUser authUser = authRepository.selectByEmailOrMobile(email);List<Position> positions = positionRepository.selectAllByAuthUserId(authUser.getId());List<Position> warehousePositions = positions.stream().filter(x -> x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_WAREHOUSE).collect(Collectors.toList());List<Integer> authWarehouseIds = null;if (warehousePositions.stream().filter(x -> EscalationType.L2.isGreaterThanEqualTo(x.getEscalationType())).count() > 0) {authWarehouseIds = new ArrayList<>(ProfitMandiConstants.WAREHOUSE_MAP.keySet());} else {Set<CustomRetailer> positionRetailers = new HashSet<>();csService.getPositionCustomRetailerMap(warehousePositions).values().forEach(customRetailers -> {positionRetailers.addAll(customRetailers);});LOGGER.info("positionRetailers" + positionRetailers);List<Integer> fofoIds = new ArrayList<>();if (!positionRetailers.isEmpty()) {fofoIds.addAll(positionRetailers.stream().map(x -> x.getPartnerId()).collect(Collectors.toList()));authWarehouseIds = this.getWarehouses(positionRetailers).entrySet().stream().map(x -> x.getKey()).collect(Collectors.toList());}}Map<String, DispatchNotificationModel> dispatchNotication = new HashMap<>();if (!billedOrderListModels.isEmpty()) {List<Order> ords = orderRepository.selectByInvoiceNumbers(billedOrderListModels.stream().map(x -> x.getInvoiceNumber()).collect(Collectors.toList()));List<Integer> shippingWarehouseIds = ords.stream().map(x -> x.getWarehouseId()).collect(Collectors.toList());if (!authWarehouseIds.containsAll(shippingWarehouseIds)) {throw new ProfitMandiBusinessException("Uploaded File", "", "Partners are not belong to the same warehouse");}Map<String, Integer> invoiceRetailerMap = ords.stream().collect(Collectors.toMap(x -> x.getInvoiceNumber(), x -> x.getRetailerId(), (u, v) -> u));LOGGER.info("invoicefofoIdmap" + invoiceRetailerMap);Map<String, Set<String>> airbillInvoiceNumberMap = billedOrderListModels.stream().collect(Collectors.groupingBy(x -> x.getAirwayBillNumber(), Collectors.mapping(BilledOrderListModel::getInvoiceNumber, Collectors.toSet())));LOGGER.info("airbillInvoiceNumberMap" + airbillInvoiceNumberMap);for (Entry<String, Set<String>> airbillInvoiceNumberEntry : airbillInvoiceNumberMap.entrySet()) {Set<String> invoiceNumbers = airbillInvoiceNumberEntry.getValue();Set<Integer> wayBillRetailerSet = new HashSet<>();for (String invoiceNumber : invoiceNumbers) {if (invoiceRetailerMap.get(invoiceNumber) != null) {wayBillRetailerSet.add(invoiceRetailerMap.get(invoiceNumber));}}LOGGER.info("wayBillRetailerSet - {}" + wayBillRetailerSet);if (wayBillRetailerSet.size() > 1) {throw new ProfitMandiBusinessException("Uploaded File", "", "Waybill " + airbillInvoiceNumberEntry.getKey() + " number cannot have invoices with different Retailers");}}Map<String, List<BilledOrderListModel>> blueDartAwbBilledOrderMap = billedOrderListModels.stream().filter(x -> x.getLogisticsProviderName().equals("BlueDart")).collect(Collectors.groupingBy(x -> x.getAirwayBillNumber(), Collectors.toList()));List<BilledOrderListModel> orderList = billedOrderListModels.stream().filter(x -> !x.getLogisticsProviderName().equals("BlueDart")).collect(Collectors.toList());if (!blueDartAwbBilledOrderMap.isEmpty()) {List<BilledOrderListModel> blueDartorderList = billedOrderListModels.stream().filter(x -> x.getLogisticsProviderName().equals("BlueDart")).collect(Collectors.toList());Provider provider = providerRepository.selectByName("BlueDart");List<Integer> unserviceablePincode = new ArrayList<>();for (BilledOrderListModel billedOrder : blueDartorderList) {List<Order> orders = orderRepository.selectByInvoiceNumber(billedOrder.getInvoiceNumber());for (Order order : orders) {ProviderTat providerTat = providerTatRepository.selectByProviderId(provider.getId(), order.getWarehouseId(), order.getRetailerPinCode());if (providerTat == null) {unserviceablePincode.add(order.getId());}}}if (!unserviceablePincode.isEmpty()) {throw new ProfitMandiBusinessException("Uploaded File", "", "Orders " + unserviceablePincode + " Unserviceable Pincode");}//Use api to create fresh Waybills for BlueDartList<BilledOrderListModel> blueDartOrders = bluedartService.getAirwayBillNo(blueDartAwbBilledOrderMap, authUser.getEmailId());orderList.addAll(blueDartOrders);}Map<String, BilledOrderListModel> uniqueCombinations = new HashMap<>();for (BilledOrderListModel bl : orderList) {List<Order> orders = orderRepository.selectByInvoiceNumber(bl.getInvoiceNumber());Provider provider = providerRepository.selectByName(bl.getLogisticsProviderName());if (provider == null) {throw new ProfitMandiBusinessException("Uploaded File", "", "Provider is not Available");}if (!orders.isEmpty()) {dispatchNotication = logisticsService.markedOrderShippedDetail(orders, provider, dispatchNotication, bl.getAirwayBillNumber(), bl.getShippingDate());} else {throw new ProfitMandiBusinessException("Uploaded File", "", "No Order Found");}LOGGER.info("dispatchNotication" + dispatchNotication);}if (!dispatchNotication.isEmpty()) {for (Entry<String, DispatchNotificationModel> dn : dispatchNotication.entrySet()) {DispatchNotificationModel dispatchNotificationModel = dn.getValue();//Send message only if shipping date is within T+1 of upload dateif (dispatchNotificationModel.getShippingDate().isAfter(LocalDate.now().minusDays(2))) {Provider pr = providerRepository.selectById(dispatchNotificationModel.getProviderId());String title = "Order Shipped";com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectById(dn.getValue().getFofoId());Set<String> invoiceNumber = new HashSet<>();invoiceNumber.addAll(dn.getValue().getInvoiceNumber());String message = String.format("Dear Partner, your items with the invoice number " + String.join(",", invoiceNumber) + " worth Rs." + dn.getValue().getTotalAmount() + " and qty " + dn.getValue().getTotalQty() + " has been shipped through " + pr.getName() + " via your track id " + dn.getKey() + " and is expected to be delivered by " + dn.getValue().getDate().format(DateTimeFormatter.ofPattern("dd-MM-yyyy")) + ".");SendNotificationModel sendNotificationModel = new SendNotificationModel();sendNotificationModel.setCampaignName("Order Shipped");sendNotificationModel.setTitle(title);sendNotificationModel.setMessage(message);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(dn.getValue().getFofoId());sendNotificationModel.setUserIds(Arrays.asList(userId));notificationService.sendNotification(sendNotificationModel);}}}}model.addAttribute("response1", mvcResponseSender.createResponseString(true));return "response";}private BilledOrderListModel createBilleOrder(CSVRecord record) {BilledOrderListModel bol = new BilledOrderListModel();bol.setInvoiceNumber(record.get(0));bol.setLogisticsProviderName(record.get(1));bol.setAirwayBillNumber(record.get(2));bol.setWeight(Double.valueOf(record.get(3)));bol.setShippingDate(LocalDateTime.parse(record.get(4), FormattingUtils.dateTimeFormatter));// bol.setShippingDate(String.valueOf(LocalDateTime.parse(record.get(4), FormattingUtils.yyMMDDTimeFormatter)));//rkb//bol.setShipping_Date(record.get(formattingUtils.formatDateTime(ofpat)));//bol.setShipping_Date(record.get(FormattingUtils.formatDateTime(yyyy-MM-dd HH:mm));// bol.setDate(record.get(4));//bol.setDate(DateTimeFormatter);// bol.simpleDateFormat(dateTimeFormat);return bol;}@RequestMapping(value = "/provider", method = RequestMethod.GET)public String provider(Model model, @RequestParam boolean status) throws Exception {List<Provider> providers = providerRepository.selectAllByStatus(status);List<Integer> providerIds = providers.stream().map(x -> x.getId()).collect(Collectors.toList());Map<Integer, ProviderDetails> providerDetails = providerDetailsRepository.selectByProviderIds(providerIds, DeliveryType.PREPAID, true).stream().collect(Collectors.toMap(x -> x.getProviderId(), x -> x));model.addAttribute("providers", providers);model.addAttribute("providerDetails", providerDetails);model.addAttribute("selectedStatus", status);model.addAttribute("deliveryTypes", DeliveryType.values());return "provider";}@PutMapping(value = "/provider-status-update")public String providerStatusUpdate(@RequestParam int id, @RequestParam boolean status, Model model) throws Exception {Provider providers = providerRepository.selectById(id);providers.setActive(status);model.addAttribute("response1", mvcResponseSender.createResponseString(true));return "response";}@RequestMapping(value = "/createProvider", method = RequestMethod.POST)public String createProvider(HttpServletRequest request, @RequestBody ProviderDetailModel providerDetailModel, Model model) throws Exception {Provider provider = new Provider();provider.setName(providerDetailModel.getName());provider.setActive(providerDetailModel.isProvideractive());provider.setBundleWeightLimit(0);provider.setGroupShipmentAllowed(true);provider.setPickupType(PickUpType.COURIER);provider.setMaxCODLimit(0);providerRepository.persist(provider);ProviderDetails pd = new ProviderDetails();pd.setAccountNo(providerDetailModel.getAccountNo());pd.setEmail(providerDetailModel.getEmail());pd.setPhone(providerDetailModel.getMobile());pd.setProviderId(provider.getId());pd.setActive(true);pd.setType(DeliveryType.PREPAID);providerDetailsRepository.persist(pd);model.addAttribute("response1", mvcResponseSender.createResponseString(true));return "response";}@RequestMapping(value = "/providerTat", method = RequestMethod.GET)public String providerTat(HttpServletRequest request, Model model) throws Exception {List<Provider> providers = providerRepository.selectAll();model.addAttribute("providers", providers);return "provider-tat";}@RequestMapping(value = "/getProviderTat", method = RequestMethod.GET)public String getProviderTat(HttpServletRequest request, @RequestParam int providerId, Model model) throws Exception {List<ProviderTat> providerTat = providerTatRepository.selectByProviderId(providerId);Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;providerTat = providerTat.stream().filter(x -> warehouseMap.containsKey(x.getWarehouseLocation())).collect(Collectors.toList());Map<Integer, Provider> providerIdMap = new HashMap<>();Provider provider = providerRepository.selectById(providerId);providerIdMap.put(provider.getId(), provider);LOGGER.info("providerTat" + providerTat);model.addAttribute("providerTat", providerTat);model.addAttribute("warehouseMap", warehouseMap);model.addAttribute("providerIdMap", providerIdMap);return "provider-tat-detail";}@RequestMapping(value = "/providerTatFileUploader", method = RequestMethod.POST)public String providerTatFileUploader(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 = FileUtil.readFile(file);List<ProviderTatModel> providerTatList = new ArrayList<>();for (CSVRecord record : records) {ProviderTatModel sgr = createProviderTat(record);providerTatList.add(sgr);}if (!providerTatList.isEmpty()) {for (ProviderTatModel pt : providerTatList) {Provider provider = providerRepository.selectByName(pt.getProviderName());if (provider == null) {throw new ProfitMandiBusinessException("Uploaded File", "", "Provider is not Available");}Map<String, Integer> warehouseMap = ProfitMandiConstants.WAREHOUSE_NAME_MAP;ProviderTat providerTat = providerTatRepository.selectByProviderId(provider.getId(), warehouseMap.get(pt.getWarehouseName()), pt.getPincode());LOGGER.info("providerTat" + providerTat);if (providerTat == null) {LOGGER.info("providerTat" + providerTat);providerTat = new ProviderTat();providerTat.setDestinationPin(pt.getPincode());providerTat.setProviderId(provider.getId());providerTat.setWarehouseLocation(warehouseMap.get(pt.getWarehouseName()));providerTat.setDeliveryTime(pt.getTat());providerTatRepository.persist(providerTat);} else {LOGGER.info("providerTat else" + providerTat);providerTat.setDeliveryTime(pt.getTat());}}}model.addAttribute("response1", mvcResponseSender.createResponseString(true));return "response";}private ProviderTatModel createProviderTat(CSVRecord record) {ProviderTatModel ptm = new ProviderTatModel();ptm.setProviderName(record.get(0));ptm.setWarehouseName(record.get(1));ptm.setPincode(record.get(2));ptm.setTat(Integer.parseInt(record.get(3)));return ptm;}@RequestMapping(value = "/publicProviderHolidays", method = RequestMethod.GET)public String publicProviderHolidays(HttpServletRequest request, Model model) throws Exception {List<PublicHolidays> publicHolidays = publicHolidaysRepository.selectAllByDate(LocalDate.of(LocalDate.now().getYear(), 1, 1));model.addAttribute("publicHolidays", publicHolidays);return "public-provider-holiday";}@RequestMapping(value = "/createPublicHoliday", method = RequestMethod.POST)public String createPublicHoliday(HttpServletRequest request, @RequestParam LocalDate date, @RequestParam String occassion, Model model) throws Exception {PublicHolidays ph = new PublicHolidays();ph.setDate(date);ph.setHolidayDate(LocalDate.now().atStartOfDay());ph.setOccasion(occassion);publicHolidaysRepository.persist(ph);model.addAttribute("response1", mvcResponseSender.createResponseString(true));return "response";}@RequestMapping(value = "/downloadUploadShippingTemplate", method = RequestMethod.GET)public ResponseEntity<?> downloadUploadShippingTemplate(HttpServletRequest request, @RequestParam int warehouseId) throws Exception {List<List<?>> rows = new ArrayList<>();List<Order> orders = orderRepository.selectAllByWarehouseAndStatus(warehouseId, OrderStatus.BILLED);if (orders.isEmpty()) {throw new ProfitMandiBusinessException("Template File", "", "No order has been billed");}Set<String> invoiceNumbers = orders.stream().map(x -> x.getInvoiceNumber()).collect(Collectors.toSet());for (String invoiceNumber : invoiceNumbers) {rows.add(Arrays.asList(invoiceNumber));}//rkborg.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil.getCSVByteStream(Arrays.asList("Invoice Number", "Provider", "AWB", "Weight(Kg)", "Shipping Date(dd-MM-yyyy HH:mm:ss)"), rows);final HttpHeaders headers = new HttpHeaders();headers.set("Content-Type", "text/csv");headers.set("Content-disposition", "inline; filename=upload-shipping-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);}private Map<Integer, String> getWarehouses(Set<CustomRetailer> positionRetailers) {Map<Integer, String> warehouses = new HashMap<>();positionRetailers.stream().forEach(x -> {if (x.getWarehouseId() != 0) {warehouses.put(x.getWarehouseId(), ProfitMandiConstants.WAREHOUSE_MAP.get(x.getWarehouseId()));}});return warehouses;}@RequestMapping(value = "/downloadProviderTatTemplate", method = RequestMethod.GET)public ResponseEntity<?> downloadProviderTatTemplate(HttpServletRequest request) throws Exception {List<List<?>> rows = new ArrayList<>();Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;for (Entry<Integer, String> warehouse : warehouseMap.entrySet()) {rows.add(Arrays.asList("Delhivery", warehouse.getValue(), "110018", "-"));}org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil.getCSVByteStream(Arrays.asList("Provider Name", "Source Warehouse", "Destination Pincode", "TAT in days"), rows);final HttpHeaders headers = new HttpHeaders();headers.set("Content-Type", "text/csv");headers.set("Content-disposition", "inline; filename=provider-tat-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 = "/downloadDelayDayTemplate", method = RequestMethod.GET)public ResponseEntity<?> downloadDelayDayTemplate(HttpServletRequest request) throws Exception {List<List<?>> rows = new ArrayList<>();rows.add(Arrays.asList("-", "-", "Vehicle Delay"));rows.add(Arrays.asList("-", "-", "Vehicle Breakdown"));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 = FileUtil.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() != (OrderStatus.SHIPPED_FROM_WH)).collect(Collectors.toList());if (!filteredorders.isEmpty()) {throw new ProfitMandiBusinessException("Upload File", String.join(",", filteredorders.stream().map(x -> x.getAirwayBillNumber()).collect(Collectors.toList())), "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()));String title = "Order Update";String message = 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 due to " + ddm.getReason() + " and will be delivered by " + deliveryDate.format(DateTimeFormatter.ofPattern("dd-MM-yyyy"))) + ".";com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectById(order.getRetailerId());Address address = addressRepository.selectById(user.getAddressId());SendNotificationModel sendNotificationModel = new SendNotificationModel();sendNotificationModel.setCampaignName("Order Update");sendNotificationModel.setTitle(title);sendNotificationModel.setMessage(message);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);//TODO-Whatsapp//notificationService.sendWhatsappMessage(message, title, address.getPhoneNumber());} else {throw new ProfitMandiBusinessException("Upload File", "", "No order available for " + ddm.getAirwayBIllNumber() + " airwaybill Number");}}}model.addAttribute("response1", 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 = FileUtil.readFile(file);List<MarkDeliveredModel> deliveredList = new ArrayList<>();for (CSVRecord record : records) {MarkDeliveredModel ddm = createMarkDeliveredModel(record);deliveredList.add(ddm);}Map<Pair<String, String>, MarkDeliveredModel> markDeliveredModelMap = deliveredList.stream().collect(Collectors.toMap(x -> Pair.of(x.getAirwayBillNumber(), x.getDeliveredBy()), x -> x));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()) {for (Order filteredOrder : filteredOrders) {int logisticsProviderId = filteredOrder.getLogisticsProviderId();Provider provider = providerRepository.selectById(logisticsProviderId);if (markDeliveredModelMap.containsKey(Pair.of(filteredOrder.getAirwayBillNumber(), provider.getName()))) {throw new ProfitMandiBusinessException("Upload File", String.join(",", filteredOrders.stream().map(x -> x.getAirwayBillNumber()).collect(Collectors.toList())), "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 != null) {for (Order order : orders) {order.setDeliveryTimestamp(dl.getDeliveredOn());order.setStatus(OrderStatus.DELIVERY_SUCCESS);order.setStatusDescription("Order Delivered");}//Send notification only if the case is of T + 2 daysif (orders.get(0).getDeliveryTimestamp().toLocalDate().isBefore(LocalDate.now().plusDays(2))) {String title = "Order Delivered";SendNotificationModel sendNotificationModel = new SendNotificationModel();sendNotificationModel.setCampaignName("Order Delivered");sendNotificationModel.setTitle(title);sendNotificationModel.setMessage(String.format("Dear Partner, your SmartDukaan shipment " + dl.getAirwayBillNumber() + " has been delivered on" + dl.getDeliveredOn().format(DateTimeFormatter.ofPattern("dd-MM-yyyy")) + " 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);}//String message = String.format("Dear partner, Your SmartDukaan Order " + dl.getAirwayBillNumber() + " has been delivered to you in a safe sealed bag.");//notificationService.sendWhatsappMessage(message, title, address.getPhoneNumber());} else {throw new ProfitMandiBusinessException("Upload File", "", "No order available for " + dl.getAirwayBillNumber() + " airwaybill Number");}}}model.addAttribute("response1", mvcResponseSender.createResponseString(true));return "response";}private MarkDeliveredModel createMarkDeliveredModel(CSVRecord record) {MarkDeliveredModel mdm = new MarkDeliveredModel();mdm.setAirwayBillNumber(record.get(0));DateTimeFormatter formatter = DateTimeFormatter.ofPattern("dd-MM-yyyy");LOGGER.info(record.get(1));LocalDate dateTime = LocalDate.parse(record.get(1), formatter);mdm.setDeliveredOn(dateTime.atStartOfDay());mdm.setDeliveredBy(record.get(2));return mdm;}@RequestMapping(value = "/delayBillingTemplate", method = RequestMethod.GET)public ResponseEntity<?> delayBillingTemplate(HttpServletRequest request) throws Exception {List<List<?>> rows = new ArrayList<>();rows.add(Arrays.asList("-", "Shipment on hold, low invoice value, please ensure order value of minimum Rs. 40,000."));rows.add(Arrays.asList("-", "Order Billed,Shipping will be done tomorrow."));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 = FileUtil.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 number " + delayBilling.getInvoiceNumber() + " has been delayed due to" + 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("response1", mvcResponseSender.createResponseString(true));return "response";}@RequestMapping(value = "/getAwbNumber", method = RequestMethod.GET)public String getAwbNumber(HttpServletRequest request, Model model) throws Exception {List<Order> orders = orderRepository.selectByInvoiceNumber("NSLCK7931");// blueDartService.getAirwayBillNo(orders.2);model.addAttribute("response1", mvcResponseSender.createResponseString(true));return "response";}}