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

 package com.spice.profitmandi.web.controller;
-import java.io.Serializable;
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.stream.Collectors;
-import javax.servlet.http.HttpServletRequest;
-import org.apache.commons.io.output.ByteArrayOutputStream;
-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.ByteArrayResource;
-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.PathVariable;
-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 com.fasterxml.jackson.databind.ObjectMapper;
+import com.spice.profitmandi.common.enumuration.MessageType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
-import com.spice.profitmandi.common.model.ImeiDropSummaryModel;
-import com.spice.profitmandi.common.model.ItemDescriptionModel;
-import com.spice.profitmandi.common.model.PriceDropImeisModel;
-import com.spice.profitmandi.common.model.PriceDropModel;
+import com.spice.profitmandi.common.model.*;
-import com.spice.profitmandi.common.model.PriceDropProcessModel;
 import com.spice.profitmandi.common.services.ReporticoService;
 import com.spice.profitmandi.common.util.FileUtil;
 import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.common.util.Utils;
+import com.spice.profitmandi.dao.entity.auth.AuthUser;
 import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
+import com.spice.profitmandi.dao.entity.dtr.User;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.PartnerType;
 import com.spice.profitmandi.dao.entity.inventory.ItemPricingHistory;
 import com.spice.profitmandi.dao.entity.inventory.VendorItemPricing;
 import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
 import com.spice.profitmandi.dao.entity.transaction.PriceDropIMEI;
 import com.spice.profitmandi.dao.enumuration.transaction.PriceDropImeiStatus;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
+import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
+import com.spice.profitmandi.dao.repository.dtr.UserRepository;
 import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
 import com.spice.profitmandi.dao.repository.inventory.ItemPricingHistoryRepository;
 import com.spice.profitmandi.dao.repository.inventory.VendorItemPricingRepository;
 import com.spice.profitmandi.dao.repository.transaction.LineItemImeisRepository;
 import com.spice.profitmandi.dao.repository.transaction.PriceDropIMEIRepository;
 import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
+import com.spice.profitmandi.service.NotificationService;
 import com.spice.profitmandi.service.inventory.InventoryService;
 import com.spice.profitmandi.service.pricecircular.PriceCircularItemModel;
 import com.spice.profitmandi.service.pricecircular.PriceCircularModel;
 import com.spice.profitmandi.service.pricecircular.PriceCircularService;
 import com.spice.profitmandi.service.pricing.PriceDropService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.wallet.WalletService;
 import com.spice.profitmandi.web.model.LoginDetails;
 import com.spice.profitmandi.web.util.CookiesProcessor;
 import com.spice.profitmandi.web.util.MVCResponseSender;
+import org.apache.commons.io.output.ByteArrayOutputStream;
+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.ByteArrayResource;
+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.*;
+import javax.servlet.http.HttpServletRequest;
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.*;
+import java.util.stream.Collectors;
 @Controller
 @Transactional(rollbackFor = Throwable.class)
 public class PriceDropController {
 	private static final Logger LOGGER = LogManager.getLogger(PriceDropController.class);
 	@Autowired
+	private CsService csService;
+	@Autowired
+	private UserRepository dtrUserRepository;
+	@Autowired
 	private PriceDropRepository priceDropRepository;
 	@Autowired
 	private ObjectMapper objectMapper;
 	@Autowired
 	private RetailerService retailerService;
 	@Autowired
+	private NotificationService notificationService;
+	@Autowired
 	private FofoStoreRepository fofoStoreRepository;
 	@RequestMapping(value = "/getItemDescription", method = RequestMethod.GET)
 	public String getItemDescription(HttpServletRequest request, Model model) throws Throwable {
 		List<PriceDrop> priceDrops = priceDropRepository.selectAllIncomplete();
 				priceDrop.setCreatedOn(LocalDateTime.now());
 				priceDrop.setCatalogItemId(currentItem.getCatalogItemId());
 				priceDropRepository.persist(priceDrop);
 				priceDropService.priceDropStatus(priceDrop.getId());
 				response = true;
+				this.sendPriceChangeNotification(priceDrop);
 			} else {
 				throw new ProfitMandiBusinessException("Price Drop", priceDropModel.getPd(),
 						"Price Drop Should be greater than 0");
+			}
+		}
 		model.addAttribute("response", mvcResponseSender.createResponseString(response));
 		return "response";
+	}
+	private void sendPriceChangeNotification(PriceDrop priceDrop) throws ProfitMandiBusinessException {
+		List<Item> items = itemRepository.selectAllByCatalogItemId(priceDrop.getCatalogItemId());
+		String title = "Price has been %s for %s";
+		SendNotificationModel sendNotificationModel = new SendNotificationModel();
+		sendNotificationModel.setCampaignName("pricechange");
+		sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
+		sendNotificationModel.setTitle("");
+		StringBuffer sb = new StringBuffer();
+		String message = null;
+		if(priceDrop.getDropAmount() > 0) {
+			title = String.format(title, "dropped", items.get(0).getItemDescriptionNoColor());
+			message = String.format("Price has been dropped from Rs.%d. Old DP - Rs.%d, New DP - Rs.%d", priceDrop.getDropAmount(),
+					priceDrop.getOldDp(), priceDrop.getNewDp());
+		} else {
+			title = String.format(title, "increased", items.get(0).getItemDescriptionNoColor());
+			message = String.format("Price has been increased from Rs.%d. Old DP - Rs.%d, New DP - Rs.%d", -priceDrop.getDropAmount(),
+					priceDrop.getOldDp(), priceDrop.getNewDp());
+		}
+		sendNotificationModel.setTitle(title);
+		sendNotificationModel.setMessage(message);
+		sendNotificationModel.setMessageType(MessageType.pricechange);
+		sendNotificationModel.setUserIds(fofoStoreRepository.selectAllDtrUserIds());
+		Set<AuthUser> authUsers = new HashSet<>(csService.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM));
+		authUsers.addAll(csService.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY));
+		authUsers.addAll(csService.getAuthUserByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES));
+		List<String> emailIds = authUsers.stream().map(x->x.getEmailId()).collect(Collectors.toList());
+		List<User> user = dtrUserRepository.selectAllByEmailIds(emailIds);
+		sendNotificationModel.getUserIds().addAll(user.stream().map(x->x.getId()).collect(Collectors.toList()));
+		notificationService.sendNotification(sendNotificationModel);
+	}
 	@RequestMapping(value = "/downloadtotalPriceDropIMEI/{priceDropId}", method = RequestMethod.GET)
 	public ResponseEntity<?> downloadTotalPriceDropIMEI(HttpServletRequest request, @PathVariable int priceDropId,
 			Model model) throws ProfitMandiBusinessException, Exception {

Subversion Repositories SmartDukaan

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