WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/offers/OfferServiceImpl.java

         return rollout;
+    }
     @Override
     public Map<Integer, QtyAmountModel> getCriteriaQtyAmounModelMap(CreateOfferRequest createOfferRequest, int fofoId) throws ProfitMandiBusinessException {
-        final Map<String, LocalDateTime> activatedImeisActivationDateMap;
         Map<Integer, QtyAmountModel> qtyAmountMap;
         if (createOfferRequest.getSchemeType().equals(OfferSchemeType.SELLIN)) {
             qtyAmountMap = getCriteriaQtyAmountModelMapForSellin(createOfferRequest, fofoId);
         } else {
             qtyAmountMap = getCriteriaQtyAmountModelMapForSelloutAndActivation(createOfferRequest, fofoId);
+        }
         LOGGER.info("Qty Amount Map {}", qtyAmountMap);
         return qtyAmountMap;
+    }
-    private Map<Integer, QtyAmountModel> getCriteriaQtyAmountModelMapForSellin(CreateOfferRequest createOfferRequest, int fofoId) throws ProfitMandiBusinessException {
+    private PayoutSlab findEligibleSlab(List<PayoutSlab> slabs, int achievedValue) {
-        Map<Integer, QtyAmountModel> criteriaQtyAmountMap = new HashMap<>();
+        PayoutSlab eligibleSlab = null;
-        List<ItemCriteriaPayout> itemCriteriaPayouts = createOfferRequest.getTargetSlabs().get(0).getItemCriteriaPayouts();
+        for (PayoutSlab slab : slabs) {
-        Map<Integer, ItemCriteriaPayout> itemCriteriaPayoutMap = itemCriteriaPayouts.stream().collect(Collectors.toMap(x -> x.getItemCriteria().getId(), x -> x));
+            if (slab.getOnwardsAmount() <= achievedValue) {
+                eligibleSlab = slab;
+            } else {
+                break;
+            }
+        }
+        return eligibleSlab;
+    }
-        Map<Integer, List<Order>> criteriaOrdersMap = offerRepository.getPartnerWiseSellin(fofoId, createOfferRequest, true);
+    private double calculateFinalPayout(PayoutSlab eligibleSlab, AmountType amountType,
+                                        int valueForPercentage, int valueForFixed) {
+        if (eligibleSlab == null) return 0;
+        eligibleSlab.setSelected(true);
+        float payoutRate = eligibleSlab.getPayoutAmount();
+        if (AmountType.PERCENTAGE.equals(amountType)) {
+            return (payoutRate * valueForPercentage) / 100;
+        } else if (AmountType.FIXED.equals(amountType)) {
+            return payoutRate * valueForFixed;
+        } else {
+            return payoutRate;
+        }
+    }
+    private QtyAmountModel calculateSellinQtyAndValue(List<Order> orders) {
+        int qty = orders.stream().collect(Collectors.summingInt(x ->
+                x.getLineItem().getQuantity() - x.getLineItem().getReturnQty()));
+        int value = orders.stream().collect(Collectors.summingInt(x ->
+                Math.round(x.getLineItem().getUnitPrice() *
+                        (x.getLineItem().getQuantity() - x.getLineItem().getReturnQty()))));
+        return new QtyAmountModel(qty, value);
+    }
-        List<Order> baseCriteriaOrders = null;
-        if (criteriaOrdersMap.get(0) != null && criteriaOrdersMap.get(0).size() > 0) {
+    private Map<Integer, QtyAmountModel> getCriteriaQtyAmountModelMapForSellin(CreateOfferRequest createOfferRequest, int fofoId) throws ProfitMandiBusinessException {
-            baseCriteriaOrders = criteriaOrdersMap.get(0);
+        Map<Integer, QtyAmountModel> criteriaQtyAmountMap = new HashMap<>();
-        }
+        Map<Integer, List<Order>> criteriaOrdersMap = offerRepository.getPartnerWiseSellin(fofoId, createOfferRequest, true);
+        List<Order> baseCriteriaOrders = criteriaOrdersMap.get(0);
         Integer userBaseQty = null;
         Integer userBaseValue = null;
-        if (baseCriteriaOrders != null) {
+        if (baseCriteriaOrders != null && baseCriteriaOrders.size() > 0) {
-            userBaseQty = baseCriteriaOrders.stream().collect(Collectors.summingInt(x -> (x.getLineItem().getQuantity() - x.getLineItem().getReturnQty())));
+            QtyAmountModel baseModel = calculateSellinQtyAndValue(baseCriteriaOrders);
+            userBaseQty = baseModel.getQty();
-            userBaseValue = baseCriteriaOrders.stream().collect(Collectors.summingInt(x ->
+            userBaseValue = (int) baseModel.getAmount();
-                    Math.round(x.getLineItem().getUnitPrice() * (x.getLineItem().getQuantity() - x.getLineItem().getReturnQty()))
+            criteriaQtyAmountMap.put(0, baseModel);
-            ));
+        } else {
-            criteriaQtyAmountMap.put(0, new QtyAmountModel(userBaseQty, userBaseValue));
+            criteriaQtyAmountMap.put(0, new QtyAmountModel(0, 0));
+        }
         LOGGER.info("Processing sellin");
         for (ItemCriteriaPayout itemCriteriaPayout : createOfferRequest.getTargetSlabs().get(0).getItemCriteriaPayouts()) {
             int criteriaId = itemCriteriaPayout.getItemCriteria().getId();
             QtyAmountModel qtyAmountModel = new QtyAmountModel(0, 0);
-            criteriaQtyAmountMap.put(itemCriteriaPayout.getItemCriteria().getId(), qtyAmountModel);
+            criteriaQtyAmountMap.put(criteriaId, qtyAmountModel);
             List<Order> orders = criteriaOrdersMap.get(criteriaId);
-            int totalQty = orders.stream().collect(Collectors.summingInt(x -> (x.getLineItem().getQuantity() - x.getLineItem().getReturnQty())));
-            int totalValue = orders.stream().collect(Collectors.summingInt(x -> Math.round(x.getLineItem().
+            if (orders == null || orders.isEmpty()) continue;
-                    getUnitPrice() * (x.getLineItem().getQuantity() - x.getLineItem().getReturnQty()))));
+            QtyAmountModel criteriaModel = calculateSellinQtyAndValue(orders);
-            int totalBaseQty = totalQty;
+            int totalBaseQty = criteriaModel.getQty();
-            int totalBaseValue = totalValue;
+            int totalBaseValue = (int) criteriaModel.getAmount();
-            criteriaQtyAmountMap.put(0, new QtyAmountModel(userBaseQty==null? 0 : userBaseQty, userBaseValue==null?0 : userBaseValue));
             if (userBaseQty != null) {
                 totalBaseQty = userBaseQty;
                 totalBaseValue = userBaseValue;
+            }
                 purchasedValue = totalBaseQty;
+            }
             qtyAmountModel.setQty(totalBaseQty);
             qtyAmountModel.setAmount(totalBaseValue);
-            PayoutSlab eligibleSlab = null;
-            for (PayoutSlab payoutSlab : itemCriteriaPayout.getPayoutSlabs()) {
+            PayoutSlab eligibleSlab = findEligibleSlab(itemCriteriaPayout.getPayoutSlabs(), purchasedValue);
-                if (payoutSlab.getOnwardsAmount() <= purchasedValue) {
-                    eligibleSlab = payoutSlab;
-                } else {
-                    break;
-                }
-            }
-            double finalPayout = 0;
-            if(eligibleSlab != null) {
-                eligibleSlab.setSelected(true);
-                float eligiblePayoutValue = eligibleSlab.getPayoutAmount();
-                if (AmountType.PERCENTAGE.equals(itemCriteriaPayout.getAmountType())) {
-                    finalPayout = (eligiblePayoutValue * purchasedValue) / 100;
-                } else if (AmountType.FIXED.equals(itemCriteriaPayout.getAmountType())) {
+            double finalPayout = calculateFinalPayout(eligibleSlab, itemCriteriaPayout.getAmountType(),
-                    finalPayout = eligiblePayoutValue * purchasedValue;
+                    purchasedValue, purchasedValue);
-                } else {
-                    finalPayout = eligiblePayoutValue;
-                }
-            }
             qtyAmountModel.setFinalPayout(finalPayout);
-            createOfferRequest.setCriteriaQtyAmountModel(criteriaQtyAmountMap);
+        }
         return criteriaQtyAmountMap;
+    }
     private Map<Integer, QtyAmountModel> getCriteriaQtyAmountModelMapForSelloutAndActivation(CreateOfferRequest createOfferRequest, int fofoId) {
             activatedImeisActivationDateMap = null;
+        }
         QtyAmountModel qtyAmountModel = null;
         if (createOfferRequest.isBaseCriteria()) {
+            Map<Integer, List<FofoOrderItem>> baseCriteriaMap = criteriaPartnerwiseTertiary.get(0);
-            List<FofoOrderItem> fofoOrderItems = criteriaPartnerwiseTertiary.get(0).get(fofoId);
+            List<FofoOrderItem> fofoOrderItems = baseCriteriaMap == null ? null : baseCriteriaMap.get(fofoId);
             int totalBaseQty = fofoOrderItems == null ? 0 : fofoOrderItems.stream().filter(x->createOfferRequest.isWithinRange(x.getCreateTimestamp())).collect(Collectors.summingInt(x -> (x.getQuantity())));
             int totalBaseValue = fofoOrderItems == null ? 0 : fofoOrderItems.stream().filter(x->createOfferRequest.isWithinRange(x.getCreateTimestamp())).mapToInt(x -> (Math.round(x.getDp())) * x.getQuantity()).sum();
             qtyAmountModel = new QtyAmountModel(totalBaseQty, totalBaseValue);
             if (createOfferRequest.getSchemeType().equals(OfferSchemeType.ACTIVATION)) {
                 Map<Integer, Integer> inventoryItemValueMap = new HashMap<>();
+                if (fofoOrderItems != null) {
-                for (FofoOrderItem fofoOrderItem : fofoOrderItems) {
+                    for (FofoOrderItem fofoOrderItem : fofoOrderItems) {
-                    fofoOrderItem.getFofoLineItems().stream().filter(x -> x.getSerialNumber() != null).forEach(
+                        fofoOrderItem.getFofoLineItems().stream().filter(x -> x.getSerialNumber() != null).forEach(
-                            lineItem -> {
+                                lineItem -> {
-                                if (activatedImeisActivationDateMap == null || activatedImeisActivationDateMap.containsKey(lineItem.getSerialNumber())) {
+                                    if (activatedImeisActivationDateMap == null || activatedImeisActivationDateMap.containsKey(lineItem.getSerialNumber())) {
-                                    inventoryItemValueMap.put(lineItem.getInventoryItemId(), (int) fofoOrderItem.getDp());
+                                        inventoryItemValueMap.put(lineItem.getInventoryItemId(), (int) fofoOrderItem.getDp());
+                                    }
+                                }
-                            }
+                        );
-                    );
+                    }
+                }
                 qtyAmountModel.setActivationQty(inventoryItemValueMap.size());
                 qtyAmountModel.setActivationAmount(inventoryItemValueMap.entrySet().stream().collect(Collectors.summingInt(x -> x.getValue())));
                 qtyAmountMap.put(0, qtyAmountModel);
+            }
+        }
-        //As of now eligible sale is considered to be without special criteria like brand/
         //CriteriaPayoutWise
         for (ItemCriteriaPayout itemCriteriaPayout : createOfferRequest.getTargetSlabs().get(0).getItemCriteriaPayouts()) {
             int criteriaId = itemCriteriaPayout.getItemCriteria().getId();
             Map<Integer, List<FofoOrderItem>> ordersMap = criteriaPartnerwiseTertiary.get(criteriaId);
-            //Partywise iteration
-            QtyAmountModel qtyAmountModel1 = new QtyAmountModel(0, 0);
-            qtyAmountMap.put(criteriaId, qtyAmountModel1);
-            List<FofoOrderItem> fofoOrderItems = ordersMap.get(fofoId) == null ? null : ordersMap.get(fofoId);
-            if (fofoOrderItems != null && fofoOrderItems.size() > 0) {
-                int totalQty = fofoOrderItems.stream().collect(Collectors.summingInt(x -> (x.getQuantity())));
-                int totalValue = fofoOrderItems.stream().collect(Collectors.summingInt(x -> Math.round(x.getDp()) * (x.getQuantity())));
-                int eligibleQty = totalQty;
-                int eligibleValue = totalValue;
-                qtyAmountModel1.setQty(totalQty);
-                qtyAmountModel1.setAmount(totalValue);
-                Map<FofoLineItem, Integer> lineItemValueMap = new HashMap<>();
-                if (createOfferRequest.getSchemeType().equals(OfferSchemeType.ACTIVATION)) {
-                    for (FofoOrderItem fofoOrderItem : fofoOrderItems) {
-                        fofoOrderItem.getFofoLineItems().stream().filter(x -> x.getSerialNumber() != null).forEach(
-                                lineItem -> {
-                                    if (activatedImeisActivationDateMap == null) {
-                                        lineItemValueMap.put(lineItem, (int) fofoOrderItem.getDp());
-                                    } else if (activatedImeisActivationDateMap.containsKey(lineItem.getSerialNumber())) {
-                                        if (itemCriteriaPayout.isWithinRange(activatedImeisActivationDateMap.get(lineItem.getSerialNumber()))) {
-                                            lineItemValueMap.put(lineItem, (int) fofoOrderItem.getDp());
-                                        }
-                                    }
-                                }
-                        );
-                    }
-                    eligibleQty = lineItemValueMap.size();
-                    eligibleValue = lineItemValueMap.entrySet().stream().collect(Collectors.summingInt(x -> x.getValue()));
-                    qtyAmountModel1.setActivationQty(eligibleQty);
-                    qtyAmountModel1.setActivationAmount(eligibleValue);
-                }
-                qtyAmountMap.put(criteriaId, qtyAmountModel1);
-                int eligibleBaseQty = eligibleQty;
-                int eligibleBaseValue = eligibleValue;
-                if (createOfferRequest.isBaseCriteria()) {
-                    eligibleBaseQty = qtyAmountModel.getActivationQty();
+            QtyAmountModel criteriaQtyAmountModel = new QtyAmountModel(0, 0);
-                    eligibleBaseValue = (int) qtyAmountModel.getActivationAmount();
+            qtyAmountMap.put(criteriaId, criteriaQtyAmountModel);
-                }
+            if (ordersMap == null) continue;
-                int eligibleSale = eligibleBaseValue;
-                int eligibleCriteriaSale = eligibleValue;
-                int eligibleCriteriaSaleDp = eligibleValue;
+            List<FofoOrderItem> fofoOrderItems = ordersMap.get(fofoId);
-                if (createOfferRequest.getTargetType().equals(AchievementType.QUANTITY)) {
+            if (fofoOrderItems == null || fofoOrderItems.isEmpty()) continue;
-                    eligibleSale = eligibleBaseQty;
-                    eligibleCriteriaSale = eligibleQty;
-                }
+            int totalQty = fofoOrderItems.stream().collect(Collectors.summingInt(x -> (x.getQuantity())));
+            int totalValue = fofoOrderItems.stream().collect(Collectors.summingInt(x -> Math.round(x.getDp()) * (x.getQuantity())));
-                float eligiblePayoutValue = 0;
+            int eligibleQty = totalQty;
-                double finalPayout = 0;
+            int eligibleValue = totalValue;
+            criteriaQtyAmountModel.setQty(totalQty);
+            criteriaQtyAmountModel.setAmount(totalValue);
-                PayoutSlab eligibleSlab = null;
+            Map<FofoLineItem, Integer> lineItemValueMap = new HashMap<>();
-                for (PayoutSlab slab : itemCriteriaPayout.getPayoutSlabs()) {
+            if (createOfferRequest.getSchemeType().equals(OfferSchemeType.ACTIVATION)) {
-                    if (slab.getOnwardsAmount() <= eligibleSale) {
+                for (FofoOrderItem fofoOrderItem : fofoOrderItems) {
-                        eligibleSlab = slab;
+                    fofoOrderItem.getFofoLineItems().stream().filter(x -> x.getSerialNumber() != null).forEach(
-                    } else {
+                            lineItem -> {
-                        break;            // slabs beyond this don't qualify
+                                if (activatedImeisActivationDateMap == null) {
+                                    lineItemValueMap.put(lineItem, (int) fofoOrderItem.getDp());
+                                } else if (activatedImeisActivationDateMap.containsKey(lineItem.getSerialNumber())) {
+                                    if (itemCriteriaPayout.isWithinRange(activatedImeisActivationDateMap.get(lineItem.getSerialNumber()))) {
+                                        lineItemValueMap.put(lineItem, (int) fofoOrderItem.getDp());
-                    }
+                                    }
-                }
+                                }
-                if(eligibleSlab != null) {
+                            }
-                    eligibleSlab.setSelected(true);
+                    );
-                    LOGGER.info("Eligible Slab {}", eligibleSlab);
+                }
+                eligibleQty = lineItemValueMap.size();
+                eligibleValue = lineItemValueMap.entrySet().stream().collect(Collectors.summingInt(x -> x.getValue()));
+                criteriaQtyAmountModel.setActivationQty(eligibleQty);
+                criteriaQtyAmountModel.setActivationAmount(eligibleValue);
+            }
-                if (AmountType.PERCENTAGE.equals(itemCriteriaPayout.getAmountType())) {
-                    finalPayout = (eligiblePayoutValue * eligibleCriteriaSaleDp) / 100;
+            int eligibleBaseQty = eligibleQty;
-                } else if (AmountType.FIXED.equals(itemCriteriaPayout.getAmountType())) {
-                    finalPayout = eligiblePayoutValue * eligibleCriteriaSale;
+            int eligibleBaseValue = eligibleValue;
-                } else {
-                    finalPayout = eligiblePayoutValue;
+            if (createOfferRequest.isBaseCriteria()) {
-                }
-                qtyAmountModel1.setFinalPayout(finalPayout);
+                eligibleBaseQty = qtyAmountModel.getActivationQty();
-                LOGGER.info("Final Payout - {}", finalPayout);
+                eligibleBaseValue = (int) qtyAmountModel.getActivationAmount();
+            }
+            int eligibleSale = eligibleBaseValue;
+            int eligibleCriteriaSale = eligibleValue;
+            int eligibleCriteriaSaleDp = eligibleValue;
+            if (createOfferRequest.getTargetType().equals(AchievementType.QUANTITY)) {
+                eligibleSale = eligibleBaseQty;
+                eligibleCriteriaSale = eligibleQty;
+            }
+            PayoutSlab eligibleSlab = findEligibleSlab(itemCriteriaPayout.getPayoutSlabs(), eligibleSale);
+            double finalPayout = calculateFinalPayout(eligibleSlab, itemCriteriaPayout.getAmountType(),
+                    eligibleCriteriaSaleDp, eligibleCriteriaSale);
+            if (eligibleSlab != null) {
+                LOGGER.info("Eligible Slab {}", eligibleSlab);
+            }
+            criteriaQtyAmountModel.setFinalPayout(finalPayout);
+            LOGGER.info("Final Payout - {}", finalPayout);
+        }
         return qtyAmountMap;
+    }
     @Override

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/offers/OfferServiceImpl.java – Rev 35595 → 35667