Subversion Repositories SmartDukaan

import com.spice.profitmandi.common.util.Utils;

import com.spice.profitmandi.dao.entity.user.StoreTimelinetb;

import com.spice.profitmandi.dao.enumuration.cs.EscalationType;

import com.spice.profitmandi.dao.enumuration.dtr.StoreTimeline;

import org.springframework.mail.javamail.JavaMailSender;

    @Autowired

    JavaMailSender mailSender;

    @Autowired

    com.spice.profitmandi.service.user.StoreTimelineTatService storeTimelineTatService;

    @Autowired

    com.spice.profitmandi.dao.repository.dtr.PartnerOnBoardingPanelRepository partnerOnBoardingPanelRepository;

    @Autowired

    com.spice.profitmandi.dao.repository.user.StoreTimelinetbRepository storeTimelinetbRepository;

                // Check if this is the first PO for this partner (before creating the new transaction)

                List<Transaction> existingTransactions = transactionRepository.selectByRetailerId(fofoId);

                boolean isFirstPO = (existingTransactions == null || existingTransactions.isEmpty());

                // Block first PO if FULL_STOCK_PAYMENT is not done (for LOI-flow partners only)

                if (isFirstPO && fofoStore != null && !fofoStore.isInternal() && fofoStore.getCode() != null) {

                    com.spice.profitmandi.dao.entity.fofo.PartnerOnBoardingPanel pob =

                            partnerOnBoardingPanelRepository.selectByCode(fofoStore.getCode());

                    if (pob != null) {

                        StoreTimelinetb fspEntry = storeTimelinetbRepository.selectByOnboardingIdAndEvent(

                                pob.getId(), StoreTimeline.FULL_STOCK_PAYMENT);

                        if (fspEntry == null) {

                            LOGGER.warn("PO creation blocked for fofoId={}, onboardingId={}: FULL_STOCK_PAYMENT not done", fofoId, pob.getId());

                            throw new ProfitMandiBusinessException(

                                    "Full Stock Payment is required before creating PO",

                                    fofoStore.getCode(),

                                    "Full Stock Payment must be completed before first PO can be created");

                        }

                    }

                }

                // Send approval email to Sales L3 only for first PO

                if (isFirstPO) {

                    try {

                        sendFirstPOApprovalEmail(fofoStore, transactionId, totalPayableAmount, creatorId);

                    } catch (Exception e) {

                        LOGGER.error("Failed to send first PO approval email for fofoId: " + fofoId, e);

                    }

                    // Track PO_CREATION on timeline for first PO

                    try {

                        if (fofoStore != null && fofoStore.getCode() != null) {

                            com.spice.profitmandi.dao.entity.fofo.PartnerOnBoardingPanel pob =

                                    partnerOnBoardingPanelRepository.selectByCode(fofoStore.getCode());

                            if (pob != null) {

                                storeTimelineTatService.onPoCreationComplete(pob.getId());

                                // If no approval required, PO is auto-approved

                                if (!approvalRequired) {

                                    storeTimelineTatService.onPoApprovalComplete(pob.getId());

                                }

                            }

                        }

                    } catch (Exception e) {

                        LOGGER.error("Failed to track PO_CREATION timeline for fofoId: " + fofoId, e);

                    }

                }

    private void sendFirstPOApprovalEmail(FofoStore fofoStore, int transactionId, double totalAmount, int creatorId) throws Exception {

        String partnerName = "Partner";

        if (fofoStore.getUserAddress() != null && fofoStore.getUserAddress().getName() != null) {

            partnerName = fofoStore.getUserAddress().getName();

        }

        String storeCode = fofoStore.getCode() != null ? fofoStore.getCode() : "";

        String createdByName = "";

        if (creatorId > 0) {

            AuthUser creator = authRepository.selectById(creatorId);

            if (creator != null) {

                createdByName = creator.getFullName();

            }

        }

        String subject = "First PO Created - Approval Required - " + partnerName + " (" + storeCode + ")";

        StringBuilder sb = new StringBuilder();

        sb.append("<html><body>");

        sb.append("<p>Dear Team,</p>");

        sb.append("<p>The <strong>first Purchase Order</strong> has been created for the below partner. Please review and approve.</p><br/>");

        sb.append("<table style='border:1px solid black; border-collapse: collapse;'>");

        sb.append("<tbody>");

        sb.append("<tr>");

        sb.append("<th style='border:1px solid black; padding: 5px;'>Partner Name</th>");

        sb.append("<th style='border:1px solid black; padding: 5px;'>Store Code</th>");

        sb.append("<th style='border:1px solid black; padding: 5px;'>Transaction ID</th>");

        sb.append("<th style='border:1px solid black; padding: 5px;'>Total Amount</th>");

        sb.append("<th style='border:1px solid black; padding: 5px;'>Created By</th>");

        sb.append("</tr>");

        sb.append("<tr>");

        sb.append("<td style='border:1px solid black; padding: 5px;'>").append(partnerName).append("</td>");

        sb.append("<td style='border:1px solid black; padding: 5px;'>").append(storeCode).append("</td>");

        sb.append("<td style='border:1px solid black; padding: 5px;'>").append(transactionId).append("</td>");

        sb.append("<td style='border:1px solid black; padding: 5px;'>").append(String.format("%.2f", totalAmount)).append("</td>");

        sb.append("<td style='border:1px solid black; padding: 5px;'>").append(createdByName).append("</td>");

        sb.append("</tr>");

        sb.append("</tbody></table>");

        sb.append("<br/><p>Please approve this order from the <strong>Transaction Approvals</strong> panel.</p>");

        sb.append("<br/><p>Regards,<br/>Smart Dukaan</p>");

        sb.append("</body></html>");

        // Send to Sales L3

        List<AuthUser> salesL3Users = csService.getAuthUserByCategoryId(

                ProfitMandiConstants.TICKET_CATEGORY_SALES, EscalationType.L3);

        List<String> sendTo = new ArrayList<>();

        if (!salesL3Users.isEmpty()) {

            sendTo.addAll(salesL3Users.stream().map(AuthUser::getEmailId).collect(Collectors.toList()));

        }

        if (!sendTo.isEmpty()) {

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

            Utils.sendMailWithAttachments(mailSender, emailArray, null, subject, sb.toString());

            LOGGER.info("First PO approval email sent for fofoId: {} transactionId: {}", fofoStore.getId(), transactionId);

        }

    }