Subversion Repositories SmartDukaan

import java.time.LocalDateTime;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.HashMap;

import java.util.HashSet;

import java.util.LinkedHashSet;

import java.util.List;

import java.util.Map;

import java.util.Set;

import java.util.stream.Collectors;

import org.apache.commons.collections4.map.HashedMap;

import org.apache.commons.lang.RandomStringUtils;

import org.apache.commons.lang.StringUtils;

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.mail.javamail.JavaMailSender;

import org.springframework.stereotype.Component;

import com.spice.profitmandi.dao.entity.cs.Activity;

import com.spice.profitmandi.dao.entity.cs.PartnerRegion;

import com.spice.profitmandi.dao.entity.cs.Position;

import com.spice.profitmandi.dao.entity.cs.Ticket;

import com.spice.profitmandi.dao.entity.cs.TicketAssigned;

import com.spice.profitmandi.dao.entity.cs.TicketCategory;

import com.spice.profitmandi.dao.entity.cs.TicketSubCategory;

import com.spice.profitmandi.dao.entity.fofo.FofoStore;

import com.spice.profitmandi.dao.model.FofoReportingModel;

				.collect(Collectors.toList());

	private class SaleRoles {

		private List<String> l1;

		private List<String> l2;

		public SaleRoles() {

			l1 = new ArrayList<>();

			l2 = new ArrayList<>();

		}

		public List<String> getL1() {

			return l1;

		}

		public List<String> getL2() {

			return l2;

		}

	}

	@Override

	@Cacheable(value = "partnerSaleHeader", cacheManager = "oneDayCacheManager")

	public Map<Integer, FofoReportingModel> getPartnerIdSalesHeaders() {

		Map<String, SaleRoles> partnerEmailSalesMap = new HashMap<>();

		List<Position> positions = positionRepository

				.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES);

		Map<Integer, AuthUser> authUsersMap = authRepository.selectAllActiveUser().stream()

				.collect(Collectors.toMap(x -> x.getId(), x -> x));

		Map<Integer, List<CustomRetailer>> positionIdRetailerMap = this.getPositionCustomRetailerMap(positions);

		for (Position position : positions) {

			List<CustomRetailer> crList = positionIdRetailerMap.get(position.getId());

			if (crList == null)

				continue;

			for (CustomRetailer cr : crList) {

				if (!partnerEmailSalesMap.containsKey(cr.getEmail())) {

					partnerEmailSalesMap.put(cr.getEmail(), new SaleRoles());

				}

				SaleRoles saleRoles = partnerEmailSalesMap.get(cr.getEmail());

				AuthUser authUser = authUsersMap.get(position.getAuthUserId());

				if (authUser == null) {

					continue;

				}

				String name = authUser.getFirstName() + " " + authUser.getLastName();

				if (position.getEscalationType().equals(EscalationType.L1)) {

					saleRoles.getL1().add(name);

				} else if (position.getEscalationType().equals(EscalationType.L2)) {

					saleRoles.getL2().add(name);

				}

			}

		}

		Set<CustomRetailer> allCrList = new HashSet<>();

		for (List<CustomRetailer> cr : positionIdRetailerMap.values()) {

			allCrList.addAll(cr);

		}

		Map<Integer, FofoStore> fofoStoresMap = fofoStoreRepository.selectActiveStores().stream()

				.collect(Collectors.toMap(x -> x.getId(), x -> x));

		Map<Integer, FofoReportingModel> partnerIdSalesHeadersMap = new HashMap<>();

		for (CustomRetailer cr : allCrList) {

			FofoStore fofoStore = fofoStoresMap.get(cr.getPartnerId());

			if (fofoStore == null) {

				LOGGER.info("Could not find Store {} in active Store", cr.getBusinessName());

				continue;

			}

			String code = fofoStore.getCode();

			// String storeName = "SmartDukaan-" +

			// fofoStore.getCode().replaceAll("[a-zA-Z]", "");

			String businessName = cr.getBusinessName();

			try {

				String stateManager = StringUtils.join(partnerEmailSalesMap.get(cr.getEmail()).getL2(), ", ");

				String territoryManager = StringUtils.join(partnerEmailSalesMap.get(cr.getEmail()).getL1(), ", ");

				FofoReportingModel reportingModel = new FofoReportingModel();

				reportingModel.setBusinessName(businessName);

				reportingModel.setCode(code);

				reportingModel.setFofoId(fofoStore.getId());

				reportingModel.setRegionalManager(stateManager);

				reportingModel.setTerritoryManager(territoryManager);

				partnerIdSalesHeadersMap.put(fofoStore.getId(), reportingModel);

			} catch (Exception e) {

				LOGGER.warn("Could not find partner with email - {}", cr.getEmail());

			}

		}

		return partnerIdSalesHeadersMap;

	}