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

 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.ArrayList;
 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 org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
+import com.spice.profitmandi.common.util.FormattingUtils;
 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.service.wallet.WalletService;
 import com.spice.profitmandi.web.model.LoginDetails;
 import com.spice.profitmandi.web.util.CookiesProcessor;
 import com.spice.profitmandi.web.util.MVCResponseSender;
+import be.ceau.chart.BarChart;
+import be.ceau.chart.data.BarData;
+import be.ceau.chart.dataset.BarDataset;
+import be.ceau.chart.options.BarOptions;
+import be.ceau.chart.options.Title;
+import be.ceau.chart.options.scales.BarScale;
+import be.ceau.chart.options.scales.XAxis;
+import be.ceau.chart.options.scales.YAxis;
+import be.ceau.chart.options.ticks.LinearTicks;
 @Controller
 @Transactional(rollbackFor = Throwable.class)
 public class DashboardController {
 	@Value("${web.api.host}")
 	private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;
 	private static final Logger LOGGER = LogManager.getLogger(DashboardController.class);
 	@RequestMapping(value = "/dashboard", method = RequestMethod.GET)
-	public String dashboard(HttpServletRequest request,@RequestParam(name = "offset", defaultValue = "0") int offset,
+	public String dashboard(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset,
 			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
 			throws ProfitMandiBusinessException, URISyntaxException, IOException {
 		// LOGGER.info("scanRepository.selectScansByInventoryItemId(1)",
 		// scanRepository.selectScansByInventoryItemId(1));
 		LOGGER.info("In Dashboard");
 		float unbilledStockAmount = 0;
 		float grnPendingStockAmount = 0;
 		float shortPercentage = 100;
 		float totalInvestedAmount = 0;
 		float minimumInvestment = 0;
-		float returnedStockInTransit=0;
+		float returnedStockInTransit = 0;
-		float sale=0;
+		float sale = 0;
 		if (roleManager.isAdmin(loginDetails.getRoleIds())) {
 			model.addAttribute("showAlert", false);
 			model.addAttribute("sale", sale);
 			List<NotificationData> notificationData = null;
 			long size = 0;
+			}
 		} else if (roleManager.isPartner(loginDetails.getRoleIds())) {
 			walletAmount = walletService.getUserWallet(loginDetails.getFofoId()).getAmount();
 			inStockAmount = inventoryService.getTotalAmountInStock(loginDetails.getFofoId());
 			List<Order> unbilledOrders = transactionService.getInTransitOrders(loginDetails.getFofoId());
 			for (Order unBilledOrder : unbilledOrders) {
 				unbilledStockAmount += unBilledOrder.getTotalAmount();
+			}
+			}
+		}
 		LocalDate endDate = LocalDate.now().minusDays(1);
 		LocalDate weekStartDate = endDate.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY));
-		LocalDate startDate = weekStartDate.minusWeeks(3);
+		LocalDate startDate = weekStartDate.minusWeeks(5);
-		List<PartnerDailyInvestment> dailyInvestments = partnerDailyInvestmentRepository.selectAll(loginDetails.getFofoId(), startDate, endDate);
+		List<PartnerDailyInvestment> partnerInvestments = partnerDailyInvestmentRepository
-		Collection<Integer> investmentMaintained = dailyInvestments.stream().collect(Collectors.groupingBy(
-				x->x.getDate().get(WeekFields.ISO.weekOfYear()),
-				Collectors.summingInt(x1-> {return x1.isComplete()?1:0;})
+				.selectAll(loginDetails.getFofoId(), startDate, endDate);
-		)).values();
-		model.addAttribute("investmentMaintained", Utils.toJSONString(investmentMaintained));
+		model.addAttribute("investmentChart", this.getInvestmentChartData(partnerInvestments));
 		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";
+	}
+	private String getInvestmentChartData(List<PartnerDailyInvestment> partnerInvestments) {
+		List<List<Integer>> walletStackList = new ArrayList<>();
+		List<List<Integer>> inStockStackList = new ArrayList<>();
+		List<List<Integer>> salesStackList = new ArrayList<>();
+		List<List<Integer>> grnPendingStackList = new ArrayList<>();
+		List<List<Integer>> billingPendingStackList = new ArrayList<>();
+		List<List<Integer>> inTransitStackList = new ArrayList<>();
+		List<List<LocalDate>> datesList = new ArrayList<>();
+		int currentWeekOfYear = 0;
+		for (PartnerDailyInvestment pdi : partnerInvestments) {
+			List<Integer> walletStack = null;
+			List<Integer> inStockStack = null;
+			List<Integer> salesStack = null;
+			List<Integer> grnPendingStack = null;
+			List<Integer> billingPendingStack = null;
+			List<Integer> inTransitStack = null;
+			List<LocalDate> dates = null;
+			int weekOfYear = pdi.getDate().get(WeekFields.ISO.weekOfYear());
+			if (weekOfYear != currentWeekOfYear) {
+				walletStack = new ArrayList<>();
+				inStockStack = new ArrayList<>();
+				salesStack = new ArrayList<>();
+				grnPendingStack = new ArrayList<>();
+				billingPendingStack = new ArrayList<>();
+				inTransitStack = new ArrayList<>();
+				dates = new ArrayList<>();
+				currentWeekOfYear = weekOfYear;
+				walletStackList.add(walletStack);
+				inStockStackList.add(inStockStack);
+				salesStackList.add(salesStack);
+				grnPendingStackList.add(grnPendingStack);
+				billingPendingStackList.add(billingPendingStack);
+				inTransitStackList.add(inTransitStack);
+			}
+			walletStack.add((int)pdi.getWalletAmount());
+			inStockStack.add((int)pdi.getInStockAmount());
+			salesStack.add((int)pdi.getSalesAmount());
+			grnPendingStack.add((int)pdi.getGrnPendingAmount());
+			billingPendingStack.add((int)pdi.getUnbilledAmount());
+			inTransitStack.add((int)pdi.getReturnInTransitAmount());
+			datesList.add(dates);
+		}
+		int counter = 0;
+		BarData barData = new BarData();
+		while(counter < walletStackList.size()) {
+			barData
+			.addDataset(new BarDataset().setData(walletStackList.get(counter).stream().mapToInt(i -> i).toArray()).setLabel("Wallet"))
+			.addDataset(new BarDataset().setData(inStockStackList.get(counter).stream().mapToInt(i -> i).toArray()).setLabel("In Stock"))
+			.addDataset(new BarDataset().setData(salesStackList.get(counter).stream().mapToInt(i -> i).toArray()).setLabel("Sales"))
+			.addDataset(new BarDataset().setData(grnPendingStackList.get(counter).stream().mapToInt(i -> i).toArray()).setLabel("Grn Pending"))
+			.addDataset(new BarDataset().setData(billingPendingStackList.get(counter).stream().mapToInt(i -> i).toArray()).setLabel("Billing Pending"))
+			.addDataset(new BarDataset().setData(inTransitStackList.get(counter).stream().mapToInt(i -> i).toArray()).setLabel("In Transit"));
+			counter++;
+		}
+		BarOptions barOptions = new BarOptions()
+				.setTitle(new Title().setText("Daily Investment Summary"))
+				.setScales(new BarScale().addxAxes(new XAxis<LinearTicks>().setStacked(true))
+										 .addyAxes(new YAxis<LinearTicks>().setStacked(true))
+										 );
+		BarChart barChart = new BarChart(barData, barOptions);
+		return barChart.toJson();
+	}
 	// 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;

Subversion Repositories SmartDukaan

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