From 225826cbc116adcd46e57e3472b73be4e1de69f8 Mon Sep 17 00:00:00 2001 From: wangxiang <1827945911@qq.com> Date: Wed, 23 Aug 2023 05:25:19 +0800 Subject: [PATCH] chore: cas sso model business change --- .../AuthorizationServerConfiguration.java | 6 +- .../kicc/common/data/entity/CasUser.java | 5 + .../kicc/common/data/entity/CommonEntity.java | 3 +- .../kicc/common/data/entity/KiccUser.java | 4 +- .../datasource/dynamic/DynamicDataSource.java | 2 +- .../DynamicDataSourceJdbcProvider.java | 6 +- .../support/DynamicDataSourceConstant.java | 2 +- .../kicc/common/datasource/util/ConnUtil.java | 2 +- .../util/DynamicDataSourceUtil.java | 4 +- .../override/jackson2/ExUserDeserializer.java | 7 +- .../service/KiccUserDetailsService.java | 48 ++-- .../impl/KiccAppUserDetailsServiceImpl.java | 4 +- .../impl/KiccUserDetailsServiceImpl.java | 6 +- .../common/security/util/SecurityUtils.java | 69 ++++-- .../feign/RemotePushConcernFanService.java | 2 +- .../cloud/kicc/system/api/entity/SsoUser.java | 6 +- .../cloud/kicc/system/api/entity/User.java | 118 +-------- .../system/api/feign/RemoteUserService.java | 9 +- .../com/cloud/kicc/system/api/vo/UserVo.java | 62 +++++ .../workflow/api/constant/SqlConstants.java | 6 +- .../controller/MapTaskController.java | 8 +- .../controller/MapTaskPresetController.java | 8 +- .../controller/PushBlacklistController.java | 7 +- .../commonbiz/mapper/PushBlacklistMapper.java | 3 +- .../service/IPushBlacklistService.java | 3 +- .../service/impl/MapLogisticServiceImpl.java | 12 +- .../impl/PushBlacklistServiceImpl.java | 6 +- .../resources/mapper/PushBlacklistMapper.xml | 62 ++--- .../resources/mapper/PushConcernFanMapper.xml | 92 ++++--- .../kicc/system/controller/AppController.java | 17 +- .../system/controller/SsoUserController.java | 13 +- .../system/controller/TenantController.java | 9 +- .../system/controller/UserController.java | 112 ++------- .../cloud/kicc/system/mapper/UserMapper.java | 33 ++- .../kicc/system/service/ISsoUserService.java | 8 + .../kicc/system/service/UserService.java | 41 +++- .../system/service/impl/AppServiceImpl.java | 11 +- .../service/impl/SsoUserServiceImpl.java | 32 +++ .../system/service/impl/UserServiceImpl.java | 84 ++++--- .../src/main/resources/mapper/UserMapper.xml | 225 +++++++++++++++--- 40 files changed, 678 insertions(+), 479 deletions(-) create mode 100644 kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/vo/UserVo.java diff --git a/kicc-auth/src/main/java/com/cloud/kicc/auth/config/AuthorizationServerConfiguration.java b/kicc-auth/src/main/java/com/cloud/kicc/auth/config/AuthorizationServerConfiguration.java index c85f68d9..15e07ee2 100644 --- a/kicc-auth/src/main/java/com/cloud/kicc/auth/config/AuthorizationServerConfiguration.java +++ b/kicc-auth/src/main/java/com/cloud/kicc/auth/config/AuthorizationServerConfiguration.java @@ -1,12 +1,11 @@ package com.cloud.kicc.auth.config; import com.cloud.kicc.common.core.constant.SecurityConstants; -import com.cloud.kicc.common.data.entity.CasUser; -import com.cloud.kicc.common.data.entity.KiccUser; import com.cloud.kicc.common.security.grant.app.ResourceOwnerCustomeAppTokenGranter; import com.cloud.kicc.common.security.override.KiccClientDetailsService; import com.cloud.kicc.common.security.override.KiccCustomTokenServices; import com.cloud.kicc.common.security.override.KiccWebResponseExceptionTranslator; +import com.cloud.kicc.common.security.util.SecurityUtils; import lombok.RequiredArgsConstructor; import lombok.SneakyThrows; import org.springframework.context.annotation.Bean; @@ -104,8 +103,7 @@ public class AuthorizationServerConfiguration extends AuthorizationServerConfigu return accessToken; } - KiccUser kiccUser = (KiccUser) authentication.getUserAuthentication().getPrincipal(); - additionalInfo.put(SecurityConstants.DETAILS_USER, kiccUser); + additionalInfo.put(SecurityConstants.DETAILS_USER, SecurityUtils.getCasUser()); ((DefaultOAuth2AccessToken) accessToken).setAdditionalInformation(additionalInfo); return accessToken; }; diff --git a/kicc-common/kicc-common-data/src/main/java/com/cloud/kicc/common/data/entity/CasUser.java b/kicc-common/kicc-common-data/src/main/java/com/cloud/kicc/common/data/entity/CasUser.java index 766b248c..54b8d203 100644 --- a/kicc-common/kicc-common-data/src/main/java/com/cloud/kicc/common/data/entity/CasUser.java +++ b/kicc-common/kicc-common-data/src/main/java/com/cloud/kicc/common/data/entity/CasUser.java @@ -74,6 +74,9 @@ public class CasUser extends User { /** 备注 */ private String remarks; + /** 角色ID */ + private String roleId; + /** 多租户ID */ private String tenantId; @@ -111,6 +114,7 @@ public class CasUser extends User { String updateByName, LocalDateTime updateTime, String remarks, + String roleId, String tenantId) { super(username, password, enabled, accountNonExpired, credentialsNonExpired, accountNonLocked, authorities); this.id = id; @@ -128,6 +132,7 @@ public class CasUser extends User { this.updateByName = updateByName; this.updateTime = updateTime; this.remarks = remarks; + this.roleId = roleId; this.tenantId = tenantId; } diff --git a/kicc-common/kicc-common-data/src/main/java/com/cloud/kicc/common/data/entity/CommonEntity.java b/kicc-common/kicc-common-data/src/main/java/com/cloud/kicc/common/data/entity/CommonEntity.java index 273db5d9..0cff3935 100644 --- a/kicc-common/kicc-common-data/src/main/java/com/cloud/kicc/common/data/entity/CommonEntity.java +++ b/kicc-common/kicc-common-data/src/main/java/com/cloud/kicc/common/data/entity/CommonEntity.java @@ -7,9 +7,9 @@ import com.fasterxml.jackson.annotation.JsonFormat; import com.fasterxml.jackson.annotation.JsonIgnore; import io.swagger.annotations.ApiModelProperty; import lombok.Data; +import lombok.EqualsAndHashCode; import java.time.LocalDateTime; -import java.util.Date; /** *

@@ -20,6 +20,7 @@ import java.util.Date; * @Date: 2021/12/28 */ @Data +@EqualsAndHashCode(callSuper = true) public class CommonEntity extends BaseEntity { private static final long serialVersionUID = 1L; diff --git a/kicc-common/kicc-common-data/src/main/java/com/cloud/kicc/common/data/entity/KiccUser.java b/kicc-common/kicc-common-data/src/main/java/com/cloud/kicc/common/data/entity/KiccUser.java index 69e2c992..8593bdb2 100644 --- a/kicc-common/kicc-common-data/src/main/java/com/cloud/kicc/common/data/entity/KiccUser.java +++ b/kicc-common/kicc-common-data/src/main/java/com/cloud/kicc/common/data/entity/KiccUser.java @@ -28,14 +28,14 @@ public class KiccUser extends CasUser { private String userType; /** 扩展用户权限 */ - private Set exPermissions; + private String[] exPermissions; public KiccUser(String username, String password, Collection authorities, String deptId, String userType, - Set exPermissions) { + String[] exPermissions) { super(username, password, authorities); this.deptId = deptId; this.userType = userType; diff --git a/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/dynamic/DynamicDataSource.java b/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/dynamic/DynamicDataSource.java index 0280f21f..9b0153b1 100644 --- a/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/dynamic/DynamicDataSource.java +++ b/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/dynamic/DynamicDataSource.java @@ -10,7 +10,7 @@ import lombok.experimental.Accessors; *

* * @Author: wangxiang4 - * @since: 2023/7/3 + * @Since: 2023/7/3 */ @Data @Accessors(chain = true) diff --git a/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/dynamic/DynamicDataSourceJdbcProvider.java b/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/dynamic/DynamicDataSourceJdbcProvider.java index 8ebfb553..313dc254 100644 --- a/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/dynamic/DynamicDataSourceJdbcProvider.java +++ b/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/dynamic/DynamicDataSourceJdbcProvider.java @@ -19,7 +19,7 @@ import java.util.Map; *

* * @Author: wangxiang4 - * @since: 2023/7/3 + * @Since: 2023/7/3 */ public class DynamicDataSourceJdbcProvider extends AbstractJdbcDataSourceProvider { @@ -55,7 +55,7 @@ public class DynamicDataSourceJdbcProvider extends AbstractJdbcDataSourceProvide map.put(dynamicDataSourceProperties.getPrimary(), masterProperty); // 构建yml数据源 Map datasource = dynamicDataSourceProperties.getDatasource(); - if (datasource.size() > 0) { + if (!datasource.isEmpty()) { datasource.remove(dynamicDataSourceProperties.getPrimary()); map.putAll(datasource); } @@ -79,7 +79,7 @@ public class DynamicDataSourceJdbcProvider extends AbstractJdbcDataSourceProvide jdbcProperty.setUrl(url); jdbcProperty.setUsername(username); jdbcProperty.setPassword(password); - map.put(id, jdbcProperty); + map.put(name, jdbcProperty); } } } catch (Exception e) { diff --git a/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/support/DynamicDataSourceConstant.java b/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/support/DynamicDataSourceConstant.java index 9145edcd..e098539e 100644 --- a/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/support/DynamicDataSourceConstant.java +++ b/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/support/DynamicDataSourceConstant.java @@ -6,7 +6,7 @@ package com.cloud.kicc.common.datasource.support; *

* * @Author: wangxiang4 - * @since: 2023/7/3 + * @Since: 2023/7/3 */ public interface DynamicDataSourceConstant { diff --git a/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/util/ConnUtil.java b/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/util/ConnUtil.java index 322cf4ec..837daf0b 100644 --- a/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/util/ConnUtil.java +++ b/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/util/ConnUtil.java @@ -12,7 +12,7 @@ import java.sql.SQLException; *

* * @Author: wangxiang4 - * @since: 2023/7/3 + * @Since: 2023/7/3 */ public class ConnUtil { diff --git a/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/util/DynamicDataSourceUtil.java b/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/util/DynamicDataSourceUtil.java index 2d3ae0c5..1a5ada86 100644 --- a/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/util/DynamicDataSourceUtil.java +++ b/kicc-common/kicc-common-datasource/src/main/java/com/cloud/kicc/common/datasource/util/DynamicDataSourceUtil.java @@ -23,7 +23,7 @@ import java.sql.SQLException; *

* * @Author: wangxiang4 - * @since: 2023/7/3 + * @Since: 2023/7/3 */ @Setter @Slf4j @@ -35,7 +35,7 @@ public class DynamicDataSourceUtil { private static DefaultDataSourceCreator defaultDataSourceCreator; private static int MAX_DATASOURCE_COUNT = 300; // 最多保存三百个数据源,按使用率淘汰 - private static LRUMap linksProperties = new LRUMap(MAX_DATASOURCE_COUNT); + private static final LRUMap linksProperties = new LRUMap(MAX_DATASOURCE_COUNT); public DynamicDataSourceUtil(DataSource dynamicRoutingDataSource, DynamicDataSourceProperties dynamicDataSourceProperties, diff --git a/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/override/jackson2/ExUserDeserializer.java b/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/override/jackson2/ExUserDeserializer.java index d219c74d..d32a1a4d 100644 --- a/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/override/jackson2/ExUserDeserializer.java +++ b/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/override/jackson2/ExUserDeserializer.java @@ -13,7 +13,6 @@ import org.springframework.security.core.authority.AuthorityUtils; import java.io.IOException; import java.util.List; -import java.util.Set; /** *

@@ -25,7 +24,7 @@ import java.util.Set; */ class ExUserDeserializer extends JsonDeserializer { - private static final TypeReference> EX_PERMISSIONS_SET = new TypeReference>() {}; + private static final TypeReference EX_PERMISSIONS_SET = new TypeReference() {}; @Override public KiccUser deserialize(JsonParser jp, DeserializationContext context) throws IOException { @@ -36,8 +35,8 @@ class ExUserDeserializer extends JsonDeserializer { String password = passwordNode.asText(""); String deptId = readJsonNode(jsonNode, "deptId").asText(); String userType = readJsonNode(jsonNode, "userType").asText(); - Set exPermissions = mapper.convertValue(jsonNode.get("exPermissions"), EX_PERMISSIONS_SET); - List authorities = AuthorityUtils.createAuthorityList(exPermissions.toArray(new String[0])); + String[] exPermissions = mapper.convertValue(jsonNode.get("exPermissions"), EX_PERMISSIONS_SET); + List authorities = AuthorityUtils.createAuthorityList(exPermissions); KiccUser result = new KiccUser( username, password, diff --git a/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/KiccUserDetailsService.java b/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/KiccUserDetailsService.java index 0a97f382..a43c4de0 100644 --- a/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/KiccUserDetailsService.java +++ b/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/KiccUserDetailsService.java @@ -1,8 +1,6 @@ package com.cloud.kicc.common.security.service; -import cn.hutool.core.util.ArrayUtil; import cn.hutool.core.util.StrUtil; -import cn.hutool.json.JSONUtil; import com.cloud.kicc.common.core.api.R; import com.cloud.kicc.common.core.constant.CommonConstants; import com.cloud.kicc.common.core.constant.SecurityConstants; @@ -10,22 +8,17 @@ import com.cloud.kicc.common.core.enums.CasSystemEnum; import com.cloud.kicc.common.data.entity.CasUser; import com.cloud.kicc.common.data.entity.KiccUser; import com.cloud.kicc.common.security.exception.SecurityCheckedException; -import com.cloud.kicc.common.security.override.jackson2.ExUserMixin; -import com.cloud.kicc.system.api.entity.User; +import com.cloud.kicc.system.api.vo.UserVo; import com.fasterxml.jackson.annotation.JsonInclude; -import com.fasterxml.jackson.core.JsonProcessingException; -import com.fasterxml.jackson.databind.MapperFeature; import com.fasterxml.jackson.databind.ObjectMapper; -import com.fasterxml.jackson.databind.SerializationFeature; import lombok.SneakyThrows; -import org.springframework.beans.BeanUtils; import org.springframework.core.Ordered; import org.springframework.security.core.GrantedAuthority; import org.springframework.security.core.authority.AuthorityUtils; import org.springframework.security.core.userdetails.UserDetails; import org.springframework.security.core.userdetails.UserDetailsService; -import java.util.*; +import java.util.List; /** *

@@ -61,23 +54,14 @@ public interface KiccUserDetailsService extends UserDetailsService, Ordered { * @return UserDetails */ @SneakyThrows - default UserDetails getUserDetails(R result) { + default UserDetails getUserDetails(R result) { // 验证请求是否成功 if (result.getCode() != R.SUCCESS) { throw new SecurityCheckedException(result.getMsg()); } - User user = result.getData(); - Set dbAuthsSet = new HashSet<>(); - - if (ArrayUtil.isNotEmpty(user.getRoleIds())) { - // 获取角色 - Arrays.stream(user.getRoleIds()).forEach(role -> dbAuthsSet.add(SecurityConstants.ROLE + role)); - // 获取资源 - dbAuthsSet.addAll(Arrays.asList(user.getPermissions())); - } - - List authorities = AuthorityUtils.createAuthorityList(dbAuthsSet.toArray(new String[0])); + UserVo user = result.getData(); + List authorities = AuthorityUtils.createAuthorityList(user.getPermissions()); CasUser casUser = new CasUser( user.getUserName(), SecurityConstants.BCRYPT + user.getPassword(), @@ -85,9 +69,25 @@ public interface KiccUserDetailsService extends UserDetailsService, Ordered { true, true, StrUtil.equals(user.getStatus(), CommonConstants.STATUS_NORMAL), - authorities + authorities, + user.getCasUserId(), + user.getNickName(), + user.getEmail(), + user.getPhone(), + user.getSex(), + user.getAvatar(), + user.getLoginIp(), + user.getLoginTime(), + user.getCreateById(), + user.getCreateByName(), + user.getCreateTime(), + user.getUpdateById(), + user.getUpdateByName(), + user.getUpdateTime(), + user.getRemarks(), + String.join(",", user.getRoleIds()), + String.join(",", user.getTenantIds()) ); - BeanUtils.copyProperties(user, casUser, CasUser.class); // 设置扩展用户数据 casUser.getExPrincipals().put(CasSystemEnum.KICC, new ObjectMapper() @@ -98,7 +98,7 @@ public interface KiccUserDetailsService extends UserDetailsService, Ordered { authorities, user.getDeptId(), user.getUserType(), - dbAuthsSet + user.getPermissions() ))); // 构造security用户 diff --git a/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/impl/KiccAppUserDetailsServiceImpl.java b/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/impl/KiccAppUserDetailsServiceImpl.java index 5b207282..b5674c3b 100644 --- a/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/impl/KiccAppUserDetailsServiceImpl.java +++ b/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/impl/KiccAppUserDetailsServiceImpl.java @@ -4,8 +4,8 @@ import com.cloud.kicc.common.core.api.R; import com.cloud.kicc.common.core.constant.SecurityConstants; import com.cloud.kicc.common.data.entity.CasUser; import com.cloud.kicc.common.security.service.KiccUserDetailsService; -import com.cloud.kicc.system.api.entity.User; import com.cloud.kicc.system.api.feign.RemoteUserService; +import com.cloud.kicc.system.api.vo.UserVo; import lombok.RequiredArgsConstructor; import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; @@ -32,7 +32,7 @@ public class KiccAppUserDetailsServiceImpl implements KiccUserDetailsService { @Override @SneakyThrows public UserDetails loadUserByUsername(String phone) { - R result = remoteUserService.selectByPhone(phone); + R result = remoteUserService.selectByPhone(phone); return getUserDetails(result); } diff --git a/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/impl/KiccUserDetailsServiceImpl.java b/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/impl/KiccUserDetailsServiceImpl.java index 3c928eaf..614ec508 100644 --- a/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/impl/KiccUserDetailsServiceImpl.java +++ b/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/impl/KiccUserDetailsServiceImpl.java @@ -1,11 +1,9 @@ package com.cloud.kicc.common.security.service.impl; import com.cloud.kicc.common.core.api.R; -import com.cloud.kicc.common.core.constant.SecurityConstants; -import com.cloud.kicc.common.security.exception.SecurityCheckedException; import com.cloud.kicc.common.security.service.KiccUserDetailsService; -import com.cloud.kicc.system.api.entity.User; import com.cloud.kicc.system.api.feign.RemoteUserService; +import com.cloud.kicc.system.api.vo.UserVo; import lombok.RequiredArgsConstructor; import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; @@ -34,7 +32,7 @@ public class KiccUserDetailsServiceImpl implements KiccUserDetailsService { @Override @SneakyThrows public UserDetails loadUserByUsername(String username) { - R result = remoteUserService.selectByUserName(username); + R result = remoteUserService.selectByUserName(username); return getUserDetails(result); } diff --git a/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/util/SecurityUtils.java b/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/util/SecurityUtils.java index d649245c..778e2fa8 100644 --- a/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/util/SecurityUtils.java +++ b/kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/util/SecurityUtils.java @@ -1,6 +1,5 @@ package com.cloud.kicc.common.security.util; -import cn.hutool.core.util.ArrayUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONUtil; import com.cloud.kicc.common.core.api.R; @@ -12,8 +11,8 @@ import com.cloud.kicc.common.core.util.SpringContextHolderUtil; import com.cloud.kicc.common.data.entity.CasUser; import com.cloud.kicc.common.data.entity.KiccUser; import com.cloud.kicc.common.security.override.jackson2.ExUserMixin; -import com.cloud.kicc.system.api.entity.User; import com.cloud.kicc.system.api.feign.RemoteUserService; +import com.cloud.kicc.system.api.vo.UserVo; import com.fasterxml.jackson.annotation.JsonInclude; import com.fasterxml.jackson.databind.ObjectMapper; import lombok.SneakyThrows; @@ -26,7 +25,9 @@ import org.springframework.security.core.authority.AuthorityUtils; import org.springframework.security.core.context.SecurityContextHolder; import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder; -import java.util.*; +import java.util.ArrayList; +import java.util.Collection; +import java.util.List; /** *

@@ -69,21 +70,34 @@ public class SecurityUtils { } /** - * 获取SSO扩展用户 + * 获取完整用户 + * @param casSystemEnum SSO系统枚举 + * @param valueType 自定义扩展用户 + * @param mixinSource 自定义jackson混合解析源 + * @return T */ @SneakyThrows - public KiccUser getUser() { + public T getUser(CasSystemEnum casSystemEnum, + Class valueType, + Class mixinSource) { CasUser casUser = getCasUser(); if (casUser == null) return null; - String user = casUser.getExPrincipals().get(CasSystemEnum.KICC); - if (JSONUtil.isJson(user)) { - KiccUser exUser = new ObjectMapper().addMixIn(KiccUser.class, ExUserMixin.class).readValue(user, KiccUser.class); + String str = casUser.getExPrincipals().get(casSystemEnum); + if (JSONUtil.isJson(str)) { + T exUser = new ObjectMapper().addMixIn(valueType, mixinSource).readValue(str, valueType); BeanUtils.copyProperties(casUser, exUser); return exUser; } return null; } + /** + * 获取SSO扩展用户 + */ + public KiccUser getUser() { + return getUser(CasSystemEnum.KICC, KiccUser.class, ExUserMixin.class); + } + /** * 获取用户角色信息 * @return 角色集合 @@ -107,23 +121,14 @@ public class SecurityUtils { * @return User 用户对象 */ @SneakyThrows - public User openInterfaceTemporaryLoginSession(String userId) { + public UserVo openInterfaceTemporaryLoginSession(String userId) { RemoteUserService remoteUserService = SpringContextHolderUtil.getBean(RemoteUserService.class); - R result = remoteUserService.selectByUserId(userId); + R result = remoteUserService.selectByUserId(userId); if (result == null || result.getData() == null) { throw new CheckedException("用户不存在"); } - User user = result.getData(); - Set dbAuthsSet = new HashSet<>(); - if (ArrayUtil.isNotEmpty(user.getRoleIds())) { - // 获取角色 - Arrays.stream(user.getRoleIds()).forEach(role -> dbAuthsSet.add(SecurityConstants.ROLE + role)); - // 获取资源 - dbAuthsSet.addAll(Arrays.asList(user.getPermissions())); - } - - List authorities = AuthorityUtils.createAuthorityList(dbAuthsSet.toArray(new String[0])); - + UserVo user = result.getData(); + List authorities = AuthorityUtils.createAuthorityList(user.getPermissions()); CasUser casUser = new CasUser( user.getUserName(), SecurityConstants.BCRYPT + user.getPassword(), @@ -131,9 +136,25 @@ public class SecurityUtils { true, true, StrUtil.equals(user.getStatus(), CommonConstants.STATUS_NORMAL), - authorities + authorities, + user.getCasUserId(), + user.getNickName(), + user.getEmail(), + user.getPhone(), + user.getSex(), + user.getAvatar(), + user.getLoginIp(), + user.getLoginTime(), + user.getCreateById(), + user.getCreateByName(), + user.getCreateTime(), + user.getUpdateById(), + user.getUpdateByName(), + user.getUpdateTime(), + user.getRemarks(), + String.join(",", user.getRoleIds()), + String.join(",", user.getTenantIds()) ); - BeanUtils.copyProperties(user, casUser); // 设置扩展用户数据 casUser.getExPrincipals().put(CasSystemEnum.KICC, new ObjectMapper() .setSerializationInclusion(JsonInclude.Include.NON_NULL) @@ -143,7 +164,7 @@ public class SecurityUtils { authorities, user.getDeptId(), user.getUserType(), - dbAuthsSet + user.getPermissions() ))); Authentication authentication = new UsernamePasswordAuthenticationToken(casUser, "N/A", casUser.getAuthorities()); diff --git a/kicc-platform/kicc-platform-api/kicc-common-api/src/main/java/com/cloud/kicc/commonbiz/api/feign/RemotePushConcernFanService.java b/kicc-platform/kicc-platform-api/kicc-common-api/src/main/java/com/cloud/kicc/commonbiz/api/feign/RemotePushConcernFanService.java index 14342458..a67412bf 100644 --- a/kicc-platform/kicc-platform-api/kicc-common-api/src/main/java/com/cloud/kicc/commonbiz/api/feign/RemotePushConcernFanService.java +++ b/kicc-platform/kicc-platform-api/kicc-common-api/src/main/java/com/cloud/kicc/commonbiz/api/feign/RemotePushConcernFanService.java @@ -19,7 +19,7 @@ import java.util.Set; *

* * @Author: wangxiang4 - * @since: 2023/4/6 + * @Since: 2023/4/6 */ @FeignClient(contextId = "remotePushConcernFanService", value = ServiceNameConstants.COMMON_SERVICE) public interface RemotePushConcernFanService { diff --git a/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/entity/SsoUser.java b/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/entity/SsoUser.java index c7fc634f..4f73641c 100644 --- a/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/entity/SsoUser.java +++ b/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/entity/SsoUser.java @@ -21,7 +21,7 @@ import java.time.LocalDateTime; @Data @EqualsAndHashCode(callSuper = false) @Accessors(chain = true) -@TableName("sys_sso_user") +@TableName("cas_sso_user") @ApiModel(description = "SSO用户表") public class SsoUser extends CommonEntity { @@ -57,10 +57,6 @@ public class SsoUser extends CommonEntity { /** 最后登陆时间 */ private LocalDateTime loginTime; - /** 权限标识集合 */ - @TableField(exist = false) - private String[] permissions; - /** 新密码 */ @TableField(exist = false) private String newPassword; diff --git a/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/entity/User.java b/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/entity/User.java index ca4794b3..3e8f2950 100644 --- a/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/entity/User.java +++ b/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/entity/User.java @@ -1,8 +1,5 @@ package com.cloud.kicc.system.api.entity; -import com.alibaba.excel.annotation.ExcelProperty; -import com.baomidou.mybatisplus.annotation.TableField; -import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import com.cloud.kicc.common.data.entity.CommonEntity; import io.swagger.annotations.ApiModel; @@ -11,149 +8,46 @@ import lombok.Data; import lombok.EqualsAndHashCode; import lombok.experimental.Accessors; -import java.time.LocalDateTime; - /** *

* 用户信息表 *

* * @Author: wangxiang4 - * @Date: 2022/2/24 + * @Since: 2023/8/21 */ @Data @EqualsAndHashCode(callSuper = false) @Accessors(chain = true) -@TableName("sys_user") +@TableName(value = "sys_user", excludeProperty = { "remarks" }) @ApiModel(description = "用户表") public class User extends CommonEntity { private static final long serialVersionUID = 1L; - /** - * 用户ID - */ - @TableId - @ApiModelProperty("用户ID") + /** 用户ID */ private String id; - /** - * 用户名 - */ - @ExcelProperty("用户名") - @ApiModelProperty("用户名") - private String userName; - - /** - * 昵称 - */ - @ExcelProperty("昵称") - @ApiModelProperty("用户昵称") - private String nickName; - - /** - * 密码 - */ - @ApiModelProperty("用户密码") - private String password; + @ApiModelProperty("CAS用户ID") + private String casUserId; - /** - * 用户类型 - */ + /** {@link com.cloud.kicc.system.api.enums.UserTypeEnum } */ @ApiModelProperty("用户类型") private String userType; - /** - * 机构ID - */ @ApiModelProperty("机构ID") private String deptId; - /** - * 机构名称 - */ @ApiModelProperty("机构名称") private String deptName; - /** - * 用户邮箱 - */ - @ExcelProperty("邮箱") - @ApiModelProperty("邮箱") - private String email; - - /** - * 手机号码 - */ - @ExcelProperty("手机号码") - @ApiModelProperty("手机号码") - private String phone; - - /** - * 用户性别（0男 1女 2未知） - */ - @ExcelProperty("性别") - @ApiModelProperty("用户性别（0男 1女 2未知") - private String sex; - - /** - * 头像路径 - */ - @ApiModelProperty("头像路径") - private String avatar; - - /** - * 最后登陆IP - */ - @ApiModelProperty("最后登陆IP") - private String loginIp; - - /** - * 最后登陆时间 - */ - @ApiModelProperty("最后登陆时间") - private LocalDateTime loginTime; - - /** - * 地图标记点位置图片旋转值 - */ @ApiModelProperty("地图标记点位置图片旋转值") private Double mapOrientation; - /** - * 地图设计器默认中心点位置 - */ @ApiModelProperty("地图设计器默认中心点位置") private String mapCenter; - /** - * 帐号状态（0正常 1停用） - */ @ApiModelProperty("帐号状态（0正常 1停用）") private String status; - /** - * 内部系统账户 - */ - @ApiModelProperty("内部系统账户ID") - private Integer klabUserAccount; - - /** - * 角色ID集合 - */ - @TableField(exist = false) - @ApiModelProperty("角色ID集合") - private String[] roleIds; - - /** - * 权限标识集合 - */ - @TableField(exist = false) - private String[] permissions; - - /** - * 新密码 - */ - @TableField(exist = false) - private String newPassword; } diff --git a/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/feign/RemoteUserService.java b/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/feign/RemoteUserService.java index e0ec0d3e..999860af 100644 --- a/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/feign/RemoteUserService.java +++ b/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/feign/RemoteUserService.java @@ -4,11 +4,10 @@ import com.cloud.kicc.common.core.api.R; import com.cloud.kicc.common.core.constant.AppConstants; import com.cloud.kicc.common.core.constant.SecurityConstants; import com.cloud.kicc.common.core.constant.ServiceNameConstants; -import com.cloud.kicc.system.api.entity.User; +import com.cloud.kicc.system.api.vo.UserVo; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; -import org.springframework.web.bind.annotation.RequestHeader; /** *

@@ -27,7 +26,7 @@ public interface RemoteUserService { * @return R */ @GetMapping(value = AppConstants.APP_SYSTEM + "/user/selectByUserName/{userName}", headers = SecurityConstants.HEADER_FROM_IN) - R selectByUserName(@PathVariable("userName") String userName); + R selectByUserName(@PathVariable("userName") String userName); /** * 通过手机号码查询用户 @@ -35,7 +34,7 @@ public interface RemoteUserService { * @return R */ @GetMapping(value = AppConstants.APP_SYSTEM + "/user/selectByPhone/{phone}", headers = SecurityConstants.HEADER_FROM_IN) - R selectByPhone(@PathVariable("phone") String phone); + R selectByPhone(@PathVariable("phone") String phone); /** * 通过用户ID查询用户 @@ -43,6 +42,6 @@ public interface RemoteUserService { * @return R */ @GetMapping(value = AppConstants.APP_SYSTEM + "/user/getUser/{userId}", headers = SecurityConstants.HEADER_FROM_IN) - R selectByUserId(@PathVariable("userId") String userid); + R selectByUserId(@PathVariable("userId") String userid); } diff --git a/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/vo/UserVo.java b/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/vo/UserVo.java new file mode 100644 index 00000000..5bedd617 --- /dev/null +++ b/kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/vo/UserVo.java @@ -0,0 +1,62 @@ +package com.cloud.kicc.system.api.vo; + +import com.cloud.kicc.system.api.entity.SsoUser; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +/** + *

+ * 返回完整用户信息（CasUser and SystemUser） + *

+ * + * @Author: wangxiang4 + * @Since: 2023/8/21 + */ +@Data +@Accessors(chain = true) +@EqualsAndHashCode(callSuper = true) +@ApiModel(description = "完整用户信息VO") +public class UserVo extends SsoUser { + + private static final long serialVersionUID = 1L; + + private String id; + + @ApiModelProperty("CAS用户ID") + private String casUserId; + + /** {@link com.cloud.kicc.system.api.enums.UserTypeEnum } */ + @ApiModelProperty("用户类型") + private String userType; + + @ApiModelProperty("机构ID") + private String deptId; + + @ApiModelProperty("机构名称") + private String deptName; + + @ApiModelProperty("地图标记点位置图片旋转值") + private Double mapOrientation; + + @ApiModelProperty("地图设计器默认中心点位置") + private String mapCenter; + + @ApiModelProperty("帐号状态（0正常 1停用）") + private String status; + + @ApiModelProperty("指定登录后首页跳转") + private String homePath; + + @ApiModelProperty("角色ID集合") + private String[] roleIds; + + @ApiModelProperty("菜单按钮权限") + private String[] permissions; + + @ApiModelProperty("多租户ID集合") + private String[] tenantIds; + +} diff --git a/kicc-platform/kicc-platform-api/kicc-workflow-api/src/main/java/com/cloud/kicc/workflow/api/constant/SqlConstants.java b/kicc-platform/kicc-platform-api/kicc-workflow-api/src/main/java/com/cloud/kicc/workflow/api/constant/SqlConstants.java index f28c2860..2ce31118 100644 --- a/kicc-platform/kicc-platform-api/kicc-workflow-api/src/main/java/com/cloud/kicc/workflow/api/constant/SqlConstants.java +++ b/kicc-platform/kicc-platform-api/kicc-workflow-api/src/main/java/com/cloud/kicc/workflow/api/constant/SqlConstants.java @@ -12,10 +12,10 @@ public interface SqlConstants { String QUERY_ACT_HI_COMMENT= "select * from ACT_HI_COMMENT where TYPE_ like ? and TASK_ID_ = ? order by TIME_ desc"; - String QUERY_USER_BY_ID = "select id, user_name userName, nick_name nickName, password, dept_id deptId, status from sys_user where id = ?"; + String QUERY_USER_BY_ID = "select csu.id, csu.user_name userName, csu.nick_name nickName, csu.password, u.dept_id deptId, u.status from sys_user u join remote_cas_sso_user csu on u.cas_user_id = csu.id where csu.id = ?"; - String QUERY_USER_BY_DEPT_ID = "select id, user_name userName, nick_name nickName, password, dept_id deptId, status from sys_user where dept_id = ?"; + String QUERY_USER_BY_DEPT_ID = "select csu.id, csu.user_name userName, csu.nick_name nickName, csu.password, u.dept_id deptId, u.status from sys_user u join remote_cas_sso_user csu on u.cas_user_id = csu.id where u.dept_id = ?"; - String QUERY_USER_BY_ROLE_ID = "select distinct id, user_name userName, nick_name nickName, password, dept_id deptId, status from sys_user a, sys_user_role b where a.id = b.user_id and b.role_id = ?"; + String QUERY_USER_BY_ROLE_ID = "select distinct csu.id, csu.user_name userName, csu.nick_name nickName, csu.password, u.dept_id deptId, u.status from sys_user u join remote_cas_sso_user csu on u.cas_user_id = csu.id join sys_user_role b on csu.id = b.user_id where b.role_id = ?"; } diff --git a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapTaskController.java b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapTaskController.java index abe50b78..294c746e 100644 --- a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapTaskController.java +++ b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapTaskController.java @@ -9,13 +9,11 @@ import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.cloud.kicc.common.core.api.R; import com.cloud.kicc.common.core.constant.AppConstants; -import com.cloud.kicc.common.core.constant.SecurityConstants; import com.cloud.kicc.common.security.util.SecurityUtils; import com.cloud.kicc.commonbiz.api.entity.*; import com.cloud.kicc.commonbiz.service.*; -import com.cloud.kicc.system.api.entity.User; import com.cloud.kicc.system.api.feign.RemoteUserService; -import io.lettuce.core.api.push.PushMessage; +import com.cloud.kicc.system.api.vo.UserVo; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.RequiredArgsConstructor; @@ -87,7 +85,7 @@ public class MapTaskController { mapTask.setBatchCode(batchCode); JSONObject jsonObject = new JSONObject(); - R user = remoteUserService.selectByUserId(mapTask.getCourierUserId()); + R user = remoteUserService.selectByUserId(mapTask.getCourierUserId()); Hospital hospital = hospitalService.getById(mapTask.getHospitalId()); jsonObject.put("hospitalId", hospital.getKlabHospitalAccount()); if (StrUtil.isNotBlank(mapTask.getOrgId())) { @@ -100,7 +98,7 @@ public class MapTaskController { jsonObject.put("officeId", 0); jsonObject.put("doctorId", 0); - jsonObject.put("syUserId", user.getData().getKlabUserAccount()); + jsonObject.put("syUserId", user.getData().getCasUserId()); jsonObject.put("batchCode", mapTask.getBatchCode()); jsonObject.put("taskType", mapTask.getTaskType()); jsonObject.put("originImages", mapTask.getReceiptFileId()); diff --git a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapTaskPresetController.java b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapTaskPresetController.java index 1ca2f258..6f488486 100644 --- a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapTaskPresetController.java +++ b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapTaskPresetController.java @@ -9,7 +9,6 @@ import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.cloud.kicc.common.core.api.R; import com.cloud.kicc.common.core.constant.AppConstants; -import com.cloud.kicc.common.core.constant.SecurityConstants; import com.cloud.kicc.commonbiz.api.entity.Hospital; import com.cloud.kicc.commonbiz.api.entity.MapTaskPreset; import com.cloud.kicc.commonbiz.api.entity.Org; @@ -17,12 +16,11 @@ import com.cloud.kicc.commonbiz.service.HospitalService; import com.cloud.kicc.commonbiz.service.IMapLogisticService; import com.cloud.kicc.commonbiz.service.IMapTaskPresetService; import com.cloud.kicc.commonbiz.service.OrgService; -import com.cloud.kicc.system.api.entity.User; import com.cloud.kicc.system.api.feign.RemoteUserService; +import com.cloud.kicc.system.api.vo.UserVo; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.RequiredArgsConstructor; -import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.*; import java.util.Arrays; @@ -83,7 +81,7 @@ public class MapTaskPresetController { String batchCode = UUID.fromString(UUID.randomUUID().toString()).toString(); mapTaskPreset.setBatchCode(batchCode); JSONObject jsonObject = new JSONObject(); - R user = remoteUserService.selectByUserId(mapTaskPreset.getCourierUserId()); + R user = remoteUserService.selectByUserId(mapTaskPreset.getCourierUserId()); if (StrUtil.isNotBlank(mapTaskPreset.getOrginPresetId())) { Hospital hospital = hospitalService.getById(mapTaskPreset.getOrginPresetId()); jsonObject.put("hospitalId", hospital.getKlabHospitalAccount()); @@ -99,7 +97,7 @@ public class MapTaskPresetController { jsonObject.put("officeId", 0); jsonObject.put("doctorId", 0); - jsonObject.put("syUserId", user.getData().getKlabUserAccount()); + jsonObject.put("syUserId", user.getData().getCasUserId()); jsonObject.put("batchCode", mapTaskPreset); jsonObject.put("taskType", 1); jsonObject.put("originImages", mapTaskPreset.getReceiptFileId()); diff --git a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/PushBlacklistController.java b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/PushBlacklistController.java index 73a7381a..79bacf48 100644 --- a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/PushBlacklistController.java +++ b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/PushBlacklistController.java @@ -13,7 +13,6 @@ import com.cloud.kicc.commonbiz.api.entity.PushConcernFanType; import com.cloud.kicc.commonbiz.service.IPushBlacklistService; import com.cloud.kicc.commonbiz.service.IPushConcernFanService; import com.cloud.kicc.commonbiz.service.IPushConcernFanTypeService; -import com.cloud.kicc.system.api.entity.User; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.RequiredArgsConstructor; @@ -43,9 +42,9 @@ public class PushBlacklistController { @ApiOperation("分页查询") @GetMapping("/list") - public R list(Page page, User user) { - user.setCreateById(SecurityUtils.getCasUser().getId()); - IPage> iPage = iPushBlacklistService.selectPushBlacklist(page, user); + public R list(Page page, @RequestParam Map map) { + map.put("createById", SecurityUtils.getCasUser().getId()); + IPage> iPage = iPushBlacklistService.selectPushBlacklist(page, map); return R.ok(iPage.getRecords(), iPage.getTotal()); } diff --git a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/mapper/PushBlacklistMapper.java b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/mapper/PushBlacklistMapper.java index a7a7899e..5114960f 100644 --- a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/mapper/PushBlacklistMapper.java +++ b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/mapper/PushBlacklistMapper.java @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage; import com.cloud.kicc.commonbiz.api.entity.PushBlacklist; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.cloud.kicc.system.api.entity.User; +import com.cloud.kicc.system.api.vo.UserVo; import org.apache.ibatis.annotations.MapKey; import org.apache.ibatis.annotations.Param; @@ -19,7 +20,7 @@ import java.util.Map; */ public interface PushBlacklistMapper extends BaseMapper { - IPage> selectPushBlacklist(@Param("page") IPage> page, @Param("user") User user); + IPage> selectPushBlacklist(@Param("page") IPage> page, @Param("map") Map map); Map getByPushBlacklistId(PushBlacklist pushBlacklist); diff --git a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/IPushBlacklistService.java b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/IPushBlacklistService.java index 74bda138..f0dd91d6 100644 --- a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/IPushBlacklistService.java +++ b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/IPushBlacklistService.java @@ -3,7 +3,6 @@ package com.cloud.kicc.commonbiz.service; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.service.IService; import com.cloud.kicc.commonbiz.api.entity.PushBlacklist; -import com.cloud.kicc.system.api.entity.User; import java.util.Map; @@ -22,7 +21,7 @@ public interface IPushBlacklistService extends IService { * @param * @return */ - IPage> selectPushBlacklist(IPage> page, User user); + IPage> selectPushBlacklist(IPage> page, Map map); /** * 根据推送黑名单ID查询 diff --git a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/MapLogisticServiceImpl.java b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/MapLogisticServiceImpl.java index b212765e..bd79d939 100644 --- a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/MapLogisticServiceImpl.java +++ b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/MapLogisticServiceImpl.java @@ -4,21 +4,19 @@ import cn.hutool.core.collection.ListUtil; import cn.hutool.core.date.LocalDateTimeUtil; import cn.hutool.core.lang.UUID; import cn.hutool.core.thread.ThreadUtil; -import cn.hutool.core.util.BooleanUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.cloud.kicc.common.core.api.R; -import com.cloud.kicc.common.core.constant.SecurityConstants; import com.cloud.kicc.common.security.util.SecurityUtils; import com.cloud.kicc.commonbiz.api.entity.*; import com.cloud.kicc.commonbiz.mapper.MapLogisticMapper; import com.cloud.kicc.commonbiz.service.*; import com.cloud.kicc.commonbiz.util.PushClientUtil; -import com.cloud.kicc.system.api.entity.User; import com.cloud.kicc.system.api.feign.RemoteUserService; +import com.cloud.kicc.system.api.vo.UserVo; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import okhttp3.*; @@ -117,7 +115,7 @@ public class MapLogisticServiceImpl extends ServiceImpl { if (mapTask.getEnabledCreateReport()) { JSONObject jsonObject = new JSONObject(); - R user = remoteUserService.selectByUserId(mapTask.getCourierUserId()); + R user = remoteUserService.selectByUserId(mapTask.getCourierUserId()); Hospital hospital = hospitalService.getById(mapTask.getHospitalId()); jsonObject.put("hospitalId", hospital.getKlabHospitalAccount()); if (StrUtil.isNotBlank(mapTask.getOrgId())) { @@ -130,7 +128,7 @@ public class MapLogisticServiceImpl extends ServiceImpl { JSONObject jsonObject = new JSONObject(); if (mapTaskPreset.getEnabledCreateReport()) { - R taskPresetUser = remoteUserService.selectByUserId(mapTaskPreset.getCourierUserId()); + R taskPresetUser = remoteUserService.selectByUserId(mapTaskPreset.getCourierUserId()); if (StrUtil.isNotBlank(mapTaskPreset.getOrginPresetId())) { Hospital hospital = hospitalService.getById(mapTaskPreset.getOrginPresetId()); jsonObject.put("hospitalId", hospital.getKlabHospitalAccount()); @@ -156,7 +154,7 @@ public class MapLogisticServiceImpl extends ServiceImpl implements IPushBlacklistService { @Override - public IPage> selectPushBlacklist(IPage> page, User user) { - return baseMapper.selectPushBlacklist(page, user); + public IPage> selectPushBlacklist(IPage> page, Map map) { + return baseMapper.selectPushBlacklist(page, map); } @Override diff --git a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/resources/mapper/PushBlacklistMapper.xml b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/resources/mapper/PushBlacklistMapper.xml index 6a82564c..391d81e2 100644 --- a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/resources/mapper/PushBlacklistMapper.xml +++ b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/resources/mapper/PushBlacklistMapper.xml @@ -3,74 +3,74 @@ + select + u.id, + csu.id cas_user_id, + csu.user_name, + csu.nick_name, + csu.password, + csu.email, + csu.phone, + csu.sex, + csu.avatar, + csu.login_ip, + csu.login_time, + u.user_type, + u.dept_id, + u.dept_name, + u.status, + u.map_orientation, + u.map_center, + u.create_by_id, + u.create_by_name, + u.create_time, + u.update_by_id, + u.update_by_name, + u.update_time, + csu.remarks, + csu.tenant_id, + u.del_flag + from + sys_user u + inner join + remote_cas_sso_user csu + on u.cas_user_id = csu.id + where + (select count(1) from common_map_logistic m where m.courier_user_id = csu.id) = 0 + and u.del_flag = 0 + and u.user_type = '3' + + + - + select + u.id, + csu.id cas_user_id, + csu.user_name, + csu.nick_name, + csu.password, + csu.email, + csu.phone, + csu.sex, + csu.avatar, + csu.login_ip, + csu.login_time, + u.user_type, + u.dept_id, + u.dept_name, + u.status, + u.map_orientation, + u.map_center, + u.create_by_id, + u.create_by_name, + u.create_time, + u.update_by_id, + u.update_by_name, + u.update_time, + csu.remarks, + csu.tenant_id, + u.del_flag + from + sys_user u + inner join + remote_cas_sso_user csu + on u.cas_user_id = csu.id - a.del_flag = 0 AND status = 0 - - AND rd1.dept_name = #{deptName} + u.del_flag = 0 + + and csu.user_name = #{userName} + + + and csu.nick_name = #{nickName} + + + and u.dept_id = #{deptId} + + + and u.id = #{id} - - AND rd1.dept_type = #{deptType} + + and csu.id = #{casUserId} + + + and u.user_type = #{userType} - limit 1 - + select + u.id, + csu.id cas_user_id, + csu.user_name, + csu.nick_name, + csu.password, + csu.email, + csu.phone, + csu.sex, + csu.avatar, + csu.login_ip, + csu.login_time, + u.user_type, + u.dept_id, + u.dept_name, + u.status, + u.map_orientation, + u.map_center, + u.create_by_id, + u.create_by_name, + u.create_time, + u.update_by_id, + u.update_by_name, + u.update_time, + csu.remarks, + csu.tenant_id, + u.del_flag + from + sys_user u + inner join + remote_cas_sso_user csu + on u.cas_user_id = csu.id + + u.del_flag = 0 + + and csu.phone = #{phone} + + + order by u.create_time asc +