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

 package com.spice.profitmandi.web.controller;
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-import java.time.LocalTime;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Collections;
-import java.util.Comparator;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Map.Entry;
-import java.util.Optional;
-import java.util.Set;
-import java.util.function.Function;
-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.apache.thrift.TException;
-import org.json.JSONArray;
-import org.json.JSONObject;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.core.io.ByteArrayResource;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
-import org.springframework.mail.javamail.JavaMailSender;
-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 org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.RequestParam;
 import com.mongodb.DBObject;
 import com.spice.profitmandi.common.enumuration.CounterSize;
 import com.spice.profitmandi.common.enumuration.MessageType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
-import com.spice.profitmandi.common.model.BrandStockPrice;
-import com.spice.profitmandi.common.model.CatalogListingModel;
-import com.spice.profitmandi.common.model.CustomRetailer;
-import com.spice.profitmandi.common.model.FocusedModelShortageModel;
-import com.spice.profitmandi.common.model.IntegerIdAggregateValue;
-import com.spice.profitmandi.common.model.PlannedModel;
+import com.spice.profitmandi.common.model.*;
-import com.spice.profitmandi.common.model.ProfitMandiConstants;
-import com.spice.profitmandi.common.model.SendNotificationModel;
-import com.spice.profitmandi.common.model.StockAllocationModel;
-import com.spice.profitmandi.common.model.SuggestedPoIdModel;
-import com.spice.profitmandi.common.model.SuggestedPoModel;
 import com.spice.profitmandi.common.util.FileUtil;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.common.util.Utils.Attachment;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
 import com.spice.profitmandi.dao.entity.catalog.Category;
 import com.spice.profitmandi.dao.entity.catalog.FocusedModel;
 import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
 import com.spice.profitmandi.dao.entity.cs.Position;
 import com.spice.profitmandi.dao.entity.cs.Region;
-import com.spice.profitmandi.dao.entity.fofo.CurrentInventorySnapshot;
-import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
-import com.spice.profitmandi.dao.entity.fofo.FofoStore;
+import com.spice.profitmandi.dao.entity.fofo.*;
-import com.spice.profitmandi.dao.entity.fofo.MonthlyPlanned;
-import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
-import com.spice.profitmandi.dao.entity.fofo.PartnerType;
-import com.spice.profitmandi.dao.entity.fofo.PlannedDetail;
-import com.spice.profitmandi.dao.entity.fofo.SuggestedPo;
-import com.spice.profitmandi.dao.entity.fofo.SuggestedPoDetail;
 import com.spice.profitmandi.dao.entity.inventory.SaholicCIS;
 import com.spice.profitmandi.dao.entity.inventory.SaholicPOItem;
 import com.spice.profitmandi.dao.entity.transaction.Order;
 import com.spice.profitmandi.dao.entity.transaction.UserWallet;
 import com.spice.profitmandi.dao.entity.user.User;
+import com.spice.profitmandi.dao.entity.warehouse.BrandRegionMapping;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.model.FofoReportingModel;
 import com.spice.profitmandi.dao.model.InStockAccessoriesTvFofoIdModel;
 import com.spice.profitmandi.dao.model.InStockBrandFofoIdModel;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.cs.PositionRepository;
 import com.spice.profitmandi.dao.repository.cs.RegionRepository;
 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.CurrentInventorySnapshotRepository;
-import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
-import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
-import com.spice.profitmandi.dao.repository.fofo.MonthlyPlannedRepository;
-import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
-import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeRepository;
-import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
-import com.spice.profitmandi.dao.repository.fofo.PlannedDetailRepository;
-import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
+import com.spice.profitmandi.dao.repository.fofo.*;
-import com.spice.profitmandi.dao.repository.fofo.SuggestedPoDetailRepository;
-import com.spice.profitmandi.dao.repository.fofo.SuggestedPoRepository;
 import com.spice.profitmandi.dao.repository.inventory.SaholicInventoryCISRepository;
+import com.spice.profitmandi.dao.repository.inventory.WarehouseRepository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
 import com.spice.profitmandi.dao.repository.user.UserRepository;
+import com.spice.profitmandi.dao.repository.warehouse.BrandRegionMappingRepository;
 import com.spice.profitmandi.service.NotificationService;
 import com.spice.profitmandi.service.authentication.RoleManager;
 import com.spice.profitmandi.service.inventory.InventoryService;
 import com.spice.profitmandi.service.inventory.SaholicInventoryService;
 import com.spice.profitmandi.service.inventory.StockAllocationService;
 import com.spice.profitmandi.thrift.clients.TransactionClient;
 import com.spice.profitmandi.thrift.clients.UserClient;
 import com.spice.profitmandi.web.model.LoginDetails;
 import com.spice.profitmandi.web.util.CookiesProcessor;
 import com.spice.profitmandi.web.util.MVCResponseSender;
 import in.shop2020.logistics.PickUpType;
-import in.shop2020.model.v1.order.LineItem;
+import in.shop2020.model.v1.order.*;
-import in.shop2020.model.v1.order.OrderSource;
-import in.shop2020.model.v1.order.OrderStatus;
-import in.shop2020.model.v1.order.OrderType;
-import in.shop2020.model.v1.order.Transaction;
-import in.shop2020.model.v1.order.TransactionService;
-import in.shop2020.model.v1.order.TransactionStatus;
 import in.shop2020.model.v1.user.ItemPriceQuantity;
 import in.shop2020.model.v1.user.ShoppingCartException;
 import in.shop2020.model.v1.user.UserContextService.Client;
 import in.shop2020.payments.Attribute;
 import in.shop2020.payments.PaymentException;
 import in.shop2020.payments.PaymentStatus;
+import org.apache.commons.io.output.ByteArrayOutputStream;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.apache.thrift.TException;
+import org.json.JSONArray;
+import org.json.JSONObject;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.io.ByteArrayResource;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.mail.javamail.JavaMailSender;
+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 org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import javax.servlet.http.HttpServletRequest;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.util.*;
+import java.util.Map.Entry;
+import java.util.function.Function;
+import java.util.stream.Collectors;
 @Controller
 @Transactional(rollbackFor = Throwable.class)
 public class IndentController {
 			OrderStatus.REACHED_DESTINATION_CITY);
 	private static final int PLANNING_OPEN_DAY = 20;
 	private static final int PLANNING_CLOSE_DAY = 1;
+	private static final String PO_TITLE_STRING = "Alert - Stock Arriving at SD Warehouse";
 	@Autowired
 	WalletService walletService;
 	@Autowired
+	BrandRegionMappingRepository brandRegionMappingRepository;
+	@Autowired
 	private JavaMailSender googleMailSender;
 	@Autowired
 	private CookiesProcessor cookiesProcessor;
 	@Autowired
 	private CsService csService;
 	@Autowired
 	private AuthRepository authRepository;
 	@Autowired
-	private SuggestedPoRepository monthlyPoRepository;
+	WarehouseRepository warehouseRepository;
 	@Autowired
-	private SuggestedPoDetailRepository monthlyPoDetailRepository;
+	private SuggestedPoRepository suggestedPoRepository;
 	@Autowired
 	private NotificationService notificationService;
 	@Autowired
 	@Autowired
 	private SaholicInventoryService saholicInventoryService;
 	@Autowired
 	private PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
+	@Autowired
+	private SuggestedPoDetailRepository suggestedPoDetailRepository;
 	@RequestMapping(value = "/open-indent/save", method = RequestMethod.POST)
 	public String saveOpenIndent(HttpServletRequest request, Model model, @RequestParam int catalogId,
-			@RequestParam int itemQty, @RequestParam int fofoId) throws Exception {
+								 @RequestParam int itemQty, @RequestParam int fofoId) throws Exception {
 		if (fofoId == 0) {
 			LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 			fofoId = loginDetails.getFofoId();
 		model.addAttribute("response", mvcResponseSender.createResponseString(false));
 		return "response";
+	}
 	private void saveMonthlyPlanned(MonthlyPlanned monthlyPlanned, int fofoId, LocalDate currentMonthDate,
-			int catalogId, int itemQty) {
+									int catalogId, int itemQty) {
 		if (monthlyPlanned == null) {
 			monthlyPlanned = new MonthlyPlanned();
 			monthlyPlanned.setFofoId(fofoId);
 			monthlyPlanned.setYearMonth(currentMonthDate);
 			monthlyPlannedRepository.persist(monthlyPlanned);
+	}
 	@RequestMapping(value = "/open-indent/confirm", method = RequestMethod.POST)
 	public String confirmOpenIndent(HttpServletRequest request,
-			@RequestParam(required = false, defaultValue = "0") int fofoId, Model model) throws Exception {
+									@RequestParam(required = false, defaultValue = "0") int fofoId, Model model) throws Exception {
 		if (fofoId == 0) {
 			LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 			fofoId = loginDetails.getFofoId();
+		}
 				Arrays.asList("Partner Id", "Partner Name", "Model Name", "Qty"),
 				plannedModel.stream()
 						.map(x -> Arrays.asList(x.getFofoId(), x.getStoreName(), x.getItemDescription(), x.getQty()))
 						.collect(Collectors.toList()));
 		LOGGER.info("baos" + baos);
-		Utils.sendMailWithAttachments(googleMailSender, new String[] { customRetailer.getEmail() },
+		Utils.sendMailWithAttachments(googleMailSender, new String[]{customRetailer.getEmail()},
 				ccemails.toArray(new String[ccemails.size()]), bccemails.toArray(new String[bccemails.size()]),
 				"Planned Indent", "PFA",
-				new Attachment[] { new Attachment("PlannedIndent.csv", new ByteArrayResource(baos.toByteArray())), });
+				new Attachment[]{new Attachment("PlannedIndent.csv", new ByteArrayResource(baos.toByteArray())),});
+	}
 	@RequestMapping(value = "/indent/download", method = RequestMethod.GET)
 	public ResponseEntity<ByteArrayResource> downloadIndent(HttpServletRequest request, Model model,
-			@RequestParam(required = false, defaultValue = "0") int fofoId,
+															@RequestParam(required = false, defaultValue = "0") int fofoId,
-			@RequestParam(defaultValue = "TEN_LAC") CounterSize counterSize) throws Exception {
+															@RequestParam(defaultValue = "TEN_LAC") CounterSize counterSize) throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		Set<Integer> roleIds = loginDetails.getRoleIds();
 		LOGGER.info("Counter size is {}", counterSize);
 		LOGGER.info("Fofo Id is {}", fofoId);
 		if (roleManager.isAdmin(roleIds) || loginDetails.getFofoId() == fofoId) {
+	}
 	@RequestMapping(value = "/itemsByCatalogId")
 	public String getItemsByCatalogId(HttpServletRequest request, Model model,
-			@RequestParam(required = false) int catalogId, @RequestParam(required = false) int itemId)
+									  @RequestParam(required = false) int catalogId, @RequestParam(required = false) int itemId)
 			throws ProfitMandiBusinessException {
 		if (catalogId == 0) {
 			catalogId = itemRepository.selectById(itemId).getCatalogItemId();
+		}
 		List<Item> items = itemRepository.selectAllByCatalogItemId(catalogId);
+	}
 	@RequestMapping(value = "/hotdealsitemsByCatalogId")
 	public String getHotdealsitemsByCatalogId(HttpServletRequest request, Model model,
-			@RequestParam(required = false) int catalogId, @RequestParam(required = false) int itemId)
+											  @RequestParam(required = false) int catalogId, @RequestParam(required = false) int itemId)
 			throws ProfitMandiBusinessException {
 		if (catalogId == 0) {
 			catalogId = itemRepository.selectById(itemId).getCatalogItemId();
+		}
 		List<Item> items = itemRepository.selectAllByCatalogItemId(catalogId);
+	}
 	@RequestMapping(value = "/indent/loadIndent")
 	public String loadOpenIndent(HttpServletRequest request, Model model,
-			@RequestParam(required = false, defaultValue = "0") int fofoId,
+								 @RequestParam(required = false, defaultValue = "0") int fofoId,
-			@RequestParam(defaultValue = "TEN_LAC") CounterSize counterSize) throws Exception {
+								 @RequestParam(defaultValue = "TEN_LAC") CounterSize counterSize) throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		Set<Integer> roleIds = loginDetails.getRoleIds();
 		LOGGER.info("Counter size is {}", counterSize);
 		LOGGER.info("Fofo Id is {}", fofoId);
 		if (LocalDate.now().isAfter(LocalDate.now().withDayOfMonth(PLANNING_OPEN_DAY))) {
 			planningMonthDate = LocalDate.now().plusMonths(1).withDayOfMonth(1);
 			monthlyPlanned = monthlyPlannedRepository.selectByFofoIdYearMonth(fofoId, planningMonthDate);
 			LOGGER.info("monthlyPlanned2" + monthlyPlanned);
 			fofoOrderIds = fofoOrderRepository.selectByFofoIdBetweenCreatedTimeStamp(loginDetails.getFofoId(),
-					LocalDateTime.now().minusDays(15), LocalDateTime.now()).stream().map(x -> x.getId())
+							LocalDateTime.now().minusDays(15), LocalDateTime.now()).stream().map(x -> x.getId())
 					.collect(Collectors.toList());
 			model.addAttribute("planningMonth", LocalDate.now().plusMonths(1).getMonth());
 		} else {
 			planningMonthDate = LocalDate.now().withDayOfMonth(1);
 			monthlyPlanned = monthlyPlannedRepository.selectByFofoIdYearMonth(fofoId, planningMonthDate);
 			model.addAttribute("planningMonth", planningMonthDate.getMonth());
 			model.addAttribute("mtd", true);
 			model.addAttribute("freezed", true);
 			fofoOrderIds = fofoOrderRepository.selectByFofoIdBetweenCreatedTimeStamp(loginDetails.getFofoId(),
-					curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX)).stream().map(x -> x.getId())
+							curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX)).stream().map(x -> x.getId())
 					.collect(Collectors.toList());
 			LOGGER.info("monthlyPlanned1" + monthlyPlanned);
+		}
 		Map<Integer, Integer> plannedDetailMap = null;
 		model.addAttribute("totalPcs", totalPcs);
 		return "open-indent";
+	}
+	private List<Order> filterValidOrders(List<Order> lastOrdersList) {
+		int orderRemovedCount = 0;
+		Iterator<Order> orderIterator = lastOrdersList.iterator();
+		while (orderIterator.hasNext()) {
+			Order o = orderIterator.next();
+			if (o.getInvoiceNumber() != null) {
+				try {
+					purchaseRepository.selectByPurchaseReferenceAndFofoId(o.getInvoiceNumber(), o.getRetailerId());
+					orderIterator.remove();
+					orderRemovedCount++;
+				} catch (Exception e) {
+				}
+			}
+		}
+		LOGGER.info("Order removed count is {}", orderRemovedCount);
+		return lastOrdersList;
+	}
+	@RequestMapping(value = "/indent/confirm-pause", method = RequestMethod.POST)
+	public String raisePO(HttpServletRequest request, Model model, @RequestBody String jsonArrayString)
+			throws Exception {
+		JSONArray jsonArray = new JSONArray(jsonArrayString);
+		for (int i = 0; i < jsonArray.length(); i++) {
+			JSONObject obj = jsonArray.getJSONObject(i);
+			TagListing tl = tagListingRepository.selectByItemId(obj.getInt("id"));
+			if (tl == null) {
+				continue;
+			} else {
+				tl.setActive(obj.getBoolean("active"));
+				tagListingRepository.persist(tl);
+			}
+		}
+		model.addAttribute("response", true);
+		return "response";
+	}
+	@RequestMapping(value = "/indent/confirm-hotdeals-pause", method = RequestMethod.POST)
+	public String hotdealUpdate(HttpServletRequest request, Model model, @RequestBody String jsonArrayString)
+			throws Exception {
+		JSONArray jsonArray = new JSONArray(jsonArrayString);
+		for (int i = 0; i < jsonArray.length(); i++) {
+			JSONObject obj = jsonArray.getJSONObject(i);
+			TagListing tl = tagListingRepository.selectByItemId(obj.getInt("id"));
+			if (tl == null) {
+				continue;
+			} else {
+				tl.setHotDeals(obj.getBoolean("hotDeals"));
+				tagListingRepository.persist(tl);
+			}
+		}
+		model.addAttribute("response", true);
+		return "response";
+	}
+	@RequestMapping(value = "/indent/create-po", method = RequestMethod.POST)
+	public String raisePO(HttpServletRequest request, Model model) throws Exception {
+		boolean success = false;
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		int fofoId = loginDetails.getFofoId();
+		List<ItemPriceQuantity> itemQuantities = this.getItemQuantities(fofoId);
+		CustomRetailer customRetailer = retailerService.getFofoRetailers(Arrays.asList(fofoId)).get(fofoId);
+		Client userClient = new UserClient().getClient();
+		double totalAmount = itemQuantities.stream().mapToDouble(x -> x.getQty() * x.getPrice()).sum();
+		if (totalAmount > 0) {
+			userClient.addItemPricingToCart(customRetailer.getCartId(), itemQuantities);
+			User user = userRepository.selectById(loginDetails.getFofoId());
+			userClient = new UserClient().getClient();
+			LOGGER.info("Setting wallet amount in cart");
+			long transactionId = userClient.createOrders(user.getActiveCartId(), "", 0, "", 0, loginDetails.getFofoId(),
+, OrderSource.WEBSITE.getValue(), true);
+			LOGGER.info("Creating wallet payment for transactionId - {}", transactionId);
+			createPayment(user, totalAmount, transactionId);
+			TransactionService.Client transactionClient = new TransactionClient().getClient();
+			transactionClient.changeTransactionStatus(transactionId, TransactionStatus.AUTHORIZED,
+					"Payment received for the order", PickUpType.RUNNER.getValue(), OrderType.B2B, OrderSource.WEBSITE);
+			transactionClient.changeTransactionStatus(Long.valueOf(transactionId), TransactionStatus.IN_PROCESS,
+					"Paid fully through wallet", PickUpType.RUNNER.getValue(), OrderType.B2B, OrderSource.WEBSITE);
+			LOGGER.info("Successfully created transaction: " + transactionId + " for amount: " + totalAmount);
+			transactionClient = new TransactionClient().getClient();
+			transactionClient.markOrderForRegisteredGstInvoice(Collections.singletonList(Long.valueOf(transactionId)));
+			try {
+				transactionClient.enqueueTransactionInfoEmail(transactionId);
+			} catch (Exception e1) {
+				e1.printStackTrace();
+				LOGGER.error("Unable to update status of transaction. Thrift Exception:", e1);
+			}
+			resetCart(transactionClient.getTransaction(transactionId));
+		}
+		model.addAttribute("response", mvcResponseSender.createResponseString(success));
+		return "response";
+	}
+	private void createPayment(User user, double totalAmount, long transactionId)
+			throws NumberFormatException, PaymentException, TException {
+		List<Attribute> paymentAttributes = new ArrayList<Attribute>();
+		in.shop2020.payments.PaymentService.Client paymentClient = new PaymentClient().getClient();
+		paymentAttributes.add(new Attribute("payMethod", "7890"));
+		long paymentId = paymentClient.createPayment(user.getId(), totalAmount, WALLET_GATEWAY_ID, transactionId,
+				false);
+		paymentClient.updatePaymentDetails(paymentId, null, null, null, null, null, null, null, null,
+				PaymentStatus.SUCCESS, null, paymentAttributes);
+	}
 	@RequestMapping(value = "/indent/loadIndentPreviousMonth")
 	public String previousMonthLoadOpenIndent(HttpServletRequest request, Model model,
-			@RequestParam(required = false, defaultValue = "0") int fofoId,
+											  @RequestParam(required = false, defaultValue = "0") int fofoId,
-			@RequestParam(defaultValue = "TEN_LAC") CounterSize counterSize) throws Exception {
+											  @RequestParam(defaultValue = "TEN_LAC") CounterSize counterSize) throws Exception {
 		LocalDate planMonthStart = null;
 		if (LocalDate.now().isAfter(LocalDate.now().withDayOfMonth(PLANNING_OPEN_DAY))) {
 			planMonthStart = LocalDate.now().plusMonths(1).withDayOfMonth(1);
 		} else {
 			planMonthStart = LocalDate.now().withDayOfMonth(1);
 		model.addAttribute("totalPcs", totalPcs);
 		return "open-indent";
+	}
-	private List<Order> filterValidOrders(List<Order> lastOrdersList) {
+	private long resetCart(Transaction transaction) {
-		int orderRemovedCount = 0;
+		long sum = 0;
-		Iterator<Order> orderIterator = lastOrdersList.iterator();
+		Map<Long, Double> items = new HashMap<Long, Double>();
-		while (orderIterator.hasNext()) {
+		for (in.shop2020.model.v1.order.Order order : transaction.getOrders()) {
-			Order o = orderIterator.next();
+			sum += order.getGvAmount();
-			if (o.getInvoiceNumber() != null) {
+			for (LineItem lineitem : order.getLineitems()) {
-				try {
+				Long itemId = lineitem.getItem_id();
-					purchaseRepository.selectByPurchaseReferenceAndFofoId(o.getInvoiceNumber(), o.getRetailerId());
+				Double quantity = items.get(itemId);
-					orderIterator.remove();
+				if (quantity == null) {
-					orderRemovedCount++;
+					quantity = lineitem.getQuantity();
-				} catch (Exception e) {
+				} else {
+					quantity = quantity + lineitem.getQuantity();
+				}
+				items.put(itemId, quantity);
+			}
+		}
-		LOGGER.info("Order removed count is {}", orderRemovedCount);
-		return lastOrdersList;
-	}
-	@RequestMapping(value = "/indent/confirm-pause", method = RequestMethod.POST)
-	public String raisePO(HttpServletRequest request, Model model, @RequestBody String jsonArrayString)
-			throws Exception {
-		JSONArray jsonArray = new JSONArray(jsonArrayString);
-		for (int i = 0; i < jsonArray.length(); i++) {
-			JSONObject obj = jsonArray.getJSONObject(i);
-			TagListing tl = tagListingRepository.selectByItemId(obj.getInt("id"));
-			if (tl == null) {
-				continue;
-			} else {
-				tl.setActive(obj.getBoolean("active"));
-				tagListingRepository.persist(tl);
-			}
-		}
-		model.addAttribute("response", true);
-		return "response";
-	}
-	@RequestMapping(value = "/indent/confirm-hotdeals-pause", method = RequestMethod.POST)
-	public String hotdealUpdate(HttpServletRequest request, Model model, @RequestBody String jsonArrayString)
-			throws Exception {
-		JSONArray jsonArray = new JSONArray(jsonArrayString);
-		for (int i = 0; i < jsonArray.length(); i++) {
-			JSONObject obj = jsonArray.getJSONObject(i);
-			TagListing tl = tagListingRepository.selectByItemId(obj.getInt("id"));
-			if (tl == null) {
-				continue;
-			} else {
-				tl.setHotDeals(obj.getBoolean("hotDeals"));
-				tagListingRepository.persist(tl);
-			}
-		}
-		model.addAttribute("response", true);
-		return "response";
-	}
-	@RequestMapping(value = "/indent/create-po", method = RequestMethod.POST)
-	public String raisePO(HttpServletRequest request, Model model) throws Exception {
-		boolean success = false;
-		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
-		int fofoId = loginDetails.getFofoId();
-		List<ItemPriceQuantity> itemQuantities = this.getItemQuantities(fofoId);
-		CustomRetailer customRetailer = retailerService.getFofoRetailers(Arrays.asList(fofoId)).get(fofoId);
-		Client userClient = new UserClient().getClient();
+		LOGGER.debug("Items to reset in cart are: " + items);
-		double totalAmount = itemQuantities.stream().mapToDouble(x -> x.getQty() * x.getPrice()).sum();
-		if (totalAmount > 0) {
+		try {
-			userClient.addItemPricingToCart(customRetailer.getCartId(), itemQuantities);
-			User user = userRepository.selectById(loginDetails.getFofoId());
-			userClient = new UserClient().getClient();
+			Client userClient = new UserClient().getClient();
-			LOGGER.info("Setting wallet amount in cart");
+			userClient.resetCart(transaction.getShoppingCartid(), items);
-			long transactionId = userClient.createOrders(user.getActiveCartId(), "", 0, "", 0, loginDetails.getFofoId(),
-, OrderSource.WEBSITE.getValue(), true);
+		} catch (TException e) {
-			LOGGER.info("Creating wallet payment for transactionId - {}", transactionId);
+			LOGGER.error("Error while updating information in payment database.", e);
-			createPayment(user, totalAmount, transactionId);
+		} catch (ShoppingCartException e) {
-			TransactionService.Client transactionClient = new TransactionClient().getClient();
-			transactionClient.changeTransactionStatus(transactionId, TransactionStatus.AUTHORIZED,
-					"Payment received for the order", PickUpType.RUNNER.getValue(), OrderType.B2B, OrderSource.WEBSITE);
-			transactionClient.changeTransactionStatus(Long.valueOf(transactionId), TransactionStatus.IN_PROCESS,
-					"Paid fully through wallet", PickUpType.RUNNER.getValue(), OrderType.B2B, OrderSource.WEBSITE);
-			LOGGER.info("Successfully created transaction: " + transactionId + " for amount: " + totalAmount);
+			LOGGER.error("Error while reseting the cart in cart database.", e);
-			transactionClient = new TransactionClient().getClient();
-			transactionClient.markOrderForRegisteredGstInvoice(Collections.singletonList(Long.valueOf(transactionId)));
-			try {
-				transactionClient.enqueueTransactionInfoEmail(transactionId);
-			} catch (Exception e1) {
+		} catch (Exception e) {
-				e1.printStackTrace();
-				LOGGER.error("Unable to update status of transaction. Thrift Exception:", e1);
+			LOGGER.error("Unexpected exception", e);
-			}
-			resetCart(transactionClient.getTransaction(transactionId));
+		}
-		model.addAttribute("response", mvcResponseSender.createResponseString(success));
-		return "response";
+		return sum;
-	}
-	private void createPayment(User user, double totalAmount, long transactionId)
-			throws NumberFormatException, PaymentException, TException {
-		List<Attribute> paymentAttributes = new ArrayList<Attribute>();
-		in.shop2020.payments.PaymentService.Client paymentClient = new PaymentClient().getClient();
-		paymentAttributes.add(new Attribute("payMethod", "7890"));
-		long paymentId = paymentClient.createPayment(user.getId(), totalAmount, WALLET_GATEWAY_ID, transactionId,
-				false);
-		paymentClient.updatePaymentDetails(paymentId, null, null, null, null, null, null, null, null,
-				PaymentStatus.SUCCESS, null, paymentAttributes);
+	}
 	private List<ItemPriceQuantity> getItemQuantities(int fofoId) throws ProfitMandiBusinessException {
 		List<ItemPriceQuantity> itemQuantities = new ArrayList<>();
 		/*
 		 * .selectItemsStock(fofoId); itemCisMap =
 		 * currentInventorySnapshots.stream().filter(x -> x.getAvailability() > 0)
 		 * .collect(Collectors.toMap(x -> x.getItemId(), x -> x));
 		 * List<StockAllocationModel> stockAllocationList =
 		 * stockAllocationService.getStockAllocation(fofoId, true);
 		 *
 		 * Map<Integer, StockAllocationModel> itemStockAllocationMap =
 		 * stockAllocationList.stream() .collect(Collectors.toMap(x -> x.catalogId(), x
 		 * -> x)); Map<Integer, Integer> itemsInTransit = null;
 		 * LOGGER.info("Item Stock Allocation Model Map {}", itemStockAllocationMap);
 		 * List<TagListing> tagListings = tagListingRepository.selectAll(false);
 		 * validOrderStatusList); inTransitOrders =
 		 * this.filterValidOrders(inTransitOrders); itemsInTransit =
 		 * inTransitOrders.stream().collect(Collectors.groupingBy(x ->
 		 * x.getLineItem().getItemId(), Collectors.summingInt(x ->
 		 * x.getLineItem().getQuantity())));
 		 *
 		 * Iterator<TagListing> iterator = tagListings.iterator();
 		 *
 		 * int toBeOrdered = 0; while (iterator.hasNext()) { TagListing tagListing =
 		 * iterator.next(); LOGGER.info(" tagListing.setAllocatedQuantity {}",
 		 * tagListing.getAllocatedQuantity()); if
 		 * (!itemCisMap.containsKey(tagListing.getItemId()) &&
 		 * !itemStockAllocationMap.containsKey(tagListing.getItemId())) {
 		 * iterator.remove(); continue; } ItemIdAvailability itemIdAvailability =
 		 * itemCisMap.get(tagListing.getItemId());
 		 * tagListing.setStockInHand(itemIdAvailability == null ? 0 :
 		 * itemIdAvailability.getAvailability()); StockAllocationModel
 		 * stockAllocationModel = itemStockAllocationMap.get(tagListing.getItemId());
 		 *
 		 * if (itemsInTransit.containsKey(tagListing.getItemId())) {
 		 * tagListing.setInTransitQuantity(itemsInTransit.get(tagListing.getItemId()));
 		 * } else { tagListing.setInTransitQuantity(0); } if (stockAllocationModel !=
 		 * null) { tagListing.setAllocatedQuantity(stockAllocationModel.getQuantity());
 		 * toBeOrdered = Math.max(tagListing.getAllocatedQuantity() -
 		 */
 		return itemQuantities;
+	}
-	private long resetCart(Transaction transaction) {
-		long sum = 0;
-		Map<Long, Double> items = new HashMap<Long, Double>();
-		for (in.shop2020.model.v1.order.Order order : transaction.getOrders()) {
-			sum += order.getGvAmount();
-			for (LineItem lineitem : order.getLineitems()) {
-				Long itemId = lineitem.getItem_id();
-				Double quantity = items.get(itemId);
-				if (quantity == null) {
-					quantity = lineitem.getQuantity();
-				} else {
-					quantity = quantity + lineitem.getQuantity();
-				}
-				items.put(itemId, quantity);
-			}
-		}
-		LOGGER.debug("Items to reset in cart are: " + items);
-		try {
-			Client userClient = new UserClient().getClient();
-			userClient.resetCart(transaction.getShoppingCartid(), items);
-		} catch (TException e) {
-			LOGGER.error("Error while updating information in payment database.", e);
-		} catch (ShoppingCartException e) {
-			LOGGER.error("Error while reseting the cart in cart database.", e);
-		} catch (Exception e) {
-			LOGGER.error("Unexpected exception", e);
-		}
-		return sum;
-	}
 	@RequestMapping(value = "/getFocusedModel", method = RequestMethod.GET)
 	public String getFocusedModel(HttpServletRequest request,
-			@RequestParam(name = "offset", defaultValue = "0") int offset,
+								  @RequestParam(name = "offset", defaultValue = "0") int offset,
-			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+								  @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
 			throws ProfitMandiBusinessException {
 		long size = 0;
 		List<FocusedModel> focusedModels = focusedModelRepository.selectAll(offset, limit);
 		model.addAttribute("regions", regions);
 		return "focused_model";
+	}
+	private Map<Integer, Item> getItemByCatalogId(List<FocusedModel> focusedModels) {
+		Map<Integer, Item> itemMap = new HashMap<>();
+		for (FocusedModel focusedModel : focusedModels) {
+			List<Item> items = itemRepository.selectAllByCatalogItemId(focusedModel.getCatalogId());
+			itemMap.put(items.get(0).getCatalogItemId(), items.get(0));
+		}
+		return itemMap;
+	}
+	private Map<Integer, Region> getRegionByRegionId(List<FocusedModel> focusedModels) {
+		Map<Integer, Region> regionMap = new HashMap<>();
+		for (FocusedModel focusedModel : focusedModels) {
+			Region region = regionRepository.selectById(focusedModel.getRegionId());
+			regionMap.put(region.getId(), region);
+		}
+		return regionMap;
+	}
 	@RequestMapping(value = "/getPaginatedFocusedModel", method = RequestMethod.GET)
 	public String getPaginatedFocusedModel(HttpServletRequest request,
-			@RequestParam(name = "offset", defaultValue = "0") int offset,
+										   @RequestParam(name = "offset", defaultValue = "0") int offset,
-			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
+										   @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
 			throws ProfitMandiBusinessException {
 		LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
 		List<FocusedModel> focusedModels = focusedModelRepository.selectAll(offset, limit);
 		if (!focusedModels.isEmpty()) {
 		model.addAttribute("regions", regions);
 		return "focused-model-paginated";
+	}
-	private Map<Integer, Item> getItemByCatalogId(List<FocusedModel> focusedModels) {
-		Map<Integer, Item> itemMap = new HashMap<>();
-		for (FocusedModel focusedModel : focusedModels) {
-			List<Item> items = itemRepository.selectAllByCatalogItemId(focusedModel.getCatalogId());
-			itemMap.put(items.get(0).getCatalogItemId(), items.get(0));
-		}
-		return itemMap;
-	}
-	private Map<Integer, Region> getRegionByRegionId(List<FocusedModel> focusedModels) {
-		Map<Integer, Region> regionMap = new HashMap<>();
-		for (FocusedModel focusedModel : focusedModels) {
-			Region region = regionRepository.selectById(focusedModel.getRegionId());
-			regionMap.put(region.getId(), region);
-		}
-		return regionMap;
-	}
 	@RequestMapping(value = "/focusedModel", method = RequestMethod.POST)
 	public String focusedModel(HttpServletRequest request, @RequestParam int catalogId,
-			@RequestParam(name = "recommended", defaultValue = "0") int recommended,
+							   @RequestParam(name = "recommended", defaultValue = "0") int recommended,
-			@RequestParam(name = "minimumQty", defaultValue = "0") int minimumQty,
+							   @RequestParam(name = "minimumQty", defaultValue = "0") int minimumQty,
-			@RequestParam(name = "obvrecommend", defaultValue = "0") int obvrecommend,
+							   @RequestParam(name = "obvrecommend", defaultValue = "0") int obvrecommend,
-			@RequestParam(name = "obvminimum", defaultValue = "0") int obvminimum, @RequestParam int regionId,
+							   @RequestParam(name = "obvminimum", defaultValue = "0") int obvminimum, @RequestParam int regionId,
-			Model model) throws ProfitMandiBusinessException {
+							   Model model) throws ProfitMandiBusinessException {
 		FocusedModel fm = new FocusedModel();
 		fm.setCatalogId(catalogId);
 		fm.setMinimumQty(minimumQty);
 		fm.setRecommendedQty(recommended);
 		fm.setCreatedTimestamp(LocalDateTime.now());
 		focusedModelRepository.persist(fm);
 		return "focused_model";
+	}
-	@RequestMapping(value = "/removeItem", method = RequestMethod.DELETE)
-	public String removeFocusedModelItem(HttpServletRequest request,
-			@RequestParam(name = "id", defaultValue = "0") int id, Model model) throws Exception {
-		focusedModelRepository.deleteById(id);
-		model.addAttribute("response", mvcResponseSender.createResponseString(true));
-		return "response";
-	}
 	private List<BrandStockPrice> getBrandStockPrices(int fofoId) throws Exception {
 		Map<String, BrandStockPrice> brandStockPricesMap = inventoryService.getBrandWiseStockValue(fofoId);
 		List<DBObject> mobileBrands = mongoClient.getMongoBrands(fofoId, "", 3);
 		List<BrandStockPrice> brandStockPrices = new ArrayList<>();
 		return "partner-po";
+	}
+	@RequestMapping(value = "/removeItem", method = RequestMethod.DELETE)
+	public String removeFocusedModelItem(HttpServletRequest request,
+										 @RequestParam(name = "id", defaultValue = "0") int id, Model model) throws Exception {
+		focusedModelRepository.deleteById(id);
+		model.addAttribute("response", mvcResponseSender.createResponseString(true));
+		return "response";
+	}
 	@RequestMapping(value = "/getPartnerloadContent")
 	public String getPartnerloadContent(HttpServletRequest request, Model model,
-			@RequestParam(required = false, defaultValue = "0") int fofoId,
+										@RequestParam(required = false, defaultValue = "0") int fofoId,
-			@RequestParam(defaultValue = "TEN_LAC") CounterSize counterSize) throws Exception {
+										@RequestParam(defaultValue = "TEN_LAC") CounterSize counterSize) throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		Set<Integer> roleIds = loginDetails.getRoleIds();
 		LOGGER.info("Counter size is {}", counterSize);
 		LOGGER.info("Fofo Id is {}", fofoId);
 		if (LocalDate.now().isAfter(LocalDate.now().withDayOfMonth(PLANNING_OPEN_DAY))) {
 			currentMonthDate = LocalDate.now().plusMonths(1).withDayOfMonth(1);
 			monthlyPlanned = monthlyPlannedRepository.selectByFofoIdYearMonth(fofoId, currentMonthDate);
 			LOGGER.info("monthlyPlanned2" + monthlyPlanned);
 			fofoOrderIds = fofoOrderRepository.selectByFofoIdBetweenCreatedTimeStamp(loginDetails.getFofoId(),
-					LocalDateTime.now().minusDays(15), LocalDateTime.now()).stream().map(x -> x.getId())
+							LocalDateTime.now().minusDays(15), LocalDateTime.now()).stream().map(x -> x.getId())
 					.collect(Collectors.toList());
 			model.addAttribute("planningMonth", LocalDate.now().plusMonths(1).getMonth());
 		} else {
 			currentMonthDate = LocalDate.now().withDayOfMonth(1);
 			monthlyPlanned = monthlyPlannedRepository.selectByFofoIdYearMonth(fofoId, currentMonthDate);
 			model.addAttribute("planningMonth", currentMonthDate.getMonth());
 			model.addAttribute("mtd", true);
 			model.addAttribute("freezed", true);
 			fofoOrderIds = fofoOrderRepository.selectByFofoIdBetweenCreatedTimeStamp(loginDetails.getFofoId(),
-					curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX)).stream().map(x -> x.getId())
+							curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX)).stream().map(x -> x.getId())
 					.collect(Collectors.toList());
 			LOGGER.info("monthlyPlanned1" + monthlyPlanned);
+		}
 		Map<Integer, Integer> plannedDetailMap = null;
 		return "create-partner-po";
+	}
-	@RequestMapping(value = "/createPo", method = RequestMethod.POST)
-	public String createPo(HttpServletRequest request, @RequestBody SuggestedPoModel monthlyPoModel, Model model)
-			throws Exception {
-		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
-		SuggestedPo mp = new SuggestedPo();
-		mp.setFofoId(monthlyPoModel.getFofoId());
-		mp.setCreateTimestamp(LocalDateTime.now());
-		mp.setStatus("open");
-		mp.setAuthId(loginDetails.getEmailId());
-		monthlyPoRepository.persist(mp);
-		for (SuggestedPoIdModel poId : monthlyPoModel.getPoIds()) {
-			SuggestedPoDetail mpd = new SuggestedPoDetail();
-			mpd.setItemId(poId.getItemId());
-			mpd.setQuantity(poId.getQty());
-			mpd.setUpdatedTimestamp(LocalDateTime.now());
-			mpd.setPoId(mp.getId());
-			monthlyPoDetailRepository.persist(mpd);
-		}
-		SendNotificationModel sendNotificationModel = new SendNotificationModel();
-		sendNotificationModel.setCampaignName("Alert");
-		sendNotificationModel.setMessage("Suggested Po");
-		sendNotificationModel.setType("url");
-		sendNotificationModel.setTitle("Alert");
-		sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/partnerPo/" + mp.getId());
-		sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(2));
-		sendNotificationModel.setMessageType(MessageType.notification);
-		int userId = userAccountRepository.selectUserIdByRetailerId(monthlyPoModel.getFofoId());
-		sendNotificationModel.setUserIds(Arrays.asList(userId));
-		notificationService.sendNotification(sendNotificationModel);
-		model.addAttribute("response", mvcResponseSender.createResponseString(true));
-		return "response";
-	}
 	@RequestMapping(value = "/selectItemColor", method = RequestMethod.GET)
 	public String selectItemColor(HttpServletRequest request, @RequestParam int catalogId, Model model)
 			throws Exception {
 		List<Item> selecteditems = itemRepository.selectAllByCatalogItemId(catalogId);
 		model.addAttribute("grnPendingAccessTvOrders", grnPendingAccessTvOrders);
 		model.addAttribute("fofoIdPartnerTypeMap", fofoIdPartnerTypeMap);
 		return "partner-brandwise-detail";
+	}
+	@RequestMapping(value = "/createPo", method = RequestMethod.POST)
+	public String createPo(HttpServletRequest request, @RequestBody SuggestedPoModel monthlyPoModel, Model model)
+			throws Exception {
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		SuggestedPo mp = new SuggestedPo();
+		mp.setFofoId(monthlyPoModel.getFofoId());
+		mp.setCreateTimestamp(LocalDateTime.now());
+		mp.setStatus("open");
+		mp.setAuthId(loginDetails.getEmailId());
+		suggestedPoRepository.persist(mp);
+		for (SuggestedPoIdModel poId : monthlyPoModel.getPoIds()) {
+			SuggestedPoDetail mpd = new SuggestedPoDetail();
+			mpd.setItemId(poId.getItemId());
+			mpd.setQuantity(poId.getQty());
+			mpd.setUpdatedTimestamp(LocalDateTime.now());
+			mpd.setPoId(mp.getId());
+			suggestedPoDetailRepository.persist(mpd);
+		}
+		SendNotificationModel sendNotificationModel = new SendNotificationModel();
+		sendNotificationModel.setCampaignName("Alert");
+		sendNotificationModel.setMessage("Suggested Po");
+		sendNotificationModel.setType("url");
+		sendNotificationModel.setTitle("Alert");
+		sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/partnerPo/" + mp.getId());
+		sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(2));
+		sendNotificationModel.setMessageType(MessageType.notification);
+		int userId = userAccountRepository.selectUserIdByRetailerId(monthlyPoModel.getFofoId());
+		sendNotificationModel.setUserIds(Arrays.asList(userId));
+		notificationService.sendNotification(sendNotificationModel);
+		model.addAttribute("response", mvcResponseSender.createResponseString(true));
+		return "response";
+	}
 	@RequestMapping(value = "/getPartnerShortageStock", method = RequestMethod.GET)
 	public String getPartnerShortageStock(HttpServletRequest request,
-			@RequestParam(required = false, defaultValue = "") String brand, @RequestParam int fofoId, Model model)
+										  @RequestParam(required = false, defaultValue = "") String brand, @RequestParam int fofoId, Model model)
 			throws Exception {
 		Map<Integer, Map<Integer, List<SaholicCIS>>> warehouseItemAvailabilityMap = saholicInventoryService
 				.getSaholicStock();
 		return "partner-stock";
+	}
 	private FocusedModelShortageModel getFocusedModelShortage(int qty, int catalogId,
-			Map<Integer, Integer> processingOrderMap, Map<Integer, Integer> grnPendingOrdersMap,
+															  Map<Integer, Integer> processingOrderMap, Map<Integer, Integer> grnPendingOrdersMap,
-			Map<Integer, Integer> catalogIdAndQtyMap, int fofoId,
+															  Map<Integer, Integer> catalogIdAndQtyMap, int fofoId,
-			Map<Integer, Map<Integer, List<SaholicCIS>>> warehouseItemAvailabilityMap,
+															  Map<Integer, Map<Integer, List<SaholicCIS>>> warehouseItemAvailabilityMap,
-			Map<Integer, Map<Integer, List<SaholicPOItem>>> warehousePoItemAvailabilityMap, List<Item> items,
+															  Map<Integer, Map<Integer, List<SaholicPOItem>>> warehousePoItemAvailabilityMap, List<Item> items,
-			CustomRetailer customRetailer) throws ProfitMandiBusinessException {
+															  CustomRetailer customRetailer) throws ProfitMandiBusinessException {
 		int minQty = qty;
 		int inStockQty = 0;
 		int processingQty = 0;
 		int grnPendingQty = 0;
 		fm.setAvailabitiy(allColorNetAvailability);
 		return fm;
+	}
+	@RequestMapping(value = "/indent/send-po-notification", method = RequestMethod.GET)
+	public String SendPONotification(HttpServletRequest request, Model model) {
+		model.addAttribute("warehouses", ProfitMandiConstants.WAREHOUSE_MAP);
+		return "send-po-notification";
+	}
+	@RequestMapping(value = "/indent/send-po-notification", method = RequestMethod.POST)
+	public String sendPONotification(HttpServletRequest request, @RequestBody POItemWarehouseModel poItemWarehouseModel, Model model) throws Exception {
+		Map<Integer, Item> selectedItemsMap = itemRepository.selectByIds(poItemWarehouseModel.getItemIdQuantityList().stream().map(x -> x.getItemId()).collect(Collectors.toSet())).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
+		Set<String> brands = selectedItemsMap.values().stream().map(x -> x.getBrand().toLowerCase()).collect(Collectors.toSet());
+		int warehouseId = poItemWarehouseModel.getWarehouseId();
+		SendNotificationModel sendNotificationModel = new SendNotificationModel();
+		sendNotificationModel.setCampaignName("SendPo");
+		sendNotificationModel.setTitle(String.format(PO_TITLE_STRING));
+		StringBuilder stringBuilder = new StringBuilder();
+		poItemWarehouseModel.getItemIdQuantityList().stream().forEach(itemIdQuantity -> {
+			stringBuilder.append(selectedItemsMap.get(itemIdQuantity.getItemId()).getItemDescription()).append("-").append(itemIdQuantity.getQuantity()).append("pcs").append("\n");
+		});
+		sendNotificationModel.setMessage(stringBuilder.toString());
+		sendNotificationModel.setType("url");
+		sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");
+		sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
+		sendNotificationModel.setMessageType(MessageType.notification);
+		List<BrandRegionMapping> brandRegionMappings = brandRegionMappingRepository.selectAll().stream().filter(x -> brands.contains(x.getBrand().toLowerCase()) && x.getFromWarehouseId() == warehouseId && x.isAccessory() == false).collect(Collectors.toList());
+		List<Integer> toWarehouseIds = brandRegionMappings.stream().map(x -> x.getToWarehouseId()).collect(Collectors.toList());
+		List<Integer> fofoIds = fofoStoreRepository.selectByWarehouseIds(toWarehouseIds).stream().filter(x -> !x.isInternal() && x.isActive()).map(x -> x.getId()).collect(Collectors.toList());
+		List<Integer> userIds = userAccountRepository.selectUserIdsByRetailerIds(fofoIds);
+		sendNotificationModel.setUserIds(userIds);
+		notificationService.sendNotification(sendNotificationModel);
+		model.addAttribute("response", true);
+		return "response";
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/IndentController.java – Rev 30006 → 30017