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

 package com.spice.profitmandi.web.controller;
 import java.io.File;
 import java.io.FileInputStream;
 import java.io.FileNotFoundException;
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 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.json.JSONObject;
 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.enumuration.CounterSize;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.AddLocationModel;
 import com.spice.profitmandi.common.model.CustomRetailer;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
-import com.spice.profitmandi.common.model.SendNotificationModel;
+import com.spice.profitmandi.common.model.PromoterDetailModel;
 import com.spice.profitmandi.common.model.UpdateRetailerRequest;
-import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.common.web.util.ResponseSender;
 import com.spice.profitmandi.dao.entity.dtr.Document;
 import com.spice.profitmandi.dao.entity.dtr.Retailer;
 import com.spice.profitmandi.dao.entity.dtr.Shop;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.InActiveFofoStore;
-import com.spice.profitmandi.dao.entity.user.User;
 import com.spice.profitmandi.dao.entity.user.Location;
+import com.spice.profitmandi.dao.entity.user.Promoter;
+import com.spice.profitmandi.dao.entity.user.User;
 import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
+import com.spice.profitmandi.dao.repository.dtr.Mongo;
 import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
 import com.spice.profitmandi.dao.repository.dtr.ShopRepository;
 import com.spice.profitmandi.dao.repository.user.LocationRepository;
+import com.spice.profitmandi.dao.repository.user.PromoterRepository;
 import com.spice.profitmandi.dao.repository.user.UserRepository;
+import com.spice.profitmandi.service.inventory.InventoryService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.web.util.MVCResponseSender;
 @Controller
 @Transactional(rollbackFor = Throwable.class)
 	@Autowired
 	private DocumentRepository documentRepository;
 	@Autowired
+	@Qualifier("userUserRepository")
 	private UserRepository userRepository;
 	@Autowired
 	private LocationRepository locationRepository;
 	private ResponseSender<?> responseSender;
 	@Autowired
 	private MVCResponseSender mvcResponseSender;
+	@Autowired
+	private InventoryService inventoryService;
+	@Autowired
+	private PromoterRepository promoterRepository;
+	@Autowired
+	private Mongo mongoClient;
 	@RequestMapping(value = "/retailerDetails", method = RequestMethod.GET)
 	public String retailerInfoByEmailIdOrMobileNumber(HttpServletRequest request,
 			@RequestParam(name = ProfitMandiConstants.EMAIL_ID_OR_MOBILE_NUMBER) String emailIdOrMobileNumber,
 			Model model) throws ProfitMandiBusinessException {
 		LOGGER.info("Request Received at url {} with emailIdOrMobileNumber {}", request.getRequestURI(),
 				emailIdOrMobileNumber);
 		Map<String, Object> map = retailerService.getByEmailIdOrMobileNumber(emailIdOrMobileNumber);
 		model.addAllAttributes(map);
 		model.addAttribute("counterSizes", CounterSize.values());
-		if(map.containsKey("retailer")) {
+		if (map.containsKey("retailer")) {
-				Retailer retailer = (Retailer)map.get("retailer");
+			Retailer retailer = (Retailer) map.get("retailer");
-				User user = userRepository.selectById(retailer.getId());
+			User user = userRepository.selectById(retailer.getId());
-				if (user.getLocation() != null) {
+			if (user.getLocation() != null) {
-					Location location = locationRepository.selectById(user.getLocation());
+				Location location = locationRepository.selectById(user.getLocation());
-					model.addAttribute("locationdetail", location);
+				model.addAttribute("locationdetail", location);
-					LOGGER.info("location" + location);
+				LOGGER.info("location" + location);
-				}
+			}
+		}
 		return "retailer-details";
+	}
 	@RequestMapping(value = "/retailerDetails", method = RequestMethod.PUT)
 	public String updateRetailerDetails(HttpServletRequest request,
 			file = new FileInputStream(document.getPath() + File.separator + document.getName());
 		} catch (FileNotFoundException e) {
 			LOGGER.error("Retailer Document file not found : ", e);
 			throw new ProfitMandiBusinessException(ProfitMandiConstants.DOCUMENT_ID, document.getId(), "RTLR_1013");
+		}
-		// ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
+		// ByteArrayOutputStream byteArrayOutputStream = new
+		// ByteArrayOutputStream();
 		// ExcelUtils.writeSchemeModels(schemeModels, byteArrayOutputStream);
 		final HttpHeaders headers = new HttpHeaders();
 		String contentType = "";
 		if (document.getContentType() == ContentType.JPEG) {
 		headers.set("Content-disposition", "inline; filename=" + document.getName());
 		headers.setContentLength(document.getSize());
 		final InputStreamResource inputStreamResource = new InputStreamResource(file);
 		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 = "/retailerShopDocument/shopId", method = RequestMethod.GET)
 	public ResponseEntity<?> retailerShopDocumentById(HttpServletRequest request,
 			@RequestParam(name = ProfitMandiConstants.SHOP_ID) int shopId,
 			file = new FileInputStream(document.getPath() + File.separator + document.getName());
 		} catch (FileNotFoundException e) {
 			LOGGER.error("Retailer Document file not found : ", e);
 			throw new ProfitMandiBusinessException(ProfitMandiConstants.DOCUMENT_ID, document.getId(), "RTLR_1013");
+		}
-		// ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
+		// ByteArrayOutputStream byteArrayOutputStream = new
+		// ByteArrayOutputStream();
 		// ExcelUtils.writeSchemeModels(schemeModels, byteArrayOutputStream);
 		final HttpHeaders headers = new HttpHeaders();
 		String contentType = "";
 		if (document.getContentType() == ContentType.JPEG) {
 		headers.set("Content-disposition", "inline; filename=" + document.getName());
 		headers.setContentLength(document.getSize());
 		final InputStreamResource inputStreamResource = new InputStreamResource(file);
 		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
-		// return responseSender.ok(ResponseCodeHolder.getMessage("ITM_AGNG_OK_1000"));
-	}
-	@RequestMapping(value = "/getAddLocation", method = RequestMethod.GET)
-	public String getAddLocationModal(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
-		model.addAttribute("stateNames", Utils.getAllStateNames());
-		return "add-location-modal";
-	}
-	@RequestMapping(value = "/addLocation", method = RequestMethod.POST)
-	public String addLocation(HttpServletRequest request, @RequestBody AddLocationModel addLocationModel, Model model)
-			throws Exception {
+		// return
-		Location location = new Location();
-		location.setName(addLocationModel.getName());
-		location.setLine1(addLocationModel.getLine1());
-		location.setLine2(addLocationModel.getLine2());
-		location.setCity(addLocationModel.getCity());
-		location.setState(addLocationModel.getState());
-		location.setPin(addLocationModel.getPin());
-		LOGGER.info("PostLocation" + location);
-		locationRepository.persist(location);
-		model.addAttribute("response", mvcResponseSender.createResponseString(true));
+		// responseSender.ok(ResponseCodeHolder.getMessage("ITM_AGNG_OK_1000"));
-		return "response";
+	}
 	@GetMapping(value = "/getAllStores")
 	public String getAllStores(HttpServletRequest request, Model model) {
 		return fofoIds;
+	}
+	@RequestMapping(value = "/userDetails", method = RequestMethod.GET)
+	public String UserInfoByEmailIdOrMobileNumber(HttpServletRequest request,
+			@RequestParam(name = ProfitMandiConstants.EMAIL_ID_OR_MOBILE_NUMBER) String emailIdOrMobileNumber,
+			Model model) throws Exception {
+		boolean value = userRepository.isExistByEmailId(emailIdOrMobileNumber);
+		LOGGER.info("value" + emailIdOrMobileNumber);
+		LOGGER.info("boolean" + value);
+		if (value == true) {
+			model.addAttribute("response", mvcResponseSender.createResponseString(true));
+		} else {
+			model.addAttribute("response", mvcResponseSender.createResponseString(false));
+		}
+		return "response";
+	}
+	@RequestMapping(value = "/getPromoterInfo", method = RequestMethod.GET)
+	public String getPromoterInfo(HttpServletRequest request,
+			@RequestParam(name = "offset", defaultValue = "0") int offset,
+			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws Exception {
+		LOGGER.info("requested url : " + request.getRequestURL().toString());
+		List<Promoter> promoterInfo = null;
+		long size = 0;
+		List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().map(x -> x.getId())
+				.collect(Collectors.toList());
+		Map<Integer, CustomRetailer> customRetailersMap = retailerService.getFofoRetailers(fofoIds);
+		String customRetailers = JSONObject.valueToString(customRetailersMap.values());
+		model.addAttribute("customRetailers", customRetailers);
+		model.addAttribute("brands", inventoryService.getAllTagListingBrands(ProfitMandiConstants.MOBILE_CATEGORY_ID));
+		promoterInfo = promoterRepository.selectAllPromoter(offset, limit);
+		size = promoterRepository.selectAllCount();
+		LOGGER.info("promoterInfo" + promoterInfo);
+		if (!promoterInfo.isEmpty()) {
+			List<Integer> partnerIds = new ArrayList<>();
+			for (Promoter promoterdetail : promoterInfo) {
+				partnerIds.add(promoterdetail.getRetailerId());
+			}
+			Map<Integer, CustomRetailer> partnersMap = null;
+			if(!partnerIds.equals(null)){
+				LOGGER.info("partnerIds" + partnerIds);
+			 partnersMap = retailerService.getFofoRetailers(partnerIds);
+			}
+			LOGGER.info("partnerIds" + partnersMap);
+			model.addAttribute("promoterInfo", promoterInfo);
+			model.addAttribute("partnersMap", partnersMap);
+			model.addAttribute("start", offset + 1);
+			model.addAttribute("size", size);
+			model.addAttribute("url", "/getPaginatedPromoterInfo");
+			if (promoterInfo.size() < limit) {
+				model.addAttribute("end", offset + promoterInfo.size());
+			} else {
+				model.addAttribute("end", offset + limit);
+			}
+		} else {
+			model.addAttribute("promoterInfo", promoterInfo);
+			model.addAttribute("size", size);
+		}
+		return "promoter-info";
+	}
+	@RequestMapping(value = "/getPaginatedPromoterInfo", method = RequestMethod.GET)
+	public String getPaginatedPromoterInfo(HttpServletRequest request,
+			@RequestParam(name = "offset", defaultValue = "0") int offset,
+			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+			throws ProfitMandiBusinessException {
+		LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
+		List<Promoter> promoterInfo = null;
+		promoterInfo = promoterRepository.selectAllPromoter(offset, limit);
+		LOGGER.info("promoterInfo" + promoterInfo);
+		if (!promoterInfo.isEmpty()) {
+			List<Integer> partnerIds = new ArrayList<>();
+			for (Promoter promoterdetail : promoterInfo) {
+				partnerIds.add(promoterdetail.getRetailerId());
+			}
+			Map<Integer, CustomRetailer> partnersMap = null;
+			if(!partnerIds.equals(null)){
+				LOGGER.info("partnerIds" + partnerIds);
+			 partnersMap = retailerService.getFofoRetailers(partnerIds);
+			}
+			LOGGER.info("partnerIds" + partnersMap);
+			model.addAttribute("promoterInfo", promoterInfo);
+			model.addAttribute("partnersMap", partnersMap);
+			model.addAttribute("url", "/getPaginatedPromoterInfo");
+		} else {
+			model.addAttribute("promoterInfo", promoterInfo);
+		}
+		return "promoter-info-paginated";
+	}
+	@RequestMapping(value = "/createPromoter", method = RequestMethod.POST)
+	public String createPromoter(HttpServletRequest request, @RequestBody PromoterDetailModel promoterdetailModel,
+			Model model) throws Exception {
+		LOGGER.info("requested url : " + request.getRequestURL().toString());
+		LOGGER.info("requested url : " + promoterdetailModel);
+		if (promoterdetailModel.getId()==0) {
+			Promoter promoter = new Promoter();
+			promoter.setName(promoterdetailModel.getName());
+			promoter.setBrand(promoterdetailModel.getBrand());
+			promoter.setEmail(promoterdetailModel.getEmail());
+			promoter.setMobile(promoterdetailModel.getMobile());
+			promoter.setRetailerId(promoterdetailModel.getRetailerId());
+			promoter.setCreatedTimestamp(LocalDateTime.now());
+			promoterRepository.persist(promoter);
+		} else {
+			Promoter updatePromoter = promoterRepository.selectById(promoterdetailModel.getId());
+			updatePromoter.setRetailerId(promoterdetailModel.getRetailerId());
+			promoterRepository.persist(updatePromoter);
+		}
+		model.addAttribute("response", mvcResponseSender.createResponseString(true));
+		return "response";
+	}
+	@RequestMapping(value = "/removePromoterfromPartnerStore", method = RequestMethod.POST)
+	public String removePromoterfromPartnerStore(HttpServletRequest request,
+			@RequestParam(name = "id", defaultValue = "0") int id, Model model) throws Exception {
+		Promoter promoter = promoterRepository.selectById(id);
+		promoter.setRetailerId(0);
+		promoterRepository.persist(promoter);
+		model.addAttribute("response", mvcResponseSender.createResponseString(true));
+		return "response";
+	}
+	@RequestMapping(value = "/addLocation", method = RequestMethod.POST)
+	public String addLocation(HttpServletRequest request, @RequestBody AddLocationModel addLocationModel, Model model)
+			throws Exception {
+		Location location = new Location();
+		location.setName(addLocationModel.getName());
+		location.setLine1(addLocationModel.getLine1());
+		location.setLine2(addLocationModel.getLine2());
+		location.setCity(addLocationModel.getCity());
+		location.setState(addLocationModel.getState());
+		location.setPin(addLocationModel.getPin());
+		LOGGER.info("PostLocation" + location);
+		locationRepository.persist(location);
+		User user = userRepository.selectById(addLocationModel.getUserId());
+		user.setLocation(location.getId());
+		userRepository.persist(user);
+		model.addAttribute("response", mvcResponseSender.createResponseString(true));
+		return "response";
+	}
+	@RequestMapping(value = "/updateLocation", method = RequestMethod.POST)
+	public String updateLocation(HttpServletRequest request, @RequestBody AddLocationModel addLocationModel,
+			Model model) throws Exception {
+		Location userlocation = locationRepository.selectById(addLocationModel.getUserId());
+		userlocation.setName(addLocationModel.getName());
+		userlocation.setCity(addLocationModel.getCity());
+		userlocation.setLine1(addLocationModel.getLine1());
+		userlocation.setLine2(addLocationModel.getLine2());
+		userlocation.setPin(addLocationModel.getPin());
+		userlocation.setState(addLocationModel.getState());
+		locationRepository.persist(userlocation);
+		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 24140 → 24159