取出数据库表中的内容写入到文件,并将所有文件写入到压缩包最终导出到指定的某目录下
//导出的压缩包格式 xxxx_date
Date currentTime = new Date();
//格式化日期格式将yyyy-MM-dd HH:mm:ss 格式转换成xxxxxxxxx格式(去掉中间符号)
SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMddHHmmss");
String dateString = formatter.format(currentTime);
//1.创建文件夹
String usrHome = configBackPath;//获取到系统目录(configBackPath 是在配置文件中配置的一个路径,通过注入的方式获取)
String path = usrHome + taskParams.getTaskPath()+ "\\";//创建的文件夹路径 path + (taskParams.getTaskPath()_该方式是从数据 库中获取的用户自定义的路径,既配置路径+自定义路径)
//在当前路径下配置文件夹
File file = new File(path);
//如果不存在则创建
if(!file.exists()){
file.mkdirs();
}
//声明文件格式
File zipFile = null;
//写入流
FileInputStream fis = null;
//输出流
FileOutputStream fos = null;
//zip写入流
ZipOutputStream zos = null;
try {
//在此路径下创建压缩包,命名规则为,例:configbackup_20181030101232.tar.gz
zipFile = new File(path +"configbackup_"+ dateString +".tar.gz");
//执行创建
zipFile.createNewFile();
fos = new FileOutputStream(zipFile);
zos = new ZipOutputStream(fos);
//定义两个布尔变量,用于判断前端勾选的命名规则1、2、3
boolean isExistName = false, isExistDate = false;
//获取数据库中保存的命名规则
String namingRules = taskParams.getTaskFileFormat();
String[] nameRanges = namingRules.split(",");
//判断其是否被勾选
for (String nameRange : nameRanges) {
if("2".equals(nameRange)){
isExistName = true;
}
if("3".equals(nameRange)){
isExistDate = true;
}
}
//configData是数据源,List,其中list中包含一个list
for (int i = 0; i < configDatas.size(); i++) {
//创建一个StringBuilder
StringBuilder conName = new StringBuilder();
//循环获取对象
ConfigData data = configDatas.get(i);
//循环对象中的list
for (ConfigItem conItem : data.getConfigs()) {
//该赋值需求 默认命名规则1 + other
conName.append(data.getDeviceIp() + "_" + conItem.getName());
//如果规则2被选中
if(isExistName){
//将2添加到命名规则中
conName.append("_" + data.getDeviceName());
log.info("勾选了设备名称" + conName);
}
//如果勾选了3
if(isExistDate){
try {
//将3的命名规则添加到命名中,因为此时数据中存储的时间格式与需求不同,所以在此做一下转换
Date date = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(data.getEndTimeStr());
String nowTime = new SimpleDateFormat("yyyyMMddHHmmss").format(date);
conName.append("_" + nowTime);
log.info("勾选了时间" + conName);
} catch (ParseException e) {
e.printStackTrace();
}
}
//获取最终命名的规则(此处以.txt命名,也可以其它方式命名)
String name = new String((conName).toString().getBytes("UTF-8"))+ ".txt";
log.info("最终命名" + name);
//创建ZIP实体,并添加进压缩包
ZipEntry zipEntry = new ZipEntry(name);
zos.putNextEntry(zipEntry);
//读取待压缩的文件并写进压缩包里
zos.write(conItem.getContent().getBytes("UTF-8"));
}
}
//最终记得要关闭流
zos.flush();
zos.close();
} catch (IOException e) {
log.error(e);
log.error("下载失败---->", e);
} finally{
try {
if(fis != null){
fis.close();
}
if(fos != null){
fos.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}