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

 import com.spice.profitmandi.dao.entity.cs.*;
 import com.spice.profitmandi.dao.entity.fofo.ActivityType;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.enumuration.auth.CollectionRemark;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
-import com.spice.profitmandi.dao.model.ActivityMediaModel;
+import com.spice.profitmandi.dao.model.*;
-import com.spice.profitmandi.dao.model.AuthUserPartnerMapModel;
-import com.spice.profitmandi.dao.model.FofoRBMReportingModel;
-import com.spice.profitmandi.dao.model.FofoReportingModel;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.service.user.RetailerService;
 import org.apache.commons.collections4.map.HashedMap;
 import org.apache.commons.lang.RandomStringUtils;
         LOGGER.info("partnerPositionIds" + partnerPositionIds);
         List<Position> positions = positionRepository.selectAll(partnerPositionIds);
-        positions = positions.stream().filter(x -> (x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_SALES || x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_RBM)).collect(Collectors.toList());
+        positions = positions.stream().filter(x -> (x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_SALES || x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_RBM || x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_ABM)).collect(Collectors.toList());
         if (!positions.isEmpty()) {
             for (Position partnerPostionId : positions) {
                 AuthUser authUser = authRepository.selectById(partnerPostionId.getAuthUserId());
         //LOGGER.info("fofoIds" + fofoIds);
         List<Integer> partnerPositionIds = partnerPositionRepository.selectByRegionIdAndPartnerId(regionIds, fofoIds).stream().map(x -> x.getPositionId()).collect(Collectors.toList());
         //LOGGER.info("partnerPositionIds" + partnerPositionIds);
-        List<Integer> allowedTicketCategoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_RBM);
+        List<Integer> allowedTicketCategoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_RBM,ProfitMandiConstants.TICKET_CATEGORY_ABM);
         List<Position> escalationBasedPositions = positionRepository.selectAll(partnerPositionIds).stream().filter(x -> allowedTicketCategoryIds.contains(x.getCategoryId()) &&
                 Arrays.stream(escalationTypes)
                         .anyMatch(y -> y.equals(x.getEscalationType()))).collect(Collectors.toList());
         return partnerIdSalesHeadersMap;
+    }
+    private class ABMRoles {
+        private List<String> l1;
+        private List<String> l2;
+        private List<String> l3;
+        private List<String> l4;
+        public ABMRoles() {
+            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 "SaleRoles [l1=" + l1 + ", l2=" + l2 + ", l3=" + l3 + ", l4=" + l4 + "]";
+        }
+    }
+    @Override
+    @Cacheable(value = "partnerABMHeader", cacheManager = "oneDayCacheManager")
+    public Map<Integer, FofoAbmReportingModel> getPartnerIdABMHeaders() throws ProfitMandiBusinessException {
+        Map<String, ABMRoles> partnerEmailABMMap = new HashMap<>();
+        List<Position> positions = positionRepository.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_ABM);
+        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 (!partnerEmailABMMap.containsKey(cr.getEmail())) {
+                    partnerEmailABMMap.put(cr.getEmail(), new ABMRoles());
+                }
+                ABMRoles abmRoles = partnerEmailABMMap.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)) {
+                    abmRoles.getL1().add(name);
+                } else if (position.getEscalationType().equals(EscalationType.L2)) {
+                    abmRoles.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, FofoAbmReportingModel> partnerIdAbmHeadersMap = new HashMap<>();
+        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
+        for (Map.Entry<Integer, CustomRetailer> customRetailerEntry : customRetailerMap.entrySet()) {
+            CustomRetailer customRetailer = customRetailerEntry.getValue();
+            String code = customRetailer.getCode();
+            // String storeName = "SmartDukaan-" +
+            // fofoStore.getCode().replaceAll("[a-zA-Z]", "");
+            String businessName = customRetailer.getBusinessName();
+            try {
+                String l2Manager = StringUtils.join(new HashSet(partnerEmailABMMap.get(customRetailer.getEmail()).getL2()), ", ");
+                String l1Manager = StringUtils.join(new HashSet(partnerEmailABMMap.get(customRetailer.getEmail()).getL1()), ", ");
+                if (StringUtils.isEmpty(l1Manager)) {
+                    l2Manager = StringUtils.join(new HashSet(partnerEmailABMMap.get(customRetailer.getEmail()).getL2()), ", ");
+                }
+                FofoAbmReportingModel reportingModel = new FofoAbmReportingModel();
+                reportingModel.setBusinessName(businessName);
+                reportingModel.setCode(code);
+                reportingModel.setFofoId(customRetailer.getPartnerId());
+                reportingModel.setL1Manager(l2Manager);
+                reportingModel.setL2Manager(l1Manager);
+                partnerIdAbmHeadersMap.put(customRetailer.getPartnerId(), reportingModel);
+            } catch (Exception e) {
+                LOGGER.warn("Could not find partner with email - {}", customRetailer.getEmail());
+            }
+        }
+        return partnerIdAbmHeadersMap;
+    }
     private class RBMRoles {
         private List<String> l1;
         private List<String> l2;
         private List<String> l3;

Subversion Repositories SmartDukaan

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