movieaction.java

一个用struts tiles的在线影院web系统

package com.eline.vod.struts;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Calendar;
import java.util.GregorianCalendar;

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

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.apache.struts.upload.FormFile;

import com.blue.web.common.util.AppKeys;
import com.blue.web.common.util.AppLogger;
import com.blue.web.common.util.AppSettings;
import com.blue.web.common.util.StringUtils;
import com.eline.vod.client.Movies;
import com.eline.vod.exceptions.ResourceException;
import com.eline.vod.model.Movie;
public class MovieAction extends Action {
    private static final int ACTION_CREATE = 0;
    private static final int ACTION_UPDATE = 1;
    private static final int ACTION_DELETE = 2;
    /**
     * @param mapping
     * @param form
     * @param request
     * @param response
     * @return
     * @throws Exception
     */
    public ActionForward execute(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
        System.out.println("hello, MovieAction.execute()");
        boolean isOK = false;
        int webAction = StringUtils.getInt(request.getParameter("webAction"), -1);
        if (form instanceof MovieForm) {
        	MovieForm actionForm = (MovieForm) form;
            if (webAction == ACTION_CREATE) {
                isOK = doCreate(actionForm, request, response);
            } else if (webAction == ACTION_UPDATE) {
                isOK = doUpdate(actionForm, request, response);
            } else if (webAction == ACTION_DELETE) {
                isOK = doDelete(actionForm, request, response);
            }
        }
        String strMsg = isOK ? "操作成功" : "操作失败";
        request.setAttribute("message", strMsg);
        return mapping.findForward(isOK ? "success" : "failure");
    }
    /**
     * @param form
     * @param request
     * @param response
     * @return
     * @throws Exception
     */
    private boolean doCreate(MovieForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
        try {
        	Movie item = new Movie();
			item.setTitle(form.getTitle());
			item.setOriginName(form.getOriginName());
			item.setPublishDate(form.getPublishDate());
			item.setDirector(form.getDirector());
			item.setPlaywright(form.getPlaywright());
			item.setActors(form.getActors());
			item.setRecommend(form.getRecommend());
			item.setIntro(form.getIntro());
			String filePath = uploadImageFile(form.getFileImage());
            item.setOrigionFile(filePath == null ? "" : filePath);
			item.setAuthor(form.getAuthor());
			item.setUserLastUpdate(form.getUserLastUpdate());
			item.setAccessCount(form.getAccessCount());
			item.setApproved(form.isApproved());
			item.setArea(form.getArea());
        	Movies nh = new Movies();
            nh.createMovie(item);
        } catch (Exception e) {
            AppLogger.error("MovieAction.doCreate() Exception: " + e.getMessage());
            return false;
        }
        return true;
    }
    /**
     * @param form
     * @param request
     * @param response
     * @return
     * @throws Exception
     */
    private boolean doUpdate(MovieForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
        Movies helper = new Movies();
        try {
            Movie item = helper.getMovie(form.getIndexID());
            item.setTitle(form.getTitle());
            item.setOriginName(form.getOriginName());
            item.setPublishDate(form.getPublishDate());
			item.setDirector(form.getDirector());
			item.setPlaywright(form.getPlaywright());
			item.setActors(form.getActors());
			item.setRecommend(form.getRecommend());
			item.setIntro(form.getIntro());
			String filePath = uploadImageFile(form.getFileImage());
			item.setOrigionFile(filePath != null ? filePath : item.getOrigionFile());
            // item.setOrigionFile(filePath == null ? "" : filePath);
			item.setAuthor(form.getAuthor());
			item.setUserLastUpdate(form.getUserLastUpdate());
			item.setAccessCount(form.getAccessCount());
			item.setApproved(form.isApproved());
			item.setArea(form.getArea());
            Movies nh = new Movies();
            nh.updateMovie(item);
        } catch (Exception e) {
            AppLogger.error("MovieAction.doUpdate() Exception: " + e.getMessage());
            return false;
        }
        return true;
    }
    /**
     * @param form
     * @param request
     * @param response
     * @return
     * @throws Exception
     */
    private boolean doDelete(MovieForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {
        String[] strIdList = form.getDeletes().split(";");
        Movies nh = new Movies();
        boolean returnValue = true;
        // parse id(s) and delete them.
        for (int i = 0; i < strIdList.length; i++) {
            try {
                if (strIdList[i] == null || strIdList[i].length() < 1) continue;
                int itemId = Integer.parseInt(strIdList[i]);
                nh.deleteItem(itemId);
            } catch (NumberFormatException e) {
                AppLogger.error("NumberFormatException: MovieAction.doDelete() - parse id error, contiune.");
                continue;
            } catch (ResourceException e) {
                AppLogger.error("ResourceException: MovieAction.doDelete() - " + e.getMessage());
                returnValue = false;
            }
        }
        return returnValue;
    }
    
    private String uploadImageFile(FormFile file) {
        if (file == null || file.getFileSize() < 1) return null;
        try {
            InputStream stream = file.getInputStream();
            // 获取文件扩展名并判断其有效性
            String[] sp = file.getFileName().split("\\.");
            String ext = null;
            if (sp.length > 1) {
                ext = sp[sp.length - 1].toLowerCase();
                if (!ext.equals("jpg") && !ext.equals("gif") && !ext.equals("png") && !ext.equals("bmp")) ext = null;
            }
            if (ext == null) return null;
            // 生成上传目录，如果不存在则创建
            GregorianCalendar calendar = new GregorianCalendar();
            String virtualPath = AppSettings.getInstance().getProperty(AppKeys.UPLOAD_ROOT) + "/pictures/" + calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1) + "-" + calendar.get(Calendar.DAY_OF_MONTH);
            String physicalPath = this.getServlet().getServletContext().getRealPath(virtualPath);
            System.out.println("*************************"+physicalPath);
            File dir = new File(physicalPath);
            if (!dir.exists()) dir.mkdir();
            // 生成文件名
            String fileName = "pic_" + calendar.get(Calendar.HOUR) + calendar.get(Calendar.MINUTE) + calendar.get(Calendar.SECOND) + calendar.get(Calendar.MILLISECOND) + "." + ext;
            physicalPath = this.getServlet().getServletContext().getRealPath(virtualPath + "/" + fileName);
            OutputStream bos = new FileOutputStream(physicalPath);
            int bytesRead = 0;
            byte[] buffer = new byte[8192];
            while ((bytesRead = stream.read(buffer, 0, 8192)) != -1) {
                bos.write(buffer, 0, bytesRead);
            }
            bos.close();
            stream.close();
            // 返回相对路径名
            String filePath = "/" + calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1) + "-" + calendar.get(Calendar.DAY_OF_MONTH) + "/" + fileName;
            AppLogger.info("MovieAction.uploadImageFile() The file has been written to \"" + filePath + "\"");
            return filePath;
        } catch (FileNotFoundException e) {
            AppLogger.error("MovieAction.uploadImageFile() FileNotFoundException:" + e.getMessage());
            return null;
        } catch (IOException e) {
            AppLogger.error("MovieAction.uploadImageFile() IOException:" + e.getMessage());
            return null;
        }
    }
}