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

 import java.util.List;
 import java.util.Map;
 import javax.servlet.http.HttpServletRequest;
-import org.apache.logging.log4j.Logger;
 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.http.HttpHeaders;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Controller;
 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;
+import com.spice.profitmandi.common.web.util.ResponseSender;
 import com.spice.profitmandi.dao.entity.catalog.Scheme;
+import com.spice.profitmandi.dao.entity.dtr.Role;
 import com.spice.profitmandi.dao.entity.fofo.SchemeItem;
 import com.spice.profitmandi.dao.enumuration.dtr.RoleType;
 import com.spice.profitmandi.dao.repository.catalog.SchemeRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
+import com.spice.profitmandi.dao.repository.dtr.RoleRepository;
 import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
 import com.spice.profitmandi.dao.repository.fofo.SchemeItemRepository;
 import com.spice.profitmandi.service.inventory.InventoryService;
 import com.spice.profitmandi.service.scheme.SchemeService;
 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 =
-		// inventoryService.getAllItemIdItemDescriptionMap();
+		//Map<Integer, String> itemIdItemDescriptionMap = inventoryService.getAllItemIdItemDescriptionMap();
-		// model.addAttribute("itemIdItemDescriptionMap",
+		//model.addAttribute("itemIdItemDescriptionMap", itemIdItemDescriptionMap);
-		// itemIdItemDescriptionMap);
 		model.addAttribute("brands", inventoryService.getAllTagListingBrands());
 		return "create-scheme";
+	}
 	@RequestMapping(value = "/getTagListingItemsByBrand", method = RequestMethod.GET)
-	public String getTagListingItemsByBrand(HttpServletRequest request,
-			@RequestParam(name = ProfitMandiConstants.BRAND) String brand, Model model) {
+	public String getTagListingItemsByBrand(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.BRAND) String brand, Model model){
-		Map<Integer, String> itemIdItemDescriptionMap = inventoryService
+		Map<Integer, String> itemIdItemDescriptionMap = inventoryService.getAllTagListingItemIdItemDescriptionMap(brand);
-				.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.getRoleTypes().contains(RoleType.FOFO_ADMIN)) {
+		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)
+	public String updateShcemes(HttpServletRequest request, @RequestBody SchemeItems schemeItems, Model model) throws Exception {
-			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)),
+				if(tagListingRepository.selectByItemIdsAndTagIds(new HashSet<>(Arrays.asList(itemId)), new HashSet<>(Arrays.asList(4,7))).size() > 0) {
-							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,
 			@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.getRoleTypes().contains(RoleType.FOFO_ADMIN)) {
+		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,
-			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+	public String getPaginatedSchemes(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws ProfitMandiBusinessException{
-			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.getRoleTypes().contains(RoleType.FOFO_ADMIN)) {
+		if(loginDetails.getRoleIds().contains(role.getId())){
 			schemes = schemeRepository.selectAll(offset, limit);
-		} else {
+		}else{
 			schemes = schemeRepository.selectActiveAll(offset, limit);
+		}
 		model.addAttribute("schemes", schemes);
-		model.addAttribute("roleTypes", loginDetails.getRoleTypes());
+		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,
-			@RequestParam(name = ProfitMandiConstants.END_DATE_TIME) String endDateTimeString, Model model)
+	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{
-			throws ProfitMandiBusinessException {
-		LocalDateTime startDateTime = StringUtils.toDateTime(startDateTimeString,
+		LocalDateTime startDateTime = StringUtils.toDateTime(startDateTimeString, DateTimePattern.DD_MM_YYYY_T_HH_MM_SS);
-				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,
-			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId, Model model)
+	public String getSchemeById(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId, Model model)  throws ProfitMandiBusinessException{
-			throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		Scheme scheme = schemeService.getSchemeById(schemeId);
 		model.addAttribute("scheme", scheme);
-		model.addAttribute("roleTypes", loginDetails.getRoleTypes());
+		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,
-			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+	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{
-			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,
-			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+	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{
-			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, @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")
 	public String getSchemeBySchemeId(HttpServletRequest request,
 			@RequestParam(name = "offset", defaultValue = "0") int offset,
 			@RequestParam(name = "limit", defaultValue = "10") int limit,
 			} else {
 				throw new ProfitMandiBusinessException("SchemeIds", searchItem, "SchemeId Not Found");
+			}
 		} else {
+			Role role = roleRepository.selectByName(RoleType.FOFO_ADMIN.toString());
-			if (loginDetails.getRoleTypes().contains(RoleType.FOFO_ADMIN)) {
+		    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 23752 → 23784