下载附件

1、设置setContentType为application/x-msdownload
2、设置Content-Disposition为附件形式并指定文件名称attachment;filename=contact.csv
3、根据文件路径创建输入流,response获取输出流
4、写入到输出流
5、删除缓存文件
6、关闭流

@RequestMapping(value = "/exportContact", method = RequestMethod.GET)
private void exportContact(HttpServletRequest request, HttpServletResponse response) {

    DBObject query = new BasicDBObject();
    String loginEmail = null;
    DataOutputStream os = null;
    InputStream is = null;
    String contactPath = null;
    try {
        //TODO:登录人信息,目前从配置文件中读取登陆人邮箱
        loginEmail = PropertyUtil.getMailProperties().getProperty("mail.email");
        query.put("emailAccount", loginEmail);

        //取得收件箱所有数据
        List<DBObject> list = wmPerService.getData(WmPerConstant.MONGODB_COLLECTION_CONTACT, query);

        List<String[]> contacts = new ArrayList<String[]>();
        for (DBObject entity : list) {
            String json = entity.toString();
            WmPerInfoDTO wmPerInfo = com.alibaba.fastjson.JSON.parseObject(json, WmPerInfoDTO.class);
            String[] contact =
                    {
                            wmPerInfo.getPerName(),
                            wmPerInfo.getPerEmail(),
                            wmPerInfo.getPerPhone(),
                            wmPerInfo.getPerProvinceName(),
                            wmPerInfo.getPerCityName(),
                            wmPerInfo.getPerCountyName(),
                            wmPerInfo.getPerStreetName(),
                            wmPerInfo.getPerDetailAddrss(),
                            wmPerInfo.getPerRemark()
                    };
//            {"姓名", "邮箱地址", "手机号码", "省", "市", "县/区", "乡镇/街道", "详细地址", "备注"};
            contacts.add(contact);
        }
        contactPath = CVSUtils.writeCsv(loginEmail, contacts);

        response.setContentType("application/x-msdownload");
        response.setHeader("Content-Disposition", "attachment;filename=contact.csv");
        is = new BufferedInputStream(new FileInputStream(contactPath));
        if (null != is){
            os = new DataOutputStream(response.getOutputStream());
            IOUtils.copy(is, os);
            os.flush();
        }
    } catch (Exception e) {
        logger.error("当前下载的附件不存在,或者下载附件错误", e);
    }
    finally {
        IOUtils.closeQuietly(is);
        IOUtils.closeQuietly(os);
        File file = new File(contactPath);
        file.delete();
    }

}

CSVUtils.java

/**
 * CSV文件导出工具类
 */
public class CVSUtils {
    public static final String FILE_EXTENSIONS = ".csv";
    public static final String CONTACT_FOLDER = "contact";
    public static final String CONTACT_PATH = CVSUtils.class.getClassLoader().getResource("/").getPath();
    public static final String[] heads = {"姓名", "邮箱地址", "手机号码", "省", "市", "县/区", "乡镇/街道", "详细地址", "备注"};

    //读取csv文件
    public static List<String[]> readCsv(String filePath) throws Exception {
        List<String[]> csvList = new ArrayList<String[]>();
        if (isCsv(filePath)) {
            CsvReader reader = new CsvReader(filePath, ',', Charset.forName("GBK"));

            while (reader.readRecord()) { //逐行读入除表头的数据
                csvList.add(reader.getValues());
            }
            reader.close();
        } else {
            System.out.println("此文件不是CSV文件!");
            throw new RuntimeException("此文件不是CSV文件!");
        }
        return csvList;
    }

    //判断是否是csv文件
    private static boolean isCsv(String fileName) {
        return fileName.matches("^.+\\.(?i)(csv)$");
    }

    //写入csv文件并返回文件路径
    public static String writeCsv(String fileName, List<String[]> contents) {
        try {
            String filePath = CONTACT_PATH.substring(0, CONTACT_PATH.length() - 8);
            String fileNameTemp = System.currentTimeMillis() + fileName + FILE_EXTENSIONS;
            String fileQualifiedName = filePath + CONTACT_FOLDER + File.separator + fileNameTemp;
            File csvFile = new File(fileQualifiedName);
            File parent = csvFile.getParentFile();//得到父目录
            if (parent != null && !parent.exists()) {
                parent.mkdirs();//创建文件夹
            }
            csvFile.createNewFile();//创建具体的文件

            CsvWriter wr = new CsvWriter(fileQualifiedName, ',', Charset.forName("GBK"));
            wr.writeRecord(heads);
            if (contents != null && contents.size() > 0) {
                for (String[] content : contents) {
                    wr.writeRecord(content);
                }
            }
            wr.close();
            return fileQualifiedName;
        } catch (IOException e) {
            e.printStackTrace();
            return null;
        }
    }

//    public static void writeCsv(Class<?> clazz) {
//        // Get all the declared fields
//        Field[] fields = clazz.getDeclaredFields();
//        LinkedList<Field> fieldList = new LinkedList<Field>();
//        int length = fields.length;
//        for (int i = -1; ++i < length; ) {
//            boolean isStaticField = Modifier.isStatic(fields[i].getModifiers());
//            if (isStaticField)
//                continue;
//            boolean isTransientField = Modifier.isTransient(fields[i].getModifiers());
//            if (isTransientField)
//                continue;
//            fieldList.add(fields[i]);
//        }
//        System.out.println(clazz.getName());
//    }
}

所需jar包

<dependency>
    <groupId>org.jumpmind.symmetric</groupId>
    <artifactId>symmetric-csv</artifactId>
    <version>3.5.19</version>
</dependency>
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 本文包括:1、文件上传概述2、利用 Commons-fileupload 组件实现文件上传3、核心API——Dis...
    廖少少阅读 12,587评论 5 91
  • 最近在一个项目中碰到了下载附件的需求,自己撸了一下,效果不是很理想,文件类型,以及浏览器的兼容性,这方面处理的不是...
    ITtian阅读 2,492评论 3 2
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,869评论 18 139
  • github地址,欢迎大家提交更新。 express() express()用来创建一个Express的程序。ex...
    Programmer客栈阅读 2,588评论 0 1
  • 越来越觉得拍照特别麻烦。冰冻鱿鱼须超市打特价买了一些炒,配合着鸡胸肉,西芹,就搞定了这一周的便当。上图吧。 西芹炒...
    词穷又词贫阅读 137评论 0 0