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

 import com.google.gson.Gson;
 import com.razorpay.Payment;
 import com.smartdukaan.cron.itelImeiActivation.ItelImeiActivationNewService;
 import com.smartdukaan.cron.itelImeiActivation.ItelImeiActivationService;
 import com.smartdukaan.cron.itelImeiActivation.TecnoImeiActivation;
+import com.smartdukaan.cron.scheduled.runnables.PurchaseMigration;
 import com.spice.profitmandi.common.enumuration.ActivationType;
 import com.spice.profitmandi.common.enumuration.MessageType;
 import com.spice.profitmandi.common.enumuration.RechargeStatus;
 import com.spice.profitmandi.common.enumuration.ReporticoProject;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.service.integrations.bharti.model.BAGInsuranceModel;
 import com.spice.profitmandi.service.integrations.toffee.ToffeeService;
 import com.spice.profitmandi.service.inventory.*;
 import com.spice.profitmandi.service.offers.OfferService;
 import com.spice.profitmandi.service.order.OrderService;
+import com.spice.profitmandi.service.pricecircular.PriceCircularModel;
 import com.spice.profitmandi.service.pricing.PriceDropService;
 import com.spice.profitmandi.service.recharge.provider.OxigenRechargeProviderService;
 import com.spice.profitmandi.service.recharge.provider.ThinkWalnutDigitalRechargeProviderService;
 import com.spice.profitmandi.service.scheme.SchemeService;
 import com.spice.profitmandi.service.serviceConfig.ServiceConfigService;
     @Value("${oxigen.recharge.enquiry.url}")
     private String oxigenRechargeEnquiryUrl;
     @Autowired
+    PurchaseMigration purchaseMigration;
+    @Autowired
     private RegionRepository regionRepository;
     @Autowired
     private ServiceConfigService serviceConfigService;
         } catch (Throwable e) {
             throw new Exception(e);
+        }
+    }
-    private static String getCellString(XSSFCell xssfCell) {
-        xssfCell.setCellType(CellType.STRING);
-        return xssfCell.getStringCellValue();
-    }
     public void test() throws Exception {
-        //Read xls
-        FileInputStream fis = new FileInputStream(new File("/tmp/sample.xlsx"));
-        //creating workbook instance that refers to .xls file
-        XSSFWorkbook wb = new XSSFWorkbook(fis);
-        //creating a Sheet object to retrieve the object
-        XSSFSheet sheet = wb.getSheetAt(0);
-        int rows = sheet.getLastRowNum();
-        List<AddItemModel> addItemModels = new ArrayList<>();
-        for (int rowNum = 1; rowNum < rows; rowNum++) {
-            try {
-                XSSFRow xssfRow = sheet.getRow(rowNum);
-                AddItemModel addItemModel = new AddItemModel();
-                addItemModel.setItemId(Integer.parseInt(getCellString(xssfRow.getCell(0))));
-                addItemModel.setCatalogItemId((Integer.parseInt(getCellString(xssfRow.getCell(1)))));
-                addItemModel.setTp((Integer.parseInt(getCellString(xssfRow.getCell(7)))));
-                addItemModel.setSellingPrice((Integer.parseInt(getCellString(xssfRow.getCell(8)))));
-                addItemModel.setMop((Integer.parseInt(getCellString(xssfRow.getCell(9)))));
-                addItemModel.setMrp((Integer.parseInt(getCellString(xssfRow.getCell(10)))));
-                addItemModels.add(addItemModel);
-            } catch (RuntimeException re) {
-                System.out.println("Could not parse rownum - " + rowNum);
-            }
-        }
-        Map<Integer, List<AddItemModel>> catalogAddItemModelMap = addItemModels.stream().collect(Collectors.groupingBy(x -> x.getCatalogItemId()));
-        try {
-            for (Entry<Integer, List<AddItemModel>> catalogAddItemModelListEntry : catalogAddItemModelMap.entrySet()) {
-                int newCatalogId = itemRepository.getNextEntity();
-                List<AddItemModel> addItemModelList = catalogAddItemModelListEntry.getValue();
-                for (AddItemModel addItemModel : addItemModelList) {
-                    Item item = itemRepository.selectById(addItemModel.getItemId());
-                    Item clonedItem = item.clone();
-                    clonedItem.setCatalogItemId(newCatalogId);
-                    clonedItem.setModelName(String.join(" ", clonedItem.getBrand(), clonedItem.getModelName() == null ? "" : clonedItem.getModelName()));
-                    clonedItem.setBrand("Almost New");
-                    clonedItem.setWarrantyPeriod(6);
-                    clonedItem.setUpdatedOn(LocalDateTime.now());
-                    clonedItem.setMrp((float) addItemModel.getMrp());
-                    clonedItem.setSellingPrice((float) addItemModel.getSellingPrice());
-                    itemRepository.persist(clonedItem);
-                    TagListing tagListing = new TagListing();
-                    tagListing.setItemId(clonedItem.getId());
-                    tagListing.setSellingPrice(clonedItem.getSellingPrice());
-                    tagListing.setActive(true);
-                    tagListing.setCreatedTimestamp(LocalDateTime.now());
-                    tagListing.setTagId(4);
-                    tagListing.setMop((float) addItemModel.getMop());
-                    tagListing.setMrp((float) addItemModel.getMrp());
-                    tagListing.setStartDate(LocalDateTime.now());
-                    tagListingRepository.persist(tagListing);
-                }
-            }
-            //this.migrateDebitNote();
-            //itelImeiActivationNewService.checkItelImeiActivationNew(LocalDate.now(), 15);
-        } catch (Throwable e) {
-            throw new Exception(e);
-        }
+            purchaseMigration.migrateDebitNote();
         //this.sendMailForSamsungRebilling();
         /*List<PurchaseReturnItem> purchaseReturnItems = purchaseReturnItemRepository.selectPurchaseReturnByStatuses(Arrays.asList(PurchaseReturnStatus.DEBIT_NOTE_CREATED));
         Map<Integer, List<PurchaseReturnItem>> inventoryItemsMap = purchaseReturnItems.stream().collect(Collectors.groupingBy(x -> x.getDebitNoteId()));
         for (Map.Entry<Integer, List<PurchaseReturnItem>> debitNotePurcahseReturnMap : inventoryItemsMap.entrySet()) {
             List<InventoryItem> inventoryItems = inventoryItemRepository.selectAllByIds(debitNotePurcahseReturnMap.getValue().stream().map(x -> x.getInventoryItemId()).collect(Collectors.toList()));
     WarehouseSupplierInvoiceRepository warehouseSupplierInvoiceRepository;
     @Autowired
     PurchaseOrderService purchaseOrderService;
-    public void migrateDebitNote() {
-        //Delete all debit notes table and then run this
-        List<WarehouseInvoiceItem> warehouseInvoiceItems = warehouseInvoiceItemRepository.selectAll();
-        List<WarehouseSupplierInvoice> invoices = warehouseSupplierInvoiceRepository.selectAllByIds(warehouseInvoiceItems.stream().map(x -> x.getInvoiceId()).distinct().collect(Collectors.toList()));
-        invoices = invoices.stream().filter(x -> x.getStatus().equals(WarehouseInvoiceStatus.received)).collect(Collectors.toList());
-        invoices.stream().forEach(x -> {
-            GrnModel grnModel = new GrnModel();
-            grnModel.setInvoiceId(x.getId());
-            try {
+    @Autowired
-                purchaseOrderService.generateDebitNote(Arrays.asList(grnModel));
+    VendorCatalogPricingLogRepository vendorCatalogPricingLogRepository;
-            } catch (Exception e) {
-                LOGGER.info("Could not create debit note for invoice - ", x.getInvoiceNumber());
-            }
-        });
-    }
 //    private void checkItelImeiActivationNew(LocalDate now, int i) {
 //    }
     @Autowired
             this.insruanceQty = insruanceQty;
+        }
+    }
+    private void getStateWiseSales
-    private void getStateWiseSales(Map<Integer, SaleTargetReportModel> saleTargetReportModelMap, Map<Integer, FofoReportingModel> partnerSalesHeadersMap) throws Exception {
+            (Map<Integer, SaleTargetReportModel> saleTargetReportModelMap, Map<Integer, FofoReportingModel> partnerSalesHeadersMap) throws
+            Exception {
         String timeString = "Today %s";
         LocalDateTime now = LocalDateTime.now();
         DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("h:m a");
         List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_LOGISTICS, ProfitMandiConstants.TICKET_CATEGORY_FINANCIAL_SERVICES, ProfitMandiConstants.TICKET_CATEGORY_CATEGORY, ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_MARKETING, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT, ProfitMandiConstants.TICKET_CATEGORY_TECHNOLOGY);
+            }
+        }
+    }
-    private void sendMailOfHtmlFormat(JavaMailSender sender, String[] email, String body, String cc[], String subject) throws MessagingException, ProfitMandiBusinessException, IOException {
+    private void sendMailOfHtmlFormat(JavaMailSender sender, String[] email, String body, String cc[], String subject) throws
+            MessagingException, ProfitMandiBusinessException, IOException {
         MimeMessage message = sender.createMimeMessage();
         MimeMessageHelper helper = new MimeMessageHelper(message);
         helper.setSubject(subject);
         helper.setText(body, true);
         helper.setTo(email);
+            }
+        }
+    }
+    private void addMissedScheduledLeadsTable(StringBuilder
-    private void addMissedScheduledLeadsTable(StringBuilder sb, List<Lead> missedScheduleLeads, Map<Integer, AuthUser> authUserMap) {
+                                                      sb, List<Lead> missedScheduleLeads, Map<Integer, AuthUser> authUserMap) {
         sb.append("<h3>Leads That Missed the schedule</h3>");
         sb.append("<table style='border:1px solid black' cellspacing='0'>").append("<tr>").append("<th style='border:1px solid black;padding: 5px'>").append("Lead Id").append("</th>").append("<th style='border:1px solid black;padding: 5px'>").append("Lead Name").append("</th>").append("<th style='border:1px solid black;padding: 5px'>").append("Mobile No").append("</th>").append("<th style='border:1px solid black;padding: 5px'>").append("City").append("</th>").append("<th style='border:1px solid black;padding: 5px'>").append("State").append("</th>").append("<th style='border:1px solid black;padding: 5px'>").append("Created On").append("</th>").append("<th style='border:1px solid black;padding: 5px'>").append("Assigned To").append("</th>").append("<th style='border:1px solid black;padding: 5px'>").append("Scheduled On").append("</th>").append("</tr>");
         for (Lead lead : missedScheduleLeads) {
             sb.append("<tr style='background-color:").append(lead.getColor()).append("'>").append("<td style='border:1px solid black;padding: 5px'>").append(lead.getId()).append("</td>").append("<td style='border:1px solid black;padding: 5px'>").append(lead.getFullName()).append("</td>").append("<td style='border:1px solid black;padding: 5px'>").append(lead.getLeadMobile()).append("</td>").append("<td style='border:1px solid black;padding: 5px'>").append(lead.getCity()).append("</td>").append("<td style='border:1px solid black;padding: 5px'>").append(lead.getState()).append("</td>").append("<td style='border:1px solid black;padding: 5px'>").append(FormattingUtils.formatDate(lead.getCreatedTimestamp())).append("</td>").append("<td style='border:1px solid black;padding: 5px'>").append(
                     authUserMap.containsKey(lead.getAssignTo()) ? authUserMap.get(lead.getAssignTo()).getFullName() : lead.getAssignTo()).append("</td>").append("<td style='border:1px solid black;padding: 5px'>").append(FormattingUtils.formatDate(lead.getScheduledTimestamp())).append("</td>").append("</tr>");
         sb.append("</tbody></table></body></html>");
         return sb.toString();
+    }
-    private String getMessageForUncontacblePartner(List<PartnerCollectionRemark> pcrs) throws ProfitMandiBusinessException {
+    private String getMessageForUncontacblePartner(List<PartnerCollectionRemark> pcrs) throws
+            ProfitMandiBusinessException {
         StringBuilder sb = new StringBuilder();
         sb.append("<html><body><p>Alert</p><p>Not Responding Partner:-</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'>from</th>\n"
                 + "	    				</tr>");
             e.printStackTrace();
+        }
+    }
-    public void selectFinServiceFollowUpDateByCurrDate(LocalDate currentDate) throws MessagingException, ProfitMandiBusinessException, IOException {
+    public void selectFinServiceFollowUpDateByCurrDate(LocalDate currentDate) throws
+            MessagingException, ProfitMandiBusinessException, IOException {
         LOGGER.info("selectfinServiceFollow - {}", "selectfinServiceFollowUpDateByCurrDate");
         serviceConfigService.selectFinServicePartnerfollowUpDateByCurrentDate(currentDate);
+    }
+    }
     @Autowired
     private PartnerCollectionRemarkRepository partnerCollectionRemarkRepository;
+    public void reviewUncontactablePartner() throws
-    public void reviewUncontactablePartner() throws ProfitMandiBusinessException, MessagingException, UnsupportedEncodingException {
+            ProfitMandiBusinessException, MessagingException, UnsupportedEncodingException {
         Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(true);
         List<Integer> pcrms = partnerCollectionRemarkRepository.selectMaxRemarkId(new ArrayList<>(customRetailerMap.keySet()));
      * public void getCCAvenuePendingOrderStatus(int pendingOrderId) { PendingOrder
      * pendingOrder = pendingOrderRepository.selectById(pendingOrderId);
      * ccAvenuePaymentService.getPaymentStatusMap(pendingOrder); }
      */
-    private void calculateInterest(Loan loan, Map<LoanReferenceType, Double> loanStatusAmount, int loanStatementId) throws ProfitMandiBusinessException {
+    private void calculateInterest(Loan loan, Map<LoanReferenceType, Double> loanStatusAmount,
+                                   int loanStatementId) throws ProfitMandiBusinessException {
         LoanStatement loanStatement = loanStatementRepository.selectById(loanStatementId);
         if (loanStatement.getLoanId() == loan.getId()) {
             sdCreditService.addInterest(loanStatement.getCreatedAt().toLocalDate(), LocalDate.now(), loan, loanStatusAmount);
         Utils.sendMailWithAttachments(mailSender, emailTo, ccTo, subject, message);
+    }
-    private void settledLoanStatement(LoanReferenceType loanReferneceType, BigDecimal amount, int fofoId, int loanId, String description, LocalDateTime now) {
+    private void settledLoanStatement(LoanReferenceType loanReferneceType, BigDecimal amount, int fofoId,
+                                      int loanId, String description, LocalDateTime now) {
         sdCreditService.createLoanStatement(loanReferneceType, amount.abs(), fofoId, loanId, description, LocalDateTime.now());
+    }
-    private void createUserWalletHistory(int walletId, int userId, WalletReferenceType referenceType, int loanId, double interestAmount) {
+    private void createUserWalletHistory(int walletId, int userId, WalletReferenceType referenceType, int loanId,
+                                         double interestAmount) {
         UserWalletHistory uwh = new UserWalletHistory();
         uwh.setWalletId(walletId);
         uwh.setFofoId(userId);
         uwh.setBusinessTimestamp(LocalDateTime.now());
         uwh.setReferenceType(referenceType);
             this.sendDefaultLoanAlert(defaultLoans);
+        }
+    }
+    public void sendDefaultLoanAlert(List<Loan> defaultLoans) throws
-    public void sendDefaultLoanAlert(List<Loan> defaultLoans) throws ProfitMandiBusinessException, MessagingException, IOException {
+            ProfitMandiBusinessException, MessagingException, IOException {
         String subject = "Default Partners";
         List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY, ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT);
         for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(categoryIds, false).entrySet()) {
+        }
+    }
     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) {
         Map<Integer, CustomRetailer> customeRetailerMap = retailerService.getAllFofoRetailers();
         LocalDateTime startDate = LocalDate.now().withDayOfMonth(1).atStartOfDay();
         LocalDateTime endDate = LocalDateTime.now();
+    }
     @Autowired
     private VendorItemPricingRepository vendorItemPricingRepository;
-    @Autowired
-    private VendorCatalogPricingLogRepository vendorCatalogPricingLogRepository;
     @Autowired
     private VendorCatalogPricingService vendorCatalogPricingService;

Subversion Repositories SmartDukaan

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