Subversion Repositories SmartDukaan

package com.spice.profitmandi.dao.event;

import com.spice.profitmandi.dao.service.solr.FofoSolr;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.context.ApplicationListener;

import org.springframework.context.annotation.Profile;

import org.springframework.context.event.ContextRefreshedEvent;

import org.springframework.stereotype.Component;

/**

 * Triggers a full Solr sync on application startup.

 * Ensures data consistency after application restarts.

 * Only active in production environment.

 */

@Component

@Profile("scheduled")

public class SolrStartupSync implements ApplicationListener<ContextRefreshedEvent> {

    private static final Logger logger = LoggerFactory.getLogger(SolrStartupSync.class);

    private boolean executed = false;

    @Value("${prod:false}")

    private boolean isProd;

    @Autowired

    private FofoSolr fofoSolr;

    @Override

    public void onApplicationEvent(ContextRefreshedEvent event) {

        // Only execute once (ContextRefreshedEvent may fire multiple times)

        if (executed) {

            return;

        }

        executed = true;

        if (!isProd) {

            logger.info("Skipping Solr startup sync in non-prod environment");

            return;

        }

        logger.info("Application context refreshed - triggering full Solr sync for data consistency");

        try {

            fofoSolr.pushData();

            logger.info("Full Solr sync completed successfully on startup");

        } catch (Exception e) {

            logger.error("Full Solr sync failed on startup", e);

        }

    }

}