Subversion Repositories SmartDukaan

package com.spice.profitmandi.dao.repository.cs;

import com.itextpdf.text.pdf.PdfStructTreeController.returnType;

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.util.Utils;

import com.spice.profitmandi.dao.entity.auth.AuthUser;

import com.spice.profitmandi.dao.entity.cs.*;

import com.spice.profitmandi.dao.entity.fofo.ActivityType;

import com.spice.profitmandi.dao.entity.fofo.FofoStore;

import com.spice.profitmandi.dao.enumuration.cs.EscalationType;

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

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

import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;

import com.spice.profitmandi.service.user.RetailerService;

import org.apache.commons.collections4.map.HashedMap;

import org.apache.commons.lang.RandomStringUtils;

import org.apache.commons.lang.StringUtils;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.cache.annotation.Cacheable;

import org.springframework.mail.javamail.JavaMailSender;

import org.springframework.stereotype.Component;

import java.time.LocalDateTime;

import java.util.*;

import java.util.stream.Collectors;

@Component

public class CsServiceImpl implements CsService {

	private static final int ALL_PARTNERS_REGION = 5;

	private static final Logger LOGGER = LogManager.getLogger(CsServiceImpl.class);

	private static final String ASSIGNED_TICKET = "Dear %s, New ticket #%s created by %s has been assigned to you. Regards\nSmartdukaan";

	private static final String ESCALATED_TICKET = "Dear %s, Ticket #%s created by %s has been escalated to you. Regards\nSmartdukaan";

	private static final String CATEGORY_CHANGED_TICKET = "Dear team, Category of Ticket #%s created by %s has been changed to %s. Regards\nSmartdukaan";

	private static final String ASSINMENT_SUBJECT = "Assignment Ticket";

	@Autowired

	TicketRepository ticketRepository;

	@Autowired

	JavaMailSender mailSender;

	@Autowired

	TicketCategoryRepository ticketCategoryRepository;

	@Autowired

	TicketSubCategoryRepository ticketSubCategoryRepository;

	@Autowired

	ActivityRepository activityRepository;

	@Autowired

	PartnerRegionRepository partnerRegionRepository;

	@Autowired

	private PositionRepository positionRepository;

	@Autowired

	private AuthRepository authRepository;

	@Autowired

	private RetailerService retailerService;

	@Autowired

	private RegionRepository regionRepository;

	@Autowired

	private TicketAssignedRepository ticketAssignedRepository;

	@Autowired

	private PartnersPositionRepository partnersPositionRepository;

	@Autowired

	private FofoStoreRepository fofoStoreRepository;

	@Override

	public void createTicket(int fofoId, int categoryId, int subcategoryId, String message)

			throws ProfitMandiBusinessException {

		ActivityType type = ActivityType.OPENED;

		Ticket ticket = new Ticket();

		ticket.setSubCategoryId(subcategoryId);

		ticket.setFofoId(fofoId);

		ticket.setCreateTimestamp(LocalDateTime.now());

		ticket.setUpdateTimestamp(LocalDateTime.now());

		ticket.setHappyCode(getRandomString());

		ticketRepository.persist(ticket);

		this.addActivity(ticket, this.createActivity(type, message, 0));

		this.assignTicket(ticket);

	}

	@Override

	public void assignTicket(Ticket ticket) throws ProfitMandiBusinessException {

		TicketAssigned ticketAssigned = null;

		EscalationType newEscalationType = EscalationType.L1;

		if (ticket.getAssignmentId() > 0) {

			ticketAssigned = ticketAssignedRepository.selectById(ticket.getAssignmentId());

			newEscalationType = ticketAssigned.getEscalationType().next();

			if (newEscalationType == null || newEscalationType.equals(EscalationType.Final)) {

				LOGGER.info("Cant escalate further");

				return;

			}

		} else {

			ticket.setL1AuthUser(0);

			ticket.setL2AuthUser(0);

			ticket.setL3AuthUser(0);

			ticket.setL4AuthUser(0);

			ticket.setL5AuthUser(0);

		}

		ticket.setUpdateTimestamp(LocalDateTime.now());

		TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());

		TicketCategory ticketCategory = ticketCategoryRepository.selectById(ticketSubCategory.getCategoryId());

		Map<Integer, EscalationType> escalationUserMap = new HashedMap<>();

		Set<Integer> assigneeUserIds = new LinkedHashSet<>();

		EscalationType escalationTypeNext = newEscalationType;

		do {

			int assigneeUserId = this.getAuthUserId(ticketCategory.getId(), escalationTypeNext, ticket.getFofoId());

			if (assigneeUserId == 0) {

				escalationTypeNext = escalationTypeNext.next();

				LOGGER.info("Escalation type next {}", escalationTypeNext);

				continue;

			}

			assigneeUserIds.add(assigneeUserId);

			escalationUserMap.put(assigneeUserId, escalationTypeNext);

			switch (escalationTypeNext) {

			case L1:

				ticket.setL1AuthUser(assigneeUserId);

				break;

			case L2:

				ticket.setL2AuthUser(assigneeUserId);

				break;

			case L3:

				ticket.setL3AuthUser(assigneeUserId);

				break;

			case L4:

				ticket.setL4AuthUser(assigneeUserId);

				break;

			case L5:

				ticket.setL5AuthUser(assigneeUserId);

				break;

			default:

				break;

			}

			escalationTypeNext = escalationTypeNext.next();

			// LOGGER.info("Escalation type next {}", escalationTypeNext);

		} while (!escalationTypeNext.equals(EscalationType.Final));

		int assigneeAuthId = assigneeUserIds.stream().findFirst().orElse(0);

		int managerAuthId = 0;

		EscalationType assigneeEscalationType = null;

		if (assigneeAuthId == 0) {

			assigneeAuthId = ProfitMandiConstants.FINAL_AUTH_ID;

			assigneeEscalationType = EscalationType.Final;

			managerAuthId = ProfitMandiConstants.FINAL_AUTH_ID;

		} else {

			assigneeEscalationType = escalationUserMap.get(assigneeAuthId);

			managerAuthId = assigneeUserIds.stream().skip(1).findFirst().orElse(0);

			if (managerAuthId == 0) {

				managerAuthId = ProfitMandiConstants.FINAL_AUTH_ID;

			}

		}

		TicketAssigned ticketAssignedNew = new TicketAssigned();

		ticketAssignedNew.setTicketId(ticket.getId());

		ticketAssignedNew.setAssineeId(assigneeAuthId);

		ticketAssignedNew.setEscalationType(assigneeEscalationType);

		ticketAssignedNew.setManagerId(managerAuthId);

		ticketAssignedNew.setCreateTimestamp(LocalDateTime.now());

		ticketAssignedRepository.persist(ticketAssignedNew);

		LOGGER.info(ticketAssigned);

		AuthUser authUser = authRepository.selectById(ticketAssignedNew.getAssineeId());

		AuthUser authUserManager = null;

		// Dont send cc mail if both are same

		if (managerAuthId != assigneeAuthId) {

			authUserManager = authRepository.selectById(managerAuthId);

		}

		ticket.setAssignmentId(ticketAssignedNew.getId());

		this.sendAssignedTicketMail(authUser, Arrays.asList(authUserManager), ticket, ticketAssigned != null);

		if (!ticketAssignedNew.getEscalationType().equals(EscalationType.L1)) {

			this.addActivity(ticket, this.createActivity(ActivityType.ESCALATED,

					"Ticket ecalated and assigned to " + authUser.getName(), 0));

		} else {

			this.addActivity(ticket,

					this.createActivity(ActivityType.ASSIGNED, "Ticket assigned to " + authUser.getName(), 0));

		}

	}

	@Override

	public void updateTicket(int categoryId, int subCategoryId, Ticket ticket) throws ProfitMandiBusinessException {

		TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.getTicketSubCategoryMap().get(subCategoryId);

		if (ticketSubCategory == null) {

			throw new ProfitMandiBusinessException("Could not find subCategoryId " + subCategoryId + "- " + categoryId,

					"Problem", "Problem");

		}

		String storeName = retailerService.getAllFofoRetailers().get(ticket.getFofoId()).getBusinessName();

		List<TicketAssigned> oldTicketAssignedList = ticketAssignedRepository

				.selectByTicketIds(Arrays.asList(ticket.getId()));

		for (TicketAssigned oldTicketAssigned : oldTicketAssignedList) {

			ticketAssignedRepository.delete(oldTicketAssigned);

		}

		if (ticket.getSubCategoryId() != ticketSubCategory.getId()) {

			ticket.setSubCategoryId(ticketSubCategory.getId());

			List<Integer> oldAssignedAuthUserIds = oldTicketAssignedList.stream().map(x -> x.getAssineeId())

					.collect(Collectors.toList());

			List<String> oldAssignedEmailIds = authRepository.selectAllAuthUserByIds(oldAssignedAuthUserIds).stream()

					.map(x -> x.getEmailId()).collect(Collectors.toList());

			String mailTo = oldAssignedEmailIds.remove(0);

			String message = String.format(CATEGORY_CHANGED_TICKET, ticket.getId(), storeName,

					ticketSubCategory.getTicketCategory().getName() + " - " + ticketSubCategory.getName());

			try {

				Utils.sendMailWithAttachments(mailSender, mailTo, oldAssignedEmailIds.toArray(new String[0]),

						"Ticket Category/Subcategory Changed", message, null);

			} catch (Exception e) {

				LOGGER.info("Could not send mail for ticket {}", ticket.toString());

			}

		}

		Activity categoryChangedActivity = this.createActivity(ActivityType.CATEGORY_CHANGED, "Category changed to "

				+ ticketSubCategory.getTicketCategory().getName() + " - " + ticketSubCategory.getName(), 0);

		this.addActivity(ticket, categoryChangedActivity);

		ticket.setAssignmentId(0);

		this.assignTicket(ticket);

	}

	@Override

	public Activity createActivity(ActivityType activityType, String message, int createdBy) {

		Activity activity = new Activity();

		activity.setMessage(message);

		activity.setCreatedBy(createdBy);

		activity.setType(activityType);

		activity.setCreateTimestamp(LocalDateTime.now());

		activityRepository.persist(activity);

		return activity;

	}

	@Override

	public int getAuthUserId(int categoryId, EscalationType escalationType, int fofoId) {

		int authUserId = 0;

		List<Position> positions = positionRepository.selectPositionbyCategoryIdAndEscalationType(categoryId,

				escalationType);

		List<Integer> regionIds = partnerRegionRepository.selectByfofoId(fofoId).stream().map(x -> x.getRegionId())

				.collect(Collectors.toList());

		// Add all Partner regions id

		regionIds.add(ALL_PARTNERS_REGION);

		LOGGER.info("Escalation Type {}, Region Ids {}", escalationType, regionIds);

		List<Integer> partnerPositionsIds = partnersPositionRepository

				.selectByRegionIdAndPartnerId(regionIds, Arrays.asList(0, fofoId)).stream().map(x -> x.getPositionId())

				.collect(Collectors.toList());

		positions = positions.stream().filter(x -> partnerPositionsIds.contains(x.getId()))

				.collect(Collectors.toList());

		LOGGER.info("User List List {}", positions.stream().map(x -> x.getAuthUserId()).collect(Collectors.toList()));

		if (positions.size() > 0) {

			List<AuthUser> authUsers = authRepository.selectAllAuthUserByIds(

					positions.stream().map(x -> x.getAuthUserId()).collect(Collectors.toList()));

			authUsers = authUsers.stream().filter(x -> x.isActive()).collect(Collectors.toList());

			if (authUsers.size() > 0) {

				authUserId = authUsers.get(0).getId();

				/*

				 * Random rand = new Random(); authUserId =

				 * authUsers.get(rand.nextInt(authUsers.size())).getId();

				 */

			}

		}

		return authUserId;

	}

	@Override

	public void addActivity(Ticket ticket, Activity activity) {

		activity.setTicketId(ticket.getId());

		ticket.setLastActivity(activity.getType());

		ticket.setLastActivityId(activity.getId());

	}

	private String getRandomString() {

		int length = 4;

		boolean useLetters = false;

		boolean useNumbers = true;

		String generatedString = RandomStringUtils.random(length, useLetters, useNumbers);

		return generatedString;

	}

	@Override

	public void addPartnerToRegion(int regionId, List<Integer> fofoIds) {

		for (int fofoId : fofoIds) {

			PartnerRegion partnerRegion = new PartnerRegion();

			partnerRegion.setFofoId(fofoId);

			partnerRegion.setRegionId(regionId);

			partnerRegionRepository.persist(partnerRegion);

		}

	}

	@Override

	public Map<Integer, AuthUser> getAuthUserIdAndAuthUserMap(List<TicketAssigned> ticketAssigneds) {

		Map<Integer, AuthUser> authUserIdAndAuthUserMap = new HashMap<>();

		for (TicketAssigned ticketAssigned : ticketAssigneds) {

			AuthUser authUser = authRepository.selectById(ticketAssigned.getAssineeId());

			authUserIdAndAuthUserMap.put(ticketAssigned.getTicketId(), authUser);

		}

		return authUserIdAndAuthUserMap;

	}

	@Override

	public Map<Integer, AuthUser> getTicketIdAndAuthUserMapUsingTickets(List<Ticket> tickets) {

		Map<Integer, AuthUser> authUserIdAndAuthUserMap = new HashMap<>();

		for (Ticket ticket : tickets) {

			AuthUser authUser = authRepository.selectById(ticket.getL1AuthUser());

			authUserIdAndAuthUserMap.put(ticket.getId(), authUser);

		}

		return authUserIdAndAuthUserMap;

	}

	@Override

	public Map<Integer, TicketSubCategory> getSubCategoryIdAndSubCategoryMap(List<Ticket> tickets) {

		Map<Integer, TicketSubCategory> subCategoryIdAndSubCategoryMap = new HashMap<>();

		if (tickets != null) {

			for (Ticket ticket : tickets) {

				TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());

				subCategoryIdAndSubCategoryMap.put(ticket.getSubCategoryId(), ticketSubCategory);

			}

		}

		return subCategoryIdAndSubCategoryMap;

	}

	@Override

	public Map<Integer, CustomRetailer> getPartnerByFofoIds(List<Ticket> tickets) {

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

		LOGGER.info(tickets);

		if (tickets == null) {

			return null;

		}

		for (Ticket ticket : tickets) {

			fofoIds.add(ticket.getFofoId());

		}

		Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();

		Map<Integer, CustomRetailer> fofoIdsAndCustomRetailer = fofoIds.stream().distinct()

				.map(x -> customRetailerMap.get(x)).filter(x -> x != null).collect(Collectors.toList()).stream()

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

		return fofoIdsAndCustomRetailer;

	}

	@Override

	public List<TicketCategory> getAllTicketCategotyFromSubCategory() {

		List<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.selectAll();

		HashSet<Integer> categoryIds = new HashSet<>();

		for (TicketSubCategory ticketSubcategory : ticketSubCategories) {

			categoryIds.add(ticketSubcategory.getCategoryId());

		}

		List<TicketCategory> ticketcategories = ticketCategoryRepository.selectAll(new ArrayList<>(categoryIds));

		return ticketcategories;

	}

	@Override

	public Map<Integer, AuthUser> getAuthUserIdAndAuthUserMapUsingPositions(List<Position> positions) {

		Map<Integer, AuthUser> authUserIdAndAuthUserMap = new HashMap<>();

		for (Position position : positions) {

			AuthUser authUser = authRepository.selectById(position.getAuthUserId());

			authUserIdAndAuthUserMap.put(position.getAuthUserId(), authUser);

		}

		return authUserIdAndAuthUserMap;

	}

	@Override

	public Map<Integer, TicketCategory> getCategoryIdAndCategoryUsingPositions(List<Position> positions) {

		Map<Integer, TicketCategory> categoryIdAndCategoryMap = new HashMap<>();

		for (Position position : positions) {

			TicketCategory ticketCategory = ticketCategoryRepository.selectById(position.getCategoryId());

			categoryIdAndCategoryMap.put(position.getCategoryId(), ticketCategory);

		}

		return categoryIdAndCategoryMap;

	}

	@Override

	public Map<Integer, Region> getRegionIdAndRegionMap(List<Position> positions) {

		Map<Integer, Region> regionIdAndRegionMap = new HashMap<>();

		for (Position position : positions) {

			Region region = regionRepository.selectById(position.getRegionId());

			regionIdAndRegionMap.put(position.getRegionId(), region);

		}

		return regionIdAndRegionMap;

	}

	private void sendAssignedTicketMail(AuthUser authUserTo, List<AuthUser> authUsersCc, Ticket ticket,

			boolean isEscalated) throws ProfitMandiBusinessException {

		try {

			String[] ccTo = authUsersCc.stream().filter(x -> x != null).map(x -> x.getEmailId()).toArray(String[]::new);

			String messageFormat = null;

			if (isEscalated) {

				messageFormat = ESCALATED_TICKET;

			} else {

				messageFormat = ASSIGNED_TICKET;

			}

			String message = String.format(messageFormat, authUserTo.getName(), ticket.getId(),

					retailerService.getFofoRetailer(ticket.getFofoId()).getBusinessName());

			Utils.sendMailWithAttachments(mailSender, authUserTo.getEmailId(), ccTo, ASSINMENT_SUBJECT, message, null);

		} catch (Exception e) {

			e.printStackTrace();

			throw new ProfitMandiBusinessException("Ticket Assingment", authUserTo.getEmailId(),

					"Could not send ticket assignment mail");

		}

	}

	@Override

	public Map<Integer, List<CustomRetailer>> getPositionCustomRetailerMap(List<Position> positions) {

		Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();

		Map<Integer, List<CustomRetailer>> positionRetailerMap = new HashMap<>();

		for (Position position : positions) {

			List<Integer> fofoIds = partnersPositionRepository.selectByPositionId(position.getId()).stream()

					.map(x -> x.getFofoId()).collect(Collectors.toList());

			LOGGER.info("fofoIds - {}", fofoIds);

			if (!fofoIds.isEmpty()) {

				if (fofoIds.contains(0)) {

					fofoIds = partnerRegionRepository.selectByRegionId(position.getRegionId()).stream()

							.map(x -> x.getFofoId()).collect(Collectors.toList());

					if (fofoIds.contains(0)) {

						fofoIds = new ArrayList<>(customRetailerMap.keySet());

					}

				}

				LOGGER.info("fofoIds - {}", fofoIds);

				positionRetailerMap.put(position.getId(), fofoIds.stream().map(x -> customRetailerMap.get(x))

						.filter(x -> x != null).collect(Collectors.toList()));

			}

		}

		return positionRetailerMap;

	}

	@Override

	public Map<Integer, List<CustomRetailer>> getRegionPartners(List<Position> positions) {

		Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();

		Map<Integer, List<CustomRetailer>> positionIdAndpartnerRegionMap = new HashedMap<>();

		for (Position position : positions) {

			List<Integer> fofoIds = partnerRegionRepository.selectByRegionId(position.getRegionId()).stream()

					.map(x -> x.getFofoId()).collect(Collectors.toList());

			if (!fofoIds.isEmpty()) {

				if (fofoIds.contains(0)) {

					fofoIds = fofoStoreRepository.selectAll().stream().map(x -> x.getId()).collect(Collectors.toList());

				}

				Map<Integer, CustomRetailer> fofoRetailers = fofoIds.stream().map(x -> customRetailerMap.get(x))

						.filter(x -> x != null).collect(Collectors.toList()).stream()

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

				positionIdAndpartnerRegionMap.put(position.getRegionId(),

						new ArrayList<CustomRetailer>(fofoRetailers.values()));

			}

		}

		return positionIdAndpartnerRegionMap;

	}

	@Override

	@Cacheable(value = "authUserEmailMapping", cacheManager = "thirtyMinsTimeOutCacheManager")

	public Map<String, Set<String>> getAuthUserPartnerEmailMapping() {

		Map<String, Set<String>> storeGuyMap = new HashMap<>();

		Set<Integer> activeFofoIds = fofoStoreRepository.selectActiveStores().stream().map(x -> x.getId())

				.collect(Collectors.toSet());

		List<Position> categoryPositions = positionRepository

				.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES);

		categoryPositions

				.addAll(positionRepository.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM));

		Map<Integer, Position> positionsMap = categoryPositions.stream()

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

		Map<Integer, List<CustomRetailer>> positonPartnerMap = this.getPositionCustomRetailerMap(categoryPositions);

		for (Map.Entry<Integer, List<CustomRetailer>> positionPartnerEntry : positonPartnerMap.entrySet()) {

			int authUserId = positionsMap.get(positionPartnerEntry.getKey()).getAuthUserId();

			Set<String> partnerEmails = positionPartnerEntry.getValue().stream()

					.filter(x -> activeFofoIds.contains(x.getPartnerId())).map(x -> x.getEmail())

					.collect(Collectors.toSet());

			AuthUser authUser = authRepository.selectById(authUserId);

			if (authUser.isActive()) {

				if (!storeGuyMap.containsKey(authUser.getEmailId())) {

					storeGuyMap.put(authUser.getEmailId(), partnerEmails);

				} else {

					storeGuyMap.get(authUser.getEmailId()).addAll(partnerEmails);

				}

			}

		}

		return storeGuyMap;

	}

	@Override

	@Cacheable(value = "authUserEmailPartnerIdMapping", cacheManager = "thirtyMinsTimeOutCacheManager")

	public Map<String, Set<Integer>> getAuthUserPartnerIdMapping() {

		Map<String, Set<Integer>> storeGuyMap = new HashMap<>();

		Set<Integer> activeFofoIds = fofoStoreRepository.selectActiveStores().stream().map(x -> x.getId())

				.collect(Collectors.toSet());

		List<Position> categoryPositions = positionRepository

				.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES);

		categoryPositions

				.addAll(positionRepository.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM));

		Map<Integer, Position> positionsMap = categoryPositions.stream()

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

		Map<Integer, List<CustomRetailer>> positonPartnerMap = this.getPositionCustomRetailerMap(categoryPositions);

		for (Map.Entry<Integer, List<CustomRetailer>> positionPartnerEntry : positonPartnerMap.entrySet()) {

			int authUserId = positionsMap.get(positionPartnerEntry.getKey()).getAuthUserId();

			Set<Integer> partnerIds = positionPartnerEntry.getValue().stream()

					.filter(x -> activeFofoIds.contains(x.getPartnerId())).map(x -> x.getPartnerId())

					.collect(Collectors.toSet());

			AuthUser authUser = authRepository.selectById(authUserId);

			if (authUser.isActive()) {

				if (!storeGuyMap.containsKey(authUser.getEmailId())) {

					storeGuyMap.put(authUser.getEmailId(), partnerIds);

				} else {

					storeGuyMap.get(authUser.getEmailId()).addAll(partnerIds);

				}

			}

		}

		return storeGuyMap;

	}

	@Override

	@Cacheable(value = "authUserPartnerEmailPartnerIdMapping", cacheManager = "thirtyMinsTimeOutCacheManager")

	public Map<String, Set<Integer>> getAuthUserPartnerIdMappingByCategoryIds(List<Integer> categoryIds) {

		Map<String, Set<Integer>> authUserPartnerMap = new HashMap<>();

		Set<Integer> activeFofoIds = fofoStoreRepository.selectActiveStores().stream().map(x -> x.getId())

				.collect(Collectors.toSet());

		List<Position> categoryPositions = positionRepository.selectPositionByCategoryIds(categoryIds);

		Map<Integer, Position> positionsMap = categoryPositions.stream()

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

		Map<Integer, List<CustomRetailer>> positonPartnerMap = this.getPositionCustomRetailerMap(categoryPositions);

		for (Map.Entry<Integer, List<CustomRetailer>> positionPartnerEntry : positonPartnerMap.entrySet()) {

			int authUserId = positionsMap.get(positionPartnerEntry.getKey()).getAuthUserId();

			Set<Integer> partnerIds = positionPartnerEntry.getValue().stream()

					.filter(x -> activeFofoIds.contains(x.getPartnerId())).map(x -> x.getPartnerId())

					.collect(Collectors.toSet());

			AuthUser authUser = authRepository.selectById(authUserId);

			if (authUser.isActive()) {

				if (!authUserPartnerMap.containsKey(authUser.getEmailId())) {

					authUserPartnerMap.put(authUser.getEmailId(), partnerIds);

				} else {

					authUserPartnerMap.get(authUser.getEmailId()).addAll(partnerIds);

				}

			}

		}

		return authUserPartnerMap;

	}

	@Override

	public List<String> getAuthUserByPartnerId(int fofoId) {

		List<String> emails = new ArrayList<>();

		List<Integer> regionIds = partnerRegionRepository.selectByfofoId(fofoId).stream().map(x -> x.getRegionId())

				.collect(Collectors.toList());

		regionIds.add(5);// All partners Id;

		List<Integer> partnerPositionIds = partnersPositionRepository

				.selectByRegionIdAndPartnerId(regionIds, Arrays.asList(fofoId, 0)).stream().map(x -> x.getPositionId())

				.collect(Collectors.toList());

		LOGGER.info("partnerPositionIds" + partnerPositionIds);

		List<Position> positions = positionRepository.selectAll(partnerPositionIds);

		positions = positions.stream().filter(x -> (x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_SALES

				|| x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_RBM)).collect(Collectors.toList());

		if (!positions.isEmpty()) {

			for (Position partnerPostionId : positions) {

				AuthUser authUser = authRepository.selectById(partnerPostionId.getAuthUserId());

				LOGGER.info("authUser" + authUser);

				emails.add(authUser.getEmailId());

			}

		}

		return emails;

	}

	@Override

	public Map<EscalationType, String> getAuthUserAndEsclationTypeByPartnerId(int fofoId) {

		List<String> emails = new ArrayList<>();

		Map<EscalationType, String> emailEsclationTypeMap = new HashMap<>();

		List<Integer> regionIds = partnerRegionRepository.selectByfofoId(fofoId).stream().map(x -> x.getRegionId())

				.collect(Collectors.toList());

		regionIds.add(5);// All partners Id;

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

		fofoIds.add(fofoId);

		fofoIds.add(0);

		LOGGER.info("fofoIds" + fofoIds);

		List<Integer> partnerPositionIds = partnersPositionRepository.selectByRegionIdAndPartnerId(regionIds, fofoIds)

				.stream().map(x -> x.getPositionId()).collect(Collectors.toList());

		LOGGER.info("partnerPositionIds" + partnerPositionIds);

		for (Integer partnerPostionId : partnerPositionIds) {

			Position position = positionRepository.selectByIdAndCategoryId(partnerPostionId,

					ProfitMandiConstants.TICKET_CATEGORY_SALES);

			LOGGER.info("position" + position);

			if (position != null) {

				AuthUser authUser = authRepository.selectById(position.getAuthUserId());

				LOGGER.info("authUser" + authUser);

				emailEsclationTypeMap.put(position.getEscalationType(), authUser.getEmailId());

			}

		}

		LOGGER.info("emailEsclationTypeMap" + emailEsclationTypeMap);

		return emailEsclationTypeMap;

	}

	@Override

	@Cacheable(value = "authUserIdPartnerIdMapping", cacheManager = "thirtyMinsTimeOutCacheManager")

	public Map<Integer, List<Integer>> getAuthUserIdPartnerIdMapping() {

		Map<Integer, List<Integer>> storeGuyMap = new HashMap<>();

		Set<Integer> activeFofoIds = fofoStoreRepository.selectActiveStores().stream().map(x -> x.getId())

				.collect(Collectors.toSet());

		List<Position> categoryPositions = positionRepository

				.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES);

		categoryPositions

				.addAll(positionRepository.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM));

		categoryPositions

				.addAll(positionRepository.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_CRM));

		Map<Integer, Position> positionsMap = categoryPositions.stream()

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

		Map<Integer, List<CustomRetailer>> positonPartnerMap = this.getPositionCustomRetailerMap(categoryPositions);

		for (Map.Entry<Integer, List<CustomRetailer>> positionPartnerEntry : positonPartnerMap.entrySet()) {

			int authUserId = positionsMap.get(positionPartnerEntry.getKey()).getAuthUserId();

			List<Integer> partnerIds = positionPartnerEntry.getValue().stream()

					.filter(x -> activeFofoIds.contains(x.getPartnerId())).map(x -> x.getPartnerId())

					.collect(Collectors.toList());

			AuthUser authUser = authRepository.selectById(authUserId);

			if (authUser != null && authUser.isActive()) {

				if (!storeGuyMap.containsKey(authUserId)) {

					storeGuyMap.put(authUserId, partnerIds);

				} else {

					storeGuyMap.get(authUserId).addAll(partnerIds);

				}

			}

		}

		storeGuyMap.keySet().stream().forEach(x -> {

			List<Integer> fofoIds = storeGuyMap.get(x);

			storeGuyMap.put(x, fofoIds.stream().distinct().collect(Collectors.toList()));

		});

		return storeGuyMap;

	}

	@Override

	@Cacheable(value = "L1L2Mapping", cacheManager = "thirtyMinsTimeOutCacheManager")

	public Map<Integer, List<Integer>> getL2L1Mapping() {

		List<Position> l1SalesPositions = positionRepository.selectPositionbyCategoryIdAndEscalationType(

				ProfitMandiConstants.TICKET_CATEGORY_SALES, EscalationType.L1);

		List<Position> l2SalesPositions = positionRepository.selectPositionbyCategoryIdAndEscalationType(

				ProfitMandiConstants.TICKET_CATEGORY_SALES, EscalationType.L2);

		LOGGER.info("position" + l1SalesPositions);

		Map<Integer, List<Integer>> authUserPartnerListMap = this.getAuthUserIdPartnerIdMapping();

		LOGGER.info("map" + authUserPartnerListMap);

		Map<Integer, List<Integer>> l2l1ListMap = new HashMap<>();

		for (Position l2SalePosition : l2SalesPositions) {

			int l2AuthUserId = l2SalePosition.getAuthUserId();

			if (authUserPartnerListMap.containsKey(l2SalePosition.getAuthUserId())) {

				List<Integer> mappedL1AuthUsers = new ArrayList<>();

				l2l1ListMap.put(l2AuthUserId, mappedL1AuthUsers);

				List<Integer> l2FofoIds = authUserPartnerListMap.get(l2AuthUserId);

				for (Position l1SalePosition : l1SalesPositions) {

					int l1AuthUserId = l1SalePosition.getAuthUserId();

					if (authUserPartnerListMap.containsKey(l1AuthUserId)) {

						List<Integer> l1FofoIds = authUserPartnerListMap.get(l1SalePosition.getAuthUserId());

						if (l2FofoIds.containsAll(l1FofoIds)) {

							mappedL1AuthUsers.add(l1AuthUserId);

						}

					}

				}

			}

		}

		return l2l1ListMap;

	}

	@Override

	public Map<Integer, List<AuthUser>> getAssignedAuthList(List<Ticket> tickets) {

		if (tickets.size() == 0) {

			return new HashMap<>();

		}

		List<TicketAssigned> ticketAssignedList = ticketAssignedRepository

				.selectByTicketIds(tickets.stream().map(x -> x.getId()).collect(Collectors.toList()));

		List<Integer> authUserIds = ticketAssignedList.stream().map(x -> x.getAssineeId()).distinct()

				.collect(Collectors.toList());

		Map<Integer, AuthUser> authUserMap = authRepository.selectAllAuthUserByIds(authUserIds).stream()

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

		return ticketAssignedList.stream().collect(Collectors.groupingBy(x -> x.getTicketId(),

				Collectors.mapping(x -> authUserMap.get(x.getAssineeId()), Collectors.toList())));

	}

	@Override

	public Map<EscalationType, AuthUser> getAuthUserAndEsclationByPartnerId(int fofoId) {

		Map<EscalationType, AuthUser> authuserEsclationTypeMap = new HashMap<>();

		List<Integer> regionIds = partnerRegionRepository.selectByfofoId(fofoId).stream().map(x -> x.getRegionId())

				.collect(Collectors.toList());

		regionIds.add(5);// All partners Id;

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

		fofoIds.add(fofoId);

		fofoIds.add(0);

		LOGGER.info("fofoIds" + fofoIds);

		List<Integer> partnerPositionIds = partnersPositionRepository.selectByRegionIdAndPartnerId(regionIds, fofoIds)

				.stream().map(x -> x.getPositionId()).collect(Collectors.toList());

		LOGGER.info("partnerPositionIds" + partnerPositionIds);

		for (Integer partnerPostionId : partnerPositionIds) {

			Position position = positionRepository.selectByIdAndCategoryId(partnerPostionId,

					ProfitMandiConstants.TICKET_CATEGORY_SALES);

			LOGGER.info("position" + position);

			if (position != null) {

				AuthUser authUser = authRepository.selectById(position.getAuthUserId());

				LOGGER.info("authUser" + authUser);

				authuserEsclationTypeMap.put(position.getEscalationType(), authUser);

			}

		}

		LOGGER.info("emailEsclationTypeMap" + authuserEsclationTypeMap);

		return authuserEsclationTypeMap;

	}

	@Override

	public List<AuthUser> getAuthUserIdByPartnerId(int fofoId) {

		List<AuthUser> authUsers = new ArrayList<>();

		List<Integer> regionIds = partnerRegionRepository.selectByfofoId(fofoId).stream().map(x -> x.getRegionId())

				.collect(Collectors.toList());

		regionIds.add(5);// All partners Id;

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

		fofoIds.add(fofoId);

		fofoIds.add(0);

		LOGGER.info("fofoIds" + fofoIds);

		List<Integer> partnerPositionIds = partnersPositionRepository.selectByRegionIdAndPartnerId(regionIds, fofoIds)

				.stream().map(x -> x.getPositionId()).collect(Collectors.toList());

		LOGGER.info("partnerPositionIds" + partnerPositionIds);

		for (Integer partnerPostionId : partnerPositionIds) {

			Position position = positionRepository.selectByIdAndCategoryId(partnerPostionId,

					ProfitMandiConstants.TICKET_CATEGORY_SALES);

			LOGGER.info("position" + position);

			if (position != null) {

				AuthUser authUser = authRepository.selectById(position.getAuthUserId());

				LOGGER.info("authUser" + authUser);

				authUsers.add(authUser);

			}

			Position rbmPosition = positionRepository.selectByIdAndCategoryId(partnerPostionId,

					ProfitMandiConstants.TICKET_CATEGORY_RBM);

			if (rbmPosition != null) {

				AuthUser authUser = authRepository.selectById(rbmPosition.getAuthUserId());

				LOGGER.info("authUser" + authUser);

				authUsers.add(authUser);

			}

		}

		return authUsers;

	}

	@Override

	public List<AuthUser> getAuthUserIds(int categoryId, List<EscalationType> escalationType) {

		List<Position> positions = positionRepository.selectPositionbyCategoryIdAndEscalationTypes(categoryId,

				escalationType);

		List<Integer> authIds = positions.stream().map(x -> x.getAuthUserId()).distinct().collect(Collectors.toList());

		LOGGER.info("authIds" + authIds);

		List<AuthUser> authUsers = authRepository.selectAllAuthUserByIds(authIds);

		LOGGER.info("authUsers" + authUsers);

		return authUsers;

	}

	@Override

	public List<AuthUser> getAuthUserByCategoryId(int categoryId, EscalationType escalationType) {

		List<Position> positions = positionRepository.selectPositionbyCategoryIdAndEscalationType(categoryId,

				escalationType);

		List<Integer> authIds = positions.stream().map(x -> x.getAuthUserId()).distinct().collect(Collectors.toList());

		LOGGER.info("authIds" + authIds);

		List<AuthUser> authUsers = new ArrayList<>();

		if (!authIds.isEmpty()) {

			authUsers = authRepository.selectAllAuthUserByIds(authIds);

		}

		LOGGER.info("authUsers" + authUsers);

		return authUsers;

	}

	@Override

	@Cacheable(value = "authUserByCategoryId", cacheManager = "thirtyMinsTimeOutCacheManager")

	public List<AuthUser> getAuthUserByCategoryId(int categoryId) {

		List<Position> positions = positionRepository.selectPositionByCategoryId(categoryId);

		List<Integer> authIds = positions.stream().map(x -> x.getAuthUserId()).distinct().collect(Collectors.toList());

		LOGGER.info("authIds" + authIds);

		List<AuthUser> authUsers = authRepository.selectAllAuthUserByIds(authIds).stream().filter(x -> x.getActive())

				.collect(Collectors.toList());

		LOGGER.info("authUsers" + authUsers);

		return authUsers;

	}

	private class SaleRoles {

		private List<String> l1;

		private List<String> l2;

		private List<String> l3;

		private List<String> l4;

		public SaleRoles() {

			l1 = new ArrayList<>();

			l2 = new ArrayList<>();

			l3 = new ArrayList<>();

			l4 = new ArrayList<>();

		}

		public List<String> getL1() {

			return l1;

		}

		public List<String> getL2() {

			return l2;

		}

		public List<String> getL3() {

			return l3;

		}

		public List<String> getL4() {

			return l4;

		}

		@Override

		public String toString() {

			return "SaleRoles [l1=" + l1 + ", l2=" + l2 + ", l3=" + l3 + ", l4=" + l4 + "]";

		}

	}

	@Override

	@Cacheable(value = "partnerSaleHeader", cacheManager = "oneDayCacheManager")

	public Map<Integer, FofoReportingModel> getPartnerIdSalesHeaders() {

		Map<String, SaleRoles> partnerEmailSalesMap = new HashMap<>();

		List<Position> positions = positionRepository

				.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES);

		Map<Integer, AuthUser> authUsersMap = authRepository.selectAllActiveUser().stream()

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

		Map<Integer, List<CustomRetailer>> positionIdRetailerMap = this.getPositionCustomRetailerMap(positions);

		for (Position position : positions) {

			List<CustomRetailer> crList = positionIdRetailerMap.get(position.getId());

			if (crList == null)

				continue;

			for (CustomRetailer cr : crList) {

				if (!partnerEmailSalesMap.containsKey(cr.getEmail())) {

					partnerEmailSalesMap.put(cr.getEmail(), new SaleRoles());

				}

				SaleRoles saleRoles = partnerEmailSalesMap.get(cr.getEmail());

				AuthUser authUser = authUsersMap.get(position.getAuthUserId());

				if (authUser == null) {

					continue;

				}

				String name = authUser.getFirstName() + " " + authUser.getLastName();

				if (position.getEscalationType().equals(EscalationType.L1)) {

					saleRoles.getL1().add(name);

				} else if (position.getEscalationType().equals(EscalationType.L2)) {

					saleRoles.getL2().add(name);

				}

			}

		}

		Set<CustomRetailer> allCrList = new HashSet<>();

		for (List<CustomRetailer> cr : positionIdRetailerMap.values()) {

			allCrList.addAll(cr);

		}

		Map<Integer, FofoStore> fofoStoresMap = fofoStoreRepository.selectActiveStores().stream()

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

		Map<Integer, FofoReportingModel> partnerIdSalesHeadersMap = new HashMap<>();

		for (CustomRetailer cr : allCrList) {

			FofoStore fofoStore = fofoStoresMap.get(cr.getPartnerId());

			if (fofoStore == null) {

				LOGGER.info("Could not find Store {} in active Store", cr.getBusinessName());

				continue;

			}

			String code = fofoStore.getCode();

			// String storeName = "SmartDukaan-" +

			// fofoStore.getCode().replaceAll("[a-zA-Z]", "");

			String businessName = cr.getBusinessName();

			try {

				String stateManager = StringUtils.join(partnerEmailSalesMap.get(cr.getEmail()).getL2(), ", ");

				String territoryManager = StringUtils.join(partnerEmailSalesMap.get(cr.getEmail()).getL1(), ", ");

				if (StringUtils.isEmpty(territoryManager)) {

					territoryManager = StringUtils.join(partnerEmailSalesMap.get(cr.getEmail()).getL2(), ", ");

				}

				FofoReportingModel reportingModel = new FofoReportingModel();

				reportingModel.setBusinessName(businessName);

				reportingModel.setCode(code);

				reportingModel.setFofoId(fofoStore.getId());

				reportingModel.setRegionalManager(stateManager);

				reportingModel.setTerritoryManager(territoryManager);

				partnerIdSalesHeadersMap.put(fofoStore.getId(), reportingModel);

			} catch (Exception e) {

				LOGGER.warn("Could not find partner with email - {}", cr.getEmail());

			}

		}

		return partnerIdSalesHeadersMap;

	}

	@Override

	public Set<Integer> getAuthFofoIds(String email) throws ProfitMandiBusinessException {

		List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_LOGISTICS,

				ProfitMandiConstants.TICKET_CATEGORY_FINANCIAL_SERVICES, ProfitMandiConstants.TICKET_CATEGORY_CATEGORY,

				ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES,

				ProfitMandiConstants.TICKET_CATEGORY_MARKETING, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS,

				ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT,

				ProfitMandiConstants.TICKET_CATEGORY_TECHNOLOGY);