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

 import javax.mail.MessagingException;
 import javax.mail.internet.InternetAddress;
 import javax.mail.internet.MimeMessage;
+import com.spice.profitmandi.dao.enumuration.transaction.SchemePayoutStatus;
 import org.apache.commons.io.output.ByteArrayOutputStream;
 import org.apache.commons.lang.StringUtils;
 import org.apache.http.client.methods.CloseableHttpResponse;
 import org.apache.http.client.methods.HttpPost;
 import org.apache.http.conn.HttpHostConnectException;
 import org.apache.http.entity.StringEntity;
 import org.apache.http.impl.client.CloseableHttpClient;
 import org.apache.http.impl.client.HttpClients;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.hibernate.Session;
+import org.hibernate.SessionFactory;
+import org.hibernate.query.NativeQuery;
 import org.json.JSONArray;
 import org.json.JSONObject;
 import org.json.XML;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
     @Autowired
     StandAlone standAlone;
     public void test() throws Exception {
         try {
-            standAlone.checkOppoImeiStatus();
+            checkAllPayoutsDuplicate();
         } catch (Throwable e) {
             throw new Exception(e);
+        }
         //this.sendMailForSamsungRebilling();
         //this.sendMailForAgeingAlert();
         //System.out.println(brandRegionMappingRepository.getAvailabilityToVendorWarehouse(Arrays.asList(33353), 7720));
+    }
+    @Autowired
+    SessionFactory sessionFactory;
+    private void checkAllPayoutsDuplicate() throws Exception {
+        final Session session = sessionFactory.getCurrentSession();
+        final NativeQuery<Object[]> nativeQuery = session.createNativeQuery("select sio.inventory_item_id, sio.scheme_id, sio.status, count(*) c\n" +
+                "from fofo.scheme_in_out sio\n" +
+                "         join catalog.scheme s on s.id = sio.scheme_id\n" +
+                "where (sio.status = 'CREDITED'\n" +
+                "    or sio.status = 'PENDING')\n" +
+                "  and s.type != 'INVESTMENT'\n" +
+                " and sio.create_timestamp >= '2023-01-01' " +
+                "group by sio.inventory_item_id, sio.scheme_id, sio.status\n" +
+                "having c > 1");
+        List<Object[]> resultList = nativeQuery.getResultList();
+        for (Object[] tuple : resultList) {
+            LOGGER.info("RESULT -- {}, {}, {}", tuple[0], tuple[1], tuple[2]);
+            int inventoryItemId = (Integer) tuple[0];
+            int schemeId = (Integer) tuple[1];
+            SchemePayoutStatus schemePayoutStatus = SchemePayoutStatus.valueOf((String) tuple[2]);
+            List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByScheme(schemeId, inventoryItemId);
+            List<SchemeInOut> statusSpecificSchemeInOuts = schemeInOuts.stream().filter(x -> x.getStatus().equals(schemePayoutStatus)).collect(Collectors.toList());
+            if (statusSpecificSchemeInOuts.size() > 0) {
+                InventoryItem inventoryItem = inventoryItemRepository.selectById(inventoryItemId);
+                Scheme scheme = schemeRepository.selectById(schemeId);
+                List<ScanRecord> scanRecords = scanRecordRepository.selectByInventoryItemId(inventoryItemId);
+                if (scheme.getType().equals(SchemeType.IN)) {
+                    LOGGER.info("Skipping -- {}", inventoryItem.getSerialNumber());
+                } else {
+                    int fofoOrderId = scanRecords.stream().filter(x -> x.getOrderId() != 0).max(Comparator.comparing(x -> x.getOrderId())).get().getOrderId();
+                    WalletReferenceType walletReferenceType = SchemeType.ACTIVATION.equals(scheme.getType()) ? WalletReferenceType.ACTIVATION_SCHEME : SchemeType.SPECIAL_SUPPORT.equals(scheme.getType()) ? WalletReferenceType.SPECIAL_SUPPORT : WalletReferenceType.SCHEME_OUT;
+                    List<UserWalletHistory> userWalletHistoryList = userWalletHistoryRepository.selectAllByreferenceIdandreferenceType(fofoOrderId, walletReferenceType).stream().filter(x -> x.getAmount() == Math.round(statusSpecificSchemeInOuts.get(0).getAmount())).collect(Collectors.toList());
+                    LOGGER.info("UserwalletHistory Entry --> {}, Sios --> {}", userWalletHistoryList.size(), statusSpecificSchemeInOuts.size());
+                    if (userWalletHistoryList.size() != statusSpecificSchemeInOuts.size()) {
+                        //Skipping them in first run as it is the special casw of upgrade where mismatch has happend.
+                        LOGGER.info("problem with {}, sio status - {}, inventoryItem id {}, schemeID {} ", fofoOrderId, statusSpecificSchemeInOuts.stream().map(x -> x.getStatus()).collect(Collectors.toList()), inventoryItemId, schemeId);
+                        //Primarily multiple pending cases
+                        statusSpecificSchemeInOuts.stream().skip(1).forEach(schemeInOut -> {
+                            schemeInOut.setStatus(SchemePayoutStatus.REJECTED);
+                            schemeInOut.setStatusDescription("Rejected as entry is duplicate");
+                        });
+                    } else {
+                        userWalletHistoryList.stream().skip(1).forEach(userWalletHistory -> {
+                            try {
+                                walletService.rollbackAmountFromWallet(inventoryItem.getFofoId(), userWalletHistory.getAmount(), userWalletHistory.getReference(), userWalletHistory.getReferenceType(), "Reversal as multiple entries created", userWalletHistory.getBusinessTimestamp());
+                            } catch (ProfitMandiBusinessException e) {
+                                throw new RuntimeException(e);
+                            }
+                        });
+                        statusSpecificSchemeInOuts.stream().skip(1).forEach(schemeInOut -> {
+                            schemeInOut.setStatus(SchemePayoutStatus.REJECTED);
+                            if (schemePayoutStatus.equals(SchemePayoutStatus.CREDITED)) {
+                                schemeInOut.setRolledBackTimestamp(LocalDateTime.now());
+                                schemeInOut.setStatusDescription("Rolled back as entry is duplicate");
+                            } else {
+                                LOGGER.info("This seems higly unreachable should not come here");
+                                schemeInOut.setStatusDescription("Rejected as entry is duplicate");
+                            }
+                        });
+                    }
+                }
+            }
+        }
+    }
     public void test1() throws Exception {
         System.out.println("Starting test");
         processScheme(LocalDate.of(2023, 05, 06).atStartOfDay(), LocalDate.of(2023, 05, 9).atStartOfDay(), false);
         /*partnerTypeChangeService.getTypeOnDate(175139287, LocalDate.of(2023,02, 01));
         partnerTypeChangeService.getTypeOnDate(175139287, LocalDate.of(2023,03, 01));
     public void sendPartnerInvestmentDetails(List<String> sendTo) throws Exception {
         LocalDate yesterDay = LocalDate.now().minusDays(1);
         List<FofoStore> fofoStores = fofoStoreRepository.selectActiveStores();
         Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(fofoStores.stream().map(x -> x.getId()).collect(Collectors.toList()));
-        List<String> headers = Arrays.asList("Code", "Outlet name", "State Manager", "Teritory/Team Lead", "Wallet Amount", "In Stock Amount", "Activated Stock", "Return In Transit Stock", "Unbilled Amount", "Grn Pending Amount", "Min Investment", "Investment Amount", "Investment Short", "Unbilled Qty", "Short Days");
+        List<String> headers = Arrays.asList("Code", "Outlet name", "State Manager", "Territory/Team Lead", "Wallet Amount", "In Stock Amount", "Activated Stock", "Return In Transit Stock", "Unbilled Amount", "Grn Pending Amount", "Min Investment", "Investment Amount", "Investment Short", "Unbilled Qty", "Short Days");
         List<List<?>> rows = new ArrayList<>();
         Map<Integer, List<?>> partnerRowsMap = new HashMap<>();
         Map<Integer, FofoReportingModel> partnerIdSalesHeaderMap = this.getPartnerIdSalesHeaders();
+        }
+    }
     private String getMessageHygieneAlertForPartner(
-                                                    Map<Integer, Map<YearMonth, List<HygieneData>>> partnerYearMonthData, Map<Integer, Map<LocalDate, List<HygieneData>>> partnerDateWiseData) {
+            Map<Integer, Map<YearMonth, List<HygieneData>>> partnerYearMonthData, Map<Integer, Map<LocalDate, List<HygieneData>>> partnerDateWiseData) {
         Map<Integer, CustomRetailer> customeRetailerMap = retailerService.getAllFofoRetailers();
         LocalDateTime startDate = LocalDate.now().withDayOfMonth(1).atStartOfDay();
         LocalDateTime endDate = LocalDateTime.now();

Subversion Repositories SmartDukaan

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