Subversion Repositories SmartDukaan

import com.mysql.fabric.xmlrpc.base.Array;

import com.spice.profitmandi.common.enumuration.MessageType;

import com.spice.profitmandi.common.model.SuggestedPoIdModel;

import com.spice.profitmandi.common.model.SuggestedPoModel;

import com.spice.profitmandi.common.model.NotifyOrderModel;

import com.spice.profitmandi.common.model.SendNotificationModel;

import com.spice.profitmandi.dao.entity.fofo.SuggestedPo;

import com.spice.profitmandi.dao.entity.fofo.SuggestedPoDetail;

import com.spice.profitmandi.dao.entity.transaction.UserWallet;

import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;

import com.spice.profitmandi.dao.repository.fofo.SuggestedPoDetailRepository;

import com.spice.profitmandi.dao.repository.fofo.SuggestedPoRepository;

import com.spice.profitmandi.service.NotificationService;

	private UserAccountRepository userAccountRepository;

	@Autowired

	@Autowired

	private SuggestedPoRepository monthlyPoRepository;

	@Autowired

	private SuggestedPoDetailRepository monthlyPoDetailRepository;

	@Autowired

	private NotificationService notificationService;

	@RequestMapping(value = "/partnerPendingOrder")

	public String partnerPendingOrder(HttpServletRequest request, Model model) throws Exception {

		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

		AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());

		Map<Integer, List<Integer>> pp = csService.getAuthUserIdPartnerIdMapping();

		List<Integer> fofoIds = pp.get(authUser.getId());

		Map<Integer, CustomRetailer> customRetailersMap = retailerService.getFofoRetailers(fofoIds);

		model.addAttribute("customRetailersMap", customRetailersMap);

		return "partner-po";

	}

	@RequestMapping(value = "/getPartnerloadContent")

	public String getPartnerloadContent(HttpServletRequest request, Model model,

			@RequestParam(required = false, defaultValue = "0") int fofoId,

			@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);

		boolean isAdmin = roleManager.isAdmin(roleIds);

		List<String> brands = mongoClient.getMongoBrands(fofoId, null, 3).stream().map(x -> (String) x.get("name"))

				.collect(Collectors.toList());

		Map<String, Object> equalsMap = new HashMap<>();

		equalsMap.put("categoryId", 10006);

		equalsMap.put("brand", brands);

		Map<String, List<?>> notEqualsMap = new HashMap<>();

		Map<String, List<?>> notEqualsJoinMap = new HashMap<>();

		Map<Integer, Integer> currentStockMap;

		if (!isAdmin && fofoId == 0) {

			fofoId = cookiesProcessor.getCookiesObject(request).getFofoId();

			Map<String, Object> equalsStockJoinMap = new HashMap<>();

			equalsStockJoinMap.put("fofoId", fofoId);

			currentStockMap = itemRepository

					.selectItems(CurrentInventorySnapshot.class, "id", "itemId", equalsMap, notEqualsMap,

							equalsStockJoinMap, notEqualsJoinMap, "availability")

					.stream().collect(Collectors.toMap(x -> x.getCatalogId(), x -> (int) x.getAggregateValue()));

			LOGGER.info("currentStock");

		} else {

			if (fofoId == 0) {

				Map<String, Object> equalsStockJoinMap = new HashMap<>();

				equalsStockJoinMap.put("fofoId", fofoId);

				currentStockMap = itemRepository

						.selectItems(CurrentInventorySnapshot.class, "id", "itemId", equalsMap, notEqualsMap,

								equalsStockJoinMap, notEqualsJoinMap, "availability")

						.stream().collect(Collectors.toMap(x -> x.getCatalogId(), x -> (int) x.getAggregateValue()));

			} else {

				Map<String, Object> equalsStockJoinMap = new HashMap<>();

				equalsStockJoinMap.put("fofoId", fofoId);

				currentStockMap = itemRepository

						.selectItems(CurrentInventorySnapshot.class, "id", "itemId", equalsMap, notEqualsMap,

								equalsStockJoinMap, notEqualsJoinMap, "availability")

						.stream().collect(Collectors.toMap(x -> x.getCatalogId(), x -> (int) x.getAggregateValue()));

			}

		}

		LOGGER.info("currentStock" + currentStockMap);

		Map<Integer, Integer> itemsInTransit = null;

		List<TagListing> tagListings = tagListingRepository.selectAll(true);

		if (!isAdmin) {

			tagListings = new ArrayList<>(tagListings);

			List<Order> inTransitOrders = orderRepository.selectPendingGrnOrder(fofoId, validOrderStatusList);

			inTransitOrders = this.filterValidOrders(inTransitOrders);

			itemsInTransit = inTransitOrders.stream().collect(Collectors.groupingBy(x -> x.getLineItem().getItemId(),

					Collectors.summingInt(x -> x.getLineItem().getQuantity())));

		} else {

			itemsInTransit = new HashMap<>();

		}

		int totalPcs = 0;

		float totalAmount = 0;

		Map<Integer, CatalogListingModel> catalogListingMap = new HashMap<>();

		Map<Integer, FocusedModel> focusedModelMap = focusedModelRepository.selectAll().stream()

				.collect(Collectors.toMap(FocusedModel::getCatalogId, Function.identity()));

		LocalDate currentMonthDate = LocalDate.now();

		MonthlyPlanned monthlyPlanned = null;

		List<Integer> fofoOrderIds = null;

		LOGGER.info("localDate" + LocalDate.now());

		if (LocalDate.now().isAfter(LocalDate.now().withDayOfMonth(25))

				&& LocalDate.now().isBefore(LocalDate.now().plusMonths(1).withDayOfMonth(8))) {

			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())

					.collect(Collectors.toList());

			model.addAttribute("planningMonth", LocalDate.now().plusMonths(1).getMonth());

		} else if (LocalDate.now().isAfter(LocalDate.now().withDayOfMonth(8))

				&& (LocalDate.now().isBefore(LocalDate.now().withDayOfMonth(26)))) {

			currentMonthDate = LocalDate.now().withDayOfMonth(1);

			LocalDateTime curDate = LocalDate.now().atStartOfDay();

			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())

					.collect(Collectors.toList());

			LOGGER.info("monthlyPlanned1" + monthlyPlanned);

		} else if (LocalDate.now().isBefore(LocalDate.now().withDayOfMonth(8))) {

			currentMonthDate = LocalDate.now().withDayOfMonth(1);

			monthlyPlanned = monthlyPlannedRepository.selectByFofoIdYearMonth(fofoId, currentMonthDate);

			LOGGER.info("monthlyPlanned3" + monthlyPlanned);

			fofoOrderIds = fofoOrderRepository.selectByFofoIdBetweenCreatedTimeStamp(loginDetails.getFofoId(),

					LocalDateTime.now().minusDays(15), LocalDateTime.now()).stream().map(x -> x.getId())

					.collect(Collectors.toList());

			model.addAttribute("planningMonth", LocalDate.now().getMonth());

		}

		Map<Integer, Integer> plannedDetailMap = null;

		if (monthlyPlanned != null) {

			plannedDetailMap = plannedDetailRepository.selectByPlannedId(monthlyPlanned.getId()).stream()

					.collect(Collectors.toMap(x -> x.getCatalogId(), x -> x.getQuantity()));

		}

		LOGGER.info("plannedDetailMap" + plannedDetailMap);

		LOGGER.info("fofoOrderIds" + fofoOrderIds);

		Map<String, Object> equalsJoinMap = new HashMap<>();

		equalsJoinMap.put("orderId", fofoOrderIds);

		Map<Integer, Integer> last15daysMap = null;

		if (fofoOrderIds != null && !fofoOrderIds.isEmpty()) {

			last15daysMap = itemRepository

					.selectItems(FofoOrderItem.class, "id", "itemId", equalsMap, notEqualsMap, equalsJoinMap,

							notEqualsJoinMap, "quantity")

					.stream().collect(Collectors.toMap(x -> x.getCatalogId(), x -> (int) x.getAggregateValue()));

		}

		LOGGER.info("last15daysMap" + last15daysMap);

		Map<Integer, TagListing> taglistingMap = tagListings.stream()

				.collect(Collectors.toMap(x -> x.getItemId(), x -> x));

		List<Item> items = itemRepository.selectByIds(taglistingMap.keySet());

		Map<Integer, List<Item>> catalogIdItemMap = items.stream().collect(

				Collectors.groupingBy(x -> x.getCatalogItemId(), Collectors.mapping(y -> y, Collectors.toList())));

		LOGGER.info("catalogIdItemMap");

		Map<String, Object> equalsItemJoinMap = new HashMap<>();

		equalsItemJoinMap.put("active", 1);

		List<CatalogIdAggregateValue> tagListingCatalogIds = itemRepository.selectItems(TagListing.class, "id",

				"itemId", equalsMap, notEqualsMap, equalsItemJoinMap, notEqualsJoinMap, "tagId");

		LOGGER.info("tagListingCatalogIds");

		for (CatalogIdAggregateValue catalogIdAggregateValue : tagListingCatalogIds) {

			int catalogId = catalogIdAggregateValue.getCatalogId();

			Item item = catalogIdItemMap.get(catalogId).get(0);

			TagListing tagListing = taglistingMap.get(item.getId());

			CatalogListingModel catalogListingModel = catalogListingMap.get(catalogId);

			if (!catalogListingMap.containsKey(catalogId)) {

				catalogListingModel = new CatalogListingModel();

				catalogListingModel.setCatalogId(catalogId);

				catalogListingModel.setDp(tagListing.getSellingPrice());

				catalogListingModel.setMop(tagListing.getMop());

				catalogListingModel.setItemDescription(item.getItemDescriptionNoColor());

				if (plannedDetailMap != null) {

					Integer quantity = plannedDetailMap.get(catalogId);

					if (quantity != null) {

						catalogListingModel.setAllocatedQuantity(quantity);

					}

				}

				if (last15daysMap != null) {

					Integer last15DaysSale = last15daysMap.get(catalogId);

					if (last15DaysSale != null) {

						catalogListingModel.setLast15DaysSale(last15DaysSale);

					} else {

						catalogListingModel.setLast15DaysSale(0);

					}

				} else {

					catalogListingModel.setLast15DaysSale(0);

				}

				catalogListingModel.setBrand(item.getBrand());

				if (item.getCategoryId() == 10006) {

					catalogListingModel.setCategoryId(item.getCategoryId());

				}

				FocusedModel fm = focusedModelMap.get(catalogId);

				if (fm != null) {

					catalogListingModel.setRecommendedQty(fm.getRecommendedQty());

					catalogListingModel.setMinimumQty(fm.getMinimumQty());

				} else {

					catalogListingModel.setRecommendedQty(0);

					catalogListingModel.setMinimumQty(0);

				}

				catalogListingMap.put(catalogId, catalogListingModel);

			}

			int itemAvailability = 0;

			if (currentStockMap != null) {

				Integer qty = currentStockMap.get(catalogId);

				itemAvailability = qty == null ? 0 : qty;

				catalogListingModel.setStockInHand(itemAvailability);

			} else {

				catalogListingModel.setStockInHand(0);

			}

			Integer inTransitQuantity = itemsInTransit.get(item.getId());

			int inTransitQty = (inTransitQuantity == null ? 0 : inTransitQuantity);

			catalogListingModel.setInTransitQuantity(catalogListingModel.getInTransitQuantity() + inTransitQty);

			if (plannedDetailMap != null) {

				if (plannedDetailMap.get(catalogId) != null) {

					int remaining = plannedDetailMap.get(catalogId) - catalogListingModel.getLast15DaysSale()

							+ catalogListingModel.getStockInHand() + catalogListingModel.getInTransitQuantity();

					LOGGER.info("remaning" + remaining);

					if (remaining != 0) {

						catalogListingModel.setRemaining(remaining);

					} else {

						catalogListingModel.setRemaining(0);

					}

				}

			}

		}

		Map<Integer, CustomRetailer> customRetailersMap = retailerService.getFofoRetailers();

		if (fofoId > 0) {

			CustomRetailer customRetailer = customRetailersMap.get(fofoId);

			model.addAttribute("retailerName",

					customRetailer.getBusinessName() + "-" + customRetailer.getAddress().getCity());

			FofoStore fs = fofoStoreRepository.selectByRetailerId(fofoId);

			model.addAttribute("retailerId", customRetailer.getPartnerId());

			model.addAttribute("counterSize", fs.getCounterSize().toString());

		} else {

			model.addAttribute("counterSize", counterSize.toString());

		}

		String customRetailers = JSONObject.valueToString(customRetailersMap.values());

		List<CatalogListingModel> catalogModelList = new ArrayList<>(catalogListingMap.values());

		Comparator<CatalogListingModel> firstCmp = Comparator.comparing(CatalogListingModel::getMinimumQty,

				Comparator.reverseOrder());

		LOGGER.info("monthlyPlanned" + monthlyPlanned);

		model.addAttribute("catalogTagListings",

				catalogModelList.stream().sorted(firstCmp).collect(Collectors.toList()));

		model.addAttribute("isAdmin", roleManager.isAdmin(roleIds));

		model.addAttribute("brandStockPrices", this.getBrandStockPrices(loginDetails.getFofoId()));

		model.addAttribute("previousPlanningMonth", LocalDate.now().minusMonths(1).getMonth());

		model.addAttribute("currentPlanningMonth", LocalDate.now().getMonth());

		model.addAttribute("customRetailers", customRetailers);

		model.addAttribute("totalAmount", totalAmount);

		model.addAttribute("monthlyPlanned", monthlyPlanned);

		model.addAttribute("totalPcs", totalPcs);

		UserWallet userWallet = walletService.getUserWallet(fofoId);

		model.addAttribute("userWallet", userWallet);

		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("http://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);

		List<Item> items = new ArrayList<>();

		for (Item item : selecteditems) {

			TagListing tagListing = tagListingRepository.selectByItemId(item.getId(), true);

			if (tagListing != null) {

				items.add(item);

			}

		}

		model.addAttribute("items", items);

		LOGGER.info("itemIdAndColorMap" + items);

		return "select-item-color";

	}