Subversion Repositories SmartDukaan

package com.spice.profitmandi.service;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.model.ProfitMandiConstants;

import com.spice.profitmandi.dao.entity.logistics.*;

import com.spice.profitmandi.dao.entity.transaction.Order;

import com.spice.profitmandi.dao.entity.transaction.Transaction;

import com.spice.profitmandi.dao.entity.transaction.TransactionShipmentSequence;

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

import com.spice.profitmandi.dao.repository.logistics.*;

import com.spice.profitmandi.dao.repository.transaction.TransactionRepository;

import com.spice.profitmandi.dao.repository.transaction.TransactionShipmentSequenceRepository;

import com.spice.profitmandi.service.integrations.gstpro.api.model.E_InvoiceCommon;

import in.shop2020.model.v1.order.OrderStatus;

import org.apache.commons.lang.StringUtils;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import java.time.DayOfWeek;

import java.time.LocalDate;

import java.time.LocalDateTime;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import java.util.stream.Collectors;

@Component

public class LogisticsServiceImpl implements LogisticsService {

    @Autowired

    private PublicHolidaysRepository publicHolidaysRepository;

    @Autowired

    private ProviderTatRepository providerTatRepository;

    @Autowired

    ProviderRepository providerRepository;

    private static final Logger LOGGER = LogManager.getLogger(LogisticsServiceImpl.class);

    @Override

    public LocalDate calculateDeliveryTimeline(LocalDate date, ProviderTat providerTat, int delayDays) {

        int businessDays = 0;

        int deliveryTat = 3;

        if (providerTat != null) {

            deliveryTat = providerTat.getDeliveryTime();

        }

        deliveryTat = deliveryTat + delayDays;

        LocalDate currDate = date.plusDays(1);

        List<LocalDate> ph = publicHolidaysRepository.selectAllByDate(currDate).stream().map(x -> x.getDate())

                .collect(Collectors.toList());

        while (businessDays < deliveryTat) {

            if (ph.contains(currDate) || currDate.getDayOfWeek().equals(DayOfWeek.SUNDAY)) {

            } else {

                businessDays++;

            }

            currDate = currDate.plusDays(1);

        }

        return currDate;

    }

    @Override

    public Map<String, DispatchNotificationModel> markedOrderShippedDetail(List<Order> orders, Provider provider,

                                                                           Map<String, DispatchNotificationModel> dispatchNotication, String airwaybillNo, LocalDateTime shippingTimestamp)

            throws ProfitMandiBusinessException {

        for (Order order : orders) {

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

                if (order.getBillingTimestamp().isAfter(shippingTimestamp)) {

                    throw new ProfitMandiBusinessException("Uploaded File", "",

                            "Invoice Number " + order.getInvoiceNumber() + " cannot be shipped before billing date");

                }

                if (StringUtils.isEmpty(airwaybillNo)) {

                    throw new ProfitMandiBusinessException("Uploaded File", "",

                            "Invoice Number " + order.getInvoiceNumber() + " airwaybill_no is empty");

                }

                if (airwaybillNo.equals("Error")) {

                    break;

                }

                order.setLogisticsProviderId(provider.getId());

                order.setAirwayBillNumber(airwaybillNo);

                order.setStatus(OrderStatus.SHIPPED_FROM_WH);

                order.setStatusDescription("Order shipped from warehouses");

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

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

                order.setShippingTimestamp(shippingTimestamp);

                LocalDate deliveryDate = this.calculateDeliveryTimeline(LocalDate.now(), pt, 0);

                order.setExpectedDeliveryTime(deliveryDate.atStartOfDay());

                if (dispatchNotication.get(airwaybillNo) != null) {

                    DispatchNotificationModel dnm = dispatchNotication.get(airwaybillNo);

                    List<String> invoiceNumbers = dnm.getInvoiceNumber();

                    invoiceNumbers.add(order.getInvoiceNumber());

                    dnm.setInvoiceNumber(invoiceNumbers);

                    Float totalAmount = dnm.getTotalAmount();

                    dnm.setTotalAmount(totalAmount + order.getTotalAmount());

                    int totalQty = dnm.getTotalQty();

                    dnm.setTotalQty(totalQty + order.getLineItem().getQuantity());

                    dispatchNotication.put(airwaybillNo, dnm);

                } else {

                    DispatchNotificationModel dnm = new DispatchNotificationModel();

                    List<String> invoiceNumber = new ArrayList<>();

                    invoiceNumber.add(order.getInvoiceNumber());

                    dnm.setInvoiceNumber(invoiceNumber);

                    dnm.setTotalAmount(order.getTotalAmount());

                    dnm.setTotalQty(order.getLineItem().getQuantity());

                    dnm.setFofoId(order.getRetailerId());

                    dnm.setProviderId(order.getLogisticsProviderId());

                    dnm.setDate(deliveryDate);

                    dnm.setShippingDate(shippingTimestamp.toLocalDate());

                    dispatchNotication.put(airwaybillNo, dnm);

                }

            }

        }

        return dispatchNotication;

    }

    @Autowired

    WarehouseProviderRepository warehouseProviderRepository;

    @Autowired

    WarehouseRiderRepository warehouseRiderRepository;

    @Autowired

    TransactionShipmentSequenceRepository transactionShipmentSequenceRepository;

    @Autowired

    TransactionRepository transactionRepository;

    @Autowired

    WarehousePartnerDistanceMappingRepository warehousePartnerDistanceMappingRepository;

    @Override

    public E_InvoiceCommon.ReqPlGenIRN.EwbDetails getEwbDetails(Order order) throws ProfitMandiBusinessException {

        E_InvoiceCommon.ReqPlGenIRN.EwbDetails ewbDetails = new E_InvoiceCommon.ReqPlGenIRN.EwbDetails();

        //ewbDetails.Distance = String.valueOf(200);

        //1 is road, 2 is rail, 3 is air, 4 is ship

        if (order.getLogisticsProviderId() == ProfitMandiConstants.LOGISTICS_PROVIDER_SELF_PICKUP

                || order.getLogisticsProviderId() == ProfitMandiConstants.LOGISTICS_PROVIDER_RUNNER) {

            TransactionShipmentSequence transactionShipmentSequence = transactionShipmentSequenceRepository.selectByTransactionShipmentSequence(order.getLogisticsTransactionId());

            if (transactionShipmentSequence != null) {

                ewbDetails.VehNo = transactionShipmentSequence.getVehicleNumber();

                ewbDetails.VehType = "R";

                ewbDetails.TransMode = "1";

                ewbDetails.TransDocDt = com.spice.profitmandi.common.util.StringUtils.toString(order.getBillingTimestamp().toLocalDate());

                ewbDetails.TransDocNo = order.getAirwayBillNumber();

            } else {

                LOGGER.warn("No shipment sequence found for logistics transaction: {}, order will get EWB Part A only", order.getLogisticsTransactionId());

            }

        } else {

            WarehouseProvider warehouseProvider = warehouseProviderRepository.selectByProviderWarehouse(order.getLogisticsProviderId(), order.getWarehouseId());

            Provider provider = providerRepository.selectById(order.getLogisticsProviderId());

            if (warehouseProvider != null && provider != null) {

                ewbDetails.TransId = warehouseProvider.getGstin();

                ewbDetails.TransName = provider.getName();

            } else {

                LOGGER.warn("No provider details for logistics provider: {}, warehouse: {}", order.getLogisticsProviderId(), order.getWarehouseId());

            }

        }

        String distance = "0";

        WarehousePartnerDistanceMapping distanceMapping = warehousePartnerDistanceMappingRepository.selectByWarehouseIdAndFofoId(order.getWarehouseId(), order.getRetailerId());

        if (distanceMapping != null) {

            distance = distanceMapping.getDistance();

        }

        LOGGER.info("distance - " + distance);

        ewbDetails.Distance = distance;

        return ewbDetails;

    }

}