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

 import com.spice.profitmandi.common.util.StringUtils;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.dao.entity.catalog.*;
 import com.spice.profitmandi.dao.entity.fofo.*;
 import com.spice.profitmandi.dao.entity.inventory.PartnerAgeingModel;
+import com.spice.profitmandi.dao.entity.transaction.Loan;
 import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
 import com.spice.profitmandi.dao.entity.transaction.UserWallet;
 import com.spice.profitmandi.dao.entity.transaction.UserWalletHistory;
 import com.spice.profitmandi.dao.enumuration.catalog.AmountType;
 import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
 import com.spice.profitmandi.dao.model.CreateSchemeRequest;
 import com.spice.profitmandi.dao.repository.catalog.*;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
 import com.spice.profitmandi.dao.repository.fofo.*;
+import com.spice.profitmandi.dao.repository.transaction.LoanRepository;
 import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletHistoryRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
 import com.spice.profitmandi.dao.repository.warehouse.AgeingSummaryModel;
 import com.spice.profitmandi.dao.repository.warehouse.WarehouseInventoryItemRepository;
 @Component
 public class SchemeServiceImpl implements SchemeService {
     private static final Logger LOGGER = LogManager.getLogger(SchemeServiceImpl.class);
     private static final Set<Integer> tagIds = new HashSet<>(Arrays.asList(4));
-//    //These Imeis provided by deena
-//    private static final List<String> BLOCKED_IMEIS =
+    private static final List<SchemeType> FULL_DAYS_CD_SCHEME_TYPES = Arrays.asList(SchemeType.CASH_DISCOUNT, SchemeType.CASH_DISCOUNT1);
-//            Arrays.asList(
-//                    "864883056397593", "864883054606656", "864883056567815", "861950056518271", "869175055649511", "861362058924574", "866009066803036", "866009066816699", "866009066816137", "866009066815873",
-//                    "866009066805536", "866009066803010", "866009066821939", "866009066802756", "866009066820592", "866009066820311", "866009066816491", "866009066816376", "866009066815899", "866009066815774",
-//                    "866009066817937", "866009066819859", "866009066817655", "866009066820691", "866009066820832", "866009066803291", "866009066820733", "866009066814496", "866009066820451", "866009066820659",
-//                    "866009066804976", "866009066820717", "866009066816095", "861362054898434", "869599051117852", "869599056695332", "869599056695894", "864883057389656", "862661052418692", "860118051929254",
-//                    "862888051664998", "862680054625831", "862888051666316", "860118051738895", "868066050447970", "868066052424399", "865084051552576", "865084050755097", "865084050755295", "865084050754819",
-//                    "864883057487278", "864883057389599", "864883057437455", "864883057388278", "862680058278058", "869599056810139", "862200053994193", "861932057188916", "861175050581774", "863933065909093",
-//                    "863933065635391", "861362054889177", "864004062055154", "864004062069239", "862661050221676", "862661052416993", "866812058631475", "869599051118173", "869599051504273", "868066052729250",
-//                    "864883057701397", "864883054123033", "864883054947316", "864883056235694", "868066052727692", "866030052139896", "866030052140175", "860588051522053", "860588051513193", "861932056969779",
-//                    "869599056171995", "865594061074932", "863935059410491", "866088059072718", "869599055375894", "869599054306916", "863782054006472", "863782054012371", "860588053486992", "868066052726835",
-//                    "868066052726694", "860688053876430", "860688053869674", "868494054682394", "869599053512357", "863132060568430", "357737717299925", "863132060568471", "869663062661835", "869663062659458",
-//                    "863132061326994", "863132061326796", "863132060906770", "869663064230795", "869663064231876", "869663064230670", "869663064231819", "865303063431276", "865303063431391", "865303064031315",
-//                    "865303064031273", "865303064030994", "865303064031091", "865303063689113", "865303063689576", "865303063688636", "865303063689055", "868386069690414", "868386069688533", "864288066323771",
-//                    "864288066330156", "869657061613797", "864288065002178", "867791065108199", "867791065069839", "867791065069474", "867791065114395", "867791065113918", "867791065088318", "862814069767037",
-//                    "867791063493114", "861433069356815", "861433069357359", "861433066654055", "861433066748675", "861433065712136", "861433065712656", "867791062605650", "867791062593559", "867791062593112",
-//                    "867791062804436", "867791062798455", "867791062805177", "862965069680636", "862807060752412", "862807060752214", "865626066329117", "861433069357011", "861433066749319", "861433068904698",
-//                    "861433068906057", "861433065714017", "861433065712177", "867791062804279", "866670064793915", "868386063007672", "865626064418557", "861433069357110", "864179066094829", "866382065031176",
-//                    "864562072802477", "864562072801651", "864562072801917", "864288066786274", "864562070789478", "864562070785930", "864562070788330", "864179066116929", "864470060972569", "867492065820095",
-//                    "867940069618279", "863718065007331", "863718065001417", "860948069657616", "860948069562733", "860948069563939", "860948068569838", "860948068569598", "860948067443092", "860948067442912",
-//                    "860948067442573", "860948069561750", "860948069561479", "860948069561974", "860948069562550", "860948069560679", "860948069560190", "860948069562691", "860948069735859"
+    private static final List<SchemeType> HALF_DAYS_CD_REJECT_SCHEME_TYPES = Arrays.asList(SchemeType.CASH_DISCOUNT1);
-//    );
     private static final List<SchemeType> ACTIVATION_SCHEME_TYPES = Arrays.asList(SchemeType.SPECIAL_SUPPORT, SchemeType.SELLOUT);
     @Autowired
     SchemeBlockedImeiRepository schemeBlockedImeiRepository;
             sendNotificationModel.setType("url");
             sendNotificationModel.setMessageType(MessageType.scheme);
             notificationService.sendNotificationToAll(sendNotificationModel);
+        }
+    }
-    private void sendCombinedSchemesNotification(List<Scheme> schemes) throws ProfitMandiBusinessException {
-        SendNotificationModel sendNotificationModel = new SendNotificationModel();
-        StringBuilder messageBuilder = new StringBuilder();
-        for (Scheme scheme : schemes) {
-            if (!ACTIVATION_SCHEME_TYPES.contains(scheme.getType())) {
-                continue;
-            }
+    @Autowired
-            String schemeTypeLabel = "Activation scheme";
-            if (scheme.getType().equals(SchemeType.SPECIAL_SUPPORT)) {
-                schemeTypeLabel = "Special Support";
-            }
-            List<SchemeItem> schemeItems = schemeItemRepository.selectBySchemeIds(Collections.singleton(scheme.getId()));
-            Set<Integer> catalogIds = schemeItems.stream().map(SchemeItem::getCatalogId).collect(Collectors.toSet());
-            List<String> itemBrand = itemRepository.selectAllByCatalogIds(catalogIds).stream()
-                    .filter(Utils.distinctByKey(Item::getCatalogItemId))
-                    .map(Item::getBrand)
-                    .collect(Collectors.toList());
-            List<String> itemDescriptions = itemRepository.selectAllByCatalogIds(catalogIds).stream()
-                    .filter(Utils.distinctByKey(Item::getCatalogItemId))
-                    .map(Item::getItemDescriptionNoColor)
-                    .collect(Collectors.toList());
-            messageBuilder.append(String.format("*%s* on *%s* of Rs.*%s* for *%s*\n Duration from - *%s to %s*\n\n",
-                    schemeTypeLabel,
-                    itemBrand.get(0),
-                    FormattingUtils.formatDecimal(scheme.getAmount()),
-                    String.join(", ", itemDescriptions),
-                    FormattingUtils.formatDateMonth(scheme.getStartDateTime()),
-                    FormattingUtils.formatDateMonth(scheme.getEndDateTime())));
-        }
-        sendNotificationModel.setCampaignName("activationscheme");
-        sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");
-        sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
-        sendNotificationModel.setTitle("Special Support");
-        sendNotificationModel.setMessage(messageBuilder.toString());
-        sendNotificationModel.setType("url");
+    LoanRepository loanRepository;
-        sendNotificationModel.setMessageType(MessageType.scheme);
-        notificationService.sendNotificationToAll(sendNotificationModel);
-    }
     @Override
     public void expireSchemeById(int schemeId, LocalDateTime expiryTime) throws ProfitMandiBusinessException {
         Scheme scheme = schemeRepository.selectById(schemeId);
         if (scheme == null || scheme.getActiveTimestamp() == null) {
     @Autowired
     OfferPayoutRepository offerPayoutRepository;
     @Autowired
     AgeingService ageingService;
+    private void sendCombinedSchemesNotification(List<Scheme> schemes) throws ProfitMandiBusinessException {
+        if (schemes == null || schemes.isEmpty()) return;
+        SendNotificationModel sendNotificationModel = new SendNotificationModel();
+        StringBuilder messageBuilder = new StringBuilder();
+        StringBuilder titleBuilder = new StringBuilder();
+        Set<Integer> allCatalogIds = new HashSet<>();
+        for (Scheme scheme : schemes) {
+            if (!ACTIVATION_SCHEME_TYPES.contains(scheme.getType())) {
+                continue;
+            }
+            String schemeTypeLabel = "Activation scheme";
+            if (scheme.getType().equals(SchemeType.SPECIAL_SUPPORT)) {
+                schemeTypeLabel = "Special Support";
+            }
+            List<SchemeItem> schemeItems = schemeItemRepository.selectBySchemeIds(Collections.singleton(scheme.getId()));
+            Set<Integer> catalogIds = schemeItems.stream().map(SchemeItem::getCatalogId).collect(Collectors.toSet());
+            allCatalogIds.addAll(catalogIds);
+            List<String> itemBrand = itemRepository.selectAllByCatalogIds(catalogIds).stream()
+                    .filter(Utils.distinctByKey(Item::getCatalogItemId))
+                    .map(Item::getBrand)
+                    .collect(Collectors.toList());
+            List<String> itemDescriptions = itemRepository.selectAllByCatalogIds(catalogIds).stream()
+                    .filter(Utils.distinctByKey(Item::getCatalogItemId))
+                    .map(Item::getItemDescriptionNoColor)
+                    .collect(Collectors.toList());
+            // Title line
+            titleBuilder.append(String.format("%s of Rs.%s for %s\n",
+                    schemeTypeLabel,
+                    FormattingUtils.formatDecimal(scheme.getAmount()),
+                    itemBrand.get(0)));
+            // Message details
+            messageBuilder.append(String.format("On Selected Models: %s\n", String.join(", ", itemDescriptions)));
+            messageBuilder.append(String.format("Duration from - %s to %s\n\n",
+                    FormattingUtils.formatDateMonth(scheme.getStartDateTime()),
+                    FormattingUtils.formatDateMonth(scheme.getEndDateTime())));
+        }
+        if (titleBuilder.length() == 0) return;
+        sendNotificationModel.setCampaignName("activationscheme");
+        sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");
+        sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
+        sendNotificationModel.setTitle(titleBuilder.toString().trim());
+        sendNotificationModel.setMessage(messageBuilder.toString().trim());
+        sendNotificationModel.setType("url");
+        sendNotificationModel.setMessageType(MessageType.scheme);
+        notificationService.sendNotificationToAll(sendNotificationModel);
+    }
+    //CDs would be rejected based on cdFreeDays
     public void processSchemeIn(int purchaseId, int retailerId) throws ProfitMandiBusinessException {
         LOGGER.info("Processing scheme in  for purchaseId - {}", purchaseId);
         Purchase purchase = purchaseRepository.selectByIdAndFofoId(purchaseId, retailerId);
+        String purchaseInvoice = purchase.getPurchaseReference();
+        Loan loan = loanRepository.selectLoanByInvoice(purchaseInvoice);
         PartnerType partnerType = partnerTypeChangeService.getTypeOnMonth(retailerId,
                 YearMonth.from(purchase.getCreateTimestamp()));
         List<InventoryItem> inventoryItems = inventoryItemRepository.selectByPurchaseId(purchaseId);
         //Remove imeis from blocked imeis list
         List<String> blockedImeis = this.getBlockedImeis();
             schemeSummaryModels.stream().filter(x -> x != null && x.getSchemeType().getTransactionType().equals(StockTransactionType.IN)).forEach(x -> x.setProcess(true));
             if (schemeSummaryModels.stream().filter(x -> x.isProcess()).count() == 0) continue;
             List<InventoryItem> modelInventoryItems = catalogInventoryItemMap.get(catalogSummaryModel.getCatalogId());
             for (InventoryItem inventoryItem : modelInventoryItems) {
                 float inventoryItemCashback = this.createSchemeInOut(schemeSummaryModels, inventoryItem);
+                if (loan != null && loan.getCdFreeDays() > 0) {
+                    List<SchemeType> rejectedCDTypes = HALF_DAYS_CD_REJECT_SCHEME_TYPES;
+                    if (loan.getCdFreeDays() == ProfitMandiConstants.LOAN_FULL_CREDIT_DAYS) {
+                        rejectedCDTypes = FULL_DAYS_CD_SCHEME_TYPES;
+                    }
+                    for (SchemeType rejectedCDType : rejectedCDTypes) {
+                        SchemeInOut sio = schemeInOutRepository.selectAllByType(rejectedCDType, inventoryItem.getId()).get(0);
+                        sio.setStatus(SchemePayoutStatus.REJECTED);
+                        sio.setStatusDescription("Rejected due to free days availed");
+                        sio.setRolledBackTimestamp(LocalDateTime.now());
+                        inventoryItemCashback -= sio.getAmount();
+                    }
+                }
-                if (inventoryItemCashback > 0) {
+                if (inventoryItemCashback > 0.01f) {
                     itemsCount++;
                     totalCashback += inventoryItemCashback;
+                }
+            }
+        }
                     sio.setStatus(SchemePayoutStatus.PENDING);
                     schemeInOutRepository.persist(sio);
+                }
             } else if (!StockTransactionType.IN.equals(schemeSummaryModelToProcess.getSchemeType().getTransactionType())) {
                 //We have got non repeating scheme type
-                if (paidSchemeTypesMap.containsKey(schemeSummaryModelToProcess.getSchemeType())) {
-                    SchemeInOut sio = paidSchemeTypesMap.get(schemeSummaryModelToProcess.getSchemeType()).get(0);
-                    Scheme paidScheme = sio.getScheme();
-                    //Don't entertain if amount types do not match for same type
-                    if (paidScheme.getAmountType().equals(schemeSummaryModelToProcess.getAmountType()) &&
-                            schemeSummaryModelToProcess.getAmount() > paidScheme.getAmount() + Utils.DOUBLE_EPSILON) {
-                        sio.setRolledBackTimestamp(LocalDateTime.now());
-                        sio.setStatus(SchemePayoutStatus.REJECTED);
-                        sio.setStatusDescription("Eligible for higher margin for " + schemeSummaryModelToProcess.getSchemeType() + ", new entry added");
-                        schemeTypeCancelledAmountMap.put(schemeSummaryModelToProcess.getSchemeType(), sio.getAmount());
-                        if (paidScheme.getAmountType().equals(AmountType.PERCENTAGE)) {
+                if (schemeSummaryModelToProcess.getAmountType().equals(AmountType.PERCENTAGE)) {
-                            percentageToPay += schemeSummaryModelToProcess.getAmount() - paidScheme.getAmount();
+                    percentageToPay += schemeSummaryModelToProcess.getAmount();
-                        } else {
-                            fixedToPay += schemeSummaryModelToProcess.getAmount() - paidScheme.getAmount();
-                        }
-                        payoutSchemeSummaryModelMap.put(schemeSummaryModelToProcess, new AmountModel(schemeSummaryModelToProcess.getAmount() - paidScheme.getAmount(), schemeSummaryModelToProcess.getAmountType()));
-                    }
                 } else {
-                    if (schemeSummaryModelToProcess.getAmountType().equals(AmountType.PERCENTAGE)) {
-                        percentageToPay += schemeSummaryModelToProcess.getAmount();
-                    } else {
-                        fixedToPay += schemeSummaryModelToProcess.getAmount();
+                    fixedToPay += schemeSummaryModelToProcess.getAmount();
-                    }
-                    payoutSchemeSummaryModelMap.put(schemeSummaryModelToProcess, new AmountModel(schemeSummaryModelToProcess.getAmount(), schemeSummaryModelToProcess.getAmountType()));
+                }
+                payoutSchemeSummaryModelMap.put(schemeSummaryModelToProcess, new AmountModel(schemeSummaryModelToProcess.getAmount(), schemeSummaryModelToProcess.getAmountType()));
             } else {
                 if (schemeSummaryModelToProcess.getAmountType().equals(AmountType.PERCENTAGE)) {
+                    //Check for rejected CashDiscounts dont continue if its ever rejected once
+                    if (SchemeType.CDS.contains(schemeSummaryModelToProcess.getSchemeType())) {
+                        List<SchemeInOut> cdSchemeInOuts = schemeInOutRepository.selectAllByType(schemeSummaryModelToProcess.getSchemeType(), inventoryItem.getId());
+                        LOGGER.info(cdSchemeInOuts);
+                        if (!cdSchemeInOuts.isEmpty()) continue;
+                    }
                     percentageToPay += schemeSummaryModelToProcess.getAmount();
                 } else {
                     fixedToPay += schemeSummaryModelToProcess.getAmount();
+                }
                 payoutSchemeSummaryModelMap.put(schemeSummaryModelToProcess, new AmountModel(schemeSummaryModelToProcess.getAmount(), schemeSummaryModelToProcess.getAmountType()));
                 if (schemeSummaryModels.stream().filter(x -> x.isProcess()).count() == 0) continue;
                 List<InventoryItem> modelInventoryItems = catalogInventoryItemMap.get(catalogSummaryModel.getCatalogId());
                 for (InventoryItem inventoryItem : modelInventoryItems) {
                     Map<Integer, SchemeSummaryModel> schemeSummaryModelMap = schemeSummaryModels.stream().collect(Collectors.toMap(x -> x.getSchemeId(), x -> x));
-                    List<SchemeInOut> siosToReject = schemeInOutRepository.selectAll(inventoryItem.getId())
+                    List<SchemeInOut> sios = schemeInOutRepository.selectAll(inventoryItem.getId());
+                    List<Integer> creditedSchemeIds = sios.stream()
-                            .stream().filter(x -> x.getStatus().equals(SchemePayoutStatus.CREDITED))
+                            .filter(x -> x.getStatus().equals(SchemePayoutStatus.CREDITED))
-                            .filter(x -> !schemeSummaryModelMap.containsKey(x.getSchemeId())).collect(Collectors.toList());
+                            .map(x -> x.getSchemeId()).collect(Collectors.toList());
+                    List<Integer> schemeIdsToReject = schemeRepository.selectBySchemeIds(creditedSchemeIds).stream().filter(x -> SchemeType.OUT_TYPES.contains(x.getType())).map(x -> x.getId()).collect(Collectors.toList());
                     //Reject invalid scheme payouts due to upgrade in Category or any change in schemes historically
-                    for (SchemeInOut sioToReject : siosToReject) {
+                    for (SchemeInOut sio : sios) {
+                        if (schemeIdsToReject.contains(sio.getSchemeId())) {
-                        sioToReject.setStatusDescription("Rolledback due to Category upgrade/invalid scheme");
+                            sio.setStatusDescription("Rolledback due to Category upgrade/invalid scheme");
-                        sioToReject.setStatus(SchemePayoutStatus.REJECTED);
+                            sio.setStatus(SchemePayoutStatus.REJECTED);
-                        sioToReject.setRolledBackTimestamp(LocalDateTime.now());
+                            sio.setRolledBackTimestamp(LocalDateTime.now());
-                        totalCashback -= sioToReject.getAmount();
+                            totalCashback -= sio.getAmount();
+                        }
+                    }
                     float inventoryItemCashback = this.createSchemeInOut(schemeSummaryModels, inventoryItem);
                     if (inventoryItemCashback > 0) {
                         count++;
                         totalCashback += inventoryItemCashback;

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/scheme/SchemeServiceImpl.java – Rev 34698 → 34705