Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import com.spice.profitmandi.common.enumuration.MessageType;
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.common.model.UnsettledPaymentModel;
import com.spice.profitmandi.common.util.*;
import com.spice.profitmandi.dao.entity.dtr.CreditAccount;
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
import com.spice.profitmandi.dao.entity.transaction.*;
import com.spice.profitmandi.dao.enumuration.fofo.Gateway;
import com.spice.profitmandi.dao.enumuration.transaction.AddWalletRequestStatus;
import com.spice.profitmandi.dao.enumuration.transaction.TransactionType;
import com.spice.profitmandi.dao.repository.catalog.AddWalletRequestRepository;
import com.spice.profitmandi.dao.repository.catalog.ManualPaymentRequestRepository;
import com.spice.profitmandi.dao.repository.catalog.UnsettledPaymentsRepository;
import com.spice.profitmandi.dao.repository.dtr.CreditAccountRepository;
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
import com.spice.profitmandi.dao.repository.transaction.*;
import com.spice.profitmandi.service.NotificationService;
import com.spice.profitmandi.service.authentication.RoleManager;
import com.spice.profitmandi.service.transaction.TransactionService;
import com.spice.profitmandi.service.user.RetailerService;
import com.spice.profitmandi.service.wallet.WalletService;
import com.spice.profitmandi.web.model.LoginDetails;
import com.spice.profitmandi.web.util.CookiesProcessor;
import com.spice.profitmandi.web.util.MVCResponseSender;
import in.shop2020.model.v1.order.WalletReferenceType;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.CellStyle;
import org.apache.poi.ss.usermodel.CreationHelper;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.json.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.io.InputStreamResource;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.mail.javamail.MimeMessageHelper;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import javax.servlet.http.HttpServletRequest;
import javax.swing.*;
import javax.transaction.Transactional;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.math.BigDecimal;
import java.text.MessageFormat;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.*;
import java.util.stream.Collectors;

@Controller
@Transactional(rollbackOn = Throwable.class)
public class WalletController {

    private static final int IDX_PERIOD = 1;
    private static final int OPENING_BALANCE = 2;
    private static final int ACTIVATION_SCHEME = 4;
    private static final int ADVANCE_AMOUNT = 5;
    private static final int AUTOMATED_ADVANCE = 6;
    private static final int BRAND_PAYOUT = 7;
    private static final int INVESTMENT_PAYOUT = 8;
    private static final int OTHERS = 9;
    private static final int PREBOOKING_ORDER = 10;
    private static final int PRICE_DROP = 11;
    private static final int PURCHASE = 12;
    private static final int PURCHASE_BILLED = 13;
    private static final int PURCHASE_PENDING_BILLING = 14;
    private static final int PURCHASE_CANCELLED = 15;
    private static final int RECHARGE = 16;
    private static final int REFUND = 17;
    private static final int SCHEME_IN = 18;
    private static final int SCHEME_OUT = 19;
    private static final Map<WalletReferenceType, Integer> walletReferenceMap = new HashMap<>();
    private static final int GRAND_TOTAL = 20;
    private static final int CLOSING_BALANCE = 22;
    private static final int PENDING_GRN = 23;
    private static final int ACTIVATED_IMEIS = 24;
    private static final Logger LOGGER = LogManager.getLogger(WalletController.class);

    static {
        walletReferenceMap.put(WalletReferenceType.ACTIVATION_SCHEME, ACTIVATION_SCHEME);
        walletReferenceMap.put(WalletReferenceType.ADVANCE_AMOUNT, ADVANCE_AMOUNT);
        walletReferenceMap.put(WalletReferenceType.AUTOMATED_ADVANCE, AUTOMATED_ADVANCE);
        walletReferenceMap.put(WalletReferenceType.BRAND_PAYOUT, BRAND_PAYOUT);
        walletReferenceMap.put(WalletReferenceType.INVESTMENT_PAYOUT, INVESTMENT_PAYOUT);
        walletReferenceMap.put(WalletReferenceType.OTHERS, OTHERS);
        walletReferenceMap.put(WalletReferenceType.PREBOOKING_ORDER, PREBOOKING_ORDER);
        walletReferenceMap.put(WalletReferenceType.PRICE_DROP, PRICE_DROP);
        walletReferenceMap.put(WalletReferenceType.PURCHASE, PURCHASE);
        walletReferenceMap.put(WalletReferenceType.RECHARGE, RECHARGE);
        walletReferenceMap.put(WalletReferenceType.REFUND, REFUND);
        walletReferenceMap.put(WalletReferenceType.SCHEME_IN, SCHEME_IN);
        walletReferenceMap.put(WalletReferenceType.SCHEME_OUT, SCHEME_OUT);

    }

    @Autowired
    JavaMailSender mailSender;
    @Autowired
    AddWalletRequestRepository addWalletRequestRepository;
    @Autowired
    TransactionService transactionService;
    @Autowired
    private CookiesProcessor cookiesProcessor;
    @Autowired
    private WalletService walletService;
    @Autowired
    private UserWalletRepository userWalletRepository;
    @Autowired
    private UserWalletHistoryRepository userWalletHistoryRepository;
    @Autowired
    private MVCResponseSender mvcResponseSender;
    @Autowired
    private UserAccountRepository userAccountRepository;
    @Autowired
    private OrderRepository orderRepository;
    @Autowired
    private UnsettledPaymentsRepository unsettledPaymentsRepository;
    @Autowired
    private RetailerService retailerService;
    @Autowired
    private RoleManager roleManager;
    @Autowired
    private FofoStoreRepository fofoStoreRepository;
    @Autowired
    private ManualPaymentRequestRepository manualPaymentRequestRepository;
    @Autowired
    private CreditAccountRepository creditAccountRepository;

    @Autowired
    private NotificationService notificationService;
    @Autowired
    LoanRepository loanRepository;
    @Autowired
    private LoanStatementRepository loanStatementRepository;
    @Autowired
    SDCreditRequirementRepository sdCreditRequirementRepository;

    @PostMapping(value = "/wallet/upload")
    public String uploadWalletBulk(HttpServletRequest request, @RequestPart("file") MultipartFile file, Model model) throws Exception {
        List<WalletHistoryModel> walletHistoryModelList = ExcelUtils.parseWalletBulkCredit(file.getInputStream());
        for (WalletHistoryModel walletHistoryModel : walletHistoryModelList) {
            if (walletHistoryModel.getReference() == 0) {
                ManualPaymentType paymentType = manualPaymentRequestRepository.selectByReferenceType(walletHistoryModel.getWalletReferenceType());
                if (paymentType == null) {
                    paymentType = new ManualPaymentType();
                    paymentType.setReferenceType(walletHistoryModel.getWalletReferenceType());
                    manualPaymentRequestRepository.persist(paymentType);
                }
                paymentType.setCounter(paymentType.getCounter() + 1);
                int reference = paymentType.getCounter();
                walletService.addAmountToWallet(walletHistoryModel.getFofoId(), reference, walletHistoryModel.getWalletReferenceType(), walletHistoryModel.getDescription(), (float) walletHistoryModel.getAmount(), walletHistoryModel.getBusinessDate());
            } else {
                walletService.addAmountToWallet(walletHistoryModel.getFofoId(), walletHistoryModel.getReference(), walletHistoryModel.getWalletReferenceType(), walletHistoryModel.getDescription(), (float) walletHistoryModel.getAmount(), walletHistoryModel.getBusinessDate());
            }
        }

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

    @RequestMapping(value = "/walletDetails", method = RequestMethod.GET)
    public String dashboard(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.START_TIME, required = false) String startTimeString, @RequestParam(name = ProfitMandiConstants.END_TIME, required = false) String endTimeString, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "100") int limit, Model model) throws ProfitMandiBusinessException {
        /*
         * boolean underMaintainance = true; if(underMaintainance) { throw new
         * ProfitMandiBusinessException("Wallet", "Wallet",
         * "Wallet is under Maintenance"); }
         */
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
        int fofoId = fofoDetails.getFofoId();
        boolean isAdmin = roleManager.isAdmin(fofoDetails.getRoleIds());
        UserWallet userWallet = walletService.getUserWallet(fofoId);

        LocalDateTime startDateTime = StringUtils.toDateTime(startTimeString);
        LocalDateTime endDateTime = StringUtils.toDateTime(endTimeString);

        List<UserWalletHistory> userWalletHistories = new ArrayList<>();
        try {
            userWalletHistories = walletService.getPaginatedUserWalletHistoryByRetailerId(fofoId, startDateTime, endDateTime, offset, limit);
        } catch (ProfitMandiBusinessException profitMandiBusinessException) {
            LOGGER.error("UserWallet History not found : ", profitMandiBusinessException);
        }

        long countItems = 0;
        try {
            countItems = walletService.getSizeByRetailerId(fofoDetails.getFofoId(), startDateTime, endDateTime);
        } catch (ProfitMandiBusinessException profitMandiBusinessException) {
            LOGGER.error("UserWallet not found : ", profitMandiBusinessException);
        }
        SDCreditRequirement sdCreditRequirement = sdCreditRequirementRepository.selectByFofoId(fofoId);
        List<Loan> loans = loanRepository.selectActiveLoan(fofoId);
        BigDecimal availableLimit = sdCreditRequirement.getAvailableLimit();
        BigDecimal creditlimit = sdCreditRequirement.getLimit();
        BigDecimal totalDue = new BigDecimal(0);
        for (Loan loan : loans) {
            BigDecimal pendingAmount = loan.getPendingAmount();
            BigDecimal interestAccrued = loan.getInterestAccrued();
            BigDecimal interestPaid = loan.getInterestPaid();
            totalDue = totalDue.add(interestAccrued.subtract(interestPaid).add(pendingAmount));
            availableLimit = creditlimit.subtract(totalDue);
        }
        model.addAttribute("userWallet", userWallet);
        model.addAttribute("walletHistories", userWalletHistories);
        model.addAttribute("start", offset + 1);
        model.addAttribute("size", countItems);
        model.addAttribute("isAdmin", isAdmin);
        model.addAttribute("loans", loans);
        model.addAttribute("totalDue", totalDue);
        model.addAttribute("availableLimit", availableLimit);
        model.addAttribute("creditlimit", creditlimit);
        model.addAttribute(ProfitMandiConstants.START_TIME, startTimeString);
        model.addAttribute(ProfitMandiConstants.END_TIME, endTimeString);

        if (userWalletHistories.size() < limit) {
            model.addAttribute("end", offset + userWalletHistories.size());
        } else {
            model.addAttribute("end", offset + limit);
        }
        return "wallet-details";
    }

    @RequestMapping(value = "/getPaginatedWalletHistory")
    public String getSaleHistoryPaginated(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.START_TIME, required = false) String startTimeString, @RequestParam(name = ProfitMandiConstants.END_TIME, required = false) String endTimeString, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws ProfitMandiBusinessException {
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

        LocalDateTime startDateTime = StringUtils.toDateTime(startTimeString);
        LocalDateTime endDateTime = StringUtils.toDateTime(endTimeString);

        List<UserWalletHistory> userWalletHistories = new ArrayList<>();
        try {
            userWalletHistories = walletService.getPaginatedUserWalletHistoryByRetailerId(loginDetails.getFofoId(), startDateTime, endDateTime, offset, limit);
        } catch (ProfitMandiBusinessException profitMandiBusinessException) {
            LOGGER.error("UserWallet History not found : ", profitMandiBusinessException);
        }

        model.addAttribute("walletHistories", userWalletHistories);
        return "wallet-history-paginated";
    }

    @RequestMapping(value = "/getAddWalletRequest", method = RequestMethod.GET)
    public String getAddwalletRequest(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws Exception {
        List<AddWalletRequest> walletRequest = null;
        long size = 0;
        walletRequest = addWalletRequestRepository.selectAllByStatus(offset, limit, AddWalletRequestStatus.pending);
        LOGGER.info("walletRequest" + walletRequest);
        size = addWalletRequestRepository.selectCountByStatus(AddWalletRequestStatus.pending);
        if (!walletRequest.isEmpty()) {
            List<Integer> fofoIds = this.getFofoIdsFromWalletRequest(walletRequest);

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

            Map<Integer, CustomRetailer> fofoIdsAndRetailerName = fofoIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null).collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));

            model.addAttribute("fofoIdsAndRetailerName", fofoIdsAndRetailerName);
            model.addAttribute("walletRequest", walletRequest);
            model.addAttribute("rStatus", "pending");
            model.addAttribute("start", offset + 1);
            model.addAttribute("size", size);
            model.addAttribute("url", "/getPaginatedWalletRequest");

            if (walletRequest.size() < limit) {
                model.addAttribute("end", offset + walletRequest.size());
            } else {
                model.addAttribute("end", offset + limit);
            }

        } else {

            model.addAttribute("walletRequest", walletRequest);
            model.addAttribute("size", size);

        }
        return "add-wallet-request";
    }

    @RequestMapping(value = "/getPaginatedWalletRequest", method = RequestMethod.GET)
    public String getPaginatedWalletRequest(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws Exception {
        LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
        List<AddWalletRequest> walletRequest = null;
        walletRequest = addWalletRequestRepository.selectAllByStatus(offset, limit, AddWalletRequestStatus.pending);
        LOGGER.info("walletRequest" + walletRequest);
        if (!walletRequest.isEmpty()) {
            List<Integer> fofoIds = this.getFofoIdsFromWalletRequest(walletRequest);
            Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();

            Map<Integer, CustomRetailer> fofoIdsAndRetailerName = fofoIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null).collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));

            model.addAttribute("fofoIdsAndRetailerName", fofoIdsAndRetailerName);
            model.addAttribute("walletRequest", walletRequest);
            model.addAttribute("rStatus", "pending");
            model.addAttribute("url", "/getPaginatedWalletRequest");

        } else {
            model.addAttribute("walletRequest", walletRequest);

        }

        return "add-wallet-request-paginated";
    }

    @RequestMapping(value = "/getAddWalletApproved", method = RequestMethod.GET)
    public String getAddwalletRequestApproved(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws ProfitMandiBusinessException {
        List<AddWalletRequest> walletRequest = null;

        long size = 0;
        walletRequest = addWalletRequestRepository.selectAllByStatus(offset, limit, AddWalletRequestStatus.approved);
        size = addWalletRequestRepository.selectCountByStatus(AddWalletRequestStatus.approved);
        LOGGER.info("walletRequest" + walletRequest);
        if (!walletRequest.isEmpty()) {
            List<Integer> fofoIds = this.getFofoIdsFromWalletRequest(walletRequest);
            Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();

            Map<Integer, CustomRetailer> fofoIdsAndRetailerName = fofoIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null).collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));

            model.addAttribute("fofoIdsAndRetailerName", fofoIdsAndRetailerName);
            model.addAttribute("walletRequest", walletRequest);
            model.addAttribute("start", offset + 1);
            model.addAttribute("size", size);
            model.addAttribute("url", "/getPaginatedWalletApproved");

            if (walletRequest.size() < limit) {
                model.addAttribute("end", offset + walletRequest.size());
            } else {
                model.addAttribute("end", offset + limit);
            }
        } else {

            model.addAttribute("walletRequest", walletRequest);
            model.addAttribute("size", size);

        }
        return "add-wallet-request";
    }

    @RequestMapping(value = "/getPaginatedWalletApproved", method = RequestMethod.GET)
    public String getPaginatedWalletApproved(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws ProfitMandiBusinessException {
        LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
        List<AddWalletRequest> walletRequest = null;
        walletRequest = addWalletRequestRepository.selectAllByStatus(offset, limit, AddWalletRequestStatus.approved);
        LOGGER.info("walletRequest" + walletRequest);
        if (!walletRequest.isEmpty()) {
            List<Integer> fofoIds = this.getFofoIdsFromWalletRequest(walletRequest);
            Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();

            Map<Integer, CustomRetailer> fofoIdsAndRetailerName = fofoIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null).collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));

            model.addAttribute("fofoIdsAndRetailerName", fofoIdsAndRetailerName);
            model.addAttribute("walletRequest", walletRequest);
            model.addAttribute("url", "/getPaginatedWalletApproved");
        } else {
            model.addAttribute("walletRequest", walletRequest);

        }
        return "add-wallet-request-paginated";
    }

    @RequestMapping(value = "/getAddWalletRequestRejected", method = RequestMethod.GET)
    public String getAddwalletRequestRejected(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws ProfitMandiBusinessException {
        List<AddWalletRequest> walletRequest = null;

        long size = 0;
        walletRequest = addWalletRequestRepository.selectAllByStatus(offset, limit, AddWalletRequestStatus.rejected);
        size = addWalletRequestRepository.selectCountByStatus(AddWalletRequestStatus.rejected);
        LOGGER.info("walletRequest" + walletRequest);
        if (!walletRequest.isEmpty()) {
            List<Integer> fofoIds = this.getFofoIdsFromWalletRequest(walletRequest);
            Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();

            Map<Integer, CustomRetailer> fofoIdsAndRetailerName = fofoIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null).collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));

            model.addAttribute("fofoIdsAndRetailerName", fofoIdsAndRetailerName);
            model.addAttribute("walletRequest", walletRequest);
            model.addAttribute("start", offset + 1);
            model.addAttribute("size", size);
            model.addAttribute("url", "/getPaginatedWalletRequestRejected");

            if (walletRequest.size() < limit) {
                model.addAttribute("end", offset + walletRequest.size());
            } else {
                model.addAttribute("end", offset + limit);
            }
        } else {
            model.addAttribute("walletRequest", walletRequest);
            model.addAttribute("size", size);
        }

        return "add-wallet-request";
    }

    @RequestMapping(value = "/getPaginatedWalletRequestRejected", method = RequestMethod.GET)
    public String getPaginatedWalletRequestRejected(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws ProfitMandiBusinessException {
        LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
        List<AddWalletRequest> walletRequest = null;
        walletRequest = addWalletRequestRepository.selectAllByStatus(offset, limit, AddWalletRequestStatus.rejected);
        LOGGER.info("walletRequest" + walletRequest);
        if (!walletRequest.isEmpty()) {
            List<Integer> fofoIds = this.getFofoIdsFromWalletRequest(walletRequest);
            Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();

            Map<Integer, CustomRetailer> fofoIdsAndRetailerName = fofoIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null).collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
            model.addAttribute("fofoIdsAndRetailerName", fofoIdsAndRetailerName);
            model.addAttribute("walletRequest", walletRequest);
            model.addAttribute("url", "/getPaginatedWalletRequestRejected");
        } else {
            model.addAttribute("walletRequest", walletRequest);

        }

        return "add-wallet-request-paginated";
    }

    @RequestMapping(value = "/addAmountToWallet", method = RequestMethod.PUT)
    public String addAmountToWallet(HttpServletRequest request, @RequestParam(name = "id", defaultValue = "0") int id, @RequestParam(name = "walletRequestid", defaultValue = "0") int walletRequestid, Model model) throws Exception {

        AddWalletRequest addWalletRequest = addWalletRequestRepository.selectById(walletRequestid);
        if (addWalletRequest.getStatus().equals(AddWalletRequestStatus.pending)) {
            walletService.addAmountToWallet(addWalletRequest.getRetailerId(), walletRequestid, WalletReferenceType.ADVANCE_AMOUNT, "ntfs/rgfs", addWalletRequest.getAmount(), addWalletRequest.getCreateTimestamp());
            addWalletRequest.setStatus(AddWalletRequestStatus.approved);
            addWalletRequest.setUpdateTimestamp(LocalDateTime.now());
            addWalletRequestRepository.persist(addWalletRequest);
            unsettledPaymentsRepository.deleteById(id);
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
            CustomRetailer customRetailer = retailerService.getFofoRetailer(addWalletRequest.getRetailerId());
            String subject = "Request Approved for " + customRetailer.getBusinessName() + " of Rs." + addWalletRequest.getAmount();
            String messageText = MessageFormat.format("User Id - {0}\n Name -{1}\n Email -{2}\n mobile -{3}\n Reference - {4}\n Amount - Rs.{5}", new Integer(addWalletRequest.getRetailerId()), customRetailer.getBusinessName(), customRetailer.getEmail(), customRetailer.getMobileNumber(), addWalletRequest.getTransaction_reference(), new Float(addWalletRequest.getAmount()));

            //  this.sendMailWithAttachments(subject, messageText);
            return "response";
        } else {
            model.addAttribute("response1", mvcResponseSender.createResponseString(false));
            return "response";
        }
    }

    @RequestMapping(value = "/addAmountToWalletRequestRejected", method = RequestMethod.PUT)
    public String addAmountToWalletRequestRejected(HttpServletRequest request, @RequestParam(name = "id", defaultValue = "0") int id, Model model) throws Exception {

        AddWalletRequest addWalletRequest = addWalletRequestRepository.selectById(id);
        if (addWalletRequest.getStatus().equals(AddWalletRequestStatus.pending)) {
            addWalletRequest.setStatus(AddWalletRequestStatus.rejected);
            addWalletRequest.setUpdateTimestamp(LocalDateTime.now());
            addWalletRequestRepository.persist(addWalletRequest);
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
            CustomRetailer customRetailer = retailerService.getFofoRetailer(addWalletRequest.getRetailerId());
            String subject = "Request Rejected for " + customRetailer.getBusinessName() + " of Rs." + addWalletRequest.getAmount();
            String messageText = MessageFormat.format("User Id - {0}\n Name -{1}\n Email -{2}\n mobile -{3}\n Reference - {4}\n Amount - Rs.{5}", new Integer(addWalletRequest.getRetailerId()), customRetailer.getBusinessName(), customRetailer.getEmail(), customRetailer.getMobileNumber(), addWalletRequest.getTransaction_reference(), new Float(addWalletRequest.getAmount()));

            //this.sendMailWithAttachments(subject, messageText);
            return "response";
        } else {
            model.addAttribute("response1", mvcResponseSender.createResponseString(false));
            return "response";
        }
    }

    private void sendMailWithAttachments(String subject, String messageText) throws Exception {
        MimeMessage message = mailSender.createMimeMessage();
        MimeMessageHelper helper = new MimeMessageHelper(message, true);
        String[] email = {"neerajgupta2021@gmail.com", "adeel.yazdani@smartdukaan.com", "kamini.sharma@smartdukaan.com", "care@smartdukaan.com", "mohinder.mutreja@smartdukaan.com"};
        helper.setSubject(subject);
        helper.setText(messageText);
        helper.setTo(email);
        InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
        helper.setFrom(senderAddress);
        mailSender.send(message);

    }

    private List<Integer> getFofoIdsFromWalletRequest(List<AddWalletRequest> walletRequest) {
        return walletRequest.stream().map(x -> x.getRetailerId()).distinct().collect(Collectors.toList());
    }

    @RequestMapping(value = "/getcreateUnsettledPayments", method = RequestMethod.GET)
    public String getcreateUnsettledPayment(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "15") int limit, Model model) throws Exception {
        List<UnsettledPayment> up = null;

        long size = 0;
        up = unsettledPaymentsRepository.selectAllById(offset, limit);

        size = unsettledPaymentsRepository.selectAllCount();
        if (!up.isEmpty()) {
            model.addAttribute("unsettledPayment", up);
            model.addAttribute("start", offset + 1);
            model.addAttribute("size", size);
            model.addAttribute("url", "/getPaginatedUnsettledPayments");

            if (up.size() < limit) {
                model.addAttribute("end", offset + up.size());
            } else {
                model.addAttribute("end", offset + limit);
            }
        } else {
            model.addAttribute("unsettledPayment", up);
            model.addAttribute("size", size);
        }

        LOGGER.info("unsettledPaymentList" + up);
        return "unsettled-payments";
    }

    @RequestMapping(value = "/getUnsettledPaymentsByAmount", method = RequestMethod.GET)
    public String getUnsettledPaymentByAmount(HttpServletRequest request, @RequestParam(name = "amount", defaultValue = "0") float amount, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws Exception {
        List<UnsettledPayment> up = null;

        long size = 0;
        up = unsettledPaymentsRepository.selectAllByAmount(amount, offset, limit);

        size = unsettledPaymentsRepository.selectAllCount();
        if (!up.isEmpty()) {
            model.addAttribute("unsettledPayment", up);
            model.addAttribute("start", offset + 1);
            model.addAttribute("size", size);
            model.addAttribute("url", "/getPaginatedUnsettledPayments");

            if (up.size() < limit) {
                model.addAttribute("end", offset + up.size());
            } else {
                model.addAttribute("end", offset + limit);
            }
            return "unsettle-payment-modal";
        } else {
            model.addAttribute("unsettledPayment", up);
            model.addAttribute("size", size);
        }

        return "unsettle-payment-modal";
    }

    @RequestMapping(value = "/createUnsettledPaymentsEntries", method = RequestMethod.POST)
    public String createUnsettledPaymentsEntries(HttpServletRequest request, @RequestBody UnsettledPaymentModel unsettledPaymentModel, Model model) throws Exception {

        UnsettledPayment up = new UnsettledPayment();
        up.setTransaction_reference(unsettledPaymentModel.getTransactionReference());
        up.setAmount(unsettledPaymentModel.getAmount());
        up.setDescription(unsettledPaymentModel.getDescription());
        up.setReference_date(unsettledPaymentModel.getReferenceDate());
        LOGGER.info("uppaynments" + up);
        unsettledPaymentsRepository.persist(up);
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
        return "response";
    }

    @RequestMapping(value = "/removeUnsettledPaymentsEntries", method = RequestMethod.DELETE)
    public String removeUnsettledPaymentsEntries(HttpServletRequest request, @RequestParam(name = "id", defaultValue = "0") int id, Model model) throws Exception {

        unsettledPaymentsRepository.deleteById(id);

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

    @RequestMapping(value = "/wallet/statement", method = RequestMethod.GET)
    public String getWalletStatement(HttpServletRequest request, @RequestParam LocalDateTime startDate, @RequestParam LocalDateTime endDate, Model model, @RequestParam(defaultValue = "0") int fofoId) throws Exception {
        boolean isAdmin = roleManager.isAdmin(cookiesProcessor.getCookiesObject(request).getRoleIds());
        if (fofoId > 0) {
            if (!isAdmin) {
                throw new ProfitMandiBusinessException("Unauthorised access", "PartnerId", "Permission Denied");
            }
        } else {
            fofoId = cookiesProcessor.getCookiesObject(request).getFofoId();
        }
        float openingBalance = walletService.getOpeningTill(fofoId, startDate);
        float closingBalance = walletService.getOpeningTill(fofoId, endDate);
        List<UserWalletHistory> uwhList = walletService.getPaginatedUserWalletHistoryByRetailerId(fofoId, startDate, endDate, 0, 0);
        Collections.reverse(uwhList);
        model.addAttribute("opening", openingBalance);
        model.addAttribute("closing", closingBalance);
        model.addAttribute("history", uwhList);
        model.addAttribute("startDate", startDate);
        model.addAttribute("endDate", endDate);
        return "walletStatement";
    }

    @RequestMapping(value = "/account/reco", method = RequestMethod.GET)
    public ResponseEntity<?> accountReco(HttpServletRequest request, @RequestParam LocalDate closingDate, Model model) throws Exception {
        boolean isAdmin = roleManager.isAdmin(cookiesProcessor.getCookiesObject(request).getRoleIds());
        if (!isAdmin) {
            throw new ProfitMandiBusinessException("Unauthorised access", "PartnerId", "Permission Denied");
        }
        LocalDateTime closingDateTime = LocalDate.now().atStartOfDay().plusDays(1);
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
        Set<Integer> retailersSet = customRetailerMap.keySet();

        Map<Integer, Float> closingPurchaseMap = orderRepository.selectOpeningAmount(closingDateTime, retailersSet);

        Map<Integer, UserWallet> retailerWalletMap = walletService.getRetailerIdUserWalletMap(retailersSet);
        Map<Integer, Integer> walletRetailerMap = retailerWalletMap.entrySet().stream().collect(Collectors.toMap(x -> x.getValue().getId(), x -> x.getKey()));

        Set<Integer> walletSet = walletRetailerMap.keySet();
        Map<Integer, Float> closingBalanceMap = userWalletHistoryRepository.getSumTillDateExcludingPurchase(closingDateTime, walletSet);
        Map<Integer, Float> closingWalletMap = userWalletHistoryRepository.getSumTillDate(closingDateTime, walletSet);
        Map<Integer, Float> peindingIndentMap = transactionService.getPendingIndentValueMap();

        List<List<?>> rows = new ArrayList<>();
        for (Map.Entry<Integer, Float> closingBalance : closingBalanceMap.entrySet()) {
            int walletId = closingBalance.getKey();
            int retailerId = walletRetailerMap.get(walletId);

            float accountClosing = 0f;
            if (!closingPurchaseMap.containsKey(retailerId)) {
                accountClosing = closingBalance.getValue();
            } else {
                accountClosing = closingBalance.getValue() - closingPurchaseMap.get(retailerId);
            }

            CustomRetailer cr = customRetailerMap.get(retailerId);

            rows.add(Arrays.asList(retailerId, cr.getBusinessName(), cr.getAddress().getCity(), cr.getAddress().getState(), accountClosing, closingWalletMap.get(walletId), peindingIndentMap.get(retailerId)));
        }

        org.apache.commons.io.output.ByteArrayOutputStream byteArrayOutputStream = FileUtil.getCSVByteStream(Arrays.asList("Id", "Partner Name", "City", "State", "Closing Balance", "Closing Wallet", "In Transit"), rows);
        final HttpHeaders headers = new HttpHeaders();
        headers.set("Content-Type", "text/csv");
        headers.set("Content-disposition", "inline; filename=account-statement-closing-." + StringUtils.toHyphenatedString(closingDate) + ".csv");
        headers.setContentLength(byteArrayOutputStream.toByteArray().length);

        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
    }

    @RequestMapping(value = "/account/closing-statements", method = RequestMethod.GET)
    public ResponseEntity<?> getAccountStatement(HttpServletRequest request, @RequestParam LocalDate closingDate, Model model) throws Exception {
        boolean isAdmin = roleManager.isAdmin(cookiesProcessor.getCookiesObject(request).getRoleIds());
        if (!isAdmin) {
            throw new ProfitMandiBusinessException("Unauthorised access", "PartnerId", "Permission Denied");
        }
        LocalDateTime closingDateTime = closingDate.atStartOfDay().plusDays(1);

        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
        Set<Integer> retailersSet = customRetailerMap.keySet();

        Map<Integer, Float> closingPurchaseMap = orderRepository.selectOpeningAmount(closingDateTime, retailersSet);

        Map<Integer, UserWallet> retailerWalletMap = walletService.getRetailerIdUserWalletMap(retailersSet);
        Map<Integer, Integer> walletRetailerMap = retailerWalletMap.entrySet().stream().collect(Collectors.toMap(x -> x.getValue().getId(), x -> x.getKey()));

        Set<Integer> walletSet = walletRetailerMap.keySet();
        Map<Integer, Float> closingBalanceMap = userWalletHistoryRepository.getSumTillDateExcludingPurchase(closingDateTime, walletSet);

        List<List<?>> rows = new ArrayList<>();
        for (Map.Entry<Integer, Float> closingWalletBalance : closingBalanceMap.entrySet()) {
            int walletId = closingWalletBalance.getKey();
            int retailerId = walletRetailerMap.get(walletId);
            if (!closingPurchaseMap.containsKey(retailerId)) {
                closingPurchaseMap.put(retailerId, closingWalletBalance.getValue());
            } else {
                closingPurchaseMap.put(retailerId, closingWalletBalance.getValue() - closingPurchaseMap.get(retailerId));
            }
            float closingValue = closingPurchaseMap.get(retailerId);
            CustomRetailer cr = customRetailerMap.get(retailerId);

            rows.add(Arrays.asList(retailerId, cr.getBusinessName(), cr.getAddress().getCity(), cr.getAddress().getState(), closingValue));
        }

        org.apache.commons.io.output.ByteArrayOutputStream byteArrayOutputStream = FileUtil.getCSVByteStream(Arrays.asList("Id", "Partner Name", "City", "State", "Closing Balance"), rows);
        final HttpHeaders headers = new HttpHeaders();
        headers.set("Content-Type", "text/csv");
        headers.set("Content-disposition", "inline; filename=account-statement-closing-." + StringUtils.toHyphenatedString(closingDate) + ".csv");
        headers.setContentLength(byteArrayOutputStream.toByteArray().length);

        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);

        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);

    }

    @RequestMapping(value = "/account/statement", method = RequestMethod.GET)
    public ResponseEntity<?> getAccountStatement(HttpServletRequest request, @RequestParam LocalDateTime startDate, @RequestParam LocalDateTime endDate, Model model, @RequestParam(defaultValue = "0") int fofoId) throws Exception {
        boolean isAdmin = roleManager.isAdmin(cookiesProcessor.getCookiesObject(request).getRoleIds());
        if (fofoId > 0) {
            if (!isAdmin) {
                throw new ProfitMandiBusinessException("Unauthorised access", "PartnerId", "Permission Denied");
            }
        } else {
            fofoId = cookiesProcessor.getCookiesObject(request).getFofoId();
        }
        float openingBalance = walletService.getOpeningTillExcludingPurchase(fofoId, startDate);
        float closingBalance = walletService.getOpeningTillExcludingPurchase(fofoId, endDate);
        UserWallet uw = walletService.getUserWallet(fofoId);
        List<UserWalletHistory> history = userWalletHistoryRepository.selectPaginatedByWalletId(uw.getId(), startDate, endDate, 0, 0);
        history = history.stream().filter(x -> !x.getReferenceType().equals(WalletReferenceType.PURCHASE)).collect(Collectors.toList());
        InputStream is = getClass().getClassLoader().getResourceAsStream("account-statement.xlsx");
        String partnerName = retailerService.getAllFofoRetailerIdNameMap().get(fofoId);
        List<StatementDetailModel> details = orderRepository.selectDetailsBetween(fofoId, startDate, endDate);
        float openingAmount = orderRepository.selectOpeningAmount(fofoId, startDate);
        float closingAmount = orderRepository.selectOpeningAmount(fofoId, endDate);
        LOGGER.info("Opening - {}, Closing - {}", openingAmount, closingAmount);
        ByteArrayOutputStream byteArrayOutputStream = this.populateData(is, openingBalance - openingAmount, closingBalance - closingAmount, partnerName, history, startDate, endDate, details);

        final HttpHeaders headers = new HttpHeaders();
        headers.set("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
        headers.set("Content-disposition", "inline; filename=account-statement." + StringUtils.toHyphenatedString(startDate.toLocalDate()) + "-" + StringUtils.toHyphenatedString(endDate.toLocalDate()) + ".xlsx");
        headers.setContentLength(byteArrayOutputStream.toByteArray().length);

        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);

        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);

    }

    private ByteArrayOutputStream populateData(InputStream is, float openingBalance, float closingBalance, String partnerName, List<UserWalletHistory> history, LocalDateTime startDate, LocalDateTime endDate, List<StatementDetailModel> invoiceDetails) throws Exception {
        XSSFWorkbook workbook = new XSSFWorkbook(is);
        CreationHelper creationHelper = workbook.getCreationHelper();
        CellStyle style2 = workbook.createCellStyle();
        style2.setDataFormat(creationHelper.createDataFormat().getFormat("mm/dd/yyyy hh:mm:ss"));

        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        Sheet sheet = workbook.getSheetAt(0);
        sheet.getRow(0).getCell(0).setCellValue(partnerName);
        sheet.getRow(1).getCell(1).setCellValue(new Date(startDate.atZone(ZoneId.systemDefault()).toInstant().toEpochMilli()));
        sheet.getRow(1).getCell(2).setCellValue(new Date(endDate.atZone(ZoneId.systemDefault()).toInstant().toEpochMilli()));
        sheet.getRow(2).getCell(2).setCellValue(openingBalance);
        long grandTotalDebit = 0l;
        long grandTotalCredit = 0l;
        int row = 4;
        for (UserWalletHistory walletEntry : history) {
            Cell dateCell = sheet.createRow(row).createCell(0);
            dateCell.setCellValue(new Date(walletEntry.getTimestamp().atZone(ZoneId.systemDefault()).toInstant().toEpochMilli()));
            dateCell.setCellStyle(style2);
            sheet.getRow(row).createCell(1).setCellValue(walletEntry.getReferenceType().toString());
            if (walletEntry.getAmount() > 0) {
                sheet.getRow(row).createCell(2).setCellValue(0);
                sheet.getRow(row).createCell(3).setCellValue(walletEntry.getAmount());
                grandTotalCredit += walletEntry.getAmount();
            } else {
                sheet.getRow(row).createCell(2).setCellValue(-walletEntry.getAmount());
                sheet.getRow(row).createCell(3).setCellValue(0);
                grandTotalDebit -= walletEntry.getAmount();
            }
            sheet.getRow(row).createCell(4).setCellValue(walletEntry.getDescription());
            sheet.getRow(row).createCell(5).setCellValue(walletEntry.getReference());
            row++;
        }
        for (StatementDetailModel statementDetailModel : invoiceDetails) {
            Cell dateCell = sheet.createRow(row).createCell(0);
            dateCell.setCellValue(statementDetailModel.getOnDate());
            dateCell.setCellStyle(style2);
            sheet.getRow(row).createCell(1).setCellValue("BILLING");
            if (statementDetailModel.getAmount() > 0) {
                sheet.getRow(row).createCell(2).setCellValue(statementDetailModel.getAmount());
                sheet.getRow(row).createCell(3).setCellValue(0);
                grandTotalDebit += statementDetailModel.getAmount();
            } else {
                sheet.getRow(row).createCell(2).setCellValue(0);
                sheet.getRow(row).createCell(3).setCellValue(-statementDetailModel.getAmount());
                grandTotalCredit += -statementDetailModel.getAmount();
            }

            sheet.getRow(row).createCell(4).setCellValue(statementDetailModel.getReferenceType());
            sheet.getRow(row).createCell(5).setCellValue(statementDetailModel.getInvoiceNumber());

            row += 1;
        }
        sheet.createRow(row).createCell(0).setCellValue("Grand Total");
        sheet.getRow(row).createCell(2).setCellValue(grandTotalDebit);
        sheet.getRow(row).createCell(3).setCellValue(grandTotalCredit);
        row += 2;
        sheet.createRow(row).createCell(0).setCellValue("Closing Balance");
        sheet.getRow(row).createCell(3).setCellValue(closingBalance);
        row++;
        /*
         * sheet.createRow(row).createCell(0).setCellValue("Pending Grns");
         * sheet.getRow(row).createCell(2).setCellValue(closingBalance); row++;
         */
        try {
            workbook.write(bos);
        } finally {
            workbook.close();
            bos.close();
        }

        return bos;
    }

    @RequestMapping(value = "/manualPayment", method = RequestMethod.GET)
    public String ManualPayment(HttpServletRequest request, Model model) throws Exception {

        List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().map(x -> x.getId()).collect(Collectors.toList());
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();

        Map<Integer, CustomRetailer> customRetailersMap = fofoIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null).collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
        String customRetailers = JSONObject.valueToString(customRetailersMap.values());
        model.addAttribute("customRetailers", customRetailers);

        model.addAttribute("referenceTypes", WalletReferenceType.referenceType);
        model.addAttribute("transactionTypes", TransactionType.values());
        return "wallet-edit";

    }

    @RequestMapping(value = "/getWalletHistory", method = RequestMethod.GET)
    public String getWalletHistory(HttpServletRequest request, @RequestParam(name = "reference", defaultValue = "0") int reference, @RequestParam WalletReferenceType referenceType, Model model) throws Exception {

        LOGGER.info("type" + referenceType);
        List<UserWalletHistory> userWalletHistory = userWalletHistoryRepository.selectAllByreferenceIdandreferenceType(reference, referenceType);

        if (userWalletHistory.isEmpty()) {
            throw new ProfitMandiBusinessException("RefrenceId", reference, "Reference Id not found");
        }

        UserWallet userWallet = userWalletRepository.selectById(userWalletHistory.get(0).getWalletId());

        LOGGER.info("userWallet" + userWallet);
        CustomRetailer customretailer = retailerService.getFofoRetailer(userWallet.getUserId());

        model.addAttribute("userWallet", userWallet);
        model.addAttribute("customretailer", customretailer);

        model.addAttribute("wallethistory", userWalletHistory);
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
        return "wallet-history";

    }

    @RequestMapping(value = "/getWalletHistoryByPartner", method = RequestMethod.GET)
    public String getWalletHistoryByPartner(HttpServletRequest request, int fofoId, @RequestParam(name = "referenceType", required = false) WalletReferenceType referenceType, @RequestParam(name = "offset", required = false, defaultValue = "0") int offset, @RequestParam(name = "limit", required = false, defaultValue = "100") int limit, Model model) throws Exception {

        UserWallet userWallet = userWalletRepository.selectByRetailerId(fofoId);
        List<UserWalletHistory> userWalletHistory = userWalletHistoryRepository.selectPaginatedByWalletIdReferenceType(userWallet.getId(), referenceType, SortOrder.DESCENDING, offset, limit);

        CustomRetailer customretailer = retailerService.getFofoRetailer(fofoId);

        SDCreditRequirement sdCreditRequirement = sdCreditRequirementRepository.selectByFofoId(fofoId);

        List<Loan> loans = null;
        BigDecimal totalDue = BigDecimal.ZERO;
        BigDecimal availableLimit = BigDecimal.ZERO;
        BigDecimal creditlimit = BigDecimal.ZERO;
        if (sdCreditRequirement != null) {
            loans = loanRepository.selectActiveLoan(fofoId);
            availableLimit = sdCreditRequirement.getAvailableLimit();
            creditlimit = sdCreditRequirement.getLimit();
            for (Loan loan : loans) {
                BigDecimal pendingAmount = loan.getPendingAmount();
                BigDecimal interestAccrued = loan.getInterestAccrued();
                BigDecimal interestPaid = loan.getInterestPaid();
                totalDue = totalDue.add(interestAccrued.subtract(interestPaid).add(pendingAmount));
                availableLimit = creditlimit.subtract(totalDue);
            }
        }
        model.addAttribute("userWallet", userWallet);
        model.addAttribute("customretailer", customretailer);
        model.addAttribute("wallethistory", userWalletHistory);
        model.addAttribute("loans", loans);
        model.addAttribute("totalDue", totalDue);
        model.addAttribute("availableLimit", availableLimit);
        model.addAttribute("creditlimit", creditlimit);
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
        return "wallet-history";
    }


    @RequestMapping(value = "/getPartnerName", method = RequestMethod.GET)
    public String getPartnerName(HttpServletRequest request, @RequestParam(name = "reference", defaultValue = "0") int reference, @RequestParam WalletReferenceType referenceType, Model model) throws Exception {

        List<UserWalletHistory> userWalletHistory = userWalletHistoryRepository.selectAllByreferenceIdandreferenceType(reference, referenceType);
        if (userWalletHistory.isEmpty()) {
            throw new ProfitMandiBusinessException("RefrenceId", reference, "Reference Id not found");
        }
        UserWallet userWallet = userWalletRepository.selectById(userWalletHistory.get(0).getWalletId());

        CustomRetailer retailer = retailerService.getFofoRetailer(userWallet.getUserId());

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

        return "response";

    }

    @RequestMapping(value = "/reset-wallet/9990381", method = RequestMethod.GET)
    public String walletUpdate(Model model) throws Exception {
        walletService.resetWallet();
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
        return "response";
    }

    @RequestMapping(value = "/walletUpdate", method = RequestMethod.POST)
    public String walletUpdate(HttpServletRequest request, @RequestParam(name = "reference", defaultValue = "0") int reference, @RequestParam int referenceTypeValue, @RequestParam TransactionType transactiontype, @RequestParam int amount, @RequestParam String description, @RequestParam int retailerId, Model model, @RequestParam LocalDateTime businessTimestamp) throws Exception {
        WalletReferenceType referenceType = WalletReferenceType.findByValue(referenceTypeValue);
        if (reference == 0 && referenceType.getValue() >= WalletReferenceType.INCENTIVES.getValue()) {
            LOGGER.error("referenceType: " + referenceType);
            ManualPaymentType paymentType = manualPaymentRequestRepository.selectByReferenceType(referenceType);

            if (paymentType == null) {
                paymentType = new ManualPaymentType();
                paymentType.setReferenceType(referenceType);
            }
            paymentType.setCounter(paymentType.getCounter() + 1);
            manualPaymentRequestRepository.persist(paymentType);
            reference = paymentType.getCounter();

        } else if (reference == 0) {
            throw new ProfitMandiBusinessException("RefrenceId", reference, "System specific reference type cant be used manually");
        }

        List<UserWalletHistory> userWalletHistoryList = userWalletHistoryRepository.selectAllByreferenceIdandreferenceType(reference, referenceType);
        UserWallet userWallet = userWalletRepository.selectByRetailerId(retailerId);
        int walletId = userWallet.getId();
        int walletAmount = walletService.getWalletAmount(retailerId);

        int returnReference = 0;
        UserWalletHistory newUserWalletHistory = new UserWalletHistory();

        if (!userWalletHistoryList.isEmpty()) {
            long validRetailerEntries = userWalletHistoryList.stream().filter(x -> x.getWalletId() == walletId).count();
            if (validRetailerEntries == 0) {
                throw new ProfitMandiBusinessException("RefrenceId", reference, "Reference Id assign to Other  partner");
            }
        }

        if (TransactionType.DEBIT.equals(transactiontype)) {
            amount = -amount;
        }

        userWallet.setAmount(walletAmount + amount);
        newUserWalletHistory.setAmount(amount);
        newUserWalletHistory.setBusinessTimestamp(businessTimestamp);
        newUserWalletHistory.setDescription(description);
        newUserWalletHistory.setReference(reference);
        newUserWalletHistory.setWalletId(userWallet.getId());
        newUserWalletHistory.setReferenceType(referenceType);
        newUserWalletHistory.setTimestamp(LocalDateTime.now());
        userWalletHistoryRepository.persist(newUserWalletHistory);

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

    }

    @RequestMapping(value = "/addMoney", method = RequestMethod.POST)
    public String addMoney(HttpServletRequest request, @RequestParam float amount, @RequestParam String transactionReference, @RequestParam LocalDateTime referenceTime, @RequestParam String bankName, @RequestParam int fofoId, Model model) throws Exception {

        AddWalletRequest addWalletRequest = new AddWalletRequest();
        addWalletRequest.setRetailerId(fofoId);
        addWalletRequest.setAmount(amount);
        addWalletRequest.setTransaction_reference(transactionReference);
        addWalletRequest.setCreateTimestamp(LocalDateTime.now());
        addWalletRequest.setBank_name(bankName);
        addWalletRequest.setReference_date(referenceTime.toLocalDate());
        addWalletRequest.setStatus(AddWalletRequestStatus.pending);

        LOGGER.info("info" + addWalletRequest);

        addWalletRequestRepository.persist(addWalletRequest);
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
        return "response";
    }

    @RequestMapping(value = "/getCreditDetail", method = RequestMethod.GET)
    public String getCreditDetail(HttpServletRequest request, Model model) throws Exception {
        List<CreditAccount> creditAccounts = creditAccountRepository.selectAll().stream().filter(x->x.getGateway().equals(Gateway.SDDIRECT)).collect(Collectors.toList());
        Map<Integer, CustomRetailer> customRetailers = retailerService.getAllFofoRetailers();

        Map<Integer, FofoStore> fofoStoreMap = fofoStoreRepository.selectByRetailerIds(new ArrayList<>(customRetailers.keySet())).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));

        model.addAttribute("creditAccounts", creditAccounts);
        model.addAttribute("fofoStoreMap", fofoStoreMap);
        model.addAttribute("customRetailers", customRetailers);
        return "partner-credit-detail";
    }

    @RequestMapping(value = "/activateKred", method = RequestMethod.POST)
    public String activateKred(HttpServletRequest request, @RequestParam int id, Model model) throws Exception {
        CreditAccount creditAccount = creditAccountRepository.selectById(id);

        creditAccount.setActive(true);

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

        String title = "Loan Approved";
        String url = "http://app.smartdukaan.com/pages/home/credit";
        String message = "Congratulations! Your Credit Limit is approved for Rs." + FormattingUtils.formatDecimal(creditAccount.getSanctionedAmount());
        notificationService.sendNotification(creditAccount.getFofoId(), "Loan", MessageType.notification, title, message, url);

        model.addAttribute("creditAccount", creditAccount);
        model.addAttribute("customRetailers", customRetailers);
        return "partner-credit-detail-row";
    }

    @RequestMapping(value = "/deactivateKred", method = RequestMethod.POST)
    public String deactivateKred(HttpServletRequest request, @RequestParam int id, Model model) throws Exception {
        CreditAccount creditAccount = creditAccountRepository.selectById(id);

        creditAccount.setActive(false);

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

        model.addAttribute("creditAccount", creditAccount);
        model.addAttribute("customRetailers", customRetailers);
        return "partner-credit-detail-row";
    }

}