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

 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.Comparator;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
 import java.util.Set;
 import java.util.stream.Collectors;
 import org.springframework.web.bind.annotation.RequestParam;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.CustomRetailer;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
+import com.spice.profitmandi.common.services.mandii.TransactionSummaryResponseOut;
 import com.spice.profitmandi.common.web.util.ResponseSender;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
 import com.spice.profitmandi.dao.entity.auth.PartnerCollectionPlan;
 import com.spice.profitmandi.dao.entity.auth.PartnerSecondaryPlan;
-import com.spice.profitmandi.dao.entity.cs.Position;
 import com.spice.profitmandi.dao.entity.dtr.User;
 import com.spice.profitmandi.dao.entity.dtr.UserAccount;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
+import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
 import com.spice.profitmandi.dao.entity.fofo.PartnerOnBoardingPanel;
 import com.spice.profitmandi.dao.entity.user.FranchiseeActivity;
 import com.spice.profitmandi.dao.entity.user.FranchiseeVisit;
 import com.spice.profitmandi.dao.entity.user.Lead;
 import com.spice.profitmandi.dao.entity.user.LeadActivity;
 import com.spice.profitmandi.dao.repository.dtr.LeadActivityRepository;
 import com.spice.profitmandi.dao.repository.dtr.LeadRepository;
 import com.spice.profitmandi.dao.repository.dtr.PartnerOnBoardingPanelRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserRepository;
-import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
+import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.user.StoreTimelineTatService;
 import com.spice.profitmandi.web.req.CreateFranchiseeRequest;
 		return responseSender.ok(status);
+	}
 	@Autowired
-	private com.spice.profitmandi.service.transaction.TransactionService transactionService;
-	@Autowired
-	private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;
-	@Autowired
 	private OrderRepository orderRepository;
 	@Autowired
 	private PositionRepository positionRepository;
 	private PartnerCollectionPlanRepository partnerCollectionPlanRepository;
 	@Autowired
 	private PartnerSecondaryPlanRepository partnerSecondaryPlanRepository;
+	@Autowired
+	private PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
 	@RequestMapping(value = "/getPartnerTarget", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
 	@ApiImplicitParams({
 			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
 	public ResponseEntity<?> getPartnerTarget(HttpServletRequest request,
-			@RequestParam(name = "gmailId") String gmailId) throws ProfitMandiBusinessException {
+			@RequestParam(name = "gmailId") String gmailId, @RequestParam String dayValue)
+			throws ProfitMandiBusinessException {
 		AuthUser authUser = authRepository.selectByGmailId(gmailId);
 		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
-		Set<Integer> fofoIds = storeGuyMap.get("ankit.bhatia@smartdukaan.com");
+		Set<Integer> fofoIds = storeGuyMap.get(authUser.getEmailId());
 		LOGGER.info("fofoIds" + fofoIds);
-		if (fofoIds == null) {
-			List<Position> positions1 = positionRepository.selectAll(authUser.getId());
-			if (positions1.stream().filter(x -> x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_MASTER)
-					.count() > 0) {
-				fofoIds = csService.getPositionCustomRetailerMap(positions1).values().stream().flatMap(x -> x.stream())
-						.map(x -> x.getPartnerId()).collect(Collectors.toSet());
-			}
-		}
 		List<String> brands = Arrays.asList("Vivo", "Samsung", "Oppo", "Itel", "Others");
 		float totalPartnerTargetSecondary = 0;
 		float totalPartnerTargetCollection = 0;
 		float totalPartnerAchievementSecondary = 0;
 		float totalPartnerAchievementCollection = 0;
 		TargetModel tm = new TargetModel();
+		Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = new HashMap<>();
 		List<PartnerTargetAchievementModel> ptams = new ArrayList<>();
 		if (fofoIds.size() > 0 && fofoIds != null) {
-			List<Integer> fofoIdList = new ArrayList<>(fofoIds);
+			List<Integer> fofoIdl = new ArrayList<>(fofoIds);
+			List<Integer> fofoIdList = fofoStoreRepository.selectByRetailerIds(fofoIdl).stream()
+					.filter(x -> !x.isInternal()).map(x -> x.getId()).collect(Collectors.toList());
 			LocalDateTime startDate = LocalDate.now().atStartOfDay();
+			LocalDateTime endDate = LocalDate.now().atTime(LocalTime.MAX);
+			if (dayValue.equals("previous")) {
+				startDate = LocalDate.now().minusDays(1).atStartOfDay();
+				endDate = LocalDate.now().minusDays(1).atTime(LocalTime.MAX);
+			}
+			List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository
+					.selectAll(fofoIdList, startDate.minusDays(3).toLocalDate());
+			if (!partnerDailyInvestments.isEmpty()) {
+				partnerDailyInvestmentMap = partnerDailyInvestments.stream()
+						.collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
+			}
 			Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(fofoIdList);
 			Map<Integer, PartnerCollectionPlanModel> collectionPlans = userWalletRepository
-					.getPartnerWiseTargetCollections(fofoIdList, startDate).stream()
+					.getPartnerWiseTargetCollections(fofoIdList, startDate, endDate).stream()
 					.collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
 			LOGGER.info("collectionPlans {}", collectionPlans);
 			Map<Integer, List<PartnerSecondaryPlanModel>> partnerSecondayPlans = orderRepository
-					.selectPartnerSecondaryGroupByBrand(fofoIdList, startDate).stream()
+					.selectPartnerSecondaryGroupByBrand(fofoIdList, startDate, endDate).stream()
 					.collect(Collectors.groupingBy(x -> x.getFofoId()));
 			LOGGER.info("partnerSecondayPlans {}", partnerSecondayPlans);
 			for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailers.entrySet()) {
 				int fofoId = customRetailerEntry.getKey();
 				PartnerTargetAchievementModel ptam = new PartnerTargetAchievementModel();
 				ptam.setFofoId(fofoId);
 				ptam.setBusinessName(customRetailer.getBusinessName());
+				if (partnerDailyInvestmentMap.get(fofoId) != null) {
+					ptam.setWalletAmount(partnerDailyInvestmentMap.get(fofoId).getWalletAmount());
+					ptam.setShortInvestment(partnerDailyInvestmentMap.get(fofoId).getShortInvestment());
+				}
 				if (collectionPlans.get(fofoId) != null) {
-					totalPartnerTargetCollection += collectionPlans.get(fofoId).getTargetPlan();
+					Integer authId = collectionPlans.get(fofoId).getAuthId();
+					LOGGER.info("authId" + authId);
+					if (authId != null && authId == authUser.getId()) {
+						if (collectionPlans.get(fofoId).getTargetPlan() != null) {
+							totalPartnerTargetCollection += collectionPlans.get(fofoId).getTargetPlan();
+						}
+						if (collectionPlans.get(fofoId).getAchievementPlan() != null) {
-					totalPartnerAchievementCollection += collectionPlans.get(fofoId).getAchievementPlan();
+							totalPartnerAchievementCollection += collectionPlans.get(fofoId).getAchievementPlan();
+						}
+					}
+					if (authId != null && authId != authUser.getId()) {
+						ptam.setAuthUser(authRepository.selectById(authId));
+						ptam.setCollectionColor("red");
+					}
+					if (collectionPlans.get(fofoId).getTargetPlan() != null) {
-					ptam.setCollectionTarget(collectionPlans.get(fofoId).getTargetPlan());
+						ptam.setCollectionTarget(collectionPlans.get(fofoId).getTargetPlan());
+					}
+					if (collectionPlans.get(fofoId).getAchievementPlan() != null) {
-					ptam.setCollectionAchievement(collectionPlans.get(fofoId).getAchievementPlan());
+						ptam.setCollectionAchievement(collectionPlans.get(fofoId).getAchievementPlan());
+					}
+				}
 				PartnerSecondaryPlanModel otherPartnerSecondaryPlanModel = null;
+				Map<String, PartnerSecondaryPlanModel> secondaryModelMap = new HashMap<>();
 				if (partnerSecondayPlans.get(fofoId) != null) {
 					long otherBrandSecondary = 0;
 					for (PartnerSecondaryPlanModel pspm : partnerSecondayPlans.get(fofoId)) {
+						Integer authId = pspm.getAuthId();
 						if (!brands.contains(pspm.getBrand())) {
+							if (pspm.getAchievementPlan() != null) {
-							otherBrandSecondary += pspm.getAchievementPlan();
+								otherBrandSecondary += pspm.getAchievementPlan();
+							}
 						} else {
 							otherPartnerSecondaryPlanModel = pspm;
+						}
+						if (pspm.getTargetPlan() != null) {
-						totalSecondaryPlan += pspm.getTargetPlan();
+							totalSecondaryPlan += pspm.getTargetPlan();
+						}
+						if (pspm.getAchievementPlan() != null) {
-						totalSecondaryAchivement += pspm.getAchievementPlan();
+							totalSecondaryAchivement += pspm.getAchievementPlan();
+						}
+						if (authId != null && authId == authUser.getId()) {
+							if (pspm.getTargetPlan() != null) {
+								totalPartnerTargetSecondary += pspm.getTargetPlan();
+							}
+							if (pspm.getAchievementPlan() != null) {
+								totalPartnerAchievementSecondary += pspm.getAchievementPlan();
+							}
+						}
+					}
 					if (otherPartnerSecondaryPlanModel != null) {
 						otherPartnerSecondaryPlanModel.setAchievementPlan(otherBrandSecondary);
+					}
-					Map<String, PartnerSecondaryPlanModel> secondaryModelMap = partnerSecondayPlans.get(fofoId).stream()
+					secondaryModelMap = partnerSecondayPlans.get(fofoId).stream()
 							.filter(x -> brands.contains(x.getBrand()))
 							.collect(Collectors.toMap(x -> x.getBrand(), x -> x));
 					if (secondaryModelMap.containsKey("Others")) {
 						PartnerSecondaryPlanModel psp = secondaryModelMap.get("Others");
 						psp.setAchievementPlan(otherBrandSecondary);
 					} else {
-						secondaryModelMap.put("Others",
+						secondaryModelMap.put("Others", new PartnerSecondaryPlanModel(fofoId, "Others", (long) 0,
-								new PartnerSecondaryPlanModel(fofoId, "Others", 0, otherBrandSecondary));
+								otherBrandSecondary, authUser.getId()));
+					}
 					for (String brand : brands) {
 						if (!secondaryModelMap.containsKey(brand)) {
+							secondaryModelMap.put(brand,
+									new PartnerSecondaryPlanModel(fofoId, brand, (long) 0, (long) 0, authUser.getId()));
+						}
+					}
+					for (Entry<String, PartnerSecondaryPlanModel> secondaryModelEntry : secondaryModelMap.entrySet()) {
+						Integer authId = secondaryModelEntry.getValue().getAuthId();
+						if (authId != null && authId != authUser.getId()) {
-							secondaryModelMap.put(brand, new PartnerSecondaryPlanModel(fofoId, brand, 0, 0));
+							secondaryModelEntry.getValue().setAuthUser(authRepository.selectById(authId));
+							ptam.setSecondaryColor("red");
+						}
+					}
 					ptam.setPartnerSecondaryModel(secondaryModelMap);
 					ptam.setTotalSecondaryPlan(totalSecondaryPlan);
-					totalPartnerTargetSecondary += totalSecondaryPlan;
+					ptam.setTotalSecondaryAchievement(totalSecondaryAchivement);
+				} else {
+					for (String brand : brands) {
-					totalPartnerAchievementSecondary += totalSecondaryAchivement;
+						PartnerSecondaryPlanModel pspm = new PartnerSecondaryPlanModel();
+						pspm.setAchievementPlan((long) 0);
+						pspm.setTargetPlan((long) 0);
+						pspm.setBrand(brand);
+						pspm.setFofoId(fofoId);
+						secondaryModelMap.put(brand, pspm);
+					}
-					ptam.setTotalSecondaryAchivewment(totalSecondaryAchivement);
+					ptam.setPartnerSecondaryModel(secondaryModelMap);
+				}
 				ptams.add(ptam);
 			tm.setTotalPartnerTargetCollection(totalPartnerTargetCollection);
 			tm.setTotalPartnerTargetSecondary(totalPartnerTargetSecondary);
 			tm.setTotalPartnerSecondary(totalPartnerAchievementSecondary);
 			tm.setTotalPartnerCollection(totalPartnerAchievementCollection);
-			tm.setTargetAchievement(ptams);
+			tm.setTargetAchievement(ptams.stream()
+					.sorted(Comparator.comparing(PartnerTargetAchievementModel::getShortInvestment).reversed())
+					.collect(Collectors.toList()));
+		}
 		return responseSender.ok(tm);
 	@ApiImplicitParams({
 			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
 	public ResponseEntity<?> createPartnerTarget(HttpServletRequest request,
 			@RequestBody PartnerTargetAchievementModel ptam) throws ProfitMandiBusinessException {
-		AuthUser authUser = authRepository.selectByGmailId("ankit.bhatia@shop2020.in");
+		AuthUser authUser = authRepository.selectByGmailId(ptam.getCreatedBy());
-		PartnerCollectionPlan pcp = partnerCollectionPlanRepository.selectByLocalDate(LocalDate.now(),
+		PartnerCollectionPlan partnerCollectionPlan = partnerCollectionPlanRepository.selectByLocalDate(LocalDate.now(),
-				ptam.getFofoId());
+				ptam.getFofoId(), true);
-		LOGGER.info("pcp" + pcp);
+		LOGGER.info("pcp" + partnerCollectionPlan);
-		if (pcp == null) {
+		if (partnerCollectionPlan == null) {
 			if (ptam.getCollectionTarget() > 0) {
-				PartnerCollectionPlan partnerCollectionPlan = new PartnerCollectionPlan();
+				partnerCollectionPlan = new PartnerCollectionPlan();
+				partnerCollectionPlan.setCreateTimestamp(LocalDateTime.now());
 				partnerCollectionPlan.setAuthId(authUser.getId());
 				partnerCollectionPlan.setFofoId(ptam.getFofoId());
+				partnerCollectionPlan.setActive(true);
 				partnerCollectionPlan.setCollectionPlan(ptam.getCollectionTarget());
-				partnerCollectionPlan.setCreateTimestamp(LocalDateTime.now());
 				partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
 				partnerCollectionPlanRepository.persist(partnerCollectionPlan);
+			}
+		} else {
+			if (partnerCollectionPlan.getCollectionPlan() != ptam.getCollectionTarget()) {
+				float totalCollectionPlan = partnerCollectionPlan.getCollectionPlan() + 10000;
+				if (authUser.getId() == partnerCollectionPlan.getAuthId()) {
+					if (ptam.getCollectionTarget() >= totalCollectionPlan) {
+						partnerCollectionPlan.setCollectionPlan(ptam.getCollectionTarget());
+						partnerCollectionPlan.setActive(true);
+						partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
+					} else {
+						throw new ProfitMandiBusinessException("collection target", "",
+								"collection target should be more than " + totalCollectionPlan);
+					}
+				} else {
+					if (ptam.getCollectionTarget() >= totalCollectionPlan) {
+						partnerCollectionPlan.setActive(false);
+						partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
+						partnerCollectionPlan = new PartnerCollectionPlan();
+						partnerCollectionPlan.setCreateTimestamp(LocalDateTime.now());
+						partnerCollectionPlan.setAuthId(authUser.getId());
+						partnerCollectionPlan.setFofoId(ptam.getFofoId());
+						partnerCollectionPlan.setActive(true);
+						partnerCollectionPlan.setCollectionPlan(ptam.getCollectionTarget());
+						partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
+						partnerCollectionPlanRepository.persist(partnerCollectionPlan);
+					} else {
+						throw new ProfitMandiBusinessException("collection target", "",
+								"collection target should be more than " + totalCollectionPlan);
+					}
+				}
+			}
+		}
 		for (Entry<String, PartnerSecondaryPlanModel> pspm : ptam.getPartnerSecondaryModel().entrySet()) {
-			if (pspm.getValue().getTargetPlan() > 0) {
-				PartnerSecondaryPlanModel plan = pspm.getValue();
+			PartnerSecondaryPlanModel plan = pspm.getValue();
-				PartnerSecondaryPlan psp = partnerSecondaryPlanRepository.selectByLocalDateBrand(plan.getBrand(),
+			PartnerSecondaryPlan psp = partnerSecondaryPlanRepository.selectByLocalDateBrand(plan.getBrand(),
-						LocalDate.now(), ptam.getFofoId());
+					LocalDate.now(), ptam.getFofoId(), true);
-				LOGGER.info("psp" + psp);
+			LOGGER.info("psp" + psp);
-				if (psp == null)
+			if (psp == null) {
+				if (plan.getTargetPlan() > 0) {
 					psp = new PartnerSecondaryPlan();
-				psp.setAuthId(authUser.getId());
+					psp.setAuthId(authUser.getId());
-				psp.setBrand(pspm.getKey());
+					psp.setBrand(pspm.getKey());
-				psp.setFofoId(pspm.getValue().getFofoId());
+					psp.setFofoId(pspm.getValue().getFofoId());
-				psp.setSecondaryPlan(pspm.getValue().getTargetPlan());
+					psp.setSecondaryPlan(pspm.getValue().getTargetPlan());
-				psp.setCreateTimestamp(LocalDateTime.now());
+					psp.setCreateTimestamp(LocalDateTime.now());
-				psp.setUpdatedTimestamp(LocalDateTime.now());
+					psp.setUpdatedTimestamp(LocalDateTime.now());
+					psp.setActive(true);
-				partnerSecondaryPlanRepository.persist(psp);
+					partnerSecondaryPlanRepository.persist(psp);
+				}
+			} else {
+				if (plan.getTargetPlan() != psp.getSecondaryPlan()) {
+					float totalSecondaryPlan = psp.getSecondaryPlan() + 10000;
+					if (authUser.getId() == plan.getAuthId()) {
+						if (plan.getTargetPlan() >= totalSecondaryPlan) {
+							psp.setSecondaryPlan(pspm.getValue().getTargetPlan());
+							psp.setUpdatedTimestamp(LocalDateTime.now());
+							psp.setActive(true);
+						} else {
+							throw new ProfitMandiBusinessException("secondary target", "",
+									"secondary target should be more than " + totalSecondaryPlan);
+						}
+					} else {
+						if (plan.getTargetPlan() >= totalSecondaryPlan) {
+							psp.setUpdatedTimestamp(LocalDateTime.now());
+							psp.setActive(false);
+							psp = new PartnerSecondaryPlan();
+							psp.setAuthId(authUser.getId());
+							psp.setBrand(pspm.getKey());
+							psp.setFofoId(pspm.getValue().getFofoId());
+							psp.setSecondaryPlan(pspm.getValue().getTargetPlan());
+							psp.setCreateTimestamp(LocalDateTime.now());
+							psp.setUpdatedTimestamp(LocalDateTime.now());
+							psp.setActive(true);
+							partnerSecondaryPlanRepository.persist(psp);
+						} else {
+							throw new ProfitMandiBusinessException("secondary target", "",
+									"secondary target should be more than " + totalSecondaryPlan);
+						}
+					}
+				}
+			}
+		}
 		return responseSender.ok(true);
+	}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/LeadController.java – Rev 30078 → 30087