1002ee6cd731001d139f992bfca89756

客户关系管理系统主要管理新老客户的一些信息并可以发现潜在客户

/**
 * 
 */
package com.qrsx.qrsxcrm.action;

import java.util.List;

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

import org.apache.commons.beanutils.BeanUtils;
import org.apache.struts.action.ActionErrors;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;

import com.qrsx.qrsxcrm.dao.AnnouncementDAO;
import com.qrsx.qrsxcrm.dao.UserDAO;
import com.qrsx.qrsxcrm.form.AnnouncementForm;
import com.qrsx.qrsxcrm.model.Announcement;
import com.qrsx.qrsxcrm.model.User;
import com.qrsx.qrsxcrm.web.Pager;

/**
 * @author Administrator
 * 
 */
public class AnnouncementAction extends BaseDispatchAction {

	/**
	 * 创建或者更新一个公告
	 * 
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return
	 * @throws Exception
	 */
	@SuppressWarnings("unchecked")
	public ActionForward save(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response)
			throws Exception {
		ActionErrors errors = form.validate(mapping, request);
		if (!errors.isEmpty()) {
			System.out.println("--------执行0------");
			saveErrors(request, errors);
			return edit(mapping, form, request, response);
		}
		AnnouncementForm announcementForm = (AnnouncementForm) form;
		Announcement announcement = new Announcement();
		BeanUtils.copyProperties(announcement, form);
		
		System.out.println(announcement.getUserId());// 打印userId
		AnnouncementDAO announcementDAO = new AnnouncementDAO(
				(Class<Announcement>) announcement.getClass());
		UserDAO userDAO = new UserDAO(User.class);
		User user = new User();
		user = (User) userDAO.findById(user.getClass(), (String) request
				.getSession().getAttribute("userId"));
		announcement.setUser(user);
		if (announcementForm.getId() == null
				|| announcementForm.getId().trim().length() == 0) {
			System.out.println("没有ID");

			announcementDAO.create(announcement);
			saveMessage(request, "announcementForm.added", announcement
					.getPostTitle());
		} else {
			announcementDAO.update(announcement);
			saveMessage(request, "announcementForm.updated", announcement
					.getPostTitle());
		}
		System.out.println(announcement.getBeginTime());
		return mapping.findForward("success");
	}

	/**
	 * 进入编辑页面
	 * 
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return
	 * @throws Exception
	 */
	@SuppressWarnings("unchecked")
	public ActionForward edit(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response)
			throws Exception {
		String id = request.getParameter("id");
		Announcement announcement = new Announcement();
		AnnouncementForm announcementForm = (AnnouncementForm) form;
		String userId = (String) request.getSession().getAttribute("userId");
		User user = new User();
		UserDAO userDAO = new UserDAO(User.class);
		user = (User) userDAO.findById(user.getClass(), userId);
		request.setAttribute("userName", user.getUserName());
		if (id != null && id.trim().length() > 0) {
			AnnouncementDAO announcementDAO = new AnnouncementDAO(
					(Class<Announcement>) announcement.getClass());
			announcement = (Announcement) announcementDAO.findById(announcement
					.getClass(), id);

			// request.setAttribute("userName", announcement.getUser()
			// .getUserName());
			// System.out.println("!!!!!" + announcementForm.getUserId());
			if (announcement != null) {

				BeanUtils.copyProperties(form, announcement);
				String end = String.valueOf(announcement.getEndTime());
				end = end.substring(0, 10);
				announcementForm.setEndTime(end);

				String begin = String.valueOf(announcement.getBeginTime());
				begin = begin.substring(0, 10);
				announcementForm.setBeginTime(begin);
			}
		} else {
			String date = System.currentTimeMillis();
			announcementForm.setBeginTime(getCalendar());
		}
		// announcementForm.setUser(user);
		return mapping.findForward("edit");
	}

	/**
	 * 删除公告
	 * 
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return
	 * @throws Exception
	 */
	@SuppressWarnings("unchecked")
	public ActionForward delete(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response)
			throws Exception {
		String id = request.getParameter("id");
		Announcement announcement = new Announcement();
		System.out.println("--测试2--");
		if (id != null && id.trim().length() > 0) {
			System.out.println("--测试--");
			AnnouncementDAO announcementDAO = new AnnouncementDAO(
					(Class<Announcement>) announcement.getClass());
			announcement = (Announcement) announcementDAO.findById(announcement
					.getClass(), id);
			announcementDAO.delete(announcement);
			saveMessage(request, "announcementForm.deleted", announcement
					.getPostTitle());
		}
		return mapping.findForward("success");
	}

	/**
	 * 显示公告
	 * 
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return
	 * @throws Exception
	 */
	@SuppressWarnings("unchecked")
	public ActionForward list(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response)
			throws Exception {
		Announcement announcement = new Announcement();
		BeanUtils.copyProperties(announcement, form);
		AnnouncementDAO announcementDAO = new AnnouncementDAO(
				Announcement.class);
		UserDAO userDAO = new UserDAO(User.class);
		List results = announcementDAO.list(announcement);// 得到总数据
		List userResults = userDAO.findAll("from User");
		request.setAttribute("users", userResults);
		
		String userId = (String)request.getSession().getAttribute("userId");
		announcement.setUserId(userId);
		// AnnouncementDAO announcementDAO = new AnnouncementDAO(
		// (Class<Announcement>) announcement.getClass());
		// System.out.println("---执行5---");
		// List<Announcement> list = announcementDAO.list(announcement);
		// System.out.println("---执行6---");
		// request.setAttribute("announcements", list);
		try {
			Pager pager = null;
			
			pager = new Pager(); // 构造分页对象
			int totalRows = results.size(); // 得到总数据量
			pager.init(totalRows);

			if (request.getParameter("action") != null) {
				pager.doAction(request.getParameter("action").toString());
			}
			// 使用分页标签的方法
			List list = announcementDAO.findAllByPage(announcement, (pager
					.getCurrentPage() - 1)
					* pager.getPageSize(), pager.getPageSize());
			request.getSession().setAttribute("pagerstruts", pager);
			request.setAttribute("announcements", list);
		} catch (Exception e) {
			e.printStackTrace();
		}

		return mapping.findForward("list");
	}
}