messagesaction.java

java开发的经典框架assh,做的一个系统！

// Created by MyEclipse Struts
// XSL source (default):
// platform:/plugin/com.genuitec.eclipse.cross.easystruts.eclipse_4.0.1/xslt/JavaClass.xsl

package com.caolulu.assh.web.action;

import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.PrintStream;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

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

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
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 com.caolulu.assh.bean.Messages;
import com.caolulu.assh.comm.Constant;
import com.caolulu.assh.comm.PageList;
import com.caolulu.assh.comm.Pages;
import com.caolulu.assh.exception.CommunityHandleException;
import com.caolulu.assh.service.MessagesService;
import com.caolulu.assh.web.form.MessagesForm;

/**
 * MyEclipse Struts Creation date: 03-27-2006
 * 
 * XDoclet definition:
 * 
 * @struts.action path="/messages" name="messagesForm" scope="request"
 *                validate="true"
 */
public class MessagesAction extends BaseDispatchAction {

  // --------------------------------------------------------- Instance
  // Variables
  private static final Log logger = LogFactory.getLog(MessagesAction.class);

  private MessagesService messagesService;

  // --------------------------------------------------------- Methods

  public MessagesService getMessagesService() {

    return messagesService;
  }

  public void setMessagesService(MessagesService messagesService) {

    this.messagesService = messagesService;
  }

  /**
   * Method execute
   * 
   * @param mapping
   * @param form
   * @param request
   * @param response
   * @return ActionForward
   */
  public ActionForward findMessagesByChangCiId(ActionMapping mapping,
          ActionForm form, HttpServletRequest request,
          HttpServletResponse response) {

    MessagesForm messagesForm = (MessagesForm) form;
    long changCiId = messagesForm.getChangCiId();
    int page = messagesForm.getPage();
    if (page == 0)
      page = +1;
    Pages pages = new Pages(this.getLocale(request));
    pages.setPage(page);
    pages.setPerPageNum(3);
    pages.setStyle(6);
    pages.setFileName("messages.do?method=findMessagesByChangCiId&changCiId="
            + changCiId);
    PageList pageList = this.getMessagesService().findObjectByChangCiId(pages,
            changCiId);
    request.setAttribute("pageList", pageList);
    request.setAttribute("changCiId", "" + changCiId);
    request.setAttribute("page", "" + page);
    return mapping.findForward("messagesList");

  }

  public ActionForward createMessages(ActionMapping mapping, ActionForm form,
          HttpServletRequest request, HttpServletResponse response) {

    MessagesForm messagesForm = (MessagesForm) form;
    long changCiId = messagesForm.getChangCiId();
    String content = messagesForm.getContent().trim();
    String mobileNumber = messagesForm.getMobileNumber().trim();
    Messages messages = new Messages();
    messages.setBusinessLine(1);
    messages.setCreateTime(System.currentTimeMillis());
    messages.setContent(content);
    messages.setMobileNumber(mobileNumber);
    messages.setChangCiId(changCiId);
    try {
      this.getMessagesService().createObject(messages);
      return this.toMessage("1", "创建留言成功", request, mapping);
    } catch (CommunityHandleException e) {
      logger.debug("createMessages", e);
      return this.toMessage("0", "创建留言失败", request, mapping);
    }
  }

  public ActionForward deleteMessages(ActionMapping mapping, ActionForm form,
          HttpServletRequest request, HttpServletResponse response) {

    MessagesForm messagesForm = (MessagesForm) form;
    long messageId = messagesForm.getMessageId();
    try {
      this.getMessagesService().removeObjectById(messageId);
      return this.toMessage("1", "删除留言成功", request, mapping);
    } catch (CommunityHandleException e) {
      logger.debug("deleteMessages", e);
      return this.toMessage("0", "删除留言失败", request, mapping);
    }
  }

  public ActionForward modifyMessages(ActionMapping mapping, ActionForm form,
          HttpServletRequest request, HttpServletResponse response) {

    MessagesForm messagesForm = (MessagesForm) form;
    long messageId = messagesForm.getMessageId();
    String mobileNumber = messagesForm.getMobileNumber();
    String content = messagesForm.getContent();
    Messages messages = this.getMessagesService().findObjectById(messageId);
    if (messages == null) {
      return this.toMessage("0", "无此留言", request, mapping);
    }
    messages.setMobileNumber(mobileNumber);
    messages.setContent(content);
    try {
      this.getMessagesService().createObject(messages);
      return this.toMessage("1", "修改留言成功", request, mapping);
    } catch (CommunityHandleException e) {
      logger.debug("modifyMessages", e);
      e.printStackTrace();
      return this.toMessage("0", "修改留言失败", request, mapping);
    }
  }

  public ActionForward clearMessagesByChangCiId(ActionMapping mapping,
          ActionForm form, HttpServletRequest request,
          HttpServletResponse response) {

    MessagesForm messagesForm = (MessagesForm) form;
    long changCiId = messagesForm.getChangCiId();
    try {
      this.getMessagesService().removeObjectByChangCiId(changCiId);
      return this.toMessage("1", "清除本场留言成功", request, mapping);
    } catch (CommunityHandleException e) {
      logger.debug("modifyMessages", e);
      e.printStackTrace();
      return this.toMessage("0", "清除本场留言失败", request, mapping);
    }
  }

  public ActionForward toExcel(ActionMapping mapping, ActionForm form,
          HttpServletRequest request, HttpServletResponse response) {

    MessagesForm messagesForm = (MessagesForm) form;
    long changCiId = messagesForm.getChangCiId();
    String changCiNo = messagesForm.getChangCiNo();
    DateFormat dt = new SimpleDateFormat(" yyyy年MM月dd日 HH:mm:ss");
    List list = this.getMessagesService().findObjectByChangCiId(changCiId);

    FileOutputStream fileOutputStream;
    PrintStream out = null;
    try {
      fileOutputStream = new FileOutputStream(Constant.ROOTPATH
              + "\\turnxml\\messages.xls");
      out = new PrintStream(fileOutputStream, true, "GBK");
    } catch (Exception e) {
      e.printStackTrace();
      logger.debug("toExcel", e);
      return this.toMessage("0", "转EXCEL失败", request, mapping);
    }

    StringBuffer title = new StringBuffer();
    title.append("手机号码").append("" + ((char) ((int) 0x09)));
    title.append("场次编号").append("" + ((char) ((int) 0x09)));
    title.append("上行时间").append("" + ((char) ((int) 0x09)));
    title.append("业务线").append("" + ((char) ((int) 0x09)));
    title.append("留言内容").append("\n");
    out.println(title.toString());
    for (int i = 0, n = list.size(); i < n; i++) {
      Messages messages = (Messages) list.get(i);
      StringBuffer sb = new StringBuffer();
      sb.append(messages.getMobileNumber()).append("" + ((char) ((int) 0x09)));
      sb.append(changCiNo).append("" + ((char) ((int) 0x09)));
      sb.append(dt.format(new Date(messages.getCreateTime()))).append(
              "" + ((char) ((int) 0x09)));
      sb.append(Constant.BL_MESSAGES[messages.getBusinessLine()]).append(
              "" + ((char) ((int) 0x09)));
      sb.append(messages.getContent());
      out.println(sb.toString());
      out.flush();
    }
    out.close();

    return this.toMessage("1", "转EXCEL成功", request, mapping);

  }

  public ActionForward toText(ActionMapping mapping, ActionForm form,
          HttpServletRequest request, HttpServletResponse response) {

    MessagesForm messagesForm = (MessagesForm) form;
    long changCiId = messagesForm.getChangCiId();
    List list = this.getMessagesService().findObjectByChangCiId(changCiId);
    FileOutputStream fileOutputStream;
    PrintStream out = null;
    try {
      fileOutputStream = new FileOutputStream(Constant.ROOTPATH
              + "\\turnxml\\messages.txt");
      out = new PrintStream(fileOutputStream, true, "GBK");
    } catch (Exception e) {
      e.printStackTrace();
      logger.debug("toText", e);
      return this.toMessage("0", "转TEXT失败", request, mapping);
    }

    for (int i = 0, n = list.size(); i < n; i++) {
      Messages messages = (Messages) list.get(i);
      StringBuffer sb = new StringBuffer();
      sb.append(messages.getMobileNumber()).append(",");
      out.println(sb.toString());
      out.flush();
    }
    out.close();
    return this.toMessage("1", "转TEXT成功", request, mapping);
  }

}