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

 package com.spice.profitmandi.web.controller;
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.InputStream;
+import java.time.LocalDate;
 import java.time.LocalDateTime;
+import java.time.chrono.ChronoLocalDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.Arrays;
+import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import javax.servlet.http.HttpServletRequest;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.core.io.InputStreamResource;
+import org.springframework.format.annotation.DateTimeFormat;
+import org.springframework.format.annotation.DateTimeFormat.ISO;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Controller;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.RequestParam;
 import com.spice.profitmandi.common.enumuration.DateTimePattern;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.CreateSchemeRequest;
+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.StringUtils;
 	@Qualifier("fofoInventoryService")
 	private InventoryService inventoryService;
 	@Autowired
 	private TagListingRepository tagListingRepository;
 	@Autowired
 	private RoleManager roleManager;
 	@Autowired
 	PurchaseRepository purchaseRepository;
 	@RequestMapping(value = "/createScheme", method = RequestMethod.GET)
 	public String createScheme(HttpServletRequest request, Model model) {
 		// Map<Integer, String> itemIdItemDescriptionMap =
 		// inventoryService.getAllItemIdItemDescriptionMap();
 		// model.addAttribute("itemIdItemDescriptionMap", itemIdItemDescriptionMap);
-		model.addAttribute("brands", inventoryService.getAllTagListingBrands());
+		model.addAttribute("brands", inventoryService.getAllTagListingBrands(ProfitMandiConstants.MOBILE_CATEGORY_ID));
 		return "create-scheme";
+	}
-	@RequestMapping(value = "/getTagListingItemsByBrand", method = RequestMethod.GET)
+	@RequestMapping(value = "/getTagListingItemsByBrand", method = RequestMethod.POST)
-	public String getTagListingItemsByBrand(HttpServletRequest request,
+	public String getTagListingItemsByBrand(HttpServletRequest request, @RequestBody List<String> brands, Model model) {
-			@RequestParam(name = ProfitMandiConstants.BRAND) String brand, Model model) {
+		Map<Integer, String> itemIdItemDescriptionMap = new HashMap<>();
+		LOGGER.info("brands" + brands);
-		Map<Integer, String> itemIdItemDescriptionMap = inventoryService
+		List<MapWrapper<Integer, String>> itemIdItemDescriptionMaplist = inventoryService
-				.getAllTagListingItemIdItemDescriptionMap(brand);
+				.getAllTagListingItemIdItemDescriptionMap(new HashSet<>(brands));
+		for (MapWrapper<Integer, String> mapWrapper : itemIdItemDescriptionMaplist) {
+			itemIdItemDescriptionMap.put(mapWrapper.getKey(), mapWrapper.getValue());
+		}
 		model.addAttribute("itemIdItemDescriptionMap", itemIdItemDescriptionMap);
 		// model.addAttribute("brands", inventoryService.getAllBrands());
 		return "tag-listing-items-description";
+	}
 	@RequestMapping(value = "/schemes/update-schemes-page", method = RequestMethod.GET)
 	public String updateShcemes(HttpServletRequest request) throws ProfitMandiBusinessException {
 	@RequestMapping(value = "/schemes/update", method = RequestMethod.POST)
 	public String updateShcemes(HttpServletRequest request, @RequestBody SchemeItems schemeItems, Model model)
 			throws Exception {
 		for (int schemeId : schemeItems.getSchemeIds()) {
+			List<Integer> itemIds = schemeItemRepository.selectItemIdsBySchemeId(schemeId);
 			if (schemeRepository.selectById(schemeId) != null)
 				for (int itemId : schemeItems.getItemIds()) {
 					if (tagListingRepository.selectByItemIdsAndTagIds(new HashSet<>(Arrays.asList(itemId)),
-							new HashSet<>(Arrays.asList(4, 7))).size() > 0) {
+							new HashSet<>(Arrays.asList(4, 7))).size() > 0 && (!(itemIds.contains(itemId)))) {
 						SchemeItem si = new SchemeItem();
 						si.setItemId(itemId);
 						si.setSchemeId(schemeId);
 						try {
 							schemeItemRepository.persist(si);
 						} catch (Exception e) {
-							LOGGER.info("Scheme aleady exist");
+							LOGGER.info("Scheme already exist");
+						}
 						model.addAttribute("response", mvcResponseSender.createResponseString(true));
 					} else {
 						model.addAttribute("response", mvcResponseSender.createResponseString(false));
-						throw new ProfitMandiBusinessException("ItemId", itemId, "Invalid Item Id");
+					}
+				}
+		}
 		return "response";
+	}
-	@RequestMapping(value = "/schemes/delete", method = RequestMethod.POST)
+	@RequestMapping(value = "/schemes/delete", method = RequestMethod.DELETE)
-	public String deleteShcemes(HttpServletRequest request, @RequestBody SchemeItems schemeItems, Model model)
+	public String deleteShcemes(HttpServletRequest request,
+			@RequestParam(name = "schemeId", required = false, defaultValue = "0") int schemeId,
+			@RequestParam(name = "itemId", required = false, defaultValue = "0") int itemId, Model model)
 			throws Exception {
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		if (!(schemeId == 0 && itemId == 0) || (!(schemeId == 0 || itemId == 0))) {
-		if (schemeItemRepository.selectBySchemeIdsAndItemIds(new HashSet<>(schemeItems.getSchemeIds()),
+			schemeItemRepository.deletebyItemIdsandSchemeIds(itemId, schemeId);
+			model.addAttribute("response", mvcResponseSender.createResponseString(true));
+			model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
+		}
+		return "response";
+	}
+	@RequestMapping(value = "/extendAllSchemes", method = RequestMethod.POST)
+	public String extendAllScheme(HttpServletRequest request, @RequestBody LocalDateTime extendDatetime, Model model)
+			throws Exception {
+		LOGGER.info("ExtendDatetime" + extendDatetime);
+		List<Scheme> schemes = schemeRepository.selectActiveAll();
-				new HashSet<>(schemeItems.getItemIds())).size() > 0) {
+		if (schemes.size() > 0) {
-			for (int schemeId : schemeItems.getSchemeIds()) {
+			for (Scheme scheme : schemes) {
+				if (scheme.getEndDateTime().isBefore(extendDatetime) && scheme.getExpireTimestamp() == null
-				for (int itemId : schemeItems.getItemIds()) {
+						&& (!(scheme.getActiveTimestamp() == null))) {
-					schemeItemRepository.deletebyItemIdsandSchemeIds(itemId, schemeId);
+					scheme.setEndDateTime(extendDatetime);
-					model.addAttribute("response", mvcResponseSender.createResponseString(true));
+					schemeRepository.persist(scheme);
+				} else {
+					continue;
+				}
+			}
-		} else {
-			throw new ProfitMandiBusinessException("ItemId", schemeItems.getItemIds(), "invalid Item Id");
+			model.addAttribute("response", mvcResponseSender.createResponseString(true));
+			return "response";
+		}
+		model.addAttribute("response", mvcResponseSender.createResponseString(false));
 		return "response";
+	}
+	@RequestMapping(value = "/extendSchemeById", method = RequestMethod.POST)
+	public String extendSchemeById(HttpServletRequest request,
+			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
+			@RequestBody LocalDateTime extendDatetime, Model model) throws Exception {
+		LOGGER.info("ExtendDatetime" + extendDatetime);
+		LOGGER.info("schemeId" + schemeId);
+		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";
+		}
+		model.addAttribute("response", mvcResponseSender.createResponseString(false));
+		return "response";
+	}
 	@RequestMapping(value = "/createScheme", method = RequestMethod.POST)
 	public String createScheme(HttpServletRequest request, @RequestBody CreateSchemeRequest createSchemeRequest,
 			@RequestParam(name = "offset", defaultValue = "0") int offset,
 			@RequestParam(name = "limit", defaultValue = "10") int limit,
 		model.addAttribute("schemes", schemes);
 		model.addAttribute("start", offset + 1);
 		model.addAttribute("size", size);
 		model.addAttribute("searchItem", searchItem);
 		model.addAttribute("searchTerm", searchTerm);
+		model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
 		if (schemes.size() < limit) {
 			model.addAttribute("end", offset + schemes.size());
 		} else {
 			model.addAttribute("end", offset + limit);
+		}
 		model.addAttribute("schemes", schemes);
 		model.addAttribute("start", offset + 1);
 		model.addAttribute("size", size);
 		model.addAttribute("searchItem", searchItem);
 		model.addAttribute("searchTerm", searchTerm);
+		model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
 		if (schemes.size() < limit) {
 			model.addAttribute("end", offset + schemes.size());
 		} else {
 			model.addAttribute("end", offset + limit);
+		}
 			schemes = schemeRepository.selectAll(offset, limit);
 		} else {
 			schemes = schemeRepository.selectActiveAll(offset, limit);
+		}
 		model.addAttribute("schemes", schemes);
-		model.addAttribute("roleIds", loginDetails.getRoleIds());
+		model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
 		return "schemes-paginated";
+	}
 	@RequestMapping(value = "/schemes/downloadPage", method = RequestMethod.GET)
 	public String downloadPage(HttpServletRequest request, Model model) {
 		return "schemes-download";
+	}
 	@RequestMapping(value = "/schemes/download", method = RequestMethod.GET)
 	public ResponseEntity<?> downloadInventoryItemAgingByInterval(HttpServletRequest request,
-			@RequestParam LocalDateTime startDateTime,
+			@RequestParam(name = ProfitMandiConstants.START_DATE_TIME) String startDateTimeString,
-			@RequestParam LocalDateTime endDateTime, Model model)
+			@RequestParam(name = ProfitMandiConstants.END_DATE_TIME) String endDateTimeString, Model model)
 			throws ProfitMandiBusinessException {
+		LocalDateTime startDateTime = StringUtils.toDateTime(startDateTimeString,
+				DateTimePattern.DD_MM_YYYY_T_HH_MM_SS);
+		LocalDateTime endDateTime = StringUtils.toDateTime(endDateTimeString, DateTimePattern.DD_MM_YYYY_T_HH_MM_SS);
 		List<SchemeModel> schemeModels = schemeService.getAllSchemeModels(startDateTime, endDateTime);
 		ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
 		ExcelUtils.writeSchemeModels(schemeModels, byteArrayOutputStream);
 			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId, Model model)
 			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		Scheme scheme = schemeService.getSchemeById(schemeId);
 		model.addAttribute("scheme", scheme);
-		model.addAttribute("isFofoAdmin", roleManager.isAdmin(loginDetails.getRoleIds()));
+		model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
 		return "scheme-details";
+	}
 	@RequestMapping(value = "/activeSchemeById", method = RequestMethod.PUT)
 	public String activeSchemeById(HttpServletRequest request,
 			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
 				model.addAttribute("schemes", schemes);
 				model.addAttribute("start", offset + 1);
 				model.addAttribute("size", size);
 				model.addAttribute("searchTerm", searchTerm);
 				model.addAttribute("searchItem", searchItem);
+				model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
 				if (schemes.size() < limit) {
 					model.addAttribute("end", offset + schemes.size());
 				} else {
 					model.addAttribute("end", offset + limit);
+				}
 				model.addAttribute("schemes", schemes);
 				model.addAttribute("start", offset + 1);
 				model.addAttribute("size", size);
 				model.addAttribute("searchItem", searchItem);
 				model.addAttribute("searchTerm", searchTerm);
+				model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
 				if (schemes.size() < limit) {
 					model.addAttribute("end", offset + schemes.size());
 				} else {
 					model.addAttribute("end", offset + limit);
+				}
 			model.addAttribute("schemes", schemes);
 			model.addAttribute("start", offset + 1);
 			model.addAttribute("size", size);
 			model.addAttribute("searchItem", searchItem);
 			model.addAttribute("searchTerm", searchTerm);
+			model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
 			if (schemes.size() < limit) {
 				model.addAttribute("end", offset + schemes.size());
 			} else {
 				model.addAttribute("end", offset + limit);
+			}
 	public String getSchemeByItemPanigated(HttpServletRequest request,
 			@RequestParam(name = "offset", defaultValue = "0") int offset,
 			@RequestParam(name = "limit", defaultValue = "10") int limit,
 			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem, Model model)
 			throws ProfitMandiBusinessException {
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		LOGGER.info("In search Item....");
 		List<Scheme> schemes = null;
 		if (!searchItem.equals("")) {
 			List<Integer> schemeIds = schemeItemRepository.selectSchemeIdByItemId(Integer.parseInt(searchItem));
 			if (schemeIds != null) {
+			}
+		}
 		model.addAttribute("schemes", schemes);
 		model.addAttribute("searchItem", searchItem);
+		model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
 		return "schemes-paginated";
+	}
+}

Subversion Repositories SmartDukaan

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