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

 package com.spice.profitmandi.web.controller;
 import java.io.IOException;
 import java.net.URISyntaxException;
+import java.time.DayOfWeek;
+import java.time.LocalDate;
 import java.time.LocalDateTime;
+import java.time.temporal.TemporalAdjusters;
+import java.time.temporal.WeekFields;
+import java.util.Collection;
 import java.util.List;
+import java.util.stream.Collectors;
 import javax.servlet.http.HttpServletRequest;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.apache.solr.common.util.Utils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Controller;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.ui.Model;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.dao.entity.dtr.NotificationData;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
+import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
 import com.spice.profitmandi.dao.entity.transaction.Order;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.NotificationPanelRepository;
 import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
+import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
 import com.spice.profitmandi.dao.repository.fofo.PurchaseReturnItemRepository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
 import com.spice.profitmandi.service.authentication.RoleManager;
 import com.spice.profitmandi.service.inventory.InventoryService;
 import com.spice.profitmandi.service.slab.TargetSlabService;
 	@Value("${web.api.host}")
 	private String webApiHost;
 	@Value("${web.api.scheme}")
 	private String webApiScheme;
 	@Value("${web.api.root}")
 	private String webApiRoot;
 	@Value("${web.api.port}")
 	private int webApiPort;
 	@Autowired
 	private CookiesProcessor cookiesProcessor;
 	@Autowired
 	private RoleManager roleManager;
 	@Autowired
 	private WalletService walletService;
 	@Autowired
 	private InventoryService inventoryService;
 	@Autowired
 	private TargetSlabService targetSlabService;
 	@Autowired
 	private OrderRepository orderRepository;
 	@Autowired
 	private PurchaseReturnItemRepository purchaseReturnItemRepository;
+	@Autowired
+	private PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
 	/*
 	 * @Autowired private ScanRepository scanRepository;
 	 */
 	@Autowired
 				model.addAttribute("size", size);
 				LOGGER.info("sizeOriginal {}", size);
+			}
+		}
+		LocalDate endDate = LocalDate.now().minusDays(1);
+		LocalDate weekStartDate = endDate.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY));
+		LocalDate startDate = weekStartDate.minusWeeks(3);
+		List<PartnerDailyInvestment> dailyInvestments = partnerDailyInvestmentRepository.selectAll(loginDetails.getFofoId(), startDate, endDate);
+		Collection<Integer> investmentMaintained = dailyInvestments.stream().collect(Collectors.groupingBy(
+				x->x.getDate().get(WeekFields.ISO.weekOfYear()),
+				Collectors.summingInt(x1-> {return x1.isComplete()?1:0;})
+		)).values();
+		model.addAttribute("investmentMaintained", Utils.toJSONString(investmentMaintained));
 		model.addAttribute("sale", sale);
 		model.addAttribute("walletAmount", walletAmount);
 		model.addAttribute("inStockAmount", inStockAmount);
 		model.addAttribute("unbilledStockAmount", unbilledStockAmount);
 		model.addAttribute("grnPendingStockAmount", grnPendingStockAmount);
 		// LOGGER.info("loginDetails.getFofoId()"+loginDetails.getFofoId());
 		// inventoryService.prebookingAvailabilitySendMessage(loginDetails.getFofoId());
 		return "dashboard";
+	}
-	//This method is currently hardcoded to faciliate watches sold as gift.
+	// This method is currently hardcoded to faciliate watches sold as gift.
 	private boolean hasGift(int fofoId) {
 		try {
-			return currentInventorySnapshotRepository.selectByItemIdAndFofoId(ProfitMandiConstants.GIFT_ID, fofoId).getAvailability() > 0;
+			return currentInventorySnapshotRepository.selectByItemIdAndFofoId(ProfitMandiConstants.GIFT_ID, fofoId)
+					.getAvailability() > 0;
 		} catch (ProfitMandiBusinessException e) {
 			return false;
+		}
+	}
 	@RequestMapping(value = "/getPaginatedNotificationData", method = RequestMethod.GET)
 	public String getPaginatedNotificationData(HttpServletRequest request,
 			@RequestParam(name = "offset", defaultValue = "0") int offset,
 			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+			}
+		}
 		return "dashboard-paginated";
+	}
 	@RequestMapping(value = "/contactUs", method = RequestMethod.GET)
 	public String contactUs(HttpServletRequest request, Model model) throws Throwable {
 		model.addAttribute("appContextPath", request.getContextPath());
 		return "contact-us";
+	}
 	/*
 	 * private List<PaymentOption> getPaymentOptions(int fofoId){ List<Integer>
 	 * paymentOptionIds =
-	 * fofoPartnerPaymentOptionRepository.selectPaymentOptionIdsByFofoId(fofoId)
+	 * fofoPartnerPaymentOptionRepository.selectPaymentOptionIdsByFofoId(fofoId) ;
-	 * ; if(paymentOptionIds.isEmpty()){ return new ArrayList<>(); } return
+	 * if(paymentOptionIds.isEmpty()){ return new ArrayList<>(); } return
 	 * paymentOptionRepository.selectByIds(new HashSet<>(paymentOptionIds)); }
 	 */
 	@RequestMapping(value = "/inactiveNotificationData", method = RequestMethod.POST)
 	public String inactiveNotificationData(HttpServletRequest request,

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/DashboardController.java – Rev 24276 → 24288