From 4caf9cf7c6bba46bf0f23fdc3fb90f7eba502648 Mon Sep 17 00:00:00 2001 From: zxh <279049017@qq.com> Date: Tue, 25 Aug 2020 15:51:37 +0800 Subject: [PATCH] 获取医院科室下的所有H端有效的医生 进行排序 --- kidgrow-business/kidgrow-usercenter/kidgrow-usercenter-biz/src/main/java/com/kidgrow/usercenter/service/impl/SysUserServiceImpl.java | 258 +++++++++++++++++++++++++-------------------------- 1 files changed, 125 insertions(+), 133 deletions(-) diff --git a/kidgrow-business/kidgrow-usercenter/kidgrow-usercenter-biz/src/main/java/com/kidgrow/usercenter/service/impl/SysUserServiceImpl.java b/kidgrow-business/kidgrow-usercenter/kidgrow-usercenter-biz/src/main/java/com/kidgrow/usercenter/service/impl/SysUserServiceImpl.java index 26f5f57..fe814ac 100644 --- a/kidgrow-business/kidgrow-usercenter/kidgrow-usercenter-biz/src/main/java/com/kidgrow/usercenter/service/impl/SysUserServiceImpl.java +++ b/kidgrow-business/kidgrow-usercenter/kidgrow-usercenter-biz/src/main/java/com/kidgrow/usercenter/service/impl/SysUserServiceImpl.java @@ -4,7 +4,6 @@ import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.kidgrow.common.constant.CommonConstant; import com.kidgrow.common.constant.DictionariesConstants; @@ -19,6 +18,7 @@ import com.kidgrow.common.utils.AesUtils; import com.kidgrow.common.utils.DateUtils; import com.kidgrow.common.utils.Pinyin4jUtil; +import com.kidgrow.oprationcenter.feign.ProductOrderService; import com.kidgrow.redis.util.RedisUtils; import com.kidgrow.sms.feign.SmsChuangLanService; import com.kidgrow.sms.model.ConstantSMS; @@ -90,11 +90,18 @@ private SysUserRoleMapper sysUserRoleMapper; @Autowired private SysOrganizationMapper sysOrganizationMapper; + @Autowired + private ProductOrderService productOrderService; + @Override public LoginAppUser findByUsername(String username) { SysUser sysUser = this.selectByUsername(username); - return getLoginAppUser(sysUser); + if (sysUser == null) { + return null; + } else { + return getLoginAppUser(sysUser); + } } @Override @@ -112,25 +119,22 @@ /** * 获取登录用户的一系列信息 hrj 06-04修改 * - * @param sysUser + * @param sysUserNew * @return */ @Override - public LoginAppUser getLoginAppUser(SysUser sysUser) { + public LoginAppUser getLoginAppUser(SysUser sysUserNew) { LoginAppUser loginAppUser = new LoginAppUser(); - SysUser sysUserNew = this.baseMapper.selectById(sysUser); + SysUser sysUser = this.baseMapper.selectById(sysUserNew); if (sysUser != null) { - //返回的数据为什么要把密码也返回?清空!! - loginAppUser.setPassword(""); - loginAppUser.setNewPassword(""); - loginAppUser.setOldPassword(""); - BeanUtils.copyProperties(sysUser, loginAppUser); //获取用户所属组织机构列表 - loginAppUser.setDefaultAuth(sysUserNew.getDefaultAuth()); + loginAppUser.setDefaultAuth(sysUser.getDefaultAuth()); List<SysOrganization> sysOrganizations = organizationService.findListByUserId(sysUser.getId()); //设置组织机构集合 - loginAppUser.setOrganizations(sysOrganizations); + if (sysOrganizations != null) { + loginAppUser.setOrganizations(sysOrganizations); + } List<SysRole> sysRoles = roleUserService.findRolesByUserId(sysUser.getId()); // 设置角色 loginAppUser.setRoles(sysRoles); @@ -145,15 +149,13 @@ loginAppUser.setPermissions(permissions); } } - //是否医院管理员 - com.kidgrow.usercenter.model.SysDoctor sysDoctor = findDoctorByUserId(sysUser.getId()); - if (sysDoctor.getIsAdminUser() != null) { - loginAppUser.setHAdminUser(sysDoctor.getIsAdminUser()); - } - //医院信息 只有H端要返回的信息 - if (sysUser.getTenantId().toLowerCase().equals(CommonConstant.H_TENANT.toLowerCase())) { - DoctorUserAll doctorUserAllVo = baseMapper.findDoctorUserAllData(sysUser.getId()); + + //医院信息 + DoctorUserAll doctorUserAllVo = baseMapper.findDoctorUserAllData(sysUser.getId()); + if (doctorUserAllVo != null) { loginAppUser.setDoctorUserAllVO(doctorUserAllVo); + //是否医院管理员 + loginAppUser.setHAdminUser(doctorUserAllVo.getIsAdminUser()); } } return loginAppUser; @@ -464,8 +466,8 @@ @Override public ResultBody findCountByMap(Map<String, Object> map) { - map.put("enable",1); - map.put("is_del",0); + map.put("enable", 1); + map.put("isDel", 0); Integer integer = baseMapper.selectCountByMap(map); return ResultBody.ok().data(integer); } @@ -670,6 +672,10 @@ Long createUserId = CommonConstant.CREATE_USER_ID; //创建人名称 String createUserName = CommonConstant.CREATE_USER_NAME; + //销售服务人员 + SysUser sysUserSale = baseMapper.selectById(CommonConstant.SALE_USER_ID); + //运营服务人员 + SysUser sysUserOpration = baseMapper.selectById(CommonConstant.OPRATION_USER_ID); //是否注册用户 Boolean isReg = false; //业务成功 @@ -677,8 +683,8 @@ //业务失败提示信息 String expMsg = ""; //系统内置的注册医院和科室的组织数据 - Long organizationHos = CommonConstant.HOSPITAL_ORG_ID; - Long organizationDep = CommonConstant.DEPARTMENT_ORG_ID; + Long organizationHos = 0L; + Long organizationDep = 0L; //检查判断是注册 还是添加用户,注册用户先走基本数据建设 医院/科室 SysUserOrg sysUserOrgH = new SysUserOrg(); SysUserOrg sysUserOrgD = new SysUserOrg(); @@ -688,50 +694,81 @@ isReg = true; if (CheckVerificationCode(ConstantSMS.REGISTER_SMS, userRegVo.getMobile(), userRegVo.getVerification())) { userRegVo.setDoctorState(true); - //写医院数据 - SysHospital sysHospital = new SysHospital(); - sysHospital.setHospitalName(userRegVo.getHospitalName()); - sysHospital.setOrgId(organizationHos); - //注册的用户所在医院默认是试用状态 - sysHospital.setHospitalState(0); - sysHospital.setCreateUserId(createUserId); - sysHospital.setCreateUserName(createUserName); - - boolean h = hospitalService.save(sysHospital); - if (h) { - userRegVo.setHospitalId(sysHospital.getId()); - //保存科室数据 - SysDepartment sysDepartment = new SysDepartment(); - sysDepartment.setOrgId(organizationDep); - sysDepartment.setDepartmentName(userRegVo.getDepartmentName()); - sysDepartment.setSaleUserId(createUserId); - sysDepartment.setAccountsCount(1); - sysDepartment.setSaleUserName(createUserName); - sysDepartment.setSaleUserTel("0"); - sysDepartment.setServerUserId(createUserId); - sysDepartment.setServerUserTel("0"); - sysDepartment.setServerUserName(createUserName); - boolean d = departmentService.save(sysDepartment); - if (!d) { - isSuccess = false; - expMsg = "科室数据写入失败"; + //写医院组织数据 + SysOrganization sysOrganizationH = new SysOrganization(); + sysOrganizationH.setOrgLevel(1); + sysOrganizationH.setOrgAttr(1); + sysOrganizationH.setOrgParentId(CommonConstant.ORG_PARENT_ID); + sysOrganizationH.setOrgName(userRegVo.getHospitalName()); + sysOrganizationH.setCreateUserId(createUserId); + sysOrganizationH.setCreateUserName(createUserName); + if (organizationService.save(sysOrganizationH)) { + //写科室组织数据 + SysOrganization sysOrganizationD = new SysOrganization(); + sysOrganizationD.setOrgLevel(2); + sysOrganizationD.setOrgAttr(2); + sysOrganizationD.setOrgParentId(sysOrganizationH.getId()); + sysOrganizationD.setOrgName(userRegVo.getDepartmentName()); + sysOrganizationD.setCreateUserId(createUserId); + sysOrganizationD.setCreateUserName(createUserName); + if (organizationService.save(sysOrganizationD)) { + //写医院组织数据 + SysHospital sysHospital = new SysHospital(); + sysHospital.setHospitalName(userRegVo.getHospitalName()); + sysHospital.setOrgId(sysOrganizationH.getId()); + //注册的用户所在医院默认是试用状态 + sysHospital.setHospitalState(0); + sysHospital.setCreateUserId(createUserId); + sysHospital.setCreateUserName(createUserName); + if (hospitalService.save(sysHospital)) { + userRegVo.setHospitalId(sysHospital.getId()); + //保存科室数据 + SysDepartment sysDepartment = new SysDepartment(); + sysDepartment.setOrgId(sysOrganizationD.getId()); + sysDepartment.setDepartmentName(userRegVo.getDepartmentName()); + sysDepartment.setSaleUserId(sysUserSale.getId()); + sysDepartment.setAccountsCount(1); + sysDepartment.setSaleUserName(sysUserSale.getNickname()); + sysDepartment.setSaleUserTel(sysUserSale.getMobile()); + sysDepartment.setServerUserId(sysUserOpration.getId()); + sysDepartment.setServerUserTel(sysUserOpration.getMobile()); + sysDepartment.setServerUserName(sysUserOpration.getNickname()); + sysDepartment.setCreateUserId(createUserId); + sysDepartment.setCreateUserName(createUserName); + if (departmentService.save(sysDepartment)) { + userRegVo.setDepartmentId(sysDepartment.getId()); + //自动充入系统指定的试用套餐 + if (!saveProductDetail(sysHospital.getId(), + sysDepartment.getId(), + sysHospital.getHospitalName(), + sysDepartment.getDepartmentName())) { + isSuccess = false; + expMsg = "试用套餐充值失败"; + } + } else { + isSuccess = false; + expMsg = "科室数据写入失败"; + } + } else { + isSuccess = false; + expMsg = "医院数据写入失败"; + } } else { - userRegVo.setDepartmentId(sysDepartment.getId()); + isSuccess = false; + expMsg = "科室组织数据写入失败"; } } else { isSuccess = false; - expMsg = "医院数据写入失败"; + expMsg = "医院组织数据写入失败"; } } else { return ResultBody.failed("无效的验证码"); } } - //业务执行中途出错 手动撤回数据 + //业务执行中途出错 if (isReg && !isSuccess) { - RollBackData(userRegVo.getHospitalId(), - userRegVo.getDepartmentId(), 0L, 0L, - 0L, 0L, 0L); + //注册过程失败 return ResultBody.failed(expMsg); } if (!isReg && departmetAccountsCount(userRegVo.getDepartmentId()) < 1) { @@ -761,7 +798,7 @@ sysUser.setDefaultAuth(false); sysUser.setOpenId(userRegVo.getOpenId()); sysUser.setDel(false); - sysUser.setTenantId("hospital"); + sysUser.setTenantId(CommonConstant.H_TENANT); boolean u = this.save(sysUser); SysRoleUser sysRoleUser = new SysRoleUser(); if (u) { @@ -782,18 +819,19 @@ if (StringUtils.isNotBlank(userRegVo.getDoctorRank())) { //检查医生职务是否存在 Map<String, Object> selectMap = new HashMap<>(); - selectMap.put("dictionariesName", userRegVo.getDoctorRank()); + selectMap.put("dictionariesNameAll", userRegVo.getDoctorRank().trim()); List<SysDictionaries> dictionariesList = sysDictionariesService.findAll(selectMap); boolean dicBool = false; if (dictionariesList.size() > 0) { for (int i = dictionariesList.size() - 1; i >= 0; i--) { - if (dictionariesList.get(i).getDictionariesName().equals(userRegVo.getDoctorRank())) { + if (dictionariesList.get(i).getDictionariesName().trim().equals(userRegVo.getDoctorRank().trim())) { userRegVo.setDoctorRankId(dictionariesList.get(i).getId()); dicBool = true; break; } } - } else { + } + else { //创建字典数据 sysDictionaries.setDictionariesClassId(DictionariesConstants.DOCTOR_RANK); //将名称汉字转为拼音 @@ -841,10 +879,11 @@ sysDoctor.setDoctorState(!isReg); sysDoctor.setDoctorTel(userRegVo.getMobile()); sysDoctor.setDoctorName(userRegVo.getNickname()); - sysDoctor.setServerUserId(isReg ? createUserId : sysUserd.getId()); - sysDoctor.setServerUserName(isReg ? createUserName : sysUserd.getUsername()); + sysDoctor.setServerUserId(isReg ? sysUserSale.getId() : sysUserd.getId()); + sysDoctor.setServerUserName(isReg ? sysUserSale.getNickname() : sysUserd.getUsername()); sysDoctor.setIsAdminUser(false); - sysDoctor.setEnabled(!isReg); + sysDoctor.setDoctorCcie(userRegVo.getDoctorCcie()); + sysDoctor.setEnabled(true); if (sysDoctorMapper.insert(sysDoctor) == 1) { //非自主注册的 返回信息带密码 if (!isReg) { @@ -883,11 +922,6 @@ } /***返回数据***/ if (!isSuccess) { - //撤回数据 - RollBackData(0L, - 0L, sysUser.getId(), sysUserOrgH.getId(), - sysUserOrgH.getId(), sysDictionaries.getId(), - sysDoctor.getId()); return ResultBody.failed(expMsg); } else { return ResultBody.ok().data(sysUser); @@ -895,41 +929,22 @@ } /** - * 手动撤回数据,需要撤回那个,给那个id传值,不需要的传0 + * feign客户端调用写入试用套餐 * * @param hospitalId * @param departmentId - * @param userId - * @param userOrgIdH - * @param userOrgIdD - * @param dicId - * @param doctorId + * @param hospitalName + * @param departmentName + * @return */ - private void RollBackData(Long hospitalId, Long departmentId, - Long userId, Long userOrgIdH, Long userOrgIdD, - Long dicId, Long doctorId) { - if (hospitalId > 0) { - hospitalService.removeById(hospitalId); - } - if (departmentId > 0) { - departmentService.removeById(departmentId); - } - if (userId > 0) { - baseMapper.deleteById(userId); - sysUserRoleMapper.deleteById(userId); - } - if (userOrgIdH > 0) { - sysUserRoleMapper.deleteById(userOrgIdH); - } - if (userOrgIdD > 0) { - sysUserRoleMapper.deleteById(userOrgIdD); - } - if (dicId > 0) { - sysDictionariesService.removeById(dicId); - } - if (doctorId > 0) { - sysDoctorMapper.deleteById(doctorId); - } + private boolean saveProductDetail(Long hospitalId, Long departmentId, String hospitalName, String departmentName) { + Map<String, Object> params = new HashMap<String, Object>(); + params.put("hospitalId", hospitalId); + params.put("departmentId", departmentId); + params.put("hospitalName", hospitalName); + params.put("departmentName", departmentName); + ResultBody resultBody = productOrderService.saveProductDetail(params); + return (boolean) resultBody.getData(); } /** @@ -948,6 +963,9 @@ } else { listVoList = baseMapper.hospitalDoctorList(hospitalId, departmentId, CommonConstant.HOSPITAL_DOCTOR_ID, CommonConstant.HOSPITAL_ADMIN_ID); } + listVoList.sort((e1,e2)-> + e2.getUserId().compareTo(e1.getUserId()) + ); return ResultBody.ok().data(listVoList); } else { return ResultBody.failed("医院数据有误"); @@ -964,6 +982,7 @@ Map<String, Object> selectMap = new HashMap<>(); selectMap.put("mobile", phone); selectMap.put("is_del", 0); + selectMap.put("tenant_id", "hospital"); List<SysUser> sysUsers = baseMapper.selectByMap(selectMap); return (sysUsers.size() > 0); } @@ -979,20 +998,18 @@ if (sysDepartment == null) { return 0; } else { - Long sysHospitalId=HospitalIdByDepartmentId(depatmentId); - if (sysHospitalId>0) { + Long sysHospitalId = HospitalIdByDepartmentId(depatmentId); + if (sysHospitalId > 0) { List<HospitalDoctorListVo> hospitalDoctorListVos = baseMapper.hospitalDoctorList(sysHospitalId, depatmentId, CommonConstant.HOSPITAL_DOCTOR_ID, CommonConstant.HOSPITAL_ADMIN_ID); if (hospitalDoctorListVos != null) { int doctorCount = hospitalDoctorListVos.size(); int accountCount = sysDepartment.getAccountsCount().intValue(); - int liveCount=accountCount - doctorCount; + int liveCount = accountCount - doctorCount; return liveCount; } else { return 0; } - } - else - { + } else { return 0; } } @@ -1026,31 +1043,6 @@ } return hospitalId; } - /** - * 根据部门的id获取所属医院id - * - * @return - */ -// public List<Long> DepartmentIdListByhospitalId(Long hospitalId) { -// List<Long> hospitalIdList =new ArrayList<Long>(); -// SysHospital sysHospital = hospitalService.getById(hospitalId); -// if (sysHospital != null) { -// //先获取医院的组织数据 -// SysOrganization sysOrganization = sysOrganizationMapper.selectById(sysHospital.getOrgId()); -// if (sysOrganization != null) { -// //根据组织id获取下级科室组织id -// Map<String, Object> selectMap = new HashMap<>(); -// selectMap.put("org_parent_id", sysOrganization.getId()); -// List<SysOrganization> sysDepartmentList = sysOrganizationMapper.selectByMap(selectMap); -// if (sysDepartmentList != null && sysDepartmentList.size() > 0) { -// //hospitalIdList=sysDepartmentList.stream().sorted(Comparator.comparing(SysOrganization::getCreateTime).reversed()).map(SysOrganization::getId).collect(Collectors.toList()); -// sysDepartmentList.stream().sorted(Comparator.comparing(SysOrganization::getCreateTime).reversed()).map(SysOrganization::getId).collect(Collectors.toList()).get(0); -// } -// } -// } -// return hospitalIdList; -// } - /** * 检查用户登录名是否已经注册 true存在 false不存在 @@ -1114,8 +1106,8 @@ QueryWrapper<SysDoctor> queryWrapper = new QueryWrapper<>(); queryWrapper.eq("user_id", id); List<SysDoctor> sysDoctors = sysDoctorMapper.selectList(queryWrapper); - if(!sysDoctors.isEmpty()){ - sysDoctors.forEach(e->{ + if (!sysDoctors.isEmpty()) { + sysDoctors.forEach(e -> { e.setIsDel(true); sysDoctorMapper.updateById(e); }); -- Gitblit v1.8.0