Subversion Repositories SmartDukaan

package com.smartdukaan.cron.scheduled;

import java.time.LocalDate;

import java.time.LocalDateTime;

import java.time.LocalTime;

import java.util.List;

import java.util.Map;

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

import org.springframework.transaction.annotation.Transactional;

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

import com.spice.profitmandi.common.util.FormattingUtils;

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

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

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

import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;

import com.spice.profitmandi.dao.enumuration.transaction.SchemePayoutStatus;

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

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

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

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

import com.spice.profitmandi.service.wallet.WalletService;

import in.shop2020.model.v1.order.WalletReferenceType;;

@Component

@Transactional(rollbackFor = Throwable.class)

public class InvestmentRelatedTasks {

	@Autowired

	RetailerService retailerService;

	@Autowired

	SchemeInOutRepository schemeInOutRepository;

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

	@Autowired

	InventoryItemRepository inventoryItemRepository;

	@Autowired

	PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;

	@Autowired

	WalletService walletService;

	public void payMonthlyInvestment() throws ProfitMandiBusinessException {

		LocalDate firstDateOfCurrentMonth = LocalDateTime.now().withDayOfMonth(1).toLocalDate();

		LocalDate startOfPreviousMonth = firstDateOfCurrentMonth.minusMonths(1);

		int referenceId = Integer.parseInt(FormattingUtils.getYearMonth(startOfPreviousMonth.atStartOfDay()));

		LocalDate lastOfPreviousMonth = firstDateOfCurrentMonth.minusDays(1);

		List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository

				.selectAll(startOfPreviousMonth, lastOfPreviousMonth);

		Map<Integer, Long> investmentMaintainedDaysMap = partnerDailyInvestments.stream()

				.filter(x -> x.getShortPercentage() <= 10)

				.collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.counting()));

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

		List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectAllPending(SchemeType.INVESTMENT,

				startOfPreviousMonth.atStartOfDay(), firstDateOfCurrentMonth.atStartOfDay());

		Map<Integer, List<SchemeInOut>> inventoryItemIdSchemeMap = schemeInOuts.stream()

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

		List<InventoryItem> inventoryItems = inventoryItemRepository.selectByIds(inventoryItemIdSchemeMap.keySet());

		Map<Integer, List<Integer>> retailerInventoryItemIdMap = inventoryItems.stream().collect(

				Collectors.groupingBy(x -> x.getFofoId(), Collectors.mapping(x -> x.getId(), Collectors.toList())));

		System.out.println("Fofo Id\tInvestment Short Days\tEligible payout");

		for (Map.Entry<Integer, List<Integer>> retailerEntry : retailerInventoryItemIdMap.entrySet()) {

			int fofoId = retailerEntry.getKey();

			long investmentMaintainedDays = investmentMaintainedDaysMap.get(fofoId) == null ? 0

					: investmentMaintainedDaysMap.get(fofoId);

			List<SchemeInOut> schemeInouts = retailerEntry.getValue().stream().map(x -> inventoryItemIdSchemeMap.get(x))

					.flatMap(List::stream).filter(x -> x.getRolledBackTimestamp() == null).collect(Collectors.toList());

			float totalAmount = 0;

			for(SchemeInOut sio : schemeInouts) {

				if (investmentMaintainedDays < 8) {

					sio.setStatus(SchemePayoutStatus.REJECTED);

					sio.setRolledBackTimestamp(LocalDateTime.now());

					sio.setStatusDescription("Investment maintained for " + investmentMaintainedDays + "(< 8) days");

				} else if (investmentMaintainedDays < 12) {

					sio.setStatus(SchemePayoutStatus.CREDITED);

					sio.setAmount(sio.getAmount()/2);

					sio.setCreditTimestamp(LocalDateTime.now());

					sio.setStatusDescription("Investment maintained for " + investmentMaintainedDays + "(< 12) days");

					totalAmount += sio.getAmount();

				} else {

					sio.setStatus(SchemePayoutStatus.CREDITED);

					sio.setCreditTimestamp(LocalDateTime.now());

					totalAmount += sio.getAmount();

				}

			}

			if(totalAmount > 0) {

				String description = "Margin rolled out for " + FormattingUtils.formatYearMonth(startOfPreviousMonth.atStartOfDay());

				if(investmentMaintainedDays < 12) {

					description += ", as maintained for " + investmentMaintainedDays  + "(< 12) days";

				}

				walletService.addAmountToWallet(fofoId,referenceId, WalletReferenceType.INVESTMENT_PAYOUT,  description, totalAmount, lastOfPreviousMonth.atTime(LocalTime.MAX));

			}

			System.out.printf("%d\t%d\t%f%n", fofoId, investmentMaintainedDays, totalAmount);

		}

	}

	public void evaluateActualInvestmentPayout() {

		LocalDate firstDateOfCurrentMonth = LocalDateTime.now().withDayOfMonth(1).toLocalDate();

		LocalDate startOfPreviousMonth = firstDateOfCurrentMonth.minusMonths(1);

		LocalDate lastOfPreviousMonth = firstDateOfCurrentMonth.minusDays(1);

		List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository

				.selectAll(startOfPreviousMonth, lastOfPreviousMonth);

		Map<Integer, Long> investmentMaintainedDaysMap = partnerDailyInvestments.stream()

				.filter(x -> x.getShortPercentage() <= 10)

				.collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.counting()));

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

		List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectAllPending(SchemeType.INVESTMENT,

				startOfPreviousMonth.atStartOfDay(), firstDateOfCurrentMonth.atStartOfDay());

		Map<Integer, List<SchemeInOut>> inventoryItemIdSchemeMap = schemeInOuts.stream()

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

		List<InventoryItem> inventoryItems = inventoryItemRepository.selectByIds(inventoryItemIdSchemeMap.keySet());

		Map<Integer, List<Integer>> retailerInventoryItemIdMap = inventoryItems.stream().collect(

				Collectors.groupingBy(x -> x.getFofoId(), Collectors.mapping(x -> x.getId(), Collectors.toList())));

		System.out.println("Fofo Id\tInvestment Short Days\tEligible payout");

		for (Map.Entry<Integer, List<Integer>> retailerEntry : retailerInventoryItemIdMap.entrySet()) {

			int fofoId = retailerEntry.getKey();

			List<SchemeInOut> schemeInouts = retailerEntry.getValue().stream().map(x -> inventoryItemIdSchemeMap.get(x))

					.flatMap(List::stream).collect(Collectors.toList());

			double totalAmount = schemeInouts.stream().filter(x -> x.getRolledBackTimestamp() == null)

					.collect(Collectors.summingDouble(x -> x.getAmount()));

			long investmentMaintainedDays = investmentMaintainedDaysMap.get(fofoId) == null ? 0

					: investmentMaintainedDaysMap.get(fofoId);

			if (investmentMaintainedDays < 8) {

				totalAmount = 0;

			} else if (investmentMaintainedDays < 12) {

				totalAmount = totalAmount / 2;

			}

			System.out.printf("%d\t%d\t%f%n", fofoId, investmentMaintainedDays, totalAmount);

		}

	}

}