Subversion Repositories SmartDukaan

import com.spice.profitmandi.common.services.mandii.*;

    MandiiService mandiiService;

    @Autowired

    public void mandiiUser(String firstName, String lastName, String pan, String dob, String aadhaar, String gender,

                           String father) throws Exception {

        FofoStore fs = fofoStoreRepository.selectByPan(pan);

        CustomRetailer cr = retailerService.getFofoRetailer(fs.getId());

        com.spice.profitmandi.dao.entity.dtr.User dtrUser = dtrUserRepository.selectByEmailId(cr.getEmail());

        MandiiUser mandiiUser = mandiiService.getUser(dtrUser.getFirstName(), dtrUser.getLastName(), father,

                Gender.valueOf(gender), cr.getEmail(), pan, cr.getMobileNumber(), LocalDate.parse(dob),

                cr.getAddress().getLine1() + " " + cr.getAddress().getLine2(), cr.getAddress().getCity(),

                cr.getAddress().getState(), cr.getAddress().getPinCode());

        mandiiUser.setFatherName(father);

        if (StringUtils.isNotEmpty(firstName)) {

            mandiiUser.setFirstName(firstName);

            mandiiUser.setLastName(lastName);

        }

        if (StringUtils.isNotEmpty(father)) {

            mandiiUser.setFatherName(father);

        }

        if (StringUtils.isNotEmpty(aadhaar)) {

            mandiiUser.setAadharNumber(aadhaar);

        }

        mandiiUser.setGender(Gender.valueOf(gender));

        mandiiService.createAccount(cr.getBusinessName(), mandiiUser);

    }

    @Autowired

    CreditAccountRepository creditAccountRepository;

    public void mandiiUsers() throws Exception {

        List<CreditAccount> creditAccounts = creditAccountRepository.selectAll();

        List<Integer> fofoIds = creditAccounts.stream().filter(x -> x.getGateway().equals(Gateway.MANDII) && (x.getCreditStatus().equals(CreditStatus.UNKNOWN) || x.getCreditStatus().equals(CreditStatus.TO_BE_EVALUATED))).map(x -> x.getFofoId()).collect(Collectors.toList());

        List<FofoStore> fsList = fofoStoreRepository.selectByRetailerIds(fofoIds);

        for (FofoStore store : fsList) {

            this.mandiiUsers(store.getPan());

        }

    }

    public void mandiiUsers(String pan) throws Exception {

        FofoStore fs = fofoStoreRepository.selectByPan(pan);

        PartnerOnBoardingPanel pob = partnerOnBoardingPanelRepository.selectByCode(fs.getCode());

        List<FofoKyc> fofoKycs = fofoKycRepository.selectByPartnerOnBoardingId(pob.getId());

        CustomRetailer cr = retailerService.getFofoRetailer(fs.getId());

        com.spice.profitmandi.dao.entity.dtr.User dtrUser = dtrUserRepository.selectByEmailId(cr.getEmail());

        boolean ca = false;

        for (FofoKyc fk : fofoKycs) {

            MandiiUser mandiiUser = mandiiService.getUser(fk.getFirstName(), fk.getLastName(), fk.getFatherName(),

                    fk.getGender(), fk.getEmail(), pan, fk.getMobile(), fk.getDob(),

                    fk.getAddress1() + " " + fk.getAddress2() + " " + fk.getAddress3(), fk.getCity(), fk.getState(),

                    fk.getPincode());

            LOGGER.info("mandiiUser" + mandiiUser);

            ca = mandiiService.createAccount(cr.getBusinessName(), mandiiUser);

            Document panDoc = documentRepository.selectById(fk.getPanDoc());

            File fPan = new File(panDoc.getPath() + panDoc.getName());

            String encodeString = encodeFileToBase64Binary(fPan);

            mandiiService.documentUpload(pan, fk.getMobile(), "PROPRIETOR_PAN", encodeString, null);

            Document adhaarF = documentRepository.selectById(fk.getPoaFront());

            File adharf = new File(adhaarF.getPath() + adhaarF.getName());

            String adhaarFEncodstring = encodeFileToBase64Binary(adharf);

            mandiiService.documentUpload(pan, fk.getMobile(), "AADHAAR", adhaarFEncodstring, "FRONT");

            Document adhaarB = documentRepository.selectById(fk.getPoaBack());

            File adharb = new File(adhaarB.getPath() + adhaarF.getName());

            String adhaarBEncodstring = encodeFileToBase64Binary(adharb);

            mandiiService.documentUpload(pan, fk.getMobile(), "AADHAAR", adhaarBEncodstring, "BACK");

            if (ca == true) {

                AccountStatusResponseOut accountStatusResponseOut = mandiiService.getStatus(fs.getPan());

                this.setCreditAccount(fs.getId(), accountStatusResponseOut);

            }

        }

    }

    private void setCreditAccount(int fofoId, AccountStatusResponseOut accountStatusResponseOut) {

        CreditAccount creditAccount = creditAccountRepository.selectByFofoIdAndGateway(fofoId, Gateway.MANDII);

        if (creditAccount == null) {

            creditAccount = new CreditAccount();

            creditAccount.setFofoId(fofoId);

            creditAccount.setGateway(Gateway.MANDII);

        }

        if (accountStatusResponseOut == null) {

            creditAccount.setCreditStatus(CreditStatus.UNKNOWN);

            creditAccount.setDescription("User company not found");

        } else {

            if (accountStatusResponseOut.getSanctionLimit() != null) {

                creditAccount.setSanctionedAmount(accountStatusResponseOut.getSanctionLimit().floatValue());

            } else {

                creditAccount.setSanctionedAmount(0);

            }

            creditAccount.setInterestRate(accountStatusResponseOut.getRateOfInterest());

            if (accountStatusResponseOut.getBalanceAmount() != null) {

                creditAccount.setAvailableAmount(accountStatusResponseOut.getBalanceAmount().floatValue());

            } else {

                creditAccount.setAvailableAmount(0);

            }

            if (accountStatusResponseOut.getCurrentStage() != null) {

                creditAccount.setDescription(accountStatusResponseOut.getCurrentStage().toString());

            }

            if (accountStatusResponseOut.getStatus().equals(EligibilityStatusEnum.SANCTION_AVAILABLE)) {

                creditAccount.setCreditStatus(CreditStatus.SANCTIONED);

            } else if (accountStatusResponseOut.getStatus().equals(EligibilityStatusEnum.IN_ELIGIBLE)) {

                creditAccount.setCreditStatus(CreditStatus.INELIGIBLE);

            } else {

                creditAccount.setCreditStatus(CreditStatus.TO_BE_EVALUATED);

            }

        }

        creditAccount.setUpdatedOn(LocalDateTime.now());

        creditAccountRepository.persist(creditAccount);

    }

    private static String encodeFileToBase64Binary(File file) throws Exception {

        FileInputStream fileInputStreamReader = new FileInputStream(file);

        byte[] bytes = new byte[(int) file.length()];

        fileInputStreamReader.read(bytes);

        return new String(Base64.getEncoder().encodeToString(bytes));

    }