From 73d5561cbf2bea50acc22f91050fcc3557d49de4 Mon Sep 17 00:00:00 2001 From: zhaoxiaohao <913652501@qq.com> Date: Mon, 17 Aug 2020 09:58:10 +0800 Subject: [PATCH] Merge branch 'dev' of http://192.168.2.240:7070/r/kidgrow-microservices-platform into dev --- kidgrow-business/kidgrow-usercenter/kidgrow-usercenter-biz/src/main/java/com/kidgrow/usercenter/service/impl/SysUserServiceImpl.java | 141 +++++++++++++++++++--------------------------- 1 files changed, 58 insertions(+), 83 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 3e6b1a0..3750c3c 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 @@ -18,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; @@ -89,6 +90,9 @@ private SysUserRoleMapper sysUserRoleMapper; @Autowired private SysOrganizationMapper sysOrganizationMapper; + @Autowired + private ProductOrderService productOrderService; + @Override public LoginAppUser findByUsername(String username) { @@ -404,7 +408,7 @@ organizationService.deleteByUserId(id); //删除医生数据 Map<String, Object> params = new HashMap<>(); - params.put("userId", id); + params.put("user_id", id); sysDoctorMapper.deleteByMap(params); //删除用户数据 return baseMapper.deleteById(id) > 0; @@ -463,6 +467,8 @@ @Override public ResultBody findCountByMap(Map<String, Object> map) { + map.put("enable",1); + map.put("is_del",0); Integer integer = baseMapper.selectCountByMap(map); return ResultBody.ok().data(integer); } @@ -709,11 +715,17 @@ sysDepartment.setServerUserTel("0"); sysDepartment.setServerUserName(createUserName); boolean d = departmentService.save(sysDepartment); - if (!d) { + if (d) { + userRegVo.setDepartmentId(sysDepartment.getId()); + //自动充入系统指定的试用套餐 + if(!saveProductDetail(sysHospital.getId(),sysDepartment.getId(),sysHospital.getHospitalName(),sysDepartment.getDepartmentName())) + { + isSuccess = false; + expMsg = "套餐充值失败"; + } + } else { isSuccess = false; expMsg = "科室数据写入失败"; - } else { - userRegVo.setDepartmentId(sysDepartment.getId()); } } else { isSuccess = false; @@ -724,11 +736,8 @@ } } - //业务执行中途出错 手动撤回数据 + //业务执行中途出错 if (isReg && !isSuccess) { - RollBackData(userRegVo.getHospitalId(), - userRegVo.getDepartmentId(), 0L, 0L, - 0L, 0L, 0L); return ResultBody.failed(expMsg); } if (!isReg && departmetAccountsCount(userRegVo.getDepartmentId()) < 1) { @@ -737,7 +746,7 @@ //添加用户数据 如果没有输入密码,将会创建一个默认密码返回 String defaultPassWord = ""; SysUser sysUser = new SysUser(); - sysUser.setUsername(userRegVo.getUsername()); + sysUser.setUsername(userRegVo.getMobile()); sysUser.setMobile(userRegVo.getMobile()); if (StringUtils.isBlank(userRegVo.getPassword())) { defaultPassWord = com.kidgrow.common.utils.RandomValueUtils.getRandom(6); @@ -758,7 +767,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) { @@ -799,13 +808,14 @@ sysDictionaries.setCreateUserId(createUserId); sysDictionaries.setCreateUserName(createUserName); dicBool = sysDictionariesService.save(sysDictionaries); + if (dicBool) { + userRegVo.setDoctorRankId(sysDictionaries.getId()); + } } if (dicBool) { - userRegVo.setDoctorRankId(sysDictionaries.getId()); //写用户组织关系表 List<SysUserOrg> sysUserOrgList = new ArrayList<SysUserOrg>(); - sysUserOrgH.setUserId(sysUser.getId()); sysUserOrgH.setOrgId(organizationHos); sysUserOrgH.setFromLevel(CommonConstant.SYSTEM_ORG_HOS_LEVEL); @@ -834,17 +844,14 @@ sysDoctor.setDoctorType(CommonConstant.H_DOCTOR_TYPE); sysDoctor.setCreateUserId(isReg ? createUserId : sysUserd.getId()); sysDoctor.setCreateUserName(isReg ? createUserName : sysUserd.getUsername()); - if (isReg) { - sysDoctor.setDoctorState(false); - } else { - sysDoctor.setDoctorState(true); - } + sysDoctor.setDoctorState(!isReg); sysDoctor.setDoctorTel(userRegVo.getMobile()); sysDoctor.setDoctorName(userRegVo.getNickname()); sysDoctor.setServerUserId(isReg ? createUserId : sysUserd.getId()); sysDoctor.setServerUserName(isReg ? createUserName : sysUserd.getUsername()); sysDoctor.setIsAdminUser(false); - sysDoctor.setEnabled(!isReg); + sysDoctor.setDoctorCcie(userRegVo.getDoctorCcie()); + sysDoctor.setEnabled(true); if (sysDoctorMapper.insert(sysDoctor) == 1) { //非自主注册的 返回信息带密码 if (!isReg) { @@ -883,11 +890,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,43 +897,23 @@ } /** - * 手动撤回数据,需要撤回那个,给那个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(); } - /** * 获取医院科室下的所有H端有效的医生 * @@ -964,6 +946,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); } @@ -984,8 +967,9 @@ 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(); - return (accountCount - doctorCount); + int accountCount = sysDepartment.getAccountsCount().intValue(); + int liveCount=accountCount - doctorCount; + return liveCount; } else { return 0; } @@ -1025,31 +1009,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不存在 @@ -1106,4 +1065,20 @@ String encode = passwordEncoder.encode(password); return ResultBody.ok().data(encode); } + + @Override + public boolean deleteNoContact(Long id) { + //删除医生数据 + QueryWrapper<SysDoctor> queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("user_id", id); + List<SysDoctor> sysDoctors = sysDoctorMapper.selectList(queryWrapper); + if(!sysDoctors.isEmpty()){ + sysDoctors.forEach(e->{ + e.setIsDel(true); + sysDoctorMapper.updateById(e); + }); + } + //删除用户数据 + return baseMapper.deleteById(id) > 0; + } } \ No newline at end of file -- Gitblit v1.8.0