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

 	@Autowired
 	private FofoStoreRepository fofoStoreRepository;
 	@Autowired
+	private OfferPayoutRepository offerPayoutRepository;
+	@Autowired
 	private RetailerService retailerService;
 	@Autowired
 	private Mongo mongoClient;
+	}
 	@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";
 		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;
 		} else if (org.apache.commons.lang3.StringUtils.isNotEmpty(searchImei)) {
 			LOGGER.info("searchImei" + searchImei);
-			InventoryItem inventoryItem = inventoryItemRepository.selectBySerialNumber(searchImei);
+			InventoryItem inventoryItem = inventoryItemRepository.selectBySerialNumberFofoId(searchImei,
+					loginDetails.getFofoId());
 			Item item = itemRepository.selectById(inventoryItem.getItemId());
 			Map<Integer, Scheme> schemeMap = new HashMap<>();
+			double netEarnings = 0;
 			if (inventoryItem != null) {
+				//Offer payout
+				List<OfferPayout> offerPayouts = offerPayoutRepository.selectAllBySerialNumber(loginDetails.getFofoId(), searchImei);
+				Map<Integer, CreateOfferRequest> offerRequestMap = offerPayouts.stream().map(x -> offerService.getOffer(loginDetails.getFofoId(), (int) x.getOfferId())).collect(Collectors.toMap(x -> x.getId(), x -> x));
-				LOGGER.info("inventoryItem" + inventoryItem);
-				schemeInOut = schemeInOutRepository
-						.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItem.getId())));
+				schemeInOut = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItem.getId())));
-				LOGGER.info("schemeInOut" + schemeInOut);
 				if (!schemeInOut.isEmpty()) {
-					List<Integer> schemeIds = schemeInOut.stream().map(x -> x.getSchemeId())
+					List<Integer> schemeIds = schemeInOut.stream().map(x -> x.getSchemeId()).collect(Collectors.toList());
-							.collect(Collectors.toList());
 					schemes = schemeRepository.selectBySchemeIds(schemeIds);
 					for (Scheme scheme : schemes) {
 						if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {
 							scheme.setAmountModel(scheme.getAmount() + "%");
+						}
+					}
 					schemeMap = schemes.stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
+				}
+				List<PriceDropIMEI> priceDropImeis = priceDropIMEIRepository
+						.selectByFofoIdImei(loginDetails.getFofoId(), searchImei);
+				if (priceDropImeis.size() > 0) {
+					for (PriceDropIMEI priceDropIMEI : priceDropImeis) {
+						int priceDropId = priceDropIMEI.getPriceDropId();
+						PriceDrop pd = priceDropRepository.selectById(priceDropId);
+						priceDropIMEI.setPriceDrop(pd);
+					}
+					model.addAttribute("priceDropImeis", priceDropImeis);
+				}
+				model.addAttribute("offerPayouts", offerPayouts);
+				model.addAttribute("offerRequestMap", offerRequestMap);
+				model.addAttribute("inventoryItem", inventoryItem);
+				model.addAttribute("inventoryItem", inventoryItem);
+			}
+			model.addAttribute("netEarnings", netEarnings);
 			model.addAttribute("fofoId", loginDetails.getFofoId());
 			model.addAttribute("schemeMap", schemeMap);
 			model.addAttribute("item", item);
 			model.addAttribute("schemeInOut", schemeInOut);
 			return "schemes-partner";
 		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();
 		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 30599 → 30651