Subversion Repositories SmartDukaan

package com.smartdukaan.cron.scheduled.b2b;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
import com.spice.profitmandi.dao.entity.catalog.Item;
import com.spice.profitmandi.dao.entity.dtr.WebListing;
import com.spice.profitmandi.dao.entity.dtr.WebProductListing;
import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
import com.spice.profitmandi.dao.repository.catalog.*;
import com.spice.profitmandi.dao.repository.dtr.WebListingRepository;
import com.spice.profitmandi.dao.repository.dtr.WebProductListingRepository;
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
import com.spice.profitmandi.dao.service.solr.FofoSolr;
import com.spice.profitmandi.service.catalog.CatalogDelistService;
import in.shop2020.model.v1.order.OrderStatus;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
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
    private FofoSolr fofoSolr;

    @Autowired
    OrderRepository orderRepository;

    @Autowired
    ItemRepository itemRepository;

    @Autowired
    PriceDropRepository priceDropRepository;

    @Autowired
    CustomerOfferRepository customerOfferRepository;

    @Autowired
    CustomerOfferItemRepository customerOfferItemRepository;

    @Autowired
    SchemeRepository schemeRepository;

    @Autowired
    TagListingRepository tagListingRepository;

    @Autowired
    CatalogDelistService catalogDelistService;

    // Inline default: env profiles have NO fallback between each other, so a key
    // missing from one profile's properties would otherwise stop the context booting.
    @Value("${catalog.autoDelist.enabled:true}")
    private boolean autoDelistEnabled;


    private static final Logger LOGGER = LogManager.getLogger(Listing.class);

    @Autowired
    private WebProductListingRepository webProductListingRepository;


    public void pushDataToSolr() throws Exception {
        fofoSolr.pushData();
    }

    public void getBestSeller() throws ProfitMandiBusinessException {
        WebListing webListing = webListingRepository.selectByUrl("partner-best-sellers");

        List<WebProductListing> webProductListings = webProductListingRepository.selectAllByWebListingId(webListing.getId());

        List<Integer> catalogItemIds = orderRepository.selectAllOrderWeight(LocalDateTime.now().minusDays(30), LocalDateTime.now(), OrderStatus.DELIVERY_SUCCESS);

        LOGGER.info("catalogItemIds {}", catalogItemIds);
        if (!catalogItemIds.isEmpty()) {
            webProductListingRepository.deleteByEqual(webListing.getId());
            int count = 0;
            for (Integer catalogItemId : catalogItemIds) {

                WebProductListing webProductListing = new WebProductListing();
                webProductListing.setEntityId(catalogItemId);
                webProductListing.setWebListingId(webListing.getId());
                count = count + 1;

                webProductListing.setRank(count + 1);
                webProductListingRepository.persist(webProductListing);

            }

        }
    }

    public void getPriceDrop() throws ProfitMandiBusinessException {
        WebListing webListing = webListingRepository.selectByUrl("partner-price-drop");

        Set<Integer> catalogItemIds = priceDropRepository.selectAllByDatesBetweenSortByDate(LocalDateTime.now().minusDays(30), LocalDateTime.now()).stream().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;
            for (Integer catalogItemId : catalogItemIds) {

                WebProductListing webProductListing = new WebProductListing();
                webProductListing.setEntityId(catalogItemId);
                webProductListing.setWebListingId(webListing.getId());
                count = count + 1;
                webProductListing.setRank(count);
                webProductListingRepository.persist(webProductListing);

            }

        }
    }

    public void getNewLaunches() throws ProfitMandiBusinessException {
        WebListing webListing = webListingRepository.selectByUrl("new-launches");

        List<Integer> catalogItemIds = tagListingRepository.getRecentLanuch(LocalDate.now().minusDays(30), LocalDate.now().plusDays(1));

        if (!catalogItemIds.isEmpty()) {
            webProductListingRepository.deleteByEqual(webListing.getId());
            int count = 0;
            for (Integer catalogItemId : catalogItemIds) {

                WebProductListing webProductListing = new WebProductListing();
                webProductListing.setEntityId(catalogItemId);
                webProductListing.setWebListingId(webListing.getId());
                count = count + 1;
                webProductListing.setRank(count);
                webProductListingRepository.persist(webProductListing);

            }

        }
    }

    public void getSpecialSupport() throws ProfitMandiBusinessException {
        WebListing webListing = webListingRepository.selectByUrl("special-support");

        List<Integer> catalogItemIds = schemeRepository.getActiveScheme(SchemeType.SPECIAL_SUPPORT, LocalDate.now().plusDays(1));

        LOGGER.info("catalogItemIds {}", catalogItemIds);
        if (!catalogItemIds.isEmpty()) {
            webProductListingRepository.deleteByEqual(webListing.getId());
            int count = 0;
            for (Integer catalogItemId : catalogItemIds) {

                WebProductListing webProductListing = new WebProductListing();
                webProductListing.setEntityId(catalogItemId);
                webProductListing.setWebListingId(webListing.getId());
                count = count + 1;
                webProductListing.setRank(count);
                webProductListingRepository.persist(webProductListing);

            }

        }
    }

    public void getUpgradeOffer() throws ProfitMandiBusinessException {
        WebListing webListing = webListingRepository.selectByUrl("upgrade-offer");
        webProductListingRepository.deleteByEqual(webListing.getId());

        List<Integer> customerOfferIds = customerOfferRepository.selectOffers(LocalDate.now()).stream().map(x -> x.getId()).collect(Collectors.toList());

        List<Integer> catalogItemIds = customerOfferItemRepository.selectByOfferIdsRange(customerOfferIds, LocalDate.now()).stream().map(x -> x.getCatalogId()).distinct().collect(Collectors.toList());

        LOGGER.info("catalogItemIds {}", catalogItemIds);
        if (!catalogItemIds.isEmpty()) {
            int count = 0;
            for (Integer catalogItemId : catalogItemIds) {

                WebProductListing webProductListing = new WebProductListing();
                webProductListing.setEntityId(catalogItemId);
                webProductListing.setWebListingId(webListing.getId());
                count = count + 1;
                webProductListing.setRank(count);
                webProductListingRepository.persist(webProductListing);

            }

        }
    }

    @Scheduled(cron = "0 0 6,18 * * *")
    public void scheduledPushDataToSolr() throws Throwable {
        this.pushDataToSolr();
    }

    /**
     * Retire dead catalogue, 30 minutes ahead of the 06:00 reindex above so the
     * same morning's Solr pass publishes it - a bulk UPDATE fires no
     * TagListingChangeListener event, so without that ordering the portal would
     * lag until 18:00.
     *
     * <p>Steady state is small: the 2026-09-10 backfill cleared a 2.5-year
     * backlog, so a run now catches only listings newly crossing the 24-month
     * line plus items whose stock just went to zero.
     */
    @Scheduled(cron = "0 30 5 * * *")
    public void scheduledDelistDeadListings() {
        if (!autoDelistEnabled) {
            LOGGER.info("catalog delist skipped: catalog.autoDelist.enabled=false");
            return;
        }
        LOGGER.info("catalog delist starting");
        LOGGER.info("catalog delist finished: {}", catalogDelistService.delistDeadListings());
    }

    @Scheduled(cron = "0 0 8 * * *")
    public void scheduledGetBestSeller() throws Throwable {
        this.getBestSeller();
    }

    @Scheduled(cron = "0 0 8 * * *")
    public void scheduledGetPriceDrop() throws Throwable {
        this.getPriceDrop();
    }

    @Scheduled(cron = "0 0 8 * * *")
    public void scheduledGetNewLaunches() throws Throwable {
        this.getNewLaunches();
    }

    @Scheduled(cron = "0 0 8 * * *")
    public void scheduledGetSpecialSupport() throws Throwable {
        this.getSpecialSupport();
    }

    @Scheduled(cron = "0 0 8 * * *")
    public void scheduledGetUpgradeOffer() throws Throwable {
        this.getUpgradeOffer();
    }
}