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.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
 import javax.transaction.Transactional;
 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.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.ChartInvestmentModel;
 import com.spice.profitmandi.common.model.Data;
 import com.spice.profitmandi.common.model.DataInvestmentModel;
 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.cs.Position;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
 import com.spice.profitmandi.dao.entity.user.Lead;
 import com.spice.profitmandi.dao.entity.user.LeadActivity;
 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.DataLeadModel;
+import com.spice.profitmandi.dao.model.LeadIvoryModel;
 import com.spice.profitmandi.dao.model.LeadStatusData;
+import com.spice.profitmandi.dao.model.StateGstRateModel;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.cs.PositionRepository;
 import com.spice.profitmandi.dao.repository.dtr.LeadActivityRepository;
 import com.spice.profitmandi.dao.repository.dtr.LeadRepository;
 import com.spice.profitmandi.dao.repository.inventory.StateRepository;
 	@Autowired
 	private Gson gson;
 	@Autowired
 	private CookiesProcessor cookiesProcessor;
 	@Autowired
 	PositionRepository positionRepository;
 	@Autowired
 	private MVCResponseSender mvcResponseSender;
 	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 = "followUp") List<LeadStatus> leadStatus,
+			@RequestParam(name = "leadStatus", required = false, defaultValue = "All") List<LeadStatus> leadStatus,
 			@RequestParam(name = "color", required = false, defaultValue = "") List<String> color, Model model)
 			throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		String emailId = loginDetails.getEmailId();
 		AuthUser authUser = authRepository.selectByEmailOrMobile(emailId);
-	boolean authPositon  = 	positionRepository.hasCategory(authUser.getId(),ProfitMandiConstants.TICKET_CATEGORY_SALES);
+		boolean authPositon = positionRepository.hasCategory(authUser.getId(),
+				ProfitMandiConstants.TICKET_CATEGORY_SALES);
 		if (leadStatus.contains(LeadStatus.All)) {
 			leadStatus.addAll(Arrays.asList(LeadStatus.values()));
+		}
 		if (!color.isEmpty()) {
 			if (color.contains("All")) {
 				color.add("yellow");
 				color.add("green");
+			}
-			if(authPositon)
+			if (authPositon) {
-			{
 				authUserIds = authService.getAllReportees(authUser.getId());
 				authUserIds.add(authUser.getId());
 				LOGGER.info("authIds" + authUserIds);
-			leads = leadRepository.selectAllByColorStatusAndUpdatedTimestampAndAuthIds(leadStatus, authUserIds, color,
+				leads = leadRepository.selectAllByColorStatusAndUpdatedTimestampAndAuthIds(leadStatus, authUserIds,
-					LocalDateTime.now().withDayOfMonth(1).minusMonths(3));
+						color, LocalDateTime.now().withDayOfMonth(1).minusMonths(3));
-			}
-			else {
+			} else {
 				leads = leadRepository.selectAllByColorStatusAndUpdatedTimestamp(leadStatus, color,
 						LocalDateTime.now().withDayOfMonth(1).minusMonths(3));
+			}
 		} else {
-			if(authPositon) {
+			if (authPositon) {
 				authUserIds = authService.getAllReportees(authUser.getId());
 				authUserIds.add(authUser.getId());
 				LOGGER.info("authIds" + authUserIds);
-				leads =	leadRepository.selectAllByStatusAndUpdatedTimestampAndAuthId(leadStatus,
+				leads = leadRepository.selectAllByStatusAndUpdatedTimestampAndAuthId(leadStatus,
-						LocalDateTime.now().withDayOfMonth(1).minusMonths(3),authUserIds);
+						LocalDateTime.now().withDayOfMonth(1).minusMonths(3), authUserIds);
-			}
-			else {
+			} else {
-			leads = leadRepository.selectAllByStatusAndUpdatedTimestamp(leadStatus,
+				leads = leadRepository.selectAllByStatusAndUpdatedTimestamp(leadStatus,
-					LocalDateTime.now().withDayOfMonth(1).minusMonths(3));
+						LocalDateTime.now().withDayOfMonth(1).minusMonths(3));
+			}
 			// List<Lead> leads = leadRepository.selectAllBylistStatus(leadStatus);
 			if (!leads.isEmpty()) {
 				leads.addAll(leadRepository.selectAllByStatus(LeadStatus.pending));
+			}
+		}
-		if(authPositon && authUserIds.size() > 0) {
+		if (authPositon && authUserIds.size() > 0) {
 			List<String> leadCreators = new ArrayList<>();
 			leadCreators.add("daily-sync");
-			leadCreators.addAll(authRepository.selectAllAuthUserByIds(authUserIds).stream().map(x->x.getFullName()).collect(Collectors.toList()));
+			leadCreators.addAll(authRepository.selectAllAuthUserByIds(authUserIds).stream().map(x -> x.getFullName())
+					.collect(Collectors.toList()));
 			model.addAttribute("leadCreators", leadCreators);
+		}
 		List<Lead> weekLast = new ArrayList<>();
 		List<Lead> weekThird = new ArrayList<>();
 		List<Lead> weekSecond = new ArrayList<>();
 		List<Lead> weekFirst = new ArrayList<>();
 		LocalDateTime curDate = LocalDate.now().atStartOfDay();
 		List<LeadWeakWiseModel> lwDays = new ArrayList<>();
 		for (int i = 7; i >= 1; i--) {
 			LocalDateTime startOfDay = curDate.minusDays(i);
 			LeadWeakWiseModel lm = new LeadWeakWiseModel();
 			lm.setMonth(startOfDay.toLocalDate());
 			lwDays.add(lm);
+		}
-      if(!leads.isEmpty())
+		if (!leads.isEmpty()) {
-      {
-		for (Lead lead : leads) {
+			for (Lead lead : leads) {
-			if (lead.getCreatedTimestamp().isAfter(curDate.minusDays(28))
+				if (lead.getCreatedTimestamp().isAfter(curDate.minusDays(28))
-					&& lead.getCreatedTimestamp().isBefore(curDate.minusDays(21))) {
+						&& lead.getCreatedTimestamp().isBefore(curDate.minusDays(21))) {
-				weekLast.add(lead);
+					weekLast.add(lead);
-			} else if(lead.getCreatedTimestamp().isAfter(curDate.minusDays(21))
+				} else if (lead.getCreatedTimestamp().isAfter(curDate.minusDays(21))
-					&& lead.getCreatedTimestamp().isBefore(curDate.minusDays(14))) {
+						&& lead.getCreatedTimestamp().isBefore(curDate.minusDays(14))) {
-				weekThird.add(lead);
+					weekThird.add(lead);
-			} else if (lead.getCreatedTimestamp().isAfter(curDate.minusDays(14))
+				} else if (lead.getCreatedTimestamp().isAfter(curDate.minusDays(14))
-					&& lead.getCreatedTimestamp().isBefore(curDate.minusDays(7))) {
+						&& lead.getCreatedTimestamp().isBefore(curDate.minusDays(7))) {
-				weekSecond.add(lead);
+					weekSecond.add(lead);
-			} else if (lead.getCreatedTimestamp().isAfter(curDate.minusDays(7))) {
+				} else if (lead.getCreatedTimestamp().isAfter(curDate.minusDays(7))) {
-				weekFirst.add(lead);
+					weekFirst.add(lead);
-			}
+				}
+			}
+		}
-	}
 		LOGGER.info("weekLast" + weekLast);
 		LOGGER.info("weekThird" + weekThird);
 		LOGGER.info("weekSecond" + weekSecond);
+		Map<String, Long> leadLasts = weekLast.stream()
-		Map<String, Long> leadLasts = weekLast.stream().collect(Collectors.groupingBy(x -> x.getCreatedBy(), Collectors.counting()));
+				.collect(Collectors.groupingBy(x -> x.getCreatedBy(), Collectors.counting()));
+		Map<String, Long> leadThirds = weekThird.stream()
-		Map<String, Long> leadThirds = weekThird.stream().collect(Collectors.groupingBy(x -> x.getCreatedBy(), Collectors.counting()));
+				.collect(Collectors.groupingBy(x -> x.getCreatedBy(), Collectors.counting()));
 		Map<String, Long> leadSeconds = weekSecond.stream().collect(Collectors.groupingBy(x -> x.getCreatedBy(),
 				Collectors.mapping(Lead::getCreatedBy, Collectors.counting())));
 		Map<String, Map<LocalDate, Long>> leadFirsts = weekFirst.stream()
 				.collect(Collectors.groupingBy(x -> x.getCreatedBy(),
 		LOGGER.info("leads" + leads);
 		List<String> stateNames = stateRepository.selectAll().stream().map(x -> x.getName())
 				.collect(Collectors.toList());
 		List<AuthUser> authUsers = authRepository.selectAllActiveUser();
 		LocalDate lastDate = curDate.minusDays(1).toLocalDate();
 		List<LocalDate> weekDates = new ArrayList<>();
 		weekDates.add(curDate.minusDays(28).toLocalDate());
 		weekDates.add(curDate.minusDays(22).toLocalDate());
 		weekDates.add(curDate.minusDays(21).toLocalDate());
 		weekDates.add(curDate.minusDays(15).toLocalDate());
 		weekDates.add(curDate.minusDays(14).toLocalDate());
 		weekDates.add(curDate.minusDays(8).toLocalDate());
 		weekDates.add(curDate.minusDays(7).toLocalDate());
 		LOGGER.info("lastDate" + lastDate);
 		model.addAttribute("weekDates", weekDates);
 		model.addAttribute("lastDate", lastDate);
 		model.addAttribute("stateNames", stateNames);
 		model.addAttribute("authUsers", authUsers);
 		model.addAttribute("lead", leads);
 		model.addAttribute("leadStatus", LeadStatus.values());
 		model.addAttribute("leadLasts", leadLasts);
 		model.addAttribute("leadThirds", leadThirds);
 		model.addAttribute("leadSeconds", leadSeconds);
 		model.addAttribute("leadFirsts", leadFirsts);
 		model.addAttribute("lwDays", lwDays);
+		model.addAttribute("colors", color);
 		model.addAttribute("selectedLeadStatus", leadStatus.get(0));
 		return "lead";
+	}
 	public ChartLeadModel getLeadChart(List<Lead> leads) throws ProfitMandiBusinessException {
 		Map<LeadStatus, Long> leadStatusMap = leads.stream().collect(
 				Collectors.groupingBy(x -> x.getStatus(), Collectors.mapping(Lead::getStatus, Collectors.counting())));
+		Map<String, Long> hotLeadsMap = leads.stream().collect(
+				Collectors.groupingBy(x -> x.getColor(), Collectors.mapping(Lead::getColor, Collectors.counting())));
+		LOGGER.info("hotLeadsMap" + hotLeadsMap);
 		ChartLeadModel cm = new ChartLeadModel();
 		HashSet<LeadStatus> labels = new HashSet<LeadStatus>();
 		labels.addAll(leadStatusMap.keySet());
+		HashSet<String> hotLeads = new HashSet<String>();
+		hotLeads.addAll(leadStatusMap.keySet().stream().map(x -> x.toString()).collect(Collectors.toSet()));
+		hotLeads.add("HotLead");
+		HashSet<String> hotLeadKeys = new HashSet<String>();
+		hotLeadKeys.add("HotLead");
+		List<String> hotLeadGreen = new ArrayList<>(hotLeadKeys);
 		List<LeadStatus> labelList = new ArrayList<>(labels);
 		List<String> backgroundColor = new ArrayList<>();
+		LOGGER.info("hotLeadKeys" + hotLeadKeys);
 		List<Long> values = new ArrayList<>();
 		for (LeadStatus label : labelList) {
 			values.add(leadStatusMap.get(label));
 			if (label.equals(LeadStatus.followUp)) {
 				backgroundColor.add("#9ACD32");
+			}
 			if (label.equals(LeadStatus.finalized)) {
 				backgroundColor.add("blue");
+			}
+		}
+		for ( String hotLeadList : hotLeadGreen){
+			if(hotLeadList.equals("HotLead"))
+			{
+				backgroundColor.add("green");
+				values.add(hotLeadsMap.get("Green"));
+			}
+		}
 		LOGGER.info("labelList" + labelList);
 		LOGGER.info("backgroundColor" + backgroundColor);
 		LOGGER.info("labelsChartLead" + labels);
 		List<LeadStatusData> dataList = new ArrayList<>();
 		dataList.add(data);
 		DataLeadModel datasets = new DataLeadModel();
 		datasets.setDatasets(dataList);
-		datasets.setLabels(labels);
+		datasets.setLabels(hotLeads);
 		OptionModel om = new OptionModel();
 		om.setLegend(legend);
 		cm.setType("pie");
 		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 		return "response";
+	}
+	@RequestMapping(value = "/downloadIvoryLead", method = RequestMethod.GET)
+	public ResponseEntity<?> downloadDelayDayTemplate(HttpServletRequest request) throws Exception {
+		List<List<?>> rows = new ArrayList<>();
+		org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil
+				.getCSVByteStream(Arrays.asList("created_time", "Name", "email","Mobile","state","city"), rows);
+		final HttpHeaders headers = new HttpHeaders();
+		headers.set("Content-Type", "text/csv");
+		headers.set("Content-disposition", "inline; filename=Ivory.format.csv");
+		headers.setContentLength(baos.toByteArray().length);
+		final InputStream inputStream = new ByteArrayInputStream(baos.toByteArray());
+		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
+		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
+	}
+	@RequestMapping(value = "/csvFileAndSetLead", method = RequestMethod.POST)
+	public String readCsvFileAndSetLead(HttpServletRequest request, Model model, HttpServletResponse response,
+			@RequestPart MultipartFile file) throws Throwable {
+		LOGGER.info("file" + file.toString());
+		String fileName = file.getName();
+		String fileNames = file.getOriginalFilename();
+		LOGGER.info("fileName" + fileName);
+		LOGGER.info("fileNames" + fileNames);
+		List<LeadIvoryModel> leadIvoryModels = leadActivityRepository.readFile(file);
+		LOGGER.info("sgtFileName" + leadIvoryModels);
+		if (leadIvoryModels.isEmpty()) {
+			return "";
+		}
+		for (LeadIvoryModel leadIvoryModel : leadIvoryModels) {
+			Lead lead = new Lead();
+			lead.setFirstName(leadIvoryModel.getFirstName());
+			lead.setLastName("");
+			lead.setLeadMobile(leadIvoryModel.getMobile());
+			lead.setState(leadIvoryModel.getState());
+			lead.setCity(leadIvoryModel.getCity());
+			lead.setAddress("NOT AVAILABLE");
+			AuthUser authUser = authRepository.selectById(4);
+			if(leadIvoryModel.getCreatedTime() != null) {
+			lead.setCreatedTimestamp(leadIvoryModel.getCreatedTime());
+			}
+			else
+			{
+				lead.setCreatedTimestamp(LocalDateTime.now());
+			}
+			lead.setUpdatedTimestamp(LocalDateTime.now());
+			lead.setStatus(LeadStatus.pending);
+			lead.setAssignTo(authUser.getId());
+			lead.setSource("IVORY");
+			lead.setColor("yellow");
+			// change
+			String authUserName = authUser.getFirstName() + " " + authUser.getLastName();
+			lead.setCreatedBy(authUserName);
+			lead.setAuthId(authUser.getId());
+			leadRepository.persist(lead);
+			LeadActivity leadActivity = new LeadActivity();
+			leadActivity.setLeadId(lead.getId());
+			leadActivity.setRemark("Internet");
+			leadActivity.setSchelduleTimestamp(null);
+			leadActivity.setCreatedTimestamp(LocalDateTime.now());
+			leadActivityRepository.persist(leadActivity);
+			model.addAttribute("response", mvcResponseSender.createResponseString(true));
+		}
+		model.addAttribute("responseSTG", mvcResponseSender.createResponseString(true));
+		return "response";
+	}
+}

Subversion Repositories SmartDukaan

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