sendallaction.java

企业内部邮件系统（初级开发）企业内部邮件系统（初级开发）企业内部邮件系统（初级开发）

/*
 * Generated by MyEclipse Struts
 * Template path: templates/java/JavaClass.vtl
 */
package com.struts.action;

import java.util.Date;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Set;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;

import com.hibernate.HibernateUtils;
import com.jopo.Message;
import com.jopo.User;

public class SendallAction extends Action {

	public ActionForward execute(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response)
			throws Exception {
		
		Message message = (Message) form;

		int sendtoid = message.getSendtoid();
		System.out.println(sendtoid + "...............sendall1.............");
		String title = message.getTitle();
		String content = message.getContent();

		System.out.println(title + "................sendall2...............");
		HttpSession session = request.getSession(false);
		String username = (String) session.getAttribute("username");
		int userid = this.getuserId(username);

		sendOneMessage(userid, sendtoid, title, content);

		HttpSession session2 = request.getSession();
		session2.setAttribute("title", title);
		return mapping.findForward("sendsuccess");

		
	}

	public void sendOneMessage(int userid, int sendid, String title,
			String content) {
		Session session = HibernateUtils.getSession();

		Message message = new Message();
		message.setTitle(title);
		message.setContent(content);
		message.setSentDate(new Date());
		message.setSendtoid(sendid);
		User from = (User) session.load(User.class, userid);
		message.setSentFrom(from);

		User to1 = (User) session.load(User.class, sendid);

		Set tolist = new HashSet();

		tolist.add(to1);

		message.setReceiveList(tolist);

		Transaction tx = session.beginTransaction();
		session.save(message);
		tx.commit();

		session.close();
	}

	public static int getuserId(String username) {
		Session session = HibernateUtils.getSession();
		int id = 0;

		Query query = session.createQuery("from User where username='"
				+ username + "'");

		Iterator it = query.list().iterator();

		while (it.hasNext()) {
			User user = (User) it.next();
			id = user.getId();
		}

		System.out.println(id + "+++++++++++++++++++++++++++++++++++==");
		session.close();
		return id;

	}

}