Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.time.LocalDateTime;
import java.time.temporal.ChronoUnit;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
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.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Controller;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PutMapping;
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.spice.profitmandi.common.enumuration.SearchType;
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
import com.spice.profitmandi.common.model.CartFofo;
import com.spice.profitmandi.common.model.CreateOrderRequest;
import com.spice.profitmandi.common.model.CreditNotePdfModel;
import com.spice.profitmandi.common.model.CustomCustomer;
import com.spice.profitmandi.common.model.FoiBadReturnRequest;
import com.spice.profitmandi.common.model.PaymentOptionTransactionModel;
import com.spice.profitmandi.common.model.PdfModel;
import com.spice.profitmandi.common.model.PriceModel;
import com.spice.profitmandi.common.model.ProfitMandiConstants;
import com.spice.profitmandi.common.util.PdfUtils;
import com.spice.profitmandi.common.util.StringUtils;
import com.spice.profitmandi.common.web.util.ResponseSender;
import com.spice.profitmandi.dao.entity.catalog.Item;
import com.spice.profitmandi.dao.entity.dtr.InsurancePolicy;
import com.spice.profitmandi.dao.entity.dtr.InsuranceProvider;
import com.spice.profitmandi.dao.entity.dtr.PaymentOptionTransaction;
import com.spice.profitmandi.dao.entity.fofo.Customer;
import com.spice.profitmandi.dao.entity.fofo.CustomerAddress;
import com.spice.profitmandi.dao.entity.fofo.CustomerCreditNote;
import com.spice.profitmandi.dao.entity.fofo.CustomerReturnItem;
import com.spice.profitmandi.dao.entity.fofo.FofoLineItem;
import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
import com.spice.profitmandi.dao.entity.fofo.PaymentOption;
import com.spice.profitmandi.dao.entity.user.Address;
import com.spice.profitmandi.dao.enumuration.dtr.PaymentOptionReferenceType;
import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
import com.spice.profitmandi.dao.repository.dtr.InsurancePolicyRepository;
import com.spice.profitmandi.dao.repository.dtr.InsuranceProviderRepository;
import com.spice.profitmandi.dao.repository.dtr.PaymentOptionTransactionRepository;
import com.spice.profitmandi.dao.repository.dtr.RetailerRegisteredAddressRepository;
import com.spice.profitmandi.dao.repository.fofo.CustomerAddressRepository;
import com.spice.profitmandi.dao.repository.fofo.CustomerRepository;
import com.spice.profitmandi.dao.repository.fofo.CustomerReturnItemRepository;
import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
import com.spice.profitmandi.dao.repository.fofo.FofoPartnerPaymentOptionRepository;
import com.spice.profitmandi.dao.repository.fofo.PaymentOptionRepository;
import com.spice.profitmandi.dao.repository.inventory.StateRepository;
import com.spice.profitmandi.dao.repository.user.AddressRepository;
import com.spice.profitmandi.service.authentication.RoleManager;
import com.spice.profitmandi.service.integrations.zest.InsuranceService;
import com.spice.profitmandi.service.integrations.zest.MobileInsurancePlan;
import com.spice.profitmandi.service.order.OrderService;
import com.spice.profitmandi.service.pricing.PricingService;
import com.spice.profitmandi.web.model.LoginDetails;
import com.spice.profitmandi.web.util.CookiesProcessor;
import com.spice.profitmandi.web.util.MVCResponseSender;

@Controller
@Transactional(rollbackFor = Throwable.class)
public class OrderController {

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

        @Autowired
        private CustomerRepository customerRepository;

        private boolean accessoriesDeals = true;

        @Autowired
        private RoleManager roleManager;

        @Autowired
        private CustomerReturnItemRepository customerReturnItemRepository;

        @Autowired
        private FofoOrderItemRepository fofoOrderItemRepository;

        @Autowired
        private PaymentOptionRepository paymentOptionRepository;

        @Autowired
        private StateRepository stateRepository;

        @Autowired
        private ItemRepository itemRepository;

        @Autowired
        private MVCResponseSender mvcResponseSender;

        @Autowired
        private InsuranceService insuranceService;

        @Autowired
        private FofoOrderRepository fofoOrderRepository;

        @Autowired
        private CustomerAddressRepository customerAddressRepository;

        @Autowired
        private InsurancePolicyRepository insurancePolicyRepository;

        @Autowired
        private InsuranceProviderRepository insuranceProviderRepository;

        @Autowired
        private CookiesProcessor cookiesProcessor;

        @Autowired
        private PricingService pricingService;

        @Autowired
        private OrderService orderService;

        @Autowired
        private RetailerRegisteredAddressRepository retailerRegisteredAddressRepository;

        @Autowired
        private AddressRepository addressRepository;

        @Autowired
        private PaymentOptionTransactionRepository fofoOrderPaymentOptionRepository;

        @Autowired
        private FofoPartnerPaymentOptionRepository fofoPartnerPaymentOptionRepository;

        @Autowired
        private ResponseSender<?> responseSender;

        @RequestMapping(value = "/order")
        public String orderIndex(HttpServletRequest request, @RequestParam(name = "cartData") String cartData, Model model)
                        throws ProfitMandiBusinessException {
                LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
                ;

                int addressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(loginDetails.getFofoId());
                Address address = addressRepository.selectById(addressId);

                List<CartFofo> cartItems = orderService.cartCheckout(cartData);
                Set<Integer> itemIds = new HashSet<>();
                for (CartFofo cartFofo : cartItems) {
                        itemIds.add(cartFofo.getItemId());
                }
                Map<Integer, PriceModel> mopPriceMap = pricingService.getPurchasePriceMopPriceNotFound(itemIds,
                                loginDetails.getFofoId());
                List<Integer> paymentOptionIds = fofoPartnerPaymentOptionRepository
                                .selectPaymentOptionIdsByFofoId(loginDetails.getFofoId());
                List<PaymentOption> paymentOptions = paymentOptionRepository.selectByIds(new HashSet<>(paymentOptionIds));
                LOGGER.info("mopPriceMap {}", mopPriceMap);
                model.addAttribute("stateNames",
                                stateRepository.selectAll().stream().map(x -> x.getName()).collect(Collectors.toList()));
                model.addAttribute("retailerStateName", address.getState());
                model.addAttribute("cartItems", cartItems);
                model.addAttribute("mopPriceMap", mopPriceMap);
                model.addAttribute("paymentOptions", paymentOptions);
                model.addAttribute("accessoriesDeals", accessoriesDeals);
                return "order-index";
        }

        @RequestMapping(value = "/checkplans", method = RequestMethod.GET)
        public String getInsurancePrices(HttpServletRequest request, @RequestParam float price, Model model,
                        @RequestParam int itemId) throws ProfitMandiBusinessException {
                LOGGER.info("Request received at url : {}", request.getRequestURI());

                try {
                        String response = mvcResponseSender.createResponseString(this.getPlans(price, itemId));
                        model.addAttribute("response", response);
                } catch (Exception e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                        throw new ProfitMandiBusinessException("Plans", "Plans API", "Error formatting insurance plans");
                }

                return "response";
        }

        @RequestMapping(value = "/get-order", method = RequestMethod.GET)
        public String getOrder(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.ORDER_ID) int orderId,
                        Model model) throws ProfitMandiBusinessException {
                LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
                FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndOrderId(fofoDetails.getFofoId(), orderId);
                List<FofoOrderItem> fofoLineItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
                CustomerAddress customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());
                Customer customer = customerRepository.selectById(fofoOrder.getCustomerId());
                customerAddress.setPhoneNumber(customer.getMobileNumber());
                List<PaymentOptionTransaction> paymentOptionTransactions = fofoOrderPaymentOptionRepository
                                .selectByReferenceIdAndType(fofoOrder.getId(), PaymentOptionReferenceType.ORDER);
                Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = this
                                .paymentOptionIdPaymentOptionMap(paymentOptionTransactions);
                List<InsurancePolicy> insurancePolicies = insurancePolicyRepository
                                .selectByRetailerIdInvoiceNumber(fofoOrder.getFofoId(), fofoOrder.getInvoiceNumber());
                this.addInsuranceProvider(insurancePolicies);

                model.addAttribute("fofoOrder", fofoOrder);
                model.addAttribute("fofoLineItems", fofoLineItems);
                model.addAttribute("customerBillingAddress", orderService.getBillingAddress(customerAddress));
                model.addAttribute("customerBillingAddressObj", customerAddress);
                model.addAttribute("paymentOptionTransactions", paymentOptionTransactions);
                model.addAttribute("paymentOptionIdPaymentOptionMap", paymentOptionIdPaymentOptionMap);
                model.addAttribute("insurancePolicies", insurancePolicies);
                return "order-details";
        }

        private Map<Integer, InsuranceProvider> toInsuranceProviderIdInsuranceProvider(
                        List<InsuranceProvider> insuranceProviders) {
                Map<Integer, InsuranceProvider> insuranceProviderIdInsuranceProviderMap = new HashMap<>();
                for (InsuranceProvider insuranceProvider : insuranceProviders) {
                        insuranceProviderIdInsuranceProviderMap.put(insuranceProvider.getId(), insuranceProvider);
                }
                return insuranceProviderIdInsuranceProviderMap;
        }

        private void addInsuranceProvider(List<InsurancePolicy> insurancePolicies) {
                if (insurancePolicies.isEmpty()) {
                        return;
                }
                Set<Integer> insuranceProviderIds = new HashSet<>();
                for (InsurancePolicy insurancePolicy : insurancePolicies) {
                        insuranceProviderIds.add(insurancePolicy.getProviderId());
                }
                LOGGER.info("insuranceProviderIds {}", insuranceProviderIds);
                List<InsuranceProvider> insuranceProviders = insuranceProviderRepository.selectByIds(insuranceProviderIds);
                Map<Integer, InsuranceProvider> insuranceProviderIdInsuranceProviderMap = this
                                .toInsuranceProviderIdInsuranceProvider(insuranceProviders);
                for (InsurancePolicy insurancePolicy : insurancePolicies) {
                        insurancePolicy
                                        .setInsuranceProvider(insuranceProviderIdInsuranceProviderMap.get(insurancePolicy.getProviderId()));
                }
        }

        @RequestMapping(value = "/saleDetails", method = RequestMethod.GET)
        public String getSaleDetails(HttpServletRequest request,
                        @RequestParam(name = ProfitMandiConstants.ORDER_ID) int orderId, Model model) throws Exception {
                LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
                boolean isAdmin = roleManager.isAdmin(fofoDetails.getRoleIds());
                FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndOrderId(fofoDetails.getFofoId(), orderId);
                List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
                CustomerAddress customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());
                List<PaymentOptionTransaction> paymentOptionTransactions = fofoOrderPaymentOptionRepository
                                .selectByReferenceIdAndType(fofoOrder.getId(), PaymentOptionReferenceType.ORDER);

                // Added Migration info as we lost it.
                if (paymentOptionTransactions == null || paymentOptionTransactions.size() == 0) {
                        PaymentOptionTransaction pot = new PaymentOptionTransaction();
                        pot.setAmount(fofoOrder.getTotalAmount());
                        pot.setCreateTimestamp(fofoOrder.getCreateTimestamp());
                        // Mark it paid through cash
                        pot.setPaymentOptionId(1);
                        pot.setReferenceType(PaymentOptionReferenceType.ORDER);
                        fofoOrderPaymentOptionRepository.persist(pot);
                        paymentOptionTransactions.add(pot);
                        LOGGER.info("Added to get invoice");
                }
                Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = this
                                .paymentOptionIdPaymentOptionMap(paymentOptionTransactions);
                List<InsurancePolicy> insurancePolicies = insurancePolicyRepository
                                .selectByRetailerIdInvoiceNumber(fofoOrder.getFofoId(), fofoOrder.getInvoiceNumber());
                this.addInsuranceProvider(insurancePolicies);
                Map<Integer, Item> itemsMap = fofoOrderItems.stream().collect(Collectors.toMap(x -> x.getItemId(), x -> {
                        try {
                                return itemRepository.selectById(x.getItemId());
                        } catch (ProfitMandiBusinessException e) {
                                // TODO Auto-generated catch block
                                return null;
                        }
                }));
                Map<Integer, Set<FofoLineItem>> fofoOrderItemIdLineItemMap = fofoOrderItems.stream()
                                .collect(Collectors.toMap(FofoOrderItem::getId, FofoOrderItem::getFofoLineItems));

                Map<Integer, List<CustomerReturnItem>> foiIdCustomerReturnInventoryItemsMap = fofoOrderItems.stream()
                                .collect(Collectors.toMap(foi -> foi.getId(),
                                                foi -> customerReturnItemRepository.selectAllByOrderItemId(foi.getId())));

                Map<Integer, Integer> inventoryItemBilledQtyMap = new HashMap<>();

                for (FofoOrderItem foi : fofoOrderItems) {
                        for (FofoLineItem fli : foi.getFofoLineItems()) {
                                inventoryItemBilledQtyMap.put(fli.getInventoryItemId(), fli.getQuantity());
                        }
                        List<CustomerReturnItem> customerReturnItems = customerReturnItemRepository
                                        .selectAllByOrderItemId(foi.getId());
                        this.markDoa(fofoOrder, foi, isAdmin);
                        for (CustomerReturnItem customerReturnItem : customerReturnItems) {
                                inventoryItemBilledQtyMap.put(customerReturnItem.getInventoryItemId(),
                                                inventoryItemBilledQtyMap.get(customerReturnItem.getInventoryItemId()) - 1);
                        }
                }

                LOGGER.info("fofoOrderItemIdLineItemMap {}", fofoOrderItemIdLineItemMap);
                model.addAttribute("fofoOrder", fofoOrder);
                model.addAttribute("itemsMap", itemsMap);
                model.addAttribute("fofoOrderItemIdLineItemsMap", StringUtils.toString(fofoOrderItemIdLineItemMap));
                model.addAttribute("foiIdCustomerReturnInventoryItemsMap",
                                StringUtils.toString(foiIdCustomerReturnInventoryItemsMap));
                model.addAttribute("fofoOrderItems", fofoOrderItems);
                model.addAttribute("inventoryItemBilledQtyMap", StringUtils.toString(inventoryItemBilledQtyMap));
                model.addAttribute("customerBillingAddress", orderService.getBillingAddress(customerAddress));
                model.addAttribute("customerBillingAddressObj", customerAddress);
                model.addAttribute("paymentOptionTransactions", paymentOptionTransactions);
                model.addAttribute("paymentOptionIdPaymentOptionMap", paymentOptionIdPaymentOptionMap);
                model.addAttribute("insurancePolicies", insurancePolicies);
                model.addAttribute("markDefective", this.markDefective(fofoOrder));
                return "sale-details";
        }

        private void markDoa(FofoOrder fofoOrder, FofoOrderItem foi, boolean isAdmin) {
                if (isAdmin) {
                        foi.setDoa(true);
                        return;
                }
                LocalDateTime buyDate = fofoOrder.getCreateTimestamp().truncatedTo(ChronoUnit.DAYS);
                LocalDateTime curDate = LocalDateTime.now().truncatedTo(ChronoUnit.DAYS);
                if (buyDate.isAfter(curDate.minusDays(45))) {
                        foi.setDoa(true);
                } else
                        foi.setDoa(
                                        foi.getBrand().equals("Nokia") && foi.getCost() < 4990 && buyDate.isAfter(curDate.minusYears(1)));
        }

        private boolean markDefective(FofoOrder fofoOrder) {
                return fofoOrder.getCreateTimestamp().truncatedTo(ChronoUnit.DAYS).plusDays(180)
                                .isAfter(LocalDateTime.now().truncatedTo(ChronoUnit.DAYS));

        }

        @RequestMapping(value = "/getSearchOrder")
        public String getSearchOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
                return "search-order";
        }

        @RequestMapping(value = "/customerDetails", method = RequestMethod.PUT)
        public String updateCustomerDetails(HttpServletRequest request, @RequestBody CustomCustomer customCustomer,
                        @RequestParam(name = ProfitMandiConstants.INVOICE_NUMBER) String invoiceNumber, Model model)
                        throws Exception {

                orderService.updateCustomerDetails(customCustomer, invoiceNumber);
                return this.getSearchOrderDetails(request, invoiceNumber, model);
        }

        @RequestMapping(value = "/searchOrderDetails", method = RequestMethod.GET)
        public String getSearchOrderDetails(HttpServletRequest request,
                        @RequestParam(name = ProfitMandiConstants.INVOICE_NUMBER) String invoiceNumber, Model model)
                        throws Exception {

                FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(invoiceNumber);
                List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
                Customer customer = customerRepository.selectById(fofoOrder.getCustomerId());
                CustomerAddress customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());
                List<Integer> fofoPartnerPaymentOptions = fofoPartnerPaymentOptionRepository
                                .selectPaymentOptionIdsByFofoId(fofoOrder.getFofoId());

                Map<Integer, Item> itemsMap = fofoOrderItems.stream().collect(Collectors.toMap(x -> x.getItemId(), x -> {
                        try {
                                return itemRepository.selectById(x.getItemId());
                        } catch (ProfitMandiBusinessException e) {
                                // TODO Auto-generated catch block
                                return null;
                        }
                }));
                LOGGER.info("fofoPartnerPaymentOptions" + fofoPartnerPaymentOptions);
                List<PaymentOptionTransaction> paymentOptionTransactions = fofoOrderPaymentOptionRepository
                                .selectByReferenceIdAndType(fofoOrder.getId(), PaymentOptionReferenceType.ORDER);
                LOGGER.info("paymentOptionTransactions" + paymentOptionTransactions);
                Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = this
                                .paymentOptionIdPaymentOptionMapUsingPaymentOptions(fofoPartnerPaymentOptions);
                Map<Integer, PaymentOptionTransaction> paymentOptionIdPaymentOptionTransactionMap = this
                                .paymentOptionIdPaymentOptionTransactionMap(paymentOptionTransactions);
                LOGGER.info("paymentOptionIdPaymentOptionTransactionMap" + paymentOptionIdPaymentOptionTransactionMap.keySet());
                List<InsurancePolicy> insurancePolicies = insurancePolicyRepository
                                .selectByRetailerIdInvoiceNumber(fofoOrder.getFofoId(), fofoOrder.getInvoiceNumber());
                this.addInsuranceProvider(insurancePolicies);
                model.addAttribute("fofoOrder", fofoOrder);
                for (FofoOrderItem fofoOrderItem : fofoOrderItems) {
                        fofoOrderItem.setDoa(true);
                }

                Map<Integer, Set<FofoLineItem>> fofoOrderItemIdLineItemMap = fofoOrderItems.stream()
                                .collect(Collectors.toMap(FofoOrderItem::getId, FofoOrderItem::getFofoLineItems));

                Map<Integer, List<CustomerReturnItem>> foiIdCustomerReturnInventoryItemsMap = fofoOrderItems.stream()
                                .collect(Collectors.toMap(foi -> foi.getId(),
                                                foi -> customerReturnItemRepository.selectAllByOrderItemId(foi.getId())));

                Map<Integer, Integer> inventoryItemBilledQtyMap = new HashMap<>();

                for (FofoOrderItem foi : fofoOrderItems) {
                        for (FofoLineItem fli : foi.getFofoLineItems()) {
                                inventoryItemBilledQtyMap.put(fli.getInventoryItemId(), fli.getQuantity());
                        }
                        List<CustomerReturnItem> customerReturnItems = customerReturnItemRepository
                                        .selectAllByOrderItemId(foi.getId());
                        for (CustomerReturnItem customerReturnItem : customerReturnItems) {
                                inventoryItemBilledQtyMap.put(customerReturnItem.getInventoryItemId(),
                                                inventoryItemBilledQtyMap.get(customerReturnItem.getInventoryItemId()) - 1);
                        }
                }
                model.addAttribute("foiIdCustomerReturnInventoryItemsMap",
                                StringUtils.toString(foiIdCustomerReturnInventoryItemsMap));
                model.addAttribute("fofoOrderItems", fofoOrderItems);
                model.addAttribute("inventoryItemBilledQtyMap", StringUtils.toString(inventoryItemBilledQtyMap));
                model.addAttribute("fofoOrderItemIdLineItemsMap", StringUtils.toString(fofoOrderItemIdLineItemMap));
                model.addAttribute("itemsMap", itemsMap);
                model.addAttribute("markDefective", true);
                model.addAttribute("customer", customer);
                model.addAttribute("customerAddress", customerAddress);
                model.addAttribute("paymentOptionTransactions", paymentOptionTransactions);
                model.addAttribute("paymentOptionIdPaymentOptionMap", paymentOptionIdPaymentOptionMap);
                model.addAttribute("paymentOptionIdPaymentOptionTransactionMap", paymentOptionIdPaymentOptionTransactionMap);
                model.addAttribute("insurancePolicies", insurancePolicies);
                model.addAttribute("fofoPartnerPaymentOptions", fofoPartnerPaymentOptions);
                model.addAttribute("totalNumberOfPaymentOptionId", fofoPartnerPaymentOptions.size());
                model.addAttribute("stateNames",
                                stateRepository.selectAll().stream().map(x -> x.getName()).collect(Collectors.toList()));
                return "search-order-details";
        }

        private Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap(
                        List<PaymentOptionTransaction> paymentOptionTransactions) {
                Set<Integer> paymentOptionIds = new HashSet<>();
                for (PaymentOptionTransaction paymentOptionTransaction : paymentOptionTransactions) {
                        paymentOptionIds.add(paymentOptionTransaction.getPaymentOptionId());
                }
                List<PaymentOption> paymentOptions = paymentOptionRepository.selectByIds(paymentOptionIds);
                Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = new HashMap<>();
                for (PaymentOption paymentOption : paymentOptions) {
                        paymentOptionIdPaymentOptionMap.put(paymentOption.getId(), paymentOption);
                }
                return paymentOptionIdPaymentOptionMap;
        }

        private Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMapUsingPaymentOptions(
                        List<Integer> fofoPartnerPaymentOptions) {
                List<PaymentOption> paymentOptions = paymentOptionRepository
                                .selectByIds(new HashSet<>(fofoPartnerPaymentOptions));
                Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = new HashMap<>();
                for (PaymentOption paymentOption : paymentOptions) {
                        paymentOptionIdPaymentOptionMap.put(paymentOption.getId(), paymentOption);
                }
                return paymentOptionIdPaymentOptionMap;
        }

        private Map<Integer, PaymentOptionTransaction> paymentOptionIdPaymentOptionTransactionMap(
                        List<PaymentOptionTransaction> paymentOptionTransactions) {
                Map<Integer, PaymentOptionTransaction> paymentOptionIdPaymentOptionTransactionMap = new HashMap<>();
                for (PaymentOptionTransaction paymentOptionTransaction : paymentOptionTransactions) {
                        paymentOptionIdPaymentOptionTransactionMap.put(paymentOptionTransaction.getPaymentOptionId(),
                                        paymentOptionTransaction);
                }
                return paymentOptionIdPaymentOptionTransactionMap;
        }

        @RequestMapping(value = "/create-order", method = RequestMethod.POST)
        public String createOrder(HttpServletRequest request, @RequestBody CreateOrderRequest createOrderRequest,
                        Model model) throws ProfitMandiBusinessException {
                LOGGER.info("request at uri {} body {}", request.getRequestURI(), createOrderRequest);
                LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);

                int fofoOrderId = orderService.createOrder(createOrderRequest, fofoDetails.getFofoId(), accessoriesDeals);
                LOGGER.info("Order has been created successfully...");
                return "redirect:/get-order/?orderId=" + fofoOrderId;
        }

        @RequestMapping(value = "/order/bad_return", method = RequestMethod.POST)
        public ResponseEntity<?> badReturn(HttpServletRequest request, @RequestBody FoiBadReturnRequest foiBadReturnRequest,
                        Model model) throws ProfitMandiBusinessException {
                LOGGER.info("request at uri {} body {}", request.getRequestURI(), foiBadReturnRequest);
                LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
                CustomerCreditNote custmoerCreditNote;
                if (roleManager.isAdmin(fofoDetails.getRoleIds())) {
                        FofoOrderItem foi = fofoOrderItemRepository.selectById(foiBadReturnRequest.getFofoOrderItemId());
                        FofoOrder fo = fofoOrderRepository.selectByOrderId(foi.getOrderId());
                        custmoerCreditNote = orderService.badReturn(fo.getFofoId(), foiBadReturnRequest);
                } else {
                        custmoerCreditNote = orderService.badReturn(fofoDetails.getFofoId(), foiBadReturnRequest);
                }
                return responseSender.ok(custmoerCreditNote.getId());
        }

        @RequestMapping(value = "/generateInvoice")
        public ResponseEntity<?> generateInvoice(HttpServletRequest request, HttpServletResponse response,
                        @RequestParam(name = ProfitMandiConstants.ORDER_ID) int orderId) throws ProfitMandiBusinessException {
                LOGGER.info("Request received at url {} with params [{}={}] ", request.getRequestURI(),
                                ProfitMandiConstants.ORDER_ID, orderId);
                LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
                PdfModel pdfModel = null;
                if (roleManager.isAdmin(fofoDetails.getRoleIds())) {
                        pdfModel = orderService.getInvoicePdfModel(orderId);
                } else {
                        pdfModel = orderService.getInvoicePdfModel(fofoDetails.getFofoId(), orderId);
                }
                ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
                PdfUtils.generateAndWrite(Arrays.asList(pdfModel), byteArrayOutputStream);
                LOGGER.info("Pdf Stream length {}", byteArrayOutputStream.toByteArray().length);
                final HttpHeaders headers = new HttpHeaders();
                headers.setContentType(MediaType.APPLICATION_PDF);
                headers.set("Content-disposition", "inline; filename=invoice-" + pdfModel.getInvoiceNumber() + ".pdf");
                headers.setContentLength(byteArrayOutputStream.toByteArray().length);
                final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
                final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
                return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
        }

        @RequestMapping(value = "/generateInvoices")
        public ResponseEntity<?> generateInvoice(HttpServletRequest request, HttpServletResponse response,
                        @RequestParam LocalDateTime startDate, @RequestParam LocalDateTime endDate, @RequestParam int partnerId)
                        throws ProfitMandiBusinessException {
                LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
                List<PdfModel> pdfModels = new ArrayList<>();
                if (roleManager.isAdmin(fofoDetails.getRoleIds())) {
                        List<Integer> orderIds = fofoOrderRepository.selectByFofoId(partnerId, startDate, endDate, 0, 0).stream()
                                        .map(x -> x.getId()).collect(Collectors.toList());
                        for (int orderId : orderIds) {
                                pdfModels.add(orderService.getInvoicePdfModel(orderId));
                        }
                        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
                        PdfUtils.generateAndWrite(pdfModels, byteArrayOutputStream);
                        LOGGER.info("Pdf Stream length {}", byteArrayOutputStream.toByteArray().length);
                        final HttpHeaders headers = new HttpHeaders();
                        headers.setContentType(MediaType.APPLICATION_PDF);
                        headers.set("Content-disposition", "inline; filename=invoice-" + partnerId + ".pdf");
                        headers.setContentLength(byteArrayOutputStream.toByteArray().length);
                        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
                        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
                        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
                } else {
                        throw new ProfitMandiBusinessException("Auth", fofoDetails.getEmailId(), "Unauthorised access");
                }
        }

        @RequestMapping(value = "/saleHistory")
        public String saleHistory(HttpServletRequest request,
                        @RequestParam(name = "searchValue", defaultValue = "") String searchValue,
                        @RequestParam(name = "searchType", defaultValue = "") SearchType searchType,
                        @RequestParam(required = false) LocalDateTime startTime,
                        @RequestParam(required = false) LocalDateTime endTime,
                        @RequestParam(name = "offset", defaultValue = "0") int offset,
                        @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
                        throws ProfitMandiBusinessException {
                LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

                Map<String, Object> map = orderService.getSaleHistory(loginDetails.getFofoId(), searchType, searchValue,
                                startTime, endTime, offset, limit);
                model.addAllAttributes(map);
                return "sale-history";
        }

        @RequestMapping(value = "/downloadInvoices")
        public ResponseEntity<?> downloadInvoices(HttpServletRequest request,
                        @RequestParam(name = "searchValue", defaultValue = "") String searchValue,
                        @RequestParam(name = "searchType", defaultValue = "") SearchType searchType,
                        @RequestParam(required = false) LocalDateTime startTime,
                        @RequestParam(required = false) LocalDateTime endTime,
                        @RequestParam(name = "offset", defaultValue = "0") int offset,
                        @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
                        throws ProfitMandiBusinessException {
                LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

                Map<String, Object> map = orderService.getSaleHistory(loginDetails.getFofoId(), searchType, searchValue,
                                startTime, endTime, offset, 100);
                List<FofoOrder> fofoOrders = (List<FofoOrder>) map.get("saleHistories");

                if (fofoOrders.size() == 0) {
                        throw new ProfitMandiBusinessException("Search criteria", "", "No orders found for criteria");
                }

                final HttpHeaders headers = new HttpHeaders();
                headers.setContentType(MediaType.APPLICATION_PDF);
                headers.set("Content-disposition", "inline; filename=invoices.pdf");
                ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
                List<PdfModel> pdfModels = new ArrayList<>();
                for (FofoOrder fofoOrder : fofoOrders) {
                        try {
                                pdfModels.add(orderService.getInvoicePdfModel(fofoOrder.getId()));
                        } catch (Exception e) {
                                LOGGER.info("could not create invoice for {}, invoice number {}", fofoOrder.getId(),
                                                fofoOrder.getInvoiceNumber());
                        }
                }
                PdfUtils.generateAndWrite(pdfModels, byteArrayOutputStream);
                headers.setContentLength(byteArrayOutputStream.toByteArray().length);
                final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
                final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
                return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
        }

        @RequestMapping(value = "/credit-note/{creditNoteId}")
        public ResponseEntity<?> downloadCreditNote(HttpServletRequest request, @PathVariable int creditNoteId)
                        throws ProfitMandiBusinessException {
                CreditNotePdfModel creditNotePdfModel = orderService.getCreditNotePdfModel(creditNoteId);
                ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
                PdfUtils.generateAndWriteCustomerCreditNotes(Arrays.asList(creditNotePdfModel), byteArrayOutputStream);
                LOGGER.info("Pdf Stream length {}", byteArrayOutputStream.toByteArray().length);
                final HttpHeaders headers = new HttpHeaders();
                headers.setContentType(MediaType.APPLICATION_PDF);
                headers.set("Content-disposition",
                                "inline; filename=invoice-" + creditNotePdfModel.getCreditNoteNumber() + ".pdf");
                headers.setContentLength(byteArrayOutputStream.toByteArray().length);
                final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
                final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
                return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
        }

        @RequestMapping(value = "/getPaginatedSaleHistory")
        public String getSaleHistoryPaginated(HttpServletRequest request,
                        @RequestParam(name = "searchValue", defaultValue = "") String searchValue,
                        @RequestParam(name = "searchType", defaultValue = "") SearchType searchType,
                        @RequestParam(required = false) LocalDateTime startTime,
                        @RequestParam(required = false) LocalDateTime endTime,
                        @RequestParam(name = "offset", defaultValue = "0") int offset,
                        @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
                        throws ProfitMandiBusinessException {
                LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
                Map<String, Object> map = orderService.getSaleHistoryPaginated(loginDetails.getFofoId(), searchType,
                                searchValue, startTime, endTime, offset, limit);
                model.addAllAttributes(map);
                return "sale-history-paginated";
        }

        @PutMapping(value = "/updatePaymentTransaction")
        public String updateTransactionDetails(HttpServletRequest request, @RequestParam String referenceType,
                        @RequestParam int fofoId, @RequestParam int referenceId,
                        @RequestBody List<PaymentOptionTransactionModel> paymentOptionTransactionModels, Model model)
                        throws Exception {
                float amount = 0;
                LOGGER.info(paymentOptionTransactionModels);

                for (PaymentOptionTransactionModel paymentOptionTransactionModel : paymentOptionTransactionModels) {
                        amount = amount + paymentOptionTransactionModel.getAmount();
                }
                FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndOrderId(fofoId, referenceId);
                LOGGER.info("FofoOrder amount" + fofoOrder.getTotalAmount() + "amount" + amount);
                if (amount == fofoOrder.getTotalAmount()) {
                        if (paymentOptionTransactionModels.size() > 0) {
                                List<PaymentOptionTransaction> paymentOptionTransactions = fofoOrderPaymentOptionRepository
                                                .selectByReferenceIdAndType(referenceId, PaymentOptionReferenceType.ORDER);
                                Map<Integer, PaymentOptionTransaction> paymentOptionIdPaymentOptionTransactionMap = this
                                                .paymentOptionIdPaymentOptionTransactionMap(paymentOptionTransactions);
                                LOGGER.info("paymentOptionIdPaymentOptionTransactionMap"
                                                + paymentOptionIdPaymentOptionTransactionMap.keySet());
                                for (PaymentOptionTransactionModel paymentOptionTransactionModel : paymentOptionTransactionModels) {
                                        if (paymentOptionIdPaymentOptionTransactionMap
                                                        .containsKey(paymentOptionTransactionModel.getPaymentOptionId())) {

                                                PaymentOptionTransaction paymentOptionTransaction = paymentOptionIdPaymentOptionTransactionMap
                                                                .get(paymentOptionTransactionModel.getPaymentOptionId());

                                                if (paymentOptionTransactionModel.getAmount() == 0) {
                                                        fofoOrderPaymentOptionRepository.delete(paymentOptionTransaction);
                                                        LOGGER.info("deleted successfully");
                                                } else {

                                                        paymentOptionTransaction.setAmount(paymentOptionTransactionModel.getAmount());
                                                        fofoOrderPaymentOptionRepository.persist(paymentOptionTransaction);
                                                        LOGGER.info("updated successfully");

                                                }
                                        } else {
                                                if (paymentOptionTransactionModel.getAmount() > 0) {
                                                        PaymentOptionTransaction paymentOptionTransaction = new PaymentOptionTransaction();
                                                        paymentOptionTransaction.setReferenceId(referenceId);
                                                        paymentOptionTransaction.setReferenceType(PaymentOptionReferenceType.ORDER);
                                                        paymentOptionTransaction
                                                                        .setPaymentOptionId(paymentOptionTransactionModel.getPaymentOptionId());
                                                        paymentOptionTransaction.setAmount(paymentOptionTransactionModel.getAmount());
                                                        paymentOptionTransaction.setFofoId(fofoId);
                                                        paymentOptionTransaction.setCreateTimestamp(fofoOrder.getCreateTimestamp());
                                                        fofoOrderPaymentOptionRepository.persist(paymentOptionTransaction);
                                                        LOGGER.info("inserted successfully");
                                                }
                                        }

                                }

                                model.addAttribute("response", mvcResponseSender.createResponseString(true));
                        }
                } else {
                        throw new ProfitMandiBusinessException("Amount", amount, "Sum of amount is not equal to total amount");
                }

                return "response";
        }

        private Map<String, List<MobileInsurancePlan>> getPlans(float sellingPrice, int itemId)
                        throws ProfitMandiBusinessException {
                try {
                        Map<String, List<MobileInsurancePlan>> productDurationPlans = insuranceService.getAllPlans(itemId,
                                        sellingPrice);
                        return productDurationPlans;
                } catch (Exception e) {
                        e.printStackTrace();
                        throw new ProfitMandiBusinessException("Fetch Insurance Plans", "Insurance",
                                        "Could not fetch insurance Plans");     
                }

        }

        @GetMapping("/insuranceDetails")
        public String getInsuranceDetails(HttpServletRequest request,
                        @RequestParam(name = "offset", defaultValue = "0") int offset,
                        @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
                        throws ProfitMandiBusinessException {
                LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
                long size = 0;
                List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectByRetailerId(loginDetails.getFofoId(),
                                offset, limit);
                size = insurancePolicyRepository.selectCountByRetailerId(loginDetails.getFofoId());
                Map<Integer, String> providerPolicyNameAndIdMap = insuranceProviderRepository
                                .selectByIds(insurancePolicies.stream().map(x -> x.getProviderId()).collect(Collectors.toSet()))
                                .stream().collect(Collectors.toMap(InsuranceProvider::getId, InsuranceProvider::getName));
                if (size < limit) {
                        model.addAttribute("end", offset + size);
                } else {
                        model.addAttribute("end", offset + limit);
                }
                model.addAttribute("start", offset + 1);
                model.addAttribute("size", size);
                model.addAttribute("insurancePolicies", insurancePolicies);
                model.addAttribute("providerPolicyNameAndIdMap", providerPolicyNameAndIdMap);
                return "insurance-details";
        }

        @GetMapping("/insuranceDetailsPaginated")
        public String getInsuranceDetailsPaginated(HttpServletRequest request,
                        @RequestParam(name = "offset", defaultValue = "0") int offset,
                        @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
                        throws ProfitMandiBusinessException {
                LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
                List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectByRetailerId(loginDetails.getFofoId(),
                                offset, limit);
                Map<Integer, String> providerPolicyNameAndIdMap = insuranceProviderRepository
                                .selectByIds(insurancePolicies.stream().map(x -> x.getProviderId()).collect(Collectors.toSet()))
                                .stream().collect(Collectors.toMap(InsuranceProvider::getId, InsuranceProvider::getName));
                model.addAttribute("insurancePolicies", insurancePolicies);
                model.addAttribute("providerPolicyNameAndIdMap", providerPolicyNameAndIdMap);
                return "insurance-details-paginated";
        }
}