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

一写代码就开心

发布于 2024-01-09 06:17:51

26400

代码可运行

文章被收录于专栏：java和pythonjava和python

运行总次数：0

代码可运行

1 问题

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

2 实现

 @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("录入成功");
    }