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.LocalDateTime;

import java.time.format.DateTimeFormatter;

import java.util.*;

import java.util.stream.Collectors;

import javax.mail.internet.InternetAddress;

import javax.mail.internet.MimeMessage;

import javax.servlet.http.HttpServletRequest;

import org.apache.commons.io.FileUtils;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.json.JSONObject;

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

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

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.service.user.StoreStatusService;

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.CustomOrderItem;

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

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

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

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.web.util.ResponseSender;

import com.spice.profitmandi.dao.entity.catalog.RangeItem;

import com.spice.profitmandi.dao.entity.catalog.RangeItemPrice;

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.entity.inventory.State;

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

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

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

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

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

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.dao.repository.inventory.StateRepository;

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

import com.spice.profitmandi.service.order.InsuranceInvoiceLine;

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

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

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

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

@Controller

@Transactional(rollbackFor = Throwable.class)

public class InsuranceController {

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

	private static final String gadgetCopsFilePath = "/GadgetCops";

	@Autowired

	private StateRepository stateRepository;

	@Autowired

	private RangeItemPriceRepository rangeItemPriceRepository;

	@Autowired

	private RangeItemRepository rangeItemRepository;

	// This is now unused as we are not supporting multiple companies.

	@Value("${fofo.warehouseIds}")

	private int[] warehouseIds;

	@Autowired

	OtpProcessor otpProcessor;

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

	public ResponseEntity<?> getById(HttpServletRequest request) {

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

		Map<Integer, List<RangeItemPrice>> rangeItemPrices = rangeItemPriceRepository.selectAll().stream()

				.collect(Collectors.groupingBy(RangeItemPrice::getRangeItemId, Collectors.toList()));

		List<RangeItem> rangeItems = rangeItemRepository.selectAll();

		rangeItems.stream().forEach(x -> x.setRangeItemPrices(rangeItemPrices.get(x.getId())));

		return responseSender.ok(rangeItems);

	}

	@Autowired

	ResponseSender<?> responseSender;

	@Autowired

	ThirdPartyInvoiceSequenceRepository thirdPartyInvoiceSequenceRepository;

	@Autowired

	DocumentRepository documentRepository;

	@Autowired

	InvoiceNumberGenerationSequenceRepository invoiceNumberGenerationSequenceRepository;

	@Autowired

	InsurancePolicyRepository insurancePolicyRepository;

	@Autowired

	PricingService pricingService;

	@Autowired

	JavaMailSender gmailRelaySender;

	@Autowired

	InsuranceProviderRepository insuranceProviderRepository;

	@Autowired

	UserAccountRepository userAccountRepository;

	@Autowired

	WalletService walletService;

	@Autowired

	private StoreStatusService storeStatusService;

	@Autowired

	UserWalletRepository userWalletRepositoy;

	@Autowired

	PolicyNumberGenerationSequenceRepository policyNumberGenerationSequenceRepository;

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

	public ResponseEntity<?> createDamageProtection(HttpServletRequest request,

			@RequestBody GadgetCopsDocumentInsuranceModel insuranceModel) throws Throwable {

		insuranceModel

				.setCustomerDateOfBirth(StringUtils.fromHypendatedDate(insuranceModel.getCustomerDateOfBirthString()));

		insuranceModel.setInvoiceCreationDate(LocalDate.now());

		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);

		insuranceModel.setPolicyNumber(insurancePolicy.getPolicyNumber());

		String walletDescription = "Purchased Damage Protection policy " + insurancePolicy.getPolicyNumber() + " for "

				+ insurancePolicy.getCustomerFirstName();

		storeStatusService.assertCanSpendWallet(uc.getUserId());

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

				WalletReferenceType.DAMAGE_PROTECTION, walletDescription, insurancePolicy.getSaleAmount(),

				LocalDateTime.now());

		try {

			InsuranceUtils.submitToGadgetCops(insuranceModel);

			insurancePolicy.setPosted(true);

		} catch (ProfitMandiBusinessException profitMandiBusinessException) {

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

					profitMandiBusinessException);

			throw new ProfitMandiBusinessException("", "", "GDTCPSServerDown_1000");

		}

		insurancePolicyRepository.persist(insurancePolicy);

		InvoicePdfModel pdfModel = this.getInvoicePdfModel(insurancePolicy);

		ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();

		PdfUtils.generateAndWrite(Arrays.asList(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());

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

				deviceImg, deviceInvoiceImg);

		String messageText = MessageFormat.format(

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

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

		// TODO: add template if needed

		otpProcessor.sendSms("", messageText, insurancePolicy.getCustomerMobileNumber());

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

		String subject = "Your Gadget Cop damage Protection purchase is successful";

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

		float taxableInsuranceMargin = (insurancePolicy.getSaleAmount() - insurancePolicy.getPurchaseAmount())

				/ (1 + ProfitMandiConstants.INSURANCE_TAX_RATE / 100);

		walletService.addAmountToWallet(uc.getUserId(), insurancePolicy.getId(), WalletReferenceType.CASHBACK,

				"Cashback against insurance policy", taxableInsuranceMargin, LocalDateTime.now());

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

		JSONObject jsonObject = new JSONObject();

		jsonObject.put("policyNumber", insurancePolicy.getPolicyNumber());

		jsonObject.put("premiumCharged", insurancePolicy.getSaleAmount());

		return responseSender.ok(jsonObject.toString());

	}

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

			throws Exception {

		MimeMessage message = gmailRelaySender.createMimeMessage();

		MimeMessageHelper helper = new MimeMessageHelper(message, true);

		helper.setSubject(subject);

		helper.setText(body);

		String[] cc = { "backup@shop2020.in", "gadgetcops.01@gmail.com" };

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

		helper.setCc(cc);

		helper.setTo(email);

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

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

		helper.setFrom(senderAddress);

		for (File file : attachments) {

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

		}

		gmailRelaySender.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);

			pdfInvoiceStream.flush();

		} 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(LocalDateTime localDate) {

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

		return localDate.format(formatter);

	}

	/**

	 * GST state code for a state name, or null when the name is blank or unknown to us — the

	 * renderer simply omits the line rather than failing the policy purchase.

	 */

	private String stateCode(String stateName) {

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

			return null;

		}

		State state = stateRepository.selectByName(stateName);

		return state != null ? state.getCode() : null;

	}

	private InvoicePdfModel getInvoicePdfModel(InsurancePolicy insurancePolicy) throws ProfitMandiBusinessException {

		InvoicePdfModel pdfModel = new InvoicePdfModel();

		pdfModel.setAuther("profitmandi");

		pdfModel.setTitle("Retailer Invoice");

		pdfModel.setInvoiceDate(getFormattedDate(insurancePolicy.getCreateTimestamp()));

		// insurance calculation

		pdfModel.setInsurancePolicies(Arrays.asList(InsuranceInvoiceLine.from(insurancePolicy)));

		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));

		// 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());

		// customRetailer.setAddress(address);

		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());

		customRetailer.setAddress(providerAddress);

		pdfModel.setRetailer(customRetailer);

		// Place of supply: needed on the face of the invoice whenever the buyer is registered, and

		// it is what decides the CGST+SGST vs IGST split on the policy line.

		pdfModel.setPartnerAddressStateCode(stateCode(providerAddress.getState()));

		pdfModel.setCustomerAddressStateCode(stateCode(customAddress.getState()));

		List<CustomOrderItem> customerFofoOrderItems = new ArrayList<>();

		pdfModel.setOrderItems(customerFofoOrderItems);

		pdfModel.setTncs(Arrays.asList("Please check out Policy Schedule for detailed terms and conditions."));

		return pdfModel;

	}

}