From 2c4189febf04adb1505ad3ed9816d9258fd852b8 Mon Sep 17 00:00:00 2001
From: zhaoxiaohao <279049017@qq.com>
Date: Tue, 24 Nov 2020 12:06:10 +0800
Subject: [PATCH] 添加taocan 的功能
---
kidgrow-business/kidgrow-usercenter/kidgrow-usercenter-biz/src/main/java/com/kidgrow/usercenter/service/impl/SysUserServiceImpl.java | 444 ++++++++++++++++++++++++++++++++++++------------------
1 files changed, 293 insertions(+), 151 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 f67c7b7..1fbec45 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
@@ -15,8 +15,10 @@
import com.kidgrow.common.model.SysUser;
import com.kidgrow.common.model.*;
import com.kidgrow.common.service.impl.SuperServiceImpl;
+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;
@@ -86,17 +88,30 @@
private SysRoleMapper sysRoleMapper;
@Autowired
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
public LoginAppUser findByOpenId(String username) {
SysUser sysUser = this.selectByOpenId(username);
- return getLoginAppUser(sysUser);
+ if (sysUser == null) {
+ return null;
+ } else {
+ return getLoginAppUser(sysUser);
+ }
}
@Override
@@ -108,27 +123,26 @@
/**
* 获取登录用户的一系列信息 hrj 06-04修改
*
- * @param sysUser
+ * @param sysUserNew
* @return
*/
@Override
- public LoginAppUser getLoginAppUser(SysUser sysUser) {
+ public LoginAppUser getLoginAppUser(SysUser sysUserNew) {
+ log.error(sysUserNew.toString());
LoginAppUser loginAppUser = new LoginAppUser();
+ SysUser sysUser = this.baseMapper.selectById(sysUserNew);
if (sysUser != null) {
- //返回的数据为什么要把密码也返回？清空!!
- loginAppUser.setPassword("");
- loginAppUser.setNewPassword("");
- loginAppUser.setOldPassword("");
-
BeanUtils.copyProperties(sysUser, loginAppUser);
//获取用户所属组织机构列表
+ 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);
-
if (!CollectionUtils.isEmpty(sysRoles)) {
Set<Long> roleIds = sysRoles.parallelStream().map(SuperEntity::getId).collect(Collectors.toSet());
List<SysMenu> menus = roleMenuMapper.findMenusByRoleIds(roleIds, CommonConstant.PERMISSION);
@@ -139,15 +153,12 @@
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;
@@ -164,7 +175,8 @@
public SysUser selectByUsername(String username) {
String clientId = ClientContextHolder.getClient();
List<SysUser> users = baseMapper.selectList(
- new QueryWrapper<SysUser>().eq("username", username).eq("tenant_id", clientId)
+ //new QueryWrapper<SysUser>().eq("username", username).eq("tenant_id", clientId)
+ new QueryWrapper<SysUser>().eq("username", username)
);
return getUser(users);
}
@@ -226,21 +238,27 @@
@Transactional(rollbackFor = Exception.class)
@Override
- public ResultBody updatePassword(Long id, String oldPassword, String newPassword, Boolean isdefault) {
+ public ResultBody updatePassword(Long id, String oldPassword, String newPassword, Boolean isdefault) throws Exception {
+
SysUser sysUser = baseMapper.selectById(id);
if (StrUtil.isNotBlank(oldPassword)) {
+ oldPassword = AesUtils.desEncrypt(oldPassword).trim();
if (!passwordEncoder.matches(oldPassword, sysUser.getPassword())) {
return ResultBody.failed("旧密码错误！");
}
}
if (StrUtil.isBlank(newPassword)) {
newPassword = com.kidgrow.common.utils.RandomValueUtils.getRandom(6);
+ } else {
+ newPassword = AesUtils.desEncrypt(newPassword).trim();
}
SysUser user = new SysUser();
user.setId(id);
user.setPassword(passwordEncoder.encode(newPassword));
if (isdefault) {
user.setDefaultAuth(true);
+ } else {
+ user.setDefaultAuth(false);
}
baseMapper.updateById(user);
if (isdefault) {
@@ -252,12 +270,12 @@
@Override
@Transactional(rollbackFor = Exception.class)
- public ResultBody updateUserTel(Map<String, Object> params) {
+ public ResultBody updateUserTel(Map<String, Object> params) throws Exception {
Long id = MapUtils.getLong(params, "id");
String oldTel = MapUtils.getString(params, "oldTel");
- String newTel = MapUtils.getString(params, "newTel");
- String authCode = MapUtils.getString(params, "authCode");
- String userPassword = MapUtils.getString(params, "userPassword");
+ String newTel = AesUtils.desEncrypt(MapUtils.getString(params, "newTel")).trim();
+ String authCode = AesUtils.desEncrypt(MapUtils.getString(params, "authCode")).trim();
+ String userPassword =MapUtils.getString(params, "userPassword");
if (id > 0 && StringUtils.isNotBlank(oldTel) && StringUtils.isNotBlank(newTel) && StringUtils.isNotBlank(authCode) && StringUtils.isNotBlank(userPassword)) {
//检查验证码
@@ -271,6 +289,7 @@
} else {
//验证旧手机号和密码
SysUser sysUser = baseMapper.selectById(id);
+ userPassword = AesUtils.desEncrypt(userPassword);
if (passwordEncoder.matches(userPassword, sysUser.getPassword()) && sysUser.getMobile().equals((oldTel))) {
//验证通过，修改手机号
SysUser user = new SysUser();
@@ -282,8 +301,8 @@
com.kidgrow.usercenter.model.SysDoctor newsysDoctorModel = new com.kidgrow.usercenter.model.SysDoctor();
if (sysDoctorModel != null) {
//理论上只有一个，如果有多个 只取第一个
- newsysDoctorModel.setId(sysDoctorModel.getId());
- newsysDoctorModel.setDoctorTel(newTel);
+ sysDoctorModel.setId(sysDoctorModel.getId());
+ sysDoctorModel.setDoctorTel(newTel);
sysDoctorMapper.updateById(newsysDoctorModel);
}
if (baseMapper.updateById(user) > 0) {
@@ -293,13 +312,11 @@
} else {
return ResultBody.failed("手机号修改失败！");
}
- }else {
+ } else {
return ResultBody.failed("用户信息验证失败，请提供正确的手机号和密码！");
}
}
- }
- else
- {
+ } else {
return ResultBody.failed("无效的验证码");
}
} else {
@@ -312,15 +329,13 @@
Page<SysUser> page = new Page<>(MapUtils.getInteger(params, "page"), MapUtils.getInteger(params, "limit"));
List<SysUser> list = baseMapper.findList(page, params);
long total = page.getTotal();
- if (total > 0) {
+ if (total > 0&&list.size()>0) {
List<Long> userIds = list.stream().map(SysUser::getId).collect(Collectors.toList());
-
- List<SysRole> sysRoles = roleUserService.findRolesByUserIds(userIds);
-
-// Map<String, Object> map = new HashMap<String, Object>();
-// List<SysOrganization> sysOrganizationList=organizationService.fin();
- list.forEach(u -> u.setRoles(sysRoles.stream().filter(r -> !ObjectUtils.notEqual(u.getId(), r.getUserId()))
- .collect(Collectors.toList())));
+ if (userIds.size()>0) {
+ List<SysRole> sysRoles = roleUserService.findRolesByUserIds(userIds);
+ list.forEach(u -> u.setRoles(sysRoles.stream().filter(r -> !ObjectUtils.notEqual(u.getId(), r.getUserId()))
+ .collect(Collectors.toList())));
+ }
}
return PageResult.<SysUser>builder().data(list).code(0).count(total).build();
}
@@ -351,11 +366,11 @@
@Transactional(rollbackFor = Exception.class)
@Override
public ResultBody saveOrUpdateUser(SysUser sysUser) {
+ String defaultPassWord = com.kidgrow.common.utils.RandomValueUtils.getRandom(6);
if (sysUser.getId() == null) {
if (StringUtils.isBlank(sysUser.getType())) {
sysUser.setType(UserType.BACKEND.name());
}
- String defaultPassWord = com.kidgrow.common.utils.RandomValueUtils.getRandom(6);
sysUser.setPassword(passwordEncoder.encode(defaultPassWord));
sysUser.setEnabled(Boolean.TRUE);
}
@@ -374,6 +389,7 @@
roleUserService.saveBatch(roleUsers);
}
}
+ sysUser.setPassword(defaultPassWord);
return result ? ResultBody.ok().data(sysUser).msg("操作成功") : ResultBody.failed("操作失败");
}
@@ -392,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;
@@ -451,6 +467,8 @@
@Override
public ResultBody findCountByMap(Map<String, Object> map) {
+ map.put("enable", 1);
+ map.put("isDel", 0);
Integer integer = baseMapper.selectCountByMap(map);
return ResultBody.ok().data(integer);
}
@@ -490,7 +508,7 @@
* @return
*/
@Override
- public ResultBody passwordByPhone(Map<String, Object> map) {
+ public ResultBody passwordByPhone(Map<String, Object> map) throws Exception {
//手机号，type，验证码，新密码
String phone = MapUtils.getString(map, "phone");
if (phone == null || "".equals(phone.trim())) {
@@ -504,7 +522,10 @@
if (newPass == null || "".equals(newPass.trim())) {
return ResultBody.failed("请输入正确的密码");
}
- if (CheckVerificationCode(ConstantSMS.PASSWORD_SMS, map.get("phone").toString(), verificationCode)) {
+ phone = AesUtils.desEncrypt(phone.trim());
+ verificationCode = AesUtils.desEncrypt(verificationCode.trim());
+ newPass = AesUtils.desEncrypt(newPass.trim());
+ if (CheckVerificationCode(ConstantSMS.PASSWORD_SMS, phone, verificationCode)) {
//查询表
Map<String, Object> selectMap = new HashMap<>();
selectMap.put("mobile", phone);
@@ -638,15 +659,24 @@
*/
@Transactional(rollbackFor = Exception.class)
@Override
- public ResultBody doctorUserReg(UserRegVo userRegVo, SysUser sysUserd) {
+ public ResultBody doctorUserReg(UserRegVo userRegVo, SysUser sysUserd) throws Exception {
+ if (sysUserd.getId() == null) {
+ sysUserd = this.baseMapper.selectById(userRegVo.getUserId());
+ }
+ userRegVo.setPassword(AesUtils.desEncrypt(userRegVo.getPassword()).trim());
+ userRegVo.setUsername(AesUtils.desEncrypt(userRegVo.getUsername()).trim());
//检查手机号是否已经注册 H端登录名和手机号存一样的值
if (phoneIsUsed(userRegVo.getMobile())) {
return ResultBody.failed("该手机号已经注册");
}
//创建人id
- Long createUserId = 0L;
- //创建人id
- String createUserName = "自动创建";
+ 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;
//业务成功
@@ -654,8 +684,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();
@@ -665,50 +695,83 @@
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.setHospitalId(sysHospital.getId());
- 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)) {
+ organizationHos=sysOrganizationH.getId();
+ //写科室组织数据
+ 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)) {
+ organizationDep=sysOrganizationD.getId();
+ //写医院组织数据
+ 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) {
@@ -717,7 +780,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);
@@ -738,7 +801,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) {
@@ -759,42 +822,58 @@
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.setDictionariesKey(DictionariesConstants.DOCTOR_RANK);
- sysDictionaries.setDictionariesClassId(DictionariesConstants.DOCTOR_RANK_ID.toString());
+ sysDictionaries.setDictionariesClassId(DictionariesConstants.DOCTOR_RANK);
//将名称汉字转为拼音
- sysDictionaries.setDictionariesKey(Pinyin4jUtil.makeStringByStringSet(Pinyin4jUtil.getPinyin(userRegVo.getDoctorRank(), true)));
+ String keyStr=Pinyin4jUtil.makeStringByStringSet(Pinyin4jUtil.getPinyin(userRegVo.getDoctorRank(), true));
+ if (keyStr.length()>50) {
+ keyStr=keyStr.substring(0,49);
+ }
+ sysDictionaries.setDictionariesKey(keyStr);
sysDictionaries.setDictionariesName(userRegVo.getDoctorRank());
sysDictionaries.setCreateUserId(createUserId);
sysDictionaries.setCreateUserName(createUserName);
dicBool = sysDictionariesService.save(sysDictionaries);
+ if (dicBool) {
+ userRegVo.setDoctorRankId(sysDictionaries.getId());
+ }
}
if (dicBool) {
- userRegVo.setDoctorRankId(sysDictionaries.getId());
//写用户组织关系表
+ SysHospital byId = hospitalService.getById(userRegVo.getHospitalId());
+ if(byId!=null){
+ organizationHos=byId.getOrgId();
+ }
List<SysUserOrg> sysUserOrgList = new ArrayList<SysUserOrg>();
-
sysUserOrgH.setUserId(sysUser.getId());
sysUserOrgH.setOrgId(organizationHos);
+ sysUserOrgH.setFromLevel(CommonConstant.SYSTEM_ORG_HOS_LEVEL);
+ sysUserOrgH.setFromId(userRegVo.getHospitalId());
sysUserOrgH.setCreateUserId(isReg ? createUserId : sysUserd.getId());
sysUserOrgH.setCreateUserName(isReg ? createUserName : sysUserd.getUsername());
sysUserOrgList.add(sysUserOrgH);
-
+ SysDepartment department = departmentService.getById(userRegVo.getDepartmentId());
+ if(department!=null){
+ organizationDep=department.getOrgId();
+ }
sysUserOrgD.setUserId(sysUser.getId());
sysUserOrgD.setOrgId(organizationDep);
+ sysUserOrgD.setFromId(userRegVo.getDepartmentId());
+ sysUserOrgD.setFromLevel(CommonConstant.SYSTEM_ORG_DEP_LEVEL);
sysUserOrgD.setCreateUserId(isReg ? createUserId : sysUserd.getId());
sysUserOrgD.setCreateUserName(isReg ? createUserName : sysUserd.getUsername());
sysUserOrgList.add(sysUserOrgD);
@@ -808,19 +887,17 @@
sysDoctor.setDepartmentName(userRegVo.getDepartmentName());
sysDoctor.setDoctorRank(userRegVo.getDoctorRank());
sysDoctor.setDoctorRankId(userRegVo.getDoctorRankId());
+ 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.setServerUserId(isReg ? sysUserSale.getId() : sysUserd.getId());
+ sysDoctor.setServerUserName(isReg ? sysUserSale.getNickname() : sysUserd.getUsername());
+ sysDoctor.setIsAdminUser(false);
+ sysDoctor.setDoctorCcie(userRegVo.getDoctorCcie());
+ sysDoctor.setEnabled(true);
if (sysDoctorMapper.insert(sysDoctor) == 1) {
//非自主注册的 返回信息带密码
if (!isReg) {
@@ -859,11 +936,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);
@@ -871,54 +943,43 @@
}
/**
- * 手动撤回数据，需要撤回那个，给那个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端有效的医生
*
* @param hospitalId
* @param departmentId
* @return
*/
@Override
- public ResultBody hospitalDoctorList(Long hospitalId, Long departmentId) {
+ public ResultBody hospitalDoctorList(Long hospitalId, Long departmentId, Boolean isIncluddel) {
if (hospitalId > 0 && departmentId > 0) {
- List<HospitalDoctorListVo> listVoList = baseMapper.hospitalDoctorList(hospitalId, departmentId);
+ List<HospitalDoctorListVo> listVoList;
+ if (isIncluddel) {
+ listVoList = baseMapper.hospitalDoctorListAndDel(hospitalId, departmentId, CommonConstant.HOSPITAL_DOCTOR_ID, CommonConstant.HOSPITAL_ADMIN_ID);
+ } 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("医院数据有误");
@@ -931,9 +992,11 @@
* @param phone
* @return
*/
- private boolean phoneIsUsed(String phone) {
+ public boolean phoneIsUsed(String phone) {
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);
}
@@ -944,23 +1007,55 @@
* @param depatmentId
* @return
*/
- private Integer departmetAccountsCount(Long depatmentId) {
+ public Integer departmetAccountsCount(Long depatmentId) {
SysDepartment sysDepartment = departmentService.getById(depatmentId);
if (sysDepartment == null) {
return 0;
} else {
- Map<String, Object> selectMap = new HashMap<>();
- selectMap.put("departmentId", depatmentId);
- selectMap.put("enabled", 1);
- List<SysDoctor> sysDoctorList = sysDoctorMapper.selectByMap(selectMap);
- if (sysDoctorList == null) {
- int doctorCount = sysDoctorList.size();
- int accountCount = sysDepartment.getAccountsCount();
- return (accountCount - doctorCount);
+ 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;
+ return liveCount;
+ } else {
+ return 0;
+ }
} else {
return 0;
}
}
+ }
+
+ /**
+ * 根据部门的id获取所属医院id
+ *
+ * @return
+ */
+ public Long HospitalIdByDepartmentId(Long departmentId) {
+ Long hospitalId = -1L;
+ SysDepartment sysDepartment = departmentService.getById(departmentId);
+ if (sysDepartment != null) {
+ //先获取科室的组织数据
+ SysOrganization sysOrganization = sysOrganizationMapper.selectById(sysDepartment.getOrgId());
+ if (sysOrganization != null) {
+ //获取上级组织id
+ sysOrganization = sysOrganizationMapper.selectById(sysOrganization.getOrgParentId());
+ if (sysOrganization != null) {
+ //根据组织id获取上级医院id
+ Map<String, Object> selectMap = new HashMap<>();
+ selectMap.put("org_id", sysOrganization.getId());
+ List<SysHospital> sysHospitalList = hospitalService.listByMap(selectMap);
+ if (sysHospitalList != null && sysHospitalList.size() > 0) {
+ //取第一个
+ hospitalId = sysHospitalList.get(0).getId();
+ }
+ }
+ }
+ }
+ return hospitalId;
}
/**
@@ -987,4 +1082,51 @@
}
return new com.kidgrow.usercenter.model.SysDoctor();
}
+
+ /**
+ * 检查手机号是注册用户还是正式用户
+ *
+ * @param userTel
+ * @return
+ */
+ public ResultBody isRegUser(String userTel) {
+ if (StringUtils.isNotBlank(userTel)) {
+ List<SysUser> users = baseMapper.selectList(
+ new QueryWrapper<SysUser>().eq("username", userTel)
+ );
+ if (users != null && users.size() == 1) {
+ SysUser sysUser = users.get(0);
+ if (sysUser.getCreateUserId() == CommonConstant.CREATE_USER_ID && sysUser.getCreateUserName().equals(CommonConstant.CREATE_USER_NAME)) {
+ return ResultBody.ok().data(true);
+ }
+ return ResultBody.ok().data(false);
+ } else {
+ return ResultBody.failed("用户数据有误！");
+ }
+ } else {
+ return ResultBody.failed("必要参数有误！");
+ }
+ }
+
+ @Override
+ public ResultBody jiaMipython(String password) {
+ 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