前后端分离之goldri

package club.goldri.web.system.service.impl; import club.goldri.core.constant.Constant; import club.goldri.core.util.BeanUtil; import club.goldri.web.system.domain.*; import club.goldri.web.system.mapper.*; import com.github.pagehelper.PageHelper; import club.goldri.core.common.service.AbstractService; import club.goldri.core.util.SystemCacheUtil; import club.goldri.web.system.domain.*; import club.goldri.web.system.mapper.*; import club.goldri.web.system.service.UserService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cache.annotation.CacheEvict; import org.springframework.cache.annotation.CachePut; import org.springframework.cache.annotation.Cacheable; import org.springframework.cache.annotation.Caching; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import tk.mybatis.mapper.entity.Example; import java.util.*; @Service public class UserServiceImpl extends AbstractService<SysUser> implements UserService{ @Autowired private SysUserMapper sysUserMapper; @Autowired private SysUserRoleMapper sysUserRoleMapper; @Autowired private SysUserOrgMapper sysUserOrgMapper; @Autowired private SysRoleMapper sysRoleMapper; @Autowired private SysOrgMapper sysOrgMapper; /** * 查询方法，支持模糊查询 * @param sysUser * @return */ @Override public List<SysUser> listAll(SysUser sysUser){ if (sysUser.getPage() != null && sysUser.getRows() != null) { PageHelper.startPage(sysUser.getPage(), sysUser.getRows()); } Example example = new Example(SysUser.class); Example.Criteria criteria = example.createCriteria(); //search condition //用户名 if(sysUser != null && sysUser.getUsername() != null && !"".equals(sysUser.getUsername())){ criteria.andLike("username","%" + sysUser.getUsername() + "%"); } //姓名 if(sysUser != null && sysUser.getName() != null && !"".equals(sysUser.getName())){ criteria.andLike("name","%" + sysUser.getName() + "%"); } //职位 if(sysUser != null && sysUser.getPosition() != null && !"".equals(sysUser.getPosition())){ criteria.andLike("position","%" + sysUser.getPosition() + "%"); } //状态 if(sysUser != null && sysUser.getState() != null && !"".equals(sysUser.getState())){ criteria.andEqualTo("state", sysUser.getState()); } if(sysUser != null && sysUser.getId() != null && !"".equals(sysUser.getId())){ criteria.andEqualTo("id", sysUser.getId()); } //获取删除标记为正常的记录 criteria.andEqualTo("delFlag", sysUser.getDelFlag()); return this.sysUserMapper.selectByExample(example); } /** * 将修改和添加封装在一起，便于缓存处理 * 当数据发生变化时更新缓存 * 注意事项：username一定要传 * @param sysUser * @return */ @Caching(put = { @CachePut(value=SystemCacheUtil.CACHE_USER , key="T(club.goldri.core.util.SystemCacheUtil).SYS_USER_USERNAME + #sysUser.username", condition = "#sysUser.username != null"), @CachePut(value=SystemCacheUtil.CACHE_USER , key="T(club.goldri.core.util.SystemCacheUtil).SYS_USER_ID + #sysUser.id", condition = "#sysUser.id != null"), @CachePut(value=SystemCacheUtil.CACHE_USER , key="T(club.goldri.core.util.SystemCacheUtil).SYS_USER_USERNAME + T(club.goldri.core.util.SystemCacheUtil).getUserById(#sysUser.id)?.getUsername()" , condition = "#sysUser.id != null and #sysUser.username == null"), @CachePut(value=SystemCacheUtil.CACHE_USER , key="T(club.goldri.core.util.SystemCacheUtil).SYS_USER_ID + T(club.goldri.core.util.SystemCacheUtil).getUserByUsername(#sysUser.username)?.getId()" , condition = "#sysUser.username != null and #sysUser.id == null") }) @Transactional @Override public SysUser commonSave(SysUser currentUser, SysUser sysUser){ if(sysUser.getId() == null){ super.save(sysUser); } else { this.updateNotNull(sysUser); } //判断用户的组织是否为空，不为空时需要对部门处理 if(sysUser != null && sysUser.getOrgList() != null && sysUser.getOrgList().size() > 0 ){ List<SysOrg> orgList = sysUser.getOrgList(); Set<String> orgIdList = new HashSet<String>(); //获取前台传过来的orgid for(SysOrg sysOrg : orgList){ orgIdList.add(sysOrg.getId()); } //获取当前用户所属部门 Example example = new Example(SysUserOrg.class); Example.Criteria criteria = example.createCriteria(); //获取删除标记为正常的记录 criteria.andEqualTo("userId", sysUser.getId()); criteria.andEqualTo("delFlag", Constant.DEL_FLAG_NORMAL); //用户的当前组织列表 List<SysUserOrg> currUserOrgList = this.sysUserOrgMapper.selectByExample(example); Set<String> currUserOrgIdList = new HashSet<String>(); if(currUserOrgList != null && currUserOrgList.size()> 0){ for(SysUserOrg sysUserOrg : currUserOrgList){ currUserOrgIdList.add(sysUserOrg.getOrgId()); } } //比对用户的部门变化（新增、删除） Map<String,Set<String>> map = BeanUtil.diffList(orgIdList, currUserOrgIdList); Set<String> addUserOrgIdList = map.get(BeanUtil.ADD); Set<String> removeSysUserOrgList = map.get(BeanUtil.REMOVE); //删除数据 if(removeSysUserOrgList != null && removeSysUserOrgList.size() > 0){ for(String removeOrgId : removeSysUserOrgList){ SysUserOrg sysUserOrg = new SysUserOrg(); BeanUtil.setUpdateUser(currentUser, sysUserOrg); sysUserOrg.setDelFlag(Constant.DEL_FLAG_DELETE); Example remExample = new Example(SysUserOrg.class); Example.Criteria remCriteria = remExample.createCriteria(); //获取删除标记为正常的记录 remCriteria.andEqualTo("userId", sysUser.getId()); remCriteria.andEqualTo("orgId", removeOrgId); remCriteria.andNotEqualTo("delFlag", Constant.DEL_FLAG_DELETE); this.sysUserOrgMapper.updateByExampleSelective(sysUserOrg, remExample); } } //添加数据 if(addUserOrgIdList != null && addUserOrgIdList.size() > 0){ for(String orgId : addUserOrgIdList){ SysUserOrg sysUserOrg = new SysUserOrg(); sysUserOrg.setUserId(sysUser.getId()); sysUserOrg.setOrgId(orgId); BeanUtil.setCreateUser(currentUser, sysUserOrg); BeanUtil.setUpdateUser(currentUser, sysUserOrg); this.sysUserOrgMapper.insert(sysUserOrg); } } } //处理用户角色 if(sysUser != null && sysUser.getRoleList() != null && sysUser.getRoleList().size() > 0 ){ List<SysRole> roleList = sysUser.getRoleList(); Set<String> roleIdList = new HashSet<String>(); //获取前台传过来的roleId for(SysRole sysRole : roleList){ roleIdList.add(sysRole.getId()); } //获取当前用户所有角色