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

 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.apache.poi.ss.usermodel.Row.MissingCellPolicy;
+import org.apache.poi.xssf.usermodel.XSSFRow;
+import org.apache.poi.xssf.usermodel.XSSFSheet;
+import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.apache.thrift.TException;
 import org.json.JSONObject;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
 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.google.gson.Gson;
 import com.spice.profitmandi.common.enumuration.SearchType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.CustomCurrentInventorySnapshot;
 import com.spice.profitmandi.common.util.PdfUtils;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
 import com.spice.profitmandi.dao.entity.catalog.TagRanking;
+import com.spice.profitmandi.dao.entity.dtr.NotificationCampaign;
 import com.spice.profitmandi.dao.entity.dtr.NotificationCampaigns;
+import com.spice.profitmandi.dao.entity.dtr.PushNotifications;
+import com.spice.profitmandi.dao.entity.dtr.UserCampaign;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
 import com.spice.profitmandi.dao.entity.fofo.LiveDemoSerialNumber;
 import com.spice.profitmandi.dao.entity.transaction.NotifyColorChange;
 import com.spice.profitmandi.dao.entity.transaction.NotifyItem;
 import com.spice.profitmandi.dao.entity.transaction.NotifyMessage;
 import com.spice.profitmandi.dao.entity.transaction.NotifyOrder;
 import com.spice.profitmandi.dao.entity.transaction.Order;
+import com.spice.profitmandi.dao.entity.user.Device;
 import com.spice.profitmandi.dao.entity.user.User;
+import com.spice.profitmandi.dao.model.SimpleCampaign;
+import com.spice.profitmandi.dao.model.SimpleCampaignParams;
+import com.spice.profitmandi.dao.repository.catalog.DeviceRepository;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagRankingRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
+import com.spice.profitmandi.dao.repository.dtr.NotificationCampaignRepository;
+import com.spice.profitmandi.dao.repository.dtr.PushNotificationRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
+import com.spice.profitmandi.dao.repository.dtr.UserCampaignRepository;
 import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
 import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
 import com.spice.profitmandi.dao.repository.fofo.LiveDemoBillingRespository;
 import com.spice.profitmandi.dao.repository.inventory.NotifyStatus;
 import com.spice.profitmandi.dao.repository.transaction.NotifyColorChangeRepository;
 	@Autowired
 	JavaMailSender mailSender;
 	@Autowired
+	private NotificationCampaignRepository notificationCampaignRepository;
+	@Autowired
+	private DeviceRepository deviceRepository;
+	@Autowired
 	private Mongo mongoClient;
+	@Autowired
+	private PushNotificationRepository pushNotificationRepository;
+	@Autowired
+	private UserCampaignRepository userCampaignRepository;
+	@Autowired
+	private Gson gson;
 	@RequestMapping(value = "/getCurrentInventorySnapshot")
 	public String getCurrentAvailability(HttpServletRequest request,
 			@RequestParam(name = "offset", defaultValue = "0") int offset,
 			@RequestParam(name = "limit", defaultValue = "10") int limit,
 			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm, Model model)
 		final HttpHeaders headers = new HttpHeaders();
 		headers.setContentType(MediaType.APPLICATION_PDF);
 		headers.set("Content-disposition", "inline; filename=invoices.pdf");
 		ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
 		List<PdfModel> pdfModels = new ArrayList<>();
+		/*
-		/*for (FofoOrder fofoOrder : fofoOrders) {
+		 * for (FofoOrder fofoOrder : fofoOrders) { try {
-			try {
-				pdfModels.add(orderService.getInvoicePdfModel(fofoOrder.getId()));
+		 * pdfModels.add(orderService.getInvoicePdfModel(fofoOrder.getId())); } catch
-			} catch (Exception e) {
+		 * (Exception e) {
-				LOGGER.info("could not create invoice for {}, invoice number {}", fofoOrder.getId(),
+		 * LOGGER.info("could not create invoice for {}, invoice number {}",
-						fofoOrder.getInvoiceNumber());
+		 * fofoOrder.getId(), fofoOrder.getInvoiceNumber()); } }
-			}
-		}*/
+		 */
 		PdfUtils.generateAndWrite(pdfModels, byteArrayOutputStream);
 		headers.setContentLength(byteArrayOutputStream.toByteArray().length);
 		final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
 		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
 		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
 		// return
 		// responseSender.ok(ResponseCodeHolder.getMessage("ITM_AGNG_OK_1000"));
+	}
 	@RequestMapping(value = "/featurePanel", method = RequestMethod.GET)
-	public String FeaturePanel(HttpServletRequest request,Model model) throws Exception {
+	public String FeaturePanel(HttpServletRequest request, Model model) throws Exception {
 		List<TagRanking> tagRanking = null;
 		tagRanking = tagRankingRepository.getAllTagRanking();
 		LOGGER.info("tagRanking" + tagRanking);
 		if (!tagRanking.isEmpty()) {
-            Set<Integer> catalogIds = tagRanking.stream().map(x -> x.getCatalogItemId()).collect(Collectors.toSet());
+			Set<Integer> catalogIds = tagRanking.stream().map(x -> x.getCatalogItemId()).collect(Collectors.toSet());
 			List<Item> items = itemRepository.selectAllByCatalogIds(catalogIds);
 			Map<Integer, String> catalogDescription = items.stream().collect(Collectors.toMap(x -> x.getCatalogItemId(),
 					x -> x.getItemDescription(), (description1, description2) -> description1));
 			LOGGER.info("catalogDescription" + catalogDescription);
 	 * "feature-paginated"; }
 	 */
 	@RequestMapping(value = "/itemfeature", method = RequestMethod.POST)
 	public String Itemfeature(HttpServletRequest request, @RequestBody ItemFeatureDataModel itemFeatureDatatModel,
 			Model model) throws Exception {
-        TagRanking tagRanking = tagRankingRepository.selectBycatalogItemId(itemFeatureDatatModel.getCatalogItemId());
+		TagRanking tagRanking = tagRankingRepository.selectBycatalogItemId(itemFeatureDatatModel.getCatalogItemId());
-        LOGGER.info("tagRanking" + tagRanking);
+		LOGGER.info("tagRanking" + tagRanking);
-        if(tagRanking == null) {
+		if (tagRanking == null) {
-		tagRanking = new TagRanking();
+			tagRanking = new TagRanking();
-		tagRanking.setCatalogItemId(itemFeatureDatatModel.getCatalogItemId());
+			tagRanking.setCatalogItemId(itemFeatureDatatModel.getCatalogItemId());
+		}
 		tagRanking.setFeature(itemFeatureDatatModel.getFeature());
 		tagRanking.setRankPoints(itemFeatureDatatModel.getRankPoints());
 		tagRankingRepository.persist(tagRanking);
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
 			Set<String> serial = new HashSet<>();
 			for (InventoryItem invItem : inventoryItem) {
 				if (!serailNumberList.contains(invItem.getSerialNumber())) {
 					inventoryItem1.add(invItem);
+				}
+			}
 			LOGGER.info("inventoyItem" + inventoryItem1);
 			model.addAttribute("customRetailers", customRetailers);
-			model.addAttribute("liveDemo", inventoryItem1);
+			model.addAttribute("liveDemo", inventoryItem1);
 			CustomRetailer fofoIdsAndRetailerName = retailerService.getFofoRetailer(fofoId);
 			model.addAttribute("fofoIdsAndRetailerName", fofoIdsAndRetailerName);
+		}
 		// User userInfo = saholicUserRepository.selectById(loginDetails.getFofoId());
 		LOGGER.info("status" + orderStatus);
 		try {
 			Order order = orderRepository.selectById(orderId);
 			orderRepository.refundOrder(orderId, loginDetails.getEmailId(), reason, orderStatus);
 			sendCancellationNotificationToPartner(order, reason);
 			model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		} catch (TransactionServiceException | TException e) {
 			model.addAttribute("response", mvcResponseSender.createResponseString(false));
 		return "response";
+	}
 	private void sendCancellationNotificationToPartner(Order order, String reason) throws Exception {
 		Item item = itemRepository.selectById(order.getLineItem().getItemId());
-		NotificationCampaigns notification = new NotificationCampaigns();
+		SimpleCampaignParams scp = new SimpleCampaignParams();
-		notification.setName("Order Cancellation");
-		notification.setTitle(String.format("Order %s %d(Pcs) cancelled", item.getItemDescription(),
+		scp.setTitle(String.format("Order %s %d(Pcs) cancelled", item.getItemDescription(),
 				order.getLineItem().getQuantity()));
-		notification.setMessage(reason);
+		scp.setMessage(reason);
-		notification.setType("url");
+		scp.setType("url");
-		notification.setUrl("http://app.profitmandi.com/pages/home/notifications");
+		scp.setUrl("http://app.profitmandi.com/pages/home/notifyOrder");
+		scp.setExpireTimestamp(LocalDateTime.now().plusDays(2));
+		SimpleCampaign sc = new SimpleCampaign(scp);
+		sc.setSimpleCampaignParams(scp);
-		notification.setSql("SELECT distinct d1.user_id from devices d1 left join devices d2 on"
+		NotificationCampaign nc = new NotificationCampaign();
+		nc.setName("Order Cancellation");
+		nc.setImplementationType("SimpleCampaign");
+		nc.setImplementationParams(gson.toJson(scp));
-				+ "(d1.imeinumber = d2.imeinumber and d1.created < d2.created) "
+		nc.setCreatedTimestamp(LocalDateTime.now());
-				+ " where d2.id is null and d1.user_id = "
+		notificationCampaignRepository.persist(nc);
-				+ userAccountRepository.selectUserIdByRetailerId(order.getRetailerId()));
+		int userId = userAccountRepository.selectUserIdByRetailerId(order.getRetailerId());
-		notification.setExpiresat(LocalDateTime.now().plusDays(2).toEpochSecond(ZoneOffset.UTC) * 1000);
+		UserCampaign uc = new UserCampaign();
-		notification.setStatus("active");
+		uc.setCampaignId(nc.getId());
-		notification.setSmsprocessed(0);
+		uc.setUserId(userId);
+		uc.setPushTimestamp(LocalDateTime.now());
-		notification.setNotification_processed(0);
+		userCampaignRepository.persist(uc);
+		List<Device> devices = deviceRepository.selectByUserIdAndModifiedTimestamp(userId,
-		notification.setNotification_type("GENERAL_NOTIFICATION");
+				LocalDateTime.now().minusMonths(3), LocalDateTime.now());
-		mongoClient.persistNotificationCmpInfo(notification);
+		pushNotification(nc.getId(), devices);
+	}
 	@RequestMapping(value = "/getNotifyItemColor", method = RequestMethod.GET)
 	public String getNotifyItemColor(HttpServletRequest request, @RequestParam int catalogItemId,
 		for (Order order : orders) {
 			LOGGER.info("order" + order.getId());
 			NotifyMessage message = notifyMessageRepository.selectByNotifyId(notifytimestamp.getId());
+			SimpleCampaignParams scp = new SimpleCampaignParams();
-			// LOGGER.info("message112" + message.getNotifyMessages());
+			scp.setMessage(message.getNotifyMessages());
+			scp.setTitle("Notify Partner");
+			scp.setType("url");
+			scp.setUrl("http://app.profitmandi.com/pages/home/notifyOrder");
+			scp.setExpireTimestamp(LocalDateTime.now().plusDays(2));
+			SimpleCampaign sc = new SimpleCampaign(scp);
+			sc.setSimpleCampaignParams(scp);
-			NotificationCampaigns notification = new NotificationCampaigns();
+			NotificationCampaign nc = new NotificationCampaign();
-			notification.setName("Notify Partner");
+			nc.setName("Notify Partner");
-			notification.setTitle("Notify Partner");
+			nc.setImplementationType("SimpleCampaign");
-			notification.setMessage(message.getNotifyMessages());
+			nc.setImplementationParams(gson.toJson(scp));
-			notification.setType("url");
+			nc.setCreatedTimestamp(LocalDateTime.now());
-			notification.setUrl("http://app.profitmandi.com/pages/home/notifyOrder");
+			notificationCampaignRepository.persist(nc);
-			notification.setSql("SELECT distinct d1.user_id from devices d1 left join devices d2 on"
+			int userId = userAccountRepository.selectUserIdByRetailerId(order.getRetailerId());
-					+ "(d1.imeinumber = d2.imeinumber and d1.created < d2.created) "
+			UserCampaign uc = new UserCampaign();
-					+ " where d2.id is null and d1.user_id = "
+			uc.setCampaignId(nc.getId());
-					+ userAccountRepository.selectUserIdByRetailerId(order.getRetailerId()));
+			uc.setUserId(userId);
-			notification.setExpiresat(LocalDateTime.now().plusDays(2).toEpochSecond(ZoneOffset.UTC) * 1000);
-			notification.setStatus("active");
+			uc.setPushTimestamp(LocalDateTime.now());
-			notification.setSmsprocessed(0);
+			userCampaignRepository.persist(uc);
-			notification.setNotification_processed(0);
+			List<Device> devices = deviceRepository.selectByUserIdAndModifiedTimestamp(userId,
-			notification.setNotification_type("GENERAL_NOTIFICATION");
+					LocalDateTime.now().minusMonths(3), LocalDateTime.now());
-			mongoClient.persistNotificationCmpInfo(notification);
+			pushNotification(nc.getId(), devices);
+		}
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
+	public void pushNotification(int cid, List<Device> devices) {
+		for (Device device : devices) {
+			PushNotifications pn = new PushNotifications();
+			pn.setNotificationCampaignid(cid);
+			pn.setDeviceId(device.getId());
+			pn.setUserId(device.getUser_id());
+			pushNotificationRepository.persist(pn);
+		}
+	}
 	private void sendMailOfHtmlFomat(String email, String messageText, String subject)
 			throws MessagingException, ProfitMandiBusinessException, IOException {
 		MimeMessage message = mailSender.createMimeMessage();
 		MimeMessageHelper helper = new MimeMessageHelper(message);
 		helper.setSubject(subject);
 			notifyIdNotifyColorMap.put(notifyColorChange.getId(), notifyColorChange);
+		}
 		return notifyIdNotifyColorMap;
+	}
-	/*@RequestMapping(value = "/getContentUploader", method = RequestMethod.GET)
+	@RequestMapping(value = "/getContentUploader", method = RequestMethod.GET)
 	public String contentUploader(HttpServletRequest request) throws Exception {
 		return "content-upload";
+	}
+	/*@RequestMapping(value = "/fileUpload", method = RequestMethod.POST)
+	public String updateContents(HttpServletRequest request, @RequestParam("file") MultipartFile multipartFile)
+			throws Throwable {
+		try (XSSFWorkbook myWorkBook = new XSSFWorkbook(multipartFile.getInputStream())) {
+			myWorkBook.setMissingCellPolicy(MissingCellPolicy.RETURN_BLANK_AS_NULL);
+			// Return first sheet from the XLSX workbook
+			XSSFSheet mySheet = myWorkBook.getSheetAt(0);
+			LOGGER.info("row" + mySheet.getLastRowNum());
+			for (int rowNumber = 0; rowNumber <= mySheet.getLastRowNum(); rowNumber++) {
+				XSSFRow row = mySheet.getRow(rowNumber);
+				LOGGER.info("row1" + row.getCell(0).getStringCellValue());
+			}
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+		LOGGER.info("multipart" + multipartFile);
+		return "response";
 	}*/
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/InventoryController.java – Rev 25363 → 25371