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

         return rollout;
+    }
     @Override
     public void processActivationtOffer(CreateOfferRequest createOfferRequest) throws ProfitMandiBusinessException {
-        //List<OfferRowModel> offerRowModels = new ArrayList<>();
         List<OfferPayout> offerPayouts = offerPayoutRepository.selectAllByOfferId(createOfferRequest.getId());
         List<ItemCriteriaPayout> itemCriteriaPayouts = createOfferRequest.getTargetSlabs().get(0).getItemCriteriaPayouts();
         Map<Integer, ItemCriteriaPayout> itemCriteriaPayoutMap = itemCriteriaPayouts.stream().collect(Collectors.toMap(x -> x.getItemCriteria().getId(), x -> x));
         LOGGER.info("itemCriteriaPayoutMap {}", itemCriteriaPayoutMap);
         LOGGER.info("offerPayouts {}", offerPayouts);
         Map<Integer, Map<Integer, Double>> fixedSlabCriteriaPartnerMap = offerPayouts.stream().filter(x -> itemCriteriaPayoutMap.get((int) x.getCriteriaId()).getAmountType().equals(AmountType.SLAB_FIXED))
                 .collect(Collectors.groupingBy(x -> (int) x.getCriteriaId(), Collectors.groupingBy(x -> (int) x.getFofoId(), Collectors.summingDouble(x -> x.getSlabAmount()))));
         Map<String, Double> serialNumberPaid = offerPayouts.stream().filter(x -> x.getRejectTimestamp() == null).collect(Collectors.groupingBy(x -> x.getSerialNumber(), Collectors.summingDouble(x -> x.getSlabAmount())));
-        /*if (offerPayouts.size() > 0) {
-            throw new ProfitMandiBusinessException("Offer Already Processed", "Offer Already Processed", "Offer Already Processed");
-        }*/
         Map<Integer, Map<Integer, List<FofoOrderItem>>> criteriaPartnerwiseTertiary = offerRepository.getCriteriaWisePartnerTertiary(createOfferRequest);
         final Set<String> activatedImeis;
-        final Set<String> missingImeis;
         if (createOfferRequest.getSchemeType().equals(OfferSchemeType.ACTIVATION)) {
             //All Serialnumbers for all eligible retailers
             List<String> serialNumbers = criteriaPartnerwiseTertiary.entrySet().stream().flatMap(x -> x.getValue().entrySet().stream().flatMap(foiList -> foiList.getValue().stream()))
                     .flatMap(y -> y.getFofoLineItems().stream()).filter(fli -> fli.getSerialNumber() != null)
                     .map(x -> x.getSerialNumber()).collect(Collectors.toList());
             if (serialNumbers.size() > 0) {
                 activatedImeis = activatedImeiRepository.selectBySerialNumbers(serialNumbers).stream()
                         .filter(x -> createOfferRequest.isWithinRange(x.getActivationTimestamp()))
                         .map(x -> x.getSerialNumber()).collect(Collectors.toSet());
-                //missingImeis = serialNumbers.stream().filter(x -> !activatedImeis.contains(x)).collect(Collectors.toSet());
-                //activatedImeis.addAll(missingImeis);
-                //serialNumbers.removeAll(activatedImeis);
             } else {
                 activatedImeis = null;
+            }
-            // TODO Amit
-            /**
-             * Missing imeis are considered as activated as long as payout calculations are
-             * concerned - Add flag if calculations are meant for final payout(Wherein
-             * missing imeis are no longer considered to be activated)
-             **/
         } else {
             activatedImeis = null;
+        }
         Map<Integer, Integer> userBaseQtyMap = new HashMap<>();
+                }
+            }
+        }
-        //Map<Integer, Double> totalPurchaseValueMap = null;
-        if (createOfferRequest.getSellinPercentage() > 0) {
-			/*List<Order> purchaseOrders = orderRepository.selectOrdersBetweenDates(fofoIds, "billingTimestamp",
-					createOfferRequest.getStartDate(), createOfferRequest.getEndDate());
-			Map<Integer, Double> totalPurchaseValueMap = purchaseOrders.stream().collect(
-					Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingDouble(x -> x.getWalletAmount())));*/
-        }
         //As of now eligible sale is considered to be without special criteria like brand/
         for (ItemCriteriaPayout itemCriteriaPayout : createOfferRequest.getTargetSlabs().get(0).getItemCriteriaPayouts()) {
             int criteriaId = itemCriteriaPayout.getItemCriteria().getId();
             Map<Integer, List<FofoOrderItem>> ordersMap = criteriaPartnerwiseTertiary.get(criteriaId);
+        }
         Offer offer = offerRepository.selectById(createOfferRequest.getId());
         offer.setProcessedTimestamp(LocalDateTime.now());
+    }
+    private void extracted(CreateOfferRequest createOfferRequest, Map<String, Double> serialNumberPaid, ItemCriteriaPayout itemCriteriaPayout, int criteriaId, double totalRolloutAmount, int fofoId, Map<FofoLineItem, Integer> lineItemValueMap, float eligiblePayoutValue) throws ProfitMandiBusinessException {
+        List<Integer> inventoryItemIds = lineItemValueMap.keySet().stream().map(x -> x.getInventoryItemId()).collect(Collectors.toList());
+        Map<Integer, InventoryItem> inventoryItemsMap = inventoryItemRepository.selectAllByIds(inventoryItemIds).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
+        for (Map.Entry<FofoLineItem, Integer> lineItemValueEntry : lineItemValueMap.entrySet()) {
+            double amount = 0;
+            int totalDpValue = lineItemValueMap.values().stream().collect(Collectors.summingInt(x -> x));
+            LOGGER.info("Total DP Value {}", totalDpValue);
+            if (AmountType.SLAB_FIXED.equals(itemCriteriaPayout.getAmountType())) {
+                amount = (eligiblePayoutValue * lineItemValueEntry.getValue()) / totalDpValue;
+                LOGGER.info("Amount - {}", amount);
+                //Fixed slab should be treated as fixed after payout
+            } else {
+                amount = eligiblePayoutValue;
+                //Fixed slab has already taken care of that amount;
+                if (serialNumberPaid.containsKey(lineItemValueEntry.getKey().getSerialNumber())) {
+                    amount = amount - serialNumberPaid.get(lineItemValueEntry.getKey().getSerialNumber());
+                }
+            }
+            LOGGER.info("Amount - {}", amount);
+            //ignore reasonably small
+            if (amount < Utils.DOUBLE_EPSILON) continue;
+            AmountModel amountModel = new AmountModel();
+            amountModel.setAmountType(itemCriteriaPayout.getAmountType());
+            amountModel.setAmount(amount);
+            amountModel.setDiscount(createOfferRequest.isDiscount());
+            InventoryPayoutModel inventoryPayoutModel = priceCircularService.getPayouts(inventoryItemsMap.get(lineItemValueEntry.getKey().getInventoryItemId()));
+            double rolloutAmount = inventoryPayoutModel.getRolloutAmount(amountModel);
+            totalRolloutAmount += rolloutAmount;
+            OfferPayout offerPayout = new OfferPayout(fofoId, createOfferRequest.getId(), criteriaId, amount, lineItemValueEntry.getKey().getSerialNumber(), rolloutAmount, SchemePayoutStatus.CREDITED, createOfferRequest.getDescription(), LocalDateTime.now());
+            //offerPayout.setInventoryItemId(inventoryItemSaleModelsMap.get(lineItemValueEntry.getKey().getInventoryItemId()));
+            offerPayoutRepository.persist(offerPayout);
+        }
+        walletService.addAmountToWallet((int) fofoId, createOfferRequest.getId(), WalletReferenceType.ADDITIONAL_SCHEME, createOfferRequest.getDescription(), (float) totalRolloutAmount, LocalDateTime.now());
+    }
     @Override
     public void processSellin(CreateOfferRequest createOfferRequest) throws Exception {
         //List<OfferRowModel> offerRowModels = new ArrayList<>();
         List<OfferPayout> offerPayouts = offerPayoutRepository.selectAllByOfferId(createOfferRequest.getId());
         LOGGER.info("Processing sellin");
         List<OfferPayout> offerPayoutsNew = new ArrayList<>();
         for (ItemCriteriaPayout itemCriteriaPayout : createOfferRequest.getTargetSlabs().get(0).getItemCriteriaPayouts()) {
             int criteriaId = itemCriteriaPayout.getItemCriteria().getId();
-            LOGGER.info("Criteria Id - {}", criteriaId);
             Map<Integer, List<Order>> ordersMap = criteriaOrdersMap.get(criteriaId).entrySet().stream()
                     .filter(x -> !fofoIds.contains(x.getKey())).collect(Collectors.toMap(x -> x.getKey(), x -> x.getValue()));
             for (Map.Entry<Integer, List<Order>> orderEntry : ordersMap.entrySet()) {
                 int fofoId = orderEntry.getKey();
                 //CustomRetailer retailer = retailerService.getAllFofoRetailers().get(fofoId);
                 List<Order> orders = orderEntry.getValue();
                 Set<String> returnedSerialNumbers = orders.stream().filter(x -> x.getSerialNumber() != null).flatMap(x -> x.getReturnedImeis().stream()).collect(Collectors.toSet());
                 int totalQty = orders.stream().collect(Collectors.summingInt(x -> (x.getLineItem().getQuantity() - x.getLineItem().getReturnQty())));
-                LOGGER.info("LineItems = {}", orders.stream().map(x -> x.getLineItem().getId()).collect(Collectors.toList()));
                 int totalValue = orders.stream().collect(Collectors.summingInt(x -> Math.round(x.getLineItem().
                         getUnitPrice() * (x.getLineItem().getQuantity() - x.getLineItem().getReturnQty()))));
                 int totalBaseQty = totalQty;
                 int totalBaseValue = totalValue;
                 if (userBaseCriteriaOrdersMap != null) {
                     purchasedValue = totalBaseQty;
+                }
                 PayoutSlab currentSlab = itemCriteriaPayout.getPayoutSlabs().stream()
                         .filter(x -> x.getOnwardsAmount() <= purchasedValue).max(Comparator.comparing(x
                                 -> x.getOnwardsAmount())).orElse(null);
-                int targetAchieved = currentSlab ==
-                        null ? 0 : currentSlab.getOnwardsAmount();
                 //TODO-- payouts handling is here
                 if (currentSlab == null) continue;
                 //Need to remove hardcoding on tax
                 List<Integer> orderIds = orders.stream().map(x -> x.getId()).collect(Collectors.toList());
                 Map<String, LineItem> serialNumberMap = lineItemImeisRepository.selectByLineItemIds(new ArrayList<>(lineItemMap.keySet()))
                         .stream().collect(Collectors.toMap(x -> x.getSerialNumber(), x -> lineItemMap.get(x.getLineItemId()), (x1, x2) -> x1.getId() > x2.getId() ? x1 : x2));
                 serialNumberMap = serialNumberMap.entrySet().stream().filter(x -> serialNumbers.contains(x.getKey())).collect(Collectors.toMap(x -> x.getKey(), x -> x.getValue()));
+                Map<String, InventoryItem> serialNumberInventoryItemMap = this.getInventoryItemMap(fofoId, serialNumberMap);
+                //Continue if all imeis havent been grned
+                if(serialNumberInventoryItemMap.size() < serialNumberCountMap.size()) continue;
                 LOGGER.info("serialNumberMap {}", serialNumberMap);
                 double amount = 0;
                 int lineItemsValue = serialNumberMap.values().stream().collect(Collectors.summingInt(x -> x.getUnitPrice().intValue()));
                 LOGGER.info("lineItemsValue - {}, totalValue - {}", lineItemsValue, totalValue);
                 for (Map.Entry<String, LineItem> entry : serialNumberMap.entrySet()) {
                         LOGGER.info("Serial no - {}, unitPrice - {}, amount - {}", entry.getKey(), lineItem.getUnitPrice(), amount);
                     } else {
                         //per unit amount
                         amount = currentSlab.getPayoutAmount();
+                    }
+                    AmountModel amountModel = new AmountModel();
+                    amountModel.setAmountType(itemCriteriaPayout.getAmountType());
+                    amountModel.setAmount(amount);
+                    amountModel.setDiscount(createOfferRequest.isDiscount());
+                    InventoryPayoutModel inventoryPayoutModel = priceCircularService.getPayouts(serialNumberInventoryItemMap.get(entry.getKey()));
+                    double rolloutAmount = inventoryPayoutModel.getRolloutAmount(amountModel);
                     if (fofoIds.contains(Long.valueOf(fofoId))) continue;
-                    OfferPayout offerPayout = new OfferPayout(fofoId, createOfferRequest.getId(), criteriaId, currentSlab.getPayoutAmount(), entry.getKey(), amount, SchemePayoutStatus.CREDITED, createOfferRequest.getDescription(), LocalDateTime.now());
+                    OfferPayout offerPayout = new OfferPayout(fofoId, createOfferRequest.getId(), criteriaId, currentSlab.getPayoutAmount(), entry.getKey(), rolloutAmount, SchemePayoutStatus.CREDITED, createOfferRequest.getDescription(), LocalDateTime.now());
                     //offerPayout.setLineItemId();
                     offerPayoutRepository.persist(offerPayout);
                     offerPayoutsNew.add(offerPayout);
+                }
+            }
+        }
         Map<Long, Double> offerPayoutMap = offerPayoutsNew.stream().collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.summingDouble(x -> x.getAmount())));
         for (Map.Entry<Long, Double> offerPayoutEntry : offerPayoutMap.entrySet()) {
             long fofoId = offerPayoutEntry.getKey();
             walletService.addAmountToWallet((int) fofoId, createOfferRequest.getId(), WalletReferenceType.ADDITIONAL_SCHEME, createOfferRequest.getDescription(), (float) amountToCredit, LocalDateTime.now());
+        }
         Offer offer = offerRepository.selectById(createOfferRequest.getId());
         offer.setProcessedTimestamp(LocalDateTime.now());
+    }
+    private Map<String, InventoryItem> getInventoryItemMap(int fofoId, Map<String, LineItem> serialNumberMap) {
+        List<InventoryItem> inventoryItems = inventoryItemRepository.selectBySerialNumbers(serialNumberMap.keySet());
+        inventoryItems = inventoryItems.stream().filter(x->x.getFofoId()== fofoId).collect(Collectors.toList());
+        Map<String,InventoryItem> inventoryItemMap = inventoryItems.stream().collect(Collectors.toMap(x->x.getSerialNumber(), x->x, (u,v)->v.getCreateTimestamp().isAfter(u.getCreateTimestamp()) ? v : u));
+        return inventoryItemMap;
+    }
+}

Subversion Repositories SmartDukaan

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