Subversion Repositories SmartDukaan

import java.io.ByteArrayInputStream;

import java.io.ByteArrayOutputStream;

import java.io.InputStream;

import java.time.LocalDate;

import java.time.LocalDateTime;

import java.time.LocalTime;

import java.time.Month;

import java.time.YearMonth;

import java.time.format.DateTimeFormatter;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.Comparator;

import java.util.HashMap;

import java.util.HashSet;

import java.util.LinkedHashSet;

import java.util.List;

import java.util.Map;

import java.util.Set;

import java.util.stream.Collectors;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import javax.transaction.Transactional;

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.beans.factory.annotation.Qualifier;

import org.springframework.core.io.InputStreamResource;

import org.springframework.http.HttpHeaders;

import org.springframework.http.HttpStatus;

import org.springframework.http.ResponseEntity;

import org.springframework.stereotype.Controller;

import org.springframework.ui.Model;

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

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

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

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

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

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

import org.springframework.web.multipart.MultipartFile;

import com.google.gson.Gson;

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

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

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

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

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

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

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

import com.spice.profitmandi.dao.entity.fofo.InventoryItem;

import com.spice.profitmandi.dao.entity.fofo.OfferPayout;

import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;

import com.spice.profitmandi.dao.entity.fofo.PartnerType;

import com.spice.profitmandi.dao.entity.fofo.SchemeInOut;

import com.spice.profitmandi.dao.entity.fofo.SchemeItem;

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

import com.spice.profitmandi.service.offers.PartnerCriteria;

	@Autowired

	private Gson gson;

			@RequestParam(name = "searchModel", required = false, defaultValue = "0") int searchModel, Model model)

			throws ProfitMandiBusinessException {

		List<CustomerOffer> customerOffers = new ArrayList<>();

		if (searchModel > 0) {

			Item item = itemRepository.selectAllByCatalogItemId(searchModel).get(0);

			customerOffers = customerOfferRepository.selectActiveOfferByModel(searchModel, LocalDate.now());

			model.addAttribute("modelName", item.getItemDescriptionNoColor());

		} else {

		}

		LOGGER.info("customerOffers" + customerOffers);

		for (CustomerOffer customerOffer : customerOffers) {

			LOGGER.info("ss" + searchModel);

			if (!StringUtils.isEmpty(customerOffer.getPartnerCriteria())) {

				String partnerCriteria = retailerService.getPartnerCriteriaString(

						gson.fromJson(customerOffer.getPartnerCriteria(), PartnerCriteria.class));

				customerOffer.setPartnerCriteriaString(partnerCriteria);

			}

		}

		List<Integer> fofoIds = fofoStoreRepository.selectActiveStores().stream().map(x -> x.getId())

				.collect(Collectors.toList());

		Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();

		Map<Integer, CustomRetailer> customRetailersMap = fofoIds.stream().map(x -> customRetailerMap.get(x))

				.filter(x -> x != null).collect(Collectors.toList()).stream()

				.collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));

		model.addAttribute("customRetailersMap", customRetailersMap);

		model.addAttribute("warehouseRegion", ProfitMandiConstants.WAREHOUSE_MAP);

		model.addAttribute("searchModel", searchModel);

		co.setPartnerCriteria(gson.toJson(customerOfferModel.getPartnerCriteria()));

				rows);

		DateTimeFormatter formatter = DateTimeFormatter.ofPattern("dd-MM-yyyy");

		CustomerOffer customerOffer = customerOfferRepository.selectById(offerId);

		List<Integer> catalogIds = new ArrayList<>();

			if (coi == null) {

			}

			coi.setSchemePayout(Integer.parseInt(record.get(2)));

			coi.setDealerPayout(Integer.parseInt(record.get(3)));

			coi.setCustomerOfferId(offerId);

			coi.setUpdatedTimestamp(LocalDateTime.now());

			LOGGER.info(record.get(4));

			LocalDate startDate = LocalDate.parse(record.get(4), formatter);

			LocalDate endDate = LocalDate.parse(record.get(5), formatter);

			if ((startDate.equals(customerOffer.getStartDate().toLocalDate())

					|| startDate.isAfter(customerOffer.getStartDate().toLocalDate()))

					&& (startDate.isEqual(customerOffer.getEndDate().toLocalDate())

							|| startDate.isBefore(customerOffer.getEndDate().toLocalDate()))) {

				coi.setStartDate(startDate);

				catalogIds.add(coi.getCatalogId());

			}

			if ((endDate.equals(customerOffer.getStartDate().toLocalDate())

			} else {

				catalogIds.add(coi.getCatalogId());

		if (!catalogIds.isEmpty()) {

			throw new ProfitMandiBusinessException("Please set accurate start and end date", catalogIds,

					"Please set accurate start and end date");

		}

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

		return "response";

	}

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

	public String addCustomerOfferItem(HttpServletRequest request,

			@RequestBody CustomerOfferItemModel customerOfferItemModel, Model model) throws Throwable {

		CustomerOffer customerOffer = customerOfferRepository.selectById(customerOfferItemModel.getOfferId());

		if (!(customerOffer.getEndDate().toLocalDate().equals(LocalDate.now()))

				&& customerOffer.getEndDate().isBefore(LocalDateTime.now())) {

			throw new ProfitMandiBusinessException("Catalog Id", customerOffer.getOfferName(), "Offer is Expired");

		}

		List<CustomerOfferItem> customerOfferItems = customerOfferItemRepository

				.selectByOfferAndCatalogId(customerOfferItemModel.getOfferId(), customerOfferItemModel.getCatalogId());

		if (!customerOfferItems.isEmpty()) {

			for (CustomerOfferItem coi : customerOfferItems) {

				if (!(coi.getEndDate().equals(LocalDate.now())) && coi.getEndDate().isAfter(LocalDate.now())) {

					throw new ProfitMandiBusinessException("Catalog Id", coi.getCatalogId(), "Item is already exist.");

				}

			}

		}

		LocalDate startDate = customerOfferItemModel.getStartDate().toLocalDate();

		LocalDate endDate = customerOfferItemModel.getEndDate().toLocalDate();

		CustomerOfferItem coi = new CustomerOfferItem();

		coi.setCatalogId(customerOfferItemModel.getCatalogId());

		coi.setSchemePayout(customerOfferItemModel.getSchemePayout());

		coi.setDealerPayout(customerOfferItemModel.getDealerPayout());

		coi.setCustomerOfferId(customerOfferItemModel.getOfferId());

		coi.setUpdatedTimestamp(LocalDateTime.now());

		coi.setCreatedTimestamp(LocalDateTime.now());

		if ((startDate.equals(customerOffer.getStartDate().toLocalDate())

				|| startDate.isAfter(customerOffer.getStartDate().toLocalDate()))

				&& (startDate.isEqual(customerOffer.getEndDate().toLocalDate())

						|| startDate.isBefore(customerOffer.getEndDate().toLocalDate()))) {

			coi.setStartDate(startDate);

		} else {

			throw new ProfitMandiBusinessException("Catalog Id", customerOffer.getOfferName(),

					"Please select accurate duration between " + customerOffer.getStartDate().toLocalDate() + " - "

							+ customerOffer.getEndDate());

		}

		if ((endDate.equals(customerOffer.getStartDate().toLocalDate())

				|| endDate.isAfter(customerOffer.getStartDate().toLocalDate()))

				&& (endDate.isEqual(customerOffer.getEndDate().toLocalDate())

						|| endDate.isBefore(customerOffer.getEndDate().toLocalDate()))) {

			coi.setEndDate(endDate);

		} else {

			throw new ProfitMandiBusinessException("Catalog Id", customerOffer.getOfferName(),

					"Please select accurate duration between " + customerOffer.getStartDate().toLocalDate() + " - "

							+ customerOffer.getEndDate());

		}

		customerOfferItemRepository.persist(coi);

		DateTimeFormatter formatter = DateTimeFormatter.ofPattern("dd-MM-yyyy");

					coi.getStartDate().format(formatter), coi.getEndDate().format(formatter)));

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

	public String getCustomerOfferItem(HttpServletRequest request, @RequestParam int offerId, Model model)

			throws Exception {

		List<CustomerOfferItem> customerOfferItems = customerOfferItemRepository.selectByOfferId(offerId);

		List<Integer> catalogIds = customerOfferItems.stream().map(x -> x.getCatalogId()).collect(Collectors.toList());

		Map<Integer, List<Item>> catalogItemMap = itemRepository.selectAllByCatalogIds(new HashSet<>(catalogIds))

				.stream().collect(Collectors.groupingBy(x -> x.getCatalogItemId()));

		model.addAttribute("catalogItemMap", catalogItemMap);

		model.addAttribute("offerId", offerId);

		model.addAttribute("customerOfferItems", customerOfferItems);

		return "customer-offer-item";

	}

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

	public String expiredCustomerOfferItem(HttpServletRequest request, @RequestParam int id,

			@RequestParam LocalDateTime endDate, Model model) throws Exception {

		CustomerOfferItem customerOfferItem = customerOfferItemRepository.selectById(id);

		CustomerOffer customerOffer = customerOfferRepository.selectById(customerOfferItem.getCustomerOfferId());

		if ((endDate.toLocalDate().equals(customerOffer.getStartDate().toLocalDate())

				|| endDate.toLocalDate().isAfter(customerOffer.getStartDate().toLocalDate()))

				&& (endDate.toLocalDate().isEqual(customerOffer.getEndDate().toLocalDate())

						|| endDate.toLocalDate().isBefore(customerOffer.getEndDate().toLocalDate()))) {

			customerOfferItem.setEndDate(endDate.toLocalDate());

		} else {

			throw new ProfitMandiBusinessException("Date", customerOffer.getOfferName(),

					"customer offer expired on " + customerOffer.getEndDate());

		}

		Map<Integer, List<Item>> catalogItemMap = itemRepository

				.selectAllByCatalogItemId(customerOfferItem.getCatalogId()).stream()

				.collect(Collectors.groupingBy(x -> x.getCatalogItemId()));

		model.addAttribute("catalogItemMap", catalogItemMap);

		model.addAttribute("coi", customerOfferItem);

		return "customer-offer-item-index";

	}