Subversion Repositories SmartDukaan

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

    private class RBMRoles {

        private List<String> l1;

        private List<String> l2;

        private List<String> l3;

        private List<String> l4;

        public RBMRoles() {

            l1 = new ArrayList<>();

            l2 = new ArrayList<>();

            l3 = new ArrayList<>();

            l4 = new ArrayList<>();

        }

        public List<String> getL1() {

            return l1;

        }

        public List<String> getL2() {

            return l2;

        }

        public List<String> getL3() {

            return l3;

        }

        public List<String> getL4() {

            return l4;

        }

        @Override

        public String toString() {

            return "RBMRoles [l1=" + l1 + ", l2=" + l2 + ", l3=" + l3 + ", l4=" + l4 + "]";

        }

    }

    @Override

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

    public Map<Integer, FofoRBMReportingModel> getPartnerIdRBMHeaders() {

        Map<String, RBMRoles> partnerEmailRbmMap = new HashMap<>();

        List<Position> positions = positionRepository.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM);

        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 (!partnerEmailRbmMap.containsKey(cr.getEmail())) {

                    partnerEmailRbmMap.put(cr.getEmail(), new RBMRoles());

                }

                RBMRoles rbmRole = partnerEmailRbmMap.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)) {

                    rbmRole.getL1().add(name);

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

                    rbmRole.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, FofoRBMReportingModel> partnerIdRbmHeadersMap = 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 L2User = StringUtils.join(partnerEmailRbmMap.get(cr.getEmail()).getL2(), ", ");

                String L1USer = StringUtils.join(partnerEmailRbmMap.get(cr.getEmail()).getL1(), ", ");

                if (StringUtils.isEmpty(L1USer)) {

                    L1USer = StringUtils.join(partnerEmailRbmMap.get(cr.getEmail()).getL2(), ", ");

                }

                FofoRBMReportingModel reportingModel = new FofoRBMReportingModel();

                reportingModel.setBusinessName(businessName);

                reportingModel.setCode(code);

                reportingModel.setFofoId(fofoStore.getId());

                reportingModel.setL1Manager(L2User);

                reportingModel.setL2Manager(L1USer);

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

            } catch (Exception e) {

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

            }

        }

        return partnerIdRbmHeadersMap;

    }