审计日志相关代码提交

pqs-auth/src/main/java/com/njcn/auth/service/UserTokenService.java

@@ -2,11 +2,16 @@ package com.njcn.auth.service;
 
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
+import com.github.tocrhz.mqtt.publisher.MqttPublisher;
 import com.nimbusds.jose.JWSObject;
+import com.njcn.common.config.GeneralInfo;
+import com.njcn.common.pojo.constant.OperateType;
 import com.njcn.common.pojo.constant.SecurityConstants;
+import com.njcn.common.pojo.dto.LogInfoDTO;
 import com.njcn.common.pojo.dto.UserTokenInfo;
 import com.njcn.common.pojo.enums.response.CommonResponseEnum;
 import com.njcn.common.pojo.exception.BusinessException;
+import com.njcn.common.utils.PubUtils;
 import com.njcn.redis.utils.RedisUtil;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -33,6 +38,10 @@ public class UserTokenService {
 
     private final RedisUtil redisUtil;
 
+    private final MqttPublisher publisher;
+
+    private final GeneralInfo generalInfo;
+
 
     /**
      * 记录用户token信息，并经过处理后达到最新登录的使用者，将之前的token信息置为黑名单，过期状态
@@ -45,7 +54,7 @@ public class UserTokenService {
      * @param oAuth2AccessToken 认证后的最新token信息
      */
     @Async("asyncExecutor")
-    public void recordUserInfo(OAuth2AccessToken oAuth2AccessToken) {
+    public void recordUserInfo(OAuth2AccessToken oAuth2AccessToken,String ip) {
         UserTokenInfo userTokenInfo = new UserTokenInfo();
         String accessTokenValue = oAuth2AccessToken.getValue();
         JWSObject accessJwsObject ;
@@ -56,6 +65,7 @@ public class UserTokenService {
         }
         JSONObject accessJson = JSONUtil.parseObj(accessJwsObject.getPayload().toString());
         String userIndex = accessJson.getStr(SecurityConstants.USER_INDEX_KEY);
+        String nickName = accessJson.getStr(SecurityConstants.USER_NICKNAME_KEY);
         //查询是否有在线的当前用户
         String onlineUserKey = SecurityConstants.TOKEN_ONLINE_PREFIX + userIndex;
         Object onlineTokenInfoOld = redisUtil.getObjectByKey(onlineUserKey);
@@ -91,6 +101,10 @@ public class UserTokenService {
         userTokenInfo.setRefreshTokenExpire(refreshLifeTime);
         //生命周期在refreshToken的基础上，延迟5分钟
         redisUtil.saveByKeyWithExpire(onlineUserKey, userTokenInfo, refreshLifeTime.plusMinutes(5L).toEpochSecond(ZoneOffset.of("+8")) - LocalDateTime.now().toEpochSecond(ZoneOffset.of("+8")));
+
+        //记录成功登录后的信息
+        LogInfoDTO logInfoDTO = new LogInfoDTO(nickName, ip, "登录认证", OperateType.AUTHENTICATE, 1, "",0, 1, generalInfo.getMicroServiceName(), userIndex);
+        publisher.send("/userLog", PubUtils.obj2json(logInfoDTO), 2, false);
     }
 
     /**