/*
|
* 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.bekosoftware.genericdaolayer.dao.tools.RestrictionsContainer;
|
import com.megatim.fdxcommons.model.enumeration.EtatOperation;
|
import com.megatim.fdxcommons.model.enumeration.TypeOperation;
|
import com.megatim.fdxconsultation.core.ifaces.administration.RoleManager;
|
import com.megatim.fdxconsultation.core.ifaces.administration.UserManager;
|
import com.megatim.fdxconsultation.model.administration.User;
|
import com.megatim.fdxconsultation.model.dto.AdministrationNumberDto;
|
import com.megatim.fdxconsultation.model.dto.InformationGeneraleDto;
|
import com.megatim.fdxconsultation.model.dto.UserDto;
|
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.ArrayList;
|
import java.util.Iterator;
|
import java.util.List;
|
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 AdministrationCronBean {
|
|
@Inject
|
private UserManager userManager;
|
|
@Inject
|
private RoleManager roleManager;
|
|
@PostConstruct
|
public void init() {
|
|
}
|
|
// @Schedule(second = "*/1", minute = "*", hour = "*", persistent = false)
|
public void refreshDatas() {
|
|
//Variables
|
ApplicationData message = new ApplicationData();
|
InformationGeneraleDto informationGeneraleDto = null;
|
AdministrationNumberDto administrationNumberDto = null;
|
Iterator<String> iterateur = null;
|
String idSession = null;
|
Session session = null;
|
User utilisateur = null;
|
User utilisateurBD = null;
|
|
try {
|
|
//On crée une instance de l'iterateur
|
iterateur = UserSesionApplication.getInstance().getUsers().keySet().iterator();
|
|
//On construit l'objet AdministrationNumberDto
|
administrationNumberDto = new AdministrationNumberDto();
|
administrationNumberDto.setUtilisateursEnAttenteValidation(countUsers(EtatOperation.ATTENTE_VALIDATION));
|
administrationNumberDto.setRolesEnAttenteValidation(countRoles(EtatOperation.ATTENTE_VALIDATION));
|
|
//On construit l'objet InformationGeneraleDto
|
informationGeneraleDto = new InformationGeneraleDto();
|
|
//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_APPLICATION_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();
|
utilisateurBD = userManager.findById(utilisateur.getId());
|
|
//Si non null
|
if (utilisateurBD != null) {
|
|
//On set la clé de la session
|
informationGeneraleDto.setSessionKeyUser(utilisateurBD.getCleSession());
|
|
}
|
|
//On hydrate le message
|
message.setInformationGeneraleDto(informationGeneraleDto);
|
message.setAdministrationNumberDto(administrationNumberDto);
|
message.setUtlisateursConnectes(obtenirListeUtilisateursConnectes());
|
|
//On envoie le message
|
UserSesionApplication.getInstance().send(session, message);
|
|
}
|
|
}
|
|
} catch (Exception ex) {
|
|
//On affiche les erreurs
|
ex.printStackTrace();
|
|
}
|
|
}
|
|
/**
|
* Methode permettant de recuperer la liste des utilisateurs connectés
|
*
|
* @return
|
*/
|
private List<UserDto> obtenirListeUtilisateursConnectes() {
|
List<UserDto> liste = new ArrayList<UserDto>();
|
String idSession = null;
|
Iterator<String> iterateur = null;
|
UserDto userDto = null;
|
iterateur = UserSesionApplication.getInstance().getUsers().keySet().iterator();
|
while (iterateur.hasNext()) {
|
idSession = iterateur.next();
|
userDto = new UserDto();
|
userDto.setUserName(UserSesionApplication.getInstance().getUsers().get(idSession).getUtilisateur().getUserName());
|
liste.add(userDto);
|
}
|
return liste;
|
}
|
|
private long countUsers(EtatOperation etatOperation) {
|
RestrictionsContainer requeteur = RestrictionsContainer.newInstance();
|
requeteur.addEq("typeOperation", TypeOperation.AJOUTER);
|
requeteur.addEq("etatOperation", etatOperation);
|
return userManager.count(requeteur.getPredicats());
|
}
|
|
private long countRoles(EtatOperation etatOperation) {
|
RestrictionsContainer requeteur = RestrictionsContainer.newInstance();
|
requeteur.addEq("typeOperation", TypeOperation.AJOUTER);
|
requeteur.addEq("etatOperation", etatOperation);
|
return roleManager.count(requeteur.getPredicats());
|
}
|
|
}
|
