Subversion Repositories SmartDukaan

import com.spice.profitmandi.dao.repository.cs.TicketRepository;

import com.spice.profitmandi.dao.repository.cs.ActivityRepository;

import com.spice.profitmandi.dao.repository.auth.AuthRepository;

import com.spice.profitmandi.dao.entity.cs.Ticket;

import com.spice.profitmandi.dao.entity.cs.Activity;

import com.spice.profitmandi.dao.entity.auth.AuthUser;

import com.spice.profitmandi.dao.entity.fofo.ActivityType;

    private TicketRepository ticketRepository;

    @Autowired

    private ActivityRepository activityRepository;

    @Autowired

    private AuthRepository authRepository;

    @Autowired

    /**

     * Mark all Sales Escalation (84) and RBM Escalation (83) tickets created before September 30, 2025 as resolved.

     * Tickets resolved on behalf of Gaurav CRM (gaurav.sharma@smartdukaan.com)

     *

     * @param dryRun if true, only logs what would be done without making changes

     * @return summary of the operation

     */

    public String resolveOldEscalationTickets(boolean dryRun) throws Exception {

        StringBuilder result = new StringBuilder();

        result.append(dryRun ? "=== DRY RUN MODE ===\n" : "=== EXECUTING ===\n");

        LOGGER.info("Starting resolveOldEscalationTickets migration (dryRun={})...", dryRun);

        // Get Gaurav's auth user ID

        AuthUser gauravUser = authRepository.selectByEmailOrMobile("gaurav.sharma@smartdukaan.com");

        if (gauravUser == null) {

            String error = "Gaurav CRM user not found with email gaurav.sharma@smartdukaan.com";

            LOGGER.error(error);

            return error;

        }

        int gauravAuthId = gauravUser.getId();

        result.append("Gaurav CRM auth user ID: ").append(gauravAuthId).append("\n");

        LOGGER.info("Gaurav CRM auth user ID: {}", gauravAuthId);

        // Define cutoff date: September 30, 2025 23:59:59

        LocalDateTime cutoffDate = LocalDateTime.of(2025, 9, 30, 23, 59, 59);

        LocalDateTime now = LocalDateTime.now();

        result.append("Cutoff date: ").append(cutoffDate).append("\n");

        // Subcategory IDs for Sales Escalation and RBM Escalation

        int salesEscalationSubCatId = ProfitMandiConstants.TICKET_SUBCATEGORY_SALES_ESCALATION; // 84

        int rbmEscalationSubCatId = ProfitMandiConstants.TICKET_SUBCATEGORY_RBM_ESCALATION; // 83

        // Select all open tickets with these subcategories created before cutoff

        Map<String, Object> params = new HashMap<>();

        params.put("closeTimestamp", GenericRepository.IS_NULL);

        List<Ticket> allOpenTickets = genericRepository.selectAllByEqualsOrderByDesc(

                Ticket.class, params, "createTimestamp");

        // Filter for escalation subcategories and before cutoff date

        List<Ticket> ticketsToResolve = allOpenTickets.stream()

                .filter(t -> (t.getSubCategoryId() == salesEscalationSubCatId || t.getSubCategoryId() == rbmEscalationSubCatId))

                .filter(t -> t.getCreateTimestamp() != null && t.getCreateTimestamp().isBefore(cutoffDate))

                .collect(Collectors.toList());

        result.append("Found ").append(ticketsToResolve.size()).append(" escalation tickets to resolve\n\n");

        LOGGER.info("Found {} escalation tickets to resolve (created before {})", ticketsToResolve.size(), cutoffDate);

        // List tickets

        result.append("Tickets:\n");

        for (Ticket ticket : ticketsToResolve) {

            String ticketInfo = String.format("ID: %d, SubCatId: %d, FofoId: %d, Created: %s",

                    ticket.getId(), ticket.getSubCategoryId(), ticket.getFofoId(), ticket.getCreateTimestamp());

            result.append("  ").append(ticketInfo).append("\n");

        }

        if (dryRun) {

            result.append("\n=== DRY RUN - No changes made ===\n");

            result.append("Call with dryRun=false to execute\n");

            return result.toString();

        }

        // Execute resolution

        int resolvedCount = 0;

        int failedCount = 0;

        for (Ticket ticket : ticketsToResolve) {

            try {

                // Update ticket

                ticket.setLastActivity(ActivityType.RESOLVED);

                ticket.setCloseTimestamp(now);

                ticketRepository.persist(ticket);

                // Create activity record

                Activity activity = new Activity();

                activity.setTicketId(ticket.getId());

                activity.setType(ActivityType.RESOLVED);

                activity.setCreatedBy(gauravAuthId);

                activity.setCreateTimestamp(now);

                activity.setMessage("Bulk resolved - old escalation ticket cleanup by CRM");

                activityRepository.persist(activity);

                // Update ticket's last activity ID

                ticket.setLastActivityId(activity.getId());

                ticketRepository.persist(ticket);

                resolvedCount++;

                LOGGER.info("Resolved ticket ID: {}, subCategoryId: {}, created: {}",

                        ticket.getId(), ticket.getSubCategoryId(), ticket.getCreateTimestamp());

            } catch (Exception e) {

                failedCount++;

                LOGGER.error("Failed to resolve ticket ID: {}", ticket.getId(), e);

            }

        }

        result.append("\n=== COMPLETED ===\n");

        result.append("Resolved: ").append(resolvedCount).append(" tickets\n");

        result.append("Failed: ").append(failedCount).append(" tickets\n");

        LOGGER.info("Completed resolveOldEscalationTickets migration. Resolved {} tickets, Failed {} tickets.", resolvedCount, failedCount);

        return result.toString();

    }