Subversion Repositories SmartDukaan

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

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.auth.CollectionRemark;

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

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

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

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

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.hibernate.Session;

import org.hibernate.SessionFactory;

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 javax.persistence.TypedQuery;

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 #%s created by %s has been assigned to you. Regards\nSmartdukaan";

    private static final String ESCALATED_TICKET = "Dear %s, Ticket #%s #%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

    TicketActivityMediaRepository activityMediaRepository;

    @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 PartnerPositionRepository partnerPositionRepository;

    @Autowired

    private FofoStoreRepository fofoStoreRepository;

    @Autowired

    private SessionFactory sessionFactory;

    @Override

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

        this.createTicket(fofoId, categoryId, subcategoryId, message, 0);

    }

    @Override

    public void createTicket(int fofoId, int categoryId, int subcategoryId, String message, int createdByAuthId) 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, createdByAuthId));

        ticket.setFirstActivityId(ticket.getLastActivityId());

        if (createdByAuthId != 0) {

            int l2AuthUser = this.getAuthUserId(categoryId, EscalationType.L2, fofoId);

            this.updateTicket(categoryId, subcategoryId, ticket, l2AuthUser, EscalationType.L2);

        } else {

            this.assignTicket(ticket);

        }

    }

    @Override

    public void createTicketWithMedia(int fofoId, int categoryId, int subcategoryId, String message, int createdByAuthId, ActivityMediaModel selectedRecording) 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, createdByAuthId));

        this.addMediaActivity(ticket, this.createMediaActivity(selectedRecording));

        ticket.setFirstActivityId(ticket.getLastActivityId());

        if (createdByAuthId != 0) {

            int l2AuthUser = this.getAuthUserId(categoryId, EscalationType.L2, fofoId);

            this.updateTicket(categoryId, subcategoryId, ticket, l2AuthUser, EscalationType.L2);

        } else {

            this.assignTicket(ticket);

        }

    }

    @Override

    public TicketActivityMedia createMediaActivity(ActivityMediaModel selectedRecording) {

        TicketActivityMedia activity = new TicketActivityMedia();

        activity.setMobile(selectedRecording.getMobile());

        // add a prefix endpoint of mediaUrl

       // String customValue = "https://ccs1.smartpingcc.io/v2/recording/direct/71287091";

        activity.setMediaUrl(selectedRecording.getMediaUrl());

        activity.setDurationInSec(selectedRecording.getDurationInSec());

        activity.setCallTime(selectedRecording.getCallConnectTime());

        activity.setCreatedBy(0);

        activity.setCreateTimestamp(LocalDateTime.now());

        activityMediaRepository.persist(activity);

        return activity;

    }

    @Override

    public void addMediaActivity(Ticket ticket, TicketActivityMedia activity) {

        activity.setActivityId(ticket.getLastActivityId());

    }

    @Override

    public void createTicketRemarkEscalation(int fofoId, int authId, int categoryId, int subcategoryId, String message, CollectionRemark remark) 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, String.valueOf(remark), authId));

        ticket.setFirstActivityId(ticket.getLastActivityId());

        this.assignTicketByAuthId(ticket, authId, EscalationType.L2);

    }

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

        List<Activity> activities = activityRepository.selectAll(ticket.getId());

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

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

        }

    }

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

        this.updateTicket(categoryId,subCategoryId,ticket,authUserId,escalationType,null);

    }

    @Override

    public void updateTicket(int categoryId, int subCategoryId, Ticket ticket, int authUserId, EscalationType escalationType, ActivityMediaModel recording) 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);

            if(recording != null){

                this.addMediaActivity(ticket, this.createMediaActivity(recording));

            }

        }

        if (authUserId > 0) {

            this.assignTicketByAuthId(ticket, authUserId, escalationType);

        } else {

            ticket.setAssignmentId(0);

            this.assignTicket(ticket);

        }

    }

    private void assignTicketByAuthId(Ticket ticket, int authUserId, EscalationType escalationType) throws ProfitMandiBusinessException {

        AuthUser authUser = authRepository.selectById(authUserId);

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

        int managerAuthId = authUser.getManagerId();

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

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

        int authUserL2 = this.getAuthUserId(ticketCategory.getId(), EscalationType.L2, ticket.getFofoId());

        int authUserL3 = this.getAuthUserId(ticketCategory.getId(), EscalationType.L3, ticket.getFofoId());

        int authUserL4 = this.getAuthUserId(ticketCategory.getId(), EscalationType.L4, ticket.getFofoId());

        int authUserL5 = this.getAuthUserId(ticketCategory.getId(), EscalationType.L5, ticket.getFofoId());

        if (escalationType.equals(EscalationType.L1)) {

            ticket.setL1AuthUser(authUserId);

            ticket.setL2AuthUser(authUserL2);

            ticket.setL3AuthUser(authUserL3);

            ticket.setL4AuthUser(authUserL4);

            ticket.setL5AuthUser(authUserL5);

        } else if (escalationType.equals(EscalationType.L2)) {

            ticket.setL2AuthUser(authUserId);

            ticket.setL3AuthUser(authUserL3);

            ticket.setL4AuthUser(authUserL4);

            ticket.setL5AuthUser(authUserL5);

        }

        if (escalationType.equals(EscalationType.L3)) {

            ticket.setL3AuthUser(authUserId);

            ticket.setL4AuthUser(authUserL4);

            ticket.setL5AuthUser(authUserL5);

        }

        if (escalationType.equals(EscalationType.L4)) {

            ticket.setL4AuthUser(authUserId);

            ticket.setL5AuthUser(authUserL5);

        }

        if (escalationType.equals(EscalationType.L5)) {

            ticket.setL5AuthUser(authUserId);

        }

        TicketAssigned ticketAssignedNew = new TicketAssigned();

        ticketAssignedNew.setTicketId(ticket.getId());

        ticketAssignedNew.setAssineeId(authUserId);

        ticketAssignedNew.setEscalationType(escalationType);

        ticketAssignedNew.setManagerId(managerAuthId);

        ticketAssignedNew.setCreateTimestamp(LocalDateTime.now());

        ticketAssignedRepository.persist(ticketAssignedNew);

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

        AuthUser authUserManager = null;

        // Dont send cc mail if both are same

        if (managerAuthId != authUserId) {

            authUserManager = authRepository.selectById(managerAuthId);

        }

        ticket.setAssignmentId(ticketAssignedNew.getId());

        List<Activity> activities = activityRepository.selectAll(ticket.getId());

        this.sendAssignedTicketMail(authUser, Arrays.asList(authUserManager), ticket, false, activities);

        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 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) throws ProfitMandiBusinessException {

        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 = partnerPositionRepository.selectByRegionIdAndPartnerId(regionIds, Arrays.asList(0, fofoId)).stream().map(x -> x.getPositionId()).collect(Collectors.toList());

        List<Position> positionAssignee = positions.stream().filter(x -> x.isTicketAssignee() && partnerPositionsIds.contains(x.getId())).collect(Collectors.toList());

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

        if (positionAssignee.size() > 0) {

            List<AuthUser> authUsers = authRepository.selectAllAuthUserByIds(

                    positionAssignee.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<Integer> subCategoryIds) {

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

        subCategoryIdAndSubCategoryMap = ticketSubCategoryRepository.selectByIds(subCategoryIds).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));

        return subCategoryIdAndSubCategoryMap;

    }

    @Override

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

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

        Collection<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.getTicketSubCategoryMap().values();

        return new ArrayList<>(ticketSubCategories.stream().map(x -> x.getTicketCategory()).collect(Collectors.toSet()));

    }

    @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, List<Activity> activities) 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(), activities.get(0).getMessage(), 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) throws ProfitMandiBusinessException {

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

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

        for (Position position : positions) {

            List<Integer> fofoIds = partnerPositionRepository.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) throws ProfitMandiBusinessException {

        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() throws ProfitMandiBusinessException {

        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() throws ProfitMandiBusinessException {

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

        categoryPositions.addAll(positionRepository.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT));

        categoryPositions.addAll(positionRepository.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_TRAINING));

        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, boolean activeOnly) throws ProfitMandiBusinessException {

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

        Set<Integer> activeFofoIds;

        if (activeOnly) {

            activeFofoIds = fofoStoreRepository.selectActiveStores().stream().map(x -> x.getId()).collect(Collectors.toSet());

        } else {

            activeFofoIds = fofoStoreRepository.selectAll().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 Map<Integer, List<Integer>> authUserpartnerIdMap(int authId, int categoryId) {

        Session session = sessionFactory.getCurrentSession();

        final TypedQuery<AuthUserPartnerMapModel> typedQuerySimilar = session

                .createNamedQuery("Position.Auth_User_Partner_Maping", AuthUserPartnerMapModel.class);

        typedQuerySimilar.setParameter("authId", authId);

        typedQuerySimilar.setParameter("categoryId", categoryId);

        List<AuthUserPartnerMapModel> authUserPartnerMapModels = typedQuerySimilar.getResultList();

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

        Map<Integer, List<Integer>> authUserpartnerIdMap = authUserPartnerMapModels.stream()

                .collect(Collectors.groupingBy(

                        AuthUserPartnerMapModel::getAuthId,

                        Collectors.mapping(AuthUserPartnerMapModel::getFofoId, Collectors.toList())

                ));

        LOGGER.info("partnerusermap {}", authUserpartnerIdMap);

        return authUserpartnerIdMap;

    }

    @Override

    public List<String> getAuthUserByPartnerId(int fofoId) throws ProfitMandiBusinessException {

        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 = partnerPositionRepository.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) throws ProfitMandiBusinessException {

        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 = partnerPositionRepository.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() throws ProfitMandiBusinessException {

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

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

        List<Position> categoryPositions = positionRepository.selectAllPosition();

        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() throws ProfitMandiBusinessException {

        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) throws ProfitMandiBusinessException {

        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 = partnerPositionRepository.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) throws ProfitMandiBusinessException {

        return this.getAuthUserIdByPartnerId(fofoId, EscalationType.escalations.toArray(new EscalationType[0]));

    }

    @Override

    public List<AuthUser> getAuthUserIdByPartnerId(int fofoId, EscalationType... escalationTypes) throws ProfitMandiBusinessException {

        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 = partnerPositionRepository.selectByRegionIdAndPartnerId(regionIds, fofoIds).stream().map(x -> x.getPositionId()).collect(Collectors.toList());

        //LOGGER.info("partnerPositionIds" + partnerPositionIds);

        List<Integer> allowedTicketCategoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_RBM);

        List<Position> escalationBasedPositions = positionRepository.selectAll(partnerPositionIds).stream().filter(x -> allowedTicketCategoryIds.contains(x.getCategoryId()) &&

                Arrays.stream(escalationTypes)

                        .anyMatch(y -> y.equals(x.getEscalationType()))).collect(Collectors.toList());

        List<Integer> authUserIds = escalationBasedPositions.stream().map(x -> x.getAuthUserId()).collect(Collectors.toList());

        return authRepository.selectAllAuthUserByIds(authUserIds);

    }

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