Subversion Repositories SmartDukaan

import com.spice.profitmandi.common.enumuration.ReporticoProject;

import com.spice.profitmandi.common.model.CustomRetailer;

import com.spice.profitmandi.common.services.ReporticoService;

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

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

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

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

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

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

	@Autowired

	private ReporticoService reporticoService;

	@Autowired

	WalletService walletService;

	@Autowired

	PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;

		LocalDate currentdate = LocalDate.now();

		Month month = currentdate.getMonth().minus(1);

		model.addAttribute("month", month);

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

	public void payMonthlyInvestment(HttpServletRequest request, Model model) 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());

		if(schemeInOuts.isEmpty()) 

		{

			throw new ProfitMandiBusinessException("Investment Payout", "",

					"No data Found");

		}

		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 Maintained 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 = "Investment margin paid 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);

		}

	}

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

   public ResponseEntity<?> evaluateActualInvestmentPayout(HttpServletRequest request,Model model) throws Exception {

		List<List<?>> rows = new ArrayList<>();

		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 Maintained 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);

			CustomRetailer customRetailer= retailerService.getFofoRetailer(fofoId);

			 rows.add(Arrays.asList(fofoId,customRetailer.getBusinessName(),customRetailer.getCode(),investmentMaintainedDays,totalAmount));

		}

				org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil

				.getCSVByteStream(Arrays.asList("fofoId","Name", "Code", "investmentMaintainedDays","totalAmount"), rows);

		final HttpHeaders headers = new HttpHeaders();

		headers.set("Content-Type", "text/csv");

		headers.set("Content-disposition", "inline; filename=investmentMaintainedDays.csv");

		headers.setContentLength(baos.toByteArray().length);

		final InputStream inputStream = new ByteArrayInputStream(baos.toByteArray());

		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);

		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);

	}

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

	   public ResponseEntity<?> processInvestmentDryRun(HttpServletRequest request,Model model) throws Exception {

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

		LocalDate startOfPreviousMonth = firstDateOfCurrentMonth.minusMonths(1);

		LocalDate lastOfPreviousMonth = firstDateOfCurrentMonth.minusDays(1);

		List<List<?>> rows = new ArrayList<>();

			Map<String, String> params = new HashMap<>();

			params.put("MANUAL_datesBetween_FROMDATE",firstDateOfCurrentMonth.toString());

			params.put("MANUAL_datesBetween_TODATE",firstDateOfCurrentMonth.plusDays(9).toString());

			params.put("type","INVESTMENT");

			List<EvaluateSchemeInvestmentPayoutModel> evaluateSchemeInvestmentPayouts = reporticoService.getReports(EvaluateSchemeInvestmentPayoutModel.class,

					ReporticoProject.FOCO, "schemepayout.xml", params);

			LOGGER.info("reportResponse {}", evaluateSchemeInvestmentPayouts);

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

		  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()));

			for (EvaluateSchemeInvestmentPayoutModel esip : evaluateSchemeInvestmentPayouts) {

				long investmentMaintainedDays = investmentMaintainedDaysMap.get(esip.getFofoId()) == null ? 0

						: investmentMaintainedDaysMap.get(esip.getFofoId());

				esip.setInvestmentDays(investmentMaintainedDays);

				float processAmount = esip.getPaidAmount()/2;

				esip.setProcessAmount(processAmount);

				rows.add(Arrays.asList(esip.getCode(),esip.getStoreName(),esip.getFofoId(),esip.getItemId(),esip.getBrand(),esip.getModelName(),esip.getModelNumber(),

						esip.getColor(),esip.getSchemeInDp(),esip.getSchemeOutDp(),esip.getSchemeId(),

						esip.getName(),esip.getType(),esip.getPartnerType(),esip.getAmountType(),esip.getAmount(),esip.getPurchaseInvoice(),esip.getSaleInovoice(),

						esip.getPaidAmount(),esip.getCreateTimestamp(),esip.getRolledBackTimestamp(),esip.getSerialNumber(),esip.getInRef(),esip.getOutRef()

						,esip.getBusinessDate(),esip.getStatus(),esip.getDescription(),esip.getProcessAmount(),esip.getInvestmentDays()));

			}

			org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil

					.getCSVByteStream(Arrays.asList("Code","Store Name","Fofo Id","Item Id","Brand","Model Name",

							"Model Number","Color","Scheme In Dp","Scheme Out Dp","Scheme Id",

							"Name","Type","Partner Type","Amount Type","Amount","Purchase Invoice","Sale Inovoice",

							"Paid Amount","Create Timestamp","Rolled Back Timestamp",

							"Serial Number","In Ref","Out Ref","Business Date","Status","Description","Process Amount","Investment Days"), rows);

			final HttpHeaders headers = new HttpHeaders();

			headers.set("Content-Type", "text/csv");

			headers.set("Content-disposition", "inline; filename=schemePayout.csv");

			headers.setContentLength(baos.toByteArray().length);

			final InputStream inputStream = new ByteArrayInputStream(baos.toByteArray());

			final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);

			return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);

		}