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

 import com.spice.profitmandi.dao.repository.catalog.OfferMarginRepository;
 import com.spice.profitmandi.dao.repository.catalog.OfferPartnerRepository;
 import com.spice.profitmandi.dao.repository.catalog.OfferRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
+import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
 import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
 import com.spice.profitmandi.service.NotificationService;
 import com.spice.profitmandi.service.authentication.RoleManager;
 import com.spice.profitmandi.service.offers.OfferService;
 import com.spice.profitmandi.service.user.RetailerService;
 	@Autowired
 	private OfferPartnerRepository offerPartnerRepository;
 	private static final String IMAGE_REMOTE_DIR = "/var/www/dtrdashboard/uploads/campaigns/";
 	private static final String IMAGE_STATIC_SERVER_URL = "https://images.smartdukaan.com/uploads/campaigns";
 	@Autowired
 	private ItemRepository itemRepository;
 	@Autowired
 	private MVCResponseSender mvcResponseSender;
+	}
 	@RequestMapping(value = "/createOffer", method = RequestMethod.POST)
 	public String createOffer(HttpServletRequest request, @RequestBody CreateOfferRequest createOfferRequest,
-			Model model) throws Exception {
+							  Model model) throws Exception {
 		LOGGER.info("createOfferRequest [{}]", createOfferRequest);
 		offerService.addOfferService(createOfferRequest);
 		thirtyMinsTimeOutCacheManager.getCache("allOffers").evict(YearMonth.now());
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
 		return "scheme_offer/published";
+	}
 	@RequestMapping(value = "/offer/active/{offerId}", method = RequestMethod.GET)
-	public String activateOffer(HttpServletRequest request, @PathVariable int offerId, Model model, @RequestParam(defaultValue = "true") boolean active)
+	public String activateOffer(HttpServletRequest request, @PathVariable int offerId, Model model,
-			throws ProfitMandiBusinessException, Exception {
+								@RequestParam(defaultValue = "true") boolean active) throws ProfitMandiBusinessException, Exception {
 		Offer offer = offerRepository.selectById(offerId);
 		boolean alreadyActive = offer.isActive();
-		if(alreadyActive != active) {
+		if (alreadyActive != active) {
 			offer.setActive(active);
 			oneDayCacheManager.getCache("catalog.published_yearmonth").evict(YearMonth.now());
+		}
-		if(active && !alreadyActive) {
+		if (active && !alreadyActive) {
 			this.sendNotification(offer);
+		}
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+		// CreateOfferRequest createOfferRequest =
-		//CreateOfferRequest createOfferRequest = offerService.getCreateOfferRequest(offer);
+		// offerService.getCreateOfferRequest(offer);
-		//model.addAttribute("offer", createOfferRequest);
+		// model.addAttribute("offer", createOfferRequest);
-		//return "offer_margin_detail_partner2";
+		// return "offer_margin_detail_partner2";
+	}
 	@RequestMapping(value = "/offer/testimage/{offerId}", method = RequestMethod.GET)
-	public String testOffer(HttpServletRequest request, @PathVariable int offerId, Model model, @RequestParam(defaultValue = "true") boolean active)
+	public String testOffer(HttpServletRequest request, @PathVariable int offerId, Model model,
-			throws ProfitMandiBusinessException, Exception {
+							@RequestParam(defaultValue = "true") boolean active) throws ProfitMandiBusinessException, Exception {
 		Offer offer = offerRepository.selectById(offerId);
-		//model.addAttribute("response", mvcResponseSender.createResponseString(true));
+		// model.addAttribute("response", mvcResponseSender.createResponseString(true));
-		//return "response";
+		// return "response";
 		CreateOfferRequest createOfferRequest = offerService.getCreateOfferRequest(offer);
 		model.addAttribute("offer", createOfferRequest);
 		return "offer_margin_detail_partner2";
+	}
 	@Autowired
 	private com.spice.profitmandi.dao.repository.dtr.UserRepository dtrUserRepository;
 	@RequestMapping(value = "/offer/active/fofo/{fofoId}", method = RequestMethod.GET)
-	public String sendOfferNotification(HttpServletRequest request, @PathVariable int fofoId, Model model, @RequestParam(defaultValue = "true") boolean active)
+	public String sendOfferNotification(HttpServletRequest request, @PathVariable int fofoId, Model model,
-			throws ProfitMandiBusinessException, Exception {
+										@RequestParam(defaultValue = "true") boolean active) throws ProfitMandiBusinessException, Exception {
 		List<Offer> offers = offerRepository.selectAllPublishedMapByPartner(YearMonth.now()).get(fofoId);
-		for(Offer offer : offers) {
+		for (Offer offer : offers) {
 			this.sendNotification(offer);
+		}
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
+	@Autowired
+	UserAccountRepository userAccountRepository;
 	private void sendNotification(Offer offer) throws Exception {
 		String fileName = "offer-" + offer.getId() + ".png";
 		CreateOfferRequest createOfferRequest = offerService.getCreateOfferRequest(offer);
 		SendNotificationModel sendNotificationModel = new SendNotificationModel();
 		sendNotificationModel.setCampaignName("SchemeOffer");
 		sendNotificationModel.setTitle(offer.getName());
 		sendNotificationModel.setMessage(createOfferRequest.getSchemeType().name() + " of select models, "
-		+ FormattingUtils.formatDateMonth(offer.getStartDate()) + " to " + FormattingUtils.formatDateMonth(offer.getEndDate()));
+				+ FormattingUtils.formatDateMonth(offer.getStartDate()) + " to "
+				+ FormattingUtils.formatDateMonth(offer.getEndDate()));
 		sendNotificationModel.setType("url");
 		sendNotificationModel.setImageUrl(IMAGE_STATIC_SERVER_URL + "/" + "image" + LocalDate.now() + "/" + fileName);
 		sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");
 		sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
 		sendNotificationModel.setMessageType(MessageType.scheme);
-		Map<Integer, Map<Integer, Long>> partnerWiseMap = null;
 		Map<Integer, List<Offer>> offersMap = offerRepository.selectAllPublishedMapByPartner(YearMonth.now());
 		List<Integer> fofoIds = offersMap.entrySet().stream().filter(x -> x.getValue().contains(offer))
 				.map(x -> x.getKey()).collect(Collectors.toList());
+		List<Integer> userIds = userAccountRepository.selectUserIdsByRetailerIds(fofoIds);
-		sendNotificationModel.setFofoIds(fofoIds);
+		sendNotificationModel.setUserIds(userIds);
 		Map<String, InputStream> fileStreamsMap = new HashMap<>();
+		Map<String, Object> model = new HashMap<>();
-		List<Integer> dtrIds = dtrUserRepository
+		model.put("offer", createOfferRequest);
-				.selectAllByEmailIds(Arrays.asList("tarun.verma@smartdukaan.com", "amit.gupta@shop2020.in"))
+		String htmlContent = this.getContentFromTemplate("offer_margin_detail_partner.vm", model);
+		LOGGER.info("this.getContentFromTemplate {}", htmlContent);
-				.stream().map(x->x.getId()).collect(Collectors.toList());
+		fileStreamsMap.put(fileName, this.getImageBuffer(htmlContent));
-		sendNotificationModel.setUserIds(dtrIds);
+		this.uploadFile(fileStreamsMap);
 		notificationService.sendNotification(sendNotificationModel);
-		try {
-			Map<String, Object> model = new HashMap<>();
-			model.put("offer", createOfferRequest);
-			String htmlContent=this.getContentFromTemplate("offer_margin_detail_partner.vm", model);
-			LOGGER.info("this.getContentFromTemplate {}", htmlContent);
-			fileStreamsMap.put(fileName, this.getImageBuffer(htmlContent));
-			this.uploadFile(fileStreamsMap);
-		} catch (Exception e) {
-			e.printStackTrace();
-		}
+	}
-	private InputStream	asInputStream(BufferedImage bi) throws Exception {
+	private InputStream asInputStream(BufferedImage bi) throws Exception {
 		ByteArrayOutputStream baos = new ByteArrayOutputStream();
 		ImageIO.write(bi, "png", baos);
 		return new ByteArrayInputStream(baos.toByteArray());
+	}
 	private ChannelSftp setupJsch() throws JSchException {
 		JSch jsch = new JSch();
 		Session jschSession = jsch.getSession("root", "192.168.179.131");
-		//Session jschSession = jsch.getSession("root", "173.255.254.24");
+		// Session jschSession = jsch.getSession("root", "173.255.254.24");
+		LOGGER.info("getClass().getResource(\"id_rsa\") {}",
-		LOGGER.info("getClass().getResource(\"id_rsa\") {}", getClass().getClassLoader().getResource("id_rsa").getPath());
+				getClass().getClassLoader().getResource("id_rsa").getPath());
 		jsch.addIdentity(getClass().getClassLoader().getResource("id_rsa").getPath());
-		//jschSession.setPassword("spic@2015static0");
+		// jschSession.setPassword("spic@2015static0");
 		jschSession.setConfig("StrictHostKeyChecking", "no");
 		jschSession.connect();
 		return (ChannelSftp) jschSession.openChannel("sftp");
+	}
 		for (Map.Entry<String, InputStream> streamsFileEntry : streamsFileMap.entrySet()) {
 			channelSftp.put(streamsFileEntry.getValue(), streamsFileEntry.getKey(), ChannelSftp.OVERWRITE);
+		}
+	}
 	private void uploadFile(Map<String, InputStream> fileStreamsMap) throws Exception {
 		ChannelSftp channelSftp = setupJsch();
 		channelSftp.connect();
 		this.fileUpload(channelSftp, fileStreamsMap, IMAGE_REMOTE_DIR + "");
 		channelSftp.exit();
+	}
-	private InputStream getImageBuffer (String html) throws Exception {
+	private InputStream getImageBuffer(String html) throws Exception {
 		String fileName = "/tmp/" + Instant.now().toEpochMilli();
 		FileUtils.writeStringToFile(new File(fileName), html, "UTF-8");
 		String address = "file:" + fileName;
 		Java2DRenderer renderer = new Java2DRenderer(address, 400);
-		RenderingHints hints = new RenderingHints(RenderingHints.KEY_COLOR_RENDERING, RenderingHints.VALUE_COLOR_RENDER_QUALITY);
+		RenderingHints hints = new RenderingHints(RenderingHints.KEY_COLOR_RENDERING,
+				RenderingHints.VALUE_COLOR_RENDER_QUALITY);
 		hints.add(new RenderingHints(RenderingHints.KEY_RENDERING, RenderingHints.VALUE_RENDER_QUALITY));
 		hints.add(new RenderingHints(RenderingHints.KEY_ANTIALIASING, RenderingHints.VALUE_ANTIALIAS_ON));
 		hints.add(new RenderingHints(RenderingHints.KEY_INTERPOLATION, RenderingHints.VALUE_INTERPOLATION_BICUBIC));
 		renderer.setRenderingHints(hints);
 		BufferedImage img = renderer.getImage();
 				Arrays.asList("Id", "Name", "Target Type", "Scheme Type", "Brand %", "Sellin %", "Partner Criteria",
 						"Item Criteria", "Start", "End", "Created", "Partner Id", "Partner Name", "Partner Code",
 						"Total Sale", "Eligible Sale", "Achieved Target", "Next Target", "Eligible Sale DP",
 						"Total Purchase DP", "Current Payout Target", "Payout Target Achieved", "Payout Amount Type",
 						"Payout Value", "Payout Value DP", "Amount to be credited", "IMEIs pending for Activation"
-				// "Payout Sale Qty", "Activated Value", "Activated Qty",
+						// "Payout Sale Qty", "Activated Value", "Activated Qty",
 				), listOfRows);
 		final InputStream inputStream = new ByteArrayInputStream(baos.toByteArray());
 		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
 		return new ResponseEntity<>(inputStreamResource, headers, HttpStatus.OK);
+	}
 	@Autowired
 	RoleManager roleManager;
 	@RequestMapping(value = "/getOfferMargins", method = RequestMethod.GET)
 	public String getOfferMargins(HttpServletRequest request,
-			@RequestParam(name = "offerId", defaultValue = "0") int offerId, Model model) throws Exception {
+								  @RequestParam(name = "offerId", defaultValue = "0") int offerId, Model model) throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
 		CreateOfferRequest createOfferRequest = offerService.getOffer(isAdmin ? 0 : loginDetails.getFofoId(), offerId);
 		model.addAttribute("offer", createOfferRequest);

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/OfferController.java – Rev 29921 → 29926