forked from kidgrow-microservices-platform
kidgrow-business/kidgrow-usercenter/kidgrow-usercenter-biz/src/main/java/com/kidgrow/usercenter/service/impl/SysDoctorServiceImpl.java
@@ -1,5 +1,6 @@ package com.kidgrow.usercenter.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.kidgrow.common.constant.CommonConstant; import com.kidgrow.common.constant.SecurityConstants; @@ -8,10 +9,10 @@ import com.kidgrow.common.utils.StringUtils; import com.kidgrow.redis.util.RedisConstant; import com.kidgrow.redis.util.RedisUtils; import com.kidgrow.usercenter.mapper.SysDoctorMapper; import com.kidgrow.usercenter.mapper.SysRoleMapper; import com.kidgrow.usercenter.mapper.SysUserRoleMapper; import com.kidgrow.usercenter.mapper.*; import com.kidgrow.usercenter.model.SysDepartment; import com.kidgrow.usercenter.model.SysDoctor; import com.kidgrow.usercenter.model.SysHospital; import com.kidgrow.usercenter.model.SysRoleUser; import com.kidgrow.usercenter.service.ISysDoctorService; import com.kidgrow.usercenter.service.ISysUserOrgService; @@ -28,6 +29,7 @@ import javax.servlet.http.HttpServletRequest; import java.util.*; import java.util.stream.Collectors; /** * 石家庄喜高科技有限责任公司 版权所有 © Copyright 2020<br> @@ -60,9 +62,15 @@ @Autowired private SysRoleMapper sysRoleMapper; @Autowired private SysHospitalMapper sysHospitalMapper; @Autowired private SysDepartmentMapper sysDepartmentMapper; @Autowired private SysUserRoleMapper sysUserRoleMapper; @Autowired private SysUserServiceImpl sysUserServiceImpl; private final String HOSPITAL_ADMIN="hospital_admin"; // private final String HOSPITAL_ADMIN="hospital_admin"; @Override public PageResult<SysDoctorVo> findList(Map<String, Object> params, SysUser user) { @@ -121,6 +129,22 @@ params.put("userId", userId); return baseMapper.deleteByMap(params); } /** * 统计医生的数量 * @param datatype 业务类型 * 0 自注册医生 * 1 签约医生 * 2 医答医生 * 3 C端医生 * 4 H端医生 * 5 待审核医生 * @return */ @Override public int chartDoctor(int datatype) { return baseMapper.chartDoctor(datatype); } @Override public ResultBody enable(Map<String, Object> params) { Long aLong = MapUtils.getLong(params,"id"); @@ -145,11 +169,52 @@ @Override @Transactional(rollbackFor = Exception.class) public boolean saveOrUpdateSer(SysDoctorDto sysDoctor, HttpServletRequest request,SysUser user) { public ResultBody saveOrUpdateSer(SysDoctorDto sysDoctor, HttpServletRequest request,SysUser user) { String id = request.getHeader(SecurityConstants.USER_ID_HEADER); if(null==sysDoctor){ return false; return ResultBody.failed("请填写信息"); }else { if(sysDoctor.getRoles()==null||sysDoctor.getRoles().size()<=0){ return ResultBody.failed("选择一个角色"); } /** * 限制管理员只有一个 */ Boolean flag=false; if(sysDoctor.getRoles().contains(CommonConstant.HOSPITAL_ADMIN_ID)){ //查询一个部门下的所有医生 QueryWrapper wrapper=new QueryWrapper(); wrapper.eq("is_del",0); wrapper.eq("enabled",1); wrapper.eq("department_id",sysDoctor.getDepartmentId()); List<SysDoctor> doctoerList = this.baseMapper.selectList(wrapper); if(doctoerList.size()>0){ //查询role——user List<Long> collect = doctoerList.stream().map(e -> e.getUserId()).collect(Collectors.toList()); wrapper=new QueryWrapper(); wrapper.in("user_id",collect); List<SysRoleUser> list= this.sysUserRoleMapper.selectList(wrapper); for (SysRoleUser sysRoleUser : list) { if(sysRoleUser.getRoleId()==CommonConstant.HOSPITAL_ADMIN_ID){ flag=true; } } } } if(flag){ return ResultBody.failed("该部门已经有管理员"); } /** * 限制只有创建医生的个数 * */ if(sysUserServiceImpl.departmetAccountsCount(sysDoctor.getDepartmentId())<=0){ return ResultBody.failed("该部门创建人数已经达到上限"); } SysHospital sysHospital= sysHospitalMapper.selectById(sysDoctor.getHospitalId()); SysDepartment sysDepartment= sysDepartmentMapper.selectById(sysDoctor.getDepartmentId()); if (sysDoctor.getId()==null) { //保存 SysUser sysUser=new SysUser(); @@ -158,7 +223,7 @@ sysUser.setNickname(sysDoctor.getHospitalName()); sysUser.setHeadImgUrl(sysDoctor.getDoctorLogo()); sysUser.setMobile(sysDoctor.getDoctorTel()); sysUser.setType(CommonConstant.H_DOCTOR); sysUser.setType(UserType.DOCTOR.name()); sysUser.setTenantId(CommonConstant.H_TENANT); sysUser.setCreateTime(new Date()); SysUser byId = iSysUserService.getById(id); @@ -168,19 +233,19 @@ } iSysUserService.save(sysUser); //保存 角色信息 Map<String,Object> map= new HashMap<>(); map.put("code",HOSPITAL_ADMIN); map.put("enabled",1); map.put("is_del",0); List<SysRole> sysRoles = sysRoleMapper.selectByMap(map); if(sysRoles.size()>0){ // Map<String,Object> map= new HashMap<>(); // map.put("code",HOSPITAL_ADMIN); // map.put("enabled",1); // map.put("is_del",0); // List<SysRole> sysRoles = sysRoleMapper.selectByMap(map); // if(sysRoles.size()>0){ //保存一个角色 SysRole sysRole = sysRoles.get(0); sysDoctor.getRoles().forEach(e->{ SysRoleUser sysRoleUser=new SysRoleUser(); sysRoleUser.setRoleId(sysRole.getId()); sysRoleUser.setRoleId(e); sysRoleUser.setUserId(sysUser.getId()); int insert = sysUserRoleMapper.insert(sysRoleUser); } }); //保存doctor的数据 SysDoctor sysDoc=new SysDoctor(); BeanCopier beanCopier = BeanCopier.create(SysDoctorDto.class, SysDoctor.class, false); @@ -195,12 +260,16 @@ //保存将sys_user_org 保存部门 SysUserOrg sysUserOrg=new SysUserOrg(); sysUserOrg.setUserId(sysUser.getId()); sysUserOrg.setOrgId(sysDoctor.getDepartmentId()); sysUserOrg.setFromId(sysDoctor.getDepartmentId()); sysUserOrg.setFromLevel(CommonConstant.SYSTEM_ORG_DEP_LEVEL); sysUserOrg.setOrgId(sysDepartment.getOrgId()); //保存公司 sysUserOrgService.saveOrUpdate(sysUserOrg); SysUserOrg sysGongsi=new SysUserOrg(); sysGongsi.setUserId(sysUser.getId()); sysGongsi.setOrgId(sysDoctor.getHospitalId()); sysGongsi.setOrgId(sysHospital.getOrgId()); sysGongsi.setFromId(sysDoctor.getHospitalId()); sysGongsi.setFromLevel(CommonConstant.SYSTEM_ORG_DEP_LEVEL); sysUserOrgService.saveOrUpdate(sysGongsi); //保存到Redis boolean hset = redisUtils.hset(RedisConstant.USER_ORGANIZATION, sysUserOrg.getUserId().toString(), sysUserOrg); @@ -214,12 +283,16 @@ SysUserOrg sysUserOrg=new SysUserOrg(); sysUserOrg.setUserId(getOne.getUserId()); sysUserOrg.setEnabled(false); sysUserOrg.setOrgId(sysDoctor.getDepartmentId()); sysUserOrg.setFromId(sysDoctor.getDepartmentId()); sysUserOrg.setFromLevel(CommonConstant.SYSTEM_ORG_DEP_LEVEL); sysUserOrg.setOrgId(sysDepartment.getOrgId()); sysUserOrg.setCreateTime(new Date()); sysUserOrgService.saveOrUpdate(sysUserOrg); SysUserOrg sysGongsi=new SysUserOrg(); sysGongsi.setUserId(getOne.getId()); sysGongsi.setOrgId(sysDoctor.getHospitalId()); sysGongsi.setOrgId(sysHospital.getOrgId()); sysGongsi.setFromId(sysDoctor.getHospitalId()); sysGongsi.setFromLevel(CommonConstant.SYSTEM_ORG_DEP_LEVEL); sysUserOrgService.saveOrUpdate(sysGongsi); baseMapper.updateById(sysDoctor); if(redisUtils.hHasKey(RedisConstant.USER_ORGANIZATION, getOne.getUserId().toString())){ @@ -228,7 +301,7 @@ redisUtils.hset(RedisConstant.USER_ORGANIZATION, getOne.getUserId().toString(), sysUserOrg); } } return true; return ResultBody.ok(); } @Override @@ -254,8 +327,15 @@ //先检查操作用户是否管理员 if(sysDoctor!=null){ if (sysDoctor.getIsAdminUser()) { //现将操作人员设为非管理 // sysDoctor=new SysDoctor(); //将超级管理员的角色设为普通角色 SysRoleUser sysRoleUser=new SysRoleUser(); sysRoleUser.setUserId(adminId); sysRoleUser.setRoleId(CommonConstant.HOSPITAL_DOCTOR_ID); QueryWrapper queryWrapper=new QueryWrapper(); queryWrapper.eq("user_id",adminId); queryWrapper.eq("role_id",CommonConstant.HOSPITAL_ADMIN_ID); int update = sysUserRoleMapper.update(sysRoleUser, queryWrapper); //现将操作人员设为非管理角色 sysDoctor.setIsAdminUser(false); if(baseMapper.updateById(sysDoctor)>0) { @@ -263,7 +343,14 @@ sysDoctor=baseMapper.selectById(id); if (sysDoctor != null) { if (!sysDoctor.getIsAdminUser()) { // sysDoctor=new SysDoctor(); //现将普通人员设为管理角色 sysRoleUser=new SysRoleUser(); sysRoleUser.setUserId(sysDoctor.getUserId()); sysRoleUser.setRoleId(CommonConstant.HOSPITAL_ADMIN_ID); queryWrapper=new QueryWrapper(); queryWrapper.eq("user_id",sysDoctor.getUserId()); queryWrapper.eq("role_id",CommonConstant.HOSPITAL_DOCTOR_ID); sysUserRoleMapper.update(sysRoleUser, queryWrapper); sysDoctor.setIsAdminUser(true); if (baseMapper.updateById(sysDoctor)>0) { return ResultBody.ok().data(true).msg("管理员设置成功！");
