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

 import java.io.FileInputStream;
 import java.io.FileNotFoundException;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.HashMap;
 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.apache.logging.log4j.Logger;
 import org.json.JSONObject;
 import org.springframework.beans.factory.annotation.Autowired;
 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 org.springframework.transaction.annotation.Transactional;
 import org.springframework.ui.Model;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import com.spice.profitmandi.dao.repository.user.PromoterRepository;
 import com.spice.profitmandi.dao.repository.user.UserRepository;
 import com.spice.profitmandi.service.PartnerInvestmentService;
 import com.spice.profitmandi.service.inventory.InventoryService;
 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;
 @Controller
 @Transactional(rollbackFor = Throwable.class)
 public class RetailerController {
 	@Autowired
 	private DocumentRepository documentRepository;
 	@Autowired
+	private CookiesProcessor cookiesProcessor;
+	@Autowired
 	@Qualifier("userUserRepository")
 	private UserRepository userRepository;
 	@Autowired
 	private LocationRepository locationRepository;
+	}
 	@GetMapping(value = "/getAllStores")
 	public String getAllStores(HttpServletRequest request, Model model) {
-		List<FofoStore> fofoStores = fofoStoreRepository.selectAll().stream().filter(x->x.isActive()).collect(Collectors.toList());
+		List<FofoStore> fofoStores = fofoStoreRepository.selectAll().stream().filter(x -> x.isActive())
+				.collect(Collectors.toList());
 		Map<Integer, Boolean> investments = new HashMap<>();
 		for (FofoStore fofoStore : fofoStores) {
 			boolean isOk = false;
 			if (fofoStore.getGraceDate() != null && fofoStore.getGraceDate().isAfter(LocalDate.now())) {
 				isOk = true;
 			} else {
 				try {
-					isOk = partnerInvestmentService.isInvestmentOk(fofoStore.getId(), 10, 30);
+					isOk = partnerInvestmentService.isInvestmentOk(fofoStore.getId(), 10,
+							ProfitMandiConstants.CUTOFF_INVESTMENT);
-					if(fofoStore.getGraceCount() > 0) {
+					if (fofoStore.getGraceCount() > 0) {
 						fofoStore.setGraceDate(null);
 						fofoStore.setGraceCount(0);
 						fofoStoreRepository.persist(fofoStore);
+					}
 				} catch (ProfitMandiBusinessException e) {
 	@PostMapping(value = "/deactivateStore")
 	public String deActivateStore(HttpServletRequest request,
 			@RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model) throws Exception {
 		FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		if (!Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com").contains(loginDetails.getEmailId())) {
+			throw new ProfitMandiBusinessException("Access Denied", "Unauthorised Access", "You are not authorise to deactivate retailer");
+		}
 		fofoStore.setActive(false);
 		fofoStoreRepository.persist(fofoStore);
 		LOGGER.info("inserted into InActiveFofoStore successfully");
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
-	@GetMapping(value="/getAllInactiveStores")
+	@GetMapping(value = "/getAllInactiveStores")
-	public String getInactiveStores(HttpServletRequest request,Model model)
+	public String getInactiveStores(HttpServletRequest request, Model model) {
-	{
-		List<FofoStore> inActiveFofoStores=fofoStoreRepository.selectInActiveStore();
+		List<FofoStore> inActiveFofoStores = fofoStoreRepository.selectInActiveStore();
+		Map<Integer, CustomRetailer> customRetailers = retailerService
-		Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(inActiveFofoStores.stream().map(x->x.getId()).collect(Collectors.toList()));
+				.getFofoRetailers(inActiveFofoStores.stream().map(x -> x.getId()).collect(Collectors.toList()));
 		model.addAttribute("inActiveFofoStores", inActiveFofoStores);
 		model.addAttribute("customRetailers", customRetailers);
 		return "inactive-stores";
+	}
-	//Extend billing for 2 days
+	// Extend billing for 2 days
 	@PostMapping(value = "/extendBilling")
 	public String extendBilling(HttpServletRequest request,
 			@RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model) throws Exception {
 		FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		if (Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com").contains(loginDetails.getEmailId())) {
-		fofoStore.setGraceDate(LocalDate.now().plusDays(2));
+			fofoStore.setGraceDate(LocalDate.now().plusDays(2));
-		fofoStore.setGraceCount(fofoStore.getGraceCount() + 1);
+			fofoStore.setGraceCount(fofoStore.getGraceCount() + 1);
-		fofoStoreRepository.persist(fofoStore);
+			fofoStoreRepository.persist(fofoStore);
-		model.addAttribute("response", mvcResponseSender.createResponseString(fofoStore.getGraceCount()));
+			model.addAttribute("response", mvcResponseSender.createResponseString(fofoStore.getGraceCount()));
+		} else {
+			throw new ProfitMandiBusinessException("Access Denied", "Unauthorised Access", "You are not authorise to extend billing");
+		}
 		return "response";
+	}
 	@RequestMapping(value = "/getPromoterInfo", method = RequestMethod.GET)
 	public String getPromoterInfo(HttpServletRequest request,
 			@RequestParam(name = "offset", defaultValue = "0") int offset,
 		String customRetailers = JSONObject.valueToString(customRetailersMap.values());
 		Set<String> brands = inventoryService.getAllTagListingBrands(ProfitMandiConstants.MOBILE_CATEGORY_ID);
 		brands.add("Airtel");
 		brands.add("Vodafone");
 		brands.add("Idea");
-		LOGGER.info("brands"+brands);
+		LOGGER.info("brands" + brands);
 		model.addAttribute("customRetailers", customRetailers);
-		model.addAttribute("brands",brands );
+		model.addAttribute("brands", brands);
 		promoterInfo = promoterRepository.selectAllPromoter(offset, limit);
 		size = promoterRepository.selectAllCount();
 		LOGGER.info("promoterInfo" + promoterInfo);
 			promoterRepository.persist(promoter);
 		} else {
 			Promoter updatePromoter = promoterRepository.selectById(promoterdetailModel.getId());
 			updatePromoter.setRetailerId(promoterdetailModel.getRetailerId());
 			updatePromoter.setSdPortalAccess(promoterdetailModel.isSdPortalAccess());
-			LOGGER.info("sdport"+ promoterdetailModel.isSdPortalAccess());
+			LOGGER.info("sdport" + promoterdetailModel.isSdPortalAccess());
-			LOGGER.info("sdport"  + updatePromoter);
+			LOGGER.info("sdport" + updatePromoter);
 			promoterRepository.persist(updatePromoter);
+		}
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/RetailerController.java – Rev 24986 → 25276