From 8ea75b6f027f18f6daf229e43928f78b49740f79 Mon Sep 17 00:00:00 2001
From: zhaoxiaohao <279049017@qq.com>
Date: Wed, 04 Nov 2020 16:51:36 +0800
Subject: [PATCH] Merge branch 'dev'

---
 kidgrow-business/kidgrow-usercenter/kidgrow-usercenter-biz/src/main/java/com/kidgrow/usercenter/service/impl/SysUserServiceImpl.java |  231 ++++++++++++++++++++++++++++++++++-----------------------
 1 files changed, 137 insertions(+), 94 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 f874488..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
@@ -97,10 +97,9 @@
     @Override
     public LoginAppUser findByUsername(String username) {
         SysUser sysUser = this.selectByUsername(username);
-        if(sysUser==null){
+        if (sysUser == null) {
             return null;
-        }
-        else {
+        } else {
             return getLoginAppUser(sysUser);
         }
     }
@@ -108,7 +107,11 @@
     @Override
     public LoginAppUser findByOpenId(String username) {
         SysUser sysUser = this.selectByOpenId(username);
-        return getLoginAppUser(sysUser);
+        if (sysUser == null) {
+            return null;
+        } else {
+            return getLoginAppUser(sysUser);
+        }
     }
 
     @Override
@@ -120,29 +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 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);
-
             if (!CollectionUtils.isEmpty(sysRoles)) {
                 Set<Long> roleIds = sysRoles.parallelStream().map(SuperEntity::getId).collect(Collectors.toSet());
                 List<SysMenu> menus = roleMenuMapper.findMenusByRoleIds(roleIds, CommonConstant.PERMISSION);
@@ -153,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;
@@ -278,7 +275,7 @@
         String oldTel = MapUtils.getString(params, "oldTel");
         String newTel = AesUtils.desEncrypt(MapUtils.getString(params, "newTel")).trim();
         String authCode = AesUtils.desEncrypt(MapUtils.getString(params, "authCode")).trim();
-        String userPassword = AesUtils.desEncrypt(MapUtils.getString(params, "userPassword")).trim();
+        String userPassword =MapUtils.getString(params, "userPassword");
 
         if (id > 0 && StringUtils.isNotBlank(oldTel) && StringUtils.isNotBlank(newTel) && StringUtils.isNotBlank(authCode) && StringUtils.isNotBlank(userPassword)) {
             //检查验证码
@@ -304,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) {
@@ -332,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();
     }
@@ -472,8 +467,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);
     }
@@ -678,6 +673,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;
         //业务成功
@@ -685,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();
@@ -696,45 +695,74 @@
             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) {
-                        userRegVo.setDepartmentId(sysDepartment.getId());
-                        //自动充入系统指定的试用套餐
-                        if(!saveProductDetail(sysHospital.getId(),sysDepartment.getId(),sysHospital.getHospitalName(),sysDepartment.getDepartmentName()))
-                        {
+                //写医院组织数据
+                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 = "套餐充值失败";
+                            expMsg = "医院数据写入失败";
                         }
                     } else {
                         isSuccess = false;
-                        expMsg = "科室数据写入失败";
+                        expMsg = "科室组织数据写入失败";
                     }
                 } else {
                     isSuccess = false;
-                    expMsg = "医院数据写入失败";
+                    expMsg = "医院组织数据写入失败";
                 }
             } else {
                 return ResultBody.failed("无效的验证码");
@@ -743,6 +771,7 @@
 
         //业务执行中途出错
         if (isReg && !isSuccess) {
+            //注册过程失败
             return ResultBody.failed(expMsg);
         }
         if (!isReg && departmetAccountsCount(userRegVo.getDepartmentId()) < 1) {
@@ -793,22 +822,27 @@
                     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);
                             //将名称汉字转为拼音
-                            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);
@@ -820,6 +854,10 @@
 
                         if (dicBool) {
                             //写用户组织关系表
+                            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);
@@ -828,7 +866,10 @@
                             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());
@@ -852,8 +893,8 @@
                                 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);
@@ -903,22 +944,23 @@
 
     /**
      * feign客户端调用写入试用套餐
+     *
      * @param hospitalId
      * @param departmentId
      * @param hospitalName
      * @param departmentName
      * @return
      */
-    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();
+    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端有效的医生
      *
@@ -935,6 +977,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("医院数据有误");
@@ -967,20 +1012,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;
             }
         }
@@ -1077,8 +1120,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