/*
 * Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
 * Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
 */
package com.megatim.fdxconsultation.service.impl.sockets;

/**
 *
 * @author Lenovo P53
 */
import com.megatim.fdxconsultation.core.ifaces.administration.UserManager;
import com.megatim.fdxconsultation.core.ifaces.message.systeme.MessageSystemeManager;
import com.megatim.fdxconsultation.model.administration.User;
import com.megatim.fdxconsultation.model.dto.MessageSystemeDto;
import com.megatim.fdxconsultation.model.message.systeme.ApplicationData;
import com.megatim.fdxconsultation.model.message.systeme.UserSesionApplication;
import com.megatim.fdxconsultation.tools.context.AppCommonContext;
import java.util.Iterator;
import javax.annotation.PostConstruct;
import javax.ejb.LocalBean;
import javax.ejb.Schedule;
import javax.ejb.Singleton;
import javax.ejb.Startup;
import javax.inject.Inject;
import javax.websocket.Session;

@Singleton
@Startup
@LocalBean
public class MessagesSystemeCronBean {
    
    @Inject
    private MessageSystemeManager messageSystemeManager;
    
    @Inject
    private UserManager userManager;
    
    @PostConstruct
    public void init() {
        
    }

    @Schedule(second = "*/3", minute = "*", hour = "*", persistent = false)
    public void refreshDatas() {
        
        //Variables
        ApplicationData message = new ApplicationData();
        MessageSystemeDto messageSystemeDto = null;
        Iterator<String> iterateur = null;
        String idSession = null;
        Session session = null;
        User utilisateur = null;
        
        try {
        
            //On crée une instance de l'iterateur
            iterateur = UserSesionApplication.getInstance().getUsers().keySet().iterator();   

            //On parcourt la liste des sessions
            while(iterateur.hasNext()){  

                //On recupère l'id de la session
                idSession = iterateur.next();
                
                //On filtre par type
                if(UserSesionApplication.getInstance().getUsers() != null && UserSesionApplication.getInstance().getUsers().get(idSession) != null
                        && (UserSesionApplication.getInstance().getUsers().get(idSession).getType() != null
                        && UserSesionApplication.getInstance().getUsers().get(idSession).getType().equalsIgnoreCase(AppCommonContext.CODE_WEB_SOCKET_PATH_SYSTEME_MESSAGE))){
                
                    //On recupère la session
                    session = UserSesionApplication.getInstance().getUsers().get(idSession).getSession();

                    //On recupère l'utilisateur associé à cette session
                    utilisateur = UserSesionApplication.getInstance().getUsers().get(idSession).getUtilisateur();

                    //On recupère le message système
                    messageSystemeDto = messageSystemeManager.recupererUnMessageSystemeDto(utilisateur);

                    //Si non null
                    if(messageSystemeDto != null){
                    
                        //On hydrate le message
                        message.setMessageSystemeDto(messageSystemeDto);

                        //On envoie le message
                        UserSesionApplication.getInstance().send(session, message);
                    
                    }
                    
                }

            }
            
        } catch (Exception ex) {
                
            //On affiche les erreurs
            ex.printStackTrace();

        }
        
    }
    
}