Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import com.fasterxml.jackson.databind.ObjectMapper;

import com.google.common.hash.Hashing;

import com.spice.profitmandi.common.enumuration.BusinessType;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.model.ProfitMandiConstants;

import com.spice.profitmandi.common.web.util.ResponseSender;

import com.spice.profitmandi.dao.entity.auth.AuthUser;

import com.spice.profitmandi.dao.entity.brandFee.BrandFee;

import com.spice.profitmandi.dao.entity.brandFee.BrandFeeCollection;

import com.spice.profitmandi.dao.entity.dtr.Otp;

import com.spice.profitmandi.dao.entity.fofo.FofoStore;

import com.spice.profitmandi.dao.entity.fofo.PartnerOnBoardingPanel;

import com.spice.profitmandi.dao.entity.fofo.PartnerOnboardingTrainingPanel;

import com.spice.profitmandi.dao.entity.fofo.PaymentOption;

import com.spice.profitmandi.dao.entity.onBoarding.*;

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

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

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

import com.spice.profitmandi.dao.enumuration.fofo.StoreStatus;

import com.spice.profitmandi.dao.enumuration.onBorading.OnboardingType;

import com.spice.profitmandi.dao.enumuration.onBorading.onBoardingFormEnums.FeePaymentStatus;

import com.spice.profitmandi.dao.enumuration.onBorading.onBoardingFormEnums.LoiStatus;

import com.spice.profitmandi.dao.enumuration.onBorading.onBoardingFormEnums.StoreType;

import com.spice.profitmandi.dao.enumuration.transaction.PartnerOnBoardingStatus;

import com.spice.profitmandi.dao.enumuration.transaction.PartnerOnboardingDesignTatStatus;

import com.spice.profitmandi.dao.model.LoiFormModel;

import com.spice.profitmandi.dao.repository.auth.AuthRepository;

import com.spice.profitmandi.dao.repository.brandFee.BrandFeeCollectionRepository;

import com.spice.profitmandi.dao.repository.brandFee.BrandFeeRepository;

import com.spice.profitmandi.dao.repository.catalog.BrandCategoryRepository;

import com.spice.profitmandi.dao.repository.catalog.BrandsRepository;

import com.spice.profitmandi.dao.repository.cs.CsService;

import com.spice.profitmandi.dao.repository.dtr.*;

import com.spice.profitmandi.dao.repository.fofo.PaymentOptionRepository;

import com.spice.profitmandi.dao.repository.inventory.PartnerOnboardingService;

import com.spice.profitmandi.dao.repository.inventory.StateRepository;

import com.spice.profitmandi.dao.repository.onboarding.*;

import com.spice.profitmandi.dao.repository.transaction.OrderRepository;

import com.spice.profitmandi.dao.repository.user.*;

import com.spice.profitmandi.dao.service.LoiDocModel;

import com.spice.profitmandi.dao.service.OTPResponse;

import com.spice.profitmandi.dao.service.OtpProcessor;

import com.spice.profitmandi.dao.service.loiForm.LoiFormService;

import com.spice.profitmandi.service.AuthService;

import com.spice.profitmandi.service.integrations.gstpro.GstProService;

import com.spice.profitmandi.service.integrations.gstpro.entity.GstDetails;

import com.spice.profitmandi.service.user.StoreStatusService;

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

import com.spice.profitmandi.web.model.LoginDetails;

import com.spice.profitmandi.web.util.CookiesProcessor;

import com.spice.profitmandi.web.util.MVCResponseSender;

import org.apache.commons.lang3.tuple.Pair;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.http.ResponseEntity;

import org.springframework.mail.javamail.JavaMailSender;

import org.springframework.stereotype.Controller;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.ui.Model;

import org.springframework.web.bind.annotation.RequestBody;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RequestParam;

import javax.servlet.http.HttpServletRequest;

import java.nio.charset.StandardCharsets;

import java.time.LocalDate;

import java.time.LocalDateTime;

import java.util.*;

import java.util.stream.Collectors;

@Controller

@Transactional(rollbackFor = Throwable.class)

public class LoiFormController {

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

    @Autowired

    DocumentRepository documentRepository;

    @Autowired

    private StoreStatusService storeStatusService;

    @Autowired

    AuthRepository authRepository;

    @Autowired

    StateRepository stateRepository;

    @Autowired

    DistrictMasterRepository districtMasterRepository;

    @Autowired

    LoiFormRepository loiFormRepository;

    @Autowired

    GstProService gstProService;

    @Autowired

    ObjectMapper objectMapper;

    @Autowired

    OrderRepository orderRepository;

    @Autowired

    LoiFormService loiFormService;

    @Autowired

    BrandFeeCollectionRepository brandFeeCollectionRepository;

    @Autowired

    BrandFeeRepository brandFeeRepository;

    @Autowired

    OtpProcessor otpProcessor;

    @Autowired

    OtpRepository otpRepository;

    @Autowired

    JavaMailSender gmailRelaySender;

    @Autowired

    LoiDocMasterRepository loiDocMasterList;

    @Autowired

    CsService csService;

    @Autowired

    PartnerOnboardingService partnerOnboardingService;

    @Autowired

    StoreTimelineTatService storeTimelineTatService;

    @Autowired

    LoiDocRepository loiDocRepository;

    @Autowired

    MVCResponseSender mvcResponseSender;

    @Autowired

    private CookiesProcessor cookiesProcessor;

    @Autowired

    BrandCommitRepository brandCommitRepository;

    @Autowired

    BrandsRepository brandsRepository;

    @Autowired

    BrandCategoryRepository brandCategoryRepository;

    @Autowired

    BillingAddressRepository billingAddressRepository;

    @Autowired

    LoiBrandCommitmentRepository brandCommitmentRepository;

    @Autowired

    PartnerOnBoardingPanelRepository partnerOnBoardingPanelRepository;

    @Autowired

    LoiAuditTrailRepository loiAuditTrailRepository;

    @Autowired

    PaymentOptionRepository paymentOptionRepository;

    @Autowired

    FofoStoreRepository fofoStoreRepository;

    @Autowired

    StoreTimelinetbRepository storeTimelinetbRepository;

    @Autowired

    AgreementEsignRepository agreementEsignRepository;

    @Autowired

    RbmAssignmentRepository rbmAssignmentRepository;

    @Autowired

    AuthService authService;

    @Autowired

    PartnerDashboardTrainingRepository partnerDashboardTrainingRepository;

    @Autowired

    ResponseSender responseSender;

    List<String> agreedBrandFeeChangerEmail = Arrays.asList("kamini.sharma@smartdukaan.com");

    // Loi Form

    @RequestMapping(value = "/loiForm", method = RequestMethod.GET)

    public String loiForm(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {

        List<AuthUser> authUsersList = loiFormService.getReferalAuthList();

        List<BrandFee> brandFee = brandFeeRepository.selectFeeOnDate(LocalDateTime.now());

        Set<Pair<StoreType, BrandFee>> storeTypeFeePairs = new HashSet<>();

        for (BrandFee fee : brandFee) {

            for (StoreType storeType : StoreType.values()) {

                storeTypeFeePairs.add(Pair.of(storeType, fee));

            }

        }

        // BM (labelled "State Head" on the LOI form) is now the L4/L5 sales head — was

        // L2/L3 previously, which no longer matches the org hierarchy.

        List<AuthUser> stateHeadList = csService.getAuthUserIds(ProfitMandiConstants.TICKET_CATEGORY_SALES, Arrays.asList(EscalationType.L4, EscalationType.L5));

        List<AuthUser> bdmList = csService.getAuthUserIds(ProfitMandiConstants.TICKET_CATEGORY_SALES, Arrays.asList(EscalationType.L1, EscalationType.L2));

        List<AuthUser> abmHeadList = csService.getAuthUserIds(ProfitMandiConstants.TICKET_CATEGORY_ABM, Arrays.asList(EscalationType.L4, EscalationType.L5));

        List<AuthUser> abmList = csService.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_ABM, EscalationType.L1);

        bdmList.addAll(abmList);

        stateHeadList.addAll(abmHeadList);

        List<BrandCommit> brandCommits = brandCommitRepository.selectAllActiveBrand();

        List<PaymentOption> paperFinanceOptions = paymentOptionRepository.selectAllPaperFinanceOption();

        model.addAttribute("businessTypes", BusinessType.values());

        model.addAttribute("brandCommits", brandCommits);

        model.addAttribute("storeTypeFeePairs", storeTypeFeePairs);

        model.addAttribute("authUsersList", authUsersList);

        model.addAttribute("stateHeadList", stateHeadList);

        model.addAttribute("bdmList", bdmList);

        model.addAttribute("paperFinanceOptions", paperFinanceOptions);

        return "loi-form";

    }

    // use to validate GSTIN

    @RequestMapping(value = "/gstValidate", method = RequestMethod.GET)

    public ResponseEntity<?> gstValidate(HttpServletRequest request, @RequestParam String gstNo) throws Exception {

        LOGGER.info("gstNo -" + gstNo);

        GstDetails gstDetails = gstProService.getGstDetails(gstNo);

        LOGGER.info("gstDetails -" + gstDetails);

        if (gstDetails != null) {

            List<GstDetails.Pradr> adadr = gstDetails.getAdadr();

            adadr.add(gstDetails.getPradr());

            Collections.reverse(adadr);

            LOGGER.info("list_of_adadr-" + adadr);

        }

        return ResponseEntity.ok(gstDetails);

    }

    // Save Loi data in fofo.loi_form table

    @RequestMapping(value = "/submitLoiForm", method = RequestMethod.POST)

    public String submitLoiForm(HttpServletRequest request, @RequestBody LoiFormData loiFormData, Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        LOGGER.info("filledBy - " + loginDetails.getEmailId());

        String validationError = validateOnboardingTypeFields(loiFormData);

        if (validationError != null) {

            LOGGER.warn("LOI submit rejected for " + loginDetails.getEmailId() + ": " + validationError);

            model.addAttribute("response1", mvcResponseSender.createResponseString(false));

            return "response";

        }

        boolean isDataCreated = loiFormService.createLoiForm(loiFormData, loginDetails.getEmailId());

        if (isDataCreated) {

            model.addAttribute("response1", mvcResponseSender.createResponseString(true));

            return "response";

        } else {

            model.addAttribute("response1", mvcResponseSender.createResponseString(false));

            return "response";

        }

    }

    // Returns null if valid, else an error message. NEW is default; only REVIVAL / ANY_OTHER need extras.

    private String validateOnboardingTypeFields(LoiFormData loiFormData) throws ProfitMandiBusinessException {

        String rawType = loiFormData.getOnboardingType();

        if (rawType == null || rawType.trim().isEmpty()) {

            loiFormData.setOnboardingType(OnboardingType.NEW.name());

            return null;

        }

        OnboardingType type;

        try {

            type = OnboardingType.valueOf(rawType.trim().toUpperCase());

        } catch (IllegalArgumentException e) {

            return "Invalid onboarding type: " + rawType;

        }

        if (type == OnboardingType.NEW) return null;

        String reason = loiFormData.getRevivalReason();

        if (reason == null || reason.trim().isEmpty()) {

            return "Reason is mandatory for " + type + " onboarding";

        }

        if (type == OnboardingType.REVIVAL) {

            String oldCode = loiFormData.getOldStoreCode();

            if (oldCode == null || oldCode.trim().isEmpty()) {

                return "Old Store Code is mandatory for REVIVAL";

            }

            FofoStore existing = fofoStoreRepository.selectByStoreCode(oldCode.trim());

            if (existing == null) {

                return "Old Store Code " + oldCode + " does not exist";

            }

            try {

                storeStatusService.assertRevivable(existing);

            } catch (ProfitMandiBusinessException e) {

                return e.getCode();

            }

        }

        return null;

    }

    // show all pending loi form to specific auth user who have filled the form(type based)

    @RequestMapping(value = "/pendingLoiForm", method = RequestMethod.GET)

    public String pendingLoiForm(HttpServletRequest request, Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        String email = loginDetails.getEmailId();

        boolean isDocApprover = false;

        String approverEmail = "gaurav.sharma@smartdukaan.com";

        if (email.equals(approverEmail)) {

            isDocApprover = true;

        }

        boolean isAgreedBrandFeeChanger = agreedBrandFeeChangerEmail.stream().anyMatch(x -> x.equals(email));

        List<String> authEmails = Arrays.asList("raj.singh@smartdukaan.com", "kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com");

        boolean isAuthUser = authEmails.stream().anyMatch(x -> x.equals(email));

        boolean isAccountsUser = csService.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS)

                .stream().anyMatch(x -> email.equals(x.getEmailId()));

        List<LoiFormModel> pendingFormList = loiFormService.pendingFormList(email);

        model.addAttribute("isDocApprover", isDocApprover);

        model.addAttribute("isAuthUser", isAuthUser);

        model.addAttribute("isAccountsUser", isAccountsUser);

        model.addAttribute("isAgreedBrandFeeChanger", isAgreedBrandFeeChanger);

        model.addAttribute("pendingFormList", pendingFormList);

        model.addAttribute("brandType", StoreType.valueList);

        return "pendingForm";

    }

//    @RequestMapping(value = "/pendingLoiFormList", method = RequestMethod.GET)

//    public String pendingLoiForm1(HttpServletRequest request, @RequestParam int pageSize, @RequestParam int pageNumber, Model model) throws Exception {

//        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

//        String email = loginDetails.getEmailId();

//        Map<String, Object> pendingFormMap = loiFormService.pendingFormList(email);

//        model.addAttribute("pendingFormList", pendingFormMap.get("pendingFormModelList"));

//        model.addAttribute("paginationInfo", this.getPaginationInfo(pageNumber,pageSize,(long)pendingFormMap.get("totalCount")));

//        return "loiData";

//    }

//    public String getPaginationInfo(int currentPage, int pageSize, long totalEntries) {

//        // Calculate the starting index

//        int start = (currentPage - 1) * pageSize + 1; // Start from 1

//        // Calculate the ending index

//        int end = Math.min(start + pageSize - 1, (int) totalEntries); // Ensure it doesn't exceed totalEntries

//

//        return "Showing " + start + " to " + end + " of " + totalEntries + " entries";

//    }

    // generate LOI for specific Form data

    @RequestMapping(value = "/generateLoi", method = RequestMethod.GET)

    public String generateLoi(HttpServletRequest request, @RequestParam int loiId, Model model) throws ProfitMandiBusinessException {

        LoiForm loiForm = loiFormRepository.selectById(loiId);

        String filledBy = authRepository.selectByEmailOrMobile(loiForm.getFilledBy()).getFullName();

        loiForm.setLoiGeneratedOn(LocalDateTime.now());

        BrandFee brandFee = brandFeeRepository.selectById(1L);

        BillingAddress address = billingAddressRepository.selectByLoiFormId(loiId);

        List<LoiBrandCommitment> loiBrandCommitments = brandCommitmentRepository.selectByLoiId(loiId).stream().filter(x -> x.getAmount() > 0).collect(Collectors.toList());

        double totalCommitment = loiBrandCommitments.stream().mapToDouble(x -> x.getAmount()).sum();

        List<BrandFeeCollection> brandFeeCollections = brandFeeCollectionRepository.selectAllConfirmPaymetByLoiId(loiId);

        double brandFeeAmount = brandFeeCollections.stream().mapToDouble(x -> x.getCollectedAmount()).sum();

        BrandFeeCollection brandFeeCollection = brandFeeCollections.get(0);

        model.addAttribute("totalCommitment", totalCommitment);

        model.addAttribute("loiBrandCommitments", loiBrandCommitments);

        model.addAttribute("brandFeeAmount", brandFeeAmount);

        model.addAttribute("brandFee", brandFee);

        model.addAttribute("brandFeeCollection", brandFeeCollection);

        model.addAttribute("address", address);

        model.addAttribute("loiForm", loiForm);

        model.addAttribute("filledBy", filledBy);

        return "auto-Loi";

    }

    private String getHash256(String originalString) {

        String hashString = Hashing.sha256().hashString(originalString, StandardCharsets.UTF_8).toString();

        LOGGER.info("Hash String {}", hashString);

        return hashString;

    }

    // send Filled form for update purpose

    @RequestMapping(value = "/updateLoiForm", method = RequestMethod.GET)

    public String UpdateLoiForm(HttpServletRequest request,

                                @RequestParam int loiId,

                                Model model) throws ProfitMandiBusinessException {

        LoiForm loiForm = loiFormRepository.selectById(loiId);

        model.addAttribute("updateForm", true);

        model.addAttribute("loiForm", loiForm);

        return "loiForm/update-loiForm";

    }

    @RequestMapping(value = "/updateLoiFormData", method = RequestMethod.POST)

    public String UpdateLoiFormDetail(HttpServletRequest request,

                                      @RequestParam int loiId,

                                      @RequestBody LoiFormData loiFormData,

                                      Model model) throws Exception {

        loiFormService.updateLoiForm(loiFormData, loiId);

        model.addAttribute("response1", mvcResponseSender.createResponseString(true));

        return "response";

    }

    @RequestMapping(value = "/brandfeeCollection", method = RequestMethod.POST)

    public String addBrandFee(HttpServletRequest request, @RequestBody BrandFeeCollection brandFeeCollection, @RequestParam int loiId, Model model) throws Exception {

        LoiForm loiForm = loiFormRepository.selectById(loiId);

        double totatcollectedfee = brandFeeCollectionRepository.selectAllConfirmPaymetByLoiId(loiId).stream().mapToDouble(x -> x.getCollectedAmount()).sum();

        double brandFee = loiForm.getAgreedBrandFees();

        double differanceAmount = brandFee - totatcollectedfee;

        if (totatcollectedfee + brandFeeCollection.getCollectedAmount() <= brandFee) {

            brandFeeCollection.setPaymentStatus(FeePaymentStatus.PENDING);

            brandFeeCollection.setLoiFormId(loiId);

            brandFeeCollectionRepository.persist(brandFeeCollection);

            loiFormService.sentMailToPaymentApprover(brandFeeCollection, loiForm);

            model.addAttribute("response1", mvcResponseSender.createResponseString(true));

            return "response";

        } else {

            throw new ProfitMandiBusinessException("You need to add only due brand fee that is Only, " + differanceAmount + " INR", null, "Pay differance amount or less then differance amount");

        }

    }

    @RequestMapping(value = "/paymentsDetail", method = RequestMethod.GET)

    public String paymentsDetails(HttpServletRequest request, @RequestParam int loiId, Model model) throws ProfitMandiBusinessException {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        String email = loginDetails.getEmailId();

        boolean isNiraj = false;

        if (email.equals("neeraj.gupta@smartdukaan.com")) {

            isNiraj = true;

        }

        List<BrandFeeCollection> brandFeeCollections = brandFeeCollectionRepository.selectAllByLoiFormId(loiId);

        model.addAttribute("brandFeeCollections", brandFeeCollections);

        model.addAttribute("confirm", FeePaymentStatus.CONFIRM);

        model.addAttribute("isNiraj", isNiraj);

        return "payment-collection-details";

    }

    // bfcId - Brand Fee Collection Id

    @RequestMapping(value = "/feePaymentApproval", method = RequestMethod.PUT)

    public String feePaymentApproval(HttpServletRequest request, @RequestParam int bfcId, @RequestParam FeePaymentStatus feePaymentStatus, @RequestParam String description,

                                     Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        String authEmail = loginDetails.getEmailId();

        BrandFeeCollection brandFeeCollection = brandFeeCollectionRepository.selectById(bfcId);

        brandFeeCollection.setApproverEmail(authEmail);

        brandFeeCollection.setPaymentStatus(feePaymentStatus);

        brandFeeCollection.setDescription(description);

        brandFeeCollection.setApprovalTimeStamp(LocalDateTime.now());

        if (feePaymentStatus.equals(FeePaymentStatus.CONFIRM)) {

            // Payment Approval timeline entry

            storeTimelineTatService.createStoreTimeline(brandFeeCollection.getLoiFormId(), StoreTimeline.PAYMENT_APPROVAL);

            LoiForm approvedLoi = loiFormRepository.selectById(brandFeeCollection.getLoiFormId());

            applyRevivalPaymentHooks(approvedLoi, authEmail);

            loiFormService.checkLoiDetailsCompletion(approvedLoi);

        }

        loiFormService.sendPaymentStatusMailToLoiFormFilledBy(brandFeeCollection);

        model.addAttribute("response1", mvcResponseSender.createResponseString(true));

        return "response";

    }

    @RequestMapping(value = "/feePaymentDeletion", method = RequestMethod.PUT)

    public String feePaymentDeletion(HttpServletRequest request, @RequestParam int bfcId,

                                     Model model) throws Exception {

        brandFeeCollectionRepository.deleteById(bfcId);

        model.addAttribute("response1", mvcResponseSender.createResponseString(true));

        return "response";

    }

    @RequestMapping(value = "/uploadDocumentForm", method = RequestMethod.GET)

    public String uploadDocumentForm(HttpServletRequest request, @RequestParam int loiId, Model model) throws ProfitMandiBusinessException {

        List<LoiDocMaster> activeDocMasterList = loiDocMasterList.getAllActiveDoc();

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        String authEmail = authRepository.selectByEmailOrMobile(loginDetails.getEmailId()).getEmailId();

        String approverEmail = "gaurav.sharma@smartdukaan.com";

        boolean isApprover = false;

        if (authEmail.equals(approverEmail)) {

            isApprover = true;

        }

        Map<Integer, LoiDoc> masterDocIdLoiDocMap = loiDocRepository.selectByLoiFormId(loiId).stream().collect(Collectors.toMap(x -> x.getMasterDocId(), x -> x));

        model.addAttribute("isApprover", isApprover);

        model.addAttribute("loiId", loiId);

        model.addAttribute("activeDocMasterList", activeDocMasterList);

        model.addAttribute("masterDocIdLoiDocMap", masterDocIdLoiDocMap);

        return "loiForm/document-upload";

    }

    @RequestMapping(value = "/uploadOnboardingDocument", method = RequestMethod.POST)

    public String uploadDocument(HttpServletRequest request, @RequestParam int loiId, @RequestBody List<LoiDocModel> loiDocModels, Model model) throws Exception {

        LoiForm loiForm = loiFormRepository.selectById(loiId);

        loiFormService.setDocs(loiForm, loiDocModels);

        model.addAttribute("response1", mvcResponseSender.createResponseString("Document uploaded successfully"));

        return "response";

    }

    @RequestMapping(value = "/documentVerify", method = RequestMethod.PUT)

    public String docApproval(HttpServletRequest request, @RequestParam int loiId, @RequestParam int docMasterId, @RequestParam boolean flag, Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        AuthUser auth = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());

        LoiDoc loiDoc = loiDocRepository.selectByLoiIdAndMasterDocId(loiId, docMasterId);

        if (flag) {

            loiDoc.setOk(true);

            loiDoc.setVerifyBy(auth.getId());

            // Document Approval timeline entry

            storeTimelineTatService.createStoreTimeline(loiId, StoreTimeline.LOI_DOCUMENT_APPROVAL);

            model.addAttribute("response1", mvcResponseSender.createResponseString(loiDoc.getDocType() + " is Accepted "));

            return "response";

        } else {

            loiDoc.setOk(false);

            loiDoc.setVerifyBy(auth.getId());

            LoiForm loiForm = loiFormRepository.selectById(loiId);

            if (loiForm.isLoiApproved()) {

                loiForm.setLoiApproved(false);

            }

            loiFormService.sendDocRejectionMail(loiDoc);

            model.addAttribute("response1", mvcResponseSender.createResponseString(loiDoc.getDocType() + " is Rejected"));

            return "response";

        }

    }

    @RequestMapping(value = "/loiAcceptanceOtp", method = RequestMethod.POST)

    public String sentLoiAcceptanceOtp(@RequestParam int loiId, Model model) throws Exception {

        LoiForm loiForm = loiFormRepository.selectById(loiId);

        String mobile = String.valueOf(loiForm.getMobile());

        Map<String, Object> response = new HashMap<>();

        OTPResponse otpResponse;

        try {

            otpResponse = otpProcessor.generateOtp(mobile, OtpType.LOI_ACCEPTANCE);

        } catch (Exception e) {

            // The dispatch itself blew up (gateway error, duplicate loi_form on this mobile, ...). Never

            // report this as a send - the panel used to show "OTP Sent Successfully!" for exactly this case.

            LOGGER.error("LOI acceptance OTP dispatch failed for loiId " + loiId + ", mobile " + mobile, e);

            response.put("status", false);

            response.put("sent", false);

            response.put("message", "OTP could not be sent due to a system error. Please report to tech support.");

            model.addAttribute("response1", mvcResponseSender.createResponseString(response));

            return "response";

        }

        LOGGER.info("OTPResponse for loiId " + loiId + " - result=" + otpResponse.isResult()

                + ", sent=" + otpResponse.isSent() + ", message=" + otpResponse.getMessage());

        response.put("status", otpResponse.isResult());

        response.put("sent", otpResponse.isSent());

        if (otpResponse.isResult() && otpResponse.isSent()) {

            response.put("message", "OTP sent on registered mobile and EmailId - " + mobile + " and " + loiForm.getEmail());

        } else {

            // Accepted-but-not-dispatched (resend throttle) and outright rejections (daily cap) both land

            // here. Pass the processor's own reason through instead of a generic "Something went wrong..".

            response.put("message", otpResponse.getMessage());

        }

        model.addAttribute("response1", mvcResponseSender.createResponseString(response));

        return "response";

    }

    @RequestMapping(value = "/validateLoiOtp", method = RequestMethod.PUT)

    public ResponseEntity<?> validateLoiAcceptanceOtp(HttpServletRequest request, @RequestParam int loiId, @RequestParam String provideOtp, Model model) throws Exception {

        LoiForm loiForm = loiFormRepository.selectById(loiId);

        if (loiForm.getLoiSignOtp() != null && loiForm.getLoiDoc() > 0) {

            throw new ProfitMandiBusinessException("LOI already signed", loiId, "This LOI is already signed and saved. Refresh the Pending LOI list.");

        }

        String mobile = String.valueOf(loiForm.getMobile());

        List<Otp> otps = otpRepository.selectAllByMobileWithTime(mobile);

        if (otps.isEmpty()) {

            throw new ProfitMandiBusinessException("No OTP", mobile, "No OTP was sent to " + mobile + " in the last 24 hours. Click Send OTP first.");

        }

        OTPResponse otpResponse = otpProcessor.validateOtp(otps.get(0).getId(), mobile, provideOtp);

        Map<String, Object> response = new HashMap<>();

        if (otpResponse.isResult()) {

            loiForm.setLoiSignOtp(provideOtp);

            loiForm.setLoiSignedOn(LocalDateTime.now());

            List<LoiBrandCommitment> loiBrandCommitments = brandCommitmentRepository.selectByLoiId(loiId).stream().filter(x -> x.getAmount() > 0).collect(Collectors.toList());

            double totalCommitment = loiBrandCommitments.stream().mapToDouble(x -> x.getAmount()).sum();

            List<BrandFeeCollection> brandFeeCollections = brandFeeCollectionRepository.selectAllConfirmPaymetByLoiId(loiId);

            double brandFeeAmount = brandFeeCollections.stream().mapToDouble(x -> x.getCollectedAmount()).sum();

            BrandFeeCollection brandFeeCollection = brandFeeCollections.get(0);

            String prevHash = loiAuditTrailRepository.findDocumentHashByLoiId(loiId);

            String rawData = loiId + "|"

                    + loiForm.getCompanyName() + "|"

                    + loiForm.getBrandType() + "|"

                    + brandFeeAmount + "|"

                    + brandFeeCollection.getPaymentMode() + "|"

                    + totalCommitment;

            String hash = getHash256(rawData);

            LoiAuditTrail audit = new LoiAuditTrail();

            audit.setLoiId(loiId);

            audit.setCompanyName(loiForm.getCompanyName());

            audit.setReferBy(loiForm.getReferBy());

            audit.setReferId(loiForm.getReferId());

            audit.setFilledBy(loiForm.getFilledBy());

            audit.setFranchiseeName(loiForm.getFullName());

            audit.setBrandType(loiForm.getBrandType());

            audit.setBrandFeeAmount(brandFeeAmount);

            audit.setPaymentMode(brandFeeCollection.getPaymentMode());

            audit.setTotalCommitment(totalCommitment);

            audit.setLoiSignedOn(LocalDateTime.now());

            audit.setLoiGeneratedOn(loiForm.getLoiGeneratedOn());

            audit.setLoiOtp(provideOtp);

            if (prevHash != null) {

                audit.setPrevHash(prevHash);

            }

            audit.setIpAddress(request.getRemoteAddr());

            audit.setDocumentHash(hash);

            response.put("success", true);

            response.put("documentHash", audit.getDocumentHash());

            response.put("ipAddress", audit.getIpAddress());

            response.put("generatedAt", audit.getCreatedAt());

            response.put("loiId", loiId);

            loiAuditTrailRepository.persist(audit);

        } else {

            // "OTP expired" also covers an OTP that was already used - e.g. re-entering the code after

            // the signed PDF failed to save. Say so instead of calling it wrong.

            throw new ProfitMandiBusinessException("Wrong OTP", "", "OTP " + provideOtp + " not accepted (" + otpResponse.getMessage()

                    + "). An OTP works only once - if it was already entered, click Send OTP to get a new one.");

        }

        return responseSender.ok(response);

    }

    @RequestMapping(value = "/saveLoiDoc", method = RequestMethod.POST)

    public String saveLoiDoc(@RequestParam int loiId, @RequestParam int loiDocId, Model model) throws Exception {

        LOGGER.info("loi_docId-" + loiDocId);

        LoiForm loiForm = loiFormRepository.selectById(loiId);

        if (loiDocId > 0) {

            if (loiForm.getLoiSignOtp() == null) {

                throw new ProfitMandiBusinessException("LOI OTP not verified", loiId, "Partner OTP is not verified for this LOI. Click Send OTP and Confirm Sign again.");

            }

            if (loiForm.getLoiDoc() > 0) {

                // Retry of a save that already went through: don't mail the partner or complete the LOI twice.

                LOGGER.info("Signed LOI already saved for loiId {} (doc {}), ignoring doc {}", loiId, loiForm.getLoiDoc(), loiDocId);

                model.addAttribute("response1", mvcResponseSender.createResponseString(true));

                return "response";

            }

            loiForm.setLoiDoc(loiDocId);

            loiFormService.sendSignedLoiPdfToPartner(loiForm);

            loiFormService.checkLoiDetailsCompletion(loiForm);

            model.addAttribute("response1", mvcResponseSender.createResponseString(true));

        } else {

            loiForm.setLoiSignOtp(null);

            loiForm.setLoiGeneratedOn(null);

            loiForm.setLoiSignedOn(null);

            model.addAttribute("response1", mvcResponseSender.createResponseString(false));

        }

        return "response";

    }

    @RequestMapping(value = "/downloadLoiFromReport", method = RequestMethod.GET)

    public ResponseEntity<?> downloadAllLoiForm(@RequestParam LocalDate from, @RequestParam LocalDate to) throws Exception {

        ResponseEntity<?> responseEntity = loiFormService.createLoiFormReport(from, to);

        return responseEntity;

    }

    @RequestMapping(value = "/updatePayment", method = RequestMethod.POST)

    public String updateForm(@RequestBody BrandFeeCollection brandFeeCollection, Model model) throws Exception {

        BrandFeeCollection brandFeeCollection1 = brandFeeCollectionRepository.selectById(brandFeeCollection.getId());

        LoiForm loiForm = loiFormRepository.selectById(brandFeeCollection1.getLoiFormId());

        brandFeeCollection1.setFeeCollectingTimeStamp(brandFeeCollection.getFeeCollectingTimeStamp());

        brandFeeCollection1.setCollectedAmount(brandFeeCollection.getCollectedAmount());

        brandFeeCollection1.setPaymentAttachment(brandFeeCollection.getPaymentAttachment());

        brandFeeCollection1.setPaymentReferenceNo(brandFeeCollection.getPaymentReferenceNo());

        brandFeeCollection1.setPaymentMode(brandFeeCollection.getPaymentMode());

        double totalCollectedFee = brandFeeCollectionRepository.selectAllByLoiFormId(loiForm.getId()).stream().mapToDouble(x -> x.getCollectedAmount()).sum();

        if (totalCollectedFee <= loiForm.getAgreedBrandFees()) {

            model.addAttribute("response1", mvcResponseSender.createResponseString(true));

        } else {

            double differanceAmount = totalCollectedFee - loiForm.getAgreedBrandFees();

            throw new ProfitMandiBusinessException("You need to add only due brand fee that is Only, " + differanceAmount + " INR", null, "Pay differance amount or less then differance amount");

        }

        return "response";

    }

    @RequestMapping(value = "/updateAgreedBrandFee", method = RequestMethod.PUT)

    public String updateAgreedBrandFee(HttpServletRequest request, @RequestParam int loiId, @RequestParam double brandFee, @RequestParam StoreType storeType, Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        boolean isAgreedBrandFeeChanger = agreedBrandFeeChangerEmail.stream().anyMatch(x -> x.equals(loginDetails.getEmailId()));

        if (isAgreedBrandFeeChanger) {

            LoiForm loiForm = loiFormRepository.selectById(loiId);

            loiForm.setAgreedBrandFees(brandFee);

            loiForm.setBrandType(storeType);

            loiFormService.checkLoiDetailsCompletion(loiFormRepository.selectById(loiId));

            model.addAttribute("response1", mvcResponseSender.createResponseString(true));

            return "response";

        } else {

            throw new ProfitMandiBusinessException("failed in Authority check ", null, "Sorry " + authRepository.selectByEmailOrMobile(loginDetails.getEmailId()).getName() + " you have no authority to change agreed brand fee");

        }

    }

    @RequestMapping(value = "/approve-reject-Loi", method = RequestMethod.PUT)

    public String approveDetails(HttpServletRequest request, @RequestParam int loiId, @RequestParam boolean flag, Model model) throws Exception {

        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        String email = loginDetails.getEmailId();

        LoiForm loiForm = loiFormRepository.selectById(loiId);

        AuthUser filledBy = authRepository.selectByEmailOrMobile(loiForm.getFilledBy());

        // Approver chain = every manager above the filler. Previously hardcoded to

        // (immediate manager, grandmanager) which NPE'd whenever the filler sat near

        // the top of the hierarchy — common now that upper-level users fill LOIs on

        // behalf of their reportees (filledBy = themselves). Walk the full chain so

        // any ancestor can approve, and null-guard every hop.

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

        if (filledBy != null) {

            for (AuthUser ancestor : authService.getAllManagers(filledBy.getId())) {

                if (ancestor != null && ancestor.getEmailId() != null) {

                    approverMail.add(ancestor.getEmailId());

                }

            }

        }

        LOGGER.info("approverMail-" + approverMail);

        // Approver - Manager or Upper manager of loi filledBy(BM)

        boolean isApprover = approverMail.contains(email);

        LOGGER.info("isApprover-" + isApprover);

        List<String> authEmail = Arrays.asList("tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com");

        boolean isAuthUser = authEmail.stream().anyMatch(x -> x.equals(email));

        if (flag) {

            if (isApprover || isAuthUser) {

                loiForm.setLoiApprover(email);

                loiForm.setLoiApproved(flag);

                if (loiForm.getStatus() == LoiStatus.LOI_REJECT) {

                    loiForm.setStatus(LoiStatus.PENDING);

                }

                // BM Approval timeline entry

                storeTimelineTatService.createStoreTimeline(loiId, StoreTimeline.BM_APPROVAL);

                // Check if all LOI conditions are now met (BM approval could be the last step)

                loiFormService.checkLoiDetailsCompletion(loiForm);

                model.addAttribute("response1", mvcResponseSender.createResponseString(true));

            } else {

                throw new ProfitMandiBusinessException("Failed in Authority check ", "Read", "Sorry " + authRepository.selectByEmailOrMobile(loginDetails.getEmailId()).getName() + " you have no authority to Approve this Loi Form ,Only reporting manager and upper can Approve");

            }

        } else {

            if (isApprover || isAuthUser) {

                loiForm.setLoiApprover(email);

                loiForm.setLoiApproved(flag);

                loiForm.setStatus(LoiStatus.LOI_REJECT);

                model.addAttribute("response1", mvcResponseSender.createResponseString(true));

            } else {

                throw new ProfitMandiBusinessException("Failed in Authority check ", "Read", "Sorry " + authRepository.selectByEmailOrMobile(loginDetails.getEmailId()).getName() + " you have no authority to Approve this Loi Form ,Only reporting manager and upper can Approve");

            }

        }

        return "response";

    }

    // For a REVIVAL LOI whose brand-fee payment just got confirmed:

    //   1. Reactivate the FofoStore behind the old code so orders / wallet / inventory

    //      start honoring the store again.

    //   2. Wipe all Store Setup + Launch timeline events (RECCE, WOD, FIN_CODE,

    //      WOD_FINANCE_MAPPING, BRANDING, ADVANCE_STOCK_PAYMENT, FULL_STOCK_PAYMENT,

    //      AGREEMENT_ESIGN, PO_CREATION, PO_APPROVAL, BILLING, INAUGRATION, TRAINING)

    //      plus RBM_ASSIGNMENT so the revived partner has to redo the full lifecycle.

    //      Kept from old life: ON_BOARDING, VERIFICATION, STORE_CODE_CREATED,

    //      DOCUMENTS, WELCOME_CALL — partner is already known + verified.

    //   3. Reset the backing panel fields (billingStatus, inaugrationDate,

    //      deploymentDate, receeActual, status) and the training panel's

    //      appTraining / dashboardTraning flags so the events can actually re-fire.

    //   4. Wipe the AgreementEsign record so the upload widget starts blank.

    // No-op for NEW and ANY_OTHER LOIs.

    private void applyRevivalPaymentHooks(LoiForm loi, String approvedBy) throws ProfitMandiBusinessException {

        if (loi == null || loi.getOnboardingType() != OnboardingType.REVIVAL) return;

        String oldCode = loi.getOldStoreCode();

        if (oldCode != null && !oldCode.trim().isEmpty()) {

            // A SUSPENDED store comes back on the same code. A CLOSED store stays closed; its new code is issued

            // when the store is created (RetailerServiceImpl.takeoverClosedStoreIdentity).

            FofoStore store = fofoStoreRepository.selectByStoreCode(oldCode.trim());

            if (store != null && store.getStoreStatus() == StoreStatus.SUSPENDED) {

                storeStatusService.reviveSameStore(store.getId(), loi.getId(), approvedBy);

                LOGGER.info("Revival PAYMENT_APPROVAL: reactivated FofoStore code=" + oldCode);

            }

        }

        int onboardingId = loi.getOnBoardingId();

        if (onboardingId > 0) {

            // RECCE and BRANDING are NOT cleared on revival — the old store's design work

            // is reused. Only the operational / commercial side of the lifecycle is redone:

            // fresh WOD, FIN_CODE, WOD_FINANCE_MAPPING; new stock payment; fresh agreement

            // signing; new PO cycle; new billing + inauguration + training; new RBM assignment.

            StoreTimeline[] revivalClearEvents = {

                    StoreTimeline.WOD,

                    StoreTimeline.FIN_CODE,

                    StoreTimeline.WOD_FINANCE_MAPPING,

                    StoreTimeline.ADVANCE_STOCK_PAYMENT,

                    StoreTimeline.FULL_STOCK_PAYMENT,

                    StoreTimeline.AGREEMENT_ESIGN,

                    StoreTimeline.PO_CREATION,

                    StoreTimeline.PO_APPROVAL,

                    StoreTimeline.BILLING,

                    StoreTimeline.INAUGRATION,

                    StoreTimeline.TRAINING,

                    StoreTimeline.RBM_ASSIGNMENT

            };

            for (StoreTimeline ev : revivalClearEvents) {

                storeTimelinetbRepository.deleteByOnboardingIdAndEvent(onboardingId, ev);

            }

            agreementEsignRepository.deleteByOnboardingId(onboardingId);

            // Reset the RBM Assignment gating row to PENDING. The timeline event

            // above is deleted so the admin needs to re-mark; but STORE_CODE_CREATED

            // isn't cleared on revival (same store code reused), so the PENDING-row

            // seeder in StoreTimelineTatServiceImpl.onStoreCodeCreated won't re-run.

            // Without this reset the row stays ASSIGNED from the previous lifecycle,

            // /rbmAssignmentPanel (filters status='PENDING') hides the partner, and

            // PO_CREATION stays gated forever.

            com.spice.profitmandi.dao.entity.user.RbmAssignment rbmRow =

                    rbmAssignmentRepository.selectByOnboardingId(onboardingId);

            if (rbmRow != null) {

                rbmRow.setStatus("PENDING");

                rbmRow.setMarkedBy(null);

                rbmRow.setMarkedAt(null);

                rbmAssignmentRepository.persist(rbmRow);

            } else {

                com.spice.profitmandi.dao.entity.user.RbmAssignment seed =

                        new com.spice.profitmandi.dao.entity.user.RbmAssignment();

                seed.setOnboardingId(onboardingId);

                seed.setStatus("PENDING");

                seed.setCreatedAt(LocalDateTime.now());

                rbmAssignmentRepository.persist(seed);

            }

            PartnerOnBoardingPanel panel = partnerOnBoardingPanelRepository.selectById(onboardingId);

            if (panel != null) {

                panel.setBillingStatus(0);

                panel.setInaugrationDate(null);

                panel.setDeploymentDate(null);

                panel.setReceeActual(null);

                panel.setStatus(PartnerOnBoardingStatus.pending);

                // Reopen the Design TAT queue slot — the listing at

                // /partnerDesignTatPanel filters by (status=pending AND

                // designTatStatus=pending). Without this reset the revival panel

                // stays completed and RECCE / BRANDING never surface for the design team.

                panel.setDesignTatStatus(PartnerOnboardingDesignTatStatus.pending);

                panel.setUpdatedTimestamp(LocalDateTime.now());

                partnerOnBoardingPanelRepository.persist(panel);

            }

            PartnerOnboardingTrainingPanel training = partnerDashboardTrainingRepository.selectByOnboardingId(onboardingId);

            if (training != null) {

                training.setAppTraining(null);

                training.setDashboardTraning(null);

                training.setDateCompleted(null);

                training.setUpdateTimestamp(LocalDateTime.now());

                partnerDashboardTrainingRepository.persist(training);

            }

            LOGGER.info("Revival PAYMENT_APPROVAL: cleared " + revivalClearEvents.length

                    + " timeline events + AgreementEsign + reset panel/training state for onboardingId=" + onboardingId);

        }

    }

}