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.entity.transaction.PriceDrop;

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);

        // Wipe first so a window that yields zero qualifying catalogs collapses

        // the list to empty instead of leaving yesterday's stale entries in place.

        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");

        // "Latest event wins" per catalog: group all price_drop rows in the

        // 30-day window by catalogItemId, take the row with the latest

        // affectedOn (tiebreak on id for determinism), and keep the catalog

        // only if that row is a drop (amount > 0). A hike after an earlier

        // drop removes the label immediately — previously the filter

        // considered any drop row in the window, so a later hike was ignored

        // and the catalog stayed labeled even when currently priced higher.

        Set<Integer> catalogItemIds = priceDropRepository.selectAllByDatesBetweenSortByDate(LocalDateTime.now().minusDays(30), LocalDateTime.now())

                .stream()

                .collect(Collectors.groupingBy(

                        PriceDrop::getCatalogItemId,

                        Collectors.maxBy(Comparator

                                .comparing(PriceDrop::getAffectedOn)

                                .thenComparingInt(PriceDrop::getId))))

                .entrySet().stream()

                .filter(e -> e.getValue().isPresent() && e.getValue().get().getAmount() > 0)

                .map(Map.Entry::getKey)

                .collect(Collectors.toSet());

        LOGGER.info("catalogItemIds {}", catalogItemIds);

        // Wipe unconditionally: filter is on affectedOn (rolling 30 days), so

        // catalogs whose most recent drop slides out of the window must be

        // removed even when no new drops happened that day. Prior guard left

        // stale entries in place (see catalog 1026477 case).

        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));

        // Wipe first so items that fall out of the 30-day window get removed

        // even when no fresh launches were tagged that day.

        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);

        // Wipe first so items whose scheme ended get cleared even when no

        // Special Support scheme is active on this day.

        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();

    }

}