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.TicketCategory;

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 in.shop2020.util.CRMConstants;

import in.shop2020.util.CRMConstants.ActivityCommonDescriptionMatrix;

import java.text.ParseException;

import java.util.ArrayList;

import java.util.Collections;

import java.util.List;

import org.apache.thrift.TException;

/**

 * @author mandeep

 * 

 */

public class ActivityController extends BaseController {

    /**

     * 

     */

    private static final long serialVersionUID = 1L;

    private List<Activity>    activities;

    private String            activityId;

    private String            description;

    private String			  commonDescription;

    private String            type;

    private String            category;

    private String            customerMobileNumber;

    private String            creatorId;

    private String[]          agentIds;

    private String            startTimestamp;

    private String            endTimestamp;

    private String            customerEmailId;

    private String            customerName;

    private String            userId;

    private String			  notShowPmTickets;

    public String index() {

        try {

            SearchFilter searchFilter = new SearchFilter();

            if(notShowPmTickets!=null && !notShowPmTickets.isEmpty()){

            	searchFilter.setNotShowPmTickets(Boolean.parseBoolean(notShowPmTickets));

            }

            if (activityId != null && !activityId.isEmpty()) {

                searchFilter.setActivityId(Long.parseLong(activityId));

            } else if (userId != null && !userId.isEmpty()) {

                searchFilter.setCustomerId(Long.parseLong(userId));

            } else if (creatorId != null && !creatorId.isEmpty()) {

                searchFilter.setActivityCreatorIds(Collections

                        .singletonList(Long.parseLong(creatorId)));

                searchFilter.setIsActivityRead(false);

            } else if (agentIds != null && agentIds.length != 0) {

                searchFilter.setActivityCreatorIds(new ArrayList<Long>());

                for (String agentId : agentIds) {

                    searchFilter.getActivityCreatorIds().add(

                            CRMAuthorizingRealm.getAgent(agentId).getId());

                }

                if (type != null && !type.isEmpty()) {

                    searchFilter.setActivityType(ActivityType.valueOf(type));

                }

                if (category != null && !category.isEmpty()) {

                    searchFilter.setTicketCategory(TicketCategory.valueOf(category));

                }

                //Start:- Added By Manish Sharma for Searching Tickets/Activities using  Mobile No. on 21-Jun-2013

                if(customerMobileNumber!=null && !customerMobileNumber.isEmpty()){

                	searchFilter.setCustomerMobileNumber(customerMobileNumber);

                }

                //End:- Added By Manish Sharma for Searching Tickets/Activities using  Mobile No. on 21-Jun-2013

                try {

                    if (startTimestamp != null && !startTimestamp.isEmpty()) {

                        searchFilter.setStartTimestamp(SDF

                                .parse(startTimestamp).getTime());

                    }

                    if (endTimestamp != null && !endTimestamp.isEmpty()) {

                        searchFilter.setEndTimestamp(SDF.parse(endTimestamp)

                                .getTime());

                    }

                } catch (ParseException e) {

                    log.error("Error parsing timestamps", e);

                }

            } else {

                searchFilter.setActivityCreatorIds(Collections

                        .singletonList(CRMAuthorizingRealm.getAgent(

                                currentAgentEmailId).getId()));

            }

            crmServiceClient = new CRMClient().getClient();

            activities = crmServiceClient.getActivities(searchFilter);

        } catch (TException e) {

            log.error("Error while retrieving activities for "

                    + currentAgentEmailId, e);

        } catch (NumberFormatException e) {

            log.error("Error parsing userId: " + userId, e);

        }

        return INDEX;

    }

    public String editNew() {

        return EDIT_NEW;

    }

    public String create() throws Exception {

        Activity activity = new Activity();

        if(commonDescription!=null && !commonDescription.isEmpty()){

        	if(description!=null) {

        		description = commonDescription + "  " +description;

        	} else {

        		description = commonDescription;

        	}

        }

        activity.setDescription(description);

        activity.setType(ActivityType.valueOf(type));

        activity.setCreatorId(CRMAuthorizingRealm.getAgent(currentAgentEmailId)

                .getId());

        if (userId != null && !userId.isEmpty()) {

            activity.setCustomerId(Long.parseLong(userId));

            if(customerMobileNumber != null

                        && !customerMobileNumber.isEmpty()) {

            	activity.setCustomerMobileNumber(customerMobileNumber);

            }

        } else {

            User user = null;

            userContextServiceClient = new UserClient().getClient();

            try {

                if (customerName != null && !customerName.isEmpty()) {

                    activity.setCustomerName(customerName);

                }

                if (customerEmailId != null && !customerEmailId.isEmpty()) {

                    activity.setCustomerEmailId(customerEmailId);

                    user = userContextServiceClient

                            .getUserByEmail(customerEmailId);

                }

                if ((user == null || user.getUserId() == -1)

                        && customerMobileNumber != null

                        && !customerMobileNumber.isEmpty()) {

                    activity.setCustomerMobileNumber(customerMobileNumber);

                    user = userContextServiceClient.getUserByMobileNumber(Long

                            .parseLong(customerMobileNumber));

                }

            } catch (UserContextException e) {

                log.error("Could not fetch user for: " + customerEmailId + " "

                        + customerMobileNumber + " " + customerName, e);

            }

            if (user != null && user.getUserId() != -1) {

                activity.setCustomerId(user.getUserId());

            }

        }

        crmServiceClient = new CRMClient().getClient();

        activityId = String.valueOf(crmServiceClient.insertActivity(activity));

        return index();

    }

    public String markAsRead() {

        try {

            crmServiceClient = new CRMClient().getClient();

            crmServiceClient.markAsRead(Long.parseLong(activityId),

                    CRMAuthorizingRealm.getAgent(currentAgentEmailId).getId());

        } catch (NumberFormatException e) {

            log.error("Could not parse activity id from" + activityId, e);

        } catch (TException e) {

            log.error("Could not mark the activityId: " + activityId

                    + " as read", e);

        }

        return index();

    }

    public String getUnreadActivities() {

        try {

            SearchFilter searchFilter = new SearchFilter();

            searchFilter.setIsActivityRead(false);

            searchFilter.setActivityCreatorIds(Collections.singletonList(CRMConstants.ADMIN_AGENT_ID));

            if(notShowPmTickets!=null && !notShowPmTickets.isEmpty()){

            	searchFilter.setNotShowPmTickets(Boolean.parseBoolean(notShowPmTickets));

            }

            searchFilter.setTicketAssigneeIds(Collections

                    .singletonList(CRMAuthorizingRealm.getAgent(

                            currentAgentEmailId).getId()));

            crmServiceClient = new CRMClient().getClient();

            activities = crmServiceClient.getActivities(searchFilter);

        } catch (TException e) {

            log.error("Could not get agentId for: " + currentAgentEmailId, e);

        }

        return INDEX;

    }

    public ActivityType[] getActivityTypes() {

        return ActivityType.values();

    }

    public Agent getAgent(long agentId) throws TException {

        return CRMAuthorizingRealm.getAgent(agentId);

    }

    public ActivityCommonDescriptionMatrix[] getActivityCommonDescriptionMatrix () {

        return CRMConstants.ActivityCommonDescriptionMatrix.values();

    }

    public String getDescription() {

        return description;

    }

    public void setDescription(String description) {

        this.description = description;

    }

    public String getCommonDescription() {

		return commonDescription;

	}

	public void setCommonDescription(String commonDescription) {

		this.commonDescription = commonDescription;

	}

	public String getType() {

        return type;

    }

    public void setType(String type) {

        this.type = type;

    }

    public String getCustomerMobileNumber() {

        return customerMobileNumber;

    }

    public void setCustomerMobileNumber(String customerMobileNumber) {

        this.customerMobileNumber = customerMobileNumber;

    }

    public List<Activity> getActivities() {

        return activities;

    }

    public String getCreatorId() {

        return creatorId;

    }

    public void setCreatorId(String creatorId) {

        this.creatorId = creatorId;

    }

    public String getActivityId() {

        return activityId;

    }

    public void setActivityId(String activityId) {

        this.activityId = activityId;

    }

    public String[] getAgentIds() {

        return agentIds;

    }

    public void setAgentIds(String[] agentIds) {

        this.agentIds = agentIds;

    }

    public String getStartTimestamp() {

        return startTimestamp;

    }

    public void setStartTimestamp(String startTimestamp) {

        this.startTimestamp = startTimestamp;

    }

    public String getEndTimestamp() {

        return endTimestamp;

    }

    public void setEndTimestamp(String endTimestamp) {

        this.endTimestamp = endTimestamp;

    }

    public void setActivities(List<Activity> activities) {

        this.activities = activities;

    }

    public String getCustomerEmailId() {

        return customerEmailId;

    }

    public void setCustomerEmailId(String customerEmailId) {

        this.customerEmailId = customerEmailId;

    }

    public String getUserId() {

        return userId;

    }

    public void setUserId(String userId) {

        this.userId = userId;

    }

    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 String getCustomerName() {

        return customerName;

    }

    public void setCustomerName(String customerName) {

        this.customerName = customerName;

    }

    public String getCategory() {

        return category;

    }

    public void setCategory(String category) {

        this.category = category;

    }

	public String getNotShowPmTickets() {

		return notShowPmTickets;

	}

	public void setNotShowPmTickets(String notShowPmTickets) {

		this.notShowPmTickets = notShowPmTickets;

	}

}