WebSVN – SmartDukaan – Diff – //trunk/Crm/src/main/java/in/shop2020/serving/controllers/TicketsController.java

 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.order.LineItem;
+import in.shop2020.model.v1.order.Order;
+import in.shop2020.model.v1.order.OrderStatus;
+import in.shop2020.model.v1.order.TransactionServiceException;
 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.HelperClient;
+import in.shop2020.thrift.clients.TransactionClient;
 import in.shop2020.thrift.clients.UserClient;
 import in.shop2020.util.CRMConstants;
 import in.shop2020.utils.HelperService.Client;
 import in.shop2020.utils.HelperServiceException;
+import in.shop2020.utils.ModelUtils;
 import java.text.ParseException;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.Date;
 import java.util.List;
 import org.apache.shiro.SecurityUtils;
 import org.apache.thrift.TException;
+import org.apache.thrift.transport.TTransportException;
 /**
  * @author mandeep
+ *
  */
     private List<Activity>    activities;
     private String            subject;
     private String            body;
     private String            customerName;
     private String            customerMobileNumber;
+    private User              user;
+    private String            orderStatus;
+    private List<Order>       orders;
     public String index() {
         try {
             if (id != null && !id.isEmpty()) {
                 SearchFilter searchFilter = new SearchFilter();
             activities = crmServiceClient.getActivities(searchFilter);
             subject = createSubjectString(ticket);
             if (ticket.isSetCustomerId()) {
                 userId = String.valueOf(ticket.getCustomerId());
+                userContextServiceClient = new UserClient().getClient();
+                try {
+                    user = userContextServiceClient.getUserById(ticket
+                            .getCustomerId());
+                } catch (UserContextException e) {
+                    log.error("Could not fetch user details", e);
+                }
+            }
             customerEmailId = ticket.getCustomerEmailId();
+            if (TicketCategory.COD_VERIFICATION.equals(ticket.getCategory())) {
+                log.info("Fetching orders for " + ticket.getCustomerId());
+                orders = new ArrayList<Order>();
+                transactionServiceClient = new TransactionClient().getClient();
+                for (Order order : transactionServiceClient
+                        .getOrdersForCustomer(ticket.getCustomerId(), 0, 0,
+                                Collections.singletonList(OrderStatus.INIT))) {
+                    log.info("Processing Order: " + order);
+                    if (order.isCod()) {
+                        orders.add(order);
+                    }
+                }
+            }
         } catch (TException e) {
-            log.error("Error while loading edit page", e);
+            log.error("Error loading edit page", e);
+            return EXCEPTION;
+        } catch (NumberFormatException e) {
+            log.error("Error parsing orderId", e);
+            return EXCEPTION;
+        } catch (TransactionServiceException e) {
+            log.error("Error fetching orders for " + ticket.getCustomerId(), e);
             return EXCEPTION;
+        }
         return EDIT;
+    }
                 + " " + ticket.getCategory().name();
+    }
     public String create() {
         try {
-            long creatorId = CRMAuthorizingRealm.getAgent(currentAgentEmailId).getId();
+            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));
+            }
             if (userId != null && !userId.isEmpty()) {
                 ticket.setCustomerId(Long.parseLong(userId));
                 activity.setCustomerId(Long.parseLong(userId));
-            }
-            else {
+            } else {
                 User user = null;
                 userContextServiceClient = new UserClient().getClient();
                 try {
                     if (customerName != null && !customerName.isEmpty()) {
                         ticket.setCustomerName(customerName);
+                    }
                     if (customerEmailId != null && !customerEmailId.isEmpty()) {
                         ticket.setCustomerEmailId(customerEmailId);
                         activity.setCustomerEmailId(customerEmailId);
+                        user = userContextServiceClient
-                        user = userContextServiceClient.getUserByEmail(customerEmailId);
+                                .getUserByEmail(customerEmailId);
+                    }
+                    if ((user == null || user.getUserId() == -1)
+                            && customerMobileNumber != null
-                    if ((user == null || user.getUserId() == -1) && customerMobileNumber != null && !customerMobileNumber.isEmpty()) {
+                            && !customerMobileNumber.isEmpty()) {
                         ticket.setCustomerMobileNumber(customerMobileNumber);
                         activity.setCustomerMobileNumber(customerMobileNumber);
+                        user = userContextServiceClient
+                                .getUserByMobileNumber(Long
-                        user = userContextServiceClient.getUserByMobileNumber(Long.parseLong(customerMobileNumber));
+                                        .parseLong(customerMobileNumber));
+                    }
                 } catch (UserContextException e) {
-                    log.error("Could not fetch user for: " + customerEmailId + " "
+                    log.error("Could not fetch user for: " + customerEmailId
-                            + customerMobileNumber + " " + customerName, e);
+                            + " " + customerMobileNumber + " " + customerName,
+                            e);
+                }
                 if (user != null && user.getUserId() != -1) {
                     ticket.setCustomerId(user.getUserId());
                     activity.setCustomerId(user.getUserId());
+                }
+            }
             // handling null values appropriately
             if (assigneeEmailId != null && !assigneeEmailId.isEmpty()) {
-                long assigneeId = CRMAuthorizingRealm.getAgent(assigneeEmailId).getId();
+                long assigneeId = CRMAuthorizingRealm.getAgent(assigneeEmailId)
+                        .getId();
                 ticket.setAssigneeId(assigneeId);
                 activity.setTicketAssigneeId(assigneeId);
+            }
-            crmServiceClient         = new CRMClient().getClient();
+            crmServiceClient = new CRMClient().getClient();
+            id = String
-            id = String.valueOf(crmServiceClient.insertTicket(ticket, activity));
+                    .valueOf(crmServiceClient.insertTicket(ticket, activity));
         } catch (TException e) {
             log.error("Error while creating ticket", e);
             return EXCEPTION;
+        }
+            }
             if (agentIds != null && agentIds.length != 0) {
                 searchFilter.setTicketAssigneeIds(new ArrayList<Long>());
                 for (String agentId : agentIds) {
+                    searchFilter.getTicketAssigneeIds().add(
-                    searchFilter.getTicketAssigneeIds().add(CRMAuthorizingRealm.getAgent(agentId).getId());
+                            CRMAuthorizingRealm.getAgent(agentId).getId());
+                }
+            }
             if (startTimestamp != null && !startTimestamp.isEmpty()) {
-                searchFilter.setStartTimestamp(SDF.parse(startTimestamp).getTime());
+                searchFilter.setStartTimestamp(SDF.parse(startTimestamp)
+                        .getTime());
+            }
             if (endTimestamp != null && !endTimestamp.isEmpty()) {
                 searchFilter.setEndTimestamp(SDF.parse(endTimestamp).getTime());
+            }
             if (id != null && !id.isEmpty()) {
                 searchFilter.setTicketId(Long.parseLong(id));
+            }
             if (status != null && !status.isEmpty()) {
+                searchFilter.setTicketStatuses(Collections
-                searchFilter.setTicketStatus(TicketStatus.valueOf(status));
+                        .singletonList(TicketStatus.valueOf(status)));
+            }
             if (category != null && !category.isEmpty()) {
+                searchFilter
-                searchFilter.setTicketCategory(TicketCategory.valueOf(category));
+                        .setTicketCategory(TicketCategory.valueOf(category));
+            }
-            crmServiceClient         = new CRMClient().getClient();
+            crmServiceClient = new CRMClient().getClient();
             tickets = crmServiceClient.getTickets(searchFilter);
         } catch (TException e) {
             String errorString = "Error getting tickets for "
                     + currentAgentEmailId;
             log.error(errorString, e);
         return index();
+    }
     /**
      * Returns tickets assigned to the current logged in agent
      *
      * @return
      */
     public String getMyOpenTickets() {
         try {
             Agent agent = CRMAuthorizingRealm.getAgent(currentAgentEmailId);
             SearchFilter searchFilter = new SearchFilter();
-            searchFilter.setTicketAssigneeIds(Collections.singletonList(agent.getId()));
+            searchFilter.setTicketAssigneeIds(Collections.singletonList(agent
+                    .getId()));
-            crmServiceClient         = new CRMClient().getClient();
+            crmServiceClient = new CRMClient().getClient();
             for (Ticket ticket : crmServiceClient.getTickets(searchFilter)) {
                 if (TicketStatus.OPEN.equals(ticket.getStatus())) {
                     tickets.add(ticket);
+                }
+            }
         return index();
+    }
     public String getUnassignedTickets() {
         try {
-            crmServiceClient         = new CRMClient().getClient();
+            crmServiceClient = new CRMClient().getClient();
             tickets = crmServiceClient.getUnassignedTickets();
         } catch (TException e) {
             String errorString = "Error getting tickets for "
                     + currentAgentEmailId;
             log.error(errorString, e);
     public String update() {
         try {
             long creatorId = CRMAuthorizingRealm.getAgent(currentAgentEmailId)
                     .getId();
-            // Only subject and close date are editable fields for a ticket
+            SearchFilter searchFilter = new SearchFilter();
-            Ticket ticket = new Ticket();
+            searchFilter.setTicketId(Long.parseLong(id));
-            ticket.setId(Long.parseLong(id));
+            crmServiceClient = new CRMClient().getClient();
+            Ticket ticket = crmServiceClient.getTickets(searchFilter).get(0);
             ticket.setDescription(description);
-            ticket.setCategory(TicketCategory.valueOf(category));
             ticket.setPriority(TicketPriority.valueOf(priority));
-            ticket.setStatus(TicketStatus.valueOf(status));
             // Update when a ticket is closed!
             if (TicketStatus.CLOSED.name().equals(status)) {
+                if (TicketCategory.COD_VERIFICATION.equals(ticket.getCategory())
+                        && pendingCODOrders(ticket.getCustomerId())) {
+                    addActionMessage("Cod orders pending for verification. Ticket can not be closed and its category cannot be changed.");
+                } else {
+                    ticket.setCategory(TicketCategory.valueOf(category));
+                    ticket.setStatus(TicketStatus.valueOf(status));
-                ticket.setCloseDate(new Date().getTime());
+                    ticket.setCloseDate(new Date().getTime());
+                }
+            }
+            else {
+                ticket.setCategory(TicketCategory.valueOf(category));
+                ticket.setStatus(TicketStatus.valueOf(status));
+            }
             if (activityDescription == null || activityDescription.isEmpty()) {
                 activityDescription = "Updating ticket fields";
+            }
             Activity activity = new Activity();
             activity.setDescription(activityDescription);
             activity.setType(ActivityType.valueOf(activityType));
-            activity.setTicketPriority(TicketPriority.valueOf(priority));
+            activity.setTicketPriority(ticket.getPriority());
-            activity.setTicketStatus(TicketStatus.valueOf(status));
+            activity.setTicketStatus(ticket.getStatus());
             activity.setCreatorId(creatorId);
-            activity.setTicketCategory(TicketCategory.valueOf(category));
+            activity.setTicketCategory(ticket.getCategory());
-            activity.setTicketDescription(description);
+            activity.setTicketDescription(ticket.getDescription());
             if (userId != null && !userId.isEmpty()) {
                 activity.setCustomerId(Long.parseLong(userId));
+            }
-            log.info(activityType);
             if (ActivityType.SEND_EMAIL_TO_CUSTOMER.equals(activity.getType())) {
                 log.info("Sending mail");
                 Client helperClient = new HelperClient().getClient();
                 activity.setUserEmailId(helperClient.saveUserEmailForSending(
-                        customerEmailId, CRMConstants.CRM_EMAIL_SENDOR, subject,
+                        customerEmailId, CRMConstants.CRM_EMAIL_SENDOR,
-                        body, null, CRMConstants.CRM_EMAIL_TYPE));
+                        subject, body, null, CRMConstants.CRM_EMAIL_TYPE));
                 // We change activityType to OTHER when pop up box for email
                 // closes
                 activity.setDescription("Subject: " + subject + "\n\n"
                         + "Body: " + body);
+            }
             // handling null values appropriately
             if (assigneeEmailId != null && !assigneeEmailId.isEmpty()) {
-                long assigneeId = CRMAuthorizingRealm.getAgent(
+                long assigneeId = CRMAuthorizingRealm.getAgent(assigneeEmailId)
-                        assigneeEmailId).getId();
+                        .getId();
                 ticket.setAssigneeId(assigneeId);
                 activity.setTicketAssigneeId(assigneeId);
+            }
             User user = null;
+                }
                 if (customerEmailId != null && !customerEmailId.isEmpty()) {
                     ticket.setCustomerEmailId(customerEmailId);
                     activity.setCustomerEmailId(customerEmailId);
+                    user = userContextServiceClient
-                    user = userContextServiceClient.getUserByEmail(customerEmailId);
+                            .getUserByEmail(customerEmailId);
+                }
+                if ((user == null || user.getUserId() == -1)
+                        && customerMobileNumber != null
-                if ((user == null || user.getUserId() == -1) && customerMobileNumber != null && !customerMobileNumber.isEmpty()) {
+                        && !customerMobileNumber.isEmpty()) {
                     ticket.setCustomerMobileNumber(customerMobileNumber);
                     activity.setCustomerMobileNumber(customerMobileNumber);
-                    user = userContextServiceClient.getUserByMobileNumber(Long.parseLong(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) {
                 ticket.setCustomerId(user.getUserId());
                 activity.setCustomerId(user.getUserId());
+            }
+        }
         return index();
+    }
+    private boolean pendingCODOrders(long customerId) {
+        try {
+            log.info("Trying to fetch orders for " + customerId);
+            transactionServiceClient = new TransactionClient().getClient();
+            for (Order order : transactionServiceClient.getOrdersForCustomer(
+                    customerId, 0, 0,
+                    Collections.singletonList(OrderStatus.INIT))) {
+                log.info("Processing order: " + order.getId() + " with COD: " + order.isCod());
+                if (order.isCod()) {
+                    log.info("Returning true from pendingCODOrders() for " + customerId);
+                    return true;
+                }
+            }
+        } catch (TTransportException e) {
+            log.error("Error while creating thrift client", e);
+        } catch (TransactionServiceException e) {
+            log.error("Error fetching orders", e);
+        } catch (TException e) {
+            log.error("Error fetching orders", e);
+        }
+        log.info("Returning false from pendingCODOrders() for " + customerId);
+        return false;
+    }
+    public String updateOrderStatus() throws NumberFormatException,
+            TransactionServiceException, TException {
+        long creatorId = CRMAuthorizingRealm.getAgent(currentAgentEmailId)
+                .getId();
+        transactionServiceClient = new TransactionClient().getClient();
+        transactionServiceClient.changeOrderStatus(Long.parseLong(orderId),
+                OrderStatus.valueOf(orderStatus),
+                OrderStatus.valueOf(orderStatus).getDescription());
+        SearchFilter searchFilter = new SearchFilter();
+        searchFilter.setTicketId(Long.parseLong(id));
+        crmServiceClient = new CRMClient().getClient();
+        Ticket ticket = crmServiceClient.getTickets(searchFilter).get(0);
+        // Inserting activity
+        Activity activity = new Activity();
+        activity.setDescription("Updating status for Order Id: " + orderId
+                + " to " + orderStatus);
+        activity.setType(ActivityType.OTHER);
+        activity.setTicketPriority(ticket.getPriority());
+        activity.setTicketStatus(ticket.getStatus());
+        activity.setCreatorId(creatorId);
+        activity.setTicketCategory(ticket.getCategory());
+        activity.setTicketDescription(ticket.getDescription());
+        activity.setCustomerId(ticket.getCustomerId());
+        activity.setTicketAssigneeId(ticket.getAssigneeId());
+        crmServiceClient = new CRMClient().getClient();
+        crmServiceClient.updateTicket(ticket, activity);
+        return edit();
+    }
     public User getUser(Long userId) {
         User user = null;
         try {
             userContextServiceClient = new UserClient().getClient();
+        }
         return user;
+    }
+    public String getAddress(Order order) {
+        return ModelUtils.extractAddressFromOrder(order);
+    }
+    public String getProductName(LineItem lineItem) {
+        return ModelUtils.extractProductNameFromLineItem(lineItem);
+    }
     public ActivityType[] getActivityTypes() {
         return ActivityType.values();
+    }
     public TicketStatus[] getTicketStatuses() {
+    }
     public void setCustomerMobileNumber(String customerMobileNumber) {
         this.customerMobileNumber = customerMobileNumber;
+    }
+    public User getUser() {
+        return user;
+    }
+    public void setUser(User user) {
+        this.user = user;
+    }
+    public String getOrderStatus() {
+        return orderStatus;
+    }
+    public void setOrderStatus(String orderStatus) {
+        this.orderStatus = orderStatus;
+    }
+    public List<Order> getOrders() {
+        return orders;
+    }
+    public void setOrders(List<Order> orders) {
+        this.orders = orders;
+    }
+}

Subversion Repositories SmartDukaan

(root)//trunk/Crm/src/main/java/in/shop2020/serving/controllers/TicketsController.java – Rev 3519 → 3546