WebSVN – SmartDukaan – Diff – /trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/InsuranceController.java

 import java.io.OutputStream;
 import java.text.MessageFormat;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
-import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 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.GadgetCopsInsuranceCalcResponse;
-import com.spice.profitmandi.common.model.PdfModel;
+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;
 	private static final Logger LOGGER = LogManager.getLogger(InsuranceController.class);
 	private static final String gadgetCopsFilePath = "/GadgetCops";
 	@Autowired
 	private RangeItemPriceRepository rangeItemPriceRepository;
 	@Autowired
 	private RangeItemRepository rangeItemRepository;
-	//This is now unused as we are not supporting multiple companies.
+	// This is now unused as we are not supporting multiple companies.
 	@Value("${fofo.warehouseIds}")
 	private int[] warehouseIds;
+	@Autowired
-	@Autowired OtpProcessor otpProcessor;
+	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()));
+		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())));
+		rangeItems.stream().forEach(x -> x.setRangeItemPrices(rangeItemPrices.get(x.getId())));
 		return responseSender.ok(rangeItems);
+	}
 	@Autowired
 	ResponseSender<?> responseSender;
 	@Autowired
 	GadgetCopsInsuranceCalcRepository gadgetCopsInsuranceCalcRepository;
 	@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
 	UserWalletRepository userWalletRepositoy;
 	PolicyNumberGenerationSequenceRepository policyNumberGenerationSequenceRepository;
 	@RequestMapping(value = ProfitMandiConstants.URL_DAMAGE_INSURANCE, method = RequestMethod.POST)
 	public ResponseEntity<?> createDamageProtection(HttpServletRequest request,
 			@RequestBody GadgetCopsDocumentInsuranceModel insuranceModel) throws Throwable {
+		insuranceModel
-		insuranceModel.setCustomerDateOfBirth(StringUtils.fromHypendatedDate(insuranceModel.getCustomerDateOfBirthString()));
+				.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;
 		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()
+		String walletDescription = "Purchased Damage Protection policy " + insurancePolicy.getPolicyNumber() + " for "
-			+ " for " + insurancePolicy.getCustomerFirstName();
+				+ insurancePolicy.getCustomerFirstName();
 		walletService.consumeAmountFromWallet(uc.getUserId(), insurancePolicy.getId(),
-				WalletReferenceType.DAMAGE_PROTECTION, walletDescription, insurancePolicy.getSaleAmount(), LocalDateTime.now());
+				WalletReferenceType.DAMAGE_PROTECTION, walletDescription, insurancePolicy.getSaleAmount(),
+				LocalDateTime.now());
-		try{
+		try {
 			InsuranceUtils.submitToGadgetCops(insuranceModel);
 			insurancePolicy.setPosted(true);
-		}catch (ProfitMandiBusinessException profitMandiBusinessException) {
+		} catch (ProfitMandiBusinessException profitMandiBusinessException) {
-			LOGGER.info("Unable to submit insurance policy details to {}", insuranceProvider.getName(), profitMandiBusinessException);
+			LOGGER.info("Unable to submit insurance policy details to {}", insuranceProvider.getName(),
+					profitMandiBusinessException);
 			throw new ProfitMandiBusinessException("", "", "GDTCPSServerDown_1000");
+		}
 		insurancePolicyRepository.persist(insurancePolicy);
-		PdfModel pdfModel = this.getInvoicePdfModel(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);
+		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
+		// 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);
+		this.sendMailWithAttachments(insuranceModel.getCustomerEmailId(), subject, messageText, attachments);
-		float taxableInsuranceMargin = (insurancePolicy.getSaleAmount() - insurancePolicy.getPurchaseAmount()) / (1 + ProfitMandiConstants.INSURANCE_TAX_RATE / 100);
+		float taxableInsuranceMargin = (insurancePolicy.getSaleAmount() - insurancePolicy.getPurchaseAmount())
+				/ (1 + ProfitMandiConstants.INSURANCE_TAX_RATE / 100);
-		walletService.addAmountToWallet(uc.getUserId(), insurancePolicy.getId(), WalletReferenceType.CASHBACK, "Cashback against insurance policy",
+		walletService.addAmountToWallet(uc.getUserId(), insurancePolicy.getId(), WalletReferenceType.CASHBACK,
-				taxableInsuranceMargin, LocalDateTime.now());
+				"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 {
+	private void sendMailWithAttachments(String email, String subject, String body, List<File> attachments)
+			throws Exception {
-    	MimeMessage message = mailSender.createMimeMessage();
+		MimeMessage message = mailSender.createMimeMessage();
-    	MimeMessageHelper helper = new MimeMessageHelper(message,true);
+		MimeMessageHelper helper = new MimeMessageHelper(message, true);
-    	helper.setSubject(subject);
+		helper.setSubject(subject);
-    	helper.setText(body);
+		helper.setText(body);
-    	String[] cc = {"backup@shop2020.in", "gadgetcops.01@gmail.com"};
+		String[] cc = { "backup@shop2020.in", "gadgetcops.01@gmail.com" };
-    	//String[] cc = {"amit.gupta@shop2020.in"};
+		// String[] cc = {"amit.gupta@shop2020.in"};
-    	helper.setCc(cc);
+		helper.setCc(cc);
-    	helper.setTo(email);
+		helper.setTo(email);
-    	InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "ProfitMandi Admin");
+		InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "ProfitMandi Admin");
-    	helper.setTo("help@smartdukaan.com");
+		helper.setTo("help@smartdukaan.com");
-    	helper.setFrom(senderAddress);
+		helper.setFrom(senderAddress);
-    	for (File file : attachments) {
+		for (File file : attachments) {
-    		helper.addAttachment(file.getName(), file);
+			helper.addAttachment(file.getName(), file);
-    	}
+		}
-    	mailSender.send(message);
+		mailSender.send(message);
+	}
 	private List<File> savePolicyDocs(String policyNumber, ByteArrayOutputStream pdfInvoiceStream, File deviceImg,
 			File deviceInvoiceImg) throws Exception {
 		// save file to gadgetCops/policyname
 			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);
+	}
-	private PdfModel getInvoicePdfModel(InsurancePolicy insurancePolicy) throws ProfitMandiBusinessException {
+	private InvoicePdfModel getInvoicePdfModel(InsurancePolicy insurancePolicy) throws ProfitMandiBusinessException {
-		PdfModel pdfModel = new PdfModel();
+		InvoicePdfModel pdfModel = new InvoicePdfModel();
 		pdfModel.setAuther("profitmandi");
 		pdfModel.setTitle("Retailer Invoice");
 		pdfModel.setInvoiceDate(getFormattedDate(insurancePolicy.getCreateTimestamp()));
 		// insurance calculation
 		// Gadget cop mobile
 		CustomRetailer customRetailer = new CustomRetailer();
 		customRetailer.setBusinessName(damageProtectionProvider.getName());
 		customRetailer.setMobileNumber(damageProtectionProvider.getMobileNumber());
 		customRetailer.setGstNumber(damageProtectionProvider.getGstNumber());
-		//customRetailer.setAddress(address);
+		// 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);
 		Set<CustomOrderItem> customerFofoOrderItems = new HashSet<>();
 		pdfModel.setOrderItems(customerFofoOrderItems);

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/InsuranceController.java – Rev 29597 → 30330