WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/dao/repository/cs/CsServiceImpl.java

 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.model.*;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.service.user.RetailerService;
+import com.spice.profitmandi.dao.entity.cs.TicketReadStatus;
+import com.spice.profitmandi.dao.entity.cs.TicketReadStatus.UserType;
+import com.spice.profitmandi.service.EmailService;
 import org.apache.commons.collections4.map.HashedMap;
 import org.apache.commons.lang.RandomStringUtils;
 import org.apache.commons.lang.StringUtils;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
     private FofoStoreRepository fofoStoreRepository;
     @Autowired
     private SessionFactory sessionFactory;
+    @Autowired
+    private TicketReadStatusRepository ticketReadStatusRepository;
+    @Autowired
+    private EmailService emailService;
     @Override
     public void createTicket(int fofoId, int categoryId, int subcategoryId, String message) throws ProfitMandiBusinessException {
         this.createTicket(fofoId, categoryId, subcategoryId, message, 0);
+    }
     @Override
     public void addActivity(Ticket ticket, Activity activity) {
         activity.setTicketId(ticket.getId());
         ticket.setLastActivity(activity.getType());
         ticket.setLastActivityId(activity.getId());
+        if (activity.getType() == ActivityType.COMMUNICATION_OUT) {
+            notifyPartnerOfExternalCommunication(ticket, activity);
+        }
+    }
     private String getRandomString() {
         int length = 4;
         boolean useLetters = false;
+        }
         return result;
+    }
+    @Override
+    public Map<Integer, Boolean> getUnreadStatusForTickets(List<Ticket> tickets, int userId, UserType userType) {
+        Map<Integer, Boolean> unreadMap = new HashMap<>();
+        if (tickets == null || tickets.isEmpty()) {
+            return unreadMap;
+        }
+        List<Integer> ticketIds = tickets.stream().map(Ticket::getId).collect(Collectors.toList());
+        List<TicketReadStatus> readStatuses = ticketReadStatusRepository.selectByTicketIdsAndUser(ticketIds, userId, userType);
+        Map<Integer, Integer> ticketLastReadMap = readStatuses.stream()
+                .collect(Collectors.toMap(TicketReadStatus::getTicketId, TicketReadStatus::getLastReadActivityId));
+        // Get last activities for all tickets to check who created them
+        Map<Integer, Activity> lastActivityMap = getLastActivitiesForTickets(ticketIds);
+        for (Ticket ticket : tickets) {
+            int lastActivityId = ticket.getLastActivityId();
+            int lastReadActivityId = ticketLastReadMap.getOrDefault(ticket.getId(), 0);
+            if (lastActivityId <= lastReadActivityId) {
+                unreadMap.put(ticket.getId(), false);
+                continue;
+            }
+            // Check if the current user created the last activity (exclude own updates)
+            Activity lastActivity = lastActivityMap.get(ticket.getId());
+            if (lastActivity != null) {
+                if (userType == UserType.AUTH_USER && lastActivity.getCreatedBy() == userId) {
+                    unreadMap.put(ticket.getId(), false);
+                    continue;
+                }
+                if (userType == UserType.PARTNER && lastActivity.getCreatedBy() == 0
+                        && lastActivity.getType() == ActivityType.COMMUNICATION_IN) {
+                    unreadMap.put(ticket.getId(), false);
+                    continue;
+                }
+                // For partners: only show as unread if activity type is external communication or resolved
+                if (userType == UserType.PARTNER) {
+                    boolean isRelevantForPartner = ActivityType.PARTNER_ACTIVITIES.contains(lastActivity.getType());
+                    unreadMap.put(ticket.getId(), isRelevantForPartner);
+                    continue;
+                }
+            }
+            unreadMap.put(ticket.getId(), true);
+        }
+        return unreadMap;
+    }
+    @Override
+    public void markTicketAsRead(int ticketId, int userId, UserType userType) {
+        Ticket ticket = ticketRepository.selectById(ticketId);
+        if (ticket == null) {
+            return;
+        }
+        TicketReadStatus readStatus = new TicketReadStatus();
+        readStatus.setTicketId(ticketId);
+        readStatus.setUserId(userId);
+        readStatus.setUserType(userType);
+        readStatus.setLastReadActivityId(ticket.getLastActivityId());
+        ticketReadStatusRepository.upsert(readStatus);
+    }
+    @Override
+    public Map<Integer, Activity> getLastActivitiesForTickets(List<Integer> ticketIds) {
+        Map<Integer, Activity> lastActivityMap = new HashMap<>();
+        if (ticketIds == null || ticketIds.isEmpty()) {
+            return lastActivityMap;
+        }
+        List<Activity> allActivities = activityRepository.selectAll(ticketIds);
+        // Group by ticketId and get the last one (highest id)
+        Map<Integer, List<Activity>> groupedByTicket = allActivities.stream()
+                .collect(Collectors.groupingBy(Activity::getTicketId));
+        for (Map.Entry<Integer, List<Activity>> entry : groupedByTicket.entrySet()) {
+            Activity lastActivity = entry.getValue().stream()
+                    .max(Comparator.comparingInt(Activity::getId))
+                    .orElse(null);
+            if (lastActivity != null) {
+                lastActivityMap.put(entry.getKey(), lastActivity);
+            }
+        }
+        return lastActivityMap;
+    }
+    @Override
+    public void notifyPartnerOfExternalCommunication(Ticket ticket, Activity activity) {
+        try {
+            CustomRetailer partner = retailerService.getFofoRetailer(ticket.getFofoId());
+            if (partner == null || partner.getEmail() == null) {
+                return;
+            }
+            TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());
+            TicketCategory ticketCategory = ticketCategoryRepository.selectById(ticketSubCategory.getCategoryId());
+            Map<String, Object> model = new HashMap<>();
+            model.put("ticketId", ticket.getId());
+            model.put("partnerName", partner.getBusinessName());
+            model.put("categoryName", ticketCategory.getName());
+            model.put("subCategoryName", ticketSubCategory.getName());
+            model.put("activityMessage", activity.getMessage());
+            emailService.sendMailWithAttachments(
+                    "Update on Your Support Ticket #" + ticket.getId(),
+                    "partner-ticket-update.vm",
+                    model,
+                    new String[]{partner.getEmail()},
+                    null,
+                    null);
+        } catch (Exception e) {
+            LOGGER.error("Failed to send partner notification email for ticket {}", ticket.getId(), e);
+        }
+    }
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/dao/repository/cs/CsServiceImpl.java – Rev 35592 → 35626