WebSVN – SmartDukaan – Diff – /trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/LeadController.java

 import java.io.IOException;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Comparator;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.Map.Entry;
-import java.util.Set;
 import java.util.stream.Collectors;
 import javax.servlet.http.HttpServletRequest;
 import com.spice.profitmandi.common.enumuration.ActivationType;
+import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.common.web.client.RestClient;
+import com.spice.profitmandi.dao.entity.cs.*;
-import com.spice.profitmandi.dao.entity.fofo.RetailerContact;
+import com.spice.profitmandi.dao.entity.dtr.Document;
-import com.spice.profitmandi.service.FofoUser;
+import com.spice.profitmandi.dao.entity.fofo.*;
+import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
+import com.spice.profitmandi.dao.model.*;
+import com.spice.profitmandi.dao.repository.cs.*;
+import com.spice.profitmandi.dao.repository.dtr.*;
+import com.spice.profitmandi.dao.repository.user.AddressRepository;
 import com.spice.profitmandi.service.smartping.SmartPingAgentModel;
 import com.spice.profitmandi.service.smartping.SmartPingService;
 import org.apache.commons.csv.CSVRecord;
+import org.apache.commons.io.output.ByteArrayOutputStream;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.format.annotation.DateTimeFormat;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
+import org.springframework.mail.javamail.JavaMailSender;
 import org.springframework.stereotype.Controller;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.ui.Model;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.CustomRetailer;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.model.SendNotificationModel;
 import com.spice.profitmandi.common.util.FileUtil;
-import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.common.web.util.ResponseSender;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
 import com.spice.profitmandi.dao.entity.auth.PartnerCollectionPlan;
 import com.spice.profitmandi.dao.entity.auth.PartnerCollectionRemark;
 import com.spice.profitmandi.dao.entity.auth.PartnerSecondaryPlan;
-import com.spice.profitmandi.dao.entity.cs.Ticket;
-import com.spice.profitmandi.dao.entity.cs.TicketCategory;
-import com.spice.profitmandi.dao.entity.cs.TicketSubCategory;
 import com.spice.profitmandi.dao.entity.dtr.User;
 import com.spice.profitmandi.dao.entity.dtr.UserAccount;
-import com.spice.profitmandi.dao.entity.fofo.FofoStore;
-import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
-import com.spice.profitmandi.dao.entity.fofo.PartnerOnBoardingPanel;
 import com.spice.profitmandi.dao.entity.user.FranchiseeActivity;
 import com.spice.profitmandi.dao.entity.user.FranchiseeVisit;
 import com.spice.profitmandi.dao.entity.user.Lead;
 import com.spice.profitmandi.dao.entity.user.LeadActivity;
 import com.spice.profitmandi.dao.entity.user.VisitRequest;
 import com.spice.profitmandi.dao.enumuration.dtr.FranchiseeActivityStatus;
 import com.spice.profitmandi.dao.enumuration.dtr.FranchiseeVisitStatus;
 import com.spice.profitmandi.dao.enumuration.dtr.LeadStatus;
 import com.spice.profitmandi.dao.enumuration.dtr.StoreTimeline;
 import com.spice.profitmandi.dao.enumuration.dtr.VisitStatus;
-import com.spice.profitmandi.dao.model.CreateRefferalRequest;
-import com.spice.profitmandi.dao.model.OnBoardingTimelineModel;
-import com.spice.profitmandi.dao.model.PartnerCollectionPlanModel;
-import com.spice.profitmandi.dao.model.PartnerCollectionRemarkModel;
-import com.spice.profitmandi.dao.model.PartnerSecondaryPlanModel;
-import com.spice.profitmandi.dao.model.PartnerTargetAchievementModel;
-import com.spice.profitmandi.dao.model.TargetModel;
-import com.spice.profitmandi.dao.model.TicketViewModel;
-import com.spice.profitmandi.dao.model.UserCart;
-import com.spice.profitmandi.dao.model.UserVisitModel;
-import com.spice.profitmandi.dao.model.VisitDescriptionModel;
-import com.spice.profitmandi.dao.model.VisitSummaryModel;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.auth.AuthUserPartnerMappingRepository;
 import com.spice.profitmandi.dao.repository.auth.PartnerCollectionPlanRepository;
 import com.spice.profitmandi.dao.repository.auth.PartnerCollectionRemarkRepository;
 import com.spice.profitmandi.dao.repository.auth.PartnerSecondaryPlanRepository;
-import com.spice.profitmandi.dao.repository.cs.CsService;
-import com.spice.profitmandi.dao.repository.cs.TicketCategoryRepository;
-import com.spice.profitmandi.dao.repository.cs.TicketRepository;
-import com.spice.profitmandi.dao.repository.cs.TicketSubCategoryRepository;
-import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
-import com.spice.profitmandi.dao.repository.dtr.FranchiseeActivityRepository;
-import com.spice.profitmandi.dao.repository.dtr.FranchiseeVisitRepository;
-import com.spice.profitmandi.dao.repository.dtr.LeadActivityRepository;
-import com.spice.profitmandi.dao.repository.dtr.LeadRepository;
-import com.spice.profitmandi.dao.repository.dtr.Mongo;
-import com.spice.profitmandi.dao.repository.dtr.PartnerOnBoardingPanelRepository;
-import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
-import com.spice.profitmandi.dao.repository.dtr.UserRepository;
-import com.spice.profitmandi.dao.repository.dtr.VisitRequestRepository;
 import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
 import com.spice.profitmandi.service.AuthService;
 import com.spice.profitmandi.service.NotificationService;
 import com.spice.profitmandi.service.PartnerCollectionService;
     @Autowired
     private LeadRepository leadRepository;
     @Autowired
+    private ActivityRepository activityRepository;
+    @Autowired
+    private TicketActivityMediaRepository activityMeidaRepository;
+    @Autowired
+    DocumentRepository documentRepository;
+    @Autowired
+    PositionRepository positionRepository;
+    @Autowired
+    private ActivityAttachmentRepository activityAttachmentRepository;
+    @Autowired
     private CsService csService;
     @Autowired
     private UserRepository userRepository;
     @Autowired
+    private AddressRepository addressRepository;
+    @Autowired
+    private UserRoleRepository userRoleRepository;
+    @Autowired
     private UserAccountRepository userAccountRepository;
     @Autowired
     private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
     private AuthService authService;
     @Autowired
     private NotificationService notificationService;
+    @Autowired
+    JavaMailSender mailSender;
+    @Autowired
+    private TicketAssignedRepository ticketAssignedRepository;
     @RequestMapping(value = "/lead", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
     @ApiImplicitParams({
             @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
     public ResponseEntity<?> LeadUser(HttpServletRequest request,
                                       @RequestBody CreateRefferalRequest createRefferalRequest) throws Exception {
+                    }
                     ptams.add(ptam);
+                }
+                List<Position> positions = positionRepository.selectPositionByAuthId(authUser.getId()).stream().collect(Collectors.toList());
+                LOGGER.info("positions {}", positions);
+                boolean isRBMAndL1 = positions.stream()
+                        .anyMatch(position ->
+                                ProfitMandiConstants.TICKET_CATEGORY_RBM == position.getCategoryId()
+                                        &&  EscalationType.L1.equals(position.getEscalationType()));
+                boolean isRBMAndNotL1 = positions.stream()
+                        .anyMatch(position ->
+                                ProfitMandiConstants.TICKET_CATEGORY_RBM == position.getCategoryId()
+                                        &&  !EscalationType.L1.equals(position.getEscalationType()));
+                LOGGER.info("isRBMAndL1{}",isRBMAndL1);
+                boolean isSales = positions.stream()
+                        .anyMatch(position ->
+                                ProfitMandiConstants.TICKET_CATEGORY_SALES == position.getCategoryId());
                 tm.setTotalPartnerTargetCollection(totalPartnerTargetCollection);
                 tm.setTotalPartnerTargetSecondary(totalPartnerTargetSecondary);
                 tm.setTotalPartnerSecondary(totalPartnerAchievementSecondary);
                 tm.setTotalPartnerCollection(totalPartnerAchievementCollection);
                 tm.setTodayCollectionCount((int) todayCollectionCount);
+                List<PartnerTargetAchievementModel> filteredPtams;
+                if (isRBMAndL1) {
+                    filteredPtams = ptams.stream()
+                            .filter(ptam -> !(CollectionRemark.RBM_ESCALATION.equals(ptam.getRemark()) || CollectionRemark.SALES_ESCALATION.equals(ptam.getRemark())))
+                            .collect(Collectors.toList());
+                } else if (isRBMAndNotL1) {
+                    filteredPtams = ptams.stream()
+                            .filter(ptam -> !(CollectionRemark.SALES_ESCALATION.equals(ptam.getRemark())))
+                            .collect(Collectors.toList());
+                } else {
+                    filteredPtams = ptams;
+                }
-                tm.setTargetAchievement(ptams.stream().sorted(Comparator.comparing(PartnerTargetAchievementModel::getRank))
+                tm.setTargetAchievement(filteredPtams.stream().sorted(Comparator.comparing(PartnerTargetAchievementModel::getRank))
                         .collect(Collectors.toList()));
+            }
+        }
         return responseSender.ok(tm);
+    }
     //TODO:Amit
         return responseSender.ok(true);
+    }
-    @RequestMapping(value = "/viewTickets", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
-    @ApiImplicitParams({
-            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
-    public ResponseEntity<?> viewTickets(HttpServletRequest request, @RequestParam int fofoId)
-            throws ProfitMandiBusinessException {
-        List<Ticket> tickets = ticketRepository.selectAllOpenTicketByRetailer(fofoId);
-        List<TicketViewModel> viewList = new ArrayList<>();
-        for (Ticket ticket : tickets) {
-            TicketViewModel ticketViewModel = new TicketViewModel();
-            ticketViewModel.setId(ticket.getId());
-            TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());
-            TicketCategory ticketCategory = ticketCategoryRepository.selectById(ticketSubCategory.getCategoryId());
-            ticketViewModel.setCategoryName(ticketCategory.getName());
-            ticketViewModel.setSubCategoryName(ticketSubCategory.getName());
-            ticketViewModel.setCreatedTimestamp(ticket.getCreateTimestamp());
-            viewList.add(ticketViewModel);
-        }
-        return responseSender.ok(viewList);
-    }
-    @RequestMapping(value = "/viewRecentTickets", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
-    @ApiImplicitParams({
-            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
-    public ResponseEntity<?> viewRecentTickets(HttpServletRequest request, @RequestParam int fofoId)
-            throws ProfitMandiBusinessException {
-        List<TicketViewModel> viewList = ticketRepository.selectRecentClosedTicket(fofoId,
-                LocalDateTime.now().minusDays(20));
-        return responseSender.ok(viewList);
-    }
-    @RequestMapping(value = "/createTicket", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
-    @ApiImplicitParams({
-            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
-    public ResponseEntity<?> createTicket(HttpServletRequest request) throws ProfitMandiBusinessException {
-        List<TicketCategory> ticketCategories = csService.getAllTicketCategotyFromSubCategory();
-        return responseSender.ok(ticketCategories);
-    }
-    @RequestMapping(value = "/getSubCategoriesByCategoryId", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
-    @ApiImplicitParams({
-            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
-    public ResponseEntity<?> getSubCategoriesByCategoryId(HttpServletRequest request,
-                                                          @RequestParam(name = "categoryId", defaultValue = "0") int categoryId, Model model) {
-        List<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.selectAll(categoryId);
-        LOGGER.info(ticketSubCategories);
-        return responseSender.ok(ticketSubCategories);
-    }
-    @RequestMapping(value = "/createTicket", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
-    @ApiImplicitParams({
-            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
-    public ResponseEntity<?> createTicket(HttpServletRequest request, @RequestParam(name = "categoryId") int categoryId,
-                                          @RequestParam(name = "subCategoryId") int subCategoryId, @RequestParam(name = "message") String message,
-                                          @RequestParam(name = "fofoId") int fofoId) throws Exception {
-        int id = (int) request.getAttribute("userId");
-        LOGGER.info("id" + id);
-        User user = userRepository.selectById(id);
-        AuthUser authUser = authRepository.selectByEmailOrMobile(user.getEmailId());
-        List<Ticket> tickets = ticketRepository.selectAllResolvedMarkedTicketByCreator(fofoId);
-        if (tickets.size() > 3 || tickets.size() == 3) {
-            return responseSender.ok(false);
-        } else {
-            csService.createTicket(fofoId, categoryId, subCategoryId, message);
-            PartnerCollectionRemark pcr = new PartnerCollectionRemark();
-            pcr.setFofoId(fofoId);
-            pcr.setAuthId(authUser.getId());
-            pcr.setMessage("Ticket Created");
-            pcr.setRemark(CollectionRemark.TICKET_CREATED);
-            pcr.setCreateTimestamp(LocalDateTime.now());
-            partnerCollectionRemarkRepository.persist(pcr);
-        }
-        return responseSender.ok(true);
-    }
-    @RequestMapping(value = "/getCollectionRemark", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
-    @ApiImplicitParams({
-            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
-    public ResponseEntity<?> getCollectionRemark(HttpServletRequest request) throws ProfitMandiBusinessException {
-        List<CollectionRemark> remarks = Arrays.asList(CollectionRemark.values()).stream()
-                .filter(x -> !x.equals(CollectionRemark.COLLECTION_PLAN)).collect(Collectors.toList());
-        return responseSender.ok(remarks);
-    }
-    @Autowired
-    RestClient restClient;
-    @Autowired
-    SmartPingService smartPingService;
-    @RequestMapping(value = "/retailer/contacts/{fofoId}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
-    public ResponseEntity<?> getContacts(HttpServletRequest request, @PathVariable int fofoId) throws Exception {
-        return responseSender.ok(retailerService.getContactsByFofoId(fofoId, true));
-    }
-    @RequestMapping(value = "/click2call/{toMobile}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
-    public ResponseEntity<?> makeCallOnAgentBehalf(HttpServletRequest request, @PathVariable String toMobile) throws Exception {
-        int id = (int) request.getAttribute("userId");
-        User user = userRepository.selectById(id);
-        AuthUser authUser = authRepository.selectByEmailOrMobile(user.getEmailId());
-        String fromMobile = authUser.getMobileNumber();
-        SmartPingAgentModel smartPingAgentModel = smartPingService.getAllAgents().get(fromMobile);
-        String urlTemplate = "https://ccs1.smartpingcc.io/v2/clickToCall/para?&user_id=71287091&token=InCfClzwFUtLUW610faI&from=%d&fromType=Agent&fromCLI=&to=%s&toCLI=%s";
-        LOGGER.info("smartPingAgentModel - {}", smartPingAgentModel);
-        String url  = String.format(urlTemplate, smartPingAgentModel.getAgentId(), smartPingAgentModel.getAllowDid().get(0), toMobile, smartPingAgentModel.getAllowDid().get(0));
-        restClient.get(url, null, null);
-        return responseSender.ok(true);
-    }
-    @RequestMapping(value = "/createPartnerColectionRemark", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
-    @ApiImplicitParams({
-            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
-    public ResponseEntity<?> createPartnerCollectionRemark(HttpServletRequest request,
-                                                           @RequestBody PartnerCollectionRemarkModel partnerCollectionRemarkModel)
-            throws ProfitMandiBusinessException {
-        AuthUser authUser = authRepository.selectByGmailId(partnerCollectionRemarkModel.getGmailId());
-        PartnerCollectionRemark pcr = new PartnerCollectionRemark();
-        pcr.setFofoId(partnerCollectionRemarkModel.getFofoId());
-        pcr.setAuthId(authUser.getId());
-        pcr.setMessage(partnerCollectionRemarkModel.getMessage());
-        pcr.setRemark(partnerCollectionRemarkModel.getRemark());
-        pcr.setCreateTimestamp(LocalDateTime.now());
-        partnerCollectionRemarkRepository.persist(pcr);
-        return responseSender.ok(true);
-    }
     @RequestMapping(value = "/uploadFranchiseeVisit", method = RequestMethod.POST)
     public ResponseEntity<?> readCsvFileAndSetLead(HttpServletRequest request, @RequestPart MultipartFile multipartFile)
             throws Throwable {
         int id = (int) request.getAttribute("userId");
         // ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
         List<List<?>> rows = new ArrayList<>();
-        org.apache.commons.io.output.ByteArrayOutputStream byteArrayOutputStream = FileUtil
+        ByteArrayOutputStream byteArrayOutputStream = FileUtil
                 .getCSVByteStream(Arrays.asList("Partner Id", "Agenda", "Schedule Timestamp"), rows);
         try {
             byteArrayOutputStream.close();
         } catch (IOException e) {

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/LeadController.java – Rev 32747 → 32923