Subversion Repositories SmartDukaan

package com.spice.profitmandi.service;

import com.spice.profitmandi.dao.entity.user.AgendaInstance;

import com.spice.profitmandi.dao.enumuration.dtr.AgendaSource;

import com.spice.profitmandi.dao.enumuration.dtr.AgendaType;

import com.spice.profitmandi.dao.repository.dtr.AgendaInstanceRepository;

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

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Propagation;

import org.springframework.transaction.annotation.Transactional;

import java.util.Map;

/**

 * Per-store write step of the nightly agenda sync. Separate bean (not a method

 * on the orchestrator) so the REQUIRES_NEW proxy actually applies — one store's

 * failure rolls back only its own instance changes.

 *

 * Only AUTO instances are ever closed here; MANUAL instances belong to the

 * visiting team. OPEN on a type that already has any open instance (AUTO or

 * MANUAL) is a no-op via AgendaInstanceService.open.

 */

@Service

public class AgendaAutoRuleApplier {

    @Autowired

    AgendaInstanceRepository agendaInstanceRepository;

    @Autowired

    AgendaInstanceService agendaInstanceService;

    /** Returns {opened, closed} for this store. */

    @Transactional(propagation = Propagation.REQUIRES_NEW)

    public int[] applyForStore(int fofoId, Map<AgendaType, AgendaRuleDecider.Decision> decisions)

            throws Exception {

        int opened = 0;

        int closed = 0;

        for (Map.Entry<AgendaType, AgendaRuleDecider.Decision> e : decisions.entrySet()) {

            AgendaType type = e.getKey();

            AgendaRuleDecider.Decision d = e.getValue();

            if (d.action == AgendaRuleDecider.Action.LEAVE) continue;

            AgendaInstance existing = agendaInstanceRepository.selectOpenByFofoIdAndType(fofoId, type.name());

            if (d.action == AgendaRuleDecider.Action.OPEN) {

                if (existing == null) {

                    agendaInstanceService.open(fofoId, type.name(), AgendaSource.AUTO, null, d.metric);

                    opened++;

                }

            } else { // CLOSE

                if (existing != null && AgendaSource.AUTO.name().equals(existing.getSource())) {

                    agendaInstanceService.closeByMetric(existing, d.metric);

                    closed++;

                }

            }

        }

        return new int[]{opened, closed};

    }

}