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

 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.util.*;
 import java.util.stream.Collectors;
 @Component
+@Transactional(rollbackFor = Throwable.class)
 public class Listing {
     @Autowired
     private WebListingRepository webListingRepository;
     @Autowired
+    }
     public void getBestSeller() throws ProfitMandiBusinessException {
         WebListing webListing = webListingRepository.selectByUrl("partner-best-sellers");
-        List<WebProductListing> webProductListings = webProductListingRepository
+        List<WebProductListing> webProductListings = webProductListingRepository.selectAllByWebListingId(webListing.getId());
-                .selectAllByWebListingId(webListing.getId());
-        List<Integer> catalogItemIds = orderRepository.selectAllOrderWeight(LocalDateTime.now().minusDays(30),
+        List<Integer> catalogItemIds = orderRepository.selectAllOrderWeight(LocalDateTime.now().minusDays(30), LocalDateTime.now(), OrderStatus.DELIVERY_SUCCESS);
-                LocalDateTime.now(), OrderStatus.DELIVERY_SUCCESS);
         LOGGER.info("catalogItemIds {}", catalogItemIds);
         if (!catalogItemIds.isEmpty()) {
             webProductListingRepository.deleteByEqual(webListing.getId());
             int count = 0;
+    }
     public void getPriceDrop() throws ProfitMandiBusinessException {
         WebListing webListing = webListingRepository.selectByUrl("partner-price-drop");
-        List<WebProductListing> webProductListings = webProductListingRepository
+        List<WebProductListing> webProductListings = webProductListingRepository.selectAllByWebListingId(webListing.getId());
-                .selectAllByWebListingId(webListing.getId());
-        Set<Integer> catalogItemIds = priceDropRepository
-                .selectAllByDatesBetweenSortByDate(LocalDateTime.now().minusDays(30), LocalDateTime.now()).stream()
+        Set<Integer> catalogItemIds = priceDropRepository.selectAllByDatesBetweenSortByDate(LocalDateTime.now().minusDays(30), LocalDateTime.now()).stream().filter(x -> x.getAmount() > 0).map(x -> x.getCatalogItemId()).collect(Collectors.toSet());
-                .filter(x->x.getAmount()>0).map(x -> x.getCatalogItemId()).collect(Collectors.toSet());
         LOGGER.info("catalogItemIds {}", catalogItemIds);
         if (!catalogItemIds.isEmpty()) {
             webProductListingRepository.deleteByEqual(webListing.getId());
             int count = 0;
+    }
     public void getNewLaunches() throws ProfitMandiBusinessException {
         WebListing webListing = webListingRepository.selectByUrl("new-launches");
-        List<Integer> catalogItemIds = tagListingRepository.getRecentLanuch(LocalDate.now().minusDays(30),
+        List<Integer> catalogItemIds = tagListingRepository.getRecentLanuch(LocalDate.now().minusDays(30), LocalDate.now().plusDays(1));
-                LocalDate.now().plusDays(1));
         if (!catalogItemIds.isEmpty()) {
             webProductListingRepository.deleteByEqual(webListing.getId());
             int count = 0;
             for (Integer catalogItemId : catalogItemIds) {
+    }
     public void getSpecialSupport() throws ProfitMandiBusinessException {
         WebListing webListing = webListingRepository.selectByUrl("special-support");
-        List<Integer> catalogItemIds = schemeRepository.getActiveScheme(SchemeType.SPECIAL_SUPPORT,
+        List<Integer> catalogItemIds = schemeRepository.getActiveScheme(SchemeType.SPECIAL_SUPPORT, LocalDate.now().plusDays(1));
-                LocalDate.now().plusDays(1));
         LOGGER.info("catalogItemIds {}", catalogItemIds);
         if (!catalogItemIds.isEmpty()) {
             webProductListingRepository.deleteByEqual(webListing.getId());
             int count = 0;
     public void getUpgradeOffer() throws ProfitMandiBusinessException {
         WebListing webListing = webListingRepository.selectByUrl("upgrade-offer");
         webProductListingRepository.deleteByEqual(webListing.getId());
-        List<Integer> customerOfferIds = customerOfferRepository.selectOffers(LocalDate.now()).stream()
+        List<Integer> customerOfferIds = customerOfferRepository.selectOffers(LocalDate.now()).stream().map(x -> x.getId()).collect(Collectors.toList());
-                .map(x -> x.getId()).collect(Collectors.toList());
-        List<Integer> catalogItemIds = customerOfferItemRepository
-                .selectByOfferIdsRange(customerOfferIds, LocalDate.now()).stream().map(x -> x.getCatalogId()).distinct()
+        List<Integer> catalogItemIds = customerOfferItemRepository.selectByOfferIdsRange(customerOfferIds, LocalDate.now()).stream().map(x -> x.getCatalogId()).distinct().collect(Collectors.toList());
-                .collect(Collectors.toList());
         LOGGER.info("catalogItemIds {}", catalogItemIds);
         if (!catalogItemIds.isEmpty()) {
             int count = 0;
             for (Integer catalogItemId : catalogItemIds) {
     public void scheduledGetUpgradeOffer() throws Throwable {
         this.getUpgradeOffer();
+    }
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/b2b/Listing.java – Rev 31732 → 31754