Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import java.time.LocalDate;

import java.time.LocalDateTime;

import java.util.ArrayList;

import java.util.List;

import java.util.stream.Collectors;

import javax.servlet.http.HttpServletRequest;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

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

import org.springframework.http.MediaType;

import org.springframework.http.ResponseEntity;

import org.springframework.stereotype.Controller;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.util.StringUtils;

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

import com.spice.profitmandi.common.solr.SolrService;

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

import com.spice.profitmandi.service.CustomerService;

import com.spice.profitmandi.service.inventory.InventoryService;

import io.swagger.annotations.ApiImplicitParam;

import io.swagger.annotations.ApiImplicitParams;

@Controller

@Transactional(rollbackFor = Throwable.class)

public class CustomerController {

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

	@Autowired

	private ResponseSender<?> responseSender;

	@Autowired

	private UserAccountRepository userAccountRepository;

	@Autowired

	private CustomerRepository customerRepository;

	@Autowired

	private InventoryService inventoryService;

	@Autowired

	private CustomerService customerService;

	@Autowired

	private CustomerAddressRepository customerAddressRepository;

	@Autowired

	private FofoOrderItemRepository fofoOrderItemRepository;

	@Autowired

	private SolrService commonSolrService;

	@Autowired

	private FofoLineItemRepository fofoLineItemRepository;

	@Autowired

	private ItemRepository itemRepository;

	@Autowired

	private FofoOrderRepository fofoOrderRepository;

	@Autowired

	private CustomerOfferRepository customerOfferRepository;

	@Autowired

	private CustomerOfferItemRepository customerOfferItemRepository;

	@Autowired

	private SamsungUpgradeOfferRepository samsungUpgradeOfferRepository;

	@RequestMapping(value = "/customer/mobileNumber", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	@ApiImplicitParams({

			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })

	public ResponseEntity<?> getCustomerByMobileNumber(HttpServletRequest request,

			@RequestParam(name = ProfitMandiConstants.MOBILE_NUMBER) String mobileNumber)

			throws ProfitMandiBusinessException {

		CustomCustomer customCustomer = null;

		LOGGER.info("Request Received at url {}", request.getRequestURI());

		try {

			Customer customer = customerRepository.selectByMobileNumber(mobileNumber);

			customCustomer = new CustomCustomer();

			customCustomer.setCustomerId(customer.getId());

			customCustomer.setEmailId(customer.getEmailId());

			customCustomer.setFirstName(customer.getFirstName());

			customCustomer.setLastName(customer.getLastName());

			customCustomer.setMobileNumber(customer.getMobileNumber());

			LOGGER.info(customer.getCustomerAddress());

			List<CustomerAddress> customerAddresses = customer.getCustomerAddress().stream()

					.sorted((CustomerAddress c1, CustomerAddress c2) -> {

						return c1.getCreateTimestamp().isBefore(c2.getCreateTimestamp()) ? 1 : -1;

					}).limit(5).collect(Collectors.toList());

			LOGGER.info(customerAddresses);

			if (!customerAddresses.isEmpty()) {

				List<CustomAddress> customAddresses = new ArrayList<>();

				for (CustomerAddress customerAddress : customerAddresses) {

					customAddresses.add(this.toCustomAddress(customerAddress));

				}

				customCustomer.setAddresses(customAddresses);

			}

		} catch (Exception e) {

			e.printStackTrace();

		}

		return responseSender.ok(customCustomer);

	}

	private CustomAddress toCustomAddress(CustomerAddress customerAddress) {

		CustomAddress customAddress = new CustomAddress();

		customAddress.setCity(customerAddress.getCity());

		customAddress.setCountry(customerAddress.getCountry());

		customAddress.setLandmark(customerAddress.getLandmark());

		customAddress.setLine1(customerAddress.getLine1());

		customAddress.setLine2(customerAddress.getLine2());

		customAddress.setName(customerAddress.getName());

		customAddress.setLastName(customerAddress.getLastName());

		customAddress.setPhoneNumber(customerAddress.getPhoneNumber());

		customAddress.setPinCode(customerAddress.getPinCode());

		customAddress.setState(customerAddress.getState());

		customAddress.setId(customerAddress.getId());

		return customAddress;

	}

	@RequestMapping(value = "/customer/add", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)

	@ApiImplicitParams({

			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })

	public ResponseEntity<?> addCustomer(HttpServletRequest request, @RequestBody CustomCustomer customCustomer)

			throws ProfitMandiBusinessException {

		Customer customer = new Customer();

		if (StringUtils.isEmpty(customCustomer.getFirstName())) {

			throw new ProfitMandiBusinessException("First Name", "Empty", "First Name required");

		}

		customer.setEmailId(customCustomer.getEmailId());

		customer.setFirstName(customCustomer.getFirstName());

		customer.setLastName(customCustomer.getLastName());

		customer.setMobileNumber(customCustomer.getMobileNumber());

		customer = customerService.addCustomer(customer);

		customCustomer.setCustomerId(customer.getId());

		return responseSender.ok(customCustomer);

	}

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

	public ResponseEntity<?> addAddress(HttpServletRequest request, @RequestParam int customerId,

			@RequestBody CustomAddress customAddress) {

		CustomerAddress customerAddress = this.toCustomerAddress(customerId, customAddress);

		customerAddressRepository.persist(customerAddress);

		return responseSender.ok(this.toCustomAddress(customerAddress));

	}

	private CustomerAddress toCustomerAddress(int customerId, CustomAddress customAddress) {

		CustomerAddress customerAddress = new CustomerAddress();

		customerAddress.setCustomerId(customerId);

		customerAddress.setName(customAddress.getName());

		customerAddress.setLastName(customAddress.getLastName());

		customerAddress.setLine1(customAddress.getLine1());

		customerAddress.setLine2(customAddress.getLine2());

		customerAddress.setLandmark(customAddress.getLandmark());

		customerAddress.setCity(customAddress.getCity());

		customerAddress.setPinCode(customAddress.getPinCode());

		customerAddress.setState(customAddress.getState());

		customerAddress.setCountry(customAddress.getCountry());

		customerAddress.setPhoneNumber(customAddress.getPhoneNumber());

		return customerAddress;

	}

	@RequestMapping(value = "/customer/order", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

	@ApiImplicitParams({

			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })

	public ResponseEntity<?> getOrderInvoiceDetail(HttpServletRequest request,

			@RequestParam(name = "offset") int offset, @RequestParam(name = "limit") int limit) throws Exception {

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

		UserCart uc = userAccountRepository.getUserCart(userId);

		List<CustomerOrderDetail> customerOrderDetails = new ArrayList<>();

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

		List<FofoOrder> fofoOrders = fofoOrderRepository.selectOrderByFofoId(uc.getUserId(), offset, limit);

		if (!fofoOrders.isEmpty()) {

			for (FofoOrder fo : fofoOrders) {

				if (fo.getCancelledTimestamp() == null) {

					List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fo.getId());

					Customer customer = customerRepository.selectById(fo.getCustomerId());

					CustomerAddress customerAddress = customerAddressRepository.selectById(fo.getCustomerAddressId());

					for (FofoOrderItem fofoOrderItem : fofoOrderItems) {

						Item item = itemRepository.selectById(fofoOrderItem.getItemId());

						fofoOrderItem.setItemName(item.getItemDescription());

						catalogIds.add(item.getCatalogItemId());

					}

					// Map<Integer, JSONObject> contentMap =

					// commonSolrService.getContentByCatalogIds(catalogIds);

					for (FofoOrderItem foi : fofoOrderItems) {

						List<FofoLineItem> flis = fofoLineItemRepository.selectByFofoOrderItemId(foi.getId());

						CustomerOrderDetail customerOrderDetail = new CustomerOrderDetail();

						List<String> serialNumber = flis.stream().map(x -> x.getSerialNumber())

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

								.collect(Collectors.toList());

						customerOrderDetail.setSerialNumber(serialNumber);

						customerOrderDetail.setCustomerName(customerAddress.getName());

						customerOrderDetail.setCustomerMobile(customerAddress.getPhoneNumber());

						customerOrderDetail.setCustomerEmail(customer.getEmailId());

						customerOrderDetail.setCustomerCity(customerAddress.getCity());

						customerOrderDetail.setCustomerState(customerAddress.getState());

						Item item = itemRepository.selectById(foi.getItemId());

						// JSONObject jsonObj = contentMap.get(item.getCatalogItemId());

						// customerOrderDetail.setImageUrl(jsonObj.getString("imageUrl_s"));

						customerOrderDetail.setBrand(item.getBrand());

						customerOrderDetail.setColor(item.getColor());

						customerOrderDetail.setFofoOrderItemId(foi.getId());

						customerOrderDetail.setFofoOrderId(foi.getOrderId());

						customerOrderDetail.setItemId(foi.getItemId());

						customerOrderDetail.setModelName(item.getModelName());

						customerOrderDetail.setModelNumber(item.getModelNumber());

						customerOrderDetail.setQuantity(foi.getQuantity());

						customerOrderDetail.setTotalPrice(foi.getSellingPrice());

						customerOrderDetail.setCreatedTimeStamp(foi.getCreateTimestamp());

						customerOrderDetail.setInvoiceNumber(fo.getInvoiceNumber());

						customerOrderDetail.setCancelledTimestamp(fo.getCancelledTimestamp());

						customerOrderDetail.setInsurance(false);

						if (!serialNumber.isEmpty()) {

							if (fo.getCreateTimestamp().toLocalDate().equals(LocalDate.now())

									&& item.getHsnCode().equals("85171290")) {

								customerOrderDetail.setInsurance(true);

							} else {

								customerOrderDetail.setInsurance(false);

							}

						}

						List<Integer> offerIds = customerOfferRepository

								.selectOffersByDate(LocalDateTime.now().toLocalDate().atStartOfDay()).stream()

								.map(x -> x.getId()).collect(Collectors.toList());

						LOGGER.info("offerIds" + offerIds);

						long offerCount = 0;

						if (!offerIds.isEmpty()) {

							List<CustomerOfferItem> customerOfferItems = customerOfferItemRepository

									.selectByOfferIds(offerIds, item.getCatalogItemId());

							offerCount = customerOfferItems.stream().collect(Collectors.counting());

						}

						customerOrderDetail.setOfferCount(offerCount);

						customerOrderDetails.add(customerOrderDetail);

					}

				}

			}

		}

		return responseSender.ok(customerOrderDetails);

	}

}