Subversion Repositories SmartDukaan

package com.spice.profitmandi.service;

import java.time.LocalDate;

import java.time.LocalDateTime;

import java.time.LocalTime;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.Set;

import java.util.stream.Collectors;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

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

import org.springframework.cache.annotation.Cacheable;

import org.springframework.stereotype.Component;

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

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

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

import com.spice.profitmandi.dao.entity.transaction.UserWallet;

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

import com.spice.profitmandi.dao.repository.cs.CsService;

import com.spice.profitmandi.dao.repository.cs.TicketRepository;

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

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

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

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

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

@Component

public class PartnerStatsServiceImpl implements PartnerStatsService {

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

	@Autowired

	RetailerService retailerService;

	@Autowired

	FofoStoreRepository fofoStoreRepository;

	@Autowired

	FofoOrderItemRepository fofoOrderItemRepository;

	@Autowired

	CsService csService;

	@Autowired

	TicketRepository ticketRepository;

	@Autowired

	PartnerInvestmentService partnerInvestmentService;

	@Autowired

	HygieneDataRepository hygieneDataRepository;

	@Autowired

	UserWalletRepository userWalletRepository;

	@Override

	@Cacheable(value = "partnerStats", cacheManager = "thirtyMinsTimeOutCacheManager")

	public Map<Integer, PartnerDetailModel> getAllPartnerStats() throws ProfitMandiBusinessException {

		LocalDateTime curDate = LocalDate.now().atStartOfDay();

		Map<Integer, Double> lmtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(

				curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), 0, false);

		Map<Integer, Double> mtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(curDate.withDayOfMonth(1),

				curDate.with(LocalTime.MAX), 0, false);

		Map<Integer, Long> last1daystertiary = fofoOrderItemRepository.selectQtyGroupByRetailer(curDate,

				curDate.with(LocalTime.MAX), 0, false);

		Map<Integer, Long> last3daystertiary = fofoOrderItemRepository.selectQtyGroupByRetailer(curDate.minusDays(4),

				curDate.minusDays(1).with(LocalTime.MAX), 0, false);

		Map<Integer, Long> ticketMap = ticketRepository.selectAllOpenTicketsGroupByRetailer();

		List<FofoStore> fofoStores = fofoStoreRepository.selectActiveStores();

		Set<Integer> fofoIds = fofoStores.stream().map(x -> x.getId()).collect(Collectors.toSet());

		Map<Integer, UserWallet> userWallet = userWalletRepository.selectByRetailerIds(fofoIds).stream()

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

		Map<Integer, PartnerDetailModel> allPartnerStats = new HashMap<>();

		Map<Integer, PartnerDailyInvestment> investmentMap = fofoStores.stream().map(x -> {

			try {

				return partnerInvestmentService.getInvestment(x.getId(), 0);

			} catch (Exception e) {

				LOGGER.info("Could not get invetment summary for {}", x);

				return new PartnerDailyInvestment();

			}

		}).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));

		for (FofoStore store : fofoStores) {

			int fofoId = store.getId();

			int hygieneCount = (int) hygieneDataRepository.selectHygieneCount(fofoId, true,

					curDate.withDayOfMonth(1).minusMonths(1), curDate.plusMonths(1).withDayOfMonth(1));

			int invalidHygieneCount = (int) hygieneDataRepository.selectHygieneCount(fofoId, true,

					curDate.withDayOfMonth(1).minusMonths(1), curDate.plusMonths(1).withDayOfMonth(1));

			int totalHygieneCount = hygieneCount + invalidHygieneCount;

			PartnerDetailModel pm = new PartnerDetailModel();

			pm.setLmtd(lmtdSale.get(fofoId) == null ? 0 : lmtdSale.get(fofoId));

			pm.setMtd(mtdSale.get(fofoId) == null ? 0 : mtdSale.get(fofoId));

			pm.setLastOneDayTertiary(last1daystertiary.get(fofoId) == null ? 0 : last1daystertiary.get(fofoId));

			pm.setLastThreeDaytertiary(last3daystertiary.get(fofoId) == null ? 0 : last3daystertiary.get(fofoId));

			pm.setWalletAmount(userWallet.get(fofoId).getAmount() == 0 ? 0 : userWallet.get(fofoId).getAmount());

			pm.setInvestment(investmentMap.get(fofoId));

			pm.setTicket(ticketMap.get(fofoId) == null ? 0 : ticketMap.get(fofoId).intValue());

			pm.setHygiene(hygieneCount);

			pm.setAuthUser(csService.getAuthUserByPartnerId(fofoId).get(0) == null ? "not available"

					: csService.getAuthUserByPartnerId(fofoId).get(0));

			pm.setTotalHygiene(totalHygieneCount);

			pm.setTicket(ticketMap.get(fofoId) == null ? 0 : ticketMap.get(fofoId).intValue());

			allPartnerStats.put(fofoId, pm);

			LOGGER.info("pm {}", pm);

		}

		return allPartnerStats;

	}

	@Override

	// @Cacheable(value = "partnerAggregateStats", cacheManager =

	// "oneDayCacheManager")

	public PartnerDetailModel getAggregateStats(List<PartnerDetailModel> partnerDetailModels)

			throws ProfitMandiBusinessException {

		PartnerDetailModel pdm = new PartnerDetailModel();

		PartnerDailyInvestment aggregateInvestment = new PartnerDailyInvestment();

		pdm.setInvestment(aggregateInvestment);

		double totallmtdAmount = 0;

		double totalmtdAmount = 0;

		int totalTicketCount = 0;

		int currentHygieneCount = 0;

		int currentTotalHygieneCount = 0;

		for (PartnerDetailModel partnerDetailModel : partnerDetailModels) {

			PartnerDailyInvestment pdi = partnerDetailModel.getInvestment();

			totallmtdAmount += partnerDetailModel.getLmtd();

			totalmtdAmount += partnerDetailModel.getMtd();

			totalTicketCount += partnerDetailModel.getTicket();

			currentHygieneCount += partnerDetailModel.getHygiene();

			currentTotalHygieneCount += partnerDetailModel.getTotalHygiene();

			aggregateInvestment.setActivatedStockAmount(

					aggregateInvestment.getActivatedStockAmount() + pdi.getActivatedStockAmount());

			aggregateInvestment

					.setGrnPendingAmount(aggregateInvestment.getGrnPendingAmount() + pdi.getGrnPendingAmount());

			aggregateInvestment.setInStockAmount(aggregateInvestment.getInStockAmount() + pdi.getInStockAmount());

			aggregateInvestment.setReturnInTransitAmount(

					aggregateInvestment.getReturnInTransitAmount() + pdi.getReturnInTransitAmount());

			aggregateInvestment.setSalesAmount(aggregateInvestment.getSalesAmount() + pdi.getSalesAmount());

			aggregateInvestment.setUnbilledAmount(aggregateInvestment.getUnbilledAmount() + pdi.getUnbilledAmount());

			aggregateInvestment.setWalletAmount(aggregateInvestment.getWalletAmount() + pdi.getWalletAmount());

		}

		pdm.setHygiene(currentHygieneCount);

		pdm.setTotalHygiene(currentTotalHygieneCount);

		pdm.setLmtd(totallmtdAmount);

		pdm.setMtd(totalmtdAmount);

		pdm.setTicket(totalTicketCount);

		pdm.setCount(partnerDetailModels.size());

		return pdm;

	}

}