Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import com.spice.profitmandi.service.warehouse.BillingWarehouseService;

import com.google.gson.Gson;

import com.mongodb.DBObject;

import com.spice.profitmandi.common.enumuration.ContentType;

import com.spice.profitmandi.common.enumuration.MessageType;

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

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

import com.spice.profitmandi.common.web.util.ResponseSender;

import com.spice.profitmandi.dao.entity.ContactUs;

import com.spice.profitmandi.dao.entity.StoreSalesTarget;

import com.spice.profitmandi.dao.entity.auth.AuthUser;

import com.spice.profitmandi.dao.entity.catalog.Item;

import com.spice.profitmandi.dao.entity.catalog.Scheme;

import com.spice.profitmandi.dao.entity.catalog.TagListing;

import com.spice.profitmandi.dao.entity.cs.PartnerRegion;

import com.spice.profitmandi.dao.entity.cs.Position;

import com.spice.profitmandi.dao.entity.cs.Ticket;

import com.spice.profitmandi.dao.entity.cs.TicketAssigned;

import com.spice.profitmandi.dao.entity.dtr.Document;

import com.spice.profitmandi.dao.entity.dtr.NotificationCampaign;

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

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

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

import com.spice.profitmandi.dao.enumuration.catalog.UpgradeOfferStatus;

import com.spice.profitmandi.dao.enumuration.cs.EscalationType;

import com.spice.profitmandi.dao.enumuration.fofo.Milestone;

import com.spice.profitmandi.dao.enumuration.transaction.OrderStatus;

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

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

import com.spice.profitmandi.dao.model.warehouse.LMSGraphRequest;

import com.spice.profitmandi.dao.repository.ContactUsRepository;

import com.spice.profitmandi.dao.repository.auth.AuthRepository;

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

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

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

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

import com.spice.profitmandi.dao.repository.inventory.ReporticoCacheTableRepository;

import com.spice.profitmandi.dao.repository.inventory.SaholicInventoryCISRepository;

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

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

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

import com.spice.profitmandi.dao.service.SaleRewardService;

import com.spice.profitmandi.service.AdminUser;

import com.spice.profitmandi.service.FofoUser;

import com.spice.profitmandi.service.PartnerInvestmentService;

import com.spice.profitmandi.service.PartnerStatsService;

import com.spice.profitmandi.service.SshServer.SSHService;

import com.spice.profitmandi.service.authentication.RoleManager;

import com.spice.profitmandi.service.catalog.BrandsService;

import com.spice.profitmandi.service.integrations.psismart.PsiSmartService;

import com.spice.profitmandi.service.inventory.InventoryService;

import com.spice.profitmandi.service.offers.OfferService;

import com.spice.profitmandi.service.scheme.SchemeService;

import com.spice.profitmandi.service.transaction.TransactionService;

import com.spice.profitmandi.service.user.RetailerService;

import com.spice.profitmandi.web.model.LoginDetails;

import com.spice.profitmandi.web.util.CookiesProcessor;

import com.spice.profitmandi.web.util.MVCResponseSender;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.json.JSONObject;

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

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

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.transaction.annotation.Transactional;

import org.springframework.ui.Model;

import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.time.LocalDate;

import java.time.LocalDateTime;

import java.time.LocalTime;

import java.time.YearMonth;

import java.time.format.DateTimeFormatter;

import java.util.*;

import java.util.Map.Entry;

import java.util.stream.Collectors;

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

@Controller

@Transactional(rollbackFor = Throwable.class)

public class DashboardController {

    @Autowired

    private BillingWarehouseService billingWarehouseService;

    List<String> emails = Arrays.asList("kamini.sharma@smartdukaan.com", "neeraj.gupta@smartdukaan.com", "amit.gupta@smartdukaan.com", "ranu.rajput@smartdukaan.com", "vikas.jangra@smartdukaan.com", "tanay.gupta@smartdukaan.com", "rudy.kanwar@smartdukaan.com");

    @Value("${web.api.host}")

    private String webApiHost;

    @Value("${web.api.scheme}")

    private String webApiScheme;

    @Autowired

    private CsService1 csService1;

    @Value("${web.api.root}")

    private String webApiRoot;

    @Value("${web.api.port}")

    private int webApiPort;

    @Autowired

    private PriceDropRepository priceDropRepository;

    @Autowired

    private BrandsRepository brandsRepository;

    @Autowired

    private CookiesProcessor cookiesProcessor;

    @Autowired

    private PendingOrderRepository pendingOrderRepository;

    @Autowired

    private PartnerStatsService partnerStatsService;

    @Autowired

    private CsService csService;

    @Autowired

    private ResponseSender<?> responseSender;

    @Autowired

    RetailerService retailerService;

    @Autowired

    private AdminUser adminUser;

    @Autowired

    private RoleManager roleManager;

    @Autowired

    private FofoStoreRepository fofoStoreRepository;

    @Autowired

    private PartnerInvestmentService partnerInvestmentService;

    @Autowired

    DocumentRepository documentRepository;

    @Autowired

    InventoryItemRepository inventoryItemRepository;

    @Autowired

    InventoryService inventoryService;

    @Autowired

    private PendingOrderItemRepository pendingOrderItemRepository;

    @Autowired

    private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;

    @Autowired

    private FofoOrderItemRepository fofoOrderItemRepository;

    @Autowired

    private PartnerTypeChangeService partnerTypeChangeService;

    @Autowired

    private HygieneDataRepository hygieneDataRepository;

    @Autowired

    private UserAccountRepository userAccountRepository;

    @Autowired

    private NotificationCampaignRepository notificationCampaignRepository;

    @Autowired

    private AuthRepository authRepository;

    @Autowired

    private FofoOrderRepository fofoOrderRepository;

    @Autowired

    private Gson gson;

    @Autowired

    TicketRepository ticketRepository;

    @Autowired

    private OfferService offerService;

    @Autowired

    private ItemRepository itemRepository;

    @Autowired

    private SaholicInventoryCISRepository saholicInventoryCISRepository;

    @Autowired

    private MVCResponseSender mvcResponseSender;

    @Autowired

    private ContactUsRepository contactUsRepository;

    @Autowired

    private ReporticoCacheTableRepository reporticoCacheTableRepository;

    @Autowired

    private TransactionService transactionService;

    @Autowired

    private TagListingRepository tagListingRepository;

    @Autowired

    private TicketAssignedRepository ticketAssignedRepository;

    @Autowired

    private OrderRepository orderRepository;

    @Autowired

    private FofoUser fofoUser;

    @Autowired

    private ActivatedImeiRepository activatedImeiRepository;

    @Autowired

    private Mongo mongoClient;

    @Autowired

    private SchemeInOutRepository schemeInOutRepository;

    @Autowired

    private LineItemRepository lineItemRepository;

    @Autowired

    private FofoLineItemRepository fofoLineItemRepository;

    @Autowired

    private PositionRepository positionRepository;

    @Autowired

    private MonthlyTargetRepository monthlyTargetRepository;

    @Autowired

    private SamsungUpgradeOfferRepository samsungUpgradeOfferRepository;

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

    @Autowired

    private SSHService sshService;

    @Autowired

    BrandsService brandsService;

    @Autowired

    SaleRewardService saleRewardService;

    @Autowired

    SchemeService schemeService;

    @Autowired

    PrintResourceRegionRepository printResourceRegionRepository;

    @Autowired

    PartnerRegionRepository partnerRegionRepository;

    @Autowired

    PrintResourceRepository printResourceRepository;

    @Autowired

    CatalogRepository catalogRepository;

    @Autowired

    OfferRepository offerRepository;

    @Autowired

    OfferPayoutRepository offerPayoutRepository;

    @Value("${google.api.key}")

    private String googleApiKey;

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

    public String dashboard1(HttpServletRequest request, Model model, @RequestParam int fofoId) throws Exception {

        boolean isAdmin = false;

        model.addAttribute("isAdmin", isAdmin);

        model.addAttribute("webApiHost", webApiHost);

        model.addAttribute("webApiPort", webApiPort);

        model.addAttribute("webApiScheme", webApiScheme);

        model.addAttribute("webApiRoot", webApiRoot);

        if (isAdmin) {

            return "dashboard1";

        }

        FofoStore fofoStore = null;

        try {

            CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);

            fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);

            if (!fofoStore.isActive()) {

                return "redirect:/login";

            }

            PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fofoStore.getId(), LocalDate.now());

            model.addAttribute("partnerType", partnerType);

            model.addAttribute("partnerTypeImage", PartnerType.imageMap.get(partnerType));

            model.addAttribute("fofoStore", customRetailer);

            model.addAttribute("partnerType", partnerType);

            model.addAttribute("hasGift", fofoUser.hasGift(fofoId));

            model.addAttribute("giftItemId", ProfitMandiConstants.GIFT_ID);

            model.addAttribute("brandStockPrices", fofoUser.getBrandStockPrices(fofoId, false));

            model.addAttribute("salesMap", fofoUser.getSales(fofoId));

            model.addAttribute("activatedImeis", inventoryItemRepository.selectCountByActivatedNotSold(fofoId));

            // this.setInvestments

            //

            Map<Integer, String> monthValueMap = new HashMap<>();

            for (int i = 0; i <= 5; i++) {

                LocalDateTime startOfMonth = LocalDateTime.now().withDayOfMonth(1).minusMonths(i);

                monthValueMap.put(i, startOfMonth.format(DateTimeFormatter.ofPattern("MMM''uu")));

            }

            LOGGER.info("monthValueMap" + monthValueMap);

            Set<String> brands = brandsService.getBrandsToDisplay(3).stream().map(x -> x.getName()).collect(Collectors.toSet());

            brands.addAll(itemRepository.selectAllBrands(ProfitMandiConstants.LED_CATEGORY_ID));

            brands.addAll(itemRepository.selectAllBrands(ProfitMandiConstants.SMART_WATCH_CATEGORY_ID));

            brands.add("Live Demo");

            model.addAttribute("brands", brands);

            model.addAttribute("monthValueMap", monthValueMap);

            model.addAttribute("investments", fofoUser.getInvestments(fofoId));

            model.addAttribute("isInvestmentOk", partnerInvestmentService.isInvestmentOk(fofoId, ProfitMandiConstants.MIN_INVESTMENT_PERCENTAGE, ProfitMandiConstants.CUTOFF_INVESTMENT));

        } catch (ProfitMandiBusinessException e) {

            LOGGER.error("FofoStore Code not found of fofoId {}", fofoId);

        }

        return "12dashboard34";

    }

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

    public String getMonthsale(HttpServletRequest request, Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        int fofoId = loginDetails.getFofoId();

        Map<Integer, MonthSaleModel> monthSaleMap = new HashMap<>();

        LocalDateTime curDate = LocalDate.now().atStartOfDay();

        int dayOfMonth = curDate.getDayOfMonth();

        YearMonth yearMonth = YearMonth.now();

        for (int i = 0; i <= 6; i++) {

            LocalDateTime startOfMonth = curDate.withDayOfMonth(1).minusMonths(i);

            int lengthOfMonth = YearMonth.from(startOfMonth).lengthOfMonth();

            LOGGER.info("Start of previous Month {}, start of next month Month {}", startOfMonth, startOfMonth.plusMonths(1));

            double monthSales = fofoOrderItemRepository.selectSumMopGroupByRetailer(startOfMonth, startOfMonth.plusMonths(1), loginDetails.getFofoId(), false).get(fofoId);

            LOGGER.info("Month sales - {}", monthSales);

            double mtdSales = fofoOrderItemRepository.selectSumMopGroupByRetailer(startOfMonth, startOfMonth.plusDays(Math.min(dayOfMonth, lengthOfMonth)), loginDetails.getFofoId(), false).get(fofoId);

            PartnerType partnerType = partnerTypeChangeService.getTypeOnMonth(fofoId, yearMonth.minusMonths(i));

            MonthSaleModel ms = new MonthSaleModel();

            ms.setMtdSales(fofoUser.format((long) mtdSales));

            ms.setMonthlySales(fofoUser.format(((long) monthSales)));

            ms.setPartnerType(partnerType);

            ms.setMonth(startOfMonth.format(DateTimeFormatter.ofPattern("MMM''uu")));

            monthSaleMap.put(i, ms);

        }

        model.addAttribute("monthSales", monthSaleMap);

        return "monthSales";

    }

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

    @ResponseBody

    public List<Map<String, Object>> getBrandwisePartnerSale(

            HttpServletRequest request,

            @RequestParam(name = "month", required = true, defaultValue = "0") int month,

            Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        int fofoId = loginDetails.getFofoId();

        List<BrandWisePartnerSaleModel> mobileList =

                fofoStoreRepository.selectBrandWiseMonthlyPartnerSale(Collections.singletonList(fofoId), month);

        List<BrandWisePartnerSaleModel> accList =

                fofoStoreRepository.selectBrandWiseMonthlyPartnerAccessoriesSale(Collections.singletonList(fofoId), month);

        List<Map<String, Object>> response = new ArrayList<>();

        for (BrandWisePartnerSaleModel m : mobileList) {

            Map<String, Object> row = new HashMap<>();

            row.put("brand", m.getBrand());

            row.put("lmtd", fofoUser.format(m.getLmtd()));

            row.put("lmtdQty", m.getLmtdQty());

            row.put("mtd", fofoUser.format(m.getMtd()));

            row.put("mtdQty", m.getMtdQty());

            response.add(row);

        }

        long accLmtd = 0;

        long accLmtdQty = 0;

        long accMtd = 0;

        long accMtdQty = 0;

        for (BrandWisePartnerSaleModel a : accList) {

            accLmtd += a.getLmtd();

            accLmtdQty += a.getLmtdQty();

            accMtd += a.getMtd();

            accMtdQty += a.getMtdQty();

        }

        if (!accList.isEmpty()) {

            Map<String, Object> accRow = new HashMap<>();

            accRow.put("brand", "Accessories");

            accRow.put("lmtd", fofoUser.format(accLmtd));

            accRow.put("lmtdQty", accLmtdQty);

            accRow.put("mtd", fofoUser.format(accMtd));

            accRow.put("mtdQty", accMtdQty);

            response.add(accRow);

        }

        return response;

    }

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

    @ResponseBody

    public List<BrandItemWisePartnerSaleModel> getBrandItemwisePartnerSale(HttpServletRequest request, @RequestParam(name = "month", required = true, defaultValue = "0") int month, @RequestParam(name = "brand") String brand, @RequestParam(name = "fofoId") Integer fofoId, Model model) throws Exception {

        List<BrandItemWisePartnerSaleModel> brandItemWisePartnerSaleModels = fofoStoreRepository.selectPartnerBrandItemMonthlySale(Collections.singletonList(fofoId), month, brand);

        LOGGER.info("brandItemWisePartnerSaleModels {}", brandItemWisePartnerSaleModels);

        return brandItemWisePartnerSaleModels;

    }

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

    @ResponseBody

    public List<BrandItemWisePartnerSaleModel> getBrandItemwisePartnerSecondarySale(HttpServletRequest request, @RequestParam(name = "month", required = true, defaultValue = "0") int month, @RequestParam(name = "brand") String brand, @RequestParam(name = "fofoId") Integer fofoId, Model model) throws Exception {

        List<BrandItemWisePartnerSaleModel> brandItemWisePartnerSaleModels = fofoStoreRepository.selectPartnerBrandItemMonthlySecondarySale(Collections.singletonList(fofoId), month, brand);

        LOGGER.info("brandItemWisePartnerSaleModels {}", brandItemWisePartnerSaleModels);

        return brandItemWisePartnerSaleModels;

    }

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

    public String getDateWiseBulletins(HttpServletRequest request,

                                       @RequestParam("date") String date,

                                       Model model) throws Exception {

        // Callers on the partner-facing domain don't always carry the fofo admin

        // cookies (FOFO_ID / EMAIL_ID / ROLE_IDS) — cookiesProcessor would then

        // throw ProfitMandiBusinessException and the global handler would turn it

        // into a 400. Bulletins are per-position, so a session-less request has

        // nothing to show — return an empty bulletin list instead of failing.

        LoginDetails loginDetails;

        try {

            loginDetails = cookiesProcessor.getCookiesObject(request);

        } catch (ProfitMandiBusinessException e) {

            model.addAttribute("bulletins", new LinkedHashMap<>());

            return "bulletin-list";

        }

        String email = loginDetails.getEmailId();

        AuthUser authUser = authRepository.selectByEmailOrMobile(email);

        List<Position> positions = authUser == null

                ? new ArrayList<>()

                : positionRepository.selectAllByAuthUserId(authUser.getId());

        LocalDate selectedDate = LocalDate.parse(date);

        // Short-circuit when the caller has no Position rows. getTodayBulletin's

        // `positions` parameter is @NotEmpty validated — handing it an empty list

        // throws "List should not be empty" and 500s the dashboard. A user with

        // no positions simply has no bulletins to see, so render an empty page.

        //

        // Bulletin fetch is best-effort: it fans out to several sub-services

        // (catalog offers / schemes / web offers / prebooking). If any one of

        // them throws, we'd otherwise bubble a 500/400 to the caller. For this

        // endpoint we prefer to degrade to an empty list rather than fail the

        // page — the frontend renders nothing, which is what the user asked for.

        Map<ProfitMandiConstants.BULLETIN_TYPE_ENUM, List<BulletinOfferModal>> dbBulletins;

        if (positions == null || positions.isEmpty()) {

            dbBulletins = new HashMap<>();

        } else {

            try {

                dbBulletins = adminUser.getTodayBulletin(positions, selectedDate.atStartOfDay());

            } catch (Exception e) {

                LOGGER.warn("getTodayBulletin failed for date={} authUserId={}: {}",

                        date, authUser != null ? authUser.getId() : null, e.getMessage());

                dbBulletins = new HashMap<>();

            }

        }

        // Final ordered map (STRICT enum order)

        Map<ProfitMandiConstants.BULLETIN_TYPE_ENUM, List<BulletinOfferModal>> bulletins =

                new LinkedHashMap<>();

        for (ProfitMandiConstants.BULLETIN_TYPE_ENUM type :

                ProfitMandiConstants.BULLETIN_TYPE_ENUM.values()) {

            List<BulletinOfferModal> list = dbBulletins.get(type);

            if (list != null && !list.isEmpty()) {

                bulletins.put(type, list);   // only add if has data

            }

        }

        model.addAttribute("bulletins", bulletins);

        return "bulletin-list";

    }

    static String formatIndianCurrency(long amount) {

        if (amount >= 10000000L) {

            return String.format("%.2f Cr", amount / 10000000.0);

        }

        if (amount >= 100000L) {

            return String.format("%.2f L", amount / 100000.0);

        }

        return String.format("%,d", amount);

    }

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

    public String getGrnPendingOrderStatus(HttpServletRequest request, Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        int fofoId = loginDetails.getFofoId();

        List<Order> grnPendingOrders = orderRepository.selectGrnTimestampNull(fofoId, Arrays.asList(in.shop2020.model.v1.order.OrderStatus.DELIVERY_SUCCESS));

        model.addAttribute("grnPendingOrders", grnPendingOrders);

        return "purchase-grn-order-status";

    }

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

    public String getPendingOrderStatus(HttpServletRequest request, Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        int fofoId = loginDetails.getFofoId();

        ArrayList<in.shop2020.model.v1.order.OrderStatus> orderStatus = new ArrayList<>();

        orderStatus.add(in.shop2020.model.v1.order.OrderStatus.SUBMITTED_FOR_PROCESSING);

        List<Order> order = orderRepository.selectOrders(fofoId, orderStatus);

        List<Integer> submittedOrderIds = order.stream().filter(x -> x.getStatus() == in.shop2020.model.v1.order.OrderStatus.SUBMITTED_FOR_PROCESSING).map(x -> x.getId()).collect(Collectors.toList());

        model.addAttribute("submittedOrderIds", submittedOrderIds);

        if (!submittedOrderIds.isEmpty()) {

            List<LineItem> submittedLineItem = lineItemRepository.selectLineItem(submittedOrderIds);

            Map<Integer, LineItem> submittedLineItemMap = submittedLineItem.stream().collect(Collectors.toMap(x -> x.getOrderId(), x -> x));

            //LOGGER.info("submittedLineItemMap {}", submittedLineItemMap);

            model.addAttribute("submittedLineItemMap", submittedLineItemMap);

        }

        return "purchase-pending-order-status";

    }

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

    public String getBilledOrderStatus(HttpServletRequest request, Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        int fofoId = loginDetails.getFofoId();

        ArrayList<in.shop2020.model.v1.order.OrderStatus> orderStatus = new ArrayList<>();

        orderStatus.add(in.shop2020.model.v1.order.OrderStatus.BILLED);

        List<Order> order = orderRepository.selectOrders(fofoId, orderStatus);

        List<Integer> billedOrderIds = order.stream().filter(x -> x.getStatus() == in.shop2020.model.v1.order.OrderStatus.BILLED).map(x -> x.getId()).collect(Collectors.toList());

        LOGGER.info("billedOrderIds {}", billedOrderIds);

        model.addAttribute("billedOrderIds", billedOrderIds);

        if (!billedOrderIds.isEmpty()) {

            List<LineItem> billedLineItem = lineItemRepository.selectLineItem(billedOrderIds);

            Map<Integer, LineItem> billedLineItemMap = billedLineItem.stream().collect(Collectors.toMap(x -> x.getOrderId(), x -> x));

            LOGGER.info("billedLineItemMap {}", billedLineItemMap);

            model.addAttribute("billedLineItemMap", billedLineItemMap);

        }

        return "purchase-billed-order-status";

    }

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

    public String getShippedOrderStatus(HttpServletRequest request, Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        int fofoId = loginDetails.getFofoId();

        ArrayList<in.shop2020.model.v1.order.OrderStatus> orderStatus = new ArrayList<>();

        orderStatus.add(SHIPPED_FROM_WH);

        List<Order> order = orderRepository.selectOrders(fofoId, orderStatus);

        List<Integer> shippedOrderIds = order.stream().filter(x -> x.getPartnerGrnTimestamp() == null).map(x -> x.getId()).collect(Collectors.toList());

        model.addAttribute("shippedOrderIds", shippedOrderIds);

        LOGGER.info("shippedOrderIds {}", shippedOrderIds);

        if (!shippedOrderIds.isEmpty()) {

            List<LineItem> shippedLineItem = lineItemRepository.selectLineItem(shippedOrderIds);

            Map<Integer, LineItem> shippedLineItemMap = shippedLineItem.stream().collect(Collectors.toMap(x -> x.getOrderId(), x -> x));

            LOGGER.info("shippedLineItemMap {}", shippedLineItemMap);

            model.addAttribute("shippedLineItemMap", shippedLineItemMap);

        }

        return "purchase-shipped-order-status";

    }

    @RequestMapping(value = "/partnerTotalIncomeByMonth/{yearMonth}", method = RequestMethod.GET)

    public String getPartnerTotalIncomeByMonth(HttpServletRequest request, @PathVariable int yearMonth, Model model) throws

            Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        Map<String, Object> data = retailerService

                .computeIncomeMap(loginDetails.getFofoId(), yearMonth);

//        long pendingIncome = 0;

//        long partnerPurchaseIn = 0;

//        long partnerCreditedSale = 0;

//        long partnerFrontIncome = 0;

//

//        LocalDateTime startOfMonth = LocalDate.now().minusMonths(yearMonth).withDayOfMonth(1).atStartOfDay();

//        LocalDateTime endOfMonth = startOfMonth.plusMonths(1).toLocalDate().atStartOfDay();

//

//        AllPurchaseInventoryModel partnerlPendingSaleAmount = schemeInOutRepository.selectAllPendingSaleInventoryByFofoId(loginDetails.getFofoId(), startOfMonth, endOfMonth);

//        AllPurchaseInventoryModel partnerCreditedSaleAmount = schemeInOutRepository.selectAllCreditedSaleInventoryByFofoId(loginDetails.getFofoId(), startOfMonth, endOfMonth);

//        AllPurchaseInventoryModel partnerPurchaseInAmount = schemeInOutRepository.selectAllPurchaseInventoryByFofoId(loginDetails.getFofoId(), startOfMonth, endOfMonth);

//

//        AllPurchaseInventoryModel partnerFrontIncomes = schemeInOutRepository.selectFrontIncomeByFofoId(loginDetails.getFofoId(), startOfMonth, endOfMonth);

//

//        List<OfferPayoutImeiIncomeModel> offerPayoutImeiIncomeModels = offerPayoutRepository.getTotalPayoutsByPartnerPeriod(YearMonth.of(startOfMonth.getYear(), startOfMonth.getMonth()), loginDetails.getFofoId(), null, null);

//

//        long additionalIncome = offerPayoutImeiIncomeModels.stream().collect(Collectors.summingDouble(x -> x.getSalePayout() + x.getPurchasePayout())).longValue();

//        // AllPurchaseInventoryModel partnerAdditionalIncome =

//        // offerRepository.selectPurchaseIncome(loginDetails.getFofoId(), startOfMonth,

//        // endOfMonth);

//

//        LOGGER.info("partnerfrontIncomes" + partnerFrontIncomes);

//

//        LOGGER.info("partnerCreditedSaleAmount" + partnerCreditedSaleAmount);

//        LOGGER.info("partnerPurchaseInAmount" + partnerPurchaseInAmount);

//        LOGGER.info("partnerlPendingSaleAmount" + partnerlPendingSaleAmount);

//

//        if (partnerlPendingSaleAmount != null) {

//

//            pendingIncome = partnerlPendingSaleAmount.getAmount();

//

//            LOGGER.info("pendingIncome" + pendingIncome);

//

//        }

//

//        if (partnerCreditedSaleAmount != null) {

//

//            partnerCreditedSale = partnerCreditedSaleAmount.getAmount();

//

//            LOGGER.info("partnerCreditedSale" + partnerCreditedSale);

//

//        }

//        if (partnerFrontIncomes != null) {

//

//            partnerFrontIncome = partnerFrontIncomes.getAmount();

//            LOGGER.info("partnerPurchaseIn" + partnerPurchaseIn);

//

//        }

//        if (partnerPurchaseInAmount != null) {

//

//            partnerPurchaseIn = partnerPurchaseInAmount.getAmount();

//            LOGGER.info("partnerPurchaseIn" + partnerPurchaseIn);

//

//        }

//

//        LOGGER.info("partnerPurchaseInTT" + partnerPurchaseIn);

//        LOGGER.info("partnerCreditedSaleTT" + partnerCreditedSale);

//        LOGGER.info("pendingIncomeTT" + pendingIncome);

//

//        long totalIncome = partnerCreditedSale + partnerPurchaseIn + pendingIncome + partnerFrontIncome + additionalIncome;

//

//        long creditedIncome = partnerCreditedSale + partnerPurchaseIn + partnerFrontIncome + additionalIncome;

//

//        long pendingTotalIncome = pendingIncome;

//        LOGGER.info("totalIncome" + totalIncome);

//        LOGGER.info("creditedIncome" + creditedIncome);

//        LOGGER.info("pendingTotalIncome" + pendingTotalIncome);

//

        model.addAttribute("totalIncome", data.get("totalIncome"));

        model.addAttribute("creditedIncome", data.get("creditedIncome"));

        model.addAttribute("pendingTotalIncome", data.get("pendingIncome"));

//

//        Map<Integer, String> monthValueMap = new HashMap<>();

//        for (int i = 0; i <= 5; i++) {

//            LocalDateTime monthStart = LocalDateTime.now().withDayOfMonth(1).minusMonths(i);

//            monthValueMap.put(i, monthStart.format(DateTimeFormatter.ofPattern("MMM''uu")));

//        }

//

        model.addAttribute("month", data.get("monthIndex"));

        model.addAttribute("monthValueMap", data.get("monthValueMap"));

        LOGGER.info("income data", data);

        model.addAttribute("data", data);

        return "partner-total-income";

    }

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

    public String getMonthsInvestment(HttpServletRequest request,

                                      @RequestParam(name = "month", required = true, defaultValue = "0") int month, Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        int fofoId = loginDetails.getFofoId();

        Map<String, Object> investment = fofoUser.getInvestmentsMonths(fofoId, month);

        LocalDateTime currentMonthStart = LocalDateTime.now().withDayOfMonth(1);

        LocalDateTime lastMonthStart = currentMonthStart.minusMonths(1);

        LocalDateTime currentMonthEnd = currentMonthStart.plusMonths(1).withDayOfMonth(1);

        double currentMonthRating = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), DateRangeModel.of(currentMonthStart, currentMonthEnd)) / 2;

        double lastMonthRating = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), DateRangeModel.of(lastMonthStart, currentMonthStart)) / 2;

        double ratingTillDate = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), DateRangeModel.withEndDate(currentMonthEnd)) / 2;

        model.addAttribute("currentMonthRating", (float) Math.round(currentMonthRating * 10) / 10);

        model.addAttribute("lastMonthRating", (float) Math.round(lastMonthRating * 10) / 10);

        model.addAttribute("ratingTillDate", (float) Math.round(ratingTillDate * 10) / 10);

        long hygieneCount = hygieneDataRepository.selectHygieneCount(loginDetails.getFofoId(), true, currentMonthStart.minusMonths(month), currentMonthEnd.minusMonths(month));

        long invalidHygieneCount = hygieneDataRepository.selectHygieneCount(loginDetails.getFofoId(), false, currentMonthStart.minusMonths(month), currentMonthEnd.minusMonths(month));

        if (hygieneCount == 0 && invalidHygieneCount == 0) {

            invalidHygieneCount = 1;

        }

        Map<Integer, String> monthValueMap = new HashMap<>();

        for (int i = 0; i <= 5; i++) {

            LocalDateTime startOfMonth = LocalDateTime.now().withDayOfMonth(1).minusMonths(i);

            monthValueMap.put(i, startOfMonth.format(DateTimeFormatter.ofPattern("MMM''uu")));

        }

        model.addAttribute("hygienePercentage", (hygieneCount * 100) / (invalidHygieneCount + hygieneCount));

        model.addAttribute("monthValueMap", monthValueMap);

        model.addAttribute("investments", investment);

        model.addAttribute("monthDays", LocalDate.now().minusMonths(month).lengthOfMonth());

        model.addAttribute("dayOfMonth", LocalDate.now().minusMonths(month).lengthOfMonth());

        model.addAttribute("month", month);

        return "performance";

    }

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

    public String getInvestmentDetails(HttpServletRequest request, Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        int fofoId = loginDetails.getFofoId();

        ChartInvestmentModel cm = fofoUser.getInvestmentChart(fofoId);

        model.addAttribute("chartPieMap", gson.toJson(cm));

        LOGGER.info("InvestmentChart" + gson.toJson(cm));

        LOGGER.info("InvestmentChart" + cm);

        return "investmentdetails";

    }

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

    public String getlmsLineChart(HttpServletRequest request, Model model, @RequestParam(name = "fofoId", defaultValue = "0") int fofoId) throws Exception {

        if (fofoId == 0) {

            LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

            fofoId = loginDetails.getFofoId();

        }

        ChartModel cm = fofoUser.getLmsLineChart(fofoId);

        LOGGER.info("linechartMap" + gson.toJson(cm));

        model.addAttribute("linechartMap", gson.toJson(cm));

        return "lmsLineChart";

    }

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

    public String getMonthlyPurchaseLineChart(HttpServletRequest request, Model model, @RequestParam(name = "fofoId", defaultValue = "0") int fofoId) throws Exception {

        if (fofoId == 0) {

            LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

            fofoId = loginDetails.getFofoId();

        }

        ChartModel cm = fofoUser.getPurchaseOrderChart(fofoId);

        LOGGER.info("chartMap" + gson.toJson(cm));

        model.addAttribute("chartMap", gson.toJson(cm));

        return "purchase_chart";

    }

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

    public String getBarChart(HttpServletRequest request, @RequestParam(required = false) LocalDate from, @RequestParam(required = false) LocalDate to,@RequestParam(required = false) Boolean isQuantity ,Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        int fofoId = loginDetails.getFofoId();

        LocalDateTime curDate = from == null ? LocalDate.now().atStartOfDay().withDayOfMonth(1) : from.atStartOfDay();

        LocalDateTime lastDate = to == null ? LocalDate.now().atStartOfDay().with(LocalTime.MAX) : to.atStartOfDay();

        isQuantity = isQuantity==null?false:isQuantity;

        ChartModel cm = fofoUser.getBrandChart(fofoId, from, to,isQuantity);

        LOGGER.info("from" + curDate);

        LOGGER.info("to" + lastDate);

        LOGGER.info("chartMap" + gson.toJson(cm));

        model.addAttribute("chartMap", gson.toJson(cm));

        model.addAttribute("from", curDate.toLocalDate());

        model.addAttribute("to", lastDate.toLocalDate());

        model.addAttribute("fofoId", fofoId);

        model.addAttribute("isQuantity",isQuantity);

        return "bar_chart";

    }

    @GetMapping(value = "/brandWiseFofoSaleData")

    public String getBarChartModelWise(HttpServletRequest request,

                                       @RequestParam LocalDate from,

                                       @RequestParam LocalDate to,

                                       @RequestParam String brand,

                                       @RequestParam boolean isQuantity,

                                       @RequestParam int fofoId, Model model) throws Exception {

        ChartModel cm = fofoUser.getModelBrandChart(fofoId, brand, from, to,isQuantity);

        LOGGER.info("chartMap" + gson.toJson(cm));

        model.addAttribute("chartMap", gson.toJson(cm));

        return "bar_chart_model_wise";

    }

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

    public String getPriceDropDetails(HttpServletRequest request,

                                      @RequestParam(name = "fofoId", required = true, defaultValue = "0") int fofoId,

                                      @RequestParam(name = "brand", required = true, defaultValue = "0") String brand,

                                      @RequestParam(name = "yearMonth", required = false, defaultValue = "0") String yearMonth, Model model) throws

            Exception {

        LOGGER.info("params" + fofoId + brand + yearMonth);

        List<PriceDropWithDetailsByYearMonthModel> priceDropdetailsList = priceDropRepository.selectBrandPendingPriceDropWithDetailsByYearMonth(fofoId, brand, yearMonth);

        LOGGER.info("priceDropdetailsList" + priceDropdetailsList);

        model.addAttribute("priceDropdetailsList", priceDropdetailsList);

        return "price-drop-details";

    }

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

    public String getPriceDropDetailSixMonths(HttpServletRequest request,

                                              @RequestParam(name = "fofoId", required = true, defaultValue = "0") int fofoId,

                                              @RequestParam(name = "brand", required = true, defaultValue = "0") String brand, Model model) throws Exception {

        LOGGER.info("params" + fofoId + brand);

        LocalDateTime curDate = LocalDate.now().atStartOfDay();

        LocalDateTime startfMonthSixMonth = curDate.withDayOfMonth(1).minusMonths(12);

        LocalDateTime endMonthTotal = curDate.withDayOfMonth(1).minusMonths(6);

        List<PriceDropWithDetailsByYearMonthModel> priceDropdetailsList = priceDropRepository.selectBrandPendingPriceDropWithDetailsAndSixMonth(fofoId, brand, startfMonthSixMonth, endMonthTotal);

        LOGGER.info("priceDropdetailsList" + priceDropdetailsList);

        model.addAttribute("priceDropdetailsList", priceDropdetailsList);

        return "price-drop-details";

    }

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

    public String getMonthlyPriceDropTabular(HttpServletRequest request, Model model, @RequestParam(name = "fofoId", defaultValue = "0") int fofoId) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        if (fofoId == 0) {

            fofoId = loginDetails.getFofoId();

        }

        LocalDateTime curDate = LocalDate.now().atStartOfDay();

        LocalDateTime startOfMonth = curDate.withDayOfMonth(1).minusMonths(6);

        LocalDateTime startfMonthTotal = curDate.withDayOfMonth(1).minusMonths(12);

        LocalDateTime endMonthTotal = curDate.withDayOfMonth(1).minusMonths(5);

        LOGGER.info("startfMonthTotal" + startfMonthTotal);

        LOGGER.info("endMonthTotal" + endMonthTotal);

        List<YearMonth> yms = new ArrayList<YearMonth>();

        for (int i = 0; i <= 5; i++) {

            yms.add(YearMonth.from(curDate.withDayOfMonth(1).minusMonths(i)));

        }

        Collections.reverse(yms);

        model.addAttribute("yms", yms);

        LOGGER.info("ym" + yms);

        List<PriceDropYearMonthModel> priceDropYearMonthModels = priceDropRepository.selectBrandPendingPriceDropByYearMonth(fofoId, startOfMonth);

        List<PriceDropBrandModel> priceDropBrandSixMonthTotals = priceDropRepository.selectSixMonthBrandPriceDropByYearMonth(fofoId, startfMonthTotal, endMonthTotal);

        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("MM-yyyy");

        Map<String, Map<YearMonth, Double>> brandMonthValue = new HashMap<>();

        LOGGER.info("priceDropBrandSixMonthTotals" + priceDropBrandSixMonthTotals);

        Map<String, Double> priceDropBrandSixMonthMap = priceDropBrandSixMonthTotals.stream().collect(Collectors.toMap(x -> x.getBrand(), x -> (double) x.getAmount()));

        model.addAttribute("priceDropBrandSixMonthMap", priceDropBrandSixMonthMap);

        LOGGER.info("priceDropYearMonthModels" + priceDropYearMonthModels);

        for (PriceDropYearMonthModel pdm : priceDropYearMonthModels) {

            Map<YearMonth, Double> brandValue = new HashMap<>();

            if (brandMonthValue.containsKey(pdm.getBrand())) {

                brandValue = brandMonthValue.get(pdm.getBrand());

                brandValue.put(YearMonth.parse(pdm.getYearMonth(), dateTimeFormatter), (double) pdm.getAmount());

            } else {

                brandValue.put(YearMonth.parse(pdm.getYearMonth(), dateTimeFormatter), (double) pdm.getAmount());

            }

            brandMonthValue.put(pdm.getBrand(), brandValue);

        }

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

        brands.add("Accessories");

        brands.add("Oppo");

        brands.add("Vivo");

        brands.add("Samsung");

        brands.add("Realme");

        brands.add("MI");

        brands.add("Tecno");

        brands.add("Itel");

        brands.add("Nokia");

        Map<String, List<Double>> sortedBrandValue = new LinkedHashMap<>();

        model.addAttribute("brands", brands);

        for (String brand : brands) {

            Map<YearMonth, Double> yearMonthValue = brandMonthValue.get(brand);

            for (int i = 5; i >= 0; i--) {

                LocalDateTime startMonth = curDate.withDayOfMonth(1).minusMonths(i);

                if (yearMonthValue != null) {

                    if (yearMonthValue.get(YearMonth.from(startMonth)) == null) {

                        yearMonthValue.put(YearMonth.from(startMonth), 0.0);

                    }

                } else {

                    yearMonthValue = new HashMap<>();

                    yearMonthValue.put(YearMonth.from(startMonth), 0.0);

                }

            }

            Map<YearMonth, Double> sortedMonthBrandValue = new TreeMap<>(yearMonthValue);

            brandMonthValue.put(brand, sortedMonthBrandValue);

            sortedBrandValue.put(brand, sortedMonthBrandValue.values().stream().collect(Collectors.toList()));

        }

        LOGGER.info("sortedBrandValue" + sortedBrandValue);

        model.addAttribute("fofoId", fofoId);

        model.addAttribute("sortedBrandValue", sortedBrandValue);

        return "price-drop-tabular";

    }

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

    public String getMonthlyActivation(HttpServletRequest request, Model model, @RequestParam(name = "fofoId", defaultValue = "0") int fofoId) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        if (fofoId == 0) {

            fofoId = loginDetails.getFofoId();

        }

        LocalDateTime curDate = LocalDate.now().atStartOfDay();

        LocalDateTime startOfMonth = curDate.withDayOfMonth(1).minusMonths(6);

        List<YearMonth> yms = new ArrayList<YearMonth>();

        for (int i = 0; i <= 5; i++) {

            yms.add(YearMonth.from(curDate.withDayOfMonth(1).minusMonths(i)));

        }

        Collections.reverse(yms);

        model.addAttribute("yms", yms);

        LOGGER.info("ym" + yms);

        List<ActivationYearMonthModel> pendingActivationModels = schemeInOutRepository.selectPendingActivationGroupByBrandYearMonth(fofoId, startOfMonth);

        List<ActivationBrandModel> pendingActivationBeforeSixMonth = schemeInOutRepository.selectByYearMonthActivationGroupByBrand(fofoId, startOfMonth);

        Map<String, Double> pendingActivationBeforeSixMonthMap = pendingActivationBeforeSixMonth.stream().collect(Collectors.toMap(x -> x.getBrand(), x -> (double) x.getAmount()));