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
 	private InventoryService inventoryService;
 	@Autowired
 	private TagListingRepository tagListingRepository;
 	@Autowired
 	PurchaseRepository purchaseRepository;
 	@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);
-		if(!loginDetails.getRoleTypes().contains(RoleType.FOFO_ADMIN)) {
+		if (!loginDetails.getRoleTypes().contains(RoleType.FOFO_ADMIN)) {
 			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");
+					}
+				}
+		}
+		return "response";
+	}
+	@RequestMapping(value = "/schemes/delete", method = RequestMethod.POST)
+	public String deleteShcemes(HttpServletRequest request, @RequestBody SchemeItems schemeItems, Model model)
+			throws Exception {
+		if(schemeItemRepository.selectBySchemeIdsAndItemIds(new HashSet<>(schemeItems.getSchemeIds()), new HashSet<>(schemeItems.getItemIds())).size()>0)
+		{
+			for(int schemeId:schemeItems.getSchemeIds())
+			{
+				for(int itemId:schemeItems.getItemIds())
+				{
+					schemeItemRepository.deletebyItemIdsandSchemeIds(itemId, schemeId);
 					model.addAttribute("response", mvcResponseSender.createResponseString(true));
-				} else {
-					model.addAttribute("response", mvcResponseSender.createResponseString(false));
-					throw new ProfitMandiBusinessException("ItemId", itemId,"Invalid Item Id");
+				}
+			}
+		}
+		else {
+			throw new ProfitMandiBusinessException("ItemId", schemeItems.getItemIds(),"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, Model model)  throws ProfitMandiBusinessException{
+	public String createScheme(HttpServletRequest request, @RequestBody CreateSchemeRequest createSchemeRequest,
+			@RequestParam(name = "offset", defaultValue = "0") int offset,
+			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		LOGGER.info("CreateSchemeRequest {}", createSchemeRequest);
 		schemeService.saveScheme(loginDetails.getFofoId(), createSchemeRequest);
 		LOGGER.info("Scheme saved successfully");
 		long size = schemeRepository.selectAllCount();
 		List<Scheme> schemes = schemeRepository.selectAll(offset, limit);
 		model.addAttribute("schemes", schemes);
 		model.addAttribute("start", offset + 1);
 		model.addAttribute("size", size);
-		if (schemes.size() < limit){
+		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, Model model) throws ProfitMandiBusinessException{
+	public String getSchemes(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset,
+			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		List<Scheme> schemes = null;
 		long size = 0;
-		if(loginDetails.getRoleTypes().contains(RoleType.FOFO_ADMIN)){
+		if (loginDetails.getRoleTypes().contains(RoleType.FOFO_ADMIN)) {
 			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);
-		if (schemes.size() < limit){
+		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;
-		if(loginDetails.getRoleTypes().contains(RoleType.FOFO_ADMIN)){
+		if (loginDetails.getRoleTypes().contains(RoleType.FOFO_ADMIN)) {
 			schemes = schemeRepository.selectAll(offset, limit);
-		}else{
+		} else {
 			schemes = schemeRepository.selectActiveAll(offset, limit);
+		}
 		model.addAttribute("schemes", schemes);
 		model.addAttribute("roleTypes", loginDetails.getRoleTypes());
 		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
-		//return responseSender.ok(ResponseCodeHolder.getMessage("ITM_AGNG_OK_1000"));
+		// 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("roleTypes", loginDetails.getRoleTypes());
 		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";
+	}

Subversion Repositories SmartDukaan

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