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

 package in.shop2020.serving.controllers;
 import in.shop2020.crm.Activity;
-import in.shop2020.crm.CRMService.Client;
+import in.shop2020.crm.SearchFilter;
 import in.shop2020.crm.Ticket;
 import in.shop2020.crm.TicketStatus;
 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.UserCommunication;
 import in.shop2020.model.v1.user.UserCommunicationException;
 import in.shop2020.model.v1.user.UserContextException;
 import in.shop2020.model.v1.user.UserState;
+import in.shop2020.serving.auth.CRMAuthorizingRealm;
+import in.shop2020.thrift.clients.CRMClient;
+import in.shop2020.thrift.clients.TransactionClient;
+import in.shop2020.thrift.clients.UserClient;
 import in.shop2020.util.CRMConstants;
-import java.text.SimpleDateFormat;
+import java.util.Collections;
 import java.util.Date;
 import java.util.List;
 import org.apache.log4j.Logger;
 import org.apache.struts2.convention.annotation.Action;
+ *
  */
 @SuppressWarnings("serial")
 public class HomeController extends BaseController {
     private static final Logger log = Logger.getLogger(HomeController.class);
-    private final SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
     private String email;
-    private long orderId;
+    private String orderId;
     private String mobileNumber;
     private User user;
     private long orderCount;
     private long completedOrderCount;
     private long openOrderCount;
     private long activityCount;
     private long customerActivityCount;
     @Action("/")
     public String index() throws Exception {
-        createServiceClients();
         String returnValue = INPUT;
         try {
             if (email == null) {
-                loadTicketCounts(crmServiceClient);
+                loadTicketCounts();
-                loadCustomerActivities(crmServiceClient);
+                loadCustomerActivities();
                 return returnValue;
+            }
+            userContextServiceClient = new UserClient().getClient();
             if (email != null && !email.isEmpty()) {
                 user = userContextServiceClient.getUserByEmail(email);
+            }
             else if (mobileNumber != null && !mobileNumber.isEmpty()) {
                 user = userContextServiceClient.getUserByMobileNumber(Long.parseLong(mobileNumber));
+            }
-            else if (orderId != 0) {
+            else if (orderId != null && !orderId.isEmpty()) {
+                transactionServiceClient = new TransactionClient().getClient();
-                Order order = transactionServiceClient.getOrder(orderId);
+                Order order = transactionServiceClient.getOrder(Long.parseLong(orderId));
                 user = userContextServiceClient.getUserById(order.getCustomer_id());
+            }
             else if (ticketId != null && !ticketId.isEmpty()) {
+                SearchFilter searchFilter = new SearchFilter();
+                searchFilter.setTicketId(Long.parseLong(ticketId));
+                crmServiceClient         = new CRMClient().getClient();
-                Ticket ticket = crmServiceClient.getTicket(Long.parseLong(ticketId));
+                List<Ticket> tickets = crmServiceClient.getTickets(searchFilter);
+                if (!tickets.isEmpty()) {
+                    Ticket ticket = tickets.get(0);
+                    if (ticket.isSetCustomerId()) {
-                user = userContextServiceClient.getUserById(ticket.getCustomerId());
+                        user = userContextServiceClient.getUserById(ticket.getCustomerId());
+                    }
+                    else {
+                        // TODO support unregistered users!
+                    }
+                }
+            }
             if (user == null || user.getUserId() <= 0) {
                 addActionError("Invalid Input");
+            }
             else {
-                loadUserCommunicationDetails(userContextServiceClient);
+                loadUserCommunicationDetails();
-                loadOrderDetails(transactionServiceClient);
+                loadOrderDetails();
-                loadCartDetails(userContextServiceClient);
+                loadCartDetails();
-                loadTicketDetails(crmServiceClient);
+                loadTicketDetails();
-                loadActivityDetails(crmServiceClient);
+                loadActivityDetails();
                 returnValue = INDEX;
+            }
+        }
         catch (Exception e) {
             addActionError("Invalid input");
             log.error("Error occurred", e);
+        }
         if (INPUT.equals(returnValue)) {
-            loadTicketCounts(crmServiceClient);
+            loadTicketCounts();
+        }
         return returnValue;
+    }
-    private void loadCustomerActivities(Client crmServiceClient) throws TException {
+    private void loadCustomerActivities() throws TException {
+        SearchFilter searchFilter = new SearchFilter();
+        searchFilter.setActivityCreatorIds(Collections.singletonList(CRMConstants.ADMIN_AGENT_ID));
+        searchFilter.setIsActivityRead(false);
+        crmServiceClient         = new CRMClient().getClient();
-        List<Activity> activities = crmServiceClient.getActivitiesByCreator(CRMConstants.ADMIN_AGENT_ID);
+        List<Activity> activities = crmServiceClient.getActivities(searchFilter);
         if (activities != null) {
             customerActivityCount = activities.size();
+        }
+    }
-    private void loadActivityDetails(Client crmServiceClient) throws TException {
+    private void loadActivityDetails() throws TException {
+        SearchFilter searchFilter = new SearchFilter();
+        searchFilter.setCustomerId(user.getUserId());
+        crmServiceClient         = new CRMClient().getClient();
-        List<Activity> activities = crmServiceClient.getActivities(user.getUserId());
+        List<Activity> activities = crmServiceClient.getActivities(searchFilter);
         if (activities != null) {
             activityCount = activities.size();
+        }
+    }
-    private void loadTicketCounts(Client crmServiceClient) throws TException {
+    private void loadTicketCounts() throws TException {
+        SearchFilter searchFilter = new SearchFilter();
-        long currentAgentId = crmServiceClient.getAgentByEmailId(currentAgentEmailId).getId();
+        searchFilter.setTicketAssigneeIds(Collections.singletonList(CRMAuthorizingRealm.getAgent(currentAgentEmailId).getId()));
+        crmServiceClient         = new CRMClient().getClient();
-        List<Ticket> tickets = crmServiceClient.getAssignedTickets(currentAgentId);
+        List<Ticket> tickets = crmServiceClient.getTickets(searchFilter);
         agentTicketCount = tickets.size();
         for (Ticket ticket : tickets) {
             if (TicketStatus.OPEN.equals(ticket.getStatus())) {
                 agentOpenTicketCount++;
+            }
+        }
         List<Ticket> unassignedTickets = crmServiceClient.getUnassignedTickets();
         unassignedTicketCount = unassignedTickets.size();
-        List<Ticket> allTickets = crmServiceClient.getAllTickets(currentAgentId);
+        List<Ticket> allTickets = tickets;
         allTicketCount = allTickets.size();
         for (Ticket ticket : allTickets) {
             if (TicketStatus.OPEN.equals(ticket.getStatus())) {
                 allOpenTicketCount++;
+            }
+        }
+    }
-    private void loadUserCommunicationDetails(
+    private void loadUserCommunicationDetails()
-            in.shop2020.model.v1.user.UserContextService.Client userContextServiceClient)
             throws UserCommunicationException, TException {
+        userContextServiceClient = new UserClient().getClient();
         List<UserCommunication> userCommunication = userContextServiceClient.getUserCommunicationByUser(user.getUserId());
         userCommunicationCount = userCommunication.size();
+    }
-    private void loadOrderDetails(
+    private void loadOrderDetails()
-            in.shop2020.model.v1.order.TransactionService.Client transactionServiceClient)
             throws TransactionServiceException, TException {
+        transactionServiceClient = new TransactionClient().getClient();
         List<Order> allOrders = transactionServiceClient.getOrdersForCustomer(user.getUserId(), 0, (new Date()).getTime(), null);
         orderCount = allOrders.size();
         for (Order o : allOrders) {
             if (o.getStatus() == OrderStatus.DELIVERY_SUCCESS) {
                 openOrderCount++;
+            }
+        }
+    }
-    private void loadCartDetails(
+    private void loadCartDetails()
-            in.shop2020.model.v1.user.UserContextService.Client userContextServiceClient)
             throws UserContextException, TException {
+        userContextServiceClient = new UserClient().getClient();
         UserState userState = userContextServiceClient.getUserState(user.getUserId());
-        lastLogin = sdf.format(new Date(userState.getLastLogin()));
+        lastLogin = SDF.format(new Date(userState.getLastLogin()));
         Cart cart = null;
         try {
             cart = userContextServiceClient.getCurrentCart(user.getUserId());
             if (cart.getCouponCode() != null) {
         } catch (Exception e) {
             log.warn("No cart assigned for this user", e);
+        }
+    }
-    private void loadTicketDetails(Client crmServiceClient) throws TException {
+    private void loadTicketDetails() throws TException {
         // Fetching tickets' info
         ticketCount = 0;
         openTicketCount = 0;
         closedTicketCount = 0;
+        crmServiceClient         = new CRMClient().getClient();
+        SearchFilter searchFilter = new SearchFilter();
+        searchFilter.setCustomerId(user.getUserId());
-        List<Ticket> tickets = crmServiceClient.getTickets(user.getUserId());
+        List<Ticket> tickets = crmServiceClient.getTickets(searchFilter);
         if (tickets != null)
+        {
             for (Ticket ticket : tickets) {
                 ticketCount++;
                 if (!ticket.getStatus().equals(TicketStatus.CLOSED)) {
     public String getEmail() {
         return email;
+    }
     public void setOrderId(String orderId) {
-        if (orderId != null && !orderId.isEmpty()) {
-            this.orderId = Long.parseLong(orderId);
+        this.orderId = orderId;
-        }
+    }
-    public Long getOrderId() {
+    public String getOrderId() {
         return orderId;
+    }
     public User getUser() {
         return user;

Subversion Repositories SmartDukaan

(root)/trunk/Crm/src/main/java/in/shop2020/serving/controllers/HomeController.java – Rev 3339 → 3390