Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
import com.spice.profitmandi.common.model.CustomRetailer;
import com.spice.profitmandi.dao.entity.catalog.Item;
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.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.service.user.RetailerService;
import com.spice.profitmandi.web.util.MVCResponseSender;
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.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 javax.servlet.http.HttpServletRequest;
import java.time.LocalDateTime;
import java.util.*;
import java.util.stream.Collectors;

@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 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, @RequestParam(name = "date", required = false, defaultValue = "") LocalDateTime date, @RequestParam(name = "mobileNumber", required = false, defaultValue = "") String mobileNumber, Model model) throws ProfitMandiBusinessException {
        List<HygieneData> hygieneData = new ArrayList<HygieneData>();
        List<Integer> orderIds = new ArrayList<Integer>();
        if (!StringUtils.isEmpty(mobileNumber)) {
            orderIds = hygieneDataRepository.selectHygieneByMobile(mobileNumber);
            hygieneData = hygieneDataRepository.selectByOrderIds(orderIds);

        } else if (fofoId != 0 && date != null) {
            hygieneData = hygieneDataRepository.selectAllByFofoIdDate(fofoId, date.toLocalDate());
            model.addAttribute("date", date);

        } else if (fofoId != 0) {
            hygieneData = hygieneDataRepository.selectAllByFofoIdDisposedTimestamp(fofoId);

        } else if (date != null) {
            hygieneData = hygieneDataRepository.selectAllByDate(date.toLocalDate());
            model.addAttribute("date", date);

        }

        else {
            hygieneData = hygieneDataRepository.selectByDisposedTimestamp();
        }

        //LOGGER.info("hygineeDate {}", hygieneData);

        //LOGGER.info("orderIds {}", orderIds);

        if (!hygieneData.isEmpty()) {
            if (StringUtils.isEmpty(mobileNumber)) {
                orderIds = hygieneData.stream().map(x -> x.getOrderId()).collect(Collectors.toList());
            }
            Map<Integer, FofoOrder> fofoOrdersMap = new HashMap<Integer, FofoOrder>();

            if (!orderIds.isEmpty()) {
                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> customRetailerMap = retailerService.getAllFofoRetailers();

            Map<Integer, CustomRetailer> partnerAddressMap = fofoIds.stream().map(x -> customRetailerMap.get(x)).filter(x -> x != null).collect(Collectors.toList()).stream().collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));

            List<HygieneData> filteredHygieneData = new ArrayList<>();
            if (!hygieneData.isEmpty()) {
                List<Integer> filteredOrderIds = fofoOrdersMap.values().stream().map(x -> x.getId()).collect(Collectors.toList());

                filteredHygieneData.addAll(hygieneData.stream().filter(x -> filteredOrderIds.contains(x.getOrderId())).collect(Collectors.toList()));

            }
            model.addAttribute("hygieneData", filteredHygieneData).addAttribute("fofoOrder", fofoOrdersMap).addAttribute("partnerAddress", partnerAddressMap).addAttribute("customerAddress", customerAddress);

        } else {
            model.addAttribute("hygieneData", hygieneData);
        }

        return "hygiene";
    }

    private Map<Integer, FofoOrder> getfofoOrderByOrderId(List<Integer> fofoOrderIds) throws ProfitMandiBusinessException {
        Map<Integer, FofoOrder> fofoOrderMap = new HashMap<>();
        List<FofoOrder> fofoOrders = fofoOrderRepository.selectAllByOrderIds(fofoOrderIds);

        for (FofoOrder fofoOrder : fofoOrders) {
            List<FofoOrderItem> fofoItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());

            boolean smartPhone = false;
            for (FofoOrderItem fofoItem : fofoItems) {
                Item orderItem = itemRepository.selectById(fofoItem.getItemId());
                if (orderItem.isSmartPhone()) {
                    smartPhone = true;
                }

            }

            if (smartPhone) {
                fofoOrderMap.put(fofoOrder.getId(), fofoOrder);
            }

        }
        return fofoOrderMap;
    }

    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) {
            int count = 0;
            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);
            }

            count = hygieneData.getCallCount();
            count = count + 1;
            hygieneData.setCallCount(count);
        }

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

        return "response";
    }

}