communication_system-master.zip

package com.system.communication.services.impl; import com.system.communication.common.AppResult; import com.system.communication.common.ResultCode; import com.system.communication.dao.UserMapper; import com.system.communication.exception.ApplicationException; import com.system.communication.model.User; import com.system.communication.services.IUserService; import com.system.communication.utils.MD5Util; import com.system.communication.utils.StringUtil; import com.system.communication.utils.UUIDUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.util.Date; @Slf4j @Service public class UserServiceImpl implements IUserService { @Resource private UserMapper userMapper; @Override public void createNormalUser(User user) { //1.非空校验 if (user == null || StringUtil.isEmpty(user.getUsername()) || StringUtil.isEmpty(user.getNickname()) || StringUtil.isEmpty(user.getPassword())){ //打印日志 log.warn(ResultCode.FAILED_PARAMS_VALIDATE.toString()); //抛出异常，统一抛出applicationException throw new ApplicationException(AppResult.failed(ResultCode.FAILED_PARAMS_VALIDATE)); } //2.按用户名查询用户信息 User existsUser = userMapper.selectByUserName(user.getUsername()); //2.1判断用户是否存在 if(existsUser != null){ //打印日志（用户已存在） log.info(ResultCode.FAILED_USER_EXISTS.toString()); //抛出异常 throw new ApplicationException(AppResult.failed(ResultCode.FAILED_USER_EXISTS)); } //3.新增用户,设置默认值 user.setGender((byte)2); user.setArticleCount(0); user.setIsAdmin((byte)0); user.setState((byte) 0); user.setDeleteState((byte) 0); //当前日期 Date date = new Date(); user.setCreateTime(date); user.setUpdateTime(date); //写入数据库 int row = userMapper.insertSelective(user); //受影响行数 if(row != 1){ //打印日志 log.info(ResultCode.FAILED_CREATE.toString()); //抛出异常 throw new ApplicationException(AppResult.failed(ResultCode.FAILED_CREATE)); } //打印日志 log.info("新增用户成功.username = " + user.getUsername()); } @Override public User selectByUserName(String username) { //非空校验 if (StringUtil.isEmpty(username)){ //打印日志 log.warn(ResultCode.FAILED_PARAMS_VALIDATE.toString()); //抛出异常 throw new ApplicationException(AppResult.failed(ResultCode.FAILED_PARAMS_VALIDATE)); } return userMapper.selectByUserName(username); } @Override public User login(String username, String password) { //1.非空校验 if (StringUtil.isEmpty(username) || StringUtil.isEmpty(password)) { //打印日志 log.warn(ResultCode.FAILED_PARAMS_VALIDATE.toString()); //抛出异常 throw new ApplicationException(AppResult.failed(ResultCode.FAILED_PARAMS_VALIDATE)); } //2.按用户名查询用户信息 User user = selectByUserName(username); //3.对查询结果做非空校验 if (user == null){ //打印日志 log.warn(ResultCode.FAILED_LOGIN.toString() + ", username :" + username); //抛出异常 throw new ApplicationException(AppResult.failed(ResultCode.FAILED_LOGIN)); } //4.做密码校验 String encryptPassword = MD5Util.md5Salt(password, user.getSalt()); if (!encryptPassword.equalsIgnoreCase(user.getPassword())){ //打印日志 log.warn(ResultCode.FAILED_LOGIN.toString()+ ", 密码错误 , username :" + username); //抛出异常 throw new ApplicationException(AppResult.failed(ResultCode.FAILED_LOGIN)); } //登录成功，返回用户信息 return user; } @Override public User selectById(Long id) { //1.非空校验 if (id == null){ //打印日志 log.warn(ResultCode.FAILED_PARAMS_VALIDATE.toString()); //抛出异常 throw new ApplicationException(AppResult.failed(ResultCode.FAILED_LOGIN)); } //2.调用DAO查询数据库并获取对象 User user = userMapper.selectByPrimaryKey(id); //3.返回结果 return user; } @Override public void addOneArticleCountById(Long id) { if (id == null || id <= 0){ //打印日志 log.warn(ResultCode.FAILED_BOARD_ARTICLE_COUNT.toString()); //抛出异常 throw new ApplicationException(AppResult.failed(ResultCode.FAILED_BOARD_ARTICLE_COUNT)); } //查询用户信息 User user = userMapper.selectByPrimaryKey(id); if (user == null){ //打印日志 log.warn(ResultCode.ERROR_IS_NULL.toString() + "user id =" + id); //抛出异常 throw new ApplicationException(AppResult.failed(ResultCode.ERROR_IS_NULL)); } //更新用户发帖数量,重新创建一个要更新的对象 User updateUser = new User(); updateUser.setId(user.getId()); updateUser.setArticleCount(user.getArticleCount() + 1); //更新数据库 int row = userMapper.updateByPrimaryKeySelective(updateUser); if (row != 1){ log.warn(ResultCode.FAILED.toString() + "受影响的行数不等于1"); throw new ApplicationException(AppResult.failed(ResultCode.FAILED)); } } @Override public void subOneArticleCountById(Long id) { if (id == null || id <= 0){ //打印日志 log.warn(ResultCode.FAILED_BOARD_ARTICLE_COUNT.toString()); //抛出异常 throw new ApplicationException(AppResult.failed(ResultCode.FAILED_BOARD_ARTICLE_COUNT)); } //查询用户信息 User user = userMapper.selectByPrimaryKey(id); if (user == null){ //打印日志 log.warn(ResultCode.ERROR_IS_NULL.toString() + "user id =" + id); //抛出异常 throw new ApplicationException(AppResult.failed(ResultCode.ERROR_IS_NULL)); } //更新用户发帖数量,重新创建一个要更新的对象 User updateUser = new User(); updateUser.setId(user.getId()); updateUser.setArticleCount(user.getArticleCount() - 1); //判断-1后用户发帖数是否小于0 if (updateUser.getArticleCount() < 0){ //小于0，置零 updateUser.setArticleCount(0); } //更新数据库 int row = userMapper.updateByPrimaryKeySelective(updateUser); if (row != 1){ log.warn(ResultCode.FAILED.toString() + "受影响的行数不等于1"); throw new ApplicationException(AppResult.failed(ResultCode.FAILED)); } } @Override public void modifyInfo(User user) { //非空校验 if (user == null || user.getId() == null || user.getId() <= 0){ //打印日志 log.warn(ResultCode.FAILED_PARAMS_VALIDATE.toString()); //抛出异常 throw new ApplicationException(AppResult.failed(ResultCode.FAILED_PARAMS_VALIDATE)); } //校验用户是否存在 User existsUser = userMapper.selectByPrimaryKey(user.getId()); if (existsUser == null){ log.warn(ResultCode.FAI