Subversion Repositories SmartDukaan

    @Override

    public int getAuthUserIdWithoutTicketAssignee(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 -> partnerPositionsIds.contains(x.getId())).collect(Collectors.toList());

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

        LOGGER.info("positionAssignee List {}", positionAssignee);

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

            LOGGER.info("Auth User List {}", authUsers);

            if (authUsers.size() > 0) {

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

                /*

                 * Random rand = new Random(); authUserId =

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

                 */

            }

        }

        return authUserId;

    }