WebSVN – SmartDukaan – Diff – //trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/SupportController.java

 package com.spice.profitmandi.web.controller;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 import javax.mail.internet.InternetAddress;
 import javax.mail.internet.MimeMessage;
 import javax.servlet.http.HttpServletRequest;
 import com.spice.profitmandi.dao.entity.dtr.User;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.entity.dtr.Retailer;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
+import com.spice.profitmandi.dao.entity.cs.CallbackRequestReply;
+import com.spice.profitmandi.dao.repository.cs.CallbackRequestReplyRepository;
 import com.spice.profitmandi.dao.repository.cs.CallbackRequestRepository;
 import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserRepository;
+import com.spice.profitmandi.web.req.CallbackReplyRequest;
 import com.spice.profitmandi.web.req.CallbackRequest;
 import com.spice.profitmandi.web.req.ResolveCallbackRequest;
 import com.spice.profitmandi.web.res.AssignedRequestResponse;
+import com.spice.profitmandi.web.res.CallbackReplyResponse;
 import com.spice.profitmandi.web.res.CallbackRequestResponse;
 import com.spice.profitmandi.web.res.SupportTeamResponse;
 import com.spice.profitmandi.web.res.SupportTeamResponse.ContactDetail;
 import io.swagger.annotations.ApiImplicitParam;
     @Autowired
     private CallbackRequestRepository callbackRequestRepository;
     @Autowired
+    private CallbackRequestReplyRepository callbackRequestReplyRepository;
+    @Autowired
     private RetailerRepository retailerRepository;
     @Autowired
     private FofoStoreRepository fofoStoreRepository;
             int abmAuthUserId = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_SALES, EscalationType.L1, fofoId);
             if (abmAuthUserId > 0) {
                 AuthUser user = authRepository.selectById(abmAuthUserId);
                 if (user != null) {
                     l1Contacts.add(buildContact(user, "ASM", "#1a7a4c",
-                            "Sales support and regional queries", true, true, false, false));
+                            "Sales support and regional queries", true, true, false, true));
+                }
+            }
         } catch (Exception e) {
             LOGGER.warn("Could not fetch ABM for fofoId: {}", fofoId, e);
+        }
             int rbmManagerAuthUserId = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_RBM, EscalationType.L2, fofoId);
             if (rbmManagerAuthUserId > 0) {
                 AuthUser user = authRepository.selectById(rbmManagerAuthUserId);
                 if (user != null) {
                     l2Contacts.add(buildContact(user, "RBM MANAGER", "#7c3aed",
-                            "For escalated regional matters", false, false, true, true));
+                            "For escalated regional matters", true, true, false, true));
+                }
+            }
         } catch (Exception e) {
             LOGGER.warn("Could not fetch RBM Manager for fofoId: {}", fofoId, e);
+        }
             int bmAuthUserId = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_SALES, EscalationType.L2, fofoId);
             if (bmAuthUserId > 0) {
                 AuthUser user = authRepository.selectById(bmAuthUserId);
                 if (user != null) {
                     l2Contacts.add(buildContact(user, "BM", "#1e6091",
-                            "Handles: Orders, Stock, Schemes", true, false, false, true));
+                            "Handles: Orders, Stock, Schemes", true, true, false, true));
+                }
+            }
         } catch (Exception e) {
             LOGGER.warn("Could not fetch BM for fofoId: {}", fofoId, e);
+        }
-        // Affordability Operations = FINANCIAL_SERVICES category, L2
+        // Finance Partner Mapping Operations = FINANCIAL_SERVICES category, L2
         try {
             int affordAuthUserId = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_FINANCIAL_SERVICES, EscalationType.L2, fofoId);
             if (affordAuthUserId > 0) {
                 AuthUser user = authRepository.selectById(affordAuthUserId);
                 if (user != null) {
                     l2Contacts.add(buildContact(user, "Finance Partner Mapping", "#d97706",
                             "Credit, payment plans, and operations", false, false, true, false));
+                }
+            }
         } catch (Exception e) {
-            LOGGER.warn("Could not fetch Affordability Manager for fofoId: {}", fofoId, e);
+            LOGGER.warn("Could not fetch Finance Partner Mapping Manager for fofoId: {}", fofoId, e);
+        }
         // Branding Manager = DESIGN category, L1
         try {
             int brandingAuthUserId = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_DESIGN, EscalationType.L1, fofoId);
             res.setSubject(entity.getSubject());
             res.setMessage(entity.getMessage());
             res.setTiming(entity.getTiming());
             res.setTimingLabel("11-15".equals(entity.getTiming()) ? "11:00 AM - 3:00 PM" : "3:00 PM - 7:00 PM");
             res.setStatus(entity.getStatus());
+            res.setResolutionNotes(entity.getResolutionNotes());
+            res.setReplyCount(callbackRequestReplyRepository.countByCallbackRequestId(entity.getId()));
+            res.setUnread(entity.isUnread());
             if (entity.getCreateTimestamp() != null) {
                 res.setCreateTimestamp(entity.getCreateTimestamp().format(formatter));
+            }
             responseList.add(res);
+        }
         return responseSender.ok(responseList);
+    }
+    @RequestMapping(value = "/support/callback-requests/unread-count", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
+    @ApiOperation(value = "Get count of unread callback requests for the logged-in retailer")
+    public ResponseEntity<?> getUnreadCount(HttpServletRequest request) throws Throwable {
+        UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
+        int fofoId = userInfo.getRetailerId();
+        LOGGER.info("Getting unread callback request count for fofoId: {}", fofoId);
+        long count = callbackRequestRepository.countUnreadByFofoId(fofoId);
+        return responseSender.ok(count);
+    }
+    @RequestMapping(value = "/support/callback-requests/mark-read", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
+    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
+    @ApiOperation(value = "Mark all callback requests as read for the logged-in retailer")
+    public ResponseEntity<?> markRequestsAsRead(HttpServletRequest request) throws Throwable {
+        UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
+        int fofoId = userInfo.getRetailerId();
+        LOGGER.info("Marking all callback requests as read for fofoId: {}", fofoId);
+        callbackRequestRepository.markAllReadByFofoId(fofoId);
+        return responseSender.ok(true);
+    }
     @RequestMapping(value = "/support/assigned-requests", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
     @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
     @ApiOperation(value = "Get callback requests assigned to the logged-in internal user")
     public ResponseEntity<?> getAssignedRequests(HttpServletRequest request) throws Throwable {
         UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
             res.setMessage(entity.getMessage());
             res.setTiming(entity.getTiming());
             res.setTimingLabel("11-15".equals(entity.getTiming()) ? "11:00 AM - 3:00 PM" : "3:00 PM - 7:00 PM");
             res.setStatus(entity.getStatus());
             res.setResolutionNotes(entity.getResolutionNotes());
+            res.setReplyCount(callbackRequestReplyRepository.countByCallbackRequestId(entity.getId()));
             if (entity.getCreateTimestamp() != null) {
                 res.setCreateTimestamp(entity.getCreateTimestamp().format(formatter));
+            }
             if (entity.getUpdateTimestamp() != null) {
         LOGGER.info("Callback request id: {} resolved with status: {}", id, resolveRequest.getStatus());
         return responseSender.ok(true);
+    }
+    @RequestMapping(value = "/support/callback-requests/{id}/replies", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
+    @ApiOperation(value = "Get all replies for a callback request")
+    public ResponseEntity<?> getReplies(HttpServletRequest request, @PathVariable("id") int id) throws Throwable {
+        LOGGER.info("Getting replies for callback request id: {}", id);
+        List<CallbackRequestReply> replies = callbackRequestReplyRepository.selectAllByCallbackRequestId(id);
+        Collections.reverse(replies); // oldest first for chat order
+        List<CallbackReplyResponse> responseList = new ArrayList<>();
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("dd MMM yyyy, hh:mm a");
+        for (CallbackRequestReply reply : replies) {
+            CallbackReplyResponse res = new CallbackReplyResponse();
+            res.setId(reply.getId());
+            res.setMessage(reply.getMessage());
+            res.setSenderType(reply.getSenderType());
+            res.setSenderName(reply.getSenderName());
+            if (reply.getCreateTimestamp() != null) {
+                res.setCreateTimestamp(reply.getCreateTimestamp().format(formatter));
+            }
+            responseList.add(res);
+        }
+        return responseSender.ok(responseList);
+    }
+    @RequestMapping(value = "/support/callback-requests/{id}/reply", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
+    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
+    @ApiOperation(value = "Add a reply to a callback request")
+    public ResponseEntity<?> addReply(HttpServletRequest request, @PathVariable("id") int id,
+                                       @RequestBody CallbackReplyRequest replyRequest) throws Throwable {
+        UserInfo userInfo = (UserInfo) request.getAttribute("userInfo");
+        com.spice.profitmandi.dao.entity.cs.CallbackRequest callbackReq = callbackRequestRepository.selectById(id);
+        if (callbackReq == null) {
+            LOGGER.warn("Callback request not found for id: {}", id);
+            return responseSender.ok(false);
+        }
+        // Determine sender type: if userId matches the request creator, it's RETAILER; otherwise INTERNAL
+        String senderType = (userInfo.getUserId() == callbackReq.getUserId()) ? "RETAILER" : "INTERNAL";
+        User senderUser = userRepository.selectById(userInfo.getUserId());
+        String senderName = senderUser != null ? senderUser.getFirstName() : "Unknown";
+        LOGGER.info("Adding reply to callback request id: {} by userId: {} senderType: {}", id, userInfo.getUserId(), senderType);
+        CallbackRequestReply reply = new CallbackRequestReply();
+        reply.setCallbackRequestId(id);
+        reply.setMessage(replyRequest.getMessage());
+        reply.setSenderType(senderType);
+        reply.setSenderName(senderName);
+        reply.setSenderId(userInfo.getUserId());
+        reply.setCreateTimestamp(LocalDateTime.now());
+        callbackRequestReplyRepository.persist(reply);
+        // Update the parent request's updateTimestamp
+        callbackReq.setUpdateTimestamp(LocalDateTime.now());
+        // Mark as unread for the retailer when an internal user replies
+        if ("INTERNAL".equals(senderType)) {
+            callbackReq.setUnread(true);
+        }
+        callbackRequestRepository.persist(callbackReq);
+        LOGGER.info("Reply added with id: {} to callback request id: {}", reply.getId(), id);
+        return responseSender.ok(true);
+    }
     private ContactDetail buildContact(AuthUser authUser, String badge, String badgeColor,
                                        String description, boolean showCall, boolean showMessage,
                                        boolean showCallback, boolean expanded) {
         ContactDetail contact = new ContactDetail();
         contact.setId(authUser.getId());

Subversion Repositories SmartDukaan

(root)//trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/SupportController.java – Rev 35948 → 35969