Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.service;

import org.hibernate.Session;

import org.hibernate.SessionFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;

import java.time.LocalDateTime;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import java.util.concurrent.ConcurrentHashMap;

@Service

public class AgentLiveStatusService {

    // In-memory map to store agent status by authId

    private final Map<Integer, AgentStatus> agentStatusMap = new ConcurrentHashMap<>();

    // Caller ID (Knowlarity SR Number) to Auth ID mapping (loaded from sip_master)

    private final Map<String, Integer> callerIdToAuthIdMap = new ConcurrentHashMap<>();

    // SR Number to Auth ID mapping (loaded from sip_master)

    private final Map<String, Integer> srNumberToAuthIdMap = new ConcurrentHashMap<>();

    // Agent name to Auth ID mapping (fallback)

    private final Map<String, Integer> agentNameToAuthIdMap = new ConcurrentHashMap<>();

    @Autowired

    private SessionFactory sessionFactory;

    private String lastError = null;

    private int lastQueryCount = 0;

    /**

     * Load mapping from sip_master table on startup

     * caller_id in sip_master = SR Number on Knowlarity dashboard

     * sip_master has auth_id directly

     */

    @PostConstruct

    public void loadMappingFromDatabase() {

        try {

            Session session = sessionFactory.openSession();

            // Query to get caller_id, auth_user.id, first_name from sip_master

            // Join with auth_user to get correct auth_id used by rbm_call_target page

            String sql = "SELECT sm.caller_id, au.id, sm.first_name " +

                    "FROM auth.sip_master sm " +

                    "JOIN auth.auth_user au ON sm.email_id = au.email_id " +

                    "WHERE au.id IS NOT NULL";

            List<Object[]> results = session.createNativeQuery(sql).getResultList();

            lastQueryCount = results.size();

            for (Object[] row : results) {

                String callerId = row[0] != null ? row[0].toString().trim() : "";

                int authId = row[1] != null ? ((Number) row[1]).intValue() : 0;

                String firstName = row[2] != null ? row[2].toString().trim() : "";

                if (authId > 0) {

                    // Map by caller_id if available

                    if (!callerId.isEmpty()) {

                        callerIdToAuthIdMap.put(callerId, authId);

                    }

                    // Map by first_name for name-based matching

                    if (!firstName.isEmpty()) {

                        agentNameToAuthIdMap.put(firstName.toLowerCase(), authId);

                        System.out.println("Mapping: '" + firstName + "' -> authId=" + authId + " (caller_id=" + callerId + ")");

                    }

                }

            }

            session.close();

            System.out.println("Loaded " + callerIdToAuthIdMap.size() + " caller_id -> auth_id mappings from sip_master");

            System.out.println("Loaded " + agentNameToAuthIdMap.size() + " name -> auth_id mappings");

        } catch (Exception e) {

            lastError = e.getClass().getSimpleName() + ": " + e.getMessage();

            System.err.println("Error loading sip_master mapping: " + e.getMessage());

            e.printStackTrace();

        }

    }

    public String getLastError() {

        return lastError;

    }

    public int getLastQueryCount() {

        return lastQueryCount;

    }

    /**

     * Reload mapping from database (can be called via API)

     */

    public void reloadMapping() {

        callerIdToAuthIdMap.clear();

        srNumberToAuthIdMap.clear();

        agentNameToAuthIdMap.clear();

        lastError = null;

        lastQueryCount = 0;

        loadMappingFromDatabase();

    }

    public Integer getAuthIdByCallerId(String callerId) {

        return callerIdToAuthIdMap.get(callerId);

    }

    public void setSrNumberMapping(String srNumber, int authId) {

        srNumberToAuthIdMap.put(srNumber, authId);

    }

    public void setAgentNameMapping(String agentName, int authId) {

        agentNameToAuthIdMap.put(agentName.toLowerCase(), authId);

    }

    public Integer getAuthIdBySrNumber(String srNumber) {

        return srNumberToAuthIdMap.get(srNumber);

    }

    public Integer getAuthIdByAgentName(String agentName) {

        // Try exact match

        Integer authId = agentNameToAuthIdMap.get(agentName.toLowerCase());

        if (authId != null) return authId;

        // Try partial match

        for (Map.Entry<String, Integer> entry : agentNameToAuthIdMap.entrySet()) {

            if (agentName.toLowerCase().contains(entry.getKey()) || entry.getKey().contains(agentName.toLowerCase())) {

                return entry.getValue();

            }

        }

        return null;

    }

    public Map<String, Integer> getSrNumberMapping() {

        return srNumberToAuthIdMap;

    }

    public Map<String, Integer> getAgentNameMapping() {

        return agentNameToAuthIdMap;

    }

    public Map<String, Integer> getCallerIdMapping() {

        return callerIdToAuthIdMap;

    }

    public void clearMappings() {

        srNumberToAuthIdMap.clear();

        agentNameToAuthIdMap.clear();

    }

    public void updateStatus(int authId, String srNumber, String agentName, String agentStatus, String timeInStatus, String customerNumber) {

        AgentStatus status = new AgentStatus(authId, srNumber, agentName, agentStatus, timeInStatus, customerNumber);

        agentStatusMap.put(authId, status);

    }

    public AgentStatus getStatusByAuthId(int authId) {

        return agentStatusMap.get(authId);

    }

    public Map<Integer, AgentStatus> getAllStatusMap() {

        return agentStatusMap;

    }

    public List<AgentStatus> getAllStatuses() {

        return new ArrayList<>(agentStatusMap.values());

    }

    public void clearAll() {

        agentStatusMap.clear();

    }

    // Inner class to hold agent status

    public static class AgentStatus {

        private int authId;

        private String srNumber;

        private String agentName;

        private String agentStatus;

        private String timeInStatus;

        private String customerNumber;

        private LocalDateTime lastUpdated;

        public AgentStatus() {

        }

        public AgentStatus(int authId, String srNumber, String agentName, String agentStatus, String timeInStatus, String customerNumber) {

            this.authId = authId;

            this.srNumber = srNumber;

            this.agentName = agentName;

            this.agentStatus = agentStatus;

            this.timeInStatus = timeInStatus;

            this.customerNumber = customerNumber;

            this.lastUpdated = LocalDateTime.now();

        }

        public int getAuthId() {

            return authId;

        }

        public void setAuthId(int authId) {

            this.authId = authId;

        }

        public String getSrNumber() {

            return srNumber;

        }

        public void setSrNumber(String srNumber) {

            this.srNumber = srNumber;

        }

        public String getAgentName() {

            return agentName;

        }

        public void setAgentName(String agentName) {

            this.agentName = agentName;

        }

        public String getAgentStatus() {

            return agentStatus;

        }

        public void setAgentStatus(String agentStatus) {

            this.agentStatus = agentStatus;

        }

        public String getTimeInStatus() {

            return timeInStatus;

        }

        public void setTimeInStatus(String timeInStatus) {

            this.timeInStatus = timeInStatus;

        }

        public String getCustomerNumber() {

            return customerNumber;

        }

        public void setCustomerNumber(String customerNumber) {

            this.customerNumber = customerNumber;

        }

        public LocalDateTime getLastUpdated() {

            return lastUpdated;

        }

        public void setLastUpdated(LocalDateTime lastUpdated) {

            this.lastUpdated = lastUpdated;

        }

    }

}