Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import java.time.LocalDate;

import java.time.LocalDateTime;

import java.util.ArrayList;

import java.util.Collection;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.Set;

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.stereotype.Controller;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.ui.Model;

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

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

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

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

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

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

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

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

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

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

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

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

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

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

import com.spice.profitmandi.service.user.RetailerService;

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

@Controller

@Transactional(rollbackFor = Throwable.class)

public class HygieneController {

	@Autowired

	private FofoOrderRepository fofoOrderRepository;

	@Autowired

	private CustomerAddressRepository customerAddressRepository;

	@Autowired

	private RetailerService retailerService;

	@Autowired

	private FofoOrderItemRepository fofoOrderItemRepository;

	@Autowired

	private HygieneDataRepository hygieneDataRepository;

	@Autowired

	private ItemRepository itemRepository;

	@Autowired

	private RetailerService reatilerService;

	@Autowired

	private FofoStoreRepository fofotSoreRepository;

	@Autowired

	private MVCResponseSender mvcResponseSender;

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

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

	public String getHygieneData(HttpServletRequest request,

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

			throws ProfitMandiBusinessException {

		List<HygieneData> hygieneData = null;

		if (fofoId != 0) {

			hygieneData = hygieneDataRepository.selectAllByFofoIdDisposedTimestamp(fofoId);

		} else {

			hygieneData = hygieneDataRepository.selectByDisposedTimestamp();

		}

		List<Integer> orderIds = hygieneData.stream().map(x -> x.getOrderId()).collect(Collectors.toList());

		Map<Integer, FofoOrder> fofoOrdersMap = this.getfofoOrderByOrderId(orderIds);

		Set<Integer> fofoIds = fofoOrdersMap.values().stream().map(x -> x.getFofoId()).collect(Collectors.toSet());

		Map<Integer, CustomerAddress> customerAddress = this.getCustomerAddressByFofoOrder(fofoOrdersMap.values());

		Map<Integer, CustomRetailer> partnerAddressMap = retailerService

				.getFofoRetailers(new ArrayList<Integer>(fofoIds));

		model.addAttribute("hygieneData", hygieneData).addAttribute("fofoOrder", fofoOrdersMap)

				.addAttribute("partnerAddress", partnerAddressMap).addAttribute("customerAddress", customerAddress);

		return "hygiene";

	}

	private Map<Integer, FofoOrder> getfofoOrderByOrderId(List<Integer> fofoOrderIds)

			throws ProfitMandiBusinessException {

		Map<Integer, FofoOrder> fofoOrders = fofoOrderRepository.selectAllByOrderIds(fofoOrderIds).stream()

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

		return fofoOrders;

	}

	private Map<Integer, CustomerAddress> getCustomerAddressByFofoOrder(Collection<FofoOrder> fofoOrders)

			throws ProfitMandiBusinessException {

		Map<Integer, CustomerAddress> customerAddressMap = new HashMap<>();

		for (FofoOrder fofoOrder : fofoOrders) {

			CustomerAddress ca = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());

			customerAddressMap.put(fofoOrder.getCustomerAddressId(), ca);

		}

		return customerAddressMap;

	}

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

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

		FofoOrder fofoOrder = null;

		CustomRetailer customRetailer = null;

		CustomerAddress customerAddress = null;

		List<FofoOrderItem> fofoOrderItems = null;

		List<HygieneData> hygiene = hygieneDataRepository.selectAllByDisposedTimestamp();

		hygiene = hygiene.stream().filter(x -> x.getNextTimestamp().isBefore(LocalDateTime.now()))

				.collect(Collectors.toList());

		if (!hygiene.isEmpty()) {

			fofoOrder = fofoOrderRepository.selectByOrderId(hygiene.get(0).getOrderId());

			customRetailer = retailerService.getFofoRetailer(fofoOrder.getFofoId());

			customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());

			fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());

		} else {

			HygieneData hygieneData = hygieneDataRepository.selectFirstByDisposedTimestamp();

			if (hygieneData != null) {

				fofoOrder = fofoOrderRepository.selectByOrderId(hygieneData.getOrderId());

				customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());

				customRetailer = retailerService.getFofoRetailer(fofoOrder.getFofoId());

				fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());

				LOGGER.info("hygieneData" + hygieneData);

				LOGGER.info("fofoOrder" + fofoOrder);

				LOGGER.info("customRetailer" + customRetailer);

				LOGGER.info("customerAddress" + customerAddress);

			}

		}

		model.addAttribute("fofoOrder", fofoOrder);

		model.addAttribute("customRetailer", customRetailer);

		model.addAttribute("customerAddress", customerAddress);

		model.addAttribute("fofoOrderItems", fofoOrderItems);

		return "hygiene-modal";

	}

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

	public String getFetchHygieneDataByOrderId(HttpServletRequest request, @RequestParam int orderId, Model model)

			throws Exception {

		FofoOrder fofoOrder = null;

		CustomRetailer customRetailer = null;

		CustomerAddress customerAddress = null;

		List<FofoOrderItem> fofoOrderItems = null;

		HygieneData hygiene = hygieneDataRepository.selectById(orderId);

		fofoOrder = fofoOrderRepository.selectByOrderId(hygiene.getOrderId());

		customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());

		customRetailer = retailerService.getFofoRetailer(fofoOrder.getFofoId());

		fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());

		LOGGER.info("hygieneData" + hygiene);

		LOGGER.info("fofoOrder" + fofoOrder);

		LOGGER.info("customRetailer" + customRetailer);

		LOGGER.info("customerAddress" + customerAddress);

		model.addAttribute("fofoOrder", fofoOrder);

		model.addAttribute("customRetailer", customRetailer);

		model.addAttribute("customerAddress", customerAddress);

		model.addAttribute("fofoOrderItems", fofoOrderItems);

		return "hygiene-modal";

	}

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

	public String HygieneData(HttpServletRequest request, @RequestBody HygieneDataModel hygieneDataModel, Model model)

			throws Exception {

		HygieneData hygieneData = hygieneDataRepository.selectById(hygieneDataModel.getOrderId());

		FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(hygieneDataModel.getOrderId());

		LocalDateTime hygieneDateTime = hygieneData.getCreatedTimestamp().toLocalDate().atStartOfDay();

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

		List<CustomerAddress> customerAddresses = customerAddressRepository.selectByMobileNumber(customerAddress.getPhoneNumber());

		LOGGER.info("Fofo id {}, Date Range = {}, Customer Address Ids  {}", fofoOrder.getFofoId(), DateRangeModel.of(hygieneDateTime, hygieneDateTime.plusDays(1)), 

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

		List<FofoOrder> fofoOrders = fofoOrderRepository.selectByCustomerAddressIds(fofoOrder.getFofoId(), DateRangeModel.of(hygieneDateTime, hygieneDateTime.plusDays(1)), 

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

		LOGGER.info("Order Size - {}", fofoOrders.size());

		for(FofoOrder fo : fofoOrders) {

			LOGGER.info("Order Id - {}", fo.getId());

			hygieneData = hygieneDataRepository.selectById(fo.getId());

			if(hygieneData==null) continue;

			if (hygieneDataModel.getScheduleTime() != null) {

				hygieneData.setStatus(hygieneDataModel.getStatus());

				hygieneData.setRemark(hygieneDataModel.getRemark());

				hygieneData.setHygieneRating(hygieneDataModel.getHygieneRating());

				hygieneData.setNextTimestamp(hygieneDataModel.getScheduleTime());

				hygieneDataRepository.persist(hygieneData);

			} else {

				hygieneData.setStatus(hygieneDataModel.getStatus());

				hygieneData.setRemark(hygieneDataModel.getRemark());

				hygieneData.setRating(hygieneDataModel.getRating());

				hygieneData.setHygieneRating(hygieneDataModel.getHygieneRating());

				hygieneData.setDOP(hygieneDataModel.getDOP());

				hygieneData.setFeedback(hygieneDataModel.getFeedback());

				hygieneData.setQuesPhone(hygieneDataModel.getQuesPhone());

				hygieneData.setQuesInformation(hygieneDataModel.getQuesInformation());

				hygieneData.setQuesInvoice(hygieneDataModel.getQuesInvoice());

				hygieneData.setDisposedTimestamp(LocalDateTime.now());

				hygieneData.setNextTimestamp(null);

				hygieneDataRepository.persist(hygieneData);

			}

		}

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

		return "response";

	}

}