A 用户将自己的数据文件,放到 一个文件夹下,B 用户需要写一个代码,定时将 公共文件夹下的数据,复制到自己的文件夹下,然后对数据进行入库与 去重。防止将相同数据入库
@ApiOperation(value = "报告文件 数据入库", httpMethod = "POST")
@PostMapping("/insertFileInfo")
public Result insertFileInfo(String path) {
ArrayList<String> elelist = new ArrayList<>();
StringInfoUtils.readFiles(path,elelist, Pattern.compile("^*.docx$"));
if(elelist!=null && elelist.size()>0){
ArrayList<ZpReportContents> objects = new ArrayList<>();
for(String item : elelist) {
File file = new File(item);
// 202309
String data = file.getParentFile().getName();
// 本地文件
File tmpFile = new File(Const.reportPath + File.separator + data + File.separator + file.getName());
if (!new File(tmpFile + ".ok").exists()) {
// 进行解析入库
String copyPath = Const.reportPath + File.separator + data;
File copy = new File(copyPath + File.separator);
if (!copy.exists())
copy.mkdirs();
FileUtil.copy(file.getPath(),copyPath,true);
String copyFile = copyPath + File.separator + file.getName();
try {
ZpReportContents zpReportContents = zpReportContentsService.insertFileInfo(copyFile);
objects.add(zpReportContents);
} catch (Exception e) {
e.printStackTrace();
}
try{
new File(copyFile+".ok").createNewFile();
} catch (Exception e){
e.getMessage();
}
}
}
System.out.println("解析完成");
// 批量入库
if(objects!=null && objects.size()>0){
List<List<ZpReportContents>> lists = Lists.partition(objects,BJTYPHOON_LENHTH);
for (List<ZpReportContents> list : lists){
// pg数据入库
zpReportContentsMapper.batchInsert(list);
System.out.println("插入成功-----");
//baseMapper.saveOrUpdateBatch(list);
}
System.out.println("插入成功");
}
}
return ResultUtil.ok("录入成功");
}