将 公共文件夹下的数据,复制到自己的文件夹下,然后对数据进行入库与 去重。防止将相同数据入库

2024-01-09 14:17:51 浏览数 (1)

目录
  • 1 问题
  • 2 实现

1 问题

A 用户将自己的数据文件,放到 一个文件夹下,B 用户需要写一个代码,定时将 公共文件夹下的数据,复制到自己的文件夹下,然后对数据进行入库与 去重。防止将相同数据入库

2 实现

代码语言:javascript复制
 @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("录入成功");
    }

0 人点赞