WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/migrations/RunOnceTasks.java

 import com.spice.profitmandi.dao.entity.warehouse.BrandRegionMapping;
 import com.spice.profitmandi.dao.entity.warehouse.WarehouseInventoryItem;
 import com.spice.profitmandi.dao.entity.warehouse.WarehouseScan;
 import com.spice.profitmandi.dao.enumuration.catalog.AmountType;
 import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
+import com.spice.profitmandi.dao.enumuration.catalog.StockTransactionType;
 import com.spice.profitmandi.dao.enumuration.dtr.PaymentOptionReferenceType;
 import com.spice.profitmandi.dao.enumuration.fofo.Gateway;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
 import com.spice.profitmandi.dao.enumuration.transaction.PriceDropImeiStatus;
 import com.spice.profitmandi.dao.model.*;
     public void processSchemeByIds(List<Integer> schemeIds) throws Exception {
         List<Scheme> schemes = schemeRepository.selectBySchemeIds(schemeIds);
         for (Scheme scheme : schemes) {
             List<Integer> catalogIds = schemeItemRepository.selectBySchemeIds(new HashSet<>(Arrays.asList(scheme.getId()))).stream().map(x -> x.getCatalogId()).collect(Collectors.toList());
-            if (Arrays.asList(SchemeType.SPECIAL_SUPPORT, SchemeType.ACTIVATION, SchemeType.CATEGORY, SchemeType.INVESTMENT, SchemeType.ACTIVATION, SchemeType.SPECIAL_SUPPORT).contains(scheme.getType())) {
+            if (scheme.getType().getTransactionType().equals(StockTransactionType.OUT)) {
                 List<FofoOrder> fofoOrders = fofoOrderRepository.selectOrderByModelAndSaleBetween(catalogIds, scheme.getStartDateTime(), scheme.getEndDateTime());
                 for (FofoOrder fofoOrder : fofoOrders) {
                     System.out.println("Processing fofoOrder --- " + fofoOrder.getInvoiceNumber());
                     System.out.println("Processing fofoOrder --- " + fofoOrder.getInvoiceNumber());
                     schemeService.processSchemeOut(fofoOrder.getId(), fofoOrder.getFofoId());
+                }
-            } else if (Arrays.asList(SchemeType.IN).contains(scheme.getType())) {
+            } else if (Arrays.asList(StockTransactionType.IN).contains(scheme.getType())) {
                 List<Purchase> purchases = purchaseRepository.selectPurchaseByCatalogsAndSaleBetween(catalogIds, scheme.getStartDateTime(), scheme.getEndDateTime());
                 for (Purchase purchase : purchases) {
                     System.out.println("Processing purchase --- " + purchase.getPurchaseReference());
                     schemeService.processSchemeIn(purchase.getId(), purchase.getFofoId());
+                }
+    }
     @Autowired
     InsurancePolicyRepository insurancePolicyRepository;
+    @Autowired
+    CreditNoteLineRepository creditNoteLineRepository;
+    @Autowired
+    CreditNoteRepository creditNoteRepository;
     public void addMissingWalletDebitsForInsurance() throws Exception {
         List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectAllByProviderId(5, Optional.empty());
         for (InsurancePolicy insurancePolicy : insurancePolicies) {
             FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(insurancePolicy.getInvoiceNumber());
             List<UserWalletHistory> userWalletHistories = userWalletHistoryRepository.selectAllByreferenceIdandreferenceType(insurancePolicy.getId(), WalletReferenceType.DAMAGE_PROTECTION);
+    }
     public void changeFulfillmentWarehouse(int orderId, int whId) throws ProfitMandiBusinessException {
         transactionService.changeFulfillmentWarehouse(orderId, whId);
+    }
+    public void findCNDiff() throws ProfitMandiBusinessException {
+        LocalDate startDate = LocalDate.of(2022, 9, 01);
+        List<UserWalletHistory> userWalletHistories = userWalletHistoryRepository.selectAllByDateType(startDate.atStartOfDay(), startDate.plusYears(3).atStartOfDay().withMonth(Month.JANUARY.getValue()), Arrays.asList(WalletReferenceType.ACTIVATION_SCHEME, WalletReferenceType.ADDITIONAL_SCHEME, WalletReferenceType.INVESTMENT_PAYOUT
+                , WalletReferenceType.SPECIAL_SUPPORT, WalletReferenceType.PRICE_DROP, WalletReferenceType.SCHEME_IN, WalletReferenceType.SCHEME_OUT));
+        Map<Integer, Map<YearMonth, Double>> fofoMonthAmount = userWalletHistories.stream().collect(Collectors.groupingBy(x -> x.getWalletId(),
+                Collectors.groupingBy(x -> YearMonth.from(x.getTimestamp()), Collectors.summingDouble(x -> x.getAmount()))));
+        System.out.println("FofoId\tYearMonth\tWallet\tCN");
+        for (Map.Entry<Integer, Map<YearMonth, Double>> fofoMonthAmountEntry : fofoMonthAmount.entrySet()) {
+            int walletId = fofoMonthAmountEntry.getKey();
+            int fofoId = userWalletRepository.selectById(walletId).getUserId();
+            for (Map.Entry<YearMonth, Double> yearMonthAmountEntry : fofoMonthAmountEntry.getValue().entrySet()) {
+                YearMonth yearMonth = yearMonthAmountEntry.getKey();
+                double walletAmount = yearMonthAmountEntry.getValue();
+                double cnAmount = 0;
+                List<Integer> creditNoteIds = creditNoteRepository.selectAll(fofoId, yearMonth).stream().map(cn -> cn.getId()).collect(Collectors.toList());
+                if(creditNoteIds.size() > 0) {
+                    cnAmount = creditNoteLineRepository.selectAllByCreditNoteIds(creditNoteIds).stream().collect(Collectors.summingDouble(CreditNoteLine::getAmount));
+                }
+                if(cnAmount != walletAmount) {
+                    System.out.println(fofoId + "\t" + yearMonth + "\t" + walletAmount + "\t" + cnAmount);
+                }
+            }
+        }
+    }
+}
 //7015845171

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/migrations/RunOnceTasks.java – Rev 34318 → 34326