基于SSH的J2EE项目 博客系统

package com.haiersoft.service.impl; import java.util.List; import com.haiersoft.model.*; import com.haiersoft.dao.MessageDao; import com.haiersoft.dao.UserDao; import com.haiersoft.exception.ExamException; /** * blog服务处理类。<BR> * @author hs * @version 1.0 * @since 1.0 */ public class BlogServiceImpl implements com.haiersoft.service.BlogService { private UserDao userDao; private MessageDao messageDao; public void setUserDao(UserDao userDao) { this.userDao = userDao; } public void setMessageDao(MessageDao messageDao) { this.messageDao = messageDao; } /** * 增加一个用户实例，对应为增加一条用户的记录 * @param name 用户学号。 * @param pass 密码。 * @param email 用户学号。 * @param address 用户地址。 * @param phone 用户电话。 * @param loginName 登录名。 * @return 新增用户的主键 */ public int addUser(String name , String pass , String email , String address , String phone,String loginName) throws ExamException { try { User User = new User(name, pass, email, address, phone,loginName); userDao.save(User); return User.getId(); } catch (Exception e) { e.printStackTrace(); throw new ExamException("添加用户时出现异常,请重试！"); } } /** * 根据用户I删除用户 * @param id 需要删除的用户的主键。 * @return 删除用户的记录数 */ public void deleteUser(int id) throws ExamException { try { userDao.delete(id); } catch (Exception e) { e.printStackTrace(); throw new ExamException("删除用户时出现异常,请重试！"); } } /** * 根据ID来获取用户资料。 * @param id 需要获取用户的ID。 * @return 指定ID对应的用户对象。 * @throws ExamException */ public User getUser(int id) throws ExamException { try { User user = userDao.get(id); return user; } catch (Exception e) { e.printStackTrace(); throw new ExamException("获取用户时出现异常,请重试！"); } } /** * 根据用户名和密码判断用户是否可以成功登录 * @param user 登录用的用户名 * @param pass 登录用的密码 * @return 是否可以成功登录 */ public String adminLogin(String user , String pass) throws ExamException { try { List result = userDao.findUserByNameAndStuNumber(user, pass); if (result != null && result.size() > 0) { User u = (User)result.get(0); return String.valueOf(u.getId()) ; } return null; } catch (Exception e) { e.printStackTrace(); throw new ExamException("登录出现异常,请重试！"); } } /** * 保存博客消息 * @param message 博客 * @return 指定ID对应的消息 */ public int addMessage(Message message) throws ExamException { try { messageDao.save(message); return message.getId(); } catch (Exception e) { e.printStackTrace(); throw new ExamException("添加博客时出现异常,请重试！"); } } /** * 获取blog数量 * @return blog的个数 */ public Message getMessage(int id)throws Exception { try { Message message = messageDao.get(id); return message; } catch (Exception e) { e.printStackTrace(); throw new Exception("获取博客资料异常"); } } /** * 获取blog数量 * @param id 用户Id * @return blog的个数 */ public int getMessageCount()throws ExamException { try { return (int)messageDao.getMessageCount(); } catch (Exception e) { e.printStackTrace(); throw new ExamException("获取博客数量时出现异常,请重试！"); } } /** * 获取blog数量 * @param id 用户Id * @return blog的个数 */ public int getMessageCount(int id)throws ExamException { try { return (int)messageDao.getMessageCount(id); } catch (Exception e) { e.printStackTrace(); throw new ExamException("获取博客数量时出现异常,请重试！"); } } /** * 根据每页记录数，总记录数获取总页数 * @param count 总记录数 * @param pageSize 每页显示的记录数 * @return 计算得到的总页数 */ public int getPageCount(int count , int pageSize) { return (count + pageSize - 1 ) / pageSize; } /** * 根据页码列出博客列表 * @param pageNo 页码 * return 列出的博客列表 */ public List<Message> listMessage(int pageNo) throws ExamException { try { return messageDao.findAllByPage(pageNo , MESSAGE_PAGE_SIZE); } catch (Exception e) { e.printStackTrace(); throw new ExamException("列出学生时出现异常,请重试！"); } } /** * 根据页码列出博客列表 * @param pageNo 页码 * return 列出的博客列表 */ public List<Message> listMessage(int pageNo,int id) throws ExamException { try { return messageDao.findAllByPage(pageNo ,id , MESSAGE_PAGE_SIZE); } catch (Exception e) { e.printStackTrace(); throw new ExamException("列出学生时出现异常,请重试！"); } } /** * 根据用户I删除用户 * @param id 需要删除的用户的主键。 * @return 删除用户的记录数 */ public void deleteMessage(int id) throws ExamException { try { messageDao.delete(id); } catch (Exception e) { e.printStackTrace(); throw new ExamException("删除用户时出现异常,请重试！"); } } /** * 更新用户 * @param user 用户 */ public void updateUser(User user)throws Exception { try { User usertemp = userDao.get(user.getId()); usertemp.setAddress(user.getAddress()); usertemp.setEmail(user.getEmail()); usertemp.setLoginName(user.getLoginName()); usertemp.setName(user.getName()); usertemp.setPass(user.getPass()); usertemp.setPhone(user.getPhone()); userDao.update(usertemp); } catch (Exception e) { e.printStackTrace(); throw new Exception("修改用户信息异常"); } } }