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

 import com.spice.profitmandi.dao.entity.warehouse.WarehouseScan;
 import com.spice.profitmandi.dao.enumuration.catalog.AchievementType;
 import com.spice.profitmandi.dao.enumuration.catalog.AmountType;
 import com.spice.profitmandi.dao.enumuration.catalog.OfferSchemeType;
 import com.spice.profitmandi.dao.enumuration.transaction.SchemePayoutStatus;
-import com.spice.profitmandi.dao.model.AmountModel;
+import com.spice.profitmandi.dao.model.*;
-import com.spice.profitmandi.dao.model.CreateOfferRequest;
-import com.spice.profitmandi.dao.model.ItemCriteriaPayout;
-import com.spice.profitmandi.dao.model.OfferRowModel;
 import com.spice.profitmandi.dao.repository.catalog.*;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.fofo.ActivatedImeiRepository;
 import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
 import com.spice.profitmandi.dao.repository.fofo.OfferPayoutRepository;
 import java.util.stream.Collectors;
 @Component
 public class OfferServiceImpl implements OfferService {
+    private static final Logger LOGGER = LogManager.getLogger(OfferServiceImpl.class);
+    // Constants
-    private static final List<String> targets = Arrays.asList("Target 1", "Target 2", "Target 3", "Target 4",
+    private static final List<String> TARGETS = Arrays.asList("Target 1", "Target 2", "Target 3", "Target 4", "Target 5");
-            "Target 5");
+    private static final int STOCK_AGEING_THRESHOLD_DAYS = 300;
+    // Dependencies - Core
     @Autowired
     private Gson gson;
     @Autowired
-    NotificationService notificationService;
+    private CacheManager oneDayCacheManager;
+    // Dependencies - Repositories
     @Autowired
     private OfferRepository offerRepository;
     @Autowired
-    private RetailerService retailerService;
+    private OfferPayoutRepository offerPayoutRepository;
-    @Autowired
-    PriceCircularService priceCircularService;
     @Autowired
-    OfferPayoutRepository offerPayoutRepository;
+    private OfferTargetSlabRepository offerTargetSlabRepository;
     @Autowired
     private ItemCriteriaRepository itemCriteriaRepository;
     @Autowired
     @Autowired
     private TagListingRepository tagListingRepository;
     @Autowired
-    private OfferTargetSlabRepository offerTargetSlabRepository;
-    @Autowired
     private FofoStoreRepository fofoStoreRepository;
     @Autowired
-    CacheManager oneDayCacheManager;
-    private static final Logger LOGGER = LogManager.getLogger(OfferServiceImpl.class);
-    @Autowired
     private ActivatedImeiRepository activatedImeiRepository;
     @Autowired
     private WarehouseScanRepository warehouseScanRepository;
     @Autowired
     private WarehouseInventoryItemRepository warehouseInventoryItemRepository;
     @Autowired
     private LineItemImeisRepository lineItemImeisRepository;
     @Autowired
     private InventoryItemRepository inventoryItemRepository;
+    @Autowired
+    private OfferEligibleImeiRepository offerEligibleImeiRepository;
+    // Dependencies - Services
+    @Autowired
+    private NotificationService notificationService;
+    @Autowired
+    private RetailerService retailerService;
+    @Autowired
+    private PriceCircularService priceCircularService;
+    @Autowired
+    private WalletService walletService;
     @Override
     public void addOfferService(CreateOfferRequest createOfferRequest) throws ProfitMandiBusinessException {
         LOGGER.info("createOfferRequest  -- {}", createOfferRequest);
         this.createOffer(createOfferRequest);
         this.createTargetSlabs(createOfferRequest);
         createOfferRequest.setId(offer.getId());
+    }
     @Override
     public List<CreateOfferRequest> getPublishedOffers(int fofoId, YearMonth yearMonth) throws ProfitMandiBusinessException {
-        List<Offer> publishedOffers = offerRepository.selectAllPublishedMapByPartner(yearMonth).get(fofoId);
+        Map<Integer, List<Offer>> publishedMapByPartner = offerRepository.selectAllPublishedMapByPartner(yearMonth);
+        List<Offer> publishedOffers = publishedMapByPartner != null ? publishedMapByPartner.get(fofoId) : null;
         List<CreateOfferRequest> createOfferRequests = new ArrayList<>();
         if (publishedOffers != null) {
             for (Offer offer : publishedOffers) {
                 CreateOfferRequest createOfferRequest = this.getCreateOfferRequest(offer);
                 createOfferRequests.add(createOfferRequest);
+    }
     private void setCriteriaPayoutAchieved(int fofoId, CreateOfferRequest createOfferRequest) {
         Map<Integer, Long> criteriaTransactionMap = null;
         if (createOfferRequest.getSchemeType().equals(OfferSchemeType.SELLIN)) {
-            criteriaTransactionMap = offerRepository.getPartnerWisePurchaseSum(createOfferRequest).get(fofoId);
+            Map<Integer, Map<Integer, Long>> partnerWiseMap = offerRepository.getPartnerWisePurchaseSum(createOfferRequest);
+            criteriaTransactionMap = partnerWiseMap != null ? partnerWiseMap.get(fofoId) : null;
         } else {
-            criteriaTransactionMap = offerRepository.getPartnerWiseSalesSum(createOfferRequest).get(fofoId);
+            Map<Integer, Map<Integer, Long>> partnerWiseMap = offerRepository.getPartnerWiseSalesSum(createOfferRequest);
+            criteriaTransactionMap = partnerWiseMap != null ? partnerWiseMap.get(fofoId) : null;
+        }
         LOGGER.info("I am here ------- {}", createOfferRequest.getId());
         List<com.spice.profitmandi.dao.model.ItemCriteriaPayout> itemCriteriaPayouts = createOfferRequest
                 .getTargetSlabs().get(0).getItemCriteriaPayouts();
     @Cacheable(value = "partnerOffers", cacheManager = "thirtyMinsTimeOutCacheManager")
     public CreateOfferRequest getOffer(int fofoId, int offerId) throws ProfitMandiBusinessException {
         Offer offer = offerRepository.selectById(offerId);
         CreateOfferRequest createOfferRequest = this.getCreateOfferRequest(offer);
         if (fofoId > 0) {
-            this.setCriteriaPayoutAchieved(fofoId, createOfferRequest);
+            createOfferRequest.setCriteriaQtyAmountModel(this.getCriteriaQtyAmounModelMap(createOfferRequest, fofoId));
+        }
         return createOfferRequest;
+    }
         for (com.spice.profitmandi.dao.model.ItemCriteriaPayout itemCriteriaPayout : createOfferRequest.getTargetSlabs()
                 .get(0).getItemCriteriaPayouts()) {
             itemCriteriaPayout.setNextSlab(itemCriteriaPayout.getPayoutSlabs().get(0));
+        }
         return createOfferRequest;
+    }
-    @Autowired
-    private WalletService walletService;
     @Override
     public void reverseAdditionalSelloutSchemes(List<InventoryItem> inventoryItems, String reversalReason) throws ProfitMandiBusinessException {
         Map<Integer, List<InventoryItem>> fofoInventoryItemsMap = inventoryItems.stream().collect(Collectors.groupingBy(x -> x.getFofoId()));
         for (Map.Entry<Integer, List<InventoryItem>> fofoInventoryItemsEntry : fofoInventoryItemsMap.entrySet()) {
             int fofoId = fofoInventoryItemsEntry.getKey();
             List<InventoryItem> partnerInventoryItems = fofoInventoryItemsEntry.getValue();
             List<OfferPayout> offerPayouts = new ArrayList<>();
             LOGGER.info("Reversing schemes for fofoId {}, InventoryItems {}", fofoId, inventoryItems);
             //As of now we are not handling non-serialised items
-            inventoryItems = inventoryItems.stream().filter(x -> x.getSerialNumber() != null).collect(Collectors.toList());
+            List<InventoryItem> serializedItems = partnerInventoryItems.stream().filter(x -> x.getSerialNumber() != null).collect(Collectors.toList());
-            if (inventoryItems.size() > 0) {
+            if (serializedItems.size() > 0) {
-                for (InventoryItem inventoryItem : inventoryItems) {
+                // Batch fetch: collect all serial numbers and fetch in one call per fofoId
+                Set<String> serialNumbers = serializedItems.stream().map(InventoryItem::getSerialNumber).collect(Collectors.toSet());
-                    offerPayouts.addAll(offerPayoutRepository.selectAllBySerialNumber(inventoryItem.getFofoId(), inventoryItem.getSerialNumber())
+                offerPayouts = offerPayoutRepository.selectAllBySerialNumbers(fofoId, serialNumbers)
-                            .stream()
+                        .stream()
-                            .filter(x -> x.getRejectTimestamp() == null)
+                        .filter(x -> x.getRejectTimestamp() == null)
-                            .collect(Collectors.toList()));
+                        .collect(Collectors.toList());
-                }
                 for (OfferPayout offerPayout : offerPayouts) {
                     offerPayout.setStatus(SchemePayoutStatus.REJECTED);
                     offerPayout.setRejectTimestamp(LocalDateTime.now());
+                }
                 Map<Long, Double> offerPayoutAmountMap = offerPayouts.stream().collect(Collectors.groupingBy(x -> x.getOfferId(), Collectors.summingDouble(x -> x.getAmount())));
+    }
     private void createTargetSlabs(CreateOfferRequest createOfferRequest) throws ProfitMandiBusinessException {
         List<com.spice.profitmandi.dao.model.TargetSlab> targetSlabs = createOfferRequest.getTargetSlabs().stream()
                 .filter(x -> x.validate()).collect(Collectors.toList());
-        if (targetSlabs.size() >= 0) {
+        if (!targetSlabs.isEmpty()) {
             Collections.sort(targetSlabs);
             for (com.spice.profitmandi.dao.model.TargetSlab targetSlab : targetSlabs) {
                 if (targetSlab.validate()) {
                     List<ItemCriteriaPayout> itemCriteriaPayouts = targetSlab.getItemCriteriaPayouts();
                     for (ItemCriteriaPayout itemCriteriaPayout : itemCriteriaPayouts) {
+    }
     @Override
     public List<CreateOfferRequest> getPublishedOffers(LocalDate date, int fofoId, int catalogId) throws ProfitMandiBusinessException {
-        List<Offer> publishedOffers = offerRepository.selectAllPublishedMapByPartner(YearMonth.from(date)).get(fofoId);
+        Map<Integer, List<Offer>> publishedMapByPartner = offerRepository.selectAllPublishedMapByPartner(YearMonth.from(date));
+        List<Offer> publishedOffers = publishedMapByPartner != null ? publishedMapByPartner.get(fofoId) : null;
         List<CreateOfferRequest> createOfferRequests = new ArrayList<>();
         if (publishedOffers != null) {
             for (Offer offer : publishedOffers) {
                 boolean found = false;
                 List<com.spice.profitmandi.dao.model.TargetSlab> targetSlabs = offerTargetSlabRepository
     private void printIterator(XSSFSheet sheet) {
         Iterator<Row> rowIterator = sheet.iterator();
         while (rowIterator.hasNext()) {
             Row row = rowIterator.next();
-            // For each row, iterate through all the columns
+            StringBuilder rowContent = new StringBuilder();
             Iterator<Cell> cellIterator = row.cellIterator();
             while (cellIterator.hasNext()) {
                 Cell cell = cellIterator.next();
-                // Check the cell type and format accordingly
                 switch (cell.getCellType()) {
                     case Cell.CELL_TYPE_NUMERIC:
-                        System.out.print(cell.getNumericCellValue() + "t");
+                        rowContent.append(cell.getNumericCellValue()).append("\t");
                         break;
                     case Cell.CELL_TYPE_STRING:
-                        System.out.print(cell.getStringCellValue() + "t");
+                        rowContent.append(cell.getStringCellValue()).append("\t");
                         break;
+                }
+            }
-            System.out.println("");
+            LOGGER.debug("Row content: {}", rowContent);
+        }
+    }
     @Override
     public Map<Integer, CreateOfferRequest> getPublishedOffers(LocalDate date, int fofoId, String brand) {
             rollout = amountModel.getAmount() * (100 / (100 + inventoryPayoutModel.getPercentageAmount()));
+        }
         return rollout;
+    }
-    @Autowired
+    @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 {
+        Map<Integer, QtyAmountModel> criteriaQtyAmountMap = new HashMap<>();
+        List<ItemCriteriaPayout> itemCriteriaPayouts = createOfferRequest.getTargetSlabs().get(0).getItemCriteriaPayouts();
+        Map<Integer, ItemCriteriaPayout> itemCriteriaPayoutMap = itemCriteriaPayouts.stream().collect(Collectors.toMap(x -> x.getItemCriteria().getId(), x -> x));
+        Map<Integer, List<Order>> criteriaOrdersMap = offerRepository.getPartnerWiseSellin(fofoId, createOfferRequest, true);
+        List<Order> baseCriteriaOrders = null;
+        if (criteriaOrdersMap.get(0) != null && criteriaOrdersMap.get(0).size() > 0) {
+            baseCriteriaOrders = criteriaOrdersMap.get(0);
+        }
+        Integer userBaseQty = null;
+        Integer userBaseValue = null;
+        if (baseCriteriaOrders != null) {
+            userBaseQty = baseCriteriaOrders.stream().collect(Collectors.summingInt(x -> (x.getLineItem().getQuantity() - x.getLineItem().getReturnQty())));
+            userBaseValue = baseCriteriaOrders.stream().collect(Collectors.summingInt(x ->
+                    Math.round(x.getLineItem().getUnitPrice() * (x.getLineItem().getQuantity() - x.getLineItem().getReturnQty()))
+            ));
+            criteriaQtyAmountMap.put(0, new QtyAmountModel(userBaseQty, userBaseValue));
+        }
+        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);
+            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().
+                    getUnitPrice() * (x.getLineItem().getQuantity() - x.getLineItem().getReturnQty()))));
+            int totalBaseQty = totalQty;
+            int totalBaseValue = totalValue;
+            criteriaQtyAmountMap.put(0, new QtyAmountModel(userBaseQty==null? 0 : userBaseQty, userBaseValue==null?0 : userBaseValue));
+            if (userBaseQty != null) {
+                totalBaseQty = userBaseQty;
+                totalBaseValue = userBaseValue;
+            }
+            int purchasedValue;
+            if (createOfferRequest.getTargetType().equals(AchievementType.VALUE)) {
+                purchasedValue = totalBaseValue;
+            } else {
+                purchasedValue = totalBaseQty;
+            }
+            qtyAmountModel.setQty(totalBaseQty);
+            qtyAmountModel.setAmount(totalBaseValue);
+            PayoutSlab eligibleSlab = null;
+            for (PayoutSlab payoutSlab : itemCriteriaPayout.getPayoutSlabs()) {
+                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())) {
+                    finalPayout = eligiblePayoutValue * purchasedValue;
+                } else {
+                    finalPayout = eligiblePayoutValue;
+                }
+            }
+            qtyAmountModel.setFinalPayout(finalPayout);
+            createOfferRequest.setCriteriaQtyAmountModel(criteriaQtyAmountMap);
+        }
+        return criteriaQtyAmountMap;
+    }
+    private Map<Integer, QtyAmountModel> getCriteriaQtyAmountModelMapForSelloutAndActivation(CreateOfferRequest createOfferRequest, int fofoId) {
+        Map<Integer, Map<Integer, List<FofoOrderItem>>> criteriaPartnerwiseTertiary = offerRepository.getCriteriaWisePartnerTertiary(createOfferRequest, fofoId);
+        Map<Integer, QtyAmountModel> qtyAmountMap;
+        final Map<String, LocalDateTime> activatedImeisActivationDateMap;
+        qtyAmountMap = new HashMap<>();
+        if (createOfferRequest.getSchemeType().equals(OfferSchemeType.ACTIVATION)) {
-    OfferEligibleImeiRepository offerEligibleImeiRepository;
+            //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) {
+            /*if (imeisAllowedManually != null) {
+                serialNumbers = serialNumbers.stream().filter(x -> imeisAllowedManually.contains(x)).collect(Collectors.toList());
+            }*/
+                activatedImeisActivationDateMap = activatedImeiRepository.selectBySerialNumbers(serialNumbers).stream()
+                        .filter(x -> createOfferRequest.isWithinRange(x.getActivationTimestamp()))
+                        .collect(Collectors.toMap(x -> x.getSerialNumber(), x -> x.getActivationTimestamp()));
+            } else {
+                activatedImeisActivationDateMap = null;
+            }
+        } else {
+            activatedImeisActivationDateMap = null;
+        }
+        QtyAmountModel qtyAmountModel = null;
+        if (createOfferRequest.isBaseCriteria()) {
+            List<FofoOrderItem> fofoOrderItems = criteriaPartnerwiseTertiary.get(0).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<>();
+                for (FofoOrderItem fofoOrderItem : fofoOrderItems) {
+                    fofoOrderItem.getFofoLineItems().stream().filter(x -> x.getSerialNumber() != null).forEach(
+                            lineItem -> {
+                                if (activatedImeisActivationDateMap == null || activatedImeisActivationDateMap.containsKey(lineItem.getSerialNumber())) {
+                                    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();
+                    eligibleBaseValue = (int) qtyAmountModel.getActivationAmount();
+                }
+                int eligibleSale = eligibleBaseValue;
+                int eligibleCriteriaSale = eligibleValue;
+                int eligibleCriteriaSaleDp = eligibleValue;
+                if (createOfferRequest.getTargetType().equals(AchievementType.QUANTITY)) {
+                    eligibleSale = eligibleBaseQty;
+                    eligibleCriteriaSale = eligibleQty;
+                }
+                float eligiblePayoutValue = 0;
+                double finalPayout = 0;
+                PayoutSlab eligibleSlab = null;
+                for (PayoutSlab slab : itemCriteriaPayout.getPayoutSlabs()) {
+                    if (slab.getOnwardsAmount() <= eligibleSale) {
+                        eligibleSlab = slab;
+                    } else {
+                        break;            // slabs beyond this don't qualify
+                    }
+                }
+                if(eligibleSlab != null) {
+                    eligibleSlab.setSelected(true);
+                    LOGGER.info("Eligible Slab {}", eligibleSlab);
+                }
+                if (AmountType.PERCENTAGE.equals(itemCriteriaPayout.getAmountType())) {
+                    finalPayout = (eligiblePayoutValue * eligibleCriteriaSaleDp) / 100;
+                } else if (AmountType.FIXED.equals(itemCriteriaPayout.getAmountType())) {
+                    finalPayout = eligiblePayoutValue * eligibleCriteriaSale;
+                } else {
+                    finalPayout = eligiblePayoutValue;
+                }
+                qtyAmountModel1.setFinalPayout(finalPayout);
+                LOGGER.info("Final Payout - {}", finalPayout);
+            }
+        }
+        return qtyAmountMap;
+    }
     @Override
     public void processActivationtOffer(CreateOfferRequest createOfferRequest) throws ProfitMandiBusinessException {
         List<OfferPayout> offerPayouts = offerPayoutRepository.selectAllByOfferId(createOfferRequest.getId());
         List<ItemCriteriaPayout> itemCriteriaPayouts = createOfferRequest.getTargetSlabs().get(0).getItemCriteriaPayouts();
                         double amount = 0;
                         if (AmountType.SLAB_FIXED.equals(itemCriteriaPayout.getAmountType())) {
                             amount = (eligiblePayoutValue * lineItemValueEntry.getValue()) / totalDpValue;
                         } else {
                             if (ageingSummaryModelsMap.containsKey(fofoLineItem.getSerialNumber())) {
-                                if (ageingSummaryModelsMap.get(fofoLineItem.getSerialNumber()).isAgedAbove(300)) {
+                                if (ageingSummaryModelsMap.get(fofoLineItem.getSerialNumber()).isAgedAbove(STOCK_AGEING_THRESHOLD_DAYS)) {
                                     continue;
+                                }
+                            }
                             amount = eligiblePayoutValue;
+                        }
             if (partnerCriteria.getRegionIds().size() > 0) {
                 sb.append("from ");
                 sb.append(String.join(", ", partnerCriteria.getRegionIds().stream().map(x -> ProfitMandiConstants.WAREHOUSE_MAP.get(x)).collect(Collectors.toList())));
+            }
             if (partnerCriteria.getExcludeFofoIds() != null && partnerCriteria.getExcludeFofoIds().size() > 0) {
-                sb.append("excluding ");
+                sb.append("<b>excluding</b> ");
                 appendPartnerCodes(partnerCriteria.getExcludeFofoIds(), sb);
+            }
+        }
         return sb.toString();
+    }
     public ByteArrayOutputStream createCSVOfferReport(CreateOfferRequest createOfferRequest) throws Exception {
         List<List<?>> listOfRows = new ArrayList<>();
         ByteArrayOutputStream baos = null;
         Collection<OfferRowModel> offerRowModels = offerRepository.getOfferRows(createOfferRequest);
         ItemCriteriaPayout itemCriteriaPayout = createOfferRequest.getTargetSlabs().get(0).getItemCriteriaPayouts().get(0);
+        // Batch fetch all retailers once to avoid N+1 queries
+        Map<Integer, CustomRetailer> allRetailers = retailerService.getAllFofoRetailers();
         if (createOfferRequest.getSchemeType().equals(OfferSchemeType.SELLIN)) {
             for (OfferRowModel offerRowModel : offerRowModels) {
-                CustomRetailer customRetailer = retailerService.getFofoRetailer(offerRowModel.getFofoId());
+                CustomRetailer customRetailer = allRetailers.get(offerRowModel.getFofoId());
                 listOfRows.add(Arrays.asList(
                         createOfferRequest.getId()
                         , createOfferRequest.getName()
                         , createOfferRequest.getTargetType()
                         , createOfferRequest.getSchemeType()
                             , "Eligible IMEIs"
                             , "Billing Pending Imeis"
                     ), listOfRows);
         } else {
             for (OfferRowModel offerRowModel : offerRowModels) {
-                CustomRetailer customRetailer = retailerService.getFofoRetailer(offerRowModel.getFofoId());
+                CustomRetailer customRetailer = allRetailers.get(offerRowModel.getFofoId());
                 listOfRows.add(Arrays.asList(
                                 createOfferRequest.getId()
                                 , createOfferRequest.getName()
                                 , createOfferRequest.getTargetType()
                                 , createOfferRequest.getSchemeType()

Subversion Repositories SmartDukaan

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