基于struts2 的网络U盘

package com.zys.action; import java.io.File; import java.util.ArrayList; import java.util.List; import org.apache.commons.io.FileUtils; import com.opensymphony.xwork2.ActionSupport; import com.opensymphony.xwork2.ModelDriven; import com.zys.biz.FileBiz; import com.zys.entity.FileBean; import com.zys.entity.User; import com.zys.util.Config; import com.zys.util.FileUtil; import com.zys.util.MD5; import com.zys.util.MyContext; public class FileAction extends ActionSupport { FileBean file = new FileBean(); private File ff[]; private String ffFileName[] ; private FileBiz biz = new FileBiz(); private String fetch; public String upload() throws Exception { User user = (User) MyContext.getSession().get("user"); String path = Config.mainDir +user.getUsername(); //上传前确认用户是否添加了要上传的文件 if(ff==null){ MyContext.getRequest().put("message", "没有选择文件！！请选择文件后再上传。。。"); return INPUT; } long limitSize = 0; for (int i = 0; i < ff.length; i++) { File newfile = new File(path, FileUtil.rename(ffFileName[i]));//重命名 //上传前先确认是否重复上传 boolean canupload= biz.isExist(ffFileName[i], Integer.parseInt(user.getUserid())); if(canupload==true){ MyContext.getRequest().put("message", "该文件已存在网盘,请勿重复上传！"); return INPUT; } limitSize+= ff[i].length(); if(limitSize>getUploadSize(user)){//用户上传文件大小大于对应权限能上传的最大限制 MyContext.getRequest().put("message", "上传文件大小超过限制！！"); return INPUT; } if(limitSize>getCanUseSize(user)){ MyContext.getRequest().put("message", "磁盘剩余空间不足！！"); return INPUT; } FileUtils.copyFile(ff[i],newfile); //文件上传成功更新md5map Config.putMap(newfile); file.setUserid(user.getUserid()); file.setFilename(ffFileName[i]); file.setFilesize(ff[i].length()+""); file.setRealpathname(newfile.getAbsolutePath()); file.setFetchcode(MD5.create(newfile.getAbsolutePath())); int is = biz.upload(file); if(is<=0){ MyContext.getRequest().put("message", "文件上传存储到数据库失败！"); return INPUT; } } return SUCCESS; } /** * 获得用户磁盘剩余空间 * @param user */ private long getCanUseSize(User user) { String path= FileUtil.getSaveDir()+user.getUsername(); long c = FileUtil.countSize(path); return getTotalSize(user)-c; } /** * 返回用户单次允许上传文件大小 * @param user * @return */ private long getUploadSize(User user) { if(user.getUsertype()== Config.USER_TYPE_VIP){ return Config.maxSize_vip*1024*1024; }else{ return Config.maxSize_user*1024*1024; } } /** * 返回用户磁盘总大小 * @param user * @return */ private long getTotalSize(User user) { if(user.getUsertype()== Config.USER_TYPE_VIP){ return Config.container_vip*1024*1024; }else{ return Config.container_user*1024*1024; } } /** * 用户已上传文件列表 * @return */ public String list(){ System.out.println("============="); User user=(User) MyContext.getSession().get("user"); if(user==null){ MyContext.getRequest().put("message", "未登录,没有权限访问！"); return INPUT; } List<FileBean> filelist = new ArrayList<FileBean>(); filelist = biz.list(Integer.parseInt(user.getUserid())); if(filelist==null){ MyContext.getRequest().put("message", "没有以上传文件"); return INPUT; } System.out.println(filelist.size()); MyContext.getRequest().put("filelist", filelist); return SUCCESS; } public String delete(){ FileBean wfile= biz.getFile(fetch); String realpath = wfile.getRealpathname(); System.out.println(realpath+"删除文件的真实路径"); File file = new File(realpath); boolean isFileDel = file.delete(); if(isFileDel){ int isDbDel = biz.delete(fetch); if(isDbDel>0){ //删除成功后将映射表中数据删除 Config.md5Map.remove(fetch); return SUCCESS; }else{ MyContext.getRequest().put("message", "文件从数据库删除失败，可能无此条数据！"); return INPUT; } }else{ MyContext.getRequest().put("message", "文件从网盘删除失败！可能文件不存在"); return INPUT; } } public File[] getFf() { return ff; } public void setFf(File[] ff) { this.ff = ff; } public String[] getFfFileName() { return ffFileName; } public void setFfFileName(String[] ffFileName) { this.ffFileName = ffFileName; } public String getFetch() { return fetch; } public void setFetch(String fetch) { this.fetch = fetch; } }