导出csv并压缩

public byte[] getCSVDataByte(MarketingStatisticsQueryDTO dto, StatisticsFileMark statisticsFileMark) {
    String fileName = statisticsFileMark.getName() + FILE_END;
StopWatch stopWatch = new StopWatch("电销自定义报表导出" + fileName);
    try {
        log.info("CSV电销自定义报表导出{},[{}]", fileName, dto);
stopWatch.start("参数处理");
MarketingStatisticsQueryDTO queryDTO = queryTableData(dto);
stopWatch.stop();
log.info("CSV电销营销统计报表查询参数queryDTO:{}", queryDTO);
stopWatch.start("数据查询");
List<MarketingStatisticsRespVO> result = marketingStatisticsMapper.queryMarketingStatisticsData(queryDTO);
stopWatch.stop();
log.info("CSV电销营销统计报表导出{},共计:{}条数据", fileName, result.size());

stopWatch.start("数据导出");
        try (ByteArrayOutputStream csvByteArrayOutputStream = new ByteArrayOutputStream();
BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(csvByteArrayOutputStream, "GBK"));
CSVPrinter csvPrinter = new CSVPrinter(writer, CSVFormat.DEFAULT.withHeader(columnToHeader(dto)))) {
            for (MarketingStatisticsRespVO vo : result) {
                switch (statisticsFileMark) {
                    case SD:
                        csvPrinter.printRecord(vo.getImportDate(), vo.getProduct(), vo.getStage(), vo.getStrategyLabel(), vo.getStreamLabel(), vo.getFirstDrawCashDate(), vo.getQuota(), vo.getMarketSign(), vo.getListNum(), vo.getDrawCashNum());
                        break;
                    case SIGN:
                        csvPrinter.printRecord(vo.getImportDate(), vo.getFirstDrawCashDate(), vo.getSignDate(), vo.getMarketSign(), vo.getProduct(), vo.getStage(), vo.getStrategyLabel(), vo.getStreamLabel(), vo.getTerminalScore(), vo.getCustType(), vo.getListNum(), vo.getDrawCashNum(), vo.getSignNum());
                        break;
                    case AI:
                        csvPrinter.printRecord(vo.getImportDate(), vo.getProduct(), vo.getStage(), vo.getFirstDrawCashDate(), vo.getLoanDate(), vo.getMarketSign(), vo.getGrade(), vo.getStrategyLabel(), vo.getStreamLabel(), vo.getMarketSign(), vo.getListNum(), vo.getLoanNum(), vo.getTotalLoanAmount(), vo.getTotalDrawCashAmount());
                        break;
                    case LOAN:
                        csvPrinter.printRecord(vo.getImportDate(), vo.getFirstDrawCashDate(), vo.getLoanDate(), vo.getAgentName(), vo.getAgentNo(), vo.getOnsite(), vo.getMarketSign(), vo.getProduct(), vo.getStage(), vo.getStrategyLabel(), vo.getStreamLabel(), vo.getTerminalScore(), vo.getCustType(), vo.getDrawCashNum(), vo.getSignNum(), vo.getLoanNum(), vo.getTotalSignAmount(), vo.getTotalLoanAmount(), vo.getTotalDrawCashAmount());
                        break;
                    case ALL:
                        csvPrinter.printRecord(vo.getImportDate(), vo.getFirstDrawCashDate(), vo.getMarketSign(), vo.getProduct(), vo.getStage(), vo.getDecisionCompleteType(), vo.getGrade(), vo.getStrategyLabel(), vo.getStreamLabel(), vo.getOverallDrawCash(), vo.getQuota(), vo.getMarketingRuleId(), vo.getQuotaGrade(), vo.getTerminalScore(), vo.getCustType(), vo.getQuotaCno(), vo.getQuotaProcess(), vo.getSignDate(), vo.getLoanDate(), vo.getListNum(), vo.getDrawCashNum(), vo.getSignNum(), vo.getLoanNum(), vo.getTotalSignAmount(), vo.getTotalLoanAmount(), vo.getTotalDrawCashAmount());
                        break;
                    default:
                        break;
}
                csvPrinter.flush();
}

            try (ByteArrayOutputStream zipByteArrayStream = new ByteArrayOutputStream();
ZipOutputStream zipOutputStream = new ZipOutputStream(zipByteArrayStream)) {
                ZipEntry zipEntry = new ZipEntry(fileName);
zipOutputStream.putNextEntry(zipEntry);
zipOutputStream.write(csvByteArrayOutputStream.toByteArray());
zipOutputStream.closeEntry();
zipOutputStream.close();
stopWatch.stop();
                return zipByteArrayStream.toByteArray();
} catch (Exception e) {
                log.error("CSV电销营销统计报表压缩异常！", e);
}
        }
    } catch (Exception e) {
        log.error("CSV电销营销统计报表导出异常！", e);
} finally {
        if (stopWatch.isRunning()) {
            stopWatch.stop();
}
        log.info("CSV电销营销统计报表导出,耗时:{}", stopWatch.prettyPrint(TimeUnit.MILLISECONDS));
}
    return new byte[0];
}
//发邮件

private void createMailMessageSendDTO(byte[] fileByte, String fileName, String email) {
    log.info("电销自定义报表自动发送邮件:{}", email);
    if (StringUtils.isNotBlank(email)) {
        try {
            MailMessageSendDTO mailMessageSendDTO = new MailMessageSendDTO();
mailMessageSendDTO.setSubject(fileName);
mailMessageSendDTO.setText("请查看附件获取电销自定义报表。");
mailMessageSendDTO.setTo(email);
mailMessageSendDTO.setSendId("1");
mailMessageSendDTO.setSendName("system");
List<FileTranDTO> fileTranDTOList = new ArrayList<>();
FileTranDTO fileTranDTO = new FileTranDTO();
fileTranDTO.setFileName("电销自定义报表" + fileName + ".zip");
fileTranDTO.setFileByte(fileByte);
fileTranDTOList.add(fileTranDTO);
FileTranListDTO fileTranListDTO = new FileTranListDTO();
fileTranListDTO.setFileList(fileTranDTOList);
mailMessageSendDTO.setAttachment(fileTranListDTO);
// 发送邮件
remoteEmailService.send(mailMessageSendDTO);
log.info("电销自定义报表邮件发送成功-{}", fileName);
} catch (Exception e) {
            log.error("电销自定义报表邮件发送失败", e);
}
    }
}