Subversion Repositories SmartDukaan

package com.smartdukaan.cron.scheduled;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
import com.spice.profitmandi.common.model.CustomRetailer;
import com.spice.profitmandi.common.model.ProfitMandiConstants;
import com.spice.profitmandi.dao.cart.CartService;
import com.spice.profitmandi.dao.cart.SmartCartService;
import com.spice.profitmandi.dao.entity.auth.AuthUser;
import com.spice.profitmandi.dao.entity.fofo.*;
import com.spice.profitmandi.dao.entity.logistics.AST;
import com.spice.profitmandi.dao.entity.logistics.ASTRepository;
import com.spice.profitmandi.dao.entity.logistics.AreaRepository;
import com.spice.profitmandi.dao.entity.transaction.Loan;
import com.spice.profitmandi.dao.entity.transaction.Order;
import com.spice.profitmandi.dao.entity.transaction.Transaction;
import com.spice.profitmandi.dao.entity.user.User;
import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
import com.spice.profitmandi.dao.model.BIRetailerModel;
import com.spice.profitmandi.dao.model.BiSecondaryModel;
import com.spice.profitmandi.dao.model.ReturnOrderInfoModel;
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
import com.spice.profitmandi.dao.repository.cs.CsService;
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
import com.spice.profitmandi.dao.repository.fofo.*;
import com.spice.profitmandi.dao.repository.inventory.StateRepository;
import com.spice.profitmandi.dao.repository.transaction.LoanRepository;
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
import com.spice.profitmandi.dao.repository.transaction.ReturnOrderInfoRepository;
import com.spice.profitmandi.dao.repository.transaction.TransactionRepository;
import com.spice.profitmandi.dao.repository.user.UserRepository;
import com.spice.profitmandi.service.transaction.SDCreditService;
import com.spice.profitmandi.service.user.RetailerService;
import in.shop2020.model.v1.order.OrderStatus;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.mail.javamail.MimeMessageHelper;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import javax.mail.MessagingException;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import java.io.IOException;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.YearMonth;
import java.time.temporal.ChronoUnit;
import java.util.*;
import java.util.stream.Collectors;

@Component
@Transactional(rollbackFor = {Throwable.class, ProfitMandiBusinessException.class})
public class ScheduledTasksTest {

    private static final Logger LOGGER = LogManager.getLogger(ScheduledTasksTest.class);

    @Autowired
    TransactionRepository transactionRepository;

    @Autowired
    LoanRepository loanRepository;

    @Autowired
    SDCreditService sdCreditService;

    @Autowired
    UserRepository userRepository;

    @Autowired
    CsService csService;

    @Autowired
    RbmRatingRepository rbmRatingRepository;

    @Autowired
    private JavaMailSender mailSender;

    @Autowired
    SalesRatingRepository salesRatingRepository;

    @Autowired
    FofoStoreRepository fofoStoreRepository;

    @Autowired
    SmartCartService smartCartService;

    @Autowired
    RetailerService retailerService;

    @Autowired
    ASTRepository astRepository;

    @Autowired
    AuthRepository authRepository;

    @Autowired
    StateRepository stateRepository;

    @Autowired
    MonthlyTargetRepository monthlyTargetRepository;

    @Autowired
    PartnerTypeChangeService partnerTypeChangeService;

    @Autowired
    ReturnOrderInfoRepository returnOrderInfoRepository;

    @Autowired
    OrderRepository orderRepository;

    public void test() throws Exception {
        System.out.println("test start");
//        smartCartService.activatedButNotBilledCatalogQtyMap();
        System.out.println("test end");

    }

    public void createLoanForBillingByTransactionIdAndInvoiceNumber(int transactionId, double invoiceAmount, String invoiceNumber) throws Exception {
        sdCreditService.createLoanForBilling(transactionId, invoiceAmount, invoiceNumber);

    }


    private void sendMailHtmlFormat(String email[], String body, String cc[], String bcc[], String subject)
            throws MessagingException, ProfitMandiBusinessException, IOException {
        MimeMessage message = mailSender.createMimeMessage();
        MimeMessageHelper helper = new MimeMessageHelper(message);
        helper.setSubject(subject);
        helper.setText(body, true);
        helper.setTo(email);
        if (cc != null) {
            helper.setCc(cc);
        }
        if (bcc != null) {
            helper.setBcc(bcc);

        }

        InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smart Dukaan");
        helper.setFrom(senderAddress);
        mailSender.send(message);
    }

    public Map<Integer,Integer> findLoanTransactionMapingAccordingLoan(List<Integer> loanIds) throws ProfitMandiBusinessException {

        Map<Integer, Integer> transactionLoanMap = new HashMap<>();

        for(int loanId : loanIds){
            Transaction transaction = null;
            Loan loan = loanRepository.selectByLoanId(loanId);
            List<Transaction> transactions = transactionRepository.selectByRetailerId(loan.getFofoId());

            LocalDateTime nearestDateTime = transactions.stream().map(x -> x.getCreateTimestamp())
                    .min(Comparator.comparingLong(x -> Math.abs(ChronoUnit.MILLIS.between(x, loan.getCreatedOn()))))
                    .orElse(null);

            if (nearestDateTime != null && loan.getCreatedOn().plusMinutes(2).isAfter(nearestDateTime) &&
                    loan.getCreatedOn().minusMinutes(1).isBefore(nearestDateTime)) {
                // Here transaction is still null
                transaction = transactions.stream()
                        .filter(x -> x.getCreateTimestamp().equals(nearestDateTime))
                        .findFirst().get();
                transactionLoanMap.put(transaction.getId(), loanId);
            }

        }
        LOGGER.info("transactionLoanMap {}",transactionLoanMap);
        return transactionLoanMap;
    }



    public void sendRbmFeedbackSummaryEmail() throws MessagingException, ProfitMandiBusinessException, IOException {
        LocalDateTime startOfMonth = LocalDate.now().withDayOfMonth(1).atStartOfDay();
        LocalDateTime endOfMonth = LocalDateTime.now();
        String[] bcc = {"tarun.verma@smartdukaan.com"};

        // Get all RBM users
        List<AuthUser> authUsers = csService.getAuthUserIds(
                ProfitMandiConstants.TICKET_CATEGORY_RBM,
                Arrays.asList(EscalationType.L1)
        );

        if (authUsers.isEmpty()) {
            LOGGER.info("No RBMs found.");
            return;
        }

        List<Integer> rbmIds = authUsers.stream().map(AuthUser::getId).collect(Collectors.toList());

        // Fetch ratings for all RBMs for current month
        List<RbmRating> feedbackList = rbmRatingRepository.selectByRbmIdsAndDateRange(rbmIds, startOfMonth, endOfMonth);

        if (feedbackList.isEmpty()) {
            LOGGER.info("No feedback entries found for RBMs.");
            return;
        }

        // Sort feedback by createTimeStamp DESC
        feedbackList.sort((a, b) -> b.getCreateTimeStamp().compareTo(a.getCreateTimeStamp()));

        // Fetch and map FOFO (partner) names
        Map<Integer, String> fofoNameMap = new HashMap<>();
        for (RbmRating rating : feedbackList) {
            int fofoId = rating.getFofoId();
            if (!fofoNameMap.containsKey(fofoId)) {
                User fofoUser = userRepository.selectById(fofoId);
                FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);

                String partnerName = fofoUser != null ? fofoUser.getName() : "Unknown Partner";
                String storeCode = fofoStore != null ? fofoStore.getCode() : "Unknown Code";

                String displayName = partnerName + " (" + storeCode + ")";
                fofoNameMap.put(fofoId, displayName);
            }
        }

        // Map RBM ID to name for quick lookup
        Map<Integer, String> rbmNameMap = authUsers.stream()
                .collect(Collectors.toMap(AuthUser::getId, AuthUser::getFullName));

        // Generate HTML content
        StringBuilder emailContent = new StringBuilder();
        emailContent.append("<html><body>");
        emailContent.append("<p>Dear Team,</p>");
        emailContent.append("<p>Here is the <b>latest RBM Rating and Feedback Summary</b> for ")
                .append(LocalDate.now().getMonth()).append(":</p>");

        emailContent.append("<table border='1' cellspacing='0' cellpadding='5'>");
        emailContent.append("<tr>")
                .append("<th>RBM Name</th>")
                .append("<th>Partner Name</th>")
                .append("<th>Rating</th>")
                .append("<th>Comment</th>")
                .append("<th>Date</th>")
                .append("</tr>");

        for (RbmRating rating : feedbackList) {
            String rbmName = rbmNameMap.getOrDefault(rating.getRbmId(), "Unknown RBM");
            String partnerName = fofoNameMap.getOrDefault(rating.getFofoId(), "Unknown Partner");
            emailContent.append("<tr>")
                    .append("<td>").append(rbmName).append("</td>")
                    .append("<td>").append(partnerName).append("</td>")
                    .append("<td>").append(rating.getRating()).append("</td>")
                    .append("<td>").append(rating.getComment() != null ? rating.getComment() : "-").append("</td>")
                    .append("<td>").append(rating.getCreateTimeStamp().toLocalDate()).append("</td>")
                    .append("</tr>");
        }

        emailContent.append("</table>");
        emailContent.append("<br><p>Regards,<br>Smart Dukaan Team</p>");
        emailContent.append("</body></html>");

        String subject = "Monthly RBM Feedback Summary - " + LocalDate.now().getMonth();

        List<String> sendTo = new ArrayList<>();
        sendTo.add("sm@smartdukaan.com"); //
        sendTo.add("chiranjib.sarkar@smartdukaan.com"); //
        sendTo.add("kamini.sharma@smartdukaan.com"); //

        String[] emailRecipients = sendTo.toArray(new String[0]);


        this.sendMailHtmlFormat(emailRecipients, emailContent.toString(), null, bcc, subject);

        LOGGER.info("Consolidated RBM feedback summary email sent.");
    }


    public void sendSalesFeedbackSummaryEmail() throws MessagingException, ProfitMandiBusinessException, IOException {
        LocalDateTime startOfMonth = LocalDate.now().withDayOfMonth(1).atStartOfDay();
        LocalDateTime endOfMonth = LocalDateTime.now();
        String[] bcc = {"tarun.verma@smartdukaan.com"};
//        String[] bcc = {"tejus.lohani@smartdukaan.com"};

        // Get all RBM users
        List<AuthUser> authUsers = csService.getAuthUserIds(
                ProfitMandiConstants.TICKET_CATEGORY_SALES,
                Arrays.asList(EscalationType.L1)
        );

        if (authUsers.isEmpty()) {
            LOGGER.info("No sales person found.");
            return;
        }

        List<Integer> salesL1Ids = authUsers.stream().map(AuthUser::getId).collect(Collectors.toList());

        // Fetch ratings for all RBMs for current month
        List<SalesRating> feedbackList = salesRatingRepository.selectBySalesL1IdsAndDateRange(salesL1Ids, startOfMonth, endOfMonth);

        if (feedbackList.isEmpty()) {
            LOGGER.info("No feedback entries found for Sales.");
            return;
        }

        // Sort feedback by createTimeStamp DESC
        feedbackList.sort((a, b) -> b.getCreateTimeStamp().compareTo(a.getCreateTimeStamp()));

        // Fetch and map FOFO (partner) names
        Map<Integer, String> fofoNameMap = new HashMap<>();
        for (SalesRating rating : feedbackList) {
            int fofoId = rating.getFofoId();
            if (!fofoNameMap.containsKey(fofoId)) {
                User fofoUser = userRepository.selectById(fofoId);
                FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);

                String partnerName = fofoUser != null ? fofoUser.getName() : "Unknown Partner";
                String storeCode = fofoStore != null ? fofoStore.getCode() : "Unknown Code";

                String displayName = partnerName + " (" + storeCode + ")";
                fofoNameMap.put(fofoId, displayName);
            }
        }

        // Map RBM ID to name for quick lookup
        Map<Integer, String> salesL1NameMap = authUsers.stream()
                .collect(Collectors.toMap(AuthUser::getId, AuthUser::getFullName));

        // Generate HTML content
        StringBuilder emailContent = new StringBuilder();
        emailContent.append("<html><body>");
        emailContent.append("<p>Dear Team,</p>");
        emailContent.append("<p>Here is the <b>latest Sales L1 Rating and Feedback Summary</b> for ")
                .append(LocalDate.now().getMonth()).append(":</p>");

        emailContent.append("<table border='1' cellspacing='0' cellpadding='5'>");
        emailContent.append("<tr>")
                .append("<th>Sales L1 Name</th>")
                .append("<th>Partner Name</th>")
                .append("<th>Partner Category</th>")
                .append("<th>Rating</th>")
                .append("<th>Comment</th>")
                .append("<th>Date</th>")
                .append("</tr>");

        for (SalesRating rating : feedbackList) {
            String salesL1 = salesL1NameMap.getOrDefault(rating.getSalesL1Id(), "Unknown Sales Person");
            String partnerName = fofoNameMap.getOrDefault(rating.getFofoId(), "Unknown Partner");
            PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(rating.getFofoId(), LocalDate.now());
            emailContent.append("<tr>")
                    .append("<td>").append(salesL1).append("</td>")
                    .append("<td>").append(partnerName).append("</td>")
                    .append("<td>").append(partnerType).append("</td>")
                    .append("<td>").append(rating.getRating()).append("</td>")
                    .append("<td>").append(rating.getComment() != null ? rating.getComment() : "-").append("</td>")
                    .append("<td>").append(rating.getCreateTimeStamp().toLocalDate()).append("</td>")
                    .append("</tr>");
        }

        emailContent.append("</table>");
        emailContent.append("<br><p>Regards,<br>Smartdukaan Team</p>");
        emailContent.append("</body></html>");

        String subject = "Monthly Sales L1 Feedback Summary Test test - " + LocalDate.now().getMonth();

        List<String> sendTo = new ArrayList<>();
         sendTo.add("sm@smartdukaan.com"); //
         sendTo.add("chiranjib.sarkar@smartdukaan.com"); //
         sendTo.add("kamini.sharma@smartdukaan.com"); //

        String[] emailRecipients = sendTo.toArray(new String[0]);


        this.sendMailHtmlFormat(emailRecipients, emailContent.toString(), null, bcc, subject);

        LOGGER.info("Consolidated Sales L1 feedback summary email sent.");
    }


    public void generateBiReportExcel() throws Exception {
        LocalDateTime startOfToday = LocalDate.now().atStartOfDay();

        Map<Integer, CustomRetailer> customRetailers = retailerService.getAllFofoRetailers();

        List<Integer> retailerIds = customRetailers.values().stream().map(CustomRetailer::getPartnerId).collect(Collectors.toList());

//        this month return data
        LocalDateTime currentMonthStartDate = YearMonth.now().atDay(1).atStartOfDay();
        LocalDateTime currentMonthEndDate = LocalDateTime.now();

        List<ReturnOrderInfoModel> currentMonthReturnOrderInfoModels = returnOrderInfoRepository.selectAllByBetweenDate(currentMonthStartDate, currentMonthEndDate);
        Map<Integer, Long> currentMonthPartnerReturnOrderInfoModelMap = currentMonthReturnOrderInfoModels.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingLong(x -> Math.round(x.getRefundAmount()))));

        List<Order> currentMonthRtoRefundOrders = orderRepository.selectAllOrderDatesBetweenByStatus(currentMonthStartDate, currentMonthEndDate, OrderStatus.RTO_REFUNDED);
        Map<Integer, Long> currentMonthRtoRefundOrderMap = currentMonthRtoRefundOrders.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingLong(x -> Math.round(x.getTotalAmount()))));


//        last month return data
        YearMonth lastMonth = YearMonth.now().minusMonths(1);
        LocalDateTime lastMontStartDate = lastMonth.atDay(1).atStartOfDay();
        LocalDateTime lastMonthEndDate = lastMonth.atEndOfMonth().atTime(23, 59, 59);

        List<ReturnOrderInfoModel> lastMonthReturnOrderInfoModels = returnOrderInfoRepository.selectAllByBetweenDate(lastMontStartDate, lastMonthEndDate);
        Map<Integer, Long> lastMonthPartnerReturnOrderInfoModelMap = lastMonthReturnOrderInfoModels.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingLong(x -> Math.round(x.getRefundAmount()))));

        List<Order> lastMonthRtoRefundOrders = orderRepository.selectAllOrderDatesBetweenByStatus(lastMontStartDate, lastMonthEndDate, OrderStatus.RTO_REFUNDED);
        Map<Integer, Long> lastMonthRtoRefundOrderMap = lastMonthRtoRefundOrders.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingLong(x -> Math.round(x.getTotalAmount()))));


//        twoMonthsAgo return data
        YearMonth twoMonthsAgo = YearMonth.now().minusMonths(2);
        LocalDateTime twoMonthsAgoStartDate = twoMonthsAgo.atDay(1).atStartOfDay();
        LocalDateTime twoMonthsAgoEndDate = twoMonthsAgo.atEndOfMonth().atTime(23, 59, 59);

        List<ReturnOrderInfoModel> twoMonthAgoReturnOrderInfoModels = returnOrderInfoRepository.selectAllByBetweenDate(twoMonthsAgoStartDate, twoMonthsAgoEndDate);
        Map<Integer, Long> twoMonthAgoPartnerReturnOrderInfoModelMap = twoMonthAgoReturnOrderInfoModels.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingLong(x -> Math.round(x.getRefundAmount()))));

        List<Order> twoMonthRtoRefundOrders = orderRepository.selectAllOrderDatesBetweenByStatus(twoMonthsAgoStartDate, twoMonthsAgoEndDate, OrderStatus.RTO_REFUNDED);
        Map<Integer, Long> twoMonthRtoRefundOrderMap = twoMonthRtoRefundOrders.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingLong(x -> Math.round(x.getTotalAmount()))));


        List<BIRetailerModel> biRetailerModels = new ArrayList<>();

        List<BiSecondaryModel> biSecondaryModels = new ArrayList<>();

        for(Integer fofoId: retailerIds){

            int rbmL1 = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_RBM,EscalationType.L1,fofoId);
            String rbmName = authRepository.selectById(rbmL1).getFullName();

            int bmId = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_SALES,EscalationType.L2,fofoId);
            String bmName = authRepository.selectById(bmId).getFullName();

            int managerId = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_SALES,EscalationType.L1,fofoId);
            String managerName = " ";
            if(managerId != 0){
                 managerName = authRepository.selectById(managerId).getFullName();
            }else {
                managerName = bmName;
            }

            AST ast = astRepository.selectById(customRetailers.get(fofoId).getAstId());

            PartnerType partnerTypeThisMonth = partnerTypeChangeService.getTypeOnMonth(fofoId, YearMonth.now());

//            generate retaile detail

            BIRetailerModel biRetailerModel = new BIRetailerModel();
            biRetailerModel.setBmName(bmName);
            biRetailerModel.setCode(customRetailers.get(fofoId).getCode());
            biRetailerModel.setArea(ast.getArea());
            biRetailerModel.setCity(customRetailers.get(fofoId).getAddress().getCity());
            biRetailerModel.setStoreName(customRetailers.get(fofoId).getBusinessName());
            biRetailerModel.setStoreName(String.valueOf(customRetailers.get(fofoId).getActivationType()));
            biRetailerModel.setCategory(String.valueOf(partnerTypeThisMonth));
            biRetailerModel.setSalesManager(managerName);
            biRetailerModel.setRbm(rbmName);
            biRetailerModels.add(biRetailerModel);

//            generate secondary data

//            this month secondary target

            MonthlyTarget secondaryTarget = monthlyTargetRepository.selectByDateAndFofoId(YearMonth.now(), fofoId);

            Map<Integer, Double> secondaryMtd = orderRepository.selectOrderValueBetweenDatesGroupByFofoId(Arrays.asList(fofoId),
                    Arrays.asList(OrderStatus.BILLED, OrderStatus.SHIPPED_FROM_WH, OrderStatus.SHIPPED_TO_LOGST, OrderStatus.DELIVERY_SUCCESS, OrderStatus.ACCEPTED, OrderStatus.SUBMITTED_FOR_PROCESSING),
                    startOfToday.withDayOfMonth(1), startOfToday.with(LocalTime.MAX)).stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getAmount()));

            double secondaryAchievedMtd = secondaryMtd.getOrDefault(fofoId, 0.0);


//            last month secondary target

            MonthlyTarget lastMonthSecondaryTarget = monthlyTargetRepository.selectByDateAndFofoId(lastMonth, fofoId);

            Map<Integer, Double> lastMonthSecondary = orderRepository.selectOrderValueBetweenDatesGroupByFofoId(Arrays.asList(fofoId),
                    Arrays.asList(OrderStatus.BILLED, OrderStatus.SHIPPED_FROM_WH, OrderStatus.SHIPPED_TO_LOGST, OrderStatus.DELIVERY_SUCCESS, OrderStatus.ACCEPTED, OrderStatus.SUBMITTED_FOR_PROCESSING),
                    lastMontStartDate, lastMonthEndDate).stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getAmount()));

            double lastMonthSecondaryAchieved = lastMonthSecondary.getOrDefault(fofoId, 0.0);


//            last month secondary target

            MonthlyTarget twoMonthAgoSecondaryTarget = monthlyTargetRepository.selectByDateAndFofoId(lastMonth, fofoId);

            Map<Integer, Double> twoMonthAgoSecondary = orderRepository.selectOrderValueBetweenDatesGroupByFofoId(Arrays.asList(fofoId),
                    Arrays.asList(OrderStatus.BILLED, OrderStatus.SHIPPED_FROM_WH, OrderStatus.SHIPPED_TO_LOGST, OrderStatus.DELIVERY_SUCCESS, OrderStatus.ACCEPTED, OrderStatus.SUBMITTED_FOR_PROCESSING),
                    twoMonthsAgoStartDate, twoMonthsAgoEndDate).stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getAmount()));

            double twoMonthAgoSecondaryAchieved = twoMonthAgoSecondary.getOrDefault(fofoId, 0.0);

//
////            this month tertiary
//            Double todaySale = fofoOrderItemRepository.selectSumMopGroupByRetailer(startOfToday, now, fofoId, false).get(fofoId);
//            Double mtdSaleTillYesterDay = fofoOrderItemRepository.selectSumMopGroupByRetailer(startOfToday.withDayOfMonth(1), startOfToday, fofoId, false).get(fofoId);
//            Double mtdSale = mtdSaleTillYesterDay + todaySale;
//            Double lmtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
//                    startOfToday.withDayOfMonth(1).minusMonths(1), now.minusMonths(1), fofoId, false).get(fofoId);
//
//
//            BiSecondaryModel biSecondaryModel = new BiSecondaryModel();

        }

        LOGGER.info("biRetailerModels {}",biRetailerModels);




    }




}