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

 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 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.cache.annotation.Cacheable;
 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.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.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.user.Lead;
 import com.spice.profitmandi.dao.entity.user.LeadActivity;
+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.DataLeadModel;
-import com.spice.profitmandi.dao.model.LeadIvoryModel;
 import com.spice.profitmandi.dao.model.LeadStatusData;
 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;
 			@RequestParam(name = "color", required = false, defaultValue = "") List<String> color,
 			@RequestParam(name = "leadDate", required = false, defaultValue = "") LocalDate leadDate, Model model)
 			throws Exception {
 		LocalDateTime localDateTime = null;
 		LOGGER.info("color" + color);
 		LOGGER.info("leadDate" + leadDate);
 					if (localDateTime == null) {
 						leads = leadRepository.selectAllByStatusAndUpdatedTimestamp(leadStatus,
 								LocalDateTime.now().minusMonths(1));
+					}
 					else {
 						leads = leadRepository.selectAllByStatusAndUpdatedTimestamp(leadStatus, localDateTime);
 		HashSet<String> hotLeadKeys = new HashSet<String>();
 		hotLeadKeys.add("HotLead");
 		List<String> hotLeadGreen = new ArrayList<>(hotLeadKeys);
 		LOGGER.info("hotLeads" + hotLeads);
 		List<LeadStatus> labelList = new ArrayList<>(labels);
 		List<String> backgroundColor = new ArrayList<>();
 		LOGGER.info("hotLeadKeys" + hotLeadKeys);
 		List<Long> values = new ArrayList<>();
 		for (String hotLead : hotLeads) {
 			if (hotLead.equals("pending")) {
 				backgroundColor.add("pink");
 				values.add(leadStatusMap.get(LeadStatus.pending));
+			}
+			}
 			if (hotLead.equals("finalized")) {
 				backgroundColor.add("blue");
 				values.add(leadStatusMap.get(LeadStatus.finalized));
+			}
 			if (hotLead.equals("HotLead")) {
 				backgroundColor.add("green");
 				values.add(hotLeadsMap.get("Green"));
+			}
 			@RequestBody CreateLeacdActivityRequest createLeadActivityRequest, Model model) throws Exception {
 		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());
 		} else {
 			leadActivity.setSchelduleTimestamp(null);
+		}
 		leadActivity.setCreatedTimestamp(LocalDateTime.now());
 		leadActivityRepository.persist(leadActivity);
-        Lead lead = leadRepository.selectById(createLeadActivityRequest.getId());
+		Lead lead = leadRepository.selectById(createLeadActivityRequest.getId());
 		lead.setAssignTo(createLeadActivityRequest.getAssignTo());
 		lead.setStatus(createLeadActivityRequest.getStatus());
 		lead.setNotinterestedReason(createLeadActivityRequest.getReason());
 		lead.setUpdatedTimestamp(LocalDateTime.now());
 		lead = leadRepository.selectById(createLeadActivityRequest.getId());
 		int authId = 0;
 		if (lead != null) {
 			authId = lead.getAssignTo();
 			Map<Integer, LeadActivity> leadActivityMap = new HashMap<>();
-				List<LeadActivity> leadActivitys = leadActivityRepository.selectBYLeadId(lead.getId());
+			List<LeadActivity> leadActivitys = leadActivityRepository.selectBYLeadId(lead.getId());
-				if (!leadActivitys.isEmpty()) {
+			if (!leadActivitys.isEmpty()) {
-					leadActivityMap.put(lead.getId(), leadActivitys.get(0));
+				leadActivityMap.put(lead.getId(), leadActivitys.get(0));
-				}
+			}
-				Map<Integer, AuthUser> authIdAndAuthUserMap = new HashMap<>();
+			Map<Integer, AuthUser> authIdAndAuthUserMap = new HashMap<>();
-				AuthUser AuthUser = authRepository.selectById(authId);
+			AuthUser AuthUser = authRepository.selectById(authId);
-				authIdAndAuthUserMap.put(AuthUser.getId(), AuthUser);
+			authIdAndAuthUserMap.put(AuthUser.getId(), AuthUser);
 			model.addAttribute("leadActivityMap", leadActivityMap);
 			model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);
+		}
 		model.addAttribute("request", lead);
+	}
 	@RequestMapping(value = "/downloadIvoryLead", method = RequestMethod.GET)
 	public ResponseEntity<?> downloadDelayDayTemplate(HttpServletRequest request) throws Exception {
+		List<String> stateNames = stateRepository.selectAll().stream().map(x -> x.getName())
+				.collect(Collectors.toList());
 		List<List<?>> rows = new ArrayList<>();
+		List<LeadSource> lss = LeadSource.enumValues;
+		for (LeadSource ls : lss) {
+			rows.add(Arrays.asList("-", "-", "-", "-", "-", "-", "-", ls));
+		}
+		for (String stateName : stateNames) {
+			rows.add(Arrays.asList("-", "-", "-", "-", stateName, "-", "-", "-"));
+		}
-		org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil
+		org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil.getCSVByteStream(Arrays.asList("First Name",
-				.getCSVByteStream(Arrays.asList("created_time", "Name", "email", "Mobile", "state", "city"), rows);
+				"Last Name", "Address", "City", "State", "Mobile", "Assign To(email)", "Source"), rows);
 		final HttpHeaders headers = new HttpHeaders();
 		headers.set("Content-Type", "text/csv");
-		headers.set("Content-disposition", "inline; filename=Ivory.format.csv");
+		headers.set("Content-disposition", "inline; filename=leads.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 {
+		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		String email = loginDetails.getEmailId();
+		AuthUser createdBy = authRepository.selectByEmailOrMobile(email);
 		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);
+		List<CSVRecord> records = FileUtil.readFile(file);
-		LOGGER.info("sgtFileName" + leadIvoryModels);
-		if (leadIvoryModels.isEmpty()) {
-			return "";
-		}
-		for (LeadIvoryModel leadIvoryModel : leadIvoryModels) {
+		for (CSVRecord record : records) {
 			Lead lead = new Lead();
-			lead.setFirstName(leadIvoryModel.getFirstName());
+			lead.setFirstName(record.get(0));
-			lead.setLastName("");
+			lead.setLastName(record.get(1));
-			lead.setLeadMobile(leadIvoryModel.getMobile());
+			lead.setAddress(record.get(2));
-			lead.setState(leadIvoryModel.getState());
+			lead.setCity(record.get(3));
-			lead.setCity(leadIvoryModel.getCity());
+			lead.setState(record.get(4));
-			lead.setAddress("NOT AVAILABLE");
+			lead.setLeadMobile(record.get(5));
+			LOGGER.info("record" + record.get(6));
-			AuthUser authUser = authRepository.selectById(4);
+			AuthUser assignTo = authRepository.selectByEmailOrMobile(record.get(6));
-			if (leadIvoryModel.getCreatedTime() != null) {
+			if (assignTo == null) {
-				lead.setCreatedTimestamp(leadIvoryModel.getCreatedTime());
+				throw new ProfitMandiBusinessException("Assign To ", record.get(6), "email id not exist");
-			} else {
-				lead.setCreatedTimestamp(LocalDateTime.now());
+			}
+			lead.setAssignTo(assignTo.getId());
+			lead.setSource(record.get(7));
+			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.setCreatedBy(createdBy.getFullName());
-			lead.setAuthId(authUser.getId());
+			lead.setAuthId(createdBy.getId());
 			leadRepository.persist(lead);
 			LeadActivity leadActivity = new LeadActivity();
 			leadActivity.setLeadId(lead.getId());
-			leadActivity.setRemark("Internet");
+			leadActivity.setRemark("New Lead");
 			leadActivity.setSchelduleTimestamp(null);
 			leadActivity.setCreatedTimestamp(LocalDateTime.now());
 			leadActivityRepository.persist(leadActivity);
 			model.addAttribute("response", mvcResponseSender.createResponseString(true));

Subversion Repositories SmartDukaan

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