jnpf-java-boot-v6x/jnpf-oauth/jnpf-oauth-biz/target/classes/jnpf/service/impl/LoginServiceImpl.java

package jnpf.service.impl;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.net.url.UrlBuilder;
import cn.hutool.core.util.BooleanUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.http.useragent.UserAgent;
import cn.hutool.http.useragent.UserAgentUtil;
import jnpf.base.KeyNameModel;
import jnpf.base.UserInfo;
import jnpf.base.UserOrgPosModel;
import jnpf.base.entity.SuperBaseEntity;
import jnpf.base.entity.SystemEntity;
import jnpf.base.model.base.SystemBaeModel;
import jnpf.base.model.button.ButtonModel;
import jnpf.base.model.column.ColumnModel;
import jnpf.base.model.form.ModuleFormModel;
import jnpf.base.model.module.ModuleModel;
import jnpf.base.model.resource.ResourceModel;
import jnpf.base.service.ModuleService;
import jnpf.base.service.SignService;
import jnpf.base.service.SysconfigService;
import jnpf.base.service.SystemService;
import jnpf.config.ConfigValueUtil;
import jnpf.constant.EventConst;
import jnpf.constant.JnpfConst;
import jnpf.constant.MsgCode;
import jnpf.constant.PermissionConst;
import jnpf.database.util.TenantDataSourceUtil;
import jnpf.exception.LoginException;
import jnpf.exception.NoPermiLoginException;
import jnpf.exception.TenantDatabaseException;
import jnpf.granter.UserDetailsServiceBuilder;
import jnpf.message.entity.MessageTemplateConfigEntity;
import jnpf.message.service.MessageService;
import jnpf.message.service.MessageTemplateConfigService;
import jnpf.model.BaseSystemInfo;
import jnpf.model.BuildUserCommonInfoModel;
import jnpf.model.login.*;
import jnpf.model.tenant.TenantVO;
import jnpf.module.ProjectEventBuilder;
import jnpf.permission.entity.*;
import jnpf.permission.model.authorize.AuthorizeVO;
import jnpf.permission.model.authorize.OtherModel;
import jnpf.permission.service.*;
import jnpf.portal.service.PortalDataService;
import jnpf.properties.SecurityProperties;
import jnpf.service.LoginService;
import jnpf.util.*;
import jnpf.util.context.RequestContext;
import jnpf.util.treeutil.SumTree;
import jnpf.util.treeutil.newtreeutil.TreeDotUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.*;
import java.util.stream.Collectors;

import static jnpf.util.Constants.ADMIN_KEY;

/**
 * @author JNPF开发平台组
 * @version V3.1.0
 * @copyright 引迈信息技术有限公司（<a href="https://www.jnpfsoft.com">...</a>）
 * @date 2021/3/16
 */
@Slf4j
@Service
public class LoginServiceImpl implements LoginService {
    @Autowired
    private ConfigValueUtil configValueUtil;
    @Autowired
    private SecurityProperties securityProperties;
    @Autowired
    private UserService userApi;
    @Autowired
    private UserRelationService userRelationApi;
    @Autowired
    private RoleRelationService roleRelationApi;
    @Autowired
    private OrganizeService organizeApi;
    @Autowired
    private PositionService positionApi;
    @Autowired
    private RoleService roleApi;
    @Autowired
    private GroupService groupApi;
    @Autowired
    private AuthorizeService authorizeApi;
    @Autowired
    private SysconfigService sysconfigApi;
    @Autowired
    private PortalDataService portalDataService;
    @Autowired
    private RedisUtil redisUtil;
    @Autowired
    private CacheKeyUtil cacheKeyUtil;
    @Autowired
    private SystemService systemApi;
    @Autowired
    private UserDetailsServiceBuilder userDetailsServiceBuilder;
    @Autowired
    private SignService signService;
    @Autowired
    private MessageTemplateConfigService messageTemplateApi;
    @Autowired
    private MessageService sentMessageApi;
    @Autowired
    private ModuleService moduleApi;
    @Autowired
    private RoleRelationService roleRelationService;

    @Autowired
    private UserExtraService userExtraService;


    @Override
    public UserInfo getTenantAccount(UserInfo userInfo) throws LoginException {
        String tenantId = null;
        if (configValueUtil.isMultiTenancy()) {
            String[] tenantAccount = userInfo.getUserAccount().split("\\@");
            if (tenantAccount.length == 1) {
                //只输入账号, 1:配置的二级域名下只输入账号, 2:主域名下输入了租户号
                String referer = ServletUtil.getHeader("Referer");
                if (StringUtil.isNotEmpty(referer)) {
                    String remoteHost = UrlBuilder.of(referer).getHost();
                    String apiHost = UrlBuilder.of(RequestContext.isOrignPc() ? configValueUtil.getFrontDomain() : configValueUtil.getAppDomain()).getHost();
                    if (!ObjectUtil.equals(remoteHost, apiHost)
                            && remoteHost.endsWith(apiHost)) {
                        //二级域名访问, 输入的是账号
                        tenantId = remoteHost.split("\\.")[0];
                        userInfo.setUserAccount(tenantAccount[0]);
                    }
                }
                if (tenantId == null) {
                    //主域名访问, 输入的是租户号
                    tenantId = tenantAccount[0];
                    userInfo.setUserAccount(ADMIN_KEY);
                }
            } else {
                //租户号@账号
                tenantId = tenantAccount[0];
                userInfo.setUserAccount(tenantAccount[1]);
            }
            if (StringUtil.isEmpty(tenantId) || tenantAccount.length > 2 || StringUtil.isEmpty(userInfo.getUserAccount())) {
                throw new LoginException(MsgCode.LOG102.get());
            }
            TenantVO tenantVO = TenantDataSourceUtil.getRemoteTenantInfo(tenantId);
            TenantDataSourceUtil.switchTenant(tenantId, tenantVO);
            //切换成租户库
            userInfo.setTenantId(tenantId);
            userInfo.setTenantDbConnectionString(tenantVO.getDbName());
            userInfo.setTenantDbType(tenantVO.getType());
            //查库测试
            BaseSystemInfo baseSystemInfo = null;
            try {
                baseSystemInfo = getBaseSystemConfig(userInfo.getTenantId());
            } catch (Exception e) {
                log.error("登录获取系统配置失败: {}", e.getMessage());
            }
            if (baseSystemInfo == null || baseSystemInfo.getSingleLogin() == null) {
                throw new TenantDatabaseException();
            }
        }
        return userInfo;
    }

    @Override
    public UserInfo userInfo(UserInfo userInfo, BaseSystemInfo sysConfigInfo) throws LoginException {
        //获取账号信息
        UserEntity userEntity = LoginHolder.getUserEntity();
        if (userEntity == null) {
            userEntity = userDetailsServiceBuilder.getUserDetailService(userInfo.getUserDetailKey()).loadUserEntity(userInfo);
            LoginHolder.setUserEntity(userEntity);
        }

        checkUser(userEntity, userInfo, sysConfigInfo);

        userInfo.setUserId(userEntity.getId());
        userInfo.setUserAccount(userEntity.getAccount());
        userInfo.setUserName(userEntity.getRealName());
        userInfo.setUserIcon(userEntity.getHeadIcon());
        userInfo.setTheme(userEntity.getTheme());
        userInfo.setOrganizeId(userEntity.getOrganizeId());
        userInfo.setPortalId(userEntity.getPortalId());
        userInfo.setIsAdministrator(BooleanUtil.toBoolean(String.valueOf((userEntity.getIsAdministrator()))));
        if (!ADMIN_KEY.equals(userInfo.getUserAccount())) {
            if (ObjectUtil.isNotEmpty(userEntity.getStanding())) {
                userInfo.setIsAdministrator(Objects.equals(userEntity.getStanding(), 1));
            }
        }
        // 添加过期时间
        String time = sysConfigInfo.getTokenTimeout();
        if (StringUtil.isNotEmpty(time)) {
            Integer minu = Integer.valueOf(time);
            userInfo.setOverdueTime(DateUtil.dateAddMinutes(null, minu));
            userInfo.setTokenTimeout(minu);
        }

        String ipAddr = IpUtil.getIpAddr();
        userInfo.setLoginIpAddress(ipAddr);
        userInfo.setLoginIpAddressName(IpUtil.getIpCity(ipAddr));
        userInfo.setLoginTime(DateUtil.getmmNow());
        UserAgent userAgent = UserAgentUtil.parse(ServletUtil.getUserAgent());
        if (userAgent != null) {
            userInfo.setLoginPlatForm(userAgent.getPlatform().getName() + " " + userAgent.getOsVersion());
            userInfo.setBrowser(userAgent.getBrowser().getName() + " " + userAgent.getVersion());
        }
        userInfo.setPrevLoginTime(userEntity.getPrevLogTime());
        userInfo.setPrevLoginIpAddress(userEntity.getPrevLogIp());
        userInfo.setPrevLoginIpAddressName(IpUtil.getIpCity(userEntity.getPrevLogIp()));
        // 生成id
        String token = RandomUtil.uuId();
        userInfo.setId(cacheKeyUtil.getLoginToken(userInfo.getTenantId()) + token);

        createUserOnline(userInfo);
        return userInfo;
    }

    @Override
    public void updatePasswordMessage() {
        UserInfo userInfo = UserProvider.getUser();
        UserEntity userEntity = userApi.getInfo(userInfo.getUserId());
        BaseSystemInfo baseSystemInfo = sysconfigApi.getSysInfo();
        if (baseSystemInfo.getPasswordIsUpdatedRegularly() == 1) {
            Date changePasswordDate = userEntity.getCreatorTime();
            if (userEntity.getChangePasswordDate() != null) {
                changePasswordDate = userEntity.getChangePasswordDate();
            }
            //当前时间
            Date nowDate = DateUtil.getNowDate();
            //更新周期
            Integer updateCycle = baseSystemInfo.getUpdateCycle();
            //提前N天提醒
            Integer updateInAdvance = baseSystemInfo.getUpdateInAdvance();
            Integer day = DateUtil.getDiffDays(changePasswordDate, nowDate);
            if (day >= (updateCycle - updateInAdvance)) {
                MessageTemplateConfigEntity entity = messageTemplateApi.getInfoByEnCode("XTXXTX001", "1");
                if (entity != null) {
                    List<String> toUserIds = new ArrayList<>();
                    toUserIds.add(userInfo.getUserId());
                    sentMessageApi.sentMessage(toUserIds, entity.getTitle(), entity.getContent(), userInfo, Integer.parseInt(entity.getMessageSource()), Integer.parseInt(entity.getMessageType()));
                }
            }
        }
    }

    /**
     * 创建用户在线信息
     *
     * @param userInfo
     */
    private void createUserOnline(UserInfo userInfo) {
        String userId = userInfo.getUserId();
//        long time= DateUtil.getTime(userInfo.getOverdueTime()) - DateUtil.getTime(new Date());

        String authorize = String.valueOf(redisUtil.getString(cacheKeyUtil.getUserAuthorize() + userId));
//        String loginOnlineKey=cacheKeyUtil.getLoginOnline() + userId;
        redisUtil.remove(authorize);
        //记录Token
//        redisUtil.insert(userInfo.getId(), userInfo,time);
        //记录在线
        if (ServletUtil.getIsMobileDevice()) {
//            redisUtil.insert(cacheKeyUtil.getMobileLoginOnline() + userId, userInfo.getId(), time);
            //记录移动设备CID,用于消息推送
            if (ServletUtil.getHeader("clientId") != null) {
                String clientId = ServletUtil.getHeader("clientId");
                Map<String, String> map = new HashMap<>(16);
                map.put(userInfo.getUserId(), clientId);
                redisUtil.insert(cacheKeyUtil.getMobileDeviceList(), map);
            }
        } else {
//            redisUtil.insert(loginOnlineKey, userInfo.getId(), time);
        }
    }

    private UserCommonInfoVO data(BuildUserCommonInfoModel buildUserCommonInfoModel) {
        UserInfo userInfo = buildUserCommonInfoModel.getUserInfo();
        UserEntity userEntity = buildUserCommonInfoModel.getUserEntity();
        UserExtraEntity userExtraByUserId = userExtraService.getUserExtraByUserId(userInfo.getUserId());
        //userInfo 填充信息
        UserOrgPosModel uopm = this.userInfo(userInfo, userEntity);
        //返回前端vo
        BaseSystemInfo baseSystemInfo = buildUserCommonInfoModel.getBaseSystemInfo();
        UserCommonInfoVO infoVO = JsonUtil.getJsonToBean(userInfo, UserCommonInfoVO.class);
        infoVO.setPrevLogin(baseSystemInfo.getLastLoginTimeSwitch() == 1 ? 1 : 0);
        if (BeanUtil.isNotEmpty(userExtraByUserId)) {
            infoVO.setPreferenceJson(userExtraByUserId.getPreferenceJson());
        }
        //最后一次修改密码时间
        infoVO.setChangePasswordDate(userEntity.getChangePasswordDate());
        // 姓名
        infoVO.setUserName(userEntity.getRealName());
        // 组织名称
        KeyNameModel defaultOrg = uopm.getOrganizeList().stream().filter(t -> t.getId().equals(userInfo.getOrganizeId())).findFirst().orElse(new KeyNameModel());
        infoVO.setOrganizeName(defaultOrg.getFullName());
        // 岗位名称
        KeyNameModel defaultPos = uopm.getPositionList().stream().filter(t -> t.getId().equals(userInfo.getPositionId())).findFirst().orElse(new KeyNameModel());
        infoVO.setPositionName(defaultPos.getFullName());
        //是否超级管理员
        infoVO.setIsAdministrator(BooleanUtil.toBoolean(String.valueOf(userEntity.getIsAdministrator())));
        if (!ADMIN_KEY.equals(userEntity.getAccount())) {
            if (ObjectUtil.isNotEmpty(userEntity.getStanding())) {
                userInfo.setIsAdministrator(Objects.equals(userEntity.getStanding(), 1));
                infoVO.setIsAdministrator(Objects.equals(userEntity.getStanding(), 1));
            }
        }
        infoVO.setSecurityKey(userInfo.getSecurityKey());
        return infoVO;
    }

    public UserEntity checkUser(UserEntity userEntity, UserInfo userInfo, BaseSystemInfo sysConfigInfo) throws LoginException {
        if (userEntity == null) {
            throw new LoginException(MsgCode.LOG101.get());
        }
        //判断是否组织、岗位、角色、部门主管是否为空，为空则抛出异常
        //判断是否为管理员，是否为Admin(Admin为最高账号，不受限制)
        if (!ADMIN_KEY.equals(userEntity.getAccount()) || userEntity.getIsAdministrator() != 1) {
            List<String> posAndRole = new ArrayList<>();
            //没岗位，且没用户角色时直接提示没权限
            List<UserRelationEntity> userPos = userRelationApi.getListByUserIdAndObjType(userEntity.getId(), PermissionConst.POSITION);
            List<String> userPosIds = userPos.stream().map(t -> t.getObjectId()).collect(Collectors.toList());
            userPosIds.add(userEntity.getId());
            List<RoleRelationEntity> userRole = roleRelationApi.getListByObjectId(userPosIds, null);
            posAndRole.addAll(userPosIds);
            posAndRole.addAll(userRole.stream().map(t -> t.getRoleId()).collect(Collectors.toList()));
            //有岗位角色但是没有权限
            if (CollectionUtil.isEmpty(posAndRole) || CollectionUtil.isEmpty(authorizeApi.getListByObjectId(posAndRole))) {
                throw new LoginException(MsgCode.LOG004.get());
            }

        }
        if (userEntity.getIsAdministrator() == 0) {
            if (userEntity.getEnabledMark() == null) {
                throw new LoginException(MsgCode.LOG005.get());
            }
            if (userEntity.getEnabledMark() == 0) {
                throw new LoginException(MsgCode.LOG006.get());
            }
        }
        if (userEntity.getDeleteMark() != null && userEntity.getDeleteMark() == 1) {
            throw new LoginException(MsgCode.LOG007.get());
        }
        //安全验证
        String ipAddr = IpUtil.getIpAddr();
        userInfo.setLoginIpAddress(IpUtil.getIpAddr());
        // 判断白名单
        if (!ADMIN_KEY.equals(userEntity.getAccount()) && "1".equals(sysConfigInfo.getWhitelistSwitch())) {
            List<String> ipList = Arrays.asList(sysConfigInfo.getWhitelistIp().split(","));
            if (!ipList.contains(ipAddr)) {
                throw new LoginException(MsgCode.LOG010.get());
            }
        }
        // 判断当前账号是否被锁定
        Integer lockMark = userEntity.getEnabledMark();
        if (Objects.nonNull(lockMark) && lockMark == 2) {
            // 获取解锁时间
            Date unlockTime = userEntity.getUnlockTime();
            // 账号锁定
            if (sysConfigInfo.getLockType() == 1 || Objects.isNull(unlockTime)) {
                throw new LoginException(MsgCode.LOG012.get());
            }
            // 延迟登陆锁定
            long millis = System.currentTimeMillis();
            // 系统设置的错误次数
            int passwordErrorsNumber = sysConfigInfo.getPasswordErrorsNumber() != null ? sysConfigInfo.getPasswordErrorsNumber() : 0;
            // 用户登录错误次数
            int logErrorCount = userEntity.getLogErrorCount() != null ? userEntity.getLogErrorCount() : 0;
            if (unlockTime.getTime() > millis) {
                // 转成分钟
                int time = (int) ((unlockTime.getTime() - millis) / (1000 * 60));
                throw new LoginException(MsgCode.LOG108.get(time + 1));
            } else if (unlockTime.getTime() < millis && logErrorCount >= passwordErrorsNumber) {
                // 已经接触错误时间锁定的话就重置错误次数
                userEntity.setLogErrorCount(0);
                userEntity.setEnabledMark(1);
                userApi.updateById(userEntity);
            }
        }
        return userEntity;
    }

    /**
     * 获取用户登陆信息
     *
     * @return
     */
    @Override
    public PcUserVO getCurrentUser(String type, String systemCode, Integer isBackend) {
        UserInfo userInfo = UserProvider.getUser();
        UserEntity userEntity = userApi.getInfo(userInfo.getUserId());
        if (userEntity == null) {
            return null;
        }
        userInfo.setIsBackend(isBackend);
        BaseSystemInfo baseSystemInfo = sysconfigApi.getSysInfo();
        BuildUserCommonInfoModel buildUserCommonInfoModel = new BuildUserCommonInfoModel(userInfo, userEntity, baseSystemInfo, type);
        //添加userInfo信息
        UserCommonInfoVO infoVO = this.data(buildUserCommonInfoModel);
        //获取权限
        if (StringUtil.isEmpty(systemCode) && JnpfConst.WEB.equals(type)) {
            systemCode = JnpfConst.MAIN_SYSTEM_CODE;
        } else if (StringUtil.isEmpty(systemCode) && JnpfConst.APP.equals(type)) {
            SystemEntity sysInfo = systemApi.getInfo(userEntity.getAppSystemId());
            systemCode = sysInfo != null ? sysInfo.getEnCode() : null;
        }
        AuthorizeVO authorizeModel = authorizeApi.getAuthorize(false, systemCode, isBackend);

        OtherModel otherModel = authorizeModel.getOtherModel();
        userInfo.setIsManageRole(otherModel.getIsManageRole());
        userInfo.setIsDevRole(otherModel.getIsDevRole());
        userInfo.setIsUserRole(otherModel.getIsUserRole());
        userInfo.setIsOtherRole(otherModel.getIsOtherRole());
        userInfo.setWorkflowEnabled(otherModel.getWorkflowEnabled());
        infoVO.setIsManageRole(userInfo.getIsManageRole());
        infoVO.setIsDevRole(userInfo.getIsDevRole());
        infoVO.setIsUserRole(userInfo.getIsUserRole());
        infoVO.setIsOtherRole(userInfo.getIsOtherRole());
        infoVO.setWorkflowEnabled(userInfo.getWorkflowEnabled());
        //当前系统信息
        SystemEntity currentSystem = authorizeModel.getCurrentSystem();
        if (currentSystem != null) {
            userInfo.setAppSystemId(currentSystem.getId());
            infoVO.setSystemId(currentSystem.getId());
            infoVO.setSystemName(currentSystem.getFullName());
            infoVO.setSystemCode(currentSystem.getEnCode());
            infoVO.setSystemIcon(currentSystem.getIcon());
            infoVO.setSystemColor(currentSystem.getBackgroundColor());
        }


        //身份
        infoVO.setStandingList(authorizeModel.getStandingList());
        List<SystemBaeModel> systemList = authorizeModel.getSystemList();

        // 获取菜单权限
        List<ModuleModel> moduleList = authorizeModel.getModuleList();
        //当前pc或app权限过滤
        List<ModuleModel> moduleListRes = moduleList.stream().filter(t -> type.equals(t.getCategory())).sorted(Comparator.comparing(ModuleModel::getSortCode)).collect(Collectors.toList());
        List<PermissionModel> models = new ArrayList<>();
        for (ModuleModel moduleModel : moduleListRes) {
            PermissionModel model = new PermissionModel();
            model.setModelId(moduleModel.getId());
            model.setModuleName(moduleModel.getFullName());
            List<ButtonModel> buttonModels = authorizeModel.getButtonList().stream().filter(t -> moduleModel.getId().equals(t.getModuleId())).collect(Collectors.toList());
            List<ColumnModel> columnModels = authorizeModel.getColumnList().stream().filter(t -> moduleModel.getId().equals(t.getModuleId())).collect(Collectors.toList());
            List<ResourceModel> resourceModels = authorizeModel.getResourceList().stream().filter(t -> moduleModel.getId().equals(t.getModuleId())).collect(Collectors.toList());
            List<ModuleFormModel> moduleFormModels = authorizeModel.getFormsList().stream().filter(t -> moduleModel.getId().equals(t.getModuleId())).collect(Collectors.toList());
            model.setButton(JsonUtil.getJsonToList(buttonModels, PermissionVO.class));
            model.setColumn(JsonUtil.getJsonToList(columnModels, PermissionVO.class));
            model.setResource(JsonUtil.getJsonToList(resourceModels, PermissionVO.class));
            model.setForm(JsonUtil.getJsonToList(moduleFormModels, PermissionVO.class));
            if (moduleModel.getType() != 1) {
                models.add(model);
            }
        }

        // 获取签名信息
        SignEntity signEntity = signService.getDefaultByUserId(userEntity.getId());
        infoVO.setSignImg(signEntity != null ? signEntity.getSignImg() : "");
        infoVO.setSignId(signEntity != null ? signEntity.getId() : "");

        List<ModuleModel> collect = moduleListRes.stream().sorted(Comparator.comparing(ModuleModel::getSystemId).thenComparing(ModuleModel::getSortCode)).collect(Collectors.toList());
        List<AllUserMenuModel> needList = JsonUtil.getJsonToList(collect, AllUserMenuModel.class);
        List<SumTree<AllUserMenuModel>> needTree = TreeDotUtils.convertListToTreeDotFilter(needList);
        List<AllMenuSelectVO> menuvo = JsonUtil.getJsonToList(needTree, AllMenuSelectVO.class);

        SystemInfo jsonToBean = JsonUtil.getJsonToBean(baseSystemInfo, SystemInfo.class);
        jsonToBean.setJnpfDomain(configValueUtil.getApiDomain());
        PcUserVO userVO = new PcUserVO(menuvo, models, infoVO, jsonToBean);
        userVO.setCurrentSystemId(currentSystem != null ? currentSystem.getId() : null);
        userVO.getUserInfo().setHeadIcon(UploaderUtil.uploaderImg(userInfo.getUserIcon()));
        // 更新userInfo对象
        if (StringUtil.isNotEmpty(userInfo.getId())) {
            UserProvider.setLoginUser(userInfo);
            UserProvider.setLocalLoginUser(userInfo);
        }

        if (JnpfConst.WEB.equals(type)) {
            if (!JnpfConst.MAIN_SYSTEM_CODE.equals(systemCode)) {
                if (CollectionUtil.isEmpty(systemList)) {
                    throw new NoPermiLoginException(MsgCode.PS032.get());
                }
            }
        } else {
            if (CollectionUtil.isEmpty(systemList) || !systemList.stream().anyMatch(t -> !Objects.equals(t.getIsMain(), 1))) {
//                throw new NoPermiLoginException(MsgCode.LOG004.get());
                userVO.setCurrentSystemId(null); //如果需要自动切不提示替换成这段代码
            }
        }

        //判断开发者-有无后台
        List<String> sysIdList = systemApi.getAuthListByUser(userInfo.getUserId(), true).stream().map(SystemEntity::getId).collect(Collectors.toList());
        if (currentSystem != null && sysIdList.contains(currentSystem.getId())) {
            infoVO.setHasBackend(true);
        }
        //无后台权限
        if (Objects.equals(isBackend, 1) && !userInfo.getIsAdministrator() && !sysIdList.contains(currentSystem.getId())) {
            throw new LoginException(MsgCode.PS039.get());
        }

        //获取默认门户
        if (currentSystem != null && !JnpfConst.MAIN_SYSTEM_CODE.equals(currentSystem.getEnCode())) {
            List<String> webPortalIds = authorizeModel.getModuleList().stream().filter(t -> Objects.equals(t.getType(), 8)
                            && t.getCategory().equals(JnpfConst.WEB))
                    .map(ModuleModel::getId).collect(Collectors.toList());
            List<String> appPortalIds = authorizeModel.getModuleList().stream().filter(t -> Objects.equals(t.getType(), 8)
                            && t.getCategory().equals(JnpfConst.APP))
                    .map(ModuleModel::getId).collect(Collectors.toList());
            // 门户Web
            infoVO.setPortalId(portalDataService.getCurrentDefault(webPortalIds, currentSystem.getId(), userEntity.getId(), JnpfConst.WEB));
            // 门户App
            infoVO.setAppPortalId(portalDataService.getCurrentDefault(appPortalIds, currentSystem.getId(), userEntity.getId(), JnpfConst.APP));
        }

        //初始化接口权限
        if (securityProperties.isEnablePreAuth()) {
            // 如需使用远程事件, 改用publish
            PublishEventUtil.publishLocalEvent(new ProjectEventBuilder(EventConst.EVENT_INIT_LOGIN_PERMISSION, authorizeModel).setAsync(false));
        }
        return userVO;
    }

    @Override
    public BaseSystemInfo getBaseSystemConfig(String tenantId) {
        if (tenantId != null) {
            TenantDataSourceUtil.switchTenant(tenantId);
        }
        return sysconfigApi.getSysInfo();
    }

    private List<AllMenuSelectVO> buildModule(List<SystemBaeModel> systemList, List<ModuleModel> moduleList, String type, UserEntity entity, UserCommonInfoVO infoVO, String systemCode, BaseSystemInfo baseSystemInfo) {
        List<String> moduleCode = new ArrayList<>(JnpfConst.MODULE_CODE);
        if (!Objects.equals(baseSystemInfo.getFlowSign(), 1)) {
            moduleCode.remove(JnpfConst.WORK_FLOWSIGN);
        }
        if (!Objects.equals(baseSystemInfo.getFlowTodo(), 1)) {
            moduleCode.remove(JnpfConst.WORK_FLOWTODO);
        }
        moduleList = moduleList.stream().filter(t -> type.equals(t.getCategory())).sorted(Comparator.comparing(ModuleModel::getSortCode)).collect(Collectors.toList());
        List<AllUserMenuModel> list = JsonUtil.getJsonToList(moduleList, AllUserMenuModel.class);
        list.forEach(t -> {
            if ("-1".equals(t.getParentId())) {
                t.setParentId(t.getSystemId());
            }
        });
        List<AllUserMenuModel> jsonToList = JsonUtil.getJsonToList(systemList, AllUserMenuModel.class);
        jsonToList.forEach(t -> {
            t.setType(0);
            t.setParentId("-1");
        });
        list.addAll(jsonToList);
        List<SumTree<AllUserMenuModel>> menuList = TreeDotUtils.convertListToTreeDotFilter(list);
        List<AllMenuSelectVO> menuvo = JsonUtil.getJsonToList(menuList, AllMenuSelectVO.class);
        return menuvo;
    }

    /**
     * userInfo添加组织、岗位、分组、角色的关系
     * 默认组织和默认岗位
     *
     * @param userInfo
     * @param userEntity
     */
    private UserOrgPosModel userInfo(UserInfo userInfo, UserEntity userEntity) {
        UserOrgPosModel uopm= new UserOrgPosModel();
        // 得到用户和组织、岗位、分组、角色的关系
        List<UserRelationEntity> data = userRelationApi.getListByUserId(userInfo.getUserId());
        List<String> positionIds = data.stream().filter(t -> PermissionConst.POSITION.equalsIgnoreCase(t.getObjectType())).map(UserRelationEntity::getObjectId).collect(Collectors.toList());
        List<String> groupIds = data.stream().filter(t -> PermissionConst.GROUP.equalsIgnoreCase(t.getObjectType())).map(UserRelationEntity::getObjectId).collect(Collectors.toList());

        List<PositionEntity> positionList = positionApi.getListByIds(positionIds);
        List<String> orgIds = new ArrayList<>(positionList.stream().map(PositionEntity::getOrganizeId).collect(Collectors.toSet()));
        List<OrganizeEntity> organizeList = organizeApi.getListByIds(orgIds);
        List<GroupEntity> groupList = groupApi.getListByIds(groupIds);

        List<String> allIds = new ArrayList<>();
        allIds.addAll(orgIds);
        allIds.addAll(positionIds);
        allIds.add(userEntity.getId());
        List<RoleRelationEntity> roleRelationList = roleRelationService.getListByObjectId(allIds, null);
        List<String> roleIds = roleRelationList.stream().map(RoleRelationEntity::getRoleId).collect(Collectors.toList());
        List<RoleEntity> roleList = roleApi.getListByIds(roleIds);

        userInfo.setOrganizeIds(orgIds);
        userInfo.setPositionIds(positionIds);
        userInfo.setGroupIds(groupIds);
        userInfo.setRoleIds(roleIds);

        //组织全名，岗位全名
        List<KeyNameModel> organizeListRes = organizeList.stream().map(t -> {
            KeyNameModel jsonb = JsonUtil.getJsonToBean(t, KeyNameModel.class);
            jsonb.setTreeName(t.getOrgNameTree());
            jsonb.setTreeId(t.getOrganizeIdTree());
            return jsonb;
        }).collect(Collectors.toList());
        List<KeyNameModel> positionListRes = positionList.stream().map(t -> {
            KeyNameModel jsonb = JsonUtil.getJsonToBean(t, KeyNameModel.class);
            OrganizeEntity organizeEntity = organizeList.stream().filter(m -> m.getId().equals(t.getOrganizeId())).findFirst().orElse(new OrganizeEntity());
            jsonb.setTreeName(organizeEntity.getOrgNameTree() + "/" + t.getFullName());
            jsonb.setTreeId(t.getPositionIdTree());
            return jsonb;
        }).collect(Collectors.toList());
        uopm.setOrganizeList(organizeListRes);
        uopm.setPositionList(positionListRes);
        uopm.setGroupList(JsonUtil.getJsonToList(groupList, KeyNameModel.class));
        uopm.setRoleList(JsonUtil.getJsonToList(roleList, KeyNameModel.class));
        userInfo.setIsManageRole(false);
        userInfo.setIsDevRole(false);
        userInfo.setIsUserRole(false);
        userInfo.setIsOtherRole(false);
        for (RoleEntity roleEntity : roleList) {
            if (PermissionConst.MANAGER_CODE.equals(roleEntity.getEnCode())) {
                userInfo.setIsManageRole(true);
            } else if (PermissionConst.DEVELOPER_CODE.equals(roleEntity.getEnCode())) {
                userInfo.setIsDevRole(true);
            } else if (PermissionConst.USER_CODE.equals(roleEntity.getEnCode())) {
                userInfo.setIsUserRole(true);
            } else {
                userInfo.setIsOtherRole(true);
            }
        }

        //默认组织和默认岗位
        String organizeId = userEntity.getOrganizeId();
        String positionId = userEntity.getPositionId();
        if (CollectionUtil.isNotEmpty(orgIds)) {
            if (!orgIds.contains(userEntity.getOrganizeId())) {
                organizeId = orgIds.get(0);
            }
        }
        if (CollectionUtil.isNotEmpty(positionIds)) {
            if (!positionIds.contains(userEntity.getPositionId())) {
                positionId = positionIds.get(0);
            }
        }
        userInfo.setOrganizeId(organizeId);
        userInfo.setPositionId(positionId);

        // 修改用户信息
        userEntity.setOrganizeId(organizeId);
        userEntity.setPositionId(positionId);
        userApi.updateById(userEntity);

        //todo 我的下属。重写
        userInfo.setManagerId(userEntity.getManagerId());
        //获取岗位
        List<UserRelationEntity> listByObjectType = userRelationApi.getListByObjectType(userInfo.getUserId(), PermissionConst.POSITION);
        if (CollectionUtil.isNotEmpty(listByObjectType)) {
            List<String> collect = listByObjectType.stream()
                    .map(UserRelationEntity::getObjectId)
                    .collect(Collectors.toList());
            //获取子岗位
            List<String> sonPositionIdList = positionApi.getListByParentIds(collect).stream()
                    .map(SuperBaseEntity.SuperIBaseEntity::getId)
                    .collect(Collectors.toList());
            if (CollectionUtil.isNotEmpty(sonPositionIdList)) {
                List<String> userIds = userRelationApi.getListByObjectIdAll(sonPositionIdList).stream()
                        .map(UserRelationEntity::getUserId)
                        .collect(Collectors.toList());
                userIds.add(userInfo.getUserId());
                userInfo.setSubordinateIds(userIds);

            }

        }
        userInfo.setLoginTime(DateUtil.getmmNow());
        return uopm;
    }

}