package com.shlanbao.tzsc.pms.sys.role.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import com.shlanbao.tzsc.utils.tools.*;
|
import net.sf.json.JSONArray;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.shlanbao.tzsc.base.dao.SysResourceDaoI;
|
import com.shlanbao.tzsc.base.dao.SysRoleDaoI;
|
import com.shlanbao.tzsc.base.dao.SysRoleResourceDaoI;
|
import com.shlanbao.tzsc.base.dao.SysUserDaoI;
|
import com.shlanbao.tzsc.base.dao.SysUserRoleDaoI;
|
import com.shlanbao.tzsc.base.mapping.MdFixCode;
|
import com.shlanbao.tzsc.base.mapping.SysResource;
|
import com.shlanbao.tzsc.base.mapping.SysRole;
|
import com.shlanbao.tzsc.base.mapping.SysRoleResource;
|
import com.shlanbao.tzsc.base.mapping.SysUser;
|
import com.shlanbao.tzsc.base.mapping.SysUserRole;
|
import com.shlanbao.tzsc.base.service.BaseService;
|
import com.shlanbao.tzsc.init.BaseParams;
|
import com.shlanbao.tzsc.pms.md.fixCode.beans.FixCodeBean;
|
import com.shlanbao.tzsc.pms.md.fixCode.service.FixCodeServiceI;
|
import com.shlanbao.tzsc.pms.sys.resource.beans.ResourceBean;
|
import com.shlanbao.tzsc.pms.sys.role.beans.RoleBean;
|
import com.shlanbao.tzsc.pms.sys.role.service.RoleServiceI;
|
import com.shlanbao.tzsc.pms.sys.user.beans.UserBean;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
/**
|
* 角色业务实现类
|
* @author Leejean
|
* @create 2014年9月16日上午10:28:46
|
*/
|
@Service
|
public class RoleServiceImp extends BaseService implements RoleServiceI{
|
@Autowired
|
private SysRoleDaoI sysRoleDao;
|
@Autowired
|
private SysResourceDaoI sysResourceDao;
|
@Autowired
|
private SysRoleResourceDaoI sysRoleResourceDao;
|
@Autowired
|
private SysUserDaoI sysUserDao;
|
@Autowired
|
private SysUserRoleDaoI sysUserRoleDao;
|
@Autowired
|
private FixCodeServiceI fixCodeService;
|
@Autowired
|
private HttpServletRequest request;
|
@Override
|
public List<RoleBean> getAllRoles(RoleBean roleBean) throws Exception {
|
List<RoleBean> roleBeans = new ArrayList<RoleBean>();
|
String name="";
|
if(StringUtil.notNull(roleBean.getName())){
|
name = roleBean.getName();
|
}
|
List<SysRole> roles=sysRoleDao.query("from SysRole o where o.del=0 and o.name like '%"+name+"%' order by o.seq asc");
|
for (SysRole role : roles) {
|
RoleBean bean=BeanConvertor.copyProperties(role, RoleBean.class);
|
FillUserInfoUtil.fillCreateAndUpdateUserInfo(role,bean);
|
roleBeans.add(bean);
|
}
|
return roleBeans;
|
}
|
|
@LogAnno(operateType = "新增角色")
|
@Override
|
public void addRole(RoleBean roleBean) throws Exception {
|
|
//添加角色基础信息
|
SysRole role=BeanConvertor.copyProperties(roleBean, SysRole.class);
|
FillUserInfoUtil.fillCreateUserInfo(role,request);
|
SysRole roler=sysRoleDao.saveAndReturn(role);
|
roleBean.setId(roler.getId());
|
savemdFixCodeInfo(roleBean);
|
|
}
|
//维护综合基础数据
|
private void savemdFixCodeInfo(RoleBean roleBean){
|
//轮保角色
|
String lbTypeName=roleBean.getLbTypeName();
|
//点检角色
|
String djTypeName=roleBean.getDjTypeName();
|
String rolerId=roleBean.getId();
|
//判断是否需要刷新缓存
|
if(StringUtil.notEmpty(lbTypeName)){
|
MdFixCode lbBean=new MdFixCode();
|
lbBean.setName(lbTypeName);
|
lbBean.setCode(rolerId);
|
lbBean.setUpcode("LBTYPE001");
|
lbBean.setDel("0");
|
lbBean.setDes("轮保类型项目");
|
FixCodeBean params = new FixCodeBean();
|
params.setUpcode(lbBean.getUpcode());
|
params.setCode(lbBean.getCode());
|
fixCodeService.saveFixCode(lbBean,params);
|
}
|
if(StringUtil.notEmpty(djTypeName)){
|
MdFixCode djbean=new MdFixCode();
|
djbean.setName(djTypeName);
|
djbean.setCode(rolerId);
|
djbean.setUpcode("DJTYPE001");
|
djbean.setDel("0");
|
djbean.setDes("点检类型项目");
|
FixCodeBean params = new FixCodeBean();
|
params.setUpcode(djbean.getUpcode());
|
params.setCode(djbean.getCode());
|
fixCodeService.saveFixCode(djbean,params);
|
}
|
}
|
|
@LogAnno(operateType = "编辑角色")
|
@Override
|
public void editRole(RoleBean roleBean) throws Exception {
|
SysRole sysRole=sysRoleDao.findById(SysRole.class, roleBean.getId());
|
BeanConvertor.copyProperties(roleBean, sysRole);
|
FillUserInfoUtil.fillUpdateUserInfo(sysRole,request);
|
roleBean.setId(sysRole.getId());
|
savemdFixCodeInfo(roleBean);
|
}
|
|
@LogAnno(operateType = "删除角色")
|
@Override
|
public void deleteRole(String id) throws Exception {
|
sysRoleDao.findById(SysRole.class, id).setDel(1L);
|
}
|
|
@LogAnno(operateType = "批量删除角色")
|
@Override
|
public void batchDeleteRoles(String ids) throws Exception {
|
for(String id: StringUtil.splitToStringList(ids, ",")){
|
this.deleteRole(id);
|
}
|
}
|
|
@LogAnno(operateType = "给角色分配权限")
|
@Override
|
public void assignResourceToRole(String id, String resids) throws Exception {
|
//清除用户所有角色
|
//批量添加
|
sysRoleResourceDao.deleteByParams("delete from SysRoleResource o where o.sysRole.id = ?",id);
|
for (String resid : StringUtil.splitToStringList(resids, ",")) {
|
SysRoleResource o = new SysRoleResource(new SysRole(id), new SysResource(resid));
|
try{
|
FillUserInfoUtil.fillCreateUserInfo(o,request);
|
}catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
|
|
sysRoleResourceDao.save(o);
|
}
|
}
|
@Override
|
public void batchAssignResourceToRoles(String rids, String resids)
|
throws Exception {
|
//清除用户所有角色
|
//批量添加
|
for (String rid : StringUtil.splitToStringList(rids, ",")) {
|
sysRoleResourceDao.deleteByParams("delete from SysRoleResource o where o.sysRole.id = ?",rid);
|
for (String resid : StringUtil.splitToStringList(resids, ",")) {
|
sysRoleResourceDao.save(new SysRoleResource(new SysRole(rid), new SysResource(resid)));
|
}
|
}
|
|
}
|
@Override
|
public RoleBean getSysRoleById(String id) throws Exception {
|
RoleBean bean= BeanConvertor.copyProperties(sysRoleDao.findById(SysRole.class, id),RoleBean.class);
|
//查询该角色在综合基础数据中维护的保养类型
|
//刷新md_fix_code 数据
|
//BaseParams.setListMdFixCode(fixCodeService.queryFixCode(null));
|
RedisUtil.addMap("baseParams","FIXCODES", JSONArray.fromObject(fixCodeService.queryFixCode(null)).toString());
|
List<FixCodeBean> list=BaseParams.getListMdFixCode();
|
//查询点检权限
|
for (FixCodeBean fixCodeBean : list) {
|
//点检
|
if("DJTYPE001".equals(fixCodeBean.getUpcode()) && id.equals(fixCodeBean.getCode())){
|
bean.setDjTypeName(fixCodeBean.getName());
|
}
|
//轮保护
|
if("LBTYPE001".equals(fixCodeBean.getUpcode()) && id.equals(fixCodeBean.getCode())){
|
bean.setLbTypeName(fixCodeBean.getName());
|
}
|
}
|
return bean;
|
}
|
@Override
|
public List<ResourceBean> getResourcesByRole(String id) throws Exception {
|
//查询所有目录资源
|
List<SysResource> menuResources=sysResourceDao.query("from SysResource o where o.del=0 and o.enable=1 and o.typ=1 order by o.seq asc");
|
//查询所有功能资源
|
List<SysResource> funcResources=sysResourceDao.query("from SysResource o where o.del=0 and o.enable=1 and o.typ=2 order by o.seq asc");
|
|
//查询当前角色拥有目录资源
|
List<SysResource> roleOwnMenuResources = sysResourceDao.query(
|
"select o.sysResource from SysRoleResource o where o.sysResource.typ=1 and o.sysRole.id = ?",id);
|
//查询当前角色拥有目录资源
|
List<SysResource> roleOwnFuncResources = sysResourceDao.query(
|
"select o.sysResource from SysRoleResource o where o.sysResource.typ=2 and o.sysRole.id = ?",id);
|
|
List<ResourceBean> resourceBeans = new ArrayList<ResourceBean>();
|
|
for (SysResource sysResource : menuResources) {
|
|
ResourceBean resourceBean = BeanConvertor.copyProperties(sysResource, ResourceBean.class);
|
|
if(sysResource.getSysResource()!=null){
|
resourceBean.setPid(sysResource.getSysResource().getId());
|
resourceBean.setPname(sysResource.getSysResource().getText());
|
}
|
//判断当前角色是否拥有这个目录权限,如果有checked=true
|
resourceBean.setChecked(isAssignedResource(roleOwnMenuResources,sysResource.getId()));
|
//设置该目录下面的功能，并判断是否拥有该权限
|
resourceBean.setFunctions(fmtFuncsToMenus(sysResource.getId(),funcResources,roleOwnFuncResources));
|
|
resourceBeans.add(resourceBean);
|
}
|
//
|
return resourceBeans;
|
}
|
|
private List<ResourceBean> fmtFuncsToMenus(String menuId,List<SysResource> funcResources,List<SysResource> roleOwnFuncResources) throws Exception{
|
if(funcResources==null){
|
return null;
|
}
|
List<ResourceBean> functions =new ArrayList<ResourceBean>();
|
for(SysResource func:funcResources){
|
try {
|
if(func.getSysResource().getId().equals(menuId)){//该功能属于这个模块
|
ResourceBean funcBean = BeanConvertor.copyProperties(func, ResourceBean.class);
|
//判断当前角色是否拥有这个功能权限
|
funcBean.setChecked(isOwnFunc(roleOwnFuncResources,func.getId()));
|
functions.add(funcBean);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
}
|
|
return functions;
|
}
|
/**
|
* 判断角色是否拥有该功能权限
|
* @author Leejean
|
* @create 2014年8月26日上午9:44:25
|
* @param roleOwnFuncResources 用户拥有的功能列表
|
* @param id 功能id
|
* @return
|
*/
|
private boolean isOwnFunc(List<SysResource> roleOwnFuncResources, String id) {
|
for (SysResource sysResource : roleOwnFuncResources) {
|
if(sysResource.getId().equals(id)){
|
return true;
|
}
|
}
|
return false;
|
}
|
/**
|
* 判断角色是否拥有此目录权限
|
* @author Leejean
|
* @create 2014年8月26日上午9:40:16
|
* @param roleOwnMenuResources 目录s
|
* @param id
|
* @return
|
*/
|
private boolean isAssignedResource(List<SysResource> roleOwnMenuResources, String id) {
|
for (SysResource sysResource : roleOwnMenuResources) {
|
if(sysResource.getId().equals(id)){
|
return true;
|
}
|
}
|
return false;
|
}
|
@LogAnno(operateType = "给角色分配用户")
|
@Override
|
public void assignUsersToRole(String id, String ids) throws Exception {
|
//清除
|
sysUserRoleDao.deleteByParams("delete from SysUserRole o where o.sysRole.id = ?",id);
|
for (String uid : StringUtil.splitToStringList(ids, ",")) {
|
SysUserRole o = new SysUserRole(new SysRole(id), new SysUser(uid));
|
FillUserInfoUtil.fillCreateUserInfo(o,request);
|
sysUserRoleDao.save(o);
|
}
|
}
|
@Override
|
public List<UserBean> getRoleUnAssignedUsers(String oid, String name)
|
throws Exception {
|
if(name==null)name="";
|
|
String hql= "from SysUser o where o.del=0 and o.enable=1 and (o.name like '%"+name+"%' or o.loginName like '%"+name+"%' or o.eno like '%"+name+"%' ) and o.id not in (select oo.sysUser.id from SysUserRole oo where oo.sysRole.id=?)";
|
//获得所有用户
|
List<SysUser> rows = sysUserDao.query(hql,oid);
|
|
return BeanConvertor.copyList(rows,UserBean.class);
|
}
|
@Override
|
public List<UserBean> getRoleAssignedUsers(String oid) throws Exception {
|
String hql= "from SysUserRole o where o.sysRole.id=?";
|
//获得所有用户
|
List<SysUser> rows = sysUserDao.query("select o.sysUser ".concat(hql), oid);
|
|
return BeanConvertor.copyList(rows,UserBean.class);
|
}
|
@Override
|
public List<RoleBean> getRolesByUser(String id) throws Exception {
|
//查询所有角色
|
List<SysRole> sysRoles=sysRoleDao.query("from SysRole o where o.del=0 and o.enable=1");
|
//查询当前用户拥有的角色
|
List<SysRole> sysUserRoles = sysRoleDao.query(
|
"select o.sysRole from SysUserRole o where o.sysUser.id = ?",id);
|
List<RoleBean> roleBeans = new ArrayList<RoleBean>();
|
for (SysRole sysRole : sysRoles) {
|
RoleBean roleBean = BeanConvertor.copyProperties(sysRole, RoleBean.class);
|
roleBean.setChecked(isAssignedRole(sysUserRoles,sysRole.getId()));
|
roleBeans.add(roleBean);
|
}
|
return roleBeans;
|
}
|
/**
|
* 是否拥有此角色
|
* @author Leejean
|
* @create 2014-8-19下午06:36:21
|
* @param sysRoles
|
* @param id
|
* @return
|
*/
|
private boolean isAssignedRole(List<SysRole> sysRoles, String id) {
|
for (SysRole sysRole : sysRoles) {
|
if(sysRole.getId().equals(id)){
|
return true;
|
}
|
}
|
return false;
|
}
|
@LogAnno(operateType = "给用户分配角色")
|
@Override
|
public void assignRole(String id, String ids) throws Exception {
|
//清除用户所有角色
|
sysUserRoleDao.deleteByParams("delete from SysUserRole o where o.sysUser.id = ?",id);
|
//批量添加
|
for (String rid : StringUtil.splitToStringList(ids, ",")) {
|
SysUserRole o = new SysUserRole(new SysRole(rid), new SysUser(id));
|
FillUserInfoUtil.fillCreateUserInfo(o,request);
|
sysUserRoleDao.save(o);
|
}
|
}
|
|
@LogAnno(operateType = "用户角色批量分配")
|
@Override
|
public void batchAssignRole(String uids, String rids) throws Exception {
|
//清除用户所有角色
|
//批量添加
|
for (String uid : StringUtil.splitToStringList(uids, ",")) {
|
sysUserRoleDao.deleteByParams("delete from SysUserRole o where o.sysUser.id = ?",uid);
|
for (String rid : StringUtil.splitToStringList(rids, ",")) {
|
SysUserRole o = new SysUserRole(new SysRole(rid), new SysUser(uid));
|
FillUserInfoUtil.fillCreateUserInfo(o,request);
|
sysUserRoleDao.save(o);
|
}
|
}
|
}
|
}
|
