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

 package com.spice.profitmandi.web.controller;
+import java.io.ByteArrayInputStream;
+import java.io.InputStream;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.TreeMap;
+import java.util.stream.Collectors;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import javax.transaction.Transactional;
+import org.apache.commons.csv.CSVRecord;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.io.InputStreamResource;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Controller;
+import org.springframework.ui.Model;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RequestPart;
+import org.springframework.web.multipart.MultipartFile;
 import com.google.gson.Gson;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
+import com.spice.profitmandi.common.model.CustomRetailer;
-import com.spice.profitmandi.common.model.*;
+import com.spice.profitmandi.common.model.Legend;
+import com.spice.profitmandi.common.model.OptionModel;
+import com.spice.profitmandi.common.model.PieLables;
+import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.util.FileUtil;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
 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.cs.EscalationType;
+import com.spice.profitmandi.dao.enumuration.dtr.CommunicationType;
 import com.spice.profitmandi.dao.enumuration.dtr.LeadSource;
 import com.spice.profitmandi.dao.enumuration.dtr.LeadStatus;
+import com.spice.profitmandi.dao.model.ChartLeadModel;
+import com.spice.profitmandi.dao.model.CreateLeacdActivityRequest;
+import com.spice.profitmandi.dao.model.CreateRefferalRequest;
-import com.spice.profitmandi.dao.model.*;
+import com.spice.profitmandi.dao.model.DataLeadModel;
+import com.spice.profitmandi.dao.model.DateRangeModel;
+import com.spice.profitmandi.dao.model.LeadStatusData;
+import com.spice.profitmandi.dao.model.PartnerCollectionPlanModel;
+import com.spice.profitmandi.dao.model.RBMPerformanceSummaryModel;
+import com.spice.profitmandi.dao.model.TeamCommitmentModel;
+import com.spice.profitmandi.dao.model.TotalTargetColectionModel;
+import com.spice.profitmandi.dao.model.UserVisitModel;
+import com.spice.profitmandi.dao.model.VisitDescriptionModel;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.auth.PartnerCollectionPlanRepository;
 import com.spice.profitmandi.dao.repository.auth.PartnerCollectionRemarkRepository;
 import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.cs.PositionRepository;
 import com.spice.profitmandi.service.PartnerCollectionService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.web.model.LoginDetails;
 import com.spice.profitmandi.web.util.CookiesProcessor;
 import com.spice.profitmandi.web.util.MVCResponseSender;
-import org.apache.commons.csv.CSVRecord;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.core.io.InputStreamResource;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
-import org.springframework.stereotype.Controller;
-import org.springframework.ui.Model;
-import org.springframework.util.StringUtils;
-import org.springframework.web.bind.annotation.*;
-import org.springframework.web.multipart.MultipartFile;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-import javax.transaction.Transactional;
-import java.io.ByteArrayInputStream;
-import java.io.InputStream;
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-import java.time.format.DateTimeFormatter;
-import java.util.*;
-import java.util.stream.Collectors;
 @Controller
 @Transactional(rollbackOn = Throwable.class)
 public class LeadController {
 	private static final Logger LOGGER = LogManager.getLogger(LeadController.class);
 	private FranchiseeVisitRepository franchiseeVisitRepository;
 	@Autowired
 	private FranchiseeActivityRepository franchiseeActivityRepository;
+	@Autowired
+	private VisitRequestRepository visitRequestRepository;
 	List<LeadStatus> status = Arrays.asList(LeadStatus.notInterested, LeadStatus.finalized);
 	@RequestMapping(value = "/getOpenLead", method = RequestMethod.GET)
 	public String getOpenLead(HttpServletRequest request,
 			@RequestParam(name = "leadStatus", required = false, defaultValue = "All") List<LeadStatus> leadStatus,
 		model.addAttribute("weekDates", weekDates);
 		model.addAttribute("leadDate", leadDate);
 		model.addAttribute("lastDate", lastDate);
 		model.addAttribute("stateNames", stateNames);
+		model.addAttribute("communicationTypes", CommunicationType.values());
 		model.addAttribute("authUsers", authUsers);
 		model.addAttribute("lead", leads);
 		model.addAttribute("leadStatus", LeadStatus.values());
 		model.addAttribute("leadLasts", leadLasts);
 		model.addAttribute("leadThirds", leadThirds);
+	}
 	@RequestMapping(value = "/getLeadActivity", method = RequestMethod.GET)
 	public String getLeadActivity(HttpServletRequest request, @RequestParam int leadId, Model model) throws Exception {
 		List<LeadActivity> leadActivity = leadActivityRepository.selectBYLeadId(leadId);
+		LOGGER.info("leadActivity" + leadActivity);
 		model.addAttribute("leadActivity", leadActivity);
+		model.addAttribute("authUserMap",
+				authRepository.selectAllActiveUser().stream().collect(Collectors.toMap(x -> x.getId(), x -> x)));
 		return "lead_activity_modal";
+	}
 	@RequestMapping(value = "/createLead", method = RequestMethod.POST)
 	public String CreateLead(HttpServletRequest request, @RequestBody CreateRefferalRequest createRefferalRequest,
 			Model model) throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		LOGGER.info("createRefferalRequest" + createRefferalRequest.getSchelduleTimestamp());
 		Lead lead = new Lead();
 		lead.setFirstName(createRefferalRequest.getFirstName());
 		lead.setLastName(createRefferalRequest.getLastName());
 		lead.setLeadMobile(createRefferalRequest.getMobile());
 		leadRepository.persist(lead);
 		LeadActivity leadActivity = new LeadActivity();
 		leadActivity.setLeadId(lead.getId());
 		leadActivity.setRemark(createRefferalRequest.getRemark());
+		leadActivity.setAuthId(authUser.getId());
+		LOGGER.info("createRefferalRequest" + createRefferalRequest.getCommunicationType());
 		if (createRefferalRequest.getStatus() == LeadStatus.followUp) {
 			leadActivity.setSchelduleTimestamp(createRefferalRequest.getSchelduleTimestamp());
+			leadActivity.setCommunicationType(createRefferalRequest.getCommunicationType());
+			if (leadActivity.getCommunicationType().equals(CommunicationType.VISIT)) {
+				visitRequestRepository.createVisitRequest(lead.getId(), "lead", lead.getAssignTo(),
+						createRefferalRequest.getSchelduleTimestamp());
+			}
 		} else {
 			leadActivity.setSchelduleTimestamp(null);
+		}
 		leadActivity.setCreatedTimestamp(LocalDateTime.now());
 		leadActivityRepository.persist(leadActivity);
-		model.addAttribute("response1", mvcResponseSender.createResponseString(true));
+		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
 	@RequestMapping(value = "/editLead", method = RequestMethod.POST)
 	public String EditLead(HttpServletRequest request,
 			@RequestBody CreateLeacdActivityRequest createLeadActivityRequest, Model model) throws Exception {
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
 		LeadActivity leadActivity = new LeadActivity();
 		leadActivity.setLeadId(createLeadActivityRequest.getId());
 		leadActivity.setRemark(createLeadActivityRequest.getRemark());
 		LOGGER.info("createRefferalRequest" + createLeadActivityRequest);
 		if (createLeadActivityRequest.getStatus() == LeadStatus.followUp) {
 			leadActivity.setSchelduleTimestamp(createLeadActivityRequest.getScheldule());
+			leadActivity.setCommunicationType(createLeadActivityRequest.getCommunicationType());
+			if (leadActivity.getCommunicationType().equals(CommunicationType.VISIT)) {
+				visitRequestRepository.createVisitRequest(createLeadActivityRequest.getId(), "lead",
+						createLeadActivityRequest.getAssignTo(), createLeadActivityRequest.getScheldule());
+			}
 		} else {
 			leadActivity.setSchelduleTimestamp(null);
+		}
 		leadActivity.setCreatedTimestamp(LocalDateTime.now());
+		leadActivity.setAuthId(authUser.getId());
 		leadActivityRepository.persist(leadActivity);
 		Lead lead = leadRepository.selectById(createLeadActivityRequest.getId());
 		lead.setAssignTo(createLeadActivityRequest.getAssignTo());
 		lead.setStatus(createLeadActivityRequest.getStatus());
 		lead.setNotinterestedReason(createLeadActivityRequest.getReason());
+	}
 	@RequestMapping(value = "/indent/today_target", method = RequestMethod.GET)
 	public String todayTarget(HttpServletRequest request, Model model) throws Exception {
-		// model.addAttribute("warehouseCollectionMap", warehouseCollectionMap);
 		List<RBMPerformanceSummaryModel> summaryModels = new ArrayList<>();
 		List<Integer> rbmPositionsAuthIds = positionRepository
 				.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM).stream()
 				.filter(x -> Arrays.asList(EscalationType.L1, EscalationType.L2).contains(x.getEscalationType()))
 				.map(x -> x.getAuthUserId()).distinct().collect(Collectors.toList());
+		}
 		model.addAttribute("summaryModels", summaryModels);
 		return "today_target";
+	}
+	@RequestMapping(value = "/visitPlan", method = RequestMethod.GET)
+	public String visitPlan(HttpServletRequest request, Model model) throws Exception {
+		return "visit-request-plan";
+	}
+	@RequestMapping(value = "/visit/getVisitPlan", method = RequestMethod.GET)
+	public String getVisitPlan(HttpServletRequest request, @RequestParam LocalDate date, Model model) throws Exception {
+		List<VisitRequest> visitRequests = visitRequestRepository.selectByAuthIdAndDate(date);
+		List<Integer> leadIds = visitRequests.stream().filter(x -> x.getVisitType().equals("lead"))
+				.map(x -> x.getVisitId()).collect(Collectors.toList());
+		Map<Integer, Lead> leadMap = new HashMap<>();
+		if (!leadIds.isEmpty()) {
+			List<Lead> leads = leadRepository.selectAllByIds(leadIds);
+			for (Lead lead : leads) {
+				List<LeadActivity> leadActivities = leadActivityRepository.selectBYLeadId(lead.getId());
+				lead.setScheduledTimestamp(leadActivities.get(0).getSchelduleTimestamp());
+				lead.setLeadActivity(leadActivities.get(0));
+				leadMap.put(lead.getId(), lead);
+			}
+		}
+		List<Integer> franchiseeIds = visitRequests.stream().filter(x -> x.getVisitType().equals("franchiseeVisit"))
+				.map(x -> x.getVisitId()).collect(Collectors.toList());
+		Map<Integer, FranchiseeVisit> franchiseeVisitsMap = new HashMap<>();
+		if (!franchiseeIds.isEmpty()) {
+			List<FranchiseeVisit> franchiseeVisits = franchiseeVisitRepository.selectAllByIds(franchiseeIds);
+			LOGGER.info("franchiseeVisits {}", franchiseeVisits);
+			for (FranchiseeVisit franchiseeVisit : franchiseeVisits) {
+				List<FranchiseeActivity> franchiseeActivities = franchiseeActivityRepository
+						.selectByFranchiseeVisitId(franchiseeVisit.getId());
+				LOGGER.info("franchiseeActivities {}", franchiseeActivities);
+				franchiseeVisit.setScheduleTimestamp(franchiseeActivities.get(0).getSchelduleTimestamp());
+				franchiseeVisit.setFranchiseeActivity(franchiseeActivities.get(0));
+				franchiseeVisitsMap.put(franchiseeVisit.getId(), franchiseeVisit);
+			}
+		}
+		Map<Integer, List<VisitRequest>> visitRequestMap = visitRequests.stream()
+				.collect(Collectors.groupingBy(x -> x.getCreatedBy()));
+		List<AuthUser> authUsers = authRepository.selectAllActiveUser();
+		List<UserVisitModel> userVisits = new ArrayList<>();
+		for (AuthUser authUser : authUsers) {
+			List<VisitRequest> authVisitRequests = visitRequestMap.get(authUser.getId());
+			if (authVisitRequests != null) {
+				UserVisitModel userVisitModel = new UserVisitModel();
+				userVisitModel.setAuthUser(authUser.getFullName());
+				List<VisitDescriptionModel> visitDescriptions = new ArrayList<>();
+				for (VisitRequest authVisitRequest : authVisitRequests) {
+					VisitDescriptionModel visitDescriptionModel = new VisitDescriptionModel();
+					visitDescriptionModel.setVisitId(authVisitRequest.getVisitId());
+					if (authVisitRequest.getVisitType().equals("lead")) {
+						Lead lead = leadMap.get(authVisitRequest.getVisitId());
+						visitDescriptionModel.setVisitName(lead.getFirstName());
+						visitDescriptionModel.setCity(lead.getCity());
+						visitDescriptionModel.setState(lead.getState());
+						visitDescriptionModel.setScheduleTime(lead.getScheduledTimestamp());
+						visitDescriptionModel.setRemarks(lead.getLeadActivity().getRemark());
+					} else {
+						FranchiseeVisit franchiseeVisit = franchiseeVisitsMap.get(authVisitRequest.getVisitId());
+						CustomRetailer customRetailer = retailerService.getFofoRetailer(franchiseeVisit.getFofoId());
+						visitDescriptionModel.setVisitName(franchiseeVisit.getPartnerName());
+						visitDescriptionModel.setCity(customRetailer.getAddress().getCity());
+						visitDescriptionModel.setState(customRetailer.getAddress().getState());
+						visitDescriptionModel
+								.setScheduleTime(franchiseeVisit.getFranchiseeActivity().getSchelduleTimestamp());
+						visitDescriptionModel.setRemarks(franchiseeVisit.getAgenda());
+					}
+					if (authVisitRequest.getActionedBy() != 0) {
+						AuthUser au = authRepository.selectById(authVisitRequest.getActionedBy());
+						visitDescriptionModel.setActionBy(au.getFullName());
+					}
+					visitDescriptionModel.setStatus(authVisitRequest.getStatus());
+					visitDescriptionModel.setVisitType(authVisitRequest.getVisitType());
+					visitDescriptions.add(visitDescriptionModel);
+				}
+				userVisitModel.setVisitDescriptions(visitDescriptions);
+				userVisits.add(userVisitModel);
+			}
+		}
+		model.addAttribute("userVisits", userVisits);
+		return "visit-request-plan";
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/LeadController.java – Rev 31238 → 31249