Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import java.io.File;

import java.io.IOException;

import java.io.InputStreamReader;

import java.sql.SQLClientInfoException;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.List;

import java.util.stream.Collectors;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import org.apache.commons.csv.CSVFormat;

import org.apache.commons.csv.CSVParser;

import org.apache.commons.csv.CSVRecord;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

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

import org.springframework.stereotype.Controller;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.ui.Model;

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

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

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

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

import org.springframework.web.multipart.MultipartFile;

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

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

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

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

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

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

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

import com.spice.profitmandi.web.util.MVCResponseSender;

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

@Controller

@Transactional(rollbackFor = Throwable.class)

public class TaxationController {

	@Autowired

	private DocumentRepository documentRepository;

	@Autowired

	private StateGstRateRepository stateGstRateRepository;

	@Autowired

	private MVCResponseSender mvcResponseSender;

	@Autowired

	private ResponseSender<?> responseSender;

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

	@RequestMapping(value = "/csvFileUploader", method = RequestMethod.POST)

	public String getFileUploader(HttpServletRequest request, Model model ,HttpServletResponse response,

			@RequestPart MultipartFile file) throws Throwable {

		LOGGER.info("file"+file.toString());

		String fileName= file.getName();

		String fileNames = file.getOriginalFilename();

		LOGGER.info("fileName"+ fileName);

		LOGGER.info("fileNames"+ fileNames);

		List<StateGstRateModel> sgtFileName = this.readFile(file);

		LOGGER.info("sgtFileName"+sgtFileName);

		stateGstRateRepository.addStateGstRates(sgtFileName);

		model.addAttribute("responseSTG", mvcResponseSender.createResponseString(true));

		return "response";

	}

	private static StateGstRateModel createStateGstRate(CSVRecord record) {

		int itemId = Integer.parseInt(record.get(0));

       LOGGER.info("itemId"+itemId);

		double igstRate = Double.parseDouble(record.get(1));

		LOGGER.info("igstRate"+igstRate);

		// create and return book of this metadata

		return new StateGstRateModel(itemId, igstRate);

	}

	private List<StateGstRateModel> readFile(MultipartFile file) throws Exception {

		CSVParser parser = new CSVParser(new InputStreamReader(file.getInputStream()), CSVFormat.DEFAULT);

		List<CSVRecord> records = parser.getRecords();

		LOGGER.info("records"+records);

		LOGGER.info("parser"+parser);

		if (records.size() < 2) {

			parser.close();

			throw new ProfitMandiBusinessException("Uploaded File", "", "No records Found");

		}

		// Remove header

		records.remove(0);

		List<StateGstRateModel> returnList = new ArrayList<StateGstRateModel>();

		for (CSVRecord record : records) {

			StateGstRateModel cp = null;

			StateGstRateModel sgr = createStateGstRate(record);

			returnList.add(sgr);

			LOGGER.info("records"+record.get(1));

		}

		parser.close();

		return returnList;

	}

	@RequestMapping(value = "/createTaxation", method = RequestMethod.GET)

	public String showUploaderTaxation(HttpServletRequest request, Model model) throws Exception {

		return "taxation";

	}

}