Subversion Repositories SmartDukaan

    public void updatePartnerActivationTypeByMonthlySale() throws Exception {

        LocalDateTime now = LocalDateTime.now();

        LocalDateTime thirtyDaysAgo = now.minusDays(30);

        LocalDateTime sixtyDaysAgo = now.minusDays(60);

        long threshold = 99_999L;

        List<FofoStore> candidates = fofoStoreRepository.selectByStatus(true).stream().filter(x-> !x.isInternal()).collect(toList());

        if (candidates.isEmpty()) {

            LOGGER.info("updatePartnerActivationTypeByMonthlySale: no candidate stores");

            return;

        }

        List<Integer> ids = candidates.stream().map(FofoStore::getId).collect(Collectors.toList());

        Set<Integer> met30 = orderRepository.selectFofoIdsWithMtdBillingAboveThreshold(ids, thirtyDaysAgo, now, threshold);

        Set<Integer> met60 = orderRepository.selectFofoIdsWithMtdBillingAboveThreshold(ids, sixtyDaysAgo, now, threshold);

        int toFocus = 0;

        int toRevival = 0;

        for (FofoStore store : candidates) {

            int id = store.getId();

            boolean below30 = !met30.contains(id);

            boolean below60 = !met60.contains(id);

            ActivationType current = store.getActivationType();

            ActivationType target = current;

            if (below60) {

                target = ActivationType.REVIVAL;

            } else if (below30 && current == ActivationType.ACTIVE) {

                target = ActivationType.FOCUS;

            }

            if (target != current) {

                LOGGER.info("Auto-downgrade fofoId={} code={} from {} to {} (below30={}, below60={})",

                        id, store.getCode(), current, target, below30, below60);

                store.setActivationType(target);

                store.setActive(false);

                store.setActiveTimeStamp(null);

                fofoStoreRepository.persist(store);

                if (target == ActivationType.FOCUS) {

                    toFocus++;

                } else {

                    toRevival++;

                }

            }

        }

        LOGGER.info("updatePartnerActivationTypeByMonthlySale done: scanned={}, toFocus={}, toRevival={}",

                candidates.size(), toFocus, toRevival);

    }