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

 import com.spice.profitmandi.dao.repository.warehouse.WarehouseInventoryItemRepository;
 import com.spice.profitmandi.dao.repository.warehouse.WarehouseScanRepository;
 import com.spice.profitmandi.dao.service.LiquidationService;
 import com.spice.profitmandi.dao.service.LocationTrackingService;
 import com.spice.profitmandi.dao.service.SaleRewardService;
-import com.spice.profitmandi.service.integrations.bharti.BAGService;
-import com.spice.profitmandi.service.integrations.bharti.model.Sample;
 import com.spice.profitmandi.service.integrations.gstpro.GstProAuthService;
 import com.spice.profitmandi.service.integrations.gstpro.GstProService;
 import com.spice.profitmandi.service.integrations.oneassist.OneAssistService;
 import com.spice.profitmandi.service.integrations.oneassist.model.CancelPlanRequestModel;
 import com.spice.profitmandi.service.integrations.zest.InsuranceService;
     private PoStockApprovalDigestService poStockApprovalDigestService;*/
     @Autowired
     private RbmPerformanceRankingService rbmPerformanceRankingService;
-    private static final String ACCOUNT_ID = "aZ6flHhrgPIEl18buHdPBdueEN4";
-    private static final String SECRET_KEY = "a7rsX5B4UNNfTTx1-IJ19qdH48BT4YvBKlQJg3n3_KKNe7WWych55g";
     @Autowired
     private WarehouseInventoryItemRepository warehouseInventoryItemRepository;
     public void populateGrnTimestamp() {
         List<Purchase> allPurchases = purchaseRepository.selectAll();
+            }
             cis.setReserved(value);
         });
+    }
     public void fixWallet() throws Exception {
         List<FofoStore> fofoStores = fofoStoreRepository.selectAll();
         System.out.println("id\tcode\tactive\tname\tcity\tstate\twallet amount\tsum\twallet amount-sum");
         for (FofoStore fofoStore : fofoStores) {
             UserWallet uw = userWalletRepository.selectByRetailerId(fofoStore.getId());
+    }
     @Autowired
     PriceDropRepository priceDropRepository;
     @Autowired
     PriceDropIMEIRepository priceDropIMEIRepository;
     public void fixPriceDrop() throws ProfitMandiBusinessException {
         List<Integer> priceDropIds = Arrays.asList(609, 610, 611, 648, 649, 650, 651, 653, 667, 691, 692, 693, 695, 696, 697, 698, 645, 688);
     public void updateSaholicCISTable() {
         saholicInventoryService.updateSaholicCIS();
+    }
     @Autowired
-    BAGService bagService;
-    public void testBag() throws Exception {
-        //bagService.getPlans(10006, 10000f);
-        //bagService.getBrandsMaster();
-        bagService.getAllPlans();
-    }
-    @Autowired
     private OneAssistService oneAssistService;
     public void cancelOnceAssist(String invoiceNumber) throws Exception {
         FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(invoiceNumber);
         insuranceService.cancelInsurance(fofoOrder);
     public void cancelOnceAssistByMemberShipNumber(String applicationNo, String membershipId) throws Exception {
         insuranceService.cancelInsurance(applicationNo, membershipId);
+    }
-    public void mapBag() throws Exception {
-        List<Item> items = itemRepository.selectAllItems(10006, Arrays.asList("OnePlus", "Oppo", "Realme", "Samsung", "Vivo", "Xiaomi"));
-        items.stream().collect(Collectors.groupingBy(x -> x.getBrand()));
-        List<CSVRecord> csvRecordList = FileUtil.readFile(new File("/home/amit/Documents/sample.csv"));
-        for (CSVRecord csvRecord : csvRecordList) {
-            Sample sample = new Sample(csvRecord.get(0), csvRecord.get(1), csvRecord.get(2));
-            //StringUtils.getLevenshteinDistance()
-        }
-    }
     public void reverseInvalidActivation(List<Integer> inventoryItemIds) throws Exception {
         orderService.reverseActivationScheme(inventoryItemIds);
+    }
     public void processBids(ProfitMandiConstants.BID_CRON_ENUM schedule) throws Exception {
     CartService cartService;
     @Autowired
     private CommonPaymentService commonPaymentService;
     @Autowired
     LoanRepository loanRepository;
     @Autowired
     LoanStatementRepository loanStatementRepository;
     //Reverse CD of a specified Loan
     public void reverseCD() throws ProfitMandiBusinessException {
         Loan loan = loanRepository.selectByLoanId(45975);
         List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(loan.getId());
         loanStatements.stream().filter(x->x.getLoanReferenceType().equals(LoanReferenceType.PRINCIPAL) && x.getAmount().compareTo(BigDecimal.ZERO) > 0).forEach(x->loanStatementRepository.delete(x));
                 "Total Sale Amount Reversal - {}, Total Wallet Amount Reversal {}, Total Scheme Reversal Amount - {}",
                 saleAmount, totalAmount, schemeReverseAmount);
         // throw new Exception();
+    }
-    public void createGeofence() throws IOException, ProfitMandiBusinessException {
-        // List<FofoStore> fofoStores = fofoStoreRepository.selectActiveStores();
-        // for (FofoStore fofoStore : fofoStores) {
-        // if (fofoStore.getLatitude() != null && fofoStore.getLongitude() != null) {
-        CustomRetailer customRetailer = retailerService.getFofoRetailer(175138812);
-        JSONObject geofe = new JSONObject();
-        JSONArray geofences = new JSONArray();
-        JSONObject geometry = new JSONObject();
-        JSONObject geo = new JSONObject();
-        JSONArray coordinates = new JSONArray();
-        ArrayList<Double> crds = new ArrayList<>();
-        crds.add(79.739197);
-        crds.add(27.961215);
-        geo.put("type", "Point");
-        geo.put("coordinates", crds);
-        geometry.put("geometry", geo);
-        JSONObject metadata = new JSONObject();
-        metadata.put("name", customRetailer.getBusinessName());
-        metadata.put("city", customRetailer.getAddress().getCity());
-        metadata.put("Code", customRetailer.getCode());
-        geometry.put("metadata", metadata);
-        geometry.put("radius", 200);
-        geofences.put(geometry);
-        geofe.put("geofences", geofences);
-        String authString = "Basic "
-                + Base64.getEncoder().encodeToString(String.format("%s:%s", ACCOUNT_ID, SECRET_KEY).getBytes());
-        String responseBody = restClient.postJson("https://v3.api.hypertrack.com/geofences",
-                geofe.toString(), Collections.singletonMap("Authorization", authString));
-        JSONArray ja = new JSONArray(responseBody);
-        LOGGER.info("geofence" + ja);
-        LOGGER.info("jalength" + ja.length());
-        /*
-         * for (int i = 0; i < ja.length(); i++) { JSONObject c = ja.getJSONObject(i);
-         * String geofenceId = c.getString("geofence_id"); LOGGER.info("geofenceId" +
-         * geofenceId); FofoStoreGeofence fsg = new FofoStoreGeofence();
-         * fsg.setFofoId(customRetailer.getPartnerId()); fsg.setGeofenceId(geofenceId);
-         * fofoStoreGeofenceRepository.persist(fsg); }
-         *
-         * }
-         *
-         * }
-         */
-    }
-    public void getAllGeofences() throws Exception {
-        String authString = "Basic "
-                + Base64.getEncoder().encodeToString(String.format("%s:%s", ACCOUNT_ID, SECRET_KEY).getBytes());
-        String body = restClient.get("https://v3.api.hypertrack.com/geofences",
-                null, Collections.singletonMap("Authorization", authString));
-        LOGGER.info("response" + body);
-    }
-    public void deleteGeofences(List<String> geofenceIds) throws IOException, ProfitMandiBusinessException {
-        String authString = "Basic "
-                + Base64.getEncoder().encodeToString(String.format("%s:%s", ACCOUNT_ID, SECRET_KEY).getBytes());
-        try (CloseableHttpClient client = HttpClientFactory.apacheHttp()) {
-            for (String geofenceId : geofenceIds) {
-                HttpDelete delete = new HttpDelete("https://v3.api.hypertrack.com/geofences/" + geofenceId);
-                delete.setHeader("Authorization", authString);
-                LOGGER.info("geofenceId" + geofenceId);
-                try (CloseableHttpResponse response = client.execute(delete)) {
-                    String body = response.getEntity() != null ? EntityUtils.toString(response.getEntity()) : "";
-                    LOGGER.info("response" + body);
-                }
-            }
-        }
-    }
     public void processSchemeOut(int fofoId, int orderId) throws Exception {
         schemeService.processSchemeOut(orderId, fofoId);
+    }
     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));

Subversion Repositories SmartDukaan

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