package com.mvc.service.impl;import java.util.List;import com.mvc.common.exception.MessageServiceException;import com.mvc.common.transaction.HibernateTransaction;import com.mvc.common.util.BeanFactory;import com.mvc.dao.IMessageDao;import com.mvc.dao.bean.JinfengMemberinfo;import com.mvc.dao.bean.JinfengMessage;import com.mvc.dao.bean.JinfengStudents;import com.mvc.service.IMessageService;public class MessageServiceImpl implements IMessageService {	private IMessageDao messageDao =(IMessageDao) BeanFactory.getBean("messageDao");	//	 刪除客戶	public void delMemberinfo(JinfengMemberinfo memberinfo) throws MessageServiceException {		HibernateTransaction ht=new HibernateTransaction();		ht.beginTransaction();		try {			messageDao.delMemberinfo(memberinfo);			ht.commit();		} catch (Exception e) {			ht.rollback();			e.printStackTrace();			throw new MessageServiceException(e.getMessage());		}					}//刪除信息	public void delMessage(JinfengMessage message) throws MessageServiceException {		HibernateTransaction ht=new HibernateTransaction();		ht.beginTransaction();		try {			messageDao.delMessage(message);			ht.commit();		} catch (Exception e) {			ht.rollback();			e.printStackTrace();			throw new MessageServiceException(e.getMessage());		}					}//刪除學員	public void delStudents(JinfengStudents studnet) throws MessageServiceException {		HibernateTransaction ht=new HibernateTransaction();		ht.beginTransaction();		try {			messageDao.delStudents(studnet);			ht.commit();		} catch (Exception e) {			ht.rollback();			e.printStackTrace();			throw new MessageServiceException(e.getMessage());		}					}//根據(jù)id查找信息	public JinfengMessage findMessageById(Long id) throws MessageServiceException {		HibernateTransaction ht=new HibernateTransaction();		ht.beginTransaction();		try {			JinfengMessage messageid=messageDao.findMessageById(id);			if(messageid==null){				throw new Exception("您要查詢的信息不存在!!");			}			ht.commit();			return messageid;		} catch (Exception e) {			ht.rollback();			e.printStackTrace();			throw new MessageServiceException(e.getMessage());		}	}//根據(jù)receiver(收件人)查詢新信息	public List findNewMessages(String nickname) throws MessageServiceException {		HibernateTransaction ht=new HibernateTransaction();		ht.beginTransaction();		try {			List list=messageDao.findNewMessages(nickname);			if(list==null){				throw new Exception("您暫時沒有新信息!!");							}			ht.commit();			return list;		} catch (Exception e) {			e.printStackTrace();			ht.rollback();			throw new MessageServiceException(e.getMessage());		}	}//	 根據(jù)receiver查詢已接收到的信息	public List findReMessages(String nickname) throws MessageServiceException {		HibernateTransaction ht=new HibernateTransaction();		ht.beginTransaction();		try {			List list=messageDao.findReMessages(nickname);			if(list==null){				throw new Exception("您到現(xiàn)在為止收到任何人發(fā)的信息!!");			}			ht.commit();			return list;		} catch (Exception e) {			e.printStackTrace();			ht.rollback();			throw new MessageServiceException(e.getMessage());		}		}//	 根據(jù)sender(發(fā)件人)查詢已發(fā)送的信息	public List findSeMessages(String nickname) throws MessageServiceException {		HibernateTransaction ht=new HibernateTransaction();		ht.beginTransaction();		try {			List list=messageDao.findSeMessages(nickname);			if(list==null){				throw new Exception("您沒有給任何人發(fā)過信息");			}			ht.commit();			return list;		} catch (Exception e) {			e.printStackTrace();			ht.rollback();			throw new MessageServiceException(e.getMessage());		}	}	public int findUnreadedMessagesNumber(String nickname) throws MessageServiceException{		HibernateTransaction ht=new HibernateTransaction();		ht.beginTransaction();		try {			int number=messageDao.findUnreadedMessagesNumber(nickname);			ht.commit();			return number;		} catch (Exception e) {			e.printStackTrace();			ht.rollback();			throw new MessageServiceException(e.getMessage());		}	}	//發(fā)送信息	public String sendMessage(JinfengMessage mess) throws MessageServiceException {		HibernateTransaction ht=new HibernateTransaction();		ht.beginTransaction();		String s="";		try {			//System.out.println("aaaaaaaaaaaaa");			//System.out.println("messageDao=="+messageDao);			messageDao.saveMessage(mess);			s="發(fā)送成功!!";			ht.commit();		} catch (Exception e) {			e.printStackTrace();			ht.rollback();					}		return s;			}	/*public JinfengMessage findMessageByid(Long id) throws MessageServiceException {		HibernateTransaction ht=new HibernateTransaction();		ht.beginTransaction();		try {			JinfengMessage messageby=messageDao.findMessageById(id);			ht.commit();			return messageby;		} catch (Exception e) {			e.printStackTrace();ht.rollback();			throw new MessageServiceException(e.getMessage());		}			}*/	}