Subversion Repositories SmartDukaan

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

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.model.ProfitMandiConstants;

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

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

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

import com.spice.profitmandi.service.AuthService;

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

import org.springframework.stereotype.Component;

import java.util.Arrays;

import java.util.List;

import java.util.Map;

import java.util.Set;

import java.util.stream.Collectors;

@Component

public class CsService1Impl implements CsService1 {

    @Autowired

    AuthService authService;

    @Autowired

    AuthRepository authRepository;

    @Autowired

    CsService csService;

    @Autowired

    PositionRepository positionRepository;

    private static 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_ABM,

            ProfitMandiConstants.TICKET_CATEGORY_MARKETING, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS,

            ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT, ProfitMandiConstants.TICKET_CATEGORY_STOCKS,

            ProfitMandiConstants.TICKET_CATEGORY_TECHNOLOGY, ProfitMandiConstants.TICKET_CATEGORY_TRAINING,ProfitMandiConstants.TICKET_CATEGORY_RECOVERY);

    @Override

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

        Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMappingByCategoryIds(categoryIds, active);

        Set<Integer> authfofoIds = storeGuyMap.get(email);

        if (authfofoIds == null) {

            AuthUser authUser = authRepository.selectByEmailOrMobile(email);

            if (authUser != null) {

                List<Position> positions1 = positionRepository.selectAllByAuthUserId(authUser.getId());

                if (positions1.stream().anyMatch(x -> x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_MASTER)) {

                    authfofoIds = csService.getPositionCustomRetailerMap(positions1).values().stream().flatMap(x -> x.stream())

                            .map(x -> x.getPartnerId()).collect(Collectors.toSet());

                }

            }

        }

        return authfofoIds;

    }

}