Subversion Repositories SmartDukaan

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

    public String getSchemesByImei(HttpServletRequest request, @RequestParam(name = "searchImei", required = false, defaultValue = "") String searchImei, Model model) throws ProfitMandiBusinessException {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        if (org.apache.commons.lang3.StringUtils.isNotEmpty(searchImei)) {

            List<Scheme> schemes = null;

            List<SchemeInOut> schemeInOuts = null;

            InventoryItem inventoryItem = inventoryItemRepository.selectBySerialNumber(searchImei);

            int fofoId = inventoryItem.getFofoId();

            CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);

            Item item = itemRepository.selectById(inventoryItem.getItemId());

            Map<Integer, Scheme> schemeMap = new HashMap<>();

            double netEarnings = 0;

            if (inventoryItem != null) {

                // Offer payout

                List<OfferPayout> offerPayouts = offerPayoutRepository.selectAllBySerialNumber(fofoId, searchImei);

                Map<Integer, CreateOfferRequest> offerRequestMap = offerPayouts.stream().map(x -> offerService.getOffer(fofoId, (int) x.getOfferId())).collect(Collectors.toMap(x -> x.getId(), x -> x));

                schemeInOuts = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItem.getId())));

                if (!schemeInOuts.isEmpty()) {

                    netEarnings += schemeInOuts.stream().filter(x -> x.getStatus().equals(SchemePayoutStatus.CREDITED)).collect(Collectors.summingDouble(x -> x.getAmount()));

                    List<Integer> schemeIds = schemeInOuts.stream().map(x -> x.getSchemeId()).collect(Collectors.toList());

                    schemes = schemeRepository.selectBySchemeIds(schemeIds);

                    for (Scheme scheme : schemes) {

                        if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {

                            scheme.setAmountModel(scheme.getAmount() + "%");

                        } else {

                            scheme.setAmountModel(scheme.getAmount() + "");

                        }

                    }

                    schemeMap = schemes.stream().collect(Collectors.toMap(x -> x.getId(), x -> x));

                }

                List<PriceDropIMEI> priceDropImeis = priceDropIMEIRepository.selectByFofoIdImei(loginDetails.getFofoId(), searchImei);

                if (priceDropImeis.size() > 0) {

                    for (PriceDropIMEI priceDropIMEI : priceDropImeis) {

                        int priceDropId = priceDropIMEI.getPriceDropId();

                        PriceDrop pd = priceDropRepository.selectById(priceDropId);

                        priceDropIMEI.setPriceDrop(pd);

                    }

                    model.addAttribute("priceDropImeis", priceDropImeis);

                }

                netEarnings += offerPayouts.stream().collect(Collectors.summingDouble(x -> x.getAmount()));

                model.addAttribute("offerPayouts", offerPayouts);

                model.addAttribute("offerRequestMap", offerRequestMap);

                model.addAttribute("inventoryItem", inventoryItem);

                model.addAttribute("inventoryItem", inventoryItem);

            }

            model.addAttribute("netEarnings", netEarnings);

            model.addAttribute("fofoId", fofoId);

            model.addAttribute("schemeMap", schemeMap);

            model.addAttribute("item", item);

            model.addAttribute("schemeInOut", schemeInOuts);

            model.addAttribute("schemes", schemes);

            model.addAttribute("customRetailer", customRetailer);

        }

        return "scheme-imei-history";

    }