WebSVN – SmartDukaan – Diff – /trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/SchemeController.java

 import java.io.InputStream;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.time.Month;
+import java.time.YearMonth;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 	@Autowired
 	private StateGstRateRepository stateGstRateRepository;
 	@Autowired
 	private ItemRepository itemRepository;
 	@Autowired
 	private ReporticoService reporticoService;
 	@Autowired
 	private SchemeRepository schemeRepository;
 	@Autowired
 	private RetailerService retailerService;
 	@Autowired
 	private Mongo mongoClient;
 	@Autowired
 	WalletService walletService;
 	@Autowired
 	PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
 	@Autowired
 	private PartnerTypeChangeService partnerTypeChangeService;
 	@Autowired
 	InventoryItemRepository inventoryItemRepository;
 	@Autowired
 	SchemeInOutRepository schemeInOutRepository;
 	@RequestMapping(value = "/createScheme", method = RequestMethod.GET)
 	public String createScheme(HttpServletRequest request, Model model) {
 		LocalDate currentdate = LocalDate.now();
 		Month month = currentdate.getMonth().minus(1);
 		model.addAttribute("month", month);
 		// Map<Integer, String> itemIdItemDescriptionMap =
 		// inventoryService.getAllItemIdItemDescriptionMap();
 		// model.addAttribute("itemIdItemDescriptionMap", itemIdItemDescriptionMap);
 		Set<String> brands = inventoryService.getAllTagListingBrands(ProfitMandiConstants.MOBILE_CATEGORY_ID);
 		brands.addAll(inventoryService.getAllTagListingBrands(14206));
 		model.addAttribute("brands", brands);
 		model.addAttribute("retailerTypes", PartnerType.values());
 		return "create-scheme";
+	}
 	@RequestMapping(value = "/getTagListingItemsByBrand", method = RequestMethod.POST)
 	public String getTagListingItemsByBrand(HttpServletRequest request, @RequestBody List<String> brands, Model model) {
 		Map<Integer, String> itemIdItemDescriptionMap = new HashMap<>();
 		LOGGER.info("brands" + brands);
 		if (!roleManager.isAdmin(loginDetails.getRoleIds())) {
 			throw new ProfitMandiBusinessException("User", loginDetails.getEmailId(), "Unauthorised access");
+		}
 		return "update-schemes-page";
+	}
 	@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
 				.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())
+		if (schemeInOuts.isEmpty()) {
-		{
-			throw new ProfitMandiBusinessException("Investment Payout", "",
+			throw new ProfitMandiBusinessException("Investment Payout", "", "No data Found");
-					"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())));
 					: 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) {
+			for (SchemeInOut sio : schemeInouts) {
 				if (investmentMaintainedDays < 8) {
 					sio.setStatus(SchemePayoutStatus.REJECTED);
-					//sio.setRolledBackTimestamp(LocalDateTime.now());
+					// 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.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) {
+			if (totalAmount > 0) {
+				String description = "Investment margin paid for "
-				String description = "Investment margin paid for " + FormattingUtils.formatYearMonth(startOfPreviousMonth.atStartOfDay());
+						+ FormattingUtils.formatYearMonth(startOfPreviousMonth.atStartOfDay());
-				if(investmentMaintainedDays < 12) {
+				if (investmentMaintainedDays < 12) {
-					description += ", as maintained for " + investmentMaintainedDays  + "(< 12) days";
+					description += ", as maintained for " + investmentMaintainedDays + "(< 12) days";
+				}
-				walletService.addAmountToWallet(fofoId,referenceId, WalletReferenceType.INVESTMENT_PAYOUT,  description, totalAmount, lastOfPreviousMonth.atTime(LocalTime.MAX));
+				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 {
+	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
 				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);
+			CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
-			 rows.add(Arrays.asList(fofoId,customRetailer.getBusinessName(),customRetailer.getCode(),investmentMaintainedDays,totalAmount));
+			rows.add(Arrays.asList(fofoId, customRetailer.getBusinessName(), customRetailer.getCode(),
+					investmentMaintainedDays, totalAmount));
 		}
-				org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil
+		org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil.getCSVByteStream(
-				.getCSVByteStream(Arrays.asList("fofoId","Name", "Code", "investmentMaintainedDays","totalAmount"), rows);
+				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 {
+	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<>();
+		Map<String, String> params = new HashMap<>();
-			params.put("MANUAL_datesBetween_FROMDATE",firstDateOfCurrentMonth.toString());
+		params.put("MANUAL_datesBetween_FROMDATE", firstDateOfCurrentMonth.toString());
-			params.put("MANUAL_datesBetween_TODATE",firstDateOfCurrentMonth.plusDays(9).toString());
+		params.put("MANUAL_datesBetween_TODATE", firstDateOfCurrentMonth.plusDays(9).toString());
-			params.put("type","INVESTMENT");
+		params.put("type", "INVESTMENT");
-			List<EvaluateSchemeInvestmentPayoutModel> evaluateSchemeInvestmentPayouts = reporticoService.getReports(EvaluateSchemeInvestmentPayoutModel.class,
+		List<EvaluateSchemeInvestmentPayoutModel> evaluateSchemeInvestmentPayouts = reporticoService.getReports(
-					ReporticoProject.FOCO, "schemepayout.xml", params);
+				EvaluateSchemeInvestmentPayoutModel.class, ReporticoProject.FOCO, "schemepayout.xml", params);
-			LOGGER.info("reportResponse {}", evaluateSchemeInvestmentPayouts);
+		LOGGER.info("reportResponse {}", evaluateSchemeInvestmentPayouts);
-			int referenceId = Integer.parseInt(FormattingUtils.getYearMonth(startOfPreviousMonth.atStartOfDay()));
+		int referenceId = Integer.parseInt(FormattingUtils.getYearMonth(startOfPreviousMonth.atStartOfDay()));
-		  List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository
+		List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository
-					.selectAll(startOfPreviousMonth, lastOfPreviousMonth);
+				.selectAll(startOfPreviousMonth, lastOfPreviousMonth);
-			Map<Integer, Long> investmentMaintainedDaysMap = partnerDailyInvestments.stream()
+		Map<Integer, Long> investmentMaintainedDaysMap = partnerDailyInvestments.stream()
-					.filter(x -> x.getShortPercentage() <= 10)
+				.filter(x -> x.getShortPercentage() <= 10)
-					.collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.counting()));
+				.collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.counting()));
-			for (EvaluateSchemeInvestmentPayoutModel esip : evaluateSchemeInvestmentPayouts) {
+		for (EvaluateSchemeInvestmentPayoutModel esip : evaluateSchemeInvestmentPayouts) {
-				long investmentMaintainedDays = investmentMaintainedDaysMap.get(esip.getFofoId()) == null ? 0
+			long investmentMaintainedDays = investmentMaintainedDaysMap.get(esip.getFofoId()) == null ? 0
-						: investmentMaintainedDaysMap.get(esip.getFofoId());
+					: investmentMaintainedDaysMap.get(esip.getFofoId());
-				esip.setInvestmentDays(investmentMaintainedDays);
+			esip.setInvestmentDays(investmentMaintainedDays);
-				float processAmount = esip.getPaidAmount()/2;
+			float processAmount = esip.getPaidAmount() / 2;
-				esip.setProcessAmount(processAmount);
+			esip.setProcessAmount(processAmount);
-				rows.add(Arrays.asList(esip.getCode(),esip.getStoreName(),esip.getFofoId(),esip.getItemId(),esip.getBrand(),esip.getModelName(),esip.getModelNumber(),
+			rows.add(Arrays.asList(esip.getCode(), esip.getStoreName(), esip.getFofoId(), esip.getItemId(),
-						esip.getColor(),esip.getSchemeInDp(),esip.getSchemeOutDp(),esip.getSchemeId(),
+					esip.getBrand(), esip.getModelName(), esip.getModelNumber(), esip.getColor(), esip.getSchemeInDp(),
-						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()));
+					esip.getSchemeOutDp(), esip.getSchemeId(), esip.getName(), esip.getType(), esip.getPartnerType(),
-			}
-			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",
+					esip.getAmountType(), esip.getAmount(), esip.getPurchaseInvoice(), esip.getSaleInovoice(),
-							"Paid Amount","Create Timestamp","Rolled Back Timestamp",
+					esip.getPaidAmount(), esip.getCreateTimestamp(), esip.getRolledBackTimestamp(),
-							"Serial Number","In Ref","Out Ref","Business Date","Status","Description","Process Amount","Investment Days"), rows);
+					esip.getSerialNumber(), esip.getInRef(), esip.getOutRef(), esip.getBusinessDate(), esip.getStatus(),
-			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());
+					esip.getDescription(), esip.getProcessAmount(), esip.getInvestmentDays()));
-			final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
-			return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
+		}
+		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);
+	}
 	@RequestMapping(value = "/schemes/update", method = RequestMethod.POST)
 	public String updateShcemes(HttpServletRequest request, @RequestBody SchemeItems schemeItems, Model model)
 			throws Exception {
 		for (int schemeId : schemeItems.getSchemeIds()) {
 			if (schemeRepository.selectById(schemeId) != null)
 					if (tagListingRepository.selectByItemIdsAndTagIds(new HashSet<>(Arrays.asList(itemId)),
 							new HashSet<>(Arrays.asList(4, 7))).size() > 0) {
 						SchemeItem si = new SchemeItem();
 						si.setItemId(itemId);
 						si.setSchemeId(schemeId);
+						si.setCreateTimestamp(LocalDateTime.now());
 						try {
 							schemeItemRepository.persist(si);
 						} catch (Exception e) {
 							LOGGER.info("Scheme aleady exist");
+						}
 					if (tagListingRepository.selectByItemIdsAndTagIds(new HashSet<>(Arrays.asList(itemId)),
 							new HashSet<>(Arrays.asList(4, 7))).size() > 0 && (!(itemIds.contains(itemId)))) {
 						SchemeItem si = new SchemeItem();
 						si.setItemId(itemId);
 						si.setSchemeId(schemeId);
+						si.setCreateTimestamp(LocalDateTime.now());
 						try {
 							schemeItemRepository.persist(si);
 						} catch (Exception e) {
 							LOGGER.info("Scheme already exist");
+						}
 		List<SchemeInOut> schemeInOut = null;
 		long size = 0;
 		date = date.isAfter(LocalDate.now()) ? LocalDate.now() : date;
 		if (partnerType == null) {
-			//TODO - SCHEME
+			// TODO - SCHEME
-			/*
-			 * partnerType =
-			 * partnerTypeChangeService.getTypeOnMonth(loginDetails.getFofoId(),
+			partnerType = partnerTypeChangeService.getTypeOnMonth(loginDetails.getFofoId(), YearMonth.from(date));
-			 * YearMonth.of(date.getYear(), date.getMonth()));
-			 */
+			// partnerType =
-			partnerType = partnerTypeChangeService.getTypeOnDate(loginDetails.getFofoId(), date);
+			// partnerTypeChangeService.getTypeOnDate(loginDetails.getFofoId(), date);
+		}
 		if (!(searchTerm.equals(""))) {
 			schemes = schemeRepository.selectBySearchTerm(searchTerm, offset, limit);
 			for (Scheme scheme : schemes) {
 				if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/SchemeController.java – Rev 29585 → 29608