Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import java.io.ByteArrayOutputStream;

import java.io.File;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.OutputStream;

import java.text.MessageFormat;

import java.time.LocalDate;

import java.time.format.DateTimeFormatter;

import java.util.Arrays;

import java.util.HashSet;

import java.util.List;

import java.util.Map;

import java.util.Set;

import javax.mail.internet.InternetAddress;

import javax.mail.internet.MimeMessage;

import javax.servlet.http.HttpServletRequest;

import org.apache.commons.io.FileUtils;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

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

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.transaction.annotation.Transactional;

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

import com.spice.profitmandi.service.pricing.PricingService;

import com.spice.profitmandi.service.wallet.WalletService;

import in.shop2020.model.v1.order.WalletReferenceType;

@Controller

@Transactional(rollbackFor = Throwable.class)

public class InsuranceController {

	private static final Logger LOGGER = LoggerFactory.getLogger(InsuranceController.class);

	private static final String gadgetCopsFilePath = "/GadgetCops";

	@Autowired

	private GadgetCopsInsuranceCalcRepository gadgetCopsInsuranceCalcRepository;

	@RequestMapping(value = ProfitMandiConstants.URL_INSURANCE_GADGET_COPS_MAPPING, method = RequestMethod.GET)

	public ResponseEntity<?> getById(HttpServletRequest request) {

		LOGGER.info("requested url : " + request.getRequestURL().toString());

		return responseSender.ok(gadgetCopsInsuranceCalcRepository.selectAll());

	}

	@Autowired

	ResponseSender<?> responseSender;

	@Autowired

	ThirdPartyInvoiceSequenceRepository thirdPartyInvoiceSequenceRepository;

	@Autowired

	DocumentRepository documentRepository;

	@Autowired

	InvoiceNumberGenerationSequenceRepository invoiceNumberGenerationSequenceRepository;

	@Autowired

	InsurancePolicyRepository insurancePolicyRepository;

	@Autowired

	PricingService pricingService;

	@Autowired

	JavaMailSender mailSender;

	@Autowired

	InsuranceProviderRepository insuranceProviderRepository;

	@Autowired

	UserAccountRepository userAccountRepository;

	@Autowired

	WalletService walletService;

	@Autowired

	PolicyNumberGenerationSequenceRepository policyNumberGenerationSequenceRepository;

	@Autowired

	@RequestMapping(value = ProfitMandiConstants.URL_DAMAGE_INSURANCE, method = RequestMethod.POST)

	public ResponseEntity<?> createTheftProtection(HttpServletRequest request,

			@RequestBody GadgetCopsDocumentInsuranceModel insuranceModel) throws Throwable {

		if (insuranceModel.validate()) {

			int userId = (int) request.getAttribute("userId");

			UserCart uc = userAccountRepository.getUserCart(userId);

			PolicyNumberGenerationSequence policyNumberGenerationSequence = null;

			try {

				policyNumberGenerationSequence = policyNumberGenerationSequenceRepository.select();

				policyNumberGenerationSequence.setSequence(policyNumberGenerationSequence.getSequence() + 1);

				policyNumberGenerationSequenceRepository.persist(policyNumberGenerationSequence);

			} catch (ProfitMandiBusinessException profitMandiBusinessException) {

				policyNumberGenerationSequence = new PolicyNumberGenerationSequence();

				policyNumberGenerationSequence.setSequence(1);

				policyNumberGenerationSequenceRepository.persist(policyNumberGenerationSequence);

			}

			String policyNumber = StringUtils.generatePolicyNumber(ProfitMandiConstants.POLICY_NUMBER_PREFIX,

					policyNumberGenerationSequence.getSequence());

			InsuranceProvider insuranceProvider = insuranceProviderRepository

					.selectByName(ProfitMandiConstants.GADGET_COPS);

			Set<Float> devicePriceSet = new HashSet<>();

			devicePriceSet.add(insuranceModel.getPrice());

			Map<Float, GadgetCopsInsuranceCalc> insurancePricesMap = pricingService.getInsurancePrices(devicePriceSet,

					ProfitMandiConstants.GADGET_COPS);

			InsurancePolicy insurancePolicy = new InsurancePolicy();

			insurancePolicy.setInvoiceNumber(insuranceModel.getInvoiceNumber());

			insurancePolicy.setRetailerId(uc.getUserId());

			insurancePolicy.setPurchaseAmount(insurancePricesMap.get(insuranceModel.getPrice()).getDealerPrice());

			insurancePolicy.setSaleAmount(insurancePricesMap.get(insuranceModel.getPrice()).getSellingPrice());

			insurancePolicy.setSellingPrice(insuranceModel.getPrice());

			insurancePolicy.setSerialNumber(insuranceModel.getSerialNumber());

			insurancePolicy.setModelName(insuranceModel.getModelName());

			insurancePolicy.setBrand(insuranceModel.getBrand());

			insurancePolicy.setPolicyNumber(policyNumber);

			insurancePolicy.setProviderId(insuranceProvider.getId());

			insurancePolicy.setCustomerFirstName(insuranceModel.getCustomerFirstName());

			insurancePolicy.setCustomerLastName(insuranceModel.getCustomerFirstName());

			insurancePolicy.setCustomerMobileNumber(insuranceModel.getCustomerMobileNumber());

			insurancePolicy.setCustomerEmailId(insuranceModel.getCustomerEmailId());

			insurancePolicy.setCustomerDateOfBirth(insuranceModel.getCustomerDateOfBirth());

			insurancePolicy.setCustomerAddress1(insuranceModel.getCustomerAddress1());

			insurancePolicy.setCustomerAddress2(insuranceModel.getCustomerAddress2());

			insurancePolicy.setCustomerCity(insuranceModel.getCustomerCity());

			insurancePolicy.setCustomerPinCode(insuranceModel.getCustomerPinCode());

			insurancePolicy.setCustomerState(insuranceModel.getCustomerState());

			insurancePolicyRepository.persist(insurancePolicy);

			try{

				InsuranceUtils.submitToGadgetCops(insuranceModel);

				insurancePolicy.setPosted(true);

			}catch (ProfitMandiBusinessException profitMandiBusinessException) {

				LOGGER.info("Unable to submit insurance policy details to {}", insuranceProvider.getName(), profitMandiBusinessException);

			}

			insurancePolicyRepository.persist(insurancePolicy);			

			walletService.consumeAmountFromWallet(uc.getUserId(), insurancePolicy.getId(), WalletReferenceType.DAMAGE_PROTECTION, 

					"Purchased Damage Protection policy for " + insurancePolicy.getCustomerFirstName() , insurancePolicy.getSaleAmount());

			PdfModel pdfModel = this.getInvoicePdfModel(insurancePolicy);

			ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();

			PdfUtils.generateAndWrite(pdfModel, byteArrayOutputStream);

			Document deviceDocument = documentRepository.selectById(insuranceModel.getDeviceImageDocumentId());

			File deviceImg = new File(deviceDocument.getPath() + deviceDocument.getName());

			Document invoiceDocument = documentRepository.selectById(insuranceModel.getDeviceImageDocumentId());

			File deviceInvoiceImg = new File(invoiceDocument.getPath() + invoiceDocument.getName());

			String messageText = MessageFormat.format(

					"Dear {0}, Thank you for purchasing Damage Protection Plan. Your Policy number is {1}",

					insurancePolicy.getCustomerFirstName(), insurancePolicy.getPolicyNumber());

			Utils.sendSms(messageText, insurancePolicy.getCustomerMobileNumber());

			List<File> attachments = this.savePolicyDocs(insurancePolicy.getPolicyNumber(), byteArrayOutputStream, deviceImg, deviceInvoiceImg);

			messageText += "\n Please find your Invoice, and documents submitted by you.";

			String subject = "Your Gadget Cop damage Protection";

			this.sendMailWithAttachments(insuranceModel.getCustomerEmailId() , subject, messageText, attachments);

		}

		LOGGER.info("requested url : " + request.getRequestURL().toString());

		return responseSender.ok(true);

	}

	private void sendMailWithAttachments(String email, String subject, String body, List<File> attachments) throws Exception {

    	MimeMessage message = mailSender.createMimeMessage();

    	MimeMessageHelper helper = new MimeMessageHelper(message);

    	helper.setSubject("New Contact Us message");

    	helper.setText(body);

    	String[] cc = {"amit.gupta@shop2020.in"};

    	//String[] cc = {"amit.gupta@shop2020.in"};

    	helper.setCc(cc);

    	InternetAddress senderAddress = new InternetAddress("noreply@profitmandi.com", "ProfitMandi Admin");

    	helper.setTo("help@profitmandi.com");

    	helper.setFrom(senderAddress);

    	for (File file : attachments) {

    		helper.addAttachment(file.getName(), file);

    	}

    	mailSender.send(message);

	}

	private List<File> savePolicyDocs(String policyNumber, ByteArrayOutputStream pdfInvoiceStream, File deviceImg,

			File deviceInvoiceImg) throws Exception {

		// save file to gadgetCops/policyname

		String policyFolderPath = gadgetCopsFilePath + File.separator + policyNumber;

		File destDeviceInvoiceImg = new File(policyFolderPath + File.separator + "deviceInvoice.jpg");

		File destDeviceImg = new File(policyFolderPath + File.separator + "device.jpg");

		FileUtils.copyFile(deviceImg, destDeviceImg);

		FileUtils.copyFile(deviceInvoiceImg, destDeviceInvoiceImg);

		OutputStream outStream = null;

		try {

			outStream = new FileOutputStream(policyFolderPath + File.separator + "invoice.pdf");

			pdfInvoiceStream.writeTo(outStream);

		} catch (IOException e) {

			e.printStackTrace();

		} finally {

			outStream.close();

			pdfInvoiceStream.close();

		}

		File pdfInvoice = new File(policyFolderPath + File.separator + "invoice.pdf");

		return Arrays.asList(pdfInvoice, destDeviceImg, destDeviceInvoiceImg);

	}

	public String getFormattedDate(LocalDate localDate) {

		DateTimeFormatter formatter = DateTimeFormatter.ofPattern("dd-MM-YYYY HH:mm");

		return localDate.format(formatter);

	}

	private PdfModel getInvoicePdfModel(InsurancePolicy insurancePolicy) throws ProfitMandiBusinessException {

		PdfModel pdfModel = new PdfModel();

		pdfModel.setAuther("profitmandi");

		pdfModel.setTitle("Retailer Invoice");

		pdfModel.setInvoiceDate(getFormattedDate(LocalDate.now()));

		// insurance calculation

		Set<CustomInsurancePolicy> customInsurancePolicies = new HashSet<>();

		final float totalInsuranceTaxRate = 18;

		float taxableInsurancePrice = insurancePolicy.getSaleAmount() / (1 + totalInsuranceTaxRate / 100);

		CustomInsurancePolicy customInsurancePolicy = new CustomInsurancePolicy();

		customInsurancePolicy.setDescription("Damage Protection Plan for device IMEI #"

				+ insurancePolicy.getSerialNumber() + "\n Certificate No. " + insurancePolicy.getPolicyNumber());

		customInsurancePolicy.setHsnCode("998716");

		customInsurancePolicy.setRate(taxableInsurancePrice);

		customInsurancePolicy.setIgstRate(18);

		customInsurancePolicy.setIgstAmount(taxableInsurancePrice * 18 / 100);

		customInsurancePolicy.setCgstRate(9);

		customInsurancePolicy.setCgstAmount(taxableInsurancePrice * 9 / 100);

		customInsurancePolicy.setSgstRate(9);

		customInsurancePolicy.setSgstAmount(taxableInsurancePrice * 9 / 100);

		customInsurancePolicy.setNetAmount(insurancePolicy.getSaleAmount());

		customInsurancePolicies.add(customInsurancePolicy);

		pdfModel.setInsurancePolicies(customInsurancePolicies);

		CustomCustomer customCustomer = new CustomCustomer();

		customCustomer.setFirstName(insurancePolicy.getCustomerFirstName());

		customCustomer.setLastName(insurancePolicy.getCustomerLastName());

		customCustomer.setEmailId(insurancePolicy.getCustomerEmailId());

		customCustomer.setMobileNumber(insurancePolicy.getCustomerMobileNumber());

		CustomAddress customAddress = new CustomAddress();

		customAddress.setName(insurancePolicy.getCustomerFirstName() + " " + insurancePolicy.getCustomerLastName());

		customAddress.setLine1(insurancePolicy.getCustomerAddress1());

		customAddress.setLine2(insurancePolicy.getCustomerAddress2());

		customAddress.setLandmark("");

		customAddress.setCity(insurancePolicy.getCustomerCity());

		customAddress.setPinCode(insurancePolicy.getCustomerPinCode());

		customAddress.setState(insurancePolicy.getCustomerState());

		customAddress.setPhoneNumber(insurancePolicy.getCustomerMobileNumber());

		customCustomer.setAddress(customAddress);

		pdfModel.setCustomer(customCustomer);

		// TODO get invoice number for damageProtection provider

		pdfModel.setInvoiceNumber(thirdPartyInvoiceSequenceRepository.getNextSequence(ThirdParty.GADGET_COP));

		pdfModel.setTotalAmount(gadgetCopsInsuranceCalcRepository.selectByPrice(insurancePolicy.getSellingPrice()));

		// Here bill is generated on behalf of GadgetCop

		ThirdPartyInvoiceSequence damageProtectionProvider = thirdPartyInvoiceSequenceRepository

				.selectByThirdParty(ThirdParty.GADGET_COP);

		// Gadget Cop

		// Gadget cop mobile

		CustomRetailer customRetailer = new CustomRetailer();

		customRetailer.setBusinessName(damageProtectionProvider.getName());

		customRetailer.setMobileNumber(damageProtectionProvider.getMobileNumber());

		customRetailer.setGstNumber(damageProtectionProvider.getGstNumber());

		CustomAddress providerAddress = new CustomAddress();

		providerAddress.setCity(damageProtectionProvider.getCity());

		providerAddress.setLine1(damageProtectionProvider.getLine1());

		providerAddress.setLine2(damageProtectionProvider.getLine2());

		providerAddress.setPinCode(damageProtectionProvider.getPin());

		providerAddress.setPhoneNumber(damageProtectionProvider.getMobileNumber());

		providerAddress.setState(damageProtectionProvider.getState());

		pdfModel.setRetailer(customRetailer);

		Set<CustomOrderItem> customerFofoOrderItems = new HashSet<>();

		pdfModel.setOrderItems(customerFofoOrderItems);

		return pdfModel;

	}

}