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.serving.auth.CRMAuthorizingRealm;
import in.shop2020.thrift.clients.CRMClient;
import in.shop2020.thrift.clients.HelperClient;
import in.shop2020.util.CRMConstants;
import in.shop2020.utils.HelperService.Client;

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            type;
    private String            subject;
    private String            body;
    private String            userEmailId;
    private String            customerMobileNumber;
    private String            creatorId;
    private String[]          agentIds;
    private String            startTimestamp;
    private String            endTimestamp;

    public String index() {
        try {
            SearchFilter searchFilter = new SearchFilter();

            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());
                }

                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);
        }

        return INDEX;
    }

    public String create() throws Exception {
        Activity activity = new Activity();
        activity.setDescription(description);
        activity.setType(ActivityType.valueOf(type));
        activity.setCreatorId(CRMAuthorizingRealm.getAgent(currentAgentEmailId).getId());

        if (customerMobileNumber != null && !customerMobileNumber.isEmpty()) {
            activity.setCustomerMobileNumber(customerMobileNumber);
        }

        if (ActivityType.SEND_EMAIL_TO_CUSTOMER.equals(activity.getType())) {
            log.info("Sending mail");
            Client helperClient = new HelperClient().getClient();
            activity.setUserEmailId(helperClient.saveUserEmailForSending(
                    userEmailId, CRMConstants.CRM_EMAIL_SENDOR, subject, body,
                    null, CRMConstants.CRM_EMAIL_TYPE));

            activity.setDescription("Subject: " + subject + "\n\n" + "Body: "
                    + body);
        }

        crmServiceClient         = new CRMClient().getClient();
        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 ActivityType[] getActivityTypes() {
        return ActivityType.values();
    }

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

    public String getDescription() {
        return description;
    }

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

    public String getType() {
        return type;
    }

    public void setType(String type) {
        this.type = type;
    }

    public String getSubject() {
        return subject;
    }

    public void setSubject(String subject) {
        this.subject = subject;
    }

    public String getBody() {
        return body;
    }

    public void setBody(String body) {
        this.body = body;
    }

    public String getUserEmailId() {
        return userEmailId;
    }

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

    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;
    }
}