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



import com.spice.profitmandi.dao.service.shopify.ShopifyProductSyncService;
import com.spice.profitmandi.dao.service.solr.FofoSolr;
import com.spice.profitmandi.service.*;
import com.spice.profitmandi.service.integrations.CCAvenuePaymentService;
import com.spice.profitmandi.service.integrations.RazorpayPaymentService;
 
import com.spice.profitmandi.service.integrations.gstpro.GstProAuthService;
import com.spice.profitmandi.service.integrations.gstpro.GstProService;
import com.spice.profitmandi.service.integrations.pinelabs.PinelabsAffordabilityService;
import com.spice.profitmandi.service.integrations.pinelabs.PinelabsAuthService;
import com.spice.profitmandi.service.integrations.pinelabs.PinelabsOfferCacheService;
import com.spice.profitmandi.service.integrations.pinelabs.dto.*;
import com.spice.profitmandi.service.integrations.psismart.PsiSmartService;
 
 
import com.spice.profitmandi.service.inventory.*;
import com.spice.profitmandi.service.AgendaSyncResult;
import com.spice.profitmandi.service.mail.MailOutboxService;
import com.spice.profitmandi.service.offers.OfferService;
import com.spice.profitmandi.service.order.OrderService;

import java.util.stream.Collectors;
import java.util.stream.Stream;
 
import static java.util.stream.Collectors.*;
 
 
@Component
@Transactional(rollbackFor = {Throwable.class, ProfitMandiBusinessException.class})
public class ScheduledTasks {
 
    // Lock to serialize all methods that write to sd_credit_requirement table.

 
    @Autowired
    private com.spice.profitmandi.service.AgendaAutoRuleService agendaAutoRuleService;
 
    @Autowired
 
 
 
    private ASTRepository astRepository;
 
    @Autowired
    private ServiceConfigService serviceConfigService;
 

    CarlcareImeiActivationService carlcareImeiActivationService;
 
    @Autowired
    private PartnerTypeChangeService partnerTypeChangeService;
 
 
    @Autowired
    private LeadRepository leadRepository;
 
    @Autowired
    private AuthRepository authRepository;

    private SaholicInventoryService saholicInventoryService;
 
    @Autowired
    private InsurancePolicyRepository insurancePolicyRepository;
 
 
 
 
    @Value("${oxigen.recharge.auth.key}")
    private String oxigenRechargeAuthKey;
 
    @Value("${oxigen.recharge.validation.url}")

    private CustomerRepository customerRepository;
 
    @Autowired
    private RestClient restClient;
 
 
    @Autowired
    CreditAccountRepository creditAccountRepository;
 
    @Autowired
    CustomerOfferRepository customerOfferRepository;

    @Autowired
    CustomerOfferItemRepository customerOfferItemRepository;
    @Autowired
    private FofoSolr fofoSolr;
 
 
    private static final Logger LOGGER = LogManager.getLogger(ScheduledTasks.class);
 
    private String FCM_URL = "https://fcm.googleapis.com/v1/projects/api-project-309385327230/messages:send";
    private String FCM_SCOPED = "https://www.googleapis.com/auth/cloud-platform";
 

                schemeService.processSchemeOut(fofoOrder.getId(), fofoId);
            }
        }
    }
 
 
    public void rollOutUpgardedMargins(List<Integer> fofoIds) throws Exception {
        LocalDate today = LocalDate.now();
        LocalDate yesterday = today.minusDays(1);
        int upgradedCount = 0;
        List<FofoStore> stores;

        Map<String, AgeingModel> ageingModelMap = ageingService.getAllAgeingForSecondary();
 
        System.out.println(ageingModelMap.size());
        List<PartnerAgeingModel> partnerAgeingModels = ageingService.getAllAgeingForTertiary();
 
 
        ByteArrayOutputStream byteArrayOutputStream = FileUtil.getCSVByteStream(Arrays.asList("InventoryItemId", "Serial Number", "Item Id", "Brand", "Model Name", "ModelNumber", "Color", "Exceed Days", "Last ScanType", "Supplier Name", "Current Warehouse", "First Warehouse", "Invoice Number", "Invoice Date"), ageingModelMap.values().stream().map(x -> Arrays.asList(x.getInventoryItemId(), x.getSerialNumber(), x.getItemId(), x.getBrand(), x.getModelName(), x.getModelNumber(), x.getColor(), x.getExceedDays(), x.getLastScanType(), x.getSupplierName(), x.getCurrentWarehouse(), x.getFirstWarehouse(), x.getInvoiceNumber(), FormattingUtils.formatDate(x.getInvoiceDate()))).collect(Collectors.toList()));
 
        ByteArrayOutputStream byteArrayOutputStream2 = FileUtil.getCSVByteStream(Arrays.asList("InventoryItemId", "Serial Number", "Item Id", "Brand", "Model Name", "ModelNumber", "Color", "Partner Id", "Partner Code", "Partner Name", "Activation Type", "City", "State", "Billing Date", "Exceed Days", "Max Ageing", "Activation Date"), partnerAgeingModels.stream().map(x -> Arrays.asList(x.getInventoryItemId(), x.getSerialNumber(), x.getItemId(), x.getBrand(), x.getModelName(), x.getModelNumber(), x.getColor(), x.getFofoId(), x.getFofoCode(), x.getFofoName(), x.getActivationType(), x.getFofoCity(), x.getFofoState(), FormattingUtils.formatDate(x.getBillingDate()), x.getExceedDays(), x.getMaxAgeingDays(), x.getActivationDate())).collect(Collectors.toList()));
        Attachment attachment1 = new Attachment("secondary-alert.csv", new ByteArrayResource(byteArrayOutputStream.toByteArray()));
        Attachment attachment2 = new Attachment("tertiary-alert.csv", new ByteArrayResource(byteArrayOutputStream2.toByteArray()));
 
        String mailSubject = "Stock ageing Alert";
        mailOutboxService.queueMailWithAttachmentsViaGoogle(new String[]{"deena.nath@smartdukaan.com"}, null, mailSubject, "PFA", "ScheduledTasks.sendMailForAgeingAlert", attachment1, attachment2);
    }
 
 
    public void processDeductions() {
        sidbiService.processDeductions();
    }
 
    public void resetHardLimit() throws ProfitMandiBusinessException {

                sdCreditService.settleLoan(x);
            } catch (ProfitMandiBusinessException e) {
                throw new RuntimeException(e);
            }
        });*/
 
    }
 
    private void regenerateDCInvoices() {
        List<String> dcInvoiceNumbers = Arrays.asList(
                "DCNSUPDL5", "DCNSUPDL4", "DCNSLCK2", "DCNSUPDL3",

            int loanAmount = blockedLoan.getIntialAmount().intValue();
            if (loanAmount > -amount) {
                sdCreditService.settleBlockedLoan(transactionId, loanAmount + amount);
            }
 
 
        }
    }
 
    @Autowired
    LoanTransactionRepository loanTransactionRepository;

            System.out.println("processedOrderIds " + processedOrderIds);
            //if(unsettledBlockedLoan !=null) continue;
            double limitToRelease = processedOrders.stream().collect(Collectors.summingDouble(x -> x.getWalletAmount()));
            sdCreditService.releaseBlockedLimit(unsettledBlockedLoan, limitToRelease);
 
 
        }
    }
 
    private void fixStuckLimitBlocks(int maxFixes) {
        int[] stuckIds = {100908, 100909, 102018, 104843, 105119, 105613, 105758, 105766, 105999};

        //this.processOrdersToRebill(fofoIdImeiReturnMap, debitNoteDate);
        purchaseReturnService.fixReturns(fofoIdImeiReturnMap, debitNoteDate);
 
    }
 
 
    private void processOrdersToRebill(Map<Integer, Set<String>> fofoIdImeiReturnMap, LocalDateTime debitNoteDate) throws Exception {
 
 
        for (Entry<Integer, Set<String>> fofoIdImeiReturnEntry : fofoIdImeiReturnMap.entrySet()) {
            int fofoId = fofoIdImeiReturnEntry.getKey();
            Set<String> imeis = fofoIdImeiReturnEntry.getValue();
            List<InventoryItem> inventoryItems = inventoryItemRepository.selectByFofoIdSerialNumbers(fofoId, imeis, true);
            for (InventoryItem inventoryItem : inventoryItems) {

    CommonPaymentService commonPaymentService;
 
    @Autowired
    LineItemImeisRepository lineItemImeisRepository;
 
 
    //Also create order
    private List<CartItem> refundDnAmount(DebitNote debitNote) throws ProfitMandiBusinessException {
        List<Integer> inventoryItemIds = purchaseReturnItemRepository.selectAllByDebitNoteId(debitNote.getId()).stream().map(x -> x.getInventoryItemId()).collect(Collectors.toList());
        Map<Integer, Long> inventoryItemCountMap = inventoryItemIds.stream().collect(groupingBy(x -> x, Collectors.counting()));
        List<InventoryItem> inventoryItems = inventoryItemRepository.selectAllByIds(new ArrayList<>(inventoryItemCountMap.keySet()));

    VendorCatalogPricingLogRepository vendorCatalogPricingLogRepository;
 
//    private void checkItelImeiActivationNew(LocalDate now, int i) {
//    }
 
 
 
    public void sendMailForSamsungRebilling() throws Exception {
        List<BilledImeiModel> samsungModels = warehouseInventoryItemRepository.findByBillingDateBrand(LocalDate.now(), "Samsung");
        LOGGER.info("SamsungModels {}", samsungModels);
        samsungModels = samsungModels.stream().sorted(Comparator.comparing(x -> x.getPcmDate() == null ? -1 : 1)).collect(Collectors.toList());
        if (samsungModels.size() > 0) {

                LOGGER.info("Invoice {}, Date {}", fofoOrder.getInvoiceNumber(), fofoOrder.getCreateTimestamp());
                LOGGER.info("customerAddress.getState() {}, retailerAddress.getState() {}", customerAddress.getState(), retailerAddress.getState());
                LOGGER.info("Rates getIgstRate() {}", itemIdStateTaxRateMap.get(foi.getItemId()).getIgstRate());
                LOGGER.info("Rates getCgstRate() {}, getSgstRate() {}", itemIdStateTaxRateMap.get(foi.getItemId()).getCgstRate(), itemIdStateTaxRateMap.get(foi.getItemId()).getSgstRate());
 
 
            }
        }
 
    }
 

         */
 
        List<Integer> fofoIds = null;
        Map<Integer, FofoStore> fofoStoreMap = fofoStoreRepository.selectAll().stream().filter(x -> x.isActive()).collect(Collectors.toMap(x -> x.getId(), x -> x));
 
 
        if (fofoIdInt == null) {
            fofoIds = new ArrayList<>(fofoStoreMap.keySet());
        } else {
            fofoIds = Arrays.asList(fofoIdInt);
        }

        private double past3daysSale;
        private int fofoId;
        private String code;
        private ActivationType activationType;
 
 
        @Override
        public boolean equals(Object o) {
            if (this == o) return true;
            if (o == null || getClass() != o.getClass()) return false;
            SaleTargetReportModel that = (SaleTargetReportModel) o;

                sb.append("</tbody></table><br><br>");
 
                sb.append("<p>Partnerwise Report:</p><br/><table style=\"border-collapse: collapse;\">");
                sb.append("<tbody>\n" + "	    				<tr>\n" + "	    					<th style='border:1px solid black;padding: 5px'>Code</th>" + "	    					<th style='border:1px solid black;padding: 5px'>Business Name</th>" + "	    					<th style='border:1px solid black;padding: 5px'>BDM Name</th>" + "	    					<th style='border:1px solid black;padding: 5px'>Regional Manager</th>" + "	    					<th style='border:1px solid black;padding: 5px'>Territory Manager</th>" + "	    					<th style='border:1px solid black;padding: 5px'>Billed(4 days)</th>" + "	    					<th style='border:1px solid black;padding: 5px'>Sale</th>" + "	    					<th style='border:1px solid black;padding: 5px'>Smartphone Sale</th>" + "	    					<th style='border:1px solid black;padding: 5px'>SmartPhone Qty</th>" + "	    				</tr>");
 
 
                List<Integer> sortedSaleTargetReport = saleTargetReportModelMap.values().stream().filter(x -> fofoIds.contains(x.getFofoId())).sorted(Comparator.comparing(SaleTargetReportModel::getCode).thenComparing(SaleTargetReportModel::getSecondary)).map(SaleTargetReportModel::getFofoId).collect(Collectors.toList());
 
                String subject = String.format("Sale till %s", String.format(timeString, now.format(timeFormatter)));
 
                List<String> headers = Arrays.asList("Store Id", "Store Code", "Store Name", "Activation Type", "BDM Name", "Regional Manager", "Territory Manager", "Secondary(4 days)", "Sale", "Smartphone Value", "Smartphone Qty");

                    sb.append("<td style='border:1px solid black;padding: 5px'>" + saleTargetReportModelMap.get(fofoId).getTotalSale() + "</td>");
                    sb.append("<td style='border:1px solid black;padding: 5px'>" + saleTargetReportModelMap.get(fofoId).getSmartphoneSale() + "</td>");
                    sb.append("<td style='border:1px solid black;padding: 5px'>" + saleTargetReportModelMap.get(fofoId).getSmartphoneQty() + "</td>");
                    sb.append("</tr>");
 
 
                }
                sb.append("</tr>");
                sb.append("</body></html>");
                String statewiseSaleReport = sb.toString();
 
 
                ByteArrayOutputStream baos = null;
                try {
                    baos = FileUtil.getCSVByteStream(headers, rows);
                } catch (Exception e2) {
                    e2.printStackTrace();

                Utils.sendHtmlMailWithAttachments(googleMailSender, new String[]{email}, null, "Statewise " + subject, statewiseSaleReport, attachment);
            }
        }
    }
 
 
    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);

                }
            }
        }
    }
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
    public void schemeRollback(List<String> schemeIds) throws Exception {
        List<Integer> schemeIdsInt = schemeIds.stream().map(x -> Integer.parseInt(x)).collect(Collectors.toList());
        Map<Integer, Scheme> schemesMap = schemeRepository.selectBySchemeIds(schemeIdsInt, 0, schemeIds.size()).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
        List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectBySchemeIds(new HashSet<>(schemeIdsInt));
        for (SchemeInOut sio : schemeInOuts) {

 
            Map<Integer, PartnerCollectionRemark> rbmEscalatedRemarksMap = partnerCollectionRemarks.stream().filter(x -> x.getRemark().equals(CollectionRemark.RBM_L2_ESCALATION)).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
            Map<Integer, PartnerCollectionRemark> rbmL3EscalatedRemarksMap = partnerCollectionRemarks.stream().filter(x -> x.getRemark().equals(CollectionRemark.RBM_L3_ESCALATION)).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
            Map<Integer, PartnerCollectionRemark> salesEscalatedRemarksMap = partnerCollectionRemarks.stream().filter(x -> x.getRemark().equals(CollectionRemark.SALES_ESCALATION)).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
 
 
            if (!rbmEscalatedRemarksMap.isEmpty()) {
                //
                for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_RBM), true).entrySet()) {
                    List<PartnerCollectionRemark> filteredRows = storeGuyEntry.getValue().stream()
                            .map(x -> rbmEscalatedRemarksMap.get(x)).filter(x -> x != null).collect(Collectors.toList());

            }
 
        }
    }
 
 
    @Autowired
    private NonSdBuyingRepository nonSdBuyingRepository;
 
    //Non Sd Buying
    public void reviewNonSdBuyingBrand() throws

                    helper.setFrom(senderAddress);
                    gmailRelaySender.send(message);
                    LOGGER.info("unAuthorizedfilteredRows {}", unAuthorizedfilteredRows);
                }
 
 
            }
 
        }
    }
 

            }
        }
 
    }
 
 
    private void sendUnholdEmail(List<Order> orders) throws Exception {
 
 
        orders.forEach(x -> x.setShipmentHold(false));
        orders = orders.stream().filter(x -> x.getRefundTimestamp() != null).collect(Collectors.toList());
        if (orders.size() > 0) {
 
            double totalAmount = orders.stream().collect(Collectors.summingDouble(x -> x.getTotalAmount()));

            String subject = "Dispatch held orders of - " + (orders.get(0).getRetailerName());
            String message = String.format("Dear Team, \n" + "kindly note the material for the " + orders.get(0).getRetailerName() + "of Rs." + totalAmount + "is unhold now and needs to be dispatched.");
            mailOutboxService.queueMailViaGoogle(emailTo, ccTo, subject, message, "ScheduledTasks.sendUnholdEmail");
        }
 
 
    }
 
    // Nightly at 23:30: detect beat-days the assignee missed (no PUNCHIN, or punched
    // in but no stops worked) and fan out per-stop miss rows into beat_deferred_visit
    // so the Deferred Partners panel surfaces them. Idempotent on repeat runs.

            175140101
    );*/
 
    private static List<Integer> hundredPercentLimitPartnerIds = Arrays.asList();
 
 
 
    public void notifyDefaultLoans() throws ProfitMandiBusinessException, MessagingException, IOException {
        synchronized (SD_CREDIT_LOCK) {
            sdCreditService.updateRisk();
            List<Loan> defaultLoans = sdCreditService.getDefaultLoans();
            if (!defaultLoans.isEmpty()) {

                byteArrayOutputStream = this.generateLoanCsv(filteredAllActiveLoans);
                attachment1 = new Utils.Attachment("partnner-credit.csv", new ByteArrayResource(byteArrayOutputStream.toByteArray()));
 
            }
 
 
            if (!filteredRows.isEmpty()) {
                String messageText = this.getMessageForDueDateCross(filteredRows);
                String[] email = new String[]{storeGuyEntry.getKey(),"neeraj.gupta@smartdukaan.com"};
 
                if (attachment1 != null) {

            mailOutboxService.queueMailWithAttachmentsViaGoogle(new String[]{"sdtech@smartdukaan.com"}, null, null, "Partner Credit Report", messageText, true, "ScheduledTasks.sendDueDateCrossLoanAlert", attachment);
        } else {
            this.sendMailOfHtmlFormat(googleMailSender, new String[]{"sdtech@smartdukaan.com"}, messageText, null, "Due Date Cross");
        }
 
 
        if (!dueDateCrossLoans.isEmpty()) {
            for (Loan loan : dueDateCrossLoans) {
                double principal = loan.getPendingAmount().doubleValue();
                double interest = loan.getInterestAccrued().doubleValue() - loan.getInterestPaid().doubleValue();
                double total = principal + interest;

    }
 
    private ByteArrayOutputStream generateLoanCsv(List<Loan> loans) throws ProfitMandiBusinessException {
        org.apache.commons.io.output.ByteArrayOutputStream byteArrayOutputStream = null;
 
 
        if (!loans.isEmpty()) {
            Map<Integer, com.spice.profitmandi.dao.model.FofoReportingModel> fofoReportingModelMap = csService.getPartnerIdSalesHeaders();
            Map<Integer, FofoRBMReportingModel> fofoRbmReportingModelMap = csService.getPartnerIdRBMHeaders();
            List<AST> asts = astRepository.selectAll();
            Map<Integer, AST> astMap = asts.stream()

                    rows.add(row);
                }
 
                byteArrayOutputStream = FileUtil.getCSVByteStream(headers, rows);
 
 
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
 
        }
        return byteArrayOutputStream;
    }
 
 
    public void alertForDueDate() throws Exception {
 
        List<Loan> loans = loanRepository.selectAllActiveLoan();
 
        for (Loan loan : loans) {

 
        }
 
    }
 
 
    public void findAllLiveDemoBrandItemsByBillingDate() throws
            MessagingException, ProfitMandiBusinessException, IOException {
        LocalDateTime endDate = LocalDate.now().atStartOfDay().minusDays(8);
 
        List<LiveDemoOrderLineItemModel> liveDemoOrderLineItemModels = orderRepository.findAllLiveDemoBrandItemsByBillingDate(endDate.minusDays(60), endDate);

 
        }
        List<String> sendTo = Arrays.asList("kamini.sharma@smartdukaan.com", "niranjan.kala@smartdukaan.com",
                "mohit.gulati@smartdukaan.com", "vinay.p@smartdukaan.com", "shivam.gupta@smartdukaan.com");
 
 
        String[] email = sendTo.toArray(new String[sendTo.size()]);
    this.sendMailOfHtmlFormat(googleMailSender, email, sb.toString(), null, subject);
 
    }
 

        String[] email = sendTo.toArray(new String[sendTo.size()]);
        this.sendMailOfHtmlFormat(googleMailSender, email, sb.toString(), null, subject);
 
    }
 
 
    public void monthlyTargetForInternalTeam() throws MessagingException, ProfitMandiBusinessException, IOException {
 
        LocalDateTime curDate = LocalDateTime.now();
 
        List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY, ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_ABM, ProfitMandiConstants.TICKET_CATEGORY_MARKETING, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT);

    }
 
    @Autowired
    private PerformanceService performanceService;
 
 
    public void sendFilteredRetailerPerformance() throws Exception {
        RetailerFilterModel retailerFilterModel = performanceService.getRetailerFilterModel();
 
        Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(true);
 
 
        List<RetailerPeformanceFilterModel> partnersPerformance = performanceService.getPerformance(retailerFilterModel, customRetailers);
 
        Map<Integer, RetailerPeformanceFilterModel> partnersPerformanceMap = new HashMap<>();
 
        if (!partnersPerformance.isEmpty()) {
            partnersPerformanceMap = partnersPerformance.stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
            performanceService.sendPartnerPerformanceEmail(partnersPerformanceMap, retailerFilterModel, customRetailers);
 
        }
 
 
    }
 
    @Autowired
    private VendorCatalogPricingService vendorCatalogPricingService;
 
 
    public void approveVendorCatalogPricing() {
        List<VendorCatalogPricingLog> vendorCatalogPricingLogs = vendorCatalogPricingLogRepository.selectByStatus(VendorCatalogPricingStatus.PENDING);
 
 
        for (VendorCatalogPricingLog vendorCatalogPricingLog : vendorCatalogPricingLogs) {
            vendorCatalogPricingLog.setStatus(VendorCatalogPricingStatus.APPROVED);
            vendorCatalogPricingLog.setUpdatedTimestamp(LocalDateTime.now());
            vendorCatalogPricingLog.setApprovedBy(13);
            vendorCatalogPricingLog.setApprovedTimestamp(LocalDateTime.now());

        sb.append("<p>Team SmartDukaan</p>");
        sb.append("</body></html>");
        return sb.toString();
    }
 
 
    @Autowired
    private FofoOpeningStockRepository fofoOpeningStockRepository;
    @Autowired
    private SmartCartService smartCartService;
 

                        .values()
                        .stream()
                        .collect(Collectors.toList())
        );
 
 
        Map<Integer, Map<Integer, Integer>> activatedButNotBilledCatalogQtyMap = smartCartService.activatedButNotBilledCatalogQtyMap();
        LOGGER.info("PartnerOpeningStockByTodayModel {}", partnerOpeningStockByTodayMap);
        for (Map.Entry<Integer, List<PartnerOpeningStockByTodayModel>> entry : partnerOpeningStockByTodayMap.entrySet()) {
            int fofoId = entry.getKey();
            List<PartnerOpeningStockByTodayModel> partnerStockList = entry.getValue();

                }
 
                // Subtract soldQty from partnerCurrentQty
                int partnerCurrentQty = Math.max(stockCurrentQty - soldButNotBilledQty, 0); // Ensure it doesn't go negative
 
 
                // Check if an entry already exists in the FofoOpeningStock table
                FofoOpeningStock existingStock = fofoOpeningStockRepository.findByFofoIdAndCatalogId(fofoId, catalogId);
 
 
                if (existingStock != null) {
                    if (partnerCurrentQty < 1 && existingStock.getOpeningDate().isBefore(LocalDate.now().minusDays(5))) {
                        fofoOpeningStockRepository.delete(existingStock);
                    }
                    if (existingStock.getOpeningQty() < partnerCurrentQty) {

            }
 
        }
    }
 
 
    @Autowired
    private CategorisedCatalogRepository categorisedCatalogRepository;
 
    public void groupHidCatalogsByWeeks() throws ProfitMandiBusinessException, MessagingException, IOException {
        List<CategorisedCatalogListModel> categorisedCatalogs = categorisedCatalogRepository.getListByStatus(CatalogMovingEnum.HID);

        // Older than Two Weeks Ago (anything older than three weeks ago)
        List<CategorisedCatalogListModel> olderCatalogs = categorisedCatalogs.stream()
                .filter(catalog -> catalog.getStatusCreatedDate().isBefore(threeWeeksAgo))
                .collect(Collectors.toList());
 
 
        String subject = "Hid Catalogs";
        StringBuilder sb = new StringBuilder();
 
        sb.append("<html><body><p>Hi Catagory Team,\n");
        sb.append("<p style='font-weight:500;'>Please review the HID catalogs for this week:</p>\n" + "<table style='border:1px solid black ;padding: 5px; border-collapse: collapse;'>");

        sb.append("</table>");
        sb.append("</body></html>");
 
        List<String> sendTo = Arrays.asList("sourcing@smartdukaan.com", "tarun.verma@smartdukaan.com");
 
 
        String[] email = sendTo.toArray(new String[sendTo.size()]);
 
        this.sendMailOfHtmlFormat(gmailRelaySender, email, sb.toString(), null, subject);
    }
 

Subversion Repositories SmartDukaan

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

Rev 37658		Rev 37735
Line 82...		Line 82...
82	`import com.spice.profitmandi.dao.service.shopify.ShopifyProductSyncService;`	82	`import com.spice.profitmandi.dao.service.shopify.ShopifyProductSyncService;`
83	`import com.spice.profitmandi.dao.service.solr.FofoSolr;`	83	`import com.spice.profitmandi.dao.service.solr.FofoSolr;`
84	`import com.spice.profitmandi.service.*;`	84	`import com.spice.profitmandi.service.*;`
85	`import com.spice.profitmandi.service.integrations.CCAvenuePaymentService;`	85	`import com.spice.profitmandi.service.integrations.CCAvenuePaymentService;`
86	`import com.spice.profitmandi.service.integrations.RazorpayPaymentService;`	86	`import com.spice.profitmandi.service.integrations.RazorpayPaymentService;`
87	`import com.spice.profitmandi.service.integrations.bharti.model.BAGInsuranceModel;`	-
88	`import com.spice.profitmandi.service.integrations.gstpro.GstProAuthService;`	87	`import com.spice.profitmandi.service.integrations.gstpro.GstProAuthService;`
89	`import com.spice.profitmandi.service.integrations.gstpro.GstProService;`	88	`import com.spice.profitmandi.service.integrations.gstpro.GstProService;`
90	`import com.spice.profitmandi.service.integrations.pinelabs.PinelabsAffordabilityService;`	89	`import com.spice.profitmandi.service.integrations.pinelabs.PinelabsAffordabilityService;`
91	`import com.spice.profitmandi.service.integrations.pinelabs.PinelabsAuthService;`	90	`import com.spice.profitmandi.service.integrations.pinelabs.PinelabsAuthService;`
92	`import com.spice.profitmandi.service.integrations.pinelabs.PinelabsOfferCacheService;`	91	`import com.spice.profitmandi.service.integrations.pinelabs.PinelabsOfferCacheService;`
93	`import com.spice.profitmandi.service.integrations.pinelabs.dto.*;`	92	`import com.spice.profitmandi.service.integrations.pinelabs.dto.*;`
94	`import com.spice.profitmandi.service.integrations.psismart.PsiSmartService;`	93	`import com.spice.profitmandi.service.integrations.psismart.PsiSmartService;`
95	`import com.spice.profitmandi.service.integrations.smartping.SmartPingService;`	-
96	`import com.spice.profitmandi.service.integrations.toffee.ToffeeService;`	-
97	`import com.spice.profitmandi.service.inventory.*;`	94	`import com.spice.profitmandi.service.inventory.*;`
98	`import com.spice.profitmandi.service.AgendaSyncResult;`	95	`import com.spice.profitmandi.service.AgendaSyncResult;`
99	`import com.spice.profitmandi.service.mail.MailOutboxService;`	96	`import com.spice.profitmandi.service.mail.MailOutboxService;`
100	`import com.spice.profitmandi.service.offers.OfferService;`	97	`import com.spice.profitmandi.service.offers.OfferService;`
101	`import com.spice.profitmandi.service.order.OrderService;`	98	`import com.spice.profitmandi.service.order.OrderService;`
Line 159...		Line 156...
159	`import java.util.stream.Collectors;`	156	`import java.util.stream.Collectors;`
160	`import java.util.stream.Stream;`	157	`import java.util.stream.Stream;`
161		158
162	`import static java.util.stream.Collectors.*;`	159	`import static java.util.stream.Collectors.*;`
163		160
164		-
165	`@Component`	161	`@Component`
166	`@Transactional(rollbackFor = {Throwable.class, ProfitMandiBusinessException.class})`	162	`@Transactional(rollbackFor = {Throwable.class, ProfitMandiBusinessException.class})`
167	`public class ScheduledTasks {`	163	`public class ScheduledTasks {`
168		164
169	`// Lock to serialize all methods that write to sd_credit_requirement table.`	165	`// Lock to serialize all methods that write to sd_credit_requirement table.`
Line 187...		Line 183...
187		183
188	`@Autowired`	184	`@Autowired`
189	`private com.spice.profitmandi.service.AgendaAutoRuleService agendaAutoRuleService;`	185	`private com.spice.profitmandi.service.AgendaAutoRuleService agendaAutoRuleService;`
190		186
191	`@Autowired`	187	`@Autowired`
192	`SmartPingService smartPingService;`	-