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

 	@Autowired
 	private CategoryRepository categoryRepository;
 	List<String> adminEmail = Arrays.asList("tarun.verma@smartdukaan.com", "neeraj.gupta@smartdukaan.com",
-			"amit.gupta@smartdukaan.com", "tejbeer.kaur@smartdukaan.com");
+			"amit.gupta@smartdukaan.com", "tejbeer.kaur@smartdukaan.com", "raksha.vyas@smartdukaan.com");
 	@RequestMapping(value = "/createScheme", method = RequestMethod.GET)
 	public String createScheme(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+	}
 	@RequestMapping(value = "/getCatalogDescriptionByBrands", method = RequestMethod.GET)
 	public String getTagListingItemsByBrand(HttpServletRequest request, @RequestParam int categoryId,
-											@RequestParam List<String> brands, Model model) throws Exception {
+			@RequestParam List<String> brands, Model model) throws Exception {
 		Map<Integer, String> catalogIdItemDescriptionMap = inventoryService.getModelDescriptionMap(categoryId, brands);
 		model.addAttribute("catalogIdItemDescriptionMap", catalogIdItemDescriptionMap);
 		// model.addAttribute("brands", inventoryService.getAllBrands());
 		return "tag-listing-items-description";
 			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)
-					.flatMap(List::stream).filter(x -> x.getStatus().equals(SchemePayoutStatus.PENDING) && x.getRolledBackTimestamp() == null).collect(Collectors.toList());
+					.filter(x -> x.getStatus().equals(SchemePayoutStatus.PENDING) && x.getRolledBackTimestamp() == null)
+					.collect(Collectors.toList());
 			float totalAmount = 0;
 			LocalDateTime firstBillingDate = transactionRepository.getFirstBillingDate(fofoId);
-			boolean sameYearMonth = firstBillingDate.getMonth() == startOfPreviousMonth.getMonth() && firstBillingDate.getYear() == startOfPreviousMonth.getYear();
+			boolean sameYearMonth = firstBillingDate.getMonth() == startOfPreviousMonth.getMonth()
+					&& firstBillingDate.getYear() == startOfPreviousMonth.getYear();
 			for (SchemeInOut sio : schemeInouts) {
 				if (sameYearMonth) {
 					sio.setStatusDescription("Investment payout fully disbursed for first month");
 					sio.setStatus(SchemePayoutStatus.CREDITED);
 					sio.setCreditTimestamp(LocalDateTime.now());
 					totalAmount += sio.getAmount();
 				} else {
 					if (investmentMaintainedDays < 8) {
 						sio.setStatus(SchemePayoutStatus.REJECTED);
-						//sio.setRolledBackTimestamp(LocalDateTime.now());
+						// sio.setRolledBackTimestamp(LocalDateTime.now());
+						sio.setStatusDescription(
-						sio.setStatusDescription("Investment maintained for " + investmentMaintainedDays + "(< 8) days");
+								"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(
-						sio.setStatusDescription("Investment maintained for " + investmentMaintainedDays + "(< 12) days");
+								"Investment maintained for " + investmentMaintainedDays + "(< 12) days");
 						totalAmount += sio.getAmount();
 					} else {
 						sio.setStatus(SchemePayoutStatus.CREDITED);
 						sio.setCreditTimestamp(LocalDateTime.now());
 						totalAmount += sio.getAmount();
 					description += ", as maintained for " + investmentMaintainedDays + "(< 12) days";
+				}
 				walletService.addAmountToWallet(fofoId, referenceId, WalletReferenceType.INVESTMENT_PAYOUT, description,
 						totalAmount, lastOfPreviousMonth.atTime(LocalTime.MAX));
+			}
-			//Its ok to process Margins Pending for activation
+			// Its ok to process Margins Pending for activation
 			schemeService.processActivation();
 			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 {
 		return "response";
+	}
 	@RequestMapping(value = "/schemes/delete", method = RequestMethod.DELETE)
 	public String deleteShcemes(HttpServletRequest request,
-								@RequestParam(name = "schemeId", required = false, defaultValue = "0") int schemeId,
+			@RequestParam(name = "schemeId", required = false, defaultValue = "0") int schemeId,
-								@RequestParam(name = "catalogId", required = false, defaultValue = "0") int catalogId, Model model)
+			@RequestParam(name = "catalogId", required = false, defaultValue = "0") int catalogId, Model model)
 			throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		if (schemeId > 0 && catalogId > 0) {
 			schemeItemRepository.deleteByCatalogIdsAndSchemeIds(catalogId, schemeId);
+	}
 	@RequestMapping(value = "/extendSchemeById", method = RequestMethod.POST)
 	public String extendSchemeById(HttpServletRequest request,
-								   @RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
+			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
-								   @RequestBody LocalDateTime extendDatetime, Model model) throws Exception {
+			@RequestBody LocalDateTime extendDatetime, Model model) throws Exception {
 		Scheme scheme = schemeRepository.selectById(schemeId);
 		if ((!(scheme.getActiveTimestamp() == null)) && scheme.getExpireTimestamp() == null) {
 			scheme.setEndDateTime(extendDatetime);
 			schemeRepository.persist(scheme);
 			model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
 	@RequestMapping(value = "/createScheme", method = RequestMethod.POST)
 	public String createScheme(HttpServletRequest request, @RequestBody CreateSchemeRequest createSchemeRequest,
-							   Model model) throws ProfitMandiBusinessException {
+			Model model) throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		LOGGER.info("CreateSchemeRequest {}", createSchemeRequest);
 		schemeService.saveScheme(loginDetails.getFofoId(), createSchemeRequest);
 		return getDefaultSchemes(request, model);
+	}
+	}
 	// Show 20 recents
 	@RequestMapping(value = "/getSchemes", method = RequestMethod.GET)
 	public String getSchemes(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset,
-							 @RequestParam(required = false) LocalDate date,
+			@RequestParam(required = false) LocalDate date,
-							 @RequestParam(name = "limit", required = false, defaultValue = "30") int limit,
+			@RequestParam(name = "limit", required = false, defaultValue = "30") int limit,
-							 @RequestParam(name = "searchModel", required = false, defaultValue = "0") int searchModel,
+			@RequestParam(name = "searchModel", required = false, defaultValue = "0") int searchModel,
-							 @RequestParam(name = "searchScheme", required = false, defaultValue = "0") int searchScheme,
+			@RequestParam(name = "searchScheme", required = false, defaultValue = "0") int searchScheme,
-							 @RequestParam(name = "partnerType", required = false, defaultValue = "ALL") PartnerType partnerType,
+			@RequestParam(name = "partnerType", required = false, defaultValue = "ALL") PartnerType partnerType,
-							 @RequestParam(name = "searchImei", required = false, defaultValue = "") String searchImei, Model model)
+			@RequestParam(name = "searchImei", required = false, defaultValue = "") String searchImei, Model model)
 			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
 		if (date != null) {
 			date = date.isAfter(LocalDate.now()) ? LocalDate.now() : date;
 					loginDetails.getFofoId());
 			Item item = itemRepository.selectById(inventoryItem.getItemId());
 			Map<Integer, Scheme> schemeMap = new HashMap<>();
 			double netEarnings = 0;
 			if (inventoryItem != null) {
-				//Offer payout
+				// Offer payout
-				List<OfferPayout> offerPayouts = offerPayoutRepository.selectAllBySerialNumber(loginDetails.getFofoId(), searchImei);
+				List<OfferPayout> offerPayouts = offerPayoutRepository.selectAllBySerialNumber(loginDetails.getFofoId(),
+						searchImei);
+				Map<Integer, CreateOfferRequest> offerRequestMap = offerPayouts.stream()
-				Map<Integer, CreateOfferRequest> offerRequestMap = offerPayouts.stream().map(x -> offerService.getOffer(loginDetails.getFofoId(), (int) x.getOfferId())).collect(Collectors.toMap(x -> x.getId(), x -> x));
+						.map(x -> offerService.getOffer(loginDetails.getFofoId(), (int) x.getOfferId()))
+						.collect(Collectors.toMap(x -> x.getId(), x -> x));
+				schemeInOuts = schemeInOutRepository
-				schemeInOuts = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItem.getId())));
+						.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItem.getId())));
 				if (!schemeInOuts.isEmpty()) {
-					netEarnings += schemeInOuts.stream().filter(x -> x.getStatus().equals(SchemePayoutStatus.CREDITED)).collect(Collectors.summingDouble(x -> x.getAmount()));
+					netEarnings += schemeInOuts.stream().filter(x -> x.getStatus().equals(SchemePayoutStatus.CREDITED))
+							.collect(Collectors.summingDouble(x -> x.getAmount()));
-					List<Integer> schemeIds = schemeInOuts.stream().map(x -> x.getSchemeId()).collect(Collectors.toList());
+					List<Integer> schemeIds = schemeInOuts.stream().map(x -> x.getSchemeId())
+							.collect(Collectors.toList());
 					schemes = schemeRepository.selectBySchemeIds(schemeIds);
 					for (Scheme scheme : schemes) {
 						if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {
 							scheme.setAmountModel(scheme.getAmount() + "%");
 		return "last-month-credited-income";
+	}
 	@RequestMapping(value = "/getLastMonthImeiWiseIncome", method = RequestMethod.GET)
 	public String getLastMonthImeiWiseIncome(HttpServletRequest request,
-											 @RequestParam(name = "catalogItemId", required = false, defaultValue = "") int catalogItemId,
+			@RequestParam(name = "catalogItemId", required = false, defaultValue = "") int catalogItemId,
-											 @RequestParam(name = "month", required = false, defaultValue = "") int month, Model model)
+			@RequestParam(name = "month", required = false, defaultValue = "") int month, Model model)
 			throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		LocalDateTime lastMonthStart = LocalDate.now().minusMonths(month).withDayOfMonth(1).atStartOfDay();
 		LOGGER.info("lastMonthFrontEndImei {}", lastMonthFrontEndImeis);
 		LOGGER.info("lastMonthPurchaseInImei {}", lastMonthPurchaseInImeis);
 		LOGGER.info("lastMonthCreditedImei {}", lastMonthCreditedImeis);
 		Map<String, Double> imeiWisePendingSaleAmount = lastMonthCreditedImeis.stream()
-				.filter(x -> x.getStatus().equals(SchemePayoutStatus.PENDING))
+				.filter(x -> x.getStatus().equals(SchemePayoutStatus.PENDING)).collect(Collectors
-				.collect(Collectors.groupingBy(x -> x.getImei(), Collectors.summingDouble(x -> x.getPendingSaleAmount())));
+						.groupingBy(x -> x.getImei(), Collectors.summingDouble(x -> x.getPendingSaleAmount())));
 		Map<IncomeImeiDate, Map<String, Double>> lastMonthPurchaseInMapPairMap = lastMonthPurchaseInImeis.stream()
 				.collect(Collectors.groupingBy(x -> new IncomeImeiDate(x.getImei(), x.getCreateTimeStamp()),
 						Collectors.groupingBy(x -> x.getDescription(), Collectors.summingDouble(x -> x.getAmount()))));
 		return "last-month-imei-wise-income";
+	}
 	@RequestMapping(value = "/brandWiseIncome", method = RequestMethod.GET)
 	public String getBrandWiseIncome(HttpServletRequest request,
-									 @RequestParam(name = "brand", required = false, defaultValue = "") String brand,
+			@RequestParam(name = "brand", required = false, defaultValue = "") String brand,
-									 @RequestParam(name = "status", required = false, defaultValue = "") String status,
+			@RequestParam(name = "status", required = false, defaultValue = "") String status,
-									 @RequestParam(name = "month", required = false, defaultValue = "") int month, Model model)
+			@RequestParam(name = "month", required = false, defaultValue = "") int month, Model model)
 			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		LOGGER.info("loginDetails {}", loginDetails);
 		LOGGER.info("brand" + brand);
 		LOGGER.info("month {}", month);
 		return "schemes-download";
+	}
 	@RequestMapping(value = "/schemes/download", method = RequestMethod.GET)
 	public ResponseEntity<?> downloadInventoryItemAgingByInterval(HttpServletRequest request,
-																  @RequestParam LocalDateTime startDateTime, @RequestParam LocalDateTime endDateTime)
+			@RequestParam LocalDateTime startDateTime, @RequestParam LocalDateTime endDateTime)
 			throws ProfitMandiBusinessException {
 		List<SchemeModel> schemeModels = schemeService.getAllSchemeModels(startDateTime, endDateTime);
 		ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
 		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
+	}
 	@RequestMapping(value = "/getSchemeById", method = RequestMethod.GET)
 	public String getSchemeById(HttpServletRequest request,
-								@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId, Model model)
+			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId, Model model)
 			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		boolean fullAccess = this.getAccess(loginDetails.getEmailId());
 		Scheme scheme = schemeService.getSchemeById(schemeId);
 		return "scheme-details";
+	}
 	@RequestMapping(value = "/activeSchemeById", method = RequestMethod.PUT)
 	public String activeSchemeById(HttpServletRequest request,
-								   @RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
+			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
-								   @RequestParam(name = "offset", defaultValue = "0") int offset,
+			@RequestParam(name = "offset", defaultValue = "0") int offset,
-								   @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
 			throws ProfitMandiBusinessException {
 		schemeService.activeSchemeById(schemeId);
 		List<Scheme> schemes = schemeRepository.selectAll(offset, limit);
 		for (Scheme scheme : schemes) {
 			if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {
 		return "schemes";
+	}
 	@RequestMapping(value = "/expireSchemeById", method = RequestMethod.PUT)
 	public String expireSchemeById(HttpServletRequest request,
-								   @RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
+			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
-								   @RequestParam(name = ProfitMandiConstants.EXPIRE_TIMESTAMP) LocalDateTime expiryTimestamp, Model model)
+			@RequestParam(name = ProfitMandiConstants.EXPIRE_TIMESTAMP) LocalDateTime expiryTimestamp, Model model)
 			throws ProfitMandiBusinessException {
 		schemeService.expireSchemeById(schemeId, expiryTimestamp);
 		return getDefaultSchemes(request, model);
+	}
 	@RequestMapping(value = "/getSchemesJson", method = RequestMethod.GET)
 	public ResponseEntity<?> getSchemesJson(HttpServletRequest request,
-											@RequestParam(name = "offset", defaultValue = "0") int offset,
+			@RequestParam(name = "offset", defaultValue = "0") int offset,
-											@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
 			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		return responseSender.ok(schemeService.getSchemes(loginDetails.getRoleIds(), offset, limit));
+	}
+	}
 	@RequestMapping(value = "/createCustomerOffer", method = RequestMethod.POST)
 	public String createCustomerOffer(HttpServletRequest request, @RequestParam String offerName,
-									  @RequestParam LocalDateTime startDate, @RequestParam LocalDateTime endDate, Model model) throws Exception {
+			@RequestParam LocalDateTime startDate, @RequestParam LocalDateTime endDate, Model model) throws Exception {
 		CustomerOffer co = new CustomerOffer();
 		co.setOfferName(offerName);
 		co.setStartDate(startDate);
 		co.setEndDate(endDate);
+	}
 	@RequestMapping(value = "/customerOfferItem/upload", method = RequestMethod.POST)
 	public String uploadCustomerOfferItem(HttpServletRequest request, Model model, @RequestParam int offerId,
-										  HttpServletResponse response, @RequestPart MultipartFile file) throws Throwable {
+			HttpServletResponse response, @RequestPart MultipartFile file) throws Throwable {
 		List<CSVRecord> records = FileUtil.readFile(file);
 		for (CSVRecord record : records) {
 			if (Integer.parseInt(record.get(0)) == 0) {
+	}
 	@RequestMapping(value = "/extendCustomerOffer", method = RequestMethod.POST)
 	public String extendCustomerOffer(HttpServletRequest request, @RequestParam int id,
-									  @RequestParam LocalDateTime endDate, Model model) throws ProfitMandiBusinessException {
+			@RequestParam LocalDateTime endDate, Model model) throws ProfitMandiBusinessException {
 		CustomerOffer co = customerOfferRepository.selectById(id);
 		co.setEndDate(endDate);
 		co.setUpdatedTimestamp(LocalDateTime.now());

Subversion Repositories SmartDukaan

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