[jfinancials-war.git] /

/*
 * Copyright (C) 2017, 2018 Free Software Foundation
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
package org.mxchange.jfinancials.beans.business.opening_time;

import fish.payara.cdi.jsr107.impl.NamedCache;
import java.text.MessageFormat;
import java.util.Comparator;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import javax.annotation.PostConstruct;
import javax.cache.Cache;
import javax.ejb.EJB;
import javax.enterprise.context.RequestScoped;
import javax.enterprise.event.Observes;
import javax.inject.Inject;
import javax.inject.Named;
import org.mxchange.jcontactsbusiness.events.opening_time.added.ObservableOpeningTimeAddedEvent;
import org.mxchange.jcontactsbusiness.exceptions.opening_time.OpeningTimeNotFoundException;
import org.mxchange.jcontactsbusiness.model.opening_time.OpeningTime;
import org.mxchange.jcontactsbusiness.model.opening_time.OpeningTimeSessionBeanRemote;
import org.mxchange.jfinancials.beans.BaseFinancialsBean;

/**
 * A general bean for opening times
 * <p>
 * @author Roland Häder<roland@mxchange.org>
 */
@Named ("openingTimeController")
@RequestScoped
public class FinancialsOpeningTimeWebRequestBean extends BaseFinancialsBean implements FinancialsOpeningTimeWebRequestController {

        /**
         * Serial number
         */
        private static final long serialVersionUID = 5_028_697_360_462L;

        /**
         * A list of all opening times
         */
        private final List<OpeningTime> allOpeningTimes;

        /**
         * A list of filtered opening times
         */
        private List<OpeningTime> filteredOpeningTimes;

        /**
         * EJB for administrative purposes
         */
        @EJB (lookup = "java:global/jfinancials-ejb/openingTimes!org.mxchange.jcontactsbusiness.model.opening_time.OpeningTimeSessionBeanRemote")
        private OpeningTimeSessionBeanRemote openingTimesBean;

        /**
         * A list of all opening times (globally)
         */
        @Inject
        @NamedCache (cacheName = "openingTimesCache")
        private Cache<Long, OpeningTime> openingTimesCache;

        /**
         * Default constructor
         */
        public FinancialsOpeningTimeWebRequestBean () {
                // Call super constructor
                super();

                // Init list
                this.allOpeningTimes = new LinkedList<>();
        }

        /**
         * Observes events being thrown when a new opening time has been added
         * <p>
         * @param event Event being fired
         */
        public void afterOpeningTimeAddedEvent (@Observes final ObservableOpeningTimeAddedEvent event) {
                // Validate parameter
                if (null == event) {
                        // Throw NPE
                        throw new NullPointerException("event is null");
                } else if (event.getOpeningTime() == null) {
                        // Throw it again
                        throw new NullPointerException("event.openingTime is null");
                } else if (event.getOpeningTime().getOpeningId() == null) {
                        // Throw it again
                        throw new NullPointerException("event.openingTime.openingId is null");
                } else if (event.getOpeningTime().getOpeningId() < 1) {
                        // Throw it again
                        throw new NullPointerException(MessageFormat.format("event.openingTime.openingId={0} is invalid", event.getOpeningTime().getOpeningId()));
                }

                // Add to cache and list
                this.openingTimesCache.put(event.getOpeningTime().getOpeningId(), event.getOpeningTime());
                this.allOpeningTimes.add(event.getOpeningTime());
        }

        @Override
        @SuppressWarnings ("ReturnOfCollectionOrArrayField")
        public List<OpeningTime> allOpeningTimes () {
                return this.allOpeningTimes;
        }

        @Override
        public OpeningTime findOpeningTimeById (final Long openingId) throws OpeningTimeNotFoundException {
                // Validate parameter
                if (null == openingId) {
                        // Throw NPE
                        throw new NullPointerException("openingId is null"); //NOI18N
                } else if (openingId < 1) {
                        // Throw IAE
                        throw new IllegalArgumentException("openingId=" + openingId + " is invalid"); //NOI18N
                } else if (!this.openingTimesCache.containsKey(openingId)) {
                        // Not found
                        throw new OpeningTimeNotFoundException(openingId);
                }

                // Get it from cache
                final OpeningTime opening = this.openingTimesCache.get(openingId);

                // Return it
                return opening;
        }

        /**
         * Getter for a list of filtered opening times
         * <p>
         * @return Filtered opening times
         */
        @SuppressWarnings ("ReturnOfCollectionOrArrayField")
        public List<OpeningTime> getFilteredOpeningTimes () {
                return this.filteredOpeningTimes;
        }

        /**
         * Setter for a list of filtered opening times
         * <p>
         * @param filteredOpeningTimes Filtered opening times
         */
        @SuppressWarnings ("AssignmentToCollectionOrArrayFieldFromParameter")
        public void setFilteredOpeningTimes (final List<OpeningTime> filteredOpeningTimes) {
                this.filteredOpeningTimes = filteredOpeningTimes;
        }

        /**
         * Initializer method
         */
        @PostConstruct
        public void initializeList () {
                // Is cache there?
                if (!this.openingTimesCache.iterator().hasNext()) {
                        // Get whole list
                        final List<OpeningTime> openingTimes = this.openingTimesBean.allOpeningTimes();

                        // Add all
                        for (final OpeningTime openingTime : openingTimes) {
                                // Add it to cache
                                this.openingTimesCache.put(openingTime.getOpeningId(), openingTime);
                        }
                }

                // Is the list empty, but filled cache?
                if (this.allOpeningTimes.isEmpty() && this.openingTimesCache.iterator().hasNext()) {
                        // Get iterator
                        final Iterator<Cache.Entry<Long, OpeningTime>> iterator = this.openingTimesCache.iterator();

                        // Build up list
                        while (iterator.hasNext()) {
                                // GEt next element
                                final Cache.Entry<Long, OpeningTime> next = iterator.next();

                                // Add to list
                                this.allOpeningTimes.add(next.getValue());
                        }

                        // Sort list
                        this.allOpeningTimes.sort(new Comparator<OpeningTime>() {
                                @Override
                                public int compare (final OpeningTime o1, final OpeningTime o2) {
                                        return o1.getOpeningId() > o2.getOpeningId() ? 1 : o1.getOpeningId() < o2.getOpeningId() ? -1 : 0;
                                }
                        }
                        );
                }
        }

}