Subversion Repositories SmartDukaan

package com.smartdukaan.cron.scheduled;

import com.spice.profitmandi.dao.model.ImeiActivationTimestampModel;
import com.spice.profitmandi.dao.repository.fofo.ActivatedImeiRepository;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

@Component
public class StandAlone {

        @Autowired
        private OppoImeiActivationService oppoImeiActivationService;

        @Autowired
        private RealmeImeiActivationService realmeImeiActivationService;

        @Autowired
        private ActivatedImeiRepository activatedImeiRepository;

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

        public void checkOppoImeiStatus() throws Exception {
                List<ImeiActivationTimestampModel> imeiActivationTimestampModels = activatedImeiRepository.selectImeiActivationPendingByBrand("Oppo", 1, 25);
                List<String> imeis = imeiActivationTimestampModels.stream().map(x -> x.getSerialNumber()).collect(Collectors.toList());
                LOGGER.info("Oppo secondary imeis {}", imeis);
                oppoImeiActivationService.updateActivationDate(imeis);
        }

        public void checkOppoImeiStatusTertiary() throws Exception {
                List<ImeiActivationTimestampModel> imeiActivationTimestampModels = activatedImeiRepository.selectImeiActivationPendingByBrandTertiary("Oppo", 1, 25);
                List<String> imeis = imeiActivationTimestampModels.stream().map(x -> x.getSerialNumber()).collect(Collectors.toList());
                LOGGER.info("Oppo tertiary imeis {}", imeis);
                oppoImeiActivationService.updateActivationDate(imeis);
        }

        public void checkRealmeImeiStatus() throws Exception {
                List<ImeiActivationTimestampModel> imeiActivationTimestampModels = activatedImeiRepository.selectImeiActivationPendingByRealme("Realme", 1, 12);
                List<String> imeis = imeiActivationTimestampModels.stream().map(x -> x.getSerialNumber()).collect(Collectors.toList());
                LOGGER.info("Realme secondary imeis {}", imeis);
                realmeImeiActivationService.updateActivationDate(imeis);
        }

        public void checkRealmeImeiStatusTertiary() throws Exception {
                List<ImeiActivationTimestampModel> imeiActivationTimestampModels = activatedImeiRepository.selectImeiActivationPendingByBrandTertiary("Realme", 1, 12);
                List<String> imeis = imeiActivationTimestampModels.stream().map(x -> x.getSerialNumber()).collect(Collectors.toList());
                LOGGER.info("Realme tertiary imeis {}", imeis);
                realmeImeiActivationService.updateActivationDate(imeis);
        }

        /**
         * Secondary + tertiary in ONE browser session per brand.
         *
         * They were separate @Scheduled jobs, so each brand span up two ChromeDrivers at
         * once and the fleet ran four. Each driver tree costs roughly 850MB, and this box
         * co-hosts a 9.4GB tomcat with ~3GB available -- it has been OOM-killed twice this
         * month and tomcat was the victim both times. Halving concurrent drivers is the
         * single biggest memory saving available here.
         *
         * Nothing else changes: the two pools differ only in which named query fills them,
         * and both already funnel into the same updateActivationDate -> checkWarranty ->
         * saveActivation path. The pools are disjoint by construction (secondary excludes
         * anything with a FofoLineItem, tertiary is FofoLineItem-based); distinct() is cheap
         * insurance rather than a fix for a known overlap.
         *
         *
         * Sizing: merging SERIALISES work that used to run in parallel, so keeping the old
         * batch sizes would cost throughput. Measured post-cap at 10.2s/imei (oppo) and
         * 14.2s/imei (realme), solving M * 86400 / (300 + M*t):
         *   oppo    2 parallel jobs x10 = 4,299/day  ->  merged 30 = 4,277/day  (parity)
         *   realme  2 parallel jobs x10 = 3,910/day  ->  merged 20 = 2,959/day  (-24%)
         * Oppo is sized to hold parity because it is already short of its 4,798/day need.
         * Realme is left at 20 -- it needs 2,243/day, so it can absorb the dip in exchange
         * for shorter batches.
         *
         * Note what this does and does not save: total driver-SECONDS are unchanged (that is
         * the point of resizing), but PEAK concurrent drivers halves from 4 to 2. Peak is
         * what triggers the OOM killer, not average.
         *
         * The per-pool log lines are kept so existing log analysis still works.
         */
        public void checkOppoImeiStatusCombined() throws Exception {
                List<String> secondary = activatedImeiRepository.selectImeiActivationPendingByBrand("Oppo", 1, 15)
                                .stream().map(ImeiActivationTimestampModel::getSerialNumber).collect(Collectors.toList());
                List<String> tertiary = activatedImeiRepository.selectImeiActivationPendingByBrandTertiary("Oppo", 1, 15)
                                .stream().map(ImeiActivationTimestampModel::getSerialNumber).collect(Collectors.toList());
                LOGGER.info("Oppo secondary imeis {}", secondary);
                LOGGER.info("Oppo tertiary imeis {}", tertiary);
                List<String> all = new ArrayList<>(secondary);
                all.addAll(tertiary);
                all = all.stream().distinct().collect(Collectors.toList());
                if (all.isEmpty()) {
                        LOGGER.info("Oppo: nothing pending, not starting a browser");
                        return;
                }
                oppoImeiActivationService.updateActivationDate(all);
        }

        public void checkRealmeImeiStatusCombined() throws Exception {
                List<String> secondary = activatedImeiRepository.selectImeiActivationPendingByRealme("Realme", 1, 12)
                                .stream().map(ImeiActivationTimestampModel::getSerialNumber).collect(Collectors.toList());
                List<String> tertiary = activatedImeiRepository.selectImeiActivationPendingByBrandTertiary("Realme", 1, 12)
                                .stream().map(ImeiActivationTimestampModel::getSerialNumber).collect(Collectors.toList());
                LOGGER.info("Realme secondary imeis {}", secondary);
                LOGGER.info("Realme tertiary imeis {}", tertiary);
                List<String> all = new ArrayList<>(secondary);
                all.addAll(tertiary);
                all = all.stream().distinct().collect(Collectors.toList());
                if (all.isEmpty()) {
                        LOGGER.info("Realme: nothing pending, not starting a browser");
                        return;
                }
                realmeImeiActivationService.updateActivationDate(all);
        }

}