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

 package com.spice.profitmandi.web.controller;
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
-import java.io.IOException;
 import java.io.InputStream;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.Map;
 import java.util.Optional;
 import java.util.Set;
 import java.util.stream.Collectors;
-import javax.mail.MessagingException;
-import javax.mail.internet.InternetAddress;
-import javax.mail.internet.MimeMessage;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.mail.javamail.JavaMailSender;
-import org.springframework.mail.javamail.MimeMessageHelper;
 import org.springframework.stereotype.Controller;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.ui.Model;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import com.spice.profitmandi.common.model.NotifyOrderIdModel;
 import com.spice.profitmandi.common.model.NotifyOrderModel;
 import com.spice.profitmandi.common.model.OrderCancellationModel;
 import com.spice.profitmandi.common.model.PdfModel;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
+import com.spice.profitmandi.common.model.SendNotificationModel;
 import com.spice.profitmandi.common.util.ExcelUtils;
 import com.spice.profitmandi.common.util.PdfUtils;
 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.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.transaction.NotifyColorChangeRepository;
 import com.spice.profitmandi.dao.repository.transaction.NotifyItemRepository;
 import com.spice.profitmandi.dao.repository.transaction.NotifyMessageRepository;
 import com.spice.profitmandi.dao.repository.transaction.NotifyOrderRespository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
-import com.spice.profitmandi.dao.repository.user.UserRepository;
+import com.spice.profitmandi.service.NotificationService;
 import com.spice.profitmandi.service.inventory.InventoryService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.web.model.LoginDetails;
 import com.spice.profitmandi.web.util.CookiesProcessor;
 import com.spice.profitmandi.web.util.MVCResponseSender;
 	@Autowired
 	private NotifyOrderRespository notifyOrderRespository;
 	@Autowired
+	private NotificationService notificationService;
+	@Autowired
 	private NotifyMessageRepository notifyMessageRepository;
 	@Autowired
 	private UserAccountRepository userAccountRepository;
+	}
 	private void sendCancellationNotificationToPartner(Order order, String reason) throws Exception {
 		Item item = itemRepository.selectById(order.getLineItem().getItemId());
-		SimpleCampaignParams scp = new SimpleCampaignParams();
+		SendNotificationModel sendNotificationModel = new SendNotificationModel();
+		sendNotificationModel.setCampaignName("Order Cancellation");
-		scp.setTitle(String.format("Order %s %d(Pcs) cancelled", item.getItemDescription(),
+		sendNotificationModel.setTitle(String.format("Order %s %d(Pcs) cancelled", item.getItemDescription(),
 				order.getLineItem().getQuantity()));
-		scp.setMessage(reason);
+		sendNotificationModel.setType("url");
-		scp.setType("url");
+		sendNotificationModel.setMessage(reason);
-		scp.setUrl("http://app.smartdukaan.com/pages/home/orderDetails");
+		sendNotificationModel.setUrl("http://app.smartdukaan.com/pages/home/orderDetails");
-		scp.setExpireTimestamp(LocalDateTime.now().plusDays(2));
+		sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(2));
-		SimpleCampaign sc = new SimpleCampaign(scp);
-		sc.setSimpleCampaignParams(scp);
-		NotificationCampaign nc = new NotificationCampaign();
-		nc.setName("Order Cancellation");
-		nc.setImplementationType("SimpleCampaign");
-		nc.setImplementationParams(gson.toJson(scp));
-		nc.setMessageType(MessageType.notification);
+		sendNotificationModel.setMessageType(MessageType.notification);
-		nc.setCreatedTimestamp(LocalDateTime.now());
-		notificationCampaignRepository.persist(nc);
+		notificationService.sendNotification(sendNotificationModel);
-		int userId = userAccountRepository.selectUserIdByRetailerId(order.getRetailerId());
-		UserCampaign uc = new UserCampaign();
-		uc.setCampaignId(nc.getId());
-		uc.setUserId(userId);
-		uc.setPushTimestamp(LocalDateTime.now());
-		userCampaignRepository.persist(uc);
-		List<Device> devices = deviceRepository.selectByUserIdAndModifiedTimestamp(userId,
-				LocalDateTime.now().minusMonths(3), LocalDateTime.now());
-		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());
+			SendNotificationModel sendNotificationModel = new SendNotificationModel();
-			SimpleCampaignParams scp = new SimpleCampaignParams();
+			sendNotificationModel.setCampaignName("Notify Partner");
-			scp.setMessage(message.getNotifyMessages());
+			sendNotificationModel.setMessage(message.getNotifyMessages());
-			scp.setTitle("Alert");
+			sendNotificationModel.setType("url");
-			scp.setType("url");
+			sendNotificationModel.setTitle("Alert");
-			scp.setUrl("http://app.smartdukaan.com/pages/home/notifyOrder");
+			sendNotificationModel.setUrl("http://app.smartdukaan.com/pages/home/notifyOrder");
-			scp.setExpireTimestamp(LocalDateTime.now().plusDays(2));
+			sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(2));
-			SimpleCampaign sc = new SimpleCampaign(scp);
-			sc.setSimpleCampaignParams(scp);
-			NotificationCampaign nc = new NotificationCampaign();
-			nc.setName("Notify Partner");
-			nc.setImplementationType("SimpleCampaign");
-			nc.setImplementationParams(gson.toJson(scp));
-			nc.setCreatedTimestamp(LocalDateTime.now());
-			nc.setMessageType(MessageType.notification);
+			sendNotificationModel.setMessageType(MessageType.notification);
-			notificationCampaignRepository.persist(nc);
+			notificationService.sendNotification(sendNotificationModel);
-			int userId = userAccountRepository.selectUserIdByRetailerId(order.getRetailerId());
-			UserCampaign uc = new UserCampaign();
-			uc.setCampaignId(nc.getId());
-			uc.setUserId(userId);
-			uc.setPushTimestamp(LocalDateTime.now());
-			userCampaignRepository.persist(uc);
-			List<Device> devices = deviceRepository.selectByUserIdAndModifiedTimestamp(userId,
-					LocalDateTime.now().minusMonths(3), LocalDateTime.now());
-			pushNotification(nc.getId(), devices);
+		}
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
 			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);
-		helper.setText(messageText, true);
-		helper.setTo(email);
-		InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smart Dukaan");
-		helper.setFrom(senderAddress);
-		mailSender.send(message);
-	}
-	/*
-	 * private String getMessage(List<NotifyOrderModel> notifyOrderModels, Order
-	 * order) throws ProfitMandiBusinessException {
-	 *
-	 * StringBuilder sb = new StringBuilder(); sb.
-	 * append("<html><body><p>Notify Partner</p><p>Which have order out stock following model:-</p>"
-	 * + "<div>" + order.getLineItem().getItem().getItemDescription() +
-	 * "</div> <div>choose the model from following:- </div><br/><table style='border:1px solid black ;padding: 5px';>"
-	 * ); sb.append("<tbody>\n" + "	    				<tr>\n" +
-	 * "	    					<th style='border:1px solid black;padding: 5px'>Color</th>\n"
-	 * +
-	 * "	    					<th style='border:1px solid black;padding: 5px'>Procured Time</th>\n"
-	 * +
-	 * "	    					<th style='border:1px solid black;padding: 5px'>Response Time</th>\n"
-	 * + "	    				</tr>"); for (NotifyOrderModel notifyOrderModel :
-	 * notifyOrderModels) { Item item =
-	 * itemRepository.selectById(notifyOrderModel.getItemId()); sb.append("<tr>");
-	 * sb.append("<td style='border:1px solid black;padding: 5px'>" +
-	 * item.getColor() + "</td>");
-	 *
-	 * sb.append("<td style='border:1px solid black;padding: 5px'>" +
-	 * notifyOrderModel.getFormattedProcuredTime() + "</td>");
-	 *
-	 * sb.append("<td style='border:1px solid black;padding: 5px'>" +
-	 * notifyOrderModel.getFormattedResponseTime() + "</td>");
-	 *
-	 * sb.append("</tr>"); }
-	 *
-	 * sb.append("</tbody></table></body></html>"); return sb.toString(); }
-	 */
 	@RequestMapping(value = "/getAllNotifyOrder", method = RequestMethod.GET)
 	public String getAllNotifyOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
 		List<NotifyOrder> notifyOrders = null;
 		List<com.spice.profitmandi.dao.entity.transaction.Order> inProcessorder = orderRepository
 				.selectAllOrder(OrderStatus.SUBMITTED_FOR_PROCESSING);

Subversion Repositories SmartDukaan

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