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

 package com.spice.profitmandi.web.controller;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
 import java.text.DecimalFormat;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.time.ZoneOffset;
 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.Value;
+import org.springframework.core.io.InputStreamResource;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Controller;
 import org.springframework.ui.Model;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
 import com.google.gson.Gson;
 import com.mongodb.DBObject;
+import com.spice.profitmandi.common.enumuration.ContentType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.BrandStockPrice;
 import com.spice.profitmandi.common.model.Notification;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.model.SendNotificationModel;
+import com.spice.profitmandi.common.web.util.ResponseSender;
 import com.spice.profitmandi.dao.Interface.Campaign;
+import com.spice.profitmandi.dao.entity.dtr.Document;
 import com.spice.profitmandi.dao.entity.dtr.NotificationCampaign;
+import com.spice.profitmandi.dao.entity.dtr.Retailer;
 import com.spice.profitmandi.dao.entity.dtr.UserCampaign;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.HygieneData;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
 import com.spice.profitmandi.dao.entity.fofo.PartnerTargetDetails;
 import com.spice.profitmandi.dao.entity.fofo.PartnerType;
 import com.spice.profitmandi.dao.model.SimpleCampaign;
 import com.spice.profitmandi.dao.model.SimpleCampaignParams;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
+import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.InsurancePolicyRepository;
 import com.spice.profitmandi.dao.repository.dtr.InsuranceProviderRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
 import com.spice.profitmandi.dao.repository.dtr.NotificationCampaignRepository;
 	@Autowired
 	private CookiesProcessor cookiesProcessor;
 	@Autowired
+	private ResponseSender<?> responseSender;
+	@Autowired
 	private ItemRepository itemRepository;
 	@Autowired
 	private TargetSlabService targetSlabService;
 	@Autowired
 	private NotificationCampaignRepository notificationCampaignRepository;
 	@Autowired
+	private DocumentRepository documentRepository;
+	@Autowired
 	private Mongo mongoClient;
 	@Autowired
 	private Gson gson;
 		LOGGER.info("hygieneData" + hygieneData);
 		int successHygieneData = hygieneData.stream().filter(x -> x.getHygieneRating() == true)
 				.collect(Collectors.toList()).size();
 		int unsuccessfullHygieneData = hygieneData.stream().filter(x -> x.getHygieneRating() == false)
 				.collect(Collectors.toList()).size();
 		model.addAttribute("successHygieneData", successHygieneData);
 		model.addAttribute("fullHygieneData", successHygieneData + unsuccessfullHygieneData);
 		model.addAttribute("monthDays", LocalDate.now().minusDays(1).lengthOfMonth());
 		model.addAttribute("dayOfMonth", LocalDate.now().minusDays(1).getDayOfMonth());
 		return "dashboard1";
+	}
 			@RequestParam(name = "limit", defaultValue = "20") int limit, Model model) throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		int userId = userAccountRepository.selectUserIdByRetailerId(loginDetails.getFofoId());
 		List<UserCampaign> userCampaigns = userCampaignRepository.selectByUserId(userId);
 		List<Notification> notifications = new ArrayList<>();
+		Document document = null;
 		if (!userCampaigns.isEmpty()) {
 			List<Integer> campaignIds = new ArrayList<>();
 			for (UserCampaign userCampaign : userCampaigns) {
 				campaignIds.add(userCampaign.getCampaignId());
+			}
 						LocalDateTime expire = campaign.getExpireTimestamp();
 						ns.setCid(Integer.toString(notificationCampaign.getId()));
 						ns.setType(campaign.getType());
 						ns.setMessage(campaign.getMessage());
 						ns.setTitle(campaign.getTitle());
+						if (notificationCampaign.getDocumentId() != null) {
+							document = documentRepository.selectById(notificationCampaign.getDocumentId());
+							ns.setDocumentName(document.getDisplayName());
+						}
 						ns.setUrl(campaign.getUrl());
 						ns.setShowImage(campaign.getShowImage());
 						ns.setImageUrl(campaign.getImageUrl());
+						ns.setDocumentId(notificationCampaign.getDocumentId());
 						ns.setAnnoucement(notificationCampaign.isAnnoucement());
 						ns.setCreated(notificationCampaign.getCreatedTimestamp()
 								.toEpochSecond(ZoneOffset.ofHoursMinutes(5, 30)) * 1000);
 						if (LocalDateTime.now().isAfter(expire)) {
 							ns.setExpired(true);
 						ns.setCid(Integer.toString(notificationCampaign.getId()));
 						ns.setType(campaign.getType());
 						ns.setMessage(campaign.getMessage());
 						ns.setTitle(campaign.getTitle());
 						ns.setUrl(campaign.getUrl());
+						if (notificationCampaign.getDocumentId() != null) {
+							document = documentRepository.selectById(notificationCampaign.getDocumentId());
+							ns.setDocumentName(document.getDisplayName());
+						}
 						ns.setShowImage(campaign.getShowImage());
 						ns.setImageUrl(campaign.getImageUrl());
+						ns.setDocumentId(notificationCampaign.getDocumentId());
 						ns.setAnnoucement(notificationCampaign.isAnnoucement());
 						ns.setCreated(notificationCampaign.getCreatedTimestamp()
 								.toEpochSecond(ZoneOffset.ofHoursMinutes(5, 30)) * 1000);
 						if (LocalDateTime.now().isAfter(expire)) {
 							ns.setExpired(true);
 					ns.setCid(Integer.toString(notificationCampaign.getId()));
 					ns.setType(campaign.getType());
 					ns.setMessage(campaign.getMessage());
 					ns.setTitle(campaign.getTitle());
 					ns.setUrl(campaign.getUrl());
+					if (notificationCampaign.getDocumentId() != null) {
+						document = documentRepository.selectById(notificationCampaign.getDocumentId());
+						ns.setDocumentName(document.getDisplayName());
+					}
+					ns.setDocumentId(notificationCampaign.getDocumentId());
 					ns.setShowImage(campaign.getShowImage());
 					ns.setImageUrl(campaign.getImageUrl());
 					ns.setAnnoucement(notificationCampaign.isAnnoucement());
 					ns.setCreated(
 							notificationCampaign.getCreatedTimestamp().toEpochSecond(ZoneOffset.ofHoursMinutes(5, 30))
+					}
 					notifications.add(ns);
+				}
+			}
+		}
 		model.addAttribute("notifications", notifications);
+		return "notification-template";
+	}
+	@RequestMapping(value = "/notifyDocument/documentId", method = RequestMethod.GET)
+	public ResponseEntity<?> retailerDocumentById(HttpServletRequest request,
+			@RequestParam(name = ProfitMandiConstants.DOCUMENT_ID) int documentId, @RequestParam int cid)
+			throws ProfitMandiBusinessException {
+		Document document = documentRepository.selectById(documentId);
+		NotificationCampaign nc = notificationCampaignRepository.selectById(cid);
+		if (nc.getDocumentId() == null) {
+			throw new ProfitMandiBusinessException("cid", nc.getId(), "not available");
+		}
+		if (nc.getDocumentId() != documentId) {
+			throw new ProfitMandiBusinessException(ProfitMandiConstants.DOCUMENT_ID, documentId, "RTLR_1014");
+		}
+		return responseSender.ok(document);
+	}
+	@RequestMapping(value = "/notifyDocument/download", method = RequestMethod.GET)
+	public ResponseEntity<?> downloadRetailerDocument(HttpServletRequest request, @RequestParam int cid, Model model)
+			throws ProfitMandiBusinessException {
+		NotificationCampaign nc = notificationCampaignRepository.selectById(cid);
+		if (nc.getDocumentId() == null) {
+			throw new ProfitMandiBusinessException("cid", nc.getId(), "not available");
+		}
+		Document document = documentRepository.selectById(nc.getDocumentId());
+		FileInputStream file = null;
+		try {
+			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();
+		// ExcelUtils.writeSchemeModels(schemeModels, byteArrayOutputStream);
+		final HttpHeaders headers = new HttpHeaders();
+		String contentType = "";
+		if (document.getContentType() == ContentType.JPEG) {
+			contentType = "image/jpeg";
+		} else if (document.getContentType() == ContentType.PNG) {
+			contentType = "image/png";
+		} else if (document.getContentType() == ContentType.PDF) {
+			contentType = "application/pdf";
+		}
+		headers.set("Content-Type", contentType);
+		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);
-		LOGGER.info("notifications"+notifications);
+		// return
-		return "notification-template" ;
+		// responseSender.ok(ResponseCodeHolder.getMessage("ITM_AGNG_OK_1000"));
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/DashboardController.java – Rev 25649 → 25651