WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java

         Map<Integer, String> userNameMap = retailerService.getAllFofoRetailerIdNameMap();
         Map<Integer, Float> userAmountMap = new HashMap<>();
         List<List<?>> rows = new ArrayList<>();
         List<String> headers = Arrays.asList("Scheme", "Item", "Partner", "Amount", "Credited On", "Invoice Number", "Sale On", "Scheme Start", "Scheme End", "Active On", "Expired On");
-        schemeRepository.selectAll().stream().forEach(x -> {
+        for (Scheme scheme : schemeRepository.selectAll()) {
-            if (x.getType().equals(SchemeType.OUT)) {
+            if (scheme.getType().equals(SchemeType.OUT)) {
-                List<SchemeInOut> sioList = schemeInOutRepository.selectBySchemeIds(new HashSet<>(Arrays.asList(x.getId())));
+                List<SchemeInOut> sioList = schemeInOutRepository.selectBySchemeIds(new HashSet<>(Arrays.asList(scheme.getId())));
-                if (x.getActiveTimestamp() != null) {
+                if (scheme.getActiveTimestamp() != null) {
-                    LocalDateTime endDateTime = x.getEndDateTime();
+                    LocalDateTime endDateTime = scheme.getEndDateTime();
-                    if (x.getExpireTimestamp() != null && x.getExpireTimestamp().isBefore(x.getEndDateTime())) {
+                    if (scheme.getExpireTimestamp() != null && scheme.getExpireTimestamp().isBefore(scheme.getEndDateTime())) {
-                        endDateTime = x.getExpireTimestamp();
+                        endDateTime = scheme.getExpireTimestamp();
+                    }
                     for (SchemeInOut sio : sioList) {
                         InventoryItem inventoryItem = null;
                         inventoryItem = inventoryItemRepository.selectById(sio.getInventoryItemId());
                         FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndSerialNumber(
                                 inventoryItem.getFofoId(), inventoryItem.getSerialNumber(), null, null, 0, 1).get(0);
                         Optional<ScanRecord> record = scanRecordRepository.selectByInventoryItemId(sio.getInventoryItemId()).stream().filter(y -> y.getType().equals(ScanType.SALE)).findFirst();
                         if (record.isPresent()) {
                             int fofoId = record.get().getFofoId();
-                            if (record.get().getCreateTimestamp().isAfter(endDateTime) || record.get().getCreateTimestamp().isBefore(x.getStartDateTime())) {
+                            if (record.get().getCreateTimestamp().isAfter(endDateTime) || record.get().getCreateTimestamp().isBefore(scheme.getStartDateTime())) {
                                 if (!userAmountMap.containsKey(fofoId)) {
                                     userAmountMap.put(fofoId, 0f);
+                                }
                                 userAmountMap.put(fofoId, sio.getAmount() + userAmountMap.get(fofoId));
                                 try {
-                                    rows.add(Arrays.asList(x.getDescription(), itemRepository.selectById(inventoryItem.getItemId()).getItemDescription(), userNameMap.get(fofoId), sio.getAmount(), FormattingUtils.formatDate(sio.getCreateTimestamp()), fofoOrder.getInvoiceNumber(), FormattingUtils.formatDate(record.get().getCreateTimestamp()), FormattingUtils.formatDate(x.getStartDateTime()), FormattingUtils.formatDate(x.getEndDateTime()), FormattingUtils.formatDate(x.getActiveTimestamp()), FormattingUtils.formatDate(x.getExpireTimestamp())));
+                                    rows.add(Arrays.asList(scheme.getDescription(), itemRepository.selectById(inventoryItem.getItemId()).getItemDescription(), userNameMap.get(fofoId), sio.getAmount(), FormattingUtils.formatDate(sio.getCreateTimestamp()), fofoOrder.getInvoiceNumber(), FormattingUtils.formatDate(record.get().getCreateTimestamp()), FormattingUtils.formatDate(scheme.getStartDateTime()), FormattingUtils.formatDate(scheme.getEndDateTime()), FormattingUtils.formatDate(scheme.getActiveTimestamp()), FormattingUtils.formatDate(scheme.getExpireTimestamp())));
                                 } catch (Exception e) {
                                     e.printStackTrace();
+                                }
+                            }
+                        }
+                    }
+                }
+            }
-        });
+        }
         userAmountMap.entrySet().stream().forEach(x -> LOGGER.info("{} to be deducted from {}({}) for wrongly disbursed due to technical error.", x.getValue(), userNameMap.get(x.getKey())));
         ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
         Utils.sendMailWithAttachment(googleMailSender, new String[]{"amit.gupta@shop2020.in"}, null, "Partner Excess Amount", "PFA", "ListofSchemes.csv", new ByteArrayResource(baos.toByteArray()));
     @Autowired
     InvoiceService invoiceService;
     public void test() throws Exception {
-        //invoiceService.createInvoices(Arrays.asList("NSDLUK62", "NSDL39915", "NSDLHR24036", "NSDL39831", "NSNOI5266", "NSDL39849"));
-        /*vendorCatalogPricingLogRepository.selectByCatalogId(1024271, VendorCatalogPricingStatus.APPROVED).stream().filter(x -> x.getVendorId() == 341).forEach(x -> {
-            System.out.println(x.getEffectedOn() + ", " + x.getTransferPrice());
-        });*/
-        List<AgeingSummaryModel> ageingSummaryModels = warehouseInventoryItemRepository.
-                findPartnerStockAgeingByBrand("Samsung", 0, 80);
-        System.out.println(ageingSummaryModels.size());
-        //this.setInventoryItemIdToPriceDropImei();
-        //fofoSolr.populateTagItems();
-        //System.out.println(smartPingService.getAllAgentsByEmail());
-        //System.out.println(psiSmartService.getRegistrationEndPoint("9990381569"));
+        System.out.println(saholicInventoryService.getByWarehouseIdItemIds(7573, Arrays.asList(35942, 35943, 35945)));
-        //migrateValentine();
-        //Map<Integer, List<Offer>> offerMap = offerRepository.selectAllPublishedMapByPartner(YearMonth.now());
-        //LOGGER.info("Offers - {}", offerMap.entrySet().stream().filter(x->x.getKey()==168118414).flatMap(x->x.getValue().stream().map(y->y.getId())).collect(Collectors.toList()));
-        //bluedartAuthService.getAuthToken();
-        //bluedartService.getAirwayBillNo()
-        /*transactionRelatedTasks.reverseRTO(Arrays.asList(
-                "BLY156",
-                "BLY159",
-                "BLY339",
-                "NSDL33621",
-                "NSDL34037",
-                "NSLCK13532",
-                "NSSRNPR1124",
-                "NSSRNPR1248",
-                "NSSRNPR1249",
-                "NSUK267",
-                "UKRDPR139"));*/
-        //sendMailWhatsAppAfterLoanDueDate();
+    }
     public void test3() throws Exception {
         List<Long> payoutIds = Arrays.asList();
         List<OfferPayout> offerPayouts = offerPayoutRepository.selectAllByIds(payoutIds);
         String[] sendToArray = sendTo.toArray(new String[sendTo.size()]);
         Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Franchise Investment Summary", "PFA", fileName, new ByteArrayResource(baos.toByteArray()));
+    }
-    private Map<Integer, FofoReportingModel> getPartnerIdSalesHeaders() {
+    private Map<Integer, FofoReportingModel> getPartnerIdSalesHeaders() throws ProfitMandiBusinessException {
         Map<String, SaleRoles> partnerEmailSalesMap = new HashMap<>();
         Map<String, SaleRoles> partnerEmailRBMMap = new HashMap<>();
         List<Position> positions = positionRepository.selectPositionByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_RBM));
         Map<Integer, AuthUser> authUsersMap = authRepository.selectAllActiveUser().stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
+            }
+        }
+    }
-    public void schemewalletmismatch() {
+    public void schemewalletmismatch() throws ProfitMandiBusinessException {
         LocalDate dateToReconcile = LocalDate.of(2018, 4, 1);
         while (dateToReconcile.isBefore(LocalDate.now())) {
             reconcileSchemes(dateToReconcile);
             // reconcileOrders(dateTime);
             // reconcileRecharges(dateTime);
             dateToReconcile = dateToReconcile.plusDays(1);
+        }
+    }
-    private void reconcileSchemes(LocalDate date) {
+    private void reconcileSchemes(LocalDate date) throws ProfitMandiBusinessException {
         LocalDateTime startDate = date.atStartOfDay();
         LocalDateTime endDate = startDate.plusDays(1);
         List<SchemeInOut> siosCreated = schemeInOutRepository.selectAllByCreateDate(startDate, endDate);
         List<SchemeInOut> siosRefunded = schemeInOutRepository.selectAllByRefundDate(startDate, endDate);
         double totalSchemeDisbursed = siosCreated.stream().mapToDouble(x -> x.getAmount()).sum();
         LocalDateTime startDate = LocalDate.of(2018, 3, 1).atStartOfDay();
         LocalDateTime endDate = LocalDate.now().atStartOfDay();
         List<Purchase> purchases = purchaseRepository.selectAllBetweenPurchaseDate(startDate, endDate);
         Map<Integer, String> storeNameMap = fofoStoreRepository.getStoresMap();
-        purchases.stream().forEach(purchase -> {
+        for (Purchase purchase : purchases) {
             float amountToRollback = 0;
             String description = "Adjustment of Duplicate Scheme for Purchase Invoice " + purchase.getPurchaseReference();
             Map<Integer, String> inventorySerialNumberMap = inventoryItemRepository.selectByPurchaseId(purchase.getId()).stream().filter(ii -> ii.getSerialNumber() != null).collect(Collectors.toMap(InventoryItem::getId, InventoryItem::getSerialNumber));
             if (inventorySerialNumberMap.size() > 0) {
-                for (Map.Entry<Integer, String> inventorySerialNumberEntry : inventorySerialNumberMap.entrySet()) {
+                for (Entry<Integer, String> inventorySerialNumberEntry : inventorySerialNumberMap.entrySet()) {
                     String serialNumber = inventorySerialNumberEntry.getValue();
                     int inventoryItemId = inventorySerialNumberEntry.getKey();
                     if (serialNumbersConsidered.contains(serialNumber)) {
                         // This will rollback scheme for differenct orders for same serial
                         List<SchemeInOut> sios = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId))).stream().filter(x -> x.getRolledBackTimestamp() == null && schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.IN)).collect(Collectors.toList());
                 uwh.setWalletId(userWalletMap.get(purchase.getFofoId()));
                 uwh.setFofoId(purchase.getFofoId());
                 uwh.setStoreCode(storeNameMap.get(purchase.getFofoId()));
                 userWalletHistory.add(uwh);
+            }
-        });
+        }
         ByteArrayOutputStream baos = FileUtil.getCSVByteStream(
                 Arrays.asList("User Id", "Store Code", "Reference Type", "Reference", "Amount", "Description", "Timestamp"), userWalletHistory.stream().map(x -> Arrays.asList(x.getWalletId(), x.getStoreCode(), x.getReferenceType(), x.getReference(), x.getAmount(), x.getDescription(), x.getTimestamp())).collect(Collectors.toList()));
         ByteArrayOutputStream baosOuts = FileUtil.getCSVByteStream(
                 Arrays.asList("Scheme ID", "SchemeType", "Reference", "Store Code", "Serial Number", "Amount", "Created", "Rolledback"), rolledbackSios.stream().map(x -> Arrays.asList(x.getSchemeId(), x.getSchemeType(), x.getReference(), x.getStoreCode(), x.getSerialNumber(), x.getAmount(), x.getCreateTimestamp(), x.getRolledBackTimestamp())).collect(Collectors.toList()));
         // Collections.reverse(allOrders);
         // List<FofoOrder> allOrders =
         // List<FofoOrder> allOrders =
         // Arrays.asList(fofoOrderRepository.selectByInvoiceNumber("UPGZ019/25"));
         Set<String> serialNumbersConsidered = new HashSet<>();
-        allOrders.stream().forEach(fofoOrder -> {
+        for (FofoOrder fofoOrder : allOrders) {
             String description = "Adjustment of Duplicate Scheme for Sale Invoice " + fofoOrder.getInvoiceNumber();
             Map<Integer, String> inventorySerialNumberMap = new HashMap<>();
             float amountToRollback = 0;
             List<FofoOrderItem> orderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
             orderItems.forEach(x -> {
                 inventorySerialNumberMap.putAll(x.getFofoLineItems().stream().filter(li -> li.getSerialNumber() != null).collect(Collectors.toMap(FofoLineItem::getInventoryItemId, FofoLineItem::getSerialNumber)));
             });
             if (inventorySerialNumberMap.size() > 0) {
-                for (Map.Entry<Integer, String> inventorySerialNumberEntry : inventorySerialNumberMap.entrySet()) {
+                for (Entry<Integer, String> inventorySerialNumberEntry : inventorySerialNumberMap.entrySet()) {
                     String serialNumber = inventorySerialNumberEntry.getValue();
                     int inventoryItemId = inventorySerialNumberEntry.getKey();
                     if (serialNumbersConsidered.contains(serialNumber)) {
                         // This will rollback scheme for differenct orders for same serial
-                        List<SchemeInOut> sios = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId))).stream().filter(x -> x.getRolledBackTimestamp() == null && schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.OUT)).collect(Collectors.toList());
+                        List<SchemeInOut> sios = new ArrayList<>();
+                        for (SchemeInOut schemeInOut : schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId)))) {
+                            if (schemeInOut.getRolledBackTimestamp() == null && schemeTypeMap.get(schemeInOut.getSchemeId()).equals(SchemeType.OUT)) {
+                                sios.add(schemeInOut);
+                            }
+                        }
                         Collections.reverse(sios);
                         for (SchemeInOut sio : sios) {
                             sio.setRolledBackTimestamp(LocalDateTime.now());
                             amountToRollback += sio.getAmount();
                             // sio.setSchemeType(SchemeType.OUT);
                 uwh.setWalletId(userWalletMap.get(fofoOrder.getFofoId()));
                 uwh.setFofoId(fofoOrder.getFofoId());
                 uwh.setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);
                 userWalletHistory.add(uwh);
+            }
-        });
+        }
         ByteArrayOutputStream baos = FileUtil.getCSVByteStream(
                 Arrays.asList("Wallet Id", "Store Code", "Reference Type", "Reference", "Amount", "Description", "Timestamp"), userWalletHistory.stream().map(x -> Arrays.asList(x.getWalletId(), x.getStoreCode(), x.getReferenceType(), x.getReference(), x.getAmount(), x.getDescription(), x.getTimestamp())).collect(Collectors.toList()));
         ByteArrayOutputStream baosOuts = FileUtil.getCSVByteStream(
         List<Integer> references = Arrays.asList(6744, 7347, 8320, 8891, 9124, 9217, 9263, 9379);
         List<UserWalletHistory> userWalletHistory = new ArrayList<>();
         List<SchemeInOut> rolledbackSios = new ArrayList<>();
         Map<Integer, Integer> userWalletMap = userWalletRepository.selectAll().stream().collect(Collectors.toMap(UserWallet::getUserId, UserWallet::getId));
         Map<Integer, SchemeType> schemeTypeMap = schemeRepository.selectAll().stream().collect(Collectors.toMap(Scheme::getId, Scheme::getType));
-        references.stream().forEach(reference -> {
+        for (Integer reference : references) {
             FofoOrder fofoOrder = null;
             try {
                 fofoOrder = fofoOrderRepository.selectByOrderId(reference);
             } catch (Exception e) {
             if (inventorySerialNumberMap.size() > 0) {
                 List<SchemeInOut> sios = schemeInOutRepository.selectByInventoryItemIds(inventorySerialNumberMap.keySet()).stream().filter(x -> schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.OUT)).collect(Collectors.toList());
                 LOGGER.info("Found {} duplicate schemeouts for Orderid {}", sios.size(), fofoOrder.getId());
                 UserWalletHistory uwh = new UserWalletHistory();
                 Map<Integer, List<SchemeInOut>> inventoryIdSouts = sios.stream().collect(groupingBy(SchemeInOut::getInventoryItemId, Collectors.toList()));
-                for (Map.Entry<Integer, List<SchemeInOut>> inventorySioEntry : inventoryIdSouts.entrySet()) {
+                for (Entry<Integer, List<SchemeInOut>> inventorySioEntry : inventoryIdSouts.entrySet()) {
                     List<SchemeInOut> outList = inventorySioEntry.getValue();
                     if (outList.size() > 1) {
+                    }
+                }
                 uwh.setWalletId(userWalletMap.get(fofoOrder.getFofoId()));
                 uwh.setFofoId(fofoOrder.getFofoId());
                 uwh.setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);
                 userWalletHistory.add(uwh);
+            }
-        });
+        }
         ByteArrayOutputStream baos = FileUtil.getCSVByteStream(
                 Arrays.asList("User Id", "Reference Type", "Reference", "Amount", "Description", "Timestamp"), userWalletHistory.stream().map(x -> Arrays.asList(x.getWalletId(), x.getReferenceType(), x.getReference(), x.getAmount(), x.getDescription(), x.getTimestamp())).collect(Collectors.toList()));
         ByteArrayOutputStream baosOuts = FileUtil.getCSVByteStream(
+    }
     @Autowired
     WarehouseRepository warehouseRepository;
-    public void getVendorWarehouses(int warehouseId) {
+    public void getVendorWarehouses(int warehouseId) throws ProfitMandiBusinessException {
         LOGGER.info("Warehouses - {}", warehouseRepository.getVendorWarehouses().get(warehouseId));
+    }
     public void checkImeiActivation() {
                             CreditAccount creditAccount = creditAccountRepository.selectByFofoIdAndGateway(loan.getFofoId(), Gateway.SDDIRECT);
                             creditAccount.setAvailableAmount(sdCreditRequirement.getAvailableLimit().floatValue());
                             creditAccount.setUpdatedOn(LocalDateTime.now());
-                            //userWallet.setAmount(0);
                             loan.setPendingAmount(
                                     loan.getPendingAmount().subtract(BigDecimal.valueOf(userWalletAmount)));
+                        }
                         walletService.consumeAmountFromWallet(userWallet.getUserId(), loan.getId(), WalletReferenceType.LOAN_REPAYMENT, "Amount adjusted against loan", (float) Math.abs(paidAmount), LocalDateTime.now());
-                        // createUserWalletHistory(userWallet.getId(), userWallet.getUserId(), WalletReferenceType.LOAN_REPAYMENT, loan.getId(), Math.abs(paidAmount));
                     } else {
-                        settledLoanStatement(LoanReferenceType.INTEREST, BigDecimal.valueOf(userWallet.getAmount()), loan.getFofoId(), loan.getId(), "Amount adjusted against loan", LocalDateTime.now());
+                        settledLoanStatement(LoanReferenceType.INTEREST, BigDecimal.valueOf(userWallet.getAmount()), loan.getFofoId(), loan.getId(),
+                                "Amount adjusted against loan", LocalDateTime.now());
                         paidAmount += Math.abs(userWallet.getAmount());
-                        loan.setInterestPaid(
-                                loan.getInterestPaid().add(BigDecimal.valueOf(userWallet.getAmount()).abs()));
+                        loan.setInterestPaid(loan.getInterestPaid().add(BigDecimal.valueOf(userWallet.getAmount()).abs()));
-                        //  createUserWalletHistory(userWallet.getId(), userWallet.getUserId(), WalletReferenceType.LOAN_REPAYMENT, loan.getId(), Math.abs(paidAmount));
+                        walletService.consumeAmountFromWallet(userWallet.getUserId(), loan.getId(), WalletReferenceType.LOAN_REPAYMENT,
-                        walletService.consumeAmountFromWallet(userWallet.getUserId(), loan.getId(), WalletReferenceType.LOAN_REPAYMENT, "Amount adjusted against loan", (float) Math.abs(paidAmount), LocalDateTime.now());
+                                "Amount adjusted against loan", (float) Math.abs(paidAmount), LocalDateTime.now());
-                        // userWallet.setAmount(0);
+                    }
                     List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanctionByFofoId(loan.getFofoId());
                             LOGGER.info("Could not find orders - for Sanction Request {}", sanctionRequest);
                             continue;
+                        }
                         if (settledAmount >= sanctionRequest.getPendingAmount().doubleValue()) {
-                            settledAmount = settledAmount - sanctionRequest.getPendingAmount().doubleValue();
+                            settledAmount -= sanctionRequest.getPendingAmount().doubleValue();
                             sanctionRequest.setPendingAmount(BigDecimal.valueOf(0));
                             this.sendUnholdEmail(orders);
                         } else {
-                            settledAmount = sanctionRequest.getPendingAmount().doubleValue() - settledAmount;
+                            settledAmount -= sanctionRequest.getPendingAmount().doubleValue();
                             sanctionRequest.setPendingAmount(BigDecimal.valueOf(settledAmount));
                             break;
+                        }
+                    }
     @Autowired
     FofoSidbiSanctionRepository fofoSidbiSanctionRepository;
     public void updatePartnerLimit() throws ProfitMandiBusinessException {
         Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(true);
-        Map<Integer, List<FofoSidbiSanction>> fofoSidbiSanctionMap = fofoSidbiSanctionRepository.selectAllUptoBy(ProfitMandiConstants.SIDBI_TENUERE_MONTHS).stream().collect(Collectors.groupingBy(x->x.getFofoId()));
+        Map<Integer, List<FofoSidbiSanction>> fofoSidbiSanctionMap = fofoSidbiSanctionRepository.selectAllUptoBy(ProfitMandiConstants.SIDBI_TENUERE_MONTHS).stream().collect(Collectors.groupingBy(x -> x.getFofoId()));
         Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
         Map<Integer, CreditAccount> creditAccountMap = creditAccountRepository.selectAllByGateways(Arrays.asList(Gateway.SIDBI, Gateway.SDDIRECT))
                 .stream().filter(x -> x.isActive()).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
         Map<Integer, CurrentPartnerDailyInvestment> currentPartnerDailyInvestmentMap = currentPartnerDailyInvestmentRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
         for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailerMap.entrySet()) {
                 suggestedAmount = BigDecimal.valueOf(Math.min(currentPartnerDailyInvestment.getTotalInvestment() * 0.1, limitValue));
+            }
             if (suggestedAmount.doubleValue() < 0) {
                 suggestedAmount = BigDecimal.ZERO;
+            }
-        } else if(creditAccount.getGateway().equals(Gateway.SIDBI) && fofoSidbiSanctions!= null && fofoSidbiSanctions.size() > 0){
+        } else if (creditAccount.getGateway().equals(Gateway.SIDBI) && fofoSidbiSanctions != null && fofoSidbiSanctions.size() > 0) {
             //Left
             FofoSidbiSanction fofoSidbiSanction = fofoSidbiSanctions.get(0);
             int monthsLeft = fofoSidbiSanction.getMonthsLeft(ProfitMandiConstants.SIDBI_TENUERE_MONTHS);
-            if(monthsLeft >=0) {
+            if (monthsLeft >= 0) {
-                suggestedAmount = BigDecimal.valueOf(fofoSidbiSanction.getSanctionAmount()*monthsLeft/ProfitMandiConstants.SIDBI_TENUERE_MONTHS);
+                suggestedAmount = BigDecimal.valueOf(fofoSidbiSanction.getSanctionAmount() * monthsLeft / ProfitMandiConstants.SIDBI_TENUERE_MONTHS);
+            }
+        }
         return suggestedAmount;
+    }
         Map<Integer, com.spice.profitmandi.dao.model.FofoRBMReportingModel> fofoRbmReportingModelMap = csService.getPartnerIdRBMHeaders();
         StringBuilder sb = new StringBuilder();
         sb.append("<html><body><p>Alert</p><p>Due Date Cross Partners :-</p>" + "<br/><p>Additional penal interest of  shall be levied on daily basis.</p>" + "<br/>" +
                 "<table style='border:1px solid black ;padding: 5px';>");
         sb.append("<tbody>\n" + "<tr>\n" +
-                    "<th style='border:1px solid black;padding: 5px'>PartnerName</th>\n" +
+                "<th style='border:1px solid black;padding: 5px'>PartnerName</th>\n" +
-                    "<th style='border:1px solid black;padding: 5px'>State Name</th>\n" +
+                "<th style='border:1px solid black;padding: 5px'>State Name</th>\n" +
-                    "<th style='border:1px solid black;padding: 5px'>due date</th>\n" +
+                "<th style='border:1px solid black;padding: 5px'>due date</th>\n" +
-                    "<th style='border:1px solid black;padding: 5px'>Days</th>\n" +
+                "<th style='border:1px solid black;padding: 5px'>Days</th>\n" +
-                    "<th style='border:1px solid black;padding: 5px'>Pending Amount</th>\n"+
+                "<th style='border:1px solid black;padding: 5px'>Pending Amount</th>\n" +
-                    "<th style='border:1px solid black;padding: 5px'>RBM L1</th>\n"+
+                "<th style='border:1px solid black;padding: 5px'>RBM L1</th>\n" +
-                    "<th style='border:1px solid black;padding: 5px'>RBM L2</th>\n"+
+                "<th style='border:1px solid black;padding: 5px'>RBM L2</th>\n" +
-                    "<th style='border:1px solid black;padding: 5px'>Sales L1</th>\n"+
+                "<th style='border:1px solid black;padding: 5px'>Sales L1</th>\n" +
-                    "<th style='border:1px solid black;padding: 5px'>Sales L2</th>\n"+
+                "<th style='border:1px solid black;padding: 5px'>Sales L2</th>\n" +
                 "</tr>");
         for (Loan entry : loans) {
             List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(entry.getId());
+    }
     @Autowired
     SaholicReservationSnapshotRepository saholicReservationSnapshotRepository;
-    public void removePartialBillingForTransaction(int transactionId) {
+    public void removePartialBillingForTransaction(int transactionId) throws ProfitMandiBusinessException {
         List<Order> orderList = orderRepository.selectAllByTransactionId(transactionId);
         Map<Integer, Order> orderMap = orderList.stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
         //Delete scanRecords
         List<WarehouseScan> warehouseScans = warehouseScanRepository.selectAllByOrderIds(new ArrayList<>(orderMap.keySet()));
         for (WarehouseScan warehouseScan : warehouseScans) {
+        }
+    }
     private String getMessageHygieneAlertForPartner(
-            Map<Integer, Map<YearMonth, List<HygieneData>>> partnerYearMonthData, Map<Integer, Map<LocalDate, List<HygieneData>>> partnerDateWiseData) {
+            Map<Integer, Map<YearMonth, List<HygieneData>>> partnerYearMonthData, Map<Integer, Map<LocalDate, List<HygieneData>>> partnerDateWiseData)
+            throws ProfitMandiBusinessException {
         Map<Integer, CustomRetailer> customeRetailerMap = retailerService.getAllFofoRetailers();
         LocalDateTime startDate = LocalDate.now().withDayOfMonth(1).atStartOfDay();
         LocalDateTime endDate = LocalDateTime.now();
     @Autowired
     private VendorCatalogPricingService vendorCatalogPricingService;
-    public void migrateVendorItemPricing() {
+    public void migrateVendorItemPricing() throws ProfitMandiBusinessException {
         List<VendorItemPricing> vendorItemPricings = vendorItemPricingRepository.selectAll();
         LOGGER.info("At migrate VendorItemPricing");
         Map<Integer, Item> items = itemRepository.selectByIds(vendorItemPricings.stream().map(x -> x.getItemId()).collect(Collectors.toSet())).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
         for (VendorItemPricing vendorItemPricing : vendorItemPricings) {

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java – Rev 33163 → 33256