WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasksTest.java

 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.dao.cart.SmartCartService;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
+import com.spice.profitmandi.dao.entity.catalog.TagListing;
 import com.spice.profitmandi.dao.entity.fofo.*;
 import com.spice.profitmandi.dao.entity.logistics.AST;
 import com.spice.profitmandi.dao.entity.logistics.ASTRepository;
 import com.spice.profitmandi.dao.entity.transaction.*;
 import com.spice.profitmandi.dao.entity.user.User;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.enumuration.transaction.LoanReferenceType;
 import com.spice.profitmandi.dao.model.*;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
+import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.fofo.*;
 import com.spice.profitmandi.dao.repository.inventory.StateRepository;
 import com.spice.profitmandi.dao.repository.transaction.*;
 import com.spice.profitmandi.dao.repository.user.UserRepository;
 import com.spice.profitmandi.service.PartnerStatsService;
 import com.spice.profitmandi.service.RbmTargetService;
-import com.spice.profitmandi.service.inventory.InventoryService;
+import com.spice.profitmandi.service.inventory.*;
 import com.spice.profitmandi.service.transaction.SDCreditService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.wallet.WalletService;
 import in.shop2020.model.v1.order.OrderStatus;
 import in.shop2020.model.v1.order.WalletReferenceType;
     @Autowired
     PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
     @Autowired
+    SaholicInventoryService saholicInventoryService;
+    @Autowired
     WalletService walletService;
     @Autowired
     RbmTargetService rbmTargetService;
     @Autowired
     PartnerStatsService partnerStatsService;
     @Autowired
+    AgeingService ageingService;
+    @Autowired
+    TagListingRepository tagListingRepository;
+    @Autowired
     UserWalletHistoryRepository userWalletHistoryRepository;
     public void test() throws Exception {
         System.out.println("test start");
         //partnerStatsService.getAllPartnerStats();
+        }
         Map<Integer, CustomRetailer> customRetailers = retailerService.getAllFofoRetailersInternalFalse();
         List<Integer> retailerIds = customRetailers.values().stream().map(CustomRetailer::getPartnerId).collect(Collectors.toList());
-//
-//        List<Integer> retailerIds = Arrays.asList(175139440,175139441);
+/*        List<Integer> retailerIds = Arrays.asList(175130896);
-//        Map<Integer,CustomRetailer> customRetailers = retailerService.getFofoRetailers(retailerIds);
+        Map<Integer,CustomRetailer> customRetailers = retailerService.getFofoRetailers(retailerIds);*/
         //partner daily investment
         List<Loan> defaultLoans = sdCreditService.getDefaultLoans();
         Map<Integer,List<Loan>> defaultLoanMap = defaultLoans.stream().collect(Collectors.groupingBy(Loan::getFofoId));
             double totalMtdTertiaryAmount = brandMtdTertiaryAmount.values().stream().mapToDouble(Double::doubleValue).sum();
             fofoTotalMtdTertiaryMap.put(fofoId,totalMtdTertiaryAmount);
-            LOGGER.info("fofoBrandMtdTertiaryMap- {}",fofoBrandMtdTertiaryMap);
             List<BrandWiseModel> brandWiseMtdSecondary = orderRepository.selectAllBilledByCategoryOrderGroupByBrandFofoId(fofoId, currentMonthStartDate,Arrays.asList(10006,10001));
             Map<String,Long> brandWiseMtdSecondaryMap = brandWiseMtdSecondary.stream().collect(Collectors.toMap(BrandWiseModel::getBrand,BrandWiseModel::getAmount));
             //retrunInfo
             List<BrandWiseReturnInfo> brandWiseReturnInfos = returnOrderInfoRepository.selectAllBrandWiseByBetweenDate(currentMonthStartDate,currentMonthEndDate.plusDays(1),fofoId);
             Map<String,Double> brandWiseReturnInfoMap = brandWiseReturnInfos.stream().collect(Collectors.toMap(BrandWiseReturnInfo::getBrand, x->x.getReturnAmount()));
             LOGGER.info("brandWiseReturnInfos {}",brandWiseReturnInfos);
-            LOGGER.info("brandWiseReturnInfoMap {}",brandWiseReturnInfoMap);
             //Rto retrunInfo
             List<BrandWiseReturnInfo> brandWiseRTOReturnInfos = returnOrderInfoRepository.selectAllBrandWiseRTORefundByBetweenDate(currentMonthStartDate,currentMonthEndDate.plusDays(1),fofoId);
             Map<String,Double> brandWiseRTOReturnInfoMap = brandWiseRTOReturnInfos.stream().collect(Collectors.toMap(BrandWiseReturnInfo::getBrand, x->x.getReturnAmount()));
             // Step 1: Get union of all brand keys
         for (Map.Entry<Integer, BIRetailerModel> entry : biRetailerModelMap.entrySet()) {
             DateTimeFormatter formatter = DateTimeFormatter.ofPattern("dd/MM/yyyy");
             Integer fofoId = entry.getKey();
             User user = userRepository.selectById(fofoId);
             LocalDateTime walletCreationDate = userWalletHistoryRepository.selectFirstCreatedDate(fofoId);
+            if(walletCreationDate == null){
+                walletCreationDate = user.getCreateTimestamp();
+            }
             BIRetailerModel retailer = entry.getValue();
             Map<YearMonth, BiSecondaryModel> monthlyData = allRetailerMonthlyData.get(fofoId);
             BiSecondaryModel current = monthlyData.getOrDefault(currentMonth, new BiSecondaryModel(0,0,0,0,0,0,0));
             BiSecondaryModel last = monthlyData.getOrDefault(currentMonth.minusMonths(1), new BiSecondaryModel(0,0,0,0,0,0,0));
             BiSecondaryModel twoAgo = monthlyData.getOrDefault(currentMonth.minusMonths(2), new BiSecondaryModel(0,0,0,0,0,0,0));
             List<Object> row = new ArrayList<>();
+            LOGGER.info("fofoId-11 {}",fofoId);
             row.addAll(Arrays.asList(
+                    assessmentMap.get(fofoId),
+                    zeroBillingMap.get(fofoId),
+                    billingNeededMap.get(fofoId),
+                    countAMap.get(fofoId),
+                    retailer.getBmName(),
+                    fofoId ,
+                    "https://partners.smartdukaan.com/partnerPerformance?fofoId="+fofoId,
+                    walletCreationDate.format(formatter),
-                    assessmentMap.get(fofoId),zeroBillingMap.get(fofoId),billingNeededMap.get(fofoId),countAMap.get(fofoId),
+                    user.getCreateTimestamp() != null ? (user.getCreateTimestamp()).format(formatter) : "-",
+                    retailer.getCode(),
+                    retailer.getArea(),
+                    retailer.getCity(),
-                    retailer.getBmName(),fofoId ,"https://partners.smartdukaan.com/partnerPerformance?fofoId="+fofoId,walletCreationDate.format(formatter),(user.getCreateTimestamp()).format(formatter), retailer.getCode(), retailer.getArea(), retailer.getCity(),  retailer.getStoreName(), retailer.getStatus(),
+                    retailer.getStoreName(),
+                    retailer.getStatus(),
+                    retailer.getCategory(),
-                    retailer.getCategory(),  retailer.getSalesManager(), retailer.getRbm()
+                    retailer.getSalesManager(),
+                    retailer.getRbm()
             ));
             // Two Months Ago
         // Send to email
 //        ByteArrayOutputStream csvStream = FileUtil.getCSVByteStreamWithMultiHeaders(headerGroup, rows);
         ByteArrayOutputStream csvStream = getExcelStreamWithMultiHeaders(headerGroup, rows);
         String fileName = "BI-Retailer-Monthly-Report-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".xlsx";
-//        String[] sendToArray = new String[]{"ranu.rajput@smartdukaan.com","ashutosh.verma@smartdukaan.com","sm@smartdukaan.com","raj.singh@smartdukaan.com"};
+        String[] sendToArray = new String[]{"ranu.rajput@smartdukaan.com","ashutosh.verma@smartdukaan.com","sm@smartdukaan.com","raj.singh@smartdukaan.com"};
-        String[] sendToArray = new String[]{"ranu.rajput@smartdukaan.com"};
+//        String[] sendToArray = new String[]{"ranu.rajput@smartdukaan.com"};
         Utils.sendMailWithAttachment(googleMailSender, sendToArray, new String[]{}, "BI Retailer Monthly Report", "Please find attached the BI retailer secondary/tertiary monthly report.", fileName, new ByteArrayResource(csvStream.toByteArray()));
+    }
         style.setFont(font);
         return style;
+    }
+    public void stockAlertMailToRetailer() throws Exception {
+        Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(true);
+        List<Integer> retailerIds = customRetailers.values().stream().map(CustomRetailer::getPartnerId).collect(Collectors.toList());
+        for(Integer fofoId : retailerIds){
+            List<String> statusOrder = Arrays.asList("HID", "FASTMOVING", "RUNNING", "SLOWMOVING", "OTHER");
+            FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
+            List<PartnerWarehouseStockSummaryModel> partnerWarehouseStockSummaryModels = saholicInventoryService.getSaholicAndPartnerStock(fofoId, fofoStore.getWarehouseId());
+            List<PartnerWarehouseStockAgingSummaryModel> partnerWarehouseStockAgingSummaryModelList = new ArrayList<>();
+            Set<Integer> catalogIds = partnerWarehouseStockSummaryModels.stream().map(x -> x.getCatalogId()).collect(Collectors.toSet());
+            List<Integer> catalogsList = new ArrayList<>(catalogIds);
+            Map<Integer, TagListing> tagListingsMap = tagListingRepository.selectAllByCatalogIds(catalogsList);
+            List<CatalogAgingModel> catalogAgingModels = ageingService.getCatalogsAgingByWarehouse(catalogIds, fofoStore.getWarehouseId());
+            Map<Integer, CatalogAgingModel> catalogAgingModelMap = catalogAgingModels.stream().collect(Collectors.toMap(x -> x.getCatalogId(), x -> x));
+            for (PartnerWarehouseStockSummaryModel stockSummary : partnerWarehouseStockSummaryModels) {
+                PartnerWarehouseStockAgingSummaryModel partnerWarehouseStockAgingSummaryModel = new PartnerWarehouseStockAgingSummaryModel();
+                partnerWarehouseStockAgingSummaryModel.setCatalogId(stockSummary.getCatalogId());
+                partnerWarehouseStockAgingSummaryModel.setBrand(stockSummary.getBrand());
+                partnerWarehouseStockAgingSummaryModel.setModelNumber(stockSummary.getModelNumber());
+                partnerWarehouseStockAgingSummaryModel.setNetAvailability(stockSummary.getShaholicNetAvailability());
+                partnerWarehouseStockAgingSummaryModel.setPartnerStockAvailability(stockSummary.getPartnerFullFilledQty());
+                partnerWarehouseStockAgingSummaryModel.setPartnerCurrentAvailability(stockSummary.getPartnerCurrentQty());
+                partnerWarehouseStockAgingSummaryModel.setPartnerShortageStock(stockSummary.getPartnerShortageQty());
+                if (catalogAgingModelMap.get(stockSummary.getCatalogId()) != null) {
+                    partnerWarehouseStockAgingSummaryModel.setExceedDays(catalogAgingModelMap.get(stockSummary.getCatalogId()).getExceedDays());
+                } else {
+                    partnerWarehouseStockAgingSummaryModel.setExceedDays(0);
+                }
+                partnerWarehouseStockAgingSummaryModel.setStatus(stockSummary.getStatus());
+                partnerWarehouseStockAgingSummaryModelList.add(partnerWarehouseStockAgingSummaryModel);
+            }
+            Set<Integer> existingCatalogIdsInAgingSummaryList = partnerWarehouseStockAgingSummaryModelList.stream()
+                    .map(PartnerWarehouseStockAgingSummaryModel::getCatalogId)
+                    .collect(Collectors.toSet());
+        }
+    }
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasksTest.java – Rev 34751 → 34758