feat: 在用户登录事件中记录客户IP

Author: mousheng

server/api-service/barda-domain/src/main/java/com/barda/domain/auditlog/service/AuditLogEventListener.java

@@ -37,6 +37,7 @@ public class AuditLogEventListener {
     public void onUserLoginEvent(UserLoginEvent event) {
         LinkedHashMap<String, Object> detail = new LinkedHashMap<>();
         detail.put("loginWay", event.getSource());
+        detail.put("clientIp", event.getClientIp());
         this.record(event, detail);
     }
 

server/api-service/barda-infra/src/main/java/com/barda/infra/event/user/UserLoginEvent.java

@@ -12,6 +12,11 @@ public class UserLoginEvent extends AbstractEvent {
 
     private final String source;
 
+    /**
+     * 登录者的客户端IP地址
+     */
+    private final String clientIp;
+
     @Override
     public EventType getEventType() {
         return EventType.USER_LOGIN;

server/api-service/barda-server/src/main/java/com/barda/api/authentication/service/AuthenticationApiServiceImpl.java

@@ -238,7 +238,7 @@ public Mono<Void> loginOrRegister(AuthUser authUser, ServerWebExchange exchange,
                     return invitationApiService.inviteUser(invitationId);
                 })
                 // 发布事件
-                .then(businessEventPublisher.publishUserLoginEvent(authUser.getSource()));
+                .then(businessEventPublisher.publishUserLoginEvent(authUser.getSource(), exchange));
     }
 
     /**

server/api-service/barda-server/src/main/java/com/barda/api/usermanagement/OrganizationController.java

@@ -136,7 +136,7 @@ public Mono<ResponseView<?>> setCurrentOrganization(@PathVariable String orgId,
                 // 切换到指定的组织
                 .then(orgApiService.switchCurrentOrganizationTo(orgId))
                 // 延迟直到发布用户登录事件
-                .delayUntil(result -> businessEventPublisher.publishUserLoginEvent(null))
+                .delayUntil(result -> businessEventPublisher.publishUserLoginEvent(null, serverWebExchange))
                 // 检查组织域并构建响应视图
                 .flatMap(result -> orgApiService.checkOrganizationDomain()
                         .flatMap(OrganizationDomainCheckResult::buildOrganizationDomainCheckView)

server/api-service/barda-server/src/main/java/com/barda/api/util/BusinessEventPublisher.java

@@ -51,10 +51,12 @@
 import com.barda.infra.event.groupmember.GroupMemberRoleUpdateEvent;
 import com.barda.infra.event.user.UserLoginEvent;
 import com.barda.infra.event.user.UserLogoutEvent;
+import com.barda.infra.util.NetworkUtils;
 import com.barda.sdk.util.LocaleUtils;
 
 import lombok.extern.slf4j.Slf4j;
 import reactor.core.publisher.Mono;
+import org.springframework.web.server.ServerWebExchange;
 
 @Slf4j
 @Component
@@ -150,13 +152,15 @@ public Mono<Void> publishApplicationCommonEvent(ApplicationView applicationView,
                 });
     }
 
-    public Mono<Void> publishUserLoginEvent(String source) {
+    public Mono<Void> publishUserLoginEvent(String source, ServerWebExchange exchange) {
+        String clientIp = NetworkUtils.getRemoteIp(exchange);
         return sessionUserService.getVisitorOrgMember()
                 .doOnNext(orgMember -> {
                     UserLoginEvent event = UserLoginEvent.builder()
                             .orgId(orgMember.getOrgId())
                             .userId(orgMember.getUserId())
                             .source(source)
+                            .clientIp(clientIp)
                             .build();
                     applicationEventPublisher.publishEvent(event);
                 })