/* * Copyright [2020-2030] [https://www.stylefeng.cn] * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * * Guns采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点： * * 1.请不要删除和修改根目录下的LICENSE文件。 * 2.请不要删除和修改Guns源码头部的版权声明。 * 3.请保留源码和相关描述文件的项目出处，作者声明等。 * 4.分发源码时候，请注明软件出处 https://gitee.com/stylefeng/guns * 5.在修改包名，模块名称，项目代码等时，请注明软件出处 https://gitee.com/stylefeng/guns * 6.若您的项目无法满足以上几点，可申请商业授权 */ package cn.stylefeng.roses.kernel.system.modular.user.service.impl; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.util.ObjectUtil; import cn.stylefeng.roses.kernel.cache.api.CacheOperatorApi; import cn.stylefeng.roses.kernel.system.api.exception.SystemModularException; import cn.stylefeng.roses.kernel.system.api.exception.enums.user.SysUserOrgExceptionEnum; import cn.stylefeng.roses.kernel.system.api.pojo.user.SysUserOrgDTO; import cn.stylefeng.roses.kernel.system.api.pojo.user.request.UserOrgRequest; import cn.stylefeng.roses.kernel.system.modular.user.entity.SysUserOrg; import cn.stylefeng.roses.kernel.system.modular.user.mapper.SysUserOrgMapper; import cn.stylefeng.roses.kernel.system.modular.user.service.SysUserOrgService; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.List; import java.util.Set; import java.util.stream.Collectors; /** * 用户组织机构关联信息 * * @author fengshuonan * @date 2020/12/19 22:17 */ @Service public class SysUserOrgServiceServiceImpl extends ServiceImpl implements SysUserOrgService { @Resource(name = "userOrgCacheApi") private CacheOperatorApi userOrgCacheApi; @Override public SysUserOrgDTO getUserOrgByUserId(Long userId) { // 从缓存获取数据 String key = String.valueOf(userId); SysUserOrgDTO sysUserDTOCache = userOrgCacheApi.get(key); if (sysUserDTOCache != null) { return sysUserDTOCache; } UserOrgRequest userOrgRequest = new UserOrgRequest(); userOrgRequest.setUserId(userId); SysUserOrg sysUserOrg = this.detail(userOrgRequest); if (ObjectUtil.isEmpty(sysUserOrg)) { throw new SystemModularException(SysUserOrgExceptionEnum.EMPLOYEE_MANY_MAIN_NOT_FOUND); } SysUserOrgDTO sysUserOrgDTO = new SysUserOrgDTO(); BeanUtil.copyProperties(sysUserOrg, sysUserOrgDTO); // 加入缓存 userOrgCacheApi.put(key, sysUserOrgDTO); return sysUserOrgDTO; } @Override public Set getUserIdsByOrgIds(Set organizationIds) { List userOrgs = this.lambdaQuery().in(SysUserOrg::getOrgId, organizationIds).list(); return userOrgs.stream().map(SysUserOrg::getUserId).collect(Collectors.toSet()); } @Override public void add(UserOrgRequest userOrgResponse) { SysUserOrg sysUserOrg = new SysUserOrg(); BeanUtil.copyProperties(userOrgResponse, sysUserOrg); this.save(sysUserOrg); } @Override public void add(Long userId, Long orgId) { SysUserOrg sysUserOrg = new SysUserOrg(); sysUserOrg.setUserId(userId); sysUserOrg.setOrgId(orgId); this.save(sysUserOrg); } @Override public void add(Long userId, Long orgId, Long positionId) { SysUserOrg sysUserOrg = new SysUserOrg(); sysUserOrg.setUserId(userId); sysUserOrg.setOrgId(orgId); sysUserOrg.setPositionId(positionId); this.save(sysUserOrg); } @Override public void del(UserOrgRequest userOrgResponse) { SysUserOrg sysUserOrg = this.querySysUserOrgById(userOrgResponse); this.removeById(sysUserOrg.getUserOrgId()); // 清除缓存 userOrgCacheApi.remove(String.valueOf(sysUserOrg.getUserId())); } @Override public void delByUserId(Long userId) { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(SysUserOrg::getUserId, userId); this.remove(queryWrapper); // 清除缓存 userOrgCacheApi.remove(String.valueOf(userId)); } @Override public void edit(UserOrgRequest userOrgResponse) { SysUserOrg sysUserOrg = this.querySysUserOrgById(userOrgResponse); BeanUtil.copyProperties(userOrgResponse, sysUserOrg); this.updateById(sysUserOrg); // 清除缓存 userOrgCacheApi.remove(String.valueOf(sysUserOrg.getUserId())); } @Override @Transactional(rollbackFor = Exception.class) public void edit(Long userId, Long orgId) { // 删除已有绑定的组织机构 this.delByUserId(userId); // 新增组织机构绑定 this.add(userId, orgId); // 清除缓存 userOrgCacheApi.remove(String.valueOf(userId)); } @Override @Transactional(rollbackFor = Exception.class) public void edit(Long userId, Long orgId, Long positionId) { // 删除已有绑定的组织机构 this.delByUserId(userId); // 新增组织机构绑定 this.add(userId, orgId, positionId); // 清除缓存 userOrgCacheApi.remove(String.valueOf(userId)); } @Override public SysUserOrg detail(UserOrgRequest userOrgResponse) { return this.getOne(this.createWrapper(userOrgResponse), false); } @Override public List findList(UserOrgRequest userOrgResponse) { LambdaQueryWrapper queryWrapper = this.createWrapper(userOrgResponse); return this.list(queryWrapper); } @Override public Boolean getUserOrgFlag(Long orgId, Long positionId) { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(ObjectUtil.isNotNull(orgId), SysUserOrg::getOrgId, orgId); queryWrapper.eq(ObjectUtil.isNotNull(positionId), SysUserOrg::getPositionId, positionId); return this.list(queryWrapper).size() > 0; } /** * 根据主键id获取对象 * * @author chenjinlong * @date 2021/1/26 13:28 */ private SysUserOrg querySysUserOrgById(UserOrgRequest userOrgResponse) { SysUserOrg sysUserOrg = this.getById(userOrgResponse.getUserOrgId()); if (ObjectUtil.isEmpty(sysUserOrg)) { throw new SystemModularException(SysUserOrgExceptionEnum.USER_ORG_NOT_EXIST, sysUserOrg.getOrgId()); } return sysUserOrg; } /** * 实体构建queryWrapper * * @author fengshuonan * @date 2021/1/24 22:03 */ private LambdaQueryWrapper createWrapper(UserOrgRequest userOrgResponse) { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(ObjectUtil.isNotEmpty(userOrgResponse.getUserOrgId()), SysUserOrg::getUserOrgId, userOrgResponse.getUserOrgId()); queryWrapper.eq(ObjectUtil.isNotEmpty(userOrgResponse.getUserId()), SysUserOrg::getUserId, userOrgResponse.getUserId()); queryWrapper.eq(ObjectUtil.isNotEmpty(userOrgResponse.getOrgId()), SysUserOrg::getOrgId, userOrgResponse.getOrgId()); queryWrapper.eq(ObjectUtil.isNotEmpty(userOrgResponse.getPositionId()), SysUserOrg::getPositionId, userOrgResponse.getPositionId()); return queryWrapper; } }