/*
 *  Copyright (c) 2010-2011, ITArchitects
 *  All rights reserved.
 * 
 *
 *  THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 *  "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 *  LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 *  A PARTICULAR PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE COPYRIGHT OWNER
 *  OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
 *  EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
 *  PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
 *  PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
 *  LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
 *  NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
 *  SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */


package at.itarchitects.wist.server.ejb;

//import at.itarchitects.wist.server.entities.accidentcase.AccidentCase;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import javax.ejb.EJB;
import javax.ejb.EJBException;
import javax.ejb.LocalBean;
import javax.ejb.Singleton;
import javax.ejb.Startup;
import javax.ejb.Timeout;
import javax.ejb.Timer;
import javax.ejb.TimerService;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.TypedQuery;

/**
 *
 * @author Clemens Lanthaler clemens.lanthaler@itarchitects.at
 */
@Singleton
@LocalBean
@Startup
public class StartupBean
{
/**
    @EJB
    private InvoiceBeanLocal invoiceBean;
**/

    @Resource
    TimerService timerService;
/**
    @PersistenceContext
    private EntityManager em;
**/
    @PostConstruct
    private void startup() {
        Collection<Timer> timerSet = timerService.getTimers();
/**
        List<Long> allActiveAccidentIDs = getAllActiveAccidentIDs();
        for (Long refNr : allActiveAccidentIDs) {
            boolean checkIfTimerExists = checkIfTimerExists(refNr, timerSet);
            if (checkIfTimerExists == false) {
**/
                createTimer(System.currentTimeMillis()); //refNr);
/**
            }
        }
**/
    }

    /**
     * Checks if a timer is already running
     * @param refNr case ID
     * @param timerSet set of actual running timers
     * @return true if running timer found
     * @throws EJBException
     * @throws IllegalStateException
     */
    @SuppressWarnings("unchecked")
    private boolean checkIfTimerExists(long refNr, Collection<Timer> timerSet) throws EJBException, IllegalStateException {
        for (Iterator<Timer> it = timerSet.iterator(); it.hasNext();) {
            Timer timer = it.next();
            ArrayList<Object> data = (ArrayList<Object>) timer.getInfo();
            long caseID = (Long) data.get(0);
            if (refNr == caseID) {
                return true;
            }
        }
        return false;
    }

    /*
     * finds all accident case IDs which are not locked
     * @Return null if nothing is found
     */
    private List<Long> getAllActiveAccidentIDs() {
/**
        TypedQuery<Long> findAllRefNumbersNotLocked = em.createQuery("SELECT acase.referenceNumber FROM AccidentCase acase WHERE acase.locked=false", Long.class);
        List<Long> resultList = findAllRefNumbersNotLocked.getResultList();
        return resultList;
**/
        return null;
    }

    private void createTimer(long refNr) throws EJBException {
/**
        AccidentCase aCase = em.find(AccidentCase.class, refNr);
        if (aCase != null) {
**/
            Collection<Timer> timerSet = timerService.getTimers();
            ArrayList<Object> data = new ArrayList<Object>();
            data.add(refNr);
/**
            data.add(aCase.getInvoiceAdress());
            data.add(aCase.getUserID());
**/
            Timer timer = timerService.createTimer(100, //aCase.getLockDate(),
                    data);
/**
        }
**/
    }

    @Timeout
    @SuppressWarnings(value = "unchecked")
    public void timeout(Timer timer) {
        //invoiceBean.timeout(timer);
        ArrayList<Object> data = (ArrayList<Object>)timer.getInfo();
        System.err.println("In timeout for " + data.get(0));
    }

}