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

 import java.util.Map;
 import java.util.Set;
 import java.util.stream.Collectors;
 import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
 import javax.transaction.Transactional;
+import org.apache.commons.csv.CSVRecord;
 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.ui.Model;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RequestPart;
+import org.springframework.web.multipart.MultipartFile;
 import com.spice.profitmandi.common.enumuration.DateTimePattern;
 import com.spice.profitmandi.common.enumuration.ReporticoProject;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.CustomRetailer;
 import com.spice.profitmandi.common.util.FileUtil;
 import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.common.util.StringUtils;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.common.web.util.ResponseSender;
+import com.spice.profitmandi.dao.entity.catalog.CustomerOffer;
+import com.spice.profitmandi.dao.entity.catalog.CustomerOfferItem;
 import com.spice.profitmandi.dao.entity.catalog.EvaluateSchemeInvestmentPayoutModel;
 import com.spice.profitmandi.dao.entity.catalog.Item;
+import com.spice.profitmandi.dao.entity.catalog.SamsungUpgradeOffer;
 import com.spice.profitmandi.dao.entity.catalog.Scheme;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
+import com.spice.profitmandi.dao.entity.fofo.FofoLineItem;
+import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
+import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
 import com.spice.profitmandi.dao.entity.fofo.PartnerType;
 import com.spice.profitmandi.dao.entity.fofo.SchemeInOut;
 import com.spice.profitmandi.dao.entity.fofo.SchemeItem;
 import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
 import com.spice.profitmandi.dao.entity.transaction.PriceDropIMEI;
 import com.spice.profitmandi.dao.enumuration.catalog.AmountType;
 import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
+import com.spice.profitmandi.dao.enumuration.catalog.UpgradeOfferStatus;
 import com.spice.profitmandi.dao.enumuration.transaction.SchemePayoutStatus;
 import com.spice.profitmandi.dao.model.CreateOfferRequest;
 import com.spice.profitmandi.dao.model.CreateSchemeRequest;
+import com.spice.profitmandi.dao.repository.catalog.CustomerOfferItemRepository;
+import com.spice.profitmandi.dao.repository.catalog.CustomerOfferRepository;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
+import com.spice.profitmandi.dao.repository.catalog.SamsungUpgradeOfferRepository;
 import com.spice.profitmandi.dao.repository.catalog.SchemeRepository;
 import com.spice.profitmandi.dao.repository.catalog.StateGstRateRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
+import com.spice.profitmandi.dao.repository.fofo.FofoLineItemRepository;
+import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
+import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
 import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
 import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
 import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
 import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;
 import com.spice.profitmandi.dao.repository.fofo.SchemeItemRepository;
 	PriceDropRepository priceDropRepository;
 	@Autowired
 	SchemeInOutRepository schemeInOutRepository;
+	@Autowired
+	private CustomerOfferRepository customerOfferRepository;
+	@Autowired
+	private CustomerOfferItemRepository customerOfferItemRepository;
+	@Autowired
+	private SamsungUpgradeOfferRepository samsungUpgradeOfferRepository;
 	@RequestMapping(value = "/createScheme", method = RequestMethod.GET)
 	public String createScheme(HttpServletRequest request, Model model) {
 		LocalDate currentdate = LocalDate.now();
 		Month month = currentdate.getMonth().minus(1);
 			Item item = itemRepository.selectById(searchItem);
 			if (tagListing != null) {
 				model.addAttribute("dp", tagListing.getSellingPrice());
 				model.addAttribute("mop", tagListing.getMop());
+			}
-			schemes = schemeService.selectSchemeByPartnerType(partnerType, date, searchItem, isAdmin, offset, limit).stream().filter(x-> {
+			schemes = schemeService.selectSchemeByPartnerType(partnerType, date, searchItem, isAdmin, offset, limit)
+					.stream().filter(x -> {
-				return (x.getId()!=411 && x.getId()!=612) || date1.isBefore(LocalDate.of(2021, 12, 1));
+						return (x.getId() != 411 && x.getId() != 612) || date1.isBefore(LocalDate.of(2021, 12, 1));
-			}).collect(Collectors.toList());
+					}).collect(Collectors.toList());
-			//Remove 411 and 612
+			// Remove 411 and 612
 			model.addAttribute("schemes", schemes);
 			if (schemes.size() == 0) {
 				if (isAdmin)
 					return "schemes";
 				else {
 		model.addAttribute("searchItem", searchItem);
 		model.addAttribute("searchTerm", searchTerm);
 		model.addAttribute("partnerType", partnerType);
 		model.addAttribute("isAdmin", isAdmin);
 		LOGGER.info("schemes" + schemes);
-		model.addAttribute("schemes", schemes !=null ? schemes.stream().filter(x-> {
+		model.addAttribute("schemes", schemes != null ? schemes.stream().filter(x -> {
-			return (x.getId()!=411 && x.getId()!=612) || date1.isBefore(LocalDate.of(2021, 12, 1));
+			return (x.getId() != 411 && x.getId() != 612) || date1.isBefore(LocalDate.of(2021, 12, 1));
 		}).collect(Collectors.toList()) : null);
 		LOGGER.info("schemes" + schemes);
 		// model.addAttribute("roleTypes", loginDetails.getRoleTypes());
 		if (isAdmin)
 			return "schemes";
 		model.addAttribute("searchItem", searchItem);
 		model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
 		return "schemes-paginated";
+	}
+	@RequestMapping(value = "/getCustomerOffer", method = RequestMethod.GET)
+	public String getCustomerOffer(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
+		List<CustomerOffer> customerOffers = customerOfferRepository.selectAll();
+		model.addAttribute("customerOffers", customerOffers);
+		return "customer-offer";
+	}
+	@RequestMapping(value = "/createCustomerOffer", method = RequestMethod.POST)
+	public String createCustomerOffer(HttpServletRequest request, @RequestParam String offerName,
+			@RequestParam LocalDateTime startDate, @RequestParam LocalDateTime endDate, Model model) throws Exception {
+		CustomerOffer co = new CustomerOffer();
+		co.setOfferName(offerName);
+		co.setStartDate(startDate);
+		co.setEndDate(endDate);
+		co.setCreatedTimestamp(LocalDateTime.now());
+		co.setUpdatedTimestamp(LocalDateTime.now());
+		customerOfferRepository.persist(co);
+		model.addAttribute("response", mvcResponseSender.createResponseString(true));
+		return "response";
+	}
+	@RequestMapping(value = "/customerOffer/downloadTemplate", method = RequestMethod.GET)
+	public ResponseEntity<?> downloadCustomerOfferTemplate(HttpServletRequest request) throws Exception {
+		List<List<?>> rows = new ArrayList<>();
+		org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil
+				.getCSVByteStream(Arrays.asList("id", "Catalog Id", "Scheme Payout", "Dealer Payout"), rows);
+		final HttpHeaders headers = new HttpHeaders();
+		headers.set("Content-Type", "text/csv");
+		headers.set("Content-disposition", "inline; filename=customer-offer-template.csv");
+		headers.setContentLength(baos.toByteArray().length);
+		final InputStream inputStream = new ByteArrayInputStream(baos.toByteArray());
+		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
+		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
+	}
+	@RequestMapping(value = "/customerOfferItem/upload", method = RequestMethod.POST)
+	public String uploadCustomerOfferItem(HttpServletRequest request, Model model, @RequestParam int offerId,
+			HttpServletResponse response, @RequestPart MultipartFile file) throws Throwable {
+		List<CSVRecord> records = FileUtil.readFile(file);
+		for (CSVRecord record : records) {
+			if (Integer.parseInt(record.get(0)) == 0) {
+				CustomerOfferItem coi = new CustomerOfferItem();
+				coi.setCatalogId(Integer.parseInt(record.get(1)));
+				coi.setSchemePayout(Integer.parseInt(record.get(2)));
+				coi.setDealerPayout(Integer.parseInt(record.get(3)));
+				coi.setCustomerOfferId(offerId);
+				coi.setUpdatedTimestamp(LocalDateTime.now());
+				coi.setCreatedTimestamp(LocalDateTime.now());
+				customerOfferItemRepository.persist(coi);
+			} else {
+				CustomerOfferItem coi = customerOfferItemRepository.selectById(Integer.parseInt(record.get(0)));
+				coi.setSchemePayout(Integer.parseInt(record.get(2)));
+				coi.setDealerPayout(Integer.parseInt(record.get(3)));
+				coi.setUpdatedTimestamp(LocalDateTime.now());
+			}
+		}
+		model.addAttribute("response", mvcResponseSender.createResponseString(true));
+		return "response";
+	}
+	@RequestMapping(value = "/customerOfferItem/download", method = RequestMethod.GET)
+	public ResponseEntity<?> downloadOfferItem(HttpServletRequest request, @RequestParam int offerId) throws Exception {
+		List<CustomerOfferItem> cois = customerOfferItemRepository.selectByOfferId(offerId);
+		List<List<?>> rows = new ArrayList<>();
+		for (CustomerOfferItem coi : cois) {
+			rows.add(Arrays.asList(coi.getId(), coi.getCatalogId(), coi.getSchemePayout(), coi.getDealerPayout()));
+		}
+		org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil
+				.getCSVByteStream(Arrays.asList("id", "Catalog Id", "Scheme Payout", "Dealer Payout"), rows);
+		final HttpHeaders headers = new HttpHeaders();
+		headers.set("Content-Type", "text/csv");
+		headers.set("Content-disposition", "inline; filename=customer-offer-template.csv");
+		headers.setContentLength(baos.toByteArray().length);
+		final InputStream inputStream = new ByteArrayInputStream(baos.toByteArray());
+		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
+		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
+	}
+	@RequestMapping(value = "/extendCustomerOffer", method = RequestMethod.POST)
+	public String extendCustomerOffer(HttpServletRequest request, @RequestParam int id,
+			@RequestParam LocalDateTime endDate, Model model) throws ProfitMandiBusinessException {
+		CustomerOffer co = customerOfferRepository.selectById(id);
+		co.setEndDate(endDate);
+		co.setUpdatedTimestamp(LocalDateTime.now());
+		model.addAttribute("co", co);
+		return "customer-index-offer";
+	}
+	@RequestMapping(value = "/getSamsungUpgradeOffer", method = RequestMethod.GET)
+	public String getSamsungUpgradeOffer(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
+		List<UpgradeOfferStatus> uos = UpgradeOfferStatus.offerStatus;
+		List<SamsungUpgradeOffer> samsungUpgradeOffers = samsungUpgradeOfferRepository.selectByStatus(
+				uos.stream().filter(x -> !x.equals(UpgradeOfferStatus.rejected)).collect(Collectors.toList()));
+		model.addAttribute("samsungUpgradeOffers", samsungUpgradeOffers);
+		return "samsung-upgrade-offer";
+	}
+	@RequestMapping(value = "/approveSamsungUpgradeOffer", method = RequestMethod.POST)
+	public String approveSamsungUpgradeOffer(HttpServletRequest request, @RequestParam int id, Model model)
+			throws ProfitMandiBusinessException {
+		SamsungUpgradeOffer suo = samsungUpgradeOfferRepository.selectById(id);
+		suo.setStatus(UpgradeOfferStatus.approved);
+		suo.setApprovedTimestamp(LocalDateTime.now());
+		model.addAttribute("suo", suo);
+		return "samsung-upgrade-offer-index";
+	}
+	@RequestMapping(value = "/rejectSamsungUpgradeOffer", method = RequestMethod.POST)
+	public String rejectSamsungUpgradeOffer(HttpServletRequest request, @RequestParam int id, Model model)
+			throws ProfitMandiBusinessException {
+		SamsungUpgradeOffer suo = samsungUpgradeOfferRepository.selectById(id);
+		suo.setStatus(UpgradeOfferStatus.rejected);
+		model.addAttribute("suo", suo);
+		return "samsung-upgrade-offer-index";
+	}
+}

Subversion Repositories SmartDukaan

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