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.File;
 import java.io.FileInputStream;
 import java.io.FileNotFoundException;
+import java.io.FileOutputStream;
+import java.io.ObjectInputStream;
+import java.io.ObjectOutputStream;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.time.YearMonth;
 import java.time.ZoneOffset;
 import org.springframework.ui.Model;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.gson.Gson;
 import com.mongodb.DBObject;
 import com.spice.profitmandi.common.enumuration.ContentType;
 import com.spice.profitmandi.common.enumuration.MessageType;
 import com.spice.profitmandi.common.enumuration.ReporticoProject;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
 import com.spice.profitmandi.dao.entity.fofo.PartnerTargetDetails;
 import com.spice.profitmandi.dao.entity.fofo.PartnerType;
 import com.spice.profitmandi.dao.entity.inventory.ReporticoCacheTable;
-import com.spice.profitmandi.dao.entity.transaction.LineItem;
 import com.spice.profitmandi.dao.entity.transaction.Order;
 import com.spice.profitmandi.dao.entity.user.Lead;
 import com.spice.profitmandi.dao.enumuration.catalog.ItemCriteriaType;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.enumuration.dtr.LeadStatus;
+import com.spice.profitmandi.dao.model.BrandWisePartnerSaleModel;
 import com.spice.profitmandi.dao.model.CreateOfferRequest;
 import com.spice.profitmandi.dao.model.ItemTypeParams;
 import com.spice.profitmandi.dao.model.ItemWiseTertiaryModel;
 import com.spice.profitmandi.dao.model.MonthSaleModel;
 import com.spice.profitmandi.dao.model.PartnerDetailModel;
 import com.spice.profitmandi.dao.model.PartnerPendingIndentItemModel;
 import com.spice.profitmandi.dao.model.SimpleCampaign;
 import com.spice.profitmandi.dao.model.SimpleCampaignParams;
 import com.spice.profitmandi.dao.model.WarehouseBrandWiseItemSaleModel;
-import com.spice.profitmandi.dao.model.BrandWisePartnerSaleModel;
-import com.spice.profitmandi.dao.model.WarehouseWiseBrandStockModel;
 import com.spice.profitmandi.dao.model.WarehouseWiseBrandSaleModel;
+import com.spice.profitmandi.dao.model.WarehouseWiseBrandStockModel;
 import com.spice.profitmandi.dao.model.WarehouseWiseStockModel;
 import com.spice.profitmandi.dao.model.WarehouseWiseitemStockModel;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.auth.MenuCategoryRepository;
 import com.spice.profitmandi.dao.repository.auth.MenuRepository;
 			model.addAttribute("fofoStore", customRetailer);
 			model.addAttribute("partnerType", partnerType);
 			model.addAttribute("hasGift", hasGift(fofoId));
 			model.addAttribute("giftItemId", ProfitMandiConstants.GIFT_ID);
-			model.addAttribute("brandStockPrices", this.getBrandStockPrices(fofoId));
+			// model.addAttribute("brandStockPrices", this.getBrandStockPrices(fofoId));
 			model.addAttribute("salesMap", this.getSales(fofoId));
 			model.addAttribute("activatedImeis", inventoryItemRepository.selectCountByActivatedNotSold(fofoId));
 			// this.setInvestments
 			//
 			model.addAttribute("investments", this.getInvestments(fofoId));
 		List<Menu> menus = null;
 		try {
 			AuthUser authUser = authRepository.selectByEmailOrMobile(email);
 			List<Position> positions = positionRepository.selectAll(authUser.getId());
 			Map<Integer, PartnerDetailModel> warehousePartnerDetailMap = null;
-			ReporticoCacheTable rct = null;
+			ReporticoCacheTable rctSaholic = null;
+			ReporticoCacheTable rctPartneStat = null;
 			Map<Integer, WarehouseWiseStockModel> warehouseStockMap = new HashMap<>();
 			Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
 			LinkedHashMap<Integer, String> wm = new LinkedHashMap<Integer, String>();
 			List<BrandWisePartnerSaleModel> partnersBrandSale = null;
 						warehouseStockMap.put(0, ws);
+					}
 					warehousePartnerDetailMap = this.getWarehousePartnerDetail();
+					LOGGER.info("warehousePartnerDetailMap" + warehousePartnerDetailMap);
-					rct = reporticoCacheTableRepository.selectByTableName("SaholicInventoryCIS");
+					rctSaholic = reporticoCacheTableRepository.selectByTableName("SaholicInventoryCIS");
+					rctPartneStat = reporticoCacheTableRepository.selectByTableName("partnerStat");
 					partnersBrandSale = fofoStoreRepository.selectGroupByBrandWarehousePartnerSale();
 					accessoriesBrandSales = fofoStoreRepository.selectGroupByBrandAccesoriesWarehousePartnerSale();
+				}
+			}
 					model.addAttribute("warehouses", getWarehouses(positionRetailers));
+				}
 				model.addAttribute("authId", authUser.getId());
+			}
+			model.addAttribute("rctPartneStat", rctPartneStat);
-			model.addAttribute("reporticoDate", rct);
+			model.addAttribute("reporticoDate", rctSaholic);
 			model.addAttribute("warehousePartnerDetailMap", warehousePartnerDetailMap);
 			model.addAttribute("warehouseMap", wm);
 			model.addAttribute("warehouseStockMap", warehouseStockMap);
 			model.addAttribute("brandSales", partnersBrandSale);
 	@RequestMapping(value = "/getWarehousePartners", method = RequestMethod.GET)
 	public String warehousePartnersDetail(HttpServletRequest request, Model model, @RequestParam int warehouseId)
 			throws Exception {
 		Map<Integer, CustomRetailer> fofoIdAndPartnerMap = retailerService.getFofoRetailers(false);
-		Map<Integer, PartnerDetailModel> fofoIdAndallValues = partnerStatsService.getAllPartnerStats();
+		Map<Integer, PartnerDetailModel> fofoIdAndallValues = this.getPartnersStatDataFromFile();
 		if (warehouseId != 0) {
 			List<Integer> fofoIds = fofoStoreRepository.selectActivePartnerByWarehouse(warehouseId).stream()
 					.map(x -> x.getId()).collect(Collectors.toList());
 			fofoIdAndallValues = fofoIdAndallValues.entrySet().stream().filter(x -> fofoIds.contains(x.getKey()))
 		inventoryService.getItemAvailabilityAndIndent();
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
+	public Map<Integer, PartnerDetailModel> getWarehousePartnerDetail() throws Exception {
+		Map<Integer, PartnerDetailModel> warehouseIdAndallValues = new LinkedHashMap<>();
+		Map<Integer, List<FofoStore>> warehousePartnerMap = fofoStoreRepository.getWarehousePartnerMap();
+		Map<Integer, PartnerDetailModel> partnerStats = this.getPartnersStatDataFromFile();
+		if (partnerStats != null) {
+			for (Entry<Integer, List<FofoStore>> warehouse : warehousePartnerMap.entrySet()) {
+				List<Integer> fofoIds = warehouse.getValue().stream().map(x -> x.getId()).collect(Collectors.toList());
+				List<PartnerDetailModel> partnerDetails = fofoIds.stream().map(x -> partnerStats.get(x))
+						.collect(Collectors.toList());
+				LOGGER.info("partnerDetails" + partnerDetails);
+				PartnerDetailModel partnerDetailModel = partnerStatsService.getAggregateStats(partnerDetails);
+				warehouseIdAndallValues.put(warehouse.getKey(), partnerDetailModel);
+			}
+			LOGGER.info("warehouseIdAndallValues" + warehouseIdAndallValues);
+			PartnerDetailModel partnerDetailModel = partnerStatsService
+					.getAggregateStats(new ArrayList<>(partnerStats.values()));
+			warehouseIdAndallValues.put(0, partnerDetailModel);
+		}
+		return warehouseIdAndallValues;
+	}
+	@RequestMapping(value = "/getPartnersStatData", method = RequestMethod.GET)
+	public String getPartnersStatData(HttpServletRequest request, Model model) throws Exception {
+		Map<Integer, PartnerDetailModel> partnerStats = partnerStatsService.getAllPartnerStats();
+		ObjectOutputStream oos = null;
+		FileOutputStream fout = null;
+		try {
+			fout = new FileOutputStream("/tmp/partnerStat.tmp", false);
+			oos = new ObjectOutputStream(fout);
+			oos.writeObject(partnerStats);
+		} catch (Exception ex) {
+			ex.printStackTrace();
+		} finally {
+			if (oos != null) {
+				oos.close();
+			}
+		}
+		ReporticoCacheTable rct = reporticoCacheTableRepository.selectByTableName("partnerStat");
+		if (rct == null) {
+			rct = new ReporticoCacheTable();
+			rct.setTableName("partnerStat");
+		}
+		rct.setLastCreatedTimestamp(LocalDateTime.now());
+		reporticoCacheTableRepository.persist(rct);
+		model.addAttribute("response", mvcResponseSender.createResponseString(true));
+		return "response";
+	}
+	public Map<Integer, PartnerDetailModel> getPartnersStatDataFromFile() throws Exception {
+		ObjectInputStream objectinputstream = null;
+		Map<Integer, PartnerDetailModel> partnerStat = null;
+		try {
+			FileInputStream streamIn = new FileInputStream("/tmp/partnerStat.tmp");
+			objectinputstream = new ObjectInputStream(streamIn);
+			partnerStat = (Map<Integer, PartnerDetailModel>) objectinputstream.readObject();
+			LOGGER.info("partnerStat" + partnerStat);
+			objectinputstream.close();
+		} catch (Exception e) {
+			LOGGER.info("exceptionddd" + e);
+			e.printStackTrace();
+		} finally {
+			if (objectinputstream != null) {
+				objectinputstream.close();
+				LOGGER.info("clofddd" + partnerStat);
+			}
+		}
+		return partnerStat;
+	}
 	@RequestMapping(value = "/getWarehouseWiseBrandAndCategory", method = RequestMethod.GET)
 	public String getWarehouseWiseBrandAndCategory(HttpServletRequest request, Model model,
 			@RequestParam List<Integer> warehouseId, @RequestParam List<String> brands, @RequestParam String category)
 			throws Exception {
 		authIdAndallValues.put(-1, partnerStatsService.getAggregateStats(unmappedPartnerDetails));
 		authIdAndallValues.put(0, partnerDetailModel);
 		return authIdAndallValues;
+	}
-	public Map<Integer, PartnerDetailModel> getWarehousePartnerDetail() throws Exception {
-		Map<Integer, PartnerDetailModel> warehouseIdAndallValues = new LinkedHashMap<>();
-		Map<Integer, List<FofoStore>> warehousePartnerMap = fofoStoreRepository.getWarehousePartnerMap();
-		Map<Integer, PartnerDetailModel> partnerStats = partnerStatsService.getAllPartnerStats();
-		for (Entry<Integer, List<FofoStore>> warehouse : warehousePartnerMap.entrySet()) {
-			List<Integer> fofoIds = warehouse.getValue().stream().map(x -> x.getId()).collect(Collectors.toList());
-			List<PartnerDetailModel> partnerDetails = fofoIds.stream().map(x -> partnerStats.get(x))
-					.collect(Collectors.toList());
-			LOGGER.info("partnerDetails" + partnerDetails);
-			PartnerDetailModel partnerDetailModel = partnerStatsService.getAggregateStats(partnerDetails);
-			warehouseIdAndallValues.put(warehouse.getKey(), partnerDetailModel);
-		}
-		LOGGER.info("warehouseIdAndallValues" + warehouseIdAndallValues);
-		PartnerDetailModel partnerDetailModel = partnerStatsService
-				.getAggregateStats(new ArrayList<>(partnerStats.values()));
-		warehouseIdAndallValues.put(0, partnerDetailModel);
-		return warehouseIdAndallValues;
-	}
 	@RequestMapping(value = "/getItemWiseTertiary", method = RequestMethod.GET)
 	public String getItemWiseTertiary(HttpServletRequest request,
 			@RequestParam(name = ProfitMandiConstants.FOFO_ID) int fofoId, Model model)
 			throws ProfitMandiBusinessException {
 		List<ItemWiseTertiaryModel> itemWiseTertiary = fofoOrderRepository.SelectItemWiseTertiary(fofoId);

Subversion Repositories SmartDukaan

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