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

 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.util.ArrayList;
 import java.util.Arrays;
-import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 import javax.servlet.http.HttpServletRequest;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.json.JSONObject;
 import org.springframework.beans.factory.annotation.Autowired;
 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.spice.profitmandi.common.enumuration.IndentStatus;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
-import com.spice.profitmandi.common.model.ItemIdQuantity;
+import com.spice.profitmandi.common.model.StockAllocationModel;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
 import com.spice.profitmandi.dao.entity.fofo.CurrentInventorySnapshot;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
-import com.spice.profitmandi.dao.entity.fofo.Indent;
 import com.spice.profitmandi.dao.entity.fofo.IndentItem;
 import com.spice.profitmandi.dao.repository.catalog.CategoryRepository;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
+import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.IndentItemRepository;
 import com.spice.profitmandi.dao.repository.dtr.IndentRepository;
 import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
 import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
 import com.spice.profitmandi.service.indent.IndentService;
+import com.spice.profitmandi.service.inventory.StockAllocationService;
+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;
 @Controller
 	private static final Logger LOGGER = LogManager.getLogger(IndentController.class);
 	@Autowired
 	private CookiesProcessor cookiesProcessor;
+	@Autowired
+	FofoStoreRepository fofoStoreRepository;
 	@Autowired
 	private CategoryRepository categoryRepository;
 	@Autowired
 	@Autowired
 	private IndentRepository indentRepository;
 	@Autowired
+	private StockAllocationService stockAllocationService;
+	@Autowired
 	private IndentItemRepository indentItemRepository;
+	@Autowired
+	private RetailerService retailerService;
 	@Autowired
 	private IndentService indentService;
 	@Autowired
 	private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;
 	@Autowired
 	private MVCResponseSender mvcResponseSender;
-	@RequestMapping(value = "/indent-item/save", method = RequestMethod.PUT)
+	/*@RequestMapping(value = "/indent-item/save", method = RequestMethod.PUT)
 	public String saveIndentItem(HttpServletRequest request, @RequestBody ItemIdQuantity itemIdQuantity, Model model)
 			throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		LOGGER.info("Item id is {}, And quantity is {}", itemIdQuantity.getItemId(), itemIdQuantity.getItemId());
+		boolean response = false;
-		int fofoId = loginDetails.getFofoId();
+		if(loginDetails.isAdmin()) {
+			StockAllocationModel stockAllocationModel = new StockAllocationModel();
+			stockAllocationModel.setQuantity(itemIdQuantity.getQuantity());
-		boolean response = indentService.updateOpenIndentItem(fofoId, itemIdQuantity.getItemId(),
+			stockAllocationModel.setItemId(itemIdQuantity.getItemId());
+			response = stockAllocationService.addToAllocation(stockAllocationModel);
+		}
-				itemIdQuantity.getQuantity());
+		//int fofoId = loginDetails.getFofoId();
 		model.addAttribute("response", mvcResponseSender.createResponseString(response));
 		return "response";
-	}
+	}*/
-	@RequestMapping(value = "/open-indent/save", method = RequestMethod.PUT)
+	@RequestMapping(value = "/open-indent/save", method = RequestMethod.POST)
-	public String saveOpenIndent(HttpServletRequest request, Model model) throws Exception {
+	public String saveOpenIndent(HttpServletRequest request, Model model, @RequestBody List<StockAllocationModel> stockAllocationModelList) throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
-		int fofoId = loginDetails.getFofoId();
+		boolean response = false;
-		List<Indent> openIndents = indentRepository.selectIndentByStatus(fofoId, IndentStatus.OPEN);
-		if (openIndents.size() > 0) {
+		if(loginDetails.isAdmin()) {
-			Indent openIndent = openIndents.get(0);
-			if (indentItemRepository.selectIndentItems(Arrays.asList(openIndent.getId())).size() == 0) {
-				model.addAttribute("response", mvcResponseSender.createResponseString(false));
+			response = stockAllocationService.addToAllocation(stockAllocationModelList);
-			}
-			openIndent.setCreateTimestamp(LocalDateTime.now());
-			openIndent.setStatus(IndentStatus.ALLOCATED);
-			indentRepository.persist(openIndent);
-			model.addAttribute("response", mvcResponseSender.createResponseString(true));
+			model.addAttribute("response", mvcResponseSender.createResponseString(response));
+		}
 		return "response";
+	}
 	@RequestMapping(value = "/migrate", method = RequestMethod.PUT)
 	public String migrate(HttpServletRequest request, Model model) throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		int fofoId = loginDetails.getFofoId();
 		List<TagListing> tagListings = tagListingRepository.selectAll();
-		for(TagListing tagListing : tagListings) {
+		for (TagListing tagListing : tagListings) {
 			int itemId = tagListing.getItemId();
+		}
 		return "";
+	}
 	@RequestMapping(value = "/indent/inProcess")
-	public String loadInProcessIndents(HttpServletRequest request, Model model) throws ProfitMandiBusinessException{
+	public String loadInProcessIndents(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		int fofoId = loginDetails.getFofoId();
-		List<Integer> pendingIndentIds = indentRepository.selectIndentByStatus(fofoId, IndentStatus.PENDING).stream().map(x->x.getId()).collect(Collectors.toList());
+		List<Integer> pendingIndentIds = indentRepository.selectIndentByStatus(fofoId, IndentStatus.PENDING).stream()
+				.map(x -> x.getId()).collect(Collectors.toList());
-		List<Integer> allocatedIndentIds = indentRepository.selectIndentByStatus(fofoId, IndentStatus.ALLOCATED).stream().map(x->x.getId()).collect(Collectors.toList());
+		List<Integer> allocatedIndentIds = indentRepository.selectIndentByStatus(fofoId, IndentStatus.ALLOCATED)
+				.stream().map(x -> x.getId()).collect(Collectors.toList());
 		pendingIndentIds.addAll(allocatedIndentIds);
-		if(pendingIndentIds.size() > 0) {
+		if (pendingIndentIds.size() > 0) {
-			Map<Integer, IndentItem> pendingIndentItemIdMap = indentItemRepository.selectIndentItems(pendingIndentIds).stream().collect(Collectors.toMap(x->x.getItemId(), x->x));
+			Map<Integer, IndentItem> pendingIndentItemIdMap = indentItemRepository.selectIndentItems(pendingIndentIds)
+					.stream().collect(Collectors.toMap(x -> x.getItemId(), x -> x));
+			List<TagListing> tagListings = tagListingRepository
-			List<TagListing> tagListings = tagListingRepository.selectByItemIdsAndTagIds(pendingIndentItemIdMap.keySet(), new HashSet<>(Arrays.asList(4)));
+					.selectByItemIdsAndTagIds(pendingIndentItemIdMap.keySet(), new HashSet<>(Arrays.asList(4)));
-			List<FofoOrderItem> fofoOrderItems = fofoOrderRepository.selectByFofoItemIds(fofoId, pendingIndentIds, LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT).minusDays(30), LocalDateTime.now());
+			List<FofoOrderItem> fofoOrderItems = fofoOrderRepository.selectByFofoItemIds(fofoId, pendingIndentIds,
+					LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT).minusDays(30), LocalDateTime.now());
 			Map<Integer, Integer> itemQuantity = fofoOrderItems.stream().collect(
 					Collectors.groupingBy(FofoOrderItem::getItemId, Collectors.summingInt(FofoOrderItem::getQuantity)));
 			List<CurrentInventorySnapshot> cis = currentInventorySnapshotRepository.selectByFofoId(fofoId);
-			Map<Integer, CurrentInventorySnapshot> itemIdSnapshotMap = cis.stream().collect(Collectors.toMap(x->x.getItemId(), x->x));
+			Map<Integer, CurrentInventorySnapshot> itemIdSnapshotMap = cis.stream()
+					.collect(Collectors.toMap(x -> x.getItemId(), x -> x));
-			for(TagListing tagListing : tagListings){
+			for (TagListing tagListing : tagListings) {
 				Integer itemId = tagListing.getItemId();
 				tagListing.setItemDescription(itemRepository.selectById(itemId).getItemDescription());
-				if(itemQuantity.containsKey(itemId)) {
+				if (itemQuantity.containsKey(itemId)) {
 					tagListing.setLast30DaysSale(itemQuantity.get(itemId));
+				}
-				if(itemIdSnapshotMap.containsKey(itemId)){
+				if (itemIdSnapshotMap.containsKey(itemId)) {
 					tagListing.setStockInHand(itemIdSnapshotMap.get(itemId).getAvailability());
+				}
+			}
 			model.addAttribute("pendingIndentItemIdMap", pendingIndentItemIdMap);
 			model.addAttribute("tagListings", tagListings);
+		}
 		return "pending-indent";
+	}
 	@RequestMapping(value = "/indent/loadIndent")
-	public String loadOpenIndent(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
+	public String loadOpenIndent(HttpServletRequest request, Model model, @RequestParam(required=false, defaultValue="0") int fofoId ) throws ProfitMandiBusinessException {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
-		int fofoId = loginDetails.getFofoId();
+		if (loginDetails.isAdmin()) {
-		List<Indent> openIndents = indentRepository.selectIndentByStatus(fofoId, IndentStatus.OPEN);
-		Indent openIndent = null;
+			List<StockAllocationModel> stockAllocationList;
-		if (openIndents.size() > 0) {
+			if(fofoId > 0) {
-			openIndent = openIndents.get(0);
+				stockAllocationList = stockAllocationService.getStockAllocation(fofoId, true);
-		} else {
+			} else {
-			LOGGER.info("Indent does not exist");
-		}
-		Map<Integer, IndentItem> itemIndentMap = new HashMap<>();
-		if (openIndent != null) {
-			List<IndentItem> openIndentItems = indentItemRepository
-					.selectIndentItems(Arrays.asList(openIndent.getId()));
+				stockAllocationList = stockAllocationService.getStockAllocation(true);
-			if (openIndentItems.size() > 0) {
-				itemIndentMap = openIndentItems.stream().collect(Collectors.toMap(x -> x.getItemId(), x -> x));
+			}
-		}
-		List<TagListing> tagListings = tagListingRepository.selectAll();
-		List<Integer> itemIds = new ArrayList<>();
-		for (TagListing tagListing : tagListings) {
-			itemIds.add(tagListing.getItemId());
-		}
-		List<FofoOrderItem> fofoOrderItems = fofoOrderRepository.selectByFofoItemIds(fofoId, itemIds,
-				LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT).minusDays(30), LocalDateTime.now());
-		Map<Integer, Integer> itemQuantity = fofoOrderItems.stream().collect(
-				Collectors.groupingBy(FofoOrderItem::getItemId, Collectors.summingInt(FofoOrderItem::getQuantity)));
-		List<CurrentInventorySnapshot> cis = currentInventorySnapshotRepository.selectByFofoId(fofoId);
-		Map<Integer, CurrentInventorySnapshot> itemIdSnapshotMap = cis.stream()
+			Map<Integer, StockAllocationModel> itemStockAllocationMap = stockAllocationList.stream()
-				.collect(Collectors.toMap(x->x.getItemId(), x->x));
+					.collect(Collectors.toMap(x -> x.getItemId(), x -> x));
-		List<Integer> pendingIndentIds = indentRepository.selectIndentByStatus(fofoId, IndentStatus.PENDING).stream()
-				.map(x -> x.getId()).collect(Collectors.toList());
-		List<Integer> allocatedIndentIds = indentRepository.selectIndentByStatus(fofoId, IndentStatus.ALLOCATED)
-				.stream().map(x -> x.getId()).collect(Collectors.toList());
-		pendingIndentIds.addAll(allocatedIndentIds);
-		if (pendingIndentIds.size() > 0) {
-			List<Integer> pendingItemIds = indentItemRepository.selectIndentItems(pendingIndentIds).stream()
-					.map(x -> x.getItemId()).collect(Collectors.toList());
-			tagListings = tagListings.stream().filter(x -> pendingItemIds.indexOf(x.getItemId()) == -1)
+			List<TagListing> tagListings = tagListingRepository.selectAll();
-					.collect(Collectors.toList());
-		}
-		for (TagListing tagListing : tagListings) {
+			for (TagListing tagListing : tagListings) {
-			Integer itemId = tagListing.getItemId();
-			tagListing.setItemDescription(itemRepository.selectById(itemId).getItemDescription());
+				StockAllocationModel stockAllocationModel = itemStockAllocationMap.get(tagListing.getItemId());
-			if (itemQuantity.containsKey(itemId)) {
+				if(stockAllocationModel!= null ) {
-				tagListing.setLast30DaysSale(itemQuantity.get(itemId));
+					tagListing.setAllocatedQuantity(stockAllocationModel.getQuantity());
-			}
+				}
-			if (itemIdSnapshotMap.containsKey(itemId)) {
-				tagListing.setStockInHand(itemIdSnapshotMap.get(itemId).getAvailability());
+				tagListing.setItemDescription(itemRepository.selectById(tagListing.getItemId()).getItemDescription());
+			}
-		}
+			List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().map(x->x.getId()).collect(Collectors.toList());
-		model.addAttribute("tagListings", tagListings);
+			model.addAttribute("tagListings", tagListings);
+			String customRetailers = JSONObject.valueToString(retailerService.getFofoRetailers(fofoIds).values());
+			LOGGER.info("Custom retailesr {}", customRetailers);
-		model.addAttribute("itemIndentMap", itemIndentMap);
+			model.addAttribute("customRetailers", customRetailers);
-		return "open-indent";
+			return "open-indent";
+		} else {
+			throw new ProfitMandiBusinessException("Unauthorised", loginDetails.getEmailId(),
+					"Can't access the resource");
+		}
+	}
+}

Subversion Repositories SmartDukaan

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