Subversion Repositories SmartDukaan

Rev

Rev 33022 | Rev 33074 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 33022 Rev 33041
Line 100... Line 100...
100 
        ticket.setUpdateTimestamp(LocalDateTime.now());
 100 
        ticket.setUpdateTimestamp(LocalDateTime.now());
101 
        ticket.setHappyCode(getRandomString());
 101 
        ticket.setHappyCode(getRandomString());
102 
        ticketRepository.persist(ticket);
 102 
        ticketRepository.persist(ticket);
103 
        this.addActivity(ticket, this.createActivity(type, message, createdByAuthId));
 103 
        this.addActivity(ticket, this.createActivity(type, message, createdByAuthId));
104 
        ticket.setFirstActivityId(ticket.getLastActivityId());
 104 
        ticket.setFirstActivityId(ticket.getLastActivityId());
105 
        if(createdByAuthId != 0){
 105 
        if (createdByAuthId != 0) {
106 
            int l2AuthUser = this.getAuthUserId(categoryId,EscalationType.L2,fofoId);
 106 
            int l2AuthUser = this.getAuthUserId(categoryId, EscalationType.L2, fofoId);
107 
            this.updateTicket(categoryId, subcategoryId, ticket, l2AuthUser, EscalationType.L2);
 107 
            this.updateTicket(categoryId, subcategoryId, ticket, l2AuthUser, EscalationType.L2);
108 
        }else{
 108 
        } else {
109 
            this.assignTicket(ticket);
 109 
            this.assignTicket(ticket);
110 
        }
 110 
        }
111 
 
 111 
 
112 
    }
 112 
    }
113 
 
 113 
 
Line 122... Line 122...
122 
        ticket.setHappyCode(getRandomString());
 122 
        ticket.setHappyCode(getRandomString());
123 
        ticketRepository.persist(ticket);
 123 
        ticketRepository.persist(ticket);
124 
        this.addActivity(ticket, this.createActivity(type, message, createdByAuthId));
 124 
        this.addActivity(ticket, this.createActivity(type, message, createdByAuthId));
125 
        this.addMediaActivity(ticket, this.createMediaActivity(selectedRecording));
 125 
        this.addMediaActivity(ticket, this.createMediaActivity(selectedRecording));
126 
        ticket.setFirstActivityId(ticket.getLastActivityId());
 126 
        ticket.setFirstActivityId(ticket.getLastActivityId());
127 
        if(createdByAuthId != 0){
 127 
        if (createdByAuthId != 0) {
128 
            int l2AuthUser = this.getAuthUserId(categoryId,EscalationType.L2,fofoId);
 128 
            int l2AuthUser = this.getAuthUserId(categoryId, EscalationType.L2, fofoId);
129 
            this.updateTicket(categoryId, subcategoryId, ticket, l2AuthUser, EscalationType.L2);
 129 
            this.updateTicket(categoryId, subcategoryId, ticket, l2AuthUser, EscalationType.L2);
130 
        }else{
 130 
        } else {
131 
            this.assignTicket(ticket);
 131 
            this.assignTicket(ticket);
132 
        }
 132 
        }
133 
    }
 133 
    }
134 
 
 134 
 
135 
    public TicketActivityMedia createMediaActivity(ActivityMediaModel selectedRecording) {
 135 
    public TicketActivityMedia createMediaActivity(ActivityMediaModel selectedRecording) {
136 
        TicketActivityMedia activity = new TicketActivityMedia();
 136 
        TicketActivityMedia activity = new TicketActivityMedia();
137 
        activity.setMobile(selectedRecording.getMobile());
 137 
        activity.setMobile(selectedRecording.getMobile());
138 
        // add a prefix endpoint of mediaUrl
 138 
        // add a prefix endpoint of mediaUrl
139 
        String customValue = "https://ccs1.smartpingcc.io/v2/recording/direct/71287091";
 139 
        String customValue = "https://ccs1.smartpingcc.io/v2/recording/direct/71287091";
140 
        activity.setMediaUrl(customValue+ selectedRecording.getMediaUrl());
 140 
        activity.setMediaUrl(customValue + selectedRecording.getMediaUrl());
141 
        activity.setDurationInSec(selectedRecording.getDurationInSec());
 141 
        activity.setDurationInSec(selectedRecording.getDurationInSec());
142 
        activity.setCallTime(selectedRecording.getCallConnectTime());
 142 
        activity.setCallTime(selectedRecording.getCallConnectTime());
143 
        activity.setCreatedBy(0);
 143 
        activity.setCreatedBy(0);
144 
        activity.setCreateTimestamp(LocalDateTime.now());
 144 
        activity.setCreateTimestamp(LocalDateTime.now());
145 
        activityMediaRepository.persist(activity);
 145 
        activityMediaRepository.persist(activity);
Line 161... Line 161...
161 
        ticket.setUpdateTimestamp(LocalDateTime.now());
 161 
        ticket.setUpdateTimestamp(LocalDateTime.now());
162 
        ticket.setHappyCode(getRandomString());
 162 
        ticket.setHappyCode(getRandomString());
163 
        ticketRepository.persist(ticket);
 163 
        ticketRepository.persist(ticket);
164 
        this.addActivity(ticket, this.createActivity(type, String.valueOf(remark), authId));
 164 
        this.addActivity(ticket, this.createActivity(type, String.valueOf(remark), authId));
165 
        ticket.setFirstActivityId(ticket.getLastActivityId());
 165 
        ticket.setFirstActivityId(ticket.getLastActivityId());
166 
        this.assignTicketByAuthId(ticket, authId,EscalationType.L2);
 166 
        this.assignTicketByAuthId(ticket, authId, EscalationType.L2);
167 
 
 167 
 
168 
    }
 168 
    }
169 
 
 169 
 
170 
 
 170 
 
171 
    @Override
 171 
    @Override
Line 853... Line 853...
853 
        return authuserEsclationTypeMap;
 853 
        return authuserEsclationTypeMap;
854 
    }
 854 
    }
855 
 
 855 
 
856 
    @Override
 856 
    @Override
857 
    public List<AuthUser> getAuthUserIdByPartnerId(int fofoId) {
 857 
    public List<AuthUser> getAuthUserIdByPartnerId(int fofoId) {
- 
 
 858 
        return this.getAuthUserIdByPartnerId(fofoId, EscalationType.escalations.toArray(new EscalationType[0]));
- 
 
 859 
    }
- 
 
 860 
 
- 
 
 861 
    @Override
- 
 
 862 
    public List<AuthUser> getAuthUserIdByPartnerId(int fofoId, EscalationType... escalationTypes) {
858 
        List<AuthUser> authUsers = new ArrayList<>();
 863 
        List<AuthUser> authUsers = new ArrayList<>();
859 
        List<Integer> regionIds = partnerRegionRepository.selectByfofoId(fofoId).stream().map(x -> x.getRegionId()).collect(Collectors.toList());
 864 
        List<Integer> regionIds = partnerRegionRepository.selectByfofoId(fofoId).stream().map(x -> x.getRegionId()).collect(Collectors.toList());
860 
 
 865 
 
861 
        regionIds.add(5);// All partners Id;
 866 
        regionIds.add(5);// All partners Id;
862 
        List<Integer> fofoIds = new ArrayList<>();
 867 
        List<Integer> fofoIds = new ArrayList<>();
Line 865... Line 870...
865 
 
 870 
 
866 
        LOGGER.info("fofoIds" + fofoIds);
 871 
        LOGGER.info("fofoIds" + fofoIds);
867 
        List<Integer> partnerPositionIds = partnerPositionRepository.selectByRegionIdAndPartnerId(regionIds, fofoIds).stream().map(x -> x.getPositionId()).collect(Collectors.toList());
 872 
        List<Integer> partnerPositionIds = partnerPositionRepository.selectByRegionIdAndPartnerId(regionIds, fofoIds).stream().map(x -> x.getPositionId()).collect(Collectors.toList());
868 
 
 873 
 
869 
        LOGGER.info("partnerPositionIds" + partnerPositionIds);
 874 
        LOGGER.info("partnerPositionIds" + partnerPositionIds);
- 
 
 875 
        List<Integer> allowedTicketCategoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_RBM);
870 
 
 876 
 
871 
        for (Integer partnerPostionId : partnerPositionIds) {
 - 
 
872 
            Position position = positionRepository.selectByIdAndCategoryId(partnerPostionId, ProfitMandiConstants.TICKET_CATEGORY_SALES);
 - 
 
873 
            LOGGER.info("position" + position);
 - 
 
874 
            if (position != null) {
 - 
 
875 
 
 - 
 
876 
                AuthUser authUser = authRepository.selectById(position.getAuthUserId());
 - 
 
877 
                LOGGER.info("authUser" + authUser);
 - 
 
878 
                authUsers.add(authUser);
 - 
 
879 
            }
 - 
 
880 
 
 877 
 
881 
            Position rbmPosition = positionRepository.selectByIdAndCategoryId(partnerPostionId, ProfitMandiConstants.TICKET_CATEGORY_RBM);
 878 
        List<Position> escalationBasedPositions = positionRepository.selectAll(partnerPositionIds).stream().filter(x -> allowedTicketCategoryIds.contains(x.getCategoryId()) &&
882 
            if (rbmPosition != null) {
 879 
                Arrays.stream(escalationTypes)
- 
 
 880 
                        .anyMatch(y -> y.equals(x.getEscalationType()))).collect(Collectors.toList());
883 
 
 881 
 
884 
                AuthUser authUser = authRepository.selectById(rbmPosition.getAuthUserId());
 882 
        List<Integer> authUserIds = escalationBasedPositions.stream().map(x -> x.getAuthUserId()).collect(Collectors.toList());
885 
                LOGGER.info("authUser" + authUser);
 - 
 
886 
                authUsers.add(authUser);
 - 
 
887 
            }
 - 
 
888 
 
 883 
 
889 
        }
 884 
        return authRepository.selectAllAuthUserByIds(authUserIds);
890 
 
 885 
 
891 
        return authUsers;
 - 
 
892 
    }
 886 
    }
893 
 
 887 
 
894 
    @Override
 888 
    @Override
895 
    public List<AuthUser> getAuthUserIds(int categoryId, List<EscalationType> escalationType) {
 889 
    public List<AuthUser> getAuthUserIds(int categoryId, List<EscalationType> escalationType) {
896 
 
 890