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

 import com.google.common.collect.Lists;
 import com.google.gson.Gson;
 import com.razorpay.Payment;
 import com.smartdukaan.cron.itelImeiActivation.ItelImeiActivationService;
 import com.smartdukaan.cron.itelImeiActivation.TecnoImeiActivation;
+import com.spice.profitmandi.common.enumuration.ActivationType;
-import com.spice.profitmandi.common.enumuration.*;
+import com.spice.profitmandi.common.enumuration.MessageType;
+import com.spice.profitmandi.common.enumuration.RechargeStatus;
+import com.spice.profitmandi.common.enumuration.ReporticoProject;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.*;
 import com.spice.profitmandi.common.services.ReporticoService;
 import com.spice.profitmandi.common.services.mandii.AccountStatusResponseOut;
 import com.spice.profitmandi.common.services.mandii.EligibilityStatusEnum;
 import com.spice.profitmandi.dao.entity.inventory.ReporticoCacheTable;
 import com.spice.profitmandi.dao.entity.inventory.SaholicCIS;
 import com.spice.profitmandi.dao.entity.inventory.SaholicPOItem;
 import com.spice.profitmandi.dao.entity.transaction.*;
 import com.spice.profitmandi.dao.entity.user.*;
-import com.spice.profitmandi.dao.entity.warehouse.BrandRegionMapping;
 import com.spice.profitmandi.dao.enumuration.auth.CollectionRemark;
 import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.enumuration.dtr.RefferalStatus;
 import com.spice.profitmandi.dao.enumuration.fofo.Gateway;
 import com.spice.profitmandi.dao.enumuration.fofo.PaymentStatus;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
 import com.spice.profitmandi.dao.enumuration.transaction.CreditRisk;
 import com.spice.profitmandi.dao.enumuration.transaction.LoanReferenceType;
 import com.spice.profitmandi.dao.enumuration.transaction.PriceDropImeiStatus;
-import com.spice.profitmandi.dao.model.PartnerDetailModel;
-import com.spice.profitmandi.dao.model.SimpleCampaign;
+import com.spice.profitmandi.dao.model.*;
-import com.spice.profitmandi.dao.model.SimpleCampaignParams;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.auth.PartnerCollectionRemarkRepository;
 import com.spice.profitmandi.dao.repository.catalog.*;
 import com.spice.profitmandi.dao.repository.cs.*;
 import com.spice.profitmandi.dao.repository.dtr.*;
 import com.spice.profitmandi.dao.repository.warehouse.WarehouseInventoryItemRepository;
 import com.spice.profitmandi.dao.service.solr.FofoSolr;
 import com.spice.profitmandi.service.NotificationService;
 import com.spice.profitmandi.service.PartnerInvestmentService;
 import com.spice.profitmandi.service.PartnerStatsService;
+import com.spice.profitmandi.service.PerformanceService;
 import com.spice.profitmandi.service.integrations.CCAvenuePaymentService;
 import com.spice.profitmandi.service.integrations.RazorpayPaymentService;
 import com.spice.profitmandi.service.integrations.bharti.model.BAGInsuranceModel;
 import com.spice.profitmandi.service.integrations.toffee.ToffeeService;
 import com.spice.profitmandi.service.inventory.AgeingModel;
 import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoField;
 import java.time.temporal.ChronoUnit;
 import java.util.*;
 import java.util.Map.Entry;
-import java.util.stream.Collector;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 import static java.util.stream.Collectors.groupingBy;
 import static java.util.stream.Collectors.mapping;
     @Autowired
     private CsService csService;
     @Autowired
-    RetailerBlockBrandsRepository retailerBlockBrandsRepository;
-    @Autowired
     private SaholicInventoryService saholicInventoryService;
     @Autowired
     private InsurancePolicyRepository insurancePolicyRepository;
     private SchemeService schemeService;
     @Autowired
     private ServiceConfigRepository serviceConfigRepository;
+    @Autowired
+    private RetailerBlockBrandsRepository retailerBlockBrandsRepository;
     @Value("${delhivery.tracking.token}")
     private String token;
     private static final String[] STOCK_AGEING_MAIL_LIST = new String[]{"uday.singh@smartudkaan.com", "mohinder.mutreja@smartdukaan.com", "ankit.bhatia@smartdukaan.com", "tarun.verma@smartdukaan.com", "kuldeep.kumar@smartdukaan.com", "manish.gupta@smartdukaan.com"};
     public void test() throws Exception {
         System.out.println("Starting test");
         //processScheme(LocalDate.of(2023,05, 02).atStartOfDay(), LocalDate.of(2023, 05, 6).atStartOfDay(), false);
         //
-        for (String inv : Arrays.asList("DLWE066/2966","UPBLY175/1014","UPSRP547/16","UPSBL299/2620","UPSML508/76","UPBLY175/1015","UPBLY175/1013","UPMTR498/377","UPBUD432/122","UPAZM132/1443","UPETH173/2124","HRGN516/139","UPSRP547/36","UPCDL116/1172","UPSRP547/42","RJAMR522/36","RJBHW525/16","HRRHK424/78","HRRHK424/81","HRRHK424/84","HRRHK424/85","HRRHK424/83","HRRHK424/77","HRRHK424/76","HRRHK424/75","HRRHK424/73","HRRHK424/74","HRRHK424/45","HRKA135/3528","HRKN025/4479","UPAZM132/1460","UPBSR530/51","HRKN093/1434","HRRHK424/80","HRKA153/3823","HRFB402/534","UPETH173/2232","HRGN516/140","UPGBN590/10","RJJHU440/113","HRKN148/828","HRPHK245/617","HRKA256/170","UPBSR608/4","RJBHW445/3","UPSJP484/169","UPSJP484/169","UPSRP455/600","UPSRP455/599","RJJU518/546","HRKN184/669","UPMTR498/447","UPAMH419/232","UPMZR448/392","HRPW604/24","UPSML508/126","HRMWT562/38","HRKA395/221","UKAL569/69","UPMZR448/324","UPMTR532/153","UPMTR532/193", "HRKN025/4630")) {
+        for (String inv : Arrays.asList("DLWE066/2966", "UPBLY175/1014", "UPSRP547/16", "UPSBL299/2620", "UPSML508/76", "UPBLY175/1015", "UPBLY175/1013", "UPMTR498/377", "UPBUD432/122", "UPAZM132/1443", "UPETH173/2124", "HRGN516/139", "UPSRP547/36", "UPCDL116/1172", "UPSRP547/42", "RJAMR522/36", "RJBHW525/16", "HRRHK424/78", "HRRHK424/81", "HRRHK424/84", "HRRHK424/85", "HRRHK424/83", "HRRHK424/77", "HRRHK424/76", "HRRHK424/75", "HRRHK424/73", "HRRHK424/74", "HRRHK424/45", "HRKA135/3528", "HRKN025/4479", "UPAZM132/1460", "UPBSR530/51", "HRKN093/1434", "HRRHK424/80", "HRKA153/3823", "HRFB402/534", "UPETH173/2232", "HRGN516/140", "UPGBN590/10", "RJJHU440/113", "HRKN148/828", "HRPHK245/617", "HRKA256/170", "UPBSR608/4", "RJBHW445/3", "UPSJP484/169", "UPSJP484/169", "UPSRP455/600", "UPSRP455/599", "RJJU518/546", "HRKN184/669", "UPMTR498/447", "UPAMH419/232", "UPMZR448/392", "HRPW604/24", "UPSML508/126", "HRMWT562/38", "HRKA395/221", "UKAL569/69", "UPMZR448/324", "UPMTR532/153", "UPMTR532/193", "HRKN025/4630")) {
-            System.out.println("Invoice - " +  inv);
+            System.out.println("Invoice - " + inv);
             orderService.reverseScheme(fofoOrderRepository.selectByInvoiceNumber(inv));
+        }
         //this.sendMailForSamsungRebilling();
         /*List<PurchaseReturnItem> purchaseReturnItems = purchaseReturnItemRepository.selectPurchaseReturnByStatuses(Arrays.asList(PurchaseReturnStatus.DEBIT_NOTE_CREATED));
+        }
+    }
+    @Autowired
+    private RetailerFilterRepository retailerFilterRepository;
+    @Autowired
+    private PerformanceService performanceService;
+    public void sendFilteredRetailerPerformance() throws Exception {
+        RetailerFilterModel retailerFilterModel = performanceService.getRetailerFilterModel();
+        Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(true);
+        List<RetailerPeformanceFilterModel> partnersPerformance = performanceService.getPerformance(retailerFilterModel, customRetailers);
+        Map<Integer, RetailerPeformanceFilterModel> partnersPerformanceMap = new HashMap<>();
+        if (!partnersPerformance.isEmpty()) {
+            partnersPerformanceMap = partnersPerformance.stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
+            performanceService.sendPartnerPerformanceEmail(partnersPerformanceMap, retailerFilterModel, customRetailers);
+        }
+    }
+}
 // 2284'

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java – Rev 32060 → 32061