Java上传下载，支持单个、批量

chinarocky

主要用到的包
import org.apache.commons.io.FileUtils;
import org.apache.commons.io.filefilter.IOFileFilter;

上传，下载，删除

1. /**
   
2.      * 上传文件到临时目录
   
3.      * {模块名}\{日期}\{用户id}\{文件名}
   
4.      *
   
5.      * @param model
   
6.      * @param is
   
7.      * @param header
   
8.      * @return
   
9.      * @throws IOException
   
10.      */
    
11.     @POST
    
12.     @Path("{model}")
    
13.     @Consumes(MediaType.MULTIPART_FORM_DATA)
    
14.     public String uploadFile(@PathParam("model") String model,
    
15.                              @FormDataParam("file") InputStream is,
    
16.                              @FormDataParam("file") FormDataContentDisposition header) throws IOException {
    
17.         Integer createEmpId = 99001; //todo 当前登录人ID
    
18.         String fileName = new String(header.getFileName().getBytes("ISO8859_1"), "utf-8");
    
19.         String afterPath = model + "/" + datedir + "/" + createEmpId.toString() + "/" + fileName;
    
20.         String path = tempdir + afterPath;
    
21.         File file = new File(path);
    
22.         FileUtils.forceMkdir(file.getParentFile());
    
23.         file.createNewFile();
    
24.         OutputStream out = new FileOutputStream(file);
    
25.         try {
    
26.             ByteStreams.copy(is, out);
    
27.         } finally {
    
28.             IOUtils.closeQuietly(is);
    
29.             IOUtils.closeQuietly(out);
    
30.         }
    
31.         //moveFile(model, header.getFileName(), "project", 1);
    
32.         return fileName;
    
33.     }
    
34. 
    
35.     /**
    
36.      * 批量上传
    
37.      *
    
38.      * @param model
    
39.      * @param form
    
40.      * @return list
    
41.      * @throws IOException
    
42.      */
    
43.     @POST
    
44.     @Path("/more/{model}")
    
45.     @Consumes(MediaType.MULTIPART_FORM_DATA)
    
46.     public String uploadMoreFile(@PathParam("model") String model, FormDataMultiPart form) throws IOException {
    
47.         String str = "";
    
48.         List<FormDataBodyPart> l = form.getFields("file");
    
49.         for (FormDataBodyPart p : l) {
    
50.             InputStream is = p.getValueAs(InputStream.class);
    
51.             FormDataContentDisposition detail = p.getFormDataContentDisposition();
    
52.             str += uploadFile(model, is, detail) + "/";
    
53.         }
    
54.         return str;
    
55.     }
    
56. /**
    
57.      * 根据文件id下载文件
    
58.      */
    
59.     @GET
    
60.     @Path("download/{id}")
    
61.     @Produces(MediaType.APPLICATION_OCTET_STREAM)
    
62.     public Response download(@NotNull @PathParam("id") Integer id) {
    
63.         Integer createEmpId = 99001; //todo 当前登录人ID
    
64.         ZGJAttachment attachment = ZGJAttachment.withFinder().byId(id);
    
65.         if (attachment != null && attachment.createEmpid.equals(createEmpId)) {
    
66.             String path = attachment.storePath;
    
67.             return Response.ok(new File(attachments + path))
    
68.                     .header("Content-Disposition", "attachment;filename=" + attachment.fileName)
    
69.                             //.type(DefaultMediaTypePredictor.CommonMediaTypes.getMediaTypeFromFileName(path))
    
70.                     .build();
    
71.         } else return null;
    
72.     }
    
73. 
    
74. /**
    
75.      * 删除临时目录中 最后更新日期为系统日期前一天的所有内容
    
76.      */
    
77. 
    
78.     public void deleteTemplFilesBeforeToday() {
    
79.         Akka.system().scheduler().scheduleOnce(Duration.Zero(),
    
80.                 new Runnable() {
    
81.                     public void run() {
    
82.                         File tempFile = new File(tempdir);
    
83.                         Collection<File> files = FileUtils.listFilesAndDirs(tempFile, new IOFileFilter() {
    
84.                             public boolean accept(File dir) {
    
85.                                 return true;
    
86.                             }
    
87. 
    
88.                             public boolean accept(File dir, String name) {
    
89.                                 File f = new File(dir, name);
    
90.                                 if (f.isDirectory())
    
91.                                     return true;
    
92.                                 else
    
93.                                     return false;
    
94.                             }
    
95.                         }, new IOFileFilter() {
    
96.                             public boolean accept(File dir) {
    
97.                                 return dir.isDirectory();
    
98.                             }
    
99. 
    
100.                             public boolean accept(File dir, String name) {
     
101.                                 File f = new File(dir, name);
     
102.                                 if (f.isDirectory())
     
103.                                     return true;
     
104.                                 else
     
105.                                     return false;
     
106.                             }
     
107.                         });
     
108.                         Calendar cldr = Calendar.getInstance();
     
109.                         cldr.add(Calendar.DATE, -1);
     
110.                         long yesterday = cldr.getTime().getTime();
     
111.                         String yesterdayDate = new SimpleDateFormat("yyyyMMdd").format(yesterday);
     
112.                         for (File f : files) {
     
113.                             if (f.exists()) {
     
114.                                 if (f.isFile() && FileUtils.isFileOlder(f, yesterday))
     
115.                                     FileUtils.deleteQuietly(f);
     
116.                                 else if (f.isDirectory() && f.getName().equals(yesterdayDate)) {
     
117.                                     try {
     
118.                                         FileUtils.deleteDirectory(f);
     
119.                                     } catch (IOException e) {
     
120.                                         e.printStackTrace();
     
121.                                     }
     
122.                                 } else logger().debug("删除临时文件未知错误！");
     
123.                             }
     
124.                         }
     
125.                     }
     
126.                 }, Akka.system().dispatcher());
     
127.     }
     

复制代码