基于springboot医院管理系统

package com.xgs.hisystem.service.impl; import com.xgs.hisystem.config.HisConstants; import com.xgs.hisystem.config.ServerConfig; import com.xgs.hisystem.pojo.bo.BaseResponse; import com.xgs.hisystem.pojo.bo.PageRspBO; import com.xgs.hisystem.pojo.entity.*; import com.xgs.hisystem.pojo.vo.*; import com.xgs.hisystem.repository.*; import com.xgs.hisystem.service.IEmailService; import com.xgs.hisystem.service.IUserService; import com.xgs.hisystem.task.AsyncTask; import com.xgs.hisystem.util.DateUtil; import com.xgs.hisystem.util.MD5Util; import org.apache.shiro.SecurityUtils; import org.apache.shiro.authc.AuthenticationException; import org.apache.shiro.authc.UsernamePasswordToken; import org.apache.shiro.crypto.hash.SimpleHash; import org.apache.shiro.subject.Subject; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.domain.Page; import org.springframework.data.domain.PageRequest; import org.springframework.data.domain.Sort; import org.springframework.data.jpa.domain.Specification; import org.springframework.stereotype.Service; import org.springframework.util.StringUtils; import org.thymeleaf.context.Context; import org.thymeleaf.spring5.SpringTemplateEngine; import javax.persistence.criteria.Predicate; import javax.transaction.Transactional; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Optional; import java.util.stream.Collectors; @Service public class UserServiceImpl implements IUserService { @Autowired private IUserRepository iUserRepository; @Autowired private ILoginInforRepository iLoginInforRepository; @Autowired private SpringTemplateEngine templateEngine; @Autowired private IEmailService iEmailService; @Autowired private IRoleRespository iRoleRespository; @Autowired private IUserRoleRepository iUserRoleRepository; @Autowired private IAnnouncementRepository iAnnouncementRepository; @Autowired private AsyncTask asyncTask; @Autowired private ServerConfig serverConfig; private static final Logger logger = LoggerFactory.getLogger(UserServiceImpl.class); /** * 登录验证 * * @param reqVO * @return */ @Override public BaseResponse<String> doLogin(UserLoginReqVO reqVO) { String email = reqVO.getEmail(); String password = reqVO.getPassword(); UserEntity user = iUserRepository.findByEmail(email); if (StringUtils.isEmpty(user)) { return BaseResponse.error(HisConstants.USER.USER_NOT_EXIST); } //登录验证 UsernamePasswordToken token = new UsernamePasswordToken(email, password); Subject subject = SecurityUtils.getSubject(); try { subject.login(token); } catch (AuthenticationException e) { return BaseResponse.error(HisConstants.USER.PASSWORD_ERROR); } //验证邮箱激活状态 if (user.getEmailStatus().equals(0)) { return BaseResponse.error(HisConstants.USER.EMAIL_STATUS_INACTIVE); } //验证角色审核状态 List<UserRoleEntity> userRoleList = iUserRoleRepository.findByUId(user.getId()); //审核通过角色个数 long passStatusCount = userRoleList.stream() .filter(userRole -> userRole.getRoleStatus().equals(1)).count(); if (passStatusCount == 0) { //未审核角色个数 long unAuditStatusCount = userRoleList.stream() .filter(userRole -> userRole.getRoleStatus().equals(0)).count(); if (unAuditStatusCount >= 1) { return BaseResponse.error(HisConstants.USER.ROLE_STATUS_NOTAUDIT); } //审核未通过 else { return BaseResponse.error(HisConstants.USER.ROLE_STATUS_NOTPASS); } } //保存用户登录信息 asyncTask.saveLoginInfor(reqVO.getIp(), reqVO.getBroswer(), email); return BaseResponse.success(HisConstants.USER.SUCCESS); } /** * 保存用户注册信息，向用户发送激活链接 * * @param reqVO * @return */ @Transactional @Override public BaseResponse<String> saveUserAndSendEmail(UserRegisterReqVO reqVO) { String email = reqVO.getEmail(); String roleName = reqVO.getRoleName(); try { //验证角色 RoleEntity role = iRoleRespository.findByDescription(roleName); if (role == null) { return BaseResponse.error("您选择的角色不存在，请重试！"); } //检查该账户是否已存在 UserEntity checkUser = iUserRepository.findByEmail(email); if (checkUser != null) { return BaseResponse.error(HisConstants.USER.ACCOUNT_EXIST); } UserEntity user = new UserEntity(); user.setEmail(email); user.setUsername(reqVO.getUsername()); user.setPlainPassword(reqVO.getPassword()); //生成盐和加盐密码 String salt = MD5Util.md5Encrypt32Lower(reqVO.getEmail()); // 使用SimpleHash类对原始密码进行加密 String password = new SimpleHash("MD5", reqVO.getPassword(), salt, 1024).toHex(); user.setPassword(password); user.setSalt(salt); //生成激活码 String validateCode = MD5Util.md5Encrypt32Upper(reqVO.getEmail()); user.setValidateCode(validateCode); user.setEmailStatus(0); iUserRepository.saveAndFlush(user); //保存用户与角色信息 UserRoleEntity userRole = new UserRoleEntity(); userRole.setuId(user.getId()); userRole.setRoleId(role.getId()); String description = user.getEmail() + "#" + role.getRole(); userRole.setDescription(description); userRole.setRoleStatus(0); iUserRoleRepository.saveAndFlush(userRole); //组装发送邮件参数 String title = "账户激活"; Context context = new Context(); //组装激活地址 String url = serverConfig.getUrl().concat("/activation").concat("?email=") .concat(email).concat("&validateCode=").concat(validateCode); context.setVariable("url", url); String emailContent = templateEngine.process("email/email", context); //发送邮件 iEmailService.sendMail(reqVO.getEmail(), title, emailContent); return BaseResponse.success(HisConstants.USER.SUCCESS); } catch (Exception e) { e.printStackTrace(); return BaseResponse.error("保存用户信息或邮件发送异常,请联系管理员处理!"); } } /** * 激活账户 * * @param email * @param validateCode * @return * @throws ParseException */ @Transactional @Override public BaseResponse<String> activation(String email, String validateCode) throws ParseException { try { UserEntity user = iUserRepository.findByEmail(email); if (user == null) { return BaseResponse.error("未查询到该邮箱，请核对信息！"); } String nowDate = DateUtil.getCurrentDateToString(); String createDate = user.getCreateDatetime(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-M-d HH:mm:ss"); Date start = sdf.parse(createDate); Date end = sdf.parse(nowDate); long cha = end.getTime() - start.getTime(); double result = cha * 1.0 / (1000 * 60 * 60); if (result > 48) { return BaseRes