Uphrh 7903 mobile otp

Created by: shishirsuman092

src/main/java/org/upsmf/grievance/controller/TicketController.java

@@ -13,8 +13,10 @@ import org.upsmf.grievance.exception.CustomException;
 import org.upsmf.grievance.exception.TicketException;
 import org.upsmf.grievance.exception.UserException;
 import org.upsmf.grievance.model.Ticket;
+import org.upsmf.grievance.model.TicketStatistics;
 import org.upsmf.grievance.model.reponse.Response;
 import org.upsmf.grievance.service.AttachmentService;
+import org.upsmf.grievance.service.DashboardService;
 import org.upsmf.grievance.service.TicketService;
 import org.upsmf.grievance.util.ErrorCode;
 
@@ -29,6 +31,9 @@ public class TicketController {
     @Autowired
     private AttachmentService attachmentService;
 
+    @Autowired
+    private DashboardService dashboardService;
+
     @PostMapping("/save")
     public ResponseEntity<Response> save(@RequestBody TicketRequest ticketRequest) {
         Ticket responseTicket = null;
@@ -72,4 +77,15 @@ public class TicketController {
             return ResponseEntity.internalServerError().body(e.getLocalizedMessage());
         }
     }
+
+    @PostMapping("/statistic")
+    public ResponseEntity upload(@RequestBody Long userId) {
+        try {
+            TicketStatistics ticketStatisticsByUser = dashboardService.getTicketStatisticsByUser(userId);
+            Response response = new Response(HttpStatus.OK.value(), ticketStatisticsByUser);
+            return new ResponseEntity<Response>(response, HttpStatus.OK);
+        } catch (Exception e) {
+            return ResponseEntity.internalServerError().body(e.getLocalizedMessage());
+        }
+    }
 }

src/main/java/org/upsmf/grievance/model/TicketStatistics.java

+package org.upsmf.grievance.model;
+
+import lombok.*;
+
+@Getter
+@Setter
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+@ToString
+public class TicketStatistics {
+
+    Long escalatedToMeCount;
+    Long nudgedTicketCount;
+    Long notAssignedTicketCount;
+    Long priorityTicketCount;
+    Long pendingTicketCount;
+    Long resolvedTicketCount;
+    Long junkTicketCount;
+}

src/main/java/org/upsmf/grievance/service/impl/DashboardServiceImpl.java

@@ -18,6 +18,7 @@ import org.upsmf.grievance.dto.SearchDateRange;
 import org.upsmf.grievance.dto.SearchRequest;
 import org.upsmf.grievance.enums.TicketPriority;
 import org.upsmf.grievance.enums.TicketStatus;
+import org.upsmf.grievance.model.TicketStatistics;
 import org.upsmf.grievance.model.es.Feedback;
 import org.upsmf.grievance.model.es.Ticket;
 import org.upsmf.grievance.service.DashboardService;
@@ -627,4 +628,62 @@ public class DashboardServiceImpl implements DashboardService {
                 break;
         }
     }
+
+    /**
+     * Method to give ticket statistical data for logged in user
+     * @param userId
+     * @return
+     */
+    @Override
+    public TicketStatistics getTicketStatisticsByUser(Long userId) {
+        // validate payload
+        Long escalatedToMeCount = null;
+        Long nudgedTicketCount = null;
+        Long notAssignedTicketCount = null;
+        Long priorityTicketCount = null;
+        if(userId == null || userId <= 0) {
+            log.info("creating response for Administrative role");
+            // create Filter Payload for Escalated to me
+            escalatedToMeCount = createAndExecuteFilterPayload(null, "OPEN", false, "MEDIUM");
+            // create filter payload for Nudged
+            nudgedTicketCount = createAndExecuteFilterPayload(null, "OPEN", false, "HIGH");
+            // create filter payload for Not Assigned
+            notAssignedTicketCount = createAndExecuteFilterPayload(-1l, "OPEN", false, "LOW");
+        }
+        if(userId > 0) {
+            // create filter for priority tab
+            priorityTicketCount = createAndExecuteFilterPayload(userId, "OPEN", false, "HIGH");
+        }
+        // create filter payload for pending
+        Long pendingTicketCount = createAndExecuteFilterPayload(userId, "OPEN", false, "LOW");
+        // create filter payload for resolved
+        Long resolvedTicketCount = createAndExecuteFilterPayload(userId, "CLOSED", false, null);
+        // create filter payload for junk
+        Long junkTicketCount = createAndExecuteFilterPayload(userId, "INVALID", true, null);
+        // create response
+        TicketStatistics ticketStatistics = TicketStatistics.builder().nudgedTicketCount(nudgedTicketCount)
+                .pendingTicketCount(pendingTicketCount)
+                .notAssignedTicketCount(notAssignedTicketCount)
+                .resolvedTicketCount(resolvedTicketCount)
+                .escalatedToMeCount(escalatedToMeCount)
+                .junkTicketCount(junkTicketCount)
+                .priorityTicketCount(priorityTicketCount)
+                .build();
+        return ticketStatistics;
+    }
+
+    private Long createAndExecuteFilterPayload(Long userId, String status, boolean isJunk, String ticketPriority) {
+        BoolQueryBuilder esQueryForTicketCount = createESQueryForTicketCount(userId, status, isJunk, ticketPriority);
+        return executeQueryForCount(esQueryForTicketCount);
+    }
+
+    private BoolQueryBuilder createESQueryForTicketCount(Long userId, String status, boolean isJunk, String ticketPriority) {
+        BoolQueryBuilder esQuery = QueryBuilders.boolQuery();
+        // looping to add filter params in the main query
+        esQuery.must(QueryBuilders.matchQuery("assigned_to_id", userId));
+        esQuery.must(QueryBuilders.matchQuery("status", status));
+        esQuery.must(QueryBuilders.matchQuery("priority", ticketPriority));
+        esQuery.must(QueryBuilders.matchQuery("is_junk", isJunk));
+        return esQuery;
+    }
 }

src/main/java/org/upsmf/grievance/service/DashboardService.java

 package org.upsmf.grievance.service;
 
 import org.upsmf.grievance.dto.SearchRequest;
+import org.upsmf.grievance.model.TicketStatistics;
 import org.upsmf.grievance.model.es.Feedback;
 
 import java.util.List;
@@ -11,4 +12,6 @@ public interface DashboardService {
     public Map<String, Object> dashboardReport(SearchRequest searchRequest);
 
     public List<Feedback> getFeedbackByTicketId(String ticketId);
+
+    public TicketStatistics getTicketStatisticsByUser(Long userId);
 }