gitee
/
eiam
mirror of https://gitee.com/topiam/eiam
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

身份源同步

pull/65/head
xiuchen 2023-10-09 14:31:56 +08:00
parent 08f8e7a932
commit ad92f6cc78
4 changed files with 2 additions and 81 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
eiam-console/src/main/java/cn/topiam/employee/console/service/identitysource/impl/IdentitySourceServiceImpl.java
View File

@ -208,7 +208,6 @@ public class IdentitySourceServiceImpl implements IdentitySourceService {
@Override
public Boolean saveIdentitySourceConfig(IdentitySourceConfigSaveParam param) {
IdentitySourceEntity entity = getIdentitySource(param.getId());
param.getBasicConfig().putAll(JSONObject.parseObject(entity.getBasicConfig()));
//转换
IdentitySourceEntity source = identitySourceConverter
.saveConfigParamConverterToEntity(param, entity.getProvider());

1
eiam-console/src/main/java/cn/topiam/employee/console/synchronizer/endpoint/IdentitySourceEventReceiveEndpoint.java
View File

@ -70,6 +70,7 @@ public class IdentitySourceEventReceiveEndpoint {
Object event = identitySource.event(request, body);
return ResponseEntity.ok(event);
}
log.error("身份源信息不存在:[{}]", code);
return ResponseEntity.ok().build();
}

2
eiam-console/src/main/java/cn/topiam/employee/console/synchronizer/processor/DefaultIdentitySourceUserPostProcessor.java
View File

@ -414,7 +414,7 @@ public class DefaultIdentitySourceUserPostProcessor extends AbstractIdentitySour
log.info("上游用户:[{}]对应系统用户:[{}]({})存在,用户信息不一致,修改用户信息：{}", thirdPartyUser.getUserId(), currentUser.getUsername(), currentUser.getId(), JSONObject.toJSONString(currentUser));
updateUsers.add(currentUser);
} else {
skipUsers.add(SkipUser.builder().user(currentUser).actionType(IdentitySourceActionType.UPDATE).status(SyncStatus.SKIP).reason( "用户信息一致").build());
skipUsers.add(SkipUser.builder().user(currentUser).actionType(IdentitySourceActionType.UPDATE).status(SyncStatus.SKIP).reason("用户信息一致").build());
log.info("上游用户:[{}]对应系统用户:[{}]({})存在,用户信息一致", thirdPartyUser.getUserId(), currentUser.getUsername(), currentUser.getId());
}
//处理组织机构关系

79
eiam-protocol/eiam-protocol-jwt/src/main/java/cn/topiam/employee/protocol/jwt/token/JwtUtils.java
View File

@ -1,79 +0,0 @@
/*
* eiam-protocol-jwt - Employee Identity and Access Management
* Copyright © 2022-Present Jinan Yuanchuang Network Technology Co., Ltd. (support@topiam.cn)
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package cn.topiam.employee.protocol.jwt.token;
import java.io.IOException;
import java.security.PublicKey;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import cn.topiam.employee.common.util.X509Utils;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import io.jsonwebtoken.*;
/**
* JWT 工具类
*
* @author TopIAM
* Created by support@topiam.cn on 2023/02/12 21:58
*/
@Slf4j
@NoArgsConstructor(access = AccessLevel.PRIVATE)
public class JwtUtils {
private static final Logger logger = LoggerFactory.getLogger(JwtUtils.class);
/**
* parserToken
*
* @param token {@link String}
* @param publicKey {@link String}
* @return {@link Claims}
*/
public static Claims parserToken(String token, String publicKey) {
try {
PublicKey readPublicKey = X509Utils.readPublicKey(publicKey, "");
JwtParser jwtParser = Jwts.parserBuilder().setSigningKey(readPublicKey).build();
// 解析 JWT
return jwtParser.parseClaimsJws(token).getBody();
} catch (io.jsonwebtoken.security.SecurityException | MalformedJwtException e) {
logger.info("Invalid JWT signature.");
logger.trace("Invalid JWT signature trace: {}", e.getMessage());
throw e;
} catch (ExpiredJwtException e) {
logger.info("Expired JWT token.");
logger.trace("Expired JWT token trace: {}", e.getMessage());
throw e;
} catch (UnsupportedJwtException e) {
logger.info("Unsupported JWT token.");
logger.trace("Unsupported JWT token trace: {}", e.getMessage());
throw e;
} catch (IllegalArgumentException e) {
logger.info("JWT token compact of handler are invalid.");
logger.trace("JWT token compact of handler are invalid trace: {}", e.getMessage());
throw e;
} catch (IOException e) {
throw new RuntimeException(e);
}
}
}