package org.apereo.cas.web.landtool.log.listener;
|
|
import java.util.Map;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.apereo.cas.authentication.principal.Service;
|
import org.apereo.cas.ticket.TicketGrantingTicket;
|
import org.apereo.cas.web.landtool.log.service.LogService;
|
import org.apereo.cas.web.landtool.rabbitmq.RadarRabbitMqTemplate;
|
import org.apereo.cas.web.landtool.rabbitmq.config.RabbitMqProperties;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.event.EventListener;
|
import org.springframework.scheduling.annotation.Async;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
/**
|
* @author Tanbin
|
* @date 2018-12-12
|
*/
|
public class LogListener {
|
private static final Logger LOGGER = LoggerFactory.getLogger(LogListener.class);
|
|
@Autowired
|
private LogService logService;
|
@Autowired
|
private RadarRabbitMqTemplate rabbitMqTemplate;
|
@Autowired
|
private RabbitMqProperties rabbitConfig;
|
|
public LogListener() {
|
|
}
|
|
/**
|
* 发送用户登陆i消息
|
* @param event
|
*/
|
@EventListener
|
@Async
|
public void onTgtCreated(org.apereo.cas.support.events.CasTicketGrantingTicketCreatedEvent event) {
|
TicketGrantingTicket ticketGrantingTicket = event.getTicketGrantingTicket();
|
String userId = ticketGrantingTicket.getAuthentication().getPrincipal().getId();
|
String tgtId = ticketGrantingTicket.getId();
|
String clientIp = (String) ticketGrantingTicket.getAuthentication().getAttributes().get("clientIp");
|
String browserInfo = (String) ticketGrantingTicket.getAuthentication().getAttributes().get("browserInfo");
|
String serviceUrl = (String) ticketGrantingTicket.getAuthentication().getAttributes().get("serviceUrl");
|
if(!StringUtils.isNotBlank(browserInfo)) {
|
browserInfo = "未知";
|
}
|
if(!StringUtils.isNotBlank(serviceUrl)) {
|
serviceUrl = "ssologin";
|
}
|
LOGGER.debug("#####LOGIN:[{}],[{}],[{}],[{}], [{}]", userId, clientIp, browserInfo, tgtId , serviceUrl);
|
System.out.println("onTgtCreated#####VALIDATE:[{}],[{}],[{}],[{}],[{}]"+ userId+"-"+ clientIp+"-"+tgtId+"-"+ serviceUrl);
|
logService.addLog(userId, clientIp, 1, 0, browserInfo, serviceUrl);
|
if(rabbitConfig.isEnabled()){
|
JSONObject json = new JSONObject();
|
json.put("userId", userId);
|
json.put("clientIp", clientIp);
|
json.put("status", "登入");
|
json.put("browserInfo", browserInfo);
|
///
|
// json.put("serviceUrl", serviceUrl);
|
rabbitMqTemplate.send(rabbitConfig.getRmqRoutingKeyPrefixCas()+"login", json.toJSONString());
|
}
|
}
|
|
/**
|
* 发送用户登出消息
|
* @param event
|
*/
|
@EventListener
|
@Async
|
public void onTgtDestroyed(org.apereo.cas.support.events.CasTicketGrantingTicketDestroyedEvent event) {
|
TicketGrantingTicket ticketGrantingTicket = event.getTicketGrantingTicket();
|
String userId = ticketGrantingTicket.getAuthentication().getPrincipal().getId();
|
String tgtId = ticketGrantingTicket.getId();
|
String clientIp = (String) ticketGrantingTicket.getAuthentication().getAttributes().get("clientIp");
|
String browserInfo = (String) ticketGrantingTicket.getAuthentication().getAttributes().get("browserInfo");
|
if(!StringUtils.isNotBlank(browserInfo)) {
|
browserInfo = "未知";
|
}
|
LOGGER.debug("#####LOGOUT:[{}],[{}],[{}]", userId, clientIp, tgtId);
|
System.out.println("onTgtDestroyed#####LOGOUT:[{}],[{}],[{}]"+userId+"-"+clientIp+"-"+tgtId);
|
if(rabbitConfig.isEnabled()){
|
logService.addLog(userId, clientIp, 2, 0, browserInfo, "ssologout");
|
JSONObject json = new JSONObject();
|
json.put("userId", userId);
|
json.put("clientIp", clientIp);
|
json.put("status", "登出");
|
json.put("browserInfo", browserInfo);
|
///
|
//json.put("serviceUrl", "ssologout");
|
rabbitMqTemplate.send(rabbitConfig.getRmqRoutingKeyPrefixCas()+"logout", json.toJSONString());
|
}
|
}
|
|
/**
|
* 登录登出日志添加
|
* @param event
|
*/
|
@EventListener
|
@Async
|
public void onStValidated(org.apereo.cas.support.events.CasServiceTicketValidatedEvent event) {
|
TicketGrantingTicket ticketGrantingTicket = event.getServiceTicket().getGrantingTicket();
|
String userId = ticketGrantingTicket.getAuthentication().getPrincipal().getId();
|
String tgtId = ticketGrantingTicket.getId();
|
String clientIp = (String) ticketGrantingTicket.getAuthentication().getAttributes().get("clientIp");
|
String stId = event.getServiceTicket().getId();
|
String appUrl = "";
|
String browserInfo = (String) ticketGrantingTicket.getAuthentication().getAttributes().get("browserInfo");
|
if(!StringUtils.isNotBlank(browserInfo)) {
|
browserInfo = "未知";
|
}
|
Map<String, Service> services = ticketGrantingTicket.getServices();
|
Service service = services.get(stId);
|
if(service != null) {
|
appUrl = service.getId();
|
}
|
LOGGER.debug("#####VALIDATE:[{}],[{}],[{}],[{}],[{}]", userId, clientIp, tgtId, stId, appUrl);
|
System.out.println("onStValidated#####VALIDATE:[{}],[{}],[{}],[{}],[{}]"+ userId+"-"+ clientIp+"-"+tgtId+"-"+stId+"-"+ appUrl);
|
logService.addLog(userId, clientIp, 3, 0, browserInfo, appUrl);
|
|
}
|
|
}
|
