WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/dao/repository/cs/CsServiceImpl.java

 	@Override
 	public void assignTicket(Ticket ticket) throws ProfitMandiBusinessException {
 		TicketAssigned ticketAssigned = null;
 		EscalationType newEscalationType = EscalationType.L1;
-		if(ticket.getAssignmentId()>0) {
+		if (ticket.getAssignmentId() > 0) {
 			ticketAssigned = ticketAssignedRepository.selectById(ticket.getAssignmentId());
 			newEscalationType = ticketAssigned.getEscalationType().next();
 			if (newEscalationType == null || newEscalationType.equals(EscalationType.Final)) {
 				LOGGER.info("Cant escalate further");
 				return;
 			escalationTypeNext = escalationTypeNext.next();
 			// LOGGER.info("Escalation type next {}", escalationTypeNext);
 		} while (!escalationTypeNext.equals(EscalationType.Final));
 		int assigneeAuthId = assigneeUserIds.stream().findFirst().orElse(0);
 		int managerAuthId = 0;
 		EscalationType assigneeEscalationType = null;
 		if (assigneeAuthId == 0) {
 			assigneeAuthId = ProfitMandiConstants.FINAL_AUTH_ID;
 			assigneeEscalationType = EscalationType.Final;
 		ticketAssignedNew.setEscalationType(assigneeEscalationType);
 		ticketAssignedNew.setManagerId(managerAuthId);
 		ticketAssignedNew.setCreateTimestamp(LocalDateTime.now());
 		ticketAssignedRepository.persist(ticketAssignedNew);
 		LOGGER.info(ticketAssigned);
 		AuthUser authUser = authRepository.selectById(ticketAssignedNew.getAssineeId());
 		AuthUser authUserManager = null;
-		//Dont send cc mail if both are same
+		// Dont send cc mail if both are same
-		if (managerAuthId!= assigneeAuthId) {
+		if (managerAuthId != assigneeAuthId) {
 			authUserManager = authRepository.selectById(managerAuthId);
+		}
 		ticket.setAssignmentId(ticketAssignedNew.getId());
-		this.sendAssignedTicketMail(authUser, Arrays.asList(authUserManager), ticket, ticketAssigned!=null);
+		this.sendAssignedTicketMail(authUser, Arrays.asList(authUserManager), ticket, ticketAssigned != null);
 		if (!ticketAssignedNew.getEscalationType().equals(EscalationType.L1)) {
 			this.addActivity(ticket, this.createActivity(ActivityType.ESCALATED,
 					"Ticket ecalated and assigned to " + authUser.getName(), 0));
 		} else {
 			this.addActivity(ticket,
 	@Override
 	public void updateTicket(int categoryId, int subCategoryId, Ticket ticket) throws ProfitMandiBusinessException {
 		TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.getTicketSubCategoryMap().get(subCategoryId);
-		if(ticketSubCategory==null) {
+		if (ticketSubCategory == null) {
-			throw new ProfitMandiBusinessException("Could not find subCategoryId " + subCategoryId + "- " + categoryId, "Problem", "Problem");
+			throw new ProfitMandiBusinessException("Could not find subCategoryId " + subCategoryId + "- " + categoryId,
+					"Problem", "Problem");
+		}
 		String storeName = retailerService.getFofoRetailers(true).get(ticket.getFofoId()).getBusinessName();
-		List<TicketAssigned> oldTicketAssignedList = ticketAssignedRepository.selectByTicketIds(Arrays.asList(ticket.getId()));
+		List<TicketAssigned> oldTicketAssignedList = ticketAssignedRepository
+				.selectByTicketIds(Arrays.asList(ticket.getId()));
-		for(TicketAssigned oldTicketAssigned : oldTicketAssignedList) {
+		for (TicketAssigned oldTicketAssigned : oldTicketAssignedList) {
 			ticketAssignedRepository.delete(oldTicketAssigned);
+		}
 		if (ticket.getSubCategoryId() != ticketSubCategory.getId()) {
 			ticket.setSubCategoryId(ticketSubCategory.getId());
-			List<Integer> oldAssignedAuthUserIds = oldTicketAssignedList.stream().map(x->x.getAssineeId()).collect(Collectors.toList());
+			List<Integer> oldAssignedAuthUserIds = oldTicketAssignedList.stream().map(x -> x.getAssineeId())
+					.collect(Collectors.toList());
-			List<String> oldAssignedEmailIds = authRepository.selectAllAuthUserByIds(oldAssignedAuthUserIds).stream().map(x->x.getEmailId()).collect(Collectors.toList());
+			List<String> oldAssignedEmailIds = authRepository.selectAllAuthUserByIds(oldAssignedAuthUserIds).stream()
+					.map(x -> x.getEmailId()).collect(Collectors.toList());
 			String mailTo = oldAssignedEmailIds.remove(0);
+			String message = String.format(CATEGORY_CHANGED_TICKET, ticket.getId(), storeName,
-			String message = String.format(CATEGORY_CHANGED_TICKET, ticket.getId(),storeName, ticketSubCategory.getTicketCategory().getName() + " - " + ticketSubCategory.getName());
+					ticketSubCategory.getTicketCategory().getName() + " - " + ticketSubCategory.getName());
 			try {
-				Utils.sendMailWithAttachments(mailSender, mailTo, oldAssignedEmailIds.toArray(new String[0]), "Ticket Category/Subcategory Changed",
+				Utils.sendMailWithAttachments(mailSender, mailTo, oldAssignedEmailIds.toArray(new String[0]),
-						message, null);
+						"Ticket Category/Subcategory Changed", message, null);
 			} catch (Exception e) {
 				LOGGER.info("Could not send mail for ticket {}", ticket.toString());
+			}
+		}
 		Activity categoryChangedActivity = this.createActivity(ActivityType.CATEGORY_CHANGED, "Category changed to "
 				+ ticketSubCategory.getTicketCategory().getName() + " - " + ticketSubCategory.getName(), 0);
 		this.addActivity(ticket, categoryChangedActivity);
 		ticket.setAssignmentId(0);
 		this.assignTicket(ticket);
+	}
 	@Override
 	public Activity createActivity(ActivityType activityType, String message, int createdBy) {
 		Activity activity = new Activity();
 			List<AuthUser> authUsers = authRepository.selectAllAuthUserByIds(
 					positions.stream().map(x -> x.getAuthUserId()).collect(Collectors.toList()));
 			authUsers = authUsers.stream().filter(x -> x.isActive()).collect(Collectors.toList());
 			if (authUsers.size() > 0) {
 				authUserId = authUsers.get(0).getId();
+				/*
-				/*Random rand = new Random();
+				 * Random rand = new Random(); authUserId =
-				authUserId = authUsers.get(rand.nextInt(authUsers.size())).getId();*/
+				 * authUsers.get(rand.nextInt(authUsers.size())).getId();
+				 */
+			}
+		}
 		return authUserId;
+	}
 			regionIdAndRegionMap.put(position.getRegionId(), region);
+		}
 		return regionIdAndRegionMap;
+	}
-	private void sendAssignedTicketMail(AuthUser authUserTo, List<AuthUser> authUsersCc, Ticket ticket, boolean isEscalated)
+	private void sendAssignedTicketMail(AuthUser authUserTo, List<AuthUser> authUsersCc, Ticket ticket,
-			throws ProfitMandiBusinessException {
+			boolean isEscalated) throws ProfitMandiBusinessException {
 		try {
 			String[] ccTo = authUsersCc.stream().filter(x -> x != null).map(x -> x.getEmailId()).toArray(String[]::new);
 			String messageFormat = null;
-			if(isEscalated) {
+			if (isEscalated) {
 				messageFormat = ESCALATED_TICKET;
 			} else {
 				messageFormat = ASSIGNED_TICKET;
+			}
 			String message = String.format(messageFormat, authUserTo.getName(), ticket.getId(),
 					retailerService.getFofoRetailer(ticket.getFofoId()).getBusinessName());
-			Utils.sendMailWithAttachments(mailSender, authUserTo.getEmailId(), ccTo, ASSINMENT_SUBJECT,
+			Utils.sendMailWithAttachments(mailSender, authUserTo.getEmailId(), ccTo, ASSINMENT_SUBJECT, message, null);
-					message, null);
 		} catch (Exception e) {
 			e.printStackTrace();
 			throw new ProfitMandiBusinessException("Ticket Assingment", authUserTo.getEmailId(),
 					"Could not send ticket assignment mail");
+		}
 		return emails;
+	}
 	@Override
+	public List<AuthUser> getAuthUserByPartners(int fofoId) {
+		List<AuthUser> authUsers = new ArrayList<>();
+		List<Integer> regionIds = partnerRegionRepository.selectByfofoId(fofoId).stream().map(x -> x.getRegionId())
+				.collect(Collectors.toList());
+		regionIds.add(5);// All partners Id;
+		List<Integer> fofoIds = new ArrayList<>();
+		fofoIds.add(fofoId);
+		fofoIds.add(0);
+		LOGGER.info("fofoIds" + fofoIds);
+		List<Integer> partnerPositionIds = partnersPositionRepository.selectByRegionIdAndPartnerId(regionIds, fofoIds)
+				.stream().map(x -> x.getPositionId()).collect(Collectors.toList());
+		LOGGER.info("partnerPositionIds" + partnerPositionIds);
+		for (Integer partnerPostionId : partnerPositionIds) {
+			Position position = positionRepository.selectByIdAndCategoryId(partnerPostionId,
+					ProfitMandiConstants.TICKET_CATEGORY_SALES);
+			LOGGER.info("position" + position);
+			if (position != null) {
+				AuthUser authUser = authRepository.selectById(position.getAuthUserId());
+				LOGGER.info("authUser" + authUser);
+				authUsers.add(authUser);
+			}
+		}
+		return authUsers;
+	}
+	@Override
 	public Map<EscalationType, String> getAuthUserAndEsclationTypeByPartnerId(int fofoId) {
 		List<String> emails = new ArrayList<>();
 		Map<EscalationType, String> emailEsclationTypeMap = new HashMap<>();
 		List<Integer> regionIds = partnerRegionRepository.selectByfofoId(fofoId).stream().map(x -> x.getRegionId())
 		return l2l1ListMap;
+	}
 	@Override
 	public Map<Integer, List<AuthUser>> getAssignedAuthList(List<Ticket> tickets) {
-		if(tickets.size()==0) {
+		if (tickets.size() == 0) {
 			return new HashMap<>();
+		}
+		List<TicketAssigned> ticketAssignedList = ticketAssignedRepository
-		List<TicketAssigned> ticketAssignedList = ticketAssignedRepository.selectByTicketIds(tickets.stream().map(x->x.getId()).collect(Collectors.toList()));
+				.selectByTicketIds(tickets.stream().map(x -> x.getId()).collect(Collectors.toList()));
-		List<Integer> authUserIds = ticketAssignedList.stream().map(x->x.getAssineeId()).distinct().collect(Collectors.toList());
+		List<Integer> authUserIds = ticketAssignedList.stream().map(x -> x.getAssineeId()).distinct()
+				.collect(Collectors.toList());
-		Map<Integer, AuthUser> authUserMap = authRepository.selectAllAuthUserByIds(authUserIds).stream().collect(Collectors.toMap(x->x.getId(), x->x));
+		Map<Integer, AuthUser> authUserMap = authRepository.selectAllAuthUserByIds(authUserIds).stream()
+				.collect(Collectors.toMap(x -> x.getId(), x -> x));
-		return ticketAssignedList.stream().collect(Collectors.groupingBy(x->x.getTicketId(), Collectors.mapping(x->authUserMap.get(x.getAssineeId()), Collectors.toList())));
+		return ticketAssignedList.stream().collect(Collectors.groupingBy(x -> x.getTicketId(),
+				Collectors.mapping(x -> authUserMap.get(x.getAssineeId()), Collectors.toList())));
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/dao/repository/cs/CsServiceImpl.java – Rev 27410 → 27545