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

 import com.spice.profitmandi.web.model.LoginDetails;
 import com.spice.profitmandi.web.util.CookiesProcessor;
 import com.spice.profitmandi.web.util.MVCResponseSender;
 @Controller
-@Transactional(rollbackFor=Throwable.class)
+@Transactional(rollbackFor = Throwable.class)
 public class SchemeController {
 	private static final Logger LOGGER = LogManager.getLogger(SchemeController.class);
 	@Autowired
 	private SchemeService schemeService;
 	@Autowired
 	private SchemeRepository schemeRepository;
 	@Autowired
 	private SchemeItemRepository schemeItemRepository;
 	@Autowired
 	private MVCResponseSender mvcResponseSender;
 	@Autowired
 	private CookiesProcessor cookiesProcessor;
 	@Autowired
 	@Qualifier("fofoInventoryService")
 	private InventoryService inventoryService;
 	@Autowired
 	private TagListingRepository tagListingRepository;
 	@Autowired
 	PurchaseRepository purchaseRepository;
 	@Autowired
 	private RoleRepository roleRepository;
 	@Autowired
 	private ResponseSender<?> responseSender;
 	@RequestMapping(value = "/createScheme", method = RequestMethod.GET)
-	public String createScheme(HttpServletRequest request, Model model){
+	public String createScheme(HttpServletRequest request, Model model) {
+		// Map<Integer, String> itemIdItemDescriptionMap =
-		//Map<Integer, String> itemIdItemDescriptionMap = inventoryService.getAllItemIdItemDescriptionMap();
+		// inventoryService.getAllItemIdItemDescriptionMap();
-		//model.addAttribute("itemIdItemDescriptionMap", itemIdItemDescriptionMap);
+		// model.addAttribute("itemIdItemDescriptionMap", itemIdItemDescriptionMap);
 		model.addAttribute("brands", inventoryService.getAllTagListingBrands());
 		return "create-scheme";
+	}
 	@RequestMapping(value = "/getTagListingItemsByBrand", method = RequestMethod.GET)
+	public String getTagListingItemsByBrand(HttpServletRequest request,
-	public String getTagListingItemsByBrand(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.BRAND) String brand, Model model){
+			@RequestParam(name = ProfitMandiConstants.BRAND) String brand, Model model) {
-		Map<Integer, String> itemIdItemDescriptionMap = inventoryService.getAllTagListingItemIdItemDescriptionMap(brand);
+		Map<Integer, String> itemIdItemDescriptionMap = inventoryService
+				.getAllTagListingItemIdItemDescriptionMap(brand);
 		model.addAttribute("itemIdItemDescriptionMap", itemIdItemDescriptionMap);
-		//model.addAttribute("brands", inventoryService.getAllBrands());
+		// 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 {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		Role role = roleRepository.selectByName(RoleType.FOFO_ADMIN.toString());
-		if(loginDetails.getRoleIds().contains(role.getId())) {
+		if (loginDetails.getRoleIds().contains(role.getId())) {
 			throw new ProfitMandiBusinessException("User", loginDetails.getEmailId(), "Unauthorised access");
+		}
 		return "update-schemes-page";
+	}
 	@RequestMapping(value = "/schemes/update", method = RequestMethod.POST)
-	public String updateShcemes(HttpServletRequest request, @RequestBody SchemeItems schemeItems, Model model) throws Exception {
+	public String updateShcemes(HttpServletRequest request, @RequestBody SchemeItems schemeItems, Model model)
+			throws Exception {
-		for(int schemeId : schemeItems.getSchemeIds()) {
+		for (int schemeId : schemeItems.getSchemeIds()) {
-			if(schemeRepository.selectById(schemeId) != null)
+			if (schemeRepository.selectById(schemeId) != null)
-			for(int itemId : schemeItems.getItemIds()) {
+				for (int itemId : schemeItems.getItemIds()) {
-				if(tagListingRepository.selectByItemIdsAndTagIds(new HashSet<>(Arrays.asList(itemId)), new HashSet<>(Arrays.asList(4,7))).size() > 0) {
+					if (tagListingRepository.selectByItemIdsAndTagIds(new HashSet<>(Arrays.asList(itemId)),
+							new HashSet<>(Arrays.asList(4, 7))).size() > 0) {
-					SchemeItem si = new SchemeItem();
+						SchemeItem si = new SchemeItem();
-					si.setItemId(itemId);
+						si.setItemId(itemId);
-					si.setSchemeId(schemeId);
+						si.setSchemeId(schemeId);
-					try {
+						try {
-						schemeItemRepository.persist(si);
+							schemeItemRepository.persist(si);
-					} catch (Exception e) {
+						} catch (Exception e) {
-						LOGGER.info("Scheme aleady exist");
+							LOGGER.info("Scheme aleady exist");
+						}
+						model.addAttribute("response", mvcResponseSender.createResponseString(true));
+					} else {
+						model.addAttribute("response", mvcResponseSender.createResponseString(false));
+						throw new ProfitMandiBusinessException("ItemId", itemId, "Invalid Item Id");
+					}
-					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 = "/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,
 			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem,
 		model.addAttribute("size", size);
 		model.addAttribute("searchItem", searchItem);
 		model.addAttribute("searchTerm", searchTerm);
 		if (schemes.size() < limit) {
 			model.addAttribute("end", offset + schemes.size());
-		}else{
+		} else {
 			model.addAttribute("end", offset + limit);
+		}
 		return "schemes";
+	}
 	@RequestMapping(value = "/getSchemes", method = RequestMethod.GET)
 	public String getSchemes(HttpServletRequest request, @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, Model model)
 			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		List<Scheme> schemes = null;
 		long size = 0;
 		Role role = roleRepository.selectByName(RoleType.FOFO_ADMIN.toString());
-		if(loginDetails.getRoleIds().contains(role.getId())){
+		if (loginDetails.getRoleIds().contains(role.getId())) {
 			schemes = schemeRepository.selectAll(offset, limit);
 			size = schemeRepository.selectAllCount();
-		}else{
+		} else {
 			schemes = schemeRepository.selectActiveAll(offset, limit);
 			size = schemeRepository.selectAllActiveCount();
+		}
 		model.addAttribute("schemes", schemes);
 		model.addAttribute("start", offset + 1);
 		model.addAttribute("size", size);
 		model.addAttribute("searchItem", searchItem);
 		model.addAttribute("searchTerm", searchTerm);
 		if (schemes.size() < limit) {
 			model.addAttribute("end", offset + schemes.size());
-		}else{
+		} else {
 			model.addAttribute("end", offset + limit);
+		}
-		//model.addAttribute("roleTypes", loginDetails.getRoleTypes());
+		// model.addAttribute("roleTypes", loginDetails.getRoleTypes());
 		return "schemes";
+	}
 	@RequestMapping(value = "/getPaginatedSchemes", method = RequestMethod.GET)
+	public String getPaginatedSchemes(HttpServletRequest request,
+			@RequestParam(name = "offset", defaultValue = "0") int offset,
-	public String getPaginatedSchemes(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws ProfitMandiBusinessException{
+			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
 		List<Scheme> schemes = null;
 		Role role = roleRepository.selectByName(RoleType.FOFO_ADMIN.toString());
-		if(loginDetails.getRoleIds().contains(role.getId())){
+		if (loginDetails.getRoleIds().contains(role.getId())) {
 			schemes = schemeRepository.selectAll(offset, limit);
-		}else{
+		} else {
 			schemes = schemeRepository.selectActiveAll(offset, limit);
+		}
 		model.addAttribute("schemes", schemes);
 		model.addAttribute("roleIds", loginDetails.getRoleIds());
 		return "schemes-paginated";
+	}
 	@RequestMapping(value = "/schemes/downloadPage", method = RequestMethod.GET)
-	public String downloadPage(HttpServletRequest request, Model model){
+	public String downloadPage(HttpServletRequest request, Model model) {
 		return "schemes-download";
+	}
 	@RequestMapping(value = "/schemes/download", method = RequestMethod.GET)
+	public ResponseEntity<?> downloadInventoryItemAgingByInterval(HttpServletRequest request,
+			@RequestParam(name = ProfitMandiConstants.START_DATE_TIME) String startDateTimeString,
-	public ResponseEntity<?> downloadInventoryItemAgingByInterval(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.START_DATE_TIME) String startDateTimeString, @RequestParam(name = ProfitMandiConstants.END_DATE_TIME) String endDateTimeString, Model model) throws ProfitMandiBusinessException{
+			@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 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);
-		final HttpHeaders headers=new HttpHeaders();
+		final HttpHeaders headers = new HttpHeaders();
-        headers.set("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
+		headers.set("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
 		headers.set("Content-disposition", "inline; filename=SchemesReport.xlsx");
-        headers.setContentLength(byteArrayOutputStream.toByteArray().length);
+		headers.setContentLength(byteArrayOutputStream.toByteArray().length);
-        final InputStream inputStream=new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
+		final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
-        final InputStreamResource inputStreamResource=new InputStreamResource(inputStream);
+		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
-        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
+		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
-		//return responseSender.ok(ResponseCodeHolder.getMessage("ITM_AGNG_OK_1000"));
+		// return responseSender.ok(ResponseCodeHolder.getMessage("ITM_AGNG_OK_1000"));
+	}
 	@RequestMapping(value = "/getSchemeById", method = RequestMethod.GET)
+	public String getSchemeById(HttpServletRequest request,
-	public String getSchemeById(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId, Model model)  throws ProfitMandiBusinessException{
+			@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("roleIds", loginDetails.getRoleIds());
 		return "scheme-details";
+	}
 	@RequestMapping(value = "/activeSchemeById", method = RequestMethod.PUT)
+	public String activeSchemeById(HttpServletRequest request,
+			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
+			@RequestParam(name = "offset", defaultValue = "0") int offset,
-	public String activeSchemeById(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)  throws ProfitMandiBusinessException{
+			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+			throws ProfitMandiBusinessException {
 		schemeService.activeSchemeById(schemeId);
 		List<Scheme> schemes = schemeRepository.selectAll(offset, limit);
 		model.addAttribute("schemes", schemes);
 		return "schemes-paginated";
+	}
 	@RequestMapping(value = "/expireSchemeById", method = RequestMethod.PUT)
+	public String expireSchemeById(HttpServletRequest request,
+			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
+			@RequestParam(name = "offset", defaultValue = "0") int offset,
-	public String expireSchemeById(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)  throws ProfitMandiBusinessException{
+			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+			throws ProfitMandiBusinessException {
 		schemeService.expireSchemeById(schemeId);
 		List<Scheme> schemes = schemeRepository.selectAll(offset, limit);
 		model.addAttribute("schemes", schemes);
 		return "schemes-paginated";
+	}
 	@RequestMapping(value = "/getSchemesJson", method = RequestMethod.GET)
+	public ResponseEntity<?> getSchemesJson(HttpServletRequest request,
+			@RequestParam(name = "offset", defaultValue = "0") int offset,
-	public ResponseEntity<?> getSchemesJson(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws ProfitMandiBusinessException{
+			@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 = "/searchScheme")
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		List<Scheme> schemes = null;
 		long size = 0;
 		if (!(searchTerm.equals("")) && searchItem.equals("")) {
 			schemes = schemeRepository.selectBySearchTerm(searchTerm, offset, limit);
-			if(!(schemes.size()==0))
+			if (!(schemes.size() == 0)) {
-			{
-			size = schemeRepository.selectAllCount();
+				size = schemeRepository.selectAllCount();
-			LOGGER.info("schemes" + schemes);
+				LOGGER.info("schemes" + schemes);
-			model.addAttribute("schemes", schemes);
+				model.addAttribute("schemes", schemes);
-			model.addAttribute("start", offset + 1);
+				model.addAttribute("start", offset + 1);
-			model.addAttribute("size", size);
+				model.addAttribute("size", size);
-			model.addAttribute("searchTerm", searchTerm);
+				model.addAttribute("searchTerm", searchTerm);
-			model.addAttribute("searchItem", searchItem);
+				model.addAttribute("searchItem", searchItem);
-			if (schemes.size() < limit) {
+				if (schemes.size() < limit) {
-				model.addAttribute("end", offset + schemes.size());
+					model.addAttribute("end", offset + schemes.size());
+				} else {
+					model.addAttribute("end", offset + limit);
+				}
 			} else {
-				model.addAttribute("end", offset + limit);
-			}
-			}
-			else
-			{
-				throw new ProfitMandiBusinessException("SchemeId",searchTerm,"SchemeId Not Found");
+				throw new ProfitMandiBusinessException("SchemeId", searchTerm, "SchemeId Not Found");
+			}
 		} else if (!(searchItem.equals("")) && searchTerm.equals("")) {
 			List<Integer> schemeIds = schemeItemRepository.selectSchemeIdByItemId(Integer.parseInt(searchItem));
-			if (!(schemeIds.size()==0)) {
+			if (!(schemeIds.size() == 0)) {
 				LOGGER.info("schemeIds in searchItemScheme" + schemeIds);
 				schemes = schemeRepository.selectBySchemeIds(schemeIds, offset, limit);
 				size = schemeIds.size();
 				LOGGER.info("Size" + size);
 				model.addAttribute("schemes", schemes);
 			} else {
 				throw new ProfitMandiBusinessException("SchemeIds", searchItem, "SchemeId Not Found");
+			}
 		} else {
 			Role role = roleRepository.selectByName(RoleType.FOFO_ADMIN.toString());
-		    if (loginDetails.getRoleIds().contains(role.getId())) {
+			if (loginDetails.getRoleIds().contains(role.getId())) {
 				schemes = schemeRepository.selectAll(offset, limit);
 				size = schemeRepository.selectAllCount();
 			} else {
 				schemes = schemeRepository.selectActiveAll(offset, limit);
 				size = schemeRepository.selectAllActiveCount();

Subversion Repositories SmartDukaan

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