parent
9464b209de
commit
8d6b5ef9be
2 changed files with 42 additions and 4 deletions
|
|
@ -56,4 +56,44 @@ public class UserAuthAction implements IAction<UserAuthRequest> {
|
||||||
public ActionType getActionType() {
|
public ActionType getActionType() {
|
||||||
return ActionType.SYSTEM;
|
return ActionType.SYSTEM;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public String getUsername() {
|
||||||
|
return username;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setUsername(String username) {
|
||||||
|
this.username = username;
|
||||||
|
}
|
||||||
|
|
||||||
|
public List<String> getRoles() {
|
||||||
|
return roles;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setRoles(List<String> roles) {
|
||||||
|
this.roles = roles;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Instant getTime() {
|
||||||
|
return time;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setTime(Instant time) {
|
||||||
|
this.time = time;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getServerIp() {
|
||||||
|
return serverIp;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setServerIp(String serverIp) {
|
||||||
|
this.serverIp = serverIp;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getClientIp() {
|
||||||
|
return clientIp;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setClientIp(String clientIp) {
|
||||||
|
this.clientIp = clientIp;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -8,7 +8,6 @@ import org.springframework.stereotype.Service;
|
||||||
import ru.spcex.clearing.backendapi.controller.request.cud.utilities.UserAuthAction;
|
import ru.spcex.clearing.backendapi.controller.request.cud.utilities.UserAuthAction;
|
||||||
import ru.spcex.clearing.backendapi.controller.request.cud.utilities.UserLogoutAction;
|
import ru.spcex.clearing.backendapi.controller.request.cud.utilities.UserLogoutAction;
|
||||||
import ru.spcex.clearing.platform.messaging.domain.Consts;
|
import ru.spcex.clearing.platform.messaging.domain.Consts;
|
||||||
import ru.spcex.clearing.platform.messaging.domain.cud.utilities.UserAuthRequest;
|
|
||||||
import ru.spcex.clearing.platform.messaging.domain.cud.utilities.UserLogoutRequest;
|
import ru.spcex.clearing.platform.messaging.domain.cud.utilities.UserLogoutRequest;
|
||||||
import ru.spcex.platform.utils.log.ExceptionUtils;
|
import ru.spcex.platform.utils.log.ExceptionUtils;
|
||||||
|
|
||||||
|
|
@ -34,15 +33,14 @@ public class UserAuthProcessor {
|
||||||
}
|
}
|
||||||
|
|
||||||
public void sendAuthSuccessEvent(String identifier, Collection<String> roles, String userIp, String serverIp) {
|
public void sendAuthSuccessEvent(String identifier, Collection<String> roles, String userIp, String serverIp) {
|
||||||
UserAuthAction authEvent = new UserAuthAction();
|
UserAuthAction requestData = new UserAuthAction();
|
||||||
UserAuthRequest requestData = authEvent.toRequest();
|
|
||||||
requestData.setUsername(identifier);
|
requestData.setUsername(identifier);
|
||||||
requestData.setTime(Instant.now());
|
requestData.setTime(Instant.now());
|
||||||
requestData.setRoles(new ArrayList<>(roles));
|
requestData.setRoles(new ArrayList<>(roles));
|
||||||
requestData.setServerIp(serverIp + ":" + serverPort); //getServerAddress() + ":" + serverPort
|
requestData.setServerIp(serverIp + ":" + serverPort); //getServerAddress() + ":" + serverPort
|
||||||
requestData.setClientIp(userIp);
|
requestData.setClientIp(userIp);
|
||||||
try {
|
try {
|
||||||
operator.sendRequestToQueue(Consts.USER_AUTH_SUCCESS, authEvent);
|
operator.sendRequestToQueue(Consts.USER_AUTH_SUCCESS, requestData);
|
||||||
} catch (Throwable e) { //ExecutionException | InterruptedException
|
} catch (Throwable e) { //ExecutionException | InterruptedException
|
||||||
log.error(ExceptionUtils.getStackTrace(e));
|
log.error(ExceptionUtils.getStackTrace(e));
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue