Subversion Repositories SmartDukaan

package com.spice.profitmandi.service;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
import com.spice.profitmandi.dao.entity.user.AgendaInstance;
import com.spice.profitmandi.dao.entity.user.AgendaVisitLog;
import com.spice.profitmandi.dao.enumuration.dtr.AgendaSource;
import com.spice.profitmandi.dao.enumuration.dtr.AgendaStatus;
import com.spice.profitmandi.dao.repository.dtr.AgendaInstanceRepository;
import com.spice.profitmandi.dao.repository.dtr.AgendaVisitLogRepository;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.time.LocalDate;
import java.time.LocalDateTime;

@Service
@Transactional
public class AgendaInstanceServiceImpl implements AgendaInstanceService {

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

    @Autowired
    AgendaInstanceRepository agendaInstanceRepository;

    @Autowired
    AgendaVisitLogRepository agendaVisitLogRepository;

    @Override
    public AgendaInstance open(int fofoId, String agendaType, AgendaSource source, Integer openedBy,
                               String openMetricJson) throws ProfitMandiBusinessException {
        AgendaInstance existing = agendaInstanceRepository.selectOpenByFofoIdAndType(fofoId, agendaType);
        if (existing != null) return existing;

        AgendaInstance instance = new AgendaInstance();
        instance.setFofoId(fofoId);
        instance.setAgendaType(agendaType);
        instance.setSource(source.name());
        instance.setStatus(AgendaStatus.OPEN.name());
        instance.setOpenedOn(LocalDateTime.now());
        instance.setOpenedBy(openedBy);
        instance.setOpenMetric(openMetricJson);
        try {
            agendaInstanceRepository.persist(instance);
            return instance;
        } catch (Exception e) {
            // uq_one_open race: someone opened it between select and insert.
            AgendaInstance winner = agendaInstanceRepository.selectOpenByFofoIdAndType(fofoId, agendaType);
            if (winner != null) {
                LOGGER.info("Agenda open race for fofoId={} type={} — using existing instance {}",
                        fofoId, agendaType, winner.getId());
                return winner;
            }
            throw new ProfitMandiBusinessException("agendaType", agendaType,
                    "Could not open agenda instance for fofoId " + fofoId + ": " + e.getMessage());
        }
    }

    @Override
    public void closeByMetric(AgendaInstance instance, String closeMetricJson) {
        instance.setStatus(AgendaStatus.CLOSED.name());
        instance.setClosedOn(LocalDateTime.now());
        instance.setClosedBy(null);
        instance.setCloseMetric(closeMetricJson);
        agendaInstanceRepository.persist(instance);
    }

    @Override
    public void closeManual(AgendaInstance instance, int closedBy, String remark)
            throws ProfitMandiBusinessException {
        if (AgendaSource.AUTO.name().equals(instance.getSource())) {
            throw new ProfitMandiBusinessException("instanceId", instance.getId(),
                    "Auto agendas close only when the metric normalizes");
        }
        if (!AgendaStatus.OPEN.name().equals(instance.getStatus())) {
            throw new ProfitMandiBusinessException("instanceId", instance.getId(),
                    "Agenda instance is already closed");
        }
        instance.setStatus(AgendaStatus.CLOSED.name());
        instance.setClosedOn(LocalDateTime.now());
        instance.setClosedBy(closedBy);
        instance.setCloseRemark(remark);
        agendaInstanceRepository.persist(instance);
    }

    @Override
    public java.util.List<AgendaInstance> filterVisibleForVisit(java.util.List<AgendaInstance> openInstances) {
        return filterVisibleForVisitStatic(openInstances);
    }

    // Static + pure for unit tests. Input must be one store's OPEN instances.
    static java.util.List<AgendaInstance> filterVisibleForVisitStatic(java.util.List<AgendaInstance> openInstances) {
        if (openInstances == null || openInstances.isEmpty()) return openInstances;
        boolean revivalOpen = false;
        for (AgendaInstance ai : openInstances) {
            if (com.spice.profitmandi.dao.enumuration.dtr.AgendaType.REVIVAL.name().equals(ai.getAgendaType())) {
                revivalOpen = true;
                break;
            }
        }
        if (!revivalOpen) return openInstances;
        java.util.List<AgendaInstance> visible = new java.util.ArrayList<>();
        for (AgendaInstance ai : openInstances) {
            boolean keep = AgendaSource.MANUAL.name().equals(ai.getSource())
                    || com.spice.profitmandi.dao.enumuration.dtr.AgendaType.REVIVAL.name().equals(ai.getAgendaType())
                    || com.spice.profitmandi.dao.enumuration.dtr.AgendaType.CREDIT_DUES.name().equals(ai.getAgendaType());
            if (keep) visible.add(ai);
        }
        return visible;
    }

    @Override
    public void logVisit(int instanceId, Integer locationTrackingId, int visitorUserId,
                         LocalDate visitDate, String discussion) throws ProfitMandiBusinessException {
        AgendaInstance instance = agendaInstanceRepository.selectById(instanceId);
        if (instance == null) {
            throw new ProfitMandiBusinessException("instanceId", instanceId, "Agenda instance not found");
        }
        if (!AgendaStatus.OPEN.name().equals(instance.getStatus())) {
            throw new ProfitMandiBusinessException("instanceId", instanceId,
                    "Agenda instance is closed — discussions attach to open agendas only");
        }
        AgendaVisitLog log = new AgendaVisitLog();
        log.setAgendaInstanceId(instanceId);
        log.setLocationTrackingId(locationTrackingId);
        log.setVisitorUserId(visitorUserId);
        log.setVisitDate(visitDate != null ? visitDate : LocalDate.now());
        log.setDiscussion(discussion);
        agendaVisitLogRepository.persist(log);
    }
}