Subversion Repositories SmartDukaan

/**
 * 
 */
package in.shop2020.serving.controllers;

import in.shop2020.crm.Activity;
import in.shop2020.crm.ActivityType;
import in.shop2020.crm.Agent;
import in.shop2020.crm.SearchFilter;
import in.shop2020.crm.Ticket;
import in.shop2020.crm.TicketCategory;
import in.shop2020.crm.TicketPriority;
import in.shop2020.crm.TicketStatus;
import in.shop2020.model.v1.user.User;
import in.shop2020.model.v1.user.UserContextException;
import in.shop2020.serving.auth.CRMAuthorizingRealm;
import in.shop2020.thrift.clients.CRMClient;
import in.shop2020.thrift.clients.UserClient;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

import org.apache.thrift.TException;

/**
 * @author mandeep
 * 
 */
public class TicketsController extends BaseController {

    /**
     * 
     */
    private static final long serialVersionUID = 1L;

    List<Ticket>              tickets          = new ArrayList<Ticket>();
    private String            userEmailId;
    private String            description;
    private String            assigneeEmailId;
    private String            priority;
    private String            category;
    private String            orderId;

    public String create() {
        try {
            long creatorId = CRMAuthorizingRealm.getAgent(currentAgentEmailId).getId();
            Ticket ticket = new Ticket();
            ticket.setDescription(description);
            ticket.setCreatorId(creatorId);
            ticket.setStatus(TicketStatus.OPEN);
            ticket.setPriority(TicketPriority.valueOf(priority));
            ticket.setCategory(TicketCategory.valueOf(category));

            Activity activity = new Activity();
            // At creation of ticket activity's description is same as that of
            // ticket
            activity.setDescription("Creating Ticket");
            activity.setType(ActivityType.OTHER);
            activity.setTicketPriority(TicketPriority.valueOf(priority));
            activity.setTicketStatus(TicketStatus.OPEN);
            activity.setCreatorId(creatorId);
            activity.setTicketCategory(TicketCategory.valueOf(category));
            activity.setTicketDescription(description);

            if (orderId != null && !orderId.isEmpty()) {
                ticket.setOrderId(Long.parseLong(orderId));
            }

            if (userEmailId != null && !userEmailId.isEmpty()) {
                User user = null;
                userContextServiceClient = new UserClient().getClient();
                try {
                    user = userContextServiceClient.getUserByEmail(userEmailId);
                } catch (UserContextException e) {
                    log.error("Could not fetch user for " + userEmailId, e);
                }

                if (user != null && user.getUserId() != -1) {
                    ticket.setCustomerId(user.getUserId());
                    activity.setCustomerId(user.getUserId());
                }
                else {
                    ticket.setCustomerEmailId(userEmailId);
                    activity.setCustomerEmailId(userEmailId);
                }
            }

            // handling null values appropriately
            if (assigneeEmailId != null && !assigneeEmailId.isEmpty()) {
                long assigneeId = CRMAuthorizingRealm.getAgent(assigneeEmailId).getId();
                ticket.setAssigneeId(assigneeId);
                activity.setTicketAssigneeId(assigneeId);
            }

            crmServiceClient         = new CRMClient().getClient();
            crmServiceClient.insertTicket(ticket, activity);
        } catch (TException e) {
            log.error("Error while creating ticket", e);
            return EXCEPTION;
        }

        return getMyOpenTickets();
    }

    public String getMyOpenTickets() {
        try {
            Agent agent = CRMAuthorizingRealm.getAgent(currentAgentEmailId);

            SearchFilter searchFilter = new SearchFilter();
            searchFilter.setTicketAssigneeIds(Collections.singletonList(agent.getId()));
            crmServiceClient         = new CRMClient().getClient();
            for (Ticket ticket : crmServiceClient.getTickets(searchFilter)) {
                if (TicketStatus.OPEN.equals(ticket.getStatus())) {
                    tickets.add(ticket);
                }
            }
        } catch (TException e) {
            String errorString = "Error getting tickets for "
                    + currentAgentEmailId;
            log.error(errorString, e);
            addActionError(errorString);
        }

        return INDEX;
    }

    public String getMyTickets() {
        try {
            Agent agent = CRMAuthorizingRealm.getAgent(currentAgentEmailId);

            SearchFilter searchFilter = new SearchFilter();
            searchFilter.setTicketAssigneeIds(Collections.singletonList(agent.getId()));
            crmServiceClient         = new CRMClient().getClient();
            tickets = crmServiceClient.getTickets(searchFilter);
        } catch (TException e) {
            String errorString = "Error getting tickets for "
                    + currentAgentEmailId;
            log.error(errorString, e);
            addActionError(errorString);
        }

        return INDEX;
    }

    public String getUnassignedTickets() {
        try {
            crmServiceClient         = new CRMClient().getClient();
            tickets = crmServiceClient.getUnassignedTickets();
        } catch (TException e) {
            String errorString = "Error getting tickets for "
                    + currentAgentEmailId;
            log.error(errorString, e);
            addActionError(errorString);
        }

        return INDEX;
    }

    public String getAllTickets() {
        try {
            SearchFilter searchFilter = new SearchFilter();
            searchFilter.setTicketAssigneeIds(Collections.singletonList(CRMAuthorizingRealm.getAgent(currentAgentEmailId).getId()));
            crmServiceClient         = new CRMClient().getClient();
            tickets = crmServiceClient.getTickets(searchFilter);
        } catch (TException e) {
            String errorString = "Error getting tickets for "
                    + currentAgentEmailId;
            log.error(errorString, e);
            addActionError(errorString);
        }

        return INDEX;
    }

    public String getAllOpenTickets() {
        try {
            SearchFilter searchFilter = new SearchFilter();
            searchFilter.setTicketAssigneeIds(Collections.singletonList(CRMAuthorizingRealm.getAgent(currentAgentEmailId).getId()));
            crmServiceClient          = new CRMClient().getClient();
            for (Ticket ticket : crmServiceClient.getTickets(searchFilter)) {
                if (TicketStatus.OPEN.equals(ticket.getStatus())) {
                    tickets.add(ticket);
                }
            }
        } catch (TException e) {
            String errorString = "Error getting tickets for "
                    + currentAgentEmailId;
            log.error(errorString, e);
            addActionError(errorString);
        }

        return INDEX;
    }

    public User getUser(Long userId) {
        User user = null;

        try {
            userContextServiceClient = new UserClient().getClient();
            user = userContextServiceClient.getUserById(userId);
        } catch (UserContextException e) {
            String errorString = "Could not fetch user for " + userId;
            log.error(errorString, e);
            addActionError(errorString);
        } catch (TException e) {
            String errorString = "Could not create client";
            log.error(errorString, e);
            addActionError(errorString);
        }

        return user;
    }

    public Agent getAgent(long agentId) throws TException {
        return CRMAuthorizingRealm.getAgent(agentId);
    }

    public List<Agent> getAllAgents() {
        return CRMAuthorizingRealm.getAgents();
    }

    public TicketCategory[] getTicketCategories() {
        return TicketCategory.values();
    }

    public TicketPriority[] getTicketPriorities() {
        return TicketPriority.values();
    }

    public List<Ticket> getTickets() {
        return tickets;
    }

    public void setTickets(List<Ticket> tickets) {
        this.tickets = tickets;
    }

    public String getUserEmailId() {
        return userEmailId;
    }

    public void setUserEmailId(String userEmailId) {
        this.userEmailId = userEmailId;
    }

    public String getDescription() {
        return description;
    }

    public void setDescription(String description) {
        this.description = description;
    }

    public String getAssigneeEmailId() {
        return assigneeEmailId;
    }

    public void setAssigneeEmailId(String assigneeEmailId) {
        this.assigneeEmailId = assigneeEmailId;
    }

    public String getPriority() {
        return priority;
    }

    public void setPriority(String priority) {
        this.priority = priority;
    }

    public String getCategory() {
        return category;
    }

    public void setCategory(String category) {
        this.category = category;
    }

    public String getOrderId() {
        return orderId;
    }

    public void setOrderId(String orderId) {
        this.orderId = orderId;
    }
}