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

 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.InputStream;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
+import java.time.YearMonth;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
-import java.util.stream.Collectors;
 import javax.servlet.http.HttpServletRequest;
 import javax.transaction.Transactional;
 import org.apache.logging.log4j.LogManager;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
-import com.google.gson.Gson;
 import com.spice.profitmandi.common.enumuration.DateTimePattern;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
-import com.spice.profitmandi.common.model.CustomRetailer;
 import com.spice.profitmandi.common.model.MapWrapper;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.model.SchemeItems;
 import com.spice.profitmandi.common.model.SchemeModel;
 import com.spice.profitmandi.common.util.ExcelUtils;
 import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.common.util.StringUtils;
 import com.spice.profitmandi.common.web.util.ResponseSender;
-import com.spice.profitmandi.dao.entity.catalog.Item;
-import com.spice.profitmandi.dao.entity.catalog.Offer;
 import com.spice.profitmandi.dao.entity.catalog.Scheme;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
 import com.spice.profitmandi.dao.entity.fofo.PartnerType;
 import com.spice.profitmandi.dao.entity.fofo.SchemeItem;
 import com.spice.profitmandi.dao.enumuration.catalog.AmountType;
-import com.spice.profitmandi.dao.enumuration.catalog.ItemCriteriaType;
+import com.spice.profitmandi.dao.model.CreateOfferRequest;
 import com.spice.profitmandi.dao.model.CreateSchemeRequest;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.SchemeRepository;
 import com.spice.profitmandi.dao.repository.catalog.StateGstRateRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
-import com.spice.profitmandi.dao.repository.dtr.RoleRepository;
 import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
-import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
 import com.spice.profitmandi.dao.repository.fofo.SchemeItemRepository;
 import com.spice.profitmandi.service.authentication.RoleManager;
 import com.spice.profitmandi.service.inventory.InventoryService;
+import com.spice.profitmandi.service.offers.OfferService;
 import com.spice.profitmandi.service.scheme.SchemeService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.web.model.LoginDetails;
 import com.spice.profitmandi.web.util.CookiesProcessor;
 import com.spice.profitmandi.web.util.MVCResponseSender;
 	private static final Logger LOGGER = LogManager.getLogger(SchemeController.class);
 	@Autowired
 	private SchemeService schemeService;
+	@Autowired
+	private OfferService offerService;
 	@Autowired
 	private StateGstRateRepository stateGstRateRepository;
 	@Autowired
+	}
 	@RequestMapping(value = "/getSchemes", method = RequestMethod.GET)
 	public String getSchemes(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset,
+			@RequestParam(required = false) LocalDate date,
 			@RequestParam(name = "limit", defaultValue = "10") int limit,
 			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem,
 			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm,
 			@RequestParam(name = "partnerType", required = false, defaultValue = "") PartnerType partnerType,
 			Model model) throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
+		if (date == null) {
+			date = LocalDate.now();
+		}
+		model.addAttribute("date", date);
-		model.addAttribute("searchItem", searchItem);
-		model.addAttribute("searchTerm", searchTerm);
-		model.addAttribute("partnerType", partnerType);
-		model.addAttribute("roleType", isAdmin);
-		LOGGER.info("isAdmin" + isAdmin);
 		List<Scheme> schemes = null;
 		long size = 0;
-		LOGGER.info("partnerType" + partnerType);
 		if (partnerType == null) {
-			partnerType = partnerTypeChangeService.getTypeOnDate(loginDetails.getFofoId(), LocalDate.now());
+			partnerType = partnerTypeChangeService.getTypeOnDate(loginDetails.getFofoId(),
+					date.isAfter(LocalDate.now()) ? LocalDate.now() : date);
+		}
 		if (!(searchTerm.equals(""))) {
 			schemes = schemeRepository.selectBySearchTerm(searchTerm, offset, limit);
 			for (Scheme scheme : schemes) {
 				if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {
 					scheme.setAmountModel(scheme.getAmount() + "%");
 				} else {
 					scheme.setAmountModel(scheme.getAmount() + "");
+				}
+			}
-			if (!(schemes.size() == 0)) {
+			if (schemes.size() > 0) {
 				size = schemeRepository.selectAllCount();
 				LOGGER.info("schemes" + schemes);
 				model.addAttribute("schemes", schemes);
 				model.addAttribute("start", offset + 1);
 				model.addAttribute("size", size);
 				if (schemes.size() < limit) {
 					model.addAttribute("end", offset + schemes.size());
-				}
-				else {
+				} else {
 					model.addAttribute("end", offset + limit);
+				}
+			}
 			else {
 				if (tagListing != null) {
 					model.addAttribute("dp", tagListing.getSellingPrice());
 					model.addAttribute("mop", tagListing.getMop());
+				}
+			}
-			schemes = schemeService.selectSchemeByPartnerType(partnerType, itemId, isAdmin, offset, limit);
+			schemes = schemeService.selectSchemeByPartnerType(partnerType, date, itemId, isAdmin, offset, limit);
 			model.addAttribute("schemes", schemes);
 			if (schemes.size() == 0) {
 				return "schemes";
+			}
 						scheme.setAmountModel(scheme.getAmount() + "%");
+					}
 				} else {
 					scheme.setAmountModel(scheme.getAmount() + "");
+				}
+			}
-			size = schemeService.selectSchemeCount(partnerType, itemId, isAdmin);
+			size = schemeService.selectSchemeCount(partnerType, date, itemId, isAdmin);
 			model.addAttribute("start", offset + 1);
 			model.addAttribute("size", size);
 			if (schemes.size() < limit) {
 				model.addAttribute("end", offset + schemes.size());
 			} else {
 				model.addAttribute("end", offset + limit);
+			}
+		}
+		model.addAttribute("searchItem", searchItem);
+		model.addAttribute("searchTerm", searchTerm);
+		model.addAttribute("partnerType", partnerType);
+		model.addAttribute("isAdmin", isAdmin);
 		model.addAttribute("schemes", schemes);
-		LOGGER.info("schemes"+schemes);
+		LOGGER.info("schemes" + schemes);
 		// model.addAttribute("roleTypes", loginDetails.getRoleTypes());
+		if (isAdmin)
-		return "schemes";
+			return "schemes";
+		else {
+			List<CreateOfferRequest> offers = offerService.getPublishedOffers(date, loginDetails.getFofoId(), Integer.parseInt(searchItem));
+			model.addAttribute("offers", offers);
+			return "schemes-partner";
+		}
+	}
 	@RequestMapping(value = "/getPaginatedSchemes", method = RequestMethod.GET)
-	public String getPaginatedSchemes(HttpServletRequest request,
+	public String getPaginatedSchemes(HttpServletRequest request, @RequestParam(required = false) LocalDate date,
 			@RequestParam(name = "offset", defaultValue = "0") int offset,
 			@RequestParam(name = "limit", defaultValue = "10") int limit,
-			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem,
-			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm,
-			@RequestParam(name = "partnerType", required = false, defaultValue = "") PartnerType partnerType,
+			@RequestParam(name = "partnerType", required = false, defaultValue = "ALL") PartnerType partnerType,
 			Model model) throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
-		LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
-		List<Scheme> schemes = null;
-		/*
-		 * if (roleManager.isAdmin(loginDetails.getRoleIds())) { schemes =
-		 * schemeRepository.selectAll(offset, limit); } else { schemes =
-		 * schemeRepository.selectActiveAll(offset, limit); }
-		 */
-		if (partnerType == null) {
+		if (date == null) {
-			partnerType = partnerTypeChangeService.getTypeOnDate(loginDetails.getFofoId(), LocalDate.now());
+			date = LocalDate.now();
+		}
-		LOGGER.info("partnerType" + partnerType);
+		LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
+		List<Scheme> schemes = schemeRepository.selectAll();
 		int itemId = 0;
 		TagListing tagListing = null;
-		if (!(searchItem.equals(""))) {
-			itemId = Integer.parseInt(searchItem);
-			tagListing = tagListingRepository.selectByItemId(itemId);
-		}
-		schemes = schemeService.selectSchemeByPartnerType(partnerType, itemId, isAdmin, offset, limit);
 		for (Scheme scheme : schemes) {
 			if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {
 				if (itemId > 0) {
 					float taxRate = stateGstRateRepository.getIgstTaxRate(Arrays.asList(itemId)).get(itemId);
 					float taxableSellingPrice = tagListing.getSellingPrice() / (1 + taxRate / 100);
 							FormattingUtils.formatDecimalTwoDigits(amount) + " (" + scheme.getAmount() + "%)");
 				} else {
 					scheme.setAmountModel(scheme.getAmount() + "%");
+				}
 			} else {
-				scheme.setAmountModel("₹" + scheme.getAmount());
+				scheme.setAmountModel("" + scheme.getAmount());
+			}
+		}
 		model.addAttribute("schemes", schemes);
 		model.addAttribute("partnerType", partnerType);
 		headers.set("Content-disposition", "inline; filename=SchemesReport.xlsx");
 		headers.setContentLength(byteArrayOutputStream.toByteArray().length);
 		final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
 		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
 		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
-		// return responseSender.ok(ResponseCodeHolder.getMessage("ITM_AGNG_OK_1000"));
+	}
 	@RequestMapping(value = "/getSchemeById", method = RequestMethod.GET)
 	public String getSchemeById(HttpServletRequest request,
 			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId, Model model)

Subversion Repositories SmartDukaan

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