Subversion Repositories SmartDukaan

import java.util.Map.Entry;

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.model.PartnerCollectionPlanModel;

import com.spice.profitmandi.dao.model.PartnerSecondaryPlanModel;

import com.spice.profitmandi.dao.model.PartnerTargetAchievementModel;

import com.spice.profitmandi.dao.model.TargetModel;

import com.spice.profitmandi.dao.repository.auth.PartnerCollectionPlanRepository;

import com.spice.profitmandi.dao.repository.auth.PartnerSecondaryPlanRepository;

import com.spice.profitmandi.dao.repository.cs.PositionRepository;

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

import com.spice.profitmandi.dao.repository.transaction.OrderRepository;

import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;

			leads = leadRepository.selectLeadsScheduledBetweenDate(Arrays.asList(authUser.getId()),

	@Autowired

	private com.spice.profitmandi.service.transaction.TransactionService transactionService;

	@Autowired

	private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;

	@Autowired

	private OrderRepository orderRepository;

	@Autowired

	private PositionRepository positionRepository;

	@Autowired

	private UserWalletRepository userWalletRepository;

	@Autowired

	private PartnerCollectionPlanRepository partnerCollectionPlanRepository;

	@Autowired

	private PartnerSecondaryPlanRepository partnerSecondaryPlanRepository;

	@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 {

		AuthUser authUser = authRepository.selectByGmailId(gmailId);

		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();

		Set<Integer> fofoIds = storeGuyMap.get("ankit.bhatia@smartdukaan.com");

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

		List<PartnerTargetAchievementModel> ptams = new ArrayList<>();

		if (fofoIds.size() > 0 && fofoIds != null) {

			List<Integer> fofoIdList = new ArrayList<>(fofoIds);

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

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

			Map<Integer, PartnerCollectionPlanModel> collectionPlans = userWalletRepository

					.getPartnerWiseTargetCollections(fofoIdList, startDate).stream()

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

			LOGGER.info("collectionPlans {}", collectionPlans);

			Map<Integer, List<PartnerSecondaryPlanModel>> partnerSecondayPlans = orderRepository

					.selectPartnerSecondaryGroupByBrand(fofoIdList, startDate).stream()

					.collect(Collectors.groupingBy(x -> x.getFofoId()));

			LOGGER.info("partnerSecondayPlans {}", partnerSecondayPlans);

			for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailers.entrySet()) {

				int fofoId = customRetailerEntry.getKey();

				CustomRetailer customRetailer = customRetailerEntry.getValue();

				float totalSecondaryPlan = 0;

				float totalSecondaryAchivement = 0;

				PartnerTargetAchievementModel ptam = new PartnerTargetAchievementModel();

				ptam.setFofoId(fofoId);

				ptam.setBusinessName(customRetailer.getBusinessName());

				if (collectionPlans.get(fofoId) != null) {

					totalPartnerTargetCollection += collectionPlans.get(fofoId).getTargetPlan();

					totalPartnerAchievementCollection += collectionPlans.get(fofoId).getAchievementPlan();

					ptam.setCollectionTarget(collectionPlans.get(fofoId).getTargetPlan());

					ptam.setCollectionAchievement(collectionPlans.get(fofoId).getAchievementPlan());

				}

				PartnerSecondaryPlanModel otherPartnerSecondaryPlanModel = null;

				if (partnerSecondayPlans.get(fofoId) != null) {

					long otherBrandSecondary = 0;

					for (PartnerSecondaryPlanModel pspm : partnerSecondayPlans.get(fofoId)) {

						if (!brands.contains(pspm.getBrand())) {

							otherBrandSecondary += pspm.getAchievementPlan();

						} else {

							otherPartnerSecondaryPlanModel = pspm;

						}

						totalSecondaryPlan += pspm.getTargetPlan();

						totalSecondaryAchivement += pspm.getAchievementPlan();

					}

					if (otherPartnerSecondaryPlanModel != null) {

						otherPartnerSecondaryPlanModel.setAchievementPlan(otherBrandSecondary);

					}

					Map<String, PartnerSecondaryPlanModel> 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",

								new PartnerSecondaryPlanModel(fofoId, "Others", 0, otherBrandSecondary));

					}

					for (String brand : brands) {

						if (!secondaryModelMap.containsKey(brand)) {

							secondaryModelMap.put(brand, new PartnerSecondaryPlanModel(fofoId, brand, 0, 0));

						}

					}

					ptam.setPartnerSecondaryModel(secondaryModelMap);

					ptam.setTotalSecondaryPlan(totalSecondaryPlan);

					totalPartnerTargetSecondary += totalSecondaryPlan;

					totalPartnerAchievementSecondary += totalSecondaryAchivement;

					ptam.setTotalSecondaryAchivewment(totalSecondaryAchivement);

					ptams.add(ptam);

				}

			}

			tm.setTotalPartnerTargetCollection(totalPartnerTargetCollection);

			tm.setTotalPartnerTargetSecondary(totalPartnerTargetSecondary);

			tm.setTotalPartnerSecondary(totalPartnerAchievementSecondary);

			tm.setTotalPartnerCollection(totalPartnerAchievementCollection);

			tm.setTargetAchievement(ptams);

		}

		return responseSender.ok(tm);

	}

	@RequestMapping(value = "/target", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)

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

		PartnerCollectionPlan pcp = partnerCollectionPlanRepository.selectByLocalDate(LocalDate.now(),

				ptam.getFofoId());

		LOGGER.info("pcp" + pcp);

		if (pcp == null) {

			if (ptam.getCollectionTarget() > 0) {

				PartnerCollectionPlan partnerCollectionPlan = new PartnerCollectionPlan();

				partnerCollectionPlan.setAuthId(authUser.getId());

				partnerCollectionPlan.setFofoId(ptam.getFofoId());

				partnerCollectionPlan.setCollectionPlan(ptam.getCollectionTarget());

				partnerCollectionPlan.setCreateTimestamp(LocalDateTime.now());

				partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());

				partnerCollectionPlanRepository.persist(partnerCollectionPlan);

			}

		}

		for (Entry<String, PartnerSecondaryPlanModel> pspm : ptam.getPartnerSecondaryModel().entrySet()) {

			if (pspm.getValue().getTargetPlan() > 0) {

				PartnerSecondaryPlanModel plan = pspm.getValue();

				PartnerSecondaryPlan psp = partnerSecondaryPlanRepository.selectByLocalDateBrand(plan.getBrand(),

						LocalDate.now(), ptam.getFofoId());

				LOGGER.info("psp" + psp);

				if (psp == null)

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

				partnerSecondaryPlanRepository.persist(psp);

			}

		}

		return responseSender.ok(true);

	}